http_server.c 56 KB

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