Gecko [ edgpens.lpkmn.gov.my ]

Name	Size	Permission
.mad-root	0 B	-rw-rw-rw-
pwnkit	10.99 KB	-rw-rw-rw-
sublime.py	138.49 KB	-rw-rw-rw-
sublime_plugin.py	83.21 KB	-rw-rw-rw-
sublime_types.py	594 B	-rw-rw-rw-

Code Editor : sublime_plugin.py

# Don't evaluate type annotations at runtime
from __future__ import annotations

import importlib
import io
import marshal
import os
import sys
import threading
import time
import traceback
import zipfile

import sublime
import sublime_api

from typing import Optional, TYPE_CHECKING

if TYPE_CHECKING:
    from sublime_types import Value

api_ready = False

deferred_plugin_loadeds = []

application_command_classes = []
window_command_classes = []
text_command_classes = []

view_event_listener_classes = []
view_event_listeners = {}

all_command_classes = [
    application_command_classes,
    window_command_classes,
    text_command_classes]

all_callbacks = {
    'on_init': [],
    'on_new': [],
    'on_clone': [],
    'on_load': [],
    'on_revert': [],
    'on_reload': [],
    'on_pre_close': [],
    'on_close': [],
    'on_pre_save': [],
    'on_post_save': [],
    'on_pre_move': [],
    'on_post_move': [],
    'on_modified': [],
    'on_selection_modified': [],
    'on_activated': [],
    'on_deactivated': [],
    'on_query_context': [],
    'on_query_completions': [],
    'on_hover': [],
    'on_text_command': [],
    'on_window_command': [],
    'on_post_text_command': [],
    'on_post_window_command': [],
    'on_modified_async': [],
    'on_selection_modified_async': [],
    'on_pre_save_async': [],
    'on_post_save_async': [],
    'on_post_move_async': [],
    'on_activated_async': [],
    'on_deactivated_async': [],
    'on_new_async': [],
    'on_load_async': [],
    'on_revert_async': [],
    'on_reload_async': [],
    'on_clone_async': [],
    'on_new_buffer': [],
    'on_new_buffer_async': [],
    'on_associate_buffer': [],
    'on_associate_buffer_async': [],
    'on_close_buffer': [],
    'on_close_buffer_async': [],
    'on_new_project': [],
    'on_new_project_async': [],
    'on_load_project': [],
    'on_load_project_async': [],
    'on_pre_save_project': [],
    'on_post_save_project': [],
    'on_post_save_project_async': [],
    'on_pre_close_project': [],
    'on_new_window': [],
    'on_new_window_async': [],
    'on_pre_close_window': [],
    'on_exit': [],
}

pending_on_activated_async_lock = threading.Lock()

pending_on_activated_async_callbacks = {
    'EventListener': [],
    'ViewEventListener': [],
}

view_event_listener_excluded_callbacks = {
    'on_clone',
    'on_clone_async',
    'on_exit',
    'on_init',
    'on_load_project',
    'on_load_project_async',
    'on_new',
    'on_new_async',
    'on_new_buffer',
    'on_new_buffer_async',
    'on_associate_buffer',
    'on_associate_buffer_async',
    'on_close_buffer',
    'on_close_buffer_async',
    'on_new_project',
    'on_new_project_async',
    'on_new_window',
    'on_new_window_async',
    'on_post_save_project',
    'on_post_save_project_async',
    'on_post_window_command',
    'on_pre_close_project',
    'on_pre_close_window',
    'on_pre_save_project',
    'on_window_command',
}

text_change_listener_classes = []
text_change_listener_callbacks = {
    'on_text_changed',
    'on_text_changed_async',
    'on_revert',
    'on_revert_async',
    'on_reload',
    'on_reload_async',
}
text_change_listeners = {}

profile = {}

def add_profiling(event_handler):
    """
    Decorator to measure blocking event handler methods. Also prevents
    exceptions from interrupting other events handlers.

:param event_handler:
        The event handler method - must be an unbound method

:return:
        The decorated method

:meta private:
    """

def profiler(*args):
        global profile
        t0 = time.time()
        try:
            return event_handler(*args)
        except (Exception) as e:
            # All this to include stack frames before the call to
            # event_handler() above
            tb = traceback.extract_stack()[:-1]
            tb += traceback.extract_tb(e.__traceback__)
            out = ["Traceback (most recent call last):\n"]
            out += traceback.format_list(tb)
            out += traceback.format_exception_only(type(e), e)
            print("".join(out), end="")
        finally:
            elapsed = time.time() - t0
            mod = event_handler.__module__
            p = profile.setdefault(event_handler.__name__, {})
            p.setdefault(mod, Summary()).record(elapsed)

# Make the method look like the original for introspection
    profiler.__doc__ = event_handler.__doc__
    profiler.__name__ = event_handler.__name__
    profiler.__module__ = event_handler.__module__
    # Follow the pattern of decorators like @classmethod and @staticmethod
    profiler.__func__ = event_handler
    return profiler

def trap_exceptions(event_handler):
    """
    Decorator to prevent exceptions from interrupting other events handlers.

:param event_handler:
        The event handler method - must be an unbound method

:return:
        The decorated method

:meta private:
    """

def exception_handler(*args):
        try:
            return event_handler(*args)
        except (Exception) as e:
            # All this to include stack frames before the call to
            # event_handler() above
            tb = traceback.extract_stack()[:-1]
            tb += traceback.extract_tb(e.__traceback__)
            out = ["Traceback (most recent call last):\n"]
            out += traceback.format_list(tb)
            out += traceback.format_exception_only(type(e), e)
            print("".join(out), end="")

# Make the method look like the original for introspection
    exception_handler.__doc__ = event_handler.__doc__
    exception_handler.__name__ = event_handler.__name__
    exception_handler.__module__ = event_handler.__module__
    event_handler.__name__ = '_wrapped_%s' % event_handler.__name__
    # Follow the pattern of decorators like @classmethod and @staticmethod
    exception_handler.__func__ = event_handler
    return exception_handler

def decorate_handler(cls, method_name):
    """
    Decorates an event handler method with exception trapping, and in the case
    of blocking calls, profiling.

:param cls:
        The class object to decorate
    :param method_name:
        A unicode string of the name of the method to decorate

:meta private:
    """

# We have to use __dict__ rather than getattr(), otherwise the function
    # is passed through decorators, and we can't detect @classmethod and
    # @staticmethod
    method = cls.__dict__[method_name]
    if method_name.endswith('_async'):
        wrapper = trap_exceptions
    else:
        wrapper = add_profiling
    if isinstance(method, staticmethod):
        wrapped = staticmethod(wrapper(method.__func__))
    elif isinstance(method, classmethod):
        wrapped = classmethod(wrapper(method.__func__))
    else:
        wrapped = wrapper(method)
    setattr(cls, method_name, wrapped)

def unload_module(module):
    if "plugin_unloaded" in module.__dict__:
        try:
            module.plugin_unloaded()
        except:
            traceback.print_exc()

# Unload the old plugins
    if "__plugins__" in module.__dict__:
        for view_id, listener_instances in view_event_listeners.items():
            for vel in listener_instances[:]:
                if vel.__class__ in module.__plugins__:
                    listener_instances.remove(vel)

for buffer_id, listener_instances in text_change_listeners.items():
            for tcl in listener_instances[:]:
                if tcl.__class__ in module.__plugins__:
                    tcl.detach()
                    listener_instances.remove(tcl)

for p in module.__plugins__:
            for cmd_cls_list in all_command_classes:
                try:
                    cmd_cls_list.remove(p)
                except ValueError:
                    pass
            for c in all_callbacks.values():
                try:
                    c.remove(p)
                except ValueError:
                    pass

try:
                view_event_listener_classes.remove(p)
            except ValueError:
                pass

try:
                text_change_listener_classes.remove(p)
            except ValueError:
                pass

def unload_plugin(modulename):
    print(f"unloading plugin {modulename}")

was_loaded = modulename in sys.modules
    if was_loaded:
        m = sys.modules[modulename]
        unload_module(m)
        del sys.modules[modulename]

def reload_plugin(modulename):
    print(f"reloading plugin {modulename}")

loaded = False
    if modulename in sys.modules:
        m = sys.modules[modulename]
        unload_module(m)

# In the situation that the module was previously loaded using
        # ZipLoader, but now the .sublime-package is gone, we can't use the
        # ZipLoader to reload, so we erase all traces and do a fresh import
        l = m.__spec__.loader
        if not isinstance(l, ZipLoader) or l in multi_importer.loaders:
            m = importlib.reload(m)
            loaded = True
        else:
            del sys.modules[modulename]

