docs/delegated-routing.md
[!IMPORTANT] Most users are best served by setting delegated HTTP router URLs in
Routing.DelegatedRoutersandRouting.Typetoautoorautoclient, rather than using custom routing withRouting.RoutersandRouting.Methodsdirectly.The rest of this documentation describes experimental features intended only for researchers and advanced users.
[!CAUTION]
Routing.Type=customwithRouting.RoutersandRouting.Methodsis EXPERIMENTAL.This feature is provided for research and testing purposes only. It is not suitable for production use.
- The configuration format and behavior may change without notice between Kubo releases.
- Bugs and regressions affecting custom routing may not be prioritized or fixed promptly.
- HTTP-only routing configurations (without DHT) cannot reliably provide content to the network (👉️ see Limitations below).
For production deployments, use
Routing.Type=auto(default) orRouting.Type=autoclientwithRouting.DelegatedRouters.
The actual routing implementation is not enough. Some users need to have more options when configuring the routing system. The new implementations should be able to:
The Routing configuration section will contain the following keys:
Type will be still in use to avoid complexity for the user that only wants to use Kubo with the default behavior. We are going to add a new type, custom, that will use the new router systems. none type will deactivate all routers, default dht and delegated ones.
Routers will be a key-value list of routers that will be available to use. The key is the router name and the value is all the needed configurations for that router. the Type will define the routing kind. The main router types will be http and dht, but we will implement two special routers used to execute a set of routers in parallel or sequentially: parallel router and sequential router.
Depending on the routing type, it will use different parameters:
Params:
"Endpoint": URL of HTTP server with endpoints that implement Delegated Routing V1 HTTP API protocol.Params:
"Mode": Mode used by the Amino DHT. Possible values: "server", "client", "auto""AcceleratedDHTClient": Set to true if you want to use the experimentalDHT."PublicIPNetwork": Set to true to create a WAN Amino DHT. Set to false to create a LAN DHT.Params:
Routers: A list of routers that will be executed in parallel:
Name:string: Name of the router. It should be one of the previously added to Routers list.Timeout:duration: Local timeout. It accepts strings compatible with Go time.ParseDuration(string). Time will start counting when this specific router is called, and it will stop when the router returns, or we reach the specified timeout.ExecuteAfter:duration: Providing this param will delay the execution of that router at the specified time. It accepts strings compatible with Go time.ParseDuration(string).IgnoreErrors:bool: It will specify if that router should be ignored if an error occurred.Timeout:duration: Global timeout. It accepts strings compatible with Go time.ParseDuration(string).Params:
Routers: A list of routers that will be executed in order:
Name:string: Name of the router. It should be one of the previously added to Routers list.Timeout:duration: Local timeout. It accepts strings compatible with Go time.ParseDuration(string). Time will start counting when this specific router is called, and it will stop when the router returns, or we reach the specified timeout.IgnoreErrors:bool: It will specify if that router should be ignored if an error occurred.Timeout:duration: Global timeout. It accepts strings compatible with Go time.ParseDuration(string).Methods:map will define which routers will be executed per method. The key will be the name of the method: "provide", "find-providers", "find-peers", "put-ipns", "get-ipns". All methods must be added to the list. This will make configuration discoverable giving good errors to the user if a method is missing.
The value will contain:
RouterName:string: Name of the router. It should be one of the previously added to Routers list."Routing": {
"Type": "custom",
"Routers": {
"http-delegated": {
"Type": "http",
"Parameters": {
"Endpoint": "https://delegated-ipfs.dev" // /routing/v1 (https://specs.ipfs.tech/routing/http-routing-v1/)
}
},
"dht-lan": {
"Type": "dht",
"Parameters": {
"Mode": "server",
"PublicIPNetwork": false,
"AcceleratedDHTClient": false
}
},
"dht-wan": {
"Type": "dht",
"Parameters": {
"Mode": "auto",
"PublicIPNetwork": true,
"AcceleratedDHTClient": false
}
},
"find-providers-router": {
"Type": "parallel",
"Parameters": {
"Routers": [
{
"RouterName": "dht-lan",
"IgnoreErrors": true
},
{
"RouterName": "dht-wan"
},
{
"RouterName": "http-delegated"
}
]
}
},
"provide-router": {
"Type": "parallel",
"Parameters": {
"Routers": [
{
"RouterName": "dht-lan",
"IgnoreErrors": true
},
{
"RouterName": "dht-wan",
"ExecuteAfter": "100ms",
"Timeout": "100ms"
},
{
"RouterName": "http-delegated",
"ExecuteAfter": "100ms"
}
]
}
},
"get-ipns-router": {
"Type": "sequential",
"Parameters": {
"Routers": [
{
"RouterName": "dht-lan",
"IgnoreErrors": true
},
{
"RouterName": "dht-wan",
"Timeout": "300ms"
},
{
"RouterName": "http-delegated",
"Timeout": "300ms"
}
]
}
},
"put-ipns-router": {
"Type": "parallel",
"Parameters": {
"Routers": [
{
"RouterName": "dht-lan"
},
{
"RouterName": "dht-wan"
},
{
"RouterName": "http-delegated"
}
]
}
}
},
"Methods": {
"find-providers": {
"RouterName": "find-providers-router"
},
"provide": {
"RouterName": "provide-router"
},
"get-ipns": {
"RouterName": "get-ipns-router"
},
"put-ipns": {
"RouterName": "put-ipns-router"
}
}
}
IgnoreErrors:true to ignore errors for a specific router outputAll routers must implement the routing.Routing interface:
type Routing interface {
ContentRouting
PeerRouting
ValueStore
Bootstrap(context.Context) error
}
All methods involved:
type Routing interface {
Provide(context.Context, cid.Cid, bool) error
FindProvidersAsync(context.Context, cid.Cid, int) <-chan peer.AddrInfo
FindPeer(context.Context, peer.ID) (peer.AddrInfo, error)
PutValue(context.Context, string, []byte, ...Option) error
GetValue(context.Context, string, ...Option) ([]byte, error)
SearchValue(context.Context, string, ...Option) (<-chan []byte, error)
Bootstrap(context.Context) error
}
We can configure which methods will be used per routing implementation. Methods names used in the configuration file will be:
Provide: "provide"FindProvidersAsync: "find-providers"FindPeer: "find-peers"PutValue: "put-ipns"GetValue, SearchValue: "get-ipns"Bootstrap: It will be always executed when needed.We need to implement the parallel and sequential routers and stop using routinghelpers.Tiered router implementation.
Add cycle detection to avoid to user some headaches.
Also we need to implement an internal router, that will define the router used per method.
custom router type to be able to use the new routing system.As test fixtures we can add different use cases here and see how the configuration will look like.
"Routing": {
"Type": "custom",
"Routers": {
"dht-lan": {
"Type": "dht",
"Parameters": {
"Mode": "server",
"PublicIPNetwork": false
}
},
"dht-wan": {
"Type": "dht",
"Parameters": {
"Mode": "auto",
"PublicIPNetwork": true
}
},
"parallel-dht-strict": {
"Type": "parallel",
"Parameters": {
"Routers": [
{
"RouterName": "dht-lan"
},
{
"RouterName": "dht-wan"
}
]
}
},
"parallel-dht": {
"Type": "parallel",
"Parameters": {
"Routers": [
{
"RouterName": "dht-lan",
"IgnoreError": true
},
{
"RouterName": "dht-wan"
}
]
}
}
},
"Methods": {
"provide": {
"RouterName": "dht-wan"
},
"find-providers": {
"RouterName": "parallel-dht-strict"
},
"find-peers": {
"RouterName": "parallel-dht-strict"
},
"get-ipns": {
"RouterName": "parallel-dht"
},
"put-ipns": {
"RouterName": "parallel-dht"
}
}
}
We need to create a config migration using fs-repo-migrations. We should remove the Routing.Type param and add the configuration specified previously.
We don't need to create any config migration! To avoid to the users the hassle of understanding how the new routing system works, we are going to keep the old behavior. We will add the Type custom to make available the new Routing system.
No new security implications or considerations were found.
I got ideas from all of the following links to create this design document:
Configurations that use only HTTP routers (without any DHT router) are unable to reliably announce content (provider records) to the network.
This limitation exists because:
No standardized HTTP API for providing: The Routing V1 HTTP API spec only defines read operations (GET /routing/v1/providers/{cid}). The write operation (PUT /routing/v1/providers) was never standardized.
Legacy experimental API: The only available HTTP providing mechanism is an undocumented PUT /routing/v1/providers request format called ProvideBitswap, which is a historical experiment. See IPIP-526 for ongoing discussion about formalizing HTTP-based provider announcements.
Provider system integration: Kubo's default provider system (Provide.DHT.SweepEnabled=true since v0.38) is designed for DHT-based providing. When no DHT is configured, the provider system may silently skip HTTP routers or behave unexpectedly.
Workarounds for testing:
If you need to test HTTP providing, you can try:
Provide.DHT.SweepEnabled=false to use the legacy provider systemThese workarounds are not guaranteed to work across Kubo versions and should not be relied upon for production use.
Copyright and related rights waived via CC0.