pingdotgg · juliusmarminge · May 8, 2025 · May 7, 2025 · May 8, 2025 · May 8, 2025
diff --git a/docs/src/app/(docs)/concepts/regions-acl/multiregion.png b/docs/src/app/(docs)/concepts/regions-acl/multiregion.png
diff --git a/docs/src/app/(docs)/concepts/regions-acl/page.mdx b/docs/src/app/(docs)/concepts/regions-acl/page.mdx
@@ -47,6 +47,61 @@ you can select the region you want to upload your files to. Once changed, all
   or via [email](mailto:ut-support@ping.gg).
 </Note>
 
+### Dynamic region selection (Private Beta)
+
+UploadThing allows you to seamlessly select the region based on the user's
+location. This is useful for applications that are global and want to upload
+files to the region closest to the user for lower latencies.
+
+This feature is currently in private beta and to enable it, reach out to us on
+[support@uploadthing.com](mailto:support@uploadthing.com) if you're interested
+in enrolling.
+
+Once enabled, you can upload to any region you have enabled on your app in the
+dashboard:
+
+![Dynamic region selection](./multiregion.png)
+
+Then, in your middleware, tag the upload's metadata with the
+`experimental_UTRegion` key:
+
+```ts
+export const uploadRouter = {
+  anyPrivate: fileRoute({
+    blob: { maxFileSize: "256MB", maxFileCount: 10, acl: "public-read" },
+  })
+    .input(z.object({}))
+    .middleware(async (opts) => {
+      /**
+       * Simple example using continent code to select region.
+       *
+       * Europe and Africa will be routed to Frankfurt,
+       * Asia to Mumbai (India), and the rest to Virginia (US-East).
+       *
+       * You can do this selection however you like.
+       */
+      const region =
+        (
+          {
+            AF: "fra1",
+            AN: "sea1",
+            AS: "bom1",
+            EU: "fra1",
+            NA: "sea1",
+            OC: "sea1",
+            SA: "sea1",
+          } as const
+        )[opts.req.headers.get("x-vercel-ip-continent")?.toUpperCase()] ??
+        "sea1"; // Fallback
+
+      return { [experimental_UTRegion]: region }; // <-- Tag the upload with the selected region
+    })
+    .onUploadComplete(async (opts) => {
+      console.log("Upload complete", opts.file);
+    }),
+} satisfies FileRouter;
+```
+
 ## Access Controls
 
 By default every file uploaded to UploadThing is accessible simply by it's URL

diff --git a/packages/react/coverage.json b/packages/react/coverage.json
diff --git a/packages/uploadthing/src/_internal/config.ts b/packages/uploadthing/src/_internal/config.ts
@@ -82,9 +82,14 @@ export const ApiUrl = Config.string("apiUrl").pipe(
   Config.map((url) => url.href.replace(/\/$/, "")),
 );
 
