From 4f13d637e666058c89aae6afb4ec1578e6c92ce8 Mon Sep 17 00:00:00 2001
From: Adam Dunkels <adam@thingsquare.com>
Date: Mon, 31 Oct 2016 22:07:01 +0100
Subject: [PATCH] Example code for the Contiki websocket client

---
 examples/websockets/Makefile            |  6 +++
 examples/websockets/websocket-example.c | 63 +++++++++++++++++++++++++
 2 files changed, 69 insertions(+)
 create mode 100644 examples/websockets/Makefile
 create mode 100644 examples/websockets/websocket-example.c

diff --git a/examples/websockets/Makefile b/examples/websockets/Makefile
new file mode 100644
index 000000000..49d706070
--- /dev/null
+++ b/examples/websockets/Makefile
@@ -0,0 +1,6 @@
+all: websocket-example
+CONTIKI=../..
+
+include $(CONTIKI)/Makefile.include
+
+
diff --git a/examples/websockets/websocket-example.c b/examples/websockets/websocket-example.c
new file mode 100644
index 000000000..7214deb39
--- /dev/null
+++ b/examples/websockets/websocket-example.c
@@ -0,0 +1,63 @@
+#include "contiki.h"
+
+#include "websocket.h"
+
+#include <stdio.h>
+
+static struct websocket s;
+
+static void callback(struct websocket *s, websocket_result_t r,
+                     const uint8_t *data, uint16_t datalen);
+
+#define RECONNECT_INTERVAL 10 * CLOCK_SECOND
+static struct ctimer reconnect_timer;
+
+/*---------------------------------------------------------------------------*/
+PROCESS(websocket_example_process, "Websocket Example");
+AUTOSTART_PROCESSES(&websocket_example_process);
+/*---------------------------------------------------------------------------*/
+static void
+reconnect_callback(void *ptr)
+{
+  websocket_open(&s, "ws://172.16.0.1:8080/",
+                 "contiki", NULL, callback);
+}
+/*---------------------------------------------------------------------------*/
+static void
+callback(struct websocket *s, websocket_result_t r,
+         const uint8_t *data, uint16_t datalen)
+{
+  if(r == WEBSOCKET_CLOSED ||
+     r == WEBSOCKET_RESET ||
+     r == WEBSOCKET_HOSTNAME_NOT_FOUND ||
+     r == WEBSOCKET_TIMEDOUT) {
+    ctimer_set(&reconnect_timer, RECONNECT_INTERVAL, reconnect_callback, s);
+  } else if(r == WEBSOCKET_CONNECTED) {
+    websocket_send_str(s, "Connected");
+  } else if(r == WEBSOCKET_DATA) {
+    printf("websocket-example: Received data '%.*s' (len %d)\n", datalen,
+           data, datalen);
+  }
+}
+/*---------------------------------------------------------------------------*/
+PROCESS_THREAD(websocket_example_process, ev, data)
+{
+  static struct etimer et;
+  PROCESS_BEGIN();
+
+  ctimer_set(&reconnect_timer, RECONNECT_INTERVAL, reconnect_callback, &s);
+
+  websocket_init(&s);
+  while(1) {
+    etimer_set(&et, CLOCK_SECOND / 8);
+    PROCESS_WAIT_EVENT_UNTIL(etimer_expired(&et));
+    char buf[] = "012345678";
+    static int count;
+    buf[0] = (count % 9) + '0';
+    count++;
+    websocket_send_str(&s, buf);
+  }
+
+  PROCESS_END();
+}
+/*---------------------------------------------------------------------------*/