source: verona/phcpp/testphcpp.cpp @ 97:688b45026d07

#include <string>
#include <iostream>
#include <time.h>
#include <stdlib.h>
#include <string.h>
#include <cstdio>

#ifdef _MSC_VER
#include <windows.h>
#define sleep(x) Sleep((x)*1000)
#define snprintf _snprintf
#endif

using namespace std;

#include "phapipp.h"


int vl1, vl2, cid1, cid2;
string gChatRoom;


string extract_uri(const char *s)
{
  string tmp = s;
  int lt = tmp.find('<');
  int gt = tmp.find('>');
  
  return tmp.substr(lt+1, gt-lt-1);

}

class myphapi:public verona::stdphapi
{

  static const char *nz(const char *s) { return s ? s : ""; }

  void  onRegProgress(int rid, int status)
  {
    printf("Reg: %d Status: %d\n", rid, status);
  }


  virtual void onMsgProgress(int mid,  const phMsgStateInfo_t *info)
  {
    if (info->event == phMsgNew)
      {
        printf("Got Message: to=%s from=%s type=%s\n======\n%s=======\n",
               info->to, info->from, info->rawctt, info->content);
      }
  }

  virtual void onNotifyProgress (const char* event, const char* from, const char *ctt, const char* content)
  {
    printf("Got notification: from=%s evt=%s ctt=%s content:\n====\n%s\n====\n", from, event, ctt, content);
  }


  void onCallProgress(int cid, const phCallStateInfo_t *info)
  {
    switch (info->event)
      {
      case phDIALING:
        printf("DIALING line=%d cid=%d uri=%s\n", info->vlid, cid, info->u.remoteUri);
        break;

      case phRINGING:
        printf("RINGING cid=%d uri=%s\n", cid, info->u.remoteUri);
        break;

      case phRINGandSTART:
        printf("RINGINGandSTART cid=%d uri=%s\n", cid, info->u.remoteUri);
        break;

      case phRINGandSTOP:
        printf("RINGandSTOP cid=%d uri=%s\n", cid, info->u.remoteUri);
        break;


      case phNOANSWER:
        printf("NOANSWER cid=%d uri=%s\n", cid, info->u.remoteUri);
        break;

      case phCALLBUSY:
        printf("BUSY cid=%d uri=%s\n", cid, info->u.remoteUri);
        break;

      case phCALLREDIRECTED:
        printf("REDIRECTED cid=%d newcid=%d to=%s\n", cid, info->newcid, info->u.remoteUri);
        break;

      case phCALLOK:
        printf("CALLOK cid=%d uri=%s\n", cid, info->u.remoteUri);
        break;

      case phCALLHELD:
        printf("CALLHELD cid=%d  status=%d\n", cid, info->u.errorCode);
        break;

      case phCALLRESUMED:
        printf("CALLRESUMED cid=%d  status=%d\n", cid, info->u.errorCode);
        break;

      case phHOLDOK:
        printf("HOLDOK cid=%d  status=%d\n", cid, info->u.errorCode);
        break;

      case phRESUMEOK:
        printf("RESUMEOK cid=%d  status=%d\n", cid, info->u.errorCode);
        break;

      case phINCALL:
        printf("INCALL line=%d cid=%d to=%s from=%s streams=%x callinfo=%s\n", info->vlid, cid, 
               info->localUri, info->u.remoteUri, info->streams, nz(info->callinfo));
        
        if (info->streams == PH_STREAM_DATA)
          {
            acceptCall(cid, 0, PH_STREAM_DATA);
            cid2 = cid;
          }

        break;

      case phCALLCLOSED:
        printf("CALLCLOSED cid=%d  status=%d\n", cid, info->u.errorCode);
        break;


      case phCALLCLOSEDandSTOPRING:
        printf("CALLCLOSEDandSTOPRING cid=%d  status=%d\n", cid, info->u.errorCode);
        break;

      case phCALLERROR:
        printf("CALLERROR cid=%d  status=%d\n", cid, info->u.errorCode);
        break;

      case phDTMF:
        printf("DTMF cid=%d  digit=%c\n", cid, info->u.dtmfDigit);
        break;

      case phXFERREQ:
        printf("XFERREQ line=%d cid=%d newcid=%d to=%s", info->vlid, cid, info->newcid, info->u.remoteUri);
        break;

      case phXFERPROGRESS:
        printf("XFERPROGRESS cid=%d status=%d\n", cid, info->u.errorCode);
        break;

      case phXFEROK:
        printf("XFEROK cid=%d status=%d\n", cid, info->u.errorCode);
        break;

      case phXFERFAIL:
        printf("XFERFAIL cid=%d status=%d\n", cid, info->u.errorCode);
        break;

      case phCALLREPLACED:
        printf("CALLREPLACED cid=%d newcid=%d uri=%s streams=%x, callinfo=%s\n", cid, info->newcid, 
               info->u.remoteUri, info->streams, nz(info->callinfo));

        gChatRoom = extract_uri(info->u.remoteUri);
        cid1 = info->newcid;

        phCloseCall(cid);
        break;

      }

    fflush(stdout);

    
  }

};


extern myphapi  api;


static char * 
maketimestamp(char buf[], int bsize)
{
    struct tm tmbuf;
    time_t  now;
    char  tmstr[64];

    now = time(0);
    tmbuf = *localtime(&now);

    strftime(tmstr, 64, "%d-%b-%Y %I:%M:%S", &tmbuf);
        
    snprintf(buf, bsize, "%s.%03d %s", 
             tmstr, now % 1000, 
             ((tmbuf.tm_hour < 12) ? "AM" : "PM"));

    return buf;
}


