test: basic routing interface test

This commit was moved from ipfs/interface-go-ipfs-core@d069f41be1

This commit was moved from ipfs/boxo@48f8c69a90

core/coreiface/tests/api.go

@@ -69,6 +69,7 @@ func TestApi(p Provider) func(t *testing.T) {
 		t.Run("Path", tp.TestPath)
 		t.Run("Pin", tp.TestPin)
 		t.Run("PubSub", tp.TestPubSub)
+		t.Run("Routing", tp.TestRouting)
 		t.Run("Unixfs", tp.TestUnixfs)
 
 		apis <- -1

core/coreiface/tests/routing.go

@@ -0,0 +1,92 @@
+package tests
+
+import (
+	"context"
+	"testing"
+	"time"
+
+	"github.com/gogo/protobuf/proto"
+	ipns_pb "github.com/ipfs/go-ipns/pb"
+	iface "github.com/ipfs/interface-go-ipfs-core"
+)
+
+func (tp *TestSuite) TestRouting(t *testing.T) {
+	tp.hasApi(t, func(api iface.CoreAPI) error {
+		if api.Routing() == nil {
+			return errAPINotImplemented
+		}
+		return nil
+	})
+
+	t.Run("TestRoutingGet", tp.TestRoutingGet)
+	t.Run("TestRoutingPut", tp.TestRoutingPut)
+}
+
+func (tp *TestSuite) testRoutingPublishKey(t *testing.T, ctx context.Context, api iface.CoreAPI) iface.IpnsEntry {
+	p, err := addTestObject(ctx, api)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	entry, err := api.Name().Publish(ctx, p)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	time.Sleep(3 * time.Second)
+	return entry
+}
+
+func (tp *TestSuite) TestRoutingGet(t *testing.T) {
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+
+	apis, err := tp.MakeAPISwarm(ctx, true, 2)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	// Node 1: publishes an IPNS name
+	ipnsEntry := tp.testRoutingPublishKey(t, ctx, apis[0])
+
+	// Node 2: retrieves the best value for the IPNS name.
+	data, err := apis[1].Routing().Get(ctx, "/ipns/"+ipnsEntry.Name())
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	// Checks if values match.
+	var entry ipns_pb.IpnsEntry
+	err = proto.Unmarshal(data, &entry)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	if string(entry.GetValue()) != ipnsEntry.Value().String() {
+		t.Fatalf("routing key has wrong value, expected %s, got %s", ipnsEntry.Value().String(), string(entry.GetValue()))
+	}
+}
+
+func (tp *TestSuite) TestRoutingPut(t *testing.T) {
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+	apis, err := tp.MakeAPISwarm(ctx, true, 1)
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	// Create and publish IPNS entry.
+	ipnsEntry := tp.testRoutingPublishKey(t, ctx, apis[0])
+
+	// Get valid routing value.
+	data, err := apis[0].Routing().Get(ctx, "/ipns/"+ipnsEntry.Name())
+	if err != nil {
+		t.Fatal(err)
+	}
+
+	// Put routing value.
+	err = apis[0].Routing().Put(ctx, "/ipns/"+ipnsEntry.Name(), data)
+	if err != nil {
+		t.Fatal(err)
+	}
+}