jacobemerick / web

utility/Request.class.inc.php

Doc Comments +3 added lines

@@ -34,6 +34,9 @@
 		return false;

 	}

 

+	/**
+	 * @param string $key
+	 */
 	static function getGet($key = null)

 	{

 		if($key)

Spacing +7 added lines, -7 removed lines

@@ -18,9 +18,9 @@ 
 

 	static function getServer($key = null)

 	{

-		if($key)

+		if ($key)

 		{

-			if(isset(self::$server[$key]))

+			if (isset(self::$server[$key]))

 				return self::$server[$key];

 			return false;

 		}

@@ -29,16 +29,16 @@ 
 

 	static function isAjax()

 	{

-		if(self::getServer(self::$AJAX_REQUEST))

+		if (self::getServer(self::$AJAX_REQUEST))

 			return true;

 		return false;

 	}

 

 	static function getGet($key = null)

 	{

-		if($key)

+		if ($key)

 		{

-			if(isset(self::$get[$key]))

+			if (isset(self::$get[$key]))

 				return self::$get[$key];

 			return false;

 		}

@@ -47,9 +47,9 @@ 
 

 	static function getPost($key = null)

 	{

-		if($key)

+		if ($key)

 		{

-			if(isset(self::$post[$key]))

+			if (isset(self::$post[$key]))

 				return self::$post[$key];

 			return false;

 		}

Braces +12 added lines, -8 removed lines

@@ -20,8 +20,9 @@ 
 	{

 		if($key)

 		{

-			if(isset(self::$server[$key]))

-				return self::$server[$key];

+			if(isset(self::$server[$key])) {

+							return self::$server[$key];

+			}

 			return false;

 		}

 		return self::$server;

@@ -29,8 +30,9 @@ 
 

 	static function isAjax()

 	{

-		if(self::getServer(self::$AJAX_REQUEST))

-			return true;

+		if(self::getServer(self::$AJAX_REQUEST)) {

+					return true;

+		}

 		return false;

 	}

 

@@ -38,8 +40,9 @@ 
 	{

 		if($key)

 		{

-			if(isset(self::$get[$key]))

-				return self::$get[$key];

+			if(isset(self::$get[$key])) {

+							return self::$get[$key];

+			}

 			return false;

 		}

 		return self::$get;

@@ -49,8 +52,9 @@ 
 	{

 		if($key)

 		{

-			if(isset(self::$post[$key]))

-				return self::$post[$key];

+			if(isset(self::$post[$key])) {

+							return self::$post[$key];

+			}

 			return false;

 		}

 		return self::$post;

utility/URLDecode.class.inc.php

Doc Comments +6 added lines

@@ -38,6 +38,9 @@ 
 		self::$array['pieces'] = (array) $uri_array;

 	}

 

+	/**
+	 * @return string
+	 */
 	static function getSite()

 	{

 		return self::$array['site'];

@@ -66,6 +69,9 @@ 
 		return substr($file, strrpos($file, '.') + 1);;

 	}

 

+	/**
+	 * @param integer $piece
+	 */
 	static function getPiece($piece = null)

 	{

 		if(!$piece)

Spacing +8 added lines, -8 removed lines

@@ -15,11 +15,11 @@ 
 	static private function form_url_array($host, $uri)

 	{

 		$uri = substr($uri, 1);

-		if(strpos($uri, '?'))

+		if (strpos($uri, '?'))

 			$uri = substr($uri, 0, strpos($uri, '?'));

 		$uri_array = explode('/', $uri);

 		

-		if(!Loader::isLive())

+		if (!Loader::isLive())

 			$host = substr($host, strpos($host, '.') + 1);

 		

 		self::$array['host'] = $host;

@@ -33,7 +33,7 @@ 
 		self::$array['base'] = 'http://' . (!Loader::isLive() ? 'dev.' : '') . $host . '/';

 		self::$array['uri'] = '/' . implode('/', $uri_array);

 		

-		if(end($uri_array) == '')

+		if (end($uri_array) == '')

 			$uri_array = array_slice($uri_array, 0, count($uri_array) - 1);

 		self::$array['pieces'] = (array) $uri_array;

 	}

@@ -61,21 +61,21 @@ 
 	static function getExtension()

 	{

 		$file = self::getPiece(-1);

-		if(substr($file, -1) == '/')

+		if (substr($file, -1) == '/')

 			return false;

-		return substr($file, strrpos($file, '.') + 1);;

+		return substr($file, strrpos($file, '.') + 1); ;

 	}

 

 	static function getPiece($piece = null)

 	{

-		if(!$piece)

+		if (!$piece)

 			return self::$array['pieces'];

 		

-		if($piece == -1)

+		if ($piece == -1)

 			return end(self::$array['pieces']);

 		

 		$piece = $piece - 1;

-		if(array_key_exists($piece, self::$array['pieces']))

+		if (array_key_exists($piece, self::$array['pieces']))

 			return self::$array['pieces'][$piece];

 		return;

 	}

Braces +21 added lines, -14 removed lines

@@ -15,12 +15,14 @@ 
 	static private function form_url_array($host, $uri)

 	{

 		$uri = substr($uri, 1);

-		if(strpos($uri, '?'))

-			$uri = substr($uri, 0, strpos($uri, '?'));

+		if(strpos($uri, '?')) {

+					$uri = substr($uri, 0, strpos($uri, '?'));

+		}

 		$uri_array = explode('/', $uri);

 		

-		if(!Loader::isLive())

-			$host = substr($host, strpos($host, '.') + 1);

+		if(!Loader::isLive()) {

+					$host = substr($host, strpos($host, '.') + 1);

+		}

 		

 		self::$array['host'] = $host;

 		

@@ -33,8 +35,9 @@ 
 		self::$array['base'] = 'http://' . (!Loader::isLive() ? 'dev.' : '') . $host . '/';

 		self::$array['uri'] = '/' . implode('/', $uri_array);

 		

-		if(end($uri_array) == '')

-			$uri_array = array_slice($uri_array, 0, count($uri_array) - 1);

+		if(end($uri_array) == '') {

+					$uri_array = array_slice($uri_array, 0, count($uri_array) - 1);

+		}

 		self::$array['pieces'] = (array) $uri_array;

 	}

 

@@ -61,22 +64,26 @@ 
 	static function getExtension()

 	{

 		$file = self::getPiece(-1);

-		if(substr($file, -1) == '/')

-			return false;

+		if(substr($file, -1) == '/') {

+					return false;

+		}

 		return substr($file, strrpos($file, '.') + 1);;

 	}

 

 	static function getPiece($piece = null)

 	{

-		if(!$piece)

-			return self::$array['pieces'];

+		if(!$piece) {

+					return self::$array['pieces'];

+		}

 		

-		if($piece == -1)

-			return end(self::$array['pieces']);

+		if($piece == -1) {

+					return end(self::$array['pieces']);

+		}

 		

 		$piece = $piece - 1;

-		if(array_key_exists($piece, self::$array['pieces']))

-			return self::$array['pieces'][$piece];

+		if(array_key_exists($piece, self::$array['pieces'])) {

+					return self::$array['pieces'][$piece];

+		}

 		return;

 	}

 

utility/Validate.class.inc.php

Doc Comments +5 added lines

@@ -72,6 +72,11 @@
 		return $matches[0] == $string;

 	}

 

+	/**
+	 * @param string $type
+	 * @param string $key
+	 * @param string $validation
+	 */
 	public static function checkRequest($type, $key, $validation, $strict = false)

 	{

 		switch($type)

Spacing +11 added lines, -11 removed lines

@@ -11,39 +11,39 @@ 
 

 	public static function isBoolean($value, $strict = false)

 	{

-		if($strict && ($value === true || $value === false))

+		if ($strict && ($value === true || $value === false))

 			return true;

-		if(!$strict && ((bool) $value === true || (bool) $value === false))

+		if (!$strict && ((bool) $value === true || (bool) $value === false))

 			return true;

 		return false;

 	}

 

 	public static function isDate($value)

 	{

-		if(strtotime($value) !== -1)

+		if (strtotime($value) !== -1)

 			return true;

-		if(date('y', $value) !== false)

+		if (date('y', $value) !== false)

 			return true;

 		return false;

 	}

 

 	public static function isInteger($value, $strict = false)

 	{

-		if($strict)

+		if ($strict)

 			return is_int($value);

 		return (int) $value == $value;

 	}

 

 	public static function isIP($value)

 	{

-		if(self::isInteger(ip2long($value)))

+		if (self::isInteger(ip2long($value)))

 			return true;

 		return false;

 	}

 

 	public static function isString($value, $strict = false)

 	{

-		if($strict)

+		if ($strict)

 			return is_string($value);

 		return (string) $value == $value;

 	}

@@ -67,14 +67,14 @@ 
 	private static function check_value($pattern, $string)

 	{

 		preg_match($pattern, $string, $matches);

-		if(empty($matches))

+		if (empty($matches))

 			return false;

 		return $matches[0] == $string;

 	}

 

 	public static function checkRequest($type, $key, $validation, $strict = false)

 	{

-		switch($type)

+		switch ($type)

 		{

 			case 'server':

 				$value = Request::getServer($key);

@@ -84,10 +84,10 @@ 
 			break;

 		}

 		

-		if($value == false)

+		if ($value == false)

 			return false;

 		

-		switch($validation)

+		switch ($validation)

 		{

 			case 'boolean':

 				return self::isBoolean($value, $strict);

Braces +27 added lines, -18 removed lines

@@ -11,40 +11,47 @@ 
 

 	public static function isBoolean($value, $strict = false)

 	{

-		if($strict && ($value === true || $value === false))

-			return true;

-		if(!$strict && ((bool) $value === true || (bool) $value === false))

-			return true;

+		if($strict && ($value === true || $value === false)) {

+					return true;

+		}

+		if(!$strict && ((bool) $value === true || (bool) $value === false)) {

+					return true;

+		}

 		return false;

 	}

 

 	public static function isDate($value)

 	{

-		if(strtotime($value) !== -1)

-			return true;

-		if(date('y', $value) !== false)

-			return true;

+		if(strtotime($value) !== -1) {

+					return true;

+		}

+		if(date('y', $value) !== false) {

+					return true;

+		}

 		return false;

 	}

 

 	public static function isInteger($value, $strict = false)

 	{

-		if($strict)

-			return is_int($value);

+		if($strict) {

+					return is_int($value);

+		}

 		return (int) $value == $value;

 	}

 

 	public static function isIP($value)

 	{

-		if(self::isInteger(ip2long($value)))

-			return true;

+		if(self::isInteger(ip2long($value))) {

+					return true;

+		}

 		return false;

 	}

 

 	public static function isString($value, $strict = false)

 	{

-		if($strict)

-			return is_string($value);

+		if($strict) {

+					return is_string($value);

+		}

 		return (string) $value == $value;

 	}

 

@@ -67,8 +74,9 @@ 
 	private static function check_value($pattern, $string)

 	{

 		preg_match($pattern, $string, $matches);

-		if(empty($matches))

-			return false;

+		if(empty($matches)) {

+					return false;

+		}

 		return $matches[0] == $string;

 	}

 

@@ -84,8 +92,9 @@ 
 			break;

 		}

 		

-		if($value == false)

-			return false;

+		if($value == false) {

+					return false;

+		}

 		

 		switch($validation)

 		{

bootstrap.php

Indentation +20 added lines, -20 removed lines

@@ -7,7 +7,7 @@ 
 
 $handle = @fopen($configuration_path, 'r');
 if ($handle === false) {
-    throw new RuntimeException("Could not load configuration");
+	throw new RuntimeException("Could not load configuration");
 }
 $configuration = fread($handle, filesize($configuration_path));
 fclose($handle);
@@ -15,34 +15,34 @@ 
 $configuration = json_decode($configuration);
 $last_json_error = json_last_error();
 if ($last_json_error !== JSON_ERROR_NONE) {
-    throw new RuntimeException("Could not parse configuration - JSON error detected");
+	throw new RuntimeException("Could not parse configuration - JSON error detected");
 }
 
 // configure the db connections holder
 $db_connections = new Aura\Sql\ConnectionLocator();
 $db_connections->setDefault(function () use ($configuration) {
-    $connection = $configuration->database->slave;
-    return new Aura\Sql\ExtendedPdo(
-        "mysql:host={$connection->host}",
-        $connection->user,
-        $connection->password
-    );
+	$connection = $configuration->database->slave;
+	return new Aura\Sql\ExtendedPdo(
+		"mysql:host={$connection->host}",
+		$connection->user,
+		$connection->password
+	);
 });
 $db_connections->setWrite('master', function () use ($configuration) {
-    $connection = $configuration->database->master;
-    return new Aura\Sql\ExtendedPdo(
-        "mysql:host={$connection->host}",
-        $connection->user,
-        $connection->password
-    );
+	$connection = $configuration->database->master;
+	return new Aura\Sql\ExtendedPdo(
+		"mysql:host={$connection->host}",
+		$connection->user,
+		$connection->password
+	);
 });
 $db_connections->setRead('slave', function () use ($configuration) {
-    $connection = $configuration->database->slave;
-    return new Aura\Sql\ExtendedPdo(
-        "mysql:host={$connection->host}",
-        $connection->user,
-        $connection->password
-    );
+	$connection = $configuration->database->slave;
+	return new Aura\Sql\ExtendedPdo(
+		"mysql:host={$connection->host}",
+		$connection->user,
+		$connection->password
+	);
 });
 
 // setup the service locator

Spacing +3 added lines, -3 removed lines

@@ -20,7 +20,7 @@ 
 
 // configure the db connections holder
 $db_connections = new Aura\Sql\ConnectionLocator();
-$db_connections->setDefault(function () use ($configuration) {
+$db_connections->setDefault(function() use ($configuration) {
     $connection = $configuration->database->slave;
     return new Aura\Sql\ExtendedPdo(
         "mysql:host={$connection->host}",
@@ -28,7 +28,7 @@ 
         $connection->password
     );
 });
-$db_connections->setWrite('master', function () use ($configuration) {
+$db_connections->setWrite('master', function() use ($configuration) {
     $connection = $configuration->database->master;
     return new Aura\Sql\ExtendedPdo(
         "mysql:host={$connection->host}",
@@ -36,7 +36,7 @@ 
         $connection->password
     );
 });
-$db_connections->setRead('slave', function () use ($configuration) {
+$db_connections->setRead('slave', function() use ($configuration) {
     $connection = $configuration->database->slave;
     return new Aura\Sql\ExtendedPdo(
         "mysql:host={$connection->host}",

collector/waterfall/WatercourseCollector.class.inc.php

Indentation +3 added lines, -3 removed lines

@@ -153,9 +153,9 @@
 		return self::run_query($query);

 	}

 

-    public static function getParentWatercourse($watercourse)

-    {

-    }

+	public static function getParentWatercourse($watercourse)

+	{

+	}

 

 	public static function getLogCountForWatercourse($watercourse)

 	{

controller/AJAXController.class.inc.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
 

 	protected function set_response($message, $type = 'internal')

 	{

-		switch($type)

+		switch ($type)

 		{

 			case 'internal' :

 				$this->response['internal'] = $message;

controller/Error404Controller.class.inc.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
 		Loader::load('collector', 'SiteCollector');

 		$site_result = SiteCollector::getSitesForMenu();

 		

-		foreach($site_result as $site)

+		foreach ($site_result as $site)

 		{

 			$site_array[] = array(

 				'url' => $site->url,

controller/SitemapController.class.inc.php

Spacing +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
 

 	protected function addURL($loc, $lastmod = false, $changefreq = 'monthly', $priority = .5)

 	{

-		if(!$lastmod)

+		if (!$lastmod)

 			$lastmod = $this->default_lastmod;

 		

 		$url = $this->xml->addChild('url');

Braces +3 added lines, -2 removed lines

@@ -22,8 +22,9 @@
 

 	protected function addURL($loc, $lastmod = false, $changefreq = 'monthly', $priority = .5)

 	{

-		if(!$lastmod)

-			$lastmod = $this->default_lastmod;

+		if(!$lastmod) {

+					$lastmod = $this->default_lastmod;

+		}

 		

 		$url = $this->xml->addChild('url');

 		

controller/ajax/SubmitCommentController.class.inc.php

Spacing +16 added lines, -16 removed lines

@@ -14,19 +14,19 @@ 
 

 	protected function set_data()

 	{

-		if(!Validate::checkRequest('post', 'name', 'name'))

+		if (!Validate::checkRequest('post', 'name', 'name'))

 			return $this->fail_response('You must include a valid name.');

-		if(!Validate::checkRequest('post', 'email', 'email'))

+		if (!Validate::checkRequest('post', 'email', 'email'))

 			return $this->fail_response('You must include a valid email.');

-		if(Request::getPost('website') && !Validate::checkRequest('post', 'website', 'url'))

+		if (Request::getPost('website') && !Validate::checkRequest('post', 'website', 'url'))

 			return $this->fail_response('Please include a valid website.');

-		if(!Validate::checkRequest('post', 'comment', 'string'))

+		if (!Validate::checkRequest('post', 'comment', 'string'))

 			return $this->fail_response('You must enter a comment.');

-		if(!Validate::checkRequest('post', 'save', 'boolean'))

+		if (!Validate::checkRequest('post', 'save', 'boolean'))

 			return $this->fail_response('You entered an invalid save request.');

-		if(!Validate::checkRequest('post', 'notify', 'boolean'))

+		if (!Validate::checkRequest('post', 'notify', 'boolean'))

 			return $this->fail_response('You entered an invalid notify request.');

-		if(Request::getPost('reply') && !Validate::checkRequest('post', 'reply', 'integer'))

+		if (Request::getPost('reply') && !Validate::checkRequest('post', 'reply', 'integer'))

 			return $this->fail_response('You entered an invalid reply value.');

 		

 		$referer_url = Request::getServer('HTTP_REFERER');

@@ -35,11 +35,11 @@ 
 		$url = array_pop($url);

 		$post = PostCollector::getPostByURI($url);

 		

-		if($post === null)

+		if ($post === null)

 			return $this->fail_response('There seems to be a problem with this page.', 'error');

 		

 		$commentpage_result = CommentCollector::getCommentPageByURL($post->path, 2);

-		if($commentpage_result === null)

+		if ($commentpage_result === null)

 		{

 			$query = "INSERT INTO `jpemeric_comment`.`comment_page` (`site_id`, `url`) VALUES ('%d', '%s')";

 			

@@ -56,7 +56,7 @@ 
 		$save = (Request::getPost('save') == 'true') ? 1 : 0;

 		

 		$commenter_result = CommentCollector::getCommenterByFields(Request::getPost('name'), Request::getPost('email'), Request::getPost('website'));

-		if($commenter_result === null)

+		if ($commenter_result === null)

 		{

 			$query = "INSERT INTO `jpemeric_comment`.`commenter` (`name`,`email`,`url`,`save`) VALUES ('%s','%s','%s','%s')";

 			

@@ -70,7 +70,7 @@ 
 		}

 		else

 		{

-			if($commenter_result->save !== $save)

+			if ($commenter_result->save !== $save)

 			{

 				$query = "UPDATE `jpemeric_comment`.`commenter` SET `save` = '%s' WHERE `id` = '%d'";

 				

@@ -81,7 +81,7 @@ 
 		}

 		

 		$comment_result = CommentCollector::getCommentByBody(Request::getPost('comment'));

-		if($comment_result === null)

+		if ($comment_result === null)

 		{

 			$query = "INSERT INTO `jpemeric_comment`.`comment` (`body`) VALUES ('%s')";

 			

@@ -112,9 +112,9 @@ 
 		

 		$notification_result = CommentCollector::getNotificationForPage($commentpage_id);

 		

-		foreach($notification_result as $notification_row)

+		foreach ($notification_result as $notification_row)

 		{

-			if($notification_row->email == $email)

+			if ($notification_row->email == $email)

 				continue;

 			

 			$email_recipient_array[$notification_row->email] = array(

@@ -123,7 +123,7 @@ 
 		}

 		

 		$message = "Hello!\nThere has been a new post on the post '{$post->title}' at Jacob Emerick's Blog. You have chosen to be notified of it - please reply to {$config->admin_email} if you do would like to be removed from these notifications.\n\nOn " . date('F j, Y g:i a') . ", " . Request::getPost('name') . " commented...\n" . Request::getPost('comment') . "\n\nVisit {$referer_url}#comments to see and reply to all the comments on this post.\nThank you!";

-		foreach($email_recipient_array as $email_recipient)

+		foreach ($email_recipient_array as $email_recipient)

 		{

 			$mail = new Mail();

 			$mail->setToAddress($email_recipient['email'], $email_recipient['name']);

@@ -132,7 +132,7 @@ 
 			$mail->send();

 		}

 		

-		if(Request::getPost('save') == true)

+		if (Request::getPost('save') == true)

 		{

 			/*

 			$cookie = new Cookie('jpe_commenter');

Braces +32 added lines, -24 removed lines

@@ -14,20 +14,27 @@ 
 

 	protected function set_data()

 	{

-		if(!Validate::checkRequest('post', 'name', 'name'))

-			return $this->fail_response('You must include a valid name.');

-		if(!Validate::checkRequest('post', 'email', 'email'))

-			return $this->fail_response('You must include a valid email.');

-		if(Request::getPost('website') && !Validate::checkRequest('post', 'website', 'url'))

-			return $this->fail_response('Please include a valid website.');

-		if(!Validate::checkRequest('post', 'comment', 'string'))

-			return $this->fail_response('You must enter a comment.');

-		if(!Validate::checkRequest('post', 'save', 'boolean'))

-			return $this->fail_response('You entered an invalid save request.');

-		if(!Validate::checkRequest('post', 'notify', 'boolean'))

-			return $this->fail_response('You entered an invalid notify request.');

-		if(Request::getPost('reply') && !Validate::checkRequest('post', 'reply', 'integer'))

-			return $this->fail_response('You entered an invalid reply value.');

+		if(!Validate::checkRequest('post', 'name', 'name')) {

+					return $this->fail_response('You must include a valid name.');

+		}

+		if(!Validate::checkRequest('post', 'email', 'email')) {

+					return $this->fail_response('You must include a valid email.');

+		}

+		if(Request::getPost('website') && !Validate::checkRequest('post', 'website', 'url')) {

+					return $this->fail_response('Please include a valid website.');

+		}

+		if(!Validate::checkRequest('post', 'comment', 'string')) {

+					return $this->fail_response('You must enter a comment.');

+		}

+		if(!Validate::checkRequest('post', 'save', 'boolean')) {

+					return $this->fail_response('You entered an invalid save request.');

+		}

+		if(!Validate::checkRequest('post', 'notify', 'boolean')) {

+					return $this->fail_response('You entered an invalid notify request.');

+		}

+		if(Request::getPost('reply') && !Validate::checkRequest('post', 'reply', 'integer')) {

+					return $this->fail_response('You entered an invalid reply value.');

+		}

 		

 		$referer_url = Request::getServer('HTTP_REFERER');

 		$url = explode('/', $referer_url);

@@ -35,8 +42,9 @@ 
 		$url = array_pop($url);

 		$post = PostCollector::getPostByURI($url);

 		

-		if($post === null)

-			return $this->fail_response('There seems to be a problem with this page.', 'error');

+		if($post === null) {

+					return $this->fail_response('There seems to be a problem with this page.', 'error');

+		}

 		

 		$commentpage_result = CommentCollector::getCommentPageByURL($post->path, 2);

 		if($commentpage_result === null)

@@ -49,9 +57,9 @@ 
 			$query = sprintf($query, $site_id, $url);

 			Database::execute($query);

 			$commentpage_id = Database::lastInsertID();

+		} else {

+					$commentpage_id = $commentpage_result->id;

 		}

-		else

-			$commentpage_id = $commentpage_result->id;

 		

 		$save = (Request::getPost('save') == 'true') ? 1 : 0;

 		

@@ -67,8 +75,7 @@ 
 			$query = sprintf($query, $name, $email, $website, $save);

 			Database::execute($query);

 			$commenter_id = Database::lastInsertID();

-		}

-		else

+		} else

 		{

 			if($commenter_result->save !== $save)

 			{

@@ -90,9 +97,9 @@ 
 			$query = sprintf($query, $body);

 			Database::execute($query);

 			$comment_id = Database::lastInsertID();

+		} else {

+					$comment_id = $comment_result->id;

 		}

-		else

-			$comment_id = $comment_result->id;

 		

 		$query = "INSERT INTO `jpemeric_comment`.`comment_meta` (`commenter_id`,`comment_id`,`reply`,`notify`,`commentpage_id`,`date`,`display`) VALUES ('%d','%d','%d','%d','%d','%s','%d')";

 		

@@ -114,8 +121,9 @@ 
 		

 		foreach($notification_result as $notification_row)

 		{

-			if($notification_row->email == $email)

-				continue;

+			if($notification_row->email == $email) {

+							continue;

+			}

 			

 			$email_recipient_array[$notification_row->email] = array(

 				'email' => $notification_row->email,