chore(nodejs): update examples (#3)

Author: glasstiger

examples.manifest.yaml

@@ -5,14 +5,14 @@
     NodeJS client library [repo](https://github.com/questdb/nodejs-questdb-client).
 - name: ilp-auth-tls
   lang: javascript
-  path: examples/auth_and_tls.js
+  path: examples/auth_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
+    kid: testapp
+    d: 9b9x5WhJywDEuo1KGQWSPNxtX-6X6R2BRCKhYMMY6n8
+    x: aultdA0PjhD_cWViqKKyL5chm6H1n-BiZBo_48T-uqc
+    y: __ptaol41JWSpTTL525yVEfzmY8A6Vi_QrW1FjKcHMg
   addr:
     host: localhost
     port: 9009

examples/auth_tls.js

@@ -1,81 +1,37 @@
-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}`)
-}
+const { Sender } = require("@questdb/nodejs-client");
 
 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)
+  // construct a JsonWebKey
+  const CLIENT_ID = "testapp";
+  const PRIVATE_KEY = "9b9x5WhJywDEuo1KGQWSPNxtX-6X6R2BRCKhYMMY6n8";
+  const PUBLIC_KEY = {
+    x: "aultdA0PjhD_cWViqKKyL5chm6H1n-BiZBo_48T-uqc",
+    y: "__ptaol41JWSpTTL525yVEfzmY8A6Vi_QrW1FjKcHMg"
+  };
+  const JWK = {
+    ...PUBLIC_KEY,
+    d: PRIVATE_KEY,
+    kid: CLIENT_ID,
+    kty: "EC",
+    crv: "P-256",
+  };
+
+  // pass the JsonWebKey to the sender
+  // will use it for authentication
+  const sender = new Sender({bufferSize: 4096, jwk: JWK});
+
+  // connect() takes an optional second argument
+  // if 'true' passed the connection is secured with TLS encryption
+  await sender.connect({port: 9009, host: "127.0.0.1"}, true);
+
+  // send the data over the authenticated and secure connection
+  sender.table("prices").symbol("instrument", "EURUSD")
+      .floatColumn("bid", 1.0197).floatColumn("ask", 1.0224).atNow();
+  await sender.flush();
+
+  // close the connection after all rows ingested
+  await sender.close();
+  return 0;
 }
 
-run()
+run().then(value => console.log(value)).catch(err => console.log(err));

examples/basic.js

@@ -1,49 +1,31 @@
-// 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")
-  })
+const { Sender } = require("@questdb/nodejs-client");
+
+async function run() {
+  // create a sender with a 4k buffer
+  const sender = new Sender({bufferSize: 4096});
+
+  // connect to QuestDB
+  // host and port are required in connect options
+  await sender.connect({port: 9009, host: "127.0.0.1"});
+
+  // add rows to the buffer of the sender
+  sender.table("prices").symbol("instrument", "EURUSD")
+      .floatColumn("bid", 1.0195).floatColumn("ask", 1.0221).atNow();
+  sender.table("prices").symbol("instrument", "GBPUSD")
+      .floatColumn("bid", 1.2076).floatColumn("ask", 1.2082).atNow();
+
+  // flush the buffer of the sender, sending the data to QuestDB
+  // the buffer is cleared after the data is sent and the sender is ready to accept new data
+  await sender.flush();
+
+  // add rows to the buffer again and send it to the server
+  sender.table("prices").symbol("instrument", "EURUSD")
+      .floatColumn("bid", 1.0197).floatColumn("ask", 1.0224).atNow();
+  await sender.flush();
+
+  // close the connection after all rows ingested
+  await sender.close();
+  return 0;
 }
 
-run()
+run().then(value => console.log(value)).catch(err => console.log(err));