forked from Dan-in-CA/SIP
-
Notifications
You must be signed in to change notification settings - Fork 0
/
ospi.py
214 lines (184 loc) · 9.19 KB
/
ospi.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
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
# !/usr/bin/env python
# -*- coding: utf-8 -*-
import json
import ast
import time
import thread
from calendar import timegm
import sys
import i18n
sys.path.append('./plugins')
import web # the Web.py module. See webpy.org (Enables the Python OpenSprinkler web interface)
import gv
from helpers import plugin_adjustment, prog_match, schedule_stations, log_run, stop_onrain, check_rain, jsave
from urls import urls # Provides access to URLs for UI pages
from gpio_pins import set_output
from ReverseProxied import ReverseProxied
set_output()
def timing_loop():
""" ***** Main timing algorithm. Runs in a separate thread.***** """
try:
print _('Starting timing loop') + '\n'
except Exception:
pass
last_min = 0
while True: # infinite loop
gv.now = timegm(time.localtime()) # Current time as timestamp based on local time from the Pi. updated once per second.
if gv.sd['en'] and not gv.sd['mm'] and (not gv.sd['bsy'] or not gv.sd['seq']):
if gv.now / 60 != last_min: # only check programs once a minute
last_min = gv.now / 60
extra_adjustment = plugin_adjustment()
for i, p in enumerate(gv.pd): # get both index and prog item
# check if program time matches current time, is active, and has a duration
if prog_match(p) and p[0] and p[6]:
duration = p[6] * gv.sd['wl'] / 100 * extra_adjustment # program duration scaled by "water level"
duration = int(round(duration)) # convert to int
# check each station for boards listed in program up to number of boards in Options
for b in range(len(p[7:7 + gv.sd['nbrd']])):
for s in range(8):
sid = b * 8 + s # station index
if sid + 1 == gv.sd['mas']:
continue # skip if this is master station
if gv.srvals[sid]: # skip if currently on
continue
if p[7 + b] & 1 << s: # if this station is scheduled in this program
if gv.sd['seq']: # sequential mode
gv.rs[sid][2] = duration
gv.rs[sid][3] = i + 1 # store program number for scheduling
gv.ps[sid][0] = i + 1 # store program number for display
gv.ps[sid][1] = duration
else: # concurrent mode
# If duration is shortter than any already set for this station
if duration < gv.rs[sid][2]:
continue
else:
gv.rs[sid][2] = duration
gv.rs[sid][3] = i + 1 # store program number
gv.ps[sid][0] = i + 1 # store program number for display
gv.ps[sid][1] = duration
schedule_stations(p[7:7 + gv.sd['nbrd']]) # turns on gv.sd['bsy']
if gv.sd['bsy']:
for b in range(gv.sd['nbrd']): # Check each station once a second
for s in range(8):
sid = b * 8 + s # station index
if gv.srvals[sid]: # if this station is on
if gv.now >= gv.rs[sid][1]: # check if time is up
gv.srvals[sid] = 0
set_output()
gv.sbits[b] &= ~(1 << s)
if gv.sd['mas'] - 1 != sid: # if not master, fill out log
gv.ps[sid] = [0, 0]
gv.lrun[0] = sid
gv.lrun[1] = gv.rs[sid][3]
gv.lrun[2] = int(gv.now - gv.rs[sid][0])
gv.lrun[3] = gv.now
log_run()
gv.pon = None # Program has ended
gv.rs[sid] = [0, 0, 0, 0]
else: # if this station is not yet on
if gv.rs[sid][0] <= gv.now < gv.rs[sid][1]:
if gv.sd['mas'] - 1 != sid: # if not master
gv.srvals[sid] = 1 # station is turned on
set_output()
gv.sbits[b] |= 1 << s # Set display to on
gv.ps[sid][0] = gv.rs[sid][3]
gv.ps[sid][1] = gv.rs[sid][2]
if gv.sd['mas'] and gv.sd['mo'][b] & 1 << (s - (s / 8) * 80): # Master settings
masid = gv.sd['mas'] - 1 # master index
gv.rs[masid][0] = gv.rs[sid][0] + gv.sd['mton']
gv.rs[masid][1] = gv.rs[sid][1] + gv.sd['mtoff']
gv.rs[masid][3] = gv.rs[sid][3]
elif gv.sd['mas'] == sid + 1:
gv.sbits[b] |= 1 << sid # (gv.sd['mas'] - 1)
gv.srvals[masid] = 1
set_output()
for s in range(gv.sd['nst']):
if gv.rs[s][1]: # if any station is scheduled
program_running = True
gv.pon = gv.rs[s][3] # Store number of running program
break
program_running = False
gv.pon = None
if program_running:
if gv.sd['urs'] and gv.sd['rs']: # Stop stations if use rain sensor and rain detected.
stop_onrain() # Clear schedule for stations that do not ignore rain.
for idx in range(len(gv.rs)): # loop through program schedule (gv.ps)
if gv.rs[idx][2] == 0: # skip stations with no duration
continue
if gv.srvals[idx]: # If station is on, decrement time remaining display
gv.ps[idx][1] -= 1
if not program_running:
gv.srvals = [0] * (gv.sd['nst'])
set_output()
gv.sbits = [0] * (gv.sd['nbrd'] + 1)
gv.ps = []
for i in range(gv.sd['nst']):
gv.ps.append([0, 0])
gv.rs = []
for i in range(gv.sd['nst']):
gv.rs.append([0, 0, 0, 0])
gv.sd['bsy'] = 0
if gv.sd['mas'] and (gv.sd['mm'] or not gv.sd['seq']): # handle master for maual or concurrent mode.
mval = 0
for sid in range(gv.sd['nst']):
bid = sid / 8
s = sid - bid * 8
if gv.sd['mas'] != sid + 1 and (gv.srvals[sid] and gv.sd['mo'][bid] & 1 << s):
mval = 1
break
if not mval:
gv.rs[gv.sd['mas'] - 1][1] = gv.now # turn off master
if gv.sd['urs']:
check_rain() # in helpers.py
if gv.sd['rd'] and gv.now >= gv.sd['rdst']: # Check of rain delay time is up
gv.sd['rd'] = 0
gv.sd['rdst'] = 0 # Rain delay stop time
jsave(gv.sd, 'sd')
time.sleep(1)
#### End of timing loop ####
class OSPiApp(web.application):
"""Allow program to select HTTP port."""
def run(self, port=gv.sd['htp'], *middleware): # get port number from options settings
func = self.wsgifunc(*middleware)
func = ReverseProxied(func)
return web.httpserver.runsimple(func, ('0.0.0.0', port))
app = OSPiApp(urls, globals())
# disableShiftRegisterOutput()
web.config.debug = False # Improves page load speed
if web.config.get('_session') is None:
web.config._session = web.session.Session(app, web.session.DiskStore('sessions'),
initializer={'user': 'anonymous'})
template_globals = {
'gv': gv,
'str': str,
'eval': eval,
'session': web.config._session,
'json': json,
'ast': ast,
'_': _,
'i18n': i18n,
'app_path': lambda p: web.ctx.homepath + p,
'web' : web,
}
template_render = web.template.render('templates', globals=template_globals, base='base')
if __name__ == '__main__':
#########################################################
#### Code to import all webpages and plugin webpages ####
import plugins
try:
print _('plugins loaded:')
except Exception:
pass
for name in plugins.__all__:
print ' ', name
gv.plugin_menu.sort(key=lambda entry: entry[0])
# Keep plugin manager at top of menu
try:
gv.plugin_menu.pop(gv.plugin_menu.index(['Manage Plugins', '/plugins']))
except Exception:
pass
if gv.use_gpio_pins:
set_output()
thread.start_new_thread(timing_loop, ())
app.notfound = lambda: web.seeother('/')
app.run()