123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128 |
- #include <Arduino.h>
- #include <ESP8266WiFi.h>
- #include <ESP8266WiFiMulti.h>
- #include <ArduinoJson.h>
- #include <WebSocketsClient.h>
- #include <SocketIOclient.h>
- #include <Hash.h>
- ESP8266WiFiMulti WiFiMulti;
- SocketIOclient socketIO;
- #define USE_SERIAL Serial1
- void socketIOEvent(socketIOmessageType_t type, uint8_t * payload, size_t length) {
- switch(type) {
- case sIOtype_DISCONNECT:
- USE_SERIAL.printf("[IOc] Disconnected!\n");
- break;
- case sIOtype_CONNECT:
- USE_SERIAL.printf("[IOc] Connected to url: %s\n", payload);
-
- socketIO.send(sIOtype_CONNECT, "/");
- break;
- case sIOtype_EVENT:
- USE_SERIAL.printf("[IOc] get event: %s\n", payload);
- break;
- case sIOtype_ACK:
- USE_SERIAL.printf("[IOc] get ack: %u\n", length);
- hexdump(payload, length);
- break;
- case sIOtype_ERROR:
- USE_SERIAL.printf("[IOc] get error: %u\n", length);
- hexdump(payload, length);
- break;
- case sIOtype_BINARY_EVENT:
- USE_SERIAL.printf("[IOc] get binary: %u\n", length);
- hexdump(payload, length);
- break;
- case sIOtype_BINARY_ACK:
- USE_SERIAL.printf("[IOc] get binary ack: %u\n", length);
- hexdump(payload, length);
- break;
- }
- }
- void setup() {
-
- USE_SERIAL.begin(115200);
-
- USE_SERIAL.setDebugOutput(true);
- USE_SERIAL.println();
- USE_SERIAL.println();
- USE_SERIAL.println();
- for(uint8_t t = 4; t > 0; t--) {
- USE_SERIAL.printf("[SETUP] BOOT WAIT %d...\n", t);
- USE_SERIAL.flush();
- delay(1000);
- }
-
- if(WiFi.getMode() & WIFI_AP) {
- WiFi.softAPdisconnect(true);
- }
- WiFiMulti.addAP("SSID", "passpasspass");
-
- while(WiFiMulti.run() != WL_CONNECTED) {
- delay(100);
- }
- String ip = WiFi.localIP().toString();
- USE_SERIAL.printf("[SETUP] WiFi Connected %s\n", ip.c_str());
-
- socketIO.begin("10.11.100.100", 8880, "/socket.io/?EIO=4");
-
- socketIO.onEvent(socketIOEvent);
- }
- unsigned long messageTimestamp = 0;
- void loop() {
- socketIO.loop();
- uint64_t now = millis();
- if(now - messageTimestamp > 2000) {
- messageTimestamp = now;
-
- DynamicJsonDocument doc(1024);
- JsonArray array = doc.to<JsonArray>();
-
-
- array.add("event_name");
-
- JsonObject param1 = array.createNestedObject();
- param1["now"] = (uint32_t) now;
-
- String output;
- serializeJson(doc, output);
-
- socketIO.sendEVENT(output);
-
- USE_SERIAL.println(output);
- }
- }
|