Skip to content

Commit d003b56

Browse files
committed
feat: add flat response endpoint
1 parent 24e68e7 commit d003b56

File tree

3 files changed

+25
-0
lines changed

3 files changed

+25
-0
lines changed

cmd/server/main.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,7 @@ func main() {
6060
r.HandleFunc("/eventstreams/chat", eventstreams.HandleEventStreamChat).Methods(http.MethodPost)
6161
r.HandleFunc("/eventstreams/chat-chunked", eventstreams.HandleEventStreamChat).Methods(http.MethodPost)
6262
r.HandleFunc("/eventstreams/differentdataschemas", eventstreams.HandleEventStreamDifferentDataSchemas).Methods(http.MethodPost)
63+
r.HandleFunc("/eventstreams/differentdataschemasflatten", eventstreams.HandleEventStreamDifferentDataSchemasFlatten).Methods(http.MethodPost)
6364
r.HandleFunc("/clientcredentials/token", clientcredentials.HandleTokenRequest).Methods(http.MethodPost)
6465
r.HandleFunc("/clientcredentials/authenticatedrequest", clientcredentials.HandleAuthenticatedRequest).Methods(http.MethodPost)
6566
r.HandleFunc("/clientcredentials/alt/token", clientcredentials.HandleTokenRequest).Methods(http.MethodPost)

cmd/server/server

13.2 MB
Binary file not shown.

internal/eventstreams/service.go

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -174,3 +174,27 @@ func HandleEventStreamDifferentDataSchemas(rw http.ResponseWriter, _ *http.Reque
174174
},
175175
})
176176
}
177+
178+
func HandleEventStreamDifferentDataSchemasFlatten(rw http.ResponseWriter, _ *http.Request) {
179+
rw.Header().Add("Content-Type", "text/event-stream")
180+
181+
pushEvents(rw, [][]string{
182+
{
183+
`id: event-1`,
184+
`event: message`,
185+
`data: {"content": "Here is your url"}`,
186+
},
187+
188+
{
189+
`id: event-2`,
190+
`event: url`,
191+
`data: {"url": "https://example.com"}`,
192+
},
193+
194+
{
195+
`id: event-3`,
196+
`event: message`,
197+
`data: {"content": "Have a great day!"}`,
198+
},
199+
})
200+
}

0 commit comments

Comments
 (0)