Elgato_dark/ToolJet
1
0
Fork 0
mirror of https://github.com/ToolJet/ToolJet synced 2026-05-23 08:58:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

Conditionally parse and decode api response (#12151)

Browse source
This commit is contained in:
Parth 2025-03-07 11:34:30 +05:30 committed by GitHub
parent 0fa90ee875
commit 72b51f6165
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 18 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
server/src/modules/data-sources/service.ts
View file

@ -61,11 +61,24 @@ export class DataSourcesService implements IDataSourcesService {
environmentId: selectedEnvironmentId,
});
for (const dataSource of dataSources) {
if (dataSource.pluginId) {
dataSource.plugin.iconFile.data = dataSource.plugin.iconFile.data.toString('utf8');
dataSource.plugin.manifestFile.data = JSON.parse(decode(dataSource.plugin.manifestFile.data.toString('utf8')));
dataSource.plugin.operationsFile.data = JSON.parse(
decode(dataSource.plugin.operationsFile.data.toString('utf8'))
const parseIfNeeded = (data: any) => {
if (typeof data === 'object' && data !== null) return data;
if (Buffer.isBuffer(data) || typeof data === 'string') {
return JSON.parse(decode(data.toString('utf8')));
}
return data;
};
try {
if (dataSource.pluginId) {
if (Buffer.isBuffer(dataSource.plugin.iconFile.data)) {
dataSource.plugin.iconFile.data = dataSource.plugin.iconFile.data.toString('utf8');
}
dataSource.plugin.manifestFile.data = parseIfNeeded(dataSource.plugin.manifestFile.data);
dataSource.plugin.operationsFile.data = parseIfNeeded(dataSource.plugin.operationsFile.data);
}
} catch (error) {
throw new BadRequestException(
`Error parsing plugin data for dataSourceId: ${dataSource.id}. Details: ${error.message}`
);
}
}