Basic SQL connections

Author: HiGuyMB

bin/chat-server.php

@@ -2,19 +2,24 @@
 use Ratchet\Server\IoServer;
 use Ratchet\Http\HttpServer;
 use Ratchet\WebSocket\WsServer;
-use LBChat\ChatServer;
+use LBChat\Database\Database;
+use LBChat\Database\SQLChatServer;
+use LBChat\Command\CommandFactory;
 
 require dirname(__DIR__) . "/vendor/autoload.php";
 
-\LBChat\Command\CommandFactory::init();
+CommandFactory::init();
+
+$database = new Database();
+$database->connect();
 
 $server = IoServer::factory(
 	new HttpServer(
 		new WsServer(
-			new ChatServer()
+			new SQLChatServer($database)
 		)
 	),
-	28002
+	39002
 );
 
 $server->run();

db.php

@@ -0,0 +1,90 @@
+<?php
+
+//Catch any errors
+if (defined("MBDBRUN"))
+	return;
+define("MBDBRUN", 1);
+
+/**
+ * Master database control class
+ */
+class MBDB {
+	static $databases = null;
+
+	/**
+	 * Get the hostname for the specified database
+	 * @param string $db The database's identifier
+	 * @return string The database's hostname
+	 */
+	static function getDatabaseHost($db) {
+		return self::$databases[$db]["host"];
+	}
+
+	/**
+	 * Get the database name for the specified database
+	 * @param string $db The database's identifier
+	 * @return string The database's name
+	 */
+	static function getDatabaseName($db) {
+		return self::$databases[$db]["data"];
+	}
+
+	/**
+	 * Get the username to access the specified database
+	 * @param string $db The database's identifier
+	 * @return string The username to access the database
+	 */
+	static function getDatabaseUser($db) {
+		return self::$databases[$db]["user"];
+	}
+
+	/**
+	 * Get the password to access the specified database
+	 * @param string $db The database's identifier
+	 * @return string The password to access the database
+	 */
+	static function getDatabasePass($db) {
+		return self::$databases[$db]["pass"];
+	}
+
+	/**
+	 * Add a database to the class's list of databases
+	 * @param string $ident The database's identifier
+	 * @param string $host The host for the database
+	 * @param string $data The database name for the database
+	 * @param string $user The username to access the database
+	 * @param string $pass The password to access the database
+	 */
+	static function addDatabase($ident = null, $host = null, $data = null, $user = null, $pass = null) {
+		if ($ident == null || $host == null || $data == null || $user == null || $pass == null)
+			return;
+		if (self::$databases == null) {
+			self::$databases = array();
+		}
+		
+		//%b -> resolves to getBranch()
+		$ident = str_replace("%b", self::getBranch(), $ident);
+		$host  = str_replace("%b", self::getBranch(),  $host);
+		$data  = str_replace("%b", self::getBranch(),  $data);
+		$user  = str_replace("%b", self::getBranch(),  $user);
+		$pass  = str_replace("%b", self::getBranch(),  $pass);
+
+		self::$databases[$ident] = array("host" => $host, "data" => $data, "user" => $user, "pass" => $pass);
+	}
+
+	/**
+	 * Get the current site "branch" (dev | staging | prod)
+	 * @return string The current branch
+	 */
+	static function getBranch() {
+		$branch = basename(dirname(__DIR__));
+		return $branch;
+	}
+}
+
+//Default DBs
+MBDB::addDatabase("joomla",       "localhost", "%b_joomla",       "mb-%b", "");
+MBDB::addDatabase("platinum",     "localhost", "%b_platinum",     "mb-%b", "");
+MBDB::addDatabase("platinum_old", "localhost", "%b_platinum_old", "mb-%b", "");
+MBDB::addDatabase("dedicated",    "localhost", "%b_dedicated",    "mb-%b", "");
+MBDB::addDatabase("fubar",        "localhost", "%b_fubar",        "mb-%b", "");

src/LBChat/Database/Database.php

@@ -0,0 +1,19 @@
+<?php
+namespace LBChat\Database;
+
+class Database {
+	protected $connection;
+
+	public function connect() {
+		//Load the db config
+		require("../db.php");
+
+		try {
+			$dsn = "mysql:dbname=" . \MBDB::getDatabaseName("platinum") . ";host=" . \MBDB::getDatabaseHost("platinum");
+			$this->connection = new \PDO($dsn, \MBDB::getDatabaseUser("platinum"), \MBDB::getDatabasePass("platinum"));
+		} catch (\Exception $e) {
+			//Something
+			throw $e;
+		}
+	}
+}

src/LBChat/Database/SQLChatServer.php

@@ -0,0 +1,15 @@
+<?php
+namespace LBChat\Database;
+
+use LBChat\ChatServer;
+
+class SQLChatServer extends ChatServer {
+	protected $database;
+
+	public function __construct($database) {
+		parent::__construct();
+
+		$this->database = $database;
+	}
+
+}