create_release.go

package cmd

import (
	semver "github.com/cppforlife/go-semi-semantic/version"

	boshrel "github.com/cloudfoundry/bosh-cli/release"
	boshreldir "github.com/cloudfoundry/bosh-cli/releasedir"
	boshui "github.com/cloudfoundry/bosh-cli/ui"
	bosherr "github.com/cloudfoundry/bosh-utils/errors"
	boshfu "github.com/cloudfoundry/bosh-utils/fileutil"
	boshsys "github.com/cloudfoundry/bosh-utils/system"
)

type CreateReleaseCmd struct {
	releaseDirFactory func(DirOrCWDArg) (boshrel.Reader, boshreldir.ReleaseDir)
	releaseWriter     boshrel.Writer
	fs                boshsys.FileSystem
	ui                boshui.UI
}

func NewCreateReleaseCmd(
	releaseDirFactory func(DirOrCWDArg) (boshrel.Reader, boshreldir.ReleaseDir),
	releaseWriter boshrel.Writer,
	fs boshsys.FileSystem,
	ui boshui.UI,
) CreateReleaseCmd {
	return CreateReleaseCmd{releaseDirFactory, releaseWriter, fs, ui}
}

func (c CreateReleaseCmd) Run(opts CreateReleaseOpts) (boshrel.Release, error) {
	releaseManifestReader, releaseDir := c.releaseDirFactory(opts.Directory)
	manifestGiven := len(opts.Args.Manifest.Path) > 0

	var release boshrel.Release
	var err error

	if manifestGiven {
		release, err = releaseManifestReader.Read(opts.Args.Manifest.Path)
		if err != nil {
			return nil, err
		}
	} else {
		release, err = c.buildRelease(releaseDir, opts)
		if err != nil {
			return nil, err
		}

		if opts.Final {
			err = c.finalizeRelease(releaseDir, release, opts)
			if err != nil {
				return nil, err
			}
		}
	}

	var archivePath string

	if opts.Tarball != "" {

		archivePath, err = c.fs.ExpandPath(opts.Tarball)
		if err != nil {
			return nil, err
		}

		path, err := c.releaseWriter.Write(release, nil)
		if err != nil {
			return nil, err
		}

		err = boshfu.NewFileMover(c.fs).Move(path, archivePath)
		if err != nil {
			return nil, bosherr.WrapErrorf(err, "Moving release archive to final destination")
		}
	}

	ReleaseTables{Release: release, ArchivePath: archivePath}.Print(c.ui)

	return release, nil
}

func (c CreateReleaseCmd) buildRelease(releaseDir boshreldir.ReleaseDir, opts CreateReleaseOpts) (boshrel.Release, error) {
	var err error

	name := opts.Name

	if len(name) == 0 {
		name, err = releaseDir.DefaultName()
		if err != nil {
			return nil, err
		}
	}

	version := semver.Version(opts.Version)

	if version.Empty() {
		version, err = releaseDir.NextDevVersion(name, opts.TimestampVersion)
		if err != nil {
			return nil, err
		}
	}

	return releaseDir.BuildRelease(name, version, opts.Force)
}

func (c CreateReleaseCmd) finalizeRelease(releaseDir boshreldir.ReleaseDir, release boshrel.Release, opts CreateReleaseOpts) error {
	version := semver.Version(opts.Version)

	if version.Empty() {
		version, err := releaseDir.NextFinalVersion(release.Name())
		if err != nil {
			return err
		}

		release.SetVersion(version.AsString())
	}

	return releaseDir.FinalizeRelease(release, opts.Force)
}