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

(method, params = {}, timeoutMs = 10_000)

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

( state: DemoState, userId: string, payloads: Partial<Record<ProviderId, NormalizedPayload>>, now = ne

(syncStatus: Awaited<ReturnType<OpenVitalsClient["syncStatus"]>>)

(context: CollectorContext)

()

(relativePath: string, content: string)

(value, message)

(dayStart: Date, minutes: number)

(values: number[])

(input: AppleHealthIngestRecordInput)

(input: { userId?: string; name?: string; timezone?: string; providerIds?: ProviderId[]; now?: Date;

( currentState: Awaited<ReturnType<typeof store.loadState>>, userId: string, providerId: string |

(user: User)

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

(config: CollectorConfig)

(dbPath: string)

(mode: RuntimeMode)

(user: User, now: Date)

(user: User, now: Date)

(args: string[])

(state: DemoState, entity: string, id: string)

(input: { accessToken: string; path: string; mode: "history" | "incremental"; lastAnchor: string | nul

( deps: DerivePipelineDeps, episodes: Episode[], episodeType: Episode["episodeType"], day: string )

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

(metadata: ReturnType<typeof summarizeSyncMetadata>)

(providerId: ProviderId)

(model: OpenRouterModel)

(date: Date, timezone: string)

(input: { context: CollectorContext; credential: ProviderCredential; })

(input: { context: CollectorContext; credential: ProviderCredential; mode: "history" | "incremental"; })

(date: Date, timezone: string)

(input: { user: User; providerId: ProviderId; sourceAccount: SourceAccount; records: IngestRecord[];

(env: NodeJS.ProcessEnv = process.env)

()

(value: number)

(providerId: ProviderId)

(credential: { providerId: ProviderCredential["providerId"]; authState: ProviderCredential["authState"];

( models: OpenRouterModel[], options: Pick<SelectCheapestModelOptions, "allowFree"> = {} )

()

(input: unknown)

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

( eventType: string, policy: { staleGate: boolean; inQuietHours: boolean; } )

(value: unknown)

(value: unknown)

(context: CollectorContext)

(records: IngestInput["records"])

(run: WorkflowRun)

()

(runDir: string, run: WorkflowRun)

(source: dict)

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

(value: float | int)

(alertId: string)

(seconds: number)

(seconds: number)

(items: typeof recent)

( providerId: ProviderId, sourceStatus: "connected" | "stale" | "errored", credential: ProviderCredentia

(values: number[])

(value: string | undefined, fallback: boolean)

(input: { dataGranularity: AppleHealthDataGranularity; latencyClass: AppleHealthLatencyClass; connection

(state: Awaited<ReturnType<typeof store.loadState>>)

(input: { userId: string; sessionId: string; state: string; })

( source: ProviderId, sourceRecordId: string, timezone: string, originalType: string, unit: string,

(state: Awaited<ReturnType<typeof store.loadState>>, userId: string, now = nowForApi())

(input: { userId: string; sessionId: string; state: string; })

(entry: Observation)

(mode: RuntimeMode)

(input: { currentState: Awaited<ReturnType<typeof store.loadState>>; session: z.infer<typeof Connector

(input: { currentState: Awaited<ReturnType<typeof store.loadState>>; session: z.infer<typeof Connector

(input: CircadianDisruptionInput)

(input: RecoveryReadinessInput)

(input: SleepConsistencyInput)

(providerId: ProviderId)

(method: ConnectionMethod)

(override?: SourcePrecedenceOverride["precedence"])

(user: User, sourceAccounts: SourceAccount[], now = new Date())

({ user, sourceAccount, device, now }: PayloadInput)

(value: string)

(input: { userId: string; sourceRecordId: string; metricFamily: MetricFamily; startAt: string; endAt

( state: Awaited<ReturnType<typeof store.loadState>>, userId: string, now = new Date() )

( user: User, sourceAccounts: SourceAccount[], scores: Score[], dailySummaries: DemoState["dailySummar

(user: User, policies: AgentAccessPolicy[], alerts: Alert[], now: Date)

(user: User, alerts: Alert[], automations: Automation[], now: Date)

(context: DerivedContext)

(user: User, scores: Score[], now: Date)

(user: User, alerts: Alert[], scores: Score[], now: Date)

(user: User, scores: Score[], now: Date)

(context: DerivedContext)

(user: User, now: Date)

(user: User, sourceAccounts: SourceAccount[])

(source: SyncStatusEntry)

()

()

()

()

(value: string)

(sessionId: string)

(entity: string, id: string)