sql

type AuthMode string

type CiPipelineMaterial struct {
	Id            int        `sql:"id"`
	GitMaterialId int        `sql:"git_material_id"` //id stored in db GitMaterial( foreign key)
	Type          SourceType `sql:"type"`
	Value         string     `sql:"value"`
	Active        bool       `sql:"active,notnull"`
	LastSeenHash  string     `sql:"last_seen_hash,notnull"`
	CommitAuthor  string     `sql:"commit_author"`
	CommitDate    time.Time  `sql:"commit_date"`
	CommitMessage string     `sql:"commit_message"`

	CommitHistory string `sql:"commit_history"` //last five commit for caching purpose1
	Errored       bool   `sql:"errored,notnull"`
	ErrorMsg      string `sql:"error_msg,notnull"`
	// contains filtered or unexported fields
}

type CiPipelineMaterialRepository interface {
	FindByGitMaterialId(gitMaterialId int) ([]*CiPipelineMaterial, error)
	Update(material []*CiPipelineMaterial) error
	FindByIds(ids []int) ([]*CiPipelineMaterial, error)
	FindById(id int) (*CiPipelineMaterial, error)
	Exists(id int) (bool, error)
	Save(material []*CiPipelineMaterial) ([]*CiPipelineMaterial, error)
}

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

type CiPipelineMaterialWebhookDataMapping struct {
	Id                   int       `sql:"id,pk"`
	CiPipelineMaterialId int       `sql:"ci_pipeline_material_id"`
	WebhookDataId        int       `sql:"webhook_data_id"`
	ConditionMatched     bool      `sql:"condition_matched,notnull"`
	IsActive             bool      `sql:"is_active,notnull"`
	CreatedOn            time.Time `sql:"created_on"`
	UpdatedOn            time.Time `sql:"updated_on"`

	FilterResults []*CiPipelineMaterialWebhookDataMappingFilterResult `pg:"fk:webhook_data_mapping_id"`
	// contains filtered or unexported fields
}

type CiPipelineMaterialWebhookDataMappingFilterResult struct {
	Id                   int               `sql:"id,pk"`
	WebhookDataMappingId int               `sql:"webhook_data_mapping_id,notnull"`
	SelectorName         string            `sql:"selector_name,notnull"`
	SelectorCondition    string            `sql:"selector_condition"`
	SelectorValue        string            `sql:"selector_value"`
	ConditionMatched     bool              `sql:"condition_matched,notnull"`
	MatchedGroups        map[string]string `sql:"matched_groups"`
	IsActive             bool              `sql:"is_active,notnull"`
	CreatedOn            time.Time         `sql:"created_on,notnull"`
	// contains filtered or unexported fields
}

type Config struct {
	Addr            string `env:"PG_ADDR" envDefault:"127.0.0.1"`
	Port            string `env:"PG_PORT" envDefault:"5432"`
	User            string `env:"PG_USER" envDefault:""`
	Password        string `env:"PG_PASSWORD" envDefault:"" secretData:"-"`
	Database        string `env:"PG_DATABASE" envDefault:"git_sensor"`
	ApplicationName string `env:"APP" envDefault:"git-sensor"`
	LogQuery        bool   `env:"PG_LOG_QUERY" envDefault:"true"`
}

type GitHostWebhookEvent struct {
	Id            int       `sql:"id,pk"`
	GitHostId     int       `sql:"git_host_id,notnull"`
	GitHostName   string    `sql:"git_host_name,notnull"`
	Name          string    `sql:"name,notnull"`
	EventTypesCsv string    `sql:"event_types_csv,notnull"`
	ActionType    string    `sql:"action_type,notnull"`
	IsActive      bool      `sql:"is_active,notnull"`
	CreatedOn     time.Time `sql:"created_on,notnull"`
	UpdatedOn     time.Time `sql:"updated_on"`

	Selectors []*GitHostWebhookEventSelectors `pg:"fk:event_id"`
	// contains filtered or unexported fields
}

type GitHostWebhookEventSelectors struct {
	Id                   int       `sql:"id,pk"`
	EventId              int       `sql:"event_id,notnull"`
	Name                 string    `sql:"name,notnull"`
	Selector             string    `sql:"selector,notnull"`
	ToShow               bool      `sql:"to_show,notnull"`
	ToShowInCiFilter     bool      `sql:"to_show_in_ci_filter,notnull"`
	ToUseInCiEnvVariable bool      `sql:"to_use_in_ci_env_variable"`
	FixValue             string    `sql:"fix_value"`
	PossibleValues       string    `sql:"possible_values"`
	IsActive             bool      `sql:"is_active,notnull"`
	CreatedOn            time.Time `sql:"created_on,notnull"`
	UpdatedOn            time.Time `sql:"updated_on"`
	// contains filtered or unexported fields
}

