Skip to content

Commit

Permalink
chore: send events async
Browse files Browse the repository at this point in the history
  • Loading branch information
ReuDa committed Jan 10, 2025
1 parent 20c01eb commit 878d0ed
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions extevents/extevents.go
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ func handle(handler eventHandler) func(w http.ResponseWriter, r *http.Request, b

if request, err := handler(event); err == nil {
if request != nil {
sendDatadogEvent(r.Context(), &config.Config, request)
go sendDatadogEvent(&config.Config, request)
}
} else {
exthttp.WriteError(w, extension_kit.ToError(err.Error(), err))
Expand Down Expand Up @@ -369,8 +369,8 @@ func parseBodyToEventRequestBody(body []byte) (event_kit_api.EventRequestBody, e
return event, err
}

func sendDatadogEvent(ctx context.Context, api SendEventApi, datadogEventBody *datadogV1.EventCreateRequest) {
_, r, err := api.SendEvent(ctx, *datadogEventBody)
func sendDatadogEvent(api SendEventApi, datadogEventBody *datadogV1.EventCreateRequest) {
_, r, err := api.SendEvent(context.Background(), *datadogEventBody)

if err != nil {
log.Err(err).Msgf("Failed to send Datadog event. Full response %v",
Expand Down
2 changes: 1 addition & 1 deletion extevents/extevents_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ func Test_sendDatadogEvent(t *testing.T) {
Tags: []string{},
SourceTypeName: extutil.Ptr("Steadybit"),
}
sendDatadogEvent(context.Background(), mockedApi, &datadogEventBody)
sendDatadogEvent(mockedApi, &datadogEventBody)

// Then
mockedApi.AssertNumberOfCalls(t, "SendEvent", 1)
Expand Down

0 comments on commit 878d0ed

Please sign in to comment.