Add handling of completion message to signalr.

Author: aopoltorzhicky

README.md

@@ -22,20 +22,15 @@ if args.Help {
 
 #### `config`
 
-DipDup YAML [configuration](https://docs.dipdup.net/config-file-reference) parser.
+DipDup YAML [configuration](https://docs.dipdup.net/config-file-reference) parser. You can validate config by `validate` tag from [validator package](https://github.com/go-playground/validator).
 
 ```go
 import "github.com/dipdup-net/go-lib/config"
 
 type MyConfig struct {
 	config.Config `yaml:",inline"`
     // Custom field here
-    Fields Fields `yaml:"fields"`
-}
-
-// Validate - required by Configurable interface
-func (c *MyConfig) Validate() error {
-    return c.Fields.Validate() // if needed
+    Fields Fields `yaml:"fields" validate:"required"`
 }
 
 // Substitute - required by Configurable interface
@@ -47,11 +42,6 @@ type Fields struct {
     First string `yaml:"first"`
 }
 
-// Validate -
-func (f *Fields) Validate() error {
-    return nil
-}
-
 var cfg MyConfig
 if err := config.Parse("config.yaml", &cfg); err != nil {
     panic(err)
@@ -86,6 +76,7 @@ type State struct {
 	IndexType string
 	Hash      string
 	Level     uint64
+	UpdatedAt int    `gorm:"autoUpdateTime"`
 }
 ```
 
@@ -164,6 +155,8 @@ func main() {
 			log.Print("reorg")
 		case events.MessageTypeState:
 			log.Print("initialized")
+		case events.MessageTypeSubscribed:
+			log.Println("subscribed", msg)
 		}
 	}
 }

tzkt/events/message.go

@@ -16,6 +16,7 @@ const (
 	MessageTypeState MessageType = iota
 	MessageTypeData
 	MessageTypeReorg
+	MessageTypeSubscribed
 )
 
 // Message - message struct

tzkt/events/signalr/message.go

@@ -67,7 +67,7 @@ type StreamItem struct {
 // Completion -  a `Completion` message
 type Completion struct {
 	Message
-	Result string `json:"result,omitempty"`
+	Result uint64 `json:"result,omitempty"`
 	Error  string `json:"string,omitempty"`
 }
 

tzkt/events/tzkt.go

@@ -30,7 +30,7 @@ func NewTzKT(url string) *TzKT {
 	}
 	return &TzKT{
 		s:             signalr.NewSignalR(url),
-		msgs:          make(chan Message),
+		msgs:          make(chan Message, 1024),
 		stop:          make(chan struct{}),
 		subscriptions: make([]signalr.Invocation, 0),
 	}
@@ -163,7 +163,17 @@ func (tzkt *TzKT) listen() {
 
 					tzkt.msgs <- message
 				case signalr.Completion:
-					log.Trace("subscribed")
+					for i := range tzkt.subscriptions {
+						if tzkt.subscriptions[i].ID != typ.ID {
+							continue
+						}
+						tzkt.msgs <- Message{
+							Channel: tzkt.subscriptions[i].Target,
+							Type:    MessageTypeSubscribed,
+							State:   typ.Result,
+						}
+						break
+					}
 				}
 			}
 		}