p2p

type Channel interface {
	ChannelSender
	ChannelHandler

	// Tracer returns tracer which tracks channel establishment
	Tracer() *trace.Tracer

	// ServiceConn returns UDP connection which can be used for services.
	ServiceConn() *net.UDPConn

	// Conn returns underlying channel's UDP connection.
	Conn() *net.UDPConn

	// Close closes p2p communication channel.
	Close() error

	// Unique ID
	ID() string
}

type ChannelHandler interface {
	// Handle registers handler for given topic which handles peer request.
	Handle(topic string, handler HandlerFunc)
}

type ChannelSender interface {
	// Send sends message to given topic. Peer listening to topic will receive message.
	Send(ctx context.Context, topic string, msg *Message) (*Message, error)
}

type ContactDefinition struct {
	BrokerAddresses []string `json:"broker_addresses"`
}

type Context interface {
	// Request returns message with data bytes.
	Request() *Message

	// Error allows to return error which will be seen for peer.
	Error(err error) error

	// OkWithReply indicates that request was handled successfully and returns reply with given message.
	OkWithReply(msg *Message) error

	// Ok indicates that request was handled successfully
	OK() error

	// PeerID returns peer identity used to authenticate P2P channel
	PeerID() identity.Identity
}

type Dialer interface {
	// Dial exchanges p2p configuration via broker, performs NAT pinging if needed
	// and create p2p channel which is ready for communication.
	Dial(ctx context.Context, consumerID, providerID identity.Identity, serviceType string, contactDef ContactDefinition, tracer *trace.Tracer) (Channel, error)
}

type HandlerFunc func(c Context) error

type Listener interface {
	// Listen listens for incoming peer connections to establish new p2p channels. Establishes p2p channel and passes it
	// to channelHandlers
	Listen(providerID identity.Identity, serviceType string, channelHandler func(ch Channel)) (func(), error)

	// GetContact returns contract which is later can be added to proposal contacts definition so consumer can
	// know how to connect to this p2p listener.
	GetContact() market.Contact
}

type Message struct {
	Data []byte
}

type PrivateKey [32]byte

type PublicKey [keySize]byte

type STUNDetectionStatus struct {
	Identity string
	NATType  string
}