http_server.c 53 KB

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