Initial commit

lib/github/upload.go

@@ -0,0 +1,83 @@
+package github
+
+import (
+	"fmt"
+	"os"
+
+	"github.com/google/go-github/v72/github"
+)
+
+func (g *Github) Upload(releaseID int64) error {
+	var assets []*github.ReleaseAsset
+	listOpts := &github.ListOptions{}
+
+	for {
+		asset, resp, err := g.client.Repositories.ListReleaseAssets(
+			g.app.Context(), g.app.Settings().Owner, g.app.Settings().Repo,
+			releaseID, listOpts,
+		)
+		if err != nil {
+			g.app.Logger().WithError(err).Error("Failed to fetch existing assets")
+
+			return err
+		}
+
+		assets = append(assets, asset...)
+
+		if resp.NextPage == 0 {
+			break
+		}
+
+		listOpts.Page = resp.NextPage
+	}
+
+	uploadFiles, err := os.ReadDir(g.app.Settings().Storage)
+	if err != nil {
+		g.app.Logger().WithError(err).Error("Failed to read assets storage")
+	}
+
+	for _, file := range uploadFiles {
+		if !file.IsDir() {
+			for _, asset := range assets {
+				if file.Name() == *asset.Name {
+					g.app.Logger().WithField("name", file.Name()).Error("File exists")
+
+					return fmt.Errorf("file exists: %s", file.Name())
+				}
+			}
+		}
+	}
+
+	for _, file := range uploadFiles {
+		if file.IsDir() {
+			continue
+		}
+
+		fileReader, err := os.Open(
+			fmt.Sprintf("%s/%s", g.app.Settings().Storage, file.Name()),
+		)
+		if err != nil {
+			g.app.Logger().
+				WithError(err).WithField("name", file.Name()).
+				Error("Failed to read artifact")
+
+			return err
+		}
+
+		uploadOptions := &github.UploadOptions{Name: file.Name()}
+
+		if _, _, err = g.client.Repositories.UploadReleaseAsset(
+			g.app.Context(), g.app.Settings().Owner, g.app.Settings().Repo,
+			releaseID, uploadOptions, fileReader); err != nil {
+			g.app.Logger().
+				WithError(err).WithField("name", file.Name()).
+				Error("Failed to upload artifact")
+
+			return err
+		}
+
+		g.app.Logger().WithField("name", file.Name()).Info("Successfully uploaded artifact")
+	}
+
+	return nil
+}