model

type BrokerDestinationConfig struct {
	Destination  string
	ConnectionId string
}

type Direction int

type Message struct {
	Id            *uuid.UUID      `json:"id"`            // message identifier
	DestinationId *uuid.UUID      `json:"destinationId"` // destinationId (targeted recipient)
	Channel       string          `json:"channel"`       // reference to channel message was sent on.
	Destination   string          `json:"destination"`   // destination message was sent to (if galactic)
	Payload       interface{}     `json:"payload"`
	Error         error           `json:"error"`
	Direction     Direction       `json:"direction"`
	Headers       []MessageHeader `json:"headers"`
}

type MessageConfig struct {
	Id            *uuid.UUID
	DestinationId *uuid.UUID
	Destination   string
	Channel       string
	Payload       interface{}
	Headers       []MessageHeader
	Direction     Direction
	Err           error
}

type MessageHeader struct {
	Label string
	Value string
}

type Request struct {
	Id                 *uuid.UUID          `json:"id,omitempty"`
	Destination        string              `json:"channel,omitempty"`
	Payload            interface{}         `json:"payload,omitempty"`
	RequestCommand     string              `json:"request,omitempty" mapstructure:"request"`
	HttpRequest        *http.Request       `json:"-"`
	HttpResponseWriter http.ResponseWriter `json:"-"`
	// Populated if the request was sent on a "private" channel and
	// indicates where to send back the Response.
	// A service should check this field and if not null copy it to the
	// Response.BrokerDestination field to ensure that the response will be sent
	// back on the correct the "private" channel.
	BrokerDestination *BrokerDestinationConfig `json:"-"`
}

type Response struct {
	Id             *uuid.UUID  `json:"id,omitempty"`
	Destination    string      `json:"channel,omitempty"`
	Payload        interface{} `json:"payload,omitempty"`
	HttpStatusCode int         `json:"httpStatusCode,omitempty"`
	Error          bool        `json:"error,omitempty"`
	ErrorCode      int         `json:"errorCode,omitempty"`
	ErrorMessage   string      `json:"errorMessage,omitempty"`
	ErrorObject    interface{} `json:"errorObject,omitempty"`
	// If populated the response will be sent to a single client
	// on the specified destination topic.
	BrokerDestination *BrokerDestinationConfig `json:"-"`
	Headers           map[string]interface{}   `json:"-"` // passthrough any http headers
	Marshal           bool                     `json:"-"` // if true, the payload be marshalled into JSON.
}

type ResponseHandlerFunction func(*Response)

type StoreContentResponse struct {
	Items        map[string]interface{} `json:"items"`
	ResponseType string                 `json:"responseType"` // should be "storeContentResponse"
	StoreId      string                 `json:"storeId"`
	StoreVersion int64                  `json:"storeVersion"`
}

type UpdateStoreResponse struct {
	ItemId       string      `json:"itemId"`
	NewItemValue interface{} `json:"newItemValue"`
	ResponseType string      `json:"responseType"` // should be "updateStoreResponse"
	StoreId      string      `json:"storeId"`
	StoreVersion int64       `json:"storeVersion"`
}