CanGateway_ESP8266/WebSockets.cpp at master · Locoduino/CanGateway_ESP8266 · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
/*
   WebSockets.cpp

*/


#include "WebSockets.h"

/****************************** Constructeur ******************************/

GW_WebSockets::GW_WebSockets(uint16_t port) {
  mPort = port;
  mInputMsg = NULL;
  ptWss = NULL;
}

/******************************** begin ********************************/

void GW_WebSockets::begin() { // Start WebSocket server
  ptWss = new WebSocketsServer(mPort);
  ptWss->begin();
  ptWss->onEvent([&](uint8_t num, WStype_t type, uint8_t * payload, size_t length) {
    switch (type) {
      case WStype_DISCONNECTED:
        DBG_OUTPUT.printf("Wifi [%u] Disconnected!\n", num);
        break;
      case WStype_CONNECTED: {
          IPAddress ip = ptWss->remoteIP(num);
          DBG_OUTPUT.printf("Wifi [%u] Connected from %d.%d.%d.%d url: %s\n", num, ip[0], ip[1], ip[2], ip[3], payload);
          ptWss->sendTXT(num, "Connected");
        }
        break;
      case WStype_TEXT:
        DBG_OUTPUT.printf("Wifi [%u] get Text: %s\n", num, payload);
        mInputMsg = (char*)payload;
        mState = 0;
#ifdef LCD
        lcd.setCursor(0, 2);
        lcd.print("Message from WiFi   ");
#endif
        break;
    }
  });
  DBG_OUTPUT.printf("WebSocket started on port %d.\n", mPort);
}

/******************************** loop ********************************/

void GW_WebSockets::loop() {
  ptWss->loop();
}

/******************************** getInputMsg ********************************/

const char* GW_WebSockets::getInputMsg() {
  return mInputMsg;
}

/******************************** msgRx ********************************/

int GW_WebSockets::msgRx() {
  return mState;
}

/******************************** broadcastTXT ********************************/

bool GW_WebSockets::broadcastTXT(const char * text) {
  ptWss->broadcastTXT(text);
}