http_server.c 55 KB

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