frishi/threetwo-core-service
1
0
Fork 0
Code Issues 2 Pull Requests 2 Actions Packages Projects Releases Wiki Activity

➕ Added the importSingleIssue action

Browse Source
This commit is contained in:
Rishi Ghan
2023-11-15 15:59:27 -06:00
parent c2bbbf311d
commit 7b0c0a7420
1 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
services/socket.service.ts
View File

@@ -134,14 +134,14 @@ export default class SocketService extends Service {
sessionRecord.length !== 0 && sessionRecord.length !== 0 &&
sessionRecord[0].sessionId === sessionId sessionRecord[0].sessionId === sessionId
) { ) {
// 2. Find if the queue has active jobs // 2. Find if the queue has active, paused or waiting jobs
const jobs: JobType = await this.broker.call( const jobs: JobType = await this.broker.call(
"jobqueue.getJobCountsByType", "jobqueue.getJobCountsByType",
{} {}
); );
const { active } = jobs; const { active, paused, waiting } = jobs;
if (active > 0) { if (active > 0 || paused > 0 || waiting > 0) {
// 3. Get job counts // 3. Get job counts
const completedJobCount = await pubClient.get( const completedJobCount = await pubClient.get(
"completedJobCount" "completedJobCount"
@@ -189,6 +189,15 @@ export default class SocketService extends Service {
{} {}
); );
}, },
importSingleIssue: async (ctx: Context<{}>) => {
console.info("AirDC++ finished a download -> ");
console.log(ctx.params);
// await this.broker.call(
// "library.importDownloadedComic",
// { bundle: data },
// {}
// );
},
}, },
methods: {}, methods: {},
async started() { async started() {