fix newHeads unsubscribe

go/common/subscription/utils.go

@@ -62,8 +62,5 @@ func ForwardFromChannels[R any](inputChannels []chan R, unsubscribed *atomic.Boo
 // Must be called as a go routine!
 func HandleUnsubscribe(connectionSub *rpc.Subscription, unsubscribed *atomic.Bool, onUnsub func()) {
 	<-connectionSub.Err()
-	if unsubscribed != nil {
-		unsubscribed.Store(true)
-	}
 	onUnsub()
 }

go/host/rpc/clientapi/client_api_filter.go

@@ -62,6 +62,7 @@ func (api *FilterAPI) Logs(ctx context.Context, encryptedParams common.Encrypted
 	})
 	go subscriptioncommon.HandleUnsubscribe(subscription, &unsubscribed, func() {
 		api.host.UnsubscribeLogs(subscription.ID)
+		unsubscribed.Store(true)
 	})
 	return subscription, nil
 }

go/node/docker_node.go

@@ -9,9 +9,7 @@ import (
 	"github.com/ten-protocol/go-ten/go/common/docker"
 )
 
-var (
-	_enclaveDataDir = "/enclavedata" // this is how the directory is references within the enclave container
-)
+var _enclaveDataDir = "/enclavedata" // this is how the directory is references within the enclave container
 
 type DockerNode struct {
 	cfg *Config

tools/walletextension/rpcapi/filter_api.go

@@ -114,6 +114,7 @@ func (api *FilterAPI) Logs(ctx context.Context, crit common.FilterCriteria) (*rp
 		for _, connection := range backendWSConnections {
 			_ = returnConn(api.we.rpcWSConnPool, connection.BackingClient())
 		}
+		unsubscribed.Store(true)
 	})
 
 	return subscription, err