git

type Author struct {
	Name  string
	Email string
	Date  time.Time
}

type CiPipelineMaterialBean struct {
	Id                        int
	GitMaterialId             int
	Type                      sql.SourceType
	Value                     string
	Active                    bool
	GitCommit                 *GitCommitBase
	ExtraEnvironmentVariables map[string]string // extra env variables which will be used for CI
}

type Commit struct {
	Hash      *Hash
	Tree      *Tree
	Author    *Author
	Committer *Committer
	Tag       *Tag
	Subject   string
	Body      string
}

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

type CommitGoGitIterator struct {
	object.CommitIter
}

type CommitIterator interface {
	Next() (GitCommit, error)
}

type CommitMetadataRequest struct {
	PipelineMaterialId int    `json:"pipelineMaterialId"`
	GitHash            string `json:"gitHash"`
	GitTag             string `json:"gitTag"`
	BranchName         string `json:"branchName"`
}

type Committer struct {
	Name  string
	Email string
	Date  time.Time
}

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

type FetchScmChangesRequest struct {
	PipelineMaterialId int    `json:"pipelineMaterialId"`
	From               string `json:"from"`
	To                 string `json:"to"`
	Count              int    `json:"count"`
	ShowAll            bool   `json:"showAll"`
}

type FileStat struct {
	Name     string
	Addition int
	Deletion int
}

type FileStats []FileStat

type FileStatsResult struct {
	FileStats FileStats
	Error     error
}

type GitChanges struct {
	Commits   []*Commit
	FileStats FileStats
}

type GitCliManagerImpl struct {
	GitManagerBase
	// contains filtered or unexported fields
}

type GitCommit interface {
	GetCommit() *GitCommitBase
}

type GitCommitBase struct {
	Commit      string
	Author      string
	Date        time.Time
	Message     string
	Changes     []string     `json:",omitempty"`
	FileStats   *FileStats   `json:",omitempty"`
	WebhookData *WebhookData `json:"webhookData"`
	Excluded    bool         `json:",omitempty"`
}

type GitCommitCli struct {
	GitCommitBase
}

type GitCommitFormat struct {
	Commit   string    `json:"commit"`
	Parent   string    `json:"parent"`
	Refs     string    `json:"refs"`
	Subject  string    `json:"subject"`
	Commiter GitPerson `json:"commiter"`
	Author   GitPerson `json:"author"`
	Body     string    `json:"body"`
}

type GitCommitGoGit struct {
	GitCommitBase
	Cm *object.Commit
}

type GitContext struct {
	context.Context // Embedding original Go context
	Username        string
	Password        string
	CloningMode     string
}

type GitManager interface {
	GitManagerBase
	// GetCommitStats retrieves the stats for the given commit vs its parent
	GetCommitStats(gitCtx GitContext, commit GitCommit, checkoutPath string) (FileStats, error)
	// GetCommitIterator returns an iterator for the provided git repo and iterator request describing the commits to fetch
	GetCommitIterator(gitCtx GitContext, repository *GitRepository, iteratorRequest IteratorRequest) (CommitIterator, error)
	// GetCommitForHash retrieves the commit reference for given tag
	GetCommitForHash(gitCtx GitContext, checkoutPath, commitHash string) (GitCommit, error)
	// GetCommitsForTag retrieves the commit reference for given tag
	GetCommitsForTag(gitCtx GitContext, checkoutPath, tag string) (GitCommit, error)
	// OpenRepoPlain opens a new git repo at the given path
	OpenRepoPlain(checkoutPath string) (*GitRepository, error)
	// Init initializes a git repo
	Init(gitCtx GitContext, rootDir string, remoteUrl string, isBare bool) error
}

type GitManagerBase interface {
	// PathMatcher matches paths of files changes with defined regex expression
	PathMatcher(fileStats *FileStats, gitMaterial *sql.GitMaterial) bool
	// Fetch executes git fetch
	Fetch(gitCtx GitContext, rootDir string) (response, errMsg string, err error)
	// Checkout executes git checkout
	Checkout(gitCtx GitContext, rootDir, branch string) (response, errMsg string, err error)
	// ConfigureSshCommand configures ssh in git repo
	ConfigureSshCommand(gitCtx GitContext, rootDir string, sshPrivateKeyPath string) (response, errMsg string, err error)
	//  FetchDiffStatBetweenCommits returns the file stats reponse on executing git action
	FetchDiffStatBetweenCommits(gitCtx GitContext, oldHash string, newHash string, rootDir string) (FileStats, error)
	// LogMergeBase get the commit diff between using a merge base strategy
	LogMergeBase(gitCtx GitContext, rootDir, from string, to string) ([]*Commit, error)
	ExecuteCustomCommand(gitContext GitContext, name string, arg ...string) (response, errMsg string, err error)
}

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

