mirror of
https://github.com/SAP/jenkins-library.git
synced 2024-12-14 11:03:09 +02:00
363 lines
12 KiB
Go
363 lines
12 KiB
Go
package cmd
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"os"
|
|
"strings"
|
|
"text/template"
|
|
"time"
|
|
|
|
"github.com/SAP/jenkins-library/pkg/command"
|
|
"github.com/SAP/jenkins-library/pkg/log"
|
|
"github.com/SAP/jenkins-library/pkg/telemetry"
|
|
"github.com/SAP/jenkins-library/pkg/versioning"
|
|
"github.com/pkg/errors"
|
|
|
|
"github.com/go-git/go-git/v5"
|
|
gitConfig "github.com/go-git/go-git/v5/config"
|
|
"github.com/go-git/go-git/v5/plumbing"
|
|
"github.com/go-git/go-git/v5/plumbing/object"
|
|
"github.com/go-git/go-git/v5/plumbing/transport/http"
|
|
"github.com/go-git/go-git/v5/plumbing/transport/ssh"
|
|
)
|
|
|
|
type gitRepository interface {
|
|
CreateTag(string, plumbing.Hash, *git.CreateTagOptions) (*plumbing.Reference, error)
|
|
CreateRemote(*gitConfig.RemoteConfig) (*git.Remote, error)
|
|
DeleteRemote(string) error
|
|
Push(*git.PushOptions) error
|
|
Remote(string) (*git.Remote, error)
|
|
ResolveRevision(plumbing.Revision) (*plumbing.Hash, error)
|
|
Worktree() (*git.Worktree, error)
|
|
}
|
|
|
|
type gitWorktree interface {
|
|
Add(string) (plumbing.Hash, error)
|
|
Checkout(*git.CheckoutOptions) error
|
|
Commit(string, *git.CommitOptions) (plumbing.Hash, error)
|
|
}
|
|
|
|
func getGitWorktree(repository gitRepository) (gitWorktree, error) {
|
|
return repository.Worktree()
|
|
}
|
|
|
|
func artifactPrepareVersion(config artifactPrepareVersionOptions, telemetryData *telemetry.CustomData, commonPipelineEnvironment *artifactPrepareVersionCommonPipelineEnvironment) {
|
|
c := command.Command{}
|
|
// reroute command output to logging framework
|
|
c.Stdout(log.Entry().Writer())
|
|
c.Stderr(log.Entry().Writer())
|
|
|
|
// open local .git repository
|
|
repository, err := openGit()
|
|
if err != nil {
|
|
log.Entry().WithError(err).Fatal("git repository required - none available")
|
|
}
|
|
|
|
err = runArtifactPrepareVersion(&config, telemetryData, commonPipelineEnvironment, nil, &c, repository, getGitWorktree)
|
|
if err != nil {
|
|
log.Entry().WithError(err).Fatal("artifactPrepareVersion failed")
|
|
}
|
|
log.Entry().Info("SUCCESS")
|
|
}
|
|
|
|
var sshAgentAuth = ssh.NewSSHAgentAuth
|
|
|
|
func runArtifactPrepareVersion(config *artifactPrepareVersionOptions, telemetryData *telemetry.CustomData, commonPipelineEnvironment *artifactPrepareVersionCommonPipelineEnvironment, artifact versioning.Artifact, runner execRunner, repository gitRepository, getWorktree func(gitRepository) (gitWorktree, error)) error {
|
|
|
|
telemetryData.Custom1Label = "buildTool"
|
|
telemetryData.Custom1 = config.BuildTool
|
|
telemetryData.Custom2Label = "filePath"
|
|
telemetryData.Custom2 = config.FilePath
|
|
|
|
// Options for artifact
|
|
artifactOpts := versioning.Options{
|
|
GlobalSettingsFile: config.GlobalSettingsFile,
|
|
M2Path: config.M2Path,
|
|
ProjectSettingsFile: config.ProjectSettingsFile,
|
|
VersionField: config.CustomVersionField,
|
|
VersionSection: config.CustomVersionSection,
|
|
VersioningScheme: config.CustomVersioningScheme,
|
|
}
|
|
|
|
if config.BuildTool == "docker" {
|
|
artifactOpts.VersionSource = config.DockerVersionSource
|
|
}
|
|
|
|
var err error
|
|
if artifact == nil {
|
|
artifact, err = versioning.GetArtifact(config.BuildTool, config.FilePath, &artifactOpts, runner)
|
|
if err != nil {
|
|
return errors.Wrap(err, "failed to retrieve artifact")
|
|
}
|
|
}
|
|
|
|
versioningType := config.VersioningType
|
|
|
|
// support former groovy versioning template and translate into new options
|
|
if len(config.VersioningTemplate) > 0 {
|
|
versioningType, _, config.IncludeCommitID = templateCompatibility(config.VersioningTemplate)
|
|
}
|
|
|
|
version, err := artifact.GetVersion()
|
|
if err != nil {
|
|
return errors.Wrap(err, "failed to retrieve version")
|
|
}
|
|
log.Entry().Infof("Version before automatic versioning: %v", version)
|
|
|
|
gitCommit, err := getGitCommitID(repository)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
gitCommitID := gitCommit.String()
|
|
|
|
newVersion := version
|
|
|
|
if versioningType == "cloud" || versioningType == "cloud_noTag" {
|
|
versioningTempl, err := versioningTemplate(artifact.VersioningScheme())
|
|
if err != nil {
|
|
return errors.Wrapf(err, "failed to get versioning template for scheme '%v'", artifact.VersioningScheme())
|
|
}
|
|
|
|
now := time.Now()
|
|
|
|
newVersion, err = calculateNewVersion(versioningTempl, version, gitCommitID, config.IncludeCommitID, now)
|
|
if err != nil {
|
|
return errors.Wrap(err, "failed to calculate new version")
|
|
}
|
|
|
|
worktree, err := getWorktree(repository)
|
|
if err != nil {
|
|
return errors.Wrap(err, "failed to retrieve git worktree")
|
|
}
|
|
|
|
// opening repository does not seem to consider already existing files properly
|
|
// behavior in case we do not run initializeWorktree:
|
|
// git.Add(".") will add the complete workspace instead of only changed files
|
|
err = initializeWorktree(gitCommit, worktree)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
// only update version in build descriptor if required in order to save prossing time (e.g. maven case)
|
|
if newVersion != version {
|
|
err = artifact.SetVersion(newVersion)
|
|
if err != nil {
|
|
return errors.Wrap(err, "failed to write version")
|
|
}
|
|
}
|
|
|
|
//ToDo: what about closure in current Groovy step. Discard the possibility or provide extension mechanism?
|
|
|
|
if versioningType == "cloud" {
|
|
// commit changes and push to repository (including new version tag)
|
|
gitCommitID, err = pushChanges(config, newVersion, repository, worktree, now)
|
|
if err != nil {
|
|
return errors.Wrapf(err, "failed to push changes for version '%v'", newVersion)
|
|
}
|
|
}
|
|
}
|
|
|
|
log.Entry().Infof("New version: '%v'", newVersion)
|
|
|
|
commonPipelineEnvironment.git.commitID = gitCommitID
|
|
commonPipelineEnvironment.artifactVersion = newVersion
|
|
|
|
return nil
|
|
}
|
|
|
|
func openGit() (gitRepository, error) {
|
|
workdir, _ := os.Getwd()
|
|
return git.PlainOpen(workdir)
|
|
}
|
|
|
|
func getGitCommitID(repository gitRepository) (plumbing.Hash, error) {
|
|
commitID, err := repository.ResolveRevision(plumbing.Revision("HEAD"))
|
|
if err != nil {
|
|
return plumbing.Hash{}, errors.Wrap(err, "failed to retrieve git commit ID")
|
|
}
|
|
return *commitID, nil
|
|
}
|
|
|
|
func versioningTemplate(scheme string) (string, error) {
|
|
// generally: timestamp acts as build number providing a proper order
|
|
switch scheme {
|
|
case "maven":
|
|
// according to https://www.mojohaus.org/versions-maven-plugin/version-rules.html
|
|
return "{{.Version}}{{if .Timestamp}}-{{.Timestamp}}{{if .CommitID}}_{{.CommitID}}{{end}}{{end}}", nil
|
|
case "pep440":
|
|
// according to https://www.python.org/dev/peps/pep-0440/
|
|
return "{{.Version}}{{if .Timestamp}}.{{.Timestamp}}{{if .CommitID}}+{{.CommitID}}{{end}}{{end}}", nil
|
|
case "semver2":
|
|
// according to https://semver.org/spec/v2.0.0.html
|
|
return "{{.Version}}{{if .Timestamp}}-{{.Timestamp}}{{if .CommitID}}+{{.CommitID}}{{end}}{{end}}", nil
|
|
}
|
|
return "", fmt.Errorf("versioning scheme '%v' not supported", scheme)
|
|
}
|
|
|
|
func calculateNewVersion(versioningTemplate, currentVersion, commitID string, includeCommitID bool, t time.Time) (string, error) {
|
|
tmpl, err := template.New("version").Parse(versioningTemplate)
|
|
if err != nil {
|
|
return "", errors.Wrapf(err, "failed to create version template: %v", versioningTemplate)
|
|
}
|
|
|
|
buf := new(bytes.Buffer)
|
|
versionParts := struct {
|
|
Version string
|
|
Timestamp string
|
|
CommitID string
|
|
}{
|
|
Version: currentVersion,
|
|
Timestamp: t.Format("20060102150405"),
|
|
}
|
|
|
|
if includeCommitID {
|
|
versionParts.CommitID = commitID
|
|
}
|
|
|
|
err = tmpl.Execute(buf, versionParts)
|
|
if err != nil {
|
|
return "", errors.Wrapf(err, "failed to execute versioning template: %v", versioningTemplate)
|
|
}
|
|
|
|
newVersion := buf.String()
|
|
if len(newVersion) == 0 {
|
|
return "", fmt.Errorf("failed calculate version, new version is '%v'", newVersion)
|
|
}
|
|
return buf.String(), nil
|
|
}
|
|
|
|
func initializeWorktree(gitCommit plumbing.Hash, worktree gitWorktree) error {
|
|
// checkout current revision in order to work on that
|
|
err := worktree.Checkout(&git.CheckoutOptions{Hash: gitCommit, Keep: true})
|
|
if err != nil {
|
|
return errors.Wrap(err, "failed to initialize worktree")
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func pushChanges(config *artifactPrepareVersionOptions, newVersion string, repository gitRepository, worktree gitWorktree, t time.Time) (string, error) {
|
|
|
|
var commitID string
|
|
|
|
commit, err := addAndCommit(config, worktree, newVersion, t)
|
|
if err != nil {
|
|
return commit.String(), err
|
|
}
|
|
|
|
commitID = commit.String()
|
|
|
|
tag := fmt.Sprintf("%v%v", config.TagPrefix, newVersion)
|
|
_, err = repository.CreateTag(tag, commit, nil)
|
|
if err != nil {
|
|
return commitID, err
|
|
}
|
|
|
|
ref := gitConfig.RefSpec(fmt.Sprintf("refs/tags/%v:refs/tags/%v", tag, tag))
|
|
|
|
pushOptions := git.PushOptions{
|
|
RefSpecs: []gitConfig.RefSpec{gitConfig.RefSpec(ref)},
|
|
}
|
|
|
|
currentRemoteOrigin, err := repository.Remote("origin")
|
|
if err != nil {
|
|
return commitID, errors.Wrap(err, "failed to retrieve current remote origin")
|
|
}
|
|
var updatedRemoteOrigin *git.Remote
|
|
|
|
urls := originUrls(repository)
|
|
if len(urls) == 0 {
|
|
return commitID, fmt.Errorf("no remote url maintained")
|
|
}
|
|
if strings.HasPrefix(urls[0], "http") {
|
|
if len(config.Username) == 0 || len(config.Password) == 0 {
|
|
// handling compatibility: try to use ssh in case no credentials are available
|
|
log.Entry().Info("git username/password missing - switching to ssh")
|
|
|
|
remoteURL := convertHTTPToSSHURL(urls[0])
|
|
|
|
// update remote origin url to point to ssh url instead of http(s) url
|
|
err = repository.DeleteRemote("origin")
|
|
if err != nil {
|
|
return commitID, errors.Wrap(err, "failed to update remote origin - remove")
|
|
}
|
|
updatedRemoteOrigin, err = repository.CreateRemote(&gitConfig.RemoteConfig{Name: "origin", URLs: []string{remoteURL}})
|
|
if err != nil {
|
|
return commitID, errors.Wrap(err, "failed to update remote origin - create")
|
|
}
|
|
|
|
pushOptions.Auth, err = sshAgentAuth("git")
|
|
if err != nil {
|
|
return commitID, errors.Wrap(err, "failed to retrieve ssh authentication")
|
|
}
|
|
log.Entry().Infof("using remote '%v'", remoteURL)
|
|
} else {
|
|
pushOptions.Auth = &http.BasicAuth{Username: config.Username, Password: config.Password}
|
|
}
|
|
} else {
|
|
pushOptions.Auth, err = sshAgentAuth("git")
|
|
if err != nil {
|
|
return commitID, errors.Wrap(err, "failed to retrieve ssh authentication")
|
|
}
|
|
}
|
|
|
|
err = repository.Push(&pushOptions)
|
|
if err != nil {
|
|
return commitID, err
|
|
}
|
|
|
|
if updatedRemoteOrigin != currentRemoteOrigin {
|
|
err = repository.DeleteRemote("origin")
|
|
if err != nil {
|
|
return commitID, errors.Wrap(err, "failed to restore remote origin - remove")
|
|
}
|
|
_, err := repository.CreateRemote(currentRemoteOrigin.Config())
|
|
if err != nil {
|
|
return commitID, errors.Wrap(err, "failed to restore remote origin - create")
|
|
}
|
|
}
|
|
|
|
return commitID, nil
|
|
}
|
|
|
|
func addAndCommit(config *artifactPrepareVersionOptions, worktree gitWorktree, newVersion string, t time.Time) (plumbing.Hash, error) {
|
|
_, err := worktree.Add(".")
|
|
if err != nil {
|
|
return plumbing.Hash{}, errors.Wrap(err, "failed to execute 'git add .'")
|
|
}
|
|
|
|
//maybe more options are required: https://github.com/go-git/go-git/blob/master/_examples/commit/main.go
|
|
commit, err := worktree.Commit(fmt.Sprintf("update version %v", newVersion), &git.CommitOptions{Author: &object.Signature{Name: config.CommitUserName, When: t}})
|
|
if err != nil {
|
|
return commit, errors.Wrap(err, "failed to commit new version")
|
|
}
|
|
return commit, nil
|
|
}
|
|
|
|
func originUrls(repository gitRepository) []string {
|
|
remote, err := repository.Remote("origin")
|
|
if err != nil || remote == nil {
|
|
return []string{}
|
|
}
|
|
return remote.Config().URLs
|
|
}
|
|
|
|
func convertHTTPToSSHURL(url string) string {
|
|
sshURL := strings.Replace(url, "https://", "git@", 1)
|
|
return strings.Replace(sshURL, "/", ":", 1)
|
|
}
|
|
|
|
func templateCompatibility(groovyTemplate string) (versioningType string, useTimestamp bool, useCommitID bool) {
|
|
useTimestamp = strings.Contains(groovyTemplate, "${timestamp}")
|
|
useCommitID = strings.Contains(groovyTemplate, "${commitId")
|
|
|
|
versioningType = "library"
|
|
|
|
if useTimestamp {
|
|
versioningType = "cloud"
|
|
}
|
|
|
|
return
|
|
}
|