From 559a3dc2a437490759d5797b1b45de54c104c8d1 Mon Sep 17 00:00:00 2001 From: Amrit Prakash <65587505+solo-daemon@users.noreply.github.com> Date: Wed, 17 Apr 2024 17:28:52 +0530 Subject: [PATCH] add unit test for common/deliverclient/blocksprovider/delivery_requester (#4798) * add unit test for common/deliverclient/blocksprovider/delivery_requester Signed-off-by: Amrit Prakash * fix runtime errors Signed-off-by: Amrit Prakash --------- Signed-off-by: Amrit Prakash --- .../blocksprovider/delivery_requester_test.go | 198 ++++++++++++++++++ 1 file changed, 198 insertions(+) create mode 100644 common/deliverclient/blocksprovider/delivery_requester_test.go diff --git a/common/deliverclient/blocksprovider/delivery_requester_test.go b/common/deliverclient/blocksprovider/delivery_requester_test.go new file mode 100644 index 00000000000..8661aff4e5b --- /dev/null +++ b/common/deliverclient/blocksprovider/delivery_requester_test.go @@ -0,0 +1,198 @@ +/* +Copyright IBM Corp. All Rights Reserved. + +SPDX-License-Identifier: Apache-2.0 +*/ + +package blocksprovider_test + +import ( + "testing" + + "github.com/hyperledger/fabric-protos-go/common" + "github.com/hyperledger/fabric/common/deliverclient/blocksprovider" + "github.com/hyperledger/fabric/common/deliverclient/blocksprovider/fake" + "github.com/hyperledger/fabric/common/deliverclient/orderers" + "github.com/pkg/errors" + "github.com/stretchr/testify/assert" + "github.com/stretchr/testify/require" + "google.golang.org/grpc" + "google.golang.org/grpc/connectivity" + "google.golang.org/grpc/credentials/insecure" +) + +func TestDeliveryRequester_Connect_Success(t *testing.T) { + fakeSigner := &fake.Signer{} + fakeSigner.SignReturns([]byte("good-sig"), nil) + + fakeDialer := &fake.Dialer{} + cc := &grpc.ClientConn{} + fakeDialer.DialReturns(cc, nil) + + fakeDeliverClient := &fake.DeliverClient{} + fakeDeliverClient.SendReturns(nil) + + fakeDeliverStreamer := &fake.DeliverStreamer{} + fakeDeliverStreamer.DeliverReturns(fakeDeliverClient, nil) + + dr := blocksprovider.NewDeliveryRequester("channel-id", fakeSigner, []byte("tls-cert-hash"), fakeDialer, fakeDeliverStreamer) + assert.NotNil(t, dr) + + seekInfoEnv := &common.Envelope{} + endpoint := &orderers.Endpoint{ + Address: "orderer-address-1", + RootCerts: [][]byte{[]byte("root-cert")}, + Refreshed: make(chan struct{}), + } + + deliverClient, cancelFunc, err := dr.Connect(seekInfoEnv, endpoint) + assert.NoError(t, err) + assert.NotNil(t, deliverClient) + assert.NotNil(t, cancelFunc) +} + +func TestDeliveryRequester_Connect_DialerError(t *testing.T) { + fakeSigner := &fake.Signer{} + fakeSigner.SignReturns([]byte("good-sig"), nil) + + fakeDialer := &fake.Dialer{} + dialError := errors.New("dialer-error") + fakeDialer.DialReturns(nil, dialError) + + fakeDeliverClient := &fake.DeliverClient{} + fakeDeliverClient.SendReturns(nil) + + fakeDeliverStreamer := &fake.DeliverStreamer{} + fakeDeliverStreamer.DeliverReturns(fakeDeliverClient, nil) + + dr := blocksprovider.NewDeliveryRequester("channel-id", fakeSigner, []byte("tls-cert-hash"), fakeDialer, fakeDeliverStreamer) + assert.NotNil(t, dr) + + seekInfoEnv := &common.Envelope{} + endpoint := &orderers.Endpoint{ + Address: "orderer-address-1", + RootCerts: [][]byte{[]byte("root-cert")}, + Refreshed: make(chan struct{}), + } + + deliverClient, cancelFunc, err := dr.Connect(seekInfoEnv, endpoint) + assert.Error(t, err) + assert.Nil(t, deliverClient) + assert.Nil(t, cancelFunc) +} + +func TestDeliveryRequester_Connect_DeliverStreamerError(t *testing.T) { + fakeSigner := &fake.Signer{} + fakeSigner.SignReturns([]byte("good-sig"), nil) + + fakeDialer := &fake.Dialer{} + fakeDialer.DialStub = func(string, [][]byte) (*grpc.ClientConn, error) { + cc, err := grpc.Dial("localhost:6005", grpc.WithTransportCredentials(insecure.NewCredentials())) + require.NoError(t, err) + require.NotEqual(t, connectivity.Shutdown, cc.GetState()) + + return cc, nil + } + + fakeDeliverClient := &fake.DeliverClient{} + fakeDeliverClient.SendReturns(nil) + + fakeDeliverStreamer := &fake.DeliverStreamer{} + deliverStreamerError := errors.New("deliver-streamer-error") + fakeDeliverStreamer.DeliverReturns(fakeDeliverClient, deliverStreamerError) + + dr := blocksprovider.NewDeliveryRequester("channel-id", fakeSigner, []byte("tls-cert-hash"), fakeDialer, fakeDeliverStreamer) + assert.NotNil(t, dr) + + seekInfoEnv := &common.Envelope{} + endpoint := &orderers.Endpoint{ + Address: "orderer-address-1", + RootCerts: [][]byte{[]byte("root-cert")}, + Refreshed: make(chan struct{}), + } + + deliverClient, cancelFunc, err := dr.Connect(seekInfoEnv, endpoint) + assert.Error(t, err) + assert.Nil(t, deliverClient) + assert.Nil(t, cancelFunc) +} + +func TestDeliveryRequester_Connect_DeliverClientError(t *testing.T) { + fakeSigner := &fake.Signer{} + fakeSigner.SignReturns([]byte("good-sig"), nil) + + fakeDialer := &fake.Dialer{} + fakeDialer.DialStub = func(string, [][]byte) (*grpc.ClientConn, error) { + cc, err := grpc.Dial("localhost:6005", grpc.WithTransportCredentials(insecure.NewCredentials())) + require.NoError(t, err) + require.NotEqual(t, connectivity.Shutdown, cc.GetState()) + + return cc, nil + } + + fakeDeliverClient := &fake.DeliverClient{} + deliverClientError := errors.New("deliver-client-error") + fakeDeliverClient.SendReturns(deliverClientError) + + fakeDeliverStreamer := &fake.DeliverStreamer{} + fakeDeliverStreamer.DeliverReturns(fakeDeliverClient, nil) + + dr := blocksprovider.NewDeliveryRequester("channel-id", fakeSigner, []byte("tls-cert-hash"), fakeDialer, fakeDeliverStreamer) + assert.NotNil(t, dr) + + seekInfoEnv := &common.Envelope{} + endpoint := &orderers.Endpoint{ + Address: "orderer-address-1", + RootCerts: [][]byte{[]byte("root-cert")}, + Refreshed: make(chan struct{}), + } + + deliverClient, cancelFunc, err := dr.Connect(seekInfoEnv, endpoint) + assert.Error(t, err) + assert.Nil(t, deliverClient) + assert.Nil(t, cancelFunc) +} + +func TestDeliveryRequester_SeekInfoBlocksFrom(t *testing.T) { + fakeSigner := &fake.Signer{} + fakeSigner.SignReturns([]byte("good-sig"), nil) + + fakeDialer := &fake.Dialer{} + cc := &grpc.ClientConn{} + fakeDialer.DialReturns(cc, nil) + + fakeDeliverClient := &fake.DeliverClient{} + fakeDeliverClient.SendReturns(nil) + + fakeDeliverStreamer := &fake.DeliverStreamer{} + fakeDeliverStreamer.DeliverReturns(fakeDeliverClient, nil) + + dr := blocksprovider.NewDeliveryRequester("channel-id", fakeSigner, []byte("tls-cert-hash"), fakeDialer, fakeDeliverStreamer) + assert.NotNil(t, dr) + + envelope, err := dr.SeekInfoBlocksFrom(1000) + assert.NoError(t, err) + assert.NotNil(t, envelope) +} + +func TestDeliveryRequester_SeekInfoHeadersFrom(t *testing.T) { + fakeSigner := &fake.Signer{} + fakeSigner.SignReturns([]byte("good-sig"), nil) + + fakeDialer := &fake.Dialer{} + cc := &grpc.ClientConn{} + fakeDialer.DialReturns(cc, nil) + + fakeDeliverClient := &fake.DeliverClient{} + fakeDeliverClient.SendReturns(nil) + + fakeDeliverStreamer := &fake.DeliverStreamer{} + fakeDeliverStreamer.DeliverReturns(fakeDeliverClient, nil) + + dr := blocksprovider.NewDeliveryRequester("channel-id", fakeSigner, []byte("tls-cert-hash"), fakeDialer, fakeDeliverStreamer) + assert.NotNil(t, dr) + + envelope, err := dr.SeekInfoHeadersFrom(1000) + assert.NoError(t, err) + assert.NotNil(t, envelope) +}