Function queryCAPIStatus

cmd/crowdsec-cli/clicapi/capi.go:168–214

queryCAPIStatus checks if the Central API is reachable, and if the credentials are correct. It then checks if the instance is enrolled in the console.

(ctx context.Context, db *database.Client, hub *cwhub.Hub, credURL string, login string, password string)

// queryCAPIStatus checks if the Central API is reachable, and if the credentials are correct. It then checks if the instance is enrolled in the console.
func queryCAPIStatus(ctx context.Context, db *database.Client, hub *cwhub.Hub, credURL string, login string, password string) (capiStatus, error) {
	apiURL, err := url.Parse(credURL)
	if err != nil {
		return capiStatus{}, err
	}

	itemsForAPI := hub.GetInstalledListForAPI()

	passwd := strfmt.Password(password)

	client := apiclient.NewClient(&apiclient.Config{
		MachineID: login,
		Password:  passwd,
		URL:       apiURL,
		// I don't believe papi is needed to check enrollement
		// PapiURL:       papiURL,
		VersionPrefix: "v3",
		UpdateScenario: func(_ context.Context) ([]string, error) {
			return itemsForAPI, nil
		},
	})

	pw := strfmt.Password(password)

	t := models.WatcherAuthRequest{
		MachineID: &login,
		Password:  &pw,
		Scenarios: itemsForAPI,
	}

	authResp, _, err := client.Auth.AuthenticateWatcher(ctx, t)
	if err != nil {
		return capiStatus{}, err
	}

	if err := db.SaveAPICToken(ctx, authResp.Token); err != nil {
		return capiStatus{}, err
	}

	client.GetClient().Transport.(*apiclient.JWTTransport).Token = authResp.Token

	if client.IsEnrolled() {
		return capiStatus{true, true, client.GetSubscriptionType()}, nil
	}

	return capiStatus{true, false, ""}, nil
}

func (cli *cliCapi) Status(ctx context.Context, db *database.Client, out io.Writer, hub *cwhub.Hub) error {
	cfg := cli.cfg()