domain

type BuildJobTemplateData struct {
	AccountName string
	Name        string
	Namespace   string
	Labels      map[string]string
	Annotations map[string]string

	Registry     dbv1.Registry
	Caches       []dbv1.Cache
	Resource     dbv1.Resource
	GitRepo      dbv1.GitRepo
	BuildOptions *dbv1.BuildOptions

	CredentialsRef common_types.SecretRef
}

type CheckNameAvailabilityOutput struct {
	Result         bool     `json:"result"`
	SuggestedNames []string `json:"suggestedNames,omitempty"`
}

type Domain interface {
	ProcessRegistryEvents(ctx context.Context, events []entities.Event, logger logging.Logger) error

	CheckUserNameAvailability(ctx RegistryContext, username string) (*CheckNameAvailabilityOutput, error)

	// registry
	ListRepositories(ctx RegistryContext, search map[string]repos.MatchFilter, pagination repos.CursorPagination) (*repos.PaginatedRecord[*entities.Repository], error)
	CreateRepository(ctx RegistryContext, repoName string) (*entities.Repository, error)
	DeleteRepository(ctx RegistryContext, repoName string) error

	// tags
	ListRepositoryDigests(ctx RegistryContext, repoName string, search map[string]repos.MatchFilter, pagination repos.CursorPagination) (*repos.PaginatedRecord[*entities.Digest], error)
	DeleteRepositoryDigest(ctx RegistryContext, repoName string, digest string) error

	// credential
	ListCredentials(ctx RegistryContext, search map[string]repos.MatchFilter, pagination repos.CursorPagination) (*repos.PaginatedRecord[*entities.Credential], error)
	CreateCredential(ctx RegistryContext, credential entities.Credential) (*entities.Credential, error)
	DeleteCredential(ctx RegistryContext, userName string) error
	CreateAdminCredential(ctx RegistryContext, credential entities.Credential) (*entities.Credential, error)

	GetToken(ctx RegistryContext, username string) (string, error)
	GetTokenKey(ctx context.Context, username string, accountname string) (string, error)

	AddBuild(ctx RegistryContext, build entities.Build) (*entities.Build, error)
	UpdateBuild(ctx RegistryContext, id repos.ID, build entities.Build) (*entities.Build, error)
	UpdateBuildInternal(ctx context.Context, build *entities.Build) (*entities.Build, error)
	ListBuilds(ctx RegistryContext, repoName string, search map[string]repos.MatchFilter, pagination repos.CursorPagination) (*repos.PaginatedRecord[*entities.Build], error)
	GetBuild(ctx RegistryContext, buildId repos.ID) (*entities.Build, error)
	DeleteBuild(ctx RegistryContext, buildId repos.ID) error
	TriggerBuild(ctx RegistryContext, buildId repos.ID) error

	// webhook
	ParseGithubHook(eventType string, hookBody []byte) (*GitWebhookPayload, error)
	ParseGitlabHook(eventType string, hookBody []byte) (*GitWebhookPayload, error)

	GithubInstallationToken(ctx context.Context, repoUrl string) (string, error)
	GithubListInstallations(ctx context.Context, userId repos.ID, pagination *types.Pagination) ([]*entities.GithubInstallation, error)
	GithubListRepos(ctx context.Context, userId repos.ID, installationId int64, pagination *types.Pagination) (*entities.GithubListRepository, error)
	GithubSearchRepos(ctx context.Context, userId repos.ID, q, org string, pagination *types.Pagination) (*entities.GithubSearchRepository, error)
	GithubListBranches(ctx context.Context, userId repos.ID, repoUrl string, pagination *types.Pagination) ([]*entities.GitBranch, error)
	GithubAddWebhook(ctx context.Context, userId repos.ID, repoUrl string) (repos.ID, error)

	GitlabListGroups(ctx context.Context, userId repos.ID, query *string, pagination *types.Pagination) ([]*entities.GitlabGroup, error)
	GitlabListRepos(ctx context.Context, userId repos.ID, gid string, query *string, pagination *types.Pagination) ([]*entities.GitlabProject, error)
	GitlabListBranches(ctx context.Context, userId repos.ID, repoId string, query *string, pagination *types.Pagination) ([]*entities.GitBranch, error)
	GitlabAddWebhook(ctx context.Context, userId repos.ID, repoId string) (*int, error)
	GitlabPullToken(ctx context.Context, userId repos.ID) (string, error)

	GetBuildTemplate(obj BuildJobTemplateData) ([]byte, error)

	ListBuildsByGit(ctx context.Context, repoUrl, branch, provider string) ([]*entities.Build, error)

	// AddBuildCache(ctx RegistryContext, buildCache entities.BuildCacheKey) (*entities.BuildCacheKey, error)
	// UpdateBuildCache(ctx RegistryContext, id repos.ID, buildCache entities.BuildCacheKey) (*entities.BuildCacheKey, error)
	// DeleteBuildCache(ctx RegistryContext, id repos.ID) error
	// ListBuildCaches(ctx RegistryContext, search map[string]repos.MatchFilter, pagination repos.CursorPagination) (*repos.PaginatedRecord[*entities.BuildCacheKey], error)
	ListBuildRuns(ctx RegistryContext, search map[string]repos.MatchFilter, pagination repos.CursorPagination) (*repos.PaginatedRecord[*entities.BuildRun], error)
	GetLatestBuildRun(ctx RegistryContext, buildId repos.ID) (*entities.BuildRun, error)
	GetBuildRun(ctx RegistryContext, buildId repos.ID, runName string) (*entities.BuildRun, error)
	OnBuildRunUpdateMessage(ctx RegistryContext, buildRun entities.BuildRun, status t.ResourceStatus, opts UpdateAndDeleteOpts) error

	OnBuildRunDeleteMessage(ctx RegistryContext, buildRun entities.BuildRun) error
	OnBuildRunApplyErrorMessage(ctx RegistryContext, clusterName string, name string, errorMsg string) error
	// ListBuildsByCache(ctx RegistryContext, cacheId repos.ID, pagination repos.CursorPagination) (*repos.PaginatedRecord[*entities.Build], error)
	CreateBuildRun(ctx RegistryContext, build *entities.Build, hook *GitWebhookPayload, pullToken string, seed string) error
}

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

