namespace Fengling.Activity.Domain.Repositories;

using Fengling.Activity.Domain.Aggregates.Campaigns;
using Fengling.Activity.Domain.Aggregates.ParticipationRecords;
using Fengling.Activity.Domain.Enums;
using Fengling.Activity.Domain.ValueObjects;

public interface IParticipationRecordRepository
{
    Task<ParticipationRecord?> GetByIdAsync(ParticipationRecordId id, CancellationToken cancellationToken = default);
    Task<List<ParticipationRecord>> GetByCampaignIdAsync(CampaignId campaignId, CancellationToken cancellationToken = default);
    Task<List<ParticipationRecord>> GetByMemberIdAsync(TenantId tenantId, Guid memberId, CancellationToken cancellationToken = default);
    Task<ParticipationRecord?> GetByCampaignAndMemberAsync(CampaignId campaignId, Guid memberId, CancellationToken cancellationToken = default);
    Task<List<ParticipationRecord>> GetByStatusAsync(CampaignId campaignId, ParticipationStatus status, CancellationToken cancellationToken = default);
    Task<int> GetParticipationCountAsync(CampaignId campaignId, Guid memberId, CancellationToken cancellationToken = default);
    Task AddAsync(ParticipationRecord record, CancellationToken cancellationToken = default);
    Task UpdateAsync(ParticipationRecord record, CancellationToken cancellationToken = default);
    Task DeleteAsync(ParticipationRecord record, CancellationToken cancellationToken = default);
}