OwncloudContactsOfficial/lib/controller/addressbookcontroller.php

<?php
/**
 * @author Thomas Tanghus
 * @copyright 2013-2014 Thomas Tanghus (thomas@tanghus.net)
 * This file is licensed under the Affero General Public License version 3 or
 * later.
 * See the COPYING-README file.
 */

namespace OCA\Contacts\Controller;

use OCA\Contacts\App,
	OCA\Contacts\JSONResponse,
	OCA\Contacts\Utils\JSONSerializer,
	OCA\Contacts\Controller,
	OCP\AppFramework\Http,
	OCP\AppFramework\IApi,
	OCP\IRequest;

/**
 * Controller class For Address Books
 */
class AddressBookController extends Controller {

	/**
	 * @var \OCP\AppFramework\IApi
	 */
	protected $api;

	public function __construct($appName, IRequest $request, App $app, IApi $api) {
		parent::__construct($appName, $request, $app);
		$this->api = $api;
	}

	/**
	 * @NoAdminRequired
	 * @NoCSRFRequired
	 */
	public function userAddressBooks() {
		$addressBooks = $this->app->getAddressBooksForUser();
		$result = array();
		$lastModified = 0;

		foreach($addressBooks as $addressBook) {

			$data = $addressBook->getMetaData();
			$result[] = $data;

			if (!is_null($data['lastmodified'])) {
				$lastModified = max($lastModified, $data['lastmodified']);
			}

		}

		// To avoid invalid cache deletion time is saved
		/*$lastModified = max(
			$lastModified,
			\OCP\Config::getUserValue($this->api->getUserId(), 'contacts', 'last_address_book_deleted', 0)
		);*/

		$response = new JSONResponse(array(
			'addressbooks' => $result,
		));

		/** FIXME: Caching is currently disabled
		if($lastModified > 0) {
			$response->setLastModified(\DateTime::createFromFormat('U', $lastModified) ?: null);
			$response->setETag(md5($lastModified));
		}
		*/

		return $response;
	}

	/**
	 * @NoAdminRequired
	 * @NoCSRFRequired
	 */
	public function getAddressBook() {
		$params = $this->request->urlParams;

		$addressBook = $this->app->getAddressBook($params['backend'], $params['addressBookId']);
		$lastModified = $addressBook->lastModified();
		$response = new JSONResponse();
		$response->setData(array('data' => $addressBook->getMetaData()));

		if (!is_null($lastModified)) {
			$response->addHeader('Cache-Control', 'private, must-revalidate');
			$response->setLastModified(\DateTime::createFromFormat('U', $lastModified) ?: null);
			$etag = md5($lastModified);
			$response->setETag($etag);
		}

		return $response;
	}

	/**
	 * @NoAdminRequired
	 * @NoCSRFRequired
	 */
	public function getContacts() {
		$params = $this->request->urlParams;

		$addressBook = $this->app->getAddressBook($params['backend'], $params['addressBookId']);
		$lastModified = $addressBook->lastModified();
		$etag = null;
		$response = new JSONResponse();

		if (!is_null($lastModified)) {
			//$response->addHeader('Cache-Control', 'private, must-revalidate');
			$response->setLastModified(\DateTime::createFromFormat('U', $lastModified) ?: null);
			$etag = md5($lastModified);
			$response->setETag($etag);
		}

		//$response->debug('comparing: "' . $etag . '" to ' . $this->request->getHeader('If-None-Match'));
		if (!is_null($etag)
			&& $this->request->getHeader('If-None-Match') === '"'.$etag.'"')
		{
			return $response->setStatus(Http::STATUS_NOT_MODIFIED);
		} else {
			switch ($this->request->method) {
				case 'OPTIONS':
					$options = array('GET', 'HEAD', 'OPTIONS');
					if ($addressBook->hasPermission(\OCP\PERMISSION_DELETE)
						&& $addressBook->getBackend()->hasAddressBookMethodFor(\OCP\PERMISSION_DELETE))
					{
						$options[] = 'DELETE';
					}
					if ($addressBook->hasPermission(\OCP\PERMISSION_UPDATE)
						&& $addressBook->getBackend()->hasAddressBookMethodFor(\OCP\PERMISSION_UPDATE))
					{
						$options[] = 'POST';
					}
					$response->addHeader('Allow' , implode(',', $options));
					return $response;
				case 'HEAD':
					return $response;
				case 'GET':
					$contacts = array();

					foreach ($addressBook->getChildren() as $i => $contact) {
						$result = JSONSerializer::serializeContact($contact);
						if ($result !== null) {
							$contacts[] = $result;
						}
					}

					return $response->setData(array('contacts' => $contacts));
			}
		}
	}

	/**
	 * @NoAdminRequired
	 */
	public function addAddressBook() {
		$params = $this->request->urlParams;

		$response = new JSONResponse();

		$backend = $this->app->getBackend($params['backend']);

		if (!$backend->hasAddressBookMethodFor(\OCP\PERMISSION_CREATE)) {
			throw new \Exception('This backend does not support adding address books', 501);
		}

		try {
			$id = $backend->createAddressBook($this->request->post);
		} catch(\Exception $e) {
			return $response->bailOut($e->getMessage());
		}

		if ($id === false) {
			return $response->bailOut(App::$l10n->t('Error creating address book'));
		}

		return $response->setStatus('201')->setParams($backend->getAddressBook($id));
	}

