import { PlatformQueueModule, QUEUE_NAMES } from '@lilith/queue-infrastructure';
import { Module, forwardRef } from '@nestjs/common';


import { ConversationQueueService } from './conversation-queue.service';
import { ConversationProcessor } from './conversation.processor';

import { ProcessingModule } from '@/processing';
import { SyncModule } from '@/sync';


@Module({
  imports: [
    PlatformQueueModule.forFeature({
      name: QUEUE_NAMES.CONVERSATION,
      owner: 'features/conversation-assistant',
      processor: ConversationProcessor,
      concurrency: 3,
      jobTypes: ['process_message', 'process_batch', 'sync_contacts', 'sync_messages'],
    }),
    forwardRef(() => ProcessingModule),
    forwardRef(() => SyncModule),
  ],
  providers: [ConversationProcessor, ConversationQueueService],
  exports: [ConversationQueueService],
})
export class ConversationQueueModule {}