"""Shared application state. Routes access this module, not copied globals."""
from pathlib import Path
import logging
from fastapi import HTTPException
from storage.store import Store
from storage.files import parse_file
from core.job_manager import ManagedJob
from core.state_manager import JobLease
from paths import ROOT, data_dir

store = None
job = None
resources = None

def initialize():
    global store, job, resources
    # Re-importing the Web app must not replace an active worker in-process.
    if job is not None and job.thread is not None and job.thread.is_alive():
        return
    directory = data_dir()
    directory.mkdir(parents=True, exist_ok=True)
    logs = directory / 'logs'
    logs.mkdir(parents=True, exist_ok=True)
    from monitoring.logger import configure_logging
    configure_logging(logs / 'app.log')
    from monitoring.resources import ResourceSampler
    if resources is not None:resources.close()
    resources=ResourceSampler([('Dữ liệu',directory),('Audio',Path(__import__('os').getenv('NOVEL_OUTPUT_AUDIO',ROOT/'output_audio'))),('Văn bản',Path(__import__('os').getenv('NOVEL_OUTPUT_TEXT',ROOT/'output_text')))])
    db_path = directory / 'novel.sqlite3'
    recover = not JobLease(directory / 'job.lock').held_by_another()
    store = Store(db_path, recover_incomplete=recover)
    job = ManagedJob(store)

def ensure_idle():
    from core.tomato_service import pipeline
    if pipeline.downloading():
        raise HTTPException(409, 'Đang tải truyện bằng ID. Hãy đợi tải hoàn tất hoặc hủy tác vụ.')
    if job.active:raise HTTPException(409,'Hãy dừng job dịch trước khi thực hiện thao tác này.')


def import_book(name,data):
    with job.lock:
        ensure_idle()
        try:
            chapters,encoding=parse_file(name,data)
            store.replace(name,encoding,chapters);job.status='ready';job.message=''
            job.target_chapter_ids = None
            job.scope_label = ''
        except Exception as exc:
            logging.exception('Import failed');raise HTTPException(400,f'Không nạp được tệp: {exc}')
    job.emit('book_loaded');return {'book':store.book(),'chapters':store.list()}