feat(prospective-parachains) implements fanin operation

ChainSafe · Jan 8, 2025 · a67abba · a67abba
1 parent 2d038e6
commit a67abba
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/dot/parachain/statement-distribution/statement_distribution.go b/dot/parachain/statement-distribution/statement_distribution.go
@@ -15,7 +15,7 @@ var logger = log.NewFromGlobal(log.AddContext("pkg", "statement-distribution"))
 
 type StatementDistribution struct {
 	reputationAggregator parachainutil.ReputationAggregator
-	SubSystemToOverseer  chan<- any
+	SubSystemToOverseer  chan<- parachainutil.NetworkBridgeTxMessage
 }
 
 func (s *StatementDistribution) Run(
@@ -36,11 +36,11 @@ func (s *StatementDistribution) Run(
 			if err != nil {
 				logger.Errorf("error processing overseer message: %v", err)
 			}
-		case _ = <-v2CommChannel:
-			panic("Not Implemented")
-		case _ = <-receiverRespCh:
-			panic("Not Implemented")
-		case _ = <-retryReqCh:
+			// case _ = <-v2CommChannel:
+			// 	panic("Not Implemented")
+			// case _ = <-receiverRespCh:
+			// 	panic("Not Implemented")
+			// case _ = <-retryReqCh:
 			logger.Infof("received retry request, no action taken")
 		case <-reputationDelay.C:
 			// Trigger reputation aggregator logic

diff --git a/dot/parachain/util/util.go b/dot/parachain/util/util.go
@@ -108,7 +108,7 @@ func NewReputationAggregator(sendImmediatelyIf func(rep UnifiedReputationChange)
 }
 
 // Send sends the accumulated reputation changes in a batch and clears the state.
-func (r *ReputationAggregator) Send(overseerCh chan<- any) {
+func (r *ReputationAggregator) Send(overseerCh chan<- NetworkBridgeTxMessage) {
 	r.mu.Lock()
 	defer r.mu.Unlock()