Skip to content

Commit

Permalink
Fixes for generating data.json
Browse files Browse the repository at this point in the history
- remove rke2/k3s keys so data only has required info for rke1
- decide kdm url based on the tag version
  • Loading branch information
kinarashah authored and jiaqiluo committed Oct 21, 2024
1 parent 0ea51f9 commit e1f3686
Show file tree
Hide file tree
Showing 3 changed files with 107 additions and 7 deletions.
1 change: 1 addition & 0 deletions .github/workflows/workflow.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,7 @@ jobs:
ls -lR build/bin
env:
CROSS: 1
TAG: ${{ startsWith(github.ref, 'refs/tags/') && github.ref_name || '' }}
- name: Generate sha256 file for release
if: github.event_name == 'push' && github.ref_type == 'tag'
run: |
Expand Down
47 changes: 40 additions & 7 deletions codegen/codegen.go
Original file line number Diff line number Diff line change
@@ -1,25 +1,27 @@
package main

import (
"encoding/json"
"fmt"
"io"
"net/http"
"os"
"strings"

"github.com/coreos/go-semver/semver"
"github.com/rancher/rke/metadata"
)

const (
defaultURL = "https://releases.rancher.com/kontainer-driver-metadata/dev-v2.7/data.json"
dataFile = "data/data.json"
defaultDevURL = "https://releases.rancher.com/kontainer-driver-metadata/dev-v2.7/data.json"
defaultReleaseURL = "https://releases.rancher.com/kontainer-driver-metadata/release-v2.7/data.json"
dataFile = "data/data.json"
)

// Codegen fetch data.json from https://releases.rancher.com/kontainer-driver-metadata/release-v2.7/data.json and generates bindata
// Codegen fetch data.json from defaultURL or defaultReleaseURL and generates bindata
func main() {
u := os.Getenv(metadata.RancherMetadataURLEnv)
if u == "" {
u = defaultURL
}
u := getURL()
fmt.Printf("Reading data from %s \n", u)
data, err := http.Get(u)
if err != nil {
panic(fmt.Errorf("failed to fetch data.json from kontainer-driver-metadata repository"))
Expand All @@ -31,8 +33,39 @@ func main() {
panic(err)
}

var jsonData map[string]interface{}
err = json.Unmarshal(b, &jsonData)
if err != nil {
panic(fmt.Errorf("failed to parse JSON: %v", err))
}
// rke doesn't need info about rke2 and k3s versions
delete(jsonData, "rke2")
delete(jsonData, "k3s")

b, err = json.Marshal(jsonData)
if err != nil {
panic(fmt.Errorf("failed to marshal json data: %v", err))
}

fmt.Println("Writing data")
if err := os.WriteFile(dataFile, b, 0755); err != nil {
return
}
}

func getURL() string {
u := os.Getenv(metadata.RancherMetadataURLEnv)
if u == "" {
u = defaultDevURL
tag := os.Getenv("TAG")
if strings.HasPrefix(tag, "v") {
tag = tag[1:]
}
if v, err := semver.NewVersion(tag); err == nil {
if v.PreRelease == "" && v.String() != "" {
u = defaultReleaseURL
}
}
}
return u
}
66 changes: 66 additions & 0 deletions codegen/codegen_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,66 @@
package main

import (
"os"
"testing"

"github.com/rancher/rke/metadata"
)

func TestGetURL(t *testing.T) {
tests := []struct {
name string
envVar string
tag string
expectedURL string
}{
{
name: "No Metadata URL and TAG is release version",
envVar: "",
tag: "v1.0.0",
expectedURL: defaultReleaseURL,
},
{
name: "No Metadata URL and TAG is pre-release version",
envVar: "",
tag: "v1.0.0-alpha",
expectedURL: defaultDevURL,
},
{
name: "Metadata URL set",
envVar: "https://example.com",
tag: "v1.0.0",
expectedURL: "https://example.com",
},
{
name: "Invalid TAG",
envVar: "",
tag: "invalid-tag",
expectedURL: defaultDevURL,
},
{
name: "No TAG",
envVar: "",
tag: "",
expectedURL: defaultDevURL,
},
}

for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
// Set the environment variables
os.Setenv(metadata.RancherMetadataURLEnv, tt.envVar)
os.Setenv("TAG", tt.tag)
defer func() {
os.Unsetenv(metadata.RancherMetadataURLEnv)
os.Unsetenv("TAG")
}()

result := getURL()

if result != tt.expectedURL {
t.Errorf("expected %s, got %s", tt.expectedURL, result)
}
})
}
}

0 comments on commit e1f3686

Please sign in to comment.