mirror of
https://github.com/danny-avila/LibreChat.git
synced 2025-12-17 08:50:15 +01:00
* 🪦 refactor: Remove Legacy Code (#10533) * 🗑️ chore: Remove unused Legacy Provider clients and related helpers * Deleted OpenAIClient and GoogleClient files along with their associated tests. * Removed references to these clients in the clients index file. * Cleaned up typedefs by removing the OpenAISpecClient export. * Updated chat controllers to use the OpenAI SDK directly instead of the removed client classes. * chore/remove-openapi-specs * 🗑️ chore: Remove unused mergeSort and misc utility functions * Deleted mergeSort.js and misc.js files as they are no longer needed. * Removed references to cleanUpPrimaryKeyValue in messages.js and adjusted related logic. * Updated mongoMeili.ts to eliminate local implementations of removed functions. * chore: remove legacy endpoints * chore: remove all plugins endpoint related code * chore: remove unused prompt handling code and clean up imports * Deleted handleInputs.js and instructions.js files as they are no longer needed. * Removed references to these files in the prompts index.js. * Updated docker-compose.yml to simplify reverse proxy configuration. * chore: remove unused LightningIcon import from Icons.tsx * chore: clean up translation.json by removing deprecated and unused keys * chore: update Jest configuration and remove unused mock file * Simplified the setupFiles array in jest.config.js by removing the fetchEventSource mock. * Deleted the fetchEventSource.js mock file as it is no longer needed. * fix: simplify endpoint type check in Landing and ConversationStarters components * Updated the endpoint type check to use strict equality for better clarity and performance. * Ensured consistency in the handling of the azureOpenAI endpoint across both components. * chore: remove unused dependencies from package.json and package-lock.json * chore: remove legacy EditController, associated routes and imports * chore: update banResponse logic to refine request handling for banned users * chore: remove unused validateEndpoint middleware and its references * chore: remove unused 'res' parameter from initializeClient in multiple endpoint files * chore: remove unused 'isSmallScreen' prop from BookmarkNav and NewChat components; clean up imports in ArchivedChatsTable and useSetIndexOptions hooks; enhance localization in PromptVersions * chore: remove unused import of Constants and TMessage from MobileNav; retain only necessary QueryKeys import * chore: remove unused TResPlugin type and related references; clean up imports in types and schemas * 🪦 refactor: Remove Legacy Code (#10533) * 🗑️ chore: Remove unused Legacy Provider clients and related helpers * Deleted OpenAIClient and GoogleClient files along with their associated tests. * Removed references to these clients in the clients index file. * Cleaned up typedefs by removing the OpenAISpecClient export. * Updated chat controllers to use the OpenAI SDK directly instead of the removed client classes. * chore/remove-openapi-specs * 🗑️ chore: Remove unused mergeSort and misc utility functions * Deleted mergeSort.js and misc.js files as they are no longer needed. * Removed references to cleanUpPrimaryKeyValue in messages.js and adjusted related logic. * Updated mongoMeili.ts to eliminate local implementations of removed functions. * chore: remove legacy endpoints * chore: remove all plugins endpoint related code * chore: remove unused prompt handling code and clean up imports * Deleted handleInputs.js and instructions.js files as they are no longer needed. * Removed references to these files in the prompts index.js. * Updated docker-compose.yml to simplify reverse proxy configuration. * chore: remove unused LightningIcon import from Icons.tsx * chore: clean up translation.json by removing deprecated and unused keys * chore: update Jest configuration and remove unused mock file * Simplified the setupFiles array in jest.config.js by removing the fetchEventSource mock. * Deleted the fetchEventSource.js mock file as it is no longer needed. * fix: simplify endpoint type check in Landing and ConversationStarters components * Updated the endpoint type check to use strict equality for better clarity and performance. * Ensured consistency in the handling of the azureOpenAI endpoint across both components. * chore: remove unused dependencies from package.json and package-lock.json * chore: remove legacy EditController, associated routes and imports * chore: update banResponse logic to refine request handling for banned users * chore: remove unused validateEndpoint middleware and its references * chore: remove unused 'res' parameter from initializeClient in multiple endpoint files * chore: remove unused 'isSmallScreen' prop from BookmarkNav and NewChat components; clean up imports in ArchivedChatsTable and useSetIndexOptions hooks; enhance localization in PromptVersions * chore: remove unused import of Constants and TMessage from MobileNav; retain only necessary QueryKeys import * chore: remove unused TResPlugin type and related references; clean up imports in types and schemas * 📦 chore: Bump Express.js to v5 (#10671) * chore: update express to version 5.1.0 in package.json * chore: update express-rate-limit to version 8.2.1 in package.json and package-lock.json * fix: Enhance server startup error handling in experimental and index files * Added error handling for server startup in both experimental.js and index.js to log errors and exit the process if the server fails to start. * Updated comments in openidStrategy.js to clarify the purpose of the CustomOpenIDStrategy class and its relation to Express version changes. * chore: Implement rate limiting for all POST routes excluding /speech, required for express v5 * Added middleware to apply IP and user rate limiters to all POST requests, ensuring that the /speech route remains unaffected. * Enhanced code clarity with comments explaining the new rate limiting logic. * chore: Enable writable req.query for mongoSanitize compatibility in Express 5 * chore: Ensure req.body exists in multiple middleware and route files for Express 5 compatibility * 🗣 feat: MCP Status Accessibility Improvements (#10738) * feat: make MultiSelect highlight same opacity as other focus highlights in app * feat: add better screenreader announcements for mcp server and variable states * feat: memoize fullTitle calculation * 🪨 feat: Add PROXY support for AWS Bedrock endpoints (#8871) * feat: added PROXY support for AWS Bedrock endpoint * chore: explicit install of new packages required for bedrock proxy --------- Co-authored-by: Danny Avila <danny@librechat.ai> * ✨ feat: Implement Favorites functionality with controllers, hooks, and UI components * ✨ feat: Refactor Favorites functionality to support new data structure and enhance UI interactions * ✨ feat: Add endpoint to new conversation for agent favorites * ✨ feat: Enhance Conversations and Favorites components with expanded functionality and improved UI interactions * ✨ feat: Remove 'Pinned' label from UI translations for cleaner interface * feat: clean up comments and improve code readability in favorites and agent components; bump @librechat/data-schemas to 0.0.24 * ✨ feat: Enhance favorites management with validation, update data structure, and improve UI interactions * ✨ feat: Simplify rendering logic in EndpointModelItem and optimize useEffect dependencies in Conversations component * ✨ test: Update favorites mock implementation and improve button focus styles in AgentDetail tests * ✨ feat: Enhance favorites management by adding loading and error states, and refactor related hooks and components * ✨ feat: Add loading skeletons for favorites while agents are being fetched * ✨ feat: Improve loading experience in FavoritesList by adding skeleton placeholders for favorites and marketplace * feat: Optimize cache handling in Conversations and enhance FavoritesList to notify height changes on loading completion * ✨ feat: Add loading skeleton for SearchBar in Nav component and update agent avatar fallback icon to Feather * feat: Refactor FavoritesController validation, streamline ModelSelector component, and enhance EndpointModelItem with selection state * feat: Adjust padding in Conversations and FavoritesList components for improved layout consistency * feat: Refactor FavoritesController to use model methods for user updates and retrieval * feat: Enhance Favorites functionality with validation, cleanup, and improved error handling * tests: Update AgentCard and agent utilities to use Feather icon fallback instead of Bot icon * refactor: Remove collapsible animation styles from CSS * feat: Migrate favorites state management from Recoil to Jotai * fix: Correct type definition in useGetFavoritesQuery and ensure useFavorites is exported * refactor: Simplify AuthField component by removing TooltipAnchor and directly rendering Label * fix: Ensure favorites are always an array and update references in FavoritesList * style: Update Conversation component styles for improved UI consistency * feat: re-integrate AuthContext to manage agent marketplace visibility based on authentication state * fix: Improve optimistic updates in favorites mutation handling * feat: Implement error handling for favorites limit and consolidate marketplace access logic * fix: package-lock --------- Co-authored-by: Danny Avila <danny@librechat.ai> Co-authored-by: Dustin Healy <54083382+dustinhealy@users.noreply.github.com> Co-authored-by: Arthur Barrett <abarrett@fas.harvard.edu>
994 lines
27 KiB
TypeScript
994 lines
27 KiB
TypeScript
import type { AxiosResponse } from 'axios';
|
|
import type * as t from './types';
|
|
import * as endpoints from './api-endpoints';
|
|
import * as a from './types/assistants';
|
|
import * as ag from './types/agents';
|
|
import * as m from './types/mutations';
|
|
import * as q from './types/queries';
|
|
import * as f from './types/files';
|
|
import * as mcp from './types/mcpServers';
|
|
import * as config from './config';
|
|
import request from './request';
|
|
import * as s from './schemas';
|
|
import * as r from './roles';
|
|
import * as permissions from './accessPermissions';
|
|
|
|
export function revokeUserKey(name: string): Promise<unknown> {
|
|
return request.delete(endpoints.revokeUserKey(name));
|
|
}
|
|
|
|
export function revokeAllUserKeys(): Promise<unknown> {
|
|
return request.delete(endpoints.revokeAllUserKeys());
|
|
}
|
|
|
|
export function deleteUser(): Promise<s.TPreset> {
|
|
return request.delete(endpoints.deleteUser());
|
|
}
|
|
|
|
export type FavoriteItem = {
|
|
agentId?: string;
|
|
model?: string;
|
|
endpoint?: string;
|
|
};
|
|
|
|
export function getFavorites(): Promise<FavoriteItem[]> {
|
|
return request.get('/api/user/settings/favorites');
|
|
}
|
|
|
|
export function updateFavorites(favorites: FavoriteItem[]): Promise<FavoriteItem[]> {
|
|
return request.post('/api/user/settings/favorites', { favorites });
|
|
}
|
|
|
|
export function getSharedMessages(shareId: string): Promise<t.TSharedMessagesResponse> {
|
|
return request.get(endpoints.shareMessages(shareId));
|
|
}
|
|
|
|
export const listSharedLinks = async (
|
|
params: q.SharedLinksListParams,
|
|
): Promise<q.SharedLinksResponse> => {
|
|
const { pageSize, isPublic, sortBy, sortDirection, search, cursor } = params;
|
|
|
|
return request.get(
|
|
endpoints.getSharedLinks(pageSize, isPublic, sortBy, sortDirection, search, cursor),
|
|
);
|
|
};
|
|
|
|
export function getSharedLink(conversationId: string): Promise<t.TSharedLinkGetResponse> {
|
|
return request.get(endpoints.getSharedLink(conversationId));
|
|
}
|
|
|
|
export function createSharedLink(
|
|
conversationId: string,
|
|
targetMessageId?: string,
|
|
): Promise<t.TSharedLinkResponse> {
|
|
return request.post(endpoints.createSharedLink(conversationId), { targetMessageId });
|
|
}
|
|
|
|
export function updateSharedLink(shareId: string): Promise<t.TSharedLinkResponse> {
|
|
return request.patch(endpoints.updateSharedLink(shareId));
|
|
}
|
|
|
|
export function deleteSharedLink(shareId: string): Promise<m.TDeleteSharedLinkResponse> {
|
|
return request.delete(endpoints.shareMessages(shareId));
|
|
}
|
|
|
|
export function updateUserKey(payload: t.TUpdateUserKeyRequest) {
|
|
const { value } = payload;
|
|
if (!value) {
|
|
throw new Error('value is required');
|
|
}
|
|
|
|
return request.put(endpoints.keys(), payload);
|
|
}
|
|
|
|
export function getPresets(): Promise<s.TPreset[]> {
|
|
return request.get(endpoints.presets());
|
|
}
|
|
|
|
export function createPreset(payload: s.TPreset): Promise<s.TPreset> {
|
|
return request.post(endpoints.presets(), payload);
|
|
}
|
|
|
|
export function updatePreset(payload: s.TPreset): Promise<s.TPreset> {
|
|
return request.post(endpoints.presets(), payload);
|
|
}
|
|
|
|
export function deletePreset(arg: s.TPreset | undefined): Promise<m.PresetDeleteResponse> {
|
|
return request.post(endpoints.deletePreset(), arg);
|
|
}
|
|
|
|
export function getSearchEnabled(): Promise<boolean> {
|
|
return request.get(endpoints.searchEnabled());
|
|
}
|
|
|
|
export function getUser(): Promise<t.TUser> {
|
|
return request.get(endpoints.user());
|
|
}
|
|
|
|
export function getUserBalance(): Promise<t.TBalanceResponse> {
|
|
return request.get(endpoints.balance());
|
|
}
|
|
|
|
export const updateTokenCount = (text: string) => {
|
|
return request.post(endpoints.tokenizer(), { arg: text });
|
|
};
|
|
|
|
export const login = (payload: t.TLoginUser): Promise<t.TLoginResponse> => {
|
|
return request.post(endpoints.login(), payload);
|
|
};
|
|
|
|
export const logout = (): Promise<m.TLogoutResponse> => {
|
|
return request.post(endpoints.logout());
|
|
};
|
|
|
|
export const register = (payload: t.TRegisterUser) => {
|
|
return request.post(endpoints.register(), payload);
|
|
};
|
|
|
|
export const userKeyQuery = (name: string): Promise<t.TCheckUserKeyResponse> =>
|
|
request.get(endpoints.userKeyQuery(name));
|
|
|
|
export const getLoginGoogle = () => {
|
|
return request.get(endpoints.loginGoogle());
|
|
};
|
|
|
|
export const requestPasswordReset = (
|
|
payload: t.TRequestPasswordReset,
|
|
): Promise<t.TRequestPasswordResetResponse> => {
|
|
return request.post(endpoints.requestPasswordReset(), payload);
|
|
};
|
|
|
|
export const resetPassword = (payload: t.TResetPassword) => {
|
|
return request.post(endpoints.resetPassword(), payload);
|
|
};
|
|
|
|
export const verifyEmail = (payload: t.TVerifyEmail): Promise<t.VerifyEmailResponse> => {
|
|
return request.post(endpoints.verifyEmail(), payload);
|
|
};
|
|
|
|
export const resendVerificationEmail = (
|
|
payload: t.TResendVerificationEmail,
|
|
): Promise<t.VerifyEmailResponse> => {
|
|
return request.post(endpoints.resendVerificationEmail(), payload);
|
|
};
|
|
|
|
export const getAvailablePlugins = (): Promise<s.TPlugin[]> => {
|
|
return request.get(endpoints.plugins());
|
|
};
|
|
|
|
export const updateUserPlugins = (payload: t.TUpdateUserPlugins) => {
|
|
return request.post(endpoints.userPlugins(), payload);
|
|
};
|
|
|
|
export const reinitializeMCPServer = (serverName: string) => {
|
|
return request.post(endpoints.mcpReinitialize(serverName));
|
|
};
|
|
|
|
export const getMCPConnectionStatus = (): Promise<q.MCPConnectionStatusResponse> => {
|
|
return request.get(endpoints.mcpConnectionStatus());
|
|
};
|
|
|
|
export const getMCPServerConnectionStatus = (
|
|
serverName: string,
|
|
): Promise<q.MCPServerConnectionStatusResponse> => {
|
|
return request.get(endpoints.mcpServerConnectionStatus(serverName));
|
|
};
|
|
|
|
export const getMCPAuthValues = (serverName: string): Promise<q.MCPAuthValuesResponse> => {
|
|
return request.get(endpoints.mcpAuthValues(serverName));
|
|
};
|
|
|
|
export function cancelMCPOAuth(serverName: string): Promise<m.CancelMCPOAuthResponse> {
|
|
return request.post(endpoints.cancelMCPOAuth(serverName), {});
|
|
}
|
|
|
|
/* Config */
|
|
|
|
export const getStartupConfig = (): Promise<
|
|
config.TStartupConfig & {
|
|
mcpCustomUserVars?: Record<string, { title: string; description: string }>;
|
|
}
|
|
> => {
|
|
return request.get(endpoints.config());
|
|
};
|
|
|
|
export const getAIEndpoints = (): Promise<t.TEndpointsConfig> => {
|
|
return request.get(endpoints.aiEndpoints());
|
|
};
|
|
|
|
export const getModels = async (): Promise<t.TModelsConfig> => {
|
|
return request.get(endpoints.models());
|
|
};
|
|
|
|
/* Assistants */
|
|
|
|
export const createAssistant = ({
|
|
version,
|
|
...data
|
|
}: a.AssistantCreateParams): Promise<a.Assistant> => {
|
|
return request.post(endpoints.assistants({ version }), data);
|
|
};
|
|
|
|
export const getAssistantById = ({
|
|
endpoint,
|
|
assistant_id,
|
|
version,
|
|
}: {
|
|
endpoint: s.AssistantsEndpoint;
|
|
assistant_id: string;
|
|
version: number | string | number;
|
|
}): Promise<a.Assistant> => {
|
|
return request.get(
|
|
endpoints.assistants({
|
|
path: assistant_id,
|
|
endpoint,
|
|
version,
|
|
}),
|
|
);
|
|
};
|
|
|
|
export const updateAssistant = ({
|
|
assistant_id,
|
|
data,
|
|
version,
|
|
}: {
|
|
assistant_id: string;
|
|
data: a.AssistantUpdateParams;
|
|
version: number | string;
|
|
}): Promise<a.Assistant> => {
|
|
return request.patch(
|
|
endpoints.assistants({
|
|
path: assistant_id,
|
|
version,
|
|
}),
|
|
data,
|
|
);
|
|
};
|
|
|
|
export const deleteAssistant = ({
|
|
assistant_id,
|
|
model,
|
|
endpoint,
|
|
version,
|
|
}: m.DeleteAssistantBody & { version: number | string }): Promise<void> => {
|
|
return request.delete(
|
|
endpoints.assistants({
|
|
path: assistant_id,
|
|
options: { model, endpoint },
|
|
version,
|
|
}),
|
|
);
|
|
};
|
|
|
|
export const listAssistants = (
|
|
params: a.AssistantListParams,
|
|
version: number | string,
|
|
): Promise<a.AssistantListResponse> => {
|
|
return request.get(
|
|
endpoints.assistants({
|
|
version,
|
|
options: params,
|
|
}),
|
|
);
|
|
};
|
|
|
|
export function getAssistantDocs({
|
|
endpoint,
|
|
version,
|
|
}: {
|
|
endpoint: s.AssistantsEndpoint | string;
|
|
version: number | string;
|
|
}): Promise<a.AssistantDocument[]> {
|
|
if (!s.isAssistantsEndpoint(endpoint)) {
|
|
return Promise.resolve([]);
|
|
}
|
|
return request.get(
|
|
endpoints.assistants({
|
|
path: 'documents',
|
|
version,
|
|
options: { endpoint },
|
|
endpoint: endpoint as s.AssistantsEndpoint,
|
|
}),
|
|
);
|
|
}
|
|
|
|
/* Tools */
|
|
|
|
export const getAvailableTools = (
|
|
_endpoint: s.AssistantsEndpoint | s.EModelEndpoint.agents,
|
|
version?: number | string,
|
|
): Promise<s.TPlugin[]> => {
|
|
let path = '';
|
|
if (s.isAssistantsEndpoint(_endpoint)) {
|
|
const endpoint = _endpoint as s.AssistantsEndpoint;
|
|
path = endpoints.assistants({
|
|
path: 'tools',
|
|
endpoint: endpoint,
|
|
version: version ?? config.defaultAssistantsVersion[endpoint],
|
|
});
|
|
} else {
|
|
path = endpoints.agents({
|
|
path: 'tools',
|
|
});
|
|
}
|
|
|
|
return request.get(path);
|
|
};
|
|
|
|
/* MCP Tools - Decoupled from regular tools */
|
|
|
|
export const getMCPTools = (): Promise<q.MCPServersResponse> => {
|
|
return request.get(endpoints.mcp.tools);
|
|
};
|
|
|
|
export const getVerifyAgentToolAuth = (
|
|
params: q.VerifyToolAuthParams,
|
|
): Promise<q.VerifyToolAuthResponse> => {
|
|
return request.get(
|
|
endpoints.agents({
|
|
path: `tools/${params.toolId}/auth`,
|
|
}),
|
|
);
|
|
};
|
|
|
|
export const callTool = <T extends m.ToolId>({
|
|
toolId,
|
|
toolParams,
|
|
}: {
|
|
toolId: T;
|
|
toolParams: m.ToolParams<T>;
|
|
}): Promise<m.ToolCallResponse> => {
|
|
return request.post(
|
|
endpoints.agents({
|
|
path: `tools/${toolId}/call`,
|
|
}),
|
|
toolParams,
|
|
);
|
|
};
|
|
|
|
export const getToolCalls = (params: q.GetToolCallParams): Promise<q.ToolCallResults> => {
|
|
return request.get(
|
|
endpoints.agents({
|
|
path: 'tools/calls',
|
|
options: params,
|
|
}),
|
|
);
|
|
};
|
|
|
|
/* Files */
|
|
|
|
export const getFiles = (): Promise<f.TFile[]> => {
|
|
return request.get(endpoints.files());
|
|
};
|
|
|
|
export const getAgentFiles = (agentId: string): Promise<f.TFile[]> => {
|
|
return request.get(endpoints.agentFiles(agentId));
|
|
};
|
|
|
|
export const getFileConfig = (): Promise<f.FileConfig> => {
|
|
return request.get(`${endpoints.files()}/config`);
|
|
};
|
|
|
|
export const uploadImage = (
|
|
data: FormData,
|
|
signal?: AbortSignal | null,
|
|
): Promise<f.TFileUpload> => {
|
|
const requestConfig = signal ? { signal } : undefined;
|
|
return request.postMultiPart(endpoints.images(), data, requestConfig);
|
|
};
|
|
|
|
export const uploadFile = (data: FormData, signal?: AbortSignal | null): Promise<f.TFileUpload> => {
|
|
const requestConfig = signal ? { signal } : undefined;
|
|
return request.postMultiPart(endpoints.files(), data, requestConfig);
|
|
};
|
|
|
|
/* actions */
|
|
|
|
export const updateAction = (data: m.UpdateActionVariables): Promise<m.UpdateActionResponse> => {
|
|
const { assistant_id, version, ...body } = data;
|
|
return request.post(
|
|
endpoints.assistants({
|
|
path: `actions/${assistant_id}`,
|
|
version,
|
|
}),
|
|
body,
|
|
);
|
|
};
|
|
|
|
export function getActions(): Promise<ag.Action[]> {
|
|
return request.get(
|
|
endpoints.agents({
|
|
path: 'actions',
|
|
}),
|
|
);
|
|
}
|
|
|
|
export const deleteAction = async ({
|
|
assistant_id,
|
|
action_id,
|
|
model,
|
|
version,
|
|
endpoint,
|
|
}: m.DeleteActionVariables & { version: number | string }): Promise<void> =>
|
|
request.delete(
|
|
endpoints.assistants({
|
|
path: `actions/${assistant_id}/${action_id}/${model}`,
|
|
version,
|
|
endpoint,
|
|
}),
|
|
);
|
|
|
|
/**
|
|
* Agents
|
|
*/
|
|
|
|
export const createAgent = ({ ...data }: a.AgentCreateParams): Promise<a.Agent> => {
|
|
return request.post(endpoints.agents({}), data);
|
|
};
|
|
|
|
export const getAgentById = ({ agent_id }: { agent_id: string }): Promise<a.Agent> => {
|
|
return request.get(
|
|
endpoints.agents({
|
|
path: agent_id,
|
|
}),
|
|
);
|
|
};
|
|
|
|
export const getExpandedAgentById = ({ agent_id }: { agent_id: string }): Promise<a.Agent> => {
|
|
return request.get(
|
|
endpoints.agents({
|
|
path: `${agent_id}/expanded`,
|
|
}),
|
|
);
|
|
};
|
|
|
|
export const updateAgent = ({
|
|
agent_id,
|
|
data,
|
|
}: {
|
|
agent_id: string;
|
|
data: a.AgentUpdateParams;
|
|
}): Promise<a.Agent> => {
|
|
return request.patch(
|
|
endpoints.agents({
|
|
path: agent_id,
|
|
}),
|
|
data,
|
|
);
|
|
};
|
|
|
|
export const duplicateAgent = ({
|
|
agent_id,
|
|
}: m.DuplicateAgentBody): Promise<{ agent: a.Agent; actions: ag.Action[] }> => {
|
|
return request.post(
|
|
endpoints.agents({
|
|
path: `${agent_id}/duplicate`,
|
|
}),
|
|
);
|
|
};
|
|
|
|
export const deleteAgent = ({ agent_id }: m.DeleteAgentBody): Promise<void> => {
|
|
return request.delete(
|
|
endpoints.agents({
|
|
path: agent_id,
|
|
}),
|
|
);
|
|
};
|
|
|
|
export const listAgents = (params: a.AgentListParams): Promise<a.AgentListResponse> => {
|
|
return request.get(
|
|
endpoints.agents({
|
|
options: params,
|
|
}),
|
|
);
|
|
};
|
|
|
|
export const revertAgentVersion = ({
|
|
agent_id,
|
|
version_index,
|
|
}: {
|
|
agent_id: string;
|
|
version_index: number;
|
|
}): Promise<a.Agent> => request.post(endpoints.revertAgentVersion(agent_id), { version_index });
|
|
|
|
/* Marketplace */
|
|
|
|
/**
|
|
* Get agent categories with counts for marketplace tabs
|
|
*/
|
|
export const getAgentCategories = (): Promise<t.TMarketplaceCategory[]> => {
|
|
return request.get(endpoints.agents({ path: 'categories' }));
|
|
};
|
|
|
|
/**
|
|
* Unified marketplace agents endpoint with query string controls
|
|
*/
|
|
export const getMarketplaceAgents = (params: {
|
|
requiredPermission: number;
|
|
category?: string;
|
|
search?: string;
|
|
limit?: number;
|
|
cursor?: string;
|
|
promoted?: 0 | 1;
|
|
}): Promise<a.AgentListResponse> => {
|
|
return request.get(
|
|
endpoints.agents({
|
|
// path: 'marketplace',
|
|
options: params,
|
|
}),
|
|
);
|
|
};
|
|
|
|
/* Tools */
|
|
|
|
export const getAvailableAgentTools = (): Promise<s.TPlugin[]> => {
|
|
return request.get(
|
|
endpoints.agents({
|
|
path: 'tools',
|
|
}),
|
|
);
|
|
};
|
|
|
|
/* Actions */
|
|
|
|
export const updateAgentAction = (
|
|
data: m.UpdateAgentActionVariables,
|
|
): Promise<m.UpdateAgentActionResponse> => {
|
|
const { agent_id, ...body } = data;
|
|
return request.post(
|
|
endpoints.agents({
|
|
path: `actions/${agent_id}`,
|
|
}),
|
|
body,
|
|
);
|
|
};
|
|
|
|
export const deleteAgentAction = async ({
|
|
agent_id,
|
|
action_id,
|
|
}: m.DeleteAgentActionVariables): Promise<void> =>
|
|
request.delete(
|
|
endpoints.agents({
|
|
path: `actions/${agent_id}/${action_id}`,
|
|
}),
|
|
);
|
|
|
|
/**
|
|
* MCP Servers
|
|
*/
|
|
|
|
/**
|
|
*
|
|
* Ensure and List loaded mcp server configs from the cache Enriched with effective permissions.
|
|
*/
|
|
export const getMCPServers = async (): Promise<mcp.MCPServersListResponse> => {
|
|
return request.get(endpoints.mcp.servers);
|
|
};
|
|
|
|
/**
|
|
* Imports a conversations file.
|
|
*
|
|
* @param data - The FormData containing the file to import.
|
|
* @returns A Promise that resolves to the import start response.
|
|
*/
|
|
export const importConversationsFile = (data: FormData): Promise<t.TImportResponse> => {
|
|
return request.postMultiPart(endpoints.importConversation(), data);
|
|
};
|
|
|
|
export const uploadAvatar = (data: FormData): Promise<f.AvatarUploadResponse> => {
|
|
return request.postMultiPart(endpoints.avatar(), data);
|
|
};
|
|
|
|
export const uploadAssistantAvatar = (data: m.AssistantAvatarVariables): Promise<a.Assistant> => {
|
|
return request.postMultiPart(
|
|
endpoints.assistants({
|
|
isAvatar: true,
|
|
path: `${data.assistant_id}/avatar`,
|
|
options: { model: data.model, endpoint: data.endpoint },
|
|
version: data.version,
|
|
}),
|
|
data.formData,
|
|
);
|
|
};
|
|
|
|
export const uploadAgentAvatar = (data: m.AgentAvatarVariables): Promise<a.Agent> => {
|
|
return request.postMultiPart(
|
|
`${endpoints.images()}/agents/${data.agent_id}/avatar`,
|
|
data.formData,
|
|
);
|
|
};
|
|
|
|
export const getFileDownload = async (userId: string, file_id: string): Promise<AxiosResponse> => {
|
|
return request.getResponse(`${endpoints.files()}/download/${userId}/${file_id}`, {
|
|
responseType: 'blob',
|
|
headers: {
|
|
Accept: 'application/octet-stream',
|
|
},
|
|
});
|
|
};
|
|
|
|
export const getCodeOutputDownload = async (url: string): Promise<AxiosResponse> => {
|
|
return request.getResponse(url, {
|
|
responseType: 'blob',
|
|
headers: {
|
|
Accept: 'application/octet-stream',
|
|
},
|
|
});
|
|
};
|
|
|
|
export const deleteFiles = async (payload: {
|
|
files: f.BatchFile[];
|
|
agent_id?: string;
|
|
assistant_id?: string;
|
|
tool_resource?: a.EToolResources;
|
|
}): Promise<f.DeleteFilesResponse> =>
|
|
request.deleteWithOptions(endpoints.files(), {
|
|
data: payload,
|
|
});
|
|
|
|
/* Speech */
|
|
|
|
export const speechToText = (data: FormData): Promise<f.SpeechToTextResponse> => {
|
|
return request.postMultiPart(endpoints.speechToText(), data);
|
|
};
|
|
|
|
export const textToSpeech = (data: FormData): Promise<ArrayBuffer> => {
|
|
return request.postTTS(endpoints.textToSpeechManual(), data);
|
|
};
|
|
|
|
export const getVoices = (): Promise<f.VoiceResponse> => {
|
|
return request.get(endpoints.textToSpeechVoices());
|
|
};
|
|
|
|
export const getCustomConfigSpeech = (): Promise<t.TCustomConfigSpeechResponse> => {
|
|
return request.get(endpoints.getCustomConfigSpeech());
|
|
};
|
|
|
|
/* conversations */
|
|
|
|
export function duplicateConversation(
|
|
payload: t.TDuplicateConvoRequest,
|
|
): Promise<t.TDuplicateConvoResponse> {
|
|
return request.post(endpoints.duplicateConversation(), payload);
|
|
}
|
|
|
|
export function forkConversation(payload: t.TForkConvoRequest): Promise<t.TForkConvoResponse> {
|
|
return request.post(endpoints.forkConversation(), payload);
|
|
}
|
|
|
|
export function deleteConversation(payload: t.TDeleteConversationRequest) {
|
|
return request.deleteWithOptions(endpoints.deleteConversation(), { data: { arg: payload } });
|
|
}
|
|
|
|
export function clearAllConversations(): Promise<unknown> {
|
|
return request.delete(endpoints.deleteAllConversation());
|
|
}
|
|
|
|
export const listConversations = (
|
|
params?: q.ConversationListParams,
|
|
): Promise<q.ConversationListResponse> => {
|
|
return request.get(endpoints.conversations(params ?? {}));
|
|
};
|
|
|
|
export function getConversations(cursor: string): Promise<t.TGetConversationsResponse> {
|
|
return request.get(endpoints.conversations({ cursor }));
|
|
}
|
|
|
|
export function getConversationById(id: string): Promise<s.TConversation> {
|
|
return request.get(endpoints.conversationById(id));
|
|
}
|
|
|
|
export function updateConversation(
|
|
payload: t.TUpdateConversationRequest,
|
|
): Promise<t.TUpdateConversationResponse> {
|
|
return request.post(endpoints.updateConversation(), { arg: payload });
|
|
}
|
|
|
|
export function archiveConversation(
|
|
payload: t.TArchiveConversationRequest,
|
|
): Promise<t.TArchiveConversationResponse> {
|
|
return request.post(endpoints.updateConversation(), { arg: payload });
|
|
}
|
|
|
|
export function genTitle(payload: m.TGenTitleRequest): Promise<m.TGenTitleResponse> {
|
|
return request.post(endpoints.genTitle(), payload);
|
|
}
|
|
|
|
export const listMessages = (params?: q.MessagesListParams): Promise<q.MessagesListResponse> => {
|
|
return request.get(endpoints.messages(params ?? {}));
|
|
};
|
|
|
|
export function updateMessage(payload: t.TUpdateMessageRequest): Promise<unknown> {
|
|
const { conversationId, messageId, text } = payload;
|
|
if (!conversationId) {
|
|
throw new Error('conversationId is required');
|
|
}
|
|
|
|
return request.put(endpoints.messages({ conversationId, messageId }), { text });
|
|
}
|
|
|
|
export function updateMessageContent(payload: t.TUpdateMessageContent): Promise<unknown> {
|
|
const { conversationId, messageId, index, text } = payload;
|
|
if (!conversationId) {
|
|
throw new Error('conversationId is required');
|
|
}
|
|
|
|
return request.put(endpoints.messages({ conversationId, messageId }), { text, index });
|
|
}
|
|
|
|
export const editArtifact = async ({
|
|
messageId,
|
|
...params
|
|
}: m.TEditArtifactRequest): Promise<m.TEditArtifactResponse> => {
|
|
return request.post(endpoints.messagesArtifacts(messageId), params);
|
|
};
|
|
|
|
export function getMessagesByConvoId(conversationId: string): Promise<s.TMessage[]> {
|
|
if (
|
|
conversationId === config.Constants.NEW_CONVO ||
|
|
conversationId === config.Constants.PENDING_CONVO
|
|
) {
|
|
return Promise.resolve([]);
|
|
}
|
|
return request.get(endpoints.messages({ conversationId }));
|
|
}
|
|
|
|
export function getPrompt(id: string): Promise<{ prompt: t.TPrompt }> {
|
|
return request.get(endpoints.getPrompt(id));
|
|
}
|
|
|
|
export function getPrompts(filter: t.TPromptsWithFilterRequest): Promise<t.TPrompt[]> {
|
|
return request.get(endpoints.getPromptsWithFilters(filter));
|
|
}
|
|
|
|
export function getAllPromptGroups(): Promise<q.AllPromptGroupsResponse> {
|
|
return request.get(endpoints.getAllPromptGroups());
|
|
}
|
|
|
|
export function getPromptGroups(
|
|
filter: t.TPromptGroupsWithFilterRequest,
|
|
): Promise<t.PromptGroupListResponse> {
|
|
return request.get(endpoints.getPromptGroupsWithFilters(filter));
|
|
}
|
|
|
|
export function getPromptGroup(id: string): Promise<t.TPromptGroup> {
|
|
return request.get(endpoints.getPromptGroup(id));
|
|
}
|
|
|
|
export function createPrompt(payload: t.TCreatePrompt): Promise<t.TCreatePromptResponse> {
|
|
return request.post(endpoints.postPrompt(), payload);
|
|
}
|
|
|
|
export function addPromptToGroup(
|
|
groupId: string,
|
|
payload: t.TCreatePrompt,
|
|
): Promise<t.TCreatePromptResponse> {
|
|
return request.post(endpoints.addPromptToGroup(groupId), payload);
|
|
}
|
|
|
|
export function updatePromptGroup(
|
|
variables: t.TUpdatePromptGroupVariables,
|
|
): Promise<t.TUpdatePromptGroupResponse> {
|
|
return request.patch(endpoints.updatePromptGroup(variables.id), variables.payload);
|
|
}
|
|
|
|
export function deletePrompt(payload: t.TDeletePromptVariables): Promise<t.TDeletePromptResponse> {
|
|
return request.delete(endpoints.deletePrompt(payload));
|
|
}
|
|
|
|
export function makePromptProduction(id: string): Promise<t.TMakePromptProductionResponse> {
|
|
return request.patch(endpoints.updatePromptTag(id));
|
|
}
|
|
|
|
export function updatePromptLabels(
|
|
variables: t.TUpdatePromptLabelsRequest,
|
|
): Promise<t.TUpdatePromptLabelsResponse> {
|
|
return request.patch(endpoints.updatePromptLabels(variables.id), variables.payload);
|
|
}
|
|
|
|
export function deletePromptGroup(id: string): Promise<t.TDeletePromptGroupResponse> {
|
|
return request.delete(endpoints.deletePromptGroup(id));
|
|
}
|
|
|
|
export function getCategories(): Promise<t.TGetCategoriesResponse> {
|
|
return request.get(endpoints.getCategories());
|
|
}
|
|
|
|
export function getRandomPrompts(
|
|
variables: t.TGetRandomPromptsRequest,
|
|
): Promise<t.TGetRandomPromptsResponse> {
|
|
return request.get(endpoints.getRandomPrompts(variables.limit, variables.skip));
|
|
}
|
|
|
|
/* Roles */
|
|
export function getRole(roleName: string): Promise<r.TRole> {
|
|
return request.get(endpoints.getRole(roleName));
|
|
}
|
|
|
|
export function updatePromptPermissions(
|
|
variables: m.UpdatePromptPermVars,
|
|
): Promise<m.UpdatePermResponse> {
|
|
return request.put(endpoints.updatePromptPermissions(variables.roleName), variables.updates);
|
|
}
|
|
|
|
export function updateAgentPermissions(
|
|
variables: m.UpdateAgentPermVars,
|
|
): Promise<m.UpdatePermResponse> {
|
|
return request.put(endpoints.updateAgentPermissions(variables.roleName), variables.updates);
|
|
}
|
|
|
|
export function updateMemoryPermissions(
|
|
variables: m.UpdateMemoryPermVars,
|
|
): Promise<m.UpdatePermResponse> {
|
|
return request.put(endpoints.updateMemoryPermissions(variables.roleName), variables.updates);
|
|
}
|
|
|
|
export function updatePeoplePickerPermissions(
|
|
variables: m.UpdatePeoplePickerPermVars,
|
|
): Promise<m.UpdatePermResponse> {
|
|
return request.put(
|
|
endpoints.updatePeoplePickerPermissions(variables.roleName),
|
|
variables.updates,
|
|
);
|
|
}
|
|
|
|
export function updateMarketplacePermissions(
|
|
variables: m.UpdateMarketplacePermVars,
|
|
): Promise<m.UpdatePermResponse> {
|
|
return request.put(endpoints.updateMarketplacePermissions(variables.roleName), variables.updates);
|
|
}
|
|
|
|
/* Tags */
|
|
export function getConversationTags(): Promise<t.TConversationTagsResponse> {
|
|
return request.get(endpoints.conversationTags());
|
|
}
|
|
|
|
export function createConversationTag(
|
|
payload: t.TConversationTagRequest,
|
|
): Promise<t.TConversationTagResponse> {
|
|
return request.post(endpoints.conversationTags(), payload);
|
|
}
|
|
|
|
export function updateConversationTag(
|
|
tag: string,
|
|
payload: t.TConversationTagRequest,
|
|
): Promise<t.TConversationTagResponse> {
|
|
return request.put(endpoints.conversationTags(tag), payload);
|
|
}
|
|
export function deleteConversationTag(tag: string): Promise<t.TConversationTagResponse> {
|
|
return request.delete(endpoints.conversationTags(tag));
|
|
}
|
|
|
|
export function addTagToConversation(
|
|
conversationId: string,
|
|
payload: t.TTagConversationRequest,
|
|
): Promise<t.TTagConversationResponse> {
|
|
return request.put(endpoints.addTagToConversation(conversationId), payload);
|
|
}
|
|
export function rebuildConversationTags(): Promise<t.TConversationTagsResponse> {
|
|
return request.post(endpoints.conversationTags('rebuild'));
|
|
}
|
|
|
|
export function healthCheck(): Promise<string> {
|
|
return request.get(endpoints.health());
|
|
}
|
|
|
|
export function getUserTerms(): Promise<t.TUserTermsResponse> {
|
|
return request.get(endpoints.userTerms());
|
|
}
|
|
|
|
export function acceptTerms(): Promise<t.TAcceptTermsResponse> {
|
|
return request.post(endpoints.acceptUserTerms());
|
|
}
|
|
|
|
export function getBanner(): Promise<t.TBannerResponse> {
|
|
return request.get(endpoints.banner());
|
|
}
|
|
|
|
export function updateFeedback(
|
|
conversationId: string,
|
|
messageId: string,
|
|
payload: t.TUpdateFeedbackRequest,
|
|
): Promise<t.TUpdateFeedbackResponse> {
|
|
return request.put(endpoints.feedback(conversationId, messageId), payload);
|
|
}
|
|
|
|
// 2FA
|
|
export function enableTwoFactor(): Promise<t.TEnable2FAResponse> {
|
|
return request.get(endpoints.enableTwoFactor());
|
|
}
|
|
|
|
export function verifyTwoFactor(payload: t.TVerify2FARequest): Promise<t.TVerify2FAResponse> {
|
|
return request.post(endpoints.verifyTwoFactor(), payload);
|
|
}
|
|
|
|
export function confirmTwoFactor(payload: t.TVerify2FARequest): Promise<t.TVerify2FAResponse> {
|
|
return request.post(endpoints.confirmTwoFactor(), payload);
|
|
}
|
|
|
|
export function disableTwoFactor(payload?: t.TDisable2FARequest): Promise<t.TDisable2FAResponse> {
|
|
return request.post(endpoints.disableTwoFactor(), payload);
|
|
}
|
|
|
|
export function regenerateBackupCodes(): Promise<t.TRegenerateBackupCodesResponse> {
|
|
return request.post(endpoints.regenerateBackupCodes());
|
|
}
|
|
|
|
export function verifyTwoFactorTemp(
|
|
payload: t.TVerify2FATempRequest,
|
|
): Promise<t.TVerify2FATempResponse> {
|
|
return request.post(endpoints.verifyTwoFactorTemp(), payload);
|
|
}
|
|
|
|
/* Memories */
|
|
export const getMemories = (): Promise<q.MemoriesResponse> => {
|
|
return request.get(endpoints.memories());
|
|
};
|
|
|
|
export const deleteMemory = (key: string): Promise<void> => {
|
|
return request.delete(endpoints.memory(key));
|
|
};
|
|
|
|
export const updateMemory = (
|
|
key: string,
|
|
value: string,
|
|
originalKey?: string,
|
|
): Promise<q.TUserMemory> => {
|
|
return request.patch(endpoints.memory(originalKey || key), { key, value });
|
|
};
|
|
|
|
export const updateMemoryPreferences = (preferences: {
|
|
memories: boolean;
|
|
}): Promise<{ updated: boolean; preferences: { memories: boolean } }> => {
|
|
return request.patch(endpoints.memoryPreferences(), preferences);
|
|
};
|
|
|
|
export const createMemory = (data: {
|
|
key: string;
|
|
value: string;
|
|
}): Promise<{ created: boolean; memory: q.TUserMemory }> => {
|
|
return request.post(endpoints.memories(), data);
|
|
};
|
|
|
|
export function searchPrincipals(
|
|
params: q.PrincipalSearchParams,
|
|
): Promise<q.PrincipalSearchResponse> {
|
|
return request.get(endpoints.searchPrincipals(params));
|
|
}
|
|
|
|
export function getAccessRoles(
|
|
resourceType: permissions.ResourceType,
|
|
): Promise<q.AccessRolesResponse> {
|
|
return request.get(endpoints.getAccessRoles(resourceType));
|
|
}
|
|
|
|
export function getResourcePermissions(
|
|
resourceType: permissions.ResourceType,
|
|
resourceId: string,
|
|
): Promise<permissions.TGetResourcePermissionsResponse> {
|
|
return request.get(endpoints.getResourcePermissions(resourceType, resourceId));
|
|
}
|
|
|
|
export function updateResourcePermissions(
|
|
resourceType: permissions.ResourceType,
|
|
resourceId: string,
|
|
data: permissions.TUpdateResourcePermissionsRequest,
|
|
): Promise<permissions.TUpdateResourcePermissionsResponse> {
|
|
return request.put(endpoints.updateResourcePermissions(resourceType, resourceId), data);
|
|
}
|
|
|
|
export function getEffectivePermissions(
|
|
resourceType: permissions.ResourceType,
|
|
resourceId: string,
|
|
): Promise<permissions.TEffectivePermissionsResponse> {
|
|
return request.get(endpoints.getEffectivePermissions(resourceType, resourceId));
|
|
}
|
|
|
|
// SharePoint Graph API Token
|
|
export function getGraphApiToken(params: q.GraphTokenParams): Promise<q.GraphTokenResponse> {
|
|
return request.get(endpoints.graphToken(params.scopes));
|
|
}
|
|
|
|
export function getDomainServerBaseUrl(): string {
|
|
return `${endpoints.apiBaseUrl()}/api`;
|
|
}
|