repository

type AppLevelMetrics struct {
	Id           int  `sql:"id,pk"`
	AppId        int  `sql:"app_id,notnull"`
	AppMetrics   bool `sql:"app_metrics,notnull"`
	InfraMetrics bool `sql:"infra_metrics,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type AppLevelMetricsRepository interface {
	Save(metrics *AppLevelMetrics) error
	FindByAppId(id int) (*AppLevelMetrics, error)
	Update(metrics *AppLevelMetrics) error
}

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

type AppListingRepository interface {
	FetchAppsByEnvironment(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, error)
	FetchJobs(appIds []int, statuses []string, sortOrder string) ([]*bean.JobListingContainer, error)
	FetchOverviewCiPipelines(jobId int) ([]*bean.JobListingContainer, error)
	FetchJobsLastSucceededOn(ciPipelineIDs []int) ([]*bean.CiPipelineLastSucceededTime, error)
	FetchAppDetail(ctx context.Context, appId int, envId int) (bean.AppDetailContainer, error)

	FetchAppTriggerView(appId int) ([]bean.TriggerView, error)
	FetchAppStageStatus(appId int, appType int) ([]bean.AppStageStatus, error)

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

	FetchOtherEnvironment(appId int) ([]*bean.Environment, error)
	FetchMinDetailOtherEnvironment(appId int) ([]*bean.Environment, error)
	DeploymentDetailByArtifactId(ciArtifactId int, envId int) (bean.DeploymentDetailContainer, error)
	FindAppCount(isProd bool) (int, error)
	FetchAppsByEnvironmentV2(appListingFilter helper.AppListingFilter) ([]*bean.AppEnvironmentContainer, int, error)
	FetchOverviewAppsByEnvironment(envId, limit, offset int) ([]*bean.AppEnvironmentContainer, 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 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 AuthMode string

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"`
	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"`
	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(id int) (artifact *CiArtifact, err error)
	GetArtifactParentCiAndWorkflowDetailsByIds(ids []int) ([]*CiArtifact, error)
	GetByWfId(wfId int) (artifact *CiArtifact, err error)
	GetArtifactsByCDPipeline(cdPipelineId, limit int, parentId int, parentType bean.WorkflowType) ([]*CiArtifact, error)

	GetArtifactsByCDPipelineV2(cdPipelineId int) ([]CiArtifact, error)
	GetArtifactsByCDPipelineAndRunnerType(cdPipelineId int, runnerType bean.WorkflowType) ([]CiArtifact, error)
	SaveAll(artifacts []*CiArtifact) error
	GetArtifactsByCiPipelineId(ciPipelineId 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)
}

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

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

type DbConfig struct {
	Id       int    `sql:"id,pk"`
	Name     string `sql:"name"` //name by which user identifies this db
	Type     DbType `sql:"type"` //type of db, PG, MYsql, MariaDb
	Host     string `sql:"host"`
	Port     string `sql:"port"`
	DbName   string `sql:"db_name"` //name of database inside PG
	UserName string `sql:"user_name"`
	Password string `sql:"password"`
	Active   bool   `sql:"active"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type DbConfigRepository interface {
	Save(config *DbConfig) error
	GetAll() (configs []*DbConfig, err error)
	GetById(id int) (*DbConfig, error)
	Update(config *DbConfig) (*DbConfig, error)
	GetActiveForAutocomplete() (configs []*DbConfig, err error)
}

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

type DbType string

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 EnvLevelAppMetrics struct {
	Id           int   `sql:"id,pk"`
	AppId        int   `sql:"app_id,notnull"`
	EnvId        int   `sql:"env_id,notnull"`
	AppMetrics   *bool `sql:"app_metrics,notnull"`
	InfraMetrics *bool `sql:"infra_metrics,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type EnvLevelAppMetricsRepository interface {
	Save(metrics *EnvLevelAppMetrics) error
	Update(metrics *EnvLevelAppMetrics) error
	FindByAppIdAndEnvId(appId int, envId int) (*EnvLevelAppMetrics, error)
	Delete(metrics *EnvLevelAppMetrics) error
	FindByAppId(appId int) ([]*EnvLevelAppMetrics, error)
	FindByAppIdAndEnvIds(appId int, envIds []int) ([]*EnvLevelAppMetrics, error)
}

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

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