type GitManagerImpl struct {
	GitManager
}

type GitPerson struct {
	Name  string    `json:"name"`
	Email string    `json:"email"`
	Date  time.Time `json:"date"`
}

type GitRepository struct {
	*git.Repository
	// contains filtered or unexported fields
}

type GitWatcher interface {
	PollAndUpdateGitMaterial(material *sql.GitMaterial) (*sql.GitMaterial, error)
}

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

type GoGitSDKManagerImpl struct {
	GitManagerBase
	// contains filtered or unexported fields
}

type Hash struct {
	Long  string
	Short string
}

type HeadRequest struct {
	MaterialIds []int `json:"materialIds"`
}

type IteratorRequest struct {
	BranchRef      string
	Branch         string
	CommitCount    int
	FromCommitHash string
	ToCommitHash   string
}

type MaterialChangeResp struct {
	Commits        []*GitCommitBase `json:"commits"`
	LastFetchTime  time.Time        `json:"lastFetchTime"`
	IsRepoError    bool             `json:"isRepoError"`
	RepoErrorMsg   string           `json:"repoErrorMsg"`
	IsBranchError  bool             `json:"isBranchError"`
	BranchErrorMsg string           `json:"branchErrorMsg"`
}

type PollConfig struct {
	PollDuration int `env:"POLL_DURATION" envDefault:"2"`
	PollWorker   int `env:"POLL_WORKER" envDefault:"5"`
}

type RefreshGitMaterialRequest struct {
	GitMaterialId int `json:"gitMaterialId"`
}

type RefreshGitMaterialResponse struct {
	Message       string    `json:"message"`
	ErrorMsg      string    `json:"errorMsg"`
	LastFetchTime time.Time `json:"lastFetchTime"`
}

type RepositoryManager interface {
	// Fetch Fetches latest commit for  repo. Creates a new repo if it doesn't already exist
	// and returns the reference to the repo
	Fetch(gitCtx GitContext, url string, location string) (updated bool, repo *GitRepository, err error)
	// Add adds and initializes a new git repo , cleans the directory if not empty and fetches latest commits
	Add(gitCtx GitContext, gitProviderId int, location, url string, authMode sql.AuthMode, sshPrivateKeyContent string) error
	GetSshPrivateKeyPath(gitCtx GitContext, gitProviderId int, location, url string, authMode sql.AuthMode, sshPrivateKeyContent string) (string, error)
	FetchRepo(gitCtx GitContext, location string) error
	GetCheckoutLocationFromGitUrl(material *sql.GitMaterial, cloningMode string) (location string, httpMatched bool, shMatched bool, err error)
	GetCheckoutLocation(gitCtx GitContext, material *sql.GitMaterial, url, checkoutPath string) string
	TrimLastGitCommit(gitCommits []*GitCommitBase, count int) []*GitCommitBase
	// Clean cleans a directory
	Clean(cloneDir string) error
	// ChangesSinceByRepository returns the latest commits list for the given range and count for an existing repo
	ChangesSinceByRepository(gitCtx GitContext, repository *GitRepository, branch string, from string, to string, count int, checkoutPath string, openNewGitRepo bool) ([]*GitCommitBase, error)
	// GetCommitMetadata retrieves the commit metadata for given hash
	GetCommitMetadata(gitCtx GitContext, checkoutPath, commitHash string) (*GitCommitBase, error)
	// GetCommitForTag retrieves the commit metadata for given tag
	GetCommitForTag(gitCtx GitContext, checkoutPath, tag string) (*GitCommitBase, error)
	// CreateSshFileIfNotExistsAndConfigureSshCommand creates ssh file with creds and configures it at the location
	CreateSshFileIfNotExistsAndConfigureSshCommand(gitCtx GitContext, location string, gitProviderId int, sshPrivateKeyContent string) (string, error)
}

type RepositoryManagerAnalytics interface {
	ChangesSinceByRepositoryForAnalytics(gitCtx GitContext, checkoutPath string, Old string, New string) (*GitChanges, error)
}

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

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

type Tag struct {
	Name string
	Date time.Time
}

type Tree struct {
	Long  string
	Short string
}

type WebhookAndCiData struct {
	ExtraEnvironmentVariables map[string]string `json:"extraEnvironmentVariables"` // extra env variables which will be used for CI
	WebhookData               *WebhookData      `json:"webhookData"`
}

type WebhookData struct {
	Id              int               `json:"id"`
	EventActionType string            `json:"eventActionType"`
	Data            map[string]string `json:"data"`
}

type WebhookDataRequest struct {
	Id                   int `json:"id"`
	CiPipelineMaterialId int `json:"ciPipelineMaterialId"`
}

