/*
 * @licence app begin@
 * SPDX license identifier: MPL-2.0
 *
 * Copyright (C) 2011-2015, BMW AG
 *
 * This file is part of GENIVI Project DLT - Diagnostic Log and Trace.
 *
 * This Source Code Form is subject to the terms of the
 * Mozilla Public License (MPL), v. 2.0.
 * If a copy of the MPL was not distributed with this file,
 * You can obtain one at http://mozilla.org/MPL/2.0/.
 *
 * For further information see http://www.genivi.org/.
 * @licence end@
 */

/*!
 * \author Alexander Wenzel <alexander.aw.wenzel@bmw.de>
 *
 * \copyright Copyright © 2011-2015 BMW AG. \n
 * License MPL-2.0: Mozilla Public License version 2.0 http://mozilla.org/MPL/2.0/.
 *
 * \file dlt-dbus.c
 */

#include "dlt-dbus.h"

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <dbus/dbus.h>
#include <sys/time.h>
#include <dlt.h>

#include <time.h>

DLT_DECLARE_CONTEXT(dbusLog)
DLT_DECLARE_CONTEXT(dbusContext)

static char dbus_message_buffer[DBUS_MAXIMUM_MESSAGE_LENGTH];

static DBusHandlerResult
filter_func (DBusConnection *con,
             DBusMessage *message,
             void *data)
{
  char **buf;
  int len_p;
  UNUSED(con);
  UNUSED(data);

  buf = (char**)&dbus_message_buffer;
  if (!dbus_message_marshal(message,
                            buf,
                            &len_p))
  {
    fprintf (stderr, "Failed to serialize DBus message!\n");
    return DBUS_HANDLER_RESULT_HANDLED;
  }

  DLT_TRACE_NETWORK_SEGMENTED(dbusContext,DLT_NW_TRACE_IPC,0,0,len_p,(void *)*buf);

  free(*buf);
  *buf = NULL;

  if (dbus_message_is_signal (message,
                              DBUS_INTERFACE_LOCAL,
                              "Disconnected"))
  {
    DLT_UNREGISTER_CONTEXT (dbusContext);
    DLT_UNREGISTER_APP ();
    exit (0);
  }


  /* Conceptually we want this to be
   * DBUS_HANDLER_RESULT_NOT_YET_HANDLED, but this raises
   * some problems.  See bug 1719.
   */
  return DBUS_HANDLER_RESULT_HANDLED;
}

int main (int argc, char *argv[])
{
    DltDBusCliOptions options;
    DltDBusConfiguration config;

    DBusConnection *connection;
    DBusError error;
    DBusBusType type;

    int num;

    if(read_command_line(&options, argc, argv) < 0)
    {
        fprintf(stderr, "Failed to read command line!\n");
        return -1;
    }

    if(read_configuration_file(&config, options.ConfigurationFileName) < 0)
    {
        fprintf(stderr, "Failed to read configuration file!\n");
        return -1;
    }

    // register application
    if(options.ApplicationId)
        DLT_REGISTER_APP (options.ApplicationId, "DBus Logging");
    else
        DLT_REGISTER_APP (config.ApplicationId, "DBus Logging");

    // register context
    DLT_REGISTER_CONTEXT_LL_TS(dbusContext, config.DBus.ContextId, "DBus Context for Logging",DLT_LOG_INFO,DLT_TRACE_STATUS_ON);
    DLT_REGISTER_CONTEXT(dbusLog, "Log", "DBus Context for Logging Generic information");

    // initialise error handler
    dbus_error_init (&error);

    // set DBus bus type
    if(options.BusType)
        type = (DBusBusType) atoi(options.BusType);
    else
        type = (DBusBusType) atoi(config.DBus.BusType);

    // get connection
    connection = dbus_bus_get (type, &error);

    if(type==0)
        DLT_LOG(dbusLog,DLT_LOG_INFO,DLT_STRING("BusType"),DLT_STRING("Session Bus"));
    else if(type==1)
        DLT_LOG(dbusLog,DLT_LOG_INFO,DLT_STRING("BusType"),DLT_STRING("System Bus"));
    else
        DLT_LOG(dbusLog,DLT_LOG_INFO,DLT_STRING("BusType"),DLT_INT(type));

    if (NULL == connection)
    {
    fprintf (stderr, "Failed to open connection to %d: %s\n",
             DBUS_BUS_SYSTEM,
             error.message);
             dbus_error_free (&error);
             exit (1);
    }

    for(num=0;num<config.DBus.FilterCount;num++)
    {
        dbus_bus_add_match (connection,
                          config.DBus.FilterMatch[num],
                          &error);
        printf("Added FilterMatch: %s\n",config.DBus.FilterMatch[num]);
        DLT_LOG(dbusLog,DLT_LOG_INFO,DLT_STRING("FilterMatch"),DLT_UINT(num+1),DLT_STRING(config.DBus.FilterMatch[num]));
        if (dbus_error_is_set (&error))
        goto fail;
    }

    if (!dbus_connection_add_filter (connection, filter_func, NULL, NULL)) {
    fprintf (stderr, "Couldn't add filter!\n");
    exit (1);
    }

    while (dbus_connection_read_write_dispatch(connection, -1))
    ;

    DLT_UNREGISTER_CONTEXT (dbusContext);
    DLT_UNREGISTER_CONTEXT (dbusLog);
    DLT_UNREGISTER_APP ();
    exit(1);

fail:

    /* fail */
    fprintf (stderr, "Error: %s\n", error.message);
    DLT_UNREGISTER_CONTEXT (dbusContext);
    DLT_UNREGISTER_CONTEXT (dbusLog);
    DLT_UNREGISTER_APP ();
    exit(1);

}