Chris CoutinhoandClaude Opus 4.8
ef5b3f3873
Consume the astrolabe.semantic_search capability as the source of truth for which content sources an admin has approved for semantic search, and enforce it independently of Astrolabe (this server queries Qdrant directly). - capabilities.py: cached per-user reader for enabled_doc_types (TTL+LRU, fail-open so older Astrolabe / transient OCS errors don't break search) - semantic search: intersect requested doc_types with the allowed set; restrict to the allowed set when none requested; short-circuit when empty - scanner: skip disabled sources during discovery (files discovery yields nothing when disabled, so the existing grace-period reconcile purges them) - processor: drop near-real-time index tasks for disabled doc_types (webhook events bypass the scanner gate); deletes always proceed - vector/purge.py + POST /api/v1/vector-sync/purge: admin-only global delete-by-doc_type, called by Astrolabe when a source is disabled so consent is binding on data-at-rest Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
92 lines
2.5 KiB
Python
92 lines
2.5 KiB
Python
"""Management API for Nextcloud MCP Server.
|
|
|
|
Provides REST endpoints for the Nextcloud PHP app to query server status,
|
|
user sessions, and vector sync metrics. All endpoints use OAuth bearer token
|
|
authentication via the UnifiedTokenVerifier.
|
|
|
|
This package is organized into modules by domain:
|
|
- management.py: Server status, user sessions, shared helpers
|
|
- passwords.py: App password provisioning for multi-user BasicAuth
|
|
- webhooks.py: Webhook registration management
|
|
- visualization.py: Search and PDF visualization endpoints
|
|
"""
|
|
|
|
from nextcloud_mcp_server.api.access import (
|
|
get_user_access,
|
|
list_supported_scopes,
|
|
update_user_scopes,
|
|
)
|
|
|
|
# Re-export all public functions for backward compatibility
|
|
from nextcloud_mcp_server.api.management import (
|
|
__version__,
|
|
_parse_float_param,
|
|
_parse_int_param,
|
|
_sanitize_error_for_client,
|
|
_validate_query_string,
|
|
extract_bearer_token,
|
|
get_server_status,
|
|
get_user_session,
|
|
get_vector_sync_status,
|
|
revoke_user_access,
|
|
validate_token_and_get_user,
|
|
)
|
|
from nextcloud_mcp_server.api.passwords import (
|
|
delete_app_password,
|
|
get_app_password_status,
|
|
provision_app_password,
|
|
)
|
|
from nextcloud_mcp_server.api.vector_sync import (
|
|
purge_doc_types_route,
|
|
)
|
|
from nextcloud_mcp_server.api.visualization import (
|
|
get_chunk_context,
|
|
get_pdf_preview,
|
|
unified_search,
|
|
vector_search,
|
|
)
|
|
from nextcloud_mcp_server.api.webhooks import (
|
|
create_webhook,
|
|
delete_webhook,
|
|
get_installed_apps,
|
|
list_webhooks,
|
|
)
|
|
|
|
__all__ = [
|
|
# Access endpoints (from access.py)
|
|
"get_user_access",
|
|
"update_user_scopes",
|
|
"list_supported_scopes",
|
|
# Version
|
|
"__version__",
|
|
# Shared helpers (from management.py)
|
|
"extract_bearer_token",
|
|
"validate_token_and_get_user",
|
|
"_sanitize_error_for_client",
|
|
"_parse_int_param",
|
|
"_parse_float_param",
|
|
"_validate_query_string",
|
|
# Status endpoints (from management.py)
|
|
"get_server_status",
|
|
"get_vector_sync_status",
|
|
# Session endpoints (from management.py)
|
|
"get_user_session",
|
|
"revoke_user_access",
|
|
# Password endpoints (from passwords.py)
|
|
"provision_app_password",
|
|
"get_app_password_status",
|
|
"delete_app_password",
|
|
# Webhook endpoints (from webhooks.py)
|
|
"get_installed_apps",
|
|
"list_webhooks",
|
|
"create_webhook",
|
|
"delete_webhook",
|
|
# Vector-sync admin endpoints (from vector_sync.py)
|
|
"purge_doc_types_route",
|
|
# Visualization endpoints (from visualization.py)
|
|
"unified_search",
|
|
"vector_search",
|
|
"get_chunk_context",
|
|
"get_pdf_preview",
|
|
]
|