repository

type AiPromptLogRepository interface {
	Store(aiPrompt entity.AiPromptLog) (string, error)
	UpdateResponse(id string, rawResponse string) error
	UpdateError(id string, postProcessErrorMessage string) error
}

type AppKeyRepository interface {
	FindByKey(ctx context.Context, app string, key string) helper.QueryResult
}

type CurrencyRateRepository interface {
	GetLatestCurrencyRate(currency string) (*entity.CurrencyRate, error)
	SaveCurrencyRate(currency string, rate float64, date time.Time, source string) error
}

type EventBufferRepository interface {
	Upsert(eventBuffer *entity.EventBuffer) error
	GetByExpired(now time.Time) ([]entity.EventBuffer, error)
	GetByUUID(uuid string) (*entity.EventBuffer, error)
	Delete(eventBuffer *entity.EventBuffer) error
}

type GoogleServiceAccountKeyRepository interface {
	GetApiKeyByTenantService(ctx context.Context, tenantId, serviceId string) (string, error)
	SaveKey(ctx context.Context, tenant, key, value string) error
	DeleteKey(ctx context.Context, tenant, key string) error
}

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

type PersonalEmailProviderRepository interface {
	GetPersonalEmailProviders() ([]entity.PersonalEmailProvider, error)
}

type PersonalIntegrationRepository interface {
	FindIntegration(tenant, email, integration string) helper.QueryResult
	FindIntegrations(tenant, email string) helper.QueryResult
	SaveIntegration(integration entity.PersonalIntegration) helper.QueryResult
}

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

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

type PostmarkApiKeyRepository interface {
	GetPostmarkApiKey(tenant string) helper.QueryResult
	CreateApiKey(integration entity.PostmarkApiKey) helper.QueryResult
}

type Repositories struct {
	AppKeyRepository                  AppKeyRepository
	PersonalIntegrationRepository     PersonalIntegrationRepository
	AiPromptLogRepository             AiPromptLogRepository
	WhitelistDomainRepository         WhitelistDomainRepository
	PersonalEmailProviderRepository   PersonalEmailProviderRepository
	TenantWebhookApiKeyRepository     TenantWebhookApiKeyRepository
	TenantWebhookRepository           TenantWebhookRepository
	SlackChannelRepository            SlackChannelRepository
	PostmarkApiKeyRepository          PostmarkApiKeyRepository
	GoogleServiceAccountKeyRepository GoogleServiceAccountKeyRepository
	CurrencyRateRepository            CurrencyRateRepository
	EventBufferRepository             EventBufferRepository
	TableViewDefinitionRepository     TableViewDefinitionRepository
}

type SlackChannelRepository interface {
	GetSlackChannel(tenant, channelId string) (*entity.SlackChannel, error)
	GetSlackChannels(tenant string) ([]*entity.SlackChannel, error)
	GetPaginatedSlackChannels(tenant string, skip, limit int) ([]*entity.SlackChannel, int64, error)

	CreateSlackChannel(entity *entity.SlackChannel) error
	UpdateSlackChannelOrganization(entityId uuid.UUID, organizationId string) error
	UpdateSlackChannelName(entityId uuid.UUID, channelName string) error
}

type TableViewDefinitionRepository interface {
	GetTableViewDefinitions(ctx context.Context, tenant, userId string) helper.QueryResult
	CreateTableViewDefinition(ctx context.Context, viewDefinition entity.TableViewDefinition) helper.QueryResult
	UpdateTableViewDefinition(ctx context.Context, viewDefinition entity.TableViewDefinition) helper.QueryResult
}

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

type TenantWebhookApiKeyRepository interface {
	GetTenantWithApiKey(apiKey string) helper.QueryResult
	SaveApiKey(integration entity.TenantWebhookApiKey) helper.QueryResult
}

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

type TenantWebhookRepository interface {
	GetWebhook(tenant, event string) helper.QueryResult
	GetWebhooks(tenant string) helper.QueryResult
	CreateWebhook(integration entity.TenantWebhook) helper.QueryResult
}

type WhitelistDomainRepository interface {
	GetWildcardAllWhitelistDomain(tenant string) (*entity.WhitelistDomain, error)
	SaveWildcardAllWhitelistDomain(tenant, source, appSource string) error
	RemoveWildcardAllWhitelistDomain(tenant string) error

	SaveWhitelistDomain(whitelistDomain entity.WhitelistDomain) error
	GetWhitelistDomains(tenant string) ([]entity.WhitelistDomain, error)
}