OCA\Chat\OCH\Db\UserOnlineMapper

Complexity

Total Complexity

7

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	getAll()	0	3	1
A	deleteBySessionId()	0	4	1
A	updateLastOnline()	0	4	1
A	getOnlineUsers()	0	16	2
A	findByUser()	0	11	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 UserOnlineMapper extends Mapper {

	public function __construct(IDb $api) {
		parent::__construct($api, 'chat_och_users_online'); // tablename is news_feeds
	}

	public function getOnlineUsers(){
		$sql = <<<SQL
			SELECT
				`user`
			FROM
				`*PREFIX*chat_och_users_online`
SQL;
		$result = $this->execute($sql);

		$rows = array();

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

	public function getAll(){
		return $this->findEntities("SELECT * FROM " . $this->getTableName());
	}
	
	public function findByUser($user){
		$sql = <<<SQL
			SELECT
				*
			FROM `*PREFIX*chat_och_users_online`
			WHERE
				`user` = ?
SQL;
		$result = $this->findEntities($sql, array($user));
		return $result;
	}

	public function deleteBySessionId($sessionID){
		$sql = 'DELETE FROM `' . $this->getTableName() . '` WHERE `session_id` = ?';
		$this->execute($sql, array($sessionID));
	}
	
	public function updateLastOnline($sessionID, $timestamp){
		$sql = 'UPDATE `' . $this->getTableName() . '` SET `last_online` = ? WHERE `session_id` = ?';
		$this->execute($sql, array($timestamp, $sessionID));
	}
 
}