feat: utilities - cache

server/graph/resolvers/asset.js

@@ -154,6 +154,19 @@ module.exports = {
       } catch (err) {
         return graphHelper.generateError(err)
       }
+    },
+    /**
+     * Flush Temporary Uploads
+     */
+    async flushTempUploads(obj, args, context) {
+      try {
+        await WIKI.models.assets.flushTempUploads()
+        return {
+          responseResult: graphHelper.generateSuccess('Temporary Uploads have been flushed successfully.')
+        }
+      } catch (err) {
+        return graphHelper.generateError(err)
+      }
     }
   }
   // File: {

server/graph/resolvers/page.js

@@ -85,6 +85,16 @@ module.exports = {
         responseResult: graphHelper.generateSuccess('Page has been updated.'),
         page
       }
+    },
+    async flushCache(obj, args, context) {
+      try {
+        await WIKI.models.pages.flushCache()
+        return {
+          responseResult: graphHelper.generateSuccess('Pages Cache has been flushed successfully.')
+        }
+      } catch (err) {
+        return graphHelper.generateError(err)
+      }
     }
   },
   Page: {

server/graph/schemas/asset.graphql

@@ -44,6 +44,8 @@ type AssetMutation {
   deleteAsset(
     id: Int!
   ): DefaultResponse @auth(requires: ["manage:system", "manage:assets"])
+
+  flushTempUploads: DefaultResponse @auth(requires: ["manage:system"])
 }
 
 # -----------------------------------------------

server/graph/schemas/page.graphql

@@ -71,6 +71,8 @@ type PageMutation {
   delete(
     id: Int!
   ): DefaultResponse @auth(requires: ["delete:pages", "manage:system"])
+
+  flushCache: DefaultResponse @auth(requires: ["manage:system"])
 }
 
 # -----------------------------------------------

server/models/assets.js

@@ -164,4 +164,8 @@ module.exports = class Asset extends Model {
       res.sendStatus(404)
     }
   }
+
+  static async flushTempUploads() {
+    return fs.emptyDir(path.join(process.cwd(), `data/uploads`))
+  }
 }

server/models/pages.js

@@ -417,6 +417,10 @@ module.exports = class Page extends Model {
     return fs.remove(path.join(process.cwd(), `data/cache/${page.hash}.bin`))
   }
 
+  static async flushCache() {
+    return fs.emptyDir(path.join(process.cwd(), `data/cache`))
+  }
+
   static cleanHTML(rawHTML = '') {
     return striptags(rawHTML || '')
       .replace(emojiRegex(), '')