129 lines
4.8 KiB
JavaScript
129 lines
4.8 KiB
JavaScript
"use strict";
|
|
var __defProp = Object.defineProperty;
|
|
var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
|
|
var __getOwnPropNames = Object.getOwnPropertyNames;
|
|
var __hasOwnProp = Object.prototype.hasOwnProperty;
|
|
var __export = (target, all) => {
|
|
for (var name in all)
|
|
__defProp(target, name, { get: all[name], enumerable: true });
|
|
};
|
|
var __copyProps = (to, from, except, desc) => {
|
|
if (from && typeof from === "object" || typeof from === "function") {
|
|
for (let key of __getOwnPropNames(from))
|
|
if (!__hasOwnProp.call(to, key) && key !== except)
|
|
__defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });
|
|
}
|
|
return to;
|
|
};
|
|
var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);
|
|
var AgentDispatchClient_exports = {};
|
|
__export(AgentDispatchClient_exports, {
|
|
AgentDispatchClient: () => AgentDispatchClient
|
|
});
|
|
module.exports = __toCommonJS(AgentDispatchClient_exports);
|
|
var import_protocol = require("@livekit/protocol");
|
|
var import_ServiceBase = require("./ServiceBase.cjs");
|
|
var import_TwirpRPC = require("./TwirpRPC.cjs");
|
|
const svc = "AgentDispatchService";
|
|
class AgentDispatchClient extends import_ServiceBase.ServiceBase {
|
|
/**
|
|
* @param host - hostname including protocol. i.e. 'https://<project>.livekit.cloud'
|
|
* @param apiKey - API Key, can be set in env var LIVEKIT_API_KEY
|
|
* @param secret - API Secret, can be set in env var LIVEKIT_API_SECRET
|
|
* @param options - client options
|
|
*/
|
|
constructor(host, apiKey, secret, options) {
|
|
super({ apiKey, secret, token: options == null ? void 0 : options.token });
|
|
this.rpc = new import_TwirpRPC.TwirpRpc(host, import_TwirpRPC.livekitPackage, {
|
|
requestTimeout: options == null ? void 0 : options.requestTimeout,
|
|
failover: options == null ? void 0 : options.failover
|
|
});
|
|
}
|
|
/**
|
|
* Create an explicit dispatch for an agent to join a room. To use explicit
|
|
* dispatch, your agent must be registered with an `agentName`.
|
|
* @param roomName - name of the room to dispatch to
|
|
* @param agentName - name of the agent to dispatch
|
|
* @param options - optional metadata to send along with the dispatch
|
|
* @returns the dispatch that was created
|
|
*/
|
|
async createDispatch(roomName, agentName, options) {
|
|
const req = new import_protocol.CreateAgentDispatchRequest({
|
|
room: roomName,
|
|
agentName,
|
|
metadata: options == null ? void 0 : options.metadata,
|
|
restartPolicy: options == null ? void 0 : options.restartPolicy,
|
|
deployment: options == null ? void 0 : options.deployment
|
|
}).toJson();
|
|
const data = await this.rpc.request(
|
|
svc,
|
|
"CreateDispatch",
|
|
req,
|
|
await this.authHeader({ roomAdmin: true, room: roomName })
|
|
);
|
|
return import_protocol.AgentDispatch.fromJson(data, { ignoreUnknownFields: true });
|
|
}
|
|
/**
|
|
* Delete an explicit dispatch for an agent in a room.
|
|
* @param dispatchId - id of the dispatch to delete
|
|
* @param roomName - name of the room the dispatch is for
|
|
*/
|
|
async deleteDispatch(dispatchId, roomName) {
|
|
const req = new import_protocol.DeleteAgentDispatchRequest({
|
|
dispatchId,
|
|
room: roomName
|
|
}).toJson();
|
|
await this.rpc.request(
|
|
svc,
|
|
"DeleteDispatch",
|
|
req,
|
|
await this.authHeader({ roomAdmin: true, room: roomName })
|
|
);
|
|
}
|
|
/**
|
|
* Get an Agent dispatch by ID
|
|
* @param dispatchId - id of the dispatch to get
|
|
* @param roomName - name of the room the dispatch is for
|
|
* @returns the dispatch that was found, or undefined if not found
|
|
*/
|
|
async getDispatch(dispatchId, roomName) {
|
|
const req = new import_protocol.ListAgentDispatchRequest({
|
|
dispatchId,
|
|
room: roomName
|
|
}).toJson();
|
|
const data = await this.rpc.request(
|
|
svc,
|
|
"ListDispatch",
|
|
req,
|
|
await this.authHeader({ roomAdmin: true, room: roomName })
|
|
);
|
|
const res = import_protocol.ListAgentDispatchResponse.fromJson(data, { ignoreUnknownFields: true });
|
|
if (res.agentDispatches.length === 0) {
|
|
return void 0;
|
|
}
|
|
return res.agentDispatches[0];
|
|
}
|
|
/**
|
|
* List all agent dispatches for a room
|
|
* @param roomName - name of the room to list dispatches for
|
|
* @returns the list of dispatches
|
|
*/
|
|
async listDispatch(roomName) {
|
|
const req = new import_protocol.ListAgentDispatchRequest({
|
|
room: roomName
|
|
}).toJson();
|
|
const data = await this.rpc.request(
|
|
svc,
|
|
"ListDispatch",
|
|
req,
|
|
await this.authHeader({ roomAdmin: true, room: roomName })
|
|
);
|
|
const res = import_protocol.ListAgentDispatchResponse.fromJson(data, { ignoreUnknownFields: true });
|
|
return res.agentDispatches;
|
|
}
|
|
}
|
|
// Annotate the CommonJS export names for ESM import in node:
|
|
0 && (module.exports = {
|
|
AgentDispatchClient
|
|
});
|
|
//# sourceMappingURL=AgentDispatchClient.cjs.map
|