sdk/node, net, node, readme: create tests using mocha and chai, recode away all streams to use async generator instead to adhere to backpressure support, add support for sending messages to other nodes and listening for other nodes in nodejs, expose peer id in Context for both nodejs and go, update readme with new doc info

Author: lithdew

README.md

@@ -307,6 +307,9 @@ import "io"
 import "io/ioutil"
 
 func helloWorld(ctx *flatend.Context) {
+    // The ID of the requester may be accessed via `ctx.ID`.
+    _ = ctx.ID
+
     // All headers must be written before writing any response body data.
 
     // Headers are used to send small amounts of metadata to a requester.
@@ -347,27 +350,29 @@ func helloWorld(ctx *flatend.Context) {
 ```js
 const {Node} = require("flatend");
 
-interface NodeOpts {
-    // A reachable, public address which peers may reach you on.
-    // The format of the address must be [host]:[port].
-    addr?: string;
-
-    // A list of addresses to nodes to initially reach out 
-    // for/bootstrap from first.
-    addrs?: string;
-
-    // An Ed25519 keypair. A keypair must be provided to allow for
-    // peers to reach you. A secret key may be generated by calling
-    // 'nacl.sign.keyPair()' using the 'tweetnacl' library.
-    keys?: nacl.SignKeyPair;
-
-    // A mapping of service names to their respective handlers.
-    services?: { [key: string]: Handler };
-
-    // bindAddrs?: string[], (not supported yet)
+export interface NodeOptions {
+  // A reachable, public address which peers may reach you on.
+  // The format of the address must be [host]:[port].
+  publicAddr?: string;
+  
+  // A list of [host]:[port] addresses which this node will bind a listener
+  // against to accept new Flatend nodes.
+  bindAddrs?: string[];
+
+  // A list of addresses to nodes to initially reach out 
+  // for/bootstrap from first.
+  addrs?: string[];
+
+  // An Ed25519 secret key. A secret key must be provided to allow for
+  // peers to reach you. A secret key may be generated by calling
+  // 'flatend.generateSecretKey()'.
+  secretKey?: Uint8Array;
+
+  // A mapping of service names to their respective handlers.
+  services?: { [key: string]: Handler };
 }
 
-await Node.start(opts?: NodeOpts);
+await Node.start(opts: NodeOpts);
 
 const {Context} = require("flatend");
 
@@ -378,6 +383,8 @@ const helloWorld = async ctx => {
     // 'ctx' is a NodeJS Duplex stream. Writing to it writes a response
     // body, and reading from it reads a request body.
 
+    _ = ctx.id; // The ID of the requester.
+
     ctx.pipe(ctx); // This would pipe all request data as response data.
 
     // Headers are used to send small amounts of metadata to a requester.

examples/go/clock/README.md

@@ -149,4 +149,4 @@ func main() {
 	signal.Notify(ch, os.Interrupt)
 	<-ch
 }
-```
+```

examples/go/counter/README.md

@@ -8,7 +8,7 @@ $ flatend
 2020/06/17 02:12:53 Listening for HTTP requests on '[::]:3000'.
 2020/06/17 02:12:59 <anon> has connected to you. Services: [count]
 
-$ go run main.go 
+$ go run main.go
 2020/06/17 02:13:00 You are now connected to 127.0.0.1:9000. Services: []
 
 $ http://localhost:3000
@@ -68,4 +68,4 @@ func main() {
 
 	node.Shutdown()
 }
-```
+```

examples/go/file/README.md

@@ -8,7 +8,7 @@ $ flatend
 2020/06/17 02:36:30 Listening for HTTP requests on '[::]:3000'.
 2020/06/17 02:36:41 <anon> has connected to you. Services: [file]
 
-$ node index.js 
+$ node index.js
 Successfully dialed 127.0.0.1:9000. Services: []
 
 $ http://localhost:3000/
@@ -36,14 +36,14 @@ service = "file"
 ```
 
 ```js
-const {Node} = require("flatend");
+const { Node } = require("flatend");
 const fs = require("fs");
 
 const main = async () => {
-    const node = new Node();
-    node.register('file', ctx => fs.createReadStream("index.js").pipe(ctx));
-    await node.dial("127.0.0.1:9000");
-}
+  const node = new Node();
+  node.register("file", (ctx) => fs.createReadStream("index.js").pipe(ctx));
+  await node.dial("127.0.0.1:9000");
+};
 
-main().catch(err => console.error(err));
-```
+main().catch((err) => console.error(err));
+```

examples/go/hello_world/README.md

@@ -64,4 +64,4 @@ func main() {
 
 	node.Shutdown()
 }
-```
+```

examples/go/pipe/README.md

@@ -59,4 +59,4 @@ func main() {
 
 	node.Shutdown()
 }
-```
+```

examples/go/todo/README.md

@@ -191,4 +191,4 @@ func main() {
 	node.Shutdown()
 	check(db.Close())
 }
-```
+```

examples/go/todo/public/index.html

@@ -1,15 +1,18 @@
 <!DOCTYPE html>
 <html lang="en">
-<head>
-    <meta charset="utf-8">
-    <meta http-equiv="X-UA-Compatible" content="IE=edge">
-    <meta name="viewport" content="width=device-width,initial-scale=1.0">
+  <head>
+    <meta charset="utf-8" />
+    <meta http-equiv="X-UA-Compatible" content="IE=edge" />
+    <meta name="viewport" content="width=device-width,initial-scale=1.0" />
     <title>Flatend Demo - Todo</title>
-    <link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/bulma/0.8.0/css/bulma.min.css">
-    <link rel="stylesheet" href="/style.css">
-</head>
-<body>
-<div id="root"></div>
-<script src="/main.js"></script>
-</body>
-</html>
+    <link
+      rel="stylesheet"
+      href="https://cdnjs.cloudflare.com/ajax/libs/bulma/0.8.0/css/bulma.min.css"
+    />
+    <link rel="stylesheet" href="/style.css" />
+  </head>
+  <body>
+    <div id="root"></div>
+    <script src="/main.js"></script>
+  </body>
+</html>

examples/go/todo/public/main.js

@@ -1,31 +1,31 @@
 form {
-    display: flex;
-    padding: 10px;
+  display: flex;
+  padding: 10px;
 }
 
 .wrapper {
-    min-height: 100vh;
-    display: flex;
-    justify-content: center;
-    align-items: center;
-    background-image: url('data:image/svg+xml,%3Csvg xmlns="http://www.w3.org/2000/svg" width="4" height="4" viewBox="0 0 4 4"%3E%3Cpath fill="%239C92AC" fill-opacity="0.4" d="M1 3h1v1H1V3zm2-2h1v1H3V1z"%3E%3C/path%3E%3C/svg%3E');
+  min-height: 100vh;
+  display: flex;
+  justify-content: center;
+  align-items: center;
+  background-image: url('data:image/svg+xml,%3Csvg xmlns="http://www.w3.org/2000/svg" width="4" height="4" viewBox="0 0 4 4"%3E%3Cpath fill="%239C92AC" fill-opacity="0.4" d="M1 3h1v1H1V3zm2-2h1v1H3V1z"%3E%3C/path%3E%3C/svg%3E');
 }
 
 .input {
-    margin-right: 10px;
+  margin-right: 10px;
 }
 
 .frame {
-    width: 40vw;
-    max-width: 400px;
+  width: 40vw;
+  max-width: 400px;
 }
 
 .header {
-    display: inline;
-    text-align: center;
+  display: inline;
+  text-align: center;
 }
 
 .list-wrapper {
-    max-height: 200px;
-    overflow-y: auto;
-}
+  max-height: 200px;
+  overflow-y: auto;
+}