/* -*- Mode: C ; c-basic-offset: 2 -*- */
/*
 * LADI Session Handler (ladish)
 *
 * Copyright (C) 2011 Nedko Arnaudov <nedko@arnaudov.name>
 *
 **************************************************************************
 * The D-Bus patchbay manager
 **************************************************************************
 *
 * LADI Session Handler 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.
 *
 * LADI Session Handler 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.
 *
 * You should have received a copy of the GNU General Public License
 * along with LADI Session Handler. If not, see <http://www.gnu.org/licenses/>
 * or write to the Free Software Foundation, Inc.,
 * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
 */

#include "graph_manager.h"
#include "../dbus_constants.h"
#include "graph.h"
#include "virtualizer.h"

/**********************************************************************************/
/*                                D-Bus methods                                   */
/**********************************************************************************/

#define graph ((ladish_graph_handle)call_ptr->iface_context)

static void ladish_graph_manager_dbus_split(struct cdbus_method_call * call_ptr)
{
  uint64_t client_id;

  if (!dbus_message_get_args(
        call_ptr->message,
        &cdbus_g_dbus_error,
        DBUS_TYPE_UINT64, &client_id,
        DBUS_TYPE_INVALID))
  {
    cdbus_error(call_ptr, DBUS_ERROR_INVALID_ARGS, "Invalid arguments to method \"%s\": %s",  call_ptr->method_name, cdbus_g_dbus_error.message);
    dbus_error_free(&cdbus_g_dbus_error);
    return;
  }

  log_info("split request, graph '%s', client %"PRIu64, ladish_graph_get_description(graph), client_id);

  if (!ladish_virtualizer_split_client(graph, client_id))
  {
    cdbus_error(call_ptr, DBUS_ERROR_FAILED, "split failed");
  }
  else
  {
    cdbus_method_return_new_void(call_ptr);
  }
}

static void ladish_graph_manager_dbus_join(struct cdbus_method_call * call_ptr)
{
  uint64_t client1_id;
  uint64_t client2_id;

  if (!dbus_message_get_args(
        call_ptr->message,
        &cdbus_g_dbus_error,
        DBUS_TYPE_UINT64, &client1_id,
        DBUS_TYPE_UINT64, &client2_id,
        DBUS_TYPE_INVALID))
  {
    cdbus_error(call_ptr, DBUS_ERROR_INVALID_ARGS, "Invalid arguments to method \"%s\": %s",  call_ptr->method_name, cdbus_g_dbus_error.message);
    dbus_error_free(&cdbus_g_dbus_error);
    return;
  }

  log_info("join request, graph '%s', client1 %"PRIu64", client2 %"PRIu64, ladish_graph_get_description(graph), client1_id, client2_id);

  if (!ladish_virtualizer_join_clients(graph, client1_id, client2_id))
  {
    cdbus_error(call_ptr, DBUS_ERROR_FAILED, "join failed");
  }
  else
  {
    cdbus_method_return_new_void(call_ptr);
  }
}

static void ladish_graph_manager_dbus_rename_client(struct cdbus_method_call * call_ptr)
{
  uint64_t client_id;
  const char * newname;
  ladish_client_handle client;

  if (!dbus_message_get_args(
        call_ptr->message,
        &cdbus_g_dbus_error,
        DBUS_TYPE_UINT64, &client_id,
        DBUS_TYPE_STRING, &newname,
        DBUS_TYPE_INVALID))
  {
    cdbus_error(call_ptr, DBUS_ERROR_INVALID_ARGS, "Invalid arguments to method \"%s\": %s",  call_ptr->method_name, cdbus_g_dbus_error.message);
    dbus_error_free(&cdbus_g_dbus_error);
    return;
  }

  log_info("rename client request, graph '%s', client %"PRIu64", newname '%s'", ladish_graph_get_description(graph), client_id, newname);

  client = ladish_graph_find_client_by_id(graph, client_id);
  if (client == NULL)
  {
    cdbus_error(call_ptr, DBUS_ERROR_INVALID_ARGS, "Cannot rename unknown client");
    return;
  }

  if (!ladish_graph_rename_client(graph, client, newname))
  {
    cdbus_error(call_ptr, DBUS_ERROR_FAILED, "client rename failed");
  }
  else
  {
    cdbus_method_return_new_void(call_ptr);
  }
}

