Archive repositories

Author: CarlosMecha

operations/README.md

@@ -49,6 +49,17 @@ Options:
 - `--monorepoPath=<string>`: Local path where the monorepo lives. Default to `.`.
 - `--tmpPath=<string>`: Temporal folder. Default to `/tmp/integrations`.
 
+## archive-integration-repository
+
+Archives the repository of the integration:
+1. Removes all webhooks.
+1. Archives the repository.
+
+Options:
+- `--verbose`
+- `--integration=<name>`
+- `--tmpPath=<string>`: Temporal folder. Default to `/tmp/integrations`.
+
 ## libgit2
 
 Install libgit2 v27 following [this script](ci/install-libgit2). This is also required

operations/cmd/archive-integration-repository/main.go

@@ -0,0 +1,45 @@
+package main
+
+import (
+	"flag"
+	"os"
+	"path"
+
+	"github.com/segmentio/analytics.js-integrations/operations"
+)
+
+const organization = "segment-integrations"
+
+var integrationName string
+var tmpPath string
+
+func init() {
+	flag.BoolVar(&operations.Verbose, "verbose", false, "prints more stuff")
+	flag.StringVar(&integrationName, "integration", "", "integration name")
+	flag.StringVar(&tmpPath, "tmpPath", "/tmp/integrations", "path where the integration code is going to be stored")
+}
+
+func main() {
+
+	operations.GetAuthToken()
+
+	flag.Parse()
+	if integrationName == "" {
+		operations.Log("No integration provided")
+		flag.Usage()
+		os.Exit(1)
+	}
+
+	github := operations.NewGitHubClient()
+	integration, err := operations.OpenIntegrationRepo(github, organization, integrationName, path.Join(tmpPath, integrationName))
+	if err != nil {
+		os.Exit(1)
+	}
+
+	operations.Log("Archiving %s", integration.RepositoryName)
+
+	if err := integration.Archive(github); err != nil {
+		os.Exit(1)
+	}
+
+}

operations/github.go

@@ -567,3 +567,40 @@ func (g *GitHub) UpdateTopics(topics []string, project Project) error {
 
 	return nil
 }
+
+// DeleteAllWebHooks retrieves and deletes all webhooks for the project
+func (g *GitHub) DeleteAllWebHooks(project Project) error {
+	ops := github.ListOptions{PerPage: 50}
+	hooks, _, err := g.V3.Repositories.ListHooks(context.Background(), project.Organization, project.RepositoryName, &ops)
+	if err != nil {
+		LogError(err, "Error listing hooks")
+		return err
+	}
+
+	for _, hook := range hooks {
+		if _, err := g.V3.Repositories.DeleteHook(context.Background(), project.Organization, project.RepositoryName, *hook.ID); err != nil {
+			LogError(err, "Error removing hook %d", *hook.ID)
+			return err
+		}
+	}
+
+	return nil
+}
+
+// ArchiveRepository patches the repo and archives it
+func (g *GitHub) ArchiveRepository(project Project) error {
+	if project.IsArchived {
+		return nil
+	}
+
+	repo := github.Repository{
+		Archived: github.Bool(true),
+	}
+
+	if _, _, err := g.V3.Repositories.Edit(context.Background(), project.Organization, project.RepositoryName, &repo); err != nil {
+		LogError(err, "Error archiving repository %s", project.RepositoryName)
+		return err
+	}
+
+	return nil
+}

operations/integrationrepo.go

@@ -1,6 +1,7 @@
 package operations
 
 import (
+	"errors"
 	"fmt"
 	"io/ioutil"
 	"path"
@@ -417,3 +418,22 @@ func (i *IntegrationRepo) updateIssueTemplate(monorepo Monorepo) error {
 
 	return writeFileWithTemplate(file, i.issueTmpl, info)
 }
+
+// Archive archives the repo and removes webhooks.
+func (i *IntegrationRepo) Archive(github *GitHub) error {
+	if i.IsArchived {
+		return nil
+	}
+
+	if !i.IsMigrated() {
+		err := errors.New("The integration has not been migrated. Migrate the integration and then archive the repository")
+		LogError(err, "Unable to archive %s", i.Name)
+		return err
+	}
+
+	if err := github.DeleteAllWebHooks(i.Project); err != nil {
+		return err
+	}
+
+	return github.ArchiveRepository(i.Project)
+}