friend.c 43.8 KB
Newer Older
aymeric's avatar
aymeric committed
1 2 3 4
/***************************************************************************
 *            friend.c
 *
 *  Sat May 15 15:25:16 2004
5
 *  Copyright  2004-2009  Simon Morlat
aymeric's avatar
aymeric committed
6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28
 *  Email
 ****************************************************************************/

/*
 *  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 2 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 Library General Public License for more details.
 *
 *  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 "linphonecore.h"
#include "private.h"
#include "lpconfig.h"

29 30 31 32 33 34 35 36 37 38 39 40 41 42 43
#ifdef FRIENDS_SQL_STORAGE_ENABLED
#ifndef _WIN32
#if !defined(ANDROID) && !defined(__QNXNTO__)
#	include <langinfo.h>
#	include <iconv.h>
#	include <string.h>
#endif
#else
#include <Windows.h>
#endif

#define MAX_PATH_SIZE 1024
#include "sqlite3.h"
#endif

aymeric's avatar
aymeric committed
44 45 46
const char *linphone_online_status_to_string(LinphoneOnlineStatus ss){
	const char *str=NULL;
	switch(ss){
47
		case LinphoneStatusOnline:
aymeric's avatar
aymeric committed
48 49
		str=_("Online");
		break;
50
		case LinphoneStatusBusy:
aymeric's avatar
aymeric committed
51 52
		str=_("Busy");
		break;
53
		case LinphoneStatusBeRightBack:
aymeric's avatar
aymeric committed
54 55
		str=_("Be right back");
		break;
56
		case LinphoneStatusAway:
aymeric's avatar
aymeric committed
57 58
		str=_("Away");
		break;
59
		case LinphoneStatusOnThePhone:
aymeric's avatar
aymeric committed
60 61
		str=_("On the phone");
		break;
62
		case LinphoneStatusOutToLunch:
aymeric's avatar
aymeric committed
63 64
		str=_("Out to lunch");
		break;
65
		case LinphoneStatusDoNotDisturb:
aymeric's avatar
aymeric committed
66 67
		str=_("Do not disturb");
		break;
68
		case LinphoneStatusMoved:
aymeric's avatar
aymeric committed
69 70
		str=_("Moved");
		break;
71
		case LinphoneStatusAltService:
aymeric's avatar
aymeric committed
72 73
		str=_("Using another messaging service");
		break;
74
		case LinphoneStatusOffline:
aymeric's avatar
aymeric committed
75 76
		str=_("Offline");
		break;
77
		case LinphoneStatusPending:
aymeric's avatar
aymeric committed
78 79
		str=_("Pending");
		break;
80 81
		case LinphoneStatusVacation:
		str=_("Vacation");
aymeric's avatar
aymeric committed
82
		default:
Gautier Pelloux-Prayer's avatar
Gautier Pelloux-Prayer committed
83
		str=_("Unknown status");
aymeric's avatar
aymeric committed
84 85 86 87
	}
	return str;
}

Simon Morlat's avatar
Simon Morlat committed
88
static int friend_compare(const void * a, const void * b){
89 90
	LinphoneAddress *fa=((LinphoneFriend*)a)->uri;
	LinphoneAddress *fb=((LinphoneFriend*)b)->uri;
91
	if (linphone_address_weak_equal(fa,fb)) return 0;
Simon Morlat's avatar
Simon Morlat committed
92
	return 1;
aymeric's avatar
aymeric committed
93 94 95
}


Ghislain MARY's avatar
Ghislain MARY committed
96
MSList *linphone_find_friend_by_address(MSList *fl, const LinphoneAddress *addr, LinphoneFriend **lf){
aymeric's avatar
aymeric committed
97 98 99
	MSList *res=NULL;
	LinphoneFriend dummy;
	if (lf!=NULL) *lf=NULL;
100
	dummy.uri=(LinphoneAddress*)addr;
aymeric's avatar
aymeric committed
101 102 103 104 105 106
	res=ms_list_find_custom(fl,friend_compare,&dummy);
	if (lf!=NULL && res!=NULL) *lf=(LinphoneFriend*)res->data;
	return res;
}

void __linphone_friend_do_subscribe(LinphoneFriend *fr){
Simon Morlat's avatar
Simon Morlat committed
107
	LinphoneCore *lc=fr->lc;
108

109
	if (fr->outsub==NULL){
aymeric's avatar
aymeric committed
110
		/* people for which we don't have yet an answer should appear as offline */
111
		fr->presence=NULL;
112
		/*
113
		if (fr->lc->vtable.notify_recv)
114
			fr->lc->vtable.notify_recv(fr->lc,(LinphoneFriend*)fr);
115
		 */
116 117 118 119
	}else{
		sal_op_release(fr->outsub);
		fr->outsub=NULL;
	}
Simon Morlat's avatar
Simon Morlat committed
120 121
	fr->outsub=sal_op_new(lc->sal);
	linphone_configure_op(lc,fr->outsub,fr->uri,NULL,TRUE);
Simon Morlat's avatar
Simon Morlat committed
122
	sal_subscribe_presence(fr->outsub,NULL,NULL,lp_config_get_int(lc->config,"sip","subscribe_expires",600));
123
	fr->subscribe_active=TRUE;
aymeric's avatar
aymeric committed
124 125
}

