<?php

class ircbot{

	public $debug = false;	//Debugging

	protected $nick;
	protected $username;
	protected $realname;

	protected $host;
	protected $port;

	public $alive;			//Bot alive?

	protected $sleep;		//How long to wait after sending 1 line

	protected $channels = array();	//Channel-Array

	private $protocol;		//IRC-Protocol Handler
	private $connection;		//Fsock-class Handler (false if not connected)
	private $recvbuf;		//RECV-Buffer
	private $sendbuf;		//SEND-Buffer
	private $reactbuf;		//REACT-Buffer (to bypass linebreak errors)

	private $commands;		//Command-Handler for additional files
	private $userdb;		//User-Permission-DB

	private $endl = "\r\n";		//ENDL-Marker
	private $prefix;		//Command Prefix

	private $autoreconnect;		//Shall the Bot try to reconnect again?
	private $login = false;		//connection successful, we can work if it's true

	private $lastline = "";		//last sent line... (flood protection)
	private $lastlinetime = 0;	//timestamp of last sent line


	/*
	 * Class general stuff
	 */
	function __construct($nick, $username, $realname){
		$this -> alive = true;

		$this -> nick = $nick;
		$this -> username = $username;
		$this -> realname = $realname;
		$this -> connection = false;

		$this -> protocol = new ircprotocol($nick, $username, $realname);

		$this -> sendbuf = new blockstring($this -> endl);
		$this -> recvbuf = new blockstring($this -> endl);
		$this -> reactbuf = new blockstring($this -> endl);

		$this -> commands = new command_handler();
		$this -> userdb = new userdb();
	}

	public function setServer($host, $port){
		$this -> host = $host;
		$this -> port = $port;
	}

	public function setAutoReconnect($bool){
		$this -> autoreconnect = $bool;
	}

	public function setPrefix($prefix){
		$this -> prefix = $prefix;
	}

	public function addChannels($channels){
		$this -> channels = array_merge($this -> channels, $channels);
		if($this -> login){
			foreach($channels as $channel){
				$this -> call("join", $channel);
			}
		}
	}

	public function removeChannels($channels){
		foreach($channels as $channel){
			unset($this -> channels[array_search($channel, $this -> channels)]);	
			if($this -> login) $this -> call("part", $channel, "Removed ".$channel." from list.");
		}
	}
	
	public function setSleep($sleep){
		$this -> sleep = $sleep * 1000000;
	}

	public function clearBuffer(){
		$this -> sendbuf -> clear();
		$this -> recvbuf -> clear();
		$this -> reactbuf -> clear();
	}

	function __destruct(){
		$this -> clearBuffer();

		if($this -> connection){
			$this -> autoreconnect = false;
			$this -> disconnect();
		}

		unset($this -> recvbuf);
		unset($this -> sendbuf);
		unset($this -> reactbuf);
		unset($this -> commands);
		unset($this -> userdb);

		$this -> alive = false;
	}


	/*
	 * Connection handling stuff
	 */
	public function connect(){
		$this -> connection = new fsock($this -> host, $this -> port, 16384, $this -> endl, 5, 0.5);
		$this -> send($this -> protocol -> auth());
		$this -> send($this -> protocol -> nick());
		
		//Wait for being able to join channels
		while(!$this -> login) $this -> update();

		//Join given channels
		foreach($this -> channels as $channel){
			$this -> call("join", $channel);
		}

		//Update in order to send all join commands...
		$this -> update();
	}	

	public function send($msg){
		if($msg != "") $this -> sendbuf -> addData($msg.$this -> endl);
		$this -> update();
	}

