Skip to content

Commit

Permalink
Adding test per code review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
absurdfarce committed Jun 25, 2024
1 parent 415052d commit 0dec0bc
Showing 1 changed file with 10 additions and 6 deletions.
16 changes: 10 additions & 6 deletions proxy/proxy_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -206,13 +206,17 @@ func TestProxy_UseKeyspace(t *testing.T) {

cl := connectTestClient(t, ctx, proxyContactPoint)

resp, err := cl.SendAndReceive(ctx, frame.NewFrame(primitive.ProtocolVersion4, 0, &message.Query{Query: "USE system"}))
require.NoError(t, err)
testKeyspaces := []string{"system", "\"system\""}
for _, testKeyspace := range testKeyspaces {

assert.Equal(t, primitive.OpCodeResult, resp.Header.OpCode)
res, ok := resp.Body.Message.(*message.SetKeyspaceResult)
require.True(t, ok, "expected set keyspace result")
assert.Equal(t, "system", res.Keyspace)
resp, err := cl.SendAndReceive(ctx, frame.NewFrame(primitive.ProtocolVersion4, 0, &message.Query{Query: "USE " + testKeyspace}))
require.NoError(t, err)

assert.Equal(t, primitive.OpCodeResult, resp.Header.OpCode)
res, ok := resp.Body.Message.(*message.SetKeyspaceResult)
require.True(t, ok, "expected set keyspace result")
assert.Equal(t, "system", res.Keyspace)
}
}

func TestProxy_NegotiateProtocolV5(t *testing.T) {
Expand Down

0 comments on commit 0dec0bc

Please sign in to comment.