126
LinphoneFriend * linphone_friend_new(void){
127 128 129 130
	LinphoneFriend *obj = belle_sip_object_new(LinphoneFriend);
	obj->pol = LinphoneSPAccept;
	obj->presence = NULL;
	obj->subscribe = TRUE;
131
	obj->vcard = NULL;
132
	obj->storage_id = 0;
133
	return obj;
aymeric's avatar
aymeric committed
134 135
}

Ghislain MARY's avatar
Ghislain MARY committed
136
LinphoneFriend *linphone_friend_new_with_address(const char *addr){
jehan's avatar
jehan committed
137
	LinphoneAddress* linphone_address = linphone_address_new(addr);
Sylvain Berfini's avatar
Sylvain Berfini committed
138 139
	LinphoneFriend *fr;

jehan's avatar
jehan committed
140 141 142 143
	if (linphone_address == NULL) {
		ms_error("Cannot create friend for address [%s]",addr?addr:"null");
		return NULL;
	}
Sylvain Berfini's avatar
Sylvain Berfini committed
144
	fr=linphone_friend_new();
Ghislain MARY's avatar
Ghislain MARY committed
145
	linphone_friend_set_address(fr,linphone_address);
146
	linphone_address_unref(linphone_address);
aymeric's avatar
aymeric committed
147 148 149
	return fr;
}

Simon Morlat's avatar
Simon Morlat committed
150
void linphone_friend_set_user_data(LinphoneFriend *lf, void *data){
151
	lf->user_data=data;
Simon Morlat's avatar
Simon Morlat committed
152 153 154
}

void* linphone_friend_get_user_data(const LinphoneFriend *lf){
155
	return lf->user_data;
Simon Morlat's avatar
Simon Morlat committed
156 157
}

158 159
bool_t linphone_friend_in_list(const LinphoneFriend *lf) {
	return lf->friend_list != NULL;
160 161
}

smorlat's avatar
smorlat committed
162
void linphone_core_interpret_friend_uri(LinphoneCore *lc, const char *uri, char **result){
163
	LinphoneAddress *fr=NULL;
164
	*result=NULL;
165
	fr=linphone_address_new(uri);
166
	if (fr==NULL){
smorlat's avatar
smorlat committed
167 168
		char *tmp=NULL;
		if (strchr(uri,'@')!=NULL){
169
			LinphoneAddress *u;
smorlat's avatar
smorlat committed
170 171
			/*try adding sip:*/
			tmp=ms_strdup_printf("sip:%s",uri);
172
			u=linphone_address_new(tmp);
173 174 175
			if (u!=NULL){
				*result=tmp;
			}
smorlat's avatar
smorlat committed
176 177
		}else if (lc->default_proxy!=NULL){
			/*try adding domain part from default current proxy*/
178
			LinphoneAddress * id=linphone_address_new(linphone_core_get_identity(lc));
179
			if ((id!=NULL) && (uri[0] != '\0')){
180
				linphone_address_set_display_name(id,NULL);
181 182
				linphone_address_set_username(id,uri);
				*result=linphone_address_as_string(id);
183
				linphone_address_unref(id);
smorlat's avatar
smorlat committed
184 185
			}
		}
186
		if (*result){
smorlat's avatar
smorlat committed
187
			/*looks good */
188 189 190 191
			ms_message("%s interpreted as %s",uri,*result);
		}else{
			ms_warning("Fail to interpret friend uri %s",uri);
		}
jehan's avatar
jehan committed
192 193
	}else {
		*result=linphone_address_as_string(fr);
194
		linphone_address_unref(fr);
jehan's avatar
jehan committed
195
	}
smorlat's avatar
smorlat committed
196
}
aymeric's avatar
aymeric committed
197

198 199 200 201
const LinphoneAddress *linphone_friend_get_address(const LinphoneFriend *lf){
	return lf->uri;
}

202
int linphone_friend_set_address(LinphoneFriend *lf, const LinphoneAddress *addr){
203
	LinphoneAddress *fr = linphone_address_clone(addr);
204
	LinphoneVcard *vcard = NULL;
205

206
	linphone_address_clean(fr);
207
	if (lf->uri != NULL) linphone_address_unref(lf->uri);
208
	lf->uri = fr;
209

210 211 212 213
	vcard = linphone_friend_get_vcard(lf);
	if (vcard) {
		linphone_vcard_edit_main_sip_address(vcard, linphone_address_as_string_uri_only(fr));
	}
214

aymeric's avatar
aymeric committed
215 216 217
	return 0;
}

218 219 220 221 222
void linphone_friend_add_address(LinphoneFriend *lf, const LinphoneAddress *addr) {
	LinphoneVcard *vcard = NULL;
	if (!lf || !addr) {
		return;
	}
223 224 225 226 227
	if (lf->uri == NULL) {
		LinphoneAddress *fr = linphone_address_clone(addr);
		linphone_address_clean(fr);
		lf->uri = fr;
	}
228

229 230 231 232
	vcard = linphone_friend_get_vcard(lf);
	if (!vcard) {
		return;
	}
233

234 235 236
	linphone_vcard_add_sip_address(vcard, linphone_address_as_string_uri_only(addr));
}

