BOSWatch/BW3-Core
1
0
Fork 0
mirror of https://github.com/BOSWatch/BW3-Core.git synced 2026-01-03 15:19:57 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

neue Funktion msg_send und aufruf davon mit Payload in "onLoad" und "zvei"

Browse source
This commit is contained in:
KoenigMjr 2025-06-08 14:21:29 +02:00 committed by GitHub
parent 194a7ef8aa
commit 11a456a1ef
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 18 additions and 42 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

60
plugin/telegramdirty.py
View file

@ -35,26 +35,33 @@ class BoswatchPlugin(PluginBase):
"""!Do not change anything here!"""
super().__init__(__name__, config) # you can access the config class on 'self.config'
def onLoad(self):
"""!Called by import of the plugin"""
bot_token = self.config.get("botToken") #Import von Token aus config/server.yaml
chat_id = self.config.get("chatIds") #Import von ChatIDs aus config/server.yaml
msg_payload = "Server up and running!"
def msg_send(self, bwPacket, msg_payload):
"""!Funktion zum Senden einer Nachricht über Telegram
@param bwPacket: bwPacket instance
@param msg_payload: Nachrichtentext, der gesendet werden soll"""
bot_token = self.config.get("botToken")
chat_id = self.config.get("chatIds")
url = f'https://api.telegram.org/bot{bot_token}/sendMessage'
payload = {
'chat_id': chat_id,
'text': msg_payload
}
response = requests.post(url, data=payload)
if response.status_code == 200:
print("Nachricht erfolgreich gesendet!")
else:
print("Fehler beim Senden:", response.text)
def onLoad(self):
"""!Called by import of the plugin"""
msg_payload = "Server up and running!"
self.msg_send(None, msg_payload)
pass
def setup(self):
"""!Called before alarm
Remove if not implemented"""
@ -77,21 +84,10 @@ class BoswatchPlugin(PluginBase):
def zvei(self, bwPacket):
"""!Called on ZVEI alarm
@param bwPacket: bwPacket instance"""
bot_token = self.config.get("botToken") #Import von Token aus config/server.yaml
chat_id = self.config.get("chatIds") #Import von ChatIDs aus config/server.yaml
msg_payload = self.parseWildcards(self.config.get("message_zvei", default="{TONE}")) # Übergabe mit Wildcards aus config/server.yaml der "message_zvei", falls nicht definiert, Defaultwert
#msg_payload = bwPacket.get("clientName") + ": " + (bwPacket.get("description") or bwPacket.get("tone")) # Name vom Client und ": " und wenn Description vorhanden, ansonsten ZVEI
url = f'https://api.telegram.org/bot{bot_token}/sendMessage'
payload = {
'chat_id': chat_id,
'text': msg_payload
}
response = requests.post(url, data=payload)
if response.status_code == 200:
print("Nachricht erfolgreich gesendet!")
else:
print("Fehler beim Senden:", response.text)
msg_payload = self.parseWildcards(
self.config.get("message_zvei", default="{TONE}") # Übergabe mit Wildcards aus config/server.yaml der "message_zvei", falls nicht definiert, Defaultwert
)
self.msg_send(bwPacket, msg_payload)
pass
def msg(self, bwPacket):
@ -110,23 +106,3 @@ class BoswatchPlugin(PluginBase):
"""!Called by destruction of the plugin
Remove if not implemented"""
pass
def msg_send(self, bwPacket):
"""!Funktion zum senden einer Nachricht
@param bwPacket: bwPacket instance"""
bot_token = self.config.get("botToken") #Import von Token aus config/server.yaml
chat_id = self.config.get("chatIds") #Import von ChatIDs aus config/server.yaml
msg_payload = self.parseWildcards(self.config.get("message_zvei", default="{TONE}")) # Übergabe mit Wildcards aus config/server.yaml der "message_zvei", falls nicht definiert, Defaultwert
#msg_payload = bwPacket.get("clientName") + ": " + (bwPacket.get("description") or bwPacket.get("tone")) # mit bwPacket anstelle Wildcards: Name vom Client und ": " und wenn Description vorhanden, ansonsten ZVEI
url = f'https://api.telegram.org/bot{bot_token}/sendMessage'
payload = {
'chat_id': chat_id,
'text': msg_payload
}
response = requests.post(url, data=payload)
if response.status_code == 200:
print("Nachricht erfolgreich gesendet!")
else:
print("Fehler beim Senden:", response.text)
pass