config_file, true); $this->db = new mysqli( $config['database']['domain'], $config['database']['user'], $config['database']['password'], $config['database']['database']); if (mysqli_connect_errno()) { echo "Problem connecting to database: "; echo mysqli_connect_error(); exit(); } } public function query() { $args = func_get_args(); $statement = $this->db->prepare(array_shift($args)); if ($args) call_user_func_array(array($statement, 'bind_param'), &$args); $statement->execute(); $statement->store_result(); $statement->store_result(); $data = $statement->result_metadata(); $return = $row = $fields = array(); $fields[0] = &$statement; while($field = $data->fetch_field()) $fields[] = &$row[$field->name]; call_user_func_array("mysqli_stmt_bind_result", $fields); $i = 0; while ($statement->fetch()) { foreach ($row as $key=>$value) $return[$i][$key] = $value; $i++; } $statement->free_result(); return $return; } public function insert() { $args = func_get_args(); $statement = $this->db->prepare(array_shift($args)); call_user_func_array(array($statement, 'bind_param'), &$args); $statement->execute(); return $this->db->insert_id; } public function update() { $args = func_get_args(); $statement = $this->db->prepare(array_shift($args)); call_user_func_array(array($statement, 'bind_param'), &$args); $statement->execute(); return $this->db->insert_id; } } class universe { public $rows = 30; public $columns = 30; public $rooms = array(); public function __construct($db) { $rooms = $db->query('SELECT id,x,y,state FROM rooms'); if ($rooms) { foreach ($rooms as $room) { $this->rooms[$room['x']][$room['y']] = array('id' => $room['id'], 'state' => $room['state']); } } else { $sql = 'INSERT INTO rooms (x,y,state) VALUES(?,?,?)'; $types = 'iii'; for ($x = 0; $x < $this->columns; $x++) { $column = array(); for ($y = 0; $y < $this->rows; $y++) { $state = (rand(0, 9) < 2 ? true : false); $id = $db->insert($sql, $types, $x, $y, $state); $this->rooms[$x][$y] = array('id' => $id, 'state' => $state); } } } } public function serialize() { $serial = array(); for ($x = 0; $x < $this->columns; $x++) { for ($y = 0; $y < $this->rows; $y++) { $serial[$x][$y] = $this->rooms[$x][$y]['state']; } } return $serial; } } class player { public $id; public $name; public $room; public $x; public $y; public function __construct($db) { $player = $db->query( 'SELECT players.id, players.name, players.room, rooms.x, rooms.y' . ' FROM players LEFT JOIN rooms ON players.room = rooms.id' . ' WHERE players.id = ?', 'i', $_SESSION['id'] ); $player = $player[0]; $this->id = $player['id']; $this->name = $player['name']; $this->room = $player['room']; $this->x = $player['x']; $this->y = $player['y']; } } class mud extends model { private $universe; public function __construct() { parent::__construct(); session_start(); $this->universe = new universe($this); } private function join() { $x = $y = 0; do { $x = rand(0, count($this->universe->rooms)-1); $y = rand(0, count($this->universe->rooms[0])-1); } while ($this->universe->rooms[$x][$y]['state']); $id = $this->insert('INSERT INTO players (name,room) VALUES(?,?)', 'si', $_GET['name'], $this->universe->rooms[$x][$y]['id']); $_SESSION['id'] = $id; //$others = $this->query('SELECT id, room FROM players WHERE id != ?', 'i', $this->player->id); return array('x' => $x, 'y' => $y, 'id' => $id, 'name' => $name, 'poll' => $this->poll()); } private function yell($msg) { $this->insert( 'INSERT INTO messages (message,type,room,source) VALUES(?,?,?,?)', 'ssii', $msg, 'yell', $this->player->room, $this->player->id); } private function say($msg) { $this->insert( 'INSERT INTO messages (message,type,room,source) VALUES(?,?,?,?)', 'ssii', $msg, 'say', $this->player->room, $this->player->id); } private function move() { } private function poll() { $time = isset($_SESSION['last_polled']) ? $_SESSION['last_polled'] : 0; $messages = $this->query( 'SELECT message, type, name, sent, players.id FROM messages LEFT JOIN players' . ' ON destination = players.id' . ' OR source = players.id' . ' WHERE TIMESTAMPDIFF(MINUTE, sent, NOW()) < 5' . ' AND UNIX_TIMESTAMP(sent) >= ?' . ' AND (type = "yell"' . ' OR (type = "tell" AND destination = ?)' . ' OR (type = "say" AND messages.room = ?))', 'iii', $time, $this->player->id, $this->player->room); $players = $this->query( 'SELECT players.id, name, x ,y ' . 'FROM players JOIN rooms ' . 'ON players.room = rooms.id'); $_SESSION['last_polled'] = time(); return array('messages' => $messages, 'players' => $players); } public function response($content) { header('Content-Type: application/json'); echo json_encode($content); } public function command($cmd) { if (!$_GET['cmd']) $this->error(400, 'Missing command: expected `cmd` field'); if ($_GET['cmd'] != 'join' && $_GET['cmd'] != 'start' && !isset($_SESSION['id'])) $this->error(401, 'Missing user ID: please join first'); if (isset($_SESSION['id'])) $this->player = new player($this); switch ($cmd) { case 'start': $this->response($this->universe->serialize()); break; case 'join': $this->response($this->join()); break; case 'move': $this->response(array('valid' => $this->move())); break; case 'tell': $this->tell(); break; case 'yell': $this->yell($_GET['msg']); break; case 'say': $this->say(); break; case 'tell': $this->tell(); break; case 'poll': echo json_encode($this->poll()); break; default: $this->error(400, 'Unknown command'); } } private function error($status, $msg) { header("HTTP/1.0 $status"); echo $msg; } } $mud = new mud(); $mud->command($_GET['cmd']); ?>