( request: FastifyRequest, reply: FastifyReply, input: { userId?: string; requiredScop

(date: Date)

()

(operation: T)

(condition, message)

(table: typeof usersTable, parse: (value: unknown) => T, userId?: string)

(...parts: string[])

(tableName: string)

(path: string, parser: { parse: (value: unknown) => T }, options: RequestOptions = {})

(schema: unknown, name: string)

( table: typeof usersTable, rows: Array<{ id: string; userId?: string; createdAt?: string }>, fall

(condition, message)

()

(options: CreateApiOptions = {})

(condition, message)

(message: string)

(reply: FastifyReply, statusCode: number, error: unknown)

(value: number)

(value: number, min: number, max: number)

(name: N)

(payload: unknown)

(value: unknown)

(method, pathName, options = {})

(userId: string)

(now = new Date(), sourceOverrides: SourceOverrides = {})

(id: string, userId?: string | null)

(value: unknown)

(value: unknown)

(index: number, amplitude: number, phase = 0)

(reply: FastifyReply, userId: string)

(self, path: str, params: dict | None = None)

(value, message)

(error: unknown)

(command, args, options = {})

(value: unknown)

(value, message)

(operation: T)

(overrides)

( state: DemoState, userId: string, providerId: ProviderId, input: IngestBatchInput, now = new Date(

(id: string, prompt: string, completion: string)

(value: unknown)

(argv: string[])

( payload: { id: string; userId?: string; createdAt?: string }, fallbackUserId?: string )

(rows: T[], incoming: T[])

(input: { id: string; userId: string; sourceAccountId: string; deviceId: string | null; metricFamily

(input: { accessToken: string; path: string; context: CollectorContext; })

(id?: string)

(message)

(method, pathName, options = {})

(syncStatus: SyncStatusResponse, generatedAt = new Date())

(input: { expectedProviderId: ProviderId; manifest: ProviderManifest; collector: Collector; })

( state: DemoState, userId: string, providerId: ProviderId, now = new Date() )

(manifest: ProviderManifest)

( userId: string, sourceAccountId: string, providerId: ProviderId, sourceRecordId: string, eventType

(userId: string, now = new Date())

(providerId: ProviderId)

(error: unknown)

(value: unknown)

(value: unknown)

()

(capabilities: MetricCapabilitySeed[])

(records: IngestRecord[], record: IngestRecord)

( mode: RuntimeMode, providerId: ProviderId )

(runDir: string, run: WorkflowRun)

(self)

(source: dict)

(self, path: str, payload: dict | None = None)

(config: CollectorConfig, providerId: MobileProvider)

(value: unknown)

(deps: DerivePipelineDeps, observations: Observation[], metric: string, day: string)

(type: "year" | "month" | "day" | "hour" | "minute")

()

(source: MobileSyncStatusSource | null, now = new Date())

()

(source: SyncStatusEntry)

()

( nextState: Awaited<ReturnType<typeof store.loadState>>, options: { allowedTypes?: string[]; dryRun?:

( state: DemoState, now: Date, syncedProviderIds: ProviderId[] = [] )

(path: string, init: RequestInit = {})

( config: CollectorConfig, path: string, method: "GET" | "POST" | "PUT", body?: unknown )

(value: number)

(input: unknown)

(value, message)

(value, message)

(values: number[])

( scoreKind: Score["scoreKind"], providerId: ProviderId, value: ReturnType<typeof computeSleepCons

(sourceRecordId: string)

(source: AppleHealthSourceMetadata)

(input: StrainBalanceInput)

( mode: "demo" | "live", providerId: ProviderId, credential: ProviderCredential | null )

(config: OpenRouterConfig, fetchImpl: FetchLike = globalThis.fetch)

(workflowKind: WorkflowKind, severity: Alert["severity"])

(value: unknown)

( entries: T[], now = new Date(), precedenceOverride?: SourcePrecedenceOverride["precedence"] )

(input: { userId: string; job: Exclude<SchedulerJob, "all">; dryRun?: boolean; })

(state: DemoState, userId: string, now = new Date(), options: SyncStatusOptions = {})

(payload: unknown)

()

(value: unknown)

(record: IngestRecord)