fix: enable snowflake auth using key or token (#3878)

Author: mbani01

services/apps/snowflake_connectors/src/core/snowflakeExporter.ts

@@ -28,7 +28,7 @@ export class SnowflakeExporter {
   private readonly snowflake: SnowflakeClient
 
   constructor() {
-    this.snowflake = SnowflakeClient.fromToken({ parentLog: log })
+    this.snowflake = SnowflakeClient.fromEnv({ parentLog: log })
   }
 
   async destroy(): Promise<void> {

services/apps/snowflake_connectors/src/main.ts

@@ -9,7 +9,7 @@ import { Options, ServiceWorker } from '@crowd/archetype-worker'
 
 const config: Config = {
   envvars: [
-    'CROWD_SNOWFLAKE_ENABLED_PLATFORMS',
+    // 'CROWD_SNOWFLAKE_ENABLED_PLATFORMS', // allow optional to enable/disable worker
     'CROWD_SNOWFLAKE_S3_BUCKET_PATH',
     'CROWD_SNOWFLAKE_STORAGE_INTEGRATION',
     'CROWD_SNOWFLAKE_S3_REGION',

services/libs/snowflake/src/client.ts

@@ -179,28 +179,26 @@ export class SnowflakeClient {
   }
 
   public static fromEnv(extraConfig: any = {}) {
-    return new SnowflakeClient({
-      privateKeyString: process.env.CROWD_SNOWFLAKE_PRIVATE_KEY,
+    const base = {
       account: process.env.CROWD_SNOWFLAKE_ACCOUNT,
       username: process.env.CROWD_SNOWFLAKE_USERNAME,
       database: process.env.CROWD_SNOWFLAKE_DATABASE,
       warehouse: process.env.CROWD_SNOWFLAKE_WAREHOUSE,
       role: process.env.CROWD_SNOWFLAKE_ROLE,
       maxConnections: 1,
       ...extraConfig,
-    })
-  }
+    }
+
+    if (process.env.CROWD_SNOWFLAKE_TOKEN) {
+      return new SnowflakeClient({
+        token: process.env.CROWD_SNOWFLAKE_TOKEN,
+        ...base,
+      })
+    }
 
-  public static fromToken(extraConfig: any = {}) {
     return new SnowflakeClient({
-      token: process.env.CROWD_SNOWFLAKE_TOKEN,
-      account: process.env.CROWD_SNOWFLAKE_ACCOUNT,
-      username: process.env.CROWD_SNOWFLAKE_USERNAME,
-      database: process.env.CROWD_SNOWFLAKE_DATABASE,
-      warehouse: process.env.CROWD_SNOWFLAKE_WAREHOUSE,
-      role: process.env.CROWD_SNOWFLAKE_ROLE,
-      maxConnections: 1,
-      ...extraConfig,
+      privateKeyString: process.env.CROWD_SNOWFLAKE_PRIVATE_KEY,
+      ...base,
     })
   }
 }