demo code upload

Author: shu-liu1314

Projects/PubSub/B-U585I-IOT02A/.cproject

@@ -0,0 +1,31 @@
+/**
+******************************************************************************
+* @file : esp32.h
+* @version : v 1.0.0
+* @brief : This file implements esp32 mini driver header
+*/
+#include "main.h"
+
+#ifndef ESP32_H_
+#define ESP32_H_
+
+#define ESP32_BOOT_DELAY 3000
+#define ESP32_COMMAND_TIMEOUT 3000
+
+
+char* esp32_reset (void);
+char* esp32_mode (void);
+char* esp32_setwifi (char*, char*);
+char* esp32_sntp (char* sntp_server);
+char* esp32_mqtt_cfg (void);
+char* esp32_mqtt_username (char* mqtt_username);
+char* esp32_mqtt_password (void);
+char* esp32_mqtt_client_id (char* mqtt_client_id);
+char* esp32_mqtt_connect (char* mqtt_host);
+char* esp32_at (void);
+char* esp32_mqtt_clean (void);
+char* esp32_mqtt_conn (void);
+char* esp32_mqtt_pub (char* topic, char* data);
+char* esp32_mqtt_pub_raw (char* topic, uint8_t length);
+char* esp32_mqtt_send_raw_data (char* data);
+#endif /* ESP32_H_ */

Projects/PubSub/B-U585I-IOT02A/Inc/esp32.h

@@ -0,0 +1,87 @@
+/* USER CODE BEGIN Header */
+/**
+ ******************************************************************************
+ * @file : main.h
+ * @brief : Header for main.c file.
+ * This file contains the common defines of the application.
+ ******************************************************************************
+ * @attention
+ *
+ * Copyright (c) 2023 STMicroelectronics.
+ * All rights reserved.
+ *
+ * This software is licensed under terms that can be found in the LICENSE file
+ * in the root directory of this software component.
+ * If no LICENSE file comes with this software, it is provided AS-IS.
+ *
+ ******************************************************************************
+ */
+/* USER CODE END Header */
+
+/* Define to prevent recursive inclusion -------------------------------------*/
+#ifndef __MAIN_H
+#define __MAIN_H
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+/* Includes ------------------------------------------------------------------*/
+#include "stm32u5xx_hal.h"
+#include "stm32u5xx_ll_icache.h"
+#include "stm32u5xx_ll_pwr.h"
+#include "stm32u5xx_ll_crs.h"
+#include "stm32u5xx_ll_rcc.h"
+#include "stm32u5xx_ll_bus.h"
+#include "stm32u5xx_ll_system.h"
+#include "stm32u5xx_ll_exti.h"
+#include "stm32u5xx_ll_cortex.h"
+#include "stm32u5xx_ll_utils.h"
+#include "stm32u5xx_ll_dma.h"
+#include "stm32u5xx_ll_gpio.h"
+#include "stm32u5xx_ll_lpgpio.h"
+
+/* Private includes ----------------------------------------------------------*/
+/* USER CODE BEGIN Includes */
+
+/* USER CODE END Includes */
+
+/* Exported types ------------------------------------------------------------*/
+/* USER CODE BEGIN ET */
+
+/* USER CODE END ET */
+
+/* Exported constants --------------------------------------------------------*/
+/* USER CODE BEGIN EC */
+
+/* USER CODE END EC */
+
+/* Exported macro ------------------------------------------------------------*/
+/* USER CODE BEGIN EM */
+
+/* USER CODE END EM */
+
+/* Exported functions prototypes ---------------------------------------------*/
+void Error_Handler(void);
+
+/* USER CODE BEGIN EFP */
+
+/* USER CODE END EFP */
+
+/* Private defines -----------------------------------------------------------*/
+#define ExpressLink_EVENT_Pin LL_GPIO_PIN_15
+#define ExpressLink_EVENT_GPIO_Port GPIOD
+#define LD2_Pin LL_GPIO_PIN_13
+#define LD2_GPIO_Port GPIOE
+
+#define ESP32_USART_HANDLER huart3
+
+/* USER CODE BEGIN Private defines */
+
+/* USER CODE END Private defines */
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif /* __MAIN_H */

Projects/PubSub/B-U585I-IOT02A/Inc/main.h

