linepresencemonitor.cpp

基于sipfoundy 公司开发的sipx协议API

// 
// Copyright (C) 2005 SIPfoundry Inc.
// Licensed by SIPfoundry under the LGPL license.
// 
// Copyright (C) 2005 Pingtel Corp.
// Licensed to SIPfoundry under a Contributor Agreement.
// 
// $$
//////////////////////////////////////////////////////////////////////////////

// SYSTEM INCLUDES

// APPLICATION INCLUDES
#include <os/OsSysLog.h>
#include <utl/UtlSListIterator.h>
#include <net/SipRefreshManager.h>
#include <net/SipSubscribeClient.h>
#include <net/XmlRpcRequest.h>
#include <net/SipPresenceEvent.h>
#include <net/NetMd5Codec.h>
#include <cp/LinePresenceMonitor.h>

// EXTERNAL FUNCTIONS
// EXTERNAL VARIABLES
// CONSTANTS
#define DEFAULT_REFRESH_INTERVAL      300
#define CONFIG_ETC_DIR                SIPX_CONFDIR

// STATIC VARIABLE INITIALIZATIONS

/* //////////////////////////// PUBLIC //////////////////////////////////// */

/* ============================ CREATORS ================================== */

// Constructor
LinePresenceMonitor::LinePresenceMonitor(int userAgentPort,
                                         UtlString& domainName,
                                         UtlString& groupName,
                                         bool local,
                                         Url& remoteServer,
                                         Url& presenceServer)
   : mLock(OsBSem::Q_PRIORITY, OsBSem::FULL)
{
   // Bind the SIP user agent to a port and start it up
   mpUserAgent = new SipUserAgent(userAgentPort, userAgentPort);
   mpUserAgent->start();
   
   mGroupName = groupName;
   mLocal = local;
   mDomainName = domainName;

   if (mLocal)
   {
      // Create a local Sip Dialog Monitor
      mpDialogMonitor = new SipDialogMonitor(mpUserAgent,
                                             domainName,
                                             userAgentPort,
                                             DEFAULT_REFRESH_INTERVAL,
                                             false);
      
      // Add itself to the dialog monitor for state change notification
      mpDialogMonitor->addStateChangeNotifier("Line_Presence_Monitor", this);

      // Verify that a presence server uri has been specified
      presenceServer.getHostAddress(mPresenceServer);
      if (mPresenceServer != NULL)
      {
         presenceServer.getIdentity(mPresenceServer);
      }
   }
   else
   {
      mRemoteServer = remoteServer;
   }

   // Create the SIP Subscribe Client for subscribing both dialog event and presence event
   mpRefreshMgr = new SipRefreshManager(*mpUserAgent, mDialogManager);
   mpRefreshMgr->start();
   
   mpSipSubscribeClient = new SipSubscribeClient(*mpUserAgent, mDialogManager, *mpRefreshMgr);
   mpSipSubscribeClient->start();
   
   UtlString localAddress;
   OsSocket::getHostIp(&localAddress);
   
   Url url(localAddress);
   url.setHostPort(userAgentPort);
   url.includeAngleBrackets();
   mContact = url.toString();    
}


// Destructor
LinePresenceMonitor::~LinePresenceMonitor()
{
   if (mpRefreshMgr)
   {
      delete mpRefreshMgr;
   }
   
   if (mpSipSubscribeClient)
   {
      mpSipSubscribeClient->endAllSubscriptions();
      delete mpSipSubscribeClient;
   }

   // Shut down the sipUserAgent
   mpUserAgent->shutdown(FALSE);

   while(!mpUserAgent->isShutdownDone())
   {
      ;
   }

   delete mpUserAgent;
   
   if (mpDialogMonitor)
   {
      // Remove itself to the dialog monitor
      mpDialogMonitor->removeStateChangeNotifier("Line_Presence_Monitor");

      delete mpDialogMonitor;
   }
   
   if (!mDialogSubscribeList.isEmpty())
   {
      mDialogSubscribeList.destroyAll();
   }

   if (!mPresenceSubscribeList.isEmpty())
   {
      mPresenceSubscribeList.destroyAll();
   }
}

/* ============================ MANIPULATORS ============================== */


// Assignment operator
LinePresenceMonitor&
LinePresenceMonitor::operator=(const LinePresenceMonitor& rhs)
{
   if (this == &rhs)            // handle the assignment to self case
      return *this;
}

