2 * InspIRCd -- Internet Relay Chat Daemon
4 * Copyright (C) 2009-2010 Daniel De Graaf <danieldg@inspircd.org>
5 * Copyright (C) 2008 Robin Burchell <robin+git@viroteck.net>
6 * Copyright (C) 2008 Dennis Friis <peavey@inspircd.org>
7 * Copyright (C) 2008 Craig Edwards <craigedwards@brainbox.cc>
9 * This file is part of InspIRCd. InspIRCd is free software: you can
10 * redistribute it and/or modify it under the terms of the GNU General Public
11 * License as published by the Free Software Foundation, version 2.
13 * This program is distributed in the hope that it will be useful, but WITHOUT
14 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
15 * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more
18 * You should have received a copy of the GNU General Public License
19 * along with this program. If not, see <http://www.gnu.org/licenses/>.
25 #include "treeserver.h"
26 #include "treesocket.h"
28 /** FJOIN, almost identical to TS6 SJOIN, except for nicklist handling. */
29 CmdResult CommandFJoin::Handle(User* srcuser, std::vector<std::string>& params)
31 /* 1.1+ FJOIN works as follows:
33 * Each FJOIN is sent along with a timestamp, and the side with the lowest
34 * timestamp 'wins'. From this point on we will refer to this side as the
35 * winner. The side with the higher timestamp loses, from this point on we
36 * will call this side the loser or losing side. This should be familiar to
37 * anyone who's dealt with dreamforge or TS6 before.
39 * When two sides of a split heal and this occurs, the following things
42 * If the timestamps are exactly equal, both sides merge their privilages
43 * and users, as in InspIRCd 1.0 and ircd2.8. The channels have not been
44 * re-created during a split, this is safe to do.
46 * If the timestamps are NOT equal, the losing side removes all of its
47 * modes from the channel, before introducing new users into the channel
48 * which are listed in the FJOIN command's parameters. The losing side then
49 * LOWERS its timestamp value of the channel to match that of the winning
50 * side, and the modes of the users of the winning side are merged in with
53 * The winning side on the other hand will ignore all user modes from the
54 * losing side, so only its own modes get applied. Life is simple for those
55 * who succeed at internets. :-)
58 * :<sid> FJOIN <chan> <TS> <modes> :[<member> [<member> ...]]
59 * The last parameter is a list consisting of zero or more channel members
60 * (permanent channels may have zero users). Each entry on the list is in the
62 * [[<modes>,]<uuid>[:<membid>]
63 * <modes> is a concatenation of the mode letters the user has on the channel
64 * (e.g.: "ov" if the user is opped and voiced). The order of the mode letters
65 * are not important but if a server ecounters an unknown mode letter, it will
66 * drop the link to avoid desync.
68 * InspIRCd 2.0 and older required a comma before the uuid even if the user
69 * had no prefix modes on the channel, InspIRCd 2.2 and later does not require
70 * a comma in this case anymore.
72 * <membid> is a positive integer representing the id of the membership.
73 * If not present (in FJOINs coming from pre-1205 servers), 0 is assumed.
77 time_t TS = ServerCommand::ExtractTS(params[1]);
79 const std::string& channel = params[0];
80 Channel* chan = ServerInstance->FindChan(channel);
81 bool apply_other_sides_modes = true;
85 chan = new Channel(channel, TS);
89 time_t ourTS = chan->age;
92 ServerInstance->SNO->WriteToSnoMask('d', "Merge FJOIN received for %s, ourTS: %lu, TS: %lu, difference: %lu",
93 chan->name.c_str(), (unsigned long)ourTS, (unsigned long)TS, (unsigned long)(ourTS - TS));
94 /* If our TS is less than theirs, we dont accept their modes */
97 apply_other_sides_modes = false;
101 // Our TS is greater than theirs, remove all modes, extensions, etc. from the channel
102 LowerTS(chan, TS, channel);
104 // XXX: If the channel does not exist in the chan hash at this point, create it so the remote modes can be applied on it.
105 // This happens to 0-user permanent channels on the losing side, because those are removed (from the chan hash, then
106 // deleted later) as soon as the permchan mode is removed from them.
107 if (ServerInstance->FindChan(channel) == NULL)
109 chan = new Channel(channel, TS);
115 /* First up, apply their channel modes if they won the TS war */
116 Modes::ChangeList modechangelist;
117 if (apply_other_sides_modes)
119 std::vector<std::string>::const_iterator paramit = params.begin() + 3;
120 const std::vector<std::string>::const_iterator lastparamit = ((params.size() > 3) ? (params.end() - 1) : params.end());
121 for (std::string::const_iterator i = params[2].begin(); i != params[2].end(); ++i)
123 ModeHandler* mh = ServerInstance->Modes->FindMode(*i, MODETYPE_CHANNEL);
127 std::string modeparam;
128 if ((paramit != lastparamit) && (mh->GetNumParams(true)))
130 modeparam = *paramit;
134 modechangelist.push_add(mh, modeparam);
137 ServerInstance->Modes->Process(srcuser, chan, NULL, modechangelist, ModeParser::MODE_LOCALONLY | ModeParser::MODE_MERGE);
138 // Reuse for prefix modes
139 modechangelist.clear();
142 TreeServer* const sourceserver = TreeServer::Get(srcuser);
144 /* Now, process every 'modes,uuid' pair */
145 irc::tokenstream users(params.back());
147 Modes::ChangeList* modechangelistptr = (apply_other_sides_modes ? &modechangelist : NULL);
148 while (users.GetToken(item))
150 ProcessModeUUIDPair(item, sourceserver, chan, modechangelistptr);
153 // Set prefix modes on their users if we lost the FJOIN or had equal TS
154 if (apply_other_sides_modes)
155 ServerInstance->Modes->Process(srcuser, chan, NULL, modechangelist, ModeParser::MODE_LOCALONLY);
160 void CommandFJoin::ProcessModeUUIDPair(const std::string& item, TreeServer* sourceserver, Channel* chan, Modes::ChangeList* modechangelist)
162 std::string::size_type comma = item.find(',');
164 // Comma not required anymore if the user has no modes
165 const std::string::size_type ubegin = (comma == std::string::npos ? 0 : comma+1);
166 std::string uuid(item, ubegin, UIDGenerator::UUID_LENGTH);
167 User* who = ServerInstance->FindUUID(uuid);
170 // Probably KILLed, ignore
174 TreeSocket* src_socket = sourceserver->GetSocket();
175 /* Check that the user's 'direction' is correct */
176 TreeServer* route_back_again = TreeServer::Get(who);
177 if (route_back_again->GetSocket() != src_socket)
182 /* Check if the user received at least one mode */
183 if ((modechangelist) && (comma > 0) && (comma != std::string::npos))
185 /* Iterate through the modes and see if they are valid here, if so, apply */
186 std::string::const_iterator commait = item.begin()+comma;
187 for (std::string::const_iterator i = item.begin(); i != commait; ++i)
189 ModeHandler* mh = ServerInstance->Modes->FindMode(*i, MODETYPE_CHANNEL);
191 throw ProtocolException("Unrecognised mode '" + std::string(1, *i) + "'");
193 /* Add any modes this user had to the mode stack */
194 modechangelist->push_add(mh, who->nick);
198 Membership* memb = chan->ForceJoin(who, NULL, sourceserver->IsBursting());
202 // Assign the id to the new Membership
203 Membership::Id membid = 0;
204 const std::string::size_type colon = item.rfind(':');
205 if (colon != std::string::npos)
206 membid = Membership::IdFromString(item.substr(colon+1));
210 void CommandFJoin::RemoveStatus(Channel* c)
212 Modes::ChangeList changelist;
214 const ModeParser::ModeHandlerMap& mhs = ServerInstance->Modes->GetModes(MODETYPE_CHANNEL);
215 for (ModeParser::ModeHandlerMap::const_iterator i = mhs.begin(); i != mhs.end(); ++i)
217 ModeHandler* mh = i->second;
219 /* Passing a pointer to a modestacker here causes the mode to be put onto the mode stack,
220 * rather than applied immediately. Module unloads require this to be done immediately,
221 * for this function we require tidyness instead. Fixes bug #493
223 mh->RemoveMode(c, changelist);
226 ServerInstance->Modes->Process(ServerInstance->FakeClient, c, NULL, changelist, ModeParser::MODE_LOCALONLY);
229 void CommandFJoin::ApplyModeStack(User* srcuser, Channel* c, irc::modestacker& stack)
231 parameterlist stackresult;
232 stackresult.push_back(c->name);
234 while (stack.GetStackedLine(stackresult))
236 ServerInstance->Modes->Process(stackresult, srcuser, ModeParser::MODE_LOCALONLY);
237 stackresult.erase(stackresult.begin() + 1, stackresult.end());
241 void CommandFJoin::LowerTS(Channel* chan, time_t TS, const std::string& newname)
243 if (Utils->AnnounceTSChange)
244 chan->WriteChannelWithServ(ServerInstance->Config->ServerName, "NOTICE %s :TS for %s changed from %lu to %lu", chan->name.c_str(), newname.c_str(), (unsigned long) chan->age, (unsigned long) TS);
246 // While the name is equal in case-insensitive compare, it might differ in case; use the remote version
247 chan->name = newname;
250 // Remove all pending invites
251 chan->ClearInvites();
254 CommandFJoin::RemoveStatus(chan);
256 // Unset all extensions
257 chan->FreeAllExtItems();
259 // Clear the topic, if it isn't empty then send a topic change message to local users
260 if (!chan->topic.empty())
263 chan->WriteChannelWithServ(ServerInstance->Config->ServerName, "TOPIC %s :", chan->name.c_str());
269 CommandFJoin::Builder::Builder(Channel* chan)
270 : CmdBuilder("FJOIN")
272 push(chan->name).push_int(chan->age).push_raw(" +");
274 push_raw(chan->ChanModes(true)).push_raw(" :");
277 void CommandFJoin::Builder::add(Membership* memb)
279 push_raw(memb->modes).push_raw(',').push_raw(memb->user->uuid);
280 push_raw(':').push_raw_int(memb->id);
284 bool CommandFJoin::Builder::has_room(Membership* memb) const
286 return ((str().size() + memb->modes.size() + UIDGenerator::UUID_LENGTH + 2 + membid_max_digits + 1) <= maxline);
289 void CommandFJoin::Builder::clear()
295 const std::string& CommandFJoin::Builder::finalize()
297 if (*content.rbegin() == ' ')
298 content.erase(content.size()-1);