130 lines
3.1 KiB
Go
130 lines
3.1 KiB
Go
package updater
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"fmt"
|
|
"io"
|
|
"net/http"
|
|
"os"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/evcc-io/evcc/util"
|
|
"github.com/evcc-io/evcc/util/request"
|
|
"github.com/google/go-github/v32/github"
|
|
"github.com/hashicorp/go-version"
|
|
"golang.org/x/oauth2"
|
|
)
|
|
|
|
const (
|
|
owner = "evcc-io"
|
|
repository = "evcc"
|
|
|
|
timeout = 30 * time.Second
|
|
)
|
|
|
|
// Repo is a github repository adapter
|
|
type Repo struct {
|
|
owner, repository string
|
|
*github.Client
|
|
}
|
|
|
|
// NewRepo creates repository adapter
|
|
func NewRepo(log *util.Logger, owner, repository string) *Repo {
|
|
client := request.NewClient(log)
|
|
|
|
if token := os.Getenv("GITHUB_TOKEN"); token != "" {
|
|
ctx := context.WithValue(context.Background(), oauth2.HTTPClient, client)
|
|
client = oauth2.NewClient(ctx, oauth2.StaticTokenSource(&oauth2.Token{
|
|
AccessToken: token,
|
|
}))
|
|
}
|
|
|
|
r := &Repo{
|
|
owner: owner,
|
|
repository: repository,
|
|
Client: github.NewClient(client),
|
|
}
|
|
|
|
return r
|
|
}
|
|
|
|
// GetLatestRelease gets latest of github releases
|
|
func (r *Repo) GetLatestRelease() (*github.RepositoryRelease, error) {
|
|
ctx, cancel := context.WithTimeout(context.Background(), timeout)
|
|
defer cancel()
|
|
|
|
release, _, err := r.Repositories.GetLatestRelease(ctx, r.owner, r.repository)
|
|
return release, err
|
|
}
|
|
|
|
// ReleaseNotes returns github release notes for the (from,to] semver interval
|
|
func (r *Repo) ReleaseNotes(from string) (rendered string, err error) {
|
|
ctx, cancel := context.WithTimeout(context.Background(), timeout)
|
|
defer cancel()
|
|
|
|
var fromVersion *version.Version
|
|
if fromVersion, err = version.NewVersion(from); err != nil {
|
|
return
|
|
}
|
|
|
|
releases, _, err := r.Repositories.ListReleases(ctx, r.owner, r.repository, nil)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
history := bytes.NewBuffer([]byte{})
|
|
for _, rel := range releases {
|
|
tag := *rel.TagName
|
|
|
|
var ver *version.Version
|
|
if ver, err = version.NewVersion(tag); err != nil {
|
|
return
|
|
}
|
|
|
|
if ver.LessThanOrEqual(fromVersion) {
|
|
continue
|
|
}
|
|
|
|
if notes := strings.TrimSpace(rel.GetBody()); notes != "" {
|
|
var md string
|
|
if md, _, err = r.Markdown(context.Background(), notes, &github.MarkdownOptions{
|
|
Mode: "gfm",
|
|
Context: fmt.Sprintf("%s/%s", r.owner, r.repository),
|
|
}); err != nil {
|
|
return
|
|
}
|
|
|
|
history.WriteString(fmt.Sprintf("<h1>%s</h1>\n", tag))
|
|
history.WriteString(md)
|
|
}
|
|
}
|
|
|
|
return history.String(), nil
|
|
}
|
|
|
|
// FindReleaseAsset finds asset by name and returns ID and size
|
|
func (r *Repo) FindReleaseAsset(name string) (int64, int, error) {
|
|
ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
|
|
defer cancel()
|
|
|
|
rel, _, err := r.Repositories.GetLatestRelease(ctx, r.owner, r.repository)
|
|
if err != nil {
|
|
return 0, 0, err
|
|
}
|
|
|
|
for _, a := range rel.Assets {
|
|
if *a.Name == name {
|
|
return *a.ID, *a.Size, nil
|
|
}
|
|
}
|
|
|
|
return 0, 0, fmt.Errorf("asset not found: %s", name)
|
|
}
|
|
|
|
// StreamAsset provides a ReadCloser for streaming the assets over HTTP
|
|
func (r *Repo) StreamAsset(id int64) (io.ReadCloser, error) {
|
|
rc, _, err := r.Repositories.DownloadReleaseAsset(context.Background(), r.owner, r.repository, id, http.DefaultClient)
|
|
return rc, err
|
|
}
|