Improve auditing of joining sessions (#145)

service/rtc/config.go

@@ -74,6 +74,15 @@ type SessionConfig struct {
 	UserID string
 	// SessionID specifies the unique identifier for the session.
 	SessionID string
+	Props     map[string]any
+}
+
+func (c *SessionConfig) GetStringProp(key string) string {
+	if c == nil || c.Props == nil {
+		return ""
+	}
+	val, _ := c.Props[key].(string)
+	return val
 }
 
 func (c SessionConfig) IsValid() error {

service/rtc/sfu.go

@@ -652,6 +652,13 @@ func (s *Server) InitSession(cfg SessionConfig, closeCb func() error) error {
 		<-iceDoneCh
 	}()
 
+	s.log.Debug("session has joined call",
+		mlog.String("userID", cfg.UserID),
+		mlog.String("sessionID", cfg.SessionID),
+		mlog.String("channelID", cfg.GetStringProp("channelID")),
+		mlog.String("callID", cfg.CallID),
+	)
+
 	return nil
 }
 

service/service.go

@@ -296,6 +296,7 @@ func (s *Service) handleClientMsg(msg ws.Message) error {
 		if sessionID == "" {
 			return fmt.Errorf("missing sessionID in client message")
 		}
+		channelID := data["channelID"]
 
 		closeCb := func() error {
 			s.mut.Lock()
@@ -321,8 +322,13 @@ func (s *Service) handleClientMsg(msg ws.Message) error {
 			CallID:    callID,
 			UserID:    userID,
 			SessionID: sessionID,
+			Props: map[string]any{
+				"channelID": channelID,
+			},
 		}
+
 		s.log.Debug("join message", mlog.Any("sessionCfg", cfg))
+
 		if err := s.rtcServer.InitSession(cfg, closeCb); err != nil {
 			return fmt.Errorf("failed to initialize rtc session: %w", err)
 		}