type WebhookEvent struct {
	PayloadId          int    `json:"payloadId"`
	RequestPayloadJson string `json:"requestPayloadJson"`
	GitHostId          int    `json:"gitHostId"`
	EventType          string `json:"eventType"`
}

type WebhookEventBeanConverter interface {
	ConvertFromWebhookParsedDataSqlBean(sqlBean *sql.WebhookEventParsedData) *WebhookData
	ConvertFromWebhookEventSqlBean(sqlBean *sql.GitHostWebhookEvent) *WebhookEventConfig
}

type WebhookEventBeanConverterImpl struct {
}

type WebhookEventConfig struct {
	Id            int       `json:"id"`
	GitHostId     int       `json:"gitHostId"`
	Name          string    `json:"name"`
	EventTypesCsv string    `json:"eventTypesCsv"`
	ActionType    string    `json:"actionType"`
	IsActive      bool      `json:"isActive"`
	CreatedOn     time.Time `json:"createdOn"`
	UpdatedOn     time.Time `json:"updatedOn"`

	Selectors []*WebhookEventSelectors `json:"selectors"`
}

type WebhookEventConfigRequest struct {
	GitHostId int `json:"gitHostId"`
	EventId   int `json:"eventId"`
}

type WebhookEventParser interface {
	ParseEvent(selectors []*sql.GitHostWebhookEventSelectors, requestPayloadJson string) (*sql.WebhookEventParsedData, map[string]string, error)
}

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

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

type WebhookEventSelectors struct {
	Id               int       `json:"id"`
	EventId          int       `json:"eventId"`
	Name             string    `json:"name"`
	Selector         string    `json:"selector"`
	ToShow           bool      `json:"toShow"`
	ToShowInCiFilter bool      `json:"toShowInCiFilter"`
	FixValue         string    `json:"fixValue"`
	PossibleValues   string    `json:"possibleValues"`
	IsActive         bool      `json:"isActive"`
	CreatedOn        time.Time `json:"createdOn"`
	UpdatedOn        time.Time `json:"updatedOn"`
}

type WebhookEventService interface {
	GetAllGitHostWebhookEventByGitHostId(gitHostId int) ([]*sql.GitHostWebhookEvent, error)
	GetWebhookParsedEventDataByEventIdAndUniqueId(eventId int, uniqueId string) (*sql.WebhookEventParsedData, error)
	SaveWebhookParsedEventData(webhookEventParsedData *sql.WebhookEventParsedData) error
	UpdateWebhookParsedEventData(webhookEventParsedData *sql.WebhookEventParsedData) error
	MatchCiTriggerConditionAndNotify(event *sql.GitHostWebhookEvent, webhookEventParsedData *sql.WebhookEventParsedData, fullDataMap map[string]string) error
}

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

type WebhookHandler interface {
	HandleWebhookEvent(webhookEvent *WebhookEvent) error
}

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

type WebhookPayloadDataPayloadsResponse struct {
	ParsedDataId        int       `json:"parsedDataId"`
	EventTime           time.Time `json:"eventTime"`
	MatchedFiltersCount int       `json:"matchedFiltersCount"`
	FailedFiltersCount  int       `json:"failedFiltersCount"`
	MatchedFilters      bool      `json:"matchedFilters"`
}

type WebhookPayloadDataRequest struct {
	CiPipelineMaterialId int    `json:"ciPipelineMaterialId"`
	Limit                int    `json:"limit"`
	Offset               int    `json:"offset"`
	EventTimeSortOrder   string `json:"eventTimeSortOrder"`
}

type WebhookPayloadDataResponse struct {
	Filters       map[string]string                     `json:"filters"`
	RepositoryUrl string                                `json:"repositoryUrl"`
	Payloads      []*WebhookPayloadDataPayloadsResponse `json:"payloads"`
}

type WebhookPayloadFilterDataRequest struct {
	CiPipelineMaterialId int `json:"ciPipelineMaterialId"`
	ParsedDataId         int `json:"parsedDataId"`
}

type WebhookPayloadFilterDataResponse struct {
	PayloadId     int                                         `json:"payloadId"`
	SelectorsData []*WebhookPayloadFilterDataSelectorResponse `json:"selectorsData"`
}

type WebhookPayloadFilterDataSelectorResponse struct {
	SelectorName      string `json:"selectorName"`
	SelectorCondition string `json:"selectorCondition"`
	SelectorValue     string `json:"selectorValue"`
	Match             bool   `json:"match"`
}

type WebhookSourceTypeValue struct {
	EventId   int            `json:"eventId,omitempty"`
	Condition map[int]string `json:"condition,omitempty"`
}