out_command.go

package resource

import (
	"errors"
	"fmt"
	"io"
	"io/ioutil"
	"strconv"
	"strings"

	"github.com/ahume/go-github/github"
)

type OutCommand struct {
	github GitHub
	writer io.Writer
}

func NewOutCommand(github GitHub, writer io.Writer) *OutCommand {
	return &OutCommand{
		github: github,
		writer: writer,
	}
}

func (c *OutCommand) Run(sourceDir string, request OutRequest) (OutResponse, error) {
	if request.Params.ID == "" {
		return OutResponse{}, errors.New("id is a required parameter")
	}
	if request.Params.State == "" {
		return OutResponse{}, errors.New("state is a required parameter")
	}

	idInt, err := strconv.Atoi(request.Params.ID)
	if err != nil {
		return OutResponse{}, err
	}
	fmt.Fprintln(c.writer, "getting deployment")
	deployment, err := c.github.GetDeployment(idInt)
	if err != nil {
		return OutResponse{}, err
	}

	newStatus := &github.DeploymentStatusRequest{
		State:       github.String(request.Params.State),
		Description: github.String(request.Params.Description),
	}

	fmt.Fprintln(c.writer, "creating deployment status")
	_, err = c.github.CreateDeploymentStatus(*deployment.ID, newStatus)
	if err != nil {
		return OutResponse{}, err
	}

	fmt.Fprintln(c.writer, "getting deployment statuses list")
	statuses, err := c.github.ListDeploymentStatuses(*deployment.ID)
	if err != nil {
		return OutResponse{}, err
	}

	latestStatus := ""
	if len(statuses) > 0 {
		latestStatus = *statuses[0].State
	}

	return OutResponse{
		Version: Version{
			ID:       request.Params.ID,
			Statuses: latestStatus,
		},
		Metadata: metadataFromDeployment(deployment, statuses),
	}, nil
}

func (c *OutCommand) fileContents(path string) (string, error) {
	contents, err := ioutil.ReadFile(path)
	if err != nil {
		return "", err
	}

	return strings.TrimSpace(string(contents)), nil
}