Navigation

Changeset 409:c2fb5b26bfcb in freeDiameter for extensions/app_sip


Ignore:
Timestamp:
Jul 8, 2010, 4:19:28 PM (14 years ago)
Author:
Alexandre Westfahl <awestfahl@freediameter.net>
Branch:
default
Phase:
public
Message:

Fix for ticket 8

Location:
extensions/app_sip
Files:
1 added
5 edited

Legend:

Unmodified
Added
Removed

  • extensions/app_sip/diamsip.c

    r392 r409  
    3737
    3838struct disp_hdl * diamsip_MAR_hdl=NULL;
     39struct disp_hdl * diamsip_LIR_hdl=NULL;
     40struct disp_hdl * diamsip_UAR_hdl=NULL;
     41struct disp_hdl * diamsip_SAR_hdl=NULL;
     42struct disp_hdl * diamsip_PPA_hdl=NULL;
     43struct disp_hdl * diamsip_RTA_hdl=NULL;
     44
     45
    3946struct disp_hdl * diamsip_default_hdl=NULL;
    4047struct session_handler * ds_sess_hdl;
    … …  
    137144        memset(&data, 0, sizeof(data));
    138145        CHECK_FCT( fd_dict_search( fd_g_config->cnf_dict, DICT_APPLICATION, APPLICATION_BY_NAME, "Diameter Session Initiation Protocol (SIP) Application", &data.app, ENOENT) );
    139         CHECK_FCT( fd_dict_search( fd_g_config->cnf_dict, DICT_COMMAND, CMD_BY_NAME, "Multimedia-Auth-Request", &data.command, ENOENT) );
    140146       
    141         //Callback for unexpected messages
    142         CHECK_FCT( fd_disp_register( diamsip_MAR_cb, DISP_HOW_APPID, &data, &diamsip_default_hdl ) );
    143147       
    144148        //**Command Codes
    145149        //MAR
     150        CHECK_FCT( fd_dict_search( fd_g_config->cnf_dict, DICT_COMMAND, CMD_BY_NAME, "Multimedia-Auth-Request", &data.command, ENOENT) );
    146151        CHECK_FCT( fd_disp_register( diamsip_MAR_cb, DISP_HOW_CC, &data, &diamsip_MAR_hdl ) );
     152        //RTA
     153        CHECK_FCT( fd_dict_search( fd_g_config->cnf_dict, DICT_COMMAND, CMD_BY_NAME, "Registration-Termination-Answer", &data.command, ENOENT) );
     154        CHECK_FCT( fd_disp_register( diamsip_RTA_cb, DISP_HOW_CC, &data, &diamsip_RTA_hdl ) );
    147155       
    148         //TRACE_DEBUG(INFO,"*%s*%s*%s*%s*",DB_SERVER,DB_USERNAME, DB_PASSWORD, DB_DATABASE);
     156        //Callback for unexpected messages
     157        CHECK_FCT( fd_disp_register( diamsip_default_cb, DISP_HOW_APPID, &data, &diamsip_default_hdl ) );
     158       
     159       
    149160        //We start database connection
    150161        if(start_mysql_connection())
    … …  
    160171{
    161172       
    162         if (diamsip_MAR_cb) {
    163                 (void) fd_disp_unregister(&diamsip_MAR_hdl);
    164                 CHECK_FCT_DO( fd_sess_handler_destroy(&ds_sess_hdl),return);
    165         }
     173       
     174        (void) fd_disp_unregister(&diamsip_MAR_hdl);
     175        CHECK_FCT_DO( fd_sess_handler_destroy(&ds_sess_hdl),return);
     176       
    166177       
    167178        //We close database connection

  • extensions/app_sip/diamsip.h

    r392 r409  
    7676
    7777void calc_md5(char *buffer, char * data);
    78 void clear_digest(char * digest, char * readable_digest, int digestlength);
     78void clear_digest(uint8_t * digest, char * readable_digest, int digestlength);
    7979struct avp_hdr * walk_digest(struct avp *avp, int avp_code);
    8080int start_mysql_connection();
    … …  
    8282void close_mysql_connection();
    8383
     84void DigestCalcHA1(char * pszAlg,char * pszUserName,char * pszRealm,char * pszPassword,char * pszNonce,char * pszCNonce,HASHHEX SessionKey);
     85void DigestCalcResponse(HASHHEX HA1,char * pszNonce,char * pszNonceCount,char * pszCNonce,char * pszQop,char * pszMethod,char * pszDigestUri,HASHHEX HEntity,HASHHEX Response);
     86void DigestCalcResponseAuth(HASHHEX HA1,char * pszNonce,char * pszNonceCount,char * pszCNonce,char * pszQop,char * pszMethod,char * pszDigestUri,HASHHEX HEntity,HASHHEX Response);
    8487
     88int fd_avp_search_avp ( struct avp * groupedavp, struct dict_object * what, struct avp ** avp );
    8589
    8690int ds_entry();
    … …  
    8892int diamsip_default_cb( struct msg ** msg, struct avp * avp, struct session * sess, enum disp_action * act);
    8993int diamsip_MAR_cb( struct msg ** msg, struct avp * avp, struct session * sess, enum disp_action * act);
     94int diamsip_RTA_cb( struct msg ** msg, struct avp * avp, struct session * sess, enum disp_action * act);
    9095#define SQL_GETPASSWORD "SELECT `password` FROM ds_users WHERE `username` ='%s'"
    9196#define SQL_GETPASSWORD_LEN 52

  • extensions/app_sip/libdiamsip.c

    r392 r409  
    3838
    3939MYSQL *conn;
    40 /*
    41 void calculate_nonce(u8 * nonce)
    42 {
    43 
    44         nonce="lkgbsljhsdjdsgj";
    45         return;
    46 }*/
    47 
    48 void clear_digest(char * digest, char * readable_digest, int digestlength)
     40
     41void clear_digest(uint8_t * digest, char * readable_digest, int digestlength)
    4942{
    5043        int i=0;
    … …  
    8174        struct avp_hdr * nextavphdr;
    8275        struct dict_avp_data    dictdata;
    83         enum dict_object_type   dicttype;
     76       
    8477       
    8578        TRACE_ENTRY("%p %p %p", groupedavp, what, avp);
    … …  
    125118{
    126119        struct avp_hdr *temphdr=NULL;
    127         CHECK_FCT_DO(fd_msg_browse ( avp, MSG_BRW_WALK, &avp, NULL),0 );
     120        CHECK_FCT_DO(fd_msg_browse ( avp, MSG_BRW_WALK, &avp, NULL),return NULL);
    128121       
    129122        while(avp!=NULL)
    130123        {
    131124               
    132                 CHECK_FCT_DO( fd_msg_avp_hdr( avp,&temphdr ),0);
     125                CHECK_FCT_DO( fd_msg_avp_hdr( avp,&temphdr ),return NULL);
    133126
    134127                if(temphdr->avp_code==avp_code)
    … …  
    149142                else
    150143                {
    151                         CHECK_FCT_DO(fd_msg_browse ( avp, MSG_BRW_WALK, &avp, NULL),0 );
     144                        CHECK_FCT_DO(fd_msg_browse ( avp, MSG_BRW_WALK, &avp, NULL),return NULL);
    152145                        temphdr=NULL;
    153146                       

  • extensions/app_sip/md5.c

    r360 r409  
    5353
    5454      MD5Init(&Md5Ctx);
    55       MD5Update(&Md5Ctx, pszUserName, strlen(pszUserName));
    56       MD5Update(&Md5Ctx, ":", 1);
    57       MD5Update(&Md5Ctx, pszRealm, strlen(pszRealm));
    58       MD5Update(&Md5Ctx, ":", 1);
    59       MD5Update(&Md5Ctx, pszPassword, strlen(pszPassword));
    60       MD5Final(HA1, &Md5Ctx);
     55      MD5Update(&Md5Ctx, (const unsigned char *)pszUserName, strlen(pszUserName));
     56      MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     57      MD5Update(&Md5Ctx, (const unsigned char *)pszRealm, strlen(pszRealm));
     58      MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     59      MD5Update(&Md5Ctx, (const unsigned char *)pszPassword, strlen(pszPassword));
     60      MD5Final((unsigned char *)HA1, &Md5Ctx);
    6161      if (strcmp(pszAlg, "md5-sess") == 0) {   
    6262                MD5Init(&Md5Ctx);
    63                 MD5Update(&Md5Ctx, HA1, HASHLEN);
    64                 MD5Update(&Md5Ctx, ":", 1);
    65                 MD5Update(&Md5Ctx, pszNonce, strlen(pszNonce));
    66                 MD5Update(&Md5Ctx, ":", 1);
    67                 MD5Update(&Md5Ctx, pszCNonce, strlen(pszCNonce));
    68                 MD5Final(HA1, &Md5Ctx);
     63                MD5Update(&Md5Ctx, (const unsigned char *)HA1, HASHLEN);
     64                MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     65                MD5Update(&Md5Ctx, (const unsigned char *)pszNonce, strlen(pszNonce));
     66                MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     67                MD5Update(&Md5Ctx, (const unsigned char *)pszCNonce, strlen(pszCNonce));
     68                MD5Final((unsigned char *)HA1, &Md5Ctx);
    6969      }
    7070      CvtHex(HA1, SessionKey);
    … …  
    8181      // calculate H(A2)
    8282      MD5Init(&Md5Ctx);
    83       MD5Update(&Md5Ctx, pszMethod, strlen(pszMethod));
    84       MD5Update(&Md5Ctx, ":", 1);
    85       MD5Update(&Md5Ctx, pszDigestUri, strlen(pszDigestUri));
     83      MD5Update(&Md5Ctx, (const unsigned char *)pszMethod, strlen(pszMethod));
     84      MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     85      MD5Update(&Md5Ctx, (const unsigned char *)pszDigestUri, strlen(pszDigestUri));
    8686      if (strcmp(pszQop, "auth-int") == 0) {
    87             MD5Update(&Md5Ctx, ":", 1);
    88             MD5Update(&Md5Ctx, HEntity, HASHHEXLEN);
     87            MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     88            MD5Update(&Md5Ctx, (const unsigned char *)HEntity, HASHHEXLEN);
    8989      }
    90       MD5Final(HA2, &Md5Ctx);
     90      MD5Final((unsigned char *)HA2, &Md5Ctx);
    9191       CvtHex(HA2, HA2Hex);
    9292       
    9393      // calculate response
    9494      MD5Init(&Md5Ctx);
    95       MD5Update(&Md5Ctx, HA1, HASHHEXLEN);
    96       MD5Update(&Md5Ctx, ":", 1);
    97       MD5Update(&Md5Ctx, pszNonce, strlen(pszNonce));
    98       MD5Update(&Md5Ctx, ":", 1);
     95      MD5Update(&Md5Ctx, (const unsigned char *)HA1, HASHHEXLEN);
     96      MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     97      MD5Update(&Md5Ctx,(const unsigned char *) pszNonce, strlen(pszNonce));
     98      MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
    9999      if (*pszQop) {
    100           MD5Update(&Md5Ctx, pszNonceCount, strlen(pszNonceCount));
    101           MD5Update(&Md5Ctx, ":", 1);
    102           MD5Update(&Md5Ctx, pszCNonce, strlen(pszCNonce));
    103           MD5Update(&Md5Ctx, ":", 1);
    104           MD5Update(&Md5Ctx, pszQop, strlen(pszQop));
    105           MD5Update(&Md5Ctx, ":", 1);
     100          MD5Update(&Md5Ctx, (const unsigned char *)pszNonceCount, strlen(pszNonceCount));
     101          MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     102          MD5Update(&Md5Ctx, (const unsigned char *)pszCNonce, strlen(pszCNonce));
     103          MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     104          MD5Update(&Md5Ctx, (const unsigned char *)pszQop, strlen(pszQop));
     105          MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
    106106      }
    107       MD5Update(&Md5Ctx, HA2Hex, HASHHEXLEN);
    108       MD5Final(RespHash, &Md5Ctx);
     107      MD5Update(&Md5Ctx, (const unsigned char *)HA2Hex, HASHHEXLEN);
     108      MD5Final((unsigned char *)RespHash, &Md5Ctx);
    109109      CvtHex(RespHash, Response);
    110110}
    … …  
    119119      // calculate H(A2)
    120120      MD5Init(&Md5Ctx);
    121       MD5Update(&Md5Ctx, ":", 1);
    122       MD5Update(&Md5Ctx, pszDigestUri, strlen(pszDigestUri));
     121      MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     122      MD5Update(&Md5Ctx, (const unsigned char *)pszDigestUri, strlen(pszDigestUri));
    123123      if (strcmp(pszQop, "auth-int") == 0) {
    124             MD5Update(&Md5Ctx, ":", 1);
    125             MD5Update(&Md5Ctx, HEntity, HASHHEXLEN);
     124            MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     125            MD5Update(&Md5Ctx, (const unsigned char *)HEntity, HASHHEXLEN);
    126126      }
    127       MD5Final(HA2, &Md5Ctx);
     127      MD5Final((unsigned char *)HA2, &Md5Ctx);
    128128       CvtHex(HA2, HA2Hex);
    129129       
    130130      // calculate response
    131131      MD5Init(&Md5Ctx);
    132       MD5Update(&Md5Ctx, HA1, HASHHEXLEN);
    133       MD5Update(&Md5Ctx, ":", 1);
    134       MD5Update(&Md5Ctx, pszNonce, strlen(pszNonce));
    135       MD5Update(&Md5Ctx, ":", 1);
     132      MD5Update(&Md5Ctx, (const unsigned char *)HA1, HASHHEXLEN);
     133      MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     134      MD5Update(&Md5Ctx, (const unsigned char *)pszNonce, strlen(pszNonce));
     135      MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
    136136      if (*pszQop) {
    137           MD5Update(&Md5Ctx, pszNonceCount, strlen(pszNonceCount));
    138           MD5Update(&Md5Ctx, ":", 1);
    139           MD5Update(&Md5Ctx, pszCNonce, strlen(pszCNonce));
    140           MD5Update(&Md5Ctx, ":", 1);
    141           MD5Update(&Md5Ctx, pszQop, strlen(pszQop));
    142           MD5Update(&Md5Ctx, ":", 1);
     137          MD5Update(&Md5Ctx, (const unsigned char *)pszNonceCount, strlen(pszNonceCount));
     138          MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     139          MD5Update(&Md5Ctx, (const unsigned char *)pszCNonce, strlen(pszCNonce));
     140          MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
     141          MD5Update(&Md5Ctx, (const unsigned char *)pszQop, strlen(pszQop));
     142          MD5Update(&Md5Ctx, (const unsigned char *)":", 1);
    143143      }
    144       MD5Update(&Md5Ctx, HA2Hex, HASHHEXLEN);
    145       MD5Final(RespHash, &Md5Ctx);
     144      MD5Update(&Md5Ctx, (const unsigned char *)HA2Hex, HASHHEXLEN);
     145      MD5Final((unsigned char *)RespHash, &Md5Ctx);
    146146      CvtHex(RespHash, Response);
    147147}

  • extensions/app_sip/multimediaauth.c

    r368 r409  
    4141        struct msg *ans, *qry;
    4242        struct avp *avp, *a2, *authdataitem;
    43         struct msg_hdr * header = NULL;
     43        //struct msg_hdr * header = NULL;
    4444        struct avp_hdr * avphdr=NULL, *avpheader=NULL, *avpheader_auth=NULL,*digestheader=NULL;
    4545        union avp_value val;
    … …  
    4848        char * result;
    4949        char password[51];
    50         int idx=0, idx2=0, number_of_auth_items=0,i=0;
     50        int idx=0, number_of_auth_items=0,i=0;
    5151        //Flags and variables for Database
    5252        int sipurinotstored=0, authenticationpending=0, querylen=0, usernamelen=0;
    … …  
    7070
    7171
    72         /* Add the appropriate command code & Auth-Application-Id */
     72        /* Add the appropriate command code & Auth-Application-Id
    7373        {
    7474               
    … …  
    7979               
    8080               
    81                 /* Add the Auth-Application-Id */
     81                // Add the Auth-Application-Id
    8282                {
    8383                        CHECK_FCT( fd_msg_avp_new ( sip_dict.Auth_Application_Id, 0, &avp ) );
    … …  
    8787                        CHECK_FCT( fd_msg_avp_add ( ans, MSG_BRW_LAST_CHILD, avp) );
    8888                }
    89         }
     89        }*/
    9090       
    9191       
    … …  
    125125                        username=malloc(avphdr->avp_value->os.len*2+1);
    126126                        //We purify username not to have forbidden characters
    127                         usernamelen=mysql_real_escape_string(conn, username, avphdr->avp_value->os.data, avphdr->avp_value->os.len);
    128                        
    129                        
    130                         if((strncmp(avpheader->avp_value->os.data,"REGISTER",avpheader->avp_value->os.len)==0))
     127                        usernamelen=mysql_real_escape_string(conn, username, (const char *)avphdr->avp_value->os.data, avphdr->avp_value->os.len);
     128                       
     129                       
     130                        if((strncmp((const char *)avpheader->avp_value->os.data,"REGISTER",avpheader->avp_value->os.len)==0))
    131131                        {
    132132                                not_found=1;
    … …  
    153153                                while ((row = mysql_fetch_row(res)) != NULL)
    154154                                {
    155                                         if(row[0]!="")
     155                                        if(strlen(row[0])>0)
    156156                                        {
    157157                                                strcpy(password,row[0]);
    … …  
    195195                                while ((row = mysql_fetch_row(res)) != NULL)
    196196                                {
    197                                         if(strncmp(avphdr->avp_value->os.data,row[0],avphdr->avp_value->os.len)==0)
     197                                        if(strncmp((const char *)avphdr->avp_value->os.data,row[0],avphdr->avp_value->os.len)==0)
    198198                                        {
    199199                                                not_found=0;
    … …  
    225225                                sipuri=malloc(avphdr->avp_value->os.len*2+1);
    226226                                //We purify SIP-URI not to have forbidden characters
    227                                 sipurilen=mysql_real_escape_string(conn, sipuri, avphdr->avp_value->os.data, avphdr->avp_value->os.len);
     227                                sipurilen=mysql_real_escape_string(conn, sipuri, (const char *)avphdr->avp_value->os.data, avphdr->avp_value->os.len);
    228228                               
    229229                               
    … …  
    245245                                while ((row = mysql_fetch_row(res)) != NULL)
    246246                                {
    247                                         if(strncmp(avphdr->avp_value->os.data,row[0],avphdr->avp_value->os.len)==0)
     247                                        if(strncmp((const char *)avphdr->avp_value->os.data,row[0],avphdr->avp_value->os.len)==0)
    248248                                        {
    249249                                                not_found=0;
    … …  
    361361                                                                {
    362362                                                                        CHECK_FCT( fd_msg_avp_new ( sip_dict.Digest_QOP, 0, &a2 ) );
    363                                                                         val.os.data="auth";
    364                                                                         val.os.len=strlen(val.os.data);
     363                                                                        val.os.data=(unsigned char *)"auth";
     364                                                                        val.os.len=strlen((const char *)val.os.data);
    365365                                                                        CHECK_FCT( fd_msg_avp_setvalue( a2, &val ) );
    366366                                                                        CHECK_FCT( fd_msg_avp_add( sipAuthenticate, MSG_BRW_LAST_CHILD, a2 ) );
    … …  
    387387                                                                        CHECK_FCT( fd_sess_state_store ( ds_sess_hdl, sess, &storednonce )); 
    388388                                                                       
    389                                                                         val.os.data=nonce;
     389                                                                        val.os.data=(unsigned char *)nonce;
    390390                                                                        val.os.len=NONCE_SIZE * 2;
    391391                                                                       
    … …  
    396396                                                                {
    397397                                                                        CHECK_FCT( fd_msg_avp_new ( sip_dict.Digest_Algorithm, 0, &a2 ) );
    398                                                                         val.os.data="MD5";
    399                                                                         val.os.len=strlen(val.os.data);
     398                                                                        val.os.data=(unsigned char *)"MD5";
     399                                                                        val.os.len=strlen((const char *)val.os.data);
    400400                                                                        CHECK_FCT( fd_msg_avp_setvalue( a2, &val ) );
    401401                                                                        CHECK_FCT( fd_msg_avp_add( sipAuthenticate, MSG_BRW_LAST_CHILD, a2 ) );
    … …  
    464464                                                                        //uint8_t bufferresp[DIGEST_LEN];
    465465                                                                        //char response[DIGEST_LEN*2+1];
    466                                                                         int i=0;
     466                                                                       
    467467                                                                       
    468468                                                                        //We extract all the data we need
    … …  
    640640                                                                       
    641641                                                                        DigestCalcHA1(digest_algorithm, digest_username, digest_realm, password, digest_nonce,digest_cnonce, HA1);
    642                                                                        
    643                                                         DigestCalcResponse(HA1, digest_nonce, digest_noncecount, digest_cnonce, digest_qop,digest_method, digest_uri, HA2, response);
     642                                                                DigestCalcResponse(HA1, digest_nonce, digest_noncecount, digest_cnonce, digest_qop,digest_method, digest_uri, HA2, response);
    644643                                                                       
    645644               
    … …  
    677676                                                                                //Digest-HA1 MUST be used instead of Digest-Response-Auth if Digest-Qop is 'auth-int'.
    678677                                                                                CHECK_FCT( fd_msg_avp_new ( sip_dict.Digest_HA1, 0, &a2 ) );
    679                                                                                 val.os.data=HA1;
     678                                                                                val.os.data=(unsigned char *)HA1;
    680679                                                                                val.os.len=HASHHEXLEN+1;
    681680                                                                                CHECK_FCT( fd_msg_avp_setvalue( a2, &val ) );
    … …  
    686685                                                                                //Digest-Response-Auth MUST be used instead of Digest-HA1 if Digest-Qop is 'auth'.
    687686                                                                                CHECK_FCT( fd_msg_avp_new ( sip_dict.Digest_Response_Auth, 0, &a2 ) );
    688                                                                                 val.os.data=responseauth;
     687                                                                                val.os.data=(unsigned char *)responseauth;
    689688                                                                                val.os.len=DIGEST_LEN*2;
    690689                                                                                CHECK_FCT( fd_msg_avp_setvalue( a2, &val ) );
Note: See TracChangeset for help on using the changeset viewer.