ReadonlyconfigReadonlyserviceStable, human-readable name for the service. Must be set explicitly on each subclass
because this.constructor.name gets mangled by minification in production builds,
which breaks tracing/observability span names.
ProtectedloggerOptionalchartReviewJobs?: {OptionaldrainProxyPdfs?: booleanSet only by the manual "Sync Episode" action (SyncEpisodeService, run inline so never keyed). No longer
consulted for proxy integrations: their PDF fetch chain always hands the episode to the submit drain, which
works through the whole episode whether the sync was manual or hourly.
Optionalmanual?: { createdBy: UserId; templateIds: AuditTemplateId[] }Present when the run is UI-initiated (Sync & Run). Routes to the manual enqueue pipeline.
OptionalreadWholeEpisode?: booleanSet by the manual "Sync Episode" action and the episode-linking backfill: the proxy reads every document of the episode instead of only those changed since the newest stored one. Keyed apart from the hourly sync of the same episode so neither dedupes the other away.
ProtectedderiveDerive the queue retentionSeconds from the effective dedup TTL. The queue overloads
retentionSeconds — it's BOTH the message lifetime AND the idempotency dedup window
(min(retentionSeconds, 24h)). So:
ttlHours·3600), capped at 24h (the window can't exceed it);delaySeconds + every retry),
else a short TTL would expire the message mid-retry — and the queue hard-rejects
delaySeconds > retentionSeconds.
ttlHours <= 0 means "no dedup" → undefined: the idempotency key is dropped (see
performLater), so there's no dedup window to bound — this just leaves the queue's default
message lifetime in place.Extract an entityId from params for job_executions tracking. Override in subclasses when applicable.
OptionalchartReviewJobs?: {OptionaldrainProxyPdfs?: booleanSet only by the manual "Sync Episode" action (SyncEpisodeService, run inline so never keyed). No longer
consulted for proxy integrations: their PDF fetch chain always hands the episode to the submit drain, which
works through the whole episode whether the sync was manual or hourly.
Optionalmanual?: { createdBy: UserId; templateIds: AuditTemplateId[] }Present when the run is UI-initiated (Sync & Run). Routes to the manual enqueue pipeline.
OptionalreadWholeEpisode?: booleanSet by the manual "Sync Episode" action and the episode-linking backfill: the proxy reads every document of the episode instead of only those changed since the newest stored one. Keyed apart from the hourly sync of the same episode so neither dedupes the other away.
NEW key format (deliberately ≠ v1's patient_{id}sync…). The :scheduled token mirrors
v1: a pending scheduled review must force a fresh doc sync even when a non-scheduled
sync ran inside the TTL window. Manual runs return null so they aren't deduped against
an in-flight triggered sync for the same episode (the manual templateIds would be dropped).
OptionalchartReviewJobs?: {OptionaldrainProxyPdfs?: booleanSet only by the manual "Sync Episode" action (SyncEpisodeService, run inline so never keyed). No longer
consulted for proxy integrations: their PDF fetch chain always hands the episode to the submit drain, which
works through the whole episode whether the sync was manual or hourly.
Optionalmanual?: { createdBy: UserId; templateIds: AuditTemplateId[] }Present when the run is UI-initiated (Sync & Run). Routes to the manual enqueue pipeline.
OptionalreadWholeEpisode?: booleanSet by the manual "Sync Episode" action and the episode-linking backfill: the proxy reads every document of the episode instead of only those changed since the newest stored one. Keyed apart from the hourly sync of the same episode so neither dedupes the other away.
OptionalchartReviewJobs?: {OptionaldrainProxyPdfs?: booleanSet only by the manual "Sync Episode" action (SyncEpisodeService, run inline so never keyed). No longer
consulted for proxy integrations: their PDF fetch chain always hands the episode to the submit drain, which
works through the whole episode whether the sync was manual or hourly.
Optionalmanual?: { createdBy: UserId; templateIds: AuditTemplateId[] }Present when the run is UI-initiated (Sync & Run). Routes to the manual enqueue pipeline.
OptionalreadWholeEpisode?: booleanSet by the manual "Sync Episode" action and the episode-linking backfill: the proxy reads every document of the episode instead of only those changed since the newest stored one. Keyed apart from the hourly sync of the same episode so neither dedupes the other away.
Enqueue this job for async processing via the configured queue driver (VQS_DRIVER).
Checks for deduplication via job_executions before sending.
OptionalchartReviewJobs?: {OptionaldrainProxyPdfs?: booleanSet only by the manual "Sync Episode" action (SyncEpisodeService, run inline so never keyed). No longer
consulted for proxy integrations: their PDF fetch chain always hands the episode to the submit drain, which
works through the whole episode whether the sync was manual or hourly.
Optionalmanual?: { createdBy: UserId; templateIds: AuditTemplateId[] }Present when the run is UI-initiated (Sync & Run). Routes to the manual enqueue pipeline.
OptionalreadWholeEpisode?: booleanSet by the manual "Sync Episode" action and the episode-linking backfill: the proxy reads every document of the episode instead of only those changed since the newest stored one. Keyed apart from the hourly sync of the same episode so neither dedupes the other away.
Optionaloptions: PerformLaterOptionsOptionalchartReviewJobs?: {OptionaldrainProxyPdfs?: booleanSet only by the manual "Sync Episode" action (SyncEpisodeService, run inline so never keyed). No longer
consulted for proxy integrations: their PDF fetch chain always hands the episode to the submit drain, which
works through the whole episode whether the sync was manual or hourly.
Optionalmanual?: { createdBy: UserId; templateIds: AuditTemplateId[] }Present when the run is UI-initiated (Sync & Run). Routes to the manual enqueue pipeline.
OptionalreadWholeEpisode?: booleanSet by the manual "Sync Episode" action and the episode-linking backfill: the proxy reads every document of the episode instead of only those changed since the newest stored one. Keyed apart from the hourly sync of the same episode so neither dedupes the other away.
Run the job with status tracking. Used by the queue handler. Errors propagate (not caught by safe()) so the RetryHandler can decide.
parentSpanContext (the enqueuer's span, recovered from the queue envelope) is attached
as a span LINK and the run span is started as a new trace root, so each job runs in its
own trace rather than collapsing a fan-out into one unbounded trace.
OptionalchartReviewJobs?: {OptionaldrainProxyPdfs?: booleanSet only by the manual "Sync Episode" action (SyncEpisodeService, run inline so never keyed). No longer
consulted for proxy integrations: their PDF fetch chain always hands the episode to the submit drain, which
works through the whole episode whether the sync was manual or hourly.
Optionalmanual?: { createdBy: UserId; templateIds: AuditTemplateId[] }Present when the run is UI-initiated (Sync & Run). Routes to the manual enqueue pipeline.
OptionalreadWholeEpisode?: booleanSet by the manual "Sync Episode" action and the episode-linking backfill: the proxy reads every document of the episode instead of only those changed since the newest stored one. Keyed apart from the hourly sync of the same episode so neither dedupes the other away.
OptionalparentSpanContext: SpanContextProtectedspanOptional hook for subclasses to attach extra non-PII span attributes derived from params.
The returned attributes appear on the service.${serviceName} span (and, for jobs,
on job.enqueue.* and job.run.* spans too).
Safe ID-like keys on params (e.g. patientId, templateIds, limit, cursor) are
already auto-extracted via toSpanAttributes("service.input", params) — you don't need
to enumerate them here. Use this hook for derived/computed attributes (counts, flags,
computed names) or for fields you've explicitly verified safe but that aren't in the
global allowlist. Hook output overrides auto-extracted attributes on key collision.
Safe by default: returns {} when not overridden. Only declare keys you've confirmed
are non-PII. Never include emails, names, dob, free-text, etc.
OptionalchartReviewJobs?: {OptionaldrainProxyPdfs?: booleanSet only by the manual "Sync Episode" action (SyncEpisodeService, run inline so never keyed). No longer
consulted for proxy integrations: their PDF fetch chain always hands the episode to the submit drain, which
works through the whole episode whether the sync was manual or hourly.
Optionalmanual?: { createdBy: UserId; templateIds: AuditTemplateId[] }Present when the run is UI-initiated (Sync & Run). Routes to the manual enqueue pipeline.
OptionalreadWholeEpisode?: booleanSet by the manual "Sync Episode" action and the episode-linking backfill: the proxy reads every document of the episode instead of only those changed since the newest stored one. Keyed apart from the hourly sync of the same episode so neither dedupes the other away.
ProtectedspanOptional hook for subclasses to attach extra non-PII span attributes derived from the
successful service result. Only called when run resolves successfully; on error, the
span is marked via markSpanError instead.
Safe by default: returns {} when not overridden. Only declare keys you've confirmed
are non-PII (e.g. counts, status flags, computed summaries). Never include emails,
names, dob, free-text, etc.
Per-episode EMR sync (episode-first port of v1 sync-patient): episode-scoped sync, treatment_episodes dual-write (both models maintained during the transition window), documents when reviews are pending, then the chart reviews — docs always precede reviews. Routes to the manual enqueue pipeline when
manualis set, otherwise to the triggered pipeline. Returns theauditRunIdsfrom whichever enqueue ran.