Function initCmd

cli/cmd/init.go:304–489

(cmd *cobra.Command, args []string)

}

func initCmd(cmd *cobra.Command, args []string) (initCommandError error) {
	ctx := cmd.Context()
	source, destination, specPath, acceptDefaults, disableAI, resumeConversation, disablePlatform, err := parseFlags(cmd)
	analytics.TrackInitStarted(ctx, invocationUUID.UUID, analytics.InitEvent{
		Source:         source,
		Destination:    destination,
		AcceptDefaults: acceptDefaults,
		SpecPath:       specPath,
		Error:          err,
	})
	defer func() {
		analytics.TrackInitCompleted(ctx, invocationUUID.UUID, analytics.InitEvent{
			Source:         source,
			Destination:    destination,
			AcceptDefaults: acceptDefaults,
			SpecPath:       specPath,
			Error:          initCommandError,
		})
	}()
	if err != nil {
		return err
	}

	authClient := cqauth.NewTokenClient()
	token, err := authClient.GetToken()
	var user *cqapi.User
	if err == nil {
		user, _ = auth.GetUser(cmd.Context(), token)
	}

	team, _ := auth.GetTeamForToken(cmd.Context(), token)

	// If the user has a CloudQuery Platform tenant (cloud login, or a
	// CQ_PLATFORM_TOKEN), scaffold a source-only spec that targets the platform
	// destination (auto-injected at sync time), skipping the destination prompt
	// and AI. --disable-platform opts out (normal source+destination spec); an
	// explicit --destination also takes the normal path.
	platformURL, platformTenant := "", false
	if !disablePlatform {
		platformURL, platformTenant = platform.DetectTenant(ctx, token.Value, team)
	}

	apiClient, err := api.NewAnonymousClient()
	var apiClientWithoutRetries *cqapi.ClientWithResponses
	if err != nil {
		return err
	}
	if user != nil {
		apiClient, err = api.NewClient(token.Value)
		if err != nil {
			return err
		}

		apiClientWithoutRetries, err = api.NewClient(token.Value, cqapi.WithHTTPClient(http.DefaultClient))
		if err != nil {
			return err
		}
	}