⏸ Added a pause queue method
This commit is contained in:
@@ -104,6 +104,10 @@ export default class ApiService extends Service {
|
|||||||
{}
|
{}
|
||||||
);
|
);
|
||||||
break;
|
break;
|
||||||
|
case "LS_PAUSE_IMPORT_QUEUE":
|
||||||
|
console.log("lol")
|
||||||
|
await this.broker.call("queue.pauseImportQueue", action.data);
|
||||||
|
break;
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
// Add a disconnect listener
|
// Add a disconnect listener
|
||||||
|
|||||||
@@ -153,6 +153,13 @@ export default class QueueService extends Service {
|
|||||||
});
|
});
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
pauseImportQueue: {
|
||||||
|
rest: "POST /pauseImportQueue",
|
||||||
|
params: {},
|
||||||
|
handler: async (ctx: Context<{}>) => {
|
||||||
|
return await this.getQueue("process.import").resume();
|
||||||
|
}
|
||||||
|
},
|
||||||
unarchiveComicBook: {
|
unarchiveComicBook: {
|
||||||
rest: "POST /unarchiveComicBook",
|
rest: "POST /unarchiveComicBook",
|
||||||
params: {},
|
params: {},
|
||||||
|
|||||||
Reference in New Issue
Block a user