mirror of
https://github.com/ipfs/kubo.git
synced 2026-02-26 12:57:44 +08:00
d1db95c447
Most of the removed options are many years old. In addition, they've all been removed in past iterations of Kubo. Some options were marked as removed in the config.md, but we still had a warning in the code to let users know they have been removed. I think it's been long enough for all of this options, and enough Kubo iterations in order to alert the users. It is good to keep it in the config.md for now so that people can actually check. However, I think it's time to remove them from the code itself.
34 lines
923 B
Go
34 lines
923 B
Go
package libp2p
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
|
|
"github.com/ipfs/kubo/config"
|
|
|
|
"github.com/libp2p/go-libp2p"
|
|
"github.com/libp2p/go-libp2p/p2p/muxer/yamux"
|
|
)
|
|
|
|
func makeSmuxTransportOption(tptConfig config.Transports) (libp2p.Option, error) {
|
|
if prefs := os.Getenv("LIBP2P_MUX_PREFS"); prefs != "" {
|
|
return nil, fmt.Errorf("configuring muxers with LIBP2P_MUX_PREFS is no longer supported, use Swarm.Transports.Multiplexers")
|
|
}
|
|
if tptConfig.Multiplexers.Yamux < 0 {
|
|
return nil, fmt.Errorf("running libp2p with Swarm.Transports.Multiplexers.Yamux disabled is not supported")
|
|
}
|
|
|
|
return libp2p.Muxer(yamux.ID, yamux.DefaultTransport), nil
|
|
}
|
|
|
|
func SmuxTransport(tptConfig config.Transports) func() (opts Libp2pOpts, err error) {
|
|
return func() (opts Libp2pOpts, err error) {
|
|
res, err := makeSmuxTransportOption(tptConfig)
|
|
if err != nil {
|
|
return opts, err
|
|
}
|
|
opts.Opts = append(opts.Opts, res)
|
|
return opts, nil
|
|
}
|
|
}
|