From de11685a89debcaa56a6220faae91b403c64e445 Mon Sep 17 00:00:00 2001
From: Black Swan <q.blacks1ne@gmail.com>
Date: Tue, 18 Nov 2025 00:30:45 +0200
Subject: [PATCH] implement Close() in MockPubSub

---
 node/execution/engines/compute_execution_engine_test.go | 4 ++++
 node/rpc/proxy_blossomsub_test.go                       | 1 +
 2 files changed, 5 insertions(+)

diff --git a/node/execution/engines/compute_execution_engine_test.go b/node/execution/engines/compute_execution_engine_test.go
index 55ff7f6..8f979da 100644
--- a/node/execution/engines/compute_execution_engine_test.go
+++ b/node/execution/engines/compute_execution_engine_test.go
@@ -827,6 +827,10 @@ func (m *mockPubSub) GetNetworkInfo() *protobufs.NetworkInfoResponse {
 	return &protobufs.NetworkInfoResponse{}
 }
 
+func (m *mockPubSub) Close() error {
+	return nil
+}
+
 type mockTransaction struct{}
 
 // Abort implements store.Transaction.
diff --git a/node/rpc/proxy_blossomsub_test.go b/node/rpc/proxy_blossomsub_test.go
index ef27436..19fb4f9 100644
--- a/node/rpc/proxy_blossomsub_test.go
+++ b/node/rpc/proxy_blossomsub_test.go
@@ -177,6 +177,7 @@ func (m *mockPubSub) DiscoverPeers(ctx context.Context) error      { return nil
 func (m *mockPubSub) GetNetwork() uint                             { return 0 }
 func (m *mockPubSub) IsPeerConnected(peerId []byte) bool           { return true }
 func (m *mockPubSub) Reachability() *wrapperspb.BoolValue          { return wrapperspb.Bool(true) }
+func (m *mockPubSub) Close() error                                 { return nil }
 
 // Test helper functions
 func createTestConfigs() (*config.P2PConfig, *config.EngineConfig, error) {