/* logic/cover.c — 封面下载（HTTPS）+ 限幅 + 解码缓存（单张，URL 变更即换；后台线程）。
 *
 * 内存纪律：下载限幅 NCM_COVER_MAX（字节上限）；解码后的 RGBA 保持单张（换封面先 free 旧再解码）。
 * 线程模型：一个持久的 cover 工作线程负责「目标 URL → 下载 → 解码 → 换入」；UI 线程只经
 *   cover_request(url)（提交目标）与 cover_get()/cover_changed()（读取/判变）+ cover_ack()（消费）。
 * 工作线程不碰 meow_ui（绘制在 UI 线程 tick 判 cover_changed 后触发 invalidate）。
 *
 * §18 修复（切歌封面不更新/CPU 忙等根因）：
 *   - worker 换入成功后**清目标**（g_tgt_url[0]=0）转怠速——旧版成功后不清目标，每圈
 *     缓存读+JPEG 解码+换入+g_gen++ 无 sleep 死循环：CPU 占满、cover_changed() 恒真导致
 *     播放页每帧整盘重绘，慢网络下新封面请求被饿到表现如「切歌封面不更新」。
 *   - 下载/解码失败**指数退避**重试（0.5s→4s），连续 8 次放弃（UI 重进页会重新提交目标）；
 *     失败写 WARN 日志（排查资产），不再无声死等。
 *   - 绘制安全：cover_get() 持锁返回、cover_put() 解锁——旧版 UI 绘制期 worker 可 free
 *     同一 meow_img（use-after-free）；调用方须在 cover_get 后配对 cover_put。
 *
 * §30 修复（真机封面全加载失败）：旧版 `static g_buf[NCM_COVER_MAX(288KB)]` 作为下载缓冲，
 * 网易云封面全尺寸实测 ~1.34MB（>288KB）→ ncm_http 回 NCM_ERR_FULL → 下载失败×8 放弃。
 * 且设备 RAM 仅 56MB，不能再涨静态 bss。改为**流式写文件**：ncm_http_download 的写回调直接
 * 把 body 写进 ncm_cache 写者临时文件（write(2) 直写，无 stdio 缓冲），meow_img_load_file 从
 * 临时文件解码，commit 落盘。全程零封面大缓冲、无 bss 上涨；NCM_COVER_MAX 仅作下载字节上限。
 */
#include "../ncm_app_internal.h"
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/stat.h>

static pthread_mutex_t g_cm = PTHREAD_MUTEX_INITIALIZER;
static meow_img       *g_cover_img;
static char            g_cover_url[512];    /* g_cover_img 对应的 URL */
static char            g_tgt_url[512];      /* 目标 URL（worker 拉取） */
static pthread_t       g_thr;
static int             g_thr_on;
static int             g_quit;
static volatile int    g_gen;               /* 每次换入 +1 */
static int             g_acked;             /* UI 已消费的版本 */
static char            g_cover_path[512];   /* 封面原始文件路径（供 launcher） */

/* 封面缓存键：URL 的 djb2 哈希（稳定性由 URL 决定——同一专辑封面 URL 名即可命中）。
 * 走 ncm_cache（LRU 口径沿用 ncm_cache，见 REPORT §14.2）：键进 ncm_cache_path => 文件
 * `song_cov<hex>.jpg`，与 mp3（song_<id>.mp3）同池，lookup/commit 刷新 mtime（LRU）。 */
static void cover_cache_id(const char *url, char *out, size_t out_sz)
{
    unsigned long h = 5381;
    for (const char *p = url; *p; p++) h = ((h << 5) + h) + (unsigned char)*p;
    snprintf(out, out_sz, "cov%lx", h);
}

/* 文件存在且非空（封面缓存命中用；streaming 后无需整读进内存）。 */
static int file_nonempty(const char *path)
{
    struct stat st;
    return (path && stat(path, &st) == 0 && st.st_size > 0) ? 1 : 0;
}

/* 流式写回调：body 字节直接写进 ncm_cache 写者临时文件（write(2) 直写）。ctx=cover_sink_t*。 */
typedef struct { ncm_cache_writer_t *w; size_t total; } cover_sink_t;
static int cover_sink_write(void *ctx, const unsigned char *data, size_t len)
{
    cover_sink_t *s = (cover_sink_t *)ctx;
    if (ncm_cache_write(s->w, data, len) != 0) return -1;
    s->total += len;
    return 0;
}

