update

Author: bierdok

setup.py

@@ -2,7 +2,7 @@
 
 setup(
     name='talkops',
-    version='1.0.15',
+    version='1.1.0',
     author='PicoUX',
     description="TalkOps SDK",
     long_description=open('README.md',encoding='utf-8').read(),

talkops/extension.py

@@ -25,11 +25,16 @@ def __init__(self, token=None):
         self._instructions = None
         self._name = None
         self._parameters = []
+        self._publisher = None
         self._software_version = None
+        self._started = False
         self._token = token or os.environ.get('TALKOPS_TOKEN')
         self._website = None
 
     async def _setup(self):
+        if self._started:
+            return
+        self._started = True
         await asyncio.sleep(0.5)
         if self._token:
             mercure = json.loads(base64.b64decode(self._token).decode())

talkops/publisher.py

@@ -1,18 +1,16 @@
+from urllib.parse import urlencode
 import json
 import requests
 import time
 import sys
 import threading
-from urllib.parse import urlencode
 
 class Publisher:
     def __init__(self, use_config, use_state):
         self._use_config = use_config
         self._use_state = use_state
         self._last_event_state = None
         self._last_ping_at = None
-        threading.Timer(0.4, lambda: self._publish_data(json.dumps({'type': 'init'}))).start()
-        threading.Timer(0.5, self._publish_state).start()
         self._original_stdout_write = sys.stdout.write
         self._original_stderr_write = sys.stderr.write
         def stdout_wrapper(chunk):
@@ -21,17 +19,17 @@ def stdout_wrapper(chunk):
                 'data': chunk.strip()
             })
             return self._original_stdout_write(chunk)
-
         def stderr_wrapper(chunk):
             if b"KeyboardInterrupt" not in chunk:
                 self.publish_event({
                     'type': 'stderr',
                     'data': chunk.strip()
                 })
             return self._original_stderr_write(chunk)
-
         sys.stdout.write = stdout_wrapper
         sys.stderr.write = stderr_wrapper
+        self._publish_data(json.dumps({'type': 'init'}))
+        threading.Timer(0.1, self._publish_state).start()
 
     def publish_state(self):
         event = {'type': 'state', 'state': self._use_state()}