aboutsummaryrefslogtreecommitdiff
path: root/src/mm-call-qmi.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/mm-call-qmi.c')
-rw-r--r--src/mm-call-qmi.c305
1 files changed, 305 insertions, 0 deletions
diff --git a/src/mm-call-qmi.c b/src/mm-call-qmi.c
index 3d732cf1..e072f0e5 100644
--- a/src/mm-call-qmi.c
+++ b/src/mm-call-qmi.c
@@ -34,6 +34,303 @@
G_DEFINE_TYPE (MMCallQmi, mm_call_qmi, MM_TYPE_BASE_CALL)
+/*****************************************************************************/
+
+static gboolean
+ensure_qmi_client (MMCallQmi *self,
+ QmiService service,
+ QmiClient **o_client,
+ GAsyncReadyCallback callback,
+ gpointer user_data)
+{
+ MMBaseModem *modem = NULL;
+ QmiClient *client;
+ MMPortQmi *port;
+
+ g_object_get (self,
+ MM_BASE_CALL_MODEM, &modem,
+ NULL);
+ g_assert (MM_IS_BASE_MODEM (modem));
+
+ port = mm_broadband_modem_qmi_peek_port_qmi (MM_BROADBAND_MODEM_QMI (modem));
+ g_object_unref (modem);
+
+ if (!port) {
+ g_task_report_new_error (self,
+ callback,
+ user_data,
+ ensure_qmi_client,
+ MM_CORE_ERROR,
+ MM_CORE_ERROR_FAILED,
+ "Couldn't peek QMI port");
+ return FALSE;
+ }
+
+ client = mm_port_qmi_peek_client (port,
+ service,
+ MM_PORT_QMI_FLAG_DEFAULT);
+ if (!client) {
+ g_task_report_new_error (self,
+ callback,
+ user_data,
+ ensure_qmi_client,
+ MM_CORE_ERROR,
+ MM_CORE_ERROR_FAILED,
+ "Couldn't peek client for service '%s'",
+ qmi_service_get_string (service));
+ return FALSE;
+ }
+
+ *o_client = client;
+ return TRUE;
+}
+
+/*****************************************************************************/
+/* Start the CALL */
+
+static gboolean
+call_start_finish (MMBaseCall *self,
+ GAsyncResult *res,
+ GError **error)
+{
+ return g_task_propagate_boolean (G_TASK (res), error);
+}
+
+static void
+voice_dial_call_ready (QmiClientVoice *client,
+ GAsyncResult *res,
+ GTask *task)
+{
+ QmiMessageVoiceDialCallOutput *output;
+ GError *error = NULL;
+ MMBaseCall *self;
+
+ self = MM_BASE_CALL (g_task_get_source_object (task));
+
+ output = qmi_client_voice_dial_call_finish (client, res, &error);
+ if (!output) {
+ g_prefix_error (&error, "QMI operation failed: ");
+ g_task_return_error (task, error);
+ } else if (!qmi_message_voice_dial_call_output_get_result (output, &error)) {
+ g_prefix_error (&error, "Couldn't create call: ");
+ g_task_return_error (task, error);
+ } else {
+ guint8 call_id = 0;
+
+ qmi_message_voice_dial_call_output_get_call_id (output, &call_id, NULL);
+ if (call_id == 0) {
+ g_task_return_new_error (task,
+ MM_CORE_ERROR,
+ MM_CORE_ERROR_INVALID_ARGS,
+ "Invalid call index");
+ } else {
+ mm_base_call_set_index (self, call_id);
+ g_task_return_boolean (task, TRUE);
+ }
+ }
+
+ if (output)
+ qmi_message_voice_dial_call_output_unref (output);
+
+ g_object_unref (task);
+}
+
+static void
+call_start (MMBaseCall *self,
+ GCancellable *cancellable,
+ GAsyncReadyCallback callback,
+ gpointer user_data)
+{
+ QmiClient *client = NULL;
+ GTask *task;
+ QmiMessageVoiceDialCallInput *input;
+
+ /* Ensure Voice client */
+ if (!ensure_qmi_client (MM_CALL_QMI (self),
+ QMI_SERVICE_VOICE, &client,
+ callback, user_data))
+ return;
+
+ task = g_task_new (self, NULL, callback, user_data);
+
+ input = qmi_message_voice_dial_call_input_new ();
+ qmi_message_voice_dial_call_input_set_calling_number (
+ input,
+ mm_gdbus_call_get_number (MM_GDBUS_CALL (self)),
+ NULL);
+
+ mm_obj_dbg (self, "starting call");
+ qmi_client_voice_dial_call (QMI_CLIENT_VOICE (client),
+ input,
+ 90,
+ NULL,
+ (GAsyncReadyCallback) voice_dial_call_ready,
+ task);
+ qmi_message_voice_dial_call_input_unref (input);
+}
+
+/*****************************************************************************/
+/* Accept the call */
+
+static gboolean
+call_accept_finish (MMBaseCall *self,
+ GAsyncResult *res,
+ GError **error)
+{
+ return g_task_propagate_boolean (G_TASK (res), error);
+}
+
+static void
+voice_answer_call_ready (QmiClientVoice *client,
+ GAsyncResult *res,
+ GTask *task)
+{
+ QmiMessageVoiceAnswerCallOutput *output;
+ GError *error = NULL;
+
+ output = qmi_client_voice_answer_call_finish (client, res, &error);
+ if (!output) {
+ g_prefix_error (&error, "QMI operation failed: ");
+ g_task_return_error (task, error);
+ } else if (!qmi_message_voice_answer_call_output_get_result (output, &error)) {
+ g_prefix_error (&error, "Couldn't accept call: ");
+ g_task_return_error (task, error);
+ } else {
+ g_task_return_boolean (task, TRUE);
+ }
+
+ if (output)
+ qmi_message_voice_answer_call_output_unref (output);
+
+ g_object_unref (task);
+}
+
+static void
+call_accept (MMBaseCall *self,
+ GAsyncReadyCallback callback,
+ gpointer user_data)
+{
+ QmiClient *client = NULL;
+ GTask *task;
+ guint8 call_id;
+ QmiMessageVoiceAnswerCallInput *input;
+
+ /* Ensure Voice client */
+ if (!ensure_qmi_client (MM_CALL_QMI (self),
+ QMI_SERVICE_VOICE, &client,
+ callback, user_data))
+ return;
+
+ task = g_task_new (self, NULL, callback, user_data);
+
+ call_id = mm_base_call_get_index (self);
+ if (call_id == 0) {
+ g_task_return_new_error (task,
+ MM_CORE_ERROR,
+ MM_CORE_ERROR_INVALID_ARGS,
+ "Invalid call index");
+ g_object_unref (task);
+ return;
+ }
+
+ input = qmi_message_voice_answer_call_input_new ();
+ qmi_message_voice_answer_call_input_set_call_id (
+ input,
+ call_id,
+ NULL);
+
+ mm_obj_dbg (self, "Accepting call with id: %u", call_id);
+ qmi_client_voice_answer_call (QMI_CLIENT_VOICE (client),
+ input,
+ 5,
+ NULL,
+ (GAsyncReadyCallback) voice_answer_call_ready,
+ task);
+ qmi_message_voice_answer_call_input_unref (input);
+}
+
+/*****************************************************************************/
+/* Hangup the call */
+
+static gboolean
+call_hangup_finish (MMBaseCall *self,
+ GAsyncResult *res,
+ GError **error)
+{
+ return g_task_propagate_boolean (G_TASK (res), error);
+}
+
+static void
+voice_end_call_ready (QmiClientVoice *client,
+ GAsyncResult *res,
+ GTask *task)
+{
+ QmiMessageVoiceEndCallOutput *output;
+ GError *error = NULL;
+
+ output = qmi_client_voice_end_call_finish (client, res, &error);
+ if (!output) {
+ g_prefix_error (&error, "QMI operation failed: ");
+ g_task_return_error (task, error);
+ } else if (!qmi_message_voice_end_call_output_get_result (output, &error)) {
+ g_prefix_error (&error, "Couldn't hangup call: ");
+ g_task_return_error (task, error);
+ } else {
+ g_task_return_boolean (task, TRUE);
+ }
+
+ if (output)
+ qmi_message_voice_end_call_output_unref (output);
+
+ g_object_unref (task);
+}
+
+static void
+call_hangup (MMBaseCall *self,
+ GAsyncReadyCallback callback,
+ gpointer user_data)
+{
+ QmiClient *client = NULL;
+ GTask *task;
+ guint8 call_id;
+ QmiMessageVoiceEndCallInput *input;
+
+ /* Ensure Voice client */
+ if (!ensure_qmi_client (MM_CALL_QMI (self),
+ QMI_SERVICE_VOICE, &client,
+ callback, user_data))
+ return;
+
+ task = g_task_new (self, NULL, callback, user_data);
+
+ call_id = mm_base_call_get_index (self);
+ if (call_id == 0) {
+ g_task_return_new_error (task,
+ MM_CORE_ERROR,
+ MM_CORE_ERROR_INVALID_ARGS,
+ "Invalid call index");
+ g_object_unref (task);
+ return;
+ }
+
+ input = qmi_message_voice_end_call_input_new ();
+ qmi_message_voice_end_call_input_set_call_id (
+ input,
+ call_id,
+ NULL);
+
+ mm_obj_dbg (self, "Hanging up call with id: %u", call_id);
+ qmi_client_voice_end_call (QMI_CLIENT_VOICE (client),
+ input,
+ 5,
+ NULL,
+ (GAsyncReadyCallback) voice_end_call_ready,
+ task);
+ qmi_message_voice_end_call_input_unref (input);
+}
+
+/*****************************************************************************/
+
MMBaseCall *
mm_call_qmi_new (MMBaseModem *modem,
MMCallDirection direction,
@@ -57,4 +354,12 @@ mm_call_qmi_init (MMCallQmi *self)
static void
mm_call_qmi_class_init (MMCallQmiClass *klass)
{
+ MMBaseCallClass *base_call_class = MM_BASE_CALL_CLASS (klass);
+
+ base_call_class->start = call_start;
+ base_call_class->start_finish = call_start_finish;
+ base_call_class->accept = call_accept;
+ base_call_class->accept_finish = call_accept_finish;
+ base_call_class->hangup = call_hangup;
+ base_call_class->hangup_finish = call_hangup_finish;
}
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2025-06-07 16:22:26 +0000