[98] | 1 | package soju
|
---|
[32] | 2 |
|
---|
| 3 | import (
|
---|
| 4 | "gopkg.in/irc.v3"
|
---|
| 5 | )
|
---|
| 6 |
|
---|
| 7 | func forwardChannel(dc *downstreamConn, ch *upstreamChannel) {
|
---|
| 8 | if !ch.complete {
|
---|
| 9 | panic("Tried to forward a partial channel")
|
---|
| 10 | }
|
---|
| 11 |
|
---|
[69] | 12 | downstreamName := dc.marshalChannel(ch.conn, ch.Name)
|
---|
| 13 |
|
---|
[32] | 14 | if ch.Topic != "" {
|
---|
[54] | 15 | dc.SendMessage(&irc.Message{
|
---|
[32] | 16 | Prefix: dc.srv.prefix(),
|
---|
| 17 | Command: irc.RPL_TOPIC,
|
---|
[69] | 18 | Params: []string{dc.nick, downstreamName, ch.Topic},
|
---|
[54] | 19 | })
|
---|
[32] | 20 | } else {
|
---|
[54] | 21 | dc.SendMessage(&irc.Message{
|
---|
[32] | 22 | Prefix: dc.srv.prefix(),
|
---|
| 23 | Command: irc.RPL_NOTOPIC,
|
---|
[69] | 24 | Params: []string{dc.nick, downstreamName, "No topic is set"},
|
---|
[54] | 25 | })
|
---|
[32] | 26 | }
|
---|
| 27 |
|
---|
| 28 | // TODO: rpl_topicwhotime
|
---|
| 29 |
|
---|
| 30 | // TODO: send multiple members in each message
|
---|
| 31 | for nick, membership := range ch.Members {
|
---|
[69] | 32 | s := dc.marshalNick(ch.conn, nick)
|
---|
[32] | 33 | if membership != 0 {
|
---|
[69] | 34 | s = string(membership) + s
|
---|
[32] | 35 | }
|
---|
| 36 |
|
---|
[54] | 37 | dc.SendMessage(&irc.Message{
|
---|
[32] | 38 | Prefix: dc.srv.prefix(),
|
---|
| 39 | Command: irc.RPL_NAMREPLY,
|
---|
[69] | 40 | Params: []string{dc.nick, string(ch.Status), downstreamName, s},
|
---|
[54] | 41 | })
|
---|
[32] | 42 | }
|
---|
| 43 |
|
---|
[54] | 44 | dc.SendMessage(&irc.Message{
|
---|
[32] | 45 | Prefix: dc.srv.prefix(),
|
---|
| 46 | Command: irc.RPL_ENDOFNAMES,
|
---|
[69] | 47 | Params: []string{dc.nick, downstreamName, "End of /NAMES list"},
|
---|
[54] | 48 | })
|
---|
[32] | 49 | }
|
---|