Function TestSharedState_StorageErrorsArePropagated

shared_state_test.go:304–366

(t *testing.T)

}

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

	expectedErr := errors.New("storage failed")
	closeErr := errors.New("close failed")
	app := New(Config{
		SharedStorage: &errorStorage{err: expectedErr, closeErr: closeErr},
		MsgPackEncoder: func(any) ([]byte, error) {
			return []byte("msgpack"), nil
		},
		MsgPackDecoder: func([]byte, any) error {
			return nil
		},
		CBOREncoder: func(any) ([]byte, error) {
			return []byte("cbor"), nil
		},
		CBORDecoder: func([]byte, any) error {
			return nil
		},
		XMLEncoder: func(any) ([]byte, error) {
			return []byte("<xml/>"), nil
		},
		XMLDecoder: func([]byte, any) error {
			return nil
		},
	})

	err := app.SharedState().SetJSON("k", Map{"v": 1}, time.Second)
	require.ErrorIs(t, err, expectedErr)
	err = app.SharedState().SetMsgPack("k", Map{"v": 1}, time.Second)
	require.ErrorIs(t, err, expectedErr)
	err = app.SharedState().SetCBOR("k", Map{"v": 1}, time.Second)
	require.ErrorIs(t, err, expectedErr)
	err = app.SharedState().SetXML("k", Map{"v": 1}, time.Second)
	require.ErrorIs(t, err, expectedErr)

	err = app.SharedState().Set("k", []byte("v"), time.Second)
	require.ErrorIs(t, err, expectedErr)

	_, _, err = app.SharedState().Get("k")
	require.ErrorIs(t, err, expectedErr)

	_, _, err = app.SharedState().GetJSON("k", &Map{})
	require.ErrorIs(t, err, expectedErr)
	_, _, err = app.SharedState().GetMsgPack("k", &Map{})
	require.ErrorIs(t, err, expectedErr)
	_, _, err = app.SharedState().GetCBOR("k", &Map{})
	require.ErrorIs(t, err, expectedErr)
	_, _, err = app.SharedState().GetXML("k", &Map{})
	require.ErrorIs(t, err, expectedErr)

	_, err = app.SharedState().Has("k")
	require.ErrorIs(t, err, expectedErr)

	err = app.SharedState().Delete("k")
	require.ErrorIs(t, err, expectedErr)

	err = app.SharedState().Reset()