upload/koji: add a simple test

This commit adds a test which uploads a random file to Koji and runs CGImport.
The result is checked using the koji cli client.

internal/upload/koji/README.md

@@ -0,0 +1,22 @@
+## How to run the Koji test
+
+Firstly, you need to start the koji container:
+
+```
+sudo ./internal/upload/koji/run-koji-container.sh
+```
+
+This command starts a kojihub instance available at
+http://localhost:8080/kojihub . You can test that it started successfully
+by running:
+```
+koji --server=http://localhost:8080/kojihub --user=osbuild --password=osbuildpass --authtype=password hello
+```
+
+Now, you can run the koji test using:
+```
+go test -v -tags koji_test ./internal/upload/koji
+```
+
+The test is run on each PR in the Github CI. See `.github/workflows/tests.yml`
+for more details.

internal/upload/koji/koji_test.go

@@ -0,0 +1,132 @@
+//+build koji_test
+
+package koji_test
+
+import (
+	"crypto/rand"
+	"io"
+	"io/ioutil"
+	"os"
+	"os/exec"
+	"strconv"
+	"testing"
+	"time"
+
+	"github.com/google/uuid"
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+
+	"github.com/osbuild/osbuild-composer/internal/upload/koji"
+)
+
+func TestKojiImport(t *testing.T) {
+	// define constants
+	server := "http://localhost:8080/kojihub"
+	user := "osbuild"
+	password := "osbuildpass"
+	filename := "image.qcow2"
+	filesize := 1024
+	// you cannot create two build with a same name, let's create a random one each time
+	buildName := "osbuild-image-" + uuid.Must(uuid.NewRandom()).String()
+	// koji needs to specify a directory to which the upload should happen, let's reuse the build name
+	uploadDirectory := buildName
+
+	// authenticate
+	k, err := koji.New(server)
+	require.NoError(t, err)
+	err = k.Login(user, password)
+	require.NoError(t, err)
+
+	defer func() {
+		err := k.Logout()
+		if err != nil {
+			require.NoError(t, err)
+		}
+	}()
+
+	// Create a random file
+	f, err := ioutil.TempFile("", "osbuild-koji-test-*.qcow2")
+	require.NoError(t, err)
+	defer func() {
+		assert.NoError(t, f.Close())
+		assert.NoError(t, os.Remove(f.Name()))
+	}()
+
+	_, err = io.CopyN(f, rand.Reader, int64(filesize))
+	require.NoError(t, err)
+	_, err = f.Seek(0, io.SeekStart)
+	require.NoError(t, err)
+
+	// Upload the file
+	hash, _, err := k.Upload(f, uploadDirectory, filename)
+	require.NoError(t, err)
+
+	// Import the build
+	build := koji.Build{
+		Name:      buildName,
+		Version:   "1",
+		Release:   "1",
+		StartTime: time.Now().Unix(),
+		EndTime:   time.Now().Unix(),
+	}
+	buildRoots := []koji.BuildRoot{
+		{
+			ID: 1,
+			Host: koji.Host{
+				Os:   "RHEL8",
+				Arch: "noarch",
+			},
+			ContentGenerator: koji.ContentGenerator{
+				Name:    "osbuild",
+				Version: "1",
+			},
+			Container: koji.Container{
+				Type: "nspawn",
+				Arch: "noarch",
+			},
+			Tools:      []koji.Tool{},
+			Components: []koji.Component{},
+		},
+	}
+	output := []koji.Output{
+		{
+			BuildRootID:  1,
+			Filename:     filename,
+			FileSize:     uint64(filesize),
+			Arch:         "noarch",
+			ChecksumType: "md5",
+			MD5:          hash,
+			Type:         "image",
+			Components:   []koji.Component{},
+			Extra: koji.OutputExtra{
+				Image: koji.OutputExtraImageInfo{
+					Arch: "noarch",
+				},
+			},
+		},
+	}
+
+	result, err := k.CGImport(build, buildRoots, output, uploadDirectory)
+	require.NoError(t, err)
+
+	// check if the build is really there:
+	cmd := exec.Command(
+		"koji",
+		"--server", server,
+		"--user", user,
+		"--password", password,
+		"--authtype", "password",
+		"list-builds",
+		"--buildid", strconv.Itoa(result.BuildID),
+	)
+
+	// sample output:
+	// Build                                                    Built by          State
+	// -------------------------------------------------------  ----------------  ----------------
+	// osbuild-image-92882b90-4bd9-4422-8b8a-40863f94535a-1-1   osbuild           COMPLETE
+	out, err := cmd.CombinedOutput()
+	assert.NoError(t, err)
+
+	// let's check for COMPLETE, koji will exit with non-zero status code if the build doesn't exist
+	assert.Contains(t, string(out), "COMPLETE")
+}

internal/upload/koji/run-koji-container.sh

@@ -0,0 +1,43 @@
+#!/bin/bash
+set -eu
+
+if [ $UID != 0 ]; then
+  echo must be run as root
+  exit 1
+fi
+
+clean_up () {
+    EXIT_CODE=$?
+
+    echo "Shutting down containers, please wait..."
+
+    podman stop org.osbuild.koji.koji || true
+    podman rm org.osbuild.koji.koji || true
+
+    podman stop org.osbuild.koji.postgres || true
+    podman rm org.osbuild.koji.postgres || true
+
+    podman network rm -f org.osbuild.koji || true
+
+    exit $EXIT_CODE
+}
+
+trap clean_up EXIT
+
+podman network create org.osbuild.koji
+podman run -d --name org.osbuild.koji.postgres --network org.osbuild.koji \
+  -e POSTGRES_USER=koji \
+  -e POSTGRES_PASSWORD=kojipass \
+  -e POSTGRES_DB=koji \
+  docker.io/library/postgres:12-alpine
+
+podman run -d --name org.osbuild.koji.koji --network org.osbuild.koji \
+  -p 8080:80 \
+  -e POSTGRES_USER=koji \
+  -e POSTGRES_PASSWORD=kojipass \
+  -e POSTGRES_DB=koji \
+  -e POSTGRES_HOST=org.osbuild.koji.postgres \
+  quay.io/osbuild/ghci-koji:rc1
+
+echo "Running, press CTRL+C to stop..."
+sleep infinity