app.ts 2.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
  1. import Koa from 'koa';
  2. import cors from '@koa/cors';
  3. import Router from '@koa/router';
  4. import bodyParser from '@koa/bodyparser';
  5. import serve from 'koa-static';
  6. import mount from 'koa-mount';
  7. import path from 'path';
  8. import { config } from './config';
  9. import { connectDatabase } from './models';
  10. import { errorHandler } from './middleware/errorHandler';
  11. import authRoutes from './modules/auth/auth.controller';
  12. import ttsRoutes from './modules/tts/tts.controller';
  13. import audioRoutes from './modules/audio/audio.controller';
  14. import memberRoutes from './modules/member/member.controller';
  15. import shareRoutes from './modules/share/share.controller';
  16. import aiRoutes from './modules/ai/ai.controller';
  17. import playerRoutes from './modules/player/player.controller';
  18. import favoritesRoutes from './modules/favorites/favorites.controller';
  19. import preferencesRoutes from './modules/preferences/preferences.controller';
  20. import searchRoutes from './modules/search/search.controller';
  21. import categoriesRoutes from './modules/categories/categories.controller';
  22. import commentsRoutes from './modules/comments/comments.controller';
  23. import notificationsRoutes from './modules/notifications/notifications.controller';
  24. const app = new Koa();
  25. const router = new Router();
  26. // 中间件
  27. app.use(errorHandler);
  28. app.use(cors({
  29. origin: '*',
  30. allowMethods: ['GET', 'POST', 'PUT', 'DELETE', 'OPTIONS'],
  31. allowHeaders: ['Content-Type', 'Authorization'],
  32. }));
  33. app.use(bodyParser());
  34. // 静态文件服务 - 音频文件
  35. app.use(mount('/uploads', serve(config.upload.dir)));
  36. // 健康检查
  37. router.get('/health', (ctx) => {
  38. ctx.body = { code: 0, message: 'ok', data: { status: 'healthy' } };
  39. });
  40. // 注册路由
  41. router.use('/api/auth', authRoutes.routes());
  42. router.use('/api/tts', ttsRoutes.routes());
  43. router.use('/api/audio', audioRoutes.routes());
  44. router.use('/api/member', memberRoutes.routes());
  45. router.use('/api/share', shareRoutes.routes());
  46. router.use('/api/ai', aiRoutes.routes());
  47. router.use('/api/player', playerRoutes.routes());
  48. router.use('/api/favorites', favoritesRoutes.routes());
  49. router.use('/api/user/preferences', preferencesRoutes.routes());
  50. router.use('/api/search', searchRoutes.routes());
  51. router.use('/api/categories', categoriesRoutes.routes());
  52. router.use('/api/comments', commentsRoutes.routes());
  53. router.use('/api/notifications', notificationsRoutes.routes());
  54. app.use(router.routes()).use(router.allowedMethods());
  55. // 启动服务
  56. async function start() {
  57. try {
  58. await connectDatabase();
  59. console.log('✅ MySQL 连接成功');
  60. app.listen(config.port, () => {
  61. console.log(`🚀 服务启动成功: http://localhost:${config.port}`);
  62. console.log(`📁 上传目录: ${config.upload.dir}`);
  63. });
  64. } catch (error) {
  65. console.error('❌ 服务启动失败:', error);
  66. process.exit(1);
  67. }
  68. }
  69. start();