summaryrefslogtreecommitdiff
path: root/searx/plugins
diff options
context:
space:
mode:
authorAdam Tauber <asciimoo@gmail.com>2015-03-10 19:55:22 +0100
committerAdam Tauber <asciimoo@gmail.com>2015-03-10 19:55:22 +0100
commit00cc4dcbf44d9ecea89befb08cae4ee5561c4247 (patch)
tree0a9151bd7ee1ac614ccfe69f8ea8a536a139e60c /searx/plugins
parent8d1d4819ae53ff33a258e12ab6a2dc5b58e88846 (diff)
downloadsearxng-00cc4dcbf44d9ecea89befb08cae4ee5561c4247.tar.gz
searxng-00cc4dcbf44d9ecea89befb08cae4ee5561c4247.zip
[enh] plugin support basics ++ self ip plugin
Diffstat (limited to 'searx/plugins')
-rw-r--r--searx/plugins/__init__.py46
-rw-r--r--searx/plugins/self_ip.py17
2 files changed, 63 insertions, 0 deletions
diff --git a/searx/plugins/__init__.py b/searx/plugins/__init__.py
new file mode 100644
index 000000000..b40d2ee89
--- /dev/null
+++ b/searx/plugins/__init__.py
@@ -0,0 +1,46 @@
+from searx.plugins import self_ip
+from searx import logger
+from sys import exit
+
+logger = logger.getChild('plugins')
+
+required_attrs = ('name',
+ 'description',
+ 'default_on')
+
+
+class Plugin():
+ default_on = False
+ name = 'Default plugin'
+
+
+class PluginStore():
+
+ def __init__(self):
+ self.plugins = []
+
+ def __iter__(self):
+ for plugin in plugins:
+ yield plugin
+
+ def register(self, *plugins):
+ for plugin in plugins:
+ for plugin_attr in required_attrs:
+ if not hasattr(plugin, plugin_attr):
+ logger.critical('missing attribute "{0}", cannot load plugin: {1}'.format(plugin_attr, plugin))
+ exit(3)
+ self.plugins.append(plugin)
+
+ def call(self, plugin_type, request, *args, **kwargs):
+ ret = True
+ for plugin in self.plugins:
+ if hasattr(plugin, plugin_type):
+ ret = getattr(plugin, plugin_type)(request, *args, **kwargs)
+ if not ret:
+ break
+
+ return ret
+
+
+plugins = PluginStore()
+plugins.register(self_ip)
diff --git a/searx/plugins/self_ip.py b/searx/plugins/self_ip.py
new file mode 100644
index 000000000..0db6c08df
--- /dev/null
+++ b/searx/plugins/self_ip.py
@@ -0,0 +1,17 @@
+
+name = "Self IP"
+description = ""
+default_on = True
+
+
+def pre_search(request, ctx):
+ if ctx['search'].query == 'ip':
+ x_forwarded_for = request.headers.getlist("X-Forwarded-For")
+ if x_forwarded_for:
+ ip = x_forwarded_for[0]
+ else:
+ ip = request.remote_addr
+ ctx['search'].answers.clear()
+ ctx['search'].answers.add(ip)
+ return False
+ return True