ikatson/.gitignore

## .gitignore
*.pyc

## index.html
<!doctype html>
<meta charset=utf-8>
<title>UWSGI WS test</title>
<link rel="stylesheet" href="//maxcdn.bootstrapcdn.com/bootstrap/3.2.0/css/bootstrap.min.css">
<script src="//ajax.googleapis.com/ajax/libs/angularjs/1.2.26/angular.min.js"></script>
<script>
  angular.module('app', []).controller('Ctrl', function ($scope) {
    this.logMessages = [];

    var self = this;

    var log = function (msg) {
      self.logMessages.push({date: new Date(), msg: msg});
      $scope.$digest();
    }

    var ws = new WebSocket('ws://localhost:5000/ws/');
    ws.onopen = function () {
      log('WS open');
      ws.send('message to server');
    }
    ws.onmessage = function (msg) {
      log('WS message received: ' + msg);
    };
    ws.onclose = function () {
      log('WS closed');
    };
    ws.onerror = function (err) {
      log('WS error: ' + err);
    }
  });
</script>
<body ng-app="app" ng-controller="Ctrl as ctrl" class="container">
  <h2>uWSGI websocket test</h2>

  <div ng-repeat="msg in ctrl.logMessages.slice().reverse()"><pre>[{{msg.date|date:'mediumTime'}}]: {{msg.msg}}</pre><div>
</body>

## requirements.txt
gevent>=1.0
uwsgi

## server.py
import uwsgi

def application(env, start_response):
  if env['PATH_INFO'] != '/ws/':
    start_response('404 Not Found', [])
    return
  uwsgi.websocket_handshake(env['HTTP_SEC_WEBSOCKET_KEY'], env.get('HTTP_ORIGIN', ''))
  websocket_fd = uwsgi.connection_fd()

  def process_msg(msg):
    uwsgi.websocket_send('got %s' % msg)

  while True:
    uwsgi.wait_fd_read(websocket_fd, 3)
    uwsgi.suspend()
    fd = uwsgi.ready_fd()
    if fd > -1:
      if fd == websocket_fd:
        msg = uwsgi.websocket_recv_nb()
        if msg:
          process_msg(msg)
    else:
      # on timeout call websocket_recv_nb again to manage ping/pong
      msg = uwsgi.websocket_recv_nb()
      if msg:
        process_msg(msg)

## uwsgi.ini
[uwsgi]
gevent=1000
route = ^/$ static:%dindex.html
wsgi=server:application
pythonpath=%d
pythonhome=$(VIRTUAL_ENV)
http=:5000
http-websockets=
master=
py-autoreload=1
	<!doctype html>
	<meta charset=utf-8>
	<title>UWSGI WS test</title>
	<link rel="stylesheet" href="//maxcdn.bootstrapcdn.com/bootstrap/3.2.0/css/bootstrap.min.css">
	<script src="//ajax.googleapis.com/ajax/libs/angularjs/1.2.26/angular.min.js"></script>
	<script>
	angular.module('app', []).controller('Ctrl', function ($scope) {
	this.logMessages = [];

	var self = this;

	var log = function (msg) {
	self.logMessages.push({date: new Date(), msg: msg});
	$scope.$digest();
	}

	var ws = new WebSocket('ws://localhost:5000/ws/');
	ws.onopen = function () {
	log('WS open');
	ws.send('message to server');
	}
	ws.onmessage = function (msg) {
	log('WS message received: ' + msg);
	};
	ws.onclose = function () {
	log('WS closed');
	};
	ws.onerror = function (err) {
	log('WS error: ' + err);
	}
	});
	</script>
	<body ng-app="app" ng-controller="Ctrl as ctrl" class="container">
	<h2>uWSGI websocket test</h2>

	<div ng-repeat="msg in ctrl.logMessages.slice().reverse()"><pre>[{{msg.date\|date:'mediumTime'}}]: {{msg.msg}}</pre><div>
	</body>
	import uwsgi

	def application(env, start_response):
	if env['PATH_INFO'] != '/ws/':
	start_response('404 Not Found', [])
	return
	uwsgi.websocket_handshake(env['HTTP_SEC_WEBSOCKET_KEY'], env.get('HTTP_ORIGIN', ''))
	websocket_fd = uwsgi.connection_fd()

	def process_msg(msg):
	uwsgi.websocket_send('got %s' % msg)

	while True:
	uwsgi.wait_fd_read(websocket_fd, 3)
	uwsgi.suspend()
	fd = uwsgi.ready_fd()
	if fd > -1:
	if fd == websocket_fd:
	msg = uwsgi.websocket_recv_nb()
	if msg:
	process_msg(msg)
	else:
	# on timeout call websocket_recv_nb again to manage ping/pong
	msg = uwsgi.websocket_recv_nb()
	if msg:
	process_msg(msg)
	[uwsgi]
	gevent=1000
	route = ^/$ static:%dindex.html
	wsgi=server:application
	pythonpath=%d
	pythonhome=$(VIRTUAL_ENV)
	http=:5000
	http-websockets=
	master=
	py-autoreload=1