reformatted to PAT from oauth

Author: aadamgough

apps/sim/app/api/auth/oauth/utils.ts

@@ -69,7 +69,6 @@ export async function getOAuthToken(userId: string, providerId: string): Promise
       accessTokenExpiresAt: account.accessTokenExpiresAt,
       accountId: account.accountId,
       providerId: account.providerId,
-      password: account.password, // Include password field for Snowflake OAuth credentials
     })
     .from(account)
     .where(and(eq(account.userId, userId), eq(account.providerId, providerId)))
@@ -96,25 +95,8 @@ export async function getOAuthToken(userId: string, providerId: string): Promise
     )
 
     try {
-      // Extract account URL and OAuth credentials for Snowflake
-      let metadata: { accountUrl?: string; clientId?: string; clientSecret?: string } | undefined
-      if (providerId === 'snowflake' && credential.accountId) {
-        metadata = { accountUrl: credential.accountId }
-
-        // Extract clientId and clientSecret from the password field (stored as JSON)
-        if (credential.password) {
-          try {
-            const oauthCredentials = JSON.parse(credential.password)
-            metadata.clientId = oauthCredentials.clientId
-            metadata.clientSecret = oauthCredentials.clientSecret
-          } catch (e) {
-            logger.error('Failed to parse Snowflake OAuth credentials', { error: e })
-          }
-        }
-      }
-
       // Use the existing refreshOAuthToken function
-      const refreshResult = await refreshOAuthToken(providerId, credential.refreshToken!, metadata)
+      const refreshResult = await refreshOAuthToken(providerId, credential.refreshToken!)
 
       if (!refreshResult) {
         logger.error(`Failed to refresh token for user ${userId}, provider ${providerId}`, {
@@ -197,27 +179,9 @@ export async function refreshAccessTokenIfNeeded(
   if (shouldRefresh) {
     logger.info(`[${requestId}] Token expired, attempting to refresh for credential`)
     try {
-      // Extract account URL and OAuth credentials for Snowflake
-      let metadata: { accountUrl?: string; clientId?: string; clientSecret?: string } | undefined
-      if (credential.providerId === 'snowflake' && credential.accountId) {
-        metadata = { accountUrl: credential.accountId }
-
-        // Extract clientId and clientSecret from the password field (stored as JSON)
-        if (credential.password) {
-          try {
-            const oauthCredentials = JSON.parse(credential.password)
-            metadata.clientId = oauthCredentials.clientId
-            metadata.clientSecret = oauthCredentials.clientSecret
-          } catch (e) {
-            logger.error('Failed to parse Snowflake OAuth credentials', { error: e })
-          }
-        }
-      }
-
       const refreshedToken = await refreshOAuthToken(
         credential.providerId,
-        credential.refreshToken!,
-        metadata
+        credential.refreshToken!
       )
 
       if (!refreshedToken) {
@@ -289,28 +253,7 @@ export async function refreshTokenIfNeeded(
   }
 
   try {
-    // Extract account URL and OAuth credentials for Snowflake
-    let metadata: { accountUrl?: string; clientId?: string; clientSecret?: string } | undefined
-    if (credential.providerId === 'snowflake' && credential.accountId) {
-      metadata = { accountUrl: credential.accountId }
-
-      // Extract clientId and clientSecret from the password field (stored as JSON)
-      if (credential.password) {
-        try {
-          const oauthCredentials = JSON.parse(credential.password)
-          metadata.clientId = oauthCredentials.clientId
-          metadata.clientSecret = oauthCredentials.clientSecret
-        } catch (e) {
-          logger.error('Failed to parse Snowflake OAuth credentials', { error: e })
-        }
-      }
-    }
-
-    const refreshResult = await refreshOAuthToken(
-      credential.providerId,
-      credential.refreshToken!,
-      metadata
-    )
+    const refreshResult = await refreshOAuthToken(credential.providerId, credential.refreshToken!)
 
     if (!refreshResult) {
       logger.error(`[${requestId}] Failed to refresh token for credential`)