if not loaded:
        m = importlib.import_module(modulename)

load_module(m)

def load_module(m):
    module_plugins = []
    on_activated_targets = []
    vel_on_activated_classes = []
    el_on_activated_async_targets = []
    vel_on_activated_async_targets = []
    module_view_event_listener_classes = []
    module_text_change_listener_classes = []

objs = dir(m)
    # We build a set of allowed imports, but iterate over the
    # module itself so that the classes are added in order
    if '__all__' in objs:
        importable_objs = m.__all__
    else:
        # When the plugin doesn't define __all__, we ignore
        # "private" entries
        importable_objs = set()
        for type_name in objs:
            if type_name[0] != '_':
                importable_objs.add(type_name)

for type_name in objs:
        if type_name not in importable_objs:
            continue

try:
            t = m.__dict__[type_name]
            if t.__bases__:
                is_plugin = False
                if issubclass(t, ApplicationCommand) and t is not ApplicationCommand:
                    application_command_classes.append(t)
                    is_plugin = True
                if issubclass(t, WindowCommand) and t is not WindowCommand:
                    window_command_classes.append(t)
                    is_plugin = True
                if issubclass(t, TextCommand) and t is not TextCommand:
                    text_command_classes.append(t)
                    is_plugin = True

if is_plugin:
                    module_plugins.append(t)

if issubclass(t, EventListener) and t is not EventListener:
                    for method_name, _ in all_callbacks.items():
                        if method_name in dir(t):
                            decorate_handler(t, method_name)

obj = t()

for method_name, listeners in all_callbacks.items():
                        if method_name in dir(t):
                            listeners.append(obj)

if "on_activated" in dir(obj):
                        on_activated_targets.append(obj)

if "on_activated_async" in dir(obj):
                        el_on_activated_async_targets.append(obj)

module_plugins.append(obj)

if issubclass(t, ViewEventListener) and t is not ViewEventListener:
                    for method_name, _ in all_callbacks.items():
                        if method_name in view_event_listener_excluded_callbacks:
                            continue
                        if method_name in dir(t):
                            decorate_handler(t, method_name)
                    view_event_listener_classes.append(t)
                    module_view_event_listener_classes.append(t)
                    if "on_activated" in dir(t):
                        vel_on_activated_classes.append(t)
                    if "on_activated_async" in dir(t):
                        vel_on_activated_async_targets.append(t)
                    module_plugins.append(t)

if issubclass(t, TextChangeListener) and t is not TextChangeListener:
                    for name in text_change_listener_callbacks:
                        if name in dir(t):
                            decorate_handler(t, name)

module_plugins.append(t)
                    text_change_listener_classes.append(t)
                    module_text_change_listener_classes.append(t)
        except AttributeError:
            pass

if el_on_activated_async_targets or vel_on_activated_async_targets:
        with pending_on_activated_async_lock:
            pending_on_activated_async_callbacks['EventListener'].extend(
                el_on_activated_async_targets
            )
            pending_on_activated_async_callbacks['ViewEventListener'].extend(
                vel_on_activated_async_targets
            )

if len(module_plugins) > 0:
        m.__plugins__ = module_plugins

if api_ready:
        if "plugin_loaded" in m.__dict__:
            try:
                m.plugin_loaded()
            except:
                traceback.print_exc()

# Create any require ViewEventListener objects
        if len(module_view_event_listener_classes) > 0:
            for w in sublime.windows():
                for v in w.views(include_transient=True):
                    create_view_event_listeners(
                        module_view_event_listener_classes, v)

# Create any required TextChangeListener objects
        if len(module_text_change_listener_classes) > 0:
            for b in sublime._buffers():
                attach_buffer(b)

on_init(m.__name__)

# Synthesize any required on_activated calls
        w = sublime.active_window()
        if w:
            v = w.active_view()
            if v:
                for el in on_activated_targets:
                    try:
                        el.on_activated(v)
                    except:
                        traceback.print_exc()

for vel_cls in vel_on_activated_classes:
                    vel = find_view_event_listener(v, vel_cls)
                    if not vel:
                        continue
                    try:
                        vel.on_activated()
                    except:
                        traceback.print_exc()

elif "plugin_loaded" in m.__dict__:
        deferred_plugin_loadeds.append(m.plugin_loaded)

def synthesize_on_activated_async():
    if not api_ready:
        return

with pending_on_activated_async_lock:
        els = pending_on_activated_async_callbacks['EventListener']
        vels = pending_on_activated_async_callbacks['ViewEventListener']
        pending_on_activated_async_callbacks['EventListener'] = []
        pending_on_activated_async_callbacks['ViewEventListener'] = []

for el in els:
        w = sublime.active_window()
        if not w:
            continue
        v = w.active_view()
        if not v:
            continue
        el.on_activated_async(v)

for vel_cls in vels:
        w = sublime.active_window()
        if not w:
            continue
        v = w.active_view()
        if not v:
            continue
        vel = find_view_event_listener(v, vel_cls)
        if not vel:
            continue
        vel.on_activated_async()

def _instantiation_error(cls, e):
    rex = RuntimeError(
        "unable to instantiate "
        f"'{cls.__module__}.{cls.__name__}'"
    )
    rex.__cause__ = e
    traceback.print_exception(None, rex, None)

def notify_application_commands():
    sublime_api.notify_application_commands(create_application_commands())

def create_application_commands():
    cmds = []
    for cls in application_command_classes:
        try:
            o = cls()
            cmds.append((o, o.name()))
        except Exception as e:
            _instantiation_error(cls, e)
    return cmds

def create_window_commands(window_id):
    window = sublime.Window(window_id)
    cmds = []
    for cls in window_command_classes:
        try:
            o = cls(window)
            cmds.append((o, o.name()))
        except Exception as e:
            _instantiation_error(cls, e)
    return cmds

def create_text_commands(view_id):
    view = sublime.View(view_id)
    cmds = []
    for cls in text_command_classes:
        try:
            o = cls(view)
            cmds.append((o, o.name()))
        except Exception as e:
            _instantiation_error(cls, e)
    return cmds

def on_api_ready():
    global api_ready
    api_ready = True

for plc in deferred_plugin_loadeds:
        try:
            plc()
        except:
            traceback.print_exc()
    deferred_plugin_loadeds.clear()

# Create ViewEventListener instances
    if len(view_event_listener_classes) > 0:
        for w in sublime.windows():
            for v in w.views(include_transient=True):
                attach_view(v)

# Create TextEventListener instances
    if len(text_change_listener_classes) > 0:
        for buf in sublime._buffers():
            attach_buffer(buf)

def init():
        on_init(None)

# Synthesize an on_activated call
        w = sublime.active_window()
        if w:
            view_id = sublime_api.window_active_view(w.window_id)
            if view_id != 0:
                on_activated(view_id)

sublime.set_timeout(init)

def is_view_event_listener_applicable(cls, view):
    if not cls.is_applicable(view.settings()):
        return False

if cls.applies_to_primary_view_only() and not view.is_primary():
        return False

return True

def create_view_event_listeners(classes, view):
    if len(classes) > 0:
        if view.view_id not in view_event_listeners:
            view_event_listeners[view.view_id] = []

for c in classes:
            if is_view_event_listener_applicable(c, view):
                view_event_listeners[view.view_id].append(c(view))

def check_view_event_listeners(view):
    if len(view_event_listener_classes) > 0:
        if view.view_id not in view_event_listeners:
            view_event_listeners[view.view_id] = []

listeners = view_event_listeners[view.view_id]

for cls in view_event_listener_classes:
            found = False
            instance = None
            for l in listeners:
                if l.__class__ == cls:
                    found = True
                    instance = l
                    break

want = is_view_event_listener_applicable(cls, view)

if want and not found:
                listeners.append(cls(view))
            elif found and not want:
                listeners.remove(instance)

def attach_view(view):
    if isinstance(view, int):
        view = sublime.View(view)

check_view_event_listeners(view)

view.settings().add_on_change(
        "check_view_event_listeners",
        lambda: check_view_event_listeners(view))

check_all_view_event_listeners_scheduled = False

def check_all_view_event_listeners():
    global check_all_view_event_listeners_scheduled
    check_all_view_event_listeners_scheduled = False
    for w in sublime.windows():
        for v in w.views(include_transient=True):
            check_view_event_listeners(v)

def detach_view(view):
    if view.view_id in view_event_listeners:
        del view_event_listeners[view.view_id]

