provider.c 12.7 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
/*
	belle-sip - SIP (RFC3261) library.
    Copyright (C) 2010  Belledonne Communications SARL

    This program 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 3 of the License, or
    (at your option) any later version.

    This program 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.

    You should have received a copy of the GNU General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
*/

#include "belle_sip_internal.h"
jehan's avatar
jehan committed
20
#include "listeningpoint_internal.h"
21 22 23 24


static void belle_sip_provider_uninit(belle_sip_provider_t *p){
	belle_sip_list_free(p->listeners);
Simon Morlat's avatar
Simon Morlat committed
25
	belle_sip_list_free_with_data(p->lps,belle_sip_object_unref);
26 27
}

28
static void channel_state_changed(belle_sip_channel_listener_t *obj, belle_sip_channel_t *chan, belle_sip_channel_state_t state){
29 30 31 32 33 34 35 36
	belle_sip_io_error_event_t ev;
	if (state == BELLE_SIP_CHANNEL_ERROR) {
		ev.transport=belle_sip_channel_get_transport_name(chan);
		ev.source=(belle_sip_provider_t*)obj;
		ev.port=chan->local_port;
		ev.host=chan->local_ip;
		BELLE_SIP_PROVIDER_INVOKE_LISTENERS(ev.source,process_io_error,&ev);
	}
37 38
}

Simon Morlat's avatar
Simon Morlat committed
39 40 41 42 43 44 45 46 47
static void belle_sip_provider_dispatch_message(belle_sip_provider_t *prov, belle_sip_message_t *msg){
	if (belle_sip_message_is_request(msg)){
		belle_sip_request_event_t event;
		event.source=prov;
		event.server_transaction=NULL;
		event.request=(belle_sip_request_t*)msg;
		event.dialog=NULL;
		BELLE_SIP_PROVIDER_INVOKE_LISTENERS(prov,process_request_event,&event);
	}else{
48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66
		belle_sip_client_transaction_t *t;
		t=belle_sip_provider_find_matching_client_transaction(prov,(belle_sip_response_t*)msg);
		/*
		 * If a transaction is found, pass it to the transaction and let it decide what to do.
		 * Else notifies directly.
		 */
		if (t){
			/*since the add_response may indirectly terminate the transaction, we need to guarantee the transaction is not freed
			 * until full completion*/
			belle_sip_object_ref(t);
			belle_sip_client_transaction_add_response(t,(belle_sip_response_t*)msg);
			belle_sip_object_unref(t);
		}else{
			belle_sip_response_event_t event;
			event.source=prov;
			event.client_transaction=NULL;
			event.dialog=NULL;
			event.response=(belle_sip_response_t*)msg;
			BELLE_SIP_PROVIDER_INVOKE_LISTENERS(prov,process_response_event,&event);
67
		}
Simon Morlat's avatar
Simon Morlat committed
68
	}
69
	belle_sip_object_unref(msg);
Simon Morlat's avatar
Simon Morlat committed
70 71
}

jehan's avatar
jehan committed
72

Simon Morlat's avatar
Simon Morlat committed
73

74 75 76
static void fix_outgoing_via(belle_sip_provider_t *p, belle_sip_channel_t *chan, belle_sip_message_t *msg){
	belle_sip_header_via_t *via=BELLE_SIP_HEADER_VIA(belle_sip_message_get_header(msg,"via"));
	belle_sip_parameters_set_parameter(BELLE_SIP_PARAMETERS(via),"rport",NULL);
Simon Morlat's avatar
Simon Morlat committed
77
	char token[7]="fixme";
78 79 80 81 82 83 84 85 86 87
	if (belle_sip_header_via_get_host(via)==NULL){
		const char *local_ip;
		int local_port;
		local_ip=belle_sip_channel_get_local_address(chan,&local_port);
		belle_sip_header_via_set_host(via,local_ip);
		belle_sip_header_via_set_port(via,local_port);
		belle_sip_header_via_set_protocol(via,"SIP/2.0");
		belle_sip_header_via_set_transport(via,belle_sip_channel_get_transport_name(chan));
	}
	if (belle_sip_header_via_get_branch(via)==NULL){
Simon Morlat's avatar
Simon Morlat committed
88 89
		/*FIXME: should not be set random here: but rather a hash of message invariants*/
		char *branchid=belle_sip_strdup_printf(BELLE_SIP_BRANCH_MAGIC_COOKIE ".%s",token);
90 91 92 93
		belle_sip_header_via_set_branch(via,branchid);
		belle_sip_free(branchid);
	}
}
jehan's avatar
jehan committed
94
/*
Simon Morlat's avatar
Simon Morlat committed
95 96 97 98 99 100 101
static void belle_sip_provider_read_message(belle_sip_provider_t *prov, belle_sip_channel_t *chan){
	char buffer[belle_sip_network_buffer_size];
	int err;
	err=belle_sip_channel_recv(chan,buffer,sizeof(buffer));
	if (err>0){
		belle_sip_message_t *msg;
		buffer[err]='\0';
102
		belle_sip_message("provider %p read message from %s:%i\n%s",prov,chan->peer_name,chan->peer_port,buffer);
Simon Morlat's avatar
Simon Morlat committed
103 104
		msg=belle_sip_message_parse(buffer);
		if (msg){
105
			if (belle_sip_message_is_request(msg)) fix_incoming_via(BELLE_SIP_REQUEST(msg),chan->peer);
Simon Morlat's avatar
Simon Morlat committed
106 107 108 109 110 111
			belle_sip_provider_dispatch_message(prov,msg);
		}else{
			belle_sip_error("Could not parse this message.");
		}
	}
}
jehan's avatar
jehan committed
112
*/
Simon Morlat's avatar
Simon Morlat committed
113 114
static int channel_on_event(belle_sip_channel_listener_t *obj, belle_sip_channel_t *chan, unsigned int revents){
	if (revents & BELLE_SIP_EVENT_READ){
jehan's avatar
jehan committed
115
		belle_sip_provider_dispatch_message(BELLE_SIP_PROVIDER(obj),belle_sip_channel_pick_message(chan));
Simon Morlat's avatar
Simon Morlat committed
116 117 118 119
	}
	return 0;
}

