插件商店

curl -s http://127.0.0.1:8765/health
# {"ok":true,"service":"lvx-agent","api":1,"bin":"/home/linux/lvx-office/lvx-run/build/lvx"}

curl -s http://127.0.0.1:8765/plugins          # 本机 lvx plugins 原文：58 个插件
# {"ok":true,"code":0,"output":"LVX plugins (58 loaded):\n  backend-vulkan-fake v1  ABI 1  caps=0x0  …\n"}

curl -s -X POST http://127.0.0.1:8765/install \
     -H 'Content-Type: application/json' \
     -d '{"id":"no-such-plugin-xyz"}'
# {"ok":false,"code":1,"output":"lvx: package not found: no-such-plugin-xyz\n…"}

curl -s -X POST http://127.0.0.1:8765/uninstall \
     -H 'Content-Type: application/json' -d '{"id":"no-such-plugin-xyz"}'
# {"ok":false,"code":1,"output":"lvx: package 'no-such-plugin-xyz' not installed (plugin ls)\n"}

curl -s -o /dev/null -w '%{http_code}\n' -X POST http://127.0.0.1:8765/install \
     -H 'Content-Type: application/json' -d '{}'      # 400（参数错）
curl -s -o /dev/null -w '%{http_code}\n' http://127.0.0.1:8765/nope   # 404（未知路由）

失败时 output 就是 lvx CLI 的原话，本页会原样显示在日志区。

const AGENT = 'http://127.0.0.1:8765';           // 只在本机可达
const hasAgent = async () => { try { return (await fetch(AGENT+'/health')).ok } catch { return false } };

async function installPlugin(app) {              // app.downloadUrl / app.id 来自 store.json
  const r = await fetch(AGENT + '/install', {
    method: 'POST', headers: {'Content-Type': 'application/json'},
    body: JSON.stringify({url: app.downloadUrl, id: app.id}),
  });
  const d = await r.json();
  if (!d.ok) throw new Error(d.output || d.error);
  return d.output;
}
async function uninstallPlugin(app) {
  const r = await fetch(AGENT + '/uninstall', {
    method: 'POST', headers: {'Content-Type': 'application/json'},
    body: JSON.stringify({id: app.id}),
  });
  const d = await r.json();
  if (!d.ok) throw new Error(d.output || d.error);
  return d.output;
}
// 装了令牌时给所有请求加 X-LVX-Token 头即可。

std::string resolveUrl(const std::string &explicitUrl, const std::string &package,
                       const std::string &base, const std::string &repo) {
  if (!explicitUrl.empty()) return explicitUrl;
  if (package.empty()) return {};
  if (package.rfind("http://", 0) == 0 || package.rfind("https://", 0) == 0)
    return package;
  std::string rel = package;
  while (!rel.empty() && rel[0] == '/') rel.erase(rel.begin());
  if (!repo.empty())
    return "https://raw.githubusercontent.com/" + repo + "/main/" + rel;
  return join(base, rel);
}

// 起任务：两个源各自抓取
int Catalog::load(const std::string &officialUrlIn) {
  if (fetcher_ == nullptr) fetcher_.reset(new fetch::Fetcher());
  std::unique_ptr<Job> j(new Job());
  const std::string official = officialUrlIn.empty() ? officialUrl() : officialUrlIn;
  if (!official.empty())
    j->fetchers[j->fetcherCount++] =
        fetcher_->startText(join(official, "store.json"), "the official index");
  const std::vector<std::string> repos = Catalog::repos();
  const std::string token = githubToken();
  const std::string auth = token.empty() ? std::string() : "Authorization: Bearer " + token;
  for (size_t i = 0; i < repos.size() && j->fetcherCount < 2; ++i)
    j->fetchers[j->fetcherCount++] = fetcher_->startText(
        githubApiBase() + "/repos/" + repos[i] + "/contents/store.json",
        "the GitHub index", auth);
  jobs_.push_back(std::move(j));
  return static_cast<int>(jobs_.size());
}

// 每帧推进一步：全部抓取完成 → finish()
void Catalog::pump() {
  if (fetcher_ == nullptr) return;
  fetcher_->pump();
  for (auto &jp : jobs_) {
    if (jp == nullptr || jp->state != 0) continue;
    bool allDone = true;
    for (int i = 0; i < jp->fetcherCount; ++i)
      if (fetcher_->state(jp->fetchers[i]) == fetch::kRunning) allDone = false;
    if (allDone) finish(*jp);
  }
}

// 合并：任一源成功即 ready（0 加载中 / 1 就绪 / 2 失败）
void Catalog::finish(Job &j) {
  int ok = 0;
  for (int i = 0; i < j.fetcherCount; ++i) {
    if (fetcher_->state(j.fetchers[i]) != fetch::kDone) { /* 记错误，继续下一个源 */ continue; }
    const size_t before = j.entries.size();
    if (i == 0) parseStore(fetcher_->body(id), "official", official, "", &j.entries);
    else        parseStore(fetcher_->body(id), "github:" + repos[i-1], "", repos[i-1], &j.entries);
    if (j.entries.size() > before) ++ok;
  }
  j.state = j.fetcherCount == 0 ? 2 : (ok > 0 ? 1 : 2);
}

/// 简单点分版本比较：0.10 > 0.9（按数值，不按字典序）
int cmpVersion(String a, String b) {
  final pa = a.split('.').map((x) => int.tryParse(x)).toList();
  final pb = b.split('.').map((x) => int.tryParse(x)).toList();
  final n = pa.length > pb.length ? pa.length : pb.length;
  for (var i = 0; i < n; i++) {
    final x = i < pa.length ? (pa[i] ?? 0) : 0;
    final y = i < pb.length ? (pb[i] ?? 0) : 0;
    if (x != y) return x.compareTo(y);
  }
  return 0;
}

bool isNewerVersion(String remote, String local) => cmpVersion(remote, local) > 0;