src/infrastructure/infrastructure.module.ts - master - integrator2/dklt

src/infrastructure/infrastructure.module.ts
107 строк5 KB
sarkazi
first_commit
05 июн 2025, 14:40
05 июн 2025, 14:407f52590
import { BullQueueModule } from "@/infrastructure/bull/bull.module";
import { Module } from "@nestjs/common";
import { AccountRepository } from "@/infrastructure/account/repositories/account.repository";
import { AmoService } from "@/core/amo/amo.service";
import { ChatRepository } from "@/infrastructure/source/repositories/chat.repository";
import { MongooseModule } from "@nestjs/mongoose";
import { AccountSchema } from "@/infrastructure/account/schemas/account.schema";

import { OwnCrmService } from "@/core/own-crm/own-crm.service";

import { ChatSchema } from "@/infrastructure/source/schemas/chat.schema";
import { ChannelRepository } from "@/infrastructure/source/repositories/channel.repository";
import { OfferRepository } from "@/infrastructure/source/repositories/offer.repository";
import { SourceService } from "@/core/source/source.service";
import { RedisService } from "@/infrastructure/redis/redis.service";
import { FinanceService } from "@/core/account/finance.service";
import { SubscriptionRepository } from "@/infrastructure/account/repositories/subscription.repository";
import { WebsocketsService } from "@/infrastructure/network/websocket/websockets.service";
import { TransactionRepository } from "@/infrastructure/account/repositories/transaction.repository";
import { SubscriptionSchema } from "@/infrastructure/account/schemas/Subscription.model";
import { WebsocketsGateway } from "@/infrastructure/network/websocket/websockets.gateway";
import { TransactionSchema } from "@/infrastructure/account/schemas/Transaction.model";
import { GlobalLoggerService } from "@/infrastructure/logger/logger.service";
import { LostMessagesRepository } from "@/infrastructure/source/repositories/lost-message.repository";
import { SourceClientService } from "./source/source-client/source-client.service";
import { LostMessageSchema } from "./source/schemas/lost-message.schema";
import { MessageImporterService } from "@/core/source/message-importer.service";
import { ChannelSchema } from "./source/schemas/channel.schema";
import { OfferSchema } from "./source/schemas/offer.schema";
import { DatabaseModule } from "./mongoose/mongoose.module";
import { RedisModule } from "./redis/redis.module";
import { WebsocketsModule } from "./network/websocket/websockets.module";
import { UtilsService } from "@/core/utils/utils.service";

import { SourceIncomingMessageProcessor } from "@/core/source/processors/incoming-msg.processor";
import { AmoCrmIncomingMessageProcessor } from "@/core/amo/processors/incoming-msg.processor";
import { ChangeContactResponsibleProcessor } from "@/core/amo/processors/change-contact-responsible.processor";
import { FindTargetUnsortedProcessor } from "@/core/amo/processors/find-target-unsorted.processor";
import { AccountDataUpdatingProcessor } from "@/core/account/processors/account-data-updating.processor";
import { AmoRateLimiterProcessor } from "@/core/amo/processors/axios.rate-limiter.processor";
import { AmoRefreshTokensProcessor } from "@/core/amo/processors/refresh-token.processor";

@Module({
  imports: [
    BullQueueModule,
    MongooseModule.forFeature([
      { name: "Account", schema: AccountSchema },
      { name: "Chat", schema: ChatSchema },
      { name: "Channel", schema: ChannelSchema },
      { name: "Offer", schema: OfferSchema },
      { name: "Subscription", schema: SubscriptionSchema },
      { name: "Transaction", schema: TransactionSchema },
      { name: "LostMessage", schema: LostMessageSchema },
    ]),
    DatabaseModule,
    RedisModule,
    WebsocketsModule,
  ],
  providers: [
    AmoRefreshTokensProcessor,
    SourceIncomingMessageProcessor,
    AmoCrmIncomingMessageProcessor,
    ChangeContactResponsibleProcessor,
    AmoRateLimiterProcessor,
    FindTargetUnsortedProcessor,
    AccountDataUpdatingProcessor,
    AccountRepository,
    AmoService,
    ChatRepository,
    OwnCrmService,
    ChannelRepository,
    OfferRepository,
    MessageImporterService,
    SourceService,
    RedisService,
    FinanceService,
    SubscriptionRepository,
    LostMessagesRepository,
    SourceClientService,
    WebsocketsService,
    TransactionRepository,
    WebsocketsGateway,
    GlobalLoggerService,
    UtilsService,
  ],
  exports: [
    AccountRepository,
    AmoService,
    ChatRepository,
    OwnCrmService,
    ChannelRepository,
    OfferRepository,
    MessageImporterService,
    SourceService,
    RedisService,
    FinanceService,
    SubscriptionRepository,
    LostMessagesRepository,
    SourceClientService,
    WebsocketsService,
    TransactionRepository,
    WebsocketsGateway,
    GlobalLoggerService,
    UtilsService,
  ],
})
export class InfrastructureModule {}