bridge.cpp 26 KB
Newer Older
1
#include <bridge/bridge.hpp>
2
#include <bridge/list_element.hpp>
3
#include <xmpp/biboumi_component.hpp>
4
#include <network/poller.hpp>
5
#include <utils/empty_if_fixed_server.hpp>
6
#include <utils/encoding.hpp>
7
#include <utils/tolower.hpp>
louiz’'s avatar
louiz’ committed
8
#include <logger/logger.hpp>
9
#include <utils/revstr.hpp>
louiz’'s avatar
louiz’ committed
10
#include <utils/split.hpp>
11
#include <xmpp/jid.hpp>
12
#include <database/database.hpp>
louiz’'s avatar
louiz’ committed
13

louiz’'s avatar
louiz’ committed
14 15
using namespace std::string_literals;

16 17
static const char* action_prefix = "\01ACTION ";

18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40

static std::string out_encoding_for(const Bridge& bridge, const Iid& iid)
{
#ifdef USE_DATABASE
  const auto jid = bridge.get_bare_jid();
  auto options = Database::get_irc_channel_options_with_server_default(jid, iid.get_server(), iid.get_local());
  return options.encodingOut.value();
#else
  return {"ISO-8859-1"};
#endif
}

static std::string in_encoding_for(const Bridge& bridge, const Iid& iid)
{
#ifdef USE_DATABASE
  const auto jid = bridge.get_bare_jid();
  auto options = Database::get_irc_channel_options_with_server_default(jid, iid.get_server(), iid.get_local());
  return options.encodingIn.value();
#else
  return {"ISO-8859-1"};
#endif
}

41
Bridge::Bridge(const std::string& user_jid, BiboumiComponent& xmpp, std::shared_ptr<Poller> poller):
42 43 44 45 46 47 48 49 50 51
  user_jid(user_jid),
  xmpp(xmpp),
  poller(poller)
{
}

Bridge::~Bridge()
{
}

52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67
/**
 * Return the role and affiliation, corresponding to the given irc mode */
static std::tuple<std::string, std::string> get_role_affiliation_from_irc_mode(const char mode)
{
  if (mode == 'a' || mode == 'q')
    return std::make_tuple("moderator", "owner");
  else if (mode == 'o')
    return std::make_tuple("moderator", "admin");
  else if (mode == 'h')
    return std::make_tuple("moderator", "member");
  else if (mode == 'v')
    return std::make_tuple("participant", "member");
  else
    return std::make_tuple("participant", "none");
}

68
void Bridge::shutdown(const std::string& exit_message)
louiz’'s avatar
louiz’ committed
69 70 71
{
  for (auto it = this->irc_clients.begin(); it != this->irc_clients.end(); ++it)
  {
louiz’'s avatar
louiz’ committed
72 73
    it->second->send_quit_command(exit_message);
    it->second->leave_dummy_channel(exit_message);
louiz’'s avatar
louiz’ committed
74 75 76
  }
}

louiz’'s avatar
louiz’ committed
77 78 79 80 81 82
void Bridge::clean()
{
  auto it = this->irc_clients.begin();
  while (it != this->irc_clients.end())
  {
    IrcClient* client = it->second.get();
louiz’'s avatar
louiz’ committed
83 84
    if (!client->is_connected() && !client->is_connecting() &&
        !client->get_resolver().is_resolving())
louiz’'s avatar
louiz’ committed
85 86 87 88 89 90
      it = this->irc_clients.erase(it);
    else
      ++it;
  }
}

91 92 93 94 95
const std::string& Bridge::get_jid() const
{
  return this->user_jid;
}

louiz’'s avatar
louiz’ committed
96 97 98 99 100 101
std::string Bridge::get_bare_jid() const
{
  Jid jid(this->user_jid);
  return jid.local + "@" + jid.domain;
}

102
Xmpp::body Bridge::make_xmpp_body(const std::string& str, const std::string& encoding)
103 104 105 106 107
{
  std::string res;
  if (utils::is_valid_utf8(str.c_str()))
    res = str;
  else
108
    res = utils::convert_to_utf8(str, encoding.data());
109
  return irc_format_to_xhtmlim(res);
110 111
}

