pgweb/pkg/client/result.go

package client

import (
	"bytes"
	"encoding/csv"
	"encoding/json"
	"fmt"
	"log"
	"math"
	"strconv"
	"time"

	"github.com/sosedoff/pgweb/pkg/command"
)

const (
	ObjTypeTable            = "table"
	ObjTypeView             = "view"
	ObjTypeMaterializedView = "materialized_view"
	ObjTypeSequence         = "sequence"
)

type (
	Row []interface{}

	Pagination struct {
		Rows    int64 `json:"rows_count"`
		Page    int64 `json:"page"`
		Pages   int64 `json:"pages_count"`
		PerPage int64 `json:"per_page"`
	}

	Result struct {
		Pagination *Pagination `json:"pagination,omitempty"`
		Columns    []string    `json:"columns"`
		Rows       []Row       `json:"rows"`
	}

	Objects struct {
		Tables            []string `json:"table"`
		Views             []string `json:"view"`
		MaterializedViews []string `json:"materialized_view"`
		Sequences         []string `json:"sequence"`
	}
)

// Due to big int number limitations in javascript, numbers should be encoded
// as strings so they could be properly loaded on the frontend.
func (res *Result) PostProcess() {
	for i, row := range res.Rows {
		for j, col := range row {
			if col == nil {
				continue
			}

			switch val := col.(type) {
			case int64:
				if val < -9007199254740991 || val > 9007199254740991 {
					res.Rows[i][j] = strconv.FormatInt(col.(int64), 10)
				}
			case float64:
				// json.Marshal panics when dealing with NaN/Inf values
				// issue: https://github.com/golang/go/issues/25721
				if math.IsNaN(val) {
					res.Rows[i][j] = nil
					break
				}

				if val < -999999999999999 || val > 999999999999999 {
					res.Rows[i][j] = strconv.FormatFloat(val, 'e', -1, 64)
				}
			case string:
				if hasBinary(val, 8) && BinaryCodec != CodecNone {
					res.Rows[i][j] = encodeBinaryData([]byte(val), BinaryCodec)
				}
			case time.Time:
				// RFC 3339 is clear that years are 4 digits exactly.
				// See golang.org/issue/4556#c15 for more discussion.
				if val.Year() < 0 || val.Year() >= 10000 {
					res.Rows[i][j] = "ERR: INVALID_DATE"
				} else {
					res.Rows[i][j] = val
				}
			}
		}
	}
}

func (res *Result) Format() []map[string]interface{} {
	var items []map[string]interface{}

	for _, row := range res.Rows {
		item := make(map[string]interface{})

		for i, c := range res.Columns {
			item[c] = row[i]
		}

		items = append(items, item)
	}

	return items
}

func (res *Result) CSV() []byte {
	buff := &bytes.Buffer{}
	writer := csv.NewWriter(buff)

	if err := writer.Write(res.Columns); err != nil {
		log.Printf("result csv write error: %v\n", err)
	}

	for _, row := range res.Rows {
		record := make([]string, len(res.Columns))

		for i, item := range row {
			if item != nil {
				switch v := item.(type) {
				case time.Time:
					record[i] = v.Format("2006-01-02 15:04:05")
				default:
					record[i] = fmt.Sprintf("%v", item)
				}
			} else {
				record[i] = ""
			}
		}

		err := writer.Write(record)

		if err != nil {
			fmt.Println(err)
			break
		}
	}

	writer.Flush()
	return buff.Bytes()
}

func (res *Result) JSON() []byte {
	var data []byte

	if command.Opts.DisablePrettyJSON {
		data, _ = json.Marshal(res.Format())
	} else {
		data, _ = json.MarshalIndent(res.Format(), "", " ")
	}

	return data
}

func ObjectsFromResult(res *Result) map[string]*Objects {
	objects := map[string]*Objects{}

	for _, row := range res.Rows {
		schema := row[0].(string)
		name := row[1].(string)
		objectType := row[2].(string)

		if objects[schema] == nil {
			objects[schema] = &Objects{
				Tables:            []string{},
				Views:             []string{},
				MaterializedViews: []string{},
				Sequences:         []string{},
			}
		}

		switch objectType {
		case ObjTypeTable:
			objects[schema].Tables = append(objects[schema].Tables, name)
		case ObjTypeView:
			objects[schema].Views = append(objects[schema].Views, name)
		case ObjTypeMaterializedView:
			objects[schema].MaterializedViews = append(objects[schema].MaterializedViews, name)
		case ObjTypeSequence:
			objects[schema].Sequences = append(objects[schema].Sequences, name)
		}
	}

	return objects
}