binding/mediaplayer-api.c

   1 /*
   2  *   Copyright 2017 Konsulko Group
   3  *
   4  *   Licensed under the Apache License, Version 2.0 (the "License");
   5  *   you may not use this file except in compliance with the License.
   6  *   You may obtain a copy of the License at
   7  *
   8  *   http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  *   Unless required by applicable law or agreed to in writing, software
  11  *   distributed under the License is distributed on an "AS IS" BASIS,
  12  *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  *   See the License for the specific language governing permissions and
  14  *   limitations under the License.
  15  */
  16
  17 #define _GNU_SOURCE
  18 #include <stdio.h>
  19 #include <string.h>
  20 #include <stdlib.h>
  21 #include <unistd.h>
  22 #include <json-c/json.h>
  23 #include <afb/afb-binding.h>
  24
  25 #include "mediaplayer-manager.h"
  26
  27 const struct afb_binding_interface *afbitf;
  28
  29 static struct afb_event media_added_event;
  30 static struct afb_event media_removed_event;
  31
  32 /*
  33  * @brief Subscribe for an event
  34  *
  35  * @param struct afb_req : an afb request structure
  36  *
  37  */
  38 static void subscribe(struct afb_req request)
  39 {
  40         const char *value = afb_req_value(request, "value");
  41         if(value) {
  42                 if(!strcasecmp(value, "media_added")) {
  43                         afb_req_subscribe(request, media_added_event);
  44                 } else if(!strcasecmp(value, "media_removed")) {
  45                         afb_req_subscribe(request, media_removed_event);
  46                 } else {
  47                         afb_req_fail(request, "failed", "Invalid event");
  48                         return;
  49                 }
  50         }
  51         afb_req_success(request, NULL, NULL);
  52 }
  53
  54 /*
  55  * @brief Unsubscribe for an event
  56  *
  57  * @param struct afb_req : an afb request structure
  58  *
  59  */
  60 static void unsubscribe(struct afb_req request)
  61 {
  62         const char *value = afb_req_value(request, "value");
  63         if(value) {
  64                 if(!strcasecmp(value, "media_added")) {
  65                         afb_req_unsubscribe(request, media_added_event);
  66                 } else if(!strcasecmp(value, "media_removed")) {
  67                         afb_req_unsubscribe(request, media_removed_event);
  68                 } else {
  69                         afb_req_fail(request, "failed", "Invalid event");
  70                         return;
  71                 }
  72         }
  73         afb_req_success(request, NULL, NULL);
  74 }
  75
  76 static json_object *new_json_object_from_device(GList *list)
  77 {
  78     json_object *jarray = json_object_new_array();
  79     json_object *jresp = json_object_new_object();
  80     json_object *jstring = NULL;
  81     GList *l;
  82
  83     for (l = list; l; l = l->next)
  84     {
  85         jstring = json_object_new_string(l->data);
  86         json_object_array_add(jarray, jstring);
  87     }
  88
  89     json_object_object_add(jresp, "Media", jarray);
  90
  91     // TODO: Add media path
  92     jstring = json_object_new_string("");
  93     json_object_object_add(jresp, "Path", jstring);
  94
  95     return jresp;
  96 }
  97
  98 static void media_results_get (struct afb_req request)
  99 {
 100     GList *list;
 101     json_object *jresp = NULL;
 102
 103     ListLock();
 104     list = media_lightmediascanner_scan();
 105     if (list == NULL) {
 106         afb_req_fail(request, "failed", "media scan error");
 107         ListUnlock();
 108         return;
 109     }
 110
 111     jresp = new_json_object_from_device(list);
 112     ListUnlock();
 113
 114     if (jresp == NULL) {
 115         afb_req_fail(request, "failed", "media parsing error");
 116         return;
 117     }
 118
 119     afb_req_success(request, jresp, "Media Results Displayed");
 120 }
 121
 122 static void media_broadcast_device_added (GList *list)
 123 {
 124     json_object *jresp = new_json_object_from_device(list);
 125
 126     afb_event_push(media_added_event, jresp);
 127 }
 128
 129 /*
 130  * TODO: support multiple devices
 131  */
 132 static void media_broadcast_device_removed (const char *obj_path)
 133 {
 134     json_object *jresp = json_object_new_object();
 135     json_object *jstring = json_object_new_string(obj_path);
 136
 137     json_object_object_add(jresp, "Path", jstring);
 138
 139     afb_event_push(media_removed_event, jresp);
 140 }
 141
 142 static const struct afb_verb_desc_v1 binding_verbs[] = {
 143     { "media_result",   AFB_SESSION_CHECK, media_results_get,   "Media scan result" },
 144     { "subscribe",      AFB_SESSION_CHECK, subscribe,           "Subscribe for an event" },
 145     { "unsubscribe",    AFB_SESSION_CHECK, unsubscribe,         "Unsubscribe for an event" },
 146     { NULL }
 147 };
 148
 149 static const struct afb_binding binding_description = {
 150     .type = AFB_BINDING_VERSION_1,
 151     .v1 = {
 152         .prefix = "media-manager",
 153         .info = "mediaplayer API",
 154         .verbs = binding_verbs,
 155     }
 156 };
 157
 158 const struct afb_binding
 159 *afbBindingV1Register(const struct afb_binding_interface *itf)
 160 {
 161     afbitf = itf;
 162
 163     Binding_RegisterCallback_t API_Callback;
 164     API_Callback.binding_device_added = media_broadcast_device_added;
 165     API_Callback.binding_device_removed = media_broadcast_device_removed;
 166     BindingAPIRegister(&API_Callback);
 167
 168     MediaPlayerManagerInit();
 169
 170     return &binding_description;
 171 }
 172
 173 int afbBindingV1ServiceInit(struct afb_service service)
 174 {
 175     media_added_event = afb_daemon_make_event(afbitf->daemon, "media_added");
 176     media_removed_event = afb_daemon_make_event(afbitf->daemon, "media_removed");
 177
 178     return 0;
 179 }