SocketIO support for TurboGears through gevent-socketio
Project description
About tgext.socketio
tgext.socketio provides an easy way to implement SocketIO in TurboGears2. SocketIO support is provided by gevent-socketio and specific SocketIO server based on gevent is provided.
Installing
tgextsocketio can be installed from pypi:
pip install tgext.socketio
Running
SocketIO support requires a custom GEvent based HTTP server to work correctly, remember to edit your development.ini and add:
# SOCKETIO doesn't work with debug mode debug = false [server:main] use = egg:tgext.socketio#socketio socketio_resource = socketio host = 127.0.0.1 port = 8080
tgext.socketio#socketio is the server provided by tgext.socketio to correctly support SocketIO, while socketio_resource is the path of your SocketIOController class.
By default socketio is used so you can mount a SocketIOController subclass under the RootController or you can mount it in any other location and change your socketio_resource option.
Using SocketIOController
SocketIOController works like any other TurboGears controller but supports serving SocketIOTGNamespace as sub controllers. SocketIOController can also behave like any other TG Controller and provide normal web pages.
SocketIOTGNamespace are subclasses of socketio.namespace.Basenamespace with additional TurboGears features like @validate and @require support. Please keep in mind that SocketIOTGNamespace requires at least TurboGears 2.3.1, if you want to use a previous TurboGears version you can still use SocketIOController with plain socketio.namespace.Basenamespace classes.
Usage Example
The following is a very simple example that handles two type of events ping and fireball and response on real time to those:
from tgext.socketio import SocketIOTGNamespace, SocketIOController
class PingPong(SocketIOTGNamespace):
def on_ping(self, attack):
if attack['type'] == 'fireball':
for i in range(10):
self.emit('pong',{'sound':'bang!'})
else:
self.emit('pong',{'sound':'pong'})
class SocketIO(SocketIOController):
pingpong = PingPong
@expose()
def page(self, **kw):
return '''
<html>
<body>
<div>
<a class="ping" href="#" data-attack="ping">Ping</a>
<a class="ping" href="#" data-attack="fireball">Fireball</a>
<a class="ping" href="#" data-attack="auto">Auto</a>
<a class="ping" href="#" data-attack="error">Error</a>
</div>
<div id="result"></div>
<script src="//cdnjs.cloudflare.com/ajax/libs/jquery/2.1.1/jquery.min.js"></script>
<script src="//cdnjs.cloudflare.com/ajax/libs/socket.io/0.9.16/socket.io.min.js"></script>
<script>
$(function(){
var socket = io.connect('/pingpong', {'resource':'socketio'});
socket.on('pong',function(data){
$('#result').append(data.sound + '<br/>');
});
socket.on('error',function(error, info) {
if (error == 'method_access_denied') { alert(info); }
else { console.log(info); alert(error); }
});
$('.ping').click(function(event){
event.preventDefault();
socket.emit('ping',{'type':$(this).data('attack')});
});
});
</script>
</body>
</html>
'''
class RootController(BaseController):
socketio = SocketIO()
Keep in mind that the SocketIOController must be mounted in the same location specified by socketio_resource property in your configuration file.
Using Validators and Requirements
SocketIOTGNamespace also supports using @validate and @require TurboGears decorators.
The same example can be changed to provide validation and permission checks with a few lines of code:
from tg import validate, require, predicates
from tg.validation import TGValidationError
import random
class NoFireBallValidator(object):
def to_python(self, value, *args, **kw):
type_ = value['type']
if type_ == 'auto':
return {'type': random.choice(['ping', 'fireball'])}
elif type_ == 'error':
raise TGValidationError('Got an error!')
return value
class PingPong(SocketIOTGNamespace):
@require(predicates.not_anonymous())
@validate({'attack': NoFireBallValidator()})
def on_ping(self, attack):
if attack['type'] == 'fireball':
for i in range(10):
self.emit('pong',{'sound':'bang!'})
else:
self.emit('pong',{'sound':'pong'})
PubSub Support
tgext.socketio has builtin support for PubSub paradigm based on anypubsub library. If you want to use PubSub you should install anypubsub through pip install anypubsub or add it to your project dependencies.
PubSub support works by subclassing from tgext.socketio.pubsub.PubSubTGNamespace this special namespace permits clients to subscribe to channels using socket.emit('subscribe', 'channel_name') from the javascript interface.
Whenever an user subscribes to a channel, the PubSubTGNamespace subclass will receive a call for subscribe_channelname method, which can return if the user is permitted to subscribe to the given channel or not (@require decorator can be used). The subscribe_channelname method can also return a different channel name if you want to specify a subchannel.
For each message published on the subscribed channel PubSubTGNamespace will emit a pubblication event, which can be trapped by the socket.io client to perform required actions.
Publishing a message will be possible through PubSubTGNamespace.publish.
You can see a simple example providing a real time chat implemented on redis backend in examples/chat.py
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
File details
Details for the file tgext.socketio-0.0.3.tar.gz.
File metadata
- Download URL: tgext.socketio-0.0.3.tar.gz
- Upload date:
- Size: 7.8 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 488c344a20610944fc58cdb526e2bf3b3cd837146d68393cfbbbb4a77a6b47ed |
|
| MD5 | acc50ef775aaf8eb79742142cb469eb1 |
|
| BLAKE2b-256 | 36d6a45823cad31c259ba1ab90e722c54cf12eef21e9ef9eb5793b1378d0885c |