112
IrcClient* Bridge::make_irc_client(const std::string& hostname, const std::string& nickname)
113 114 115 116 117 118 119
{
  try
    {
      return this->irc_clients.at(hostname).get();
    }
  catch (const std::out_of_range& exception)
    {
120 121
      auto username = nickname;
      auto realname = nickname;
louiz’'s avatar
louiz’ committed
122
      Jid jid(this->user_jid);
123 124 125 126 127 128 129 130
      if (Config::get("realname_from_jid", "false") == "true")
        {
          username = jid.local;
          realname = this->get_bare_jid();
        }
      this->irc_clients.emplace(hostname,
                                std::make_shared<IrcClient>(this->poller, hostname,
                                                            nickname, username,
louiz’'s avatar
louiz’ committed
131
                                                            realname, jid.domain,
132
                                                            *this));
133 134 135 136 137
      std::shared_ptr<IrcClient> irc = this->irc_clients.at(hostname);
      return irc.get();
    }
}

louiz’'s avatar
louiz’ committed
138
IrcClient* Bridge::get_irc_client(const std::string& hostname)
139 140 141 142 143 144 145 146 147 148 149 150
{
  try
    {
      return this->irc_clients.at(hostname).get();
    }
  catch (const std::out_of_range& exception)
    {
      throw IRCNotConnected(hostname);
    }
}

IrcClient* Bridge::find_irc_client(const std::string& hostname)
louiz’'s avatar
louiz’ committed
151 152 153 154 155 156 157 158 159 160 161
{
  try
    {
      return this->irc_clients.at(hostname).get();
    }
  catch (const std::out_of_range& exception)
    {
      return nullptr;
    }
}

162
bool Bridge::join_irc_channel(const Iid& iid, const std::string& nickname, const std::string& password)
163
{
164
  IrcClient* irc = this->make_irc_client(iid.get_server(), nickname);
louiz’'s avatar
louiz’ committed
165
  if (iid.get_local().empty())
louiz’'s avatar
louiz’ committed
166 167 168 169 170 171 172 173 174
    { // Join the dummy channel
      if (irc->is_welcomed())
        {
          if (irc->get_dummy_channel().joined)
            return false;
          // Immediately simulate a message coming from the IRC server saying that we
          // joined the channel
          const IrcMessage join_message(irc->get_nick(), "JOIN", {""});
          irc->on_channel_join(join_message);
louiz’'s avatar
louiz’ committed
175
          const IrcMessage end_join_message(std::string(iid.get_server()), "366",
louiz’'s avatar
louiz’ committed
176 177 178 179 180
                                            {irc->get_nick(),
                                                "", "End of NAMES list"});
          irc->on_channel_completely_joined(end_join_message);
        }
      else
181
        {
louiz’'s avatar
louiz’ committed
182
          irc->get_dummy_channel().joining = true;
183 184
          irc->start();
        }
louiz’'s avatar
louiz’ committed
185 186
      return true;
    }
louiz’'s avatar
louiz’ committed
187
  if (irc->is_channel_joined(iid.get_local()) == false)
louiz’'s avatar
louiz’ committed
188
    {
189
      irc->send_join_command(iid.get_local(), password);
louiz’'s avatar
louiz’ committed
190 191 192
      return true;
    }
  return false;
193 194
}

