feat: add unlimited upload api in admin

msgbyte · Mar 10, 2023 · 5ab4829 · 5ab4829
1 parent e6bc8fe
commit 5ab4829
Show file tree

Hide file tree

Showing 8 changed files with 126 additions and 38 deletions.
diff --git a/docker-compose.env b/docker-compose.env
@@ -11,7 +11,6 @@ MONGO_URL=mongodb://mongo/tailchat
 SECRET=
 
 # file
-STAIC_HOST="{BACKEND}"
 API_URL=https://tailchat-nightly.moonrailgun.com
 
 # minio

diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
diff --git a/server/.env.example b/server/.env.example
@@ -10,7 +10,6 @@ REDIS_URL=redis://localhost:6379/
 TRANSPORTER=
 
 # 填写服务端可访问的接口地址
-STAIC_HOST="{BACKEND}"
 API_URL=
 
 # 文件存储

diff --git a/server/admin/app/server/broker.ts b/server/admin/app/server/broker.ts
@@ -13,9 +13,15 @@ broker.start().then(() => {
   console.log('Linked to Tailchat network, TRANSPORTER: ', transporter);
 });
 
-export function call<T>(actionName: string, params: any): Promise<T> {
+export function callBrokerAction<T>(
+  actionName: string,
+  params: any,
+  opts?: Record<string, any>
+): Promise<T> {
   return broker.call(actionName, params, {
+    ...opts,
     meta: {
+      ...opts?.meta,
       userId: SYSTEM_USERID,
     },
   });

diff --git a/server/admin/app/server/router/api.ts b/server/admin/app/server/router/api.ts
@@ -1,10 +1,11 @@
 import { Router } from 'express';
 import raExpressMongoose from 'express-mongoose-ra-json-server';
 import jwt from 'jsonwebtoken';
-import { call } from '../broker';
+import { callBrokerAction } from '../broker';
 import { adminAuth, auth, authSecret } from '../middleware/auth';
 import { configRouter } from './config';
 import { networkRouter } from './network';
+import { fileRouter } from './upload';
 
 const router = Router();
 
@@ -41,6 +42,7 @@ router.post('/login', (req, res) => {
 
 router.use('/network', networkRouter);
 router.use('/config', configRouter);
+router.use('/file', fileRouter);
 
 router.use(
   '/users',
@@ -52,7 +54,7 @@ router.use(
 router.delete('/messages/:id', auth(), async (req, res) => {
   try {
     const messageId = req.params.id;
-    await call('chat.message.deleteMessage', {
+    await callBrokerAction('chat.message.deleteMessage', {
       messageId,
     });