<?php
/**
 * Nextcloud - Phone Sync
 *
 * This file is licensed under the Affero General Public License version 3 or
 * later. See the COPYING file.
 *
 * @author Loic Blot <loic.blot@unix-experience.fr>
 * @copyright Loic Blot 2014-2017
 */

namespace OCA\OcSms\Db;

use OCP\AppFramework\Db\MultipleObjectsReturnedException;
use \OCP\IDBConnection;

use \OCP\AppFramework\Db\Mapper;
use \OCP\AppFramework\Db\DoesNotExistException;

class ConfigMapper extends Mapper {

	/**
	 * @var string ownCloud user id
	 */
	private $user;

	/**
	 * @var \OCP\Security\ICrypto
	 */
	private $crypto;

	public function __construct (IDBConnection $db, $user, $crypto){
		parent::__construct($db, 'ocsms_config');
		$this->user = $user;
		$this->crypto = $crypto;
	}

	/**
	 * @param $key
	 * @param $value
     */
	public function set ($key, $value){
		$value = $this->crypto->encrypt($value);
		if($this->hasKey($key, $value)){
			$sql = "UPDATE `*PREFIX*ocsms_config` SET `value` = ? WHERE `user` = ? AND `key` = ?";
			$this->execute($sql, array($value, $this->user, $key));
		} else {
			$sql = "INSERT INTO `*PREFIX*ocsms_config` (`user`,`key`,`value`) VALUES (?,?,?);";
			$this->execute($sql, array($this->user, $key, $value));
		}
	}

	public function hasKey ($key, $value){
		try {
			$sql = "SELECT `key` FROM `*PREFIX*ocsms_config` WHERE `key` = ? AND `user` = ?";
			$this->findEntity($sql, array($key, $this->user));

			return true;
		} catch (DoesNotExistException $e){
			return false;
		} catch (MultipleObjectsReturnedException $e) {
			return true;
		}
	}

	public function getKey ($key) {
		try {
			$qb = $this->db->getQueryBuilder();
			$qb->select('value')
				->from('ocsms_config')
				->where(
					$qb->expr()->andX(
						$qb->expr()->eq('key', $qb->createNamedParameter($key)),
						$qb->expr()->eq('user', $qb->createNamedParameter($this->user))
					)
				);
			$result = $qb->execute();
			if ($row = $result->fetch()) {
				return $this->crypto->decrypt($row["value"]);
			}
			return false;
		} catch (DoesNotExistException $e){
			return false;
		} catch (\Exception $e) {
			return false;
		}
	}

	/**
	* Helpers for different config options
	*/
	public function getCountry () { return $this->getKey("country"); }
	public function getMessageLimit () {
		$limit = $this->getKey("message_limit");
		// Default limit is 500 messages
		if ($limit === false) {
			$limit = 500;
		}
		return $limit;
	}

	public function getNotificationState () {
		$st = $this->getKey("notification_state");
		// Default state is 1/enabled
		if ($st === false) {
			$st = 1;
		}
		return $st;
	}

	public function getContactOrder() {
		$order = $this->getKey("contact_order");
		if ($order === false) {
			$order = "lastmsg";
		}
		return $order;
	}

	public function getContactOrderReverse() {
		$rev = $this->getKey("contact_order_reverse");
		if ($rev === false) {
			$rev = "true";
		}
		return $rev;
	}
};

?>