with gitea server

internal/gitproviders/gitea.go

@@ -0,0 +1,66 @@
+package gitproviders
+
+import (
+	"context"
+	"fmt"
+	"sync"
+
+	"code.gitea.io/sdk/gitea"
+	"go.uber.org/zap"
+)
+
+type Gitea struct {
+	logger       *zap.Logger
+	giteamu      sync.Mutex
+	giteaClients map[string]*gitea.Client
+}
+
+func NewGitea(logger *zap.Logger) *Gitea {
+	return &Gitea{
+		logger: logger,
+	}
+}
+
+func (g *Gitea) ListRepositoriesForOrganization(ctx context.Context, server string, organization string) ([]string, error) {
+	client, err := g.getOrCreateClient(ctx, server)
+	if err != nil {
+		return nil, err
+	}
+
+	repos, resp, err := client.ListOrgRepos(organization, gitea.ListOrgReposOptions{
+		ListOptions: gitea.ListOptions{
+			Page:     0,
+			PageSize: 0,
+		},
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	if resp.StatusCode >= 300 {
+		return nil, fmt.Errorf("gitea responded with a non 200 status code (gitea response: %s)", resp.Status)
+	}
+
+	repoUrls := make([]string, len(repos))
+	for i, repo := range repos {
+		repoUrls[i] = repo.SSHURL
+	}
+
+	return repoUrls, err
+}
+
+func (g *Gitea) getOrCreateClient(ctx context.Context, server string) (*gitea.Client, error) {
+	g.giteamu.Lock()
+	defer g.giteamu.Unlock()
+	client, ok := g.giteaClients[server]
+	if !ok {
+		c, err := gitea.NewClient(server)
+		if err != nil {
+			return nil, nil
+		}
+		g.giteaClients[server] = c
+		return c, nil
+	}
+
+	return client, nil
+}