api.ts 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120
  1. import { OpenAPIHono } from '@hono/zod-openapi'
  2. import { swaggerUI } from '@hono/swagger-ui'
  3. import { errorHandler } from './utils/errorHandler'
  4. import usersRouter from './api/users/index'
  5. import authRoute from './api/auth/index'
  6. import rolesRoute from './api/roles/index'
  7. import fileRoutes from './api/files/index'
  8. import { AuthContext } from './types/context'
  9. import { AppDataSource } from './data-source'
  10. import { Hono } from 'hono'
  11. import { databaseBackup } from './utils/backup'
  12. if(!AppDataSource.isInitialized) {
  13. await AppDataSource.initialize();
  14. console.log('数据库初始化完成')
  15. // 启动数据库备份调度
  16. databaseBackup.startScheduledBackups();
  17. console.log('数据库备份调度已启动');
  18. }
  19. const app = new Hono();
  20. const api = new OpenAPIHono<AuthContext>()
  21. api.onError(errorHandler)
  22. // Rate limiting
  23. api.use('/api/v1/*', async (c, next) => {
  24. const ip = c.req.header('x-forwarded-for') || c.req.header('cf-connecting-ip')
  25. // 实现速率限制逻辑
  26. await next()
  27. })
  28. // // 数据库初始化中间件
  29. // api.use('/api/v1/*', async (c, next) => {
  30. // await next();
  31. // })
  32. // 注册Bearer认证方案
  33. api.openAPIRegistry.registerComponent('securitySchemes','bearerAuth',{
  34. type:'http',
  35. scheme:'bearer',
  36. bearerFormat:'JWT',
  37. description:'使用JWT进行认证'
  38. })
  39. // OpenAPI documentation endpoint
  40. // !import.meta.env.PROD
  41. if(1){
  42. // api.doc31('/doc', {
  43. // openapi: '3.1.0',
  44. // info: {
  45. // title: 'API Documentation',
  46. // version: '1.0.0'
  47. // },
  48. // security: [{
  49. // bearerAuth: []
  50. // }]
  51. // // servers: [{ url: '/api/v1' }]
  52. // })
  53. api.get('/doc', (c) => {
  54. const config = {
  55. openapi: '3.1.0',
  56. info: {
  57. title: 'API Documentation',
  58. version: '1.0.0'
  59. },
  60. security: [{
  61. bearerAuth: []
  62. }]
  63. // servers: [{ url: '/api/v1' }]
  64. };
  65. try {
  66. const document = api.getOpenAPI31Document(config);
  67. return c.json(document);
  68. } catch (e: any) {
  69. return c.json({
  70. error: 'OpenAPI document generation failed',
  71. message: e.message || 'Unknown error',
  72. stack: e.stack
  73. }, 500)
  74. }
  75. })
  76. app.get('/ui', swaggerUI({
  77. url: '/doc',
  78. persistAuthorization: true,
  79. manuallySwaggerUIHtml: (asset) => `
  80. <div>
  81. <div id="swagger-ui"></div>
  82. <link rel="stylesheet" href="https://ai-oss.d8d.fun/swagger-ui-dist/swagger-ui.css" />
  83. <script src="https://ai-oss.d8d.fun/swagger-ui-dist/swagger-ui-bundle.js" crossorigin="anonymous"></script>
  84. <script>
  85. window.onload = () => {
  86. window.ui = SwaggerUIBundle({
  87. dom_id: '#swagger-ui',
  88. url: '/doc',
  89. persistAuthorization: true
  90. })
  91. }
  92. </script>
  93. </div>
  94. `
  95. }))
  96. }
  97. export const userRoutes = api.route('/api/v1/users', usersRouter)
  98. export const authRoutes = api.route('/api/v1/auth', authRoute)
  99. export const roleRoutes = api.route('/api/v1/roles', rolesRoute)
  100. export const fileApiRoutes = api.route('/api/v1/files', fileRoutes)
  101. export type AuthRoutes = typeof authRoutes
  102. export type UserRoutes = typeof userRoutes
  103. export type RoleRoutes = typeof roleRoutes
  104. export type FileRoutes = typeof fileApiRoutes
  105. app.route('/', api)
  106. export default app