@@ -0,0 +1,205 @@
+/**
+ ******************************************************************************
+ * @file : ExpressLink.c
+ * @version : v 1.0.0
+ * @brief : This file implements AWS ExpressLink driver
+ ******************************************************************************
+ * @attention
+ *
+ * <h2><center>&copy; Copyright (c) 2019 STMicroelectronics.
+ * All rights reserved.</center></h2>
+ *
+ * This software component is licensed by ST under BSD 3-Clause license,
+ * the "License"; You may not use this file except in compliance with the
+ * ththe "License"; You may not use this file except in compliance with the
+ * opensource.org/licenses/BSD-3-Clause
+ *
+ ******************************************************************************
+ */
+#include "main.h"
+#include "esp32.h"
+
+#include <stdio.h>
+#include <string.h>
+#include <stdlib.h>
+#include <ctype.h>
+
+#define ESP32_TX_BUFFER_SIZE 256
+#define ESP32_RX_BUFFER_SIZE 256
+
+/*---------- ESP32_USART_HANDLER -----------*/
+extern UART_HandleTypeDef ESP32_USART_HANDLER;
+
+/*---------- ESP32_DEBUG -----------*/
+#define ESP32_DEBUG 1
+
+
+
+static char command[ESP32_TX_BUFFER_SIZE] = { 0 };
+static char response[ESP32_RX_BUFFER_SIZE] = { 0 };
+
+
+/******************************************************************************/
+/**
+ * @brief Send a command to the module
+ * @retval The ExpressLink Module response
+ */
+static char* esp32_execute_command(char *command, unsigned long timeout_ms)
+{
+ int i = 0;
+ int command_flag = 0;
+ int command_size = strlen(command);
+ if (command_size > 255) {
+ printf("AT COMMAND is over size!\r\n");
+ return response;
+ }
+
+ if ((strcmp(command, "AT+RST\r\n") == 0)) {
+ command_flag = 1; //RST command
+ }
+ else if ((strncmp(command, "AT+CIPSNTPCFG", 13) == 0)) {
+ command_flag = 2; //SNTP command
+ }
+ else if ((strncmp(command, "AT+MQTTPUBRAW", 13) == 0)) {
+ command_flag = 3;
+ }
+
+ HAL_StatusTypeDef USART_STATUS = HAL_OK;
+
+ //flush UART
+ while (HAL_TIMEOUT != HAL_UART_Receive(&ESP32_USART_HANDLER, (uint8_t* )&response[0], ESP32_TX_BUFFER_SIZE, 50)) {
+ //do nothing
+ }
+
+ memset(response, 0, ESP32_RX_BUFFER_SIZE);
+
+#if 0
+ printf("%s", command);
+#endif
+
+ HAL_UART_Transmit(&ESP32_USART_HANDLER, (uint8_t* )command, command_size, timeout_ms);
+
+if (!command_flag) { //command flag is 0
+ do
+ {
+ USART_STATUS = HAL_UART_Receive(&ESP32_USART_HANDLER, (uint8_t* )&response[i], 1, timeout_ms);
+ i++;
+
+ if (i > 3) {
+ if ((response[i - 1] == '\n') && (response[i - 2] == '\r') && (response[i - 3] == 'K') && (response[i - 4] == 'O')) {
+ break; //\r\nOK\r\n
+ }
+ else if ((response[i - 1] == '\n') && (response[i - 2] == '\r') && (response[i - 3] == 'R') && (response[i - 4] == 'O')) {
+ break; //\r\nERROR\r\n
+ }
+ }
+ } while ((USART_STATUS != HAL_TIMEOUT));
+}
+else { //command_flag is 1 or 2 or 3
+ do
+ {
+ USART_STATUS = HAL_UART_Receive(&ESP32_USART_HANDLER, (uint8_t* )&response[i], 1, timeout_ms);
+ i++;
+
+ if (i > 3) {
+ if ((response[i - 1] == '\n') && (response[i - 2] == '\r') && (response[i - 3] == 'P') && (response[i - 4] == 'I')) {
+ if (command_flag == 1) {
+ //printf("i is %d and GOT IP\r\n", i);
+ break;
+	}
+ }
+ else if ((response[i - 1] == '\n') && (response[i - 2] == '\r') && (response[i - 3] == 'D') && (response[i - 4] == 'E')) {
+ if (command_flag == 2) {
+ //printf("i is %d and UPDATED\r\n", i);
+ break;
+	}
+ }
+ else if ((response[i - 1] == '>') && (response[i - 2] == '\n') && (response[i - 3] == '\r')) {
+ if (command_flag == 3) {
+ //printf("i is %d and >>>>>\r\n", i);
+ break;
+	}
+ }
+ }
+ } while ((USART_STATUS != HAL_TIMEOUT));
+}
+ if(USART_STATUS == HAL_TIMEOUT)
+ {
+ memset (response, 0, ESP32_RX_BUFFER_SIZE);
+ snprintf(response, ESP32_TX_BUFFER_SIZE, "ERROR\r\n");
+ }
+
+#if (ESP32_DEBUG)
+ printf("%s", response);
+#endif
+ return response;
+}
+
+
+//----------ESP32--------------
+char* esp32_at(void) {
+ return esp32_execute_command("AT\r\n", ESP32_COMMAND_TIMEOUT);
+}
+char* esp32_reset(void) {
+ return esp32_execute_command("AT+RST\r\n", 20000);
+}
+
+char* esp32_mode(void) {
+ return esp32_execute_command("AT+CWMODE=1\r\n", ESP32_COMMAND_TIMEOUT);
+}
+
+char* esp32_setwifi(char* ssid, char* pw) {
+ snprintf(command, ESP32_TX_BUFFER_SIZE, "AT+CWJAP=\"%s\",\"%s\"\r\n", ssid, pw);
+ return esp32_execute_command(command, 5 * ESP32_COMMAND_TIMEOUT);
+}
+
+char* esp32_sntp(char* sntp_server) {
+ snprintf(command, ESP32_TX_BUFFER_SIZE, "AT+CIPSNTPCFG=1,-6,\"%s\"\r\n", sntp_server);
+ esp32_execute_command(command, 20000);
+ return esp32_execute_command("AT+CIPSNTPTIME?\r\n", ESP32_COMMAND_TIMEOUT);
+}
+
+char* esp32_mqtt_cfg(void) {
+ return esp32_execute_command("AT+MQTTUSERCFG=0,5,\"\",\"\",\"\",0,0,\"\"\r\n", ESP32_COMMAND_TIMEOUT);
+}
+
+char* esp32_mqtt_username(char* mqtt_username) {
+ snprintf(command, ESP32_TX_BUFFER_SIZE, "AT+MQTTUSERNAME=0,\"%s\"\r\n", mqtt_username);
+ return esp32_execute_command(command, ESP32_COMMAND_TIMEOUT);
+}
+
+char* esp32_mqtt_password(void) {
+ return esp32_execute_command("AT+MQTTPASSWORD=0,\"\"\r\n", ESP32_COMMAND_TIMEOUT);
+}
+
+char* esp32_mqtt_client_id(char* mqtt_client_id) {
+ snprintf(command, ESP32_TX_BUFFER_SIZE, "AT+MQTTCLIENTID=0,\"%s\"\r\n", mqtt_client_id);
+ return esp32_execute_command(command, ESP32_COMMAND_TIMEOUT);
+}
+
+char* esp32_mqtt_connect(char* mqtt_host) {
+ snprintf(command, ESP32_TX_BUFFER_SIZE, "AT+MQTTCONN=0,\"%s\",8883,1\r\n", mqtt_host);
+ return esp32_execute_command(command, 10 * ESP32_COMMAND_TIMEOUT);
+}
+
+char* esp32_mqtt_clean(void) {
+return esp32_execute_command("AT+MQTTCLEAN=0\r\n", 3 * ESP32_COMMAND_TIMEOUT);
+}
+
+char* esp32_mqtt_conn(void) {
+return esp32_execute_command("AT+MQTTCONN?\r\n", 3 * ESP32_COMMAND_TIMEOUT);
+}
+
+char* esp32_mqtt_pub(char* topic, char* data) {
+ snprintf(command, ESP32_TX_BUFFER_SIZE, "AT+MQTTPUB=0,\"%s\",\"%s\",1,0\r\n", topic, data);
+ return esp32_execute_command(command, 5 * ESP32_COMMAND_TIMEOUT);
+}
+
+char* esp32_mqtt_pub_raw(char* topic, uint8_t length) {
+ snprintf(command, ESP32_TX_BUFFER_SIZE, "AT+MQTTPUBRAW=0,\"%s\",%d,1,0\r\n", topic, length);
+ return esp32_execute_command(command, 2 * ESP32_COMMAND_TIMEOUT);
+}
+char* esp32_mqtt_send_raw_data(char* data) {
+ strcpy(command, data);
+ return esp32_execute_command(command, 4 * ESP32_COMMAND_TIMEOUT);
+}