From 548b8a22521c0927706580dbd54261fd9d10d25d Mon Sep 17 00:00:00 2001
From: Assaf Vayner <assaf@huggingface.co>
Date: Wed, 10 Sep 2025 09:05:31 -0700
Subject: [PATCH] update xet api paths

---
 packages/hub/scripts/bench.ts          | 4 ++--
 packages/hub/src/utils/XetBlob.ts      | 4 ++--
 packages/hub/src/utils/createXorbs.ts  | 4 ++--
 packages/hub/src/utils/uploadShards.ts | 4 ++--
 4 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/packages/hub/scripts/bench.ts b/packages/hub/scripts/bench.ts
index b97ca80ca9..bede3a9db8 100644
--- a/packages/hub/scripts/bench.ts
+++ b/packages/hub/scripts/bench.ts
@@ -157,7 +157,7 @@ function createMockFetch(args: { write: boolean }): {
 		const url = typeof input === "string" ? input : input.toString();
 
 		// Mock successful responses for xorb and shard uploads
-		if (url.includes("/xorb/")) {
+		if (url.includes("/xorbs/")) {
 			xorbCount++;
 			const bodySize = getBodySize(init?.body);
 			xorbBytes += parseInt(bodySize);
@@ -174,7 +174,7 @@ function createMockFetch(args: { write: boolean }): {
 			});
 		}
 
-		if (url.endsWith("/shard")) {
+		if (url.endsWith("/shards")) {
 			shardCount++;
 			const bodySize = getBodySize(init?.body);
 			shardBytes += parseInt(bodySize);
diff --git a/packages/hub/src/utils/XetBlob.ts b/packages/hub/src/utils/XetBlob.ts
index 027477c4a2..16b66b78cc 100644
--- a/packages/hub/src/utils/XetBlob.ts
+++ b/packages/hub/src/utils/XetBlob.ts
@@ -159,10 +159,10 @@ export class XetBlob extends Blob {
 			const connParams = await getAccessToken(this.accessToken, this.fetch, this.refreshUrl);
 
 			// debug(
-			// 	`curl '${connParams.casUrl}/v1/reconstruction/${this.hash}' -H 'Authorization: Bearer ${connParams.accessToken}'`
+			// 	`curl '${connParams.casUrl}/v1/reconstructions/${this.hash}' -H 'Authorization: Bearer ${connParams.accessToken}'`
 			// );
 
-			const resp = await this.fetch(this.reconstructionUrl ?? `${connParams.casUrl}/v1/reconstruction/${this.hash}`, {
+			const resp = await this.fetch(this.reconstructionUrl ?? `${connParams.casUrl}/v1/reconstructions/${this.hash}`, {
 				headers: {
 					Authorization: `Bearer ${connParams.accessToken}`,
 					Range: `bytes=${this.start}-${this.end - 1}`,
diff --git a/packages/hub/src/utils/createXorbs.ts b/packages/hub/src/utils/createXorbs.ts
index de8c451303..4be67c58af 100644
--- a/packages/hub/src/utils/createXorbs.ts
+++ b/packages/hub/src/utils/createXorbs.ts
@@ -202,7 +202,7 @@ export async function* createXorbs(
 						const token = await xetWriteToken(params);
 						bytesSinceRemoteDedup = 0;
 
-						const shardResp = await (params.fetch ?? fetch)(token.casUrl + "/v1/chunk/default/" + chunk.hash, {
+						const shardResp = await (params.fetch ?? fetch)(token.casUrl + "/v1/chunks/default/" + chunk.hash, {
 							headers: {
 								Authorization: `Bearer ${token.accessToken}`,
 							},
@@ -683,7 +683,7 @@ async function loadDedupInfoToCache(
 					const token = await xetWriteToken(params);
 					bytesSinceRemoteDedup = 0;
 
-					const shardResp = await (params.fetch ?? fetch)(token.casUrl + "/v1/chunk/default/" + chunk.hash, {
+					const shardResp = await (params.fetch ?? fetch)(token.casUrl + "/v1/chunks/default/" + chunk.hash, {
 						headers: {
 							Authorization: `Bearer ${token.accessToken}`,
 						},
diff --git a/packages/hub/src/utils/uploadShards.ts b/packages/hub/src/utils/uploadShards.ts
index c8d3f2caa3..164c3393c5 100644
--- a/packages/hub/src/utils/uploadShards.ts
+++ b/packages/hub/src/utils/uploadShards.ts
@@ -359,7 +359,7 @@ async function uploadXorb(
 ) {
 	const token = await xetWriteToken(params);
 
-	const resp = await (params.fetch ?? fetch)(`${token.casUrl}/v1/xorb/default/${xorb.hash}`, {
+	const resp = await (params.fetch ?? fetch)(`${token.casUrl}/v1/xorbs/default/${xorb.hash}`, {
 		method: "POST",
 		body: xorb.xorb,
 		headers: {
@@ -388,7 +388,7 @@ async function uploadXorb(
 async function uploadShard(shard: Uint8Array, params: UploadShardsParams) {
 	const token = await xetWriteToken(params);
 
-	const resp = await (params.fetch ?? fetch)(`${token.casUrl}/v1/shard`, {
+	const resp = await (params.fetch ?? fetch)(`${token.casUrl}/v1/shards`, {
 		method: "POST",
 		body: shard,
 		headers: {