mirror of
https://github.com/TriliumNext/Notes.git
synced 2025-07-30 19:52:28 +08:00
fix(server): async routes causing transaction issues
This commit is contained in:
parent
c8ace1e0b2
commit
a333f8a59a
@ -101,7 +101,7 @@ async function importNotesToBranch(req: Request) {
|
|||||||
return note.getPojo();
|
return note.getPojo();
|
||||||
}
|
}
|
||||||
|
|
||||||
async function importAttachmentsToNote(req: Request) {
|
function importAttachmentsToNote(req: Request) {
|
||||||
const { parentNoteId } = req.params;
|
const { parentNoteId } = req.params;
|
||||||
const { taskId, last } = req.body;
|
const { taskId, last } = req.body;
|
||||||
|
|
||||||
@ -121,7 +121,7 @@ async function importAttachmentsToNote(req: Request) {
|
|||||||
// unlike in note import, we let the events run, because a huge number of attachments is not likely
|
// unlike in note import, we let the events run, because a huge number of attachments is not likely
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await singleImportService.importAttachment(taskContext, file, parentNote);
|
singleImportService.importAttachment(taskContext, file, parentNote);
|
||||||
} catch (e: unknown) {
|
} catch (e: unknown) {
|
||||||
const [errMessage, errStack] = safeExtractMessageAndStackFromError(e);
|
const [errMessage, errStack] = safeExtractMessageAndStackFromError(e);
|
||||||
|
|
||||||
|
@ -18,7 +18,10 @@ export const router = express.Router();
|
|||||||
type HttpMethod = "all" | "get" | "post" | "put" | "delete" | "patch" | "options" | "head";
|
type HttpMethod = "all" | "get" | "post" | "put" | "delete" | "patch" | "options" | "head";
|
||||||
|
|
||||||
export type ApiResultHandler = (req: express.Request, res: express.Response, result: unknown) => number;
|
export type ApiResultHandler = (req: express.Request, res: express.Response, result: unknown) => number;
|
||||||
|
|
||||||
|
type NotAPromise<T> = T & { then?: void };
|
||||||
export type ApiRequestHandler = (req: express.Request, res: express.Response, next: express.NextFunction) => unknown;
|
export type ApiRequestHandler = (req: express.Request, res: express.Response, next: express.NextFunction) => unknown;
|
||||||
|
export type SyncRouteRequestHandler = (req: express.Request, res: express.Response, next: express.NextFunction) => NotAPromise<object> | number | string | void | null;
|
||||||
|
|
||||||
/** Handling common patterns. If entity is not caught, serialization to JSON will fail */
|
/** Handling common patterns. If entity is not caught, serialization to JSON will fail */
|
||||||
function convertEntitiesToPojo(result: unknown) {
|
function convertEntitiesToPojo(result: unknown) {
|
||||||
@ -88,11 +91,15 @@ function send(res: express.Response, statusCode: number, response: unknown) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export function apiRoute(method: HttpMethod, path: string, routeHandler: ApiRequestHandler) {
|
export function apiRoute(method: HttpMethod, path: string, routeHandler: SyncRouteRequestHandler) {
|
||||||
route(method, path, [auth.checkApiAuth, csrfMiddleware], routeHandler, apiResultHandler);
|
route(method, path, [auth.checkApiAuth, csrfMiddleware], routeHandler, apiResultHandler);
|
||||||
}
|
}
|
||||||
|
|
||||||
export function route(method: HttpMethod, path: string, middleware: express.Handler[], routeHandler: ApiRequestHandler, resultHandler: ApiResultHandler | null = null) {
|
export function asyncApiRoute(method: HttpMethod, path: string, routeHandler: ApiRequestHandler) {
|
||||||
|
asyncRoute(method, path, [auth.checkApiAuth, csrfMiddleware], routeHandler, apiResultHandler);
|
||||||
|
}
|
||||||
|
|
||||||
|
export function route(method: HttpMethod, path: string, middleware: express.Handler[], routeHandler: SyncRouteRequestHandler, resultHandler: ApiResultHandler | null = null) {
|
||||||
internalRoute(method, path, middleware, routeHandler, resultHandler, true);
|
internalRoute(method, path, middleware, routeHandler, resultHandler, true);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -69,7 +69,7 @@ import etapiSpecialNoteRoutes from "../etapi/special_notes.js";
|
|||||||
import etapiSpecRoute from "../etapi/spec.js";
|
import etapiSpecRoute from "../etapi/spec.js";
|
||||||
import etapiBackupRoute from "../etapi/backup.js";
|
import etapiBackupRoute from "../etapi/backup.js";
|
||||||
import apiDocsRoute from "./api_docs.js";
|
import apiDocsRoute from "./api_docs.js";
|
||||||
import { apiResultHandler, apiRoute, asyncRoute, route, router, uploadMiddlewareWithErrorHandling } from "./route_api.js";
|
import { apiResultHandler, apiRoute, asyncApiRoute, asyncRoute, route, router, uploadMiddlewareWithErrorHandling } from "./route_api.js";
|
||||||
|
|
||||||
const GET = "get",
|
const GET = "get",
|
||||||
PST = "post",
|
PST = "post",
|
||||||
@ -99,7 +99,7 @@ function register(app: express.Application) {
|
|||||||
apiRoute(GET, '/api/totp/get', totp.getSecret);
|
apiRoute(GET, '/api/totp/get', totp.getSecret);
|
||||||
|
|
||||||
apiRoute(GET, '/api/oauth/status', openID.getOAuthStatus);
|
apiRoute(GET, '/api/oauth/status', openID.getOAuthStatus);
|
||||||
apiRoute(GET, '/api/oauth/validate', openID.isTokenValid);
|
asyncApiRoute(GET, '/api/oauth/validate', openID.isTokenValid);
|
||||||
|
|
||||||
apiRoute(PST, '/api/totp_recovery/set', recoveryCodes.setRecoveryCodes);
|
apiRoute(PST, '/api/totp_recovery/set', recoveryCodes.setRecoveryCodes);
|
||||||
apiRoute(PST, '/api/totp_recovery/verify', recoveryCodes.verifyRecoveryCode);
|
apiRoute(PST, '/api/totp_recovery/verify', recoveryCodes.verifyRecoveryCode);
|
||||||
@ -129,7 +129,7 @@ function register(app: express.Application) {
|
|||||||
apiRoute(PUT, "/api/notes/:noteId/clone-after/:afterBranchId", cloningApiRoute.cloneNoteAfter);
|
apiRoute(PUT, "/api/notes/:noteId/clone-after/:afterBranchId", cloningApiRoute.cloneNoteAfter);
|
||||||
route(PUT, "/api/notes/:noteId/file", [auth.checkApiAuthOrElectron, uploadMiddlewareWithErrorHandling, csrfMiddleware], filesRoute.updateFile, apiResultHandler);
|
route(PUT, "/api/notes/:noteId/file", [auth.checkApiAuthOrElectron, uploadMiddlewareWithErrorHandling, csrfMiddleware], filesRoute.updateFile, apiResultHandler);
|
||||||
route(GET, "/api/notes/:noteId/open", [auth.checkApiAuthOrElectron], filesRoute.openFile);
|
route(GET, "/api/notes/:noteId/open", [auth.checkApiAuthOrElectron], filesRoute.openFile);
|
||||||
route(
|
asyncRoute(
|
||||||
GET,
|
GET,
|
||||||
"/api/notes/:noteId/open-partial",
|
"/api/notes/:noteId/open-partial",
|
||||||
[auth.checkApiAuthOrElectron],
|
[auth.checkApiAuthOrElectron],
|
||||||
@ -165,7 +165,7 @@ function register(app: express.Application) {
|
|||||||
apiRoute(GET, "/api/attachments/:attachmentId/blob", attachmentsApiRoute.getAttachmentBlob);
|
apiRoute(GET, "/api/attachments/:attachmentId/blob", attachmentsApiRoute.getAttachmentBlob);
|
||||||
route(GET, "/api/attachments/:attachmentId/image/:filename", [auth.checkApiAuthOrElectron], imageRoute.returnAttachedImage);
|
route(GET, "/api/attachments/:attachmentId/image/:filename", [auth.checkApiAuthOrElectron], imageRoute.returnAttachedImage);
|
||||||
route(GET, "/api/attachments/:attachmentId/open", [auth.checkApiAuthOrElectron], filesRoute.openAttachment);
|
route(GET, "/api/attachments/:attachmentId/open", [auth.checkApiAuthOrElectron], filesRoute.openAttachment);
|
||||||
route(
|
asyncRoute(
|
||||||
GET,
|
GET,
|
||||||
"/api/attachments/:attachmentId/open-partial",
|
"/api/attachments/:attachmentId/open-partial",
|
||||||
[auth.checkApiAuthOrElectron],
|
[auth.checkApiAuthOrElectron],
|
||||||
@ -194,7 +194,7 @@ function register(app: express.Application) {
|
|||||||
route(GET, "/api/revisions/:revisionId/download", [auth.checkApiAuthOrElectron], revisionsApiRoute.downloadRevision);
|
route(GET, "/api/revisions/:revisionId/download", [auth.checkApiAuthOrElectron], revisionsApiRoute.downloadRevision);
|
||||||
|
|
||||||
route(GET, "/api/branches/:branchId/export/:type/:format/:version/:taskId", [auth.checkApiAuthOrElectron], exportRoute.exportBranch);
|
route(GET, "/api/branches/:branchId/export/:type/:format/:version/:taskId", [auth.checkApiAuthOrElectron], exportRoute.exportBranch);
|
||||||
route(PST, "/api/notes/:parentNoteId/notes-import", [auth.checkApiAuthOrElectron, uploadMiddlewareWithErrorHandling, csrfMiddleware], importRoute.importNotesToBranch, apiResultHandler);
|
asyncRoute(PST, "/api/notes/:parentNoteId/notes-import", [auth.checkApiAuthOrElectron, uploadMiddlewareWithErrorHandling, csrfMiddleware], importRoute.importNotesToBranch, apiResultHandler);
|
||||||
route(PST, "/api/notes/:parentNoteId/attachments-import", [auth.checkApiAuthOrElectron, uploadMiddlewareWithErrorHandling, csrfMiddleware], importRoute.importAttachmentsToNote, apiResultHandler);
|
route(PST, "/api/notes/:parentNoteId/attachments-import", [auth.checkApiAuthOrElectron, uploadMiddlewareWithErrorHandling, csrfMiddleware], importRoute.importAttachmentsToNote, apiResultHandler);
|
||||||
|
|
||||||
apiRoute(GET, "/api/notes/:noteId/attributes", attributesRoute.getEffectiveNoteAttributes);
|
apiRoute(GET, "/api/notes/:noteId/attributes", attributesRoute.getEffectiveNoteAttributes);
|
||||||
@ -223,8 +223,8 @@ function register(app: express.Application) {
|
|||||||
apiRoute(PST, "/api/password/change", passwordApiRoute.changePassword);
|
apiRoute(PST, "/api/password/change", passwordApiRoute.changePassword);
|
||||||
apiRoute(PST, "/api/password/reset", passwordApiRoute.resetPassword);
|
apiRoute(PST, "/api/password/reset", passwordApiRoute.resetPassword);
|
||||||
|
|
||||||
apiRoute(PST, "/api/sync/test", syncApiRoute.testSync);
|
asyncApiRoute(PST, "/api/sync/test", syncApiRoute.testSync);
|
||||||
apiRoute(PST, "/api/sync/now", syncApiRoute.syncNow);
|
asyncApiRoute(PST, "/api/sync/now", syncApiRoute.syncNow);
|
||||||
apiRoute(PST, "/api/sync/fill-entity-changes", syncApiRoute.fillEntityChanges);
|
apiRoute(PST, "/api/sync/fill-entity-changes", syncApiRoute.fillEntityChanges);
|
||||||
apiRoute(PST, "/api/sync/force-full-sync", syncApiRoute.forceFullSync);
|
apiRoute(PST, "/api/sync/force-full-sync", syncApiRoute.forceFullSync);
|
||||||
route(GET, "/api/sync/check", [auth.checkApiAuth], syncApiRoute.checkSync, apiResultHandler);
|
route(GET, "/api/sync/check", [auth.checkApiAuth], syncApiRoute.checkSync, apiResultHandler);
|
||||||
@ -277,21 +277,21 @@ function register(app: express.Application) {
|
|||||||
const clipperMiddleware = isElectron ? [] : [auth.checkEtapiToken];
|
const clipperMiddleware = isElectron ? [] : [auth.checkEtapiToken];
|
||||||
|
|
||||||
route(GET, "/api/clipper/handshake", clipperMiddleware, clipperRoute.handshake, apiResultHandler);
|
route(GET, "/api/clipper/handshake", clipperMiddleware, clipperRoute.handshake, apiResultHandler);
|
||||||
route(PST, "/api/clipper/clippings", clipperMiddleware, clipperRoute.addClipping, apiResultHandler);
|
asyncRoute(PST, "/api/clipper/clippings", clipperMiddleware, clipperRoute.addClipping, apiResultHandler);
|
||||||
route(PST, "/api/clipper/notes", clipperMiddleware, clipperRoute.createNote, apiResultHandler);
|
asyncRoute(PST, "/api/clipper/notes", clipperMiddleware, clipperRoute.createNote, apiResultHandler);
|
||||||
route(PST, "/api/clipper/open/:noteId", clipperMiddleware, clipperRoute.openNote, apiResultHandler);
|
route(PST, "/api/clipper/open/:noteId", clipperMiddleware, clipperRoute.openNote, apiResultHandler);
|
||||||
route(GET, "/api/clipper/notes-by-url/:noteUrl", clipperMiddleware, clipperRoute.findNotesByUrl, apiResultHandler);
|
asyncRoute(GET, "/api/clipper/notes-by-url/:noteUrl", clipperMiddleware, clipperRoute.findNotesByUrl, apiResultHandler);
|
||||||
|
|
||||||
apiRoute(GET, "/api/special-notes/inbox/:date", specialNotesRoute.getInboxNote);
|
asyncApiRoute(GET, "/api/special-notes/inbox/:date", specialNotesRoute.getInboxNote);
|
||||||
apiRoute(GET, "/api/special-notes/days/:date", specialNotesRoute.getDayNote);
|
asyncApiRoute(GET, "/api/special-notes/days/:date", specialNotesRoute.getDayNote);
|
||||||
apiRoute(GET, "/api/special-notes/week-first-day/:date", specialNotesRoute.getWeekFirstDayNote);
|
asyncApiRoute(GET, "/api/special-notes/week-first-day/:date", specialNotesRoute.getWeekFirstDayNote);
|
||||||
apiRoute(GET, "/api/special-notes/weeks/:week", specialNotesRoute.getWeekNote);
|
asyncApiRoute(GET, "/api/special-notes/weeks/:week", specialNotesRoute.getWeekNote);
|
||||||
apiRoute(GET, "/api/special-notes/months/:month", specialNotesRoute.getMonthNote);
|
asyncApiRoute(GET, "/api/special-notes/months/:month", specialNotesRoute.getMonthNote);
|
||||||
apiRoute(GET, "/api/special-notes/quarters/:quarter", specialNotesRoute.getQuarterNote);
|
asyncApiRoute(GET, "/api/special-notes/quarters/:quarter", specialNotesRoute.getQuarterNote);
|
||||||
apiRoute(GET, "/api/special-notes/years/:year", specialNotesRoute.getYearNote);
|
apiRoute(GET, "/api/special-notes/years/:year", specialNotesRoute.getYearNote);
|
||||||
apiRoute(GET, "/api/special-notes/notes-for-month/:month", specialNotesRoute.getDayNotesForMonth);
|
apiRoute(GET, "/api/special-notes/notes-for-month/:month", specialNotesRoute.getDayNotesForMonth);
|
||||||
apiRoute(PST, "/api/special-notes/sql-console", specialNotesRoute.createSqlConsole);
|
apiRoute(PST, "/api/special-notes/sql-console", specialNotesRoute.createSqlConsole);
|
||||||
apiRoute(PST, "/api/special-notes/save-sql-console", specialNotesRoute.saveSqlConsole);
|
asyncApiRoute(PST, "/api/special-notes/save-sql-console", specialNotesRoute.saveSqlConsole);
|
||||||
apiRoute(PST, "/api/special-notes/search-note", specialNotesRoute.createSearchNote);
|
apiRoute(PST, "/api/special-notes/search-note", specialNotesRoute.createSearchNote);
|
||||||
apiRoute(PST, "/api/special-notes/save-search-note", specialNotesRoute.saveSearchNote);
|
apiRoute(PST, "/api/special-notes/save-search-note", specialNotesRoute.saveSearchNote);
|
||||||
apiRoute(PST, "/api/special-notes/launchers/:noteId/reset", specialNotesRoute.resetLauncher);
|
apiRoute(PST, "/api/special-notes/launchers/:noteId/reset", specialNotesRoute.resetLauncher);
|
||||||
@ -328,8 +328,8 @@ function register(app: express.Application) {
|
|||||||
|
|
||||||
// no CSRF since this is called from android app
|
// no CSRF since this is called from android app
|
||||||
route(PST, "/api/sender/login", [loginRateLimiter], loginApiRoute.token, apiResultHandler);
|
route(PST, "/api/sender/login", [loginRateLimiter], loginApiRoute.token, apiResultHandler);
|
||||||
route(PST, "/api/sender/image", [auth.checkEtapiToken, uploadMiddlewareWithErrorHandling], senderRoute.uploadImage, apiResultHandler);
|
asyncRoute(PST, "/api/sender/image", [auth.checkEtapiToken, uploadMiddlewareWithErrorHandling], senderRoute.uploadImage, apiResultHandler);
|
||||||
route(PST, "/api/sender/note", [auth.checkEtapiToken], senderRoute.saveNote, apiResultHandler);
|
asyncRoute(PST, "/api/sender/note", [auth.checkEtapiToken], senderRoute.saveNote, apiResultHandler);
|
||||||
|
|
||||||
apiRoute(GET, "/api/keyboard-actions", keysRoute.getKeyboardActions);
|
apiRoute(GET, "/api/keyboard-actions", keysRoute.getKeyboardActions);
|
||||||
apiRoute(GET, "/api/keyboard-shortcuts-for-notes", keysRoute.getShortcutsForNotes);
|
apiRoute(GET, "/api/keyboard-shortcuts-for-notes", keysRoute.getShortcutsForNotes);
|
||||||
@ -337,8 +337,8 @@ function register(app: express.Application) {
|
|||||||
apiRoute(PST, "/api/relation-map", relationMapApiRoute.getRelationMap);
|
apiRoute(PST, "/api/relation-map", relationMapApiRoute.getRelationMap);
|
||||||
apiRoute(PST, "/api/notes/erase-deleted-notes-now", notesApiRoute.eraseDeletedNotesNow);
|
apiRoute(PST, "/api/notes/erase-deleted-notes-now", notesApiRoute.eraseDeletedNotesNow);
|
||||||
apiRoute(PST, "/api/notes/erase-unused-attachments-now", notesApiRoute.eraseUnusedAttachmentsNow);
|
apiRoute(PST, "/api/notes/erase-unused-attachments-now", notesApiRoute.eraseUnusedAttachmentsNow);
|
||||||
apiRoute(GET, "/api/similar-notes/:noteId", similarNotesRoute.getSimilarNotes);
|
asyncApiRoute(GET, "/api/similar-notes/:noteId", similarNotesRoute.getSimilarNotes);
|
||||||
apiRoute(GET, "/api/backend-log", backendLogRoute.getBackendLog);
|
asyncApiRoute(GET, "/api/backend-log", backendLogRoute.getBackendLog);
|
||||||
apiRoute(GET, "/api/stats/note-size/:noteId", statsRoute.getNoteSize);
|
apiRoute(GET, "/api/stats/note-size/:noteId", statsRoute.getNoteSize);
|
||||||
apiRoute(GET, "/api/stats/subtree-size/:noteId", statsRoute.getSubtreeSize);
|
apiRoute(GET, "/api/stats/subtree-size/:noteId", statsRoute.getSubtreeSize);
|
||||||
apiRoute(PST, "/api/delete-notes-preview", notesApiRoute.getDeleteNotesPreview);
|
apiRoute(PST, "/api/delete-notes-preview", notesApiRoute.getDeleteNotesPreview);
|
||||||
@ -366,42 +366,42 @@ function register(app: express.Application) {
|
|||||||
etapiBackupRoute.register(router);
|
etapiBackupRoute.register(router);
|
||||||
|
|
||||||
// LLM Chat API
|
// LLM Chat API
|
||||||
apiRoute(PST, "/api/llm/chat", llmRoute.createSession);
|
asyncApiRoute(PST, "/api/llm/chat", llmRoute.createSession);
|
||||||
apiRoute(GET, "/api/llm/chat", llmRoute.listSessions);
|
asyncApiRoute(GET, "/api/llm/chat", llmRoute.listSessions);
|
||||||
apiRoute(GET, "/api/llm/chat/:sessionId", llmRoute.getSession);
|
asyncApiRoute(GET, "/api/llm/chat/:sessionId", llmRoute.getSession);
|
||||||
apiRoute(PATCH, "/api/llm/chat/:sessionId", llmRoute.updateSession);
|
asyncApiRoute(PATCH, "/api/llm/chat/:sessionId", llmRoute.updateSession);
|
||||||
apiRoute(DEL, "/api/llm/chat/:chatNoteId", llmRoute.deleteSession);
|
asyncApiRoute(DEL, "/api/llm/chat/:chatNoteId", llmRoute.deleteSession);
|
||||||
apiRoute(PST, "/api/llm/chat/:chatNoteId/messages", llmRoute.sendMessage);
|
asyncApiRoute(PST, "/api/llm/chat/:chatNoteId/messages", llmRoute.sendMessage);
|
||||||
apiRoute(PST, "/api/llm/chat/:chatNoteId/messages/stream", llmRoute.streamMessage);
|
asyncApiRoute(PST, "/api/llm/chat/:chatNoteId/messages/stream", llmRoute.streamMessage);
|
||||||
|
|
||||||
// LLM index management endpoints - reorganized for REST principles
|
// LLM index management endpoints - reorganized for REST principles
|
||||||
apiRoute(GET, "/api/llm/indexes/stats", llmRoute.getIndexStats);
|
asyncApiRoute(GET, "/api/llm/indexes/stats", llmRoute.getIndexStats);
|
||||||
apiRoute(PST, "/api/llm/indexes", llmRoute.startIndexing); // Create index process
|
asyncApiRoute(PST, "/api/llm/indexes", llmRoute.startIndexing); // Create index process
|
||||||
apiRoute(GET, "/api/llm/indexes/failed", llmRoute.getFailedIndexes);
|
asyncApiRoute(GET, "/api/llm/indexes/failed", llmRoute.getFailedIndexes);
|
||||||
apiRoute(PUT, "/api/llm/indexes/notes/:noteId", llmRoute.retryFailedIndex); // Update index for note
|
asyncApiRoute(PUT, "/api/llm/indexes/notes/:noteId", llmRoute.retryFailedIndex); // Update index for note
|
||||||
apiRoute(PUT, "/api/llm/indexes/failed", llmRoute.retryAllFailedIndexes); // Update all failed indexes
|
asyncApiRoute(PUT, "/api/llm/indexes/failed", llmRoute.retryAllFailedIndexes); // Update all failed indexes
|
||||||
apiRoute(GET, "/api/llm/indexes/notes/similar", llmRoute.findSimilarNotes); // Get similar notes
|
asyncApiRoute(GET, "/api/llm/indexes/notes/similar", llmRoute.findSimilarNotes); // Get similar notes
|
||||||
apiRoute(GET, "/api/llm/indexes/context", llmRoute.generateQueryContext); // Get context
|
asyncApiRoute(GET, "/api/llm/indexes/context", llmRoute.generateQueryContext); // Get context
|
||||||
apiRoute(PST, "/api/llm/indexes/notes/:noteId", llmRoute.indexNote); // Create index for specific note
|
asyncApiRoute(PST, "/api/llm/indexes/notes/:noteId", llmRoute.indexNote); // Create index for specific note
|
||||||
|
|
||||||
// LLM embeddings endpoints
|
// LLM embeddings endpoints
|
||||||
apiRoute(GET, "/api/llm/embeddings/similar/:noteId", embeddingsRoute.findSimilarNotes);
|
asyncApiRoute(GET, "/api/llm/embeddings/similar/:noteId", embeddingsRoute.findSimilarNotes);
|
||||||
apiRoute(PST, "/api/llm/embeddings/search", embeddingsRoute.searchByText);
|
asyncApiRoute(PST, "/api/llm/embeddings/search", embeddingsRoute.searchByText);
|
||||||
apiRoute(GET, "/api/llm/embeddings/providers", embeddingsRoute.getProviders);
|
asyncApiRoute(GET, "/api/llm/embeddings/providers", embeddingsRoute.getProviders);
|
||||||
apiRoute(PATCH, "/api/llm/embeddings/providers/:providerId", embeddingsRoute.updateProvider);
|
asyncApiRoute(PATCH, "/api/llm/embeddings/providers/:providerId", embeddingsRoute.updateProvider);
|
||||||
apiRoute(PST, "/api/llm/embeddings/reprocess", embeddingsRoute.reprocessAllNotes);
|
asyncApiRoute(PST, "/api/llm/embeddings/reprocess", embeddingsRoute.reprocessAllNotes);
|
||||||
apiRoute(GET, "/api/llm/embeddings/queue-status", embeddingsRoute.getQueueStatus);
|
asyncApiRoute(GET, "/api/llm/embeddings/queue-status", embeddingsRoute.getQueueStatus);
|
||||||
apiRoute(GET, "/api/llm/embeddings/stats", embeddingsRoute.getEmbeddingStats);
|
asyncApiRoute(GET, "/api/llm/embeddings/stats", embeddingsRoute.getEmbeddingStats);
|
||||||
apiRoute(GET, "/api/llm/embeddings/failed", embeddingsRoute.getFailedNotes);
|
asyncApiRoute(GET, "/api/llm/embeddings/failed", embeddingsRoute.getFailedNotes);
|
||||||
apiRoute(PST, "/api/llm/embeddings/retry/:noteId", embeddingsRoute.retryFailedNote);
|
asyncApiRoute(PST, "/api/llm/embeddings/retry/:noteId", embeddingsRoute.retryFailedNote);
|
||||||
apiRoute(PST, "/api/llm/embeddings/retry-all-failed", embeddingsRoute.retryAllFailedNotes);
|
asyncApiRoute(PST, "/api/llm/embeddings/retry-all-failed", embeddingsRoute.retryAllFailedNotes);
|
||||||
apiRoute(PST, "/api/llm/embeddings/rebuild-index", embeddingsRoute.rebuildIndex);
|
asyncApiRoute(PST, "/api/llm/embeddings/rebuild-index", embeddingsRoute.rebuildIndex);
|
||||||
apiRoute(GET, "/api/llm/embeddings/index-rebuild-status", embeddingsRoute.getIndexRebuildStatus);
|
asyncApiRoute(GET, "/api/llm/embeddings/index-rebuild-status", embeddingsRoute.getIndexRebuildStatus);
|
||||||
|
|
||||||
// LLM provider endpoints - moved under /api/llm/providers hierarchy
|
// LLM provider endpoints - moved under /api/llm/providers hierarchy
|
||||||
apiRoute(GET, "/api/llm/providers/ollama/models", ollamaRoute.listModels);
|
asyncApiRoute(GET, "/api/llm/providers/ollama/models", ollamaRoute.listModels);
|
||||||
apiRoute(GET, "/api/llm/providers/openai/models", openaiRoute.listModels);
|
asyncApiRoute(GET, "/api/llm/providers/openai/models", openaiRoute.listModels);
|
||||||
apiRoute(GET, "/api/llm/providers/anthropic/models", anthropicRoute.listModels);
|
asyncApiRoute(GET, "/api/llm/providers/anthropic/models", anthropicRoute.listModels);
|
||||||
|
|
||||||
// API Documentation
|
// API Documentation
|
||||||
apiDocsRoute(app);
|
apiDocsRoute(app);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user