diff options
| -rw-r--r-- | gateway/gateway.go | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/gateway/gateway.go b/gateway/gateway.go index 881e0ac9..2fa5a0bb 100644 --- a/gateway/gateway.go +++ b/gateway/gateway.go @@ -139,6 +139,9 @@ RECONNECT: func (gw *Gateway) mapChannels() error { for _, br := range append(gw.MyConfig.Out, gw.MyConfig.InOut...) { + if isApi(br.Account) { + br.Channel = "api" + } ID := br.Channel + br.Account _, ok := gw.Channels[ID] if !ok { @@ -153,6 +156,9 @@ func (gw *Gateway) mapChannels() error { } for _, br := range append(gw.MyConfig.In, gw.MyConfig.InOut...) { + if isApi(br.Account) { + br.Channel = "api" + } ID := br.Channel + br.Account _, ok := gw.Channels[ID] if !ok { @@ -298,3 +304,10 @@ func (gw *Gateway) validGatewayDest(msg *config.Message, channel *config.Channel } return false } + +func isApi(account string) bool { + if strings.HasPrefix(account, "api.") { + return true + } + return false +} |