Filip Babic 2020/0511
Dependencies: Adafruit_GFX 19E042PIM_MB_PINS
Diff: main.cpp
- Revision:
- 0:82908a60b720
- Child:
- 2:bcdecb244887
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/main.cpp Fri Dec 10 18:13:38 2021 +0000 @@ -0,0 +1,84 @@ +#include "mb_pins.h" +#include "mbed.h" +#include "platform/mbed_thread.h" +#include "MQTTClientMbedOs.h" + +#include "Adafruit_GFX.h" +#include "Adafruit_GFX_Config.h" +#include "Adafruit_SSD1306.h" + +/////////////////////////////////////////////////////////////// + +#define SMALL_WAIT_MS 10 + +//I2C adress +#define I2C_ADDRESS 0x3c +#define I2C_ADD_MBED I2C_ADDRESS << 1 + +//OLED DIMENSIONS +#define OLED_HEIGHT_PX 64 +#define OLED_WIDTH_PX 128 + +/////////////////////////////////////////////////////////////// + +TCPSocket socket; +MQTTClient client(&socket); +MQTT::Message message; +WiFiInterface *wifi; + +I2C i2c_obj(MB_OLED_SDA, MB_OLED_SCL); +Adafruit_SSD1306_I2c myOLED(i2c_obj, PB_5, I2C_ADD_MBED, OLED_HEIGHT_PX, OLED_WIDTH_PX); + +char* topic_sub = "mbed-sample-sub"; +const char* hostname = "broker.hivemq.com"; +int port = 1883; + +/////////////////////////////////////////////////////////////// + +void messageArrived(MQTT::MessageData& md) +{ + MQTT::Message &message = md.message; + printf("Browser message: %.*s \n", message.payloadlen, (char*)message.payload); + + myOLED.clearDisplay(); + //myOLED.setTextCursor(0, 0); + myOLED.printf("%.*s \r", message.payloadlen, (char*)message.payload); + myOLED.display(); +} + +/////////////////////////////////////////////////////////////// + +int main() +{ + wifi = WiFiInterface::get_default_instance(); + + printf("Connecting 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("Greska u povezivanju"); + return -1; + } + printf("Success\n"); + + socket.open(wifi); + socket.connect(hostname,port); + + MQTTPacket_connectData data = MQTTPacket_connectData_initializer; + data.MQTTVersion = 3; + data.clientID.cstring = "Mustafa"; + + client.connect(data); + client.subscribe(topic_sub, MQTT::QOS0, messageArrived); + + myOLED.begin(); //pocetak + i2c_obj.frequency(400000); //veca frekvencija slanja da ne bi ghostovalo + + myOLED.clearDisplay(); + myOLED.display(); + + + while(1) { + thread_sleep_for(SMALL_WAIT_MS); + client.yield(1000); + } +}