#include <TuIM.hxx>
Detailed Description
Member Typedef Documentation
typedef std::vector<Buddy>::iterator resip::TuIM::BuddyIterator [private] |
typedef std::list<Page>::iterator resip::TuIM::PageIterator [private] |
typedef std::list<StateAgent>::iterator resip::TuIM::StateAgentIterator [private] |
typedef std::list<Subscriber>::iterator resip::TuIM::SubscriberIterator [private] |
Constructor & Destructor Documentation
| TuIM::TuIM | ( | SipStack * | stack, |
| const Uri & | aor, | ||
| const Uri & | contact, | ||
| Callback * | callback, | ||
| const int | registrationTimeSeconds = 1*60*60, |
||
| const int | subscriptionTimeSeconds = 10*60 |
||
| ) |
Definition at line 62 of file TuIM.cxx.
References resip::Data::Empty, resip::Uri::getAor(), resip::Random::getRandomHex(), mAor, mCallback, mContact, mPidf, mStack, resip::Pidf::setEntity(), resip::Pidf::setSimpleId(), and resip::Pidf::setSimpleStatus().
: mCallback(callback), mStack(stack), mAor(aor), mContact(contact), mPidf( new Pidf ), mRegistrationDialog(NameAddr(contact)), mNextTimeToRegister(0), mRegistrationPassword( Data::Empty ), mLastAuthCSeq(0), mRegistrationTimeSeconds(registrationTimeSeconds), mSubscriptionTimeSeconds(subscriptionTimeSeconds), mDefaultProtocol( UNKNOWN_TRANSPORT ) { assert( mStack ); assert(mCallback); assert(mPidf); mPidf->setSimpleId( Random::getRandomHex(4) ); mPidf->setEntity(mAor); mPidf->setSimpleStatus( true, Data::Empty, mContact.getAor() ); }
Member Function Documentation
Definition at line 1266 of file TuIM.cxx.
References resip::Data::Empty, resip::TuIM::Buddy::group, mBuddies, mContact, resip::TuIM::Buddy::online, resip::TuIM::Buddy::presDialog, resip::TuIM::Buddy::status, subscribeBuddy(), and resip::TuIM::Buddy::uri.
Referenced by myMain(), processStdin(), and processSubscribeResponse().
{
Buddy buddy;
buddy.uri = uri;
buddy.online = false;
buddy.status = Data::Empty;
buddy.group = group;
buddy.presDialog = new DeprecatedDialog( NameAddr(mContact) );
assert( buddy.presDialog );
subscribeBuddy( buddy );
mBuddies.push_back( buddy );
}
| void TuIM::addStateAgent | ( | const Uri & | uri | ) |
Definition at line 1432 of file TuIM.cxx.
References resip::TuIM::StateAgent::dialog, mContact, mStateAgents, sendPublish(), and resip::TuIM::StateAgent::uri.
Referenced by myMain().
{
StateAgent sa;
sa.dialog = new DeprecatedDialog( NameAddr(mContact) );
sa.uri = uri;
mStateAgents.push_back( sa );
sendPublish( sa );
}
| void TuIM::authorizeSubscription | ( | const Data & | user | ) |
| const Data TuIM::getBuddyGroup | ( | const int | index | ) |
Definition at line 1221 of file TuIM.cxx.
References getNumBuddies(), and mBuddies.
{
assert( index >= 0 );
assert( index < getNumBuddies() );
return mBuddies[index].group;
}
| bool TuIM::getBuddyStatus | ( | const int | index, |
| Data * | status = NULL |
||
| ) |
Definition at line 1231 of file TuIM.cxx.
References getNumBuddies(), and mBuddies.
Referenced by displayPres().
{
assert( index >= 0 );
assert( index < getNumBuddies() );
if (status)
{
*status = mBuddies[index].status;
}
bool online = mBuddies[index].online;
return online;
}
| const Uri TuIM::getBuddyUri | ( | const int | index | ) |
Definition at line 1211 of file TuIM.cxx.
References getNumBuddies(), and mBuddies.
Referenced by displayPres().
{
assert( index >= 0 );
assert( index < getNumBuddies() );
return mBuddies[index].uri;
}
| int TuIM::getNumBuddies | ( | ) | const |
Definition at line 1204 of file TuIM.cxx.
References mBuddies.
Referenced by displayPres(), getBuddyGroup(), getBuddyStatus(), and getBuddyUri().
{
return int(mBuddies.size());
}
| bool TuIM::haveCerts | ( | bool | sign, |
| const Data & | encryptFor | ||
| ) |
Definition at line 92 of file TuIM.cxx.
References resip::Data::empty(), resip::Uri::getAor(), resip::SipStack::getSecurity(), resip::BaseSecurity::hasUserCert(), resip::BaseSecurity::hasUserPrivateKey(), mAor, and mStack.
Referenced by processStdin().
{
/* assert(0); */
#if defined( USE_SSL )
Security* sec = mStack->getSecurity();
assert(sec);
if ( sign )
{
if ( !sec->hasUserPrivateKey(mAor.getAor()) )
{
return false;
}
}
if ( !encryptFor.empty() )
{
if ( !sec->hasUserCert( encryptFor ) )
{
return false;
}
}
#else
if ( (!encryptFor.empty()) || (sign) )
{
return false;
}
#endif
return true;
}
| void TuIM::process | ( | ) |
Definition at line 1102 of file TuIM.cxx.
References DebugLog, resip::Timer::getRandomFutureTimeMs(), resip::Timer::getTimeMs(), resip::DeprecatedDialog::isCreated(), resip::DeprecatedDialog::makeRegister(), resip::DeprecatedDialog::makeSubscribe(), mBuddies, mNextTimeToRegister, resip::TuIM::Buddy::mNextTimeToSubscribe, mRegistrationDialog, mRegistrationTimeSeconds, mStack, mSubscriptionTimeSeconds, resip::TuIM::Buddy::presDialog, processRequest(), processResponse(), resip::SipStack::receive(), resip::SipStack::send(), setOutbound(), and subscribeBuddy().
Referenced by myMain().
{
assert( mStack );
UInt64 now = Timer::getTimeMs();
// check if register needs refresh
if ( now > mNextTimeToRegister )
{
if ( mRegistrationDialog.isCreated() )
{
auto_ptr<SipMessage> msg( mRegistrationDialog.makeRegister() );
msg->header(h_Expires).value() = mRegistrationTimeSeconds;
setOutbound( *msg );
mStack->send( *msg );
}
mNextTimeToRegister = Timer::getRandomFutureTimeMs( mRegistrationTimeSeconds*1000 );
}
// check if any subscribes need refresh
for ( BuddyIterator i=mBuddies.begin(); i != mBuddies.end(); i++)
{
if ( now > i->mNextTimeToSubscribe )
{
Buddy& buddy = *i;
buddy.mNextTimeToSubscribe
= Timer::getRandomFutureTimeMs( mSubscriptionTimeSeconds*1000 );
assert( buddy.presDialog );
if ( buddy.presDialog->isCreated() )
{
auto_ptr<SipMessage> msg( buddy.presDialog->makeSubscribe() );
msg->header(h_Event).value() = Data("presence");;
msg->header(h_Accepts).push_back( Mime( "application","pidf+xml") );
msg->header(h_Expires).value() = mSubscriptionTimeSeconds;
setOutbound( *msg );
mStack->send( *msg );
}
else
{
// person was not available last time - try to subscribe now
subscribeBuddy( buddy );
}
}
}
// TODO - go and clean out any subscrption to us that have expired
// check for any messages from the sip stack
SipMessage* msg( mStack->receive() );
if ( msg )
{
DebugLog ( << "got message: " << *msg);
if ( msg->isResponse() )
{
processResponse( msg );
}
if ( msg->isRequest() )
{
processRequest( msg );
}
delete msg; msg=0;
}
}
| void TuIM::processMessageRequest | ( | SipMessage * | msg | ) | [private] |
Definition at line 568 of file TuIM.cxx.
References resip::BaseSecurity::checkSignature(), DebugLog, resip::BaseSecurity::decrypt(), resip::Uri::getAor(), resip::Uri::getAorNoPort(), resip::Contents::getBodyData(), resip::SipMessage::getContents(), resip::RequestLine::getMethod(), resip::SipStack::getSecurity(), resip::Contents::getType(), resip::SipMessage::header(), InfoLog, resip::Helper::makeResponse(), mAor, mCallback, mContact, mStack, resip::MultipartMixedContents::parts(), resip::TuIM::Callback::receivedPage(), resip::TuIM::Callback::receivePageFailed(), resip::SipStack::send(), resip::Mime::subType(), resip::PlainContents::text(), resip::CpimContents::text(), resip::Mime::type(), resip::RequestLine::uri(), and resip::NameAddr::uri().
Referenced by processRequest().
{
assert( msg );
assert( msg->header(h_RequestLine).getMethod() == MESSAGE );
NameAddr contact;
contact.uri() = mContact;
SipMessage* response = Helper::makeResponse(*msg, 200, contact, "OK");
mStack->send( *response );
delete response; response=0;
Contents* contents = msg->getContents();
if ( !contents )
{
InfoLog(<< "Received Message message with no contents" );
// .kw. NO: delete msg; msg=0; // our caller owns msg
return;
}
Mime mime = contents->getType();
DebugLog ( << "got body of type " << mime.type() << "/" << mime.subType() );
Data signedBy;
SignatureStatus sigStat = SignatureNone;
bool encrypted=false;
#if defined( USE_SSL )
Uri from = msg->header(h_From).uri();
signedBy = from.getAorNoPort();
InfoLog ( << "assuming signedBy is " << signedBy );
MultipartSignedContents* mBody = dynamic_cast<MultipartSignedContents*>(contents);
if ( mBody )
{
Security* sec = mStack->getSecurity();
assert(sec);
contents = sec->checkSignature( mBody, &signedBy, &sigStat );
//ErrLog("Signed by " << signedBy << " stat = " << sigStat );
if ( !contents )
{
Uri from = msg->header(h_From).uri();
InfoLog( << "Some problem decoding multipart/signed message");
mCallback->receivePageFailed( from );
return;
}
}
Pkcs7SignedContents* sBody = dynamic_cast<Pkcs7SignedContents*>(contents);
if ( sBody )
{
assert( sBody );
Security* sec = mStack->getSecurity();
assert(sec);
contents = sec->decrypt( mAor.getAor(), sBody );
if ( !contents )
{
Uri from = msg->header(h_From).uri();
InfoLog( << "Some problem decoding signed SMIME message");
mCallback->receivePageFailed( from );
return;
}
encrypted=true;
}
Pkcs7Contents* eBody = dynamic_cast<Pkcs7Contents*>(contents);
if ( eBody )
{
assert( eBody );
Security* sec = mStack->getSecurity();
assert(sec);
contents = sec->decrypt( mAor.getAor(), eBody );
if ( !contents )
{
Uri from = msg->header(h_From).uri();
InfoLog( << "Some problem decoding SMIME message");
mCallback->receivePageFailed( from );
return;
}
encrypted=true;
}
#endif
if ( contents )
{
PlainContents* plain = dynamic_cast<PlainContents*>(contents);
if ( plain )
{
assert( plain );
const Data& text = plain->text();
DebugLog ( << "got message from with text of <" << text << ">" );
Uri from = msg->header(h_From).uri();
DebugLog ( << "got message from " << from );
assert( mCallback );
mCallback->receivedPage( text, from, signedBy, sigStat, encrypted );
return;
}
CpimContents* cpim = dynamic_cast<CpimContents*>(contents);
if ( cpim )
{
assert( cpim );
const Data& text = cpim->text();
DebugLog ( << "got CPIM message from with text of <" << text << ">" );
// !cj! TODO - should get from out of CPIM message
Uri from = msg->header(h_From).uri();
DebugLog ( << "got message from " << from );
assert( mCallback );
mCallback->receivedPage( text, from, signedBy, sigStat, encrypted );
return;
}
MultipartMixedContents* mixed = dynamic_cast<MultipartMixedContents*>(contents);
if ( mixed )
{
InfoLog( << "Got a multipart mixed" );
contents = NULL;
MultipartMixedContents::Parts& parts = mixed->parts();
for( MultipartMixedContents::Parts::const_iterator i = parts.begin();
i != parts.end();
++i)
{
Contents* c = *i;
assert( c );
InfoLog ( << "mixed has a " << c->getType() );
if ( c->getType() == Mime("text","plain") )
{
InfoLog ( << "mixed has sipfrag " << c->getType() );
PlainContents* plainBody = dynamic_cast<PlainContents*>(c);
if ( plainBody )
{
assert( plainBody );
const Data& text = plainBody->text();
DebugLog ( << "got message from with text of <" << text << ">" );
Uri from = msg->header(h_From).uri();
DebugLog ( << "got message from " << from );
assert( mCallback );
mCallback->receivedPage( text, from, signedBy, sigStat, encrypted );
return;
}
// !cj! TODO - should deal with CPIM too
}
}
return;
}
#if 1 // !cj! TODO remove
OctetContents* octets = dynamic_cast<OctetContents*>(contents);
if (octets)
{
assert( contents );
const Data& text = octets->getBodyData();
DebugLog ( << "got message from with text of <" << text << ">" );
Uri from = msg->header(h_From).uri();
DebugLog ( << "got message from " << from );
assert( mCallback );
mCallback->receivedPage( text, from, signedBy, sigStat, encrypted );
return;
}
#endif
// deal with it if no one else has
{
InfoLog ( << "Can not handle type " << contents->getType() );
Uri from = msg->header(h_From).uri();
mCallback->receivePageFailed( from );
return;
}
}
}
| void TuIM::processNotifyRequest | ( | SipMessage * | msg | ) | [private] |
Definition at line 500 of file TuIM.cxx.
References DebugLog, resip::Data::Empty, resip::Uri::getAor(), resip::SipMessage::getContents(), resip::RequestLine::getMethod(), resip::Contents::getType(), resip::SipMessage::header(), InfoLog, resip::Helper::makeResponse(), mBuddies, mCallback, mStack, resip::TuIM::Callback::presenceUpdate(), processSipFrag(), resip::SipStack::send(), resip::Mime::subType(), resip::Mime::type(), and resip::RequestLine::uri().
Referenced by processRequest().
{
assert( mCallback );
assert( msg->header(h_RequestLine).getMethod() == NOTIFY );
processSipFrag( msg );
auto_ptr<SipMessage> response( Helper::makeResponse( *msg, 200 ));
mStack->send( *response );
Uri from = msg->header(h_From).uri();
DebugLog ( << "got notify from " << from );
Contents* contents = msg->getContents();
if ( !contents )
{
InfoLog(<< "Received NOTIFY message event with no contents" );
mCallback->presenceUpdate( from, true, Data::Empty );
return;
}
Mime mime = contents->getType();
DebugLog ( << "got NOTIFY event with body of type " << mime.type() << "/" << mime.subType() );
Pidf* body = dynamic_cast<Pidf*>(contents);
if ( !body )
{
InfoLog(<< "Received NOTIFY message event with no PIDF contents" );
mCallback->presenceUpdate( from, true, Data::Empty );
return;
}
Data note;
bool open = body->getSimpleStatus( ¬e );
bool changed = true;
// update if found in budy list
for ( BuddyIterator i=mBuddies.begin(); i != mBuddies.end(); i++)
{
Uri u = i->uri; // getBuddyUri(i);
if ( u.getAor() == from.getAor() )
{
if ( (i->status == note) &&
(i->online == open) )
{
changed = false;
}
i->status = note;
i->online = open;
}
}
InfoLog(<< "Processed NOTIFY message : Presence changed: " << changed );
// notify callback
if (changed)
{
assert(mCallback);
mCallback->presenceUpdate( from, open, note );
}
}
| void TuIM::processNotifyResponse | ( | SipMessage * | msg, |
| DeprecatedDialog & | d | ||
| ) | [private] |
Definition at line 954 of file TuIM.cxx.
References DebugLog, and resip::SipMessage::header().
Referenced by processResponse().
{
int number = msg->header(h_StatusLine).responseCode();
DebugLog( << "got NOTIFY response of type " << number );
if ( number >= 300 )
{
// TODO
}
}
| void TuIM::processPageResponse | ( | SipMessage * | msg, |
| Page & | page | ||
| ) | [private] |
Definition at line 980 of file TuIM.cxx.
References DebugLog, dest, resip::TuIM::Page::encryptFor, resip::SipMessage::header(), mCallback, mPages, sendPage(), resip::TuIM::Callback::sendPageFailed(), resip::TuIM::Page::sign, resip::TuIM::Page::text, and resip::RequestLine::uri().
Referenced by processResponse().
{
int number = msg->header(h_StatusLine).responseCode();
DebugLog( << "got MESSAGE response of type " << number );
if ( number >= 400 )
{
Uri dest = msg->header(h_To).uri();
assert( mCallback );
mCallback->sendPageFailed( dest,number );
}
if ( (number>=300) && (number<400) )
{
ParserContainer<NameAddr>::iterator dest = msg->header(h_Contacts).begin();
while ( dest != msg->header(h_Contacts).end() )
{
DebugLog(<< "Got a 3xx to" << *dest );
// send a message to redirected location
Uri uri = dest->uri();
sendPage( page.text, uri, page.sign, page.encryptFor );
dest++;
}
}
if ( (number>=200) && (number<300) )
{
// got a final response for notify - can remove this dialog information
CallId id = msg->header(h_CallId);
for( PageIterator i=mPages.begin(); i != mPages.end(); i++ )
{
if ( i->dialog->getCallId() == id )
{
i = mPages.erase( i );
}
}
}
}
| void TuIM::processPublishResponse | ( | SipMessage * | msg, |
| StateAgent & | sa | ||
| ) | [private] |
Definition at line 967 of file TuIM.cxx.
References DebugLog, and resip::SipMessage::header().
Referenced by processResponse().
{
int number = msg->header(h_StatusLine).responseCode();
DebugLog( << "got PUBLISH response of type " << number );
if ( number >= 300 )
{
// TODO
}
}
| void TuIM::processRegisterRequest | ( | SipMessage * | msg | ) | [private] |
Definition at line 450 of file TuIM.cxx.
References DebugLog, resip::SipMessage::exists(), resip::RequestLine::getMethod(), resip::SipMessage::header(), resip::Helper::makeResponse(), mStack, resip::SipMessage::remove(), resip::SipStack::send(), and resip::ParserContainerBase::size().
Referenced by processRequest().
{
assert( msg->header(h_RequestLine).getMethod() == REGISTER );
CallId id = msg->header(h_CallId);
int expires = msg->header(h_Expires).value();
if ( expires == 0 )
{
expires = 3600;
}
SipMessage* response = Helper::makeResponse( *msg, 200 );
// the Contacts from the default Helper are wrong for a Registration
response->remove(h_Contacts);
if ( msg->exists(h_Contacts) )
{
ParserContainer<NameAddr> &providedContacts(msg->header(h_Contacts));
int multipleContacts = (int)providedContacts.size();
DebugLog ( << multipleContacts << " contacts were in received message." );
ParserContainer<NameAddr>::iterator i(providedContacts.begin());
for ( ; i != providedContacts.end() ; ++ i) {
if ( i->isAllContacts() && multipleContacts ) // oops, multiple Contacts and one is "*"
{
delete response; // do I need to do this?
response = Helper::makeResponse( *msg, 400 );
mStack->send( *response );
delete response;
return;
}
if ( !i->exists(p_expires) ) // add expires params where they don't exist
{
i->param(p_expires) = expires;
}
response->header(h_Contacts).push_back(*i); // copy each Contact into response
}
}
// else the REGISTER is a query, just send the message with no Contacts
mStack->send( *response );
delete response;
}
| void TuIM::processRegisterResponse | ( | SipMessage * | msg | ) | [private] |
Definition at line 854 of file TuIM.cxx.
References resip::Helper::addAuthorization(), resip::DeprecatedDialog::createDialogAsUAC(), DebugLog, resip::Data::Empty, resip::SipMessage::exists(), resip::Uri::getAor(), resip::Timer::getRandomFutureTimeMs(), resip::SipMessage::header(), InfoLog, resip::DeprecatedDialog::makeRegister(), mAor, mCallback, mContact, mLastAuthCSeq, mNextTimeToRegister, mRegistrationDialog, mRegistrationPassword, mRegistrationTimeSeconds, mStack, resip::TuIM::Callback::registrationFailed(), resip::TuIM::Callback::registrationWorked(), resip::SipStack::send(), setOutbound(), resip::RequestLine::uri(), and resip::Uri::user().
Referenced by processResponse().
{
int number = msg->header(h_StatusLine).responseCode();
Uri to = msg->header(h_To).uri();
InfoLog ( << "register of " << to << " got response " << number );
unsigned int cSeq = msg->header(h_CSeq).sequence();
if ( number<200 )
{
return;
}
if ( number >= 200 )
{
mRegistrationDialog.createDialogAsUAC( *msg );
}
if ( ((number == 401) || (number == 407)) && (cSeq != mLastAuthCSeq) )
{
SipMessage* reg = mRegistrationDialog.makeRegister();
const Data cnonce = Data::Empty;
unsigned int nonceCount=0;
Helper::addAuthorization(*reg,*msg,mAor.user(),mRegistrationPassword,cnonce,nonceCount);
mLastAuthCSeq = reg->header(h_CSeq).sequence();
reg->header(h_Expires).value() = mRegistrationTimeSeconds;
reg->header(h_Contacts).front().param(p_expires) = mRegistrationTimeSeconds;
mNextTimeToRegister = Timer::getRandomFutureTimeMs( mRegistrationTimeSeconds*1000 );
InfoLog( << *reg );
setOutbound( *reg );
mStack->send( *reg );
delete reg; reg=NULL;
return;
}
if ( number >= 300 )
{
assert( mCallback );
mCallback->registrationFailed( to, number );
return;
}
if ( (number>=200) && (number<300) )
{
int expires = mRegistrationTimeSeconds;
if ( msg->exists(h_Expires) )
{
expires = msg->header(h_Expires).value();
}
// loop throught the contacts, find me, and extract expire time
resip::ParserContainer<resip::NameAddr>::iterator i = msg->header(h_Contacts).begin();
while ( i != msg->header(h_Contacts).end() )
{
try
{
Uri uri = i->uri();
if ( uri.getAor() == mContact.getAor() )
{
int e = i->param(p_expires);
DebugLog(<< "match " << uri.getAor() << " e=" << e );
expires = e;
}
}
catch ( exception* )
{
InfoLog(<< "Bad contact in 2xx to register - skipped" );
}
i++;
}
if ( expires < 15 )
{
InfoLog(<< "Got very small expiers of " << expires );
expires = 15;
}
mNextTimeToRegister = Timer::getRandomFutureTimeMs( expires*1000 );
mCallback->registrationWorked( to );
return;
}
}
| void TuIM::processRequest | ( | SipMessage * | msg | ) | [private] |
Definition at line 232 of file TuIM.cxx.
References resip::RequestLine::getMethod(), resip::SipMessage::header(), IMMethodList, IMMethodListSize, InfoLog, resip::Helper::make405(), mStack, processMessageRequest(), processNotifyRequest(), processRegisterRequest(), processSubscribeRequest(), and resip::SipStack::send().
Referenced by process().
{
if ( msg->header(h_RequestLine).getMethod() == MESSAGE )
{
processMessageRequest(msg);
return;
}
if ( msg->header(h_RequestLine).getMethod() == SUBSCRIBE )
{
processSubscribeRequest(msg);
return;
}
if ( msg->header(h_RequestLine).getMethod() == REGISTER )
{
processRegisterRequest(msg);
return;
}
if ( msg->header(h_RequestLine).getMethod() == NOTIFY )
{
processNotifyRequest(msg);
return;
}
InfoLog(<< "Don't support this METHOD, send 405" );
SipMessage * resp = Helper::make405( *msg, IMMethodList, IMMethodListSize );
mStack->send(*resp);
delete resp;
}
| void TuIM::processResponse | ( | SipMessage * | msg | ) | [private] |
Definition at line 770 of file TuIM.cxx.
References DebugLog, resip::Data::Empty, resip::SipMessage::exists(), resip::DeprecatedDialog::getCallId(), resip::SipMessage::header(), InfoLog, mBuddies, mPages, mRegistrationDialog, mStateAgents, mSubscribers, resip::TuIM::Buddy::presDialog, processNotifyResponse(), processPageResponse(), processPublishResponse(), processRegisterResponse(), processSipFrag(), processSubscribeResponse(), resip::CallID::value(), and value.
Referenced by process().
{
assert( msg->exists(h_CallId));
CallId id = msg->header(h_CallId);
assert( id.value() != Data::Empty );
processSipFrag( msg );
// see if it is a registraition response
CallId regId = mRegistrationDialog.getCallId();
Data v1 = id.value();
Data v2 = regId.value();
InfoLog( << "want id =" << id );
if ( id == regId )
{
InfoLog ( << "matched the reg dialog"
<< mRegistrationDialog.getCallId() << " = " << id );
processRegisterResponse( msg );
return;
}
// see if it is a subscribe response
for ( BuddyIterator i=mBuddies.begin(); i != mBuddies.end(); i++)
{
Buddy& buddy = *i;
assert( buddy.presDialog );
InfoLog( << "check buddy id =" << buddy.presDialog->getCallId() );
if ( buddy.presDialog->getCallId() == id )
{
DebugLog ( << "matched the subscribe dialog" );
processSubscribeResponse( msg, buddy );
return;
}
}
// see if it is a publish response
for ( StateAgentIterator i=mStateAgents.begin(); i != mStateAgents.end(); i++)
{
assert( i->dialog );
InfoLog( << "check publish id =" << i->dialog->getCallId() );
if ( i->dialog->getCallId() == id )
{
DebugLog ( << "matched the publish dialog" );
processPublishResponse( msg, *i );
return;
}
}
// see if it is a notify response
for ( SubscriberIterator i=mSubscribers.begin(); i != mSubscribers.end(); i++)
{
DeprecatedDialog* dialog = i->dialog;
assert( dialog );
InfoLog( << "check subscriber id =" << dialog->getCallId() );
if ( dialog->getCallId() == id )
{
DebugLog ( << "matched the notify dialog" );
processNotifyResponse( msg, *dialog );
return;
}
}
// see if it is a page response
for ( PageIterator i=mPages.begin(); i != mPages.end(); i++)
{
assert( i->dialog );
InfoLog( << "check page id =" << i->dialog->getCallId() );
if ( i->dialog->getCallId() == id )
{
DebugLog ( << "matched the MESSAGE dialog" );
processPageResponse( msg, *i );
return;
}
}
int number = msg->header(h_StatusLine).responseCode();
InfoLog( << "got response that DID NOT MATCH of type " << number );
}
| void TuIM::processSipFrag | ( | SipMessage * | msg | ) | [private] |
Definition at line 264 of file TuIM.cxx.
References resip::BaseSecurity::checkSignature(), DebugLog, resip::SipMessage::getContents(), resip::SipStack::getSecurity(), resip::Contents::getType(), InfoLog, resip::SipFrag::message(), mStack, resip::MultipartMixedContents::parts(), resip::Mime::subType(), and resip::Mime::type().
Referenced by processNotifyRequest(), processResponse(), and processSubscribeRequest().
{
Contents* contents = msg->getContents();
if ( !contents )
{
InfoLog(<< "Received message with no contents" );
return;
}
InfoLog(<< "Received message with body contents" );
assert( contents );
Mime mime = contents->getType();
DebugLog ( << "got body of type " << mime.type() << "/" << mime.subType() );
Data signedBy;
#if defined( USE_SSL )
SignatureStatus sigStat = SignatureNone;
MultipartSignedContents* mBody = dynamic_cast<MultipartSignedContents*>(contents);
if ( mBody )
{
Security* sec = mStack->getSecurity();
assert(sec);
contents = sec->checkSignature( mBody, &signedBy, &sigStat );
if ( !contents )
{
InfoLog( << "Some problem decoding multipart/signed message");
return;
}
InfoLog( << "Signed by " << signedBy << " stat = " << sigStat );
}
#endif
if ( contents )
{
MultipartMixedContents* mixed = dynamic_cast<MultipartMixedContents*>(contents);
if ( mixed )
{
InfoLog( << "Got a multipart mixed" );
contents = NULL;
MultipartMixedContents::Parts& parts = mixed->parts();
for( MultipartMixedContents::Parts::const_iterator i = parts.begin();
i != parts.end();
++i)
{
Contents* c = *i;
assert( c );
InfoLog ( << "mixed has a " << c->getType() );
if ( c->getType() == Mime("application","sipfrag") )
{
InfoLog ( << "mixed has sipfrag " << c->getType() );
SipFrag* frag = dynamic_cast<SipFrag*>(c);
if ( frag )
{
InfoLog( << "Got a sipFrag inside mixed" );
SipMessage& m = frag->message();
InfoLog( <<"Frag is " << m );
}
}
}
}
}
if ( contents )
{
SipFrag* frag = dynamic_cast<SipFrag*>(contents);
if ( frag )
{
InfoLog( << "Got a sipFrag" );
SipMessage& m = frag->message();
InfoLog( <<"Frag is " << m );
}
else
{
InfoLog ( << "Can not handle type " << contents->getType() );
return;
}
}
}
| void TuIM::processSubscribeRequest | ( | SipMessage * | msg | ) | [private] |
Definition at line 359 of file TuIM.cxx.
References resip::TuIM::Subscriber::aor, resip::TuIM::Subscriber::authorized, resip::TuIM::Callback::authorizeSubscription(), DebugLog, resip::TuIM::Subscriber::dialog, resip::SipMessage::exists(), resip::Uri::getAor(), resip::Uri::getAorNoPort(), resip::DeprecatedDialog::getCallId(), resip::RequestLine::getMethod(), resip::Timer::getTimeMs(), resip::SipMessage::header(), resip::DeprecatedDialog::makeResponse(), mAor, mBuddies, mCallback, mContact, mStack, mSubscribers, mSubscriptionTimeSeconds, processSipFrag(), resip::SipStack::send(), sendNotify(), resip::DeprecatedDialog::setExpirySeconds(), and resip::RequestLine::uri().
Referenced by processRequest().
{
assert( msg->header(h_RequestLine).getMethod() == SUBSCRIBE );
CallId id = msg->header(h_CallId);
processSipFrag( msg );
int expires=mSubscriptionTimeSeconds;
if ( msg->exists(h_Expires) )
{
expires = msg->header(h_Expires).value();
}
if (expires > mSubscriptionTimeSeconds )
{
expires = mSubscriptionTimeSeconds;
}
DeprecatedDialog* dialog = NULL;
// see if we already have this subscription
for ( SubscriberIterator i=mSubscribers.begin(); i != mSubscribers.end(); i++)
{
DeprecatedDialog* d = i->dialog;
assert( d );
if ( d->getCallId() == id )
{
// found the subscrition in list of current subscrbtions
dialog = d;
break;
}
}
if ( !dialog )
{
// create a new subscriber
DebugLog ( << "Creating new subscrition dialog ");
Subscriber s;
s.dialog = new DeprecatedDialog( NameAddr(mContact) );
dialog = s.dialog;
Uri from = msg->header(h_From).uri();
s.aor = from.getAorNoPort();
assert( mCallback );
s.authorized = mCallback->authorizeSubscription( from );
mSubscribers.push_back( s );
}
assert( dialog );
dialog->setExpirySeconds( expires );
auto_ptr<SipMessage> response( dialog->makeResponse( *msg, 200 ));
response->header(h_Expires).value() = expires;
response->header(h_Event).value() = Data("presence");
mStack->send( *response );
sendNotify( dialog );
#if 1
// do symetric subscriptions
// See if this person is our buddy list and if we are not subscribed to them
UInt64 now = Timer::getTimeMs();
Uri from = msg->header(h_From).uri();
for ( BuddyIterator i=mBuddies.begin(); i != mBuddies.end(); i++)
{
Data buddyAor = i->uri.getAor();
if ( ! (i->presDialog->isCreated()) )
{
if ( from.getAor() == i->uri.getAor() )
{
if ( from.getAor() != mAor.getAor() )
{
i->mNextTimeToSubscribe = now;
}
}
}
}
#endif
}
| void TuIM::processSubscribeResponse | ( | SipMessage * | msg, |
| Buddy & | buddy | ||
| ) | [private] |
Definition at line 1024 of file TuIM.cxx.
References addBuddy(), resip::DeprecatedDialog::createDialogAsUAC(), DebugLog, dest, resip::Data::Empty, resip::SipMessage::exists(), resip::Uri::getAor(), resip::Timer::getForever(), resip::Timer::getRandomFutureTimeMs(), resip::TuIM::Buddy::group, resip::SipMessage::header(), InfoLog, mBuddies, mCallback, resip::TuIM::Buddy::mNextTimeToSubscribe, mSubscriptionTimeSeconds, resip::TuIM::Buddy::presDialog, resip::TuIM::Callback::presenceUpdate(), and resip::RequestLine::uri().
Referenced by processResponse().
{
int number = msg->header(h_StatusLine).responseCode();
Uri to = msg->header(h_To).uri();
InfoLog ( << "subscribe got response " << number << " from " << to );
if ( (number>=200) && (number<300) )
{
int expires = mSubscriptionTimeSeconds;
if ( msg->exists(h_Expires) )
{
expires = msg->header(h_Expires).value();
}
if ( expires < 15 )
{
InfoLog( << "Got very small expiers of " << expires );
expires = 15;
}
assert( buddy.presDialog );
buddy.presDialog->createDialogAsUAC( *msg );
buddy.mNextTimeToSubscribe = Timer::getRandomFutureTimeMs( expires*1000 );
}
if ( (number>=300) && (number<400) )
{
ParserContainer<NameAddr>::iterator dest = msg->header(h_Contacts).begin();
while ( dest != msg->header(h_Contacts).end() )
{
DebugLog(<< "Got a 3xx to" << *dest );
Uri uri = dest->uri();
addBuddy( uri , buddy.group );
buddy.mNextTimeToSubscribe = Timer::getForever();
dest++;
}
}
if ( (number>=400) )
{
DebugLog( << "Got an error to some subscription" );
// take this buddy off line
Uri to = msg->header(h_To).uri();
assert( mCallback );
bool changed = true;
for ( BuddyIterator i=mBuddies.begin(); i != mBuddies.end(); i++)
{
Uri u = i->uri; // getBuddyUri(i);
if ( u.getAor() == to.getAor() )
{
if ( i->online == false )
{
changed = false;
}
i->online = false;
}
}
if ( changed )
{
mCallback->presenceUpdate( to, false, Data::Empty );
}
// try to contact this buddy again later
buddy.mNextTimeToSubscribe = Timer::getRandomFutureTimeMs( mSubscriptionTimeSeconds*1000 );
}
}
| void TuIM::registerAor | ( | const Uri & | uri, |
| const Data & | password = Data::Empty |
||
| ) |
Definition at line 1176 of file TuIM.cxx.
References resip::Timer::getRandomFutureTimeMs(), resip::DeprecatedDialog::makeInitialRegister(), mNextTimeToRegister, mRegistrationDialog, mRegistrationPassword, mRegistrationTimeSeconds, mStack, resip::SipStack::send(), and setOutbound().
Referenced by myMain().
{
mRegistrationPassword = password;
//const NameAddr aorName;
//const NameAddr contactName;
//aorName.uri() = uri;
//contactName.uri() = mContact;
//SipMessage* msg = Helper::makeRegister(aorName,aorName,contactName);
auto_ptr<SipMessage> msg( mRegistrationDialog.makeInitialRegister(NameAddr(uri),NameAddr(uri)) );
msg->header(h_Expires).value() = mRegistrationTimeSeconds;
msg->header(h_Contacts).front().param(p_expires) = mRegistrationTimeSeconds;
Token t;
t = Token(Data("presence"));
msg->header(h_AllowEvents).push_back( t );
mNextTimeToRegister = Timer::getRandomFutureTimeMs( mRegistrationTimeSeconds*1000 );
setOutbound( *msg );
mStack->send( *msg );
}
| void TuIM::removeBuddy | ( | const Uri & | name | ) |
Definition at line 1283 of file TuIM.cxx.
References resip::Uri::getAor(), and mBuddies.
{
TuIM::BuddyIterator i;
i = mBuddies.begin();
while ( i != mBuddies.end() )
{
Uri u = i->uri;
if ( u.getAor() == name.getAor() )
{
// remove this buddy
// !cj! - should unsubscribe
i = mBuddies.erase(i);
}
else
{
i++;
}
}
}
| void TuIM::sendNotify | ( | DeprecatedDialog * | dialog | ) | [private] |
Definition at line 1307 of file TuIM.cxx.
References resip::DeprecatedDialog::getExpirySeconds(), resip::DeprecatedDialog::makeNotify(), mPidf, mStack, resip::ParserCategory::param(), resip::SipStack::send(), setOutbound(), and resip::Token::value().
Referenced by processSubscribeRequest(), and setMyPresence().
{
assert( dialog );
auto_ptr<SipMessage> msg( dialog->makeNotify() );
Pidf* pidf = new Pidf( *mPidf );
msg->header(h_Event).value() = "presence";
Token state;
state.value() = Data("active");
state.param(p_expires) = dialog->getExpirySeconds();
msg->header(h_SubscriptionState) = state;
msg->setContents( pidf );
setOutbound( *msg );
mStack->send( *msg );
}
| void TuIM::sendPage | ( | const Data & | text, |
| const Uri & | dest, | ||
| const bool | sign = false, |
||
| const Data & | encryptFor = Data::Empty |
||
| ) |
Definition at line 125 of file TuIM.cxx.
References DebugLog, dest, resip::Data::empty(), resip::Data::Empty, resip::BaseSecurity::encrypt(), resip::Uri::getAor(), resip::SipStack::getSecurity(), resip::Contents::header(), resip::DeprecatedDialog::makeInitialMessage(), mAor, mCallback, mContact, mPages, mStack, resip::SipStack::send(), resip::TuIM::Callback::sendPageFailed(), setOutbound(), resip::BaseSecurity::sign(), resip::TuIM::Page::text, and resip::NameAddr::uri().
Referenced by myMain(), processPageResponse(), and processStdin().
{
if ( text.empty() )
{
DebugLog( << "tried to send blank message - dropped " );
return;
}
DebugLog( << "send to <" << dest << ">" << "\n" << text );
NameAddr target;
target.uri() = dest;
NameAddr from;
from.uri() = mAor;
NameAddr contact;
contact.uri() = mContact;
DeprecatedDialog* dialog = new DeprecatedDialog( NameAddr(mContact) );
auto_ptr<SipMessage> msg( dialog->makeInitialMessage(NameAddr(target),NameAddr(from)) );
Page page;
page.text = text;
page.uri = dest;
page.sign = sign;
page.encryptFor = encryptFor;
page.dialog = dialog;
mPages.push_back(page);
Contents* body = ( new PlainContents(text) );
#if 1
msg->header(h_ContentTransferEncoding) = StringCategory(Data("binary"));
#endif
#if defined( USE_SSL )
if ( !encryptFor.empty() )
{
Security* sec = mStack->getSecurity();
assert(sec);
Contents* old = body;
old->header(h_ContentTransferEncoding) = msg->header(h_ContentTransferEncoding);
body = sec->encrypt( old, encryptFor );
delete old;
if ( !body )
{
mCallback->sendPageFailed( dest, -2 );
return;
}
#if 0
msg->header(h_ContentTransferEncoding) = StringCategory(Data("binary"));
#endif
}
if ( sign )
{
Security* sec = mStack->getSecurity();
assert(sec);
Contents* old = body;
old->header(h_ContentTransferEncoding) = msg->header(h_ContentTransferEncoding);
body = sec->sign( mAor.getAor(), old );
delete old;
if ( !body )
{
mCallback->sendPageFailed( dest, -1 );
return;
}
#if 0
msg->header(h_ContentTransferEncoding) = StringCategory(Data("binary"));
#endif
}
#endif
msg->setContents(body);
if (1) // Compute the identity header.
{
//Security* sec = mStack->getSecurity();
//assert(sec);
DateCategory now;
msg->header(h_Date) = now;
//Data token = msg->getCanonicalIdentityString();
//Data res = sec->computeIdentity( token );
msg->header(h_Identity).value() = Data::Empty;
}
setOutbound( *msg );
//ErrLog( "About to send " << *msg );
mStack->send( *msg );
delete body;
}
| void TuIM::sendPublish | ( | StateAgent & | dialog | ) | [private] |
Definition at line 1331 of file TuIM.cxx.
References resip::TuIM::StateAgent::dialog, resip::DeprecatedDialog::makeInitialPublish(), mAor, mPidf, mStack, resip::SipStack::send(), setOutbound(), and resip::TuIM::StateAgent::uri.
Referenced by addStateAgent(), and setMyPresence().
{
assert( sa.dialog );
auto_ptr<SipMessage> msg( sa.dialog->makeInitialPublish(NameAddr(sa.uri),NameAddr(mAor)) );
Pidf* pidf = new Pidf( *mPidf );
msg->header(h_Event).value() = "presence";
msg->setContents( pidf );
setOutbound( *msg );
mStack->send( *msg );
}
| void TuIM::setDefaultProtocol | ( | TransportType | protocol | ) |
Definition at line 1425 of file TuIM.cxx.
References mDefaultProtocol.
Referenced by myMain().
{
mDefaultProtocol = protocol;
}
| void TuIM::setMyPresence | ( | const bool | open, |
| const Data & | status = Data::Empty, |
||
| const Data & | user = Data::Empty |
||
| ) |
Definition at line 1357 of file TuIM.cxx.
References resip::Uri::getAor(), mContact, mPidf, mStateAgents, mSubscribers, sendNotify(), sendPublish(), and resip::Pidf::setSimpleStatus().
Referenced by processStdin().
{
// TODO implement the pser user status (when user is not empty)
assert( mPidf );
mPidf->setSimpleStatus( open, status, mContact.getAor() );
for ( SubscriberIterator i=mSubscribers.begin(); i != mSubscribers.end(); i++)
{
DeprecatedDialog* dialog = i->dialog;
assert( dialog );
sendNotify(dialog);
}
for ( StateAgentIterator i=mStateAgents.begin(); i != mStateAgents.end(); i++)
{
sendPublish( *i );
}
}
| void TuIM::setOutbound | ( | SipMessage & | msg | ) | [private] |
Definition at line 1395 of file TuIM.cxx.
References DebugLog, resip::Data::empty(), resip::Uri::exists(), resip::SipMessage::header(), resip::Uri::host(), resip::SipMessage::isResponse(), mDefaultProtocol, mOutboundProxy, mUAName, resip::ParserCategory::param(), resip::toDataLower(), resip::UNKNOWN_TRANSPORT, and resip::RequestLine::uri().
Referenced by process(), processRegisterResponse(), registerAor(), sendNotify(), sendPage(), sendPublish(), and subscribeBuddy().
{
if ( msg.isResponse() )
{
return;
}
if ( !mOutboundProxy.host().empty() )
{
NameAddr proxy( mOutboundProxy );
msg.header(h_Routes).push_front( proxy );
}
if ( !mUAName.empty() )
{
DebugLog( << "UserAgent name=" << mUAName );
msg.header(h_UserAgent).value() = mUAName;
}
if ( mDefaultProtocol != UNKNOWN_TRANSPORT )
{
if ( ! msg.header(h_RequestLine).uri().exists(p_transport) )
{
msg.header(h_RequestLine).uri().param(p_transport) = Tuple::toDataLower(mDefaultProtocol);
}
}
}
| void TuIM::setOutboundProxy | ( | const Uri & | uri | ) |
Definition at line 1379 of file TuIM.cxx.
References InfoLog, and mOutboundProxy.
Referenced by myMain().
{
InfoLog( << "Set outbound proxy to " << uri );
mOutboundProxy = uri;
}
| void TuIM::setUAName | ( | const Data & | name | ) |
| void TuIM::subscribeBuddy | ( | Buddy & | buddy | ) | [private] |
Definition at line 1248 of file TuIM.cxx.
References resip::Timer::getRandomFutureTimeMs(), resip::DeprecatedDialog::makeInitialSubscribe(), mAor, resip::TuIM::Buddy::mNextTimeToSubscribe, mStack, mSubscriptionTimeSeconds, resip::TuIM::Buddy::presDialog, resip::SipStack::send(), setOutbound(), and resip::TuIM::Buddy::uri.
Referenced by addBuddy(), and process().
{
// subscribe to this budy
auto_ptr<SipMessage> msg( buddy.presDialog->makeInitialSubscribe(NameAddr(buddy.uri),NameAddr(mAor)) );
msg->header(h_Event).value() = Data("presence");;
msg->header(h_Accepts).push_back( Mime( "application","pidf+xml") );
msg->header(h_Expires).value() = mSubscriptionTimeSeconds;
buddy.mNextTimeToSubscribe = Timer::getRandomFutureTimeMs( mSubscriptionTimeSeconds*1000 );
setOutbound( *msg );
mStack->send( *msg );
}
Member Data Documentation
Uri resip::TuIM::mAor [private] |
Definition at line 107 of file TuIM.hxx.
Referenced by haveCerts(), processMessageRequest(), processRegisterResponse(), processSubscribeRequest(), sendPage(), sendPublish(), subscribeBuddy(), and TuIM().
std::vector<Buddy> resip::TuIM::mBuddies [private] |
Definition at line 133 of file TuIM.hxx.
Referenced by addBuddy(), getBuddyGroup(), getBuddyStatus(), getBuddyUri(), getNumBuddies(), process(), processNotifyRequest(), processResponse(), processSubscribeRequest(), processSubscribeResponse(), and removeBuddy().
Callback* resip::TuIM::mCallback [private] |
Definition at line 105 of file TuIM.hxx.
Referenced by processMessageRequest(), processNotifyRequest(), processPageResponse(), processRegisterResponse(), processSubscribeRequest(), processSubscribeResponse(), sendPage(), and TuIM().
Uri resip::TuIM::mContact [private] |
Definition at line 108 of file TuIM.hxx.
Referenced by addBuddy(), addStateAgent(), processMessageRequest(), processRegisterResponse(), processSubscribeRequest(), sendPage(), setMyPresence(), and TuIM().
TransportType resip::TuIM::mDefaultProtocol [private] |
Definition at line 188 of file TuIM.hxx.
Referenced by setDefaultProtocol(), and setOutbound().
unsigned int resip::TuIM::mLastAuthCSeq [private] |
Definition at line 177 of file TuIM.hxx.
Referenced by processRegisterResponse().
UInt64 resip::TuIM::mNextTimeToRegister [private] |
Definition at line 175 of file TuIM.hxx.
Referenced by process(), processRegisterResponse(), and registerAor().
Uri resip::TuIM::mOutboundProxy [private] |
Definition at line 186 of file TuIM.hxx.
Referenced by setOutbound(), and setOutboundProxy().
std::list<Page> resip::TuIM::mPages [private] |
Definition at line 167 of file TuIM.hxx.
Referenced by processPageResponse(), processResponse(), and sendPage().
Pidf* resip::TuIM::mPidf [private] |
Definition at line 171 of file TuIM.hxx.
Referenced by sendNotify(), sendPublish(), setMyPresence(), and TuIM().
Definition at line 174 of file TuIM.hxx.
Referenced by process(), processRegisterResponse(), processResponse(), and registerAor().
Data resip::TuIM::mRegistrationPassword [private] |
Definition at line 176 of file TuIM.hxx.
Referenced by processRegisterResponse(), and registerAor().
const int resip::TuIM::mRegistrationTimeSeconds [private] |
Definition at line 180 of file TuIM.hxx.
Referenced by process(), processRegisterResponse(), and registerAor().
SipStack* resip::TuIM::mStack [private] |
Definition at line 106 of file TuIM.hxx.
Referenced by haveCerts(), process(), processMessageRequest(), processNotifyRequest(), processRegisterRequest(), processRegisterResponse(), processRequest(), processSipFrag(), processSubscribeRequest(), registerAor(), sendNotify(), sendPage(), sendPublish(), subscribeBuddy(), and TuIM().
std::list<StateAgent> resip::TuIM::mStateAgents [private] |
Definition at line 143 of file TuIM.hxx.
Referenced by addStateAgent(), processResponse(), and setMyPresence().
std::list<Subscriber> resip::TuIM::mSubscribers [private] |
Definition at line 154 of file TuIM.hxx.
Referenced by processResponse(), processSubscribeRequest(), and setMyPresence().
const int resip::TuIM::mSubscriptionTimeSeconds [private] |
Definition at line 183 of file TuIM.hxx.
Referenced by process(), processSubscribeRequest(), processSubscribeResponse(), and subscribeBuddy().
Data resip::TuIM::mUAName [private] |
Definition at line 187 of file TuIM.hxx.
Referenced by setOutbound(), and setUAName().
The documentation for this class was generated from the following files:
