root/as3/SpaceNavigator/server/src/SpaceNavigator.py

/*
 * SpaceNavigator
 * 
 * Licensed under the MIT License
 * 
 * Copyright (c) 2009 Lyuta Nakashima (www.atuyl.jp)
 * 
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 * 
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 * 
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */

import comtypes.client as client
from ctypes import *
import socket

import logging
console = logging.StreamHandler()
console.setLevel(logging.DEBUG)
logging.getLogger('').addHandler(console)

HOST = 'localhost'
PORT = 15000

server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
server.bind((HOST,PORT))
server.listen(1)

class POINT(Structure): _fields_ = [("x", c_long),("y", c_long)]
class MSG(Structure): _fields_ = [("hWnd", c_ulong),("message", c_uint),("wParam", c_ulong),("lParam", c_ulong),("time", c_ulong),("pt", POINT)]

class SensorListener:
        def __init__(self, sensor,conn):
                self.sensor = sensor
                self.conn = conn
        
        def SensorInput(self, this, inval=None):
                val  = str(self.sensor.Translation.X) + "," + str(self.sensor.Translation.Y) + "," + str(self.sensor.Translation.Z) + ","
                val += str(self.sensor.Rotation.X) + "," + str(self.sensor.Rotation.Y) + "," + str(self.sensor.Rotation.Z) + "\x00"
                self.conn.sendall(unicode(val,"utf_8"))

if __name__ == '__main__':
        print 'Waiting for connections...'
        conn, address = server.accept()
        print "connect from:" , address
        
        device = client.CreateObject("TDxInput.Device")
        
        if not device.Connect(): print "Connected!"
        
        sensor = device.Sensor
        listener = SensorListener(sensor,conn)
        client.GetEvents(sensor,listener)
        
        while True:
                msg = byref(MSG())
                windll.user32.GetMessageW(msg, None, 0, 0)
                windll.user32.DispatchMessageW(msg)