Ë ²^´j…ãól—ddlmZddlZddlZddlZddlmZmZddlmZm Z m Z d d„Z d d„Z d d„Z d d„Zy) é)Ú annotationsN)ÚdatetimeÚtimezone)ÚINTERNAL_TOKEN_FILEÚconnectÚ ensure_dirscó„—tjtj«j d¬«j «S)Nr)Ú microsecond)rÚnowrÚutcÚreplaceÚ isoformat©óú?/var/www/origus_pro_usr/data/www/origus.pro/core/core_schema.pyÚutc_nowr s,€Ü <‰<œŸ ™ Ó %× -Ñ -¸!Ð -Ó <× FÑ FÓ HÐHrcó@—t«tj«r(tjd¬«j «}|r|St j d«}tj|d¬« tjtd«|S#t$rY|SwxYw)Nzutf-8)Úencodingé0i€) rrÚexistsÚ read_textÚstripÚsecretsÚ token_urlsafeÚ write_textÚosÚchmodÚOSError)Útokens rÚensure_internal_tokenr sˆ€Ü„MÜ×!Ñ!Ô#Ü#×-Ñ-°wÔ?×EÑEÓGˆÙ ؈LÜ × !Ñ ! "Ó %€EÜ×"Ñ" 5°7Õ;ð Ü ‰Ô$ eÔ,ð €Løô ò Ø Ø €Lð úsÁ4B BÂBcóÄ—|jd|›d«j«Dchc]}t|d«’Œ}}||vr|jd|›d|›d|›«yycc}w)NzPRAGMA table_info(ú)éz ALTER TABLE z ADD COLUMN ú )ÚexecuteÚfetchallÚstr)ÚconÚtableÚcolumnÚddlÚrowÚcolumnss rÚ_ensure_columnr.sk€Ø&)§k¡kÐ4FÀuÀgÈQÐ2OÓ&P×&YÑ&YÓ&[Ö\˜sŒs3q‘6{Ð\€GÐ\Ø WÑØ ‰ l 5 '¨°f°X¸Q¸s¸eÐDÕEðùò]s¦Ac ó —t«t«t«5}|jd«t |ddd«t |ddd«|j d«ddd d d d d œfddd dddd œfddd dddd œfg}|D]4\}}}}}|j d||||t j|d¬«f«Œ6|j d«|j dt«f«|j«ddd«y#1swYyxYw)Nat CREATE TABLE IF NOT EXISTS connectors( connector_key TEXT PRIMARY KEY, connector_name TEXT NOT NULL, connector_type TEXT NOT NULL, base_url TEXT, status TEXT NOT NULL DEFAULT 'not_configured', last_test_at TEXT, last_sync_at TEXT, last_error TEXT, meta_json TEXT NOT NULL DEFAULT '{}' ); CREATE TABLE IF NOT EXISTS tracked_documents( id INTEGER PRIMARY KEY, source_key TEXT NOT NULL, document_slug TEXT NOT NULL, document_code TEXT NOT NULL, search_query TEXT NOT NULL, discovered_url TEXT, enabled INTEGER NOT NULL DEFAULT 1, last_checked_at TEXT, last_changed_at TEXT, last_hash TEXT, last_snapshot_id INTEGER, last_error TEXT, UNIQUE(source_key, document_slug) ); CREATE TABLE IF NOT EXISTS source_snapshots( id INTEGER PRIMARY KEY, source_key TEXT NOT NULL, document_slug TEXT NOT NULL, document_code TEXT NOT NULL, source_url TEXT NOT NULL, checked_at TEXT NOT NULL, content_hash TEXT NOT NULL, title TEXT, text_path TEXT, html_path TEXT, downloaded_file_path TEXT, manifest_path TEXT, is_current INTEGER NOT NULL DEFAULT 1, extraction_status TEXT NOT NULL DEFAULT 'raw_saved', extraction_meta_json TEXT NOT NULL DEFAULT '{}' ); CREATE INDEX IF NOT EXISTS idx_core_snapshots_document ON source_snapshots(source_key, document_slug, checked_at); CREATE INDEX IF NOT EXISTS idx_core_tracked_enabled ON tracked_documents(source_key, enabled); CREATE TABLE IF NOT EXISTS ai_runs( id INTEGER PRIMARY KEY, purpose TEXT NOT NULL, provider TEXT, model TEXT NOT NULL, created_at TEXT NOT NULL, status TEXT NOT NULL, input_hash TEXT, result_meta_json TEXT NOT NULL DEFAULT '{}', error TEXT ); CREATE TABLE IF NOT EXISTS ai_settings( singleton INTEGER PRIMARY KEY CHECK(singleton=1), primary_provider TEXT NOT NULL DEFAULT 'groq', fallback_enabled INTEGER NOT NULL DEFAULT 0, fallback_order_json TEXT NOT NULL DEFAULT '["gemini","openrouter"]', updated_at TEXT NOT NULL ); CREATE TABLE IF NOT EXISTS knowledge_documents( id INTEGER PRIMARY KEY, document_slug TEXT NOT NULL, source_snapshot_id INTEGER NOT NULL, document_code TEXT NOT NULL, title TEXT, source_hash TEXT NOT NULL, status TEXT NOT NULL DEFAULT 'review_required', completeness_status TEXT NOT NULL DEFAULT 'unknown', completeness_score REAL, completeness_reasons_json TEXT NOT NULL DEFAULT '[]', last_visible_section TEXT, model TEXT, extracted_at TEXT NOT NULL, is_current INTEGER NOT NULL DEFAULT 1, meta_json TEXT NOT NULL DEFAULT '{}', UNIQUE(document_slug, source_snapshot_id) ); CREATE INDEX IF NOT EXISTS idx_knowledge_documents_current ON knowledge_documents(document_slug, is_current); CREATE TABLE IF NOT EXISTS knowledge_rules( id INTEGER PRIMARY KEY, knowledge_document_id INTEGER NOT NULL, document_slug TEXT NOT NULL, source_snapshot_id INTEGER NOT NULL, rule_type TEXT NOT NULL, legal_basis TEXT, statement TEXT NOT NULL, conditions_json TEXT NOT NULL DEFAULT '[]', outcomes_json TEXT NOT NULL DEFAULT '[]', confidence REAL, review_status TEXT NOT NULL DEFAULT 'review_required', ai_run_id INTEGER, created_at TEXT NOT NULL, FOREIGN KEY(knowledge_document_id) REFERENCES knowledge_documents(id) ON DELETE CASCADE ); CREATE INDEX IF NOT EXISTS idx_knowledge_rules_document ON knowledge_rules(document_slug, rule_type, review_status); CREATE TABLE IF NOT EXISTS product_analyses( id INTEGER PRIMARY KEY, created_at TEXT NOT NULL, input_hash TEXT NOT NULL, provider TEXT, model TEXT NOT NULL, result_json TEXT NOT NULL, ai_run_id INTEGER ); Úai_runsÚproviderÚTEXTÚproduct_analysesuÔ INSERT INTO connectors(connector_key,connector_name,connector_type,base_url,status,meta_json) VALUES('techexpert','ТехÑкÑперт','legal_source','http://nps3.cntd.ru/docs','not_configured','{}') ON CONFLICT(connector_key) DO UPDATE SET connector_name=excluded.connector_name, connector_type=excluded.connector_type, base_url=COALESCE(connectors.base_url, excluded.base_url) Úgroqz Groq FreeÚaizhttps://api.groq.com/openai/v1zopenai/gpt-oss-120bÚprimary)ÚmodelÚroleÚgeminiz Gemini Freez8https://generativelanguage.googleapis.com/v1beta/openai/zgemini-3.6-flashÚfallbackÚ openrouterzOpenRouter Freezhttps://openrouter.ai/api/v1zopenrouter/freeaŠ INSERT INTO connectors(connector_key,connector_name,connector_type,base_url,status,meta_json) VALUES(?,?,?,?, 'not_configured', ?) ON CONFLICT(connector_key) DO UPDATE SET connector_name=excluded.connector_name, connector_type=excluded.connector_type, base_url=excluded.base_url F)Ú ensure_asciizZUPDATE connectors SET status='legacy' WHERE connector_key='openai' AND connector_type='ai'zâ INSERT INTO ai_settings(singleton,primary_provider,fallback_enabled,fallback_order_json,updated_at) VALUES(1,'groq',0,'["gemini","openrouter"]',?) ON CONFLICT(singleton) DO NOTHING ) rr rÚ executescriptr.r%ÚjsonÚdumpsrÚcommit)r(Ú providersÚkeyÚnameÚctypeÚurlÚmetas rÚinit_core_schemarG$sB€Ü„MÜÔÜ ‹ðhcØ ×Ñð} ô} ô@ s˜I z°6Ô:ÜsÐ.° ¸FÔCà ‰ ð ô ðK Ð%EØ+°9Ñ =ð ?à m DÐ)cØ(° Ñ ;ð =à Ð+¨DÐ1OØ'¨zÑ :ð <ð  ˆ ð(1ò KÑ #ˆCU˜3˜tØ K‰Kððd˜5 ¤T§Z¡Z°À%Ô%HÐIõ Kð Kð ‰ ÐpÔqà ‰ ð ô‹iˆ\ô  ð ‰ Œ ÷Qh÷hñhús ŸCC9Ã9D)Úreturnr')r)r'r*r'r+r'rHÚNone)rHrI)Ú __future__rr>rrrrÚcore_dbrrrrr r.rGrrrúrLs1ðÝ"ã Û Ûß'ç=Ñ=óIó óFô kr