louiz’'s avatar
louiz’ committed
195 196
void Bridge::send_channel_message(const Iid& iid, const std::string& body)
{
197
  if (iid.get_server().empty())
louiz’'s avatar
louiz’ committed
198
    {
199
      this->xmpp.send_stanza_error("message", this->user_jid, std::to_string(iid), "",
200 201 202 203
                                    "cancel", "remote-server-not-found",
                                    std::to_string(iid) + " is not a valid channel name. "
                                    "A correct room jid is of the form: #<chan>%<server>",
                                    false);
louiz’'s avatar
louiz’ committed
204 205
      return;
    }
louiz’'s avatar
louiz’ committed
206
  IrcClient* irc = this->get_irc_client(iid.get_server());
207

208 209 210 211 212 213 214 215 216 217 218 219
  // Because an IRC message cannot contain \n, we need to convert each line
  // of text into a separate IRC message. For conveniance, we also cut the
  // message into submessages on the XMPP side, this way the user of the
  // gateway sees what was actually sent over IRC.  For example if an user
  // sends “hello\n/me waves”, two messages will be generated: “hello” and
  // “/me waves”. Note that the “command” handling (messages starting with
  // /me, /mode, etc) is done for each message generated this way. In the
  // above example, the /me will be interpreted.
  std::vector<std::string> lines = utils::split(body, '\n', true);
  if (lines.empty())
    return ;
  for (const std::string& line: lines)
louiz’'s avatar
louiz’ committed
220
    {
louiz’'s avatar
louiz’ committed
221
      if (line.substr(0, 5) == "/mode")
222
        {
louiz’'s avatar
louiz’ committed
223
          std::vector<std::string> args = utils::split(line.substr(5), ' ', false);
louiz’'s avatar
louiz’ committed
224
          irc->send_mode_command(iid.get_local(), args);
225 226 227 228
          continue;             // We do not want to send that back to the
                                // XMPP user, that’s not a textual message.
        }
      else if (line.substr(0, 4) == "/me ")
louiz’'s avatar
louiz’ committed
229
        irc->send_channel_message(iid.get_local(), action_prefix + line.substr(4) + "\01");
230
      else
louiz’'s avatar
louiz’ committed
231
        irc->send_channel_message(iid.get_local(), line);
232
      this->xmpp.send_muc_message(std::to_string(iid), irc->get_own_nick(),
233
                                   this->make_xmpp_body(line), this->user_jid);
louiz’'s avatar
louiz’ committed
234
    }
louiz’'s avatar
louiz’ committed
235 236
}

237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300
void Bridge::forward_affiliation_role_change(const Iid& iid, const std::string& nick,
                                             const std::string& affiliation,
                                             const std::string& role)
{
  IrcClient* irc = this->get_irc_client(iid.get_server());
  IrcChannel* chan = irc->get_channel(iid.get_local());
  if (!chan || !chan->joined)
    return;
  IrcUser* user = chan->find_user(nick);
  if (!user)
    return;
  // For each affiliation or role, we have a “maximal” mode that we want to
  // set. We must remove any superior mode at the same time. For example if
  // the user already has +o mode, and we set its affiliation to member, we
  // remove the +o mode, and add +v.  For each “superior” mode (for example,
  // for +v, the superior modes are 'h', 'a', 'o' and 'q') we check if that
  // user has it, and if yes we remove that mode

  std::size_t nb = 1;               // the number of times the nick must be
                                    // repeated in the argument list
  std::string modes;                // The string of modes to
                                    // add/remove. For example "+v-aoh"
  std::vector<char> modes_to_remove; // List of modes to check for removal
  if (affiliation == "none")
    {
      modes = "";
      nb = 0;
      modes_to_remove = {'v', 'h', 'o', 'a', 'q'};
    }
  else if (affiliation == "member")
    {
      modes = "+v";
      modes_to_remove = {'h', 'o', 'a', 'q'};
    }
  else if (role == "moderator")
    {
      modes = "+h";
      modes_to_remove = {'o', 'a', 'q'};
    }
  else if (affiliation == "admin")
    {
      modes = "+o";
      modes_to_remove = {'a', 'q'};
    }
  else if (affiliation == "owner")
    {
      modes = "+a";
      modes_to_remove = {'q'};
    }
  else
    return;
  for (const char mode: modes_to_remove)
    if (user->modes.find(mode) != user->modes.end())
      {
        modes += "-"s + mode;
        nb++;
      }
  if (modes.empty())
    return;
  std::vector<std::string> args(nb, nick);
  args.insert(args.begin(), modes);
  irc->send_mode_command(iid.get_local(), args);
}

