EmmetBlue / Emmet-Blue

src/Core/Connection/Adapters/MySQL.php

Indentation +88 added lines, -88 removed lines

@@ -21,105 +21,105 @@
  */
 class MySQL implements ConnectableInterface
 {
-    /**
-     * @var string $dsn
-     */
-    protected $dsn;
+	/**
+	 * @var string $dsn
+	 */
+	protected $dsn;
 
-    /**
-     * @var \PDO $connectionObject
-     */
-    protected $connectionObject;
+	/**
+	 * @var \PDO $connectionObject
+	 */
+	protected $connectionObject;
 
-    /**
-     * @var array loginData
-     */
-    private $loginData = [];
+	/**
+	 * @var array loginData
+	 */
+	private $loginData = [];
 
-    /**
-     * Setter for the DSN string {@see $dsn}
-     *
-     * @param array $dsnArray
-     * @return void
-     */
-    public function setDsn(array $dsnArray)
-    {
-        $this->dsn = $dsnArray;
-    }
+	/**
+	 * Setter for the DSN string {@see $dsn}
+	 *
+	 * @param array $dsnArray
+	 * @return void
+	 */
+	public function setDsn(array $dsnArray)
+	{
+		$this->dsn = $dsnArray;
+	}
 
-    /**
-     * Establishes connection
-     *
-     * @param string $username
-     * @param string $password optional
-     * @throws \EmmetBlue\Core\Exception\SQLException
-     * @return void
-     */
-    public function connect(string $username, string $password="")
-    {
-        $host = $this->dsn[0];
-        $database = $this->dsn[1];
+	/**
+	 * Establishes connection
+	 *
+	 * @param string $username
+	 * @param string $password optional
+	 * @throws \EmmetBlue\Core\Exception\SQLException
+	 * @return void
+	 */
+	public function connect(string $username, string $password="")
+	{
+		$host = $this->dsn[0];
+		$database = $this->dsn[1];
 
-        $this->loginData['username'] = $username;
-        $this->loginData['password'] = $password;
+		$this->loginData['username'] = $username;
+		$this->loginData['password'] = $password;
 
-        try
-        {
-            $this->connectionObject = new \PDO("mysql:host=$host;dbname=$database;", $username, $password);
-        }
-        catch (\PDOException $e)
-        {
-            throw new SQLException("Unable to connect to database", 400, $e);  
-        }
+		try
+		{
+			$this->connectionObject = new \PDO("mysql:host=$host;dbname=$database;", $username, $password);
+		}
+		catch (\PDOException $e)
+		{
+			throw new SQLException("Unable to connect to database", 400, $e);  
+		}
 
-        $dsn = $this->dsn;
-        unset($dsn[0], $dsn[1]);
+		$dsn = $this->dsn;
+		unset($dsn[0], $dsn[1]);
         
-        foreach ($dsn as $attribute)
-        {
-            foreach ($attribute as $key=>$value)
-            {
-                $this->connectionObject->setAttribute($key, $value);
-            }
-        }
-    }
+		foreach ($dsn as $attribute)
+		{
+			foreach ($attribute as $key=>$value)
+			{
+				$this->connectionObject->setAttribute($key, $value);
+			}
+		}
+	}
 
-    /**
-     * Returns an instance a pdo intance of the connection object
-     *
-     * @return \PDO
-     */
-    public function getConnection() : \PDO
-    {
-        if ($this->connectionObject instanceof \PDO)
-        {
-            return $this->connectionObject;
-        }
+	/**
+	 * Returns an instance a pdo intance of the connection object
+	 *
+	 * @return \PDO
+	 */
+	public function getConnection() : \PDO
+	{
+		if ($this->connectionObject instanceof \PDO)
+		{
+			return $this->connectionObject;
+		}
 
-        $this->connect(
-            $this->loginData['username'] ?? '',
-            $this->loginData['password'] ?? ''
-        );
+		$this->connect(
+			$this->loginData['username'] ?? '',
+			$this->loginData['password'] ?? ''
+		);
 
-        return $this->connectionObject;
-    }
+		return $this->connectionObject;
+	}
 
-    /**
-     * Closes connection
-     */
-    public function disableConnection()
-    {
-        $this->connectionObject = null;
-    }
+	/**
+	 * Closes connection
+	 */
+	public function disableConnection()
+	{
+		$this->connectionObject = null;
+	}
 
-    /**
-     * Sets attributes for the PDO object
-     *
-     * @param \PDO $attribute
-     * @param \PDO $value
-     */
-    public function setAttribute(\PDO $attribute, \PDO $value)
-    {
-         $this->connectionObject->setAttribute($attribute, $value);
-    }
+	/**
+	 * Sets attributes for the PDO object
+	 *
+	 * @param \PDO $attribute
+	 * @param \PDO $value
+	 */
+	public function setAttribute(\PDO $attribute, \PDO $value)
+	{
+		 $this->connectionObject->setAttribute($attribute, $value);
+	}
 }

