Small fixes

This commit is contained in:
2022-06-18 22:27:17 -05:00
parent 793621745a
commit 111c535876
5 changed files with 28 additions and 35 deletions

View File

@@ -9,13 +9,13 @@ from gi.repository import Gtk
# Application imports
# NOTE: Threads will not die with parent's destruction
# NOTE: Threads WILL NOT die with parent's destruction.
def threaded(fn):
def wrapper(*args, **kwargs):
threading.Thread(target=fn, args=args, kwargs=kwargs, daemon=False).start()
return wrapper
# NOTE: Insure threads die with parent's destruction
# NOTE: Threads WILL die with parent's destruction.
def daemon_threaded(fn):
def wrapper(*args, **kwargs):
threading.Thread(target=fn, args=args, kwargs=kwargs, daemon=True).start()
@@ -39,18 +39,11 @@ class Plugin:
button = Gtk.Button(label=self._plugin_name)
button.connect("button-release-event", self.send_message)
# self._module_event_observer() # NOTE: Enable if you want the plugin to watch for events sent to it
plugin_list = self._builder.get_object("plugin_socket")
plugin_list.add(button)
plugin_list.show_all()
def send_message(self, widget=None, eve=None):
message = "Hello, World!"
self._event_system.push_gui_event([self._plugin_name, "display_message", ("warning", message, None)])
def get_plugin_name(self):
return self._plugin_name
@@ -63,6 +56,12 @@ class Plugin:
def get_socket_id(self):
return self._socket_id
def send_message(self, widget=None, eve=None):
message = "Hello, World!"
self._event_system.push_gui_event([self._plugin_name, "display_message", ("warning", message, None)])
@daemon_threaded
def _module_event_observer(self):
while True:

View File

@@ -9,13 +9,13 @@ from gi.repository import Gtk
# Application imports
# NOTE: Threads will not die with parent's destruction
# NOTE: Threads WILL NOT die with parent's destruction.
def threaded(fn):
def wrapper(*args, **kwargs):
threading.Thread(target=fn, args=args, kwargs=kwargs, daemon=False).start()
return wrapper
# NOTE: Insure threads die with parent's destruction
# NOTE: Threads WILL die with parent's destruction.
def daemon_threaded(fn):
def wrapper(*args, **kwargs):
threading.Thread(target=fn, args=args, kwargs=kwargs, daemon=True).start()
@@ -36,16 +36,26 @@ class Plugin:
self._event_sleep_time = .5
self._fm_event_message = None
self._module_event_observer()
button = Gtk.Button(label=self._plugin_name)
button.connect("button-release-event", self._do_download)
self._module_event_observer()
plugin_list = self._fm_builder.get_object("plugin_socket")
plugin_list.add(button)
plugin_list.show_all()
def get_plugin_name(self):
return self._plugin_name
def get_plugin_author(self):
return self._plugin_author
def get_plugin_version(self):
return self._plugin_version
@daemon_threaded
def _module_event_observer(self):
while True:
@@ -74,13 +84,3 @@ class Plugin:
state = self._fm_event_message
subprocess.Popen([f'{self.SCRIPT_PTH}/download.sh' , state.tab.get_current_directory()])
self._fm_event_message = None
def get_plugin_name(self):
return self._plugin_name
def get_plugin_author(self):
return self._plugin_author
def get_plugin_version(self):
return self._plugin_version