Method HandleMessage

lib/event/router.go:70–88

HandleMessage is the single entry point.

(ctx context.Context, eventID string, data []byte)

// HandleMessage is the single entry point.
func (r *Router) HandleMessage(ctx context.Context, eventID string, data []byte) error {
	// 1. Efficient Peek: We only parse the metadata fields.
	// The rest of the JSON is captured as RawMessage without full decoding.
	var env envelope
	if err := json.Unmarshal(data, &env); err != nil {
		return fmt.Errorf("%w: %w: %w", ErrUnprocessableEntity, ErrInvalidEnvelope, err)
	}

	// 2. Find matching route
	for _, route := range r.routes {
		if route.Matches(env.Kind, env.APIVersion) {
			// 3. Dispatch using only the inner 'data' payload

			return route.Dispatch(ctx, eventID, env.Data)
		}
	}

	return fmt.Errorf("%w: %w: kind=%q version=%q", ErrUnprocessableEntity, ErrNoHandler, env.Kind, env.APIVersion)
}

// envelope is used for the initial peek.
type envelope struct {