Repository navigation

Add the CQRS query cache, messaging brokers, webhooks and callbacks, and harden the resilience store - #16

Merged

ancongui merged 49 commits into

mainfrom

feat/ports-parity

Oct 13, 2026

Merged

Add the CQRS query cache, messaging brokers, webhooks and callbacks, and harden the resilience store#16
ancongui merged 49 commits into
mainfrom
feat/ports-parity

Commits on Oct 13, 2026
- feat(cqrs): compile #[CachedQuery] and #[InvalidatesQuery] into the handler manifest and derive cache keys from query value objects
  Andres Contreras
  committed
  e5c161e
- fix(cqrs): refuse to key queries with non-public state and validate #[InvalidatesQuery] with maps at scan time
  Andres Contreras
  committed
  d045be2
- fix(cqrs): refuse an #[InvalidatesQuery] key template on a query that is keyed by value
  Andres Contreras
  committed
  19227f5
- fix(cqrs): refuse #[CachedQuery] on a value-keyed query with non-public state and never key a Traversable by its empty view
  Andres Contreras
  committed
  6f2f262
- test(cqrs): type the Traversable collection fixture so PHPStan max passes on the query cache key tests
  Andres Contreras
  committed
  7a7ebe7
- feat(cqrs): a Laravel-cache query cache with generation-based group eviction that never fails a query
  Andres Contreras
  committed
  913ee85
- fix(cqrs): drop a query cache store that lands after its group's eviction instead of caching the stale result
  Andres Contreras
  committed
  c08e43a
- fix(cqrs): bound a no-TTL query cache entry by its generation TTL so evicted groups leave no forever orphans
  Andres Contreras
  committed
  e64e3fa
- feat(cqrs): cache #[CachedQuery] results with per-query TTLs behind firefly.cqrs.query.cache.provider
  Andres Contreras
  committed
  a46fd68
- docs(config): document firefly.cqrs.query.cache provider, store and prefix in the skeleton
  Andres Contreras
  committed
  6cd92a1
- feat(cqrs): evict cached queries on committed domain events and on EDA envelopes via #[InvalidatesQuery]
  Andres Contreras
  committed
  21b8e0b
- docs(config): document firefly.cqrs.query.cache.invalidation in the skeleton
  Andres Contreras
  committed
  67642f8
- fix(cqrs): evict the group when an EDA envelope cannot rebuild a typed with-map query key
  Andres Contreras
  committed
  18b146f
- fix(resilience): select the store with firefly.resilience.store.provider and refuse to boot on a cache store without atomic locks
  Andres Contreras
  committed
  02c0d9a
- docs(config): document firefly.resilience.store provider and allow-lockless in the skeleton and the resilience module
  Andres Contreras
  committed
  695c9f1
- feat(actuator): opt-in health indicators for cache stores, queue connections and Redis
  Andres Contreras
  committed
  b0dbf15
- docs(config): document the cache, queue and redis health indicator keys in the skeleton and the actuator module
  Andres Contreras
  committed
  d99a034
- fix(config): wire the cache, queue and redis health gates to their FIREFLY_HEALTH_*_ENABLED variables in the skeleton
  Andres Contreras
  committed
  1e2ee76
- feat(messaging): a listener container contract with retry and back-off policies, and firefly:messaging:consume
  Andres Contreras
  committed
  d76e4c9
- docs(config): document firefly.messaging.listener.retry and firefly:messaging:consume in the skeleton and the messaging module
  Andres Contreras
  committed
  c34acae
- feat(eda-kafka): a Kafka listener container for firefly/messaging with retries, back-off and dead-letter topics
  Andres Contreras
  committed
  683d8af
- docs(config): document firefly.messaging.kafka and firefly.messaging.listener.dead-letter.enabled in the skeleton
  Andres Contreras
  committed
  74acc43
- fix(eda-kafka): fail a Kafka flush on a failed delivery report and round-robin poll() across consumer groups
  Andres Contreras
  committed
  13addbb
- test(eda-kafka): prove the messaging listener container against a real Kafka, dead-letter topic included
  Andres Contreras
  committed
  2caa970
