Host is required

-k uses substring match, so -k Sable matched ErgoUtf8NickDisabledTestCase

.github/workflows/lint.yml

@@ -19,7 +19,7 @@ jobs:
         python-version: 3.11
 
     - name: Cache dependencies
-      uses: actions/cache@v4
+      uses: actions/cache@v2
       with:
         path: |
           ~/.cache

.github/workflows/test-devel.yml

@@ -120,8 +120,6 @@ jobs:
         path: ircd-hybrid
         ref: 8.2.x
         repository: ircd-hybrid/ircd-hybrid
-    - name: Install system dependencies
-      run: sudo apt-get install atheme-services faketime libjansson-dev
     - name: Build Hybrid
       run: |
         cd $GITHUB_WORKSPACE/ircd-hybrid/
@@ -560,7 +558,7 @@ jobs:
         repository: ergochat/ergo
     - uses: actions/setup-go@v3
       with:
-        go-version: ^1.24.0
+        go-version: ^1.23.0
     - run: go version
     - name: Build Ergo
       run: |
@@ -992,6 +990,7 @@ jobs:
         cache-on-failure: true
         workspaces: sable -> target
     - run: rustc --version
+    - run: sudo systemctl start postgresql.service
     - name: Build Sable
       run: |
         cd $GITHUB_WORKSPACE/sable/
@@ -1005,7 +1004,8 @@ jobs:
     - env:
         IRCTEST_DEBUG_LOGS: ${{ runner.debug }}
       name: Test with pytest
-      run: PYTEST_ARGS='--junit-xml pytest.xml --timeout 300' PATH=$HOME/.local/bin:$PATH  PATH=$GITHUB_WORKSPACE/sable/target/debug/sbin:$GITHUB_WORKSPACE/sable/target/debug/bin:$GITHUB_WORKSPACE/sable/target/debug:$PATH
+      run: PYTEST_ARGS='--junit-xml pytest.xml --timeout 300' PATH=$HOME/.local/bin:$PATH
+        IRCTEST_POSTGRESQL_URL=postgresql://localhost IRCTEST_DEBUG_LOGS=1 PATH=$GITHUB_WORKSPACE/sable/target/debug/sbin:$GITHUB_WORKSPACE/sable/target/debug/bin:$GITHUB_WORKSPACE/sable/target/debug:$PATH
         make sable
       timeout-minutes: 30
     - if: always()

.github/workflows/test-stable.yml

@@ -161,8 +161,6 @@ jobs:
         path: ircd-hybrid
         ref: 8.2.39
         repository: ircd-hybrid/ircd-hybrid
-    - name: Install system dependencies
-      run: sudo apt-get install atheme-services faketime libjansson-dev
     - name: Build Hybrid
       run: |
         cd $GITHUB_WORKSPACE/ircd-hybrid/
@@ -638,7 +636,7 @@ jobs:
         repository: ergochat/ergo
     - uses: actions/setup-go@v3
       with:
-        go-version: ^1.24.0
+        go-version: ^1.23.0
     - run: go version
     - name: Build Ergo
       run: |
@@ -1142,7 +1140,7 @@ jobs:
       uses: actions/checkout@v4
       with:
         path: sable
-        ref: baed3ef9ac4550dc36a45b758436769e82e8ec58
+        ref: 034c4d5dd937774099773238d8d5b8054b015607
         repository: Libera-Chat/sable
     - name: Install rust toolchain
       uses: actions-rs/toolchain@v1
@@ -1156,6 +1154,7 @@ jobs:
         cache-on-failure: true
         workspaces: sable -> target
     - run: rustc --version
+    - run: sudo systemctl start postgresql.service
     - name: Build Sable
       run: |
         cd $GITHUB_WORKSPACE/sable/
@@ -1169,7 +1168,8 @@ jobs:
     - env:
         IRCTEST_DEBUG_LOGS: ${{ runner.debug }}
       name: Test with pytest
-      run: PYTEST_ARGS='--junit-xml pytest.xml --timeout 300' PATH=$HOME/.local/bin:$PATH  PATH=$GITHUB_WORKSPACE/sable/target/debug/sbin:$GITHUB_WORKSPACE/sable/target/debug/bin:$GITHUB_WORKSPACE/sable/target/debug:$PATH
+      run: PYTEST_ARGS='--junit-xml pytest.xml --timeout 300' PATH=$HOME/.local/bin:$PATH
+        IRCTEST_POSTGRESQL_URL=postgresql://localhost IRCTEST_DEBUG_LOGS=1 PATH=$GITHUB_WORKSPACE/sable/target/debug/sbin:$GITHUB_WORKSPACE/sable/target/debug/bin:$GITHUB_WORKSPACE/sable/target/debug:$PATH
         make sable
       timeout-minutes: 30
     - if: always()

Makefile

@@ -4,109 +4,161 @@ PYTEST ?= python3 -m pytest
 # pytest-xdist is installed)
 PYTEST_ARGS ?=
 
+# Will be appended at the end of the -m argument to pytest
+EXTRA_MARKERS ?=
+
 # Will be appended at the end of the -k argument to pytest
 EXTRA_SELECTORS ?=
 
-BAHAMUT_SELECTORS := \
+BAHAMUT_MARKERS := \
-	not Ergo \
+	not implementation-specific \
 	and not deprecated \
 	and not strict \
 	and not IRCv3 \
+	$(EXTRA_MARKERS)
+BAHAMUT_SELECTORS := \
+	(foo or not foo) \
 	$(EXTRA_SELECTORS)
 
+CHARYBDIS_MARKERS := \
+	not implementation-specific \
+	and not deprecated \
+	and not strict \
+	$(EXTRA_MARKERS)
 CHARYBDIS_SELECTORS := \
-	not Ergo \
+	(foo or not foo) \
-	and not deprecated \
-	and not strict \
 	$(EXTRA_SELECTORS)
 
+ERGO_MARKERS := \
+	(Ergo or not implementation-specific) \
+	and not deprecated \
+	$(EXTRA_MARKERS)
 ERGO_SELECTORS := \
-	not deprecated \
+	(foo or not foo) \
 	$(EXTRA_SELECTORS)
 
+HYBRID_MARKERS := \
+	not implementation-specific \
+	and not deprecated \
+	$(EXTRA_MARKERS)
 HYBRID_SELECTORS := \
-	not Ergo \
+	(foo or not foo) \
-	and not deprecated \
 	$(EXTRA_SELECTORS)
 
+INSPIRCD_MARKERS := \
+	not implementation-specific \
+	and not deprecated \
+	and not strict \
+	$(EXTRA_MARKERS)
 INSPIRCD_SELECTORS := \
-	not Ergo \
+	(foo or not foo) \
-	and not deprecated \
-	and not strict \
 	$(EXTRA_SELECTORS)
 
+IRCU2_MARKERS := \
+	not implementation-specific \
+	and not deprecated \
+	and not strict \
+	and not IRCv3 \
+	$(EXTRA_MARKERS)
 IRCU2_SELECTORS := \
-	not Ergo \
+	(foo or not foo) \
-	and not deprecated \
-	and not strict \
 	$(EXTRA_SELECTORS)
 
+NEFARIOUS_MARKERS := \
+	not implementation-specific \
+	and not deprecated \
+	and not strict \
+	$(EXTRA_MARKERS)
 NEFARIOUS_SELECTORS := \
-	not Ergo \
+	(foo or not foo) \
-	and not deprecated \
-	and not strict \
 	$(EXTRA_SELECTORS)
 
+SNIRCD_MARKERS := \
+	not implementation-specific \
+	and not deprecated \
+	and not strict \
+	and not IRCv3 \
+	$(EXTRA_MARKERS)
 SNIRCD_SELECTORS := \
-	not Ergo \
+	(foo or not foo) \
-	and not deprecated \
-	and not strict \
 	$(EXTRA_SELECTORS)
 
+IRC2_MARKERS := \
+	not implementation-specific \
+	and not deprecated \
+	and not strict \
+	and not IRCv3 \
+	$(EXTRA_MARKERS)
 IRC2_SELECTORS := \
-	not Ergo \
+	(foo or not foo) \
-	and not deprecated \
-	and not strict \
 	$(EXTRA_SELECTORS)
 
+MAMMON_MARKERS := \
+	not implementation-specific \
+	and not deprecated \
+	and not strict \
+	$(EXTRA_MARKERS)
 MAMMON_SELECTORS := \
-	not Ergo \
+	(foo or not foo) \
-	and not deprecated \
-	and not strict \
 	$(EXTRA_SELECTORS)
 
+NGIRCD_MARKERS := \
+	not implementation-specific \
+	and not deprecated \
+	and not strict \
+	$(EXTRA_MARKERS)
 NGIRCD_SELECTORS := \
-	not Ergo \
+	(foo or not foo) \
-	and not deprecated \
-	and not strict \
 	$(EXTRA_SELECTORS)
 
+PLEXUS4_MARKERS := \
+	not implementation-specific \
+	and not deprecated \
+	$(EXTRA_MARKERS)
 PLEXUS4_SELECTORS := \
-	not Ergo \
+	(foo or not foo) \
-	and not deprecated \
 	$(EXTRA_SELECTORS)
 
-# Limnoria can actually pass all the test so there is none to exclude.
+LIMNORIA_MARKERS := \
-# `(foo or not foo)` serves as a `true` value so it doesn't break when
+	not implementation-specific \
-# $(EXTRA_SELECTORS) is non-empty
+	$(EXTRA_MARKERS)
 LIMNORIA_SELECTORS := \
 	(foo or not foo) \
 	$(EXTRA_SELECTORS)
 
 # Tests marked with arbitrary_client_tags or react_tag can't pass because Sable does not support client tags yet
