http_server.c 56 KB

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