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
  24 #define AFB_BINDING_VERSION 2
  25 #include <afb/afb-binding.h>
  26
  27 #include "mediaplayer-manager.h"
  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     if (jstring == NULL) {
  90         json_object_put(jarray);
  91         json_object_put(jresp);
  92         return NULL;
  93     }
  94
  95     json_object_object_add(jresp, "Media", jarray);
  96
  97     return jresp;
  98 }
  99
 100 static void media_results_get (struct afb_req request)
 101 {
 102     GList *list;
 103     json_object *jresp = NULL;
 104
 105     ListLock();
 106     list = media_lightmediascanner_scan();
 107     list = media_local_scan(list);
 108     if (list == NULL) {
 109         afb_req_fail(request, "failed", "media scan error");
 110         ListUnlock();
 111         return;
 112     }
 113
 114     jresp = new_json_object_from_device(list);
 115     g_list_free(list);
 116     ListUnlock();
 117
 118     if (jresp == NULL) {
 119         afb_req_fail(request, "failed", "media parsing error");
 120         return;
 121     }
 122
 123     afb_req_success(request, jresp, "Media Results Displayed");
 124 }
 125
 126 static void media_broadcast_device_added (GList *list)
 127 {
 128     json_object *jresp = new_json_object_from_device(list);
 129
 130     if (jresp != NULL) {
 131         afb_event_push(media_added_event, jresp);
 132     }
 133 }
 134
 135 static void media_broadcast_device_removed (const char *obj_path)
 136 {
 137     json_object *jresp = json_object_new_object();
 138     json_object *jstring = json_object_new_string(obj_path);
 139
 140     json_object_object_add(jresp, "Path", jstring);
 141
 142     afb_event_push(media_removed_event, jresp);
 143 }
 144
 145 static const struct afb_verb_v2 binding_verbs[] = {
 146     { "media_result", media_results_get, NULL, "Media scan result",        AFB_SESSION_CHECK },
 147     { "subscribe",    subscribe,         NULL, "Subscribe for an event",   AFB_SESSION_CHECK },
 148     { "unsubscribe",  unsubscribe,       NULL, "Unsubscribe for an event", AFB_SESSION_CHECK },
 149     { NULL }
 150 };
 151
 152 static int preinit()
 153 {
 154     Binding_RegisterCallback_t API_Callback;
 155     API_Callback.binding_device_added = media_broadcast_device_added;
 156     API_Callback.binding_device_removed = media_broadcast_device_removed;
 157     BindingAPIRegister(&API_Callback);
 158
 159     return MediaPlayerManagerInit();
 160 }
 161
 162 static int init()
 163 {
 164     media_added_event = afb_daemon_make_event("media_added");
 165     media_removed_event = afb_daemon_make_event("media_removed");
 166
 167     return 0;
 168 }
 169
 170 const struct afb_binding_v2 afbBindingV2 = {
 171     .api = "media-manager",
 172     .specification = "mediaplayer API",
 173     .preinit = preinit,
 174     .init = init,
 175     .verbs = binding_verbs,
 176 };