#if defined(HAVE_CONFIG_H)#include "resip/stack/config.hxx"#endif#include <stdlib.h>#include "resip/stack/TuIM.hxx"#include "GagMessage.hxx"#include "GagConduit.hxx"#include "resip/stack/os/Logger.hxx"#define RESIPROCATE_SUBSYSTEM Subsystem::TESTGagConduit::GagConduit(SipStack &stack, int _udpPort)  : sipStack(&stack), udpPort(_udpPort), running(true){  // Nothing interesting to do here}voidGagConduit::handleMessage(GagMessage *message){  switch (message->getMessageType())  {    case GagMessage::IM:      gaimIm(reinterpret_cast<GagImMessage *>(message));      break;    case GagMessage::PRESENCE:      gaimPresence(reinterpret_cast<GagPresenceMessage *>(message));      break;    case GagMessage::HELLO:      gaimHello(reinterpret_cast<GagHelloMessage *>(message));      break;    case GagMessage::LOGIN:      gaimLogin(reinterpret_cast<GagLoginMessage *>(message));      break;    case GagMessage::LOGOUT:      gaimLogout(reinterpret_cast<GagLogoutMessage *>(message));      break;    case GagMessage::ADD_BUDDY:      gaimAddBuddy(reinterpret_cast<GagAddBuddyMessage *>(message));      break;    case GagMessage::REMOVE_BUDDY:      gaimRemoveBuddy(reinterpret_cast<GagRemoveBuddyMessage *>(message));      break;    case GagMessage::SHUTDOWN:      gaimShutdown(reinterpret_cast<GagShutdownMessage *>(message));      break;    case GagMessage::GAG_ERROR:      gaimError(reinterpret_cast<GagErrorMessage *>(message));      break;    case GagMessage::LOGIN_STATUS:      gaimLoginStatus(reinterpret_cast<GagLoginStatusMessage *>(message));      break;    default:      InfoLog ( << "Ignoring unexpected message of type "                 << message->getMessageType());      break;  }}GagConduit::~GagConduit(){  removeAllUsers();}voidGagConduit::removeAllUsers(){  // Shut down all logged in users  map<Uri,TuIM *>::iterator tu;  tu = tuIM.begin();  while (tu != tuIM.end())  {    delete(tu->second);    tuIM.erase(tu);    tu++;  }}map<Uri,TuIM *>::iteratorGagConduit::getTu(Uri &aor){  map<Uri,TuIM *>::iterator tu = tuIM.find(aor);  if (tu == tuIM.end())  {    Data error;    error = "You are not logged in as ";    error += Data::from(aor);    GagErrorMessage(error).serialize(cout);  }  return tu;}voidGagConduit::gaimIm(GagImMessage *msg){  Uri *from = msg->getFromPtr();  Uri *to = msg->getToPtr();  Data *im = msg->getImPtr();  map<Uri,TuIM *>::iterator tu = getTu(*from);  if (tu == tuIM.end()) return;  tu->second->sendPage(*im, *to, false, Data::Empty);}voidGagConduit::gaimPresence(GagPresenceMessage *msg){  Uri *aor = msg->getAorPtr();  bool online = msg->getAvailable();  Data *status = msg->getStatusPtr();  map<Uri,TuIM *>::iterator tu = getTu(*aor);  if (tu == tuIM.end()) return;    tu->second->setMyPresence(online, *status);}voidGagConduit::gaimHello(GagHelloMessage *msg){  // We don't need to do anything when we get a hello.  // Not yet, at least.}voidGagConduit::gaimLogin(GagLoginMessage *msg){  Uri *aor = msg->getAorPtr();  Data *userid = msg->getUseridPtr();  Data *password = msg->getPasswordPtr();  bool register_with_service = msg->getRegisterWithService();  bool publish_to_service = msg->getPublishToService();  TuIM *newTu;  map<Uri,TuIM *>::iterator tu = tuIM.find(*aor);  if (tu != tuIM.end())  {    Data error;    error = "You are already logged in as ";    error += Data::from(aor);    GagErrorMessage(error).serialize(cout);  }  // Figure out what out contact is  Uri contact;  contact.user() = aor->user();  newTu = new TuIM(sipStack, *aor, contact, this );  if (!newTu)  {    Data error;    error = "Ran out of memory when logging in as ";    error += Data::from(aor);    GagErrorMessage(error).serialize(cout);    return;  }  newTu->setUAName(Data("gag/0.0.1 (gaim)"));  if (register_with_service)  {    newTu->registerAor(*aor, *password);  }  else  {    // If we're not registering, then login always    // trivially succeeds :)    Data ok("Okay");    GagLoginStatusMessage (true, 200, ok).serialize(cout);  }  if (publish_to_service)  {    newTu->addStateAgent(*aor);  }  /* adam: This is a temporary hack until we get the     configuration plumbing working */  char *outboundProxy = getenv("DEFAULT_PROXY");  if (outboundProxy)  {    newTu->setOutboundProxy(Uri(outboundProxy));  }  tuIM[*aor] = newTu;}voidGagConduit::gaimLogout(GagLogoutMessage *msg){  Uri *aor = msg->getAorPtr();  map<Uri,TuIM *>::iterator tu = getTu(*aor);  if (tu == tuIM.end()) return;    delete(tu->second);  tuIM.erase(tu);}voidGagConduit::gaimAddBuddy(GagAddBuddyMessage *msg){  Uri *us = msg->getUsPtr();  Uri *them = msg->getThemPtr();  map<Uri,TuIM *>::iterator tu = getTu(*us);  if (tu == tuIM.end()) return;  tu->second->addBuddy(*them, Data::Empty);}voidGagConduit::gaimRemoveBuddy(GagRemoveBuddyMessage *msg){  Uri *us = msg->getUsPtr();  Uri *them = msg->getThemPtr();  map<Uri,TuIM *>::iterator tu = getTu(*us);  if (tu == tuIM.end()) return;  tu->second->removeBuddy(*them);}voidGagConduit::gaimShutdown(GagShutdownMessage *msg){  running = false;  removeAllUsers();}voidGagConduit::gaimError(GagErrorMessage *msg){  // This should *never* be called..  InfoLog ( << "GAIM should not send me errors.");}voidGagConduit::gaimLoginStatus(GagLoginStatusMessage *msg){  // This should *never* be called..  InfoLog ( << "GAIM should not send me login status messages.");}voidGagConduit::process(){  map<Uri,TuIM *>::iterator tu;  tu = tuIM.begin();  while (tu != tuIM.end())  {    (tu->second)->process();    tu++;  }}void GagConduit::presenceUpdate(const Uri& dest, bool open,                           const Data& status ){  InfoLog ( << " Gag got a presenceUpdate Callback");  GagPresenceMessage(dest, open, status).serialize(cout);}void GagConduit::receivedPage( const Data& msg, const Uri& from ,                          const Data& signedBy,                          Security::SignatureStatus sigStatus,                          bool wasEncryped){  Uri to("sip:dummy@dummy.xx"); // XXX  GagImMessage (from, to, msg).serialize(cout);}void GagConduit::sendPageFailed( const Uri& dest,int respNumber ){  Data error;  error = "Could not send IM to ";  error += Data::from(dest);  error += " (";  error += Data::from(respNumber);  error += ")";  GagErrorMessage (error).serialize(cout);}void GagConduit::registrationFailed(const resip::Uri& uri, int respNumber){  Data error;  error = "Could not register as ";  error += Data::from(uri);  error += " (";  error += Data::from(respNumber);  error += ")";  GagLoginStatusMessage (false, respNumber, error).serialize(cout);}void GagConduit::registrationWorked(const Uri& dest ){  Data ok("Okay");  GagLoginStatusMessage (true, 200, ok).serialize(cout);}void GagConduit::receivePageFailed(const Uri& sender){  Data error;  error = "Could not get IM from ";  error += Data::from(sender);  GagErrorMessage (error).serialize(cout);}