Sylvain Berfini's avatar
Sylvain Berfini committed
237
MSList* linphone_friend_get_addresses(LinphoneFriend *lf) {
238 239 240
	LinphoneVcard *vcard = NULL;
	MSList *sipAddresses = NULL;
	MSList *addresses = NULL;
Sylvain Berfini's avatar
Sylvain Berfini committed
241
	MSList *iterator = NULL;
242

243 244 245
	if (!lf) {
		return NULL;
	}
246

247 248 249 250
	vcard = linphone_friend_get_vcard(lf);
	if (!vcard) {
		return NULL;
	}
251

252
	sipAddresses = linphone_vcard_get_sip_addresses(vcard);
Sylvain Berfini's avatar
Sylvain Berfini committed
253 254 255
	iterator = sipAddresses;
	while (iterator) {
		const char *sipAddress = (const char *)iterator->data;
256 257
		LinphoneAddress *addr = linphone_address_new(sipAddress);
		if (addr) {
Sylvain Berfini's avatar
Sylvain Berfini committed
258
			addresses = ms_list_append(addresses, addr);
259
		}
Sylvain Berfini's avatar
Sylvain Berfini committed
260
		iterator = ms_list_next(iterator);
261
	}
Sylvain Berfini's avatar
Sylvain Berfini committed
262
	if (sipAddresses) ms_list_free(sipAddresses);
263 264 265 266 267 268 269 270
	return addresses;
}

void linphone_friend_remove_address(LinphoneFriend *lf, const LinphoneAddress *addr) {
	LinphoneVcard *vcard = NULL;
	if (!lf || !addr) {
		return;
	}
271

272 273 274 275
	vcard = linphone_friend_get_vcard(lf);
	if (!vcard) {
		return;
	}
276

277 278 279 280 281 282 283 284
	linphone_vcard_remove_sip_address(vcard, linphone_address_as_string_uri_only(addr));
}

void linphone_friend_add_phone_number(LinphoneFriend *lf, const char *phone) {
	LinphoneVcard *vcard = NULL;
	if (!lf || !phone) {
		return;
	}
285

286 287 288 289
	vcard = linphone_friend_get_vcard(lf);
	if (!vcard) {
		return;
	}
290

291 292 293
	linphone_vcard_add_phone_number(vcard, phone);
}

Sylvain Berfini's avatar
Sylvain Berfini committed
294
MSList* linphone_friend_get_phone_numbers(LinphoneFriend *lf) {
295
	LinphoneVcard *vcard = NULL;
296

297 298 299
	if (!lf) {
		return NULL;
	}
300

301 302 303 304
	vcard = linphone_friend_get_vcard(lf);
	if (!vcard) {
		return NULL;
	}
305

306 307 308 309 310 311 312 313
	return linphone_vcard_get_phone_numbers(vcard);
}

void linphone_friend_remove_phone_number(LinphoneFriend *lf, const char *phone) {
	LinphoneVcard *vcard = NULL;
	if (!lf || !phone) {
		return;
	}
314

315 316 317 318
	vcard = linphone_friend_get_vcard(lf);
	if (!vcard) {
		return;
	}
319

320 321 322
	linphone_vcard_remove_phone_number(vcard, phone);
}

aymeric's avatar
aymeric committed
323
int linphone_friend_set_name(LinphoneFriend *lf, const char *name){
324
	LinphoneAddress *fr = lf->uri;
325
	LinphoneVcard *vcard = NULL;
326
	bool_t vcard_created = FALSE;
327

328 329 330
	vcard = linphone_friend_get_vcard(lf);
	if (!vcard) {
		linphone_friend_create_vcard(lf, name);
331
		vcard = linphone_friend_get_vcard(lf);
332 333
		vcard_created = TRUE;
	}
334
	if (vcard) {
335
		linphone_vcard_set_full_name(vcard, name);
336 337 338 339
		if (fr && vcard_created) { // SIP address wasn't set yet, let's do it
			linphone_vcard_edit_main_sip_address(vcard, linphone_address_as_string_uri_only(fr));
		}
	}
340

341
	if (!fr && !vcard) {
342 343
		ms_warning("linphone_friend_set_address() must be called before linphone_friend_set_name() to be able to set display name.");
		return -1;
344 345
	} else if (fr) {
		linphone_address_set_display_name(fr, name);
346
	}
347

aymeric's avatar
aymeric committed
348 349 350
	return 0;
}

jehan's avatar
jehan committed
351
int linphone_friend_enable_subscribes(LinphoneFriend *fr, bool_t val){
aymeric's avatar
aymeric committed
352 353 354 355
	fr->subscribe=val;
	return 0;
}

Sylvain Berfini's avatar
Sylvain Berfini committed
356
int linphone_friend_set_inc_subscribe_policy(LinphoneFriend *fr, LinphoneSubscribePolicy pol) {
aymeric's avatar
aymeric committed
357 358 359 360
	fr->pol=pol;
	return 0;
}

361
void linphone_friend_notify(LinphoneFriend *lf, LinphonePresenceModel *presence){
362 363 364 365 366 367 368 369 370
	MSList *elem;
	if (lf->insubs){
		char *addr=linphone_address_as_string(linphone_friend_get_address(lf));
		ms_message("Want to notify %s",addr);
		ms_free(addr);
	}
	for(elem=lf->insubs; elem!=NULL; elem=elem->next){
		SalOp *op = (SalOp*)elem->data;
		sal_notify_presence(op,(SalPresenceModel *)presence);
aymeric's avatar
aymeric committed
371 372 373
	}
}

374
void linphone_friend_add_incoming_subscription(LinphoneFriend *lf, SalOp *op){
375
	/*ownership of the op is transfered from sal to the LinphoneFriend*/
376 377 378 379
	lf->insubs = ms_list_append(lf->insubs, op);
}

void linphone_friend_remove_incoming_subscription(LinphoneFriend *lf, SalOp *op){
380 381
	if (ms_list_find(lf->insubs, op)){
		sal_op_release(op);
Simon Morlat's avatar
Simon Morlat committed
382
		lf->insubs = ms_list_remove(lf->insubs, op);
383
	}
384

385 386
}

aymeric's avatar
aymeric committed
387
static void linphone_friend_unsubscribe(LinphoneFriend *lf){
388 389
	if (lf->outsub!=NULL) {
		sal_unsubscribe(lf->outsub);
aymeric's avatar
aymeric committed
390
	}
391 392
	/* for friend list there is no necessary outsub*/
	lf->subscribe_active=FALSE;
aymeric's avatar
aymeric committed
393 394
}

395
void linphone_friend_invalidate_subscription(LinphoneFriend *lf){
396 397
	LinphoneCore *lc=lf->lc;

Simon Morlat's avatar
Simon Morlat committed
398 399 400 401 402
	if (lf->outsub!=NULL) {
		sal_op_release(lf->outsub);
		lf->outsub=NULL;
		lf->subscribe_active=FALSE;
	}
403 404 405 406

	/* Notify application that we no longer know the presence activity */
	if (lf->presence != NULL) {
		linphone_presence_model_unref(lf->presence);
407 408
		lf->presence = linphone_presence_model_new_with_activity(LinphonePresenceActivityOffline,"unknown activity");
		linphone_core_notify_notify_presence_received(lc,lf);
409 410
	}

411
	lf->initial_subscribes_sent=FALSE;
Simon Morlat's avatar
Simon Morlat committed
412 413
}

414
void linphone_friend_close_subscriptions(LinphoneFriend *lf){
aymeric's avatar
aymeric committed
415
	linphone_friend_unsubscribe(lf);
416
	ms_list_for_each(lf->insubs, (MSIterateFunc) sal_notify_presence_close);
417
	lf->insubs = ms_list_free_with_data(lf->insubs, (MSIterateFunc)sal_op_release);
418 419
}

420
static void _linphone_friend_release_ops(LinphoneFriend *lf){
421
	lf->insubs = ms_list_free_with_data(lf->insubs, (MSIterateFunc) sal_op_release);
422 423 424 425
	if (lf->outsub){
		sal_op_release(lf->outsub);
		lf->outsub=NULL;
	}
426 427 428 429
}

static void _linphone_friend_destroy(LinphoneFriend *lf){
	_linphone_friend_release_ops(lf);
430
	if (lf->presence != NULL) linphone_presence_model_unref(lf->presence);
431
	if (lf->uri!=NULL) linphone_address_unref(lf->uri);
432
	if (lf->info!=NULL) buddy_info_free(lf->info);
433
	if (lf->vcard != NULL) linphone_vcard_free(lf->vcard);
aymeric's avatar
aymeric committed
434 435
}

436 437 438 439 440 441 442 443 444 445 446
static belle_sip_error_code _linphone_friend_marshall(belle_sip_object_t *obj, char* buff, size_t buff_size, size_t *offset) {
	LinphoneFriend *lf = (LinphoneFriend*)obj;
	belle_sip_error_code err = BELLE_SIP_OK;
	if (lf->uri){
		char *tmp = linphone_address_as_string(lf->uri);
		err = belle_sip_snprintf(buff, buff_size, offset, "%s", tmp);
		ms_free(tmp);
	}
	return err;
}

447
const char * linphone_friend_get_name(const LinphoneFriend *lf) {
448 449 450 451 452 453 454
	if (lf && lf->vcard) {
		return linphone_vcard_get_full_name(lf->vcard);
	} else if (lf && lf->uri) {
		LinphoneAddress *fr = lf->uri;
		return linphone_address_get_display_name(fr);
	}
	return NULL;
455 456
}

aymeric's avatar
aymeric committed
457 458 459 460 461 462 463 464 465
bool_t linphone_friend_get_send_subscribe(const LinphoneFriend *lf){
	return lf->subscribe;
}

LinphoneSubscribePolicy linphone_friend_get_inc_subscribe_policy(const LinphoneFriend *lf){
	return lf->pol;
}