# A view has closed, which implies 'is_primary' may have changed, so see if
    # any of the ViewEventListener classes need to be created.
    # Call this in a timeout, as 'view' will still be reporting itself as a
    # primary at this stage
    global check_all_view_event_listeners_scheduled
    if not check_all_view_event_listeners_scheduled:
        check_all_view_event_listeners_scheduled = True
        sublime.set_timeout(check_all_view_event_listeners)

def find_view_event_listener(view, cls):
    if view.view_id in view_event_listeners:
        for vel in view_event_listeners[view.view_id]:
            if vel.__class__ == cls:
                return vel
    return None

def attach_buffer(buf):
    for cls in text_change_listener_classes:
        if cls.is_applicable(buf):
            cls().attach(buf)

def check_text_change_listeners(buf):
    if len(text_change_listener_classes) > 0:
        if buf.buffer_id not in text_change_listeners:
            text_change_listeners[buf.buffer_id] = []

listeners = text_change_listeners[buf.buffer_id]

for cls in text_change_listener_classes:
            found = False
            instance = None
            for l in listeners:
                if l.__class__ == cls:
                    found = True
                    instance = l
                    break

want = cls.is_applicable(buf)

if want and not found:
                cls().attach(buf)
            elif found and not want:
                instance.detach()

def detach_buffer(buf):
    if buf.buffer_id in text_change_listeners:
        listeners = text_change_listeners[buf.buffer_id]
        for tcl in listeners:
            tcl.detach()
        del text_change_listeners[buf.buffer_id]

def plugin_module_for_obj(obj):
    # Since objects in plugins may be defined deep in a sub-module, if we want
    # to filter by a module, we must make sure we are only looking at the
    # first two module labels
    cm = obj.__class__.__module__
    if cm.count('.') > 2:
        cm = '.'.join(cm.split('.', 2)[0:2])
    return cm

def el_callbacks(name, listener_only=False):
    for el in all_callbacks[name]:
        yield el if listener_only else getattr(el, name)

def vel_callbacks(v, name, listener_only=False):
    for vel in view_event_listeners.get(v.view_id, []):
        if not hasattr(vel, name):
            continue
        yield vel if listener_only else getattr(vel, name)

def run_view_callbacks(name, view_id, *args, el_only=False):
    v = sublime.View(view_id)

for callback in el_callbacks(name):
        callback(v, *args)

if el_only:
        return

for callback in vel_callbacks(v, name):
        callback(*args)

def run_window_callbacks(name, window_id, *args):
    w = sublime.Window(window_id)

for callback in el_callbacks(name):
        callback(w, *args)

def on_init(module):
    """
    Trigger the on_init() methods on EventListener and ViewEventListener
    objects. This is method that allows event listeners to run something
    once per view, even if the view is done loading before the listener
    starts listening.

:param module:
        A unicode string of the name of a plugin module to filter listeners by

:meta private:
    """

buffers = sublime._buffers()

for listener in el_callbacks('on_new_buffer', listener_only=True):
        if module is not None and plugin_module_for_obj(listener) != module:
            continue
        for b in buffers:
            listener.on_new_buffer(b)

for listener in el_callbacks('on_new_buffer_async', listener_only=True):
        if module is not None and plugin_module_for_obj(listener) != module:
            continue

def on_new_buffers_async(bufs=buffers, l=listener):
            for b in bufs:
                l.on_new_buffer_async(b)
        sublime.set_timeout_async(on_new_buffers_async, 0)

views = []

for w in sublime.windows():
        for v in w.views(include_transient=True):
            if not v.is_loading():
                views.append(v)

for listener in el_callbacks('on_init', listener_only=True):
        if module is not None and plugin_module_for_obj(listener) != module:
            continue
        listener.on_init(views)

for v in views:
        for listener in vel_callbacks(v, 'on_init', listener_only=True):
            if module is not None and plugin_module_for_obj(listener) != module:
                continue
            listener.on_init()

def on_new(view_id):
    run_view_callbacks('on_new', view_id, el_only=True)

def on_new_async(view_id):
    run_view_callbacks('on_new_async', view_id, el_only=True)

def on_new_buffer(buffer_id):
    buf = sublime.Buffer(buffer_id)

attach_buffer(buf)

for callback in el_callbacks('on_new_buffer'):
        callback(buf)

def on_new_buffer_async(buffer_id):
    buf = sublime.Buffer(buffer_id)

for callback in el_callbacks('on_new_buffer_async'):
        callback(buf)

def on_associate_buffer(buffer_id):
    buf = sublime.Buffer(buffer_id)

check_text_change_listeners(buf)

for callback in el_callbacks('on_associate_buffer'):
        callback(buf)

def on_associate_buffer_async(buffer_id):
    buf = sublime.Buffer(buffer_id)

for callback in el_callbacks('on_associate_buffer_async'):
        callback(buf)

def on_close_buffer(buffer_id):
    buf = sublime.Buffer(buffer_id)

detach_buffer(buf)

for callback in el_callbacks('on_close_buffer'):
        callback(buf)

def on_close_buffer_async(buffer_id):
    buf = sublime.Buffer(buffer_id)

for callback in el_callbacks('on_close_buffer_async'):
        callback(buf)

def on_clone(view_id):
    run_view_callbacks('on_clone', view_id, el_only=True)

def on_clone_async(view_id):
    run_view_callbacks('on_clone_async', view_id, el_only=True)

class Summary:
    def __init__(self):
        self.max = 0.0
        self.sum = 0.0
        self.count = 0

def record(self, x):
        self.count += 1
        self.sum += x
        self.max = max(self.max, x)

def get_profiling_data():
    global profile
    out = []
    for event in profile:
        data = profile[event]
        for plugin in data:
            s = data[plugin]
            out.append((event, plugin, s.count, s.max, s.sum))
    return out

def on_load(view_id):
    run_view_callbacks('on_load', view_id)

def on_load_async(view_id):
    run_view_callbacks('on_load_async', view_id)

def on_revert(view_id):
    run_view_callbacks('on_revert', view_id)

def on_revert_async(view_id):
    run_view_callbacks('on_revert_async', view_id)

def on_reload(view_id):
    run_view_callbacks('on_reload', view_id)

def on_reload_async(view_id):
    run_view_callbacks('on_reload_async', view_id)

def on_pre_close(view_id):
    run_view_callbacks('on_pre_close', view_id)

def on_close(view_id):
    v = sublime.View(view_id)
    for callback in vel_callbacks(v, 'on_close'):
        callback()
    detach_view(v)
    for callback in el_callbacks('on_close'):
        callback(v)

def on_pre_save(view_id):
    run_view_callbacks('on_pre_save', view_id)

def on_pre_save_async(view_id):
    run_view_callbacks('on_pre_save_async', view_id)

def on_post_save(view_id):
    run_view_callbacks('on_post_save', view_id)

def on_post_save_async(view_id):
    run_view_callbacks('on_post_save_async', view_id)

def on_pre_move(view_id):
    run_view_callbacks('on_pre_move', view_id)

def on_post_move(view_id):
    run_view_callbacks('on_post_move', view_id)

def on_post_move_async(view_id):
    run_view_callbacks('on_post_move_async', view_id)

def on_modified(view_id):
    run_view_callbacks('on_modified', view_id)

def on_modified_async(view_id):
    run_view_callbacks('on_modified_async', view_id)

def on_selection_modified(view_id):
    run_view_callbacks('on_selection_modified', view_id)

def on_selection_modified_async(view_id):
    run_view_callbacks('on_selection_modified_async', view_id)

def on_activated(view_id):
    run_view_callbacks('on_activated', view_id)

def on_activated_async(view_id):
    run_view_callbacks('on_activated_async', view_id)

def on_deactivated(view_id):
    run_view_callbacks('on_deactivated', view_id)

def on_deactivated_async(view_id):
    run_view_callbacks('on_deactivated_async', view_id)

def on_query_context(view_id, key, operator, operand, match_all):
    v = sublime.View(view_id)
    for callback in el_callbacks('on_query_context'):
        val = callback(v, key, operator, operand, match_all)
        if val:
            return True
    for callback in vel_callbacks(v, 'on_query_context'):
        val = callback(key, operator, operand, match_all)
        if val:
            return True
    return False

def normalise_completion(c):
    def split_trigger(trigger):
        idx = trigger.find("\t")
        if idx < 0:
            return (trigger, "")
        else:
            return (trigger[0:idx], trigger[idx + 1:])

