39 lines
1.3 KiB
Go
39 lines
1.3 KiB
Go
package lp2p
|
|
|
|
import (
|
|
"github.com/libp2p/go-libp2p"
|
|
metrics "github.com/libp2p/go-libp2p-core/metrics"
|
|
libp2pquic "github.com/libp2p/go-libp2p-quic-transport"
|
|
secio "github.com/libp2p/go-libp2p-secio"
|
|
tls "github.com/libp2p/go-libp2p-tls"
|
|
)
|
|
|
|
var DefaultTransports = simpleOpt(libp2p.DefaultTransports)
|
|
var QUIC = simpleOpt(libp2p.Transport(libp2pquic.NewTransport))
|
|
|
|
func Security(enabled, preferTLS bool) interface{} {
|
|
if !enabled {
|
|
return func() (opts Libp2pOpts) {
|
|
// TODO: shouldn't this be Errorf to guarantee visibility?
|
|
log.Warnf(`Your lotus node has been configured to run WITHOUT ENCRYPTED CONNECTIONS.
|
|
You will not be able to connect to any nodes configured to use encrypted connections`)
|
|
opts.Opts = append(opts.Opts, libp2p.NoSecurity)
|
|
return opts
|
|
}
|
|
}
|
|
return func() (opts Libp2pOpts) {
|
|
if preferTLS {
|
|
opts.Opts = append(opts.Opts, libp2p.ChainOptions(libp2p.Security(tls.ID, tls.New), libp2p.Security(secio.ID, secio.New)))
|
|
} else {
|
|
opts.Opts = append(opts.Opts, libp2p.ChainOptions(libp2p.Security(secio.ID, secio.New), libp2p.Security(tls.ID, tls.New)))
|
|
}
|
|
return opts
|
|
}
|
|
}
|
|
|
|
func BandwidthCounter() (opts Libp2pOpts, reporter metrics.Reporter) {
|
|
reporter = metrics.NewBandwidthCounter()
|
|
opts.Opts = append(opts.Opts, libp2p.BandwidthReporter(reporter))
|
|
return opts, reporter
|
|
}
|