mirror of
https://github.com/ipfs/kubo.git
synced 2026-02-23 11:27:42 +08:00
52c177ced9
* plumb through go-datastore context changes * update go-libp2p to v0.16.0 * use LIBP2P_TCP_REUSEPORT instead of IPFS_REUSEPORT * use relay config * making deprecation notice match the go-ipfs-config key * docs(config): circuit relay v2 * docs(config): fix links and headers * feat(config): Internal.Libp2pForceReachability This switches to config that supports setting and reading Internal.Libp2pForceReachability OptionalString flag * use configuration option for static relays * chore: go-ipfs-config v0.18.0 https://github.com/ipfs/go-ipfs-config/releases/tag/v0.18.0 * feat: circuit v1 migration prompt when Swarm.EnableRelayHop is set (#8559) * exit when Swarm.EnableRelayHop is set * docs: Experimental.ShardingEnabled migration This ensures existing users of global sharding experiment get notified that the flag no longer works + that autosharding happens automatically. For people who NEED to keep the old behavior (eg. have no time to migrate today) there is a note about restoring it with `UnixFSShardingSizeThreshold`. * chore: add dag-jose code to the cid command output * add support for setting automatic unixfs sharding threshold from the config * test: have tests use low cutoff for sharding to mimic old behavior * test: change error message to match the current error * test: Add automatic sharding/unsharding tests (#8547) * test: refactored naming in the sharding sharness tests to make more sense * ci: set interop test executor to convenience image for Go1.16 + Node * ci: use interop master Co-authored-by: Marcin Rataj <lidel@lidel.org> Co-authored-by: Marten Seemann <martenseemann@gmail.com> Co-authored-by: Marcin Rataj <lidel@lidel.org> Co-authored-by: Gus Eggert <gus@gus.dev> Co-authored-by: Lucas Molas <schomatis@gmail.com>
100 lines
2.4 KiB
Go
100 lines
2.4 KiB
Go
package libp2p
|
|
|
|
import (
|
|
"fmt"
|
|
"sort"
|
|
"time"
|
|
|
|
version "github.com/ipfs/go-ipfs"
|
|
config "github.com/ipfs/go-ipfs-config"
|
|
|
|
logging "github.com/ipfs/go-log"
|
|
"github.com/libp2p/go-libp2p"
|
|
connmgr "github.com/libp2p/go-libp2p-connmgr"
|
|
"github.com/libp2p/go-libp2p-core/crypto"
|
|
"github.com/libp2p/go-libp2p-core/peer"
|
|
"github.com/libp2p/go-libp2p-core/peerstore"
|
|
"go.uber.org/fx"
|
|
)
|
|
|
|
var log = logging.Logger("p2pnode")
|
|
|
|
type Libp2pOpts struct {
|
|
fx.Out
|
|
|
|
Opts []libp2p.Option `group:"libp2p"`
|
|
}
|
|
|
|
// Misc options
|
|
var UserAgent = simpleOpt(libp2p.UserAgent(version.GetUserAgentVersion()))
|
|
|
|
func ConnectionManager(low, high int, grace time.Duration) func() (opts Libp2pOpts, err error) {
|
|
return func() (opts Libp2pOpts, err error) {
|
|
cm := connmgr.NewConnManager(low, high, grace)
|
|
opts.Opts = append(opts.Opts, libp2p.ConnectionManager(cm))
|
|
return
|
|
}
|
|
}
|
|
|
|
func PstoreAddSelfKeys(id peer.ID, sk crypto.PrivKey, ps peerstore.Peerstore) error {
|
|
if err := ps.AddPubKey(id, sk.GetPublic()); err != nil {
|
|
return err
|
|
}
|
|
|
|
return ps.AddPrivKey(id, sk)
|
|
}
|
|
|
|
func simpleOpt(opt libp2p.Option) func() (opts Libp2pOpts, err error) {
|
|
return func() (opts Libp2pOpts, err error) {
|
|
opts.Opts = append(opts.Opts, opt)
|
|
return
|
|
}
|
|
}
|
|
|
|
type priorityOption struct {
|
|
priority, defaultPriority config.Priority
|
|
opt libp2p.Option
|
|
}
|
|
|
|
func prioritizeOptions(opts []priorityOption) libp2p.Option {
|
|
type popt struct {
|
|
priority int64
|
|
opt libp2p.Option
|
|
}
|
|
enabledOptions := make([]popt, 0, len(opts))
|
|
for _, o := range opts {
|
|
if prio, ok := o.priority.WithDefault(o.defaultPriority); ok {
|
|
enabledOptions = append(enabledOptions, popt{
|
|
priority: prio,
|
|
opt: o.opt,
|
|
})
|
|
}
|
|
}
|
|
sort.Slice(enabledOptions, func(i, j int) bool {
|
|
return enabledOptions[i].priority > enabledOptions[j].priority
|
|
})
|
|
p2pOpts := make([]libp2p.Option, len(enabledOptions))
|
|
for i, opt := range enabledOptions {
|
|
p2pOpts[i] = opt.opt
|
|
}
|
|
return libp2p.ChainOptions(p2pOpts...)
|
|
}
|
|
|
|
func ForceReachability(val *config.OptionalString) func() (opts Libp2pOpts, err error) {
|
|
return func() (opts Libp2pOpts, err error) {
|
|
if val.IsDefault() {
|
|
return
|
|
}
|
|
v := val.WithDefault("unrecognized")
|
|
switch v {
|
|
case "public":
|
|
opts.Opts = append(opts.Opts, libp2p.ForceReachabilityPublic())
|
|
case "private":
|
|
opts.Opts = append(opts.Opts, libp2p.ForceReachabilityPrivate())
|
|
default:
|
|
return opts, fmt.Errorf("unrecognized reachability option: %s", v)
|
|
}
|
|
return
|
|
}
|
|
}
|