--- /dev/null
+/*
+ * Copyright (C) 2017 Konsulko Group
+ *
+ * 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 <glib.h>
+#include <json-c/json.h>
+
+#include <afb/afb-binding.h>
+#include <afb/afb-service-itf.h>
+
+#include "ofono_manager.h"
+#include "ofono_voicecallmanager.h"
+#include "ofono_voicecall.h"
+
+static const struct afb_binding_interface *interface;
+
+static OrgOfonoVoiceCallManager *vcm;
+static OrgOfonoVoiceCall *incoming_call, *voice_call;
+
+static void dial(struct afb_req request)
+{
+ struct json_object *query, *val;
+ const char *number;
+
+ query = afb_req_json(request);
+ json_object_object_get_ex(query, "value", &val);
+ if (json_object_is_type(val, json_type_string)) {
+ number = json_object_get_string(val);
+ if (voice_call) {
+ ERROR(interface, "dial: cannot dial with active call");
+ afb_req_fail(request, "active call", NULL);
+ } else {
+ DEBUG(interface, "dial: %s...\n", number);
+ if (ofono_voicecallmanager_dial(vcm, (gchar *)number, "")) {
+ afb_req_success(request, NULL, NULL);
+ } else {
+ ERROR(interface, "dial: failed to dial number\n");
+ afb_req_fail(request, "failed dial", NULL);
+ }
+ }
+ } else {
+ ERROR(interface, "dial: no phone number parameter\n");
+ afb_req_fail(request, "no number", NULL);
+ }
+}
+
+static void hangup(struct afb_req request)
+{
+ if (voice_call) {
+ DEBUG(interface, "Hangup voice call\n");
+ ofono_voicecall_hangup(voice_call);
+ afb_req_success(request, NULL, NULL);
+ } else if (incoming_call) {
+ DEBUG(interface, "Reject incoming call\n");
+ ofono_voicecall_hangup(incoming_call);
+ afb_req_success(request, NULL, NULL);
+ } else {
+ ERROR(interface, "Hangup: no active call");
+ afb_req_fail(request, "failed hangup", NULL);
+ }
+}
+
+static void answer(struct afb_req request)
+{
+ if (incoming_call) {
+ DEBUG(interface, "Answer voice call\n");
+ voice_call = incoming_call;
+ ofono_voicecall_answer(voice_call);
+ } else {
+ ERROR(interface, "Answer: no incoming call");
+ }
+}
+
+static void call_state_changed_cb(OrgOfonoVoiceCall *vc, gchar *state)
+{
+ struct json_object *call_state;
+ call_state = json_object_new_object();
+ json_object_object_add(call_state, "state", json_object_new_string(state));
+ afb_daemon_broadcast_event(interface->daemon, "callStateChanged", call_state);
+}
+
+static void incoming_call_cb(OrgOfonoVoiceCallManager *manager, gchar *op, gchar *clip)
+{
+ struct json_object *call_info;
+
+ call_info = json_object_new_object();
+ json_object_object_add(call_info, "clip", json_object_new_string(clip));
+ afb_daemon_broadcast_event(interface->daemon, "incomingCall", call_info);
+ incoming_call = ofono_voicecall_new(interface, op, call_state_changed_cb);
+}
+
+static void dialing_call_cb(OrgOfonoVoiceCallManager *manager, gchar *op, gchar *colp)
+{
+ struct json_object *call_info;
+
+ call_info = json_object_new_object();
+ json_object_object_add(call_info, "colp", json_object_new_string(colp));
+ afb_daemon_broadcast_event(interface->daemon, "dialingCall", call_info);
+ voice_call = ofono_voicecall_new(interface, op, call_state_changed_cb);
+}
+
+static void terminated_call_cb(OrgOfonoVoiceCallManager *manager, gchar *op)
+{
+ if (incoming_call) {
+ ofono_voicecall_free(incoming_call);
+ incoming_call = NULL;
+ } else if (voice_call) {
+ ofono_voicecall_free(voice_call);
+ }
+ voice_call = NULL;
+
+ afb_daemon_broadcast_event(interface->daemon, "terminatedCall", NULL);
+}
+
+static void *main_loop_thread(void *unused)
+{
+ GMainLoop *loop = g_main_loop_new(NULL, FALSE);
+ g_main_loop_run(loop);
+ return NULL;
+}
+
+static int ofono_init(void)
+{
+ pthread_t tid;
+ int ret = 0;
+
+ /* Start the main loop thread */
+ pthread_create(&tid, NULL, main_loop_thread, NULL);
+
+ ret = ofono_manager_init(interface);
+ if (ret == 0) {
+ const gchar *modem_path = ofono_manager_get_default_modem_path();
+ if (modem_path) {
+ DEBUG(interface, "modem_path: %s\n", modem_path);
+ vcm = ofono_voicecallmanager_init(interface, modem_path,
+ incoming_call_cb,
+ dialing_call_cb,
+ terminated_call_cb);
+ if (!vcm) {
+ ERROR(interface, "[telephony] failed to initialize voice call manager\n");
+ ret = -1;
+ }
+ } else {
+ ERROR(interface, "[telephony] default modem not set\n");
+ ret = -1;
+ }
+ } else {
+ ERROR(interface, "[telephony] failed to initialize ofono manager: " \
+ "HFP device not connected or Bluetooth disabled\n");
+ }
+
+ return ret;
+}
+
+static const struct afb_verb_desc_v1 verbs[]= {
+ {
+ .name = "dial",
+ .session = AFB_SESSION_NONE,
+ .callback = dial,
+ .info = "Dial phone"
+ },
+ {
+ .name = "hangup",
+ .session = AFB_SESSION_NONE,
+ .callback = hangup,
+ .info = "Hangup phone"
+ },
+ {
+ .name = "answer",
+ .session = AFB_SESSION_NONE,
+ .callback = answer,
+ .info = "Answer phone"
+ },
+ {NULL}
+};
+
+static const struct afb_binding binding_desc = {
+ .type = AFB_BINDING_VERSION_1,
+ .v1 = {
+ .info = "telephony service",
+ .prefix = "telephony",
+ .verbs = verbs
+ }
+};
+
+const struct afb_binding *afbBindingV1Register (const struct afb_binding_interface *itf)
+{
+ interface = itf;
+
+ return &binding_desc;
+}
+
+int afbBindingV1ServiceInit(struct afb_service service)
+{
+ DEBUG(interface, "Initializing telephony service\n");
+
+ return ofono_init();
+}
Code Review / staging / soundmanager.git / blobdiff