type GitWebhookPayload struct {
	GitProvider string `json:"git_provider,omitempty"`
	RepoUrl     string `json:"repo_url,omitempty"`
	GitBranch   string `json:"git_branch,omitempty"`
	CommitHash  string `json:"commit_hash,omitempty"`
}

type Github interface {
	Callback(ctx context.Context, code, state string) (*github.User, *oauth2.Token, error)
	GetToken(ctx context.Context, token *oauth2.Token) (*oauth2.Token, error)
	GetInstallationToken(ctx context.Context, repoUrl string) (string, error)

	ListInstallations(ctx context.Context, accToken *entities.AccessToken, pagination *types.Pagination) ([]*github.Installation, error)
	ListRepos(ctx context.Context, accToken *entities.AccessToken, instId int64, pagination *types.Pagination) (*github.ListRepositories, error)
	SearchRepos(ctx context.Context, accToken *entities.AccessToken, q, org string, pagination *types.Pagination) (*github.RepositoriesSearchResult, error)
	ListBranches(ctx context.Context, accToken *entities.AccessToken, repoUrl string, pagination *types.Pagination) ([]*github.Branch, error)
	CheckWebhookExists(ctx context.Context, token *entities.AccessToken, repoUrl string, webhookId *entities.GithubWebhookId) (bool, error)
	AddWebhook(ctx context.Context, accToken *entities.AccessToken, repoUrl string, webhookUrl string) (*entities.GithubWebhookId, error)
	DeleteWebhook(ctx context.Context, accToken *entities.AccessToken, repoUrl string, hookId entities.GithubWebhookId) error
	GetLatestCommit(ctx context.Context, accToken *entities.AccessToken, repoUrl string, branchName string) (string, error)
}

type Gitlab interface {
	Callback(ctx context.Context, code, state string) (*gitlab.User, *oauth2.Token, error)
	ListGroups(ctx context.Context, token *entities.AccessToken, query *string, pagination *types.Pagination) ([]*entities.GitlabGroup, error)
	ListRepos(ctx context.Context, token *entities.AccessToken, gid string, query *string, pagination *types.Pagination) ([]*gitlab.Project, error)
	ListBranches(ctx context.Context, token *entities.AccessToken, repoId string, query *string, pagination *types.Pagination) ([]*gitlab.Branch, error)
	CheckWebhookExists(ctx context.Context, token *entities.AccessToken, repoId string, webhookId *entities.GitlabWebhookId) (bool, error)
	AddWebhook(ctx context.Context, token *entities.AccessToken, repoId string) (*int, error)
	DeleteWebhook(ctx context.Context, token *entities.AccessToken, repoUrl string, hookId entities.GitlabWebhookId) error
	RepoToken(ctx context.Context, token *entities.AccessToken) (*oauth2.Token, error)
	GetRepoId(repoUrl string) string
	GetLatestCommit(ctx context.Context, token *entities.AccessToken, repoUrl string, branchName string) (string, error)
	GetTriggerWebhookUrl() string
}

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

type PublishMsg string

type RegistryContext struct {
	context.Context
	UserId      repos.ID
	UserName    string
	AccountName string
	UserEmail   string
}

type ResourceDispatcher interface {
	ApplyToTargetCluster(ctx RegistryContext, clusterName string, obj client.Object, recordVersion int) error
	DeleteFromTargetCluster(ctx RegistryContext, clusterName string, obj client.Object) error
}

type ResourceEventPublisher interface {
	PublishBuildRunEvent(cluster *entities.BuildRun, msg PublishMsg)
	PublishBuildCacheEvent(buildcache *entities.BuildCacheKey, msg PublishMsg)
}

type UpdateAndDeleteOpts struct {
	MessageTimestamp time.Time
}