File size: 2,552 Bytes
3d700dd | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 | import type { SkillInfo } from "#/types/settings";
import { getActiveBackend } from "../backend-registry/active-store";
import type { Backend } from "../backend-registry/types";
import { callCloudProxy } from "./proxy";
interface CloudSkillsPage {
items: SkillInfo[];
next_page_id: string | null;
}
const PAGE_LIMIT = 100;
function getActiveCloudBackend(): Backend {
const active = getActiveBackend().backend;
if (active.kind !== "cloud") {
throw new Error("Cloud skills call requires a cloud backend.");
}
return active;
}
/**
* Fetch the full list of skills from the cloud backend. The cloud endpoint is
* paginated (page_id cursor); we walk all pages so the settings UI gets a
* complete list in one call. The cloud SkillInfo shape
* (name/type/source/triggers) matches the GUI's SkillInfo type, so items are
* passed through unchanged.
*/
export async function fetchCloudSkills(): Promise<SkillInfo[]> {
const backend = getActiveCloudBackend();
const skills: SkillInfo[] = [];
let pageId: string | null = null;
do {
const query = new URLSearchParams({ limit: String(PAGE_LIMIT) });
if (pageId) query.set("page_id", pageId);
const page = await callCloudProxy<CloudSkillsPage>({
backend,
method: "GET",
path: `/api/v1/skills/search?${query.toString()}`,
});
skills.push(...(page.items ?? []));
pageId = page.next_page_id;
} while (pageId);
return skills;
}
interface CloudConversationSkill {
name: string;
type: SkillInfo["type"];
content: string;
triggers: string[];
}
interface CloudConversationSkillsResponse {
skills: CloudConversationSkill[];
}
/**
* Fetch the skills loaded into a running cloud conversation from the
* per-conversation route (the one the OpenHands web UI's own "Show Available
* Skills" modal uses). Unlike `/api/v1/skills/search`, which only scans the
* API host's built-in skills directory, this resolves the conversation's
* sandbox and asks its agent-server for the merged set: public catalog,
* user/org repos, project skills and auto-loaded marketplace plugins. The
* route reports no `source`, so it is `null`.
*/
export async function fetchCloudConversationSkills(
conversationId: string,
): Promise<SkillInfo[]> {
const backend = getActiveCloudBackend();
const data = await callCloudProxy<CloudConversationSkillsResponse>({
backend,
method: "GET",
path: `/api/v1/app-conversations/${conversationId}/skills`,
});
return (data?.skills ?? []).map((skill) => ({ ...skill, source: null }));
}
|