spec/plans: 29 wire-frame conformance plans + unskip 004

Plans organised by WAMP §:

  Basic Profile
    004  Register → call → invocation → yield → result, two peers (was skipped pending multi-peer support)
    006  Pub/sub fan-out across two distinct sessions
    007  Call unknown procedure returns ERROR(no_such_procedure)
    008  Subscribe → unsubscribe → unsubscribed roundtrip
    009  Client GOODBYE → router echoes goodbye_and_out

  Advanced Profile
    010  Pattern-based subscription (match=prefix), §14.4.7
    011  Pattern-based subscription (match=wildcard), §14.4.7
    012  Shared registration roundrobin distribution, §14.3.9
    013  Progressive call results, §14.3.1.2
    014  Standard error URIs reachable without auth (§13.6.2)
    015  Cancel mode skip, §14.3.4
    016  Cancel mode kill (callee receives INTERRUPT), §14.3.4
    017  Cancel mode killnowait, §14.3.4
    018  Publish with eligible/exclude session lists, §14.4.2
    019  Pattern-based registration prefix, §14.3.7
    020  Pattern-based registration wildcard, §14.3.7
    021  Call timeout fires router-side, §14.3.3
    022  Shared registration invoke=first, §14.3.9
    023  Shared registration invoke=last, §14.3.9
    024  Publisher exclusion (default-true and explicit-false), §14.4.5
    025  Resubscribing to same topic returns existing id, §3.5.4
    026  Shared registration invoke=random (option-acceptance smoke), §14.3.9
    027  Shared registration invoke=random distribution via from_any, §14.3.9

  Authentication
    028  Anonymous welcome with explicit method + role, §13.2
    029  Ticket auth happy path (challenge / authenticate / welcome), §13.5
    030  Ticket auth with bad ticket aborts, §13.5
    031  WAMP-CRA happy path (challenge / sign / authenticate / welcome), §13.4
    032  WAMP-CRA with wrong signature aborts, §13.4

  Disclosure
    033  Caller disclosure adds caller_authid + caller_authrole, §14.3.5
    034  Publisher disclosure adds publisher_authid + publisher_authrole, §14.4.4

Plans 028+ exercise the auth-aware router setup; plans 027 + 033/034
exercise the from_any / placeholder-peer substitution; plans 031/032
exercise the wampcra_sign compute step.

