repository

type AppListingRepository interface {
	FetchJobs(appIds []int, statuses []string, environmentIds []int, sortOrder string) ([]*AppView.JobListingContainer, error)
	FetchOverviewCiPipelines(jobId int) ([]*AppView.JobListingContainer, error)
	FetchJobsLastSucceededOn(ciPipelineIDs []int) ([]*AppView.CiPipelineLastSucceededTime, error)
	FetchAppTriggerView(appId int) ([]AppView.TriggerView, error)

	FetchAppStage(appId int, appType int) (AppView.AppStages, error)
	GetEnvironmentNameFromPipelineId(pipelineId int) (string, error)
	GetDeploymentDetailsByAppIdAndEnvId(appId int, envId int) (AppView.DeploymentDetailContainer, error)

	// Not in used
	PrometheusApiByEnvId(id int) (*string, error)

	FetchOtherEnvironment(appId int) ([]*AppView.Environment, error)
	FetchMinDetailOtherEnvironment(appId int) ([]*AppView.Environment, error)
	DeploymentDetailByArtifactId(ciArtifactId int, envId int) (AppView.DeploymentDetailContainer, error)
	FindAppCount(isProd bool) (int, error)
	FetchAppsByEnvironmentV2(appListingFilter helper.AppListingFilter) ([]*AppView.AppEnvironmentContainer, int, error)
	FetchAppsEnvContainers(envId int, appIds []int, limit, offset int) ([]*AppView.AppEnvironmentContainer, error)
	FetchLastDeployedImage(appId, envId int) (*LastDeployed, error)
}

type AppListingRepositoryImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

type AppNameTypeIdContainerDBResponse struct {
	AppName string `sql:"app_name"`
	AppId   int    `sql:"id"`
}

type ArtifactsSourceType = string