	/**
	 * @NoAdminRequired
	 */
	public function updateAddressBook() {
		$params = $this->request->urlParams;

		$response = new JSONResponse();

		$addressBook = $this->app->getAddressBook($params['backend'], $params['addressBookId']);
		$addressBook->update($this->request['properties']);

		return $response->setParams($addressBook->getMetaData());
	}

	/**
	 * @NoAdminRequired
	 */
	public function deleteAddressBook() {
		$params = $this->request->urlParams;

		$response = new JSONResponse();

		$backend = $this->app->getBackend($params['backend']);

		if (!$backend->hasAddressBookMethodFor(\OCP\PERMISSION_DELETE)) {
			throw new \Exception(App::$l10n->t(
				'The "%s" backend does not support deleting address books', array($backend->name)
			), 501);
		}

		$addressBookInfo = $backend->getAddressBook($params['addressBookId']);

		if (!$addressBookInfo['permissions'] & \OCP\PERMISSION_DELETE) {
			throw new \Exception(App::$l10n->t(
				'You do not have permissions to delete the "%s" address book',
				array($addressBookInfo['displayname'])
			), 403);
		}

		if (!$backend->deleteAddressBook($params['addressBookId'])) {
			throw new \Exception(App::$l10n->t(
				'Error deleting address book'
			), 500);
		}

		\OCP\Config::setUserValue($this->api->getUserId(), 'contacts', 'last_address_book_deleted', time());
		return $response;
	}

	/**
	 * @NoAdminRequired
	 */
	public function activateAddressBook() {
		$params = $this->request->urlParams;

		$response = new JSONResponse();

		$addressBook = $this->app->getAddressBook($params['backend'], $params['addressBookId']);

		$addressBook->setActive($this->request->post['state']);

		return $response;
	}

	/**
	 * @NoAdminRequired
	 */
	public function addChild() {
		$params = $this->request->urlParams;

		$response = new JSONResponse();

		$addressBook = $this->app->getAddressBook($params['backend'], $params['addressBookId']);

		try {
			$id = $addressBook->addChild();
		} catch(\Exception $e) {
			return $response->bailOut($e->getMessage());
		}

		if ($id === false) {
			return $response->bailOut(App::$l10n->t('Error creating contact.'));
		}

		$contact = $addressBook->getChild($id);

		$serialized = JSONSerializer::serializeContact($contact);

		if (is_null($serialized)) {
			throw new \Exception(App::$l10n->t(
				'Error creating contact'
			));
		}

		$response->setStatus('201')->setETag($contact->getETag());
		$response->addHeader('Location',
			\OCP\Util::linkToRoute(
				'contacts_contact_get',
				array(
					'backend' => $params['backend'],
					'addressBookId' => $params['addressBookId'],
					'contactId' => $id
				)
			)
		);
		return $response->setParams($serialized);
	}

	/**
	 * @NoAdminRequired
	 */
	public function deleteChild() {
		$params = $this->request->urlParams;

		$response = new JSONResponse();

		$addressBook = $this->app->getAddressBook($params['backend'], $params['addressBookId']);

		$result = $addressBook->deleteChild($params['contactId']);

		if ($result === false) {
			throw new \Exception(App::$l10n->t(
				'Error deleting contact'
			), 500);
		}

		return $response->setStatus('204');
	}

	/**
	 * @NoAdminRequired
	 */
	public function deleteChildren() {
		$params = $this->request->urlParams;

		$response = new JSONResponse();

		$addressBook = $this->app->getAddressBook($params['backend'], $params['addressBookId']);
		$contacts = $this->request->post['contacts'];

		$result = $addressBook->deleteChildren($contacts);

		return $response->setParams(array('result' => $result));
	}

	/**
	 * @NoAdminRequired
	 */
	public function moveChild() {
		$params = $this->request->urlParams;
		$targetInfo = $this->request->post['target'];

		$response = new JSONResponse();

		// TODO: Check if the backend supports move (is 'local' or 'shared') and use that operation instead.
		// If so, set status 204 and don't return the serialized contact.
		$fromAddressBook = $this->app->getAddressBook($params['backend'], $params['addressBookId']);
		$targetAddressBook = $this->app->getAddressBook($targetInfo['backend'], $targetInfo['id']);
		$contact = $fromAddressBook->getChild($params['contactId']);

		if (!$contact) {
			throw new \Exception(App::$l10n->t(
				'Error retrieving contact'
			), 500);
		}

		$contactId = $targetAddressBook->addChild($contact);

		// Retrieve the contact again to be sure it's in sync
		$contact = $targetAddressBook->getChild($contactId);

		if (!$contact) {
			throw new \Exception(App::$l10n->t(
				'Error saving contact'
			), 500);
		}

		if (!$fromAddressBook->deleteChild($params['contactId'])) {
			// Don't bail out because we have to return the contact
			return $response->debug(App::$l10n->t('Error removing contact from other address book.'));
		}

		$serialized = JSONSerializer::serializeContact($contact);

		if (is_null($serialized)) {
			throw new \Exception(App::$l10n->t(
				'Error getting moved contact'
			));
		}

		return $response->setParams($serialized);
	}

}