Added Maven native implementation using flexpack

Author: agrasth

go.mod

@@ -242,7 +242,7 @@ require (
 	sigs.k8s.io/yaml v1.4.0 // indirect
 )
 
-replace github.com/jfrog/build-info-go => github.com/jfrog/build-info-go v1.8.9-0.20250907205057-2bfe50c014b7
+replace github.com/jfrog/build-info-go => github.com/jfrog/build-info-go v1.8.9-0.20250911222232-c782a2a600e1
 
 replace github.com/jfrog/jfrog-cli-artifactory => github.com/jfrog/jfrog-cli-artifactory v0.7.2-0.20250907212025-fb4679f280a0
 

go.sum

@@ -349,8 +349,8 @@ github.com/jellydator/ttlcache/v3 v3.3.0 h1:BdoC9cE81qXfrxeb9eoJi9dWrdhSuwXMAnHT
 github.com/jellydator/ttlcache/v3 v3.3.0/go.mod h1:bj2/e0l4jRnQdrnSTaGTsh4GSXvMjQcy41i7th0GVGw=
 github.com/jfrog/archiver/v3 v3.6.1 h1:LOxnkw9pOn45DzCbZNFV6K0+6dCsQ0L8mR3ZcujO5eI=
 github.com/jfrog/archiver/v3 v3.6.1/go.mod h1:VgR+3WZS4N+i9FaDwLZbq+jeU4B4zctXL+gL4EMzfLw=
-github.com/jfrog/build-info-go v1.8.9-0.20250907205057-2bfe50c014b7 h1:AH31gF//1Dv0ETrT2I4XLR4bCbG6anvw7tEEO8SkHzo=
-github.com/jfrog/build-info-go v1.8.9-0.20250907205057-2bfe50c014b7/go.mod h1:szdz9+WzB7+7PGnILLUgyY+OF5qD5geBT7UGNIxibyw=
+github.com/jfrog/build-info-go v1.8.9-0.20250911222232-c782a2a600e1 h1:785XxuIeWpTefTDFMcSEYywM+AIeLIUGc1Z526Bveu8=
+github.com/jfrog/build-info-go v1.8.9-0.20250911222232-c782a2a600e1/go.mod h1:szdz9+WzB7+7PGnILLUgyY+OF5qD5geBT7UGNIxibyw=
 github.com/jfrog/froggit-go v1.20.3 h1:U3HHT0+AEHUVSSyQBbagQR4fLRqGqzSptPujDZuuDTk=
 github.com/jfrog/froggit-go v1.20.3/go.mod h1:obSG1SlsWjktkuqmKtpq7MNTTL63e0ot+ucTnlOMV88=
 github.com/jfrog/go-mockhttp v0.3.1 h1:/wac8v4GMZx62viZmv4wazB5GNKs+GxawuS1u3maJH8=

maven_test.go

