// Copyright 2019 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package event

import (
	"fmt"
	"io"
	"strconv"
)

//TODO: some actual research into what this arbritray optimization number should be
const bufCap = 50

type printer struct {
	io.Writer
	io.StringWriter

	buf [bufCap]byte
}

type stringWriter struct {
	io.Writer
}

// Printer returns a handler that prints the events to the supplied writer.
// Each event is printed in logfmt format on a single line.
func Printer(to io.Writer) Handler {
	return newPrinter(to)
}

func newPrinter(to io.Writer) *printer {
	p := &printer{Writer: to}
	ok := false
	p.StringWriter, ok = to.(io.StringWriter)
	if !ok {
		p.StringWriter = &stringWriter{to}
	}
	return p
}

// Handle makes printer implement the Handler interface so it can be used
// directly to print all handled events.
func (p *printer) Handle(ev *Event) {
	p.Event(ev)
	p.WriteString("\n")
}

func (p *printer) Event(ev *Event) {
	const timeFormat = "2006-01-02T15:04:05"
	if !ev.At.IsZero() {
		p.WriteString("time=")
		p.Write(ev.At.AppendFormat(p.buf[:0], timeFormat))
		p.WriteString(" ")
	}

	p.WriteString("id=")
	p.Write(strconv.AppendUint(p.buf[:0], ev.ID, 10))
	if ev.Parent != 0 {
		p.WriteString(" span=")
		p.Write(strconv.AppendUint(p.buf[:0], ev.Parent, 10))
	}

	p.WriteString(" kind=")
	p.Kind(ev.Kind)

	if ev.Message != "" {
		p.WriteString(" msg=")
		p.Quote(ev.Message)
	}

	for _, l := range ev.Labels {
		if l.Name == "" {
			continue
		}
		p.WriteString(" ")
		p.Label(&l)
	}
}

func (p *printer) Kind(k Kind) {
	switch k {
	case LogKind:
		p.WriteString("log")
	case StartKind:
		p.WriteString("start")
	case EndKind:
		p.WriteString("end")
	case MetricKind:
		p.WriteString("metric")
	case AnnotateKind:
		p.WriteString("annotate")
	default:
		p.Write(strconv.AppendUint(p.buf[:0], uint64(k), 10))
	}
}

func (p *printer) Label(l *Label) {
	p.Ident(l.Name)
	p.WriteString("=")
	p.Value(&l.Value)
}

func (p *printer) Value(v *Value) {
	switch {
	case v.IsString():
		p.Quote(v.String())
	case v.IsInt64():
		p.Write(strconv.AppendInt(p.buf[:0], v.Int64(), 10))
	case v.IsUint64():
		p.Write(strconv.AppendUint(p.buf[:0], v.Uint64(), 10))
	case v.IsFloat64():
		p.Write(strconv.AppendFloat(p.buf[:0], v.Float64(), 'g', -1, 64))
	case v.IsBool():
		if v.Bool() {
			p.WriteString("true")
		} else {
			p.WriteString("false")
		}
	default:
		fmt.Fprint(p, v.Interface())
	}
}

func (p *printer) Ident(s string) {
	//TODO: this should also escape = if it occurs in an ident?
	p.Quote(s)
}

func (p *printer) Quote(s string) {
	if s == "" {
		p.WriteString(`""`)
		return
	}
	if !needQuote(s) {
		p.WriteString(s)
		return
	}
	// string needs quoting
	p.WriteString(`"`)
	written := 0
	for o, r := range s {
		q := quoteRune(r)
		if len(q) == 0 {
			continue
		}
		// write out any prefix
		p.WriteString(s[written:o])
		written = o + 1 // we can plus 1 because all runes we escape are ascii
		// and write out the quoted rune
		p.WriteString(q)
	}
	p.WriteString(s[written:])
	p.WriteString(`"`)
}

func needQuote(s string) bool {
	for _, r := range s {
		if len(quoteRune(r)) > 0 {
			return true
		}
	}
	return false
}

func quoteRune(r rune) string {
	switch r {
	case '"':
		return `\"`
	case ' ':
		return ` ` // does not change but forces quoting
	case '\n':
		return `\n`
	case '\\':
		return `\\`
	default:
		return ``
	}
}

func (w *stringWriter) WriteString(s string) (int, error) {
	return w.Write([]byte(s))
}