#ifdef HARDWARE_BT6706 #include "lwip/opt.h" #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" #include "bt6706_fs/fsdata.c" #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 #endif #ifdef PRINTF_CUSTOM #include "tinystdio.h" #endif #include #include #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_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(); getAuthenticatedState(); 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; send_data(pcb, hs); tcp_sent(pcb, http_sent); switch(HTTPTypeAnswer){ case HISTORY_ANSWER: while(sendBufLoadLen != 0){ hs->file = HTTP_SendHistory(&sendBufLoadLen); hs->left = sendBufLoadLen; if(sendBufLoadLen == 0){ close_conn(pcb,hs); break; } send_data(pcb, hs); tcp_sent(pcb, http_sent); } break; case UPS_HISTORY_ANSWER: while(sendBufLoadLen != 0){ hs->file = HTTP_SendLog(&sendBufLoadLen); hs->left = sendBufLoadLen; if(sendBufLoadLen == 0){ close_conn(pcb,hs); break; } send_data(pcb, hs); tcp_sent(pcb, http_sent); } break; } } } } pbuf_free(p); close_conn(pcb,hs); } if (err == ERR_OK && p == NULL) { close_conn(pcb, hs); } 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; /* 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; struct tcp_pcb *pcb; pcb = tcp_new(); tcp_bind(pcb, IP_ADDR_ANY, 80); pcb = tcp_listen(pcb); 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); /* Сетевые параметры */ 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); #ifdef HARDWARE_BT6706 /* Сетевые параметры */ 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); #endif #ifdef HARDWARE_BT6702 GetParamValue(buf, "swauth=", value, &valueLen); SetAuthEnableStateStr(value); if (strncmp(value, "on", 2) == 0){ /* параметры RADIUS*/ memset(value, 0, len); GetParamValue(buf, "rs_enabled=", value, &valueLen); SetRDSEnableStateStr(value); if (strncmp(value, "on", 2) == 0) // Если raddius off устанавливаем параметры { memset(value, 0, len); GetParamValue(buf, "rs_server=", value, &valueLen); SetRDSIpStr(value); memset(value, 0, len); GetParamValue(buf, "rs_port=", value, &valueLen); SetRDSPortStr(value); memset(value, 0, len); GetParamValue(buf, "rs_pwd=", value, &valueLen); SetRDSPasswordkStr(value); memset(value, 0, len); GetParamValue(buf, "rs_key=", value, &valueLen); SetRDSKeyAccesstStr(value); memset(value, 0, len); } } memset(value, 0, len); #endif // Параметры реле и сухих контактов 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); 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); } /* Если параметры WEB изменились выставляем флаг, сохраняем настройки и перезагружаемся */ if (GetStateWebReinit() == true) { SetWebReinitFlag(true); HTTP_SaveSettings(); /* Блокируем управление ключем на тау секунд*/ //IO_KeyBlockOn(); vTaskDelay(1010); Reboot(); } HTTP_SaveSettings(); } /** * @brief * @retval None */ void HTTP_SetInfo(char *buf, uint16_t lenBuf) { uint8_t valueLen = 0; const uint8_t len = 110; char value[110]; char str[110]; // ClearParamString(buf); 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); 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); /* Запускаем задачу отложенной перезагрузки. Контроллер должен успеть отправить ответ серверу о статусе пароля */ 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]; 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(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=", password, &valueLen); 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,"\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,"

Не правильный логин или пароль

"); else strcat(bufOut,"

Вход заблокирован!

Повторите попытку через 1 минуту

