Method getEncodedWithContext

shared_state.go:312–341

getEncodedWithContext returns a defensive copy of the encoded payload after decoding it into out, so callers can safely mutate the returned slice. nolint:gocritic // Keep unnamed returns for clarity.

(
	ctx context.Context,
	key string,
	out any,
	decoder func([]byte, any) error,
	format string,
)

//
//nolint:gocritic // Keep unnamed returns for clarity.
func (s *SharedState) getEncodedWithContext(
	ctx context.Context,
	key string,
	out any,
	decoder func([]byte, any) error,
	format string,
) ([]byte, bool, error) {
	if err := s.ensureStorage(); err != nil {
		return nil, false, err
	}

	storageKey, ok := s.storageKey(key)
	if !ok {
		return nil, false, nil
	}

	data, err := s.storage.GetWithContext(ctx, storageKey)
	if err != nil {
		return nil, false, err
	}
	if data == nil {
		return nil, false, nil
	}

	if err := decodeSharedStateValue(data, out, decoder, format); err != nil {
		return nil, false, err
	}

	return append([]byte(nil), data...), true, nil
}

func encodeSharedStateValue(v any, encoder func(any) ([]byte, error), format string) ([]byte, error) {
	if encoder == nil {