louiz’'s avatar
louiz’ committed
301
void Bridge::send_private_message(const Iid& iid, const std::string& body, const std::string& type)
louiz’'s avatar
louiz’ committed
302
{
louiz’'s avatar
louiz’ committed
303
  if (iid.get_local().empty() || iid.get_server().empty())
304
    {
305
      this->xmpp.send_stanza_error("message", this->user_jid, std::to_string(iid), "",
306 307 308 309
                                    "cancel", "remote-server-not-found",
                                    std::to_string(iid) + " is not a valid channel name. "
                                    "A correct room jid is of the form: #<chan>%<server>",
                                    false);
310 311
      return;
    }
312
  IrcClient* irc = this->get_irc_client(iid.get_server());
313 314 315 316 317 318
  std::vector<std::string> lines = utils::split(body, '\n', true);
  if (lines.empty())
    return ;
  for (const std::string& line: lines)
    {
      if (line.substr(0, 4) == "/me ")
louiz’'s avatar
louiz’ committed
319
        irc->send_private_message(iid.get_local(), action_prefix + line.substr(4) + "\01", type);
320
      else
louiz’'s avatar
louiz’ committed
321
        irc->send_private_message(iid.get_local(), line, type);
322
    }
louiz’'s avatar
louiz’ committed
323 324
}

louiz’'s avatar
louiz’ committed
325 326 327 328 329 330
void Bridge::send_raw_message(const std::string& hostname, const std::string& body)
{
  IrcClient* irc = this->get_irc_client(hostname);
  irc->send_raw(body);
}

louiz’'s avatar
louiz’ committed
331 332
void Bridge::leave_irc_channel(Iid&& iid, std::string&& status_message)
{
louiz’'s avatar
louiz’ committed
333
  IrcClient* irc = this->get_irc_client(iid.get_server());
334
  irc->send_part_command(iid.get_local(), status_message);
louiz’'s avatar
louiz’ committed
335 336
}

louiz’'s avatar
louiz’ committed
337 338
void Bridge::send_irc_nick_change(const Iid& iid, const std::string& new_nick)
{
louiz’'s avatar
louiz’ committed
339
  IrcClient* irc = this->get_irc_client(iid.get_server());
340
  irc->send_nick_command(new_nick);
louiz’'s avatar
louiz’ committed
341 342
}

343 344 345 346 347 348
void Bridge::send_irc_channel_list_request(const Iid& iid, const std::string& iq_id,
                                           const std::string& to_jid)
{
  IrcClient* irc = this->get_irc_client(iid.get_server());

  irc->send_list_command();
349

350 351 352 353 354 355 356
  irc_responder_callback_t cb = [this, iid, iq_id, to_jid](const std::string& irc_hostname,
                                                           const IrcMessage& message) -> bool
    {
      static std::vector<ListElement> list;

      if (irc_hostname != iid.get_server())
        return false;
357 358 359 360 361 362
      if (message.command == "263" || message.command == "RPL_TRYAGAIN" ||
          message.command == "ERR_TOOMANYMATCHES" || message.command == "ERR_NOSUCHSERVER")
        {
          std::string text;
          if (message.arguments.size() >= 2)
            text = message.arguments[1];
363
          this->xmpp.send_stanza_error("iq", to_jid, std::to_string(iid), iq_id,
364
                                        "wait", "service-unavailable", text, false);
365 366 367 368 369 370 371 372 373 374 375
          return true;
        }
      else if (message.command == "322" || message.command == "RPL_LIST")
        { // Add element to list
          if (message.arguments.size() == 4)
            list.emplace_back(message.arguments[1], message.arguments[2],
                              message.arguments[3]);
          return false;
        }
      else if (message.command == "323" || message.command == "RPL_LISTEND")
        { // Send the iq response with the content of the list
376
          this->xmpp.send_iq_room_list_result(iq_id, to_jid, std::to_string(iid), list);
377 378 379 380 381 382 383
          return true;
        }
      return false;
    };
  this->add_waiting_irc(std::move(cb));
}

384 385
void Bridge::send_irc_kick(const Iid& iid, const std::string& target, const std::string& reason,
                           const std::string& iq_id, const std::string& to_jid)
386
{
louiz’'s avatar
louiz’ committed
387
  IrcClient* irc = this->get_irc_client(iid.get_server());
388 389 390 391

  irc->send_kick_command(iid.get_local(), target, reason);
  irc_responder_callback_t cb = [this, target, iq_id, to_jid, iid](const std::string& irc_hostname,
                                                                   const IrcMessage& message) -> bool
392
    {
393 394 395 396 397 398 399
      if (irc_hostname != iid.get_server())
        return false;
      if (message.command == "KICK" && message.arguments.size() >= 2)
        {
          const std::string target_later = message.arguments[1];
          const std::string chan_name_later = utils::tolower(message.arguments[0]);
          if (target_later != target || chan_name_later != iid.get_local())
400
            return false;
401
          this->xmpp.send_iq_result(iq_id, to_jid, std::to_string(iid));
402 403 404 405 406 407 408 409 410
        }
      else if (message.command == "401" && message.arguments.size() >= 2)
        {
          const std::string target_later = message.arguments[1];
          if (target_later != target)
            return false;
          std::string error_message = "No such nick";
          if (message.arguments.size() >= 3)
            error_message = message.arguments[2];
411
          this->xmpp.send_stanza_error("iq", to_jid, std::to_string(iid), iq_id, "cancel", "item-not-found",
412 413 414 415 416 417 418 419 420 421
                                        error_message, false);
        }
      else if (message.command == "482" && message.arguments.size() >= 2)
        {
          const std::string chan_name_later = utils::tolower(message.arguments[1]);
          if (chan_name_later != iid.get_local())
            return false;
          std::string error_message = "You're not channel operator";
          if (message.arguments.size() >= 3)
            error_message = message.arguments[2];
422
          this->xmpp.send_stanza_error("iq", to_jid, std::to_string(iid), iq_id, "cancel", "not-allowed",
423 424 425 426 427
                                        error_message, false);
        }
      return true;
    };
  this->add_waiting_irc(std::move(cb));
428 429
}

430 431
void Bridge::set_channel_topic(const Iid& iid, const std::string& subject)
{
louiz’'s avatar
louiz’ committed
432
  IrcClient* irc = this->get_irc_client(iid.get_server());
433
  irc->send_topic_command(iid.get_local(), subject);
434 435
}

louiz’'s avatar
louiz’ committed
436 437 438 439 440 441 442
void Bridge::send_xmpp_version_to_irc(const Iid& iid, const std::string& name, const std::string& version, const std::string& os)
{
  std::string result(name + " " + version + " " + os);

  this->send_private_message(iid, "\01VERSION "s + result + "\01", "NOTICE");
}

443 444
void Bridge::send_irc_ping_result(const Iid& iid, const std::string& id)
{
445
  this->send_private_message(iid, "\01PING "s + utils::revstr(id) + "\01", "NOTICE");
446 447 448 449 450 451 452 453 454
}

