diff --git a/services/message-delivery-method-web-push/src/server.ts b/services/message-delivery-method-web-push/src/server.ts index 12fa392..f5f678d 100644 --- a/services/message-delivery-method-web-push/src/server.ts +++ b/services/message-delivery-method-web-push/src/server.ts @@ -22,7 +22,9 @@ function limitStringLengthWithEllipsis(str: string, maxLength: number): string { } const start = async () => { + const checkedDatabases = await checkDatabases(); await setupVapidDetails(); + const serviceSeqTracker = await ServiceSeqTracker.Init( "_local/service:message-delivery-method-web-push", ); @@ -51,18 +53,14 @@ const start = async () => { }); console.info("Service started from sequence", serviceSeqTracker.lastSeq); - - // check dbs - await checkDatabases().then(({ messagesDb }) => { - if ( - parseInt(serviceSeqTracker.lastSeq.toString(), 10) === - parseInt(messagesDb.update_seq.toString(), 10) - ) { - console.log("Since is the last seq"); - } else { - console.log("Last seq is", messagesDb.update_seq); - } - }); + if ( + parseInt(serviceSeqTracker.lastSeq.toString(), 10) === + parseInt(checkedDatabases.messagesDb.update_seq.toString(), 10) + ) { + console.log("Since is the last seq"); + } else { + console.log("Last seq is", checkedDatabases.messagesDb.update_seq); + } await startHealthServer(abortController);