@@ -1,8 +1,16 @@
 package main
 
 import (
+	"encoding/json"
 	"errors"
 	"fmt"
+	"net/http"
+	"os"
+	"os/exec"
+	"path/filepath"
+	"strings"
+	"testing"
+
 	commonCliUtils "github.com/jfrog/jfrog-cli-core/v2/common/cliutils"
 	outputFormat "github.com/jfrog/jfrog-cli-core/v2/common/format"
 	"github.com/jfrog/jfrog-cli-core/v2/common/project"
@@ -12,17 +20,13 @@ import (
 	"github.com/jfrog/jfrog-client-go/utils/io/fileutils"
 	"github.com/stretchr/testify/require"
 	"gopkg.in/yaml.v2"
-	"net/http"
-	"os"
-	"os/exec"
-	"path/filepath"
-	"strings"
-	"testing"
 
 	"github.com/jfrog/build-info-go/build"
 	buildinfo "github.com/jfrog/build-info-go/entities"
 	biutils "github.com/jfrog/build-info-go/utils"
+	"github.com/jfrog/jfrog-cli-artifactory/artifactory/commands/generic"
 	"github.com/jfrog/jfrog-cli-artifactory/artifactory/commands/mvn"
+	"github.com/jfrog/jfrog-cli-core/v2/artifactory/utils"
 	buildUtils "github.com/jfrog/jfrog-cli-core/v2/common/build"
 	"github.com/jfrog/jfrog-cli-core/v2/common/commands"
 	"github.com/jfrog/jfrog-cli-core/v2/common/spec"
@@ -59,6 +63,134 @@ func TestMavenBuildWithServerID(t *testing.T) {
 	cleanMavenTest(t)
 }
 
+func TestMavenBuildWithFlexPack(t *testing.T) {
+	initMavenTest(t, false)
+	// Set environment for native FlexPack implementation
+	setEnvCallBack := clientTestUtils.SetEnvWithCallbackAndAssert(t, "JFROG_RUN_NATIVE", "true")
+	defer setEnvCallBack()
+
+	assert.NoError(t, runMaven(t, createSimpleMavenProject, tests.MavenConfig, "install"))
+	// Validate artifacts are deployed
+	searchSpec, err := tests.CreateSpec(tests.SearchAllMaven)
+	assert.NoError(t, err)
+	inttestutils.VerifyExistInArtifactory(tests.GetMavenDeployedArtifacts(), searchSpec, serverDetails, t)
+	cleanMavenTest(t)
+}
+
+func TestMavenBuildWithFlexPackBuildInfo(t *testing.T) {
+	initMavenTest(t, false)
+	buildName := tests.MvnBuildName + "-flexpack"
+	buildNumber := "1"
+
+	// Set environment for native FlexPack implementation
+	setEnvCallBack := clientTestUtils.SetEnvWithCallbackAndAssert(t, "JFROG_RUN_NATIVE", "true")
+	defer setEnvCallBack()
+
+	// Run Maven with build info
+	args := []string{"install", "--build-name=" + buildName, "--build-number=" + buildNumber}
+	assert.NoError(t, runMaven(t, createSimpleMavenProject, tests.MavenConfig, args...))
+
+	// Validate artifacts are deployed
+	searchSpec, err := tests.CreateSpec(tests.SearchAllMaven)
+	assert.NoError(t, err)
+	inttestutils.VerifyExistInArtifactory(tests.GetMavenDeployedArtifacts(), searchSpec, serverDetails, t)
+
+	// Publish build info
+	assert.NoError(t, runJfrogCliWithoutAssertion("rt", "bp", buildName, buildNumber))
+
+	// Validate build info was created with FlexPack dependencies
+	publishedBuildInfo, found, err := tests.GetBuildInfo(serverDetails, buildName, buildNumber)
+	if !assert.NoError(t, err, "Failed to get build info") {
+		return
+	}
+	if !assert.True(t, found, "build info was expected to be found") {
+		return
+	}
+
+	// Validate build info structure
+	assert.NotEmpty(t, publishedBuildInfo.BuildInfo.Modules, "Build info should have modules")
+	if len(publishedBuildInfo.BuildInfo.Modules) > 0 {
+		module := publishedBuildInfo.BuildInfo.Modules[0]
+		assert.Equal(t, "maven", string(module.Type), "Module type should be maven")
+		assert.NotEmpty(t, module.Id, "Module should have ID")
+
+		// FlexPack should collect dependencies
+		assert.Greater(t, len(module.Dependencies), 0, "FlexPack should collect dependencies")
+
+		// Validate dependency structure
+		for _, dep := range module.Dependencies {
+			assert.NotEmpty(t, dep.Id, "Dependency should have ID")
+			assert.NotEmpty(t, dep.Type, "Dependency should have type")
+			assert.NotEmpty(t, dep.Scopes, "Dependency should have scopes")
+			// FlexPack should provide checksums
+			hasChecksum := dep.Checksum.Sha1 != "" || dep.Checksum.Sha256 != "" || dep.Checksum.Md5 != ""
+			assert.True(t, hasChecksum, "Dependency %s should have at least one checksum", dep.Id)
+		}
+
+		// Should have artifacts from native Maven deployment
+		assert.Greater(t, len(module.Artifacts), 0, "Should have artifacts from Maven deployment")
+	}
+
+	cleanMavenTest(t)
+}
+
+func TestMavenFlexPackBuildProperties(t *testing.T) {
+	initMavenTest(t, false)
+	buildName := tests.MvnBuildName + "-props"
+	buildNumber := "42"
+
+	// Set environment for native FlexPack implementation
+	setEnvCallBack := clientTestUtils.SetEnvWithCallbackAndAssert(t, "JFROG_RUN_NATIVE", "true")
+	defer setEnvCallBack()
+
+	// Run Maven deploy with build info (this should set build properties on artifacts)
+	args := []string{"deploy", "--build-name=" + buildName, "--build-number=" + buildNumber}
+	assert.NoError(t, runMaven(t, createSimpleMavenProject, tests.MavenConfig, args...))
+
+	// Validate artifacts are deployed
+	searchSpec, err := tests.CreateSpec(tests.SearchAllMaven)
+	assert.NoError(t, err)
+	inttestutils.VerifyExistInArtifactory(tests.GetMavenDeployedArtifacts(), searchSpec, serverDetails, t)
+
+	// Publish build info
+	assert.NoError(t, runJfrogCliWithoutAssertion("rt", "bp", buildName, buildNumber))
+
+	// Search for artifacts with build properties
+	// This validates that FlexPack correctly set build.name and build.number properties
+	propsSearchSpec := fmt.Sprintf(`{
+		"files": [{
+			"aql": {
+				"items.find": {
+					"repo": "%s",
+					"@build.name": "%s",
+					"@build.number": "%s"
+				}
+			}
+		}]
+	}`, tests.MvnRepo1, buildName, buildNumber)
+
+	propsSpec := new(spec.SpecFiles)
+	err = json.Unmarshal([]byte(propsSearchSpec), propsSpec)
+	assert.NoError(t, err)
+
+	// Verify artifacts have build properties set by FlexPack
+	searchCmd := generic.NewSearchCommand()
+	searchCmd.SetServerDetails(serverDetails).SetSpec(propsSpec)
+	reader, err := searchCmd.Search()
+	assert.NoError(t, err)
+	var propsResults []utils.SearchResult
+	readerNoDate, err := utils.SearchResultNoDate(reader)
+	assert.NoError(t, err)
+	for searchResult := new(utils.SearchResult); readerNoDate.NextRecord(searchResult) == nil; searchResult = new(utils.SearchResult) {
+		propsResults = append(propsResults, *searchResult)
+	}
+	assert.NoError(t, reader.Close(), "Couldn't close reader")
+	assert.NoError(t, reader.GetError(), "Couldn't get reader error")
+	assert.Greater(t, len(propsResults), 0, "Should find artifacts with build properties set by FlexPack")
+
+	cleanMavenTest(t)
+}
+
 func TestMavenBuildWithNoProxy(t *testing.T) {
 	initMavenTest(t, false)
 	// jfrog-ignore - not a real password
@@ -107,17 +239,17 @@ func TestMavenBuildWithConditionalUpload(t *testing.T) {
 	cleanMavenTest(t)
 }
 
-func runMvnConditionalUploadTest(buildName, buildNumber string) (err error) {
+func runMvnConditionalUploadTest(buildName, buildNumber string) error {
 	configFilePath, exists, err := project.GetProjectConfFilePath(project.Maven)
 	if err != nil {
-		return
+		return err
 	}
 	if !exists {
 		return errors.New("no config file was found!")
 	}
 	buildConfig := buildUtils.NewBuildConfiguration(buildName, buildNumber, "", "")
 	if err = buildConfig.ValidateBuildAndModuleParams(); err != nil {
-		return
+		return err
 	}
 	printDeploymentView := log.IsStdErrTerminal()
 	mvnCmd := mvn.NewMvnCommand().
@@ -215,8 +347,7 @@ func createSimpleMavenProject(t *testing.T) string {
 func createMultiMavenProject(t *testing.T) string {
 	projectDir := filepath.Join(filepath.FromSlash(tests.GetTestResourcesPath()), "maven", "multiproject")
 	destPath, err := os.Getwd()
-	if err != nil {
-		assert.NoError(t, err)
+	if !assert.NoError(t, err, "Failed to get current working directory") {
 		return ""
 	}
 	destPath = filepath.Join(destPath, tests.Temp)
@@ -266,17 +397,14 @@ func TestMavenBuildIncludePatterns(t *testing.T) {
 	// Validate build info.
 	assert.NoError(t, artifactoryCli.Exec("build-publish", tests.MvnBuildName, buildNumber))
 	publishedBuildInfo, found, err := tests.GetBuildInfo(serverDetails, tests.MvnBuildName, buildNumber)
-	if err != nil {
-		assert.NoError(t, err)
+	if !assert.NoError(t, err, "Failed to get build info") {
 		return
 	}
-	if !found {
-		assert.True(t, found, "build info was expected to be found")
+	if !assert.True(t, found, "build info was expected to be found") {
 		return
 	}
 	buildInfo := publishedBuildInfo.BuildInfo
-	if len(buildInfo.Modules) != 4 {
-		assert.Len(t, buildInfo.Modules, 4)
+	if !assert.Len(t, buildInfo.Modules, 4, "Expected 4 modules in build info") {
 		return
 	}
 	validateSpecificModule(buildInfo, t, 13, 2, 1, "org.jfrog.test:multi1:3.7-SNAPSHOT", buildinfo.Maven)
@@ -302,8 +430,9 @@ func runMavenAndValidateDeployedArtifacts(t *testing.T, shouldDeployArtifact boo
 	if shouldDeployArtifact {
 		inttestutils.VerifyExistInArtifactory(tests.GetMavenMultiIncludedDeployedArtifacts(), searchSpec, serverDetails, t)
 	} else {
-		results, _ := inttestutils.SearchInArtifactory(searchSpec, serverDetails, t)
-		assert.Zero(t, results)
+		results, err := inttestutils.SearchInArtifactory(searchSpec, serverDetails, t)
+		assert.NoError(t, err)
+		assert.Zero(t, len(results))
 	}
 }
 func TestMavenWithSummary(t *testing.T) {
@@ -414,7 +543,9 @@ func prepareMavenSetupTest(t *testing.T, homeDir string) func() {
 	restoreSettingsXml, err := ioutils.BackupFile(settingsXml, ".settings.xml.backup")
 	require.NoError(t, err)
 	defer func() {
-		assert.NoError(t, restoreSettingsXml())
+		if err := restoreSettingsXml(); err != nil {
+			t.Errorf("Failed to restore settings.xml: %v", err)
+		}
 	}()
 
 	wd, err := os.Getwd()
@@ -433,7 +564,9 @@ func prepareMavenSetupTest(t *testing.T, homeDir string) func() {
 	restoreDir := clientTestUtils.ChangeDirWithCallback(t, wd, filepath.Join(tempDir, "mock-project"))
 
 	return func() {
-		assert.NoError(t, restoreSettingsXml())
+		if err := restoreSettingsXml(); err != nil {
+			t.Errorf("Failed to restore settings.xml: %v", err)
+		}
 		restoreDir()
 	}
 }

npm_test.go

@@ -84,7 +84,7 @@ func testNpm(t *testing.T, isLegacy bool) {
 	wd, err := os.Getwd()
 	assert.NoError(t, err, "Failed to get current dir")
 	defer clientTestUtils.ChangeDirAndAssert(t, wd)
-	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(log.Logger)
+	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(&biutils.NullLog{})
 	if err != nil {
 		assert.NoError(t, err)
 		return
@@ -164,7 +164,7 @@ func testNpmPublishWithNpmrc(t *testing.T, validationFunc func(t *testing.T, npm
 	assert.NoError(t, err, "Failed to get current dir")
 	defer clientTestUtils.ChangeDirAndAssert(t, wd)
 	buildNumber := "1"
-	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(log.Logger)
+	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(&biutils.NullLog{})
 	if err != nil {
 		assert.NoError(t, err)
 		return
@@ -214,7 +214,7 @@ func TestNpmInstallClientNative(t *testing.T) {
 	assert.NoError(t, err, "Failed to get current dir")
 	defer clientTestUtils.ChangeDirAndAssert(t, wd)
 
-	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(log.Logger)
+	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(&biutils.NullLog{})
 	if err != nil {
 		assert.NoError(t, err)
 		return
@@ -359,7 +359,7 @@ func TestNpmConditionalUpload(t *testing.T) {
 	assert.NoError(t, err, "Failed to get current dir")
 	searchSpec, err := tests.CreateSpec(tests.SearchAllNpm)
 	assert.NoError(t, err)
-	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(log.Logger)
+	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(&biutils.NullLog{})
 	assert.NoError(t, err)
 	npmProjectPath := initNpmProjectTest(t)
 	clientTestUtils.ChangeDirAndAssert(t, npmProjectPath)
@@ -585,7 +585,7 @@ func TestNpmPublishDetailedSummary(t *testing.T) {
 	assert.NoError(t, err, "Failed to get current dir")
 	defer clientTestUtils.ChangeDirAndAssert(t, wd)
 
-	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(log.Logger)
+	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(&biutils.NullLog{})
 	if err != nil {
 		assert.NoError(t, err)
 		return
@@ -734,7 +734,7 @@ func TestNpmPackInstall(t *testing.T) {
 // Read more about npm workspaces here: https://docs.npmjs.com/cli/v7/using-npm/workspaces
 func TestNpmPublishWithWorkspaces(t *testing.T) {
 	// Check npm version
-	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(log.Logger)
+	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(&biutils.NullLog{})
 	if err != nil {
 		assert.NoError(t, err)
 		return
@@ -780,7 +780,7 @@ func TestNpmPublishWithWorkspaces(t *testing.T) {
 // Test npm publish command with provided tarball
 func TestNpmPackProvidedTarball(t *testing.T) {
 	// Check npm version
-	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(log.Logger)
+	npmVersion, _, err := buildutils.GetNpmVersionAndExecPath(&biutils.NullLog{})
 	if err != nil {
 		assert.NoError(t, err)
 		return