dialogeventpublisher.cpp

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

   
                  remoteIdentity.getIdentity(identity);
                  remoteIdentity.getDisplayName(displayName);
                  pDialog->setRemoteIdentity(identity, displayName);
   
                  sipDialog.getLocalContact(localTarget);
                  pDialog->setLocalTarget(localTarget.toString());
   
                  sipDialog.getRemoteContact(remoteTarget);
                  pDialog->setRemoteTarget(remoteTarget.toString());
   
                  pDialog->setDuration(OsDateTime::getSecsSinceEpoch());
   
                  pThisCall->insertDialog(pDialog);
               }
                   
               pThisCall->buildBody();

               // Publish the content to the subscribe server
               if (!mpSipPublishContentMgr->publish(entity.data(), DIALOG_EVENT_TYPE, DIALOG_EVENT_TYPE, 1, (HttpBody**)&pThisCall, 1, numOldContents, oldContent))
               {
                  pThisCall->getBytes(&dialogEvent, &length);
                  OsSysLog::add(FAC_SIP, PRI_ERR, "DialogEventPublisher:: Call connected - DialogEvent %s\n was not successfully published to the subscribe server",
                                dialogEvent.data());
               }
            }

            break;
            
         case PtEvent::CONNECTION_DISCONNECTED:
         case PtEvent::CONNECTION_FAILED:
            OsSysLog::add(FAC_SIP, PRI_DEBUG, "DialogEventPublisher::handleMessage CONNECTION_DISCONNECTED, CONNECTION_FAILED");         
            if (!localConnection) 
            {
               if (mpCallManager->getSipDialog(callId, address, sipDialog) !=
                   OS_SUCCESS)
               {
                  OsSysLog::add(FAC_ACD, PRI_ERR,
                                "DialogEventPublisher::handleMessage - CONNECTION_DISCONNECTED - Failed call to getSipDialog(%s, %s)",
                                callId.data(), address.data());
                  // Fill sipDialog with empty information as if we had gotten an empty SipDialog - then go on 
                  // and try to remove the event by just knowing the callId that we got passed in.
                  UtlString emptyUri("");
                  sipDialog.setRemoteRequestUri(emptyUri);
               }
#ifdef DEBUGGING            
               sipDialog.toString(sipDialogContent);
               OsSysLog::add(FAC_SIP, PRI_DEBUG, "DialogEventPublisher::handleMessage sipDialog = %s", 
                             sipDialogContent.data());
#endif            
               sipDialog.getRemoteRequestUri(remoteRequestUri);
               getEntity(remoteRequestUri, entity);               

               OsSysLog::add(FAC_SIP, PRI_DEBUG, "DialogEventPublisher::handleMessage Call dropped: '%s' address '%s' with entity '%s'",
                             callId.data(), address.data(), entity.data());
            
               if (entity.isNull())
               {
                  // Under some circumstances (example failed transfer) the getSipDialog call above will return an empty SipDialog
                  // with an empty requestUrl and callId. We need to remember th callId that was passed in as a Tao message parameter
                  // and try to associate the callId with an entity.
                  OsSysLog::add(FAC_SIP, PRI_WARNING, "DialogEventPublisher::handleMessage Call dropped: callId '%s' address '%s' without requestUrl", 
                                callId.data(), address.data());
                  // We have no request Url - try to get entity from callId
                  failCallId = callId;
                  if (!findEntryByCallId(callId, entity))
                  {
                     break;
                  }
               }
              
               requestUrl = Url(entity);
               requestUrl.getIdentity(entity);     
                         
               // Get the new callId because it might be changed
               sipDialog.getCallId(callId);

               sipDialog.getLocalField(localIdentity);
               localIdentity.getFieldParameter("tag", localTag);
               sipDialog.getRemoteField(remoteIdentity);
               remoteIdentity.getFieldParameter("tag", remoteTag);
         
               // If the SipDialog is empty we can't use the empty callId. Reassign the remembered callId.
               if (callId.isNull() && !failCallId.isNull())
               {
                  OsSysLog::add(FAC_SIP, PRI_WARNING, "DialogEventPublisher::handleMessage callId is empty, using fail callId '%s'", 
                                failCallId.data());
                  callId = failCallId;
               }

               // Remove the call from the pool and clean up the call
               OsSysLog::add(FAC_SIP, PRI_DEBUG, "Trying to find entity '%s'", entity.data());
               pThisCall = (SipDialogEvent *) mCalls.findValue(&entity);
               if (pThisCall)
               {
                  // Use the work-around for XCL-98 in case that we can't get tags from 
                  // the SipDialog object
                  if (localTag.isNull())
                  {
                     pDialog = pThisCall->getDialogByCallId(callId);
                  }
                  else
                  {
                     pDialog = pThisCall->getDialog(callId);
                  }
                  if (pDialog)
                  {
                     pDialog->setState(STATE_TERMINATED, NULL, NULL);
                   
                     pThisCall->buildBody();

                     // Publish the content to the subscribe server
                     if (!mpSipPublishContentMgr->publish(entity.data(), DIALOG_EVENT_TYPE, DIALOG_EVENT_TYPE, 1, (HttpBody**)&pThisCall, 1, numOldContents, oldContent))
                     {
                        pThisCall->getBytes(&dialogEvent, &length);
                        OsSysLog::add(FAC_SIP, PRI_ERR, "DialogEventPublisher:: Call dropped - DialogEvent %s\n was not successfully published to the subscribe server",
                                      dialogEvent.data());
                     }
                       
                     // Remove the dialog from the dialog event package
                     pDialog = pThisCall->removeDialog(pDialog);
                     delete pDialog;
                  }
                  
                  if (pThisCall->isEmpty())
                  {
                     // Unpublisher the content from the subscribe server
                     if (!mpSipPublishContentMgr->unpublish(entity.data(), DIALOG_EVENT_TYPE, DIALOG_EVENT_TYPE, 1, numOldContents, oldContent))
                     {
                        pThisCall->getBytes(&dialogEvent, &length);
                        OsSysLog::add(FAC_SIP, PRI_ERR, "DialogEventPublisher:: Call dropped - DialogEvent %s\n was not successfully unpublished to the subscribe server",
                                      dialogEvent.data());
                     }
                     
                     UtlContainable *foundValue;
                     mCalls.removeKeyAndValue(pEntity, foundValue);
                     if (foundValue)
                     {
                        OsSysLog::add(FAC_SIP, PRI_DEBUG, "DialogEventPublisher:: remove DialogEvent object %p from the list",
                                      pThisCall);
                        pThisCall = (SipDialogEvent *) foundValue;
                        delete pThisCall;
                        delete pEntity;
                     }
                  }
               }
               else
               {
                  OsSysLog::add(FAC_SIP, PRI_ERR, "DialogEventPublisher::handleMessage Call dropped - no entity %s founded in the active call list",
                                entity.data());
               }
            }

            break;
      }
   }
   return(TRUE);
}


