cleanup

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

Author: SaidAltury-ibm

platform/fabricx/core/finality/listenermanager.go

@@ -82,7 +82,6 @@ func newNotifi(ctx context.Context, cfg config.ConfigService) (*notificationList
 }
 
 func GetListenerManager(ctx context.Context, sp services.Provider, network, channel string) (ListenerManager, error) {
-	logger.Infof("@@@@@@@@@@ here at GetListenerManager")
 	lmp, err := sp.GetService(reflect.TypeOf((*ListenerManagerProvider)(nil)))
 	if err != nil {
 		return nil, errors.Wrapf(err, "could not find provider")

platform/fabricx/core/finality/nlm.go

@@ -35,15 +35,13 @@ type notificationListenerManager struct {
 
 func (n *notificationListenerManager) Listen(ctx context.Context) error {
 	g, gCtx := errgroup.WithContext(n.notifyStream.Context())
-	logger.Infof("@@@@@@@@@@ here at Listen")
 	// spawn stream receiver
 	g.Go(func() error {
 		for {
 			res, err := n.notifyStream.Recv()
 			if err != nil {
 				return err
 			}
-			logger.Infof("[nlm.Listen] Received new notification: %+v", res)
 			select {
 			case <-gCtx.Done():
 				return gCtx.Err()
@@ -79,7 +77,6 @@ func (n *notificationListenerManager) Listen(ctx context.Context) error {
 			}
 
 			res := parseResponse(resp)
-			logger.Infof("[nlm.Listen] Parsed notification result: %+v", res)
 
 			n.lock.Lock()
 			for txID, v := range res {

platform/fabricx/core/vault/queryservice/query.go

@@ -76,7 +76,7 @@ func (s *RemoteQueryService) query(m map[driver.Namespace][]driver.PKey) (map[dr
 		return nil, err
 	}
 
-	ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
+	ctx, cancel := context.WithTimeout(context.Background(), s.config.QueryTimeout)
 	defer cancel()
 
 	now := time.Now()