LinphoneOnlineStatus linphone_friend_get_status(const LinphoneFriend *lf){
466 467
	LinphoneOnlineStatus online_status = LinphoneStatusOffline;
	LinphonePresenceBasicStatus basic_status = LinphonePresenceBasicStatusClosed;
468
	LinphonePresenceActivity *activity = NULL;
469
	const char *description = NULL;
470 471 472 473
	unsigned int nb_activities = 0;

	if (lf->presence != NULL) {
		basic_status = linphone_presence_model_get_basic_status(lf->presence);
474
		nb_activities = linphone_presence_model_get_nb_activities(lf->presence);
475 476 477 478 479 480 481 482 483 484
		online_status = (basic_status == LinphonePresenceBasicStatusOpen) ? LinphoneStatusOnline : LinphoneStatusOffline;
		if (nb_activities > 1) {
			char *tmp = NULL;
			const LinphoneAddress *addr = linphone_friend_get_address(lf);
			if (addr) tmp = linphone_address_as_string(addr);
			ms_warning("Friend %s has several activities, get status from the first one", tmp ? tmp : "unknown");
			if (tmp) ms_free(tmp);
			nb_activities = 1;
		}
		if (nb_activities == 1) {
485
			activity = linphone_presence_model_get_activity(lf->presence);
486
			description = linphone_presence_activity_get_description(activity);
487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512
			switch (linphone_presence_activity_get_type(activity)) {
				case LinphonePresenceActivityBreakfast:
				case LinphonePresenceActivityDinner:
				case LinphonePresenceActivityLunch:
				case LinphonePresenceActivityMeal:
					online_status = LinphoneStatusOutToLunch;
					break;
				case LinphonePresenceActivityAppointment:
				case LinphonePresenceActivityMeeting:
				case LinphonePresenceActivityPerformance:
				case LinphonePresenceActivityPresentation:
				case LinphonePresenceActivitySpectator:
				case LinphonePresenceActivityWorking:
				case LinphonePresenceActivityWorship:
					online_status = LinphoneStatusDoNotDisturb;
					break;
				case LinphonePresenceActivityAway:
				case LinphonePresenceActivitySleeping:
					online_status = LinphoneStatusAway;
					break;
				case LinphonePresenceActivityHoliday:
				case LinphonePresenceActivityTravel:
				case LinphonePresenceActivityVacation:
					online_status = LinphoneStatusVacation;
					break;
				case LinphonePresenceActivityBusy:
513 514 515 516 517 518
					if (description && strcmp(description, "Do not disturb") == 0) { // See linphonecore.c linphone_core_set_presence_info() method
						online_status = LinphoneStatusDoNotDisturb;
					} else {
						online_status = LinphoneStatusBusy;
					}
					break;
519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540
				case LinphonePresenceActivityLookingForWork:
				case LinphonePresenceActivityPlaying:
				case LinphonePresenceActivityShopping:
				case LinphonePresenceActivityTV:
					online_status = LinphoneStatusBusy;
					break;
				case LinphonePresenceActivityInTransit:
				case LinphonePresenceActivitySteering:
					online_status = LinphoneStatusBeRightBack;
					break;
				case LinphonePresenceActivityOnThePhone:
					online_status = LinphoneStatusOnThePhone;
					break;
				case LinphonePresenceActivityOther:
				case LinphonePresenceActivityPermanentAbsence:
					online_status = LinphoneStatusMoved;
					break;
				case LinphonePresenceActivityUnknown:
					/* Rely on the basic status information. */
					break;
				case LinphonePresenceActivityOnline:
					/* Should not happen! */
541
					/*ms_warning("LinphonePresenceActivityOnline should not happen here!");*/
542 543 544
					break;
				case LinphonePresenceActivityOffline:
					online_status = LinphoneStatusOffline;
545
					break;
546 547 548 549 550 551 552
			}
		}
	}

	return online_status;
}

553
const LinphonePresenceModel * linphone_friend_get_presence_model(LinphoneFriend *lf) {
554 555 556
	return lf->presence;
}

557 558 559 560 561 562 563
void linphone_friend_set_presence_model(LinphoneFriend *lf, LinphonePresenceModel *presence) {
	if (lf->presence != NULL) {
		linphone_presence_model_unref(lf->presence);
	}
	lf->presence = presence;
}

564 565 566 567
bool_t linphone_friend_is_presence_received(const LinphoneFriend *lf) {
	return lf->presence_received;
}

568 569 570
BuddyInfo * linphone_friend_get_info(const LinphoneFriend *lf){
	return lf->info;
}
aymeric's avatar
aymeric committed
571

572 573 574 575 576 577 578 579
/*
 * updates the subscriptions.
 * If only_when_registered is TRUE, subscribe will be sent only if the friend's corresponding proxy config is in registered.
 * Otherwise if the proxy config goes to unregistered state, the subscription refresh will be suspended.
 * An optional proxy whose state has changed can be passed to optimize the processing.
**/
void linphone_friend_update_subscribes(LinphoneFriend *fr, LinphoneProxyConfig *proxy, bool_t only_when_registered){
	int can_subscribe=1;
580

581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602
	if (only_when_registered && (fr->subscribe || fr->subscribe_active)){
		LinphoneProxyConfig *cfg=linphone_core_lookup_known_proxy(fr->lc,fr->uri);
		if (proxy && proxy!=cfg) return;
		if (cfg && cfg->state!=LinphoneRegistrationOk){
			char *tmp=linphone_address_as_string(fr->uri);
			ms_message("Friend [%s] belongs to proxy config with identity [%s], but this one isn't registered. Subscription is suspended.",
				   tmp,linphone_proxy_config_get_identity(cfg));
			ms_free(tmp);
			can_subscribe=0;
		}
	}
	if (can_subscribe && fr->subscribe && fr->subscribe_active==FALSE){
		ms_message("Sending a new SUBSCRIBE");
		__linphone_friend_do_subscribe(fr);
	}else if (can_subscribe && fr->subscribe_active && !fr->subscribe){
		linphone_friend_unsubscribe(fr);
	}else if (!can_subscribe && fr->outsub){
		fr->subscribe_active=FALSE;
		sal_op_stop_refreshing(fr->outsub);
	}
}

