Function TestSharedState_UsesAppMsgPackCodec

shared_state_test.go:592–624

(t *testing.T)

}

func TestSharedState_UsesAppMsgPackCodec(t *testing.T) {
	t.Parallel()

	encoderCalled := false
	decoderCalled := false

	app := New(Config{
		SharedStorage: newSharedStateMemoryStorage(t),
		MsgPackEncoder: func(_ any) ([]byte, error) {
			encoderCalled = true
			return []byte("msgpack-payload"), nil
		},
		MsgPackDecoder: func(data []byte, out any) error {
			decoderCalled = true
			ptr, ok := out.(*string)
			if ok {
				*ptr = string(data)
			}
			return nil
		},
	})

	require.NoError(t, app.SharedState().SetMsgPack("codec", Map{"ignored": true}, time.Minute))

	var out string
	raw, found, err := app.SharedState().GetMsgPack("codec", &out)
	require.NoError(t, err)
	require.True(t, found)
	require.Equal(t, []byte("msgpack-payload"), raw)
	require.Equal(t, "msgpack-payload", out)
	require.True(t, encoderCalled)
	require.True(t, decoderCalled)
}

func TestSharedState_UnconfiguredCodecsReturnErrorInsteadOfPanic(t *testing.T) {
	t.Parallel()