hemna/aprsd-telegram-plugin
1
0
Fork 0
mirror of https://github.com/hemna/aprsd-telegram-plugin.git synced 2024-11-24 00:48:57 -05:00
Code Issues Projects Releases Wiki Activity

remove trace

Browse Source
This commit is contained in:
Hemna 2022-12-02 14:00:17 -05:00
parent 547c326a09
commit 108ea07f60
2 changed files with 34 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
ChangeLog
View File

@ -4,6 +4,7 @@ CHANGES
v0.1.2
------
* for v0.1.2
* for v0.1.1
* Use the pbr version of the package as plugin version

19
aprsd_telegram_plugin/telegram.py
View File

@ -3,7 +3,7 @@ import logging
import threading
import time
from aprsd import messaging, objectstore, plugin, threads, trace
from aprsd import messaging, objectstore, plugin, threads
from telegram.ext import Filters, MessageHandler, Updater
import aprsd_telegram_plugin
@ -101,11 +101,19 @@ class TelegramChatPlugin(plugin.APRSDRegexCommandPluginBase):
# self.bot = telegram.Bot(token=token)
# LOG.info(self.bot.get_me())
LOG.info("Starting up Updater")
try:
self.updater = Updater(
token=token,
use_context=True,
persistence=False,
)
except Exception as ex:
self.enabled = False
LOG.exception(ex)
LOG.info("Starting up Dispatcher")
try:
self.dispatcher = self.updater.dispatcher
self.dispatcher.add_handler(
MessageHandler(
@ -113,6 +121,9 @@ class TelegramChatPlugin(plugin.APRSDRegexCommandPluginBase):
self.message_handler,
),
)
except Exception as ex:
self.enabled = False
LOG.exception(ex)
def message_handler(self, update, context):
"""This is called when a telegram users texts the bot."""
@ -145,9 +156,9 @@ class TelegramChatPlugin(plugin.APRSDRegexCommandPluginBase):
def create_threads(self):
if self.enabled:
LOG.info("Starting TelegramThread")
return TelegramThread(self.config, self.updater)
@trace.trace
def process(self, packet):
"""This is called when a received packet matches self.command_regex."""
LOG.info("TelegramChatPlugin Plugin")
@ -205,10 +216,14 @@ class TelegramThread(threads.APRSDThread):
def loop(self):
"""We have to loop, so we can stop the thread upon CTRL-C"""
try:
self.updater.start_polling(
timeout=2,
drop_pending_updates=True,
)
except Exception as ex:
LOG.exception(ex)
return False
# So we don't eat 100% CPU
time.sleep(1)
# so we can continue looping