cleanup.ts 1.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. import 'reflect-metadata'
  2. import { Logger } from 'winston'
  3. import { ContainerConfigLoader } from '../src/Bootstrap/Container'
  4. import TYPES from '../src/Bootstrap/Types'
  5. import { Env } from '../src/Bootstrap/Env'
  6. import { CleanupSessionTraces } from '../src/Domain/UseCase/CleanupSessionTraces/CleanupSessionTraces'
  7. import { CleanupExpiredSessions } from '../src/Domain/UseCase/CleanupExpiredSessions/CleanupExpiredSessions'
  8. const cleanup = async (
  9. cleanupSessionTraces: CleanupSessionTraces,
  10. cleanupExpiredSessions: CleanupExpiredSessions,
  11. ): Promise<void> => {
  12. const date = new Date()
  13. await cleanupSessionTraces.execute({ date })
  14. await cleanupExpiredSessions.execute({ date })
  15. }
  16. const container = new ContainerConfigLoader('worker')
  17. void container.load().then((container) => {
  18. const env: Env = new Env()
  19. env.load()
  20. const logger: Logger = container.get(TYPES.Auth_Logger)
  21. logger.info('Starting sessions and session traces cleanup')
  22. const cleanupSessionTraces: CleanupSessionTraces = container.get(TYPES.Auth_CleanupSessionTraces)
  23. const cleanupExpiredSessions: CleanupExpiredSessions = container.get(TYPES.Auth_CleanupExpiredSessions)
  24. Promise.resolve(cleanup(cleanupSessionTraces, cleanupExpiredSessions))
  25. .then(() => {
  26. logger.info('Expired sessions and session traces cleaned.')
  27. process.exit(0)
  28. })
  29. .catch((error) => {
  30. logger.error(`Could not clean sessions and session traces: ${error.message}`)
  31. process.exit(1)
  32. })
  33. })