diff options
Diffstat (limited to 'binding/media-manager.c')
| -rw-r--r-- | binding/media-manager.c | 294 |
1 files changed, 294 insertions, 0 deletions
diff --git a/binding/media-manager.c b/binding/media-manager.c new file mode 100644 index 0000000..342df47 --- /dev/null +++ b/binding/media-manager.c @@ -0,0 +1,294 @@ +/* + * Copyright 2017 Konsulko Group + * + * Based on bluetooth-manager.c + * Copyright 2016 ALPS ELECTRIC CO., LTD. + * + * 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 <stdio.h> +#include <stdlib.h> +#include <string.h> +#include <unistd.h> +#include <sys/types.h> +#include <sys/stat.h> + +#include <pthread.h> +#include <glib.h> +#include <gio/gio.h> +#include <glib-object.h> +#include <sqlite3.h> + +#include "media-manager.h" + +static Binding_RegisterCallback_t g_RegisterCallback = { 0 }; +static stMediaPlayerManage MediaPlayerManage = { 0 }; + +/* ------ LOCAL FUNCTIONS --------- */ +void ListLock() { + g_mutex_lock(&(MediaPlayerManage.m)); +} + +void ListUnlock() { + g_mutex_unlock(&(MediaPlayerManage.m)); +} + +void DebugTraceSendMsg(int level, gchar* message) +{ +#ifdef LOCAL_PRINT_DEBUG + switch (level) + { + case DT_LEVEL_ERROR: + g_print("[E]"); + break; + + case DT_LEVEL_WARNING: + g_print("[W]"); + break; + + case DT_LEVEL_NOTICE: + g_print("[N]"); + break; + + case DT_LEVEL_INFO: + g_print("[I]"); + break; + + case DT_LEVEL_DEBUG: + g_print("[D]"); + break; + + default: + g_print("[-]"); + break; + } + + g_print("%s",message); +#endif + + if (message) { + g_free(message); + } + +} + +GList* media_local_scan(GList *list) +{ + gchar *path = g_strconcat(g_get_home_dir(), "/", "Music", NULL); + gchar *tmp = NULL; + GDir *dir; + + dir = g_dir_open(path, 0, NULL); + if (dir == NULL) + { + LOGE("Cannot open media path %s\n", path); + return list; + } + + while ((tmp = (gchar *) g_dir_read_name(dir)) != NULL) + { + list = g_list_append(list, g_strdup_printf("file://%s/%s", path, tmp)); + } + + g_free(path); + g_dir_close(dir); + + return list; +} + +GList* media_lightmediascanner_scan(void) +{ + sqlite3 *conn; + sqlite3_stmt *res; + GList *list = NULL; + const char *tail; + const gchar *db_path; + int ret = 0; + + db_path = scanner1_get_data_base_path(MediaPlayerManage.lms_proxy); + + ret = sqlite3_open(db_path, &conn); + if (ret) { + LOGE("Cannot open SQLITE database: '%s'\n", db_path); + return NULL; + } + + ret = sqlite3_prepare_v2(conn, SQL_QUERY, strlen(SQL_QUERY) + 1, &res, &tail); + if (ret) { + LOGE("Cannot execute query '%s'\n", SQL_QUERY); + return NULL; + } + + while (sqlite3_step(res) == SQLITE_ROW) { + struct stat buf; + const char *path = (const char *) sqlite3_column_text(res, 0); + + ret = stat(path, &buf); + if (ret) + continue; + + list = g_list_append(list, g_strdup_printf("file://%s", path)); + } + + return list; +} + + +static void +on_interface_proxy_properties_changed (GDBusProxy *proxy, + GVariant *changed_properties, + const gchar* const *invalidated_properties) +{ + GVariantIter iter; + const gchar *key; + GVariant *subValue; + const gchar *pInterface; + GList *list; + + pInterface = g_dbus_proxy_get_interface_name (proxy); + + if (0 != g_strcmp0(pInterface, LIGHTMEDIASCANNER_INTERFACE)) + return; + + g_variant_iter_init (&iter, changed_properties); + while (g_variant_iter_next (&iter, "{&sv}", &key, &subValue)) + { + gboolean val; + if (0 == g_strcmp0(key,"IsScanning")) { + g_variant_get(subValue, "b", &val); + if (val == TRUE) + return; + } else if (0 == g_strcmp0(key, "WriteLocked")) { + g_variant_get(subValue, "b", &val); + if (val == TRUE) + return; + } + } + + ListLock(); + + list = media_lightmediascanner_scan(); + + if (list != NULL && g_RegisterCallback.binding_device_added) + g_RegisterCallback.binding_device_added(list); + + g_list_free_full(list, g_free); + + ListUnlock(); +} + +static int MediaPlayerDBusInit(void) +{ + GError *error = NULL; + + MediaPlayerManage.lms_proxy = scanner1_proxy_new_for_bus_sync( + G_BUS_TYPE_SESSION, G_DBUS_PROXY_FLAGS_NONE, LIGHTMEDIASCANNER_SERVICE, + LIGHTMEDIASCANNER_PATH, NULL, &error); + + if (MediaPlayerManage.lms_proxy == NULL) { + LOGE("Create LightMediaScanner Proxy failed\n"); + return -1; + } + + g_signal_connect (MediaPlayerManage.lms_proxy, + "g-properties-changed", + G_CALLBACK (on_interface_proxy_properties_changed), + NULL); + + return 0; +} + +static void *media_event_loop_thread(void *unused) +{ + GMainLoop *loop = g_main_loop_new(NULL, FALSE); + int ret; + + ret = MediaPlayerDBusInit(); + if (ret == 0) { + LOGD("g_main_loop_run\n"); + g_main_loop_run(loop); + } + + g_main_loop_unref(loop); + + return NULL; +} + +void +unmount_cb (GFileMonitor *mon, + GFile *file, + GFile *other_file, + GFileMonitorEvent event, + gpointer udata) +{ + gchar *path = g_file_get_path(file); + gchar *uri = g_strconcat("file://", path, NULL); + g_free(path); + + ListLock(); + + if (g_RegisterCallback.binding_device_removed && + event == G_FILE_MONITOR_EVENT_DELETED) { + g_RegisterCallback.binding_device_removed(uri); + } + + ListUnlock(); + g_free(uri); +} + +/* + * Create MediaPlayer Manager Thread + * Note: mediaplayer-api should do MediaPlayerManagerInit() before any other + * API calls + * Returns: 0 - success or error conditions + */ +int MediaPlayerManagerInit() { + pthread_t thread_id; + GFile *file; + GFileMonitor *mon; + + g_mutex_init(&(MediaPlayerManage.m)); + + file = g_file_new_for_path("/media"); + g_assert(file != NULL); + + mon = g_file_monitor (file, G_FILE_MONITOR_NONE, NULL, NULL); + g_assert(mon != NULL); + g_signal_connect (mon, "changed", G_CALLBACK(unmount_cb), NULL); + + pthread_create(&thread_id, NULL, media_event_loop_thread, NULL); + + return 0; +} + +/* + * Register MediaPlayer Manager Callback functions + */ +void BindingAPIRegister(const Binding_RegisterCallback_t* pstRegisterCallback) +{ + if (NULL != pstRegisterCallback) + { + if (NULL != pstRegisterCallback->binding_device_added) + { + g_RegisterCallback.binding_device_added = + pstRegisterCallback->binding_device_added; + } + + if (NULL != pstRegisterCallback->binding_device_removed) + { + g_RegisterCallback.binding_device_removed = + pstRegisterCallback->binding_device_removed; + } + } +} |