/* 下载 url 到 cache 写者 w（流式，写进其临时文件），成功后从临时文件解码并返回 img。
 * 失败返回 NULL（不 commit，调用方 abort）。*out_len=body 字节数；*out_rc 与 *out_status
 * 回填下载 rc 与 HTTP status（封面 4xx 加固判定：确定性 4xx 不重试，REPORT §NEW 任务3）。 */
static meow_img *download_cover(const char *url, ncm_cache_writer_t *w, size_t *out_len,
                                int *out_rc, int *out_status)
{
    ncm_http_req_t req;
    memset(&req, 0, sizeof req);
    req.url = url;
    req.method = "GET";
    req.extra_hdrs = "User-Agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) "
                     "AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36";
    req.verify_ca = NCM_HTTP_VERIFY_DEFAULT;
    req.timeout_ms = 15000;
    ncm_http_resp_t resp;
    cover_sink_t sink = { w, 0 };
    int rc = ncm_http_download(&req, cover_sink_write, &sink, NCM_COVER_MAX, &resp);
    if (out_rc)     *out_rc = rc;
    if (out_status) *out_status = resp.status;
    if (rc != NCM_OK || resp.status != 200 || sink.total == 0) return NULL;
    if (out_len) *out_len = sink.total;
    /* 从写者临时文件解码（未 commit，文件仍在 .tmp；解码到内存 RGBA，与落盘无关） */
    const char *tmp = ncm_cache_writer_tmp_path(w);
    if (!tmp) return NULL;
    return meow_img_load_file(tmp);
}

/* 封面原始文件路径写入（供 launcher 媒体卡片读；兼容保留）。调用方须已持有 g_cm。
 * 从 cache 写者临时文件把已下载字节复制到 cover_current.jpg（早前版本在此内再 lock g_cm
 * → 非递归锁自锁死——cover worker 永久卡死、封面永不出现）。 */
static void save_cover_raw(const char *path, size_t len)
{
    if (!path || len == 0) return;
    if (g_st.cache_dir[0]) {
        char dst[NCM_CACHE_DIR_MAX + 32];
        snprintf(dst, sizeof dst, "%s/cover_current.jpg", g_st.cache_dir);
        /* 文件复制（源=临时文件，目标=cover_current.jpg）。 */
        FILE *in = fopen(path, "rb");
        FILE *out = NULL;
        if (in) {
            out = fopen(dst, "wb");
            if (out) {
                char buf[4096];
                size_t n;
                while ((n = fread(buf, 1, sizeof buf, in)) > 0)
                    if (fwrite(buf, 1, n, out) != n) { fclose(out); out = NULL; break; }
                if (out) fclose(out);
            }
            fclose(in);
        }
        ncm_strlcpy(g_cover_path, dst, sizeof g_cover_path);
    }
}

#define COVER_RETRY_MAX 8       /* 连续失败放弃次数（UI 重进页/切歌会重新提交目标） */

/* 内存瘦身：封面解码后按显示上限降采样驻留。网易云全尺寸封面（如 1448×1448）解码成
 * RGBA = 8MB，而应用显示只需 ≤480px（播放页黑胶方图+歌词页模糊铺底均 ≤ 屏幕 480 宽）——
 * 缩到 480×480 = 0.9MB，省 ~7MB anon（设备 RAM 仅 56MB，OOM 真机被杀，最高优先级）。
 * 若已 ≤上限（小缩略图）则原样保留。返回本函数处理后的图（可能替换/释放旧图）。 */
#define NCM_COVER_DECODE_MAX 480
static meow_img *cover_cap(meow_img *im)
{
    if (!im) return NULL;
    meow_img *small = meow_img_downscale(im, NCM_COVER_DECODE_MAX);
    if (small) { meow_img_free(im); return small; }   /* 已缩放：释放原始大图，换小图驻留 */
    return im;                                          /* 本就够小：保留原图 */
}

