From 8156662e79110d445553f3f560e59dc764f058be Mon Sep 17 00:00:00 2001
From: Vasilii Mikhailovskii <ti.webdev@ya.ru>
Date: Tue, 3 Dec 2024 19:09:36 +0200
Subject: [PATCH] check db first

---
 .../src/server.ts                             | 22 +++++++++----------
 1 file changed, 10 insertions(+), 12 deletions(-)

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);