"); *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;i0) { /* 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]; uint8_t valueLen, valueLen2, user_id; char WebLogin[MAX_WEB_LOGIN_LEN]; (void)lenBufIn; memset(login, 0, 20); memset(password, 0, 20); 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=", password, &valueLen)) { memcpy(sSettings.sAuth[user_id].password, password, 11); 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; } } } // 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; char *ptr; 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) { if (seclevel == 0) { DataOffset = 0; // POST Packet received TotalReceived = 0; TotalData = 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) { //ssl_server_read(); // SSL_ReadRoutine(&ssl, (unsigned char*)receiveBuf); DataOffset = strstr(receiveBuf, "managerIP"); } TotalReceived = receivedBufLen - (DataOffset - &receiveBuf[0]); TotalData += TotalReceived; strncat(sendBuf, DataOffset, TotalReceived); for (int i = TotalData; i < size; i ++) { //ssl_server_read(); // SSL_ReadRoutine(&ssl, (unsigned char*)receiveBuf); strncat(sendBuf, receiveBuf, receivedBufLen); TotalData += receivedBufLen; } // check if last data packet if (TotalData == 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); strcpy(sendBuf, "HTTP/1.1 200 OK\r\n"); strcat(sendBuf, "\r\n\r\n"); strcat(sendBuf,"\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) { if (seclevel == 0) { DataOffset = 0; // POST Packet received TotalReceived = 0; TotalData = 0; memset(sendBuf, 0, strlen(sendBuf)); // parse packet for Content-length field size = Parse_Content_Length(receiveBuf, receivedBufLen); DataOffset = strstr(receiveBuf, "owner"); // case of MSIE8 : we do not receive data in the POST packet if (DataOffset == 0) { // SSL_ReadRoutine(&ssl, (unsigned char*)receiveBuf); DataOffset = strstr(receiveBuf, "owner"); } TotalReceived = receivedBufLen - (DataOffset - &receiveBuf[0]); TotalData += TotalReceived; strncat(sendBuf, DataOffset, TotalReceived); // check if last data packet if (TotalReceived == size) { strncat(sendBuf, " ", 1); HTTP_SetInfo(sendBuf, strlen(sendBuf)); DataFlag = 0; BrowserFlag = 0; memset(sendBuf, 0, size); strcpy(sendBuf, "HTTP/1.1 200 OK\r\n"); strcat(sendBuf, "\r\n\r\n"); strcat(sendBuf,"\r\n\r\n"); *sendLen = strlen(sendBuf); return sendBuf; } // not last data packet else { // write data in flash if(receivedBufLen) { strncat(sendBuf, ptr, receivedBufLen); //memcpy(receiveBufTemp, ptr, receivedBufLen); } } } } 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 HTTP_SendHistory(sendLen); } 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 HTTP_SendLog(sendLen); } 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) { HTTP_ResetSettings(); HTTP_SaveSettings(); fs_open("/settings.html", &file); *sendLen = file.len; return file.data; } /* Перезагрузка контроллера */ else if (strncmp(receiveBuf, "GET /reboot.cgi", 15) == 0) { HTTP_Reboot(); } /* Подтверждение новых сетевых настроек */ else if (strncmp(receiveBuf, "GET /confirm.cgi", 16) == 0) { 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 Send callback for log file transfer (messages as is, not ordered) */ char* HTTP_SendHistory(uint16_t *Len) { struct http_state *hs; uint32_t nbytes = 0; static bool start = true; 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; *Len = nbytes; if (nbytes == 0) { // File transfer finished. start = true; // Clear file transfer in progress flag fLogTransInprog = false; return 0; } return logFileBuf; // hs->file = logFileBuf; // hs->left = nbytes; // send_data(pcb, hs); // SSL_SendFrames(&ssl, logFileBuf, nbytes); // HTTP_SendHistory(); } /** * @brief Sent callback for log file transfer (messages as is, not ordered) */ char* HTTP_SendLog(uint16_t *Len) { uint32_t nbytes = 0; static bool start = true; 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; *Len = nbytes; if (nbytes == 0) { // File transfer finished. start = true; // Clear file transfer in progress flag fLogTransInprog = false; return 0; } // SSL_SendFrames(&ssl, logFileBuf, nbytes); // HTTP_SendLog(); return logFileBuf; } /** * @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