utils

Documentation

Index

• func BuildRepoMapsAndKeys(src, tgt []models.ExtendedRepository) (map[string]models.ExtendedRepository, map[string]models.ExtendedRepository, ...)
• func BuildRollbackPlan[T any, ID comparable](source []models.ExtendedRepository, diff models.RepoDiff, ...) *models.RollbackPlan
• func DiffRepoItems[T any, ID comparable](sourceRepo, targetRepo models.ExtendedRepository, ops RepoItemOps[T, ID]) (create []T, update []T, delete_ []T)
• func ForceUpdateBySourceIDs[T any, ID comparable](source, target []models.ExtendedRepository, ops RepoItemOps[T, ID]) []models.ExtendedRepository
• func GenerateRepoDiff[T any, ID comparable](src, tgt []models.ExtendedRepository, ops RepoItemOps[T, ID]) (*models.RepoDiff, error)
• func GroupRepositories(repos []models.ExtendedRepository) []models.ExtendedRepository
• func HasOption(options string, target string) bool
• func Int32PtrToString(v *int32) string
• func Int64PtrToString(v *int64) string
• func OptionalBool(b bool) *bool
• func OptionalString(s string) *string
• func ParseColumnsToLower(columns string) []string
• func ParseFile[T any](filePath string, out *T) error
• func ParseRepositoriesFromArgs(repoIdent, input string) ([]models.ExtendedRepository, error)
• func PrintRepos(repos []models.ExtendedRepository, columns []string)
• func PrintStructured(name string, data interface{}, format string, columns string) error
• func ReadRollbackPlan(path string) (*models.RollbackPlan, error)
• func SafeInterface(v interface{}) string
• func SafeValue[T any](v *T) T
• func SortRepositoriesStable(repos []models.ExtendedRepository) []models.ExtendedRepository
• func WriteRepositoriesToFile(path string, repos []models.ExtendedRepository, format string) error
• func WriteRollbackPlan(path, format string, plan *models.RollbackPlan) error
• type RepoItemOps

Functions

func BuildRepoMapsAndKeys

func BuildRepoMapsAndKeys(src, tgt []models.ExtendedRepository) (map[string]models.ExtendedRepository, map[string]models.ExtendedRepository, []string)

BuildRepoMapsAndKeys builds source/target maps keyed by projectKey/repositorySlug and returns the union of keys in a deterministic slice order (insertion order: all keys from source, then new keys from target).

func BuildRollbackPlan

func BuildRollbackPlan[T any, ID comparable](source []models.ExtendedRepository, diff models.RepoDiff, updated, created []models.ExtendedRepository, ops RepoItemOps[T, ID]) *models.RollbackPlan

BuildRollbackPlan constructs a rollback plan based on source state and diff result

func DiffRepoItems

func DiffRepoItems[T any, ID comparable](sourceRepo, targetRepo models.ExtendedRepository, ops RepoItemOps[T, ID]) (create []T, update []T, delete_ []T)

DiffRepoItems computes create/update/delete sets between two repositories for a given item type. - create: target items without ID, plus items whose ID is in target but not in source - update: items with IDs present in both repos but differing by Equal - delete: items with IDs present in source but not in target

func ForceUpdateBySourceIDs

func ForceUpdateBySourceIDs[T any, ID comparable](source, target []models.ExtendedRepository, ops RepoItemOps[T, ID]) []models.ExtendedRepository

ForceUpdateBySourceIDs selects from target all items whose IDs are present in source for the same repo

func GenerateRepoDiff

func GenerateRepoDiff[T any, ID comparable](src, tgt []models.ExtendedRepository, ops RepoItemOps[T, ID]) (*models.RepoDiff, error)

GenerateRepoDiff builds a generic repo-level diff using the provided item ops

func GroupRepositories

func GroupRepositories(repos []models.ExtendedRepository) []models.ExtendedRepository

GroupRepositories merges items for the same repo and deduplicates both required-builds and webhooks by id.

func HasOption

func HasOption(options string, target string) bool

func Int32PtrToString

func Int32PtrToString(v *int32) string

func Int64PtrToString

func Int64PtrToString(v *int64) string

func OptionalBool

func OptionalBool(b bool) *bool

func OptionalString

func OptionalString(s string) *string

Helpers

func ParseColumnsToLower

func ParseColumnsToLower(columns string) []string

func ParseFile

func ParseFile[T any](filePath string, out *T) error

ParseFile is a universal function that parses YAML or JSON files into the provided struct pointer

func ParseRepositoriesFromArgs

func ParseRepositoriesFromArgs(repoIdent, input string) ([]models.ExtendedRepository, error)

ParseRepositoriesFromArgs parses repositories from either repoIdent (comma-separated project/repo) or input file/stdin. If input is provided, it takes precedence. Returns error if neither is provided.

func PrintRepos

func PrintRepos(repos []models.ExtendedRepository, columns []string)

PrintRepos prints a slice of Repository according to selected columns

func PrintStructured

func PrintStructured(name string, data interface{}, format string, columns string) error

PrintStructured prints data in JSON, YAML, or plain table format

func ReadRollbackPlan

func ReadRollbackPlan(path string) (*models.RollbackPlan, error)

ReadRollbackPlan reads a rollback plan from JSON or YAML file

func SafeInterface

func SafeInterface(v interface{}) string

func SafeValue

func SafeValue[T any](v *T) T

func SortRepositoriesStable

func SortRepositoriesStable(repos []models.ExtendedRepository) []models.ExtendedRepository

SortRepositoriesStable returns a sorted copy of repositories ordered by projectKey, repositorySlug, and with inner collections sorted by id: - requiredBuilds[].id (int64) ascending, nil first - webhooks[].id (int32) ascending, nil first

func WriteRepositoriesToFile

func WriteRepositoriesToFile(path string, repos []models.ExtendedRepository, format string) error

WriteRepositoriesToFile writes repositories grouped by projectKey/repositorySlug to a file. The payload is wrapped under key "repositories". Format is controlled by the `format` argument (json|yaml). For each repository, both RequiredBuilds and Webhooks are merged across duplicates and de-duplicated by id.

func WriteRollbackPlan

func WriteRollbackPlan(path, format string, plan *models.RollbackPlan) error

WriteRollbackPlan writes plan to file in json or yaml based on format

Types

type RepoItemOps

type RepoItemOps[T any, ID comparable] struct {
	GetItems func(models.ExtendedRepository) []T
	SetItems func(*models.ExtendedRepository, []T)
	GetID    func(T) (ID, bool) // returns (id, true) if item has id, otherwise (_, false)
	Equal    func(T, T) bool    // semantic equality
}

RepoItemOps defines how to access, identify, and compare repository-scoped items. T is the item type (e.g., RestRequiredBuildCondition or RestWebhook), ID is the id type (e.g., int64 or int32).