modify server ip

rest_api.py

@@ -0,0 +1,221 @@
+#!/usr/bin/env python
+import json
+import config
+import sys
+import re
+from flask_cors import CORS
+from gevent.pywsgi import WSGIServer
+from flask import Flask, request
+from werkzeug.exceptions import NotFound, Unauthorized, BadRequest
+from models import *
+
+app = Flask(__name__)
+app.debug = True
+app.config['CORS_HEADERS'] = ['Content-Type', 'X-API-KEY']
+cors = CORS(app)
+
+
+def check_auth():
+    api_key = request.headers.get('X-API-KEY')
+    print "api_key"+api_key
+    if not api_key:
+        raise Unauthorized()
+    u = User.check_api_key(api_key)
+    if not u:
+        raise Unauthorized()
+    return u
+
+
+@app.route('/login', methods=['POST'])
+def login():
+    try:
+        d = json.loads(request.data)
+        email = d['email']
+        password = d['password']
+    except:
+        raise BadRequest()
+    try:
+        u = User.objects.get(email=email)
+    except (User.DoesNotExist, User.MultipleObjectsReturned):
+        raise Unauthorized()
+    if u.check_password(password):
+        return json.dumps({
+            'api_key'   : u.api_key,
+            'email'     : u.email,
+            'id'        : str(u.id),
+        })
+    raise Unauthorized()
+
+@app.route('/user/register', methods=['POST'])
+def user_register():
+    try:
+        d = json.loads(request.data)
+        email = d['email']
+        password = d['password']
+    except:
+        raise BadRequest()
+    if not email or not password:
+        raise BadRequest('Please supply both email and password')
+    u = User(email=email, password=password)
+    try:
+        u.save()
+    except mongoengine.NotUniqueError:
+        raise BadRequest('User with that email already exists')
+    except mongoengine.ValidationError:
+        raise BadRequest('Bad email')
+    return json.dumps({
+        'api_key'   : u.api_key,
+        'email'     : u.email,
+        'id'        : str(u.id),
+    })
+
+@app.route('/device/<device_id>/messages', methods=['GET'])
+def device_messages(device_id):
+    user = check_auth()
+    try:
+        device = GPSDevice.objects.get(id=device_id)
+    except (GPSDevice.DoesNotExist, mongoengine.ValidationError):
+        raise NotFound()
+    except GPSDevice.MultipleObjectsReturned:
+        raise
+    if device not in user.devices:
+        raise Unauthorized()
+    resp = []
+    for message in device.messages:
+        resp.append({
+            'id'                : str(message.id),
+            'message_type'      : message.message_type,
+            'state'             : message.state,
+            'imei'              : message.imei,
+            'message_datastring': message.message_datastring,
+            'latitude'          : str(message.latitude) if message.latitude else None,
+            'longitude'         : str(message.longitude) if message.longitude else None,
+            'created'           : message.created.isoformat(),
+        })
+    return json.dumps(resp)
+
+@app.route('/device/<device_id>/trackOnce', methods=['POST'])
+def device_track_once(device_id):
+    user = check_auth()
+    try:
+        device = GPSDevice.objects.get(id=device_id)
+    except (GPSDevice.DoesNotExist, mongoengine.ValidationError):
+        raise NotFound()
+    except GPSDevice.MultipleObjectsReturned:
+        raise
+    if device not in user.devices:
+        raise Unauthorized()
+    print 'IMEI %s requesting to trackOnce' % device.imei
+    m = Message()
+    m.imei = device.imei
+    m.message_type = config.MESSAGE_TYPE_REQ_LOCATION
+    m.save()
+    return 'location request sent'
+
+@app.route('/user/<user_id>', methods=['GET'])
+@app.route('/user', methods=['GET'])
+def user_list(user_id=None):
+    user = check_auth()
+    if user_id:
+        try:
+            u = User.objects.get(id=user_id)
+        except:
+            raise NotFound()
+        resp = {
+            '_id'       : str(u.id),
+            'email'     : str(u.email),
+            'devices'   : [str(d.id) for d in u.devices],
+        }
+    else:
+        resp = []
+        for u in User.objects.filter(id=user.id):
+            resp.append({
+                '_id'       : str(u.id),
+                'email'     : str(u.email),
+                'devices'   : [str(d.id) for d in u.devices],
+            })
+    return json.dumps(resp)
+
+@app.route('/device/<id>', methods=['DELETE'])
+def delete_device(id):
+    user = check_auth()
+    try:
+        device = GPSDevice.objects.get(id=id)
+    except GPSDevice.DoesNotExist:
+        raise NotFound()
+    if user != device.user:
+        raise NotFound()
+    user.devices = filter(lambda x:x.id!=id, user.devices)
+    user.save()
+    device.delete()
+    return 'ok'
+
+@app.route('/device', methods=['POST'])
+def add_device():
+    user = check_auth()
+    try:
+        data = json.loads(request.data)
+    except:
+        raise BadRequest()
+    if not data.get('imei', None):
+        raise BadRequest('imei required')
+    if not re.match('^\d{15}$', data['imei']):
+        raise BadRequest('imei must be 15 digits long')
+    try:
+        device = GPSDevice.objects.get(imei=data['imei'])
+        if device.user != user:
+            raise BadRequest('There was a problem adding that device')
+    except GPSDevice.DoesNotExist:
+        data = {
+            'imei'          : data.get('imei'),
+            'vehicle_plate' : data.get('vehicle_plate', None),
+        }
+        device = GPSDevice(imei=data['imei'])
+        device.save()
+        user.devices.append(device)
+        user.save()
+    resp = {
+        'id'    : str(device.id),
+        'imei'  : device.imei,
+    }
+    return json.dumps(resp)
+
+@app.route('/device/<device_id>', methods=['GET'])
+@app.route('/device', methods=['GET'])
+def devices(device_id=None):
+    user = check_auth()
+    if device_id:
+        try:
+            d = filter(lambda d:str(d.id)==device_id, user.devices)[0]
+            resp = {
+                'id'            : str(d.id),
+                'name'          : d.name,
+                'imei'          : d.imei,
+                'ipaddr'        : d.ipaddr,
+                'vehicle_plate' : d.vehicle_plate,
+                'is_online'     : d.is_online,
+                'latitude'      : str(d.latitude) if d.latitude else None,
+                'longitude'     : str(d.longitude) if d.longitude else None,
+                'icon'          : 'img/car-black.png'
+            }
+        except:
+            raise NotFound()
+    else:
+        resp = []
+        for device in user.devices:
+            d = {
+                'id'            : str(device.id),
+                'imei'          : device.imei,
+                'ipaddr'        : device.ipaddr,
+                'is_online'     : device.is_online,
+                'latitude'      : str(device.latitude) if device.latitude else None,
+                'longitude'     : str(device.longitude) if device.longitude else None,
+                'icon'          : 'img/car-black.png'
+            }
+            resp.append(d)
+    return json.dumps(resp)
+
+
+if __name__=='__main__':
+    http = WSGIServer(('', 5000), app)
+    http.serve_forever()

