Polecat#119: foundation re-pin + adopt lifted *ProjectionDistributor concretes + cut 4.0.0-alpha.9

[jeremydmiller]

Summary

Closes #119. Polecat#119 chip executed: deletes Polecat's three near-identical *ProjectionDistributor concretes in favour of the lifted versions now shipping in JasperFx.Events.Daemon, and lands the foundation re-pin needed to pick them up. Part of the Critter Stack 2026 dedupe pillar; follows on from PR #118 (interface-level lift, polecat#117), weasel#285 (Weasel.Core.IAdvisoryLock dedupe), and jasperfx PRs #318/#319/#320 (concrete lifts).

Three commits per chip shape: −255 / +59 across 6 files net.

Foundation matrix

Package	From	To	Note
JasperFx	2.0.0-alpha.17	2.0.0-alpha.20	Phase 1
JasperFx.Events	2.0.0-alpha.16	2.0.0-alpha.20	Phase 1 → α.19, Phase 2 → α.20 (α.19 only shipped Solo + MultiTenanted; SingleTenant was orphaned per jasperfx#322, re-landed for α.20)
JasperFx.Events.SourceGenerator	2.0.0-alpha.9	2.0.0-alpha.12	Phase 1
JasperFx.RuntimeCompiler	5.0.0-alpha.5	5.0.0-alpha.8	Phase 1, 5.x line confirmed
JasperFx.SourceGeneration	2.0.0-alpha.6	2.0.0-alpha.9	Phase 1
Weasel.SqlServer	9.0.0-alpha.6	9.0.0-alpha.7	Phase 2 (picks up weasel#284 — AdvisoryLock implements lifted JFx.Events.Daemon.IAdvisoryLock directly)
Weasel.EntityFrameworkCore	9.0.0-alpha.6	9.0.0-alpha.7	Phase 2
Polecat	4.0.0-alpha.8	4.0.0-alpha.9	Phase 3

What the dedupe replaced

ProjectionCoordinator.BuildDistributor() now constructs the lifted concretes with store-specific closures rather than instantiating Polecat-local copies:

Func<IEnumerable<ShardName>> allShards =
    () => _options.Projections.AllShards().Select(s => s.Name);

Func<IProjectionDatabase, IReadOnlyList<ShardName>, int, IProjectionSet> setFactory =
    (db, names, lockId) => new ProjectionSet(lockId, (PolecatDatabase)db, names);

var lockLogger = _loggerFactory.CreateLogger<AdvisoryLock>();
Func<IProjectionDatabase, IAdvisoryLock> lockFactory =
    db => new AdvisoryLock(
        () => new SqlConnection(((PolecatDatabase)db).ConnectionString),
        lockLogger,
        db.Identifier);

if (cardinality == DatabaseCardinality.StaticMultiple)
{
    return new MultiTenantedProjectionDistributor(
        databaseSource: () => ValueTask.FromResult<IReadOnlyList<IProjectionDatabase>>(
            _options.Tenancy?.AllDatabases().Cast<IProjectionDatabase>().ToList() ?? []),
        allShards: allShards,
        lockFactory: lockFactory,
        setFactory: setFactory,
        baseLockId: baseLockId);
}

return new SingleTenantProjectionDistributor(
    databaseAccessor: () => _options.Tenancy!.AllDatabases().Single(),
    allShards: allShards,
    lockFactory: lockFactory,
    setFactory: setFactory,
    schemaQualifier: _options.DatabaseSchemaName,
    baseLockId: baseLockId);

Files deleted (235 lines)

• src/Polecat/Events/Daemon/Coordination/SoloProjectionDistributor.cs
• src/Polecat/Events/Daemon/Coordination/SingleTenantProjectionDistributor.cs
• src/Polecat/Events/Daemon/Coordination/MultiTenantedProjectionDistributor.cs

Files retained

• src/Polecat/Events/Daemon/Coordination/ProjectionSet.cs — implements the lifted IProjectionSet with both typed PolecatDatabase Database (for distributor call sites that need the connection string) and explicit-interface IProjectionDatabase Database (per PR Polecat: adopt lifted IProjectionDistributor / IProjectionSet + align SingleTenant lock-id with Marten (#117) #118).

Behavioural tightening

The previous Polecat-local SingleTenantProjectionDistributor iterated AllDatabases() with SelectMany even in single-database tenancy — which would have happily produced sets for an unintended multi-database deployment. The lifted concrete takes a Func<IProjectionDatabase> (single, not list); the Polecat closure uses .Single() so a misconfigured deployment now surfaces with a useful exception rather than silently no-opping.

Verification

Polecat.Tests.Daemon (net10.0):   53 pass / 3 pre-existing skips / 0 fail   (matches post-PR-#118 baseline)
Polecat.AotSmoke    (net10.0):    builds + runs clean — "Polecat AOT smoke OK."
dotnet build         -c Release:   0 errors, 14 pre-existing IL warnings (unchanged)
dotnet build (full solution Debug): 0 errors

Commit shape

Three commits per chip:

1. 8c6ec85 — Polecat: re-pin to JasperFx alpha.20 / Events alpha.19 / SG alpha.12 / RC 5.0-alpha.8 / SG alpha.9 (Phase 1, foundation re-pin)
2. 7057bf0 — Polecat#119: adopt lifted *ProjectionDistributor concretes from JasperFx.Events (Phase 2 — folds the JFx.Events α19→α20 + Weasel α6→α7 unblocker bumps because they're mechanically inseparable from the concrete adoption)
3. ff7e15e — Polecat: cut 4.0.0-alpha.9 (Phase 3)

Backstory

This chip surfaced two blockers along the way, both upstream-fixed before this PR could finish:

• weasel#284 — Weasel.SqlServer.AdvisoryLock implemented a separate Weasel.Core.IAdvisoryLock, byte-identical to the lifted JFx one but not actually assignable to it. Fixed in weasel#285 (option 3 — Weasel.Core.IAdvisoryLock deleted, both providers route at the lifted JFx interface directly) and shipped in Weasel.SqlServer 9.0.0-alpha.7.
• jasperfx#322 — SingleTenantProjectionDistributor was missing from JasperFx.Events α.19 because PR #320 had merged into a deleted feature branch instead of main. Re-landed for α.20.

Both blockers are linked from the test plan boxes below so the cross-repo dependency chain is auditable.

Test plan

• weasel#284 closed by weasel#285 — Weasel.SqlServer.AdvisoryLock implements lifted JFx.Events.Daemon.IAdvisoryLock (shipped in Weasel.SqlServer 9.0.0-alpha.7)
• jasperfx#322 re-landed — SingleTenantProjectionDistributor shipped in JasperFx.Events 2.0.0-alpha.20
• CI green on feature/119-lift-distributor-concretes
• No regression in async daemon hot-cold lease handover (async_daemon_tests)
• No regression in multi-tenant daemon lock-per-database semantics (multi_tenant_daemon_tests)
• Polecat.AotSmoke still builds + runs

Per Polecat#46 master plan.

🤖 Generated with Claude Code