120
static void channel_on_sending(belle_sip_channel_listener_t *obj, belle_sip_channel_t *chan, belle_sip_message_t *msg){
jehan's avatar
jehan committed
121
	belle_sip_header_contact_t* contact = (belle_sip_header_contact_t*)belle_sip_message_get_header(msg,"Contact");
jehan's avatar
jehan committed
122
	belle_sip_header_content_length_t* content_lenght = (belle_sip_header_content_length_t*)belle_sip_message_get_header(msg,"Content-Length");
jehan's avatar
jehan committed
123 124
	belle_sip_uri_t* contact_uri;
	/*probably better to be in channel*/
125
	fix_outgoing_via((belle_sip_provider_t*)obj,chan,msg);
Simon Morlat's avatar
Simon Morlat committed
126 127

	/* fix the contact if empty*/
jehan's avatar
jehan committed
128 129 130 131 132 133 134 135 136 137 138 139 140
	if (!(contact_uri =belle_sip_header_address_get_uri((belle_sip_header_address_t*)contact))) {
		contact_uri = belle_sip_uri_new();
		belle_sip_header_address_set_uri((belle_sip_header_address_t*)contact,contact_uri);
	}
	if (!belle_sip_uri_get_host(contact_uri)) {
		belle_sip_uri_set_host(contact_uri,chan->local_ip);
	}
	if (belle_sip_uri_get_transport_param(contact_uri) == NULL && strcasecmp("udp",belle_sip_channel_get_transport_name(chan))!=0) {
		belle_sip_uri_set_transport_param(contact_uri,belle_sip_channel_get_transport_name_lower_case(chan));
	}
	if (belle_sip_uri_get_port(contact_uri) == 0 && chan->local_port!=5060) {
		belle_sip_uri_set_port(contact_uri,chan->local_port);
	}
jehan's avatar
jehan committed
141 142 143 144
	if (!content_lenght && strcasecmp("udp",belle_sip_channel_get_transport_name(chan))!=0) {
		content_lenght = belle_sip_header_content_length_create(0);
		belle_sip_message_add_header(msg,(belle_sip_header_t*)content_lenght);
	}
145 146
}

147
BELLE_SIP_IMPLEMENT_INTERFACE_BEGIN(belle_sip_provider_t,belle_sip_channel_listener_t)
Simon Morlat's avatar
Simon Morlat committed
148
	channel_state_changed,
149 150
	channel_on_event,
	channel_on_sending
151 152 153 154
BELLE_SIP_IMPLEMENT_INTERFACE_END

BELLE_SIP_DECLARE_IMPLEMENTED_INTERFACES_1(belle_sip_provider_t,belle_sip_channel_listener_t);
	
Simon Morlat's avatar
Simon Morlat committed
155
BELLE_SIP_INSTANCIATE_VPTR(belle_sip_provider_t,belle_sip_object_t,belle_sip_provider_uninit,NULL,NULL,FALSE);
Simon Morlat's avatar
Simon Morlat committed
156

