-
-
Notifications
You must be signed in to change notification settings - Fork 33
/
_P016_IR.py
126 lines (117 loc) · 4 KB
/
_P016_IR.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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
#!/usr/bin/env python3
#############################################################################
##################### IR Receiver plugin for RPIEasy ########################
#############################################################################
#
# This plugin made for LIRC compatible IR receivers.
#
# Copyright (C) 2019 by Alexander Nagy - https://bitekmindenhol.blog.hu/
#
import plugin
import webserver
import rpieGlobals
import rpieTime
import misc
import time
import threading
from lib.lib_ir import *
class Plugin(plugin.PluginProto):
PLUGIN_ID = 16
PLUGIN_NAME = "Communication - IR Receiver (TESTING)"
PLUGIN_VALUENAME1 = "IR"
def __init__(self,taskindex): # general init
plugin.PluginProto.__init__(self,taskindex)
self.dtype = rpieGlobals.DEVICE_TYPE_DUMMY # use lirc device, not gpio directly!
self.vtype = rpieGlobals.SENSOR_TYPE_LONG
self.readinprogress = 0
self.valuecount = 1
self.senddataoption = True
self.timeroption = False
self.timeroptional = False
self.formulaoption = False
self.irdevice = None
self.bgproc = None
self.enprot = []
def __del__(self):
try:
self.initialized = False
if self.irdevice is not None:
self.irdevice.stop()
except:
pass
def plugin_exit(self):
self.__del__()
def plugin_init(self,enableplugin=None):
plugin.PluginProto.plugin_init(self,enableplugin)
self.initialized = False
if self.enabled==False:
self.__del__()
return False
if self.uservar[0]!="0":
self.uservar[0]="0"
self.decimals[0]=0
if str(self.taskdevicepluginconfig[0])!="0" and str(self.taskdevicepluginconfig[0]).strip()!="":
if self.enabled:
try:
self.irdevice = request_ir_device(self.taskdevicepluginconfig[0],True,self.receiver)
self.initialized = self.irdevice.initialized
except Exception as e:
misc.addLog(rpieGlobals.LOG_LEVEL_ERROR,"LIRC device init error: ",+str(e))
if self.initialized:
try:
pname = str(self.taskdevicepluginconfig[0]).split("/")
self.ports = str(pname[-1])
except:
pass
set_ir_protocols(self.enprot) # print(enprot)
misc.addLog(rpieGlobals.LOG_LEVEL_INFO,"LIRC RX device initialized")
self.bgproc = threading.Thread(target=self.irdevice.poller)
self.bgproc.daemon = True
self.bgproc.start()
def receiver(self,proto,code):
self.set_value(1,int(code,0),True)
misc.addLog(rpieGlobals.LOG_LEVEL_INFO,"IRSEND,"+str(proto)+","+str(code))
# misc.addLog(rpieGlobals.LOG_LEVEL_DEBUG,"Protocol: "+str(proto)+" Code: "+str(code))
def webform_load(self):
try:
choice1 = self.taskdevicepluginconfig[0]
options = find_lirc_devices()
if len(options)>0:
webserver.addHtml("<tr><td>LIRC device<td>")
webserver.addSelector_Head("p016_dev",False)
for o in range(len(options)):
webserver.addSelector_Item(options[o],options[o],(str(options[o])==str(choice1)),False)
webserver.addSelector_Foot()
else:
webserver.addFormNote("/dev/lirc* not found")
return False
webserver.addFormNote("Select a receiver LIRC device (lirc-rx)! Do not forget to set the Data pin to IR-RX <a href='pinout'>at pinout settings</a>!")
except Exception as e:
print(e)
try:
supprot = get_ir_supported_protocols()
enprot = get_ir_enabled_protocols()
webserver.addRowLabel("Enabled protocols")
for s in range(len(supprot)):
webserver.addHtml("<label class='container' style='height:30px'>"+supprot[s]+" <input type='checkbox' id='")
webserver.addHtml("_"+supprot[s]+"' name='_"+supprot[s]+"'")
if (supprot[s] in enprot):
webserver.addHtml(" checked")
webserver.addHtml("><span class='checkmark'></span></label>")
except Exception as e:
print(e)
return True
def webform_save(self,params):
par = webserver.arg("p016_dev",params)
self.taskdevicepluginconfig[0] = str(par)
self.enprot = []
try:
for k,v in params.items():
if k[0]=="_":
if v=="on":
self.enprot.append(k[1:])
except Exception as e:
print(e)
# set_ir_protocols(self.enprot) # print(enprot)
self.plugin_init()
return True