void Bridge::send_irc_user_ping_request(const std::string& irc_hostname, const std::string& nick,
                                        const std::string& iq_id, const std::string& to_jid,
                                        const std::string& from_jid)
{
  Iid iid(nick + "!" + irc_hostname);
  this->send_private_message(iid, "\01PING " + iq_id + "\01");

455
  irc_responder_callback_t cb = [this, nick=utils::tolower(nick), iq_id, to_jid, irc_hostname, from_jid](const std::string& hostname, const IrcMessage& message) -> bool
456
    {
louiz’'s avatar
louiz’ committed
457
      if (irc_hostname != hostname || message.arguments.size() < 2)
458 459 460
        return false;
      IrcUser user(message.prefix);
      const std::string body = message.arguments[1];
louiz’'s avatar
louiz’ committed
461 462
      if (message.command == "NOTICE" && utils::tolower(user.nick) == nick
          && body.substr(0, 6) == "\01PING ")
463
        {
464
          const std::string id = body.substr(6, body.size() - 7);
465 466 467
          if (id != iq_id)
            return false;
          Jid jid(from_jid);
468
          this->xmpp.send_iq_result(iq_id, to_jid, jid.local);
469 470
          return true;
        }
louiz’'s avatar
louiz’ committed
471
      if (message.command == "401" && message.arguments[1] == nick)
472 473 474 475
        {
          std::string error_message = "No such nick";
          if (message.arguments.size() >= 3)
            error_message = message.arguments[2];
476
          this->xmpp.send_stanza_error("iq", to_jid, from_jid, iq_id, "cancel", "service-unavailable",
477 478 479 480 481 482 483 484 485
                                        error_message, true);
          return true;
        }

      return false;
    };
  this->add_waiting_irc(std::move(cb));
}

486 487 488 489 490 491 492 493
void Bridge::send_irc_participant_ping_request(const Iid& iid, const std::string& nick,
                                               const std::string& iq_id, const std::string& to_jid,
                                               const std::string& from_jid)
{
  IrcClient* irc = this->get_irc_client(iid.get_server());
  IrcChannel* chan = irc->get_channel(iid.get_local());
  if (!chan->joined)
    {
494
      this->xmpp.send_stanza_error("iq", to_jid, from_jid, iq_id, "cancel", "not-allowed",
495 496 497 498 499
                                    "", true);
      return;
    }
  if (chan->get_self()->nick != nick && !chan->find_user(nick))
    {
500
      this->xmpp.send_stanza_error("iq", to_jid, from_jid, iq_id, "cancel", "item-not-found",
501 502 503 504 505 506 507 508
                                    "Recipient not in room", true);
      return;
    }

  // The user is in the room, send it a direct PING
  this->send_irc_user_ping_request(iid.get_server(), nick, iq_id, to_jid, from_jid);
}

509 510 511 512
void Bridge::on_gateway_ping(const std::string& irc_hostname, const std::string& iq_id, const std::string& to_jid,
                             const std::string& from_jid)
{
  Jid jid(from_jid);
513
  if (irc_hostname.empty() || this->find_irc_client(irc_hostname))
514
    this->xmpp.send_iq_result(iq_id, to_jid, jid.local);
515
  else
516
    this->xmpp.send_stanza_error("iq", to_jid, from_jid, iq_id, "cancel", "service-unavailable",
517 518 519
                                  "", true);
}

520 521 522 523 524 525 526 527
void Bridge::send_irc_version_request(const std::string& irc_hostname, const std::string& target,
                                      const std::string& iq_id, const std::string& to_jid,
                                      const std::string& from_jid)
{
  Iid iid(target + "!" + irc_hostname);
  this->send_private_message(iid, "\01VERSION\01");
  // TODO, add a timer to remove that waiting iq if the server does not
  // respond with a matching command before n seconds
528 529
  irc_responder_callback_t cb = [this, target, iq_id, to_jid, irc_hostname, from_jid](const std::string& hostname, const IrcMessage& message) -> bool
    {
530 531 532 533 534 535 536 537
      if (irc_hostname != hostname)
        return false;
      IrcUser user(message.prefix);
      if (message.command == "NOTICE" && user.nick == target &&
          message.arguments.size() >= 2 && message.arguments[1].substr(0, 9) == "\01VERSION ")
        {
          // remove the "\01VERSION " and the "\01" parts from the string
          const std::string version = message.arguments[1].substr(9, message.arguments[1].size() - 10);
538
          this->xmpp.send_version(iq_id, to_jid, from_jid, version);
539 540 541 542 543 544 545 546
          return true;
        }
      if (message.command == "401" && message.arguments.size() >= 2
          && message.arguments[1] == target)
        {
          std::string error_message = "No such nick";
          if (message.arguments.size() >= 3)
            error_message = message.arguments[2];
547
          this->xmpp.send_stanza_error("iq", to_jid, from_jid, iq_id, "cancel", "item-not-found",
548 549 550 551
                                        error_message, true);
          return true;
        }
      return false;
552 553
    };
  this->add_waiting_irc(std::move(cb));
554 555
}

