dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-25 12:06:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed import preview

Browse Source
This commit is contained in:
SPRINX0\prochazka
2025-01-07 17:52:26 +01:00
parent 2521f05526
commit 48eb8badec
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
packages/api/src/controllers/runners.js
View File

@@ -49,7 +49,8 @@ logger.info('Finished job script');
dbgateApi.runScript(run); dbgateApi.runScript(run);
`; `;
const loaderScriptTemplate = (functionName, props, runid) => ` const loaderScriptTemplate = (prefix, functionName, props, runid) => `
${prefix}
const dbgateApi = require(process.env.DBGATE_API); const dbgateApi = require(process.env.DBGATE_API);
dbgateApi.initializeApiEnvironment(); dbgateApi.initializeApiEnvironment();
${requirePluginsTemplate(extractShellApiPlugins(functionName, props))} ${requirePluginsTemplate(extractShellApiPlugins(functionName, props))}
@@ -107,8 +108,6 @@ module.exports = {
}, },
startCore(runid, scriptText) { startCore(runid, scriptText) {
// console.log('************* RUN SCRIPT *************');
// console.log(scriptText);
const directory = path.join(rundir(), runid); const directory = path.join(rundir(), runid);
const scriptFile = path.join(uploadsdir(), runid + '.js'); const scriptFile = path.join(uploadsdir(), runid + '.js');
fs.writeFileSync(`${scriptFile}`, scriptText); fs.writeFileSync(`${scriptFile}`, scriptText);
@@ -226,10 +225,14 @@ module.exports = {
loadReader_meta: true, loadReader_meta: true,
async loadReader({ functionName, props }) { async loadReader({ functionName, props }) {
const prefix = extractShellApiPlugins(functionName)
.map(packageName => `// @require ${packageName}\n`)
.join('');
const promise = new Promise((resolve, reject) => { const promise = new Promise((resolve, reject) => {
const runid = crypto.randomUUID(); const runid = crypto.randomUUID();
this.requests[runid] = [resolve, reject]; this.requests[runid] = [resolve, reject];
this.startCore(runid, loaderScriptTemplate(functionName, props, runid)); this.startCore(runid, loaderScriptTemplate(prefix, functionName, props, runid));
}); });
return promise; return promise;
}, },