summary refs log tree commit diff
path: root/synapse/events
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2020-03-16 15:44:53 +0000
committerAndrew Morgan <andrew@amorgan.xyz>2020-03-16 15:44:53 +0000
commit2c80ae77a4a9f5bbb7fa4c03248307bb1944c287 (patch)
tree70227152ac2eaead8734437e9956eab7f4f897ca /synapse/events
parentMerge pull request #6307 from matrix-org/erikj/fix_purge_room (diff)
parentExpose some homeserver functionality to spam checkers (#6259) (diff)
downloadsynapse-2c80ae77a4a9f5bbb7fa4c03248307bb1944c287.tar.xz
Expose some homeserver functionality to spam checkers (#6259)
* commit '3a74c03ff':
  Expose some homeserver functionality to spam checkers (#6259)
Diffstat (limited to 'synapse/events')
-rw-r--r--synapse/events/spamcheck.py14
1 files changed, 13 insertions, 1 deletions
diff --git a/synapse/events/spamcheck.py b/synapse/events/spamcheck.py
index f0de4d961f..b7a31c9a7d 100644
--- a/synapse/events/spamcheck.py
+++ b/synapse/events/spamcheck.py
@@ -1,5 +1,6 @@
 # -*- coding: utf-8 -*-
 # Copyright 2017 New Vector Ltd
+# Copyright 2019 The Matrix.org Foundation C.I.C.
 #
 # Licensed under the Apache License, Version 2.0 (the "License");
 # you may not use this file except in compliance with the License.
@@ -13,6 +14,10 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+import inspect
+
+from synapse.spam_checker_api import SpamCheckerApi
+
 
 class SpamChecker(object):
     def __init__(self, hs):
@@ -26,7 +31,14 @@ class SpamChecker(object):
             pass
 
         if module is not None:
-            self.spam_checker = module(config=config)
+            # Older spam checkers don't accept the `api` argument, so we
+            # try and detect support.
+            spam_args = inspect.getfullargspec(module)
+            if "api" in spam_args.args:
+                api = SpamCheckerApi(hs)
+                self.spam_checker = module(config=config, api=api)
+            else:
+                self.spam_checker = module(config=config)
 
     def check_event_for_spam(self, event):
         """Checks if a given event is considered "spammy" by this server.