jyapayne/socketIO-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Prepare to run tests

Browse source
This commit is contained in:
Roy Hyunjin Han 2015-02-22 17:30:35 -05:00
commit dec8e09327
4 changed files with 43 additions and 25 deletions
Download patch file Download diff file Expand all files Collapse all files

2
.travis.yml
View file

@ -7,7 +7,7 @@ before_install:
- sudo apt-get update
- sudo apt-get install nodejs
install:
- npm install -G socket.io@1.3.1
- npm install -G socket.io
- npm install -G http-proxy
- pip install -U requests
- pip install -U six

2
README.rst
View file

@ -30,7 +30,7 @@ Activate isolated environment. ::
VIRTUAL_ENV=$HOME/.virtualenv
source $VIRTUAL_ENV/bin/activate
Launch your server. ::
Launch your socket.io server. ::
# Get package folder
PACKAGE_FOLDER=`python -c "import os, socketIO_client; print(os.path.dirname(socketIO_client.__file__))"`

33
socketIO_client/__init__.py
View file

@ -4,7 +4,8 @@ from .logs import LoggingMixin
from .namespaces import EngineIONamespace, SocketIONamespace, find_callback
from .parsers import (
parse_host, parse_engineIO_session,
parse_socketIO_data, format_socketIO_data)
format_socketIO_packet_data, parse_socketIO_packet_data,
get_namespace_path)
from .symmetries import get_character
from .transports import XHR_PollingTransport, prepare_http_session, TRANSPORTS
@ -69,17 +70,22 @@ class EngineIO(LoggingMixin):
return parse_engineIO_session(engineIO_packet_data)
def _negotiate_transport(self):
self.__transport = self._get_transport('xhr-polling')
transport_name = 'xhr-polling'
self.__transport = self._get_transport(transport_name)
self._transport_name = transport_name
def _reset_heartbeat(self):
try:
self._heartbeat_thread.stop()
except AttributeError:
pass
ping_interval = self._engineIO_session.ping_interval
self._heartbeat_thread = HeartbeatThread(
send_heartbeat=self.__transport._ping,
relax_interval_in_seconds=self._engineIO_session.ping_interval,
hurry_interval_in_seconds=1)
send_heartbeat=self._ping,
relax_interval_in_seconds=ping_interval,
hurry_interval_in_seconds=1 if self._transport_name in [
'xhr-polling',
] else ping_interval)
self._heartbeat_thread.start()
def _connect_namespaces(self):
@ -197,7 +203,6 @@ class EngineIO(LoggingMixin):
def _process_packet(self, packet):
engineIO_packet_type, engineIO_packet_data = packet
print('engineIO_packet_type = %s' % engineIO_packet_type)
# Launch callbacks
namespace = self.get_namespace()
try:
@ -310,7 +315,7 @@ class SocketIO(EngineIO):
def connect(self, path):
socketIO_packet_type = 0
socketIO_packet_data = format_socketIO_data(path)
socketIO_packet_data = format_socketIO_packet_data(path)
self._message(str(socketIO_packet_type) + socketIO_packet_data)
def disconnect(self, path=''):
@ -318,7 +323,7 @@ class SocketIO(EngineIO):
return
if path:
socketIO_packet_type = 1
socketIO_packet_data = format_socketIO_data(path)
socketIO_packet_data = format_socketIO_packet_data(path)
self._message(str(socketIO_packet_type) + socketIO_packet_data)
else:
self._close()
@ -333,7 +338,7 @@ class SocketIO(EngineIO):
callback, args = find_callback(args, kw)
ack_id = self._set_ack_callback(callback) if callback else None
socketIO_packet_type = 2
socketIO_packet_data = format_socketIO_data(path, ack_id, args)
socketIO_packet_data = format_socketIO_packet_data(path, ack_id, args)
self._message(str(socketIO_packet_type) + socketIO_packet_data)
def send(self, data='', callback=None):
@ -344,7 +349,7 @@ class SocketIO(EngineIO):
def _ack(self, path, ack_id, *args):
socketIO_packet_type = 3
socketIO_packet_data = format_socketIO_data(path, ack_id, args)
socketIO_packet_data = format_socketIO_packet_data(path, ack_id, args)
self._message(str(socketIO_packet_type) + socketIO_packet_data)
# React
@ -366,9 +371,9 @@ class SocketIO(EngineIO):
return
socketIO_packet_type = int(get_character(engineIO_packet_data, 0))
socketIO_packet_data = engineIO_packet_data[1:]
print('socketIO_packet_type = %s' % socketIO_packet_type)
# Launch callbacks
namespace = self.get_namespace()
path = get_namespace_path(socketIO_packet_data)
namespace = self.get_namespace(path)
try:
delegate = {
0: self._on_connect,
@ -392,7 +397,7 @@ class SocketIO(EngineIO):
find_packet_callback('disconnect')()
def _on_event(self, data, find_packet_callback):
data_parsed = parse_socketIO_data(data)
data_parsed = parse_socketIO_packet_data(data)
args = data_parsed.args
try:
event = args.pop(0)
@ -404,7 +409,7 @@ class SocketIO(EngineIO):
find_packet_callback(event)(*args)
def _on_ack(self, data, find_packet_callback):
data_parsed = parse_socketIO_data(data)
data_parsed = parse_socketIO_packet_data(data)
try:
ack_callback = self._get_ack_callback(data_parsed.ack_id)
except KeyError:

31
socketIO_client/parsers.py
View file

@ -53,8 +53,17 @@ def decode_engineIO_content(content):
yield engineIO_packet_type, engineIO_packet_data
def parse_socketIO_data(data):
data = decode_string(data)
def format_socketIO_packet_data(path=None, ack_id=None, args=None):
socketIO_packet_data = json.dumps(args, ensure_ascii=False) if args else ''
if ack_id is not None:
socketIO_packet_data = str(ack_id) + socketIO_packet_data
if path:
socketIO_packet_data = path + ',' + socketIO_packet_data
return socketIO_packet_data
def parse_socketIO_packet_data(socketIO_packet_data):
data = decode_string(socketIO_packet_data)
if data.startswith('/'):
try:
path, data = data.split(',', 1)
@ -76,13 +85,17 @@ def parse_socketIO_data(data):
return SocketIOData(path=path, ack_id=ack_id, args=args)
def format_socketIO_data(path=None, ack_id=None, args=None):
socketIO_packet_data = json.dumps(args, ensure_ascii=False) if args else ''
if ack_id is not None:
socketIO_packet_data = str(ack_id) + socketIO_packet_data
if path:
socketIO_packet_data = path + ',' + socketIO_packet_data
return socketIO_packet_data
def get_namespace_path(socketIO_packet_data):
if '/' != get_character(socketIO_packet_data, 0):
return ''
# Loop incrementally in case there is binary data
parts = []
for i in range(len(socketIO_packet_data)):
character = get_character(socketIO_packet_data, i)
if ',' == character:
break
parts.append(character)
return ''.join(parts)
def _make_packet_header(packet_string):