std::string gChatUri = "sip:CHAT@comverse.com";

void sendSessionMessage(int vlid, const std::string &chatroom, const char *from, const char *message)
{
    char mid[64];
    char cpimbuf[4096];
    char timestamp[128];


    maketimestamp(timestamp, sizeof(timestamp));

    sprintf(mid, "%d", time(0));

    snprintf(cpimbuf, sizeof(cpimbuf), 
             "To: %s\r\n"
             "From: %s\r\n"
             "DateTime: %s\r\n"
             "Subject: \r\n"
             "Expires: %d\r\n"
             "imdn.Message-ID: %s\r\n"
             "imdn.Disposition-Notification: \r\n"
             "Content-Type: text/html\r\n"
             "\r\n",
             chatroom.c_str(), from, timestamp, 3600, mid);

    ::strcat(cpimbuf, message);

    api.sendMessage(vlid, gChatUri, cpimbuf,  "message/cpim", gChatUri);
 
}



const char * 
getMobilityString(int vlid)
{
  switch(api.mobility(vlid))
    {
    case PH_LINE_MOBILITY_FIXED:
      return "fixed";

    case PH_LINE_MOBILITY_MOBILE:
      return "mobile";

    default:
    case PH_LINE_MOBILITY_DEFAULT:
      return "";
    }

}

void remove_port(std::string& s)
{
  int colon = s.rfind(':');
  int at = s.find('@');

  if (colon > at && colon != s.npos)
    s.replace(colon, s.length() - colon, "");

}

std::string 
getEntity(int vlid)
{
  std::string tmp = api.getSipAddress(vlid);
  std::string sa = extract_uri(tmp.c_str());

  remove_port(sa);
  sa.replace(0,4, ""); // remove "sip:"
  return sa;
  
}
#define PUBLISH_MSG_TEMPLATE_WITH_DEVTYPE "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n\
<presence xmlns=\"urn:ietf:params:xml:ns:pidf\"\n entity=\"%s\">\n\
<tuple id=\"%s%s\">\n\
<status><basic>%s</basic></status>\n\
<activities>%s</activities>\n\
<note>%s</note>\n\
<contact priority=\"1\">%s</contact>\n\
<time>%u</time>\n\
</tuple>\n\
</presence>\n"

void publishPresence(int vlid, bool status,const std::string& activity, int timeout) 
{

    char *body = new char[4*1024];
    std::string prefix = getMobilityString(vlid);
    std::string uri = getEntity(vlid);
    std::string realAct = activity;
    const char *mood="1";

 
    if (prefix.length())
      prefix += ".";

    snprintf(body, 4*1024, PUBLISH_MSG_TEMPLATE_WITH_DEVTYPE,  
             uri.c_str(), 
             prefix.c_str(), 
             uri.c_str(),  
             (status ? "open" : "closed"),
             realAct.c_str(),
             mood,
             uri.c_str(), 
             time(0));


    api.publish(vlid, "sip:" + uri, "presence" , "application/pidf+xml", body, timeout);

    delete [] body;


}




void joinServerChat(const std::string& chatroom, int vlid, int cid)
{
  std::string cidstr  = api.getSipCallID(cid);

  api.sendMessage(vlid, chatroom, "Join", "text/plain", gChatUri, cidstr);
}
 







myphapi api;



int main(int argc,  char *argv[])
{

  cout << "Intializing and creating virtual lines " << endl; 
  api.init();
  
  api.addCustomHeader("INVITE", "Expires", "3600");

  api.addAuthInfo(argv[1], argv[1], argv[2], NULL);
  
  vl1 = api.addVline(argv[1], argv[1], "voip.mbdsys.com", "voip.mbdsys.com:6060", 600);

  string s;


 // cout << "Placeing data call " << endl;
 // cin >> s;

  // place data call

  ph_config_t* conf = api.getConfig();
  strcpy(conf->audio_codecs, "PCMA,PCMU");
  strcpy(conf->local_rtp_port, "27000");
  /*
  cid1 = api.placeCall(vl1, "sip:10001@sfrdroid", 0, 0, PH_STREAM_AUDIO, 0, "voip.mbdsys.com");
  sleep(5);

  cout << "netc1 joining chatroom: " << endl; 
  cin >> s;

  joinServerChat(gChatRoom, vl1, cid1);
  sleep(3);

  cout << "netc2 joining chatroom: " << endl; 
  cin >> s;

  joinServerChat(gChatRoom, vl2, cid2);
  sleep(3);

  cout << "netc1 sending message: " << endl; 
  cin >> s;

  sendSessionMessage(vl1, gChatRoom, "sip:netc1@comverse.com", "hello you");
  sleep(3);
*/
 // cout << "Closing data calls" << endl;
//  cin >> s;

//  api.closeCall(cid1);
//  api.closeCall(cid2);

  cout << "subscribing to nikita presence"  << endl;
    cin >> s;

    api.subscribe(vl1, "sip:nikita@voip.mbdsys.com:6060", PH_SUBS_PRESENCE);
    sleep(3);
    publishPresence(vl1, true, "online", 300);
return 0;
  sleep(3);

  cout << "subscribing to netc2 presence"  << endl;
  cin >> s;

  api.subscribe(vl1, "sip:netc2@comverse.com", PH_SUBS_PRESENCE);
  sleep(3);

  cout << "Publishing netc2 presence"  << endl;
  cin >> s;

  publishPresence(vl2, true, "online", 300);
  sleep(3);

  cout << "Publishing changed netc2 presence"  << endl;
  cin >> s;

  publishPresence(vl2, true, "busy", 300);
  sleep(3);


  cout << "Terminating" << endl;
  cin >> s;

  api.terminate();
}