// Package mockrouting provides a virtual routing server. To use it, // create a virtual routing server and use the Client() method to get a // routing client (IpfsRouting). The server quacks like a DHT but is // really a local in-memory hash table. package mockrouting import ( "context" ds "github.com/ipfs/go-datastore" delay "github.com/ipfs/go-ipfs-delay" peer "github.com/libp2p/go-libp2p-peer" routing "github.com/libp2p/go-libp2p-routing" "github.com/libp2p/go-testutil" ) // Server provides mockrouting Clients type Server interface { Client(p testutil.Identity) Client ClientWithDatastore(context.Context, testutil.Identity, ds.Datastore) Client } // Client implements IpfsRouting type Client interface { routing.IpfsRouting } // NewServer returns a mockrouting Server func NewServer() Server { return NewServerWithDelay(DelayConfig{ ValueVisibility: delay.Fixed(0), Query: delay.Fixed(0), }) } // NewServerWithDelay returns a mockrouting Server with a delay! func NewServerWithDelay(conf DelayConfig) Server { return &s{ providers: make(map[string]map[peer.ID]providerRecord), delayConf: conf, } } // DelayConfig can be used to configured the fake delays of a mock server. // Use with NewServerWithDelay(). type DelayConfig struct { // ValueVisibility is the time it takes for a value to be visible in the network // FIXME there _must_ be a better term for this ValueVisibility delay.D // Query is the time it takes to receive a response from a routing query Query delay.D }