cleanup.ts 1.5 KB

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