feat: tim version config flag

synapse/config/homeserver.py

@@ -59,6 +59,7 @@
 from .sso import SSOConfig
 from .stats import StatsConfig
 from .third_party_event_rules import ThirdPartyRulesConfig
+from .tim import TimConfig
 from .tls import TlsConfig
 from .tracer import TracerConfig
 from .user_directory import UserDirectoryConfig
@@ -117,6 +118,7 @@ class HomeServerConfig(RootConfig):
         BackgroundUpdateConfig,
         AutoAcceptInvitesConfig,
         UserTypesConfig,
+        TimConfig,
         # This must be last, as it checks for conflicts with other config options.
         MasConfig,
     ]

synapse/config/tim.py

@@ -0,0 +1,38 @@
+#
+# This file is licensed under the Affero General Public License (AGPL) version 3.
+#
+# Copyright (C) 2026 Famedly GmbH
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU Affero General Public License as
+# published by the Free Software Foundation, either version 3 of the
+# License, or (at your option) any later version.
+#
+# See the GNU Affero General Public License for more details:
+# <https://www.gnu.org/licenses/agpl-3.0.html>.
+#
+
+from typing import Any
+
+from synapse.config._base import Config, ConfigError
+from synapse.types import JsonDict
+
+VALID_TIM_VERSIONS = ("1.1", "1.2")
+
+
+class TimConfig(Config):
+    """Config section for TIM-specific settings."""
+
+    section = "tim"
+
+    def read_config(self, config: JsonDict, **kwargs: Any) -> None:
+        tim_version = config.get("tim_version", "1.1")
+
+        if tim_version not in VALID_TIM_VERSIONS:
+            raise ConfigError(
+                f"tim_version must be one of {', '.join(VALID_TIM_VERSIONS)}, "
+                f"got {tim_version!r}",
+                ("tim_version",),
+            )
+
+        self.tim_version: str = tim_version

tests/config/test_tim.py

@@ -0,0 +1,57 @@
+#
+# This file is licensed under the Affero General Public License (AGPL) version 3.
+#
+# Copyright (C) 2026 Famedly GmbH
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU Affero General Public License as
+# published by the Free Software Foundation, either version 3 of the
+# License, or (at your option) any later version.
+#
+# See the GNU Affero General Public License for more details:
+# <https://www.gnu.org/licenses/agpl-3.0.html>.
+#
+
+from synapse.config import ConfigError
+from synapse.config.homeserver import HomeServerConfig
+
+from tests.unittest import TestCase
+from tests.utils import default_config
+
+
+class TimConfigTestCase(TestCase):
+    def _parse_config(self, extra: dict) -> HomeServerConfig:
+        config_dict = {**default_config("test"), **extra}
+        config = HomeServerConfig()
+        config.parse_config_dict(config_dict, "", "")
+        return config
+
+    def test_default_tim_version(self) -> None:
+        """tim_version defaults to '1.1' when not set."""
+        config = self._parse_config({})
+        self.assertEqual(config.tim.tim_version, "1.1")
+
+    def test_tim_version_1_1(self) -> None:
+        """tim_version can be explicitly set to '1.1'."""
+        config = self._parse_config({"tim_version": "1.1"})
+        self.assertEqual(config.tim.tim_version, "1.1")
+
+    def test_tim_version_1_2(self) -> None:
+        """tim_version can be set to '1.2'."""
+        config = self._parse_config({"tim_version": "1.2"})
+        self.assertEqual(config.tim.tim_version, "1.2")
+
+    def test_invalid_tim_version_rejected(self) -> None:
+        """An invalid tim_version should raise ConfigError."""
+        with self.assertRaises(ConfigError):
+            self._parse_config({"tim_version": "2.0"})
+
+    def test_invalid_tim_version_string(self) -> None:
+        """A non-version string should raise ConfigError."""
+        with self.assertRaises(ConfigError):
+            self._parse_config({"tim_version": "invalid"})
+
+    def test_invalid_tim_version_numeric(self) -> None:
+        """A numeric (non-string) tim_version should raise ConfigError."""
+        with self.assertRaises(ConfigError):
+            self._parse_config({"tim_version": 1.1})

tests/utils.py

@@ -66,6 +66,9 @@
 # DB to disk and query it with the sqlite CLI.
 SQLITE_PERSIST_DB = os.environ.get("SYNAPSE_TEST_PERSIST_SQLITE_DB") is not None
 
+# Defaults to 1.1
+TIM_VERSION_FOR_TESTS = os.environ.get("SYNAPSE_TIM_VERSION", "1.1")
+
 # the dbname we will connect to in order to create the base database.
 POSTGRES_DBNAME_FOR_INITIAL_CREATE = "postgres"
 
@@ -219,6 +222,7 @@ def default_config(
         "update_user_directory_from_worker": "does_not_exist_worker_name",
         "caches": {"global_factor": 1, "sync_response_cache_duration": 0},
         "listeners": [{"port": 0, "type": "http"}],
+        "tim_version": TIM_VERSION_FOR_TESTS,
     }
 
     if parse: