move to new skeleton

tutorials/tcp/tcp/Makefile

@@ -0,0 +1,39 @@
+PROG ?= example                   # Program we are building
+PACK ?= ./pack                    # Packing executable
+DELETE = rm -rf                   # Command to remove files
+OUT ?= -o $(PROG)                 # Compiler argument for output file
+SOURCES = main.c mongoose.c packed_fs.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_PACKED_FS=1
+
+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
+  PACK = pack.exe               # Packing executable
+  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
+  MAKE += WINDOWS=1 CC=$(CC)
+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 mbedtls $(PACK)
+
+# Generate packed filesystem for serving credentials
+packed_fs.c: $(wildcard certs/*) Makefile
+	$(CC) ../../../test/pack.c -o $(PACK)
+	$(PACK) $(wildcard certs/*) > $@
+
+# see https://mongoose.ws/tutorials/tls/#how-to-build for TLS build options
+
+mbedtls:                  # Pull and build mbedTLS library
+	git clone --depth 1 -b v2.28.2 https://github.com/mbed-tls/mbedtls $@
+	$(MAKE) -C mbedtls/library

tutorials/tcp/tcp/README.md

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

tutorials/tcp/tcp/certs/ss_ca.pem

@@ -0,0 +1 @@
+../../../../test/data/ss_ca.pem

tutorials/tcp/tcp/certs/ss_client.pem

@@ -0,0 +1 @@
+../../../../test/data/ss_client.pem

tutorials/tcp/tcp/certs/ss_server.pem

@@ -0,0 +1 @@
+../../../../test/data/ss_server.pem

tutorials/tcp/tcp/main.c

@@ -0,0 +1,105 @@
+// Copyright (c) 2022 Cesanta Software Limited
+// All rights reserved
+
+#include "mongoose.h"
+
+static const char *s_lsn = "tcp://localhost:8765";   // Listening address
+static const char *s_conn = "tcp://localhost:8765";  // Connect to address
+
+// client resources
+static struct c_res_s {
+  int i;
+  struct mg_connection *c;
+} c_res;
+
+// CLIENT event handler
+static void cfn(struct mg_connection *c, int ev, void *ev_data) {
+  int *i = &((struct c_res_s *) c->fn_data)->i;
+  if (ev == MG_EV_OPEN) {
+    MG_INFO(("CLIENT has been initialized"));
+  } else if (ev == MG_EV_CONNECT) {
+    MG_INFO(("CLIENT connected"));
+    if (mg_url_is_ssl(s_conn)) {
+      struct mg_tls_opts opts = {.ca = mg_unpacked("/certs/ss_ca.pem"),
+                                 .cert = mg_unpacked("/certs/ss_client.pem"),
+                                 .key = mg_unpacked("/certs/ss_client.pem")};
+      mg_tls_init(c, &opts);
+    }
+    *i = 1;  // do something
+  } else if (ev == MG_EV_READ) {
+    struct mg_iobuf *r = &c->recv;
+    MG_INFO(("CLIENT got data: %.*s", r->len, r->buf));
+    r->len = 0;  // Tell Mongoose we've consumed data
+  } else if (ev == MG_EV_CLOSE) {
+    MG_INFO(("CLIENT disconnected"));
+    // signal we are done
+    ((struct c_res_s *) c->fn_data)->c = NULL;
+  } else if (ev == MG_EV_ERROR) {
+    MG_INFO(("CLIENT error: %s", (char *) ev_data));
+  } else if (ev == MG_EV_POLL && *i != 0) {
+    switch ((*i)++) {
+      case 50:  // 50 x 100ms = 5s
+        mg_send(c, "Hi, there", 9);
+        MG_INFO(("CLIENT sent data"));
+        break;
+      case 100:  // another 5s
+        // send any possible outstanding data and close the connection
+        c->is_draining = 1;
+        break;
+    }
+  }
+}
+
+// SERVER event handler
+static void sfn(struct mg_connection *c, int ev, void *ev_data) {
+  if (ev == MG_EV_OPEN && c->is_listening == 1) {
+    MG_INFO(("SERVER is listening"));
+  } else if (ev == MG_EV_ACCEPT) {
+    MG_INFO(("SERVER accepted a connection"));
+    if (mg_url_is_ssl(s_lsn)) {
+      struct mg_tls_opts opts = {.ca = mg_unpacked("/certs/ss_ca.pem"),
+                                 .cert = mg_unpacked("/certs/ss_server.pem"),
+                                 .key = mg_unpacked("/certs/ss_server.pem")};
+      mg_tls_init(c, &opts);
+    }
+  } else if (ev == MG_EV_READ) {
+    struct mg_iobuf *r = &c->recv;
+    MG_INFO(("SERVER got data: %.*s", r->len, r->buf));
+    mg_send(c, r->buf, r->len);  // echo it back
+    r->len = 0;                  // Tell Mongoose we've consumed data
+  } else if (ev == MG_EV_CLOSE) {
+    MG_INFO(("SERVER disconnected"));
+  } else if (ev == MG_EV_ERROR) {
+    MG_INFO(("SERVER error: %s", (char *) ev_data));
+  }
+}
+
+// Timer function - recreate client connection if it is closed
+static void timer_fn(void *arg) {
+  struct mg_mgr *mgr = (struct mg_mgr *) arg;
+  if (c_res.c == NULL) {
+    c_res.i = 0;
+    c_res.c = mg_connect(mgr, s_conn, cfn, &c_res);
+    MG_INFO(("CLIENT %s", c_res.c ? "connecting" : "failed"));
+  }
+}
+
+int main(void) {
+  struct mg_mgr mgr;  // Event manager
+  struct mg_connection *c;
+
+  mg_log_set(MG_LL_INFO);  // Set log level
+  mg_mgr_init(&mgr);       // Initialize event manager
+
+  mg_timer_add(&mgr, 15000, MG_TIMER_REPEAT | MG_TIMER_RUN_NOW, timer_fn, &mgr);
+  c = mg_listen(&mgr, s_lsn, sfn, NULL);  // Create server connection
+  if (c == NULL) {
+    MG_INFO(("SERVER cant' open a connection"));
+    return 0;
+  }
+  while (true)
+    mg_mgr_poll(&mgr, 100);  // Infinite event loop, blocks for upto 100ms
+                             // unless there is network activity
+  mg_mgr_free(&mgr);         // Free resources
+  return 0;
+}

tutorials/tcp/tcp/mongoose.c

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

tutorials/tcp/tcp/mongoose.h

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