murm/mrmBot-Matrix
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

hotfix moment

Browse source
This commit is contained in:
TheEssem 2021-04-29 18:55:58 -05:00
parent 41555424f4
commit 5a60e4be70
1 changed files with 20 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

24
api/index.js
View file

@ -2,7 +2,9 @@
require("dotenv").config(); require("dotenv").config();
const os = require("os"); const os = require("os");
const { run } = require("../utils/image-runner.js"); //const { run } = require("../utils/image-runner.js");
const { Worker } = require("worker_threads");
const path = require("path");
const net = require("net"); const net = require("net");
const http = require("http"); const http = require("http");
@ -184,7 +186,22 @@ const runJob = (job, sock) => {
} }
log(`Job ${job.uuid} started`, job.num); log(`Job ${job.uuid} started`, job.num);
run(object).then((data) => { const worker = new Worker(path.join(__dirname, "../utils/image-runner.js"), {
workerData: object
});
worker.on("message", (data) => {
log(`Sending result of job ${job.uuid} back to the bot`, job.num);
const jobObject = jobs.get(job.uuid);
jobObject.data = data.buffer;
jobObject.ext = data.fileExtension;
jobs.set(job.uuid, jobObject);
sock.write(Buffer.concat([Buffer.from([0x1]), Buffer.from(job.uuid)]), (e) => {
if (e) return reject(e);
return resolve();
});
});
worker.on("error", reject);
/*run(object).then((data) => {
log(`Sending result of job ${job.uuid} back to the bot`, job.num); log(`Sending result of job ${job.uuid} back to the bot`, job.num);
const jobObject = jobs.get(job.uuid); const jobObject = jobs.get(job.uuid);
jobObject.data = data.buffer; jobObject.data = data.buffer;
@ -194,9 +211,8 @@ const runJob = (job, sock) => {
if (e) return reject(e); if (e) return reject(e);
return resolve(); return resolve();
}); });
return;
}).catch(e => { }).catch(e => {
reject(e); reject(e);
}); });*/
}); });
}; };