chore: codegen

Author: luxass

src/index.ts

@@ -19,9 +19,7 @@ app.route("/", RANDOM_EMOJI_ROUTER);
 app.get(
   "/scalar",
   apiReference({
-    spec: {
-      url: "/openapi.json",
-    },
+    url: "/openapi.json",
     layout: "classic",
     customCss: /* css */`
     .endpoint-label-path {

worker-configuration.d.ts

@@ -1,10 +1,13 @@
-// Generated by Wrangler by running `wrangler types --env-interface CloudflareBindings` (hash: 89d7044924684f84281de354a02ef061)
-// Runtime types generated with workerd@1.20250310.0 2025-03-13 
-interface CloudflareBindings {
-	GITHUB_TOKEN: "";
-	API_VERSION: "x.y.z";
-	ENVIRONMENT: "preview" | "production";
-}
+// Generated by Wrangler by running `wrangler types --env-interface CloudflareBindings` (hash: e71cf0de9c927e7e3f2e02a5b583aba3)
+// Runtime types generated with workerd@1.20250317.0 2025-03-13 
+declare namespace Cloudflare {
+	interface Env {
+		API_VERSION: "x.y.z";
+		ENVIRONMENT: "preview" | "production";
+		GITHUB_TOKEN: string;
+	}
+}
+interface CloudflareBindings extends Cloudflare.Env {}
 
 // Begin runtime types
 /*! *****************************************************************************
@@ -1402,6 +1405,7 @@ interface RequestInit<Cf = CfProperties> {
     integrity?: string;
     /* An AbortSignal to set request's signal. */
     signal?: (AbortSignal | null);
+    encodeResponseBody?: "automatic" | "manual";
 }
 type Service<T extends Rpc.WorkerEntrypointBranded | undefined = undefined> = Fetcher<T>;
 type Fetcher<T extends Rpc.EntrypointBranded | undefined = undefined, Reserved extends string = never> = (T extends Rpc.EntrypointBranded ? Rpc.Provider<T, Reserved | "fetch" | "connect"> : unknown) & {
@@ -3770,6 +3774,7 @@ type AiModelListType = Record<string, any>;
 declare abstract class Ai<AiModelList extends AiModelListType = AiModels> {
     aiGatewayLogId: string | null;
     gateway(gatewayId: string): AiGateway;
+    autorag(autoragId: string): AutoRAG;
     run<Name extends keyof AiModelList, Options extends AiOptions>(model: Name, inputs: AiModelList[Name]["inputs"], options?: Options): Promise<Options extends {
         returnRawResponse: true;
     } ? Response : AiModelList[Name]["postProcessedOutputs"]>;
@@ -3779,12 +3784,14 @@ declare abstract class Ai<AiModelList extends AiModelListType = AiModels> {
         blob: Blob;
     }[], options?: {
         gateway?: GatewayOptions;
+        extraHeaders?: object;
     }): Promise<ConversionResponse[]>;
     public toMarkdown(files: {
         name: string;
         blob: Blob;
     }, options?: {
         gateway?: GatewayOptions;
+        extraHeaders?: object;
     }): Promise<ConversionResponse>;
 }
 type GatewayOptions = {
@@ -3827,21 +3834,21 @@ type AiGatewayLog = {
     response_head_complete: boolean;
     created_at: Date;
 };
-type AIGatewayProviders = 'workers-ai' | 'anthropic' | 'aws-bedrock' | 'azure-openai' | 'google-vertex-ai' | 'huggingface' | 'openai' | 'perplexity-ai' | 'replicate' | 'groq' | 'cohere' | 'google-ai-studio' | 'mistral' | 'grok' | 'openrouter';
+type AIGatewayProviders = "workers-ai" | "anthropic" | "aws-bedrock" | "azure-openai" | "google-vertex-ai" | "huggingface" | "openai" | "perplexity-ai" | "replicate" | "groq" | "cohere" | "google-ai-studio" | "mistral" | "grok" | "openrouter" | "deepseek" | "cerebras" | "cartesia" | "elevenlabs" | "adobe-firefly";
 type AIGatewayHeaders = {
-    'cf-aig-metadata': Record<string, number | string | boolean | null | bigint> | string;
-    'cf-aig-custom-cost': {
+    "cf-aig-metadata": Record<string, number | string | boolean | null | bigint> | string;
+    "cf-aig-custom-cost": {
         per_token_in?: number;
         per_token_out?: number;
     } | {
         total_cost?: number;
     } | string;
-    'cf-aig-cache-ttl': number | string;
-    'cf-aig-skip-cache': boolean | string;
-    'cf-aig-cache-key': string;
-    'cf-aig-collect-log': boolean | string;
+    "cf-aig-cache-ttl": number | string;
+    "cf-aig-skip-cache": boolean | string;
+    "cf-aig-cache-key": string;
+    "cf-aig-collect-log": boolean | string;
     Authorization: string;
-    'Content-Type': string;
+    "Content-Type": string;
     [key: string]: string | number | boolean | object;
 };
 type AIGatewayUniversalRequest = {
@@ -3858,6 +3865,45 @@ declare abstract class AiGateway {
     patchLog(logId: string, data: AiGatewayPatchLog): Promise<void>;
     getLog(logId: string): Promise<AiGatewayLog>;
     run(data: AIGatewayUniversalRequest | AIGatewayUniversalRequest[]): Promise<Response>;
+    getUrl(provider?: AIGatewayProviders | string): Promise<string>; // eslint-disable-line
+}
+interface AutoRAGInternalError extends Error {
+}
+interface AutoRAGNotFoundError extends Error {
+}
+interface AutoRAGUnauthorizedError extends Error {
+}
+type AutoRagSearchRequest = {
+    query: string;
+    max_num_results?: number;
+    ranking_options?: {
+        ranker?: string;
+        score_threshold?: number;
+    };
+    rewrite_query?: boolean;
+};
+type AutoRagSearchResponse = {
+    object: "vector_store.search_results.page";
+    search_query: string;
+    data: {
+        file_id: string;
+        filename: string;
+        score: number;
+        attributes: Record<string, string | number | boolean | null>;
+        content: {
+            type: "text";
+            text: string;
+        }[];
+    }[];
+    has_more: boolean;
+    next_page: string | null;
+};
+type AutoRagAiSearchResponse = AutoRagSearchResponse & {
+    response: string;
+};
+declare abstract class AutoRAG {
+    search(params: AutoRagSearchRequest): Promise<AutoRagSearchResponse>;
+    aiSearch(params: AutoRagSearchRequest): Promise<AutoRagAiSearchResponse>;
 }
 interface BasicImageTransformations {
     /**
@@ -4579,11 +4625,41 @@ interface D1ExecResult {
     count: number;
     duration: number;
 }
+type D1SessionConstraint = 
+// Indicates that the first query should go to the primary, and the rest queries
+// using the same D1DatabaseSession will go to any replica that is consistent with
+// the bookmark maintained by the session (returned by the first query).
+"first-primary"
+// Indicates that the first query can go anywhere (primary or replica), and the rest queries
+// using the same D1DatabaseSession will go to any replica that is consistent with
+// the bookmark maintained by the session (returned by the first query).
+ | "first-unconstrained";
+type D1SessionBookmark = string;
 declare abstract class D1Database {
     prepare(query: string): D1PreparedStatement;
-    dump(): Promise<ArrayBuffer>;
     batch<T = unknown>(statements: D1PreparedStatement[]): Promise<D1Result<T>[]>;
     exec(query: string): Promise<D1ExecResult>;
+    /**
+     * Creates a new D1 Session anchored at the given constraint or the bookmark.
+     * All queries executed using the created session will have sequential consistency,
+     * meaning that all writes done through the session will be visible in subsequent reads.
+     *
+     * @param constraintOrBookmark Either the session constraint or the explicit bookmark to anchor the created session.
+     */
+    withSession(constraintOrBookmark?: D1SessionBookmark | D1SessionConstraint): D1DatabaseSession;
+    /**
+     * @deprecated dump() will be removed soon, only applies to deprecated alpha v1 databases.
+     */
+    dump(): Promise<ArrayBuffer>;
+}
+declare abstract class D1DatabaseSession {
+    prepare(query: string): D1PreparedStatement;
+    batch<T = unknown>(statements: D1PreparedStatement[]): Promise<D1Result<T>[]>;
+    /**
+     * @returns The latest session bookmark across all executed queries on the session.
+     *          If no query has been executed yet, `null` is returned.
+     */
+    getBookmark(): D1SessionBookmark | null;
 }
 declare abstract class D1PreparedStatement {
     bind(...values: unknown[]): D1PreparedStatement;
@@ -4877,28 +4953,33 @@ declare module "assets:*" {
 // Copyright (c) 2022-2023 Cloudflare, Inc.
 // Licensed under the Apache 2.0 license found in the LICENSE file or at:
 //     https://opensource.org/licenses/Apache-2.0
-type PipelineRecord = Record<string, unknown>;
-type PipelineBatchMetadata = {
-    pipelineId: string;
-    pipelineName: string;
-};
-declare abstract class PipelineTransformationEntrypoint<I extends PipelineRecord, O extends PipelineRecord> {
-    /**
-     * run recieves an array of PipelineRecord which can be
-     * mutated and returned to the pipeline
-     * @param records Incoming records from the pipeline to be transformed
-     * @param metadata Information about the specific pipeline calling the transformation entrypoint
-     * @returns A promise containing the transformed PipelineRecord array
-     */
-    public run(records: I[], metadata: PipelineBatchMetadata): Promise<O[]>;
-}
-interface Pipeline<T extends PipelineRecord> {
-    /**
-     * The Pipeline interface represents the type of a binding to a Pipeline
-     *
-     * @param records The records to send to the pipeline
-     */
-    send(records: T[]): Promise<void>;
+declare module "cloudflare:pipelines" {
+    export abstract class PipelineTransformationEntrypoint<Env = unknown, I extends PipelineRecord = {}, O extends PipelineRecord = {}> {
+        /**
+         * run recieves an array of PipelineRecord which can be
+         * mutated and returned to the pipeline
+         * @param records Incoming records from the pipeline to be transformed
+         * @param metadata Information about the specific pipeline calling the transformation entrypoint
+         * @returns A promise containing the transformed PipelineRecord array
+         */
+        protected env: Env;
+        protected ctx: ExecutionContext;
+        constructor(ctx: ExecutionContext, env: Env);
+        public run(records: I[], metadata: PipelineBatchMetadata): Promise<O[]>;
+    }
+    export type PipelineRecord = Record<string, unknown>;
+    export type PipelineBatchMetadata = {
+        pipelineId: string;
+        pipelineName: string;
+    };
+    export interface Pipeline<T extends PipelineRecord> {
+        /**
+         * The Pipeline interface represents the type of a binding to a Pipeline
+         *
+         * @param records The records to send to the pipeline
+         */
+        send(records: T[]): Promise<void>;
+    }
 }
 // PubSubMessage represents an incoming PubSub message.
 // The message includes metadata about the broker, the client, and the payload
@@ -4948,9 +5029,6 @@ interface RateLimit {
      */
     limit(options: RateLimitOptions): Promise<RateLimitOutcome>;
 }
-// Extend this in your apps to properly type Env
-interface Env {
-}
 // Namespace for RPC utility types. Unfortunately, we can't use a `module` here as these types need
 // to referenced by `Fetcher`. This is included in the "importable" version of the types which
 // strips all `module` blocks.
@@ -5049,6 +5127,10 @@ declare namespace Rpc {
         [K in Exclude<keyof T, Reserved | symbol | keyof StubBase<never>>]: MethodOrProperty<T[K]>;
     };
 }
+declare namespace Cloudflare {
+    interface Env {
+    }
+}
 declare module "cloudflare:workers" {
     export type RpcStub<T extends Rpc.Stubable> = Rpc.Stub<T>;
     export const RpcStub: {
@@ -5112,7 +5194,7 @@ declare module "cloudflare:workers" {
         constructor(ctx: ExecutionContext, env: Env);
         run(event: Readonly<WorkflowEvent<T>>, step: WorkflowStep): Promise<unknown>;
     }
-    export const env: Env;
+    export const env: Cloudflare.Env;
 }
 declare module "cloudflare:sockets" {
     function _connect(address: string | SocketAddress, options?: SocketOptions): Socket;
@@ -5571,6 +5653,13 @@ declare abstract class Workflow<PARAMS = unknown> {
      * @returns A promise that resolves with a handle for the Instance
      */
     public create(options?: WorkflowInstanceCreateOptions<PARAMS>): Promise<WorkflowInstance>;
+    /**
+     * Create a batch of instances and return handle for all of them. If a provided id exists, an error will be thrown.
+     * `createBatch` is limited at 100 instances at a time or when the RPC limit for the batch (1MiB) is reached.
+     * @param batch List of Options when creating an instance including name and params
+     * @returns A promise that resolves with a list of handles for the created instances.
+     */
+    public createBatch(batch: WorkflowInstanceCreateOptions<PARAMS>[]): Promise<WorkflowInstance[]>;
 }
 interface WorkflowInstanceCreateOptions<PARAMS = unknown> {
     /**