client

type CiPipelineMaterialResponse struct {
	Id              int                    `json:"id"`
	GitMaterialId   int                    `json:"gitMaterialId"`
	GitMaterialUrl  string                 `json:"gitMaterialUrl"`
	GitMaterialName string                 `json:"gitMaterialName"`
	Type            string                 `json:"type"`
	Value           string                 `json:"value"`
	Active          bool                   `json:"active"`
	History         []*gitSensor.GitCommit `json:"history,omitempty"`
	LastFetchTime   time.Time              `json:"lastFetchTime"`
	IsRepoError     bool                   `json:"isRepoError"`
	RepoErrorMsg    string                 `json:"repoErrorMsg"`
	IsBranchError   bool                   `json:"isBranchError"`
	BranchErrorMsg  string                 `json:"branchErrorMsg"`
	Url             string                 `json:"url"`
}

type Event struct {
	EventTypeId        int                 `json:"eventTypeId"`
	EventName          string              `json:"eventName"`
	PipelineId         int                 `json:"pipelineId"`
	PipelineType       string              `json:"pipelineType"`
	CorrelationId      string              `json:"correlationId"`
	Payload            *Payload            `json:"payload"`
	EventTime          string              `json:"eventTime"`
	TeamId             int                 `json:"teamId"`
	AppId              int                 `json:"appId"`
	EnvId              int                 `json:"envId"`
	CdWorkflowType     bean.CdWorkflowType `json:"cdWorkflowType,omitempty"`
	CdWorkflowRunnerId int                 `json:"cdWorkflowRunnerId"`
	CiWorkflowRunnerId int                 `json:"ciWorkflowRunnerId"`
	CiArtifactId       int                 `json:"ciArtifactId"`
	BaseUrl            string              `json:"baseUrl"`
	UserId             int                 `json:"-"`
}

type EventClient interface {
	WriteEvent(event Event) (bool, error)
	WriteNatsEvent(channel string, payload interface{}) error
	SendTestSuite(reqBody []byte) (bool, error)
}

type EventClientConfig struct {
	DestinationURL string `env:"EVENT_URL" envDefault:"http://localhost:3000/notify"`
	TestSuitURL    string `env:"TEST_SUIT_URL" envDefault:"http://localhost:3000"`
}

type EventFactory interface {
	Build(eventType util.EventType, sourceId *int, appId int, envId *int, pipelineType util.PipelineType) Event
	BuildExtraCDData(event Event, wfr *pipelineConfig.CdWorkflowRunner, pipelineOverrideId int, stage bean2.CdWorkflowType) Event
	BuildExtraCIData(event Event, material *MaterialTriggerInfo, dockerImage string) Event
}

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

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

type MaterialTriggerInfo struct {
	GitTriggers map[int]pipelineConfig.GitCommit `json:"gitTriggers"`
	CiMaterials []CiPipelineMaterialResponse     `json:"ciMaterials"`
}

type Payload struct {
	AppName               string               `json:"appName"`
	EnvName               string               `json:"envName"`
	PipelineName          string               `json:"pipelineName"`
	Source                string               `json:"source"`
	DockerImageUrl        string               `json:"dockerImageUrl"`
	TriggeredBy           string               `json:"triggeredBy"`
	Stage                 string               `json:"stage"`
	DeploymentHistoryLink string               `json:"deploymentHistoryLink"`
	AppDetailLink         string               `json:"appDetailLink"`
	DownloadLink          string               `json:"downloadLink"`
	BuildHistoryLink      string               `json:"buildHistoryLink"`
	MaterialTriggerInfo   *MaterialTriggerInfo `json:"material"`
}