/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
/*
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details:
 *
 * Copyright (C) 2021 Joel Selvaraj <jo@jsfamily.in>
 */

#include <config.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <ctype.h>

#include <ModemManager.h>
#define _LIBMM_INSIDE_MM
#include <libmm-glib.h>

#include "mm-broadband-modem-qmi.h"
#include "mm-modem-helpers-qmi.h"
#include "mm-iface-modem.h"
#include "mm-iface-modem-voice.h"
#include "mm-call-qmi.h"
#include "mm-base-modem.h"
#include "mm-log-object.h"

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,
                 const gchar     *number)
{
    return MM_BASE_CALL (g_object_new (MM_TYPE_CALL_QMI,
                                       MM_BASE_CALL_MODEM, modem,
                                       "direction",        direction,
                                       "number",           number,
                                       MM_BASE_CALL_SKIP_INCOMING_TIMEOUT,       TRUE,
                                       MM_BASE_CALL_SUPPORTS_DIALING_TO_RINGING, TRUE,
                                       MM_BASE_CALL_SUPPORTS_RINGING_TO_ACTIVE,  TRUE,
                                       NULL));
}

static void
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;
}