diff options
Diffstat (limited to 'native/ctsvc_group.c')
| -rw-r--r-- | native/ctsvc_group.c | 223 |
1 files changed, 223 insertions, 0 deletions
diff --git a/native/ctsvc_group.c b/native/ctsvc_group.c new file mode 100644 index 0000000..c7f33a4 --- /dev/null +++ b/native/ctsvc_group.c @@ -0,0 +1,223 @@ +/* + * Contacts Service + * + * Copyright (c) 2010 - 2012 Samsung Electronics Co., Ltd. All rights reserved. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +#include "contacts.h" +#include "ctsvc_internal.h" +#include "ctsvc_schema.h" +#include "ctsvc_sqlite.h" +#include "ctsvc_utils.h" +#include "ctsvc_db_plugin_contact_helper.h" +#include "ctsvc_group.h" +#include "ctsvc_notification.h" + +int ctsvc_group_add_contact_in_transaction(int group_id, int contact_id) +{ + int ret; + int version; + cts_stmt stmt = NULL; + char query[CTS_SQL_MIN_LEN] = {0}; + int rel_changed = 0; + int grp_acc, contact_acc; + int exist; + + snprintf(query, sizeof(query), + "SELECT COUNT(*) FROM %s WHERE group_id = %d AND contact_id=%d AND deleted = 0", + CTS_TABLE_GROUP_RELATIONS, group_id, contact_id); + + ret = ctsvc_query_get_first_int_result(query, &exist); + if (1 == exist) { + CTS_DBG("group relation already exist (group_id:%d, contac_id:%d)", group_id, contact_id); + return CONTACTS_ERROR_NONE; + } + + version = ctsvc_get_next_ver(); + snprintf(query, sizeof(query), + "SELECT addressbook_id FROM %s WHERE group_id = %d", + CTS_TABLE_GROUPS, group_id); + + ret = ctsvc_query_get_first_int_result(query, &grp_acc); + RETVM_IF(CONTACTS_ERROR_NO_DATA == grp_acc, CONTACTS_ERROR_INVALID_PARAMETER, + "Invalid Parameter: group_id(%d) is Invalid", group_id); + + snprintf(query, sizeof(query), + "SELECT addressbook_id FROM %s WHERE contact_id = %d AND deleted = 0", + CTS_TABLE_CONTACTS, contact_id); + + ret = ctsvc_query_get_first_int_result(query, &contact_acc); + RETVM_IF( contact_acc != grp_acc, CONTACTS_ERROR_INVALID_PARAMETER, + "Invalid Parameter: group_acc(%d) is differ from contact_acc(%d) Invalid", grp_acc, contact_acc); + + snprintf(query, sizeof(query), "INSERT OR REPLACE INTO %s VALUES(%d, %d, %d, 0)", + CTS_TABLE_GROUP_RELATIONS, group_id, contact_id, version); + + stmt = cts_query_prepare(query); + RETVM_IF(NULL == stmt, CONTACTS_ERROR_DB, "DB error : cts_query_prepare() Failed"); + + ret = cts_stmt_step(stmt); + WARN_IF(CONTACTS_ERROR_NONE != ret, "cts_stmt_step() Failed(%d)", ret); + + rel_changed = cts_db_change(); + cts_stmt_finalize(stmt); + + if (0 < rel_changed) { + snprintf(query, sizeof(query), + "UPDATE "CTS_TABLE_GROUPS" SET member_changed_ver=%d WHERE group_id=%d", + version, group_id); + ret = ctsvc_query_exec(query); + RETVM_IF(ret != CONTACTS_ERROR_NONE, ret, "ctsvc_query_exec() Failed(%d)", ret); + ctsvc_set_group_rel_noti(); + return rel_changed; + } + + return ret; +} + +API int contacts_group_add_contact(int group_id, int contact_id) +{ + RETVM_IF( group_id <= 0, CONTACTS_ERROR_INVALID_PARAMETER, "Invalid Parameter: group_id should be greater than 0"); + RETVM_IF( contact_id <= 0, CONTACTS_ERROR_INVALID_PARAMETER, "Invalid Parameter: contact_id should be greater than 0"); + + /* BEGIN_TRANSACTION */ + int ret = ctsvc_begin_trans(); + RETVM_IF(ret, ret, "contacts_svc_begin_trans() Failed(%d)", ret); + + /* DOING JOB */ + do { + int changed = ctsvc_group_add_contact_in_transaction(group_id, contact_id); + if (changed < CONTACTS_ERROR_NONE) { + CTS_ERR("DB error : ctsvc_group_add_contact_in_transaction() Failed(%d)", changed); + ret = changed; + break; + } + + ret = ctsvc_db_contact_update_changed_time(contact_id); + if (CONTACTS_ERROR_NONE != ret) { + CTS_ERR("DB error : ctsvc_db_contact_update_changed_time() Failed(%d)", ret); + ret = CONTACTS_ERROR_DB; + break; + } + + ctsvc_set_contact_noti(); + + ret = ctsvc_end_trans(true); + if(ret < CONTACTS_ERROR_NONE ) + { + CTS_ERR("DB error : ctsvc_end_trans() Failed(%d)", ret); + return ret; + } + + return CONTACTS_ERROR_NONE; + + } while(0); + + /* ROLLBACK TRANSACTION */ + ctsvc_end_trans(false); + + return ret; +} + +int ctsvc_group_remove_contact_in_transaction(int group_id, int contact_id) +{ + int ret; + int version; + cts_stmt stmt = NULL; + char query[CTS_SQL_MIN_LEN] = {0}; + + version = ctsvc_get_next_ver(); + snprintf(query, sizeof(query), + "UPDATE %s SET deleted=1, ver = %d WHERE group_id = %d AND contact_id = %d", + CTS_TABLE_GROUP_RELATIONS, version, group_id, contact_id); + + stmt = cts_query_prepare(query); + RETVM_IF(NULL == stmt, CONTACTS_ERROR_DB, "DB Error: cts_query_prepare() Failed"); + + ret = cts_stmt_step(stmt); + WARN_IF(CONTACTS_ERROR_NONE != ret, "DB Error: cts_stmt_step() Failed(%d)", ret); + + int rel_changed = cts_db_change(); + cts_stmt_finalize(stmt); + + if (0 <= rel_changed) { + snprintf(query, sizeof(query), + "UPDATE "CTS_TABLE_GROUPS" SET member_changed_ver=%d WHERE group_id=%d", + version, group_id); + ret = ctsvc_query_exec(query); + RETVM_IF(ret != CONTACTS_ERROR_NONE, ret, "ctsvc_query_exec() Failed(%d)", ret); + ctsvc_set_group_rel_noti(); + return rel_changed; + } + + return CONTACTS_ERROR_NONE; +} + +API int contacts_group_remove_contact(int group_id, int contact_id) +{ + RETVM_IF( group_id <= 0, CONTACTS_ERROR_INVALID_PARAMETER, "Invalid Parameter: group_id should be greater than 0"); + RETVM_IF( contact_id <= 0, CONTACTS_ERROR_INVALID_PARAMETER, "Invalid Parameter: contact_id should be greater than 0"); + + /* BEGIN_TRANSACTION */ + int ret = ctsvc_begin_trans(); + RETVM_IF(ret, ret, "contacts_svc_begin_trans() Failed(%d)", ret); + + /* DOING JOB */ + do { + int changed = ctsvc_group_remove_contact_in_transaction(group_id, contact_id); + if (changed < CONTACTS_ERROR_NONE) { + CTS_ERR("DB error : ctsvc_group_remove_contact_in_transaction() Failed(%d)", changed); + ret = changed; + break; + } + + ret = ctsvc_db_contact_update_changed_time(contact_id); + if (CONTACTS_ERROR_NONE != ret) { + CTS_ERR("DB error : ctsvc_db_contact_update_changed_time() Failed(%d)", ret); + ret = CONTACTS_ERROR_DB; + break; + } + + ctsvc_set_contact_noti(); + + ret = ctsvc_end_trans(true); + if(ret < CONTACTS_ERROR_NONE ) + { + CTS_ERR("DB error : ctsvc_end_trans() Failed(%d)", ret); + return ret; + } + + return CONTACTS_ERROR_NONE; + + } while(0); + + /* ROLLBACK TRANSACTION */ + ctsvc_end_trans(false); + + return ret; +} + +/* +API int contacts_group_add_person(int group_id, int person_id) +{ + return CONTACTS_ERROR_NONE; +} +API int contacts_group_remove_person(int group_id, int person_id) +{ + return CONTACTS_ERROR_NONE; +} +*/ + |