routes.py

from flask import Flask, render_template, flash, request, jsonify
from flask_mail import Mail, Message
from flask_sqlalchemy import SQLAlchemy
from datetime import datetime
import sys
import time
import zmq

app = Flask(__name__) 
app.config.from_pyfile('webHomeControl.cfg')
app.config.update(
    #EMAIL SETTINGS
    MAIL_SERVER='smtp.gmail.com',
    MAIL_PORT=465,
    MAIL_USE_SSL=True,
    MAIL_USERNAME = 'webhomecontrol@gmail.com',
    MAIL_PASSWORD = 'towsongraduateproject'
    )

mail=Mail(app)
# set the secret key.  keep this really secret:
app.secret_key = 'A0Zr98j/3yX R~XHH!jmN]LWX/,?RT'
db = SQLAlchemy(app)


class Status(db.Model):
	# Setting the table name and
	# creating columns for various fields
    __tablename__ = 'status'
    id = db.Column(db.Integer, primary_key = True)
    hardware=db.Column(db.String, index = True, unique = False)
    time=db.Column(db.DateTime, index = True, unique = False)
    status=db.Column(db.String, index = True, unique = False)
    
    __mapper_args__ = {
            'polymorphic_on':hardware,
            'polymorphic_identity':'none'
    }

    def __init__(self, time, status):
        # Initializes the fields with entered data
        self.time = datetime.now()
        self.status = status

class DoorStatus(Status):
    __mapper_args__ = {
            'polymorphic_identity':'door'
    }

class MotionStatus(Status):
    __mapper_args__ = {
            'polymorphic_identity':'motionSensor'
    }

class MotorStatus(Status):
    duration = db.Column(db.Integer, index = False, unique = False)

    def __init__(self, time, status, duration):
        super(MotorStatus, self).__init__(hardware, time, status)
        self.duration = duration

# The default route for the app
@app.route('/')
def home():
   return render_template('home.html')

@app.route('/doorSensor/status/<status>', methods = ['POST'])
def doorStatus(status):
    msg = Message(
              'WebHomeControl',
           sender='webhomecontrol@gmail.com',
           recipients=
               ['marbaugh@gmail.com'])
    if request.method == 'POST':
        insert_door = None
        if status == 'opened':
            insert_door = DoorStatus(datetime.now(), status)
            msg.body = "Door Opened"
        elif status == 'closed':
            insert_door = DoorStatus(datetime.now(), status)
            msg.body = "Door Closed"
        else:
            pass
    db.session.add(insert_door)
    db.session.commit()
    mail.send(msg)
    return 'success' 

@app.route('/motionSensor/status/<status>', methods = ['POST'])
def motionStatus(status):
    msg = Message(
             'WebHomeControl',
             sender='webhomecontrol@gmail.com',
             recipients=['marbaugh@gmail.com'])
    if request.method == 'POST':
        insert_motion = None
        if status == 'motion':
            insert_motion = MotionStatus(datetime.now(), status)
            msg.body = "Motion Detected"
        else:
            pass
    db.session.add(insert_motion)
    db.session.commit()
    mail.send(msg)
    return 'success' 

@app.route('/doorSensor/history')
def doorSensor_history():
    aadata = dict()
    rowData= list()
    results = DoorStatus.query.order_by(db.desc(DoorStatus.time)).all()
    for row in results:
        rowData.append([row.time, row.status])
	aadata['aaData'] = rowData
    return jsonify(aadata)

@app.route('/motionSensor/history')
def motionSensor_history():
    aadata = dict()
    rowData= list()
    results = MotionStatus.query.order_by(db.desc(MotionStatus.time)).all()
    for row in results:
        rowData.append([row.time, row.status])
	aadata['aaData'] = rowData
    return jsonify(aadata)

@app.route('/motor/forward', methods = ['POST'])
def motor_forward():
    port = "5556"
    topic = "motor"
    context = zmq.Context()
    socket = context.socket(zmq.PUB)
    socket.bind("tcp://*:{0}".format(port))
    time.sleep(.5)
    messagedata = 'forward'
    print "{0} {1}".format(topic, messagedata)
    socket.send("{0} {1}".format(topic, messagedata))
    print "after socket"
    return 'success' 

@app.route('/motor/reverse', methods = ['POST'])
def motor_reverse():
    port = "5556"
    topic = "motor"
    context = zmq.Context()
    socket = context.socket(zmq.PUB)
    socket.bind("tcp://*:{0}".format(port))
    time.sleep(.5)
    messagedata = 'reverse'
    print "{0} {1}".format(topic, messagedata)
    socket.send("{0} {1}".format(topic, messagedata))
    print "after socket"
    return 'success' 

if __name__ == '__main__':
  app.run(host='192.168.3.107', debug=True)