Merge pull request #2 from mona-actions/amenocal/diff-releases

Feat: skips existing releases, adds source timestamps

.gitignore

@@ -10,6 +10,7 @@
 *.tar.gz
 *.zip
 *.json
+/tmp
 
 # Test binary, built with `go test -c`
 *.test

internal/api/api.go

@@ -176,7 +176,11 @@ func CreateRelease(release *github.RepositoryRelease) (*github.RepositoryRelease
 	ctx := context.WithValue(context.Background(), github.SleepUntilPrimaryRateLimitResetWhenRateLimited, true)
 	newRelease, _, err := client.Repositories.CreateRelease(ctx, viper.Get("TARGET_ORGANIZATION").(string), viper.Get("REPOSITORY").(string), release)
 	if err != nil {
-		return nil, err
+		if strings.Contains(err.Error(), "already_exists") {
+			return nil, fmt.Errorf("release already exists: %v", release.GetName())
+		} else {
+			return nil, err
+		}
 	}
 
 	return newRelease, nil

internal/mapping/mapping.go

@@ -5,6 +5,7 @@ import (
 	"os"
 	"strings"
 
+	"github.com/google/go-github/v62/github"
 	"github.com/spf13/viper"
 )
 
@@ -56,3 +57,18 @@ func ModifyReleaseBody(releaseBody *string, filePath string) (*string, error) {
 
 	return &updatedReleaseBody, nil
 }
+
+func AddSourceTimeStamps(release *github.RepositoryRelease) (*github.RepositoryRelease, error) {
+	releaseBody := *release.Body
+
+	// Format the timestamps
+	createdAt := release.CreatedAt.Format("January 2, 2006 at 15:04:05 CST")
+	publishedAt := release.PublishedAt.Format("January 2, 2006 at 15:04:05 CST")
+
+	// Add source timestamps to release body
+	releaseBody = releaseBody + "\n\n" + ">Release Originally Created on: " + createdAt + "\n" + "> Release Originally Published on: " + publishedAt
+
+	release.Body = &releaseBody
+
+	return release, nil
+}

pkg/sync/sync.go

@@ -1,6 +1,8 @@
 package sync
 
 import (
+	"strings"
+
 	"github.com/mona-actions/gh-migrate-releases/internal/api"
 	"github.com/mona-actions/gh-migrate-releases/internal/mapping"
 	"github.com/pterm/pterm"
@@ -9,33 +11,42 @@ import (
 
 func SyncReleases() {
 	// Get all releases from source repository
-	fetchReleasesSpinner, _ := pterm.DefaultSpinner.Start("Fetching releases from repository...")
+	fetchReleasesSpinner, _ := pterm.DefaultSpinner.Start("Fetching releases from repository: ", viper.GetString("REPOSITORY"))
 	releases, err := api.GetSourceRepositoryReleases()
 	if err != nil {
 		pterm.Error.Printf("Error getting releases: %v", err)
 		fetchReleasesSpinner.Fail()
 	}
+	fetchReleasesSpinner.UpdateText("Releases fetched successfully!")
 	fetchReleasesSpinner.Success()
 
 	// Create releases in target repository
-	createReleasesSpinner, _ := pterm.DefaultSpinner.Start("Creating releases in target repository...")
+	createReleasesSpinner, _ := pterm.DefaultSpinner.Start("Creating releases in target repository...", viper.GetString("REPOSITORY"))
 
 	//loop through each release and create it in the target repository
 	for _, release := range releases {
 		createReleasesSpinner.UpdateText("Creating release: " + release.GetName())
 
 		// Modify release body to map new handles and map old urls to new urls
+		release, err := mapping.AddSourceTimeStamps(release)
+		if err != nil {
+			pterm.Warning.Printf("Error adding source timestamps: %v", err)
+		}
 		release.Body, err = mapping.ModifyReleaseBody(release.Body, viper.GetString("MAPPING_FILE"))
 		if err != nil {
-			pterm.Error.Printf("Error modifying release body: %v", err)
+			pterm.Warning.Printf("Error modifying release body: %v", err)
 		}
 		// Create release api call
 		newRelease, err := api.CreateRelease(release)
 		if err != nil {
-			createReleasesSpinner.Fail()
-			pterm.Fatal.Printf("Error creating release: %v", err)
+			if strings.Contains(err.Error(), "already exists") {
+				pterm.Info.Printf("Release already exists: %v... skipping", release.GetName())
+				continue
+			} else {
+				createReleasesSpinner.Fail()
+				pterm.Fatal.Printf("Error creating release: %v", err)
+			}
 		}
-		createReleasesSpinner.UpdateText("Downloading assets...")
 		// Download assets from source repository and upload to target repository
 		for _, asset := range release.Assets {