src/Core/Factory/MailerFactory.php

Indentation +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
 	public function __construct(array $sender, array $recipients, array $message){
 		$smtpConfigJson = file_get_contents(Constant::getGlobals()["config-dir"]["smtp-config"]);
 
-        $smtpConfig = json_decode($smtpConfigJson);
+		$smtpConfig = json_decode($smtpConfigJson);
 
 		$mail = new \PHPMailer;
 		$mail->SMTPDebug = $smtpConfig->debug;

src/Core/Factory/DatabaseConnectionFactory.php

Indentation +39 added lines, -39 removed lines

@@ -21,43 +21,43 @@
  */
 class DatabaseConnectionFactory
 {
-    /**
-     * @var \PDO $connectionObject
-     */
-    private static $connectionObject;
-
-    /**
-     * Gets the config values defined in the database-config.json file
-     * and uses the values to create a new connection object.
-     */
-    public static function bootstrap()
-    {
-        $databaseConfigJson = file_get_contents(Constant::getGlobals()["config-dir"]["database-config"]);
-
-        $databaseConfig = json_decode($databaseConfigJson);
-
-        $adapter = $databaseConfig->adapter;
-        $server = $databaseConfig->server;
-        $database = $databaseConfig->database;
-        $username = $databaseConfig->username;
-        $password = $databaseConfig->password;
-
-        self::$connectionObject = new Connection($adapter, [$server, $database], $username, $password);
-
-        if ($databaseConfig->showError)
-        {
-            self::$connectionObject->getConnection()->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
-        }
-    }
-
-    /**
-     * Returns a new connection object
-     * 
-     * @return \PDO
-     */
-    public static function getConnection() : \PDO
-    {
-        self::bootstrap();
-        return self::$connectionObject->getConnection();
-    }
+	/**
+	 * @var \PDO $connectionObject
+	 */
+	private static $connectionObject;
+
+	/**
+	 * Gets the config values defined in the database-config.json file
+	 * and uses the values to create a new connection object.
+	 */
+	public static function bootstrap()
+	{
+		$databaseConfigJson = file_get_contents(Constant::getGlobals()["config-dir"]["database-config"]);
+
+		$databaseConfig = json_decode($databaseConfigJson);
+
+		$adapter = $databaseConfig->adapter;
+		$server = $databaseConfig->server;
+		$database = $databaseConfig->database;
+		$username = $databaseConfig->username;
+		$password = $databaseConfig->password;
+
+		self::$connectionObject = new Connection($adapter, [$server, $database], $username, $password);
+
+		if ($databaseConfig->showError)
+		{
+			self::$connectionObject->getConnection()->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
+		}
+	}
+
+	/**
+	 * Returns a new connection object
+	 * 
+	 * @return \PDO
+	 */
+	public static function getConnection() : \PDO
+	{
+		self::bootstrap();
+		return self::$connectionObject->getConnection();
+	}
 }

src/Core/Factory/HTTPRequestFactory.php

Indentation +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
 	{
 		$configJson = file_get_contents(Constant::getGlobals()["config-dir"]["http-headers-config"]);
 
-        self::$headers = json_decode($configJson, true);
+		self::$headers = json_decode($configJson, true);
 	}
 
 	public static function get($url, $extraHeaders = [])

src/Core/Factory/ElasticSearchClientFactory.php

Indentation +2 added lines, -2 removed lines

@@ -26,9 +26,9 @@
 	{
 		$configJson = file_get_contents(Constant::getGlobals()["config-dir"]["elasticsearch-config"]);
 
-        $config = json_decode($configJson, true);
+		$config = json_decode($configJson, true);
 
-        self::$clientObject = \Elasticsearch\ClientBuilder::create()->setHosts($config["hosts"])->build();
+		self::$clientObject = \Elasticsearch\ClientBuilder::create()->setHosts($config["hosts"])->build();
 	}
 
 	public static function getClient()

src/Core/Logger/DatabaseLog.php

Indentation +24 added lines, -24 removed lines

@@ -22,12 +22,12 @@ 
  */
 class DatabaseLog implements LogInterface
 {
-    public static function logDeprecated(string $databaseUserId, string $event, string $objectSchema, string $object, string $tSql)
-    {
-        $insertBuilder = (new Builder("QueryBuilder", "Insert"))->getBuilder();
-        try {
-            $insertBuilder
-                ->into('
+	public static function logDeprecated(string $databaseUserId, string $event, string $objectSchema, string $object, string $tSql)
+	{
+		$insertBuilder = (new Builder("QueryBuilder", "Insert"))->getBuilder();
+		try {
+			$insertBuilder
+				->into('
                     [Logs].[DatabaseLog]
                     (
                         PostTime,
@@ -38,25 +38,25 @@ 
                         TSQL
                     )
                 ')
-                ->values([
-                    'GETDATE()',
-                    QB::wrapString($databaseUserId, "'"),
-                    QB::wrapString((string)$event, "'"),
-                    QB::wrapString($objectSchema, "'"),
-                    QB::wrapString($object, "'"),
-                    QB::wrapString(str_replace("'", "\"", $tSql), "'")
-                ]);
+				->values([
+					'GETDATE()',
+					QB::wrapString($databaseUserId, "'"),
+					QB::wrapString((string)$event, "'"),
+					QB::wrapString($objectSchema, "'"),
+					QB::wrapString($object, "'"),
+					QB::wrapString(str_replace("'", "\"", $tSql), "'")
+				]);
             
-            DBConnectionFactory::getConnection()->query((string)$insertBuilder);
-        } catch (\PDOException $e) {
-            echo $e->getMessage();
-            throw new SQLException(sprintf(
-                    "Unable to store database log"
-                ), 1);
-        }
-    }
+			DBConnectionFactory::getConnection()->query((string)$insertBuilder);
+		} catch (\PDOException $e) {
+			echo $e->getMessage();
+			throw new SQLException(sprintf(
+					"Unable to store database log"
+				), 1);
+		}
+	}
 
-    public static function log(string $databaseUserId, string $event, string $objectSchema, string $object, string $tSql){
+	public static function log(string $databaseUserId, string $event, string $objectSchema, string $object, string $tSql){
 
-    }
+	}
 }

src/Core/Logger/ErrorLog.php

Indentation +25 added lines, -25 removed lines

@@ -22,21 +22,21 @@ 
  */
 class ErrorLog implements LogInterface
 {
-    public static function logDeprecated(int $databaseUserId, string $errorNumber, string $errorSeverity, string $errorMessage, string $errorObject=null)
-    {
-        /**
-         * For now I am not doing anything with $errorObject yet.
-         *
-         * As soon as it can be properly serialized for the MSSQL Server db
-         * it shall be saved in the database.
-         *
-         * FUNNY: I'M GONNA INTENTIONALLY LEAVE THIS COMMIT FOR MY AMUSEMENT
-         * $errorObject, wasn't the issue. My DB schema was.
-         */
-        $insertBuilder = (new Builder("QueryBuilder", "Insert"))->getBuilder();
+	public static function logDeprecated(int $databaseUserId, string $errorNumber, string $errorSeverity, string $errorMessage, string $errorObject=null)
+	{
+		/**
+		 * For now I am not doing anything with $errorObject yet.
+		 *
+		 * As soon as it can be properly serialized for the MSSQL Server db
+		 * it shall be saved in the database.
+		 *
+		 * FUNNY: I'M GONNA INTENTIONALLY LEAVE THIS COMMIT FOR MY AMUSEMENT
+		 * $errorObject, wasn't the issue. My DB schema was.
+		 */
+		$insertBuilder = (new Builder("QueryBuilder", "Insert"))->getBuilder();
 
-        $insertBuilder
-            ->into('
+		$insertBuilder
+			->into('
                 [Logs].[ErrorLog]
                 (
                     ErrorTime,
@@ -46,18 +46,18 @@ 
                     ErrorMessage
                 )
             ')
-            ->values([
-                'GETDATE()',
-                $databaseUserId,
-                QB::wrapString($errorNumber, "'"),
-                QB::wrapString($errorSeverity, "'"),
-                QB::wrapString($errorMessage, "'")
-            ]);
+			->values([
+				'GETDATE()',
+				$databaseUserId,
+				QB::wrapString($errorNumber, "'"),
+				QB::wrapString($errorSeverity, "'"),
+				QB::wrapString($errorMessage, "'")
+			]);
             
-        DBConnectionFactory::getConnection()->query((string)$insertBuilder);
-    }
+		DBConnectionFactory::getConnection()->query((string)$insertBuilder);
+	}
 
-    public static function log(int $databaseUserId, string $errorNumber, string $errorSeverity, string $errorMessage, string $errorObject=null) {
+	public static function log(int $databaseUserId, string $errorNumber, string $errorSeverity, string $errorMessage, string $errorObject=null) {
 
-    }
+	}
 }

src/Core/Constant.php

Indentation +37 added lines, -37 removed lines

@@ -19,50 +19,50 @@
  */
 class Constant
 {
-    /**
-     * Events
-     */
-    const EVENT_INSERT = 'EVENT: INSERT DML EVENT';
-    const EVENT_SELECT = 'EVENT: SELECT DML EVENT';
-    const EVENT_UPDATE = 'EVENT: UPDATE DML EVENT';
+	/**
+	 * Events
+	 */
+	const EVENT_INSERT = 'EVENT: INSERT DML EVENT';
+	const EVENT_SELECT = 'EVENT: SELECT DML EVENT';
+	const EVENT_UPDATE = 'EVENT: UPDATE DML EVENT';
 
-    /**
-     * @author Lucky Bardeson
-     */
-    const EVENT_DELETE = 'EVENT: DELETE DML EVENT';
+	/**
+	 * @author Lucky Bardeson
+	 */
+	const EVENT_DELETE = 'EVENT: DELETE DML EVENT';
 
-    /**
-     * Error Numbers
-     */
-    const ERROR_401 = 'ERROR_401: Resource Inaccessible';
-    const ERROR_402 = 'ERROR_402: Resource Requirements Not Met';
-    const ERROR_403 = 'ERROR_403: Resource Not Writable';
-    const ERROR_404 = 'ERROR_404: Resource Not Found';
+	/**
+	 * Error Numbers
+	 */
+	const ERROR_401 = 'ERROR_401: Resource Inaccessible';
+	const ERROR_402 = 'ERROR_402: Resource Requirements Not Met';
+	const ERROR_403 = 'ERROR_403: Resource Not Writable';
+	const ERROR_404 = 'ERROR_404: Resource Not Found';
 
-    /**
-     * Error Severities
-     */
-    const ERROR_HIGH = 'ERROR_SEVERITY: HIGH';
-    const ERROR_LOW = 'ERROR_SEVERITY: LOW';
-    const ERROR_NORMAL = 'ERROR_SEVERITY: NORMAL';
+	/**
+	 * Error Severities
+	 */
+	const ERROR_HIGH = 'ERROR_SEVERITY: HIGH';
+	const ERROR_LOW = 'ERROR_SEVERITY: LOW';
+	const ERROR_NORMAL = 'ERROR_SEVERITY: NORMAL';
 
-    /**
-     * 
-     */
-    const UNDEFINED = 0;
+	/**
+	 * 
+	 */
+	const UNDEFINED = 0;
 
-    public static function getGlobals($config = "configs") {        
-        if (is_file("globals.json")){
-            $globalLoc = json_decode(file_get_contents("globals.json"), true);
+	public static function getGlobals($config = "configs") {        
+		if (is_file("globals.json")){
+			$globalLoc = json_decode(file_get_contents("globals.json"), true);
 
-            if (isset($globalLoc["globals"])){
-                $file = $globalLoc["globals"].".json";
+			if (isset($globalLoc["globals"])){
+				$file = $globalLoc["globals"].".json";
 
-                return json_decode(file_get_contents($file), true);
-            }
-        }
+				return json_decode(file_get_contents($file), true);
+			}
+		}
 
-        throw new Exception\UndefinedValueException("No configuration data set.", 0);
+		throw new Exception\UndefinedValueException("No configuration data set.", 0);
 
-    }
+	}
 }

tests/Core/Database/Abstraction/QueryBuilderTest.php

Indentation +18 added lines, -18 removed lines

@@ -11,27 +11,27 @@
 use EmmetBlue\Core\Database\Abstraction\QueryBuilder;
 
 /**
-  * class QueryBuilderTest.
-  *
-  * @author Samuel Adeshina <samueladeshina73@gmail.com>
-  *
-  * @since v0.0.1 27/05/2016 14:27
-  */
+ * class QueryBuilderTest.
+ *
+ * @author Samuel Adeshina <samueladeshina73@gmail.com>
+ *
+ * @since v0.0.1 27/05/2016 14:27
+ */
  class QueryBuilderTest extends \PHPUnit\Framework\TestCase
  {
-     public function testBuilderActuallyBuilding()
-     {
-         $queryBuilder = new QueryBuilder('INSERT INTO tbl_name');
-         $queryBuilder = $queryBuilder->build("VALUES ('tbl_col1', 'tbl_col2')");
+	 public function testBuilderActuallyBuilding()
+	 {
+		 $queryBuilder = new QueryBuilder('INSERT INTO tbl_name');
+		 $queryBuilder = $queryBuilder->build("VALUES ('tbl_col1', 'tbl_col2')");
 
-         $builtQuery = (string) $queryBuilder;
-         $expectedQuery = "INSERT INTO tbl_name VALUES ('tbl_col1', 'tbl_col2')";
+		 $builtQuery = (string) $queryBuilder;
+		 $expectedQuery = "INSERT INTO tbl_name VALUES ('tbl_col1', 'tbl_col2')";
 
-         $this->assertEquals($expectedQuery, $builtQuery);
-     }
+		 $this->assertEquals($expectedQuery, $builtQuery);
+	 }
 
-     public function testWrapStringFunctionBehavesStatically()
-     {
-         $built = QueryBuilder::wrapString('Name', "'");
-     }
+	 public function testWrapStringFunctionBehavesStatically()
+	 {
+		 $built = QueryBuilder::wrapString('Name', "'");
+	 }
  }