feat: init

Author: johancube

packages/cubejs-backend-shared/src/env.ts

@@ -1413,6 +1413,19 @@ const variables: Record<string, (...args: any) => any> = {
     ]
   ),
 
+  /**
+   * Snowflake OAuth token path.
+   */
+  snowflakeOAuthTokenPath: ({
+    dataSource
+  }: {
+    dataSource: string,
+  }) => (
+    process.env[
+      keyByDataSource('CUBEJS_DB_SNOWFLAKE_OAUTH_TOKEN_PATH', dataSource)
+    ]
+  ),
+
   /**
    * Snowflake private key.
    */

packages/cubejs-snowflake-driver/src/SnowflakeDriver.ts

@@ -24,6 +24,7 @@ import {
   DriverCapabilities,
 } from '@cubejs-backend/base-driver';
 import { formatToTimeZone } from 'date-fns-timezone';
+import fs from 'fs/promises';
 import { HydrationMap, HydrationStream } from './HydrationStream';
 
 // eslint-disable-next-line import/order
@@ -163,6 +164,7 @@ interface SnowflakeDriverOptions {
   clientSessionKeepAlive?: boolean,
   database?: string,
   authenticator?: string,
+  token?: string,
   privateKeyPath?: string,
   privateKeyPass?: string,
   privateKey?: string,
@@ -207,7 +209,8 @@ export class SnowflakeDriver extends BaseDriver implements DriverInterface {
       'CUBEJS_DB_SNOWFLAKE_CLIENT_SESSION_KEEP_ALIVE',
       'CUBEJS_DB_SNOWFLAKE_AUTHENTICATOR',
       'CUBEJS_DB_SNOWFLAKE_PRIVATE_KEY_PATH',
-      'CUBEJS_DB_SNOWFLAKE_PRIVATE_KEY_PASS'
+      'CUBEJS_DB_SNOWFLAKE_PRIVATE_KEY_PASS',
+      'CUBEJS_DB_SNOWFLAKE_OAUTH_TOKEN_PATH',
     ];
   }
 
@@ -388,11 +391,28 @@ export class SnowflakeDriver extends BaseDriver implements DriverInterface {
     return undefined;
   }
 
+  private async readOAuthToken(dataSource: string) {
+    const tokenPath = getEnv('snowflakeOAuthTokenPath', { dataSource });
+    const token = await fs.readFile(tokenPath, 'utf8');
+    return token.trim();
+  }
+
+  private async createConnection() {
+    if (this.config.authenticator?.toUpperCase() === 'OAUTH') {
+      this.config.token = await this.readOAuthToken(this.config.dataSource);
+    }
+
+    const connection = snowflake.createConnection(this.config);
+
+    return connection;
+  }
+
   /**
    * Test driver's connection.
    */
   public async testConnection() {
-    const connection = snowflake.createConnection(this.config);
+    const connection = await this.createConnection();
+
     await new Promise(
       (resolve, reject) => connection.connect((err, conn) => (err ? reject(err) : resolve(conn)))
     );
@@ -411,7 +431,8 @@ export class SnowflakeDriver extends BaseDriver implements DriverInterface {
    */
   protected async initConnection() {
     try {
-      const connection = snowflake.createConnection(this.config);
+      const connection = await this.createConnection();
+
       await new Promise(
         (resolve, reject) => connection.connect((err, conn) => (err ? reject(err) : resolve(conn)))
       );