adding thenable reject on builders

cblanquera · cblanquera · commit a361fb3028fe · 2024-12-26T02:07:01.000+08:00
diff --git a/examples/with-crdb/package.json b/examples/with-crdb/package.json
@@ -8,7 +8,7 @@
     "test": "dotenv -e .env -- yarn ts-node ./src/index.ts"
   },
   "dependencies": {
-    "@stackpress/inquire-pg": "0.2.11",
+    "@stackpress/inquire-pg": "0.2.12",
     "pg": "8.13.1"
   },
   "devDependencies": {
diff --git a/examples/with-mysql2/package.json b/examples/with-mysql2/package.json
@@ -8,7 +8,7 @@
     "test": "ts-node ./src/index.ts"
   },
   "dependencies": {
-    "@stackpress/inquire-mysql2": "0.2.11",
+    "@stackpress/inquire-mysql2": "0.2.12",
     "mysql2": "3.11.5"
   },
   "devDependencies": {
diff --git a/examples/with-pg/package.json b/examples/with-pg/package.json
@@ -8,7 +8,7 @@
     "test": "ts-node ./src/index.ts"
   },
   "dependencies": {
-    "@stackpress/inquire-pg": "0.2.11",
+    "@stackpress/inquire-pg": "0.2.12",
     "pg": "8.13.1"
   },
   "devDependencies": {
diff --git a/examples/with-pglite/package.json b/examples/with-pglite/package.json
@@ -9,7 +9,7 @@
   },
   "dependencies": {
     "@electric-sql/pglite": "0.2.14",
-    "@stackpress/inquire-pglite": "0.2.11"
+    "@stackpress/inquire-pglite": "0.2.12"
   },
   "devDependencies": {
     "@types/node": "22.9.3",
diff --git a/examples/with-sqlite3/package.json b/examples/with-sqlite3/package.json
@@ -8,7 +8,7 @@
     "test": "ts-node ./src/index.ts"
   },
   "dependencies": {
-    "@stackpress/inquire-sqlite3": "0.2.11",
+    "@stackpress/inquire-sqlite3": "0.2.12",
     "better-sqlite3": "11.7.0"
   },
   "devDependencies": {
diff --git a/packages/inquire-mysql2/package.json b/packages/inquire-mysql2/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@stackpress/inquire-mysql2",
-  "version": "0.2.11",
+  "version": "0.2.12",
   "license": "Apache-2.0",
   "description": "Generic typed mysql2",
   "author": "Chris <chris@incept.asia>",
@@ -20,7 +20,7 @@
     "test": "nyc ts-mocha tests/*.test.ts"
   },
   "dependencies": {
-    "@stackpress/inquire": "0.2.11"
+    "@stackpress/inquire": "0.2.12"
   },
   "peerDependencies": {
     "mysql2": "^3.11.5"
diff --git a/packages/inquire-pg/package.json b/packages/inquire-pg/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@stackpress/inquire-pg",
-  "version": "0.2.11",
+  "version": "0.2.12",
   "license": "Apache-2.0",
   "description": "Generic typed pg",
   "author": "Chris <chris@incept.asia>",
@@ -19,7 +19,7 @@
     "build": "tsc"
   },
   "dependencies": {
-    "@stackpress/inquire": "0.2.11"
+    "@stackpress/inquire": "0.2.12"
   },
   "peerDependencies": {
     "pg": "^8.13.1"
diff --git a/packages/inquire-pglite/package.json b/packages/inquire-pglite/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@stackpress/inquire-pglite",
-  "version": "0.2.11",
+  "version": "0.2.12",
   "license": "Apache-2.0",
   "description": "Generic typed pglite",
   "author": "Chris <chris@incept.asia>",
@@ -20,7 +20,7 @@
     "test": "nyc ts-mocha tests/*.test.ts && rm -rf ./tests/database"
   },
   "dependencies": {
-    "@stackpress/inquire": "0.2.11"
+    "@stackpress/inquire": "0.2.12"
   },
   "peerDependencies": {
     "@electric-sql/pglite": "^0.2.14"
diff --git a/packages/inquire-sqlite3/package.json b/packages/inquire-sqlite3/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@stackpress/inquire-sqlite3",
-  "version": "0.2.11",
+  "version": "0.2.12",
   "license": "Apache-2.0",
   "description": "Generic typed better-sqlite3",
   "author": "Chris <chris@incept.asia>",
@@ -20,7 +20,7 @@
     "test": "nyc ts-mocha tests/*.test.ts && rm -rf ./tests/database"
   },
   "dependencies": {
-    "@stackpress/inquire": "0.2.11"
+    "@stackpress/inquire": "0.2.12"
   },
   "peerDependencies": {
     "better-sqlite3": "^11.7.0"
diff --git a/packages/inquire/package.json b/packages/inquire/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@stackpress/inquire",
-  "version": "0.2.11",
+  "version": "0.2.12",
   "license": "Apache-2.0",
   "description": "Generic typed SQL",
   "author": "Chris <chris@incept.asia>",
diff --git a/packages/inquire/src/builder/Alter.ts b/packages/inquire/src/builder/Alter.ts
@@ -1,6 +1,7 @@
 //common
 import type { 
   Field, 
+  Reject,
   Resolve,
   Dialect,
   ForeignKey,
@@ -195,7 +196,7 @@ export default class Alter<R = unknown> {
    * Makes class awaitable. Should get the 
    * query and values and call the action.
    */
-  public then(resolve: Resolve<R[]>) {
+  public then(resolve: Resolve<R[]>, reject: Reject) {
     if (!this._engine) {
       throw Exception.for('No engine provided');
     }
@@ -206,6 +207,6 @@ export default class Alter<R = unknown> {
         await connection.query<R>(connection.format(request));
       }
       return await connection.query<R>(connection.format(last));
-    }).then(resolve);
+    }).then(resolve).catch(reject);
   }
 }
