From 3c4a78e7f08de5518fa37084fedc827608a93aed Mon Sep 17 00:00:00 2001
From: karishmas6 <carishmashukla28@gmail.com>
Date: Thu, 19 Sep 2024 17:49:15 +0530
Subject: [PATCH] feat: import loadIntegrations and saveIntegrations

---
 server/src/routes/integration.ts | 54 ++------------------------------
 1 file changed, 3 insertions(+), 51 deletions(-)

diff --git a/server/src/routes/integration.ts b/server/src/routes/integration.ts
index e05c14f4..1be3a85c 100644
--- a/server/src/routes/integration.ts
+++ b/server/src/routes/integration.ts
@@ -2,35 +2,17 @@ import { Router } from 'express';
 import fs from 'fs';
 import path from 'path';
 import logger from "../logger";
-import { writeDataToSheet } from "../workflow-management/integrations/gsheet"
-import { readFile } from "../workflow-management/storage";
-
+import { loadIntegrations, saveIntegrations } from '../workflow-management/integrations/gsheet';
 
 export const router = Router();
 
-// Temproary Path to the JSON file that will store the integration details
-const integrationsFilePath = path.join(__dirname, 'integrations.json');
-
-export function loadIntegrations() {
-  if (fs.existsSync(integrationsFilePath)) {
-    const data = fs.readFileSync(integrationsFilePath, 'utf-8');
-    return JSON.parse(data);
-  }
-  return {};
-}
-
-function saveIntegrations(integrations: any) {
-  fs.writeFileSync(integrationsFilePath, JSON.stringify(integrations, null, 2));
-}
-
 router.post('/upload-credentials', async (req, res) => {
   try {
     const { fileName, credentials, spreadsheetId, range } = req.body;
     if (!fileName || !credentials || !spreadsheetId || !range) {
       return res.status(400).json({ message: 'Credentials, Spreadsheet ID, and Range are required.' });
     }
-    // Store the credentials in a secure place (for test, we store them locally)
-    // Load existing integrations from the JSON file
+    // *** TEMPORARILY WE STORE CREDENTIALS HERE ***
     const integrations = loadIntegrations();
     integrations[fileName] = { fileName, spreadsheetId, range, credentials };
     saveIntegrations(integrations);
@@ -40,34 +22,4 @@ router.post('/upload-credentials', async (req, res) => {
     logger.log('error', `Error saving credentials: ${error.message}`);
     return res.status(500).json({ message: 'Failed to save credentials.', error: error.message });
   }
-});
-
-export async function updateGoogleSheet(fileName: string, runId: string) {
-  try {
-    const run = await readFile(`./../storage/runs/${fileName}_${runId}.json`);
-    const parsedRun = JSON.parse(run);
-
-    if (parsedRun.status === 'success' && parsedRun.serializableOutput) {
-      const data = parsedRun.serializableOutput['item-0'] as { [key: string]: any }[];
-      const integrationConfig = await loadIntegrations();
-
-      if (integrationConfig) {
-        const { spreadsheetId, range, credentials } = integrationConfig;
-
-        if (spreadsheetId && range && credentials) {
-          // Convert data to Google Sheets format (headers and rows)
-          const headers = Object.keys(data[0]);
-          const rows = data.map((row: { [key: string]: any }) => Object.values(row));
-          const outputData = [headers, ...rows];
-
-          await writeDataToSheet(spreadsheetId, range, outputData);
-          logger.log('info', `Data written to Google Sheet successfully for ${fileName}_${runId}`);
-        }
-      }
-      logger.log('error', `Google Sheet integration not configured for ${fileName}_${runId}`);
-    }
-    logger.log('error', `Run not successful or no data to update for ${fileName}_${runId}`);
-  } catch (error: any) {
-    logger.log('error', `Failed to write data to Google Sheet for ${fileName}_${runId}: ${error.message}`);
-  }
-};
\ No newline at end of file
+});
\ No newline at end of file