Retrieval Market Extraction (#13)

* feat(retrievalmarket): extract from lotus Extract retrievalmarket from lotus, migrate to shared types, use cbor-gen-for, etc * Testing refactors (#21) * extract mocknet setup from datatransfer testing, fold whitebox testing into graphsync_impl_test Co-authored-by: Shannon Wells <[email protected]>
filecoin-project · Dec 19, 2019 · 920f643 · 920f643
1 parent d9fb621
commit 920f643
Show file tree

Hide file tree

Showing 16 changed files with 2,895 additions and 377 deletions.
diff --git a/datatransfer/impl/graphsync/graphsync_impl.go b/datatransfer/impl/graphsync/graphsync_impl.go
@@ -254,6 +254,13 @@ func (impl *graphsyncImpl) TransferChannelStatus(x datatransfer.ChannelID) datat
 	return datatransfer.ChannelNotFoundError
 }
 
+// Subscribers returns a copy of the list of subscribers.
+func (impl *graphsyncImpl) Subscribers() []datatransfer.Subscriber {
+	subscribersCopy := make([]datatransfer.Subscriber, len(impl.subscribers))
+	copy(subscribersCopy, impl.subscribers)
+	return subscribersCopy
+}
+
 // get notified when certain types of events happen
 func (impl *graphsyncImpl) SubscribeToEvents(subscriber datatransfer.Subscriber) datatransfer.Unsubscribe {
 	impl.subscribers = append(impl.subscribers, subscriber)
@@ -277,7 +284,7 @@ func (impl *graphsyncImpl) unsubscribeAt(sub datatransfer.Subscriber) datatransf
 }
 
 func (impl *graphsyncImpl) notifySubscribers(evt datatransfer.Event, cs datatransfer.ChannelState) {
-	for _, cb := range impl.subscribers {
+	for _, cb := range impl.Subscribers() {
 		cb(evt, cs)
 	}
 }