name: joule-moq-room room service # The room service (joule-code/joule-code-rs/crates/joule-moq-room), a workspace of its own # with its own lock file: its keys file, the grants it signs checked against its # descriptor and read by the relay's reader, the places and the limiter, and # tests/room_service.rs, the service against a relay on loopback that trusts its authority: # a grant and its proof open a session and the clock announces the publisher, the grant # alone opens none, the room verifies (live-rooms §9), a publisher past the room's places # is refused, clients are bounded, and a new room starts when the last publisher has left; # an end-to-end encrypted room (WAI confidentiality), members keying through the # service's log on a relay; admission by age (WAI age-assurance §5.6), the service a # Privacy Pass origin whose tokens' thresholds its grants state and the relay serves by; and a # watch room (WAI co-watch): viewers admitted by a proof of their key, their controls and # statements carried when co-watch accepts them, the clock's skew statements and leaves, and the # room the log carries verified by wai-rs; and a remote desktop room (WAI remote-desktop, # tests/remote_room.rs): the host agent of joule-moq-remote enters by an invitation over https:// # and wss:// through TLS fronts, viewers make their keys, the host hands control over by a grant # exchange it proves its key for, inputs are applied and refused by the rules, a controller's # typing sealed to the host and absent from what a viewer receives, refused floor statements # change nothing, a record out of its chain's order is cut and its author removed, the session's # records are read under a grant of the room alone, and the session verified by wai-rs as the # clock and the host hold it, at the commitment and the opened levels; a viewer flooding past its # own record bound (max_records_per_principal), cut and removed while the session goes on and # verifies; and a session the clock ends at its record bound on the whole session (max_records), # whole and verified; a conversation (WAI live-messaging, tests/messaging_room.rs): # members keying through real MLS groups, messaging across a restart of the service from its # history store, a thread, reactions, an edit and a retraction, a removed member served nothing # past its removal, every record verified offline; and a call (tests/call_room.rs) rung, accepted # and carrying audio and video through the relay, and another missed. tests/openapi_contract.rs # holds openapi.json to the service: every operationId is the operation's name in the toolchain's # catalogue (wai/wai-rs/src/catalogue.rs, at the route it gives) and every operation the # catalogue routes to the room service is described, the routes the routers match are exactly its # operations, each status it lists is one its handlers return and each status they return is # listed, and the service, run in each of its modes, answers every operation with a status it # lists. tests/mcp_dev_room.rs builds `wai` with the feature `mcp` and the relay wai-relay (each a # target directory of its own) and drives `wai mcp --toolset core,dev` with an MCP client: the tool # room_grant and POST /grant named alike (room.grant), a stack whose room service is of another # toolchain refused as stale, WAI's local stack (`wai dev --control`) started on loopback, grants # for test principals, two joining and publishing with their receipts and one without, whose # objects the relay drops, the session verified as live-rooms §9 verifies a room, a changed record # refused, a synthetic publisher and viewer's test, and a grant from a service off the machine # refused. tests/cli_dev_room.rs runs the same stack with `wai dev --control` in a project and # drives it from the command line: wai room join (a grant, then the join through the stack's # origin), wai session show verified as live-rooms §9 verifies a room, before and after wai room # leave, wai room show --target local, wai log tail, wai session list (the summary of the session # the relay closed) and wai room invite (an invitation the room's authority signed), and once the # stack stops a door finds none. tests/participants.rs holds the synthetic participants (`wai-room participant`) to a # relay with doors: a participant without receipts dropped there and served where there is none, # impairment on the QUIC binding changing the loss QUIC measures, and a load delivered in full. # tests/source_room.rs: the room's own source ([source]) through the relay, every object held # to its playout timing, and through the HTTP egress gateway, each part served on its running # receipt; and its real-time test, refused on a loaded runner. # tests/ports.rs holds the local stack's ports in one place: room.example.toml's relay_url is # relay.example.toml's WebSocket endpoint and path, gateway.example.toml, read by the gateway's # own reader (joule-moq-ingest, a dev-dependency), has the relay's QUIC endpoint and each listener # it names a row (off until set when commented out, and read at the row's port once set), the relay's # example is `wai-relay --dev`, wai dev's origin is the one the remote desktop template's host # reaches, and the defaults of wai-audit, wai-ledger, wai-fleet, wai-quantum-service, the worlds' # relay, the stitched presentation verifier and `wai http origin` are their sources', every one # of them a row of wai/quickstart/README.md's port table and no port twice; the room service # started from its example opens its clock's session on the relay started from its; and the # gateway started from its example (ports moved to free ones, its files made) opens HTTP and # RTMP and none of the listeners its example leaves off. # # It builds on wai-rs's room, event, composition, co-watch and remote desktop records, on the # relay, on joule-moq-mls, on the remote desktop host agent and on wai-metrics, so a change to any # of them runs it. Push filters match the push's delta, so every path the job reads is listed. # After the tests, clippy holds the service's own code, every target, to no warnings. concurrency: group: ${{ github.workflow }}-${{ github.event_name == 'push' && github.sha || github.ref }} cancel-in-progress: true on: # A push to main runs it too: work lands as direct commits to main, and this workflow has # no schedule, so without this a direct commit would build and test none of it. push: branches: [main] paths: - 'joule-code/joule-code-rs/crates/joule-moq-room/**' - 'joule-code/joule-code-rs/crates/joule-moq-remote/**' - 'joule-code/joule-code-rs/crates/joule-moq/**' - 'joule-code/joule-code-rs/crates/joule-moq-mls/**' - 'joule-code/joule-code-rs/crates/joule-moq-relay/**' - 'joule-code/joule-code-rs/crates/jwp/**' - 'joule-code/joule-code-rs/vendor/**' - 'wai/wai-rs/**' - 'wai/wai-ops/**' - 'wai/wai-metrics/**' # tests/tempo_vectors.rs regenerates and checks the playout timing corpus and requires # co-watch §15.6's table; the step after the tests reads it with its second implementation. - 'wai/moqt-conformance/tempo/**' - 'wai/moqt-conformance/tempo_verify.py' - 'wai/extensions/co-watch.md' # Read and started by tests/ports.rs: the ingest gateway and what it builds on. - 'joule-code/joule-code-rs/crates/joule-moq-ingest/**' - 'joule-code/joule-code-rs/crates/joule-contrib/**' # tests/source_room.rs: the HTTP egress gateway serves the room source's parts, and the # source publishes the package it names. - 'joule-code/joule-code-rs/crates/joule-moq-http/**' - 'wai/pack-conformance/multi/multi-opus-01/**' # Read by tests/ports.rs. - 'wai/quickstart/README.md' - 'wai/examples/remote-desktop/host.sh' - 'wai/wai-audit/src/main.rs' - 'wai/wai-ledger/src/main.rs' - 'wai/wai-fleet/src/main.rs' - 'wai/wai-quantum-service/src/main.rs' - 'wai/wai-relay/src/main.rs' - '.github/workflows/joule-moq-room.yml' pull_request: paths: - 'joule-code/joule-code-rs/crates/joule-moq-room/**' - 'joule-code/joule-code-rs/crates/joule-moq-remote/**' - 'joule-code/joule-code-rs/crates/joule-moq/**' - 'joule-code/joule-code-rs/crates/joule-moq-mls/**' - 'joule-code/joule-code-rs/crates/joule-moq-relay/**' - 'joule-code/joule-code-rs/crates/jwp/**' - 'joule-code/joule-code-rs/vendor/**' - 'wai/wai-rs/**' - 'wai/wai-ops/**' - 'wai/wai-metrics/**' # tests/tempo_vectors.rs regenerates and checks the playout timing corpus and requires # co-watch §15.6's table; the step after the tests reads it with its second implementation. - 'wai/moqt-conformance/tempo/**' - 'wai/moqt-conformance/tempo_verify.py' - 'wai/extensions/co-watch.md' # Read and started by tests/ports.rs: the ingest gateway and what it builds on. - 'joule-code/joule-code-rs/crates/joule-moq-ingest/**' - 'joule-code/joule-code-rs/crates/joule-contrib/**' # tests/source_room.rs: the HTTP egress gateway serves the room source's parts, and the # source publishes the package it names. - 'joule-code/joule-code-rs/crates/joule-moq-http/**' - 'wai/pack-conformance/multi/multi-opus-01/**' # Read by tests/ports.rs. - 'wai/quickstart/README.md' - 'wai/examples/remote-desktop/host.sh' - 'wai/wai-audit/src/main.rs' - 'wai/wai-ledger/src/main.rs' - 'wai/wai-fleet/src/main.rs' - 'wai/wai-quantum-service/src/main.rs' - 'wai/wai-relay/src/main.rs' - '.github/workflows/joule-moq-room.yml' jobs: # Forgejo matches `paths:` against the push delta, so a rebase fires this workflow # whatever the pull request changes. This job reads the pull request's own diff against # the paths above (scripts/pr-touches-paths.py, which fails open). relevant: name: joule-moq-room · does this change touch it runs-on: gate outputs: run: ${{ steps.gate.outputs.run }} steps: - uses: actions/checkout@v5 with: fetch-depth: 0 - id: gate run: | set -euo pipefail r=$(python3 scripts/pr-touches-paths.py .github/workflows/joule-moq-room.yml \ "${{ github.event.pull_request.base.sha }}" \ "${{ github.event.pull_request.head.sha }}") echo "this change touches the room service: $r" echo "run=$r" >> "$GITHUB_OUTPUT" test: name: joule-moq-room, every target needs: relevant if: needs.relevant.outputs.run == 'true' runs-on: linux-arm64 timeout-minutes: 45 steps: - name: Checkout uses: actions/checkout@v4 - name: Install Rust 1.99.1 shell: bash run: | export PATH="$HOME/.cargo/bin:$PATH" command -v rustup >/dev/null 2>&1 || \ curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh -s -- -y --profile minimal --default-toolchain 1.99.1 rustup toolchain install 1.99.1 --profile minimal --component clippy rustup default 1.99.1 echo "$HOME/.cargo/bin" >> "$GITHUB_PATH" - name: joule-moq-room, every target working-directory: joule-code/joule-code-rs/crates/joule-moq-room shell: bash run: cargo test --locked --all-targets # Playout timing (draft-nandakumar-moq-tempo-00; WAI co-watch §15): the corpus read by # a second implementation written from the text, which computes the controlled position # itself (tests/tempo_vectors.rs holds the crate to the corpus in the step above). - name: playout timing, second implementation shell: bash run: | if ! command -v python3 >/dev/null 2>&1; then SUDO=""; [ "$(id -u)" = 0 ] || SUDO="sudo" $SUDO apt-get update -qq $SUDO apt-get install -y -qq python3 fi python3 -I wai/moqt-conformance/tempo_verify.py # Its own code only (`--no-deps`), every target, warnings as errors: a lint in a crate it # builds on through a path dependency is that crate's to fix. - name: joule-moq-room, clippy working-directory: joule-code/joule-code-rs/crates/joule-moq-room shell: bash run: cargo clippy --locked --all-targets --no-deps -- -D warnings