if not isinstance(c, sublime.CompletionItem):
        if isinstance(c, str):
            trigger, annotation = split_trigger(c)
            c = sublime.CompletionItem(trigger, annotation)
        elif len(c) == 1:
            trigger, annotation = split_trigger(c[0])
            c = sublime.CompletionItem(trigger, annotation)
        elif len(c) == 2:
            trigger, annotation = split_trigger(c[0])
            c = sublime.CompletionItem.snippet_completion(
                trigger,
                c[1],
                annotation,
                kind=sublime.KIND_AMBIGUOUS
            )
        elif len(c) == 3:
            trigger, annotation = split_trigger(c[0])
            c = sublime.CompletionItem.snippet_completion(
                trigger,
                c[2],
                annotation,
                kind=sublime.KIND_AMBIGUOUS
            )
        else:
            c = sublime.CompletionItem("")

kind, kind_letter, kind_name = c.kind

letter = 0
    if isinstance(kind_letter, str) and kind_letter != '':
        letter = ord(kind_letter)
    return (c.trigger, c.annotation, c.details, c.completion, kind_name, letter, c.completion_format, c.flags, kind)

class MultiCompletionList:
    def __init__(self, num_completion_lists, view_id, req_id):
        self.remaining_calls = num_completion_lists
        self.view_id = view_id
        self.req_id = req_id
        self.completions = []
        self.flags = 0

def completions_ready(self, completions, flags):
        self.completions += [normalise_completion(c) for c in completions]
        self.flags |= flags
        self.remaining_calls -= 1

if self.remaining_calls == 0:
            sublime_api.view_set_completions(
                self.view_id, self.req_id, (self.completions, self.flags))

def on_query_completions(view_id, req_id, prefix, locations):
    v = sublime.View(view_id)

completion_lists = []

def norm_res(res):
        if isinstance(res, tuple):
            completion_lists.append(sublime.CompletionList(res[0], flags=res[1]))
        elif isinstance(res, list):
            completion_lists.append(sublime.CompletionList(res))
        elif isinstance(res, sublime.CompletionList):
            completion_lists.append(res)

for callback in el_callbacks('on_query_completions'):
        norm_res(callback(v, prefix, locations))

for callback in vel_callbacks(v, 'on_query_completions'):
        norm_res(callback(prefix, locations))

if not completion_lists:
        completion_lists = [sublime.CompletionList([])]

mlist = MultiCompletionList(len(completion_lists), view_id, req_id)
    for cl in completion_lists:
        cl._set_target(mlist)

def on_hover(view_id, point, hover_zone):
    run_view_callbacks('on_hover', view_id, point, hover_zone)

def on_text_command(view_id, name, args):
    v = sublime.View(view_id)

for callback in vel_callbacks(v, 'on_text_command'):
        res = callback(name, args)
        if isinstance(res, tuple):
            return res
        if res:
            return (res, None)

for callback in el_callbacks('on_text_command'):
        res = callback(v, name, args)
        if isinstance(res, tuple):
            return res
        if res:
            return (res, None)

return ("", None)

def on_window_command(window_id, name, args):
    w = sublime.Window(window_id)
    for callback in el_callbacks('on_window_command'):
        res = callback(w, name, args)
        if isinstance(res, tuple):
            return res
        if res:
            return (res, None)

return ("", None)

def on_post_text_command(view_id, name, args):
    run_view_callbacks('on_post_text_command', view_id, name, args)

def on_post_window_command(window_id, name, args):
    run_window_callbacks('on_post_window_command', window_id, name, args)

def on_new_project(window_id):
    run_window_callbacks('on_new_project', window_id)

def on_new_project_async(window_id):
    run_window_callbacks('on_new_project_async', window_id)

def on_load_project(window_id):
    run_window_callbacks('on_load_project', window_id)

def on_load_project_async(window_id):
    run_window_callbacks('on_load_project_async', window_id)

def on_pre_save_project(window_id):
    run_window_callbacks('on_pre_save_project', window_id)

def on_post_save_project(window_id):
    run_window_callbacks('on_post_save_project', window_id)

def on_post_save_project_async(window_id):
    run_window_callbacks('on_post_save_project_async', window_id)

def on_pre_close_project(window_id):
    run_window_callbacks('on_pre_close_project', window_id)

def on_new_window(window_id):
    run_window_callbacks('on_new_window', window_id)

def on_new_window_async(window_id):
    run_window_callbacks('on_new_window_async', window_id)

def on_pre_close_window(window_id):
    run_window_callbacks('on_pre_close_window', window_id)

def on_exit(log_path):
    # on_exit() is called once the API it shutdown, which means that stdout
    # will not be visible for debugging. Thus we write to a log file.
    stdout = io.StringIO()
    sys.stdout = stdout
    sys.stderr = stdout

for callback in el_callbacks('on_exit'):
        callback()

if len(stdout.getvalue()):
        with open(log_path, "w", encoding="utf-8") as f:
            f.write(stdout.getvalue())
    else:
        os.unlink(log_path)

class CommandInputHandler:
    """
    """

def name(self) -> str:
        """
        The command argument name this input handler is editing. Defaults to
        ``foo_bar`` for an input handler named ``FooBarInputHandler``.
        """
        clsname = self.__class__.__name__
        name = clsname[0].lower()
        last_upper = False
        for c in clsname[1:]:
            if c.isupper() and not last_upper:
                name += '_'
                name += c.lower()
            else:
                name += c
            last_upper = c.isupper()
        if name.endswith("_input_handler"):
            name = name[0:-14]
        return name

def placeholder(self) -> str:
        """
        Placeholder text is shown in the text entry box before the user has
        entered anything. Empty by default.
        """
        return ""

def initial_text(self) -> str:
        """
        Initial text shown in the text entry box. Empty by default.
        """
        return ""

def initial_selection(self) -> list[tuple[int, int]]:
        """
        A list of 2-element tuples, defining the initially selected parts of the
        initial text.

.. since:: 4081
        """
        return []

def preview(self, text: str) -> str | sublime.Html:
        """
        Called whenever the user changes the text in the entry box. The returned
        value (either plain text or HTML) will be shown in the preview area of
        the *Command Palette*.
        """
        return ""

def validate(self, text: str) -> bool:
        """
        Called whenever the user presses enter in the text entry box.
        Return :py:`False` to disallow the current value.
        """
        return True

def cancel(self):
        """
        Called when the input handler is canceled, either by the user pressing
        backspace or escape.
        """

def confirm(self, text: str):
        """
        Called when the input is accepted, after the user has pressed enter and
        the text has been validated.
        """

def next_input(self, args) -> Optional[CommandInputHandler]:
        """
        Return the next input after the user has completed this one. May return
        :py:`None` to indicate no more input is required, or
        `sublime_plugin.BackInputHandler()` to indicate that the input handler
        should be popped off the stack instead.
        """
        return None

def create_input_handler_(self, args):
        return self.next_input(args)

def preview_(self, v):
        ret = self.preview(v)

if ret is None:
            return ("", 0)
        elif isinstance(ret, sublime.Html):
            return (ret.data, 1)
        else:
            return (ret, 0)

def validate_(self, v, event):
        if self.want_event():
            return self.validate(v, event)
        return self.validate(v)

def cancel_(self):
        self.cancel()

def confirm_(self, v, event):
        if self.want_event():
            self.confirm(v, event)
        else:
            self.confirm(v)

def want_event(self) -> bool:
        """
        Whether the `validate()` and `confirm()` methods should received a
        second `Event` parameter. Returns :py:`False` by default.

.. since:: 4096
        """
        return False

class BackInputHandler(CommandInputHandler):
    """
    """

def name(self):
        return "_Back"

class TextInputHandler(CommandInputHandler):
    """
    TextInputHandlers can be used to accept textual input in the *Command
    Palette*. Return a subclass of this from `Command.input()`.

*For an input handler to be shown to the user, the command returning the
    input handler MUST be made available in the Command Palette by adding the
    command to a :path:`Default.sublime-commands` file.*
    """
    def description(self, text: str) -> str:
        """
        The text to show in the *Command Palette* when this input handler is not
        at the top of the input handler stack. Defaults to the text the user
        entered.
        """
        return text

def setup_(self, args):
        props = {
            "initial_text": self.initial_text(),
            "initial_selection": self.initial_selection(),
            "placeholder_text": self.placeholder(),
            "type": "text",
        }

return ([], props)

def description_(self, v, text):
        res = self.description(text)
        if res is None:
            return ""
        return res

class ListInputHandler(CommandInputHandler):
    """
    ListInputHandlers can be used to accept a choice input from a list items in
    the *Command Palette*. Return a subclass of this from `Command.input()`.

def list_items(self) -> list[str] | \
            tuple[list[str], int] | \
            list[tuple[str, Value]] | \
            tuple[list[tuple[str, Value]], int] | \
            list[sublime.ListInputItem] | \
            tuple[list[sublime.ListInputItem], int]:
        """
        This method should return the items to show in the list.

