Fix a bug with saml attribute maps.
Fixes a bug where the default attribute maps were prioritised over user-specified ones, resulting in incorrect mappings. The problem is that if you call SPConfig.load() multiple times, it adds new attribute mappers to a list. So by calling it with the default config first, and then the user-specified config, we would always get the default mappers before the user-specified mappers. To solve this, let's merge the config dicts first, and then pass them to SPConfig.
This commit is contained in:
parent
74fb729213
commit
b74606ea22
|
@ -0,0 +1 @@
|
||||||
|
Fix a bug which caused SAML attribute maps to be overridden by defaults.
|
|
@ -1,5 +1,6 @@
|
||||||
# -*- coding: utf-8 -*-
|
# -*- coding: utf-8 -*-
|
||||||
# Copyright 2018 New Vector Ltd
|
# Copyright 2018 New Vector Ltd
|
||||||
|
# Copyright 2019 The Matrix.org Foundation C.I.C.
|
||||||
#
|
#
|
||||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
||||||
# you may not use this file except in compliance with the License.
|
# you may not use this file except in compliance with the License.
|
||||||
|
@ -12,11 +13,29 @@
|
||||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
# See the License for the specific language governing permissions and
|
# See the License for the specific language governing permissions and
|
||||||
# limitations under the License.
|
# limitations under the License.
|
||||||
|
|
||||||
from synapse.python_dependencies import DependencyException, check_requirements
|
from synapse.python_dependencies import DependencyException, check_requirements
|
||||||
|
from synapse.util.module_loader import load_python_module
|
||||||
|
|
||||||
from ._base import Config, ConfigError
|
from ._base import Config, ConfigError
|
||||||
|
|
||||||
|
|
||||||
|
def _dict_merge(merge_dict, into_dct):
|
||||||
|
for k, v in merge_dict.items():
|
||||||
|
if k not in into_dct:
|
||||||
|
into_dct[k] = v
|
||||||
|
continue
|
||||||
|
|
||||||
|
current_val = into_dct[k]
|
||||||
|
|
||||||
|
if isinstance(v, dict) and isinstance(current_val, dict):
|
||||||
|
_dict_merge(v, current_val)
|
||||||
|
continue
|
||||||
|
|
||||||
|
# otherwise we just overwrite
|
||||||
|
into_dct[k] = v
|
||||||
|
|
||||||
|
|
||||||
class SAML2Config(Config):
|
class SAML2Config(Config):
|
||||||
def read_config(self, config, **kwargs):
|
def read_config(self, config, **kwargs):
|
||||||
self.saml2_enabled = False
|
self.saml2_enabled = False
|
||||||
|
@ -33,15 +52,18 @@ class SAML2Config(Config):
|
||||||
|
|
||||||
self.saml2_enabled = True
|
self.saml2_enabled = True
|
||||||
|
|
||||||
import saml2.config
|
saml2_config_dict = self._default_saml_config_dict()
|
||||||
|
_dict_merge(saml2_config.get("sp_config", {}), saml2_config_dict)
|
||||||
self.saml2_sp_config = saml2.config.SPConfig()
|
|
||||||
self.saml2_sp_config.load(self._default_saml_config_dict())
|
|
||||||
self.saml2_sp_config.load(saml2_config.get("sp_config", {}))
|
|
||||||
|
|
||||||
config_path = saml2_config.get("config_path", None)
|
config_path = saml2_config.get("config_path", None)
|
||||||
if config_path is not None:
|
if config_path is not None:
|
||||||
self.saml2_sp_config.load_file(config_path)
|
mod = load_python_module(config_path)
|
||||||
|
_dict_merge(mod.CONFIG, saml2_config_dict)
|
||||||
|
|
||||||
|
import saml2.config
|
||||||
|
|
||||||
|
self.saml2_sp_config = saml2.config.SPConfig()
|
||||||
|
self.saml2_sp_config.load(saml2_config_dict)
|
||||||
|
|
||||||
# session lifetime: in milliseconds
|
# session lifetime: in milliseconds
|
||||||
self.saml2_session_lifetime = self.parse_duration(
|
self.saml2_session_lifetime = self.parse_duration(
|
||||||
|
|
|
@ -14,12 +14,13 @@
|
||||||
# limitations under the License.
|
# limitations under the License.
|
||||||
|
|
||||||
import importlib
|
import importlib
|
||||||
|
import importlib.util
|
||||||
|
|
||||||
from synapse.config._base import ConfigError
|
from synapse.config._base import ConfigError
|
||||||
|
|
||||||
|
|
||||||
def load_module(provider):
|
def load_module(provider):
|
||||||
""" Loads a module with its config
|
""" Loads a synapse module with its config
|
||||||
Take a dict with keys 'module' (the module name) and 'config'
|
Take a dict with keys 'module' (the module name) and 'config'
|
||||||
(the config dict).
|
(the config dict).
|
||||||
|
|
||||||
|
@ -38,3 +39,20 @@ def load_module(provider):
|
||||||
raise ConfigError("Failed to parse config for %r: %r" % (provider["module"], e))
|
raise ConfigError("Failed to parse config for %r: %r" % (provider["module"], e))
|
||||||
|
|
||||||
return provider_class, provider_config
|
return provider_class, provider_config
|
||||||
|
|
||||||
|
|
||||||
|
def load_python_module(location: str):
|
||||||
|
"""Load a python module, and return a reference to its global namespace
|
||||||
|
|
||||||
|
Args:
|
||||||
|
location (str): path to the module
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
python module object
|
||||||
|
"""
|
||||||
|
spec = importlib.util.spec_from_file_location(location, location)
|
||||||
|
if spec is None:
|
||||||
|
raise Exception("Unable to load module at %s" % (location,))
|
||||||
|
mod = importlib.util.module_from_spec(spec)
|
||||||
|
spec.loader.exec_module(mod)
|
||||||
|
return mod
|
||||||
|
|
Loading…
Reference in New Issue