Skip to content

Commit d9fdfb6

Browse files
committed
Merge branch 'moonshot-xxii-debugger' of github.com:launchdarkly/ldcli into moonshot-xxii-debugger
2 parents 770455a + a4fde70 commit d9fdfb6

File tree

1 file changed

+14
-3
lines changed

1 file changed

+14
-3
lines changed

internal/dev_server/sdk/sdk_events.go

Lines changed: 14 additions & 3 deletions
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"
@@ -14,11 +15,11 @@ type sdkEventObserver struct {
1415
}
1516

1617
func (o sdkEventObserver) Handle(message interface{}) {
17-
str, ok := message.(string)
18+
str, ok := message.(json.RawMessage)
1819
if !ok {
1920
return
2021
}
21-
o.updateChan <- Message{Event: TYPE_PUT, Data: []byte(str)}
22+
o.updateChan <- Message{Event: TYPE_PUT, Data: str}
2223
}
2324

2425
var observers *model.Observers = model.NewObservers()
@@ -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(msg)
43+
}
3344

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

0 commit comments

Comments
 (0)