pick commit

Author: jkcs

.prettierrc.js

@@ -0,0 +1,10 @@
+module.exports = {
+  bracketSpacing: true,
+  bracketSameLine: false,
+  singleQuote: true,
+  jsxSingleQuote: true,
+  trailingComma: 'all',
+  semi: true,
+  tabWidth: 2,
+  useTabs: false,
+};

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+  "typescript.tsdk": "./node_modules/typescript/lib"
+}

examples/test.ts

@@ -0,0 +1,38 @@
+import { Config } from "../src"
+
+async function test() {
+  const config = new Config(
+    'root',
+    'admin123456123456',
+    '127.0.0.1',
+    2003
+  )
+
+  const db = await config.connect()
+  // await db.query('create space testmyspace')
+  await db.query('USE testmyspace')
+  // await db.query("create model testmyspace.user(username: string, password: string)")
+  const res = await db.query(
+    'SELECT all *  FROM int limit ?',
+    100
+  )
+  // await db.query(
+  //   'insert into testmyspace.user(?, ?)',
+  //   'test2',
+  //   `a123456`,
+  // )
+  // const res = await db.query(
+  //   'SELECT * FROM mymodel where username = ?',
+  //   'sayan6'
+  // )
+
+  // const res = await db.query(
+  //   'SELECT * FROM testmyspace.int where username = ?',
+  //   10001n
+  // )
+
+  console.log(res, 'result=========');
+
+}
+
+test()

package.json

@@ -3,16 +3,34 @@
   "version": "1.0.0",
   "main": "dist/index.js",
   "description": "Offical NodeJS client driver for Skytable",
-  "repository": "https://github.com/skytable/client-nodejs.git",
   "author": "Sayan Nandan <nandansayan@outlook.com>",
   "license": "Apache-2.0",
-  "devDependencies": {
-    "typescript": "^5.3.3"
-  },
+  "repository": {
+		"url": "https://github.com/skytable/client-nodejs"
+	},
+	"bugs": {
+		"url": "https://github.com/skytable/client-nodejs/issues"
+	},
   "scripts": {
-    "build": "tsc"
+    "build": "tsc",
+    "test": "npx tsx examples/test.ts",
+    "formatting": "prettier src --check",
+    "prettier:fix": "prettier src --write"
   },
   "dependencies": {
     "@types/node": "^20.10.4"
-  }
+  },
+  "devDependencies": {
+    "nodemon": "^3.0.2",
+    "prettier": "^3.1.1",
+    "tsx": "^4.6.2",
+    "typescript": "^5.3.3"
+  },
+  "publishConfig": {
+		"access": "public"
+	},
+  "keywords": [
+		"skytable",
+		"skytable-client"
+	]
 }

src/Config.ts

@@ -0,0 +1,120 @@
+import {
+  connectionWrite,
+  createConnection,
+  createConnectionTls,
+} from './connection';
+import { createSkytable } from './skytable';
+import { bufferToHandshakeResult, getClientHandshake } from './protocol';
+import type {
+  ConnectionOptions as ConnectionTLSOptions,
+  TLSSocket,
+} from 'node:tls';
+import { Socket } from 'node:net';
+
+/**
+ * Configuration for a client connection (single node)
+ */
+export class Config {
+  private username: string;
+  private password: string;
+  private host: string;
+  private port: number;
+  private connection: Socket | TLSSocket | undefined;
+
+  /**
+   * Create a new configuration
+   *
+   * @param username Set the username for authenticating with Skytable
+   * @param password Set the password for authenticating with Skytable
+   * @param host Set the host to connect to Skytable (defaults to `127.0.0.1`)
+   * @param port Set the port to connect to Skytable (defaults to 2003)
+   */
+  constructor(
+    username: string,
+    password: string,
+    host: string = 'localhost',
+    port: number = 2003,
+  ) {
+    this.username = username;
+    this.password = password;
+    this.host = host;
+    this.port = port;
+  }
+
+  /**
+   * Get the set username
+   * @returns Username set in this configuration
+   */
+  getUsername(): string {
+    return this.username;
+  }
+
+  /**
+   * Get the set password
+   * @returns Username set in this configuration
+   */
+  getPassword(): string {
+    return this.password;
+  }
+
+  /**
+   * Get the set host
+   * @returns Username set in this configuration
+   */
+  getHost(): string {
+    return this.host;
+  }
+
+  /**
+   * Get the set port
+   * @returns Username set in this configuration
+   */
+  getPort(): number {
+    return this.port;
+  }
+
+  /**
+   * Get the connection
+   * @returns The current connection
+   */
+  getConnection() {
+    return this.connection;
+  }
+
+  async connect() {
+    const connect = await createConnection({
+      port: this.port,
+      host: this.host,
+    });
+
+    const data = await connectionWrite(connect, getClientHandshake(this));
+
+    await bufferToHandshakeResult(data);
+
+    this.connection = connect;
+
+    return createSkytable(connect);
+  }
+
+  async connectTSL(options: ConnectionTLSOptions) {
+    const connect = await createConnectionTls({
+      port: this.port,
+      host: this.host,
+      ...options,
+    });
+
+    const data = await connectionWrite(connect, getClientHandshake(this));
+
+    await bufferToHandshakeResult(data);
+
+    this.connection = connect;
+
+    return createSkytable(connect);
+  }
+
+  async disconnect() {
+    if (this.connection) {
+      this.connection.destroySoon();
+    }
+  }
+}

src/Query.ts

@@ -0,0 +1,57 @@
+import { connect as connectTcp, Socket, NetConnectOpts } from 'node:net';
+import {
+  connect as connectTcpTLS,
+  TLSSocket,
+  ConnectionOptions as ConnectionTLSOptions,
+} from 'node:tls';
+
+export function createConnection(options: NetConnectOpts): Promise<Socket> {
+  return new Promise((resolve, reject) => {
+    const conn = connectTcp(options);
+    conn.once('connect', () => {
+      resolve(conn);
+    });
+
+    conn.once('error', (error) => {
+      console.error(`createConnection error: ${error.message}`);
+      reject(error);
+    });
+  });
+}
+
+export function createConnectionTls(
+  options: ConnectionTLSOptions,
+): Promise<TLSSocket> {
+  return new Promise((resolve, reject) => {
+    const conn = connectTcpTLS(options);
+    conn.once('connect', () => {
+      resolve(conn);
+    });
+
+    conn.once('error', (error) => {
+      console.error(`createConnection error: ${error.message}`);
+      reject(error);
+    });
+  });
+}
+
+export function connectionWrite(
+  connect: Socket | TLSSocket,
+  buffer: Buffer | string,
+): Promise<Buffer> {
+  return new Promise((resolve, reject) => {
+    connect.write(buffer, (writeError) => {
+      if (writeError) {
+        reject(writeError);
+        return;
+      }
+
+      connect.once('data', (data) => {
+        resolve(data);
+      });
+      connect.once('error', (err) => {
+        reject(err);
+      });
+    });
+  });
+}

src/config.ts

@@ -1,2 +1 @@
-export {Config} from './Config';
-export {Query, SQParam} from './Query';
+export { Config } from './config';