The returned value may be a ``list`` of item, or a 2-element ``tuple``
        containing a list of items, and an ``int`` index of the item to
        pre-select.

The each item in the list may be one of:

* A string used for both the row text and the value passed to the
          command
        * A 2-element tuple containing a string for the row text, and a `Value`
          to pass to the command
        * .. since:: 4095
            A `sublime.ListInputItem` object
        """
        return []

def description(self, value, text: str) -> str:
        """
        The text to show in the *Command Palette* when this input handler is not
        at the top of the input handler stack. Defaults to the text of the list
        item the user selected.
        """
        return text

def setup_(self, args):
        items = self.list_items()

selected_item_index = -1

if isinstance(items, tuple):
            items, selected_item_index = items

item_tuples = []
        for item in items:
            if isinstance(item, str):
                item_tuples.append((item, item))
            elif isinstance(item, (list, tuple)):
                item_tuples.append(item)
            elif isinstance(item, sublime.ListInputItem):
                details = "\x1f".join(item.details) if isinstance(item.details, (list, tuple)) else item.details
                if item.annotation != "" or item.kind != (sublime.KIND_ID_AMBIGUOUS, "", ""):
                    kind_letter = 0
                    if isinstance(item.kind[1], str) and len(item.kind[1]) == 1:
                        kind_letter = ord(item.kind[1])
                    item_tuples.append((
                        (
                            item.text,
                            details,
                            item.annotation,
                            (item.kind[0], kind_letter, item.kind[2])
                        ),
                        item.value
                    ))
                elif details is not None and details != "":
                    item_tuples.append(((item.text, details, True), item.value))
                else:
                    item_tuples.append((item.text, item.value))
            else:
                raise TypeError("items must contain only str, list, tuple or sublime.ListInputItem objects")

props = {
            "initial_text": self.initial_text(),
            "initial_selection": self.initial_selection(),
            "placeholder_text": self.placeholder(),
            "selected": selected_item_index,
            "type": "list",
        }

return (item_tuples, props)

def description_(self, v, text):
        res = self.description(v, text)
        if res is None:
            return ""
        return res

class Command:
    """
    """

def name(self) -> str:
        """
        Return the name of the command. By default this is derived from the name
        of the class.
        """
        clsname = self.__class__.__name__
        name = clsname[0].lower()
        last_upper = False
        for c in clsname[1:]:
            if c.isupper() and not last_upper:
                name += '_'
                name += c.lower()
            else:
                name += c
            last_upper = c.isupper()
        if name.endswith("_command"):
            name = name[0:-8]
        return name

def is_enabled_(self, args):
        ret = None
        try:
            args = self.filter_args(args)
            if args:
                ret = self.is_enabled(**args)
            else:
                ret = self.is_enabled()
        except TypeError:
            ret = self.is_enabled()

if not isinstance(ret, bool):
            raise ValueError("is_enabled must return a bool", self)

return ret

def is_enabled(self) -> bool:
        """
        Return whether the command is able to be run at this time. Command
        arguments are passed as keyword arguments. The default implementation
        simply always returns :py:`True`.
        """
        return True

def is_visible_(self, args):
        ret = None
        try:
            args = self.filter_args(args)
            if args:
                ret = self.is_visible(**args)
            else:
                ret = self.is_visible()
        except TypeError:
            ret = self.is_visible()

if not isinstance(ret, bool):
            raise ValueError("is_visible must return a bool", self)

return ret

def is_visible(self) -> bool:
        """
        Return whether the command should be shown in the menu at this time.
        Command arguments are passed as keyword arguments. The default
        implementation always returns :py:`True`.
        """
        return True

def is_checked_(self, args):
        ret = None
        try:
            args = self.filter_args(args)
            if args:
                ret = self.is_checked(**args)
            else:
                ret = self.is_checked()
        except TypeError:
            ret = self.is_checked()

if not isinstance(ret, bool):
            raise ValueError("is_checked must return a bool", self)

return ret

def is_checked(self) -> bool:
        """
        Return whether a checkbox should be shown next to the menu item. Command
        arguments are passed as keyword arguments. The :path:`.sublime-menu`
        file must have the ``"checkbox"`` key set to :json:`true` for this to
        be used.
        """
        return False

def description_(self, args):
        try:
            args = self.filter_args(args)
            if args is not None:
                res = self.description(**args)
            else:
                res = self.description()
            if res is None:
                return ""
            return res
        except TypeError:
            return ""

def description(self) -> Optional[str]:
        """
        Return a description of the command with the given arguments. Command
        arguments are passed as keyword arguments. Used in the menu, if no
        caption is provided. Return :py:`None` to get the default description.
        """
        return ""

def filter_args(self, args):
        if args:
            if 'event' in args and not self.want_event():
                args = args.copy()
                del args['event']

return args

def want_event(self) -> bool:
        """
        Return whether to receive an `Event` argument when the command is
        triggered by a mouse action. The event information allows commands to
        determine which portion of the view was clicked on. The default
        implementation returns :py:`False`.
        """
        return False

def input(self, args: dict) -> Optional[CommandInputHandler]:
        """
        If this returns something other than :py:`None`, the user will be
        prompted for an input before the command is run in the *Command
        Palette*.

.. since:: 3154
        """
        return None

def input_description(self) -> str:
        """
        Allows a custom name to be show to the left of the cursor in the input
        box, instead of the default one generated from the command name.

.. since:: 3154
        """
        return ""

def create_input_handler_(self, args):
        return self.input(args)

def run(self):
        """
        Called when the command is run. Command arguments are passed as keyword
        arguments.
        """

class ApplicationCommand(Command):
    """
    A `Command` instantiated just once.
    """
    def run_(self, edit_token, args):
        args = self.filter_args(args)
        try:
            if args:
                return self.run(**args)
            else:
                return self.run()
        except TypeError as e:
            if 'required positional argument' in str(e):
                if sublime_api.can_accept_input(self.name(), args):
                    sublime.active_window().run_command(
                        'show_overlay',
                        {
                            'overlay': 'command_palette',
                            'command': self.name(),
                            'args': args
                        }
                    )
                    return
            raise

def run(self):
        """ :meta private: """

class WindowCommand(Command):
    """
    A `Command` instantiated once per window. The `Window` object may be
    retrieved via `self.window <window>`.
    """

def __init__(self, window):
        """ :meta private: """

self.window: sublime.Window = window
        """ The `Window` this command is attached to. """

def run_(self, edit_token, args):
        args = self.filter_args(args)
        try:
            if args:
                return self.run(**args)
            else:
                return self.run()
        except TypeError as e:
            if 'required positional argument' in str(e):
                if sublime_api.window_can_accept_input(self.window.id(), self.name(), args):
                    sublime_api.window_run_command(
                        self.window.id(),
                        'show_overlay',
                        {
                            'overlay': 'command_palette',
                            'command': self.name(),
                            'args': args
                        }
                    )
                    return
            raise

def run(self):
        """ :meta private: """

class TextCommand(Command):
    """
    A `Command` instantiated once per `View`. The `View` object may be retrieved
    via `self.view <view>`.
    """

def __init__(self, view):
        """ :meta private: """

self.view: sublime.View = view
        """ The `View` this command is attached to. """

def run_(self, edit_token, args):
        args = self.filter_args(args)
        try:
            if args:
                edit = self.view.begin_edit(edit_token, self.name(), args)
                try:
                    return self.run(edit, **args)
                finally:
                    self.view.end_edit(edit)
            else:
                edit = self.view.begin_edit(edit_token, self.name())
                try:
                    return self.run(edit)
                finally:
                    self.view.end_edit(edit)
        except TypeError as e:
            if 'required positional argument' in str(e):
                if sublime_api.view_can_accept_input(self.view.id(), self.name(), args):
                    sublime_api.window_run_command(
                        sublime_api.view_window(self.view.id()),
                        'show_overlay',
                        {
                            'overlay': 'command_palette',
                            'command': self.name(),
                            'args': args
                        }
                    )
                    return
            raise

def run(self, edit: sublime.Edit):
        """
        Called when the command is run. Command arguments are passed as keyword
        arguments.
        """

class EventListener:
    """
    .. method:: on_init(views: List[View])

Called once with a list of views that were loaded before the
        EventListener was instantiated

.. since:: 4050

.. method:: on_exit()

Called once after the API has shut down, immediately before the
        plugin_host process exits

.. since:: 4050