157
belle_sip_provider_t *belle_sip_provider_new(belle_sip_stack_t *s, belle_sip_listening_point_t *lp){
Simon Morlat's avatar
Simon Morlat committed
158
	belle_sip_provider_t *p=belle_sip_object_new(belle_sip_provider_t);
159
	p->stack=s;
160 161 162 163 164
	belle_sip_provider_add_listening_point(p,lp);
	return p;
}

int belle_sip_provider_add_listening_point(belle_sip_provider_t *p, belle_sip_listening_point_t *lp){
Simon Morlat's avatar
Simon Morlat committed
165
	p->lps=belle_sip_list_append(p->lps,belle_sip_object_ref(lp));
166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182
	return 0;
}

belle_sip_listening_point_t *belle_sip_provider_get_listening_point(belle_sip_provider_t *p, const char *transport){
	belle_sip_list_t *l;
	for(l=p->lps;l!=NULL;l=l->next){
		belle_sip_listening_point_t *lp=(belle_sip_listening_point_t*)l->data;
		if (strcasecmp(belle_sip_listening_point_get_transport(lp),transport)==0)
			return lp;
	}
	return NULL;
}

const belle_sip_list_t *belle_sip_provider_get_listening_points(belle_sip_provider_t *p){
	return p->lps;
}

183 184
void belle_sip_provider_add_sip_listener(belle_sip_provider_t *p, belle_sip_listener_t *l){
	p->listeners=belle_sip_list_append(p->listeners,l);
185 186
}

187 188
void belle_sip_provider_remove_sip_listener(belle_sip_provider_t *p, belle_sip_listener_t *l){
	p->listeners=belle_sip_list_remove(p->listeners,l);
189 190
}

191 192
belle_sip_header_call_id_t * belle_sip_provider_create_call_id(belle_sip_provider_t *prov){
	belle_sip_header_call_id_t *cid=belle_sip_header_call_id_new();
193 194
	char tmp[11];
	belle_sip_header_call_id_set_call_id(cid,belle_sip_random_token(tmp,sizeof(tmp)));
195 196 197
	return cid;
}

Simon Morlat's avatar
Simon Morlat committed
198
belle_sip_client_transaction_t *belle_sip_provider_create_client_transaction(belle_sip_provider_t *prov, belle_sip_request_t *req){
199 200
	const char *method=belle_sip_request_get_method(req);
	if (strcmp(method,"INVITE")==0)
Simon Morlat's avatar
Simon Morlat committed
201
		return (belle_sip_client_transaction_t*)belle_sip_ict_new(prov,req);
202 203 204 205 206
	else if (strcmp(method,"ACK")==0){
		belle_sip_error("belle_sip_provider_create_client_transaction() cannot be used for ACK requests.");
		return NULL;
	}
	else return (belle_sip_client_transaction_t*)belle_sip_nict_new(prov,req);
207 208
}

Simon Morlat's avatar
Simon Morlat committed
209 210 211 212 213
belle_sip_server_transaction_t *belle_sip_provider_create_server_transaction(belle_sip_provider_t *prov, belle_sip_request_t *req){
	if (strcmp(belle_sip_request_get_method(req),"INVITE")==0)
		return (belle_sip_server_transaction_t*)belle_sip_ist_new(prov,req);
	else 
		return (belle_sip_server_transaction_t*)belle_sip_nist_new(prov,req);
214 215 216 217 218 219
}

belle_sip_stack_t *belle_sip_provider_get_sip_stack(belle_sip_provider_t *p){
	return p->stack;
}

220 221 222 223 224 225 226 227 228 229 230 231 232 233 234
belle_sip_channel_t * belle_sip_provider_get_channel(belle_sip_provider_t *p, const char *name, int port, const char *transport){
	belle_sip_list_t *l;
	belle_sip_listening_point_t *candidate=NULL,*lp;
	belle_sip_channel_t *chan;
	for(l=p->lps;l!=NULL;l=l->next){
		lp=(belle_sip_listening_point_t*)l->data;
		if (strcasecmp(belle_sip_listening_point_get_transport(lp),transport)==0){
			chan=belle_sip_listening_point_get_channel(lp,name,port);
			if (chan) return chan;
			candidate=lp;
		}
	}
	if (candidate){
		chan=belle_sip_listening_point_create_channel(candidate,name,port);
		if (chan==NULL) belle_sip_error("Could not create channel to %s:%s:%i",transport,name,port);
Simon Morlat's avatar
Simon Morlat committed
235
		else belle_sip_channel_add_listener(chan,BELLE_SIP_CHANNEL_LISTENER(p));
236 237 238
		return chan;
	}
	belle_sip_error("No listening point matching for transport %s",transport);
239
	return NULL;
Simon Morlat's avatar
wip  
Simon Morlat committed
240 241
}

