ua_appprobe.hpp

改进后的SIP SERVICE API

#ifndef _OCSIP_UAS_APPPROBS_H_
#define _OCSIP_UAS_APPPROBS_H_

#include <SIP_AppProbe.h>

class UA_Session;
class FF_SipMessageContainer;

#include <deque>
#include <string>
#include <stdexcept>
#include <memory>
#include <sip_message_api.h>

class UA_AppProbe : public SIP_AppProbe
{

public:
  UA_AppProbe (const char* P_name,
	       const char* P_sipUserInfo ,
	       const char* P_hostname  ,
	       const int P_port = 5060,
	       const SIP_TransportType P_trp = SIP_TRANSPORT_UDP,
	       const SIP_LogicalEntityType P_LE = SIP_LE_NULL );
  
  UA_AppProbe (const char* P_name, const char * P_copyName = "master");

  virtual ~UA_AppProbe();


  SIP_Event* buildRsp 
  (FF_SipMessageContainer & P_initialRequest,
   sip_msg_message_t      * P_Message_rsp);

  SIP_Event* buildReqInDialog 
  (FF_SipMessageContainer & P_initialRequest,
   sip_msg_message_t      * P_Message_rsp);

  SIP_Probe& getProbe () throw (std::exception);
  SIP_Service& getService() throw (std::exception);
  void setService(SIP_Service& P_service);

	  
  void initOrReinitSession(std::string & P_calledUri, 
                           SIP_Service * P_service,
                           UA_Session  * P_session_for_reinvite)
    throw ();

  void statelessRequest
  (
   std::string      & P_calledUri, 
   SIP_Service      * P_service,
   sip_msg_method_t   P_method,
   char             * P_extension_method,
   char             * P_CallID
   ) throw ();

  void closeSession(UA_Session& P_session);
  std::deque<UA_Session*> callQueue;
  const std::string& getCopyName() const;

protected:

  int reportStateChanged (SIP_ProbeState P_newState,
			  SIP_Cause P_cause ) throw ();

  virtual SIP_Status receive (SIP_Service& P_service,
                              SIP_Session& P_session,
                              SIP_Event&   P_message) throw ();

  SIP_Event* createMessage () throw ();
  
  int ProcessSubscriptionMessage(SIP_Service& P_service, 
				 SIP_Session& P_session, 
				 SIP_Event&   P_message);
  
  
  int sendSubscriptionMessage(SIP_Service& P_service, 
                              UA_Session&  P_session, 
                              SIP_Event&   P_message);  
  
  void destroyMessage (SIP_Event& P_message) throw ();

private:
  UA_AppProbe(const UA_AppProbe &right);

  UA_AppProbe & operator=(const UA_AppProbe &right);

  SIP_Service* service;
  const std::string copyName;
	  
};

#endif