// Package mock 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" delay "github.com/ipfs/go-ipfs/thirdparty/delay" "gx/ipfs/QmWRCn8vruNAzHx8i6SAXinuheRitKEGu8c7m26stKvsYx/go-testutil" routing "gx/ipfs/QmPR2JzfKd9poHx9XBhzoFeBBC31ZM3W5iUPKJZWyaoZZm/go-libp2p-routing" ds "gx/ipfs/QmVSase1JP7cq9QkPT46oNwdp9pT6kBkG3oqS14y3QcZjG/go-datastore" peer "gx/ipfs/QmXYjuNuxVzXKJCfWasQk1RqkhVLDM9jtUKhqc2WPQmFSB/go-libp2p-peer" ) // 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, } } 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 }