Function TestProxy_DseVersion

proxy/proxy_test.go:282–319

(t *testing.T)

}

func TestProxy_DseVersion(t *testing.T) {
	const dseVersion = "6.8.3"
	const protocol = primitive.ProtocolVersion4

	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()

	// Fake a peer so that "SELECT ... system.peers" returns at least one row
	tester, proxyContactPoint, err := setupProxyTestWithConfig(ctx, 1, &proxyTestConfig{
		dseVersion: dseVersion,
		rpcAddr:    "127.0.0.1",
		peers: []PeerConfig{{
			RPCAddr: "127.0.0.2",
		}}})
	defer func() {
		cancel()
		tester.shutdown()
	}()
	require.NoError(t, err)

	cl := connectTestClient(t, ctx, proxyContactPoint)

	checkDseVersion := func(resp *frame.Frame, err error) {
		require.NoError(t, err)
		assert.Equal(t, primitive.OpCodeResult, resp.Header.OpCode)
		rows, ok := resp.Body.Message.(*message.RowsResult)
		assert.True(t, ok, "expected rows result")

		rs := proxycore.NewResultSet(rows, protocol)
		require.GreaterOrEqual(t, rs.RowCount(), 1)
		actualDseVersion, err := rs.Row(0).StringByName("dse_version")
		require.NoError(t, err)
		assert.Equal(t, dseVersion, actualDseVersion)
	}

	checkDseVersion(cl.SendAndReceive(ctx, frame.NewFrame(protocol, 0, &message.Query{Query: "SELECT dse_version FROM system.local"})))
	checkDseVersion(cl.SendAndReceive(ctx, frame.NewFrame(primitive.ProtocolVersion4, 0, &message.Query{Query: "SELECT dse_version FROM system.peers"})))
}

func TestProxy_UnsupportedCompressionType(t *testing.T) {
	ctx, cancel := context.WithCancel(context.Background())