josch/neo1973-germany
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Minor updates, PyTrackerClient should be finished now (except for

Browse source 
thousands of bugs of course)


git-svn-id: http://www.neo1973-germany.de/svn@158 46df4e5c-bc4e-4628-a0fc-830ba316316d
This commit is contained in:
edistar 2008-09-17 19:53:52 +00:00
parent d639b4e2ac
commit 34726d8b66
1 changed files with 37 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
PyTracker/trunk/PyTrackerClient.py
View file

@ -9,68 +9,99 @@ import datetime
import ecore
import e_dbus
import os
import sys
from socket import *
from dbus import SystemBus, Interface
from optparse import OptionParser
class TrackClient:
def __init__(self, username='anonymous', passwordhash='', host='localhost', port='49152'):
self.InitSocket(host, port)
self.InitDbusStuff()
self.InitUserHash(username, passwordhash)
def InitSocket(self, host, port):
# Set the socket parameters
# e.g. host = "localhost"
# e.g. port = 49152
self.__addr = (str(host),int(port))
# Create socket
self.__UDPSock = socket(AF_INET,SOCK_DGRAM)
# Debug message:
print "UDP Socket for %s at port %s created" % (host, port)
def TransmitUDP(self, data):
if data:
self.__UDPSock.sendto(data,self.__addr)
# Debug message:
print "UDP stream %s sent" % (data)
def CloseSocket(self):
self.__UDPSock.close()
# Debug message:
print "UDP Socket closed"
# print "UDP Socket closed"
def InitDbusStuff(self):
# get FSO Usage proxy/iface up to request GPS
self.systembus=systembus = SystemBus(mainloop=e_dbus.DBusEcoreMainLoop())
self.usage_proxy = self.systembus.get_object('org.freesmartphone.ousaged', '/org/freesmartphone/Usage')
self.usage_iface = Interface(self.usage_proxy, 'org.freesmartphone.Usage')
# request GPS from FSO (which then powers on the GPS chip)
self.usage_iface.RequestResource("GPS")
# get gypsy proxy/iface up
self.ogpsd_proxy = self.systembus.get_object('org.freesmartphone.ogpsd', '/org/freedesktop/Gypsy')
self.course_iface = Interface(self.ogpsd_proxy, 'org.freedesktop.Gypsy.Course')
self.pos_iface = Interface(self.ogpsd_proxy, 'org.freedesktop.Gypsy.Position')
# call self.UpdatePosition() when a dbus signal "PositionChanged" comes along the system bus
self.pos_iface.connect_to_signal("PositionChanged", self.UpdateData)
def UpdateData(self, fields, timestamp, lat, lon, alt):
# get UTC time from gypsy timestamp
string = str(datetime.datetime.utcfromtimestamp(timestamp))
date, time = string.split()
utctime = "%sT%sZ" % (date, time)
# prepare data for sending
UDPData = "%s,%s,%s,%s" % (lat, lon, alt, utctime)
self.SendData(self.__username, self.__pwhash, 'Transmit', UDPData)
UDPData = "%s,%s,%s,%s" % (lat, lon, alt, utctime)
self.SendData(self.__username, self.__pwhash, 'TRANSMIT', UDPData)
# Debug message:
print "Updated Data"
# print "Updated Data"
def InitUserHash(self, username, pwhash):
# set username and password globally in the class
self.__username = username
self.__pwhash = pwhash
self.SendData(self.__username, self.__pwhash, action="START")
def SendData(self, username, pwhash, action, data=""):
# put together and send data to TransmitUDP()
senddata = "%s;%s;%s;%s" % (username, pwhash, action, data)
self.TransmitUDP(senddata)
def StartTrack(self):
self.SendData(self.__username, self.__pwhash, action="START")
# call self.UpdatePosition() when a dbus signal "PositionChanged" comes along the system bus
self.terminator = self.pos_iface.connect_to_signal("PositionChanged", self.UpdateData)
def StopTrack(self):
self.SendData(self.__username, self.__pwhash, action="STOP")
self.terminator.remove()
self.usage_iface.ReleaseResource("GPS")
sys.exit()