fix types in Materialize driver

Author: KSDaemon

packages/cubejs-materialize-driver/package.json

@@ -32,7 +32,6 @@
     "@cubejs-backend/shared": "^1.0.2",
     "@types/pg": "^8.6.0",
     "pg": "^8.6.0",
-    "ramda": "0.27.2",
     "semver": "7.3.7"
   },
   "license": "Apache-2.0",

packages/cubejs-materialize-driver/src/MaterializeDriver.ts

@@ -5,9 +5,16 @@
  */
 
 import { PostgresDriver, PostgresDriverConfiguration } from '@cubejs-backend/postgres-driver';
-import { BaseDriver, DownloadTableMemoryData, IndexesSQL, StreamOptions, StreamTableDataWithTypes, TableStructure } from '@cubejs-backend/base-driver';
+import {
+  BaseDriver,
+  DatabaseStructure,
+  DownloadTableMemoryData,
+  IndexesSQL,
+  StreamOptions,
+  StreamTableDataWithTypes,
+  TableStructure
+} from '@cubejs-backend/base-driver';
 import { PoolClient, QueryResult } from 'pg';
-import { reduce } from 'ramda';
 import { Readable } from 'stream';
 import semver from 'semver';
 
@@ -18,16 +25,6 @@ export type ReadableStreamTableDataWithTypes = StreamTableDataWithTypes & {
   rowStream: Readable;
 };
 
-export type SchemaResponse = {
-  [schema: string]: {
-    [schemaObject: string]: {
-      name: string;
-      type: string;
-      attributes: any[];
-  }[];
-  }
-};
-
 /**
  * Materialize driver class.
  */
@@ -73,6 +70,7 @@ export class MaterializeDriver extends PostgresDriver {
       /**
        * Application name to set for the connection.
        */
+      // eslint-disable-next-line camelcase
       application_name?: string,
     } = {},
   ) {
@@ -175,11 +173,11 @@ export class MaterializeDriver extends PostgresDriver {
     return version.split(' ')[0];
   }
 
-  public async tablesSchema(): Promise<SchemaResponse> {
+  public async tablesSchema(): Promise<DatabaseStructure> {
     const version = await this.getMaterializeVersion();
     const query = this.informationSchemaQueryWithFilter(version);
 
-    return this.query(query, []).then(data => reduce(this.informationColumnsSchemaReducer, {}, data));
+    return this.query(query, []).then(data => data.reduce<DatabaseStructure>(this.informationColumnsSchemaReducer, {}));
   }
 
   protected async* asyncFetcher<R extends unknown>(conn: PoolClient, cursorId: string): AsyncGenerator<R> {

yarn.lock

@@ -24487,16 +24487,16 @@ raf@^3.4.0:
   dependencies:
     performance-now "^2.1.0"
 
-[email protected], ramda@^0.27.2:
-  version "0.27.2"
-  resolved "https://registry.yarnpkg.com/ramda/-/ramda-0.27.2.tgz#84463226f7f36dc33592f6f4ed6374c48306c3f1"
-  integrity sha512-SbiLPU40JuJniHexQSAgad32hfwd+DRUdwF2PlVuI5RZD0/vahUco7R8vD86J/tcEKKF9vZrUVwgtmGCqlCKyA==
-
 ramda@^0.27.0, ramda@^0.27.1, ramda@~0.27.1:
   version "0.27.1"
   resolved "https://registry.yarnpkg.com/ramda/-/ramda-0.27.1.tgz#66fc2df3ef873874ffc2da6aa8984658abacf5c9"
   integrity sha512-PgIdVpn5y5Yns8vqb8FzBUEYn98V3xcPgawAkkgj0YJ0qDsnHCiNmZYfOGMgOvoB0eWFLpYbhxUR3mxfDIMvpw==
 
+ramda@^0.27.2:
+  version "0.27.2"
+  resolved "https://registry.yarnpkg.com/ramda/-/ramda-0.27.2.tgz#84463226f7f36dc33592f6f4ed6374c48306c3f1"
+  integrity sha512-SbiLPU40JuJniHexQSAgad32hfwd+DRUdwF2PlVuI5RZD0/vahUco7R8vD86J/tcEKKF9vZrUVwgtmGCqlCKyA==
+
 ramda@^0.28.0:
   version "0.28.0"
   resolved "https://registry.yarnpkg.com/ramda/-/ramda-0.28.0.tgz#acd785690100337e8b063cab3470019be427cc97"