root
40 lines
1.3 KiB
Python
Executable File
40 lines
1.3 KiB
Python
Executable File
#!/usr/bin/env python
|
|
# -*- encoding: utf-8 -*-
|
|
from enocean.consolelogger import init_logging
|
|
from enocean.communicators.tcpcommunicator import TCPCommunicator
|
|
from enocean.protocol.constants import PACKET, RORG
|
|
import sys
|
|
import traceback
|
|
|
|
try:
|
|
import queue
|
|
except ImportError:
|
|
import Queue as queue
|
|
|
|
init_logging()
|
|
communicator = TCPCommunicator()
|
|
communicator.start()
|
|
while communicator.is_alive():
|
|
try:
|
|
# Loop to empty the queue...
|
|
packet = communicator.receive.get(block=True, timeout=1)
|
|
if packet.packet_type == PACKET.RADIO_ERP1 and packet.rorg == RORG.BS4:
|
|
for k in packet.parse_eep(0x02, 0x05):
|
|
print('%s: %s' % (k, packet.parsed[k]))
|
|
if packet.packet_type == PACKET.RADIO_ERP1 and packet.rorg == RORG.BS1:
|
|
for k in packet.parse_eep(0x00, 0x01):
|
|
print('%s: %s' % (k, packet.parsed[k]))
|
|
if packet.packet_type == PACKET.RADIO_ERP1 and packet.rorg == RORG.RPS:
|
|
for k in packet.parse_eep(0x02, 0x04):
|
|
print('%s: %s' % (k, packet.parsed[k]))
|
|
except queue.Empty:
|
|
continue
|
|
except KeyboardInterrupt:
|
|
break
|
|
except Exception:
|
|
traceback.print_exc(file=sys.stdout)
|
|
break
|
|
|
|
if communicator.is_alive():
|
|
communicator.stop()
|