/* ============================ ACCESSORS ================================= */

/* ============================ INQUIRY =================================== */

/* //////////////////////////// PROTECTED ///////////////////////////////// */


void DialogEventPublisher::dumpTaoMessageArgs(unsigned char eventId, TaoString& args) 
{
   OsSysLog::add(FAC_SIP, PRI_DEBUG, "===>Message type: %d args:\n", eventId) ;
        
   int argc = args.getCnt();
   for(int argIndex = 0; argIndex < argc; argIndex++)
   {
      OsSysLog::add(FAC_SIP, PRI_DEBUG, "\targ[%d]=\"%s\"", argIndex, args[argIndex]);
   }
}

void DialogEventPublisher::getEntity(UtlString& requestUri, UtlString& entity)
{
   entity = "";
   // Contruct entity from requestUri and local contact information
   if (mpCallManager)
   {
      SipUserAgent *tempUA = mpCallManager->getUserAgent();
      if (tempUA)
      {
         int port;
         UtlString localAddress;
         UtlString userId;
         
         OsSysLog::add(FAC_SIP, PRI_DEBUG, "DialogEventPublisher::getEntity requestUri '%s'", requestUri.data());
         
         Url tempRequestUri(requestUri);
         tempRequestUri.getUserId(userId);
         OsSysLog::add(FAC_SIP, PRI_DEBUG, "DialogEventPublisher::getEntity userId '%s'", userId.data());  
         
         if (!userId.isNull())
         {
            tempUA->getLocalAddress(&localAddress, &port);
         
            Url entityUrl(localAddress);
            entityUrl.setHostPort(port);
            entityUrl.setUserId(userId.data());
         
            entityUrl.toString(entity);
            OsSysLog::add(FAC_SIP, PRI_DEBUG, "DialogEventPublisher::getEntity entity '%s'", entity.data());         
         }
      }
      else
      {
         OsSysLog::add(FAC_SIP, PRI_WARNING, "DialogEventPublisher::getEntity UserAgent not found");      
      }
   }
   else
   {
      OsSysLog::add(FAC_SIP, PRI_WARNING, "DialogEventPublisher::getEntity CallManager not found");
   }
}

bool DialogEventPublisher::findEntryByCallId(UtlString& callId, UtlString& entity)
{
   bool bRet = false;
   UtlHashMapIterator iterator(mCalls);
   UtlString* pKey = NULL;

   while ((pKey = dynamic_cast<UtlString *>(iterator())))
   {
      OsSysLog::add(FAC_SIP, PRI_DEBUG, "DialogEventPublisher::findEntryByCallId callId '%s', key '%s'", callId.data(), pKey->data());
            
      SipDialogEvent* pEvent;         
      pEvent = dynamic_cast<SipDialogEvent *>(iterator.value());      
 
      Dialog* pDialog;
      
      if (pEvent)
      {
         pDialog = pEvent->getDialogByCallId(callId);
         OsSysLog::add(FAC_SIP, PRI_DEBUG, "DialogEventPublisher::findEntryByCallId After getDialog, result %p", pDialog);
         if (pDialog)
         {
            bRet = true;
            entity = pKey->data();
            break;
         }     
      }
      else
      {
         OsSysLog::add(FAC_SIP, PRI_WARNING, "DialogEventPublisher::findEntryByCallId pEvent == NULL");            
      }
   }
   return bRet;
}


/* //////////////////////////// PRIVATE /////////////////////////////////// */

/* ============================ TESTING =================================== */

/* ============================ FUNCTIONS ================================= */