static void ladish_graph_manager_dbus_rename_port(struct cdbus_method_call * call_ptr)
{
  uint64_t port_id;
  const char * newname;
  ladish_port_handle port;

  if (!dbus_message_get_args(
        call_ptr->message,
        &cdbus_g_dbus_error,
        DBUS_TYPE_UINT64, &port_id,
        DBUS_TYPE_STRING, &newname,
        DBUS_TYPE_INVALID))
  {
    cdbus_error(call_ptr, DBUS_ERROR_INVALID_ARGS, "Invalid arguments to method \"%s\": %s",  call_ptr->method_name, cdbus_g_dbus_error.message);
    dbus_error_free(&cdbus_g_dbus_error);
    return;
  }

  log_info("rename port request, graph '%s', port %"PRIu64", newname '%s'", ladish_graph_get_description(graph), port_id, newname);

  port = ladish_graph_find_port_by_id(graph, port_id);
  if (port == NULL)
  {
    cdbus_error(call_ptr, DBUS_ERROR_INVALID_ARGS, "Cannot rename unknown port");
    return;
  }

  if (!ladish_graph_rename_port(graph, port, newname))
  {
    cdbus_error(call_ptr, DBUS_ERROR_FAILED, "port rename failed");
  }
  else
  {
    cdbus_method_return_new_void(call_ptr);
  }
}

static void ladish_graph_manager_dbus_move_port(struct cdbus_method_call * call_ptr)
{
  uint64_t port_id;
  uint64_t client_id;
  ladish_port_handle port;
  ladish_client_handle client;

  if (!dbus_message_get_args(
        call_ptr->message,
        &cdbus_g_dbus_error,
        DBUS_TYPE_UINT64, &port_id,
        DBUS_TYPE_UINT64, &client_id,
        DBUS_TYPE_INVALID))
  {
    cdbus_error(call_ptr, DBUS_ERROR_INVALID_ARGS, "Invalid arguments to method \"%s\": %s",  call_ptr->method_name, cdbus_g_dbus_error.message);
    dbus_error_free(&cdbus_g_dbus_error);
    return;
  }

  log_info("move port request, graph '%s', port %"PRIu64", client %"PRIu64, ladish_graph_get_description(graph), port_id, client_id);

  port = ladish_graph_find_port_by_id(graph, port_id);
  if (port == NULL)
  {
    cdbus_error(call_ptr, DBUS_ERROR_INVALID_ARGS, "Cannot move unknown port");
    return;
  }

  client = ladish_graph_find_client_by_id(graph, client_id);
  if (client == NULL)
  {
    cdbus_error(call_ptr, DBUS_ERROR_INVALID_ARGS, "Cannot move port to unknown client");
    return;
  }

  ladish_graph_move_port(graph, port, client);

  cdbus_method_return_new_void(call_ptr);
}

static void ladish_graph_manager_dbus_new_client(struct cdbus_method_call * call_ptr)
{
  const char * name;
  ladish_client_handle client;
  uint64_t client_id;

  if (!dbus_message_get_args(
        call_ptr->message,
        &cdbus_g_dbus_error,
        DBUS_TYPE_STRING, &name,
        DBUS_TYPE_INVALID))
  {
    cdbus_error(call_ptr, DBUS_ERROR_INVALID_ARGS, "Invalid arguments to method \"%s\": %s",  call_ptr->method_name, cdbus_g_dbus_error.message);
    dbus_error_free(&cdbus_g_dbus_error);
    return;
  }

  log_info("new client request, graph '%s', name '%s'", ladish_graph_get_description(graph), name);

  if (!ladish_client_create(NULL, &client))
  {
    cdbus_error(call_ptr, DBUS_ERROR_FAILED, "ladish_client_create() failed.");
    return;
  }

  if (!ladish_graph_add_client(graph, client, name, false))
  {
    cdbus_error(call_ptr, DBUS_ERROR_FAILED, "ladish_graph_add_client() failed to add client '%s' to virtual graph", name);
    ladish_client_destroy(client);
    return;
  }

  client_id = ladish_graph_get_client_id(graph, client);

  cdbus_method_return_new_single(call_ptr, DBUS_TYPE_UINT64, &client_id);
}

