/* -*- mode: C; c-file-style: "gnu"; indent-tabs-mode: nil; -*- */
/*
 * Copyright © 2012 – 2017 Red Hat, Inc.
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2 of the License, or (at your option) any later version.
 *
 * This library 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
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General
 * Public License along with this library; if not, see <http://www.gnu.org/licenses/>.
 */

#include "config.h"

#include "goakerberosidentityinquiry.h"
#include "goaidentityinquiryprivate.h"

#include <string.h>
#include <glib/gi18n.h>
#include <gio/gio.h>

struct _GoaKerberosIdentityInquiryPrivate
{
  GoaIdentity *identity;
  char *name;
  char *banner;
  GList *queries;
  int number_of_queries;
  int number_of_unanswered_queries;
  gboolean is_failed;
};

typedef struct
{
  GoaIdentityInquiry *inquiry;
  krb5_prompt *kerberos_prompt;
  gboolean is_answered;
} GoaKerberosIdentityQuery;

static void identity_inquiry_interface_init (GoaIdentityInquiryInterface *
                                             interface);
static void initable_interface_init (GInitableIface *interface);

G_DEFINE_TYPE_WITH_CODE (GoaKerberosIdentityInquiry,
                         goa_kerberos_identity_inquiry,
                         G_TYPE_OBJECT,
                         G_IMPLEMENT_INTERFACE (G_TYPE_INITABLE,
                                                initable_interface_init)
                         G_IMPLEMENT_INTERFACE (GOA_TYPE_IDENTITY_INQUIRY,
                                                identity_inquiry_interface_init));

static gboolean
goa_kerberos_identity_inquiry_initable_init (GInitable * initable,
                                             GCancellable *cancellable,
                                             GError ** error)
{
  if (g_cancellable_set_error_if_cancelled (cancellable, error))
    {
      return FALSE;
    }

  return TRUE;
}

static void
initable_interface_init (GInitableIface *interface)
{
  interface->init = goa_kerberos_identity_inquiry_initable_init;
}

static GoaKerberosIdentityQuery *
goa_kerberos_identity_query_new (GoaIdentityInquiry * inquiry,
                                 krb5_prompt * kerberos_prompt)
{
  GoaKerberosIdentityQuery *query;

  query = g_slice_new (GoaKerberosIdentityQuery);
  query->inquiry = inquiry;
  query->kerberos_prompt = kerberos_prompt;
  query->is_answered = FALSE;

  return query;
}

static void
goa_kerberos_identity_query_free (GoaKerberosIdentityQuery *query)
{
  g_slice_free (GoaKerberosIdentityQuery, query);
}

static void
goa_kerberos_identity_inquiry_dispose (GObject *object)
{
  GoaKerberosIdentityInquiry *self = GOA_KERBEROS_IDENTITY_INQUIRY (object);

  g_clear_object (&self->priv->identity);
  g_clear_pointer (&self->priv->name, (GDestroyNotify) g_free);
  g_clear_pointer (&self->priv->banner, (GDestroyNotify) g_free);

  G_OBJECT_CLASS (goa_kerberos_identity_inquiry_parent_class)->dispose (object);
}

static void
goa_kerberos_identity_inquiry_finalize (GObject *object)
{
  GoaKerberosIdentityInquiry *self = GOA_KERBEROS_IDENTITY_INQUIRY (object);

  g_list_free_full (self->priv->queries, (GDestroyNotify) goa_kerberos_identity_query_free);

  G_OBJECT_CLASS (goa_kerberos_identity_inquiry_parent_class)->finalize (object);
}

static void
goa_kerberos_identity_inquiry_class_init (GoaKerberosIdentityInquiryClass *klass)
{
  GObjectClass *object_class;

  object_class = G_OBJECT_CLASS (klass);

  object_class->dispose = goa_kerberos_identity_inquiry_dispose;
  object_class->finalize = goa_kerberos_identity_inquiry_finalize;

  g_type_class_add_private (klass, sizeof (GoaKerberosIdentityInquiryPrivate));
}

static void
goa_kerberos_identity_inquiry_init (GoaKerberosIdentityInquiry *self)
{
  self->priv = G_TYPE_INSTANCE_GET_PRIVATE (self,
                                            GOA_TYPE_KERBEROS_IDENTITY_INQUIRY,
                                            GoaKerberosIdentityInquiryPrivate);
}

