natsio/client/communication.go

package client

import (
	"encoding/json"

	"git.selly.red/Selly-Modules/natsio"
	"git.selly.red/Selly-Modules/natsio/model"
	"git.selly.red/Selly-Modules/natsio/subject"
)

// Communication ...
type Communication struct{}

// GetCommunication ...
func GetCommunication() Communication {
	return Communication{}
}

// RequestHttp ...
func (c Communication) RequestHttp(p model.CommunicationRequestHttp) (r *model.CommunicationHttpResponse, err error) {
	msg, err := natsio.GetServer().Request(subject.Communication.RequestHTTP, toBytes(p))
	if err != nil {
		return nil, err
	}
	err = json.Unmarshal(msg.Data, &r)
	return r, err
}