feat: replace EventSourced::Services with Jobs and wire atomic enqueue

[0xgleb]

Motivation

The crash-safety gap ADR-0001 exists to close: with type Services, handlers run
side effects before events persist, so a crash between the two orphans the
action. This change makes handlers pure and wires job enqueue into the same
transaction that commits events.

Solution

• EventSourced: drop type Services, add type Jobs: JobList;
  initialize/transition become sync and take &mut JobQueue<Self::Jobs>; the
  trait sheds #[async_trait]. Service reads (clock, config) move into the
  Command.
• Atomic enqueue without threading a transaction through cqrs-es:
  Store::send/send_command run the handler inside a with_pending_jobs
  task-local scope; the Lifecycle handler buffers its JobQueue via
  buffer_pending; SqliteEventRepository drains it with flush_pending_jobs
  inside the event-commit transaction.
• Jobs buffered with no active scope are dropped with a warning rather than
  silently lost; JobList: Send so the queue threads through the Send command
  future.
• Drops the services parameter from send_command, test_store,
  TestHarness::with, TestStore::new/with_reactor, StoreBuilder::build,
  and sqlite_snapshot_cqrs; Lifecycle::Services collapses to ().
• Test: a command enqueues its job atomically with its events (event row +
  Pending job row written together).

Closes RAI-918.

[coderabbitai]

Warning

Review limit reached

@0xgleb, we couldn't start this review because you've reached your PR review rate limit.

More reviews will be available in 18 minutes and 37 seconds. Learn how PR review limits work.

Your organization has run out of usage credits. Purchase more credits in the billing tab to continue.

⌛ How to resolve this issue?

After more reviews become available, a review can be triggered using the @coderabbitai review command as a PR comment. Alternatively, push new commits to this PR.

We recommend that you space out your commits to avoid hitting the rate limit.

🚦 How do rate limits work?

CodeRabbit enforces hourly rate limits for each developer per organization.

Our paid plans include higher PR review limits than trial, open-source, and free plans. In all cases, reviews become available again over time. During sustained high-volume PR review activity, CodeRabbit may temporarily slow when the next review becomes available.

Please see our Fair Usage Limits Policy for further information.

ℹ️ Review info

⚙️ Run configuration

Configuration used: Path: .coderabbit.yaml

Review profile: ASSERTIVE

Plan: Pro

Run ID: ad98cc83-0e59-4ccb-8316-304b76da1cc6

📥 Commits

Reviewing files that changed from the base of the PR and between d162898 and b77e4d4.

📒 Files selected for processing (17)

• crates/event-sorcery/src/dependency.rs
• crates/event-sorcery/src/job.rs
• crates/event-sorcery/src/lib.rs
• crates/event-sorcery/src/lifecycle.rs
• crates/event-sorcery/src/projection.rs
• crates/event-sorcery/src/schema_registry.rs
• crates/event-sorcery/src/sqlite_event_repository.rs
• crates/event-sorcery/src/testing.rs
• crates/event-sorcery/src/wire.rs
• examples/README.md
• examples/complex/src/audit_log.rs
• examples/complex/src/inventory.rs
• examples/complex/src/main.rs
• examples/complex/src/order.rs
• examples/simple/README.md
• examples/simple/src/main.rs
• examples/simple/src/support_ticket.rs

✨ Finishing Touches

🧪 Generate unit tests (beta)

• Create PR with unit tests
• Commit unit tests in branch feat/jobs-eventsourced-reshape

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands and usage tips.}

[0xgleb]

Warning

This pull request is not mergeable via GitHub because a downstack PR is open. Once all requirements are satisfied, merge this PR as a stack on Graphite.
Learn more

• adr: gradual consumer migration from services to jobs #19
• docs: migrate docs to the jobs model #20
• feat: migrate examples to the jobs model #16
• feat: replace EventSourced::Services with Jobs and wire atomic enqueue #15 👈 (View in Graphite)
• feat: add buffered JobQueue and apalis enqueue #14
• feat: add build_supervised_worker macro #13
• feat: job worker #12
• feat: add job module #11
• adr: jobs replace services #8
• fix: sink events as they happen #24 : 1 other dependent PR (#25 )
• master

---

How to use the Graphite Merge Queue

Add the label add-to-gt-merge-queue to this PR to add it to the merge queue.

You must have a Graphite account in order to use the merge queue. Sign up using this link.

An organization admin has required the Graphite Merge Queue in this repository.

Please do not merge from GitHub as this will restart CI on PRs being processed by the merge queue.

This stack of pull requests is managed by Graphite. Learn more about stacking.

[linear-code]

RAI-918

[findolor]

Approved.