# coding: utf-8
# python 2 only

# Copyright (c) 2026 TormachTips.com. All rights reserved.
# Licensed under the TormachTips Personal Use License.
# Permission is granted only for private personal use and private personal modification.
# No sharing, publication, distribution, resale, sublicensing, screenshots, code excerpts,
# benchmarks, or videos are permitted without prior written permission.
# Requests:         tormach.1100m@gmail.com
# Information page: https://tormachtips.com/plugins.htm

#############################################
##                                         ##
##      Status Window Patcher v0.96        ##
##          www.tormachtips.com            ##
##                                         ##
#############################################

# 0.96 - Added shared file lock, chronological backups, atomic writes, Python syntax validation, and verbose patch debug logging. - 5/03/2026
# 0.95 - Public beta. - 4/5/26

import os
import re
import time
import fcntl
import shutil
import gtk
import glib
import constants
from ui_hooks import plugin, version_list

CURRENT_VER                  = "0.96"
SCRIPT_NAME                  = "Status Window Font Patcher"
DESCRIPTION                  = "Changes the status window font to monospaced for better alignment."
ENABLED                      = 1
DEV_MACHINE                  = 0
DEV_MACHINE_FLAG             = "/home/operator/gcode/python/dev_machine.txt"
TARGET_FILE                  = os.path.join("python", "errors.py")
MARKER                       = "# BEAGLE: STATUS WINDOW FONT PATCH INSTALLED"
PATCH_START                  = "# BEAGLE: STATUS WINDOW FONT PATCH START"
PATCH_NOTE                   = "# BEAGLE: ORIGINAL DIAGNOSTICS TEXTVIEW FONT BLOCK DISABLED"
PATCH_END                    = "# BEAGLE: STATUS WINDOW FONT PATCH END"
PATCH_LOCK_PATH              = "/tmp/tt_pathpilot_file_patch.lock"
PATCH_LOCK_TIMEOUT_SECONDS   = 30.0

class TTFilePatchLock(object):
    def __init__(self, owner, error_handler, lock_path, timeout_seconds):
        self.owner = owner
        self.error_handler = error_handler
        self.lock_path = lock_path
        self.timeout_seconds = timeout_seconds
        self.fp = None

    def write(self, message):
        try:
            self.error_handler.write("[%s] %s" % (self.owner, message), constants.ALARM_LEVEL_QUIET)
        except:
            pass

    def __enter__(self):
        start_time = time.time()
        self.write("Opening patch lock file: %s" % self.lock_path)
        self.fp = open(self.lock_path, "a+")
        self.write("Waiting for patch lock: %s" % self.lock_path)
        while True:
            try:
                fcntl.flock(self.fp.fileno(), fcntl.LOCK_EX | fcntl.LOCK_NB)
                self.write("Patch lock acquired: %s" % self.lock_path)
                return self
            except IOError:
                elapsed = time.time() - start_time
                if elapsed >= self.timeout_seconds:
                    self.write("Patch lock timeout after %.1f seconds: %s" % (elapsed, self.lock_path))
                    raise RuntimeError("Timed out waiting for patch lock: %s" % self.lock_path)
                time.sleep(0.1)

    def __exit__(self, exc_type, exc_value, traceback_obj):
        try:
            if self.fp:
                self.write("Releasing patch lock: %s" % self.lock_path)
                fcntl.flock(self.fp.fileno(), fcntl.LOCK_UN)
                self.write("Patch lock released: %s" % self.lock_path)
        finally:
            try:
                if self.fp:
                    self.fp.close()
                    self.write("Closed patch lock file: %s" % self.lock_path)
            except:
                pass
        return False

