var myStream = new Stream();
 myStream.onRecieveCommand = function (json){
  switch(json.type){
   case "RECIEVE_MESSAGE":
     this.onReceiveMessage(json.params["user"], json.params["time"], json.params["message"]);
     break;
   default:
     alert('no implementation');
  }
 }
 myStream.open("irc.php);
 
</span




php code:
 
 public class MessageStreamCommand extends StreamCommand {
   private $type = "RECIEVE_MESSAGE";
   function __construct ($user, $time, $message){
    $this->setUser($user);
    $this->setTime($time);
    $this->setMessage($message);
   }
 }
 
 $stream = new Stream();
 while (//reading from irc server) {
   if (//recieved a new mesasge){
     $stream->broadcast(new MessageStreamCommand($name, $time, $message));
   }
 }
 






This all works nicely. Quite proud of it, infact! The javascript involved in getting the actual 'streaming' work is a pretty sexy bit of work.



Now, my problem. I'm trying to work out how to send messages in the other direction (from the javascript to the PHP to the IRC or whatever).



One method I thought of was to open a second ajax connection for outgoing messages and those messages get stored in a database, and my main streaming script checks the database periodically for any messages that it needs to push.



Unfortunately with PHP being single threaded, I'm not sure how to achieve this. Anyone got any ideas???



In .NET this'd be nice and easy.. but I really want to start with a PHP solution first.

Concept: Beehive Forum 2

It appears as though I 'might' be able to do something with stream_socket_client and STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT.

Really, I need the connection to be open and processing data whilst also checking a mysql database.

 
$socket = stream_socket_client("tcp://".$server_host.":".$server_port, $errno, $errstr, 2, STREAM_CLIENT_ASYNC_CONNECT);
stream_set_blocking($socket, 0);
$timer = time();
while(!feof($socket))
{
  	  $newtime = time(true);
          if (($newtime-$timer) > 2){
        	// do sql queries
                // maybe spit some stuff up into the stream
        	 $timer = $newtime;
           }
            $data = fgets($server['SOCKET'], 1024);
            if ($server['READ_BUFFER'] != ""){
              // if theres any data do whatever needs dong
              // maybe spit some more into the stream
              // maybe echo some stuff to the browser
            }
            flush();
}
 

<?php
interface iStream {
	function onRecieve ($data);
}
abstract class Stream {
	private $socket, $host, $port;
	function __construct ($host, $port){
		if (!($this instanceof Stream)){
			throw new Exception(get_class()." must implement iStream");
		}
		set_time_limit(0);
		$this->host = $host;
		$this->port = $port;
	}
	function Connect (){
		$this->socket = stream_socket_client("tcp://".$this->host.":".$this->port, $errno, $errstr, 2);
		if($this->socket)
		{
			stream_set_blocking($this->socket, 0);
			$this->onConnect();
			$this->Start();
    		}
	}
	function onConnect (){}
	function Start (){
	   $timer = time();
	   while(!feof($this->socket)) //while we are connected to the server
        {
       	$now = time(true);
		if (($now-$timer) > 5){
			$timer = $now;
			// check database
        	}
 
        	$readBuffer = fgets($this->socket, 1024);
 
        	if ($readBuffer != ""){
        		$this->onRecieve($readBuffer);
        		flush();
        	}
        }
	}
	function onRecieve ($data){
	}
	function Send($data){
		$out = $data."\n\r";
		echo $out;
		@fwrite($this->socket, $out, strlen($out));
	}
	function Broadcast($data){
		// send data (json to web client
	}
}
class IRCStream extends Stream implements iStream {
	private $nickname;
	function __construct ($host, $port, $nickname){
		$this->nickname = $nickname;
		parent::__construct($host, $port);
	}
	function onConnect (){
		$this->Send("PASS NOPASS");
		$this->Send("NICK ".$this->nickname);
		$this->Send("USER ".$this->nickname." USING PHP IRC");
	}
	function onRecieve ($data){
		echo $data;
		if(strpos($data, "422"))
	  	{
		  	$this->Send("JOIN #poop");
		}
		if(substr($data, 0, 6) == "PING :")
		{
			$this->Send("PONG :".substr($data, 6));
		}
	}
}
 
$str = new IRCStream("localhost", 6667, "Mikeemoo");
$str->Connect();
?>

Heh.. fixed. It appears as though putting a small sleep like this:

usleep(100000);

is good enough to cause no CPU usage. :)

 
$str = new IRCStream("localhost", 6667, $_GET["nick"]);
$str->Connect();
 

screen grab of it working.

the messages on the web irc client appear immediately.. locally, anyway.

Huzzah. I got a new version working which now uses flash as a proxy if it can.

first it tries using ajax, then htmlfile, then flash then iframe :)

should work is pretty much every browser ever, now.

rather proud of this! just gotta get it sending messages now.. then THE WORLD IS MY OYSTER or something.

Can some people test this for me please?

I've tested in IE7/FF2/Chrome.

http://www.mikefranklin.me.uk/experiments/msn/msn.html

- it should look like MSN
- you should be able to drag it from side to side, and resize the width
- resizing the browser will cause the MSN app to resize. if you resize it smaller the image will get knocked out, like on the real msn.
- minimize button will set it to 0x, 0y, 300 px wide.
- maimize button will set it to full screen, as will double clicking
- close button should take you to google (dunno what else to do!)
- clicking on an input field with text in it should select it, unless its already selected (in which case it'll deselect)
- the 'email address' input field should have a down arrow on it.. the cursor should change to a 'arrow' cursor when its over the dropdown icon and clicking should make the menu appear. any clicks away from the menu will hide it. the menu items should have rollover states.
- all the elements title tags should match those on the real MSN

Issues i know about:
- moving the window to the right, then shrinking the browser window causes it to break
- the 'sign in' button is the wrong color
- the 'menu' doesnt fade in when it opens
- 'help' and 'online' menus dont work (yet)
- the tickboxes dont have the correct behaviors on them yet.
- signing in doesnt actually do anything yet.

Double clicking obviously maximises the thing, but I feel once it is maximised double clicking should return it to previous or default size. If possible of course!

Otherwise it looks good.