static void *cover_worker(void *arg)
{
    (void)arg;
    int backoff_ms = 0, fails = 0;
    while (!g_quit) {
        pthread_mutex_lock(&g_cm);
        if (!g_tgt_url[0]) {
            pthread_mutex_unlock(&g_cm);
            backoff_ms = 0; fails = 0;
            usleep(250 * 1000);
            continue;
        }
        char url[512];
        ncm_strlcpy(url, g_tgt_url, sizeof url);
        pthread_mutex_unlock(&g_cm);

        char key[32];
        cover_cache_id(url, key, sizeof key);
        size_t blen = 0;
        meow_img *img = NULL;
        int drc = NCM_ERR_NET, dstatus = 0;   /* 本目标最近一次下载 rc/HTTP status（4xx 判定用） */

        /* ① 缓存命中直接解码（免下载、离线可看；LRU：lookup 刷新 mtime） */
        char cpath[512];
        if (g_st.ctx.cache.dir[0] && ncm_cache_lookup(&g_st.ctx.cache, key, ".jpg",
                                                      cpath, sizeof cpath) == NCM_OK &&
            file_nonempty(cpath)) {
            img = meow_img_load_file(cpath);
        }
        /* ② 未命中 → 流式下载解码；成功后落进 ncm_cache（LRU 池，超限由 ncm_cache_evict 淘汰） */
        if (!img) {
            if (g_st.ctx.cache.dir[0]) {
                ncm_cache_evict(&g_st.ctx.cache);
                ncm_cache_writer_t *w = NULL;
                if (ncm_cache_open(&g_st.ctx.cache, key, ".jpg", &w) == NCM_OK) {
                    blen = 0;
                    img = download_cover(url, w, &blen, &drc, &dstatus);
                    if (img) {
                        pthread_mutex_lock(&g_cm);
                        save_cover_raw(ncm_cache_writer_tmp_path(w), blen);
                        pthread_mutex_unlock(&g_cm);
                        if (ncm_cache_commit(w) != 0) { ncm_cache_abort(w); }
                    } else {
                        ncm_cache_abort(w);
                    }
                    ncm_cache_evict(&g_st.ctx.cache);
                } else {
                    /* 打开写者失败（罕见）：退避重试，不空转 */
                    img = NULL;
                }
            }
        }
        /* 内存瘦身：全尺寸封面解码后降采样到 ≤480px 驻留（省 ~7MB anon，OOM 修复）。 */
        if (img) img = cover_cap(img);
        if (!img) {
            /* 失败分诊（REPORT §NEW 任务3）：确定性 4xx（404 死链等）**不重试**，立即清目标
             * 跳下一张（重试也白费）；仅瞬时错误（超时/网络/TLS/5xx）指数退避重试。
             * 日志打 rc/status（排查资产：先前只见 "fetch failed" 不知 HTTP 层返了什么）。 */
            int deterministic = (dstatus >= 400 && dstatus < 500 && dstatus != 408 && dstatus != 429);
            meow_log(MEOW_LOG_WARN, "cover: fetch fail url=%.64s rc=%d status=%d%s",
                     url, drc, dstatus, deterministic ? " (4xx, no retry)" : "");
            if (deterministic) {
                pthread_mutex_lock(&g_cm);
                if (strcmp(g_tgt_url, url) == 0) g_tgt_url[0] = 0;   /* 立即跳下一张 */
                pthread_mutex_unlock(&g_cm);
                backoff_ms = 0; fails = 0;
                continue;
            }
            /* 瞬时错误：指数退避重试，连续 COVER_RETRY_MAX 次放弃（不无声死等；
             * 目标保留期间 UI 每帧重请求由 cover_request 去重挡住）。 */
            fails++;
            if (fails >= COVER_RETRY_MAX) {
                meow_log(MEOW_LOG_WARN, "cover: give up after %d fails url=%.64s", fails, url);
                pthread_mutex_lock(&g_cm);
                if (strcmp(g_tgt_url, url) == 0) g_tgt_url[0] = 0;
                pthread_mutex_unlock(&g_cm);
                backoff_ms = 0; fails = 0;
                continue;
            }
            meow_log(MEOW_LOG_WARN, "cover: fetch failed (%d) url=%.64s retry in %dms",
                     fails, url, backoff_ms ? backoff_ms : 500);
            if (g_app_quit) return NULL;
            usleep(backoff_ms ? backoff_ms * 1000 : 500 * 1000);
            backoff_ms = backoff_ms ? (backoff_ms * 2 > 4000 ? 4000 : backoff_ms * 2) : 500;
            continue;
        }
        backoff_ms = 0; fails = 0;

        pthread_mutex_lock(&g_cm);
        /* 目标仍是 url 才换入（期间未提交更早） */
        if (g_tgt_url[0] && strcmp(g_tgt_url, url) == 0) {
            if (g_cover_img) meow_img_free(g_cover_img);
            g_cover_img = img;
            ncm_strlcpy(g_cover_url, url, sizeof g_cover_url);
            g_gen++;
            g_tgt_url[0] = 0;   /* 目标达成即清：worker 转怠速（修忙等死循环，§18） */
        } else {
            meow_img_free(img);
        }
        pthread_mutex_unlock(&g_cm);
    }
    return NULL;
}

