mini-starter/src/server/api/files/upload-policy/post.ts

import { createRoute, OpenAPIHono, z } from '@hono/zod-openapi';
import { FileService } from '@/server/modules/files/file.service';
import { FileSchema, CreateFileDto } from '@/server/modules/files/file.schema';
import { ErrorSchema } from '@/server/utils/errorHandler';
import { AppDataSource } from '@/server/data-source';
import { AuthContext } from '@/server/types/context';
import { authMiddleware } from '@/server/middleware/auth.middleware';
import { parseWithAwait } from '@/server/utils/parseWithAwait';


const CreateFileResponseSchema = z.object({
            file: FileSchema,
            uploadPolicy: z.object({
              'x-amz-algorithm': z.string(),
              'x-amz-credential': z.string(),
              'x-amz-date': z.string(),
              'x-amz-security-token': z.string().optional(),
              policy: z.string(),
              'x-amz-signature': z.string(),
              host: z.string(),
              key: z.string(),
              bucket: z.string()
            })
          });

// 创建文件上传策略路由
const createUploadPolicyRoute = createRoute({
  method: 'post',
  path: '/',
  middleware: [authMiddleware],
  request: {
    body: {
      content: {
        'application/json': { schema: CreateFileDto }
      }
    }
  },
  responses: {
    200: {
      description: '生成文件上传策略成功',
      content: {
        'application/json': {
          schema: CreateFileResponseSchema
        }
      }
    },
    400: {
      description: '请求参数错误',
      content: { 'application/json': { schema: ErrorSchema } }
    },
    500: {
      description: '服务器错误',
      content: { 'application/json': { schema: ErrorSchema } }
    }
  }
});


// 创建路由实例
const app = new OpenAPIHono<AuthContext>().openapi(createUploadPolicyRoute, async (c) => {
  try {
    const data = await c.req.json();
    const user = c.get('user');

    console.debug('user', user)
    
    // 创建文件服务实例
    const fileService = new FileService(AppDataSource);
    
    // 添加用户ID到文件数据
    const fileData = {
      ...data,
      uploadUserId: user.id,
      uploadTime: new Date()
    };
    const result = await fileService.createFile(fileData);
    console.debug('result', result)
    const typedResult = await parseWithAwait(CreateFileResponseSchema, result);
    return c.json(typedResult, 200);
  } catch (error) {
    if (error instanceof z.ZodError) {
      return c.json({
        code: 400,
        message: '参数错误',
        errors: error.issues
      }, 400);
    }
    const message = error instanceof Error ? error.message : '生成上传策略失败';
    return c.json({ code: 500, message }, 500);
  }
});

export default app;