This repository has been archived by the owner on Jan 29, 2023. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 22
/
Copy pathWebSocketClient_ENC.ino
175 lines (137 loc) · 4.47 KB
/
WebSocketClient_ENC.ino
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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
/****************************************************************************************************************************
WebSocketClient_ENC.ino
For boards using ENC28J60 Shield/Module
Based on and modified from WebSockets libarary https://github.com/Links2004/arduinoWebSockets
to support other boards such as SAMD21, SAMD51, Adafruit's nRF52 boards, etc.
Built by Khoi Hoang https://github.com/khoih-prog/WebSockets_Generic
Licensed under MIT license
Created on: 24.05.2015
Author: Markus Sattler
*****************************************************************************************************************************/
#if ( defined(ARDUINO_SAM_DUE) || defined(__SAM3X8E__) )
// Default pin 10 to SS/CS
#define USE_THIS_SS_PIN 10
#define BOARD_TYPE "SAM DUE"
#elif ( defined(CORE_TEENSY) )
#error You have to use examples written for Teensy
#endif
#ifndef BOARD_NAME
#define BOARD_NAME BOARD_TYPE
#endif
#define _WEBSOCKETS_LOGLEVEL_ 2
#define WEBSOCKETS_NETWORK_TYPE NETWORK_ETHERNET_ENC
#define SHIELD_TYPE "ENC28J60 using EthernetENC Library"
#include <WebSocketsClient_Generic.h>
WebSocketsClient webSocket;
uint8_t mac[6] = { 0xDE, 0xAD, 0xBE, 0xEF, 0xBE, 0x08 };
// SSL not working here yet.
#define USE_SSL false
#if USE_SSL
// Deprecated echo.websocket.org to be replaced
#define WS_SERVER "wss://echo.websocket.org"
#define WS_PORT 443
#else
// To run a local WebSocket Server
#define WS_SERVER "192.168.2.30"
#define WS_PORT 8080
#endif
void webSocketEvent(const WStype_t& type, uint8_t * payload, const size_t& length)
{
switch (type)
{
case WStype_DISCONNECTED:
Serial.println("[WSc] Disconnected!");
break;
case WStype_CONNECTED:
{
Serial.print("[WSc] Connected to url: ");
Serial.println((char *) payload);
// send message to server when Connected
webSocket.sendTXT("Connected");
}
break;
case WStype_TEXT:
Serial.print("[WSc] get text: ");
Serial.println((char *) payload);
// send message to server
// webSocket.sendTXT("message here");
break;
case WStype_BIN:
Serial.print("[WSc] get binary length: ");
Serial.println(length);
// KH, To check
// hexdump(payload, length);
// send data to server
webSocket.sendBIN(payload, length);
break;
case WStype_PING:
// pong will be send automatically
Serial.printf("[WSc] get ping\n");
break;
case WStype_PONG:
// answer to a ping we send
Serial.printf("[WSc] get pong\n");
break;
case WStype_ERROR:
case WStype_FRAGMENT_TEXT_START:
case WStype_FRAGMENT_BIN_START:
case WStype_FRAGMENT:
case WStype_FRAGMENT_FIN:
break;
default:
break;
}
}
void setup()
{
//Initialize serial and wait for port to open:
Serial.begin(115200);
while (!Serial);
Serial.print("\nStart WebSocketClient_ENC on " + String(BOARD_NAME));
Serial.print(" with ");
Serial.println(SHIELD_TYPE);
Serial.println(WEBSOCKETS_GENERIC_VERSION);
Serial.println("Used/default SPI pinout:");
Serial.print("MOSI:");
Serial.println(MOSI);
Serial.print("MISO:");
Serial.println(MISO);
Serial.print("SCK:");
Serial.println(SCK);
Serial.print("SS:");
Serial.println(SS);
// start the ethernet connection and the server:
// Use Static IP
//Ethernet.begin(mac, clientIP);
//Configure IP address via DHCP
Ethernet.begin(mac);
Serial.print("WebSockets Client IP address: ");
Serial.println(Ethernet.localIP());
// server address, port and URL
Serial.print("Connecting to WebSockets Server @ ");
Serial.println(WS_SERVER);
// server address, port and URL
#if USE_SSL
webSocket.beginSSL(WS_SERVER, WS_PORT);
#else
webSocket.begin(WS_SERVER, WS_PORT, "/");
#endif
// event handler
webSocket.onEvent(webSocketEvent);
// use HTTP Basic Authorization this is optional remove if not needed
//webSocket.setAuthorization("user", "Password");
// try ever 5000 again if connection has failed
webSocket.setReconnectInterval(5000);
// start heartbeat (optional)
// ping server every 15000 ms
// expect pong from server within 3000 ms
// consider connection disconnected if pong is not received 2 times
webSocket.enableHeartbeat(15000, 3000, 2);
// server address, port and URL
Serial.print("Connected to WebSockets Server @ ");
Serial.println(WS_SERVER);
}
void loop()
{
webSocket.loop();
}