Problem with sockets

[cerbin]

Here's my code:

<?php
$SERVER_GAME_CHANNEL = "#bnfreak";
$SERVER_USERNAME = "RHAP RHAP RHAP";
$SERVER_USERNAME2 = "RHAP";
$SERVER_NICKNAME = "raeherjjr";


$socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP); // create the socket 



if (!$socket)
{
	die("Couldn't create socket");	
}
else
{
	echo "Attempting to connect to the server...<br>";	
}

$connection = socket_connect($socket,'irc.freenode.net',6667); //connect to irc.freenode.net 


if (!$connection)
{
	die("Could not connect to the server");	
}
else
{
	echo "Connected succesfully!<br>";	
}	


socket_write($socket,"USER $SERVER_USERNAME :$SERVER_USERNAME2\r\n"); // Log in
socket_write($socket,"NICK $SERVER_NICKNAME \r\n"); // Change our nickname 
socket_write($socket,"JOIN $SERVER_GAME_CHANNEL \r\n"); // Join the channel PHPFREAKS!!! 
while($data = socket_read($socket,2046)) // read whatever IRC is telling us 
{ 


echo $data . "<br>";



}
socket_close($socket);
?>

In my whole code, in the while($data = socket_read... loop, I have some parsing, let's say if the received message = "this message", then reply with another message. You get the point.

Well if I comment that echo $data . "<br>"; line, I do not see any message until the socket is closed by socket_close($socket).

My bot will work, however it'll display a white page loading and I won't see the "Attempting to connect to the server..." and "Connected successfully" messages until that socket is closed.

Any help please?

[DigitalExpl0it]

heres some code I did with sockets, check it out, it might help

<?
################################################################
##                             PhpBOT
## ------------------------------------------------------------- 
##
## By: Derrick Rose
## Website: [url]http://www.daemonprojects.com[/url]
##
##
################################################################

################################################################
##                         Configure Bot
################################################################
$cfgServer    = "localhost"; //Server you want the bot to connect to
$cfgPort      = 6666; // Server port to use
$cfgTimeOut   = 10; // Timeout in secs
$cfgbotname   = "PhpBot"; // Bot name
$cfgpassword  = "test"; //Server password
$password     = "now"; //Password
################################################################

################################################################
##                         Switches
##--------------------------------------------------------------
##
## !version 		- Display the bot version
## !say <msg> 		- have the bot say anything you want it to
## !time		- Display the time and date
## !exit		- Close the bot from remote

$version      = "-= PhpNaken Verion 0.1 by Derrick Rose =-";

function getmicrotime(){
		list($usec, $sec) = explode(" ",microtime());
		return ((float)$usec + (float)$sec);
}

//***open a socket
if(!$cfgTimeOut)
    //***without timeout
    $usenet_handle = fsockopen($cfgServer, $cfgPort);
else
    //***with timeout
    $usenet_handle = fsockopen($cfgServer, $cfgPort, &$errno, &$errstr, $cfgTimeOut);

if(!$usenet_handle) {
    echo "*** Connection failed\n";
    exit();
} else {
    echo "*** Connected to server!\n";
    $tmp = fgets($usenet_handle, 1024);

fputs($usenet_handle, ".n".$cfgbotname."\r\n");
fputs($usenet_handle, ".P".$cfgpassword."\r\n");
	$tmp = fgets($usenet_handle, 1024);

//***loop to get server data
	while($tmp!=".\r\n") {
	    $tmp = fgets($usenet_handle, 4096);
        	    echo $tmp;
		//Split String 
		//list() = split(":", $tmp);
		list($user, $msg) = split(": ", $tmp);

		$msg_command = explode(" ", $msg);
		//$get_remote_user_num = substr($user, 1, strlen($user) - 2);
		//echo $get_remote_user_num;

		//***Now for the commands, very basic setup here
		if (strstr($msg,"!say")) {
			fputs($usenet_handle, substr($msg, 4)."\r\n");
		//***Exit - will want to add a password protection on this later
		} elseif (strstr($msg,"!exit")) {
			fputs($usenet_handle, "Good day all!\r\n");
			fputs($usenet_handle, ".q\r\n");
			//fclose($usenet_handle);
			exit();
		} elseif (strstr($msg,"!version")) {
			fputs($usenet_handle, $version."\r\n");
		} elseif (strstr($msg,"!time")) {
			$time = date("F j, Y, g:i a"); 
			fputs($usenet_handle, "It is ".$time." bots time\r\n");
		}
    }
}

// close connection
fclose($usenet_handle);
?>

[DigitalExpl0it]

heres another socket script hope these help, this is a standalone php app. this isnt ment to be ran thru a web server. Just executed with php

ex: php file.php

<?
set_time_limit(0);
ob_implicit_flush();

require("cfg.php");
require("chanlist.php");
require("func_lockfile.php");
require("stylesheet.php");
XMunlock("lock.log");

if ($os == "win") {
	system("title XMPHP");
}

//Start Server, bind socket
$socket = stream_socket_server("tcp://".$server_addy.":".$server_port, $errno, $errstr);

//Print banner
$postdate = "*** LOG START: ".date('n/j/Y g:i a')."\n";
print $postdate;
print "============================================================\n";
print "XMPHP v0.1.0 - Copyright (C) 2004 Derrick Rose.\n";
print "-------------------------------------------------------------------\n";
print "XMPHP comes with ABSOLUTELY NO WARRANTY; This is free software,\n"; 
print "and you are welcome to redistribute it under certain conditions.\n";
print "Please see [url]http://www.gnu.org/licenses/gpl.txt[/url] for details.\n\n";
print "Starting Server...Started.\n";
print "Listening on Port: ".$server_port."\n";

//Socket error, check
if (!$socket) {
  echo "$errstr ($errno)<br />\n";
	$string = "$errstr ($errno)\n";
	$filname = "error.log";
	if (file_exists($filename)) {
		$fp = fopen($filename, "a");
		$write = fputs($fp, $string);
		fclose($fp);
	}
//Look for connections (LISTEN MODE)
} else {
	echo "Waiting for connections"; 
    // Create Lock File
	XMlock("lock.log");

//Put log date in lock file
 $fplockdate = fopen("lock.log", "a");
	if ($fplockdate) {
		fputs($fplockdate, "\n".$postdate);
		fclose($fplockdate);
	}

while ($conn = stream_socket_accept($socket)) {
$get_str = fgets($conn, 4096);
stream_set_timeout($conn, 82000);
$get_remote = stream_socket_get_name($conn, TRUE);

	$fplock = fopen("lock.log", "a");
	if ($fplock) {
		fputs($fplock, $get_str);
		fclose($fplock);
	}

echo "\nClient Connected.\n";
//Set Client String
$newstr = "Client ".$get_remote.": ".$get_str;
echo $newstr;
		$msg_command = explode(" ", $get_str);
		//Put switches here
		if (strstr($get_str, "XMlist")) {
			//Send Dummy XM Channel List
			stream_socket_sendto($conn, $chanlist."\r\n");
			echo "Server: Sent List to Client\r\n";
			fclose($conn);
		} elseif (strstr($get_str, "XMpoff")) {
			//Power Off PCR
			stream_socket_sendto($conn, "<html>Power Off Function not done!<br \> <a href='?XMlist'>click here</a> to go back</html>");
			echo "Server: Turning off XMPCR Unit\r\n";
			//fclose($socket);
			fclose($conn);
		} elseif (strstr($get_str, "XMpon")) {
			//Power Off PCR
			stream_socket_sendto($conn, "<html>Power On Function not done!<br \> <a href='?XMlist'>click here</a> to go back</html>");
			echo "Server: Turning on XMPCR Unit\r\n";
			fclose($conn);
		} elseif (strstr($get_str, "XMchange")) {
			//Change Channel
			//$str = "GET /?XMchange=1 HTTP/1.0";
			$rstrip = "GET /?";
			$lstrip = "HTTP/1.0";
			$partialPath1 = substr($get_str, strlen($rstrip)); 
			$partialPath2 = substr($partialPath1, 0, -10); 
			$get_channel = explode("=", $partialPath2);
			echo $get_channel[0]." ".$get_channel[1];
			stream_socket_sendto($conn, "Channel Request: ".$get_channel[1]." <br>Change Channel Function not done!<br \> <a href='?XMlist'>click here</a> to go back");
			echo "Server: Changed channel to: ".$get_channel[1]."\r\n";
			fclose($conn);
		}  elseif (strstr($get_str, "XMinfo")) {
			//Get Info
			stream_socket_sendto($conn, "<html>Info Function not done!<br \> <a href='?XMlist'>click here</a> to go back</html>");
			echo "Server: Getting info\r\n";
			fclose($conn);
		}  elseif (strstr($get_str, "XMhome")) {
			//Get Home
			stream_socket_sendto($conn, $chanlist."\r\n");
			echo "Server: Sent List to Client\r\n";
			fclose($conn);
		}  elseif (strstr($get_str, "style.css")) {
			//Send Style Sheet
			stream_socket_sendto($conn, $get_stylesheet."\r\n");
			echo "Server: Sent Style Sheet to Client\r\n";
			fclose($conn);
		} else {
			stream_socket_sendto($conn, $chanlist."\r\n");
			echo "Server: Sent List to Client\r\n";
			fclose($conn);
		}

}

//Close Sockets, exit XMPHP
  fclose($socket);
}
?> 

[cerbin]

Thanks, I'll have a look at those.

[drew010]

also, just try using flush() after everything you echo, that should push the output buffer to the user to prevent it from being stored until script finishes execution.

[cerbin]

I tried both flush() and ob_flush() combined with ob_implicit_flush()

For some reason, I need to echo every "NOTICE" message I get from the IRC server in order for this to work...