#!/usr/bin/env python
from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer
import SocketServer
from urlparse import parse_qs
import os
import cgi
import time
import requests
import subprocess
import config
import threading
import subprocess as sp
g_subscribed = []
g_bellListenerProc = None
class S(BaseHTTPRequestHandler):
def _output(self, code, content):
self.send_response(code)
self.send_header('Content-type', 'text/html')
self.end_headers()
self.wfile.write(content)
def do_GET(self):
try:
action = parse_qs(self.path[2:]).get("action")[0]
except:
action = None
output = '''<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Motion camera</title>
</head>
<body onload="onload()">
<script>
function sleep (time) {
return new Promise((resolve) => setTimeout(resolve, time));
}
function _toggle_alarm(st) {
document.getElementById("pleasewait").innerHTML = ' <i>Please wait...</i>';
var xhr = new XMLHttpRequest();
xhr.onreadystatechange = function () {
var DONE = 4; // readyState 4 means the request is done.
var OK = 200; // status 200 is a successful return.
if (xhr.readyState === DONE) {
if (xhr.status === OK) {
sleep(5000).then(() => {
document.location.reload();
});
} else {
alert('Error: ' + xhr.status); // An error occurred during the request.
}
}
};
var data = new FormData();
data.append('action', st ? 'motion_on'/*1.3.6.1.4.1.37476.2.4.1.100*/ : 'motion_off'/*1.3.6.1.4.1.37476.2.4.1.101*/);
xhr.open('POST', document.location, true);
xhr.send(data);
}
function onload() {
if (document.getElementById('campic') != null) {
document.getElementById('campic').src = 'http://' + window.location.hostname + ':'''+str(config.motion_stream_port)+'''/';
}
}
</script>'''
if ismotionrunning():
output = output + '<h2>Motion detection ON</h2>'
output = output + '<p><a href="javascript:_toggle_alarm(0)">Disable motion detection</a><span id="pleasewait"></span></p>'
output = output + '<p>Showing camera stream from port {0}. If you don\'t see a picture, please check your configuration or firewall.</p>'.format(config.motion_stream_port)
output = output + '<p><img id="campic" src="" alt=""></p>';
else:
output = output + '<h2>Motion detection OFF</h2>'
output = output + '<p><a href="javascript:_toggle_alarm(1)">Enable motion detection</a><span id="pleasewait"></span></p>'
output = output + '<h2>Subscribers</h2>'
found_subs = 0
for subscriber in g_subscribed[:]:
if int(time.time()) > subscriber[2]:
g_subscribed.remove(subscriber)
else:
found_subs = found_subs + 1
output = output + "<p>{0}:{1}</p>".format(subscriber[0], subscriber[1])
if found_subs == 0:
output = output + '<p>None</p>'
output = output + '</body>'
output = output + '</html>'
self._output(200, output)
def do_HEAD(self):
self._output(200, '')
def thr_client_notify(self, client_ip, client_port, server_targets):
print "ALERT: Will alert client http://{0}:{1} and tell that targets {2} sent an alert".format(client_ip, client_port, server_targets)
d = {"action": "client_alert", # 1.3.6.1.4.1.37476.2.4.1.3
"targets": server_targets,
"motion_port": config.motion_stream_port,
"simulation": "0"}
requests.post("http://{0}:{1}".format(client_ip, client_port), data=d)
def do_POST(self):
# https://stackoverflow.com/questions/4233218/python-how-do-i-get-key-value-pairs-from-the-basehttprequesthandler-http-post-h
# Question: Do we need the cgi package, or can we use functions available in this class (e.g. self_parse_qs?)
ctype, pdict = cgi.parse_header(self.headers.getheader('content-type'))
if ctype == 'multipart/form-data':
postvars = cgi.parse_multipart(self.rfile, pdict)
elif ctype == 'application/x-www-form-urlencoded':
length = int(self.headers.getheader('content-length'))
postvars = cgi.parse_qs(self.rfile.read(length), keep_blank_values=1)
else:
postvars = {}
# ---
global g_subscribed
global g_bellListenerProc
if pvget(postvars, "action")[0] == "client_subscribe": # 1.3.6.1.4.1.37476.2.4.1.1
client_ip = self.client_address[0]
client_port = pvget(postvars, "port")[0]
client_ttl = pvget(postvars, "ttl")[0]
client_targets = pvget(postvars, "targets")
client_expires = int(time.time()) + int(client_ttl)
print "Client subscribed: {0}:{1}, searching for targets {2}".format(client_ip, client_port, client_targets)
# Remove all expired entries, and previous entries of that client
for subscriber in g_subscribed[:]:
if int(time.time()) > subscriber[2]:
g_subscribed.remove(subscriber)
elif (subscriber[0] == client_ip) and (subscriber[1] == client_port) and (subscriber[3] == client_targets):
g_subscribed.remove(subscriber)
# Now add our new client
g_subscribed.append([client_ip, client_port, client_expires, client_targets])
# Send parameters of the device(s)
d = {"action": "client_alert", # 1.3.6.1.4.1.37476.2.4.1.3
"targets": ['1.3.6.1.4.1.37476.2.4.2.0', '1.3.6.1.4.1.37476.2.4.2.1002'],
"motion_port": config.motion_stream_port,
"simulation": "1"}
requests.post("http://{0}:{1}".format(client_ip, client_port), data=d)
if pvget(postvars, "action")[0] == "server_alert": # 1.3.6.1.4.1.37476.2.4.1.2
server_targets = pvget(postvars, "targets")
found_g = 0
for subscriber in g_subscribed[:]:
client_ip = subscriber[0]
client_port = subscriber[1]
client_expires = subscriber[2]
client_targets = subscriber[3]
if int(time.time()) > client_expires:
g_subscribed.remove(subscriber)
else:
found_c = 0
for st in server_targets:
for ct in client_targets:
if ct == st:
found_c = found_c + 1
found_g = found_g + 1
if found_c > 0:
# Notify clients via threads, so that all clients are equally fast notified
thread = threading.Thread(target=self.thr_client_notify, args=(client_ip, client_port, server_targets, ))
thread.start()
if found_g == 0:
print "ALERT {0}, but nobody is listening!".format(server_targets)
if pvget(postvars, "action")[0] == "motion_on": # 1.3.6.1.4.1.37476.2.4.1.100
# TODO: Actually, we should call this API "alarm_on" instead of "motion_on", since we also enable a doorbell checker
print "Motion start"
if config.enable_motion_detect:
os.system(os.path.dirname(os.path.abspath(__file__)) + "/motion/motion_start_safe")
if config.enable_doorbell_listener:
g_bellListenerProc = sp.Popen([os.path.dirname(os.path.abspath(__file__)) + "/doorbell/bell_listener.py"])
if pvget(postvars, "action")[0] == "motion_off": # 1.3.6.1.4.1.37476.2.4.1.101
# TODO: Actually, we should call this API "alarm_off" instead of "motion_off", since we also disable a doorbell checker
print "Motion stop"
if config.enable_motion_detect:
os.system(os.path.dirname(os.path.abspath(__file__)) + "/motion/motion_stop_safe")
if config.enable_doorbell_listener:
if g_bellListenerProc != None:
sp.Popen.terminate(g_bellListenerProc)
self._output(200, '')
def pvget(ary, key):
if ary.get(key) == None:
return [""]
else:
return ary.get(key)
def run(server_class=HTTPServer, handler_class=S, port=8085):
print 'Starting server, listening to port {0}...'.format(port)
server_address = ('', port)
httpd = server_class(server_address, handler_class)
httpd.serve_forever()
def ismotionrunning():
p = subprocess.Popen(["ps", "aux"], stdout=subprocess.PIPE)
out, err = p.communicate()
try:
return ('/usr/bin/motion' in str(out))
except:
res = os.system("pidof -x /usr/bin/motion > /dev/null")
return (res >> 8) == 0
if __name__ == "__main__":
from sys import argv
if len(argv) == 2:
run(port=int(argv[1]))
else:
run()