Updated version 3.0 from 'upstream/3.0'

with Debian dir 0f18938e98f5a466f36719f60cef0490163ab845
author: Vasudev Kamath <vasudev@copyninja.info> 2016-10-23 21:09:41 +0530
committer: Vasudev Kamath <vasudev@copyninja.info> 2016-10-23 21:09:41 +0530
commit: 4e4de7284e6e4d89d182ea459823bbec1e408842 (patch)
tree: 47e0ed5216b48649b138f168f61fddca2b0c076a /tests
parent: dfb3a6edfacf2f16a8a63690b3e8058b6295d1a3 (diff)
parent: eda4b75b1cff83336e87da90efca9fd6b4ced2c7 (diff)
download: biboumi-4e4de7284e6e4d89d182ea459823bbec1e408842.tar.gz
biboumi-4e4de7284e6e4d89d182ea459823bbec1e408842.tar.bz2
biboumi-4e4de7284e6e4d89d182ea459823bbec1e408842.tar.xz
biboumi-4e4de7284e6e4d89d182ea459823bbec1e408842.zip
18 files changed, 2426 insertions, 0 deletions
diff --git a/tests/colors.cpp b/tests/colors.cpp
new file mode 100644
index 0000000..bf52989
--- /dev/null
+++ b/tests/colors.cpp
@@ -0,0 +1,54 @@
+#include "catch.hpp"
+
+#include <bridge/colors.hpp>
+#include <xmpp/xmpp_stanza.hpp>
+
+#include <memory>
+
+TEST_CASE("IRC colors parsing")
+{
+  std::unique_ptr<XmlNode> xhtml;
+  std::string cleaned_up;
+
+  std::tie(cleaned_up, xhtml) = irc_format_to_xhtmlim("bold");
+  CHECK(xhtml);
+  CHECK(xhtml->to_string() == "<body xmlns='http://www.w3.org/1999/xhtml'><span style='font-weight:bold;'>bold</span></body>");
+
+  std::tie(cleaned_up, xhtml) =
+    irc_format_to_xhtmlim("normalboldunder-and-boldbold normal"
+                          "5red,5default-on-red10,2cyan-on-blue");
+  CHECK(xhtml);
+  CHECK(xhtml->to_string() == "<body xmlns='http://www.w3.org/1999/xhtml'>normal<span style='font-weight:bold;'>bold</span><span style='font-weight:bold;text-decoration:underline;'>under-and-bold</span><span style='font-weight:bold;'>bold</span> normal<span style='color:red;'>red</span><span style='background-color:red;'>default-on-red</span><span style='color:cyan;background-color:blue;'>cyan-on-blue</span></body>");
+  CHECK(cleaned_up == "normalboldunder-and-boldbold normalreddefault-on-redcyan-on-blue");
+
+  std::tie(cleaned_up, xhtml) = irc_format_to_xhtmlim("normal");
+  CHECK_FALSE(xhtml);
+  CHECK(cleaned_up == "normal");
+
+  std::tie(cleaned_up, xhtml) = irc_format_to_xhtmlim("");
+  CHECK(xhtml);
+  CHECK(!xhtml->has_children());
+  CHECK(cleaned_up.empty());
+
+  std::tie(cleaned_up, xhtml) = irc_format_to_xhtmlim(",a");
+  CHECK(xhtml);
+  CHECK(!xhtml->has_children());
+  CHECK(cleaned_up == "a");
+
+  std::tie(cleaned_up, xhtml) = irc_format_to_xhtmlim(",");
+  CHECK(xhtml);
+  CHECK(!xhtml->has_children());
+  CHECK(cleaned_up.empty());
+
+  std::tie(cleaned_up, xhtml) = irc_format_to_xhtmlim("[\x1D13dolphin-emu/dolphin\x1D] 03foo commented on #283 (Add support for the guide button to XInput): 02http://example.com");
+  CHECK(xhtml->to_string() == "<body xmlns='http://www.w3.org/1999/xhtml'>[<span style='font-style:italic;'/><span style='font-style:italic;color:lightmagenta;'>dolphin-emu/dolphin</span><span style='color:lightmagenta;'>] </span><span style='color:green;'>foo</span> commented on #283 (Add support for the guide button to XInput): <span style='text-decoration:underline;'/><span style='text-decoration:underline;color:blue;'>http://example.com</span><span style='text-decoration:underline;'/></body>");
+  CHECK(cleaned_up == "[dolphin-emu/dolphin] foo commented on #283 (Add support for the guide button to XInput): http://example.com");
+
+  std::tie(cleaned_up, xhtml) = irc_format_to_xhtmlim("0e46ab by 03Pierre Dindon [090|091|040] 02http://example.net/Ojrh4P media: avoid pop-in effect when loading thumbnails by specifying an explicit size");
+  CHECK(cleaned_up == "0e46ab by Pierre Dindon [0|1|0] http://example.net/Ojrh4P media: avoid pop-in effect when loading thumbnails by specifying an explicit size");
+  CHECK(xhtml->to_string() == "<body xmlns='http://www.w3.org/1999/xhtml'>0e46ab by <span style='color:green;'>Pierre Dindon</span> [<span style='color:lightgreen;'>0</span>|<span style='color:lightgreen;'>1</span>|<span style='color:indianred;'>0</span>] <span style='text-decoration:underline;'/><span style='text-decoration:underline;color:blue;'>http://example.net/Ojrh4P</span><span style='text-decoration:underline;'/> media: avoid pop-in effect when loading thumbnails by specifying an explicit size</body>");
+
+  std::tie(cleaned_up, xhtml) = irc_format_to_xhtmlim("test\ncoucou");
+  CHECK(cleaned_up == "test\ncoucou");
+  CHECK(xhtml->to_string() == "<body xmlns='http://www.w3.org/1999/xhtml'>test<br/>coucou</body>");
+}
diff --git a/tests/config.cpp b/tests/config.cpp
new file mode 100644
index 0000000..ddea151
--- /dev/null
+++ b/tests/config.cpp
@@ -0,0 +1,54 @@
+#include "catch.hpp"
+
+#include <config/config.hpp>
+
+TEST_CASE("Config basic")
+{
+  // Write a value in the config file
+  Config::read_conf("test.cfg");
+  Config::set("coucou", "bonjour", true);
+  Config::clear();
+
+  bool error = false;
+  try
+    {
+      CHECK(Config::read_conf());
+      CHECK(Config::get("coucou", "") == "bonjour");
+      CHECK(Config::get("does not exist", "default") == "default");
+      Config::clear();
+    }
+  catch (const std::ios::failure& e)
+    {
+      error = true;
+    }
+  CHECK_FALSE(error);
+}
+
+TEST_CASE("Config callbacks")
+{
+  bool switched = false;
+  Config::connect([&switched]()
+                  {
+                    switched = !switched;
+                  });
+  CHECK_FALSE(switched);
+  Config::set("un", "deux", true);
+  CHECK(switched);
+  Config::set("un", "trois", true);
+  CHECK_FALSE(switched);
+
+  Config::set("un", "trois", false);
+  CHECK_FALSE(switched);
+}
+
+TEST_CASE("Config get_int")
+{
+  auto res = Config::get_int("number", 0);
+  CHECK(res == 0);
+  Config::set("number", "88");
+  res = Config::get_int("number", 0);
+  CHECK(res == 88);
+  Config::set("number", "pouet");
+  res = Config::get_int("number", -1);
+  CHECK(res == 0);
+}
diff --git a/tests/database.cpp b/tests/database.cpp
new file mode 100644
index 0000000..4e2be14
--- /dev/null
+++ b/tests/database.cpp
@@ -0,0 +1,97 @@
+#include "catch.hpp"
+
+#include <database/database.hpp>
+
+#include <config/config.hpp>
+
+TEST_CASE("Database")
+{
+#ifdef USE_DATABASE
+  Database::open(":memory:");
+  Database::set_verbose(false);
+
+  SECTION("Basic retrieve and update")
+    {
+      auto o = Database::get_irc_server_options("zouzou@example.com", "irc.example.com");
+      o.update();
+      auto a = Database::get_irc_server_options("zouzou@example.com", "irc.example.com");
+      auto b = Database::get_irc_server_options("moumou@example.com", "irc.example.com");
+
+      // b does not yet exist in the db, the object is created but not yet
+      // inserted
+      CHECK(1 == Database::count<db::IrcServerOptions>());
+
+      b.update();
+      CHECK(2 == Database::count<db::IrcServerOptions>());
+
+      CHECK(b.pass == "");
+      CHECK(b.pass.value() == "");
+    }
+
+  SECTION("channel options")
+    {
+      Config::set("db_name", ":memory:");
+      auto o = Database::get_irc_channel_options("zouzou@example.com", "irc.example.com", "#foo");
+
+      CHECK(o.encodingIn == "");
+      o.encodingIn = "ISO-8859-1";
+      o.update();
+      auto b = Database::get_irc_channel_options("zouzou@example.com", "irc.example.com", "#foo");
+      CHECK(o.encodingIn == "ISO-8859-1");
+    }
+
+  SECTION("Channel options with server default")
+    {
+      const std::string owner{"zouzou@example.com"};
+      const std::string server{"irc.example.com"};
+      const std::string chan1{"#foo"};
+
+      auto c = Database::get_irc_channel_options(owner, server, chan1);
+      auto s = Database::get_irc_server_options(owner, server);
+
+      GIVEN("An option defined for the channel but not the server")
+      {
+        c.encodingIn = "channelEncoding";
+        c.update();
+        WHEN("we fetch that option")
+          {
+            auto r = Database::get_irc_channel_options_with_server_default(owner, server, chan1);
+            THEN("we get the channel option")
+              CHECK(r.encodingIn == "channelEncoding");
+          }
+      }
+      GIVEN("An option defined for the server but not the channel")
+        {
+          s.encodingIn = "serverEncoding";
+          s.update();
+        WHEN("we fetch that option")
+          {
+            auto r = Database::get_irc_channel_options_with_server_default(owner, server, chan1);
+            THEN("we get the server option")
+              CHECK(r.encodingIn == "serverEncoding");
+          }
+        }
+      GIVEN("An option defined for both the server and the channel")
+        {
+          s.encodingIn = "serverEncoding";
+          s.update();
+          c.encodingIn = "channelEncoding";
+          c.update();
+        WHEN("we fetch that option")
+          {
+            auto r = Database::get_irc_channel_options_with_server_default(owner, server, chan1);
+            THEN("we get the channel option")
+              CHECK(r.encodingIn == "channelEncoding");
+          }
+        WHEN("we fetch that option, with no channel specified")
+          {
+            auto r = Database::get_irc_channel_options_with_server_default(owner, server, "");
+            THEN("we get the server option")
+              CHECK(r.encodingIn == "serverEncoding");
+          }
+        }
+    }
+
+  Database::close();
+#endif
+}
diff --git a/tests/dns.cpp b/tests/dns.cpp
new file mode 100644
index 0000000..c3eda7b
--- /dev/null
+++ b/tests/dns.cpp
@@ -0,0 +1,91 @@
+#include "catch.hpp"
+
+#include <network/dns_handler.hpp>
+#include <network/resolver.hpp>
+#include <network/poller.hpp>
+
+#include <utils/timed_events.hpp>
+
+TEST_CASE("DNS resolver")
+{
+    Resolver resolver;
+    Resolver resolver2;
+    Resolver resolver3;
+
+    /**
+     * If we are using cares, we need to run a poller loop until each
+     * resolution is finished. Without cares we get the result before
+     * resolve() returns because it’s blocking.
+     */
+#ifdef CARES_FOUND
+    auto p = std::make_shared<Poller>();
+
+    const auto loop = [&p]()
+      {
+        do
+          {
+            DNSHandler::instance.watch_dns_sockets(p);
+          }
+        while (p->poll(utils::no_timeout) != -1);
+      };
+#else
+    // We don’t need to do anything if we are not using cares.
+    const auto loop = [](){};
+#endif
+
+    std::string hostname;
+    std::string port = "6667";
+
+    bool success = true;
+
+    const auto error_cb = [&success](const std::string& hostname)
+    {
+        return [&success, hostname](const char *msg)
+        {
+            INFO("Failed to resolve " << hostname << ":" << msg);
+            success = false;
+        };
+    };
+    const auto success_cb = [&success](const std::string& hostname)
+    {
+        return [&success, hostname](const struct addrinfo *addr)
+        {
+            INFO("Successfully resolved " << hostname << ": " << addr_to_string(addr));
+            success = true;
+        };
+    };
+
+    hostname = "example.com";
+    resolver.resolve(hostname, port,
+                     success_cb(hostname), error_cb(hostname));
+    hostname = "poez.io";
+    resolver2.resolve(hostname, port,
+                      success_cb(hostname), error_cb(hostname));
+    hostname = "louiz.org";
+    resolver3.resolve(hostname, port,
+                      success_cb(hostname), error_cb(hostname));
+    loop();
+    CHECK(success);
+
+    hostname = "this.should.fail.because.it.is..misformatted";
+    resolver.resolve(hostname, port,
+        success_cb(hostname), error_cb(hostname));
+    loop();
+    CHECK(!success);
+
+    hostname = "this.should.fail.because.it.is.does.not.exist.invalid";
+    resolver.resolve(hostname, port,
+        success_cb(hostname), error_cb(hostname));
+    loop();
+    CHECK(!success);
+
+    hostname = "localhost";
+    resolver.resolve(hostname, port,
+        success_cb(hostname), error_cb(hostname));
+    loop();
+    CHECK(success);
+
+#ifdef CARES_FOUND
+    DNSHandler::instance.destroy();
+#endif
+}
diff --git a/tests/encoding.cpp b/tests/encoding.cpp
new file mode 100644
index 0000000..389cf23
--- /dev/null
+++ b/tests/encoding.cpp
@@ -0,0 +1,56 @@
+#include "catch.hpp"
+
+#include <utils/encoding.hpp>
+
+
+TEST_CASE("UTF-8 validation")
+{
+  const char* valid = "C̡͔͕̩͙̽ͫ̈́ͥ̿̆ͧ̚r̸̩̘͍̻͖̆͆͛͊̉̕͡o͇͈̳̤̱̊̈͢q̻͍̦̮͕ͥͬͬ̽ͭ͌̾ͅǔ͉͕͇͚̙͉̭͉̇̽ȇ͈̮̼͍͔ͣ͊͞͝ͅ ͫ̾ͪ̓ͥ̆̋̔҉̢̦̠͈͔̖̲̯̦ụ̶̯͐̃̋ͮ͆͝n̬̱̭͇̻̱̰̖̤̏͛̏̿̑͟ë́͐҉̸̥̪͕̹̻̙͉̰ ̹̼̱̦̥ͩ͑̈́͑͝ͅt͍̥͈̹̝ͣ̃̔̈̔ͧ̕͝ḙ̸̖̟̙͙ͪ͢ų̯̞̼̲͓̻̞͛̃̀́b̮̰̗̩̰̊̆͗̾̎̆ͯ͌͝.̗̙͎̦ͫ̈́ͥ͌̈̓ͬ";
+  CHECK(utils::is_valid_utf8(valid));
+  CHECK_FALSE(utils::is_valid_utf8("\xF0\x0F"));
+  CHECK_FALSE(utils::is_valid_utf8("\xFE\xFE\xFF\xFF"));
+
+  std::string in = "Biboumi ╯°□°）╯︵ ┻━┻";
+  INFO(in);
+  CHECK(utils::is_valid_utf8(in.data()));
+}
+
+TEST_CASE("UTF-8 conversion")
+{
+  std::string in = "Biboumi ╯°□°）╯︵ ┻━┻";
+  REQUIRE(utils::is_valid_utf8(in.data()));
+
+  SECTION("Converting UTF-8 to UTF-8 should return the same string")
+    {
+      std::string res = utils::convert_to_utf8(in, "UTF-8");
+      CHECK(utils::is_valid_utf8(res.c_str()) == true);
+      CHECK(res == in);
+    }
+
+  SECTION("Testing latin-1 conversion")
+    {
+      std::string original_utf8("couc¥ou");
+      std::string original_latin1("couc\xa5ou");
+
+      SECTION("Convert proper latin-1 to UTF-8")
+        {
+          std::string from_latin1 = utils::convert_to_utf8(original_latin1.c_str(), "ISO-8859-1");
+          CHECK(from_latin1 == original_utf8);
+        }
+      SECTION("Check the behaviour when the decoding fails (here because we provide a wrong charset)")
+        {
+          std::string from_ascii = utils::convert_to_utf8(original_latin1, "US-ASCII");
+          CHECK(from_ascii == "couc�ou");
+        }
+    }
+}
+
+TEST_CASE("Remove invalid XML chars")
+{
+  std::string without_ctrl_char("𤭢€¢$");
+  std::string in = "Biboumi ╯°□°）╯︵ ┻━┻";
+  INFO(in);
+  CHECK(utils::remove_invalid_xml_chars(without_ctrl_char) == without_ctrl_char);
+  CHECK(utils::remove_invalid_xml_chars(in) == in);
+  CHECK(utils::remove_invalid_xml_chars("\acouco\u0008u\uFFFEt\uFFFFe\r\n♥") == "coucoute\r\n♥");
+}
diff --git a/tests/end_to_end/__main__.py b/tests/end_to_end/__main__.py
new file mode 100644
index 0000000..4348197
--- /dev/null
+++ b/tests/end_to_end/__main__.py
@@ -0,0 +1,1027 @@
+#!/usr/bin/env python3
+
+import collections
+import slixmpp
+import asyncio
+import logging
+import signal
+import atexit
+import lxml.etree
+import sys
+import io
+import os
+from functools import partial
+from slixmpp.xmlstream.matcher.base import MatcherBase
+
+
+class MatchAll(MatcherBase):
+    """match everything"""
+
+    def match(self, xml):
+        return True
+
+
+class StanzaError(Exception):
+    """
+    Raised when a step fails.
+    """
+    pass
+
+
+class SkipStepError(Exception):
+    """
+    Raised by a step when it needs to be skiped, by running
+    the next available step immediately.
+    """
+    pass
+
+
+class XMPPComponent(slixmpp.BaseXMPP):
+    """
+    XMPPComponent sending a “scenario” of stanzas, checking that the responses
+    match the expected results.
+    """
+
+    def __init__(self, scenario, biboumi):
+        super().__init__(jid="biboumi.localhost", default_ns="jabber:component:accept")
+        self.is_component = True
+        self.stream_header = '<stream:stream %s %s from="%s" id="%s">' % (
+            'xmlns="jabber:component:accept"',
+            'xmlns:stream="%s"' % self.stream_ns,
+            self.boundjid, self.get_id())
+        self.stream_footer = "</stream:stream>"
+
+        self.register_handler(slixmpp.Callback('Match All',
+                                               MatchAll(None),
+                                               self.handle_incoming_stanza))
+
+        self.add_event_handler("session_end", self.on_end_session)
+
+        asyncio.async(self.accept_routine())
+
+        self.scenario = scenario
+        self.biboumi = biboumi
+        # A callable, taking a stanza as argument and raising a StanzaError
+        # exception if the test should fail.
+        self.stanza_checker = None
+        self.failed = False
+        self.accepting_server = None
+
+        self.saved_values = {}
+
+    def error(self, message):
+        print("[31;1mFailure[0m: %s" % (message,))
+        self.scenario.steps = []
+        self.failed = True
+
+    def on_end_session(self, event):
+        self.loop.stop()
+
+    def handle_incoming_stanza(self, stanza):
+        if self.stanza_checker:
+            try:
+                self.stanza_checker(stanza)
+            except StanzaError as e:
+                self.error(e)
+            except SkipStepError:
+                # Run the next step and then re-handle this same stanza
+                self.run_scenario()
+                return self.handle_incoming_stanza(stanza)
+            self.stanza_checker = None
+        self.run_scenario()
+
+    def run_scenario(self):
+        if scenario.steps:
+            step = scenario.steps.pop(0)
+            step(self, self.biboumi)
+        else:
+            self.biboumi.stop()
+
+    @asyncio.coroutine
+    def accept_routine(self):
+        self.accepting_server = yield from self.loop.create_server(lambda: self,
+                                                                   "127.0.0.1", "8811", reuse_address=True)
+
+    def check_stanza_against_all_expected_xpaths(self):
+        pass
+
+
+def match(stanza, xpath):
+    tree = lxml.etree.parse(io.StringIO(str(stanza)))
+    matched = tree.xpath(xpath, namespaces={'re': 'http://exslt.org/regular-expressions',
+                                            'muc_user': 'http://jabber.org/protocol/muc#user',
+                                            'disco_items': 'http://jabber.org/protocol/disco#items',
+                                            'commands': 'http://jabber.org/protocol/commands',
+                                            'dataform': 'jabber:x:data',
+                                            'version': 'jabber:iq:version'})
+    return matched
+
+
+def check_xpath(xpaths, xmpp, after, stanza):
+    for i, xpath in enumerate(xpaths):
+        matched = match(stanza, xpath)
+        if not matched:
+            raise StanzaError("Received stanza “%s” did not match expected xpath “%s”" % (stanza, xpath))
+    if after:
+        if isinstance(after, collections.Iterable):
+            for af in after:
+                af(stanza, xmpp)
+        else:
+            after(stanza, xmpp)
+
+
+def check_xpath_optional(xpaths, xmpp, after, stanza):
+    try:
+        check_xpath(xpaths, xmpp, after, stanza)
+    except StanzaError:
+        raise SkipStepError()
+
+
+class Scenario:
+    """Defines a list of actions that are executed in sequence, until one of
+    them throws an exception, or until the end.  An action can be something
+    like “send a stanza”, “receive the next stanza and check that it matches
+    the given XPath”, “send a signal”, “wait for the end of the process”,
+    etc
+    """
+
+    def __init__(self, name, steps, conf="basic"):
+        """
+        Steps is a list of 2-tuple:
+        [(action, answer), (action, answer)]
+        """
+        self.name = name
+        self.steps = []
+        self.conf = conf
+        for elem in steps:
+            if isinstance(elem, collections.Iterable):
+                for step in elem:
+                    self.steps.append(step)
+            else:
+                self.steps.append(elem)
+
+
+class ProcessRunner:
+    def __init__(self):
+        self.process = None
+        self.signal_sent = False
+        self.create = None
+
+    @asyncio.coroutine
+    def start(self):
+        self.process = yield from self.create
+
+    @asyncio.coroutine
+    def wait(self):
+        code = yield from self.process.wait()
+        return code
+
+    def stop(self):
+        if not self.signal_sent:
+            self.signal_sent = True
+            if self.process:
+                self.process.send_signal(signal.SIGINT)
+
+    def __del__(self):
+        self.stop()
+
+
+class BiboumiRunner(ProcessRunner):
+    def __init__(self, name, with_valgrind):
+        super().__init__()
+        self.name = name
+        self.fd = open("biboumi_%s_output.txt" % (name,), "w")
+        if with_valgrind:
+            self.create = asyncio.create_subprocess_exec("valgrind", "--suppressions=" + (os.environ.get("E2E_BIBOUMI_SUPP_DIR") or "") + "biboumi.supp", "--leak-check=full", "--show-leak-kinds=all",
+                                                         "--errors-for-leak-kinds=all", "--error-exitcode=16",
+                                                         "./biboumi", "test.conf", stdin=None, stdout=self.fd,
+                                                         stderr=self.fd, loop=None, limit=None)
+        else:
+            self.create = asyncio.create_subprocess_exec("./biboumi", "test.conf", stdin=None, stdout=self.fd,
+                                                         stderr=self.fd, loop=None, limit=None)
+
+
+class IrcServerRunner(ProcessRunner):
+    def __init__(self):
+        super().__init__()
+        self.create = asyncio.create_subprocess_exec("charybdis", "-foreground", "-configfile", os.getcwd() + "/../tests/end_to_end/ircd.conf",
+                                                     stderr=asyncio.subprocess.PIPE)
+
+
+def send_stanza(stanza, xmpp, biboumi):
+    replacements = common_replacements
+    replacements.update(xmpp.saved_values)
+    xmpp.send_raw(stanza.format_map(replacements))
+    asyncio.get_event_loop().call_soon(xmpp.run_scenario)
+
+
+def expect_stanza(xpaths, xmpp, biboumi, optional=False, after=None):
+    check_func = check_xpath if not optional else check_xpath_optional
+    if isinstance(xpaths, str):
+        xmpp.stanza_checker = partial(check_func, [xpaths.format_map(common_replacements)], xmpp, after)
+    elif isinstance(xpaths, tuple):
+        xmpp.stanza_checker = partial(check_func, [xpath.format_map(common_replacements) for xpath in xpaths], xmpp, after)
+    else:
+        print("Warning, from argument type passed to expect_stanza: %s" % (type(xpaths)))
+
+
+def log_message(message, xmpp, biboumi):
+    print("[33;1m%s[0m" % (message,))
+    asyncio.get_event_loop().call_soon(xmpp.run_scenario)
+
+
+class BiboumiTest:
+    """
+    Spawns a biboumi process and a fake XMPP Component that will run a
+    Scenario.  It redirects the outputs of the subprocess into separated
+    files, and detects any failure in the running of the scenario.
+    """
+
+    def __init__(self, scenario, expected_code=0):
+        self.scenario = scenario
+        self.expected_code = expected_code
+
+    def run(self, with_valgrind=True):
+        print("Running scenario: [33;1m%s[0m%s" % (self.scenario.name, " (with valgrind)" if with_valgrind else ''))
+        # Redirect the slixmpp logging into a specific file
+        output_filename = "slixmpp_%s_output.txt" % (self.scenario.name,)
+        with open(output_filename, "w"):
+            pass
+        logging.basicConfig(level=logging.DEBUG,
+                            format='%(levelname)-8s %(message)s',
+                            filename=output_filename)
+
+        with open("test.conf", "w") as fd:
+            fd.write(confs[scenario.conf])
+
+        # Start the XMPP component and biboumi
+        biboumi = BiboumiRunner(scenario.name, with_valgrind)
+        xmpp = XMPPComponent(self.scenario, biboumi)
+        asyncio.get_event_loop().run_until_complete(biboumi.start())
+
+        asyncio.get_event_loop().call_soon(xmpp.run_scenario)
+
+        xmpp.process()
+        code = asyncio.get_event_loop().run_until_complete(biboumi.wait())
+        xmpp.biboumi = None
+        scenario.steps.clear()
+        failed = False
+        if not xmpp.failed:
+            if code != self.expected_code:
+                xmpp.error("Wrong return code from biboumi's process: %d" % (code,))
+                failed = True
+            else:
+                print("[32;1mSuccess![0m")
+        else:
+            failed = True
+
+        xmpp.saved_values.clear()
+
+        if xmpp.server:
+            xmpp.accepting_server.close()
+
+        return not failed
+
+
+confs = {
+'basic':
+"""hostname=biboumi.localhost
+password=coucou
+db_name=e2e_test.sqlite
+port=8811
+admin=admin@example.com""",
+
+'fixed_server':
+"""hostname=biboumi.localhost
+password=coucou
+db_name=e2e_test.sqlite
+port=8811
+fixed_irc_server=irc.localhost
+admin=admin@example.com
+"""}
+
+common_replacements = {
+    'irc_server_one': 'irc.localhost@biboumi.localhost',
+    'irc_host_one': 'irc.localhost',
+    'biboumi_host': 'biboumi.localhost',
+    'resource_one': 'resource1',
+    'resource_two': 'resource2',
+    'nick_one': 'Nick',
+    'jid_one': 'first@example.com',
+    'jid_two': 'second@example.com',
+    'jid_admin': 'admin@example.com',
+    'nick_two': 'Bobby',
+    'lower_nick_one': 'nick',
+    'lower_nick_two': 'bobby',
+}
+
+
+def handshake_sequence():
+    return (partial(expect_stanza, "//handshake"),
+            partial(send_stanza, "<handshake xmlns='jabber:component:accept'/>"))
+
+
+def connection_begin_sequence(irc_host, jid):
+    jid = jid.format_map(common_replacements)
+    xpath    = "/message[@to='" + jid + "'][@from='irc.localhost@biboumi.localhost']/body[text()='%s']"
+    xpath_re = "/message[@to='" + jid + "'][@from='irc.localhost@biboumi.localhost']/body[re:test(text(), '%s')]"
+    return (
+    partial(expect_stanza,
+            xpath % ('Connecting to %s:6697 (encrypted)' % irc_host)),
+    partial(expect_stanza,
+            xpath % 'Connection failed: Connection refused'),
+    partial(expect_stanza,
+            xpath % ('Connecting to %s:6670 (encrypted)' % irc_host)),
+    partial(expect_stanza,
+            xpath % 'Connection failed: Connection refused'),
+    partial(expect_stanza,
+            xpath % ('Connecting to %s:6667 (not encrypted)' % irc_host)),
+    partial(expect_stanza,
+            xpath % 'Connected to IRC server.'),
+    # These two messages can be receive in any order
+    partial(expect_stanza,
+            xpath_re % (r'^%s: \*\*\* (Checking Ident|Looking up your hostname...)$' % irc_host)),
+    partial(expect_stanza,
+            xpath_re % (r'^%s: \*\*\* (Checking Ident|Looking up your hostname...)$' % irc_host)),
+    # These three messages can be received in any order
+    partial(expect_stanza,
+            xpath_re % (r'^%s: (\*\*\* Found your hostname: .*|ACK multi-prefix|\*\*\* No Ident response)$' % irc_host)),
+    partial(expect_stanza,
+            xpath_re % (r'^%s: (\*\*\* Found your hostname: .*|ACK multi-prefix|\*\*\* No Ident response)$' % irc_host)),
+    partial(expect_stanza,
+            xpath_re % (r'^%s: (\*\*\* Found your hostname: .*|ACK multi-prefix|\*\*\* No Ident response)$' % irc_host)),
+    )
+
+
+def connection_end_sequence(irc_host, jid):
+    jid = jid.format_map(common_replacements)
+    xpath    = "/message[@to='" + jid + "'][@from='irc.localhost@biboumi.localhost']/body[text()='%s']"
+    xpath_re = "/message[@to='" + jid + "'][@from='irc.localhost@biboumi.localhost']/body[re:test(text(), '%s')]"
+    return (
+    partial(expect_stanza,
+            xpath_re % (r'^%s: Your host is .*$' % irc_host)),
+    partial(expect_stanza,
+            xpath_re % (r'^%s: This server was created .*$' % irc_host)),
+    partial(expect_stanza,
+            xpath_re % (r'^%s: There are \d+ users and \d+ invisible on \d+ servers$' % irc_host)),
+    partial(expect_stanza,
+            xpath_re % (r'^%s: \d+ unknown connection\(s\)$' % irc_host), optional=True),
+    partial(expect_stanza,
+            xpath_re % (r'^%s: \d+ channels formed$' % irc_host), optional=True),
+    partial(expect_stanza,
+            xpath_re % (r'^%s: I have \d+ clients and \d+ servers$' % irc_host)),
+    partial(expect_stanza,
+            xpath_re % (r'^%s: \d+ \d+ Current local users \d+, max \d+$' % irc_host)),
+    partial(expect_stanza,
+            xpath_re % (r'^%s: \d+ \d+ Current global users \d+, max \d+$' % irc_host)),
+    partial(expect_stanza,
+            xpath_re % (r'^%s: Highest connection count: \d+ \(\d+ clients\) \(\d+ connections received\)$' % irc_host)),
+    partial(expect_stanza,
+            xpath % "- This is charybdis MOTD you might replace it, but if not your friends will\n- laugh at you.\n"),
+    partial(expect_stanza,
+            xpath_re % r'^User mode for \w+ is \[\+i\]$'),
+    )
+
+
+def connection_sequence(irc_host, jid):
+    return connection_begin_sequence(irc_host, jid) + connection_end_sequence(irc_host, jid)
+
+
+def extract_attribute(xpath, name, stanza):
+    matched = match(stanza, xpath)
+    return matched[0].get(name)
+
+
+def save_value(name, func, stanza, xmpp):
+    xmpp.saved_values[name] = func(stanza)
+
+
+if __name__ == '__main__':
+
+    atexit.register(asyncio.get_event_loop().close)
+
+    # Start the test component, accepting connections on the configured
+    # port.
+    scenarios = (
+        Scenario("basic_handshake_success",
+                 [
+                     handshake_sequence()
+                 ]),
+        Scenario("irc_server_connection",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza,
+                             "<presence from='{jid_one}/{resource_one}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     connection_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                 ]),
+        Scenario("simple_channel_join",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza,
+                             "<presence from='{jid_one}/{resource_one}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     connection_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                     partial(expect_stanza,
+                             "/message/body[text()='Mode #foo [+nt] by {irc_host_one}']"),
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_one}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='admin'][@role='moderator']",
+                             "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat']/subject[not(text())]"),
+                 ]),
+        Scenario("virtual_channel_join",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza,
+                             "<presence from='{jid_one}/{resource_one}' to='%{irc_server_one}/{nick_one}' />"),
+                     connection_begin_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_one}/{resource_one}'][@from='%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='none'][@role='participant']",
+                              "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='%{irc_server_one}'][@type='groupchat']/subject[re:test(text(), '^This is a virtual channel.*$')]"),
+                     connection_end_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                 ]),
+        Scenario("channel_join_with_two_users",
+                 [
+                     handshake_sequence(),
+                     # First user joins
+                     partial(log_message,
+                             "First user joins"),
+                     partial(send_stanza,
+                             "<presence from='{jid_one}/{resource_one}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     connection_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                     partial(expect_stanza,
+                             "/message/body[text()='Mode #foo [+nt] by {irc_host_one}']"),
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_one}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='admin'][@jid='~nick@localhost'][@role='moderator']",
+                             "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat']/subject[not(text())]"),
+
+                     # Second user joins
+                     partial(log_message,
+                             "Second user joins"),
+                     partial(send_stanza,
+                             "<presence from='{jid_two}/{resource_one}' to='#foo%{irc_server_one}/{nick_two}' />"),
+                     connection_sequence("irc.localhost", '{jid_two}/{resource_one}'),
+                     # Our presence, sent to the other user
+                     partial(log_message,
+                             "Our presence sent to the other user"),
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_one}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_two}']/muc_user:x/muc_user:item[@affiliation='none'][@jid='~bobby@localhost'][@role='participant']",)),
+                     # The other user presence
+                     partial(log_message,
+                             "The other user presence"),
+                     partial(expect_stanza,
+                             "/presence[@to='{jid_second}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='none'][@jid='~nick@localhost'][@role='participant']"),
+                     # Our own presence
+                     partial(log_message,
+                             "Our own presence"),
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_two}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_two}']/muc_user:x/muc_user:item[@affiliation='none'][@jid='~bobby@localhost'][@role='participant']",
+                              "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat']/subject[not(text())]"),
+                 ]),
+        Scenario("channel_custom_topic",
+                 [
+                     handshake_sequence(),
+                     # First user joins
+                     partial(send_stanza,
+                             "<presence from='{jid_one}/{resource_one}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     connection_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                     partial(expect_stanza,
+                             "/message/body[text()='Mode #foo [+nt] by {irc_host_one}']"),
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_one}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='admin'][@jid='~nick@localhost'][@role='moderator']",
+                             "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat']/subject[not(text())]"),
+
+                     # First user sets the topic
+                     partial(send_stanza,
+                             "<message from='{jid_one}/{resource_one}' to='#foo%{irc_server_one}' type='groupchat'><subject>TOPIC TEST</subject></message>"),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}/{nick_one}'][@type='groupchat'][@to='{jid_one}/{resource_one}']/subject[text()='TOPIC TEST']"),
+
+                     # Second user joins
+                     partial(send_stanza,
+                             "<presence from='{jid_two}/{resource_one}' to='#foo%{irc_server_one}/{nick_two}' />"),
+                     connection_sequence("irc.localhost", '{jid_two}/{resource_one}'),
+                     # Our presence, sent to the other user
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_one}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_two}']/muc_user:x/muc_user:item[@affiliation='none'][@jid='~bobby@localhost'][@role='participant']",)),
+                     # The other user presence
+                     partial(expect_stanza,
+                             "/presence[@to='{jid_second}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='admin'][@jid='~nick@localhost'][@role='moderator']"),
+                     # Our own presence
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_two}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_two}']/muc_user:x/muc_user:item[@affiliation='none'][@jid='~bobby@localhost'][@role='participant']",
+                              "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}/{nick_one}'][@type='groupchat']/subject[text()='TOPIC TEST']"),
+                 ]),
+        Scenario("channel_basic_join_on_fixed_irc_server",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza,
+                     "<presence from='{jid_one}/{resource_one}' to='#zgeg@{biboumi_host}/{nick_one}' />"),
+                     connection_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                     partial(expect_stanza,
+                     "/message/body[text()='Mode #zgeg [+nt] by {irc_host_one}']"),
+                     partial(expect_stanza,
+                     ("/presence[@to='{jid_one}/{resource_one}'][@from='#zgeg@{biboumi_host}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='admin'][@role='moderator']",
+                     "/presence/muc_user:x/muc_user:status[@code='110']")
+                     ),
+                     partial(expect_stanza, "/message[@from='#zgeg@{biboumi_host}'][@type='groupchat']/subject[not(text())]"),
+                 ], conf='fixed_server'
+                 ),
+        Scenario("list_adhoc",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza, "<iq type='get' id='idwhatever' from='{jid_one}/{resource_one}' to='{biboumi_host}'><query xmlns='http://jabber.org/protocol/disco#items' node='http://jabber.org/protocol/commands' /></iq>"),
+                     partial(expect_stanza, ("/iq[@type='result']/disco_items:query[@node='http://jabber.org/protocol/commands']",
+                                             "/iq/disco_items:query/disco_items:item[3]")),
+                 ]),
+        Scenario("list_admin_adhoc",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza, "<iq type='get' id='idwhatever' from='{jid_admin}/{resource_one}' to='{biboumi_host}'><query xmlns='http://jabber.org/protocol/disco#items' node='http://jabber.org/protocol/commands' /></iq>"),
+                     partial(expect_stanza, ("/iq[@type='result']/disco_items:query[@node='http://jabber.org/protocol/commands']",
+                                             "/iq/disco_items:query/disco_items:item[5]")),
+                 ]),
+        Scenario("list_adhoc_fixed_server",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza, "<iq type='get' id='idwhatever' from='{jid_one}/{resource_one}' to='{biboumi_host}'><query xmlns='http://jabber.org/protocol/disco#items' node='http://jabber.org/protocol/commands' /></iq>"),
+                     partial(expect_stanza, ("/iq[@type='result']/disco_items:query[@node='http://jabber.org/protocol/commands']",
+                                             "/iq/disco_items:query/disco_items:item[3]")),
+                 ], conf='fixed_server'),
+        Scenario("list_admin_adhoc_fixed_server",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza, "<iq type='get' id='idwhatever' from='{jid_admin}/{resource_one}' to='{biboumi_host}'><query xmlns='http://jabber.org/protocol/disco#items' node='http://jabber.org/protocol/commands' /></iq>"),
+                     partial(expect_stanza, ("/iq[@type='result']/disco_items:query[@node='http://jabber.org/protocol/commands']",
+                                             "/iq/disco_items:query/disco_items:item[5]")),
+                 ], conf='fixed_server'),
+
+
+        Scenario("list_adhoc_irc",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza, "<iq type='get' id='idwhatever' from='{jid_one}/{resource_one}' to='{irc_host_one}@{biboumi_host}'><query xmlns='http://jabber.org/protocol/disco#items' node='http://jabber.org/protocol/commands' /></iq>"),
+                     partial(expect_stanza, ("/iq[@type='result']/disco_items:query[@node='http://jabber.org/protocol/commands']",
+                                             "/iq/disco_items:query/disco_items:item[1]")),
+                 ]),
+        Scenario("list_adhoc_irc_fixed_server",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza, "<iq type='get' id='idwhatever' from='{jid_one}/{resource_one}' to='{biboumi_host}'><query xmlns='http://jabber.org/protocol/disco#items' node='http://jabber.org/protocol/commands' /></iq>"),
+                     partial(expect_stanza, ("/iq[@type='result']/disco_items:query[@node='http://jabber.org/protocol/commands']",
+                                             "/iq/disco_items:query/disco_items:item[4]")),
+                 ], conf='fixed_server'),
+        Scenario("list_admin_adhoc_irc_fixed_server",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza, "<iq type='get' id='idwhatever' from='{jid_admin}/{resource_one}' to='{biboumi_host}'><query xmlns='http://jabber.org/protocol/disco#items' node='http://jabber.org/protocol/commands' /></iq>"),
+                     partial(expect_stanza, ("/iq[@type='result']/disco_items:query[@node='http://jabber.org/protocol/commands']",
+                                             "/iq/disco_items:query/disco_items:item[6]")),
+                 ], conf='fixed_server'),
+
+        Scenario("execute_hello_adhoc_command",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza, "<iq type='set' id='hello-command1' from='{jid_one}/{resource_one}' to='{biboumi_host}'><command xmlns='http://jabber.org/protocol/commands' node='hello' action='execute' /></iq>"),
+                     partial(expect_stanza, ("/iq[@type='result']/commands:command[@node='hello'][@sessionid][@status='executing']",
+                                             "/iq/commands:command/dataform:x[@type='form']/dataform:title[text()='Configure your name.']",
+                                             "/iq/commands:command/dataform:x[@type='form']/dataform:instructions[text()='Please provide your name.']",
+                                             "/iq/commands:command/dataform:x[@type='form']/dataform:field[@type='text-single']/dataform:required",
+                                             "/iq/commands:command/commands:actions/commands:next",
+                                             ),
+                                             after = partial(save_value, "sessionid", partial(extract_attribute, "/iq[@type='result']/commands:command[@node='hello']", "sessionid"))
+
+                             ),
+                     partial(send_stanza, "<iq type='set' id='hello-command2' from='{jid_one}/{resource_one}' to='{biboumi_host}'><command xmlns='http://jabber.org/protocol/commands' node='hello' sessionid='{sessionid}' action='next'><x xmlns='jabber:x:data' type='submit'><field var='name'><value>COUCOU</value></field></x></command></iq>"),
+                     partial(expect_stanza, "/iq[@type='result']/commands:command[@node='hello'][@status='completed']/commands:note[@type='info'][text()='Hello COUCOU!']")
+                 ]),
+        Scenario("multisessionnick",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza,
+                             "<presence from='{jid_one}/{resource_one}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     connection_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                     partial(expect_stanza,
+                             "/message/body[text()='Mode #foo [+nt] by {irc_host_one}']"),
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_one}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='admin'][@role='moderator']",
+                              "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat'][@to='{jid_one}/{resource_one}']/subject[not(text())]"),
+
+                     # The other resources joins the same room, with the same nick
+                     partial(send_stanza,
+                             "<presence from='{jid_one}/{resource_two}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     # We receive our own join
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_one}/{resource_two}'][@from='#foo%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='admin'][@role='moderator']",
+                              "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat'][@to='{jid_one}/{resource_two}']/subject[not(text())]"),
+
+                     # A different user joins the same room
+                     partial(send_stanza,
+                             "<presence from='{jid_two}/{resource_one}' to='#foo%{irc_server_one}/{nick_two}' />"),
+                     connection_sequence("irc.localhost", '{jid_two}/{resource_one}'),
+
+                     partial(expect_stanza,
+                     ("/presence[@to='{jid_one}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_two}']",)),
+                     partial(expect_stanza,
+                     ("/presence[@to='{jid_one}/{resource_two}'][@from='#foo%{irc_server_one}/{nick_two}']",)),
+
+                     partial(expect_stanza,
+                     "/presence[@to='{jid_second}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_one}']"),
+                     partial(expect_stanza,
+                     ("/presence[@to='{jid_two}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_two}']",
+                     "/presence/muc_user:x/muc_user:status[@code='110']")
+                     ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat']/subject[not(text())]"),
+
+                     # That second user sends a private message to the first one
+                     partial(send_stanza, "<message from='{jid_two}/{resource_one}' to='#foo%{irc_server_one}/{nick_one}' type='chat'><body>RELLO</body></message>"),
+                     # Message is received with a server-wide JID, by the two resources behind nick_one
+                     partial(expect_stanza, "/message[@from='{lower_nick_two}!{irc_server_one}'][@to='{jid_one}/{resource_one}'][@type='chat']/body[text()='RELLO']"),
+                     partial(expect_stanza, "/message[@from='{lower_nick_two}!{irc_server_one}'][@to='{jid_one}/{resource_two}'][@type='chat']/body[text()='RELLO']"),
+
+                     # One resource leaves the server entirely.
+                     partial(send_stanza, "<presence type='unavailable' from='{jid_one}/{resource_two}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     # The leave is forwarded only to us
+                     partial(expect_stanza,
+                             ("/presence[@type='unavailable']/muc_user:x/muc_user:status[@code='110']",
+                             "/presence/status[text()='Biboumi note: 1 resources are still in this channel.']")
+                             ),
+                     # The second user sends two new private messages to the first user
+                     partial(send_stanza, "<message from='{jid_two}/{resource_one}' to='#foo%{irc_server_one}/{nick_one}' type='chat'><body>first</body></message>"),
+                     partial(send_stanza, "<message from='{jid_two}/{resource_one}' to='#foo%{irc_server_one}/{nick_one}' type='chat'><body>second</body></message>"),
+                     # The first user receives the two messages, on the connected resource, once each
+                     partial(expect_stanza, "/message[@from='{lower_nick_two}!{irc_server_one}'][@to='{jid_one}/{resource_one}'][@type='chat']/body[text()='first']"),
+                     partial(expect_stanza, "/message[@from='{lower_nick_two}!{irc_server_one}'][@to='{jid_one}/{resource_one}'][@type='chat']/body[text()='second']"),
+
+
+                 ]),
+        Scenario("channel_messages",
+                 [
+                     handshake_sequence(),
+                     # First user joins
+                     partial(send_stanza,
+                     "<presence from='{jid_one}/{resource_one}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     connection_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                     partial(expect_stanza,
+                     "/message/body[text()='Mode #foo [+nt] by {irc_host_one}']"),
+                     partial(expect_stanza,
+                     ("/presence[@to='{jid_one}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='admin'][@jid='~nick@localhost'][@role='moderator']",
+                     "/presence/muc_user:x/muc_user:status[@code='110']")
+                     ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat']/subject[not(text())]"),
+
+                     # Second user joins
+                     partial(send_stanza,
+                     "<presence from='{jid_two}/{resource_one}' to='#foo%{irc_server_one}/{nick_two}' />"),
+                     connection_sequence("irc.localhost", '{jid_two}/{resource_one}'),
+                     # Our presence, sent to the other user
+                     partial(expect_stanza,
+                     ("/presence[@to='{jid_one}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_two}']/muc_user:x/muc_user:item[@affiliation='none'][@jid='~bobby@localhost'][@role='participant']",)),
+                     # The other user presence
+                     partial(expect_stanza,
+                     "/presence[@to='{jid_second}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='none'][@jid='~nick@localhost'][@role='participant']"),
+                     # Our own presence
+                     partial(expect_stanza,
+                     ("/presence[@to='{jid_two}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_two}']/muc_user:x/muc_user:item[@affiliation='none'][@jid='~bobby@localhost'][@role='participant']",
+                     "/presence/muc_user:x/muc_user:status[@code='110']")
+                     ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat']/subject[not(text())]"),
+
+                     # Send a channel message
+                     partial(send_stanza, "<message from='{jid_one}/{resource_one}' to='#foo%{irc_server_one}' type='groupchat'><body>coucou</body></message>"),
+                     # Receive the message, forwarded to the two users
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}/{nick_one}'][@to='{jid_one}/{resource_one}'][@type='groupchat']/body[text()='coucou']"),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}/{nick_one}'][@to='{jid_two}/{resource_one}'][@type='groupchat']/body[text()='coucou']"),
+
+                     # Send a private message, to a in-room JID
+                     partial(send_stanza, "<message from='{jid_one}/{resource_one}' to='#foo%{irc_server_one}/{nick_two}' type='chat'><body>coucou in private</body></message>"),
+                     # Message is received with a server-wide JID
+                     partial(expect_stanza, "/message[@from='{lower_nick_one}!{irc_server_one}'][@to='{jid_two}/{resource_one}'][@type='chat']/body[text()='coucou in private']"),
+
+                     # Respond to the message, to the server-wide JID
+                     partial(send_stanza, "<message from='{jid_two}/{resource_one}' to='{lower_nick_one}!{irc_server_one}' type='chat'><body>yes</body></message>"),
+                     # The response is received from the in-room JID
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}/{nick_two}'][@to='{jid_one}/{resource_one}'][@type='chat']/body[text()='yes']"),
+
+                     ## Do the exact same thing, from a different chan,
+                     # to check if the response comes from the right JID
+
+                     # Join the virtual channel
+                     partial(send_stanza,
+                     "<presence from='{jid_one}/{resource_one}' to='%{irc_server_one}/{nick_one}' />"),
+                     partial(expect_stanza,
+                     "/presence/muc_user:x/muc_user:status[@code='110']"),
+                     partial(expect_stanza, "/message[@from='%{irc_server_one}'][@type='groupchat']/subject"),
+
+
+                     # Send a private message, to a in-room JID
+                     partial(send_stanza, "<message from='{jid_one}/{resource_one}' to='%{irc_server_one}/{nick_two}' type='chat'><body>re in private</body></message>"),
+                     # Message is received with a server-wide JID
+                     partial(expect_stanza, "/message[@from='{lower_nick_one}!{irc_server_one}'][@to='{jid_two}/{resource_one}'][@type='chat']/body[text()='re in private']"),
+
+                     # Respond to the message, to the server-wide JID
+                     partial(send_stanza, "<message from='{jid_two}/{resource_one}' to='{lower_nick_one}!{irc_server_one}' type='chat'><body>re</body></message>"),
+                     # The response is received from the in-room JID
+                     partial(expect_stanza, "/message[@from='%{irc_server_one}/{nick_two}'][@to='{jid_one}/{resource_one}'][@type='chat']/body[text()='re']"),
+
+                     # Now we leave the room, to check if the subsequent private messages are still received properly
+                     partial(send_stanza,
+                     "<presence from='{jid_one}/{resource_one}' to='%{irc_server_one}/{nick_one}' type='unavailable' />"),
+                     partial(expect_stanza,
+                     "/presence[@type='unavailable']/muc_user:x/muc_user:status[@code='110']"),
+
+                     # The private messages from this nick should now come (again) from the server-wide JID
+                     partial(send_stanza, "<message from='{jid_two}/{resource_one}' to='{lower_nick_one}!{irc_server_one}' type='chat'><body>hihihoho</body></message>"),
+                     partial(expect_stanza,
+                     "/message[@from='{lower_nick_two}!{irc_server_one}'][@to='{jid_one}/{resource_one}']"),
+                 ]
+                 ),
+                Scenario("encoded_channel_join",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza,
+                             "<presence from='{jid_one}/{resource_one}' to='#biboumi\\40louiz.org\\3a80%{irc_server_one}/{nick_one}' />"),
+                     connection_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                     partial(expect_stanza,
+                             "/message/body[text()='Mode #biboumi@louiz.org:80 [+nt] by {irc_host_one}']"),
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_one}/{resource_one}'][@from='#biboumi\\40louiz.org\\3a80%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='admin'][@role='moderator']",
+                             "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='#biboumi\\40louiz.org\\3a80%{irc_server_one}'][@type='groupchat']/subject[not(text())]"),
+                 ]),
+                Scenario("self_ping_on_real_channel",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza,
+                             "<presence from='{jid_one}/{resource_one}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     connection_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                     partial(expect_stanza,
+                             "/message/body[text()='Mode #foo [+nt] by {irc_host_one}']"),
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_one}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='admin'][@role='moderator']",
+                              "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat']/subject[not(text())]"),
+
+                     # Send a ping to ourself
+                     partial(send_stanza,
+                             "<iq type='get' from='{jid_one}/{resource_one}' id='first_ping' to='#foo%{irc_server_one}/{nick_one}'><ping xmlns='urn:xmpp:ping' /></iq>"),
+                     # We receive our own ping request,
+                     partial(expect_stanza,
+                             "/iq[@from='{lower_nick_one}!{irc_server_one}'][@type='get'][@to='{jid_one}/{resource_one}'][@id='gnip_tsrif']"),
+                     # Respond to the request
+                     partial(send_stanza,
+                             "<iq type='result' to='{lower_nick_one}!{irc_server_one}' id='gnip_tsrif' from='{jid_one}/{resource_one}'/>"),
+                     partial(expect_stanza,
+                             "/iq[@from='#foo%{irc_server_one}/{nick_one}'][@type='result'][@to='{jid_one}/{resource_one}'][@id='first_ping']"),
+
+                     # Now join the same room, from the same bare JID, behind the same nick
+                     partial(send_stanza,
+                             "<presence from='{jid_one}/{resource_two}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_one}/{resource_two}'][@from='#foo%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='admin'][@role='moderator']",
+                              "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat'][@to='{jid_one}/{resource_two}']/subject[not(text())]"),
+
+                     # And re-send a self ping
+                     partial(send_stanza,
+                             "<iq type='get' from='{jid_one}/{resource_one}' id='second_ping' to='#foo%{irc_server_one}/{nick_one}'><ping xmlns='urn:xmpp:ping' /></iq>"),
+                     # We receive our own ping request. Note that we don't know the to value, it could be one of our two resources.
+                     partial(expect_stanza,
+                             "/iq[@from='{lower_nick_one}!{irc_server_one}'][@type='get'][@to][@id='gnip_dnoces']",
+                             after = partial(save_value, "to", partial(extract_attribute, "/iq", "to"))),
+                     # Respond to the request, using the extracted 'to' value as our 'from'
+                     partial(send_stanza,
+                             "<iq type='result' to='{lower_nick_one}!{irc_server_one}' id='gnip_dnoces' from='{to}'/>"),
+                     partial(expect_stanza,
+                             "/iq[@from='#foo%{irc_server_one}/{nick_one}'][@type='result'][@to='{jid_one}/{resource_one}'][@id='second_ping']"),
+                     ## And re-do exactly the same thing, just change the resource initiating the self ping
+                     partial(send_stanza,
+                             "<iq type='get' from='{jid_one}/{resource_two}' id='third_ping' to='#foo%{irc_server_one}/{nick_one}'><ping xmlns='urn:xmpp:ping' /></iq>"),
+                     partial(expect_stanza,
+                             "/iq[@from='{lower_nick_one}!{irc_server_one}'][@type='get'][@to][@id='gnip_driht']",
+                             after = partial(save_value, "to", partial(extract_attribute, "/iq", "to"))),
+                     partial(send_stanza,
+                             "<iq type='result' to='{lower_nick_one}!{irc_server_one}' id='gnip_driht' from='{to}'/>"),
+                     partial(expect_stanza,
+                             "/iq[@from='#foo%{irc_server_one}/{nick_one}'][@type='result'][@to='{jid_one}/{resource_two}'][@id='third_ping']"),
+
+                 ]),
+                Scenario("simple_kick",
+                [
+                     handshake_sequence(),
+                     # First user joins
+                     partial(send_stanza,
+                     "<presence from='{jid_one}/{resource_one}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     connection_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                     partial(expect_stanza, "/message"),
+                     partial(expect_stanza, "/presence/muc_user:x/muc_user:status[@code='110']"),
+                     partial(expect_stanza, "/message[@type='groupchat']/subject"),
+
+                     # Second user joins
+                     partial(send_stanza,
+                     "<presence from='{jid_two}/{resource_one}' to='#foo%{irc_server_one}/{nick_two}' />"),
+                     connection_sequence("irc.localhost", '{jid_two}/{resource_one}'),
+                     partial(expect_stanza,
+                     "/presence/muc_user:x/muc_user:item[@affiliation='none'][@role='participant']",),
+
+                     partial(expect_stanza,
+                     "/presence/muc_user:x/muc_user:item[@affiliation='admin'][@role='moderator']"),
+                     partial(expect_stanza,
+                     "/presence/muc_user:x/muc_user:status[@code='110']"),
+                     partial(expect_stanza, "/message/subject"),
+
+                     # Moderator kicks participant
+                     partial(log_message, "Moderator kicks participant"),
+                     partial(send_stanza,
+                     "<iq id='kick1' to='#foo%{irc_server_one}' from='{jid_one}/{resource_one}' type='set'><query xmlns='http://jabber.org/protocol/muc#admin'><item nick='{nick_two}' role='none'><reason>reported</reason></item></query></iq>"),
+                     partial(log_message, "Presence is sent to everyone"),
+                     partial(expect_stanza,
+                             ("/presence[@type='unavailable'][@to='{jid_second}/{resource_one}']/muc_user:x/muc_user:item[@role='none']/muc_user:actor[@nick='{nick_one}']",
+                              "/presence/muc_user:x/muc_user:item/muc_user:reason[text()='reported']",
+                              "/presence/muc_user:x/muc_user:status[@code='307']",
+                              "/presence/muc_user:x/muc_user:status[@code='110']"
+                             )),
+                     partial(expect_stanza,
+                             ("/presence[@type='unavailable']/muc_user:x/muc_user:item[@role='none']/muc_user:actor[@nick='{nick_one}']",
+                              "/presence/muc_user:x/muc_user:item/muc_user:reason[text()='reported']",
+                              "/presence/muc_user:x/muc_user:status[@code='307']",
+                              ),
+                             ),
+                     partial(expect_stanza,
+                     "/iq[@id='kick1'][@type='result']"),
+                ]),
+                Scenario("multisession_kick",
+                 [
+                     handshake_sequence(),
+                     # First user joins
+                     partial(send_stanza,
+                             "<presence from='{jid_one}/{resource_one}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     connection_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                     partial(expect_stanza, "/message"),
+                     partial(expect_stanza, "/presence/muc_user:x/muc_user:status[@code='110']"),
+                     partial(expect_stanza, "/message[@type='groupchat']/subject"),
+
+                     # Second user joins, from two resources
+                     partial(send_stanza,
+                             "<presence from='{jid_two}/{resource_one}' to='#foo%{irc_server_one}/{nick_two}' />"),
+                     connection_sequence("irc.localhost", '{jid_two}/{resource_one}'),
+                     partial(expect_stanza,
+                             "/presence/muc_user:x/muc_user:item[@affiliation='none'][@role='participant']",),
+
+                     partial(expect_stanza,
+                             "/presence/muc_user:x/muc_user:item[@affiliation='admin'][@role='moderator']"),
+                     partial(expect_stanza,
+                             "/presence/muc_user:x/muc_user:status[@code='110']"),
+                     partial(expect_stanza, "/message/subject"),
+
+                     partial(send_stanza,
+                             "<presence from='{jid_two}/{resource_two}' to='#foo%{irc_server_one}/{nick_two}' />"),
+                     partial(expect_stanza,
+                             "/presence[@to='{jid_two}/{resource_two}'][@from='#foo%{irc_server_one}/{nick_one}']"),
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_two}/{resource_two}'][@from='#foo%{irc_server_one}/{nick_two}']",
+                              "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat'][@to='{jid_two}/{resource_two}']/subject[not(text())]"),
+
+                     # Moderator kicks participant
+                     partial(log_message, "Moderator kicks participant"),
+                     partial(send_stanza,
+                             "<iq id='kick1' to='#foo%{irc_server_one}' from='{jid_one}/{resource_one}' type='set'><query xmlns='http://jabber.org/protocol/muc#admin'><item nick='{nick_two}' role='none'><reason>reported</reason></item></query></iq>"),
+                     partial(log_message, "Unavailable presence is sent to the two resources"),
+                     partial(expect_stanza,
+                             ("/presence[@type='unavailable'][@to='{jid_second}/{resource_one}']/muc_user:x/muc_user:item[@role='none']/muc_user:actor[@nick='{nick_one}']",
+                              "/presence/muc_user:x/muc_user:item/muc_user:reason[text()='reported']",
+                              "/presence/muc_user:x/muc_user:status[@code='307']",
+                              "/presence/muc_user:x/muc_user:status[@code='110']"
+                              )),
+                     partial(expect_stanza,
+                             ("/presence[@type='unavailable'][@to='{jid_second}/{resource_two}']/muc_user:x/muc_user:item[@role='none']/muc_user:actor[@nick='{nick_one}']",
+                              "/presence/muc_user:x/muc_user:item/muc_user:reason[text()='reported']",
+                              "/presence/muc_user:x/muc_user:status[@code='307']",
+                              "/presence/muc_user:x/muc_user:status[@code='110']"
+                              )),
+                     partial(expect_stanza,
+                             ("/presence[@type='unavailable']/muc_user:x/muc_user:item[@role='none']/muc_user:actor[@nick='{nick_one}']",
+                              "/presence/muc_user:x/muc_user:item/muc_user:reason[text()='reported']",
+                              "/presence/muc_user:x/muc_user:status[@code='307']",
+                              ),
+                             ),
+                     partial(expect_stanza,
+                             "/iq[@id='kick1'][@type='result']"),
+                 ]),
+                Scenario("self_version",
+                 [
+                     handshake_sequence(),
+                     partial(send_stanza,
+                             "<presence from='{jid_one}/{resource_one}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     connection_sequence("irc.localhost", '{jid_one}/{resource_one}'),
+                     partial(expect_stanza,
+                             "/message/body[text()='Mode #foo [+nt] by {irc_host_one}']"),
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_one}/{resource_one}'][@from='#foo%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='admin'][@role='moderator']",
+                              "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat']/subject[not(text())]"),
+
+                     # Send a version request to ourself
+                     partial(send_stanza,
+                             "<iq type='get' from='{jid_one}/{resource_one}' id='first_version' to='#foo%{irc_server_one}/{nick_one}'><query xmlns='jabber:iq:version' /></iq>"),
+                     # We receive our own request,
+                     partial(expect_stanza,
+                             "/iq[@from='{lower_nick_one}!{irc_server_one}'][@type='get'][@to='{jid_one}/{resource_one}']",
+                             after = partial(save_value, "id", partial(extract_attribute, "/iq", 'id'))),
+                     # Respond to the request
+                     partial(send_stanza,
+                             "<iq type='result' to='{lower_nick_one}!{irc_server_one}' id='{id}' from='{jid_one}/{resource_one}'><query xmlns='jabber:iq:version'><name>e2e test</name><version>1.0</version><os>Fedora</os></query></iq>"),
+                     partial(expect_stanza,
+                             "/iq[@from='#foo%{irc_server_one}/{nick_one}'][@type='result'][@to='{jid_one}/{resource_one}'][@id='first_version']/version:query/version:name[text()='e2e test (through the biboumi gateway) 1.0 Fedora']"),
+
+                     # Now join the same room, from the same bare JID, behind the same nick
+                     partial(send_stanza,
+                             "<presence from='{jid_one}/{resource_two}' to='#foo%{irc_server_one}/{nick_one}' />"),
+                     partial(expect_stanza,
+                             ("/presence[@to='{jid_one}/{resource_two}'][@from='#foo%{irc_server_one}/{nick_one}']/muc_user:x/muc_user:item[@affiliation='admin'][@role='moderator']",
+                              "/presence/muc_user:x/muc_user:status[@code='110']")
+                             ),
+                     partial(expect_stanza, "/message[@from='#foo%{irc_server_one}'][@type='groupchat'][@to='{jid_one}/{resource_two}']/subject[not(text())]"),
+
+                     # And re-send a self ping
+                     partial(send_stanza,
+                             "<iq type='get' from='{jid_one}/{resource_two}' id='second_version' to='#foo%{irc_server_one}/{nick_one}'><query xmlns='jabber:iq:version' /></iq>"),
+                     # We receive our own request. Note that we don't know the to value, it could be one of our two resources.
+                     partial(expect_stanza,
+                             "/iq[@from='{lower_nick_one}!{irc_server_one}'][@type='get'][@to]",
+                             after = (partial(save_value, "to", partial(extract_attribute, "/iq", "to")),
+                                      partial(save_value, "id", partial(extract_attribute, "/iq", "id")))),
+                     # Respond to the request, using the extracted 'to' value as our 'from'
+                     partial(send_stanza,
+                             "<iq type='result' to='{lower_nick_one}!{irc_server_one}' id='{id}' from='{to}'><query xmlns='jabber:iq:version'><name>e2e test</name><version>1.0</version><os>Fedora</os></query></iq>"),
+                     partial(expect_stanza,
+                             "/iq[@from='#foo%{irc_server_one}/{nick_one}'][@type='result'][@to='{jid_one}/{resource_two}'][@id='second_version']"),
+
+                     # And do exactly the same thing, but initiated by the other resource
+                     partial(send_stanza,
+                             "<iq type='get' from='{jid_one}/{resource_one}' id='second_version' to='#foo%{irc_server_one}/{nick_one}'><query xmlns='jabber:iq:version' /></iq>"),
+                     # We receive our own request. Note that we don't know the to value, it could be one of our two resources.
+                     partial(expect_stanza,
+                             "/iq[@from='{lower_nick_one}!{irc_server_one}'][@type='get'][@to]",
+                             after = (partial(save_value, "to", partial(extract_attribute, "/iq", "to")),
+                                      partial(save_value, "id", partial(extract_attribute, "/iq", "id")))),
+                     # Respond to the request, using the extracted 'to' value as our 'from'
+                     partial(send_stanza,
+                             "<iq type='result' to='{lower_nick_one}!{irc_server_one}' id='{id}' from='{to}'><query xmlns='jabber:iq:version'><name>e2e test</name><version>1.0</version><os>Fedora</os></query></iq>"),
+                     partial(expect_stanza,
+                             "/iq[@from='#foo%{irc_server_one}/{nick_one}'][@type='result'][@to='{jid_one}/{resource_one}'][@id='second_version']"),
+                 ]),
+    )
+
+    failures = 0
+
+    irc_output = open("irc_output.txt", "w")
+    irc = IrcServerRunner()
+    print("Starting irc server…")
+    asyncio.get_event_loop().run_until_complete(irc.start())
+    while True:
+        res = asyncio.get_event_loop().run_until_complete(irc.process.stderr.readline())
+        irc_output.write(res.decode())
+        if not res:
+            print("IRC server failed to start, see irc_output.txt for more details. Exiting…")
+            sys.exit(1)
+        if b"now running in foreground mode" in res:
+            break
+    print("irc server started.")
+    print("Running %s checks for biboumi." % (len(scenarios)))
+
+    for scenario in scenarios:
+        test = BiboumiTest(scenario)
+        if not test.run(os.getenv("E2E_BIBOUMI_VALGRIND") is not None):
+            print("You can check the files slixmpp_%s_output.txt and biboumi_%s_output.txt to help you debug." %
+                  (scenario.name, scenario.name))
+            failures += 1
+
+    print("Waiting for irc server to exit…")
+    irc.stop()
+    asyncio.get_event_loop().run_until_complete(irc.wait())
+
+    if failures:
+        print("%d test%s failed, please fix %s." % (failures, 's' if failures > 1 else '',
+                                                    'them' if failures > 1 else 'it'))
+        sys.exit(1)
+    else:
+        print("All tests passed successfully")
diff --git a/tests/end_to_end/biboumi.supp b/tests/end_to_end/biboumi.supp
new file mode 100644
index 0000000..d153665
--- /dev/null
+++ b/tests/end_to_end/biboumi.supp
@@ -0,0 +1,10 @@
+{
+   stdlibc++ thingy
+   Memcheck:Leak
+   match-leak-kinds: reachable
+   fun:malloc
+   ...
+   fun:call_init.part.0
+   fun:_dl_init
+   ...
+}
diff --git a/tests/end_to_end/ircd.conf b/tests/end_to_end/ircd.conf
new file mode 100644
index 0000000..7edb3a8
--- /dev/null
+++ b/tests/end_to_end/ircd.conf
@@ -0,0 +1,510 @@
+/* doc/ircd.conf.example - brief example configuration file
+ *
+ * Copyright (C) 2000-2002 Hybrid Development Team
+ * Copyright (C) 2002-2005 ircd-ratbox development team
+ * Copyright (C) 2005-2006 charybdis development team
+ *
+ * See reference.conf for more information.
+ */
+
+/* Extensions */
+#loadmodule "extensions/chm_operonly_compat";
+#loadmodule "extensions/chm_quietunreg_compat";
+#loadmodule "extensions/chm_sslonly_compat";
+#loadmodule "extensions/chm_operpeace";
+#loadmodule "extensions/createauthonly";
+#loadmodule "extensions/extb_account";
+#loadmodule "extensions/extb_canjoin";
+#loadmodule "extensions/extb_channel";
+#loadmodule "extensions/extb_combi";
+#loadmodule "extensions/extb_extgecos";
+#loadmodule "extensions/extb_hostmask";
+#loadmodule "extensions/extb_oper";
+#loadmodule "extensions/extb_realname";
+#loadmodule "extensions/extb_server";
+#loadmodule "extensions/extb_ssl";
+#loadmodule "extensions/extb_usermode";
+#loadmodule "extensions/hurt";
+#loadmodule "extensions/m_extendchans";
+#loadmodule "extensions/m_findforwards";
+#loadmodule "extensions/m_identify";
+#loadmodule "extensions/m_locops";
+#loadmodule "extensions/no_oper_invis";
+#loadmodule "extensions/sno_farconnect";
+#loadmodule "extensions/sno_globalkline";
+#loadmodule "extensions/sno_globalnickchange";
+#loadmodule "extensions/sno_globaloper";
+#loadmodule "extensions/sno_whois";
+#loadmodule "extensions/override";
+#loadmodule "extensions/no_kill_services";
+
+/*
+ * IP cloaking extensions: use ip_cloaking_4.0
+ * if you're linking 3.2 and later, otherwise use
+ * ip_cloaking, for compatibility with older 3.x
+ * releases.
+ */
+
+#loadmodule "extensions/ip_cloaking_4.0";
+#loadmodule "extensions/ip_cloaking";
+
+serverinfo {
+	name = "irc.localhost";
+	sid = "42X";
+	description = "charybdis test server";
+	network_name = "StaticBox";
+
+	/* On multi-homed hosts you may need the following. These define
+	 * the addresses we connect from to other servers. */
+	/* for IPv4 */
+	#vhost = "192.0.2.6";
+	/* for IPv6 */
+	#vhost6 = "2001:db8:2::6";
+
+	/* ssl_private_key: our ssl private key */
+	ssl_private_key = "etc/ssl.key";
+
+	/* ssl_cert: certificate for our ssl server */
+	ssl_cert = "etc/ssl.pem";
+
+	/* ssl_dh_params: DH parameters, generate with openssl dhparam -out dh.pem 2048
+	 * In general, the DH parameters size should be the same as your key's size.
+	 * However it has been reported that some clients have broken TLS implementations which may
+	 * choke on keysizes larger than 2048-bit, so we would recommend using 2048-bit DH parameters
+	 * for now if your keys are larger than 2048-bit.
+	 */
+	ssl_dh_params = "etc/dh.pem";
+
+	/* ssld_count: number of ssld processes you want to start, if you
+	 * have a really busy server, using N-1 where N is the number of
+	 * cpu/cpu cores you have might be useful. A number greater than one
+	 * can also be useful in case of bugs in ssld and because ssld needs
+	 * two file descriptors per SSL connection.
+	 */
+	ssld_count = 1;
+
+	/* default max clients: the default maximum number of clients
+	 * allowed to connect.  This can be changed once ircd has started by
+	 * issuing:
+	 *   /quote set maxclients <limit>
+	 */
+	default_max_clients = 1024;
+
+	/* nicklen: enforced nickname length (for this server only; must not
+	 * be longer than the maximum length set while building).
+	 */
+	nicklen = 30;
+};
+
+admin {
+	name = "Lazy admin (lazya)";
+	description = "StaticBox client server";
+	email = "nobody@127.0.0.1";
+};
+
+log {
+	fname_userlog = "logs/userlog";
+	#fname_fuserlog = "logs/fuserlog";
+	fname_operlog = "logs/operlog";
+	#fname_foperlog = "logs/foperlog";
+	fname_serverlog = "logs/serverlog";
+	#fname_klinelog = "logs/klinelog";
+	fname_killlog = "logs/killlog";
+	fname_operspylog = "logs/operspylog";
+	#fname_ioerrorlog = "logs/ioerror";
+};
+
+/* class {} blocks MUST be specified before anything that uses them.  That
+ * means they must be defined before auth {} and before connect {}.
+ */
+class "users" {
+	ping_time = 2 minutes;
+	number_per_ident = 10;
+	number_per_ip = 10;
+	number_per_ip_global = 50;
+	cidr_ipv4_bitlen = 24;
+	cidr_ipv6_bitlen = 64;
+	number_per_cidr = 200;
+	max_number = 3000;
+	sendq = 400 kbytes;
+};
+
+class "opers" {
+	ping_time = 5 minutes;
+	number_per_ip = 10;
+	max_number = 1000;
+	sendq = 1 megabyte;
+};
+
+class "server" {
+	ping_time = 5 minutes;
+	connectfreq = 5 minutes;
+	max_number = 1;
+	sendq = 4 megabytes;
+};
+
+listen {
+	/* defer_accept: wait for clients to send IRC handshake data before
+	 * accepting them.  if you intend to use software which depends on the
+	 * server replying first, such as BOPM, you should disable this feature.
+	 * otherwise, you probably want to leave it on.
+	 */
+	defer_accept = yes;
+
+	/* If you want to listen on a specific IP only, specify host.
+	 * host definitions apply only to the following port line.
+	 */
+	#host = "192.0.2.6";
+	port = 5000, 6665 .. 6669;
+	# sslport = 6697;
+
+	/* Listen on IPv6 (if you used host= above). */
+	#host = "2001:db8:2::6";
+	#port = 5000, 6665 .. 6669;
+	#sslport = 9999;
+};
+
+/* auth {}: allow users to connect to the ircd (OLD I:)
+ * auth {} blocks MUST be specified in order of precedence.  The first one
+ * that matches a user will be used.  So place spoofs first, then specials,
+ * then general access, then restricted.
+ */
+auth {
+	/* user: the user@host allowed to connect.  Multiple IPv4/IPv6 user
+	 * lines are permitted per auth block.  This is matched against the
+	 * hostname and IP address (using :: shortening for IPv6 and
+	 * prepending a 0 if it starts with a colon) and can also use CIDR
+	 * masks.
+	 */
+	user = "*@198.51.100.0/24";
+	user = "*test@2001:db8:1:*";
+
+	/* password: an optional password that is required to use this block.
+	 * By default this is not encrypted, specify the flag "encrypted" in
+	 * flags = ...; below if it is.
+	 */
+	password = "letmein";
+
+	/* spoof: fake the users user@host to be be this.  You may either
+	 * specify a host or a user@host to spoof to.  This is free-form,
+	 * just do everyone a favour and dont abuse it. (OLD I: = flag)
+	 */
+	spoof = "I.still.hate.packets";
+
+	/* Possible flags in auth:
+	 *
+	 * encrypted                  | password is encrypted with mkpasswd
+	 * spoof_notice               | give a notice when spoofing hosts
+	 * exceed_limit (old > flag)  | allow user to exceed class user limits
+	 * kline_exempt (old ^ flag)  | exempt this user from k/g/xlines,
+	 *                            | dnsbls, and proxies
+	 * proxy_exempt               | exempt this user from proxies
+	 * dnsbl_exempt               | exempt this user from dnsbls
+	 * spambot_exempt             | exempt this user from spambot checks
+	 * shide_exempt               | exempt this user from serverhiding
+	 * jupe_exempt                | exempt this user from generating
+	 *                              warnings joining juped channels
+	 * resv_exempt                | exempt this user from resvs
+	 * flood_exempt               | exempt this user from flood limits
+	 *                              USE WITH CAUTION.
+	 * no_tilde     (old - flag)  | don't prefix ~ to username if no ident
+	 * need_ident   (old + flag)  | require ident for user in this class
+	 * need_ssl                   | require SSL/TLS for user in this class
+	 * need_sasl                  | require SASL id for user in this class
+	 */
+	flags = kline_exempt, exceed_limit;
+
+	/* class: the class the user is placed in */
+	class = "opers";
+};
+
+auth {
+	user = "*@*";
+	class = "users";
+};
+
+/* privset {} blocks MUST be specified before anything that uses them.  That
+ * means they must be defined before operator {}.
+ */
+privset "local_op" {
+	privs = oper:local_kill, oper:operwall;
+};
+
+privset "server_bot" {
+	extends = "local_op";
+	privs = oper:kline, oper:remoteban, snomask:nick_changes;
+};
+
+privset "global_op" {
+	extends = "local_op";
+	privs = oper:global_kill, oper:routing, oper:kline, oper:unkline, oper:xline,
+		oper:resv, oper:mass_notice, oper:remoteban;
+};
+
+privset "admin" {
+	extends = "global_op";
+	privs = oper:admin, oper:die, oper:rehash, oper:spy, oper:grant;
+};
+
+operator "god" {
+	/* name: the name of the oper must go above */
+
+	/* user: the user@host required for this operator.  CIDR *is*
+	 * supported now. auth{} spoofs work here, other spoofs do not.
+ 	 * multiple user="" lines are supported.
+	 */
+	user = "*god@127.0.0.1";
+
+	/* password: the password required to oper.  Unless ~encrypted is
+	 * contained in flags = ...; this will need to be encrypted using
+	 * mkpasswd, MD5 is supported
+	 */
+	password = "etcnjl8juSU1E";
+
+	/* rsa key: the public key for this oper when using Challenge.
+	 * A password should not be defined when this is used, see
+	 * doc/challenge.txt for more information.
+	 */
+	#rsa_public_key_file = "/usr/local/ircd/etc/oper.pub";
+
+	/* umodes: the specific umodes this oper gets when they oper.
+	 * If this is specified an oper will not be given oper_umodes
+	 * These are described above oper_only_umodes in general {};
+	 */
+	#umodes = locops, servnotice, operwall, wallop;
+
+	/* fingerprint: if specified, the oper's client certificate
+	 * fingerprint will be checked against the specified fingerprint
+	 * below.
+	 */
+	#fingerprint = "c77106576abf7f9f90cca0f63874a60f2e40a64b";
+
+	/* snomask: specific server notice mask on oper up.
+	 * If this is specified an oper will not be given oper_snomask.
+	 */
+	snomask = "+Zbfkrsuy";
+
+	/* flags: misc options for the operator.  You may prefix an option
+	 * with ~ to disable it, e.g. ~encrypted.
+	 *
+	 * Default flags are encrypted.
+	 *
+	 * Available options:
+	 *
+	 * encrypted:    the password above is encrypted [DEFAULT]
+	 * need_ssl:     must be using SSL/TLS to oper up
+	 */
+	flags = encrypted;
+
+	/* privset: privileges set to grant */
+	privset = "admin";
+};
+
+connect "irc.uplink.com" {
+	host = "203.0.113.3";
+	send_password = "password";
+	accept_password = "anotherpassword";
+	port = 6666;
+	hub_mask = "*";
+	class = "server";
+	flags = compressed, topicburst;
+
+	#fingerprint = "c77106576abf7f9f90cca0f63874a60f2e40a64b";
+
+	/* If the connection is IPv6, uncomment below.
+	 * Use 0::1, not ::1, for IPv6 localhost. */
+	#aftype = ipv6;
+};
+
+connect "ssl.uplink.com" {
+	host = "203.0.113.129";
+	send_password = "password";
+	accept_password = "anotherpassword";
+	port = 9999;
+	hub_mask = "*";
+	class = "server";
+	flags = ssl, topicburst;
+};
+
+service {
+	name = "services.int";
+};
+
+cluster {
+	name = "*";
+	flags = kline, tkline, unkline, xline, txline, unxline, resv, tresv, unresv;
+};
+
+shared {
+	oper = "*@*", "*";
+	flags = all, rehash;
+};
+
+/* exempt {}: IPs that are exempt from Dlines and rejectcache. (OLD d:) */
+exempt {
+	ip = "127.0.0.1";
+};
+
+channel {
+	use_invex = yes;
+	use_except = yes;
+	use_forward = yes;
+	use_knock = yes;
+	knock_delay = 5 minutes;
+	knock_delay_channel = 1 minute;
+	max_chans_per_user = 15;
+	max_chans_per_user_large = 60;
+	max_bans = 100;
+	max_bans_large = 500;
+	default_split_user_count = 0;
+	default_split_server_count = 0;
+	no_create_on_split = no;
+	no_join_on_split = no;
+	burst_topicwho = yes;
+	kick_on_split_riding = no;
+	only_ascii_channels = no;
+	resv_forcepart = yes;
+	channel_target_change = yes;
+	disable_local_channels = no;
+	autochanmodes = "+nt";
+	displayed_usercount = 3;
+	strip_topic_colors = no;
+};
+
+serverhide {
+	flatten_links = yes;
+	links_delay = 5 minutes;
+	hidden = no;
+	disable_hidden = no;
+};
+
+alias "NickServ" {
+	target = "NickServ";
+};
+
+alias "ChanServ" {
+	target = "ChanServ";
+};
+
+alias "OperServ" {
+	target = "OperServ";
+};
+
+alias "MemoServ" {
+	target = "MemoServ";
+};
+
+alias "NS" {
+	target = "NickServ";
+};
+
+alias "CS" {
+	target = "ChanServ";
+};
+
+alias "OS" {
+	target = "OperServ";
+};
+
+alias "MS" {
+	target = "MemoServ";
+};
+
+general {
+	hide_error_messages = opers;
+	hide_spoof_ips = yes;
+
+	/*
+	 * default_umodes: umodes to enable on connect.
+	 * If you have enabled the new ip_cloaking_4.0 module, and you want
+	 * to make use of it, add +x to this option, i.e.:
+	 *      default_umodes = "+ix";
+	 *
+	 * If you have enabled the old ip_cloaking module, and you want
+	 * to make use of it, add +h to this option, i.e.:
+	 *	default_umodes = "+ih";
+	 */
+	default_umodes = "+i";
+
+	default_operstring = "is an IRC Operator";
+	default_adminstring = "is a Server Administrator";
+	servicestring = "is a Network Service";
+
+	/*
+	 * Nick of the network's SASL agent. Used to check whether services are here,
+	 * SASL credentials are only sent to its server. Needs to be a service.
+	 *
+	 * Defaults to SaslServ if unspecified.
+	 */
+	sasl_service = "SaslServ";
+	disable_fake_channels = no;
+	tkline_expire_notices = no;
+	default_floodcount = 10;
+	failed_oper_notice = yes;
+	dots_in_ident=2;
+	min_nonwildcard = 4;
+	min_nonwildcard_simple = 3;
+	max_accept = 100;
+	max_monitor = 100;
+	anti_nick_flood = yes;
+	max_nick_time = 20 seconds;
+	max_nick_changes = 5;
+	anti_spam_exit_message_time = 5 minutes;
+	ts_warn_delta = 30 seconds;
+	ts_max_delta = 5 minutes;
+	client_exit = yes;
+	collision_fnc = yes;
+	resv_fnc = yes;
+	global_snotices = yes;
+	dline_with_reason = yes;
+	kline_delay = 0 seconds;
+	kline_with_reason = yes;
+	kline_reason = "K-Lined";
+	identify_service = "NickServ@services.int";
+	identify_command = "IDENTIFY";
+	non_redundant_klines = yes;
+	warn_no_nline = yes;
+	use_propagated_bans = yes;
+	stats_e_disabled = yes;
+	stats_c_oper_only=no;
+	stats_h_oper_only=no;
+	stats_y_oper_only=no;
+	stats_o_oper_only=yes;
+	stats_P_oper_only=no;
+	stats_i_oper_only=masked;
+	stats_k_oper_only=masked;
+	map_oper_only = no;
+	operspy_admin_only = no;
+	operspy_dont_care_user_info = no;
+	caller_id_wait = 1 minute;
+	pace_wait_simple = 1 second;
+	pace_wait = 10 seconds;
+	short_motd = no;
+	ping_cookie = no;
+	connect_timeout = 30 seconds;
+	default_ident_timeout = 5;
+	disable_auth = no;
+	no_oper_flood = yes;
+	max_targets = 4;
+	client_flood_max_lines = 20;
+	use_whois_actually = no;
+	oper_only_umodes = operwall, locops, servnotice;
+	oper_umodes = locops, servnotice, operwall, wallop;
+	oper_snomask = "+s";
+	burst_away = yes;
+	nick_delay = 0 seconds; # 15 minutes if you want to enable this
+	reject_ban_time = 1 minute;
+	reject_after_count = 3;
+	reject_duration = 5 minutes;
+	throttle_duration = 60;
+	throttle_count = 4;
+	max_ratelimit_tokens = 30;
+	away_interval = 30;
+	certfp_method = sha1;
+	hide_opers_in_whois = no;
+};
+
+modules {
+	path = "modules";
+	path = "modules/autoload";
+};
diff --git a/tests/iid.cpp b/tests/iid.cpp
new file mode 100644
index 0000000..74d010d
--- /dev/null
+++ b/tests/iid.cpp
@@ -0,0 +1,130 @@
+#include "catch.hpp"
+
+#include <irc/iid.hpp>
+#include <irc/irc_user.hpp>
+
+#include <config/config.hpp>
+
+TEST_CASE("Irc user parsing")
+{
+  const std::map<char, char> prefixes{{'!', 'a'}, {'@', 'o'}};
+  IrcUser user1("!nick!~some@host.bla", prefixes);
+  CHECK(user1.nick == "nick");
+  CHECK(user1.host == "~some@host.bla");
+  CHECK(user1.modes.size() == 1);
+  CHECK(user1.modes.find('a') != user1.modes.end());
+
+  IrcUser user2("coucou!~other@host.bla", prefixes);
+  CHECK(user2.nick == "coucou");
+  CHECK(user2.host == "~other@host.bla");
+  CHECK(user2.modes.empty());
+  CHECK(user2.modes.find('a') == user2.modes.end());
+}
+
+TEST_CASE("multi-prefix")
+{
+  const std::map<char, char> prefixes{{'!', 'a'}, {'@', 'o'}, {'~', 'f'}};
+  IrcUser user("!@~nick", prefixes);
+  CHECK(user.nick == "nick");
+  CHECK(user.modes.size() == 3);
+  CHECK(user.modes.find('f') != user.modes.end());
+}
+
+/**
+ * Let Catch know how to display Iid objects
+ */
+namespace Catch
+{
+  template<>
+  struct StringMaker<Iid>
+  {
+    static std::string convert(const Iid& value)
+    {
+      return std::to_string(value);
+    }
+  };
+}
+
+TEST_CASE("Iid creation")
+{
+    Iid iid1("foo!irc.example.org");
+    CHECK(std::to_string(iid1) == "foo!irc.example.org");
+    CHECK(iid1.get_local() == "foo");
+    CHECK(iid1.get_server() == "irc.example.org");
+    CHECK(!iid1.is_channel);
+    CHECK(iid1.is_user);
+
+    Iid iid2("#test%irc.example.org");
+    CHECK(std::to_string(iid2) == "#test%irc.example.org");
+    CHECK(iid2.get_local() == "#test");
+    CHECK(iid2.get_server() == "irc.example.org");
+    CHECK(iid2.is_channel);
+    CHECK(!iid2.is_user);
+
+    Iid iid3("%irc.example.org");
+    CHECK(std::to_string(iid3) == "%irc.example.org");
+    CHECK(iid3.get_local() == "");
+    CHECK(iid3.get_server() == "irc.example.org");
+    CHECK(iid3.is_channel);
+    CHECK(!iid3.is_user);
+
+    Iid iid4("irc.example.org");
+    CHECK(std::to_string(iid4) == "irc.example.org");
+    CHECK(iid4.get_local() == "");
+    CHECK(iid4.get_server() == "irc.example.org");
+    CHECK(!iid4.is_channel);
+    CHECK(!iid4.is_user);
+
+    Iid iid5("nick!");
+    CHECK(std::to_string(iid5) == "nick!");
+    CHECK(iid5.get_local() == "nick");
+    CHECK(iid5.get_server() == "");
+    CHECK(!iid5.is_channel);
+    CHECK(iid5.is_user);
+
+    Iid iid6("##channel%");
+    CHECK(std::to_string(iid6) == "##channel%");
+    CHECK(iid6.get_local() == "##channel");
+    CHECK(iid6.get_server() == "");
+    CHECK(iid6.is_channel);
+    CHECK(!iid6.is_user);
+}
+
+TEST_CASE("Iid creation in fixed_server mode")
+{
+    Config::set("fixed_irc_server", "fixed.example.com", false);
+
+    Iid iid1("foo!irc.example.org");
+    CHECK(std::to_string(iid1) == "foo!");
+    CHECK(iid1.get_local() == "foo");
+    CHECK(iid1.get_server() == "fixed.example.com");
+    CHECK(!iid1.is_channel);
+    CHECK(iid1.is_user);
+
+    Iid iid2("#test%irc.example.org");
+    CHECK(std::to_string(iid2) == "#test%irc.example.org");
+    CHECK(iid2.get_local() == "#test%irc.example.org");
+    CHECK(iid2.get_server() == "fixed.example.com");
+    CHECK(iid2.is_channel);
+    CHECK(!iid2.is_user);
+
+    // Note that it is impossible to adress the IRC server directly, or to
+    // use the virtual channel, in that mode
+
+    // Iid iid3("%irc.example.org");
+    // Iid iid4("irc.example.org");
+
+    Iid iid5("nick!");
+    CHECK(std::to_string(iid5) == "nick!");
+    CHECK(iid5.get_local() == "nick");
+    CHECK(iid5.get_server() == "fixed.example.com");
+    CHECK(!iid5.is_channel);
+    CHECK(iid5.is_user);
+
+    Iid iid6("##channel%");
+    CHECK(std::to_string(iid6) == "##channel%");
+    CHECK(iid6.get_local() == "##channel%");
+    CHECK(iid6.get_server() == "fixed.example.com");
+    CHECK(iid6.is_channel);
+    CHECK(!iid6.is_user);
+}
diff --git a/tests/io_tester.cpp b/tests/io_tester.cpp
new file mode 100644
index 0000000..19c97c9
--- /dev/null
+++ b/tests/io_tester.cpp
@@ -0,0 +1,30 @@
+#include "io_tester.hpp"
+#include "catch.hpp"
+#include <iostream>
+
+/**
+ * Directly test this class here
+ */
+TEST_CASE()
+{
+  {
+    IoTester<std::ostream> out(std::cout);
+    std::cout << "test";
+    CHECK(out.str() == "test");
+  }
+  {
+    IoTester<std::ostream> out(std::cout);
+    CHECK(out.str().empty());
+  }
+}
+
+TEST_CASE()
+{
+  {
+    IoTester<std::istream> is(std::cin);
+    is.set_string("coucou");
+    std::string res;
+    std::cin >> res;
+    CHECK(res == "coucou");
+  }
+}
diff --git a/tests/io_tester.hpp b/tests/io_tester.hpp
new file mode 100644
index 0000000..b9cdaa7
--- /dev/null
+++ b/tests/io_tester.hpp
@@ -0,0 +1,45 @@
+#pragma once
+
+#include <ostream>
+#include <sstream>
+
+/**
+ * Redirects a stream into a streambuf until the object is destroyed.
+ */
+template <typename StreamType>
+class IoTester
+{
+public:
+  IoTester(StreamType& ios):
+    stream{},
+    ios(ios),
+    old_buf(ios.rdbuf())
+  {
+    // Redirect the given os into our stringstream’s buf
+    this->ios.rdbuf(this->stream.rdbuf());
+  }
+  ~IoTester()
+  {
+    this->ios.rdbuf(this->old_buf);
+  }
+  IoTester& operator=(const IoTester&) = delete;
+  IoTester& operator=(IoTester&&) = delete;
+  IoTester(const IoTester&) = delete;
+  IoTester(IoTester&&) = delete;
+
+  std::string str() const
+  {
+    return this->stream.str();
+  }
+
+  void set_string(const std::string& s)
+  {
+    this->stream.str(s);
+  }
+
+private:
+  std::stringstream stream;
+  StreamType& ios;
+  std::streambuf* const old_buf;
+};
+
diff --git a/tests/jid.cpp b/tests/jid.cpp
new file mode 100644
index 0000000..9015afd
--- /dev/null
+++ b/tests/jid.cpp
@@ -0,0 +1,39 @@
+#include "catch.hpp"
+
+#include <xmpp/jid.hpp>
+#include <louloulibs.h>
+
+TEST_CASE("Jid")
+{
+  Jid jid1("♥@ツ.coucou/coucou@coucou/coucou");
+  CHECK(jid1.local == "♥");
+  CHECK(jid1.domain == "ツ.coucou");
+  CHECK(jid1.resource == "coucou@coucou/coucou");
+
+  // Domain and resource
+  Jid jid2("ツ.coucou/coucou@coucou/coucou");
+  CHECK(jid2.local == "");
+  CHECK(jid2.domain == "ツ.coucou");
+  CHECK(jid2.resource == "coucou@coucou/coucou");
+
+  // Jidprep
+  const std::string badjid("~zigougou™@EpiK-7D9D1FDE.poez.io/Boujour/coucou/slt™");
+  const std::string correctjid = jidprep(badjid);
+#ifdef LIBIDN_FOUND
+  CHECK(correctjid == "~zigougoutm@epik-7d9d1fde.poez.io/Boujour/coucou/sltTM");
+  // Check that the cache does not break things when we prep the same string
+  // multiple times
+  CHECK(jidprep(badjid) == "~zigougoutm@epik-7d9d1fde.poez.io/Boujour/coucou/sltTM");
+  CHECK(jidprep(badjid) == "~zigougoutm@epik-7d9d1fde.poez.io/Boujour/coucou/sltTM");
+
+  const std::string badjid2("Zigougou@poez.io");
+  const std::string correctjid2 = jidprep(badjid2);
+  CHECK(correctjid2 == "zigougou@poez.io");
+
+  const std::string crappy("~Bisous@7ea8beb1:c5fd2849:da9a048e:ip");
+  const std::string fixed_crappy = jidprep(crappy);
+  CHECK(fixed_crappy == "~bisous@7ea8beb1-c5fd2849-da9a048e-ip");
+#else // Without libidn, jidprep always returns an empty string
+  CHECK(jidprep(badjid) == "");
+#endif
+}
diff --git a/tests/logger.cpp b/tests/logger.cpp
new file mode 100644
index 0000000..1d59a22
--- /dev/null
+++ b/tests/logger.cpp
@@ -0,0 +1,57 @@
+#include "catch.hpp"
+
+#include <logger/logger.hpp>
+#include <config/config.hpp>
+
+#include "io_tester.hpp"
+#include <iostream>
+
+using namespace std::string_literals;
+
+TEST_CASE("Basic logging")
+{
+#ifdef SYSTEMD_FOUND
+  const std::string debug_header = "<7>";
+  const std::string error_header = "<3>";
+#else
+  const std::string debug_header = "[DEBUG]: ";
+  const std::string error_header = "[ERROR]: ";
+#endif
+  Logger::instance().reset();
+  GIVEN("A logger with log_level 0")
+    {
+      Config::set("log_level", "0");
+      WHEN("we log some debug text")
+        {
+          IoTester<std::ostream> out(std::cout);
+          log_debug("deb", "ug");
+          THEN("debug logs are written")
+            CHECK(out.str() == debug_header + "tests/logger.cpp:" + std::to_string(__LINE__ - 2) + ":\tdebug\n");
+        }
+      WHEN("we log some errors")
+        {
+          IoTester<std::ostream> out(std::cout);
+          log_error("err", 12, "or");
+          THEN("error logs are written")
+            CHECK(out.str() == error_header + "tests/logger.cpp:" + std::to_string(__LINE__ - 2) + ":\terr12or\n");
+        }
+    }
+  GIVEN("A logger with log_level 3")
+    {
+      Config::set("log_level", "3");
+      WHEN("we log some debug text")
+        {
+          IoTester<std::ostream> out(std::cout);
+          log_debug(123, "debug");
+          THEN("nothing is written")
+            CHECK(out.str().empty());
+        }
+      WHEN("we log some errors")
+        {
+          IoTester<std::ostream> out(std::cout);
+          log_error(123, " errors");
+          THEN("error logs are still written")
+            CHECK(out.str() == error_header + "tests/logger.cpp:" + std::to_string(__LINE__ - 2) + ":\t123 errors\n");
+        }
+    }
+}
diff --git a/tests/test.cpp b/tests/test.cpp
new file mode 100644
index 0000000..0c7c351
--- /dev/null
+++ b/tests/test.cpp
@@ -0,0 +1,2 @@
+#define CATCH_CONFIG_MAIN
+#include "catch.hpp"
diff --git a/tests/timed_events.cpp b/tests/timed_events.cpp
new file mode 100644
index 0000000..d63abef
--- /dev/null
+++ b/tests/timed_events.cpp
@@ -0,0 +1,62 @@
+#include "catch.hpp"
+
+#include <utils/timed_events.hpp>
+
+/**
+ * Let Catch know how to display std::chrono::duration values
+ */
+namespace Catch
+{
+  template<typename Rep, typename Period> struct StringMaker<std::chrono::duration<Rep, Period>>
+  {
+    static std::string convert(const std::chrono::duration<Rep, Period>& value)
+    {
+      return  std::to_string(std::chrono::duration_cast<std::chrono::milliseconds>(value).count()) + "ms";
+    }
+  };
+}
+
+/**
+ * TODO, use a mock clock instead of relying on the real time with a sleep:
+ * it’s unreliable on heavy load.
+ */
+#include <thread>
+
+TEST_CASE("Test timed event expiration")
+{
+  SECTION("Check what happens when there is no events")
+    {
+      CHECK(TimedEventsManager::instance().get_timeout() == utils::no_timeout);
+      CHECK(TimedEventsManager::instance().execute_expired_events() == 0);
+    }
+
+  // Add a single event
+  TimedEventsManager::instance().add_event(TimedEvent(std::chrono::steady_clock::now() + 50ms, [](){}));
+
+  // The event should not yet be expired
+  CHECK(TimedEventsManager::instance().get_timeout() > 0ms);
+  CHECK(TimedEventsManager::instance().execute_expired_events() == 0);
+
+  std::chrono::milliseconds timoute = TimedEventsManager::instance().get_timeout();
+  INFO("Sleeping for " << timoute.count() << "ms");
+  std::this_thread::sleep_for(timoute + 1ms);
+
+  // Event is now expired
+  CHECK(TimedEventsManager::instance().execute_expired_events() == 1);
+  CHECK(TimedEventsManager::instance().get_timeout() == utils::no_timeout);
+}
+
+TEST_CASE("Test timed event cancellation")
+{
+  auto now = std::chrono::steady_clock::now();
+  TimedEventsManager::instance().add_event(TimedEvent(now + 100ms, [](){ }, "un"));
+  TimedEventsManager::instance().add_event(TimedEvent(now + 200ms, [](){ }, "deux"));
+  TimedEventsManager::instance().add_event(TimedEvent(now + 300ms, [](){ }, "deux"));
+
+  CHECK(TimedEventsManager::instance().get_timeout() > 0ms);
+  CHECK(TimedEventsManager::instance().size() == 3);
+  CHECK(TimedEventsManager::instance().cancel("un") == 1);
+  CHECK(TimedEventsManager::instance().size() == 2);
+  CHECK(TimedEventsManager::instance().cancel("deux") == 2);
+  CHECK(TimedEventsManager::instance().get_timeout() == utils::no_timeout);
+}
diff --git a/tests/utils.cpp b/tests/utils.cpp
new file mode 100644
index 0000000..01d070e
--- /dev/null
+++ b/tests/utils.cpp
@@ -0,0 +1,102 @@
+#include "catch.hpp"
+
+#include <utils/tolower.hpp>
+#include <utils/revstr.hpp>
+#include <utils/string.hpp>
+#include <utils/split.hpp>
+#include <utils/xdg.hpp>
+#include <utils/empty_if_fixed_server.hpp>
+
+TEST_CASE("String split")
+{
+  std::vector<std::string> splitted = utils::split("a::a", ':', false);
+  CHECK(splitted.size() == 2);
+  splitted = utils::split("a::a", ':', true);
+  CHECK(splitted.size() == 3);
+  CHECK(splitted[0] == "a");
+  CHECK(splitted[1] == "");
+  CHECK(splitted[2] == "a");
+  splitted = utils::split("\na", '\n', true);
+  CHECK(splitted.size() == 2);
+  CHECK(splitted[0] == "");
+  CHECK(splitted[1] == "a");
+}
+
+TEST_CASE("tolower")
+{
+  const std::string lowercase = utils::tolower("CoUcOu LeS CoPaiNs ♥");
+  CHECK(lowercase == "coucou les copains ♥");
+
+  const std::string ltr = "coucou";
+  CHECK(utils::revstr(ltr) == "uocuoc");
+}
+
+TEST_CASE("to_bool")
+{
+  CHECK(to_bool("true"));
+  CHECK(!to_bool("trou"));
+  CHECK(to_bool("1"));
+  CHECK(!to_bool("0"));
+  CHECK(!to_bool("-1"));
+  CHECK(!to_bool("false"));
+}
+
+TEST_CASE("xdg_*_path")
+{
+  ::unsetenv("XDG_CONFIG_HOME");
+  ::unsetenv("HOME");
+  std::string res;
+
+  SECTION("Without XDG_CONFIG_HOME nor HOME")
+    {
+      res = xdg_config_path("coucou.txt");
+      CHECK(res == "coucou.txt");
+    }
+  SECTION("With only HOME")
+    {
+      ::setenv("HOME", "/home/user", 1);
+      res = xdg_config_path("coucou.txt");
+      CHECK(res == "/home/user/.config/biboumi/coucou.txt");
+    }
+  SECTION("With only XDG_CONFIG_HOME")
+    {
+      ::setenv("XDG_CONFIG_HOME", "/some_weird_dir", 1);
+      res = xdg_config_path("coucou.txt");
+      CHECK(res == "/some_weird_dir/biboumi/coucou.txt");
+    }
+  SECTION("With XDG_DATA_HOME")
+    {
+      ::setenv("XDG_DATA_HOME", "/datadir", 1);
+      res = xdg_data_path("bonjour.txt");
+      CHECK(res == "/datadir/biboumi/bonjour.txt");
+    }
+}
+
+TEST_CASE("empty if fixed irc server")
+{
+  GIVEN("A config with fixed_irc_server")
+    {
+      Config::set("fixed_irc_server", "irc.localhost");
+      THEN("our string is made empty")
+        CHECK(utils::empty_if_fixed_server("coucou coucou") == "");
+    }
+  GIVEN("A config with NO fixed_irc_server")
+    {
+      Config::set("fixed_irc_server", "");
+      THEN("our string is returned untouched")
+        CHECK(utils::empty_if_fixed_server("coucou coucou") == "coucou coucou");
+    }
+
+}
+
+TEST_CASE("string cut")
+{
+  CHECK(cut("coucou", 2).size() == 3);
+  CHECK(cut("bonjour les copains", 6).size() == 4);
+  CHECK(cut("««««", 2).size() == 4);
+  CHECK(cut("a««««", 2).size() == 5);
+  const auto res = cut("rhello, ♥", 10);
+  CHECK(res.size() == 2);
+  CHECK(res[0] == "rhello, ");
+  CHECK(res[1] == "♥");
+}
diff --git a/tests/uuid.cpp b/tests/uuid.cpp
new file mode 100644
index 0000000..12c6c32
--- /dev/null
+++ b/tests/uuid.cpp
@@ -0,0 +1,13 @@
+#include "catch.hpp"
+
+#include <xmpp/xmpp_component.hpp>
+
+TEST_CASE("id generation")
+{
+  const std::string first_uuid = XmppComponent::next_id();
+  const std::string second_uuid = XmppComponent::next_id();
+
+  CHECK(first_uuid.size() == 36);
+  CHECK(second_uuid.size() == 36);
+  CHECK(first_uuid != second_uuid);
+}
diff --git a/tests/xmpp.cpp b/tests/xmpp.cpp
new file mode 100644
index 0000000..6aab8c4
--- /dev/null
+++ b/tests/xmpp.cpp
@@ -0,0 +1,47 @@
+#include "catch.hpp"
+
+#include <xmpp/xmpp_parser.hpp>
+
+TEST_CASE("Test basic XML parsing")
+{
+  XmppParser xml;
+
+  const std::string doc = "<stream xmlns='stream_ns'><stanza b='c'>inner<child1><grandchild/></child1><child2 xmlns='child2_ns'/>tail</stanza></stream>";
+
+  auto check_stanza = [](const Stanza& stanza)
+    {
+      CHECK(stanza.get_name() == "stanza");
+      CHECK(stanza.get_tag("xmlns") == "stream_ns");
+      CHECK(stanza.get_tag("b") == "c");
+      CHECK(stanza.get_inner() == "inner");
+      CHECK(stanza.get_tail() == "");
+      CHECK(stanza.get_child("child1", "stream_ns") != nullptr);
+      CHECK(stanza.get_child("child2", "stream_ns") == nullptr);
+      CHECK(stanza.get_child("child2", "child2_ns") != nullptr);
+      CHECK(stanza.get_child("child2", "child2_ns")->get_tail() == "tail");
+    };
+  xml.add_stanza_callback([check_stanza](const Stanza& stanza)
+      {
+        check_stanza(stanza);
+        // Do the same checks on a copy of that stanza.
+        Stanza copy(stanza);
+        check_stanza(copy);
+        // And do the same checks on moved-constructed stanza
+        Stanza moved(std::move(copy));
+      });
+  xml.feed(doc.data(), doc.size(), true);
+
+  const std::string doc2 = "<stream xmlns='s'><stanza>coucou\r\n\a</stanza></stream>";
+  xml.add_stanza_callback([](const Stanza& stanza)
+      {
+        CHECK(stanza.get_inner() == "coucou\r\n");
+      });
+
+  xml.feed(doc2.data(), doc.size(), true);
+}
+
+TEST_CASE("XML escape")
+{
+  const std::string unescaped = "'coucou'<cc>/&\"gaga\"";
+  CHECK(xml_escape(unescaped) == "&apos;coucou&apos;&lt;cc&gt;/&amp;&quot;gaga&quot;");
+}
author	Vasudev Kamath <vasudev@copyninja.info>	2016-10-23 21:09:41 +0530
committer	Vasudev Kamath <vasudev@copyninja.info>	2016-10-23 21:09:41 +0530
commit	4e4de7284e6e4d89d182ea459823bbec1e408842 (patch)
tree	47e0ed5216b48649b138f168f61fddca2b0c076a /tests
parent	dfb3a6edfacf2f16a8a63690b3e8058b6295d1a3 (diff)
parent	eda4b75b1cff83336e87da90efca9fd6b4ced2c7 (diff)
download	biboumi-4e4de7284e6e4d89d182ea459823bbec1e408842.tar.gz biboumi-4e4de7284e6e4d89d182ea459823bbec1e408842.tar.bz2 biboumi-4e4de7284e6e4d89d182ea459823bbec1e408842.tar.xz biboumi-4e4de7284e6e4d89d182ea459823bbec1e408842.zip