New structure, new windows notification package.

Author: koltenfluckiger

Release/com.koltenfluckiger.streamdeck-python-plugin.streamDeckPlugin

@@ -1,6 +1,6 @@
 import asyncio
 import logging
-
+import traceback
 
 class Command:
 
@@ -18,8 +18,10 @@ async def execute(self):
             logging.info("Output: {}".format(output))
             logging.info("Error Code: {}".format(code))
             if self.return_flag:
-                return {"output": output, "code": code}
+                return {"output": output, "code": code, "error": stderr.decode().strip()}
             else:
                 return None
         except Exception as err:
             logging.critical("ERROR: {}".format(err))
+            logging.critical(f"Traceback: {traceback.format_exc()}")
+            

Source/plugin/binaries/koltenfluckiger.streamdeck-python-plugin

@@ -4,7 +4,9 @@
 import re
 import json
 import websockets
-
+import os
+import pathlib
+import traceback
 from logging.handlers import RotatingFileHandler
 
 from process import ProcessManager
@@ -13,11 +15,14 @@
 from notifier import Notifier
 from command import Command
 
+
 logging.basicConfig(
-        handlers=[RotatingFileHandler('debug.log', maxBytes=100000, backupCount=10)],
-        level=logging.DEBUG,
-        format="[%(asctime)s] %(levelname)s [%(name)s.%(funcName)s:%(lineno)d] %(message)s",
-        datefmt='%Y-%m-%dT%H:%M:%S')
+    handlers=[RotatingFileHandler(
+        f'{pathlib.Path(os.environ["TEMP"]).joinpath("debug.log").resolve()}', maxBytes=100000, backupCount=10)],
+    level=logging.DEBUG,
+    format="[%(asctime)s] %(levelname)s [%(name)s.%(funcName)s:%(lineno)d] %(message)s",
+    datefmt='%Y-%m-%dT%H:%M:%S')
+
 
 class Plugin(object):
 
@@ -37,6 +42,7 @@ def __del__(self):
             self.loop.close()
         except Exception as err:
             logging.critical(err)
+            logging.critical(f"Traceback: {traceback.format_exc()}")
 
     async def listen(self):
         try:
@@ -45,14 +51,16 @@ async def listen(self):
             await self.on_message()
         except Exception as err:
             logging.critical(err)
+            logging.critical(f"Traceback: {traceback.format_exc()}")
 
     async def _init_websocket(self):
         uri = "ws://localhost:{}".format(self.port)
         try:
-            self.websocket = await websockets.client.connect(uri)
+            self.websocket = await websockets.connect(uri)
             return
         except Exception as err:
             logging.critical(err)
+            logging.critical(f"Traceback: {traceback.format_exc()}")
 
     async def _register_websocket(self):
         try:
@@ -66,20 +74,23 @@ async def _register_websocket(self):
             return
         except Exception as err:
             logging.critical(err)
+            logging.critical(f"Traceback: {traceback.format_exc()}")
 
     async def on_message(self):
         try:
             async for message in self.websocket:
                 await self.process_data(json.loads(message))
         except Exception as err:
             logging.critical(err)
+            logging.critical(f"Traceback: {traceback.format_exc()}")
 
     async def send_message(self, event):
         try:
             logging.info("Sending event: {}".format(event))
             await self.websocket.send(event)
         except Exception as err:
             logging.critical(err)
+            logging.critical(f"Traceback: {traceback.format_exc()}")
 
     def generate_command(self, data):
         try:
@@ -93,6 +104,7 @@ def generate_command(self, data):
             return new_command
         except Exception as err:
             logging.critical(err)
+            logging.critical(f"Traceback: {traceback.format_exc()}")
 
     async def process_data(self, data):
         logging.info("Processing data: {}".format(data))
@@ -111,6 +123,7 @@ async def process_data(self, data):
 
         except Exception as err:
             logging.critical(err)
+            logging.critical(f"Traceback: {traceback.format_exc()}")
 
 
 def parse_args(sys_args):
@@ -128,31 +141,34 @@ def parse_args(sys_args):
                 logging.info("Flag: {}, Value: {}".format(flag, value))
         except Exception as err:
             logging.critical(err)
+            logging.critical(f"Traceback: {traceback.format_exc()}")
     return args
 
 
 def main():
     try:
         args = parse_args(sys.argv)
-        loop = asyncio.get_event_loop()
-
+        logging.info(args)
+        loop = asyncio.new_event_loop()
+        eloop = asyncio.get_event_loop()
         os_manager = OSManager()
         os_type = os_manager._get_current_os()
         notifier = Notifier(os_type)
         process_manager = ProcessManager(notifier)
 
         plugin = Plugin(port=args['port'], pluginUUID=args['pluginUUID'],
-                        registerEvent=args['registerEvent'], info=args['info'], loop=loop, process_manager=process_manager, os_manager=os_manager)
+                        registerEvent=args['registerEvent'], info=args['info'], loop=eloop, process_manager=process_manager, os_manager=os_manager)
 
-        loop.run_until_complete(asyncio.gather(
+        eloop.run_until_complete(asyncio.gather(
             plugin.listen(), process_manager.process()))
-        loop.run_forever()
-        loop.stop()
-        loop.close()
+        eloop.run_forever()
+        eloop.stop()
+        eloop.close()
     except Exception as err:
         logging.critical(err)
-        loop.stop()
-        loop.close()
+        logging.critical(f"Traceback: {traceback.format_exc()}")
+        eloop.stop()
+        eloop.close()
 
 
 if __name__ == '__main__':

Source/plugin/binaries/koltenfluckiger.streamdeck-python-plugin.exe

@@ -2,22 +2,23 @@
     from operatingsystem import OSTYPE
     import platform
     import logging
+    import traceback
     if 'windows' in platform.system().lower():
-        from plyer.platforms.win.notification import instance as WinInstance
+        from pywintoaster.toaster import Toaster
     elif 'linux' in platform.system().lower():
         from plyer.platforms.linux.notification import instance as LinuxInstance
     elif 'mac' in platform.system().lower():
         from plyer.platforms.macosx.notification import instance as OSXInstance
 except ImportError as err:
     logging.critical("Import error: {}".format(err))
-
+    logging.critical(f"Traceback: {traceback.format_exc()}")
 
 class Notifier():
 
     def __init__(self, OS):
         if OS == OS.WINDOWS:
-            self.instance = WinInstance()
-        elif OS == OS.LINUX:
+            self.instance = Toaster(group="StreamDeck Python Plugin")
+        elif OS == OS.UNIX:
             self.instance = LinuxInstance()
         elif OS == OS.MACOS:
             self.instance = OSXInstance()
@@ -27,3 +28,4 @@ def notify(self, title, message):
             self.instance.notify(title=title, message=message)
         except Exception as err:
             logging.critical("Notify Error: {}".format(err))
+            logging.critical(f"Traceback: {traceback.format_exc()}")