2021-06-28 15:34:19 +00:00
|
|
|
package main
|
|
|
|
|
|
|
|
import (
|
|
|
|
"context"
|
2021-10-07 13:40:14 +00:00
|
|
|
"encoding/json"
|
2021-10-07 16:36:05 +00:00
|
|
|
"errors"
|
2021-06-28 15:34:19 +00:00
|
|
|
"fmt"
|
2021-10-07 16:36:05 +00:00
|
|
|
"io/fs"
|
2021-06-28 15:34:19 +00:00
|
|
|
"net/url"
|
2021-10-13 10:38:04 +00:00
|
|
|
"strings"
|
|
|
|
"time"
|
2021-06-28 15:34:19 +00:00
|
|
|
|
|
|
|
"github.com/crowdsecurity/crowdsec/pkg/apiclient"
|
2021-10-07 13:29:04 +00:00
|
|
|
"github.com/crowdsecurity/crowdsec/pkg/csconfig"
|
2021-06-28 15:34:19 +00:00
|
|
|
"github.com/crowdsecurity/crowdsec/pkg/cwhub"
|
|
|
|
"github.com/crowdsecurity/crowdsec/pkg/cwversion"
|
2021-10-13 10:38:04 +00:00
|
|
|
"github.com/crowdsecurity/crowdsec/pkg/database"
|
|
|
|
"github.com/crowdsecurity/crowdsec/pkg/models"
|
2021-10-07 13:29:04 +00:00
|
|
|
"github.com/crowdsecurity/crowdsec/pkg/types"
|
2021-06-28 15:34:19 +00:00
|
|
|
"github.com/go-openapi/strfmt"
|
|
|
|
log "github.com/sirupsen/logrus"
|
|
|
|
"github.com/spf13/cobra"
|
2021-10-07 13:40:14 +00:00
|
|
|
"gopkg.in/yaml.v2"
|
2021-06-28 15:34:19 +00:00
|
|
|
)
|
|
|
|
|
2021-10-13 10:38:04 +00:00
|
|
|
func IsInSlice(a string, b []string) bool {
|
|
|
|
for _, v := range b {
|
|
|
|
if a == v {
|
|
|
|
return true
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
|
|
|
|
func FetchScenariosListFromDB() ([]string, error) {
|
|
|
|
scenarios := make([]string, 0)
|
|
|
|
machines, err := dbClient.ListMachines()
|
|
|
|
if err != nil {
|
|
|
|
return nil, fmt.Errorf("while listing machines: %s", err)
|
|
|
|
}
|
|
|
|
//merge all scenarios together
|
|
|
|
for _, v := range machines {
|
|
|
|
machineScenarios := strings.Split(v.Scenarios, ",")
|
|
|
|
log.Debugf("%d scenarios for machine %d", len(machineScenarios), v.ID)
|
|
|
|
for _, sv := range machineScenarios {
|
|
|
|
if !IsInSlice(sv, scenarios) && sv != "" {
|
|
|
|
scenarios = append(scenarios, sv)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
log.Debugf("Returning list of scenarios : %+v", scenarios)
|
|
|
|
return scenarios, nil
|
|
|
|
}
|
|
|
|
|
2021-06-28 15:34:19 +00:00
|
|
|
func NewConsoleCmd() *cobra.Command {
|
|
|
|
var cmdConsole = &cobra.Command{
|
2021-09-03 10:56:17 +00:00
|
|
|
Use: "console [action]",
|
|
|
|
Short: "Manage interaction with Crowdsec console (https://app.crowdsec.net)",
|
|
|
|
Args: cobra.MinimumNArgs(1),
|
|
|
|
DisableAutoGenTag: true,
|
2021-06-28 15:34:19 +00:00
|
|
|
PersistentPreRunE: func(cmd *cobra.Command, args []string) error {
|
2021-10-07 16:36:05 +00:00
|
|
|
if err := csConfig.LoadAPIServer(); err != nil {
|
|
|
|
var fdErr *fs.PathError
|
|
|
|
if errors.As(err, &fdErr) {
|
|
|
|
log.Fatalf("Unable to load Local API : %s", fdErr)
|
|
|
|
} else {
|
|
|
|
log.Fatalf("Unable to load required Local API Configuration : %s", err)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if csConfig.DisableAPI {
|
2021-06-28 15:34:19 +00:00
|
|
|
log.Fatal("Local API is disabled, please run this command on the local API machine")
|
|
|
|
}
|
|
|
|
if csConfig.API.Server.OnlineClient == nil {
|
2021-08-25 16:30:05 +00:00
|
|
|
log.Fatalf("no configuration for Central API (CAPI) in '%s'", *csConfig.FilePath)
|
2021-06-28 15:34:19 +00:00
|
|
|
}
|
2021-10-07 13:29:04 +00:00
|
|
|
if csConfig.API.Server.OnlineClient.Credentials == nil {
|
|
|
|
log.Fatal("You must configure Central API (CAPI) with `cscli capi register` before enrolling your instance")
|
|
|
|
}
|
2021-06-28 15:34:19 +00:00
|
|
|
|
|
|
|
return nil
|
|
|
|
},
|
|
|
|
}
|
|
|
|
|
2021-10-13 16:36:29 +00:00
|
|
|
name := ""
|
|
|
|
tags := []string{}
|
|
|
|
|
2021-06-28 15:34:19 +00:00
|
|
|
cmdEnroll := &cobra.Command{
|
|
|
|
Use: "enroll [enroll-key]",
|
|
|
|
Short: "Enroll this instance to https://app.crowdsec.net [requires local API]",
|
|
|
|
Long: `
|
|
|
|
Enroll this instance to https://app.crowdsec.net
|
|
|
|
|
|
|
|
You can get your enrollment key by creating an account on https://app.crowdsec.net.
|
|
|
|
After running this command your will need to validate the enrollment in the webapp.`,
|
2021-10-13 16:39:19 +00:00
|
|
|
Example: `cscli console enroll YOUR-ENROLL-KEY
|
|
|
|
cscli console enroll --name [instance_name] YOUR-ENROLL-KEY
|
|
|
|
cscli console enroll --name [instance_name] --tags [tag_1] --tags [tag_2] YOUR-ENROLL-KEY
|
|
|
|
`,
|
2021-08-31 13:03:47 +00:00
|
|
|
Args: cobra.ExactArgs(1),
|
|
|
|
DisableAutoGenTag: true,
|
2021-06-28 15:34:19 +00:00
|
|
|
Run: func(cmd *cobra.Command, args []string) {
|
|
|
|
password := strfmt.Password(csConfig.API.Server.OnlineClient.Credentials.Password)
|
|
|
|
apiURL, err := url.Parse(csConfig.API.Server.OnlineClient.Credentials.URL)
|
|
|
|
if err != nil {
|
|
|
|
log.Fatalf("Could not parse CAPI URL : %s", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
if err := csConfig.LoadHub(); err != nil {
|
|
|
|
log.Fatalf(err.Error())
|
|
|
|
}
|
|
|
|
|
|
|
|
if err := cwhub.GetHubIdx(csConfig.Hub); err != nil {
|
|
|
|
log.Fatalf("Failed to load hub index : %s", err)
|
|
|
|
log.Infoln("Run 'sudo cscli hub update' to get the hub index")
|
|
|
|
}
|
|
|
|
|
|
|
|
scenarios, err := cwhub.GetUpstreamInstalledScenariosAsString()
|
|
|
|
if err != nil {
|
|
|
|
log.Fatalf("failed to get scenarios : %s", err.Error())
|
|
|
|
}
|
|
|
|
|
|
|
|
if len(scenarios) == 0 {
|
|
|
|
scenarios = make([]string, 0)
|
|
|
|
}
|
|
|
|
|
|
|
|
c, _ := apiclient.NewClient(&apiclient.Config{
|
|
|
|
MachineID: csConfig.API.Server.OnlineClient.Credentials.Login,
|
|
|
|
Password: password,
|
|
|
|
Scenarios: scenarios,
|
|
|
|
UserAgent: fmt.Sprintf("crowdsec/%s", cwversion.VersionStr()),
|
|
|
|
URL: apiURL,
|
|
|
|
VersionPrefix: "v2",
|
|
|
|
})
|
2021-10-13 16:36:29 +00:00
|
|
|
_, err = c.Auth.EnrollWatcher(context.Background(), args[0], name, tags)
|
2021-06-28 15:34:19 +00:00
|
|
|
if err != nil {
|
|
|
|
log.Fatalf("Could not enroll instance: %s", err)
|
|
|
|
}
|
|
|
|
log.Infof("Watcher successfully enrolled. Visit https://app.crowdsec.net to accept it.")
|
|
|
|
},
|
|
|
|
}
|
2021-10-13 16:36:29 +00:00
|
|
|
cmdEnroll.Flags().StringVarP(&name, "name", "n", "", "Name to appear in the console")
|
|
|
|
cmdEnroll.Flags().StringSliceVarP(&tags, "tags", "t", tags, "Tags to appear in the console")
|
2021-06-28 15:34:19 +00:00
|
|
|
cmdConsole.AddCommand(cmdEnroll)
|
2021-10-07 13:29:04 +00:00
|
|
|
|
|
|
|
var enableAll, disableAll bool
|
|
|
|
|
|
|
|
cmdEnable := &cobra.Command{
|
|
|
|
Use: "enable [feature-flag]",
|
|
|
|
Short: "Enable a feature flag",
|
|
|
|
Example: "enable alerts-tainted",
|
|
|
|
Long: `
|
|
|
|
Enable given information push to the central API. Allows to empower the console`,
|
|
|
|
ValidArgs: csconfig.CONSOLE_CONFIGS,
|
|
|
|
DisableAutoGenTag: true,
|
|
|
|
Run: func(cmd *cobra.Command, args []string) {
|
|
|
|
if enableAll {
|
2021-10-08 12:44:36 +00:00
|
|
|
SetConsoleOpts(csconfig.CONSOLE_CONFIGS, true)
|
2021-10-07 13:29:04 +00:00
|
|
|
} else {
|
|
|
|
SetConsoleOpts(args, true)
|
|
|
|
}
|
|
|
|
|
|
|
|
if err := csConfig.API.Server.DumpConsoleConfig(); err != nil {
|
|
|
|
log.Fatalf("failed writing console config : %s", err)
|
|
|
|
}
|
2021-10-14 13:53:39 +00:00
|
|
|
if disableAll {
|
|
|
|
log.Infof("All features have been enabled successfully")
|
|
|
|
} else {
|
|
|
|
log.Infof("%v have been enabled successfully", args)
|
|
|
|
}
|
|
|
|
log.Infof(ReloadMessage())
|
2021-10-07 13:29:04 +00:00
|
|
|
},
|
|
|
|
}
|
|
|
|
cmdEnable.Flags().BoolVarP(&enableAll, "all", "a", false, "Enable all feature flags")
|
|
|
|
cmdConsole.AddCommand(cmdEnable)
|
|
|
|
|
|
|
|
cmdDisable := &cobra.Command{
|
|
|
|
Use: "disable [feature-flag]",
|
|
|
|
Short: "Disable a feature flag",
|
|
|
|
Example: "disable alerts-tainted",
|
|
|
|
Long: `
|
|
|
|
Disable given information push to the central API.`,
|
|
|
|
ValidArgs: csconfig.CONSOLE_CONFIGS,
|
|
|
|
DisableAutoGenTag: true,
|
|
|
|
Run: func(cmd *cobra.Command, args []string) {
|
|
|
|
if disableAll {
|
2021-10-08 12:44:36 +00:00
|
|
|
SetConsoleOpts(csconfig.CONSOLE_CONFIGS, false)
|
2021-10-07 13:29:04 +00:00
|
|
|
} else {
|
|
|
|
SetConsoleOpts(args, false)
|
|
|
|
}
|
|
|
|
|
|
|
|
if err := csConfig.API.Server.DumpConsoleConfig(); err != nil {
|
|
|
|
log.Fatalf("failed writing console config : %s", err)
|
|
|
|
}
|
2021-10-14 13:53:39 +00:00
|
|
|
if disableAll {
|
|
|
|
log.Infof("All features have been disabled successfully")
|
|
|
|
} else {
|
|
|
|
log.Infof("%v have been disabled successfully", args)
|
|
|
|
}
|
|
|
|
log.Infof(ReloadMessage())
|
2021-10-07 13:29:04 +00:00
|
|
|
},
|
|
|
|
}
|
|
|
|
cmdDisable.Flags().BoolVarP(&disableAll, "all", "a", false, "Enable all feature flags")
|
|
|
|
cmdConsole.AddCommand(cmdDisable)
|
|
|
|
|
2021-10-14 13:53:39 +00:00
|
|
|
cmdConsoleStatus := &cobra.Command{
|
2021-10-07 13:29:04 +00:00
|
|
|
Use: "status [feature-flag]",
|
|
|
|
Short: "Shows status of one or all feature flags",
|
|
|
|
Example: "status alerts-tainted",
|
|
|
|
DisableAutoGenTag: true,
|
|
|
|
Run: func(cmd *cobra.Command, args []string) {
|
2021-10-07 13:40:14 +00:00
|
|
|
switch csConfig.Cscli.Output {
|
|
|
|
case "human":
|
2021-10-07 13:42:23 +00:00
|
|
|
fmt.Printf("Sharing options:\n")
|
2021-10-07 13:40:14 +00:00
|
|
|
fmt.Printf(" - Share Decisions : %t\n", *csConfig.API.Server.ConsoleConfig.ShareDecisions)
|
|
|
|
fmt.Printf(" - Share tainted scenarios alerts : %t\n", *csConfig.API.Server.ConsoleConfig.ShareTaintedScenarios)
|
|
|
|
fmt.Printf(" - Share custom scenarios alerts : %t\n", *csConfig.API.Server.ConsoleConfig.ShareCustomScenarios)
|
|
|
|
fmt.Printf(" - Share manual decisions alerts : %t\n", *csConfig.API.Server.ConsoleConfig.ShareManualDecisions)
|
2021-10-08 12:31:12 +00:00
|
|
|
fmt.Printf(" - Share alerts in simulion mode : %t\n", *csConfig.API.Server.ConsoleConfig.ShareSimulatedDecisions)
|
|
|
|
|
2021-10-07 13:40:14 +00:00
|
|
|
case "json":
|
|
|
|
data, err := json.MarshalIndent(csConfig.API.Server.ConsoleConfig, "", " ")
|
|
|
|
if err != nil {
|
|
|
|
log.Fatalf("failed to marshal configuration: %s", err)
|
|
|
|
}
|
|
|
|
fmt.Printf("%s\n", string(data))
|
|
|
|
case "raw":
|
|
|
|
data, err := yaml.Marshal(csConfig.API.Server.ConsoleConfig)
|
|
|
|
if err != nil {
|
|
|
|
log.Fatalf("failed to marshal configuration: %s", err)
|
|
|
|
}
|
|
|
|
fmt.Printf("%s\n", string(data))
|
|
|
|
}
|
2021-10-07 13:29:04 +00:00
|
|
|
},
|
|
|
|
}
|
|
|
|
|
2021-10-14 13:53:39 +00:00
|
|
|
cmdConsole.AddCommand(cmdConsoleStatus)
|
|
|
|
|
|
|
|
cmdConsoleSync := &cobra.Command{
|
2021-10-13 10:38:04 +00:00
|
|
|
Use: "sync",
|
|
|
|
Short: "Sync current decisions to console",
|
|
|
|
DisableAutoGenTag: true,
|
|
|
|
Run: func(cmd *cobra.Command, args []string) {
|
|
|
|
var err error
|
|
|
|
if err := csConfig.LoadDBConfig(); err != nil {
|
|
|
|
log.Errorf("This command requires direct database access (must be run on the local API machine)")
|
|
|
|
log.Fatalf(err.Error())
|
|
|
|
}
|
|
|
|
dbClient, err = database.NewClient(csConfig.DbConfig)
|
|
|
|
if err != nil {
|
|
|
|
log.Fatalf("unable to create new database client: %s", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
password := strfmt.Password(csConfig.API.Server.OnlineClient.Credentials.Password)
|
|
|
|
apiurl, err := url.Parse(csConfig.API.Server.OnlineClient.Credentials.URL)
|
|
|
|
if err != nil {
|
|
|
|
log.Fatalf("parsing api url ('%s'): %s", csConfig.API.Server.OnlineClient.Credentials.URL, err)
|
|
|
|
}
|
|
|
|
|
|
|
|
if err := csConfig.LoadHub(); err != nil {
|
|
|
|
log.Fatalf(err.Error())
|
|
|
|
}
|
|
|
|
|
|
|
|
if err := cwhub.GetHubIdx(csConfig.Hub); err != nil {
|
|
|
|
log.Fatalf("Failed to load hub index : %s", err)
|
|
|
|
log.Infoln("Run 'sudo cscli hub update' to get the hub index")
|
|
|
|
}
|
|
|
|
scenarios, err := cwhub.GetUpstreamInstalledScenariosAsString()
|
|
|
|
if err != nil {
|
|
|
|
log.Fatalf("failed to get scenarios : %s", err.Error())
|
|
|
|
}
|
|
|
|
if len(scenarios) == 0 {
|
|
|
|
log.Fatalf("no scenarios installed, abort")
|
|
|
|
}
|
|
|
|
|
|
|
|
Client, err = apiclient.NewClient(&apiclient.Config{
|
|
|
|
MachineID: csConfig.API.Server.OnlineClient.Credentials.Login,
|
|
|
|
Password: password,
|
|
|
|
UserAgent: fmt.Sprintf("crowdsec/%s", cwversion.VersionStr()),
|
|
|
|
URL: apiurl,
|
|
|
|
VersionPrefix: "v2",
|
|
|
|
Scenarios: scenarios,
|
|
|
|
UpdateScenario: FetchScenariosListFromDB,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
log.Fatalf("init default client: %s", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
filter := make(map[string][]string)
|
|
|
|
decisionsInDb, err := dbClient.QueryDecisionWithFilter(filter)
|
|
|
|
if err != nil {
|
|
|
|
log.Fatalf(err.Error())
|
|
|
|
}
|
|
|
|
decisionsList := make([]*models.Decision, 0)
|
|
|
|
for _, dbDecision := range decisionsInDb {
|
|
|
|
duration := dbDecision.Until.Sub(time.Now()).String()
|
|
|
|
decision := &models.Decision{
|
|
|
|
ID: int64(dbDecision.ID),
|
|
|
|
Duration: &duration,
|
|
|
|
Scenario: &dbDecision.Scenario,
|
|
|
|
Scope: &dbDecision.Scope,
|
|
|
|
Value: &dbDecision.Value,
|
|
|
|
Type: &dbDecision.Type,
|
|
|
|
Origin: &dbDecision.Origin,
|
|
|
|
Until: dbDecision.Until.String(),
|
|
|
|
}
|
|
|
|
decisionsList = append(decisionsList, decision)
|
|
|
|
}
|
2021-10-14 13:53:39 +00:00
|
|
|
_, _, err = Client.Decisions.SyncDecisions(context.Background(), decisionsList)
|
2021-10-13 10:38:04 +00:00
|
|
|
if err != nil {
|
|
|
|
log.Fatalf("unable to sync decisions with console: %s", err.Error())
|
|
|
|
}
|
2021-10-14 13:53:39 +00:00
|
|
|
log.Infof("Decisions have been synchronized successfully")
|
2021-10-13 10:38:04 +00:00
|
|
|
},
|
|
|
|
}
|
|
|
|
|
2021-10-14 13:53:39 +00:00
|
|
|
cmdConsole.AddCommand(cmdConsoleSync)
|
2021-10-07 13:29:04 +00:00
|
|
|
|
2021-06-28 15:34:19 +00:00
|
|
|
return cmdConsole
|
|
|
|
}
|
2021-10-07 13:29:04 +00:00
|
|
|
|
|
|
|
func SetConsoleOpts(args []string, wanted bool) {
|
|
|
|
for _, arg := range args {
|
|
|
|
switch arg {
|
|
|
|
case csconfig.SEND_CUSTOM_SCENARIOS:
|
|
|
|
/*for each flag check if it's already set before setting it*/
|
|
|
|
if csConfig.API.Server.ConsoleConfig.ShareCustomScenarios != nil {
|
|
|
|
if *csConfig.API.Server.ConsoleConfig.ShareCustomScenarios == wanted {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s already set to %t", csconfig.SEND_CUSTOM_SCENARIOS, wanted)
|
2021-10-07 13:29:04 +00:00
|
|
|
} else {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s set to %t", csconfig.SEND_CUSTOM_SCENARIOS, wanted)
|
2021-10-07 13:29:04 +00:00
|
|
|
*csConfig.API.Server.ConsoleConfig.ShareCustomScenarios = wanted
|
|
|
|
}
|
|
|
|
} else {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s set to %t", csconfig.SEND_CUSTOM_SCENARIOS, wanted)
|
2021-10-07 13:29:04 +00:00
|
|
|
csConfig.API.Server.ConsoleConfig.ShareCustomScenarios = types.BoolPtr(wanted)
|
|
|
|
}
|
|
|
|
case csconfig.SEND_TAINTED_SCENARIOS:
|
|
|
|
/*for each flag check if it's already set before setting it*/
|
|
|
|
if csConfig.API.Server.ConsoleConfig.ShareTaintedScenarios != nil {
|
|
|
|
if *csConfig.API.Server.ConsoleConfig.ShareTaintedScenarios == wanted {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s already set to %t", csconfig.SEND_TAINTED_SCENARIOS, wanted)
|
2021-10-07 13:29:04 +00:00
|
|
|
} else {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s set to %t", csconfig.SEND_TAINTED_SCENARIOS, wanted)
|
2021-10-07 13:29:04 +00:00
|
|
|
*csConfig.API.Server.ConsoleConfig.ShareTaintedScenarios = wanted
|
|
|
|
}
|
|
|
|
} else {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s set to %t", csconfig.SEND_TAINTED_SCENARIOS, wanted)
|
2021-10-07 13:29:04 +00:00
|
|
|
csConfig.API.Server.ConsoleConfig.ShareTaintedScenarios = types.BoolPtr(wanted)
|
|
|
|
}
|
|
|
|
case csconfig.SEND_MANUAL_SCENARIOS:
|
|
|
|
/*for each flag check if it's already set before setting it*/
|
|
|
|
if csConfig.API.Server.ConsoleConfig.ShareManualDecisions != nil {
|
|
|
|
if *csConfig.API.Server.ConsoleConfig.ShareManualDecisions == wanted {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s already set to %t", csconfig.SEND_MANUAL_SCENARIOS, wanted)
|
2021-10-07 13:29:04 +00:00
|
|
|
} else {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s set to %t", csconfig.SEND_MANUAL_SCENARIOS, wanted)
|
2021-10-07 13:29:04 +00:00
|
|
|
*csConfig.API.Server.ConsoleConfig.ShareManualDecisions = wanted
|
|
|
|
}
|
|
|
|
} else {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s set to %t", csconfig.SEND_MANUAL_SCENARIOS, wanted)
|
2021-10-07 13:29:04 +00:00
|
|
|
csConfig.API.Server.ConsoleConfig.ShareManualDecisions = types.BoolPtr(wanted)
|
|
|
|
}
|
|
|
|
case csconfig.SEND_LIVE_DECISIONS:
|
|
|
|
/*for each flag check if it's already set before setting it*/
|
|
|
|
if csConfig.API.Server.ConsoleConfig.ShareDecisions != nil {
|
|
|
|
if *csConfig.API.Server.ConsoleConfig.ShareDecisions == wanted {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s already set to %t", csconfig.SEND_LIVE_DECISIONS, wanted)
|
2021-10-07 13:29:04 +00:00
|
|
|
} else {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s set to %t", csconfig.SEND_LIVE_DECISIONS, wanted)
|
2021-10-07 13:29:04 +00:00
|
|
|
*csConfig.API.Server.ConsoleConfig.ShareDecisions = wanted
|
|
|
|
}
|
|
|
|
} else {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s set to %t", csconfig.SEND_LIVE_DECISIONS, wanted)
|
2021-10-07 13:29:04 +00:00
|
|
|
csConfig.API.Server.ConsoleConfig.ShareDecisions = types.BoolPtr(wanted)
|
|
|
|
}
|
2021-10-08 12:31:12 +00:00
|
|
|
case csconfig.SEND_SIMULATED_DECISIONS:
|
|
|
|
/*for each flag check if it's already set before setting it*/
|
|
|
|
if csConfig.API.Server.ConsoleConfig.ShareSimulatedDecisions != nil {
|
|
|
|
if *csConfig.API.Server.ConsoleConfig.ShareSimulatedDecisions == wanted {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s already set to %t", csconfig.SEND_SIMULATED_DECISIONS, wanted)
|
2021-10-08 12:31:12 +00:00
|
|
|
} else {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s set to %t", csconfig.SEND_SIMULATED_DECISIONS, wanted)
|
2021-10-08 12:31:12 +00:00
|
|
|
*csConfig.API.Server.ConsoleConfig.ShareSimulatedDecisions = wanted
|
|
|
|
}
|
|
|
|
} else {
|
2021-10-08 12:44:36 +00:00
|
|
|
log.Infof("%s set to %t", csconfig.SEND_SIMULATED_DECISIONS, wanted)
|
2021-10-08 12:31:12 +00:00
|
|
|
csConfig.API.Server.ConsoleConfig.ShareSimulatedDecisions = types.BoolPtr(wanted)
|
|
|
|
}
|
2021-10-07 13:29:04 +00:00
|
|
|
default:
|
|
|
|
log.Fatalf("unknown flag %s", arg)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|