-SABLE_SELECTORS := \
+# 'SablePostgresqlHistoryTestCase and private_chathistory' disabled because Sable does not (yet?) persist private messages to postgresql
-	not Ergo \
+SABLE_MARKERS := \
+	(Sable or not implementation-specific) \
 	and not deprecated \
 	and not strict \
 	and not arbitrary_client_tags \
 	and not react_tag \
-	and not list and not lusers and not time and not info \
+	$(EXTRA_MARKERS)
+SABLE_SELECTORS := \
+	not list and not lusers and not time and not info \
+	and not (SablePostgresqlHistoryTestCase and private_chathistory) \
 	$(EXTRA_SELECTORS)
 
-SOLANUM_SELECTORS := \
+SOLANUM_MARKERS := \
-	not Ergo \
+	not implementation-specific \
 	and not deprecated \
 	and not strict \
+	$(EXTRA_MARKERS)
+SOLANUM_SELECTORS := \
+	(foo or not foo) \
 	$(EXTRA_SELECTORS)
 
-# Same as Limnoria
+SOPEL_MARKERS := \
+	not implementation-specific \
+	$(EXTRA_MARKERS)
 SOPEL_SELECTORS := \
 	(foo or not foo) \
 	$(EXTRA_SELECTORS)
 
-# TheLounge can actually pass all the test so there is none to exclude.
+THELOUNGE_MARKERS := \
-# `(foo or not foo)` serves as a `true` value so it doesn't break when
+	not implementation-specific \
-# $(EXTRA_SELECTORS) is non-empty
+	$(EXTRA_MARKERS)
 THELOUNGE_SELECTORS := \
 	(foo or not foo) \
 	$(EXTRA_SELECTORS)
@@ -115,13 +167,16 @@ THELOUNGE_SELECTORS := \
 # Tests marked with react_tag can't pass because Unreal blocks +draft/react https://github.com/unrealircd/unrealircd/pull/149
 # Tests marked with private_chathistory can't pass because Unreal does not implement CHATHISTORY for DMs
 
-UNREALIRCD_SELECTORS := \
+UNREALIRCD_MARKERS := \
-	not Ergo \
+	not implementation-specific \
 	and not deprecated \
 	and not strict \
 	and not arbitrary_client_tags \
 	and not react_tag \
 	and not private_chathistory \
+	$(EXTRA_MARKERS)
+UNREALIRCD_SELECTORS := \
+	(foo or not foo) \
 	$(EXTRA_SELECTORS)
 
 .PHONY: all flakes bahamut charybdis ergo inspircd ircu2 snircd irc2 mammon nefarious limnoria sable sopel solanum unrealircd
@@ -137,107 +192,114 @@ bahamut:
 		-m 'not services' \
 		-n 4 \
 		-vv -s \
+		-m 'not services and $(BAHAMUT_MARKERS)'
 		-k '$(BAHAMUT_SELECTORS)'
 
 bahamut-atheme:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.bahamut \
 		--services-controller=irctest.controllers.atheme_services \
-		-m 'services' \
+		-m 'services and $(BAHAMUT_MARKERS)' \
 		-k '$(BAHAMUT_SELECTORS)'
 
 bahamut-anope:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.bahamut \
 		--services-controller=irctest.controllers.anope_services \
-		-m 'services' \
+		-m 'services and $(BAHAMUT_MARKERS)' \
 		-k '$(BAHAMUT_SELECTORS)'
 
 charybdis:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.charybdis \
 		--services-controller=irctest.controllers.atheme_services \
+		-m '$(CHARYBDIS_MARKERS)'
 		-k '$(CHARYBDIS_SELECTORS)'
 
 ergo:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller irctest.controllers.ergo \
+		-m '$(ERGO_MARKERS)'
 		-k "$(ERGO_SELECTORS)"
 
 hybrid:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller irctest.controllers.hybrid \
 		--services-controller=irctest.controllers.anope_services \
+		-m '$(HYBRID_MARKERS)'
 		-k "$(HYBRID_SELECTORS)"
 
 inspircd:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.inspircd \
-		-m 'not services' \
+		-m 'not services and $(INSPIRCD_MARKERS)' \
 		-k '$(INSPIRCD_SELECTORS)'
 
 inspircd-atheme:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.inspircd \
 		--services-controller=irctest.controllers.atheme_services \
-		-m 'services' \
+		-m 'services and $(INSPIRCD_MARKERS)' \
 		-k '$(INSPIRCD_SELECTORS)'
 
 inspircd-anope:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.inspircd \
 		--services-controller=irctest.controllers.anope_services \
-		-m 'services' \
+		-m 'services and $(INSPIRCD_MARKERS)' \
 		-k '$(INSPIRCD_SELECTORS)'
 
 ircu2:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.ircu2 \
-		-m 'not services and not IRCv3' \
+		-m 'not services and $(IRCU2_MARKERS)' \
 		-n 4 \
 		-k '$(IRCU2_SELECTORS)'
 
 nefarious:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.nefarious \
-		-m 'not services' \
+		-m 'not services and $(NEFARIOUS_MARKERS)' \
 		-n 4 \
 		-k '$(NEFARIOUS_SELECTORS)'
 
 snircd:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.snircd \
-		-m 'not services and not IRCv3' \
+		-m 'not services and $(SNIRCD_MARKERS)' \
 		-n 4 \
 		-k '$(SNIRCD_SELECTORS)'
 
 irc2:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.irc2 \
-		-m 'not services and not IRCv3' \
+		-m 'not services and $(IRCU2_MARKERS)' \
 		-n 4 \
 		-k '$(IRC2_SELECTORS)'
 
 limnoria:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.limnoria \
+		-m '$(LIMNORIA_MARKERS)' \
 		-k '$(LIMNORIA_SELECTORS)'
 
 mammon:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.mammon \
+		-m '$(MAMMON_MARKERS)' \
 		-k '$(MAMMON_SELECTORS)'
 
 plexus4:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller irctest.controllers.plexus4 \
 		--services-controller=irctest.controllers.anope_services \
+		-m '$(PLEXUS4_MARKERS)' \
 		-k "$(PLEXUS4_SELECTORS)"
 
 ngircd:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller irctest.controllers.ngircd \
-		-m 'not services' \
+		-m 'not services and $(NGIRCD_MARKERS)' \
 		-n 4 \
 		-k "$(NGIRCD_SELECTORS)"
 
@@ -245,19 +307,20 @@ ngircd-anope:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller irctest.controllers.ngircd \
 		--services-controller=irctest.controllers.anope_services \
-		-m 'services' \
+		-m 'services and $(NGIRCD_MARKERS)' \
 		-k "$(NGIRCD_SELECTORS)"
 
 ngircd-atheme:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller irctest.controllers.ngircd \
 		--services-controller=irctest.controllers.atheme_services \
-		-m 'services' \
+		-m 'services and $(NGIRCD_MARKERS)' \
 		-k "$(NGIRCD_SELECTORS)"
 
 sable:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.sable \
+		-m '$(SABLE_MARKERS)' \
 		-n 20 \
 		-k '$(SABLE_SELECTORS)'
 
@@ -265,22 +328,25 @@ solanum:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.solanum \
 		--services-controller=irctest.controllers.atheme_services \
+		-m '$(SOLANUM_MARKERS)' \
 		-k '$(SOLANUM_SELECTORS)'
 
 sopel:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.sopel \
+		-m '$(SOPEL_MARKERS)' \
 		-k '$(SOPEL_SELECTORS)'
 
 thelounge:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.thelounge \
+		-m '$(THELOUNGE_MARKERS)' \
 		-k '$(THELOUNGE_SELECTORS)'
 
 unrealircd:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.unrealircd \
-		-m 'not services' \
+		-m 'not services and $(UNREALIRCD_MARKERS)' \
 		-k '$(UNREALIRCD_SELECTORS)'
 
 unrealircd-5: unrealircd
@@ -289,19 +355,19 @@ unrealircd-atheme:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.unrealircd \
 		--services-controller=irctest.controllers.atheme_services \