type Attributes struct {
	Id     int    `sql:"id,pk"`
	Key    string `sql:"key,notnull"`
	Value  string `sql:"value,notnull"`
	Active bool   `sql:"active, notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type AttributesRepository interface {
	Save(model *Attributes, tx *pg.Tx) (*Attributes, error)
	Update(model *Attributes, tx *pg.Tx) error
	FindByKey(key string) (*Attributes, error)
	FindById(id int) (*Attributes, error)
	FindActiveList() ([]*Attributes, error)
	GetConnection() (dbConnection *pg.DB)
}

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

type CiArtifact struct {
	Id                    int       `sql:"id,pk"`
	PipelineId            int       `sql:"pipeline_id"` // id of the ci pipeline from which this webhook was triggered
	Image                 string    `sql:"image,notnull"`
	ImageDigest           string    `sql:"image_digest,notnull"`
	MaterialInfo          string    `sql:"material_info"`       // git material metadata json array string
	DataSource            string    `sql:"data_source,notnull"` // possible values -> (CI_RUNNER,EXTERNAL,post_ci,pre_cd,post_cd) CI_runner is for normal build ci
	WorkflowId            *int      `sql:"ci_workflow_id"`
	ParentCiArtifact      int       `sql:"parent_ci_artifact"`
	ScanEnabled           bool      `sql:"scan_enabled,notnull"`
	Scanned               bool      `sql:"scanned,notnull"`
	ExternalCiPipelineId  int       `sql:"external_ci_pipeline_id"`
	IsArtifactUploaded    bool      `sql:"is_artifact_uploaded"` // Deprecated; Use pipelineConfig.CiWorkflow instead.
	CredentialsSourceType string    `sql:"credentials_source_type"`
	CredentialSourceValue string    `sql:"credentials_source_value"`
	TargetPlatforms       string    `sql:"target_platforms"`
	ComponentId           int       `sql:"component_id"`
	DeployedTime          time.Time `sql:"-"`
	Deployed              bool      `sql:"-"`
	Latest                bool      `sql:"-"`
	RunningOnParent       bool      `sql:"-"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type CiArtifactRepository interface {
	Save(artifact *CiArtifact) error
	Delete(artifact *CiArtifact) error

	// Get returns the CiArtifact of the given id.
	// Note: Use Get along with MigrateToWebHookDataSourceType. For webhook artifacts, migration is required for column DataSource from 'ext' to 'EXTERNAL'
	Get(id int) (artifact *CiArtifact, err error)
	GetArtifactParentCiAndWorkflowDetailsByIds(ids []int) ([]*CiArtifact, error)
	GetByWfId(wfId int) (artifact *CiArtifact, err error)
	IfArtifactExistByImage(imageName string, pipelineId int) (exist bool, err error)
	IfArtifactExistByImageDigest(imageDigest string, imageName string, pipelineId int) (exist bool, err error)
	GetArtifactsByCDPipeline(cdPipelineId, limit int, parentId int, parentType bean.WorkflowType) ([]*CiArtifact, error)
	GetArtifactsByCDPipelineV3(listingFilterOpts *bean.ArtifactsListFilterOptions) ([]*CiArtifact, int, error)
	GetLatestArtifactTimeByCiPipelineIds(ciPipelineIds []int) ([]*CiArtifact, error)
	GetLatestArtifactTimeByCiPipelineId(ciPipelineId int) (*CiArtifact, error)
	GetArtifactsByCDPipelineV2(cdPipelineId int) ([]CiArtifact, error)
	GetArtifactsByCDPipelineAndRunnerType(cdPipelineId int, runnerType bean.WorkflowType) ([]CiArtifact, error)
	SaveAll(artifacts []*CiArtifact) ([]*CiArtifact, error)
	GetArtifactsByCiPipelineId(ciPipelineId int) ([]CiArtifact, error)
	GetArtifactsByCiPipelineIds(ciPipelineIds []int) ([]CiArtifact, error)
	FinDByParentCiArtifactAndCiId(parentCiArtifact int, ciPipelineIds []int) ([]*CiArtifact, error)
	GetLatest(cdPipelineId int) (int, error)
	GetByImageDigest(imageDigest string) (artifact *CiArtifact, err error)
	GetByIds(ids []int) ([]*CiArtifact, error)
	GetArtifactByCdWorkflowId(cdWorkflowId int) (artifact *CiArtifact, err error)
	GetArtifactsByParentCiWorkflowId(parentCiWorkflowId int) ([]string, error)
	FetchArtifactsByCdPipelineIdV2(listingFilterOptions bean.ArtifactsListFilterOptions) ([]CiArtifactWithExtraData, int, error)
	FindArtifactByListFilter(listingFilterOptions *bean.ArtifactsListFilterOptions) ([]*CiArtifact, int, error)
	GetArtifactsByDataSourceAndComponentId(dataSource string, componentId int) ([]CiArtifact, error)
	FindCiArtifactByImagePaths(images []string) ([]CiArtifact, error)

	// MigrateToWebHookDataSourceType is used for backward compatibility. It'll migrate the deprecated DataSource type
	MigrateToWebHookDataSourceType(id int) error
	UpdateLatestTimestamp(artifactIds []int) error

	Update(ciArtifact *CiArtifact) error
}

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

type CiArtifactWithExtraData struct {
	CiArtifact
	PayloadSchema      string
	TotalCount         int
	TriggeredBy        int32
	StartedOn          time.Time
	CdWorkflowRunnerId int
}

type CiMaterialInfo struct {
	Material      Material       `json:"material"`
	Changed       bool           `json:"changed"`
	Modifications []Modification `json:"modifications"`
}

type ConfigEntry struct {
	Dest      string `json:"dest"`
	Rule      string `json:"rule"`
	ConfigId  int    `json:"configId"`
	Recipient string `json:"recipient"`
}

type CustomTag struct {
	Id                   int    `sql:"id"`
	EntityKey            int    `sql:"entity_key"`
	EntityValue          string `sql:"entity_value"`
	TagPattern           string `sql:"tag_pattern"`
	AutoIncreasingNumber int    `sql:"auto_increasing_number, notnull"`
	Active               bool   `sql:"active"`
	Metadata             string `sql:"metadata"`
	Enabled              bool   `sql:"enabled, notnull"`
	// contains filtered or unexported fields
}

type DeploymentGroup struct {
	TableName           struct{} `sql:"deployment_group" pg:",discard_unknown_columns"`
	Id                  int      `sql:"id,pk"`
	Name                string   `sql:"name,notnull"`
	AppCount            int      `sql:"app_count,notnull"`
	NoOfApps            string   `sql:"no_of_apps"`
	EnvironmentId       int      `sql:"environment_id"`
	CiPipelineId        int      `sql:"ci_pipeline_id"`
	Active              bool     `sql:"active,notnull"`
	DeploymentGroupApps []*DeploymentGroupApp
	sql.AuditLog
}

type DeploymentGroupApp struct {
	TableName         struct{} `sql:"deployment_group_app" pg:",discard_unknown_columns"`
	Id                int      `sql:"id,pk"`
	DeploymentGroupId int      `sql:"deployment_group_id"`
	AppId             int      `sql:"app_id"`
	Active            bool     `sql:"active,notnull"`
	sql.AuditLog
}

type DeploymentGroupAppRepository interface {
	Create(model *DeploymentGroupApp) (*DeploymentGroupApp, error)
	GetById(id int) (*DeploymentGroupApp, error)
	GetAll() ([]*DeploymentGroupApp, error)
	Update(model *DeploymentGroupApp) (*DeploymentGroupApp, error)
	Delete(model *DeploymentGroupApp) error
	GetByDeploymentGroup(deploymentGroupId int) ([]*DeploymentGroupApp, error)
}

type DeploymentGroupAppRepositoryImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

type DeploymentGroupRepository interface {
	Create(model *DeploymentGroup) (*DeploymentGroup, error)
	GetById(id int) (*DeploymentGroup, error)
	GetAll() ([]DeploymentGroup, error)
	Update(model *DeploymentGroup) (*DeploymentGroup, error)
	Delete(model *DeploymentGroup) error
	FindByIdWithApp(id int) (*DeploymentGroup, error)
	FindByAppIdAndEnvId(envId, appId int) ([]DeploymentGroup, error)
	GetNamesByAppIdAndEnvId(envId, appId int) ([]string, error)
}

type DeploymentGroupRepositoryImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

type DeploymentStatus struct {
	Id        int       `sql:"id,pk"`
	AppName   string    `sql:"app_name,notnull"`
	Status    string    `sql:"status,notnull"`
	AppId     int       `sql:"app_id"`
	EnvId     int       `sql:"env_id"`
	CreatedOn time.Time `sql:"created_on"`
	UpdatedOn time.Time `sql:"updated_on"`
	// contains filtered or unexported fields
}

type DeploymentTemplateComparisonMetadata struct {
	ChartRefId                  int                    `json:"chartRefId"`
	ChartVersion                string                 `json:"chartVersion,omitempty"`
	ChartType                   string                 `json:"chartType,omitempty"`
	EnvironmentId               int                    `json:"environmentId,omitempty"`
	EnvironmentName             string                 `json:"environmentName,omitempty"`
	DeploymentTemplateHistoryId int                    `json:"deploymentTemplateHistoryId,omitempty"`
	WfrId                       int                    `json:"wfrId,omitempty"`
	StartedOn                   *time.Time             `json:"startedOn,omitempty"`
	FinishedOn                  *time.Time             `json:"finishedOn,omitempty"`
	Status                      string                 `json:"status,omitempty"`
	PipelineId                  int                    `json:"pipelineId,omitempty"`
	Type                        DeploymentTemplateType `json:"type"`
}

type DeploymentTemplateRepository interface {
	FetchDeploymentHistoryWithChartRefs(appId int, envId int) ([]*DeploymentTemplateComparisonMetadata, error)
	FetchPipelineOverrideValues(id int) (string, error)
	FetchLatestDeploymentWithChartRefs(appId int, envId int) ([]*DeploymentTemplateComparisonMetadata, error)
}

type DeploymentTemplateRepositoryImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

type DeploymentTemplateType int

type GetRulesRequest struct {
	TeamId              int
	EnvId               int
	AppId               int
	PipelineId          int
	PipelineType        string
	IsProdEnv           *bool
	ClusterId           int
	EnvIdsForCiPipeline []int
}

type GitConfiguration struct {
	URL string `json:"url"`
}

type GitOpsConfig struct {
	Id                    int    `sql:"id,pk"`
	Provider              string `sql:"provider"`
	Username              string `sql:"username"`
	Token                 string `sql:"token"`
	GitLabGroupId         string `sql:"gitlab_group_id"`
	GitHubOrgId           string `sql:"github_org_id"`
	AzureProject          string `sql:"azure_project"`
	Host                  string `sql:"host"`
	Active                bool   `sql:"active,notnull"`
	AllowCustomRepository bool   `sql:"allow_custom_repository,notnull"`
	BitBucketWorkspaceId  string `sql:"bitbucket_workspace_id"`
	BitBucketProjectKey   string `sql:"bitbucket_project_key"`
	EmailId               string `sql:"email_id"`
	EnableTLSVerification bool   `sql:"enable_tls_verification"`
	TlsCert               string `sql:"tls_cert"`
	TlsKey                string `sql:"tls_key"`
	CaCert                string `sql:"ca_cert"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type GitOpsConfigRepository interface {
	CreateGitOpsConfig(model *GitOpsConfig, tx *pg.Tx) (*GitOpsConfig, error)
	UpdateGitOpsConfig(model *GitOpsConfig, tx *pg.Tx) error
	GetGitOpsConfigById(id int) (*GitOpsConfig, error)
	GetAllGitOpsConfig() ([]*GitOpsConfig, error)
	GetAllGitOpsConfigCount() (int, error)
	GetGitOpsConfigByProvider(provider string) (*GitOpsConfig, error)
	GetGitOpsConfigActive() (*GitOpsConfig, error)
	GetConnection() *pg.DB
	GetEmailIdFromActiveGitOpsConfig() (string, error)
}

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

type GlobalCMCS struct {
	TableName  struct{} `sql:"global_cm_cs" pg:",discard_unknown_columns"`
	Id         int      `sql:"id,pk"`
	ConfigType string   `sql:"config_type"` // [CONFIGMAP, SECRET]
	Name       string   `sql:"name"`
	Type       string   `sql:"type"` // [environment, volume]
	//json string of map of key:value, example: '{ "a" : "b", "c" : "d"}'
	Data               string `sql:"data"`
	MountPath          string `sql:"mount_path"`
	Deleted            bool   `sql:"deleted,notnull"`
	SecretIngestionFor string `sql:"secret_ingestion_for,notnull"` // [CI, CD, CI/CD]
	sql.AuditLog
}

type GlobalCMCSRepository interface {
	Save(model *GlobalCMCS) (*GlobalCMCS, error)
	Update(model *GlobalCMCS) (*GlobalCMCS, error)
	FindAllActive() ([]*GlobalCMCS, error)
	FindById(id int) (*GlobalCMCS, error)
	FindByConfigTypeAndName(configType, name string) (*GlobalCMCS, error)
	FindByMountPath(mountPath string) (*GlobalCMCS, error)
	FindAllActiveByPipelineType(pipelineType string) ([]*GlobalCMCS, error)
	Delete(model *GlobalCMCS) error
}

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

type ImagePathReservation struct {
	Id          int    `sql:"id"`
	ImagePath   string `sql:"image_path"`
	CustomTagId int    `sql:"custom_tag_id"`
	// contains filtered or unexported fields
}

type ImageTagRepository interface {
	GetConnection() *pg.DB
	CreateImageTag(customTagData *CustomTag) error
	FetchCustomTagData(entityType int, entityValue string) (*CustomTag, error)
	IncrementAndFetchByEntityKeyAndValue(tx *pg.Tx, entityKey int, entityValue string) (*CustomTag, error)
	FindByImagePath(tx *pg.Tx, path string) ([]*ImagePathReservation, error)
	InsertImagePath(tx *pg.Tx, reservation *ImagePathReservation) error
	UpdateImageTag(customTag *CustomTag) error
	DeleteByEntityKeyAndValue(entityKey int, entityValue string) error
	DeactivateImagePathReservation(id int) error
	FetchActiveCustomTagData(entityKey int, entityValue string) (*CustomTag, error)
	FetchActiveCustomTagDataList(entityValues []string) ([]*CustomTag, error)
	DeactivateImagePathReservationByImagePaths(tx *pg.Tx, imagePaths []string) error
	DeactivateImagePathReservationByImagePathReservationIds(tx *pg.Tx, imagePathReservationIds []int) error
	DisableCustomTag(entityKey int, entityValue string) error
	GetImagePathsByIds(ids []int) ([]*ImagePathReservation, error)
}

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

type LastDeployed struct {
	CiArtifactId      int    `sql:"ci_artifact_id"`
	LastDeployedBy    string `sql:"last_deployed_by"`
	LastDeployedImage string `sql:"last_deployed_image"`
}

type LinkoutsModel struct {
	TableName     struct{} `sql:"app_env_linkouts" pg:",discard_unknown_columns"`
	Id            int      `sql:"id,pk"`
	AppId         int      `sql:"app_id,notnull"`
	EnvironmentId int      `sql:"environment_id,notnull"`
	Link          string   `sql:"link"`
	Description   string   `sql:"description"`
	Name          string   `sql:"name"`
	sql.AuditLog
}

type LinkoutsRepository interface {
	Create(model *LinkoutsModel) (*LinkoutsModel, error)
	GetById(id int) (*LinkoutsModel, error)
	GetAll() ([]LinkoutsModel, error)
	Update(model *LinkoutsModel) (*LinkoutsModel, error)
	FetchLinkoutsByAppIdAndEnvId(appId int, envId int) ([]LinkoutsModel, error)
	FetchLinkoutById(Id int) (AppView.LinkOuts, error)
}

type LinkoutsRepositoryImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

type Material struct {
	PluginID         string           `json:"plugin-id"`
	GitConfiguration GitConfiguration `json:"git-configuration"`
	ScmConfiguration ScmConfiguration `json:"scm-configuration"`
	Type             string           `json:"type"`
}

type Modification struct {
	Revision     string            `json:"revision"`
	ModifiedTime string            `json:"modified-time"`
	Data         map[string]string `json:"data"`
	Author       string            `json:"author"`
	Message      string            `json:"message"`
	Branch       string            `json:"branch"`
	Tag          string            `json:"tag,omitempty"`
	WebhookData  WebhookData       `json:"webhookData,omitempty"`
}

type NotificationSettings struct {
	Id                   int    `sql:"id,pk"`
	TeamId               *int   `sql:"team_id"`
	AppId                *int   `sql:"app_id"`
	EnvId                *int   `sql:"env_id"`
	PipelineId           *int   `sql:"pipeline_id"`
	PipelineType         string `sql:"pipeline_type"`
	EventTypeId          int    `sql:"event_type_id"`
	Config               string `sql:"config"`
	ViewId               int    `sql:"view_id"`
	NotificationRuleId   int    `sql:"notification_rule_id"`
	AdditionalConfigJson string `sql:"additional_config_json"` // user defined config json;
	ClusterId            *int   `sql:"cluster_id"`
	// contains filtered or unexported fields
}

type NotificationSettingsBean struct {
	Id           int           `json:"id"`
	TeamId       *int          `json:"team_id"`
	AppId        *int          `json:"app_id"`
	EnvId        *int          `json:"env_id"`
	PipelineId   *int          `json:"pipeline_id"`
	PipelineType string        `json:"pipeline_type"`
	EventTypeId  int           `json:"event_type_id"`
	Config       []ConfigEntry `json:"config"`
	ViewId       int           `json:"view_id"`
}

type NotificationSettingsRepository interface {
	FindNSViewCount() (int, error)
	SaveNotificationSettingsConfig(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error)
	FindNotificationSettingsViewById(id int) (*NotificationSettingsView, error)
	FindNotificationSettingsViewByIds(id []*int) ([]*NotificationSettingsView, error)
	UpdateNotificationSettingsView(notificationSettingsView *NotificationSettingsView, tx *pg.Tx) (*NotificationSettingsView, error)
	SaveNotificationSetting(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error)
	UpdateNotificationSettings(notificationSettings *NotificationSettings, tx *pg.Tx) (*NotificationSettings, error)
	FindNotificationSettingsByViewId(viewId int) ([]NotificationSettings, error)
	SaveAllNotificationSettings(notificationSettings []NotificationSettings, tx *pg.Tx) (int, error)
	DeleteNotificationSettingsByConfigId(viewId int, tx *pg.Tx) (int, error)
	FindAll(offset int, size int) ([]*NotificationSettingsView, error)
	DeleteNotificationSettingsViewById(id int, tx *pg.Tx) (int, error)

	FindNotificationSettingDeploymentOptions(settingRequest *SearchRequest) ([]*SettingOptionDTO, error)
	FindNotificationSettingBuildOptions(settingRequest *SearchRequest) ([]*SettingOptionDTO, error)
	FetchNotificationSettingGroupBy(viewId int) ([]NotificationSettings, error)
	FindNotificationSettingsByConfigIdAndConfigType(configId int, configType string) ([]*NotificationSettings, error)
	FindNotificationSettingsWithRules(ctx context.Context, eventId int, req GetRulesRequest) ([]NotificationSettings, error)
}

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

type NotificationSettingsView struct {
	Id       int    `sql:"id,pk"`
	Config   string `sql:"config"`
	Internal bool   `sql:"internal"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type NotificationSettingsViewWithAppEnv struct {
	Id              int    `json:"id"`
	AppId           *int   `json:"app_id"`
	EnvId           *int   `json:"env_id"`
	ConfigName      string `sql:"config_name"`
	Config          string `sql:"config"`
	AppName         string `json:"app_name"`
	EnvironmentName string `json:"env_name"`
	sql.AuditLog
}

type SESConfig struct {
	Id           int    `sql:"id,pk"`
	Region       string `sql:"region"`
	AccessKey    string `sql:"access_key"`
	SecretKey    string `sql:"secret_access_key"`
	FromEmail    string `sql:"from_email"`
	SessionToken string `sql:"session_token"`
	ConfigName   string `sql:"config_name"`
	Description  string `sql:"description"`
	OwnerId      int32  `sql:"owner_id"`
	Default      bool   `sql:"default,notnull"`
	Deleted      bool   `sql:"deleted,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type SESNotificationRepository interface {
	FindOne(id int) (*SESConfig, error)
	UpdateSESConfig(sesConfig *SESConfig) (*SESConfig, error)
	SaveSESConfig(sesConfig *SESConfig) (*SESConfig, error)
	FindAll() ([]*SESConfig, error)
	FindByIdsIn(ids []int) ([]*SESConfig, error)
	FindByTeamIdOrOwnerId(ownerId int32) ([]*SESConfig, error)
	UpdateSESConfigDefault() (bool, error)
	FindByIds(ids []*int) ([]*SESConfig, error)
	FindDefault() (*SESConfig, error)
	MarkSESConfigDeleted(sesConfig *SESConfig) error
}

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

type SMTPConfig struct {
	Id           int    `sql:"id,pk"`
	Port         string `sql:"port"`
	Host         string `sql:"host"`
	AuthType     string `sql:"auth_type"`
	AuthUser     string `sql:"auth_user"`
	AuthPassword string `sql:"auth_password"`
	FromEmail    string `sql:"from_email"`
	ConfigName   string `sql:"config_name"`
	Description  string `sql:"description"`
	OwnerId      int32  `sql:"owner_id"`
	Default      bool   `sql:"default,notnull"`
	Deleted      bool   `sql:"deleted,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type SMTPNotificationRepository interface {
	FindOne(id int) (*SMTPConfig, error)
	UpdateSMTPConfig(smtpConfig *SMTPConfig) (*SMTPConfig, error)
	SaveSMTPConfig(smtpConfig *SMTPConfig) (*SMTPConfig, error)
	FindAll() ([]*SMTPConfig, error)
	FindByIdsIn(ids []int) ([]*SMTPConfig, error)
	FindByTeamIdOrOwnerId(ownerId int32) ([]*SMTPConfig, error)
	UpdateSMTPConfigDefault() (bool, error)
	FindByIds(ids []*int) ([]*SMTPConfig, error)
	FindDefault() (*SMTPConfig, error)
	MarkSMTPConfigDeleted(smtpConfig *SMTPConfig) error
}

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

type ScmConfiguration struct {
	URL string `json:"url"`
}

type SearchRequest struct {
	TeamId       []*int `json:"teamId" validate:"number"`
	EnvId        []*int `json:"envId" validate:"number"`
	AppId        []*int `json:"appId" validate:"number"`
	ClusterId    []*int `json:"clusterId" validate:"number"`
	PipelineName string `json:"pipelineName"`
	UserId       int32  `json:"-"`
}

type SettingOptionDTO struct {
	//TeamId       int    `json:"-"`
	//AppId        int    `json:"-"`
	//EnvId        int    `json:"-"`
	PipelineId      int    `json:"pipelineId"`
	PipelineName    string `json:"pipelineName"`
	PipelineType    string `json:"pipelineType"`
	AppName         string `json:"appName"`
	EnvironmentName string `json:"environmentName,omitempty"`
	ClusterName     string `json:"clusterName"`
}

type SlackConfig struct {
	Id          int    `sql:"id,pk"`
	WebHookUrl  string `sql:"web_hook_url"`
	ConfigName  string `sql:"config_name"`
	Description string `sql:"description"`
	OwnerId     int32  `sql:"owner_id"`
	TeamId      int    `sql:"team_id"`
	Deleted     bool   `sql:"deleted,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type SlackNotificationRepository interface {
	FindOne(id int) (*SlackConfig, error)
	UpdateSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error)
	SaveSlackConfig(slackConfig *SlackConfig) (*SlackConfig, error)
	FindAll() ([]SlackConfig, error)
	FindByIdsIn(ids []int) ([]*SlackConfig, error)
	FindByTeamIdOrOwnerId(ownerId int32, teamIds []int) ([]SlackConfig, error)
	FindByName(value string) ([]SlackConfig, error)
	FindByIds(ids []*int) ([]*SlackConfig, error)
	MarkSlackConfigDeleted(slackConfig *SlackConfig) error
}

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

type TerminalAccessRepository interface {
	FetchTerminalAccessTemplate(templateName string) (*models.TerminalAccessTemplates, error)
	FetchAllTemplates() ([]*models.TerminalAccessTemplates, error)
	GetUserTerminalAccessData(id int) (*models.UserTerminalAccessData, error)
	GetAllRunningUserTerminalData() ([]*models.UserTerminalAccessData, error)
	SaveUserTerminalAccessData(data *models.UserTerminalAccessData) error
	UpdateUserTerminalAccessData(data *models.UserTerminalAccessData) error
	UpdateUserTerminalStatus(id int, status string) error
}

type TerminalAccessRepositoryImpl struct {
	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

type UserAttributes struct {
	EmailId  string `sql:"email_id,pk"`
	UserData string `sql:"user_data,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type UserAttributesDao struct {
	EmailId string `json:"emailId"`
	Key     string `json:"key"`
	Value   string `json:"value"`
	UserId  int32  `json:"-"`
}

type UserAttributesRepository interface {
	GetConnection() (dbConnection *pg.DB)
	AddUserAttribute(attrDto *UserAttributesDao) (*UserAttributesDao, error)
	UpdateDataValByKey(attrDto *UserAttributesDao) error
	GetDataValueByKey(attrDto *UserAttributesDao) (string, error)
	GetUserDataByEmailId(emailId string) (string, error)
}

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

type WebhookConfig struct {
	Id          int                    `sql:"id,pk"`
	WebHookUrl  string                 `sql:"web_hook_url"`
	ConfigName  string                 `sql:"config_name"`
	Header      map[string]interface{} `sql:"header"`
	Payload     string                 `sql:"payload"`
	Description string                 `sql:"description"`
	OwnerId     int32                  `sql:"owner_id"`
	Active      bool                   `sql:"active"`
	Deleted     bool                   `sql:"deleted,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type WebhookData struct {
	Id              int
	EventActionType string
	Data            map[string]string
}

type WebhookEventData struct {
	Id          int       `sql:"id,pk"`
	GitHostId   int       `sql:"git_host_id,notnull"`
	EventType   string    `sql:"event_type,notnull"`
	PayloadJson string    `sql:"payload_json,notnull"`
	CreatedOn   time.Time `sql:"created_on,notnull"`
	// contains filtered or unexported fields
}

type WebhookEventDataRepository interface {
	Save(webhookEventData *WebhookEventData) error
	GetById(id int) (*WebhookEventData, error)
}

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

type WebhookNotificationRepository interface {
	FindOne(id int) (*WebhookConfig, error)
	UpdateWebhookConfig(webhookConfig *WebhookConfig) (*WebhookConfig, error)
	SaveWebhookConfig(webhookConfig *WebhookConfig) (*WebhookConfig, error)
	FindAll() ([]WebhookConfig, error)
	FindByName(value string) ([]WebhookConfig, error)
	FindByIds(ids []*int) ([]*WebhookConfig, error)
	MarkWebhookConfigDeleted(webhookConfig *WebhookConfig) error
}

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