-
Notifications
You must be signed in to change notification settings - Fork 12
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- routing v1 client when provided - ipns routing using proxyrouter to kubo when indicated - fullRT router otherwise
- Loading branch information
Showing
8 changed files
with
348 additions
and
33 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,132 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "context" | ||
| "errors" | ||
|
|
||
| "github.com/hashicorp/go-multierror" | ||
| "github.com/ipfs/go-cid" | ||
| routinghelpers "github.com/libp2p/go-libp2p-routing-helpers" | ||
| "github.com/libp2p/go-libp2p/core/peer" | ||
| "github.com/libp2p/go-libp2p/core/routing" | ||
| "github.com/multiformats/go-multihash" | ||
| ) | ||
|
|
||
| var ( | ||
| _ routinghelpers.ProvideManyRouter = &Composer{} | ||
| _ routing.Routing = &Composer{} | ||
| ) | ||
|
|
||
| type Composer struct { | ||
| GetValueRouter routing.Routing | ||
| PutValueRouter routing.Routing | ||
| FindPeersRouter routing.Routing | ||
| FindProvidersRouter routing.Routing | ||
| ProvideRouter routing.Routing | ||
| } | ||
|
|
||
| func (c *Composer) Provide(ctx context.Context, cid cid.Cid, provide bool) error { | ||
| goLog.Debug("composer: calling provide: ", cid) | ||
| err := c.ProvideRouter.Provide(ctx, cid, provide) | ||
| if err != nil { | ||
| goLog.Debugf("composer: calling provide: ", cid, " error: ", err) | ||
| } | ||
|
|
||
| return err | ||
| } | ||
|
|
||
| func (c *Composer) ProvideMany(ctx context.Context, keys []multihash.Multihash) error { | ||
| goLog.Debug("composer: calling provide many: ", len(keys)) | ||
| pmr, ok := c.ProvideRouter.(routinghelpers.ProvideManyRouter) | ||
| if !ok { | ||
| goLog.Debug("composer: provide many is not implemented on the actual router") | ||
| return nil | ||
| } | ||
|
|
||
| err := pmr.ProvideMany(ctx, keys) | ||
| if err != nil { | ||
| goLog.Debug("composer: calling provide many error: ", err) | ||
| } | ||
|
|
||
| return err | ||
| } | ||
|
|
||
| func (c *Composer) Ready() bool { | ||
| goLog.Debug("composer: calling ready") | ||
| pmr, ok := c.ProvideRouter.(routinghelpers.ReadyAbleRouter) | ||
| if !ok { | ||
| return true | ||
| } | ||
|
|
||
| ready := pmr.Ready() | ||
|
|
||
| goLog.Debug("composer: calling ready result: ", ready) | ||
|
|
||
| return ready | ||
| } | ||
|
|
||
| func (c *Composer) FindProvidersAsync(ctx context.Context, cid cid.Cid, count int) <-chan peer.AddrInfo { | ||
| goLog.Debug("composer: calling findProvidersAsync: ", cid) | ||
| return c.FindProvidersRouter.FindProvidersAsync(ctx, cid, count) | ||
| } | ||
|
|
||
| func (c *Composer) FindPeer(ctx context.Context, pid peer.ID) (peer.AddrInfo, error) { | ||
| goLog.Debug("composer: calling findPeer: ", pid) | ||
| addr, err := c.FindPeersRouter.FindPeer(ctx, pid) | ||
| if err != nil { | ||
| goLog.Debug("composer: calling findPeer error: ", pid, addr.String(), err) | ||
| } | ||
| return addr, err | ||
| } | ||
|
|
||
| func (c *Composer) PutValue(ctx context.Context, key string, val []byte, opts ...routing.Option) error { | ||
| goLog.Debug("composer: calling putValue: ", key, len(val)) | ||
| err := c.PutValueRouter.PutValue(ctx, key, val, opts...) | ||
| if err != nil { | ||
| goLog.Debug("composer: calling putValue error: ", key, len(val), err) | ||
| } | ||
|
|
||
| return err | ||
| } | ||
|
|
||
| func (c *Composer) GetValue(ctx context.Context, key string, opts ...routing.Option) ([]byte, error) { | ||
| goLog.Debug("composer: calling getValue: ", key) | ||
| val, err := c.GetValueRouter.GetValue(ctx, key, opts...) | ||
| if err != nil { | ||
| goLog.Debug("composer: calling getValue error: ", key, len(val), err) | ||
| } | ||
|
|
||
| return val, err | ||
| } | ||
|
|
||
| func (c *Composer) SearchValue(ctx context.Context, key string, opts ...routing.Option) (<-chan []byte, error) { | ||
| goLog.Debug("composer: calling searchValue: ", key) | ||
| ch, err := c.GetValueRouter.SearchValue(ctx, key, opts...) | ||
|
|
||
| // avoid nil channels on implementations not supporting SearchValue method. | ||
| if errors.Is(err, routing.ErrNotFound) && ch == nil { | ||
| out := make(chan []byte) | ||
| close(out) | ||
| return out, err | ||
| } | ||
|
|
||
| if err != nil { | ||
| goLog.Debug("composer: calling searchValue error: ", key, err) | ||
| } | ||
|
|
||
| return ch, err | ||
| } | ||
|
|
||
| func (c *Composer) Bootstrap(ctx context.Context) error { | ||
| goLog.Debug("composer: calling bootstrap") | ||
| errfp := c.FindPeersRouter.Bootstrap(ctx) | ||
| errfps := c.FindProvidersRouter.Bootstrap(ctx) | ||
| errgv := c.GetValueRouter.Bootstrap(ctx) | ||
| errpv := c.PutValueRouter.Bootstrap(ctx) | ||
| errp := c.ProvideRouter.Bootstrap(ctx) | ||
| err := multierror.Append(errfp, errfps, errgv, errpv, errp) | ||
| if err != nil { | ||
| goLog.Debug("composer: calling bootstrap error: ", err) | ||
| } | ||
| return err | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.