add db cleaning

pyatyispyatil · Feb 6, 2020 · 907653a · 907653a
1 parent 3acf878
commit 907653a
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 1 deletion.
diff --git a/src/bot.js b/src/bot.js
@@ -13,7 +13,7 @@ const API_TOKEN = config.telegram.token || '';
 const PROXY_OPTIONS = config.telegram.proxy || '';
 
 const PREVIEW_RELEASES_COUNT = -10;
-const FIRST_UPDATE_RELEASES_COUNT = 20;
+const FIRST_UPDATE_RELEASES_COUNT = 5;
 const UPDATE_INTERVAL = Math.floor((config.app.updateInterval / 60) * 100) / 100;
 
 

diff --git a/src/db.js b/src/db.js
@@ -132,6 +132,21 @@ class DB {
     return await this.repos.find({}, {name: 1, owner: 1, watchedUsers: 1, _id: 0}).toArray();
   }
 
+  async clearReleases() {
+    return await Promise.all([
+      this.repos.update(
+        { "releases.5": { "$exists": 1 } },
+        { "$push": { "releases": { "$each": [], "$slice": -5 } } },
+        { "multi": true }
+      ),
+      this.repos.update(
+        { "tags.5": { "$exists": 1 } },
+        { "$push": { "tags": { "$each": [], "$slice": -5 } } },
+        { "multi": true }
+      )
+    ]);
+  }
+
   async updateRepo(owner, name, {releases: newReleases, tags: newTags}) {
     const {releases, tags} = await this.repos.findOne({owner, name});
 

diff --git a/src/index.js b/src/index.js
@@ -39,6 +39,7 @@ const run = async () => {
 
   const updateReleases = async () => {
     try {
+      await db.clearReleases();
       const repos = await db.getAllReposNames();
       const updates = await getManyVersionsInBunches(repos.map(({owner, name}) => ({owner, name})), 1);