worker.ts 976 B

1234567891011121314151617181920212223242526272829303132
  1. import 'reflect-metadata'
  2. import { OpenTelemetrySDK } from '@standardnotes/domain-events-infra'
  3. import { ServiceIdentifier } from '@standardnotes/domain-core'
  4. const sdk = new OpenTelemetrySDK({ serviceName: ServiceIdentifier.NAMES.FilesWorker })
  5. sdk.start()
  6. import { Logger } from 'winston'
  7. import { ContainerConfigLoader } from '../src/Bootstrap/Container'
  8. import TYPES from '../src/Bootstrap/Types'
  9. import { Env } from '../src/Bootstrap/Env'
  10. import { DomainEventSubscriberInterface } from '@standardnotes/domain-events'
  11. import * as dayjs from 'dayjs'
  12. import * as utc from 'dayjs/plugin/utc'
  13. const container = new ContainerConfigLoader()
  14. void container.load().then((container) => {
  15. dayjs.extend(utc)
  16. const env: Env = new Env()
  17. env.load()
  18. const logger: Logger = container.get(TYPES.Files_Logger)
  19. logger.info('Starting worker...')
  20. const subscriber = container.get<DomainEventSubscriberInterface>(TYPES.Files_DomainEventSubscriber)
  21. subscriber.start()
  22. })