.. method:: on_new(view: View)

Called when a new file is created.

.. method:: on_new_async(view: View)

Called when a new buffer is created. Runs in a separate thread, and does
        not block the application.

.. method:: on_associate_buffer(buffer: View)

Called when a buffer is associated with a file. buffer will be a Buffer
        object.

.. since:: 4084

.. method:: on_associate_buffer_async(buffer: View)

Called when a buffer is associated with file. Runs in a separate thread,
        and does not block the application. buffer will be a Buffer object.

.. since:: 4084

.. method:: on_clone(view: View)

Called when a view is cloned from an existing one.

.. method:: on_clone_async(view: View)

Called when a view is cloned from an existing one. Runs in a separate
        thread, and does not block the application.

.. method:: on_load(view: View)

Called when the file is finished loading.

.. method:: on_load_async(view: View)

Called when the file is finished loading. Runs in a separate thread, and
        does not block the application.

.. method:: on_reload(view: View)

Called when the View is reloaded.

.. since:: 4050

.. method:: on_reload_async(view: View)

Called when the View is reloaded. Runs in a separate thread, and does
        not block the application.

.. since:: 4050

.. method:: on_revert(view: View)

Called when the View is reverted.

.. since:: 4050

.. method:: on_revert_async(view: View)

Called when the View is reverted. Runs in a separate thread, and does
        not block the application.

.. since:: 4050

.. method:: on_pre_move(view: View)

Called right before a view is moved between two windows, passed the View
        object.

.. since:: 4050

.. method:: on_post_move(view: View)

Called right after a view is moved between two windows, passed the View
        object.

.. since:: 4050

.. method:: on_post_move_async(view: View)

Called right after a view is moved between two windows, passed the View
        object. Runs in a separate thread, and does not block the application.

.. since:: 4050

.. method:: on_pre_close(view: View)

Called when a view is about to be closed. The view will still be in the
        window at this point.

.. method:: on_close(view: View)

Called when a view is closed (note, there may still be other views into
        the same buffer).

.. method:: on_pre_save(view: View)

Called just before a view is saved.

.. method:: on_pre_save_async(view: View)

Called just before a view is saved. Runs in a separate thread, and does
        not block the application.

.. method:: on_post_save(view: View)

Called after a view has been saved.

.. method:: on_post_save_async(view: View)

Called after a view has been saved. Runs in a separate thread, and does
        not block the application.

.. method:: on_modified(view: View)

Called after changes have been made to a view.

.. method:: on_modified_async(view: View)

Called after changes have been made to a view. Runs in a separate
        thread, and does not block the application.

.. method:: on_selection_modified(view: View)

Called after the selection has been modified in a view.

.. method:: on_selection_modified_async(view: View)

Called after the selection has been modified in a view. Runs in a
        separate thread, and does not block the application.

.. method:: on_activated(view: View)

Called when a view gains input focus.

.. method:: on_activated_async(view: View)

Called when a view gains input focus. Runs in a separate thread, and
        does not block the application.

.. method:: on_deactivated(view: View)

Called when a view loses input focus.

.. method:: on_deactivated_async(view: View)

Called when a view loses input focus. Runs in a separate thread, and
        does not block the application.

.. method:: on_hover(view: View, point: Point, hover_zone: HoverZone)

Called when the user's mouse hovers over the view for a short period.

:param view: The view
        :param point:
            The closest point in the view to the mouse location. The mouse may
            not actually be located adjacent based on the value of
            ``hover_zone``.
        :param hover_zone:
            Which element in Sublime Text the mouse has hovered over.

.. method:: on_query_context(\
            view: View, key: str, operator: QueryOperator, operand: str, match_all: bool) -> Optional[bool]

Called when determining to trigger a key binding with the given context
        key. If the plugin knows how to respond to the context, it should
        return either True of False. If the context is unknown, it should
        return None.

:param key:
            The context key to query. This generally refers to specific state
            held by a plugin.
        :param operator:
            The operator to check against the operand; whether to check
            equality, inequality, etc.
        :param operand: The value against which to check using the ``operator``.
        :param match_all:
            This should be used if the context relates to the selections: does
            every selection have to match(``match_all == True``), or is at
            least one matching enough (``match_all == False``)?
        :returns:
            ``True`` or ``False`` if the plugin handles this context key and it
            either does or doesn't match. If the context is unknown return
            ``None``.

.. method:: on_query_completions(view: View, prefix: str, locations: List[Point]) -> Union[\
            None, List[CompletionValue], Tuple[List[CompletionValue], AutoCompleteFlags], CompletionList]

Called whenever completions are to be presented to the user.

:param prefix: The text already typed by the user.
        :param locations: The list of points being completed. Since this method
                          is called for all completions no matter the syntax,
                          ``self.view.match_selector(point, relevant_scope)``
                          should be called to determine if the point is
                          relevant.
        :returns: A list of completions in one of the valid formats or ``None`` if no completions are provided.

.. method:: on_text_command(view: View, command_name: str, args: CommandArgs) -> (str, CommandArgs)

Called when a text command is issued. The listener may return a
        (command, arguments) tuple to rewrite the command, or ``None`` to run
        the command unmodified.

.. method:: on_window_command(window: Window, command_name: str, args: CommandArgs) -> (str, CommandArgs)

Called when a window command is issued. The listener may return a
        (command, arguments) tuple to rewrite the command, or ``None`` to run
        the command unmodified.

.. method:: on_post_text_command(view: View, command_name: str, args: CommandArgs)

Called after a text command has been executed.

.. method:: on_post_window_command(window: Window, command_name: str, args: CommandArgs)

Called after a window command has been executed.

.. method:: on_new_window(window: Window)

Called when a window is created, passed the Window object.

.. since:: 4050

.. method:: on_new_window_async(window: Window)

Called when a window is created, passed the Window object. Runs in a
        separate thread, and does not block the application.

.. since:: 4050

.. method:: on_pre_close_window(window: Window)

Called right before a window is closed, passed the Window object.

.. since:: 4050

.. method:: on_new_project(window: Window)

Called right after a new project is created, passed the Window object.

.. since:: 4050

.. method:: on_new_project_async(window: Window)

Called right after a new project is created, passed the Window object.
        Runs in a separate thread, and does not block the application.

.. since:: 4050

.. method:: on_load_project(window: Window)

Called right after a project is loaded, passed the Window object.

.. since:: 4050

.. method:: on_load_project_async(window: Window)

Called right after a project is loaded, passed the Window object. Runs
        in a separate thread, and does not block the application.

.. since:: 4050

.. method:: on_pre_save_project(window: Window)

Called right before a project is saved, passed the Window object.

.. since:: 4050

.. method:: on_post_save_project(window: Window)

Called right after a project is saved, passed the Window object.

.. since:: 4050

.. method:: on_post_save_project_async(window: Window)

Called right after a project is saved, passed the Window object. Runs in
        a separate thread, and does not block the application.

.. since:: 4050

.. method:: on_pre_close_project(window: Window)

Called right before a project is closed, passed the Window object.
    """

class ViewEventListener:
    """
     A class that provides similar event handling to `EventListener`, but bound
     to a specific view. Provides class method-based filtering to control what
     views objects are created for.

.. method:: on_load()

Called when the file is finished loading.

.. since:: 3155

.. method:: on_load_async()

Same as `on_load` but runs in a separate thread, not blocking the
        application.

.. since:: 3155

.. method:: on_reload()

Called when the file is reloaded.

.. since:: 4050

.. method:: on_reload_async()

Same as `on_reload` but runs in a separate thread, not blocking the
        application.

.. since:: 4050

.. method:: on_revert()

Called when the file is reverted.

.. since:: 4050

.. method:: on_revert_async()

Same as `on_revert` but runs in a separate thread, not blocking the
        application.

.. since:: 4050

.. method:: on_pre_move()

Called right before a view is moved between two windows.

.. since:: 4050

.. method:: on_post_move()

Called right after a view is moved between two windows.

.. since:: 4050

.. method:: on_post_move_async()

Same as `on_post_move` but runs in a separate thread, not blocking the
        application.

.. since:: 4050

.. method:: on_pre_close()

Called when a view is about to be closed. The view will still be in the
        window at this point.

.. since:: 3155

.. method:: on_close()

Called when a view is closed (note, there may still be other views into
        the same buffer).

.. since:: 3155

.. method:: on_pre_save()

Called just before a view is saved.

.. since:: 3155

.. method:: on_pre_save_async()

Same as `on_pre_save` but runs in a separate thread, not blocking the
        application.

.. since:: 3155

