ims_pm_scscf.c

Go to the documentation of this file.

/*
 * $Id: ims_pm_scscf.c 432 2007-08-02 16:27:30Z vingarzan $
 *  
 * Copyright (C) 2004-2006 FhG Fokus
 *
 * This file is part of Open IMS Core - an open source IMS CSCFs & HSS
 * implementation
 *
 * Open IMS Core is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * For a license to use the Open IMS Core software under conditions
 * other than those described here, or to purchase support for this
 * software, please contact Fraunhofer FOKUS by e-mail at the following
 * addresses:
 *     info@open-ims.org
 *
 * Open IMS Core is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 * 
 * It has to be noted that this Open Source IMS Core System is not 
 * intended to become or act as a product in a commercial context! Its 
 * sole purpose is to provide an IMS core reference implementation for 
 * IMS technology testing and IMS application prototyping for research 
 * purposes, typically performed in IMS test-beds.
 * 
 * Users of the Open Source IMS Core System have to be aware that IMS
 * technology may be subject of patents and licence terms, as being 
 * specified within the various IMS-related IETF, ITU-T, ETSI, and 3GPP
 * standards. Thus all Open IMS Core users have to take notice of this 
 * fact and have to agree to check out carefully before installing, 
 * using and extending the Open Source IMS Core System, if related 
 * patents and licences may become applicable to the intended usage 
 * context.  
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 * 
 */
 

#include "ims_pm_scscf.h"

#ifdef WITH_IMS_PM

#include <unistd.h>
#include <fcntl.h>
#include <time.h>

#include "../../script_cb.h"
#include "../tm/tm_load.h"

#include "mod.h"
#include "sip.h"
#include "registrar.h"
#include "cx_avp.h"


extern struct tm_binds tmb;                         
static str zero={0,0};

void ims_pm_init_scscf()
{
    register_script_cb(ims_pm_pre_script,PRE_SCRIPT_CB|REQ_TYPE_CB|RPL_TYPE_CB,0);
    register_script_cb(ims_pm_post_script,POST_SCRIPT_CB|REQ_TYPE_CB|RPL_TYPE_CB,0);    
}




int ims_pm_get_registration_type(struct sip_msg *msg)
{
    str public_identity = cscf_get_public_identity(msg);
    if (r_is_registered_id(public_identity)){
        if (cscf_get_expires_hdr(msg)>0) return 1;
        else return 2;      
    }
    else
        return 0;
}

void ims_pm_register_cb(struct cell* t, int type, struct tmcb_params* ps)
{
    int k = (int) *ps->param;
    int code = ps->code; 
    switch(k){
        case 0:
            if (code>=200 && code<300) 
                IMS_PM_LOG12(UR_SuccInitReg,cscf_get_call_id(ps->req,0),cscf_get_cseq(ps->req,0),code);
            else if (code>=300) IMS_PM_LOG12(UR_FailInitReg,cscf_get_call_id(ps->req,0),cscf_get_cseq(ps->req,0),code);
            break;
        case 1:
            if (code>=200 && code<300) IMS_PM_LOG12(UR_SuccReReg,cscf_get_call_id(ps->req,0),cscf_get_cseq(ps->req,0),code);
            else if (code>=300) IMS_PM_LOG12(UR_FailReReg,cscf_get_call_id(ps->req,0),cscf_get_cseq(ps->req,0),code);
            break;
        case 2:
            if (code>=200 && code<300) IMS_PM_LOG12(UR_SuccDeRegUe,cscf_get_call_id(ps->req,0),cscf_get_cseq(ps->req,0),code);
            else if (code>=300) IMS_PM_LOG12(UR_FailDeRegUe,cscf_get_call_id(ps->req,0),cscf_get_cseq(ps->req,0),code);
            break;
    }
}

static str s_register={"REGISTER",8};
static str s_invite={"INVITE",6};