GoaIdentityInquiry *
goa_kerberos_identity_inquiry_new (GoaKerberosIdentity * identity,
                                   const char *name,
                                   const char *banner,
                                   krb5_prompt prompts[], int number_of_prompts)
{
  GObject *object;
  GoaIdentityInquiry *inquiry;
  GoaKerberosIdentityInquiry *self;
  GError *error;
  int i;

  g_return_val_if_fail (GOA_IS_KERBEROS_IDENTITY (identity), NULL);
  g_return_val_if_fail (number_of_prompts > 0, NULL);

  object = g_object_new (GOA_TYPE_KERBEROS_IDENTITY_INQUIRY, NULL);

  inquiry = GOA_IDENTITY_INQUIRY (object);
  self = GOA_KERBEROS_IDENTITY_INQUIRY (object);

  /* FIXME: make these construct properties */
  self->priv->identity = g_object_ref (identity);
  self->priv->name = g_strdup (name);
  self->priv->banner = g_strdup (banner);

  self->priv->number_of_queries = 0;
  for (i = 0; i < number_of_prompts; i++)
    {
      GoaKerberosIdentityQuery *query;

      query = goa_kerberos_identity_query_new (inquiry, &prompts[i]);

      self->priv->queries = g_list_prepend (self->priv->queries, query);
      self->priv->number_of_queries++;
    }
  self->priv->queries = g_list_reverse (self->priv->queries);

  self->priv->number_of_unanswered_queries = self->priv->number_of_queries;

  error = NULL;
  if (!g_initable_init (G_INITABLE (self), NULL, &error))
    {
      g_debug ("%s", error->message);
      g_error_free (error);
      g_object_unref (self);
      return NULL;
    }

  return inquiry;
}

static GoaIdentity *
goa_kerberos_identity_inquiry_get_identity (GoaIdentityInquiry *inquiry)
{
  GoaKerberosIdentityInquiry *self;

  g_return_val_if_fail (GOA_IS_KERBEROS_IDENTITY_INQUIRY (inquiry), NULL);

  self = GOA_KERBEROS_IDENTITY_INQUIRY (inquiry);

  return self->priv->identity;
}

static char *
goa_kerberos_identity_inquiry_get_name (GoaIdentityInquiry *inquiry)
{
  GoaKerberosIdentityInquiry *self;

  g_return_val_if_fail (GOA_IS_KERBEROS_IDENTITY_INQUIRY (inquiry), NULL);

  self = GOA_KERBEROS_IDENTITY_INQUIRY (inquiry);

  return g_strdup (self->priv->name);
}

static char *
goa_kerberos_identity_inquiry_get_banner (GoaIdentityInquiry *inquiry)
{
  GoaKerberosIdentityInquiry *self;

  g_return_val_if_fail (GOA_IS_KERBEROS_IDENTITY_INQUIRY (inquiry), NULL);

  self = GOA_KERBEROS_IDENTITY_INQUIRY (inquiry);

  return g_strdup (self->priv->banner);
}

static gboolean
goa_kerberos_identity_inquiry_is_complete (GoaIdentityInquiry *inquiry)
{
  GoaKerberosIdentityInquiry *self;

  g_return_val_if_fail (GOA_IS_KERBEROS_IDENTITY_INQUIRY (inquiry), FALSE);

  self = GOA_KERBEROS_IDENTITY_INQUIRY (inquiry);

  return self->priv->number_of_unanswered_queries == 0 || self->priv->is_failed;
}

static gboolean
goa_kerberos_identity_inquiry_is_failed (GoaIdentityInquiry *inquiry)
{
  GoaKerberosIdentityInquiry *self;

  g_return_val_if_fail (GOA_IS_KERBEROS_IDENTITY_INQUIRY (inquiry), FALSE);

  self = GOA_KERBEROS_IDENTITY_INQUIRY (inquiry);

  return self->priv->is_failed;
}

static void
goa_kerberos_identity_inquiry_mark_query_answered (GoaKerberosIdentityInquiry * self,
                                                   GoaKerberosIdentityQuery * query)
{
  if (query->is_answered)
    {
      return;
    }

  query->is_answered = TRUE;
  self->priv->number_of_unanswered_queries--;

  if (self->priv->number_of_unanswered_queries == 0)
    {
      _goa_identity_inquiry_emit_complete (GOA_IDENTITY_INQUIRY (self));
    }
}

static void
goa_kerberos_identity_inquiry_fail (GoaKerberosIdentityInquiry *self)
{
  self->priv->is_failed = TRUE;
  _goa_identity_inquiry_emit_complete (GOA_IDENTITY_INQUIRY (self));
}

