Project for course Appliance of MCU, School of Electrical engineering, Uni of Belgrade
Dependencies: 19E042PIM_MB_PINS Adafruit_GFX MAX44000 mbed-mqtt
main.cpp
- Committer:
- pavleradojkovic
- Date:
- 2022-07-04
- Revision:
- 4:b08e3f8e89bd
- Parent:
- 3:68c83e94576f
- Child:
- 5:e64e216e1ca6
File content as of revision 4:b08e3f8e89bd:
#include "mbed.h" #include "mb_pins.h" #include "platform/mbed_thread.h" #include "MQTTClientMbedOs.h" #include "Adafruit_GFX.h" #include "Adafruit_GFX_Config.h" #include "Adafruit_SSD1306.h" // LED2 blinking rate: #define BLINKING_RATE_MS 250 // Scaler to 3v3L #define VOLTAGE_SCALER 3.3f // Client yield timeout in miliseconds: #define YIELD_TIMEOUT_MS 1000 // Maximum number of networks to scan for: #define MAX_NETWORKS 15 // Small delay for network information printing: #define PRINTF_DELAY_MS 10 // Set OLED width and heigth [pixel]: #define OLED_WIDTH_PX 128 #define OLED_HEIGHT_PX 64 // Address of OLED display: #define I2C_ADDRESS 0x3c<<1 // Half of the potentiometer return value: #define HALF_INTERVAL 0.5f // I2C frequency: #define I2C_FREQUENCY 400000 // Global Variables //I2C I2C i2c(MB_OLED_SDA, MB_OLED_SCL); //OLED Adafruit_SSD1306_I2c myOled(i2c,PB_5,I2C_ADDRESS,OLED_HEIGHT_PX,OLED_WIDTH_PX); // Potentiometers: AnalogIn pot1(MB_POT1); AnalogIn pot2(MB_POT2); // Left button on the motherboard: InterruptIn sw1(MB_SW1); // LEFT LED on the motherboard: DigitalOut led1(MB_LED1); // Right LED on the motherboard: DigitalOut led2(MB_LED2); // Pointer to a WiFi network object: WiFiInterface *wifi; // Creating TCP socket: - not in use TCPSocket socket; // Creating TLS socket: TLSSocket tlsSocket; // Creating MQTT client using the TCP socket; MQTTClient client(&socket); // Message handler: MQTT::Message message; //Topics char* topic = "test/Pavle/Pot1"; char* topic_sub = "test/Olja/Pot1"; char* topic_sub_notifications = "agriculture/display"; // Counter of arrived messages: int arrivedcount = 0; // Flag indicating that button is not pressed: int button_pressed = 0; // HiveMQ broker connectivity information: const char* hostname = "broker.hivemq.com"; int port = 1883; // Returning a string for a provided network encryption: //Global Functions const char *sec2str(nsapi_security_t sec); int scan_networks(WiFiInterface *wifi); void messageArrived(MQTT::MessageData& md); void buttonFunction(); int main() { //Turn off left led led1 = 0; // Set the interrupt event: sw1.fall(&buttonFunction); // Initialize OLED: myOled.begin(); int x, y = 0; // Create a default network interface: wifi = WiFiInterface::get_default_instance(); if (!wifi) { printf("ERROR: No WiFiInterface found.\n"); return -1; } // Scan for available networks and aquire information about Access Points: int count = scan_networks(wifi); if (count == 0) { printf("No WIFI APs found - can't continue further.\n"); return -1; } // Connect to the network with the parameters specified in 'mbed_app.json': printf("\nConnecting to %s...\n", MBED_CONF_APP_WIFI_SSID); int ret = wifi->connect(MBED_CONF_APP_WIFI_SSID, MBED_CONF_APP_WIFI_PASSWORD, NSAPI_SECURITY_WPA_WPA2); if (ret != 0) { printf("\nConnection error: %d\n", ret); return -1; } // Print out the information aquired: printf("Success\n\n"); printf("MAC: %s\n", wifi->get_mac_address()); printf("IP: %s\n", wifi->get_ip_address()); printf("Netmask: %s\n", wifi->get_netmask()); printf("Gateway: %s\n", wifi->get_gateway()); printf("RSSI: %d\n\n", wifi->get_rssi()); // Open TCP socket using WiFi network interface: socket.open(wifi); // Connect to the HiveMQ broker: socket.connect(hostname, port); // Fill connect data with default values: MQTTPacket_connectData data = MQTTPacket_connectData_initializer; // Change only ID and protocol version: data.MQTTVersion = 3; data.clientID.cstring = "NUCLEO-L476RG-64"; // Connect the int rc = 0; if ((rc = client.connect(data)) != 0) printf("rc from MQTT connect is %d\n", rc); if ((rc = client.subscribe(topic_sub, MQTT::QOS0, messageArrived)) != 0) printf("rc from MQTT subscribe is %d\n", rc); while (true) { // Show that the loop is running by switching motherboard LED2: led2 = !led2; if (button_pressed==1) { button_pressed=0; // QoS 0 char buf[100]; sprintf(buf, "V(POT1) = %1.2f\r\n", pot1*VOLTAGE_SCALER); message.qos = MQTT::QOS0; message.retained = false; message.dup = false; message.payload = (void*)buf; message.payloadlen = strlen(buf)+1; client.publish(topic, message); } // Need to call yield API to maintain connection: client.yield(YIELD_TIMEOUT_MS); // text display tests myOled.setTextSize(2); myOled.setTextColor(WHITE); myOled.setTextCursor(0,0); myOled.printf("Hello, Olja!"); myOled.display(); thread_sleep_for(BLINKING_RATE_MS); myOled.clearDisplay(); } } const char *sec2str(nsapi_security_t sec) { switch (sec) { case NSAPI_SECURITY_NONE: return "None"; case NSAPI_SECURITY_WEP: return "WEP"; case NSAPI_SECURITY_WPA: return "WPA"; case NSAPI_SECURITY_WPA2: return "WPA2"; case NSAPI_SECURITY_WPA_WPA2: return "WPA/WPA2"; case NSAPI_SECURITY_UNKNOWN: default: return "Unknown"; } } int scan_networks(WiFiInterface *wifi) { printf("Scan:\n"); // Scan only for the number of networks, first parameter is NULL: int count = wifi->scan(NULL, 0); // If there are no networks, count == 0, if there is an error, counter < 0: if (count <= 0) { printf("scan() failed with return value: %d\n", count); return 0; } // Limit number of network arbitrary to some reasonable number: count = count < MAX_NETWORKS ? count : MAX_NETWORKS; // Create a local pointer to an object, which is an array of WiFi APs: WiFiAccessPoint *ap = new WiFiAccessPoint[count]; // Now scan again for 'count' networks and populate the array of APs: count = wifi->scan(ap, count); // This time, the number of entries to 'ap' is returned: if (count <= 0) { printf("scan() failed with return value: %d\n", count); return 0; } // Print out the parameters of each AP: for (int i = 0; i < count; i++) { printf("Network: %s secured: %s BSSID: %hhX:%hhX:%hhX:%hhx:%hhx:%hhx RSSI: %hhd Ch: %hhd\n", ap[i].get_ssid(), sec2str(ap[i].get_security()), ap[i].get_bssid()[0], ap[i].get_bssid()[1], ap[i].get_bssid()[2], ap[i].get_bssid()[3], ap[i].get_bssid()[4], ap[i].get_bssid()[5], ap[i].get_rssi(), ap[i].get_channel()); thread_sleep_for(PRINTF_DELAY_MS); } printf("%d networks available.\n", count); // Since 'ap' is dynamically allocated pointer to the array of objects, it // needs to be deleted: delete[] ap; return count; } void messageArrived(MQTT::MessageData& md) { MQTT::Message &message = md.message; //printf("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n", message.qos, message.retained, message.dup, message.id); printf("Message from the browser: %.*s\r\n", message.payloadlen, (char*)message.payload); ++arrivedcount; } void buttonFunction() { button_pressed=1; }