0.1.23 make uniqueid required prop

Author: rvdende

jsr.json

@@ -1,5 +1,5 @@
 {
   "name": "@netron/surreal",
-  "version": "0.1.22",
+  "version": "0.1.23",
   "exports": "./index.ts"
 }

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@netron/surreal",
-  "version": "0.1.22",
+  "version": "0.1.23",
   "description": "type safe surrealdb",
   "main": "index.ts",
   "scripts": {

src/NSurreal.ts

@@ -12,14 +12,19 @@ export class NSurreal<G extends Record<string, object> = {}> {
   timestamp_connected: Date | undefined;
   url: string | undefined;
   opts: ConnectionOptions | undefined;
-
   output_path: string = "./src/generated";
 
-  constructor(options?: { output_path: string }) {
+  debug = false;
+
+  constructor(options?: { output_path: string; debug?: boolean }) {
     if (options?.output_path) {
       this.output_path = options.output_path;
     }
 
+    if (options?.debug) {
+      this.debug = options.debug;
+    }
+
     this.client = new Surreal();
     this.timer = setInterval(() => {
       if (!this.timestamp_connected) return;
@@ -36,11 +41,21 @@ export class NSurreal<G extends Record<string, object> = {}> {
   /** Connects to a local or remote database endpoint.
    * https://surrealdb.com/docs/surrealdb/integration/sdks/javascript#connect
    */
+
+  log(...input: any[]) {
+    if (this.debug) console.log(`NSurreal -`, input);
+  }
+
   async connect(url: string, opts?: ConnectionOptions): Promise<void> {
-    if (!this.client) throw new Error("Client not connected");
+    this.log(`Connecting to ${url}`);
+    if (!this.client) {
+      this.log(`Client not connected`);
+      throw new Error("Client not connected");
+    }
     this.opts = opts;
     this.url = url;
     await this.client.connect(url, opts);
+    this.log("Connected!");
     this.timestamp_connected = new Date();
   }
 
@@ -69,8 +84,9 @@ export class NSurreal<G extends Record<string, object> = {}> {
   async query<Q extends keyof G>(
     query: string,
     /** we create a unique tag for this query to link the output back to the type */
-    uniqueID?: Q
+    uniqueID: Q
   ): Promise<G[Q]> {
+    this.log("Querying", query, uniqueID);
     query = query.trim();
     if (!this.client) throw new Error("Client not connected");
 

src/surreal_helpers.ts

@@ -3,7 +3,7 @@ import { z } from "zod";
 import { NSurreal } from "./NSurreal";
 
 export async function SR_getInfoForKV({ db }: { db: NSurreal<any> }) {
-  const result = await db.query("INFO FOR KV;").catch((err) => {
+  const result = await db.query("INFO FOR KV;", "info for kv").catch((err) => {
     console.log(err);
   });
 
@@ -21,7 +21,7 @@ export async function SR_getInfoForKV({ db }: { db: NSurreal<any> }) {
 }
 
 export async function SR_getInfoForNS({ db }: { db: NSurreal<any> }) {
-  const result = await db.query("INFO FOR NS;").catch((err) => {
+  const result = await db.query("INFO FOR NS;", "info for ns").catch((err) => {
     console.log(err);
   });
 
@@ -98,7 +98,7 @@ export async function SR_derive_fields_from_table({
   table: string;
 }) {
   const result = await db
-    .query(`SELECT * FROM ${table} LIMIT 10;`)
+    .query(`SELECT * FROM ${table} LIMIT 10;`, "derive_fields_from_table")
     .catch((err) => {
       console.log(err);
     });