[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_102":84,"_27":103,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":120,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",31,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","25319816-1098-11f1-a0a6-42dde27851f2","name","fileType","http","content","// ============================================================\n// cross-conv-file-transfer.ts\n// Transfère un fichier d'une conversation Dust vers une autre\n// ============================================================\n\nconst DUST_API_BASE = \"https://dust.tt/api/v1\";\n\ninterface TransferParams {\n dustApiKey: string;\n workspaceId: string;\n targetConversationId: string;\n fileId: string;\n}\n\n// ── Helpers ──────────────────────────────────────────────────\n\nfunction headers(apiKey: string, json = false): Record {\n const h: Record = {\n Authorization: `Bearer ${apiKey}`,\n Accept: \"application/json\",\n };\n if (json) h[\"Content-Type\"] = \"application/json\";\n return h;\n}\n\n// ── Étape 1 : Télécharger le fichier depuis Dust ────────────\n\nasync function downloadFile(\n dustApiKey: string,\n workspaceId: string,\n fileId: string,\n): Promise<{ buffer: ArrayBuffer; contentType: string }> {\n const url =\n `${DUST_API_BASE}/w/${workspaceId}/files/${fileId}?action=view&version=original`;\n const res = await fetch(url, {\n headers: {\n Authorization: `Bearer ${dustApiKey}`,\n },\n redirect: \"follow\",\n });\n\n if (!res.ok) {\n throw new Error(\n `Download file failed (${res.status}): ${await res.text()}`,\n );\n }\n\n const contentType = res.headers.get(\"content-type\") ||\n \"application/octet-stream\";\n const buffer = await res.arrayBuffer();\n\n return { buffer, contentType };\n}\n\n// ── Étape 2 : Créer un slot d'upload dans la conv cible ─────\n\nasync function createFileUpload(\n dustApiKey: string,\n workspaceId: string,\n targetConversationId: string,\n fileName: string,\n contentType: string,\n fileSize: number,\n): Promise<{ fileId: string; uploadUrl: string }> {\n const url = `${DUST_API_BASE}/w/${workspaceId}/files`;\n\n const body = {\n contentType,\n fileName,\n fileSize,\n useCase: \"conversation\",\n useCaseMetadata: JSON.stringify({ conversationId: targetConversationId }),\n };\n\n const res = await fetch(url, {\n method: \"POST\",\n headers: headers(dustApiKey, true),\n body: JSON.stringify(body),\n });\n\n if (!res.ok) {\n throw new Error(\n `Create file upload failed (${res.status}): ${await res.text()}`,\n );\n }\n\n const data = await res.json();\n return {\n fileId: data.file.sId,\n uploadUrl: data.file.uploadUrl,\n };\n}\n\n// ── Étape 3 : Uploader le contenu du fichier ────────────────\n\nasync function uploadFileContent(\n dustApiKey: string,\n workspaceId: string,\n fileId: string,\n buffer: ArrayBuffer,\n contentType: string,\n): Promise {\n const url = `${DUST_API_BASE}/w/${workspaceId}/files/${fileId}`;\n\n const res = await fetch(url, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${dustApiKey}`,\n \"Content-Type\": contentType,\n },\n body: buffer,\n });\n\n if (!res.ok) {\n throw new Error(\n `Upload file content failed (${res.status}): ${await res.text()}`,\n );\n }\n}\n\n// ── Étape 4 : Attacher le fichier à la conv cible ───────────\n\nasync function attachFileToConversation(\n dustApiKey: string,\n workspaceId: string,\n targetConversationId: string,\n fileId: string,\n title: string,\n contentType: string,\n): Promise {\n const url =\n `${DUST_API_BASE}/w/${workspaceId}/assistant/conversations/${targetConversationId}/content_fragments`;\n\n const body = {\n title,\n fileId,\n contentType,\n context: {\n username: \"file-transfer-bot\",\n timezone: \"Europe/Paris\",\n fullName: \"Cross-Conv File Transfer\",\n email: \"bot@wesype.com\",\n origin: \"api\" as const,\n },\n };\n\n const res = await fetch(url, {\n method: \"POST\",\n headers: headers(dustApiKey, true),\n body: JSON.stringify(body),\n });\n\n if (!res.ok) {\n throw new Error(\n `Attach content fragment failed (${res.status}): ${await res.text()}`,\n );\n }\n}\n\n// ── Orchestration principale ─────────────────────────────────\n\nasync function transferFile(params: TransferParams): Promise<{\n success: boolean;\n message: string;\n newFileId?: string;\n}> {\n const { dustApiKey, workspaceId, targetConversationId, fileId } = params;\n const title = `transferred-${fileId}.csv`;\n\n console.log(`⬇️ Téléchargement du fichier ${fileId}...`);\n const { buffer, contentType } = await downloadFile(\n dustApiKey,\n workspaceId,\n fileId,\n );\n console.log(`✅ Fichier téléchargé (${buffer.byteLength} bytes)`);\n\n console.log(`📤 Création de l'upload dans conv ${targetConversationId}...`);\n const upload = await createFileUpload(\n dustApiKey,\n workspaceId,\n targetConversationId,\n title,\n contentType,\n buffer.byteLength,\n );\n console.log(`✅ Slot d'upload créé : ${upload.fileId}`);\n\n console.log(`⬆️ Upload du contenu...`);\n await uploadFileContent(\n dustApiKey,\n workspaceId,\n upload.fileId,\n buffer,\n contentType,\n );\n console.log(`✅ Contenu uploadé`);\n\n console.log(`🔗 Attachement à la conversation cible...`);\n await attachFileToConversation(\n dustApiKey,\n workspaceId,\n targetConversationId,\n upload.fileId,\n title,\n contentType,\n );\n console.log(`✅ Fichier attaché avec succès !`);\n\n return {\n success: true,\n message: `Fichier ${fileId} transféré vers conv ${targetConversationId}`,\n newFileId: upload.fileId,\n };\n}\n\n// ── Point d'entrée Val.town ──────────────────────────────────\n\nexport default async function handler(req: Request): Promise {\n const dustApiKey = Deno.env.get(\"DUST_API_KEY\");\n const workspaceId = Deno.env.get(\"DUST_WORKSPACE_ID\");\n\n if (!dustApiKey || !workspaceId) {\n return Response.json(\n { error: \"DUST_API_KEY ou DUST_WORKSPACE_ID manquant dans les env vars\" },\n { status: 500 },\n );\n }\n\n const { target_conv_id, file_id } = await req.json();\n\n if (!target_conv_id || !file_id) {\n return Response.json(\n { error: \"Champs requis: target_conv_id, file_id\" },\n { status: 400 },\n );\n }\n\n try {\n const result = await transferFile({\n dustApiKey,\n workspaceId,\n targetConversationId: target_conv_id,\n fileId: file_id,\n });\n return Response.json(result);\n } catch (err: any) {\n return Response.json({ error: err.message }, { status: 500 });\n }\n}","// ============================================================\n// cross-conv-file-transfer.ts\n// Transfère TOUS les fichiers d'une conversation Dust vers une autre\n// Compatible : Val.town / Deno\n// ============================================================\n\nconst DUST_API_BASE = \"https://dust.tt/api/v1\";\n\n// ── Helpers ──────────────────────────────────────────────────\n\nfunction headers(apiKey: string, json = false): Record {\n const h: Record = {\n Authorization: `Bearer ${apiKey}`,\n Accept: \"application/json\",\n };\n if (json) h[\"Content-Type\"] = \"application/json\";\n return h;\n}\n\n// ── Étape 1 : Trouver TOUS les fichiers dans la conv source ─\n\ninterface FoundFile {\n fileId: string;\n title: string;\n contentType: string;\n}\n\nasync function findAllFilesInConversation(\n dustApiKey: string,\n workspaceId: string,\n conversationId: string,\n): Promise {\n const url =\n `${DUST_API_BASE}/w/${workspaceId}/assistant/conversations/${conversationId}`;\n const res = await fetch(url, { headers: headers(dustApiKey) });\n\n if (!res.ok) {\n throw new Error(\n `GET conversation failed (${res.status}): ${await res.text()}`,\n );\n }\n\n const data = await res.json();\n const files: FoundFile[] = [];\n\n for (const group of data.conversation.content) {\n for (const item of group) {\n if (item.type === \"content_fragment\" && item.fileId) {\n files.push({\n fileId: item.fileId,\n title: item.title || `${item.fileId}.csv`,\n contentType: item.contentType || \"text/csv\",\n });\n }\n }\n }\n\n return files;\n}\n\n// ── Étape 2 : Télécharger un fichier ────────────────────────\n\nasync function downloadFile(\n dustApiKey: string,\n workspaceId: string,\n fileId: string,\n): Promise<{ buffer: ArrayBuffer; contentType: string }> {\n const url =\n `${DUST_API_BASE}/w/${workspaceId}/files/${fileId}?action=view&version=original`;\n const res = await fetch(url, {\n headers: { Authorization: `Bearer ${dustApiKey}` },\n redirect: \"follow\",\n });\n\n if (!res.ok) {\n throw new Error(\n `Download file failed (${res.status}): ${await res.text()}`,\n );\n }\n\n const contentType = res.headers.get(\"content-type\") ||\n \"application/octet-stream\";\n const buffer = await res.arrayBuffer();\n return { buffer, contentType };\n}\n\n// ── Étape 3 : Créer un slot d'upload ────────────────────────\n\nasync function createFileUpload(\n dustApiKey: string,\n workspaceId: string,\n targetConversationId: string,\n fileName: string,\n contentType: string,\n fileSize: number,\n): Promise {\n const url = `${DUST_API_BASE}/w/${workspaceId}/files`;\n\n const res = await fetch(url, {\n method: \"POST\",\n headers: headers(dustApiKey, true),\n body: JSON.stringify({\n contentType,\n fileName,\n fileSize,\n useCase: \"conversation\",\n useCaseMetadata: JSON.stringify({ conversationId: targetConversationId }),\n }),\n });\n\n if (!res.ok) {\n throw new Error(\n `Create file upload failed (${res.status}): ${await res.text()}`,\n );\n }\n\n const data = await res.json();\n return data.file.sId;\n}\n\n// ── Étape 4 : Uploader le contenu ───────────────────────────\n\nasync function uploadFileContent(\n dustApiKey: string,\n workspaceId: string,\n fileId: string,\n buffer: ArrayBuffer,\n contentType: string,\n): Promise {\n const url = `${DUST_API_BASE}/w/${workspaceId}/files/${fileId}`;\n\n const res = await fetch(url, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${dustApiKey}`,\n \"Content-Type\": contentType,\n },\n body: buffer,\n });\n\n if (!res.ok) {\n throw new Error(\n `Upload file content failed (${res.status}): ${await res.text()}`,\n );\n }\n}\n\n// ── Étape 5 : Attacher à la conv cible ──────────────────────\n\nasync function attachFileToConversation(\n dustApiKey: string,\n workspaceId: string,\n targetConversationId: string,\n fileId: string,\n title: string,\n contentType: string,\n): Promise {\n const url =\n `${DUST_API_BASE}/w/${workspaceId}/assistant/conversations/${targetConversationId}/content_fragments`;\n\n const res = await fetch(url, {\n method: \"POST\",\n headers: headers(dustApiKey, true),\n body: JSON.stringify({\n title,\n fileId,\n contentType,\n context: {\n username: \"file-transfer-bot\",\n timezone: \"Europe/Paris\",\n fullName: \"Cross-Conv File Transfer\",\n email: \"bot@wesype.com\",\n origin: \"agent_action\" as const,\n },\n }),\n });\n\n if (!res.ok) {\n throw new Error(\n `Attach content fragment failed (${res.status}): ${await res.text()}`,\n );\n }\n}\n\n// ── Orchestration : transfère TOUS les fichiers ──────────────\n\nasync function transferAllFiles(\n dustApiKey: string,\n workspaceId: string,\n sourceConvId: string,\n targetConvId: string,\n) {\n // 1. Trouver tous les fichiers dans la conv source\n const files = await findAllFilesInConversation(\n dustApiKey,\n workspaceId,\n sourceConvId,\n );\n console.log(`🔍 ${files.length} fichier(s) trouvé(s) dans ${sourceConvId}`);\n\n const transfers = [];\n\n for (const file of files) {\n // 2. Télécharger\n const { buffer, contentType } = await downloadFile(\n dustApiKey,\n workspaceId,\n file.fileId,\n );\n\n const fileName = `${file.fileId}.csv`;\n\n // 3. Créer slot\n const newFileId = await createFileUpload(\n dustApiKey,\n workspaceId,\n targetConvId,\n fileName,\n contentType,\n buffer.byteLength,\n );\n\n // 4. Upload\n await uploadFileContent(\n dustApiKey,\n workspaceId,\n newFileId,\n buffer,\n contentType,\n );\n\n // 5. Attacher\n await attachFileToConversation(\n dustApiKey,\n workspaceId,\n targetConvId,\n newFileId,\n fileName,\n contentType,\n );\n\n transfers.push({\n sourceFileId: file.fileId,\n targetFileId: newFileId,\n fileName,\n contentType,\n fileSize: buffer.byteLength,\n origin: \"agent_action\",\n success: true,\n });\n\n console.log(`✅ ${file.fileId} → ${newFileId}`);\n }\n\n return {\n success: true,\n source: sourceConvId,\n target: targetConvId,\n filesFound: files.length,\n filesTransferred: transfers.length,\n transfers,\n messagePosted: true,\n };\n}\n\n// ── Point d'entrée Val.town ──────────────────────────────────\n\nexport default async function handler(req: Request): Promise {\n const dustApiKey = Deno.env.get(\"DUST_API_KEY\");\n const workspaceId = Deno.env.get(\"DUST_WORKSPACE_ID\");\n\n if (!dustApiKey || !workspaceId) {\n return Response.json(\n { error: \"DUST_API_KEY ou DUST_WORKSPACE_ID manquant\" },\n { status: 500 },\n );\n }\n\n const { source_conv_id, target_conv_id } = await req.json();\n\n if (!source_conv_id || !target_conv_id) {\n return Response.json(\n { error: \"Champs requis: source_conv_id, target_conv_id\" },\n { status: 400 },\n );\n }\n\n try {\n const result = await transferAllFiles(\n dustApiKey,\n workspaceId,\n source_conv_id,\n target_conv_id,\n );\n return Response.json(result);\n } catch (err: any) {\n return Response.json({ error: err.message }, { status: 500 });\n }\n}","createdAt",["D",1771937579553],"branchVersion","branchId","252ededc-1098-11f1-a0a6-42dde27851f2","id","252eaa98-1098-11f1-a0a6-42dde27851f2","doc-transfer",["D",1771838107005],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","019b4a6f-acf9-72bd-bb4b-4e73c81fa54c","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019b4a6f-acf9-72bd-bb4b-508df4b6ead2","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_101":97},"org",{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned",42,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","thomala","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM3RXU1d1VJZ3IzZGdQcXNNT2lYa0l0cTYzSCJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":150,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":151,"_78":152,"_80":153,"_82":25},"tree",[145],"files",[145],"counts",{"_133":60,"_134":135,"_136":60,"_137":138,"_139":140},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"bf71e4e8-117f-11f1-a3fb-42dde27851f2","parentId","latest",["D",1771937579553],30,"label",[28],"pulls","branches",1,"forks","envVars",{"_141":143,"_144":60},"connections",{"_141":60,"_142":60},"count","unfilledCount",2,"emptyCount",{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":146,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_147":148,"_27":149},["D",1771937579553],"children",[],[28],["D",1771838107005],{"_94":93,"_101":97},{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_122":187,"_188":189,"_190":191,"_192":25,"_193":25,"_194":25,"_195":120,"_196":-5,"_197":-7,"_198":-7,"_199":60,"_200":25,"_201":25,"_202":-5,"_203":25,"_204":25,"_205":25,"_206":-5},"ENV",{"_158":159,"_160":161,"_162":84,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v31