chore: Added NodeJS examples - Socket code without using library. (#2)

Author: amunra

examples.manifest.yaml

@@ -0,0 +1,18 @@
+- name: ilp
+  lang: javascript
+  path: examples/basic.js
+  header: |-
+    NodeJS client library [repo](https://github.com/questdb/nodejs-questdb-client).
+- name: ilp-auth-tls
+  lang: javascript
+  path: examples/auth_and_tls.js
+  header: |-
+    NodeJS client library [repo](https://github.com/questdb/nodejs-questdb-client).
+  auth:
+    kid: testUser1
+    d: 5UjEMuA0Pj5pjK8a-fa24dyIf-Es5mYny3oE_Wmus48
+    x: fLKYEaoEb9lrn3nkwLDA-M_xnuFOdSt9y0Z7_vWSHLU
+    y: Dt5tbS1dEDMSYfym3fgMv0B99szno-dFc1rYF9t0aac
+  addr:
+    host: localhost
+    port: 9009

examples/auth_tls.js

@@ -0,0 +1,81 @@
+const { TLSSocket } = require("tls")
+const { Crypto } = require("node-webcrypto-ossl")
+
+const client = new TLSSocket()
+const crypto = new Crypto()
+
+const HOST = "localhost"
+const PORT = 9009
+
+const JWK = {
+  kid: "testUser1",
+  kty: "EC",
+  d: "5UjEMuA0Pj5pjK8a-fa24dyIf-Es5mYny3oE_Wmus48",
+  crv: "P-256",
+  x: "fLKYEaoEb9lrn3nkwLDA-M_xnuFOdSt9y0Z7_vWSHLU",
+  y: "Dt5tbS1dEDMSYfym3fgMv0B99szno-dFc1rYF9t0aac",
+}
+
+async function write(data) {
+  return new Promise((resolve) => {
+    client.write(data, () => {
+      resolve()
+    })
+  })
+}
+
+async function authenticate(challenge) {
+  // Check for trailing \\n which ends the challenge
+  if (challenge.slice(-1).readInt8() === 10) {
+    const apiKey = await crypto.subtle.importKey(
+      "jwk",
+      JWK,
+      { name: "ECDSA", namedCurve: "P-256" },
+      true,
+      ["sign"],
+    )
+
+    const signature = await crypto.subtle.sign(
+      { name: "ECDSA", hash: "SHA-256" },
+      apiKey,
+      challenge.slice(0, challenge.length - 1),
+    )
+
+    await write(`${Buffer.from(signature).toString("base64")}\n`)
+
+    return true
+  }
+
+  return false
+}
+
+async function sendData() {
+  const now = Date.now()
+  await write(`test,location=us temperature=22.4 ${now * 1e6}`)
+  await write(`test,location=us temperature=21.4 ${now * 1e6}`)
+}
+
+async function run() {
+  let authenticated = false
+  let data
+
+  client.on("data", async function (raw) {
+    data = !data ? raw : Buffer.concat([data, raw])
+
+    if (!authenticated) {
+      authenticated = await authenticate(data)
+      await sendData()
+      setTimeout(() => {
+        client.destroy()
+      }, 0)
+    }
+  })
+
+  client.on("ready", async function () {
+    await write(JWK.kid)
+  })
+
+  client.connect(PORT, HOST)
+}
+
+run()

examples/basic.js

@@ -0,0 +1,49 @@
+// Raw socket connection with no validation and string quoting logic.
+// Refer to protocol description:
+// http://questdb.io/docs/reference/api/ilp/overview
+
+"use strict"
+
+const net = require("net")
+
+const client = new net.Socket()
+
+const HOST = "localhost"
+const PORT = 9009
+
+function run() {
+  client.connect(PORT, HOST, () => {
+    const rows = [
+      `trades,name=test_ilp1 value=12.4 ${Date.now() * 1e6}`,
+      `trades,name=test_ilp2 value=11.4 ${Date.now() * 1e6}`,
+    ]
+
+    function write(idx) {
+      if (idx === rows.length) {
+        client.destroy()
+        return
+      }
+
+      client.write(rows[idx] + "\n", (err) => {
+        if (err) {
+          console.error(err)
+          process.exit(1)
+        }
+        write(++idx)
+      })
+    }
+
+    write(0)
+  })
+
+  client.on("error", (err) => {
+    console.error(err)
+    process.exit(1)
+  })
+
+  client.on("close", () => {
+    console.log("Connection closed")
+  })
+}
+
+run()