chore: removal of session and session-request observer

server/src/database/board_sessions.go

@@ -4,10 +4,11 @@ import (
 	"context"
 	"errors"
 	"net/url"
-	"scrumlr.io/server/identifiers"
 	"strconv"
 	"time"
 
+	"scrumlr.io/server/identifiers"
+
 	"github.com/google/uuid"
 	"scrumlr.io/server/common"
 	"scrumlr.io/server/common/filter"
@@ -167,14 +168,6 @@ func (d *Database) UpdateBoardSessions(update BoardSessionUpdate) ([]BoardSessio
 		Join("INNER JOIN users AS u ON u.id = s.user").
 		Scan(context.Background(), &sessions)
 
-	// send update to observers here, as bun .AfterScanRow() is triggered for each updated row
-	// see more details in: https://github.com/inovex/scrumlr.io/pull/2071/files#r1026237100
-	for _, observer := range d.observer {
-		if o, ok := observer.(BoardSessionsObserver); ok {
-			o.UpdatedSessions(update.Board, sessions)
-		}
-	}
-
 	return sessions, err
 }
 
@@ -229,3 +222,20 @@ func (d *Database) GetBoardSessions(board uuid.UUID, filter ...filter.BoardSessi
 	err := query.Scan(context.Background(), &sessions)
 	return sessions, err
 }
+
+// Gets all board sessions of a single user who he is currently connected to
+func (d *Database) GetSingleUserConnectedBoards(user uuid.UUID) ([]BoardSession, error) {
+	var sessions []BoardSession
+	err := d.db.NewSelect().
+		TableExpr("board_sessions AS s").
+		ColumnExpr("s.board, s.user, u.avatar, u.name, s.connected, s.show_hidden_columns, s.ready, s.raised_hand, s.role, s.banned").
+		Where("s.user = ?", user).
+		Where("s.connected").
+		Join("INNER JOIN users AS u ON u.id = s.user").
+		Scan(context.Background(), &sessions)
+	if err != nil {
+		return nil, err
+	}
+
+	return sessions, err
+}