Skip to content

Commit ad547f2

Browse files
committed
chore: get another test working
1 parent 2be6d56 commit ad547f2

File tree

1 file changed

+26
-0
lines changed

1 file changed

+26
-0
lines changed

coderd/httpapi/httpapi_test.go

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -326,6 +326,32 @@ func TestOneWayWebSocket(t *testing.T) {
326326

327327
t.Run("Socket will immediately close if client sends any message", func(t *testing.T) {
328328
t.Parallel()
329+
330+
ctx := testutil.Context(t, testutil.WaitShort)
331+
req := newBaseRequest(ctx)
332+
writer := newWebsocketWriter()
333+
t.Cleanup(writer.close)
334+
_, done, err := httpapi.OneWayWebSocket[codersdk.ServerSentEvent](writer, req)
335+
require.NoError(t, err)
336+
337+
successC := make(chan bool)
338+
ticker := time.NewTicker(testutil.WaitShort)
339+
go func() {
340+
select {
341+
case <-done:
342+
successC <- true
343+
case <-ticker.C:
344+
successC <- false
345+
}
346+
}()
347+
348+
b, err := json.Marshal(struct {
349+
Value string `json:"value"`
350+
}{"Hi :)"})
351+
require.NoError(t, err)
352+
_, err = writer.clientConn.Write(b)
353+
require.NoError(t, err)
354+
require.True(t, <-successC)
329355
})
330356

331357
t.Run("Returned callback returns error if called after socket has been closed", func(t *testing.T) {

0 commit comments

Comments
 (0)