[CU-86b76fmp8] Add Repository interface and unit tests for Check/Get

.github/workflows/test.yaml

@@ -1,5 +1,14 @@
 name: "Unit tests"
 on:
+  push:
+    branches: [main]
+    paths:
+      - 'pkg/**'
+      - 'cmd/**'
+      - 'Dockerfile*'
+      - 'go.mod'
+      - 'go.sum'
+      - '.golangci.yaml'
   pull_request:
     paths:
       - 'pkg/**'
@@ -11,7 +20,7 @@ on:
 
 jobs:
   lint:
-    runs-on: [ default ]
+    runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4
         with:
@@ -26,7 +35,7 @@ jobs:
         run: make lint
 
   build:
-    runs-on: [ default ]
+    runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4
         with:
@@ -38,4 +47,19 @@ jobs:
           go-version-file: 'go.mod'
           token: ${{ secrets.GITHUB_TOKEN }}
       - name: build
-        run: make build
+        run: make build
+
+  test:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 # v4
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Set up Go
+        uses: actions/setup-go@d35c59abb061a4a6fb18e82ac0862c26744d6ab5 # v5
+        with:
+          go-version-file: 'go.mod'
+          token: ${{ secrets.GITHUB_TOKEN }}
+      - name: test
+        run: make test

Makefile

@@ -48,6 +48,10 @@ fmt: goimports
 lint: golint
 	$(GOLINT) run -v --timeout 5m	
 
+.PHONY: test
+test:
+	go test ./...
+
 .PHONY: check
 check: fmt lint
 

cmd/check/main.go

@@ -23,7 +23,14 @@ func main() {
 		fmt.Fprintf(os.Stderr, "invalid source configuration: %s\n", err)
 	}
 
-	resp, err := resource.Check(context.Background(), req)
+	ctx := context.Background()
+	repo, err := resource.NewRepositoryForSource(ctx, req.Source)
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "failed to create repository client: %s\n", err)
+		os.Exit(1)
+	}
+
+	resp, err := resource.Check(ctx, req, repo)
 	if err != nil {
 		fmt.Fprintf(os.Stderr, "invalid source configuration: %s\n", err)
 	}

cmd/in/main.go

@@ -27,7 +27,15 @@ func main() {
 	if err := req.Validate(); err != nil {
 		fmt.Fprintf(os.Stderr, "invalid source configuration: %s\n", err)
 	}
-	response, err := resource.Get(context.Background(), req, outputDir)
+
+	ctx := context.Background()
+	repo, err := resource.NewRepositoryForSource(ctx, req.Source)
+	if err != nil {
+		fmt.Fprintf(os.Stderr, "failed to create repository client: %s\n", err)
+		os.Exit(1)
+	}
+
+	response, err := resource.Get(ctx, req, outputDir, repo)
 	if err != nil {
 		fmt.Fprintf(os.Stderr, "get failed: %s\n", err)
 		os.Exit(1)

pkg/resource/check.go

@@ -12,7 +12,6 @@ import (
 	"github.com/Masterminds/semver/v3"
 	"github.com/pkg/errors"
 	"oras.land/oras-go/v2/registry"
-	"oras.land/oras-go/v2/registry/remote"
 )
 
 type (
@@ -28,12 +27,7 @@ func (cr *CheckRequest) Validate() error {
 	return cr.Source.Validate()
 }
 
-func Check(ctx context.Context, request CheckRequest) (*CheckResponse, error) {
-	repo, err := newRepositoryForSource(ctx, request.Source)
-	if err != nil {
-		return nil, errors.Wrap(err, "failed to create repository client")
-	}
-
+func Check(ctx context.Context, request CheckRequest, repo Repository) (*CheckResponse, error) {
 	// Fetch repository tags
 	allTags, err := registry.Tags(ctx, repo)
 	if err != nil {
@@ -68,7 +62,7 @@ func Check(ctx context.Context, request CheckRequest) (*CheckResponse, error) {
 		return nil, fmt.Errorf("no latest tag found for source %s", request.Source.String())
 	}
 
-	resolvedVersions, err := resolveImageDigests(ctx, sortedSemvers, repo)
+	resolvedVersions, err := resolveImageDigests(ctx, sortedSemvers, repo, request.Source.String())
 	if err != nil {
 		return nil, err
 	}
@@ -93,10 +87,10 @@ func sortBySemver(allTags []string) []semver.Version {
 	return allVersions
 }
 
-func resolveImageDigests(ctx context.Context, sortedSemvers []semver.Version, repo *remote.Repository) (CheckResponse, error) {
+func resolveImageDigests(ctx context.Context, sortedSemvers []semver.Version, repo Repository, source string) (CheckResponse, error) {
 	resolvedVersions := make(CheckResponse, len(sortedSemvers))
 	for i, version := range sortedSemvers {
-		digest, err := getDigestForTag(ctx, repo, version.Original())
+		digest, err := getDigestForTag(ctx, repo, source, version.Original())
 		if err != nil {
 			return nil, errors.Wrap(err, fmt.Sprintf("failed to fetch digest for latest tag %q (parsed as %s)", version.Original(), version.String()))
 		}