all: updated FSF address in GPL text
[sip-router] / modules / ims_icscf / location.c
1 /*
2  * $Id$
3  *
4  * Copyright (C) 2012 Smile Communications, jason.penton@smilecoms.com
5  * Copyright (C) 2012 Smile Communications, richard.good@smilecoms.com
6  * 
7  * The initial version of this code was written by Dragos Vingarzan
8  * (dragos(dot)vingarzan(at)fokus(dot)fraunhofer(dot)de and the
9  * Fruanhofer Institute. It was and still is maintained in a separate
10  * branch of the original SER. We are therefore migrating it to
11  * Kamailio/SR and look forward to maintaining it from here on out.
12  * 2011/2012 Smile Communications, Pty. Ltd.
13  * ported/maintained/improved by 
14  * Jason Penton (jason(dot)penton(at)smilecoms.com and
15  * Richard Good (richard(dot)good(at)smilecoms.com) as part of an 
16  * effort to add full IMS support to Kamailio/SR using a new and
17  * improved architecture
18  * 
19  * NB: Alot of this code was originally part of OpenIMSCore,
20  * FhG Fokus. 
21  * Copyright (C) 2004-2006 FhG Fokus
22  * Thanks for great work! This is an effort to 
23  * break apart the various CSCF functions into logically separate
24  * components. We hope this will drive wider use. We also feel
25  * that in this way the architecture is more complete and thereby easier
26  * to manage in the Kamailio/SR environment
27  *
28  * This file is part of Kamailio, a free SIP server.
29  *
30  * Kamailio is free software; you can redistribute it and/or modify
31  * it under the terms of the GNU General Public License as published by
32  * the Free Software Foundation; either version 2 of the License, or
33  * (at your option) any later version
34  *
35  * Kamailio is distributed in the hope that it will be useful,
36  * but WITHOUT ANY WARRANTY; without even the implied warranty of
37  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
38  * GNU General Public License for more details.
39  *
40  * You should have received a copy of the GNU General Public License 
41  * along with this program; if not, write to the Free Software 
42  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
43  * 
44  */
45
46 #include "location.h"
47 #include "../../action.h" /* run_actions */
48 #include "../../mod_fix.h"
49 #include "cxdx_lir.h"
50
51 extern int route_lir_user_unknown_no; 
52
53 /**
54  * Perform an LIR
55  * @param msg - sip message
56  * @returns 1 on success or 0 on failure
57  */
58 int I_perform_location_information_request(struct sip_msg* msg, char* route, char* str1, char* str2) {
59     str public_identity = {0, 0};
60     int orig = 0;
61     
62     tm_cell_t *t = 0;
63     saved_lir_transaction_t* saved_t;
64     
65     str route_name;
66     
67      cfg_action_t* cfg_action;
68
69      if (fixup_get_svalue(msg, (gparam_t*) route, &route_name) != 0) {
70         LM_ERR("no async route block for assign_server_unreg\n");
71         return -1;
72     }
73     
74     LM_DBG("Looking for route block [%.*s]\n", route_name.len, route_name.s);
75     int ri = route_get(&main_rt, route_name.s);
76     if (ri < 0) {
77         LM_ERR("unable to find route block [%.*s]\n", route_name.len, route_name.s);
78         return -1;
79     }
80     cfg_action = main_rt.rlist[ri];
81     if (cfg_action == NULL) {
82         LM_ERR("empty action lists in route block [%.*s]\n", route_name.len, route_name.s);
83         return -1;
84     }
85     
86     LM_DBG("DBG:I_LIR: Starting ...\n");
87     /* check if we received what we should */
88     if (msg->first_line.type != SIP_REQUEST) {
89         LM_ERR("ERR:I_LIR: The message is not a request\n");
90         return CSCF_RETURN_BREAK;
91     }
92
93     /* check orig uri parameter in topmost Route */
94     if (cscf_has_originating(msg, str1, str2) == CSCF_RETURN_TRUE) {
95         orig = 1;
96         LM_DBG("DBG:I_LIR: orig\n");
97     }
98
99     /* extract data from message */
100     if (orig) {
101         public_identity = cscf_get_asserted_identity(msg, 0);
102     } else {
103         public_identity = cscf_get_public_identity_from_requri(msg);
104     }
105     if (!public_identity.len) {
106         LM_ERR("ERR:I_LIR: Public Identity not found, responding with 400\n");
107         if (orig)
108             cscf_reply_transactional(msg, 400, MSG_400_NO_PUBLIC_FROM);
109         else
110             cscf_reply_transactional(msg, 400, MSG_400_NO_PUBLIC);
111         return CSCF_RETURN_BREAK;
112     }
113     
114     
115     //before we send lets suspend the transaction
116     t = tmb.t_gett();
117     if (t == NULL || t == T_UNDEFINED) {
118         if (tmb.t_newtran(msg) < 0) {
119             LM_ERR("cannot create the transaction for UAR async\n");
120             cscf_reply_transactional(msg, 480, MSG_480_DIAMETER_ERROR);
121             return CSCF_RETURN_BREAK;
122         }
123         t = tmb.t_gett();
124         if (t == NULL || t == T_UNDEFINED) {
125             LM_ERR("cannot lookup the transaction\n");
126             cscf_reply_transactional(msg, 480, MSG_480_DIAMETER_ERROR);
127             return CSCF_RETURN_BREAK;
128         }
129     }
130
131     saved_t = shm_malloc(sizeof (saved_lir_transaction_t));
132     if (!saved_t) {
133         LM_ERR("no more memory trying to save transaction state\n");
134         return CSCF_RETURN_ERROR;
135
136     }
137     memset(saved_t, 0, sizeof (saved_lir_transaction_t));
138     saved_t->act = cfg_action;
139     
140     saved_t->orig = orig;
141     
142     LM_DBG("Setting default AVP return code used for async callbacks to default as ERROR \n");
143     create_lia_return_code(CSCF_RETURN_ERROR);
144     
145     LM_DBG("Suspending SIP TM transaction\n");
146     if (tmb.t_suspend(msg, &saved_t->tindex, &saved_t->tlabel) < 0) {
147         LM_ERR("failed to suspend the TM processing\n");
148         free_saved_lir_transaction_data(saved_t);
149
150         cscf_reply_transactional(msg, 480, MSG_480_DIAMETER_ERROR);
151         return CSCF_RETURN_BREAK;
152     }
153     
154     if (cxdx_send_lir(msg, public_identity, saved_t) != 0) {
155         LM_ERR("ERR:I_LIR: Error sending LIR or LIR time-out\n");
156         tmb.t_cancel_suspend(saved_t->tindex, saved_t->tlabel);
157         free_saved_lir_transaction_data(saved_t);
158         cscf_reply_transactional(msg, 480, MSG_480_DIAMETER_ERROR);
159         
160         if (public_identity.s && !orig)
161         shm_free(public_identity.s); // shm_malloc in cscf_get_public_identity_from_requri              
162         return CSCF_RETURN_BREAK;
163
164     }
165     if (public_identity.s && !orig)
166         shm_free(public_identity.s); // shm_malloc in cscf_get_public_identity_from_requri              
167     
168     //we use async replies therefore we send break and not true when successful
169     return CSCF_RETURN_BREAK;
170 }