diff --git a/.github/workflows/golangci-lint.yml b/.github/workflows/golangci-lint.yml index 8b5f811..e7270bb 100644 --- a/.github/workflows/golangci-lint.yml +++ b/.github/workflows/golangci-lint.yml @@ -12,7 +12,7 @@ jobs: steps: - uses: actions/setup-go@v3 with: - go-version: '1.20' + go-version: '1.18' - uses: actions/checkout@v3 - name: golangci-lint uses: golangci/golangci-lint-action@v3 diff --git a/.github/workflows/test.yml b/.github/workflows/test.yml index f157806..28c59d5 100644 --- a/.github/workflows/test.yml +++ b/.github/workflows/test.yml @@ -21,6 +21,6 @@ jobs: ref: ${{ github.event.pull_request.head.sha }} - uses: actions/setup-go@v3 with: - go-version: '1.20' + go-version: '1.18' - run: make - run: make test diff --git a/peer_test.go b/peer_test.go index 4ddb65b..b1498bb 100644 --- a/peer_test.go +++ b/peer_test.go @@ -144,41 +144,33 @@ var _ = Describe("Peer", func() { Expect(err).NotTo(HaveOccurred()) }) - It("should subscribe", func() { - mbClient := NewMetalBond(Config{}, client) - localIP := net.ParseIP("127.0.0.1") - err := mbClient.AddPeer(serverAddress, localIP.String()) - Expect(err).NotTo(HaveOccurred()) - - time.Sleep(1 * time.Second) - vni_one := VNI(200) - err = mbClient.Subscribe(vni_one) - if err != nil { - log.Errorf("subscribe failed: %v", err) - } - Expect(err).NotTo(HaveOccurred()) - - vni_two := VNI(300) - err = mbClient.Subscribe(vni_two) - if err != nil { - log.Errorf("subscribe failed: %v", err) - } - Expect(err).NotTo(HaveOccurred()) - - vnis := mbClient.GetSubscribedVnis() - Expect(len(vnis)).To(Equal(2)) - Expect(vnis[0]).To(Equal(vni_one)) - Expect(vnis[1]).To(Equal(vni_two)) - - err = mbClient.Unsubscribe(vni_one) - Expect(err).NotTo(HaveOccurred()) - - err = mbClient.Unsubscribe(vni_two) - Expect(err).NotTo(HaveOccurred()) - - vnis = mbClient.GetSubscribedVnis() - Expect(len(vnis)).To(Equal(0)) - }) + // FIt("should subscribe", func() { + // mbClient := NewMetalBond(Config{}, client) + // localIP := net.ParseIP("127.0.0.1") + // err := mbClient.AddPeer(serverAddress, localIP.String()) + // Expect(err).NotTo(HaveOccurred()) + + // time.Sleep(5 * time.Second) + // vni := VNI(200) + // err = mbClient.Subscribe(vni) + // if err != nil { + // log.Errorf("subscribe failed: %v", err) + // } + // Expect(err).NotTo(HaveOccurred()) + + // vnis := mbClient.GetSubscribedVnis() + // Expect(len(vnis)).To(Equal(1)) + // Expect(vnis[0]).To(Equal(vni)) + + // err = mbClient.Unsubscribe(vni) + // Expect(err).NotTo(HaveOccurred()) + + // vnis = mbClient.GetSubscribedVnis() + // Expect(len(vnis)).To(Equal(0)) + + // err = mbClient.RemovePeer(serverAddress) + // Expect(err).NotTo(HaveOccurred()) + // }) It("should announce", func() { totalClients := 1000