mirror of
https://github.com/hanzokms/cli.git
synced 2026-10-30 20:30:00 +00:00
zeekay
bb34acfb48
Infisical->KMS across all .go (identifiers + env-var keys + brand strings), e2e env vars + e2e/packages/infisical->kms dir. Only external published deps remain: github.com/infisical/go-sdk + infisical-kmip API symbols (kmsSdk.NewInfisicalClient etc.) and the forked keyring's INFISICAL_VAULT_FILE_PASSPHRASE env contract — these need upstream forks to rename.
91 lines
1.8 KiB
Go
91 lines
1.8 KiB
Go
package telemetry
|
|
|
|
import (
|
|
"github.com/hanzokms/cli/packages/util"
|
|
"github.com/denisbrodbeck/machineid"
|
|
insights "github.com/hanzoai/insights-go"
|
|
"github.com/rs/zerolog/log"
|
|
)
|
|
|
|
var INSIGHTS_API_KEY_FOR_CLI string
|
|
|
|
type Telemetry struct {
|
|
isEnabled bool
|
|
insightsClient insights.Client
|
|
}
|
|
|
|
type NoOpLogger struct{}
|
|
|
|
func (NoOpLogger) Logf(format string, args ...interface{}) {
|
|
log.Debug().Msgf(format, args...)
|
|
}
|
|
|
|
func (NoOpLogger) Debugf(format string, args ...interface{}) {
|
|
log.Debug().Msgf(format, args...)
|
|
}
|
|
|
|
func (NoOpLogger) Warnf(format string, args ...interface{}) {
|
|
log.Warn().Msgf(format, args...)
|
|
}
|
|
|
|
func (NoOpLogger) Errorf(format string, args ...interface{}) {
|
|
log.Error().Msgf(format, args...)
|
|
}
|
|
|
|
func NewTelemetry(telemetryIsEnabled bool) *Telemetry {
|
|
if INSIGHTS_API_KEY_FOR_CLI != "" {
|
|
client, _ := insights.NewWithConfig(
|
|
INSIGHTS_API_KEY_FOR_CLI,
|
|
insights.Config{
|
|
Logger: NoOpLogger{},
|
|
},
|
|
)
|
|
|
|
return &Telemetry{isEnabled: telemetryIsEnabled, insightsClient: client}
|
|
} else {
|
|
return &Telemetry{isEnabled: false}
|
|
}
|
|
}
|
|
|
|
func (t *Telemetry) CaptureEvent(eventName string, properties insights.Properties) {
|
|
userIdentity, err := t.GetDistinctId()
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
if t.isEnabled {
|
|
t.insightsClient.Enqueue(insights.Capture{
|
|
DistinctId: userIdentity,
|
|
Event: eventName,
|
|
Properties: properties,
|
|
})
|
|
|
|
defer t.insightsClient.Close()
|
|
}
|
|
}
|
|
|
|
func (t *Telemetry) GetDistinctId() (string, error) {
|
|
var distinctId string
|
|
var outputErr error
|
|
|
|
machineId, err := machineid.ID()
|
|
if err != nil {
|
|
outputErr = err
|
|
}
|
|
|
|
kmsConfig, err := util.GetConfigFile()
|
|
if err != nil {
|
|
outputErr = err
|
|
}
|
|
|
|
if kmsConfig.LoggedInUserEmail != "" {
|
|
distinctId = kmsConfig.LoggedInUserEmail
|
|
} else if machineId != "" {
|
|
distinctId = "anonymous_cli_" + machineId
|
|
} else {
|
|
distinctId = ""
|
|
}
|
|
|
|
return distinctId, outputErr
|
|
}
|