Skip to content

Commit

Permalink
feat(cloudevents): add params info in tekton runs notification (#94)
Browse files Browse the repository at this point in the history
Signed-off-by: wuhuizuo <wuhuizuo@126.com>

Signed-off-by: wuhuizuo <wuhuizuo@126.com>
  • Loading branch information
wuhuizuo committed Mar 6, 2024
1 parent 9ed4028 commit 6a29275
Show file tree
Hide file tree
Showing 3 changed files with 27 additions and 1 deletion.
13 changes: 12 additions & 1 deletion cloudevents-server/pkg/events/custom/tekton/lark.go
Original file line number Diff line number Diff line change
Expand Up @@ -132,6 +132,10 @@ func extractLarkInfosFromEvent(event cloudevents.Event, baseURL string) (*cardMe
case data.PipelineRun != nil:
startTime = data.PipelineRun.Status.StartTime
endTime = data.PipelineRun.Status.CompletionTime
for _, p := range data.PipelineRun.Spec.Params {
v, _ := p.Value.MarshalJSON()
ret.Params = append(ret.Params, [2]string{p.Name, string(v)})
}
if data.PipelineRun.Status.GetCondition(apis.ConditionSucceeded).IsFalse() {
ret.RerunURL = fmt.Sprintf("tkn -n %s pipeline start %s --use-pipelinerun %s",
data.PipelineRun.Namespace, data.PipelineRun.Spec.PipelineRef.Name, data.PipelineRun.Name)
Expand All @@ -142,6 +146,10 @@ func extractLarkInfosFromEvent(event cloudevents.Event, baseURL string) (*cardMe
}
}
case data.TaskRun != nil:
for _, p := range data.TaskRun.Spec.Params {
v, _ := p.Value.MarshalJSON()
ret.Params = append(ret.Params, [2]string{p.Name, string(v)})
}
startTime = data.TaskRun.Status.StartTime
endTime = data.TaskRun.Status.CompletionTime
if data.TaskRun.Status.GetCondition(apis.ConditionSucceeded).IsFalse() {
Expand All @@ -158,7 +166,10 @@ func extractLarkInfosFromEvent(event cloudevents.Event, baseURL string) (*cardMe
case data.Run != nil:
startTime = data.Run.Status.StartTime
endTime = data.Run.Status.CompletionTime

for _, p := range data.Run.Spec.Params {
v, _ := p.Value.MarshalJSON()
ret.Params = append(ret.Params, [2]string{p.Name, string(v)})
}
if results := data.Run.Status.Results; len(results) > 0 {
var parts []string
for _, r := range results {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,17 @@ elements:
tag: lark_md
content: "⏱️ **Time cost:**\t{{ . }}"
{{- end }}

{{- with .Params }}
- tag: hr
- tag: markdown
content: |-
**Params:**
{{- range . }}
- **{{ index . 0 }}:** {{ index . 1 }}
{{- end }}
{{- end }}

{{- with .Results }}
- tag: hr
- tag: markdown
Expand All @@ -33,6 +44,7 @@ elements:
```
{{- end }}
{{- end }}

{{- with .RerunURL }}
- tag: hr
- tag: markdown
Expand All @@ -43,6 +55,8 @@ elements:
{{ . }}
```
{{- end }}

- tag: hr
- tag: action
actions:
- tag: button
Expand Down
1 change: 1 addition & 0 deletions cloudevents-server/pkg/events/custom/tekton/types.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,7 @@ type cardMessageInfos struct {
StartTime string
EndTime string
TimeCost string
Params [][2]string // key-value pairs.
Results [][2]string // Key-Value pairs.
}

Expand Down

0 comments on commit 6a29275

Please sign in to comment.