communication

type Codec interface {
	Pack(payloadPtr interface{}) (data []byte, err error)
	Unpack(data []byte, payloadPtr interface{}) error
}

type Dialog interface {
	PeerID() identity.Identity
	Sender
	Receiver
	Close() error
}

type DialogEstablisher interface {
	EstablishDialog(peerID identity.Identity, peerContact market.Contact) (Dialog, error)
}

type DialogHandler interface {
	Handle(Dialog) error
}

type DialogWaiter interface {
	GetContact() market.Contact
	Start(DialogHandler) error
	Stop() error
}

type MessageConsumer interface {
	// GetMessageEndpoint returns endpoint where to receive messages
	GetMessageEndpoint() (MessageEndpoint, error)
	// NewMessage creates struct where message from endpoint will be serialized
	NewMessage() (messagePtr interface{})
	// Consume handles messages from endpoint
	Consume(messagePtr interface{}) error
}

type MessageEndpoint string

type MessageProducer interface {
	// GetMessageEndpoint returns endpoint where to send messages
	GetMessageEndpoint() (MessageEndpoint, error)
	// Produce creates message which will be serialized to endpoint
	Produce() (messagePtr interface{})
}

type Receiver interface {
	Receive(consumer MessageConsumer) error
	ReceiveUnsubscribe(endpoint MessageEndpoint)
	Respond(consumer RequestConsumer) error
	Unsubscribe()
}

type RequestConsumer interface {
	// GetRequestEndpoint returns endpoint where to receive requests
	GetRequestEndpoint() (RequestEndpoint, error)
	// NewRequest creates struct where request from endpoint will be serialized
	NewRequest() (requestPtr interface{})
	// Consume handles requests from endpoint and replies with response
	Consume(requestPtr interface{}) (responsePtr interface{}, err error)
}

type RequestEndpoint string

type RequestProducer interface {
	// GetRequestEndpoint returns endpoint where to send requests
	GetRequestEndpoint() (RequestEndpoint, error)
	// Produce creates request which will be serialized to endpoint
	Produce() (requestPtr interface{})
	// NewResponse creates struct where responses from endpoint will be serialized
	NewResponse() (responsePtr interface{})
}

type Sender interface {
	Send(producer MessageProducer) error
	Request(producer RequestProducer) (responsePtr interface{}, err error)
}