static void ladish_graph_manager_dbus_remove_client(struct cdbus_method_call * call_ptr)
{
  uint64_t client_id;
  ladish_client_handle client;

  if (!dbus_message_get_args(
        call_ptr->message,
        &cdbus_g_dbus_error,
        DBUS_TYPE_UINT64, &client_id,
        DBUS_TYPE_INVALID))
  {
    cdbus_error(call_ptr, DBUS_ERROR_INVALID_ARGS, "Invalid arguments to method \"%s\": %s",  call_ptr->method_name, cdbus_g_dbus_error.message);
    dbus_error_free(&cdbus_g_dbus_error);
    return;
  }

  log_info("remove client request, graph '%s', client %"PRIu64, ladish_graph_get_description(graph), client_id);

  client = ladish_graph_find_client_by_id(graph, client_id);
  if (client == NULL)
  {
    cdbus_error(call_ptr, DBUS_ERROR_INVALID_ARGS, "Cannot remove unknown client");
    return;
  }

  if (ladish_graph_client_has_visible_ports(graph, client))
  {
    cdbus_error(call_ptr, DBUS_ERROR_INVALID_ARGS, "Cannot remove non-empty client");
    return;
  }

  ladish_graph_remove_client(graph, client);

  cdbus_method_return_new_void(call_ptr);
}

#undef graph_ptr

CDBUS_METHOD_ARGS_BEGIN(Split, "Split client")
  CDBUS_METHOD_ARG_DESCRIBE_IN("client_id", "t", "ID of the client")
CDBUS_METHOD_ARGS_END

CDBUS_METHOD_ARGS_BEGIN(Join, "Join two clients")
  CDBUS_METHOD_ARG_DESCRIBE_IN("client1_id", "t", "ID of the first client")
  CDBUS_METHOD_ARG_DESCRIBE_IN("client2_id", "t", "ID of the second client")
CDBUS_METHOD_ARGS_END

CDBUS_METHOD_ARGS_BEGIN(RenameClient, "Rename client")
  CDBUS_METHOD_ARG_DESCRIBE_IN("client_id", "t", "ID of the client")
  CDBUS_METHOD_ARG_DESCRIBE_IN("newname", "s", "New name for the client")
CDBUS_METHOD_ARGS_END

CDBUS_METHOD_ARGS_BEGIN(RenamePort, "Rename port")
  CDBUS_METHOD_ARG_DESCRIBE_IN("port_id", "t", "ID of the port")
  CDBUS_METHOD_ARG_DESCRIBE_IN("newname", "s", "New name for the port")
CDBUS_METHOD_ARGS_END

CDBUS_METHOD_ARGS_BEGIN(MovePort, "Move port")
  CDBUS_METHOD_ARG_DESCRIBE_IN("port_id", "t", "ID of the port")
  CDBUS_METHOD_ARG_DESCRIBE_IN("client_id", "t", "ID of the client where port will be moved to")
CDBUS_METHOD_ARGS_END

CDBUS_METHOD_ARGS_BEGIN(NewClient, "New client")
  CDBUS_METHOD_ARG_DESCRIBE_IN("name", "s", "Name for the new client")
  CDBUS_METHOD_ARG_DESCRIBE_OUT("client_id", "t", "ID of the new client")
CDBUS_METHOD_ARGS_END

CDBUS_METHOD_ARGS_BEGIN(RemoveClient, "Remove empty client")
  CDBUS_METHOD_ARG_DESCRIBE_IN("client_id", "t", "ID of the client to remove")
CDBUS_METHOD_ARGS_END

CDBUS_METHODS_BEGIN
  CDBUS_METHOD_DESCRIBE(Split, ladish_graph_manager_dbus_split)
  CDBUS_METHOD_DESCRIBE(Join, ladish_graph_manager_dbus_join)
  CDBUS_METHOD_DESCRIBE(RenameClient, ladish_graph_manager_dbus_rename_client)
  CDBUS_METHOD_DESCRIBE(RenamePort, ladish_graph_manager_dbus_rename_port)
  CDBUS_METHOD_DESCRIBE(MovePort, ladish_graph_manager_dbus_move_port)
  CDBUS_METHOD_DESCRIBE(NewClient, ladish_graph_manager_dbus_new_client)
  CDBUS_METHOD_DESCRIBE(RemoveClient, ladish_graph_manager_dbus_remove_client)
CDBUS_METHODS_END

CDBUS_INTERFACE_DEFAULT_HANDLER_METHODS_ONLY(g_iface_graph_manager, IFACE_GRAPH_MANAGER)