You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
132 lines
3.2 KiB
132 lines
3.2 KiB
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
"path"
|
|
|
|
"code.gitea.io/sdk/gitea"
|
|
)
|
|
|
|
// Release holds ties the drone env data and gitea client together.
|
|
type releaseClient struct {
|
|
*gitea.Client
|
|
Owner string
|
|
Repo string
|
|
Tag string
|
|
Draft bool
|
|
Prerelease bool
|
|
FileExists string
|
|
Title string
|
|
Note string
|
|
}
|
|
|
|
func (rc *releaseClient) buildRelease() (*gitea.Release, error) {
|
|
// first attempt to get a release by that tag
|
|
release, err := rc.getRelease()
|
|
|
|
if err != nil && release == nil {
|
|
fmt.Println(err)
|
|
} else if release != nil {
|
|
return release, nil
|
|
}
|
|
|
|
// if no release was found by that tag, create a new one
|
|
release, err = rc.newRelease()
|
|
|
|
if err != nil {
|
|
return nil, fmt.Errorf("Failed to retrieve or create a release: %s", err)
|
|
}
|
|
|
|
return release, nil
|
|
}
|
|
|
|
func (rc *releaseClient) getRelease() (*gitea.Release, error) {
|
|
releases, err := rc.Client.ListReleases(rc.Owner, rc.Repo)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
for _, release := range releases {
|
|
if release.TagName == rc.Tag {
|
|
fmt.Printf("Successfully retrieved %s release\n", rc.Tag)
|
|
return release, nil
|
|
}
|
|
}
|
|
return nil, fmt.Errorf("Release %s not found", rc.Tag)
|
|
}
|
|
|
|
func (rc *releaseClient) newRelease() (*gitea.Release, error) {
|
|
r := gitea.CreateReleaseOption{
|
|
TagName: rc.Tag,
|
|
IsDraft: rc.Draft,
|
|
IsPrerelease: rc.Prerelease,
|
|
Title: rc.Title,
|
|
Note: rc.Note,
|
|
}
|
|
|
|
release, err := rc.Client.CreateRelease(rc.Owner, rc.Repo, r)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("Failed to create release: %s", err)
|
|
}
|
|
|
|
fmt.Printf("Successfully created %s release\n", rc.Tag)
|
|
return release, nil
|
|
}
|
|
|
|
func (rc *releaseClient) uploadFiles(releaseID int64, files []string) error {
|
|
attachments, err := rc.Client.ListReleaseAttachments(rc.Owner, rc.Repo, releaseID)
|
|
|
|
if err != nil {
|
|
return fmt.Errorf("Failed to fetch existing assets: %s", err)
|
|
}
|
|
|
|
var uploadFiles []string
|
|
|
|
files:
|
|
for _, file := range files {
|
|
for _, attachment := range attachments {
|
|
if attachment.Name == path.Base(file) {
|
|
switch rc.FileExists {
|
|
case "overwrite":
|
|
// do nothing
|
|
case "fail":
|
|
return fmt.Errorf("Asset file %s already exists", path.Base(file))
|
|
case "skip":
|
|
fmt.Printf("Skipping pre-existing %s artifact\n", attachment.Name)
|
|
continue files
|
|
default:
|
|
return fmt.Errorf("Internal error, unkown file_exist value %s", rc.FileExists)
|
|
}
|
|
}
|
|
}
|
|
|
|
uploadFiles = append(uploadFiles, file)
|
|
}
|
|
|
|
for _, file := range uploadFiles {
|
|
handle, err := os.Open(file)
|
|
|
|
if err != nil {
|
|
return fmt.Errorf("Failed to read %s artifact: %s", file, err)
|
|
}
|
|
|
|
for _, attachment := range attachments {
|
|
if attachment.Name == path.Base(file) {
|
|
if err := rc.Client.DeleteReleaseAttachment(rc.Owner, rc.Repo, releaseID, attachment.ID); err != nil {
|
|
return fmt.Errorf("Failed to delete %s artifact: %s", file, err)
|
|
}
|
|
|
|
fmt.Printf("Successfully deleted old %s artifact\n", attachment.Name)
|
|
}
|
|
}
|
|
|
|
if _, err = rc.Client.CreateReleaseAttachment(rc.Owner, rc.Repo, releaseID, handle, path.Base(file)); err != nil {
|
|
return fmt.Errorf("Failed to upload %s artifact: %s", file, err)
|
|
}
|
|
|
|
fmt.Printf("Successfully uploaded %s artifact\n", file)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|