242
void belle_sip_provider_send_request(belle_sip_provider_t *p, belle_sip_request_t *req){
243 244 245 246
	belle_sip_hop_t hop={0};
	belle_sip_channel_t *chan;
	belle_sip_stack_get_next_hop(p->stack,req,&hop);
	chan=belle_sip_provider_get_channel(p,hop.host, hop.port, hop.transport);
247 248 249
	if (chan) {
		belle_sip_channel_queue_message(chan,BELLE_SIP_MESSAGE(req));
	}
250 251
}

Simon Morlat's avatar
wip  
Simon Morlat committed
252
void belle_sip_provider_send_response(belle_sip_provider_t *p, belle_sip_response_t *resp){
253 254 255 256 257
	belle_sip_hop_t hop;
	belle_sip_channel_t *chan;
	belle_sip_response_get_return_hop(resp,&hop);
	chan=belle_sip_provider_get_channel(p,hop.host, hop.port, hop.transport);
	if (chan) belle_sip_channel_queue_message(chan,BELLE_SIP_MESSAGE(resp));
258 259
}

260

261 262 263
/*private provider API*/

void belle_sip_provider_set_transaction_terminated(belle_sip_provider_t *p, belle_sip_transaction_t *t){
264 265 266 267 268 269 270 271
	belle_sip_transaction_terminated_event_t ev;
	
	BELLE_SIP_OBJECT_VPTR(t,belle_sip_transaction_t)->on_terminate(t);
	ev.source=t->provider;
	ev.transaction=t;
	ev.is_server_transaction=BELLE_SIP_IS_INSTANCE_OF(t,belle_sip_server_transaction_t);
	BELLE_SIP_PROVIDER_INVOKE_LISTENERS(t->provider,process_transaction_terminated,&ev);
	if (!ev.is_server_transaction){
Simon Morlat's avatar
Simon Morlat committed
272 273 274 275 276 277
		belle_sip_provider_remove_client_transaction(p,(belle_sip_client_transaction_t*)t);
	}
}

void belle_sip_provider_add_client_transaction(belle_sip_provider_t *prov, belle_sip_client_transaction_t *t){
	prov->client_transactions=belle_sip_list_prepend(prov->client_transactions,belle_sip_object_ref(t));
Simon Morlat's avatar
wip  
Simon Morlat committed
278
}
279

280 281 282 283 284 285 286 287 288 289 290 291 292
struct client_transaction_matcher{
	const char *branchid;
	const char *method;
};

static int client_transaction_match(const void *p_tr, const void *p_matcher){
	belle_sip_client_transaction_t *tr=(belle_sip_client_transaction_t*)p_tr;
	struct client_transaction_matcher *matcher=(struct client_transaction_matcher*)p_matcher;
	const char *req_method=belle_sip_request_get_method(tr->base.request);
	if (strcmp(matcher->branchid,tr->base.branch_id)==0 && strcmp(matcher->method,req_method)==0) return 0;
	return -1;
}

Simon Morlat's avatar
Simon Morlat committed
293 294
belle_sip_client_transaction_t * belle_sip_provider_find_matching_client_transaction(belle_sip_provider_t *prov, 
                                                                                   belle_sip_response_t *resp){
295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315
	struct client_transaction_matcher matcher;
	belle_sip_header_via_t *via=(belle_sip_header_via_t*)belle_sip_message_get_header((belle_sip_message_t*)resp,"via");
	belle_sip_header_cseq_t *cseq=(belle_sip_header_cseq_t*)belle_sip_message_get_header((belle_sip_message_t*)resp,"cseq");
	belle_sip_client_transaction_t *ret=NULL;
	belle_sip_list_t *elem;
	if (via==NULL){
		belle_sip_warning("Response has no via.");
		return NULL;
	}
	if (via==NULL){
		belle_sip_warning("Response has no cseq.");
		return NULL;
	}
	matcher.branchid=belle_sip_header_via_get_branch(via);
	matcher.method=belle_sip_header_cseq_get_method(cseq);
	elem=belle_sip_list_find_custom(prov->client_transactions,client_transaction_match,&matcher);
	if (elem){
		ret=(belle_sip_client_transaction_t*)elem->data;
		belle_sip_message("Found transaction matching response.");
	}
	return ret;
Simon Morlat's avatar
Simon Morlat committed
316 317
}

318
void belle_sip_provider_remove_client_transaction(belle_sip_provider_t *prov, belle_sip_client_transaction_t *t){	
Simon Morlat's avatar
Simon Morlat committed
319
	prov->client_transactions=belle_sip_list_remove(prov->client_transactions,t);
320
	belle_sip_object_unref(t);
Simon Morlat's avatar
Simon Morlat committed
321
}