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

feat: use getIntegrationsFilePath() for writeDataToSheet

Browse Source
This commit is contained in:
karishmas6
2024-09-19 18:56:15 +05:30
parent 83dc427668
commit 99ceb6d41c
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -42,15 +42,15 @@ export async function updateGoogleSheet(fileName: string, runId: string) {
const integrationConfig = await loadIntegrations(fileName); const integrationConfig = await loadIntegrations(fileName);
if (integrationConfig) { if (integrationConfig) {
const { spreadsheetId, range, credentials } = integrationConfig; const { fileName, spreadsheetId, range, credentials } = integrationConfig;
if (spreadsheetId && range && credentials) { if (fileName && spreadsheetId && range && credentials) {
// Convert data to Google Sheets format (headers and rows) // Convert data to Google Sheets format (headers and rows)
const headers = Object.keys(data[0]); const headers = Object.keys(data[0]);
const rows = data.map((row: { [key: string]: any }) => Object.values(row)); const rows = data.map((row: { [key: string]: any }) => Object.values(row));
const outputData = [headers, ...rows]; const outputData = [headers, ...rows];
await writeDataToSheet(spreadsheetId, range, outputData); await writeDataToSheet(fileName, spreadsheetId, range, outputData);
logger.log('info', `Data written to Google Sheet successfully for ${fileName}_${runId}`); logger.log('info', `Data written to Google Sheet successfully for ${fileName}_${runId}`);
} }
} }
@@ -62,10 +62,10 @@ export async function updateGoogleSheet(fileName: string, runId: string) {
} }
}; };
export async function writeDataToSheet(spreadsheetId: string, range: string, data: any[]) { export async function writeDataToSheet(fileName: string, spreadsheetId: string, range: string, data: any[]) {
try { try {
const integrationCredentialsPath = path.join(__dirname, 'integrations.json'); const integrationCredentialsPath = getIntegrationsFilePath(fileName);
const integrationCredentials = JSON.parse(fs.readFileSync(integrationCredentialsPath, 'utf-8')); const integrationCredentials = JSON.parse(fs.readFileSync(integrationCredentialsPath, 'utf-8'));;
const auth = new google.auth.GoogleAuth({ const auth = new google.auth.GoogleAuth({
credentials: { credentials: {