remove pino

src/routes-simple/resources/upload.ts

@@ -9,6 +9,8 @@ import { User } from '@/models/user.ts';
 import fs from 'fs';
 import { ConfigModel } from '@/routes/config/models/model.ts';
 import { validateDirectory } from './util.ts';
+import { pick } from 'lodash-es';
+import { getFileStat } from '@/routes/file/index.ts';
 
 const cacheFilePath = useFileStore('cache-file', { needExists: true });
 
@@ -16,6 +18,77 @@ router.get('/api/s1/resources/upload', async (req, res) => {
   res.writeHead(200, { 'Content-Type': 'text/plain' });
   res.end('Upload API is ready');
 });
+export const parseIfJson = (data = '{}') => {
+  try {
+    const _data = JSON.parse(data);
+    if (typeof _data === 'object') return _data;
+    return {};
+  } catch (error) {
+    return {};
+  }
+};
+router.post('/api/s1/resources/upload/check', async (req, res) => {
+  const { tokenUser, token } = await checkAuth(req, res);
+  if (!tokenUser) {
+    res.end(error('Token is invalid.'));
+    return;
+  }
+  console.log('data', req.url);
+  const data = await router.getBody(req);
+  type Data = {
+    appKey: string;
+    version: string;
+    username: string;
+    directory: string;
+    files: { path: string; hash: string }[];
+  };
+  let { appKey, version, username, directory, files } = pick(data, ['appKey', 'version', 'username', 'directory', 'files']) as Data;
+  let uid = tokenUser.id;
+  if (username) {
+    const user = await User.getUserByToken(token);
+    const has = await user.hasUser(username, true);
+    if (!has) {
+      res.end(error('username is not found'));
+      return;
+    }
+    const _user = await User.findOne({ where: { username } });
+    uid = _user?.id || '';
+  }
+  if (!appKey || !version) {
+    res.end(error('appKey and version is required'));
+  }
+
+  const { code, message } = validateDirectory(directory);
+  if (code !== 200) {
+    res.end(error(message));
+    return;
+  }
+  type CheckResult = {
+    path: string;
+    stat: any;
+    resourcePath: string;
+    hash: string;
+    uploadHash: string;
+    isUpload?: boolean;
+  };
+  const checkResult: CheckResult[] = [];
+  for (let i = 0; i < files.length; i++) {
+    const file = files[i];
+    const relativePath = file.path;
+    const minioPath = `${username || tokenUser.username}/${appKey}/${version}${directory ? `/${directory}` : ''}/${relativePath}`;
+    let stat = await getFileStat(minioPath, true);
+    const statHash = stat?.etag || '';
+    checkResult.push({
+      path: relativePath,
+      uploadHash: file.hash,
+      resourcePath: minioPath,
+      isUpload: statHash === file.hash,
+      stat,
+      hash: statHash,
+    });
+  }
+  res.end(JSON.stringify({ code: 200, data: checkResult }));
+});
 
 // /api/s1/resources/upload
 router.post('/api/s1/resources/upload', async (req, res) => {
@@ -26,6 +99,7 @@ router.post('/api/s1/resources/upload', async (req, res) => {
   }
   const url = new URL(req.url || '', 'http://localhost');
   const share = !!url.searchParams.get('public');
+  const meta = parseIfJson(url.searchParams.get('meta'));
   const noCheckAppFiles = !!url.searchParams.get('noCheckAppFiles');
   // 使用 formi dable 解析 multipart/form-data
   const form = new IncomingForm({
@@ -106,6 +180,7 @@ router.post('/api/s1/resources/upload', async (req, res) => {
       if (share) {
         metadata.share = 'public';
       }
+      Object.assign(metadata, meta);
       await minioClient.fPutObject(bucketName, minioPath, tempPath, {
         'Content-Type': getContentType(relativePath),
         'app-source': 'user-app',