from pathlib import Path
import asyncio
from services.ocean_batch import OceanBatchManager
from services.download_jobs import DownloadJobStore


def test_ocean_jobs_persist_and_are_user_scoped(tmp_path):
    m=OceanBatchManager(tmp_path/'ocean','http://example.invalid')
    spec={'start_date':'2002-08-01','end_date':'2002-08-02','variables':['sst'],'bbox':{'lon_min':120,'lon_max':140,'lat_min':20,'lat_max':40},'format':'csv','region_name':'test','region_source':'explicit_coordinates','days':2,'subtask_count':2}
    async def fake_start(jid): return None
    m.start=fake_start
    job=asyncio.run(m.create('u1','test',spec,'thread-123'))
    assert job['thread_id']=='thread-123'
    restored=OceanBatchManager(tmp_path/'ocean','http://example.invalid')
    items=restored.list_user('u1')
    assert len(items)==1 and items[0]['job_id']==job['job_id']
    assert restored.list_user('u2')==[]


def test_download_jobs_are_listed_after_store_reopen(tmp_path):
    root=tmp_path/'downloads'
    s=DownloadJobStore(root)
    j=s.create('u1','https://example.com/a','a.nc',100,True,'application/octet-stream')
    s.progress(j['job_id'],25)
    s2=DownloadJobStore(root)
    items=s2.list_user('u1')
    assert len(items)==1
    assert items[0]['transferred_bytes']==25
    assert items[0]['resume_supported'] is True


def test_frontend_has_persistent_task_center_and_single_retry():
    js=Path('static/js/app.js').read_text(encoding='utf-8')
    assert '持久化任务' in js
    assert '/subtasks/'+"'"+'+encodeURIComponent(btn.dataset.sub)+'+"'"+'/retry' in js or '/subtasks/' in js
    assert '回到关联对话' in js