1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249 |
- import * as winston from 'winston'
- import Redis from 'ioredis'
- import { Container, interfaces } from 'inversify'
- import { Env } from './Env'
- import TYPES from './Types'
- import { AppDataSource } from './DataSource'
- import { SNSClient, SNSClientConfig } from '@aws-sdk/client-sns'
- import { ItemRepositoryInterface } from '../Domain/Item/ItemRepositoryInterface'
- import { SQLLegacyItemRepository } from '../Infra/TypeORM/SQLLegacyItemRepository'
- import { MongoRepository, Repository } from 'typeorm'
- import { Item } from '../Domain/Item/Item'
- import {
- DirectCallDomainEventPublisher,
- DirectCallEventMessageHandler,
- SNSDomainEventPublisher,
- SQSDomainEventSubscriberFactory,
- SQSEventMessageHandler,
- } from '@standardnotes/domain-events-infra'
- import { DomainEventFactoryInterface } from '../Domain/Event/DomainEventFactoryInterface'
- import { DomainEventFactory } from '../Domain/Event/DomainEventFactory'
- import { Timer, TimerInterface } from '@standardnotes/time'
- import { ItemTransferCalculatorInterface } from '../Domain/Item/ItemTransferCalculatorInterface'
- import { ItemTransferCalculator } from '../Domain/Item/ItemTransferCalculator'
- import { ItemConflict } from '../Domain/Item/ItemConflict'
- import { ContentFilter } from '../Domain/Item/SaveRule/ContentFilter'
- import { ContentTypeFilter } from '../Domain/Item/SaveRule/ContentTypeFilter'
- import { OwnershipFilter } from '../Domain/Item/SaveRule/OwnershipFilter'
- import { TimeDifferenceFilter } from '../Domain/Item/SaveRule/TimeDifferenceFilter'
- import { ItemSaveValidator } from '../Domain/Item/SaveValidator/ItemSaveValidator'
- import { ItemSaveValidatorInterface } from '../Domain/Item/SaveValidator/ItemSaveValidatorInterface'
- import { SyncResponseFactory20161215 } from '../Domain/Item/SyncResponse/SyncResponseFactory20161215'
- import { SyncResponseFactory20200115 } from '../Domain/Item/SyncResponse/SyncResponseFactory20200115'
- import { SyncResponseFactoryResolver } from '../Domain/Item/SyncResponse/SyncResponseFactoryResolver'
- import { SyncResponseFactoryResolverInterface } from '../Domain/Item/SyncResponse/SyncResponseFactoryResolverInterface'
- import { CheckIntegrity } from '../Domain/UseCase/Syncing/CheckIntegrity/CheckIntegrity'
- import { GetItem } from '../Domain/UseCase/Syncing/GetItem/GetItem'
- import { SyncItems } from '../Domain/UseCase/Syncing/SyncItems/SyncItems'
- import { InversifyExpressAuthMiddleware } from '../Infra/InversifyExpressUtils/Middleware/InversifyExpressAuthMiddleware'
- import { S3Client } from '@aws-sdk/client-s3'
- import { SQSClient, SQSClientConfig } from '@aws-sdk/client-sqs'
- import { ContentDecoder, ContentDecoderInterface } from '@standardnotes/common'
- import {
- DomainEventMessageHandlerInterface,
- DomainEventHandlerInterface,
- DomainEventSubscriberFactoryInterface,
- DomainEventPublisherInterface,
- } from '@standardnotes/domain-events'
- import axios, { AxiosInstance } from 'axios'
- import { AuthHttpServiceInterface } from '../Domain/Auth/AuthHttpServiceInterface'
- import { ExtensionsHttpService } from '../Domain/Extension/ExtensionsHttpService'
- import { ExtensionsHttpServiceInterface } from '../Domain/Extension/ExtensionsHttpServiceInterface'
- import { AccountDeletionRequestedEventHandler } from '../Domain/Handler/AccountDeletionRequestedEventHandler'
- import { DuplicateItemSyncedEventHandler } from '../Domain/Handler/DuplicateItemSyncedEventHandler'
- import { EmailBackupRequestedEventHandler } from '../Domain/Handler/EmailBackupRequestedEventHandler'
- import { ItemRevisionCreationRequestedEventHandler } from '../Domain/Handler/ItemRevisionCreationRequestedEventHandler'
- import { ItemBackupServiceInterface } from '../Domain/Item/ItemBackupServiceInterface'
- import { FSItemBackupService } from '../Infra/FS/FSItemBackupService'
- import { AuthHttpService } from '../Infra/HTTP/AuthHttpService'
- import { S3ItemBackupService } from '../Infra/S3/S3ItemBackupService'
- import {
- ControllerContainer,
- ControllerContainerInterface,
- MapperInterface,
- SharedVaultUser,
- } from '@standardnotes/domain-core'
- import { BaseItemsController } from '../Infra/InversifyExpressUtils/Base/BaseItemsController'
- import { Transform } from 'stream'
- import { SQLLegacyItem } from '../Infra/TypeORM/SQLLegacyItem'
- import { SQLLegacyItemPersistenceMapper } from '../Mapping/Persistence/SQLLegacyItemPersistenceMapper'
- import { ItemHttpRepresentation } from '../Mapping/Http/ItemHttpRepresentation'
- import { ItemHttpMapper } from '../Mapping/Http/ItemHttpMapper'
- import { SavedItemHttpRepresentation } from '../Mapping/Http/SavedItemHttpRepresentation'
- import { SavedItemHttpMapper } from '../Mapping/Http/SavedItemHttpMapper'
- import { ItemConflictHttpRepresentation } from '../Mapping/Http/ItemConflictHttpRepresentation'
- import { ItemConflictHttpMapper } from '../Mapping/Http/ItemConflictHttpMapper'
- import { ItemBackupRepresentation } from '../Mapping/Backup/ItemBackupRepresentation'
- import { ItemBackupMapper } from '../Mapping/Backup/ItemBackupMapper'
- import { SaveNewItem } from '../Domain/UseCase/Syncing/SaveNewItem/SaveNewItem'
- import { UpdateExistingItem } from '../Domain/UseCase/Syncing/UpdateExistingItem/UpdateExistingItem'
- import { GetItems } from '../Domain/UseCase/Syncing/GetItems/GetItems'
- import { SaveItems } from '../Domain/UseCase/Syncing/SaveItems/SaveItems'
- import { ItemHashHttpMapper } from '../Mapping/Http/ItemHashHttpMapper'
- import { ItemHash } from '../Domain/Item/ItemHash'
- import { ItemHashHttpRepresentation } from '../Mapping/Http/ItemHashHttpRepresentation'
- import { BaseSharedVaultInvitesController } from '../Infra/InversifyExpressUtils/Base/BaseSharedVaultInvitesController'
- import { InviteUserToSharedVault } from '../Domain/UseCase/SharedVaults/InviteUserToSharedVault/InviteUserToSharedVault'
- import { TypeORMSharedVaultRepository } from '../Infra/TypeORM/TypeORMSharedVaultRepository'
- import { TypeORMSharedVault } from '../Infra/TypeORM/TypeORMSharedVault'
- import { TypeORMSharedVaultInvite } from '../Infra/TypeORM/TypeORMSharedVaultInvite'
- import { TypeORMSharedVaultUser } from '../Infra/TypeORM/TypeORMSharedVaultUser'
- import { SharedVaultRepositoryInterface } from '../Domain/SharedVault/SharedVaultRepositoryInterface'
- import { SharedVaultPersistenceMapper } from '../Mapping/Persistence/SharedVaultPersistenceMapper'
- import { SharedVault } from '../Domain/SharedVault/SharedVault'
- import { SharedVaultUserPersistenceMapper } from '../Mapping/Persistence/SharedVaultUserPersistenceMapper'
- import { SharedVaultInvite } from '../Domain/SharedVault/User/Invite/SharedVaultInvite'
- import { SharedVaultInvitePersistenceMapper } from '../Mapping/Persistence/SharedVaultInvitePersistenceMapper'
- import { SharedVaultUserRepositoryInterface } from '../Domain/SharedVault/User/SharedVaultUserRepositoryInterface'
- import { TypeORMSharedVaultUserRepository } from '../Infra/TypeORM/TypeORMSharedVaultUserRepository'
- import { SharedVaultInviteRepositoryInterface } from '../Domain/SharedVault/User/Invite/SharedVaultInviteRepositoryInterface'
- import { TypeORMSharedVaultInviteRepository } from '../Infra/TypeORM/TypeORMSharedVaultInviteRepository'
- import { UpdateSharedVaultInvite } from '../Domain/UseCase/SharedVaults/UpdateSharedVaultInvite/UpdateSharedVaultInvite'
- import { AcceptInviteToSharedVault } from '../Domain/UseCase/SharedVaults/AcceptInviteToSharedVault/AcceptInviteToSharedVault'
- import { AddUserToSharedVault } from '../Domain/UseCase/SharedVaults/AddUserToSharedVault/AddUserToSharedVault'
- import { CancelInviteToSharedVault } from '../Domain/UseCase/SharedVaults/CancelInviteToSharedVault/CancelInviteToSharedVault'
- import { DeleteSharedVaultInvitesToUser } from '../Domain/UseCase/SharedVaults/DeleteSharedVaultInvitesToUser/DeleteSharedVaultInvitesToUser'
- import { DeleteSharedVaultInvitesSentByUser } from '../Domain/UseCase/SharedVaults/DeleteSharedVaultInvitesSentByUser/DeleteSharedVaultInvitesSentByUser'
- import { GetSharedVaultInvitesSentByUser } from '../Domain/UseCase/SharedVaults/GetSharedVaultInvitesSentByUser/GetSharedVaultInvitesSentByUser'
- import { GetSharedVaultInvitesSentToUser } from '../Domain/UseCase/SharedVaults/GetSharedVaultInvitesSentToUser/GetSharedVaultInvitesSentToUser'
- import { BaseSharedVaultUsersController } from '../Infra/InversifyExpressUtils/Base/BaseSharedVaultUsersController'
- import { GetSharedVaultUsers } from '../Domain/UseCase/SharedVaults/GetSharedVaultUsers/GetSharedVaultUsers'
- import { RemoveUserFromSharedVault } from '../Domain/UseCase/SharedVaults/RemoveUserFromSharedVault/RemoveUserFromSharedVault'
- import { AddNotificationForUser } from '../Domain/UseCase/Messaging/AddNotificationForUser/AddNotificationForUser'
- import { TypeORMNotification } from '../Infra/TypeORM/TypeORMNotification'
- import { NotificationRepositoryInterface } from '../Domain/Notifications/NotificationRepositoryInterface'
- import { TypeORMNotificationRepository } from '../Infra/TypeORM/TypeORMNotificationRepository'
- import { NotificationPersistenceMapper } from '../Mapping/Persistence/NotificationPersistenceMapper'
- import { Notification } from '../Domain/Notifications/Notification'
- import { SharedVaultUserHttpRepresentation } from '../Mapping/Http/SharedVaultUserHttpRepresentation'
- import { SharedVaultUserHttpMapper } from '../Mapping/Http/SharedVaultUserHttpMapper'
- import { BaseSharedVaultsController } from '../Infra/InversifyExpressUtils/Base/BaseSharedVaultsController'
- import { GetSharedVaults } from '../Domain/UseCase/SharedVaults/GetSharedVaults/GetSharedVaults'
- import { CreateSharedVault } from '../Domain/UseCase/SharedVaults/CreateSharedVault/CreateSharedVault'
- import { DeleteSharedVault } from '../Domain/UseCase/SharedVaults/DeleteSharedVault/DeleteSharedVault'
- import { CreateSharedVaultFileValetToken } from '../Domain/UseCase/SharedVaults/CreateSharedVaultFileValetToken/CreateSharedVaultFileValetToken'
- import { SharedVaultValetTokenData, TokenEncoder, TokenEncoderInterface } from '@standardnotes/security'
- import { SharedVaultHttpRepresentation } from '../Mapping/Http/SharedVaultHttpRepresentation'
- import { SharedVaultHttpMapper } from '../Mapping/Http/SharedVaultHttpMapper'
- import { SharedVaultInviteHttpRepresentation } from '../Mapping/Http/SharedVaultInviteHttpRepresentation'
- import { SharedVaultInviteHttpMapper } from '../Mapping/Http/SharedVaultInviteHttpMapper'
- import { BaseMessagesController } from '../Infra/InversifyExpressUtils/Base/BaseMessagesController'
- import { GetMessagesSentToUser } from '../Domain/UseCase/Messaging/GetMessagesSentToUser/GetMessagesSentToUser'
- import { TypeORMMessage } from '../Infra/TypeORM/TypeORMMessage'
- import { MessageRepositoryInterface } from '../Domain/Message/MessageRepositoryInterface'
- import { TypeORMMessageRepository } from '../Infra/TypeORM/TypeORMMessageRepository'
- import { Message } from '../Domain/Message/Message'
- import { MessagePersistenceMapper } from '../Mapping/Persistence/MessagePersistenceMapper'
- import { GetMessagesSentByUser } from '../Domain/UseCase/Messaging/GetMessagesSentByUser/GetMessagesSentByUser'
- import { SendMessageToUser } from '../Domain/UseCase/Messaging/SendMessageToUser/SendMessageToUser'
- import { DeleteAllMessagesSentToUser } from '../Domain/UseCase/Messaging/DeleteAllMessagesSentToUser/DeleteAllMessagesSentToUser'
- import { DeleteMessage } from '../Domain/UseCase/Messaging/DeleteMessage/DeleteMessage'
- import { MessageHttpRepresentation } from '../Mapping/Http/MessageHttpRepresentation'
- import { MessageHttpMapper } from '../Mapping/Http/MessageHttpMapper'
- import { GetUserNotifications } from '../Domain/UseCase/Messaging/GetUserNotifications/GetUserNotifications'
- import { NotificationHttpMapper } from '../Mapping/Http/NotificationHttpMapper'
- import { NotificationHttpRepresentation } from '../Mapping/Http/NotificationHttpRepresentation'
- import { DetermineSharedVaultOperationOnItem } from '../Domain/UseCase/SharedVaults/DetermineSharedVaultOperationOnItem/DetermineSharedVaultOperationOnItem'
- import { SharedVaultFilter } from '../Domain/Item/SaveRule/SharedVaultFilter'
- import { RemoveNotificationsForUser } from '../Domain/UseCase/Messaging/RemoveNotificationsForUser/RemoveNotificationsForUser'
- import { SharedVaultSnjsFilter } from '../Domain/Item/SaveRule/SharedVaultSnjsFilter'
- import { UpdateStorageQuotaUsedInSharedVault } from '../Domain/UseCase/SharedVaults/UpdateStorageQuotaUsedInSharedVault/UpdateStorageQuotaUsedInSharedVault'
- import { SharedVaultFileUploadedEventHandler } from '../Domain/Handler/SharedVaultFileUploadedEventHandler'
- import { SharedVaultFileRemovedEventHandler } from '../Domain/Handler/SharedVaultFileRemovedEventHandler'
- import { AddNotificationsForUsers } from '../Domain/UseCase/Messaging/AddNotificationsForUsers/AddNotificationsForUsers'
- import { MongoDBItem } from '../Infra/TypeORM/MongoDBItem'
- import { MongoDBItemRepository } from '../Infra/TypeORM/MongoDBItemRepository'
- import { MongoDBItemPersistenceMapper } from '../Mapping/Persistence/MongoDB/MongoDBItemPersistenceMapper'
- import { Logger } from 'winston'
- import { ItemRepositoryResolverInterface } from '../Domain/Item/ItemRepositoryResolverInterface'
- import { TypeORMItemRepositoryResolver } from '../Infra/TypeORM/TypeORMItemRepositoryResolver'
- import { TransitionItemsFromPrimaryToSecondaryDatabaseForUser } from '../Domain/UseCase/Transition/TransitionItemsFromPrimaryToSecondaryDatabaseForUser/TransitionItemsFromPrimaryToSecondaryDatabaseForUser'
- import { SharedVaultFileMovedEventHandler } from '../Domain/Handler/SharedVaultFileMovedEventHandler'
- import { SQLItem } from '../Infra/TypeORM/SQLItem'
- import { SQLItemPersistenceMapper } from '../Mapping/Persistence/SQLItemPersistenceMapper'
- import { SQLItemRepository } from '../Infra/TypeORM/SQLItemRepository'
- import { SendEventToClient } from '../Domain/UseCase/Syncing/SendEventToClient/SendEventToClient'
- import { TransitionRequestedEventHandler } from '../Domain/Handler/TransitionRequestedEventHandler'
- import { DeleteSharedVaults } from '../Domain/UseCase/SharedVaults/DeleteSharedVaults/DeleteSharedVaults'
- import { RemoveItemsFromSharedVault } from '../Domain/UseCase/SharedVaults/RemoveItemsFromSharedVault/RemoveItemsFromSharedVault'
- import { SharedVaultRemovedEventHandler } from '../Domain/Handler/SharedVaultRemovedEventHandler'
- import { DesignateSurvivor } from '../Domain/UseCase/SharedVaults/DesignateSurvivor/DesignateSurvivor'
- import { RemoveUserFromSharedVaults } from '../Domain/UseCase/SharedVaults/RemoveUserFromSharedVaults/RemoveUserFromSharedVaults'
- import { TransferSharedVault } from '../Domain/UseCase/SharedVaults/TransferSharedVault/TransferSharedVault'
- import { TransitionRepositoryInterface } from '../Domain/Transition/TransitionRepositoryInterface'
- import { RedisTransitionRepository } from '../Infra/Redis/RedisTransitionRepository'
- import { TransferSharedVaultItems } from '../Domain/UseCase/SharedVaults/TransferSharedVaultItems/TransferSharedVaultItems'
- import { DumpItem } from '../Domain/UseCase/Syncing/DumpItem/DumpItem'
- export class ContainerConfigLoader {
- private readonly DEFAULT_CONTENT_SIZE_TRANSFER_LIMIT = 10_000_000
- private readonly DEFAULT_MAX_ITEMS_LIMIT = 300
- private readonly DEFAULT_FILE_UPLOAD_PATH = `${__dirname}/../../uploads`
- constructor(private mode: 'server' | 'worker' = 'server') {}
- async load(configuration?: {
- controllerConatiner?: ControllerContainerInterface
- directCallDomainEventPublisher?: DirectCallDomainEventPublisher
- logger?: Transform
- environmentOverrides?: { [name: string]: string }
- }): Promise<Container> {
- const directCallDomainEventPublisher =
- configuration?.directCallDomainEventPublisher ?? new DirectCallDomainEventPublisher()
- const env: Env = new Env(configuration?.environmentOverrides)
- env.load()
- const container = new Container({
- defaultScope: 'Singleton',
- })
- let logger: winston.Logger
- if (configuration?.logger) {
- logger = configuration.logger as winston.Logger
- } else {
- const winstonFormatters = [winston.format.splat(), winston.format.json()]
- if (env.get('NEW_RELIC_ENABLED', true) === 'true') {
- await import('newrelic')
- // eslint-disable-next-line @typescript-eslint/no-var-requires
- const newrelicFormatter = require('@newrelic/winston-enricher')
- const newrelicWinstonFormatter = newrelicFormatter(winston)
- winstonFormatters.push(newrelicWinstonFormatter())
- }
- logger = winston.createLogger({
- level: env.get('LOG_LEVEL', true) || 'info',
- format: winston.format.combine(...winstonFormatters),
- transports: [new winston.transports.Console({ level: env.get('LOG_LEVEL', true) || 'info' })],
- defaultMeta: { service: 'syncing-server' },
- })
- }
- container.bind<winston.Logger>(TYPES.Sync_Logger).toConstantValue(logger)
- const appDataSource = new AppDataSource({ env, runMigrations: this.mode === 'server' })
- await appDataSource.initialize()
- logger.debug('Database initialized')
- container.bind<TimerInterface>(TYPES.Sync_Timer).toConstantValue(new Timer())
- const isConfiguredForHomeServer = env.get('MODE', true) === 'home-server'
- const isConfiguredForSelfHosting = env.get('MODE', true) === 'self-hosted'
- const isConfiguredForHomeServerOrSelfHosting = isConfiguredForHomeServer || isConfiguredForSelfHosting
- const isSecondaryDatabaseEnabled = env.get('SECONDARY_DB_ENABLED', true) === 'true'
- const isConfiguredForInMemoryCache = env.get('CACHE_TYPE', true) === 'memory'
- if (!isConfiguredForInMemoryCache) {
- const redisUrl = env.get('REDIS_URL')
- const isRedisInClusterMode = redisUrl.indexOf(',') > 0
- let redis
- if (isRedisInClusterMode) {
- redis = new Redis.Cluster(redisUrl.split(','))
- } else {
- redis = new Redis(redisUrl)
- }
- container.bind(TYPES.Sync_Redis).toConstantValue(redis)
- container
- .bind<TransitionRepositoryInterface>(TYPES.Sync_TransitionStatusRepository)
- .toConstantValue(new RedisTransitionRepository(container.get<Redis>(TYPES.Sync_Redis)))
- }
- container.bind<Env>(TYPES.Sync_Env).toConstantValue(env)
- if (isConfiguredForHomeServer) {
- container
- .bind<DomainEventPublisherInterface>(TYPES.Sync_DomainEventPublisher)
- .toConstantValue(directCallDomainEventPublisher)
- } else {
- container.bind(TYPES.Sync_SNS_TOPIC_ARN).toConstantValue(env.get('SNS_TOPIC_ARN'))
- container.bind(TYPES.Sync_SNS_AWS_REGION).toConstantValue(env.get('SNS_AWS_REGION', true))
- container.bind(TYPES.Sync_SQS_QUEUE_URL).toConstantValue(env.get('SQS_QUEUE_URL'))
- container.bind(TYPES.Sync_S3_AWS_REGION).toConstantValue(env.get('S3_AWS_REGION', true))
- container.bind(TYPES.Sync_S3_BACKUP_BUCKET_NAME).toConstantValue(env.get('S3_BACKUP_BUCKET_NAME', true))
- container.bind(TYPES.Sync_EXTENSIONS_SERVER_URL).toConstantValue(env.get('EXTENSIONS_SERVER_URL', true))
- container.bind<SNSClient>(TYPES.Sync_SNS).toDynamicValue((context: interfaces.Context) => {
- const env: Env = context.container.get(TYPES.Sync_Env)
- const snsConfig: SNSClientConfig = {
- apiVersion: 'latest',
- region: env.get('SNS_AWS_REGION', true),
- }
- if (env.get('SNS_ENDPOINT', true)) {
- snsConfig.endpoint = env.get('SNS_ENDPOINT', true)
- }
- if (env.get('SNS_ACCESS_KEY_ID', true) && env.get('SNS_SECRET_ACCESS_KEY', true)) {
- snsConfig.credentials = {
- accessKeyId: env.get('SNS_ACCESS_KEY_ID', true),
- secretAccessKey: env.get('SNS_SECRET_ACCESS_KEY', true),
- }
- }
- return new SNSClient(snsConfig)
- })
- container
- .bind<DomainEventPublisherInterface>(TYPES.Sync_DomainEventPublisher)
- .toDynamicValue((context: interfaces.Context) => {
- return new SNSDomainEventPublisher(
- context.container.get(TYPES.Sync_SNS),
- context.container.get(TYPES.Sync_SNS_TOPIC_ARN),
- )
- })
- container.bind<SQSClient>(TYPES.Sync_SQS).toDynamicValue((context: interfaces.Context) => {
- const env: Env = context.container.get(TYPES.Sync_Env)
- const sqsConfig: SQSClientConfig = {
- region: env.get('SQS_AWS_REGION'),
- }
- if (env.get('SQS_ENDPOINT', true)) {
- sqsConfig.endpoint = env.get('SQS_ENDPOINT', true)
- }
- if (env.get('SQS_ACCESS_KEY_ID', true) && env.get('SQS_SECRET_ACCESS_KEY', true)) {
- sqsConfig.credentials = {
- accessKeyId: env.get('SQS_ACCESS_KEY_ID', true),
- secretAccessKey: env.get('SQS_SECRET_ACCESS_KEY', true),
- }
- }
- return new SQSClient(sqsConfig)
- })
- container.bind<S3Client | undefined>(TYPES.Sync_S3).toDynamicValue((context: interfaces.Context) => {
- const env: Env = context.container.get(TYPES.Sync_Env)
- let s3Client = undefined
- if (env.get('S3_AWS_REGION', true)) {
- s3Client = new S3Client({
- apiVersion: 'latest',
- region: env.get('S3_AWS_REGION', true),
- })
- }
- return s3Client
- })
- }
- container
- .bind(TYPES.Sync_EMAIL_ATTACHMENT_MAX_BYTE_SIZE)
- .toConstantValue(
- env.get('EMAIL_ATTACHMENT_MAX_BYTE_SIZE', true) ? +env.get('EMAIL_ATTACHMENT_MAX_BYTE_SIZE', true) : 10485760,
- )
- container.bind(TYPES.Sync_NEW_RELIC_ENABLED).toConstantValue(env.get('NEW_RELIC_ENABLED', true))
- container
- .bind(TYPES.Sync_FILE_UPLOAD_PATH)
- .toConstantValue(
- env.get('FILE_UPLOAD_PATH', true) ? env.get('FILE_UPLOAD_PATH', true) : this.DEFAULT_FILE_UPLOAD_PATH,
- )
- // Mapping
- container
- .bind<MapperInterface<Item, SQLLegacyItem>>(TYPES.Sync_SQLLegacyItemPersistenceMapper)
- .toConstantValue(new SQLLegacyItemPersistenceMapper())
- container
- .bind<MapperInterface<Item, SQLItem>>(TYPES.Sync_SQLItemPersistenceMapper)
- .toConstantValue(new SQLItemPersistenceMapper())
- container
- .bind<MapperInterface<ItemHash, ItemHashHttpRepresentation>>(TYPES.Sync_ItemHashHttpMapper)
- .toConstantValue(new ItemHashHttpMapper())
- container
- .bind<MapperInterface<Item, ItemHttpRepresentation>>(TYPES.Sync_ItemHttpMapper)
- .toConstantValue(new ItemHttpMapper(container.get(TYPES.Sync_Timer)))
- container
- .bind<MapperInterface<Item, SavedItemHttpRepresentation>>(TYPES.Sync_SavedItemHttpMapper)
- .toConstantValue(new SavedItemHttpMapper(container.get(TYPES.Sync_Timer)))
- container
- .bind<MapperInterface<ItemConflict, ItemConflictHttpRepresentation>>(TYPES.Sync_ItemConflictHttpMapper)
- .toConstantValue(
- new ItemConflictHttpMapper(
- container.get(TYPES.Sync_ItemHttpMapper),
- container.get(TYPES.Sync_ItemHashHttpMapper),
- ),
- )
- container
- .bind<MapperInterface<Item, ItemBackupRepresentation>>(TYPES.Sync_ItemBackupMapper)
- .toConstantValue(new ItemBackupMapper(container.get(TYPES.Sync_Timer)))
- container
- .bind<MapperInterface<SharedVault, TypeORMSharedVault>>(TYPES.Sync_SharedVaultPersistenceMapper)
- .toConstantValue(new SharedVaultPersistenceMapper())
- container
- .bind<MapperInterface<SharedVaultUser, TypeORMSharedVaultUser>>(TYPES.Sync_SharedVaultUserPersistenceMapper)
- .toConstantValue(new SharedVaultUserPersistenceMapper())
- container
- .bind<MapperInterface<SharedVaultInvite, TypeORMSharedVaultInvite>>(TYPES.Sync_SharedVaultInvitePersistenceMapper)
- .toConstantValue(new SharedVaultInvitePersistenceMapper())
- container
- .bind<MapperInterface<Notification, TypeORMNotification>>(TYPES.Sync_NotificationPersistenceMapper)
- .toConstantValue(new NotificationPersistenceMapper())
- container
- .bind<MapperInterface<SharedVaultUser, SharedVaultUserHttpRepresentation>>(TYPES.Sync_SharedVaultUserHttpMapper)
- .toConstantValue(new SharedVaultUserHttpMapper())
- container
- .bind<MapperInterface<SharedVault, SharedVaultHttpRepresentation>>(TYPES.Sync_SharedVaultHttpMapper)
- .toConstantValue(new SharedVaultHttpMapper())
- container
- .bind<MapperInterface<SharedVaultInvite, SharedVaultInviteHttpRepresentation>>(
- TYPES.Sync_SharedVaultInviteHttpMapper,
- )
- .toConstantValue(new SharedVaultInviteHttpMapper())
- container
- .bind<MapperInterface<Message, TypeORMMessage>>(TYPES.Sync_MessagePersistenceMapper)
- .toConstantValue(new MessagePersistenceMapper())
- container
- .bind<MapperInterface<Message, MessageHttpRepresentation>>(TYPES.Sync_MessageHttpMapper)
- .toConstantValue(new MessageHttpMapper())
- container
- .bind<MapperInterface<Notification, NotificationHttpRepresentation>>(TYPES.Sync_NotificationHttpMapper)
- .toConstantValue(new NotificationHttpMapper())
- // ORM
- container
- .bind<Repository<SQLLegacyItem>>(TYPES.Sync_ORMLegacyItemRepository)
- .toDynamicValue(() => appDataSource.getRepository(SQLLegacyItem))
- container
- .bind<Repository<SQLItem>>(TYPES.Sync_ORMItemRepository)
- .toConstantValue(appDataSource.getRepository(SQLItem))
- container
- .bind<Repository<TypeORMSharedVault>>(TYPES.Sync_ORMSharedVaultRepository)
- .toConstantValue(appDataSource.getRepository(TypeORMSharedVault))
- container
- .bind<Repository<TypeORMSharedVaultInvite>>(TYPES.Sync_ORMSharedVaultInviteRepository)
- .toConstantValue(appDataSource.getRepository(TypeORMSharedVaultInvite))
- container
- .bind<Repository<TypeORMSharedVaultUser>>(TYPES.Sync_ORMSharedVaultUserRepository)
- .toConstantValue(appDataSource.getRepository(TypeORMSharedVaultUser))
- container
- .bind<Repository<TypeORMNotification>>(TYPES.Sync_ORMNotificationRepository)
- .toConstantValue(appDataSource.getRepository(TypeORMNotification))
- container
- .bind<Repository<TypeORMMessage>>(TYPES.Sync_ORMMessageRepository)
- .toConstantValue(appDataSource.getRepository(TypeORMMessage))
- // Mongo
- if (isSecondaryDatabaseEnabled) {
- container
- .bind<MapperInterface<Item, MongoDBItem>>(TYPES.Sync_MongoDBItemPersistenceMapper)
- .toConstantValue(new MongoDBItemPersistenceMapper())
- container
- .bind<MongoRepository<MongoDBItem>>(TYPES.Sync_ORMMongoItemRepository)
- .toConstantValue(appDataSource.getMongoRepository(MongoDBItem))
- container
- .bind<ItemRepositoryInterface>(TYPES.Sync_MongoDBItemRepository)
- .toConstantValue(
- new MongoDBItemRepository(
- container.get<MongoRepository<MongoDBItem>>(TYPES.Sync_ORMMongoItemRepository),
- container.get<MapperInterface<Item, MongoDBItem>>(TYPES.Sync_MongoDBItemPersistenceMapper),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- }
- // Repositories
- container
- .bind<ItemRepositoryInterface>(TYPES.Sync_SQLItemRepository)
- .toConstantValue(
- isConfiguredForHomeServerOrSelfHosting
- ? new SQLItemRepository(
- container.get<Repository<SQLItem>>(TYPES.Sync_ORMItemRepository),
- container.get<MapperInterface<Item, SQLItem>>(TYPES.Sync_SQLItemPersistenceMapper),
- container.get<Logger>(TYPES.Sync_Logger),
- )
- : new SQLLegacyItemRepository(
- container.get<Repository<SQLLegacyItem>>(TYPES.Sync_ORMLegacyItemRepository),
- container.get<MapperInterface<Item, SQLLegacyItem>>(TYPES.Sync_SQLLegacyItemPersistenceMapper),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- container
- .bind<ItemRepositoryResolverInterface>(TYPES.Sync_ItemRepositoryResolver)
- .toConstantValue(
- new TypeORMItemRepositoryResolver(
- container.get<ItemRepositoryInterface>(TYPES.Sync_SQLItemRepository),
- isSecondaryDatabaseEnabled ? container.get<ItemRepositoryInterface>(TYPES.Sync_MongoDBItemRepository) : null,
- ),
- )
- container
- .bind<SharedVaultRepositoryInterface>(TYPES.Sync_SharedVaultRepository)
- .toConstantValue(
- new TypeORMSharedVaultRepository(
- container.get(TYPES.Sync_ORMSharedVaultRepository),
- container.get(TYPES.Sync_SharedVaultPersistenceMapper),
- ),
- )
- container
- .bind<SharedVaultUserRepositoryInterface>(TYPES.Sync_SharedVaultUserRepository)
- .toConstantValue(
- new TypeORMSharedVaultUserRepository(
- container.get(TYPES.Sync_ORMSharedVaultUserRepository),
- container.get(TYPES.Sync_SharedVaultUserPersistenceMapper),
- ),
- )
- container
- .bind<SharedVaultInviteRepositoryInterface>(TYPES.Sync_SharedVaultInviteRepository)
- .toConstantValue(
- new TypeORMSharedVaultInviteRepository(
- container.get(TYPES.Sync_ORMSharedVaultInviteRepository),
- container.get(TYPES.Sync_SharedVaultInvitePersistenceMapper),
- ),
- )
- container
- .bind<NotificationRepositoryInterface>(TYPES.Sync_NotificationRepository)
- .toConstantValue(
- new TypeORMNotificationRepository(
- container.get(TYPES.Sync_ORMNotificationRepository),
- container.get(TYPES.Sync_NotificationPersistenceMapper),
- ),
- )
- container
- .bind<MessageRepositoryInterface>(TYPES.Sync_MessageRepository)
- .toConstantValue(
- new TypeORMMessageRepository(
- container.get(TYPES.Sync_ORMMessageRepository),
- container.get(TYPES.Sync_MessagePersistenceMapper),
- ),
- )
- container
- .bind<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory)
- .toDynamicValue((context: interfaces.Context) => {
- return new DomainEventFactory(context.container.get(TYPES.Sync_Timer))
- })
- container
- .bind<ItemTransferCalculatorInterface>(TYPES.Sync_ItemTransferCalculator)
- .toDynamicValue((context: interfaces.Context) => {
- return new ItemTransferCalculator(context.container.get<Logger>(TYPES.Sync_Logger))
- })
- // Middleware
- container
- .bind<InversifyExpressAuthMiddleware>(TYPES.Sync_AuthMiddleware)
- .toDynamicValue((context: interfaces.Context) => {
- return new InversifyExpressAuthMiddleware(
- context.container.get(TYPES.Sync_AUTH_JWT_SECRET),
- context.container.get(TYPES.Sync_Logger),
- )
- })
- // env vars
- container.bind(TYPES.Sync_AUTH_JWT_SECRET).toConstantValue(env.get('AUTH_JWT_SECRET'))
- container
- .bind(TYPES.Sync_REVISIONS_FREQUENCY)
- .toConstantValue(env.get('REVISIONS_FREQUENCY', true) ? +env.get('REVISIONS_FREQUENCY', true) : 300)
- container.bind(TYPES.Sync_NEW_RELIC_ENABLED).toConstantValue(env.get('NEW_RELIC_ENABLED', true))
- container.bind(TYPES.Sync_VERSION).toConstantValue(env.get('VERSION', true) ?? 'development')
- container
- .bind(TYPES.Sync_CONTENT_SIZE_TRANSFER_LIMIT)
- .toConstantValue(
- env.get('CONTENT_SIZE_TRANSFER_LIMIT', true)
- ? +env.get('CONTENT_SIZE_TRANSFER_LIMIT', true)
- : this.DEFAULT_CONTENT_SIZE_TRANSFER_LIMIT,
- )
- container
- .bind(TYPES.Sync_MAX_ITEMS_LIMIT)
- .toConstantValue(
- env.get('MAX_ITEMS_LIMIT', true) ? +env.get('MAX_ITEMS_LIMIT', true) : this.DEFAULT_MAX_ITEMS_LIMIT,
- )
- container.bind(TYPES.Sync_VALET_TOKEN_SECRET).toConstantValue(env.get('VALET_TOKEN_SECRET', true))
- container
- .bind(TYPES.Sync_VALET_TOKEN_TTL)
- .toConstantValue(env.get('VALET_TOKEN_TTL', true) ? +env.get('VALET_TOKEN_TTL', true) : 7200)
- container
- .bind<TokenEncoderInterface<SharedVaultValetTokenData>>(TYPES.Sync_SharedVaultValetTokenEncoder)
- .toConstantValue(new TokenEncoder<SharedVaultValetTokenData>(container.get(TYPES.Sync_VALET_TOKEN_SECRET)))
- container
- .bind<DetermineSharedVaultOperationOnItem>(TYPES.Sync_DetermineSharedVaultOperationOnItem)
- .toConstantValue(new DetermineSharedVaultOperationOnItem())
- container.bind<OwnershipFilter>(TYPES.Sync_OwnershipFilter).toConstantValue(new OwnershipFilter())
- container
- .bind<TimeDifferenceFilter>(TYPES.Sync_TimeDifferenceFilter)
- .toConstantValue(new TimeDifferenceFilter(container.get(TYPES.Sync_Timer)))
- container.bind<ContentTypeFilter>(TYPES.Sync_ContentTypeFilter).toConstantValue(new ContentTypeFilter())
- container.bind<ContentFilter>(TYPES.Sync_ContentFilter).toConstantValue(new ContentFilter())
- container
- .bind<SharedVaultFilter>(TYPES.Sync_SharedVaultFilter)
- .toConstantValue(
- new SharedVaultFilter(
- container.get(TYPES.Sync_DetermineSharedVaultOperationOnItem),
- container.get(TYPES.Sync_SharedVaultUserRepository),
- ),
- )
- container.bind<SharedVaultSnjsFilter>(TYPES.Sync_SharedVaultSnjsFilter).toConstantValue(new SharedVaultSnjsFilter())
- container
- .bind<ItemSaveValidatorInterface>(TYPES.Sync_ItemSaveValidator)
- .toConstantValue(
- new ItemSaveValidator([
- container.get(TYPES.Sync_OwnershipFilter),
- container.get(TYPES.Sync_TimeDifferenceFilter),
- container.get(TYPES.Sync_ContentTypeFilter),
- container.get(TYPES.Sync_ContentFilter),
- container.get(TYPES.Sync_SharedVaultFilter),
- container.get(TYPES.Sync_SharedVaultSnjsFilter),
- ]),
- )
- container
- .bind<ItemBackupServiceInterface>(TYPES.Sync_ItemBackupService)
- .toConstantValue(
- env.get('S3_AWS_REGION', true)
- ? new S3ItemBackupService(
- container.get(TYPES.Sync_S3_BACKUP_BUCKET_NAME),
- container.get(TYPES.Sync_ItemBackupMapper),
- container.get(TYPES.Sync_ItemHttpMapper),
- container.get(TYPES.Sync_Logger),
- container.get(TYPES.Sync_S3),
- )
- : new FSItemBackupService(
- container.get(TYPES.Sync_FILE_UPLOAD_PATH),
- container.get(TYPES.Sync_ItemBackupMapper),
- container.get(TYPES.Sync_Logger),
- ),
- )
- // use cases
- container
- .bind<GetItems>(TYPES.Sync_GetItems)
- .toConstantValue(
- new GetItems(
- container.get(TYPES.Sync_ItemRepositoryResolver),
- container.get(TYPES.Sync_SharedVaultUserRepository),
- container.get(TYPES.Sync_CONTENT_SIZE_TRANSFER_LIMIT),
- container.get(TYPES.Sync_ItemTransferCalculator),
- container.get(TYPES.Sync_Timer),
- container.get(TYPES.Sync_MAX_ITEMS_LIMIT),
- ),
- )
- container
- .bind<SaveNewItem>(TYPES.Sync_SaveNewItem)
- .toConstantValue(
- new SaveNewItem(
- container.get(TYPES.Sync_ItemRepositoryResolver),
- container.get(TYPES.Sync_Timer),
- container.get(TYPES.Sync_DomainEventPublisher),
- container.get(TYPES.Sync_DomainEventFactory),
- ),
- )
- container
- .bind<SendEventToClient>(TYPES.Sync_SendEventToClient)
- .toConstantValue(
- new SendEventToClient(
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- container.get<DomainEventPublisherInterface>(TYPES.Sync_DomainEventPublisher),
- ),
- )
- container
- .bind<AddNotificationForUser>(TYPES.Sync_AddNotificationForUser)
- .toConstantValue(
- new AddNotificationForUser(
- container.get<NotificationRepositoryInterface>(TYPES.Sync_NotificationRepository),
- container.get<TimerInterface>(TYPES.Sync_Timer),
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- container.get<SendEventToClient>(TYPES.Sync_SendEventToClient),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- container
- .bind<AddNotificationsForUsers>(TYPES.Sync_AddNotificationsForUsers)
- .toConstantValue(
- new AddNotificationsForUsers(
- container.get<SharedVaultUserRepositoryInterface>(TYPES.Sync_SharedVaultUserRepository),
- container.get<AddNotificationForUser>(TYPES.Sync_AddNotificationForUser),
- ),
- )
- container
- .bind<RemoveNotificationsForUser>(TYPES.Sync_RemoveNotificationsForUser)
- .toConstantValue(new RemoveNotificationsForUser(container.get(TYPES.Sync_NotificationRepository)))
- container
- .bind<UpdateExistingItem>(TYPES.Sync_UpdateExistingItem)
- .toConstantValue(
- new UpdateExistingItem(
- container.get<ItemRepositoryResolverInterface>(TYPES.Sync_ItemRepositoryResolver),
- container.get<TimerInterface>(TYPES.Sync_Timer),
- container.get<DomainEventPublisherInterface>(TYPES.Sync_DomainEventPublisher),
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- container.get<number>(TYPES.Sync_REVISIONS_FREQUENCY),
- container.get<DetermineSharedVaultOperationOnItem>(TYPES.Sync_DetermineSharedVaultOperationOnItem),
- container.get<AddNotificationsForUsers>(TYPES.Sync_AddNotificationsForUsers),
- container.get<RemoveNotificationsForUser>(TYPES.Sync_RemoveNotificationsForUser),
- ),
- )
- container
- .bind<SaveItems>(TYPES.Sync_SaveItems)
- .toConstantValue(
- new SaveItems(
- container.get(TYPES.Sync_ItemSaveValidator),
- container.get(TYPES.Sync_ItemRepositoryResolver),
- container.get(TYPES.Sync_Timer),
- container.get(TYPES.Sync_SaveNewItem),
- container.get(TYPES.Sync_UpdateExistingItem),
- container.get(TYPES.Sync_Logger),
- ),
- )
- container
- .bind<GetUserNotifications>(TYPES.Sync_GetUserNotifications)
- .toConstantValue(new GetUserNotifications(container.get(TYPES.Sync_NotificationRepository)))
- container
- .bind<GetSharedVaults>(TYPES.Sync_GetSharedVaults)
- .toConstantValue(
- new GetSharedVaults(
- container.get(TYPES.Sync_SharedVaultUserRepository),
- container.get(TYPES.Sync_SharedVaultRepository),
- ),
- )
- container
- .bind<GetSharedVaultInvitesSentToUser>(TYPES.Sync_GetSharedVaultInvitesSentToUser)
- .toConstantValue(new GetSharedVaultInvitesSentToUser(container.get(TYPES.Sync_SharedVaultInviteRepository)))
- container
- .bind<GetMessagesSentToUser>(TYPES.Sync_GetMessagesSentToUser)
- .toConstantValue(new GetMessagesSentToUser(container.get(TYPES.Sync_MessageRepository)))
- container
- .bind<SyncItems>(TYPES.Sync_SyncItems)
- .toConstantValue(
- new SyncItems(
- container.get<ItemRepositoryResolverInterface>(TYPES.Sync_ItemRepositoryResolver),
- container.get<GetItems>(TYPES.Sync_GetItems),
- container.get<SaveItems>(TYPES.Sync_SaveItems),
- container.get<GetSharedVaults>(TYPES.Sync_GetSharedVaults),
- container.get<GetSharedVaultInvitesSentToUser>(TYPES.Sync_GetSharedVaultInvitesSentToUser),
- container.get<GetMessagesSentToUser>(TYPES.Sync_GetMessagesSentToUser),
- container.get<GetUserNotifications>(TYPES.Sync_GetUserNotifications),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- container.bind<CheckIntegrity>(TYPES.Sync_CheckIntegrity).toDynamicValue((context: interfaces.Context) => {
- return new CheckIntegrity(context.container.get(TYPES.Sync_ItemRepositoryResolver))
- })
- container.bind<GetItem>(TYPES.Sync_GetItem).toDynamicValue((context: interfaces.Context) => {
- return new GetItem(context.container.get(TYPES.Sync_ItemRepositoryResolver))
- })
- container
- .bind<InviteUserToSharedVault>(TYPES.Sync_InviteUserToSharedVault)
- .toConstantValue(
- new InviteUserToSharedVault(
- container.get<SharedVaultRepositoryInterface>(TYPES.Sync_SharedVaultRepository),
- container.get<SharedVaultInviteRepositoryInterface>(TYPES.Sync_SharedVaultInviteRepository),
- container.get<SharedVaultUserRepositoryInterface>(TYPES.Sync_SharedVaultUserRepository),
- container.get<TimerInterface>(TYPES.Sync_Timer),
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- container.get<SendEventToClient>(TYPES.Sync_SendEventToClient),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- container
- .bind<UpdateSharedVaultInvite>(TYPES.Sync_UpdateSharedVaultInvite)
- .toConstantValue(
- new UpdateSharedVaultInvite(
- container.get(TYPES.Sync_SharedVaultInviteRepository),
- container.get(TYPES.Sync_Timer),
- ),
- )
- container
- .bind<AddUserToSharedVault>(TYPES.Sync_AddUserToSharedVault)
- .toConstantValue(
- new AddUserToSharedVault(
- container.get<SharedVaultRepositoryInterface>(TYPES.Sync_SharedVaultRepository),
- container.get<SharedVaultUserRepositoryInterface>(TYPES.Sync_SharedVaultUserRepository),
- container.get<TimerInterface>(TYPES.Sync_Timer),
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- container.get<DomainEventPublisherInterface>(TYPES.Sync_DomainEventPublisher),
- container.get<AddNotificationsForUsers>(TYPES.Sync_AddNotificationsForUsers),
- ),
- )
- container
- .bind<AcceptInviteToSharedVault>(TYPES.Sync_AcceptInviteToSharedVault)
- .toConstantValue(
- new AcceptInviteToSharedVault(
- container.get(TYPES.Sync_AddUserToSharedVault),
- container.get(TYPES.Sync_SharedVaultInviteRepository),
- ),
- )
- container
- .bind<CancelInviteToSharedVault>(TYPES.Sync_DeclineInviteToSharedVault)
- .toConstantValue(
- new CancelInviteToSharedVault(
- container.get<SharedVaultInviteRepositoryInterface>(TYPES.Sync_SharedVaultInviteRepository),
- container.get<AddNotificationForUser>(TYPES.Sync_AddNotificationForUser),
- ),
- )
- container
- .bind<DeleteSharedVaultInvitesToUser>(TYPES.Sync_DeleteSharedVaultInvitesToUser)
- .toConstantValue(
- new DeleteSharedVaultInvitesToUser(
- container.get(TYPES.Sync_SharedVaultInviteRepository),
- container.get(TYPES.Sync_DeclineInviteToSharedVault),
- ),
- )
- container
- .bind<DeleteSharedVaultInvitesSentByUser>(TYPES.Sync_DeleteSharedVaultInvitesSentByUser)
- .toConstantValue(
- new DeleteSharedVaultInvitesSentByUser(
- container.get(TYPES.Sync_SharedVaultInviteRepository),
- container.get(TYPES.Sync_DeclineInviteToSharedVault),
- ),
- )
- container
- .bind<GetSharedVaultInvitesSentByUser>(TYPES.Sync_GetSharedVaultInvitesSentByUser)
- .toConstantValue(new GetSharedVaultInvitesSentByUser(container.get(TYPES.Sync_SharedVaultInviteRepository)))
- container
- .bind<GetSharedVaultUsers>(TYPES.Sync_GetSharedVaultUsers)
- .toConstantValue(
- new GetSharedVaultUsers(
- container.get(TYPES.Sync_SharedVaultUserRepository),
- container.get(TYPES.Sync_SharedVaultRepository),
- ),
- )
- container
- .bind<RemoveUserFromSharedVault>(TYPES.Sync_RemoveSharedVaultUser)
- .toConstantValue(
- new RemoveUserFromSharedVault(
- container.get<SharedVaultUserRepositoryInterface>(TYPES.Sync_SharedVaultUserRepository),
- container.get<SharedVaultRepositoryInterface>(TYPES.Sync_SharedVaultRepository),
- container.get<AddNotificationsForUsers>(TYPES.Sync_AddNotificationsForUsers),
- container.get<AddNotificationForUser>(TYPES.Sync_AddNotificationForUser),
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- container.get<DomainEventPublisherInterface>(TYPES.Sync_DomainEventPublisher),
- ),
- )
- container
- .bind<CreateSharedVault>(TYPES.Sync_CreateSharedVault)
- .toConstantValue(
- new CreateSharedVault(
- container.get(TYPES.Sync_AddUserToSharedVault),
- container.get(TYPES.Sync_SharedVaultRepository),
- container.get(TYPES.Sync_Timer),
- ),
- )
- container
- .bind<CreateSharedVaultFileValetToken>(TYPES.Sync_CreateSharedVaultFileValetToken)
- .toConstantValue(
- new CreateSharedVaultFileValetToken(
- container.get(TYPES.Sync_SharedVaultRepository),
- container.get(TYPES.Sync_SharedVaultUserRepository),
- container.get(TYPES.Sync_SharedVaultValetTokenEncoder),
- container.get(TYPES.Sync_VALET_TOKEN_TTL),
- ),
- )
- container
- .bind<GetMessagesSentByUser>(TYPES.Sync_GetMessagesSentByUser)
- .toConstantValue(new GetMessagesSentByUser(container.get(TYPES.Sync_MessageRepository)))
- container
- .bind<SendMessageToUser>(TYPES.Sync_SendMessageToUser)
- .toConstantValue(
- new SendMessageToUser(
- container.get<MessageRepositoryInterface>(TYPES.Sync_MessageRepository),
- container.get<TimerInterface>(TYPES.Sync_Timer),
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- container.get<SendEventToClient>(TYPES.Sync_SendEventToClient),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- container
- .bind<DeleteMessage>(TYPES.Sync_DeleteMessage)
- .toConstantValue(new DeleteMessage(container.get(TYPES.Sync_MessageRepository)))
- container
- .bind<DeleteAllMessagesSentToUser>(TYPES.Sync_DeleteAllMessagesSentToUser)
- .toConstantValue(
- new DeleteAllMessagesSentToUser(
- container.get(TYPES.Sync_MessageRepository),
- container.get(TYPES.Sync_DeleteMessage),
- ),
- )
- container
- .bind<UpdateStorageQuotaUsedInSharedVault>(TYPES.Sync_UpdateStorageQuotaUsedInSharedVault)
- .toConstantValue(
- new UpdateStorageQuotaUsedInSharedVault(
- container.get<SharedVaultRepositoryInterface>(TYPES.Sync_SharedVaultRepository),
- ),
- )
- container
- .bind<TransitionItemsFromPrimaryToSecondaryDatabaseForUser>(
- TYPES.Sync_TransitionItemsFromPrimaryToSecondaryDatabaseForUser,
- )
- .toConstantValue(
- new TransitionItemsFromPrimaryToSecondaryDatabaseForUser(
- container.get<ItemRepositoryInterface>(TYPES.Sync_SQLItemRepository),
- isSecondaryDatabaseEnabled ? container.get<ItemRepositoryInterface>(TYPES.Sync_MongoDBItemRepository) : null,
- isConfiguredForInMemoryCache
- ? null
- : container.get<TransitionRepositoryInterface>(TYPES.Sync_TransitionStatusRepository),
- container.get<TimerInterface>(TYPES.Sync_Timer),
- container.get<Logger>(TYPES.Sync_Logger),
- env.get('MIGRATION_BATCH_SIZE', true) ? +env.get('MIGRATION_BATCH_SIZE', true) : 100,
- container.get<DomainEventPublisherInterface>(TYPES.Sync_DomainEventPublisher),
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- ),
- )
- container
- .bind<RemoveItemsFromSharedVault>(TYPES.Sync_RemoveItemsFromSharedVault)
- .toConstantValue(
- new RemoveItemsFromSharedVault(
- isSecondaryDatabaseEnabled
- ? container.get<ItemRepositoryInterface>(TYPES.Sync_MongoDBItemRepository)
- : container.get<ItemRepositoryInterface>(TYPES.Sync_SQLItemRepository),
- ),
- )
- container
- .bind<DesignateSurvivor>(TYPES.Sync_DesignateSurvivor)
- .toConstantValue(
- new DesignateSurvivor(
- container.get<SharedVaultRepositoryInterface>(TYPES.Sync_SharedVaultRepository),
- container.get<SharedVaultUserRepositoryInterface>(TYPES.Sync_SharedVaultUserRepository),
- container.get<TimerInterface>(TYPES.Sync_Timer),
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- container.get<DomainEventPublisherInterface>(TYPES.Sync_DomainEventPublisher),
- container.get<AddNotificationForUser>(TYPES.Sync_AddNotificationForUser),
- ),
- )
- container
- .bind<RemoveUserFromSharedVaults>(TYPES.Sync_RemoveUserFromSharedVaults)
- .toConstantValue(
- new RemoveUserFromSharedVaults(
- container.get<SharedVaultUserRepositoryInterface>(TYPES.Sync_SharedVaultUserRepository),
- container.get<RemoveUserFromSharedVault>(TYPES.Sync_RemoveSharedVaultUser),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- container
- .bind<TransferSharedVaultItems>(TYPES.Sync_TransferSharedVaultItems)
- .toConstantValue(
- new TransferSharedVaultItems(
- isSecondaryDatabaseEnabled
- ? container.get<ItemRepositoryInterface>(TYPES.Sync_MongoDBItemRepository)
- : container.get<ItemRepositoryInterface>(TYPES.Sync_SQLItemRepository),
- ),
- )
- container
- .bind<TransferSharedVault>(TYPES.Sync_TransferSharedVault)
- .toConstantValue(
- new TransferSharedVault(
- container.get<SharedVaultRepositoryInterface>(TYPES.Sync_SharedVaultRepository),
- container.get<SharedVaultUserRepositoryInterface>(TYPES.Sync_SharedVaultUserRepository),
- container.get<TransferSharedVaultItems>(TYPES.Sync_TransferSharedVaultItems),
- container.get<TimerInterface>(TYPES.Sync_Timer),
- ),
- )
- container
- .bind<DeleteSharedVault>(TYPES.Sync_DeleteSharedVault)
- .toConstantValue(
- new DeleteSharedVault(
- container.get<SharedVaultRepositoryInterface>(TYPES.Sync_SharedVaultRepository),
- container.get<SharedVaultUserRepositoryInterface>(TYPES.Sync_SharedVaultUserRepository),
- container.get<SharedVaultInviteRepositoryInterface>(TYPES.Sync_SharedVaultInviteRepository),
- container.get<RemoveUserFromSharedVault>(TYPES.Sync_RemoveSharedVaultUser),
- container.get<CancelInviteToSharedVault>(TYPES.Sync_DeclineInviteToSharedVault),
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- container.get<DomainEventPublisherInterface>(TYPES.Sync_DomainEventPublisher),
- container.get<TransferSharedVault>(TYPES.Sync_TransferSharedVault),
- ),
- )
- container
- .bind<DeleteSharedVaults>(TYPES.Sync_DeleteSharedVaults)
- .toConstantValue(
- new DeleteSharedVaults(
- container.get<SharedVaultRepositoryInterface>(TYPES.Sync_SharedVaultRepository),
- container.get<DeleteSharedVault>(TYPES.Sync_DeleteSharedVault),
- ),
- )
- container
- .bind<DumpItem>(TYPES.Sync_DumpItem)
- .toConstantValue(
- new DumpItem(
- container.get<ItemRepositoryResolverInterface>(TYPES.Sync_ItemRepositoryResolver),
- container.get<ItemBackupServiceInterface>(TYPES.Sync_ItemBackupService),
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- container.get<DomainEventPublisherInterface>(TYPES.Sync_DomainEventPublisher),
- ),
- )
- // Services
- container
- .bind<SyncResponseFactory20161215>(TYPES.Sync_SyncResponseFactory20161215)
- .toConstantValue(new SyncResponseFactory20161215(container.get(TYPES.Sync_ItemHttpMapper)))
- container
- .bind<SyncResponseFactory20200115>(TYPES.Sync_SyncResponseFactory20200115)
- .toConstantValue(
- new SyncResponseFactory20200115(
- container.get(TYPES.Sync_ItemHttpMapper),
- container.get(TYPES.Sync_ItemConflictHttpMapper),
- container.get(TYPES.Sync_SavedItemHttpMapper),
- container.get(TYPES.Sync_SharedVaultHttpMapper),
- container.get(TYPES.Sync_SharedVaultInviteHttpMapper),
- container.get(TYPES.Sync_MessageHttpMapper),
- container.get(TYPES.Sync_NotificationHttpMapper),
- ),
- )
- container
- .bind<SyncResponseFactoryResolverInterface>(TYPES.Sync_SyncResponseFactoryResolver)
- .toDynamicValue((context: interfaces.Context) => {
- return new SyncResponseFactoryResolver(
- context.container.get(TYPES.Sync_SyncResponseFactory20161215),
- context.container.get(TYPES.Sync_SyncResponseFactory20200115),
- )
- })
- // Handlers
- container
- .bind<DuplicateItemSyncedEventHandler>(TYPES.Sync_DuplicateItemSyncedEventHandler)
- .toConstantValue(
- new DuplicateItemSyncedEventHandler(
- container.get<ItemRepositoryResolverInterface>(TYPES.Sync_ItemRepositoryResolver),
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- container.get<DomainEventPublisherInterface>(TYPES.Sync_DomainEventPublisher),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- container
- .bind<AccountDeletionRequestedEventHandler>(TYPES.Sync_AccountDeletionRequestedEventHandler)
- .toConstantValue(
- new AccountDeletionRequestedEventHandler(
- container.get<ItemRepositoryResolverInterface>(TYPES.Sync_ItemRepositoryResolver),
- container.get<DeleteSharedVaults>(TYPES.Sync_DeleteSharedVaults),
- container.get<RemoveUserFromSharedVaults>(TYPES.Sync_RemoveUserFromSharedVaults),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- container
- .bind<ItemRevisionCreationRequestedEventHandler>(TYPES.Sync_ItemRevisionCreationRequestedEventHandler)
- .toConstantValue(
- new ItemRevisionCreationRequestedEventHandler(
- container.get<DumpItem>(TYPES.Sync_DumpItem),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- container
- .bind<SharedVaultFileUploadedEventHandler>(TYPES.Sync_SharedVaultFileUploadedEventHandler)
- .toConstantValue(
- new SharedVaultFileUploadedEventHandler(
- container.get<UpdateStorageQuotaUsedInSharedVault>(TYPES.Sync_UpdateStorageQuotaUsedInSharedVault),
- container.get<AddNotificationsForUsers>(TYPES.Sync_AddNotificationsForUsers),
- container.get<winston.Logger>(TYPES.Sync_Logger),
- ),
- )
- container
- .bind<SharedVaultFileRemovedEventHandler>(TYPES.Sync_SharedVaultFileRemovedEventHandler)
- .toConstantValue(
- new SharedVaultFileRemovedEventHandler(
- container.get<UpdateStorageQuotaUsedInSharedVault>(TYPES.Sync_UpdateStorageQuotaUsedInSharedVault),
- container.get<AddNotificationsForUsers>(TYPES.Sync_AddNotificationsForUsers),
- container.get<winston.Logger>(TYPES.Sync_Logger),
- ),
- )
- container
- .bind<SharedVaultFileMovedEventHandler>(TYPES.Sync_SharedVaultFileMovedEventHandler)
- .toConstantValue(
- new SharedVaultFileMovedEventHandler(
- container.get<UpdateStorageQuotaUsedInSharedVault>(TYPES.Sync_UpdateStorageQuotaUsedInSharedVault),
- container.get<AddNotificationsForUsers>(TYPES.Sync_AddNotificationsForUsers),
- container.get<winston.Logger>(TYPES.Sync_Logger),
- ),
- )
- container
- .bind<TransitionRequestedEventHandler>(TYPES.Sync_TransitionRequestedEventHandler)
- .toConstantValue(
- new TransitionRequestedEventHandler(
- false,
- container.get<TransitionItemsFromPrimaryToSecondaryDatabaseForUser>(
- TYPES.Sync_TransitionItemsFromPrimaryToSecondaryDatabaseForUser,
- ),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- container
- .bind<SharedVaultRemovedEventHandler>(TYPES.Sync_SharedVaultRemovedEventHandler)
- .toConstantValue(
- new SharedVaultRemovedEventHandler(
- container.get<RemoveItemsFromSharedVault>(TYPES.Sync_RemoveItemsFromSharedVault),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- // Services
- container.bind<ContentDecoder>(TYPES.Sync_ContentDecoder).toDynamicValue(() => new ContentDecoder())
- container.bind<AxiosInstance>(TYPES.Sync_HTTPClient).toDynamicValue(() => axios.create())
- container
- .bind<ExtensionsHttpServiceInterface>(TYPES.Sync_ExtensionsHttpService)
- .toConstantValue(
- new ExtensionsHttpService(
- container.get<AxiosInstance>(TYPES.Sync_HTTPClient),
- container.get<ItemRepositoryInterface>(TYPES.Sync_SQLItemRepository),
- isSecondaryDatabaseEnabled ? container.get<ItemRepositoryInterface>(TYPES.Sync_MongoDBItemRepository) : null,
- container.get<ContentDecoderInterface>(TYPES.Sync_ContentDecoder),
- container.get<DomainEventPublisherInterface>(TYPES.Sync_DomainEventPublisher),
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- const eventHandlers: Map<string, DomainEventHandlerInterface> = new Map([
- ['DUPLICATE_ITEM_SYNCED', container.get(TYPES.Sync_DuplicateItemSyncedEventHandler)],
- ['ACCOUNT_DELETION_REQUESTED', container.get(TYPES.Sync_AccountDeletionRequestedEventHandler)],
- ['ITEM_REVISION_CREATION_REQUESTED', container.get(TYPES.Sync_ItemRevisionCreationRequestedEventHandler)],
- [
- 'SHARED_VAULT_FILE_UPLOADED',
- container.get<SharedVaultFileUploadedEventHandler>(TYPES.Sync_SharedVaultFileUploadedEventHandler),
- ],
- [
- 'SHARED_VAULT_FILE_REMOVED',
- container.get<SharedVaultFileRemovedEventHandler>(TYPES.Sync_SharedVaultFileRemovedEventHandler),
- ],
- [
- 'SHARED_VAULT_FILE_MOVED',
- container.get<SharedVaultFileMovedEventHandler>(TYPES.Sync_SharedVaultFileMovedEventHandler),
- ],
- [
- 'TRANSITION_REQUESTED',
- container.get<TransitionRequestedEventHandler>(TYPES.Sync_TransitionRequestedEventHandler),
- ],
- [
- 'SHARED_VAULT_REMOVED',
- container.get<SharedVaultRemovedEventHandler>(TYPES.Sync_SharedVaultRemovedEventHandler),
- ],
- ])
- if (!isConfiguredForHomeServer) {
- container.bind(TYPES.Sync_AUTH_SERVER_URL).toConstantValue(env.get('AUTH_SERVER_URL'))
- container
- .bind<AuthHttpServiceInterface>(TYPES.Sync_AuthHttpService)
- .toDynamicValue((context: interfaces.Context) => {
- return new AuthHttpService(
- context.container.get(TYPES.Sync_HTTPClient),
- context.container.get(TYPES.Sync_AUTH_SERVER_URL),
- )
- })
- container
- .bind<EmailBackupRequestedEventHandler>(TYPES.Sync_EmailBackupRequestedEventHandler)
- .toConstantValue(
- new EmailBackupRequestedEventHandler(
- container.get<ItemRepositoryInterface>(TYPES.Sync_SQLItemRepository),
- isSecondaryDatabaseEnabled
- ? container.get<ItemRepositoryInterface>(TYPES.Sync_MongoDBItemRepository)
- : null,
- container.get<AuthHttpServiceInterface>(TYPES.Sync_AuthHttpService),
- container.get<ItemBackupServiceInterface>(TYPES.Sync_ItemBackupService),
- container.get<DomainEventPublisherInterface>(TYPES.Sync_DomainEventPublisher),
- container.get<DomainEventFactoryInterface>(TYPES.Sync_DomainEventFactory),
- container.get<number>(TYPES.Sync_EMAIL_ATTACHMENT_MAX_BYTE_SIZE),
- container.get<ItemTransferCalculatorInterface>(TYPES.Sync_ItemTransferCalculator),
- container.get<string>(TYPES.Sync_S3_BACKUP_BUCKET_NAME),
- container.get<Logger>(TYPES.Sync_Logger),
- ),
- )
- eventHandlers.set('EMAIL_BACKUP_REQUESTED', container.get(TYPES.Sync_EmailBackupRequestedEventHandler))
- }
- if (isConfiguredForHomeServer) {
- const directCallEventMessageHandler = new DirectCallEventMessageHandler(
- eventHandlers,
- container.get(TYPES.Sync_Logger),
- )
- directCallDomainEventPublisher.register(directCallEventMessageHandler)
- container
- .bind<DomainEventMessageHandlerInterface>(TYPES.Sync_DomainEventMessageHandler)
- .toConstantValue(directCallEventMessageHandler)
- } else {
- container
- .bind<DomainEventMessageHandlerInterface>(TYPES.Sync_DomainEventMessageHandler)
- .toConstantValue(new SQSEventMessageHandler(eventHandlers, container.get(TYPES.Sync_Logger)))
- }
- container
- .bind<DomainEventSubscriberFactoryInterface>(TYPES.Sync_DomainEventSubscriberFactory)
- .toDynamicValue((context: interfaces.Context) => {
- return new SQSDomainEventSubscriberFactory(
- context.container.get(TYPES.Sync_SQS),
- context.container.get(TYPES.Sync_SQS_QUEUE_URL),
- context.container.get(TYPES.Sync_DomainEventMessageHandler),
- )
- })
- container
- .bind<ControllerContainerInterface>(TYPES.Sync_ControllerContainer)
- .toConstantValue(configuration?.controllerConatiner ?? new ControllerContainer())
- if (isConfiguredForHomeServer) {
- container
- .bind<BaseItemsController>(TYPES.Sync_BaseItemsController)
- .toConstantValue(
- new BaseItemsController(
- container.get<SyncItems>(TYPES.Sync_SyncItems),
- container.get<CheckIntegrity>(TYPES.Sync_CheckIntegrity),
- container.get<GetItem>(TYPES.Sync_GetItem),
- container.get<MapperInterface<Item, ItemHttpRepresentation>>(TYPES.Sync_ItemHttpMapper),
- container.get<SyncResponseFactoryResolverInterface>(TYPES.Sync_SyncResponseFactoryResolver),
- container.get<ControllerContainerInterface>(TYPES.Sync_ControllerContainer),
- ),
- )
- container
- .bind<BaseSharedVaultInvitesController>(TYPES.Sync_BaseSharedVaultInvitesController)
- .toConstantValue(
- new BaseSharedVaultInvitesController(
- container.get(TYPES.Sync_InviteUserToSharedVault),
- container.get(TYPES.Sync_UpdateSharedVaultInvite),
- container.get(TYPES.Sync_AcceptInviteToSharedVault),
- container.get(TYPES.Sync_DeclineInviteToSharedVault),
- container.get(TYPES.Sync_DeleteSharedVaultInvitesToUser),
- container.get(TYPES.Sync_DeleteSharedVaultInvitesSentByUser),
- container.get(TYPES.Sync_GetSharedVaultInvitesSentByUser),
- container.get(TYPES.Sync_GetSharedVaultInvitesSentToUser),
- container.get(TYPES.Sync_SharedVaultInviteHttpMapper),
- container.get(TYPES.Sync_ControllerContainer),
- ),
- )
- container
- .bind<BaseSharedVaultUsersController>(TYPES.Sync_BaseSharedVaultUsersController)
- .toConstantValue(
- new BaseSharedVaultUsersController(
- container.get<GetSharedVaultUsers>(TYPES.Sync_GetSharedVaultUsers),
- container.get<RemoveUserFromSharedVault>(TYPES.Sync_RemoveSharedVaultUser),
- container.get<DesignateSurvivor>(TYPES.Sync_DesignateSurvivor),
- container.get<MapperInterface<SharedVaultUser, SharedVaultUserHttpRepresentation>>(
- TYPES.Sync_SharedVaultUserHttpMapper,
- ),
- container.get<ControllerContainerInterface>(TYPES.Sync_ControllerContainer),
- ),
- )
- container
- .bind<BaseSharedVaultsController>(TYPES.Sync_BaseSharedVaultsController)
- .toConstantValue(
- new BaseSharedVaultsController(
- container.get(TYPES.Sync_GetSharedVaults),
- container.get(TYPES.Sync_CreateSharedVault),
- container.get(TYPES.Sync_DeleteSharedVault),
- container.get(TYPES.Sync_CreateSharedVaultFileValetToken),
- container.get(TYPES.Sync_SharedVaultHttpMapper),
- container.get(TYPES.Sync_SharedVaultUserHttpMapper),
- container.get(TYPES.Sync_ControllerContainer),
- ),
- )
- container
- .bind<BaseMessagesController>(TYPES.Sync_BaseMessagesController)
- .toConstantValue(
- new BaseMessagesController(
- container.get(TYPES.Sync_GetMessagesSentToUser),
- container.get(TYPES.Sync_GetMessagesSentByUser),
- container.get(TYPES.Sync_SendMessageToUser),
- container.get(TYPES.Sync_DeleteAllMessagesSentToUser),
- container.get(TYPES.Sync_DeleteMessage),
- container.get(TYPES.Sync_MessageHttpMapper),
- container.get(TYPES.Sync_ControllerContainer),
- ),
- )
- }
- logger.debug('Configuration complete')
- return container
- }
- }
|