[#807] ir: Merge ContractProcessor and NotaryContractProcessor interfaces

Signed-off-by: Pavel Karpy <carpawell@nspcc.ru>

pkg/innerring/bindings.go

@@ -10,43 +10,33 @@ type (
 	ContractProcessor interface {
 		ListenerNotificationParsers() []event.NotificationParserInfo
 		ListenerNotificationHandlers() []event.NotificationHandlerInfo
-		TimersHandlers() []event.NotificationHandlerInfo
-	}
-
-	// NotaryContractProcessor interface defines function for binding notary event
-	// producers such as event.Listener with contract processor.
-	//
-	// This interface is optional for contract processor. If contract processor
-	// supports notary event handling, it should implement both ContractProcessor
-	// and NotaryContractProcessor interfaces.
-	NotaryContractProcessor interface {
 		ListenerNotaryParsers() []event.NotaryParserInfo
 		ListenerNotaryHandlers() []event.NotaryHandlerInfo
+		TimersHandlers() []event.NotificationHandlerInfo
 	}
 )
 
 func connectListenerWithProcessor(l event.Listener, p ContractProcessor) {
-	// register parsers
+	// register notification parsers
 	for _, parser := range p.ListenerNotificationParsers() {
 		l.SetNotificationParser(parser)
 	}
 
-	// register handlers
+	// register notification handlers
 	for _, handler := range p.ListenerNotificationHandlers() {
 		l.RegisterNotificationHandler(handler)
 	}
 
-	// add notary handlers if processor supports it
+	// register notary parsers
-	if notaryProcessor, ok := p.(NotaryContractProcessor); ok {
+	for _, notaryParser := range p.ListenerNotaryParsers() {
-		for _, notaryParser := range notaryProcessor.ListenerNotaryParsers() {
 		l.SetNotaryParser(notaryParser)
 	}
 
-		for _, notaryHandler := range notaryProcessor.ListenerNotaryHandlers() {
+	// register notary handlers
+	for _, notaryHandler := range p.ListenerNotaryHandlers() {
 		l.RegisterNotaryHandler(notaryHandler)
 	}
 }
-}
 
 // bindMorphProcessor connects morph chain listener handlers.
 func bindMorphProcessor(proc ContractProcessor, s *Server) error {

pkg/innerring/processors/alphabet/handlers.go

@@ -6,16 +6,16 @@ import (
 	"go.uber.org/zap"
 )
 
-func (np *Processor) HandleGasEmission(ev event.Event) {
+func (ap *Processor) HandleGasEmission(ev event.Event) {
 	_ = ev.(timers.NewAlphabetEmitTick)
-	np.log.Info("tick", zap.String("type", "alphabet gas emit"))
+	ap.log.Info("tick", zap.String("type", "alphabet gas emit"))
 
 	// send event to the worker pool
 
-	err := np.pool.Submit(func() { np.processEmit() })
+	err := ap.pool.Submit(func() { ap.processEmit() })
 	if err != nil {
 		// there system can be moved into controlled degradation stage
-		np.log.Warn("alphabet processor worker pool drained",
+		ap.log.Warn("alphabet processor worker pool drained",
-			zap.Int("capacity", np.pool.Cap()))
+			zap.Int("capacity", ap.pool.Cap()))
 	}
 }

pkg/innerring/processors/alphabet/process_emit.go

@@ -10,39 +10,39 @@ import (
 
 const emitMethod = "emit"
 
-func (np *Processor) processEmit() {
+func (ap *Processor) processEmit() {
-	index := np.irList.AlphabetIndex()
+	index := ap.irList.AlphabetIndex()
 	if index < 0 {
-		np.log.Info("non alphabet mode, ignore gas emission event")
+		ap.log.Info("non alphabet mode, ignore gas emission event")
 
 		return
 	}
 
-	contract, ok := np.alphabetContracts.GetByIndex(index)
+	contract, ok := ap.alphabetContracts.GetByIndex(index)
 	if !ok {
-		np.log.Debug("node is out of alphabet range, ignore gas emission event",
+		ap.log.Debug("node is out of alphabet range, ignore gas emission event",
 			zap.Int("index", index))
 
 		return
 	}
 
 	// there is no signature collecting, so we don't need extra fee
-	err := np.morphClient.Invoke(contract, 0, emitMethod)
+	err := ap.morphClient.Invoke(contract, 0, emitMethod)
 	if err != nil {
-		np.log.Warn("can't invoke alphabet emit method")
+		ap.log.Warn("can't invoke alphabet emit method")
 
 		return
 	}
 
-	if np.storageEmission == 0 {
+	if ap.storageEmission == 0 {
-		np.log.Info("storage node emission is off")
+		ap.log.Info("storage node emission is off")
 
 		return
 	}
 
-	networkMap, err := np.netmapClient.Snapshot()
+	networkMap, err := ap.netmapClient.Snapshot()
 	if err != nil {
-		np.log.Warn("can't get netmap snapshot to emit gas to storage nodes",
+		ap.log.Warn("can't get netmap snapshot to emit gas to storage nodes",
 			zap.String("error", err.Error()))
 
 		return
@@ -50,27 +50,27 @@ func (np *Processor) processEmit() {
 
 	ln := len(networkMap.Nodes)
 	if ln == 0 {
-		np.log.Debug("empty network map, do not emit gas")
+		ap.log.Debug("empty network map, do not emit gas")
 
 		return
 	}
 
-	gasPerNode := fixedn.Fixed8(np.storageEmission / uint64(ln))
+	gasPerNode := fixedn.Fixed8(ap.storageEmission / uint64(ln))
 
 	for i := range networkMap.Nodes {
 		keyBytes := networkMap.Nodes[i].PublicKey()
 
 		key, err := keys.NewPublicKeyFromBytes(keyBytes, elliptic.P256())
 		if err != nil {
-			np.log.Warn("can't convert node public key to address",
+			ap.log.Warn("can't convert node public key to address",
 				zap.String("error", err.Error()))
 
 			continue
 		}
 
-		err = np.morphClient.TransferGas(key.GetScriptHash(), gasPerNode)
+		err = ap.morphClient.TransferGas(key.GetScriptHash(), gasPerNode)
 		if err != nil {
-			np.log.Warn("can't transfer gas",
+			ap.log.Warn("can't transfer gas",
 				zap.String("receiver", key.Address()),
 				zap.Int64("amount", int64(gasPerNode)),
 				zap.String("error", err.Error()),

pkg/innerring/processors/alphabet/processor.go

@@ -83,16 +83,26 @@ func New(p *Params) (*Processor, error) {
 }
 
 // ListenerNotificationParsers for the 'event.Listener' event producer.
-func (np *Processor) ListenerNotificationParsers() []event.NotificationParserInfo {
+func (ap *Processor) ListenerNotificationParsers() []event.NotificationParserInfo {
 	return nil
 }
 
 // ListenerNotificationHandlers for the 'event.Listener' event producer.
-func (np *Processor) ListenerNotificationHandlers() []event.NotificationHandlerInfo {
+func (ap *Processor) ListenerNotificationHandlers() []event.NotificationHandlerInfo {
+	return nil
+}
+
+// ListenerNotaryParsers for the 'event.Listener' event producer.
+func (ap *Processor) ListenerNotaryParsers() []event.NotaryParserInfo {
+	return nil
+}
+
+// ListenerNotaryHandlers for the 'event.Listener' event producer.
+func (ap *Processor) ListenerNotaryHandlers() []event.NotaryHandlerInfo {
 	return nil
 }
 
 // TimersHandlers for the 'Timers' event producer.
-func (np *Processor) TimersHandlers() []event.NotificationHandlerInfo {
+func (ap *Processor) TimersHandlers() []event.NotificationHandlerInfo {
 	return nil
 }

pkg/innerring/processors/balance/processor.go

@@ -104,6 +104,16 @@ func (bp *Processor) ListenerNotificationHandlers() []event.NotificationHandlerI
 	return handlers
 }
 
+// ListenerNotaryParsers for the 'event.Listener' event producer.
+func (bp *Processor) ListenerNotaryParsers() []event.NotaryParserInfo {
+	return nil
+}
+
+// ListenerNotaryHandlers for the 'event.Listener' event producer.
+func (bp *Processor) ListenerNotaryHandlers() []event.NotaryHandlerInfo {
+	return nil
+}
+
 // TimersHandlers for the 'Timers' event producer.
 func (bp *Processor) TimersHandlers() []event.NotificationHandlerInfo {
 	return nil

pkg/innerring/processors/governance/processor.go

@@ -146,6 +146,16 @@ func (gp *Processor) ListenerNotificationHandlers() []event.NotificationHandlerI
 	return []event.NotificationHandlerInfo{hi}
 }
 
+// ListenerNotaryParsers for the 'event.Listener' event producer.
+func (gp *Processor) ListenerNotaryParsers() []event.NotaryParserInfo {
+	return nil
+}
+
+// ListenerNotaryHandlers for the 'event.Listener' event producer.
+func (gp *Processor) ListenerNotaryHandlers() []event.NotaryHandlerInfo {
+	return nil
+}
+
 // TimersHandlers for the 'Timers' event producer.
 func (gp *Processor) TimersHandlers() []event.NotificationHandlerInfo {
 	return nil

pkg/innerring/processors/neofs/processor.go

@@ -215,6 +215,16 @@ func (np *Processor) ListenerNotificationHandlers() []event.NotificationHandlerI
 	return handlers
 }
 
+// ListenerNotaryParsers for the 'event.Listener' event producer.
+func (np *Processor) ListenerNotaryParsers() []event.NotaryParserInfo {
+	return nil
+}
+
+// ListenerNotaryHandlers for the 'event.Listener' event producer.
+func (np *Processor) ListenerNotaryHandlers() []event.NotaryHandlerInfo {
+	return nil
+}
+
 // TimersHandlers for the 'Timers' event producer.
 func (np *Processor) TimersHandlers() []event.NotificationHandlerInfo {
 	return nil

pkg/innerring/processors/netmap/processor.go

@@ -202,6 +202,16 @@ func (np *Processor) ListenerNotificationHandlers() []event.NotificationHandlerI
 	return handlers
 }
 
+// ListenerNotaryParsers for the 'event.Listener' event producer.
+func (np *Processor) ListenerNotaryParsers() []event.NotaryParserInfo {
+	return nil
+}
+
+// ListenerNotaryHandlers for the 'event.Listener' event producer.
+func (np *Processor) ListenerNotaryHandlers() []event.NotaryHandlerInfo {
+	return nil
+}
+
 // TimersHandlers for the 'Timers' event producer.
 func (np *Processor) TimersHandlers() []event.NotificationHandlerInfo {
 	return nil

pkg/innerring/processors/reputation/processor.go

@@ -116,6 +116,16 @@ func (rp *Processor) ListenerNotificationHandlers() []event.NotificationHandlerI
 	return handlers
 }
 
+// ListenerNotaryParsers for the 'event.Listener' event producer.
+func (rp *Processor) ListenerNotaryParsers() []event.NotaryParserInfo {
+	return nil
+}
+
+// ListenerNotaryHandlers for the 'event.Listener' event producer.
+func (rp *Processor) ListenerNotaryHandlers() []event.NotaryHandlerInfo {
+	return nil
+}
+
 // TimersHandlers for the 'Timers' event producer.
 func (rp *Processor) TimersHandlers() []event.NotificationHandlerInfo {
 	return nil