server/db/ctsvc_db_plugin_number_helper.c

   1 /*
   2  * Contacts Service
   3  *
   4  * Copyright (c) 2010 - 2015 Samsung Electronics Co., Ltd. All rights reserved.
   5  *
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at
   9  *
  10  * http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  *
  18  */
  19 #include "contacts.h"
  20 #include "ctsvc_internal.h"
  21 #include "ctsvc_db_schema.h"
  22 #include "ctsvc_db_sqlite.h"
  23 #include "ctsvc_db_init.h"
  24 #include "ctsvc_db_query.h"
  25 #include "ctsvc_normalize.h"
  26 #include "ctsvc_number_utils.h"
  27 #include "ctsvc_db_plugin_number_helper.h"
  28 #include "ctsvc_record.h"
  29 #include "ctsvc_notification.h"
  30 #include "ctsvc_server_setting.h"
  31 #include "ctsvc_localize_utils.h"
  32
  33 #ifdef ENABLE_LOG_FEATURE
  34 #include "ctsvc_server_phonelog.h"
  35 #endif /* ENABLE_LOG_FEATURE */
  36
  37 static int __ctsvc_db_number_reset_default(int number_id, int contact_id)
  38 {
  39         int ret;
  40         char query[CTS_SQL_MAX_LEN] = {0};
  41
  42         snprintf(query, sizeof(query),
  43                         "UPDATE "CTS_TABLE_DATA" SET is_default = 0, is_primary_default = 0 WHERE id != %d AND contact_id = %d AND datatype = %d",
  44                         number_id, contact_id, CONTACTS_DATA_TYPE_NUMBER);
  45         ret = ctsvc_query_exec(query);
  46         WARN_IF(CONTACTS_ERROR_NONE != ret, "ctsvc_query_exec() Fail(%d)", ret);
  47         return ret;
  48 }
  49
  50 int ctsvc_db_number_insert(contacts_record_h record, int contact_id, bool is_my_profile, int *id)
  51 {
  52         int ret;
  53         int number_id;
  54         cts_stmt stmt = NULL;
  55         char query[CTS_SQL_MAX_LEN] = {0};
  56         ctsvc_number_s *number = (ctsvc_number_s*)record;
  57
  58         RETV_IF(NULL == number->number, CONTACTS_ERROR_NONE);
  59         RETVM_IF(contact_id <= 0, CONTACTS_ERROR_INVALID_PARAMETER,
  60                         "contact_id(%d) is mandatory field to insert number record ", number->contact_id);
  61         RETVM_IF(0 < number->id, CONTACTS_ERROR_INVALID_PARAMETER,
  62                         "id(%d), This record is already inserted", number->id);
  63
  64         snprintf(query, sizeof(query),
  65                         "INSERT INTO "CTS_TABLE_DATA"(contact_id, is_my_profile, datatype, is_default, data1, data2, data3, data4, data5, data6) "
  66                         "VALUES(%d, %d, %d, %d, %d, ?, ?, ?, ?, ?)",
  67                         contact_id, is_my_profile, CONTACTS_DATA_TYPE_NUMBER, number->is_default, number->type);
  68
  69         ret = ctsvc_query_prepare(query, &stmt);
  70         RETVM_IF(NULL == stmt, ret, "ctsvc_query_prepare() Fail(%d)", ret);
  71
  72         if (number->label)
  73                 ctsvc_stmt_bind_text(stmt, 1, number->label);
  74
  75         ctsvc_stmt_bind_text(stmt, 2, number->number);
  76
  77         char clean_num[SAFE_STRLEN(number->number) + 1];
  78         ret = ctsvc_clean_number(number->number, clean_num, sizeof(clean_num), true);
  79         if (0 < ret) {
  80                 char normal_num[sizeof(clean_num) + 20];
  81                 ctsvc_stmt_bind_copy_text(stmt, 5, clean_num, strlen(clean_num));
  82                 ret = ctsvc_normalize_number(clean_num, normal_num, sizeof(normal_num), true);
  83                 if (0 < ret) {
  84                         ctsvc_stmt_bind_copy_text(stmt, 4, normal_num, strlen(normal_num));
  85                         char minmatch[sizeof(normal_num) + 1];
  86                         ret = ctsvc_get_minmatch_number(normal_num, minmatch, sizeof(minmatch), ctsvc_get_phonenumber_min_match_digit());
  87                         if (CONTACTS_ERROR_NONE == ret)
  88                                 ctsvc_stmt_bind_copy_text(stmt, 3, minmatch, strlen(minmatch));
  89                 }
  90         }
  91
  92         ret = ctsvc_stmt_step(stmt);
  93         if (CONTACTS_ERROR_NONE != ret) {
  94                 /* LCOV_EXCL_START */
  95                 ERR("ctsvc_stmt_step() Fail(%d)", ret);
  96                 ctsvc_stmt_finalize(stmt);
  97                 return ret;
  98                 /* LCOV_EXCL_STOP */
  99         }
 100
 101         number_id = ctsvc_db_get_last_insert_id();
 102         if (id)
 103                 *id = number_id;
 104         ctsvc_stmt_finalize(stmt);
 105
 106         if (ctsvc_record_check_property_flag((ctsvc_record_s*)record, _contacts_number.is_default, CTSVC_PROPERTY_FLAG_DIRTY)) {
 107                 if (number->is_default)
 108                         __ctsvc_db_number_reset_default(number_id, contact_id);
 109         }
 110
 111         if (false == is_my_profile) {
 112 #ifdef ENABLE_LOG_FEATURE
 113                 /* updata phonelog */
 114                 int person_id = -1;
 115                 snprintf(query, sizeof(query),
 116                                 "SELECT person_id, data3 FROM "CTS_TABLE_CONTACTS", "CTS_TABLE_DATA" "
 117                                 "ON "CTS_TABLE_CONTACTS".contact_id = "CTS_TABLE_DATA".contact_id "
 118                                 "WHERE data.id = %d", number_id);
 119                 ret = ctsvc_query_get_first_int_result(query, &person_id);
 120                 if (0 < person_id)
 121                         ctsvc_db_phone_log_update_person_id(number->number, -1, person_id, false, NULL);
 122 #endif /* ENABLE_LOG_FEATURE */
 123                 ctsvc_set_number_noti();
 124         }
 125         return CONTACTS_ERROR_NONE;
 126 }
 127
 128
 129 int ctsvc_db_number_get_value_from_stmt(cts_stmt stmt, contacts_record_h *record, int start_count)
 130 {
 131         int ret;
 132         char *temp;
 133         ctsvc_number_s *number;
 134
 135         ret = contacts_record_create(_contacts_number._uri, (contacts_record_h*)&number);
 136         RETVM_IF(CONTACTS_ERROR_NONE != ret, ret, "contacts_record_create Fail(%d)", ret);
 137
 138         number->id = ctsvc_stmt_get_int(stmt, start_count++);
 139         number->contact_id = ctsvc_stmt_get_int(stmt, start_count++);
 140         number->is_default = ctsvc_stmt_get_int(stmt, start_count++);
 141         number->type = ctsvc_stmt_get_int(stmt, start_count++);
 142         temp = ctsvc_stmt_get_text(stmt, start_count++);
 143         number->label = SAFE_STRDUP(temp);
 144         temp = ctsvc_stmt_get_text(stmt, start_count++);
 145         number->number = SAFE_STRDUP(temp);
 146         temp = ctsvc_stmt_get_text(stmt, start_count++);
 147         number->lookup = SAFE_STRDUP(temp);         /* data4 : minmatch */
 148         temp = ctsvc_stmt_get_text(stmt, start_count++);
 149         number->normalized = SAFE_STRDUP(temp);     /* data5 : normalized number */
 150         temp = ctsvc_stmt_get_text(stmt, start_count++);
 151         number->cleaned = SAFE_STRDUP(temp);        /* data6 : cleaned number */
 152
 153         *record = (contacts_record_h)number;
 154         return CONTACTS_ERROR_NONE;
 155 }
 156
 157 int ctsvc_db_number_update(contacts_record_h record, bool is_my_profile)
 158 {
 159         int id;
 160         int ret = CONTACTS_ERROR_NONE;
 161         char *set = NULL;
 162         GSList *bind_text = NULL;
 163         GSList *cursor = NULL;
 164         ctsvc_number_s *number = (ctsvc_number_s*)record;
 165         char query[CTS_SQL_MAX_LEN] = {0};
 166
 167 #ifdef ENABLE_LOG_FEATURE
 168         /* for updating phonelog */
 169         char *pre_number = NULL;
 170         int person_id = -1;
 171         cts_stmt stmt = NULL;
 172 #endif /* ENABLE_LOG_FEATURE */
 173
 174         RETVM_IF(0 == number->id, CONTACTS_ERROR_INVALID_PARAMETER, "number of contact has no ID.");
 175         RETVM_IF(CTSVC_PROPERTY_FLAG_DIRTY != (number->base.property_flag & CTSVC_PROPERTY_FLAG_DIRTY),
 176                         CONTACTS_ERROR_NONE, "No update");
 177
 178         snprintf(query, sizeof(query),
 179                         "SELECT id FROM "CTS_TABLE_DATA" WHERE id = %d", number->id);
 180         ret = ctsvc_query_get_first_int_result(query, &id);
 181         RETV_IF(ret != CONTACTS_ERROR_NONE, ret);
 182
 183         if (ctsvc_record_check_property_flag((ctsvc_record_s*)record, _contacts_number.is_default, CTSVC_PROPERTY_FLAG_DIRTY)) {
 184                 if (number->is_default)
 185                         __ctsvc_db_number_reset_default(number->id, number->contact_id);
 186         }
 187
 188         do {
 189                 if (CONTACTS_ERROR_NONE != (ret = ctsvc_db_create_set_query(record, &set, &bind_text))) break;
 190                 if (ctsvc_record_check_property_flag((ctsvc_record_s*)record, CTSVC_PROPERTY_NUMBER_NUMBER, CTSVC_PROPERTY_FLAG_DIRTY)) {
 191                         int len;
 192                         char query_set[CTS_SQL_MAX_LEN] = {0};
 193
 194 #ifdef ENABLE_LOG_FEATURE
 195                         /* updata phonelog */
 196                         snprintf(query, sizeof(query),
 197                                         "SELECT person_id, data3 FROM "CTS_TABLE_CONTACTS", "CTS_TABLE_DATA" "
 198                                         "ON "CTS_TABLE_CONTACTS".contact_id = "CTS_TABLE_DATA".contact_id "
 199                                         "WHERE data.id = %d", number->id);
 200                         ret = ctsvc_query_prepare(query, &stmt);
 201                         if (stmt) {
 202                                 ret = ctsvc_stmt_step(stmt);
 203                                 if (ret == 1) {
 204                                         person_id = ctsvc_stmt_get_int(stmt, 0);
 205                                         pre_number = ctsvc_stmt_get_text(stmt, 1);
 206                                 } else {
 207                                         WARN("ctsvc_stmt_step() Fail(%d)", ret);
 208                                 }
 209                         } else {
 210                                 WARN("ctsvc_query_prepare Fail(%d)", ret);
 211                         }
 212 #endif /* ENABLE_LOG_FEATURE */
 213
 214                         char clean_num[SAFE_STRLEN(number->number) + 1];
 215                         ret = ctsvc_clean_number(number->number, clean_num, sizeof(clean_num), true);
 216                         if (0 < ret) {
 217                                 char normal_num[sizeof(clean_num) + 20];
 218                                 len = snprintf(query_set, sizeof(query_set), "%s, data6=?", set);
 219                                 bind_text = g_slist_append(bind_text, strdup(clean_num));
 220                                 free(set);
 221
 222                                 ret = ctsvc_normalize_number(clean_num, normal_num, sizeof(normal_num), true);
 223                                 if (0 < ret) {
 224                                         len += snprintf(query_set+len, sizeof(query_set)-len, ", data5=?");
 225                                         bind_text = g_slist_append(bind_text, strdup(normal_num));
 226                                         char minmatch[sizeof(normal_num)+1];
 227                                         ret = ctsvc_get_minmatch_number(normal_num, minmatch, sizeof(minmatch), ctsvc_get_phonenumber_min_match_digit());
 228                                         if (CONTACTS_ERROR_NONE == ret) {
 229                                                 len += snprintf(query_set+len, sizeof(query_set)-len, ", data4=?");
 230                                                 bind_text = g_slist_append(bind_text, strdup(minmatch));
 231                                         }
 232                                 }
 233                                 set = strdup(query_set);
 234                         }
 235                 }
 236 #ifdef ENABLE_LOG_FEATURE
 237                 if (ctsvc_record_check_property_flag((ctsvc_record_s*)record, CTSVC_PROPERTY_NUMBER_TYPE, CTSVC_PROPERTY_FLAG_DIRTY)) {
 238                         if (person_id <= 0) {
 239                                 /* updata phonelog */
 240                                 snprintf(query, sizeof(query),
 241                                                 "SELECT person_id, data3 FROM "CTS_TABLE_CONTACTS", "CTS_TABLE_DATA" "
 242                                                 "ON "CTS_TABLE_CONTACTS".contact_id = "CTS_TABLE_DATA".contact_id "
 243                                                 "WHERE data.id = %d", number->id);
 244                                 ret = ctsvc_query_prepare(query, &stmt);
 245                                 if (stmt) {
 246                                         ret = ctsvc_stmt_step(stmt);
 247                                         if (ret == 1) {
 248                                                 person_id = ctsvc_stmt_get_int(stmt, 0);
 249                                                 pre_number = ctsvc_stmt_get_text(stmt, 1);
 250                                         } else {
 251                                                 WARN("ctsvc_stmt_step() Fail(%d)", ret);
 252                                         }
 253                                 } else {
 254                                         WARN("ctsvc_query_prepare Fail(%d)", ret);
 255                                 }
 256                         }
 257                 }
 258 #endif /* ENABLE_LOG_FEATURE */
 259
 260                 if (CONTACTS_ERROR_NONE != (ret = ctsvc_db_update_record_with_set_query(set, bind_text, CTS_TABLE_DATA, number->id))) break;
 261
 262                 if (false == is_my_profile)
 263                         ctsvc_set_number_noti();
 264
 265 #ifdef ENABLE_LOG_FEATURE
 266                 /* update phone log */
 267                 if (0 < person_id && pre_number)
 268                         ctsvc_db_phone_log_update_person_id(pre_number, person_id, -1, false, NULL);
 269                 if (0 < person_id)
 270                         ctsvc_db_phone_log_update_person_id(number->number, -1, person_id, false, NULL);
 271                 ctsvc_stmt_finalize(stmt);
 272 #endif /* ENABLE_LOG_FEATURE */
 273         } while (0);
 274
 275         CTSVC_RECORD_RESET_PROPERTY_FLAGS((ctsvc_record_s*)record);
 276         free(set);
 277
 278         if (bind_text) {
 279                 for (cursor = bind_text; cursor; cursor = cursor->next) {
 280                         free(cursor->data);
 281                         cursor->data = NULL;
 282                 }
 283                 g_slist_free(bind_text);
 284         }
 285
 286         return ret;
 287 }
 288
 289 int ctsvc_db_number_delete(int id, bool is_my_profile)
 290 {
 291         int ret;
 292         char query[CTS_SQL_MIN_LEN] = {0};
 293
 294 #ifdef ENABLE_LOG_FEATURE
 295         /* for updating phonelog */
 296         char *pre_number = NULL;
 297         int person_id = -1;
 298         cts_stmt stmt = NULL;
 299
 300         snprintf(query, sizeof(query),
 301                         "SELECT person_id, data3 FROM "CTS_TABLE_CONTACTS", "CTS_TABLE_DATA" "
 302                         "ON "CTS_TABLE_CONTACTS".contact_id = "CTS_TABLE_DATA".contact_id "
 303                         "WHERE data.id = %d", id);
 304         ret = ctsvc_query_prepare(query, &stmt);
 305         if (stmt) {
 306                 ret = ctsvc_stmt_step(stmt);
 307                 if (ret == 1) {
 308                         person_id = ctsvc_stmt_get_int(stmt, 0);
 309                         pre_number = ctsvc_stmt_get_text(stmt, 1);
 310                 } else {
 311                         WARN("ctsvc_stmt_step() Fail(%d)", ret);
 312                 }
 313         } else {
 314                 WARN("ctsvc_query_prepare Fail(%d)", ret);
 315         }
 316 #endif /* ENABLE_LOG_FEATURE */
 317
 318         snprintf(query, sizeof(query), "DELETE FROM "CTS_TABLE_DATA" WHERE id = %d AND datatype = %d",
 319                         id, CONTACTS_DATA_TYPE_NUMBER);
 320
 321         ret = ctsvc_query_exec(query);
 322         if (CONTACTS_ERROR_NONE != ret) {
 323                 /* LCOV_EXCL_START */
 324                 ERR("ctsvc_query_exec() Fail(%d)", ret);
 325 #ifdef ENABLE_LOG_FEATURE
 326                 ctsvc_stmt_finalize(stmt);
 327 #endif /* ENABLE_LOG_FEATURE */
 328                 return ret;
 329                 /* LCOV_EXCL_STOP */
 330         }
 331
 332 #ifdef ENABLE_LOG_FEATURE
 333         /* update phone log */
 334         if (0 < person_id && pre_number)
 335                 ctsvc_db_phone_log_update_person_id(pre_number, person_id, -1, false, NULL);
 336         ctsvc_stmt_finalize(stmt);
 337 #endif /* ENABLE_LOG_FEATURE */
 338
 339         if (false == is_my_profile)
 340                 ctsvc_set_number_noti();
 341
 342         return CONTACTS_ERROR_NONE;
 343 }
 344