Browse Source

Expose default room enabled to JSON.

pull/49/head
Simon Eisenmann 12 years ago
parent
commit
9e460a86a8
  1. 4
      src/app/spreed-webrtc-server/config.go
  2. 8
      src/app/spreed-webrtc-server/server.go

4
src/app/spreed-webrtc-server/config.go

@ -39,9 +39,9 @@ type Config struct {
UsersEnabled bool // Flag if users are enabled UsersEnabled bool // Flag if users are enabled
UsersAllowRegistration bool // Flag if users can register UsersAllowRegistration bool // Flag if users can register
UsersMode string // Users mode string UsersMode string // Users mode string
DefaultRoomEnabled bool // Flag if default room ("") is enabled
Plugin string // Plugin to load Plugin string // Plugin to load
globalRoomid string // Id of the global room (not exported to Javascript) globalRoomid string // Id of the global room (not exported to Javascript)
defaultRoomEnabled bool // Flag if default room ("") is enabled
} }
func NewConfig(title, ver, runtimeVersion, basePath, serverToken string, stunURIs, turnURIs []string, tokens bool, globalRoomid string, defaultRoomEnabled, usersEnabled, usersAllowRegistration bool, usersMode, plugin string) *Config { func NewConfig(title, ver, runtimeVersion, basePath, serverToken string, stunURIs, turnURIs []string, tokens bool, globalRoomid string, defaultRoomEnabled, usersEnabled, usersAllowRegistration bool, usersMode, plugin string) *Config {
@ -59,9 +59,9 @@ func NewConfig(title, ver, runtimeVersion, basePath, serverToken string, stunURI
UsersEnabled: usersEnabled, UsersEnabled: usersEnabled,
UsersAllowRegistration: usersAllowRegistration, UsersAllowRegistration: usersAllowRegistration,
UsersMode: usersMode, UsersMode: usersMode,
DefaultRoomEnabled: defaultRoomEnabled,
Plugin: plugin, Plugin: plugin,
globalRoomid: globalRoomid, globalRoomid: globalRoomid,
defaultRoomEnabled: defaultRoomEnabled,
} }
} }

8
src/app/spreed-webrtc-server/server.go

@ -89,7 +89,7 @@ func (s *Server) OnText(c *Connection, b Buffer) {
s.Broadcast(c, c.Session.DataSessionLeft("soft")) s.Broadcast(c, c.Session.DataSessionLeft("soft"))
} }
c.Roomid = msg.Hello.Id c.Roomid = msg.Hello.Id
if c.h.config.defaultRoomEnabled || !c.h.isDefaultRoomid(c.Roomid) { if c.h.config.DefaultRoomEnabled || !c.h.isDefaultRoomid(c.Roomid) {
c.Hello = true c.Hello = true
s.UpdateRoomConnection(c, &RoomConnectionUpdate{Id: c.Roomid, Status: true}) s.UpdateRoomConnection(c, &RoomConnectionUpdate{Id: c.Roomid, Status: true})
s.Broadcast(c, c.Session.DataSessionJoined()) s.Broadcast(c, c.Session.DataSessionJoined())
@ -106,7 +106,7 @@ func (s *Server) OnText(c *Connection, b Buffer) {
// TODO(longsleep): Validate Answer // TODO(longsleep): Validate Answer
s.Unicast(c, msg.Answer.To, msg.Answer) s.Unicast(c, msg.Answer.To, msg.Answer)
case "Users": case "Users":
if c.h.config.defaultRoomEnabled || !c.h.isDefaultRoomid(c.Roomid) { if c.h.config.DefaultRoomEnabled || !c.h.isDefaultRoomid(c.Roomid) {
s.Users(c) s.Users(c)
} }
case "Authentication": case "Authentication":
@ -121,7 +121,7 @@ func (s *Server) OnText(c *Connection, b Buffer) {
case "Status": case "Status":
//log.Println("Status", msg.Status) //log.Println("Status", msg.Status)
s.UpdateSession(c, &SessionUpdate{Types: []string{"Status"}, Status: msg.Status.Status}) s.UpdateSession(c, &SessionUpdate{Types: []string{"Status"}, Status: msg.Status.Status})
if c.h.config.defaultRoomEnabled || !c.h.isDefaultRoomid(c.Roomid) { if c.h.config.DefaultRoomEnabled || !c.h.isDefaultRoomid(c.Roomid) {
s.Broadcast(c, c.Session.DataSessionStatus()) s.Broadcast(c, c.Session.DataSessionStatus())
} }
case "Chat": case "Chat":
@ -132,7 +132,7 @@ func (s *Server) OnText(c *Connection, b Buffer) {
msg.Chat.Chat.Time = time.Now().Format(time.RFC3339) msg.Chat.Chat.Time = time.Now().Format(time.RFC3339)
if msg.Chat.To == "" { if msg.Chat.To == "" {
// TODO(longsleep): Check if chat broadcast is allowed. // TODO(longsleep): Check if chat broadcast is allowed.
if c.h.config.defaultRoomEnabled || !c.h.isDefaultRoomid(c.Roomid) { if c.h.config.DefaultRoomEnabled || !c.h.isDefaultRoomid(c.Roomid) {
atomic.AddUint64(&c.h.broadcastChatMessages, 1) atomic.AddUint64(&c.h.broadcastChatMessages, 1)
s.Broadcast(c, msg.Chat) s.Broadcast(c, msg.Chat)
} }

Loading…
Cancel
Save