Send a greet server when connecting to other server

be1-go/internal/handler/channel/federation/hfederation/federation.go

@@ -55,6 +55,10 @@ type RumorStateSender interface {
 	SendRumorStateTo(socket socket.Socket) error
 }
 
+type GreetServerSender interface {
+	SendGreetServer(socket socket.Socket) error
+}
+
 type Repository interface {
 	// HasMessage returns true if the message already exists.
 	HasMessage(messageID string) (bool, error)
@@ -90,20 +94,22 @@ type Handler struct {
 	conf    Config
 	db      Repository
 	rumors  RumorStateSender
+	greets  GreetServerSender
 	schema  *validation.SchemaValidator
 	log     zerolog.Logger
 }
 
 func New(hub Hub, subs Subscribers, sockets Sockets, conf Config,
-	db Repository, rumors RumorStateSender, schema *validation.SchemaValidator,
-	log zerolog.Logger) *Handler {
+	db Repository, rumors RumorStateSender, greets GreetServerSender,
+	schema *validation.SchemaValidator, log zerolog.Logger) *Handler {
 	return &Handler{
 		hub:     hub,
 		subs:    subs,
 		sockets: sockets,
 		conf:    conf,
 		db:      db,
 		rumors:  rumors,
+		greets:  greets,
 		schema:  schema,
 		log:     log.With().Str("module", "federation").Logger(),
 	}
@@ -545,6 +551,11 @@ func (h *Handler) connectTo(serverAddress string) (socket.Socket, error) {
 	go server.WritePump()
 	go server.ReadPump()
 
+	err = h.greets.SendGreetServer(server)
+	if err != nil {
+		return nil, err
+	}
+
 	return server, h.rumors.SendRumorStateTo(server)
 }
 

be1-go/internal/hub/hub.go

@@ -190,7 +190,7 @@ func New(dbPath string, ownerPubKey kyber.Point, clientAddress, serverAddress st
 
 	// Create the federation handler
 	federationHandler := hfederation.New(hubParams, subs, sockets, conf, &db,
-		rumorStateHandler, schemaValidator, log)
+		rumorStateHandler, greetserverHandler, schemaValidator, log)
 
 	// Create the query handler
 	methodHandlers := make(hquery.MethodHandlers)