<?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\IDBConnection;

use \OCP\AppFramework\Db\Mapper;

use \OCA\OcSms\AppInfo\OcSmsApp;
use \OCA\OcSms\Lib\PhoneNumberFormatter;

class ConversationStateMapper extends Mapper {
	public function __construct (IDBConnection $db) {
		parent::__construct($db, 'ocsms_smsdatas');
	}

	public function getLast ($userId) {
		$qb = $this->db->getQueryBuilder();
		$qb->selectAlias($qb->createFunction('MAX(int_date)'), 'mx')
			->from('ocsms_conv_r_states')
			->where($qb->expr()->andX(
				$qb->expr()->eq('user_id', $qb->createNamedParameter($userId))
			));
		$result = $qb->execute();

		if ($row = $result->fetch()) {
			return $row["mx"];
		}

		return 0;
	}

	public function getLastForPhoneNumber ($userId, $phoneNumber) {
		$qb = $this->db->getQueryBuilder();
		$qb->selectAlias($qb->createFunction('MAX(int_date)'), 'mx')
			->from('ocsms_conv_r_states')
			->where($qb->expr()->andX(
				$qb->expr()->eq('user_id', $qb->createNamedParameter($userId)),
				$qb->expr()->eq('phone_number', $qb->createNamedParameter($phoneNumber))
			));
		$result = $qb->execute();

		if ($row = $result->fetch()) {
			return $row["mx"];
		}

		return 0;
	}

	public function setLast ($userId, $phoneNumber, $lastDate) {
		$this->db->beginTransaction();
		$qb = $this->db->getQueryBuilder();
		$qb->delete('ocsms_conv_r_states')
			->where($qb->expr()->andX(
				$qb->expr()->eq('user_id', $qb->createNamedParameter($userId)),
				$qb->expr()->eq('phone_number', $qb->createNamedParameter($phoneNumber))
			));
		$qb->execute();

		$qb = $this->db->getQueryBuilder();
		$qb->insert('ocsms_conv_r_states')
			->values(array(
				'user_id' => $qb->createNamedParameter($userId),
				'phone_number' => $qb->createNamedParameter($phoneNumber),
				'int_date' => $qb->createNamedParameter($lastDate)
			));
		$this->db->commit();
	}

	/*
	 * Migration steps
	 */

	public function migrate () {
		$qb = $this->db->getQueryBuilder();
		$qb->select('user_id', 'datakey', 'datavalue')
			->from('ocsms_user_datas')
			->where($qb->expr()->like('datakey', $qb->createNamedParameter('lastReadDate-%')));

		$result = $qb->execute();
		while($row = $result->fetch()) {
			$pn = preg_replace("#lastReadDate[-]#", "", $row["datakey"]);
			$this->setLast($row["user_id"], $pn, $row["datavalue"]);
		};

		$qb = $this->db->getQueryBuilder();
		$qb->delete('ocsms_user_datas')
			->where($qb->expr()->like('datakey', $qb->createNamedParameter('lastReadDate-%')));
		$qb->execute();
	}
}

?>