louiz’'s avatar
louiz’ committed
556
void Bridge::send_message(const Iid& iid, const std::string& nick, const std::string& body, const bool muc)
louiz’'s avatar
louiz’ committed
557
{
558
  const auto encoding = in_encoding_for(*this, iid);
louiz’'s avatar
louiz’ committed
559
  if (muc)
560
    this->xmpp.send_muc_message(std::to_string(iid), nick,
561
                                 this->make_xmpp_body(body, encoding), this->user_jid);
louiz’'s avatar
louiz’ committed
562
  else
563 564 565 566 567 568 569 570 571
    {
      std::string target = std::to_string(iid);
      bool fulljid = false;
      auto it = this->preferred_user_from.find(iid.get_local());
      if (it != this->preferred_user_from.end())
        {
          target = it->second;
          fulljid = true;
        }
572
      this->xmpp.send_message(target, this->make_xmpp_body(body, encoding),
573 574
                               this->user_jid, "chat", fulljid);
    }
louiz’'s avatar
louiz’ committed
575 576
}

577 578 579
void Bridge::send_presence_error(const Iid& iid, const std::string& nick,
                                 const std::string& type, const std::string& condition,
                                 const std::string& error_code, const std::string& text)
580
{
581
  this->xmpp.send_presence_error(std::to_string(iid), nick, this->user_jid, type, condition, error_code, text);
582 583
}

louiz’'s avatar
louiz’ committed
584
void Bridge::send_muc_leave(Iid&& iid, std::string&& nick, const std::string& message, const bool self)
louiz’'s avatar
louiz’ committed
585
{
586
  this->xmpp.send_muc_leave(std::to_string(iid), std::move(nick), this->make_xmpp_body(message), this->user_jid, self);
587
  IrcClient* irc = this->find_irc_client(iid.get_server());
588 589
  if (irc && irc->number_of_joined_channels() == 0)
    irc->send_quit_command("");
louiz’'s avatar
louiz’ committed
590 591
}

592 593 594 595 596
void Bridge::send_nick_change(Iid&& iid,
                              const std::string& old_nick,
                              const std::string& new_nick,
                              const char user_mode,
                              const bool self)
louiz’'s avatar
louiz’ committed
597
{
598 599 600 601
  std::string affiliation;
  std::string role;
  std::tie(role, affiliation) = get_role_affiliation_from_irc_mode(user_mode);

602
  this->xmpp.send_nick_change(std::to_string(iid),
603
                               old_nick, new_nick, affiliation, role, this->user_jid, self);
louiz’'s avatar
louiz’ committed
604 605
}

606 607
void Bridge::send_xmpp_message(const std::string& from, const std::string& author, const std::string& msg)
{
louiz’'s avatar
louiz’ committed
608 609
  std::string body;
  if (!author.empty())
610 611
    {
      IrcUser user(author);
louiz’'s avatar
louiz’ committed
612
      body = "\u000303"s + user.nick + (user.host.empty()?
louiz’'s avatar
louiz’ committed
613 614
                                        "\u0003: ":
                                        (" (\u000310" + user.host + "\u000303)\u0003: ")) + msg;
615
    }
louiz’'s avatar
louiz’ committed
616 617
  else
    body = msg;
618 619 620

  const auto encoding = in_encoding_for(*this, {from});
  this->xmpp.send_message(from, this->make_xmpp_body(body, encoding), this->user_jid, "chat");
621 622
}

623 624
void Bridge::send_user_join(const std::string& hostname,
                            const std::string& chan_name,
625
                            const IrcUser* user,
626
                            const char user_mode,
627
                            const bool self)
