lpac/driver/apdu/mbim_helpers.c

// SPDX-License-Identifier: MIT
/*
 Copyright (c) 2024, Frans Klaver <frans.klaver@vislink.com>
 */

#include "mbim_helpers.h"

#include <libmbim-glib.h>

static void async_result_ready(GObject *source_object, GAsyncResult *res, gpointer user_data) {
    GAsyncResult **result_out = user_data;

    g_assert(*result_out == NULL);
    *result_out = g_object_ref(res);
}

MbimDevice *mbim_device_new_from_path(GFile *file, GMainContext *context, GError **error) {
    g_autoptr(GMainContextPusher) pusher = NULL;
    g_autoptr(GAsyncResult) result = NULL;
    g_autofree gchar *id = NULL;

    pusher = g_main_context_pusher_new(context);

    id = g_file_get_path(file);
    if (id)
        mbim_device_new(file, NULL, async_result_ready, &result);

    while (!result)
        g_main_context_iteration(context, TRUE);

    return mbim_device_new_finish(result, error);
}

gboolean mbim_device_open_sync(MbimDevice *device, MbimDeviceOpenFlags open_flags, GMainContext *context,
                               GError **error) {
    g_autoptr(GMainContextPusher) pusher = NULL;
    g_autoptr(GAsyncResult) result = NULL;

    pusher = g_main_context_pusher_new(context);

    mbim_device_open_full(device, open_flags, 15, NULL, async_result_ready, &result);

    while (!result)
        g_main_context_iteration(context, TRUE);

    return mbim_device_open_finish(device, result, error);
}

MbimMessage *mbim_device_command_sync(MbimDevice *device, GMainContext *context, MbimMessage *request, GError **error) {
    g_autoptr(GMainContextPusher) pusher = NULL;
    g_autoptr(GAsyncResult) result = NULL;

    pusher = g_main_context_pusher_new(context);

    mbim_device_command(device, request, 10, NULL, async_result_ready, &result);
    mbim_message_unref(request);

    while (result == NULL)
        g_main_context_iteration(context, TRUE);

    MbimMessage *response = mbim_device_command_finish(device, result, error);
    if (!response) {
        return NULL;
    }

    if (!mbim_message_response_get_result(response, MBIM_MESSAGE_TYPE_COMMAND_DONE, error)) {
        return NULL;
    }

    return response;
}

gboolean mbim_device_close_sync(MbimDevice *device, GMainContext *context, GError **error) {
    g_autoptr(GMainContextPusher) pusher = NULL;
    g_autoptr(GAsyncResult) result = NULL;

    pusher = g_main_context_pusher_new(context);

    mbim_device_close(device, 20, NULL, async_result_ready, &result);

    while (result == NULL)
        g_main_context_iteration(context, TRUE);

    return mbim_device_close_finish(device, result, error);
}