Save messages after check

Dockerfile

@@ -10,6 +10,7 @@ WORKDIR /usr/src/app
 ENV NODE_ENV=production
 
 COPY ["package.json", "yarn.lock", ".yarnrc.yml", "/usr/src/app/"]
+COPY ".yarn" /usr/src/app/.yarn
 
 RUN yarn install
 

package.json

@@ -1,6 +1,6 @@
 {
     "name": "rss-telegram-bot",
-    "version": "1.0.4",
+    "version": "1.0.8",
     "main": "lib/index.js",
     "author": "Fabian Stamm <dev@fabianstamm.de>",
     "license": "MIT",

src/index.ts

@@ -2,7 +2,7 @@
 // require('ssl-root-cas').inject();
 process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0";
 
-import Logging from "@hibas123/nodelogging";
+import * as _Logging from "@hibas123/nodelogging";
 import { createHash } from "crypto";
 import * as dotenv from "dotenv";
 import { decode } from "html-entities";
@@ -14,6 +14,7 @@ import { message } from "telegraf/filters";
 import * as fs from "fs";
 import lodash from 'lodash'
 
+const Logging = (_Logging.default as any).default as typeof _Logging.default;
 
 Promise.resolve().then(async () => {
     const { Low, LowSync } = await import("lowdb");
@@ -217,7 +218,9 @@ Promise.resolve().then(async () => {
     }
 
     function checkAll() {
-        Database.getAll().map(feed => checkFeed(feed).catch(err => Logging.error(err)));
+        Database.getAll().map(feed => checkFeed(feed).catch(err => Logging.error(err)).finally(() => {
+            db.write();
+        }));
     }
 
     setInterval(() => {