Method Run

internal/cmd/searchconsole.go:137–204

(ctx context.Context, flags *RootFlags)

}

func (c *SearchConsoleQueryCmd) Run(ctx context.Context, flags *RootFlags) error {
	u := ui.FromContext(ctx)
	account, err := requireAccount(flags)
	if err != nil {
		return err
	}

	plan, err := c.plan(stdinReader(ctx))
	if err != nil {
		return err
	}

	svc, err := searchConsoleService(ctx, account)
	if err != nil {
		return err
	}
	resp, err := svc.Searchanalytics.Query(plan.SiteURL, plan.Request).Context(ctx).Do()
	if err != nil {
		return wrapSearchConsoleError(err)
	}

	if outfmt.IsJSON(ctx) {
		if err := outfmt.WriteJSON(ctx, stdoutWriter(ctx), map[string]any{
			"site_url":                  plan.SiteURL,
			"from":                      plan.Request.StartDate,
			"to":                        plan.Request.EndDate,
			"type":                      plan.queryType(),
			"dimensions":                plan.Request.Dimensions,
			"response_aggregation_type": resp.ResponseAggregationType,
			"rows":                      resp.Rows,
		}); err != nil {
			return err
		}
		if len(resp.Rows) == 0 {
			return failEmptyExit(c.FailEmpty)
		}
		return nil
	}

	if len(resp.Rows) == 0 {
		u.Err().Println("No Search Console rows")
		return failEmptyExit(c.FailEmpty)
	}

	headers := requestSearchConsoleDimensions(plan.Request, resp.Rows)
	headers = append(headers, "CLICKS", "IMPRESSIONS", "CTR", "POSITION")

	w, flush := tableWriter(ctx)
	defer flush()
	fmt.Fprintln(w, strings.Join(headers, "\t"))
	for _, row := range resp.Rows {
		if row == nil {
			continue
		}
		values := make([]string, 0, len(headers))
		for i := range headers[:len(headers)-4] {
			values = append(values, sanitizeTab(searchConsoleKey(row, i)))
		}