Merge pull request #1859 from dedis/work-be1-stuart-fix-connexion-problem

Fix connexion problem

Author: sgueissa

be1-go/internal/popserver/hub.go

@@ -56,6 +56,7 @@ func (h *Hub) Start() {
 	go func() {
 		utils.LogInfo("start the Hub")
 		for {
+			utils.LogInfo("waiting for a new message")
 			select {
 			case incomingMessage := <-h.messageChan:
 				utils.LogInfo("start handling a message")
@@ -65,9 +66,9 @@ func (h *Hub) Start() {
 				} else {
 					utils.LogInfo("successfully handled a message")
 				}
-			case <-h.closedSockets:
-				utils.LogInfo("stopping the Sockets")
-				return
+			case socketID := <-h.closedSockets:
+				utils.LogInfo("stopping the Socket " + socketID)
+				state.UnsubscribeFromAll(socketID)
 			case <-h.stop:
 				utils.LogInfo("stopping the Hub")
 				return

be1-go/internal/popserver/state/state.go

@@ -23,6 +23,7 @@ type Subscriber interface {
 	HasChannel(channel string) bool
 	Subscribe(channel string, socket socket.Socket) *answer.Error
 	Unsubscribe(channel string, socket socket.Socket) *answer.Error
+	UnsubscribeFromAll(socketID string)
 	SendToAll(buf []byte, channel string) *answer.Error
 }
 
@@ -104,6 +105,17 @@ func Unsubscribe(socket socket.Socket, channel string) *answer.Error {
 	return subs.Unsubscribe(channel, socket)
 }
 
+func UnsubscribeFromAll(socketID string) *answer.Error {
+	subs, errAnswer := getSubs()
+	if errAnswer != nil {
+		return errAnswer
+	}
+
+	subs.UnsubscribeFromAll(socketID)
+
+	return nil
+}
+
 func SendToAll(buf []byte, channel string) *answer.Error {
 	subs, errAnswer := getSubs()
 	if errAnswer != nil {

be1-go/internal/popserver/types/subscribers.go

@@ -1,6 +1,7 @@
 package types
 
 import (
+	"fmt"
 	"golang.org/x/xerrors"
 	"popstellar/message/answer"
 	"popstellar/network/socket"
@@ -65,6 +66,20 @@ func (s *Subscribers) Unsubscribe(channel string, socket socket.Socket) *answer.
 	return nil
 }
 
+func (s *Subscribers) UnsubscribeFromAll(socketID string) {
+	s.Lock()
+	defer s.Unlock()
+
+	for channel, subs := range s.list {
+		_, ok := subs[socketID]
+		if !ok {
+			continue
+		}
+		delete(s.list[channel], socketID)
+		fmt.Println("unsubscribe from " + channel)
+	}
+}
+
 // SendToAll sends a message to all sockets.
 func (s *Subscribers) SendToAll(buf []byte, channel string) *answer.Error {
 	s.RLock()