vodorod/parcer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: import loadIntegrations and saveIntegrations

Browse Source
This commit is contained in:
karishmas6
2024-09-19 17:49:15 +05:30
parent 98f531b3ec
commit 3c4a78e7f0
1 changed files with 3 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

54
server/src/routes/integration.ts
View File

@@ -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}`);
}
};
});