type GitMaterial struct {
	Id               int    `sql:"id,pk"`
	GitProviderId    int    `sql:"git_provider_id,notnull"`
	Url              string `sql:"url,omitempty"`
	FetchSubmodules  bool   `sql:"fetch_submodules,notnull"`
	Name             string `sql:"name, omitempty"`
	CheckoutLocation string `sql:"checkout_location"`
	CheckoutStatus   bool   `sql:"checkout_status,notnull"`
	CheckoutMsgAny   string `sql:"checkout_msg_any"`
	Deleted          bool   `sql:"deleted,notnull"`
	//------
	LastFetchTime       time.Time `json:"last_fetch_time"`
	FetchStatus         bool      `json:"fetch_status"`
	LastFetchErrorCount int       `json:"last_fetch_error_count"` //continues fetch error
	FetchErrorMessage   string    `json:"fetch_error_message"`
	CloningMode         string    `json:"cloning_mode" sql:"-"`
	FilterPattern       []string  `sql:"filter_pattern"`
	GitProvider         *GitProvider
	CiPipelineMaterials []*CiPipelineMaterial
	// contains filtered or unexported fields
}

type GitProvider struct {
	Id                    int      `sql:"id,pk"`
	Name                  string   `sql:"name,notnull"`
	Url                   string   `sql:"url,notnull"`
	UserName              string   `sql:"user_name"`
	Password              string   `sql:"password"`
	SshPrivateKey         string   `sql:"ssh_private_key"`
	AccessToken           string   `sql:"access_token"`
	AuthMode              AuthMode `sql:"auth_mode,notnull"`
	Active                bool     `sql:"active,notnull"`
	TlsCert               string   `sql:"tls_cert"`
	TlsKey                string   `sql:"tls_key"`
	CaCert                string   `sql:"ca_cert"`
	EnableTLSVerification bool     `sql:"enable_tls_verification"`
	// contains filtered or unexported fields
}

type GitProviderRepository interface {
	GetById(id int) (*GitProvider, error)
	Save(provider *GitProvider) error
	Update(provider *GitProvider) error
	Exists(id int) (bool, error)
}

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

type MaterialRepository interface {
	FindById(id int) (*GitMaterial, error)
	Update(material *GitMaterial) error
	Save(material *GitMaterial) error
	FindActive() ([]*GitMaterial, error)
	FindAll() ([]*GitMaterial, error)
	FindInRage(startFrom int, endAt int) ([]*GitMaterial, error)
	FindAllActiveByUrls(urls []string) ([]*GitMaterial, error)
}

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

type SourceType string

type WebhookEventDataMappingFilterResultRepository interface {
	SaveAll(results []*CiPipelineMaterialWebhookDataMappingFilterResult) error
	InactivateForMappingId(webhookDataMappingId int) error
}

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

type WebhookEventDataMappingRepository interface {
	GetCiPipelineMaterialWebhookDataMapping(ciPipelineMaterialId int, webhookParsedDataId int) (*CiPipelineMaterialWebhookDataMapping, error)
	SaveCiPipelineMaterialWebhookDataMapping(ciPipelineMaterialWebhookDataMapping *CiPipelineMaterialWebhookDataMapping) error
	UpdateCiPipelineMaterialWebhookDataMapping(ciPipelineMaterialWebhookDataMapping *CiPipelineMaterialWebhookDataMapping) error
	GetMatchedCiPipelineMaterialWebhookDataMappingForPipelineMaterial(ciPipelineMaterialId int) ([]*CiPipelineMaterialWebhookDataMapping, error)
	InactivateWebhookDataMappingForPipelineMaterials(ciPipelineMaterialIds []int) error
	GetWebhookPayloadDataForPipelineMaterialId(ciPipelineMaterialId int, limit int, offset int, eventTimeSortOrder string) ([]*CiPipelineMaterialWebhookDataMapping, error)
	GetWebhookPayloadFilterDataForPipelineMaterialId(ciPipelineMaterialId int, webhookParsedDataId int) (*CiPipelineMaterialWebhookDataMapping, error)
}

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

type WebhookEventParsedData struct {
	Id                int               `sql:"id,pk"`
	EventId           int               `sql:"event_id,notnull"`
	PayloadDataId     int               `sql:"payload_data_id"`
	UniqueId          string            `sql:"unique_id"`
	EventActionType   string            `sql:"event_action_type,notnull"`
	Data              map[string]string `sql:"data,notnull"`
	CiEnvVariableData map[string]string `sql:"ci_env_variable_data"`
	CreatedOn         time.Time         `sql:"created_on,notnull"`
	UpdatedOn         time.Time         `sql:"updated_on"`
	// contains filtered or unexported fields
}

type WebhookEventParsedDataRepository interface {
	GetWebhookParsedEventDataByEventIdAndUniqueId(eventId int, uniqueId string) (*WebhookEventParsedData, error)
	SaveWebhookParsedEventData(webhookEventParsedData *WebhookEventParsedData) error
	UpdateWebhookParsedEventData(webhookEventParsedData *WebhookEventParsedData) error
	GetWebhookEventParsedDataByIds(ids []int, limit int) ([]*WebhookEventParsedData, error)
	GetWebhookEventParsedDataById(id int) (*WebhookEventParsedData, error)
}

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

type WebhookEventRepository interface {
	GetAllGitHostWebhookEventByGitHostId(gitHostId int) ([]*GitHostWebhookEvent, error)
	GetAllGitHostWebhookEventByGitHostName(gitHostName string) ([]*GitHostWebhookEvent, error)
	GetWebhookEventConfigByEventId(eventId int) (*GitHostWebhookEvent, error)
	Update(webhookEvent *GitHostWebhookEvent) error
}

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