fix(fraudserv): stop topics on Stop (#1)

There was a blocker on the node side to implement this, but we have a solution for it now
celestiaorg · Jul 13, 2023 · 1944f93 · 1944f93
1 parent fb4241b
commit 1944f93
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/fraudserv/service.go b/fraudserv/service.go
@@ -109,6 +109,12 @@ func (f *ProofService) Start(context.Context) error {
 // Stop removes the stream handler and cancels the underlying ProofService
 func (f *ProofService) Stop(context.Context) (err error) {
 	f.host.RemoveStreamHandler(protocolID(f.networkID))
+	f.topicsLk.Lock()
+	for tp, topic := range f.topics {
+		delete(f.topics, tp)
+		err = errors.Join(topic.Close())
+	}
+	f.topicsLk.Unlock()
 	f.cancel()
 	return
 }