/*********************************************************************/
/*                                                                   */
/*                     AgentService Framework                        */
/*                       www.agentservice.it                         */
/*                                                                   */
/* Copyright (C) 2007 l.i.d.o. - DIST, University of Genoa, Italy    */
/* GNU Lesser General Public License                                 */
/*                                                                   */
/* This library is free software; you can redistribute it and/or     */
/* modify it under the terms of the GNU Lesser General Public        */
/* License as published by the Free Software Foundation,             */
/* version 2.1 of the License.                                       */
/*                                                                   */
/* This library is distributed in the hope that it will be useful,   */
/* but WITHOUT ANY WARRANTY; without even the implied warranty of    */
/* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU */
/* Lesser General Public License for more details.                   */
/*                                                                   */
/* You should have received a copy of the GNU Lesser General Public  */
/* License along with this library; if not, write to the             */
/* Free Software Foundation, Inc., 59 Temple Place - Suite 330,      */
/* Boston, MA  02111-1307, USA.                                      */
/*                                                                   */
/*********************************************************************/

using System;
using AgentService.Platform.AMS;

namespace AgentService.Platform.Modules.Default
{
    /// <summary>
    /// This class holds the messaging aspects linked to an agents:
    ///     - the message queue.
    ///     - the events raised by the ImprovedMessageModule.
    /// </summary>
    public class QueueItemManager
    {
        /// <summary>
        /// The queue mapping
        /// </summary>
        public MessageQueueMapping QueueMapping
        {
            set;
            get;
        }

        /// <summary>
        /// Event raised when a new message is incoming.
        /// </summary>
        public event IncomingMessage OnIncomingMessage;

        /// <summary>
        /// Event raised when a conversation system message is incoming.
        /// </summary>
        public event IncomingConversation OnIncomingConversation;

        /// <summary>
        /// Event raised when a conversation message is incoming.
        /// </summary>
        public event IncomingConversationMessage OnIncomingConversationMessage;

        /// <summary>
        /// Constructs a new QueueItemManager object.
        /// </summary>
        /// <param name="queue">The message queue</param>
        public QueueItemManager(MessageQueueMapping queue)
        {
            this.QueueMapping = queue;
        }

        /// <summary>
        /// Raises an IncomingMessage event.
        /// </summary>
        public void RaiseIncomingMessageEvent(AID aid)
        {
            IncomingMessage temp = this.OnIncomingMessage;

            if (temp != null)
            {
                temp(this, new IncomingMessageEventArgs(aid));
            }
        }

        /// <summary>
        /// Raises an RaiseIncomingConversation event.
        /// </summary>
        public void RaiseIncomingConversationEvent(AID aid)
        {
            IncomingConversation temp = this.OnIncomingConversation;

            if (temp != null)
            {
                temp(this, new IncomingConversationEventArgs(aid));
            }
        }

        /// <summary>
        /// RaiseIncomingConversationMessage event
        /// </summary>
        /// <param name="convId">The conversation ID</param>
        public void RaiseIncomingConversationMessageEvent(string convId, AID aid)
        {
            IncomingConversationMessage temp = this.OnIncomingConversationMessage;

            if (temp != null)
            {
                temp(this, new IncomingConversationMessageEventArgs(convId,aid));
            }
        }
    }
}