bridge.cpp 26.8 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
  user_jid(user_jid),
  xmpp(xmpp),
  poller(poller)
{
}

48
/**
49 50
 * Return the role and affiliation, corresponding to the given irc mode
 */
51 52
static std::tuple<std::string, std::string> get_role_affiliation_from_irc_mode(const char mode)
{
53 54
  if (mode == 'a' || mode == 'q'){
    return std::make_tuple("moderator", "owner");}
55 56 57 58 59 60 61 62 63 64
  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");
}

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

louiz’'s avatar
louiz’ committed
74 75 76 77 78 79
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
80 81
    if (!client->is_connected() && !client->is_connecting() &&
        !client->get_resolver().is_resolving())
louiz’'s avatar
louiz’ committed
82 83 84 85 86 87
      it = this->irc_clients.erase(it);
    else
      ++it;
  }
}

88 89 90 91 92
const std::string& Bridge::get_jid() const
{
  return this->user_jid;
}

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

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

109
IrcClient* Bridge::make_irc_client(const std::string& hostname, const std::string& nickname)
110 111 112 113 114 115 116
{
  try
    {
      return this->irc_clients.at(hostname).get();
    }
  catch (const std::out_of_range& exception)
    {
117 118
      auto username = nickname;
      auto realname = nickname;
louiz’'s avatar
louiz’ committed
119
      Jid jid(this->user_jid);
120 121 122 123 124 125 126 127
      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
128
                                                            realname, jid.domain,
129
                                                            *this));
130 131 132 133 134
      std::shared_ptr<IrcClient> irc = this->irc_clients.at(hostname);
      return irc.get();
    }
}

louiz’'s avatar
louiz’ committed
135
IrcClient* Bridge::get_irc_client(const std::string& hostname)
136 137 138 139 140 141 142 143 144 145 146 147
{
  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
148 149 150 151 152 153 154 155 156 157 158
{
  try
    {
      return this->irc_clients.at(hostname).get();
    }
  catch (const std::out_of_range& exception)
    {
      return nullptr;
    }
}

159
bool Bridge::join_irc_channel(const Iid& iid, const std::string& nickname, const std::string& password)
160
{
161
  IrcClient* irc = this->make_irc_client(iid.get_server(), nickname);
louiz’'s avatar
louiz’ committed
162
  if (iid.get_local().empty())
louiz’'s avatar
louiz’ committed
163 164 165 166 167 168 169 170 171
    { // 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
172
          const IrcMessage end_join_message(std::string(iid.get_server()), "366",
louiz’'s avatar
louiz’ committed
173 174 175 176 177
                                            {irc->get_nick(),
                                                "", "End of NAMES list"});
          irc->on_channel_completely_joined(end_join_message);
        }
      else
178
        {
louiz’'s avatar
louiz’ committed
179
          irc->get_dummy_channel().joining = true;
180 181
          irc->start();
        }
louiz’'s avatar
louiz’ committed
182 183
      return true;
    }
louiz’'s avatar
louiz’ committed
184
  if (irc->is_channel_joined(iid.get_local()) == false)
louiz’'s avatar
louiz’ committed
185
    {
186
      irc->send_join_command(iid.get_local(), password);
louiz’'s avatar
louiz’ committed
187 188 189
      return true;
    }
  return false;
190 191
}

