source: code/trunk/bridge.go@ 771

package soju

import (
        "strconv"
        "strings"

        "gopkg.in/irc.v3"
)

func forwardChannel(dc *downstreamConn, ch *upstreamChannel) {
        if !ch.complete {
                panic("Tried to forward a partial channel")
        }

        // RPL_NOTOPIC shouldn't be sent on JOIN
        if ch.Topic != "" {
                sendTopic(dc, ch)
        }
        sendNames(dc, ch)
}

func sendTopic(dc *downstreamConn, ch *upstreamChannel) {
        downstreamName := dc.marshalEntity(ch.conn.network, ch.Name)

        if ch.Topic != "" {
                dc.SendMessage(&irc.Message{
                        Prefix:  dc.srv.prefix(),
                        Command: irc.RPL_TOPIC,
                        Params:  []string{dc.nick, downstreamName, ch.Topic},
                })
                if ch.TopicWho != nil {
                        topicWho := dc.marshalUserPrefix(ch.conn.network, ch.TopicWho)
                        topicTime := strconv.FormatInt(ch.TopicTime.Unix(), 10)
                        dc.SendMessage(&irc.Message{
                                Prefix:  dc.srv.prefix(),
                                Command: rpl_topicwhotime,
                                Params:  []string{dc.nick, downstreamName, topicWho.String(), topicTime},
                        })
                }
        } else {
                dc.SendMessage(&irc.Message{
                        Prefix:  dc.srv.prefix(),
                        Command: irc.RPL_NOTOPIC,
                        Params:  []string{dc.nick, downstreamName, "No topic is set"},
                })
        }
}

func sendNames(dc *downstreamConn, ch *upstreamChannel) {
        downstreamName := dc.marshalEntity(ch.conn.network, ch.Name)

        emptyNameReply := &irc.Message{
                Prefix:  dc.srv.prefix(),
                Command: irc.RPL_NAMREPLY,
                Params:  []string{dc.nick, string(ch.Status), downstreamName, ""},
        }
        maxLength := maxMessageLength - len(emptyNameReply.String())

        var buf strings.Builder
        for _, entry := range ch.Members.innerMap {
                nick := entry.originalKey
                memberships := entry.value.(*memberships)
                s := memberships.Format(dc) + dc.marshalEntity(ch.conn.network, nick)

                n := buf.Len() + 1 + len(s)
                if buf.Len() != 0 && n > maxLength {
                        // There's not enough space for the next space + nick.
                        dc.SendMessage(&irc.Message{
                                Prefix:  dc.srv.prefix(),
                                Command: irc.RPL_NAMREPLY,
                                Params:  []string{dc.nick, string(ch.Status), downstreamName, buf.String()},
                        })
                        buf.Reset()
                }

                if buf.Len() != 0 {
                        buf.WriteByte(' ')
                }
                buf.WriteString(s)
        }

        if buf.Len() != 0 {
                dc.SendMessage(&irc.Message{
                        Prefix:  dc.srv.prefix(),
                        Command: irc.RPL_NAMREPLY,
                        Params:  []string{dc.nick, string(ch.Status), downstreamName, buf.String()},
                })
        }

        dc.SendMessage(&irc.Message{
                Prefix:  dc.srv.prefix(),
                Command: irc.RPL_ENDOFNAMES,
                Params:  []string{dc.nick, downstreamName, "End of /NAMES list"},
        })
}