diff --git a/.github/workflows/test.yml b/.github/workflows/test.yml index f2a783902..5765ee044 100644 --- a/.github/workflows/test.yml +++ b/.github/workflows/test.yml @@ -38,6 +38,17 @@ jobs: with: dotnet-version: '6.x' + # Install Mono on Ubuntu to run nuget.exe (due to this issue on Ubuntu 24 that hasn't been fixed yet - https://github.com/NuGet/setup-nuget/issues/168) + - name: Install Mono on Ubuntu + if: matrix.os == 'ubuntu' + run: | + sudo apt-get update + sudo apt-get install -y apt-transport-https dirmngr gnupg ca-certificates + sudo apt-key adv --recv-keys --keyserver hkp://keyserver.ubuntu.com:80 3FA7E0328081BFF6A14DA29AA6A19B38D3D831EF + echo "deb https://download.mono-project.com/repo/ubuntu stable-focal main" | sudo tee /etc/apt/sources.list.d/mono-official-stable.list + sudo apt-get update + sudo apt-get install -y mono-complete + - name: Setup Go with cache uses: jfrog/.github/actions/install-go-with-cache@main diff --git a/artifactory/commands/transferfiles/transfer.go b/artifactory/commands/transferfiles/transfer.go index 4e2324c48..f303c1ca9 100644 --- a/artifactory/commands/transferfiles/transfer.go +++ b/artifactory/commands/transferfiles/transfer.go @@ -5,8 +5,6 @@ import ( "encoding/json" "errors" "fmt" - "github.com/jfrog/gofrog/safeconvert" - "github.com/jfrog/jfrog-client-go/artifactory/services" "os" "os/signal" "path/filepath" @@ -14,6 +12,9 @@ import ( "strings" "syscall" + "github.com/jfrog/gofrog/safeconvert" + "github.com/jfrog/jfrog-client-go/artifactory/services" + "github.com/jfrog/gofrog/version" "github.com/jfrog/jfrog-cli-core/v2/artifactory/commands/transferfiles/state" "github.com/jfrog/jfrog-cli-core/v2/artifactory/commands/utils/precheckrunner" @@ -266,7 +267,7 @@ func (tdc *TransferFilesCommand) initStateManager(allSourceLocalRepos, sourceBui } func (tdc *TransferFilesCommand) reportTransferFilesUsage() { - log.Debug(usageReporter.ReportUsagePrefix, "Sending Transfer Files info...") + log.Debug(usageReporter.ArtifactoryCallHomePrefix, "Sending Transfer Files info...") sourceStorageInfo, err := tdc.sourceStorageInfoManager.GetStorageInfo() if err != nil { log.Debug(err.Error()) @@ -288,8 +289,7 @@ func (tdc *TransferFilesCommand) reportTransferFilesUsage() { AttributeValue: sourceStorageInfo.BinariesSize, }, } - err = usage.SendReportUsage(coreutils.GetCliUserAgent(), tdc.CommandName(), tdc.targetStorageInfoManager.GetServiceManager(), reportUsageAttributes...) - if err != nil { + if err = usage.NewArtifactoryCallHome().SendUsage(coreutils.GetCliUserAgent(), tdc.CommandName(), tdc.targetStorageInfoManager.GetServiceManager(), reportUsageAttributes...); err != nil { log.Debug(err.Error()) } } diff --git a/artifactory/utils/utils.go b/artifactory/utils/utils.go index f105cae26..68831475e 100644 --- a/artifactory/utils/utils.go +++ b/artifactory/utils/utils.go @@ -4,8 +4,6 @@ import ( "context" "encoding/json" "errors" - ioutils "github.com/jfrog/gofrog/io" - "github.com/jfrog/jfrog-client-go/evidence" "io" "net/http" "net/url" @@ -16,6 +14,9 @@ import ( "strings" "time" + ioutils "github.com/jfrog/gofrog/io" + "github.com/jfrog/jfrog-client-go/evidence" + "github.com/jfrog/jfrog-cli-core/v2/utils/config" "github.com/jfrog/jfrog-cli-core/v2/utils/coreutils" "github.com/jfrog/jfrog-client-go/access" @@ -24,6 +25,7 @@ import ( clientConfig "github.com/jfrog/jfrog-client-go/config" "github.com/jfrog/jfrog-client-go/distribution" "github.com/jfrog/jfrog-client-go/http/httpclient" + "github.com/jfrog/jfrog-client-go/jfconnect" "github.com/jfrog/jfrog-client-go/lifecycle" "github.com/jfrog/jfrog-client-go/metadata" clientUtils "github.com/jfrog/jfrog-client-go/utils" @@ -260,6 +262,26 @@ func CreateMetadataServiceManager(serviceDetails *config.ServerDetails, isDryRun return metadata.NewManager(serviceConfig) } +func CreateJfConnectServiceManager(serverDetails *config.ServerDetails) (jfconnect.Manager, error) { + certsPath, err := coreutils.GetJfrogCertsDir() + if err != nil { + return nil, err + } + jfConnectAuth, err := serverDetails.CreateJfConnectAuthConfig() + if err != nil { + return nil, err + } + serviceConfig, err := clientConfig.NewConfigBuilder(). + SetServiceDetails(jfConnectAuth). + SetCertificatesPath(certsPath). + SetInsecureTls(serverDetails.InsecureTls). + Build() + if err != nil { + return nil, err + } + return jfconnect.NewManager(serviceConfig) +} + // This error indicates that the build was scanned by Xray, but Xray found issues with the build. // If Xray failed to scan the build, for example due to a networking issue, a regular error should be returned. var errBuildScan = errors.New("issues found during xray build scan") diff --git a/common/commands/command.go b/common/commands/command.go index 34d4fc6bf..52bd83cf6 100644 --- a/common/commands/command.go +++ b/common/commands/command.go @@ -1,9 +1,12 @@ package commands import ( + "sync" + "github.com/jfrog/jfrog-cli-core/v2/artifactory/utils" "github.com/jfrog/jfrog-cli-core/v2/utils/config" "github.com/jfrog/jfrog-cli-core/v2/utils/coreutils" + coreusage "github.com/jfrog/jfrog-cli-core/v2/utils/usage" usageReporter "github.com/jfrog/jfrog-cli-core/v2/utils/usage" "github.com/jfrog/jfrog-client-go/artifactory/usage" "github.com/jfrog/jfrog-client-go/utils/log" @@ -30,29 +33,59 @@ func Exec(command Command) error { } func reportUsage(command Command, channel chan<- bool) { + // When the usage reporting is done, signal to the channel. defer signalReportUsageFinished(channel) - reportUsage := usageReporter.ShouldReportUsage() - if reportUsage { - serverDetails, err := command.ServerDetails() - if err != nil { - log.Debug(usageReporter.ReportUsagePrefix, err.Error()) - return - } - if serverDetails != nil && serverDetails.ArtifactoryUrl != "" { - log.Debug(usageReporter.ReportUsagePrefix, "Sending info...") - serviceManager, err := utils.CreateServiceManager(serverDetails, -1, 0, false) - if err != nil { - log.Debug(usageReporter.ReportUsagePrefix, err.Error()) - return - } - err = usage.SendReportUsage(coreutils.GetCliUserAgent(), command.CommandName(), serviceManager) - if err != nil { - log.Debug(err.Error()) - return - } + + if !usageReporter.ShouldReportUsage() { + log.Debug("Usage reporting is disabled") + return + } + + serverDetails, err := command.ServerDetails() + if err != nil { + log.Debug("Usage reporting:", err.Error()) + return + } + + if serverDetails != nil { + var wg sync.WaitGroup + + // Report the usage to Artifactory's Call Home API. + if serverDetails.ArtifactoryUrl != "" { + wg.Add(1) + go func() { + defer wg.Done() + reportUsageToArtifactoryCallHome(command, serverDetails) + }() } - } else { - log.Debug("Usage info is disabled.") + + // Report the usage to the Visibility System. + wg.Add(1) + go func() { + defer wg.Done() + reportUsageToVisibilitySystem(command, serverDetails) + }() + + // Wait for the two report actions to finish. + wg.Wait() + } +} + +func reportUsageToVisibilitySystem(command Command, serverDetails *config.ServerDetails) { + if err := coreusage.NewVisibilitySystemManager(serverDetails).SendUsage(command.CommandName()); err != nil { + log.Debug("Visibility System Usage reporting:", err.Error()) + } +} + +func reportUsageToArtifactoryCallHome(command Command, serverDetails *config.ServerDetails) { + log.Debug(usageReporter.ArtifactoryCallHomePrefix, "Sending info...") + serviceManager, err := utils.CreateServiceManager(serverDetails, -1, 0, false) + if err != nil { + log.Debug(usageReporter.ArtifactoryCallHomePrefix, err.Error()) + return + } + if err = usage.NewArtifactoryCallHome().SendUsage(coreutils.GetCliUserAgent(), command.CommandName(), serviceManager); err != nil { + log.Debug(err.Error()) } } diff --git a/general/login/login.go b/general/login/login.go index 589651987..9bd4b47e0 100644 --- a/general/login/login.go +++ b/general/login/login.go @@ -1,6 +1,7 @@ package login import ( + "fmt" "github.com/jfrog/jfrog-cli-core/v2/common/commands" "github.com/jfrog/jfrog-cli-core/v2/general" "github.com/jfrog/jfrog-cli-core/v2/utils/config" @@ -32,21 +33,22 @@ func (lc *LoginCommand) Run() error { } func newConfLogin() error { - platformUrl, err := promptPlatformUrl() - if err != nil { - return err - } + platformUrl := promptPlatformUrl() newServer := config.ServerDetails{Url: platformUrl} return general.ConfigServerWithDeducedId(&newServer, true, true) } -func promptPlatformUrl() (string, error) { +func promptPlatformUrl() string { var platformUrl string - ioutils.ScanFromConsole("Enter your JFrog Platform URL", &platformUrl, "") - if platformUrl == "" { - return "", errorutils.CheckErrorf("providing JFrog Platform URL is mandatory") + // Loop until a non-empty platformUrl is entered + for { + ioutils.ScanFromConsole("Enter your JFrog Platform URL", &platformUrl, "") + if platformUrl != "" { + break + } + fmt.Println("The JFrog Platform URL cannot be empty. Please try again.") } - return platformUrl, nil + return platformUrl } func existingConfLogin(configurations []*config.ServerDetails) error { diff --git a/go.mod b/go.mod index 9209899c8..b7a19a152 100644 --- a/go.mod +++ b/go.mod @@ -11,22 +11,22 @@ require ( github.com/gocarina/gocsv v0.0.0-20240520201108-78e41c74b4b1 github.com/google/uuid v1.6.0 github.com/gookit/color v1.5.4 - github.com/jedib0t/go-pretty/v6 v6.6.1 - github.com/jfrog/build-info-go v1.10.6 + github.com/jedib0t/go-pretty/v6 v6.6.3 + github.com/jfrog/build-info-go v1.10.7 github.com/jfrog/gofrog v1.7.6 - github.com/jfrog/jfrog-client-go v1.48.3 + github.com/jfrog/jfrog-client-go v1.48.4 github.com/magiconair/properties v1.8.7 github.com/manifoldco/promptui v0.9.0 github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c github.com/spf13/viper v1.19.0 - github.com/stretchr/testify v1.9.0 + github.com/stretchr/testify v1.10.0 github.com/urfave/cli v1.22.16 github.com/vbauerster/mpb/v8 v8.8.3 golang.org/x/exp v0.0.0-20241108190413-2d47ceb2692f golang.org/x/mod v0.22.0 - golang.org/x/sync v0.9.0 - golang.org/x/term v0.26.0 - golang.org/x/text v0.20.0 + golang.org/x/sync v0.10.0 + golang.org/x/term v0.27.0 + golang.org/x/text v0.21.0 gopkg.in/yaml.v3 v3.0.1 ) @@ -88,15 +88,15 @@ require ( github.com/xo/terminfo v0.0.0-20210125001918-ca9a967f8778 // indirect go.uber.org/atomic v1.9.0 // indirect go.uber.org/multierr v1.9.0 // indirect - golang.org/x/crypto v0.29.0 // indirect + golang.org/x/crypto v0.31.0 // indirect golang.org/x/net v0.31.0 // indirect - golang.org/x/sys v0.27.0 // indirect + golang.org/x/sys v0.28.0 // indirect golang.org/x/tools v0.27.0 // indirect gopkg.in/ini.v1 v1.67.0 // indirect gopkg.in/warnings.v0 v0.1.2 // indirect ) -// replace github.com/jfrog/jfrog-client-go => github.com/eyalbe4/jfrog-client-go v1.28.1-0.20241103083749-45c13ff7fe16 +// replace github.com/jfrog/jfrog-client-go => github.com/eyalbe4/jfrog-client-go v1.28.1-0.20241220200217-c4b9ef90c453 // replace github.com/jfrog/build-info-go => github.com/jfrog/build-info-go v1.8.9-0.20241121100855-e7a75ceee2bd diff --git a/go.sum b/go.sum index 151a3e8f9..02ff60664 100644 --- a/go.sum +++ b/go.sum @@ -85,16 +85,16 @@ github.com/hashicorp/hcl v1.0.0 h1:0Anlzjpi4vEasTeNFn2mLJgTSwt0+6sfsiTG8qcWGx4= github.com/hashicorp/hcl v1.0.0/go.mod h1:E5yfLk+7swimpb2L/Alb/PJmXilQ/rhwaUYs4T20WEQ= github.com/jbenet/go-context v0.0.0-20150711004518-d14ea06fba99 h1:BQSFePA1RWJOlocH6Fxy8MmwDt+yVQYULKfN0RoTN8A= github.com/jbenet/go-context v0.0.0-20150711004518-d14ea06fba99/go.mod h1:1lJo3i6rXxKeerYnT8Nvf0QmHCRC1n8sfWVwXF2Frvo= -github.com/jedib0t/go-pretty/v6 v6.6.1 h1:iJ65Xjb680rHcikRj6DSIbzCex2huitmc7bDtxYVWyc= -github.com/jedib0t/go-pretty/v6 v6.6.1/go.mod h1:zbn98qrYlh95FIhwwsbIip0LYpwSG8SUOScs+v9/t0E= +github.com/jedib0t/go-pretty/v6 v6.6.3 h1:nGqgS0tgIO1Hto47HSaaK4ac/I/Bu7usmdD3qvs0WvM= +github.com/jedib0t/go-pretty/v6 v6.6.3/go.mod h1:zbn98qrYlh95FIhwwsbIip0LYpwSG8SUOScs+v9/t0E= 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.10.6 h1:zH1ZhXlVfi5DlFyunygHjrdOcnv5qxfeLqmsfD4+lc4= -github.com/jfrog/build-info-go v1.10.6/go.mod h1:JcISnovFXKx3wWf3p1fcMmlPdt6adxScXvoJN4WXqIE= +github.com/jfrog/build-info-go v1.10.7 h1:10NVHYg0193gJpQft+S4WQfvYMtj5jlwwhJRvkFJtBE= +github.com/jfrog/build-info-go v1.10.7/go.mod h1:JcISnovFXKx3wWf3p1fcMmlPdt6adxScXvoJN4WXqIE= github.com/jfrog/gofrog v1.7.6 h1:QmfAiRzVyaI7JYGsB7cxfAJePAZTzFz0gRWZSE27c6s= github.com/jfrog/gofrog v1.7.6/go.mod h1:ntr1txqNOZtHplmaNd7rS4f8jpA5Apx8em70oYEe7+4= -github.com/jfrog/jfrog-client-go v1.48.3 h1:HJpKGul0f/S2i7Uf7K/GwS1EUGiirt1LWXL1lanKNhU= -github.com/jfrog/jfrog-client-go v1.48.3/go.mod h1:1a7bmQHkRmPEza9wva2+WVrYzrGbosrMymq57kyG5gU= +github.com/jfrog/jfrog-client-go v1.48.4 h1:uXvBr2ebFKpBRUhWgC9TSSJe32IbSYGlbDp9tDzBcaY= +github.com/jfrog/jfrog-client-go v1.48.4/go.mod h1:2ySOMva54L3EYYIlCBYBTcTgqfrrQ19gtpA/MWfA/ec= github.com/kevinburke/ssh_config v1.2.0 h1:x584FjTGwHzMwvHx18PXxbBVzfnxogHaAReU4gf13a4= github.com/kevinburke/ssh_config v1.2.0/go.mod h1:CT57kijsi8u/K/BOFA39wgDQJ9CxiF4nAY/ojJ6r6mM= github.com/klauspost/compress v1.4.1/go.mod h1:RyIbtBH6LamlWaDj8nUwkbUhJ87Yi3uG0guNDohfE1A= @@ -191,8 +191,9 @@ github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81P github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU= github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo= -github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg= github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= +github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA= +github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= github.com/subosito/gotenv v1.6.0 h1:9NlTDc1FTs4qu0DDq7AEtTPNw6SVm7uBMsUCUjABIf8= github.com/subosito/gotenv v1.6.0/go.mod h1:Dk4QP5c2W3ibzajGcXpNraDfq2IrhjMIvMSWPKKo0FU= github.com/terminalstatic/go-xsd-validate v0.1.5 h1:RqpJnf6HGE2CB/lZB1A8BYguk8uRtcvYAPLCF15qguo= @@ -221,8 +222,8 @@ go.uber.org/atomic v1.9.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc= go.uber.org/multierr v1.9.0 h1:7fIwc/ZtS0q++VgcfqFDxSBZVv/Xo49/SYnDFupUwlI= go.uber.org/multierr v1.9.0/go.mod h1:X2jQV1h+kxSjClGpnseKVIxpmcjrj7MNnI0bnlfKTVQ= golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4= -golang.org/x/crypto v0.29.0 h1:L5SG1JTTXupVV3n6sUqMTeWbjAyfPwoda2DLX8J8FrQ= -golang.org/x/crypto v0.29.0/go.mod h1:+F4F4N5hv6v38hfeYwTdx20oUvLLc+QfrE9Ax9HtgRg= +golang.org/x/crypto v0.31.0 h1:ihbySMvVjLAeSH1IbfcRTkD/iNscyz8rGzjF/E5hV6U= +golang.org/x/crypto v0.31.0/go.mod h1:kDsLvtWBEx7MV9tJOj9bnXsPbxwJQ6csT/x4KIN4Ssk= golang.org/x/exp v0.0.0-20241108190413-2d47ceb2692f h1:XdNn9LlyWAhLVp6P/i8QYBW+hlyhrhei9uErw2B5GJo= golang.org/x/exp v0.0.0-20241108190413-2d47ceb2692f/go.mod h1:D5SMRVC3C2/4+F/DB1wZsLRnSNimn2Sp/NPsCrsv8ak= golang.org/x/mod v0.22.0 h1:D4nJWe9zXqHOmWqj4VMOJhvzj7bEZg4wEYa759z1pH4= @@ -231,8 +232,8 @@ golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qx golang.org/x/net v0.31.0 h1:68CPQngjLL0r2AlUKiSxtQFKvzRVbnzLwMUn5SzcLHo= golang.org/x/net v0.31.0/go.mod h1:P4fl1q7dY2hnZFxEk4pPSkDHF+QqjitcnDjUQyMM+pM= golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= -golang.org/x/sync v0.9.0 h1:fEo0HyrW1GIgZdpbhCRO0PkJajUS5H9IFUztCgEo2jQ= -golang.org/x/sync v0.9.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= +golang.org/x/sync v0.10.0 h1:3NQrjDixjgGwUOCaF8w2+VYHv0Ve/vGYSbdkTa98gmQ= +golang.org/x/sync v0.10.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= golang.org/x/sys v0.0.0-20181122145206-62eef0e2fa9b/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20190222072716-a9d3bda3a223/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20191008105621-543471e840be/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= @@ -251,14 +252,14 @@ golang.org/x/sys v0.0.0-20220704084225-05e143d24a9e/go.mod h1:oPkhp1MJrh7nUepCBc golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.1.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.27.0 h1:wBqf8DvsY9Y/2P8gAfPDEYNuS30J4lPHJxXSb/nJZ+s= -golang.org/x/sys v0.27.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= +golang.org/x/sys v0.28.0 h1:Fksou7UEQUWlKvIdsqzJmUmCX3cZuD2+P3XyyzwMhlA= +golang.org/x/sys v0.28.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= -golang.org/x/term v0.26.0 h1:WEQa6V3Gja/BhNxg540hBip/kkaYtRg3cxg4oXSw4AU= -golang.org/x/term v0.26.0/go.mod h1:Si5m1o57C5nBNQo5z1iq+XDijt21BDBDp2bK0QI8e3E= +golang.org/x/term v0.27.0 h1:WP60Sv1nlK1T6SupCHbXzSaN0b9wUmsPoRS9b61A23Q= +golang.org/x/term v0.27.0/go.mod h1:iMsnZpn0cago0GOrHO2+Y7u7JPn5AylBrcoWkElMTSM= golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= -golang.org/x/text v0.20.0 h1:gK/Kv2otX8gz+wn7Rmb3vT96ZwuoxnQlY+HlJVj7Qug= -golang.org/x/text v0.20.0/go.mod h1:D4IsuqiFMhST5bX19pQ9ikHC2GsaKyk/oF+pn3ducp4= +golang.org/x/text v0.21.0 h1:zyQAAkrwaneQ066sspRyJaG9VNi/YJ1NfzcGB3hZ/qo= +golang.org/x/text v0.21.0/go.mod h1:4IBbMaMmOPCJ8SecivzSH54+73PCFmPWxNTLm+vZkEQ= golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= golang.org/x/tools v0.27.0 h1:qEKojBykQkQ4EynWy4S8Weg69NumxKdn40Fce3uc/8o= golang.org/x/tools v0.27.0/go.mod h1:sUi0ZgbwW9ZPAq26Ekut+weQPR5eIM6GQLQ1Yjm1H0Q= diff --git a/plugins/components/commandcomp.go b/plugins/components/commandcomp.go index e7401053a..361f9533c 100644 --- a/plugins/components/commandcomp.go +++ b/plugins/components/commandcomp.go @@ -60,6 +60,10 @@ func (c *Context) GetStringFlagValue(flagName string) string { return c.stringFlags[flagName] } +func (c *Context) AddStringFlag(key, value string) { + c.stringFlags[key] = value +} + func (c *Context) GetIntFlagValue(flagName string) (value int, err error) { parsed, err := strconv.ParseInt(c.GetStringFlagValue(flagName), 0, 64) if err != nil { diff --git a/utils/config/config.go b/utils/config/config.go index 010e2ef0d..c3a15cdfd 100644 --- a/utils/config/config.go +++ b/utils/config/config.go @@ -4,6 +4,12 @@ import ( "bytes" "encoding/json" "errors" + "os" + "path/filepath" + "strconv" + "strings" + "time" + "github.com/buger/jsonparser" biutils "github.com/jfrog/build-info-go/utils" "github.com/jfrog/jfrog-cli-core/v2/utils/coreutils" @@ -22,11 +28,6 @@ import ( "github.com/jfrog/jfrog-client-go/utils/log" xrayAuth "github.com/jfrog/jfrog-client-go/xray/auth" xscAuth "github.com/jfrog/jfrog-client-go/xsc/auth" - "os" - "path/filepath" - "strconv" - "strings" - "time" ) func init() { @@ -747,6 +748,12 @@ func (serverDetails *ServerDetails) CreateAccessAuthConfig() (auth.ServiceDetail return serverDetails.createAuthConfig(pAuth) } +func (serverDetails *ServerDetails) CreateJfConnectAuthConfig() (auth.ServiceDetails, error) { + pAuth := accessAuth.NewAccessDetails() + pAuth.SetUrl(utils.AddTrailingSlashIfNeeded(serverDetails.Url) + "jfconnect/") + return serverDetails.createAuthConfig(pAuth) +} + func (serverDetails *ServerDetails) CreateLifecycleAuthConfig() (auth.ServiceDetails, error) { lcAuth := lifecycleAuth.NewLifecycleDetails() lcAuth.SetUrl(serverDetails.LifecycleUrl) diff --git a/utils/coreutils/coreconsts.go b/utils/coreutils/coreconsts.go index 9e83bc8b0..541d1feb0 100644 --- a/utils/coreutils/coreconsts.go +++ b/utils/coreutils/coreconsts.go @@ -67,6 +67,8 @@ var ( BuildName = "JFROG_CLI_BUILD_NAME" BuildNumber = "JFROG_CLI_BUILD_NUMBER" Project = "JFROG_CLI_BUILD_PROJECT" + SigningKey = "JFROG_CLI_SIGNING_KEY" + KeyAlias = "JFROG_CLI_KEY_ALIAS" //#nosec G101 EncryptionKey = "JFROG_CLI_ENCRYPTION_KEY" ) diff --git a/utils/usage/usage.go b/utils/usage/usage.go index f84dc54ea..b73cfd2b4 100644 --- a/utils/usage/usage.go +++ b/utils/usage/usage.go @@ -18,8 +18,8 @@ import ( ) const ( - ReportUsagePrefix = "Usage Report:" - clientIdAttributeName = "clientId" + ArtifactoryCallHomePrefix = "Artifactory Call Home:" + clientIdAttributeName = "clientId" ) type UsageReporter struct { @@ -57,7 +57,7 @@ func NewUsageReporter(productId string, serverDetails *config.ServerDetails) *Us func ShouldReportUsage() (reportUsage bool) { reportUsage, err := clientutils.GetBoolEnvValue(coreutils.ReportUsage, true) if err != nil { - log.Debug(ReportUsagePrefix + err.Error()) + log.Debug(ArtifactoryCallHomePrefix + err.Error()) return false } return reportUsage @@ -85,10 +85,10 @@ func (ur *UsageReporter) Report(features ...ReportFeature) { return } if len(features) == 0 { - log.Debug(ReportUsagePrefix, "Nothing to send.") + log.Debug(ArtifactoryCallHomePrefix, "Nothing to send.") return } - log.Debug(ReportUsagePrefix, "Sending info...") + log.Debug(ArtifactoryCallHomePrefix, "Sending info...") if ur.sendToEcosystem { ur.reportWaitGroup.Go(func() (err error) { if err = ur.reportToEcosystem(features...); err != nil { @@ -117,7 +117,7 @@ func (ur *UsageReporter) Report(features ...ReportFeature) { func (ur *UsageReporter) WaitForResponses() (err error) { if err = ur.reportWaitGroup.Wait(); err != nil { - err = fmt.Errorf("%s %s", ReportUsagePrefix, err.Error()) + err = fmt.Errorf("%s %s", ArtifactoryCallHomePrefix, err.Error()) } return } @@ -169,7 +169,7 @@ func (ur *UsageReporter) reportToArtifactory(features ...ReportFeature) (err err if err != nil { return } - return usage.ReportUsageToArtifactory(ur.ProductId, serviceManager, converted...) + return usage.NewArtifactoryCallHome().SendUsageToArtifactory(ur.ProductId, serviceManager, converted...) } func convertAttributesToMap(reportFeature ReportFeature) (converted map[string]string) { diff --git a/utils/usage/visibility_system_manager.go b/utils/usage/visibility_system_manager.go new file mode 100644 index 000000000..aa1cd78f2 --- /dev/null +++ b/utils/usage/visibility_system_manager.go @@ -0,0 +1,68 @@ +package usage + +import ( + "encoding/json" + "os" + + "github.com/jfrog/jfrog-cli-core/v2/artifactory/utils" + "github.com/jfrog/jfrog-cli-core/v2/utils/config" + "github.com/jfrog/jfrog-cli-core/v2/utils/coreutils" +) + +type VisibilitySystemManager struct { + serverDetails *config.ServerDetails +} + +func NewVisibilitySystemManager(serverDetails *config.ServerDetails) *VisibilitySystemManager { + return &VisibilitySystemManager{ + serverDetails: serverDetails, + } +} + +type labels struct { + ProductID string `json:"product_id"` + FeatureID string `json:"feature_id"` + OIDCUsed string `json:"oidc_used"` + JobID string `json:"job_id"` + RunID string `json:"run_id"` + GitRepo string `json:"git_repo"` + GhTokenForCodeScanningAlertsProvided string `json:"gh_token_for_code_scanning_alerts_provided"` +} + +type visibilityMetric struct { + Value int `json:"value"` + MetricsName string `json:"metrics_name"` + Labels labels `json:"labels"` +} + +func (vsm *VisibilitySystemManager) createMetric(commandName string) ([]byte, error) { + metricLabels := labels{ + ProductID: coreutils.GetCliUserAgentName(), + FeatureID: commandName, + OIDCUsed: os.Getenv("JFROG_CLI_USAGE_OIDC_USED"), + JobID: os.Getenv("JFROG_CLI_USAGE_JOB_ID"), + RunID: os.Getenv("JFROG_CLI_USAGE_RUN_ID"), + GitRepo: os.Getenv("JFROG_CLI_USAGE_GIT_REPO"), + GhTokenForCodeScanningAlertsProvided: os.Getenv("JFROG_CLI_USAGE_GH_TOKEN_FOR_CODE_SCANNING_ALERTS_PROVIDED"), + } + + metric := visibilityMetric{ + Value: 1, + MetricsName: "jfcli_commands_count", + Labels: metricLabels, + } + + return json.Marshal(metric) +} + +func (vsm *VisibilitySystemManager) SendUsage(commandName string) error { + manager, err := utils.CreateJfConnectServiceManager(vsm.serverDetails) + if err != nil { + return err + } + metric, err := vsm.createMetric(commandName) + if err != nil { + return err + } + return manager.PostMetric(metric) +} diff --git a/utils/usage/visibility_system_manager_test.go b/utils/usage/visibility_system_manager_test.go new file mode 100644 index 000000000..d5888fb4d --- /dev/null +++ b/utils/usage/visibility_system_manager_test.go @@ -0,0 +1,52 @@ +package usage + +import ( + "testing" + + "github.com/jfrog/jfrog-cli-core/v2/utils/coreutils" + testsutils "github.com/jfrog/jfrog-client-go/utils/tests" + "github.com/stretchr/testify/assert" +) + +func TestCreateMetric(t *testing.T) { + // Set environment variables for the test using SetEnvWithCallbackAndAssert + envVars := map[string]string{ + "JFROG_CLI_USAGE_OIDC_USED": "true", + "JFROG_CLI_USAGE_JOB_ID": "job123", + "JFROG_CLI_USAGE_RUN_ID": "run456", + "JFROG_CLI_USAGE_GIT_REPO": "test-repo", + "JFROG_CLI_USAGE_GH_TOKEN_FOR_CODE_SCANNING_ALERTS_PROVIDED": "true", + } + cleanupFuncs := []func(){} + for key, value := range envVars { + cleanup := testsutils.SetEnvWithCallbackAndAssert(t, key, value) + cleanupFuncs = append(cleanupFuncs, cleanup) + } + defer func() { + for _, cleanup := range cleanupFuncs { + cleanup() + } + }() + + commandName := "testCommand" + metric, err := NewVisibilitySystemManager(nil).createMetric(commandName) + assert.NoError(t, err) + + // Define the expected JSON structure + expectedJSON := `{ + "value": 1, + "metrics_name": "jfcli_commands_count", + "labels": { + "product_id": "` + coreutils.GetCliUserAgentName() + `", + "feature_id": "testCommand", + "oidc_used": "true", + "job_id": "job123", + "run_id": "run456", + "git_repo": "test-repo", + "gh_token_for_code_scanning_alerts_provided": "true" + } + }` + + // Compare the generated JSON to the expected JSON + assert.JSONEq(t, expectedJSON, string(metric)) +}