imgproxy/vendor/github.com/newrelic/go-agent/internal/cat/appdata.go

package cat

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

	"github.com/newrelic/go-agent/internal/jsonx"
)

// AppDataHeader represents a decoded AppData header.
type AppDataHeader struct {
	CrossProcessID        string
	TransactionName       string
	QueueTimeInSeconds    float64
	ResponseTimeInSeconds float64
	ContentLength         int64
	TransactionGUID       string
}

var (
	errInvalidAppDataJSON                  = errors.New("invalid transaction data JSON")
	errInvalidAppDataCrossProcessID        = errors.New("cross process ID is not a string")
	errInvalidAppDataTransactionName       = errors.New("transaction name is not a string")
	errInvalidAppDataQueueTimeInSeconds    = errors.New("queue time is not a float64")
	errInvalidAppDataResponseTimeInSeconds = errors.New("response time is not a float64")
	errInvalidAppDataContentLength         = errors.New("content length is not a float64")
	errInvalidAppDataTransactionGUID       = errors.New("transaction GUID is not a string")
)

// MarshalJSON marshalls an AppDataHeader as raw JSON.
func (appData *AppDataHeader) MarshalJSON() ([]byte, error) {
	buf := bytes.NewBufferString("[")

	jsonx.AppendString(buf, appData.CrossProcessID)

	buf.WriteString(",")
	jsonx.AppendString(buf, appData.TransactionName)

	buf.WriteString(",")
	jsonx.AppendFloat(buf, appData.QueueTimeInSeconds)

	buf.WriteString(",")
	jsonx.AppendFloat(buf, appData.ResponseTimeInSeconds)

	buf.WriteString(",")
	jsonx.AppendInt(buf, appData.ContentLength)

	buf.WriteString(",")
	jsonx.AppendString(buf, appData.TransactionGUID)

	// The mysterious unused field. We don't need to round trip this, so we'll
	// just hardcode it to false.
	buf.WriteString(",false]")
	return buf.Bytes(), nil
}

// UnmarshalJSON unmarshalls an AppDataHeader from raw JSON.
func (appData *AppDataHeader) UnmarshalJSON(data []byte) error {
	var ok bool
	var v interface{}

	if err := json.Unmarshal(data, &v); err != nil {
		return err
	}

	arr, ok := v.([]interface{})
	if !ok {
		return errInvalidAppDataJSON
	}
	if len(arr) < 7 {
		return errUnexpectedArraySize{
			label:    "unexpected number of application data elements",
			expected: 7,
			actual:   len(arr),
		}
	}

	if appData.CrossProcessID, ok = arr[0].(string); !ok {
		return errInvalidAppDataCrossProcessID
	}

	if appData.TransactionName, ok = arr[1].(string); !ok {
		return errInvalidAppDataTransactionName
	}

	if appData.QueueTimeInSeconds, ok = arr[2].(float64); !ok {
		return errInvalidAppDataQueueTimeInSeconds
	}

	if appData.ResponseTimeInSeconds, ok = arr[3].(float64); !ok {
		return errInvalidAppDataResponseTimeInSeconds
	}

	cl, ok := arr[4].(float64)
	if !ok {
		return errInvalidAppDataContentLength
	}
	// Content length is specced as int32, but not all agents are consistent on
	// this in practice. Let's handle it as int64 to maximise compatibility.
	appData.ContentLength = int64(cl)

	if appData.TransactionGUID, ok = arr[5].(string); !ok {
		return errInvalidAppDataTransactionGUID
	}

	// As above, we don't bother decoding the unused field here. It just has to
	// be present (which was checked earlier with the length check).

	return nil
}