Removing empty channels.

Removing empty channels when the channel becomes vacated.
This commit is contained in:
claudemiro
2015-01-16 13:17:22 -03:00
parent 0d4e9742b9
commit a51629f7b5
3 changed files with 29 additions and 3 deletions
+2 -2
View File
@@ -8,10 +8,10 @@ IPÊ
* [ ] Escrever testes automatizados
* [ ] SSL
* [X] Expvar - Canais, inscritos
* [-] Otimizações [1/3]
* [-] Otimizações [2/3]
* [ ] Refatorar partes do código, remover repetições
* [X] Alterar tipos de dados de slices para mapas em alguns locais.
* [ ] Remover Canais vazios com uma go routine - Uma especie de coletor de lixo
* [X] Remover Canais vazios.
* [ ] Segurança, tempo de expiração, etc
* [X] Dados extra na conexão do usuário. Ver Websockets onOpen
* [X] Webhooks [5/5]
+23
View File
@@ -134,6 +134,29 @@ func (a *App) FindConnection(socketID string) (*Connection, error) {
return nil, errors.New("Connection not found")
}
// DeleteChannel removes the channel from app
func (a *App) RemoveChannel(c *Channel) {
log.Infof("Remove the channel %s from app %s", c.ChannelID, a.Name)
a.Lock()
defer a.Unlock()
delete(a.Channels, c.ChannelID)
if c.IsPresence() {
a.Stats.Add("TotalPresenceChannels", -1)
}
if c.IsPrivate() {
a.Stats.Add("TotalPrivateChannels", -1)
}
if c.IsPublic() {
a.Stats.Add("TotalPublicChannels", -1)
}
a.Stats.Add("TotalChannels", -1)
}
// Add a new Channel to this APP
func (a *App) AddChannel(c *Channel) {
log.Infof("Adding a new channel %s to app %s", c.ChannelID, a.Name)
+4 -1
View File
@@ -176,9 +176,12 @@ func (c *Channel) Unsubscribe(a *App, conn *Connection) error {
a.TriggerMemberRemovedHook(c, subscription)
}
// WebHook
if !c.IsOccupied() {
// WebHook
a.TriggerChannelVacatedHook(c)
// Remove the empty Channel
a.RemoveChannel(c)
}
return nil