http_server.c 57 KB

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