2020-05-19 14:41:16 +03:00

232 lines
5.8 KiB
Go

package main
import (
"context"
"encoding/json"
"errors"
"fmt"
"log"
"os"
"strconv"
"strings"
"github.com/shurcooL/githubv4"
"golang.org/x/oauth2"
)
func main() {
if err := generate(context.Background()); err != nil {
log.Fatal(err)
}
}
func generate(ctx context.Context) error {
allReleases, err := fetchAllReleases(ctx)
if err != nil {
return fmt.Errorf("failed to fetch all releases: %w", err)
}
cfg, err := buildConfig(allReleases)
if err != nil {
return fmt.Errorf("failed to build config: %w", err)
}
if len(os.Args) != 2 { //nolint:gomnd
return fmt.Errorf("usage: go run .../main.go out-path.json")
}
outFile, err := os.Create(os.Args[1])
if err != nil {
return fmt.Errorf("failed to create output config file: %w", err)
}
defer outFile.Close()
enc := json.NewEncoder(outFile)
enc.SetIndent("", " ")
if err = enc.Encode(cfg); err != nil {
return fmt.Errorf("failed to json encode config: %w", err)
}
return nil
}
type logInfo struct {
Warning string `json:",omitempty"`
Info string `json:",omitempty"`
}
type versionConfig struct {
Error string `json:",omitempty"`
Log *logInfo `json:",omitempty"`
TargetVersion string `json:",omitempty"`
AssetURL string `json:",omitempty"`
}
type actionConfig struct {
MinorVersionToConfig map[string]versionConfig
}
type version struct {
major, minor, patch int
}
func (v version) String() string {
ret := fmt.Sprintf("v%d.%d", v.major, v.minor)
if v.patch != noPatch {
ret += fmt.Sprintf(".%d", v.patch)
}
return ret
}
func (v *version) isAfterOrEq(vv *version) bool {
if v.major != vv.major {
return v.major >= vv.major
}
if v.minor != vv.minor {
return v.minor >= vv.minor
}
return v.patch >= vv.patch
}
const noPatch = -1
func parseVersion(s string) (*version, error) {
const vPrefix = "v"
if !strings.HasPrefix(s, vPrefix) {
return nil, fmt.Errorf("version should start with %q", vPrefix)
}
s = strings.TrimPrefix(s, vPrefix)
parts := strings.Split(s, ".")
var nums []int
for _, part := range parts {
num, err := strconv.Atoi(part)
if err != nil {
return nil, fmt.Errorf("failed to parse version part: %w", err)
}
nums = append(nums, num)
}
if len(nums) == 2 { //nolint:gomnd
return &version{major: nums[0], minor: nums[1], patch: noPatch}, nil
}
if len(nums) == 3 { //nolint:gomnd
return &version{major: nums[0], minor: nums[1], patch: nums[2]}, nil
}
return nil, errors.New("invalid version format")
}
func findLinuxAssetURL(ver *version, releaseAssets []releaseAsset) (string, error) {
pattern := fmt.Sprintf("golangci-lint-%d.%d.%d-linux-amd64.tar.gz", ver.major, ver.minor, ver.patch)
for _, relAsset := range releaseAssets {
if strings.HasSuffix(relAsset.DownloadURL, pattern) {
return relAsset.DownloadURL, nil
}
}
return "", fmt.Errorf("no matched asset url for pattern %q", pattern)
}
func buildConfig(releases []release) (*actionConfig, error) {
versionToRelease := map[version]release{}
for _, rel := range releases {
ver, err := parseVersion(rel.TagName)
if err != nil {
return nil, fmt.Errorf("failed to parse release %s version: %w", rel.TagName, err)
}
if _, ok := versionToRelease[*ver]; ok {
return nil, fmt.Errorf("duplicate release %s", rel.TagName)
}
versionToRelease[*ver] = rel
}
maxPatchReleases := map[string]version{}
for ver := range versionToRelease {
key := fmt.Sprintf("v%d.%d", ver.major, ver.minor)
if mapVer, ok := maxPatchReleases[key]; !ok || ver.isAfterOrEq(&mapVer) {
maxPatchReleases[key] = ver
}
}
minorVersionToConfig := map[string]versionConfig{}
minAllowedVersion := version{major: 1, minor: 14, patch: 0}
for minorVersionedStr, maxPatchVersion := range maxPatchReleases {
if !maxPatchVersion.isAfterOrEq(&minAllowedVersion) {
minorVersionToConfig[minorVersionedStr] = versionConfig{
Error: fmt.Sprintf("golangci-lint version '%s' isn't supported: we support only %s and later versions",
minorVersionedStr, minAllowedVersion),
}
continue
}
maxPatchVersion := maxPatchVersion
assetURL, err := findLinuxAssetURL(&maxPatchVersion, versionToRelease[maxPatchVersion].ReleaseAssets.Nodes)
if err != nil {
return nil, fmt.Errorf("failed to find linux asset url for release %s: %w", maxPatchVersion, err)
}
minorVersionToConfig[minorVersionedStr] = versionConfig{
TargetVersion: maxPatchVersion.String(),
AssetURL: assetURL,
}
}
return &actionConfig{MinorVersionToConfig: minorVersionToConfig}, nil
}
type release struct {
TagName string
ReleaseAssets struct {
Nodes []releaseAsset
} `graphql:"releaseAssets(first: 50)"`
}
type releaseAsset struct {
DownloadURL string
}
func fetchAllReleases(ctx context.Context) ([]release, error) {
githubToken := os.Getenv("GITHUB_TOKEN")
if githubToken == "" {
return nil, errors.New("no GITHUB_TOKEN environment variable")
}
src := oauth2.StaticTokenSource(&oauth2.Token{AccessToken: githubToken})
httpClient := oauth2.NewClient(ctx, src)
client := githubv4.NewClient(httpClient)
var q struct {
Repository struct {
Releases struct {
Nodes []release
PageInfo struct {
EndCursor githubv4.String
HasNextPage bool
}
} `graphql:"releases(first: 100, after: $releasesCursor)"`
} `graphql:"repository(owner: $owner, name: $name)"`
}
vars := map[string]interface{}{
"owner": githubv4.String("golangci"),
"name": githubv4.String("golangci-lint"),
"releasesCursor": (*githubv4.String)(nil),
}
var allReleases []release
for {
err := client.Query(ctx, &q, vars)
if err != nil {
return nil, fmt.Errorf("failed to fetch releases page from github: %w", err)
}
releases := q.Repository.Releases
allReleases = append(allReleases, releases.Nodes...)
if !releases.PageInfo.HasNextPage {
break
}
vars["releasesCursor"] = githubv4.NewString(releases.PageInfo.EndCursor)
}
return allReleases, nil
}