@cubejs-backend/base-driver - npm Package Compare versions

Comparing version 0.31.58 to 0.31.60

dist/src/BaseDriver.js

@@ -113,3 +113,3 @@ "use strict";
                 canBeFile: true,
-                envKey: shared_1.keyByDataSource('CUBEJS_DB_SSL_CA', dataSource),
+                envKey: (0, shared_1.keyByDataSource)('CUBEJS_DB_SSL_CA', dataSource),
                 validate: shared_1.isSslCert,
@@ -119,3 +119,3 @@ }, {
                 canBeFile: true,
-                envKey: shared_1.keyByDataSource('CUBEJS_DB_SSL_CERT', dataSource),
+                envKey: (0, shared_1.keyByDataSource)('CUBEJS_DB_SSL_CERT', dataSource),
                 validate: shared_1.isSslCert,
@@ -125,16 +125,16 @@ }, {
                 canBeFile: true,
-                envKey: shared_1.keyByDataSource('CUBEJS_DB_SSL_KEY', dataSource),
+                envKey: (0, shared_1.keyByDataSource)('CUBEJS_DB_SSL_KEY', dataSource),
                 validate: shared_1.isSslKey,
             }, {
                 name: 'ciphers',
-                envKey: shared_1.keyByDataSource('CUBEJS_DB_SSL_CIPHERS', dataSource),
+                envKey: (0, shared_1.keyByDataSource)('CUBEJS_DB_SSL_CIPHERS', dataSource),
             }, {
                 name: 'passphrase',
-                envKey: shared_1.keyByDataSource('CUBEJS_DB_SSL_PASSPHRASE', dataSource),
+                envKey: (0, shared_1.keyByDataSource)('CUBEJS_DB_SSL_PASSPHRASE', dataSource),
             }, {
                 name: 'servername',
-                envKey: shared_1.keyByDataSource('CUBEJS_DB_SSL_SERVERNAME', dataSource),
+                envKey: (0, shared_1.keyByDataSource)('CUBEJS_DB_SSL_SERVERNAME', dataSource),
             }];
-        if (shared_1.getEnv('dbSsl', { dataSource }) ||
-            shared_1.getEnv('dbSslRejectUnauthorized', { dataSource })) {
+        if ((0, shared_1.getEnv)('dbSsl', { dataSource }) ||
+            (0, shared_1.getEnv)('dbSslRejectUnauthorized', { dataSource })) {
             ssl = sslOptions.reduce((agg, { name, envKey, canBeFile, validate }) => {
@@ -149,3 +149,3 @@ if (process.env[envKey]) {
                     }
-                    if (canBeFile && shared_1.isFilePath(value)) {
+                    if (canBeFile && (0, shared_1.isFilePath)(value)) {
                         if (!fs_1.default.existsSync(value)) {
@@ -167,3 +167,3 @@ throw new Error(`Unable to find ${name} from path: "${value}"`);
             }, {});
-            ssl.rejectUnauthorized = shared_1.getEnv('dbSslRejectUnauthorized', { dataSource });
+            ssl.rejectUnauthorized = (0, shared_1.getEnv)('dbSslRejectUnauthorized', { dataSource });
         }
@@ -207,3 +207,3 @@ return ssl;
         const query = this.informationSchemaQuery();
-        return this.query(query).then(data => ramda_1.reduce(this.informationColumnsSchemaReducer, {}, data));
+        return this.query(query).then(data => (0, ramda_1.reduce)(this.informationColumnsSchemaReducer, {}, data));
     }
@@ -240,3 +240,3 @@ async createSchemaIfNotExists(schemaName) {
     async uploadTableWithIndexes(table, columns, tableData, indexesSql, _uniqueKeyColumns, _queryTracingObj, _externalOptions) {
-        if (!driver_interface_1.isDownloadTableMemoryData(tableData)) {
+        if (!(0, driver_interface_1.isDownloadTableMemoryData)(tableData)) {
             throw new Error(`${this.constructor} driver supports only rows upload`);
@@ -246,3 +246,3 @@ }
         try {
-            if (driver_interface_1.isDownloadTableMemoryData(tableData)) {
+            if ((0, driver_interface_1.isDownloadTableMemoryData)(tableData)) {
                 for (let i = 0; i < tableData.rows.length; i++) {
@@ -302,3 +302,3 @@ await this.query(`INSERT INTO ${table}
     cancelCombinator(fn) {
-        return utils_1.cancelCombinator(fn);
+        return (0, utils_1.cancelCombinator)(fn);
     }
@@ -305,0 +305,0 @@ setLogger(logger) {

dist/src/driver.interface.d.ts

 /// <reference types="node" />
-export declare type GenericDataBaseType = string;
+export type GenericDataBaseType = string;
 export interface TableColumn {
@@ -13,7 +13,7 @@ name: string;
 }
-export declare type TableStructure = TableColumn[];
-export declare type SchemaStructure = Record<string, TableStructure>;
-export declare type DatabaseStructure = Record<string, SchemaStructure>;
-export declare type Row = Record<string, unknown>;
-export declare type Rows = Row[];
+export type TableStructure = TableColumn[];
+export type SchemaStructure = Record<string, TableStructure>;
+export type DatabaseStructure = Record<string, SchemaStructure>;
+export type Row = Record<string, unknown>;
+export type Rows = Row[];
 export interface InlineTable {
@@ -24,3 +24,3 @@ name: string;
 }
-export declare type InlineTables = InlineTable[];
+export type InlineTables = InlineTable[];
 export interface DownloadTableBase {
@@ -79,3 +79,3 @@ /**
 }
-export declare type StreamTableDataWithTypes = StreamTableData & {
+export type StreamTableDataWithTypes = StreamTableData & {
     /**
@@ -87,3 +87,3 @@ * Some drivers know types of response
 export declare function isDownloadTableMemoryData(tableData: any): tableData is DownloadTableMemoryData;
-export declare type DownloadTableData = DownloadTableMemoryData | DownloadTableCSVData | StreamTableData | StreamingSourceTableData;
+export type DownloadTableData = DownloadTableMemoryData | DownloadTableCSVData | StreamTableData | StreamingSourceTableData;
 export interface ExternalDriverCompatibilities {
@@ -97,6 +97,6 @@ csvImport?: true;
 }
-export declare type StreamOptions = {
+export type StreamOptions = {
     highWaterMark: number;
 };
-export declare type StreamingSourceOptions = {
+export type StreamingSourceOptions = {
     streamOffset?: boolean;
@@ -107,7 +107,7 @@ };
 }
-export declare type DownloadQueryResultsOptions = StreamOptions & ExternalDriverCompatibilities & StreamingSourceOptions;
-export declare type IndexesSQL = {
+export type DownloadQueryResultsOptions = StreamOptions & ExternalDriverCompatibilities & StreamingSourceOptions;
+export type IndexesSQL = {
     sql: [string, unknown[]];
 }[];
-export declare type CreateTableIndex = {
+export type CreateTableIndex = {
     indexName: string;
@@ -117,15 +117,15 @@ type: string;
 };
-declare type UnloadQuery = {
+type UnloadQuery = {
     sql: string;
     params: unknown[];
 };
-export declare type UnloadOptions = {
+export type UnloadOptions = {
     maxFileSize: number;
     query?: UnloadQuery;
 };
-export declare type QueryOptions = {
+export type QueryOptions = {
     inlineTables?: InlineTables;
     [key: string]: any;
 };
-export declare type ExternalCreateTableOptions = {
+export type ExternalCreateTableOptions = {
     aggregationsColumns?: string[];
@@ -135,4 +135,4 @@ createTableIndexes?: CreateTableIndex[];
 };
-export declare type DownloadQueryResultsResult = DownloadQueryResultsBase & (DownloadTableMemoryData | DownloadTableCSVData | StreamTableData | StreamingSourceTableData | StreamTableDataWithTypes);
-export declare type TableQueryResult = {
+export type DownloadQueryResultsResult = DownloadQueryResultsBase & (DownloadTableMemoryData | DownloadTableCSVData | StreamTableData | StreamingSourceTableData | StreamTableDataWithTypes);
+export type TableQueryResult = {
     table_name?: string;
@@ -139,0 +139,0 @@ TABLE_NAME?: string;

dist/src/index.js

 "use strict";
 var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
     if (k2 === undefined) k2 = k;
-    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
+    var desc = Object.getOwnPropertyDescriptor(m, k);
+    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
+      desc = { enumerable: true, get: function() { return m[k]; } };
+    }
+    Object.defineProperty(o, k2, desc);
 }) : (function(o, m, k, k2) {
@@ -6,0 +10,0 @@ if (k2 === undefined) k2 = k;

dist/src/queue-driver.interface.d.ts

@@ -1,3 +0,3 @@
-export declare type QueryDef = unknown;
-export declare type QueryKey = (string | [string, any[]]) & {
+export type QueryDef = unknown;
+export type QueryKey = (string | [string, any[]]) & {
     persistent?: true;
@@ -8,5 +8,5 @@ };
 }
-export declare type AddToQueueResponse = [added: number, _b: any, _c: any, queueSize: number, addedToQueueTime: number];
-export declare type QueryStageStateResponse = [active: string[], toProcess: string[]] | [active: string[], toProcess: string[], defs: Record<string, QueryDef>];
-export declare type RetrieveForProcessingResponse = [added: any, removed: any, active: QueryKeyHash[], toProcess: any, def: QueryDef, lockAquired: boolean] | null;
+export type AddToQueueResponse = [added: number, _b: any, _c: any, queueSize: number, addedToQueueTime: number];
+export type QueryStageStateResponse = [active: string[], toProcess: string[]] | [active: string[], toProcess: string[], defs: Record<string, QueryDef>];
+export type RetrieveForProcessingResponse = [added: any, removed: any, active: QueryKeyHash[], toProcess: any, def: QueryDef, lockAquired: boolean] | null;
 export interface AddToQueueQuery {
@@ -13,0 +13,0 @@ isJob: boolean;

dist/src/utils.d.ts

 import { MaybeCancelablePromise } from '@cubejs-backend/shared';
-export declare type SaveCancelFn = <T>(promise: MaybeCancelablePromise<T>) => Promise<T>;
+export type SaveCancelFn = <T>(promise: MaybeCancelablePromise<T>) => Promise<T>;
 export declare function cancelCombinator(fn: any): any;
@@ -4,0 +4,0 @@ export declare class TableName {

package.json

@@ -5,3 +5,3 @@ {
   "author": "Cube Dev, Inc.",
-  "version": "0.31.58",
+  "version": "0.31.60",
   "repository": {
@@ -33,3 +33,3 @@ "type": "git",
   "dependencies": {
-    "@cubejs-backend/shared": "^0.31.57",
+    "@cubejs-backend/shared": "^0.31.60",
     "ramda": "^0.27.0"
@@ -43,3 +43,3 @@ },
     "jest": "^26.6.3",
-    "typescript": "~4.1.5"
+    "typescript": "~4.9.5"
   },
@@ -68,3 +68,3 @@ "license": "Apache-2.0",
   },
-  "gitHead": "a9ea09dac7102b2e3a6118c8f91b65c127023e23"
+  "gitHead": "3da3fc07f66506feba4e4b552246aefd8719bb29"
 }

No alert changes

Improved metrics

Total package byte prevSize

66067

increased by0.31%

Lines of code

691

increased by0.58%

Dependency changes

• Updated@cubejs-backend/shared@^0.31.60