louiz’'s avatar
louiz’ committed
192 193
void Bridge::send_channel_message(const Iid& iid, const std::string& body)
{
194
  if (iid.get_server().empty())
louiz’'s avatar
louiz’ committed
195
    {
196
      this->xmpp.send_stanza_error("message", this->user_jid, std::to_string(iid), "",
197 198 199 200
                                    "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
201 202
      return;
    }
louiz’'s avatar
louiz’ committed
203
  IrcClient* irc = this->get_irc_client(iid.get_server());
204

205 206 207 208 209 210 211 212 213 214 215 216
  // 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
217
    {
louiz’'s avatar
louiz’ committed
218
      if (line.substr(0, 5) == "/mode")
219
        {
louiz’'s avatar
louiz’ committed
220
          std::vector<std::string> args = utils::split(line.substr(5), ' ', false);
louiz’'s avatar
louiz’ committed
221
          irc->send_mode_command(iid.get_local(), args);
222 223 224 225
          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
226
        irc->send_channel_message(iid.get_local(), action_prefix + line.substr(4) + "\01");
227
      else
louiz’'s avatar
louiz’ committed
228
        irc->send_channel_message(iid.get_local(), line);
229
      this->xmpp.send_muc_message(std::to_string(iid), irc->get_own_nick(),
230
                                   this->make_xmpp_body(line), this->user_jid);
louiz’'s avatar
louiz’ committed
231
    }
louiz’'s avatar
louiz’ committed
232 233
}

234 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
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
298
void Bridge::send_private_message(const Iid& iid, const std::string& body, const std::string& type)
louiz’'s avatar
louiz’ committed
299
{
louiz’'s avatar
louiz’ committed
300
  if (iid.get_local().empty() || iid.get_server().empty())
301
    {
302
      this->xmpp.send_stanza_error("message", this->user_jid, std::to_string(iid), "",
303 304 305 306
                                    "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);
307 308
      return;
    }
309
  IrcClient* irc = this->get_irc_client(iid.get_server());
310 311 312 313 314 315
  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
316
        irc->send_private_message(iid.get_local(), action_prefix + line.substr(4) + "\01", type);
317
      else
louiz’'s avatar
louiz’ committed
318
        irc->send_private_message(iid.get_local(), line, type);
319
    }
louiz’'s avatar
louiz’ committed
320 321
}

louiz’'s avatar
louiz’ committed
322 323 324 325 326 327
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
328 329
void Bridge::leave_irc_channel(Iid&& iid, std::string&& status_message)
{
louiz’'s avatar
louiz’ committed
330
  IrcClient* irc = this->get_irc_client(iid.get_server());
331
  irc->send_part_command(iid.get_local(), status_message);
louiz’'s avatar
louiz’ committed
332 333
}

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

340 341 342 343 344 345
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();
346

347 348 349 350 351 352 353
  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;
354 355 356 357 358 359
      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];
360
          this->xmpp.send_stanza_error("iq", to_jid, std::to_string(iid), iq_id,
361
                                        "wait", "service-unavailable", text, false);
362 363 364 365 366 367 368 369 370 371 372
          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
373
          this->xmpp.send_iq_room_list_result(iq_id, to_jid, std::to_string(iid), list);
374 375 376 377 378 379 380
          return true;
        }
      return false;
    };
  this->add_waiting_irc(std::move(cb));
}

381 382
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)
383
{
louiz’'s avatar
louiz’ committed
384
  IrcClient* irc = this->get_irc_client(iid.get_server());
385 386 387 388

  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
389
    {
390 391 392 393 394 395 396
      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())
397
            return false;
398
          this->xmpp.send_iq_result(iq_id, to_jid, std::to_string(iid));
399 400 401 402 403 404 405 406 407
        }
      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];
408
          this->xmpp.send_stanza_error("iq", to_jid, std::to_string(iid), iq_id, "cancel", "item-not-found",
409 410 411 412 413 414 415 416 417 418
                                        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];
419
          this->xmpp.send_stanza_error("iq", to_jid, std::to_string(iid), iq_id, "cancel", "not-allowed",
420 421 422 423 424
                                        error_message, false);
        }
      return true;
    };
  this->add_waiting_irc(std::move(cb));
425 426
}

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

louiz’'s avatar
louiz’ committed
433 434 435 436 437 438 439
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");
}

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

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");

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

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

