Repository navigation
feat(reporting): buyer write facade and the raw syncPrincipal guard - #3554
Conversation
Add the pure expectedSubscriptionPeriods rule for AdCP 3.3 principal-level reporting subscriptions (experimental media_buy.reporting_subscriptions), the normative period_generation calendar it uses, selector resolution (exact, finest, all with byte-order ties), scope membership, and a builder for the 3.3 registration capabilities (configuration_tasks, the deprecated configuration_task, and the subscriptions block). createAdcpServerFromPlatform adds media_buy.reporting_subscriptions to experimental_features only beside a subscriptions block. installConfiguration now throws a typed ReportingConfigurationImmutableError with the unchanged message. The cross-SDK parity table is test/fixtures/reporting-subscriptions/coverage-cases.json. Refs #3504 Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…al ships Advertising media_buy.reporting_subscriptions also requires adcp.principal.supported_sections to list reporting_subscriptions, which the SDK does not emit yet. Keep the capability builder pure in this slice and add the feature id together with the principal block in the runtime slice, so an adopter can never produce a 3.3-invalid capabilities response. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
Adopt the rules adcontextprotocol/adcp#8585 settled: - Selection reads each offering's published standard_dimensions and unmapped_dimensions, and fails closed on an offering without them. - period_timezone: a utc offering matches only UTC or Etc/UTC; a source_timezone offering only its own published zone (never an account-resolved one). - The coverage function takes the readback's inactive_intervals in wire shape, per-offering timezone_cutovers with previous_timezone (account.timezone is now the current zone), and per-offering gaps. - The parity table fixes the billing-cycle case's scope (both keys, which maxProperties 1 forbids), adds cases for the settled rules, and its subscriptions are now schema-validated. The new wire fields are hand-modeled in subscriptions/wire.ts until 3.3.0-beta.2 ships. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
- An empty flight (stop at or before start) overlaps nothing. - A cutover carries the outgoing stretch's own owing start into E, so two cutovers inside one period never owe a period twice. - Sub-daily periods under a local alignment restart at each local midnight on wall-clock multiples (adcp#8588); calendars gain next() and the walk iterates by instant with an iteration budget and skip-ahead. - A billing anchor in a DST fold is interval zero itself. - A wire authorized_at equal to the chain start continues the chain. - The start rule lives in one function for the pending owner decision. - Schema validation accepts unknown reporting-dimension values. - The parity table grows to 79 cases with obligations on every case and non-wire inputs labelled. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
The start bound is the first boundary at or after the later of the version's accepted_at and the account's authorized_at; a buy is owed every period that ends after its confirmed_at and overlaps its flight, so the period in which the buy is confirmed is owed in full. The rule stays in firstOwedBoundary. Parity table: the mid-period confirmed_at and hourly cases change, plus every case whose first period contains confirmed_at; new cases for an ASAP buy confirmed mid-day and a monthly billing buy confirmed on the 12th. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…time
Opt-in support for the AdCP 3.3 sync_principal reporting_subscriptions
section (experimental media_buy.reporting_subscriptions):
- createPrincipalLifecycle({ reportingSubscriptions }) validates, versions
and reads back subscriptions (core/reporting-subscription-state.json),
honours dry_run and expected_configuration_version, applies
replace_account_configs once per version through a host hook, derives
action_required from the destination, and emits principal.changed with
reason reporting_subscription_changed. It also exposes the adcp.principal
capability block.
- createReportingSubscriptionEngineV1 turns three host hooks into grant
history, max_accounts slots, precedence, exceptions at cutover instants,
timezone cutovers, re-grant gaps, accounts_unauthorized, the receipt
roster and the post-loss receipt window, and computes owed periods with
the same expectedSubscriptionPeriods rule buyers run.
- createReliableReportingService({ reportingSubscriptions }) advertises
configuration_tasks and the subscriptions block and adds
subscription_coverage to summary and periods views.
- createAdcpServerFromPlatform passes capabilities.principal and
capability_changes through, adds protocol.principal and
media_buy.reporting_subscriptions to experimental_features, refuses
subscriptions without the reporting_subscriptions section, and strips
3.3-only fields for callers pinned below 3.3.
Without the options every response is byte-for-byte unchanged; a golden
transcript captured from the pre-change runtime proves it.
Refs #3504
Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
… by release - readFacts refuses a roster that does not finish within the page cap, as it already did for a repeating cursor: a partial roster would read as revocations and fabricate accounts_unauthorized entries. - Callers pinned below 3.2 no longer see protocol.principal once the adcp.principal block is removed for them. - subscription_coverage is added only for callers served 3.3 or later; earlier get_reporting_status response shapes are closed. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
The placeholder regex backtracked polynomially on runs of '{' (CodeQL).
Tokenize braces in a single pass instead, which also rejects nested and
unbalanced braces explicitly.
Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
… test Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
- The principal readback lists inactive_intervals; the engine feeds them to the coverage function in wire shape. - Timezone cutovers carry previous_timezone and gaps are recorded per offering_id when covered offerings' boundaries differ. - authorized_at is the start of the authorization chain: a re-grant inside retention keeps it, so the engine stamps the re-grant when authority is observed again. - The service requires standard_dimensions on every offering when subscriptions are advertised. - Responses served at 3.3.0-beta.1 omit the fields its closed schemas do not define; they reach callers served 3.3.0-beta.2 or later. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…ts, sharded engine state Addresses the expert review of the subscription runtime: - Owed periods are frozen as they elapse and never recomputed; pruning past status_retention_days never re-owes or drops an elapsed period. A product, package or offering change applies from the E of its observation, and periods of that buy starting earlier keep resolving from the buy as it was. - Change instants come from source data (granted_at, timezone_changed_at, resolveRevocationInstant, the overriding configuration's active_until). - The engine store is sharded per principal and per account; the receipt roster is tenant-scoped; an unobserved revocation followed by a new chain opens a gap. - replace_account_configs runs after commit and is retried on failure; a destination transport change needs a version; inactive_intervals over 64 is rejected; shared path_templates that can expand to the same path are rejected; the delivery-config clash check is required unless opted out; coverage recording rejects oversized lists and no longer bumps configuration_version. - Post-beta.1 fields are gated on the served bundle's schema, and an unknown served version emits none of them. prior_versions[] carries configuration (adcp#8588). Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…counts A small max_accounts against a large roster gives every account past the cap a capacity exception, which can exceed the readback's 1000-entry limit. The reconcile used to throw for the whole principal on every pass. Now that subscription keeps its last published lists, every other subscription still updates, and the pass reports it in readback_overflow and through onReadbackOverflow. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…criptions - syncReportingSubscriptionsV1 writes and reads back the reporting_subscriptions section through the guarded sync_principal lifecycle. - reportingSubscriptionVersionRecordsV1 rebuilds coverage version records from the readback plus the buyer's own per-version configurations, and subscriptionExpectedReportingPeriodsV1 maps owed obligations onto the consumer runtime's ExpectedReportingPeriod. - The consumer runtime takes a per-account subscriptionExpectations hook fed with the summary view's subscription_coverage, and refreshes on an authenticated principal.changed through handleAuthenticatedPrincipalChanged. - createReportingSubscriptionEngineStateStoreV1 persists engine state as one CAS document per principal on any AdcpStateStore; PostgresStateStore makes it durable with no further migration. A PostgreSQL restart test joins the CI backend-contracts step. Refs #3504 Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…ords Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…he buyer side reportingSubscriptionVersionRecordsV1 no longer takes buyer-recorded inactive intervals: the readback's inactive_intervals (adcp#8585) pass to expectedSubscriptionPeriods unchanged. Test offerings publish standard_dimensions. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
listPrincipals feeds the receipt roster, so a list cut short at the page cap, or a repeating cursor, now throws instead of returning a partial list, matching the authorized-account walk. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
- The engine state store follows the engine's sharded interface: one CAS document per principal and per (principal, account), with listKeys and a tenant-scoped listPrincipals. - Subscription expectations get the summary's ledger_as_of (minus an optional grace) as now, and the hook is documented as requiring a seller that materializes subscription obligations. - Expectation templates must supply coverage; the old default could never match an obligation reporting packages or partial coverage. - principal.changed redeliveries are dropped by idempotency_key, and a burst during a run joins one trailing run. - syncReportingSubscriptionsV1 refuses a deactivation by omission unless allowDeactivation, checked against every configuration read it replaces, and verifies the stored configuration field by field. - reportingSubscriptionVersionRecordsV1 falls back to the readback's configuration and prior_versions[].configuration (adcp#8588). Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
Owed-set generations for AdCP 3.3 principal-level reporting subscriptions (#3504): one generation per (account, owning principal, subscription_id, subscription_version, resolved offering), with an immutable `subscription` block and a mutable `owedSet` horizon outside the fingerprint. - producer.planSubscriptionObligations installs each generation once, writes every frozen owed obligation with its own period, media buys and constituents (periodOrdinal = start second), and then advances owedSet.through on every generation the subscription owns. - Coverage treats an owed set as complete by construction: gaps are not owed, so there is no continuity error, and the scope stays open until owedSet.through reaches its end. - get_reporting_status, get_media_buy_delivery and sync_reporting_status scope subscription generations to the caller's principal (resolveSubscriptionPrincipal, snapshot `subscription_principal`). - Status ingest accepts a status without reporting_obligation_id against an owed set only for an existing owed obligation. - PostgreSQL: additive `subscription_key` column and a unique index on (account_id, delivery_config_id, delivery_config_version, subscription_key) replacing the three-column constraint, found and dropped by its columns. Mirrored in the memory test store. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…vice
createReliableReportingService({ reportingSubscriptions }) now writes the
engine's frozen owed sets into the ledger every cycle, before account
configurations, and the worker executes them (#3504).
- engine.frozenOwedSets(principal, { accountId? }) returns each
subscription's frozen obligations, horizon and version configurations;
engine.listPrincipals(tenantId) lists principals from the engine store.
- Generations go through the same trusted path as installConfiguration
(resolveSource, resolveCurrency, resolveCoverage), with seller policy from
the new resolveSubscriptionConfiguration hook. Each obligation freezes the
authorized constituents of exactly the media buys it owes.
- New options: listSubscriptionPrincipals (required),
resolveSubscriptionConfiguration (required), resolveSubscriptionAccount and
onPlanningError. Planning failures are isolated per subscription.
- resolvePrincipal now also scopes get_reporting_status,
get_media_buy_delivery and sync_reporting_status to the caller's own
subscription generations.
- Without reportingSubscriptions the service is byte-for-byte unchanged,
proven by a golden transcript captured from the service before the change.
Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…ntime timezone data A source-calendar P1D generation freezes the runtime's tzdb and ICU versions and the install day into its identity, so the golden differed on CI runners. The transcript now uses a UTC-aligned offering; the golden is recaptured from #3509's head (800adfc) and still matches byte for byte. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
Deliver principal-level reporting subscription obligations (#3504) to the owner's destination through managed delivery. - Destination resolution: the Core service calls a new reportingSubscriptions.bindManagedGeneration hook (through the planner's bindGeneration) before a managed generation's first obligation. The production service supplies createReportingSubscriptionManagedBindingV1: version destination_id -> the owner's current destination generation (delivery-eligible, pattern and transport matching the frozen destination_method) -> a per-account authorization of that destination_ref (ensureDestinationAuthorization) -> an immutable binding that freezes path_template. - Bindings are keyed by their Core configuration: the managed migration drops the published (account, delivery_config_id, delivery_config_version) key, found by its columns. - path_template is expanded per obligation and passed to adapters as delivery_path; object-store names place it inside the collision-free generation prefix. Subscription revision rows carry account_id inside the committed digest. - The managed worker re-checks the owner's account authority before delivering and before settling; a lost grant holds the materialization without spending an attempt, so the obligation stays owed. - Status subscribers and notification activity reach only the owner of a subscription obligation. Production reads are scoped to the caller's principal and carry subscription_coverage. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
# Conflicts: # scripts/check-package-size.mjs
…ley/reporting-subscription-ledger-service
…to bokelley/reporting-subscription-delivery
…bscription-coverage # Conflicts: # scripts/check-package-size.mjs
…dules after merging main Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…/reporting-subscription-runtime # Conflicts: # scripts/check-package-size.mjs
…er merging main Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…reporting-subscription-consumer
…/reporting-subscription-ledger
…eporting-subscription-ledger-service # Conflicts: # src/lib/reporting/subscriptions/engine.ts
…kelley/reporting-subscription-delivery
…/reporting-subscription-receipts
…/reporting-subscription-conformance
…ley/reporting-subscription-dx-advanced
…ley/reporting-subscription-dx-revocation
…elley/reporting-subscription-dx-errors # Conflicts: # src/lib/reporting/subscriptions/engine.ts
…y/reporting-subscription-dx-vectors
…ey/reporting-subscription-dx-naming
When the offerings a condition covers have different period boundaries, the engine now writes one excluded[] entry per offering with offering_id and that offering's cutover instants (capacity, excluded_by_buyer, action_required, overridden, and offering_unsupported after a resolution change). Before, it wrote one account-wide entry cut at the latest end. A per-offering entry closes at its own offering's cutover. A release whose excluded[] has no offering_id gets them folded back into one entry. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
… Reporting service
createReliableReportingService({ subscriptions: SubscriptionOptions }) now
builds the coverage engine, installs the reporting_subscriptions section on
the principal runtime, fills in capabilities.principal on install, reconciles
a principal after each sync_principal write that submits subscriptions, and
sweeps every subscribed principal at the start of runCycle.
The roster and buys are derived from the platform's accounts.list and
sales.getMediaBuys under the principal's identity, with overrides named as
in the Python SDK's SubscriptionOptions. An unreadable roster is coded
SUBSCRIPTION_ROSTER_UNAVAILABLE, and reconcile and planning failures are
returned in runCycle's subscriptionPlanningFailures instead of an
AggregateError. The production service accepts the managed block.
Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
With the managed subscriptions block the service serves the journal's authorization.authorized_at on list_accounts and sync_accounts to callers holding subscriptions, and the derived roster reads the same value. A host value is adopted on first observation, an omitted one is stamped, a value that moves an open chain earlier is refused and logged as authorized_at_regressed, and the chain rule decides whether a re-grant continues the chain. service.grants.changed pushes a grant change for an exact instant, and resolveRevocationInstant becomes optional. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
client.reporting (ReportingClient) adds subscribe, unsubscribe, replaceSubscriptions, listSubscriptions and preview: patch-shaped writes over the replace-shaped sync_principal wire, with auto-versioning, a destination merge, pre-dispatch checks (scope, destination, path_template, SUBSCRIPTION_ID_CLASH, SUBSCRIPTION_OPERATOR_SCOPE_REQUIRED, SUBSCRIPTION_SELECTOR_UNMATCHED), CONFLICT retries with fresh keys and a verified readback. A raw client.syncPrincipal that would deactivate a subscription or revoke a destination by omission is refused before sending unless allowDeactivation or allowRevocation is passed. Names follow the Python SDK's ReportingClient. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
There was a problem hiding this comment.
Ladon verdict: Approve
Approve — clean additive T7 slice with 1 medium finding (below the ≥3 threshold).
The buyer write facade client.reporting (reporting-facade.ts, 689 new lines) and the raw syncPrincipal guard are well-structured and correctly wired: the guard is fail-closed (refuses deactivation/revocation by omission unless opted in), retries are bounded (maxAttempts 1–10, roster paging capped at 10, transport retry once with replayable key), AgentClient delegates the guard through SingleAgentClient, lifecycle/storyboard writes correctly pass unguarded, and the minor changeset is appropriate for an additive, experimental (AdCP 3.3) surface. Witness-not-translator, changeset-vs-wire-impact, and transport-client rules all satisfied.
Medium findings
- src/lib/principal/reporting-facade.ts:630 — Facade verify() readback-mismatch throw path is untested (only the lower-level syncReportingSubscriptionsV1 equivalent is covered)
Decision table: no critical/high findings (row 1 n/a); gated_paths false (row 2 n/a); high_risk false (rows 3/5 n/a); the single medium is not data-loss/schema/infra (row 4 n/a); no prior escalation (row 6 n/a); no no-auto-approve team match (row 7 n/a); only 1 medium, below the 3-medium bar (row 8 n/a). Falls through to row 9 → approve. Note: review_decision is REVIEW_REQUIRED, but with gated_paths false that does not gate this PR.
Medium findings
- src/lib/principal/reporting-facade.ts:630 — Facade verify() readback-mismatch throw path is untested
…ager graph The facade loads offering selection on demand and carries its own readback diff, so client/core gains only the facade module itself. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…entity in the auth snapshot - The derived roster and buy reads take the engine's signal and check it before each read and page, so a cancelled cycle stops promptly. - The authInfo snapshot kept for service-context reads is an allowlist (clientId, scopes, resource, expiresAt), so no adopter field carrying a credential reaches the durable engine store. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…ey/reporting-subscription-dx-grants Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
… chain rule after retention - A projection whose journal write fails still serves the platform's values, but now warns and reports the failure to planningErrorHandler instead of failing silently. - New engine test: a pushed re-grant inside retention continues the chain, one after retention starts a new chain, and a listing observed after retention does too. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
…y/reporting-subscription-dx-buyer-facade
A seller that rewrites a submitted field, or drops the subscription from its readback, fails with SUBSCRIPTION_READBACK_MISMATCH. Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com>
There was a problem hiding this comment.
Ladon verdict: Approve
Approve — clean delta on a subsequent review.
The prior medium finding (src/lib/principal/reporting-facade.ts:630 — verify() readback-mismatch throw path untested) has been resolved by a new facade test covering both throw branches.
The managed.ts changes are improvements: fail-closed authInfo allowlist (SNAPSHOT_AUTH_FIELDS), abort-signal propagation into platformAccounts/platformBuys with per-page throwIfAborted, and journal reporting on authorized_at projection failure. No new blocking or medium findings.
Only a Low note remains (differingPath duplicated verbatim across two files for eager-graph isolation), which is omitted from gating.
Decision table: no critical/high findings (row 1 n/a), gated_paths false (row 2 n/a), high_risk false (rows 3/5 n/a), no medium findings (rows 4/8 n/a), prior decision was approve so sticky-escalation does not apply (row 6 n/a), no no-auto-approve team match (row 7 n/a). Falls through to row 9 → approve.
The merge-base changed after approval.
T7 for #3504 (approved DX plan, section 2.7 and section 4.1): the buyer write facade and the raw
syncPrincipalguard. It stacks on #3553 (T6) → #3552 → #3551 → #3546 → #3545 → #3544 → #3543 → #3542 → #3534 and the rest of the #3504 stack. Review onlyfeat(reporting): buyer write facade and the raw syncPrincipal guard. It targetsmainbecause CI runs only for PRs intomain.API
ReportingClient(root export) is a port of the Python SDK'sReportingClient, andclient.reportingis available onAgentClientandSingleAgentClient:Merge and versioning. It reads
get_principal, replaces thissubscription_idand keeps every other entry.subscription_versionis kept when onlyactiveorreplace_account_configschange, and bumped when the selector, scope, destination,reconciliation_mode,exclude_account_idsoroperator_domainschange. A supplied version is validated.Pre-dispatch checks (
ReportingSubscriptionError,dispatched: false):{account_id}on a multi-account scope (INVALID_REQUEST);SUBSCRIPTION_ID_CLASH, fromlist_accounts;SUBSCRIPTION_OPERATOR_SCOPE_REQUIRED;SUBSCRIPTION_SELECTOR_UNMATCHED, withnearest(offering plus failed attributes), from the advertised offerings.The roster and capability checks are best effort: when the client can't read them, they are skipped.
Write. The write sends
expected_configuration_version. OnCONFLICTthe facade re-reads, re-merges and retries with a fresh key (3 attempts), then throwsSUBSCRIPTION_CONFLICT_EXHAUSTED. A transport failure retries the same key and body once. The readback is verified; a mismatch throwsSUBSCRIPTION_READBACK_MISMATCHwithreadback.Raw guard.
client.syncPrincipalwithreporting_subscriptionsorreporting_destinationsreads the principal once. It refuses, before sending, a deactivation (SUBSCRIPTION_WOULD_DEACTIVATE, including an explicitactive: false) or a revocation (DESTINATION_WOULD_REVOKE) unless allowed. Dry runs are not guarded. Neither are the lifecycle helpers, which check what they replace themselves, or storyboard runs, which test the seller. The method's TSDoc now starts "Replaces each submitted section. To add a reporting subscription, useclient.reporting.subscribe."Error class.
ReportingSubscriptionErrornow accepts a seller's wire code, or a localINVALID_REQUEST(correctable,dispatched: false), as Python's does.Deviations
SubscriptionPreviewResult. Python calls itPreviewResult, but the root already exports an unrelatedPreviewResult.ADCPMultiAgentClienthas noreporting. The fleet view (section 2.8) is T11.Tests
test/lib/reporting-subscription-facade.test.jscovers:The storyboard suite still passes, because it sends unguarded.
File budget +4 (one dual-format module). The packed-byte cap is raised to 26,610,000 (measured 26,566,153), with a comment.
Checks
npm run typecheck,lint:boundaries,check:package-size, Prettier, and 7,760 tests across reporting, principal, client, server, storyboard andpackages/reporting-storage.Refs #3504
🤖 Generated with Claude Code