X-Git-Url: https://git.netwichtig.de/gitweb/?a=blobdiff_plain;f=src%2Fmodules%2Fm_spanningtree%2Fcompat.cpp;h=8d24cfe90619140bb617cbb4f244fb1c0e2ec055;hb=7a58d288d0fd005795a8ac6908fc91bf350174d6;hp=b2967af3bd377bb7789f4f268cc98f598682a2eb;hpb=b2ac8cc0a6405946a388b80df3be21bc276a61f3;p=user%2Fhenk%2Fcode%2Finspircd.git diff --git a/src/modules/m_spanningtree/compat.cpp b/src/modules/m_spanningtree/compat.cpp index b2967af3b..8d24cfe90 100644 --- a/src/modules/m_spanningtree/compat.cpp +++ b/src/modules/m_spanningtree/compat.cpp @@ -35,20 +35,19 @@ void TreeSocket::WriteLine(const std::string& original_line) { if (LinkState == CONNECTED) { - if (original_line.c_str()[0] != ':') - { - ServerInstance->Logs->Log(MODNAME, LOG_DEFAULT, "Sending line without server prefix!"); - WriteLine(":" + ServerInstance->Config->GetSID() + " " + original_line); - return; - } if (proto_version != ProtocolVersion) { std::string line = original_line; std::string::size_type a = line.find(' '); + if (line[0] == '@') + { + // The line contains tags which the 1202 protocol can't handle. + line.erase(0, a + 1); + a = line.find(' '); + } std::string::size_type b = line.find(' ', a + 1); std::string command(line, a + 1, b-a-1); // now try to find a translation entry - // TODO a more efficient lookup method will be needed later if (proto_version < 1205) { if (command == "IJOIN") @@ -309,6 +308,11 @@ void TreeSocket::WriteLine(const std::string& original_line) push.append(line, 26, std::string::npos); push.swap(line); } + else if (command == "TAGMSG") + { + // Drop IRCv3 tag messages as v2 has no message tag support. + return; + } } WriteLineNoCompat(line); return; @@ -489,9 +493,19 @@ bool TreeSocket::PreProcessOldProtocolMessage(User*& who, std::string& cmd, Comm params[1].swap(params[3]); params.erase(params.begin()+2, params.begin()+4); - // If the source of this SERVER message is not bursting, then new servers it introduces are bursting - TreeServer* server = TreeServer::Get(who); - if (!server->IsBursting()) + // If the source of this SERVER message or any of its parents are bursting, then new servers it + // introduces are not bursting. + bool bursting = false; + for (TreeServer* server = TreeServer::Get(who); server; server = server->GetParent()) + { + if (server->IsBursting()) + { + bursting = true; + break; + } + } + + if (!bursting) params.insert(params.begin()+2, "burst=" + ConvToStr(((uint64_t)ServerInstance->Time())*1000)); } else if (cmd == "BURST") @@ -504,6 +518,11 @@ bool TreeSocket::PreProcessOldProtocolMessage(User*& who, std::string& cmd, Comm // SVSWATCH was removed because nothing was using it, but better be sure return false; } + else if (cmd == "SVSSILENCE") + { + // SVSSILENCE was removed because nothing was using it, but better be sure + return false; + } else if (cmd == "PUSH") { if ((params.size() != 2) || (!this->MyRoot)) @@ -521,7 +540,7 @@ bool TreeSocket::PreProcessOldProtocolMessage(User*& who, std::string& cmd, Comm // See if it's a numeric being sent to the target via PUSH unsigned int numeric_number = 0; if (token.length() == 3) - numeric_number = ConvToInt(token); + numeric_number = ConvToNum(token); if ((numeric_number > 0) && (numeric_number < 1000)) {