- feat(eda-rabbitmq): a RabbitMQ listener container for firefly/messaging with retries, back-off and a dead-letter exchange
  Andres Contreras
  committed
  b06db57
- docs(config): document firefly.messaging.rabbitmq exchange, dead-letter-exchange and prefetch in the skeleton
  Andres Contreras
  committed
  c390521
- test(admin): opt the paged conditions harness into the default-off health indicators so its backed-off panel holds only the seeded rows
  Andres Contreras
  committed
  4fee709
- fix(eda-rabbitmq): declare and bind a parking queue for every listener dead-letter topic so the direct exchange never drops a dead letter as unroutable
  Andres Contreras
  committed
  1d08116
- test(eda-rabbitmq): prove the messaging listener container against a real RabbitMQ, dead-letter exchange included
  Andres Contreras
  committed
  bb7deb5
- feat(webhooks): register the firefly/webhooks package with validated provider settings behind firefly.webhooks.enabled
  Andres Contreras
  committed
  4606443
- feat(webhooks): HMAC, Stripe, GitHub, Twilio and NoOp signature validators with a replay window
  Andres Contreras
  committed
  abcf364
- fix(webhooks): choose the Twilio signed string by the URL, so a replayed JSON signature cannot carry a forged body
  Andres Contreras
  committed
  1b627d3
- fix(webhooks): parse Twilio form parameters from the raw signed body, so TrimStrings and ConvertEmptyStringsToNull cannot break the signature
  Andres Contreras
  committed
  26ee8fe
- feat(webhooks): atomic idempotency stores on memory, the cache or a portable receipts table proven on every database
  Andres Contreras
  committed
  8c061a8
- feat(webhooks): an endpoint per provider that verifies, deduplicates and publishes webhooks to the event bus, refusing with problem+json
  Andres Contreras
  committed
  64ccb8b
- feat(callbacks): register the firefly/callbacks package with a subscription registry on memory or any database
  Andres Contreras
  committed
  b3357b0
- fix(callbacks): refuse at boot a seeded subscription id wider than the 36-character id columns
  Andres Contreras
  committed
  478327a
- feat(callbacks): an execution log of every delivery on memory or any database, one row per subscription and event
  Andres Contreras
  committed
  2064bb2
- feat(callbacks): deliver events to subscriptions as signed POSTs with retries, back-off and a circuit breaker per endpoint
  Andres Contreras
  committed
  162afe3
- fix(callbacks): dispatch each event once when firefly.callbacks.event-types patterns overlap
  Andres Contreras
  committed
  eff3e9a
- feat(callbacks): firefly:callbacks:list and firefly:callbacks:replay over the execution log
  Andres Contreras
  committed
  d8c8901
- docs: document the W4 ports — query cache, messaging brokers, resilience store, health indicators, webhooks and callbacks
  Andres Contreras
  committed
  759cea4
- fix(lumen): boot EdaConsumerServiceProvider in the Postgres outbox harness so firefly:eda:consume exists
  Andres Contreras
  committed
  509b11e
- fix(callbacks): refuse delivery to an inactive subscription in the deliverer, so replay no longer reaches a deactivated endpoint without --include-inactive
  Andres Contreras
  committed
  8f2109b
- fix(callbacks): deliver and replay to the subscription's current URL and run the destination refusal on it, recording a changed endpoint
  Andres Contreras
  committed
  67d3ff5
- docs(callbacks): document that replay refuses inactive subscriptions without --include-inactive and sends to the current URL
  Andres Contreras
  committed
  af31188
- Merge origin/main (W1: eda-database, scheduling-database, IntegrationDsn, integration lanes) into feat/ports-parity
  Andres Contreras
  committed
  91e47ea
- Merge origin/main (W2: orchestration, SQL Server LOCK_TIMEOUT hygiene) into feat/ports-parity
  Andres Contreras
  committed
  7642631
- docs(publishing): count the 35 component names the root package replaces
  Andres Contreras
  committed
  1578f12

Commits

Commits on Oct 13, 2026