package appdash

import (
	"bytes"
	"encoding/json"
	"errors"
	"fmt"
	"strings"

	"github.com/tiancaiamao/appdash/internal/wire"
)

// A SpanID refers to a single span.
type SpanID struct {
	// Trace is the root ID of the tree that contains all of the spans
	// related to this one.
	Trace ID

	// Span is an ID that probabilistically uniquely identifies this
	// span.
	Span ID

	// Parent is the ID of the parent span, if any.
	Parent ID
}

var (
	// ErrBadSpanID is returned when the span ID cannot be parsed.
	ErrBadSpanID = errors.New("bad span ID")
)

// String returns the SpanID as a slash-separated, set of hex-encoded
// parameters (root, ID, parent). If the SpanID has no parent, that value is
// elided.
func (id SpanID) String() string {
	if id.Parent == 0 {
		return fmt.Sprintf("%s%s%s", id.Trace, SpanIDDelimiter, id.Span)
	}
	return fmt.Sprintf(
		"%s%s%s%s%s",
		id.Trace,
		SpanIDDelimiter,
		id.Span,
		SpanIDDelimiter,
		id.Parent,
	)
}

// Format formats according to a format specifier and returns the
// resulting string. The receiver's string representation is the first
// argument.
func (id SpanID) Format(s string, args ...interface{}) string {
	args = append([]interface{}{id.String()}, args...)
	return fmt.Sprintf(s, args...)
}

// IsRoot returns whether id is the root ID of a trace.
func (id SpanID) IsRoot() bool {
	return id.Parent == 0
}

// wire returns the span ID as it's protobuf definition.
func (id SpanID) wire() *wire.CollectPacket_SpanID {
	return &wire.CollectPacket_SpanID{
		Trace:  (*uint64)(&id.Trace),
		Span:   (*uint64)(&id.Span),
		Parent: (*uint64)(&id.Parent),
	}
}

// spanIDFromWire returns a SpanID from it's protobuf definition.
func spanIDFromWire(w *wire.CollectPacket_SpanID) SpanID {
	return SpanID{
		Trace:  ID(*w.Trace),
		Span:   ID(*w.Span),
		Parent: ID(*w.Parent),
	}
}

// NewRootSpanID generates a new span ID for a root span. This should
// only be used to generate entries for spans caused exclusively by
// spans which are outside of your system as a whole (e.g., a root
// span for the first time you see a user request).
func NewRootSpanID() SpanID {
	return SpanID{
		Trace: generateID(),
		Span:  generateID(),
	}
}

// NewSpanID returns a new ID for an span which is the child of the
// given parent ID. This should be used to track causal relationships
// between spans.
func NewSpanID(parent SpanID) SpanID {
	return SpanID{
		Trace:  parent.Trace,
		Span:   generateID(),
		Parent: parent.Span,
	}
}

const (
	// SpanIDDelimiter is the delimiter used to concatenate an
	// SpanID's components.
	SpanIDDelimiter = "/"
)

// ParseSpanID parses the given string as a slash-separated set of parameters.
func ParseSpanID(s string) (*SpanID, error) {
	parts := strings.Split(s, SpanIDDelimiter)
	if len(parts) != 2 && len(parts) != 3 {
		return nil, ErrBadSpanID
	}
	root, err := ParseID(parts[0])
	if err != nil {
		return nil, ErrBadSpanID
	}
	id, err := ParseID(parts[1])
	if err != nil {
		return nil, ErrBadSpanID
	}
	var parent ID
	if len(parts) == 3 {
		i, err := ParseID(parts[2])
		if err != nil {
			return nil, ErrBadSpanID
		}
		parent = i
	}
	return &SpanID{
		Trace:  root,
		Span:   id,
		Parent: parent,
	}, nil
}

// Span is a span ID and its annotations.
type Span struct {
	// ID probabilistically uniquely identifies this span.
	ID SpanID

	Annotations
}

// String returns the Span as a formatted string.
func (s *Span) String() string {
	b, err := json.MarshalIndent(s, "", "  ")
	if err != nil {
		panic(err)
	}
	return string(b)
}

// Name returns a span's name if it has a name annotation, and ""
// otherwise.
func (s *Span) Name() string {
	for _, ann := range s.Annotations {
		if ann.Key == "Name" {
			return string(ann.Value)
		}
	}
	return ""
}

// Annotations is a list of annotations (on a span).
type Annotations []Annotation

// An Annotation is an arbitrary key-value property on a span.
type Annotation struct {
	// Key is the annotation's key.
	Key string

	// Value is the annotation's value, which may be either human or
	// machine readable, depending on the schema of the event that
	// generated it.
	Value []byte
}

// Important determines if this annotation's key is considered important to any
// of the registered event types.
func (a Annotation) Important() bool {
	for _, ev := range registeredEvents {
		i, ok := ev.(ImportantEvent)
		if !ok {
			continue
		}
		for _, k := range i.Important() {
			if a.Key == k {
				return true
			}
		}
	}
	return false
}

// String returns a formatted list of annotations.
func (as Annotations) String() string {
	var buf bytes.Buffer
	for _, a := range as {
		fmt.Fprintf(&buf, "%s=%q\n", a.Key, a.Value)
	}
	return buf.String()
}

// schemas returns a list of schema types in the annotations.
func (as Annotations) schemas() []string {
	var schemas []string
	for _, a := range as {
		if strings.HasPrefix(a.Key, SchemaPrefix) {
			schemas = append(schemas, a.Key[len(SchemaPrefix):])
		}
	}
	return schemas
}

// get gets the value of the first annotation with the given key, or
// nil if none exists. There may be multiple annotations with the key;
// only the first's value is returned.
func (as Annotations) get(key string) []byte {
	for _, a := range as {
		if a.Key == key {
			return a.Value
		}
	}
	return nil
}

// StringMap returns the annotations as a key-value map. Only one
// annotation for a key appears in the map, and it is chosen
// arbitrarily among the annotations with the same key.
func (as Annotations) StringMap() map[string]string {
	m := make(map[string]string, len(as))
	for _, a := range as {
		m[a.Key] = string(a.Value)
	}
	return m
}

// wire returns the set of annotations as their protobuf definitions.
func (as Annotations) wire() (w []*wire.CollectPacket_Annotation) {
	for _, a := range as {
		// Important: Make a copy of a that we can retain a pointer to that
		// doesn't change after each iteration. Otherwise all wire annotations
		// would have the same key.
		cpy := a
		w = append(w, &wire.CollectPacket_Annotation{
			Key:   &cpy.Key,
			Value: cpy.Value,
		})
	}
	return
}

// annotationsFromWire returns Annotations from their protobuf definitions.
func annotationsFromWire(as []*wire.CollectPacket_Annotation) Annotations {
	var w Annotations
	for _, a := range as {
		w = append(w, Annotation{
			Key:   *a.Key,
			Value: a.Value,
		})
	}
	return w
}