2 goircd -- minimalistic simple Internet Relay Chat (IRC) server
3 Copyright (C) 2014-2020 Sergey Matveev <stargrave@stargrave.org>
5 This program is free software: you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published by
7 the Free Software Foundation, version 3 of the License.
9 This program is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 GNU General Public License for more details.
14 You should have received a copy of the GNU General Public License
15 along with this program. If not, see <http://www.gnu.org/licenses/>.
33 members map[*Client]struct{}
34 events chan ClientEvent
39 RERoom = regexp.MustCompile("^#[^\x00\x07\x0a\x0d ,:/]{1,200}$")
41 rooms map[string]*Room = make(map[string]*Room)
42 roomsLock sync.RWMutex
43 roomsWG sync.WaitGroup
46 func (r *Room) SendTopic(c *Client) {
49 c.ReplyNicknamed("331", r.name, "No topic is set")
51 c.ReplyNicknamed("332", r.name, t)
55 func (r *Room) SendNames(c *Client) {
59 } else if _, isMember := r.members[c]; isMember {
63 c.ReplyNicknamed("475", r.name, "Cannot join channel (+k)")
67 nicknames := make([]string, 0, len(r.members))
68 for member := range r.members {
69 nicknames = append(nicknames, member.nickname)
72 sort.Strings(nicknames)
73 maxLen := 512 - len(*hostname) - 2 - 2
78 for i, n := range nicknames {
80 if lenAll+lenName >= maxLen {
81 c.ReplyNicknamed("353", "=", r.name, strings.Join(nicknames[:i-1], " "))
82 nicknames = nicknames[i:]
87 if len(nicknames) > 0 {
88 c.ReplyNicknamed("353", "=", r.name, strings.Join(nicknames, " "))
90 c.ReplyNicknamed("366", r.name, "End of NAMES list")
93 func (r *Room) Broadcast(msg string, excludes ...*Client) {
95 if len(excludes) > 0 {
99 for member := range r.members {
100 if member == exclude {
108 func (r *Room) StateSave() {
109 stateSink <- StateEvent{r.name, r.topic, r.key}
112 func (r *Room) Processor(events <-chan ClientEvent) {
113 for e := range events {
121 r.members[c] = struct{}{}
124 log.Println(c, "joined", r.name)
127 r.Broadcast(fmt.Sprintf(":%s JOIN %s", c, r.name))
128 logSink <- LogEvent{r.name, c.nickname, "joined", true}
131 if _, subscribed := r.members[c]; !subscribed {
132 c.ReplyNicknamed("442", r.name, "You are not on that channel")
135 msg := fmt.Sprintf(":%s PART %s :%s", c, r.name, c.nickname)
140 logSink <- LogEvent{r.name, c.nickname, "left", true}
142 log.Println(c, "left", r.name)
145 if _, subscribed := r.members[c]; !subscribed {
146 c.ReplyParts("442", r.name, "You are not on that channel")
153 topic := strings.TrimLeft(e.text, ":")
155 msg := fmt.Sprintf(":%s TOPIC %s :%s", c, r.name, r.topic)
157 logSink <- LogEvent{r.name, c.nickname, "set topic to " + r.topic, true}
161 for m := range r.members {
173 c.ReplyNicknamed("315", r.name, "End of /WHO list")
181 c.Msg(fmt.Sprintf("324 %s %s %s", c.nickname, r.name, mode))
184 if strings.HasPrefix(e.text, "b") {
185 c.ReplyNicknamed("368", r.name, "End of channel ban list")
188 if strings.HasPrefix(e.text, "-k") || strings.HasPrefix(e.text, "+k") {
189 if _, subscribed := r.members[c]; !subscribed {
190 c.ReplyParts("442", r.name, "You are not on that channel")
194 c.ReplyNicknamed("472", e.text, "Unknown MODE flag")
199 if strings.HasPrefix(e.text, "+k") {
200 cols := strings.Split(e.text, " ")
202 c.ReplyNotEnoughParameters("MODE")
206 msg = fmt.Sprintf(":%s MODE %s +k %s", c, r.name, r.key)
207 msgLog = "set channel key"
210 msg = fmt.Sprintf(":%s MODE %s -k", c, r.name)
211 msgLog = "removed channel key"
214 logSink <- LogEvent{r.name, c.nickname, msgLog, true}
217 sep := strings.Index(e.text, " ")
218 r.Broadcast(fmt.Sprintf(
219 ":%s %s %s :%s", c, e.text[:sep], r.name, e.text[sep+1:],
221 logSink <- LogEvent{r.name, c.nickname, e.text[sep+1:], false}
226 func RoomRegister(name string) *Room {
229 members: make(map[*Client]struct{}),
230 events: make(chan ClientEvent),
236 go r.Processor(r.events)