/* -*- Mode: C; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 8 -*- */
/*
 * soup-message-io-source.c
 *
 * Copyright (C) 2000-2003, Ximian, Inc.
 * Copyright (C) 2021 Igalia S.L.
 */

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif

#include "soup-message-io-source.h"

static gboolean
message_io_source_prepare (GSource *source,
                           gint    *timeout)
{
        SoupMessageIOSource *message_io_source = (SoupMessageIOSource *)source;
        *timeout = -1;
        return message_io_source->check_func (source);
}

static gboolean
message_io_source_dispatch (GSource     *source,
                            GSourceFunc  callback,
                            gpointer     user_data)
{
        SoupMessageIOSourceFunc func = (SoupMessageIOSourceFunc)callback;
        SoupMessageIOSource *message_io_source = (SoupMessageIOSource *)source;

        return (*func) (message_io_source->msg, user_data);
}

static void
message_io_source_finalize (GSource *source)
{
        SoupMessageIOSource *message_io_source = (SoupMessageIOSource *)source;

        g_object_unref (message_io_source->msg);
}

static gboolean
message_io_source_closure_callback (SoupMessage *msg,
                                    gpointer     data)
{
        GClosure *closure = data;
        GValue param = G_VALUE_INIT;
        GValue result_value = G_VALUE_INIT;
        gboolean result;

        g_value_init (&result_value, G_TYPE_BOOLEAN);

        g_value_init (&param, SOUP_TYPE_MESSAGE);
        g_value_set_object (&param, msg);

        g_closure_invoke (closure, &result_value, 1, &param, NULL);

        result = g_value_get_boolean (&result_value);
        g_value_unset (&result_value);
        g_value_unset (&param);

        return result;
}

static GSourceFuncs message_io_source_funcs =
{
        message_io_source_prepare,
        NULL,
        message_io_source_dispatch,
        message_io_source_finalize,
        (GSourceFunc)message_io_source_closure_callback,
        (GSourceDummyMarshal)g_cclosure_marshal_generic,
};

GSource *
soup_message_io_source_new (GSource *base_source,
                            GObject *msg,
                            gboolean paused,
                            gboolean (*check_func) (GSource*))
{
        GSource *source = g_source_new (&message_io_source_funcs, sizeof (SoupMessageIOSource));
        g_source_set_name (source, "SoupMessageIOSource");
        SoupMessageIOSource *message_io_source = (SoupMessageIOSource *)source;
        message_io_source->msg = g_object_ref (msg);
        message_io_source->paused = paused;
        message_io_source->check_func = check_func;

        if (base_source) {
                g_source_set_dummy_callback (base_source);
                g_source_add_child_source (source, base_source);
                g_source_unref (base_source);
        }

        return source;
}