603
void linphone_friend_save(LinphoneFriend *fr, LinphoneCore *lc) {
604
	if (!lc) return;
605
#ifdef FRIENDS_SQL_STORAGE_ENABLED
606 607 608 609 610
	if (lc->friends_db_file) {
		linphone_core_store_friend_in_db(lc, fr);
	} else {
		linphone_core_write_friends_config(lc);
	}
611
#else
612
	linphone_core_write_friends_config(lc);
613
#endif
614 615 616
}

void linphone_friend_apply(LinphoneFriend *fr, LinphoneCore *lc) {
617 618
	LinphonePresenceModel *model;

619
	if (!fr->uri) {
aymeric's avatar
aymeric committed
620 621 622
		ms_warning("No sip url defined.");
		return;
	}
jehan's avatar
jehan committed
623

624 625
	if (fr->inc_subscribe_pending) {
		switch(fr->pol) {
aymeric's avatar
aymeric committed
626
			case LinphoneSPWait:
627
				model = linphone_presence_model_new_with_activity(LinphonePresenceActivityOther, "Waiting for user acceptance");
628
				linphone_friend_notify(fr, model);
629
				linphone_presence_model_unref(model);
aymeric's avatar
aymeric committed
630 631
				break;
			case LinphoneSPAccept:
632 633
				if (fr->lc)
					linphone_friend_notify(fr, fr->lc->presence_model);
aymeric's avatar
aymeric committed
634 635
				break;
			case LinphoneSPDeny:
636
				linphone_friend_notify(fr, NULL);
aymeric's avatar
aymeric committed
637 638
				break;
		}
639 640 641
		fr->inc_subscribe_pending = FALSE;
	}
	if (fr->lc) {
642
		linphone_friend_list_update_subscriptions(fr->friend_list, NULL, linphone_core_should_subscribe_friends_only_when_registered(fr->lc));
aymeric's avatar
aymeric committed
643
	}
644
	ms_debug("linphone_friend_apply() done.");
645
	lc->bl_refresh=TRUE;
646
	fr->commit=FALSE;
aymeric's avatar
aymeric committed
647 648
}

649
void linphone_friend_edit(LinphoneFriend *fr) {
650 651 652
	if (fr && fr->vcard) {
		linphone_vcard_compute_md5_hash(fr->vcard);
	}
aymeric's avatar
aymeric committed
653 654
}

655
void linphone_friend_done(LinphoneFriend *fr) {
656
	ms_return_if_fail(fr);
657
	if (!fr->lc || !fr->friend_list) return;
658 659
	linphone_friend_apply(fr, fr->lc);
	linphone_friend_save(fr, fr->lc);
660

661
	if (fr && fr->vcard) {
662
		if (linphone_vcard_compare_md5_hash(fr->vcard) != 0) {
663
			ms_debug("vCard's md5 has changed, mark friend as dirty");
664
			fr->friend_list->dirty_friends_to_update = ms_list_append(fr->friend_list->dirty_friends_to_update, linphone_friend_ref(fr));
665 666
		}
	}
aymeric's avatar
aymeric committed
667 668
}

669 670 671 672
#if __clang__ || ((__GNUC__ == 4 && __GNUC_MINOR__ >= 6) || __GNUC__ > 4)
#pragma GCC diagnostic push
#endif
#pragma GCC diagnostic ignored "-Wdeprecated-declarations"
673
LinphoneFriend * linphone_core_create_friend(LinphoneCore *lc) {
674 675 676
	LinphoneFriend * lf = linphone_friend_new();
	lf->lc = lc;
	return lf;
677 678 679
}

LinphoneFriend * linphone_core_create_friend_with_address(LinphoneCore *lc, const char *address) {
680 681 682 683
	LinphoneFriend * lf = linphone_friend_new_with_address(address);
	if (lf)
		lf->lc = lc;
	return lf;
684
}
685 686 687
#if __clang__ || ((__GNUC__ == 4 && __GNUC_MINOR__ >= 6) || __GNUC__ > 4)
#pragma GCC diagnostic pop
#endif
688

689
void linphone_core_add_friend(LinphoneCore *lc, LinphoneFriend *lf) {
690
	if (linphone_friend_list_add_friend(linphone_core_get_default_friend_list(lc), lf) != LinphoneFriendListOK) return;
691
	if (ms_list_find(lc->subscribers, lf)) {
692 693 694 695
		/*if this friend was in the pending subscriber list, now remove it from this list*/
		lc->subscribers = ms_list_remove(lc->subscribers, lf);
		linphone_friend_unref(lf);
	}
696 697
	if (linphone_core_ready(lc)) linphone_friend_apply(lf, lc);
	else lf->commit = TRUE;
aymeric's avatar
aymeric committed
698 699
}

700
void linphone_core_remove_friend(LinphoneCore *lc, LinphoneFriend *lf) {
701 702 703 704
	if (lf && lf->friend_list) {
		if (linphone_friend_list_remove_friend(lf->friend_list, lf) == LinphoneFriendListNonExistentFriend) {
			ms_error("linphone_core_remove_friend(): friend [%p] is not part of core's list.", lf);
		}
aymeric's avatar
aymeric committed
705 706 707
	}
}

