From 9756361f010a559abf17b831bf5204d1cd56523a Mon Sep 17 00:00:00 2001 From: Amrit Prakash Date: Sun, 7 Apr 2024 05:38:38 +0530 Subject: [PATCH] add unit test for common/deliverclient/blocksprovider/delivery_requester --- .../blocksprovider/delivery_requester_test.go | 188 ++++++++++++++++++ 1 file changed, 188 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..f952660e3e4 --- /dev/null +++ b/common/deliverclient/blocksprovider/delivery_requester_test.go @@ -0,0 +1,188 @@ +/* +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" + "google.golang.org/grpc" +) + +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.Equal(t, dialError, 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{} + cc := &grpc.ClientConn{} + fakeDialer.DialReturns(cc, nil) + + fakeDeliverClient := &fake.DeliverClient{} + fakeDeliverClient.SendReturns(nil) + + fakeDeliverStreamer := &fake.DeliverStreamer{} + deliverStreamerError := errors.New("deliver-streamer-error") + fakeDeliverStreamer.DeliverReturns(nil, 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.Equal(t, deliverStreamerError, 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{} + cc := &grpc.ClientConn{} + fakeDialer.DialReturns(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.Equal(t, deliverClientError, 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) +}