Merge pull request #11 from bcmi-labs/3-add-a-class-for-tcp-socket-clientserver

3 add a class for tcp socket clientserver

Author: gbr1

.gitignore

@@ -1,2 +1,4 @@
 .idea
-.vscode
+.vscode
+
+CMakeLists.txt

examples/client/client.ino

@@ -0,0 +1,52 @@
+#include <Arduino_RouterBridge.h>
+
+BridgeTCPClient<> client(Bridge);
+
+void setup() {
+
+    if (!Bridge.begin()) {
+        while (true) {}
+    }
+
+    if (!Monitor.begin()) {
+        while (true) {}
+    }
+
+}
+
+void loop() {
+
+    Monitor.println("\nStarting connection to server...");
+    /* if you get a connection, report back via serial: */
+    if (client.connect("arduino.tips", 80) < 0) {
+        Monitor.println("unable to connect to server");
+        return;
+    }
+
+    Monitor.println("connected to server");
+    /* Make an HTTP request: */
+    size_t w = client.println("GET /asciilogo.txt HTTP/1.1");
+    w += client.println("Host: arduino.tips");
+    w += client.println("User-Agent: Arduino");
+    w += client.println("Connection: close");
+    w += client.println();
+
+    /* if there are incoming bytes available from the server,
+     * read them and print them:
+     */
+    while (client.connected()) {
+        size_t len = client.available();
+        if (len) {
+            uint8_t buff[len];
+            client.read(buff, len);
+            Monitor.write(buff, len);
+        }
+        delay(0);
+    }
+
+    /* if the server's disconnected, stop the client: */
+    Monitor.println();
+    Monitor.println("disconnecting from server.");
+    client.stop();
+    delay(1000);
+}

examples/clientSSL/clientSSL.ino

@@ -0,0 +1,68 @@
+#include <Arduino_RouterBridge.h>
+
+static const char ca_cert[] = {
+"-----BEGIN CERTIFICATE-----\n"
+"MIICCTCCAY6gAwIBAgINAgPlwGjvYxqccpBQUjAKBggqhkjOPQQDAzBHMQswCQYD\n"
+"VQQGEwJVUzEiMCAGA1UEChMZR29vZ2xlIFRydXN0IFNlcnZpY2VzIExMQzEUMBIG\n"
+"A1UEAxMLR1RTIFJvb3QgUjQwHhcNMTYwNjIyMDAwMDAwWhcNMzYwNjIyMDAwMDAw\n"
+"WjBHMQswCQYDVQQGEwJVUzEiMCAGA1UEChMZR29vZ2xlIFRydXN0IFNlcnZpY2Vz\n"
+"IExMQzEUMBIGA1UEAxMLR1RTIFJvb3QgUjQwdjAQBgcqhkjOPQIBBgUrgQQAIgNi\n"
+"AATzdHOnaItgrkO4NcWBMHtLSZ37wWHO5t5GvWvVYRg1rkDdc/eJkTBa6zzuhXyi\n"
+"QHY7qca4R9gq55KRanPpsXI5nymfopjTX15YhmUPoYRlBtHci8nHc8iMai/lxKvR\n"
+"HYqjQjBAMA4GA1UdDwEB/wQEAwIBhjAPBgNVHRMBAf8EBTADAQH/MB0GA1UdDgQW\n"
+"BBSATNbrdP9JNqPV2Py1PsVq8JQdjDAKBggqhkjOPQQDAwNpADBmAjEA6ED/g94D\n"
+"9J+uHXqnLrmvT/aDHQ4thQEd0dlq7A/Cr8deVl5c1RxYIigL9zC2L7F8AjEA8GE8\n"
+"p/SgguMh1YQdc4acLa/KNJvxn7kjNuK8YAOdgLOaVsjh4rsUecrNIdSUtUlD\n"
+"-----END CERTIFICATE-----\n"
+};
+
+BridgeTCPClient<> client(Bridge);
+
+void setup() {
+
+  if (!Bridge.begin()) {
+    while (true) {}
+  }
+
+  if (!Monitor.begin()) {
+    while (true) {}
+  }
+
+}
+
+void loop() {
+  Monitor.println("\nStarting connection to server...");
+
+  /* if you get a connection, report back via monitor: */
+  if (client.connectSSL("arduino.tips", 443, ca_cert) < 0) {
+    Monitor.println("unable to connect to server");
+    return;
+  }
+
+  Monitor.println("connected to server");
+  /* Make aHTTP request: */
+  size_t w = client.println("GET /asciilogo.txt HTTP/1.1");
+  w += client.println("Host: arduino.tips");
+  w += client.println("User-Agent: Arduino");
+  w += client.println("Connection: close");
+  w += client.println();
+
+  /* if there are incoming bytes available  from the server,
+   * read them and print them:
+   */
+  while (client.connected()) {
+    size_t len = client.available();
+    if (len) {
+      uint8_t buff[len];
+      client.read(buff, len);
+      Monitor.write(buff, len);
+    }
+    delay(0);
+  }
+
+  /* if the server's disconnected, stop the client: */
+  Monitor.println();
+  Monitor.println("disconnecting from server.");
+  client.stop();
+  delay(1000);
+}

examples/server/python/main.py

@@ -0,0 +1,27 @@
+# A python sketch that uses RPC Bridge to test the server.ino
+
+import time
+from arduino.app_utils import *
+
+
+def log(msg):
+    with open("./log.log", "a") as f:
+        f.write(str(msg) + "\n")
+
+def main():
+    res = Bridge.call("tcp/connect", "127.0.0.1", 5678)
+    log(f"Connection attempt id: {res}")
+
+    written = Bridge.call("tcp/write", res, "Hello friend")
+    log(f"Written msg of len: {written}")
+
+    time.sleep(1)
+
+    ok = Bridge.call("tcp/close", res)
+    log(f"Closed connection: {ok}")
+
+if __name__ == "__main__":
+
+    while True:
+        main()
+        time.sleep(1)

examples/server/server.ino

@@ -0,0 +1,46 @@
+#include <Arduino_RouterBridge.h>
+
+IPAddress localhost(127, 0, 0, 1);
+BridgeTCPServer<> server(Bridge, localhost, 5678);
+
+void setup() {
+
+    if (!Bridge.begin()) {
+        while (true) {}
+    }
+
+    if (!Monitor.begin()) {
+        while (true) {}
+    }
+
+    server.begin();
+
+}
+
+void loop() {
+
+    BridgeTCPClient<> client = server.accept();
+
+    if (client.connected() == 1){
+        Monitor.print("client ");
+        Monitor.print(client.getId());
+        Monitor.println(" connected");
+    }
+
+    if (client) {
+        Monitor.println("A client established a connection");
+    }
+
+    while (client.connected()) {
+        size_t len = client.available();
+        if (len) {
+            Monitor.println("Message received from client");
+            uint8_t buff[len];
+            client.read(buff, len);
+            Monitor.write(buff, len);
+        }
+    }
+
+    server.disconnect();    // Disconnects the client server-side
+
+}

src/Arduino_RouterBridge.h

@@ -15,5 +15,7 @@
 #include "Arduino.h"
 #include "bridge.h"
 #include "monitor.h"
+#include "tcp_client.h"
+#include "tcp_server.h"
 
 #endif //ARDUINO_ROUTER_BRIDGE_H