/*

  command_reply.c

  Author: Pekka Riikonen <priikone@poseidon.pspt.fi>

  Copyright (C) 1997 - 2000 Pekka Riikonen

  This program 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.
  
  This program 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.

*/
/*
 * $Id$
 * $Log$
 * Revision 1.1  2000/06/27 11:36:56  priikone
 * Initial revision
 *
 *
 */

#include "serverincludes.h"
#include "server_internal.h"
#include "command_reply.h"

/* Server command reply list. Not all commands have reply function as
   they are never sent as forwarded command packets by server. More
   maybe added later if need appears. */
SilcServerCommandReply silc_command_reply_list[] =
{
  SILC_SERVER_CMD_REPLY(join, JOIN),

  { NULL, 0 },
};

/* Process received command reply. */

void silc_server_command_reply_process(SilcServer server,
				       SilcSocketConnection sock,
				       SilcBuffer buffer)
{
  SilcServerCommandReplyContext ctx;
  SilcCommandPayload payload;

  /* Get command reply payload from packet */
  payload = silc_command_parse_payload(buffer);
  if (!payload) {
    /* Silently ignore bad reply packet */
    SILC_LOG_DEBUG(("Bad command reply packet"));
    return;
  }
  
  /* Allocate command reply context. This must be free'd by the
     command reply routine receiving it. */
  ctx = silc_calloc(1, sizeof(*ctx));
  ctx->server = server;
  ctx->sock = sock;
  ctx->payload = payload;
      
  /* Check for pending commands and mark to be exeucted */
  SILC_SERVER_COMMAND_CHECK_PENDING(ctx);
  
  /* Execute command reply */
  SILC_SERVER_COMMAND_REPLY_EXEC(ctx);
}

/* Free command reply context and its internals. */

void silc_server_command_reply_free(SilcServerCommandReplyContext cmd)
{
  if (cmd) {
    silc_command_free_payload(cmd->payload);
    silc_free(cmd);
  }
}

/* Received reply for forwarded JOIN command. Router has created or joined
   the client to the channel. We save some channel information locally
   for future use. */

SILC_SERVER_CMD_REPLY_FUNC(join)
{
  SilcServerCommandReplyContext cmd = (SilcServerCommandReplyContext)context;
  SilcServer server = cmd->server;
  SilcCommandStatus status;
  SilcChannelID *id;
  SilcChannelList *entry;
  unsigned int argc;
  unsigned char *id_string;
  char *channel_name, *tmp;

#define LCC(x) server->local_list->channel_cache[(x) - 32]
#define LCCC(x) server->local_list->channel_cache_count[(x) - 32]

  SILC_LOG_DEBUG(("Start"));

  tmp = silc_command_get_arg_type(cmd->payload, 1, NULL);
  SILC_GET16_MSB(status, tmp);
  if (status != SILC_STATUS_OK)
    goto out;

  /* Get channel name */
  tmp = silc_command_get_arg_type(cmd->payload, 2, NULL);
  if (!tmp)
    goto out;

  /* Get channel ID */
  id_string = silc_command_get_arg_type(cmd->payload, 3, NULL);
  if (!id_string)
    goto out;

  channel_name = strdup(tmp);

  /* Add the channel to our local list. */
  id = silc_id_str2id(id_string, SILC_ID_CHANNEL);
  silc_idlist_add_channel(&server->local_list->channels, channel_name, 
			  SILC_CHANNEL_MODE_NONE, id, 
			  server->id_entry->router, NULL, &entry);
  LCCC(channel_name[0]) = silc_idcache_add(&LCC(channel_name[0]), 
					   LCCC(channel_name[0]),
					   channel_name, SILC_ID_CHANNEL, 
					   (void *)id, (void *)entry);
  entry->global_users = TRUE;

  /* Execute pending JOIN command so that the client who originally
     wanted to join the channel will be joined after all. */
  SILC_SERVER_COMMAND_EXEC_PENDING(cmd, SILC_COMMAND_JOIN);

 out:
  silc_server_command_reply_free(cmd);
#undef LCC
#undef LCCC
}