fix(sync): project a create at the calendar's active generation

packages/sync/src/app.ts

@@ -407,7 +407,15 @@ function buildSchedulers(
     {
       sweep: async (before) => {
         const enqueued = await reconcileStaleCalendars(
-          { resources, jobs },
+          {
+            resources,
+            jobs,
+            onEnqueueError: (error, resourceId) =>
+              logger.error(
+                `Sync reconcile sweep could not enqueue resource ${resourceId}; skipping it and continuing`,
+                error,
+              ),
+          },
           before,
           () => new Date(),
         );
@@ -431,7 +439,15 @@ function buildSchedulers(
     {
       sweep: (before) =>
         maintainExpiringSubscriptions(
-          { resources, jobs },
+          {
+            resources,
+            jobs,
+            onEnqueueError: (error, resourceId) =>
+              logger.error(
+                `Sync subscription sweep could not enqueue resource ${resourceId}; skipping it and continuing`,
+                error,
+              ),
+          },
           before,
           () => new Date(),
         ),
@@ -497,6 +513,7 @@ function buildSchedulers(
             events: repos.events,
             calendars: repos.calendars,
             occurrences: repos.eventOccurrences,
+            resources: repos.syncResources,
             markers: repos.deletionMarkers,
             execution: config.EXECUTION,
             provider: {

packages/sync/src/domain/cloud-command.service.db.test.ts

@@ -28,6 +28,7 @@ import { DeletionMarkerRepository } from "@sync/storage/repositories/deletion-ma
 import { EventRepository } from "@sync/storage/repositories/event.repository";
 import { EventOccurrenceRepository } from "@sync/storage/repositories/event-occurrence.repository";
 import { ProviderCalendarRepository } from "@sync/storage/repositories/provider-calendar.repository";
+import { SyncResourceRepository } from "@sync/storage/repositories/sync-resource.repository";
 import { type SyncMongoService } from "@sync/storage/sync-mongo.service";
 import { beforeEach, describe, expect, it, spyOn } from "bun:test";
 
@@ -120,6 +121,7 @@ describe("submitCloudCommand provider dispatch", () => {
   let commands: CommandRepository;
   let events: EventRepository;
   let occurrences: EventOccurrenceRepository;
+  let resources: SyncResourceRepository;
   let calendars: ProviderCalendarRepository;
   let markers: DeletionMarkerRepository;
 
@@ -181,6 +183,7 @@ describe("submitCloudCommand provider dispatch", () => {
     commands = new CommandRepository(mongo.db);
     events = new EventRepository(mongo.db);
     occurrences = new EventOccurrenceRepository(mongo.db, mongo.client);
+    resources = new SyncResourceRepository(mongo.db);
     calendars = new ProviderCalendarRepository(mongo.db);
     markers = new DeletionMarkerRepository(mongo.db);
   });
@@ -197,6 +200,7 @@ describe("submitCloudCommand provider dispatch", () => {
         events,
         calendars,
         occurrences,
+        resources,
         markers,
         execution: "active",
         provider: provider(writer),
@@ -224,6 +228,7 @@ describe("submitCloudCommand provider dispatch", () => {
         events,
         calendars,
         occurrences,
+        resources,
         markers,
         execution: "passive",
         provider: provider(writer),
@@ -247,6 +252,7 @@ describe("submitCloudCommand provider dispatch", () => {
         events,
         calendars,
         occurrences,
+        resources,
         markers,
         execution: "active",
       },
@@ -268,6 +274,7 @@ describe("submitCloudCommand provider dispatch", () => {
         events,
         calendars,
         occurrences,
+        resources,
         markers,
         execution: "active",
         provider: provider(writer),
@@ -306,6 +313,7 @@ describe("submitCloudCommand provider dispatch", () => {
         events,
         calendars,
         occurrences,
+        resources,
         markers,
         execution: "active",
       },
@@ -335,6 +343,7 @@ describe("submitCloudCommand provider dispatch", () => {
         events,
         calendars,
         occurrences,
+        resources,
         markers,
         execution: "active",
       },
@@ -415,6 +424,7 @@ describe("submitCloudCommand provider dispatch", () => {
     events,
     calendars,
     occurrences,
+    resources,
     markers,
     execution: "passive" as const,
   });
@@ -464,6 +474,7 @@ describe("submitCloudCommand provider dispatch", () => {
         events,
         calendars,
         occurrences,
+        resources,
         markers,
         execution: "active",
         provider: provider(writer),
@@ -522,6 +533,7 @@ describe("submitCloudCommand provider dispatch", () => {
         events,
         calendars,
         occurrences,
+        resources,
         markers,
         execution: "active",
         provider: provider(writer),
@@ -564,6 +576,7 @@ describe("submitCloudCommand provider dispatch", () => {
         events,
         calendars,
         occurrences,
+        resources,
         markers,
         execution: "active",
         provider: provider(writer),
@@ -598,6 +611,7 @@ describe("submitCloudCommand provider dispatch", () => {
         events,
         calendars,
         occurrences,
+        resources,
         markers,
         execution: "active",
         provider: provider(writer),
@@ -687,6 +701,7 @@ describe("submitCloudCommand provider dispatch", () => {
         events,
         calendars,
         occurrences,
+        resources,
         markers,
         execution: "active",
         provider: provider(writer),
@@ -744,6 +759,7 @@ describe("submitCloudCommand provider dispatch", () => {
         events,
         calendars,
         occurrences,
+        resources,
         markers,
         execution: "active",
         provider: provider(writer),

packages/sync/src/domain/cloud-command.service.ts

@@ -44,6 +44,7 @@ import { type DeletionMarkerRepository } from "@sync/storage/repositories/deleti
 import { type EventRepository } from "@sync/storage/repositories/event.repository";
 import { type EventOccurrenceRepository } from "@sync/storage/repositories/event-occurrence.repository";
 import { type ProviderCalendarRepository } from "@sync/storage/repositories/provider-calendar.repository";
+import { type SyncResourceRepository } from "@sync/storage/repositories/sync-resource.repository";
 
 // A provider-targeted write arrived while provider work is unavailable
 // (execution is passive, or no provider is configured). Nothing re-dispatches a
@@ -67,6 +68,9 @@ export interface CloudCommandDeps {
   // The derived occurrence projection, rebuilt for an event's horizon whenever
   // a cloud command changes it so range queries stay current.
   occurrences: EventOccurrenceRepository;
+  // Which generation reads serve per calendar, so a provider-linked create
+  // projects where reads will look for it.
+  resources: SyncResourceRepository;
   // The deletion-marker store, for the tombstone a provider delete leaves.
   markers: DeletionMarkerRepository;
   execution: SyncExecutionMode;
@@ -146,6 +150,7 @@ export async function submitCloudCommand(
             commands: deps.commands,
             events: deps.events,
             occurrences: deps.occurrences,
+            resources: deps.resources,
             writer: deps.provider.writer,
             custody: deps.provider.custody,
           },
@@ -339,6 +344,7 @@ async function applyCloudMutation(
             commands: deps.commands,
             events: deps.events,
             occurrences: deps.occurrences,
+            resources: deps.resources,
             writer: deps.provider.writer,
             custody: deps.provider.custody,
           },
@@ -386,6 +392,7 @@ async function dispatchProviderDelete(
       commands: deps.commands,
       events: deps.events,
       occurrences: deps.occurrences,
+      resources: deps.resources,
       writer: deps.provider.writer,
       custody: deps.provider.custody,
       markers: deps.markers,
@@ -421,6 +428,7 @@ async function dispatchProviderSeriesUpdate(
       commands: deps.commands,
       events: deps.events,
       occurrences: deps.occurrences,
+      resources: deps.resources,
       writer: deps.provider.writer,
       custody: deps.provider.custody,
     },
@@ -458,6 +466,7 @@ async function dispatchProviderOccurrenceDelete(
       commands: deps.commands,
       events: deps.events,
       occurrences: deps.occurrences,
+      resources: deps.resources,
       writer: deps.provider.writer,
       custody: deps.provider.custody,
     },
@@ -488,6 +497,7 @@ async function dispatchProviderOccurrenceUpdate(
       commands: deps.commands,
       events: deps.events,
       occurrences: deps.occurrences,
+      resources: deps.resources,
       writer: deps.provider.writer,
       custody: deps.provider.custody,
     },
@@ -518,6 +528,7 @@ async function dispatchProviderSeriesFollowingDelete(
       commands: deps.commands,
       events: deps.events,
       occurrences: deps.occurrences,
+      resources: deps.resources,
       writer: deps.provider.writer,
       custody: deps.provider.custody,
       markers: deps.markers,
@@ -549,6 +560,7 @@ async function dispatchProviderSeriesFollowingUpdate(
       commands: deps.commands,
       events: deps.events,
       occurrences: deps.occurrences,
+      resources: deps.resources,
       writer: deps.provider.writer,
       custody: deps.provider.custody,
     },

packages/sync/src/domain/failed-job-requeue.service.db.test.ts

@@ -102,4 +102,30 @@ describe("requeueFailedJobs", () => {
       exhaustedJobs: [],
     });
   });
+
+  it("requeues a job written before requeuedCount existed", async () => {
+    // Mongo's {$lt: n} does not match a missing field, so the self-heal sweep
+    // could not see the very jobs most likely to be wedged: the ones old
+    // enough to predate its own bookkeeping field. Three such jobs sat failed
+    // in prod while this sweep reported nothing to do (2026-07-31).
+    const id = await seedFailed({
+      runAfter: new Date("2026-07-20T10:00:00.000Z"),
+    });
+    await storage
+      .db()
+      .collection("jobs")
+      .updateOne({ _id: id as never }, { $unset: { requeuedCount: "" } });
+
+    const result = await requeueFailedJobs(deps(), cooldownBefore, now, 3);
+
+    expect(result.requeued).toBe(1);
+    expect(result.exhausted).toBe(0);
+    const raw = await storage
+      .db()
+      .collection("jobs")
+      .findOne({ _id: id as never });
+    expect(raw?.state).toBe("pending");
+    // Absence counted as zero, so the requeue is its first, not its last.
+    expect(raw?.requeuedCount).toBe(1);
+  });
 });