worker.ts 1.1 KB

123456789101112131415161718192021222324252627282930313233
  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 { DomainEventSubscriberFactoryInterface } from '@standardnotes/domain-events'
  7. import * as dayjs from 'dayjs'
  8. import * as utc from 'dayjs/plugin/utc'
  9. import { OpenTelemetrySDKInterface } from '@standardnotes/domain-events-infra'
  10. const container = new ContainerConfigLoader('worker')
  11. void container.load().then((container) => {
  12. dayjs.extend(utc)
  13. const env: Env = new Env()
  14. env.load()
  15. const logger: Logger = container.get(TYPES.Files_Logger)
  16. logger.info('Starting worker...')
  17. if (!container.get<boolean>(TYPES.Files_IS_CONFIGURED_FOR_HOME_SERVER_OR_SELF_HOSTING)) {
  18. const openTelemetrySDK = container.get<OpenTelemetrySDKInterface>(TYPES.Files_OpenTelemetrySDK)
  19. openTelemetrySDK.start()
  20. }
  21. const subscriberFactory: DomainEventSubscriberFactoryInterface = container.get(
  22. TYPES.Files_DomainEventSubscriberFactory,
  23. )
  24. subscriberFactory.create().start()
  25. })