feat(release): +download 一步下载发行版全部附件(tag/id 自动解析 version_id)

This commit is contained in:
Taoyouce 2026-07-07 16:37:54 +00:00
parent 682604f238
commit b4e66f1eaa
6 changed files with 178 additions and 1 deletions

View File

@ -487,6 +487,9 @@ gitlink-cli attachment +upload -f ./dist/app.tar.gz,./dist/app.sha256,./dist/CHA
# Download an attachment by id to a local file
gitlink-cli attachment +download -i <attachment_id> -o ./app-v1.0.0.tar.gz
# Download all attachments of a release by tag (mirrors `gh release download`)
gitlink-cli release +download -i v1.0.0 -o ./assets
# Delete an attachment by id
gitlink-cli attachment +delete -i <attachment_id>

View File

@ -478,6 +478,9 @@ gitlink-cli attachment +upload -f ./dist/app.tar.gz,./dist/app.sha256,./dist/CHA
# 按 id 下载附件到本地文件
gitlink-cli attachment +download -i <attachment_id> -o ./app-v1.0.0.tar.gz
# 按 tag 一步下载发行版全部附件(对标 `gh release download`
gitlink-cli release +download -i v1.0.0 -o ./assets
# 按 id 删除附件
gitlink-cli attachment +delete -i <attachment_id>

View File

@ -85,6 +85,8 @@
"cmd.profile.short": "User profile and statistics operations",
"cmd.release.create.short": "Create a release",
"cmd.release.delete.short": "Delete a release",
"cmd.release.download.long": "Fetch the release by id or tag and download every attachment to a local directory, mirroring `gh release download`.",
"cmd.release.download.short": "Download all attachments of a release",
"cmd.release.list.short": "List releases",
"cmd.release.short": "Release operations",
"cmd.release.view.short": "View release details",
@ -120,6 +122,7 @@
"error.dataset.delete_confirm": "dataset attachment deletion is destructive; run --dry-run first, then pass --yes to confirm",
"error.missing_required_flag": "required flag --{name} is missing",
"error.profile.user_required": "could not determine target user; pass --user or run gitlink-cli auth login",
"error.release.no_attachments": "the release has no attachments to download",
"error.unsupported_language": "unsupported language: {lang}",
"flag.api.batch_continue_on_error": "Continue running remaining batch requests after a failure",
"flag.api.batch_dry_run": "Preview batch requests without sending remote requests",
@ -217,6 +220,7 @@
"flag.release.id": "Release ID",
"flag.release.id_or_tag": "Release ID or tag",
"flag.release.name": "Release name",
"flag.release.output_dir": "Directory to save downloaded files (default current directory)",
"flag.release.prerelease": "Mark as prerelease (true/false)",
"flag.release.tag": "Tag name",
"flag.release.target": "Target branch",

View File

@ -85,6 +85,8 @@
"cmd.profile.short": "用户画像与统计操作",
"cmd.release.create.short": "创建发布",
"cmd.release.delete.short": "删除发布",
"cmd.release.download.long": "按 id 或 tag 获取发行版并把全部附件下载到本地目录,对标 `gh release download`。",
"cmd.release.download.short": "下载发行版的全部附件",
"cmd.release.list.short": "列出发布",
"cmd.release.short": "发布操作",
"cmd.release.view.short": "查看发布详情",
@ -120,6 +122,7 @@
"error.dataset.delete_confirm": "删除数据集附件具有破坏性;请先 --dry-run 预览,再传 --yes 确认",
"error.missing_required_flag": "缺少必需参数 --{name}",
"error.profile.user_required": "无法确定目标用户;请通过 --user 指定,或先运行 gitlink-cli auth login 登录",
"error.release.no_attachments": "该发行版没有可下载的附件",
"error.unsupported_language": "不支持的语言:{lang}",
"flag.api.batch_continue_on_error": "批处理请求失败后继续执行后续请求",
"flag.api.batch_dry_run": "预览批处理请求,不发送远端请求",
@ -217,6 +220,7 @@
"flag.release.id": "发布 ID",
"flag.release.id_or_tag": "发布 ID 或标签",
"flag.release.name": "发布名称",
"flag.release.output_dir": "下载文件保存目录(默认当前目录)",
"flag.release.prerelease": "标记为预发布true/false",
"flag.release.tag": "标签名称",
"flag.release.target": "目标分支",

View File

