routes_migrations.ts 1.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041
  1. import { Hono } from 'hono'
  2. import { APIClient } from '@d8d-appcontainer/api'
  3. import type { Variables } from './app.tsx'
  4. import type { WithAuth } from './app.tsx'
  5. import { migrations } from './migrations.ts'
  6. import debug from "debug";
  7. const log = {
  8. api: debug("api:migrations"),
  9. };
  10. // 初始化数据库
  11. const initDatabase = async (apiClient: APIClient) => {
  12. try {
  13. log.api('正在执行数据库迁移...')
  14. const migrationsResult = await apiClient.database.executeLiveMigrations(migrations)
  15. // log.app('数据库迁移完成 %O',migrationsResult)
  16. log.api('数据库迁移完成')
  17. return migrationsResult
  18. } catch (error) {
  19. log.api('数据库迁移失败:', error)
  20. }
  21. }
  22. export function createMigrationsRoutes(withAuth: WithAuth) {
  23. const migrationsRoutes = new Hono<{ Variables: Variables }>()
  24. migrationsRoutes.get('/', async (c) => {
  25. const apiClient = c.get('apiClient')
  26. const migrationsResult = await initDatabase(apiClient)
  27. const failedResult = migrationsResult?.find((migration) => migration.status === 'failed')
  28. if (failedResult) {
  29. log.api('数据库迁移失败 %O', failedResult)
  30. return c.json({ error: '数据库迁移失败' }, 500)
  31. }
  32. return c.json({ success: true })
  33. })
  34. return migrationsRoutes
  35. }