move to new skeleton

tutorials/webui/webui-push-ws/Makefile

@@ -0,0 +1,25 @@
+PROG ?= example                   # Program we are building
+DELETE = rm -rf                   # Command to remove files
+OUT ?= -o $(PROG)                 # Compiler argument for output file
+SOURCES = main.c mongoose.c       # Source code files
+CFLAGS = -W -Wall -Wextra -g -I.  # Build options
+
+# Mongoose build options. See https://mongoose.ws/documentation/#build-options
+CFLAGS_MONGOOSE += -DMG_ENABLE_LINES
+
+ifeq ($(OS),Windows_NT)   # Windows settings. Assume MinGW compiler. To use VC: make CC=cl CFLAGS=/MD OUT=/Feprog.exe
+  PROG ?= example.exe           # Use .exe suffix for the binary
+  CC = gcc                      # Use MinGW gcc compiler
+  CFLAGS += -lws2_32            # Link against Winsock library
+  DELETE = cmd /C del /Q /F /S  # Command prompt command to delete files
+  OUT ?= -o $(PROG)             # Build output
+endif
+
+all: $(PROG)              # Default target. Build and run program
+	$(RUN) ./$(PROG) $(ARGS)
+
+$(PROG): $(SOURCES)       # Build program from sources
+	$(CC) $(SOURCES) $(CFLAGS) $(CFLAGS_MONGOOSE) $(CFLAGS_EXTRA) $(OUT)
+
+clean:                    # Cleanup. Delete built program and all build artifacts
+	$(DELETE) $(PROG) *.o *.obj *.exe *.dSYM

tutorials/webui/webui-push-ws/README.md

@@ -0,0 +1 @@
+See detailed tutorial at https://mongoose.ws/tutorials/webui/webui-push/

tutorials/webui/webui-push-ws/main.c

@@ -0,0 +1,53 @@
+// Copyright (c) 2020 Cesanta Software Limited
+// All rights reserved
+//
+// Example Websocket server with timers. This is a simple Websocket echo
+// server, which sends a message to all connected clients periodically,
+// using timer API.
+
+#include "mongoose.h"
+
+static const char *s_listen_on = "http://localhost:8000";
+static const char *s_web_root = "web_root";
+
+static void fn(struct mg_connection *c, int ev, void *ev_data) {
+  if (ev == MG_EV_HTTP_MSG) {
+    struct mg_http_message *hm = (struct mg_http_message *) ev_data;
+    if (mg_match(hm->uri, mg_str("/api/watch"), NULL)) {
+      mg_ws_upgrade(c, hm, NULL);  // Upgrade HTTP to Websocket
+      c->data[0] = 'W';            // Set some unique mark on the connection
+    } else {
+      struct mg_http_serve_opts opts = {.root_dir = s_web_root};
+      mg_http_serve_dir(c, ev_data, &opts);
+    }
+  }
+}
+
+// Push to all watchers
+static void push(struct mg_mgr *mgr, const char *name, const void *data) {
+  struct mg_connection *c;
+  for (c = mgr->conns; c != NULL; c = c->next) {
+    if (c->data[0] != 'W') continue;
+    mg_ws_printf(c, WEBSOCKET_OP_TEXT, "{%m:%m,%m:%m}", MG_ESC("name"),
+                 MG_ESC(name), MG_ESC("data"), MG_ESC(data));
+  }
+}
+
+static void timer_fn(void *arg) {
+  struct mg_mgr *mgr = (struct mg_mgr *) arg;
+  char buf[50];
+  mg_snprintf(buf, sizeof(buf), "[%lu, %d]", (unsigned long) time(NULL),
+              10 + (int) ((double) rand() * 10 / RAND_MAX));
+  push(mgr, "metrics", buf);
+}
+
+int main(void) {
+  struct mg_mgr mgr;        // Event manager
+  mg_mgr_init(&mgr);        // Initialise event manager
+  mg_log_set(MG_LL_DEBUG);  // Set log level
+  mg_timer_add(&mgr, 2000, MG_TIMER_REPEAT, timer_fn, &mgr);
+  mg_http_listen(&mgr, s_listen_on, fn, NULL);  // Create HTTP listener
+  for (;;) mg_mgr_poll(&mgr, 500);              // Infinite event loop
+  mg_mgr_free(&mgr);                            // Free manager resources
+  return 0;
+}

tutorials/webui/webui-push-ws/mongoose.c

@@ -0,0 +1 @@
+../../../mongoose.c

tutorials/webui/webui-push-ws/mongoose.h

@@ -0,0 +1 @@
+../../../mongoose.h

tutorials/webui/webui-push-ws/web_root/index.html

@@ -0,0 +1,39 @@
+<!DOCTYPE html>
+<html lang="en">
+  <body>
+    <h1>Data push over WebSocket demo</h1>
+    <div style="margin-top: 1em;">Event log:</div>
+    <div id="log" style="background: #eee; height: 10em; padding: 0.5em; overflow:auto;"></div>
+    </body>
+  <script>
+    var log = document.getElementById('log');
+
+    const watch = function() {
+    var l = window.location, proto = l.protocol.replace('http', 'ws');
+    var tid, wsURI = proto + '//' + l.host + '/api/watch'
+    var reconnect = function() {
+      var ws = new WebSocket(wsURI);
+      ws.onopen = function() { log.innerHTML += 'CONNECTED<br/>'; }
+      ws.onmessage = function(ev) {
+        console.log(ev.data);
+        try {
+          var msg = JSON.parse(ev.data);
+          log.innerHTML += 'RECEIVED: ' + JSON.stringify(msg) + '<br/>';
+        } catch (e) {
+          console.log('Invalid ws frame:', ev.data);
+        }
+      };
+      ws.onclose = function() {
+        clearTimeout(tid);
+        tid = setTimeout(reconnect, 1000);
+        log.innerHTML += 'DISCONNECTED<br/>';
+      };
+      ws.onerror = err => console.log(err);
+    };
+    reconnect();
+  };
+
+  watch();
+
+  </script>
+</html>