add todo.md, fixed segfault in protocol.c, and fix response sending

4 files changed, 28 insertions, 15 deletions

diff --git a/stm32f091/consts.h b/stm32f091/consts.h
index 3d2ef5a..955ceea 100644
--- a/stm32f091/consts.h
+++ b/stm32f091/consts.h
@@ -6,7 +6,7 @@
 #define WS_SERVER_MAX_CHANNELS 4
 
 #define WS_DMA_RX_BUFFER_SIZE 100
-#define WS_DMA_TX_BUFFER_SIZE 1024
+#define WS_DMA_TX_BUFFER_SIZE 100
 
 #define WS_PINOUT_I2C_SDA_PIN GPIO_PIN_9
 #define WS_PINOUT_I2C_SDA_PORT GPIOB
diff --git a/stm32f091/protocol.c b/stm32f091/protocol.c
index 3a8d78b..21e6527 100644
--- a/stm32f091/protocol.c
+++ b/stm32f091/protocol.c
@@ -13,19 +13,21 @@ void ws_protocol_res_last_records(ws_s_protocol_parsed_req_cmd* parsed_cmd, ws_s
 
 	if (!send) {
 		response->success = WS_PROTOCOL_CMD_RETURN_OK;
-		if (sscanf(parsed_cmd->argv[1], "%u", &record_amount) < 1) response->success = WS_PROTOCOL_CMD_RETURN_ERROR;
-		record_amount = WS_MIN(record_amount, ws_backlog_get_record_count());
 		response->csh = true;
 		response->msg = ws_bin_s_alloc(0);
-		response->msg->bytes = strlen(response_header) + response_line_size * record_amount;
+		response->msg->bytes = 0;
+		record_amount = WS_MIN(record_amount, ws_backlog_get_record_count());
+		if (sscanf(parsed_cmd->argv[1], "%u", &record_amount) < 1) response->success = WS_PROTOCOL_CMD_RETURN_ERROR;
+		else response->msg->bytes = strlen(response_header) + response_line_size * record_amount;
 		ws_server_req_respond_start(0, response->msg->bytes + ws_protocol_get_header_size(response));
 	} else {
+		if (response->success == WS_PROTOCOL_CMD_RETURN_ERROR) return;
 		ws_protocol_send_data(response_header, strlen(response_header));
-		char line[response_line_size + 1]; // +1 for null terminator -> sprintf
+		char line[response_line_size];
 		for (unsigned int i = 0; i < record_amount; i++) {
 			ws_s_backlog_record* record = ws_backlog_get_last_record(i);
 			sprintf(line, "%04x,%02x,%02x,%02x\n", record->id, record->sens_temperature, record->sens_humidity, record->sens_atm_pressure);
-			ws_protocol_send_data(line, response_line_size);
+			ws_protocol_send_data(line, response_line_size - 1); // remove string terminator
 		}
 		ws_protocol_send_data("\r\n", 2); // test
 	}
@@ -33,5 +35,4 @@ void ws_protocol_res_last_records(ws_s_protocol_parsed_req_cmd* parsed_cmd, ws_s
 
 void ws_protocol_send_data(const char* data, unsigned int length) {
 	ws_server_buffer_send_append((uint8_t*) data, length);
-	// HAL_UART_Transmit(&huart1, (uint8_t*) data, length, HAL_MAX_DELAY);
 }
diff --git a/stm32f091/server.c b/stm32f091/server.c
index 8001380..1419da8 100644
--- a/stm32f091/server.c
+++ b/stm32f091/server.c
@@ -20,7 +20,7 @@ ws_s_server_parser g_ws_server_parser = {
 };
 
 static ws_s_protocol_req_parser_state* g_ws_protocol_parsers[WS_SERVER_MAX_CHANNELS] = {0};
-static unsigned int g_ws_esp8266_dma_tx_buffer_index = 0;
+static unsigned int g_ws_esp8266_dma_tx_buffer_size = 0;
 
 void ws_server_req_parse_byte(unsigned int channel, uint8_t byte, bool ignore) {
 	if (ignore) return;
@@ -126,7 +126,7 @@ void ws_server_req_incoming(uint8_t* data, size_t size) {
 				break;
 			}
 			case WS_SERVER_LM_CIPSEND_LISTENING: {
-				if (next_few_bytes_are("SEND OK")) {
+				if (next_few_bytes_are("SEND OK") || next_few_bytes_are("ERROR")) {
 					ws_server_req_respond_end(0);
 					// g_ws_server_parser.mode = WS_SERVER_LM_IDLE;
 				}
@@ -146,23 +146,25 @@ void ws_server_send(uint8_t* data, size_t size) {
 void ws_server_buffer_send_append(uint8_t* data, size_t size) {
 	// TODO: buffer overrun protection
 	// while (!__HAL_DMA_GET_FLAG(&hdma_usart1_tx, DMA_FLAG_TC2)); // make sure buffer isn't used
-	strncpy((char*) &g_ws_esp8266_dma_tx_buffer[g_ws_esp8266_dma_tx_buffer_index], (char*) data, size); // append string
-	g_ws_esp8266_dma_tx_buffer_index += size; // shift head
+	strncpy((char*) &g_ws_esp8266_dma_tx_buffer[g_ws_esp8266_dma_tx_buffer_size], (char*) data, size); // append string
+	g_ws_esp8266_dma_tx_buffer_size += size; // shift head
 }
 
+// TODO: refactor this
 void ws_server_buffer_send_finish() {
 #ifdef WS_DBG_PRINT_ESP_OVER_USART2
 	uint8_t green[] = { 0x1b, 0x5b, 0x33, 0x32, 0x6d };
 	HAL_UART_Transmit(&huart2, green, sizeof(green), 100);
-	HAL_UART_Transmit(&huart2, g_ws_esp8266_dma_tx_buffer, strlen((char*) g_ws_esp8266_dma_tx_buffer), 100);
+	HAL_UART_Transmit(&huart2, g_ws_esp8266_dma_tx_buffer, g_ws_esp8266_dma_tx_buffer_size, 100);
 #endif
 
-	HAL_UART_Transmit_DMA(&huart1, g_ws_esp8266_dma_tx_buffer, strlen((char*) g_ws_esp8266_dma_tx_buffer));
+	HAL_UART_Transmit_DMA(&huart1, g_ws_esp8266_dma_tx_buffer, g_ws_esp8266_dma_tx_buffer_size);
 	__HAL_UART_ENABLE_IT(&huart1, UART_IT_TXE);
-	g_ws_esp8266_dma_tx_buffer_index = 0;
+	g_ws_esp8266_dma_tx_buffer_size = 0;
 	while (!__HAL_DMA_GET_FLAG(&hdma_usart1_tx, DMA_FLAG_TC2));
 }
 
+// TODO: refactor this
 void ws_server_req_respond_start(unsigned int channel, size_t size) {
 	char* cmd = NULL;
 	size_t len = asiprintf(&cmd, "AT+CIPSEND=%d,%d\r\n", channel, size);
@@ -171,6 +173,7 @@ void ws_server_req_respond_start(unsigned int channel, size_t size) {
 	while (!__HAL_DMA_GET_FLAG(&hdma_usart1_tx, DMA_FLAG_TC2));
 }
 
+// TODO: refactor this
 void ws_server_req_respond_end(unsigned int channel) {
 	char* cmd = NULL;
 	size_t len = asiprintf(&cmd, "AT+CIPCLOSE=%d\r\n", channel);
@@ -178,4 +181,3 @@ void ws_server_req_respond_end(unsigned int channel) {
 	ws_esp8266_send((uint8_t*) cmd, len);
 	while (!__HAL_DMA_GET_FLAG(&hdma_usart1_tx, DMA_FLAG_TC2));
 }
-
diff --git a/stm32f091/todo.md b/stm32f091/todo.md
new file mode 100644
index 0000000..767d745
--- /dev/null
+++ b/stm32f091/todo.md
@@ -0,0 +1,10 @@
+- handle errors from `AT+CIPSEND`, these look like this:
+  ```
+  > AT0,CONNECT
+
+  > +IPD,0,15:last-records 5<0a>
+  < AT+CIPSEND=0,125
+  > AT+CIPSEND=0,125
+
+  > ERROR
+  ```