httpconv

var (
	// Common media types
	MediaTypeBytes    = mediatype.MustParse("application/octet-stream")
	MediaTypeJSON     = mediatype.MustParse("application/json")
	MediaTypeProtobuf = mediatype.MustParse("application/protobuf")
	MediaTypeText     = mediatype.MustParse("text/plain")

	ErrMessageTypeNotFound = errors.New("media type did not contain message type parameter")
)

var DefaultHTTPMapper = &HTTPMapper{
	DefaultHTTPMethod: http.MethodPost,
	ValueTypeResolver: func(tv *typedvalues.TypedValue) *mediatype.MediaType {

		if tv == nil {
			return MediaTypeBytes
		}

		if ct, ok := tv.GetMetadataValue(headerContentType); ok {
			mt, err := mediatype.Parse(ct)
			if err == nil {
				return mt
			}
		}

		switch tv.ValueType() {
		case typedvalues.TypeBytes:
			return MediaTypeBytes
		case typedvalues.TypeNil:
			return MediaTypeBytes
		case typedvalues.TypeString:
			return MediaTypeText
		}

		return MediaTypeJSON
	},
	MediaTypeResolver: func(mt *mediatype.MediaType) ParserFormatter {
		if mt == nil {
			return bytesMapper
		}

		switch mt.Identifier() {
		case MediaTypeJSON.String(), "text/json":
			return jsonMapper
		case MediaTypeText.String():
			return textMapper
		case MediaTypeBytes.String():
			return bytesMapper
		case MediaTypeProtobuf.String(), "application/vnd.google.protobuf", "application/x.google.protobuf",
			"application/x.protobuf":
			return protobufMapper
		}

		if mt.Type == "text" {
			return textMapper
		}

		if mt.Type == "application" {
			return bytesMapper
		}

		return bytesMapper
	},
}