udphp

type Client interface {
	WasKeySent(string) bool
	SetKeySent(string, bool)
	WasKeyReceived(string) bool
	SetKeyReceived(string, bool)
	GetServer() Server
	GetSelf() *Peer
	GetPeer(id string) (*Peer, error)
	SetPeer(*Peer)
	GetPeerConn(id string) (Connection, error)
	SetPeerConn(string, Connection)
	GetServerConn() Connection
	SetServerConn(Connection)
	Connect(id string) error
	Stop()
	Start() error
	RegisteredCallback()
	ConnectingCallback()
	ConnectedCallback()
	OnRegistered(func(Client))
	OnConnecting(func(Client))
	OnConnected(func(Client))
	Handle(handler *Handler)
}

type Connection interface {
	Send(message Message) error
	GetAddr() net.Addr
	GetSecret() ([]byte, error)
	SetSecret([]byte)
}

type Connections map[string]Connection

type Handler struct {
	// contains filtered or unexported fields
}

type HandlerFunc func(ctx context.Context, serverConnection Connection, req Message) (Message, error)

type Message interface {
	GetPath() string
	GetPeerID() string
	GetError() error
	GetHeader(string) (string, error)
	RawBody() []byte
	GetAddr() net.Addr
	SetAddr(net.Addr)
	Bytes() []byte
}

type Peer struct {
	ID         string `json:"id"`
	PublicKey  []byte `json:"public_key"`
	PrivateKey []byte `json:"-"`
	Addr       *net.UDPAddr
}

type PeerMemoryRepository struct {
	// contains filtered or unexported fields
}

type PeerRepository interface {
	Create(ctx context.Context, peer *Peer) error
	GetAll(ctx context.Context) ([]*Peer, error)
	Get(ctx context.Context, id string) (*Peer, error)
	Remove(ctx context.Context, id string) error
}

type Server interface {
	Stop()
	Listen()
	CreateConnection(addr net.Addr) (Connection, error)
	Handle(handler *Handler)
	PeerRepository(repository PeerRepository)
}

type UDPClient struct {
	// contains filtered or unexported fields
}

type UDPConnection struct {
	// contains filtered or unexported fields
}

type UDPMessage struct {
	Path    string            `json:"path"`
	PeerID  string            `json:"peerID"`
	Error   string            `json:"error"`
	Headers map[string]string `json:"headers"`
	Body    []byte            `json:"body"`
	Addr    *net.UDPAddr
}

type UDPServer struct {
	// contains filtered or unexported fields
}