diff --git a/WebControllerAddon.py b/WebControllerAddon.py index 00c9272..7f00d78 100644 --- a/WebControllerAddon.py +++ b/WebControllerAddon.py @@ -9,7 +9,7 @@ class BlenderWebController_op(bpy.types.Operator): @classmethod def poll(self,context):return True def execute(self,context): - bpy.context.scene.render.engine='BLENDER_GAME';bpy.context.scene.game_settings.show_debug_properties=True;bpy.ops.text.new();bpy.data.texts[-1].name='StartServer';bpy.data.texts['StartServer'].from_string("from server import WebSocketHttpServer\nfrom handler import BlenderHandler\nimport customButtons\nimport threading\ndef main():\n if 'Server' in bge.logic.globalDict:return\n else:\n print('\\n\\n------------------ BUILDING THE SERVER -----------------------');scene=bge.logic.getCurrentScene();scene.active_camera=scene.objects['ControllerView'];cont=bge.logic.getCurrentController();http_addr='',cont.owner['Website Port'];ws_addr='',cont.owner['Socket Port'];bge.logic.globalDict['Server']=WebSocketHttpServer(BlenderHandler,http_address=http_addr,ws_address=ws_addr)\n if bge.logic.globalDict['Server'].start():cont.owner['Website Address']=bge.logic.globalDict['Server'].httpServer.get_address();cont.owner['Socket Address']=bge.logic.globalDict['Server'].wsServer.get_address();bge.logic.globalDict['Server'].launch_webpage()\n else:print('Error Starting Server')\nif __name__=='__main__':main()");bpy.ops.text.new();bpy.data.texts[-1].name='EndServer';bpy.data.texts['EndServer'].from_string("import bge\nimport time\nif 'Server' in bge.logic.globalDict:bge.logic.globalDict['Server'].stop();time.sleep(1);cont=bge.logic.getCurrentController();cont.activate(cont.actuators['QuitGame'])");bpy.ops.text.new();bpy.data.texts[-1].name='handler.py';bpy.data.texts['handler.py'].use_module=True;bpy.data.texts['handler.py'].from_string("import server\nimport bge\nimport json\nfrom time import sleep\nclass BlenderHandler(server.WebSocketHandler):\n def on_message(self,msg):\n cont=bge.logic.getCurrentController();msg_info=msg\n if 'Actuator' in msg_info:\n direction=msg_info['Actuator'];print('Moving:',direction)\n if 'Speed' in msg_info:\n speed=msg_info['Speed'];print('Speed: ',speed);rot=cont.actuators[direction].dRot;loc=cont.actuators[direction].dLoc\n if sum(rot)!=0:rot=[x/abs(sum(rot)) for x in rot]\n if sum(loc)!=0:loc=[x/abs(sum(loc)) for x in loc]\n cont.actuators[direction].dLoc=[x*speed for x in loc];cont.actuators[direction].dRot=[x*speed for x in rot]\n cont.activate(cont.actuators[direction])\n if 'Stop' in msg_info:\n for act in cont.actuators:cont.deactivate(act)\n if 'Reset' in msg_info:\n try:cont.owner.worldOrientation=[[1.,0.,0.],[0.,1.,0.],[0.,0.,1.]];scene=bge.logic.getCurrentScene();scene.objects['ControllerView'].localPosition=0.,-2.5,0.\n except e:print('Error: '+e)\n def send_message(self,msg):pass");bpy.ops.text.new();bpy.data.texts[-1].name='server.py';bpy.data.texts['server.py'].use_module=True;bpy.data.texts['server.py'].from_string('import tempfile\nimport http.server\nimport threading\nimport os\nimport socket\nimport socketserver\nimport base64\nimport hashlib\nimport struct\nimport shutil\nimport webbrowser\nimport json\nfrom io import StringIO\nfrom string import Template\ndef writeWebsite(file,new_address):site=Template(\'\\nBlenderWebController
 

Button Control

   

Not Connected

 
 
 
 
 
 
 
 
Close

Adjust Movement Sensitivity

 

Swipe Control

   

Not Connected

Swipe Controls

  • TAP: Stop
  • SWIPE: Rotate
  • PINCH: Zoom
  • ROTATE: Rotate Z Axis
Close

Adjust Movement Sensitivity

 

Connection Settings

 

Not Connected

Http & Websocket Address

Close

Scan to connect

 

Swipe Control

Not Connected

Received Messages

\').safe_substitute(address=new_address);html=open(file,\'w\');html.write(site);html.close()\nclass QuiteCGIHandler(http.server.CGIHTTPRequestHandler):\n def log_message(self,format,*args):pass\nclass WebSocketHandler(socketserver.BaseRequestHandler):\n @classmethod\n def AddCustomButton(cls,text,action):cls._customButtons.append({\'text\':text,\'action\':action})\n def on_message(self,msg):print(msg)\n def handle_message(self,msg):\n if self._hasLock():\n msg_data=json.loads(msg)\n if \'MASTER_REQUEST\' in msg_data:\n if msg_data[\'MASTER_REQUEST\']:WebSocketHandler.lock_id=threading.current_thread().ident;self.send_json(dict(MASTER_STATUS=True));print(\'Locking to thread: \',WebSocketHandler.lock_id,\' : \',self.id);self.broadcast_all(dict(SLAVE=True))\n else:WebSocketHandler.lock_id=None;self.send_json(dict(MASTER_STATUS=False));self.broadcast_all(dict(SLAVE=False))\n self.on_message(msg_data)\n else:self.send_json(dict(SLAVE=True));print(\'Locked, trashing: \',msg)\n def on_close(self):print(\'Server: Closing Connection for \',self.client_address);self.send_message(\'Server: Closing Connection\')\n def send_message(self,message):print(\'Sending: \',message);self.send_json(dict(MESSAGE=message))\n def send_json(self,data):self.request.sendall(self._pack(json.dumps(data)))\n def broadcast_all(self,data):\n for t in WebSocketHandler.connections:\n if t.id==self.id:continue\n t.send_json(data)\n magic=b\'258EAFA5-E914-47DA-95CA-C5AB0DC85B11\';_customButtons=[];lock_id=None;connections=[]\n def _hasLock(self):return not WebSocketHandler.lock_id or WebSocketHandler.lock_id==self.id\n def setup(self):print(\'\\nConnection Established\',self.client_address);self.closeHandle=False;self.id=threading.current_thread().ident;self.alive=threading.Event();self.alive.set();WebSocketHandler.connections.append(self)\n def handle(self):\n try:self.handshake()\n except e:print(\'HANDSHAKE ERROR! - Try using FireFox\');print(e)\n def run(self):\n while self.alive.isSet():\n msg=self.request.recv(2)\n if not msg or self.closeHandle or msg[0]==136:print(\'Received Closed\');break\n length=msg[1]&127\n if length==126:length=struct.unpack(\'>H\',self.request.recv(2))[0]\n elif length==127:length=struct.unpack(\'>Q\',self.request.recv(8))[0]\n masks=self.request.recv(4);decoded=\'\'\n for char in self.request.recv(length):decoded+=chr(char^masks[len(decoded)%4])\n self.handle_message(decoded)\n self.close()\n def close(self,message=\'Cxn Closed\'):self.closeHandle=True;self.request.sendall(self._pack(message,True));self.on_close()\n def handshake(self):\n key=None;data=self.request.recv(1024).strip()\n for line in data.splitlines():\n if b\'Upgrade:\' in line:\n upgrade=line.split(b\': \')[1]\n if not upgrade==b\'websocket\':raise Exception(\'Upgrade is Not a websocket!\',data)\n if b\'Sec-WebSocket-Key:\' in line:key=line.split(b\': \')[1];break\n if key is None:raise Exception("Couldn\'t find the key?:",data)\n print(\'Handshaking... \',end=\'\');digest=self._websocketHash(key);response=\'HTTP/1.1 101 Switching Protocols\\r\\n\';response+=\'Upgrade: websocket\\r\\n\';response+=\'Connection: Upgrade\\r\\n\';response+=\'Sec-WebSocket-Accept: %s\\r\\n\\r\\n\'%digest;self.handshake_done=self.request.send(response.encode());print(\'Sending Connected Message... \',end=\'\')\n if self.handshake_done:self.send_message(\'Connected!\');self.send_json({\'BUTTONS\':WebSocketHandler._customButtons});print(\'Connected!\\n\')\n def _websocketHash(self,key):result_string=key+self.magic;sha1_digest=hashlib.sha1(result_string).digest();response_data=base64.encodestring(sha1_digest).strip();response_string=response_data.decode(\'utf8\');return response_string\n def _get_framehead(self,close=False):\n frame_head=bytearray(2);frame_head[0]=frame_head[0]|1<<7\n if close:frame_head[0]=frame_head[0]|8<<0\n else:frame_head[0]=frame_head[0]|1<<0\n return frame_head\n def _int_to_bytes(self,number,bytesize):\n try:return bytearray(number.to_bytes(bytesize,byteorder=\'big\'))\n except:\n d=bytearray(bytesize);fmt=\'!\'+{1:\'b\',2:\'H\',4:\'L\',8:\'Q\'}[bytesize]\n try:struct.pack_into(fmt,d,0,number)\n except:raise OverflowError(\'Need more bytes to represent that number\')\n return d\n def _pack(self,data,close=False):\n frame_head=self._get_framehead(close)\n if len(data)<126:frame_head[1]=len(data)\n elif len(data)<2**16-1:frame_head[1]=126;frame_head+=self._int_to_bytes(len(data),2)\n elif len(data)<2**64-1:frame_head[1]=127;frame_head+=self._int_to_bytes(len(data),8)\n frame=frame_head+data.encode(\'utf-8\');return frame\nclass HTTPServer(threading.Thread):\n def __init__(self,address_info=(\'\',0)):threading.Thread.__init__(self);self.httpd=None;self._start_server(address_info)\n def _start_server(self,address_info):\n try:self.httpd=http.server.HTTPServer(address_info,QuiteCGIHandler);print(\'HTTP Server on : \',self.get_address())\n except Exception as e:print(\'The HTTP server could not be started\')\n def get_address(self):\n if self.httpd is not None:return \'http://{host}:{port}/\'.format(host=socket.gethostbyname(self.httpd.server_name),port=self.httpd.server_port)\n else:return None\n def run(self):\n if self.httpd is not None:self.httpd.serve_forever()\n else:print(\'Error! - HTTP Server is NULL\')\n def stop(self):\n print(\'Killing Http Server ...\')\n if self.httpd is not None:self.httpd.shutdown()\n print(\'Done\')\nclass WebSocketTCPServer(socketserver.ThreadingMixIn,http.server.HTTPServer):\n def __init__(self,server_address,RequestHandlerClass,bind_and_activate=True):socketserver.TCPServer.__init__(self,server_address,RequestHandlerClass,bind_and_activate);self.handlers=[];self.daemon_threads=True\n def finish_request(self,request,client_address):print(\'launching a new request\');t=self.RequestHandlerClass(request,client_address,self);print(\'Request:\',t);self.handlers.append(t);print(\'Num request:\',len(self.handlers));t.run()\n def get_handlers(self):return self.handlers\nclass WebsocketServer(threading.Thread):\n def __init__(self,handler,address_info=(\'\',0)):threading.Thread.__init__(self);self.wsd=None;self.handler=handler;self._start_server(address_info)\n def _start_server(self,address_info):\n try:self.wsd=WebSocketTCPServer(address_info,self.handler);print(self.get_address())\n except Exception as e:print(\'Error! - Websocket Server Not Started!\',e)\n def get_address(self):\n if self.wsd is not None:return \'ws://{host}:{port}/\'.format(host=socket.gethostbyname(self.wsd.server_name),port=self.wsd.server_port)\n else:return None\n def run(self):\n if self.wsd is not None:self.wsd.serve_forever()\n else:print(\'The WebSocket Server is NULL\')\n def stop(self):\n print(\'Killing WebSocket Server ...\')\n if self.wsd is not None:\n for h in self.wsd.handlers:h.alive.clear()\n self.wsd.shutdown()\n print(\'Done\')\n def get_handlers(self):return self.wsd.get_handlers()\n def send(self,msg):\n for h in self.wsd.get_handlers():h.send_message(msg)\nclass WebSocketHttpServer:\n def __init__(self,handler_class=WebSocketHandler,http_address=(\'\',0),ws_address=(\'\',0)):self.http_address=http_address;self.ws_address=ws_address;self.handler=handler_class;self.httpServer=None;self.wsServer=None\n def _clean_server_temp_dir(self):os.chdir(self.cwd);shutil.rmtree(self.tempdir)\n def _make_server_temp_dir(self):self.cwd=os.path.dirname(os.path.realpath(__file__));self.tempdir=tempfile.mkdtemp();os.chdir(self.tempdir);print(\'New temp dir:\',self.tempdir)\n def _make_webpage(self):writeWebsite(self.tempdir+\'/index.html\',self.wsServer.get_address())\n def stop(self):\n try:self.httpServer.stop();self.wsServer.stop();self._clean_server_temp_dir()\n except Exception as e:print(\'The Servers were never started\',e)\n def start(self):\n try:\n self._make_server_temp_dir();self.httpServer=HTTPServer(self.http_address);self.wsServer=WebsocketServer(self.handler,self.ws_address)\n if self.wsServer is not None and self.httpServer is not None:self.httpServer.start();self.wsServer.start();self._make_webpage();return True\n else:print(\'Error Starting The Servers, Something is not Initialized!\');return False\n except Exception as e:print();print(\'Error!!!, There is some error!\');print(e);print();return False\n def send(self,msg):self.wsServer.send(msg)\n def launch_webpage(self):webbrowser.open(self.httpServer.get_address()+\'index.html\')\n def status(self):\n if self.wsServer is None or self.httpServer is None:return False\n else:return True\nif __name__==\'__main__\':print(\'No Main Program!\')');bpy.ops.text.new();bpy.data.texts[-1].name='customButtons.py';bpy.data.texts['customButtons.py'].use_module=True;bpy.data.texts['customButtons.py'].from_string("from server import WebSocketHandler;WebSocketHandler.AddCustomButton('Quit','SendQuit')");bpy.ops.object.add(type='EMPTY');bpy.context.active_object.name='Controller';bpy.ops.object.game_property_new(type='INT',name='Website Port');bpy.ops.object.game_property_new(type='INT',name='Socket Port');bpy.ops.object.game_property_new(type='STRING',name='Website Address');bpy.ops.object.game_property_new(type='STRING',name='Socket Address');bpy.data.objects['Controller'].location=0.,0.,0.;bpy.data.objects['Controller'].game.properties['Website Port'].value=0;bpy.data.objects['Controller'].game.properties['Socket Port'].value=0;bpy.data.objects['Controller'].game.properties['Website Address'].show_debug=True;bpy.data.objects['Controller'].game.properties['Socket Address'].show_debug=True;bpy.ops.logic.sensor_add(type='DELAY',name='StartServer');bpy.ops.logic.sensor_add(type='KEYBOARD',name='QuitKey');bpy.ops.logic.sensor_add(type='MESSAGE',name='QuitMsg');bpy.ops.logic.controller_add(type='PYTHON',name='Sever');bpy.ops.logic.controller_add(type='PYTHON',name='QuitSever');bpy.ops.logic.actuator_add(type='MOTION',name='RotateRight');bpy.ops.logic.actuator_add(type='MOTION',name='RotateLeft');bpy.ops.logic.actuator_add(type='MOTION',name='RotateUp');bpy.ops.logic.actuator_add(type='MOTION',name='RotateDown');bpy.ops.logic.actuator_add(type='MOTION',name='ZRotateLeft');bpy.ops.logic.actuator_add(type='MOTION',name='ZRotateRight');bpy.ops.logic.actuator_add(type='MESSAGE',name='SendQuit');bpy.ops.logic.actuator_add(type='GAME',name='QuitGame');bpy.ops.object.add(type='CAMERA');bpy.context.active_object.name='ControllerView';bpy.data.objects['ControllerView'].location=0.,-5.,0.;bpy.data.objects['ControllerView'].rotation_euler=math.radians(90),0.,0.;bpy.data.objects['ControllerView'].parent=bpy.data.objects['Controller'];bpy.ops.logic.actuator_add(type='MOTION',name='ZoomOut');bpy.ops.logic.actuator_add(type='MOTION',name='ZoomIn');con=bpy.data.objects['ControllerView'].constraints.new('DAMPED_TRACK');con.name='ViewLock';con.target=bpy.data.objects['Controller'];con.track_axis='TRACK_NEGATIVE_Z';bpy.context.scene.camera=bpy.data.objects['ControllerView'];bpy.data.objects['Controller'].game.sensors['StartServer'].use_repeat=True;bpy.data.objects['Controller'].game.sensors['QuitKey'].key='Q';bpy.data.objects['Controller'].game.sensors['QuitMsg'].subject='QUIT';bpy.data.objects['Controller'].game.controllers['Sever'].use_priority=True;bpy.data.objects['Controller'].game.controllers['Sever'].text=bpy.data.texts['StartServer'];bpy.data.objects['Controller'].game.controllers['QuitSever'].text=bpy.data.texts['EndServer'];bpy.data.objects['Controller'].game.actuators['QuitGame'].mode='QUIT';bpy.data.objects['Controller'].game.actuators['RotateRight'].offset_rotation=0.,0.,math.radians(-1);bpy.data.objects['Controller'].game.actuators['RotateLeft'].offset_rotation=0.,0.,math.radians(1);bpy.data.objects['Controller'].game.actuators['RotateUp'].offset_rotation=math.radians(1),0.,0.;bpy.data.objects['Controller'].game.actuators['RotateDown'].offset_rotation=math.radians(-1),0.,0.;bpy.data.objects['Controller'].game.actuators['ZRotateLeft'].offset_rotation=0.,math.radians(1),0.;bpy.data.objects['Controller'].game.actuators['ZRotateRight'].offset_rotation=0.,math.radians(-1),0.;bpy.data.objects['ControllerView'].game.actuators['ZoomIn'].offset_location=0.,0.,.01;bpy.data.objects['ControllerView'].game.actuators['ZoomOut'].offset_location=0.,0.,-.01;bpy.data.objects['Controller'].game.actuators['SendQuit'].to_property=bpy.data.objects['Controller'].name;bpy.data.objects['Controller'].game.actuators['SendQuit'].subject='QUIT';c=bpy.data.objects['Controller'].game.controllers['Sever'];d=bpy.data.objects['Controller'].game.controllers['QuitSever'];bpy.data.objects['Controller'].game.sensors['StartServer'].link(c);bpy.data.objects['Controller'].game.actuators['RotateRight'].link(c);bpy.data.objects['Controller'].game.actuators['RotateLeft'].link(c);bpy.data.objects['Controller'].game.actuators['RotateUp'].link(c);bpy.data.objects['Controller'].game.actuators['RotateDown'].link(c);bpy.data.objects['Controller'].game.actuators['ZRotateLeft'].link(c);bpy.data.objects['Controller'].game.actuators['ZRotateRight'].link(c);bpy.data.objects['Controller'].game.actuators['SendQuit'].link(c);bpy.data.objects['ControllerView'].game.actuators['ZoomIn'].link(c);bpy.data.objects['ControllerView'].game.actuators['ZoomOut'].link(c);bpy.data.objects['Controller'].game.sensors['QuitKey'].link(d);bpy.data.objects['Controller'].game.sensors['QuitMsg'].link(d);bpy.data.objects['Controller'].game.actuators['QuitGame'].link(d) + bpy.context.scene.render.engine='BLENDER_GAME';bpy.context.scene.game_settings.show_debug_properties=True;bpy.ops.text.new();bpy.data.texts[-1].name='StartServer.py';bpy.data.texts['StartServer'].from_string("from server import WebSocketHttpServer\nfrom handler import BlenderHandler\nimport customButtons\nimport threading\ndef main():\n if 'Server' in bge.logic.globalDict:return\n else:\n print('\\n\\n------------------ BUILDING THE SERVER -----------------------');scene=bge.logic.getCurrentScene();scene.active_camera=scene.objects['ControllerView'];cont=bge.logic.getCurrentController();bge.logic.globalDict['Ctrl-Ornt']=cont.owner.worldOrientation.to_3x3();bge.logic.globalDict['CtrlView-Pos']=scene.objects['ControllerView'].localPosition.to_tuple();http_addr='',cont.owner['Website Port'];ws_addr='',cont.owner['Socket Port'];bge.logic.globalDict['Server']=WebSocketHttpServer(BlenderHandler,http_address=http_addr,ws_address=ws_addr)\n if bge.logic.globalDict['Server'].start():cont.owner['Website Address']=bge.logic.globalDict['Server'].httpServer.get_address();cont.owner['Socket Address']=bge.logic.globalDict['Server'].wsServer.get_address();bge.logic.globalDict['Server'].launch_webpage()\n else:print('Error Starting Server')\nif __name__=='__main__':main()");bpy.ops.text.new();bpy.data.texts[-1].name='EndServer.py';bpy.data.texts['EndServer'].from_string("import bge\ncont=bge.logic.getCurrentController()\ntrueSensors=False\nfor s in cont.sensors:trueSensors=trueSensors or s.positive\nif 'Server' in bge.logic.globalDict and trueSensors:bge.logic.globalDict['Server'].stop();bge.logic.globalDict['Server']=None;cont.activate(cont.actuators['QuitGame'])");bpy.ops.text.new();bpy.data.texts[-1].name='handler.py';bpy.data.texts['handler.py'].from_string("import server\nimport bge\nimport json\nclass BlenderHandler(server.WebSocketHandler):\n def on_message(self,msg):\n cont=bge.logic.getCurrentController();msg_info=msg\n if 'Actuator' in msg_info:\n print('Acting: ',msg_info['Actuator']);action=msg_info['Actuator']\n if 'Speed' in msg_info:\n speed=msg_info['Speed'];print(' - Speed: ',speed);rot=cont.actuators[action].dRot;loc=cont.actuators[action].dLoc\n if sum(rot)!=0:rot=[x/abs(sum(rot)) for x in rot]\n if sum(loc)!=0:loc=[x/abs(sum(loc)) for x in loc]\n cont.actuators[action].dLoc=[x*speed for x in loc];cont.actuators[action].dRot=[x*speed for x in rot]\n cont.activate(cont.actuators[action])\n if 'Stop' in msg_info:\n for act in cont.actuators:cont.deactivate(act)\n if 'Reset' in msg_info:\n print('Resetting the scene!')\n try:print('Ornt: ',bge.logic.globalDict['Ctrl-Ornt']);print('Pos: ',bge.logic.globalDict['CtrlView-Pos']);cont.owner.worldOrientation=bge.logic.globalDict['Ctrl-Ornt'];scene=bge.logic.getCurrentScene();scene.objects['ControllerView'].localPosition=bge.logic.globalDict['CtrlView-Pos']\n except e:print('Error: '+e)\n def send_message(self,msg):pass");bpy.ops.text.new();bpy.data.texts[-1].name='server.py';bpy.data.texts['server.py'].from_string('import tempfile\nimport http.server\nimport threading\nimport os\nimport socket\nimport socketserver\nimport base64\nimport hashlib\nimport struct\nimport shutil\nimport webbrowser\nimport json\nfrom io import StringIO\nfrom string import Template\ndef writeWebsite(file,new_address):site=Template(\'\\nBlenderWebController
 

Button Control

   

Not Connected

 
 
 
 
 
 
 
 
Close

Adjust Movement Sensitivity

 

Swipe Control

   

Not Connected

Swipe Controls

  • TAP: Stop
  • SWIPE: Rotate
  • PINCH: Zoom
  • ROTATE: Rotate Z Axis
Close

Adjust Movement Sensitivity

 

Connection Settings

 

Not Connected

Http & Websocket Address

Close

Scan to connect

 

Swipe Control

Not Connected

Received Messages

\').safe_substitute(address=new_address);html=open(file,\'w\');html.write(site);html.close()\nclass QuiteCGIHandler(http.server.CGIHTTPRequestHandler):\n def log_message(self,format,*args):pass\nclass WebSocketHandler(socketserver.BaseRequestHandler):\n @classmethod\n def AddCustomButton(cls,text,action):cls._customButtons.append({\'text\':text,\'action\':action})\n def on_message(self,msg):print(msg)\n def handle_message(self,msg):\n if self._hasLock():\n msg_data=json.loads(msg)\n if \'MASTER_REQUEST\' in msg_data:\n if msg_data[\'MASTER_REQUEST\']:WebSocketHandler.lock_id=threading.current_thread().ident;self.send_json(dict(MASTER_STATUS=True));print(\'Locking to thread: \',WebSocketHandler.lock_id,\' : \',self.id);self.broadcast_all(dict(SLAVE=True))\n else:WebSocketHandler.lock_id=None;self.send_json(dict(MASTER_STATUS=False));self.broadcast_all(dict(SLAVE=False))\n self.on_message(msg_data)\n else:self.send_json(dict(SLAVE=True));print(\'Locked, trashing: \',msg)\n def on_close(self):print(\'Server: Closing Connection for \',self.client_address);self.send_message(\'Server: Closing Connection\')\n def send_message(self,message):print(\'Sending: \',message);self.send_json(dict(MESSAGE=message))\n def send_json(self,data):self.request.sendall(self._pack(json.dumps(data)))\n def broadcast_all(self,data):\n for t in WebSocketHandler.connections:\n if t.id==self.id:continue\n t.send_json(data)\n magic=b\'258EAFA5-E914-47DA-95CA-C5AB0DC85B11\';_customButtons=[];lock_id=None;connections=[]\n def _hasLock(self):return not WebSocketHandler.lock_id or WebSocketHandler.lock_id==self.id\n def setup(self):print(\'\\nConnection Established\',self.client_address);self.closeHandle=False;self.id=threading.current_thread().ident;self.alive=threading.Event();self.alive.set();WebSocketHandler.connections.append(self)\n def handle(self):\n try:self.handshake()\n except e:print(\'HANDSHAKE ERROR! - Try using FireFox\');print(e)\n def run(self):\n while self.alive.isSet():\n msg=self.request.recv(2)\n if not msg or self.closeHandle or msg[0]==136:print(\'Received Closed\');break\n length=msg[1]&127\n if length==126:length=struct.unpack(\'>H\',self.request.recv(2))[0]\n elif length==127:length=struct.unpack(\'>Q\',self.request.recv(8))[0]\n masks=self.request.recv(4);decoded=\'\'\n for char in self.request.recv(length):decoded+=chr(char^masks[len(decoded)%4])\n self.handle_message(decoded)\n self.close()\n def close(self,message=\'Cxn Closed\'):self.closeHandle=True;self.request.sendall(self._pack(message,True));self.on_close()\n def handshake(self):\n key=None;data=self.request.recv(1024).strip()\n for line in data.splitlines():\n if b\'Upgrade:\' in line:\n upgrade=line.split(b\': \')[1]\n if not upgrade==b\'websocket\':raise Exception(\'Upgrade is Not a websocket!\',data)\n if b\'Sec-WebSocket-Key:\' in line:key=line.split(b\': \')[1];break\n if key is None:raise Exception("Couldn\'t find the key?:",data)\n print(\'Handshaking... \',end=\'\');digest=self._websocketHash(key);response=\'HTTP/1.1 101 Switching Protocols\\r\\n\';response+=\'Upgrade: websocket\\r\\n\';response+=\'Connection: Upgrade\\r\\n\';response+=\'Sec-WebSocket-Accept: %s\\r\\n\\r\\n\'%digest;self.handshake_done=self.request.send(response.encode());print(\'Sending Connected Message... \',end=\'\')\n if self.handshake_done:self.send_message(\'Connected!\');self.send_json({\'BUTTONS\':WebSocketHandler._customButtons});print(\'Connected!\\n\')\n def _websocketHash(self,key):result_string=key+self.magic;sha1_digest=hashlib.sha1(result_string).digest();response_data=base64.encodestring(sha1_digest).strip();response_string=response_data.decode(\'utf8\');return response_string\n def _get_framehead(self,close=False):\n frame_head=bytearray(2);frame_head[0]=frame_head[0]|1<<7\n if close:frame_head[0]=frame_head[0]|8<<0\n else:frame_head[0]=frame_head[0]|1<<0\n return frame_head\n def _int_to_bytes(self,number,bytesize):\n try:return bytearray(number.to_bytes(bytesize,byteorder=\'big\'))\n except:\n d=bytearray(bytesize);fmt=\'!\'+{1:\'b\',2:\'H\',4:\'L\',8:\'Q\'}[bytesize]\n try:struct.pack_into(fmt,d,0,number)\n except:raise OverflowError(\'Need more bytes to represent that number\')\n return d\n def _pack(self,data,close=False):\n frame_head=self._get_framehead(close)\n if len(data)<126:frame_head[1]=len(data)\n elif len(data)<2**16-1:frame_head[1]=126;frame_head+=self._int_to_bytes(len(data),2)\n elif len(data)<2**64-1:frame_head[1]=127;frame_head+=self._int_to_bytes(len(data),8)\n frame=frame_head+data.encode(\'utf-8\');return frame\nclass HTTPServer(threading.Thread):\n def __init__(self,address_info=(\'\',0)):threading.Thread.__init__(self);self.httpd=None;self._start_server(address_info)\n def _start_server(self,address_info):\n try:self.httpd=http.server.HTTPServer(address_info,QuiteCGIHandler);print(\'HTTP Server on : \',self.get_address())\n except Exception as e:print(\'The HTTP server could not be started\')\n def get_address(self):\n if self.httpd is not None:return \'http://{host}:{port}/\'.format(host=socket.gethostbyname(self.httpd.server_name),port=self.httpd.server_port)\n else:return None\n def run(self):\n if self.httpd is not None:self.httpd.serve_forever()\n else:print(\'Error! - HTTP Server is NULL\')\n def stop(self):\n print(\'Killing Http Server ...\',end=\'\')\n if self.httpd is not None:self.httpd.shutdown()\n print(\'Done\')\nclass WebSocketTCPServer(socketserver.ThreadingMixIn,http.server.HTTPServer):\n def __init__(self,server_address,RequestHandlerClass,bind_and_activate=True):socketserver.TCPServer.__init__(self,server_address,RequestHandlerClass,bind_and_activate);self.handlers=[];self.daemon_threads=True\n def finish_request(self,request,client_address):print(\'Starting a new request\');t=self.RequestHandlerClass(request,client_address,self);self.handlers.append(t);t.run()\n def get_handlers(self):return self.handlers\nclass WebsocketServer(threading.Thread):\n def __init__(self,handler,address_info=(\'\',0)):threading.Thread.__init__(self);self.wsd=None;self.handler=handler;self._start_server(address_info)\n def _start_server(self,address_info):\n try:self.wsd=WebSocketTCPServer(address_info,self.handler);print(self.get_address())\n except Exception as e:print(\'Error! - Websocket Server Not Started!\',e)\n def get_address(self):\n if self.wsd is not None:return \'ws://{host}:{port}/\'.format(host=socket.gethostbyname(self.wsd.server_name),port=self.wsd.server_port)\n else:return None\n def run(self):\n if self.wsd is not None:self.wsd.serve_forever()\n else:print(\'The WebSocket Server is NULL\')\n def stop(self):\n print(\'Killing WebSocket Server ...\',end=\'\')\n if self.wsd is not None:\n for h in self.wsd.handlers:h.alive.clear()\n self.wsd.shutdown()\n print(\'Done\')\n def get_handlers(self):return self.wsd.get_handlers()\n def send(self,msg):\n for h in self.wsd.get_handlers():h.send_message(msg)\nclass WebSocketHttpServer:\n def __init__(self,handler_class=WebSocketHandler,http_address=(\'\',0),ws_address=(\'\',0)):self.http_address=http_address;self.ws_address=ws_address;self.handler=handler_class;self.httpServer=None;self.wsServer=None\n def _clean_server_temp_dir(self):\n try:os.chdir(self.cwd);shutil.rmtree(self.tempdir)\n except Exception as e:print(\'Err Changing Directory: \',self.cwd)\n def _make_server_temp_dir(self):self.cwd=os.getcwd();self.tempdir=tempfile.mkdtemp();os.chdir(self.tempdir);print(\'New temp dir:\',self.tempdir)\n def _make_webpage(self):writeWebsite(self.tempdir+\'/index.html\',self.wsServer.get_address())\n def stop(self):\n try:self.httpServer.stop();self.wsServer.stop();self._clean_server_temp_dir()\n except Exception as e:print(\'There was an error during clean up: \',e);print()\n def start(self):\n try:\n self._make_server_temp_dir();self.httpServer=HTTPServer(self.http_address);self.wsServer=WebsocketServer(self.handler,self.ws_address)\n if self.wsServer is not None and self.httpServer is not None:self.httpServer.start();self.wsServer.start();self._make_webpage();return True\n else:print(\'Error Starting The Servers, Something is not Initialized!\');return False\n except Exception as e:print();print(\'Error!!!, There is some error!\');print(e);print();return False\n def send(self,msg):self.wsServer.send(msg)\n def launch_webpage(self):webbrowser.open(self.httpServer.get_address()+\'index.html\')\n def status(self):\n if self.wsServer is None or self.httpServer is None:return False\n else:return True\nif __name__==\'__main__\':print(\'No Main Program!\')');bpy.ops.text.new();bpy.data.texts[-1].name='customButtons.py';bpy.data.texts['customButtons.py'].from_string("from server import WebSocketHandler;WebSocketHandler.AddCustomButton('Quit','SendQuit')");bpy.ops.object.add(type='EMPTY');bpy.context.active_object.name='Controller';bpy.ops.object.game_property_new(type='INT',name='Website Port');bpy.ops.object.game_property_new(type='INT',name='Socket Port');bpy.ops.object.game_property_new(type='STRING',name='Website Address');bpy.ops.object.game_property_new(type='STRING',name='Socket Address');bpy.data.objects['Controller'].location=0.,0.,0.;bpy.data.objects['Controller'].game.properties['Website Port'].value=0;bpy.data.objects['Controller'].game.properties['Socket Port'].value=0;bpy.data.objects['Controller'].game.properties['Website Address'].show_debug=True;bpy.data.objects['Controller'].game.properties['Socket Address'].show_debug=True;bpy.ops.logic.sensor_add(type='DELAY',name='StartServer');bpy.ops.logic.sensor_add(type='KEYBOARD',name='QuitKey');bpy.ops.logic.sensor_add(type='MESSAGE',name='QuitMsg');bpy.ops.logic.controller_add(type='PYTHON',name='Sever');bpy.ops.logic.controller_add(type='PYTHON',name='QuitSever');bpy.ops.logic.actuator_add(type='MOTION',name='RotateRight');bpy.ops.logic.actuator_add(type='MOTION',name='RotateLeft');bpy.ops.logic.actuator_add(type='MOTION',name='RotateUp');bpy.ops.logic.actuator_add(type='MOTION',name='RotateDown');bpy.ops.logic.actuator_add(type='MOTION',name='ZRotateLeft');bpy.ops.logic.actuator_add(type='MOTION',name='ZRotateRight');bpy.ops.logic.actuator_add(type='MESSAGE',name='SendQuit');bpy.ops.logic.actuator_add(type='GAME',name='QuitGame');bpy.ops.object.add(type='CAMERA');bpy.context.active_object.name='ControllerView';bpy.data.objects['ControllerView'].location=0.,-5.,0.;bpy.data.objects['ControllerView'].rotation_euler=math.radians(90),0.,0.;bpy.data.objects['ControllerView'].parent=bpy.data.objects['Controller'];bpy.ops.logic.actuator_add(type='MOTION',name='ZoomOut');bpy.ops.logic.actuator_add(type='MOTION',name='ZoomIn');con=bpy.data.objects['ControllerView'].constraints.new('DAMPED_TRACK');con.name='ViewLock';con.target=bpy.data.objects['Controller'];con.track_axis='TRACK_NEGATIVE_Z';bpy.context.scene.camera=bpy.data.objects['ControllerView'];bpy.data.objects['Controller'].game.sensors['StartServer'].use_repeat=True;bpy.data.objects['Controller'].game.sensors['QuitKey'].key='Q';bpy.data.objects['Controller'].game.sensors['QuitMsg'].subject='QUIT';bpy.data.objects['Controller'].game.controllers['Sever'].use_priority=True;bpy.data.objects['Controller'].game.controllers['Sever'].text=bpy.data.texts['StartServer'];bpy.data.objects['Controller'].game.controllers['QuitSever'].text=bpy.data.texts['EndServer'];bpy.data.objects['Controller'].game.actuators['QuitGame'].mode='QUIT';bpy.data.objects['Controller'].game.actuators['RotateRight'].offset_rotation=0.,0.,math.radians(-1);bpy.data.objects['Controller'].game.actuators['RotateLeft'].offset_rotation=0.,0.,math.radians(1);bpy.data.objects['Controller'].game.actuators['RotateUp'].offset_rotation=math.radians(1),0.,0.;bpy.data.objects['Controller'].game.actuators['RotateDown'].offset_rotation=math.radians(-1),0.,0.;bpy.data.objects['Controller'].game.actuators['ZRotateLeft'].offset_rotation=0.,math.radians(1),0.;bpy.data.objects['Controller'].game.actuators['ZRotateRight'].offset_rotation=0.,math.radians(-1),0.;bpy.data.objects['ControllerView'].game.actuators['ZoomIn'].offset_location=0.,0.,.01;bpy.data.objects['ControllerView'].game.actuators['ZoomOut'].offset_location=0.,0.,-.01;bpy.data.objects['Controller'].game.actuators['SendQuit'].to_property=bpy.data.objects['Controller'].name;bpy.data.objects['Controller'].game.actuators['SendQuit'].subject='QUIT';c=bpy.data.objects['Controller'].game.controllers['Sever'];d=bpy.data.objects['Controller'].game.controllers['QuitSever'];bpy.data.objects['Controller'].game.sensors['StartServer'].link(c);bpy.data.objects['Controller'].game.actuators['RotateRight'].link(c);bpy.data.objects['Controller'].game.actuators['RotateLeft'].link(c);bpy.data.objects['Controller'].game.actuators['RotateUp'].link(c);bpy.data.objects['Controller'].game.actuators['RotateDown'].link(c);bpy.data.objects['Controller'].game.actuators['ZRotateLeft'].link(c);bpy.data.objects['Controller'].game.actuators['ZRotateRight'].link(c);bpy.data.objects['Controller'].game.actuators['SendQuit'].link(c);bpy.data.objects['ControllerView'].game.actuators['ZoomIn'].link(c);bpy.data.objects['ControllerView'].game.actuators['ZoomOut'].link(c);bpy.data.objects['Controller'].game.sensors['QuitKey'].link(d);bpy.data.objects['Controller'].game.sensors['QuitMsg'].link(d);bpy.data.objects['Controller'].game.actuators['QuitGame'].link(d) for s in bpy.data.objects['ControllerView'].game.sensors:s.show_expanded=False for s in bpy.data.objects['ControllerView'].game.actuators:s.show_expanded=False for s in bpy.data.objects['Controller'].game.sensors:s.show_expanded=False diff --git a/examples/Coord_systems_static.blend b/examples/Coord_systems_static.blend new file mode 100644 index 0000000..55d1b82 Binary files /dev/null and b/examples/Coord_systems_static.blend differ diff --git a/examples/Water-Salt.blend b/examples/Water-Salt.blend index d10e99a..ef39339 100644 Binary files a/examples/Water-Salt.blend and b/examples/Water-Salt.blend differ diff --git a/src/WebControllerAddon.py b/src/WebControllerAddon.py index 22aba27..5f29eb2 100644 --- a/src/WebControllerAddon.py +++ b/src/WebControllerAddon.py @@ -49,22 +49,19 @@ def execute(self, context): #-------------- Create Text Files -------------------------- bpy.ops.text.new() - bpy.data.texts[-1].name = 'StartServer' + bpy.data.texts[-1].name = 'StartServer.py' bpy.data.texts['StartServer'].from_string($_STARTSERVERS_PY) bpy.ops.text.new() - bpy.data.texts[-1].name = "EndServer" + bpy.data.texts[-1].name = "EndServer.py" bpy.data.texts["EndServer"].from_string($_ENDSERVERS_PY) bpy.ops.text.new() bpy.data.texts[-1].name = "handler.py" - bpy.data.texts["handler.py"].use_module = True bpy.data.texts["handler.py"].from_string($_HANDLER_PY) bpy.ops.text.new() bpy.data.texts[-1].name = "server.py" - bpy.data.texts["server.py"].use_module = True bpy.data.texts["server.py"].from_string($_SERVER_PY) bpy.ops.text.new() bpy.data.texts[-1].name = "customButtons.py" - bpy.data.texts["customButtons.py"].use_module = True bpy.data.texts["customButtons.py"].from_string($_CUSTOMBUTTONS_PY) #-------------- Add empty Controller ------------------------ diff --git a/src/endServers.py b/src/endServers.py index b44fa2f..f3c6de5 100644 --- a/src/endServers.py +++ b/src/endServers.py @@ -1,7 +1,11 @@ import bge -import time -if "Server" in bge.logic.globalDict: + +cont = bge.logic.getCurrentController() +trueSensors = False +for s in cont.sensors: + trueSensors = trueSensors or s.positive + +if "Server" in bge.logic.globalDict and trueSensors: bge.logic.globalDict["Server"].stop() - time.sleep(1) - cont = bge.logic.getCurrentController() + bge.logic.globalDict["Server"] = None cont.activate(cont.actuators["QuitGame"]) \ No newline at end of file diff --git a/src/handler.py b/src/handler.py index 39598f1..94cdbb3 100644 --- a/src/handler.py +++ b/src/handler.py @@ -1,30 +1,21 @@ -#! /usr/bin/env python3 - -# Copyright (C) <2014> -# 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 server import bge import json -from time import sleep class BlenderHandler(server.WebSocketHandler): def on_message(self, msg): cont = bge.logic.getCurrentController() msg_info = msg if "Actuator" in msg_info: - direction = msg_info["Actuator"] - print("Moving:", direction) + print("Acting: ", msg_info["Actuator"]) + action = msg_info["Actuator"] if "Speed" in msg_info: speed = msg_info["Speed"] - print("Speed: ", speed) + print(" - Speed: ", speed) #get the curretn speed - rot = cont.actuators[direction].dRot - loc = cont.actuators[direction].dLoc + rot = cont.actuators[action].dRot + loc = cont.actuators[action].dLoc #Normalize the speed back to 1 #print(sum(rot)) if sum(rot) != 0: @@ -33,21 +24,23 @@ def on_message(self, msg): if sum(loc) != 0: loc = [x/abs(sum(loc)) for x in loc] #set teh new speed - cont.actuators[direction].dLoc = [x*speed for x in loc] - cont.actuators[direction].dRot = [x*speed for x in rot] - cont.activate(cont.actuators[direction]) -# sleep(cont.owner.get("MoveTime")) + cont.actuators[action].dLoc = [x*speed for x in loc] + cont.actuators[action].dRot = [x*speed for x in rot] + cont.activate(cont.actuators[action]) if "Stop" in msg_info: for act in cont.actuators: cont.deactivate(act) if "Reset" in msg_info: + print("Resetting the scene!") try: - cont.owner.worldOrientation = [[1.0, 0.0, 0.0], [ 0.0, 1.0, 0.0], [0.0, 0.0, 1.0]] + print("Ornt: ", bge.logic.globalDict['Ctrl-Ornt']) + print("Pos: ", bge.logic.globalDict["CtrlView-Pos"]) + cont.owner.worldOrientation = bge.logic.globalDict['Ctrl-Ornt'] scene = bge.logic.getCurrentScene() - scene.objects["ControllerView"].localPosition = (0.0, -2.5, 0.0) + scene.objects["ControllerView"].localPosition = bge.logic.globalDict["CtrlView-Pos"] except e: print("Error: "+ e) - + def send_message(self, msg): pass \ No newline at end of file diff --git a/src/server.py b/src/server.py index 4fafeb5..ccb9877 100644 --- a/src/server.py +++ b/src/server.py @@ -253,7 +253,7 @@ def run(self): def stop(self): #Overwrtien from Threading.Thread - print("Killing Http Server ...") + print("Killing Http Server ...", end="") if self.httpd is not None: self.httpd.shutdown() print("Done") @@ -267,19 +267,11 @@ def __init__(self, server_address, RequestHandlerClass, bind_and_activate=True): def finish_request(self, request, client_address): #Finish one request by instantiating RequestHandlerClass - print("launching a new request") + print("Starting a new request") t = self.RequestHandlerClass(request, client_address, self) - print("Request:" , t) self.handlers.append(t) - print("Num request:" ,len(self.handlers)) t.run() - # def process_request(self, request, client_address): - # #Start a new thread to process the request - # t = threading.Thread(target = self.process_request_thread, args = (request, client_address)) - # t.daemon = True - # t.start() - def get_handlers(self): #returns the list of handlers return self.handlers @@ -313,7 +305,7 @@ def run(self): print("The WebSocket Server is NULL") def stop(self): - print("Killing WebSocket Server ...") + print("Killing WebSocket Server ...", end="") if self.wsd is not None: for h in self.wsd.handlers: h.alive.clear() @@ -338,12 +330,15 @@ def __init__(self, handler_class = WebSocketHandler, http_address=('',0), ws_add self.wsServer = None def _clean_server_temp_dir(self): - os.chdir(self.cwd) - shutil.rmtree(self.tempdir) + try: + os.chdir(self.cwd) + shutil.rmtree(self.tempdir) + except Exception as e: + print("Err Changing Directory: ", self.cwd) def _make_server_temp_dir(self): #make the new temp directory - self.cwd = os.path.dirname(os.path.realpath(__file__)) + self.cwd = os.getcwd() self.tempdir = tempfile.mkdtemp() os.chdir(self.tempdir) print("New temp dir:", self.tempdir) @@ -357,7 +352,8 @@ def stop(self): self.wsServer.stop() self._clean_server_temp_dir() except Exception as e: - print("The Servers were never started", e) + print("There was an error during clean up: ", e) + print() def start(self): try: diff --git a/src/startServers.py b/src/startServers.py index a397084..ec094a4 100644 --- a/src/startServers.py +++ b/src/startServers.py @@ -20,6 +20,8 @@ def main(): scene=bge.logic.getCurrentScene(); scene.active_camera=scene.objects['ControllerView']; cont=bge.logic.getCurrentController() + bge.logic.globalDict['Ctrl-Ornt'] = cont.owner.worldOrientation.to_3x3() + bge.logic.globalDict["CtrlView-Pos"] = scene.objects["ControllerView"].localPosition.to_tuple() http_addr='',cont.owner['Website Port'] ws_addr='',cont.owner['Socket Port'] diff --git a/src/web/controller.js b/src/web/controller.js index 1206440..c1b3646 100644 --- a/src/web/controller.js +++ b/src/web/controller.js @@ -106,6 +106,7 @@ function addCustomButtons(buttonJSON){ }); buttons += ''; $(".customButtons").html(buttons); + $(".customButtons > div").controlgroup({ defaults: true }); log("Added Custom Buttons"); } /* -------------------------- Document Ready Function ---------------------------- diff --git a/src/web/style.css b/src/web/style.css index 77e092a..f42d44b 100644 --- a/src/web/style.css +++ b/src/web/style.css @@ -41,4 +41,9 @@ a { -webkit-user-select: none !important; } #popup-strength .ui-slider-track { margin-left: 15px; +} + +.customButtons > div{ + display: inline-block; + margin-right: 8px; } \ No newline at end of file