.. method:: on_post_save()

Called after a view has been saved.

.. since:: 3155

.. method:: on_post_save_async()

Same as `on_post_save` but runs in a separate thread, not blocking the
        application.

.. since:: 3155

.. method:: on_modified()

Called after changes have been made to the view.

.. method:: on_modified_async()

Same as `on_modified` but runs in a separate thread, not blocking the
        application.

.. method:: on_selection_modified()

Called after the selection has been modified in the view.

.. method:: on_selection_modified_async()

Called after the selection has been modified in the view. Runs in a
        separate thread, and does not block the application.

.. method:: on_activated()

Called when a view gains input focus.

.. method:: on_activated_async()

Called when the view gains input focus. Runs in a separate thread, and
        does not block the application.

.. method:: on_deactivated()

Called when the view loses input focus.

.. method:: on_deactivated_async()

Called when the view loses input focus. Runs in a separate thread, and
        does not block the application.

.. method:: on_hover(point: Point, hover_zone: HoverZone)

Called when the user's mouse hovers over the view for a short period.

:param point:
            The closest point in the view to the mouse location. The mouse may
            not actually be located adjacent based on the value of
            ``hover_zone``.
        :param hover_zone:
            Which element in Sublime Text the mouse has hovered over.

.. method:: on_query_context(key: str, operator: QueryOperator, operand: str, match_all: bool) -> Optional[bool]

:param key: The context key to query. This generally refers to specific
                    state held by a plugin.
        :param operator: The operator to check against the operand; whether to
                         check equality, inequality, etc.
        :param operand: The value against which to check using the ``operator``.
        :param match_all: This should be used if the context relates to the
                          selections: does every selection have to match
                          (``match_all == True``), or is at least one matching
                          enough (``match_all == False``)?
        :returns: ``True`` or ``False`` if the plugin handles this context key
                  and it either does or doesn't match. If the context is unknown
                  return ``None``.

.. method:: on_query_completions(prefix: str, locations: List[Point]) -> Union[\
            None, List[CompletionValue], Tuple[List[CompletionValue], AutoCompleteFlags], CompletionList]

Called whenever completions are to be presented to the user.

.. method:: on_text_command(command_name: str, args: CommandArgs) -> Tuple[str, CommandArgs]

Called when a text command is issued. The listener may return a
        `` (command, arguments)`` tuple to rewrite the command, or ``None`` to
        run the command unmodified.

.. since:: 3155

.. method:: on_post_text_command(command_name: str, args: CommandArgs)

Called after a text command has been executed.
    """

@classmethod
    def is_applicable(cls, settings: sublime.Settings) -> bool:
        """
        :returns: Whether this listener should apply to a view with the given `Settings`.
        """
        return True

@classmethod
    def applies_to_primary_view_only(cls) -> bool:
        """
        :returns: Whether this listener should apply only to the primary view
                  for a file or all of its clones as well.
        """
        return True

def __init__(self, view: sublime.View):
        self.view: sublime.View = view

class TextChangeListener:
    """
    A class that provides event handling about text changes made to a specific
    Buffer. Is separate from `ViewEventListener` since multiple views can
    share a single buffer.

.. since:: 4081

.. method:: on_text_changed(changes: List[TextChange])

Called once after changes has been made to a buffer, with detailed
        information about what has changed.

.. method:: on_text_changed_async(changes: List[TextChange]):

Same as `on_text_changed` but runs in a separate thread, not blocking
        the application.

.. method:: on_revert()

Called when the buffer is reverted.

A revert does not trigger text changes. If the contents of the buffer
        are required here use `View.substr`.

.. method:: on_revert_async()

Same as `on_revert` but runs in a separate thread, not blocking the
        application.

.. method:: on_reload()

Called when the buffer is reloaded.

A reload does not trigger text changes. If the contents of the buffer
        are required here use `View.substr`.

.. method:: on_reload_async()

Same as `on_reload` but runs in a separate thread, not blocking the
        application.
    """

@classmethod
    def is_applicable(cls, buffer: sublime.Buffer):
        """
        :returns: Whether this listener should apply to the provided buffer.
        """
        return True

def __init__(self):
        """ """
        self.__key = None
        self.buffer: sublime.Buffer = None

def detach(self):
        """
        Remove this listener from the buffer.

Async callbacks may still be called after this, as they are queued
        separately.

:raises ValueError: if the listener is not attached.
        """
        if self.__key is None:
            raise ValueError('TextChangeListener is not attached')

sublime_api.buffer_clear_text_listener(self.buffer.buffer_id, self.__key)
        if self.buffer.buffer_id in text_change_listeners:
            new_listeners = []
            for listener in text_change_listeners[self.buffer.buffer_id]:
                if listener is not self:
                    new_listeners.append(listener)
            text_change_listeners[self.buffer.buffer_id] = new_listeners
        self.__key = None

def attach(self, buffer: sublime.Buffer):
        """
        Attach this listener to a buffer.

:raises ValueError: if the listener is already attached.
        """
        if not isinstance(buffer, sublime.Buffer):
            raise TypeError('Must be a buffer')

if self.__key is not None:
            raise ValueError('TextChangeListener is already attached')

self.buffer = buffer
        if buffer.buffer_id not in text_change_listeners:
            text_change_listeners[buffer.buffer_id] = []
        text_change_listeners[buffer.buffer_id].append(self)
        self.__key = sublime_api.buffer_add_text_listener(buffer.buffer_id, self)

def is_attached(self) -> bool:
        """
        :returns:
            whether the listener is receiving events from a buffer. May not be
            called from ``__init__``.
        """
        return self.__key is not None

class MultizipImporter(importlib.abc.MetaPathFinder):
    """ :meta private: """

def __init__(self):
        self.loaders = []

def _make_spec(self, loader, fullname):
        """
        :param loader:
            The importlib.abc.Loader to create the ModuleSpec from

:param fullname:
            A unicode string of the module name

:return:
            An instance of importlib.machinery.ModuleSpec()
        """

origin, is_package = loader._spec_info(fullname)
        spec = importlib.util.spec_from_loader(
            fullname,
            loader,
            origin=origin,
            is_package=is_package
        )
        if is_package:
            spec.submodule_search_locations = [loader.zippath]
        return spec

def find_spec(self, fullname, path, target=None):
        """
        :param fullname:
            A unicode string of the module name

:param path:
            None or a list with a single unicode string of the __path__ of
            the parent module if importing a submodule

:param target:
            Unused - extra info that importlib may provide?

:return:
            An importlib.machinery.ModuleSpec() object
        """

if not path:
            for l in self.loaders:
                if l.has(fullname):
                    return self._make_spec(l, fullname)

for l in self.loaders:
            if path == [l.zippath] and l.has(fullname):
                return self._make_spec(l, fullname)

return None

class ZipResourceReader(importlib.abc.ResourceReader):
    """
    Implements the resource reader interface introduced in Python 3.7

:meta private:
    """

def __init__(self, loader, fullname):
        """
        :param loader:
            The source ZipLoader() object

:param fullname:
            A unicode string of the module name to load resources for
        """

self.loader = loader
        self.fullname = fullname

def open_resource(self, resource):
        """
        :param resource:
            A unicode string of a resource name - should not contain a path
            separator

:raises:
            FileNotFoundError - when the resource doesn't exist

:return:
            An io.BytesIO() object
        """

rel_zip_path = self.loader.resources.get(self.fullname, {}).get(resource)
        if not rel_zip_path:
            raise FileNotFoundError()
        with zipfile.ZipFile(self.loader.zippath, 'r') as z:
            return io.BytesIO(z.read(rel_zip_path))

def resource_path(self, resource):
        """
        :param resource:
            A unicode string of a resource name - should not contain a path
            separator

:raises:
            FileNotFoundError - always, since there is no normal filesystem access
        """

raise FileNotFoundError()

def is_resource(self, name):
        """
        :param name:
            A unicode string of a file name to check if it is a resource

:return:
            A boolean indicating if the file is a resource
        """

return name in self.loader.resources.get(self.fullname, {})

def contents(self):
        """
        :return:
            A list of the resources for this module
        """

return sorted([k for k in self.loader.resources.get(self.fullname, {})])

class ZipLoader(importlib.abc.InspectLoader):
    """
    A custom Python loader that handles loading .py and .pyc files from
    .sublime-package zip files, and supports overrides where a loose file in
    the Packages/ folder of the data dir may be loaded instead of a file in
    the .sublime-package file.

