Add logging to heyfil / mongo reporting

filecoin-project · Aug 1, 2023 · d246c9f · d246c9f
1 parent 2e6062f
commit d246c9f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/eventrecorder/recorder.go b/eventrecorder/recorder.go
@@ -252,7 +252,10 @@ func (r *EventRecorder) RecordAggregateEvents(ctx context.Context, events []Aggr
 				mongoReportCtx, cncl := context.WithTimeout(context.Background(), 30*time.Second)
 				defer cncl()
 				var pid peer.ID
-				pid.UnmarshalText([]byte(reportData.StorageProviderID))
+				if err := pid.UnmarshalText([]byte(reportData.StorageProviderID)); err != nil {
+					logger.Warnf("could not parse spid %s: %s", reportData.StorageProviderID, err)
+					return
+				}
 				SPID, ok := <-r.pmap.Get(mongoReportCtx, pid)
 				if ok {
 					reportData.SPID = SPID

diff --git a/spmap/spmap.go b/spmap/spmap.go
@@ -105,6 +105,7 @@ func (s *SPMap) query(ctx context.Context, id peer.ID) []string {
 		logger.Warnf("failed to decode response from heyfil: %w", err)
 		return nil
 	}
+	logger.Infof("heyfil mapped %d sps for peerID %s", len(sps), id.String())
 	return sps
 }