Remove the queue for the folder insertion
[platform/core/multimedia/libmedia-service.git] / src / common / media-svc-media-folder.c
1 /*
2  * libmedia-service
3  *
4  * Copyright (c) 2000 - 2011 Samsung Electronics Co., Ltd. All rights reserved.
5  *
6  * Contact: Hyunjun Ko <zzoon.ko@samsung.com>, Haejeong Kim <backto.kim@samsung.com>
7  *
8  * Licensed under the Apache License, Version 2.0 (the "License");
9  * you may not use this file except in compliance with the License.
10  * You may obtain a copy of the License at
11  *
12  * http://www.apache.org/licenses/LICENSE-2.0
13  *
14  * Unless required by applicable law or agreed to in writing, software
15  * distributed under the License is distributed on an "AS IS" BASIS,
16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17  * See the License for the specific language governing permissions and
18  * limitations under the License.
19  *
20  */
21
22 #include <glib/gstdio.h>
23 #include <media-util-err.h>
24 #include "media-svc-media-folder.h"
25 #include "media-svc-debug.h"
26 #include "media-svc-env.h"
27 #include "media-svc-util.h"
28 #include "media-svc-db-utils.h"
29
30 int _media_svc_get_folder_id_by_foldername(sqlite3 *handle, const char *storage_id, const char *folder_name, char *folder_id, uid_t uid)
31 {
32         int ret = MS_MEDIA_ERR_NONE;
33         sqlite3_stmt *sql_stmt = NULL;
34         char *sql = NULL;
35
36         sql = sqlite3_mprintf("SELECT folder_id FROM %q WHERE storage_uuid = '%q' AND folder_path = '%q';", MEDIA_SVC_DB_TABLE_FOLDER, storage_id, folder_name);
37
38         ret = _media_svc_sql_prepare_to_step(handle, sql, &sql_stmt);
39         if (ret != MS_MEDIA_ERR_NONE) {
40                 if (ret == MS_MEDIA_ERR_DB_NO_RECORD)
41                         media_svc_debug("No record");
42                 else
43                         media_svc_error("error when _media_svc_get_folder_id_by_foldername. err = [%d]", ret);
44
45                 return ret;
46         }
47
48         SAFE_STRLCPY(folder_id, (const char *)sqlite3_column_text(sql_stmt, 0), MEDIA_SVC_UUID_SIZE + 1);
49
50         SQLITE3_FINALIZE(sql_stmt);
51
52         return ret;
53 }
54
55 int _media_svc_get_folder_id_by_foldername_with_validity(sqlite3 *handle, const char *storage_id, const char *folder_name, char *folder_id, uid_t uid, int *validity)
56 {
57         int ret = MS_MEDIA_ERR_NONE;
58         sqlite3_stmt *sql_stmt = NULL;
59         char *sql = NULL;
60
61         sql = sqlite3_mprintf("SELECT folder_id, validity FROM %q WHERE storage_uuid='%q' AND folder_path='%q';", MEDIA_SVC_DB_TABLE_FOLDER, storage_id, folder_name);
62
63         ret = _media_svc_sql_prepare_to_step(handle, sql, &sql_stmt);
64         if (ret != MS_MEDIA_ERR_NONE) {
65                 if (ret == MS_MEDIA_ERR_DB_NO_RECORD)
66                         media_svc_debug("there is no folder.");
67                 else
68                         media_svc_error("error when _media_svc_get_folder_id_by_foldername_with_validity. err = [%d]", ret);
69
70                 return ret;
71         }
72
73         SAFE_STRLCPY(folder_id, (const char *)sqlite3_column_text(sql_stmt, 0), MEDIA_SVC_UUID_SIZE + 1);
74         *validity = (int)sqlite3_column_int(sql_stmt, 1);
75
76         SQLITE3_FINALIZE(sql_stmt);
77
78         return ret;
79 }
80
81 static int __media_svc_append_folder(bool is_direct, const char *storage_id, ms_user_storage_type_e storage_type, const char *folder_id, const char *folder_path, uid_t uid)
82 {
83         int ret = MS_MEDIA_ERR_NONE;
84         char *folder_name = NULL;
85         int folder_modified_date = 0;
86
87         folder_name = g_path_get_basename(folder_path);
88         folder_modified_date = _media_svc_get_file_time(folder_path);
89
90         /*Update Pinyin If Support Pinyin*/
91         char *folder_name_pinyin = NULL;
92         if (_media_svc_check_pinyin_support())
93                 _media_svc_get_pinyin_str(folder_name, &folder_name_pinyin);
94         /* Sometime SQLITE3 returns NO_RECORD, so need to consider conflict case.. */
95         char *sql = sqlite3_mprintf("INSERT OR IGNORE INTO %q (folder_id, folder_path, folder_name, storage_uuid, folder_storage_type, folder_modified_time, folder_name_pinyin) values (%Q, %Q, %Q, %Q, '%d', '%d', %Q); ",
96                                 MEDIA_SVC_DB_TABLE_FOLDER, folder_id, folder_path, folder_name, storage_id, storage_type, folder_modified_date, folder_name_pinyin);
97
98         if (is_direct)
99                 ret = _media_svc_sql_query_direct(sql, uid);
100         else
101                 ret = _media_svc_sql_query(sql, uid);
102
103         SQLITE3_SAFE_FREE(sql);
104
105         SAFE_FREE(folder_name);
106         SAFE_FREE(folder_name_pinyin);
107
108         return ret;
109 }
110
111 int _media_svc_update_folder_modified_time_by_folder_uuid(const char *folder_uuid, const char *folder_path, uid_t uid)
112 {
113         int ret = MS_MEDIA_ERR_NONE;
114         int modified_time = 0;
115
116         modified_time = _media_svc_get_file_time(folder_path);
117
118         char *sql = sqlite3_mprintf("UPDATE %q SET folder_modified_time=%d WHERE folder_id=%Q;", MEDIA_SVC_DB_TABLE_FOLDER, modified_time, folder_uuid);
119
120         ret = _media_svc_sql_query(sql, uid);
121         SQLITE3_SAFE_FREE(sql);
122
123         return ret;
124 }
125
126 static int __media_svc_get_and_append_parent_folder(sqlite3 *handle, bool is_direct, const char *storage_id, const char *path, ms_user_storage_type_e storage_type, char *folder_id, uid_t uid)
127 {
128         int ret = MS_MEDIA_ERR_NONE;
129         unsigned int next_pos = 0;
130         char *next = NULL;
131         char *dir_path = NULL;
132         const char *token = "/";
133         char *folder_uuid = NULL;
134         char tmp_folder_uuid[MEDIA_SVC_UUID_SIZE + 1] = {0, };
135         bool folder_search_end = FALSE;
136         char *internal_path = NULL;
137
138         memset(tmp_folder_uuid, 0, sizeof(tmp_folder_uuid));
139         ret = ms_user_get_internal_root_path(uid, &internal_path);
140         media_svc_retvm_if(ret != MS_MEDIA_ERR_NONE, ret, "Fail to get root path");
141
142         if (STRING_VALID(internal_path) && (strncmp(path, internal_path, strlen(internal_path)) == 0))
143                 next_pos = strlen(internal_path);
144         else if (STRING_VALID(MEDIA_ROOT_PATH_SDCARD) && strncmp(path, MEDIA_ROOT_PATH_SDCARD, strlen(MEDIA_ROOT_PATH_SDCARD)) == 0)
145                 next_pos = strlen(MEDIA_ROOT_PATH_SDCARD);
146         else if (STRING_VALID(MEDIA_ROOT_PATH_EXTERNAL) && strncmp(path, MEDIA_ROOT_PATH_EXTERNAL, strlen(MEDIA_ROOT_PATH_EXTERNAL)) == 0)
147                 next_pos = strlen(MEDIA_ROOT_PATH_EXTERNAL);
148         else if (STRING_VALID(MEDIA_ROOT_PATH_DISC) && strncmp(path, MEDIA_ROOT_PATH_DISC, strlen(MEDIA_ROOT_PATH_DISC)) == 0)
149                 next_pos = strlen(MEDIA_ROOT_PATH_DISC);
150         else {
151                 media_svc_error("Invalid Path");
152                 media_svc_sec_error("Invalid Path [%s], internal_path [%s]", path, internal_path);
153                 SAFE_FREE(internal_path);
154                 return MS_MEDIA_ERR_INTERNAL;
155         }
156
157         SAFE_FREE(internal_path);
158
159         while (!folder_search_end) {
160                 next = strstr(path + next_pos, token);
161                 if (next != NULL) {
162                         next_pos = (next - path);
163                         dir_path = strndup(path, next_pos);
164                         next_pos++;
165                 } else {
166                         dir_path = strndup(path, strlen(path));
167                         folder_search_end = TRUE;
168                         media_svc_sec_debug("End Path[%s]", dir_path);
169                 }
170
171                 if (STRING_VALID(MEDIA_ROOT_PATH_EXTERNAL) && (g_strcmp0(dir_path, MEDIA_ROOT_PATH_EXTERNAL) == 0)) {
172                         /*To avoid insert MEDIA_ROOT_PATH_EXTERNAL path*/
173                         SAFE_FREE(dir_path);
174                         continue;
175                 }
176
177                 ret = _media_svc_get_folder_id_by_foldername(handle, storage_id, dir_path, tmp_folder_uuid, uid);
178                 if (ret == MS_MEDIA_ERR_DB_NO_RECORD) {
179                         folder_uuid = _media_info_generate_uuid();
180                         if (folder_uuid == NULL) {
181                                 media_svc_error("Invalid UUID");
182                                 SAFE_FREE(dir_path);
183                                 return MS_MEDIA_ERR_INTERNAL;
184                         }
185
186                         ret = __media_svc_append_folder(is_direct, storage_id, storage_type, folder_uuid, dir_path, uid);
187                         if (ret != MS_MEDIA_ERR_NONE)
188                                 media_svc_error("__media_svc_append_folder is failed");
189
190                         media_svc_sec_debug("Append new folder path[%s] uuid[%s]", dir_path, folder_uuid);
191                 }
192
193                 SAFE_FREE(dir_path);
194         }
195
196         if (STRING_VALID(folder_uuid)) {
197                 SAFE_STRLCPY(folder_id, folder_uuid, MEDIA_SVC_UUID_SIZE + 1);
198         } else {
199                 media_svc_error("Fail to get folder_uuid");
200                 return MS_MEDIA_ERR_INTERNAL;
201         }
202
203         return MS_MEDIA_ERR_NONE;
204 }
205
206 static int __media_svc_update_parent_folder_validity(sqlite3 *handle, bool is_direct, const char *storage_id, const char *path, uid_t uid)
207 {
208         int ret = MS_MEDIA_ERR_NONE;
209         unsigned int next_pos = 0;
210         char *next = NULL;
211         char *dir_path = NULL;
212         const char *token = "/";
213         bool folder_search_end = FALSE;
214         char *internal_path = NULL;
215
216         ret = ms_user_get_internal_root_path(uid, &internal_path);
217         media_svc_retvm_if(ret != MS_MEDIA_ERR_NONE, ret, "Fail to get root path");
218
219         if (STRING_VALID(internal_path) && (strncmp(path, internal_path, strlen(internal_path)) == 0))
220                 next_pos = strlen(internal_path);
221         else if (STRING_VALID(MEDIA_ROOT_PATH_SDCARD) && strncmp(path, MEDIA_ROOT_PATH_SDCARD, strlen(MEDIA_ROOT_PATH_SDCARD)) == 0)
222                 next_pos = strlen(MEDIA_ROOT_PATH_SDCARD);
223         else if (STRING_VALID(MEDIA_ROOT_PATH_EXTERNAL) && strncmp(path, MEDIA_ROOT_PATH_EXTERNAL, strlen(MEDIA_ROOT_PATH_EXTERNAL)) == 0)
224                 next_pos = strlen(MEDIA_ROOT_PATH_EXTERNAL);
225         else if (STRING_VALID(MEDIA_ROOT_PATH_DISC) && strncmp(path, MEDIA_ROOT_PATH_DISC, strlen(MEDIA_ROOT_PATH_DISC)) == 0)
226                 next_pos = strlen(MEDIA_ROOT_PATH_DISC);
227         else {
228                 media_svc_error("Invalid Path");
229                 media_svc_sec_error("Invalid Path [%s], internal_path [%s]", path, internal_path);
230                 SAFE_FREE(internal_path);
231                 return MS_MEDIA_ERR_INTERNAL;
232         }
233
234         SAFE_FREE(internal_path);
235
236         while (!folder_search_end) {
237                 next = strstr(path + next_pos, token);
238                 if (next != NULL) {
239                         next_pos = (next - path);
240                         dir_path = strndup(path, next_pos);
241                         next_pos++;
242                 } else {
243                         dir_path = strndup(path, strlen(path));
244                         folder_search_end = TRUE;
245                         media_svc_sec_debug("End Path [%s]", dir_path);
246                 }
247
248                 if (STRING_VALID(MEDIA_ROOT_PATH_EXTERNAL) && (g_strcmp0(dir_path, MEDIA_ROOT_PATH_EXTERNAL) == 0)) {
249                         /*To avoid insert MEDIA_ROOT_PATH_EXTERNAL path*/
250                         SAFE_FREE(dir_path);
251                         continue;
252                 }
253
254                 ret = _media_svc_set_folder_validity(handle, is_direct, storage_id, dir_path, 1, false, uid);
255                 SAFE_FREE(dir_path);
256                 media_svc_retvm_if(ret != MS_MEDIA_ERR_NONE, ret, "Fail to set folder validity");
257         }
258
259         return MS_MEDIA_ERR_NONE;
260 }
261
262 int _media_svc_get_and_append_folder(sqlite3 *handle, bool is_direct, const char *storage_id, const char *path, ms_user_storage_type_e storage_type, char *folder_id, uid_t uid)
263 {
264         int ret = MS_MEDIA_ERR_NONE;
265         int validity = -1;
266
267         ret = _media_svc_get_folder_id_by_foldername_with_validity(handle, storage_id, path, folder_id, uid, &validity);
268
269         if (ret == MS_MEDIA_ERR_DB_NO_RECORD)
270                 ret = __media_svc_get_and_append_parent_folder(handle, is_direct, storage_id, path, storage_type, folder_id, uid);
271         else if (ret == MS_MEDIA_ERR_NONE && validity == 0)
272                 ret = __media_svc_update_parent_folder_validity(handle, is_direct, storage_id, path, uid);
273
274         return ret;
275 }
276
277 int _media_svc_get_and_append_folder_id_by_path(sqlite3 *handle, bool is_direct, const char *storage_id, const char *path, ms_user_storage_type_e storage_type, char *folder_id, uid_t uid)
278 {
279         char *dir_path = NULL;
280         int ret = MS_MEDIA_ERR_NONE;
281
282         dir_path = g_path_get_dirname(path);
283
284         ret = _media_svc_get_and_append_folder(handle, is_direct, storage_id, dir_path, storage_type, folder_id, uid);
285
286         SAFE_FREE(dir_path);
287
288         return ret;
289 }
290
291 int _media_svc_get_and_append_folder_id_by_folder_path(sqlite3 *handle, const char *storage_id, const char *path, ms_user_storage_type_e storage_type, uid_t uid)
292 {
293         char *path_name = NULL;
294         int ret = MS_MEDIA_ERR_NONE;
295         char *sql = NULL;
296         char folder_id[MEDIA_SVC_UUID_SIZE + 1] = {0, };
297
298         path_name = strdup(path);
299         if (path_name == NULL) {
300                 media_svc_error("out of memory");
301                 return MS_MEDIA_ERR_OUT_OF_MEMORY;
302         }
303
304         ret = _media_svc_get_folder_id_by_foldername(handle, storage_id, path_name, folder_id, uid);
305         if (ret == MS_MEDIA_ERR_DB_NO_RECORD) {
306                 ret = __media_svc_get_and_append_parent_folder(handle, true, storage_id, path_name, storage_type, folder_id, uid);
307         } else {
308                 sql = sqlite3_mprintf("UPDATE %q SET validity=1 WHERE storage_uuid = '%q' AND folder_path = '%q';", MEDIA_SVC_DB_TABLE_FOLDER, storage_id, path);
309                 ret = _media_svc_sql_query_direct(sql, uid);
310                 SQLITE3_SAFE_FREE(sql);
311         }
312
313         SAFE_FREE(path_name);
314
315         return ret;
316 }
317
318 int _media_svc_set_folder_validity(sqlite3 *handle, bool is_direct, const char *storage_id, const char *start_path, int validity, bool is_recursive, uid_t uid)
319 {
320         int ret = MS_MEDIA_ERR_NONE;
321         char *sql = NULL;
322
323         if (is_recursive) {
324                 sql = sqlite3_mprintf("UPDATE %q SET validity=%d WHERE storage_uuid='%q' AND (folder_path LIKE '%q/%%' OR folder_path='%q');",
325                                                 MEDIA_SVC_DB_TABLE_FOLDER, validity, storage_id, start_path, start_path);
326         } else {
327                 sql = sqlite3_mprintf("UPDATE %q SET validity=%d WHERE storage_uuid='%q' AND folder_path='%q';",
328                                                 MEDIA_SVC_DB_TABLE_FOLDER, validity, storage_id, start_path);
329         }
330
331         if (is_direct)
332                 ret = _media_svc_sql_query_direct(sql, uid);
333         else
334                 ret = _media_svc_sql_query(sql, uid);
335
336         SQLITE3_SAFE_FREE(sql);
337
338         return ret;
339 }
340
341 int _media_svc_count_folder_with_path(sqlite3 *handle, const char *storage_id, const char *path, int *count)
342 {
343         int ret = MS_MEDIA_ERR_NONE;
344         sqlite3_stmt *sql_stmt = NULL;
345         char *sql = NULL;
346
347         media_svc_retvm_if(!STRING_VALID(storage_id), MS_MEDIA_ERR_INVALID_PARAMETER, "storage_id is NULL");
348         media_svc_retvm_if(!STRING_VALID(path), MS_MEDIA_ERR_INVALID_PARAMETER, "path is NULL");
349
350         sql = sqlite3_mprintf("SELECT count(*) FROM %q WHERE (storage_uuid='%q' AND folder_path='%q')", MEDIA_SVC_DB_TABLE_FOLDER, storage_id, path);
351
352         ret = _media_svc_sql_prepare_to_step(handle, sql, &sql_stmt);
353
354         media_svc_retv_if(ret != MS_MEDIA_ERR_NONE, ret);
355
356         *count = sqlite3_column_int(sql_stmt, 0);
357
358         SQLITE3_FINALIZE(sql_stmt);
359
360         return MS_MEDIA_ERR_NONE;
361 }