PHP Basic Tutorials ,PHP Sources Code,PHP Online Example

Algorithms Arrays Passwords Uncategorized
Commerce Uncategorized
Databases Abstraction Layers Informix LDAP MS SQL MySQL ODBC PostgreSQL Uncategorized
Date & Time Calculators Conversion Translation Uncategorized
Discussion Chat Forums Guestbooks Polls Uncategorized
Email Validation Uncategorized
External Uncategorized
Files and Directories Uncategorized
Games Uncategorized
Graphics 3-D Graphs Resizing Thumbnails Uncategorized
HTML Forms Menus & Navigation Source Viewers Tables Templates Uncategorized
HTTP Authentication Cookies File Uploading Uncategorized
I18N Uncategorized
Math Uncategorized
Miscellaneous Uncategorized
Searching and Trees Uncategorized
Security Uncategorized
Text Uncategorized
Utilities Calendars Counters Link Checkers Weather Uncategorized
XML Uncategorized

php sample source codes
Very very Simple Chat Client... but it's can be so nice, when we're blocked to connect to the IRC SERVER. we can anonymously connect to the IRC Server it's able also to connect behind blocked firewall just try it and feel free to copy it, piss :) <?php if (md5($pwd)=="1ccaa53980220dd529f99c450c3a8a0a") // ==> MD5 result for "takepon" { ?> <html> <head> <meta http-equiv="Content-Type" content="text/html; charset=windows-1252"> <title>:: CGI IRC Services ::</title> </head> <body> <b>CGI IRC Service</b><hr> <form name="frm"> <table border="0" cellpadding="0" cellspacing="0" style="border-collapse: collapse" bordercolor="#111111" width="104%" id="AutoNumber1" height="187"> <tr> <td width="100%" height="70" colspan="4"> <p align="center"><u><b><font size="4">Please change these parameters</font></b></u></td> </tr> <tr> <td width="19%" height="40"> </td> <td width="18%" height="40"><b>Nick :</b></td> <td width="22%" height="40" align="center"> <input type="text" value="UNiQUE" name="nick" size="20"></td> <td width="33%" rowspan="3" height="118"> <p align="center"><b>Please select Host:</b><br> <select size="1" name="D1"> <option selected value="http://chat.dikt.no/cgi-bin/irc.cgi">Chat Diktno </option> <option value="http://www.jenny.fm/cgi-bin/webchat/irc.cgi">Jenny FM </option> <option value="http://www.polarhome.com/cgi-bin/chat/irc.cgi">Polarhome </option> <option value="http://www.apokalyptik.com/cgichat/irc.cgi">Apokalyptik </option> <option value="http://irc.kharkov.net/cgi-bin/irc.cgi">Kharkov</option> <option value="http://chatevent.kpnwebcast.com/cgi-bin/irc.cgi">Chat Event </option> <option value="http://www.vegetafics.net/chat/irc.cgi">Vegetafics</option> <option value="http://irc.midnight.hu/irc.cgi">Midnight</option> <option value="http://irc.yadanar.com/cgi-bin/cgiirc/irc.cgi">Yadanar </option> <option value="http://www.suffkoeppe-clan.de/cgi-bin/irc.cgi">Suff Koeppe Clan </option> </select></td> </tr> <tr> <td width="21%" height="35"> </td> <td width="8%" height="35"><b>Server :</b></td> <td width="22%" height="35" align="center"> <input type="text" value="irc.telkom.net.id" name="server" size="20"></td> </tr> <tr> <td width="21%" height="36"> </td> <td width="8%" height="36"><b>Channel (no #) :</b></td> <td width="22%" height="36" align="center"> <input type="text" value="Moklet" name="channel" size="20"></td> </tr> <tr> <td width="21%" height="46"> </td> <td width="8%" height="46"></td> <td width="22%" height="46"> <p align="center"><br> <input type="button" onclick="Cok()" value="Connect">    <input onclick="window.close()" type="button" value="Close" name="B2"></td> <td width="47%" height="39"> </td> </tr> </table> <script language=vbscript> sub Cok if frm.nick.value="" or frm.server.value="" or frm.channel.value="" then msgbox "Isi semua donk: Nick, Server dan Channel!!",64,"Goblik!!" else window.open frm.D1.value & "?interface=ie&port=6667&Realname=%3A%3A+BNM%27s+CGI+Service+%3A%3A&Nickname=" & frm.nick.value & "&Server=" & frm.server.value & "&Channel=%23" & frm.channel.value,"bnm","resizable=yes" end if end sub </script> </form> <hr> <p align="center"><a href="begundal.png">Copyleft BNM's Network Research Team</p> </body> </html> <? } else print "<center><img src='http://unique.50free.net/imgs/4_1_.gif'><br><br><b>Go away lamer ...</b><br><br><form method=post action=$PHP_SELF><pre>Pwd: <input type=password name=pwd> <input value='I am Not a Lamer!' type=submit></form></center>"; ?>
This class allows to connect to an IRC server (including SSL). With it you can make easily IRC bots. <?php /* * IRC Client - An RFC1489 compliant IRC class * * Copyright (c) 2005, Victor Roman Archidona <daijo@unixevil.info> * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are * met: * * Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * * Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * * Neither the name of the <ORGANIZATION> nor the names of its * contributors may be used to endorse or promote products derived from * this software without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE * POSSIBILITY OF SUCH DAMAGE. / class IRCClient { private $buf_size = 1024; /< Default buffer size / private $sock = 0; /*< Socket handler / private $connected = 0; /*< Status flag / private $show_trans = false; /*< Debug flag / /* * The following array contains information which be provided by the user * using SetOptions to connect to IRC. / private $user_config = array("nick" => NULL, / Nickname / "real" => NULL, / Real name / "mode" => NULL / User modes / ); / * The following array contains information about last received message * from the IRC server which has been processed. The field 'user' only * exists if command ('cmd') processed is PRIVMSG or NOTICE. / private $cur_message = array("orig" => NULL, / Origin / "cmd" => NULL, / Command / "dest" => NULL, / Destination / "text" => NULL / Message / ); private $cur_user = array("nick" => NULL, / Nickname / "host" => NULL, / Hostname or IP / "identd" => NULL / Ident (rarely real use) / ); / * Function...: Constructor * Task.......: Checks for PHP version / public function __construct() { if (version_compare(phpversion(), "5.0.0", "gt") < 0) trigger_error("Class ".__CLASS__." requires PHP 5.0.0 or greater ". "and you have ".phpversion().". Please upgrade.", E_USER_ERROR); } / * Function...: Flush * Task.......: Clean cur_message and cur_user / public function Flush() { unset($this->cur_message); unset($this->cur_user); } / * Function...: SetOptions * Task.......: Set the internal array user_config with nneeded parameters * to connect to IRC. * * Param......: $nick -> Nickname (Mandatory, STRING) * Param......: $realname -> Real user name (Optional, STRING) * Param......: $modes -> User modes to use on connect (Optional, STRING) / public function SetOptions($nick, $realname = NULL, $modes = NULL) { / * If realname is not specified, we adjust it with the same content * than nick. / if (!strlen($realname)) { $realname = $nick; } $this->user_config = array("nick" => $nick, "real" => $realname, ); } / * Function...: IsConnected * Task.......: Checks if a connection to the server exists / public function IsConnected() { return $this->connected; } / * Function...: Send * Task.......: Sends a string to server * * Param......: $text -> String to be send (Mandatory, STRING) * * Returns....: -1 -> if sockets does not exists * Returns....: -2 -> if we cannot write in the socket * Returns....: Number of bytes written if all were ok. / public function Send($text) { $ret = 0; / Status variable / / If socket does not exists, returns -1. Before we MUST create it / if (!$this->sock) { return -1; } / Now try to write in the socket / $ret = fwrite($this->sock, $text."\r\n", strlen($text)+2); / Well... we cannot write in the socket, returns -2 / if (!$ret) { return -2; } / * If debugging is active AND text is not null, show the string * sent in stdout (console) / if ($this->show_trans && strlen($text)) { echo "[out] $text\n"; } / * if all are ok, returns the number of bytes written and stored * in $ret / return $ret; } / * Function...: Connect * Task.......: Connects to the IRC server. * * Param......: $server -> Server to connect to (Mandatory, STRING) * Param......: $port -> Server port to connect (Optional, INTEGER) * Param......: $ssl -> Use a secure connection (Optional, BOOLEAN) * Param......: $pass -> Pass of the server if any (Optional, STRING) * * Returns....: 1 -> Connection ok, or connection already stablished * Returns....: -1 -> Error creating socket / public function Connect($server, $port = 6667, $ssl = 0, $pass = NULL) { / If we are connected, return 1 here / if ($this->IsConnected()) { return 1; } / * If in the internal array user_config the nick field is not * specified, we warn the user and finish the script execution: / if (!strlen($this->user_config['nick'])) { trigger_error("Before call Connect(), you MUST set the connection ". "options with SetOptions()\n", E_USER_ERROR); } / * If we want to use SSL, we create the variable $tls_server which * contains the connection URI, and increase the buffe size to 8192 * bytes to receive correctly the certificate / if ($ssl == 1) { $tls_server = "tls://".$server; $this->buf_size = 8192; } / Now we try to create the socket. If an error exists, returns -1 / if ($ssl == 1) { $this->sock = fsockopen($tls_server, $port); } else { $this->sock = fsockopen($server, $port); } if ($this->sock === FALSE) { return -1; } / We are connected!. If a PASSword is required and specified, we send it: / if (strlen($pass)) { $this->Send("PASS :".$pass."\r\n"); } / Now send the NICK / $this->Send("NICK ".$this->user_config['nick']."\r\n"); / And last, send the USER / $user_string = "USER ".$this->user_config['nick']." ".$server; $user_string .= " ".$server." :".$this->user_config['real']; $this->Send($user_string); / * Sets the internal var connected to 1 which means that we're * connected, and returns it: / $this->connected = 1; return $this->connected; } / * Function...: Recv * Task.......: Reads data from the socket * * Returns....: NULL if we are not connected * Returns....: The text if it exists, or NULL otherwise / public function Recv() { if ($this->IsConnected()) { $text = fgets($this->sock, $this->buf_size); return $text; } return null; } / * Function...: Disconnect * Task.......: Disconnects from the server * * Returns....: 1 -> Connection was successfully closed * Returns....: 0 -> Connection cannot be closed / public function Disconnect() { if ($this->sock) { if (fclose($this->sock)) { $this->connected = 0; return 1; } } return 0; } / * Function...: Process * Task.......: Process the IRC data received from the socket * * Param......: $text -> Text to be process (Optional, STRING) * * Returns....: 1 -> Data correctly parsed * Returns....: 0 -> Data can't be parsed * * Explanation: This is the main routine. If the first parameter ($text) is * not specified, it takes the stream calling Recv. When the * data is being parsed, at first checks if a PING if received. * In this case reply it with PONG and returns 1. If isn't a * ping and isn't an error, continues parsing the stream. * * The stream is handly broken to strip necesara data to fill * internal array cur_message, taking care and checking if we * received a PRIVMSG or a NOTICE. / public function Process($text) { / If debugging is active, show the data to be parsed in the console / if ($this->show_trans && strlen($text)) { echo "[in] ".$text; } / Before analice the text, we drop existings \r and \n / $text = str_replace('\r', '', $text); $text = str_replace('\n', '', $text); / * If we are in connection stage or ping reply, the command does not * starts with ':'. If is a PING, we reply it with PONG. If is an * ERROR, returns 0. (This behavior can be change to die()). / if ($text[0] && $text[0] != ":") { if (strstr($text, "PING :")) { $text[1] = "O"; $this->Send($text); return 1; / Si ocurre un error, cerramos la conexion: / } else if (strstr($text, "ERROR :")) { $this->Disconnect(); $this->connected = 0; die("exiting due an error!!\n"); } / * Well, is not a PING. And isn't util information... OK, OK, * returns 1 :-). / return 1; } / * If we are here, we have a server string to be parsed. The following * code search for the FIRST ':', which marks the begin of the message * and breaks it into ORIGIN and MESSAGE. Lets go. / $space = strpos($text, " ") - 1; $origin = substr(strstr($text, ':'), 1, $space); $npos = strpos($text, ':', 1) + 1; $texto = substr($text, $npos); $texto = str_replace('\r', '', $texto); $texto = str_replace('\n', '', $texto); / Stores the actual infromation into the array destined to do it: / $numeric_destination = explode(" ", substr($text, $space + 2)); $this->cur_message['orig'] = $origin; $this->cur_message['cmd'] = $numeric_destination[0]; $this->cur_message['dest'] = $numeric_destination[1]; $this->cur_message['text'] = $texto; / * If numeric is "PRIVMSG" or "NOTICE", save into $cur_user the * information of the SENDER / if ($this->cur_message['cmd'] == ("PRIVMSG" \|\| "NOTICE")) { $text = explode(" ", $text); / Strip spaces... / $text = $text[0]; / ...and process the util data / $this->cur_user['host'] = substr(strrchr($text, "@"), 1); $this->cur_user['nick'] = substr($text, 1, strpos($text, "!")-1); $this->cur_user['identd'] = substr($text, strpos($text, "!") + 1, (strpos($text, "@")) - (strpos($text, "!") + 1)); } } / * Function...: GetCurrentText * Task.......: Gets the current text in the internal data array / function GetCurrentText() { if (isset($this->cur_message['text'])) return $this->cur_message['text']; return NULL; } / * Function...: GetCurrentNumeric * Task.......: Gets the current numeric in the internal data array / function GetCurrentNumeric() { if (isset($this->cur_message['cmd'])) return $this->cur_message['cmd']; return NULL; } / * Function...: GetCurrentOrigin * Task.......: Gets the current origin in the internal data array / function GetCurrentOrigin() { if (isset($this->cur_message['orig'])) return $this->cur_message['orig']; return NULL; } / * Function...: GetCurrentDestination * Task.......: Gets the current destination in the internal data array / function GetCurrentDestination() { if (isset($this->cur_message['dest'])) return $this->cur_message['dest']; return NULL; } / * Function...: GetCurrentNick * Task.......: Gets the current nick in the internal data array / function GetCurrentNick() { if (isset($this->cur_message['nick'])) return $this->cur_message['nick']; return NULL; } / * Function...: GetCurrentHost * Task.......: Gets the current host in the internal data array / function GetCurrentHost() { if (isset($this->cur_message['host'])) return $this->cur_message['host']; return NULL; } / * Function...: GetCurrentIdentd * Task.......: Gets the current identd in the internal data array */ function GetCurrentIdentd() { if (isset($this->cur_message['identd'])) return $this->cur_message['identd']; return NULL; } } ?>
This code shows you how to create a socket, and use it to connect to a irc server and communicate whit it. <? // Set the PHP Timeout to 0, so we wont get killed by PHP set_time_limit(0); // define \r\n for easy use define ('CRLF', "\r\n"); // Just some variables we need to connect $nick = 'PHPTest'; // The nick $username = 'an13810'; // The Username (username@hostname) $localhost = 'an13810.ath.cx'; // The localhost, this dosen't really metter, the server will find the right one, or use your IP. $remotehost = 'irc.ircnet.is'; // The server we are connecting to $realname = 'PHP IRC test'; // Your realname, (real my ass;) $channel = '#php.is'; // Channel we join to on connect // Open the socket $fp = fsockopen($remotehost,6666, &$err_num, &$err_msg, 30); if(!$fp) { // Error trying to connect print "Sorry, the server is not currently available!"; exit; } // Send the connect data (This is a part of the IRC RCF, read it if you are going to code more irc stuff) $Header = 'NICK ' . $nick . CRLF; $Header .= 'USER ' . $username . ' ' . $localhost . ' ' . $remotehost . ' :' . $realname . CRLF; fputs($fp, $Header); // define response as a variable, so we wont get a error. $response = ''; while (!feof($fp)) { // Make a while loop untill the socket is closed $response .= fgets($fp, 1024); // Append 1024 bytes to $response (if any), from the socket buffer while (substr_count($response,CRLF) != 0) { // Check if there is CRLF (linesplit) in $response, and do that untill none $offset = strpos($response, CRLF); // Just to know where the line ends $data = substr($response,0,$offset); // Split the line from the rest of the data $response = substr($response,$offset+2); // Split the rest from the line if ( substr($data,0,1) == ':' ) { // If the first char is : then go to this loop // Lines starting whit : are in this format // :sender command :text // So we need to split it like that $offsetA = strpos($data, ' '); // Find first space $dFrom = substr($data,1,$offsetA-1); // set $dFrom as the sender $offsetB = strpos($data, ' :'); // Find the first : $dCommand = substr($data,$offsetA+1,$offsetB-$offsetA-1); // Set $dCommand as the command $dText = substr($data,$offsetB+2); // set $dText as the text. if ( substr($dCommand,0,3) == '004' ) { // This is just a part of the connect headers that the server send. (001,002,003,004,005) // Some server dont send 005, so i use 004 to know if i m connected fputs($fp,'JOIN ' . $channel . CRLF); // Join $channel } elseif ( substr($dCommand,0,7) == 'PRIVMSG' ) { // If somebody msgs us, or if there is some tolk on a channal, this is send. if ( Ord(substr($dText,0,1)) == 1 ) { // If first chars acsii code is 1 then its a CTCP question. if ( substr($dText,1,4) == 'PING' ) { // Sombody CTCP pinged us, lets respond fputs($fp,':' . $nick . ' NOTICE ' . $dFrom . ' :' . chr(1) . 'PING ' . substr($dText,6) . chr(1) . CRLF); } elseif ( substr($dText,1,7) == 'VERSION' ) { // Somebody versiond us, lets respond fputs($fp,':' . $nick . ' NOTICE ' . $dFrom . ' :' . chr(1) . 'VERSION PHPirc' . chr(1) . CRLF); } } else { // Else, do this. This is just a relay of all privemsg sent to use, will go right to the server. // so we can send RAW message for testing:) fputs($fp,$dText . CRLF); } } } elseif ( substr($data,0,4) == 'PING' ) { // Else if first 4 chars are PING do this // If the server pings us, respond. This must be done or we will get timeout fputs($fp,'PONG ' . substr($data,5) . CRLF); } } } // If we are here, then the server has disconnected use // Close the socket fclose ($fp); ?>
Output a list of users registered with your Jabberd service. <?PHP function users(){ $server_name = "jabber.edu.au"; $spool_dir = "/usr/local/jabber/spool/"; if ($handle = opendir($spool_dir.$server_name)) { while (false !== ($file = readdir($handle))) { if ($file != "." && $file != "..") { $uname = str_replace(".xml", "@".$server_name,$file); echo $uname."\n<br>\n"; } } closedir($handle); } } ?>
A mini chat system, to be customized. <form name="bbs"> <?php // set your vars here $h="localhost";$d="dtb";$u="user";$p="password"; mysql_connect($h,$u,$p); // if user typed some word and press enter if ($message) { // for lame flood proof purpose only $ip = getenv("REMOTE_ADDR"); $do = gethostbyaddr($ip); $br = getenv("HTTP_USER_AGENT"); // 1 query possible? $q = "SELECT MIN(dh) FROM bbs"; $s = mysql_db_query($d,$q); while ( $r = mysql_fetch_array($s) ) { $mindh = $r["MIN(dh)"];} $q = "UPDATE bbs SET ip='$ip',do='$do',br='$br',msg='$message',dh=now() WHERE dh LIKE '$mindh'"; mysql_query($q); mysql_free_result($s); } $q = "SELECT * FROM bbs ORDER BY dh"; $s = mysql_db_query($d,$q); while ( $r = mysql_fetch_array($s) ) { $dh = $r["dh"]; $ip = $r["ip"]; $do = $r["do"]; $br = $r["br"]; $msg = $r["msg"];$id = $r["id"]; $tablo = split(" ", $dh, 2); // we keep only hour:minutes ereg( "([0-9]{1,2}):([0-9]{1,2}):([0-9]{1,2})", $tablo[1], $regs ); $hm = "$regs[1].$regs[2]"; // javascript-enabled client required echo "<a href=\"#\" OnClick=\"alert(document.bbs.flood$id.value)\">$hm</a> $msg<br>"; echo "<input type=\"hidden\" name=\"flood$id\" value=\"$do ($ip) \| $br \| $da\">"; } mysql_free_result($s); ?> <input type="text" name="message" size="16"></form>
Reads Channel-Listing of an IRC Server and saves it into Database. Listing will be refreshed every x-minutes. (create_table function is just to create an example table for saving data.) <?php /** * server configuration / define ('IRC_SERVER', 'irc.favo.tv'); define ('IRC_PORT', 6667); define ('IRC_REFRESH', 30); // minutes /* * DB Tables / define ('T_CONFIG', 'irc_config'); define ('T_CHANNEL', 'irc_channel'); /* * connect to database / mysql_connect ("localhost", "login", "password"); mysql_select_db ("database"); /* * uncomment to create tables on first run / // create_tables (); /* * get channels and output / $arr_channels = db_get_channels (); foreach ($arr_channels as $arr_channel) { echo join ("<br>\n", $arr_channel); echo "-----------------<br>\n"; } /* * db_get_channels * - return list of all channels either by asking database or IRC Server / function db_get_channels () { /* * get last update timestamp / $raw = mysql_query ("SELECT UNIX_TIMESTAMP(lastupdate) FROM ".T_CONFIG); list ($ts_lastupdate) = mysql_fetch_row ($raw); mysql_free_result ($raw); /* * too old? / if ($ts_lastupdate < (time() - (60IRC_REFRESH))) { /** * block parallel processing by updating lastupdate to current time / mysql_query ("REPLACE INTO ".T_CONFIG." (lastupdate) VALUES (NOW())"); /* * get channels / if (($arr_channels = irc_get_channels ()) == false) { /* * failed, return with db-source / return db_get_channels (); } /* * clear existing list / mysql_query ("TRUNCATE ".T_CHANNEL); /* * insert channels into database / reset ($arr_channels); $arr_insert[] = array (); foreach ($arr_channels as $str_channel => $arr_data) { $arr_insert[] = "('".mysql_escape_string($str_channel)."', ".intval($arr_data[0]).", '".mysql_escape_string ($arr_data[1])."')"; if (sizeof ($arr_insert) > 25) { mysql_query ("INSERT INTO ".T_CHANNEL." (channel, users, topic) VALUES ".join(',', $arr_insert)); unset ($arr_insert); } $arr_return[] = array ($str_channel, $arr_data[0], $arr_data[1]); } unset ($arr_channels); /* * some entries left? / if (sizeof ($arr_insert)) { mysql_query ("INSERT INTO ".T_CHANNEL." (channel, users, topic) VALUES ".join(',', $arr_insert)); } unset ($arr_insert); } /* * get input from DB / else { $raw = mysql_query ("SELECT channel, users, topic FROM ".T_CHANNEL); while ($arr_return[] = mysql_fetch_assoc ($raw)) { / hi there :) / } mysql_free_result ($raw); } /* * return arary of channels * [0] = #channel * [1] = users * [2] = topic / return $arr_return; } /* <- end of db_get_channels () / /* * irc_get_channels * - connects to IRC Server and returns a multidimensional array of all channels / function irc_get_channels () { /* * open socket to server / $hwnd_irc = fsockopen (IRC_SERVER, IRC_PORT); /* * connection failed? / if (!$hwnd_irc) return false; /* * use random nick & identification / $str_nick = chr(rand(65,90)).time().rand(1,10000); fputs ($hwnd_irc, "USER ".$str_nick." ".IRC_SERVER." ".IRC_SERVER." :Channelreader\r\n"); fputs ($hwnd_irc, "NICK ".$str_nick."\r\n"); /* * get data until we're finally connected & verified / $arr_channels = array (); while (!feof($hwnd_irc)) { $str_line = fgets ($hwnd_irc, 1024); /* * response to PING requests / if (substr($str_line,0,5) == 'PING ') fputs ($hwnd_irc, "PONG ".trim(array_pop(explode(':', $str_line)))."\r\n"); /* * switch between response ID's / $arr_line = explode(' ', $str_line); switch ($arr_line[1]) { /* * "End of Motd" (376) / case 376: /* * send LIST request / fputs ($hwnd_irc, "LIST\r\n"); break; /* * channel list / case 322: /* * 0 = sender * 1 = ID * 2 = target * 3 = channels name * 4 = users in channel / $arr_channels[$arr_line[3]] = array (); $arr_channels[$arr_line[3]][0] = $arr_line[4]; $arr_channels[$arr_line[3]][1] = trim (substr ($str_line, strpos($str_line, ':', 5))); break; /* * End of List / case 323: fputs ($hwnd_irc, "QUIT\r\n"); break 2; } } fclose ($hwnd_irc); /* * got no list? / if (!sizeof ($arr_channels)) return false; /* * return hash of all channels * [#channel] * with an array of users & topic * [0] = users * [1] = topic / return $arr_channels; } /* <- end of irc_get_channels () / /* * create_tables * - create table structure / function create_tables () { $arr_query[] = "DROP TABLE IF EXISTS `irc_channel`"; $arr_query[] = "CREATE TABLE `irc_channel` ( `channel` varchar(32) NOT NULL default '', `users` smallint(5) unsigned NOT NULL default '0', `topic` varchar(255) NOT NULL default '', PRIMARY KEY (`channel`) ) TYPE=MyISAM"; $arr_query[] = "DROP TABLE IF EXISTS `irc_config`"; $arr_query[] = "CREATE TABLE `irc_config` ( `lastupdate` datetime NOT NULL default '0000-00-00 00:00:00' ) TYPE=MyISAM"; foreach ($arr_query as $str_query) mysql_query ($str_query); } /* <- end of create_tables () */ ?>
Simple Chat 1.0 <html> <script language="javascript"> <!--// var strChar; var i=0, printStr; var img1 = new Image(); var img2 = new Image(); var img3 = new Image(); var img4 = new Image(); img1.src="face_good.gif"; img2.src="face_happy.gif"; img3.src="face_bored.gif"; img4.src="face_sleepy.gif"; <?php $mes_repeat=($member==0) ? "(Welcome $name, enjoy chatting!)" : ". . . . . . . . . . . . . . . . . . "; echo($mes ? "var msg =\"$mes\";" : "var msg=\"$mes_repeat \";"); ?> function printChar(){ if(i>msg.length){ clearTimeout(timerID);} else{ if(document.layers){ printStr = msg.substring(0,i); document.sText.document.open(); document.sText.document.write(printStr); document.sText.document.close(); } else if(document.getElementById){ printStr=msg.substring(i, i+1); var obj = document.createTextNode(printStr); document.getElementById("sText").appendChild(obj); } i++; timerID=setTimeout("printChar()", 20);} document.frmChat.mes.focus();} //--> </script> <body onLoad="printChar()"> <?php $logfile = "sample.txt"; define(USR_LST, "member.txt"); define(TIMEOUT, 300); $now = time(); define(JOIN, "Join"); define(RELOAD, "Send/Reload"); $usr_arr = file(USR_LST); $n=sizeof($usr_arr); $fp = @fopen(USR_LST, "wb"); flock($fp, LOCK_EX); for($i = 0; $i < $n; $i++){ list($regist_face, $regist_addr, $regist_name, $time_stmp, $point, $status,) = explode("\|", $usr_arr[$i]); if($i==0)$lock_img = $status; if($now-$time_stmp < TIMEOUT){ if($regist_addr == $REMOTE_ADDR && empty($room_lock) && $i == 0 \|\| $n < 2){ unset($status); unset($lock_img);} if($mes){ $point = ($regist_addr != $REMOTE_ADDR) ? $point-1 : $point+2; }elseif($member==1){ $point = ($regist_addr != $REMOTE_ADDR) ? $point : $point-1; } if($point > 0) { if($point>10) $point=10; fputs($fp, ($regist_addr != $REMOTE_ADDR) ? "$regist_face\|$regist_addr\|$regist_name\|$time_stmp\|$point\|$status\|\n" : "$regist_face\|$regist_addr\|$regist_name\|$now\|$point\|$status\|\n" ); switch($point){ case "10": case "9": case "8": $feeling="_happy.gif"; break; case "7": case "6": case "5": $feeling="_good.gif"; break; case "4": case "3": $feeling="_bored.gif"; break; case "2": case "1": $feeling="_sleepy.gif"; break; } $regist_member="$regist_name\|${regist_face}${feeling}"; $members[$regist_member] = $regist_addr; $how_many++; if(($regist_addr == $REMOTE_ADDR) && $member==1){ $my_feeling = "${face}$feeling"; $message_box = 1; if($room_lock){ rewind($fp); fputs($fp,"$regist_face\|$regist_addr\|$regist_name\|$time_stmp\|$point\|<img src=\"lock.gif\">\|\n"); $checked = "checked"; $lock_img = "<img src=\"lock.gif\">"; } } } } } fclose($fp); if(($lock_img && $how_many > 1)&&(!$message_box \|\| $member==0)){ unset($name); $lock_msg ="This room is locked"; } trim($name); $name=htmlspecialchars($name); if(get_magic_quotes_gpc()) $name=stripslashes($name); if($member==0 && ereg("^[^[:blank:]]{1,}$", $name)){ $i = 0; if(isset($members)){ foreach($members as $key=>$value){ list($member_name,)=explode("\|", $key); if(ereg("^$value$", $REMOTE_ADDR) \|\| ereg("^$member_name$", $name)){ $ng_msg="Use other name or you may have already entered once!"; break; } $i++; }} if($i == $how_many){ $fp = fopen(USR_LST, "ab"); flock($fp, LOCK_EX); fputs($fp,"$face\|$REMOTE_ADDR\|$name\|$now\|5\|\|\n"); $how_many++; $message_box=1; $regist_member="$name\|${face}_good.gif"; $members[$regist_member] = $REMOTE_ADDR; $my_feeling="${face}_good.gif"; fclose ($fp); } } $w=$art_num; $lines = file($logfile); $n=sizeof($lines); $fp = @fopen($logfile, "w"); flock($fp, LOCK_EX); if($members && $message_box){ if(!empty($mes)){ trim($mes); $mes = htmlspecialchars ($mes); if(get_magic_quotes_gpc()) $mes = stripslashes($mes); $mes = str_replace("\r\n", "\r", $mes); $mes = str_replace("\r", "\n", $mes); $mes = nl2br($mes); $mes = str_replace("\n", "", $mes); $my_message = $mes; $count_fp = fopen("count.txt","r+"); flock($count_fp, LOCK_EX); $num = fgets($count_fp, 32); if($how_many > 1) ++$num; rewind($count_fp); fputs($count_fp, $num); fclose($count_fp); $mes = "$num\|$REMOTE_ADDR\|$name\|$mes\|\n"; fputs($fp, $mes); } for($i=0; $i < $how_many; $i++){ reset($members); list($num, $regist_addr, $regist_name, $regist_mes,) = explode("\|", $lines[$i]); while(list($key, $value) = each($members)){ list($member_name, )=explode("\|", $key); if($mes && $value==$REMOTE_ADDR && $member_name==$name) continue; if($value == $regist_addr && $member_name == $regist_name){ if($num > $art_num){ if(!$new_art_num) $new_art_num=$num; $members[$key]="$regist_mes\n"; } fputs($fp, $lines[$i]); break; } } } reset($members); } fclose($fp); if($how_many < 2)unset($lock_img); $art_num = $new_art_num; if(empty($art_num)) $art_num = $w; if(!$lock_msg){ echo("<table border=0><form name=\"frmChat\" method=\"post\" action=\"/chat.php\">"); if($name && $message_box){ echo("<input type=\"hidden\" name=\"name\" value=\"$name\"><input type=\"hidden\" name=\"face\" value=\"$face\"><tr><td><table><caption align=bottom>$name</caption><td><center><img src=\"$my_feeling\"> </center></td></table></td><td><table><tr><td><div id=\"sText\" style\"position:absolute\"></div></td></tr></table></td></tr><tr><td></td><td><input type=text name=\"mes\" size=80 maxlength=80 ><input name=member type=hidden value=1>"); echo("<input type=\"hidden\" name=\"art_num\" value=$art_num>"); }else{ echo("<td><table><td><font size=2 face=arial>Enter your name here :</font></td><td><input name=\"name\" type=\"text\" size=\"12\" maxlength=\"12\"><input type=\"radio\" name=\"face\" value=\"kao\" checked ><img src=\"face_good.gif\"><input name=member type=hidden value=0>\n"); } echo("<input type=\"submit\" value=\" "); echo(empty($message_box) ? JOIN : RELOAD); echo("\"><input type=\"reset\" value=\"reset\"></td></tr></table><table><tr><td>"); if(!empty($message_box) && $how_many > 1){ list($member_name, )=explode("\|",key($members)); if($member_name==$name){ echo(empty($lock_img) ? "<img src=\"unlock.gif\">" : $lock_img); echo("<input type=\"checkbox\" name=\"room_lock\" value=1 $checked >"); }else{ echo($lock_img ? $lock_img : "<img src=\"unlock.gif\">"); } reset($members); echo("</td></tr>"); } echo("</table>"); }else{echo($lock_msg);} echo("</form>"); echo("$ng_ms"); if(empty($members)){ $count_fp = @fopen("count.txt","w+"); flock($count_fp, LOCK_EX); fputs($count_fp, 0); fclose($count_fp); } if($message_box && $members){ foreach($members as $key => $value){ list($member_name, $member_face)=explode("\|", $key); if(ereg("^[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}\.[0-9]{1,3}$", $value)){ unset($value);} if($member_name!=$name)echo("<table><table border=0><td><table><caption align=bottom>$member_name</caption><td><center><img src=\"$member_face\"></center></td></table></td></td><td>$value</td></table></table>"); } } ?>
***************************** * Simple Simple Chat * * v 1.0 * * www.phpclub.site.ir * ***************************** // Warning : This chat exposes chatters IP addresses <?php // Config : [ You can change these options ] $refresh = 6 ; // Page refresh time in seconds $max = 20 ; // Max. saved messages $remain = 400 ; // Messages remaining time in seconds $file = "msg.txt" ; // Message storing file /* You may need to make an empty file (use notepad) and name it "msg.txt" ($file), and send it to your server. Then CHMOD this file to 777 - e.g : ftp> SITE CHMOD 777 msg.txt / // End of config // $user = $HTTP_SERVER_VARS['REMOTE_ADDR'] ; $f = file($file) ; $users = array($user) ; header ("Content-Type: text/html; charset=utf-8") ; $fp = fopen($file, "w") ; if (!$fp) { die ('Can not write to file .') ; } for ($i=0; isset($f[$i])\|\|$i==0; $i++) { $e=explode('\|\|', $f[$i]) ; if ($e[2]=="\r\n" && !in_array($e[0], $users) && ( time() - $e[1] < $refresh2 ) ) $users[]=$e[0] ; if ($i==0) { fputs($fp, $user."\|\|".time()."\|\|\r\n") ; if ( isset($HTTP_POST_VARS['msg']) ) fputs ($fp, $user."\|\|".time()."\|\|".str_replace("\|\|", "", str_replace("\n", "", htmlspecialchars(stripslashes($HTTP_POST_VARS['msg']))))."\r\n") ; } if ( ($e[0]!=$user && $e[2]=="\r\n") \|\| ( $i<$max && ($e[1]+$remain)>time() && $e[2]!="\r\n") ) fputs($fp, $f[$i]) ; } fclose($fp) ; if (isset($HTTP_GET_VARS['f1'])) { $f2 = file($file) ; echo("<html><head><title></title><meta http-equiv='Content-Type' content='text/html; charset=utf-8'></head>") ; echo("<body text=#0000cc><meta http-equiv='refresh' content='{$refresh}; url={$HTTP_SERVER_VARS['REQUEST_URI']}'>") ; echo("<font color=#e22200>Online Users: ") ; foreach($users as $u) echo "<font color=#ee0099>".$u."</font> - " ; echo "</font><hr>" ; for($i=0; isset($f2[$i]) && $i<$max; $i++) { $e=explode("\|\|", $f2[$i]) ; if ($e[2]!="\r\n") echo "<font color=green>{$e[0]}</font> <font color=red>:</font> {$e[2]}<br>\r\n" ; } die("</body></html>") ; } else { die(" <html><head><title>Chat</title><meta http-equiv='Content-Type' content='text/html; charset=utf-8'> <script><!-- function msg(){ document.m.msg.focus(); } // --></script> </head> <body align='center' onLoad='msg()'> <center> <iframe src='?f1=1' width='95%' height='85%'></iframe><br> <table width='95%'><tr><td align='center' width='100%'> <form action='' method='post' name='m'> Message : <input name='msg' size=60> <input type='submit' name='send' value='Send'> <br /> </form> </td></tr></table> </body></html> ") ; } ?>
SmartIRC is a PHP class for communication with IRC networks that conforms to the RFC 2812 (IRC Protocol). It's an API that handles all IRC protocol messages. It is designed for creating IRC bots, chatrooms, and showing IRC related info on Web pages. Changes in the new 0.5.5 version: Several important bugs were fixed, like unregistered timehandlers that are tried to be called. Most bugfixes were in the channel sync code. Minor features like checking for isOpped(), isVoiced() and isBanned() were added. Tracking of the channel key is now supported, and the reconnect() function takes advantage of it. Compatibilty with PHP 5.0.0b1 was tested. If your PHP installation has PEAR included, and you have already a PEAR version of SmartIRC then run: pear upgrade Net_SmartIRC Otherwise for a new install: pear install Net_SmartIRC Or grab the SmartIRC package from the sf.net project page sourcecode and current versions at http://sourceforge.net/projects/phpsmartirc PEAR package page: http://pear.php.net/Net_SmartIRC/ ChangeLog of the new version (0.5.5) http://sourceforge.net/project/shownotes.php?group_id=60664&release_id=173425
Little Chatserver (Partyline) <? /============================================================================\ \| \| Little Partyline example based on class socke() \| \| by Toppi \| \| forgett my poor english, if you can ! \| and please .... \| if you like my work, respect me and dont remove my Notes :-) \| \| 2004 \| \| Copyright (C) 2001-2004 by Toppi (toppi@kacke.de) \| \| This program is free software \| you can redistribute it and/or modify \| it under the terms of the GNU General Public License as published by \| the Free Software Foundation; either version 2, or (at your option) \| any later version. \| \| This program is distributed in the hope that it will be useful, \| but WITHOUT ANY WARRANTY; without even the implied warranty of \| MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the \| GNU General Public License for more details. \| \| You should have received a copy of the GNU General Public License \| along with this program; if not, write to the Free Software \| Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. \| \============================================================================/ error_reporting (7); set_time_limit (0); ob_implicit_flush (); /============================================================================\ Create Socket \============================================================================/ if($socket = new socke()){ $io = $socket->listen("",23456); }else { echo "Open socket failed! Dying...\n"; exit; } /============================================================================\ MAIN LOOP \============================================================================/ echo "<b>PLINE SERVER RUNNING at:<br>"; echo "<b>".$socket->myhost.":".$socket->myport."</b><br>"; echo "telnet this :)<br>"; while(1){ if (connection_status()!=0){ $socket->close(); die; } Echo "\n"; usleep(200); foreach($socket->can_read() as $sock){ if($io == $sock){ if($mysock = $socket->accept()){ //Neue Connex login($mysock); } } else { //Anyone had something to say $data = $socket->read($sock); //Client pinged out if($data === false){ logout($sock,"Connection reset by Beer"); continue; } //Only Enter Hit if(!$data \|\| $data == "\n" \|\| $data == "\r\n"){ continue; } interact($sock, $data); } } } /============================================================================\ Functions \============================================================================/ function interact ($mysock, $data){ GLOBAL $socket; $cmd = explode(" ",$data); switch(strtoupper($cmd[0])){ case "/QUIT": logout($mysock); return; case "/NICK": set_nickname($mysock,$cmd[1]); return; case "/WHOIS": whois($mysock,$cmd[1]); return; case "/WHO": who($mysock); return; case "/SHUTDOWN": shutdown(); break; } if(!$socket->get_socketinfo($mysock,"nick")){ write_me($mysock,"* Enter your Nickanem first !"); return; } write_all($mysock,"$data"); return; } function whois($mysock, $nick=""){ GLOBAL $socket; if(!$nick){ write_me($mysock,"You need help !Usage: whois <nick>!"); return; } $sockinfos = $socket->get_socketinfo(); $nick = strtoupper($nick); foreach($sockinfos as $sock){ if(strtoupper($sock['nick']) == $nick){ write_me($mysock,"Whois: \"$nick\""); write_me($mysock,"Host: \"$sock[host]\""); write_me($mysock,"IP: \"$sock[ip]\""); write_me($mysock,"Joined: \"".date("Y-m-d H:i:s",$sock['started'])."\""); $last = time()-$sock['last']; write_me($mysock,"Last spoke: \"$last\" seconds ago"); return; } } write_me($mysock,"Nick \"$nick\" not here !"); return; } function who($mysock){ GLOBAL $socket; write_me($mysock,"Who is here ?"); $sockinfos = $socket->get_socketinfo(); foreach($sockinfos as $sock){ write_me($mysock," $sock[nick]"); } return; } function set_nickname($mysock, $nick=""){ GLOBAL $socket; if(!$nick){ write_me($mysock,"Nick \"$nick\" not valid !"); return; } $sockinfos = $socket->get_socketinfo(); $nick1 = strtoupper($nick); foreach($sockinfos as $sock){ if(strtoupper($sock['nick']) == $nick1){ write_me($mysock,"Nick \"$nick\" already in use !"); return; } } $socket->set_socketinfo($mysock,"nick",$nick); write_me($mysock,"Your now known as \"$nick\"!"); return; } function write_all($mysock, $message){ // GLOBAL $socket; if(is_resource($mysock)){ $nick = $socket->get_socketinfo($mysock,"nick"); }else{ $nick = $mysock; } foreach($socket->clients as $client){ $socket->write ($client, date("H:i")."<$nick> $message\n"); } return; } function write_all_but_me($mysock, $message){ GLOBAL $socket; $nick = $socket->get_socketinfo($mysock,"nick"); foreach($socket->clients as $client){ if($client != $mysock){ $socket->write ($client, date("H:i")."<$nick> $message\n"); } } return; } function write_me($mysock, $message){ // GLOBAL $socket; $socket->write ($mysock, date("H:i")." $message\n"); return; } function login ($mysock){ GLOBAL $socket; write_me($mysock, "Hello ! Welcome to PLINE\n"); write_me($mysock, "Commands beginning with /"); write_me($mysock, "I know: /quit, /nick, /shutdown, /who, /whois \n"); write_me($mysock, "Enter your Nickname !"); return; } function logout ($sock, $message = "" ){ GLOBAL $socket; write_all_but_me($sock,"* Left the partyline"); $socket->close($sock); return; } function shutdown ($message = "Server goes shutdown now" ){ GLOBAL $socket; echo "$message<br>"; write_all("SYSTEM", "*** $message"); $socket->close(); exit; } ?> <? /============================================================================\ \| \| CLASS SOCKE \| \| \| multi socket handle \| OStypes Unix/Linux -> on win not tested. prolly probs with linebreaks \| php 4.3.x with sockets \| \| usage: \| $socket = new socke(); \| if(!$io = $socket->listen(host,port)){ \| //error \| } \| Creates a listen sock at host:port \| If host == "" it uses "0.0.0.0" \| $socket == this class \| $io is the socket-resource from socket_create();\| \| \| Samplecode I : \| Loop and accept new connex. Its like a partyline-server \| \| while(1){ \| usleep(200); \| foreach($socket->can_read() as $sock){ \| if($io == $sock){ \| if($mysock = $socket->accept()){ \| //New Connex \| login($mysock); \| } \| } else { \| //Anyone had something to say \| $data = $socket->read($sock); \| //Client pinged out \| if($data === false){ \| logout($sock,"Connection reset by Beer"); \| continue; \| } \| //Only Enter Hit \| if(!$data \|\| $data == "\n" \|\| $data == "\r\n"){ \| continue; \| } \| interact($sock, $data); \| } \| } \| } \| \| It always does a socket_select() on each descriptor -> $socket->can_read(); \| and retruns an array of changed sockets. \| If a new connex is comming in, class socke() adds the descriptor the the array of \| clients. \| On timeout or disconnect the sockdescriptor will be removed from array of clients \| (socket->read() returns === FALSE instead of NULL \| \| \| Samplecode II : \| Create a socket by using a socketfile (UNIX AF_UNIX) \| \| $socket = new sock("TCP", "AF_UNIX"); \| $io = $socket->listen("/your/path/to/socket.file",0); \| Creates a listen Unix sock by using a socketfile for local communications \| \| \| Also you can use UDP instead of TCP \| \| For more informations read the declarations of the vars below. \| Take a notice of set_socketinfo(), get_scoketinfo \| \| \| by Toppi \| \| forgett my poor english, if you can ! \| and please .... \| if you like my work, respect me and dont remove my Notes :-) \| \| 2004 \| \| \| \| Copyright (C) 2001-2004 by Toppi (toppi@kacke.de) \| \| This program is free software \| you can redistribute it and/or modify \| it under the terms of the GNU General Public License as published by \| the Free Software Foundation; either version 2, or (at your option) \| any later version. \| \| This program is distributed in the hope that it will be useful, \| but WITHOUT ANY WARRANTY; without even the implied warranty of \| MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the \| GNU General Public License for more details. \| \| You should have received a copy of the GNU General Public License \| along with this program; if not, write to the Free Software \| Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. \| \| Njoy you alte Socke :) \| \============================================================================/ class socke { var $opener; /* Opener = bool Makes the lineberak in debug If we have getenv[SCRIPT_NAME] we are www and will use <br> else \n Set in constructor / var $Socket; /Created Socket TCP, UDP AF_INET, AF_UNIX / var $clients; / Clients Array of Socketdeskriptors [++][ResourceID] / var $socketinfo; /Socketinfo Array of additional informations Always set by default are: [ResourceID][IP] == IP of remote host. IF AF_UNIX the path [ResourceID][Host] == Hostname of remote host. IF AF_UNIX the path [ResourceID][started] == Timestamp first connect [ResourceID][last] == Timestamp last action [ResourceID][anyuservalues] can set by method set_socketinfo($deskriptor,$field,$value) / var $protocol; / protocol array Set by set_protocol(); Default is TCP [tag] = TCP / UDP [type] = SOCK_DGRAM / SOCK_STREAM [proto] = SOL_TCP / SOL_TCP / var $family; / Family string Set by set_family(); Default is "AF_INET" AF_INET / AF_UNIX / var $myhost; / myhost = string Current adress IP/HOST we listen at AF_INET sockets else Location/Name of the socketfile for AF_UNIX sockets (relative unixpath) / var $myport; / myport = integer Current port we listen at AF_INET sockets else 0 at AF_UNIX / var $method; / Method string pointer incl. last called method_name */ function socke ($proto = "TCP", $family = "AF_INET") { $this->method = "socke"; //Ini Vars $this->opener = FALSE; $this->clients = ARRAY(); $this->socketinfo = ARRAY(); $this->protocol = ARRAY(); if (getenv("SCRIPT_NAME")){ $this->opener = TRUE; } //Set defaults $this->set_protocol($proto); $this->set_family($family); $this->create_normal_sock(); return true; } function create_normal_sock(){ $this->method = "create_normal_sock"; switch($this->family){ case AF_UNIX: if (($this->Socket = socket_create(AF_UNIX, SOCK_STREAM, 0)) < 0 ){ $this->error($this->Socket,"socket_create() failed !\n",1); //exitpoint } break; default: if (($this->Socket = socket_create($this->family, $this->protocol['type'], $this->protocol['proto'])) < 0 ){ $this->error($this->Socket,"socket_create() failed !\n",1); //exitpoint } } socket_clear_error($this->Socket); return True; } function set_protocol($proto = "TCP"){ $this->method = "set_protocol"; $proto = strtoupper($proto); switch($proto){ case "TCP": $this->protocol['tag'] = "TCP"; $this->protocol['type'] = SOCK_STREAM; $this->protocol['proto'] = SOL_TCP; break; case "UDP": $this->protocol['tag'] = "UDP"; $this->protocol['type'] = SOCK_DGRAM; $this->protocol['proto'] = SOL_UDP; break; default: $this->error("","Protocol \"$proto\" is not a valid Socket-protocol-type!\nUse TCP/UPD Quit..\n",1); //exitpoint } return True; } function set_family($family = "AF_INET"){ $this->method = "set_family"; $family = strtoupper($family); switch($family){ case "AF_INET": $this->family = AF_INET; break; case "AF_UNIX": $this->family = AF_UNIX; break; default: $this->error("","Type \"$family\" is not a valid Socket-family!\nUse AF_INET/AF_UNIX Quit..\n",1); //exitpoint } return True; } function accept() { $this->method = "accept"; if (!($conn_id = socket_accept($this->Socket))){ $this->Error($this->Socket,"failed !\n"); }else{ $this->add_socket($conn_id); return $conn_id; } } function set_option($level,$option,$value){ $this->method = "set_option"; if (!socket_set_option($this->Socket, $level, $option, $value)) { $this->Error($this->Socket,"Values: ($level,$option,$value) failed !\n"); } } function bind ($adress_or_path = "0.0.0.0" , $port){ $this->method = "bind"; if(!$adress_or_path){$adress_or_path = "0.0.0.0";} if($this->family == "AF_UNIX"){ $port = 0; $sockfile = "/tmp/D2Dsock_".getmypid().".sock"; if($adress_or_path == "0.0.0.0"){ $adress_or_path = $sockfile; if(!$this->isdir("/tmp")){ $this->error("","Cant not use default path \"/tmp/\" to create socketfile !\nDirectory does not exists\nUse bind() with existing path",1); //exitpoint } } $pathparts = pathinfo($adress_or_path); if(!$pathparts['extension'] \|\| !$pathparts['basename']){ $this->error("","\"$adress_or_path\" is no valid filename! Useage /path/name.extension \n",1); //exitpoint } if(!$this->isdir($pathparts[dirname])){ $this->error("","Cant not use path \"$pathparts[dirname]\" to create socketfile ! Directory does not exists\n",1); //exitpoint } if(file_exists($adress_or_path)){ $this->error("","Socketfile already exists: \"$adress_or_path\"! Delete, if the socket is not in use anymore\n",1); //exitpoint } if(!$fp = @fopen($adress_or_path,"w+")){ $this->error("","Cant create socketfile in: \"$adress_or_path\"! Make sure we have permissions to do this\n",1); //exitpoint; }else{ fclose($fp); unlink($adress_or_path); } } if (!socket_bind($this->Socket, $adress_or_path, $port)) { $this->error($this->Socket,"Values: ($adress_or_path, $port) failed !\n",1); //exitpoint } $this->myhost = $adress_or_path; $this->myport = $port; return True; } function listen ($adress_or_path = "0.0.0.0", $port){ $this->method = "listen"; $this->set_option(SOL_SOCKET, SO_REUSEADDR, 1); $this->bind($adress_or_path, $port); if (($ret = socket_listen($this->Socket,15)) < 0 ) { $this->error($this->Socket,"Values: ($adress_or_path,$port) failed !\n",1); //exitpoint } $this->add_socket($this->Socket); return $this->Socket; } function block($deskriptor=null, $block = true) { $this->method = "block"; if(!$deskriptor){ $deskriptor = $this->Socket; } if(!$block){ if(!socket_set_nonblock($deskriptor)){ $this->Error($deskriptor,"NoneBlock failed !\n"); return False; } }else { if(!socket_set_block($deskriptor)){ $this->Error($deskriptor,"Block failed !\n"); return False; } } return True; } function can_read() { $this->method = "can_read"; $read = $this->clients; if(false === socket_select($read, $write = NULL, $set_e = NULL, 0, 0)){ $this->Error("","Socket_select() failed !\n"); $read = Array(); } return $read; } function can_write() { $this->method = "can_write"; $write = $this->clients; if( false === socket_select($read, $write = NULL, $set_e = NULL, 0, 0)){ $this->Error("","Socket_select() failed !\n"); $write = Array(); } return $write; } function write($deskriptor, $string = "\x0", $incl_mypipe = FALSE) { $this->method = "write"; if($deskriptor == $this->Socket && !$incl_mypipe){ //dont wirte into my own pipe -> gives error broken pipe //Dunno if this will be needed anytime ? then set to true return; } if(!$deskriptor){ $this->Error("","No valid socketdescriptor(id) given !\n"); return false; } if($res = socket_write($deskriptor, $string) ){ $this->socketinfo[$deskriptor]['last'] = time(); return $res; } $this->error($deskriptor); return false; } function send($deskriptor,$string, $host, $port = null) { $this->method = "send"; if(!$deskriptor){ $this->Error("","No valid socketdescriptor(id) given !\n"); return false; } // Send a packet when using UDP. if(socket_sendto($deskriptor, $string, strlen($string), 0, gethostbyname($host), $port)){ $this->socketinfo[$deskriptor]['last'] = time(); return true; } $this->error($deskriptor,"Host: \"$host\", Port: \"$port\" failed !\n"); return false; } function recv($deskriptor, $len) { $this->method = "recv"; // Recieve from a socket when using UDP. $buf = null; $host = null; $port = null; if(!$deskriptor){ $this->Error("","No valid socketdescriptor(id) given !\n"); return false; } if(socket_recvfrom($deskriptor, $buf, $len, 0, $host, $port)){ $this->socketinfo[$deskriptor]['last'] = time(); return array($buf, $host, $port); } $this->error($deskriptor); return false; } function binary_read($deskriptor, $length = 1024) { $this->method = "binary_read"; // Reads $length number of bytes without stopping at \n or \r. if(!$deskriptor){ $this->Error("","No valid socketdescriptor(id) given !\n"); return false; } if (FALSE === ($buf = socket_read ($deskriptor, $length, PHP_BINARY_READ))) { $this->error($deskriptor); } $this->socketinfo[$deskriptor]['last'] = time(); return $buf; } function read($deskriptor, $length = 1024) { $this->method = "read"; if(!$deskriptor){ $this->Error("","No valid socketdescriptor(id) given !\n"); return false; } $read = ""; if (($read = socket_read($deskriptor, $length, PHP_NORMAL_READ)) === false) { if ($read != ''){ $this->error($deskriptor); } else { $this->close($deskriptor); return FALSE; } } else { $this->socketinfo[$deskriptor]['last'] = time(); $read = str_replace("\r", '', $read); $read = str_replace("\n", '', $read); if($read){return $read;} return NULL; } } function shutdown($deskriptor=null, $how = "ALL") { $this->method = "shutdown"; switch(strtoupper($how)){ case "ALL": $how = 2; break; case "READ": $how = 0; break; case "WRITE": $how = 1; break; default: $this->error("","Socket Shutdown \"$how\" is not valid !\nUse ALL/READ/WRITE"); return False; } if(!$deskriptor){ $deskriptor = $this->Socket; } if (socket_shutdown($deskriptor, $how)<0){ $this->error($deskriptor); } return true; } function close($deskriptor=null) { $this->method = "close"; if(!$deskriptor){ //Shutdown ALL incl. Me while (list ($id, $sock) = each ($this->clients)) { if($sock != $this->Socket){ socket_close($sock); } } if($this->family == AF_UNIX && file_exists($this->myhost)){ unlink($this->myhost); } socket_close($this->Socket); $this->clients = ""; $this->socketinfo = ""; $this->Socket = ""; return True; } $this->remove_socket($deskriptor); socket_close($deskriptor); return True; } function add_socket ($socket){ $this->method = "add_socket"; $this->clients[] = $socket; if($socket != $this->Socket){ $ip = $this->get_ip($socket); $this->socketinfo[$socket]['ip'] = $ip; $this->socketinfo[$socket]['host'] = $this->get_host($ip); } else { //its me ... $this->socketinfo[$socket]['ip'] = $this->myhost; $this->socketinfo[$socket]['host'] = "not supported"; } $this->socketinfo[$socket]['started'] = time(); $this->socketinfo[$socket]['last'] = time(); } function remove_socket($deskriptor){ $this->method = "remove_socket"; $sockets = ARRAY(); reset($this->clients); foreach($this->clients as $sock) { if($deskriptor != $sock){ $sockets[] = $sock; } } $this->remove_socketinfo($deskriptor); $this->clients = $sockets; } function get_socketinfo($deskriptor="", $field = ""){ $this->method = "get_socketinfo"; if(!$deskriptor){ return $this->socketinfo; } if(!$this->socketinfo[$deskriptor]){ $this->Error("","No valid socketdescriptor(id) given !\n"); return false; } if($field){ return $this->socketinfo[$deskriptor][$field]; } return $this->socketinfo[$deskriptor]; } function set_socketinfo($deskriptor, $field, $value){ $this->method = "set_socketinfo"; if(in_array($field,array("ip","host","started","last"))){ $this->Error("","Field \"$field\" is already in use by system\n"); return False; } $this->socketinfo[$deskriptor][$field] = $value; return True; } function remove_socketinfo($deskriptor){ $this->method = "remove_socketinfo"; $infos = ARRAY(); $this->socketinfo[$deskriptor] = ""; reset($this->socketinfo); while (list ($id, $sock) = each ($this->socketinfo)) { if($sock){ $infos[$id] = $sock; } } $this->socketinfo = $infos; } function get_host($ip){ $this->method = "get_host"; if($this->family == AF_INET ){ if(!$ip){ $this->Error("","Not a valid IP \"$ip\" given"); return false; } return gethostbyaddr($ip); } return "localhost"; } function get_ip ($deskriptor){ $this->method = "get_ip"; if($this->family == AF_INET ){ if(!$deskriptor){ $this->Error("","No valid socketdescriptor(id) given !\n"); return false; } socket_getpeername($deskriptor, $addr); if(!$addr){ return false; } return $addr; } return $this->mypath; } function debug_print($message){ if($this->opener){ echo nl2br($message); return; } echo "$message"; return; } function isdir($directory){ return ((@fileperms("$directory") & 0x4000) == 0x4000); } function Error($deskriptor="", $message = "", $critical = FALSE) { $headline = "Error in :".__CLASS__."::".$this->method."()"; if(!$critical){ if($message){$headline = "$headline\n->$message";} if($deskriptor){$headline.= "\n->".@socket_strerror(socket_last_error($deskriptor));} $this->debug_print("$headline\n"); return; } $msg = "Socketstatus below:\n"; $msg.= 'Last deskriptor status: '.@socket_strerror(socket_last_error($deskriptor))."\n"; $msg.= 'Last socket status: '.@socket_strerror(socket_last_error($this->Socket))."\n"; $msg.= "AT: ".__LINE__ ."\nIn:". __FILE__; $this->debug_print("CRITICAL ERROR !\n$headline\n$message\n$msg\nSocke dying...."); exit(); } } ?>
simple chat 'graffiti' wall... /* CREATE TABLE `thewall` ( `id` int(11) NOT NULL auto_increment, `timedate` varchar(15) NOT NULL default '', `nick` varchar(15) NOT NULL default '', `msg` varchar(255) NOT NULL default '', PRIMARY KEY (`id`) ) TYPE=MyISAM AUTO_INCREMENT=5 ; */ echo "<center><br><br>"; echo "<font class=header>The Grafitti Wall</font><br></center>"; if (isset($_POST['submit_wall'])) { $query = "INSERT INTO `thewall` ( `id` , `timedate` , `nick` , `msg` ) VALUES ('', '".date('F j, g:i a')."', '".$_SESSION['logged_in_username']."', '".$_POST['text']."')"; mysql_query($query) or die(mysql_error()); echo "msg submited<br><br>"; } $result = mysql_query("SELECT `id` , `timedate` , `nick` , `msg` FROM `thewall` WHERE 1 ORDER BY `id` DESC LIMIT 0 , 50") or die(mysql_error()); while ($row = mysql_fetch_array($result)) { echo $row['timedate'] . "<<font class='header'>" . $row['nick'] . "</font>> " . stripslashes(htmlspecialchars($row['msg'])) . "<br>"; } echo " <br><br> <font class=header>Add to the wall</font> <form method=post> Text: <input type=text size=50 maxlength=200 name='text'> <br><br> <input type=submit name='submit_wall' value='Add to the wall'> </form> ";

php.ComLanka.com PHP Tutorial ,PHP source code, PHP online example