Skip to content

Commit f3b19db

Browse files
committed
Add event splitting
1 parent 0974eb5 commit f3b19db

File tree

1 file changed

+12
-1
lines changed

1 file changed

+12
-1
lines changed

internal/dev_server/sdk/sdk_events.go

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package sdk
22

33
import (
4+
"encoding/json"
45
"io"
56
"log"
67
"net/http"
@@ -29,7 +30,17 @@ func SdkEventsReceiveHandler(writer http.ResponseWriter, request *http.Request)
2930
log.Printf("SdkEventsReceiveHandler: error reading request body: %v", err)
3031
return
3132
}
32-
observers.Notify(string(bodyStr))
33+
34+
var arr []json.RawMessage
35+
err = json.Unmarshal(bodyStr, &arr)
36+
37+
if err != nil {
38+
log.Printf("SdkEventsReceiveHandler: error unmarshaling request body: %v", err)
39+
}
40+
41+
for _, msg := range arr {
42+
observers.Notify(string(msg))
43+
}
3344

3445
writer.Header().Set("Content-Type", "application/json")
3546
writer.WriteHeader(http.StatusAccepted)

0 commit comments

Comments
 (0)