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

feat: use fileName for integration files

Browse Source
This commit is contained in:
karishmas6
2024-09-19 18:40:45 +05:30
parent 444875bda7
commit 83dc427668
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
server/src/workflow-management/integrations/gsheet.ts
View File

@@ -3,8 +3,6 @@ import fs from 'fs';
import path from 'path'; import path from 'path';
import logger from "../../logger"; import logger from "../../logger";
import { readFile } from "../storage"; import { readFile } from "../storage";
interface GoogleSheetUpdateTask { interface GoogleSheetUpdateTask {
name: string; name: string;
runId: string; runId: string;
@@ -18,18 +16,20 @@ export let googleSheetUpdateTasks: { [runId: string]: GoogleSheetUpdateTask } =
// *** Temporary Path to the JSON file that will store the integration details *** // *** Temporary Path to the JSON file that will store the integration details ***
const integrationsFilePath = path.join(__dirname, 'integrations.json'); const getIntegrationsFilePath = (fileName: string) => path.join(__dirname, `integrations-${fileName}.json`);
export function loadIntegrations() { export function loadIntegrations(fileName: string) {
if (fs.existsSync(integrationsFilePath)) { const filePath = getIntegrationsFilePath(fileName);
const data = fs.readFileSync(integrationsFilePath, 'utf-8'); if (fs.existsSync(filePath)) {
const data = fs.readFileSync(filePath, 'utf-8');
return JSON.parse(data); return JSON.parse(data);
} }
return {}; return {};
} }
export function saveIntegrations(integrations: any) { export function saveIntegrations(fileName: string, integrations: any) {
fs.writeFileSync(integrationsFilePath, JSON.stringify(integrations, null, 2)); const filePath = getIntegrationsFilePath(fileName);
fs.writeFileSync(filePath, JSON.stringify(integrations, null, 2));
} }
export async function updateGoogleSheet(fileName: string, runId: string) { export async function updateGoogleSheet(fileName: string, runId: string) {
@@ -39,7 +39,7 @@ export async function updateGoogleSheet(fileName: string, runId: string) {
if (parsedRun.status === 'success' && parsedRun.serializableOutput) { if (parsedRun.status === 'success' && parsedRun.serializableOutput) {
const data = parsedRun.serializableOutput['item-0'] as { [key: string]: any }[]; const data = parsedRun.serializableOutput['item-0'] as { [key: string]: any }[];
const integrationConfig = await loadIntegrations(); const integrationConfig = await loadIntegrations(fileName);
if (integrationConfig) { if (integrationConfig) {
const { spreadsheetId, range, credentials } = integrationConfig; const { spreadsheetId, range, credentials } = integrationConfig;