upgrade to es6 and catch conn errors

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "dblang",
-  "version": "1.0.0",
+  "version": "0.7.0",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "dblang",
-      "version": "1.0.0",
+      "version": "0.7.0",
       "license": "UNLICENSED",
       "dependencies": {
         "mariadb": "^3.0.2",
@@ -19,7 +19,7 @@
         "typescript": "^4.9.4"
       },
       "engines": {
-        "node": ">= 14"
+        "node": ">= 16"
       }
     },
     "node_modules/@esbuild/android-arm": {

package.json

@@ -1,10 +1,10 @@
 {
   "name": "dblang",
-  "version": "0.6.2",
+  "version": "0.7.0",
   "description": "",
   "main": "dist/db.js",
   "types": "dist/db.d.ts",
-  "type": "commonjs",
+  "type": "module",
   "directories": {
     "dist": "dist"
   },
@@ -22,7 +22,7 @@
     "pg": "^8.9.0"
   },
   "engines": {
-    "node": ">= 14"
+    "node": ">= 16"
   },
   "devDependencies": {
     "@types/node": "^18.11.18",

src/alias.ts

@@ -1,5 +1,5 @@
-import { Attribute, DB, Table } from "./db"
+import { Attribute, DB, Table } from "./db.js"
-import { Handler } from "./defaultHandler";
+import { Handler } from "./defaultHandler.js";
 
 export class AttributeAlias {
     name: string;

src/db.ts

@@ -1,12 +1,17 @@
 import mariadb from 'mariadb';
-import { checkConstraint, Constraint, Datatype, foreignConstraint, uniqueConstraint } from './dbStructure';
+import { checkConstraint, Constraint, Datatype, foreignConstraint, uniqueConstraint } from './dbStructure.js';
-import { Handler } from './defaultHandler';
+import { Handler } from './defaultHandler.js';
-import { Query } from './query';
+import { Query } from './query.js';
-import { attributeSettings, extendedAttributeSettings, onAction, dbType } from './types';
+import { attributeSettings, extendedAttributeSettings, onAction, dbType } from './types.js';
-import { TableAlias } from "./alias"
+import { TableAlias } from "./alias.js"
-import { insertResponse, readResponse, writeResponse, singleResponse } from "./responses"
+import { insertResponse, readResponse, writeResponse, singleResponse } from "./responses.js"
 //import { postgresHandler } from "./postgresHandler"
 
+declare module "mariadb" {
+    interface Pool{
+        on(ev: 'error', callback: () => void): Pool;
+    }
+}
 
 export class DB {
     tables: Table[] = [];
@@ -21,6 +26,8 @@ export class DB {
         this.type = databaseType;
         if (databaseType == dbType.mariadb) {
             this.mariaPool = mariadb.createPool({ host, user, password, port, database, connectionLimit, multipleStatements: true });
+            // catch errors
+            this.mariaPool.on("error",()=>{});
             this.handler = new Handler(this);
         }
         /*else if (databaseType == dbType.postgres) {
@@ -170,7 +177,7 @@ export class Table {
     }
 }
 
-export * from './funcs';
+export * from './funcs.js';
 export { onAction };
 export { dbType as databaseType }
 export { readResponse, writeResponse, insertResponse, singleResponse }

src/dbStructure.ts

@@ -1,7 +1,7 @@
-import { Attribute, Table } from "./db";
+import { Attribute, Table } from "./db.js";
-import { Handler } from "./defaultHandler";
+import { Handler } from "./defaultHandler.js";
-import { QueryBuilder } from "./query";
+import { QueryBuilder } from "./query.js";
-import { allModifierInput, joinElements, joinType, onAction, primaryData, serializeReturn } from "./types";
+import { allModifierInput, joinElements, joinType, onAction, primaryData, serializeReturn } from "./types.js";
 
 export class Datatype {
     type: string;

src/defaultHandler.ts

@@ -1,8 +1,8 @@
-import { AttributeAlias, TableAlias } from "./alias";
+import { AttributeAlias, TableAlias } from "./alias.js";
-import { Attribute, DB, insertResponse, readResponse, Table, writeResponse } from "./db"
+import { Attribute, DB, insertResponse, readResponse, Table, writeResponse } from "./db.js"
-import { Aggregation, checkConstraint, joinCross, Datatype, foreignConstraint, Modifier, joinNatural, onJoin, uniqueConstraint, usingJoin } from "./dbStructure"
+import { Aggregation, checkConstraint, joinCross, Datatype, foreignConstraint, Modifier, joinNatural, onJoin, uniqueConstraint, usingJoin } from "./dbStructure.js"
-import { insertQuery, Query, QueryBuilder, removeQuery, selectQuery, updateQuery } from "./query"
+import { insertQuery, Query, QueryBuilder, removeQuery, selectQuery, updateQuery } from "./query.js"
-import { allModifierInput, joinType, onAction, primaryData } from "./types"
+import { allModifierInput, joinType, onAction, primaryData } from "./types.js"
 
 export class Handler {
     db: DB;

src/funcs.ts

@@ -1,7 +1,7 @@
-import { Attribute, Table } from "./db";
+import { Attribute, Table } from "./db.js";
-import { Aggregation, BooleanModifier, checkConstraint, Datatype, foreignConstraint, joinCross, joinNatural, usingJoin, onJoin, NumberModifier, StringModifier, uniqueConstraint } from "./dbStructure";
+import { Aggregation, BooleanModifier, checkConstraint, Datatype, foreignConstraint, joinCross, joinNatural, usingJoin, onJoin, NumberModifier, StringModifier, uniqueConstraint } from "./dbStructure.js";
-import { insertQuery, removeQuery, selectQuery, updateQuery } from "./query";
+import { insertQuery, removeQuery, selectQuery, updateQuery } from "./query.js";
-import { allModifierInput, joinType, selectElements, selectFromElements } from "./types";
+import { allModifierInput, joinType, selectElements, selectFromElements } from "./types.js";
 
 //modifiers
 export const and = (...args: BooleanModifier[]) => new BooleanModifier("and", args);

src/query.ts

@@ -1,8 +1,8 @@
-import { AttributeAlias } from "./alias";
+import { AttributeAlias } from "./alias.js";
-import { Attribute, DB, Table } from "./db";
+import { Attribute, DB, Table } from "./db.js";
-import { BooleanModifier, Modifier } from "./dbStructure";
+import { BooleanModifier, Modifier } from "./dbStructure.js";
-import { Handler } from "./defaultHandler";
+import { Handler } from "./defaultHandler.js";
-import { allModifierInput, primaryData, selectElements, selectFromElements, serializeReturn } from "./types";
+import { allModifierInput, primaryData, selectElements, selectFromElements, serializeReturn } from "./types.js";
 
 
 export class Query {

src/responses.ts

@@ -1,6 +1,6 @@
-import { AttributeAlias } from "./alias";
+import { AttributeAlias } from "./alias.js";
-import { Attribute } from "./db";
+import { Attribute } from "./db.js";
-import { primaryData } from "./types";
+import { primaryData } from "./types.js";
 
 export class singleResponse {
     [key: string]: primaryData | any;

src/types.ts

@@ -1,7 +1,7 @@
-import { AttributeAlias, TableAlias } from "./alias";
+import { AttributeAlias, TableAlias } from "./alias.js";
-import { Attribute, Table } from "./db";
+import { Attribute, Table } from "./db.js";
-import { Aggregation, BooleanModifier, Datatype, Joins, Modifier } from "./dbStructure";
+import { Aggregation, BooleanModifier, Datatype, Joins, Modifier } from "./dbStructure.js";
-import { QueryBuilder, selectQuery } from "./query";
+import { QueryBuilder, selectQuery } from "./query.js";
 
 export type primaryData = string | number | boolean | null;
 export type allModifierInput = primaryData | Modifier | selectQuery | Attribute | AttributeAlias | Aggregation;

tsconfig.json

@@ -1,6 +1,7 @@
 {
   "compilerOptions": {
-    "module": "CommonJS",
+    "target": "ES6",
+    "module": "ES6",
     "lib": ["es6"],
     "types": ["node"],
     "declaration": true,