All 34 plans pass on v4-contrib (the dealer fix in the previous commit
unblocks 013 against this branch's spec-strict assertion).

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: Marko Petzold

spec/plans/basic/004_call_yield_result.yaml

@@ -2,15 +2,49 @@ name: register-call-invocation-yield-result-roundtrip
 spec_section: "Basic Profile §3.7"
 realm: realm1
 serializer: json
-skip: "register/call/result roundtrip needs two peers in the same plan; planned for the multi-peer extension of the runner"
+
+# Two sessions: a callee that registers a procedure, and a caller that
+# invokes it. The router routes CALL → INVOCATION on the callee and
+# YIELD → RESULT back to the caller.
+peers:
+  - name: callee
+  - name: caller
+
 steps:
-  - send: [1, "realm1", {roles: {callee: {}, caller: {}}}]
-  - expect: [2, "{{$session_id:int}}", "_"]
-  - send: [64, 2001, {}, "spec.test.proc"]
-    note: "REGISTER"
-  - expect: [65, 2001, "{{$reg_id:int}}"]
-    note: "REGISTERED"
-  - send: [48, 2002, {}, "spec.test.proc", [1, 2]]
-    note: "CALL — same peer, currently routed to itself by single-peer plans"
-  - expect: [68, "{{$inv_id:int}}", "{{$reg_id:int}}", "_", [1, 2]]
-    note: "INVOCATION delivered back to this peer"
+  # Callee handshake.
+  - peer: callee
+    send: [1, "realm1", {roles: {callee: {}}}]
+    note: "HELLO"
+  - peer: callee
+    expect: [2, "{{$callee_session:int}}", "_"]
+    note: "WELCOME"
+
+  # Caller handshake.
+  - peer: caller
+    send: [1, "realm1", {roles: {caller: {}}}]
+  - peer: caller
+    expect: [2, "{{$caller_session:int}}", "_"]
+
+  # Callee REGISTER → REGISTERED.
+  - peer: callee
+    send: [64, 2001, {}, "spec.test.proc"]
+    note: "REGISTER request_id=2001"
+  - peer: callee
+    expect: [65, 2001, "{{$reg_id:int}}"]
+    note: "REGISTERED carries registration id"
+
+  # Caller CALL → callee gets INVOCATION.
+  - peer: caller
+    send: [48, 2002, {}, "spec.test.proc", [1, 2]]
+    note: "CALL request_id=2002 with positional args [1,2]"
+  - peer: callee
+    expect: [68, "{{$inv_id:int}}", "{{$reg_id:int}}", "_", [1, 2]]
+    note: "INVOCATION delivered to callee, args preserved"
+
+  # Callee YIELD → caller gets RESULT.
+  - peer: callee
+    send: [70, "{{$inv_id:int}}", {}, [3]]
+    note: "YIELD invocation_id, result=[3]"
+  - peer: caller
+    expect: [50, 2002, "_", [3]]
+    note: "RESULT for request_id=2002 carries the yielded value"

spec/plans/basic/006_pubsub_two_peers.yaml

@@ -0,0 +1,41 @@
+name: pubsub-fan-out-across-two-sessions
+spec_section: "Basic Profile §3.5"
+realm: realm1
+serializer: json
+
+# Verifies the broker fans an event from one publisher session to a
+# distinct subscriber session — without relying on the exclude_me=false
+# self-fan trick that 003 uses.
+peers:
+  - name: subscriber
+  - name: publisher
+
+steps:
+  # Subscriber handshake + SUBSCRIBE.
+  - peer: subscriber
+    send: [1, "realm1", {roles: {subscriber: {}}}]
+  - peer: subscriber
+    expect: [2, "{{$sub_session:int}}", "_"]
+
+  - peer: subscriber
+    send: [32, 1101, {}, "spec.test.fanout"]
+    note: "SUBSCRIBE"
+  - peer: subscriber
+    expect: [33, 1101, "{{$sub_id:int}}"]
+
+  # Publisher handshake + PUBLISH (with acknowledge).
+  - peer: publisher
+    send: [1, "realm1", {roles: {publisher: {}}}]
+  - peer: publisher
+    expect: [2, "{{$pub_session:int}}", "_"]
+
+  - peer: publisher
+    send: [16, 1102, {acknowledge: true}, "spec.test.fanout", ["hello"]]
+  - peer: publisher
+    expect: [17, 1102, "{{$pub_id:int}}"]
+    note: "PUBLISHED ack"
+
+  # Subscriber receives the EVENT.
+  - peer: subscriber
+    expect: [36, "{{$sub_id:int}}", "{{$pub_id:int}}", "_", ["hello"]]
+    note: "EVENT carries publication id and payload"

spec/plans/basic/007_call_no_such_procedure.yaml

@@ -0,0 +1,14 @@
+name: call-unknown-procedure-yields-no-such-procedure-error
+spec_section: "Basic Profile §3.7 / Errors §13.6.2"
+realm: realm1
+serializer: json
+
+steps:
+  - send: [1, "realm1", {roles: {caller: {}}}]
+  - expect: [2, "{{$session_id:int}}", "_"]
+
+  - send: [48, 7001, {}, "no.such.procedure.exists", []]
+    note: "CALL request_id=7001 to a never-registered URI"
+
+  # ERROR for CALL: [8, CALL=48, request_id, details, error_uri, args?, kwargs?]
+  - expect: [8, 48, 7001, "_", "wamp.error.no_such_procedure"]

spec/plans/basic/008_unsubscribe_roundtrip.yaml

@@ -0,0 +1,17 @@
+name: subscribe-unsubscribe-roundtrip
+spec_section: "Basic Profile §3.5 / §3.6"
+realm: realm1
+serializer: json
+
+steps:
+  - send: [1, "realm1", {roles: {subscriber: {}}}]
+  - expect: [2, "{{$session_id:int}}", "_"]
+
+  - send: [32, 8001, {}, "spec.test.unsubscribe"]
+  - expect: [33, 8001, "{{$sub_id:int}}"]
+    note: "SUBSCRIBED — capture subscription id"
+
+  - send: [34, 8002, "{{$sub_id:int}}"]
+    note: "UNSUBSCRIBE referencing the captured id"
+  - expect: [35, 8002]
+    note: "UNSUBSCRIBED for request_id=8002"

spec/plans/basic/009_goodbye_roundtrip.yaml

@@ -0,0 +1,13 @@
+name: client-initiated-goodbye-router-echoes
+spec_section: "Basic Profile §3.4.2"
+realm: realm1
+serializer: json
+
+steps:
+  - send: [1, "realm1", {roles: {publisher: {}}}]
+  - expect: [2, "{{$session_id:int}}", "_"]
+
+  - send: [6, {message: "client done"}, "wamp.close.normal"]
+    note: "GOODBYE — message=6"
+  - expect: [6, "_", "wamp.close.goodbye_and_out"]
+    note: "Router echoes GOODBYE with the standard reason URI"

spec/plans/basic/010_pattern_prefix_subscription.yaml

@@ -0,0 +1,36 @@
+name: pattern-based-prefix-subscription
+spec_section: "Advanced §14.4.7 — Pattern-based Subscription"
+realm: realm1
+serializer: json
+
+# Subscriber subscribes with `match=prefix` to "spec.test.area.";
+# publisher posts to a child URI; broker delivers the EVENT.
+peers:
+  - name: subscriber
+  - name: publisher
+
+steps:
+  - peer: subscriber
+    send: [1, "realm1", {roles: {subscriber: {}}}]
+  - peer: subscriber
+    expect: [2, "{{$sub_session:int}}", "_"]
+
+  - peer: subscriber
+    send: [32, 10001, {match: "prefix"}, "spec.test.area."]
+    note: "SUBSCRIBE with match=prefix"
+  - peer: subscriber
+    expect: [33, 10001, "{{$sub_id:int}}"]
+
+  - peer: publisher
+    send: [1, "realm1", {roles: {publisher: {}}}]
+  - peer: publisher
+    expect: [2, "{{$pub_session:int}}", "_"]
+
+  - peer: publisher
+    send: [16, 10002, {acknowledge: true}, "spec.test.area.fire", ["alarm"]]
+  - peer: publisher
+    expect: [17, 10002, "{{$pub_id:int}}"]
+
+  # Pattern-matched EVENT carries the original topic in details.topic.
+  - peer: subscriber
+    expect: [36, "{{$sub_id:int}}", "{{$pub_id:int}}", {topic: "spec.test.area.fire"}, ["alarm"]]

spec/plans/basic/011_pattern_wildcard_subscription.yaml

@@ -0,0 +1,35 @@
+name: pattern-based-wildcard-subscription
+spec_section: "Advanced §14.4.7 — Pattern-based Subscription"
+realm: realm1
+serializer: json
+
+# Wildcard pattern: each empty URI component is a single-segment
+# wildcard. "spec.test..fire" matches "spec.test.<anything>.fire".
+peers:
+  - name: subscriber
+  - name: publisher
+
+steps:
+  - peer: subscriber
+    send: [1, "realm1", {roles: {subscriber: {}}}]
+  - peer: subscriber
+    expect: [2, "{{$sub_session:int}}", "_"]
+
+  - peer: subscriber
+    send: [32, 11001, {match: "wildcard"}, "spec.test..fire"]
+    note: "SUBSCRIBE with match=wildcard, second segment is the wildcard"
+  - peer: subscriber
+    expect: [33, 11001, "{{$sub_id:int}}"]
+
+  - peer: publisher
+    send: [1, "realm1", {roles: {publisher: {}}}]
+  - peer: publisher
+    expect: [2, "{{$pub_session:int}}", "_"]
+
+  - peer: publisher
+    send: [16, 11002, {acknowledge: true}, "spec.test.alarm.fire", ["match"]]
+  - peer: publisher
+    expect: [17, 11002, "{{$pub_id:int}}"]
+
+  - peer: subscriber
+    expect: [36, "{{$sub_id:int}}", "{{$pub_id:int}}", {topic: "spec.test.alarm.fire"}, ["match"]]

spec/plans/basic/012_shared_registration_roundrobin.yaml

@@ -0,0 +1,83 @@
+name: shared-registration-roundrobin-distributes-calls
+spec_section: "Advanced §14.3.9 — Shared Registration"
+realm: realm1
+serializer: json
+
+# Two callees register the same procedure with invoke=roundrobin. Caller
+# issues 4 CALLs; the dealer rotates: call 1 → callee1, call 2 → callee2,
+# call 3 → callee1, call 4 → callee2. Confirms roundrobin distribution
+# in registration order (matches dealer.go's nextCallee policy).
+peers:
+  - name: callee1
+  - name: callee2
+  - name: caller
+
+steps:
+  # Callee 1 handshake + REGISTER (first registrant — index 0).
+  - peer: callee1
+    send: [1, "realm1", {roles: {callee: {}}}]
+  - peer: callee1
+    expect: [2, "{{$c1_session:int}}", "_"]
+
+  - peer: callee1
+    send: [64, 12001, {invoke: "roundrobin"}, "spec.test.shared"]
+  - peer: callee1
+    expect: [65, 12001, "{{$reg_id:int}}"]
+    note: "Both callees share the same registration id"
+
+  # Callee 2 handshake + REGISTER (second registrant — index 1).
+  - peer: callee2
+    send: [1, "realm1", {roles: {callee: {}}}]
+  - peer: callee2
+    expect: [2, "{{$c2_session:int}}", "_"]
+
+  - peer: callee2
+    send: [64, 12002, {invoke: "roundrobin"}, "spec.test.shared"]
+  - peer: callee2
+    expect: [65, 12002, "{{$reg_id:int}}"]
+
+  # Caller handshake.
+  - peer: caller
+    send: [1, "realm1", {roles: {caller: {}}}]
+  - peer: caller
+    expect: [2, "{{$caller_session:int}}", "_"]
+
+  # CALL #1 → callee1.
+  - peer: caller
+    send: [48, 12101, {}, "spec.test.shared", [1]]
+  - peer: callee1
+    expect: [68, "{{$inv1:int}}", "{{$reg_id:int}}", "_", [1]]
+  - peer: callee1
+    send: [70, "{{$inv1:int}}", {}, ["one"]]
+  - peer: caller
+    expect: [50, 12101, "_", ["one"]]
+
+  # CALL #2 → callee2.
+  - peer: caller
+    send: [48, 12102, {}, "spec.test.shared", [2]]
+  - peer: callee2
+    expect: [68, "{{$inv2:int}}", "{{$reg_id:int}}", "_", [2]]
+  - peer: callee2
+    send: [70, "{{$inv2:int}}", {}, ["two"]]
+  - peer: caller
+    expect: [50, 12102, "_", ["two"]]
+
+  # CALL #3 → callee1 (rotation wraps).
+  - peer: caller
+    send: [48, 12103, {}, "spec.test.shared", [3]]
+  - peer: callee1
+    expect: [68, "{{$inv3:int}}", "{{$reg_id:int}}", "_", [3]]
+  - peer: callee1
+    send: [70, "{{$inv3:int}}", {}, ["three"]]
+  - peer: caller
+    expect: [50, 12103, "_", ["three"]]
+
+  # CALL #4 → callee2.
+  - peer: caller
+    send: [48, 12104, {}, "spec.test.shared", [4]]
+  - peer: callee2
+    expect: [68, "{{$inv4:int}}", "{{$reg_id:int}}", "_", [4]]
+  - peer: callee2
+    send: [70, "{{$inv4:int}}", {}, ["four"]]
+  - peer: caller
+    expect: [50, 12104, "_", ["four"]]

spec/plans/basic/013_progressive_call_results.yaml

@@ -0,0 +1,55 @@
+name: progressive-call-results-stream
+spec_section: "Advanced §14.3.1 — Progressive Call Results"
+realm: realm1
+serializer: json
+
+# Caller issues a CALL with receive_progress=true. The callee yields
+# two progressive YIELDs (progress=true), then a final non-progress
+# YIELD. The caller observes two progressive RESULTs followed by the
+# terminal RESULT.
+peers:
+  - name: callee
+  - name: caller
+
+steps:
+  - peer: callee
+    send: [1, "realm1", {roles: {callee: {features: {progressive_call_results: true}}}}]
+    note: "Per spec §14.3.1.2 the callee only needs to declare progressive_call_results"
+  - peer: callee
+    expect: [2, "{{$callee_session:int}}", "_"]
+
+  - peer: callee
+    send: [64, 13001, {}, "spec.test.progressive"]
+  - peer: callee
+    expect: [65, 13001, "{{$reg_id:int}}"]
+
+  - peer: caller
+    send: [1, "realm1", {roles: {caller: {}}}]
+  - peer: caller
+    expect: [2, "{{$caller_session:int}}", "_"]
+
+  - peer: caller
+    send: [48, 13002, {receive_progress: true}, "spec.test.progressive"]
+    note: "CALL with receive_progress=true"
+  - peer: callee
+    expect: [68, "{{$inv_id:int}}", "{{$reg_id:int}}", {receive_progress: true}]
+    note: "INVOCATION carries receive_progress"
+
+  # Progressive YIELD #1.
+  - peer: callee
+    send: [70, "{{$inv_id:int}}", {progress: true}, ["chunk1"]]
+  - peer: caller
+    expect: [50, 13002, {progress: true}, ["chunk1"]]
+
+  # Progressive YIELD #2.
+  - peer: callee
+    send: [70, "{{$inv_id:int}}", {progress: true}, ["chunk2"]]
+  - peer: caller
+    expect: [50, 13002, {progress: true}, ["chunk2"]]
+
+  # Final non-progress YIELD terminates the stream.
+  - peer: callee
+    send: [70, "{{$inv_id:int}}", {}, ["final"]]
+  - peer: caller
+    expect: [50, 13002, "_", ["final"]]
+    note: "Terminal RESULT — details dict need not carry progress=false explicitly"