http_server.c 55 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090
  1. #if defined HARDWARE_BT6706 || HARDWARE_BT6708
  2. #include "lwip/arch.h"
  3. #include "lwip/api.h"
  4. #include "lwip/tcp.h"
  5. #include "http_server.h"
  6. #include "web_params_api.h"
  7. #include "parameters.h"
  8. #include "urlcode.h"
  9. #include "trap_params.h"
  10. #ifdef HARDWARE_BT6706
  11. #include "bt6706_fs/fsdata.c"
  12. #elif HARDWARE_BT6708
  13. #include "bt6708_fs/fsdata.c"
  14. #endif
  15. #include "settings_api.h"
  16. #include "netconf.h"
  17. #include "common_config.h"
  18. #include "testing.h"
  19. #include "rtc.h"
  20. #include "rng.h"
  21. #include "megatec.h"
  22. #include "log.h"
  23. #include "hal.h"
  24. #include "sntp_api.h"
  25. #ifdef PRINTF_STDLIB
  26. #include <stdio.h>
  27. #endif
  28. #ifdef PRINTF_CUSTOM
  29. #include "tinystdio.h"
  30. #endif
  31. #include <string.h>
  32. #include <stdlib.h>
  33. #include "FreeRTOS.h"
  34. #include "task.h"
  35. #include "fr_timers.h"
  36. static int fs_open(char *name, struct fs_file *file);
  37. static err_t http_sent(void *arg, struct tcp_pcb *pcb, u16_t len);
  38. static err_t http_sent_history(void *arg, struct tcp_pcb *pcb, u16_t len);
  39. static err_t http_sent_log(void *arg, struct tcp_pcb *pcb, u16_t len);
  40. static void http_sent_log_err(void * arg, err_t err);
  41. static void send_data(struct tcp_pcb *pcb, struct http_state *hs);
  42. static void HTTP_GetUserCookie(uint8_t user_id, char *str, uint8_t *len);
  43. static uint32_t Parse_Content_Length(char *data, uint32_t len);
  44. static void HTTP_SetUserCookie(char *str, uint8_t user_id);
  45. static void HTTP_UpdateUserLoginTime(uint8_t user_id);
  46. static void HTTP_ForceUserLogout(uint8_t user_id);
  47. void LogoutTimerCallback(TimerHandle_t pxTimer);
  48. void LoginTimerCallback(TimerHandle_t pxTimer);
  49. int HTTP_ChangeUserPwd(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut);
  50. char* send_file(char *filename, char *pnonmatch, struct fs_file *file, uint16_t *Len);
  51. static uint32_t Parse_Header(char *data, uint32_t len, const char *field, uint32_t flen, char *value);
  52. bool GetFileName(char *inStr, char *fileName, uint8_t *fileNameLen);
  53. REQ_TYPE_SEND_t HTTPTypeAnswer = COMMON_ANSWER;
  54. #define SEND_BUF_MAX_LEN 2000
  55. #define RECIVE_BUF_MAX_LEN 1500
  56. char sendBuf[SEND_BUF_MAX_LEN];
  57. uint16_t sendBufLoadLen = 0;
  58. uint16_t printLen = 0;
  59. char receiveBuf[RECIVE_BUF_MAX_LEN];
  60. uint16_t receivedBufLen = 0;
  61. #define MAX_POST_REQ_LEN 256
  62. char post_req_data[MAX_POST_REQ_LEN];
  63. uint32_t post_data_count = 0;
  64. uint32_t log_post_reqn;
  65. /* Logout timeout, 30 minutes */
  66. #define WEB_LOGOUT_TIME configTICK_RATE_HZ*60*30
  67. /* Max user active sessions count */
  68. #define WEB_USER_MAX_SESSION_COUNT 5
  69. struct {
  70. //auth_session_t session[WEB_USER_MAX_SESSION_COUNT];
  71. char cookie[MAX_WEB_COOKIE_LEN];
  72. TimerHandle_t LogoutTimer;
  73. } users[MAX_WEB_USERS];
  74. TimerHandle_t RepeatLoginTimer;
  75. /* Repeat Login timeout, 1 minutes */
  76. #define REPEAT_LOGIN_TIME configTICK_RATE_HZ*60*1
  77. uint8_t cnt_err_psw = 0;
  78. bool Authenticated = false;
  79. /* Level of currently logged-in user */
  80. uint8_t seclevel = 0xFF;
  81. /* Max HTTP file name length including "/" */
  82. #define MAX_FILENAME_LEN 32
  83. /* Max HTTP Etag field length */
  84. #define MAX_ETAG_LEN 48
  85. static const char If_None_Match[] = "If-None-Match: ";
  86. static const char Etag[] = "ETag: ";
  87. static volatile uint32_t DataFlag2=0;
  88. static volatile uint32_t DataFlag=0;
  89. static volatile uint32_t size =0;
  90. static uint32_t TotalReceived=0;
  91. static volatile uint32_t TotalData=0;
  92. static uint32_t ContentLengthOffset =0, BrowserFlag=0;
  93. static const char Content_Length[17] =
  94. /* Content Length */
  95. {0x43, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2d, 0x4c, 0x65, 0x6e, 0x67,0x74, 0x68, 0x3a, 0x20, };
  96. const char HTTP_304_NOT_MODIFIED[] = "HTTP/1.1 304 Not Modified\r\n\r\n";
  97. const char HTTP_403_NOT_WHITE_LIST[] = "HTTP/1.1 403 Forbidden\r\n\r\n";
  98. const char HTTP_200_OK[] = "HTTP/1.1 200 OK\r\n\r\n";
  99. /* utf-8 marker to support MS Excel */
  100. const char UTF8_BOM[] = {0xEF, 0xBB, 0xBF, 0x00};
  101. unsigned long log_ptr = 0;
  102. unsigned long log_size = 0;
  103. bool fLogTransInprog = false;
  104. /**
  105. * @brief Общая структура настроек
  106. */
  107. extern SETTINGS_t sSettings;
  108. char CookieBuf[51];
  109. char *CookiePtr = NULL;
  110. char name[MAX_WEB_COOKIE_LEN];
  111. char id[MAX_WEB_COOKIE_LEN];
  112. uint8_t nameLen = 0, idLen = 0;
  113. uint8_t user_id; // Id of currently logged-in user
  114. struct fs_file file = {0, 0};
  115. /**
  116. * @brief closes tcp connection
  117. * @param pcb: pointer to a tcp_pcb struct
  118. * @param hs: pointer to a http_state struct
  119. * @retval
  120. */
  121. static void close_conn(struct tcp_pcb *pcb, struct http_state *hs)
  122. {
  123. tcp_arg(pcb, NULL);
  124. tcp_sent(pcb, NULL);
  125. tcp_recv(pcb, NULL);
  126. mem_free(hs);
  127. tcp_close(pcb);
  128. }
  129. /**
  130. * @brief callback function for handling TCP HTTP traffic
  131. * @param arg: pointer to an argument structure to be passed to callback function
  132. * @param pcb: pointer to a tcp_pcb structure
  133. * @param p: pointer to a packet buffer
  134. * @param err: LwIP error code
  135. * @retval err
  136. */
  137. static err_t http_recv(void *arg, struct tcp_pcb *pcb, struct pbuf *p, err_t err)
  138. {
  139. char *data;
  140. struct http_state *hs;
  141. struct fs_file file = {0, 0};
  142. char buf[150];
  143. hs = arg;
  144. if (err == ERR_OK && p != NULL)
  145. {
  146. tcp_recved(pcb, p->tot_len);
  147. if (hs->file == NULL)
  148. {
  149. data = p->payload;
  150. receivedBufLen = p->tot_len;
  151. memcpy(receiveBuf, p->payload , receivedBufLen);
  152. /* Cut received string */
  153. receiveBuf[receivedBufLen] = '\0';
  154. if (strncmp(data, "GET /setProdate.cgi", 19) == 0 && strncmp(sSettings.sFlags.testState, "T2OK", 4))
  155. {
  156. HTTP_Prodate(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen);
  157. hs->file = sendBuf;
  158. hs->left = sendBufLoadLen;
  159. send_data(pcb, hs);
  160. tcp_sent(pcb, http_sent);
  161. }
  162. else{
  163. Cockie();
  164. if( DataFlag == 0 && DataFlag2 == 0 ){
  165. getAuthenticatedState();
  166. }
  167. if (DataFlag >= 1)
  168. Authenticated = true;
  169. else if(DataFlag2 >= 1)
  170. Authenticated = true;
  171. if (!Authenticated)
  172. {
  173. hs->file = AuthenticatedFalseRoutine(&sendBufLoadLen);
  174. hs->left = sendBufLoadLen;
  175. send_data(pcb, hs);
  176. tcp_sent(pcb, http_sent);
  177. }
  178. else
  179. {
  180. HTTPTypeAnswer = COMMON_ANSWER;
  181. hs->file = AuthenticatedTrueRoutine(&sendBufLoadLen);
  182. hs->left = sendBufLoadLen;
  183. if(hs->file != 0){
  184. send_data(pcb, hs);
  185. switch(HTTPTypeAnswer){
  186. case HISTORY_ANSWER:
  187. tcp_sent(pcb, http_sent_history);
  188. break;
  189. case UPS_HISTORY_ANSWER:
  190. tcp_sent(pcb, http_sent_log);
  191. break;
  192. default:
  193. tcp_sent(pcb, http_sent);
  194. break;
  195. }
  196. }
  197. }
  198. }
  199. }
  200. pbuf_free(p);
  201. }
  202. return ERR_OK;
  203. }
  204. /**
  205. * @brief Sent callback for log file transfer (messages as is, not ordered)
  206. */
  207. static err_t http_sent_history(void *arg, struct tcp_pcb *pcb, u16_t len)
  208. {
  209. struct http_state *hs;
  210. uint32_t nbytes = 0;
  211. static bool start = true;
  212. (void)len;
  213. hs = arg;
  214. if (hs->left > 0)
  215. {
  216. send_data(pcb, hs);
  217. }
  218. else
  219. {
  220. memset(logFileBuf, 0, FILE_BUF_MAX_LEN);
  221. if (log_ptr + FILE_BUF_MAX_LEN <= log_size) {
  222. nbytes = History_GetData(log_ptr, logFileBuf, FILE_BUF_MAX_LEN, start);
  223. }
  224. else if (log_ptr < log_size) {
  225. nbytes = History_GetData(log_ptr, logFileBuf, (log_size - log_ptr), start);
  226. }
  227. else {
  228. nbytes = 0;
  229. }
  230. log_ptr += nbytes;
  231. start = false;
  232. if (nbytes == 0) {
  233. /* File transfer finished. */
  234. start = true;
  235. close_conn(pcb, hs);
  236. /* Clear file transfer in progress flag */
  237. fLogTransInprog = false;
  238. return ERR_OK;
  239. }
  240. hs->file = logFileBuf;
  241. hs->left = nbytes;
  242. send_data(pcb, hs);
  243. tcp_sent(pcb, http_sent_history);
  244. }
  245. return ERR_OK;
  246. }
  247. /**
  248. * @brief Sent callback for log file transfer (messages as is, not ordered)
  249. */
  250. static err_t http_sent_log(void *arg, struct tcp_pcb *pcb, u16_t len)
  251. {
  252. struct http_state *hs;
  253. uint32_t nbytes = 0;
  254. static bool start = true;
  255. (void)len;
  256. hs = arg;
  257. if (hs->left > 0)
  258. {
  259. send_data(pcb, hs);
  260. }
  261. else
  262. {
  263. memset(logFileBuf, 0, FILE_BUF_MAX_LEN);
  264. if (log_ptr + FILE_BUF_MAX_LEN_LOG <= log_size) {
  265. nbytes = LOG_GetData(log_ptr, logFileBuf, FILE_BUF_MAX_LEN_LOG, start);
  266. }
  267. else if (log_ptr < log_size) {
  268. nbytes = LOG_GetData(log_ptr, logFileBuf, (log_size - log_ptr), start);
  269. }
  270. else {
  271. nbytes = 0;
  272. }
  273. log_ptr += nbytes;
  274. start = false;
  275. if (nbytes == 0) {
  276. /* File transfer finished. */
  277. start = true;
  278. close_conn(pcb, hs);
  279. /* Clear file transfer in progress flag */
  280. fLogTransInprog = false;
  281. return ERR_OK;
  282. }
  283. hs->file = logFileBuf;
  284. hs->left = nbytes;
  285. send_data(pcb, hs);
  286. tcp_sent(pcb, http_sent_log);
  287. }
  288. return ERR_OK;
  289. }
  290. /**
  291. * @brief Error callback for log file transfer
  292. */
  293. static void http_sent_log_err(void * arg, err_t err)
  294. {
  295. (void)err;
  296. (void)arg;
  297. /* Clear file transfer in progress flag */
  298. fLogTransInprog = false;
  299. }
  300. /**
  301. * @brief callback function for handling connection errors
  302. * @param arg: pointer to an argument to be passed to callback function
  303. * @param err: LwIP error code
  304. * @retval none
  305. */
  306. static void conn_err(void *arg, err_t err)
  307. {
  308. struct http_state *hs;
  309. hs = arg;
  310. mem_free(hs);
  311. }
  312. /**
  313. * @brief callback function called after a successfull TCP data packet transmission
  314. * @param arg: pointer to an argument to be passed to callback function
  315. * @param pcb: pointer on tcp_pcb structure
  316. * @param len
  317. * @retval err : LwIP error code
  318. */
  319. static err_t http_sent(void *arg, struct tcp_pcb *pcb, u16_t len)
  320. {
  321. struct http_state *hs;
  322. hs = arg;
  323. if (hs->left > 0)
  324. {
  325. send_data(pcb, hs);
  326. }
  327. else
  328. {
  329. close_conn(pcb, hs);
  330. }
  331. return ERR_OK;
  332. }
  333. /**
  334. * @brief sends data found in member "file" of a http_state struct
  335. * @param pcb: pointer to a tcp_pcb struct
  336. * @param hs: pointer to a http_state struct
  337. * @retval none
  338. */
  339. static void send_data(struct tcp_pcb *pcb, struct http_state *hs)
  340. {
  341. err_t err;
  342. u16_t len;
  343. /* We cannot send more data than space available in the send
  344. buffer */
  345. if (tcp_sndbuf(pcb) < hs->left)
  346. {
  347. len = tcp_sndbuf(pcb);
  348. }
  349. else
  350. {
  351. len = hs->left;
  352. }
  353. err = tcp_write(pcb, hs->file, len, 0);
  354. if (err == ERR_OK)
  355. {
  356. hs->file += len;
  357. hs->left -= len;
  358. }
  359. }
  360. /**
  361. * @brief tcp poll callback function
  362. * @param arg: pointer to an argument to be passed to callback function
  363. * @param pcb: pointer on tcp_pcb structure
  364. * @retval err_t
  365. */
  366. static err_t http_poll(void *arg, struct tcp_pcb *pcb)
  367. {
  368. if (arg == NULL)
  369. {
  370. tcp_close(pcb);
  371. }
  372. else
  373. {
  374. send_data(pcb, (struct http_state *)arg);
  375. }
  376. return ERR_OK;
  377. }
  378. /**
  379. * @brief callback function on TCP connection setup ( on port 80)
  380. * @param arg: pointer to an argument structure to be passed to callback function
  381. * @param pcb: pointer to a tcp_pcb structure
  382. * &param err: Lwip stack error code
  383. * @retval err
  384. */
  385. static err_t http_accept(void *arg, struct tcp_pcb *pcb, err_t err)
  386. {
  387. struct http_state *hs;
  388. /* set priority for the newly accepted tcp connection newpcb */
  389. tcp_setprio(pcb, TCP_PRIO_MIN);
  390. /* Allocate memory for the structure that holds the state of the connection */
  391. hs = mem_malloc(sizeof(struct http_state));
  392. if (hs == NULL)
  393. {
  394. return ERR_MEM;
  395. }
  396. /* Initialize the structure. */
  397. hs->file = NULL;
  398. hs->left = 0;
  399. /* Tell TCP that this is the structure we wish to be passed for our
  400. callbacks. */
  401. tcp_arg(pcb, hs);
  402. /* Tell TCP that we wish to be informed of incoming data by a call
  403. to the http_recv() function. */
  404. tcp_recv(pcb, http_recv);
  405. tcp_err(pcb, conn_err);
  406. tcp_poll(pcb, http_poll, 10);
  407. return ERR_OK;
  408. }
  409. /**
  410. * @brief Opens a file defined in fsdata.c ROM filesystem
  411. * @param name : pointer to a file name
  412. * @param file : pointer to a fs_file structure
  413. * @retval 1 if success, 0 if fail
  414. */
  415. static int fs_open(char *name, struct fs_file *file)
  416. {
  417. struct fsdata_file_noconst *f;
  418. for (f = (struct fsdata_file_noconst *)FS_ROOT; f != NULL; f = (struct fsdata_file_noconst *)f->next)
  419. {
  420. if (!strcmp(name, f->name))
  421. {
  422. file->data = f->data;
  423. file->len = f->len;
  424. return 1;
  425. }
  426. }
  427. return 0;
  428. }
  429. /**
  430. * @brief Initialize the HTTP server (start its thread)
  431. * @param none
  432. * @retval None
  433. */
  434. void HTTP_Init()
  435. {
  436. char buf[MAX_WEB_COOKIE_LEN];
  437. uint8_t user_id;
  438. err_t err;
  439. struct tcp_pcb *pcb;
  440. /*create new pcb*/
  441. pcb = tcp_new_ip_type(IPADDR_TYPE_ANY);
  442. LWIP_ASSERT("httpd_init: tcp_new failed", pcb != NULL);
  443. /* set lowest prio to HTTP connections */
  444. //tcp_setprio(pcb, TCP_PRIO_MIN);
  445. /* bind HTTP traffic to pcb */
  446. err = tcp_bind(pcb, IP_ANY_TYPE, 80);
  447. LWIP_UNUSED_ARG(err); /* in case of LWIP_NOASSERT */
  448. LWIP_ASSERT("httpd_init: tcp_bind failed", err == ERR_OK);
  449. /* start listening on port 80 */
  450. pcb = tcp_listen(pcb);
  451. /* define callback function for TCP connection setup */
  452. tcp_accept(pcb, http_accept);
  453. for (user_id = 0; user_id < MAX_WEB_USERS; user_id++) {
  454. /* Flush user cookie by random value */
  455. sprintf(buf, "%X", (unsigned int)GetRandomNumber());
  456. HTTP_SetUserCookie(buf, user_id);
  457. /* Create user logout timers */
  458. users[user_id].LogoutTimer =
  459. xTimerCreate("LogoutTmr", WEB_LOGOUT_TIME, pdFALSE, ( void * ) user_id, LogoutTimerCallback);
  460. }
  461. RepeatLoginTimer = xTimerCreate("LoginTmr", REPEAT_LOGIN_TIME, pdFALSE, ( void * ) 0, LoginTimerCallback);
  462. }
  463. /**
  464. * @brief
  465. * @retval None
  466. */
  467. int HTTP_SettingsPage(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  468. {
  469. char tempStr[30];
  470. strncpy(tempStr, bufIn, 30);
  471. /* В запросе нет параметров, нужно формировать JSON ответ */
  472. if (strpbrk(tempStr,"?") == 0)
  473. {
  474. memset(bufOut, 0, SEND_BUF_MAX_LEN);
  475. HTTP_GetSettings(bufOut);
  476. *lenBufOut = strlen(bufOut);
  477. return SEND_REQUIRED_YES;
  478. }
  479. /* В запросе есть параметры, нужно парсить и сохранять настройки */
  480. else
  481. {
  482. //HTTP_SetSettings(bufIn, lenBufIn);
  483. return SEND_REQUIRED_NO;
  484. }
  485. }
  486. /**
  487. * @brief
  488. * @retval None
  489. */
  490. int HTTP_InfoPage(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  491. {
  492. char tempStr[30];
  493. strncpy(tempStr, bufIn, 30);
  494. /* В запросе нет параметров, нужно формировать JSON ответ */
  495. if (strpbrk(tempStr,"?") == 0)
  496. {
  497. memset(bufOut, 0, SEND_BUF_MAX_LEN);
  498. HTTP_GetInfo(bufOut);
  499. *lenBufOut = strlen(bufOut);
  500. return SEND_REQUIRED_YES;
  501. }
  502. /* В запросе есть параметры, нужно парсить и сохранять настройки */
  503. else
  504. {
  505. //HTTP_SetInfo(bufIn, lenBufIn);
  506. return SEND_REQUIRED_NO;
  507. /*
  508. HTTP_SetSettings(bufIn, lenBufIn);
  509. return SEND_REQUIRED_NO;
  510. */
  511. }
  512. }
  513. int HTTP_HistoryPage(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  514. {
  515. uint8_t i, valueLen = 0;
  516. char value[20];
  517. uint32_t nbytes = 0;
  518. (void)lenBufIn;
  519. memset(bufOut, 0, FILE_BUF_MAX_LEN);
  520. ClearParamString(bufIn);
  521. memset(value, 0, 20);
  522. GetParamValue(bufIn, "page=", value, &valueLen);
  523. if (strcmp(value, "all") == 0)
  524. {
  525. if (!LOG_IsInit()) {
  526. return SEND_REQUIRED_NO;
  527. }
  528. if (fLogTransInprog == false) {
  529. // Send log as raw data
  530. log_ptr = 0;
  531. log_size = History_GetTotalSTRCount() * STRING_SIZE_HISTORY + sizeof(UTF8_BOM)-1;
  532. sprintf(bufOut, "HTTP/1.1 200 OK\r\nContent-Length:%lu\r\n\r\n%s", log_size, UTF8_BOM);
  533. *lenBufOut = strlen(bufOut);
  534. // Set file transfer in progress flag
  535. fLogTransInprog = true;
  536. return SEND_REQUIRED_FILE;
  537. }
  538. else {
  539. // We send nothing if file transfer already in progress
  540. return SEND_REQUIRED_NO;
  541. }
  542. }
  543. else {
  544. if (!LOG_IsInit()) {
  545. return SEND_REQUIRED_NO;
  546. }
  547. else {
  548. HTTP_GetHistoryPage(bufOut, atoi(value));
  549. *lenBufOut = strlen(bufOut);
  550. return SEND_REQUIRED_YES;
  551. }
  552. }
  553. }
  554. int HTTP_UpsHistoryPage(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  555. {
  556. uint8_t i, valueLen = 0;
  557. char value[20];
  558. uint32_t nbytes = 0;
  559. (void)lenBufIn;
  560. memset(bufOut, 0, FILE_BUF_MAX_LEN);
  561. ClearParamString(bufIn);
  562. memset(value, 0, 20);
  563. GetParamValue(bufIn, "page=", value, &valueLen);
  564. if (strcmp(value, "all") == 0)
  565. {
  566. if (!LOG_IsInit()) {
  567. return SEND_REQUIRED_NO;
  568. }
  569. if (fLogTransInprog == false) {
  570. // Send log as raw data
  571. log_ptr = 0;
  572. log_size = LOG_GetTotalSTRCount() * STRING_SIZE + sizeof(UTF8_BOM)-1;
  573. sprintf(bufOut, "HTTP/1.1 200 OK\r\nContent-Length:%lu\r\n\r\n%s", log_size, UTF8_BOM);
  574. *lenBufOut = strlen(bufOut);
  575. // Set file transfer in progress flag
  576. fLogTransInprog = true;
  577. return SEND_REQUIRED_FILE;
  578. }
  579. else {
  580. // We send nothing if file transfer already in progress
  581. return SEND_REQUIRED_NO;
  582. }
  583. }
  584. else {
  585. if (!LOG_IsInit()) {
  586. return SEND_REQUIRED_NO;
  587. }
  588. else {
  589. HTTP_GetUpsHistoryPage(bufOut, atoi(value));
  590. *lenBufOut = strlen(bufOut);
  591. return SEND_REQUIRED_YES;
  592. }
  593. }
  594. }
  595. /**
  596. * @brief Установка даты производства
  597. */
  598. // TODO Убрать заглушку!
  599. void HTTP_Prodate(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  600. {
  601. uint8_t valueLen = 0;
  602. char value[20];
  603. memset(bufOut, 0, SEND_BUF_MAX_LEN);
  604. ClearParamString(bufIn);
  605. memset(value, 0, 20);
  606. GetParamValue(bufIn, "prodate=", value, &valueLen);
  607. /*
  608. printf("Prodate: ");
  609. printf(value);
  610. printf("\r\n");
  611. */
  612. /* Устанавливаем дату производства */
  613. SETTINGS_SetProDate(value, valueLen);
  614. /* Пока отправляем true */
  615. strcpy(bufOut, "HTTP/1.0 200 OK\r\nContent-Type:text/html\r\n\r\nTrue");
  616. *lenBufOut = strlen(bufOut);
  617. TEST_SetServerFlag();
  618. }
  619. /**
  620. * @brief
  621. * @retval None
  622. */
  623. void HTTP_SetSettings(char *buf, uint16_t lenBuf)
  624. {
  625. uint8_t valueLen = 0;
  626. const uint8_t len = MAX_WEB_PARAM_LEN;
  627. char value[MAX_WEB_PARAM_LEN];
  628. char str[MAX_WEB_PARAM_LEN];
  629. //printf(buf);
  630. //ClearParamString(buf);
  631. memset(value, 0, len);
  632. memset(str, 0, MAX_WEB_PARAM_LEN);
  633. /* SNMP */
  634. GetParamValue(buf, "read_community=", value, &valueLen);
  635. SetReadCommunity(value);
  636. memset(value, 0, len);
  637. GetParamValue(buf, "write_community=", value, &valueLen);
  638. SetWriteCommunity(value);
  639. memset(value, 0, len);
  640. GetParamValue(buf, "managerIP=", value, &valueLen);
  641. SetManagerIp(value);
  642. memset(value, 0, len);
  643. GetParamValue(buf, "managerIP2=", value, &valueLen);
  644. SetManagerIp2(value);
  645. memset(value, 0, len);
  646. GetParamValue(buf, "managerIP3=", value, &valueLen);
  647. SetManagerIp3(value);
  648. memset(value, 0, len);
  649. GetParamValue(buf, "managerIP4=", value, &valueLen);
  650. SetManagerIp4(value);
  651. memset(value, 0, len);
  652. GetParamValue(buf, "managerIP5=", value, &valueLen);
  653. SetManagerIp5(value);
  654. memset(value, 0, len);
  655. #ifdef HARDWARE_BT6708
  656. /* White list */
  657. const char *white_list_set[] =
  658. {
  659. "wtl_ip1=",
  660. "wtl_ip2=",
  661. "wtl_ip3=",
  662. "wtl_ip4=",
  663. "wtl_ip5=",
  664. };
  665. for(uint8_t i = 0; i < MAX_WHITE_LIST; i++){
  666. GetParamValue(buf, white_list_set[i], value, &valueLen);
  667. memset(str, 0, len);
  668. url_decode(str, sizeof(str), value);
  669. SetWhiteListSTR(str, i);
  670. memset(value, 0, len);
  671. }
  672. #endif
  673. /* Сетевые параметры */
  674. GetParamValue(buf, "dhcp=", value, &valueLen);
  675. SetDhcpStateStr(value);
  676. if (strncmp(value, "on", 2) != 0) // Если dhcp off устанавливаем параметры
  677. {
  678. memset(value, 0, len);
  679. GetParamValue(buf, "ipaddr=", value, &valueLen);
  680. SetIPStr(value);
  681. memset(value, 0, len);
  682. GetParamValue(buf, "gw=", value, &valueLen);
  683. SetGatewayStr(value);
  684. memset(value, 0, len);
  685. GetParamValue(buf, "mask=", value, &valueLen);
  686. SetMaskStr(value);
  687. memset(value, 0, len);
  688. }
  689. memset(value, 0, len);
  690. /* Сетевые параметры */
  691. GetParamValue(buf, "tn_enabled=", value, &valueLen);
  692. SetTelnetEnableStateStr(value);
  693. if (strncmp(value, "on", 2) == 0)
  694. {
  695. memset(value, 0, len);
  696. GetParamValue(buf, "tn_port=", value, &valueLen);
  697. SetTelnetPortStr(value);
  698. memset(value, 0, len);
  699. }
  700. memset(value, 0, len);
  701. #ifndef HARDWARE_BT6708
  702. // Параметры реле и сухих контактов
  703. GetParamValue(buf, "di1=", value, &valueLen);
  704. SetDINTypeActStr(value, 0);
  705. memset(value, 0, len);
  706. GetParamValue(buf, "ro1=", value, &valueLen);
  707. SetROTypeActStr(value, 0);
  708. memset(value, 0, len);
  709. GetParamValue(buf, "ro2=", value, &valueLen);
  710. SetROTypeActStr(value, 1);
  711. memset(value, 0, len);
  712. GetParamValue(buf, "ro3=", value, &valueLen);
  713. SetROTypeActStr(value, 2);
  714. memset(value, 0, len);
  715. #endif
  716. GetParamValue(buf, "utc=", value, &valueLen);
  717. SetSntpTimeZoneStr(value);
  718. memset(value, 0, len);
  719. // Параметры даты и времени
  720. GetParamValue(buf, "ntp=", value, &valueLen);
  721. if (strncmp(value, "1", 1) == 0) // Если ntp on устанавливаем параметры
  722. {
  723. bool old_sntp = false;
  724. bool enable_old_sntp = sSettings.sSNTP.sntpEnable;
  725. memset(str, 0, len);
  726. GetParamValue(buf, "ntpservip=", str, &valueLen);
  727. if(strncmp(str, sSettings.sSNTP.ip, valueLen))
  728. old_sntp = true;
  729. SetSntpServerIpStr(str);
  730. SetSntpStateStr(value);
  731. if(sSettings.sSNTP.sntpEnable != enable_old_sntp)
  732. old_sntp = true;
  733. if(old_sntp){
  734. SNTP_Init();
  735. //vTaskDelay(7000);
  736. SNTP_Poll();
  737. }
  738. memset(value, 0, len);
  739. memset(str, 0, len);
  740. }
  741. else if (strncmp(value, "0", 1) == 0){
  742. SetSntpStateStr(value);
  743. memset(value, 0, len);
  744. GetParamValue(buf, "date=", value, &valueLen);
  745. SetDateStr(value);
  746. memset(value, 0, len);
  747. GetParamValue(buf, "time=", value, &valueLen);
  748. memset(str, 0, len);
  749. url_decode(str, sizeof(str), value);
  750. SetTimeStr(str);
  751. memset(value, 0, len);
  752. memset(str, 0, len);
  753. }
  754. GetParamValue(buf, "ups_cell_min=", value, &valueLen);
  755. SetUPSVoltCellMinStr(value);
  756. memset(value, 0, len);
  757. GetParamValue(buf, "ups_cell_max=", value, &valueLen);
  758. SetUPSVoltCellMaxStr(value);
  759. memset(value, 0, len);
  760. GetParamValue(buf, "mainvolt_high=", value, &valueLen);
  761. SetVACAlarmHighRangeStr(value);
  762. memset(value, 0, len);
  763. GetParamValue(buf, "mainvolt_low=", value, &valueLen);
  764. SetVACAlarmLowRangeStr(value);
  765. memset(value, 0, len);
  766. GetParamValue(buf, "mainvolt_hist=", value, &valueLen);
  767. SetVACAlarmHisteStr(value);
  768. memset(value, 0, len);
  769. GetParamValue(buf, "temp_high=", value, &valueLen);
  770. SetTemperatureAlarmHighRangeStr(value);
  771. memset(value, 0, len);
  772. GetParamValue(buf, "temp_low=", value, &valueLen);
  773. SetTemperatureAlarmLowRangeStr(value);
  774. memset(value, 0, len);
  775. GetParamValue(buf, "temp_hist=", value, &valueLen);
  776. SetTemperatureAlarmHisteStr(value);
  777. memset(value, 0, len);
  778. GetParamValue(buf, "loadvolt_high=", value, &valueLen);
  779. SetLoadAlarmHighRangeStr(value);
  780. memset(value, 0, len);
  781. GetParamValue(buf, "loadvolt_hist=", value, &valueLen);
  782. SetLoadAlarmHistStr(value);
  783. memset(value, 0, len);
  784. /* Если параметры WEB изменились выставляем флаг, сохраняем настройки и перезагружаемся */
  785. if (GetStateWebReinit() == true)
  786. {
  787. telnet_act = false;
  788. SetWebReinitFlag(true);
  789. HTTP_SaveSettings();
  790. /* Блокируем управление ключем на тау секунд*/
  791. //IO_KeyBlockOn();
  792. vTaskDelay(1010);
  793. Reboot();
  794. }
  795. telnet_act = false;
  796. HTTP_SaveSettings();
  797. }
  798. /**
  799. * @brief
  800. * @retval None
  801. */
  802. void HTTP_SetInfo(char *buf, uint16_t lenBuf)
  803. {
  804. uint8_t valueLen = 0;
  805. const uint8_t len = 110;
  806. char value[110];
  807. char str[110];
  808. // ClearParamString(buf);
  809. memset(value, 0, len);
  810. /* Название устройства */
  811. GetParamValue(buf, "sysname=", value, &valueLen);
  812. url_decode(str, sizeof(str), value);
  813. SetNameDeviceStr(str);
  814. memset(value, 0, len);
  815. /* Владелец */
  816. GetParamValue(buf, "owner=", value, &valueLen);
  817. url_decode(str, sizeof(str), value);
  818. SetOwner(str);
  819. memset(value, 0, len);
  820. /* Владелец */
  821. GetParamValue(buf, "sysLocation=", value, &valueLen);
  822. url_decode(str, sizeof(str), value);
  823. SetLocation(str);
  824. memset(value, 0, len);
  825. /* Комментарий */
  826. GetParamValue(buf, "comment=", value, &valueLen);
  827. url_decode(str, sizeof(str), value);
  828. SetComment(str);
  829. memset(value, 0, len);
  830. telnet_act = false;
  831. HTTP_SaveSettings();
  832. }
  833. /**
  834. * @brief Запуск/останов теста UPS
  835. */
  836. void HTTP_UPSTest(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  837. {
  838. uint8_t valueLen = 0;
  839. char tempValue[20];
  840. char tempValue2[20];
  841. int8_t res = 0;
  842. char log_string[50];
  843. memset(tempValue, 0, 20);
  844. memset(tempValue2, 0, 20);
  845. memset(log_string, 0,50);
  846. strcpy(bufOut, HTTP_200_OK);
  847. GetParamValue(bufIn, "func=", tempValue, &valueLen);
  848. if (strcmp(tempValue, "stop") == 0){
  849. res = ups_metac_service_pdu(ups_cancel_test);
  850. if(res == 1 || res == 0){
  851. strcat(bufOut, "Тест остановлен!");
  852. strcpy(log_string, name_login);
  853. strcat(log_string, " (Останов)");
  854. log_event_data(LOG_TEST_UPS, log_string);
  855. }
  856. if(res == -1)
  857. strcat(bufOut, "Тест не удалось остановить!");
  858. *lenBufOut = strlen(bufOut);
  859. }
  860. else if (strcmp(tempValue, "discharge") == 0){
  861. res = ups_metac_service_pdu(ups_test_low_bat);
  862. if(res == 1 || res == 0){
  863. strcat(bufOut, "Тест запущен!");
  864. strcpy(log_string, name_login);
  865. strcat(log_string, " (Запущен)");
  866. log_event_data(LOG_TEST_UPS, log_string);
  867. }
  868. if(res == -1)
  869. strcat(bufOut, "Тест не удалось запустить!");
  870. *lenBufOut = strlen(bufOut);
  871. }
  872. else if (strncmp(tempValue, "time", 6) == 0){
  873. GetParamValue(bufIn, "=", tempValue2, &valueLen);
  874. TimeParam = atoi(tempValue2);
  875. res = ups_metac_service_pdu(ups_test_time);
  876. if(res == 1 || res == 0){
  877. strcat(bufOut, "Тест запущен!");
  878. strcpy(log_string, name_login);
  879. strcat(log_string, " (Запущен)");
  880. log_event_data(LOG_TEST_UPS, log_string);
  881. }
  882. if(res == -1)
  883. strcat(bufOut, "Тест не удалось запустить!");
  884. *lenBufOut = strlen(bufOut);
  885. }
  886. }
  887. /**
  888. * @brief Выклюение UPS
  889. */
  890. void HTTP_UPSshutdown(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  891. {
  892. uint8_t valueLen = 0;
  893. char *valueLenEnd = 0;
  894. char tempValue[50];
  895. char tempValue2[50];
  896. int8_t res = 0;
  897. char log_string[50];
  898. memset(tempValue, 0, 50);
  899. memset(log_string, 0,50);
  900. strcpy(bufOut, HTTP_200_OK);
  901. GetParamValue(bufIn, "func=", tempValue, &valueLen);
  902. if (strcmp(tempValue, "reboot") == 0){
  903. res = ups_metac_service_pdu(ups_cancel_shut_down);
  904. if(res == 1){
  905. strcpy(log_string, name_login);
  906. strcat(log_string, " (Останов)");
  907. log_event_data(LOG_SHUTDOWN_UPS, log_string);
  908. strcat(bufOut, "Выключение нагрузки ИБП отменено!");
  909. }
  910. else
  911. strcat(bufOut, "Выключение нагрузки ИБП не удалось отменить!");
  912. *lenBufOut = strlen(bufOut);
  913. }
  914. else if (strncmp(tempValue, "off", 5) == 0){
  915. memset(tempValue2, 0, 50);
  916. GetParamValue(bufIn, "after=", tempValue2, &valueLen);
  917. TimeParamFloat = atof(tempValue2);
  918. res = ups_metac_service_pdu(ups_shutdown);
  919. if(res == 1){
  920. strcat(bufOut, "Отключение нагрузки ИБП!");
  921. log_event_data(LOG_SHUTDOWN_UPS, name_login);
  922. }else
  923. strcat(bufOut, "Отключение нагрузки ИБП не удалось!");
  924. *lenBufOut = strlen(bufOut);
  925. }
  926. }
  927. /**
  928. * @brief Проверка пароля для перехода в режим bootloader
  929. * @retval None
  930. */
  931. void HTTP_ConfirmBootPwd(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  932. {
  933. char tempStr[50];
  934. strncpy(tempStr, bufIn, 50);
  935. char value[20];
  936. uint8_t valueLen;
  937. memset(value, 0, 20);
  938. telnet_act = false;
  939. /* Запускаем задачу отложенной перезагрузки. Контроллер должен успеть
  940. отправить ответ серверу о статусе пароля */
  941. HTTP_StartResetTask(true);
  942. }
  943. void LoginTimerCallback(TimerHandle_t pxTimer) {
  944. cnt_err_psw = 0;
  945. DBG printf("cnt_err_psw %d", cnt_err_psw);
  946. xTimerStop(RepeatLoginTimer, 0);
  947. }
  948. /**
  949. * @brief Проверка пароля для входа в Web
  950. * @retval None
  951. */
  952. int HTTP_ConfirmWebPwd(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  953. {
  954. char tempStr[50];
  955. char login[20];
  956. char password[20];
  957. uint8_t valueLen, user_id;
  958. char *strPtr = 0;
  959. char WebPassword[MAX_WEB_PASSWD_LEN];
  960. char WebLogin[MAX_WEB_LOGIN_LEN];
  961. memset(login, 0, 20);
  962. memset(password, 0, 20);
  963. memset(tempStr, 0, 50);
  964. memset(name_login, 0, 50);
  965. /* Get first 50 bytes of string */
  966. strncpy(tempStr, bufIn, 49);
  967. /* Add " " to the string in order GetParamValue() can be able to parse the param */
  968. strcat(tempStr, " ");
  969. GetParamValue(tempStr, "login=", login, &valueLen);
  970. GetParamValue(tempStr, "password=", password, &valueLen);
  971. for (user_id = 0; user_id < MAX_WEB_USERS; user_id++) {
  972. GetUserLogin(user_id, WebLogin, &valueLen);
  973. GetUserPassword(user_id, WebPassword, &valueLen);
  974. /* Check login and password */
  975. if ((strncmp(WebLogin, login, MAX_WEB_LOGIN_LEN) == 0) &&
  976. (strncmp(WebPassword, password, MAX_WEB_PASSWD_LEN) == 0)) {
  977. /* Login and pass are valid */
  978. /* TODO replace global flag with user-pass-cookie */
  979. if(cnt_err_psw < 4){
  980. cnt_err_psw = 0;
  981. Authenticated = true;
  982. }
  983. else{
  984. Authenticated = false;
  985. }
  986. break;
  987. }
  988. else{
  989. Authenticated = false;
  990. }
  991. }
  992. if(Authenticated){
  993. /* Generate cookie */
  994. sprintf(tempStr, "%X", (unsigned int)GetRandomNumber());
  995. /* Set users cookie */
  996. HTTP_SetUserCookie(tempStr, user_id);
  997. HTTP_UpdateUserLoginTime(user_id);
  998. /* Send login and cookie back */
  999. strcpy(bufOut, "HTTP/1.0 200 OK\r\nContent-Type:text/html\r\nSet-Cookie: uname=");
  1000. strcat(bufOut, login);
  1001. strcat(bufOut, "\r\nSet-Cookie: id=");
  1002. strcat(bufOut, tempStr);
  1003. sprintf(tempStr, "%d", user_id);
  1004. strcat(bufOut, "\r\nSet-Cookie: role=");
  1005. strcat(bufOut, tempStr);
  1006. strcat(bufOut, "\r\nSet-Cookie: auth=1");
  1007. strcat(bufOut, "\r\n\r\n");
  1008. strcat(bufOut,"<!DOCTYPE html><html lang=""><head><meta http-equiv=\"refresh\" content=\"0;url=/index.html\"/></head></html>\r\n\r\n");
  1009. *lenBufOut = strlen(bufOut);
  1010. switch (user_id) {
  1011. case 0:
  1012. snprintf(name_login, sizeof(name_login), "Администратор");
  1013. break;
  1014. case 1:
  1015. snprintf(name_login, sizeof(name_login), "Пользователь");
  1016. break;
  1017. default:
  1018. break;
  1019. }
  1020. log_event_data(LOG_LOGIN, name_login);
  1021. /* Запускаем задачу-таймер логаута. */
  1022. /* TODO отправить ответ серверу о статусе пароля */
  1023. return SEND_REQUIRED_YES;
  1024. }
  1025. else{
  1026. if(cnt_err_psw <= 4)
  1027. cnt_err_psw ++;
  1028. DBG printf("cnt_err_psw %d", cnt_err_psw);
  1029. if(cnt_err_psw == 4)
  1030. xTimerStart(RepeatLoginTimer, 0);
  1031. strcpy(bufOut, "HTTP/1.0 200 OK\r\nContent-Type: text/html;\r\n\r\n");
  1032. if(cnt_err_psw < 4)
  1033. strcat(bufOut,"<!DOCTYPE html><html><head><meta charset=\"utf-8\"><meta http-equiv=\"refresh\" content=\"3; url=/login.html\" /></head><center><h2>Не правильный логин или пароль</h2></center></html>");
  1034. else
  1035. strcat(bufOut,"<!DOCTYPE html><html><head><meta charset=\"utf-8\"><meta http-equiv=\"refresh\" content=\"3; url=/login.html\" /></head><center><h2>Вход заблокирован!</h2></center></head><center><h2>Повторите попытку через 1 минуту</h2></center></html>");
  1036. *lenBufOut = strlen(bufOut);
  1037. return SEND_REQUIRED_NO;
  1038. }
  1039. }
  1040. /**
  1041. * @brief
  1042. * @retval None
  1043. */
  1044. uint8_t GetParamValue(char *inStr, char *paramName, char *paramValue, uint8_t *paramLen)
  1045. {
  1046. char *beginValue = 0;
  1047. char *endValue = 0;
  1048. int len = 0;
  1049. char *strPtr = 0;
  1050. strPtr = strstr(inStr, paramName);
  1051. if (strPtr != 0)
  1052. {
  1053. beginValue = strpbrk(strPtr,"=");
  1054. endValue = strpbrk(strPtr,"&");
  1055. if (endValue == 0)
  1056. endValue = strpbrk(strPtr," ");
  1057. len = endValue - beginValue - 1;
  1058. strncpy(paramValue, beginValue + 1, len);
  1059. *endValue = '0';
  1060. *beginValue = '0';
  1061. *paramLen = len;
  1062. return 1;
  1063. }
  1064. else
  1065. {
  1066. *paramLen = 0;
  1067. return 0;
  1068. }
  1069. }
  1070. /**
  1071. * @brief
  1072. * @retval None
  1073. */
  1074. uint8_t GetCookieValue(char *inStr, char *paramName, char *paramValue, uint8_t *paramLen)
  1075. {
  1076. char *beginValue = 0;
  1077. char *endValue = 0;
  1078. char *endValueTemp = 0;
  1079. int len = 0;
  1080. char *strPtr = 0;
  1081. strPtr = strstr(inStr, paramName);
  1082. if (strPtr != 0)
  1083. {
  1084. beginValue = strpbrk(strPtr,"=");
  1085. endValue = strpbrk(strPtr,";");
  1086. endValueTemp = strpbrk(strPtr,"\r");
  1087. if(endValueTemp != 0 && endValueTemp < endValue)
  1088. endValue = endValueTemp;
  1089. if (endValue == 0)
  1090. endValue = strpbrk(strPtr,"\n");
  1091. len = endValue - beginValue - 1;
  1092. strncpy(paramValue, beginValue + 1, len);
  1093. *endValue = '0';
  1094. *beginValue = '0';
  1095. *paramLen = len;
  1096. return 1;
  1097. }
  1098. else
  1099. {
  1100. *paramLen = 0;
  1101. return 0;
  1102. }
  1103. }
  1104. char* Parce_Boundary(const char* data, uint32_t len, char* dst, uint8_t dstlen) {
  1105. char *ptr = NULL;
  1106. char *boundary = NULL;
  1107. uint8_t i = 0;
  1108. for (uint32_t j = 0; j < len; j++) {
  1109. if (strncmp ((char*)(data + j), "boundary=", 9) == 0) {
  1110. boundary = (char*)data + j + 9;
  1111. break;
  1112. }
  1113. }
  1114. if (!boundary) return NULL;
  1115. *dst++ = '-';
  1116. *dst++ = '-';
  1117. ptr = boundary;
  1118. while ((*ptr != 0x0d) && (i < dstlen - 4))
  1119. {
  1120. *dst++ = *ptr++;
  1121. i++;
  1122. }
  1123. //*dst++ = '-';
  1124. //*dst++ = '-';
  1125. *dst = '\0';
  1126. if (i > 0)
  1127. return boundary;
  1128. else
  1129. return NULL;
  1130. }
  1131. void ClearParamString(char *inBuf)
  1132. {
  1133. uint16_t len;
  1134. char *str;
  1135. str = strstr(inBuf, "HTTP");
  1136. if (str != 0)
  1137. {
  1138. len = str - inBuf;
  1139. memset(str, 0, RECIVE_BUF_MAX_LEN - len - 1);
  1140. }
  1141. }
  1142. /**
  1143. * @brief Чтение Cookie пользователя
  1144. */
  1145. static void HTTP_GetUserCookie(uint8_t user_id, char *str, uint8_t *len)
  1146. {
  1147. sprintf(str, "%s", users[user_id].cookie);
  1148. *len = strlen(str);
  1149. }
  1150. /**
  1151. * @brief Установка Cookie пользователя
  1152. */
  1153. static void HTTP_SetUserCookie(char *str, uint8_t user_id)
  1154. {
  1155. strcpy(users[user_id].cookie, str);
  1156. }
  1157. /**
  1158. * @brief Обновление времени последней активности пользователя
  1159. */
  1160. static void HTTP_UpdateUserLoginTime(uint8_t user_id)
  1161. {
  1162. xTimerStart(users[user_id].LogoutTimer, 0);
  1163. }
  1164. /**
  1165. * @brief Extract the Content_Length data from HTML data
  1166. * @param data : pointer on receive packet buffer
  1167. * @param len : buffer length
  1168. * @retval size : Content_length in numeric format
  1169. */
  1170. static uint32_t Parse_Content_Length(char *data, uint32_t len)
  1171. {
  1172. uint32_t i=0,size=0, S=1;
  1173. int32_t j=0;
  1174. char sizestring[6], *ptr;
  1175. ContentLengthOffset =0;
  1176. /* find Content-Length data in packet buffer */
  1177. for (i=0;i<len;i++)
  1178. {
  1179. if (strncmp ((char*)(data+i), Content_Length, 16)==0)
  1180. {
  1181. ContentLengthOffset = i+16;
  1182. break;
  1183. }
  1184. }
  1185. /* read Content-Length value */
  1186. if (ContentLengthOffset)
  1187. {
  1188. i=0;
  1189. ptr = (char*)(data + ContentLengthOffset);
  1190. while(*(ptr+i)!=0x0d)
  1191. {
  1192. sizestring[i] = *(ptr+i);
  1193. i++;
  1194. ContentLengthOffset++;
  1195. }
  1196. if (i>0)
  1197. {
  1198. /* transform string data into numeric format */
  1199. for(j=i-1;j>=0;j--)
  1200. {
  1201. size += (sizestring[j]-0x30)*S;
  1202. S=S*10;
  1203. }
  1204. }
  1205. }
  1206. return size;
  1207. }
  1208. /**
  1209. * @brief Принудительный логаут пользователя
  1210. */
  1211. static void HTTP_ForceUserLogout(uint8_t user_id)
  1212. {
  1213. char cookie[MAX_WEB_COOKIE_LEN];
  1214. /* Flush user cookie by random value */
  1215. sprintf(cookie, "%X", (unsigned int)GetRandomNumber());
  1216. HTTP_SetUserCookie(cookie, user_id);
  1217. }
  1218. /**
  1219. * @brief >Callback таймера логаута пользователя
  1220. */
  1221. void LogoutTimerCallback(TimerHandle_t pxTimer) {
  1222. uint8_t user_id = (uint8_t)pvTimerGetTimerID( pxTimer );
  1223. HTTP_ForceUserLogout(user_id);
  1224. }
  1225. /**
  1226. * @brief Смена пароля пользователя
  1227. * @retval None
  1228. */
  1229. int HTTP_ChangeUserPwd(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  1230. {
  1231. char tempStr[110];
  1232. char value[20];
  1233. char login[20];
  1234. char password[20];
  1235. uint8_t valueLen, valueLen2, user_id;
  1236. char WebLogin[MAX_WEB_LOGIN_LEN];
  1237. (void)lenBufIn;
  1238. memset(login, 0, 20);
  1239. memset(password, 0, 20);
  1240. memset(tempStr, 0, 50);
  1241. memset(value, 0, 20);
  1242. ClearParamString(bufIn);
  1243. strncpy(tempStr, bufIn, 110);
  1244. strcpy(bufOut, HTTP_200_OK);
  1245. if (GetParamValue(tempStr, "username=", login, &valueLen) &&
  1246. GetParamValue(tempStr, "oldpass=", password, &valueLen))
  1247. {
  1248. for (user_id = 0; user_id < MAX_WEB_USERS; user_id++)
  1249. {
  1250. memset(value, 0, 20);
  1251. memset(WebLogin, 0, MAX_WEB_LOGIN_LEN);
  1252. GetUserLogin(user_id, WebLogin, &valueLen);
  1253. GetUserPassword(user_id, value, &valueLen2);
  1254. /* Check login and password */
  1255. if ((strncmp(WebLogin, login, MAX_WEB_LOGIN_LEN) == 0) &&
  1256. (memcmp(password, value, 11) == 0))
  1257. {
  1258. memset(password, 0, 20);
  1259. if (GetParamValue(tempStr, "newpass=", password, &valueLen))
  1260. {
  1261. memcpy(sSettings.sAuth[user_id].password, password, 11);
  1262. telnet_act = false;
  1263. HTTP_SaveSettings();
  1264. log_event_data(LOG_PSW_CHANGE, name_login);
  1265. strcat(bufOut, "Пароль успешно изменён");
  1266. *lenBufOut = strlen(bufOut);
  1267. return SEND_REQUIRED_YES;
  1268. }
  1269. else {
  1270. strcat(bufOut, "Введены некорректные данные!");
  1271. *lenBufOut = strlen(bufOut);
  1272. return SEND_REQUIRED_YES;
  1273. }
  1274. }
  1275. }
  1276. strcat(bufOut, "Введён неверный пароль!");
  1277. *lenBufOut = strlen(bufOut);
  1278. return SEND_REQUIRED_YES;
  1279. }
  1280. else {
  1281. strcat(bufOut, "Введены некорректные данные!");
  1282. *lenBufOut = strlen(bufOut);
  1283. return SEND_REQUIRED_YES;
  1284. }
  1285. }
  1286. //
  1287. void Cockie(void)
  1288. {
  1289. receiveBuf[receivedBufLen] = '\0';
  1290. //printf("receive %s \r\n", receiveBuf);
  1291. // Get cookie "uname" value
  1292. memset(CookieBuf, 0, sizeof(CookieBuf));
  1293. CookiePtr = strstr(receiveBuf, "uname=");
  1294. strncpy(CookieBuf, CookiePtr, 50);
  1295. //printf("********CookieBuf1= %s\r\n", CookieBuf);
  1296. memset(name, 0, MAX_WEB_COOKIE_LEN);
  1297. GetCookieValue(CookieBuf, "uname=", name, &nameLen);
  1298. //printf("********CookieBuf2= %s\r\n", CookieBuf);
  1299. //printf("********uname= %s\r\n", name);
  1300. memset(CookieBuf, 0, sizeof(CookieBuf));
  1301. // Get cookie "id" value
  1302. CookiePtr = strstr(receiveBuf, " id=");
  1303. strncpy(CookieBuf, CookiePtr, 50);
  1304. //printf("********CookieBuf1= %s\r\n", CookieBuf);
  1305. memset(id, 0, MAX_WEB_COOKIE_LEN);
  1306. GetCookieValue(CookieBuf, "id=", id, &idLen);
  1307. // printf("********ID= %s\r\n", id);
  1308. }
  1309. //
  1310. void getAuthenticatedState(void)
  1311. {
  1312. seclevel = 0xFF;
  1313. for (user_id = 0; user_id < MAX_WEB_USERS; user_id++) {
  1314. HTTP_GetUserCookie(user_id, CookieBuf, &idLen);
  1315. if (strncmp(id, CookieBuf, idLen) == 0 ) {
  1316. GetUserLevelInt(user_id, &seclevel);
  1317. Authenticated = true;
  1318. break;
  1319. }
  1320. Authenticated = false;
  1321. seclevel = 0xFF;
  1322. }
  1323. }
  1324. //
  1325. char* AuthenticatedFalseRoutine(uint16_t* sendLen)
  1326. {
  1327. if (strncmp(receiveBuf, "GET /main.css", 13) == 0) // +
  1328. {
  1329. fs_open("/main.css", &file);
  1330. *sendLen = file.len;
  1331. return file.data;
  1332. }
  1333. else if (strncmp(receiveBuf, "GET /rotek.png", 14) == 0) // +
  1334. {
  1335. fs_open("/rotek.png", &file);
  1336. *sendLen = file.len;
  1337. return file.data;
  1338. }
  1339. else if (strncmp(receiveBuf, "GET /favicon.ico", 16) == 0) // ?
  1340. {
  1341. fs_open("/favicon.ico", &file);
  1342. *sendLen = file.len;
  1343. return file.data;
  1344. }
  1345. else if (strncmp(receiveBuf, "GET /role.js", 12) == 0)
  1346. {
  1347. fs_open("/role.js", &file);
  1348. *sendLen = file.len;
  1349. return file.data;
  1350. }
  1351. else if (strncmp(receiveBuf, "POST /login.cgi", 15) == 0)
  1352. {
  1353. uint32_t req_data_received = 0;
  1354. char *offset = 0;
  1355. post_data_count = Parse_Content_Length(receiveBuf, receivedBufLen);
  1356. if (post_data_count < MAX_POST_REQ_LEN)
  1357. {
  1358. memset(post_req_data, 0, MAX_POST_REQ_LEN);
  1359. offset = (strstr(receiveBuf, "\r\n\r\n")) + 4;
  1360. req_data_received = receivedBufLen - (offset - &receiveBuf[0]);
  1361. if (offset != 0)
  1362. {
  1363. if (req_data_received < post_data_count)
  1364. {
  1365. snprintf(post_req_data, req_data_received, "%s", receiveBuf);
  1366. post_data_count -= req_data_received;
  1367. }
  1368. /* if data received completely */
  1369. else {
  1370. strncat(post_req_data, &receiveBuf[offset - &receiveBuf[0]], post_data_count);
  1371. //printf("post_req_data: %s\r\n", post_req_data);
  1372. /* End reqest */
  1373. post_data_count = 0;
  1374. log_post_reqn = 0;
  1375. if (HTTP_ConfirmWebPwd(post_req_data, sendBuf, strlen(post_req_data), sendLen) == SEND_REQUIRED_YES) {
  1376. return sendBuf;
  1377. }
  1378. else {
  1379. /* Redirect to login page */
  1380. /* fs_open("/login.html", &file);
  1381. *sendLen = file.len;
  1382. return file.data;*/
  1383. return sendBuf;
  1384. }
  1385. }
  1386. }
  1387. // request was fragmented before "\r\n\r\n"
  1388. else
  1389. {
  1390. log_post_reqn++;
  1391. /* wait max 2 requests */
  1392. if (log_post_reqn > 1) {
  1393. /* End reqest */
  1394. post_data_count = 0;
  1395. log_post_reqn = 0;
  1396. /* Redirect to login page */
  1397. fs_open("/login.html", &file);
  1398. *sendLen = file.len;
  1399. return file.data;
  1400. }
  1401. }
  1402. }
  1403. else
  1404. {
  1405. //printf("Too long POST request!\r\n");
  1406. // Ignore request
  1407. post_data_count = 0;
  1408. log_post_reqn = 0;
  1409. // Redirect to login page
  1410. fs_open("/login.html", &file);
  1411. *sendLen = file.len;
  1412. return file.data;
  1413. }
  1414. }
  1415. else if (post_data_count > 0)
  1416. {
  1417. strncat(post_req_data, receiveBuf, post_data_count);
  1418. post_data_count = 0;
  1419. log_post_reqn = 0;
  1420. if (HTTP_ConfirmWebPwd(post_req_data, sendBuf, strlen(post_req_data), sendLen) == SEND_REQUIRED_YES)
  1421. {
  1422. return sendBuf;
  1423. }
  1424. else
  1425. {
  1426. return sendBuf;
  1427. }
  1428. }
  1429. else
  1430. {
  1431. fs_open("/login.html", &file);
  1432. *sendLen = file.len;
  1433. return file.data;
  1434. }
  1435. }
  1436. //
  1437. char* AuthenticatedTrueRoutine(uint16_t* sendLen)
  1438. {
  1439. char *DataOffset;
  1440. if (strncmp(receiveBuf, "GET /getJson.cgi", 16) == 0) // +
  1441. {
  1442. HTTP_GetParamsPage1(sendBuf);
  1443. *sendLen = strlen(sendBuf);
  1444. return sendBuf;
  1445. }
  1446. else if (strncmp(receiveBuf, "GET /settings.cgi", 17) == 0) // +
  1447. {
  1448. if (seclevel == 0) {
  1449. if (HTTP_SettingsPage(receiveBuf, sendBuf, receivedBufLen, sendLen) == SEND_REQUIRED_YES)
  1450. {
  1451. *sendLen = strlen(sendBuf);
  1452. return sendBuf;
  1453. }
  1454. }
  1455. return 0;
  1456. }
  1457. else if (strncmp(receiveBuf, "POST /settings.cgi", 18) == 0 || DataFlag2 >= 1)
  1458. {
  1459. if (seclevel == 0)
  1460. {
  1461. DataOffset = 0;
  1462. // POST Packet received
  1463. if (DataFlag2 == 0)
  1464. {
  1465. TotalReceived = 0;
  1466. memset(sendBuf, 0, strlen(sendBuf));
  1467. // parse packet for Content-length field
  1468. size = Parse_Content_Length(receiveBuf, receivedBufLen);
  1469. DataOffset = strstr(receiveBuf, "managerIP");
  1470. // case of MSIE8 : we do not receive data in the POST packet
  1471. if (DataOffset == 0)
  1472. {
  1473. DataFlag2++;
  1474. return 0;
  1475. }
  1476. else{
  1477. TotalReceived = receivedBufLen - (DataOffset - &receiveBuf[0]);
  1478. strncat(sendBuf, DataOffset, TotalReceived);
  1479. }
  1480. }
  1481. if (DataFlag2 == 0)
  1482. {
  1483. DataFlag2++;
  1484. }
  1485. else if (DataFlag2 == 1)
  1486. {
  1487. /* parse packet for the octet-stream field */
  1488. DataOffset = strstr(receiveBuf, "managerIP");
  1489. TotalReceived += receivedBufLen;
  1490. strncat(sendBuf, DataOffset, TotalReceived);
  1491. DataFlag2++;
  1492. }
  1493. /* DataFlag >1 => the packet is data only */
  1494. else
  1495. {
  1496. TotalReceived +=receivedBufLen;
  1497. strncat(sendBuf, receiveBuf, receivedBufLen);
  1498. }
  1499. // check if last data packet
  1500. if (TotalReceived == size)
  1501. {
  1502. DBG printf("State: Received %d bytes\r\n", (int)TotalData);
  1503. // printf("receive %s \r\n", sendBuf);
  1504. strncat(sendBuf, " ", 1);
  1505. HTTP_SetSettings(sendBuf, strlen(sendBuf));
  1506. memset(sendBuf, 0, size);
  1507. DataFlag2 = 0;
  1508. strcpy(sendBuf, "HTTP/1.1 200 OK\r\n");
  1509. strcat(sendBuf, "\r\n\r\n");
  1510. strcat(sendBuf,"<!DOCTYPE html><html lang=""><head><meta http-equiv=\"refresh\" content=\"0;url=/settings.html\"/></head></html>\r\n\r\n");
  1511. sendBufLoadLen = strlen(sendBuf);
  1512. *sendLen = sendBufLoadLen;
  1513. return sendBuf;
  1514. }
  1515. }
  1516. return 0;
  1517. }
  1518. else if (strncmp(receiveBuf, "GET /info.cgi", 13) == 0) // +
  1519. {
  1520. if (HTTP_InfoPage(receiveBuf, sendBuf, receivedBufLen, sendLen) == SEND_REQUIRED_YES)
  1521. {
  1522. return sendBuf;
  1523. }
  1524. }
  1525. else if (strncmp(receiveBuf, "POST /info.cgi", 14) == 0 || DataFlag >= 1)
  1526. {
  1527. DataOffset = 0;
  1528. // POST Packet received
  1529. if (DataFlag == 0)
  1530. {
  1531. TotalReceived = 0;
  1532. memset(sendBuf, 0, strlen(sendBuf));
  1533. // parse packet for Content-length field
  1534. size = Parse_Content_Length(receiveBuf, receivedBufLen);
  1535. DataOffset = strstr(receiveBuf, "sysname");
  1536. // case of MSIE8 : we do not receive data in the POST packet
  1537. if (DataOffset == 0)
  1538. {
  1539. DataFlag++;
  1540. return 0;
  1541. }
  1542. else{
  1543. TotalReceived = receivedBufLen - (DataOffset - &receiveBuf[0]);
  1544. strncat(sendBuf, DataOffset, TotalReceived);
  1545. }
  1546. }
  1547. if (DataFlag == 0)
  1548. {
  1549. DataFlag++;
  1550. }
  1551. else if (DataFlag == 1)
  1552. {
  1553. /* parse packet for the octet-stream field */
  1554. DataOffset = strstr(receiveBuf, "sysname");
  1555. TotalReceived += receivedBufLen;
  1556. strncat(sendBuf, DataOffset, TotalReceived);
  1557. DataFlag++;
  1558. }
  1559. /* DataFlag >1 => the packet is data only */
  1560. else
  1561. {
  1562. TotalReceived +=receivedBufLen;
  1563. strncat(sendBuf, receiveBuf, receivedBufLen);
  1564. }
  1565. // check if last data packet
  1566. if (TotalReceived == size)
  1567. {
  1568. strncat(sendBuf, " ", 1);
  1569. HTTP_SetInfo(sendBuf, strlen(sendBuf));
  1570. DataFlag = 0;
  1571. memset(sendBuf, 0, size);
  1572. strcpy(sendBuf, "HTTP/1.1 200 OK\r\n");
  1573. strcat(sendBuf, "\r\n\r\n");
  1574. strcat(sendBuf,"<!DOCTYPE html><html lang=""><head><meta http-equiv=\"refresh\" content=\"0;url=/info.html\"/></head></html>\r\n\r\n");
  1575. *sendLen = strlen(sendBuf);
  1576. return sendBuf;
  1577. }
  1578. }
  1579. else if (strncmp(receiveBuf, "GET /history.cgi", 16) == 0)
  1580. {
  1581. int res;
  1582. res = HTTP_HistoryPage(receiveBuf, sendBuf, receivedBufLen, sendLen);
  1583. if (res == SEND_REQUIRED_FILE)
  1584. {
  1585. HTTPTypeAnswer = HISTORY_ANSWER;
  1586. return sendBuf;
  1587. }
  1588. else if (res == SEND_REQUIRED_YES)
  1589. {
  1590. return sendBuf;
  1591. }
  1592. }
  1593. else if (strncmp(receiveBuf, "GET /ups_history.cgi", 19) == 0)
  1594. {
  1595. int res;
  1596. res = HTTP_UpsHistoryPage(receiveBuf, sendBuf, receivedBufLen, sendLen);
  1597. if (res == SEND_REQUIRED_FILE)
  1598. {
  1599. HTTPTypeAnswer = UPS_HISTORY_ANSWER;
  1600. return sendBuf;
  1601. }
  1602. else if (res == SEND_REQUIRED_YES)
  1603. {
  1604. return sendBuf;
  1605. }
  1606. }
  1607. /* Тест АКБ ИБП */
  1608. else if (strncmp(receiveBuf, "GET /bat_test.cgi", 17) == 0)
  1609. {
  1610. HTTP_UPSTest(receiveBuf, sendBuf, receivedBufLen, sendLen);
  1611. return sendBuf;
  1612. }
  1613. /* Выключение ИБП */
  1614. else if (strncmp(receiveBuf, "GET /ups_power.cgi", 18) == 0)
  1615. {
  1616. HTTP_UPSshutdown(receiveBuf, sendBuf, receivedBufLen, sendLen);
  1617. return sendBuf;
  1618. }
  1619. /* Сброс настроек и сохранине */
  1620. else if (strncmp(receiveBuf, "GET /reset.cgi", 14) == 0)
  1621. {
  1622. telnet_act = false;
  1623. HTTP_ResetSettings();
  1624. HTTP_SaveSettings();
  1625. fs_open("/settings.html", &file);
  1626. *sendLen = file.len;
  1627. return file.data;
  1628. }
  1629. /* Перезагрузка контроллера */
  1630. else if (strncmp(receiveBuf, "GET /reboot.cgi", 15) == 0)
  1631. {
  1632. telnet_act = false;
  1633. HTTP_Reboot();
  1634. }
  1635. /* Подтверждение новых сетевых настроек */
  1636. else if (strncmp(receiveBuf, "GET /confirm.cgi", 16) == 0)
  1637. {
  1638. telnet_act = false;
  1639. SetWebReinitFlag(false);
  1640. SetConfirmWebParamsFlag();
  1641. fs_open("/index.html", &file);
  1642. *sendLen = file.len;
  1643. return file.data;
  1644. }
  1645. /* Проверка пароля, переход в bootloader */
  1646. else if (strncmp(receiveBuf, "GET /fw_update.cgi", 18) == 0)
  1647. {
  1648. HTTP_ConfirmBootPwd(receiveBuf, sendBuf, receivedBufLen, sendLen);
  1649. return sendBuf;
  1650. }
  1651. /* Смена пароля пользователя */
  1652. else if (strncmp(receiveBuf, "GET /changepwd.cgi", 18) == 0)
  1653. {
  1654. HTTP_ChangeUserPwd(receiveBuf, sendBuf, receivedBufLen, sendLen);
  1655. return sendBuf;
  1656. }
  1657. /* Check common GET request */
  1658. else if (strncmp(receiveBuf, "GET", 3) == 0) {
  1659. char filename[MAX_FILENAME_LEN];
  1660. char nonmatch[MAX_ETAG_LEN];
  1661. char *pnonmatch = NULL;
  1662. uint8_t len;
  1663. if (GetFileName(receiveBuf, filename, &len)) {
  1664. HTTP_UpdateUserLoginTime(user_id);
  1665. /* Parce If-Non_Match value */
  1666. uint8_t nonmatch_len = Parse_Header(receiveBuf, receivedBufLen, If_None_Match, 15, nonmatch);
  1667. if (nonmatch_len < MAX_ETAG_LEN && nonmatch_len > 0) {
  1668. DBG printf("If_None_Match: %s\r\n", nonmatch);
  1669. pnonmatch = nonmatch;
  1670. }
  1671. return send_file(filename, pnonmatch, &file, sendLen);
  1672. }
  1673. }
  1674. else
  1675. {
  1676. HTTP_UpdateUserLoginTime(user_id);
  1677. fs_open("/index.html", &file); // +
  1678. *sendLen = file.len;
  1679. return file.data;
  1680. }
  1681. return 0;
  1682. }
  1683. /**
  1684. * @brief sends file from flash FS
  1685. * @param filename: pointer to the file name to send
  1686. * @param pnonmatch: pointer to the If-Non_Match value
  1687. * @param pcb: pointer to a tcp_pcb struct
  1688. * @param hs: pointer to a http_state struct
  1689. * @param file: pointer to a fs_file struct
  1690. * @retval
  1691. */
  1692. char* send_file(char *filename, char *pnonmatch, struct fs_file *file, uint16_t *Len)
  1693. {
  1694. int res = 0;
  1695. char etag[MAX_ETAG_LEN];
  1696. char *petag = NULL;
  1697. res = fs_open(filename, file);
  1698. if (res == 0) {
  1699. printf("Not found: %s\r\n", filename);
  1700. sprintf(filename, "/index.html");
  1701. fs_open(filename, file);
  1702. }
  1703. /* Find Etag value */
  1704. uint8_t etag_len = Parse_Header(file->data, file->len, Etag, 6, etag);
  1705. if (etag_len < MAX_ETAG_LEN && etag_len > 0) {
  1706. DBG printf("Etag: %s\r\n", etag);
  1707. petag = etag;
  1708. }
  1709. /* Compare Etag and If-Non-Match fields */
  1710. if (pnonmatch && petag && (strcmp(pnonmatch, petag) == 0)) {
  1711. /* Send 304 code */
  1712. sprintf(sendBuf, HTTP_304_NOT_MODIFIED);
  1713. DBG printf(sendBuf);
  1714. *Len = strlen(sendBuf);
  1715. return sendBuf;
  1716. //hs->file = sendBuf;
  1717. //hs->left = strlen(sendBuf);
  1718. }
  1719. else {
  1720. /* Send file */
  1721. //DBG printf("%s\r\n\r\n", filename);
  1722. //hs->file = file->data;
  1723. //hs->left = file->len;
  1724. *Len = file->len;
  1725. return file->data;
  1726. }
  1727. //send_data(pcb, hs);
  1728. //tcp_sent(pcb, http_sent);
  1729. }
  1730. /**
  1731. * @brief Extract the custom field data from HTML data
  1732. * @param data : pointer on receive packet buffer
  1733. * @param len : buffer length
  1734. * @param field : field name
  1735. * @param flen : field name length
  1736. * @retval value : pointer for field data
  1737. */
  1738. static uint32_t Parse_Header(char *data, uint32_t len, const char *field, uint32_t flen, char *value)
  1739. {
  1740. uint32_t i = 0, size = 0;
  1741. char *ptr;
  1742. uint32_t Offset = 0;
  1743. /* Find field name in data buffer */
  1744. for (i = 0; i < len; i++) {
  1745. if (strncmp ((char*)(data + i), field, flen) == 0) {
  1746. Offset = i + flen;
  1747. break;
  1748. }
  1749. }
  1750. /* Copy Field value */
  1751. if (Offset) {
  1752. i = 0;
  1753. ptr = (char*)(data + Offset);
  1754. while (*(ptr + i) != 0x0d) {
  1755. value[i] = *(ptr + i);
  1756. i++;
  1757. }
  1758. value[i] = '\0';
  1759. size = i;
  1760. }
  1761. return size;
  1762. }
  1763. /**
  1764. * @brief
  1765. * @retval None
  1766. */
  1767. bool GetFileName(char *inStr, char *fileName, uint8_t *fileNameLen)
  1768. {
  1769. char *beginValue = NULL;
  1770. char *endValue = NULL;
  1771. int len = 0;
  1772. char *strPtr = NULL;
  1773. strPtr = strstr(inStr, "GET");
  1774. if (strPtr == NULL) {
  1775. strPtr = strstr(inStr, "POST");
  1776. }
  1777. if (strPtr == NULL) {
  1778. *fileNameLen = 0;
  1779. return false;
  1780. }
  1781. else {
  1782. beginValue = strpbrk(strPtr, "/");
  1783. endValue = strpbrk(beginValue, " ");
  1784. if (endValue == NULL) {
  1785. *fileNameLen = 0;
  1786. return false;
  1787. }
  1788. len = endValue - beginValue;
  1789. if (len < MAX_FILENAME_LEN) {
  1790. strncpy(fileName, beginValue, len);
  1791. *fileNameLen = len;
  1792. fileName[len] = '\0';
  1793. return true;
  1794. }
  1795. else {
  1796. return false;
  1797. }
  1798. }
  1799. }
  1800. #endif