mysqllistener.py

tinyos-2.x.rar

import socket
import UdpReport
import re
import sys
import MySQLdb

port = 7000

if __name__ == '__main__':
    conn = MySQLdb.connect (host = "localhost",
                            user = "b6lowpan",
                            db = "b6lowpan")
    cursor = conn.cursor()
    s = socket.socket(socket.AF_INET6, socket.SOCK_DGRAM)
    s.bind(('', port))
    if len(sys.argv) < 2:
        print "\tListener.py <tablename>"
        sys.exit(1)

    try:
        drop = "DROP TABLE " + str(sys.argv[1])
        cursor.execute(drop)
    except:
        print "Drop failed... continuing"

    methods = []
    create_table = "CREATE TABLE " + str(sys.argv[1]) + " ("
    create_table += "ts TIMESTAMP, origin INT(4), "
    insert = "INSERT INTO " + sys.argv[1] + " (origin, "


    re = re.compile('^get_(.*)')
    for method in dir(UdpReport.UdpReport):
        result = re.search(method)
        if result != None:
            create_table += str(result.group(1)) + " INT(4), "
            insert += str(result.group(1)) + ", "
            methods.append(str(result.group(1)))

    create_table = create_table[0:len(create_table) - 2]
    insert = insert[0:len(insert) - 2]
    create_table += ")"
    insert += ") VALUES ("
    print insert
    print create_table

    cursor.execute(create_table)

    while True:
        data, addr = s.recvfrom(1024)
        if (len(data) > 0):


            print
            print str(len(data)) + ":", 
            for i in data:
                print "0x%x" % ord(i),
 
            print
            rpt = UdpReport.UdpReport(data=data, data_length=len(data))
            addr = addr[0]
            AA = addr.split(":")
            print addr
            print rpt


            thisInsert = insert
            thisInsert += "0x" + AA[-1] + ", "

            

            for m in methods:
                try:
                    getter = getattr(rpt, 'get_' + m, None)
                    val = getter()
                except:
                    val = 0
                if (isinstance(val, list)):
                    val = val[0]
                thisInsert += str(val) + ", "
            thisInsert = thisInsert[0:len(thisInsert) - 2]
            thisInsert += ")"

            print thisInsert

            cursor.execute(thisInsert)

    conn.close()