feat(hub): multi-node broker dispatch — affinity, durable intent, lifecycle + message routing by ptone · Pull Request #305 · GoogleCloudPlatform/scion

Add canonical engineering glossary (GLOSSARY.md) (#102)

scion-gteam[bot]

and

ptone

committed

P0-1: switch Postgres driver from lib/pq to pgx/v5 stdlib

Scion

authored and

ptone

committed

P0-2: add connection pool config to DatabaseConfig

Scion

authored and

ptone

committed

P0-3/P0-4: CRUD-parity test harness + spec-driven fixture generator

Scion

authored and

ptone

committed

feat(ent): add 23 new Ent schemas for full table parity (P1-2 + P1-3)

Scion

authored and

ptone

committed

P2: port notification + gcp/github/token domains to Ent entadapter

Scion

authored and

ptone

committed

P2: port schedule, maintenance, message domains to Ent entadapter

Scion

authored and

ptone

committed

feat(entadapter): port user + allowlist/invite domains to Ent (P2)

Scion

authored and

ptone

committed

P2: port secret/env_var + template/harness_config domains to Ent

Scion

authored and

ptone

committed

P2: port project/broker + brokersecret domains to Ent

Scion

authored and

ptone

committed

P2: port agent domain to Ent entadapter (XL)

Scion

authored and

ptone

committed

chore(ent): regenerate Ent code for all 30 entity schemas

Scion

authored and

ptone

committed

P2-collapse: collapse dual-DB into single Ent store

Scion

authored and

ptone

committed

P2-delete: remove raw-SQL store implementation

Scion

authored and

ptone

committed

test: compile-migrate downstream suites to Ent store + fix signing-key PK

Scion

authored and

ptone

committed

test(hub): map non-UUID fixture IDs to UUIDs via tid() helper

Scion

authored and

ptone

committed

fix(store): seed maintenance ops in Migrate; initStore uses Migrate

Scion

authored and

ptone

committed

test(hub): satisfy Ent NotEmpty validators in fixtures

Scion

authored and

ptone

committed

fix(entadapter): Get-by-id returns ErrNotFound for non-UUID identifiers

Scion

authored and

ptone

committed

test(hub): fix store-less id wraps and project-route URL paths

Scion

authored and

ptone

committed

test(hub): unwrap projectIDFromServiceAccountEmail expectation

Scion

authored and

ptone

committed

fix(ent): GCPServiceAccount.project_id is a string, not a UUID

Scion

authored and

ptone

committed

test(hub): fix GCP SA project-id assertion and project-settings id

Scion

authored and

ptone

committed

test(hub): revert tid() over-wraps in store-less events_test

Scion

authored and

ptone

committed

test(hub): fix maintenance-run path and notifications agentId queries

Scion

authored and

ptone

committed

test(hub): wrap remaining fixture IDs revealed after panic-cascade cleared

Scion

authored and

ptone

committed

test(hub): unwrap tid() in scheduler_test (mock store, raw ids)

Scion

authored and

ptone

committed

fix(ent): Template.harness may be empty (raw-store parity)

Scion

authored and

ptone

committed

test(hub): wrap dynamic fixture IDs in wake/workspace/signing-key tests

Scion

authored and

ptone

committed

test(hub): convert raw-id URL path segments to tid()

Scion

authored and

ptone

committed

fix(hub): seed creator users for agent-created agents; cascade-delete subscriptions on hard agent delete

Scion

authored and

ptone

committed

test(hub): seed broker slug/name in dispatcher and project_cache fixtures (Ent validators)

Scion

authored and

ptone

committed

fix(entadapter): cascade-delete agents on project delete (raw-store parity); test(hub): seed FK users, broker_name, deterministic UUIDs

Scion

authored and

ptone

committed

test(hub): MaxOpenConns=1 for SQLite test store (serialize writes); tid() URLs + FK user seeds in events/stopall

Scion

authored and

ptone

committed

test(hub): unwrap over-wrapped tid() in unit tests (workspace/logfilter/gcp/web); valid-UUID NotFound cases; tid() scheduled-event URLs

Scion

authored and

ptone

committed

fix(ent): allow empty display_name (raw-store NOT NULL parity, email fallback); test(hub): seed FK owner users, UUID policy/broker/agent IDs in authz remediation

Scion

authored and

ptone

committed

feat(migrate): add Migration β tool (Ent-SQLite → Ent-Postgres)

Scion

authored and

ptone

committed

feat(concurrency): dialect-aware multi-replica primitives for Postgres (P3-3..6)

Scion

authored and

ptone

committed

feat(hub): widen events to EventPublisher interface + Postgres LISTEN/NOTIFY publisher

Scion

authored and

ptone

committed

test(store): parameterize store suites over {sqlite, postgres} (P3-2)

Scion

authored and

ptone

committed

fix(hub): harden Postgres event publish + verify wiring; lower PG pool default

Scion

authored and

ptone

committed

test(store): add Postgres stress/integration suite (contention, isolation, pool, NOTIFY, migration, schema, multi-process)

Scion

authored and

ptone

committed

fix(db): recycle stale conns + keepalives; skip singleton tick on lock error

Scion

authored and

ptone

committed

fix(store): bound advisory-lock conn checkout + unlock with short timeout

Scion

authored and

ptone

committed

feat(migrate): in-process migration α (legacy raw-SQL hub.db → Ent)

Scion

authored and

ptone

committed

fix(config): apply real Postgres pool size (leaked SQLite default of 1 starved the pool)

Scion

authored and

ptone

committed

feat(hub): per-process instanceID on Server (B1-1)

Scion

authored and

ptone

committed

feat(schema): affinity columns on runtime_brokers (B1-2)

Scion

authored and

ptone

committed

feat(store): Claim/Release runtime-broker affinity CAS methods (B1-3)

Scion Agent (em-broker-dispatch)

authored and

ptone

committed

fix(hub): thread sessionID through connect + fix onDisconnect clobber race (B1-4, B1-5)

Scion Agent (em-broker-dispatch)

authored and

ptone

committed

feat(schema): broker_dispatch intent table + messages dispatch-state (B2-1, B2-2)

Scion Agent (em-broker-dispatch)

authored and

ptone

committed

feat(hub): PostgresCommandBus LISTEN/NOTIFY signal listener on scion_broker_cmd (B2-4)

Scion Agent (bd-bus)

authored and

ptone

committed

feat(store): BrokerDispatch store methods + message dispatch CAS (B2-3)

Scion Agent (em-broker-dispatch)

authored and

ptone

committed

feat(hub): reconcile-on-connect drain wired to bus + markBrokerOnline (B2-5)

Scion Agent (em-broker-dispatch)

authored and

ptone

committed

feat(hub): route() decision in HybridBrokerClient (B3-1)

Scion Agent (em-broker-dispatch)

authored and

ptone

committed

feat(hub): cross-node message dispatch via route()+intent+signal+owner drain (B3-2, B3-3)

Scion Agent (bd-msg)

authored and

ptone

committed

feat(hub): lifecycle dispatch (rolling-timeout wait + cross-node start/stop/restart) (B4-1, B4-2)

Scion Agent (bd-life)

authored and

ptone

committed

feat(hub): wire originator-side cross-node lifecycle dispatch (B4-2 complete)

Scion Agent (bd-life)

authored and

ptone

committed

fix(hub): make web session replica-portable to fix OAuth state_mismatch

Scion

authored and

ptone

committed

feat(hub): cross-node delete + create-time data ops dispatch (B4-3, B4-4)

Scion Agent (bd-ops)

authored and

ptone

committed

feat(hub): stale-affinity + stuck-dispatch reaper singleton (B5-1)

Scion Agent (bd-reaper)

authored and

ptone

committed

feat(hub): pending-message sweep + dispatch metrics (B5-2)

Scion Agent (bd-sweep)

authored and

ptone

committed

fix(hub): derive JWT signing keys from shared SESSION_SECRET to fix cross-replica login loop

Scion

authored and

ptone

committed

docs: project log for B5-3 chaos gate — GB5 PASSED (GA gate for broker dispatch)

Scion

authored and

ptone

committed

fix(hub): align fakeHTTPClient.CleanupProject with interface (3 params, not 4)

Scion

authored and

ptone

committed

fix(hub): address PR #305 review feedback

ptone

committed

docs: add project log for PR #305 review feedback fixes

ptone

committed

fix(hub): prevent duplicate message delivery, guard dispatch state transitions

ptone

committed

fix(hub): reconcile broker→eventbus and hub-native→hub-managed renames after rebase

ptone

committed

Commits

Commits on Jun 5, 2026