Skip to content

Commit

Permalink
use window.eval
Browse files Browse the repository at this point in the history
  • Loading branch information
k2tzumi committed Mar 5, 2023
1 parent b737630 commit 7c16ee3
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions src/JobBroker.ts
Original file line number Diff line number Diff line change
Expand Up @@ -89,11 +89,12 @@ class JobBroker<T extends Parameter> {
scriptLock.releaseLock();

console.info(
`job starting. id: ${parameter.id}, created_at: ${parameter.created_at}, start_at: ${parameter.start_at}, parameter: ${parameter.parameter}`
`job starting. id: ${parameter.id}, handler: ${parameter.handler}, created_at: ${parameter.created_at}, start_at: ${parameter.start_at}, parameter: ${parameter.parameter}`
);

try {
const result = this[parameter.handler](
const foo = window;
const result = foo.eval(parameter.handler)(
JSON.parse(parameter.parameter)
);
if (!result) {
Expand All @@ -104,14 +105,14 @@ class JobBroker<T extends Parameter> {
parameter.end_at = this.now;
this.saveJob(popJob);
console.info(
`job success. id: ${parameter.id}, created_at: ${parameter.created_at}, start_at: ${parameter.start_at}, start_at: ${parameter.end_at}, parameter: ${parameter.parameter}`
`job success. id: ${parameter.id}, handler: ${parameter.handler}, created_at: ${parameter.created_at}, start_at: ${parameter.start_at}, start_at: ${parameter.end_at}, parameter: ${parameter.parameter}`
);
} catch (e) {
parameter.state = "failed";
parameter.end_at = this.now;
this.saveJob(popJob);
console.warn(
`job failed. message: ${e.message}, stack: ${e.stack}, id: ${parameter.id}, created_at: ${parameter.created_at}, start_at: ${parameter.start_at}, start_at: ${parameter.end_at}, parameter: ${parameter.parameter}`
`job failed. message: ${e.message}, stack: ${e.stack}, id: ${parameter.id}, handler: ${parameter.handler}, created_at: ${parameter.created_at}, start_at: ${parameter.start_at}, start_at: ${parameter.end_at}, parameter: ${parameter.parameter}`
);

this.purgeTimeoutQueue();
Expand Down

0 comments on commit 7c16ee3

Please # to comment.