// Copyright 2025 Cloudbase Solutions SRL // // Licensed under the Apache License, Version 2.0 (the "License"); you may // not use this file except in compliance with the License. You may obtain // a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, WITHOUT // WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the // License for the specific language governing permissions and limitations // under the License. package cache import ( "context" "encoding/json" "fmt" "io" "log/slog" "net/http" "strings" "time" "golang.org/x/mod/semver" commonParams "github.com/cloudbase/garm-provider-common/params" ) const ( // GiteaRunnerReleasesURL is the public API URL that returns a json of all Gitea runner releases. // By default it returns the last 10 releases, which is enough for our needs. GiteaRunnerReleasesURL = "https://gitea.com/api/v1/repos/gitea/act_runner/releases" // GiteaRunnerMinimumVersion is the minimum version we need in order to support ephemeral runners. GiteaRunnerMinimumVersion = "v0.2.12" ) var githubArchMapping = map[string]string{ "x86_64": "x64", "amd64": "x64", "armv7l": "arm", "aarch64": "arm64", "x64": "x64", "arm": "arm", "arm64": "arm64", } var nightlyActRunner = GiteaEntityTool{ TagName: "nightly", Name: "nightly", TarballURL: "https://gitea.com/gitea/act_runner/archive/main.tar.gz", Assets: []GiteaToolsAssets{ { Name: "act_runner-nightly-linux-amd64.xz", DownloadURL: "https://dl.gitea.com/act_runner/nightly/act_runner-nightly-linux-amd64.xz", }, { Name: "act_runner-nightly-linux-arm64.xz", DownloadURL: "https://dl.gitea.com/act_runner/nightly/act_runner-nightly-linux-arm64.xz", }, { Name: "act_runner-nightly-windows-amd64.exe.xz", DownloadURL: "https://dl.gitea.com/act_runner/nightly/act_runner-nightly-windows-amd64.exe.xz", }, }, } type GiteaToolsAssets struct { ID uint `json:"id"` Name string `json:"name"` Size uint `json:"size"` DownloadCount uint `json:"download_count"` CreatedAt time.Time `json:"created_at"` UUID string `json:"uuid"` DownloadURL string `json:"browser_download_url"` } func (g GiteaToolsAssets) GetOS() (*string, error) { if g.Name == "" { return nil, fmt.Errorf("gitea tools name is empty") } parts := strings.SplitN(g.Name, "-", 4) if len(parts) != 4 { return nil, fmt.Errorf("could not parse asset name") } os := parts[2] return &os, nil } func (g GiteaToolsAssets) GetArch() (*string, error) { if g.Name == "" { return nil, fmt.Errorf("gitea tools name is empty") } parts := strings.SplitN(g.Name, "-", 4) if len(parts) != 4 { return nil, fmt.Errorf("could not parse asset name") } archParts := strings.SplitN(parts[3], ".", 2) if len(archParts) == 0 { return nil, fmt.Errorf("unexpected asset name format") } arch := githubArchMapping[archParts[0]] if arch == "" { return nil, fmt.Errorf("could not find arch for %s", archParts[0]) } return &arch, nil } type GiteaEntityTool struct { // TagName is the semver version of the release. TagName string `json:"tag_name"` Name string `json:"name"` TarballURL string `json:"tarball_url"` Assets []GiteaToolsAssets `json:"assets"` } type GiteaEntityTools []GiteaEntityTool func (g GiteaEntityTools) GetLatestVersion() string { if len(g) == 0 { return "" } return g[0].TagName } func (g GiteaEntityTools) MinimumVersion() (GiteaEntityTool, bool) { if len(g) == 0 { return GiteaEntityTool{}, false } for _, tool := range g { if semver.Compare(tool.TagName, GiteaRunnerMinimumVersion) >= 0 { return tool, true } } return GiteaEntityTool{}, false } func getTools(ctx context.Context) ([]commonParams.RunnerApplicationDownload, error) { resp, err := http.Get(GiteaRunnerReleasesURL) if err != nil { return nil, err } defer resp.Body.Close() data, err := io.ReadAll(resp.Body) if err != nil { return nil, err } var tools GiteaEntityTools err = json.Unmarshal(data, &tools) if err != nil { return nil, err } if len(tools) == 0 { return nil, fmt.Errorf("no tools found") } latest, ok := tools.MinimumVersion() if !ok { latest = nightlyActRunner } ret := []commonParams.RunnerApplicationDownload{} for _, asset := range latest.Assets { arch, err := asset.GetArch() if err != nil { slog.InfoContext(ctx, "ignoring unrecognized tools arch", "tool", asset.Name) continue } os, err := asset.GetOS() if err != nil { slog.InfoContext(ctx, "ignoring unrecognized tools os", "tool", asset.Name) continue } if !strings.HasSuffix(asset.DownloadURL, ".xz") { // filter out non compressed versions. continue } ret = append(ret, commonParams.RunnerApplicationDownload{ OS: os, Architecture: arch, DownloadURL: &asset.DownloadURL, Filename: &asset.Name, }) } return ret, nil }