commands.go

// Bash commands to be executed by the application.

package main

import (
	"fmt"
	"net/url"
	"os/exec"

	"github.com/logrusorgru/aurora"
)

func run(cmd *exec.Cmd, path string, errMessage string, cmdMessage ...interface{}) (out []byte, err error) {

	// Default path
	if path != "." {
		cmd.Dir = path
	}

	out, err = cmd.Output()
	if err != nil {
		fmt.Println(errMessage)
		fmt.Println(cmdMessage...)

		// Log the `ExitError`
		ee, ok := err.(*exec.ExitError)
		if ok {
			fmt.Println(string(ee.Stderr))
		}

		fmt.Println(string(out))
		return
	}
	return
}

func ipfsClusterAdd(link string, rmin string, rmax string, uuid string) (out []byte, err error) {
	return run(
		exec.Command("ipfs-cluster-ctl", "add", "--recursive", "--quieter", "--chunker=rabin", "--cid-version=1", "--name", link, "--replication-min", rmin, "--replication-max", rmax, uuid),
		dirHome+dirGit,
		"Couldn't add the repository to IPFS.",
		aurora.Bold("Command :"), "ipfs-cluster-ctl", "add", "--recursive", "--quieter", "--chunker=rabin", "--cid-version=1", "--name", aurora.Blue(link), "--replication-min", aurora.Bold(rmin), "--replication-max", aurora.Bold(rmax), uuid,
	)
}

func ipfsKeyGen(link string) (out []byte, err error) {
	escaped := url.PathEscape(link)
	return run(
		exec.Command("ipfs", "key", "gen", "--type", "ed25519", escaped),
		".",
		"Couldn't generate a new key.",
		aurora.Bold("Command :"), "ipfs", "key", "gen", "--type", "ed25519", aurora.Blue(escaped),
	)
}

func ipfsKeyRm(key string) (out []byte, err error) {
	return run(
		exec.Command("ipfs", "key", "rm", key),
		".",
		"Couldn't remove a key.",
		aurora.Bold("Command :"), "ipfs", "key", "rm", key,
	)
}

func ipfsKeyRmName(name string) (out []byte, err error) {
	return ipfsKeyRm(url.PathEscape(name))
}

func ipfsNamePublish(key string, ipfs string) (out []byte, err error) {
	return run(
		exec.Command("ipfs", "name", "publish", "--key", key, "--quieter", "/ipfs/"+ipfs),
		".",
		"Couldn't publish on IPNS.",
		aurora.Bold("Command :"), "ipfs", "name", "publish", "--key", key, "--quieter", aurora.Cyan("/ipfs/"+ipfs),
	)
}

func gitClone(link string, uuid string) (out []byte, err error) {
	return run(
		exec.Command("git", "clone", link, uuid),
		dirHome+dirGit,
		"Couldn't clone the repository.",
		aurora.Bold("Command :"), "git", "clone", aurora.Blue(link), uuid,
	)
}

func gitPull(uuid string) (out []byte, err error) {
	return run(
		exec.Command("git", "-C", uuid, "pull"),
		dirHome+dirGit,
		"Couldn't pull the repository.",
		aurora.Bold("Command :"), "git", "-C", uuid, "pull",
	)
}

func ipfsClusterRm(ipfs string) (out []byte, err error) {
	return run(
		exec.Command("ipfs-cluster-ctl", "pin", "rm", ipfs),
		".",
		"Couldn't remove the repository from IPFS.",
		aurora.Bold("Command :"), "ipfs-cluster-ctl", "pin", "rm", aurora.Cyan(ipfs),
	)
}

func rm(uuid string) (out []byte, err error) {
	return run(
		exec.Command("rm", "--force", "--recursive", uuid),
		dirHome+dirGit,
		"Couldn't delete the repository.",
		aurora.Bold("Command :"), "rm", "--force", "--recursive", uuid,
	)
}

func ipfsSwarmConnect(address string) (out []byte, err error) {
	return run(
		exec.Command("ipfs", "swarm", "connect", address),
		".",
		"Couldn't connect to "+address+".",
		aurora.Bold("Command :"), "ipfs", "swarm", "connect", aurora.Cyan(address),
	)
}