diff --git a/cloudevents-server/pkg/events/custom/tekton/handler_pipelinerun.go b/cloudevents-server/pkg/events/custom/tekton/handler_pipelinerun.go index 5257cf6..0d083b3 100644 --- a/cloudevents-server/pkg/events/custom/tekton/handler_pipelinerun.go +++ b/cloudevents-server/pkg/events/custom/tekton/handler_pipelinerun.go @@ -2,6 +2,7 @@ package tekton import ( "net/http" + "strings" "github.com/PingCAP-QE/ee-apps/cloudevents-server/pkg/config" cloudevents "github.com/cloudevents/sdk-go/v2" @@ -51,6 +52,11 @@ func (h *pipelineRunHandler) Handle(event cloudevents.Event) cloudevents.Result receivers = append(h.Receivers[defaultReceiversKey], h.Receivers[event.Type()]...) } + log.Debug(). + Str("ce-type", event.Type()). + Str("receivers", strings.Join(receivers, ",")). + Msg("send notification for the event type.") + return sendLarkMessages(h.LarkClient, receivers, event, h.DashboardBaseURL) default: log.Debug().Str("ce-type", event.Type()).Msg("skip notifing for the event type.") diff --git a/cloudevents-server/pkg/events/custom/tekton/handler_taskrun.go b/cloudevents-server/pkg/events/custom/tekton/handler_taskrun.go index 0f05dfc..c0d4a23 100644 --- a/cloudevents-server/pkg/events/custom/tekton/handler_taskrun.go +++ b/cloudevents-server/pkg/events/custom/tekton/handler_taskrun.go @@ -2,6 +2,7 @@ package tekton import ( "net/http" + "strings" "github.com/PingCAP-QE/ee-apps/cloudevents-server/pkg/config" cloudevents "github.com/cloudevents/sdk-go/v2" @@ -41,6 +42,11 @@ func (h *taskRunHandler) Handle(event cloudevents.Event) cloudevents.Result { receivers = append(h.Receivers[defaultReceiversKey], h.Receivers[event.Type()]...) } + log.Debug(). + Str("ce-type", event.Type()). + Str("receivers", strings.Join(receivers, ",")). + Msg("send notification for the event type.") + return sendLarkMessages(h.LarkClient, receivers, event, h.DashboardBaseURL) default: log.Debug().Str("ce-type", event.Type()).Msg("skip notifing for the event type.")