:meta private:
    """

def __init__(self, zippath):
        """
        :param zippath:
            A unicode string of the full filesystem path to the zip file
        """

self.zippath = zippath
        self.name = os.path.splitext(os.path.basename(zippath))[0]
        self._scan_zip()

def _get_name_key(self, fullname):
        """
        Converts a module name into a pair of package name and key. The
        key is used to access the various data structures in this object.

:param fullname:
            A unicode string of a module name

:return:
            If the fullname is not a module in this package, (None, None),
            otherwise a 2-element tuple of unicode strings. The first element
            being the package name, and the second being a sub-module, e.g.
            ("Default", "indentation").
        """

if '.' not in fullname:
            if fullname == self.name:
                return (self.name, '')
            return (None, None)

name, key = fullname.split('.', 1)
        if name != self.name:
            return (None, None)
        return (self.name, key)

def has(self, fullname):
        """
        Checks if the module is handled by this loader

:param fullname:
            A unicode string of the module to check

:return:
            A boolean if the module is handled by this loader
        """

name, key = self._get_name_key(fullname)
        if name is None:
            return False

# We can check this first before overrides since if this exists we
        # know at the very least it will be loaded from the zip
        if name == self.name and key in self.contents:
            return True

rel_base = os.sep.join(fullname.split('.'))
        override_file = os.path.join(override_path, rel_base + '.py')
        if os.path.isfile(override_file):
            return True

# Here we check to see if an override dir exists, in general, even if
        # there is no __init__.py. We do this since we allow users to override
        # a sub-module without ensuring there is a perfect filesystem
        # heirarchy of __init__.py files when traversing upwards.
        override_package = os.path.join(override_path, rel_base)
        if os.path.isdir(override_package):
            return True

return False

def get_resource_reader(self, fullname):
        """
        :param fullname:
            A unicode string of the module name to get the resource reader for

:return:
            None if the module is not a package, otherwise an object that
            implements the importlib.abc.ResourceReader() interface
        """

if not self.is_package(fullname):
            return None
        return ZipResourceReader(self, fullname)

def get_filename(self, fullname):
        """
        :param fullname:
            A unicode string of the module name

:raises:
            ImportError - when the module has no file path

:return:
            A unicode string of the file path to the module
        """

info = self._spec_info(fullname)
        if info[0] is None:
            raise ImportError()
        return info[0]

def get_code(self, fullname):
        """
        :param fullname:
            A unicode string of the module to get the code for

:raises:
            ModuleNotFoundError - when the module is not part of this zip file
            ImportError - when there is an error loading the code

:return:
            A code object for the module
        """

info = self._spec_info(fullname)
        if info[0] is None:
            raise ModuleNotFoundError(f'No module named {repr(fullname)}')

if not info[0].endswith('.pyc'):
            return importlib.abc.InspectLoader.source_to_code(
                self._load_source(fullname, info[0]),
                info[0]
            )

_, key = self._get_name_key(fullname)
        data = self.contents[key]
        magic = data[0:4]
        if importlib.util.MAGIC_NUMBER != magic:
            raise ImportError(f'bad magic number in {repr(fullname)}: {repr(magic)}')
        # From importlib._bootstrap_external._code_to_timestamp_pyc()
        return marshal.loads(data[16:])

def get_source(self, fullname):
        """
        :param fullname:
            A unicode string of the module to get the source for

:raises:
            ModuleNotFoundError - when the module is not part of this zip file
            ImportError - when there is an error loading the source file

:return:
            A unicode string of the source code, or None if there is no source
            for the module (i.e. a .pyc file)
        """

info = self._spec_info(fullname)
        if info[0] is None:
            raise ModuleNotFoundError(f'No module named {repr(fullname)}')

# If a sourceless file is loaded from the file, there is no source
        if info[0].endswith('.pyc'):
            return None

return self._load_source(fullname, info[0])

def _load_source(self, fullname, path):
        """
        Loads the source code to the module

:param fullname:
            A unicode string of the module name

:param path:
            A filesystem path to the module - may be a path into s
            .sublime-package file

:return:
            A unicode string
        """

if path == self.zippath or path.startswith(self.zippath + os.sep):
            _, key = self._get_name_key(fullname)
            if key in self.contents:
                return self.contents[key]
            raise ModuleNotFoundError(f'No module named {repr(fullname)}')

if os.path.isdir(path):
            return ''

try:
            with open(path, 'r', encoding='utf-8') as f:
                return f.read()
        except (Exception) as e:
            print(f'Error reading {path}: {e}')
            raise ImportError(f'Unable to load {repr(fullname)}')

def is_package(self, fullname):
        """
        :param fullname:
            A unicode string of the module to see if it is a package

:return:
            A boolean if the module is a package
        """

info = self._spec_info(fullname)
        if info[1] is None:
            raise ModuleNotFoundError(f'No module named {repr(fullname)}')
        return info[1]

def _spec_info(self, fullname):
        """
        :param fullname:
            A unicode string of the module that an
            importlib.machinery.ModuleSpec() object is going to be created for

:return:
            A 2-element tuple of:
             - (None, None) if the loader does not know about the module
             - (unicode string, bool) of the origin and is_package params to
               pass to importlib.machinery.ModuleSpec()
        """

rel_base = os.sep.join(fullname.split('.'))
        name, key = self._get_name_key(fullname)
        if name is None:
            return (None, None)

if key != '':
            rel_py_path = rel_base + '.py'
            override_py_file = os.path.join(override_path, rel_py_path)
            if os.path.isfile(override_py_file):
                return (override_py_file, False)

in_zip = name == self.name and key in self.contents
        zip_filename = None if not in_zip else self.filenames[key]

# We don't return files named __init__.py here to ensure that any
        # override that exists gets picked up instead.
        if in_zip and os.path.basename(zip_filename) != '__init__.py':
            return (
                os.path.join(self.zippath, zip_filename).rstrip(os.sep),
                key in self.packages
            )

rel_init_path = rel_base + os.sep + '__init__.py'
        override_init_file = os.path.join(override_path, rel_init_path)
        if os.path.isfile(override_init_file):
            return (override_init_file, True)

# This only handle __init__.py in the zip. It has to be placed after
        # the check for the override file.
        if in_zip:
            return (
                os.path.join(self.zippath, zip_filename),
                key in self.packages
            )

# This is necessary to support overrides in a subdir of a package
        # when there is no __init__.py file in one of the parents
        override_dir = os.path.join(override_path, rel_base)
        if os.path.isdir(override_dir):
            return (override_dir, True)

return (None, None)

def _scan_zip(self):
        """
        Rebuild the internal cached info about the contents of the zip
        """

self.contents = {'': ''}
        self.filenames = {'': ''}
        self.packages = {''}
        self.resources = {}
        self.refreshed = time.time()

try:
            with zipfile.ZipFile(self.zippath, 'r') as z:
                files = [i.filename for i in z.infolist()]

for f in files:
                    base, ext = os.path.splitext(f)

if ext != '.py' and ext != '.pyc':
                        rmod, rname = os.path.split(f)
                        rmod = rmod.replace('/', '.').replace('\\', '.')
                        rmod = (self.name + '.' + rmod).rstrip('.')
                        if rmod not in self.resources:
                            self.resources[rmod] = {}
                        self.resources[rmod][rname] = f
                        continue

paths = base.split('/')
                    if len(paths) > 0 and paths[len(paths) - 1] == '__init__':
                        paths.pop()
                        self.packages.add('.'.join(paths))

pkg_path = '.'.join(paths)
                    if f.endswith('.pyc'):
                        self.contents[pkg_path] = z.read(f)
                    else:
                        try:
                            self.contents[pkg_path] = z.read(f).decode('utf-8')
                        except UnicodeDecodeError:
                            print(
                                f'{os.path.join(self.zippath, f)} is not '
                                'utf-8 encoded, unable to load plugin'
                            )
                            continue
                    self.filenames[pkg_path] = f

while len(paths) > 1:
                        paths.pop()
                        parent = '.'.join(paths)
                        if parent not in self.contents:
                            self.contents[parent] = ''
                            self.filenames[parent] = parent
                            self.packages.add(parent)
        except (Exception) as e:
            print(f'Error loading {self.zippath}: {e}')

override_path = None
multi_importer = MultizipImporter()
sys.meta_path.insert(0, multi_importer)

def update_compressed_packages(pkgs):
    multi_importer.loaders = []
    for p in pkgs:
        try:
            multi_importer.loaders.append(ZipLoader(p))
        except (FileNotFoundError, zipfile.BadZipFile) as e:
            print("error loading " + p + ": " + str(e))

def set_override_path(path):
    global override_path
    override_path = path

${this.title}

Code Editor : sublime_plugin.py