Spaces:
Sleeping
Sleeping
| export class HttpRuntimeClient { | |
| baseUrl; | |
| controlToken; | |
| constructor(baseUrl = process.env.WA_AGENT_RUNTIME_URL ?? "http://127.0.0.1:8787") { | |
| this.baseUrl = baseUrl.replace(/\/$/, ""); | |
| this.controlToken = nonEmptyEnv("WA_AGENT_CONTROL_TOKEN") ?? nonEmptyEnv("WA_AGENT_BRIDGE_SECRET"); | |
| } | |
| async listSessions() { | |
| const response = await this.request("/sessions"); | |
| return response.sessions; | |
| } | |
| getSession(sessionId) { | |
| return this.request(`/sessions/${encodeURIComponent(sessionId)}`); | |
| } | |
| enqueueAction(sessionId, action) { | |
| return this.request(`/sessions/${encodeURIComponent(sessionId)}/actions`, { | |
| method: "POST", | |
| body: { action }, | |
| }); | |
| } | |
| say(sessionId, text, options = {}) { | |
| return this.request(`/sessions/${encodeURIComponent(sessionId)}/say`, { | |
| method: "POST", | |
| body: { | |
| text, | |
| channel: options.channel ?? "bubble", | |
| voice: options.voice ?? false, | |
| }, | |
| }); | |
| } | |
| speak(sessionId, text) { | |
| return this.request(`/sessions/${encodeURIComponent(sessionId)}/speak`, { | |
| method: "POST", | |
| body: { text }, | |
| }); | |
| } | |
| sendAgentMessage(targetSessionId, fromSessionId, message, data) { | |
| return this.request(`/sessions/${encodeURIComponent(targetSessionId)}/agent-messages`, { | |
| method: "POST", | |
| body: { | |
| fromSessionId, | |
| message, | |
| data, | |
| }, | |
| }); | |
| } | |
| async createBridgeUrl(options) { | |
| const url = new URL("/workadventure/bridge-url", this.baseUrl); | |
| url.searchParams.set("session", options.sessionId); | |
| if (options.iframeApiUrl) { | |
| url.searchParams.set("waApi", options.iframeApiUrl); | |
| } | |
| const response = await this.request(url.pathname + url.search); | |
| return response.url; | |
| } | |
| getHutterState() { | |
| return this.request("/hutter/state"); | |
| } | |
| getHutterEntity(entityId) { | |
| return this.request(`/hutter/entities/${encodeURIComponent(entityId)}`); | |
| } | |
| async submitHutterResult(input) { | |
| const response = await this.request("/hutter/results", { | |
| method: "POST", | |
| body: input, | |
| }); | |
| return response.result; | |
| } | |
| async postHutterMessage(input) { | |
| const response = await this.request("/hutter/messages", { | |
| method: "POST", | |
| body: input, | |
| }); | |
| return response.message; | |
| } | |
| getHutterLecture() { | |
| return this.request("/hutter/lecture"); | |
| } | |
| async startHutterLecture(input) { | |
| const response = await this.request("/hutter/lecture/start", { | |
| method: "POST", | |
| body: input, | |
| }); | |
| return response.lecture; | |
| } | |
| async nextHutterLectureSlide() { | |
| const response = await this.request("/hutter/lecture/next", { | |
| method: "POST", | |
| body: {}, | |
| }); | |
| return response.lecture; | |
| } | |
| async stopHutterLecture() { | |
| const response = await this.request("/hutter/lecture/stop", { | |
| method: "POST", | |
| body: {}, | |
| }); | |
| return response.lecture; | |
| } | |
| async addHutterLectureTranscript(input) { | |
| const response = await this.request("/hutter/lecture/transcript", { | |
| method: "POST", | |
| body: input, | |
| }); | |
| return response.lecture; | |
| } | |
| async request(path, options = {}) { | |
| const headers = {}; | |
| if (options.body !== undefined) { | |
| headers["Content-Type"] = "application/json"; | |
| } | |
| if (this.controlToken) { | |
| headers.Authorization = `Bearer ${this.controlToken}`; | |
| } | |
| const response = await fetch(`${this.baseUrl}${path}`, { | |
| method: options.method ?? "GET", | |
| headers: Object.keys(headers).length === 0 ? undefined : headers, | |
| body: options.body === undefined ? undefined : JSON.stringify(options.body), | |
| }); | |
| const text = await response.text(); | |
| const data = text ? JSON.parse(text) : undefined; | |
| if (!response.ok) { | |
| throw new Error(typeof data?.error === "string" ? data.error : `Runtime request failed with ${response.status}`); | |
| } | |
| return data; | |
| } | |
| } | |
| function nonEmptyEnv(name) { | |
| const value = process.env[name]?.trim(); | |
| return value ? value : undefined; | |
| } | |
| //# sourceMappingURL=runtimeClient.js.map |