this works better for some goddamn reason
This commit is contained in:
parent
d1036eb369
commit
7670cce279
1 changed files with 23 additions and 17 deletions
40
api/index.js
40
api/index.js
|
@ -173,24 +173,30 @@ server.listen(8080, () => {
|
||||||
log("TCP listening on port 8080");
|
log("TCP listening on port 8080");
|
||||||
});
|
});
|
||||||
|
|
||||||
const runJob = async (job, sock) => {
|
const runJob = (job, sock) => {
|
||||||
log(`Job ${job.uuid} starting...`, job.num);
|
return new Promise((resolve, reject) => {
|
||||||
|
log(`Job ${job.uuid} starting...`, job.num);
|
||||||
|
|
||||||
const object = JSON.parse(job.msg);
|
const object = JSON.parse(job.msg);
|
||||||
// If the image has a path, it must also have a type
|
// If the image has a path, it must also have a type
|
||||||
if (object.path && !object.type) {
|
if (object.path && !object.type) {
|
||||||
throw new TypeError("Unknown image type");
|
reject(new TypeError("Unknown image type"));
|
||||||
}
|
}
|
||||||
|
|
||||||
log(`Job ${job.uuid} started`, job.num);
|
log(`Job ${job.uuid} started`, job.num);
|
||||||
const data = await run(object).catch(e => { throw e; });
|
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;
|
||||||
jobObject.ext = data.fileExtension;
|
jobObject.ext = data.fileExtension;
|
||||||
jobs.set(job.uuid, jobObject);
|
jobs.set(job.uuid, jobObject);
|
||||||
sock.write(Buffer.concat([Buffer.from([0x1]), Buffer.from(job.uuid)]), (e) => {
|
sock.write(Buffer.concat([Buffer.from([0x1]), Buffer.from(job.uuid)]), (e) => {
|
||||||
if (e) throw e;
|
if (e) return reject(e);
|
||||||
|
return resolve();
|
||||||
|
});
|
||||||
|
return;
|
||||||
|
}).catch(e => {
|
||||||
|
reject(e);
|
||||||
|
});
|
||||||
});
|
});
|
||||||
return;
|
|
||||||
};
|
};
|
Loading…
Reference in a new issue