sunng87/index.html

## index.html
<!doctype html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title></title>

<link rel="dns-prefetch" href="//1-ps.googleusercontent.com"></head>
<body>
<div class="main">
<h2>Shake your phone</h2>
</div>

<script>

ws = new WebSocket("ws://192.168.1.100:8888/ledcontrol");
ws.onopen = function() {

}


function deviceMotionHandler(eventData) {
  // Grab the acceleration including gravity from the results
  var acceleration = eventData.accelerationIncludingGravity;

  msg = [];
  if (acceleration.x > 19) {
    if (Math.random() < 0.2) {
      msg.push('x')
    }
  }

  if (acceleration.y > 17) {
    if (Math.random() < 0.2) {
      msg.push('y')
    }
  }

  if (acceleration.z > 17) {
    if (Math.random() < 0.3) {
      msg.push('z')
    }
  }

  if (msg.length > 0) {
      ws.send(msg.join(''));
  }
}
if (window.DeviceMotionEvent) {
  window.addEventListener('devicemotion', deviceMotionHandler, false);
} else {
  document.getElementById("dmEvent").innerHTML = "Not supported on your device."
}

</script>

</body>
</html>

## server.py
import tornado.ioloop
import tornado.web
import tornado.websocket

import threading
import Queue

import RPi.GPIO as GPIO
import time,random

GPIO.setmode(GPIO.BCM)

mq = Queue.Queue()
pins = {'x':23, 'y':24, 'z':25}
for i in pins.values():  GPIO.setup(i, GPIO.OUT)

def monitor():
    while True:
        print mq.qsize()
        time.sleep(10)

def leds_loop():
    while True:
        m = mq.get()
        for i in m:
            GPIO.output(pins[i], GPIO.HIGH)
        time.sleep(0.08)
        for i in m:
            GPIO.output(pins[i], GPIO.LOW)

class LEDControlWebScoket(tornado.websocket.WebSocketHandler):
    def open(self):
        print "Connection established"

    def on_message(self, message):
        mq.put(message)

    def on_close(self):
        print "Connection lost"


application = tornado.web.Application([
        (r"/ledcontrol", LEDControlWebScoket),
        (r"/(.*)", tornado.web.StaticFileHandler,
         {'path': './', 'default_filename': 'index.html'})
])

def start_daemon(f):
    t = threading.Thread(target=f)
    t.setDaemon(True)
    t.start()

if __name__ == "__main__":
    application.listen(8888)
    start_daemon(leds_loop)
    start_daemon(monitor)
    tornado.ioloop.IOLoop.instance().start()
	<!doctype html>
	<html lang="en">
	<head>
	<meta charset="UTF-8">
	<title></title>

	<link rel="dns-prefetch" href="//1-ps.googleusercontent.com"></head>
	<body>
	<div class="main">
	<h2>Shake your phone</h2>
	</div>

	<script>

	ws = new WebSocket("ws://192.168.1.100:8888/ledcontrol");
	ws.onopen = function() {

	}


	function deviceMotionHandler(eventData) {
	// Grab the acceleration including gravity from the results
	var acceleration = eventData.accelerationIncludingGravity;

	msg = [];
	if (acceleration.x > 19) {
	if (Math.random() < 0.2) {
	msg.push('x')
	}
	}

	if (acceleration.y > 17) {
	if (Math.random() < 0.2) {
	msg.push('y')
	}
	}

	if (acceleration.z > 17) {
	if (Math.random() < 0.3) {
	msg.push('z')
	}
	}

	if (msg.length > 0) {
	ws.send(msg.join(''));
	}
	}
	if (window.DeviceMotionEvent) {
	window.addEventListener('devicemotion', deviceMotionHandler, false);
	} else {
	document.getElementById("dmEvent").innerHTML = "Not supported on your device."
	}

	</script>

	</body>
	</html>
	import tornado.ioloop
	import tornado.web
	import tornado.websocket

	import threading
	import Queue

	import RPi.GPIO as GPIO
	import time,random

	GPIO.setmode(GPIO.BCM)

	mq = Queue.Queue()
	pins = {'x':23, 'y':24, 'z':25}
	for i in pins.values(): GPIO.setup(i, GPIO.OUT)

	def monitor():
	while True:
	print mq.qsize()
	time.sleep(10)

	def leds_loop():
	while True:
	m = mq.get()
	for i in m:
	GPIO.output(pins[i], GPIO.HIGH)
	time.sleep(0.08)
	for i in m:
	GPIO.output(pins[i], GPIO.LOW)

	class LEDControlWebScoket(tornado.websocket.WebSocketHandler):
	def open(self):
	print "Connection established"

	def on_message(self, message):
	mq.put(message)

	def on_close(self):
	print "Connection lost"


	application = tornado.web.Application([
	(r"/ledcontrol", LEDControlWebScoket),
	(r"/(.*)", tornado.web.StaticFileHandler,
	{'path': './', 'default_filename': 'index.html'})
	])

	def start_daemon(f):
	t = threading.Thread(target=f)
	t.setDaemon(True)
	t.start()

	if __name__ == "__main__":
	application.listen(8888)
	start_daemon(leds_loop)
	start_daemon(monitor)
	tornado.ioloop.IOLoop.instance().start()