Add initial version of MessageSender

This commit is contained in:
Bálint Bokros 2018-01-29 16:48:32 +01:00
parent cd5f7084da
commit 16dad5e2cd
1 changed files with 14 additions and 0 deletions

View File

@ -0,0 +1,14 @@
from server_connector import ServerUplinkConnector
class MessageSender:
def __init__(self, custom_anchor=None):
self.server_connector = ServerUplinkConnector()
if isinstance(custom_anchor, str):
custom_anchor = custom_anchor.encode('utf-8')
self.anchor = custom_anchor or b'message'
def send(self, message):
if isinstance(message, str):
message = message.encode('utf-8')
self.server_connector.send(self.anchor, message)