Pega.IO

Pega.IO is a Socket.IO/Node.JS project that makes implementing a scalable and reliable pub/sub application hassle free. Your back-end doesn't need to be written in Node.JS to take advantage of this.

For example: Imagine you have a server running a Python application using Tweepy to listen for real-time tweets about foosball, and you've also got a website written in PHP where people are posting comments on your foosball blog posts.

You have decided to build a third website that shows all of this activity to hundreds of thousands of interested people in real-time. Where in the world do you start? Pega.IO.

Easy Install and Run on Linux

curl http://cloud.github.com/downloads/Gootch/pega.io/install.sh | sh

Install Manually

Dependencies

You must first install Node, NPM and Redis.

Pega.IO

git clone git://github.com/Gootch/pega.io.git
cd pega.io
npm install .
node app.js

How to Configure

For a simple Pega.IO server, no configuration required!

Examples: Push from any back-end

Just use a simple HTTP POST to push any message you like to your users.

Python (App Engine)

form_fields = {
	"channel":"channel-to-broadcast-to",
	"secretkey":"mysecretkey",
	"property1":"Some Text",
	"property2":"Some More Text
}
form_data = urllib.urlencode(form_fields)

urlfetch.make_fetch_call(rpc=urlfetch.create_rpc(), 
	url="http://www.your-pega-io-server.com:8888/send", 
	payload=form_data, 
	method=urlfetch.POST, 
	headers={'Content-Type': 'application/x-www-form-urlencoded'})

PHP

$url = 'http://www.your-pega-io-server.com:8888/send';
$fields = array(
	'channel'=>urlencode("channel-to-broadcast-to"),
	'secretkey'=>urlencode("mysecretkey"),
	'property1'=>urlencode("Some Text"),
	'property2'=>urlencode("Some More Text")
	);

foreach($fields as $key=>$value) { $fields_string .= $key.'='.$value.'&'; }
rtrim($fields_string,'&');

$ch = curl_init();
curl_setopt($ch,CURLOPT_URL,$url);
curl_setopt($ch,CURLOPT_POST,count($fields));
curl_setopt($ch,CURLOPT_POSTFIELDS,$fields_string);

$result = curl_exec($ch);

//close connection
curl_close($ch);

CURL

curl -d http://www.your-pega-io-server.com:8888/send "channel=channel-to-broadcast-to&secretkey=mysecretkey&property1=Some+Text&property2=Some+More+Text"

Example: Implement a client listener

In your HTML, or in a separate .js file, simply connect to your Pega.IO server, and subscribe to whichever channels you want to listen to.

    <script src="http://www.your-pega-io-server.com:8888/socket.io/socket.io.js"></script> 
    <script>
        var socket = io.connect('http://www.your-pega-io-server.com:8888/');
  	
        socket.on('connect', function () {
            socket.on('channel-to-broadcast-to', function (obj) {
                console.log(obj.property1 + obj.property2 + obj.channel);
            });
            socket.on('another-channel', function (obj) {
                console.log(obj);
            });
        });
    </script>