628
{
629 630 631 632
  std::string affiliation;
  std::string role;
  std::tie(role, affiliation) = get_role_affiliation_from_irc_mode(user_mode);

633
  this->xmpp.send_user_join(chan_name + utils::empty_if_fixed_server("%" + hostname), user->nick, user->host,
634
                             affiliation, role, this->user_jid, self);
635 636
}

637
void Bridge::send_topic(const std::string& hostname, const std::string& chan_name, const std::string& topic)
638
{
639 640
  const auto encoding = in_encoding_for(*this, {chan_name + '%' + hostname});
  this->xmpp.send_topic(chan_name + utils::empty_if_fixed_server("%" + hostname), this->make_xmpp_body(topic, encoding), this->user_jid);
641
}
louiz’'s avatar
louiz’ committed
642 643 644

std::string Bridge::get_own_nick(const Iid& iid)
{
645
  IrcClient* irc = this->find_irc_client(iid.get_server());
louiz’'s avatar
louiz’ committed
646 647 648 649
  if (irc)
    return irc->get_own_nick();
  return "";
}
650

651
size_t Bridge::active_clients() const
louiz’'s avatar
louiz’ committed
652 653 654 655
{
  return this->irc_clients.size();
}

656 657
void Bridge::kick_muc_user(Iid&& iid, const std::string& target, const std::string& reason, const std::string& author)
{
658
  this->xmpp.kick_user(std::to_string(iid), target, reason, author, this->user_jid);
659
}
660 661 662

void Bridge::send_nickname_conflict_error(const Iid& iid, const std::string& nickname)
{
663
  this->xmpp.send_presence_error(std::to_string(iid), nickname, this->user_jid, "cancel", "conflict", "409", "");
664
}
665 666 667 668 669

void Bridge::send_affiliation_role_change(const Iid& iid, const std::string& target, const char mode)
{
  std::string role;
  std::string affiliation;
670 671

  std::tie(role, affiliation) = get_role_affiliation_from_irc_mode(mode);
672
  this->xmpp.send_affiliation_role_change(std::to_string(iid), target, affiliation, role, this->user_jid);
673
}
674 675 676

void Bridge::send_iq_version_request(const std::string& nick, const std::string& hostname)
{
677
  this->xmpp.send_iq_version_request(nick + "!" + utils::empty_if_fixed_server(hostname), this->user_jid);
678
}
679

680 681 682 683 684 685
void Bridge::send_xmpp_ping_request(const std::string& nick, const std::string& hostname,
                                    const std::string& id)
{
  // Use revstr because the forwarded ping to target XMPP user must not be
  // the same that the request iq, but we also need to get it back easily
  // (revstr again)
686
  this->xmpp.send_ping_request(nick + "!" + utils::empty_if_fixed_server(hostname), this->user_jid, utils::revstr(id));
687 688
}

689 690 691 692 693 694 695 696 697 698 699 700 701 702 703
void Bridge::set_preferred_from_jid(const std::string& nick, const std::string& full_jid)
{
  auto it = this->preferred_user_from.find(nick);
  if (it == this->preferred_user_from.end())
    this->preferred_user_from.emplace(nick, full_jid);
  else
    this->preferred_user_from[nick] = full_jid;
}

void Bridge::remove_preferred_from_jid(const std::string& nick)
{
  auto it = this->preferred_user_from.find(nick);
  if (it != this->preferred_user_from.end())
    this->preferred_user_from.erase(it);
}
704

705
void Bridge::add_waiting_irc(irc_responder_callback_t&& callback)
706
{
707
  this->waiting_irc.emplace_back(std::move(callback));
708 709
}

710
void Bridge::trigger_on_irc_message(const std::string& irc_hostname, const IrcMessage& message)
711
{
712 713
  auto it = this->waiting_irc.begin();
  while (it != this->waiting_irc.end())
714 715
    {
      if ((*it)(irc_hostname, message) == true)
716
        it = this->waiting_irc.erase(it);
717 718 719 720
      else
        ++it;
    }
}
721 722 723 724 725

std::unordered_map<std::string, std::shared_ptr<IrcClient>>& Bridge::get_irc_clients()
{
  return this->irc_clients;
}