initial port

.gitlab-ci.yml

+stages:
+  - build
+  - test
+
+variables:
+  BUILD_DIR: "/tmp/$CI_CONCURRENT_PROJECT_ID"
+
+before_script:
+  - mkdir -p $BUILD_DIR/src
+  - cd $BUILD_DIR/src
+  - if [ -d $CI_PROJECT_DIR ]
+  - then
+  -    echo "soft link $CI_PROJECT_DIR exists"
+  - else
+  -    echo "creating soft link $CI_PROJECT_DIR"
+  -    ln -s $CI_PROJECT_DIR
+  - fi
+  - cd $CI_PROJECT_DIR
+
+build:
+  stage: build
+  tags:
+    - testing
+  script:
+    - echo $CI_JOB_STAGE
+    - go build
+
+test:
+  stage: test
+  tags:
+    - testing
+  script:
+    - echo $CI_JOB_STAGE
+    - go test -cover
+  coverage: '/coverage: \d+.\d+% of statements/'

fetch.go

@@ -5,14 +5,14 @@ import (
 	"errors"
 	"time"
 
-	"github.com/libp2p/go-libp2p-core/host"
-	"github.com/libp2p/go-libp2p-core/network"
-	"github.com/libp2p/go-libp2p-core/peer"
-	"github.com/libp2p/go-libp2p-core/protocol"
+	"gitlab.dms3.io/p2p/go-p2p-core/host"
+	"gitlab.dms3.io/p2p/go-p2p-core/network"
+	"gitlab.dms3.io/p2p/go-p2p-core/peer"
+	"gitlab.dms3.io/p2p/go-p2p-core/protocol"
 
-	"github.com/libp2p/go-msgio/protoio"
+	"gitlab.dms3.io/p2p/go-msgio/protoio"
 
-	pb "github.com/libp2p/go-libp2p-pubsub-router/pb"
+	pb "gitlab.dms3.io/p2p/go-p2p-pubsub-router/pb"
 
 	"github.com/gogo/protobuf/proto"
 )

fetch_test.go

@@ -7,7 +7,7 @@ import (
 	"testing"
 	"time"
 
-	"github.com/libp2p/go-libp2p-core/host"
+	"gitlab.dms3.io/p2p/go-p2p-core/host"
 )
 
 func connect(t *testing.T, a, b host.Host) {

go.mod

-module github.com/libp2p/go-libp2p-pubsub-router
+module gitlab.dms3.io/p2p/go-p2p-pubsub-router
 
-go 1.12
+go 1.15
 
 require (
 	github.com/gogo/protobuf v1.3.1
-	github.com/ipfs/go-datastore v0.4.4
-	github.com/ipfs/go-ipfs-ds-help v0.1.1
-	github.com/ipfs/go-log/v2 v2.1.1
-	github.com/libp2p/go-libp2p-blankhost v0.2.0
-	github.com/libp2p/go-libp2p-core v0.7.0
-	github.com/libp2p/go-libp2p-pubsub v0.4.0
-	github.com/libp2p/go-libp2p-record v0.1.3
-	github.com/libp2p/go-libp2p-swarm v0.3.1
-	github.com/libp2p/go-msgio v0.0.6
-	golang.org/x/sync v0.0.0-20200317015054-43a5402ce75a
+	gitlab.dms3.io/dms3/public/go-datastore v0.0.1
+	gitlab.dms3.io/dms3/public/go-dms3-ds-help v0.0.2
+	gitlab.dms3.io/dms3/public/go-log/v2 v2.0.0
+	gitlab.dms3.io/p2p/go-msgio v0.0.1
+	gitlab.dms3.io/p2p/go-p2p-blankhost v0.0.1
+	gitlab.dms3.io/p2p/go-p2p-core v0.0.1
+	gitlab.dms3.io/p2p/go-p2p-pubsub v0.0.1
+	gitlab.dms3.io/p2p/go-p2p-record v0.0.1
+	gitlab.dms3.io/p2p/go-p2p-swarm v0.0.1
+	golang.org/x/sync v0.0.0-20210220032951-036812b2e83c
 )

pubsub.go

@@ -9,17 +9,17 @@ import (
 	"sync"
 	"time"
 
-	"github.com/libp2p/go-libp2p-core/host"
-	"github.com/libp2p/go-libp2p-core/peer"
-	"github.com/libp2p/go-libp2p-core/routing"
+	"gitlab.dms3.io/p2p/go-p2p-core/host"
+	"gitlab.dms3.io/p2p/go-p2p-core/peer"
+	"gitlab.dms3.io/p2p/go-p2p-core/routing"
 
-	pubsub "github.com/libp2p/go-libp2p-pubsub"
-	record "github.com/libp2p/go-libp2p-record"
+	pubsub "gitlab.dms3.io/p2p/go-p2p-pubsub"
+	record "gitlab.dms3.io/p2p/go-p2p-record"
 
-	ds "github.com/ipfs/go-datastore"
-	dssync "github.com/ipfs/go-datastore/sync"
-	dshelp "github.com/ipfs/go-ipfs-ds-help"
-	logging "github.com/ipfs/go-log/v2"
+	ds "gitlab.dms3.io/dms3/public/go-datastore"
+	dssync "gitlab.dms3.io/dms3/public/go-datastore/sync"
+	dshelp "gitlab.dms3.io/dms3/public/go-dms3-ds-help"
+	logging "gitlab.dms3.io/dms3/public/go-log/v2"
 )
 
 var log = logging.Logger("pubsub-valuestore")

pubsub_test.go

@@ -9,13 +9,13 @@ import (
 
 	"golang.org/x/sync/errgroup"
 
-	"github.com/libp2p/go-libp2p-core/host"
-	"github.com/libp2p/go-libp2p-core/routing"
+	"gitlab.dms3.io/p2p/go-p2p-core/host"
+	"gitlab.dms3.io/p2p/go-p2p-core/routing"
 
-	bhost "github.com/libp2p/go-libp2p-blankhost"
-	pubsub "github.com/libp2p/go-libp2p-pubsub"
-	record "github.com/libp2p/go-libp2p-record"
-	swarmt "github.com/libp2p/go-libp2p-swarm/testing"
+	bhost "gitlab.dms3.io/p2p/go-p2p-blankhost"
+	pubsub "gitlab.dms3.io/p2p/go-p2p-pubsub"
+	record "gitlab.dms3.io/p2p/go-p2p-record"
+	swarmt "gitlab.dms3.io/p2p/go-p2p-swarm/testing"
 )
 
 func newNetHost(ctx context.Context, t *testing.T) host.Host {