1 files changed, 87 insertions, 0 deletions
diff --git a/test/functional/lib/rspamd.py b/test/functional/lib/rspamd.py
new file mode 100644
index 000000000..998eb6960
--- /dev/null
+++ b/test/functional/lib/rspamd.py
@@ -0,0 +1,87 @@
+import grp
+import os
+import os.path
+import pwd
+import shutil
+import signal
+import socket
+import string
+import tempfile
+import time
+import urllib2
+
+def cleanup_temporary_directory(directory):
+    shutil.rmtree(directory)
+
+def encode_filename(filename):
+    return "".join(['%%%0X' % ord(b) for b in filename])
+
+def get_test_directory():
+    return os.path.abspath(os.path.dirname(os.path.realpath(__file__)) + "../..")
+
+def make_temporary_directory():
+    return tempfile.mkdtemp()
+
+def populate_rspamd_config(template_file, temporary_dir, **config):
+    t = string.Template(open(template_file).read())
+    f = open("%s/rspamd.conf" % temporary_dir, "w")
+    f.write(t.safe_substitute(config))
+    f.close()
+
+def process_should_exist(pid):
+    pid = int(pid)
+    os.kill(pid, 0)
+
+def read_log_from_position(filename, offset):
+    offset = long(offset)
+    f = open(filename, 'rb')
+    f.seek(offset)
+    goo = f.read()
+    size = len(goo)
+    return [goo, size+offset]
+
+def scan_file(addr, port, filename):
+    req = urllib2.Request("http://%s:%s/symbols?%s" % (addr, port, filename))
+    response = urllib2.urlopen(req)
+    return response.read()
+
+def Send_SIGUSR1(pid):
+    pid = int(pid)
+    os.kill(pid, signal.SIGUSR1)
+
+def set_directory_ownership(path, username, groupname):
+    uid=pwd.getpwnam(username).pw_uid
+    gid=grp.getgrnam(groupname).gr_gid
+    os.chown(path, uid, gid)
+
+def spamc(addr, port, filename):
+    goo = open(filename, 'rb').read()
+    length = len(goo)
+    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    s.connect((addr, port))
+    s.send("SYMBOLS SPAMC/1.0\r\nContent-length: %s\r\n\r\n%s" % (length, goo))
+    s.shutdown(socket.SHUT_WR)
+    r = s.recv(2048)
+    return r
+
+def update_dictionary(a, b):
+    a.update(b)
+    return a
+
+def shutdown_rspamd(pid):
+    pid = int(pid)
+    process_should_exist(pid)
+    i = 0
+    while i < 5:
+        try:
+            os.kill(pid, signal.SIGTERM)
+            time.sleep(0.1)
+        except:
+            break
+    if i >= 5:
+        while True:
+            try:
+                os.kill(pid, signal.SIGTERM)
+                time.sleep(0.1)
+            except:
+                break