LICENSE
README.md
pyproject.toml
shared/__init__.py
shared/filtering.py
shared/schema_registry.py
tests/test_llm_integrations_storage.py
tests/test_protocol_handled_types.py
topos/__init__.py
topos/__version__.py
topos/app.py
topos/auth.py
topos/control_plane_client.py
topos/data_explorer_row_delete.py
topos/data_explorer_table_prefs.py
topos/data_explorer_tables.py
topos/hosted_pool_lease.py
topos/llm_integrations_storage.py
topos/mcp_stdio_proxy.py
topos/openai_client.py
topos/rate_limit.py
topos/runtime_update.py
topos/scope_resolution.py
topos/startup_banner.py
topos/sync_handlers.py
topos/uma_contact_enrichment.py
topos/uma_filters.py
topos/uma_resource_id.py
topos/uma_rpt.py
topos/websocket_client.py
topos/analytics/__init__.py
topos/analytics/duckdb_adapter.py
topos/analytics/messenger_communities.py
topos/analytics/messenger_graph.py
topos/analytics/messenger_labels.py
topos/analytics/profiles.py
topos/analytics/query_engine.py
topos/analytics/raw_queries.py
topos/api/__init__.py
topos/api/analytics.py
topos/api/app_registry.py
topos/api/backup.py
topos/api/compute_remote.py
topos/api/data_commit.py
topos/api/data_explorer_table_prefs.py
topos/api/database_explorer.py
topos/api/db.py
topos/api/device.py
topos/api/engine_run.py
topos/api/enrichment.py
topos/api/filter_lab.py
topos/api/health.py
topos/api/home_chat.py
topos/api/ingestion_api.py
topos/api/ingestion_compat.py
topos/api/ingestion_sources.py
topos/api/intelligence_lifecycle.py
topos/api/llm.py
topos/api/local_mcp.py
topos/api/messenger_analytics.py
topos/api/privacy_disclose.py
topos/api/query_api.py
topos/api/runtime_bootstrap.py
topos/api/sanitization_ollama_config.py
topos/api/signal.py
topos/api/signal_extraction_config.py
topos/api/source_install.py
topos/api/source_scrub.py
topos/api/sources.py
topos/api/sources_overview.py
topos/api/sync.py
topos/api/ui_config.py
topos/api/uma_data.py
topos/api/usage.py
topos/api/user_identity.py
topos/canonicalization/__init__.py
topos/canonicalization/models.py
topos/canonicalization/resolver.py
topos/canonicalization/mappers/__init__.py
topos/canonicalization/mappers/base.py
topos/canonicalization/mappers/browser_activity_mapper.py
topos/canonicalization/mappers/chatgpt_mapper.py
topos/canonicalization/mappers/demo_mappers.py
topos/canonicalization/mappers/grok_mapper.py
topos/canonicalization/mappers/messenger_mapper.py
topos/cli/__init__.py
topos/cli/__main__.py
topos/cli/commands.py
topos/config/__init__.py
topos/config/sanitization_ollama.py
topos/config/settings.py
topos/config/signal_extraction.py
topos/contacts/__init__.py
topos/contacts/identity.py
topos/core/__init__.py
topos/core/api_models.py
topos/core/connection_resilience.py
topos/core/device_helpers.py
topos/core/errors.py
topos/core/events.py
topos/core/logging.py
topos/core/metrics.py
topos/core/routine_access.py
topos/core/startup_banner.py
topos/core/state.py
topos/core/table_layers.py
topos/core/types.py
topos/core/handlers/__init__.py
topos/core/handlers/common.py
topos/core/handlers/config.py
topos/core/handlers/contacts_import.py
topos/core/handlers/database_explorer.py
topos/core/handlers/device.py
topos/core/handlers/enrichment.py
topos/core/handlers/filter_lab.py
topos/core/handlers/home_chat.py
topos/core/handlers/ingest.py
topos/core/handlers/messages.py
topos/core/handlers/messenger_analytics.py
topos/core/handlers/query.py
topos/core/handlers/registry.py
topos/core/handlers/routines.py
topos/core/handlers/signal_features.py
topos/core/handlers/sources.py
topos/core/handlers/uma.py
topos/disclosure/__init__.py
topos/disclosure/canonical_writer.py
topos/disclosure/content_policy.py
topos/disclosure/field_registry.py
topos/disclosure/privacy_layer.py
topos/disclosure/tier.py
topos/engine/__init__.py
topos/engine/client.py
topos/engine/engine.py
topos/engine/intake.py
topos/engine/memory_utils.py
topos/engine/model_cache.py
topos/engine/pipeline_memory.py
topos/engine/queue_manager.py
topos/engine/registration.py
topos/engine/result_formatter.py
topos/engine/router.py
topos/engine/scoped_token.py
topos/engine/tasks.py
topos/engine/transport.py
topos/engine/usage_guard.py
topos/engine/usage_observation.py
topos/engine/validator.py
topos/engine/backends/__init__.py
topos/engine/backends/base.py
topos/engine/backends/generative_prompts.py
topos/engine/backends/generative_response.py
topos/engine/backends/huggingface.py
topos/engine/backends/ollama.py
topos/engine/backends/openai.py
topos/engine/backends/openai_compatible.py
topos/engine/backends/redpill.py
topos/engine/backends/stub.py
topos/enrichment/__init__.py
topos/enrichment/derived_tables.py
topos/enrichment/job_writer.py
topos/enrichment/orchestrator.py
topos/enrichment/processor.py
topos/enrichment/progress_bar.py
topos/enrichment/registry_contract.py
topos/enrichment/website_classifier.py
topos/enrichment/jobs/__init__.py
topos/enrichment/jobs/base.py
topos/enrichment/jobs/canonical/__init__.py
topos/enrichment/jobs/canonical/_batch_limits.py
topos/enrichment/jobs/canonical/_engine_runner.py
topos/enrichment/jobs/canonical/availability_scores_job.py
topos/enrichment/jobs/canonical/brief_fallback.py
topos/enrichment/jobs/canonical/dimension_summary_job.py
topos/enrichment/jobs/canonical/embeddings_job.py
topos/enrichment/jobs/canonical/emo_27_job.py
topos/enrichment/jobs/canonical/entities_job.py
topos/enrichment/jobs/canonical/fact_extraction_job.py
topos/enrichment/jobs/canonical/goal_extraction_job.py
topos/enrichment/jobs/canonical/pii_redaction_job.py
topos/enrichment/jobs/canonical/relationship_edges_job.py
topos/enrichment/jobs/canonical/sentiment_job.py
topos/enrichment/jobs/canonical/statistics_job.py
topos/enrichment/jobs/canonical/timeline_job.py
topos/enrichment/jobs/canonical/topic_clusters_job.py
topos/enrichment/jobs/canonical/topics_job.py
topos/enrichment/jobs/canonical/url_classification_core.py
topos/enrichment/jobs/canonical/url_classification_enrichment_job.py
topos/enrichment/jobs/canonical/url_classification_signal_job.py
topos/enrichment/jobs/raw/__init__.py
topos/enrichment/jobs/raw/attachments_job.py
topos/enrichment/jobs/raw/language_job.py
topos/enrichment/jobs/raw/time_normalization_job.py
topos/enrichment/jobs/raw/tool_calls_job.py
topos/enrichment/models/__init__.py
topos/enrichment/models/manager.py
topos/enrichment/models/mvp_defaults.py
topos/enrichment/models/registry.py
topos/enrichment/models/versioning.py
topos/features/entities/__init__.py
topos/features/entities/consolidation.py
topos/features/entities/dossier.py
topos/features/entities/edges.py
topos/features/entities/linking.py
topos/features/entities/reads.py
topos/features/entities/resolver.py
topos/features/facts/__init__.py
topos/features/facts/extract.py
topos/features/facts/reads.py
topos/features/facts/store.py
topos/features/fit/evaluator.py
topos/features/lifecycle/__init__.py
topos/features/lifecycle/derived_scrub.py
topos/features/lifecycle/exclusions.py
topos/features/signal/__init__.py
topos/features/signal/brief_canonical_loader.py
topos/features/signal/brief_ontology.py
topos/features/signal/brief_renderer.py
topos/features/signal/brief_schemas.py
topos/features/signal/chunking.py
topos/features/signal/data_health.py
topos/features/signal/dimension_briefs.py
topos/features/signal/dimension_definition_loader.py
topos/features/signal/dimension_profiles.py
topos/features/signal/dimension_registry.py
topos/features/signal/embed_context.py
topos/features/signal/graph_sanitize.py
topos/features/signal/hybrid_search.py
topos/features/signal/incremental_clustering.py
topos/features/signal/query_embed_cache.py
topos/features/signal/schemas.py
topos/features/signal/service.py
topos/features/signal/signal_object_store.py
topos/features/signal/source_hydration.py
topos/features/signal/structured_signal.py
topos/features/signal/topic_clustering.py
topos/features/signal/vector_codec.py
topos/features/signal/vector_math.py
topos/features/signal/vector_settings.py
topos/features/signal/extraction/artifact_router.py
topos/features/signal/extraction/artifact_store.py
topos/features/signal/extraction/rule_extractors.py
topos/features/signal/typed_stores/aggregates.py
topos/features/signal/typed_stores/scope_materializer.py
topos/features/stats/__init__.py
topos/features/stats/definitions.py
topos/features/stats/engine.py
topos/features/stats/fold.py
topos/features/stats/insights.py
topos/filter_lab/__init__.py
topos/filter_lab/bundles.py
topos/filter_lab/schema.py
topos/filter_lab/service.py
topos/filter_lab/store.py
topos/filter_lab/worker.py
topos/home_chat/__init__.py
topos/home_chat/schema.py
topos/home_chat/store.py
topos/ingestion/__init__.py
topos/ingestion/canonical_pipeline.py
topos/ingestion/inbox_crypto.py
topos/ingestion/inbox_drain.py
topos/ingestion/ingest_helpers.py
topos/ingestion/jobs.py
topos/ingestion/journal_location_fanout.py
topos/ingestion/journal_time_log_normalize.py
topos/ingestion/local_sync.py
topos/ingestion/log_preview.py
topos/ingestion/manager.py
topos/ingestion/parser.py
topos/ingestion/progress.py
topos/ingestion/reprocess.py
topos/ingestion/state_machine.py
topos/ingestion/usage_inbox_dedupe.py
topos/ingestion/checkpoints/__init__.py
topos/ingestion/checkpoints/checkpoint_store.py
topos/ingestion/checkpoints/sqlite_checkpoint_store.py
topos/ingestion/parsers/__init__.py
topos/ingestion/parsers/base.py
topos/ingestion/parsers/browser_parser.py
topos/ingestion/parsers/calendar_parser.py
topos/ingestion/parsers/chatgpt_conversation_flattener.py
topos/ingestion/parsers/chatgpt_parser.py
topos/ingestion/parsers/demo_file_parsers.py
topos/ingestion/parsers/grok_parser.py
topos/ingestion/parsers/messenger_parser.py
topos/ingestion/parsers/voxterm_parser.py
topos/ingestion/sources/__init__.py
topos/ingestion/sources/base.py
topos/ingestion/sources/calendar.py
topos/ingestion/sources/chatgpt.py
topos/ingestion/sources/contact_importers.py
topos/ingestion/sources/grok.py
topos/ingestion/sources/imessage_reader.py
topos/ingestion/sources/signal_export_parser.py
topos/ingestion/sources/signal_reader.py
topos/ingestion/triggers/__init__.py
topos/ingestion/triggers/file_trigger.py
topos/ingestion/triggers/sqlite_trigger.py
topos/ingestion/validation/__init__.py
topos/ingestion/validation/base.py
topos/ingestion/validation/schema_registry.py
topos/ingestion/validation/schema_validator.py
topos/lineage/__init__.py
topos/lineage/provenance.py
topos/lineage/tracker.py
topos/observability/__init__.py
topos/observability/alerts.py
topos/observability/metrics.py
topos/observability/tracing.py
topos/pipeline/__init__.py
topos/pipeline/audit.py
topos/pipeline/envelope.py
topos/pipeline/stages.py
topos/pipeline/stub_enqueue.py
topos/projections/__init__.py
topos/projections/vector_index/__init__.py
topos/projections/vector_index/base.py
topos/projections/vector_index/builders.py
topos/projections/vector_index/health_checks.py
topos/protocol/__init__.py
topos/query/__init__.py
topos/query/audit.py
topos/query/ddr.py
topos/query/disclosure.py
topos/query/fingerprint.py
topos/query/game_layer.py
topos/query/grant_cache.py
topos/query/inference.py
topos/query/intent.py
topos/query/manifest.py
topos/query/manifest_validation.py
topos/query/minimizer.py
topos/query/negotiation.py
topos/query/pipeline.py
topos/query/planner.py
topos/query/retrieval.py
topos/query/runtime.py
topos/query/scope_registry_loader.py
topos/query/session.py
topos/query/session_utils.py
topos/query/source_generation.py
topos/query/turn_classifier.py
topos/query/types.py
topos/routines/__init__.py
topos/routines/schema.py
topos/routines/store.py
topos/sanitization/__init__.py
topos/sanitization/nsfw_classifier.py
topos/sanitization/ollama_transforms.py
topos/sanitization/privacy_filter.py
topos/services/__init__.py
topos/services/container.py
topos/services/interfaces.py
topos/services/local.py
topos/services/postgres.py
topos/services/embeddings/__init__.py
topos/services/embeddings/base.py
topos/services/embeddings/local.py
topos/services/embeddings/remote.py
topos/services/llm/__init__.py
topos/services/llm/base.py
topos/services/llm/openai.py
topos/sources/__init__.py
topos/sources/bundled_canonical_triples.py
topos/sources/canonical_signal_defaults.py
topos/sources/definitions.py
topos/sources/install_service.py
topos/sources/registry.py
topos/sources/runtime_install.py
topos/sources/scrub_attribution.py
topos/sources/scrub_service.py
topos/storage/__init__.py
topos/storage/signal_identity.py
topos/storage/source_settings.py
topos/storage/user_identity.py
topos/storage/adapters/__init__.py
topos/storage/adapters/factory.py
topos/storage/adapters/fakes.py
topos/storage/adapters/protocols.py
topos/storage/adapters/postgres/stores.py
topos/storage/adapters/sqlite/__init__.py
topos/storage/adapters/sqlite/stores.py
topos/storage/adapters/sqlite/vector_search.py
topos/storage/canonical/__init__.py
topos/storage/canonical/activity_tables.py
topos/storage/canonical/calendar_contacts_tables.py
topos/storage/canonical/canonical_store.py
topos/storage/canonical/conversations_tables.py
topos/storage/canonical/mapping_store.py
topos/storage/canonical/postgres.py
topos/storage/canonical/ai_chat/__init__.py
topos/storage/canonical/ai_chat/canonicalizer.py
topos/storage/canonical/ai_chat/mapper.py
topos/storage/canonical/ai_chat/model.py
topos/storage/canonical/ai_chat/tables.py
topos/storage/db/__init__.py
topos/storage/db/client.py
topos/storage/db/paths.py
topos/storage/db/postgres.py
topos/storage/db/schema.py
topos/storage/db/storage_breakdown.py
topos/storage/db/migrations/__init__.py
topos/storage/db/migrations/canonical_disclosure_v1.py
topos/storage/db/migrations/canonical_nsfw_v1.py
topos/storage/db/migrations/extraction_artifacts.py
topos/storage/db/migrations/journal_entries_duration_v1.py
topos/storage/db/migrations/journal_entries_ends_at_v1.py
topos/storage/db/migrations/journal_entries_people_v1.py
topos/storage/db/migrations/journal_entries_place_name_v1.py
topos/storage/db/migrations/journal_entries_starts_at_v1.py
topos/storage/db/migrations/remediation_person_model.py
topos/storage/db/migrations/scope_source_generation.py
topos/storage/db/migrations/signal_dimension_harness.py
topos/storage/db/migrations/signal_objects.py
topos/storage/db/migrations/signal_objects_updated_by_v1.py
topos/storage/db/migrations/stage9_column_renames.py
topos/storage/db/migrations/vector_storage_v1.py
topos/storage/db/migrations/vector_storage_v2.py
topos/storage/db/migrations/vector_storage_v3.py
topos/storage/db/migrations/vector_storage_v4.py
topos/storage/db/migrations/wiki_clusters_v2.py
topos/storage/db/migrations/wiki_entities_v1.py
topos/storage/db/migrations/wiki_entity_review_v2.py
topos/storage/db/migrations/wiki_facts_v1.py
topos/storage/db/migrations/wiki_lifecycle_v1.py
topos/storage/db/migrations/wiki_mvp_phase0.py
topos/storage/db/migrations/wiki_mvp_phase1.py
topos/storage/db/migrations/wiki_mvp_phase4_messages_cutover.py
topos/storage/db/migrations/wiki_mvp_phase5_topic_clusters.py
topos/storage/db/migrations/wiki_mvp_phase6_dimension_briefs.py
topos/storage/db/migrations/wiki_mvp_query_quality.py
topos/storage/db/migrations/wiki_mvp_topic_clusters_coordination.py
topos/storage/db/migrations/wiki_stats_v1.py
topos/storage/db/migrations/wiki_timeline_v1.py
topos/storage/enrichment/__init__.py
topos/storage/enrichment/canonical_enrichment_store.py
topos/storage/enrichment/raw_enrichment_store.py
topos/storage/normalized/__init__.py
topos/storage/normalized/normalized_store.py
topos/storage/oplog/__init__.py
topos/storage/oplog/decision.py
topos/storage/oplog/oplog_store.py
topos/storage/oplog/postgres.py
topos/storage/person/identity_resolver.py
topos/storage/projections/__init__.py
topos/storage/projections/index_ops_store.py
topos/storage/projections/vector_index_store.py
topos/storage/raw/__init__.py
topos/storage/raw/browser_flat_tables.py
topos/storage/raw/file_store.py
topos/storage/raw/raw_store.py
topos/storage/raw/raw_tables_manager.py
topos/storage/raw/sqlite_raw_store.py
topos/storage/security/encryption.py
topos/sync/__init__.py
topos/sync/client.py
topos/testing/__init__.py
topos/testing/lifespan.py
topos/utils/base_object.py
topos_node.egg-info/PKG-INFO
topos_node.egg-info/SOURCES.txt
topos_node.egg-info/dependency_links.txt
topos_node.egg-info/entry_points.txt
topos_node.egg-info/requires.txt
topos_node.egg-info/top_level.txt