midZddlZddlmZddlmZddlmZddlm Z e e Z dZ dZ d Zd Zgd Zdd eed ejfdZdd eed dfdZdd eed dfdZe dkreededSdS)zl SQLite database schema for Garmin Health Sync system. Defines tables for sync tracking and data indexing. N)Path)Optional)DB_PATH) setup_loggera] CREATE TABLE IF NOT EXISTS sync_records ( id INTEGER PRIMARY KEY AUTOINCREMENT, data_type TEXT NOT NULL, start_date TEXT NOT NULL, end_date TEXT NOT NULL, status TEXT NOT NULL, -- 'success', 'failed', 'partial' records_synced INTEGER DEFAULT 0, error_message TEXT, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ); z CREATE TABLE IF NOT EXISTS last_sync_state ( data_type TEXT PRIMARY KEY, last_sync_date TEXT NOT NULL, total_records INTEGER DEFAULT 0, updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ); a% CREATE TABLE IF NOT EXISTS daily_metrics_index ( id INTEGER PRIMARY KEY AUTOINCREMENT, metric_type TEXT NOT NULL, date TEXT NOT NULL, file_path TEXT NOT NULL, has_data BOOLEAN DEFAULT 1, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP, UNIQUE(metric_type, date) ); a8 CREATE TABLE IF NOT EXISTS activity_index ( id INTEGER PRIMARY KEY AUTOINCREMENT, activity_id TEXT UNIQUE NOT NULL, activity_type TEXT, date TEXT NOT NULL, duration_seconds INTEGER, distance_meters REAL, file_path TEXT NOT NULL, created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ); )z]CREATE INDEX IF NOT EXISTS idx_sync_records_type_date ON sync_records(data_type, start_date);zaCREATE INDEX IF NOT EXISTS idx_daily_metrics_type_date ON daily_metrics_index(metric_type, date);zECREATE INDEX IF NOT EXISTS idx_activity_date ON activity_index(date);zNCREATE INDEX IF NOT EXISTS idx_activity_type ON activity_index(activity_type);db_pathreturnc||pt}tjt|}tj|_|S)zGet a database connection. Args: db_path: Optional path to database file (defaults to config.DB_PATH) Returns: SQLite connection object )rsqlite3connectstrRow row_factory)rpathconns )/root/projects/butler/health/db/schema.pyget_connectionrJs2  gD ?3t99 % %D{D Kc2|pt}td|t|5}|}|t |t|t|ttD]}||| dddn #1swxYwYtddS)zInitialize database schema. Creates all necessary tables and indexes if they don't exist. Args: db_path: Optional path to database file (defaults to config.DB_PATH) zInitializing database at Nz Database initialization complete) rloggerinforcursorexecuteCREATE_SYNC_RECORDS_TABLECREATE_LAST_SYNC_STATE_TABLE CREATE_DAILY_METRICS_INDEX_TABLECREATE_ACTIVITY_INDEX_TABLECREATE_INDEXEScommit)rrrr index_sqls r init_databaser Ys2  gD KK2D22333     0111344478882333( & &I NN9 % % % %                 KK233333sB0C22C69C6c|pt}td|t|5}|}|d|d|d|d|dddn #1swxYwYt|tddS)zReset database by dropping all tables and reinitializing. WARNING: This will delete all sync history and indexes! Args: db_path: Optional path to database file (defaults to config.DB_PATH) zResetting database at z!DROP TABLE IF EXISTS sync_recordsz$DROP TABLE IF EXISTS last_sync_statez(DROP TABLE IF EXISTS daily_metrics_indexz#DROP TABLE IF EXISTS activity_indexNzDatabase reset complete) rrwarningrrrrr r)rrrrs rreset_databaser#vs  gD NN2D22333     :;;;=>>>ABBB<===                $ KK)*****sA=B??CC__main__zDatabase initialized at )N)__doc__r pathlibrtypingr health.configrhealth.utils.logging_configr__name__rrrrrr Connectionrr r#printrrr.se !!!!!!444444 h     $    HTN g6H    448D>4T4444:++HTN+d++++6 zMOOO E .W . ./////r