708 709 710 711 712 713
void linphone_core_update_friends_subscriptions(LinphoneCore *lc, LinphoneProxyConfig *cfg, bool_t only_when_registered) {
	MSList *lists = lc->friends_lists;
	while (lists) {
		LinphoneFriendList *list = (LinphoneFriendList *)lists->data;
		linphone_friend_list_update_subscriptions(list, cfg, only_when_registered);
		lists = ms_list_next(lists);
Simon Morlat's avatar
Simon Morlat committed
714
	}
715 716 717 718 719
}

bool_t linphone_core_should_subscribe_friends_only_when_registered(const LinphoneCore *lc){
	return lp_config_get_int(lc->config,"sip","subscribe_presence_only_when_registered",1);
}
720

721 722
void linphone_core_send_initial_subscribes(LinphoneCore *lc) {
	MSList *lists = lc->friends_lists;
Ghislain MARY's avatar
Ghislain MARY committed
723 724 725 726
	bool_t proxy_config_for_rls_presence_uri_domain = FALSE;
	LinphoneAddress *rls_address = NULL;
	const MSList *elem;

727 728
	if (lc->initial_subscribes_sent) return;
	lc->initial_subscribes_sent=TRUE;
729 730 731 732 733 734 735 736 737 738 739 740 741 742 743
	while (lists) {
		LinphoneFriendList *list = (LinphoneFriendList *)lists->data;
		if (list->rls_uri != NULL) {
			rls_address = linphone_core_create_address(lc, list->rls_uri);
			if (rls_address != NULL) {
				const char *rls_domain = linphone_address_get_domain(rls_address);
				if (rls_domain != NULL) {
					for (elem = linphone_core_get_proxy_config_list(lc); elem != NULL; elem = elem->next) {
						LinphoneProxyConfig *cfg = (LinphoneProxyConfig *)elem->data;
						const char *proxy_domain = linphone_proxy_config_get_domain(cfg);
						if (strcmp(rls_domain, proxy_domain) == 0) {
							proxy_config_for_rls_presence_uri_domain = TRUE;
							break;
						}
					}
Ghislain MARY's avatar
Ghislain MARY committed
744
				}
745 746
				linphone_address_unref(rls_address);
			}
747 748 749 750 751
		}
		if (proxy_config_for_rls_presence_uri_domain == TRUE) {
			ms_message("Presence list activated so do not send initial subscribes it will be done when registered");
		} else {
			linphone_core_update_friends_subscriptions(lc,NULL,linphone_core_should_subscribe_friends_only_when_registered(lc));
Ghislain MARY's avatar
Ghislain MARY committed
752
		}
753
		lists = ms_list_next(lists);
Ghislain MARY's avatar
Ghislain MARY committed
754
	}
Simon Morlat's avatar
Simon Morlat committed
755 756
}

757 758 759 760 761 762
void linphone_core_invalidate_friend_subscriptions(LinphoneCore *lc) {
	MSList *lists = lc->friends_lists;
	while (lists) {
		LinphoneFriendList *list = (LinphoneFriendList *)lists->data;
		linphone_friend_list_invalidate_subscriptions(list);
		lists = ms_list_next(lists);
763
	}
Simon Morlat's avatar
Simon Morlat committed
764
	lc->initial_subscribes_sent=FALSE;
765 766
}

767
void linphone_friend_set_ref_key(LinphoneFriend *lf, const char *key){
768
	if (lf->refkey != NULL) {
769
		ms_free(lf->refkey);
770 771 772 773 774 775 776
		lf->refkey = NULL;
	}
	if (key) {
		lf->refkey = ms_strdup(key);
	}
	if (lf->lc) {
		linphone_friend_save(lf, lf->lc);
777 778 779 780 781 782 783
	}
}

const char *linphone_friend_get_ref_key(const LinphoneFriend *lf){
	return lf->refkey;
}

784 785 786 787 788 789 790 791 792
LinphoneFriend *linphone_core_find_friend(const LinphoneCore *lc, const LinphoneAddress *addr) {
	MSList *lists = lc->friends_lists;
	LinphoneFriend *lf = NULL;
	while (lists && !lf) {
		LinphoneFriendList *list = (LinphoneFriendList *)lists->data;
		lf = linphone_friend_list_find_friend_by_address(list, addr);
		lists = ms_list_next(lists);
	}
	return lf;
Simon Morlat's avatar
Simon Morlat committed
793 794
}

795 796 797 798 799 800 801 802 803
LinphoneFriend *linphone_core_get_friend_by_address(const LinphoneCore *lc, const char *uri) {
	MSList *lists = lc->friends_lists;
	LinphoneFriend *lf = NULL;
	while (lists && !lf) {
		LinphoneFriendList *list = (LinphoneFriendList *)lists->data;
		lf = linphone_friend_list_find_friend_by_uri(list, uri);
		lists = ms_list_next(lists);
	}
	return lf;
804 805
}

806 807 808 809 810 811 812 813 814
LinphoneFriend *linphone_core_get_friend_by_ref_key(const LinphoneCore *lc, const char *key) {
	MSList *lists = lc->friends_lists;
	LinphoneFriend *lf = NULL;
	while (lists && !lf) {
		LinphoneFriendList *list = (LinphoneFriendList *)lists->data;
		lf = linphone_friend_list_find_friend_by_ref_key(list, key);
		lists = ms_list_next(lists);
	}
	return lf;
815 816
}

