Method PrintQueryResponse

cli/pkg/printer/resources.go:815–873

PrintQueryResponse prints the query response in the desired format (human, json, csv)

(res *runtimev1.QueryResolverResponse)

// PrintQueryResponse prints the query response in the desired format (human, json, csv)
func (p *Printer) PrintQueryResponse(res *runtimev1.QueryResolverResponse) {
	if len(res.Data) == 0 {
		p.PrintfWarn("No data found\n")
		return
	}

	switch p.Format {
	// Interceptor for human format
	case FormatHuman:
		headers := extractQueryHeaders(res.Schema)
		rows := make([][]string, len(res.Data))

		for i, row := range res.Data {
			rows[i] = make([]string, len(headers))
			for j, field := range headers {
				if val, ok := row.GetFields()[field]; ok {
					rows[i][j] = p.FormatValue(val.AsInterface())
				} else {
					rows[i][j] = "null"
				}
			}
		}

		tableprinter.New(p.dataOut()).Render(headers, rows, nil, false)
		return

	// Interceptor for CSV format
	case FormatCSV:
		headers := extractQueryHeaders(res.Schema)
		w := csv.NewWriter(p.dataOut())

		if err := w.Write(headers); err != nil {
			panic(fmt.Errorf("failed to write CSV headers: %w", err))
		}

		for _, row := range res.Data {
			record := make([]string, len(headers))
			for i, field := range headers {
				if val, ok := row.GetFields()[field]; ok {
					record[i] = p.FormatValue(val.AsInterface())
				} else {
					record[i] = ""
				}
			}
			if err := w.Write(record); err != nil {
				panic(fmt.Errorf("failed to write CSV row: %w", err))
			}
		}

		w.Flush()
		if err := w.Error(); err != nil {
			panic(fmt.Errorf("failed to flush CSV writer: %w", err))
		}

		return
	default:
		p.PrintData(res.Data)
	}