int ims_pm_pre_script(struct sip_msg *msg,void *param)
{
    int k;
    str method={0,0};
    unsigned int x,y;
    if (msg->first_line.type == SIP_REQUEST){
        method = msg->first_line.u.request.method;
        /* REGISTER */
        if (method.len==s_register.len && strncasecmp(method.s,s_register.s,s_register.len)==0){
                k = ims_pm_get_registration_type(msg);
                switch(k){
                    case 0:
                        IMS_PM_LOG11(UR_AttInitReg,cscf_get_call_id(msg,0),cscf_get_cseq(msg,0));
                        IMS_PM_LOG21(RU_RmgUsersOut,cscf_get_call_id(msg,0),
                            cscf_get_visited_network_id(msg,0),cscf_get_cseq(msg,0));
                        break;
                    case 1:
                        IMS_PM_LOG11(UR_AttReReg,cscf_get_call_id(msg,0),cscf_get_cseq(msg,0));
                        break;
                    case 2:
                        IMS_PM_LOG11(UR_AttDeRegUe,cscf_get_call_id(msg,0),cscf_get_cseq(msg,0));
                        break;
                }
                //cscf_get_transaction(msg,&x,&y);
                //tmb.register_tmcb(msg,0,TMCB_RESPONSE_OUT,ims_pm_register_cb,(void*)k);
        }
        /* INVITE */
        else if (method.len==s_invite.len && strncasecmp(method.s,s_invite.s,s_invite.len)==0){
            IMS_PM_LOG11(SC_AttSession,cscf_get_call_id(msg,0),cscf_get_cseq(msg,0));
            IMS_PM_LOG21(IC_AttSessionFromOtherNtwkDmn,cscf_get_call_id(msg,0),
                cscf_get_asserted_identity_domain(msg),
                cscf_get_cseq(msg,0));
            IMS_PM_LOG21(IC_AttSessionToOtherNtwkDmn,cscf_get_call_id(msg,0),
                cscf_get_realm_from_ruri(msg),
                cscf_get_cseq(msg,0));
        }else{
            /* Other requests */
            IMS_PM_LOG21(OTHER_Att,cscf_get_call_id(msg,0),method,cscf_get_cseq(msg,0));
        }               
    }else{
        unsigned int code = msg->first_line.u.reply.statuscode;
        method = cscf_get_cseq_method(msg,0);           
        if (method.len==s_invite.len && strncasecmp(method.s,s_invite.s,s_invite.len)==0){
            /* INVITE response */
            if (code<300) IMS_PM_LOG12(SC_SuccSession,cscf_get_call_id(msg,0),cscf_get_cseq(msg,0),code);
            else if (code>=300) {
                IMS_PM_LOG12(SC_FailSession,cscf_get_call_id(msg,0),cscf_get_cseq(msg,0),code);         
                if (code==403) {
                    IMS_PM_LOG22(IC_403SessionFromOtherNtwkDmn,cscf_get_call_id(msg,0),
                        cscf_get_asserted_identity_domain(msg),cscf_get_cseq(msg,0),code);
                    IMS_PM_LOG22(IC_403SessionToOtherNtwkDmn,cscf_get_call_id(msg,0),
                        cscf_get_realm_from_ruri(msg),cscf_get_cseq(msg,0),code);
                }                       
            }                   
        }else{  
            /* Other responses */
            if (code>=200 && code<300) IMS_PM_LOG22(OTHER_Succ,cscf_get_call_id(msg,0),method,cscf_get_cseq(msg,0),code);
            else if (code>=300) IMS_PM_LOG22(OTHER_Fail,cscf_get_call_id(msg,0),method,cscf_get_cseq(msg,0),code);
        }       
    }
    return 1;
}



int ims_pm_post_script(struct sip_msg *msg,void *param)
{
    return 1;
}


void ims_pm_diameter_request(AAAMessage *msg)
{   
    if (!msg) return;   
    switch(msg->applicationId){
        case IMS_Cx:
            switch(msg->commandCode){               
                case IMS_RTR:                                                       
                    IMS_PM_LOG11(UR_AttDeRegHss,Cx_get_session_id(msg),msg->endtoendId);
                    return ;
                    break;
                case IMS_PPR:                                                       
                    IMS_PM_LOG11(UP_AttPPR,Cx_get_session_id(msg),msg->endtoendId);
                    return ;
                    break;
                case IMS_SAR:                                                       
                    IMS_PM_LOG11(UR_AttSAR,Cx_get_session_id(msg),msg->endtoendId);
                    return ;
                    break;
                case IMS_MAR:                                                       
                    IMS_PM_LOG11(MA_AttMAR,Cx_get_session_id(msg),msg->endtoendId);
                    return ;
                    break;
            }
    }   
}

void ims_pm_diameter_answer(AAAMessage *msg)
{
    if (!msg) return;   
    int code=-1;
    if (!Cx_get_result_code(msg,&code)) 
        Cx_get_experimental_result_code(msg,&code);
    switch(msg->applicationId){
        case IMS_Cx:
            switch(msg->commandCode){               
                case IMS_RTA:
                    if (code>=2000 && code<3000) IMS_PM_LOG12(UR_SuccDeRegHss,Cx_get_session_id(msg),msg->endtoendId,code);
                    else IMS_PM_LOG12(UR_FailDeRegHss,Cx_get_session_id(msg),msg->endtoendId,code);
                    break;
                case IMS_PPA:
                    if (code>=2000 && code<3000) IMS_PM_LOG12(UP_SuccPPA,Cx_get_session_id(msg),msg->endtoendId,code);
                    else IMS_PM_LOG12(UP_FailPPA,Cx_get_session_id(msg),msg->endtoendId,code);
                    break;
                case IMS_SAA:
                    if (code>=2000 && code<3000) IMS_PM_LOG12(UR_SuccSAA,Cx_get_session_id(msg),msg->endtoendId,code);
                    else IMS_PM_LOG12(UR_FailSAA,Cx_get_session_id(msg),msg->endtoendId,code);
                    break;
                case IMS_MAA:
                    if (code>=2000 && code<3000) IMS_PM_LOG12(MA_SuccMAA,Cx_get_session_id(msg),msg->endtoendId,code);
                    else IMS_PM_LOG12(MA_FailMAA,Cx_get_session_id(msg),msg->endtoendId,code);
                    break;
            }
    }
}

#endif /* WITH_IMS_PM */

---