	public function recv(){
		$this -> update();
		if(!$line = $this -> recvbuf -> getNextLine()) return false;
		$recv = $this -> protocol -> parse($line);
	
		//add permission level, process-flag and default value for "command"
		if(isset($recv["nick"])) $recv["level"] = $this -> userdb -> getLevel($recv["nick"]);
		$recv["processed"] = false;
		$recv["command"] = false;

		//If we've got a Query...
		if($this -> protocol -> checkQuery($recv)){
			$recv["processed"] = true;
			$recv["query"] = true;
			$recv["command"] = ($recv["msgarr"][0][0] == $this -> prefix) ? substr($recv["msgarr"][0], 1) : $recv["msgarr"][0];

			if($code = $this -> commands -> getCode($recv["command"], "query", $recv["level"])){
				if($this -> debug) echo "[EVAL] Command: ".$recv["command"]." (query)\n";
				if(trim($code) != "" && !is_numeric($code)){
					eval($code);
				}
				unset($code, $recv["command"]);
			}
		}//if query

		//if command with prefix has been called...
		if($this -> protocol -> checkCommand($this -> prefix, $recv)){
			$recv["processed"] = true;
			$recv["command"] = $this -> protocol -> getCommand($this -> prefix, $recv);

			$code = $this -> commands -> getCode($recv["command"], "prefix", $recv["level"]);
			if(trim($code) != "" && !is_numeric($code)){
				if($this -> debug) echo "[EVAL] Command: ".$recv["command"]." (prefix)\n".$code."\n";
				eval($code);
				unset($code, $recv["command"]);
			}
			elseif($code == 2){
				$this -> call("privmsg", $recv["target"], $recv["nick"].": permission denied! (your level: ".$recv["level"]." < ".$this -> commands -> getLevel($recv["command"]).")");
				if(!$this -> userdb -> isActive($recv["nick"]) && $this -> userdb -> isUser($recv["nick"])) $this -> call("notice", $recv["nick"], "You have to identify yourself! (Type ".$this -> prefix."help for further information)");
			}
			elseif($code == 3){
				$this -> call("privmsg", $recv["target"], $recv["nick"].": permission denied! (context: ".$this -> commands -> getContext($recv["command"]).")");
			}
		}//if prefix command

		//If we've got a Channel-Command without trigger...that has NOT been processed before!
		if(!$recv["processed"] && $this -> protocol -> checkChannel($recv)){
			$recv["command"] = $recv["target"];

			if($code = $this -> commands -> getCode($recv["command"], "channel", $recv["level"])){
				if($this -> debug) echo "[EVAL] Command: ".$recv["command"]." (channel)\n";
				eval($code);
				unset($code, $recv["command"]);
				$recv["processed"] = true;
			}
		}//if channel

		$recv["command"] = (isset($recv["command"]) && !$recv["processed"]) ? $recv["command"] : "";

		return $recv;
	}

	/*
	 * Updating recvbuf and flushing sendbuf while checking for incoming pings
	 */
	public function update(){
		if($this -> connection -> isConnected()){
			//Putting recieved stuff into the recv-buffer
			while($recv = $this -> connection -> recv()){
				$this -> reactbuf -> addData($recv);
				unset($recv);
			}//recv loop

			//emergency flood protection
			$lines = 0;
			$lines = $this -> reactbuf -> countLines();
			if(($lines > 215)){
				if($this -> debug) echo "[FLOOD] Houston, we have got a problem! (".$lines." lines at once)\n";
				$this -> disconnect();
			}
			
			//react to stuff
			while($this -> reactbuf -> gotLine()){
				if(!$this -> react($recv = $this -> reactbuf -> getNextLine())) $this -> recvbuf -> addData($recv);
			}

			//Sending everything we've got in our buffer
			while($this -> sendbuf -> gotLine()){
				$data = $this -> sendbuf -> getNextLine();
				if(($data != $this -> lastline && trim($data) != "") || ($data == $this -> lastline && time() - 10 > $this -> lastlinetime)){//we will never repeat something within 10 seconds
					if($this -> debug) echo "Sending: '".$data."'\n";
					$this -> connection -> send($data);
					$this -> lastline = $data;
					$this -> lastlinetime = time();
					unset($data);
					usleep($this -> sleep);
				}
			}//send loop

			//if there is nothing to process and nothing to recieve, we can allow the cpu to have a break.
			if(!$this -> recvbuf -> gotLine() && !$this -> connection -> gotData()) usleep($this -> sleep);
		}//if connected
		else{
			if($this -> debug) echo "Connection closed!\n";
			$this -> disconnect();
		}
	}

