GO-15: mempool outdated

Author: aopoltorzhicky

node/chain_data.go

@@ -43,6 +43,7 @@ type MempoolResponse struct {
 	Refused       []Failed  `json:"refused"`
 	BranchRefused []Failed  `json:"branch_refused"`
 	BranchDelayed []Failed  `json:"branch_delayed"`
+	Outdated      []Failed  `json:"outdated"`
 }
 
 // Applied -

node/monitor.go

@@ -18,6 +18,7 @@ const (
 	filterRefused       = "refused"
 	filterBranchRefused = "branch_refused"
 	filterBranchDelayed = "branch_delayed"
+	filterOutdated      = "outdated"
 )
 
 // Monitor -
@@ -29,11 +30,13 @@ type Monitor struct {
 	refused       chan []*FailedMonitor
 	branchDelayed chan []*FailedMonitor
 	branchRefused chan []*FailedMonitor
+	outdated      chan []*FailedMonitor
 
 	subscribedOnApplied       bool
 	subscribedOnRefused       bool
 	subscribedOnBranchDelayed bool
 	subscribedOnBranchRefused bool
+	subscribedOnOutdated      bool
 
 	wg sync.WaitGroup
 }
@@ -51,6 +54,7 @@ func NewMonitor(url string) *Monitor {
 		refused:       make(chan []*FailedMonitor, 4096),
 		branchDelayed: make(chan []*FailedMonitor, 4096),
 		branchRefused: make(chan []*FailedMonitor, 4096),
+		outdated:      make(chan []*FailedMonitor, 4096),
 		client: &http.Client{
 			Transport: t,
 			Timeout:   time.Minute,
@@ -102,13 +106,25 @@ func (monitor *Monitor) SubscribeOnMempoolBranchDelayed(ctx context.Context) {
 	go monitor.pollingMempool(ctx, filterBranchDelayed)
 }
 
+// SubscribeOnMempoolOutdated -
+func (monitor *Monitor) SubscribeOnMempoolOutdated(ctx context.Context) {
+	if monitor.subscribedOnOutdated {
+		return
+	}
+	monitor.subscribedOnOutdated = true
+
+	monitor.wg.Add(1)
+	go monitor.pollingMempool(ctx, filterOutdated)
+}
+
 func (monitor *Monitor) Close() error {
 	monitor.wg.Wait()
 
 	close(monitor.applied)
 	close(monitor.refused)
 	close(monitor.branchDelayed)
 	close(monitor.branchRefused)
+	close(monitor.outdated)
 	return nil
 }
 
@@ -132,6 +148,11 @@ func (monitor *Monitor) Refused() <-chan []*FailedMonitor {
 	return monitor.refused
 }
 
+// Outdated -
+func (monitor *Monitor) Outdated() <-chan []*FailedMonitor {
+	return monitor.outdated
+}
+
 func (monitor *Monitor) pollingMempool(ctx context.Context, filter string) {
 	defer monitor.wg.Done()
 
@@ -168,6 +189,8 @@ func (monitor *Monitor) process(ctx context.Context, filter, url string) error {
 		return monitor.longPollingFailed(ctx, url, monitor.branchRefused)
 	case filterRefused:
 		return monitor.longPollingFailed(ctx, url, monitor.refused)
+	case filterOutdated:
+		return monitor.longPollingFailed(ctx, url, monitor.outdated)
 	default:
 		return errors.Errorf("unknown filter: %s", filter)
 	}