sm.h

/*
  Copyright (c) 2008-2009 by Jakob Schroeter <js@camaya.net>
  This file is part of the glooxd library. http://camaya.net/glooxd

  This software is distributed under a license. The full license
  agreement can be found in the file LICENSE in this distribution.
  This software may not be copied, modified, sold or distributed
  other than expressed in the named license agreement.

  This software is distributed without any warranty.
*/


#ifndef SM_H__
#define SM_H__

#include "componentbase.h"
#include "glooxd.h"

#include <gloox/gloox.h>
#include <gloox/jid.h>
#include <gloox/mutex.h>

#include <list>
#include <map>
#include <string>

namespace gloox
{
  class LogSink;
}

namespace glooxd
{

  class Client;
  class Plugin;
  class RosterProvider;

  class GLOOXD_API SM : public ComponentBase
  {
    public:
      SM( Router& router, ConfigManager& cm, const gloox::LogSink& logInstance,
          RosterProvider* rp, bool threading = false,
          const gloox::JID& name = gloox::JID( "sm." + GLOOXD_DOMAIN ) );

      virtual ~SM();

      void run();

      bool createSession( gloox::JID& jid, const std::string& id );

      bool removeSession( const std::string& id );

      void addPlugin( Plugin* p )
      {
        if( p )
          m_plugins.push_back( p );
      }

      void dispatchPresence( const gloox::Tag* pres );

      bool dispatchMessage( const gloox::Tag* msg );

      // reimplemented from TagHandler
      virtual void handleIncomingTag( gloox::Tag* tag );

      // reimplemented from TagHandler
      virtual void handleOutgoingTag( gloox::Tag* ) {}

      // reimplemented from ConfigHandler
      virtual void handleDomainAdded( const std::string& domain );

      // reimplemented from ConfigHandler
      virtual void handleDomainRemoved( const std::string& domain );

      // reimplemented from ConfigHandler
      virtual void handleShutdown();

    private:
      struct Session
      {
        std::string id;
        gloox::Tag* presence;
        int priority;
      };

      typedef std::map<std::string, Session> SessionList;

      typedef std::list<Plugin*> PluginList;

      void handleTag( gloox::Tag* tag );

      const SessionList findSessions( const gloox::JID& jid );

      SessionList m_sessions;
      PluginList m_plugins;
      RosterProvider* m_rosterProvider;

      gloox::util::Mutex m_sessionMutex;

      gloox::TagList m_queue;
      glooxd::util::Semaphore m_queueSemaphore;
      gloox::util::Mutex m_queueMutex;

      volatile bool m_threading;

  };

}

#endif // SM_H__