483 484 485 486 487 488 489 490
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)
    {
491
      this->xmpp.send_stanza_error("iq", to_jid, from_jid, iq_id, "cancel", "not-allowed",
492 493 494 495 496
                                    "", true);
      return;
    }
  if (chan->get_self()->nick != nick && !chan->find_user(nick))
    {
497
      this->xmpp.send_stanza_error("iq", to_jid, from_jid, iq_id, "cancel", "item-not-found",
498 499 500 501 502 503 504 505
                                    "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);
}

506 507 508 509
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);
510
  if (irc_hostname.empty() || this->find_irc_client(irc_hostname))
511
    this->xmpp.send_iq_result(iq_id, to_jid, jid.local);
512
  else
513
    this->xmpp.send_stanza_error("iq", to_jid, from_jid, iq_id, "cancel", "service-unavailable",
514 515 516
                                  "", true);
}

517 518 519 520 521 522 523 524
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
525 526
  irc_responder_callback_t cb = [this, target, iq_id, to_jid, irc_hostname, from_jid](const std::string& hostname, const IrcMessage& message) -> bool
    {
527 528 529 530 531 532 533 534
      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);
535
          this->xmpp.send_version(iq_id, to_jid, from_jid, version);
536 537 538 539 540 541 542 543
          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];
544
          this->xmpp.send_stanza_error("iq", to_jid, from_jid, iq_id, "cancel", "item-not-found",
545 546 547 548
                                        error_message, true);
          return true;
        }
      return false;
549 550
    };
  this->add_waiting_irc(std::move(cb));
551 552
}

louiz’'s avatar
louiz’ committed
553
void Bridge::send_message(const Iid& iid, const std::string& nick, const std::string& body, const bool muc)
louiz’'s avatar
louiz’ committed
554
{
555
  const auto encoding = in_encoding_for(*this, iid);
louiz’'s avatar
louiz’ committed
556
  if (muc)
557
    this->xmpp.send_muc_message(std::to_string(iid), nick,
558
                                 this->make_xmpp_body(body, encoding), this->user_jid);
louiz’'s avatar
louiz’ committed
559
  else
560 561 562 563 564 565 566 567 568
    {
      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;
        }
569
      this->xmpp.send_message(target, this->make_xmpp_body(body, encoding),
570 571
                               this->user_jid, "chat", fulljid);
    }
louiz’'s avatar
louiz’ committed
572 573
}

574 575 576
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)
577
{
578
  this->xmpp.send_presence_error(std::to_string(iid), nick, this->user_jid, type, condition, error_code, text);
579 580
}

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

589 590 591 592 593
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
594
{
595 596 597 598
  std::string affiliation;
  std::string role;
  std::tie(role, affiliation) = get_role_affiliation_from_irc_mode(user_mode);

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

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

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

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

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

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

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

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

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

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

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

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

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

678 679 680 681 682 683
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)
684
  this->xmpp.send_ping_request(nick + "!" + utils::empty_if_fixed_server(hostname), this->user_jid, utils::revstr(id));
685 686
}

687 688 689 690 691 692 693 694 695 696 697 698 699 700 701
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);
}
702

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

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

std::unordered_map<std::string, std::shared_ptr<IrcClient>>& Bridge::get_irc_clients()
{
  return this->irc_clients;
}
724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752

void Bridge::add_resource_to_chan(const std::string& channel, const std::string& resource)
{
  auto it = this->resources_in_chan.find(channel);
  if (it == this->resources_in_chan.end())
    this->resources_in_chan[channel] = {resource};
  else
    it->second.insert(resource);
}

void Bridge::remove_resource_from_chan(const std::string& channel, const std::string& resource)
{
  auto it = this->resources_in_chan.find(channel);
  if (it != this->resources_in_chan.end())
    {
      it->second.erase(resource);
      if (it->second.empty())
        this->resources_in_chan.erase(it);
    }
}

bool Bridge::is_resource_in_chan(const std::string& channel, const std::string& resource) const
{
  auto it = this->resources_in_chan.find(channel);
  if (it != this->resources_in_chan.end())
    if (it->second.count(resource) == 1)
      return true;
  return false;
}