123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097 |
- #if defined HARDWARE_BT6706 || HARDWARE_BT6708
- #include "lwip/arch.h"
- #include "lwip/api.h"
- #include "lwip/tcp.h"
- #include "http_server.h"
- #include "web_params_api.h"
- #include "parameters.h"
- #include "urlcode.h"
- #include "trap_params.h"
- #ifdef HARDWARE_BT6706
- #include "bt6706_fs/fsdata.c"
- #elif HARDWARE_BT6708
- #include "bt6708_fs/fsdata.c"
- #endif
- #include "settings_api.h"
- #include "netconf.h"
- #include "common_config.h"
- #include "testing.h"
- #include "rtc.h"
- #include "rng.h"
- #include "megatec.h"
- #include "log.h"
- #include "hal.h"
- #include "sntp_api.h"
- #ifdef PRINTF_STDLIB
- #include <stdio.h>
- #endif
- #ifdef PRINTF_CUSTOM
- #include "tinystdio.h"
- #endif
- #include <string.h>
- #include <stdlib.h>
- #include "FreeRTOS.h"
- #include "task.h"
- #include "fr_timers.h"
- static int fs_open(char *name, struct fs_file *file);
- static err_t http_sent(void *arg, struct tcp_pcb *pcb, u16_t len);
- static err_t http_sent_history(void *arg, struct tcp_pcb *pcb, u16_t len);
- static err_t http_sent_log(void *arg, struct tcp_pcb *pcb, u16_t len);
- static void http_sent_log_err(void * arg, err_t err);
- static void send_data(struct tcp_pcb *pcb, struct http_state *hs);
- static void HTTP_GetUserCookie(uint8_t user_id, char *str, uint8_t *len);
- static uint32_t Parse_Content_Length(char *data, uint32_t len);
- static void HTTP_SetUserCookie(char *str, uint8_t user_id);
- static void HTTP_UpdateUserLoginTime(uint8_t user_id);
- static void HTTP_ForceUserLogout(uint8_t user_id);
- void LogoutTimerCallback(TimerHandle_t pxTimer);
- void LoginTimerCallback(TimerHandle_t pxTimer);
- int HTTP_ChangeUserPwd(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut);
- char* send_file(char *filename, char *pnonmatch, struct fs_file *file, uint16_t *Len);
- static uint32_t Parse_Header(char *data, uint32_t len, const char *field, uint32_t flen, char *value);
- bool GetFileName(char *inStr, char *fileName, uint8_t *fileNameLen);
- REQ_TYPE_SEND_t HTTPTypeAnswer = COMMON_ANSWER;
- #define SEND_BUF_MAX_LEN 2000
- #define RECIVE_BUF_MAX_LEN 1500
- char sendBuf[SEND_BUF_MAX_LEN];
- uint16_t sendBufLoadLen = 0;
- uint16_t printLen = 0;
- char receiveBuf[RECIVE_BUF_MAX_LEN];
- uint16_t receivedBufLen = 0;
- #define MAX_POST_REQ_LEN 256
- char post_req_data[MAX_POST_REQ_LEN];
- uint32_t post_data_count = 0;
- uint32_t log_post_reqn;
- /* Logout timeout, 30 minutes */
- #define WEB_LOGOUT_TIME configTICK_RATE_HZ*60*30
- /* Max user active sessions count */
- #define WEB_USER_MAX_SESSION_COUNT 5
- struct {
- //auth_session_t session[WEB_USER_MAX_SESSION_COUNT];
- char cookie[MAX_WEB_COOKIE_LEN];
- TimerHandle_t LogoutTimer;
- } users[MAX_WEB_USERS];
- TimerHandle_t RepeatLoginTimer;
- /* Repeat Login timeout, 1 minutes */
- #define REPEAT_LOGIN_TIME configTICK_RATE_HZ*60*1
- uint8_t cnt_err_psw = 0;
- bool Authenticated = false;
- /* Level of currently logged-in user */
- uint8_t seclevel = 0xFF;
- /* Max HTTP file name length including "/" */
- #define MAX_FILENAME_LEN 32
- /* Max HTTP Etag field length */
- #define MAX_ETAG_LEN 48
- static const char If_None_Match[] = "If-None-Match: ";
- static const char Etag[] = "ETag: ";
- static volatile uint32_t DataFlag2=0;
- static volatile uint32_t DataFlag=0;
- static volatile uint32_t size =0;
- static uint32_t TotalReceived=0;
- static volatile uint32_t TotalData=0;
- static uint32_t ContentLengthOffset =0, BrowserFlag=0;
- static const char Content_Length[17] =
- /* Content Length */
- {0x43, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x2d, 0x4c, 0x65, 0x6e, 0x67,0x74, 0x68, 0x3a, 0x20, };
- const char HTTP_304_NOT_MODIFIED[] = "HTTP/1.1 304 Not Modified\r\n\r\n";
- const char HTTP_403_NOT_WHITE_LIST[] = "HTTP/1.1 403 Forbidden\r\n\r\n";
- const char HTTP_200_OK[] = "HTTP/1.1 200 OK\r\n\r\n";
- /* utf-8 marker to support MS Excel */
- const char UTF8_BOM[] = {0xEF, 0xBB, 0xBF, 0x00};
- unsigned long log_ptr = 0;
- unsigned long log_size = 0;
- bool fLogTransInprog = false;
- /**
- * @brief Общая структура настроек
- */
- extern SETTINGS_t sSettings;
- char CookieBuf[51];
- char *CookiePtr = NULL;
- char name[MAX_WEB_COOKIE_LEN];
- char id[MAX_WEB_COOKIE_LEN];
- uint8_t nameLen = 0, idLen = 0;
- uint8_t user_id; // Id of currently logged-in user
- struct fs_file file = {0, 0};
- /**
- * @brief closes tcp connection
- * @param pcb: pointer to a tcp_pcb struct
- * @param hs: pointer to a http_state struct
- * @retval
- */
- static void close_conn(struct tcp_pcb *pcb, struct http_state *hs)
- {
- tcp_arg(pcb, NULL);
- tcp_sent(pcb, NULL);
- tcp_recv(pcb, NULL);
- mem_free(hs);
- tcp_close(pcb);
- }
- /**
- * @brief callback function for handling TCP HTTP traffic
- * @param arg: pointer to an argument structure to be passed to callback function
- * @param pcb: pointer to a tcp_pcb structure
- * @param p: pointer to a packet buffer
- * @param err: LwIP error code
- * @retval err
- */
- static err_t http_recv(void *arg, struct tcp_pcb *pcb, struct pbuf *p, err_t err)
- {
- char *data;
- struct http_state *hs;
- struct fs_file file = {0, 0};
- char buf[150];
- hs = arg;
- if (err == ERR_OK && p != NULL)
- {
- tcp_recved(pcb, p->tot_len);
- if (hs->file == NULL)
- {
- data = p->payload;
- receivedBufLen = p->tot_len;
- memcpy(receiveBuf, p->payload , receivedBufLen);
- /* Cut received string */
- receiveBuf[receivedBufLen] = '\0';
- if (strncmp(data, "GET /setProdate.cgi", 19) == 0 && strncmp(sSettings.sFlags.testState, "T2OK", 4))
- {
- HTTP_Prodate(receiveBuf, sendBuf, receivedBufLen, &sendBufLoadLen);
- hs->file = sendBuf;
- hs->left = sendBufLoadLen;
- send_data(pcb, hs);
- tcp_sent(pcb, http_sent);
- }
- else{
- Cockie();
- if( DataFlag == 0 && DataFlag2 == 0 ){
- getAuthenticatedState();
- }
- if (DataFlag >= 1)
- Authenticated = true;
- else if(DataFlag2 >= 1)
- Authenticated = true;
- if (!Authenticated)
- {
- hs->file = AuthenticatedFalseRoutine(&sendBufLoadLen);
- hs->left = sendBufLoadLen;
- send_data(pcb, hs);
- tcp_sent(pcb, http_sent);
- }
- else
- {
- HTTPTypeAnswer = COMMON_ANSWER;
- hs->file = AuthenticatedTrueRoutine(&sendBufLoadLen);
- hs->left = sendBufLoadLen;
- if(hs->file != 0){
- send_data(pcb, hs);
- switch(HTTPTypeAnswer){
- case HISTORY_ANSWER:
- tcp_sent(pcb, http_sent_history);
- break;
- case UPS_HISTORY_ANSWER:
- tcp_sent(pcb, http_sent_log);
- break;
- default:
- tcp_sent(pcb, http_sent);
- break;
- }
- }
- }
- }
- }
- pbuf_free(p);
- }
- return ERR_OK;
- }
- /**
- * @brief Sent callback for log file transfer (messages as is, not ordered)
- */
- static err_t http_sent_history(void *arg, struct tcp_pcb *pcb, u16_t len)
- {
- struct http_state *hs;
- uint32_t nbytes = 0;
- static bool start = true;
- (void)len;
- hs = arg;
- if (hs->left > 0)
- {
- send_data(pcb, hs);
- }
- else
- {
- memset(logFileBuf, 0, FILE_BUF_MAX_LEN);
- if (log_ptr + FILE_BUF_MAX_LEN <= log_size) {
- nbytes = History_GetData(log_ptr, logFileBuf, FILE_BUF_MAX_LEN, start);
- }
- else if (log_ptr < log_size) {
- nbytes = History_GetData(log_ptr, logFileBuf, (log_size - log_ptr), start);
- }
- else {
- nbytes = 0;
- }
- log_ptr += nbytes;
- start = false;
- if (nbytes == 0) {
- /* File transfer finished. */
- start = true;
- close_conn(pcb, hs);
- /* Clear file transfer in progress flag */
- fLogTransInprog = false;
- return ERR_OK;
- }
- hs->file = logFileBuf;
- hs->left = nbytes;
- send_data(pcb, hs);
- tcp_sent(pcb, http_sent_history);
- }
- return ERR_OK;
- }
- /**
- * @brief Sent callback for log file transfer (messages as is, not ordered)
- */
- static err_t http_sent_log(void *arg, struct tcp_pcb *pcb, u16_t len)
- {
- struct http_state *hs;
- uint32_t nbytes = 0;
- static bool start = true;
- (void)len;
- hs = arg;
- if (hs->left > 0)
- {
- send_data(pcb, hs);
- }
- else
- {
- memset(logFileBuf, 0, FILE_BUF_MAX_LEN);
- if (log_ptr + FILE_BUF_MAX_LEN_LOG <= log_size) {
- nbytes = LOG_GetData(log_ptr, logFileBuf, FILE_BUF_MAX_LEN_LOG, start);
- }
- else if (log_ptr < log_size) {
- nbytes = LOG_GetData(log_ptr, logFileBuf, (log_size - log_ptr), start);
- }
- else {
- nbytes = 0;
- }
- log_ptr += nbytes;
- start = false;
- if (nbytes == 0) {
- /* File transfer finished. */
- start = true;
- close_conn(pcb, hs);
- /* Clear file transfer in progress flag */
- fLogTransInprog = false;
- return ERR_OK;
- }
- hs->file = logFileBuf;
- hs->left = nbytes;
- send_data(pcb, hs);
- tcp_sent(pcb, http_sent_log);
- }
- return ERR_OK;
- }
- /**
- * @brief Error callback for log file transfer
- */
- static void http_sent_log_err(void * arg, err_t err)
- {
- (void)err;
- (void)arg;
- /* Clear file transfer in progress flag */
- fLogTransInprog = false;
- }
- /**
- * @brief callback function for handling connection errors
- * @param arg: pointer to an argument to be passed to callback function
- * @param err: LwIP error code
- * @retval none
- */
- static void conn_err(void *arg, err_t err)
- {
- struct http_state *hs;
- hs = arg;
- mem_free(hs);
- }
- /**
- * @brief callback function called after a successfull TCP data packet transmission
- * @param arg: pointer to an argument to be passed to callback function
- * @param pcb: pointer on tcp_pcb structure
- * @param len
- * @retval err : LwIP error code
- */
- static err_t http_sent(void *arg, struct tcp_pcb *pcb, u16_t len)
- {
- struct http_state *hs;
- hs = arg;
- if (hs->left > 0)
- {
- send_data(pcb, hs);
- }
- else
- {
- close_conn(pcb, hs);
- }
- return ERR_OK;
- }
- /**
- * @brief sends data found in member "file" of a http_state struct
- * @param pcb: pointer to a tcp_pcb struct
- * @param hs: pointer to a http_state struct
- * @retval none
- */
- static void send_data(struct tcp_pcb *pcb, struct http_state *hs)
- {
- err_t err;
- u16_t len;
- /* We cannot send more data than space available in the send
- buffer */
- if (tcp_sndbuf(pcb) < hs->left)
- {
- len = tcp_sndbuf(pcb);
- }
- else
- {
- len = hs->left;
- }
- err = tcp_write(pcb, hs->file, len, 0);
- if (err == ERR_OK)
- {
- hs->file += len;
- hs->left -= len;
- }
- }
- /**
- * @brief tcp poll callback function
- * @param arg: pointer to an argument to be passed to callback function
- * @param pcb: pointer on tcp_pcb structure
- * @retval err_t
- */
- static err_t http_poll(void *arg, struct tcp_pcb *pcb)
- {
- if (arg == NULL)
- {
- tcp_close(pcb);
- }
- else
- {
- send_data(pcb, (struct http_state *)arg);
- }
- return ERR_OK;
- }
- /**
- * @brief callback function on TCP connection setup ( on port 80)
- * @param arg: pointer to an argument structure to be passed to callback function
- * @param pcb: pointer to a tcp_pcb structure
- * ¶m err: Lwip stack error code
- * @retval err
- */
- static err_t http_accept(void *arg, struct tcp_pcb *pcb, err_t err)
- {
- struct http_state *hs;
- /* set priority for the newly accepted tcp connection newpcb */
- tcp_setprio(pcb, TCP_PRIO_MIN);
- /* Allocate memory for the structure that holds the state of the connection */
- hs = mem_malloc(sizeof(struct http_state));
- if (hs == NULL)
- {
- return ERR_MEM;
- }
- /* Initialize the structure. */
- hs->file = NULL;
- hs->left = 0;
- /* Tell TCP that this is the structure we wish to be passed for our
- callbacks. */
- tcp_arg(pcb, hs);
- /* Tell TCP that we wish to be informed of incoming data by a call
- to the http_recv() function. */
- tcp_recv(pcb, http_recv);
- tcp_err(pcb, conn_err);
- tcp_poll(pcb, http_poll, 10);
- return ERR_OK;
- }
- /**
- * @brief Opens a file defined in fsdata.c ROM filesystem
- * @param name : pointer to a file name
- * @param file : pointer to a fs_file structure
- * @retval 1 if success, 0 if fail
- */
- static int fs_open(char *name, struct fs_file *file)
- {
- struct fsdata_file_noconst *f;
- for (f = (struct fsdata_file_noconst *)FS_ROOT; f != NULL; f = (struct fsdata_file_noconst *)f->next)
- {
- if (!strcmp(name, f->name))
- {
- file->data = f->data;
- file->len = f->len;
- return 1;
- }
- }
- return 0;
- }
- /**
- * @brief Initialize the HTTP server (start its thread)
- * @param none
- * @retval None
- */
- void HTTP_Init()
- {
- char buf[MAX_WEB_COOKIE_LEN];
- uint8_t user_id;
- err_t err;
- struct tcp_pcb *pcb;
- /*create new pcb*/
- pcb = tcp_new_ip_type(IPADDR_TYPE_ANY);
- LWIP_ASSERT("httpd_init: tcp_new failed", pcb != NULL);
- /* set lowest prio to HTTP connections */
- //tcp_setprio(pcb, TCP_PRIO_MIN);
- /* bind HTTP traffic to pcb */
- err = tcp_bind(pcb, IP_ANY_TYPE, 80);
- LWIP_UNUSED_ARG(err); /* in case of LWIP_NOASSERT */
- LWIP_ASSERT("httpd_init: tcp_bind failed", err == ERR_OK);
- /* start listening on port 80 */
- pcb = tcp_listen(pcb);
- /* define callback function for TCP connection setup */
- tcp_accept(pcb, http_accept);
- for (user_id = 0; user_id < MAX_WEB_USERS; user_id++) {
- /* Flush user cookie by random value */
- sprintf(buf, "%X", (unsigned int)GetRandomNumber());
- HTTP_SetUserCookie(buf, user_id);
- /* Create user logout timers */
- users[user_id].LogoutTimer =
- xTimerCreate("LogoutTmr", WEB_LOGOUT_TIME, pdFALSE, ( void * ) user_id, LogoutTimerCallback);
- }
- RepeatLoginTimer = xTimerCreate("LoginTmr", REPEAT_LOGIN_TIME, pdFALSE, ( void * ) 0, LoginTimerCallback);
- }
- /**
- * @brief
- * @retval None
- */
- int HTTP_SettingsPage(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
- {
- char tempStr[30];
- strncpy(tempStr, bufIn, 30);
-
- /* В запросе нет параметров, нужно формировать JSON ответ */
- if (strpbrk(tempStr,"?") == 0)
- {
- memset(bufOut, 0, SEND_BUF_MAX_LEN);
- HTTP_GetSettings(bufOut);
- *lenBufOut = strlen(bufOut);
- return SEND_REQUIRED_YES;
- }
- /* В запросе есть параметры, нужно парсить и сохранять настройки */
- else
- {
- //HTTP_SetSettings(bufIn, lenBufIn);
- return SEND_REQUIRED_NO;
- }
- }
- /**
- * @brief
- * @retval None
- */
- int HTTP_InfoPage(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
- {
- char tempStr[30];
- strncpy(tempStr, bufIn, 30);
-
- /* В запросе нет параметров, нужно формировать JSON ответ */
- if (strpbrk(tempStr,"?") == 0)
- {
- memset(bufOut, 0, SEND_BUF_MAX_LEN);
-
- HTTP_GetInfo(bufOut);
-
- *lenBufOut = strlen(bufOut);
-
- return SEND_REQUIRED_YES;
- }
- /* В запросе есть параметры, нужно парсить и сохранять настройки */
- else
- {
- //HTTP_SetInfo(bufIn, lenBufIn);
- return SEND_REQUIRED_NO;
- /*
- HTTP_SetSettings(bufIn, lenBufIn);
- return SEND_REQUIRED_NO;
- */
- }
- }
- int HTTP_HistoryPage(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
- {
- uint8_t i, valueLen = 0;
- char value[20];
- uint32_t nbytes = 0;
- (void)lenBufIn;
- memset(bufOut, 0, FILE_BUF_MAX_LEN);
- ClearParamString(bufIn);
- memset(value, 0, 20);
- GetParamValue(bufIn, "page=", value, &valueLen);
- if (strcmp(value, "all") == 0)
- {
- if (!LOG_IsInit()) {
- return SEND_REQUIRED_NO;
- }
- if (fLogTransInprog == false) {
- // Send log as raw data
- log_ptr = 0;
- log_size = History_GetTotalSTRCount() * STRING_SIZE_HISTORY + sizeof(UTF8_BOM)-1;
- sprintf(bufOut, "HTTP/1.1 200 OK\r\nContent-Length:%lu\r\n\r\n%s", log_size, UTF8_BOM);
- *lenBufOut = strlen(bufOut);
- // Set file transfer in progress flag
- fLogTransInprog = true;
- return SEND_REQUIRED_FILE;
- }
- else {
- // We send nothing if file transfer already in progress
- return SEND_REQUIRED_NO;
- }
- }
- else {
- if (!LOG_IsInit()) {
- return SEND_REQUIRED_NO;
- }
- else {
- HTTP_GetHistoryPage(bufOut, atoi(value));
- *lenBufOut = strlen(bufOut);
- return SEND_REQUIRED_YES;
- }
- }
- }
- int HTTP_UpsHistoryPage(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
- {
- uint8_t i, valueLen = 0;
- char value[20];
- uint32_t nbytes = 0;
- (void)lenBufIn;
- memset(bufOut, 0, FILE_BUF_MAX_LEN);
- ClearParamString(bufIn);
- memset(value, 0, 20);
- GetParamValue(bufIn, "page=", value, &valueLen);
- if (strcmp(value, "all") == 0)
- {
- if (!LOG_IsInit()) {
- return SEND_REQUIRED_NO;
- }
- if (fLogTransInprog == false) {
- // Send log as raw data
- log_ptr = 0;
- log_size = LOG_GetTotalSTRCount() * STRING_SIZE + sizeof(UTF8_BOM)-1;
- sprintf(bufOut, "HTTP/1.1 200 OK\r\nContent-Length:%lu\r\n\r\n%s", log_size, UTF8_BOM);
- *lenBufOut = strlen(bufOut);
- // Set file transfer in progress flag
- fLogTransInprog = true;
- return SEND_REQUIRED_FILE;
- }
- else {
- // We send nothing if file transfer already in progress
- return SEND_REQUIRED_NO;
- }
- }
- else {
- if (!LOG_IsInit()) {
- return SEND_REQUIRED_NO;
- }
- else {
- HTTP_GetUpsHistoryPage(bufOut, atoi(value));
- *lenBufOut = strlen(bufOut);
- return SEND_REQUIRED_YES;
- }
- }
- }
-
- /**
- * @brief Установка даты производства
- */
- // TODO Убрать заглушку!
- void HTTP_Prodate(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
- {
- uint8_t valueLen = 0;
- char value[20];
-
- memset(bufOut, 0, SEND_BUF_MAX_LEN);
-
- ClearParamString(bufIn);
-
- memset(value, 0, 20);
- GetParamValue(bufIn, "prodate=", value, &valueLen);
- /*
- printf("Prodate: ");
- printf(value);
- printf("\r\n");
- */
-
- /* Устанавливаем дату производства */
- SETTINGS_SetProDate(value, valueLen);
-
- /* Пока отправляем true */
- strcpy(bufOut, "HTTP/1.0 200 OK\r\nContent-Type:text/html\r\n\r\nTrue");
- *lenBufOut = strlen(bufOut);
-
- TEST_SetServerFlag();
- }
- /**
- * @brief
- * @retval None
- */
- void HTTP_SetSettings(char *buf, uint16_t lenBuf)
- {
- uint8_t valueLen = 0;
- const uint8_t len = MAX_WEB_PARAM_LEN;
- char value[MAX_WEB_PARAM_LEN];
- char str[MAX_WEB_PARAM_LEN];
- //printf(buf);
-
- //ClearParamString(buf);
-
- memset(value, 0, len);
- memset(str, 0, MAX_WEB_PARAM_LEN);
-
- /* SNMP */
- GetParamValue(buf, "read_community=", value, &valueLen);
- SetReadCommunity(value);
- memset(value, 0, len);
-
- GetParamValue(buf, "write_community=", value, &valueLen);
- SetWriteCommunity(value);
- memset(value, 0, len);
-
- GetParamValue(buf, "managerIP=", value, &valueLen);
- SetManagerIp(value);
- memset(value, 0, len);
- GetParamValue(buf, "managerIP2=", value, &valueLen);
- SetManagerIp2(value);
- memset(value, 0, len);
- GetParamValue(buf, "managerIP3=", value, &valueLen);
- SetManagerIp3(value);
- memset(value, 0, len);
-
- GetParamValue(buf, "managerIP4=", value, &valueLen);
- SetManagerIp4(value);
- memset(value, 0, len);
- GetParamValue(buf, "managerIP5=", value, &valueLen);
- SetManagerIp5(value);
- memset(value, 0, len);
- #ifdef HARDWARE_BT6708
- /* White list */
- const char *white_list_set[] =
- {
- "wtl_ip1=",
- "wtl_ip2=",
- "wtl_ip3=",
- "wtl_ip4=",
- "wtl_ip5=",
- };
- for(uint8_t i = 0; i < MAX_WHITE_LIST; i++){
- GetParamValue(buf, white_list_set[i], value, &valueLen);
- memset(str, 0, len);
- url_decode(str, sizeof(str), value);
- SetWhiteListSTR(str, i);
- memset(value, 0, len);
- }
- #endif
- /* Сетевые параметры */
- GetParamValue(buf, "dhcp=", value, &valueLen);
- SetDhcpStateStr(value);
-
- if (strncmp(value, "on", 2) != 0) // Если dhcp off устанавливаем параметры
- {
- memset(value, 0, len);
- GetParamValue(buf, "ipaddr=", value, &valueLen);
- SetIPStr(value);
- memset(value, 0, len);
-
- GetParamValue(buf, "gw=", value, &valueLen);
- SetGatewayStr(value);
- memset(value, 0, len);
-
- GetParamValue(buf, "mask=", value, &valueLen);
- SetMaskStr(value);
- memset(value, 0, len);
- }
- memset(value, 0, len);
- /* Сетевые параметры */
- GetParamValue(buf, "tn_enabled=", value, &valueLen);
- SetTelnetEnableStateStr(value);
- if (strncmp(value, "on", 2) == 0)
- {
- memset(value, 0, len);
- GetParamValue(buf, "tn_port=", value, &valueLen);
- SetTelnetPortStr(value);
- memset(value, 0, len);
- }
- memset(value, 0, len);
- #ifndef HARDWARE_BT6708
- // Параметры реле и сухих контактов
- GetParamValue(buf, "di1=", value, &valueLen);
- SetDINTypeActStr(value, 0);
- memset(value, 0, len);
- GetParamValue(buf, "ro1=", value, &valueLen);
- SetROTypeActStr(value, 0);
- memset(value, 0, len);
- GetParamValue(buf, "ro2=", value, &valueLen);
- SetROTypeActStr(value, 1);
- memset(value, 0, len);
- GetParamValue(buf, "ro3=", value, &valueLen);
- SetROTypeActStr(value, 2);
- memset(value, 0, len);
- #endif
- GetParamValue(buf, "utc=", value, &valueLen);
- SetSntpTimeZoneStr(value);
- memset(value, 0, len);
-
- // Параметры даты и времени
- GetParamValue(buf, "ntp=", value, &valueLen);
- if (strncmp(value, "1", 1) == 0) // Если ntp on устанавливаем параметры
- {
- bool old_sntp = false;
- bool enable_old_sntp = sSettings.sSNTP.sntpEnable;
- memset(str, 0, len);
- GetParamValue(buf, "ntpservip=", str, &valueLen);
- if(strncmp(str, sSettings.sSNTP.ip, valueLen))
- old_sntp = true;
- SetSntpServerIpStr(str);
- SetSntpStateStr(value);
- if(sSettings.sSNTP.sntpEnable != enable_old_sntp)
- old_sntp = true;
- if(old_sntp){
- SNTP_Init();
- //vTaskDelay(7000);
- SNTP_Poll();
- }
- memset(value, 0, len);
- memset(str, 0, len);
- }
- else if (strncmp(value, "0", 1) == 0){
- SetSntpStateStr(value);
- memset(value, 0, len);
- GetParamValue(buf, "date=", value, &valueLen);
- SetDateStr(value);
- memset(value, 0, len);
- GetParamValue(buf, "time=", value, &valueLen);
- memset(str, 0, len);
- url_decode(str, sizeof(str), value);
- SetTimeStr(str);
- memset(value, 0, len);
- memset(str, 0, len);
- }
-
- GetParamValue(buf, "ups_cell_min=", value, &valueLen);
- SetUPSVoltCellMinStr(value);
- memset(value, 0, len);
- GetParamValue(buf, "ups_cell_max=", value, &valueLen);
- SetUPSVoltCellMaxStr(value);
- memset(value, 0, len);
- GetParamValue(buf, "mainvolt_high=", value, &valueLen);
- SetVACAlarmHighRangeStr(value);
- memset(value, 0, len);
- GetParamValue(buf, "mainvolt_low=", value, &valueLen);
- SetVACAlarmLowRangeStr(value);
- memset(value, 0, len);
- GetParamValue(buf, "mainvolt_hist=", value, &valueLen);
- SetVACAlarmHisteStr(value);
- memset(value, 0, len);
- GetParamValue(buf, "temp_high=", value, &valueLen);
- SetTemperatureAlarmHighRangeStr(value);
- memset(value, 0, len);
- GetParamValue(buf, "temp_low=", value, &valueLen);
- SetTemperatureAlarmLowRangeStr(value);
- memset(value, 0, len);
- GetParamValue(buf, "temp_hist=", value, &valueLen);
- SetTemperatureAlarmHisteStr(value);
- memset(value, 0, len);
- GetParamValue(buf, "loadvolt_high=", value, &valueLen);
- SetLoadAlarmHighRangeStr(value);
- memset(value, 0, len);
- GetParamValue(buf, "loadvolt_hist=", value, &valueLen);
- SetLoadAlarmHistStr(value);
- memset(value, 0, len);
- /* Если параметры WEB изменились выставляем флаг, сохраняем настройки и перезагружаемся */
- if (GetStateWebReinit() == true)
- {
- telnet_act = false;
- SetWebReinitFlag(true);
- HTTP_SaveSettings();
- /* Блокируем управление ключем на тау секунд*/
- //IO_KeyBlockOn();
- vTaskDelay(1010);
- Reboot();
- }
- telnet_act = false;
- HTTP_SaveSettings();
- }
- /**
- * @brief
- * @retval None
- */
- void HTTP_SetInfo(char *buf, uint16_t lenBuf)
- {
- uint8_t valueLen = 0;
- const uint8_t len = 110;
- char value[330];
- char str[110];
- // ClearParamString(buf);
-
- memset(value, 0, len);
-
- /* Название устройства */
- GetParamValue(buf, "sysname=", value, &valueLen);
- url_decode(str, sizeof(str), value);
- SetNameDeviceStr(str);
- memset(value, 0, len);
-
- /* Владелец */
- GetParamValue(buf, "owner=", value, &valueLen);
- url_decode(str, sizeof(str), value);
- SetOwner(str);
- memset(value, 0, len);
- /* Владелец */
- GetParamValue(buf, "sysLocation=", value, &valueLen);
- url_decode(str, sizeof(str), value);
- SetLocation(str);
- memset(value, 0, len);
-
- /* Комментарий */
- GetParamValue(buf, "comment=", value, &valueLen);
- url_decode(str, sizeof(str), value);
- SetComment(str);
- memset(value, 0, len);
- telnet_act = false;
- HTTP_SaveSettings();
- }
- /**
- * @brief Запуск/останов теста UPS
- */
- void HTTP_UPSTest(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
- {
- uint8_t valueLen = 0;
- char tempValue[20];
- char tempValue2[20];
- int8_t res = 0;
- char log_string[50];
- memset(tempValue, 0, 20);
- memset(tempValue2, 0, 20);
- memset(log_string, 0,50);
- strcpy(bufOut, HTTP_200_OK);
- GetParamValue(bufIn, "func=", tempValue, &valueLen);
- if (strcmp(tempValue, "stop") == 0){
- res = ups_metac_service_pdu(ups_cancel_test);
- if(res == 1 || res == 0){
- strcat(bufOut, "Тест остановлен!");
- strcpy(log_string, name_login);
- strcat(log_string, " (Останов)");
- log_event_data(LOG_TEST_UPS, log_string);
- }
- if(res == -1)
- strcat(bufOut, "Тест не удалось остановить!");
- *lenBufOut = strlen(bufOut);
- }
- else if (strcmp(tempValue, "discharge") == 0){
- res = ups_metac_service_pdu(ups_test_low_bat);
- if(res == 1 || res == 0){
- strcat(bufOut, "Тест запущен!");
- strcpy(log_string, name_login);
- strcat(log_string, " (Запущен)");
- log_event_data(LOG_TEST_UPS, log_string);
- }
- if(res == -1)
- strcat(bufOut, "Тест не удалось запустить!");
- *lenBufOut = strlen(bufOut);
- }
- else if (strncmp(tempValue, "time", 6) == 0){
- GetParamValue(bufIn, "=", tempValue2, &valueLen);
- TimeParam = atoi(tempValue2);
- res = ups_metac_service_pdu(ups_test_time);
- if(res == 1 || res == 0){
- strcat(bufOut, "Тест запущен!");
- strcpy(log_string, name_login);
- strcat(log_string, " (Запущен)");
- log_event_data(LOG_TEST_UPS, log_string);
- }
- if(res == -1)
- strcat(bufOut, "Тест не удалось запустить!");
- *lenBufOut = strlen(bufOut);
- }
- }
- /**
- * @brief Выклюение UPS
- */
- void HTTP_UPSshutdown(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
- {
- uint8_t valueLen = 0;
- char *valueLenEnd = 0;
- char tempValue[50];
- char tempValue2[50];
- int8_t res = 0;
- char log_string[50];
- memset(tempValue, 0, 50);
- memset(log_string, 0,50);
- strcpy(bufOut, HTTP_200_OK);
- GetParamValue(bufIn, "func=", tempValue, &valueLen);
- if (strcmp(tempValue, "reboot") == 0){
- res = ups_metac_service_pdu(ups_cancel_shut_down);
- if(res == 1){
- strcpy(log_string, name_login);
- strcat(log_string, " (Останов)");
- log_event_data(LOG_SHUTDOWN_UPS, log_string);
- strcat(bufOut, "Выключение нагрузки ИБП отменено!");
- }
- else
- strcat(bufOut, "Выключение нагрузки ИБП не удалось отменить!");
- *lenBufOut = strlen(bufOut);
- }
- else if (strncmp(tempValue, "off", 5) == 0){
- memset(tempValue2, 0, 50);
- GetParamValue(bufIn, "after=", tempValue2, &valueLen);
- TimeParamFloat = atof(tempValue2);
- res = ups_metac_service_pdu(ups_shutdown);
- if(res == 1){
- strcat(bufOut, "Отключение нагрузки ИБП!");
- log_event_data(LOG_SHUTDOWN_UPS, name_login);
- }else
- strcat(bufOut, "Отключение нагрузки ИБП не удалось!");
- *lenBufOut = strlen(bufOut);
- }
- }
- /**
- * @brief Проверка пароля для перехода в режим bootloader
- * @retval None
- */
- void HTTP_ConfirmBootPwd(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
- {
- char tempStr[50];
- strncpy(tempStr, bufIn, 50);
- char value[20];
- uint8_t valueLen;
-
- memset(value, 0, 20);
- telnet_act = false;
- /* Запускаем задачу отложенной перезагрузки. Контроллер должен успеть
- отправить ответ серверу о статусе пароля */
- HTTP_StartResetTask(true);
- }
- void LoginTimerCallback(TimerHandle_t pxTimer) {
- cnt_err_psw = 0;
- DBG printf("cnt_err_psw %d", cnt_err_psw);
- xTimerStop(RepeatLoginTimer, 0);
- }
- /**
- * @brief Проверка пароля для входа в Web
- * @retval None
- */
- int HTTP_ConfirmWebPwd(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
- {
- char tempStr[50];
- char login[20];
- char password[20];
- char tmp_password[33];
- uint8_t valueLen, user_id;
- char *strPtr = 0;
- char WebPassword[MAX_WEB_PASSWD_LEN];
- char WebLogin[MAX_WEB_LOGIN_LEN];
- memset(login, 0, 20);
- memset(password, 0, 20);
- memset(tmp_password, 0, 33);
- memset(tempStr, 0, 50);
- memset(name_login, 0, 50);
- /* Get first 50 bytes of string */
- strncpy(tempStr, bufIn, 49);
- /* Add " " to the string in order GetParamValue() can be able to parse the param */
- strcat(tempStr, " ");
- GetParamValue(tempStr, "login=", login, &valueLen);
- GetParamValue(tempStr, "password=", tmp_password, &valueLen);
- url_decode(password, sizeof(password), tmp_password);
- valueLen = strlen(password);
- for (user_id = 0; user_id < MAX_WEB_USERS; user_id++) {
- GetUserLogin(user_id, WebLogin, &valueLen);
- GetUserPassword(user_id, WebPassword, &valueLen);
- /* Check login and password */
- if ((strncmp(WebLogin, login, MAX_WEB_LOGIN_LEN) == 0) &&
- (strncmp(WebPassword, password, MAX_WEB_PASSWD_LEN) == 0)) {
- /* Login and pass are valid */
- /* TODO replace global flag with user-pass-cookie */
- if(cnt_err_psw < 4){
- cnt_err_psw = 0;
- Authenticated = true;
- }
- else{
- Authenticated = false;
- }
- break;
- }
- else{
- Authenticated = false;
- }
- }
- if(Authenticated){
- /* Generate cookie */
- sprintf(tempStr, "%X", (unsigned int)GetRandomNumber());
- /* Set users cookie */
- HTTP_SetUserCookie(tempStr, user_id);
- HTTP_UpdateUserLoginTime(user_id);
- /* Send login and cookie back */
- strcpy(bufOut, "HTTP/1.0 200 OK\r\nContent-Type:text/html\r\nSet-Cookie: uname=");
- strcat(bufOut, login);
- strcat(bufOut, "\r\nSet-Cookie: id=");
- strcat(bufOut, tempStr);
- sprintf(tempStr, "%d", user_id);
- strcat(bufOut, "\r\nSet-Cookie: role=");
- strcat(bufOut, tempStr);
- strcat(bufOut, "\r\nSet-Cookie: auth=1");
- strcat(bufOut, "\r\n\r\n");
- strcat(bufOut,"<!DOCTYPE html><html lang=""><head><meta http-equiv=\"refresh\" content=\"0;url=/index.html\"/></head></html>\r\n\r\n");
- *lenBufOut = strlen(bufOut);
- switch (user_id) {
- case 0:
- snprintf(name_login, sizeof(name_login), "Администратор");
- break;
- case 1:
- snprintf(name_login, sizeof(name_login), "Пользователь");
- break;
- default:
- break;
- }
- log_event_data(LOG_LOGIN, name_login);
- /* Запускаем задачу-таймер логаута. */
- /* TODO отправить ответ серверу о статусе пароля */
- return SEND_REQUIRED_YES;
- }
- else{
- if(cnt_err_psw <= 4)
- cnt_err_psw ++;
- DBG printf("cnt_err_psw %d", cnt_err_psw);
- if(cnt_err_psw == 4)
- xTimerStart(RepeatLoginTimer, 0);
- strcpy(bufOut, "HTTP/1.0 200 OK\r\nContent-Type: text/html;\r\n\r\n");
- if(cnt_err_psw < 4)
- 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>");
- else
- strcat(bufOut,"<!DOCTYPE html><html><head><meta charset=\"utf-8\"><meta http-equiv=\"refresh\" content=\"3; url=/login.html\" /></head><center><h2>Вход заблокирован!</h2></center></head><center><h2>Повторите попытку через 1 минуту</h2></center></html>");
- *lenBufOut = strlen(bufOut);
- return SEND_REQUIRED_NO;
- }
- }
- /**
- * @brief
- * @retval None
- */
- uint8_t GetParamValue(char *inStr, char *paramName, char *paramValue, uint8_t *paramLen)
- {
- char *beginValue = 0;
- char *endValue = 0;
- int len = 0;
- char *strPtr = 0;
-
- strPtr = strstr(inStr, paramName);
-
- if (strPtr != 0)
- {
- beginValue = strpbrk(strPtr,"=");
- endValue = strpbrk(strPtr,"&");
- if (endValue == 0)
- endValue = strpbrk(strPtr," ");
- len = endValue - beginValue - 1;
- strncpy(paramValue, beginValue + 1, len);
- *endValue = '0';
- *beginValue = '0';
- *paramLen = len;
- return 1;
- }
- else
- {
- *paramLen = 0;
- return 0;
- }
- }
- /**
- * @brief
- * @retval None
- */
- uint8_t GetCookieValue(char *inStr, char *paramName, char *paramValue, uint8_t *paramLen)
- {
- char *beginValue = 0;
- char *endValue = 0;
- char *endValueTemp = 0;
- int len = 0;
- char *strPtr = 0;
- strPtr = strstr(inStr, paramName);
- if (strPtr != 0)
- {
- beginValue = strpbrk(strPtr,"=");
- endValue = strpbrk(strPtr,";");
- endValueTemp = strpbrk(strPtr,"\r");
- if(endValueTemp != 0 && endValueTemp < endValue)
- endValue = endValueTemp;
- if (endValue == 0)
- endValue = strpbrk(strPtr,"\n");
- len = endValue - beginValue - 1;
- strncpy(paramValue, beginValue + 1, len);
- *endValue = '0';
- *beginValue = '0';
- *paramLen = len;
- return 1;
- }
- else
- {
- *paramLen = 0;
- return 0;
- }
- }
- char* Parce_Boundary(const char* data, uint32_t len, char* dst, uint8_t dstlen) {
- char *ptr = NULL;
- char *boundary = NULL;
- uint8_t i = 0;
- for (uint32_t j = 0; j < len; j++) {
- if (strncmp ((char*)(data + j), "boundary=", 9) == 0) {
- boundary = (char*)data + j + 9;
- break;
- }
- }
- if (!boundary) return NULL;
- *dst++ = '-';
- *dst++ = '-';
- ptr = boundary;
- while ((*ptr != 0x0d) && (i < dstlen - 4))
- {
- *dst++ = *ptr++;
- i++;
- }
- //*dst++ = '-';
- //*dst++ = '-';
- *dst = '\0';
- if (i > 0)
- return boundary;
- else
- return NULL;
- }
- void ClearParamString(char *inBuf)
- {
- uint16_t len;
- char *str;
-
- str = strstr(inBuf, "HTTP");
-
- if (str != 0)
- {
- len = str - inBuf;
- memset(str, 0, RECIVE_BUF_MAX_LEN - len - 1);
- }
- }
- /**
- * @brief Чтение Cookie пользователя
- */
- static void HTTP_GetUserCookie(uint8_t user_id, char *str, uint8_t *len)
- {
- sprintf(str, "%s", users[user_id].cookie);
- *len = strlen(str);
- }
- /**
- * @brief Установка Cookie пользователя
- */
- static void HTTP_SetUserCookie(char *str, uint8_t user_id)
- {
- strcpy(users[user_id].cookie, str);
- }
- /**
- * @brief Обновление времени последней активности пользователя
- */
- static void HTTP_UpdateUserLoginTime(uint8_t user_id)
- {
- xTimerStart(users[user_id].LogoutTimer, 0);
- }
- /**
- * @brief Extract the Content_Length data from HTML data
- * @param data : pointer on receive packet buffer
- * @param len : buffer length
- * @retval size : Content_length in numeric format
- */
- static uint32_t Parse_Content_Length(char *data, uint32_t len)
- {
- uint32_t i=0,size=0, S=1;
- int32_t j=0;
- char sizestring[6], *ptr;
- ContentLengthOffset =0;
- /* find Content-Length data in packet buffer */
- for (i=0;i<len;i++)
- {
- if (strncmp ((char*)(data+i), Content_Length, 16)==0)
- {
- ContentLengthOffset = i+16;
- break;
- }
- }
- /* read Content-Length value */
- if (ContentLengthOffset)
- {
- i=0;
- ptr = (char*)(data + ContentLengthOffset);
- while(*(ptr+i)!=0x0d)
- {
- sizestring[i] = *(ptr+i);
- i++;
- ContentLengthOffset++;
- }
- if (i>0)
- {
- /* transform string data into numeric format */
- for(j=i-1;j>=0;j--)
- {
- size += (sizestring[j]-0x30)*S;
- S=S*10;
- }
- }
- }
- return size;
- }
- /**
- * @brief Принудительный логаут пользователя
- */
- static void HTTP_ForceUserLogout(uint8_t user_id)
- {
- char cookie[MAX_WEB_COOKIE_LEN];
- /* Flush user cookie by random value */
- sprintf(cookie, "%X", (unsigned int)GetRandomNumber());
- HTTP_SetUserCookie(cookie, user_id);
- }
- /**
- * @brief >Callback таймера логаута пользователя
- */
- void LogoutTimerCallback(TimerHandle_t pxTimer) {
- uint8_t user_id = (uint8_t)pvTimerGetTimerID( pxTimer );
- HTTP_ForceUserLogout(user_id);
- }
- /**
- * @brief Смена пароля пользователя
- * @retval None
- */
- int HTTP_ChangeUserPwd(char *bufIn, char *bufOut, uint16_t lenBufIn, uint16_t *lenBufOut)
- {
- char tempStr[110];
- char value[20];
- char login[20];
- char password[20];
- char tmp_password[33];
- uint8_t valueLen, valueLen2, user_id;
- char WebLogin[MAX_WEB_LOGIN_LEN];
- (void)lenBufIn;
- memset(login, 0, 20);
- memset(password, 0, 20);
- memset(tmp_password, 0, 33);
- memset(tempStr, 0, 50);
- memset(value, 0, 20);
- ClearParamString(bufIn);
- strncpy(tempStr, bufIn, 110);
- strcpy(bufOut, HTTP_200_OK);
- if (GetParamValue(tempStr, "username=", login, &valueLen) &&
- GetParamValue(tempStr, "oldpass=", password, &valueLen))
- {
- for (user_id = 0; user_id < MAX_WEB_USERS; user_id++)
- {
- memset(value, 0, 20);
- memset(WebLogin, 0, MAX_WEB_LOGIN_LEN);
- GetUserLogin(user_id, WebLogin, &valueLen);
- GetUserPassword(user_id, value, &valueLen2);
- /* Check login and password */
- if ((strncmp(WebLogin, login, MAX_WEB_LOGIN_LEN) == 0) &&
- (memcmp(password, value, 11) == 0))
- {
- memset(password, 0, 20);
- if (GetParamValue(tempStr, "newpass=", tmp_password, &valueLen))
- {
- url_decode(password, sizeof(password), tmp_password);
- valueLen = strlen(password);
- memcpy(sSettings.sAuth[user_id].password, password, 11);
- telnet_act = false;
- HTTP_SaveSettings();
- log_event_data(LOG_PSW_CHANGE, name_login);
- strcat(bufOut, "Пароль успешно изменён");
- *lenBufOut = strlen(bufOut);
- return SEND_REQUIRED_YES;
- }
- else {
- strcat(bufOut, "Введены некорректные данные!");
- *lenBufOut = strlen(bufOut);
- return SEND_REQUIRED_YES;
- }
- }
- }
- strcat(bufOut, "Введён неверный пароль!");
- *lenBufOut = strlen(bufOut);
- return SEND_REQUIRED_YES;
- }
- else {
- strcat(bufOut, "Введены некорректные данные!");
- *lenBufOut = strlen(bufOut);
- return SEND_REQUIRED_YES;
- }
- }
- //
- void Cockie(void)
- {
- receiveBuf[receivedBufLen] = '\0';
- //printf("receive %s \r\n", receiveBuf);
- // Get cookie "uname" value
- memset(CookieBuf, 0, sizeof(CookieBuf));
- CookiePtr = strstr(receiveBuf, "uname=");
- strncpy(CookieBuf, CookiePtr, 50);
-
- //printf("********CookieBuf1= %s\r\n", CookieBuf);
- memset(name, 0, MAX_WEB_COOKIE_LEN);
- GetCookieValue(CookieBuf, "uname=", name, &nameLen);
- //printf("********CookieBuf2= %s\r\n", CookieBuf);
- //printf("********uname= %s\r\n", name);
- memset(CookieBuf, 0, sizeof(CookieBuf));
- // Get cookie "id" value
- CookiePtr = strstr(receiveBuf, " id=");
- strncpy(CookieBuf, CookiePtr, 50);
-
- //printf("********CookieBuf1= %s\r\n", CookieBuf);
- memset(id, 0, MAX_WEB_COOKIE_LEN);
- GetCookieValue(CookieBuf, "id=", id, &idLen);
- // printf("********ID= %s\r\n", id);
- }
- //
- void getAuthenticatedState(void)
- {
- seclevel = 0xFF;
- for (user_id = 0; user_id < MAX_WEB_USERS; user_id++) {
- HTTP_GetUserCookie(user_id, CookieBuf, &idLen);
- if (strncmp(id, CookieBuf, idLen) == 0 ) {
- GetUserLevelInt(user_id, &seclevel);
- Authenticated = true;
- break;
- }
- Authenticated = false;
- seclevel = 0xFF;
- }
- }
- //
- char* AuthenticatedFalseRoutine(uint16_t* sendLen)
- {
- if (strncmp(receiveBuf, "GET /main.css", 13) == 0) // +
- {
- fs_open("/main.css", &file);
- *sendLen = file.len;
- return file.data;
- }
- else if (strncmp(receiveBuf, "GET /rotek.png", 14) == 0) // +
- {
- fs_open("/rotek.png", &file);
- *sendLen = file.len;
- return file.data;
- }
- else if (strncmp(receiveBuf, "GET /favicon.ico", 16) == 0) // ?
- {
- fs_open("/favicon.ico", &file);
- *sendLen = file.len;
- return file.data;
- }
- else if (strncmp(receiveBuf, "GET /role.js", 12) == 0)
- {
- fs_open("/role.js", &file);
- *sendLen = file.len;
- return file.data;
- }
- else if (strncmp(receiveBuf, "POST /login.cgi", 15) == 0)
- {
- uint32_t req_data_received = 0;
- char *offset = 0;
-
- post_data_count = Parse_Content_Length(receiveBuf, receivedBufLen);
-
- if (post_data_count < MAX_POST_REQ_LEN)
- {
- memset(post_req_data, 0, MAX_POST_REQ_LEN);
- offset = (strstr(receiveBuf, "\r\n\r\n")) + 4;
- req_data_received = receivedBufLen - (offset - &receiveBuf[0]);
- if (offset != 0)
- {
- if (req_data_received < post_data_count)
- {
- snprintf(post_req_data, req_data_received, "%s", receiveBuf);
- post_data_count -= req_data_received;
- }
- /* if data received completely */
- else {
- strncat(post_req_data, &receiveBuf[offset - &receiveBuf[0]], post_data_count);
- //printf("post_req_data: %s\r\n", post_req_data);
- /* End reqest */
- post_data_count = 0;
- log_post_reqn = 0;
- if (HTTP_ConfirmWebPwd(post_req_data, sendBuf, strlen(post_req_data), sendLen) == SEND_REQUIRED_YES) {
- return sendBuf;
- }
- else {
- /* Redirect to login page */
- /* fs_open("/login.html", &file);
- *sendLen = file.len;
- return file.data;*/
- return sendBuf;
- }
- }
- }
- // request was fragmented before "\r\n\r\n"
- else
- {
- log_post_reqn++;
- /* wait max 2 requests */
- if (log_post_reqn > 1) {
- /* End reqest */
- post_data_count = 0;
- log_post_reqn = 0;
- /* Redirect to login page */
- fs_open("/login.html", &file);
- *sendLen = file.len;
- return file.data;
- }
- }
- }
- else
- {
- //printf("Too long POST request!\r\n");
- // Ignore request
- post_data_count = 0;
- log_post_reqn = 0;
- // Redirect to login page
- fs_open("/login.html", &file);
-
- *sendLen = file.len;
- return file.data;
- }
- }
- else if (post_data_count > 0)
- {
- strncat(post_req_data, receiveBuf, post_data_count);
- post_data_count = 0;
- log_post_reqn = 0;
- if (HTTP_ConfirmWebPwd(post_req_data, sendBuf, strlen(post_req_data), sendLen) == SEND_REQUIRED_YES)
- {
- return sendBuf;
- }
- else
- {
- return sendBuf;
- }
- }
- else
- {
- fs_open("/login.html", &file);
-
- *sendLen = file.len;
- return file.data;
- }
- }
- //
- char* AuthenticatedTrueRoutine(uint16_t* sendLen)
- {
- char *DataOffset;
-
- if (strncmp(receiveBuf, "GET /getJson.cgi", 16) == 0) // +
- {
- HTTP_GetParamsPage1(sendBuf);
- *sendLen = strlen(sendBuf);
- return sendBuf;
- }
- else if (strncmp(receiveBuf, "GET /settings.cgi", 17) == 0) // +
- {
- if (seclevel == 0) {
- if (HTTP_SettingsPage(receiveBuf, sendBuf, receivedBufLen, sendLen) == SEND_REQUIRED_YES)
- {
- *sendLen = strlen(sendBuf);
- return sendBuf;
- }
- }
- return 0;
- }
- else if (strncmp(receiveBuf, "POST /settings.cgi", 18) == 0 || DataFlag2 >= 1)
- {
- if (seclevel == 0)
- {
- DataOffset = 0;
- // POST Packet received
- if (DataFlag2 == 0)
- {
- TotalReceived = 0;
- memset(sendBuf, 0, strlen(sendBuf));
- // parse packet for Content-length field
- size = Parse_Content_Length(receiveBuf, receivedBufLen);
- DataOffset = strstr(receiveBuf, "managerIP");
- // case of MSIE8 : we do not receive data in the POST packet
- if (DataOffset == 0)
- {
- DataFlag2++;
- return 0;
- }
- else{
- TotalReceived = receivedBufLen - (DataOffset - &receiveBuf[0]);
- strncat(sendBuf, DataOffset, TotalReceived);
- }
- }
- if (DataFlag2 == 0)
- {
- DataFlag2++;
- }
- else if (DataFlag2 == 1)
- {
- /* parse packet for the octet-stream field */
- DataOffset = strstr(receiveBuf, "managerIP");
- TotalReceived += receivedBufLen;
- strncat(sendBuf, DataOffset, TotalReceived);
- DataFlag2++;
- }
- /* DataFlag >1 => the packet is data only */
- else
- {
- TotalReceived +=receivedBufLen;
- strncat(sendBuf, receiveBuf, receivedBufLen);
- }
- // check if last data packet
- if (TotalReceived == size)
- {
- DBG printf("State: Received %d bytes\r\n", (int)TotalData);
- // printf("receive %s \r\n", sendBuf);
- strncat(sendBuf, " ", 1);
- HTTP_SetSettings(sendBuf, strlen(sendBuf));
- memset(sendBuf, 0, size);
- DataFlag2 = 0;
- strcpy(sendBuf, "HTTP/1.1 200 OK\r\n");
- strcat(sendBuf, "\r\n\r\n");
- strcat(sendBuf,"<!DOCTYPE html><html lang=""><head><meta http-equiv=\"refresh\" content=\"0;url=/settings.html\"/></head></html>\r\n\r\n");
- sendBufLoadLen = strlen(sendBuf);
- *sendLen = sendBufLoadLen;
- return sendBuf;
- }
- }
- return 0;
- }
- else if (strncmp(receiveBuf, "GET /info.cgi", 13) == 0) // +
- {
- if (HTTP_InfoPage(receiveBuf, sendBuf, receivedBufLen, sendLen) == SEND_REQUIRED_YES)
- {
- return sendBuf;
- }
- }
- else if (strncmp(receiveBuf, "POST /info.cgi", 14) == 0 || DataFlag >= 1)
- {
- DataOffset = 0;
- // POST Packet received
- if (DataFlag == 0)
- {
- TotalReceived = 0;
- memset(sendBuf, 0, strlen(sendBuf));
- // parse packet for Content-length field
- size = Parse_Content_Length(receiveBuf, receivedBufLen);
- DataOffset = strstr(receiveBuf, "sysname");
- // case of MSIE8 : we do not receive data in the POST packet
- if (DataOffset == 0)
- {
- DataFlag++;
- return 0;
- }
- else{
- TotalReceived = receivedBufLen - (DataOffset - &receiveBuf[0]);
- strncat(sendBuf, DataOffset, TotalReceived);
- }
- }
- if (DataFlag == 0)
- {
- DataFlag++;
- }
- else if (DataFlag == 1)
- {
- /* parse packet for the octet-stream field */
- DataOffset = strstr(receiveBuf, "sysname");
- TotalReceived += receivedBufLen;
- strncat(sendBuf, DataOffset, TotalReceived);
- DataFlag++;
- }
- /* DataFlag >1 => the packet is data only */
- else
- {
- TotalReceived +=receivedBufLen;
- strncat(sendBuf, receiveBuf, receivedBufLen);
- }
- // check if last data packet
- if (TotalReceived == size)
- {
- strncat(sendBuf, " ", 1);
- HTTP_SetInfo(sendBuf, strlen(sendBuf));
- DataFlag = 0;
- memset(sendBuf, 0, size);
- strcpy(sendBuf, "HTTP/1.1 200 OK\r\n");
- strcat(sendBuf, "\r\n\r\n");
- strcat(sendBuf,"<!DOCTYPE html><html lang=""><head><meta http-equiv=\"refresh\" content=\"0;url=/info.html\"/></head></html>\r\n\r\n");
- *sendLen = strlen(sendBuf);
- return sendBuf;
- }
- }
- else if (strncmp(receiveBuf, "GET /history.cgi", 16) == 0)
- {
- int res;
- res = HTTP_HistoryPage(receiveBuf, sendBuf, receivedBufLen, sendLen);
-
- if (res == SEND_REQUIRED_FILE)
- {
- HTTPTypeAnswer = HISTORY_ANSWER;
- return sendBuf;
- }
- else if (res == SEND_REQUIRED_YES)
- {
- return sendBuf;
- }
- }
- else if (strncmp(receiveBuf, "GET /ups_history.cgi", 19) == 0)
- {
- int res;
-
- res = HTTP_UpsHistoryPage(receiveBuf, sendBuf, receivedBufLen, sendLen);
-
- if (res == SEND_REQUIRED_FILE)
- {
- HTTPTypeAnswer = UPS_HISTORY_ANSWER;
- return sendBuf;
- }
- else if (res == SEND_REQUIRED_YES)
- {
- return sendBuf;
- }
- }
- /* Тест АКБ ИБП */
- else if (strncmp(receiveBuf, "GET /bat_test.cgi", 17) == 0)
- {
- HTTP_UPSTest(receiveBuf, sendBuf, receivedBufLen, sendLen);
- return sendBuf;
- }
- /* Выключение ИБП */
- else if (strncmp(receiveBuf, "GET /ups_power.cgi", 18) == 0)
- {
- HTTP_UPSshutdown(receiveBuf, sendBuf, receivedBufLen, sendLen);
- return sendBuf;
- }
- /* Сброс настроек и сохранине */
- else if (strncmp(receiveBuf, "GET /reset.cgi", 14) == 0)
- {
- telnet_act = false;
- HTTP_ResetSettings();
- HTTP_SaveSettings();
-
- fs_open("/settings.html", &file);
- *sendLen = file.len;
- return file.data;
- }
- /* Перезагрузка контроллера */
- else if (strncmp(receiveBuf, "GET /reboot.cgi", 15) == 0)
- {
- telnet_act = false;
- HTTP_Reboot();
- }
- /* Подтверждение новых сетевых настроек */
- else if (strncmp(receiveBuf, "GET /confirm.cgi", 16) == 0)
- {
- telnet_act = false;
- SetWebReinitFlag(false);
- SetConfirmWebParamsFlag();
-
- fs_open("/index.html", &file);
- *sendLen = file.len;
- return file.data;
- }
- /* Проверка пароля, переход в bootloader */
- else if (strncmp(receiveBuf, "GET /fw_update.cgi", 18) == 0)
- {
- HTTP_ConfirmBootPwd(receiveBuf, sendBuf, receivedBufLen, sendLen);
- return sendBuf;
- }
- /* Смена пароля пользователя */
- else if (strncmp(receiveBuf, "GET /changepwd.cgi", 18) == 0)
- {
- HTTP_ChangeUserPwd(receiveBuf, sendBuf, receivedBufLen, sendLen);
- return sendBuf;
- }
- /* Check common GET request */
- else if (strncmp(receiveBuf, "GET", 3) == 0) {
- char filename[MAX_FILENAME_LEN];
- char nonmatch[MAX_ETAG_LEN];
- char *pnonmatch = NULL;
- uint8_t len;
- if (GetFileName(receiveBuf, filename, &len)) {
- HTTP_UpdateUserLoginTime(user_id);
- /* Parce If-Non_Match value */
- uint8_t nonmatch_len = Parse_Header(receiveBuf, receivedBufLen, If_None_Match, 15, nonmatch);
- if (nonmatch_len < MAX_ETAG_LEN && nonmatch_len > 0) {
- DBG printf("If_None_Match: %s\r\n", nonmatch);
- pnonmatch = nonmatch;
- }
- return send_file(filename, pnonmatch, &file, sendLen);
- }
- }
- else
- {
- HTTP_UpdateUserLoginTime(user_id);
- fs_open("/index.html", &file); // +
- *sendLen = file.len;
- return file.data;
- }
-
- return 0;
- }
- /**
- * @brief sends file from flash FS
- * @param filename: pointer to the file name to send
- * @param pnonmatch: pointer to the If-Non_Match value
- * @param pcb: pointer to a tcp_pcb struct
- * @param hs: pointer to a http_state struct
- * @param file: pointer to a fs_file struct
- * @retval
- */
- char* send_file(char *filename, char *pnonmatch, struct fs_file *file, uint16_t *Len)
- {
- int res = 0;
- char etag[MAX_ETAG_LEN];
- char *petag = NULL;
- res = fs_open(filename, file);
- if (res == 0) {
- printf("Not found: %s\r\n", filename);
- sprintf(filename, "/index.html");
- fs_open(filename, file);
- }
- /* Find Etag value */
- uint8_t etag_len = Parse_Header(file->data, file->len, Etag, 6, etag);
- if (etag_len < MAX_ETAG_LEN && etag_len > 0) {
- DBG printf("Etag: %s\r\n", etag);
- petag = etag;
- }
- /* Compare Etag and If-Non-Match fields */
- if (pnonmatch && petag && (strcmp(pnonmatch, petag) == 0)) {
- /* Send 304 code */
- sprintf(sendBuf, HTTP_304_NOT_MODIFIED);
- DBG printf(sendBuf);
- *Len = strlen(sendBuf);
- return sendBuf;
- //hs->file = sendBuf;
- //hs->left = strlen(sendBuf);
- }
- else {
- /* Send file */
- //DBG printf("%s\r\n\r\n", filename);
- //hs->file = file->data;
- //hs->left = file->len;
- *Len = file->len;
- return file->data;
- }
- //send_data(pcb, hs);
- //tcp_sent(pcb, http_sent);
- }
- /**
- * @brief Extract the custom field data from HTML data
- * @param data : pointer on receive packet buffer
- * @param len : buffer length
- * @param field : field name
- * @param flen : field name length
- * @retval value : pointer for field data
- */
- static uint32_t Parse_Header(char *data, uint32_t len, const char *field, uint32_t flen, char *value)
- {
- uint32_t i = 0, size = 0;
- char *ptr;
- uint32_t Offset = 0;
- /* Find field name in data buffer */
- for (i = 0; i < len; i++) {
- if (strncmp ((char*)(data + i), field, flen) == 0) {
- Offset = i + flen;
- break;
- }
- }
- /* Copy Field value */
- if (Offset) {
- i = 0;
- ptr = (char*)(data + Offset);
- while (*(ptr + i) != 0x0d) {
- value[i] = *(ptr + i);
- i++;
- }
- value[i] = '\0';
- size = i;
- }
- return size;
- }
- /**
- * @brief
- * @retval None
- */
- bool GetFileName(char *inStr, char *fileName, uint8_t *fileNameLen)
- {
- char *beginValue = NULL;
- char *endValue = NULL;
- int len = 0;
- char *strPtr = NULL;
- strPtr = strstr(inStr, "GET");
- if (strPtr == NULL) {
- strPtr = strstr(inStr, "POST");
- }
- if (strPtr == NULL) {
- *fileNameLen = 0;
- return false;
- }
- else {
- beginValue = strpbrk(strPtr, "/");
- endValue = strpbrk(beginValue, " ");
- if (endValue == NULL) {
- *fileNameLen = 0;
- return false;
- }
- len = endValue - beginValue;
- if (len < MAX_FILENAME_LEN) {
- strncpy(fileName, beginValue, len);
- *fileNameLen = len;
- fileName[len] = '\0';
- return true;
- }
- else {
- return false;
- }
- }
- }
- #endif
|