Development

docker/routlin-dash/app/action_ddns.py

@@ -0,0 +1,197 @@
+import os
+import re
+from flask import Blueprint, request, redirect, flash, send_file, abort
+from auth import require_level
+from config_utils import load_core, save_core, verify_core_hash, queued_msg, CONFIGS_DIR
+import sanitize
+import validation as validate
+
+bp = Blueprint('action_ddns', __name__)
+
+VIEW     = '/view/view_ddns'
+LOG_FILE = f'{CONFIGS_DIR}/ddns.log'
+
+
+@bp.route('/action/ddns_cardaddaccount_add', methods=['POST'])
+@require_level('administrator')
+def ddns_cardaddaccount_add():
+    provider_type = sanitize.filtervalue(request.form.get('provider', ''), validate.VALID_DDNS_PROVIDERS)
+    description   = sanitize.description(request.form.get('description', ''))
+    hostnames     = sanitize.domainlist(request.form.get('hostnames', '').splitlines())
+
+    if not description:
+        flash('Description is required.', 'error')
+        return redirect(VIEW)
+    if not hostnames:
+        flash('At least one hostname is required.', 'error')
+        return redirect(VIEW)
+    if not provider_type:
+        flash('Unknown provider type.', 'error')
+        return redirect(VIEW)
+
+    entry = {
+        'description': description,
+        'provider':    provider_type,
+        'enabled':     True,
+        'hostnames':   hostnames,
+    }
+    if provider_type == 'noip':
+        entry['username'] = request.form.get('username', '').strip()
+        entry['password'] = request.form.get('password', '').strip()
+    else:
+        entry['api_token'] = request.form.get('api_token', '').strip()
+
+    core = load_core()
+    core.setdefault('ddns', {}).setdefault('providers', []).append(entry)
+    save_core(core)
+    flash(f'DDNS provider "{description}" added.', 'success')
+    return redirect(VIEW)
+
+
+@bp.route('/action/ddns_tableaccounts_rowedit', methods=['POST'])
+@require_level('administrator')
+def ddns_tableaccounts_rowedit():
+    try:
+        row_index = int(request.form.get('row_index', -1))
+    except (TypeError, ValueError):
+        flash('Invalid row index.', 'error')
+        return redirect(VIEW)
+
+    provider_type = sanitize.filtervalue(request.form.get('provider', ''), validate.VALID_DDNS_PROVIDERS)
+    description   = sanitize.description(request.form.get('description', ''))
+    hostnames     = [h.strip() for h in request.form.get('hostnames', '').splitlines() if h.strip()]
+    enabled       = request.form.get('enabled') == 'on'
+
+    if not provider_type:
+        flash('Unknown provider type.', 'error')
+        return redirect(VIEW)
+
+    core      = load_core()
+    providers = core.setdefault('ddns', {}).setdefault('providers', [])
+    if row_index < 0 or row_index >= len(providers):
+        flash('Invalid provider index.', 'error')
+        return redirect(VIEW)
+
+    entry = {
+        'description': description,
+        'provider':    provider_type,
+        'enabled':     enabled,
+        'hostnames':   hostnames,
+    }
+    if provider_type == 'noip':
+        entry['username'] = request.form.get('username', '').strip()
+        entry['password'] = request.form.get('password', '').strip()
+    else:
+        entry['api_token'] = request.form.get('api_token', '').strip()
+
+    providers[row_index] = entry
+    save_core(core)
+    flash('DDNS provider updated.', 'success')
+    return redirect(VIEW)
+
+
+@bp.route('/action/ddns_tableaccounts_rowdelete', methods=['POST'])
+@require_level('administrator')
+def ddns_tableaccounts_rowdelete():
+    try:
+        row_index = int(request.form.get('row_index', -1))
+    except (TypeError, ValueError):
+        flash('Invalid row index.', 'error')
+        return redirect(VIEW)
+
+    core      = load_core()
+    providers = core.setdefault('ddns', {}).setdefault('providers', [])
+    if row_index < 0 or row_index >= len(providers):
+        flash('Invalid provider index.', 'error')
+        return redirect(VIEW)
+
+    del providers[row_index]
+    save_core(core)
+    flash('DDNS provider deleted.', 'success')
+    return redirect(VIEW)
+
+
+@bp.route('/action/ddns_cardcheckinterval_save', methods=['POST'])
+@require_level('administrator')
+def ddns_cardcheckinterval_save():
+    raw = request.form.get('timer_interval', '').strip()
+    try:
+        mins = int(raw)
+        if mins < 1:
+            raise ValueError
+    except ValueError:
+        flash('Interval must be a whole number of minutes >= 1.', 'error')
+        return redirect(VIEW)
+    timer_interval = f'{mins}m'
+    if not verify_core_hash(request.form.get('config_hash', '')):
+        flash('Configuration was modified by another session. Please refresh and try again.', 'error')
+        return redirect(VIEW)
+    core = load_core()
+    core.setdefault('ddns', {}).setdefault('general', {})['timer_interval'] = timer_interval
+    save_core(core)
+    flash(queued_msg('core apply'), 'success')
+    return redirect(VIEW)
+
+
+@bp.route('/action/ddns_cardipcheckservices_save', methods=['POST'])
+@require_level('administrator')
+def ddns_cardipcheckservices_save():
+    if not verify_core_hash(request.form.get('config_hash', '')):
+        flash('Configuration was modified by another session. Please refresh and try again.', 'error')
+        return redirect(VIEW)
+
+    http_services = [u.strip() for u in request.form.getlist('http_services') if u.strip()]
+    dig_services  = [u.strip() for u in request.form.getlist('dig_services')  if u.strip()]
+
+    if not http_services and not dig_services:
+        flash('At least one IP check service is required.', 'error')
+        return redirect(VIEW)
+
+    services  = [{'type': 'http', 'url': u} for u in http_services]
+    services += [{'type': 'dig',  'url': u} for u in dig_services]
+
+    core = load_core()
+    core.setdefault('ddns', {})['ip_check_services'] = services
+    save_core(core)
+    flash('IP check services saved.', 'success')
+    return redirect(VIEW)
+
+
+@bp.route('/action/ddns_cardddnslog_save', methods=['POST'])
+@require_level('administrator')
+def ddns_cardddnslog_save():
+    log_max_kb = validate.int_range(request.form.get('log_max_kb', '').strip(), 64, None)
+    if log_max_kb is None:
+        flash('Max Log Size must be a number >= 64.', 'error')
+        return redirect(VIEW)
+    log_errors_only = 'log_errors_only' in request.form
+    if not verify_core_hash(request.form.get('config_hash', '')):
+        flash('Configuration was modified by another session. Please refresh and try again.', 'error')
+        return redirect(VIEW)
+    core = load_core()
+    core.setdefault('ddns', {}).setdefault('general', {}).update({
+        'log_max_kb':      log_max_kb,
+        'log_errors_only': log_errors_only,
+    })
+    save_core(core)
+    flash('DDNS log settings saved.', 'success')
+    return redirect(VIEW)
+
+
+@bp.route('/action/ddns_cardddnslog_clear', methods=['POST'])
+@require_level('administrator')
+def ddns_cardddnslog_clear():
+    try:
+        open(LOG_FILE, 'w').close()
+        flash('DDNS log cleared.', 'success')
+    except Exception as ex:
+        flash(f'Could not clear log: {ex}', 'error')
+    return redirect(VIEW)
+
+
+@bp.route('/action/ddns_cardddnslog_download', methods=['GET'])
+@require_level('administrator')
+def ddns_cardddnslog_download():
+    if not os.path.isfile(LOG_FILE):
+        abort(404)
+    return send_file(LOG_FILE, as_attachment=True, download_name='ddns.log', mimetype='text/plain')