-		-m 'services' \
+		-m 'services and $(UNREALIRCD_MARKERS)' \
 		-k '$(UNREALIRCD_SELECTORS)'
 
 unrealircd-anope:
 	$(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.unrealircd \
 		--services-controller=irctest.controllers.anope_services \
-		-m 'services' \
+		-m 'services and $(UNREALIRCD_MARKERS)' \
 		-k '$(UNREALIRCD_SELECTORS)'
 
 unrealircd-dlk:
 	pifpaf run mysql -- $(PYTEST) $(PYTEST_ARGS) \
 		--controller=irctest.controllers.unrealircd \
 		--services-controller=irctest.controllers.dlk_services \
-		-m 'services' \
+		-m 'services and $(UNREALIRCD_MARKERS)' \
 		-k '$(UNREALIRCD_SELECTORS)'

irctest/basecontrollers.py

@@ -8,8 +8,10 @@ from pathlib import Path
 import shutil
 import socket
 import subprocess
+import sys
 import tempfile
 import textwrap
+import threading
 import time
 from typing import (
     IO,
@@ -67,6 +69,9 @@ class TestCaseControllerConfig:
     This should be used as little as possible, using the other attributes instead;
     as they are work with any controller."""
 
+    sable_history_server: bool = False
+    """Whether to start Sable's long-term history server"""
+
 
 class _BaseController:
     """Base class for software controllers.
@@ -145,10 +150,48 @@ class _BaseController:
                 self._own_ports.remove((hostname, port))
 
     def execute(
-        self, command: Sequence[Union[str, Path]], **kwargs: Any
+        self,
+        command: Sequence[Union[str, Path]],
+        proc_name: Optional[str] = None,
+        **kwargs: Any,
     ) -> subprocess.Popen:
         output_to = None if self.debug_mode else subprocess.DEVNULL
-        return subprocess.Popen(command, stderr=output_to, stdout=output_to, **kwargs)
+        proc_name = proc_name or str(command[0])
+        kwargs.setdefault("stdout", output_to)
+        kwargs.setdefault("stderr", output_to)
+        stream_stdout = stream_stderr = None
+        if kwargs["stdout"] in (None, subprocess.STDOUT):
+            kwargs["stdout"] = subprocess.PIPE
+
+            def stream_stdout() -> None:
+                assert proc.stdout is not None  # for mypy
+                for line in proc.stdout:
+                    prefix = f"{time.time():.3f} {proc_name} ".encode()
+                    try:
+                        sys.stdout.buffer.write(prefix + line)
+                    except ValueError:
+                        # "I/O operation on closed file"
+                        pass
+
+        if kwargs["stderr"] in (subprocess.STDOUT, None):
+            kwargs["stderr"] = subprocess.PIPE
+
+            def stream_stderr() -> None:
+                assert proc.stderr is not None  # for mypy
+                for line in proc.stderr:
+                    prefix = f"{time.time():.3f} {proc_name} ".encode()
+                    try:
+                        sys.stdout.buffer.write(prefix + line)
+                    except ValueError:
+                        # "I/O operation on closed file"
+                        pass
+
+        proc = subprocess.Popen(command, **kwargs)
+        if stream_stdout is not None:
+            threading.Thread(target=stream_stdout, name="stream_stdout").start()
+        if stream_stderr is not None:
+            threading.Thread(target=stream_stderr, name="stream_stderr").start()
+        return proc
 
 
 class DirectoryBasedController(_BaseController):
@@ -273,6 +316,7 @@ class BaseServerController(_BaseController):
     def __init__(self, *args: Any, **kwargs: Any):
         super().__init__(*args, **kwargs)
         self.faketime_enabled = False
+        self.services_controller = None
 
     def run(
         self,

irctest/cases.py

@@ -842,16 +842,22 @@ def mark_services(cls: TClass) -> TClass:
 def mark_specifications(
     *specifications_str: str, deprecated: bool = False, strict: bool = False
 ) -> Callable[[TCallable], TCallable]:
-    specifications = frozenset(
+    specifications = {
         Specifications.from_name(s) if isinstance(s, str) else s
         for s in specifications_str
-    )
+    }
     if None in specifications:
         raise ValueError("Invalid set of specifications: {}".format(specifications))
 
+    is_implementation_specific = all(
+        spec.is_implementation_specific() for spec in specifications
+    )
+
     def decorator(f: TCallable) -> TCallable:
         for specification in specifications:
             f = getattr(pytest.mark, specification.value)(f)
+        if is_implementation_specific:
+            f = getattr(pytest.mark, "implementation-specific")(f)
         if strict:
             f = pytest.mark.strict(f)
         if deprecated:

irctest/controllers/anope_services.py

@@ -8,7 +8,7 @@ from irctest.basecontrollers import BaseServicesController, DirectoryBasedContro
 
 TEMPLATE_CONFIG = """
 serverinfo {{
-    name = "My.Little.Services"
+    name = "services.example.org"
     description = "Anope IRC Services"
     numeric = "00A"
     pid = "services.pid"
@@ -66,13 +66,8 @@ options {{
     warningtimeout = 4h
 }}
 
-module {{ name = "ns_sasl" }} # since 2.1.13
+module {{ name = "{module_prefix}sasl" }}
-module {{ name = "sasl" }}    # 2.1.2 to 2.1.12
+module {{ name = "enc_bcrypt" }}
-module {{ name = "m_sasl" }}  # 2.0 to 2.1.1
-
-module {{ name = "enc_sha2" }}   # 2.1
-module {{ name = "enc_sha256" }} # 2.0
-
 module {{ name = "ns_cert" }}
 
 """
@@ -128,6 +123,7 @@ class AnopeController(BaseServicesController, DirectoryBasedController):
                     protocol=protocol,
                     server_hostname=server_hostname,
                     server_port=server_port,
+                    module_prefix="" if self.software_version >= (2, 1, 2) else "m_",
                 )
             )
 

irctest/controllers/atheme_services.py

@@ -24,7 +24,7 @@ loadmodule "modules/saslserv/plain";
 #loadmodule "modules/saslserv/scram";
 
 serverinfo {{
-    name = "My.Little.Services";
+    name = "services.example.org";
     desc = "Atheme IRC Services";
     numeric = "00A";
     netname = "testnet";

irctest/controllers/bahamut.py

@@ -14,7 +14,7 @@ options {{
     network_name    unconfigured;
     allow_split_ops;                # Give ops in empty channels
 
-    services_name   My.Little.Services;
+    services_name   services.example.org;
 
     // if you need to link more than 1 server, uncomment the following line
     servtype        hub;
@@ -44,7 +44,7 @@ class {{
 
 /* for services */
 super {{
-    "My.Little.Services";
+    "services.example.org";
 }};
 
 
@@ -57,7 +57,7 @@ class {{
 
 /* our services */
 connect {{
-    name        My.Little.Services;
+    name        services.example.org;
     host        *@127.0.0.1;  # unfortunately, masks aren't allowed here
     apasswd     password;
     cpasswd     password;
@@ -91,7 +91,7 @@ class BahamutController(BaseServerController, DirectoryBasedController):
     software_name = "Bahamut"
     supported_sasl_mechanisms: Set[str] = set()
     supports_sts = False
-    nickserv = "NickServ@My.Little.Services"
+    nickserv = "NickServ@services.example.org"
 
     def create_config(self) -> None:
         super().create_config()

irctest/controllers/charybdis.py

@@ -44,7 +44,7 @@ channel {{
     displayed_usercount = 0;
 }};
 
-connect "My.Little.Services" {{
+connect "services.example.org" {{
     host = "localhost";  # Used to validate incoming connection
     port = 0;  # We don't need servers to connect to services
     send_password = "password";
@@ -53,14 +53,14 @@ connect "My.Little.Services" {{
     flags = topicburst;
 }};
 service {{
-    name = "My.Little.Services";
+    name = "services.example.org";
 }};
 
 privset "omnioper" {{
     privs = oper:general, oper:privs, oper:testline, oper:kill, oper:operwall, oper:message,
             oper:routing, oper:kline, oper:unkline, oper:xline,
             oper:resv, oper:cmodes, oper:mass_notice, oper:wallops,
-            oper:remoteban, oper:local_kill,
+            oper:remoteban,
             usermode:servnotice, auspex:oper, auspex:hostname, auspex:umodes, auspex:cmodes,
             oper:admin, oper:die, oper:rehash, oper:spy, oper:grant;
 }};

irctest/controllers/dlk_services.py

@@ -13,7 +13,7 @@ TEMPLATE_DLK_CONFIG = """\
 info {{
     SID "00A";
     network-name "testnetwork";
-    services-name "My.Little.Services";
+    services-name "services.example.org";
     admin-email "admin@example.org";
 }}
 

irctest/controllers/hybrid.py

@@ -42,7 +42,7 @@ class {{
     connectfreq = 5 minutes;
 }};
 connect {{
-    name = "My.Little.Services";
+    name = "services.example.org";
     host = "127.0.0.1";  # Used to validate incoming connection
     port = 0;  # We don't need servers to connect to services
     send_password = "password";
@@ -50,7 +50,7 @@ connect {{
     class = "server";
 }};
 service {{
-    name = "My.Little.Services";
+    name = "services.example.org";
 }};
 
 auth {{

irctest/controllers/inspircd.py

@@ -19,7 +19,7 @@ TEMPLATE_CONFIG = """
 
 <class
     name="ServerOperators"
-    commands="WALLOPS GLOBOPS KILL"
+    commands="WALLOPS GLOBOPS"
     privs="channels/auspex users/auspex channels/auspex servers/auspex"
     >
 <type
@@ -41,7 +41,7 @@ TEMPLATE_CONFIG = """
 
 # Services:
 <bind address="{services_hostname}" port="{services_port}" type="servers">
-<link name="My.Little.Services"
+<link name="services.example.org"
     ipaddr="{services_hostname}"
     port="{services_port}"
     allowmask="*"
@@ -51,7 +51,7 @@ TEMPLATE_CONFIG = """
 <module name="spanningtree">
 <module name="hidechans">  # Anope errors when missing
 <sasl requiressl="no"
-      target="My.Little.Services">
+      target="services.example.org">
 
 # Protocol:
 <module name="banexception">

irctest/controllers/irc2.py

@@ -24,7 +24,7 @@ Y:10:90::100:512000:100.100:100.100:
 I::{password_field}:::10::
 
 # O:<TARGET Host NAME>:<Password>:<Nickname>:<Port>:<Class>:<Flags>:
-O:*:operpassword:operuser:::K:
+O:*:operpassword:operuser::::
 """
 
 

irctest/controllers/ngircd.py

@@ -14,7 +14,7 @@ TEMPLATE_CONFIG = """
     {password_field}
 
 [Server]
-    Name = My.Little.Services
+    Name = services.example.org
     MyPassword = password
     PeerPassword = password
     Passive = yes  # don't connect to it

irctest/controllers/plexus4.py

@@ -44,7 +44,7 @@ class {{
     connectfreq = 5 minutes;
 }};
 connect {{
-    name = "My.Little.Services";
+    name = "services.example.org";
     host = "127.0.0.1";  # Used to validate incoming connection
     port = 0;  # We don't need servers to connect to services
     send_password = "password";
@@ -52,7 +52,7 @@ connect {{
     class = "server";
 }};
 service {{
-    name = "My.Little.Services";
+    name = "services.example.org";
 }};
 
 auth {{

irctest/controllers/sable.py

@@ -4,8 +4,9 @@ import shutil
 import signal
 import subprocess
 import tempfile
+import threading
 import time
-from typing import Optional, Type
+from typing import Any, Optional, Sequence, Type
 
 from irctest.basecontrollers import (
     BaseServerController,
@@ -86,7 +87,13 @@ def certs_dir() -> Path:
         certs_dir = tempfile.TemporaryDirectory()
         (Path(certs_dir.name) / "gen_certs.sh").write_text(GEN_CERTS)
         subprocess.run(
-            ["bash", "gen_certs.sh", "My.Little.Server", "My.Little.Services"],
+            [
+                "bash",
+                "gen_certs.sh",
+                "My.Little.Server",
+                "My.Little.History",
+                "My.Little.Services",
+            ],
             cwd=certs_dir.name,
             check=True,
         )
@@ -96,10 +103,11 @@ def certs_dir() -> Path:
 
 NETWORK_CONFIG = """
 {
-    "fanout": 1,
+    "fanout": 2,
     "ca_file": "%(certs_dir)s/ca_cert.pem",
 
     "peers": [
+        { "name": "My.Little.History", "address": "%(history_hostname)s:%(history_port)s", "fingerprint": "%(history_cert_sha1)s" },
         { "name": "My.Little.Services", "address": "%(services_hostname)s:%(services_port)s", "fingerprint": "%(services_cert_sha1)s" },
         { "name": "My.Little.Server", "address": "%(server1_hostname)s:%(server1_port)s", "fingerprint": "%(server1_cert_sha1)s" }
     ]
@@ -108,7 +116,7 @@ NETWORK_CONFIG = """
 
 NETWORK_CONFIG_CONFIG = """
 {
-    "object_expiry": 300,
+    "object_expiry": 60,  // 1 minute
 
     "opers": [
         {
@@ -220,6 +228,58 @@ SERVER_CONFIG = """
 }
 """
 
+HISTORY_SERVER_CONFIG = """
+{
+    "server_id": 50,
+    "server_name": "My.Little.History",
+
+    "management": {
+        "address": "%(history_management_hostname)s:%(history_management_port)s",
+        "client_ca": "%(certs_dir)s/ca_cert.pem",
+        "authorised_fingerprints": [
+            { "name": "user1", "fingerprint": "435bc6db9f22e84ba5d9652432154617c9509370" }
+        ]
+    },
+
+    "server": {
+        "database": "%(history_db_url)s",
+        "auto_run_migrations": true,
+    },
+
+    "event_log": {
+        "event_expiry": 300, // five minutes, for local testing
+    },
+
+    "tls_config": {
+        "key_file": "%(certs_dir)s/My.Little.History.key",
+        "cert_file": "%(certs_dir)s/My.Little.History.pem"
+    },
+
+    "node_config": {
+        "listen_addr": "%(history_hostname)s:%(history_port)s",
+        "cert_file": "%(certs_dir)s/My.Little.History.pem",
+        "key_file": "%(certs_dir)s/My.Little.History.key"
+    },
+
+    "log": {
+        "dir": "log/services/",
+
+        "module-levels": {
+            "": "debug",
+            "sable_history": "trace",
+        },
+
+        "targets": [
+            {
+                "target": "stdout",
+                "level": "trace",
+                "modules": [ "sable" ]
+            }
+        ]
+    }
+}
+"""
+
 SERVICES_CONFIG = """
 {
     "server_id": 99,
@@ -298,7 +358,7 @@ SERVICES_CONFIG = """
             {
                 "target": "stdout",
                 "level": "debug",
-                "modules": [ "sable_services" ]
+                "modules": [ "sable" ]
             }
         ]
     }
@@ -313,6 +373,12 @@ class SableController(BaseServerController, DirectoryBasedController):
     """Sable processes commands very quickly, but responses for commands changing the
     state may be sent after later commands for messages which don't."""
 
+    history_controller: Optional[BaseServicesController] = None
+
+    def __init__(self, *args: Any, **kwargs: Any):
+        super().__init__(*args, **kwargs)
+        self.history_controller = None
+
     def run(
         self,
         hostname: str,
@@ -349,10 +415,11 @@ class SableController(BaseServerController, DirectoryBasedController):
 
         (server1_hostname, server1_port) = self.get_hostname_and_port()
         (services_hostname, services_port) = self.get_hostname_and_port()
+        (history_hostname, history_port) = self.get_hostname_and_port()
 
         # Sable requires inbound connections to match the configured hostname,
         # so we can't configure 0.0.0.0
-        server1_hostname = services_hostname = "127.0.0.1"
+        server1_hostname = history_hostname = services_hostname = "127.0.0.1"
 
         (
             server1_management_hostname,
@@ -362,6 +429,10 @@ class SableController(BaseServerController, DirectoryBasedController):
             services_management_hostname,
             services_management_port,
         ) = self.get_hostname_and_port()
+        (
+            history_management_hostname,
+            history_management_port,
+        ) = self.get_hostname_and_port()
 
         self.template_vars = dict(
             certs_dir=certs_dir(),
@@ -382,6 +453,13 @@ class SableController(BaseServerController, DirectoryBasedController):
             services_management_hostname=services_management_hostname,
             services_management_port=services_management_port,
             services_alias_users=SERVICES_ALIAS_USERS if run_services else "",
+            history_hostname=history_hostname,
+            history_port=history_port,
+            history_cert_sha1=(certs_dir() / "My.Little.History.pem.sha1")
+            .read_text()
+            .strip(),
+            history_management_hostname=history_management_hostname,
+            history_management_port=history_management_port,
         )
 
         with self.open_file("configs/network.conf") as fd:
@@ -412,17 +490,28 @@ class SableController(BaseServerController, DirectoryBasedController):
             cwd=self.directory,
             preexec_fn=os.setsid,
             env={"RUST_BACKTRACE": "1", **os.environ},
+            proc_name="sable_ircd    ",
         )
         self.pgroup_id = os.getpgid(self.proc.pid)
 
         if run_services:
             self.services_controller = SableServicesController(self.test_config, self)
+            self.services_controller.faketime_cmd = faketime_cmd
             self.services_controller.run(
                 protocol="sable",
                 server_hostname=services_hostname,
                 server_port=services_port,
             )
 
+        if self.test_config.sable_history_server:
+            self.history_controller = SableHistoryController(self.test_config, self)
+            self.history_controller.faketime_cmd = faketime_cmd
+            self.history_controller.run(
+                protocol="sable",
+                server_hostname=history_hostname,
+                server_port=history_port,
+            )
+
     def kill_proc(self) -> None:
         os.killpg(self.pgroup_id, signal.SIGKILL)
         super().kill_proc()
@@ -466,11 +555,62 @@ class SableController(BaseServerController, DirectoryBasedController):
         case.sendLine(client, "QUIT")
         case.assertDisconnected(client)
 
+    def wait_for_services(self) -> None:
+        # FIXME: this isn't called when sable_history is enabled but sable_services
+        # isn't. This doesn't happen with the existing tests so this isn't an issue yet
+        if self.services_controller is not None:
+            t1 = threading.Thread(target=self.services_controller.wait_for_services)
+            t1.start()
+        if self.history_controller is not None:
+            t2 = threading.Thread(target=self.history_controller.wait_for_services)
+            t2.start()
+            t2.join()
+        if self.services_controller is not None:
+            t1.join()
+
 
 class SableServicesController(BaseServicesController):
     server_controller: SableController
     software_name = "Sable Services"
 
+    faketime_cmd: Sequence[str]
+
+    def wait_for_services(self) -> None:
+        """Overrides the default implementation, as it relies on
+        ``PRIVMSG NickServ: HELP``, which always succeeds on Sable.
+
+        Instead, this relies on SASL PLAIN availability."""
+        if self.services_up:
+            # Don't check again if they are already available
+            return
+        self.server_controller.wait_for_port()
+
+        c = ClientMock(name="chkSASL", show_io=True)
+        c.connect(self.server_controller.hostname, self.server_controller.port)
+
+        def wait() -> None:
+            while True:
+                c.sendLine("CAP LS 302")
+                for msg in c.getMessages(synchronize=False):
+                    if msg.command == "CAP":
+                        assert msg.params[-2] == "LS", msg
+                        for cap in msg.params[-1].split():
+                            if cap.startswith("sasl="):
+                                mechanisms = cap.split("=", 1)[1].split(",")
+                                if "PLAIN" in mechanisms:
+                                    return
+                        else:
+                            if msg.params[0] == "*":
+                                # End of CAP LS
+                                time.sleep(self.server_controller.sync_sleep_time)
+
+        wait()
+
+        c.sendLine("QUIT")
+        c.getMessages()
+        c.disconnect()
+        self.services_up = True
+
     def run(self, protocol: str, server_hostname: str, server_port: int) -> None:
         assert protocol == "sable"
         assert self.server_controller.directory is not None
@@ -480,6 +620,7 @@ class SableServicesController(BaseServicesController):
 
         self.proc = self.execute(
             [
+                *self.faketime_cmd,
                 "sable_services",
                 "--foreground",
                 "--server-conf",
@@ -490,6 +631,7 @@ class SableServicesController(BaseServicesController):
             cwd=self.server_controller.directory,
             preexec_fn=os.setsid,
             env={"RUST_BACKTRACE": "1", **os.environ},
+            proc_name="sable_services",
         )
         self.pgroup_id = os.getpgid(self.proc.pid)
 
@@ -497,52 +639,92 @@ class SableServicesController(BaseServicesController):
         os.killpg(self.pgroup_id, signal.SIGKILL)
         super().kill_proc()
 
+
+class SableHistoryController(BaseServicesController):
+    server_controller: SableController
+    software_name = "Sable History Server"
+    faketime_cmd: Sequence[str]
+
+    def run(self, protocol: str, server_hostname: str, server_port: int) -> None:
+        assert protocol == "sable"
+        assert self.server_controller.directory is not None
+        history_db_url = os.environ.get("PIFPAF_POSTGRESQL_URL") or os.environ.get(
+            "IRCTEST_POSTGRESQL_URL"
+        )
+        assert history_db_url, (
+            "Cannot find a postgresql database to use as backend for sable_history. "
+            "Either set the IRCTEST_POSTGRESQL_URL env var to a libpq URL, or "
+            "run `pip3 install pifpaf` and wrap irctest in a pifpaf call (ie. "
+            "pifpaf run postgresql -- pytest --controller=irctest.controllers.sable ...)"
+        )
+
+        with self.server_controller.open_file("configs/history_server.conf") as fd:
+            vals = dict(self.server_controller.template_vars)
+            vals["history_db_url"] = history_db_url
+            fd.write(HISTORY_SERVER_CONFIG % vals)
+
+        self.proc = self.execute(
+            [
+                *self.faketime_cmd,
+                "sable_history",
+                "--foreground",
+                "--server-conf",
+                self.server_controller.directory / "configs/history_server.conf",
+                "--network-conf",
+                self.server_controller.directory / "configs/network.conf",
+            ],
+            cwd=self.server_controller.directory,
+            preexec_fn=os.setsid,
+            env={"RUST_BACKTRACE": "1", **os.environ},
+            proc_name="sable_history ",
+        )
+        self.pgroup_id = os.getpgid(self.proc.pid)
+
     def wait_for_services(self) -> None:
-        # by default, wait_for_services() connects a user that sends a HELP command
+        """Overrides the default implementation, as it relies on
-        # to NickServ and assumes services are up when it receives a non-ERR_NOSUCHNICK
+        ``PRIVMSG NickServ: HELP``, which always succeeds on Sable.
-        # reply.
+
-        # However, with Sable, NickServ is always up, even when services are not linked,
+        Instead, this relies on SASL PLAIN availability."""
-        # so we need to check a different way. We check presence of a non-EXTERNAL
-        # value to the sasl capability, but LINKS would
         if self.services_up:
             # Don't check again if they are already available
             return
         self.server_controller.wait_for_port()
 
-        c = ClientMock(name="chkSvs", show_io=True)
+        c = ClientMock(name="chkHist", show_io=True)
         c.connect(self.server_controller.hostname, self.server_controller.port)
-        c.sendLine("NICK chkSvs")
+        c.sendLine("NICK chkHist")
         c.sendLine("USER chk chk chk chk")
         time.sleep(self.server_controller.sync_sleep_time)
         got_end_of_motd = False
         while not got_end_of_motd:
             for msg in c.getMessages(synchronize=False):
                 if msg.command == "PING":
-                    # Hi Unreal
                     c.sendLine("PONG :" + msg.params[0])
                 if msg.command in ("376", "422"):  # RPL_ENDOFMOTD / ERR_NOMOTD
                     got_end_of_motd = True
 
-        timeout = time.time() + 10
+        def wait() -> None:
-        while not self.services_up:
+            timeout = time.time() + 10
-            if time.time() > timeout:
+            while time.time() < timeout:
-                raise Exception("Timeout while waiting for services")
+                c.sendLine("LINKS")
-            c.sendLine("CAP LS 302")
+                time.sleep(self.server_controller.sync_sleep_time)
+                for msg in c.getMessages(synchronize=False):
+                    if msg.command == "364":  # RPL_LINKS
+                        if msg.params[2] == "My.Little.History":
+                            return
 
-            msgs = self.getNickServResponse(c, timeout=1)
+            raise Exception("History server is not available")
-            for msg in msgs:
+
-                if msg.command == "CAP":
+        wait()
-                    pass
-                for token in msg.params[-1].split():
-                    if token.startswith("sasl="):
-                        if "PLAIN" in token.removeprefix("sasl=").split(","):
-                            # SASL PLAIN is available, so services are linked.
-                            self.services_up = True
-                            break
 
         c.sendLine("QUIT")
         c.getMessages()
         c.disconnect()
+        self.services_up = True
+
+    def kill_proc(self) -> None:
+        os.killpg(self.pgroup_id, signal.SIGKILL)
+        super().kill_proc()
 
 
 def get_irctest_controller_class() -> Type[SableController]:

irctest/controllers/unrealircd.py

@@ -64,7 +64,7 @@ listen {{
     options {{ serversonly; }}
 }}
 
-link My.Little.Services {{
+link services.example.org {{
     incoming {{
         mask *;
     }}
@@ -72,11 +72,11 @@ link My.Little.Services {{
     class servers;
 }}
 ulines {{
-    My.Little.Services;
+    services.example.org;
 }}
 
 set {{
-    sasl-server My.Little.Services;
+    sasl-server services.example.org;
     kline-address "example@example.org";
     network-name "ExampleNET";
     default-server "irc.example.org";

irctest/server_tests/bouncer.py

@@ -12,8 +12,9 @@ from irctest.patma import ANYSTR, StrRe
 
 @cases.mark_services
 class BouncerTestCase(cases.BaseServerTestCase):
-    def setUp(self):
+    @cases.mark_specifications("Ergo")
-        super().setUp()
+    def testBouncer(self):
+        """Test basic bouncer functionality."""
         self.controller.registerUser(self, "observer", "observerpassword")
         self.controller.registerUser(self, "testuser", "mypassword")
 
@@ -32,27 +33,13 @@ class BouncerTestCase(cases.BaseServerTestCase):
         self.sendLine(2, "USER a 0 * a")
         self.sendLine(2, "CAP REQ :server-time message-tags")
         self.sendLine(2, "CAP END")
-        self._waitForWelcome(2, "testnick")
+        messages = self.getMessages(2)
+        welcomes = [message for message in messages if message.command == RPL_WELCOME]
+        self.assertEqual(len(welcomes), 1)
+        # should see a regburst for testnick
+        self.assertMessageMatch(welcomes[0], params=["testnick", ANYSTR])
         self.joinChannel(2, "#chan")
 
-    def _waitForWelcome(self, client, nick):
-        """Waits for numeric 001, and returns every message after that."""
-        while True:
-            messages = iter(self.getMessages(client, synchronize=False))
-            for message in messages:
-                if message.command == "001":
-                    # should see a regburst for testnick
-                    self.assertMessageMatch(message, params=[nick, ANYSTR])
-
-                    messages_after_welcome = list(messages)
-                    messages_after_welcome += self.getMessages(client)
-
-                    # check there is no other 001
-                    for message in messages_after_welcome:
-                        self.assertNotEqual(message.command, "001")
-                    return messages_after_welcome
-
-    def _connectClient3(self):
         self.addClient()
         self.sendLine(3, "CAP LS 302")
         self.sendLine(3, "AUTHENTICATE PLAIN")
@@ -61,37 +48,49 @@ class BouncerTestCase(cases.BaseServerTestCase):
         self.sendLine(3, "USER a 0 * a")
         self.sendLine(3, "CAP REQ :server-time message-tags account-tag")
         self.sendLine(3, "CAP END")
+        messages = self.getMessages(3)
+        welcomes = [message for message in messages if message.command == RPL_WELCOME]
+        self.assertEqual(len(welcomes), 1)
         # should see the *same* regburst for testnick
-        messages = self._waitForWelcome(3, "testnick")
+        self.assertMessageMatch(welcomes[0], params=["testnick", ANYSTR])
         joins = [message for message in messages if message.command == "JOIN"]
         # we should be automatically joined to #chan
         self.assertMessageMatch(joins[0], params=["#chan"])
 
-    def _connectClient4(self):
+        # disable multiclient in nickserv
-        # connect a client similar to 3, but without the message-tags and account-tag
+        self.sendLine(3, "NS SET MULTICLIENT OFF")
-        # capabilities, to make sure it does not receive the associated tags
+        self.getMessages(3)
+
         self.addClient()
         self.sendLine(4, "CAP LS 302")
         self.sendLine(4, "AUTHENTICATE PLAIN")
         self.sendLine(4, sasl_plain_blob("testuser", "mypassword"))
         self.sendLine(4, "NICK testnick")
         self.sendLine(4, "USER a 0 * a")
-        self.sendLine(4, "CAP REQ server-time")
+        self.sendLine(4, "CAP REQ :server-time message-tags")
         self.sendLine(4, "CAP END")
-        # should see the *same* regburst for testnick
+        # with multiclient disabled, we should not be able to attach to the nick
-        self._waitForWelcome(4, "testnick")
+        messages = self.getMessages(4)
+        welcomes = [message for message in messages if message.command == RPL_WELCOME]
+        self.assertEqual(len(welcomes), 0)
+        errors = [
+            message for message in messages if message.command == ERR_NICKNAMEINUSE
+        ]
+        self.assertEqual(len(errors), 1)
 
-    @cases.mark_specifications("Ergo", "Sable")
+        self.sendLine(3, "NS SET MULTICLIENT ON")
-    def testAutomaticResumption(self):
+        self.getMessages(3)
-        """Test logging into an account that already has a client joins the client's session"""
+        self.addClient()
-        self._connectClient3()
+        self.sendLine(5, "CAP LS 302")
-
+        self.sendLine(5, "AUTHENTICATE PLAIN")
-    @cases.mark_specifications("Ergo", "Sable")
+        self.sendLine(5, sasl_plain_blob("testuser", "mypassword"))
-    def testChannelMessageFromOther(self):
+        self.sendLine(5, "NICK testnick")
-        """Test that all clients attached to a session get messages sent by someone else
+        self.sendLine(5, "USER a 0 * a")
-        to a channel"""
+        self.sendLine(5, "CAP REQ server-time")
-        self._connectClient3()
+        self.sendLine(5, "CAP END")
-        self._connectClient4()
+        messages = self.getMessages(5)
+        welcomes = [message for message in messages if message.command == RPL_WELCOME]
+        self.assertEqual(len(welcomes), 1)
 
         self.sendLine(1, "@+clientOnlyTag=Value PRIVMSG #chan :hey")
         self.getMessages(1)
@@ -105,84 +104,22 @@ class BouncerTestCase(cases.BaseServerTestCase):
         self.assertEqual(len(messagesforthree), 1)
         messagefortwo = messagesfortwo[0]
         messageforthree = messagesforthree[0]
-        messageforfour = self.getMessage(4)
+        messageforfive = self.getMessage(5)
         self.assertMessageMatch(messagefortwo, params=["#chan", "hey"])
         self.assertMessageMatch(messageforthree, params=["#chan", "hey"])
-        self.assertMessageMatch(messageforfour, params=["#chan", "hey"])
+        self.assertMessageMatch(messageforfive, params=["#chan", "hey"])
         self.assertIn("time", messagefortwo.tags)
         self.assertIn("time", messageforthree.tags)
-        self.assertIn("time", messageforfour.tags)
+        self.assertIn("time", messageforfive.tags)
         # 3 has account-tag
         self.assertIn("account", messageforthree.tags)
         # should get same msgid
         self.assertEqual(messagefortwo.tags["msgid"], messageforthree.tags["msgid"])
-        # 4 only has server-time, shouldn't get account or msgid tags
+        # 5 only has server-time, shouldn't get account or msgid tags
-        self.assertNotIn("account", messageforfour.tags)
+        self.assertNotIn("account", messageforfive.tags)
-        self.assertNotIn("msgid", messageforfour.tags)
+        self.assertNotIn("msgid", messageforfive.tags)
-
-    @cases.mark_specifications("Ergo", "Sable")
-    def testChannelMessageFromSelf(self):
-        """Test that all clients attached to a session get messages sent by an other client
-
-        (TODO: check when the initial sender has echo-message too)"""
-        self._connectClient3()
-        self._connectClient4()
-
-        self.sendLine(2, "@+clientOnlyTag=Value PRIVMSG #chan :hey")
-        messagesfortwo = [
-            msg for msg in self.getMessages(2) if msg.command == "PRIVMSG"
-        ]
-        messagesforone = [
-            msg for msg in self.getMessages(1) if msg.command == "PRIVMSG"
-        ]
-        messagesforthree = [
-            msg for msg in self.getMessages(3) if msg.command == "PRIVMSG"
-        ]
-        self.assertEqual(len(messagesforone), 1)
-        self.assertEqual(len(messagesfortwo), 0)  # echo-message not enabled
-        self.assertEqual(len(messagesforthree), 1)
-        messageforone = messagesforone[0]
-        messageforthree = messagesforthree[0]
-        messageforfour = self.getMessage(4)
-        self.assertMessageMatch(messageforone, params=["#chan", "hey"])
-        self.assertMessageMatch(messageforthree, params=["#chan", "hey"])
-        self.assertMessageMatch(messageforfour, params=["#chan", "hey"])
-        self.assertIn("time", messageforone.tags)
-        self.assertIn("time", messageforthree.tags)
-        self.assertIn("time", messageforfour.tags)
-        # 3 has account-tag
-        self.assertIn("account", messageforthree.tags)
-        # should get same msgid
-        self.assertEqual(messageforone.tags["msgid"], messageforthree.tags["msgid"])
-        # 4 only has server-time, shouldn't get account or msgid tags
-        self.assertNotIn("account", messageforfour.tags)
-        self.assertNotIn("msgid", messageforfour.tags)
-
-    @cases.mark_specifications("Ergo", "Sable")
-    def testDirectMessageFromOther(self):
-        """Test that all clients attached to a session get copies of messages sent
-        by an other client of that session directly to an other user"""
-        self._connectClient3()
-        self._connectClient4()
-
-        self.sendLine(1, "PRIVMSG testnick :this is a direct message")
-        self.getMessages(1)
-        messagefortwo = [
-            msg for msg in self.getMessages(2) if msg.command == "PRIVMSG"
-        ][0]
-        messageforthree = [
-            msg for msg in self.getMessages(3) if msg.command == "PRIVMSG"
-        ][0]
-        self.assertEqual(messagefortwo.params, messageforthree.params)
-        self.assertEqual(messagefortwo.tags["msgid"], messageforthree.tags["msgid"])
-
-    @cases.mark_specifications("Ergo", "Sable")
-    def testDirectMessageFromSelf(self):
-        """Test that all clients attached to a session get copies of messages sent
-        by an other client of that session directly to an other user"""
-        self._connectClient3()
-        self._connectClient4()
 
+        # test that copies of sent messages go out to other sessions
         self.sendLine(2, "PRIVMSG observer :this is a direct message")
         self.getMessages(2)
         messageForRecipient = [
@@ -196,20 +133,10 @@ class BouncerTestCase(cases.BaseServerTestCase):
             messageForRecipient.tags["msgid"], copyForOtherSession.tags["msgid"]
         )
 
-    @cases.mark_specifications("Ergo", "Sable")
-    def testQuit(self):
-        """Test that a single client of a session does not make the whole user quit
-        (and is generally not visible to anyone else, not even their other sessions),
-        until the last client quits"""
-        self._connectClient3()
-        self._connectClient4()
         self.sendLine(2, "QUIT :two out")
-        quitLines = [
+        quitLines = [msg for msg in self.getMessages(2) if msg.command == "QUIT"]
-            msg for msg in self.getMessages(2) if msg.command in ("QUIT", "ERROR")
-        ]
         self.assertEqual(len(quitLines), 1)
-        if quitLines[0].command == "QUIT":
+        self.assertMessageMatch(quitLines[0], params=[StrRe(".*two out.*")])
-            self.assertMessageMatch(quitLines[0], params=[StrRe(".*two out.*")])
         # neither the observer nor the other attached session should see a quit here
         quitLines = [msg for msg in self.getMessages(1) if msg.command == "QUIT"]
         self.assertEqual(quitLines, [])
@@ -227,39 +154,13 @@ class BouncerTestCase(cases.BaseServerTestCase):
             messagesforthree[0], command="PRIVMSG", params=["#chan", "hey again"]
         )
 
-        self.sendLine(4, "QUIT :four out")
+        self.sendLine(5, "QUIT :five out")
-        self.getMessages(4)
+        self.getMessages(5)
         self.sendLine(3, "QUIT :three out")
-        quitLines = [
+        quitLines = [msg for msg in self.getMessages(3) if msg.command == "QUIT"]
-            msg for msg in self.getMessages(3) if msg.command in ("QUIT", "ERROR")
-        ]
         self.assertEqual(len(quitLines), 1)
-        if quitLines[0].command == "QUIT":
+        self.assertMessageMatch(quitLines[0], params=[StrRe(".*three out.*")])
-            self.assertMessageMatch(quitLines[0], params=[StrRe(".*three out.*")])
         # observer should see *this* quit
         quitLines = [msg for msg in self.getMessages(1) if msg.command == "QUIT"]
         self.assertEqual(len(quitLines), 1)
         self.assertMessageMatch(quitLines[0], params=[StrRe(".*three out.*")])
-
-    @cases.mark_specifications("Ergo")
-    def testDisableAutomaticResumption(self):
-        # disable multiclient in nickserv
-        self.sendLine(2, "NS SET MULTICLIENT OFF")
-        self.getMessages(2)
-
-        self.addClient()
-        self.sendLine(3, "CAP LS 302")
-        self.sendLine(3, "AUTHENTICATE PLAIN")
-        self.sendLine(3, sasl_plain_blob("testuser", "mypassword"))
-        self.sendLine(3, "NICK testnick")
-        self.sendLine(3, "USER a 0 * a")
-        self.sendLine(3, "CAP REQ :server-time message-tags")
-        self.sendLine(3, "CAP END")
-        # with multiclient disabled, we should not be able to attach to the nick
-        messages = self.getMessages(3)
-        welcomes = [message for message in messages if message.command == RPL_WELCOME]
-        self.assertEqual(len(welcomes), 0)
-        errors = [
-            message for message in messages if message.command == ERR_NICKNAMEINUSE
-        ]
-        self.assertEqual(len(errors), 1)

irctest/server_tests/chathistory.py

@@ -2,6 +2,7 @@
 `IRCv3 draft chathistory <https://ircv3.net/specs/extensions/chathistory>`_
 """
 
+import dataclasses
 import functools
 import secrets
 import time
@@ -31,10 +32,22 @@ def skip_ngircd(f):
     return newf
 
 
-@cases.mark_specifications("IRCv3")
+class _BaseChathistoryTests(cases.BaseServerTestCase):
-@cases.mark_services
+    def _wait_before_chathistory(self):
-class ChathistoryTestCase(cases.BaseServerTestCase):
+        """Hook for the Sable-specific tests that check the postgresql-based
-    def validate_chathistory_batch(self, msgs, target):
+        CHATHISTORY implementation is sound. This implementation only kicks in
+        after the in-memory history is cleared, which happens after a 5 min timeout;
+        and this gives a chance to :class:``SablePostgresqlHistoryTestCase`` to
+        wait this timeout.
+
+        For other tests, this does nothing.
+        """
+        raise NotImplementedError("_BaseChathistoryTests._wait_before_chathistory")
+
+    def validate_chathistory_batch(self, user, target):
+        # may need to try again for Sable, as it has a pretty high latency here
+        while not (msgs := self.getMessages(user)):
+            pass
         (start, *inner_msgs, end) = msgs
 
         self.assertMessageMatch(
@@ -94,9 +107,13 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
         self.joinChannel(qux, real_chname)
         self.getMessages(qux)
 
+        self._wait_before_chathistory()
+
         # test a nonexistent channel
         self.sendLine(bar, "CHATHISTORY LATEST #nonexistent_channel * 10")
-        msgs = self.getMessages(bar)
+        while not (msgs := self.getMessages(bar)):
+            # need to retry when Sable has the history server on
+            pass
         msgs = [msg for msg in msgs if msg.command != "MODE"]  # :NickServ MODE +r
         self.assertMessageMatch(
             msgs[0],
@@ -106,7 +123,9 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
 
         # as should a real channel to which one is not joined:
         self.sendLine(bar, "CHATHISTORY LATEST %s * 10" % (real_chname,))
-        msgs = self.getMessages(bar)
+        while not (msgs := self.getMessages(bar)):
+            # need to retry when Sable has the history server on
+            pass
         self.assertMessageMatch(
             msgs[0],
             command="FAIL",
@@ -175,6 +194,8 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
         messages.append(echo.to_history_message())
         self.assertEqual(echo.to_history_message(), delivery.to_history_message())
 
+        self._wait_before_chathistory()
+
         self.sendLine(bar, "CHATHISTORY LATEST %s * 10" % (bar,))
         replies = [msg for msg in self.getMessages(bar) if msg.command == "PRIVMSG"]
         self.assertEqual([msg.to_history_message() for msg in replies], messages)
@@ -225,9 +246,12 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
             echo_messages.extend(
                 msg.to_history_message() for msg in self.getMessages(1)
             )
-            time.sleep(0.002)
+            time.sleep(0.02)
 
         self.validate_echo_messages(NUM_MESSAGES, echo_messages)
+
+        self._wait_before_chathistory()
+
         self.validate_chathistory(subcommand, echo_messages, 1, chname)
 
     @skip_ngircd
@@ -264,6 +288,8 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
             )
             time.sleep(0.002)
 
+        self._wait_before_chathistory()
+
         self.validate_echo_messages(NUM_MESSAGES, echo_messages)
         self.sendLine(1, "CHATHISTORY LATEST %s * 100" % chname)
         (batch_open, *messages, batch_close) = self.getMessages(1)
@@ -308,6 +334,9 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
             time.sleep(0.002)
 
         self.validate_echo_messages(NUM_MESSAGES * 2, echo_messages)
+
+        self._wait_before_chathistory()
+
         self.validate_chathistory(subcommand, echo_messages, 1, chname)
 
     @pytest.mark.parametrize("subcommand", SUBCOMMANDS)
@@ -367,6 +396,9 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
         self.getMessages(2)
 
         self.validate_echo_messages(NUM_MESSAGES, echo_messages)
+
+        self._wait_before_chathistory()
+
         self.validate_chathistory(subcommand, echo_messages, 1, c2)
         self.validate_chathistory(subcommand, echo_messages, 2, c1)
 
@@ -415,6 +447,8 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
         ]
         self.assertEqual(results, new_convo)
 
+        self._wait_before_chathistory()
+
         # additional messages with c3 should not show up in the c1-c2 history:
         self.validate_chathistory(subcommand, echo_messages, 1, c2)
         self.validate_chathistory(subcommand, echo_messages, 2, c1)
@@ -459,15 +493,15 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
     def _validate_chathistory_LATEST(self, echo_messages, user, chname):
         INCLUSIVE_LIMIT = len(echo_messages) * 2
         self.sendLine(user, "CHATHISTORY LATEST %s * %d" % (chname, INCLUSIVE_LIMIT))
-        result = self.validate_chathistory_batch(self.getMessages(user), chname)
+        result = self.validate_chathistory_batch(user, chname)
         self.assertEqual(echo_messages, result)
 
         self.sendLine(user, "CHATHISTORY LATEST %s * %d" % (chname, 5))
-        result = self.validate_chathistory_batch(self.getMessages(user), chname)
+        result = self.validate_chathistory_batch(user, chname)
         self.assertEqual(echo_messages[-5:], result)
 
         self.sendLine(user, "CHATHISTORY LATEST %s * %d" % (chname, 1))
-        result = self.validate_chathistory_batch(self.getMessages(user), chname)
+        result = self.validate_chathistory_batch(user, chname)
         self.assertEqual(echo_messages[-1:], result)
 
         if self._supports_msgid():
@@ -476,7 +510,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                 "CHATHISTORY LATEST %s msgid=%s %d"
                 % (chname, echo_messages[4].msgid, INCLUSIVE_LIMIT),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[5:], result)
 
         if self._supports_timestamp():
@@ -485,7 +519,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                 "CHATHISTORY LATEST %s timestamp=%s %d"
                 % (chname, echo_messages[4].time, INCLUSIVE_LIMIT),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[5:], result)
 
     def _validate_chathistory_BEFORE(self, echo_messages, user, chname):
@@ -496,7 +530,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                 "CHATHISTORY BEFORE %s msgid=%s %d"
                 % (chname, echo_messages[6].msgid, INCLUSIVE_LIMIT),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[:6], result)
 
         if self._supports_timestamp():
@@ -505,7 +539,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                 "CHATHISTORY BEFORE %s timestamp=%s %d"
                 % (chname, echo_messages[6].time, INCLUSIVE_LIMIT),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[:6], result)
 
             self.sendLine(
@@ -513,7 +547,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                 "CHATHISTORY BEFORE %s timestamp=%s %d"
                 % (chname, echo_messages[6].time, 2),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[4:6], result)
 
     def _validate_chathistory_AFTER(self, echo_messages, user, chname):
@@ -524,7 +558,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                 "CHATHISTORY AFTER %s msgid=%s %d"
                 % (chname, echo_messages[3].msgid, INCLUSIVE_LIMIT),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[4:], result)
 
         if self._supports_timestamp():
@@ -533,7 +567,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                 "CHATHISTORY AFTER %s timestamp=%s %d"
                 % (chname, echo_messages[3].time, INCLUSIVE_LIMIT),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[4:], result)
 
             self.sendLine(
@@ -541,7 +575,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                 "CHATHISTORY AFTER %s timestamp=%s %d"
                 % (chname, echo_messages[3].time, 3),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[4:7], result)
 
     def _validate_chathistory_BETWEEN(self, echo_messages, user, chname):
@@ -558,7 +592,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                     INCLUSIVE_LIMIT,
                 ),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[1:-1], result)
 
             self.sendLine(
@@ -571,7 +605,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                     INCLUSIVE_LIMIT,
                 ),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[1:-1], result)
 
             # BETWEEN forwards and backwards with a limit, should get
@@ -581,7 +615,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                 "CHATHISTORY BETWEEN %s msgid=%s msgid=%s %d"
                 % (chname, echo_messages[0].msgid, echo_messages[-1].msgid, 3),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[1:4], result)
 
             self.sendLine(
@@ -589,7 +623,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                 "CHATHISTORY BETWEEN %s msgid=%s msgid=%s %d"
                 % (chname, echo_messages[-1].msgid, echo_messages[0].msgid, 3),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[-4:-1], result)
 
         if self._supports_timestamp():
@@ -604,7 +638,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                     INCLUSIVE_LIMIT,
                 ),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[1:-1], result)
             self.sendLine(
                 user,
@@ -616,21 +650,21 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                     INCLUSIVE_LIMIT,
                 ),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[1:-1], result)
             self.sendLine(
                 user,
                 "CHATHISTORY BETWEEN %s timestamp=%s timestamp=%s %d"
                 % (chname, echo_messages[0].time, echo_messages[-1].time, 3),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[1:4], result)
             self.sendLine(
                 user,
                 "CHATHISTORY BETWEEN %s timestamp=%s timestamp=%s %d"
                 % (chname, echo_messages[-1].time, echo_messages[0].time, 3),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[-4:-1], result)
 
     def _validate_chathistory_AROUND(self, echo_messages, user, chname):
@@ -640,7 +674,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                 "CHATHISTORY AROUND %s msgid=%s %d"
                 % (chname, echo_messages[7].msgid, 1),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual([echo_messages[7]], result)
 
             self.sendLine(
@@ -648,7 +682,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                 "CHATHISTORY AROUND %s msgid=%s %d"
                 % (chname, echo_messages[7].msgid, 3),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertEqual(echo_messages[6:9], result)
 
         if self._supports_timestamp():
@@ -657,7 +691,7 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
                 "CHATHISTORY AROUND %s timestamp=%s %d"
                 % (chname, echo_messages[7].time, 3),
             )
-            result = self.validate_chathistory_batch(self.getMessages(user), chname)
+            result = self.validate_chathistory_batch(user, chname)
             self.assertIn(echo_messages[7], result)
 
     @pytest.mark.arbitrary_client_tags
@@ -718,6 +752,8 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
         self.assertEqual(len(relay), 1)
         validate_tagmsg(relay[0], chname, msgid)
 
+        self._wait_before_chathistory()
+
         self.sendLine(1, "CHATHISTORY LATEST %s * 10" % (chname,))
         history_tagmsgs = [
             msg for msg in self.getMessages(1) if msg.command == "TAGMSG"
@@ -814,8 +850,95 @@ class ChathistoryTestCase(cases.BaseServerTestCase):
         validate_msg(relay)
 
 
+@cases.mark_specifications("IRCv3")
+@cases.mark_services
+class ChathistoryTestCase(_BaseChathistoryTests):
+    def _wait_before_chathistory(self):
+        """does nothing"""
+        pass
+
+
 assert {f"_validate_chathistory_{cmd}" for cmd in SUBCOMMANDS} == {
     meth_name
     for meth_name in dir(ChathistoryTestCase)
     if meth_name.startswith("_validate_chathistory_")
 }, "ChathistoryTestCase.validate_chathistory and SUBCOMMANDS are out of sync"
+
+
+@cases.mark_specifications("Sable")
+@cases.mark_services
+class SablePostgresqlHistoryTestCase(_BaseChathistoryTests):
+    # for every wall clock second, 15 seconds pass for the server.
+    # at x30, links between nodes timeout.
+    faketime = "+1y x15"
+
+    @staticmethod
+    def config() -> cases.TestCaseControllerConfig:
+        return dataclasses.replace(  # type: ignore[no-any-return]
+            _BaseChathistoryTests.config(),
+            sable_history_server=True,
+        )
+
+    def _wait_before_chathistory(self):
+        """waits 6 seconds which appears to be a 1.5 min to Sable; which goes over
+        the 1 min timeout for in-memory history (+ 1 min because the cleanup job
+        only runs every min)"""
+        assert self.controller.faketime_enabled, "faketime is not installed"
+        time.sleep(8)
+
+
+@cases.mark_specifications("Sable")
+@cases.mark_services
+class SableExpiringHistoryTestCase(cases.BaseServerTestCase):
+    faketime = "+1y x15"
+
+    def _wait_before_chathistory(self):
+        """waits 6 seconds which appears to be a 1.5 min to Sable; which goes over
+        the 1 min timeout for in-memory history (+ 1 min because the cleanup job
+        only runs every min)"""
+        assert self.controller.faketime_enabled, "faketime is not installed"
+        time.sleep(8)
+
+    def testChathistoryExpired(self):
+        """Checks that Sable forgets about messages if the history server is not available"""
+        self.connectClient(
+            "bar",
+            capabilities=[
+                "message-tags",
+                "server-time",
+                "echo-message",
+                "batch",
+                "labeled-response",
+                "sasl",
+                CHATHISTORY_CAP,
+            ],
+            skip_if_cap_nak=True,
+        )
+        chname = "#chan" + secrets.token_hex(12)
+        self.joinChannel(1, chname)
+        self.getMessages(1)
+        self.getMessages(1)
+
+        self.sendLine(1, f"PRIVMSG {chname} :this is a message")
+        self.getMessages(1)
+
+        self._wait_before_chathistory()
+
+        self.sendLine(1, f"CHATHISTORY LATEST {chname} * 10")
+
+        while not (messages := self.getMessages(1)):
+            # Sable processes CHATHISTORY asynchronously, which can be pretty slow as it
+            # sends cross-server requests. This means we can't just rely on a PING-PONG
+            # or the usual time.sleep(self.controller.sync_sleep_time) to make sure
+            # the ircd replied to us
+            time.sleep(self.controller.sync_sleep_time)
+
+        (start, *middle, end) = messages
+        self.assertMessageMatch(
+            start, command="BATCH", params=[StrRe(r"\+.*"), "chathistory", chname]
+        )
+        batch_tag = start.params[0][1:]
+        self.assertMessageMatch(end, command="BATCH", params=["-" + batch_tag])
+        self.assertEqual(
+            len(middle), 0, f"Got messages that should be expired: {middle}"
+        )

irctest/server_tests/kill.py

@@ -1,67 +0,0 @@
-"""
-The KILL command  (`Modern <https://modern.ircdocs.horse/#kill-message>`__)
-"""
-
-
-from irctest import cases
-from irctest.numerics import ERR_NOPRIVILEGES, RPL_YOUREOPER
-
-
-class KillTestCase(cases.BaseServerTestCase):
-    @cases.mark_specifications("Modern")
-    @cases.xfailIfSoftware(["Sable"], "https://github.com/Libera-Chat/sable/issues/154")
-    def testKill(self):
-        self.connectClient("ircop", name="ircop")
-        self.connectClient("alice", name="alice")
-        self.connectClient("bob", name="bob")
-
-        self.sendLine("ircop", "OPER operuser operpassword")
-        self.assertIn(
-            RPL_YOUREOPER,
-            [m.command for m in self.getMessages("ircop")],
-            fail_msg="OPER failed",
-        )
-
-        self.sendLine("alice", "KILL bob :some arbitrary reason")
-        self.assertIn(
-            ERR_NOPRIVILEGES,
-            [m.command for m in self.getMessages("alice")],
-            fail_msg="unprivileged KILL not rejected",
-        )
-        # bob is not killed
-        self.getMessages("bob")
-
-        self.sendLine("alice", "KILL alice :some arbitrary reason")
-        self.assertIn(
-            ERR_NOPRIVILEGES,
-            [m.command for m in self.getMessages("alice")],
-            fail_msg="unprivileged KILL not rejected",
-        )
-        # alice is not killed
-        self.getMessages("alice")
-
-        # privileged KILL should succeed
-        self.sendLine("ircop", "KILL alice :some arbitrary reason")
-        self.getMessages("ircop")
-        self.assertDisconnected("alice")
-
-        self.sendLine("ircop", "KILL bob :some arbitrary reason")
-        self.getMessages("ircop")
-        self.assertDisconnected("bob")
-
-    @cases.mark_specifications("Ergo")
-    def testKillOneArgument(self):
-        self.connectClient("ircop", name="ircop")
-        self.connectClient("alice", name="alice")
-
-        self.sendLine("ircop", "OPER operuser operpassword")
-        self.assertIn(
-            RPL_YOUREOPER,
-            [m.command for m in self.getMessages("ircop")],
-            fail_msg="OPER failed",
-        )
-
-        # 1-argument kill command, accepted by Ergo and some implementations
-        self.sendLine("ircop", "KILL alice")
-        self.getMessages("ircop")
-        self.assertDisconnected("alice")

irctest/server_tests/links.py

@@ -3,13 +3,6 @@ from irctest.numerics import ERR_UNKNOWNCOMMAND, RPL_ENDOFLINKS, RPL_LINKS
 from irctest.patma import ANYSTR, StrRe
 
 
-def _server_info_regexp(case: cases.BaseServerTestCase) -> str:
-    if case.controller.software_name == "Sable":
-        return ".+"
-    else:
-        return "test server"
-
-
 class LinksTestCase(cases.BaseServerTestCase):
     @cases.mark_specifications("RFC1459", "RFC2812", "Modern")
     def testLinksSingleServer(self):
@@ -63,7 +56,7 @@ class LinksTestCase(cases.BaseServerTestCase):
                 "nick",
                 "My.Little.Server",
                 "My.Little.Server",
-                StrRe(f"0 (0042 )?{_server_info_regexp(self)}"),
+                StrRe("0 (0042 )?test server"),
             ],
         )
 
@@ -117,7 +110,7 @@ class ServicesLinksTestCase(cases.BaseServerTestCase):
             # This server redacts links
             return
 
-        messages.sort(key=lambda m: tuple(m.params))
+        messages.sort(key=lambda m: m.params[-1])
 
         self.assertMessageMatch(
             messages.pop(0),
@@ -126,7 +119,7 @@ class ServicesLinksTestCase(cases.BaseServerTestCase):
                 "nick",
                 "My.Little.Server",
                 "My.Little.Server",
-                StrRe(f"0 (0042 )?{_server_info_regexp(self)}"),
+                StrRe("0 (0042 )?test server"),
             ],
         )
         self.assertMessageMatch(
@@ -134,9 +127,9 @@ class ServicesLinksTestCase(cases.BaseServerTestCase):
             command=RPL_LINKS,
             params=[
                 "nick",
-                "My.Little.Services",
+                "services.example.org",
                 "My.Little.Server",
-                StrRe("[01] .+"),  # SID instead of description for Anope...
+                StrRe("1 .+"),  # SID instead of description for Anope...
             ],
         )
 

irctest/specifications.py

@@ -9,7 +9,7 @@ class Specifications(enum.Enum):
     RFC2812 = "RFC2812"
     IRCv3 = "IRCv3"  # Mark with capabilities whenever possible
     Ergo = "Ergo"
-    SABLE = "Sable"
+    Sable = "Sable"
 
     Ircdocs = "ircdocs"
     """Any document on ircdocs.horse (especially defs.ircdocs.horse),
@@ -25,6 +25,9 @@ class Specifications(enum.Enum):
                 return spec
         raise ValueError(name)
 
+    def is_implementation_specific(self) -> bool:
+        return self in (Specifications.Ergo, Specifications.Sable)
+
 
 @enum.unique
 class Capabilities(enum.Enum):

mypy.ini

@@ -1,5 +1,5 @@
 [mypy]
-python_version = 3.9
+python_version = 3.8
 warn_return_any = True
 warn_unused_configs = True
 

pytest.ini

@@ -7,6 +7,10 @@ markers =
     IRCv3
     modern
     ircdocs
+
+    # implementations for which we have specific test get two markers:
+    # the implementation name and 'implementation-specific'
+    implementation-specific
     Ergo
     Sable
 

workflows.yml

@@ -33,9 +33,6 @@ software:
             devel: "8.2.x"
             devel_release: null
         path: ircd-hybrid
-        pre_deps:
-            - name: "Install system dependencies"
-              run: "sudo apt-get install atheme-services faketime libjansson-dev"
         separate_build_job: true
         build_script: |
             cd $GITHUB_WORKSPACE/ircd-hybrid/
@@ -139,7 +136,7 @@ software:
         pre_deps:
             - uses: actions/setup-go@v3
               with:
-                  go-version: '^1.24.0'
+                  go-version: '^1.23.0'
             - run: go version
         separate_build_job: false
         build_script: |
@@ -252,7 +249,7 @@ software:
         name: Sable
         repository: Libera-Chat/sable
         refs:
-            stable: baed3ef9ac4550dc36a45b758436769e82e8ec58
+            stable: 034c4d5dd937774099773238d8d5b8054b015607
             release: null
             devel: master
             devel_release: null
@@ -271,6 +268,9 @@ software:
                 workspaces: "sable -> target"
                 cache-on-failure: true
             - run: rustc --version
+            - run: start postgresql
+              run: "sudo systemctl start postgresql.service"
+        env: "IRCTEST_POSTGRESQL_URL=postgresql://localhost IRCTEST_DEBUG_LOGS=1"
         separate_build_job: false
         build_script: |
             cd $GITHUB_WORKSPACE/sable/