Update
This commit is contained in:
@@ -28,7 +28,6 @@ async function bootstrap() {
|
|||||||
`)
|
`)
|
||||||
);
|
);
|
||||||
|
|
||||||
|
|
||||||
await app.get(SqsPosterWorker).start();
|
await app.get(SqsPosterWorker).start();
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -25,13 +25,12 @@ export class SqsPosterWorker {
|
|||||||
await this.notifyService.sendMessageToTele(`🚀 Worker started for ${await this.sqs.getQueueName()}`)
|
await this.notifyService.sendMessageToTele(`🚀 Worker started for ${await this.sqs.getQueueName()}`)
|
||||||
|
|
||||||
//check cookie
|
//check cookie
|
||||||
if (!await this.xCacheService.isXCookiesAlive()) {
|
this.xCacheService.isXCookiesAlive().then(isLive => {
|
||||||
this.xRouterService.verifyCookie().catch((err) => {
|
this.logger.log(`cache cookie is ${isLive ? 'LIVE' : 'DIE'}`);
|
||||||
console.error(`SqsPosterWorker_verifyCookie`);
|
if (!isLive) {
|
||||||
console.error(err);
|
this.xRouterService.verifyCookie();
|
||||||
});
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
});
|
||||||
|
|
||||||
let ReceiptHandle = '';
|
let ReceiptHandle = '';
|
||||||
while (true) {
|
while (true) {
|
||||||
|
|||||||
Reference in New Issue
Block a user