friendica/src/Core/Conversation.php

<?php
/**
 * @file src/Core/Conversation.php
 */
namespace Friendica\Core;

use Friendica\Core\BaseObject;
use Friendica\Core\Item;

require_once 'boot.php';
require_once 'include/text.php';

/**
 * A list of threads
 *
 * We should think about making this a SPL Iterator
 */
class Conversation extends BaseObject
{
	private $threads = array();
	private $mode = null;
	private $writable = false;
	private $profile_owner = 0;
	private $preview = false;

	public function __construct($mode, $preview)
	{
		$this->set_mode($mode);
		$this->preview = $preview;
	}

	/**
	 * Set the mode we'll be displayed on
	 */
	private function set_mode($mode)
	{
		if ($this->get_mode() == $mode) {
			return;
		}

		$a = $this->get_app();

		switch ($mode) {
			case 'network':
			case 'notes':
				$this->profile_owner = local_user();
				$this->writable = true;
				break;
			case 'profile':
				$this->profile_owner = $a->profile['profile_uid'];
				$this->writable = can_write_wall($a, $this->profile_owner);
				break;
			case 'display':
				$this->profile_owner = $a->profile['uid'];
				$this->writable = can_write_wall($a, $this->profile_owner);
				break;
			default:
				logger('[ERROR] Conversation::set_mode : Unhandled mode ('. $mode .').', LOGGER_DEBUG);
				return false;
				break;
		}
		$this->mode = $mode;
	}

	/**
	 * Get mode
	 */
	public function get_mode()
	{
		return $this->mode;
	}

	/**
	 * Check if page is writable
	 */
	public function is_writable()
	{
		return $this->writable;
	}

	/**
	 * Check if page is a preview
	 */
	public function is_preview()
	{
		return $this->preview;
	}

	/**
	 * Get profile owner
	 */
	public function get_profile_owner()
	{
		return $this->profile_owner;
	}

	/**
	 * Add a thread to the conversation
	 *
	 * Returns:
	 *      _ The inserted item on success
	 *      _ false on failure
	 */
	public function add_thread($item)
	{
		$item_id = $item->getId();

		if (!$item_id) {
			logger('[ERROR] Conversation::add_thread : Item has no ID!!', LOGGER_DEBUG);
			return false;
		}

		if ($this->get_thread($item->getId())) {
			logger('[WARN] Conversation::add_thread : Thread already exists ('. $item->getId() .').', LOGGER_DEBUG);
			return false;
		}

		/*
		 * Only add will be displayed
		 */
		if ($item->getDataValue('network') === NETWORK_MAIL && local_user() != $item->getDataValue('uid')) {
			logger('[WARN] Conversation::add_thread : Thread is a mail ('. $item->getId() .').', LOGGER_DEBUG);
			return false;
		}

		if ($item->getDataValue('verb') === ACTIVITY_LIKE || $item->getDataValue('verb') === ACTIVITY_DISLIKE) {
			logger('[WARN] Conversation::add_thread : Thread is a (dis)like ('. $item->getId() .').', LOGGER_DEBUG);
			return false;
		}

		$item->setConversation($this);
		$this->threads[] = $item;

		return end($this->threads);
	}

	/**
	 * Get data in a form usable by a conversation template
	 *
	 * We should find a way to avoid using those arguments (at least most of them)
	 *
	 * Returns:
	 *      _ The data requested on success
	 *      _ false on failure
	 */
	public function get_template_data($conv_responses)
	{
		$a = get_app();
		$result = array();
		$i = 0;

		foreach ($this->threads as $item) {
			if ($item->getDataValue('network') === NETWORK_MAIL && local_user() != $item->getDataValue('uid')) {
				continue;
			}

			$item_data = $item->getTemplateData($conv_responses);

			if (!$item_data) {
				logger('[ERROR] Conversation::get_template_data : Failed to get item template data ('. $item->getId() .').', LOGGER_DEBUG);
				return false;
			}
			$result[] = $item_data;
		}

		return $result;
	}

	/**
	 * Get a thread based on its item id
	 *
	 * Returns:
	 *      _ The found item on success
	 *      _ false on failure
	 */
	private function get_thread($id)
	{
		foreach ($this->threads as $item) {
			if ($item->getId() == $id) {
				return $item;
			}
		}

		return false;
	}
}