Changeset 259 in code
- Timestamp:
- Apr 16, 2020, 2:57:33 PM (5 years ago)
- Location:
- trunk
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/bridge.go
r160 r259 17 17 18 18 func sendTopic(dc *downstreamConn, ch *upstreamChannel) { 19 downstreamName := dc.marshal Channel(ch.conn, ch.Name)19 downstreamName := dc.marshalEntity(ch.conn, ch.Name) 20 20 21 21 if ch.Topic != "" { … … 37 37 // TODO: send multiple members in each message 38 38 39 downstreamName := dc.marshal Channel(ch.conn, ch.Name)39 downstreamName := dc.marshalEntity(ch.conn, ch.Name) 40 40 41 41 for nick, membership := range ch.Members { 42 s := membership.String() + dc.marshal Nick(ch.conn, nick)42 s := membership.String() + dc.marshalEntity(ch.conn, nick) 43 43 44 44 dc.SendMessage(&irc.Message{ -
trunk/downstream.go
r258 r259 138 138 } 139 139 return name + "/" + uc.network.GetName() 140 }141 142 func (dc *downstreamConn) marshalChannel(uc *upstreamConn, name string) string {143 return dc.marshalEntity(uc, name)144 }145 146 func (dc *downstreamConn) marshalNick(uc *upstreamConn, name string) string {147 return dc.marshalEntity(uc, name)148 140 } 149 141 … … 244 236 case "NICK": 245 237 // Nick change for another user 246 msg.Params[0] = dc.marshal Nick(uc, msg.Params[0])238 msg.Params[0] = dc.marshalEntity(uc, msg.Params[0]) 247 239 case "JOIN", "PART": 248 msg.Params[0] = dc.marshal Channel(uc, msg.Params[0])240 msg.Params[0] = dc.marshalEntity(uc, msg.Params[0]) 249 241 case "KICK": 250 msg.Params[0] = dc.marshal Channel(uc, msg.Params[0])251 msg.Params[1] = dc.marshal Nick(uc, msg.Params[1])242 msg.Params[0] = dc.marshalEntity(uc, msg.Params[0]) 243 msg.Params[1] = dc.marshalEntity(uc, msg.Params[1]) 252 244 case "TOPIC": 253 msg.Params[0] = dc.marshal Channel(uc, msg.Params[0])245 msg.Params[0] = dc.marshalEntity(uc, msg.Params[0]) 254 246 case "MODE": 255 247 msg.Params[0] = dc.marshalEntity(uc, msg.Params[0]) … … 671 663 Prefix: dc.prefix(), 672 664 Command: "JOIN", 673 Params: []string{dc.marshal Channel(ch.conn, ch.Name)},665 Params: []string{dc.marshalEntity(ch.conn, ch.Name)}, 674 666 }) 675 667 -
trunk/upstream.go
r253 r259 765 765 766 766 uc.forEachDownstream(func(dc *downstreamConn) { 767 params := []string{dc.nick, dc.marshal Channel(uc, channel), modeStr}767 params := []string{dc.nick, dc.marshalEntity(uc, channel), modeStr} 768 768 params = append(params, modeParams...) 769 769 … … 827 827 Prefix: dc.srv.prefix(), 828 828 Command: irc.RPL_LIST, 829 Params: []string{dc.nick, dc.marshal Channel(uc, channel), clients, topic},829 Params: []string{dc.nick, dc.marshalEntity(uc, channel), clients, topic}, 830 830 }) 831 831 }) … … 845 845 // NAMES on a channel we have not joined, forward to downstream 846 846 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 847 channel := dc.marshal Channel(uc, name)847 channel := dc.marshalEntity(uc, name) 848 848 members := splitSpace(members) 849 849 for i, member := range members { 850 850 membership, nick := uc.parseMembershipPrefix(member) 851 members[i] = membership.String() + dc.marshal Nick(uc, nick)851 members[i] = membership.String() + dc.marshalEntity(uc, nick) 852 852 } 853 853 memberStr := strings.Join(members, " ") … … 882 882 // NAMES on a channel we have not joined, forward to downstream 883 883 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 884 channel := dc.marshal Channel(uc, name)884 channel := dc.marshalEntity(uc, name) 885 885 886 886 dc.SendMessage(&irc.Message{ … … 923 923 channel := channel 924 924 if channel != "*" { 925 channel = dc.marshal Channel(uc, channel)926 } 927 nick := dc.marshal Nick(uc, nick)925 channel = dc.marshalEntity(uc, channel) 926 } 927 nick := dc.marshalEntity(uc, nick) 928 928 dc.SendMessage(&irc.Message{ 929 929 Prefix: dc.srv.prefix(), … … 957 957 958 958 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 959 nick := dc.marshal Nick(uc, nick)959 nick := dc.marshalEntity(uc, nick) 960 960 dc.SendMessage(&irc.Message{ 961 961 Prefix: dc.srv.prefix(), … … 971 971 972 972 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 973 nick := dc.marshal Nick(uc, nick)973 nick := dc.marshalEntity(uc, nick) 974 974 dc.SendMessage(&irc.Message{ 975 975 Prefix: dc.srv.prefix(), … … 985 985 986 986 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 987 nick := dc.marshal Nick(uc, nick)987 nick := dc.marshalEntity(uc, nick) 988 988 dc.SendMessage(&irc.Message{ 989 989 Prefix: dc.srv.prefix(), … … 999 999 1000 1000 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 1001 nick := dc.marshal Nick(uc, nick)1001 nick := dc.marshalEntity(uc, nick) 1002 1002 params := []string{dc.nick, nick} 1003 1003 params = append(params, msg.Params[2:]...) … … 1016 1016 1017 1017 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 1018 nick := dc.marshal Nick(uc, nick)1018 nick := dc.marshalEntity(uc, nick) 1019 1019 channelList := make([]string, len(channels)) 1020 1020 for i, channel := range channels { 1021 1021 prefix, channel := uc.parseMembershipPrefix(channel) 1022 channel = dc.marshal Channel(uc, channel)1022 channel = dc.marshalEntity(uc, channel) 1023 1023 channelList[i] = prefix.String() + channel 1024 1024 } … … 1037 1037 1038 1038 uc.forEachDownstreamByID(downstreamID, func(dc *downstreamConn) { 1039 nick := dc.marshal Nick(uc, nick)1039 nick := dc.marshalEntity(uc, nick) 1040 1040 dc.SendMessage(&irc.Message{ 1041 1041 Prefix: dc.srv.prefix(), … … 1079 1079 Prefix: dc.marshalUserPrefix(uc, msg.Prefix), 1080 1080 Command: "INVITE", 1081 Params: []string{dc.marshal Nick(uc, nick), dc.marshalChannel(uc, channel)},1081 Params: []string{dc.marshalEntity(uc, nick), dc.marshalEntity(uc, channel)}, 1082 1082 }) 1083 1083 }) … … 1093 1093 Prefix: dc.srv.prefix(), 1094 1094 Command: irc.RPL_INVITING, 1095 Params: []string{dc.nick, dc.marshal Nick(uc, nick), dc.marshalChannel(uc, channel)},1095 Params: []string{dc.nick, dc.marshalEntity(uc, nick), dc.marshalEntity(uc, channel)}, 1096 1096 }) 1097 1097 })
Note:
See TracChangeset
for help on using the changeset viewer.