LibreChat/packages/data-provider/src/data-service.ts
Atef Bellaaj 526b1980bc
🔧 fix: Merge and Rebase Conflicts
- Move AgentCategory from api/models to @packages/data-schemas structure
  - Add schema, types, methods, and model following codebase conventions
  - Implement auto-seeding of default categories during AppService startup
  - Update marketplace controller to use new data-schemas methods
  - Remove old model file and standalone seed script

refactor: unify agent marketplace to single endpoint with cursor pagination

  - Replace multiple marketplace routes with unified /marketplace endpoint
  - Add query string controls: category, search, limit, cursor, promoted, requiredPermission
  - Implement cursor-based pagination replacing page-based system
  - Integrate ACL permissions for proper access control
  - Fix ObjectId constructor error in Agent model
  - Update React components to use unified useGetMarketplaceAgentsQuery hook
  - Enhance type safety and remove deprecated useDynamicAgentQuery
  - Update tests for new marketplace architecture
  -Known issues:
  see more button after category switching + Unit tests

feat: add icon property to ProcessedAgentCategory interface

- Add useMarketplaceAgentsInfiniteQuery and useGetAgentCategoriesQuery to client/src/data-provider/Agents/
  - Replace manual pagination in AgentGrid with infinite query pattern
  - Update imports to use local data provider instead of librechat-data-provider
  - Add proper permission handling with PERMISSION_BITS.VIEW/EDIT constants
  - Improve agent access control by adding requiredPermission validation in backend
  - Remove manual cursor/state management in favor of infinite query built-ins
  - Maintain existing search and category filtering functionality

refactor: consolidate agent marketplace endpoints into main agents API and improve data management consistency

  - Remove dedicated marketplace controller and routes, merging functionality into main agents v1 API
  - Add countPromotedAgents function to Agent model for promoted agents count
  - Enhance getListAgents handler with marketplace filtering (category, search, promoted status)
  - Move getAgentCategories from marketplace to v1 controller with same functionality
  - Update agent mutations to invalidate marketplace queries and handle multiple permission levels
  - Improve cache management by updating all agent query variants (VIEW/EDIT permissions)
  - Consolidate agent data access patterns for better maintainability and consistency
  - Remove duplicate marketplace route definitions and middleware

selected view only agents injected in the drop down

fix: remove minlength validation for support contact name in agent schema

feat: add validation and error messages for agent name in AgentConfig and AgentPanel

fix: update agent permission check logic in AgentPanel to simplify condition

Fix linting WIP

Fix Unit tests WIP

ESLint fixes

eslint fix

refactor: enhance isDuplicateVersion function in Agent model for improved comparison logic

- Introduced handling for undefined/null values in array and object comparisons.
- Normalized array comparisons to treat undefined/null as empty arrays.
- Added deep comparison for objects and improved handling of primitive values.
- Enhanced projectIds comparison to ensure consistent MongoDB ObjectId handling.

refactor: remove redundant properties from IAgent interface in agent schema

chore: update localization for agent detail component and clean up imports

ci: update access middleware tests

chore: remove unused PermissionTypes import from Role model

ci: update AclEntry model tests

ci: update button accessibility labels in AgentDetail tests

refactor: update exhaustive dep. lint warning
2025-06-28 12:37:59 -04:00

903 lines
25 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 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 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): Promise<t.TSharedLinkResponse> {
return request.post(endpoints.createSharedLink(conversationId));
}
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);
};
/* 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());
};
export const getEndpointsConfigOverride = (): Promise<unknown | boolean> => {
return request.get(endpoints.endpointsConfigOverride());
};
/* 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);
};
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 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}`,
}),
);
/**
* 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(`/api/messages/artifact/${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 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);
}
/* 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(): Promise<t.TDisable2FAResponse> {
return request.post(endpoints.disableTwoFactor());
}
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: string): Promise<q.AccessRolesResponse> {
return request.get(endpoints.getAccessRoles(resourceType));
}
export function getResourcePermissions(
resourceType: string,
resourceId: string,
): Promise<permissions.TGetResourcePermissionsResponse> {
return request.get(endpoints.getResourcePermissions(resourceType, resourceId));
}
export function updateResourcePermissions(
resourceType: string,
resourceId: string,
data: permissions.TUpdateResourcePermissionsRequest,
): Promise<permissions.TUpdateResourcePermissionsResponse> {
return request.put(endpoints.updateResourcePermissions(resourceType, resourceId), data);
}
export function getEffectivePermissions(
resourceType: string,
resourceId: string,
): Promise<permissions.TEffectivePermissionsResponse> {
return request.get(endpoints.getEffectivePermissions(resourceType, resourceId));
}