forked from wwj718/codelab_adapter_client
/
eim_node.py
34 lines (27 loc) · 979 Bytes
/
eim_node.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
import time
from loguru import logger
from codelab_adapter_client import AdapterNode
class EIMNode(AdapterNode):
def __init__(self):
super().__init__()
self.NODE_ID = "eim"
def send_message_to_scratch(self, content):
message = self.message_template()
message["payload"]["content"] = content
self.publish(message)
def extension_message_handle(self, topic, payload):
self.logger.info(f'the message payload from scratch: {payload}')
content = payload["content"]
if type(content) == str:
content_send_to_scratch = content[::-1] # 反转字符串
self.send_message_to_scratch(content_send_to_scratch)
def run(self):
while self._running:
time.sleep(1)
if __name__ == "__main__":
try:
node = EIMNode()
node.receive_loop_as_thread()
node.run()
except KeyboardInterrupt:
node.terminate() # Clean up before exiting.