From 0d7d71d22f5a81f1a6ac5d4f08a8c4701229d530 Mon Sep 17 00:00:00 2001
From: moonrailgun <moonrailgun@gmail.com>
Date: Mon, 29 May 2023 14:29:15 +0800
Subject: [PATCH] feat(admin-next): add cache manager

---
 server/admin-next/src/client/App.tsx          | 14 +++++--
 server/admin-next/src/client/i18n.ts          | 15 +++++++
 server/admin-next/src/client/routes/cache.tsx | 42 +++++++++++++++++++
 server/admin-next/src/server/router/api.ts    |  2 +
 server/admin-next/src/server/router/cache.ts  | 29 +++++++++++++
 5 files changed, 98 insertions(+), 4 deletions(-)
 create mode 100644 server/admin-next/src/client/routes/cache.tsx
 create mode 100644 server/admin-next/src/server/router/cache.ts

diff --git a/server/admin-next/src/client/App.tsx b/server/admin-next/src/client/App.tsx
index d177cec8..084bcf63 100644
--- a/server/admin-next/src/client/App.tsx
+++ b/server/admin-next/src/client/App.tsx
@@ -12,6 +12,7 @@ import {
   IconFile,
   IconMessage,
   IconSettings,
+  IconStorage,
   IconUser,
   IconUserGroup,
   IconWifi,
@@ -22,6 +23,7 @@ import { fileFields, groupFields, mailFields, messageFields } from './fields';
 import { i18n } from './i18n';
 import { httpClient } from './request';
 import { UserList } from './resources/user';
+import { CacheManager } from './routes/cache';
 import { TailchatNetwork } from './routes/network';
 import { SocketIOAdmin } from './routes/socketio';
 import { SystemConfig } from './routes/system';
@@ -95,10 +97,6 @@ function App() {
         list={<ListTable fields={mailFields} />}
       />
 
-      <CustomRoute name="system" icon={<IconSettings />}>
-        <SystemConfig />
-      </CustomRoute>
-
       <CustomRoute name="network" icon={<IconWifi />}>
         <TailchatNetwork />
       </CustomRoute>
@@ -106,6 +104,14 @@ function App() {
       <CustomRoute name="socketio" icon={<IconDashboard />}>
         <SocketIOAdmin />
       </CustomRoute>
+
+      <CustomRoute name="cache" icon={<IconStorage />}>
+        <CacheManager />
+      </CustomRoute>
+
+      <CustomRoute name="system" icon={<IconSettings />}>
+        <SystemConfig />
+      </CustomRoute>
     </Tushan>
   );
 }
diff --git a/server/admin-next/src/client/i18n.ts b/server/admin-next/src/client/i18n.ts
index 8a52bd5e..52aadd70 100644
--- a/server/admin-next/src/client/i18n.ts
+++ b/server/admin-next/src/client/i18n.ts
@@ -46,6 +46,12 @@ export const i18n: TushanContextProps['i18n'] = {
             serverName: 'Server Name',
             serverEntryImage: 'Server Entry Page Image',
           },
+          cache: {
+            cleanTitle: 'Are you sure you want to clear the cache?',
+            cleanDesc:
+              'Please be cautious in the production environment, clearing the cache may lead to increased pressure on the database in a short period of time',
+            cleanBtn: 'Clean Cache',
+          },
         },
       },
     },
@@ -132,6 +138,9 @@ export const i18n: TushanContextProps['i18n'] = {
           socketio: {
             name: 'Socket.IO 长链接',
           },
+          cache: {
+            name: '缓存管理',
+          },
         },
         custom: {
           action: {
@@ -170,6 +179,12 @@ export const i18n: TushanContextProps['i18n'] = {
             serverName: '服务器名',
             serverEntryImage: '服务器登录图',
           },
+          cache: {
+            cleanTitle: '确定要清理缓存么？',
+            cleanDesc:
+              '生产环境请谨慎操作, 清理缓存可能会导致短时间内数据库压力增加',
+            cleanBtn: '清理缓存',
+          },
         },
       },
     },
diff --git a/server/admin-next/src/client/routes/cache.tsx b/server/admin-next/src/client/routes/cache.tsx
new file mode 100644
index 00000000..c1c3207b
--- /dev/null
+++ b/server/admin-next/src/client/routes/cache.tsx
@@ -0,0 +1,42 @@
+import React from 'react';
+import {
+  Button,
+  Card,
+  Message,
+  Popconfirm,
+  useAsyncRequest,
+  useTranslation,
+} from 'tushan';
+import { request } from '../request';
+
+/**
+ * 缓存管理
+ */
+export const CacheManager: React.FC = React.memo(() => {
+  const { t } = useTranslation();
+  const [, cleanCache] = useAsyncRequest(async () => {
+    const { data } = await request.post('/cache/clean');
+
+    if (!data.success) {
+      Message.error(t('tushan.common.failed') + ':' + data.msg);
+      throw new Error(data.msg);
+    }
+
+    Message.success(t('tushan.common.success'));
+  });
+
+  return (
+    <Card>
+      <Popconfirm
+        title={t('custom.cache.cleanTitle')}
+        content={t('custom.cache.cleanDesc')}
+        onOk={cleanCache}
+      >
+        <Button type="primary" status="danger">
+          {t('custom.cache.cleanBtn')}
+        </Button>
+      </Popconfirm>
+    </Card>
+  );
+});
+CacheManager.displayName = 'CacheManager';
diff --git a/server/admin-next/src/server/router/api.ts b/server/admin-next/src/server/router/api.ts
index ffdc4cf3..9890e95b 100644
--- a/server/admin-next/src/server/router/api.ts
+++ b/server/admin-next/src/server/router/api.ts
@@ -9,6 +9,7 @@ import dayjs from 'dayjs';
 import userModel from '../../../../models/user/user';
 import messageModel from '../../../../models/chat/message';
 import { raExpressMongoose } from '../middleware/express-mongoose-ra-json-server';
+import { cacheRouter } from './cache';
 
 const router = Router();
 
@@ -46,6 +47,7 @@ router.post('/login', (req, res) => {
 router.use('/network', networkRouter);
 router.use('/config', configRouter);
 router.use('/file', fileRouter);
+router.use('/cache', cacheRouter);
 
 router.get('/user/count/summary', auth(), async (req, res) => {
   // 返回最近7天的用户数统计
diff --git a/server/admin-next/src/server/router/cache.ts b/server/admin-next/src/server/router/cache.ts
new file mode 100644
index 00000000..74cc4869
--- /dev/null
+++ b/server/admin-next/src/server/router/cache.ts
@@ -0,0 +1,29 @@
+import { Router } from 'express';
+import { broker } from '../broker';
+import { auth } from '../middleware/auth';
+
+const router = Router();
+
+/**
+ * 清理所有缓存
+ */
+router.post('/clean', auth(), async (req, res, next) => {
+  try {
+    if (!broker.cacher) {
+      res.json({
+        success: false,
+        message: 'Not found cacher',
+      });
+      return;
+    }
+    await broker.cacher.clean();
+
+    res.json({
+      success: true,
+    });
+  } catch (err) {
+    next(err);
+  }
+});
+
+export { router as cacheRouter };