magefile.publish.go

// +build mage

package main

import (
	"fmt"
	"os"
	"os/exec"
	"path/filepath"
)

const distPath = "dist"

const packageName = "cartridge-cli"

type Distro struct {
	OS   string
	Dist string
}

var targetDistros = []Distro{
	{OS: "el", Dist: "7"},
	{OS: "el", Dist: "8"},
	{OS: "fedora", Dist: "30"},
	{OS: "fedora", Dist: "31"},
	{OS: "fedora", Dist: "32"},
	{OS: "fedora", Dist: "33"},
	{OS: "fedora", Dist: "34"},
	{OS: "fedora", Dist: "35"},
	{OS: "fedora", Dist: "36"},

	{OS: "ubuntu", Dist: "xenial"},
	{OS: "ubuntu", Dist: "bionic"},
	{OS: "ubuntu", Dist: "eoan"},
	{OS: "ubuntu", Dist: "focal"},
	{OS: "ubuntu", Dist: "hirsute"},
	{OS: "ubuntu", Dist: "impish"},
	{OS: "ubuntu", Dist: "jammy"},

	{OS: "debian", Dist: "stretch"},
	{OS: "debian", Dist: "buster"},
	{OS: "debian", Dist: "bullseye"},
}

// walkMatch walks through directory and collects file paths satisfying patterns.
func walkMatch(root string, patterns []string) ([]string, error) {
	var matches []string

	err := filepath.Walk(root, func(path string, info os.FileInfo, err error) error {
		if err != nil {
			return err
		}

		if info.IsDir() {
			return nil
		}

		for _, pattern := range patterns {
			if matched, err := filepath.Match(pattern, filepath.Base(path)); err != nil {
				return err
			} else if matched {
				matches = append(matches, path)
				return nil
			}
		}

		return nil
	})

	if err != nil {
		return nil, err
	}

	return matches, nil
}

// getPatterns returns patterns to select goreleaser build artifacts.
// Based on update_repo.sh with some modifications.
// See https://github.com/tarantool/tarantool/blob/c9e3926e5ae82785c5eb494521c44ba522109e95/tools/update_repo.sh#L517
// and https://github.com/tarantool/tarantool/blob/c9e3926e5ae82785c5eb494521c44ba522109e95/tools/update_repo.sh#L986
func getPatterns(distro Distro) ([]string, error) {

	if distro.OS == "el" || distro.OS == "fedora" {
		return []string{"*.x86_64.rpm", "*.noarch.rpm"}, nil
	}

	if distro.OS == "ubuntu" || distro.OS == "debian" {
		return []string{"*.deb", "*.dsc"}, nil
	}

	return nil, fmt.Errorf("Unknown OS: %s", distro.OS)
}

func PublishRWS() error {
	fmt.Printf("Publish packages to RWS...\n")

	for _, targetDistro := range targetDistros {
		fmt.Printf("Publish package for %s/%s...\n", targetDistro.OS, targetDistro.Dist)

		patterns, perr := getPatterns(targetDistro)
		if perr != nil {
			return fmt.Errorf("Failed to publish package for %s/%s: %s", targetDistro.OS, targetDistro.Dist, perr)
		}

		files, ferr := walkMatch(distPath, patterns)
		if ferr != nil {
			return fmt.Errorf("Failed to publish package for %s/%s: %s", targetDistro.OS, targetDistro.Dist, ferr)
		}

		rwsUrlPart := os.Getenv("RWS_URL_PART")
		if rwsUrlPart == "" {
			return fmt.Errorf("Failed to publish package: RWS_URL_PART is not set")
		}

		flags := []string{
			"-v",
			"-LfsS",
			"-X", "PUT", fmt.Sprintf("%s/%s/%s", rwsUrlPart, targetDistro.OS, targetDistro.Dist),
			"-F", fmt.Sprintf("product=%s", packageName),
		}

		for _, file := range files {
			flags = append(flags, "-F", fmt.Sprintf("%s=@./%s", filepath.Base(file), file))
		}

		fmt.Printf("curl flags (excluding secrets): %s\n", flags)

		rwsAuth := os.Getenv("RWS_AUTH")
		if rwsAuth == "" {
			return fmt.Errorf("Failed to publish package: RWS_AUTH is not set")
		}
		flags = append(flags, "-u", rwsAuth)

		cmd := exec.Command("curl", flags...)

		output, err := cmd.CombinedOutput()
		if err != nil {
			return fmt.Errorf("Failed to publish package for %s/%s: %s, %s",
				targetDistro.OS, targetDistro.Dist, err, output)
		}
	}

	return nil
}