my_ssl_server.c 70 KB

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