From c4525662e45b66cf95822d485566df01c0d7dfac Mon Sep 17 00:00:00 2001 From: Matt Ranostay Date: Fri, 13 Oct 2017 21:18:09 -0700 Subject: binding: mediaplayer: rename binding from gstreamer to mediaplayer Bug-AGL: SPEC-931 Change-Id: If6e4ebbb60213ff82f630cea3e06df49c0d808a0 Signed-off-by: Matt Ranostay --- binding/CMakeLists.txt | 6 +- binding/afm-gstreamer-binding.c | 620 -------------------------------------- binding/afm-mediaplayer-binding.c | 620 ++++++++++++++++++++++++++++++++++++++ 3 files changed, 623 insertions(+), 623 deletions(-) delete mode 100644 binding/afm-gstreamer-binding.c create mode 100644 binding/afm-mediaplayer-binding.c (limited to 'binding') diff --git a/binding/CMakeLists.txt b/binding/CMakeLists.txt index 8b99ac0..02f2aa9 100644 --- a/binding/CMakeLists.txt +++ b/binding/CMakeLists.txt @@ -18,11 +18,11 @@ ########################################################################### # Add target to project dependency list -PROJECT_TARGET_ADD(afm-gstreamer-binding) +PROJECT_TARGET_ADD(afm-mediaplayer-binding) # Define project Targets - add_library(afm-gstreamer-binding MODULE - afm-gstreamer-binding.c + add_library(afm-mediaplayer-binding MODULE + afm-mediaplayer-binding.c afm-common.c) # Binder exposes a unique public entry point diff --git a/binding/afm-gstreamer-binding.c b/binding/afm-gstreamer-binding.c deleted file mode 100644 index b168ccc..0000000 --- a/binding/afm-gstreamer-binding.c +++ /dev/null @@ -1,620 +0,0 @@ -/* - * Copyright (C) 2017 Konsulko Group - * Author: Matt Ranostay - * - * 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. - */ - -#define _GNU_SOURCE -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include "afm-common.h" - -#define AFB_BINDING_VERSION 2 -#include - -static struct afb_event gstreamer_event; -static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; - -static GList *playlist = NULL; -static GList *current_track = NULL; - -typedef struct _CustomData { - GstElement *playbin; - gboolean playing; - guint volume; - gint64 position; - gint64 duration; -} CustomData; - -CustomData data = { - .volume = 50, - .position = GST_CLOCK_TIME_NONE, - .duration = GST_CLOCK_TIME_NONE, -}; - -static json_object *populate_json(struct playlist_item *track) -{ - json_object *jresp = json_object_new_object(); - json_object *jstring = json_object_new_string(track->media_path); - json_object_object_add(jresp, "path", jstring); - - if (track->title) { - jstring = json_object_new_string(track->title); - json_object_object_add(jresp, "title", jstring); - } - - if (track->album) { - jstring = json_object_new_string(track->album); - json_object_object_add(jresp, "album", jstring); - } - - if (track->artist) { - jstring = json_object_new_string(track->artist); - json_object_object_add(jresp, "artist", jstring); - } - - if (track->genre) { - jstring = json_object_new_string(track->genre); - json_object_object_add(jresp, "genre", jstring); - } - - if (track->duration > 0) - json_object_object_add(jresp, "duration", - json_object_new_int64(track->duration)); - - json_object_object_add(jresp, "index", - json_object_new_int(track->id)); - - return jresp; -} - -static gboolean populate_from_json(struct playlist_item *item, json_object *jdict) -{ - gboolean ret; - json_object *val = NULL; - - ret = json_object_object_get_ex(jdict, "path", &val); - if (!ret) - return ret; - item->media_path = g_strdup(json_object_get_string(val)); - - ret = json_object_object_get_ex(jdict, "title", &val); - if (ret) { - item->title = g_strdup(json_object_get_string(val)); - } - - ret = json_object_object_get_ex(jdict, "album", &val); - if (ret) { - item->album = g_strdup(json_object_get_string(val)); - } - - ret = json_object_object_get_ex(jdict, "artist", &val); - if (ret) { - item->artist = g_strdup(json_object_get_string(val)); - } - - ret = json_object_object_get_ex(jdict, "genre", &val); - if (ret) { - item->genre = g_strdup(json_object_get_string(val)); - } - - ret = json_object_object_get_ex(jdict, "duration", &val); - if (ret) { - item->duration = json_object_get_int64(val); - } - - return TRUE; -} - -static int set_media_uri(struct playlist_item *item) -{ - if (!item || !item->media_path) - return -ENOENT; - - gst_element_set_state(data.playbin, GST_STATE_NULL); - - g_object_set(data.playbin, "uri", item->media_path, NULL); - - data.position = GST_CLOCK_TIME_NONE; - data.duration = GST_CLOCK_TIME_NONE; - - if (data.playing) - gst_element_set_state(data.playbin, GST_STATE_PLAYING); - - g_object_set(data.playbin, "volume", data.volume / 100.0, NULL); - - return 0; -} - -static void populate_playlist(json_object *jquery) -{ - int i, idx = 0; - GList *list = g_list_last(playlist); - - if (list && list->data) { - struct playlist_item *item = list->data; - idx = item->id + 1; - } - - for (i = 0; i < json_object_array_length(jquery); i++) { - json_object *jdict = json_object_array_get_idx(jquery, i); - struct playlist_item *item = g_malloc0(sizeof(*item)); - int ret; - - if (item == NULL) - break; - - ret = populate_from_json(item, jdict); - if (!ret) { - g_free_playlist_item(item); - continue; - } - - item->id = idx++; - playlist = g_list_append(playlist, item); - } - - current_track = g_list_first(playlist); - set_media_uri(current_track->data); -} - -static void audio_playlist(struct afb_req request) -{ - const char *value = afb_req_value(request, "list"); - json_object *jresp = NULL; - - pthread_mutex_lock(&mutex); - - if (value) { - json_object *jquery; - - if (playlist) { - g_list_free_full(playlist, g_free_playlist_item); - playlist = NULL; - } - - jquery = json_tokener_parse(value); - populate_playlist(jquery); - - if (playlist == NULL) - afb_req_fail(request, "failed", "invalid playlist"); - else - afb_req_success(request, NULL, NULL); - - json_object_put(jquery); - } else { - GList *l; - json_object *jarray = json_object_new_array(); - jresp = json_object_new_object(); - - for (l = playlist; l; l = l->next) { - json_object *item = populate_json(l->data); - json_object_array_add(jarray, item); - } - - json_object_object_add(jresp, "list", jarray); - afb_req_success(request, jresp, "Playlist results"); - } - - pthread_mutex_unlock(&mutex); -} - -static int seek_track(int cmd) -{ - GList *item = (cmd == NEXT_CMD) ? current_track->next : current_track->prev; - int ret; - - if (item == NULL) - return -EINVAL; - - ret = set_media_uri(item->data); - if (ret < 0) - return -EINVAL; - - if (data.playing) - gst_element_set_state(data.playbin, GST_STATE_PLAYING); - - current_track = item; - - return 0; -} - -static int seek_stream(const char *value, int cmd) -{ - gint64 position, current = 0; - - if (value == NULL) - return -EINVAL; - - position = strtoll(value, NULL, 10); - - if (cmd != SEEK_CMD) { - gst_element_query_position (data.playbin, GST_FORMAT_TIME, ¤t); - position = (current / GST_MSECOND) + (FASTFORWARD_CMD ? position : -position); - } - - if (position < 0) - position = 0; - - if (data.duration > 0 && position > data.duration) - position = data.duration; - - return gst_element_seek_simple(data.playbin, GST_FORMAT_TIME, - GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_KEY_UNIT, - position * GST_MSECOND); -} - -/* @value can be one of the following values: - * play - go to playing transition - * pause - go to pause transition - * previous - skip to previous track - * next - skip to the next track - * seek - go to position (in milliseconds) - * - * fast-forward - skip forward in milliseconds - * rewind - skip backward in milliseconds - * - * pick-track - select track via index number - * volume - set volume between 0 - 100% - */ - -static void controls(struct afb_req request) -{ - const char *value = afb_req_value(request, "value"); - const char *position = afb_req_value(request, "position"); - int cmd = get_command_index(value); - - if (!value) { - afb_req_fail(request, "failed", "no value was passed"); - return; - } - - pthread_mutex_lock(&mutex); - errno = 0; - - switch (cmd) { - case PLAY_CMD: - gst_element_set_state(data.playbin, GST_STATE_PLAYING); - data.playing = TRUE; - break; - case PAUSE_CMD: - gst_element_set_state(data.playbin, GST_STATE_PAUSED); - data.playing = FALSE; - break; - case PREVIOUS_CMD: - case NEXT_CMD: - seek_track(cmd); - break; - case SEEK_CMD: - case FASTFORWARD_CMD: - case REWIND_CMD: - seek_stream(position, cmd); - break; - case PICKTRACK_CMD: { - const char *parameter = afb_req_value(request, "index"); - long int idx = strtol(parameter, NULL, 10); - GList *list = NULL; - - if (idx == 0 && !errno) { - afb_req_fail(request, "failed", "invalid index"); - pthread_mutex_unlock(&mutex); - return; - } - - list = find_media_index(playlist, idx); - if (list != NULL) { - struct playlist_item *item = list->data; - set_media_uri(item); - current_track = list; - } else { - afb_req_fail(request, "failed", "couldn't find index"); - pthread_mutex_unlock(&mutex); - return; - } - - break; - } - case VOLUME_CMD: { - const char *parameter = afb_req_value(request, "volume"); - long int volume = strtol(parameter, NULL, 10); - - if (volume == 0 && !errno) { - afb_req_fail(request, "failed", "invalid volume"); - pthread_mutex_unlock(&mutex); - return; - } - - if (volume < 0) - volume = 0; - if (volume > 100) - volume = 100; - - g_object_set(data.playbin, "volume", volume / 100.0, NULL); - - break; - } - default: - afb_req_fail(request, "failed", "unknown command"); - pthread_mutex_unlock(&mutex); - return; - } - - afb_req_success(request, NULL, NULL); - pthread_mutex_unlock(&mutex); -} - -static void metadata(struct afb_req request) -{ - struct playlist_item *track; - json_object *jresp; - - pthread_mutex_lock(&mutex); - - if (current_track == NULL || current_track->data == NULL) { - afb_req_fail(request, "failed", "No playlist"); - pthread_mutex_unlock(&mutex); - return; - } - - track = current_track->data; - jresp = populate_json(track); - - if (data.duration != GST_CLOCK_TIME_NONE) - json_object_object_add(jresp, "duration", - json_object_new_int64(data.duration / GST_MSECOND)); - - if (data.position != GST_CLOCK_TIME_NONE) - json_object_object_add(jresp, "position", - json_object_new_int64(data.position / GST_MSECOND)); - - json_object_object_add(jresp, "volume", - json_object_new_int(data.volume)); - - pthread_mutex_unlock(&mutex); - - afb_req_success(request, jresp, "Metadata results"); -} - -static void subscribe(struct afb_req request) -{ - const char *value = afb_req_value(request, "value"); - - if (value && !strcasecmp(value, "gstreamer")) { - afb_req_subscribe(request, gstreamer_event); - afb_req_success(request, NULL, NULL); - return; - } - - afb_req_fail(request, "failed", "Invalid event"); -} - -static void unsubscribe(struct afb_req request) -{ - const char *value = afb_req_value(request, "value"); - - if (value && !strcasecmp(value, "gstreamer")) { - afb_req_unsubscribe(request, gstreamer_event); - afb_req_success(request, NULL, NULL); - return; - } - - afb_req_fail(request, "failed", "Invalid event"); -} - -static gboolean handle_message(GstBus *bus, GstMessage *msg, CustomData *data) -{ - switch (GST_MESSAGE_TYPE (msg)) { - case GST_MESSAGE_EOS: { - int ret; - - pthread_mutex_lock(&mutex); - - data->position = GST_CLOCK_TIME_NONE; - data->duration = GST_CLOCK_TIME_NONE; - - ret = seek_track(NEXT_CMD); - if (ret < 0) { - data->playing = FALSE; - current_track = playlist; - } else if (data->playing) { - gst_element_set_state(data->playbin, GST_STATE_PLAYING); - } - - pthread_mutex_unlock(&mutex); - break; - } - case GST_MESSAGE_DURATION: - data->duration = GST_CLOCK_TIME_NONE; - break; - default: - break; - } - - return TRUE; -} - -static gboolean position_event(CustomData *data) -{ - struct playlist_item *track; - json_object *jresp = NULL; - - pthread_mutex_lock(&mutex); - - if (!data->playing || current_track == NULL) { - pthread_mutex_unlock(&mutex); - return TRUE; - } - - track = current_track->data; - jresp = populate_json(track); - - if (!GST_CLOCK_TIME_IS_VALID(data->duration)) - gst_element_query_duration(data->playbin, - GST_FORMAT_TIME, &data->duration); - - gst_element_query_position(data->playbin, - GST_FORMAT_TIME, &data->position); - - json_object_object_add(jresp, "duration", - json_object_new_int64(data->duration / GST_MSECOND)); - json_object_object_add(jresp, "position", - json_object_new_int64(data->position / GST_MSECOND)); - - pthread_mutex_unlock(&mutex); - - afb_event_push(gstreamer_event, jresp); - - return TRUE; -} - -static void *gstreamer_loop_thread(void *ptr) -{ - GstBus *bus; - json_object *query, *response; - int ret; - - gst_init(NULL, NULL); - - data.playbin = gst_element_factory_make("playbin", "playbin"); - if (!data.playbin) { - AFB_ERROR("Cannot create playbin"); - exit(1); - } - - bus = gst_element_get_bus(data.playbin); - gst_bus_add_watch(bus, (GstBusFunc) handle_message, &data); - g_timeout_add_seconds(1, (GSourceFunc) position_event, &data); - - ret = afb_service_call_sync("mediascanner", "media_result", NULL, &response); - if (!ret) { - json_object *query = json_object_object_get(response, "response"); - - if (query) - query = json_object_object_get(query, "Media"); - - if (query) - populate_playlist(query); - } - json_object_put(response); - - g_main_loop_run(g_main_loop_new(NULL, FALSE)); - - return NULL; -} - -static void onevent(const char *event, struct json_object *object) -{ - if (!g_strcmp0(event, "mediascanner/media_added")) { - pthread_mutex_lock(&mutex); - - json_object *query = json_object_object_get(object, "Media"); - if (query) - populate_playlist(query); - - pthread_mutex_unlock(&mutex); - } else if (!g_strcmp0(event, "mediascanner/media_removed")) { - json_object *query = json_object_object_get(object, "Path"); - const char *path = json_object_get_string(query); - GList *l = playlist; - - pthread_mutex_lock(&mutex); - - while (l) { - struct playlist_item *item = l->data; - - l = l->next; - - if (!strncasecmp(path, item->media_path, strlen(path))) { - playlist = g_list_remove(playlist, item); - g_free_playlist_item(item); - - if (current_track->data == item) { - current_track = NULL; - gst_element_set_state(data.playbin, GST_STATE_NULL); - } - } - } - - current_track = g_list_first(playlist); - - pthread_mutex_unlock(&mutex); - } else { - AFB_ERROR("Invalid event: %s", event); - } -} - -static int init() { - pthread_t thread_id; - json_object *response, *query; - int ret; - - ret = afb_daemon_require_api("mediascanner", 1); - if (ret < 0) { - AFB_ERROR("Cannot request mediascanner"); - return ret; - } - - query = json_object_new_object(); - json_object_object_add(query, "value", json_object_new_string("media_added")); - - ret = afb_service_call_sync("mediascanner", "subscribe", query, &response); - json_object_put(response); - - if (ret < 0) { - AFB_ERROR("Cannot subscribe to mediascanner media_added event"); - return ret; - } - - query = json_object_new_object(); - json_object_object_add(query, "value", json_object_new_string("media_removed")); - - ret = afb_service_call_sync("mediascanner", "subscribe", query, &response); - json_object_put(response); - - if (ret < 0) { - AFB_ERROR("Cannot subscribe to mediascanner media_remove event"); - return ret; - } - - gstreamer_event = afb_daemon_make_event("gstreamer"); - - return pthread_create(&thread_id, NULL, gstreamer_loop_thread, NULL); -} - -static const struct afb_verb_v2 binding_verbs[] = { - { .verb = "playlist", .callback = audio_playlist, .info = "Get/set playlist" }, - { .verb = "controls", .callback = controls, .info = "Audio controls" }, - { .verb = "metadata", .callback = metadata, .info = "Get metadata of current track" }, - { .verb = "subscribe", .callback = subscribe, .info = "Subscribe to GStreamer events" }, - { .verb = "unsubscribe", .callback = unsubscribe, .info = "Unsubscribe to GStreamer events" }, - { } -}; - -/* - * binder API description - */ -const struct afb_binding_v2 afbBindingV2 = { - .api = "gstreamer", - .specification = "GStreamer API", - .verbs = binding_verbs, - .onevent = onevent, - .init = init, -}; diff --git a/binding/afm-mediaplayer-binding.c b/binding/afm-mediaplayer-binding.c new file mode 100644 index 0000000..a60d702 --- /dev/null +++ b/binding/afm-mediaplayer-binding.c @@ -0,0 +1,620 @@ +/* + * Copyright (C) 2017 Konsulko Group + * Author: Matt Ranostay + * + * 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. + */ + +#define _GNU_SOURCE +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include "afm-common.h" + +#define AFB_BINDING_VERSION 2 +#include + +static struct afb_event gstreamer_event; +static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; + +static GList *playlist = NULL; +static GList *current_track = NULL; + +typedef struct _CustomData { + GstElement *playbin; + gboolean playing; + guint volume; + gint64 position; + gint64 duration; +} CustomData; + +CustomData data = { + .volume = 50, + .position = GST_CLOCK_TIME_NONE, + .duration = GST_CLOCK_TIME_NONE, +}; + +static json_object *populate_json(struct playlist_item *track) +{ + json_object *jresp = json_object_new_object(); + json_object *jstring = json_object_new_string(track->media_path); + json_object_object_add(jresp, "path", jstring); + + if (track->title) { + jstring = json_object_new_string(track->title); + json_object_object_add(jresp, "title", jstring); + } + + if (track->album) { + jstring = json_object_new_string(track->album); + json_object_object_add(jresp, "album", jstring); + } + + if (track->artist) { + jstring = json_object_new_string(track->artist); + json_object_object_add(jresp, "artist", jstring); + } + + if (track->genre) { + jstring = json_object_new_string(track->genre); + json_object_object_add(jresp, "genre", jstring); + } + + if (track->duration > 0) + json_object_object_add(jresp, "duration", + json_object_new_int64(track->duration)); + + json_object_object_add(jresp, "index", + json_object_new_int(track->id)); + + return jresp; +} + +static gboolean populate_from_json(struct playlist_item *item, json_object *jdict) +{ + gboolean ret; + json_object *val = NULL; + + ret = json_object_object_get_ex(jdict, "path", &val); + if (!ret) + return ret; + item->media_path = g_strdup(json_object_get_string(val)); + + ret = json_object_object_get_ex(jdict, "title", &val); + if (ret) { + item->title = g_strdup(json_object_get_string(val)); + } + + ret = json_object_object_get_ex(jdict, "album", &val); + if (ret) { + item->album = g_strdup(json_object_get_string(val)); + } + + ret = json_object_object_get_ex(jdict, "artist", &val); + if (ret) { + item->artist = g_strdup(json_object_get_string(val)); + } + + ret = json_object_object_get_ex(jdict, "genre", &val); + if (ret) { + item->genre = g_strdup(json_object_get_string(val)); + } + + ret = json_object_object_get_ex(jdict, "duration", &val); + if (ret) { + item->duration = json_object_get_int64(val); + } + + return TRUE; +} + +static int set_media_uri(struct playlist_item *item) +{ + if (!item || !item->media_path) + return -ENOENT; + + gst_element_set_state(data.playbin, GST_STATE_NULL); + + g_object_set(data.playbin, "uri", item->media_path, NULL); + + data.position = GST_CLOCK_TIME_NONE; + data.duration = GST_CLOCK_TIME_NONE; + + if (data.playing) + gst_element_set_state(data.playbin, GST_STATE_PLAYING); + + g_object_set(data.playbin, "volume", data.volume / 100.0, NULL); + + return 0; +} + +static void populate_playlist(json_object *jquery) +{ + int i, idx = 0; + GList *list = g_list_last(playlist); + + if (list && list->data) { + struct playlist_item *item = list->data; + idx = item->id + 1; + } + + for (i = 0; i < json_object_array_length(jquery); i++) { + json_object *jdict = json_object_array_get_idx(jquery, i); + struct playlist_item *item = g_malloc0(sizeof(*item)); + int ret; + + if (item == NULL) + break; + + ret = populate_from_json(item, jdict); + if (!ret) { + g_free_playlist_item(item); + continue; + } + + item->id = idx++; + playlist = g_list_append(playlist, item); + } + + current_track = g_list_first(playlist); + set_media_uri(current_track->data); +} + +static void audio_playlist(struct afb_req request) +{ + const char *value = afb_req_value(request, "list"); + json_object *jresp = NULL; + + pthread_mutex_lock(&mutex); + + if (value) { + json_object *jquery; + + if (playlist) { + g_list_free_full(playlist, g_free_playlist_item); + playlist = NULL; + } + + jquery = json_tokener_parse(value); + populate_playlist(jquery); + + if (playlist == NULL) + afb_req_fail(request, "failed", "invalid playlist"); + else + afb_req_success(request, NULL, NULL); + + json_object_put(jquery); + } else { + GList *l; + json_object *jarray = json_object_new_array(); + jresp = json_object_new_object(); + + for (l = playlist; l; l = l->next) { + json_object *item = populate_json(l->data); + json_object_array_add(jarray, item); + } + + json_object_object_add(jresp, "list", jarray); + afb_req_success(request, jresp, "Playlist results"); + } + + pthread_mutex_unlock(&mutex); +} + +static int seek_track(int cmd) +{ + GList *item = (cmd == NEXT_CMD) ? current_track->next : current_track->prev; + int ret; + + if (item == NULL) + return -EINVAL; + + ret = set_media_uri(item->data); + if (ret < 0) + return -EINVAL; + + if (data.playing) + gst_element_set_state(data.playbin, GST_STATE_PLAYING); + + current_track = item; + + return 0; +} + +static int seek_stream(const char *value, int cmd) +{ + gint64 position, current = 0; + + if (value == NULL) + return -EINVAL; + + position = strtoll(value, NULL, 10); + + if (cmd != SEEK_CMD) { + gst_element_query_position (data.playbin, GST_FORMAT_TIME, ¤t); + position = (current / GST_MSECOND) + (FASTFORWARD_CMD ? position : -position); + } + + if (position < 0) + position = 0; + + if (data.duration > 0 && position > data.duration) + position = data.duration; + + return gst_element_seek_simple(data.playbin, GST_FORMAT_TIME, + GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_KEY_UNIT, + position * GST_MSECOND); +} + +/* @value can be one of the following values: + * play - go to playing transition + * pause - go to pause transition + * previous - skip to previous track + * next - skip to the next track + * seek - go to position (in milliseconds) + * + * fast-forward - skip forward in milliseconds + * rewind - skip backward in milliseconds + * + * pick-track - select track via index number + * volume - set volume between 0 - 100% + */ + +static void controls(struct afb_req request) +{ + const char *value = afb_req_value(request, "value"); + const char *position = afb_req_value(request, "position"); + int cmd = get_command_index(value); + + if (!value) { + afb_req_fail(request, "failed", "no value was passed"); + return; + } + + pthread_mutex_lock(&mutex); + errno = 0; + + switch (cmd) { + case PLAY_CMD: + gst_element_set_state(data.playbin, GST_STATE_PLAYING); + data.playing = TRUE; + break; + case PAUSE_CMD: + gst_element_set_state(data.playbin, GST_STATE_PAUSED); + data.playing = FALSE; + break; + case PREVIOUS_CMD: + case NEXT_CMD: + seek_track(cmd); + break; + case SEEK_CMD: + case FASTFORWARD_CMD: + case REWIND_CMD: + seek_stream(position, cmd); + break; + case PICKTRACK_CMD: { + const char *parameter = afb_req_value(request, "index"); + long int idx = strtol(parameter, NULL, 10); + GList *list = NULL; + + if (idx == 0 && !errno) { + afb_req_fail(request, "failed", "invalid index"); + pthread_mutex_unlock(&mutex); + return; + } + + list = find_media_index(playlist, idx); + if (list != NULL) { + struct playlist_item *item = list->data; + set_media_uri(item); + current_track = list; + } else { + afb_req_fail(request, "failed", "couldn't find index"); + pthread_mutex_unlock(&mutex); + return; + } + + break; + } + case VOLUME_CMD: { + const char *parameter = afb_req_value(request, "volume"); + long int volume = strtol(parameter, NULL, 10); + + if (volume == 0 && !errno) { + afb_req_fail(request, "failed", "invalid volume"); + pthread_mutex_unlock(&mutex); + return; + } + + if (volume < 0) + volume = 0; + if (volume > 100) + volume = 100; + + g_object_set(data.playbin, "volume", volume / 100.0, NULL); + + break; + } + default: + afb_req_fail(request, "failed", "unknown command"); + pthread_mutex_unlock(&mutex); + return; + } + + afb_req_success(request, NULL, NULL); + pthread_mutex_unlock(&mutex); +} + +static void metadata(struct afb_req request) +{ + struct playlist_item *track; + json_object *jresp; + + pthread_mutex_lock(&mutex); + + if (current_track == NULL || current_track->data == NULL) { + afb_req_fail(request, "failed", "No playlist"); + pthread_mutex_unlock(&mutex); + return; + } + + track = current_track->data; + jresp = populate_json(track); + + if (data.duration != GST_CLOCK_TIME_NONE) + json_object_object_add(jresp, "duration", + json_object_new_int64(data.duration / GST_MSECOND)); + + if (data.position != GST_CLOCK_TIME_NONE) + json_object_object_add(jresp, "position", + json_object_new_int64(data.position / GST_MSECOND)); + + json_object_object_add(jresp, "volume", + json_object_new_int(data.volume)); + + pthread_mutex_unlock(&mutex); + + afb_req_success(request, jresp, "Metadata results"); +} + +static void subscribe(struct afb_req request) +{ + const char *value = afb_req_value(request, "value"); + + if (value && !strcasecmp(value, "gstreamer")) { + afb_req_subscribe(request, gstreamer_event); + afb_req_success(request, NULL, NULL); + return; + } + + afb_req_fail(request, "failed", "Invalid event"); +} + +static void unsubscribe(struct afb_req request) +{ + const char *value = afb_req_value(request, "value"); + + if (value && !strcasecmp(value, "gstreamer")) { + afb_req_unsubscribe(request, gstreamer_event); + afb_req_success(request, NULL, NULL); + return; + } + + afb_req_fail(request, "failed", "Invalid event"); +} + +static gboolean handle_message(GstBus *bus, GstMessage *msg, CustomData *data) +{ + switch (GST_MESSAGE_TYPE (msg)) { + case GST_MESSAGE_EOS: { + int ret; + + pthread_mutex_lock(&mutex); + + data->position = GST_CLOCK_TIME_NONE; + data->duration = GST_CLOCK_TIME_NONE; + + ret = seek_track(NEXT_CMD); + if (ret < 0) { + data->playing = FALSE; + current_track = playlist; + } else if (data->playing) { + gst_element_set_state(data->playbin, GST_STATE_PLAYING); + } + + pthread_mutex_unlock(&mutex); + break; + } + case GST_MESSAGE_DURATION: + data->duration = GST_CLOCK_TIME_NONE; + break; + default: + break; + } + + return TRUE; +} + +static gboolean position_event(CustomData *data) +{ + struct playlist_item *track; + json_object *jresp = NULL; + + pthread_mutex_lock(&mutex); + + if (!data->playing || current_track == NULL) { + pthread_mutex_unlock(&mutex); + return TRUE; + } + + track = current_track->data; + jresp = populate_json(track); + + if (!GST_CLOCK_TIME_IS_VALID(data->duration)) + gst_element_query_duration(data->playbin, + GST_FORMAT_TIME, &data->duration); + + gst_element_query_position(data->playbin, + GST_FORMAT_TIME, &data->position); + + json_object_object_add(jresp, "duration", + json_object_new_int64(data->duration / GST_MSECOND)); + json_object_object_add(jresp, "position", + json_object_new_int64(data->position / GST_MSECOND)); + + pthread_mutex_unlock(&mutex); + + afb_event_push(gstreamer_event, jresp); + + return TRUE; +} + +static void *gstreamer_loop_thread(void *ptr) +{ + GstBus *bus; + json_object *query, *response; + int ret; + + gst_init(NULL, NULL); + + data.playbin = gst_element_factory_make("playbin", "playbin"); + if (!data.playbin) { + AFB_ERROR("Cannot create playbin"); + exit(1); + } + + bus = gst_element_get_bus(data.playbin); + gst_bus_add_watch(bus, (GstBusFunc) handle_message, &data); + g_timeout_add_seconds(1, (GSourceFunc) position_event, &data); + + ret = afb_service_call_sync("mediascanner", "media_result", NULL, &response); + if (!ret) { + json_object *query = json_object_object_get(response, "response"); + + if (query) + query = json_object_object_get(query, "Media"); + + if (query) + populate_playlist(query); + } + json_object_put(response); + + g_main_loop_run(g_main_loop_new(NULL, FALSE)); + + return NULL; +} + +static void onevent(const char *event, struct json_object *object) +{ + if (!g_strcmp0(event, "mediascanner/media_added")) { + pthread_mutex_lock(&mutex); + + json_object *query = json_object_object_get(object, "Media"); + if (query) + populate_playlist(query); + + pthread_mutex_unlock(&mutex); + } else if (!g_strcmp0(event, "mediascanner/media_removed")) { + json_object *query = json_object_object_get(object, "Path"); + const char *path = json_object_get_string(query); + GList *l = playlist; + + pthread_mutex_lock(&mutex); + + while (l) { + struct playlist_item *item = l->data; + + l = l->next; + + if (!strncasecmp(path, item->media_path, strlen(path))) { + playlist = g_list_remove(playlist, item); + g_free_playlist_item(item); + + if (current_track->data == item) { + current_track = NULL; + gst_element_set_state(data.playbin, GST_STATE_NULL); + } + } + } + + current_track = g_list_first(playlist); + + pthread_mutex_unlock(&mutex); + } else { + AFB_ERROR("Invalid event: %s", event); + } +} + +static int init() { + pthread_t thread_id; + json_object *response, *query; + int ret; + + ret = afb_daemon_require_api("mediascanner", 1); + if (ret < 0) { + AFB_ERROR("Cannot request mediascanner"); + return ret; + } + + query = json_object_new_object(); + json_object_object_add(query, "value", json_object_new_string("media_added")); + + ret = afb_service_call_sync("mediascanner", "subscribe", query, &response); + json_object_put(response); + + if (ret < 0) { + AFB_ERROR("Cannot subscribe to mediascanner media_added event"); + return ret; + } + + query = json_object_new_object(); + json_object_object_add(query, "value", json_object_new_string("media_removed")); + + ret = afb_service_call_sync("mediascanner", "subscribe", query, &response); + json_object_put(response); + + if (ret < 0) { + AFB_ERROR("Cannot subscribe to mediascanner media_remove event"); + return ret; + } + + gstreamer_event = afb_daemon_make_event("gstreamer"); + + return pthread_create(&thread_id, NULL, gstreamer_loop_thread, NULL); +} + +static const struct afb_verb_v2 binding_verbs[] = { + { .verb = "playlist", .callback = audio_playlist, .info = "Get/set playlist" }, + { .verb = "controls", .callback = controls, .info = "Audio controls" }, + { .verb = "metadata", .callback = metadata, .info = "Get metadata of current track" }, + { .verb = "subscribe", .callback = subscribe, .info = "Subscribe to GStreamer events" }, + { .verb = "unsubscribe", .callback = unsubscribe, .info = "Unsubscribe to GStreamer events" }, + { } +}; + +/* + * binder API description + */ +const struct afb_binding_v2 afbBindingV2 = { + .api = "mediaplayer", + .specification = "Mediaplayer API", + .verbs = binding_verbs, + .onevent = onevent, + .init = init, +}; -- cgit 1.2.3-korg