feat(server): prune cache

yjl9903 · Jun 11, 2024 · edc2fc4 · edc2fc4
1 parent 36e3492
commit edc2fc4
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/packages/server/src/admin/index.ts b/packages/server/src/admin/index.ts
@@ -1,10 +1,17 @@
 import { registerApp } from '../app';
 
+import { pruneResourcesCache } from '../query/resources';
+
 import { syncDocuments } from './meili';
 import { fixDmhyResources, refreshDmhyResources } from './dmhy';
 
 export function registerAdmin() {
   registerApp((app) => {
+    app.delete(`/admin/dmhy/resources/cache`, async (req) => {
+      await pruneResourcesCache();
+      return req.json({ ok: true });
+    });
+
     app.post(`/admin/dmhy/resources`, async (req) => {
       const r = await refreshDmhyResources();
       return req.json(r);

diff --git a/packages/server/src/query/resources.ts b/packages/server/src/query/resources.ts
@@ -27,6 +27,10 @@ const logger = rootLogger.forkIntegrationLogger('detail');
 
 const resourcesStorage = prefixStorage(storage, 'resources');
 
+export async function pruneResourcesCache() {
+  await resourcesStorage.clear();
+}
+
 export async function queryResources(ctx: Context, filter: ResolvedFilterOptions) {
   if (filter.search) {
     const resp = await searchResources(filter.search.join(' '), filter);