From d76a04bd0a96772cec5b279aaa1ee45235adc707 Mon Sep 17 00:00:00 2001 From: Wim Date: Sun, 17 Feb 2019 22:43:04 +0100 Subject: [PATCH] Support quits from irc correctly. Fixes #722 (#724) --- bridge/irc/handlers.go | 4 ++++ gateway/gateway.go | 18 +++++++++++++++++- 2 files changed, 21 insertions(+), 1 deletion(-) diff --git a/bridge/irc/handlers.go b/bridge/irc/handlers.go index ce4f0445..a5df2d53 100644 --- a/bridge/irc/handlers.go +++ b/bridge/irc/handlers.go @@ -92,6 +92,10 @@ func (b *Birc) handleJoinPart(client *girc.Client, event girc.Event) { return } b.Log.Debugf("<= Sending JOIN_LEAVE event from %s to gateway", b.Account) + // QUIT isn't channel bound, happens for all channels on the bridge + if event.Command == "QUIT" { + channel = "" + } msg := config.Message{Username: "system", Text: event.Source.Name + " " + strings.ToLower(event.Command) + "s", Channel: channel, Account: b.Account, Event: config.EventJoinLeave} b.Log.Debugf("<= Message is %#v", msg) b.Remote <- msg diff --git a/gateway/gateway.go b/gateway/gateway.go index f74a6680..8b3ccf05 100644 --- a/gateway/gateway.go +++ b/gateway/gateway.go @@ -176,7 +176,6 @@ func (gw *Gateway) getDestChannel(msg *config.Message, dest bridge.Bridge) []con // discord join/leave is for the whole bridge, isn't a per channel join/leave if msg.Event == config.EventJoinLeave && dest.Protocol == "discord" && msg.Account == dest.Account { - flog.Error("here") for _, channel := range gw.Channels { if channel.Account == msg.Account && strings.Contains(channel.Direction, "out") && gw.validGatewayDest(msg) { @@ -186,6 +185,18 @@ func (gw *Gateway) getDestChannel(msg *config.Message, dest bridge.Bridge) []con return channels } + // irc quit is for the whole bridge, isn't a per channel quit. + // channel is empty when we quit + if msg.Event == config.EventJoinLeave && getProtocol(msg) == "irc" && msg.Channel == "" { + for _, channel := range gw.Channels { + if channel.Account == dest.Account && strings.Contains(channel.Direction, "out") && + gw.validGatewayDest(msg) { + channels = append(channels, *channel) + } + } + return channels + } + // if source channel is in only, do nothing for _, channel := range gw.Channels { // lookup the channel from the message @@ -435,3 +446,8 @@ func (gw *Gateway) ignoreText(text string, input []string) bool { } return false } + +func getProtocol(msg *config.Message) string { + p := strings.Split(msg.Account, ".") + return p[0] +}