( apiKey: string, instanceUrl: string, userId: string, )
| 1077 | }; |
| 1078 | |
| 1079 | export const queueWakApiImport = ( |
| 1080 | apiKey: string, |
| 1081 | instanceUrl: string, |
| 1082 | userId: string, |
| 1083 | ): string => { |
| 1084 | const jobId = randomUUID(); |
| 1085 | const importJob = createInitialImportJob( |
| 1086 | jobId, |
| 1087 | userId, |
| 1088 | "wakapi", |
| 1089 | `WakAPI Import ${new Date().toISOString()}`, |
| 1090 | ); |
| 1091 | activeJobs.set(jobId, importJob); |
| 1092 | |
| 1093 | const job: QueueJob = { |
| 1094 | id: jobId, |
| 1095 | type: "wakapi", |
| 1096 | userId, |
| 1097 | data: { apiKey, instanceUrl }, |
| 1098 | createdAt: new Date(), |
| 1099 | }; |
| 1100 | return importQueue.addJob(job); |
| 1101 | }; |
| 1102 | |
| 1103 | export const getQueueStatus = () => importQueue.getStatus(); |
| 1104 |
no test coverage detected