bot.php

#!/usr/bin/php
<?php
if (!defined('STDIN'))
	die("Hashbot must be run from the command line.");

$start_time = time();

if(!defined('__DIR__'))
	define('__DIR__', dirname(__FILE__));

require __DIR__ . '/config.php';
@error_reporting($errors);

echo "Loading libraries... ";
require __DIR__ . "/lib/XMPPHP/XMPP.php";
include __DIR__ . "/lib/Unirest.php";
include __DIR__ . "/lib/chatterbotapi.php";
if ($old_auth) {
	require __DIR__ . "/lib/XMPPHP/XMPP_Old.php";
}
echo "done.\n";

// Language filter
if(!empty($filter_badwords)) {
	echo "Build word filter index... ";
	$wordfilter = json_decode(gzuncompress(file_get_contents("res/badwords.gz")));
	$wordreplace = array();
	foreach($wordfilter as &$w) {
		$wordreplace["/\\b" . str_replace("\\*", ".*", preg_quote($w)) . "\\b/"] = str_repeat("*", strlen($w));
	}
	echo count($wordfilter) . " words in index.\nDone.\n";
} else {
	echo "Word filter disabled.\n";
	$wordfilter = array();
	$wordreplace = array();
}

// Twitter @mentions
/*if(!empty($enable_mentions) && !empty($twitterConsumerKey)) {
	$last_mention_check = time();
	$last_mention_id = 0;
}*/


// Base $commands and $history arrays
$commands = array();
$history = array();

if ($old_auth) {
	$conn = new XMPPHP_XMPPOld($server, $port, $user, $pass, $clientid, $domain, $printlog = True, empty($logging) ? XMPPHP_Log::LEVEL_INFO : $logging);
} else {
	$conn = new XMPPHP_XMPP($server, $port, $user, $pass, $clientid, $domain, $printlog = True, empty($logging) ? XMPPHP_Log::LEVEL_INFO : $logging);
}
$conn->autoSubscribe();

$vcard_request = array();

