RC version

Author: DSpeichert

.gitignore

@@ -0,0 +1,101 @@
+.idea/
+
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+.hypothesis/
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+local_settings.py
+
+# Flask stuff:
+instance/
+.webassets-cache
+
+# Scrapy stuff:
+.scrapy
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+target/
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# pyenv
+.python-version
+
+# celery beat schedule file
+celerybeat-schedule
+
+# SageMath parsed files
+*.sage.py
+
+# Environments
+.env
+.venv
+env/
+venv/
+ENV/
+
+# Spyder project settings
+.spyderproject
+.spyproject
+
+# Rope project settings
+.ropeproject
+
+# mkdocs documentation
+/site
+
+# mypy
+.mypy_cache/

README.rst

@@ -0,0 +1,4 @@
+DirectAdmin Server Agent
+
+* https://www.directadmin.com/search_versions.php?query=_pre.sh
+* https://www.directadmin.com/search_versions.php?query=_post.sh

dasa/__init__.py

@@ -0,0 +1,8 @@
+import requests
+from dasa.config import config
+
+
+def get_session():
+    s = requests.Session()
+    s.headers.update({'X-DASA-Key': config.get('api_key')})
+    return s

dasa/ciapi.py

@@ -0,0 +1,11 @@
+import sys
+import logging
+
+root = logging.getLogger()
+root.setLevel(logging.INFO)
+
+ch = logging.StreamHandler(sys.stdout)
+ch.setLevel(logging.DEBUG)
+formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
+ch.setFormatter(formatter)
+root.addHandler(ch)

dasa/cmd/__init__.py

@@ -0,0 +1,14 @@
+import os
+from dasa import ciapi
+from dasa.config import config
+
+
+def main():
+    s = ciapi.get_session()
+    s.post(config.get('api_base_url') + 'system/directadmin/dns_write_post',
+           json=os.environ,
+           timeout=config.get('api_timeout'))
+
+    if s.status_code != 200:
+        print(s.json().get('message'))
+        exit(1)

dasa/cmd/dns_write_post.py

@@ -0,0 +1,38 @@
+import os
+from dasa import ciapi
+from dasa.config import config
+
+
+def main():
+    s = ciapi.get_session()
+
+    # domain_create_post for newdomain
+    json = os.environ
+    old_domain = json.domain
+    json.domain = json.newdomain
+    del json.newdomain
+    s.post(config.get('api_base_url') + 'system/directadmin/domain_create_post',
+           json=json,
+           timeout=config.get('api_timeout'))
+
+    if s.status_code == 404:
+        print(s.json().get('message'))
+        exit(0)
+
+    if s.status_code != 200:
+        print(s.json().get('message'))
+        exit(1)
+
+    # domain_destroy_post for (old) domain
+    json.domain = old_domain
+    s.post(config.get('api_base_url') + 'system/directadmin/domain_destroy_post',
+           json=json,
+           timeout=config.get('api_timeout'))
+
+    if s.status_code == 404:
+        print(s.json().get('message'))
+        exit(0)
+
+    if s.status_code != 200:
+        print(s.json().get('message'))
+        exit(1)

dasa/cmd/domain_change_post.py

@@ -0,0 +1,23 @@
+import os
+from dasa import ciapi
+from dasa.config import config
+
+
+def main():
+    s = ciapi.get_session()
+
+    # pre-clear via domain_create_pre
+    json = os.environ
+    json.domain = json.newdomain
+    del json.newdomain
+    s.post(config.get('api_base_url') + 'system/directadmin/domain_create_pre',
+           json=json,
+           timeout=config.get('api_timeout'))
+
+    if s.status_code == 404:
+        print(s.json().get('message'))
+        exit(0)
+
+    if s.status_code != 200:
+        print(s.json().get('message'))
+        exit(1)

dasa/cmd/domain_change_pre.py

@@ -0,0 +1,31 @@
+import os
+from dasa import ciapi
+from dasa.config import config
+
+
+def main():
+    if 'username' not in os.environ or 'domain' not in os.environ:
+        print('Required environment variables missing, expecting: username, domain')
+        exit(1)
+
+    # Set SpamAssassin options
+    if os.path.isfile('/etc/virtual/' + os.environ.get('domain') + '/filter.conf'):
+        with open('/etc/virtual/' + os.environ.get('domain') + '/filter.conf', 'a') as f:
+            f.write("high_score=15\nhigh_score_block=yes\nwhere=userspamfolder\n")
+
+        with open('/usr/local/directadmin/data/task.queue', 'a') as f:
+            f.write('action=rewrite&value=filter&user=' + os.environ.get('username'))
+
+    # Report to CIAPI
+    s = ciapi.get_session()
+    s.post(config.get('api_base_url') + 'system/directadmin/domain_create_post',
+           json=os.environ,
+           timeout=config.get('api_timeout'))
+
+    if s.status_code == 404:
+        print(s.json().get('message'))
+        exit(0)
+
+    if s.status_code != 200:
+        print(s.json().get('message'))
+        exit(1)

dasa/cmd/domain_create_post.py

@@ -0,0 +1,18 @@
+import os
+from dasa import ciapi
+from dasa.config import config
+
+
+def main():
+    s = ciapi.get_session()
+    s.post(config.get('api_base_url') + 'system/directadmin/domain_create_pre',
+           json=os.environ,
+           timeout=config.get('api_timeout'))
+
+    if s.status_code == 404:
+        print(s.json().get('message'))
+        exit(0)
+
+    if s.status_code != 200:
+        print(s.json().get('message'))
+        exit(1)

dasa/cmd/domain_create_pre.py

@@ -0,0 +1,18 @@
+import os
+from dasa import ciapi
+from dasa.config import config
+
+
+def main():
+    s = ciapi.get_session()
+    s.post(config.get('api_base_url') + 'system/directadmin/domain_destroy_post',
+           json=os.environ,
+           timeout=config.get('api_timeout'))
+
+    if s.status_code == 404:
+        print(s.json().get('message'))
+        exit(0)
+
+    if s.status_code != 200:
+        print(s.json().get('message'))
+        exit(1)

dasa/cmd/domain_destroy_post.py

@@ -0,0 +1,18 @@
+import os
+from dasa import ciapi
+from dasa.config import config
+
+
+def main():
+    s = ciapi.get_session()
+    s.post(config.get('api_base_url') + 'system/directadmin/domain_pointer_create_post',
+           json=os.environ,
+           timeout=config.get('api_timeout'))
+
+    if s.status_code == 404:
+        print(s.json().get('message'))
+        exit(0)
+
+    if s.status_code != 200:
+        print(s.json().get('message'))
+        exit(1)

dasa/cmd/domain_pointer_create_post.py

@@ -0,0 +1,18 @@
+import os
+from dasa import ciapi
+from dasa.config import config
+
+
+def main():
+    s = ciapi.get_session()
+    s.post(config.get('api_base_url') + 'system/directadmin/domain_pointer_create_pre',
+           json=os.environ,
+           timeout=config.get('api_timeout'))
+
+    if s.status_code == 404:
+        print(s.json().get('message'))
+        exit(0)
+
+    if s.status_code != 200:
+        print(s.json().get('message'))
+        exit(1)

dasa/cmd/domain_pointer_create_pre.py

@@ -0,0 +1,18 @@
+import os
+from dasa import ciapi
+from dasa.config import config
+
+
+def main():
+    s = ciapi.get_session()
+    s.post(config.get('api_base_url') + 'system/directadmin/domain_pointer_destroy_post',
+           json=os.environ,
+           timeout=config.get('api_timeout'))
+
+    if s.status_code == 404:
+        print(s.json().get('message'))
+        exit(0)
+
+    if s.status_code != 200:
+        print(s.json().get('message'))
+        exit(1)

dasa/cmd/domain_pointer_destroy_post.py

@@ -0,0 +1,32 @@
+import os
+
+
+def fail_for_regular_use(message):
+    # https: // www.directadmin.com / features.php?id = 1466
+    if 'login_as_master_name' not in os.environ:
+        print('Modyfikowanie tych opcji SpamAssassin jest zablokowane.')
+        print(message)
+        exit(1)
+
+
+# https://www.directadmin.com/features.php?id=1702
+def main():
+    if 'where' in os.environ and os.environ.get('where') == 'inbox' or os.environ.get('where') == 'userspamfolder':
+        fail_for_regular_use('Spam możesz przekazywać do katalogu spam lub usuwać.')
+
+    if 'high_score_block' in os.environ and os.environ.get('high_score_block') == 'no':
+        fail_for_regular_use('Usuwanie wysoko punktowanego spamu musi być włączone.')
+
+    if 'high_score' in os.environ:
+        hs = int(os.environ.get('high_score'))
+        if hs == 0 or hs > 15:
+            fail_for_regular_use('Maksymalna wartość wysoko punktowanego spamu to 15.')
+
+    if 'required_hits' in os.environ:
+        if os.environ.get('required_hits') == 'custom':
+            rh = float(os.environ.get('required_hits_custom'))
+        else:
+            rh = float(os.environ.get('required_hits'))
+
+        if rh > 5.0:
+            fail_for_regular_use('Maksymalna wartość spamu to 5.0.')

dasa/cmd/spamassassin_edit_pre.py

@@ -0,0 +1,18 @@
+import os
+from dasa import ciapi
+from dasa.config import config
+
+
+def main():
+    s = ciapi.get_session()
+    s.post(config.get('api_base_url') + 'system/directadmin/user_activate_post',
+           json=os.environ,
+           timeout=config.get('api_timeout'))
+
+    if s.status_code == 404:
+        print(s.json().get('message'))
+        exit(0)
+
+    if s.status_code != 200:
+        print(s.json().get('message'))
+        exit(1)