/* ============================ ACCESSORS ================================= */
bool LinePresenceMonitor::setStatus(const Url& aor, const Status value)
{
   bool result = false;
   
   mLock.acquire();
   
   // We can only use userId to identify the line
   UtlString contact;
   aor.getUserId(contact);
   
   OsSysLog::add(FAC_SIP, PRI_DEBUG, "LinePresenceMonitor::setStatus set the value %d for %s",
                 value, contact.data());
   
   // Set the dialog status
   UtlVoidPtr* container = dynamic_cast <UtlVoidPtr *> (mDialogSubscribeList.findValue(&contact));
   if (container != NULL)
   {
      LinePresenceBase* line = (LinePresenceBase *) container->getValue();
      // Set the state value in LinePresenceBase
      switch (value)
      {
      case StateChangeNotifier::ON_HOOK:
         if (!line->getState(LinePresenceBase::ON_HOOK))
         {
            line->updateState(LinePresenceBase::ON_HOOK, true);
            result = true;
         }
         
         break;
         
      case StateChangeNotifier::OFF_HOOK:
         if (line->getState(LinePresenceBase::ON_HOOK))
         {
            line->updateState(LinePresenceBase::ON_HOOK, false);
            result = true;
         }
         
         break;

      case StateChangeNotifier::RINGING:
         if (line->getState(LinePresenceBase::ON_HOOK))
         {
            line->updateState(LinePresenceBase::ON_HOOK, false);
            result = true;
         }
         
         break;         
      }
   }

   // Set the presence status      
   container = dynamic_cast <UtlVoidPtr *> (mPresenceSubscribeList.findValue(&contact));
   if (container != NULL)
   {
      LinePresenceBase* line = (LinePresenceBase *) container->getValue();
      // Set the state value in LinePresenceBase
      switch (value)
      {
      case StateChangeNotifier::SIGN_IN:
         if (!line->getState(LinePresenceBase::SIGNED_IN))
         {
            line->updateState(LinePresenceBase::SIGNED_IN, true);
            result = true;
         }
         
         break;
         
      case StateChangeNotifier::SIGN_OUT:
         if (line->getState(LinePresenceBase::SIGNED_IN))
         {
            line->updateState(LinePresenceBase::SIGNED_IN, false);
            result = false;
         }
         
         break;
      }
   }

   mLock.release();
   
   return result;
}

OsStatus LinePresenceMonitor::subscribeDialog(LinePresenceBase* line)
{
   OsStatus result = OS_FAILED;
   mLock.acquire();
   Url* lineUrl = line->getUri();
   
   OsSysLog::add(FAC_SIP, PRI_DEBUG, "LinePresenceMonitor::subscribeDialog subscribing dialog for line %s",
                 lineUrl->toString().data()); 

   if (mLocal)
   {
      if(mpDialogMonitor->addExtension(mGroupName, *lineUrl))
      {
         result = OS_SUCCESS;
      }
      else
      {
         result = OS_FAILED;
      }
   }
   else
   {
      // Use XML-RPC to communicate with the sipX dialog monitor
      XmlRpcRequest request(mRemoteServer, "addExtension");
      
      request.addParam(&mGroupName);
      UtlString contact = lineUrl->toString();
      request.addParam(&contact);

      XmlRpcResponse response;
      if (request.execute(response))
      {
         result = OS_SUCCESS;
      }
      else
      {
         result = OS_FAILED;
      }      
   }
   
   // Insert the line to the Subscribe Map
   UtlString contactId;
   lineUrl->getUserId(contactId);
   mDialogSubscribeList.insertKeyAndValue(new UtlString(contactId),
                                          new UtlVoidPtr(line));

   mLock.release();
   
   return result;
}

OsStatus LinePresenceMonitor::unsubscribeDialog(LinePresenceBase* line)
{
   OsStatus result = OS_FAILED;
   mLock.acquire();
   Url* lineUrl = line->getUri();
   
   if (lineUrl == NULL)
   {
      return OS_FAILED;
   }

   OsSysLog::add(FAC_SIP, PRI_DEBUG, "LinePresenceMonitor::unsubscribeDialog unsubscribing dialog for line %s",
                 lineUrl->toString().data());
                  
   if (mLocal)
   {
      if (mpDialogMonitor->removeExtension(mGroupName, *lineUrl))