try {
	$conn->connect();

	while (!$conn->isDisconnected()) {
		$payloads = $conn->processUntil(array('message', 'presence', 'end_stream', 'session_start', 'vcard'));
		foreach ($payloads as $event) {
			$pl = $event[1];
			switch ($event[0]) {
				case 'message':
					$msg = trim(preg_replace("/\\s+/", " ", $pl['body']));

					$pl['realfrom'] = $pl['from'];

					// Send group messages to the room, not the sender (weird)
					if ($pl['type'] == "groupchat")
						$pl['from'] = $room . "@" . $room_server;
					// Don't require a hash for direct messages
					elseif ($msg{0} != "#")
						$msg = '#' . $msg;

					$basic_msg = trim(preg_replace("/[^a-z ]/", "", strtolower($msg)));

					// Greetings
					if (in_array($basic_msg, $greetings)) {
						$conn->message($pl['from'], "Hi!", $pl['type']);

					// Colors
					} elseif (preg_match("/^(#[0-9A-Fa-f]{6})$/",trim($msg))) {
						$color = strtolower(trim($msg,"#"));
						$conn->htmlmessage($pl['from'], "<p><span style=\"color: {$color};\">███</span></p>", $pl['type'], "http://www.colorhexa.com/{$color}.png");

					// Re-run last command
					} elseif ($msg == "##") {
						if(!empty($history)) {
							$last_command = $history[count($history) - 1];
							$commands[$last_command["cmd"]]($conn, $pl, $last_command["params"]);
						} else {
							$conn->htmlmessage($pl['from'], "<p><span style=\"color: red;\">No commands have been run yet.</span></p>", $pl['type'], "No commands have been run yet.");
						}

					// Commands
					} elseif ($msg{0} == "#" && $msg{1} != "\\") {

						// Split message into command and parameters
						if (count(explode(" ", $msg)) > 1) {
							list($cmd, $param_str) = explode(" ", $msg, 2);
							$params = explode(" ", $param_str);
						} else {
							$cmd = $msg;
							$params = array();
						}

						// Get a simplified command string
						$cmd = trim(strtolower(ltrim($cmd, "#")));

						// Output the recived command
						$short_from = substr($pl['realfrom'],0,strpos($pl['realfrom'],"@"));
						if (strpos($pl['realfrom'],"/")) {
							$short_from .= substr($pl['realfrom'],strpos($pl['realfrom'],"/"));
						}

						if($cmd)
							echo $short_from . ": {$msg}\n";

						// Check for command alias
						if(!empty($aliases[$cmd])) {
							$cmd = $aliases[$cmd];
						}

						// Check if command is disabled
						if(in_array($cmd, $disabled)) {
							$conn->message($pl['from'], "The #{$cmd} command has been disabled.", $pl['type']);
							echo "Blocked command: {$cmd}\n";
						} else {
							// Verify the command exists and process it
							if (is_file(__DIR__ . "/commands/" . $cmd . ".php")) {
								try {
									include __DIR__ . "/commands/" . $cmd . ".php";
									$history[] = array(
										"cmd" => $cmd,
										"params" => $params
									);
									if(isset($commands[$cmd])) {
										$commands[$cmd]($conn, $pl, $params);
									} else {
										$conn->message($pl['from'], "The requested command was found in the filesystem, but was not available to call as a function. Check the function name in the commands/$cmd.php.", $pl['type']);
									}
								} catch(Exception $e) {
									echo $e->getMessage();
									$conn->message($pl['from'], "An error occurred while running the requested command. See the command line for debugging information.", $pl['type']);
								}
							} elseif($cmd == "help") {
								if (count(explode(" ", $msg)) > 1) {
									// Return detailed help for a command
									list($cmd, $param_str) = explode(" ", $msg, 2);
									$params = explode(" ", $param_str);
									if(is_file(__DIR__ . "/commands/" . $params[0] . ".txt")) {
										$help = file_get_contents(__DIR__ . "/commands/" . $params[0] . ".txt");
										$conn->message($pl['from'], trim($help), $pl['type']);
									} else {
										$conn->message($pl['from'], "Help is not available for #" . $params[0] . ".  Try running the command without any parameters.", $pl['type']);
									}
								} else {
									// Return command list
									$cmd_list = glob(__DIR__ . "/commands/*.php");
									foreach($cmd_list as &$cmd) {
										$cmd = str_replace(".php", "", $cmd);
										$cmd = str_replace(__DIR__ . "/commands/", "", $cmd);
									}
									$cmd_list = array_diff($cmd_list, $disabled);
									$conn->message($pl['from'], "Available commands (" . count($cmd_list) . "): " . implode(", ",$cmd_list), $pl['type']);
									echo "Available commands: " . implode(", ",$cmd_list) . "\n";
								}
							} elseif(!$cmd) {
								// empty command, do nothing
							} else {
								//$conn->message($pl['from'], "Unknown command: {$cmd}", $pl['type']);
								echo "Unknown command: {$cmd}\n";
							}
						}
					}
					break;
//				case 'presence':
//					print "Presence: {$pl['from']} [{$pl['show']}] {$pl['status']}\n";
//					break;
				case 'session_start':
					print "Session Start\n";
					$conn->getRoster();

					// Go online
					$conn->presence($status = $status_message);

					// Join room (if set)
					if (!empty($room)) {
						$conn->joinRoom($room, $room_server, $nick, $room_password);
						echo "Joining room {$room}\n";
					}

					// Set start time again (delays 2 seconds before processing any commands)
					$start_time = time();

					break;
				case 'vcard':
					// check to see who requested this vcard
					$deliver = array_keys($vcard_request, $pl['from']);
					// work through the array to generate a message
					print_r($pl);
					$msg = '';
					foreach ($pl as $key => $item) {
						$msg .= "$key: ";
						if (is_array($item)) {
							$msg .= "\n";
							foreach ($item as $subkey => $subitem) {
								$msg .= "  $subkey: $subitem\n";
							}
						} else {
							$msg .= "$item\n";
						}
					}
					// deliver the vcard msg to everyone that requested that vcard
					foreach ($deliver as $sendjid) {
						// remove the note on requests as we send out the message
						unset($vcard_request[$sendjid]);
						$conn->message($sendjid, $msg, 'chat');
					}
					break;
			}
		}
	}
} catch (XMPPHP_Exception $e) {
	die($e->getMessage());
}

function curl_get_contents($url,$user_agent = null) {
	if (in_array('curl', get_loaded_extensions())) {
		$curl = curl_init($url);
		curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
		curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);
		curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0);
		curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 0);
		if($user_agent) {
			curl_setopt($curl, CURLOPT_HTTPHEADER, array('User-Agent: ' . $user_agent));
		}
		$data = curl_exec($curl);
		curl_close($curl);
	} else {
		$data = file_get_contents($url);
	}
	return $data;
}

function curl_post_get_contents($url,$post_data = array(),$content_type = "application/json") {
	if (in_array('curl', get_loaded_extensions())) {
		$curl = curl_init($url);
		curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
		curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);
		curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0);
		curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 0);
		curl_setopt($curl, CURLOPT_POSTFIELDS, $post_data);
		if($content_type) {
			curl_setopt($curl, CURLOPT_HTTPHEADER, array('Content-Type: ' . $content_type));
		}
		$data = curl_exec($curl);
		curl_close($curl);
	} else {
		$data = file_get_contents($url);
	}
	return $data;
}