OCA\Chat\OCH\Db\MessageMapper

Complexity

Total Complexity

4

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	0

Importance

Changes	2
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
B	getMessagesByConvId()	0	30	2
A	getMessagesByConvIdLimit()	0	23	1

<?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 \OCP\AppFramework\Db\Mapper;
use \OCP\IDb;

class MessageMapper extends Mapper{

	public function __construct(IDb $api) {
		parent::__construct($api, 'chat_och_messages'); // tablename is news_feeds
	}
 
	public function getMessagesByConvId($convId, $user, $startpoint=0){
		$sql = <<<SQL
			SELECT
				*
			FROM
				*PREFIX*chat_och_messages
			WHERE
				`convid` = ?
			AND
				`timestamp` > (
					SELECT
						`joined`
					FROM
						*PREFIX*chat_och_users_in_conversation
					WHERE
						`user` = ?
					AND `conversation_id` = ?
				)
SQL;
		if($startpoint !== 0){
			$sql = $sql . <<<SQL
			AND
				`timestamp` > ?
SQL;
			return $this->findEntities($sql, array($convId, $user, $convId, $startpoint));
		} else {
			return $this->findEntities($sql, array($convId, $user, $convId));
		}

	}

	public function getMessagesByConvIdLimit($convId, $user, $limit){
		$sql = <<<SQL
			SELECT
				*
			FROM
				*PREFIX*chat_och_messages
			WHERE
				`convid` = ?
			AND
				`timestamp` > (
					SELECT
						`joined`
					FROM
						*PREFIX*chat_och_users_in_conversation
					WHERE
						`user` = ?
					AND `conversation_id` = ?
				)
			ORDER BY timestamp DESC
			LIMIT ?,?
SQL;
		return $this->findEntities($sql, array($convId, $user, $convId, $limit[0], $limit[1]));
	}

}