diff --git a/packages/inquire/src/builder/Create.ts b/packages/inquire/src/builder/Create.ts
@@ -1,6 +1,7 @@
 //common
 import type { 
   Field, 
+  Reject,
   Resolve, 
   Dialect, 
   ForeignKey, 
@@ -142,7 +143,7 @@ export default class Create<R = unknown> {
    * Makes class awaitable. Should get the 
    * query and values and call the action.
    */
-  public then(resolve: Resolve<R[]>) {
+  public then(resolve: Resolve<R[]>, reject: Reject) {
     if (!this._engine) {
       throw Exception.for('No engine provided');
     }
@@ -153,6 +154,6 @@ export default class Create<R = unknown> {
         await connection.query<R>(connection.format(request));
       }
       return await connection.query<R>(connection.format(last));
-    }).then(resolve);
+    }).then(resolve).catch(reject);
   }
 }
diff --git a/packages/inquire/src/builder/Delete.ts b/packages/inquire/src/builder/Delete.ts
@@ -1,5 +1,5 @@
 //common
-import type { Resolve, Dialect, FlatValue } from '../types';
+import type { Reject, Resolve, Dialect, FlatValue } from '../types';
 import Engine from '../Engine';
 import Exception from '../Exception';
 
@@ -66,11 +66,11 @@ export default class Delete<R = unknown> {
    * Makes class awaitable. Should get the 
    * query and values and call the action.
    */
-  public then(resolve: Resolve<R[]>) {
+  public then(resolve: Resolve<R[]>, reject: Reject) {
     if (!this._engine) {
       throw Exception.for('No engine provided');
     }
-    return this._engine.query<R>(this.query()).then(resolve);
+    return this._engine.query<R>(this.query()).then(resolve).catch(reject);
   }
 
   /**
diff --git a/packages/inquire/src/builder/Insert.ts b/packages/inquire/src/builder/Insert.ts
@@ -1,5 +1,5 @@
 //common
-import type { Value, Resolve, Dialect } from '../types';
+import type { Value, Reject, Resolve, Dialect } from '../types';
 import Engine from '../Engine';
 import Exception from '../Exception';
 
@@ -84,11 +84,11 @@ export default class Insert<R = unknown> {
    * Makes class awaitable. Should get the 
    * query and values and call the action.
    */
-  public then(resolve: Resolve<R[]>) {
+  public then(resolve: Resolve<R[]>, reject: Reject) {
     if (!this._engine) {
       throw Exception.for('No engine provided');
     }
-    return this._engine.query<R>(this.query()).then(resolve);
+    return this._engine.query<R>(this.query()).then(resolve).catch(reject);
   }
 
   public values(values: Record<string, Value>|Record<string, Value>[]) {
diff --git a/packages/inquire/src/builder/Select.ts b/packages/inquire/src/builder/Select.ts
@@ -1,6 +1,7 @@
 //common
 import type { 
   Order, 
+  Reject,
   Resolve,
   Dialect,
   Relation, 
@@ -146,11 +147,11 @@ export default class Select<R = unknown> {
    * Makes class awaitable. Should get the 
    * query and values and call the action.
    */
-  public then(resolve: Resolve<R[]>) {
+  public then(resolve: Resolve<R[]>, reject: Reject) {
     if (!this._engine) {
       throw Exception.for('No engine provided');
     }
-    return this._engine.query<R>(this.query()).then(resolve);
+    return this._engine.query<R>(this.query()).then(resolve).catch(reject);
   }
 
   /**
diff --git a/packages/inquire/src/builder/Update.ts b/packages/inquire/src/builder/Update.ts
@@ -1,6 +1,7 @@
 //common
 import type { 
   Value, 
+  Reject,
   Resolve,
   Dialect,
   FlatValue 
@@ -85,11 +86,11 @@ export default class Update<R = unknown> {
    * Makes class awaitable. Should get the 
    * query and values and call the action.
    */
-  public then(resolve: Resolve<R[]>) {
+  public then(resolve: Resolve<R[]>, reject: Reject) {
     if (!this._engine) {
       throw Exception.for('No engine provided');
     }
-    return this._engine.query<R>(this.query()).then(resolve);
+    return this._engine.query<R>(this.query()).then(resolve).catch(reject);
   }
 
   /**

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@stackpress/inquire",`
`3`		`- "version": "0.2.11",`
	`3`	`+ "version": "0.2.12",`
`4`	`4`	`"license": "Apache-2.0",`
`5`	`5`	`"description": "Generic typed SQL",`
`6`	`6`	`"author": "Chris <chris@incept.asia>",`