From 4c36246166deb48aad6c2f7eebc04da8de654d48 Mon Sep 17 00:00:00 2001 From: Jeff Repanich Date: Sun, 13 Sep 2026 15:29:55 -0400 Subject: [PATCH 1/2] ci: allow manual workflow dispatch --- .github/workflows/ci.yml | 1 + 1 file changed, 1 insertion(+) diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml index 3ebc727..fbe2f8a 100644 --- a/.github/workflows/ci.yml +++ b/.github/workflows/ci.yml @@ -1,6 +1,7 @@ name: CI on: + workflow_dispatch: push: pull_request: schedule: From 0a30996d1e3d8db7e4b2332718d55b341438878e Mon Sep 17 00:00:00 2001 From: Jeff Repanich Date: Sun, 13 Sep 2026 15:39:09 -0400 Subject: [PATCH 2/2] test: tolerate capability hello before auth rejection --- test/transport_test.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/test/transport_test.go b/test/transport_test.go index 04e6463..7335a77 100644 --- a/test/transport_test.go +++ b/test/transport_test.go @@ -311,7 +311,15 @@ func TestShouldRejectNonConnectFrameGivenNewTransportWhenFrameSentBeforeAuthenti frame := protocol.EncodeFrameOwned(protocol.MessageTypeKvBegin, nil) defer frame.Release() require.NoError(t, trans.Write(ctx, frame.Bytes())) - _, err = trans.Read(ctx) + // New brokers may send an unsolicited SERVER_HELLO before rejecting the + // unauthenticated domain frame. Drain any such capability advertisement + // and assert that the session is ultimately closed. + for { + _, err = trans.Read(ctx) + if err != nil { + break + } + } require.Error(t, err) }) }