forked from openshift/origin
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
WIP: add --coreos-url to
oc adm release new
For RHCOS we have two things: - The "bootimage" (AMI, qcow2, PXE env) - The "oscontainer", now represented as `machine-os-content` in the payload For initial OpenShift releases (e.g. of the installer) ideally these are the same (i.e. we don't upgrade OS on boot). This PR aims to support injecting both data into the release payload. More information on the "bootimage" and its consumption by the installer as well as the Machine API Operator: openshift/installer#987 More information on `machine-os-content`: openshift/machine-config-operator#183
- Loading branch information
Showing
2 changed files
with
144 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,105 @@ | ||
| package release | ||
|
|
||
| // This package parses the HTTP API effectively | ||
| // created by https://github.com/coreos/coreos-assembler | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/json" | ||
| "fmt" | ||
| "io/ioutil" | ||
| "net/http" | ||
|
|
||
| "github.com/pkg/errors" | ||
| ) | ||
|
|
||
| // BuildMeta is a partial deserialization of the `meta.json` generated | ||
| // by coreos-assembler for a build. | ||
| type BuildMeta struct { | ||
| AMIs []struct { | ||
| HVM string `json:"hvm"` | ||
| Name string `json:"name"` | ||
| } `json:"amis"` | ||
| BuildID string `json:"buildid"` | ||
| Images struct { | ||
| QEMU struct { | ||
| Path string `json:"path"` | ||
| SHA256 string `json:"sha256"` | ||
| } `json:"qemu"` | ||
| } `json:"images"` | ||
| OSTreeVersion string `json:"ostree-version"` | ||
| OSContainer struct { | ||
| Digest string `json:"digest"` | ||
| Image string `json:"image"` | ||
| } `json:"oscontainer"` | ||
| } | ||
|
|
||
| // httpGetAll downloads a URL and gives you a byte array. | ||
| func httpGetAll(ctx context.Context, url string) ([]byte, error) { | ||
| var body []byte | ||
| req, err := http.NewRequest("GET", url, nil) | ||
| if err != nil { | ||
| return body, errors.Wrap(err, "failed to build request") | ||
| } | ||
|
|
||
| client := &http.Client{} | ||
| resp, err := client.Do(req.WithContext(ctx)) | ||
| if err != nil { | ||
| return body, errors.Wrapf(err, "failed to fetch %s", url) | ||
| } | ||
| defer resp.Body.Close() | ||
|
|
||
| if resp.StatusCode != http.StatusOK { | ||
| return body, errors.Errorf("fetching %s status %s", url, resp.Status) | ||
| } | ||
|
|
||
| body, err = ioutil.ReadAll(resp.Body) | ||
| if err != nil { | ||
| return body, errors.Wrap(err, "failed to read HTTP response") | ||
| } | ||
|
|
||
| return body, nil | ||
| } | ||
|
|
||
| // getLatestBuildVersion returns the latest CoreOS build version number | ||
| func getLatestBuildVersion(ctx context.Context, baseURL string) (string, error) { | ||
| var builds struct { | ||
| Builds []string `json:"builds"` | ||
| } | ||
| buildsBuf, err := httpGetAll(ctx, baseURL + "/builds.json") | ||
| if err != nil { | ||
| return "", err | ||
| } | ||
| if err := json.Unmarshal(buildsBuf, &builds); err != nil { | ||
| return "", errors.Wrap(err, "failed to parse HTTP response") | ||
| } | ||
|
|
||
| if len(builds.Builds) == 0 { | ||
| return "", errors.Errorf("no builds found") | ||
| } | ||
|
|
||
| return builds.Builds[0], nil | ||
| } | ||
|
|
||
| // GetLatest returns the CoreOS build with target version. If version | ||
| // is the empty string, the latest will be used. | ||
| func GetCoreOSBuild(ctx context.Context, baseURL string, version string) (*BuildMeta, error) { | ||
| var err error | ||
| if version == "" { | ||
| version, err = getLatestBuildVersion(ctx, baseURL) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| } | ||
| buildUrl := fmt.Sprintf("%s/%s/meta.json", baseURL, version) | ||
| buildStr, err := httpGetAll(ctx, buildUrl) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| var build BuildMeta | ||
| if err := json.Unmarshal(buildStr, &build); err != nil { | ||
| return nil, errors.Wrap(err, "failed to parse HTTP response") | ||
| } | ||
| return &build, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters