from flask import Blueprint, request, jsonify
from app.middleware.rbac import admin_required
from app.services.log_service import LogService
from app.api._request import json_object
from app.exceptions import ValidationError

logs_bp = Blueprint('logs', __name__)


@logs_bp.route('', methods=['GET'])
@admin_required
def list_log_files():
    """List available log files."""
    logs = LogService.get_log_files()
    return jsonify({'logs': logs}), 200


@logs_bp.route('/read', methods=['GET'])
@admin_required
def read_log():
    """Read lines from a log file."""
    filepath = request.args.get('path')
    lines = request.args.get('lines', 100, type=int)
    from_end = request.args.get('from_end', 'true').lower() == 'true'

    if not filepath:
        return jsonify({'error': 'path parameter is required'}), 400

    result = LogService.read_log(filepath, lines, from_end)
    return jsonify(result), 200 if result['success'] else 400


@logs_bp.route('/search', methods=['GET'])
@admin_required
def search_log():
    """Search log file for a pattern."""
    filepath = request.args.get('path')
    pattern = request.args.get('pattern')
    lines = request.args.get('lines', 100, type=int)

    if not filepath or not pattern:
        return jsonify({'error': 'path and pattern parameters are required'}), 400

    result = LogService.search_log(filepath, pattern, lines)
    return jsonify(result), 200 if result['success'] else 400


@logs_bp.route('/app/<app_name>', methods=['GET'])
@admin_required
def get_app_logs(app_name):
    """Get logs for a specific application."""
    log_type = request.args.get('type', 'access')
    lines = request.args.get('lines', 100, type=int)

    result = LogService.get_app_logs(app_name, log_type, lines)
    return jsonify(result), 200 if result['success'] else 400


@logs_bp.route('/journal', methods=['GET'])
@admin_required
def get_journal_logs():
    """Get logs from systemd journal."""
    unit = request.args.get('unit')
    lines = request.args.get('lines', 100, type=int)
    since = request.args.get('since')
    priority = request.args.get('priority') or None
    # journalctl levels 0 (emerg) .. 7 (debug); anything else is a client error,
    # not something to hand to a privileged journalctl.
    if priority is not None and priority not in {str(n) for n in range(8)}:
        raise ValidationError('priority must be a journal level from 0 to 7',
                              code='validation.priority')

    result = LogService.get_journalctl_logs(unit, lines, since, priority)
    return jsonify(result), 200 if result['success'] else 400


@logs_bp.route('/clear', methods=['POST'])
@admin_required
def clear_log():
    """Clear/truncate a log file."""
    data = json_object()
    filepath = data.get('path') if data else None

    if not filepath:
        return jsonify({'error': 'path is required'}), 400

    result = LogService.clear_log(filepath)
    return jsonify(result), 200 if result['success'] else 400


@logs_bp.route('/rotate', methods=['POST'])
@admin_required
def rotate_logs():
    """Trigger log rotation."""
    result = LogService.rotate_logs()
    return jsonify(result), 200 if result['success'] else 400