From ef739de97046749c824938af67d5b59106e6b341 Mon Sep 17 00:00:00 2001
From: NGPixel <github@ngpixel.com>
Date: Sat, 5 Sep 2020 23:32:00 -0400
Subject: [PATCH] feat: purge history utility

---
 .../admin/admin-utilities-content.vue         | 79 ++++++++++++++++++-
 server/graph/resolvers/page.js                | 15 +++-
 server/graph/schemas/page.graphql             |  4 +
 server/models/pageHistory.js                  | 12 +++
 4 files changed, 108 insertions(+), 2 deletions(-)

diff --git a/client/components/admin/admin-utilities-content.vue b/client/components/admin/admin-utilities-content.vue
index e5003fba..ac2b64ca 100644
--- a/client/components/admin/admin-utilities-content.vue
+++ b/client/components/admin/admin-utilities-content.vue
@@ -8,7 +8,9 @@
       v-btn(outlined, color='primary', @click='rebuildTree', :disabled='loading').ml-0.mt-3
         v-icon(left) mdi-gesture-double-tap
         span Proceed
+
       v-divider.my-5
+
       .subtitle-1.pb-3.primary--text Rerender All Pages
       .body-2 All pages will be rendered again. Useful if internal links are broken or the rendering pipeline has changed.
       v-btn(outlined, color='primary', @click='rerenderPages', :disabled='loading', :loading='isRerendering').ml-0.mt-3
@@ -37,7 +39,9 @@
               rounded
               :buffer-value='0'
             )
+
       v-divider.my-5
+
       .subtitle-1.pb-3.pl-0.primary--text Migrate all pages to target locale
       .body-2 If you created content before selecting a different locale and activating the namespacing capabilities, you may want to transfer all content to the base locale.
       .body-2.red--text: strong This operation is destructive and cannot be reversed! Make sure you have proper backups!
@@ -65,6 +69,25 @@
       v-btn(outlined, color='primary', @click='migrateToLocale', :disabled='loading').ml-0.mt-3
         v-icon(left) mdi-gesture-double-tap
         span Proceed
+
+      v-divider.my-5
+
+      .subtitle-1.pb-3.pl-0.primary--text Purge Page History
+      .body-2 You may want to purge old history for pages to reduce database usage.
+      .body-2 This operation only affects the database and not any history saved by a storage module (e.g. git version history)
+      v-toolbar.radius-7.mt-5(flat, :color='$vuetify.theme.dark ? `grey darken-3-d5` : `grey lighten-4`', height='80')
+        v-select(
+          label='Delete history older than...'
+          outlined
+          hide-details
+          :items='purgeHistoryOptions'
+          item-text='title'
+          item-value='key'
+          v-model='purgeHistorySelection'
+        )
+      v-btn(outlined, color='primary', @click='purgeHistory', :disabled='loading').ml-0.mt-3
+        v-icon(left) mdi-gesture-double-tap
+        span Proceed
 </template>
 
 <script>
@@ -90,7 +113,18 @@ export default {
       renderTotal: 0,
       renderCurrentPath: '',
       sourceLocale: '',
-      targetLocale: ''
+      targetLocale: '',
+      purgeHistorySelection: 'P1Y',
+      purgeHistoryOptions: [
+        { key: 'P1D', title: 'Today' },
+        { key: 'P1M', title: '1 month' },
+        { key: 'P3M', title: '3 months' },
+        { key: 'P6M', title: '6 months' },
+        { key: 'P1Y', title: '1 year' },
+        { key: 'P2Y', title: '2 years' },
+        { key: 'P3Y', title: '3 years' },
+        { key: 'P5Y', title: '5 years' }
+      ]
     }
   },
   computed: {
@@ -231,6 +265,49 @@ export default {
 
       this.$store.commit(`loadingStop`, 'admin-utilities-content-migratelocale')
       this.loading = false
+    },
+    async purgeHistory () {
+      this.loading = true
+      this.$store.commit(`loadingStart`, 'admin-utilities-content-purgehistory')
+
+      try {
+        const respRaw = await this.$apollo.mutate({
+          mutation: gql`
+            mutation ($olderThan: String!) {
+              pages {
+                purgeHistory (
+                  olderThan: $olderThan
+                ) {
+                  responseResult {
+                    errorCode
+                    message
+                    slug
+                    succeeded
+                  }
+                }
+              }
+            }
+          `,
+          variables: {
+            olderThan: this.purgeHistorySelection
+          }
+        })
+        const resp = _.get(respRaw, 'data.pages.purgeHistory.responseResult', {})
+        if (resp.succeeded) {
+          this.$store.commit('showNotification', {
+            message: `Purged history successfully.`,
+            style: 'success',
+            icon: 'check'
+          })
+        } else {
+          throw new Error(resp.message)
+        }
+      } catch (err) {
+        this.$store.commit('pushGraphError', err)
+      }
+
+      this.$store.commit(`loadingStop`, 'admin-utilities-content-purgehistory')
+      this.loading = false
     }
   }
 }
diff --git a/server/graph/resolvers/page.js b/server/graph/resolvers/page.js
index e60ab8d4..1d16a9e4 100644
--- a/server/graph/resolvers/page.js
+++ b/server/graph/resolvers/page.js
@@ -562,11 +562,24 @@ module.exports = {
       } catch (err) {
         return graphHelper.generateError(err)
       }
+    },
+    /**
+     * Purge history
+     */
+    async purgeHistory (obj, args, context) {
+      try {
+        await WIKI.models.pageHistory.purge(args.olderThan)
+        return {
+          responseResult: graphHelper.generateSuccess('Page history purged successfully.')
+        }
+      } catch (err) {
+        return graphHelper.generateError(err)
+      }
     }
   },
   Page: {
     async tags (obj) {
-      return await WIKI.models.pages.relatedQuery('tags').for(obj.id)
+      return WIKI.models.pages.relatedQuery('tags').for(obj.id)
     }
     // comments(pg) {
     //   return pg.$relatedQuery('comments')
diff --git a/server/graph/schemas/page.graphql b/server/graph/schemas/page.graphql
index f6f43f2a..a230185c 100644
--- a/server/graph/schemas/page.graphql
+++ b/server/graph/schemas/page.graphql
@@ -149,6 +149,10 @@ type PageMutation {
     pageId: Int!
     versionId: Int!
   ): DefaultResponse @auth(requires: ["write:pages", "manage:pages", "manage:system"])
+
+  purgeHistory (
+    olderThan: String!
+  ): DefaultResponse @auth(requires: ["manage:system"])
 }
 
 # -----------------------------------------------
diff --git a/server/models/pageHistory.js b/server/models/pageHistory.js
index 1e7e9654..94429950 100644
--- a/server/models/pageHistory.js
+++ b/server/models/pageHistory.js
@@ -1,5 +1,6 @@
 const Model = require('objection').Model
 const _ = require('lodash')
+const { DateTime, Duration } = require('luxon')
 
 /* global WIKI */
 
@@ -228,4 +229,15 @@ module.exports = class PageHistory extends Model {
       total: history.total
     }
   }
+
+  /**
+   * Purge history older than X
+   *
+   * @param {String} olderThan ISO 8601 Duration
+   */
+  static async purge (olderThan) {
+    const dur = Duration.fromISO(olderThan)
+    const olderThanISO = DateTime.utc().minus(dur)
+    await WIKI.models.pageHistory.query().where('versionDate', '<', olderThanISO.toISO()).del()
+  }
 }