import type { IncomingMessage, Server, ServerResponse } from "node:http"; import type { ContinuationOriginContextReference, DurableContinuationRecord } from "./continuation-store.js"; import { type ResolvedOriginContext } from "./continuation-service-types.js"; import { type ContinuationLimits, type ContinuationStatusSnapshot, type ContinuationSynthesisInput, type NamedContinuationRoute } from "./continuations.js"; export declare function continuationOperatorToken(secret: Uint8Array): string; export interface ParsedClaim { readonly taskKey: string; readonly taskHash: string; readonly deadline: string; } export declare function parseClaim(body: unknown, now: Date, maxDeadlineMs: number): ParsedClaim; export declare function statusOf(record: DurableContinuationRecord | undefined): ContinuationStatusSnapshot | undefined; export declare function statusOfRequired(record: DurableContinuationRecord): ContinuationStatusSnapshot; export declare function requireRecord(records: Map, id: string): DurableContinuationRecord; export declare function synthesisInput(record: DurableContinuationRecord, originContext: Extract): ContinuationSynthesisInput; export declare function originContextBindingMac(secret: Uint8Array, record: DurableContinuationRecord, reference: ContinuationOriginContextReference): string; export declare function requireLease(record: DurableContinuationRecord, owner: string): void; export declare function clearLease(record: DurableContinuationRecord): void; export declare function expire(record: DurableContinuationRecord, at: string): void; export declare function errorRecord(code: string, reason: string, at: string): NonNullable; export declare function authorizeRecordToken(record: DurableContinuationRecord, token: string): void; export declare function validateNamedRoutes(routes: Readonly>): void; export declare function resolveContinuationLimits(input: Partial | undefined): ContinuationLimits; export declare function operatorContinuationPage(records: readonly DurableContinuationRecord[], url: URL, configuredPageSize: number): Record; export declare function closeContinuationServer(server: Server): Promise; export declare function requireBearer(request: IncomingMessage): string; export declare function requireHeader(request: IncomingMessage, name: string): string; export declare function readJson(request: IncomingMessage, maxBytes: number): Promise; export declare function asObject(value: unknown): Record; export declare function requiredStringField(object: Record, key: string, max?: number): string; export declare function sendJson(response: ServerResponse, status: number, body: unknown): void; export declare function isLoopbackHost(host: string): boolean; export declare function formatHost(host: string): string; export declare function backoffMs(attempt: number, base: number, cap: number): number; export declare function safeReason(error: unknown): string; export declare function boundedHistoryErrorCode(value: string): string; //# sourceMappingURL=continuation-service-helpers.d.ts.map