@ -1,9 +1,11 @@
package release
import (
"errors"
"fmt"
"net/url"
"os"
"path/filepath"
"strconv"
"strings"
@ -12,6 +14,37 @@ import (
"github.com/gitlink-org/gitlink-cli/shortcuts/common"
)
// resolveVersionID maps a user-supplied release reference (tag name, gitea
// release id, or database version_id) to the database version_id that the
// `/releases/:id` show/edit/destroy endpoints expect. The list endpoint is
// the only one exposing both identifiers, so we page through it and match.
func resolveVersionID(ctx *common.RuntimeContext, ref string) (string, error) {
for page := 1; page <= 100; page++ {
q := url.Values{}
q.Set("page", strconv.Itoa(page))
q.Set("limit", "50")
env, err := ctx.CallAPIWithQuery("GET", ctx.RepoPath()+"/releases", q)
if err != nil {
return "", err
}
data, _ := env.Data.(map[string]interface{})
releases, _ := data["releases"].([]interface{})
if len(releases) == 0 {
break
}
for _, r := range releases {
rel, _ := r.(map[string]interface{})
tag, _ := rel["tag_name"].(string)
gid := fmt.Sprintf("%v", rel["id"])
versionID := fmt.Sprintf("%v", rel["version_id"])
if ref == tag || ref == gid || ref == versionID {
return versionID, nil
}
}
}
return "", fmt.Errorf("release %q not found", ref)
}
func Shortcuts(translators ...*i18n.Translator) []*common.Shortcut {
tr := shortcutTranslator(translators...)
return []*common.Shortcut{
@ -147,6 +180,63 @@ func Shortcuts(translators ...*i18n.Translator) []*common.Shortcut {
return ctx.Output(env)
},
},
{
Name: "download",
Description: tr.T("cmd.release.download.short"),
Long: tr.T("cmd.release.download.long"),
Flags: []common.Flag{
{Name: "id", Short: "i", Usage: tr.T("flag.release.id_or_tag"), Required: true},
{Name: "output-dir", Short: "o", Usage: tr.T("flag.release.output_dir"), Default: "."},
},
Run: func(ctx *common.RuntimeContext) error {
if err := ctx.ResolveOwnerRepo(); err != nil {
return err
}
id, err := ctx.RequireArg("id")
if err != nil {
return err
}
versionID, err := resolveVersionID(ctx, id)
if err != nil {
return err
}
env, err := ctx.CallAPI("GET", fmt.Sprintf("%s/releases/%s", ctx.RepoPath(), versionID), nil)
if err != nil {
return err
}
data, _ := env.Data.(map[string]interface{})
attachments, _ := data["attachments"].([]interface{})
if len(attachments) == 0 {
return errors.New(tr.T("error.release.no_attachments"))
}
outDir := ctx.Arg("output-dir")
if err := os.MkdirAll(outDir, 0o755); err != nil {
return fmt.Errorf("create output dir %q: %w", outDir, err)
}
var downloaded []map[string]interface{}
for _, a := range attachments {
att, _ := a.(map[string]interface{})
title, _ := att["title"].(string)
attID := fmt.Sprintf("%v", att["id"])
if title == "" || attID == "" || att["id"] == nil {
continue
}
dest := filepath.Join(outDir, filepath.Base(title))
n, err := ctx.Client.DownloadFile("/attachments/"+attID, dest)
if err != nil {
return fmt.Errorf("download %q failed: %w", title, err)
}
downloaded = append(downloaded, map[string]interface{}{
"file": dest,
"bytes": n,
})
}
return ctx.OutputData(map[string]interface{}{
"release": id,
"files": downloaded,
})
},
},
{
Name: "update",
Description: "Update a release while preserving unspecified fields",

View File

@ -331,7 +331,7 @@ func TestReleaseShortcutNames(t *testing.T) {
for _, shortcut := range Shortcuts() {
got[shortcut.Name] = true
}
want := []string{"list", "create", "edit", "view", "update", "delete"}
want := []string{"list", "create", "edit", "view", "download", "update", "delete"}
for _, name := range want {
if !got[name] {
t.Fatalf("missing shortcut %q in %v", name, got)
@ -452,6 +452,7 @@ func ExampleShortcuts() {
// create
// edit
// view
// download
// update
// delete
}
@ -510,3 +511,75 @@ func TestReleaseCreateAttachmentFilesMissing(t *testing.T) {
t.Fatal("expected error for missing attachment file")
}
}
func TestReleaseDownloadAllAttachments(t *testing.T) {
server := newReleaseTestServer(t, func(w http.ResponseWriter, r *http.Request) {
switch r.URL.Path {
case "/owner/repo/releases.json":
if r.URL.Query().Get("page") != "1" {
writeReleaseJSON(t, w, map[string]interface{}{"releases": []interface{}{}})
return
}
writeReleaseJSON(t, w, map[string]interface{}{
"releases": []map[string]interface{}{
{"tag_name": "v1.0.0", "id": "900001", "version_id": 7},
},
})
case "/owner/repo/releases/7.json":
writeReleaseJSON(t, w, map[string]interface{}{
"tag_name": "v1.0.0",
"attachments": []map[string]interface{}{
{"id": 12, "title": "a.bin"},
{"id": "uuid-34", "title": "b.txt"},
},
})
case "/attachments/12", "/attachments/12.json":
fmt.Fprint(w, "content-a")
case "/attachments/uuid-34", "/attachments/uuid-34.json":
fmt.Fprint(w, "content-b")
default:
t.Fatalf("unexpected request: %s %s", r.Method, r.URL.Path)
}
})
defer server.Close()
outDir := t.TempDir()
if err := runReleaseShortcut(t, server, "download", map[string]string{
"id": "v1.0.0",
"output-dir": outDir,
}); err != nil {
t.Fatalf("release download failed: %v", err)
}
for name, want := range map[string]string{"a.bin": "content-a", "b.txt": "content-b"} {
got, err := os.ReadFile(filepath.Join(outDir, name))
if err != nil {
t.Fatalf("read %s: %v", name, err)
}
if string(got) != want {
t.Fatalf("%s content = %q, want %q", name, got, want)
}
}
}
func TestReleaseDownloadNoAttachments(t *testing.T) {
server := newReleaseTestServer(t, func(w http.ResponseWriter, r *http.Request) {
if r.URL.Path == "/owner/repo/releases.json" {
if r.URL.Query().Get("page") != "1" {
writeReleaseJSON(t, w, map[string]interface{}{"releases": []interface{}{}})
return
}
writeReleaseJSON(t, w, map[string]interface{}{
"releases": []map[string]interface{}{
{"tag_name": "v1.0.0", "id": "900001", "version_id": 7},
},
})
return
}
writeReleaseJSON(t, w, map[string]interface{}{"tag_name": "v1.0.0"})
})
defer server.Close()
if err := runReleaseShortcut(t, server, "download", map[string]string{"id": "v1.0.0"}); err == nil {
t.Fatal("expected error when release has no attachments")
}
}