2018-01-29 21:45:21 +01:00
|
|
|
#!/usr/bin/env python3
|
2017-01-11 01:55:02 +01:00
|
|
|
|
|
|
|
import broadlink
|
|
|
|
import argparse
|
|
|
|
import time
|
|
|
|
|
2017-11-25 21:06:12 +01:00
|
|
|
TICK = 32.84
|
|
|
|
IR_TOKEN = 0x26
|
|
|
|
|
|
|
|
|
2017-01-11 01:55:02 +01:00
|
|
|
def auto_int(x):
|
|
|
|
return int(x, 0)
|
|
|
|
|
2017-11-25 21:06:12 +01:00
|
|
|
|
|
|
|
def to_microseconds(bytes):
|
|
|
|
result = []
|
|
|
|
# print bytes[0] # 0x26 = 38for IR
|
|
|
|
length = bytes[2] + 256 * bytes[3] # presently ignored
|
|
|
|
index = 4
|
|
|
|
while index < len(bytes):
|
|
|
|
chunk = bytes[index]
|
|
|
|
index += 1
|
|
|
|
if chunk == 0:
|
|
|
|
chunk = bytes[index]
|
|
|
|
chunk = 256 * chunk + bytes[index + 1]
|
|
|
|
index += 2
|
|
|
|
result.append(int(round(chunk*TICK)))
|
|
|
|
if chunk == 0x0d05:
|
|
|
|
break
|
|
|
|
return result
|
|
|
|
|
|
|
|
|
|
|
|
def durations_to_broadlink(durations):
|
|
|
|
result = bytearray()
|
|
|
|
result.append(IR_TOKEN)
|
|
|
|
result.append(0)
|
|
|
|
result.append(len(durations) % 256)
|
|
|
|
result.append(len(durations) / 256)
|
|
|
|
for dur in durations:
|
|
|
|
num = int(round(dur/TICK))
|
|
|
|
if num > 255:
|
|
|
|
result.append(0)
|
|
|
|
result.append(num / 256)
|
|
|
|
result.append(num % 256)
|
|
|
|
return result
|
|
|
|
|
|
|
|
|
|
|
|
def format_durations(data):
|
|
|
|
result = ''
|
|
|
|
for i in range(0, len(data)):
|
|
|
|
if len(result) > 0:
|
|
|
|
result += ' '
|
|
|
|
result += ('+' if i % 2 == 0 else '-') + str(data[i])
|
|
|
|
return result
|
|
|
|
|
|
|
|
|
|
|
|
def parse_durations(str):
|
|
|
|
result = []
|
|
|
|
for s in str.split():
|
|
|
|
result.append(abs(int(s)))
|
|
|
|
return result
|
|
|
|
|
|
|
|
|
2017-01-11 01:55:02 +01:00
|
|
|
parser = argparse.ArgumentParser(fromfile_prefix_chars='@');
|
|
|
|
parser.add_argument("--device", help="device definition as 'type host mac'")
|
|
|
|
parser.add_argument("--type", type=auto_int, default=0x2712, help="type of device")
|
|
|
|
parser.add_argument("--host", help="host address")
|
|
|
|
parser.add_argument("--mac", help="mac address (hex reverse), as used by python-broadlink library")
|
|
|
|
parser.add_argument("--temperature",action="store_true", help="request temperature from device")
|
2017-11-25 21:06:12 +01:00
|
|
|
parser.add_argument("--send", action="store_true", help="send command")
|
|
|
|
parser.add_argument("--sensors", action="store_true", help="check all sensors")
|
|
|
|
parser.add_argument("--learn", action="store_true", help="learn command")
|
2018-01-29 21:45:21 +01:00
|
|
|
parser.add_argument("--rfscanlearn", action="store_true", help="rf scan learning")
|
2017-01-11 01:55:02 +01:00
|
|
|
parser.add_argument("--learnfile", help="learn command and save to specified file")
|
2017-11-25 21:06:12 +01:00
|
|
|
parser.add_argument("--durations", action="store_true", help="use durations in micro seconds instead of the Broadlink format")
|
|
|
|
parser.add_argument("--convert", action="store_true", help="convert input data to durations")
|
|
|
|
parser.add_argument("data", nargs='*', help="Data to send or convert")
|
2017-01-11 01:55:02 +01:00
|
|
|
args = parser.parse_args()
|
|
|
|
|
|
|
|
if args.device:
|
2018-01-29 21:45:21 +01:00
|
|
|
values = args.device.split()
|
|
|
|
type = int(values[0], 0)
|
2017-01-11 01:55:02 +01:00
|
|
|
host = values[1]
|
|
|
|
mac = bytearray.fromhex(values[2])
|
2017-11-25 21:06:12 +01:00
|
|
|
elif args.mac:
|
2017-01-11 01:55:02 +01:00
|
|
|
type = args.type
|
|
|
|
host = args.host
|
|
|
|
mac = bytearray.fromhex(args.mac)
|
|
|
|
|
2018-01-29 21:45:21 +01:00
|
|
|
if args.host or host is not None:
|
2017-11-25 21:06:12 +01:00
|
|
|
dev = broadlink.gendevice(type, (host, 80), mac)
|
|
|
|
dev.auth()
|
2017-01-11 01:55:02 +01:00
|
|
|
|
2017-11-25 21:06:12 +01:00
|
|
|
if args.convert:
|
|
|
|
data = bytearray.fromhex(''.join(args.data))
|
|
|
|
durations = to_microseconds(data)
|
2018-01-29 21:45:21 +01:00
|
|
|
print(format_durations(durations))
|
2017-01-11 01:55:02 +01:00
|
|
|
if args.temperature:
|
2018-01-29 21:45:21 +01:00
|
|
|
print(dev.check_temperature())
|
2017-04-16 16:34:31 +02:00
|
|
|
if args.sensors:
|
|
|
|
try:
|
|
|
|
data = dev.check_sensors()
|
|
|
|
except:
|
|
|
|
data = {}
|
|
|
|
data['temperature'] = dev.check_temperature()
|
|
|
|
for key in data:
|
2018-01-29 21:45:21 +01:00
|
|
|
print("{} {}".format(key, data[key]))
|
2017-01-11 01:55:02 +01:00
|
|
|
if args.send:
|
2017-11-25 21:06:12 +01:00
|
|
|
data = durations_to_broadlink(parse_durations(' '.join(args.data))) \
|
|
|
|
if args.durations else bytearray.fromhex(''.join(args.data))
|
2017-01-11 01:55:02 +01:00
|
|
|
dev.send_data(data)
|
|
|
|
if args.learn or args.learnfile:
|
|
|
|
dev.enter_learning()
|
|
|
|
data = None
|
2018-01-29 21:45:21 +01:00
|
|
|
print("Learning...")
|
2017-01-11 01:55:02 +01:00
|
|
|
timeout = 30
|
|
|
|
while (data is None) and (timeout > 0):
|
|
|
|
time.sleep(2)
|
|
|
|
timeout -= 2
|
|
|
|
data = dev.check_data()
|
|
|
|
if data:
|
2017-11-25 21:06:12 +01:00
|
|
|
learned = format_durations(to_microseconds(bytearray(data))) \
|
|
|
|
if args.durations \
|
|
|
|
else ''.join(format(x, '02x') for x in bytearray(data))
|
2017-01-11 01:55:02 +01:00
|
|
|
if args.learn:
|
2018-01-29 21:45:21 +01:00
|
|
|
print(learned)
|
2017-01-11 01:55:02 +01:00
|
|
|
if args.learnfile:
|
2018-01-29 21:45:21 +01:00
|
|
|
print("Saving to {}".format(args.learnfile))
|
2017-01-11 01:55:02 +01:00
|
|
|
with open(args.learnfile, "w") as text_file:
|
|
|
|
text_file.write(learned)
|
|
|
|
else:
|
2018-01-29 21:45:21 +01:00
|
|
|
print("No data received...")
|
|
|
|
if args.rfscanlearn:
|
|
|
|
dev.sweep_frequency()
|
|
|
|
print("Learning RF Frequency, press and hold the button to learn...")
|
|
|
|
|
|
|
|
timeout = 20
|
|
|
|
|
|
|
|
while (not dev.check_frequency()) and (timeout > 0):
|
|
|
|
time.sleep(1)
|
|
|
|
timeout -= 1
|
|
|
|
|
|
|
|
if timeout <= 0:
|
|
|
|
print("RF Frequency not found")
|
|
|
|
dev.cancel_sweep_frequency()
|
|
|
|
exit(1)
|
|
|
|
|
|
|
|
print("Found RF Frequency - 1 of 2!")
|
|
|
|
print("You can now let go of the button")
|
|
|
|
|
|
|
|
input("Press any key to continue...")
|
|
|
|
|
|
|
|
print("To complete learning, single press the button you want to learn")
|
|
|
|
|
|
|
|
dev.find_rf_packet()
|
|
|
|
|
|
|
|
data = None
|
|
|
|
timeout = 20
|
|
|
|
|
|
|
|
while (data is None) and (timeout > 0):
|
|
|
|
time.sleep(1)
|
|
|
|
timeout -= 1
|
|
|
|
data = dev.check_data()
|
|
|
|
|
|
|
|
if data:
|
|
|
|
print("Found RF Frequency - 2 of 2!")
|
|
|
|
learned = format_durations(to_microseconds(bytearray(data))) \
|
|
|
|
if args.durations \
|
|
|
|
else ''.join(format(x, '02x') for x in bytearray(data))
|
|
|
|
if args.learn | args.rfscanlearn:
|
|
|
|
print(learned)
|
|
|
|
if args.learnfile:
|
|
|
|
print("Saving to {}".format(args.learnfile))
|
|
|
|
with open(args.learnfile, "w") as text_file:
|
|
|
|
text_file.write(learned)
|
|
|
|
else:
|
|
|
|
print("No data received...")
|