	public function disconnect(){
		if($this -> debug) echo "Disconnecting...";

		$this -> clearBuffer();
		$this -> login = false;

		$this -> lastline = "";
		$this -> lastlinetime = 0;

		if($this -> connection){
			unset($this -> connection);
			$this -> connection = false;
		}
		if($this -> debug) echo "done.\n";
		if($this -> autoreconnect){
			sleep(1);
			if($this -> debug) echo "AutoReconnect enabled. Reconnecting now...\n";
			$this -> connect();
			if($this -> debug) echo "Reconnect done.\n";
		}
	}


	/*
	 * Other stuff...
	 */
	//Nickchange within runtime
	public function setNick($nick){
		if($this -> nick != $nick){
			$this -> nick = $nick;
			$this -> send($this -> protocol -> setNick($this -> nick));
			$this -> update();
		}
	}

	//Call IRC-Protocol functions (join, part, privmsg,....) and send the result directly
	public function call(){
		$params = func_get_args();
		$function = $params[0];
		$array = array_slice($params,1);
		foreach($array as $value) $args[] = addslashes($value);
		$args = implode("', '",$args);
		$call = "\$data = \$this -> protocol -> ".$function."('".$args."');";
		if($this -> debug) echo "[EVAL] Calling: '".$call."'\n";
		eval($call);
		$this -> send(stripslashes($data));
		unset($call, $data);
	}


	/*
	 * Reacting to some important stuff
	 */
	private function react($recv){
		$p = $this -> protocol -> parse($recv);

		if($this -> login == false && ($p["servermsg"] === true && $p["action"] == "001")) $this -> login = true; //we're logged in if 001 MSG arrives
		elseif($this -> login == false && ($p["servermsg"] === true && $p["action"] == "433")) $this -> setNick($this -> nick."|".rand(0,9)); //our chosen nick is already in use
		elseif($p["servermsg"] === true && $p["action"] == "474") $this -> removeChannels(array($p["param"])); //our chosen nick is already in use
		//if we've got a PING
		elseif(trim($data = $this -> protocol -> checkPing($recv)) != ""){
			$this -> send($data);
			unset($data);
		}
		//check for a serverkick (ERROR)
		elseif(preg_match("/^ERROR :/", $recv)){
			if($this -> debug) echo "Serverkick!\n";
			$this -> disconnect();
		}
		elseif($p["action"] == "KICK" && $p["param"] == $this -> nick) $this -> call("join", $p["target"]); //check for being kicked..
		elseif($p["action"] == "PART" && $p["nick"] == $this -> nick) $this -> call("join", $p["target"]); //check for being parted..
		elseif($p["action"] == "QUIT" || $p["action"] == "PART") $this -> userdb -> logout($p["nick"]); //check for user logout
		else{
			//bot did not react to this line
			return false;
		}

		//bot reacted to this in some way.
		return true;
	}

	/*
	 * Other stuff....
	 */

	//evaluating php-code and return output (WILL CAUSE PROBLEMS WHEN DEBUG-OUTPUT IS ON!)
	public function eval_php($code){
		ob_start();
		eval($code);
		$output = ob_get_contents();
		ob_clean();
		ob_end_clean();
		return $output;
	}

	public function eval_sys($cmd){
		$p = popen($cmd, "r");
		while($data = fgets($p, 8192)){
			$result[] = $data;	
		}
		pclose($p);
		return $result;
	}

}

?>