sample/mediaplayer/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         return NULL;
  91
  92     json_object_object_add(jresp, "Media", jarray);
  93
  94     return jresp;
  95 }
  96
  97 static void media_results_get (struct afb_req request)
  98 {
  99     GList *list;
 100     json_object *jresp = NULL;
 101
 102     ListLock();
 103     list = media_lightmediascanner_scan();
 104     list = media_local_scan(list);
 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     g_list_free(list);
 113     ListUnlock();
 114
 115     if (jresp == NULL) {
 116         afb_req_fail(request, "failed", "media parsing error");
 117         return;
 118     }
 119
 120     afb_req_success(request, jresp, "Media Results Displayed");
 121 }
 122
 123 static void media_broadcast_device_added (GList *list)
 124 {
 125     json_object *jresp = new_json_object_from_device(list);
 126
 127     if (jresp != NULL) {
 128         afb_event_push(media_added_event, jresp);
 129     }
 130 }
 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_v2 binding_verbs[] = {
 143     { "media_result", media_results_get, NULL, "Media scan result",        AFB_SESSION_CHECK },
 144     { "subscribe",    subscribe,         NULL, "Subscribe for an event",   AFB_SESSION_CHECK },
 145     { "unsubscribe",  unsubscribe,       NULL, "Unsubscribe for an event", AFB_SESSION_CHECK },
 146     { NULL }
 147 };
 148
 149 static int preinit()
 150 {
 151     Binding_RegisterCallback_t API_Callback;
 152     API_Callback.binding_device_added = media_broadcast_device_added;
 153     API_Callback.binding_device_removed = media_broadcast_device_removed;
 154     BindingAPIRegister(&API_Callback);
 155
 156     return MediaPlayerManagerInit();
 157 }
 158
 159 static int init()
 160 {
 161     media_added_event = afb_daemon_make_event("media_added");
 162     media_removed_event = afb_daemon_make_event("media_removed");
 163
 164     return 0;
 165 }
 166
 167 const struct afb_binding_v2 afbBindingV2 = {
 168     .api = "media-manager",
 169     .specification = "mediaplayer API",
 170     .preinit = preinit,
 171     .init = init,
 172     .verbs = binding_verbs,
 173 };