a2a-source-edit: write frontend/src/a2a.js
This commit is contained in:
@@ -3,10 +3,17 @@ export const CONFIG_URL = import.meta.env.DEV ? "/config.json" : "./config.json"
|
|||||||
export async function requestJson(url, init = {}) {
|
export async function requestJson(url, init = {}) {
|
||||||
const response = await fetch(url, { credentials: "same-origin", ...init });
|
const response = await fetch(url, { credentials: "same-origin", ...init });
|
||||||
const text = await response.text();
|
const text = await response.text();
|
||||||
const data = text ? JSON.parse(text) : null;
|
let data = null;
|
||||||
|
try {
|
||||||
|
data = text ? JSON.parse(text) : null;
|
||||||
|
} catch {
|
||||||
|
data = { message: text };
|
||||||
|
}
|
||||||
if (!response.ok) {
|
if (!response.ok) {
|
||||||
const detail = data && (data.detail || data.message);
|
const detail = data && (data.detail || data.message || data.error);
|
||||||
throw new Error(detail || `request failed: ${response.status}`);
|
const err = new Error(detail || `request failed: ${response.status}`);
|
||||||
|
err.status = response.status;
|
||||||
|
throw err;
|
||||||
}
|
}
|
||||||
return data;
|
return data;
|
||||||
}
|
}
|
||||||
@@ -20,10 +27,6 @@ export async function loadSession(config) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export function signInUrl(config) {
|
export function signInUrl(config) {
|
||||||
// Always prefer authorizeUrl. The dashboard's login cookie is host-locked to
|
|
||||||
// the dashboard's own origin, so sending the browser straight to loginUrl
|
|
||||||
// signs the user in *there* and bounces back here still signed out.
|
|
||||||
// authorizeUrl hands this origin a code it trades for its own session.
|
|
||||||
const target = config.auth?.authorizeUrl || config.auth?.loginUrl;
|
const target = config.auth?.authorizeUrl || config.auth?.loginUrl;
|
||||||
if (!target) return null;
|
if (!target) return null;
|
||||||
const next = encodeURIComponent(
|
const next = encodeURIComponent(
|
||||||
@@ -32,54 +35,32 @@ export function signInUrl(config) {
|
|||||||
return `${target}${target.includes("?") ? "&" : "?"}next=${next}`;
|
return `${target}${target.includes("?") ? "&" : "?"}next=${next}`;
|
||||||
}
|
}
|
||||||
|
|
||||||
export async function requireSession(config) {
|
|
||||||
const session = await loadSession(config);
|
|
||||||
if (!session?.authenticated) {
|
|
||||||
const target = signInUrl(config);
|
|
||||||
if (target) window.location.assign(target);
|
|
||||||
throw new Error("sign in required");
|
|
||||||
}
|
|
||||||
return session;
|
|
||||||
}
|
|
||||||
|
|
||||||
export async function callSkill(config, skillName, args) {
|
export async function callSkill(config, skillName, args) {
|
||||||
if (config.auth?.invokeRequiresSession) {
|
return requestJson(`${config.endpoints.invoke}/${encodeURIComponent(skillName)}`, {
|
||||||
await requireSession(config);
|
method: "POST",
|
||||||
}
|
headers: { "content-type": "application/json" },
|
||||||
return requestJson(
|
body: JSON.stringify({ arguments: args }),
|
||||||
`${config.endpoints.invoke}/${encodeURIComponent(skillName)}`,
|
});
|
||||||
{
|
|
||||||
method: "POST",
|
|
||||||
headers: { "content-type": "application/json" },
|
|
||||||
body: JSON.stringify({ arguments: args }),
|
|
||||||
},
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export function sampleValue(schema) {
|
export async function fileToBrowserDocument(file, maxBytes = 128000) {
|
||||||
if (!schema || typeof schema !== "object") return null;
|
if (file.size > maxBytes) {
|
||||||
if ("default" in schema) return schema.default;
|
throw new Error(`${file.name} is too large. Upload files up to ${Math.round(maxBytes / 1000)} KB.`);
|
||||||
if ("const" in schema) return schema.const;
|
|
||||||
if (Array.isArray(schema.enum) && schema.enum.length) return schema.enum[0];
|
|
||||||
const type = Array.isArray(schema.type)
|
|
||||||
? schema.type.find((item) => item !== "null") || schema.type[0]
|
|
||||||
: schema.type;
|
|
||||||
if (type === "array") return [];
|
|
||||||
if (type === "boolean") return false;
|
|
||||||
if (type === "integer" || type === "number") return 0;
|
|
||||||
if (type === "string") return "";
|
|
||||||
const props = schema.properties || {};
|
|
||||||
if (type === "object" || Object.keys(props).length) {
|
|
||||||
const required = Array.isArray(schema.required) ? schema.required : Object.keys(props);
|
|
||||||
return Object.fromEntries(
|
|
||||||
required.map((key) => [key, sampleValue(props[key])]),
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
return null;
|
const mediaType = file.type || (file.name.endsWith(".json") ? "application/json" : file.name.endsWith(".csv") ? "text/csv" : "text/plain");
|
||||||
}
|
if (!["text/csv", "text/plain", "application/json"].includes(mediaType)) {
|
||||||
|
throw new Error(`${file.name} must be CSV, JSON, or plain text.`);
|
||||||
export function sampleArgs(skill) {
|
}
|
||||||
const schema = skill?.input_schema || skill?.inputSchema || {};
|
const buffer = await file.arrayBuffer();
|
||||||
const value = sampleValue(schema);
|
let binary = "";
|
||||||
return value && typeof value === "object" && !Array.isArray(value) ? value : {};
|
const bytes = new Uint8Array(buffer);
|
||||||
|
const chunkSize = 0x8000;
|
||||||
|
for (let i = 0; i < bytes.length; i += chunkSize) {
|
||||||
|
binary += String.fromCharCode(...bytes.subarray(i, i + chunkSize));
|
||||||
|
}
|
||||||
|
return {
|
||||||
|
filename: file.name,
|
||||||
|
media_type: mediaType,
|
||||||
|
data_base64: btoa(binary),
|
||||||
|
};
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user