Skip to content

Split API route modules #301

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
yvette-carlisle merged 6 commits into from
Jun 30, 2026
Merged

Split API route modules #301

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
dfa9e28
{"schema":"decodex/commit/1","summary":"Split API route builder modul…
yvette-carlisle Jun 30, 2026
bae9081
{"schema":"decodex/commit/1","summary":"Split graph API route handler…
yvette-carlisle Jun 30, 2026
508bff3
{"schema":"decodex/commit/1","summary":"Split knowledge API route han…
yvette-carlisle Jun 30, 2026
ff4b11e
{"schema":"decodex/commit/1","summary":"Split notes API route handler…
yvette-carlisle Jun 30, 2026
b3de84e
{"schema":"decodex/commit/1","summary":"Split docs API route handlers…
yvette-carlisle Jun 30, 2026
bea61d1
{"schema":"decodex/commit/1","summary":"Split trace API route handler…
yvette-carlisle Jun 30, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
198 changes: 8 additions & 190 deletions apps/elf-api/src/routes.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ mod ingestion_profiles;
mod knowledge;
mod notes;
mod recall;
mod route_builder;
mod search;
mod sharing;
mod support;
Expand All @@ -24,45 +25,30 @@ mod work_journal;

pub use self::{
contract::{ApiDoc, OPENAPI_JSON_PATH, SCALAR_DOCS_PATH, contract_router},
route_builder::{admin_router, router},
viewer::ADMIN_VIEWER_PATH,
};

use axum::{
Json, Router,
Json,
body::{self, Body},
extract::{
DefaultBodyLimit, Extension, Path, Query, State,
Extension, Path, Query, State,
rejection::{JsonRejection, QueryRejection},
},
http::{
HeaderMap, Request, StatusCode,
header::{CONTENT_LENGTH, CONTENT_TYPE},
},
middleware::{self, Next},
middleware::Next,
response::{IntoResponse, Response},
routing,
};
use serde::{Deserialize, Serialize};
use serde_json::{Map, Value};
use time::{OffsetDateTime, format_description::well_known::Rfc3339};
use uuid::Uuid;

use crate::state::AppState;
use admin_notes::{admin_note_correction_apply, admin_note_history_get, admin_note_provenance_get};
use admin_ops::rebuild_qdrant;
use consolidation::{
consolidation_proposal_get, consolidation_proposal_review, consolidation_proposals_list,
consolidation_run_create, consolidation_run_get, consolidation_runs_list,
};
use core_memory::{
admin_core_block_attach, admin_core_block_detach, admin_core_block_upsert, core_blocks_get,
entity_memory_get,
};
use docs::{
admin_docs_excerpts_get, admin_docs_get, admin_docs_search_l0, docs_delete, docs_excerpts_get,
docs_get, docs_put, docs_search_l0,
};
use dreaming::dreaming_review_queue;
use elf_config::{SecurityAuthKey, SecurityAuthRole};
use elf_domain::{
consolidation::{
Expand Down Expand Up @@ -116,39 +102,16 @@ use elf_service::{
WorkJournalEntryFamily, WorkJournalEntryGetRequest, WorkJournalEntryResponse,
WorkJournalSessionReadbackRequest, WorkJournalSessionReadbackResponse, search::TraceBundleMode,
};
use events::events_ingest;
use graph::{
admin_graph_predicate_alias_add, admin_graph_predicate_aliases_list,
admin_graph_predicate_patch, admin_graph_predicates_list, graph_query, graph_report,
};
use health::health;
use ingestion_profiles::{
admin_ingestion_profile_create, admin_ingestion_profile_default_get,
admin_ingestion_profile_default_set, admin_ingestion_profile_get,
admin_ingestion_profile_versions_list, admin_ingestion_profiles_list,
};
use knowledge::{
knowledge_page_get, knowledge_page_lint, knowledge_page_rebuild, knowledge_pages_list,
knowledge_pages_search, knowledge_pages_watch_rebuild,
};
use notes::{
notes_delete, notes_get, notes_ingest, notes_list, notes_patch, notes_publish, notes_unpublish,
};
use recall::{admin_recall_debug_panel, recall_debug_panel};
use search::{searches_create, searches_get, searches_notes, searches_raw, searches_timeline};
use sharing::{space_grant_revoke, space_grant_upsert, space_grants_list};
use support::{
ApiError, EntityMemoryQuery, RequestContext, SearchMode, admin_auth_middleware,
api_auth_middleware, effective_token_id, empty_json_object, format_scope, format_space,
json_error, parse_optional_rfc3339, parse_space, require_admin_for_org_shared_writes,
required_read_profile,
ApiError, EntityMemoryQuery, RequestContext, SearchMode, effective_token_id, empty_json_object,
format_scope, format_space, json_error, parse_optional_rfc3339, parse_space,
require_admin_for_org_shared_writes, required_read_profile,
};
#[cfg(test)]
use support::{
apply_auth_key_context, inject_request_id_into_json_body, parse_request_id_from_headers,
resolve_auth_key, sanitize_trusted_token_header,
};
use trace::{trace_bundle_get, trace_get, trace_item_get, trace_recent_list, trace_trajectory_get};
use types::{
AdminGraphPredicateAliasAddBody, AdminGraphPredicatePatchBody, AdminGraphPredicatesListQuery,
AdminIngestionProfileCreateBody, AdminIngestionProfileDefaultResponseV2,
Expand All @@ -166,10 +129,6 @@ use types::{
WorkJournalSessionReadbackBody,
};
#[cfg(test)] use viewer::VIEWER_HTML;
use viewer::admin_viewer;
use work_journal::{
work_journal_entry_create, work_journal_entry_get, work_journal_session_readback,
};

const HEADER_TENANT_ID: &str = "X-ELF-Tenant-Id";
const HEADER_PROJECT_ID: &str = "X-ELF-Project-Id";
Expand All @@ -191,145 +150,4 @@ const MAX_TOP_K: u32 = 100;
const MAX_CANDIDATE_K: u32 = 1_000;
const MAX_ERROR_LOG_CHARS: usize = 1_024;

/// Builds the authenticated public API router.
pub fn router(state: AppState) -> Router {
let auth_state = state.clone();
let api_router = Router::new()
.route("/health", routing::get(health))
.route("/v2/notes/ingest", routing::post(notes_ingest))
.route("/v2/events/ingest", routing::post(events_ingest))
.route("/v2/core-blocks", routing::get(core_blocks_get))
.route("/v2/entity-memory", routing::get(entity_memory_get))
.route("/v2/recall-debug/panel", routing::post(recall_debug_panel))
.route("/v2/searches", routing::post(searches_create))
.route("/v2/searches/{search_id}", routing::get(searches_get))
.route("/v2/searches/{search_id}/timeline", routing::get(searches_timeline))
.route("/v2/searches/{search_id}/notes", routing::post(searches_notes))
.route("/v2/graph/query", routing::post(graph_query))
.route("/v2/graph/report", routing::post(graph_report))
.route("/v2/notes", routing::get(notes_list))
.route(
"/v2/notes/{note_id}",
routing::get(notes_get).patch(notes_patch).delete(notes_delete),
)
.route("/v2/notes/{note_id}/publish", routing::post(notes_publish))
.route("/v2/notes/{note_id}/unpublish", routing::post(notes_unpublish))
.route("/v2/work-journal/entries", routing::post(work_journal_entry_create))
.route("/v2/work-journal/entries/{entry_id}", routing::get(work_journal_entry_get))
.route("/v2/work-journal/readback", routing::post(work_journal_session_readback))
.route(
"/v2/spaces/{space}/grants",
routing::get(space_grants_list).post(space_grant_upsert),
)
.route("/v2/spaces/{space}/grants/revoke", routing::post(space_grant_revoke))
.with_state(state.clone())
.layer(DefaultBodyLimit::max(MAX_REQUEST_BYTES));
let docs_router = Router::new()
.route("/v2/docs", routing::post(docs_put))
.route("/v2/docs/{doc_id}", routing::get(docs_get).delete(docs_delete))
.route("/v2/docs/search/l0", routing::post(docs_search_l0))
.route("/v2/docs/excerpts", routing::post(docs_excerpts_get))
.with_state(state)
.layer(DefaultBodyLimit::max(MAX_DOC_REQUEST_BYTES));

Router::new()
.merge(contract_router())
.merge(api_router)
.merge(docs_router)
.layer(middleware::from_fn_with_state(auth_state, api_auth_middleware))
}

/// Builds the authenticated admin API router.
pub fn admin_router(state: AppState) -> Router {
let auth_state = state.clone();
let protected_router = Router::new()
.route("/v2/admin/searches", routing::post(searches_create))
.route("/v2/admin/searches/{search_id}", routing::get(searches_get))
.route("/v2/admin/searches/{search_id}/timeline", routing::get(searches_timeline))
.route("/v2/admin/searches/{search_id}/notes", routing::post(searches_notes))
.route("/v2/admin/core-blocks", routing::post(admin_core_block_upsert))
.route(
"/v2/admin/core-blocks/{block_id}/attachments",
routing::post(admin_core_block_attach),
)
.route(
"/v2/admin/core-blocks/attachments/{attachment_id}",
routing::delete(admin_core_block_detach),
)
.route("/v2/admin/docs/search/l0", routing::post(admin_docs_search_l0))
.route("/v2/admin/docs/excerpts", routing::post(admin_docs_excerpts_get))
.route("/v2/admin/docs/{doc_id}", routing::get(admin_docs_get))
.route("/v2/admin/notes", routing::get(notes_list))
.route("/v2/admin/notes/{note_id}", routing::get(notes_get))
.route(
"/v2/admin/events/ingestion-profiles/default",
routing::get(admin_ingestion_profile_default_get)
.put(admin_ingestion_profile_default_set),
)
.route(
"/v2/admin/events/ingestion-profiles/{profile_id}/versions",
routing::get(admin_ingestion_profile_versions_list),
)
.route(
"/v2/admin/events/ingestion-profiles/{profile_id}",
routing::get(admin_ingestion_profile_get),
)
.route(
"/v2/admin/events/ingestion-profiles",
routing::get(admin_ingestion_profiles_list).post(admin_ingestion_profile_create),
)
.route(
"/v2/admin/consolidation/runs",
routing::get(consolidation_runs_list).post(consolidation_run_create),
)
.route("/v2/admin/consolidation/runs/{run_id}", routing::get(consolidation_run_get))
.route("/v2/admin/consolidation/proposals", routing::get(consolidation_proposals_list))
.route(
"/v2/admin/consolidation/proposals/{proposal_id}",
routing::get(consolidation_proposal_get),
)
.route(
"/v2/admin/consolidation/proposals/{proposal_id}/review",
routing::post(consolidation_proposal_review),
)
.route("/v2/admin/dreaming/review-queue", routing::get(dreaming_review_queue))
.route("/v2/admin/recall-debug/panel", routing::post(admin_recall_debug_panel))
.route("/v2/admin/knowledge/pages", routing::get(knowledge_pages_list))
.route("/v2/admin/knowledge/pages/rebuild", routing::post(knowledge_page_rebuild))
.route(
"/v2/admin/knowledge/pages/rebuild-changed-sources",
routing::post(knowledge_pages_watch_rebuild),
)
.route("/v2/admin/knowledge/pages/search", routing::post(knowledge_pages_search))
.route("/v2/admin/knowledge/pages/{page_id}", routing::get(knowledge_page_get))
.route("/v2/admin/knowledge/pages/{page_id}/lint", routing::post(knowledge_page_lint))
.route("/v2/admin/qdrant/rebuild", routing::post(rebuild_qdrant))
.route("/v2/admin/searches/raw", routing::post(searches_raw))
.route("/v2/admin/traces/recent", routing::get(trace_recent_list))
.route("/v2/admin/traces/{trace_id}", routing::get(trace_get))
.route("/v2/admin/traces/{trace_id}/bundle", routing::get(trace_bundle_get))
.route("/v2/admin/trajectories/{trace_id}", routing::get(trace_trajectory_get))
.route("/v2/admin/trace-items/{item_id}", routing::get(trace_item_get))
.route("/v2/admin/graph/predicates", routing::get(admin_graph_predicates_list))
.route(
"/v2/admin/graph/predicates/{predicate_id}",
routing::patch(admin_graph_predicate_patch),
)
.route(
"/v2/admin/graph/predicates/{predicate_id}/aliases",
routing::post(admin_graph_predicate_alias_add).get(admin_graph_predicate_aliases_list),
)
.route("/v2/admin/notes/{note_id}/provenance", routing::get(admin_note_provenance_get))
.route("/v2/admin/notes/{note_id}/history", routing::get(admin_note_history_get))
.route("/v2/admin/notes/{note_id}/corrections", routing::post(admin_note_correction_apply))
.with_state(state)
.layer(DefaultBodyLimit::max(MAX_REQUEST_BYTES))
.layer(middleware::from_fn_with_state(auth_state, admin_auth_middleware));

Router::new()
.route(ADMIN_VIEWER_PATH, routing::get(admin_viewer))
.route("/", routing::get(admin_viewer))
.merge(protected_router)
}

#[cfg(test)] mod tests;
Loading