http_server.c 55 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097
  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[330];
  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. char tmp_password[33];
  958. uint8_t valueLen, user_id;
  959. char *strPtr = 0;
  960. char WebPassword[MAX_WEB_PASSWD_LEN];
  961. char WebLogin[MAX_WEB_LOGIN_LEN];
  962. memset(login, 0, 20);
  963. memset(password, 0, 20);
  964. memset(tmp_password, 0, 33);
  965. memset(tempStr, 0, 50);
  966. memset(name_login, 0, 50);
  967. /* Get first 50 bytes of string */
  968. strncpy(tempStr, bufIn, 49);
  969. /* Add " " to the string in order GetParamValue() can be able to parse the param */
  970. strcat(tempStr, " ");
  971. GetParamValue(tempStr, "login=", login, &valueLen);
  972. GetParamValue(tempStr, "password=", tmp_password, &valueLen);
  973. url_decode(password, sizeof(password), tmp_password);
  974. valueLen = strlen(password);
  975. for (user_id = 0; user_id < MAX_WEB_USERS; user_id++) {
  976. GetUserLogin(user_id, WebLogin, &valueLen);
  977. GetUserPassword(user_id, WebPassword, &valueLen);
  978. /* Check login and password */
  979. if ((strncmp(WebLogin, login, MAX_WEB_LOGIN_LEN) == 0) &&
  980. (strncmp(WebPassword, password, MAX_WEB_PASSWD_LEN) == 0)) {
  981. /* Login and pass are valid */
  982. /* TODO replace global flag with user-pass-cookie */
  983. if(cnt_err_psw < 4){
  984. cnt_err_psw = 0;
  985. Authenticated = true;
  986. }
  987. else{
  988. Authenticated = false;
  989. }
  990. break;
  991. }
  992. else{
  993. Authenticated = false;
  994. }
  995. }
  996. if(Authenticated){
  997. /* Generate cookie */
  998. sprintf(tempStr, "%X", (unsigned int)GetRandomNumber());
  999. /* Set users cookie */
  1000. HTTP_SetUserCookie(tempStr, user_id);
  1001. HTTP_UpdateUserLoginTime(user_id);
  1002. /* Send login and cookie back */
  1003. strcpy(bufOut, "HTTP/1.0 200 OK\r\nContent-Type:text/html\r\nSet-Cookie: uname=");
  1004. strcat(bufOut, login);
  1005. strcat(bufOut, "\r\nSet-Cookie: id=");
  1006. strcat(bufOut, tempStr);
  1007. sprintf(tempStr, "%d", user_id);
  1008. strcat(bufOut, "\r\nSet-Cookie: role=");
  1009. strcat(bufOut, tempStr);
  1010. strcat(bufOut, "\r\nSet-Cookie: auth=1");
  1011. strcat(bufOut, "\r\n\r\n");
  1012. strcat(bufOut,"<!DOCTYPE html><html lang=""><head><meta http-equiv=\"refresh\" content=\"0;url=/index.html\"/></head></html>\r\n\r\n");
  1013. *lenBufOut = strlen(bufOut);
  1014. switch (user_id) {
  1015. case 0:
  1016. snprintf(name_login, sizeof(name_login), "Администратор");
  1017. break;
  1018. case 1:
  1019. snprintf(name_login, sizeof(name_login), "Пользователь");
  1020. break;
  1021. default:
  1022. break;
  1023. }
  1024. log_event_data(LOG_LOGIN, name_login);
  1025. /* Запускаем задачу-таймер логаута. */
  1026. /* TODO отправить ответ серверу о статусе пароля */
  1027. return SEND_REQUIRED_YES;
  1028. }
  1029. else{
  1030. if(cnt_err_psw <= 4)
  1031. cnt_err_psw ++;
  1032. DBG printf("cnt_err_psw %d", cnt_err_psw);
  1033. if(cnt_err_psw == 4)
  1034. xTimerStart(RepeatLoginTimer, 0);
  1035. strcpy(bufOut, "HTTP/1.0 200 OK\r\nContent-Type: text/html;\r\n\r\n");
  1036. if(cnt_err_psw < 4)
  1037. 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>");
  1038. else
  1039. 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>");
  1040. *lenBufOut = strlen(bufOut);
  1041. return SEND_REQUIRED_NO;
  1042. }
  1043. }
  1044. /**
  1045. * @brief
  1046. * @retval None
  1047. */
  1048. uint8_t GetParamValue(char *inStr, char *paramName, char *paramValue, uint8_t *paramLen)
  1049. {
  1050. char *beginValue = 0;
  1051. char *endValue = 0;
  1052. int len = 0;
  1053. char *strPtr = 0;
  1054. strPtr = strstr(inStr, paramName);
  1055. if (strPtr != 0)
  1056. {
  1057. beginValue = strpbrk(strPtr,"=");
  1058. endValue = strpbrk(strPtr,"&");
  1059. if (endValue == 0)
  1060. endValue = strpbrk(strPtr," ");
  1061. len = endValue - beginValue - 1;
  1062. strncpy(paramValue, beginValue + 1, len);
  1063. *endValue = '0';
  1064. *beginValue = '0';
  1065. *paramLen = len;
  1066. return 1;
  1067. }
  1068. else
  1069. {
  1070. *paramLen = 0;
  1071. return 0;
  1072. }
  1073. }
  1074. /**
  1075. * @brief
  1076. * @retval None
  1077. */
  1078. uint8_t GetCookieValue(char *inStr, char *paramName, char *paramValue, uint8_t *paramLen)
  1079. {
  1080. char *beginValue = 0;
  1081. char *endValue = 0;
  1082. char *endValueTemp = 0;
  1083. int len = 0;
  1084. char *strPtr = 0;
  1085. strPtr = strstr(inStr, paramName);
  1086. if (strPtr != 0)
  1087. {
  1088. beginValue = strpbrk(strPtr,"=");
  1089. endValue = strpbrk(strPtr,";");
  1090. endValueTemp = strpbrk(strPtr,"\r");
  1091. if(endValueTemp != 0 && endValueTemp < endValue)
  1092. endValue = endValueTemp;
  1093. if (endValue == 0)
  1094. endValue = strpbrk(strPtr,"\n");
  1095. len = endValue - beginValue - 1;
  1096. strncpy(paramValue, beginValue + 1, len);
  1097. *endValue = '0';
  1098. *beginValue = '0';
  1099. *paramLen = len;
  1100. return 1;
  1101. }
  1102. else
  1103. {
  1104. *paramLen = 0;
  1105. return 0;
  1106. }
  1107. }
  1108. char* Parce_Boundary(const char* data, uint32_t len, char* dst, uint8_t dstlen) {
  1109. char *ptr = NULL;
  1110. char *boundary = NULL;
  1111. uint8_t i = 0;
  1112. for (uint32_t j = 0; j < len; j++) {
  1113. if (strncmp ((char*)(data + j), "boundary=", 9) == 0) {
  1114. boundary = (char*)data + j + 9;
  1115. break;
  1116. }
  1117. }
  1118. if (!boundary) return NULL;
  1119. *dst++ = '-';
  1120. *dst++ = '-';
  1121. ptr = boundary;
  1122. while ((*ptr != 0x0d) && (i < dstlen - 4))
  1123. {
  1124. *dst++ = *ptr++;
  1125. i++;
  1126. }
  1127. //*dst++ = '-';
  1128. //*dst++ = '-';
  1129. *dst = '\0';
  1130. if (i > 0)
  1131. return boundary;
  1132. else
  1133. return NULL;
  1134. }
  1135. void ClearParamString(char *inBuf)
  1136. {
  1137. uint16_t len;
  1138. char *str;
  1139. str = strstr(inBuf, "HTTP");
  1140. if (str != 0)
  1141. {
  1142. len = str - inBuf;
  1143. memset(str, 0, RECIVE_BUF_MAX_LEN - len - 1);
  1144. }
  1145. }
  1146. /**
  1147. * @brief Чтение Cookie пользователя
  1148. */
  1149. static void HTTP_GetUserCookie(uint8_t user_id, char *str, uint8_t *len)
  1150. {
  1151. sprintf(str, "%s", users[user_id].cookie);
  1152. *len = strlen(str);
  1153. }
  1154. /**
  1155. * @brief Установка Cookie пользователя
  1156. */
  1157. static void HTTP_SetUserCookie(char *str, uint8_t user_id)
  1158. {
  1159. strcpy(users[user_id].cookie, str);
  1160. }
  1161. /**
  1162. * @brief Обновление времени последней активности пользователя
  1163. */
  1164. static void HTTP_UpdateUserLoginTime(uint8_t user_id)
  1165. {
  1166. xTimerStart(users[user_id].LogoutTimer, 0);
  1167. }
  1168. /**
  1169. * @brief Extract the Content_Length data from HTML data
  1170. * @param data : pointer on receive packet buffer
  1171. * @param len : buffer length
  1172. * @retval size : Content_length in numeric format
  1173. */
  1174. static uint32_t Parse_Content_Length(char *data, uint32_t len)
  1175. {
  1176. uint32_t i=0,size=0, S=1;
  1177. int32_t j=0;
  1178. char sizestring[6], *ptr;
  1179. ContentLengthOffset =0;
  1180. /* find Content-Length data in packet buffer */
  1181. for (i=0;i<len;i++)
  1182. {
  1183. if (strncmp ((char*)(data+i), Content_Length, 16)==0)
  1184. {
  1185. ContentLengthOffset = i+16;
  1186. break;
  1187. }
  1188. }
  1189. /* read Content-Length value */
  1190. if (ContentLengthOffset)
  1191. {
  1192. i=0;
  1193. ptr = (char*)(data + ContentLengthOffset);
  1194. while(*(ptr+i)!=0x0d)
  1195. {
  1196. sizestring[i] = *(ptr+i);
  1197. i++;
  1198. ContentLengthOffset++;
  1199. }
  1200. if (i>0)
  1201. {
  1202. /* transform string data into numeric format */
  1203. for(j=i-1;j>=0;j--)
  1204. {
  1205. size += (sizestring[j]-0x30)*S;
  1206. S=S*10;
  1207. }
  1208. }
  1209. }
  1210. return size;
  1211. }
  1212. /**
  1213. * @brief Принудительный логаут пользователя
  1214. */
  1215. static void HTTP_ForceUserLogout(uint8_t user_id)
  1216. {
  1217. char cookie[MAX_WEB_COOKIE_LEN];
  1218. /* Flush user cookie by random value */
  1219. sprintf(cookie, "%X", (unsigned int)GetRandomNumber());
  1220. HTTP_SetUserCookie(cookie, user_id);
  1221. }
  1222. /**
  1223. * @brief >Callback таймера логаута пользователя
  1224. */
  1225. void LogoutTimerCallback(TimerHandle_t pxTimer) {
  1226. uint8_t user_id = (uint8_t)pvTimerGetTimerID( pxTimer );
  1227. HTTP_ForceUserLogout(user_id);
  1228. }
  1229. /**
  1230. * @brief Смена пароля пользователя
  1231. * @retval None
  1232. */
  1233. int HTTP_ChangeUserPwd(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  1234. {
  1235. char tempStr[110];
  1236. char value[20];
  1237. char login[20];
  1238. char password[20];
  1239. char tmp_password[33];
  1240. uint8_t valueLen, valueLen2, user_id;
  1241. char WebLogin[MAX_WEB_LOGIN_LEN];
  1242. (void)lenBufIn;
  1243. memset(login, 0, 20);
  1244. memset(password, 0, 20);
  1245. memset(tmp_password, 0, 33);
  1246. memset(tempStr, 0, 50);
  1247. memset(value, 0, 20);
  1248. ClearParamString(bufIn);
  1249. strncpy(tempStr, bufIn, 110);
  1250. strcpy(bufOut, HTTP_200_OK);
  1251. if (GetParamValue(tempStr, "username=", login, &valueLen) &&
  1252. GetParamValue(tempStr, "oldpass=", password, &valueLen))
  1253. {
  1254. for (user_id = 0; user_id < MAX_WEB_USERS; user_id++)
  1255. {
  1256. memset(value, 0, 20);
  1257. memset(WebLogin, 0, MAX_WEB_LOGIN_LEN);
  1258. GetUserLogin(user_id, WebLogin, &valueLen);
  1259. GetUserPassword(user_id, value, &valueLen2);
  1260. /* Check login and password */
  1261. if ((strncmp(WebLogin, login, MAX_WEB_LOGIN_LEN) == 0) &&
  1262. (memcmp(password, value, 11) == 0))
  1263. {
  1264. memset(password, 0, 20);
  1265. if (GetParamValue(tempStr, "newpass=", tmp_password, &valueLen))
  1266. {
  1267. url_decode(password, sizeof(password), tmp_password);
  1268. valueLen = strlen(password);
  1269. memcpy(sSettings.sAuth[user_id].password, password, 11);
  1270. telnet_act = false;
  1271. HTTP_SaveSettings();
  1272. log_event_data(LOG_PSW_CHANGE, name_login);
  1273. strcat(bufOut, "Пароль успешно изменён");
  1274. *lenBufOut = strlen(bufOut);
  1275. return SEND_REQUIRED_YES;
  1276. }
  1277. else {
  1278. strcat(bufOut, "Введены некорректные данные!");
  1279. *lenBufOut = strlen(bufOut);
  1280. return SEND_REQUIRED_YES;
  1281. }
  1282. }
  1283. }
  1284. strcat(bufOut, "Введён неверный пароль!");
  1285. *lenBufOut = strlen(bufOut);
  1286. return SEND_REQUIRED_YES;
  1287. }
  1288. else {
  1289. strcat(bufOut, "Введены некорректные данные!");
  1290. *lenBufOut = strlen(bufOut);
  1291. return SEND_REQUIRED_YES;
  1292. }
  1293. }
  1294. //
  1295. void Cockie(void)
  1296. {
  1297. receiveBuf[receivedBufLen] = '\0';
  1298. //printf("receive %s \r\n", receiveBuf);
  1299. // Get cookie "uname" value
  1300. memset(CookieBuf, 0, sizeof(CookieBuf));
  1301. CookiePtr = strstr(receiveBuf, "uname=");
  1302. strncpy(CookieBuf, CookiePtr, 50);
  1303. //printf("********CookieBuf1= %s\r\n", CookieBuf);
  1304. memset(name, 0, MAX_WEB_COOKIE_LEN);
  1305. GetCookieValue(CookieBuf, "uname=", name, &nameLen);
  1306. //printf("********CookieBuf2= %s\r\n", CookieBuf);
  1307. //printf("********uname= %s\r\n", name);
  1308. memset(CookieBuf, 0, sizeof(CookieBuf));
  1309. // Get cookie "id" value
  1310. CookiePtr = strstr(receiveBuf, " id=");
  1311. strncpy(CookieBuf, CookiePtr, 50);
  1312. //printf("********CookieBuf1= %s\r\n", CookieBuf);
  1313. memset(id, 0, MAX_WEB_COOKIE_LEN);
  1314. GetCookieValue(CookieBuf, "id=", id, &idLen);
  1315. // printf("********ID= %s\r\n", id);
  1316. }
  1317. //
  1318. void getAuthenticatedState(void)
  1319. {
  1320. seclevel = 0xFF;
  1321. for (user_id = 0; user_id < MAX_WEB_USERS; user_id++) {
  1322. HTTP_GetUserCookie(user_id, CookieBuf, &idLen);
  1323. if (strncmp(id, CookieBuf, idLen) == 0 ) {
  1324. GetUserLevelInt(user_id, &seclevel);
  1325. Authenticated = true;
  1326. break;
  1327. }
  1328. Authenticated = false;
  1329. seclevel = 0xFF;
  1330. }
  1331. }
  1332. //
  1333. char* AuthenticatedFalseRoutine(uint16_t* sendLen)
  1334. {
  1335. if (strncmp(receiveBuf, "GET /main.css", 13) == 0) // +
  1336. {
  1337. fs_open("/main.css", &file);
  1338. *sendLen = file.len;
  1339. return file.data;
  1340. }
  1341. else if (strncmp(receiveBuf, "GET /rotek.png", 14) == 0) // +
  1342. {
  1343. fs_open("/rotek.png", &file);
  1344. *sendLen = file.len;
  1345. return file.data;
  1346. }
  1347. else if (strncmp(receiveBuf, "GET /favicon.ico", 16) == 0) // ?
  1348. {
  1349. fs_open("/favicon.ico", &file);
  1350. *sendLen = file.len;
  1351. return file.data;
  1352. }
  1353. else if (strncmp(receiveBuf, "GET /role.js", 12) == 0)
  1354. {
  1355. fs_open("/role.js", &file);
  1356. *sendLen = file.len;
  1357. return file.data;
  1358. }
  1359. else if (strncmp(receiveBuf, "POST /login.cgi", 15) == 0)
  1360. {
  1361. uint32_t req_data_received = 0;
  1362. char *offset = 0;
  1363. post_data_count = Parse_Content_Length(receiveBuf, receivedBufLen);
  1364. if (post_data_count < MAX_POST_REQ_LEN)
  1365. {
  1366. memset(post_req_data, 0, MAX_POST_REQ_LEN);
  1367. offset = (strstr(receiveBuf, "\r\n\r\n")) + 4;
  1368. req_data_received = receivedBufLen - (offset - &receiveBuf[0]);
  1369. if (offset != 0)
  1370. {
  1371. if (req_data_received < post_data_count)
  1372. {
  1373. snprintf(post_req_data, req_data_received, "%s", receiveBuf);
  1374. post_data_count -= req_data_received;
  1375. }
  1376. /* if data received completely */
  1377. else {
  1378. strncat(post_req_data, &receiveBuf[offset - &receiveBuf[0]], post_data_count);
  1379. //printf("post_req_data: %s\r\n", post_req_data);
  1380. /* End reqest */
  1381. post_data_count = 0;
  1382. log_post_reqn = 0;
  1383. if (HTTP_ConfirmWebPwd(post_req_data, sendBuf, strlen(post_req_data), sendLen) == SEND_REQUIRED_YES) {
  1384. return sendBuf;
  1385. }
  1386. else {
  1387. /* Redirect to login page */
  1388. /* fs_open("/login.html", &file);
  1389. *sendLen = file.len;
  1390. return file.data;*/
  1391. return sendBuf;
  1392. }
  1393. }
  1394. }
  1395. // request was fragmented before "\r\n\r\n"
  1396. else
  1397. {
  1398. log_post_reqn++;
  1399. /* wait max 2 requests */
  1400. if (log_post_reqn > 1) {
  1401. /* End reqest */
  1402. post_data_count = 0;
  1403. log_post_reqn = 0;
  1404. /* Redirect to login page */
  1405. fs_open("/login.html", &file);
  1406. *sendLen = file.len;
  1407. return file.data;
  1408. }
  1409. }
  1410. }
  1411. else
  1412. {
  1413. //printf("Too long POST request!\r\n");
  1414. // Ignore request
  1415. post_data_count = 0;
  1416. log_post_reqn = 0;
  1417. // Redirect to login page
  1418. fs_open("/login.html", &file);
  1419. *sendLen = file.len;
  1420. return file.data;
  1421. }
  1422. }
  1423. else if (post_data_count > 0)
  1424. {
  1425. strncat(post_req_data, receiveBuf, post_data_count);
  1426. post_data_count = 0;
  1427. log_post_reqn = 0;
  1428. if (HTTP_ConfirmWebPwd(post_req_data, sendBuf, strlen(post_req_data), sendLen) == SEND_REQUIRED_YES)
  1429. {
  1430. return sendBuf;
  1431. }
  1432. else
  1433. {
  1434. return sendBuf;
  1435. }
  1436. }
  1437. else
  1438. {
  1439. fs_open("/login.html", &file);
  1440. *sendLen = file.len;
  1441. return file.data;
  1442. }
  1443. }
  1444. //
  1445. char* AuthenticatedTrueRoutine(uint16_t* sendLen)
  1446. {
  1447. char *DataOffset;
  1448. if (strncmp(receiveBuf, "GET /getJson.cgi", 16) == 0) // +
  1449. {
  1450. HTTP_GetParamsPage1(sendBuf);
  1451. *sendLen = strlen(sendBuf);
  1452. return sendBuf;
  1453. }
  1454. else if (strncmp(receiveBuf, "GET /settings.cgi", 17) == 0) // +
  1455. {
  1456. if (seclevel == 0) {
  1457. if (HTTP_SettingsPage(receiveBuf, sendBuf, receivedBufLen, sendLen) == SEND_REQUIRED_YES)
  1458. {
  1459. *sendLen = strlen(sendBuf);
  1460. return sendBuf;
  1461. }
  1462. }
  1463. return 0;
  1464. }
  1465. else if (strncmp(receiveBuf, "POST /settings.cgi", 18) == 0 || DataFlag2 >= 1)
  1466. {
  1467. if (seclevel == 0)
  1468. {
  1469. DataOffset = 0;
  1470. // POST Packet received
  1471. if (DataFlag2 == 0)
  1472. {
  1473. TotalReceived = 0;
  1474. memset(sendBuf, 0, strlen(sendBuf));
  1475. // parse packet for Content-length field
  1476. size = Parse_Content_Length(receiveBuf, receivedBufLen);
  1477. DataOffset = strstr(receiveBuf, "managerIP");
  1478. // case of MSIE8 : we do not receive data in the POST packet
  1479. if (DataOffset == 0)
  1480. {
  1481. DataFlag2++;
  1482. return 0;
  1483. }
  1484. else{
  1485. TotalReceived = receivedBufLen - (DataOffset - &receiveBuf[0]);
  1486. strncat(sendBuf, DataOffset, TotalReceived);
  1487. }
  1488. }
  1489. if (DataFlag2 == 0)
  1490. {
  1491. DataFlag2++;
  1492. }
  1493. else if (DataFlag2 == 1)
  1494. {
  1495. /* parse packet for the octet-stream field */
  1496. DataOffset = strstr(receiveBuf, "managerIP");
  1497. TotalReceived += receivedBufLen;
  1498. strncat(sendBuf, DataOffset, TotalReceived);
  1499. DataFlag2++;
  1500. }
  1501. /* DataFlag >1 => the packet is data only */
  1502. else
  1503. {
  1504. TotalReceived +=receivedBufLen;
  1505. strncat(sendBuf, receiveBuf, receivedBufLen);
  1506. }
  1507. // check if last data packet
  1508. if (TotalReceived == size)
  1509. {
  1510. DBG printf("State: Received %d bytes\r\n", (int)TotalData);
  1511. // printf("receive %s \r\n", sendBuf);
  1512. strncat(sendBuf, " ", 1);
  1513. HTTP_SetSettings(sendBuf, strlen(sendBuf));
  1514. memset(sendBuf, 0, size);
  1515. DataFlag2 = 0;
  1516. strcpy(sendBuf, "HTTP/1.1 200 OK\r\n");
  1517. strcat(sendBuf, "\r\n\r\n");
  1518. strcat(sendBuf,"<!DOCTYPE html><html lang=""><head><meta http-equiv=\"refresh\" content=\"0;url=/settings.html\"/></head></html>\r\n\r\n");
  1519. sendBufLoadLen = strlen(sendBuf);
  1520. *sendLen = sendBufLoadLen;
  1521. return sendBuf;
  1522. }
  1523. }
  1524. return 0;
  1525. }
  1526. else if (strncmp(receiveBuf, "GET /info.cgi", 13) == 0) // +
  1527. {
  1528. if (HTTP_InfoPage(receiveBuf, sendBuf, receivedBufLen, sendLen) == SEND_REQUIRED_YES)
  1529. {
  1530. return sendBuf;
  1531. }
  1532. }
  1533. else if (strncmp(receiveBuf, "POST /info.cgi", 14) == 0 || DataFlag >= 1)
  1534. {
  1535. DataOffset = 0;
  1536. // POST Packet received
  1537. if (DataFlag == 0)
  1538. {
  1539. TotalReceived = 0;
  1540. memset(sendBuf, 0, strlen(sendBuf));
  1541. // parse packet for Content-length field
  1542. size = Parse_Content_Length(receiveBuf, receivedBufLen);
  1543. DataOffset = strstr(receiveBuf, "sysname");
  1544. // case of MSIE8 : we do not receive data in the POST packet
  1545. if (DataOffset == 0)
  1546. {
  1547. DataFlag++;
  1548. return 0;
  1549. }
  1550. else{
  1551. TotalReceived = receivedBufLen - (DataOffset - &receiveBuf[0]);
  1552. strncat(sendBuf, DataOffset, TotalReceived);
  1553. }
  1554. }
  1555. if (DataFlag == 0)
  1556. {
  1557. DataFlag++;
  1558. }
  1559. else if (DataFlag == 1)
  1560. {
  1561. /* parse packet for the octet-stream field */
  1562. DataOffset = strstr(receiveBuf, "sysname");
  1563. TotalReceived += receivedBufLen;
  1564. strncat(sendBuf, DataOffset, TotalReceived);
  1565. DataFlag++;
  1566. }
  1567. /* DataFlag >1 => the packet is data only */
  1568. else
  1569. {
  1570. TotalReceived +=receivedBufLen;
  1571. strncat(sendBuf, receiveBuf, receivedBufLen);
  1572. }
  1573. // check if last data packet
  1574. if (TotalReceived == size)
  1575. {
  1576. strncat(sendBuf, " ", 1);
  1577. HTTP_SetInfo(sendBuf, strlen(sendBuf));
  1578. DataFlag = 0;
  1579. memset(sendBuf, 0, size);
  1580. strcpy(sendBuf, "HTTP/1.1 200 OK\r\n");
  1581. strcat(sendBuf, "\r\n\r\n");
  1582. strcat(sendBuf,"<!DOCTYPE html><html lang=""><head><meta http-equiv=\"refresh\" content=\"0;url=/info.html\"/></head></html>\r\n\r\n");
  1583. *sendLen = strlen(sendBuf);
  1584. return sendBuf;
  1585. }
  1586. }
  1587. else if (strncmp(receiveBuf, "GET /history.cgi", 16) == 0)
  1588. {
  1589. int res;
  1590. res = HTTP_HistoryPage(receiveBuf, sendBuf, receivedBufLen, sendLen);
  1591. if (res == SEND_REQUIRED_FILE)
  1592. {
  1593. HTTPTypeAnswer = HISTORY_ANSWER;
  1594. return sendBuf;
  1595. }
  1596. else if (res == SEND_REQUIRED_YES)
  1597. {
  1598. return sendBuf;
  1599. }
  1600. }
  1601. else if (strncmp(receiveBuf, "GET /ups_history.cgi", 19) == 0)
  1602. {
  1603. int res;
  1604. res = HTTP_UpsHistoryPage(receiveBuf, sendBuf, receivedBufLen, sendLen);
  1605. if (res == SEND_REQUIRED_FILE)
  1606. {
  1607. HTTPTypeAnswer = UPS_HISTORY_ANSWER;
  1608. return sendBuf;
  1609. }
  1610. else if (res == SEND_REQUIRED_YES)
  1611. {
  1612. return sendBuf;
  1613. }
  1614. }
  1615. /* Тест АКБ ИБП */
  1616. else if (strncmp(receiveBuf, "GET /bat_test.cgi", 17) == 0)
  1617. {
  1618. HTTP_UPSTest(receiveBuf, sendBuf, receivedBufLen, sendLen);
  1619. return sendBuf;
  1620. }
  1621. /* Выключение ИБП */
  1622. else if (strncmp(receiveBuf, "GET /ups_power.cgi", 18) == 0)
  1623. {
  1624. HTTP_UPSshutdown(receiveBuf, sendBuf, receivedBufLen, sendLen);
  1625. return sendBuf;
  1626. }
  1627. /* Сброс настроек и сохранине */
  1628. else if (strncmp(receiveBuf, "GET /reset.cgi", 14) == 0)
  1629. {
  1630. telnet_act = false;
  1631. HTTP_ResetSettings();
  1632. HTTP_SaveSettings();
  1633. fs_open("/settings.html", &file);
  1634. *sendLen = file.len;
  1635. return file.data;
  1636. }
  1637. /* Перезагрузка контроллера */
  1638. else if (strncmp(receiveBuf, "GET /reboot.cgi", 15) == 0)
  1639. {
  1640. telnet_act = false;
  1641. HTTP_Reboot();
  1642. }
  1643. /* Подтверждение новых сетевых настроек */
  1644. else if (strncmp(receiveBuf, "GET /confirm.cgi", 16) == 0)
  1645. {
  1646. telnet_act = false;
  1647. SetWebReinitFlag(false);
  1648. SetConfirmWebParamsFlag();
  1649. fs_open("/index.html", &file);
  1650. *sendLen = file.len;
  1651. return file.data;
  1652. }
  1653. /* Проверка пароля, переход в bootloader */
  1654. else if (strncmp(receiveBuf, "GET /fw_update.cgi", 18) == 0)
  1655. {
  1656. HTTP_ConfirmBootPwd(receiveBuf, sendBuf, receivedBufLen, sendLen);
  1657. return sendBuf;
  1658. }
  1659. /* Смена пароля пользователя */
  1660. else if (strncmp(receiveBuf, "GET /changepwd.cgi", 18) == 0)
  1661. {
  1662. HTTP_ChangeUserPwd(receiveBuf, sendBuf, receivedBufLen, sendLen);
  1663. return sendBuf;
  1664. }
  1665. /* Check common GET request */
  1666. else if (strncmp(receiveBuf, "GET", 3) == 0) {
  1667. char filename[MAX_FILENAME_LEN];
  1668. char nonmatch[MAX_ETAG_LEN];
  1669. char *pnonmatch = NULL;
  1670. uint8_t len;
  1671. if (GetFileName(receiveBuf, filename, &len)) {
  1672. HTTP_UpdateUserLoginTime(user_id);
  1673. /* Parce If-Non_Match value */
  1674. uint8_t nonmatch_len = Parse_Header(receiveBuf, receivedBufLen, If_None_Match, 15, nonmatch);
  1675. if (nonmatch_len < MAX_ETAG_LEN && nonmatch_len > 0) {
  1676. DBG printf("If_None_Match: %s\r\n", nonmatch);
  1677. pnonmatch = nonmatch;
  1678. }
  1679. return send_file(filename, pnonmatch, &file, sendLen);
  1680. }
  1681. }
  1682. else
  1683. {
  1684. HTTP_UpdateUserLoginTime(user_id);
  1685. fs_open("/index.html", &file); // +
  1686. *sendLen = file.len;
  1687. return file.data;
  1688. }
  1689. return 0;
  1690. }
  1691. /**
  1692. * @brief sends file from flash FS
  1693. * @param filename: pointer to the file name to send
  1694. * @param pnonmatch: pointer to the If-Non_Match value
  1695. * @param pcb: pointer to a tcp_pcb struct
  1696. * @param hs: pointer to a http_state struct
  1697. * @param file: pointer to a fs_file struct
  1698. * @retval
  1699. */
  1700. char* send_file(char *filename, char *pnonmatch, struct fs_file *file, uint16_t *Len)
  1701. {
  1702. int res = 0;
  1703. char etag[MAX_ETAG_LEN];
  1704. char *petag = NULL;
  1705. res = fs_open(filename, file);
  1706. if (res == 0) {
  1707. printf("Not found: %s\r\n", filename);
  1708. sprintf(filename, "/index.html");
  1709. fs_open(filename, file);
  1710. }
  1711. /* Find Etag value */
  1712. uint8_t etag_len = Parse_Header(file->data, file->len, Etag, 6, etag);
  1713. if (etag_len < MAX_ETAG_LEN && etag_len > 0) {
  1714. DBG printf("Etag: %s\r\n", etag);
  1715. petag = etag;
  1716. }
  1717. /* Compare Etag and If-Non-Match fields */
  1718. if (pnonmatch && petag && (strcmp(pnonmatch, petag) == 0)) {
  1719. /* Send 304 code */
  1720. sprintf(sendBuf, HTTP_304_NOT_MODIFIED);
  1721. DBG printf(sendBuf);
  1722. *Len = strlen(sendBuf);
  1723. return sendBuf;
  1724. //hs->file = sendBuf;
  1725. //hs->left = strlen(sendBuf);
  1726. }
  1727. else {
  1728. /* Send file */
  1729. //DBG printf("%s\r\n\r\n", filename);
  1730. //hs->file = file->data;
  1731. //hs->left = file->len;
  1732. *Len = file->len;
  1733. return file->data;
  1734. }
  1735. //send_data(pcb, hs);
  1736. //tcp_sent(pcb, http_sent);
  1737. }
  1738. /**
  1739. * @brief Extract the custom field data from HTML data
  1740. * @param data : pointer on receive packet buffer
  1741. * @param len : buffer length
  1742. * @param field : field name
  1743. * @param flen : field name length
  1744. * @retval value : pointer for field data
  1745. */
  1746. static uint32_t Parse_Header(char *data, uint32_t len, const char *field, uint32_t flen, char *value)
  1747. {
  1748. uint32_t i = 0, size = 0;
  1749. char *ptr;
  1750. uint32_t Offset = 0;
  1751. /* Find field name in data buffer */
  1752. for (i = 0; i < len; i++) {
  1753. if (strncmp ((char*)(data + i), field, flen) == 0) {
  1754. Offset = i + flen;
  1755. break;
  1756. }
  1757. }
  1758. /* Copy Field value */
  1759. if (Offset) {
  1760. i = 0;
  1761. ptr = (char*)(data + Offset);
  1762. while (*(ptr + i) != 0x0d) {
  1763. value[i] = *(ptr + i);
  1764. i++;
  1765. }
  1766. value[i] = '\0';
  1767. size = i;
  1768. }
  1769. return size;
  1770. }
  1771. /**
  1772. * @brief
  1773. * @retval None
  1774. */
  1775. bool GetFileName(char *inStr, char *fileName, uint8_t *fileNameLen)
  1776. {
  1777. char *beginValue = NULL;
  1778. char *endValue = NULL;
  1779. int len = 0;
  1780. char *strPtr = NULL;
  1781. strPtr = strstr(inStr, "GET");
  1782. if (strPtr == NULL) {
  1783. strPtr = strstr(inStr, "POST");
  1784. }
  1785. if (strPtr == NULL) {
  1786. *fileNameLen = 0;
  1787. return false;
  1788. }
  1789. else {
  1790. beginValue = strpbrk(strPtr, "/");
  1791. endValue = strpbrk(beginValue, " ");
  1792. if (endValue == NULL) {
  1793. *fileNameLen = 0;
  1794. return false;
  1795. }
  1796. len = endValue - beginValue;
  1797. if (len < MAX_FILENAME_LEN) {
  1798. strncpy(fileName, beginValue, len);
  1799. *fileNameLen = len;
  1800. fileName[len] = '\0';
  1801. return true;
  1802. }
  1803. else {
  1804. return false;
  1805. }
  1806. }
  1807. }
  1808. #endif