🎩 You're Invited:Meet the Socket team at Black Hat in Las Vegas, August 3-6.RSVP →
Sign In

@mintlify/assistant-core

Package Overview
Dependencies
Maintainers
7
Versions
6
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@mintlify/assistant-core - npm Package Compare versions

Package was removed
Sorry, it seems this package was removed from the registry
Comparing version
0.0.4
 to
0.0.5
+4
-3
package.json
{
"name": "@mintlify/assistant-core",
"version": "0.0.4",
"version": "0.0.5",
"description": "Framework-independent state and transport core for Mintlify Assistant",

@@ -17,3 +17,4 @@ "type": "module",

"files": [
"dist",
"dist/**/*.d.ts",
"dist/**/*.js",
"examples"

@@ -31,3 +32,3 @@ ],

"scripts": {
"build": "tsc --project tsconfig.json",
"build": "yarn clean:build && tsc --project tsconfig.json",
"clean:build": "rimraf dist tsconfig.tsbuildinfo",

@@ -34,0 +35,0 @@ "clean:all": "rimraf node_modules .eslintcache && yarn clean:build",

-10
dist/cancellation.d.ts
import type { AssistantCancellationSignal } from './types.js';
export declare class CancellationController implements AssistantCancellationSignal {
private isAborted;
private readonly listeners;
get signal(): AssistantCancellationSignal;
get aborted(): boolean;
subscribe(listener: () => void): () => void;
abort(): void;
}
//# sourceMappingURL=cancellation.d.ts.map
-1
dist/cancellation.d.ts.map
{"version":3,"file":"cancellation.d.ts","sourceRoot":"","sources":["../src/cancellation.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,2BAA2B,EAAE,MAAM,YAAY,CAAC;AAE9D,qBAAa,sBAAuB,YAAW,2BAA2B;IACxE,OAAO,CAAC,SAAS,CAAS;IAC1B,OAAO,CAAC,QAAQ,CAAC,SAAS,CAAyB;IAEnD,IAAI,MAAM,IAAI,2BAA2B,CAExC;IAED,IAAI,OAAO,IAAI,OAAO,CAErB;IAED,SAAS,CAAC,QAAQ,EAAE,MAAM,IAAI,GAAG,MAAM,IAAI;IAY3C,KAAK,IAAI,IAAI;CAcd"}
-38
dist/cancellation.js
export class CancellationController {
constructor() {
this.isAborted = false;
this.listeners = new Set();
}
get signal() {
return this;
}
get aborted() {
return this.isAborted;
}
subscribe(listener) {
if (this.isAborted) {
listener();
return () => undefined;
}
this.listeners.add(listener);
return () => {
this.listeners.delete(listener);
};
}
abort() {
if (this.isAborted)
return;
this.isAborted = true;
const listeners = [...this.listeners];
this.listeners.clear();
for (const listener of listeners) {
try {
listener();
}
catch (_a) {
// One transport listener cannot prevent the remaining cancellation callbacks.
}
}
}
}
//# sourceMappingURL=cancellation.js.map
-1
dist/cancellation.js.map
{"version":3,"file":"cancellation.js","sourceRoot":"","sources":["../src/cancellation.ts"],"names":[],"mappings":"AAEA,MAAM,OAAO,sBAAsB;IAAnC;QACU,cAAS,GAAG,KAAK,CAAC;QACT,cAAS,GAAG,IAAI,GAAG,EAAc,CAAC;IAoCrD,CAAC;IAlCC,IAAI,MAAM;QACR,OAAO,IAAI,CAAC;IACd,CAAC;IAED,IAAI,OAAO;QACT,OAAO,IAAI,CAAC,SAAS,CAAC;IACxB,CAAC;IAED,SAAS,CAAC,QAAoB;QAC5B,IAAI,IAAI,CAAC,SAAS,EAAE,CAAC;YACnB,QAAQ,EAAE,CAAC;YACX,OAAO,GAAG,EAAE,CAAC,SAAS,CAAC;QACzB,CAAC;QAED,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QAC7B,OAAO,GAAG,EAAE;YACV,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC;QAClC,CAAC,CAAC;IACJ,CAAC;IAED,KAAK;QACH,IAAI,IAAI,CAAC,SAAS;YAAE,OAAO;QAE3B,IAAI,CAAC,SAAS,GAAG,IAAI,CAAC;QACtB,MAAM,SAAS,GAAG,CAAC,GAAG,IAAI,CAAC,SAAS,CAAC,CAAC;QACtC,IAAI,CAAC,SAAS,CAAC,KAAK,EAAE,CAAC;QACvB,KAAK,MAAM,QAAQ,IAAI,SAAS,EAAE,CAAC;YACjC,IAAI,CAAC;gBACH,QAAQ,EAAE,CAAC;YACb,CAAC;YAAC,WAAM,CAAC;gBACP,8EAA8E;YAChF,CAAC;QACH,CAAC;IACH,CAAC;CACF"}
-10
dist/constants.d.ts
/** Supported Assistant surfaces sent with message and feedback requests. */
export declare const ASSISTANT_SURFACES: readonly ("floating-widget" | "custom-trigger" | "headless")[];
/**
* Compatibility major for the public Assistant core contract.
*
* This is intentionally independent from the npm package version. The core sends it as
* `coreVersion` so the service can make compatibility and deprecation decisions.
*/
export declare const ASSISTANT_CORE_API_VERSION = "1";
//# sourceMappingURL=constants.d.ts.map
-1
dist/constants.d.ts.map
{"version":3,"file":"constants.d.ts","sourceRoot":"","sources":["../src/constants.ts"],"names":[],"mappings":"AAEA,4EAA4E;AAC5E,eAAO,MAAM,kBAAkB,gEAIa,CAAC;AAE7C;;;;;GAKG;AACH,eAAO,MAAM,0BAA0B,MAAM,CAAC"}
-14
dist/constants.js
/** Supported Assistant surfaces sent with message and feedback requests. */
export const ASSISTANT_SURFACES = Object.freeze([
'floating-widget',
'custom-trigger',
'headless',
]);
/**
* Compatibility major for the public Assistant core contract.
*
* This is intentionally independent from the npm package version. The core sends it as
* `coreVersion` so the service can make compatibility and deprecation decisions.
*/
export const ASSISTANT_CORE_API_VERSION = '1';
//# sourceMappingURL=constants.js.map
-1
dist/constants.js.map
{"version":3,"file":"constants.js","sourceRoot":"","sources":["../src/constants.ts"],"names":[],"mappings":"AAEA,4EAA4E;AAC5E,MAAM,CAAC,MAAM,kBAAkB,GAAG,MAAM,CAAC,MAAM,CAAC;IAC9C,iBAAiB;IACjB,gBAAgB;IAChB,UAAU;CACX,CAA2C,CAAC;AAE7C;;;;;GAKG;AACH,MAAM,CAAC,MAAM,0BAA0B,GAAG,GAAG,CAAC"}
-3
dist/core.d.ts
import type { AssistantCore, AssistantCoreOptions } from './types.js';
export declare function createAssistantCore(options: AssistantCoreOptions): AssistantCore;
//# sourceMappingURL=core.d.ts.map
-1
dist/core.d.ts.map
{"version":3,"file":"core.d.ts","sourceRoot":"","sources":["../src/core.ts"],"names":[],"mappings":"AAGA,OAAO,KAAK,EAEV,aAAa,EACb,oBAAoB,EAWrB,MAAM,YAAY,CAAC;AAqBpB,wBAAgB,mBAAmB,CAAC,OAAO,EAAE,oBAAoB,GAAG,aAAa,CA2bhF"}
-477
dist/core.js
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
var __asyncValues = (this && this.__asyncValues) || function (o) {
if (!Symbol.asyncIterator) throw new TypeError("Symbol.asyncIterator is not defined.");
var m = o[Symbol.asyncIterator], i;
return m ? m.call(o) : (o = typeof __values === "function" ? __values(o) : o[Symbol.iterator](), i = {}, verb("next"), verb("throw"), verb("return"), i[Symbol.asyncIterator] = function () { return this; }, i);
function verb(n) { i[n] = o[n] && function (v) { return new Promise(function (resolve, reject) { v = o[n](v), settle(resolve, reject, v.done, v.value); }); }; }
function settle(resolve, reject, d, v) { Promise.resolve(v).then(function(v) { resolve({ value: v, done: d }); }, reject); }
};
import { CancellationController } from './cancellation.js';
import { ASSISTANT_CORE_API_VERSION } from './constants.js';
import { AssistantError, getUnavailableForError, normalizeAssistantError } from './errors.js';
let nextDefaultId = 0;
const AVAILABLE = {
unavailable: false,
type: null,
message: '',
};
export function createAssistantCore(options) {
var _a;
const listeners = new Set();
const metadataByMessageId = new Map();
const createId = (_a = options.createId) !== null && _a !== void 0 ? _a : createDefaultId;
const persistedContinuation = loadContinuation(options);
let nextOperationId = 0;
let activeOperation;
let destroyed = false;
let snapshot = {
status: 'ready',
messages: [],
data: [],
context: copyContext(options.context),
threadId: persistedContinuation === null || persistedContinuation === void 0 ? void 0 : persistedContinuation.threadId,
threadKey: persistedContinuation === null || persistedContinuation === void 0 ? void 0 : persistedContinuation.threadKey,
unavailable: AVAILABLE,
};
const publish = (nextSnapshot) => {
snapshot = nextSnapshot;
for (const listener of [...listeners]) {
if (!listeners.has(listener))
continue;
try {
listener(snapshot);
}
catch (_a) {
// A consumer callback cannot prevent other subscribers from receiving state.
}
}
};
const emitLifecycleEvent = (event) => {
var _a;
try {
(_a = options.onEvent) === null || _a === void 0 ? void 0 : _a.call(options, event);
}
catch (_b) {
// Analytics and other observers must not affect core state transitions.
}
};
const detachActiveOperation = () => {
const operation = activeOperation;
activeOperation = undefined;
return operation;
};
const abort = () => {
const operation = detachActiveOperation();
if (operation === undefined)
return;
const messages = markAssistantMessageAborted(snapshot.messages, operation.assistantMessageId);
publish(Object.assign(Object.assign({}, snapshot), { status: 'ready', messages, error: undefined }));
operation.controller.abort();
};
const beginOperation = (surface, entryPoint) => {
const operation = {
id: ++nextOperationId,
controller: new CancellationController(),
surface,
entryPoint,
};
activeOperation = operation;
return operation;
};
const runOperation = (operation, userMessage, regenerate) => __awaiter(this, void 0, void 0, function* () {
var _a, e_1, _b, _c;
var _d, _e, _f, _g, _h;
const request = {
messages: snapshot.messages,
surface: operation.surface,
entryPoint: operation.entryPoint,
loaderVersion: options.metadata.loaderVersion,
coreVersion: ASSISTANT_CORE_API_VERSION,
context: (_d = userMessage.context) === null || _d === void 0 ? void 0 : _d.items,
currentPath: (_e = userMessage.context) === null || _e === void 0 ? void 0 : _e.currentPath,
version: (_f = userMessage.context) === null || _f === void 0 ? void 0 : _f.version,
language: (_g = userMessage.context) === null || _g === void 0 ? void 0 : _g.language,
product: (_h = userMessage.context) === null || _h === void 0 ? void 0 : _h.product,
threadId: snapshot.threadId,
threadKey: snapshot.threadKey,
regenerate: regenerate || undefined,
};
try {
try {
for (var _j = true, _k = __asyncValues(options.transport.send(request, operation.controller.signal)), _l; _l = yield _k.next(), _a = _l.done, !_a; _j = true) {
_c = _l.value;
_j = false;
const event = _c;
if (!isCurrentOperation(operation))
return snapshot;
applyTransportEvent(operation, event);
}
}
catch (e_1_1) { e_1 = { error: e_1_1 }; }
finally {
try {
if (!_j && !_a && (_b = _k.return)) yield _b.call(_k);
}
finally { if (e_1) throw e_1.error; }
}
if (!isCurrentOperation(operation))
return snapshot;
finishOperation(operation);
return snapshot;
}
catch (error) {
if (operation.controller.signal.aborted || !isCurrentOperation(operation))
return snapshot;
activeOperation = undefined;
const normalizedError = normalizeAssistantError(error);
const errorSnapshot = normalizedError.toSnapshot();
const messages = markAssistantMessageErrored(snapshot.messages, operation.assistantMessageId);
publish(Object.assign(Object.assign({}, snapshot), { status: 'error', messages, error: errorSnapshot, unavailable: getUnavailableForError(normalizedError) }));
emitLifecycleEvent({
type: 'errored',
error: errorSnapshot,
metadata: getOperationMetadata(options.metadata, operation),
});
throw normalizedError;
}
});
const applyTransportEvent = (operation, event) => {
var _a, _b;
if (event.type === 'start') {
const serverMessageId = (_a = event.messageId) !== null && _a !== void 0 ? _a : operation.serverMessageId;
operation.serverMessageId = serverMessageId;
const { threadId, threadKey } = resolveContinuation(event.threadId, event.threadKey);
const { assistantMessage, messages } = ensureAssistantMessage(operation, snapshot.messages);
const nextMessages = serverMessageId === undefined || assistantMessage.messageId === serverMessageId
? messages
: replaceMessage(messages, Object.assign(Object.assign({}, assistantMessage), { messageId: serverMessageId }));
if (event.threadId !== undefined || event.threadKey !== undefined) {
saveContinuation(options, threadId, threadKey);
}
publish(Object.assign(Object.assign({}, snapshot), { status: 'streaming', messages: nextMessages, threadId, threadKey }));
return;
}
if (event.type === 'text-delta') {
const { assistantMessage, messages } = ensureAssistantMessage(operation, snapshot.messages);
const content = `${assistantMessage.content}${event.delta}`;
publish(Object.assign(Object.assign({}, snapshot), { status: 'streaming', messages: replaceMessage(messages, Object.assign(Object.assign({}, assistantMessage), { content, parts: appendTextDelta(assistantMessage.parts, event.delta), status: 'streaming' })) }));
return;
}
if (event.type === 'message') {
operation.serverMessageId = (_b = event.messageId) !== null && _b !== void 0 ? _b : operation.serverMessageId;
const { assistantMessage, messages } = ensureAssistantMessage(operation, snapshot.messages);
publish(Object.assign(Object.assign({}, snapshot), { status: 'streaming', messages: replaceMessage(messages, Object.assign(Object.assign({}, assistantMessage), { content: event.content, parts: event.parts === undefined ? partsForContent(event.content) : [...event.parts], status: 'streaming', messageId: operation.serverMessageId })) }));
return;
}
if (event.type === 'data') {
publish(Object.assign(Object.assign({}, snapshot), { data: [...snapshot.data, event.data] }));
return;
}
finishOperation(operation, event);
};
const ensureAssistantMessage = (operation, messages) => {
const existing = getMessage(messages, operation.assistantMessageId);
if (existing !== undefined)
return { assistantMessage: existing, messages };
const assistantMessage = {
id: createId(),
role: 'assistant',
content: '',
parts: [],
status: 'streaming',
messageId: operation.serverMessageId,
};
operation.assistantMessageId = assistantMessage.id;
metadataByMessageId.set(assistantMessage.id, getOperationMetadata(options.metadata, operation));
return {
assistantMessage,
messages: [...messages, assistantMessage],
};
};
const finishOperation = (operation, event) => {
var _a, _b, _c;
if (!isCurrentOperation(operation))
return;
operation.serverMessageId = (_a = event === null || event === void 0 ? void 0 : event.messageId) !== null && _a !== void 0 ? _a : operation.serverMessageId;
const { threadId, threadKey } = resolveContinuation(event === null || event === void 0 ? void 0 : event.threadId, event === null || event === void 0 ? void 0 : event.threadKey);
const { assistantMessage, messages } = ensureAssistantMessage(operation, snapshot.messages);
const content = (_b = event === null || event === void 0 ? void 0 : event.content) !== null && _b !== void 0 ? _b : assistantMessage.content;
const completeMessage = Object.assign(Object.assign({}, assistantMessage), { content, parts: (event === null || event === void 0 ? void 0 : event.parts) !== undefined
? [...event.parts]
: (event === null || event === void 0 ? void 0 : event.content) === undefined
? assistantMessage.parts
: partsForContent(content), status: 'complete', messageId: (_c = operation.serverMessageId) !== null && _c !== void 0 ? _c : assistantMessage.messageId });
activeOperation = undefined;
if ((event === null || event === void 0 ? void 0 : event.threadId) !== undefined || (event === null || event === void 0 ? void 0 : event.threadKey) !== undefined) {
saveContinuation(options, threadId, threadKey);
}
publish(Object.assign(Object.assign({}, snapshot), { status: 'ready', messages: replaceMessage(messages, completeMessage), threadId,
threadKey, error: undefined, unavailable: AVAILABLE }));
emitLifecycleEvent({
type: 'completed',
threadId: snapshot.threadId,
messageId: completeMessage.messageId,
metadata: getOperationMetadata(options.metadata, operation),
});
};
const resolveContinuation = (threadId, threadKey) => {
return {
threadId: threadId !== null && threadId !== void 0 ? threadId : snapshot.threadId,
threadKey: threadKey !== null && threadKey !== void 0 ? threadKey : snapshot.threadKey,
};
};
const isCurrentOperation = (operation) => {
return (activeOperation === null || activeOperation === void 0 ? void 0 : activeOperation.id) === operation.id && !destroyed;
};
const send = (input) => __awaiter(this, void 0, void 0, function* () {
var _a, _b, _c;
assertUsable(destroyed);
if (activeOperation !== undefined) {
throw new AssistantError({
code: 'invalid_state',
message: 'A message is already in progress.',
retryable: true,
});
}
if (input.content.trim().length === 0) {
throw new AssistantError({
code: 'invalid_input',
message: 'A message must contain text.',
retryable: true,
});
}
const context = copyContext((_a = input.context) !== null && _a !== void 0 ? _a : snapshot.context);
const surface = (_b = input.surface) !== null && _b !== void 0 ? _b : options.metadata.surface;
const entryPoint = (_c = input.entryPoint) !== null && _c !== void 0 ? _c : options.metadata.entryPoint;
const userMessage = {
id: createId(),
role: 'user',
content: input.content,
parts: partsForContent(input.content),
status: 'complete',
context,
};
metadataByMessageId.set(userMessage.id, resolveMetadata(options.metadata, surface, entryPoint));
const operation = beginOperation(surface, entryPoint);
publish(Object.assign(Object.assign({}, snapshot), { status: 'submitted', messages: [...snapshot.messages, userMessage], data: [], error: undefined, unavailable: AVAILABLE }));
if (!isCurrentOperation(operation))
return snapshot;
return runOperation(operation, userMessage, false);
});
const retry = () => __awaiter(this, void 0, void 0, function* () {
var _a;
assertUsable(destroyed);
if (activeOperation !== undefined) {
throw new AssistantError({
code: 'invalid_state',
message: 'A message is already in progress.',
retryable: true,
});
}
const userMessageIndex = findLastUserMessageIndex(snapshot.messages);
const userMessage = snapshot.messages[userMessageIndex];
if (userMessageIndex < 0 || userMessage === undefined) {
throw new AssistantError({
code: 'invalid_state',
message: 'There is no message to retry.',
retryable: false,
});
}
const metadata = (_a = metadataByMessageId.get(userMessage.id)) !== null && _a !== void 0 ? _a : resolveMetadata(options.metadata);
const operation = beginOperation(metadata.surface, metadata.entryPoint);
publish(Object.assign(Object.assign({}, snapshot), { status: 'submitted', messages: snapshot.messages.slice(0, userMessageIndex + 1), data: [], error: undefined, unavailable: AVAILABLE }));
if (!isCurrentOperation(operation))
return snapshot;
return runOperation(operation, userMessage, true);
});
const newThread = () => {
var _a;
assertUsable(destroyed);
const operation = detachActiveOperation();
metadataByMessageId.clear();
try {
(_a = options.storage) === null || _a === void 0 ? void 0 : _a.clearContinuation();
}
catch (_b) {
// Storage failures do not make the in-memory Assistant unusable.
}
publish({
status: 'ready',
messages: [],
data: [],
context: snapshot.context,
unavailable: AVAILABLE,
});
operation === null || operation === void 0 ? void 0 : operation.controller.abort();
emitLifecycleEvent({ type: 'new-thread', metadata: resolveMetadata(options.metadata) });
return snapshot;
};
const setContext = (context) => {
assertUsable(destroyed);
publish(Object.assign(Object.assign({}, snapshot), { context: copyContext(context) }));
};
const submitFeedback = (input) => __awaiter(this, void 0, void 0, function* () {
var _a;
assertUsable(destroyed);
const message = snapshot.messages.find((candidate) => candidate.role === 'assistant' &&
(candidate.id === input.messageId || candidate.messageId === input.messageId));
if ((message === null || message === void 0 ? void 0 : message.messageId) === undefined || message.status !== 'complete') {
throw new AssistantError({
code: 'invalid_input',
message: 'Feedback requires a completed Assistant message.',
retryable: false,
});
}
const metadata = (_a = metadataByMessageId.get(message.id)) !== null && _a !== void 0 ? _a : resolveMetadata(options.metadata);
yield options.transport.submitFeedback({
messageId: message.messageId,
feedback: input.feedback,
surface: metadata.surface,
entryPoint: metadata.entryPoint,
loaderVersion: metadata.loaderVersion,
coreVersion: metadata.coreVersion,
threadId: snapshot.threadId,
threadKey: snapshot.threadKey,
});
publish(Object.assign(Object.assign({}, snapshot), { messages: replaceMessage(snapshot.messages, Object.assign(Object.assign({}, message), { feedback: input.feedback })) }));
emitLifecycleEvent({
type: 'feedback-submitted',
messageId: message.messageId,
feedback: input.feedback,
metadata,
});
});
const subscribe = (listener) => {
assertUsable(destroyed);
listeners.add(listener);
return () => {
listeners.delete(listener);
};
};
const destroy = () => {
var _a, _b;
if (destroyed)
return;
const operation = detachActiveOperation();
destroyed = true;
metadataByMessageId.clear();
publish(Object.assign(Object.assign({}, snapshot), { status: 'destroyed', messages: markAssistantMessageAborted(snapshot.messages, operation === null || operation === void 0 ? void 0 : operation.assistantMessageId) }));
listeners.clear();
operation === null || operation === void 0 ? void 0 : operation.controller.abort();
(_b = (_a = options.transport).destroy) === null || _b === void 0 ? void 0 : _b.call(_a);
};
return {
send,
abort,
retry,
newThread,
setContext,
submitFeedback,
getSnapshot: () => snapshot,
subscribe,
destroy,
};
}
function copyContext(context) {
var _a;
if (context === undefined)
return undefined;
return {
items: (_a = context.items) === null || _a === void 0 ? void 0 : _a.map((item) => (Object.assign({}, item))),
currentPath: context.currentPath,
version: context.version,
language: context.language,
product: context.product,
};
}
function getOperationMetadata(metadata, operation) {
return resolveMetadata(metadata, operation.surface, operation.entryPoint);
}
function resolveMetadata(metadata, surface = metadata.surface, entryPoint = metadata.entryPoint) {
return Object.assign(Object.assign({}, metadata), { surface,
entryPoint, coreVersion: ASSISTANT_CORE_API_VERSION });
}
function createDefaultId() {
nextDefaultId += 1;
return `assistant-message-${nextDefaultId}`;
}
function partsForContent(content) {
return content.length === 0 ? [] : [{ type: 'text', text: content }];
}
function appendTextDelta(parts, delta) {
const lastPart = parts[parts.length - 1];
if ((lastPart === null || lastPart === void 0 ? void 0 : lastPart.type) === 'text') {
return [...parts.slice(0, -1), { type: 'text', text: `${lastPart.text}${delta}` }];
}
return [...parts, { type: 'text', text: delta }];
}
function getMessage(messages, id) {
if (id === undefined)
return undefined;
return messages.find((message) => message.id === id);
}
function replaceMessage(messages, message) {
return messages.map((candidate) => (candidate.id === message.id ? message : candidate));
}
function findLastUserMessageIndex(messages) {
var _a;
for (let index = messages.length - 1; index >= 0; index -= 1) {
if (((_a = messages[index]) === null || _a === void 0 ? void 0 : _a.role) === 'user')
return index;
}
return -1;
}
function markAssistantMessageAborted(messages, id) {
if (id === undefined)
return messages;
return messages.map((message) => message.id === id ? Object.assign(Object.assign({}, message), { status: 'aborted' }) : message);
}
function markAssistantMessageErrored(messages, id) {
if (id === undefined)
return messages;
return messages.map((message) => (message.id === id ? Object.assign(Object.assign({}, message), { status: 'error' }) : message));
}
function assertUsable(destroyed) {
if (!destroyed)
return;
throw new AssistantError({
code: 'destroyed',
message: 'This Assistant client has been destroyed.',
retryable: false,
});
}
function loadContinuation(options) {
var _a;
try {
const continuation = (_a = options.storage) === null || _a === void 0 ? void 0 : _a.loadContinuation();
if (continuation === undefined)
return undefined;
return {
threadId: continuation.threadId,
threadKey: continuation.threadKey,
};
}
catch (_b) {
return undefined;
}
}
function saveContinuation(options, threadId, threadKey) {
var _a;
if (threadId === undefined && threadKey === undefined)
return;
try {
(_a = options.storage) === null || _a === void 0 ? void 0 : _a.saveContinuation({ threadId, threadKey });
}
catch (_b) {
// Storage failures do not make the in-memory Assistant unusable.
}
}
//# sourceMappingURL=core.js.map
-1
dist/core.js.map
{"version":3,"file":"core.js","sourceRoot":"","sources":["../src/core.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;AAAA,OAAO,EAAE,sBAAsB,EAAE,MAAM,mBAAmB,CAAC;AAC3D,OAAO,EAAE,0BAA0B,EAAE,MAAM,gBAAgB,CAAC;AAC5D,OAAO,EAAE,cAAc,EAAE,sBAAsB,EAAE,uBAAuB,EAAE,MAAM,aAAa,CAAC;AAiB9F,IAAI,aAAa,GAAG,CAAC,CAAC;AAEtB,MAAM,SAAS,GAAG;IAChB,WAAW,EAAE,KAAK;IAClB,IAAI,EAAE,IAAI;IACV,OAAO,EAAE,EAAE;CACZ,CAAC;AAaF,MAAM,UAAU,mBAAmB,CAAC,OAA6B;;IAC/D,MAAM,SAAS,GAAG,IAAI,GAAG,EAAyC,CAAC;IACnE,MAAM,mBAAmB,GAAG,IAAI,GAAG,EAAsC,CAAC;IAC1E,MAAM,QAAQ,GAAG,MAAA,OAAO,CAAC,QAAQ,mCAAI,eAAe,CAAC;IACrD,MAAM,qBAAqB,GAAG,gBAAgB,CAAC,OAAO,CAAC,CAAC;IACxD,IAAI,eAAe,GAAG,CAAC,CAAC;IACxB,IAAI,eAA4C,CAAC;IACjD,IAAI,SAAS,GAAG,KAAK,CAAC;IACtB,IAAI,QAAQ,GAAsB;QAChC,MAAM,EAAE,OAAO;QACf,QAAQ,EAAE,EAAE;QACZ,IAAI,EAAE,EAAE;QACR,OAAO,EAAE,WAAW,CAAC,OAAO,CAAC,OAAO,CAAC;QACrC,QAAQ,EAAE,qBAAqB,aAArB,qBAAqB,uBAArB,qBAAqB,CAAE,QAAQ;QACzC,SAAS,EAAE,qBAAqB,aAArB,qBAAqB,uBAArB,qBAAqB,CAAE,SAAS;QAC3C,WAAW,EAAE,SAAS;KACvB,CAAC;IAEF,MAAM,OAAO,GAAG,CAAC,YAA+B,EAAQ,EAAE;QACxD,QAAQ,GAAG,YAAY,CAAC;QACxB,KAAK,MAAM,QAAQ,IAAI,CAAC,GAAG,SAAS,CAAC,EAAE,CAAC;YACtC,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,QAAQ,CAAC;gBAAE,SAAS;YACvC,IAAI,CAAC;gBACH,QAAQ,CAAC,QAAQ,CAAC,CAAC;YACrB,CAAC;YAAC,WAAM,CAAC;gBACP,6EAA6E;YAC/E,CAAC;QACH,CAAC;IACH,CAAC,CAAC;IAEF,MAAM,kBAAkB,GAAG,CAAC,KAA8B,EAAQ,EAAE;;QAClE,IAAI,CAAC;YACH,MAAA,OAAO,CAAC,OAAO,wDAAG,KAAK,CAAC,CAAC;QAC3B,CAAC;QAAC,WAAM,CAAC;YACP,wEAAwE;QAC1E,CAAC;IACH,CAAC,CAAC;IAEF,MAAM,qBAAqB,GAAG,GAAgC,EAAE;QAC9D,MAAM,SAAS,GAAG,eAAe,CAAC;QAClC,eAAe,GAAG,SAAS,CAAC;QAC5B,OAAO,SAAS,CAAC;IACnB,CAAC,CAAC;IAEF,MAAM,KAAK,GAAG,GAAS,EAAE;QACvB,MAAM,SAAS,GAAG,qBAAqB,EAAE,CAAC;QAC1C,IAAI,SAAS,KAAK,SAAS;YAAE,OAAO;QAEpC,MAAM,QAAQ,GAAG,2BAA2B,CAAC,QAAQ,CAAC,QAAQ,EAAE,SAAS,CAAC,kBAAkB,CAAC,CAAC;QAC9F,OAAO,iCACF,QAAQ,KACX,MAAM,EAAE,OAAO,EACf,QAAQ,EACR,KAAK,EAAE,SAAS,IAChB,CAAC;QACH,SAAS,CAAC,UAAU,CAAC,KAAK,EAAE,CAAC;IAC/B,CAAC,CAAC;IAEF,MAAM,cAAc,GAAG,CACrB,OAAqC,EACrC,UAAkB,EACD,EAAE;QACnB,MAAM,SAAS,GAAoB;YACjC,EAAE,EAAE,EAAE,eAAe;YACrB,UAAU,EAAE,IAAI,sBAAsB,EAAE;YACxC,OAAO;YACP,UAAU;SACX,CAAC;QACF,eAAe,GAAG,SAAS,CAAC;QAC5B,OAAO,SAAS,CAAC;IACnB,CAAC,CAAC;IAEF,MAAM,YAAY,GAAG,CACnB,SAA0B,EAC1B,WAA6B,EAC7B,UAAmB,EACS,EAAE;;;QAC9B,MAAM,OAAO,GAAkC;YAC7C,QAAQ,EAAE,QAAQ,CAAC,QAAQ;YAC3B,OAAO,EAAE,SAAS,CAAC,OAAO;YAC1B,UAAU,EAAE,SAAS,CAAC,UAAU;YAChC,aAAa,EAAE,OAAO,CAAC,QAAQ,CAAC,aAAa;YAC7C,WAAW,EAAE,0BAA0B;YACvC,OAAO,EAAE,MAAA,WAAW,CAAC,OAAO,0CAAE,KAAK;YACnC,WAAW,EAAE,MAAA,WAAW,CAAC,OAAO,0CAAE,WAAW;YAC7C,OAAO,EAAE,MAAA,WAAW,CAAC,OAAO,0CAAE,OAAO;YACrC,QAAQ,EAAE,MAAA,WAAW,CAAC,OAAO,0CAAE,QAAQ;YACvC,OAAO,EAAE,MAAA,WAAW,CAAC,OAAO,0CAAE,OAAO;YACrC,QAAQ,EAAE,QAAQ,CAAC,QAAQ;YAC3B,SAAS,EAAE,QAAQ,CAAC,SAAS;YAC7B,UAAU,EAAE,UAAU,IAAI,SAAS;SACpC,CAAC;QAEF,IAAI,CAAC;;gBACH,KAA0B,eAAA,KAAA,cAAA,OAAO,CAAC,SAAS,CAAC,IAAI,CAAC,OAAO,EAAE,SAAS,CAAC,UAAU,CAAC,MAAM,CAAC,CAAA,IAAA,sDAAE,CAAC;oBAA/D,cAA4D;oBAA5D,WAA4D;oBAA3E,MAAM,KAAK,KAAA,CAAA;oBACpB,IAAI,CAAC,kBAAkB,CAAC,SAAS,CAAC;wBAAE,OAAO,QAAQ,CAAC;oBACpD,mBAAmB,CAAC,SAAS,EAAE,KAAK,CAAC,CAAC;gBACxC,CAAC;;;;;;;;;YAED,IAAI,CAAC,kBAAkB,CAAC,SAAS,CAAC;gBAAE,OAAO,QAAQ,CAAC;YACpD,eAAe,CAAC,SAAS,CAAC,CAAC;YAC3B,OAAO,QAAQ,CAAC;QAClB,CAAC;QAAC,OAAO,KAAK,EAAE,CAAC;YACf,IAAI,SAAS,CAAC,UAAU,CAAC,MAAM,CAAC,OAAO,IAAI,CAAC,kBAAkB,CAAC,SAAS,CAAC;gBAAE,OAAO,QAAQ,CAAC;YAE3F,eAAe,GAAG,SAAS,CAAC;YAC5B,MAAM,eAAe,GAAG,uBAAuB,CAAC,KAAK,CAAC,CAAC;YACvD,MAAM,aAAa,GAAG,eAAe,CAAC,UAAU,EAAE,CAAC;YACnD,MAAM,QAAQ,GAAG,2BAA2B,CAAC,QAAQ,CAAC,QAAQ,EAAE,SAAS,CAAC,kBAAkB,CAAC,CAAC;YAC9F,OAAO,iCACF,QAAQ,KACX,MAAM,EAAE,OAAO,EACf,QAAQ,EACR,KAAK,EAAE,aAAa,EACpB,WAAW,EAAE,sBAAsB,CAAC,eAAe,CAAC,IACpD,CAAC;YACH,kBAAkB,CAAC;gBACjB,IAAI,EAAE,SAAS;gBACf,KAAK,EAAE,aAAa;gBACpB,QAAQ,EAAE,oBAAoB,CAAC,OAAO,CAAC,QAAQ,EAAE,SAAS,CAAC;aAC5D,CAAC,CAAC;YACH,MAAM,eAAe,CAAC;QACxB,CAAC;IACH,CAAC,CAAA,CAAC;IAEF,MAAM,mBAAmB,GAAG,CAC1B,SAA0B,EAC1B,KAA8B,EACxB,EAAE;;QACR,IAAI,KAAK,CAAC,IAAI,KAAK,OAAO,EAAE,CAAC;YAC3B,MAAM,eAAe,GAAG,MAAA,KAAK,CAAC,SAAS,mCAAI,SAAS,CAAC,eAAe,CAAC;YACrE,SAAS,CAAC,eAAe,GAAG,eAAe,CAAC;YAC5C,MAAM,EAAE,QAAQ,EAAE,SAAS,EAAE,GAAG,mBAAmB,CAAC,KAAK,CAAC,QAAQ,EAAE,KAAK,CAAC,SAAS,CAAC,CAAC;YACrF,MAAM,EAAE,gBAAgB,EAAE,QAAQ,EAAE,GAAG,sBAAsB,CAAC,SAAS,EAAE,QAAQ,CAAC,QAAQ,CAAC,CAAC;YAC5F,MAAM,YAAY,GAChB,eAAe,KAAK,SAAS,IAAI,gBAAgB,CAAC,SAAS,KAAK,eAAe;gBAC7E,CAAC,CAAC,QAAQ;gBACV,CAAC,CAAC,cAAc,CAAC,QAAQ,kCAAO,gBAAgB,KAAE,SAAS,EAAE,eAAe,IAAG,CAAC;YACpF,IAAI,KAAK,CAAC,QAAQ,KAAK,SAAS,IAAI,KAAK,CAAC,SAAS,KAAK,SAAS,EAAE,CAAC;gBAClE,gBAAgB,CAAC,OAAO,EAAE,QAAQ,EAAE,SAAS,CAAC,CAAC;YACjD,CAAC;YACD,OAAO,iCAAM,QAAQ,KAAE,MAAM,EAAE,WAAW,EAAE,QAAQ,EAAE,YAAY,EAAE,QAAQ,EAAE,SAAS,IAAG,CAAC;YAC3F,OAAO;QACT,CAAC;QAED,IAAI,KAAK,CAAC,IAAI,KAAK,YAAY,EAAE,CAAC;YAChC,MAAM,EAAE,gBAAgB,EAAE,QAAQ,EAAE,GAAG,sBAAsB,CAAC,SAAS,EAAE,QAAQ,CAAC,QAAQ,CAAC,CAAC;YAC5F,MAAM,OAAO,GAAG,GAAG,gBAAgB,CAAC,OAAO,GAAG,KAAK,CAAC,KAAK,EAAE,CAAC;YAC5D,OAAO,iCACF,QAAQ,KACX,MAAM,EAAE,WAAW,EACnB,QAAQ,EAAE,cAAc,CAAC,QAAQ,kCAC5B,gBAAgB,KACnB,OAAO,EACP,KAAK,EAAE,eAAe,CAAC,gBAAgB,CAAC,KAAK,EAAE,KAAK,CAAC,KAAK,CAAC,EAC3D,MAAM,EAAE,WAAW,IACnB,IACF,CAAC;YACH,OAAO;QACT,CAAC;QAED,IAAI,KAAK,CAAC,IAAI,KAAK,SAAS,EAAE,CAAC;YAC7B,SAAS,CAAC,eAAe,GAAG,MAAA,KAAK,CAAC,SAAS,mCAAI,SAAS,CAAC,eAAe,CAAC;YACzE,MAAM,EAAE,gBAAgB,EAAE,QAAQ,EAAE,GAAG,sBAAsB,CAAC,SAAS,EAAE,QAAQ,CAAC,QAAQ,CAAC,CAAC;YAC5F,OAAO,iCACF,QAAQ,KACX,MAAM,EAAE,WAAW,EACnB,QAAQ,EAAE,cAAc,CAAC,QAAQ,kCAC5B,gBAAgB,KACnB,OAAO,EAAE,KAAK,CAAC,OAAO,EACtB,KAAK,EAAE,KAAK,CAAC,KAAK,KAAK,SAAS,CAAC,CAAC,CAAC,eAAe,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,CAAC,GAAG,KAAK,CAAC,KAAK,CAAC,EACpF,MAAM,EAAE,WAAW,EACnB,SAAS,EAAE,SAAS,CAAC,eAAe,IACpC,IACF,CAAC;YACH,OAAO;QACT,CAAC;QAED,IAAI,KAAK,CAAC,IAAI,KAAK,MAAM,EAAE,CAAC;YAC1B,OAAO,iCACF,QAAQ,KACX,IAAI,EAAE,CAAC,GAAG,QAAQ,CAAC,IAAI,EAAE,KAAK,CAAC,IAAI,CAAC,IACpC,CAAC;YACH,OAAO;QACT,CAAC;QAED,eAAe,CAAC,SAAS,EAAE,KAAK,CAAC,CAAC;IACpC,CAAC,CAAC;IAEF,MAAM,sBAAsB,GAAG,CAC7B,SAA0B,EAC1B,QAAyC,EAIzC,EAAE;QACF,MAAM,QAAQ,GAAG,UAAU,CAAC,QAAQ,EAAE,SAAS,CAAC,kBAAkB,CAAC,CAAC;QACpE,IAAI,QAAQ,KAAK,SAAS;YAAE,OAAO,EAAE,gBAAgB,EAAE,QAAQ,EAAE,QAAQ,EAAE,CAAC;QAE5E,MAAM,gBAAgB,GAAqB;YACzC,EAAE,EAAE,QAAQ,EAAE;YACd,IAAI,EAAE,WAAW;YACjB,OAAO,EAAE,EAAE;YACX,KAAK,EAAE,EAAE;YACT,MAAM,EAAE,WAAW;YACnB,SAAS,EAAE,SAAS,CAAC,eAAe;SACrC,CAAC;QACF,SAAS,CAAC,kBAAkB,GAAG,gBAAgB,CAAC,EAAE,CAAC;QACnD,mBAAmB,CAAC,GAAG,CAAC,gBAAgB,CAAC,EAAE,EAAE,oBAAoB,CAAC,OAAO,CAAC,QAAQ,EAAE,SAAS,CAAC,CAAC,CAAC;QAChG,OAAO;YACL,gBAAgB;YAChB,QAAQ,EAAE,CAAC,GAAG,QAAQ,EAAE,gBAAgB,CAAC;SAC1C,CAAC;IACJ,CAAC,CAAC;IAEF,MAAM,eAAe,GAAG,CAAC,SAA0B,EAAE,KAA4B,EAAQ,EAAE;;QACzF,IAAI,CAAC,kBAAkB,CAAC,SAAS,CAAC;YAAE,OAAO;QAE3C,SAAS,CAAC,eAAe,GAAG,MAAA,KAAK,aAAL,KAAK,uBAAL,KAAK,CAAE,SAAS,mCAAI,SAAS,CAAC,eAAe,CAAC;QAC1E,MAAM,EAAE,QAAQ,EAAE,SAAS,EAAE,GAAG,mBAAmB,CAAC,KAAK,aAAL,KAAK,uBAAL,KAAK,CAAE,QAAQ,EAAE,KAAK,aAAL,KAAK,uBAAL,KAAK,CAAE,SAAS,CAAC,CAAC;QACvF,MAAM,EAAE,gBAAgB,EAAE,QAAQ,EAAE,GAAG,sBAAsB,CAAC,SAAS,EAAE,QAAQ,CAAC,QAAQ,CAAC,CAAC;QAC5F,MAAM,OAAO,GAAG,MAAA,KAAK,aAAL,KAAK,uBAAL,KAAK,CAAE,OAAO,mCAAI,gBAAgB,CAAC,OAAO,CAAC;QAC3D,MAAM,eAAe,mCAChB,gBAAgB,KACnB,OAAO,EACP,KAAK,EACH,CAAA,KAAK,aAAL,KAAK,uBAAL,KAAK,CAAE,KAAK,MAAK,SAAS;gBACxB,CAAC,CAAC,CAAC,GAAG,KAAK,CAAC,KAAK,CAAC;gBAClB,CAAC,CAAC,CAAA,KAAK,aAAL,KAAK,uBAAL,KAAK,CAAE,OAAO,MAAK,SAAS;oBAC5B,CAAC,CAAC,gBAAgB,CAAC,KAAK;oBACxB,CAAC,CAAC,eAAe,CAAC,OAAO,CAAC,EAChC,MAAM,EAAE,UAAU,EAClB,SAAS,EAAE,MAAA,SAAS,CAAC,eAAe,mCAAI,gBAAgB,CAAC,SAAS,GACnE,CAAC;QACF,eAAe,GAAG,SAAS,CAAC;QAC5B,IAAI,CAAA,KAAK,aAAL,KAAK,uBAAL,KAAK,CAAE,QAAQ,MAAK,SAAS,IAAI,CAAA,KAAK,aAAL,KAAK,uBAAL,KAAK,CAAE,SAAS,MAAK,SAAS,EAAE,CAAC;YACpE,gBAAgB,CAAC,OAAO,EAAE,QAAQ,EAAE,SAAS,CAAC,CAAC;QACjD,CAAC;QACD,OAAO,iCACF,QAAQ,KACX,MAAM,EAAE,OAAO,EACf,QAAQ,EAAE,cAAc,CAAC,QAAQ,EAAE,eAAe,CAAC,EACnD,QAAQ;YACR,SAAS,EACT,KAAK,EAAE,SAAS,EAChB,WAAW,EAAE,SAAS,IACtB,CAAC;QACH,kBAAkB,CAAC;YACjB,IAAI,EAAE,WAAW;YACjB,QAAQ,EAAE,QAAQ,CAAC,QAAQ;YAC3B,SAAS,EAAE,eAAe,CAAC,SAAS;YACpC,QAAQ,EAAE,oBAAoB,CAAC,OAAO,CAAC,QAAQ,EAAE,SAAS,CAAC;SAC5D,CAAC,CAAC;IACL,CAAC,CAAC;IAEF,MAAM,mBAAmB,GAAG,CAC1B,QAAiB,EACjB,SAAkB,EACyB,EAAE;QAC7C,OAAO;YACL,QAAQ,EAAE,QAAQ,aAAR,QAAQ,cAAR,QAAQ,GAAI,QAAQ,CAAC,QAAQ;YACvC,SAAS,EAAE,SAAS,aAAT,SAAS,cAAT,SAAS,GAAI,QAAQ,CAAC,SAAS;SAC3C,CAAC;IACJ,CAAC,CAAC;IAEF,MAAM,kBAAkB,GAAG,CAAC,SAA0B,EAAW,EAAE;QACjE,OAAO,CAAA,eAAe,aAAf,eAAe,uBAAf,eAAe,CAAE,EAAE,MAAK,SAAS,CAAC,EAAE,IAAI,CAAC,SAAS,CAAC;IAC5D,CAAC,CAAC;IAEF,MAAM,IAAI,GAAG,CAAO,KAAyB,EAA8B,EAAE;;QAC3E,YAAY,CAAC,SAAS,CAAC,CAAC;QACxB,IAAI,eAAe,KAAK,SAAS,EAAE,CAAC;YAClC,MAAM,IAAI,cAAc,CAAC;gBACvB,IAAI,EAAE,eAAe;gBACrB,OAAO,EAAE,mCAAmC;gBAC5C,SAAS,EAAE,IAAI;aAChB,CAAC,CAAC;QACL,CAAC;QACD,IAAI,KAAK,CAAC,OAAO,CAAC,IAAI,EAAE,CAAC,MAAM,KAAK,CAAC,EAAE,CAAC;YACtC,MAAM,IAAI,cAAc,CAAC;gBACvB,IAAI,EAAE,eAAe;gBACrB,OAAO,EAAE,8BAA8B;gBACvC,SAAS,EAAE,IAAI;aAChB,CAAC,CAAC;QACL,CAAC;QAED,MAAM,OAAO,GAAG,WAAW,CAAC,MAAA,KAAK,CAAC,OAAO,mCAAI,QAAQ,CAAC,OAAO,CAAC,CAAC;QAC/D,MAAM,OAAO,GAAG,MAAA,KAAK,CAAC,OAAO,mCAAI,OAAO,CAAC,QAAQ,CAAC,OAAO,CAAC;QAC1D,MAAM,UAAU,GAAG,MAAA,KAAK,CAAC,UAAU,mCAAI,OAAO,CAAC,QAAQ,CAAC,UAAU,CAAC;QACnE,MAAM,WAAW,GAAqB;YACpC,EAAE,EAAE,QAAQ,EAAE;YACd,IAAI,EAAE,MAAM;YACZ,OAAO,EAAE,KAAK,CAAC,OAAO;YACtB,KAAK,EAAE,eAAe,CAAC,KAAK,CAAC,OAAO,CAAC;YACrC,MAAM,EAAE,UAAU;YAClB,OAAO;SACR,CAAC;QACF,mBAAmB,CAAC,GAAG,CAAC,WAAW,CAAC,EAAE,EAAE,eAAe,CAAC,OAAO,CAAC,QAAQ,EAAE,OAAO,EAAE,UAAU,CAAC,CAAC,CAAC;QAChG,MAAM,SAAS,GAAG,cAAc,CAAC,OAAO,EAAE,UAAU,CAAC,CAAC;QACtD,OAAO,iCACF,QAAQ,KACX,MAAM,EAAE,WAAW,EACnB,QAAQ,EAAE,CAAC,GAAG,QAAQ,CAAC,QAAQ,EAAE,WAAW,CAAC,EAC7C,IAAI,EAAE,EAAE,EACR,KAAK,EAAE,SAAS,EAChB,WAAW,EAAE,SAAS,IACtB,CAAC;QACH,IAAI,CAAC,kBAAkB,CAAC,SAAS,CAAC;YAAE,OAAO,QAAQ,CAAC;QACpD,OAAO,YAAY,CAAC,SAAS,EAAE,WAAW,EAAE,KAAK,CAAC,CAAC;IACrD,CAAC,CAAA,CAAC;IAEF,MAAM,KAAK,GAAG,GAAqC,EAAE;;QACnD,YAAY,CAAC,SAAS,CAAC,CAAC;QACxB,IAAI,eAAe,KAAK,SAAS,EAAE,CAAC;YAClC,MAAM,IAAI,cAAc,CAAC;gBACvB,IAAI,EAAE,eAAe;gBACrB,OAAO,EAAE,mCAAmC;gBAC5C,SAAS,EAAE,IAAI;aAChB,CAAC,CAAC;QACL,CAAC;QAED,MAAM,gBAAgB,GAAG,wBAAwB,CAAC,QAAQ,CAAC,QAAQ,CAAC,CAAC;QACrE,MAAM,WAAW,GAAG,QAAQ,CAAC,QAAQ,CAAC,gBAAgB,CAAC,CAAC;QACxD,IAAI,gBAAgB,GAAG,CAAC,IAAI,WAAW,KAAK,SAAS,EAAE,CAAC;YACtD,MAAM,IAAI,cAAc,CAAC;gBACvB,IAAI,EAAE,eAAe;gBACrB,OAAO,EAAE,+BAA+B;gBACxC,SAAS,EAAE,KAAK;aACjB,CAAC,CAAC;QACL,CAAC;QAED,MAAM,QAAQ,GAAG,MAAA,mBAAmB,CAAC,GAAG,CAAC,WAAW,CAAC,EAAE,CAAC,mCAAI,eAAe,CAAC,OAAO,CAAC,QAAQ,CAAC,CAAC;QAC9F,MAAM,SAAS,GAAG,cAAc,CAAC,QAAQ,CAAC,OAAO,EAAE,QAAQ,CAAC,UAAU,CAAC,CAAC;QACxE,OAAO,iCACF,QAAQ,KACX,MAAM,EAAE,WAAW,EACnB,QAAQ,EAAE,QAAQ,CAAC,QAAQ,CAAC,KAAK,CAAC,CAAC,EAAE,gBAAgB,GAAG,CAAC,CAAC,EAC1D,IAAI,EAAE,EAAE,EACR,KAAK,EAAE,SAAS,EAChB,WAAW,EAAE,SAAS,IACtB,CAAC;QACH,IAAI,CAAC,kBAAkB,CAAC,SAAS,CAAC;YAAE,OAAO,QAAQ,CAAC;QACpD,OAAO,YAAY,CAAC,SAAS,EAAE,WAAW,EAAE,IAAI,CAAC,CAAC;IACpD,CAAC,CAAA,CAAC;IAEF,MAAM,SAAS,GAAG,GAAsB,EAAE;;QACxC,YAAY,CAAC,SAAS,CAAC,CAAC;QACxB,MAAM,SAAS,GAAG,qBAAqB,EAAE,CAAC;QAC1C,mBAAmB,CAAC,KAAK,EAAE,CAAC;QAC5B,IAAI,CAAC;YACH,MAAA,OAAO,CAAC,OAAO,0CAAE,iBAAiB,EAAE,CAAC;QACvC,CAAC;QAAC,WAAM,CAAC;YACP,iEAAiE;QACnE,CAAC;QACD,OAAO,CAAC;YACN,MAAM,EAAE,OAAO;YACf,QAAQ,EAAE,EAAE;YACZ,IAAI,EAAE,EAAE;YACR,OAAO,EAAE,QAAQ,CAAC,OAAO;YACzB,WAAW,EAAE,SAAS;SACvB,CAAC,CAAC;QACH,SAAS,aAAT,SAAS,uBAAT,SAAS,CAAE,UAAU,CAAC,KAAK,EAAE,CAAC;QAC9B,kBAAkB,CAAC,EAAE,IAAI,EAAE,YAAY,EAAE,QAAQ,EAAE,eAAe,CAAC,OAAO,CAAC,QAAQ,CAAC,EAAE,CAAC,CAAC;QACxF,OAAO,QAAQ,CAAC;IAClB,CAAC,CAAC;IAEF,MAAM,UAAU,GAAG,CAAC,OAA0B,EAAQ,EAAE;QACtD,YAAY,CAAC,SAAS,CAAC,CAAC;QACxB,OAAO,iCAAM,QAAQ,KAAE,OAAO,EAAE,WAAW,CAAC,OAAO,CAAC,IAAG,CAAC;IAC1D,CAAC,CAAC;IAEF,MAAM,cAAc,GAAG,CAAO,KAA6B,EAAiB,EAAE;;QAC5E,YAAY,CAAC,SAAS,CAAC,CAAC;QACxB,MAAM,OAAO,GAAG,QAAQ,CAAC,QAAQ,CAAC,IAAI,CACpC,CAAC,SAAS,EAAE,EAAE,CACZ,SAAS,CAAC,IAAI,KAAK,WAAW;YAC9B,CAAC,SAAS,CAAC,EAAE,KAAK,KAAK,CAAC,SAAS,IAAI,SAAS,CAAC,SAAS,KAAK,KAAK,CAAC,SAAS,CAAC,CAChF,CAAC;QACF,IAAI,CAAA,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,SAAS,MAAK,SAAS,IAAI,OAAO,CAAC,MAAM,KAAK,UAAU,EAAE,CAAC;YACtE,MAAM,IAAI,cAAc,CAAC;gBACvB,IAAI,EAAE,eAAe;gBACrB,OAAO,EAAE,kDAAkD;gBAC3D,SAAS,EAAE,KAAK;aACjB,CAAC,CAAC;QACL,CAAC;QAED,MAAM,QAAQ,GAAG,MAAA,mBAAmB,CAAC,GAAG,CAAC,OAAO,CAAC,EAAE,CAAC,mCAAI,eAAe,CAAC,OAAO,CAAC,QAAQ,CAAC,CAAC;QAC1F,MAAM,OAAO,CAAC,SAAS,CAAC,cAAc,CAAC;YACrC,SAAS,EAAE,OAAO,CAAC,SAAS;YAC5B,QAAQ,EAAE,KAAK,CAAC,QAAQ;YACxB,OAAO,EAAE,QAAQ,CAAC,OAAO;YACzB,UAAU,EAAE,QAAQ,CAAC,UAAU;YAC/B,aAAa,EAAE,QAAQ,CAAC,aAAa;YACrC,WAAW,EAAE,QAAQ,CAAC,WAAW;YACjC,QAAQ,EAAE,QAAQ,CAAC,QAAQ;YAC3B,SAAS,EAAE,QAAQ,CAAC,SAAS;SAC9B,CAAC,CAAC;QACH,OAAO,iCACF,QAAQ,KACX,QAAQ,EAAE,cAAc,CAAC,QAAQ,CAAC,QAAQ,kCAAO,OAAO,KAAE,QAAQ,EAAE,KAAK,CAAC,QAAQ,IAAG,IACrF,CAAC;QACH,kBAAkB,CAAC;YACjB,IAAI,EAAE,oBAAoB;YAC1B,SAAS,EAAE,OAAO,CAAC,SAAS;YAC5B,QAAQ,EAAE,KAAK,CAAC,QAAQ;YACxB,QAAQ;SACT,CAAC,CAAC;IACL,CAAC,CAAA,CAAC;IAEF,MAAM,SAAS,GAAG,CAAC,QAA+C,EAAgB,EAAE;QAClF,YAAY,CAAC,SAAS,CAAC,CAAC;QACxB,SAAS,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QACxB,OAAO,GAAG,EAAE;YACV,SAAS,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC;QAC7B,CAAC,CAAC;IACJ,CAAC,CAAC;IAEF,MAAM,OAAO,GAAG,GAAS,EAAE;;QACzB,IAAI,SAAS;YAAE,OAAO;QACtB,MAAM,SAAS,GAAG,qBAAqB,EAAE,CAAC;QAC1C,SAAS,GAAG,IAAI,CAAC;QACjB,mBAAmB,CAAC,KAAK,EAAE,CAAC;QAC5B,OAAO,iCACF,QAAQ,KACX,MAAM,EAAE,WAAW,EACnB,QAAQ,EAAE,2BAA2B,CAAC,QAAQ,CAAC,QAAQ,EAAE,SAAS,aAAT,SAAS,uBAAT,SAAS,CAAE,kBAAkB,CAAC,IACvF,CAAC;QACH,SAAS,CAAC,KAAK,EAAE,CAAC;QAClB,SAAS,aAAT,SAAS,uBAAT,SAAS,CAAE,UAAU,CAAC,KAAK,EAAE,CAAC;QAC9B,MAAA,MAAA,OAAO,CAAC,SAAS,EAAC,OAAO,kDAAI,CAAC;IAChC,CAAC,CAAC;IAEF,OAAO;QACL,IAAI;QACJ,KAAK;QACL,KAAK;QACL,SAAS;QACT,UAAU;QACV,cAAc;QACd,WAAW,EAAE,GAAG,EAAE,CAAC,QAAQ;QAC3B,SAAS;QACT,OAAO;KACR,CAAC;AACJ,CAAC;AAED,SAAS,WAAW,CAAC,OAA0B;;IAC7C,IAAI,OAAO,KAAK,SAAS;QAAE,OAAO,SAAS,CAAC;IAC5C,OAAO;QACL,KAAK,EAAE,MAAA,OAAO,CAAC,KAAK,0CAAE,GAAG,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,mBAAM,IAAI,EAAG,CAAC;QAClD,WAAW,EAAE,OAAO,CAAC,WAAW;QAChC,OAAO,EAAE,OAAO,CAAC,OAAO;QACxB,QAAQ,EAAE,OAAO,CAAC,QAAQ;QAC1B,OAAO,EAAE,OAAO,CAAC,OAAO;KACzB,CAAC;AACJ,CAAC;AAED,SAAS,oBAAoB,CAC3B,QAA2B,EAC3B,SAA0B;IAE1B,OAAO,eAAe,CAAC,QAAQ,EAAE,SAAS,CAAC,OAAO,EAAE,SAAS,CAAC,UAAU,CAAC,CAAC;AAC5E,CAAC;AAED,SAAS,eAAe,CACtB,QAA2B,EAC3B,UAAwC,QAAQ,CAAC,OAAO,EACxD,aAAqB,QAAQ,CAAC,UAAU;IAExC,uCACK,QAAQ,KACX,OAAO;QACP,UAAU,EACV,WAAW,EAAE,0BAA0B,IACvC;AACJ,CAAC;AAED,SAAS,eAAe;IACtB,aAAa,IAAI,CAAC,CAAC;IACnB,OAAO,qBAAqB,aAAa,EAAE,CAAC;AAC9C,CAAC;AAED,SAAS,eAAe,CAAC,OAAe;IACtC,OAAO,OAAO,CAAC,MAAM,KAAK,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,CAAC,EAAE,IAAI,EAAE,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,CAAC,CAAC;AACvE,CAAC;AAED,SAAS,eAAe,CACtB,KAA0C,EAC1C,KAAa;IAEb,MAAM,QAAQ,GAAG,KAAK,CAAC,KAAK,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC;IACzC,IAAI,CAAA,QAAQ,aAAR,QAAQ,uBAAR,QAAQ,CAAE,IAAI,MAAK,MAAM,EAAE,CAAC;QAC9B,OAAO,CAAC,GAAG,KAAK,CAAC,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC,EAAE,EAAE,IAAI,EAAE,MAAM,EAAE,IAAI,EAAE,GAAG,QAAQ,CAAC,IAAI,GAAG,KAAK,EAAE,EAAE,CAAC,CAAC;IACrF,CAAC;IACD,OAAO,CAAC,GAAG,KAAK,EAAE,EAAE,IAAI,EAAE,MAAM,EAAE,IAAI,EAAE,KAAK,EAAE,CAAC,CAAC;AACnD,CAAC;AAED,SAAS,UAAU,CACjB,QAAyC,EACzC,EAAW;IAEX,IAAI,EAAE,KAAK,SAAS;QAAE,OAAO,SAAS,CAAC;IACvC,OAAO,QAAQ,CAAC,IAAI,CAAC,CAAC,OAAO,EAAE,EAAE,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC;AACvD,CAAC;AAED,SAAS,cAAc,CACrB,QAAyC,EACzC,OAAyB;IAEzB,OAAO,QAAQ,CAAC,GAAG,CAAC,CAAC,SAAS,EAAE,EAAE,CAAC,CAAC,SAAS,CAAC,EAAE,KAAK,OAAO,CAAC,EAAE,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,SAAS,CAAC,CAAC,CAAC;AAC1F,CAAC;AAED,SAAS,wBAAwB,CAAC,QAAyC;;IACzE,KAAK,IAAI,KAAK,GAAG,QAAQ,CAAC,MAAM,GAAG,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,KAAK,IAAI,CAAC,EAAE,CAAC;QAC7D,IAAI,CAAA,MAAA,QAAQ,CAAC,KAAK,CAAC,0CAAE,IAAI,MAAK,MAAM;YAAE,OAAO,KAAK,CAAC;IACrD,CAAC;IACD,OAAO,CAAC,CAAC,CAAC;AACZ,CAAC;AAED,SAAS,2BAA2B,CAClC,QAAyC,EACzC,EAAW;IAEX,IAAI,EAAE,KAAK,SAAS;QAAE,OAAO,QAAQ,CAAC;IACtC,OAAO,QAAQ,CAAC,GAAG,CAAC,CAAC,OAAO,EAAE,EAAE,CAC9B,OAAO,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,iCAAM,OAAO,KAAE,MAAM,EAAE,SAAS,IAAG,CAAC,CAAC,OAAO,CAChE,CAAC;AACJ,CAAC;AAED,SAAS,2BAA2B,CAClC,QAAyC,EACzC,EAAW;IAEX,IAAI,EAAE,KAAK,SAAS;QAAE,OAAO,QAAQ,CAAC;IACtC,OAAO,QAAQ,CAAC,GAAG,CAAC,CAAC,OAAO,EAAE,EAAE,CAAC,CAAC,OAAO,CAAC,EAAE,KAAK,EAAE,CAAC,CAAC,iCAAM,OAAO,KAAE,MAAM,EAAE,OAAO,IAAG,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC;AACpG,CAAC;AAED,SAAS,YAAY,CAAC,SAAkB;IACtC,IAAI,CAAC,SAAS;QAAE,OAAO;IACvB,MAAM,IAAI,cAAc,CAAC;QACvB,IAAI,EAAE,WAAW;QACjB,OAAO,EAAE,2CAA2C;QACpD,SAAS,EAAE,KAAK;KACjB,CAAC,CAAC;AACL,CAAC;AAED,SAAS,gBAAgB,CACvB,OAA6B;;IAE7B,IAAI,CAAC;QACH,MAAM,YAAY,GAAG,MAAA,OAAO,CAAC,OAAO,0CAAE,gBAAgB,EAAE,CAAC;QACzD,IAAI,YAAY,KAAK,SAAS;YAAE,OAAO,SAAS,CAAC;QACjD,OAAO;YACL,QAAQ,EAAE,YAAY,CAAC,QAAQ;YAC/B,SAAS,EAAE,YAAY,CAAC,SAAS;SAClC,CAAC;IACJ,CAAC;IAAC,WAAM,CAAC;QACP,OAAO,SAAS,CAAC;IACnB,CAAC;AACH,CAAC;AAED,SAAS,gBAAgB,CACvB,OAA6B,EAC7B,QAAiB,EACjB,SAAkB;;IAElB,IAAI,QAAQ,KAAK,SAAS,IAAI,SAAS,KAAK,SAAS;QAAE,OAAO;IAC9D,IAAI,CAAC;QACH,MAAA,OAAO,CAAC,OAAO,0CAAE,gBAAgB,CAAC,EAAE,QAAQ,EAAE,SAAS,EAAE,CAAC,CAAC;IAC7D,CAAC;IAAC,WAAM,CAAC;QACP,iEAAiE;IACnE,CAAC;AACH,CAAC"}
-30
dist/errors.d.ts
import type { AssistantErrorCode, AssistantErrorSnapshot, AssistantUnavailable, AssistantUnavailableType } from './types.js';
export declare class AssistantError extends Error {
readonly code: AssistantErrorCode;
readonly retryable: boolean;
readonly status?: number;
readonly unavailableType?: AssistantUnavailableType;
readonly rayId?: string;
constructor(options: {
code: AssistantErrorCode;
message: string;
retryable: boolean;
status?: number;
unavailableType?: AssistantUnavailableType;
rayId?: string;
});
toSnapshot(): AssistantErrorSnapshot;
}
export declare class AssistantTransportError extends AssistantError {
constructor(options?: {
message?: string;
status?: number;
unavailableType?: AssistantUnavailableType;
rayId?: string;
retryable?: boolean;
});
}
export declare function getUnavailableForStatus(status?: number, rayId?: string): AssistantUnavailable;
export declare function normalizeAssistantError(error: unknown): AssistantError;
export declare function getUnavailableForError(error: AssistantError): AssistantUnavailable;
//# sourceMappingURL=errors.d.ts.map
-1
dist/errors.d.ts.map
{"version":3,"file":"errors.d.ts","sourceRoot":"","sources":["../src/errors.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EACV,kBAAkB,EAClB,sBAAsB,EACtB,oBAAoB,EACpB,wBAAwB,EACzB,MAAM,YAAY,CAAC;AAmDpB,qBAAa,cAAe,SAAQ,KAAK;IACvC,QAAQ,CAAC,IAAI,EAAE,kBAAkB,CAAC;IAClC,QAAQ,CAAC,SAAS,EAAE,OAAO,CAAC;IAC5B,QAAQ,CAAC,MAAM,CAAC,EAAE,MAAM,CAAC;IACzB,QAAQ,CAAC,eAAe,CAAC,EAAE,wBAAwB,CAAC;IACpD,QAAQ,CAAC,KAAK,CAAC,EAAE,MAAM,CAAC;gBAEZ,OAAO,EAAE;QACnB,IAAI,EAAE,kBAAkB,CAAC;QACzB,OAAO,EAAE,MAAM,CAAC;QAChB,SAAS,EAAE,OAAO,CAAC;QACnB,MAAM,CAAC,EAAE,MAAM,CAAC;QAChB,eAAe,CAAC,EAAE,wBAAwB,CAAC;QAC3C,KAAK,CAAC,EAAE,MAAM,CAAC;KAChB;IAUD,UAAU,IAAI,sBAAsB;CAWrC;AAED,qBAAa,uBAAwB,SAAQ,cAAc;gBAC7C,OAAO,CAAC,EAAE;QACpB,OAAO,CAAC,EAAE,MAAM,CAAC;QACjB,MAAM,CAAC,EAAE,MAAM,CAAC;QAChB,eAAe,CAAC,EAAE,wBAAwB,CAAC;QAC3C,KAAK,CAAC,EAAE,MAAM,CAAC;QACf,SAAS,CAAC,EAAE,OAAO,CAAC;KACrB;CAKF;AAED,wBAAgB,uBAAuB,CAAC,MAAM,CAAC,EAAE,MAAM,EAAE,KAAK,CAAC,EAAE,MAAM,GAAG,oBAAoB,CA0B7F;AAED,wBAAgB,uBAAuB,CAAC,KAAK,EAAE,OAAO,GAAG,cAAc,CAQtE;AAkFD,wBAAgB,sBAAsB,CAAC,KAAK,EAAE,cAAc,GAAG,oBAAoB,CAmBlF"}
-174
dist/errors.js
const UNAVAILABLE_CONFIG = {
402: {
type: 'payment',
message: 'Usage of this feature is temporarily limited. Please try again later or contact the site owner to restore access.',
},
403: {
type: 'rate_limited',
message: "You're sending too many messages. Please wait a moment and try again.",
},
404: {
type: 'not_found',
message: 'There was an error sending your message. Please refresh and try again.',
},
413: {
type: 'thread_limit',
message: 'You have reached the maximum number of messages in a thread. Please start a new thread to continue.',
},
418: {
type: 'blocked',
message: 'The assistant is unavailable from your network. If you are using a VPN, please turn it off and try again.',
},
420: {
type: 'heuristic_blocked',
message: 'Your request could not be verified. Please refresh and try again.',
},
429: {
type: 'rate_limited',
message: "You're sending too many messages. Please wait a moment and try again.",
},
};
const DEFAULT_UNAVAILABLE = {
type: 'unknown',
message: 'This feature is temporarily unavailable. Please try again later or contact the site owner to restore access.',
};
const CAPTCHA_MESSAGE = 'Unable to verify your browser. Please try again. If this issue persists, refresh your browser.';
const STREAM_ERROR_MESSAGE = 'There was an error generating a response. Please check your connection and try again.';
export class AssistantError extends Error {
constructor(options) {
super(options.message);
this.name = 'AssistantError';
this.code = options.code;
this.retryable = options.retryable;
this.status = options.status;
this.unavailableType = options.unavailableType;
this.rayId = options.rayId;
}
toSnapshot() {
return {
name: 'AssistantError',
code: this.code,
message: this.message,
retryable: this.retryable,
status: this.status,
unavailableType: this.unavailableType,
rayId: this.rayId,
};
}
}
export class AssistantTransportError extends AssistantError {
constructor(options) {
const normalized = getTransportErrorOptions(options);
super(normalized);
this.name = 'AssistantError';
}
}
export function getUnavailableForStatus(status, rayId) {
if (status === 400 || status === 419 || status === 450) {
return {
unavailable: true,
type: 'captcha_required',
message: CAPTCHA_MESSAGE,
rayId,
};
}
const config = status === undefined ? DEFAULT_UNAVAILABLE : UNAVAILABLE_CONFIG[status];
if (config === undefined) {
return {
unavailable: true,
type: 'stream_error',
message: STREAM_ERROR_MESSAGE,
rayId,
};
}
return {
unavailable: true,
type: config.type,
message: config.message,
rayId,
};
}
export function normalizeAssistantError(error) {
if (error instanceof AssistantError)
return error;
return new AssistantError({
code: 'stream_error',
message: STREAM_ERROR_MESSAGE,
retryable: true,
});
}
function getTransportErrorOptions(options) {
var _a, _b, _c, _d, _e, _f, _g, _h;
const status = options === null || options === void 0 ? void 0 : options.status;
if ((options === null || options === void 0 ? void 0 : options.unavailableType) !== undefined) {
const unavailable = getUnavailableForType(options.unavailableType, options.rayId);
return {
code: options.unavailableType === 'captcha_required' ? 'captcha_required' : 'unavailable',
message: (_a = options.message) !== null && _a !== void 0 ? _a : unavailable.message,
retryable: (_b = options.retryable) !== null && _b !== void 0 ? _b : isRetryableType(options.unavailableType),
status,
unavailableType: options.unavailableType,
rayId: options.rayId,
};
}
if (status !== undefined &&
(UNAVAILABLE_CONFIG[status] !== undefined || isCaptchaStatus(status))) {
const unavailable = getUnavailableForStatus(status, options === null || options === void 0 ? void 0 : options.rayId);
return {
code: unavailable.type === 'captcha_required' ? 'captcha_required' : 'unavailable',
message: (_c = options === null || options === void 0 ? void 0 : options.message) !== null && _c !== void 0 ? _c : unavailable.message,
retryable: (_d = options === null || options === void 0 ? void 0 : options.retryable) !== null && _d !== void 0 ? _d : isRetryableType((_e = unavailable.type) !== null && _e !== void 0 ? _e : 'unknown'),
status,
unavailableType: (_f = unavailable.type) !== null && _f !== void 0 ? _f : 'unknown',
rayId: options === null || options === void 0 ? void 0 : options.rayId,
};
}
return {
code: 'transport_error',
message: (_g = options === null || options === void 0 ? void 0 : options.message) !== null && _g !== void 0 ? _g : STREAM_ERROR_MESSAGE,
retryable: (_h = options === null || options === void 0 ? void 0 : options.retryable) !== null && _h !== void 0 ? _h : true,
status,
rayId: options === null || options === void 0 ? void 0 : options.rayId,
};
}
function getUnavailableForType(type, rayId) {
var _a;
if (type === 'captcha_required') {
return { unavailable: true, type, message: CAPTCHA_MESSAGE, rayId };
}
if (type === 'stream_error') {
return { unavailable: true, type, message: STREAM_ERROR_MESSAGE, rayId };
}
const config = Object.values(UNAVAILABLE_CONFIG).find((value) => value.type === type);
return {
unavailable: true,
type,
message: (_a = config === null || config === void 0 ? void 0 : config.message) !== null && _a !== void 0 ? _a : DEFAULT_UNAVAILABLE.message,
rayId,
};
}
function isCaptchaStatus(status) {
return status === 400 || status === 419 || status === 450;
}
function isRetryableType(type) {
return type !== 'payment' && type !== 'blocked' && type !== 'thread_limit';
}
export function getUnavailableForError(error) {
if (error.unavailableType !== undefined) {
return getUnavailableForType(error.unavailableType, error.rayId);
}
if (error.code === 'stream_error' || error.code === 'transport_error') {
return {
unavailable: true,
type: 'stream_error',
message: STREAM_ERROR_MESSAGE,
rayId: error.rayId,
};
}
return {
unavailable: false,
type: null,
message: '',
};
}
//# sourceMappingURL=errors.js.map
-1
dist/errors.js.map
{"version":3,"file":"errors.js","sourceRoot":"","sources":["../src/errors.ts"],"names":[],"mappings":"AAOA,MAAM,kBAAkB,GAAwE;IAC9F,GAAG,EAAE;QACH,IAAI,EAAE,SAAS;QACf,OAAO,EACL,mHAAmH;KACtH;IACD,GAAG,EAAE;QACH,IAAI,EAAE,cAAc;QACpB,OAAO,EAAE,uEAAuE;KACjF;IACD,GAAG,EAAE;QACH,IAAI,EAAE,WAAW;QACjB,OAAO,EAAE,wEAAwE;KAClF;IACD,GAAG,EAAE;QACH,IAAI,EAAE,cAAc;QACpB,OAAO,EACL,qGAAqG;KACxG;IACD,GAAG,EAAE;QACH,IAAI,EAAE,SAAS;QACf,OAAO,EACL,2GAA2G;KAC9G;IACD,GAAG,EAAE;QACH,IAAI,EAAE,mBAAmB;QACzB,OAAO,EAAE,mEAAmE;KAC7E;IACD,GAAG,EAAE;QACH,IAAI,EAAE,cAAc;QACpB,OAAO,EAAE,uEAAuE;KACjF;CACF,CAAC;AAEF,MAAM,mBAAmB,GAGrB;IACF,IAAI,EAAE,SAAS;IACf,OAAO,EACL,8GAA8G;CACjH,CAAC;AAEF,MAAM,eAAe,GACnB,gGAAgG,CAAC;AAEnG,MAAM,oBAAoB,GACxB,uFAAuF,CAAC;AAE1F,MAAM,OAAO,cAAe,SAAQ,KAAK;IAOvC,YAAY,OAOX;QACC,KAAK,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC;QACvB,IAAI,CAAC,IAAI,GAAG,gBAAgB,CAAC;QAC7B,IAAI,CAAC,IAAI,GAAG,OAAO,CAAC,IAAI,CAAC;QACzB,IAAI,CAAC,SAAS,GAAG,OAAO,CAAC,SAAS,CAAC;QACnC,IAAI,CAAC,MAAM,GAAG,OAAO,CAAC,MAAM,CAAC;QAC7B,IAAI,CAAC,eAAe,GAAG,OAAO,CAAC,eAAe,CAAC;QAC/C,IAAI,CAAC,KAAK,GAAG,OAAO,CAAC,KAAK,CAAC;IAC7B,CAAC;IAED,UAAU;QACR,OAAO;YACL,IAAI,EAAE,gBAAgB;YACtB,IAAI,EAAE,IAAI,CAAC,IAAI;YACf,OAAO,EAAE,IAAI,CAAC,OAAO;YACrB,SAAS,EAAE,IAAI,CAAC,SAAS;YACzB,MAAM,EAAE,IAAI,CAAC,MAAM;YACnB,eAAe,EAAE,IAAI,CAAC,eAAe;YACrC,KAAK,EAAE,IAAI,CAAC,KAAK;SAClB,CAAC;IACJ,CAAC;CACF;AAED,MAAM,OAAO,uBAAwB,SAAQ,cAAc;IACzD,YAAY,OAMX;QACC,MAAM,UAAU,GAAG,wBAAwB,CAAC,OAAO,CAAC,CAAC;QACrD,KAAK,CAAC,UAAU,CAAC,CAAC;QAClB,IAAI,CAAC,IAAI,GAAG,gBAAgB,CAAC;IAC/B,CAAC;CACF;AAED,MAAM,UAAU,uBAAuB,CAAC,MAAe,EAAE,KAAc;IACrE,IAAI,MAAM,KAAK,GAAG,IAAI,MAAM,KAAK,GAAG,IAAI,MAAM,KAAK,GAAG,EAAE,CAAC;QACvD,OAAO;YACL,WAAW,EAAE,IAAI;YACjB,IAAI,EAAE,kBAAkB;YACxB,OAAO,EAAE,eAAe;YACxB,KAAK;SACN,CAAC;IACJ,CAAC;IAED,MAAM,MAAM,GAAG,MAAM,KAAK,SAAS,CAAC,CAAC,CAAC,mBAAmB,CAAC,CAAC,CAAC,kBAAkB,CAAC,MAAM,CAAC,CAAC;IACvF,IAAI,MAAM,KAAK,SAAS,EAAE,CAAC;QACzB,OAAO;YACL,WAAW,EAAE,IAAI;YACjB,IAAI,EAAE,cAAc;YACpB,OAAO,EAAE,oBAAoB;YAC7B,KAAK;SACN,CAAC;IACJ,CAAC;IAED,OAAO;QACL,WAAW,EAAE,IAAI;QACjB,IAAI,EAAE,MAAM,CAAC,IAAI;QACjB,OAAO,EAAE,MAAM,CAAC,OAAO;QACvB,KAAK;KACN,CAAC;AACJ,CAAC;AAED,MAAM,UAAU,uBAAuB,CAAC,KAAc;IACpD,IAAI,KAAK,YAAY,cAAc;QAAE,OAAO,KAAK,CAAC;IAElD,OAAO,IAAI,cAAc,CAAC;QACxB,IAAI,EAAE,cAAc;QACpB,OAAO,EAAE,oBAAoB;QAC7B,SAAS,EAAE,IAAI;KAChB,CAAC,CAAC;AACL,CAAC;AAED,SAAS,wBAAwB,CAAC,OAMjC;;IAQC,MAAM,MAAM,GAAG,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,MAAM,CAAC;IAC/B,IAAI,CAAA,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,eAAe,MAAK,SAAS,EAAE,CAAC;QAC3C,MAAM,WAAW,GAAG,qBAAqB,CAAC,OAAO,CAAC,eAAe,EAAE,OAAO,CAAC,KAAK,CAAC,CAAC;QAClF,OAAO;YACL,IAAI,EAAE,OAAO,CAAC,eAAe,KAAK,kBAAkB,CAAC,CAAC,CAAC,kBAAkB,CAAC,CAAC,CAAC,aAAa;YACzF,OAAO,EAAE,MAAA,OAAO,CAAC,OAAO,mCAAI,WAAW,CAAC,OAAO;YAC/C,SAAS,EAAE,MAAA,OAAO,CAAC,SAAS,mCAAI,eAAe,CAAC,OAAO,CAAC,eAAe,CAAC;YACxE,MAAM;YACN,eAAe,EAAE,OAAO,CAAC,eAAe;YACxC,KAAK,EAAE,OAAO,CAAC,KAAK;SACrB,CAAC;IACJ,CAAC;IAED,IACE,MAAM,KAAK,SAAS;QACpB,CAAC,kBAAkB,CAAC,MAAM,CAAC,KAAK,SAAS,IAAI,eAAe,CAAC,MAAM,CAAC,CAAC,EACrE,CAAC;QACD,MAAM,WAAW,GAAG,uBAAuB,CAAC,MAAM,EAAE,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,KAAK,CAAC,CAAC;QACpE,OAAO;YACL,IAAI,EAAE,WAAW,CAAC,IAAI,KAAK,kBAAkB,CAAC,CAAC,CAAC,kBAAkB,CAAC,CAAC,CAAC,aAAa;YAClF,OAAO,EAAE,MAAA,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,OAAO,mCAAI,WAAW,CAAC,OAAO;YAChD,SAAS,EAAE,MAAA,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,SAAS,mCAAI,eAAe,CAAC,MAAA,WAAW,CAAC,IAAI,mCAAI,SAAS,CAAC;YAC/E,MAAM;YACN,eAAe,EAAE,MAAA,WAAW,CAAC,IAAI,mCAAI,SAAS;YAC9C,KAAK,EAAE,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,KAAK;SACtB,CAAC;IACJ,CAAC;IAED,OAAO;QACL,IAAI,EAAE,iBAAiB;QACvB,OAAO,EAAE,MAAA,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,OAAO,mCAAI,oBAAoB;QACjD,SAAS,EAAE,MAAA,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,SAAS,mCAAI,IAAI;QACrC,MAAM;QACN,KAAK,EAAE,OAAO,aAAP,OAAO,uBAAP,OAAO,CAAE,KAAK;KACtB,CAAC;AACJ,CAAC;AAED,SAAS,qBAAqB,CAC5B,IAA8B,EAC9B,KAAc;;IAEd,IAAI,IAAI,KAAK,kBAAkB,EAAE,CAAC;QAChC,OAAO,EAAE,WAAW,EAAE,IAAI,EAAE,IAAI,EAAE,OAAO,EAAE,eAAe,EAAE,KAAK,EAAE,CAAC;IACtE,CAAC;IAED,IAAI,IAAI,KAAK,cAAc,EAAE,CAAC;QAC5B,OAAO,EAAE,WAAW,EAAE,IAAI,EAAE,IAAI,EAAE,OAAO,EAAE,oBAAoB,EAAE,KAAK,EAAE,CAAC;IAC3E,CAAC;IAED,MAAM,MAAM,GAAG,MAAM,CAAC,MAAM,CAAC,kBAAkB,CAAC,CAAC,IAAI,CAAC,CAAC,KAAK,EAAE,EAAE,CAAC,KAAK,CAAC,IAAI,KAAK,IAAI,CAAC,CAAC;IACtF,OAAO;QACL,WAAW,EAAE,IAAI;QACjB,IAAI;QACJ,OAAO,EAAE,MAAA,MAAM,aAAN,MAAM,uBAAN,MAAM,CAAE,OAAO,mCAAI,mBAAmB,CAAC,OAAO;QACvD,KAAK;KACN,CAAC;AACJ,CAAC;AAED,SAAS,eAAe,CAAC,MAAc;IACrC,OAAO,MAAM,KAAK,GAAG,IAAI,MAAM,KAAK,GAAG,IAAI,MAAM,KAAK,GAAG,CAAC;AAC5D,CAAC;AAED,SAAS,eAAe,CAAC,IAA8B;IACrD,OAAO,IAAI,KAAK,SAAS,IAAI,IAAI,KAAK,SAAS,IAAI,IAAI,KAAK,cAAc,CAAC;AAC7E,CAAC;AAED,MAAM,UAAU,sBAAsB,CAAC,KAAqB;IAC1D,IAAI,KAAK,CAAC,eAAe,KAAK,SAAS,EAAE,CAAC;QACxC,OAAO,qBAAqB,CAAC,KAAK,CAAC,eAAe,EAAE,KAAK,CAAC,KAAK,CAAC,CAAC;IACnE,CAAC;IAED,IAAI,KAAK,CAAC,IAAI,KAAK,cAAc,IAAI,KAAK,CAAC,IAAI,KAAK,iBAAiB,EAAE,CAAC;QACtE,OAAO;YACL,WAAW,EAAE,IAAI;YACjB,IAAI,EAAE,cAAc;YACpB,OAAO,EAAE,oBAAoB;YAC7B,KAAK,EAAE,KAAK,CAAC,KAAK;SACnB,CAAC;IACJ,CAAC;IAED,OAAO;QACL,WAAW,EAAE,KAAK;QAClB,IAAI,EAAE,IAAI;QACV,OAAO,EAAE,EAAE;KACZ,CAAC;AACJ,CAAC"}
-5
dist/index.d.ts
export { ASSISTANT_CORE_API_VERSION, ASSISTANT_SURFACES } from './constants.js';
export { createAssistantCore } from './core.js';
export { AssistantError, AssistantTransportError, getUnavailableForStatus } from './errors.js';
export type { AssistantCancellationSignal, AssistantContext, AssistantContextItem, AssistantContinuation, AssistantCore, AssistantCoreOptions, AssistantDataPart, AssistantErrorCode, AssistantErrorSnapshot, AssistantFeedback, AssistantFeedbackInput, AssistantLifecycleEvent, AssistantLifecycleMetadata, AssistantMessage, AssistantMessagePart, AssistantMessageStatus, AssistantMetadata, AssistantSendInput, AssistantSnapshot, AssistantSourcePart, AssistantStatus, AssistantStorageAdapter, AssistantSurface, AssistantTextPart, AssistantToolPart, AssistantTransport, AssistantTransportEvent, AssistantTransportFeedbackRequest, AssistantTransportSendRequest, AssistantUnavailable, AssistantUnavailableType, } from './types.js';
//# sourceMappingURL=index.d.ts.map
-1
dist/index.d.ts.map
{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,0BAA0B,EAAE,kBAAkB,EAAE,MAAM,gBAAgB,CAAC;AAChF,OAAO,EAAE,mBAAmB,EAAE,MAAM,WAAW,CAAC;AAChD,OAAO,EAAE,cAAc,EAAE,uBAAuB,EAAE,uBAAuB,EAAE,MAAM,aAAa,CAAC;AAC/F,YAAY,EACV,2BAA2B,EAC3B,gBAAgB,EAChB,oBAAoB,EACpB,qBAAqB,EACrB,aAAa,EACb,oBAAoB,EACpB,iBAAiB,EACjB,kBAAkB,EAClB,sBAAsB,EACtB,iBAAiB,EACjB,sBAAsB,EACtB,uBAAuB,EACvB,0BAA0B,EAC1B,gBAAgB,EAChB,oBAAoB,EACpB,sBAAsB,EACtB,iBAAiB,EACjB,kBAAkB,EAClB,iBAAiB,EACjB,mBAAmB,EACnB,eAAe,EACf,uBAAuB,EACvB,gBAAgB,EAChB,iBAAiB,EACjB,iBAAiB,EACjB,kBAAkB,EAClB,uBAAuB,EACvB,iCAAiC,EACjC,6BAA6B,EAC7B,oBAAoB,EACpB,wBAAwB,GACzB,MAAM,YAAY,CAAC"}
-4
dist/index.js
export { ASSISTANT_CORE_API_VERSION, ASSISTANT_SURFACES } from './constants.js';
export { createAssistantCore } from './core.js';
export { AssistantError, AssistantTransportError, getUnavailableForStatus } from './errors.js';
//# sourceMappingURL=index.js.map
-1
dist/index.js.map
{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,0BAA0B,EAAE,kBAAkB,EAAE,MAAM,gBAAgB,CAAC;AAChF,OAAO,EAAE,mBAAmB,EAAE,MAAM,WAAW,CAAC;AAChD,OAAO,EAAE,cAAc,EAAE,uBAAuB,EAAE,uBAAuB,EAAE,MAAM,aAAa,CAAC"}
-201
dist/types.d.ts
export type AssistantSurface = 'floating-widget' | 'custom-trigger' | 'headless';
export type AssistantContextItem = {
readonly type: 'code' | 'textSelection';
readonly value: string;
readonly path?: string;
readonly elementId?: string;
};
export type AssistantContext = {
readonly items?: ReadonlyArray<AssistantContextItem>;
readonly currentPath?: string;
readonly version?: string;
readonly language?: string;
readonly product?: string;
};
export type AssistantFeedback = 'positive' | 'negative';
export type AssistantUnavailableType = 'rate_limited' | 'blocked' | 'heuristic_blocked' | 'thread_limit' | 'payment' | 'unknown' | 'not_found' | 'captcha_required' | 'stream_error';
export type AssistantUnavailable = {
readonly unavailable: boolean;
readonly type: AssistantUnavailableType | null;
readonly message: string;
readonly rayId?: string;
};
export type AssistantTextPart = {
readonly type: 'text';
readonly text: string;
};
export type AssistantToolPart = {
readonly type: 'tool';
readonly toolCallId: string;
readonly toolName: string;
readonly state: 'input-streaming' | 'input-available' | 'output-available' | 'output-error';
readonly input?: unknown;
readonly output?: unknown;
readonly errorText?: string;
};
export type AssistantSourcePart = {
readonly type: 'source';
readonly title?: string;
readonly url: string;
};
export type AssistantDataPart = {
readonly type: 'data';
readonly data: unknown;
};
export type AssistantMessagePart = AssistantTextPart | AssistantToolPart | AssistantSourcePart | AssistantDataPart;
export type AssistantMessageStatus = 'streaming' | 'complete' | 'error' | 'aborted';
export type AssistantMessage = {
readonly id: string;
readonly role: 'user' | 'assistant';
readonly content: string;
readonly parts: ReadonlyArray<AssistantMessagePart>;
readonly status: AssistantMessageStatus;
readonly context?: AssistantContext;
/** The server message ID returned through X-Message-Id. */
readonly messageId?: string;
readonly feedback?: AssistantFeedback;
};
export type AssistantStatus = 'ready' | 'submitted' | 'streaming' | 'error' | 'destroyed';
export type AssistantErrorCode = 'aborted' | 'captcha_required' | 'destroyed' | 'invalid_input' | 'invalid_state' | 'stream_error' | 'transport_error' | 'unavailable';
export type AssistantErrorSnapshot = {
readonly name: 'AssistantError';
readonly code: AssistantErrorCode;
readonly message: string;
readonly retryable: boolean;
readonly status?: number;
readonly unavailableType?: AssistantUnavailableType;
readonly rayId?: string;
};
export type AssistantSnapshot = {
readonly status: AssistantStatus;
readonly messages: ReadonlyArray<AssistantMessage>;
readonly data: ReadonlyArray<unknown>;
readonly context?: AssistantContext;
readonly threadId?: string;
readonly threadKey?: string;
readonly error?: AssistantErrorSnapshot;
readonly unavailable: AssistantUnavailable;
};
export type AssistantContinuation = {
readonly threadId?: string;
readonly threadKey?: string;
};
export interface AssistantStorageAdapter {
loadContinuation(): AssistantContinuation | undefined;
saveContinuation(continuation: AssistantContinuation): void;
clearContinuation(): void;
}
export interface AssistantCancellationSignal {
readonly aborted: boolean;
subscribe(listener: () => void): () => void;
}
export type AssistantTransportSendRequest = {
readonly messages: ReadonlyArray<AssistantMessage>;
readonly surface: AssistantSurface;
readonly entryPoint: string;
readonly loaderVersion?: string;
readonly coreVersion: string;
readonly context?: ReadonlyArray<AssistantContextItem>;
readonly currentPath?: string;
readonly version?: string;
readonly language?: string;
readonly product?: string;
readonly threadId?: string;
readonly threadKey?: string;
readonly regenerate?: boolean;
};
export type AssistantTransportFeedbackRequest = {
readonly messageId: string;
readonly feedback: AssistantFeedback;
readonly surface: AssistantSurface;
readonly entryPoint: string;
readonly loaderVersion?: string;
readonly coreVersion: string;
readonly threadId?: string;
readonly threadKey?: string;
};
export type AssistantTransportEvent = {
type: 'start';
threadId?: string;
threadKey?: string;
messageId?: string;
} | {
type: 'text-delta';
delta: string;
} | {
type: 'message';
content: string;
parts?: ReadonlyArray<AssistantMessagePart>;
messageId?: string;
} | {
type: 'data';
data: unknown;
} | {
type: 'finish';
content?: string;
parts?: ReadonlyArray<AssistantMessagePart>;
threadId?: string;
threadKey?: string;
messageId?: string;
};
export interface AssistantTransport {
send(request: AssistantTransportSendRequest, signal: AssistantCancellationSignal): AsyncIterable<AssistantTransportEvent>;
submitFeedback(request: AssistantTransportFeedbackRequest): Promise<void>;
destroy?(): void;
}
export type AssistantLifecycleEvent = {
type: 'completed';
threadId?: string;
messageId?: string;
metadata: AssistantLifecycleMetadata;
} | {
type: 'errored';
error: AssistantErrorSnapshot;
metadata: AssistantLifecycleMetadata;
} | {
type: 'feedback-submitted';
messageId: string;
feedback: AssistantFeedback;
metadata: AssistantLifecycleMetadata;
} | {
type: 'new-thread';
metadata: AssistantLifecycleMetadata;
};
export type AssistantMetadata = {
readonly surface: AssistantSurface;
readonly entryPoint: string;
readonly loaderVersion?: string;
};
export type AssistantLifecycleMetadata = AssistantMetadata & {
readonly coreVersion: string;
};
export type AssistantCoreOptions = {
readonly transport: AssistantTransport;
readonly storage?: AssistantStorageAdapter;
readonly metadata: AssistantMetadata;
readonly context?: AssistantContext;
readonly createId?: () => string;
readonly onEvent?: (event: AssistantLifecycleEvent) => void;
};
export type AssistantSendInput = {
readonly content: string;
readonly context?: AssistantContext;
readonly surface?: AssistantSurface;
readonly entryPoint?: string;
};
export type AssistantFeedbackInput = {
readonly messageId: string;
readonly feedback: AssistantFeedback;
};
export interface AssistantCore {
send(input: AssistantSendInput): Promise<AssistantSnapshot>;
abort(): void;
retry(): Promise<AssistantSnapshot>;
newThread(): AssistantSnapshot;
setContext(context?: AssistantContext): void;
submitFeedback(input: AssistantFeedbackInput): Promise<void>;
getSnapshot(): AssistantSnapshot;
subscribe(listener: (snapshot: AssistantSnapshot) => void): () => void;
destroy(): void;
}
//# sourceMappingURL=types.d.ts.map
-1
dist/types.d.ts.map
{"version":3,"file":"types.d.ts","sourceRoot":"","sources":["../src/types.ts"],"names":[],"mappings":"AAAA,MAAM,MAAM,gBAAgB,GAAG,iBAAiB,GAAG,gBAAgB,GAAG,UAAU,CAAC;AAEjF,MAAM,MAAM,oBAAoB,GAAG;IACjC,QAAQ,CAAC,IAAI,EAAE,MAAM,GAAG,eAAe,CAAC;IACxC,QAAQ,CAAC,KAAK,EAAE,MAAM,CAAC;IACvB,QAAQ,CAAC,IAAI,CAAC,EAAE,MAAM,CAAC;IACvB,QAAQ,CAAC,SAAS,CAAC,EAAE,MAAM,CAAC;CAC7B,CAAC;AAEF,MAAM,MAAM,gBAAgB,GAAG;IAC7B,QAAQ,CAAC,KAAK,CAAC,EAAE,aAAa,CAAC,oBAAoB,CAAC,CAAC;IACrD,QAAQ,CAAC,WAAW,CAAC,EAAE,MAAM,CAAC;IAC9B,QAAQ,CAAC,OAAO,CAAC,EAAE,MAAM,CAAC;IAC1B,QAAQ,CAAC,QAAQ,CAAC,EAAE,MAAM,CAAC;IAC3B,QAAQ,CAAC,OAAO,CAAC,EAAE,MAAM,CAAC;CAC3B,CAAC;AAEF,MAAM,MAAM,iBAAiB,GAAG,UAAU,GAAG,UAAU,CAAC;AAExD,MAAM,MAAM,wBAAwB,GAChC,cAAc,GACd,SAAS,GACT,mBAAmB,GACnB,cAAc,GACd,SAAS,GACT,SAAS,GACT,WAAW,GACX,kBAAkB,GAClB,cAAc,CAAC;AAEnB,MAAM,MAAM,oBAAoB,GAAG;IACjC,QAAQ,CAAC,WAAW,EAAE,OAAO,CAAC;IAC9B,QAAQ,CAAC,IAAI,EAAE,wBAAwB,GAAG,IAAI,CAAC;IAC/C,QAAQ,CAAC,OAAO,EAAE,MAAM,CAAC;IACzB,QAAQ,CAAC,KAAK,CAAC,EAAE,MAAM,CAAC;CACzB,CAAC;AAEF,MAAM,MAAM,iBAAiB,GAAG;IAC9B,QAAQ,CAAC,IAAI,EAAE,MAAM,CAAC;IACtB,QAAQ,CAAC,IAAI,EAAE,MAAM,CAAC;CACvB,CAAC;AAEF,MAAM,MAAM,iBAAiB,GAAG;IAC9B,QAAQ,CAAC,IAAI,EAAE,MAAM,CAAC;IACtB,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC;IAC5B,QAAQ,CAAC,QAAQ,EAAE,MAAM,CAAC;IAC1B,QAAQ,CAAC,KAAK,EAAE,iBAAiB,GAAG,iBAAiB,GAAG,kBAAkB,GAAG,cAAc,CAAC;IAC5F,QAAQ,CAAC,KAAK,CAAC,EAAE,OAAO,CAAC;IACzB,QAAQ,CAAC,MAAM,CAAC,EAAE,OAAO,CAAC;IAC1B,QAAQ,CAAC,SAAS,CAAC,EAAE,MAAM,CAAC;CAC7B,CAAC;AAEF,MAAM,MAAM,mBAAmB,GAAG;IAChC,QAAQ,CAAC,IAAI,EAAE,QAAQ,CAAC;IACxB,QAAQ,CAAC,KAAK,CAAC,EAAE,MAAM,CAAC;IACxB,QAAQ,CAAC,GAAG,EAAE,MAAM,CAAC;CACtB,CAAC;AAEF,MAAM,MAAM,iBAAiB,GAAG;IAC9B,QAAQ,CAAC,IAAI,EAAE,MAAM,CAAC;IACtB,QAAQ,CAAC,IAAI,EAAE,OAAO,CAAC;CACxB,CAAC;AAEF,MAAM,MAAM,oBAAoB,GAC5B,iBAAiB,GACjB,iBAAiB,GACjB,mBAAmB,GACnB,iBAAiB,CAAC;AAEtB,MAAM,MAAM,sBAAsB,GAAG,WAAW,GAAG,UAAU,GAAG,OAAO,GAAG,SAAS,CAAC;AAEpF,MAAM,MAAM,gBAAgB,GAAG;IAC7B,QAAQ,CAAC,EAAE,EAAE,MAAM,CAAC;IACpB,QAAQ,CAAC,IAAI,EAAE,MAAM,GAAG,WAAW,CAAC;IACpC,QAAQ,CAAC,OAAO,EAAE,MAAM,CAAC;IACzB,QAAQ,CAAC,KAAK,EAAE,aAAa,CAAC,oBAAoB,CAAC,CAAC;IACpD,QAAQ,CAAC,MAAM,EAAE,sBAAsB,CAAC;IACxC,QAAQ,CAAC,OAAO,CAAC,EAAE,gBAAgB,CAAC;IACpC,2DAA2D;IAC3D,QAAQ,CAAC,SAAS,CAAC,EAAE,MAAM,CAAC;IAC5B,QAAQ,CAAC,QAAQ,CAAC,EAAE,iBAAiB,CAAC;CACvC,CAAC;AAEF,MAAM,MAAM,eAAe,GAAG,OAAO,GAAG,WAAW,GAAG,WAAW,GAAG,OAAO,GAAG,WAAW,CAAC;AAE1F,MAAM,MAAM,kBAAkB,GAC1B,SAAS,GACT,kBAAkB,GAClB,WAAW,GACX,eAAe,GACf,eAAe,GACf,cAAc,GACd,iBAAiB,GACjB,aAAa,CAAC;AAElB,MAAM,MAAM,sBAAsB,GAAG;IACnC,QAAQ,CAAC,IAAI,EAAE,gBAAgB,CAAC;IAChC,QAAQ,CAAC,IAAI,EAAE,kBAAkB,CAAC;IAClC,QAAQ,CAAC,OAAO,EAAE,MAAM,CAAC;IACzB,QAAQ,CAAC,SAAS,EAAE,OAAO,CAAC;IAC5B,QAAQ,CAAC,MAAM,CAAC,EAAE,MAAM,CAAC;IACzB,QAAQ,CAAC,eAAe,CAAC,EAAE,wBAAwB,CAAC;IACpD,QAAQ,CAAC,KAAK,CAAC,EAAE,MAAM,CAAC;CACzB,CAAC;AAEF,MAAM,MAAM,iBAAiB,GAAG;IAC9B,QAAQ,CAAC,MAAM,EAAE,eAAe,CAAC;IACjC,QAAQ,CAAC,QAAQ,EAAE,aAAa,CAAC,gBAAgB,CAAC,CAAC;IACnD,QAAQ,CAAC,IAAI,EAAE,aAAa,CAAC,OAAO,CAAC,CAAC;IACtC,QAAQ,CAAC,OAAO,CAAC,EAAE,gBAAgB,CAAC;IACpC,QAAQ,CAAC,QAAQ,CAAC,EAAE,MAAM,CAAC;IAC3B,QAAQ,CAAC,SAAS,CAAC,EAAE,MAAM,CAAC;IAC5B,QAAQ,CAAC,KAAK,CAAC,EAAE,sBAAsB,CAAC;IACxC,QAAQ,CAAC,WAAW,EAAE,oBAAoB,CAAC;CAC5C,CAAC;AAEF,MAAM,MAAM,qBAAqB,GAAG;IAClC,QAAQ,CAAC,QAAQ,CAAC,EAAE,MAAM,CAAC;IAC3B,QAAQ,CAAC,SAAS,CAAC,EAAE,MAAM,CAAC;CAC7B,CAAC;AAEF,MAAM,WAAW,uBAAuB;IACtC,gBAAgB,IAAI,qBAAqB,GAAG,SAAS,CAAC;IACtD,gBAAgB,CAAC,YAAY,EAAE,qBAAqB,GAAG,IAAI,CAAC;IAC5D,iBAAiB,IAAI,IAAI,CAAC;CAC3B;AAED,MAAM,WAAW,2BAA2B;IAC1C,QAAQ,CAAC,OAAO,EAAE,OAAO,CAAC;IAC1B,SAAS,CAAC,QAAQ,EAAE,MAAM,IAAI,GAAG,MAAM,IAAI,CAAC;CAC7C;AAED,MAAM,MAAM,6BAA6B,GAAG;IAC1C,QAAQ,CAAC,QAAQ,EAAE,aAAa,CAAC,gBAAgB,CAAC,CAAC;IACnD,QAAQ,CAAC,OAAO,EAAE,gBAAgB,CAAC;IACnC,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC;IAC5B,QAAQ,CAAC,aAAa,CAAC,EAAE,MAAM,CAAC;IAChC,QAAQ,CAAC,WAAW,EAAE,MAAM,CAAC;IAC7B,QAAQ,CAAC,OAAO,CAAC,EAAE,aAAa,CAAC,oBAAoB,CAAC,CAAC;IACvD,QAAQ,CAAC,WAAW,CAAC,EAAE,MAAM,CAAC;IAC9B,QAAQ,CAAC,OAAO,CAAC,EAAE,MAAM,CAAC;IAC1B,QAAQ,CAAC,QAAQ,CAAC,EAAE,MAAM,CAAC;IAC3B,QAAQ,CAAC,OAAO,CAAC,EAAE,MAAM,CAAC;IAC1B,QAAQ,CAAC,QAAQ,CAAC,EAAE,MAAM,CAAC;IAC3B,QAAQ,CAAC,SAAS,CAAC,EAAE,MAAM,CAAC;IAC5B,QAAQ,CAAC,UAAU,CAAC,EAAE,OAAO,CAAC;CAC/B,CAAC;AAEF,MAAM,MAAM,iCAAiC,GAAG;IAC9C,QAAQ,CAAC,SAAS,EAAE,MAAM,CAAC;IAC3B,QAAQ,CAAC,QAAQ,EAAE,iBAAiB,CAAC;IACrC,QAAQ,CAAC,OAAO,EAAE,gBAAgB,CAAC;IACnC,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC;IAC5B,QAAQ,CAAC,aAAa,CAAC,EAAE,MAAM,CAAC;IAChC,QAAQ,CAAC,WAAW,EAAE,MAAM,CAAC;IAC7B,QAAQ,CAAC,QAAQ,CAAC,EAAE,MAAM,CAAC;IAC3B,QAAQ,CAAC,SAAS,CAAC,EAAE,MAAM,CAAC;CAC7B,CAAC;AAEF,MAAM,MAAM,uBAAuB,GAC/B;IACE,IAAI,EAAE,OAAO,CAAC;IACd,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,SAAS,CAAC,EAAE,MAAM,CAAC;CACpB,GACD;IACE,IAAI,EAAE,YAAY,CAAC;IACnB,KAAK,EAAE,MAAM,CAAC;CACf,GACD;IACE,IAAI,EAAE,SAAS,CAAC;IAChB,OAAO,EAAE,MAAM,CAAC;IAChB,KAAK,CAAC,EAAE,aAAa,CAAC,oBAAoB,CAAC,CAAC;IAC5C,SAAS,CAAC,EAAE,MAAM,CAAC;CACpB,GACD;IACE,IAAI,EAAE,MAAM,CAAC;IACb,IAAI,EAAE,OAAO,CAAC;CACf,GACD;IACE,IAAI,EAAE,QAAQ,CAAC;IACf,OAAO,CAAC,EAAE,MAAM,CAAC;IACjB,KAAK,CAAC,EAAE,aAAa,CAAC,oBAAoB,CAAC,CAAC;IAC5C,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,SAAS,CAAC,EAAE,MAAM,CAAC;CACpB,CAAC;AAEN,MAAM,WAAW,kBAAkB;IACjC,IAAI,CACF,OAAO,EAAE,6BAA6B,EACtC,MAAM,EAAE,2BAA2B,GAClC,aAAa,CAAC,uBAAuB,CAAC,CAAC;IAC1C,cAAc,CAAC,OAAO,EAAE,iCAAiC,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAC1E,OAAO,CAAC,IAAI,IAAI,CAAC;CAClB;AAED,MAAM,MAAM,uBAAuB,GAC/B;IACE,IAAI,EAAE,WAAW,CAAC;IAClB,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,SAAS,CAAC,EAAE,MAAM,CAAC;IACnB,QAAQ,EAAE,0BAA0B,CAAC;CACtC,GACD;IACE,IAAI,EAAE,SAAS,CAAC;IAChB,KAAK,EAAE,sBAAsB,CAAC;IAC9B,QAAQ,EAAE,0BAA0B,CAAC;CACtC,GACD;IACE,IAAI,EAAE,oBAAoB,CAAC;IAC3B,SAAS,EAAE,MAAM,CAAC;IAClB,QAAQ,EAAE,iBAAiB,CAAC;IAC5B,QAAQ,EAAE,0BAA0B,CAAC;CACtC,GACD;IACE,IAAI,EAAE,YAAY,CAAC;IACnB,QAAQ,EAAE,0BAA0B,CAAC;CACtC,CAAC;AAEN,MAAM,MAAM,iBAAiB,GAAG;IAC9B,QAAQ,CAAC,OAAO,EAAE,gBAAgB,CAAC;IACnC,QAAQ,CAAC,UAAU,EAAE,MAAM,CAAC;IAC5B,QAAQ,CAAC,aAAa,CAAC,EAAE,MAAM,CAAC;CACjC,CAAC;AAEF,MAAM,MAAM,0BAA0B,GAAG,iBAAiB,GAAG;IAC3D,QAAQ,CAAC,WAAW,EAAE,MAAM,CAAC;CAC9B,CAAC;AAEF,MAAM,MAAM,oBAAoB,GAAG;IACjC,QAAQ,CAAC,SAAS,EAAE,kBAAkB,CAAC;IACvC,QAAQ,CAAC,OAAO,CAAC,EAAE,uBAAuB,CAAC;IAC3C,QAAQ,CAAC,QAAQ,EAAE,iBAAiB,CAAC;IACrC,QAAQ,CAAC,OAAO,CAAC,EAAE,gBAAgB,CAAC;IACpC,QAAQ,CAAC,QAAQ,CAAC,EAAE,MAAM,MAAM,CAAC;IACjC,QAAQ,CAAC,OAAO,CAAC,EAAE,CAAC,KAAK,EAAE,uBAAuB,KAAK,IAAI,CAAC;CAC7D,CAAC;AAEF,MAAM,MAAM,kBAAkB,GAAG;IAC/B,QAAQ,CAAC,OAAO,EAAE,MAAM,CAAC;IACzB,QAAQ,CAAC,OAAO,CAAC,EAAE,gBAAgB,CAAC;IACpC,QAAQ,CAAC,OAAO,CAAC,EAAE,gBAAgB,CAAC;IACpC,QAAQ,CAAC,UAAU,CAAC,EAAE,MAAM,CAAC;CAC9B,CAAC;AAEF,MAAM,MAAM,sBAAsB,GAAG;IACnC,QAAQ,CAAC,SAAS,EAAE,MAAM,CAAC;IAC3B,QAAQ,CAAC,QAAQ,EAAE,iBAAiB,CAAC;CACtC,CAAC;AAEF,MAAM,WAAW,aAAa;IAC5B,IAAI,CAAC,KAAK,EAAE,kBAAkB,GAAG,OAAO,CAAC,iBAAiB,CAAC,CAAC;IAC5D,KAAK,IAAI,IAAI,CAAC;IACd,KAAK,IAAI,OAAO,CAAC,iBAAiB,CAAC,CAAC;IACpC,SAAS,IAAI,iBAAiB,CAAC;IAC/B,UAAU,CAAC,OAAO,CAAC,EAAE,gBAAgB,GAAG,IAAI,CAAC;IAC7C,cAAc,CAAC,KAAK,EAAE,sBAAsB,GAAG,OAAO,CAAC,IAAI,CAAC,CAAC;IAC7D,WAAW,IAAI,iBAAiB,CAAC;IACjC,SAAS,CAAC,QAAQ,EAAE,CAAC,QAAQ,EAAE,iBAAiB,KAAK,IAAI,GAAG,MAAM,IAAI,CAAC;IACvE,OAAO,IAAI,IAAI,CAAC;CACjB"}
-2
dist/types.js
export {};
//# sourceMappingURL=types.js.map
-1
dist/types.js.map
{"version":3,"file":"types.js","sourceRoot":"","sources":["../src/types.ts"],"names":[],"mappings":""}