/* UI 线程：提交目标封面 URL（无网络/无 URL 则忽略）。 */
void cover_request(const char *url)
{
    if (!url || !url[0]) return;
    if (g_host_mock) return;   /* 宿主 mock = 0 网络纪律（mock URL 不得发真实 HTTPS） */
    pthread_mutex_lock(&g_cm);
    /* 去重：已在展示 或 已在拉取途中的同一 URL 不重复提交。 */
    if ((g_cover_url[0] && strcmp(g_cover_url, url) == 0) ||
        (g_tgt_url[0]   && strcmp(g_tgt_url, url) == 0)) { pthread_mutex_unlock(&g_cm); return; }
    ncm_strlcpy(g_tgt_url, url, sizeof g_tgt_url);
    pthread_mutex_unlock(&g_cm);
    if (!g_thr_on) {
        g_thr_on = 1;
        if (ncm_thread_create(&g_thr, cover_worker, NULL) == 0)
            pthread_detach(g_thr);
        else
            g_thr_on = 0;
    }
}

/* UI 线程：读取当前封面——**持锁返回**，绘制完必须配对 cover_put()（§18 修 UAF：
 * 旧版 get 后无锁绘制，worker 换入时 free 同一张图 → use-after-free）。 */
meow_img *cover_get(void)
{
    pthread_mutex_lock(&g_cm);
    return g_cover_img;
}

void cover_put(void)
{
    pthread_mutex_unlock(&g_cm);
}

/* 是否有新封面待绘制（UI tick 判变）。 */
int cover_changed(void) { return g_gen != g_acked; }
/* UI 消费一次：标记已见当前版本。 */
void cover_ack(void) { g_acked = g_gen; }

/* 封面原始文件路径（供 launcher 媒体卡片读）；NULL=无。 */
const char *cover_current_path(void)
{
    const char *p;
    pthread_mutex_lock(&g_cm);
    p = g_cover_path[0] ? g_cover_path : NULL;
    pthread_mutex_unlock(&g_cm);
    return p;
}

void cover_cache_reset(void)
{
    pthread_mutex_lock(&g_cm);
    if (g_cover_img) { meow_img_free(g_cover_img); g_cover_img = NULL; }
    g_cover_url[0] = 0;
    g_tgt_url[0] = 0;
    g_cover_path[0] = 0;
    pthread_mutex_unlock(&g_cm);
    g_gen++;
    g_acked = g_gen;
}

#ifdef MEOW_UI_HOST_TEST
/* 宿主测试桩（仅宿主构建；产品构建无此符号）：注入一张本地封面图（不经网络），
 * 验证封面页方形圆角大图与歌词页模糊置底路径（§22）。0 真实请求纪律不变。 */
void cover_host_inject(const char *path)
{
    if (!path || !path[0]) return;
    meow_img *img = meow_img_load_file(path);
    if (!img) { meow_log(MEOW_LOG_WARN, "cover host inject: load failed %s", path); return; }
    pthread_mutex_lock(&g_cm);
    if (g_cover_img) meow_img_free(g_cover_img);
    g_cover_img = img;
    ncm_strlcpy(g_cover_url, path, sizeof g_cover_url);
    g_cover_path[0] = 0;
    g_gen++;
    pthread_mutex_unlock(&g_cm);
}
#endif