type GitHost struct {
	Id              int    `sql:"id,pk"`
	Name            string `sql:"name,notnull"`
	Active          bool   `sql:"active,notnull"`
	WebhookUrl      string `sql:"webhook_url"`
	WebhookSecret   string `sql:"webhook_secret"`
	EventTypeHeader string `sql:"event_type_header"`
	SecretHeader    string `sql:"secret_header"`
	SecretValidator string `sql:"secret_validator"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type GitHostRepository interface {
	FindAll() ([]GitHost, error)
	FindOneById(Id int) (GitHost, error)
	FindOneByName(name string) (GitHost, error)
	Exists(name string) (bool, error)
	Save(gitHost *GitHost) error
}

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

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"`
	BitBucketWorkspaceId string `sql:"bitbucket_workspace_id"`
	BitBucketProjectKey  string `sql:"bitbucket_project_key"`
	EmailId              string `sql:"email_id"`
	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)
	GetGitOpsConfigByProvider(provider string) (*GitOpsConfig, error)
	GetGitOpsConfigActive() (*GitOpsConfig, error)
	GetConnection() *pg.DB
	GetEmailIdFromActiveGitOpsConfig() (string, error)
	IsGitOpsConfigured() (bool, error)
}

type GitOpsConfigRepositoryImpl struct {
	// 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"`
	Deleted       bool     `sql:"deleted,notnull"`
	GitHostId     int      `sql:"git_host_id"` //id stored in db git_host( foreign key)
	sql.AuditLog
	// contains filtered or unexported fields
}

type GitProviderRepository interface {
	Save(gitProvider *GitProvider) error
	ProviderExists(url string) (bool, error)
	FindAllActiveForAutocomplete() ([]GitProvider, error)
	FindAll() ([]GitProvider, error)
	FindOne(providerId string) (GitProvider, error)
	FindByUrl(providerUrl string) (GitProvider, error)
	Update(gitProvider *GitProvider) error
	MarkProviderDeleted(gitProvider *GitProvider) error
}

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

type GitWebhook struct {
	Id            int       `sql:"id,pk"`
	CiMaterialId  int       `sql:"ci_material_id"`
	GitMaterialId int       `sql:"git_material_id"`
	Type          string    `sql:"type"`
	Value         string    `sql:"value"`
	Active        bool      `sql:"active"`
	LastSeenHash  string    `sql:"last_seen_hash"`
	CreatedOn     time.Time `sql:"created_on"`
	// contains filtered or unexported fields
}

type GitWebhookRepository interface {
	Save(gitWebhook *GitWebhook) error
}

type GitWebhookRepositoryImpl 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 JiraAccountDetails struct {
	Id                 int32  `sql:"id,pk"`
	UserName           string `sql:"user_name"`
	AccountURL         string `sql:"account_url"`
	AuthToken          string `sql:"auth_token"`
	CommitMessageRegex string `sql:"commit_message_regex"`
	FinalIssueStatus   string `sql:"final_issue_status"`
	PipelineStage      string `sql:"pipeline_stage"`
	PipelineId         int32  `sql:"pipeline_id"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type JiraAccountRepository interface {
	Save(accountDetails *JiraAccountDetails) error
	FindByPipelineIdAndStage(pipelineId int32, pipelineStage string) (*JiraAccountDetails, error)
	Update(accountDetails *JiraAccountDetails) error
}

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

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) (bean.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"`
	// contains filtered or unexported fields
}

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)
}

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

type NotificationSettingsView struct {
	Id     int    `sql:"id,pk"`
	Config string `sql:"config"`
	//ConfigName    string   `sql:"config_name"`
	//AppId         *int     `sql:"app_id"`
	//EnvironmentId *int     `sql:"env_id"`
	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"`
	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"`
}

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     map[string]interface{} `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
}