MongooseModule.forRootAsync({
  connectionFactory: (connection) => {
    connection.plugin(SoftDeletePlugin);
    return connection;
  },
})

// Normal sorgu - sadece aktif kayıtlar
const activeStreams = await LiveStreamModel.find({ status: 'ACTIVE' });

// Silinmiş kayıtlar dahil
const allStreams = await LiveStreamModel.find({ 
  status: 'ACTIVE', 
  showDeleted: true 
});

// Sadece silinmiş kayıtlar
const deletedStreams = await LiveStreamModel.find({ 
  onlyDeleted: true 
});

@Prop({ type: Date, default: null })
deletedAt?: Date | null;

@Prop({ type: String, default: null })
deletedBy?: string | null;

  async softDeleteById(
    id: string,
    userId: string,
  ): Promise<LiveStreamDocument | null> {
    if (!Types.ObjectId.isValid(id)) {
      return null;
    }

    const liveStream = await this.liveStreamModel
      .findById(id)
      .populate(this.liveStreamUserPopulate)
      .exec();

    if (!liveStream) {
      return null;
    }

    // Plugin'in eklediği softDelete metodunu kullan
    await (liveStream as any).softDelete(userId);

    // save() işleminden sonra populate edilmiş referanslar kaybolmuş olabilir
    // Document'i tekrar populate et
    await liveStream.populate(this.liveStreamUserPopulate);

    return liveStream;
  }

  async findByIdWithDeleted(id: string): Promise<LiveStreamDocument | null> {
    if (!Types.ObjectId.isValid(id)) {
      return null;
    }

    const liveStream = await this.liveStreamModel
      .findOne({ _id: new Types.ObjectId(id), showDeleted: true } as any)
      .populate(this.liveStreamUserPopulate)
      .exec();

    return liveStream ?? null;
  }

  async restoreById(id: string): Promise<LiveStreamDocument | null> {
    if (!Types.ObjectId.isValid(id)) {
      return null;
    }

    const liveStream = await this.findByIdWithDeleted(id);

    if (!liveStream) {
      return null;
    }

    // Plugin'in eklediği restore metodunu kullan
    await (liveStream as any).restore();

    // Güncellenmiş document'i tekrar çek
    const restoredLiveStream = await this.liveStreamModel
      .findById(id)
      .populate(this.liveStreamUserPopulate)
      .exec();

    return restoredLiveStream ?? null;
  }

  async execute(
    userId: string,
    liveStreamId: string,
  ): Promise<LiveStreamResponseDto> {
    if (!liveStreamId) {
      throw new NotFoundException('Canlı yayın bulunamadı');
    }

    // Yayın bilgisini populate ile al (soft delete edilmiş olsa bile)
    const liveStream = await this.liveStreamRepo.findByIdWithDeleted(
      liveStreamId,
    );

    if (!liveStream) {
      throw new NotFoundException('Canlı yayın bulunamadı');
    }

    // Zaten soft delete edilmiş mi kontrol et
    if (liveStream.deletedAt) {
      throw new ConflictException('Yayın zaten silinmiş');
    }

    // Creator kontrolü
    const creatorId = LiveStreamMapper.extractId(
      liveStream.creator as unknown,
    );

    if (!creatorId) {
      this.logger.warn(
        `Creator ID could not be extracted from live stream ${liveStreamId}`,
      );
      throw new ForbiddenException(
        'Bu yayını sadece yayını oluşturan kişi silebilir',
      );
    }

    // MongoDB ObjectId karşılaştırması için normalize et
    let isCreator = false;
    try {
      const creatorObjectId = Types.ObjectId.isValid(creatorId)
        ? new Types.ObjectId(creatorId)
        : null;
      const userObjectId = Types.ObjectId.isValid(userId)
        ? new Types.ObjectId(userId)
        : null;

      if (creatorObjectId && userObjectId) {
        isCreator = creatorObjectId.equals(userObjectId);
      } else {
        // ObjectId'ye çevrilemezse string karşılaştırması yap
        const normalizedCreatorId = creatorId.trim().toLowerCase();
        const normalizedUserId = userId.trim().toLowerCase();
        isCreator = normalizedCreatorId === normalizedUserId;
      }
    } catch (error) {
      // Hata durumunda string karşılaştırması yap
      const normalizedCreatorId = creatorId.trim().toLowerCase();
      const normalizedUserId = userId.trim().toLowerCase();
      isCreator = normalizedCreatorId === normalizedUserId;
    }

    if (!isCreator) {
      this.logger.debug(
        `User ${userId} is not the creator of live stream ${liveStreamId}. Creator ID: ${creatorId}`,
      );
      throw new ForbiddenException(
        'Bu yayını sadece yayını oluşturan kişi silebilir',
      );
    }

    // Aktif yayınlar soft delete edilemez (önce end edilmeli)
    if (liveStream.status === LiveStreamStatus.ACTIVE) {
      throw new ConflictException(
        'Aktif yayınlar silinemez. Önce yayını sonlandırın.',
      );
    }

    // Soft delete işlemini yap
    const deletedLiveStream = await this.liveStreamRepo.softDeleteById(
      liveStreamId,
      userId,
    );

    if (!deletedLiveStream) {
      throw new NotFoundException('Yayın silinirken bir hata oluştu');
    }

    this.logger.log(
      `Live stream ${liveStreamId} soft deleted by creator ${userId}`,
    );

    return LiveStreamMapper.mapToResponseDto(deletedLiveStream);
  }

  @Delete(':id')
  @UseGuards(JwtAuthGuard)
  @ApiSoftDeleteLiveStream()
  async softDeleteLiveStream(
    @CurrentUser() user: JwtPayload,
    @Param('id') id: string,
  ): Promise<LiveStreamResponseDto> {
    return this.softDeleteLiveStreamUseCase.execute(user._id, id);
  }

// Sadece aktif (silinmemiş) yayınlar döner
const streams = await LiveStreamModel.find({ status: 'ENDED' });

// Silinmiş kayıtlar dahil tüm yayınlar
const allStreams = await LiveStreamModel.find({ 
  showDeleted: true 
});

// Sadece silinmiş yayınlar
const deletedStreams = await LiveStreamModel.find({ 
  onlyDeleted: true 
});

const restoredStream = await liveStreamRepo.restoreById(streamId);

const stream = await LiveStreamModel.findById(id);
await stream.softDelete(userId);

const stream = await LiveStreamModel.findOne({ _id: id, showDeleted: true });
await stream.restore();