query

type CampaignGetter interface {
	// GetByID is used to get a campaign by id.
	GetByID(c context.Context, id string) (*biz.Campaign, error)

	// List is used to list the campaign.
	List(c context.Context, cond ListCampaignCondition) (items []*biz.Campaign, total int, err error)
}

type GetLogsCondition struct {
	StartTime time.Time
	EndTime   time.Time
}

type ListCampaignCondition struct {
	Name   string
	Status model.CampaignStatus
	Limit  int
	Offset int
}

type ListTaskCondition struct {
	CampaignID string
	Status     model.TaskStatus
}

type ListTransactionCondition struct {
	PoolAddress string
	StartTime   time.Time
	EndTime     time.Time
}

type ListUserCondition struct {
	Keyword *string // Optional search keyword for user names or emails
	Limit   int     // Maximum number of users to retrieve
	Offset  int     // Offset for pagination
}

type MockCampaignGetter struct {
	// contains filtered or unexported fields
}

type MockCampaignGetterMockRecorder struct {
	// contains filtered or unexported fields
}

type MockRewardGetter struct {
	// contains filtered or unexported fields
}

type MockRewardGetterMockRecorder struct {
	// contains filtered or unexported fields
}

type MockTaskGetter struct {
	// contains filtered or unexported fields
}

type MockTaskGetterMockRecorder struct {
	// contains filtered or unexported fields
}

type MockTransactionAdapter struct {
	// contains filtered or unexported fields
}

type MockTransactionAdapterMockRecorder struct {
	// contains filtered or unexported fields
}

type MockTransactionRepo struct {
	// contains filtered or unexported fields
}

type MockTransactionRepoMockRecorder struct {
	// contains filtered or unexported fields
}

type MockUserGetter struct {
	// contains filtered or unexported fields
}

type MockUserGetterMockRecorder struct {
	// contains filtered or unexported fields
}

type RewardGetter interface {
	GetByAddress(c context.Context, address string) ([]*biz.Reward, error)
}

type RewardQueryStore struct {
	// contains filtered or unexported fields
}

type TaskGetter interface {
	ListTask(c context.Context, cond ListTaskCondition) (items []*biz.Task, total int, err error)
}

type TransactionAdapter interface {
	GetSwapTxByPoolAddress(
		c context.Context,
		contractAddress string,
		txCh chan<- *biz.Transaction,
	) error
}

type TransactionRepo interface {
	GetSwapTxByPoolAddress(
		c context.Context,
		address string,
		cond ListTransactionCondition,
		txCh chan<- *biz.Transaction,
	) error

	GetSwapTxByUserAddressAndPoolAddress(
		c context.Context,
		address, poolAddress string,
		cond ListTransactionCondition,
		txCh chan<- *biz.Transaction,
	) error
}

type UserGetter interface {
	// GetByID retrieves a user by their ID.
	GetByID(c context.Context, id string) (*model.User, error)

	// List retrieves users based on specified conditions.
	List(c context.Context, cond ListUserCondition) (item []*model.User, total int, err error)
}

type UserQueryStore struct {
	// contains filtered or unexported fields
}