job_resolver.go

package release

import (
	bosherr "github.com/cloudfoundry/bosh-init/internal/github.com/cloudfoundry/bosh-utils/errors"
	birel "github.com/cloudfoundry/bosh-init/release"
	bireljob "github.com/cloudfoundry/bosh-init/release/job"
)

type JobResolver interface {
	Resolve(jobName, releaseName string) (bireljob.Job, error)
}

type resolver struct {
	releaseManager birel.Manager
}

func NewJobResolver(releaseManager birel.Manager) JobResolver {
	return &resolver{
		releaseManager: releaseManager,
	}
}

func (r *resolver) Resolve(jobName, releaseName string) (bireljob.Job, error) {
	release, found := r.releaseManager.Find(releaseName)
	if !found {
		return bireljob.Job{}, bosherr.Errorf("Finding release '%s'", releaseName)
	}

	releaseJob, found := release.FindJobByName(jobName)
	if !found {
		return bireljob.Job{}, bosherr.Errorf("Finding job '%s' in release '%s'", jobName, releaseName)
	}

	return releaseJob, nil
}