817 818 819 820 821 822 823 824 825 826 827
LinphoneFriend *linphone_core_find_friend_by_out_subscribe(const LinphoneCore *lc, SalOp *op) {
	MSList *lists = lc->friends_lists;
	LinphoneFriend *lf = NULL;
	while (lists && !lf) {
		LinphoneFriendList *list = (LinphoneFriendList *)lists->data;
		lf = linphone_friend_list_find_friend_by_out_subscribe(list, op);
		lists = ms_list_next(lists);
	}
	return lf;
}

smorlat's avatar
smorlat committed
828
#define key_compare(s1,s2)	strcmp(s1,s2)
aymeric's avatar
aymeric committed
829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854

LinphoneSubscribePolicy __policy_str_to_enum(const char* pol){
	if (key_compare("accept",pol)==0){
		return LinphoneSPAccept;
	}
	if (key_compare("deny",pol)==0){
		return LinphoneSPDeny;
	}
	if (key_compare("wait",pol)==0){
		return LinphoneSPWait;
	}
	ms_warning("Unrecognized subscribe policy: %s",pol);
	return LinphoneSPWait;
}

LinphoneProxyConfig *__index_to_proxy(LinphoneCore *lc, int index){
	if (index>=0) return (LinphoneProxyConfig*)ms_list_nth_data(lc->sip_conf.proxies,index);
	else return NULL;
}

LinphoneFriend * linphone_friend_new_from_config_file(LinphoneCore *lc, int index){
	const char *tmp;
	char item[50];
	int a;
	LinphoneFriend *lf;
	LpConfig *config=lc->config;
855

aymeric's avatar
aymeric committed
856
	sprintf(item,"friend_%i",index);
857

aymeric's avatar
aymeric committed
858 859 860
	if (!lp_config_has_section(config,item)){
		return NULL;
	}
861

aymeric's avatar
aymeric committed
862 863 864 865
	tmp=lp_config_get_string(config,item,"url",NULL);
	if (tmp==NULL) {
		return NULL;
	}
866
	lf=linphone_core_create_friend_with_address(lc, tmp);
aymeric's avatar
aymeric committed
867 868 869 870 871 872 873 874 875 876
	if (lf==NULL) {
		return NULL;
	}
	tmp=lp_config_get_string(config,item,"pol",NULL);
	if (tmp==NULL) linphone_friend_set_inc_subscribe_policy(lf,LinphoneSPWait);
	else{
		linphone_friend_set_inc_subscribe_policy(lf,__policy_str_to_enum(tmp));
	}
	a=lp_config_get_int(config,item,"subscribe",0);
	linphone_friend_send_subscribe(lf,a);
877 878
	a = lp_config_get_int(config, item, "presence_received", 0);
	lf->presence_received = (bool_t)a;
879

880
	linphone_friend_set_ref_key(lf,lp_config_get_string(config,item,"refkey",NULL));
aymeric's avatar
aymeric committed
881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902
	return lf;
}

const char *__policy_enum_to_str(LinphoneSubscribePolicy pol){
	switch(pol){
		case LinphoneSPAccept:
			return "accept";
			break;
		case LinphoneSPDeny:
			return "deny";
			break;
		case LinphoneSPWait:
			return "wait";
			break;
	}
	ms_warning("Invalid policy enum value.");
	return "wait";
}

void linphone_friend_write_to_config_file(LpConfig *config, LinphoneFriend *lf, int index){
	char key[50];
	char *tmp;
903
	const char *refkey;
904

aymeric's avatar
aymeric committed
905
	sprintf(key,"friend_%i",index);
906

aymeric's avatar
aymeric committed
907 908 909 910
	if (lf==NULL){
		lp_config_clean_section(config,key);
		return;
	}
911
	if (lf->uri!=NULL){
912
		tmp=linphone_address_as_string(lf->uri);
aymeric's avatar
aymeric committed
913 914 915 916
		if (tmp==NULL) {
			return;
		}
		lp_config_set_string(config,key,"url",tmp);
Simon Morlat's avatar
Simon Morlat committed
917
		ms_free(tmp);
aymeric's avatar
aymeric committed
918 919 920
	}
	lp_config_set_string(config,key,"pol",__policy_enum_to_str(lf->pol));
	lp_config_set_int(config,key,"subscribe",lf->subscribe);
921
	lp_config_set_int(config, key, "presence_received", lf->presence_received);
922 923 924 925 926

	refkey=linphone_friend_get_ref_key(lf);
	if (refkey){
		lp_config_set_string(config,key,"refkey",refkey);
	}
aymeric's avatar
aymeric committed
927
}
928

929
void linphone_core_write_friends_config(LinphoneCore* lc) {
930 931
	MSList *elem;
	int i;
932
	int store_friends;
933

934
	if (! linphone_core_ready(lc)) return; /*dont write config when reading it !*/
935 936
	store_friends = lp_config_get_int(lc->config, "misc", "store_friends", 1);
	if (store_friends) {
937
		for (elem=linphone_core_get_default_friend_list(lc)->friends,i=0; elem!=NULL; elem=ms_list_next(elem),i++){
938 939 940
			linphone_friend_write_to_config_file(lc->config,(LinphoneFriend*)elem->data,i);
		}
		linphone_friend_write_to_config_file(lc->config,NULL,i);	/* set the end */
941 942 943
	}
}