class UserPlugin(plugin):
    def __init__(self):
        plugin.__init__(self, '%s %s' % (SCRIPT_NAME, CURRENT_VER))
        dev_machine_found = os.path.exists(DEV_MACHINE_FLAG)
        if dev_machine_found:
            plugin_enabled = DEV_MACHINE
        else:
            plugin_enabled = ENABLED
        if plugin_enabled:
            glib.timeout_add(3000, self.try_patch)
            return
        if dev_machine_found:
            self.error_handler.write("[%s] Dev machine found. Plugin loaded, but disabled by DEV_MACHINE." % SCRIPT_NAME, constants.ALARM_LEVEL_QUIET)
        else:
            self.error_handler.write("[%s] Plugin loaded, but disabled." % SCRIPT_NAME, constants.ALARM_LEVEL_QUIET)
            self.error_handler.write("[%s] To enable, open script, find ENABLED = 0 and change to ENABLED = 1." % SCRIPT_NAME, constants.ALARM_LEVEL_QUIET)

    def debug(self, message):
        self.error_handler.write("[%s] %s" % (SCRIPT_NAME, message), constants.ALARM_LEVEL_QUIET)

    def show_nonblocking_dialog(self):
        dialog = gtk.MessageDialog(
            None,
            gtk.DIALOG_DESTROY_WITH_PARENT,
            gtk.MESSAGE_INFO,
            gtk.BUTTONS_OK,
            "Status window updated to DejaVu Sans Mono with clean tab stops.\n\n"
            "Please reboot or restart PathPilot for the change to take effect.")
        dialog.set_title(SCRIPT_NAME)
        dialog.set_keep_above(True)
        dialog.set_modal(False)

        def on_response(widget, response_id):
            widget.destroy()
        dialog.connect("response", on_response)
        dialog.show_all()

    def safe_script_name(self):
        safe_name = SCRIPT_NAME.lower()
        safe_name = safe_name.replace(" ", "_")
        safe_name = re.sub(r"[^a-z0-9_]+", "_", safe_name)
        return safe_name

    def get_target_path(self):
        version_path = "v%d.%d.%d" % (version_list[0], version_list[1], version_list[2])
        version_root = os.path.join("/home/operator", version_path)
        return os.path.join(version_root, TARGET_FILE)

    def read_file(self, path):
        self.debug("Reading file: %s" % path)
        with open(path, "r") as f:
            content = f.read()
        self.debug("Read %d bytes from file: %s" % (len(content), path))
        return content

    def make_chronological_backup(self, target_path):
        timestamp = time.strftime("%Y%m%d_%H%M%S")
        safe_name = self.safe_script_name()
        backup_path = "%s.%s.%s.bak" % (target_path, timestamp, safe_name)
        counter = 1
        final_path = backup_path
        while os.path.exists(final_path):
            final_path = "%s.%03d" % (backup_path, counter)
            counter += 1
        self.debug("Creating chronological backup.")
        self.debug("Backup source: %s" % target_path)
        self.debug("Backup target: %s" % final_path)
        shutil.copy2(target_path, final_path)
        self.debug("Backup complete: %s" % final_path)
        return final_path

    def atomic_write_file(self, target_path, content):
        original_stat = os.stat(target_path)
        temp_path = "%s.%s.%d.tmp" % (
            target_path,
            self.safe_script_name(),
            os.getpid())
        self.debug("Writing temporary patched file: %s" % temp_path)
        with open(temp_path, "w") as f:
            f.write(content)
        self.debug("Temporary patched file written: %s" % temp_path)
        try:
            os.chmod(temp_path, original_stat.st_mode)
            self.debug("Copied original file mode to temporary file: %o" % original_stat.st_mode)
        except Exception as e:
            self.debug("Could not copy original mode to temporary file: %s" % str(e))
        try:
            os.chown(temp_path, original_stat.st_uid, original_stat.st_gid)
            self.debug("Copied original owner/group to temporary file.")
        except Exception as e:
            self.debug("Could not copy original owner/group to temporary file: %s" % str(e))
        self.debug("Renaming temporary file over target.")
        self.debug("Rename source: %s" % temp_path)
        self.debug("Rename target: %s" % target_path)
        os.rename(temp_path, target_path)
        self.debug("Atomic rename complete: %s" % target_path)

    def validate_python_content(self, target_path, content):
        try:
            compile(content, target_path, "exec")
            self.debug("Python syntax validation passed: %s" % target_path)
        except Exception as e:
            raise RuntimeError("Patched file failed Python syntax validation: %s" % str(e))

    def patch_content(self, content):
        if MARKER in content:
            self.debug("Patch marker already present.")
            return content, False
        original_content = content
        font_block_pattern = re.compile(
            r'(?P<indent>^[ \t]*)font_description = pango\.FontDescription\(DIAGNOSTICS_TEXTVIEW_FONT\)\s*\n'
            r'(?P=indent)self\.diagnostics_textview\.modify_font\(font_description\)',
            re.MULTILINE)

        def replace_font_block(match):
            indent = match.group('indent')
            return (
                indent + MARKER + "\n" +
                indent + PATCH_START + "\n" +
                indent + PATCH_NOTE + "\n" +
                indent + "# font_description = pango.FontDescription(DIAGNOSTICS_TEXTVIEW_FONT)\n" +
                indent + "# self.diagnostics_textview.modify_font(font_description)\n" +
                indent + "font_description = pango.FontDescription('DejaVu Sans Mono 9')\n" +
                indent + "self.diagnostics_textview.modify_font(font_description)\n" +
                indent + "def setup_tabs():\n" +
                indent + "    tab_array = pango.TabArray(20, True)\n" +
                indent + "    tab_width_in_pixels = 4 * 9\n" +
                indent + "    for i in range(20):\n" +
                indent + "        tab_array.set_tab(i, pango.TAB_LEFT, i * tab_width_in_pixels)\n" +
                indent + "    self.diagnostics_textview.set_tabs(tab_array)\n" +
                indent + "    self.write('[[[[Diagnostics]]]] Tabs set to 4 characters')\n" +
                indent + "glib.idle_add(setup_tabs)\n" +
                indent + PATCH_END)
        
        self.debug("Searching for diagnostics textview font OEM block.")
        patched_content, count = font_block_pattern.subn(replace_font_block, content, count=1)
        self.debug("Status font replacement count: %d" % count)
        if count < 1:
            raise RuntimeError("Target diagnostics textview font block not found. Patch skipped.")
        if patched_content == original_content:
            raise RuntimeError("Patch produced no content changes.")
        return patched_content, True

    def try_patch(self):
        backup_path = ""
        try:
            target_path = self.get_target_path()
            self.debug("Target file: %s" % target_path)
            self.debug("Patch marker: %s" % MARKER)
            with TTFilePatchLock(SCRIPT_NAME, self.error_handler, PATCH_LOCK_PATH, PATCH_LOCK_TIMEOUT_SECONDS):
                self.debug("Inside locked patch section.")
                if not os.path.exists(target_path):
                    self.error_handler.write("[%s] File not found: %s" % (SCRIPT_NAME, target_path), constants.ALARM_LEVEL_LOW)
                    return False
                content = self.read_file(target_path)
                patched_content, changed = self.patch_content(content)
                if not changed:
                    self.error_handler.write("[%s] Already patched. No changes made." % SCRIPT_NAME, constants.ALARM_LEVEL_QUIET)
                    self.debug("Marker found; exiting without backup or write.")
                    return False
                self.validate_python_content(target_path, patched_content)
                self.debug("Patch content generated.")
                self.debug("Original byte count: %d" % len(content))
                self.debug("Patched byte count: %d" % len(patched_content))
                backup_path = self.make_chronological_backup(target_path)
                self.atomic_write_file(target_path, patched_content)
                self.debug("Leaving locked patch section after successful write.")
            self.error_handler.write(" ", constants.ALARM_LEVEL_QUIET)
            self.error_handler.write("[%s] Patch applied to: %s" % (SCRIPT_NAME, target_path), constants.ALARM_LEVEL_MEDIUM)
            self.error_handler.write("[%s] Backup created: %s" % (SCRIPT_NAME, backup_path), constants.ALARM_LEVEL_MEDIUM)
            self.error_handler.write("[%s] Please reboot or restart PathPilot." % SCRIPT_NAME, constants.ALARM_LEVEL_MEDIUM)
            self.error_handler.write(" ", constants.ALARM_LEVEL_QUIET)
            glib.idle_add(self.show_nonblocking_dialog)
        except Exception as e:
            self.error_handler.write("[%s] Error: %s" % (SCRIPT_NAME, str(e)), constants.ALARM_LEVEL_LOW)
        return False

DESCRIPTION_LONG = """Like most of PathPilot, the status window does 
    not use clean tab spacing or a monospaced font. For any type of text based 
    column organization, this provides an ugly, counter intuitive display.</font></p>
    <p><font face="Verdana" size="2">This script fixes that. It changes the font 
    to one that is monospaced and cleans up the tab spacing. </font></p>
    <p><font face="Verdana" size="2"><a href="images/status2.jpg">
    <img border="2" src="images/status2_small.jpg" xthumbnail-orig-image="images/status2.jpg" width="200" height="150"></a>
    <a href="images/status1.jpg">
    <img border="2" src="images/status1_small.jpg" xthumbnail-orig-image="images/status1.jpg" width="200" height="150"></a><br>
    </font><font face="Verdana" size="1">Before &amp; After"""