server/cal_server_alarm.c

   1 /*
   2  * Calendar Service
   3  *
   4  * Copyright (c) 2012 - 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
  20 #include <stdlib.h>
  21 #include <sys/time.h>
  22 #include <unistd.h>
  23 #include <alarm.h>
  24 #include <vconf.h>
  25 #include <app.h>
  26
  27 #include "calendar.h"
  28 #include "cal_typedef.h"
  29 #include "cal_internal.h"
  30 #include "cal_time.h"
  31 #include "cal_inotify.h"
  32 #include "cal_db_util.h"
  33 #include "cal_db.h"
  34 #include "cal_db_query.h"
  35 #include "cal_server_service.h"
  36 #include "cal_server_ondemand.h"
  37 #include "cal_server_dbus.h"
  38 #include "cal_server_alarm.h"
  39
  40 #define CAL_SERVER_ALARM_THREAD_NAME "cal_server_alarm"
  41
  42 GThread *_cal_server_alarm_thread = NULL;
  43 GCond _cal_server_alarm_cond;
  44 GMutex _cal_server_alarm_mutex;
  45 static bool server_killed = false;
  46 static bool signal_called = false;
  47
  48 struct _alarm_data_s {
  49         int event_id;
  50         long long int alert_utime; /* to compare */
  51         int unit;
  52         int tick;
  53         int type; /* utime, localtime */
  54         long long int time;
  55         int record; /* todo, event */
  56         char datetime[CAL_STR_SHORT_LEN32];
  57         int system_type;
  58 };
  59
  60 struct alarm_ud {
  61         GList *alarm_list;
  62 };
  63
  64 /* this api is necessary for repeat instance. */
  65 static int cal_server_alarm_unset_alerted_alarmmgr_id(int alarm_id)
  66 {
  67         char query[CAL_DB_SQL_MAX_LEN] = {0};
  68         int ret = 0;
  69
  70         ret = cal_db_util_begin_trans();
  71         if (CALENDAR_ERROR_NONE != ret) {
  72                 /* LCOV_EXCL_START */
  73                 ERR("cal_db_util_begin_trans() Fail");
  74                 return CALENDAR_ERROR_DB_FAILED;
  75                 /* LCOV_EXCL_STOP */
  76         }
  77
  78         DBG("alarm_id(%d)", alarm_id);
  79
  80         snprintf(query, sizeof(query), "UPDATE %s SET alarm_id = 0 WHERE alarm_id =%d ",
  81                         CAL_TABLE_ALARM, alarm_id);
  82         ret = cal_db_util_query_exec(query);
  83         if (CALENDAR_ERROR_NONE != ret) {
  84                 /* LCOV_EXCL_START */
  85                 ERR("cal_db_util_query_exec() Fail(%d)", ret);
  86                 SECURE("[%s]", query);
  87                 cal_db_util_end_trans(false);
  88                 return ret;
  89                 /* LCOV_EXCL_STOP */
  90         }
  91         cal_db_util_end_trans(true);
  92         return CALENDAR_ERROR_NONE;
  93 }
  94
  95 static int _cal_server_alarm_clear_all_cb(alarm_id_t alarm_id, void *data)
  96 {
  97         int ret;
  98
  99         DBG("remove alarm id(%d)", alarm_id);
 100         cal_server_alarm_unset_alerted_alarmmgr_id(alarm_id);
 101         ret = alarmmgr_remove_alarm(alarm_id);
 102         if (ret != ALARMMGR_RESULT_SUCCESS) {
 103                 /* LCOV_EXCL_START */
 104                 ERR("alarmmgr_remove_alarm() Fail(ret:%d)", ret);
 105                 return ret;
 106                 /* LCOV_EXCL_STOP */
 107         }
 108         return CALENDAR_ERROR_NONE;
 109 }
 110
 111 static int _cal_server_alarm_update_alarm_id(int alarm_id, int event_id, int tick, int unit)
 112 {
 113         char query[CAL_DB_SQL_MAX_LEN] = {0};
 114         int ret = 0;
 115
 116         ret = cal_db_util_begin_trans();
 117         if (CALENDAR_ERROR_NONE != ret) {
 118                 /* LCOV_EXCL_START */
 119                 ERR("cal_db_util_begin_trans() Fail");
 120                 return CALENDAR_ERROR_DB_FAILED;
 121                 /* LCOV_EXCL_STOP */
 122         }
 123
 124         DBG("Update alarm_id(%d) in alarm table", alarm_id);
 125         snprintf(query, sizeof(query), "UPDATE %s SET alarm_id =%d "
 126                         "WHERE event_id =%d AND remind_tick =%d AND remind_tick_unit =%d",
 127                         CAL_TABLE_ALARM, alarm_id, event_id, tick, unit);
 128         ret = cal_db_util_query_exec(query);
 129         if (CALENDAR_ERROR_NONE != ret) {
 130                 /* LCOV_EXCL_START */
 131                 ERR("cal_db_util_query_exec() Fail(%d)", ret);
 132                 SECURE("[%s]", query);
 133                 cal_db_util_end_trans(false);
 134                 return ret;
 135                 /* LCOV_EXCL_STOP */
 136         }
 137         cal_db_util_end_trans(true);
 138         return CALENDAR_ERROR_NONE;
 139 }
 140
 141 static long long int _get_event_alert_utime(const char *field, int event_id, time_t current)
 142 {
 143         int ret = 0;
 144         char query[CAL_DB_SQL_MAX_LEN] = {0};
 145         snprintf(query, sizeof(query), "SELECT %s FROM %s "
 146                         "WHERE event_id=%d AND %s>%ld ORDER BY %s LIMIT 1",
 147                         field, CAL_TABLE_UTIME_INSTANCE, event_id, field, current, field);
 148
 149         sqlite3_stmt *stmt = NULL;
 150         ret = cal_db_util_query_prepare(query, &stmt);
 151         if (CALENDAR_ERROR_NONE != ret) {
 152                 /* LCOV_EXCL_START */
 153                 ERR("cal_db_util_query_prepare() Fail(%d)", ret);
 154                 SECURE("query[%s]", query);
 155                 return ret;
 156                 /* LCOV_EXCL_STOP */
 157         }
 158
 159         long long int utime = 0;
 160         if (CAL_SQLITE_ROW == cal_db_util_stmt_step(stmt))
 161                 utime = sqlite3_column_int(stmt, 0);
 162
 163         sqlite3_finalize(stmt);
 164         return utime;
 165 }
 166
 167 static int _get_event_alert_localtime(const char *field, int event_id, time_t current)
 168 {
 169         int ret = 0;
 170         char query[CAL_DB_SQL_MAX_LEN] = {0};
 171         struct tm st = {0};
 172         tzset();
 173         localtime_r(&current, &st);
 174         time_t mod_current = timegm(&st);
 175         snprintf(query, sizeof(query), "SELECT %s FROM %s "
 176                         "WHERE event_id=%d AND strftime('%%s', %s)>%ld ORDER BY %s LIMIT 1",
 177                         field, CAL_TABLE_LOCALTIME_INSTANCE, event_id, field, mod_current, field);
 178
 179         sqlite3_stmt *stmt = NULL;
 180         ret = cal_db_util_query_prepare(query, &stmt);
 181         if (CALENDAR_ERROR_NONE != ret) {
 182                 /* LCOV_EXCL_START */
 183                 ERR("cal_db_util_query_prepare() Fail(%d)", ret);
 184                 SECURE("query[%s]", query);
 185                 return ret;
 186                 /* LCOV_EXCL_STOP */
 187         }
 188
 189         const char *datetime = NULL;
 190         if (CAL_SQLITE_ROW == cal_db_util_stmt_step(stmt))
 191                 datetime = (const char *)sqlite3_column_text(stmt, 0);
 192
 193         if (NULL == datetime || '\0' == *datetime) {
 194                 /* LCOV_EXCL_START */
 195                 ERR("Invalid datetime [%s]", datetime);
 196                 sqlite3_finalize(stmt);
 197                 return 0;
 198                 /* LCOV_EXCL_STOP */
 199         }
 200
 201         int y = 0, m = 0, d = 0;
 202         int h = 0, n = 0, s = 0;
 203         sscanf(datetime, CAL_FORMAT_LOCAL_DATETIME, &y, &m, &d, &h, &n, &s);
 204         sqlite3_finalize(stmt);
 205
 206         st.tm_year = y - 1900;
 207         st.tm_mon = m - 1;
 208         st.tm_mday = d;
 209         st.tm_hour = h;
 210         st.tm_min = n;
 211         st.tm_sec = s;
 212
 213         return (long long int)mktime(&st);
 214 }
 215
 216 static int64_t _get_todo_alert_utime(const char *field, int id, time_t now_t)
 217 {
 218         int ret = 0;
 219         char query[CAL_DB_SQL_MAX_LEN] = {0};
 220         snprintf(query, sizeof(query), "SELECT %s FROM "CAL_TABLE_SCHEDULE" "
 221                         "WHERE id=%d AND %s>%ld ORDER BY %s LIMIT 1", field, id, field, now_t, field);
 222
 223         sqlite3_stmt *stmt = NULL;
 224         ret = cal_db_util_query_prepare(query, &stmt);
 225         if (CALENDAR_ERROR_NONE != ret) {
 226                 /* LCOV_EXCL_START */
 227                 ERR("cal_db_util_query_prepare() Fail(%d)", ret);
 228                 SECURE("query[%s]", query);
 229                 return ret;
 230                 /* LCOV_EXCL_STOP */
 231         }
 232
 233         int64_t utime = 0;
 234         ret = cal_db_util_stmt_step(stmt);
 235         switch (ret) {
 236         case CAL_SQLITE_ROW:
 237                 utime = (int64_t)sqlite3_column_int64(stmt, 0);
 238                 break;
 239                 /* LCOV_EXCL_START */
 240         case SQLITE_DONE:
 241                 ERR("No data");
 242                 break;
 243         default:
 244                 ERR("Invalid return(%d)", ret);
 245                 break;
 246                 /* LCOV_EXCL_STOP */
 247         }
 248
 249         sqlite3_finalize(stmt);
 250         return utime;
 251 }
 252
 253 static int _get_todo_alert_localtime(const char *field, int event_id, time_t current)
 254 {
 255         int ret = 0;
 256         char query[CAL_DB_SQL_MAX_LEN] = {0};
 257         struct tm st = {0};
 258         tzset();
 259         localtime_r(&current, &st);
 260         time_t mod_current = timegm(&st);
 261         snprintf(query, sizeof(query), "SELECT %s FROM %s "
 262                         "WHERE id=%d AND strftime('%%s', %s)>%ld ORDER BY %s LIMIT 1",
 263                         field, CAL_TABLE_SCHEDULE, event_id, field, mod_current, field);
 264
 265         sqlite3_stmt *stmt = NULL;
 266         ret = cal_db_util_query_prepare(query, &stmt);
 267         if (CALENDAR_ERROR_NONE != ret) {
 268                 /* LCOV_EXCL_START */
 269                 ERR("cal_db_util_query_prepare() Fail(%d)", ret);
 270                 SECURE("query[%s]", query);
 271                 return ret;
 272                 /* LCOV_EXCL_STOP */
 273         }
 274
 275         const char *datetime = NULL;
 276         if (CAL_SQLITE_ROW == cal_db_util_stmt_step(stmt))
 277                 datetime = (const char *)sqlite3_column_text(stmt, 0);
 278
 279         if (NULL == datetime || '\0' == *datetime) {
 280                 /* LCOV_EXCL_START */
 281                 ERR("Invalid datetime [%s]", datetime);
 282                 sqlite3_finalize(stmt);
 283                 return 0;
 284                 /* LCOV_EXCL_STOP */
 285         }
 286
 287         int y = 0, m = 0, d = 0;
 288         int h = 0, n = 0, s = 0;
 289         sscanf(datetime, CAL_FORMAT_LOCAL_DATETIME, &y, &m, &d, &h, &n, &s);
 290         sqlite3_finalize(stmt);
 291
 292         st.tm_year = y - 1900;
 293         st.tm_mon = m - 1;
 294         st.tm_mday = d;
 295         st.tm_hour = h;
 296         st.tm_min = n;
 297         st.tm_sec = s;
 298
 299         return (long long int)mktime(&st);
 300 }
 301 /*
 302  * time(NULL) is not appropriate as parameter.
 303  * 1 seconds could be flowed before calling function.(1 sec time diff)
 304  * so, searching DB is neccessary to find alert time.
 305  */
 306 static int cal_server_alarm_get_alert_time(int alarm_id, time_t *tt_alert)
 307 {
 308         int ret = 0;
 309         RETV_IF(NULL == tt_alert, CALENDAR_ERROR_INVALID_PARAMETER);
 310
 311         char query[CAL_DB_SQL_MAX_LEN] = {0};
 312         snprintf(query, sizeof(query), "SELECT A.event_id, A.remind_tick_unit, A.remind_tick, "
 313                         "A.alarm_type, A.alarm_utime, A.alarm_datetime, B.type, B.dtstart_type, "
 314                         "B.dtend_type FROM %s as A, %s as B ON A.event_id =B.id WHERE alarm_id =%d ",
 315                         CAL_TABLE_ALARM, CAL_TABLE_SCHEDULE, alarm_id);
 316
 317         sqlite3_stmt *stmt = NULL;
 318         ret = cal_db_util_query_prepare(query, &stmt);
 319         if (CALENDAR_ERROR_NONE != ret) {
 320                 /* LCOV_EXCL_START */
 321                 ERR("cal_db_util_query_prepare() Fail(%d)", ret);
 322                 SECURE("query[%s]", query);
 323                 return ret;
 324                 /* LCOV_EXCL_STOP */
 325         }
 326
 327         int event_id = 0;
 328         int unit = 0;
 329         int tick = 0;
 330         int type = 0;
 331         long long int utime = 0;
 332         const char *datetime = NULL;
 333         int record_type = 0;
 334         int dtstart_type = 0;
 335         int dtend_type = 0;
 336         struct tm st = {0};
 337
 338         if (CAL_SQLITE_ROW == cal_db_util_stmt_step(stmt)) {
 339                 event_id = sqlite3_column_int(stmt, 0);
 340                 unit = sqlite3_column_int(stmt, 1);
 341                 tick = sqlite3_column_int(stmt, 2);
 342                 type = sqlite3_column_int(stmt, 3);
 343                 utime = sqlite3_column_int64(stmt, 4);
 344                 datetime = (const char *)sqlite3_column_text(stmt, 5);
 345                 record_type = sqlite3_column_int(stmt, 6);
 346                 dtstart_type = sqlite3_column_int(stmt, 7);
 347                 dtend_type = sqlite3_column_int(stmt, 8);
 348         }
 349
 350         if (CALENDAR_ALARM_TIME_UNIT_SPECIFIC == unit) {
 351                 if (CALENDAR_TIME_UTIME == type) {
 352                         *tt_alert = utime;
 353                 } else {
 354                         int y = 0, m = 0, d = 0;
 355                         int h = 0, n = 0, s = 0;
 356                         if (datetime) {
 357                                 sscanf(datetime, CAL_FORMAT_LOCAL_DATETIME, &y, &m, &d, &h, &n, &s);
 358
 359                                 st.tm_year = y - 1900;
 360                                 st.tm_mon = m - 1;
 361                                 st.tm_mday = d;
 362                                 st.tm_hour = h;
 363                                 st.tm_min = n;
 364                                 st.tm_sec = s;
 365                                 *tt_alert = mktime(&st);
 366                                 DBG("datetime[%s] to %02d:%02d:%02d (%d)", datetime, h, n, s, *tt_alert);
 367                         }
 368                 }
 369                 sqlite3_finalize(stmt);
 370                 return CALENDAR_ERROR_NONE;
 371         }
 372         sqlite3_finalize(stmt);
 373
 374         time_t current = time(NULL);
 375         current += (tick * unit);
 376         current -= 2; /* in case time passed */
 377
 378         switch (record_type) {
 379         case CALENDAR_BOOK_TYPE_EVENT:
 380                 switch (dtstart_type) {
 381                 case CALENDAR_TIME_UTIME:
 382                         utime = _get_event_alert_utime("dtstart_utime", event_id, current);
 383                         break;
 384
 385                 case CALENDAR_TIME_LOCALTIME:
 386                         utime = _get_event_alert_localtime("dtstart_datetime", event_id, current);
 387                         break;
 388                 }
 389                 break;
 390
 391         case CALENDAR_BOOK_TYPE_TODO:
 392                 switch (dtend_type) {
 393                 case CALENDAR_TIME_UTIME:
 394                         utime = _get_todo_alert_utime("dtend_utime", event_id, current);
 395                         break;
 396
 397                 case CALENDAR_TIME_LOCALTIME:
 398                         utime = _get_todo_alert_localtime("dtend_datetime", event_id, current);
 399                         break;
 400                 }
 401                 break;
 402         }
 403         DBG("alert_time(%d) = utime(%lld) - (tick(%d) * unit(%d))", *tt_alert, utime, tick, unit);
 404
 405         *tt_alert = utime - (tick * unit);
 406         return CALENDAR_ERROR_NONE;
 407 }
 408
 409 /*
 410  * bool get_all is
 411  * true : to get all alarms including same time event.
 412  * (ig. if 3 diffrent alarms exist at 06:30, list has 3 data)
 413  * false : to get only one alarm to register in alarm-manager.
 414  * (ig. if 3 diffrent alarms exist at 06:30, list has only one)
 415  */
 416 static void _cal_server_alarm_get_upcoming_specific_utime(time_t utime, bool get_all, GList **l)
 417 {
 418         int ret = 0;
 419         char query[CAL_DB_SQL_MAX_LEN] = {0};
 420         snprintf(query, sizeof(query), "SELECT event_id,remind_tick_unit,remind_tick,"
 421                         "alarm_type,alarm_utime,alarm_datetime "
 422                         "FROM %s WHERE remind_tick_unit =%d AND alarm_type =%d AND alarm_utime %s %ld %s",
 423                         CAL_TABLE_ALARM, CALENDAR_ALARM_TIME_UNIT_SPECIFIC, CALENDAR_TIME_UTIME,
 424                         true == get_all ? "=" : ">", utime,
 425                         true == get_all ? "" : "ORDER BY alarm_utime ASC LIMIT 1");
 426
 427         sqlite3_stmt *stmt = NULL;
 428         ret = cal_db_util_query_prepare(query, &stmt);
 429         if (CALENDAR_ERROR_NONE != ret) {
 430                 /* LCOV_EXCL_START */
 431                 ERR("cal_db_util_query_prepare() Fail(%d)", ret);
 432                 SECURE("query[%s]", query);
 433                 return;
 434                 /* LCOV_EXCL_STOP */
 435         }
 436
 437         while (CAL_SQLITE_ROW == cal_db_util_stmt_step(stmt)) {
 438                 struct _alarm_data_s *ad = calloc(1, sizeof(struct _alarm_data_s));
 439                 if (NULL == ad) {
 440                         /* LCOV_EXCL_START */
 441                         ERR("calloc() Fail");
 442                         sqlite3_finalize(stmt);
 443                         return;
 444                         /* LCOV_EXCL_STOP */
 445                 }
 446
 447                 ad->event_id = sqlite3_column_int(stmt, 0);
 448                 ad->unit = sqlite3_column_int(stmt, 1);
 449                 ad->tick = sqlite3_column_int(stmt, 2);
 450                 ad->type = sqlite3_column_int(stmt, 3);
 451                 ad->time = (long long int)sqlite3_column_int64(stmt, 4);
 452                 snprintf(ad->datetime, sizeof(ad->datetime), "%s", (const char *)sqlite3_column_text(stmt, 5));
 453                 *l = g_list_append(*l, ad);
 454                 DBG("found id(%d) unit(%d) tick(%d) type(%d) time(%lld) [%s]",
 455                                 ad->event_id, ad->unit, ad->tick, ad->type, ad->time, ad->datetime);
 456                 ad->alert_utime = ad->time;
 457                 if (false == get_all) break;
 458         }
 459         sqlite3_finalize(stmt);
 460 }
 461
 462 static void _cal_server_alarm_get_upcoming_specific_localtime(const char *datetime, bool get_all, GList **l)
 463 {
 464         int ret = 0;
 465         char query[CAL_DB_SQL_MAX_LEN] = {0};
 466         snprintf(query, sizeof(query), "SELECT event_id,remind_tick_unit,remind_tick,"
 467                         "alarm_type,alarm_utime,alarm_datetime "
 468                         "FROM %s WHERE remind_tick_unit=%d AND alarm_type=%d AND alarm_datetime %s '%s' %s",
 469                         CAL_TABLE_ALARM, CALENDAR_ALARM_TIME_UNIT_SPECIFIC, CALENDAR_TIME_LOCALTIME,
 470                         true == get_all ? "=" : ">", datetime,
 471                         true == get_all ? "" : "ORDER BY alarm_datetime ASC LIMIT 1");
 472
 473         sqlite3_stmt *stmt = NULL;
 474         ret = cal_db_util_query_prepare(query, &stmt);
 475         if (CALENDAR_ERROR_NONE != ret) {
 476                 /* LCOV_EXCL_START */
 477                 ERR("cal_db_util_query_prepare() Fail(%d)", ret);
 478                 SECURE("query[%s]", query);
 479                 return;
 480                 /* LCOV_EXCL_STOP */
 481         }
 482
 483         while (CAL_SQLITE_ROW == cal_db_util_stmt_step(stmt)) {
 484                 struct _alarm_data_s *ad = calloc(1, sizeof(struct _alarm_data_s));
 485                 if (NULL == ad) {
 486                         /* LCOV_EXCL_START */
 487                         ERR("calloc() Fail");
 488                         sqlite3_finalize(stmt);
 489                         return;
 490                         /* LCOV_EXCL_STOP */
 491                 }
 492
 493                 ad->event_id = sqlite3_column_int(stmt, 0);
 494                 ad->unit = sqlite3_column_int(stmt, 1);
 495                 ad->tick = sqlite3_column_int(stmt, 2);
 496                 ad->type = sqlite3_column_int(stmt, 3);
 497                 ad->time = (long long int)sqlite3_column_int64(stmt, 4);
 498                 snprintf(ad->datetime, sizeof(ad->datetime), "%s", (const char *)sqlite3_column_text(stmt, 5));
 499                 *l = g_list_append(*l, ad);
 500                 DBG("found id(%d) unit(%d) tick(%d) type(%d) time(%lld) [%s]",
 501                                 ad->event_id, ad->unit, ad->tick, ad->type, ad->time, ad->datetime);
 502
 503                 int y = 0, m = 0, d = 0;
 504                 int h = 0, n = 0, s = 0;
 505                 sscanf(ad->datetime, CAL_FORMAT_LOCAL_DATETIME, &y, &m, &d, &h, &n, &s);
 506
 507                 struct tm st = {0};
 508                 st.tm_year = y - 1900;
 509                 st.tm_mon = m -1;
 510                 st.tm_mday = d;
 511                 st.tm_hour = h;
 512                 st.tm_min = n;
 513                 st.tm_sec = s;
 514                 ad->alert_utime = (long long int)mktime(&st);
 515                 if (false == get_all) break;
 516         }
 517         sqlite3_finalize(stmt);
 518 }
 519
 520 static void _cal_server_alarm_get_upcoming_nonspecific_event_utime(time_t utime, bool get_all, GList **l)
 521 {
 522         int ret = 0;
 523         /*
 524          * A:alarm
 525          * B:utime
 526          */
 527         char query[CAL_DB_SQL_MAX_LEN] = {0};
 528         snprintf(query, sizeof(query), "SELECT A.event_id,A.remind_tick_unit,A.remind_tick, "
 529                         "A.alarm_type,B.dtstart_utime,A.alarm_datetime "
 530                         "FROM %s as A, %s as B ON A.event_id = B.event_id "
 531                         "WHERE A.remind_tick_unit >%d AND (B.dtstart_utime - (A.remind_tick_unit * A.remind_tick)) %s %ld %s",
 532                         CAL_TABLE_ALARM, CAL_TABLE_UTIME_INSTANCE, CALENDAR_ALARM_TIME_UNIT_SPECIFIC,
 533                         true == get_all ? "=" : ">", utime,
 534                         true == get_all ? "" : "ORDER BY (B.dtstart_utime - (A.remind_tick_unit * A.remind_tick)) LIMIT 1");
 535
 536         sqlite3_stmt *stmt = NULL;
 537         ret = cal_db_util_query_prepare(query, &stmt);
 538         if (CALENDAR_ERROR_NONE != ret) {
 539                 /* LCOV_EXCL_START */
 540                 ERR("cal_db_util_query_prepare() Fail(%d)", ret);
 541                 SECURE("query[%s]", query);
 542                 return;
 543                 /* LCOV_EXCL_STOP */
 544         }
 545
 546         while (CAL_SQLITE_ROW == cal_db_util_stmt_step(stmt)) {
 547                 struct _alarm_data_s *ad = calloc(1, sizeof(struct _alarm_data_s));
 548                 if (NULL == ad) {
 549                         /* LCOV_EXCL_START */
 550                         ERR("calloc() Fail");
 551                         sqlite3_finalize(stmt);
 552                         return;
 553                         /* LCOV_EXCL_STOP */
 554                 }
 555
 556                 ad->event_id = sqlite3_column_int(stmt, 0);
 557                 ad->unit = sqlite3_column_int(stmt, 1);
 558                 ad->tick = sqlite3_column_int(stmt, 2);
 559                 ad->type = sqlite3_column_int(stmt, 3);
 560                 ad->time = (long long int)sqlite3_column_int64(stmt, 4);
 561                 snprintf(ad->datetime, sizeof(ad->datetime), "%s", (const char *)sqlite3_column_text(stmt, 5));
 562                 *l = g_list_append(*l, ad);
 563                 DBG("found id(%d) unit(%d) tick(%d) type(%d) time(%lld) [%s]",
 564                                 ad->event_id, ad->unit, ad->tick, ad->type, ad->time, ad->datetime);
 565
 566                 ad->alert_utime = ad->time - (ad->tick * ad->unit);
 567                 if (false == get_all) break;
 568         }
 569         sqlite3_finalize(stmt);
 570 }
 571
 572 static void _cal_server_alarm_get_upcoming_nonspecific_event_localtime(const char *datetime, bool get_all, GList **l)
 573 {
 574         int ret = 0;
 575         /*
 576          * A:alarm
 577          * B:localtime
 578          */
 579         char query[CAL_DB_SQL_MAX_LEN] = {0};
 580         snprintf(query, sizeof(query), "SELECT A.event_id,A.remind_tick_unit,A.remind_tick, "
 581                         "A.alarm_type,A.alarm_utime,B.dtstart_datetime "
 582                         "FROM %s as A, %s as B ON A.event_id = B.event_id "
 583                         "WHERE A.remind_tick_unit >%d AND "
 584                         "(strftime('%%s', B.dtstart_datetime) - (A.remind_tick_unit * A.remind_tick) - strftime('%%s', '%s') %s 0) %s",
 585                         CAL_TABLE_ALARM, CAL_TABLE_LOCALTIME_INSTANCE, CALENDAR_ALARM_TIME_UNIT_SPECIFIC,
 586                         datetime, true == get_all ? "=" : ">",
 587                         true == get_all ? "" : "ORDER BY (strftime('%s', B.dtstart_datetime) - (A.remind_tick_unit * A.remind_tick)) LIMIT 1 ");
 588         sqlite3_stmt *stmt = NULL;
 589         ret = cal_db_util_query_prepare(query, &stmt);
 590         if (CALENDAR_ERROR_NONE != ret) {
 591                 /* LCOV_EXCL_START */
 592                 ERR("cal_db_util_query_prepare() Fail(%d)", ret);
 593                 SECURE("query[%s]", query);
 594                 return;
 595                 /* LCOV_EXCL_STOP */
 596         }
 597
 598         while (CAL_SQLITE_ROW == cal_db_util_stmt_step(stmt)) {
 599                 struct _alarm_data_s *ad = calloc(1, sizeof(struct _alarm_data_s));
 600                 if (NULL == ad) {
 601                         /* LCOV_EXCL_START */
 602                         ERR("calloc() Fail");
 603                         sqlite3_finalize(stmt);
 604                         return;
 605                         /* LCOV_EXCL_STOP */
 606                 }
 607
 608                 ad->event_id = sqlite3_column_int(stmt, 0);
 609                 ad->unit = sqlite3_column_int(stmt, 1);
 610                 ad->tick = sqlite3_column_int(stmt, 2);
 611                 ad->type = sqlite3_column_int(stmt, 3);
 612                 ad->time = (long long int)sqlite3_column_int64(stmt, 4);
 613                 snprintf(ad->datetime, sizeof(ad->datetime), "%s", (const char *)sqlite3_column_text(stmt, 5));
 614                 *l = g_list_append(*l, ad);
 615                 DBG("found id(%d) unit(%d) tick(%d) type(%d) time(%lld) [%s]",
 616                                 ad->event_id, ad->unit, ad->tick, ad->type, ad->time, ad->datetime);
 617
 618                 int y = 0, m = 0, d = 0;
 619                 int h = 0, n = 0, s = 0;
 620                 sscanf(ad->datetime, CAL_FORMAT_LOCAL_DATETIME, &y, &m, &d, &h, &n, &s);
 621
 622                 struct tm st = {0};
 623                 st.tm_year = y - 1900;
 624                 st.tm_mon = m -1;
 625                 st.tm_mday = d;
 626                 st.tm_hour = h;
 627                 st.tm_min = n;
 628                 st.tm_sec = s;
 629                 ad->alert_utime = (long long int)mktime(&st) - (ad->tick * ad->unit);
 630                 if (false == get_all) break;
 631         }
 632         sqlite3_finalize(stmt);
 633 }
 634
 635 static void _cal_server_alarm_get_upcoming_nonspecific_todo_utime(time_t utime, bool get_all, GList **l)
 636 {
 637         int ret = 0;
 638         /*
 639          * A:alarm
 640          * B:todo(utime)
 641          */
 642         char query[CAL_DB_SQL_MAX_LEN] = {0};
 643         snprintf(query, sizeof(query), "SELECT A.event_id,A.remind_tick_unit,A.remind_tick,"
 644                         "A.alarm_type,B.dtend_utime,A.alarm_datetime "
 645                         "FROM %s as A, %s as B ON A.event_id = B.id "
 646                         "WHERE A.remind_tick_unit >%d AND B.type =%d "
 647                         "AND (B.dtend_utime - (A.remind_tick_unit * A.remind_tick)) %s %ld %s",
 648                         CAL_TABLE_ALARM, CAL_TABLE_SCHEDULE,
 649                         CALENDAR_ALARM_TIME_UNIT_SPECIFIC, CALENDAR_BOOK_TYPE_TODO,
 650                         true == get_all ? "=" : ">", utime,
 651                         true == get_all ? "" : "ORDER BY (B.dtend_utime - (A.remind_tick_unit * A.remind_tick)) LIMIT 1 ");
 652
 653         sqlite3_stmt *stmt = NULL;
 654         ret = cal_db_util_query_prepare(query, &stmt);
 655         if (CALENDAR_ERROR_NONE != ret) {
 656                 /* LCOV_EXCL_START */
 657                 ERR("cal_db_util_query_prepare() Fail(%d)", ret);
 658                 SECURE("query[%s]", query);
 659                 return;
 660                 /* LCOV_EXCL_STOP */
 661         }
 662
 663         while (CAL_SQLITE_ROW == cal_db_util_stmt_step(stmt)) {
 664                 struct _alarm_data_s *ad = calloc(1, sizeof(struct _alarm_data_s));
 665                 if (NULL == ad) {
 666                         /* LCOV_EXCL_START */
 667                         ERR("calloc() Fail");
 668                         sqlite3_finalize(stmt);
 669                         return;
 670                         /* LCOV_EXCL_STOP */
 671                 }
 672
 673                 ad->event_id = sqlite3_column_int(stmt, 0);
 674                 ad->unit = sqlite3_column_int(stmt, 1);
 675                 ad->tick = sqlite3_column_int(stmt, 2);
 676                 ad->type = sqlite3_column_int(stmt, 3);
 677                 ad->time = (long long int)sqlite3_column_int64(stmt, 4);
 678                 snprintf(ad->datetime, sizeof(ad->datetime), "%s", (const char *)sqlite3_column_text(stmt, 5));
 679                 *l = g_list_append(*l, ad);
 680                 DBG("found id(%d) unit(%d) tick(%d) type(%d) time(%lld) [%s]",
 681                                 ad->event_id, ad->unit, ad->tick, ad->type, ad->time, ad->datetime);
 682
 683                 ad->alert_utime = ad->time - (ad->tick * ad->unit);
 684                 if (false == get_all) break;
 685         }
 686         sqlite3_finalize(stmt);
 687 }
 688
 689 static void _cal_server_alarm_get_upcoming_nonspecific_todo_localtime(const char *datetime, bool get_all, GList **l)
 690 {
 691         int ret = 0;
 692         /*
 693          * A:alarm
 694          * B:todo(localtime)
 695          */
 696         char query[CAL_DB_SQL_MAX_LEN] = {0};
 697         snprintf(query, sizeof(query), "SELECT A.event_id,A.remind_tick_unit,A.remind_tick,"
 698                         "A.alarm_type,A.alarm_utime,B.dtend_datetime "
 699                         "FROM %s as A, %s as B ON A.event_id = B.id "
 700                         "WHERE A.remind_tick_unit >%d AND B.type =%d "
 701                         "AND (strftime('%%s', B.dtend_datetime) - (A.remind_tick_unit * A.remind_tick) - strftime('%%s', '%s') %s 0) %s",
 702                         CAL_TABLE_ALARM, CAL_TABLE_SCHEDULE,
 703                         CALENDAR_ALARM_TIME_UNIT_SPECIFIC, CALENDAR_BOOK_TYPE_TODO,
 704                         datetime, true == get_all ? "=" : ">",
 705                         true == get_all ? "" : "ORDER BY (strftime('%s', B.dtend_datetime) - (A.remind_tick_unit * A.remind_tick)) LIMIT 1 ");
 706
 707         sqlite3_stmt *stmt = NULL;
 708         ret = cal_db_util_query_prepare(query, &stmt);
 709         if (CALENDAR_ERROR_NONE != ret) {
 710                 /* LCOV_EXCL_START */
 711                 ERR("cal_db_util_query_prepare() Fail(%d)", ret);
 712                 SECURE("query[%s]", query);
 713                 return;
 714                 /* LCOV_EXCL_STOP */
 715         }
 716
 717         while (CAL_SQLITE_ROW == cal_db_util_stmt_step(stmt)) {
 718                 struct _alarm_data_s *ad = calloc(1, sizeof(struct _alarm_data_s));
 719                 if (NULL == ad) {
 720                         /* LCOV_EXCL_START */
 721                         ERR("calloc() Fail");
 722                         sqlite3_finalize(stmt);
 723                         return;
 724                         /* LCOV_EXCL_STOP */
 725                 }
 726
 727                 ad->event_id = sqlite3_column_int(stmt, 0);
 728                 ad->unit = sqlite3_column_int(stmt, 1);
 729                 ad->tick = sqlite3_column_int(stmt, 2);
 730                 ad->type = sqlite3_column_int(stmt, 3);
 731                 ad->time = (long long int)sqlite3_column_int64(stmt, 4);
 732                 snprintf(ad->datetime, sizeof(ad->datetime), "%s", (const char *)sqlite3_column_text(stmt, 5));
 733                 *l = g_list_append(*l, ad);
 734                 DBG("found id(%d) unit(%d) tick(%d) type(%d) time(%lld) [%s]",
 735                                 ad->event_id, ad->unit, ad->tick, ad->type, ad->time, ad->datetime);
 736
 737                 int y = 0, m = 0, d = 0;
 738                 int h = 0, n = 0, s = 0;
 739                 sscanf(ad->datetime, CAL_FORMAT_LOCAL_DATETIME, &y, &m, &d, &h, &n, &s);
 740
 741                 struct tm st = {0};
 742                 st.tm_year = y - 1900;
 743                 st.tm_mon = m -1;
 744                 st.tm_mday = d;
 745                 st.tm_hour = h;
 746                 st.tm_min = n;
 747                 st.tm_sec = s;
 748                 ad->alert_utime = (long long int)mktime(&st) - (ad->tick * ad->unit);
 749                 if (false == get_all) break;
 750         }
 751         sqlite3_finalize(stmt);
 752 }
 753
 754 static void _cal_server_alarm_get_latest(time_t utime, bool get_all, GList **out_l)
 755 {
 756         CAL_FN_CALL();
 757         RET_IF(NULL == out_l);
 758
 759         tzset();
 760         struct tm st_local = {0};
 761         localtime_r(&utime, &st_local);
 762
 763         char datetime[CAL_STR_SHORT_LEN32] = {0};
 764         snprintf(datetime, sizeof(datetime), CAL_FORMAT_LOCAL_DATETIME,
 765                         st_local.tm_year +1900, st_local.tm_mon + 1, st_local.tm_mday,
 766                         st_local.tm_hour, st_local.tm_min, st_local.tm_sec);
 767         DBG("get alert to register with given time (%ld) datetime[%s]", utime, datetime);
 768
 769         GList *l = NULL;
 770
 771         _cal_server_alarm_get_upcoming_specific_utime(utime, get_all, &l);
 772         _cal_server_alarm_get_upcoming_nonspecific_event_utime(utime, get_all, &l);
 773         _cal_server_alarm_get_upcoming_nonspecific_todo_utime(utime, get_all, &l);
 774
 775         _cal_server_alarm_get_upcoming_specific_localtime(datetime, get_all, &l);
 776         _cal_server_alarm_get_upcoming_nonspecific_event_localtime(datetime, get_all, &l);
 777         _cal_server_alarm_get_upcoming_nonspecific_todo_localtime(datetime, get_all, &l);
 778
 779         *out_l = l;
 780 }
 781
 782 static gint _cal_server_alarm_sort_cb(gconstpointer a, gconstpointer b)
 783 {
 784         struct _alarm_data_s *p1 = (struct _alarm_data_s *)a;
 785         struct _alarm_data_s *p2 = (struct _alarm_data_s *)b;
 786         DBG("%lld) > (%lld)", p1->alert_utime, p2->alert_utime);
 787
 788         return p1->alert_utime < p2->alert_utime ? -1 : 1;
 789 }
 790
 791 static GFunc _cal_server_alarm_print_cb(gpointer data, gpointer user_data)
 792 {
 793         struct _alarm_data_s *ad = (struct _alarm_data_s *)data;
 794         DBG("id(%d) unit(%d) tick(%d) type(%d) time(%lld) datetime[%s]",
 795                         ad->event_id, ad->unit, ad->tick, ad->type, ad->time, ad->datetime);
 796         return 0;
 797 }
 798
 799 static int _cal_server_alarm_register(GList *alarm_list)
 800 {
 801         CAL_FN_CALL();
 802         RETV_IF(NULL == alarm_list, CALENDAR_ERROR_INVALID_PARAMETER);
 803
 804         int ret = CALENDAR_ERROR_NONE;
 805         GList *l = g_list_first(alarm_list);
 806         struct _alarm_data_s *ad = (struct _alarm_data_s *)l->data;
 807         RETVM_IF(NULL == ad, CALENDAR_ERROR_DB_FAILED, "No data");
 808
 809         /* clear all alarm which set by mine. */
 810         ret = alarmmgr_enum_alarm_ids(_cal_server_alarm_clear_all_cb, NULL);
 811         if (ret != ALARMMGR_RESULT_SUCCESS) {
 812                 /* LCOV_EXCL_START */
 813                 ERR("alarmmgr_enum_alarm_ids() Fail");
 814                 return ret;
 815                 /* LCOV_EXCL_STOP */
 816         }
 817
 818         time_t mod_time = (time_t)ad->alert_utime;
 819         alarm_entry_t *alarm_info = NULL;
 820         alarm_info = alarmmgr_create_alarm();
 821         if (NULL == alarm_info) {
 822                 /* LCOV_EXCL_START */
 823                 ERR("Failed to create alarm");
 824                 return CALENDAR_ERROR_DB_FAILED;
 825                 /* LCOV_EXCL_STOP */
 826         }
 827         tzset();
 828         struct tm st_alarm = {0};
 829
 830         switch (ad->system_type) {
 831         case CALENDAR_SYSTEM_EAST_ASIAN_LUNISOLAR:
 832                 gmtime_r(&mod_time, &st_alarm);
 833                 break;
 834
 835         default:
 836                 tzset();
 837                 localtime_r(&mod_time, &st_alarm);
 838                 break;
 839         }
 840
 841         alarm_date_t date = {0};
 842         date.year = st_alarm.tm_year + 1900;
 843         date.month = st_alarm.tm_mon + 1;
 844         date.day = st_alarm.tm_mday;
 845         date.hour = st_alarm.tm_hour;
 846         date.min = st_alarm.tm_min;
 847         date.sec = st_alarm.tm_sec;
 848         alarmmgr_set_time(alarm_info, date);
 849         DBG(COLOR_CYAN" >>> registered record id (%d) at %04d/%02d/%02d %02d:%02d:%02d "COLOR_END" (utime(%lld), datetime[%s], tick(%d) unit(%d))",
 850                         ad->event_id, date.year, date.month, date.day, date.hour, date.min, date.sec,
 851                         ad->time, ad->datetime, ad->tick, ad->unit);
 852
 853         int alarm_id = 0;
 854         ret = alarmmgr_add_alarm_with_localtime(alarm_info, NULL, &alarm_id);
 855         if (ret < 0) {
 856                 /* LCOV_EXCL_START */
 857                 ERR("alarmmgr_add_alarm_with_localtime Fail (%d)", ret);
 858                 alarmmgr_free_alarm(alarm_info);
 859                 return ret;
 860                 /* LCOV_EXCL_STOP */
 861         }
 862         DBG("alarmmgr id (%d)", alarm_id);
 863         _cal_server_alarm_update_alarm_id(alarm_id, ad->event_id, ad->tick, ad->unit);
 864         alarmmgr_free_alarm(alarm_info);
 865         return CALENDAR_ERROR_NONE;
 866 }
 867
 868 static bool __app_matched_cb(app_control_h app_control, const char *package, void *user_data)
 869 {
 870         CAL_FN_CALL();
 871
 872         int ret = 0;
 873         int i;
 874
 875         RETV_IF(NULL == user_data, true);
 876
 877         char *mime = NULL;
 878         ret = app_control_get_mime(app_control, &mime);
 879         RETVM_IF(APP_CONTROL_ERROR_NONE != ret, true, "app_control_get_mime() Fail(%d)", ret);
 880
 881         const char *reminder_mime = "application/x-tizen.calendar.reminder";
 882         if (strncmp(mime, reminder_mime, strlen(reminder_mime))) { /* not same */
 883                 DBG("get mime[%s] is not [%s]", mime, reminder_mime);
 884                 free(mime);
 885                 return true;
 886         }
 887         free(mime);
 888
 889         struct alarm_ud *au = (struct alarm_ud *)user_data;
 890         GList *alarm_list = au->alarm_list;
 891         if (NULL == alarm_list) {
 892                 /* LCOV_EXCL_START */
 893                 ERR("No list");
 894                 return true;
 895                 /* LCOV_EXCL_STOP */
 896         }
 897         int len = 0;
 898         len = g_list_length(alarm_list);
 899         if (0 == len) {
 900                 DBG("len is 0, no alarm list");
 901                 return true;
 902         }
 903
 904         app_control_h ac = NULL;
 905         ret = app_control_create(&ac);
 906         if (APP_CONTROL_ERROR_NONE != ret) {
 907                 /* LCOV_EXCL_START */
 908                 ERR("app_control_create() Fail(%d)", ret);
 909                 return true;
 910                 /* LCOV_EXCL_STOP */
 911         }
 912         ret = app_control_set_operation(ac,  APP_CONTROL_OPERATION_DEFAULT);
 913         if (APP_CONTROL_ERROR_NONE != ret) {
 914                 /* LCOV_EXCL_START */
 915                 ERR("app_control_create() Fail(%d)", ret);
 916                 app_control_destroy(ac);
 917                 return true;
 918                 /* LCOV_EXCL_STOP */
 919         }
 920         ret = app_control_set_app_id(ac, package);
 921         if (APP_CONTROL_ERROR_NONE != ret) {
 922                 /* LCOV_EXCL_START */
 923                 ERR("app_control_set_app_id() Fail(%d)", ret);
 924                 app_control_destroy(ac);
 925                 return true;
 926                 /* LCOV_EXCL_STOP */
 927         }
 928
 929         char **ids = NULL;
 930         ids = calloc(len, sizeof(char *));
 931         if (NULL == ids) {
 932                 /* LCOV_EXCL_START */
 933                 ERR("calloc() Fail");
 934                 app_control_destroy(ac);
 935                 return true;
 936                 /* LCOV_EXCL_STOP */
 937         }
 938         GList *cursor = g_list_first(alarm_list);
 939         for (i = 0; i < len; i++) {
 940                 if (NULL == cursor){
 941                         ERR("cursor is NULL");
 942                         break;
 943                 }
 944                 struct _alarm_data_s *ad = (struct _alarm_data_s *)cursor->data;
 945                 if (NULL == ad) {
 946                         WARN("No data");
 947                         cursor = g_list_next(cursor);
 948                         continue;
 949                 }
 950                 DBG("pkg[%s] time[%lld] tick[%d] unit[%d] record_type[%d]",
 951                                 package, ad->time, ad->tick, ad->unit, ad->record);
 952
 953                 int slen = 0;
 954                 char extra[CAL_STR_MIDDLE_LEN] = {0};
 955                 slen = snprintf(extra, sizeof(extra), "%s=%d", "id", ad->event_id);
 956                 slen += snprintf(extra+slen, sizeof(extra)-slen, "&%s=%lld", "time", ad->time);
 957                 slen += snprintf(extra+slen, sizeof(extra)-slen, "&%s=%d", "tick", ad->tick);
 958                 slen += snprintf(extra+slen, sizeof(extra)-slen, "&%s=%d", "unit", ad->unit);
 959                 slen += snprintf(extra+slen, sizeof(extra)-slen, "&%s=%d", "type", ad->record);
 960
 961                 /*
 962                  * key: id, value: id=4&time=123123&..
 963                  */
 964                 char buf_id[CAL_STR_MIDDLE_LEN] = {0};
 965                 snprintf(buf_id, sizeof(buf_id), "%d", ad->event_id);
 966                 app_control_add_extra_data(ac, buf_id, extra);
 967                 DBG("value[%s] id[%s]", extra, buf_id);
 968
 969                 /* append ids */
 970                 ids[i] = strdup(buf_id);
 971
 972                 cursor = g_list_next(cursor);
 973         }
 974         app_control_add_extra_data_array(ac, "ids", (const char **)ids, len);
 975         app_control_send_launch_request(ac, NULL, NULL);
 976         app_control_destroy(ac);
 977
 978         g_list_free_full(alarm_list, free);
 979         for (i = 0; i < len; i++) {
 980                 free(ids[i]);
 981                 ids[i] = NULL;
 982         }
 983         free(ids);
 984
 985         return true;
 986 }
 987
 988 static void _cal_server_alarm_noti_with_control(GList *alarm_list)
 989 {
 990         CAL_FN_CALL();
 991
 992         int ret = 0;
 993         RETM_IF(NULL == alarm_list, "No alarm list");
 994
 995         app_control_h app_control = NULL;
 996         ret = app_control_create(&app_control);
 997         if (APP_CONTROL_ERROR_NONE != ret) {
 998                 /* LCOV_EXCL_START */
 999                 ERR("app_control_create() Fail(%d)", ret);
1000                 return;
1001                 /* LCOV_EXCL_STOP */
1002         }
1003         ret = app_control_set_operation(app_control, APP_CONTROL_OPERATION_VIEW);
1004         if (APP_CONTROL_ERROR_NONE != ret) {
1005                 /* LCOV_EXCL_START */
1006                 ERR("app_control_set_operation() Fail(%d)", ret);
1007                 app_control_destroy(app_control);
1008                 return;
1009                 /* LCOV_EXCL_STOP */
1010         }
1011         ret = app_control_set_mime(app_control, "application/x-tizen.calendar.reminder");
1012         if (APP_CONTROL_ERROR_NONE != ret) {
1013                 /* LCOV_EXCL_START */
1014                 ERR("app_control_set_mime() Fail(%d)", ret);
1015                 app_control_destroy(app_control);
1016                 return;
1017                 /* LCOV_EXCL_STOP */
1018         }
1019
1020         struct alarm_ud *au = calloc(1, sizeof(struct alarm_ud));
1021         if (NULL == au) {
1022                 /* LCOV_EXCL_START */
1023                 ERR("calloc() Fail");
1024                 app_control_destroy(app_control);
1025                 return;
1026                 /* LCOV_EXCL_STOP */
1027         }
1028         au->alarm_list = alarm_list;
1029         ret = app_control_foreach_app_matched(app_control, __app_matched_cb, au);
1030         if (APP_CONTROL_ERROR_NONE != ret) {
1031                 /* LCOV_EXCL_START */
1032                 ERR("app_control_foreach_app_matched() Fail(%d)", ret);
1033                 free(au);
1034                 app_control_destroy(app_control);
1035                 return;
1036                 /* LCOV_EXCL_STOP */
1037         }
1038         free(au);
1039         app_control_destroy(app_control);
1040 }
1041
1042 static void _cal_server_alarm_noti_with_callback(GList *alarm_list)
1043 {
1044         RETM_IF(NULL == alarm_list, "No alarm list");
1045
1046         GList *l = g_list_first(alarm_list);
1047         while (l) {
1048                 struct _alarm_data_s *ad = (struct _alarm_data_s *)l->data;
1049                 if (NULL == ad) {
1050                         WARN("No data");
1051                         l = g_list_next(l);
1052                         continue;
1053                 }
1054                 DBG("callback time[%lld] tick[%d] unit[%d] record_type[%d]",
1055                                 ad->time, ad->tick, ad->unit, ad->record);
1056
1057                 int len = 0;
1058                 char extra[CAL_STR_MIDDLE_LEN] = {0};
1059                 len = snprintf(extra, sizeof(extra), "%s=%d", "id", ad->event_id);
1060                 len += snprintf(extra+len, sizeof(extra)-len, "&%s=%lld", "time", ad->time);
1061                 len += snprintf(extra+len, sizeof(extra)-len, "&%s=%d", "tick", ad->tick);
1062                 len += snprintf(extra+len, sizeof(extra)-len, "&%s=%d", "unit", ad->unit);
1063                 len += snprintf(extra+len, sizeof(extra)-len, "&%s=%d", "type", ad->record);
1064                 cal_dbus_publish_reminder(len, extra);
1065
1066                 l = g_list_next(l);
1067         }
1068 }
1069
1070 static void cal_server_alarm_register_next_alarm(time_t utime)
1071 {
1072         CAL_FN_CALL();
1073
1074         GList *l = NULL;
1075         _cal_server_alarm_get_latest(utime, false, &l);
1076         if (NULL == l)
1077                 return;
1078
1079         l = g_list_sort(l, _cal_server_alarm_sort_cb);
1080         g_list_foreach(l, (GFunc)_cal_server_alarm_print_cb, NULL);
1081         _cal_server_alarm_register(l);
1082
1083         g_list_free_full(l, free);
1084 }
1085
1086 static void cal_server_alarm_alert(time_t tt_alert)
1087 {
1088         GList *l = NULL;
1089         _cal_server_alarm_get_latest(tt_alert, true, &l);
1090         if (NULL == l)
1091                 return;
1092
1093         _cal_server_alarm_noti_with_callback(l);
1094         _cal_server_alarm_noti_with_control(l);
1095         /* DO NOT FREE LIST, list is freed in callback */
1096 }
1097
1098 static int _alert_cb(alarm_id_t alarm_id, void *data)
1099 {
1100         CAL_FN_CALL();
1101         DBG("alarm_id (%ld)", alarm_id);
1102
1103         time_t tt_alert = 0;
1104         cal_server_alarm_get_alert_time(alarm_id, &tt_alert);
1105         cal_server_alarm_alert(tt_alert);
1106         cal_server_alarm_unset_alerted_alarmmgr_id(alarm_id);
1107         cal_server_alarm_start();
1108         return 0;
1109 }
1110
1111 static void _timechanged_cb(keynode_t *node, void *data)
1112 {
1113         cal_server_alarm_alert(time(NULL));
1114         cal_server_alarm_start();
1115 }
1116
1117 static void _cal_server_alarm_set_timechange(void)
1118 {
1119         vconf_notify_key_changed(VCONFKEY_SYSTEM_TIME_CHANGED, _timechanged_cb, NULL);
1120         vconf_notify_key_changed(VCONFKEY_TELEPHONY_NITZ_GMT, _timechanged_cb, NULL);
1121         vconf_notify_key_changed(VCONFKEY_TELEPHONY_NITZ_ZONE, _timechanged_cb, NULL);
1122         vconf_notify_key_changed(VCONFKEY_TELEPHONY_NITZ_EVENT_GMT, _timechanged_cb, NULL);
1123 }
1124
1125 static void _cal_server_alarm_unset_timechange(void)
1126 {
1127         vconf_ignore_key_changed(VCONFKEY_SYSTEM_TIME_CHANGED, _timechanged_cb);
1128         vconf_ignore_key_changed(VCONFKEY_TELEPHONY_NITZ_GMT, _timechanged_cb);
1129         vconf_ignore_key_changed(VCONFKEY_TELEPHONY_NITZ_ZONE, _timechanged_cb);
1130         vconf_ignore_key_changed(VCONFKEY_TELEPHONY_NITZ_EVENT_GMT, _timechanged_cb);
1131 }
1132
1133 static void _changed_cb(const char* view_uri, void* data)
1134 {
1135         DBG("Receive alarm change signal");
1136         cal_server_alarm_start();
1137 }
1138
1139 static int _cal_server_alarm_set_inotify(calendar_db_changed_cb callback)
1140 {
1141         cal_inotify_subscribe(CAL_NOTI_TYPE_EVENT, CAL_NOTI_FILE_EVENT, callback, NULL);
1142         cal_inotify_subscribe(CAL_NOTI_TYPE_TODO, CAL_NOTI_FILE_TODO, callback, NULL);
1143         return 0;
1144 }
1145
1146 static void _cal_server_alarm_unset_inotify(calendar_db_changed_cb callback)
1147 {
1148         cal_inotify_unsubscribe(CAL_NOTI_FILE_EVENT, callback, NULL);
1149         cal_inotify_unsubscribe(CAL_NOTI_FILE_TODO, callback, NULL);
1150 }
1151
1152 static int cal_server_alarm_init(void)
1153 {
1154         int ret = 0;
1155
1156         _cal_server_alarm_set_timechange();
1157         _cal_server_alarm_set_inotify(_changed_cb);
1158
1159         ret = alarmmgr_init("calendar-service");
1160         if (ret < 0) {
1161                 /* LCOV_EXCL_START */
1162                 ERR("alarmmgr_init() Fail(%d)", ret);
1163                 return CALENDAR_ERROR_SYSTEM;
1164                 /* LCOV_EXCL_STOP */
1165         }
1166
1167         ret = alarmmgr_set_cb(_alert_cb, NULL);
1168         if (ret < 0) {
1169                 /* LCOV_EXCL_START */
1170                 ERR("alarmmgr_set_cb() Fail(%d)", ret);
1171                 return CALENDAR_ERROR_SYSTEM;
1172                 /* LCOV_EXCL_STOP */
1173         }
1174
1175         return CALENDAR_ERROR_NONE;
1176 }
1177
1178 static gpointer _cal_server_alarm_main(gpointer user_data)
1179 {
1180         DBG("thread alarm: start");
1181
1182         int ret = 0;
1183         bool is_initialized = false;
1184
1185         while (1) {
1186                 g_mutex_lock(&_cal_server_alarm_mutex);
1187                 /*
1188                  * While syncing with contacts,
1189                  * because calendar-service could be stopped by on-demand,
1190                  * holding on-demand is needed.
1191                  */
1192                 cal_server_ondemand_hold();
1193
1194                 do {
1195                         if (false == is_initialized) {
1196                                 ret = cal_server_alarm_init();
1197                                 if (CALENDAR_ERROR_NONE != ret) {
1198                                         /* LCOV_EXCL_START */
1199                                         ERR("cal_server_alarm_init() Fail(%d)", ret);
1200                                         break;
1201                                         /* LCOV_EXCL_STOP */
1202                                 }
1203                                 DBG("thread alarm: init");
1204                                 is_initialized = true;
1205                         }
1206
1207                         ret = cal_connect();
1208                         if (CALENDAR_ERROR_NONE != ret) {
1209                                 /* LCOV_EXCL_START */
1210                                 ERR("cal_connect() Fail(%d)", ret);
1211                                 break;
1212                                 /* LCOV_EXCL_STOP */
1213                         }
1214
1215                         cal_server_alarm_register_next_alarm(time(NULL));
1216                         cal_disconnect();
1217
1218                 } while (0);
1219
1220                 cal_server_ondemand_release();
1221                 cal_server_ondemand_start();
1222
1223                 DBG("thread alarm: wait");
1224                 while (false == signal_called)
1225                         g_cond_wait(&_cal_server_alarm_cond, &_cal_server_alarm_mutex);
1226                 signal_called = false;
1227                 g_mutex_unlock(&_cal_server_alarm_mutex);
1228
1229                 if (server_killed)
1230                         break;
1231         }
1232         DBG("thread alarm: end");
1233         g_thread_exit(NULL);
1234
1235         return NULL;
1236 }
1237
1238 void cal_server_alarm_send_signal(void)
1239 {
1240         g_mutex_lock(&_cal_server_alarm_mutex);
1241         signal_called = true;
1242         g_cond_signal(&_cal_server_alarm_cond);
1243         g_mutex_unlock(&_cal_server_alarm_mutex);
1244 }
1245
1246 void cal_server_alarm_start(void)
1247 {
1248         CAL_FN_CALL();
1249
1250         if (NULL == _cal_server_alarm_thread) {
1251                 g_mutex_init(&_cal_server_alarm_mutex);
1252                 g_cond_init(&_cal_server_alarm_cond);
1253                 _cal_server_alarm_thread = g_thread_new(CAL_SERVER_ALARM_THREAD_NAME,
1254                                 _cal_server_alarm_main, NULL);
1255         }
1256         cal_server_alarm_send_signal();
1257 }
1258
1259 static void cal_server_alarm_deinit(void)
1260 {
1261         alarmmgr_fini();
1262         _cal_server_alarm_unset_inotify(_changed_cb);
1263         _cal_server_alarm_unset_timechange();
1264 }
1265
1266 void cal_server_alarm_end(void)
1267 {
1268         CAL_FN_CALL();
1269
1270         server_killed = true;
1271
1272         cal_server_alarm_deinit();
1273         cal_server_alarm_send_signal();
1274
1275         g_cond_clear(&_cal_server_alarm_cond);
1276         g_thread_join(_cal_server_alarm_thread);
1277         g_thread_unref(_cal_server_alarm_thread);
1278         _cal_server_alarm_thread = NULL;
1279 }