small fixes

Signed-off-by: Said Altury <Said.Altury@ibm.com>

Author: SaidAltury-ibm

integration/fabricx/simple/views/create.go

@@ -87,7 +87,6 @@ func (i *CreateView) Call(viewCtx view.Context) (interface{}, error) {
 		return nil, err
 	}
 
-
 	// now we have a committer listener registered, we send the approved transaction to the orderer
 	logger.Infof("Submit tx (txID=%v) to ordering service", tx.ID())
 	if _, err = viewCtx.RunView(state.NewOrderingAndFinalityWithTimeoutView(tx, FinalityTimeout)); err != nil {

platform/fabricx/core/finality/listenermanager.go

@@ -11,9 +11,9 @@ import (
 	"reflect"
 	"sync"
 
-	"github.com/hyperledger-labs/fabric-smart-client/platform/common/utils/assert"
 	"github.com/hyperledger-labs/fabric-smart-client/pkg/utils/errors"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/common/driver"
+	"github.com/hyperledger-labs/fabric-smart-client/platform/common/utils/assert"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/fabric"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/fabric/core/generic/driver/config"
 	"github.com/hyperledger-labs/fabric-smart-client/platform/view/services"
@@ -89,9 +89,9 @@ func newNotifi(ctx context.Context, cfg config.ConfigService) (*notificationList
 		return nil, err
 	}
 	// CRITICAL FIX: Use context.Background() for the stream lifecycle.
-    // This ensures the stream stays alive for the duration of the shared manager, 
-    // regardless of when the individual view's context (ctx) is cancelled.
-    streamCtx := context.Background()
+	// This ensures the stream stays alive for the duration of the shared manager,
+	// regardless of when the individual view's context (ctx) is cancelled.
+	streamCtx := context.Background()
 
 	notifyClient := protonotify.NewNotifierClient(cc)
 	notifyStream, err := notifyClient.OpenNotificationStream(streamCtx)

platform/fabricx/core/finality/nlm_test.go

@@ -142,7 +142,7 @@ func TestNotificationListenerManager(t *testing.T) {
 
 				// run Listen
 				go func() {
-					_ = nlm.Listen(ctx)
+					_ = nlm.Listen()
 				}()
 
 				require.EventuallyWithT(t, func(collect *assert.CollectT) {
@@ -185,7 +185,7 @@ func TestNotificationListenerManager(t *testing.T) {
 		}
 
 		go func() {
-			_ = nlm.Listen(ctx)
+			_ = nlm.Listen()
 		}()
 
 		require.EventuallyWithT(t, func(collect *assert.CollectT) {
@@ -212,7 +212,7 @@ func TestNotificationListenerManager(t *testing.T) {
 
 		// start the manager
 		go func() {
-			_ = nlm.Listen(ctx)
+			_ = nlm.Listen()
 		}()
 
 		// add a listener
@@ -243,7 +243,7 @@ func TestNotificationListenerManager(t *testing.T) {
 
 		// start the manager
 		go func() {
-			_ = nlm.Listen(ctx)
+			_ = nlm.Listen()
 		}()
 
 		// The single listener instance used for both calls
@@ -289,7 +289,7 @@ func TestNotificationListenerManager(t *testing.T) {
 		}
 
 		go func() {
-			_ = nlm.Listen(ctx)
+			_ = nlm.Listen()
 		}()
 
 		ml1 := &mockListener{txID: "1"}
@@ -369,7 +369,7 @@ func TestNotificationListenerManager(t *testing.T) {
 		// start the manager
 		errs := make(chan error, 1)
 		go func() {
-			errs <- nlm.Listen(cancelable_ctx)
+			errs <- nlm.Listen()
 		}()
 
 		// wait briefly to ensure all goroutines are up and blocking
@@ -391,13 +391,13 @@ func TestNotificationListenerManager(t *testing.T) {
 
 	t.Run("Stream Error Handling", func(t *testing.T) {
 		t.Parallel()
-		nlm, fakeStream, ctx := setupTest(t)
+		nlm, fakeStream, _ := setupTest(t)
 
 		expectedErr := errors.New("stream broken")
 		fakeStream.RecvReturns(nil, expectedErr)
 
 		// listen should return the error immediately
-		err := nlm.Listen(ctx)
+		err := nlm.Listen()
 		require.ErrorIs(t, err, expectedErr)
 	})