@@ -2,6 +2,7 @@ package service
2
2
3
3
import (
4
4
"context"
5
+ "encoding/json"
5
6
"fmt"
6
7
"log/slog"
7
8
"strings"
@@ -38,10 +39,14 @@ type CloudEventClient struct {
38
39
}
39
40
40
41
func (s CloudEventClient ) TriggerDevBuild (ctx context.Context , dev DevBuild ) error {
42
+ bs , _ := json .Marshal (dev )
43
+ slog .InfoContext (ctx , "trigger dev build" , "dev" , string (bs ))
41
44
event , err := newDevBuildCloudEvent (dev )
42
45
if err != nil {
43
46
return err
44
47
}
48
+ eventBytes , _ := event .MarshalJSON ()
49
+ slog .InfoContext (ctx , "trigger dev build event" , "event" , string (eventBytes ))
45
50
c := cloudevents .ContextWithTarget (ctx , s .endpoint )
46
51
if result := s .client .Send (c , * event ); ! protocol .IsACK (result ) {
47
52
slog .ErrorContext (ctx , "failed to send" , "reason" , result )
@@ -78,7 +83,7 @@ func newDevBuildCloudEvent(dev DevBuild) (*cloudevents.Event, error) {
78
83
event .SetSubject (fmt .Sprint (dev .ID ))
79
84
event .SetSource ("tibuild.pingcap.net/api/devbuilds/" + fmt .Sprint (dev .ID ))
80
85
event .SetExtension ("user" , dev .Meta .CreatedBy )
81
- event .SetExtension ("paramProfile" , dev .Spec .Edition )
86
+ event .SetExtension ("paramProfile" , string ( dev .Spec .Edition ) )
82
87
if dev .Spec .BuilderImg != "" {
83
88
event .SetExtension ("paramBuilderImage" , dev .Spec .BuilderImg )
84
89
}
0 commit comments