http_server.c 77 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532253325342535253625372538253925402541254225432544254525462547254825492550255125522553255425552556255725582559256025612562256325642565256625672568256925702571257225732574257525762577257825792580258125822583258425852586258725882589259025912592259325942595259625972598259926002601260226032604260526062607260826092610261126122613261426152616261726182619262026212622262326242625262626272628262926302631263226332634263526362637263826392640
  1. #include "lwip/opt.h"
  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. #include "fsdata.c"
  11. #include "settings_api.h"
  12. #include "netconf.h"
  13. #include "common_config.h"
  14. #include "testing.h"
  15. #include "rtc.h"
  16. #include "rng.h"
  17. #include "megatec.h"
  18. #include "log.h"
  19. #include "hal.h"
  20. #include "radius_user.h"
  21. #ifdef PRINTF_STDLIB
  22. #include <stdio.h>
  23. #endif
  24. #ifdef PRINTF_CUSTOM
  25. #include "tinystdio.h"
  26. #endif
  27. #include <string.h>
  28. #include <stdlib.h>
  29. #include "FreeRTOS.h"
  30. #include "task.h"
  31. #include "fr_timers.h"
  32. static int fs_open(char *name, struct fs_file *file);
  33. static err_t http_sent(void *arg, struct tcp_pcb *pcb, u16_t len);
  34. static err_t http_sent_history(void *arg, struct tcp_pcb *pcb, u16_t len);
  35. static err_t http_sent_log(void *arg, struct tcp_pcb *pcb, u16_t len);
  36. static void http_sent_log_err(void * arg, err_t err);
  37. static void send_data(struct tcp_pcb *pcb, struct http_state *hs);
  38. static void HTTP_GetUserCookie(uint8_t user_id, char *str, uint8_t *len);
  39. static uint32_t Parse_Content_Length(char *data, uint32_t len);
  40. static void HTTP_SetUserCookie(char *str, uint8_t user_id);
  41. static void HTTP_UpdateUserLoginTime(uint8_t user_id);
  42. static void HTTP_ForceUserLogout(uint8_t user_id);
  43. void LogoutTimerCallback(TimerHandle_t pxTimer);
  44. void LoginTimerCallback(TimerHandle_t pxTimer);
  45. int HTTP_ChangeUserPwd(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut);
  46. SET_PAGE_t SET_PAGE = SET_PAGE_IDLE;
  47. #define SEND_BUF_MAX_LEN 2000
  48. #define RECIVE_BUF_MAX_LEN 1500
  49. char sendBuf[SEND_BUF_MAX_LEN];
  50. uint16_t sendBufLoadLen = 0;
  51. uint16_t printLen = 0;
  52. //char printBuf[1000];
  53. char receiveBuf[RECIVE_BUF_MAX_LEN];
  54. uint16_t receivedBufLen = 0;
  55. #define MAX_POST_REQ_LEN 256
  56. char post_req_data[MAX_POST_REQ_LEN];
  57. uint32_t post_data_count;
  58. uint32_t log_post_reqn;
  59. /* Logout timeout, 30 minutes */
  60. #define WEB_LOGOUT_TIME configTICK_RATE_HZ*60*30
  61. /* Max user active sessions count */
  62. #define WEB_USER_MAX_SESSION_COUNT 5
  63. struct {
  64. //auth_session_t session[WEB_USER_MAX_SESSION_COUNT];
  65. char cookie[MAX_WEB_COOKIE_LEN];
  66. TimerHandle_t LogoutTimer;
  67. } users[MAX_WEB_USERS];
  68. TimerHandle_t RepeatLoginTimer;
  69. /* Repeat Login timeout, 1 minutes */
  70. #define REPEAT_LOGIN_TIME configTICK_RATE_HZ*60*1
  71. uint8_t cnt_err_psw = 0;
  72. bool Authenticated = false;
  73. /* Level of currently logged-in user */
  74. uint8_t seclevel = 0xFF;
  75. static volatile uint32_t DataFlag2=0;
  76. static volatile uint32_t DataFlag=0;
  77. static volatile uint32_t size =0;
  78. static uint32_t TotalReceived=0;
  79. static volatile uint32_t TotalData=0;
  80. static uint32_t ContentLengthOffset =0, BrowserFlag=0;
  81. static const char Content_Length[17] =
  82. /* Content Length */
  83. {0x43, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2d, 0x4c, 0x65, 0x6e, 0x67,0x74, 0x68, 0x3a, 0x20, };
  84. const char HTTP_200_OK[] = "HTTP/1.1 200 OK\r\n\r\n";
  85. /* utf-8 marker to support MS Excel */
  86. const char UTF8_BOM[] = {0xEF, 0xBB, 0xBF, 0x00};
  87. unsigned long log_ptr = 0;
  88. unsigned long log_size = 0;
  89. bool fLogTransInprog = false;
  90. static bool fl_raddius_net_err = false;
  91. /**
  92. * @brief Общая структура настроек
  93. */
  94. extern SETTINGS_t sSettings;
  95. /**
  96. * @brief closes tcp connection
  97. * @param pcb: pointer to a tcp_pcb struct
  98. * @param hs: pointer to a http_state struct
  99. * @retval
  100. */
  101. static void close_conn(struct tcp_pcb *pcb, struct http_state *hs)
  102. {
  103. tcp_arg(pcb, NULL);
  104. tcp_sent(pcb, NULL);
  105. tcp_recv(pcb, NULL);
  106. mem_free(hs);
  107. tcp_close(pcb);
  108. }
  109. /**
  110. * @brief callback function for handling TCP HTTP traffic
  111. * @param arg: pointer to an argument structure to be passed to callback function
  112. * @param pcb: pointer to a tcp_pcb structure
  113. * @param p: pointer to a packet buffer
  114. * @param err: LwIP error code
  115. * @retval err
  116. */
  117. static err_t http_recv(void *arg, struct tcp_pcb *pcb, struct pbuf *p, err_t err)
  118. {
  119. char *data;
  120. struct http_state *hs;
  121. struct fs_file file = {0, 0};
  122. hs = arg;
  123. if (err == ERR_OK && p != NULL)
  124. {
  125. tcp_recved(pcb, p->tot_len);
  126. if (hs->file == NULL)
  127. {
  128. data = p->payload;
  129. /*
  130. printLen = p->tot_len;
  131. memcpy(printBuf, p->payload , printLen);
  132. printf(printBuf);
  133. */
  134. receivedBufLen = p->tot_len;
  135. memcpy(receiveBuf, p->payload , receivedBufLen);
  136. // На производстве
  137. if (strncmp(data, "GET /setProdate.cgi", 19) == 0)
  138. {
  139. HTTP_Prodate(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen);
  140. hs->file = sendBuf;
  141. hs->left = sendBufLoadLen;
  142. send_data(pcb, hs);
  143. tcp_sent(pcb, http_sent);
  144. }
  145. }
  146. pbuf_free(p);
  147. close_conn(pcb,hs);
  148. }
  149. if (err == ERR_OK && p == NULL)
  150. {
  151. close_conn(pcb, hs);
  152. }
  153. return ERR_OK;
  154. }
  155. /**
  156. * @brief Error callback for log file transfer
  157. */
  158. static void http_sent_log_err(void * arg, err_t err)
  159. {
  160. (void)err;
  161. (void)arg;
  162. /* Clear file transfer in progress flag */
  163. fLogTransInprog = false;
  164. }
  165. /**
  166. * @brief Sent callback for log file transfer (messages as is, not ordered)
  167. */
  168. static err_t http_sent_log(void *arg, struct tcp_pcb *pcb, u16_t len)
  169. {
  170. struct http_state *hs;
  171. uint32_t nbytes = 0;
  172. static bool start = true;
  173. (void)len;
  174. hs = arg;
  175. if (hs->left > 0)
  176. {
  177. send_data(pcb, hs);
  178. }
  179. else
  180. {
  181. memset(logFileBuf, 0, FILE_BUF_MAX_LEN);
  182. if (log_ptr + FILE_BUF_MAX_LEN_LOG <= log_size) {
  183. nbytes = LOG_GetData(log_ptr, logFileBuf, FILE_BUF_MAX_LEN_LOG, start);
  184. }
  185. else if (log_ptr < log_size) {
  186. nbytes = LOG_GetData(log_ptr, logFileBuf, (log_size - log_ptr), start);
  187. }
  188. else {
  189. nbytes = 0;
  190. }
  191. log_ptr += nbytes;
  192. start = false;
  193. if (nbytes == 0) {
  194. /* File transfer finished. */
  195. start = true;
  196. close_conn(pcb, hs);
  197. /* Clear file transfer in progress flag */
  198. fLogTransInprog = false;
  199. return ERR_OK;
  200. }
  201. hs->file = logFileBuf;
  202. hs->left = nbytes;
  203. send_data(pcb, hs);
  204. tcp_sent(pcb, http_sent_log);
  205. }
  206. return ERR_OK;
  207. }
  208. /**
  209. * @brief Sent callback for log file transfer (messages as is, not ordered)
  210. */
  211. static err_t http_sent_history(void *arg, struct tcp_pcb *pcb, u16_t len)
  212. {
  213. struct http_state *hs;
  214. uint32_t nbytes = 0;
  215. static bool start = true;
  216. (void)len;
  217. hs = arg;
  218. if (hs->left > 0)
  219. {
  220. send_data(pcb, hs);
  221. }
  222. else
  223. {
  224. memset(logFileBuf, 0, FILE_BUF_MAX_LEN);
  225. if (log_ptr + FILE_BUF_MAX_LEN <= log_size) {
  226. nbytes = History_GetData(log_ptr, logFileBuf, FILE_BUF_MAX_LEN, start);
  227. }
  228. else if (log_ptr < log_size) {
  229. nbytes = History_GetData(log_ptr, logFileBuf, (log_size - log_ptr), start);
  230. }
  231. else {
  232. nbytes = 0;
  233. }
  234. log_ptr += nbytes;
  235. start = false;
  236. if (nbytes == 0) {
  237. /* File transfer finished. */
  238. start = true;
  239. close_conn(pcb, hs);
  240. /* Clear file transfer in progress flag */
  241. fLogTransInprog = false;
  242. return ERR_OK;
  243. }
  244. hs->file = logFileBuf;
  245. hs->left = nbytes;
  246. send_data(pcb, hs);
  247. tcp_sent(pcb, http_sent_history);
  248. }
  249. return ERR_OK;
  250. }
  251. /**
  252. * @brief callback function for handling connection errors
  253. * @param arg: pointer to an argument to be passed to callback function
  254. * @param err: LwIP error code
  255. * @retval none
  256. */
  257. static void conn_err(void *arg, err_t err)
  258. {
  259. struct http_state *hs;
  260. hs = arg;
  261. mem_free(hs);
  262. }
  263. /**
  264. * @brief callback function called after a successfull TCP data packet transmission
  265. * @param arg: pointer to an argument to be passed to callback function
  266. * @param pcb: pointer on tcp_pcb structure
  267. * @param len
  268. * @retval err : LwIP error code
  269. */
  270. static err_t http_sent(void *arg, struct tcp_pcb *pcb, u16_t len)
  271. {
  272. struct http_state *hs;
  273. hs = arg;
  274. if (hs->left > 0)
  275. {
  276. send_data(pcb, hs);
  277. }
  278. else
  279. {
  280. close_conn(pcb, hs);
  281. }
  282. return ERR_OK;
  283. }
  284. /**
  285. * @brief sends data found in member "file" of a http_state struct
  286. * @param pcb: pointer to a tcp_pcb struct
  287. * @param hs: pointer to a http_state struct
  288. * @retval none
  289. */
  290. static void send_data(struct tcp_pcb *pcb, struct http_state *hs)
  291. {
  292. err_t err;
  293. u16_t len;
  294. /* We cannot send more data than space available in the send
  295. buffer */
  296. if (tcp_sndbuf(pcb) < hs->left)
  297. {
  298. len = tcp_sndbuf(pcb);
  299. }
  300. else
  301. {
  302. len = hs->left;
  303. }
  304. err = tcp_write(pcb, hs->file, len, 0);
  305. if (err == ERR_OK)
  306. {
  307. hs->file += len;
  308. hs->left -= len;
  309. }
  310. }
  311. /**
  312. * @brief tcp poll callback function
  313. * @param arg: pointer to an argument to be passed to callback function
  314. * @param pcb: pointer on tcp_pcb structure
  315. * @retval err_t
  316. */
  317. static err_t http_poll(void *arg, struct tcp_pcb *pcb)
  318. {
  319. if (arg == NULL)
  320. {
  321. tcp_close(pcb);
  322. }
  323. else
  324. {
  325. send_data(pcb, (struct http_state *)arg);
  326. }
  327. return ERR_OK;
  328. }
  329. /**
  330. * @brief callback function on TCP connection setup ( on port 80)
  331. * @param arg: pointer to an argument structure to be passed to callback function
  332. * @param pcb: pointer to a tcp_pcb structure
  333. * &param err: Lwip stack error code
  334. * @retval err
  335. */
  336. static err_t http_accept(void *arg, struct tcp_pcb *pcb, err_t err)
  337. {
  338. struct http_state *hs;
  339. /* Allocate memory for the structure that holds the state of the connection */
  340. hs = mem_malloc(sizeof(struct http_state));
  341. if (hs == NULL)
  342. {
  343. return ERR_MEM;
  344. }
  345. /* Initialize the structure. */
  346. hs->file = NULL;
  347. hs->left = 0;
  348. /* Tell TCP that this is the structure we wish to be passed for our
  349. callbacks. */
  350. tcp_arg(pcb, hs);
  351. /* Tell TCP that we wish to be informed of incoming data by a call
  352. to the http_recv() function. */
  353. tcp_recv(pcb, http_recv);
  354. tcp_err(pcb, conn_err);
  355. tcp_poll(pcb, http_poll, 10);
  356. return ERR_OK;
  357. }
  358. /**
  359. * @brief Opens a file defined in fsdata.c ROM filesystem
  360. * @param name : pointer to a file name
  361. * @param file : pointer to a fs_file structure
  362. * @retval 1 if success, 0 if fail
  363. */
  364. static int fs_open(char *name, struct fs_file *file)
  365. {
  366. struct fsdata_file_noconst *f;
  367. for (f = (struct fsdata_file_noconst *)FS_ROOT; f != NULL; f = (struct fsdata_file_noconst *)f->next)
  368. {
  369. if (!strcmp(name, f->name))
  370. {
  371. file->data = f->data;
  372. file->len = f->len;
  373. return 1;
  374. }
  375. }
  376. return 0;
  377. }
  378. /**
  379. * @brief Initialize the HTTP server (start its thread)
  380. * @param none
  381. * @retval None
  382. */
  383. void HTTP_Init()
  384. {
  385. char buf[MAX_WEB_COOKIE_LEN];
  386. uint8_t user_id;
  387. //sys_thread_new("HTTP", http_server_netconn_thread, NULL, 3000, 2);
  388. struct tcp_pcb *pcb;
  389. /*create new pcb*/
  390. pcb = tcp_new();
  391. /* bind HTTP traffic to pcb */
  392. tcp_bind(pcb, IP_ADDR_ANY, 80);
  393. /* start listening on port 80 */
  394. pcb = tcp_listen(pcb);
  395. /* define callback function for TCP connection setup */
  396. tcp_accept(pcb, http_accept);
  397. /* for (user_id = 0; user_id < MAX_WEB_USERS; user_id++) {
  398. //Flush user cookie by random value
  399. sprintf(buf, "%X", (unsigned int)GetRandomNumber());
  400. HTTP_SetUserCookie(buf, user_id);
  401. // Create user logout timers
  402. users[user_id].LogoutTimer =
  403. xTimerCreate("LogoutTmr", WEB_LOGOUT_TIME, pdFALSE, ( void * ) user_id, LogoutTimerCallback);
  404. }
  405. */
  406. }
  407. /**
  408. * @brief
  409. * @retval None
  410. */
  411. int HTTP_SettingsPage(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  412. {
  413. char tempStr[30];
  414. strncpy(tempStr, bufIn, 30);
  415. /* В запросе нет параметров, нужно формировать JSON ответ */
  416. if (strpbrk(tempStr,"?") == 0)
  417. {
  418. memset(bufOut, 0, SEND_BUF_MAX_LEN);
  419. HTTP_GetSettings(bufOut);
  420. //printf(bufOut);
  421. *lenBufOut = strlen(bufOut);
  422. return SEND_REQUIRED_YES;
  423. }
  424. /* В запросе есть параметры, нужно парсить и сохранять настройки */
  425. else
  426. {
  427. //HTTP_SetSettings(bufIn, lenBufIn);
  428. return SEND_REQUIRED_NO;
  429. }
  430. }
  431. /**
  432. * @brief
  433. * @retval None
  434. */
  435. int HTTP_InfoPage(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  436. {
  437. char tempStr[30];
  438. strncpy(tempStr, bufIn, 30);
  439. /* В запросе нет параметров, нужно формировать JSON ответ */
  440. if (strpbrk(tempStr,"?") == 0)
  441. {
  442. memset(bufOut, 0, SEND_BUF_MAX_LEN);
  443. HTTP_GetInfo(bufOut);
  444. *lenBufOut = strlen(bufOut);
  445. return SEND_REQUIRED_YES;
  446. }
  447. /* В запросе есть параметры, нужно парсить и сохранять настройки */
  448. else
  449. {
  450. //HTTP_SetInfo(bufIn, lenBufIn);
  451. return SEND_REQUIRED_NO;
  452. /*
  453. HTTP_SetSettings(bufIn, lenBufIn);
  454. return SEND_REQUIRED_NO;
  455. */
  456. }
  457. }
  458. int HTTP_HistoryPage(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  459. {
  460. uint8_t i, valueLen = 0;
  461. char value[20];
  462. uint32_t nbytes = 0;
  463. (void)lenBufIn;
  464. memset(bufOut, 0, FILE_BUF_MAX_LEN);
  465. ClearParamString(bufIn);
  466. memset(value, 0, 20);
  467. GetParamValue(bufIn, "page=", value, &valueLen);
  468. if (strcmp(value, "all") == 0)
  469. {
  470. if (!LOG_IsInit()) {
  471. return SEND_REQUIRED_NO;
  472. }
  473. if (fLogTransInprog == false) {
  474. // Send log as raw data
  475. log_ptr = 0;
  476. log_size = History_GetTotalSTRCount() * STRING_SIZE_HISTORY + sizeof(UTF8_BOM)-1;
  477. sprintf(bufOut, "HTTP/1.1 200 OK\r\nContent-Length:%lu\r\n\r\n%s", log_size, UTF8_BOM);
  478. *lenBufOut = strlen(bufOut);
  479. // Set file transfer in progress flag
  480. fLogTransInprog = true;
  481. return SEND_REQUIRED_FILE;
  482. }
  483. else {
  484. // We send nothing if file transfer already in progress
  485. return SEND_REQUIRED_NO;
  486. }
  487. }
  488. else {
  489. if (!LOG_IsInit()) {
  490. return SEND_REQUIRED_NO;
  491. }
  492. else {
  493. HTTP_GetHistoryPage(bufOut, atoi(value));
  494. *lenBufOut = strlen(bufOut);
  495. return SEND_REQUIRED_YES;
  496. }
  497. }
  498. }
  499. int HTTP_UpsHistoryPage(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  500. {
  501. uint8_t i, valueLen = 0;
  502. char value[20];
  503. uint32_t nbytes = 0;
  504. (void)lenBufIn;
  505. memset(bufOut, 0, FILE_BUF_MAX_LEN);
  506. ClearParamString(bufIn);
  507. memset(value, 0, 20);
  508. GetParamValue(bufIn, "page=", value, &valueLen);
  509. if (strcmp(value, "all") == 0)
  510. {
  511. if (!LOG_IsInit()) {
  512. return SEND_REQUIRED_NO;
  513. }
  514. if (fLogTransInprog == false) {
  515. // Send log as raw data
  516. log_ptr = 0;
  517. log_size = LOG_GetTotalSTRCount() * STRING_SIZE + sizeof(UTF8_BOM)-1;
  518. sprintf(bufOut, "HTTP/1.1 200 OK\r\nContent-Length:%lu\r\n\r\n%s", log_size, UTF8_BOM);
  519. *lenBufOut = strlen(bufOut);
  520. // Set file transfer in progress flag
  521. fLogTransInprog = true;
  522. return SEND_REQUIRED_FILE;
  523. }
  524. else {
  525. // We send nothing if file transfer already in progress
  526. return SEND_REQUIRED_NO;
  527. }
  528. }
  529. else {
  530. if (!LOG_IsInit()) {
  531. return SEND_REQUIRED_NO;
  532. }
  533. else {
  534. HTTP_GetUpsHistoryPage(bufOut, atoi(value));
  535. *lenBufOut = strlen(bufOut);
  536. return SEND_REQUIRED_YES;
  537. }
  538. }
  539. }
  540. /**
  541. * @brief Установка даты производства
  542. */
  543. // TODO Убрать заглушку!
  544. void HTTP_Prodate(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  545. {
  546. uint8_t valueLen = 0;
  547. char value[20];
  548. memset(bufOut, 0, SEND_BUF_MAX_LEN);
  549. ClearParamString(bufIn);
  550. memset(value, 0, 20);
  551. GetParamValue(bufIn, "prodate=", value, &valueLen);
  552. /*
  553. printf("Prodate: ");
  554. printf(value);
  555. printf("\r\n");
  556. */
  557. /* Устанавливаем дату производства */
  558. SETTINGS_SetProDate(value, valueLen);
  559. /* Пока отправляем true */
  560. strcpy(bufOut, "HTTP/1.0 200 OK\r\nContent-Type:text/html\r\n\r\nTrue");
  561. *lenBufOut = strlen(bufOut);
  562. TEST_SetServerFlag();
  563. }
  564. /**
  565. * @brief
  566. * @retval None
  567. */
  568. void HTTP_SetSettings(char *buf, uint16_t lenBuf)
  569. {
  570. uint8_t valueLen = 0;
  571. const uint8_t len = MAX_WEB_PARAM_LEN;
  572. char value[MAX_WEB_PARAM_LEN];
  573. char str[MAX_WEB_PARAM_LEN];
  574. //printf(buf);
  575. //ClearParamString(buf);
  576. memset(value, 0, len);
  577. memset(str, 0, MAX_WEB_PARAM_LEN);
  578. /* SNMP */
  579. GetParamValue(buf, "read_community=", value, &valueLen);
  580. SetReadCommunity(value);
  581. memset(value, 0, len);
  582. GetParamValue(buf, "write_community=", value, &valueLen);
  583. SetWriteCommunity(value);
  584. memset(value, 0, len);
  585. GetParamValue(buf, "managerIP=", value, &valueLen);
  586. SetManagerIp(value);
  587. memset(value, 0, len);
  588. GetParamValue(buf, "managerIP2=", value, &valueLen);
  589. SetManagerIp2(value);
  590. memset(value, 0, len);
  591. GetParamValue(buf, "managerIP3=", value, &valueLen);
  592. SetManagerIp3(value);
  593. memset(value, 0, len);
  594. GetParamValue(buf, "managerIP4=", value, &valueLen);
  595. SetManagerIp4(value);
  596. memset(value, 0, len);
  597. GetParamValue(buf, "managerIP5=", value, &valueLen);
  598. SetManagerIp5(value);
  599. memset(value, 0, len);
  600. /* Сетевые параметры */
  601. GetParamValue(buf, "dhcp=", value, &valueLen);
  602. SetDhcpStateStr(value);
  603. if (strncmp(value, "on", 2) != 0) // Если dhcp off устанавливаем параметры
  604. {
  605. memset(value, 0, len);
  606. GetParamValue(buf, "ipaddr=", value, &valueLen);
  607. SetIPStr(value);
  608. memset(value, 0, len);
  609. GetParamValue(buf, "gw=", value, &valueLen);
  610. SetGatewayStr(value);
  611. memset(value, 0, len);
  612. GetParamValue(buf, "mask=", value, &valueLen);
  613. SetMaskStr(value);
  614. memset(value, 0, len);
  615. }
  616. memset(value, 0, len);
  617. GetParamValue(buf, "swauth=", value, &valueLen);
  618. SetAuthEnableStateStr(value);
  619. if (strncmp(value, "on", 2) == 0){
  620. /* параметры RADIUS*/
  621. memset(value, 0, len);
  622. GetParamValue(buf, "rs_enabled=", value, &valueLen);
  623. SetRDSEnableStateStr(value);
  624. if (strncmp(value, "on", 2) == 0) // Если raddius off устанавливаем параметры
  625. {
  626. memset(value, 0, len);
  627. GetParamValue(buf, "rs_server=", value, &valueLen);
  628. SetRDSIpStr(value);
  629. memset(value, 0, len);
  630. GetParamValue(buf, "rs_port=", value, &valueLen);
  631. SetRDSPortStr(value);
  632. memset(value, 0, len);
  633. GetParamValue(buf, "rs_pwd=", value, &valueLen);
  634. SetRDSPasswordkStr(value);
  635. memset(value, 0, len);
  636. GetParamValue(buf, "rs_key=", value, &valueLen);
  637. SetRDSKeyAccesstStr(value);
  638. memset(value, 0, len);
  639. }
  640. }
  641. memset(value, 0, len);
  642. // Параметры реле и сухих контактов
  643. GetParamValue(buf, "di1=", value, &valueLen);
  644. SetDINTypeActStr(value, 0);
  645. memset(value, 0, len);
  646. GetParamValue(buf, "ro1=", value, &valueLen);
  647. SetROTypeActStr(value, 0);
  648. memset(value, 0, len);
  649. GetParamValue(buf, "ro2=", value, &valueLen);
  650. SetROTypeActStr(value, 1);
  651. memset(value, 0, len);
  652. // Параметры даты и времени
  653. GetParamValue(buf, "ntp=", value, &valueLen);
  654. SetSntpStateStr(value);
  655. if (strncmp(value, "1", 1) == 0) // Если ntp on устанавливаем параметры
  656. {
  657. memset(value, 0, len);
  658. GetParamValue(buf, "ntpservip=", value, &valueLen);
  659. SetSntpServerIpStr(value);
  660. memset(value, 0, len);
  661. }
  662. else if (strncmp(value, "0", 1) == 0){
  663. GetParamValue(buf, "date=", value, &valueLen);
  664. SetDateStr(value);
  665. memset(value, 0, len);
  666. GetParamValue(buf, "time=", value, &valueLen);
  667. url_decode(str, sizeof(str), value);
  668. SetTimeStr(str);
  669. memset(value, 0, len);
  670. }
  671. GetParamValue(buf, "utc=", value, &valueLen);
  672. SetSntpTimeZoneStr(value);
  673. memset(value, 0, len);
  674. /* Если параметры WEB изменились выставляем флаг, сохраняем настройки и перезагружаемся */
  675. if (GetStateWebReinit() == true)
  676. {
  677. SetWebReinitFlag(true);
  678. HTTP_SaveSettings();
  679. /* Блокируем управление ключем на тау секунд*/
  680. //IO_KeyBlockOn();
  681. vTaskDelay(1010);
  682. Reboot();
  683. }
  684. HTTP_SaveSettings();
  685. }
  686. /**
  687. * @brief
  688. * @retval None
  689. */
  690. void HTTP_SetInfo(char *buf, uint16_t lenBuf)
  691. {
  692. uint8_t valueLen = 0;
  693. const uint8_t len = 110;
  694. char value[110];
  695. char str[110];
  696. // ClearParamString(buf);
  697. memset(value, 0, len);
  698. /* Владелец */
  699. GetParamValue(buf, "owner=", value, &valueLen);
  700. url_decode(str, sizeof(str), value);
  701. SetOwner(str);
  702. memset(value, 0, len);
  703. /* Владелец */
  704. GetParamValue(buf, "sysLocation=", value, &valueLen);
  705. url_decode(str, sizeof(str), value);
  706. SetLocation(str);
  707. memset(value, 0, len);
  708. /* Комментарий */
  709. GetParamValue(buf, "comment=", value, &valueLen);
  710. url_decode(str, sizeof(str), value);
  711. SetComment(str);
  712. memset(value, 0, len);
  713. HTTP_SaveSettings();
  714. }
  715. /**
  716. * @brief Запуск/останов теста UPS
  717. */
  718. void HTTP_UPSTest(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  719. {
  720. uint8_t valueLen = 0;
  721. char tempValue[20];
  722. char tempValue2[20];
  723. int8_t res = 0;
  724. char log_string[50];
  725. memset(tempValue, 0, 20);
  726. memset(tempValue2, 0, 20);
  727. memset(log_string, 0,50);
  728. strcpy(bufOut, HTTP_200_OK);
  729. GetParamValue(bufIn, "func=", tempValue, &valueLen);
  730. if (strcmp(tempValue, "stop") == 0){
  731. res = ups_metac_service_pdu(ups_cancel_test);
  732. if(res == 1 || res == 0){
  733. strcat(bufOut, "Тест остановлен!");
  734. strcpy(log_string, name_login);
  735. strcat(log_string, " (Останов)");
  736. log_event_data(LOG_TEST_UPS, log_string);
  737. }
  738. if(res == -1)
  739. strcat(bufOut, "Тест не удалось остановить!");
  740. *lenBufOut = strlen(bufOut);
  741. }
  742. else if (strcmp(tempValue, "discharge") == 0){
  743. res = ups_metac_service_pdu(ups_test_low_bat);
  744. if(res == 1 || res == 0){
  745. strcat(bufOut, "Тест запущен!");
  746. strcpy(log_string, name_login);
  747. strcat(log_string, " (Запущен)");
  748. log_event_data(LOG_TEST_UPS, log_string);
  749. }
  750. if(res == -1)
  751. strcat(bufOut, "Тест не удалось запустить!");
  752. *lenBufOut = strlen(bufOut);
  753. }
  754. else if (strncmp(tempValue, "time", 6) == 0){
  755. GetParamValue(bufIn, "=", tempValue2, &valueLen);
  756. TimeParam = atoi(tempValue2);
  757. res = ups_metac_service_pdu(ups_test_time);
  758. if(res == 1 || res == 0){
  759. strcat(bufOut, "Тест запущен!");
  760. strcpy(log_string, name_login);
  761. strcat(log_string, " (Запущен)");
  762. log_event_data(LOG_TEST_UPS, log_string);
  763. }
  764. if(res == -1)
  765. strcat(bufOut, "Тест не удалось запустить!");
  766. *lenBufOut = strlen(bufOut);
  767. }
  768. }
  769. /**
  770. * @brief Выклюение UPS
  771. */
  772. void HTTP_UPSshutdown(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  773. {
  774. uint8_t valueLen = 0;
  775. char *valueLenEnd = 0;
  776. char tempValue[50];
  777. char tempValue2[50];
  778. int8_t res = 0;
  779. char log_string[50];
  780. memset(tempValue, 0, 50);
  781. memset(log_string, 0,50);
  782. strcpy(bufOut, HTTP_200_OK);
  783. GetParamValue(bufIn, "func=", tempValue, &valueLen);
  784. if (strcmp(tempValue, "reboot") == 0){
  785. res = ups_metac_service_pdu(ups_cancel_shut_down);
  786. if(res == 1){
  787. strcpy(log_string, name_login);
  788. strcat(log_string, " (Останов)");
  789. log_event_data(LOG_SHUTDOWN_UPS, log_string);
  790. strcat(bufOut, "Выключение нагрузки ИБП отменено!");
  791. }
  792. else
  793. strcat(bufOut, "Выключение нагрузки ИБП не удалось отменить!");
  794. *lenBufOut = strlen(bufOut);
  795. }
  796. else if (strncmp(tempValue, "off", 5) == 0){
  797. memset(tempValue2, 0, 50);
  798. GetParamValue(bufIn, "after=", tempValue2, &valueLen);
  799. TimeParamFloat = atof(tempValue2);
  800. res = ups_metac_service_pdu(ups_shutdown);
  801. if(res == 1){
  802. strcat(bufOut, "Отключение нагрузки ИБП!");
  803. log_event_data(LOG_SHUTDOWN_UPS, name_login);
  804. }else
  805. strcat(bufOut, "Отключение нагрузки ИБП не удалось!");
  806. *lenBufOut = strlen(bufOut);
  807. }
  808. }
  809. /**
  810. * @brief Проверка пароля для перехода в режим bootloader
  811. * @retval None
  812. */
  813. void HTTP_ConfirmBootPwd(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  814. {
  815. char tempStr[50];
  816. strncpy(tempStr, bufIn, 50);
  817. char value[20];
  818. uint8_t valueLen;
  819. memset(value, 0, 20);
  820. //if (GetParamValue(tempStr, "password=", value, &valueLen))
  821. {
  822. //if (strcmp(BOOTLOADER_PASWORD, value) == 0)
  823. {
  824. // *bufOut = '1';
  825. /* Запускаем задачу отложенной перезагрузки. Контроллер должен успеть
  826. отправить ответ серверу о статусе пароля */
  827. HTTP_StartResetTask(true);
  828. }
  829. /* else
  830. *bufOut = '0';*/
  831. //*lenBufOut = 1;
  832. }
  833. }
  834. void LoginTimerCallback(TimerHandle_t pxTimer) {
  835. cnt_err_psw = 0;
  836. DBG printf("cnt_err_psw %d", cnt_err_psw);
  837. xTimerStop(RepeatLoginTimer, 0);
  838. }
  839. /**
  840. * @brief Проверка пароля для входа в Web
  841. * @retval None
  842. */
  843. int HTTP_ConfirmWebPwd(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  844. {
  845. char tempStr[50];
  846. char login[20];
  847. char password[20];
  848. uint8_t valueLen, user_id;
  849. char *strPtr = 0;
  850. char WebPassword[MAX_WEB_PASSWD_LEN];
  851. char WebLogin[MAX_WEB_LOGIN_LEN];
  852. memset(login, 0, 20);
  853. memset(password, 0, 20);
  854. memset(tempStr, 0, 50);
  855. memset(name_login, 0, 50);
  856. /* Get first 50 bytes of string */
  857. strncpy(tempStr, bufIn, 49);
  858. /* Add " " to the string in order GetParamValue() can be able to parse the param */
  859. strcat(tempStr, " ");
  860. GetParamValue(tempStr, "login=", login, &valueLen);
  861. GetParamValue(tempStr, "password=", password, &valueLen);
  862. if((sSettings.sRADIUS.RDSEnable == true) && (fl_raddius_net_err == false)){
  863. switch(RC_Login(login, password)){
  864. case RC_ERROR:
  865. Authenticated = false;
  866. break;
  867. case RC_LOGIN_ADMIN_OK:
  868. Authenticated = true;
  869. user_id = 0;
  870. break;
  871. case RC_LOGIN_USER_OK:
  872. Authenticated = true;
  873. user_id = 1;
  874. break;
  875. case RC_NET_ERR:
  876. Authenticated = false;
  877. fl_raddius_net_err = true;
  878. strcpy(bufOut, "HTTP/1.0 200 OK\r\nContent-Type: text/html;\r\n\r\n");
  879. strcat(bufOut,"<!DOCTYPE html><html><head><meta charset=\"utf-8\"><meta http-equiv=\"refresh\" content=\"3; url=/login.html\" /></head><center><h2>Ошибка соединения с RADIUS сервером</h2></center></html>");
  880. *lenBufOut = strlen(bufOut);
  881. return SEND_REQUIRED_NO;
  882. break;
  883. case RC_ACC_DENIED:
  884. Authenticated = false;
  885. break;
  886. default:
  887. break;
  888. }
  889. }
  890. else{
  891. for (user_id = 0; user_id < MAX_WEB_USERS; user_id++) {
  892. GetUserLogin(user_id, WebLogin, &valueLen);
  893. GetUserPassword(user_id, WebPassword, &valueLen);
  894. /* Check login and password */
  895. if ((strncmp(WebLogin, login, MAX_WEB_LOGIN_LEN) == 0) &&
  896. (strncmp(WebPassword, password, MAX_WEB_PASSWD_LEN) == 0)) {
  897. /* Login and pass are valid */
  898. /* TODO replace global flag with user-pass-cookie */
  899. if(cnt_err_psw < 4){
  900. cnt_err_psw = 0;
  901. Authenticated = true;
  902. }
  903. else{
  904. Authenticated = false;
  905. }
  906. break;
  907. }
  908. else{
  909. Authenticated = false;
  910. }
  911. }
  912. }
  913. if(Authenticated){
  914. /* Generate cookie */
  915. sprintf(tempStr, "%X", (unsigned int)GetRandomNumber());
  916. /* Set users cookie */
  917. HTTP_SetUserCookie(tempStr, user_id);
  918. HTTP_UpdateUserLoginTime(user_id);
  919. /* Send login and cookie back */
  920. strcpy(bufOut, "HTTP/1.0 200 OK\r\nContent-Type:text/html\r\nSet-Cookie: uname=");
  921. strcat(bufOut, login);
  922. strcat(bufOut, "\r\nSet-Cookie: id=");
  923. strcat(bufOut, tempStr);
  924. sprintf(tempStr, "%d", user_id);
  925. strcat(bufOut, "\r\nSet-Cookie: role=");
  926. strcat(bufOut, tempStr);
  927. if(sSettings.sRADIUS.Auth_enable)
  928. strcat(bufOut, "\r\nSet-Cookie: auth=1");
  929. else
  930. strcat(bufOut, "\r\nSet-Cookie: auth=0");
  931. strcat(bufOut, "\r\n\r\n");
  932. strcat(bufOut,"<!DOCTYPE html><html lang=""><head><meta http-equiv=\"refresh\" content=\"0;url=/index.html\"/></head></html>\r\n\r\n");
  933. *lenBufOut = strlen(bufOut);
  934. if((sSettings.sRADIUS.RDSEnable == true) && (fl_raddius_net_err == false)){
  935. snprintf(name_login, (strlen(login)+1), login);
  936. }
  937. else{
  938. fl_raddius_net_err = false;
  939. switch (user_id) {
  940. case 0:
  941. snprintf(name_login, sizeof(name_login), "Администратор");
  942. break;
  943. case 1:
  944. snprintf(name_login, sizeof(name_login), "Пользователь");
  945. break;
  946. default:
  947. snprintf(name_login, (strlen(login)+1), login);
  948. break;
  949. }
  950. }
  951. log_event_data(LOG_LOGIN, name_login);
  952. /* Запускаем задачу-таймер логаута. */
  953. /* TODO отправить ответ серверу о статусе пароля */
  954. return SEND_REQUIRED_YES;
  955. }
  956. else{
  957. if(cnt_err_psw <= 4)
  958. cnt_err_psw ++;
  959. DBG printf("cnt_err_psw %d", cnt_err_psw);
  960. if(cnt_err_psw == 4)
  961. xTimerStart(RepeatLoginTimer, 0);
  962. strcpy(bufOut, "HTTP/1.0 200 OK\r\nContent-Type: text/html;\r\n\r\n");
  963. if((sSettings.sRADIUS.RDSEnable == true) && (fl_raddius_net_err == false)){
  964. if(cnt_err_psw < 4)
  965. strcat(bufOut,"<!DOCTYPE html><html><head><meta charset=\"utf-8\"><meta http-equiv=\"refresh\" content=\"3; url=/rslogin.html\" /></head><center><h2>Не правильный логин или пароль</h2></center></html>");
  966. else
  967. strcat(bufOut,"<!DOCTYPE html><html><head><meta charset=\"utf-8\"><meta http-equiv=\"refresh\" content=\"3; url=/rslogin.html\" /></head><center><h2>Вход заблокирован!</h2></center></head><center><h2>Повторите попытку через 15 минут</h2></center></html>");
  968. }
  969. else{
  970. if(cnt_err_psw < 4)
  971. 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>");
  972. else
  973. 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>Повторите попытку через 15 минут</h2></center></html>");
  974. }
  975. *lenBufOut = strlen(bufOut);
  976. return SEND_REQUIRED_NO;
  977. }
  978. }
  979. void HTTP_LOGIN(char *bufOut, uint16_t *lenBufOut)
  980. {
  981. char tempStr[50];
  982. uint8_t valueLen;
  983. char WebLogin[MAX_WEB_LOGIN_LEN];
  984. GetUserLogin(ADMIN, WebLogin, &valueLen);
  985. memset(tempStr, 0, 50);
  986. memset(name_login, 0, 50);
  987. /* TODO replace global flag with user-pass-cookie */
  988. Authenticated = true;
  989. /* Generate cookie */
  990. sprintf(tempStr, "%X", (unsigned int)GetRandomNumber());
  991. /* Set users cookie */
  992. HTTP_SetUserCookie(tempStr, ADMIN);
  993. HTTP_UpdateUserLoginTime(ADMIN);
  994. /* Send login and cookie back */
  995. strcpy(bufOut, "HTTP/1.0 200 OK\r\nContent-Type:text/html\r\nSet-Cookie: uname=");
  996. strcat(bufOut, WebLogin);
  997. strcat(bufOut, "\r\nSet-Cookie: id=");
  998. strcat(bufOut, tempStr);
  999. strcat(bufOut, "\r\nSet-Cookie: role=0");
  1000. if(sSettings.sRADIUS.Auth_enable)
  1001. strcat(bufOut, "\r\nSet-Cookie: auth=1");
  1002. else
  1003. strcat(bufOut, "\r\nSet-Cookie: auth=0");
  1004. strcat(bufOut, "\r\n\r\n");
  1005. strcat(bufOut,"<!DOCTYPE html><html lang=""><head><meta http-equiv=\"refresh\" content=\"0;url=/index.html\"/></head></html>\r\n\r\n");
  1006. *lenBufOut = strlen(bufOut);
  1007. snprintf(name_login, sizeof(name_login), "Администратор");
  1008. }
  1009. /**
  1010. * @brief
  1011. * @retval None
  1012. */
  1013. uint8_t GetParamValue(char *inStr, char *paramName, char *paramValue, uint8_t *paramLen)
  1014. {
  1015. char *beginValue = 0;
  1016. char *endValue = 0;
  1017. int len = 0;
  1018. char *strPtr = 0;
  1019. strPtr = strstr(inStr, paramName);
  1020. if (strPtr != 0)
  1021. {
  1022. beginValue = strpbrk(strPtr,"=");
  1023. endValue = strpbrk(strPtr,"&");
  1024. if (endValue == 0)
  1025. endValue = strpbrk(strPtr," ");
  1026. len = endValue - beginValue - 1;
  1027. strncpy(paramValue, beginValue + 1, len);
  1028. *endValue = '0';
  1029. *beginValue = '0';
  1030. *paramLen = len;
  1031. return 1;
  1032. }
  1033. else
  1034. {
  1035. *paramLen = 0;
  1036. return 0;
  1037. }
  1038. }
  1039. /**
  1040. * @brief
  1041. * @retval None
  1042. */
  1043. uint8_t GetCookieValue(char *inStr, char *paramName, char *paramValue, uint8_t *paramLen)
  1044. {
  1045. char *beginValue = 0;
  1046. char *endValue = 0;
  1047. int len = 0;
  1048. char *strPtr = 0;
  1049. strPtr = strstr(inStr, paramName);
  1050. if (strPtr != 0)
  1051. {
  1052. beginValue = strpbrk(strPtr,"=");
  1053. endValue = strpbrk(strPtr,";");
  1054. if (endValue == 0)
  1055. endValue = strpbrk(strPtr,"\n");
  1056. len = endValue - beginValue - 1;
  1057. strncpy(paramValue, beginValue + 1, len);
  1058. *endValue = '0';
  1059. *beginValue = '0';
  1060. *paramLen = len;
  1061. return 1;
  1062. }
  1063. else
  1064. {
  1065. *paramLen = 0;
  1066. return 0;
  1067. }
  1068. }
  1069. /**
  1070. * @brief
  1071. * @retval None
  1072. */
  1073. /*
  1074. uint8_t GetParamValueInEnd(char *inStr, char *paramName, char *paramValue, uint8_t *paramLen)
  1075. {
  1076. char *beginValue = 0;
  1077. char *endValue = 0;
  1078. int len = 0;
  1079. char *strPtr = 0;
  1080. strPtr = strstr(inStr, paramName);
  1081. if (strPtr != 0)
  1082. {
  1083. beginValue = strpbrk(strPtr,"=");
  1084. endValue = strpbrk(strPtr," ");
  1085. len = endValue - beginValue - 1;
  1086. strncpy(paramValue, beginValue + 1, len);
  1087. *endValue = '0';
  1088. *beginValue = '0';
  1089. *paramLen = len;
  1090. return 1;
  1091. }
  1092. else
  1093. {
  1094. *paramLen = 0;
  1095. return 0;
  1096. }
  1097. }
  1098. */
  1099. void ClearParamString(char *inBuf)
  1100. {
  1101. uint16_t len;
  1102. char *str;
  1103. str = strstr(inBuf, "HTTP");
  1104. if (str != 0)
  1105. {
  1106. len = str - inBuf;
  1107. memset(str, 0, RECIVE_BUF_MAX_LEN - len - 1);
  1108. }
  1109. }
  1110. /**
  1111. * @brief Чтение Cookie пользователя
  1112. */
  1113. static void HTTP_GetUserCookie(uint8_t user_id, char *str, uint8_t *len)
  1114. {
  1115. sprintf(str, "%s", users[user_id].cookie);
  1116. *len = strlen(str);
  1117. }
  1118. /**
  1119. * @brief Установка Cookie пользователя
  1120. */
  1121. static void HTTP_SetUserCookie(char *str, uint8_t user_id)
  1122. {
  1123. strcpy(users[user_id].cookie, str);
  1124. }
  1125. /**
  1126. * @brief Обновление времени последней активности пользователя
  1127. */
  1128. static void HTTP_UpdateUserLoginTime(uint8_t user_id)
  1129. {
  1130. xTimerStart(users[user_id].LogoutTimer, 0);
  1131. }
  1132. /**
  1133. * @brief Extract the Content_Length data from HTML data
  1134. * @param data : pointer on receive packet buffer
  1135. * @param len : buffer length
  1136. * @retval size : Content_length in numeric format
  1137. */
  1138. static uint32_t Parse_Content_Length(char *data, uint32_t len)
  1139. {
  1140. uint32_t i=0,size=0, S=1;
  1141. int32_t j=0;
  1142. char sizestring[6], *ptr;
  1143. ContentLengthOffset =0;
  1144. /* find Content-Length data in packet buffer */
  1145. for (i=0;i<len;i++)
  1146. {
  1147. if (strncmp ((char*)(data+i), Content_Length, 16)==0)
  1148. {
  1149. ContentLengthOffset = i+16;
  1150. break;
  1151. }
  1152. }
  1153. /* read Content-Length value */
  1154. if (ContentLengthOffset)
  1155. {
  1156. i=0;
  1157. ptr = (char*)(data + ContentLengthOffset);
  1158. while(*(ptr+i)!=0x0d)
  1159. {
  1160. sizestring[i] = *(ptr+i);
  1161. i++;
  1162. ContentLengthOffset++;
  1163. }
  1164. if (i>0)
  1165. {
  1166. /* transform string data into numeric format */
  1167. for(j=i-1;j>=0;j--)
  1168. {
  1169. size += (sizestring[j]-0x30)*S;
  1170. S=S*10;
  1171. }
  1172. }
  1173. }
  1174. return size;
  1175. }
  1176. /**
  1177. * @brief Принудительный логаут пользователя
  1178. */
  1179. static void HTTP_ForceUserLogout(uint8_t user_id)
  1180. {
  1181. char cookie[MAX_WEB_COOKIE_LEN];
  1182. /* Flush user cookie by random value */
  1183. sprintf(cookie, "%X", (unsigned int)GetRandomNumber());
  1184. HTTP_SetUserCookie(cookie, user_id);
  1185. }
  1186. /**
  1187. * @brief >Callback таймера логаута пользователя
  1188. */
  1189. void LogoutTimerCallback(TimerHandle_t pxTimer) {
  1190. uint8_t user_id = (uint8_t)pvTimerGetTimerID( pxTimer );
  1191. if( sSettings.sRADIUS.Auth_enable )
  1192. HTTP_ForceUserLogout(user_id);
  1193. }
  1194. /**
  1195. * @brief Смена пароля пользователя
  1196. * @retval None
  1197. */
  1198. int HTTP_ChangeUserPwd(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
  1199. {
  1200. char tempStr[110];
  1201. char value[20];
  1202. char login[20];
  1203. char password[20];
  1204. uint8_t valueLen, valueLen2, user_id;
  1205. char WebLogin[MAX_WEB_LOGIN_LEN];
  1206. (void)lenBufIn;
  1207. memset(login, 0, 20);
  1208. memset(password, 0, 20);
  1209. memset(tempStr, 0, 50);
  1210. memset(value, 0, 20);
  1211. ClearParamString(bufIn);
  1212. strncpy(tempStr, bufIn, 110);
  1213. strcpy(bufOut, HTTP_200_OK);
  1214. if (GetParamValue(tempStr, "username=", login, &valueLen) &&
  1215. GetParamValue(tempStr, "oldpass=", password, &valueLen))
  1216. {
  1217. for (user_id = 0; user_id < MAX_WEB_USERS; user_id++)
  1218. {
  1219. memset(value, 0, 20);
  1220. memset(WebLogin, 0, MAX_WEB_LOGIN_LEN);
  1221. GetUserLogin(user_id, WebLogin, &valueLen);
  1222. GetUserPassword(user_id, value, &valueLen2);
  1223. /* Check login and password */
  1224. if ((strncmp(WebLogin, login, MAX_WEB_LOGIN_LEN) == 0) &&
  1225. (memcmp(password, value, 11) == 0))
  1226. {
  1227. memset(password, 0, 20);
  1228. if (GetParamValue(tempStr, "newpass=", password, &valueLen))
  1229. {
  1230. memcpy(sSettings.sAuth[user_id].password, password, 11);
  1231. HTTP_SaveSettings();
  1232. log_event_data(LOG_PSW_CHANGE, name_login);
  1233. strcat(bufOut, "Пароль успешно изменён");
  1234. *lenBufOut = strlen(bufOut);
  1235. return SEND_REQUIRED_YES;
  1236. }
  1237. else {
  1238. strcat(bufOut, "Введены некорректные данные!");
  1239. *lenBufOut = strlen(bufOut);
  1240. return SEND_REQUIRED_YES;
  1241. }
  1242. }
  1243. }
  1244. strcat(bufOut, "Введён неверный пароль!");
  1245. *lenBufOut = strlen(bufOut);
  1246. return SEND_REQUIRED_YES;
  1247. }
  1248. else {
  1249. strcat(bufOut, "Введены некорректные данные!");
  1250. *lenBufOut = strlen(bufOut);
  1251. return SEND_REQUIRED_YES;
  1252. }
  1253. }
  1254. // -----------------------------------------------------------------------------
  1255. //
  1256. //
  1257. // SSL тесты
  1258. //
  1259. //
  1260. // -----------------------------------------------------------------------------
  1261. //#include "stm32f4xx.h"
  1262. #include "rtc.h"
  1263. /* PolarSSL includes */
  1264. #include "polarssl/net.h"
  1265. #include "polarssl/ssl.h"
  1266. #include "polarssl/havege.h"
  1267. #include "polarssl/certs.h"
  1268. #include "polarssl/x509.h"
  1269. /* Private typedef -----------------------------------------------------------*/
  1270. /* Private define ------------------------------------------------------------*/
  1271. #define DEBUG_LEVEL 1 /* Set DEBUG_LEVEL if you want to enable SSL debug
  1272. option, this should be set to 2, 3, 4 or 5 */
  1273. #define HTTP_RESPONSE "<p><p>Successful connection using: %s\r\n"
  1274. /* Format of dynamic web page */
  1275. #define PAGE_START \
  1276. "<html>\
  1277. <head>\
  1278. </head>\
  1279. <BODY onLoad=\"window.setTimeout(&quot;location.href='index.html'&quot;,1000)\" bgcolor=\"#FFFFFF\" text=\"#000000\">\
  1280. <font size=\"4\" color=\"#0000FF\"><b>STM32F407xx : SSL Server Demo not using HW Crypto :<)</font></b></i>\
  1281. <br><br><pre>\r\nPage Hits = "
  1282. #define PAGE_END \
  1283. " \r\n</pre><br><br><hr>\
  1284. <font size=\"3\" color=\"#808080\">All rights reserved ©2017 ROTEK\
  1285. \r\n</font></BODY>\
  1286. </html>"
  1287. /* Private macro -------------------------------------------------------------*/
  1288. /* Private variables ---------------------------------------------------------*/
  1289. /* SSL structures */
  1290. rng_state rngs;
  1291. ssl_context ssl;
  1292. ssl_session ssn;
  1293. x509_cert srvcert;
  1294. rsa_context rsa;
  1295. uint32_t nPageHits = 0;
  1296. /* Private functions ---------------------------------------------------------*/
  1297. /*
  1298. * Computing a "safe" DH-1024 prime can take a very
  1299. * long time, so a precomputed value is provided below.
  1300. * You may run dh_genprime to generate a new value.
  1301. */
  1302. char *my_dhm_P =
  1303. "E4004C1F94182000103D883A448B3F80" \
  1304. "2CE4B44A83301270002C20D0321CFD00" \
  1305. "11CCEF784C26A400F43DFB901BCA7538" \
  1306. "F2C6B176001CF5A0FD16D2C48B1D0C1C" \
  1307. "F6AC8E1DA6BCC3B4E1F96B0564965300" \
  1308. "FFA1D0B601EB2800F489AA512C4B248C" \
  1309. "01F76949A60BB7F00A40B1EAB64BDD48" \
  1310. "E8A700D60B7F1200FA8E77B0A979DABF";
  1311. char *my_dhm_G = "4";
  1312. /*
  1313. * Sorted by order of preference
  1314. */
  1315. int my_ciphersuites[] =
  1316. {
  1317. SSL_EDH_RSA_AES_256_SHA,
  1318. SSL_EDH_RSA_CAMELLIA_256_SHA,
  1319. SSL_EDH_RSA_AES_128_SHA,
  1320. SSL_EDH_RSA_CAMELLIA_128_SHA,
  1321. SSL_EDH_RSA_DES_168_SHA,
  1322. SSL_RSA_AES_256_SHA,
  1323. SSL_RSA_CAMELLIA_256_SHA,
  1324. SSL_RSA_AES_128_SHA,
  1325. SSL_RSA_CAMELLIA_128_SHA,
  1326. SSL_RSA_DES_168_SHA,
  1327. SSL_RSA_RC4_128_SHA,
  1328. SSL_RSA_RC4_128_MD5,
  1329. 0
  1330. };
  1331. void my_debug(void *ctx, int level, const char *str)
  1332. {
  1333. if(level < DEBUG_LEVEL)
  1334. {
  1335. printf("\r%s", str);
  1336. }
  1337. }
  1338. /*
  1339. * These session callbacks use a simple chained list
  1340. * to store and retrieve the session information.
  1341. */
  1342. ssl_session *s_list_1st = NULL;
  1343. ssl_session *cur, *prv;
  1344. static int my_get_session(ssl_context *ssl)
  1345. {
  1346. time_t t = RTC_GetUnixTime(); //time(NULL);
  1347. if(ssl->resume == 0)
  1348. return(1);
  1349. cur = s_list_1st;
  1350. prv = NULL;
  1351. while(cur != NULL)
  1352. {
  1353. prv = cur;
  1354. cur = cur->next;
  1355. if(ssl->timeout != 0 && t - prv->start > ssl->timeout)
  1356. continue;
  1357. if( ssl->session->ciphersuite != prv->ciphersuite ||
  1358. ssl->session->length != prv->length)
  1359. continue;
  1360. if(memcmp( ssl->session->id, prv->id, prv->length ) != 0)
  1361. continue;
  1362. memcpy(ssl->session->master, prv->master, 48);
  1363. return(0);
  1364. }
  1365. return(1);
  1366. }
  1367. static int my_set_session(ssl_context *ssl)
  1368. {
  1369. time_t t = RTC_GetUnixTime(); //time(NULL);
  1370. cur = s_list_1st;
  1371. prv = NULL;
  1372. while(cur != NULL)
  1373. {
  1374. if(ssl->timeout != 0 && t - cur->start > ssl->timeout)
  1375. break; /* expired, reuse this slot */
  1376. if(memcmp( ssl->session->id, cur->id, cur->length ) == 0)
  1377. break; /* client reconnected */
  1378. prv = cur;
  1379. cur = cur->next;
  1380. }
  1381. if(cur == NULL)
  1382. {
  1383. cur = (ssl_session *) malloc(sizeof(ssl_session));
  1384. if(cur == NULL)
  1385. return(1);
  1386. if(prv == NULL)
  1387. s_list_1st = cur;
  1388. else prv->next = cur;
  1389. }
  1390. memcpy(cur, ssl->session, sizeof(ssl_session));
  1391. return(0);
  1392. }
  1393. void ssl_server_read(void)
  1394. {
  1395. int ret;
  1396. do
  1397. {
  1398. receivedBufLen = RECIVE_BUF_MAX_LEN - 1;
  1399. memset(receiveBuf, 0, RECIVE_BUF_MAX_LEN);
  1400. // Read decrypted application data
  1401. ret = ssl_read(&ssl, (unsigned char*)receiveBuf, receivedBufLen);
  1402. if(ret == POLARSSL_ERR_NET_WANT_READ || ret == POLARSSL_ERR_NET_WANT_WRITE)
  1403. continue;
  1404. if(ret <= 0)
  1405. {
  1406. switch(ret)
  1407. {
  1408. case POLARSSL_ERR_SSL_PEER_CLOSE_NOTIFY:
  1409. printf("\n\r connection was closed \n");
  1410. break;
  1411. case POLARSSL_ERR_NET_CONN_RESET:
  1412. printf("\n\r connection was reset by peer\n");
  1413. break;
  1414. default:
  1415. //printf("\n\r ssl_read returned %d\n", ret);
  1416. break;
  1417. }
  1418. break;
  1419. }
  1420. receivedBufLen = ret;
  1421. // Display the length of read data
  1422. //printf("\n\r Successfully read %d bytes from client \n\r",len);
  1423. }while(0);
  1424. }
  1425. /**
  1426. * @brief SSL Server task.
  1427. * @param pvParameters not used
  1428. * @retval None
  1429. */
  1430. void ssl_server(void *pvParameters)
  1431. {
  1432. int ret, len;
  1433. int listen_fd;
  1434. int client_fd;
  1435. char buf[1024];
  1436. char *ptr;
  1437. char CookieBuf[50];
  1438. char *CookiePtr = NULL;
  1439. char name[MAX_WEB_COOKIE_LEN];
  1440. char id[MAX_WEB_COOKIE_LEN];
  1441. uint8_t nameLen = 0, idLen = 0;
  1442. char *DataOffset;
  1443. struct fs_file file = {0, 0};
  1444. uint32_t i;
  1445. memset(&srvcert, 0, sizeof(x509_cert));
  1446. // 1. Load the certificates and private RSA key
  1447. //printf("\n\r Loading the server certificates and key...");
  1448. // This demonstration program uses embedded test certificates.
  1449. // Instead, you may want to use x509parse_crtfile() to read the
  1450. // server and CA certificates, as well as x509parse_keyfile().
  1451. ret = x509parse_crt(&srvcert, (unsigned char *) test_srv_crt, strlen(test_srv_crt));
  1452. if(ret != 0)
  1453. {
  1454. //printf(" failed\n ! x509parse_crt returned %d\n\r", ret);
  1455. goto exit;
  1456. }
  1457. ret = x509parse_crt(&srvcert, (unsigned char *) test_ca_crt, strlen(test_ca_crt));
  1458. if(ret != 0)
  1459. {
  1460. //printf(" failed\n ! x509parse_crt returned %d\n\r", ret);
  1461. goto exit;
  1462. }
  1463. rsa_init( &rsa, RSA_PKCS_V15, 0 );
  1464. ret = x509parse_key(&rsa, (unsigned char *) test_srv_key, strlen(test_srv_key), NULL, 0);
  1465. if( ret != 0 )
  1466. {
  1467. //printf(" failed\n ! x509parse_key returned %d\n\r", ret);
  1468. goto exit;
  1469. }
  1470. // 2. Setup the listening TCP socket
  1471. //printf("\n\r Bind to https port ...");
  1472. // Bind the connection to https port : 443
  1473. ret = net_bind(&listen_fd, NULL, 443);
  1474. if(ret != 0)
  1475. {
  1476. //printf(" failed\n ! net_bind returned %d\n\r", ret);
  1477. goto exit;
  1478. }
  1479. //printf(" ok\n\r");
  1480. // 3. Wait until a client connects
  1481. for(;;)
  1482. {
  1483. //printf("\n\r Waiting for a remote connection ...");
  1484. ret = net_accept(listen_fd, &client_fd, NULL);
  1485. if(ret != 0)
  1486. {
  1487. //printf(" failed\n ! net_accept returned %d\n\n", ret);
  1488. goto exit;
  1489. }
  1490. //printf(" ok\n");
  1491. // 4. Initialize the session data
  1492. //printf("\n\r Setting up the RNG and SSL data....");
  1493. // Initialize the SSL context
  1494. ret = ssl_init(&ssl);
  1495. if(ret != 0)
  1496. {
  1497. //printf(" failed\n ! ssl_init returned %d\n\n", ret);
  1498. goto accept;
  1499. }
  1500. //printf(" ok\n");
  1501. // Set the current session as SSL server
  1502. ssl_set_endpoint(&ssl, SSL_IS_SERVER);
  1503. // No certificate verification
  1504. ssl_set_authmode(&ssl, SSL_VERIFY_NONE);
  1505. // Set the random number generator callback function
  1506. ssl_set_rng(&ssl, RandVal, &rngs);
  1507. // Set the debug callback function
  1508. //ssl_set_dbg(&ssl, my_debug, stdout);
  1509. // Set read and write callback functions
  1510. ssl_set_bio(&ssl, net_recv, &client_fd, net_send, &client_fd);
  1511. // Set the session callback functions
  1512. ssl_set_scb(&ssl, my_get_session, my_set_session);
  1513. // The list of ciphersuites to be used in this session
  1514. ssl_set_ciphersuites(&ssl, my_ciphersuites);
  1515. // Set the session resuming flag, timeout and session context
  1516. ssl_set_session(&ssl, 1, 0, &ssn);
  1517. memset(&ssn, 0, sizeof(ssl_session));
  1518. // Set the data required to verify peer certificate
  1519. ssl_set_ca_chain(&ssl, srvcert.next, NULL, NULL);
  1520. // Set own certificate and private key
  1521. ssl_set_own_cert(&ssl, &srvcert, &rsa);
  1522. // Set the Diffie-Hellman public P and G values
  1523. ssl_set_dh_param(&ssl, my_dhm_P, my_dhm_G);
  1524. // 5. Handshake protocol
  1525. //printf("\n\r Performing the SSL/TLS handshake...");
  1526. // Perform the SSL handshake protocol
  1527. while((ret = ssl_handshake(&ssl)) != 0)
  1528. {
  1529. if(ret != POLARSSL_ERR_NET_WANT_READ && ret != POLARSSL_ERR_NET_WANT_WRITE)
  1530. {
  1531. //printf(" failed\n ! ssl_handshake returned %d\n\n", ret);
  1532. goto accept;
  1533. }
  1534. }
  1535. //printf(" ok\n");
  1536. // 6. Read the HTTP Request
  1537. //printf("\n\r <= Read from client :");
  1538. ssl_server_read();
  1539. // -------------------------------------------------------------------------
  1540. //receivedBufLen = p->tot_len;
  1541. //memcpy(receiveBuf, p->payload , receivedBufLen);
  1542. receiveBuf[receivedBufLen] = '\0';
  1543. // printf("receive %s \r\n", receiveBuf);
  1544. // Get cookie "uname" value
  1545. CookiePtr = strstr(receiveBuf, "uname=");
  1546. strncpy(CookieBuf, CookiePtr, 50);
  1547. //printf("********CookieBuf1= %s\r\n", CookieBuf);
  1548. memset(name, 0, MAX_WEB_COOKIE_LEN);
  1549. GetCookieValue(CookieBuf, "uname=", name, &nameLen);
  1550. //printf("********CookieBuf2= %s\r\n", CookieBuf);
  1551. //printf("********uname= %s\r\n", name);
  1552. // Get cookie "id" value
  1553. CookiePtr = strstr(receiveBuf, "id=");
  1554. strncpy(CookieBuf, CookiePtr, 50);
  1555. //printf("********CookieBuf1= %s\r\n", CookieBuf);
  1556. memset(id, 0, MAX_WEB_COOKIE_LEN);
  1557. GetCookieValue(CookieBuf, "id=", id, &idLen);
  1558. //printf("********CookieBuf2= %s\r\n", CookieBuf);
  1559. //printf("********id= %s\r\n", id);
  1560. // Id of currently logged-in user
  1561. uint8_t user_id;
  1562. // Level of currently logged-in user
  1563. seclevel = 0xFF;
  1564. for (user_id = 0; user_id < MAX_WEB_USERS; user_id++) {
  1565. HTTP_GetUserCookie(user_id, CookieBuf, &idLen);
  1566. if (strncmp(id, CookieBuf, idLen) == 0 ) {
  1567. GetUserLevelInt(user_id, &seclevel);
  1568. Authenticated = true;
  1569. break;
  1570. }
  1571. Authenticated = false;
  1572. seclevel = 0xFF;
  1573. }
  1574. if ( Authenticated == false && sSettings.sRADIUS.Auth_enable == false)
  1575. {
  1576. HTTP_LOGIN(sendBuf, &sendBufLoadLen);
  1577. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1578. }
  1579. else if ( Authenticated == false )//&& sSettings.sRADIUS.Auth_enable == true
  1580. {
  1581. if (strncmp(receiveBuf, "GET /main.css", 13) == 0) // +
  1582. {
  1583. fs_open("/main.css", &file);
  1584. ssl_sendframes(&ssl, file.data, file.len);
  1585. }
  1586. else if (strncmp(receiveBuf, "GET /rotek.png", 14) == 0) // +
  1587. {
  1588. fs_open("/rotek.png", &file);
  1589. ssl_sendframes(&ssl, file.data, file.len);
  1590. }
  1591. else if (strncmp(receiveBuf, "GET /favicon.ico", 16) == 0) // ?
  1592. {
  1593. fs_open("/favicon.ico", &file);
  1594. ssl_sendframes(&ssl, file.data, file.len);
  1595. }
  1596. else if (strncmp(receiveBuf, "GET /role.js", 12) == 0)
  1597. {
  1598. fs_open("/role.js", &file);
  1599. ssl_sendframes(&ssl, file.data, file.len);
  1600. }
  1601. else if (strncmp(receiveBuf, "POST /login.cgi", 15) == 0)
  1602. {
  1603. uint32_t req_data_received = 0;
  1604. char *offset;
  1605. offset = 0;
  1606. post_data_count = Parse_Content_Length(receiveBuf, receivedBufLen);
  1607. if (post_data_count < MAX_POST_REQ_LEN)
  1608. {
  1609. memset(post_req_data, 0, MAX_POST_REQ_LEN);
  1610. offset = (strstr(receiveBuf, "\r\n\r\n")) + 4;
  1611. req_data_received = receivedBufLen - (offset - &receiveBuf[0]);
  1612. if (offset != 0)
  1613. {
  1614. if (req_data_received < post_data_count)
  1615. {
  1616. snprintf(post_req_data, req_data_received, "%s", receiveBuf);
  1617. post_data_count -= req_data_received;
  1618. ssl_server_read();
  1619. offset = receiveBuf;
  1620. }
  1621. if(strlen(receiveBuf) != 0)
  1622. {
  1623. strncat(post_req_data, offset, post_data_count);
  1624. if (HTTP_ConfirmWebPwd(post_req_data, sendBuf, strlen(post_req_data), &sendBufLoadLen) == SEND_REQUIRED_YES)
  1625. {
  1626. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1627. }
  1628. else
  1629. {
  1630. /*if(sSettings.sRADIUS.RDSEnable == true)
  1631. fs_open("/rslogin.html", &file);
  1632. else
  1633. fs_open("/login.html", &file);
  1634. ssl_sendframes(&ssl, file.data, file.len);*/
  1635. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1636. }
  1637. post_data_count = 0;
  1638. }
  1639. else{
  1640. /* Redirect to login page */
  1641. if((sSettings.sRADIUS.RDSEnable == true) && (fl_raddius_net_err == false))
  1642. fs_open("/rslogin.html", &file);
  1643. else
  1644. fs_open("/login.html", &file);
  1645. ssl_sendframes(&ssl, file.data, file.len);
  1646. /* End reqest */
  1647. post_data_count = 0;
  1648. }
  1649. }
  1650. /* request was fragmented before "\r\n\r\n" */
  1651. else
  1652. {
  1653. /* Redirect to login page */
  1654. if((sSettings.sRADIUS.RDSEnable == true) && (fl_raddius_net_err == false))
  1655. fs_open("/rslogin.html", &file);
  1656. else
  1657. fs_open("/login.html", &file);
  1658. ssl_sendframes(&ssl, file.data, file.len);
  1659. /* End reqest */
  1660. post_data_count = 0;
  1661. }
  1662. }
  1663. else
  1664. {
  1665. //printf("Too long POST request!\r\n");
  1666. /* Ignore request */
  1667. post_data_count = 0;
  1668. /* Redirect to login page */
  1669. if((sSettings.sRADIUS.RDSEnable == true) && (fl_raddius_net_err == false))
  1670. fs_open("/rslogin.html", &file);
  1671. else
  1672. fs_open("/login.html", &file);
  1673. ssl_sendframes(&ssl, file.data, file.len);
  1674. }
  1675. }
  1676. else if (post_data_count > 0)
  1677. {
  1678. strncat(post_req_data, receiveBuf, post_data_count);
  1679. if (HTTP_ConfirmWebPwd(post_req_data, sendBuf, strlen(post_req_data), &sendBufLoadLen) == SEND_REQUIRED_YES)
  1680. {
  1681. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1682. }
  1683. else
  1684. {
  1685. /*if(sSettings.sRADIUS.RDSEnable == true)
  1686. fs_open("/rslogin.html", &file);
  1687. else
  1688. fs_open("/login.html", &file);
  1689. ssl_sendframes(&ssl, file.data, file.len);*/
  1690. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1691. }
  1692. post_data_count = 0;
  1693. log_post_reqn = 0;
  1694. }
  1695. else
  1696. {
  1697. if((sSettings.sRADIUS.RDSEnable == true) && (fl_raddius_net_err == false))
  1698. fs_open("/rslogin.html", &file);
  1699. else
  1700. fs_open("/login.html", &file);
  1701. ssl_sendframes(&ssl, file.data, file.len);
  1702. }
  1703. }
  1704. else if ( Authenticated == true )
  1705. {
  1706. if (strncmp(receiveBuf, "GET /main.css", 13) == 0) // +
  1707. {
  1708. fs_open("/main.css", &file);
  1709. ssl_sendframes(&ssl, file.data, file.len);
  1710. }
  1711. else if (strncmp(receiveBuf, "GET /rotek.png", 14) == 0) // +
  1712. {
  1713. fs_open("/rotek.png", &file);
  1714. ssl_sendframes(&ssl, file.data, file.len);
  1715. }
  1716. else if (strncmp(receiveBuf, "GET /favicon.ico", 16) == 0) // ?
  1717. {
  1718. fs_open("/favicon.ico", &file);
  1719. ssl_sendframes(&ssl, file.data, file.len);
  1720. }
  1721. else if (strncmp(receiveBuf, "GET /main.js", 12) == 0) // +
  1722. {
  1723. fs_open("/main.js", &file);
  1724. ssl_sendframes(&ssl, file.data, file.len);
  1725. }
  1726. else if (strncmp(receiveBuf, "GET /role.js", 12) == 0)
  1727. {
  1728. fs_open("/role.js", &file);
  1729. ssl_sendframes(&ssl, file.data, file.len);
  1730. }
  1731. else if (strncmp(receiveBuf, "GET /settings.html", 18) == 0) // +
  1732. {
  1733. HTTP_UpdateUserLoginTime(user_id);
  1734. if (seclevel == 0)
  1735. {
  1736. fs_open("/settings.html", &file);
  1737. ssl_sendframes(&ssl, file.data, file.len);
  1738. }
  1739. else
  1740. {
  1741. fs_open("/index.html", &file);
  1742. ssl_sendframes(&ssl, file.data, file.len);
  1743. }
  1744. }
  1745. else if (strncmp(receiveBuf, "GET /info.html", 14) == 0) // +
  1746. {
  1747. HTTP_UpdateUserLoginTime(user_id);
  1748. fs_open("/info.html", &file);
  1749. ssl_sendframes(&ssl, file.data, file.len);
  1750. }
  1751. else if (strncmp(receiveBuf, "GET /history.html", 17) == 0)
  1752. {
  1753. HTTP_UpdateUserLoginTime(user_id);
  1754. fs_open("/history.html", &file);
  1755. ssl_sendframes(&ssl, file.data, file.len);
  1756. }
  1757. else if (strncmp(receiveBuf, "GET /ups_history.html", 21) == 0)
  1758. {
  1759. HTTP_UpdateUserLoginTime(user_id);
  1760. fs_open("/ups_history.html", &file);
  1761. ssl_sendframes(&ssl, file.data, file.len);
  1762. }
  1763. else if (strncmp(receiveBuf, "GET /getJson.cgi", 16) == 0) // +
  1764. {
  1765. HTTP_GetParamsPage1(sendBuf);
  1766. ssl_sendframes(&ssl, sendBuf, strlen(sendBuf));
  1767. }
  1768. else if (strncmp(receiveBuf, "GET /settings.cgi", 17) == 0) // +
  1769. {
  1770. if (seclevel == 0) {
  1771. SET_PAGE = SET_PAGE_PAGE2;
  1772. if (HTTP_SettingsPage(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen) == SEND_REQUIRED_YES)
  1773. {
  1774. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1775. }
  1776. }
  1777. }
  1778. else if (strncmp(receiveBuf, "POST /settings.cgi", 18) == 0)
  1779. {
  1780. if (seclevel == 0)
  1781. {
  1782. DataOffset = 0;
  1783. // POST Packet received
  1784. TotalReceived = 0;
  1785. TotalData = 0;
  1786. memset(sendBuf, 0, strlen(sendBuf));
  1787. // parse packet for Content-length field
  1788. size = Parse_Content_Length(receiveBuf, receivedBufLen);
  1789. DataOffset = strstr(receiveBuf, "managerIP");
  1790. /* case of MSIE8 : we do not receive data in the POST packet*/
  1791. if (DataOffset == 0)
  1792. {
  1793. ssl_server_read();
  1794. DataOffset = strstr(receiveBuf, "managerIP");
  1795. }
  1796. TotalReceived = receivedBufLen - (DataOffset - &receiveBuf[0]);
  1797. TotalData += TotalReceived;
  1798. strncat(sendBuf, DataOffset, TotalReceived);
  1799. for(i = TotalData; i < size; i ++)
  1800. {
  1801. ssl_server_read();
  1802. strncat(sendBuf, DataOffset, receivedBufLen);
  1803. TotalData += receivedBufLen;
  1804. }
  1805. // check if last data packet
  1806. if (TotalData == size)
  1807. {
  1808. DBG printf("State: Received %d bytes\r\n", (int)TotalData);
  1809. DBG printf("receive %s /r/n", sendBuf);
  1810. strncat(sendBuf, " ", 1);
  1811. HTTP_SetSettings(sendBuf, strlen(sendBuf));
  1812. memset(sendBuf, 0, size);
  1813. strcpy(sendBuf, "HTTP/1.1 200 OK\r\n");
  1814. strcat(sendBuf, "\r\n\r\n");
  1815. strcat(sendBuf,"<!DOCTYPE html><html lang=""><head><meta http-equiv=\"refresh\" content=\"0;url=/settings.html\"/></head></html>\r\n\r\n");
  1816. sendBufLoadLen = strlen(sendBuf);
  1817. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1818. }
  1819. }
  1820. }
  1821. else if (strncmp(receiveBuf, "GET /info.cgi", 13) == 0) // +
  1822. {
  1823. if (HTTP_InfoPage(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen) == SEND_REQUIRED_YES)
  1824. {
  1825. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1826. }
  1827. }
  1828. else if (strncmp(receiveBuf, "POST /info.cgi", 14) == 0)
  1829. {
  1830. if (seclevel == 0)
  1831. {
  1832. DataOffset = 0;
  1833. // POST Packet received
  1834. TotalReceived = 0;
  1835. TotalData = 0;
  1836. memset(sendBuf, 0, strlen(sendBuf));
  1837. // parse packet for Content-length field
  1838. size = Parse_Content_Length(receiveBuf, receivedBufLen);
  1839. DataOffset = strstr(receiveBuf, "owner");
  1840. /* case of MSIE8 : we do not receive data in the POST packet*/
  1841. if (DataOffset == 0)
  1842. {
  1843. ssl_server_read();
  1844. DataOffset = strstr(receiveBuf, "owner");
  1845. }
  1846. TotalReceived = receivedBufLen - (DataOffset - &receiveBuf[0]);
  1847. TotalData += TotalReceived;
  1848. strncat(sendBuf, DataOffset, TotalReceived);
  1849. // check if last data packet
  1850. if (TotalReceived == size)
  1851. {
  1852. strncat(sendBuf, " ", 1);
  1853. HTTP_SetInfo(sendBuf, strlen(sendBuf));
  1854. DataFlag = 0;
  1855. BrowserFlag = 0;
  1856. memset(sendBuf, 0, size);
  1857. strcpy(sendBuf, "HTTP/1.1 200 OK\r\n");
  1858. strcat(sendBuf, "\r\n\r\n");
  1859. strcat(sendBuf,"<!DOCTYPE html><html lang=""><head><meta http-equiv=\"refresh\" content=\"0;url=/info.html\"/></head></html>\r\n\r\n");
  1860. sendBufLoadLen = strlen(sendBuf);
  1861. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1862. }
  1863. // not last data packet
  1864. else
  1865. {
  1866. // write data in flash
  1867. if(receivedBufLen)
  1868. {
  1869. strncat(sendBuf, ptr, receivedBufLen);
  1870. //memcpy(receiveBufTemp, ptr, receivedBufLen);
  1871. }
  1872. }
  1873. }
  1874. }
  1875. else if (strncmp(receiveBuf, "GET /history.cgi", 16) == 0)
  1876. {
  1877. int res;
  1878. res = HTTP_HistoryPage(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen);
  1879. if (res == SEND_REQUIRED_FILE)
  1880. {
  1881. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1882. //send_data(pcb, hs);
  1883. //tcp_sent(pcb, http_sent_history);
  1884. HTTP_SendHistory();
  1885. //tcp_err(pcb, http_sent_log_err);
  1886. }
  1887. else if (res == SEND_REQUIRED_YES)
  1888. {
  1889. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1890. }
  1891. }
  1892. else if (strncmp(receiveBuf, "GET /ups_history.cgi", 19) == 0)
  1893. {
  1894. int res;
  1895. res = HTTP_UpsHistoryPage(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen);
  1896. if (res == SEND_REQUIRED_FILE)
  1897. {
  1898. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1899. //send_data(pcb, hs);
  1900. //tcp_sent(pcb, http_sent_log);
  1901. HTTP_SendLog();
  1902. //tcp_err(pcb, http_sent_log_err);
  1903. }
  1904. else if (res == SEND_REQUIRED_YES)
  1905. {
  1906. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1907. }
  1908. }
  1909. /* Тест АКБ ИБП */
  1910. else if (strncmp(receiveBuf, "GET /bat_test.cgi", 17) == 0)
  1911. {
  1912. HTTP_UPSTest(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen);
  1913. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1914. }
  1915. /* Выключение ИБП */
  1916. else if (strncmp(receiveBuf, "GET /ups_power.cgi", 18) == 0)
  1917. {
  1918. HTTP_UPSshutdown(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen);
  1919. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1920. }
  1921. /* Сброс настроек и сохранине */
  1922. else if (strncmp(receiveBuf, "GET /reset.cgi", 14) == 0)
  1923. {
  1924. HTTP_ResetSettings();
  1925. HTTP_SaveSettings();
  1926. fs_open("/settings.html", &file);
  1927. ssl_sendframes(&ssl, file.data, file.len);
  1928. }
  1929. /* Перезагрузка контроллера */
  1930. else if (strncmp(receiveBuf, "GET /reboot.cgi", 15) == 0)
  1931. {
  1932. HTTP_Reboot();
  1933. }
  1934. /* Подтверждение новых сетевых настроек */
  1935. else if (strncmp(receiveBuf, "GET /confirm.cgi", 16) == 0)
  1936. {
  1937. SetWebReinitFlag(false);
  1938. SetConfirmWebParamsFlag();
  1939. fs_open("/index.html", &file);
  1940. ssl_sendframes(&ssl, file.data, file.len);
  1941. }
  1942. /* Проверка пароля, переход в bootloader */
  1943. else if (strncmp(receiveBuf, "GET /fw_update.cgi", 18) == 0)
  1944. {
  1945. HTTP_ConfirmBootPwd(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen);
  1946. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1947. }
  1948. /* Смена пароля пользователя */
  1949. else if (strncmp(receiveBuf, "GET /changepwd.cgi", 18) == 0)
  1950. {
  1951. HTTP_ChangeUserPwd(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen);
  1952. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1953. }
  1954. // На производстве
  1955. else if (strncmp(receiveBuf, "GET /setProdate.cgi", 19) == 0)
  1956. {
  1957. HTTP_Prodate(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen);
  1958. ssl_sendframes(&ssl, sendBuf, sendBufLoadLen);
  1959. }
  1960. else
  1961. {
  1962. HTTP_UpdateUserLoginTime(user_id);
  1963. fs_open("/index.html", &file); // +
  1964. ssl_sendframes(&ssl, file.data, file.len);
  1965. }
  1966. }
  1967. //}
  1968. /*
  1969. if (strncmp(buf, "GET /main.css", 13) == 0) // +
  1970. {
  1971. fs_open("/main.css", &file);
  1972. ssl_sendframes(&ssl, file.data, file.len);
  1973. }
  1974. else if (strncmp(buf, "GET /rotek.png", 14) == 0) // +
  1975. {
  1976. fs_open("/rotek.png", &file);
  1977. ssl_sendframes(&ssl, file.data, file.len);
  1978. }
  1979. else if (strncmp(buf, "GET /favicon.ico", 16) == 0) // ?
  1980. {
  1981. fs_open("/favicon.ico", &file);
  1982. ssl_sendframes(&ssl, file.data, file.len);
  1983. }
  1984. else if (strncmp(buf, "GET /main.js", 12) == 0) // +
  1985. {
  1986. fs_open("/main.js", &file);
  1987. ssl_sendframes(&ssl, file.data, file.len);
  1988. }
  1989. else if (strncmp(buf, "GET /getJson.cgi", 16) == 0) // +
  1990. {
  1991. HTTP_GetParamsPage1(sendBuf);
  1992. ssl_sendframes(&ssl, sendBuf, strlen(sendBuf));
  1993. }
  1994. else if (strncmp(buf, "GET /settings.html", 18) == 0) // +
  1995. {
  1996. fs_open("/settings.html", &file);
  1997. ssl_sendframes(&ssl, file.data, file.len);
  1998. }
  1999. else if (strncmp(buf, "GET /info.html", 14) == 0) // +
  2000. {
  2001. fs_open("/info.html", &file);
  2002. ssl_sendframes(&ssl, file.data, file.len);
  2003. }
  2004. else if (strncmp(buf, "GET /getJson.cgi", 16) == 0) // +
  2005. {
  2006. HTTP_GetParamsPage1(sendBuf);
  2007. ssl_sendframes(&ssl, sendBuf, strlen(sendBuf));
  2008. }
  2009. else if (strncmp(buf, "GET /settings.cgi", 17) == 0) // +
  2010. {
  2011. SET_PAGE = SET_PAGE_PAGE2;
  2012. if (HTTP_SettingsPage(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen) == SEND_REQUIRED_YES)
  2013. {
  2014. ssl_sendframes(&ssl, sendBuf, strlen(sendBuf));
  2015. }
  2016. else
  2017. {
  2018. fs_open("/settings.html", &file);
  2019. ssl_sendframes(&ssl, file.data, file.len);
  2020. }
  2021. }
  2022. else if (strncmp(buf, "GET /info.cgi", 13) == 0) // +
  2023. {
  2024. if (HTTP_InfoPage(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen) == SEND_REQUIRED_YES)
  2025. {
  2026. ssl_sendframes(&ssl, sendBuf, strlen(sendBuf));
  2027. }
  2028. else
  2029. {
  2030. fs_open("/info.html", &file);
  2031. ssl_sendframes(&ssl, file.data, file.len);
  2032. }
  2033. }
  2034. // Сброс настроек и сохранине
  2035. else if (strncmp(buf, "GET /reset.cgi", 14) == 0)
  2036. {
  2037. HTTP_ResetSettings();
  2038. HTTP_SaveSettings();
  2039. fs_open("/settings.html", &file);
  2040. ssl_sendframes(&ssl, file.data, file.len);
  2041. }
  2042. // Перезагрузка контроллера
  2043. else if (strncmp(buf, "GET /reboot.cgi", 15) == 0)
  2044. {
  2045. HTTP_Reboot();
  2046. }
  2047. // Подтверждение новых сетевых настроек
  2048. else if (strncmp(buf, "GET /confirm.cgi", 16) == 0)
  2049. {
  2050. SetWebReinitFlag(false);
  2051. SetConfirmWebParamsFlag();
  2052. fs_open("/index.html", &file);
  2053. ssl_sendframes(&ssl, file.data, file.len);
  2054. }
  2055. // Проверка пароля, переход в bootloader
  2056. else if (strncmp(buf, "POST /checkpwd.cgi", 18) == 0)
  2057. {
  2058. HTTP_ConfirmBootPwd(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen);
  2059. ssl_sendframes(&ssl, sendBuf, strlen(sendBuf));
  2060. }
  2061. // На производстве
  2062. else if (strncmp(buf, "GET /setProdate.cgi", 19) == 0)
  2063. {
  2064. HTTP_Prodate(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen);
  2065. ssl_sendframes(&ssl, sendBuf, strlen(sendBuf));
  2066. }
  2067. // На производстве
  2068. else if (strncmp(buf, "GET /progon.cgi", 15) == 0)
  2069. {
  2070. HTTP_Progon(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen);
  2071. ssl_sendframes(&ssl, sendBuf, strlen(sendBuf));
  2072. }
  2073. else
  2074. {
  2075. fs_open("/index.html", &file);
  2076. ssl_sendframes(&ssl, file.data, file.len);
  2077. }
  2078. // -------------------------------------------------------------------------
  2079. */
  2080. // Для теста
  2081. // 7. Write the Response
  2082. //printf("\n\r => Write to client :\n\r");
  2083. // Send the dynamic html page
  2084. //ssl_DynPage(&ssl);
  2085. // Close the connection
  2086. ssl_close_notify(&ssl);
  2087. goto accept;
  2088. exit:
  2089. // Close and delete the current session data: certificate, RSA key and SSL session
  2090. x509_free(&srvcert);
  2091. rsa_free(&rsa);
  2092. cur = s_list_1st;
  2093. while(cur != NULL)
  2094. {
  2095. prv = cur;
  2096. cur = cur->next;
  2097. memset(prv, 0, sizeof(ssl_session));
  2098. free(prv);
  2099. }
  2100. memset(&ssl, 0, sizeof(ssl_context));
  2101. accept:
  2102. // Wait 200s until next retry
  2103. vTaskDelay(200);
  2104. // Close and free the SSL context
  2105. net_close(client_fd);
  2106. ssl_free(&ssl);
  2107. }
  2108. }
  2109. /**
  2110. * @brief Create and send a dynamic Web Page. This page contains the list of
  2111. * running tasks and the number of page hits.
  2112. * @param ssl the SSL context
  2113. * @retval None
  2114. */
  2115. void ssl_DynPage(ssl_context *ssl)
  2116. {
  2117. portCHAR buf[2024];
  2118. portCHAR pagehits[10];
  2119. portCHAR getcipher[100];
  2120. uint32_t len = 0;
  2121. memset(buf, 0, 2024);
  2122. // Update the hit count
  2123. nPageHits++;
  2124. sprintf( pagehits, "%d", nPageHits );
  2125. sprintf( (char *) getcipher, HTTP_RESPONSE, ssl_get_ciphersuite(ssl));
  2126. // Generate the dynamic page
  2127. strcpy(buf, PAGE_START);
  2128. // Page header
  2129. strcat(buf, pagehits);
  2130. strcat((char *) buf, "<br><pre>** The list of tasks and their status **");
  2131. strcat((char *) buf, "<br><pre>---------------------------------------------");
  2132. strcat((char *) buf, "<br>Name State Priority Stack Num" );
  2133. //strcat((char *) buf, "<br>---------------------------------------------");
  2134. strcat((char *) buf, "<br>---------------------------------------------<br>");
  2135. // The list of tasks and their status
  2136. vTaskList((signed char *)buf + strlen(buf));
  2137. strcat((char *) buf, "<br>---------------------------------------------");
  2138. strcat((char *) buf, "<br>B : Blocked, R : Ready, D : Deleted, S : Suspended");
  2139. // The current cipher used
  2140. strcat(buf, getcipher);
  2141. // Page footer
  2142. strcat(buf, PAGE_END);
  2143. // Send the dynamically generated page
  2144. len = ssl_write(ssl, (unsigned char *)buf, strlen(buf));
  2145. // Display the length of application data
  2146. //printf( "\n Successfully write %d bytes to client\n\r", len);
  2147. }
  2148. /**
  2149. * @brief This function is used to send messages with size upper 16k bytes.
  2150. * @param ssl SSL context
  2151. * @param data buffer holding the data
  2152. * @param len how many bytes must be written
  2153. * @retval None
  2154. */
  2155. #define FRAME_SIZE (1000)
  2156. void ssl_sendframes( ssl_context *ssl, char *data, int datalen )
  2157. {
  2158. int index = 0;
  2159. int k = 0;
  2160. int lastframe, nbrframes;
  2161. // Calculate the number of frames
  2162. nbrframes = datalen / FRAME_SIZE;
  2163. // Send nbrframes frames
  2164. while(nbrframes > 0)
  2165. {
  2166. index = k * FRAME_SIZE;
  2167. ssl_write( ssl, (unsigned char *)(data + index), FRAME_SIZE );
  2168. nbrframes--;
  2169. k++;
  2170. }
  2171. // Send the last frame
  2172. index = k * FRAME_SIZE;
  2173. lastframe = datalen % FRAME_SIZE ;
  2174. ssl_write( ssl, (unsigned char *)(data + index), lastframe );
  2175. }
  2176. /**
  2177. * @brief Returns a 32-bit random number.
  2178. * @param arg not used
  2179. * @retval 32-bit random number
  2180. */
  2181. int RandVal(void* arg)
  2182. {
  2183. return (int)GetRandomNumber();
  2184. }
  2185. /**
  2186. * @brief Send callback for log file transfer (messages as is, not ordered)
  2187. */
  2188. void HTTP_SendHistory(void)
  2189. {
  2190. uint32_t nbytes = 0;
  2191. static bool start = true;
  2192. memset(logFileBuf, 0, FILE_BUF_MAX_LEN);
  2193. if (log_ptr + FILE_BUF_MAX_LEN <= log_size) {
  2194. nbytes = History_GetData(log_ptr, logFileBuf, FILE_BUF_MAX_LEN, start);
  2195. }
  2196. else if (log_ptr < log_size) {
  2197. nbytes = History_GetData(log_ptr, logFileBuf, (log_size - log_ptr), start);
  2198. }
  2199. else {
  2200. nbytes = 0;
  2201. }
  2202. log_ptr += nbytes;
  2203. start = false;
  2204. if (nbytes == 0) {
  2205. // File transfer finished.
  2206. start = true;
  2207. // Clear file transfer in progress flag
  2208. fLogTransInprog = false;
  2209. return;
  2210. }
  2211. ssl_sendframes(&ssl, logFileBuf, nbytes);
  2212. HTTP_SendHistory();
  2213. }
  2214. /**
  2215. * @brief Sent callback for log file transfer (messages as is, not ordered)
  2216. */
  2217. void HTTP_SendLog(void)
  2218. {
  2219. uint32_t nbytes = 0;
  2220. static bool start = true;
  2221. memset(logFileBuf, 0, FILE_BUF_MAX_LEN);
  2222. if (log_ptr + FILE_BUF_MAX_LEN_LOG <= log_size) {
  2223. nbytes = LOG_GetData(log_ptr, logFileBuf, FILE_BUF_MAX_LEN_LOG, start);
  2224. }
  2225. else if (log_ptr < log_size) {
  2226. nbytes = LOG_GetData(log_ptr, logFileBuf, (log_size - log_ptr), start);
  2227. }
  2228. else {
  2229. nbytes = 0;
  2230. }
  2231. log_ptr += nbytes;
  2232. start = false;
  2233. if (nbytes == 0) {
  2234. // File transfer finished.
  2235. start = true;
  2236. // Clear file transfer in progress flag
  2237. fLogTransInprog = false;
  2238. return;
  2239. }
  2240. ssl_sendframes(&ssl, logFileBuf, nbytes);
  2241. HTTP_SendLog();
  2242. return;
  2243. }
  2244. /**
  2245. * @brief Initialize the HTTPS server (start its thread)
  2246. */
  2247. void HTTPS_Init()
  2248. {
  2249. char buf[MAX_WEB_COOKIE_LEN];
  2250. uint8_t user_id;
  2251. for (user_id = 0; user_id < MAX_WEB_USERS; user_id++) {
  2252. // Flush user cookie by random value
  2253. sprintf(buf, "%X", (unsigned int)GetRandomNumber());
  2254. HTTP_SetUserCookie(buf, user_id);
  2255. // Create user logout timers
  2256. users[user_id].LogoutTimer =
  2257. xTimerCreate("LogoutTmr", WEB_LOGOUT_TIME, pdFALSE, ( void * ) user_id, LogoutTimerCallback);
  2258. }
  2259. RepeatLoginTimer = xTimerCreate("LoginTmr", REPEAT_LOGIN_TIME, pdFALSE, ( void * ) 0, LoginTimerCallback);
  2260. }