protocol

package

v1.0.0 Latest Latest Go to latest Published: Mar 7, 2022 License: MIT Imports: 16 Imported by: 0

Details

View Source

const (
	ID          = "/p2pdao/libp2p-proxy/1.0.0"
	ServiceName = "p2pdao.libp2p-proxy"
)

View Source

var Log = logging.Logger("libp2p-proxy")

func HttpHandler(bs *BufReaderStream)

func IsSocks5(v byte) bool

func Socks5Handler(bs *BufReaderStream)

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

func NewACL(cfg config.ACLConfig) (*ACLFilter, error)

func (a *ACLFilter) Allow(p peer.ID, addr ma.Multiaddr) bool

type BufReaderStream struct {
	network.Stream
	*bufio.Reader
}

func NewBufReaderStream(s network.Stream) *BufReaderStream

func (bs *BufReaderStream) Read(p []byte) (int, error)

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

func NewProxyService(ctx context.Context, h host.Host, acl *ACLFilter) *ProxyService

func (p *ProxyService) Handler(s network.Stream)

func (p *ProxyService) Serve(proxyAddr string, remotePeer peer.ID) error

func (p *ProxyService) Wait(fn func() error) error