rest_api/config.py

@@ -0,0 +1,34 @@
+MONGO_HOST                      = '127.0.0.1'
+MONGO_PORT                      = 27017
+MONGO_DBNAME                    = 'gpstrack'
+
+DEVICE_GATEWAY_MAX_CONNECTIONS  = 100
+DEVICE_GATEWAY_HOST_LISTEN      = '127.0.0.1'
+DEVICE_GATEWAY_HOST_LISTEN      = ''
+DEVICE_GATEWAY_PORT_LISTEN      = 9000
+DEVICE_GATEWAY_RECV_SIZE        = 4096
+DEVICE_GATEWAY_LOGFILE          = 'log/device_gateway.log'
+
+DEVICE_OFFLINE_TIMEOUT_MINUTES  = 1 
+
+MESSAGE_TYPE_INIT               = 'init'
+MESSAGE_TYPE_HEARTBEAT          = 'heartbeat'
+MESSAGE_TYPE_LOCATION_FULL      = 'location_full'
+MESSAGE_TYPE_LOCATION_LOW       = 'location_low'
+MESSAGE_TYPE_OBD                = 'obd'
+MESSAGE_TYPE_REQ_LOCATION       = 'req_location'
+
+MESSAGE_STATE_INITIAL           = 'initial'
+#MESSAGE_STATE_PENDING          = 'pending'
+MESSAGE_STATE_SENT              = 'sent'
+MESSAGE_STATE_RECEIVED          = 'received'
+
+GOOGLE_MAPS_URI_FORMAT          = 'https://maps.google.com.au/?q={latitude},{longitude}'
+
+EVE_SETTINGS = {
+    'MONGO_HOST'        : MONGO_HOST,
+    'MONGO_PORT'        : MONGO_PORT,
+    'MONGO_DBNAME'      : MONGO_DBNAME,
+    'DOMAIN'            : {'eve-mongoengine': {}} # sadly this is needed for eve
+}
+EVE_AUTH_HEADER_NAME            = 'X-API-KEY'