<?php
class Brivium_ConversationLiveUpdate_Model_Conversation extends XFCP_Brivium_ConversationLiveUpdate_Model_Conversation{
public function brGetNewestConversationMessagesAfterDate($conversationId,$userId, $date, array $fetchOptions = array())
{
$limitOptions = $this->prepareLimitFetchOptions($fetchOptions);
if(empty($fetchOptions['order'])){
$fetchOptions['order']='DESC';
}
$result = $this->fetchAllKeyed($this->limitQueryResults(
'
SELECT message.*,
user.*, IF(user.username IS NULL, message.username, user.username) AS username,
user_profile.*
FROM xf_conversation_message AS message
LEFT JOIN xf_user AS user ON
(user.user_id = message.user_id)
LEFT JOIN xf_user_profile AS user_profile ON
(user_profile.user_id = message.user_id)
WHERE message.conversation_id = ?
AND user.user_id != ?
AND message.message_date > ?
ORDER BY message.message_date '.$fetchOptions['order'].'
', $limitOptions['limit'], $limitOptions['offset']
), 'message_id', array($conversationId,$userId, $date,));
if (!empty($result))
{
$this->getModelFromCache('XenForo_Model_Conversation')->markConversationAsRead($conversationId, $userId, XenForo_Application::$time);
}
return $result;
}
}
