libp2p

type Addr interface {
	String() string
	Scheme() string
	User() string
	Host() string
	IsServer() bool
	UpdateUser(string)
	SetServer()
}

type Conn interface {
	// Read reads data from the connection.
	// Read can be made to time out and return an Error with Timeout() == true
	// after a fixed time limit; see SetDeadline and SetReadDeadline.
	Read(b []byte) (n int, err error)

	// Write writes data to the connection.
	// Write can be made to time out and return an Error with Timeout() == true
	// after a fixed time limit; see SetDeadline and SetWriteDeadline.
	Write(b []byte) (n int, err error)

	// Close closes the connection.
	// Any blocked Read or Write operations will be unblocked and return errors.
	Close() error

	// LocalAddr returns the local network address.
	LocalAddr() Addr

	// RemoteAddr returns the remote network address.
	RemoteAddr() Addr
}

type ConnPool interface {
	Listen(address string, handle func(conn Conn)) error
	Dial(address string) (Conn, error)
	// close the listener
	Close()
}

type ConnPoolMgr interface {
	RegConnPool(scheme string, c ConnPool)
	Listen(address string, handle func(conn Conn)) error
	Dial(address string) (Conn, error)
	// close the listener
	Close()
}

type CryptoMgr interface {
	SetPrivKey(typ string, key []byte) error
	GetType() string
	Sign(data []byte) []byte
	Verify(typ string, data, sig, pubKey []byte) bool
	Register(k SignKey)
	GetPublic() []byte
}

type Event interface {
	// encode by gob
	Reply(interface{}) error
	GetMessage() interface{}
	GetSession() Session
	GetPeerID() []byte
}

type IPlugin interface {
	// Callback for when the network starts listening for peers.
	Startup(net Network)

	// Callback for when the network stops listening for peers.
	Cleanup(net Network)

	// Callback for when an incoming message is received. Return true
	// if the plugin will intercept messages to be processed.
	Receive(e Event) error

	// RecInternalMsg receive internal message
	RecInternalMsg(InterMsg) error

	// Callback for when a peer connects to the network.
	PeerConnect(s Session)

	// Callback for when a peer disconnects from the network.
	PeerDisconnect(s Session)
}

type InterMsg interface {
	GetType() string
	GetMsg() interface{}
}

type Network interface {
	// address:  tcp://127.0.0.1:80
	NewSession(address string) (Session, error)
	RegistPlugin(IPlugin)
	SendInternalMsg(InterMsg)
	GetAddress() string
	Close()
}

type Plugin struct{}

type Session interface {
	// encode by gob
	Send(interface{}) error
	GetPeerAddr() Addr
	GetSelfAddr() Addr
	SetEnv(key, value string)
	GetEnv(key string) string
	Close()
}

type SignKey interface {
	GetType() string
	Verify(data, sig, pubKey []byte) bool
	// Cryptographically sign the given bytes
	Sign(data, privKey []byte) []byte
	// Return a public key paired with this private key
	GetPublic(privKey []byte) []byte
}