/***************************************************************************
 *
 * adt_data.c : Provides Audit functionalities
 *
 * Copyright 2008 Sun Microsystems, Inc.  All rights reserved.
 * Use is subject to license terms.
 *
 * Licensed under the Academic Free License version 2.1
 *
 ***************************************************************************/

#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <stdlib.h>
#include <glib.h>
#include <dbus/dbus-glib-lowlevel.h>
#include <dbus/dbus-glib.h>
#include "../hald/logger.h"
#include "adt_data.h"

adt_export_data_t *
get_audit_export_data(DBusConnection *bus, const char *invoked_by_syscon_name, size_t *data_size)
{
        DBusMessage *message;
        DBusMessage *reply;
        DBusMessageIter iter, subiter;
        DBusError error;
        int count, bufsize;
        uchar_t *buf;
        uchar_t value;

        message = dbus_message_new_method_call ("org.freedesktop.DBus",
                                                "/org/freedesktop/DBus",
                                                "org.freedesktop.DBus",
                                                "GetAdtAuditSessionData");
        if (message == NULL) {
                printf ("cannot get GetAdtAuditSessionData message\n");
                return NULL;
        }

        if (!dbus_message_append_args(message, DBUS_TYPE_STRING, &invoked_by_syscon_name,
            DBUS_TYPE_INVALID)) {
                dbus_message_unref(message);
                return NULL;
        }

        dbus_error_init (&error);
        reply = dbus_connection_send_with_reply_and_block (bus,
                                                           message, -1,
                                                           &error);
        if (dbus_error_is_set (&error)) {
                printf ("send failed %s\n", error.message);
                dbus_error_free (&error);
                dbus_message_unref (message);
                return NULL;
        }
        if (reply == NULL) {
                dbus_message_unref (message);
                return NULL;
        }

        dbus_message_iter_init (reply, &iter);

        if (dbus_message_iter_get_arg_type (&iter) != DBUS_TYPE_ARRAY  ||
            dbus_message_iter_get_element_type (&iter) != DBUS_TYPE_BYTE) {
                printf ("expecting an array of byte entries\n");
                dbus_message_unref (message);
                dbus_message_unref (reply);
                return NULL;
        }
        dbus_message_iter_recurse (&iter, &subiter);

        count = 0;
        bufsize = 256;
        buf = (uchar_t *)malloc (bufsize);

        while (dbus_message_iter_get_arg_type (&subiter) == DBUS_TYPE_BYTE) {
                if (count == bufsize) {
                        bufsize += 256;
                        buf = realloc (buf, bufsize);
                        if (buf == NULL) {
                                dbus_message_unref (message);
                                dbus_message_unref (reply);
                                return NULL;
                        }
                }

                dbus_message_iter_get_basic (&subiter, &value);
                buf[count++] = value;
                dbus_message_iter_next(&subiter);
        }

        dbus_message_unref (message);
        dbus_message_unref (reply);

        *data_size = count;
        if (count == 0) {
                free (buf);
                buf = NULL;
        }

        return (adt_export_data_t *)buf;
}