-export const IngestUrl = Effect.gen(function* () {
+export const IngestUrl = Effect.fn(function* (
+  preferredRegion: string | undefined,
+) {
   const { regions, ingestHost } = yield* UTToken;
-  const region = regions[0]; // Currently only support 1 region per app
+
+  const region = preferredRegion
+    ? (regions.find((r) => r === preferredRegion) ?? regions[0])
+    : regions[0];
 
   return yield* Config.string("ingestUrl").pipe(
     Config.withDefault(`https://${region}.${ingestHost}`),

diff --git a/packages/uploadthing/src/_internal/handler.ts b/packages/uploadthing/src/_internal/handler.ts
@@ -46,7 +46,7 @@ import {
   UploadedFileData,
   UploadThingHook,
 } from "./shared-schemas";
-import { UTFiles } from "./types";
+import { UTFiles, UTRegion } from "./types";
 import type { AnyFileRoute, UTEvents } from "./types";
 
 export class AdapterArguments extends Context.Tag(
@@ -329,6 +329,7 @@ const handleCallbackRequest = (opts: {
       Schema.Struct({
         status: Schema.String,
         file: UploadedFileData,
+        origin: Schema.String,
         metadata: Schema.Record({ key: Schema.String, value: Schema.Unknown }),
       }),
     );
@@ -379,14 +380,12 @@ const handleCallbackRequest = (opts: {
         "'onUploadComplete' callback finished. Sending response to UploadThing:",
       ).pipe(Effect.annotateLogs("callbackData", payload));
 
-      const baseUrl = yield* IngestUrl;
-
       const httpClient = (yield* HttpClient.HttpClient).pipe(
         HttpClient.filterStatusOk,
       );
 
       yield* HttpClientRequest.post(`/callback-result`).pipe(
-        HttpClientRequest.prependUrl(baseUrl),
+        HttpClientRequest.prependUrl(requestInput.origin),
         HttpClientRequest.setHeaders({
           "x-uploadthing-api-key": Redacted.value(apiKey),
           "x-uploadthing-version": pkgJson.version,
@@ -467,7 +466,11 @@ const runRouteMiddleware = (opts: {
       }),
     );
 
-    return { metadata, filesWithCustomIds };
+    return {
+      metadata,
+      filesWithCustomIds,
+      preferredRegion: metadata[UTRegion],
+    };
   }).pipe(Effect.withLogSpan("runRouteMiddleware"));
 
 const handleUploadAction = (opts: {
@@ -501,10 +504,11 @@ const handleUploadAction = (opts: {
       Effect.annotateLogs("input", parsedInput),
     );
 
-    const { metadata, filesWithCustomIds } = yield* runRouteMiddleware({
-      json: { input: parsedInput, files: json.files },
-      uploadable,
-    });
+    const { metadata, filesWithCustomIds, preferredRegion } =
+      yield* runRouteMiddleware({
+        json: { input: parsedInput, files: json.files },
+        uploadable,
+      });
 
     yield* Effect.logDebug("Parsing route config").pipe(
       Effect.annotateLogs("routerConfig", uploadable.routerConfig),
@@ -564,7 +568,7 @@ const handleUploadAction = (opts: {
 
     const routeOptions = uploadable.routeOptions;
     const { apiKey, appId } = yield* UTToken;
-    const ingestUrl = yield* IngestUrl;
+    const ingestUrl = yield* IngestUrl(preferredRegion);
     const isDev = yield* IsDevelopment;
 
     yield* Effect.logDebug("Generating presigned URLs").pipe(

diff --git a/packages/uploadthing/src/_internal/types.ts b/packages/uploadthing/src/_internal/types.ts
@@ -19,6 +19,23 @@ import type {
   UploadedFileData,
 } from "./shared-schemas";
 
+export type UTRegionAlias =
+  | "bom1"
+  | "icn1"
+  | "syd1"
+  | "can1"
+  | "fra1"
+  | "zrh1"
+  | "dub1"
+  | "cle1"
+  | "sfo1"
+  | "sea1";
+
+/**
+ * Marker used to select the region based on the incoming request
+ */
+export const UTRegion = Symbol("uploadthing-region-symbol");
+
 /**
  * Marker used to append a `customId` to the incoming file data in `.middleware()`
  * @example
@@ -40,6 +57,7 @@ export type UnsetMarker = "unsetMarker" & {
 };
 
 export type ValidMiddlewareObject = {
+  [UTRegion]?: UTRegionAlias;
   [UTFiles]?: Partial<FileUploadDataWithCustomId>[];
   [key: string]: unknown;
 };

diff --git a/packages/uploadthing/src/effect-platform.ts b/packages/uploadthing/src/effect-platform.ts
@@ -10,7 +10,14 @@ import type { CreateBuilderOptions } from "./_internal/upload-builder";
 import { createBuilder } from "./_internal/upload-builder";
 import type { FileRouter, RouteHandlerConfig } from "./types";
 
-export { UTFiles } from "./_internal/types";
+export {
+  UTFiles,
+  /**
+   * This is an experimental feature.
+   * You need to be feature flagged on our backend to use this
+   */
+  UTRegion as experimental_UTRegion,
+} from "./_internal/types";
 export type { FileRouter };
 
 type AdapterArgs = {

diff --git a/packages/uploadthing/src/express.ts b/packages/uploadthing/src/express.ts
@@ -14,7 +14,14 @@ import type { CreateBuilderOptions } from "./_internal/upload-builder";
 import { createBuilder } from "./_internal/upload-builder";
 import type { FileRouter, RouteHandlerOptions } from "./types";
 
-export { UTFiles } from "./_internal/types";
+export {
+  UTFiles,
+  /**
+   * This is an experimental feature.
+   * You need to be feature flagged on our backend to use this
+   */
+  UTRegion as experimental_UTRegion,
+} from "./_internal/types";
 export type { FileRouter };
 
 type AdapterArgs = {

diff --git a/packages/uploadthing/src/fastify.ts b/packages/uploadthing/src/fastify.ts
@@ -9,7 +9,14 @@ import type { CreateBuilderOptions } from "./_internal/upload-builder";
 import { createBuilder } from "./_internal/upload-builder";
 import type { FileRouter, RouteHandlerOptions } from "./types";
 
-export { UTFiles } from "./_internal/types";
+export {
+  UTFiles,
+  /**
+   * This is an experimental feature.
+   * You need to be feature flagged on our backend to use this
+   */
+  UTRegion as experimental_UTRegion,
+} from "./_internal/types";
 export type { FileRouter };
 
 type AdapterArgs = {

diff --git a/packages/uploadthing/src/h3.ts b/packages/uploadthing/src/h3.ts
@@ -9,7 +9,14 @@ import type { CreateBuilderOptions } from "./_internal/upload-builder";
 import { createBuilder } from "./_internal/upload-builder";
 import type { FileRouter, RouteHandlerOptions } from "./types";
 
-export { UTFiles } from "./_internal/types";
+export {
+  UTFiles,
+  /**
+   * This is an experimental feature.
+   * You need to be feature flagged on our backend to use this
+   */
+  UTRegion as experimental_UTRegion,
+} from "./_internal/types";
 export type { FileRouter };
 
 type AdapterArgs = {

diff --git a/packages/uploadthing/src/next-legacy.ts b/packages/uploadthing/src/next-legacy.ts
@@ -9,7 +9,14 @@ import type { CreateBuilderOptions } from "./_internal/upload-builder";
 import { createBuilder } from "./_internal/upload-builder";
 import type { FileRouter, RouteHandlerOptions } from "./types";
 
-export { UTFiles } from "./_internal/types";
+export {
+  UTFiles,
+  /**
+   * This is an experimental feature.
+   * You need to be feature flagged on our backend to use this
+   */
+  UTRegion as experimental_UTRegion,
+} from "./_internal/types";
 export type { FileRouter };
 
 type AdapterArgs = {

diff --git a/packages/uploadthing/src/next.ts b/packages/uploadthing/src/next.ts
@@ -9,7 +9,14 @@ import { createBuilder } from "./_internal/upload-builder";
 import type { FileRouter, RouteHandlerOptions } from "./types";
 
 export type { FileRouter };
-export { UTFiles } from "./_internal/types";
+export {
+  UTFiles,
+  /**
+   * This is an experimental feature.
+   * You need to be feature flagged on our backend to use this
+   */
+  UTRegion as experimental_UTRegion,
+} from "./_internal/types";
 
 type AdapterArgs = {
   req: NextRequest;

diff --git a/packages/uploadthing/src/remix.ts b/packages/uploadthing/src/remix.ts
@@ -9,7 +9,14 @@ import { createBuilder } from "./_internal/upload-builder";
 import type { FileRouter, RouteHandlerOptions } from "./types";
 
 export type { FileRouter };
-export { UTFiles } from "./_internal/types";
+export {
+  UTFiles,
+  /**
+   * This is an experimental feature.
+   * You need to be feature flagged on our backend to use this
+   */
+  UTRegion as experimental_UTRegion,
+} from "./_internal/types";
 
 type AdapterArgs = {
   event: ActionFunctionArgs;

diff --git a/packages/uploadthing/src/sdk/utils.ts b/packages/uploadthing/src/sdk/utils.ts
@@ -84,7 +84,7 @@ const generatePresignedUrl = (
 ) =>
   Effect.gen(function* () {
     const { apiKey, appId } = yield* UTToken;
-    const baseUrl = yield* IngestUrl;
+    const baseUrl = yield* IngestUrl(undefined);
 
     const key = yield* generateKey(file, appId);
 

diff --git a/packages/uploadthing/src/server.ts b/packages/uploadthing/src/server.ts
@@ -9,7 +9,14 @@ import type { CreateBuilderOptions } from "./_internal/upload-builder";
 import { createBuilder } from "./_internal/upload-builder";
 import type { FileRouter, RouteHandlerOptions } from "./types";
 
-export { UTFiles } from "./_internal/types";
+export {
+  UTFiles,
+  /**
+   * This is an experimental feature.
+   * You need to be feature flagged on our backend to use this
+   */
+  UTRegion as experimental_UTRegion,
+} from "./_internal/types";
 export { UTApi } from "./sdk";
 export { UTFile } from "./sdk/ut-file";
 export { UploadThingError, type FileRouter, makeAdapterHandler, createBuilder };

diff --git a/packages/uploadthing/test/node/config.test.ts b/packages/uploadthing/test/node/config.test.ts
@@ -248,7 +248,7 @@ describe("ingest url infers correctly", () => {
       );
       process.env.UPLOADTHING_INGEST_URL = "http://localhost:1234";
 
-      const url = yield* IngestUrl.pipe(
+      const url = yield* IngestUrl(undefined).pipe(
         Effect.provide(Layer.setConfigProvider(configProvider(null))),
         Effect.exit,
       );
@@ -263,7 +263,7 @@ describe("ingest url infers correctly", () => {
         ParsedToken.make(app1TokenData),
       );
 
-      const url = yield* IngestUrl.pipe(
+      const url = yield* IngestUrl(undefined).pipe(
         Effect.provide(Layer.setConfigProvider(configProvider(null))),
         Effect.exit,
       );

diff --git a/packages/uploadthing/test/node/request-handler.test.ts b/packages/uploadthing/test/node/request-handler.test.ts
@@ -410,6 +410,7 @@ describe(".onUploadComplete()", () => {
     const payload = JSON.stringify({
       status: "uploaded",
       metadata: {},
+      origin: "https://example.com",
       file: new UploadedFileData({
         url: `${UTFS_URL}/f/some-random-key.png`,
         appUrl: `${UTFS_URL}/a/${testToken.decoded.appId}/f/some-random-key.png`,

diff --git a/playground/app/api/uploadthing/route.ts b/playground/app/api/uploadthing/route.ts
@@ -4,6 +4,7 @@ import { z } from "zod";
 import {
   createRouteHandler,
   createUploadthing,
+  experimental_UTRegion,
   FileRouter,
 } from "uploadthing/next";
 import { UploadThingError } from "uploadthing/server";
@@ -15,7 +16,7 @@ const fileRoute = createUploadthing();
 
 export const uploadRouter = {
   anyPrivate: fileRoute({
-    blob: { maxFileSize: "256MB", maxFileCount: 10, acl: "private" },
+    blob: { maxFileSize: "256MB", maxFileCount: 10, acl: "public-read" },
   })
     .input(z.object({}))
     .middleware(async (opts) => {
@@ -26,7 +27,22 @@ export const uploadRouter = {
 
       console.log("middleware ::", session.sub, opts.input);
 
-      return {};
+      /**
+       * Example on how to select region based on user's location
+       */
+      const region = (
+        {
+          AF: "fra1",
+          AN: "sea1",
+          AS: "bom1",
+          EU: "fra1",
+          NA: "sea1",
+          OC: "sea1",
+          SA: "sea1",
+        } as const
+      )[opts.req.headers.get("x-vercel-ip-continent")?.toUpperCase() ?? "US"]!;
+
+      return { [experimental_UTRegion]: region };
     })
     .onUploadComplete(async (opts) => {
       console.log("Upload complete", opts.file);