static void
goa_kerberos_identity_inquiry_answer_query (GoaIdentityInquiry * inquiry,
                                            GoaIdentityQuery *query,
                                            const char *answer)
{
  GoaKerberosIdentityInquiry *self;
  GoaKerberosIdentityQuery *kerberos_query = (GoaKerberosIdentityQuery *) query;
  size_t answer_length;

  g_return_if_fail (GOA_IS_KERBEROS_IDENTITY_INQUIRY (inquiry));
  g_return_if_fail (inquiry == kerberos_query->inquiry);
  g_return_if_fail (!goa_kerberos_identity_inquiry_is_complete (inquiry));

  self = GOA_KERBEROS_IDENTITY_INQUIRY (inquiry);

  answer_length = strlen (answer);

  if (kerberos_query->kerberos_prompt->reply->length < answer_length)
    {
      goa_kerberos_identity_inquiry_fail (self);
    }
  else
    {
      strncpy (kerberos_query->kerberos_prompt->reply->data,
               answer, kerberos_query->kerberos_prompt->reply->length);
      kerberos_query->kerberos_prompt->reply->length = (unsigned int) answer_length;

      goa_kerberos_identity_inquiry_mark_query_answered (self, kerberos_query);
    }
}

static void
goa_kerberos_identity_inquiry_iter_init (GoaIdentityInquiryIter * iter,
                                         GoaIdentityInquiry * inquiry)
{
  GoaKerberosIdentityInquiry *self = GOA_KERBEROS_IDENTITY_INQUIRY (inquiry);

  iter->data = self->priv->queries;
}

static GoaIdentityQuery *
goa_kerberos_identity_inquiry_iter_next (GoaIdentityInquiryIter * iter,
                                         GoaIdentityInquiry * inquiry)
{
  GoaIdentityQuery *query;
  GList *node;

  node = iter->data;

  if (node == NULL)
    {
      return NULL;
    }

  query = (GoaIdentityQuery *) node->data;

  node = node->next;

  iter->data = node;

  return query;
}

static GoaIdentityQueryMode
goa_kerberos_identity_query_get_mode (GoaIdentityInquiry * inquiry,
                                      GoaIdentityQuery * query)
{
  GoaKerberosIdentityQuery *kerberos_query = (GoaKerberosIdentityQuery *) query;

  g_return_val_if_fail (GOA_IS_KERBEROS_IDENTITY_INQUIRY (inquiry),
                        GOA_KERBEROS_IDENTITY_QUERY_MODE_INVISIBLE);
  g_return_val_if_fail (inquiry == kerberos_query->inquiry,
                        GOA_KERBEROS_IDENTITY_QUERY_MODE_INVISIBLE);

  if (kerberos_query->kerberos_prompt->hidden)
    {
      return GOA_KERBEROS_IDENTITY_QUERY_MODE_INVISIBLE;
    }
  else
    {
      return GOA_KERBEROS_IDENTITY_QUERY_MODE_VISIBLE;
    }
}

static char *
goa_kerberos_identity_query_get_prompt (GoaIdentityInquiry * inquiry,
                                        GoaIdentityQuery * query)
{
  GoaKerberosIdentityQuery *kerberos_query = (GoaKerberosIdentityQuery *) query;

  g_return_val_if_fail (GOA_IS_KERBEROS_IDENTITY_INQUIRY (inquiry),
                        GOA_KERBEROS_IDENTITY_QUERY_MODE_INVISIBLE);
  g_return_val_if_fail (inquiry == kerberos_query->inquiry, NULL);

  return g_strdup (kerberos_query->kerberos_prompt->prompt);
}

static gboolean
goa_kerberos_identity_query_is_answered (GoaIdentityInquiry * inquiry,
                                         GoaIdentityQuery * query)
{
  GoaKerberosIdentityQuery *kerberos_query = (GoaKerberosIdentityQuery *) query;

  g_return_val_if_fail (GOA_IS_KERBEROS_IDENTITY_INQUIRY (inquiry),
                        GOA_KERBEROS_IDENTITY_QUERY_MODE_INVISIBLE);
  g_return_val_if_fail (inquiry == kerberos_query->inquiry, FALSE);

  return kerberos_query->is_answered;
}

static void
identity_inquiry_interface_init (GoaIdentityInquiryInterface *interface)
{
  interface->get_identity = goa_kerberos_identity_inquiry_get_identity;
  interface->get_name = goa_kerberos_identity_inquiry_get_name;
  interface->get_banner = goa_kerberos_identity_inquiry_get_banner;
  interface->is_complete = goa_kerberos_identity_inquiry_is_complete;
  interface->is_failed = goa_kerberos_identity_inquiry_is_failed;
  interface->answer_query = goa_kerberos_identity_inquiry_answer_query;
  interface->iter_init = goa_kerberos_identity_inquiry_iter_init;
  interface->iter_next = goa_kerberos_identity_inquiry_iter_next;
  interface->get_mode = goa_kerberos_identity_query_get_mode;
  interface->get_prompt = goa_kerberos_identity_query_get_prompt;
  interface->is_answered = goa_kerberos_identity_query_is_answered;
}