summaryrefslogtreecommitdiffstats
path: root/binding/radio-binding.c
diff options
context:
space:
mode:
authorScott Murray <scott.murray@konsulko.com>2019-01-03 01:36:35 -0500
committerScott Murray <scott.murray@konsulko.com>2019-01-04 20:50:19 +0000
commita2fdf6e139207e7b0e0270c8a167c6a30c8fe61d (patch)
tree32ceb4aa8a88200c52baeb376565fe6341d6f530 /binding/radio-binding.c
parentf1d5902c92eafd3aad62e29298502603a9b56d81 (diff)
Add a status event to indicate playing versus stopped state, this allows users to detect when the binding has been stopped by another user. Change-Id: I4c1256427f0113b535e12a2dbc121d45c93dc0dd Signed-off-by: Scott Murray <scott.murray@konsulko.com>
Diffstat (limited to 'binding/radio-binding.c')
-rw-r--r--binding/radio-binding.c16
1 files changed, 16 insertions, 0 deletions
diff --git a/binding/radio-binding.c b/binding/radio-binding.c
index 490af5b..02135fc 100644
--- a/binding/radio-binding.c
+++ b/binding/radio-binding.c
@@ -35,6 +35,7 @@ static radio_impl_ops_t *radio_impl_ops;
static struct afb_event freq_event;
static struct afb_event scan_event;
+static struct afb_event status_event;
static void freq_callback(uint32_t frequency, void *data)
{
@@ -376,6 +377,11 @@ static void start(struct afb_req request)
free(output);
}
afb_req_success(request, NULL, NULL);
+
+ json_object *jresp = json_object_new_object();
+ json_object *value = json_object_new_string("playing");
+ json_object_object_add(jresp, "value", value);
+ afb_event_push(status_event, json_object_get(jresp));
}
/*
@@ -389,6 +395,11 @@ static void stop(struct afb_req request)
radio_impl_ops->stop();
set_role_state(false, NULL);
afb_req_success(request, NULL, NULL);
+
+ json_object *jresp = json_object_new_object();
+ json_object *value = json_object_new_string("stopped");
+ json_object_object_add(jresp, "value", value);
+ afb_event_push(status_event, json_object_get(jresp));
}
/*
@@ -507,6 +518,8 @@ static void subscribe(struct afb_req request)
afb_req_subscribe(request, freq_event);
} else if(!strcasecmp(value, "station_found")) {
afb_req_subscribe(request, scan_event);
+ } else if(!strcasecmp(value, "status")) {
+ afb_req_subscribe(request, status_event);
} else {
afb_req_fail(request, "failed", "Invalid event");
return;
@@ -529,6 +542,8 @@ static void unsubscribe(struct afb_req request)
afb_req_unsubscribe(request, freq_event);
} else if(!strcasecmp(value, "station_found")) {
afb_req_unsubscribe(request, scan_event);
+ } else if(!strcasecmp(value, "status")) {
+ afb_req_unsubscribe(request, status_event);
} else {
afb_req_fail(request, "failed", "Invalid event");
return;
@@ -577,6 +592,7 @@ static int init()
// Initialize event structures
freq_event = afb_daemon_make_event("frequency");
scan_event = afb_daemon_make_event("station_found");
+ status_event = afb_daemon_make_event("status");
return 0;
}