OCA\Chat\OCH\Db\UserMapper

Complexity

Total Complexity

10

Size/Duplication

Total Lines	118
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	findAll()	0	4	1
A	findSessionsByConversation()	0	20	1
A	findByUser()	0	12	1
A	findConvsIdByUser()	0	14	2
A	findUsersInConv()	0	14	2
B	insertUnique()	0	37	2

<?php
/**
 * Copyright (c) 2014, Tobia De Koninck hey--at--ledfan.be
 * This file is licensed under the AGPL version 3 or later.
 * See the COPYING file.
 */

namespace OCA\Chat\OCH\Db;

use Doctrine\DBAL\Sharding\SQLAzure\SQLAzureFederationsSynchronizer;
use \OCP\AppFramework\Db\Mapper;
use \OCP\IDb;
use \OCP\AppFramework\Db\Entity;
use \OCP\AppFramework\Db\DoesNotExistException;

class UserMapper extends Mapper {
	
	private $userOnlineTable = '*PREFIX*chat_och_users_online';

The property $userOnlineTable is not used and could be removed.

	public function __construct(IDb $api) {
		parent::__construct($api, 'chat_och_users_in_conversation');
		$this->table = '*PREFIX*chat_och_users_in_conversation';
	}

	public function findSessionsByConversation($conversationId){
		$sql = <<<SQL
			SELECT
				$this->table.user,
				$this->userOnlineTable.session_id,
				$this->table.conversation_id,
				$this->table.joined,
				$this->userOnlineTable.id
			FROM
				$this->table
			INNER JOIN
				$this->userOnlineTable
			ON
				$this->table.user = $this->userOnlineTable.user
			AND
				$this->table.conversation_id = ?
SQL;
		$result = $this->findEntities($sql, array($conversationId));
		return $result;
	}

	public function findByUser($user){
		$sql = <<<SQL
			SELECT
				*
			FROM
				$this->table
			WHERE
				`user` = ?
SQL;
		$result = $this->findEntities($sql, array($user));
		return $result;
	}
	
	 public function findConvsIdByUser($user){
		$sql = 'SELECT conversation_id FROM `' . $this->getTableName() . '` ' .
				'WHERE `user` = ? ';

		$result = $this->execute($sql, array($user));

		$ids = array();
		while($row = $result->fetch()){
			array_push($ids, $row['conversation_id']);
		}

		$ids = array_unique($ids);
		return $ids;
	}
		

	public function findUsersInConv($id){
		$sql = 'SELECT `user` FROM `' . $this->getTableName() . '` ' .
				'WHERE `conversation_id` = ? ';

		$result = $this->execute($sql, array($id));

		$users = array();
		while($row = $result->fetch()){
			array_push($users, $row['user']);
		}

		$users = array_unique($users);
		return $users;
	}

	public function insertUnique(Entity $entity){
		// First check $entity is already in DB
		$sql = <<<SQL
			SELECT
				`user`
			FROM
				`*PREFIX*chat_och_users_in_conversation`
			WHERE
				`user` = ?
			AND
				`conversation_id` = ?
SQL;
		try {
			$result = $this->findOneQuery($sql, array($entity->getUser(), $entity->getConversationId()));

$result is not used, you could remove the assignment.

			// The user already joined the conv -> nothing to do
		} catch (\Exception $exception) {
			// The user isn't in this conversation -> add it
			$sql = <<<SQL
			INSERT
			INTO `*PREFIX*chat_och_users_in_conversation`
			(
				`user`,
				`conversation_id`,
				`joined`
			) VALUES (
				?,
				?,
				?
			)
SQL;
			$this->execute($sql, array(
				$entity->getUser(),
				$entity->getConversationId(),
				$entity->getJoined()
			));
		}
	}

	public function findAll(){
		$sql = 'SELECT * FROM `' . $this->getTableName() . '`';
		return $this->findEntities($sql, array());
	}

}