/*
 * Copyright (C) 2010-2016 Canonical Ltd.
 *
 * 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 3 of the License, or (at your option) any later
 * version. See http://www.gnu.org/copyleft/gpl.html the full text of the
 * license.
 */

#include <config.h>

#include <errno.h>
#include <sys/stat.h>
#include <gio/gio.h>
#include <gio/gunixsocketaddress.h>

#include "greeter-socket.h"

enum {
    CREATE_GREETER,
    LAST_SIGNAL
};
static guint signals[LAST_SIGNAL] = { 0 };

typedef struct
{
    /* Path of socket to use */
    gchar *path;

    /* Listening UNIX socket */
    GSocket *socket;

    /* Source for listening for connections */
    GSource *source;

    /* Socket to greeter */
    GSocket *greeter_socket;

    /* Greeter connected on this socket */
    Greeter *greeter;
} GreeterSocketPrivate;

G_DEFINE_TYPE_WITH_PRIVATE (GreeterSocket, greeter_socket, G_TYPE_OBJECT)

GreeterSocket *
greeter_socket_new (const gchar *path)
{
    GreeterSocket *socket = g_object_new (GREETER_SOCKET_TYPE, NULL);
    GreeterSocketPrivate *priv = greeter_socket_get_instance_private (socket);

    priv->path = g_strdup (path);

    return socket;
}

static void
greeter_disconnected_cb (Greeter *greeter, GreeterSocket *socket)
{
    GreeterSocketPrivate *priv = greeter_socket_get_instance_private (socket);

    if (greeter == priv->greeter)
    {
        g_clear_object (&priv->greeter);
        g_clear_object (&priv->greeter_socket);
    }
}

static gboolean
greeter_connect_cb (GSocket *s, GIOCondition condition, GreeterSocket *socket)
{
    GreeterSocketPrivate *priv = greeter_socket_get_instance_private (socket);

    g_autoptr(GError) error = NULL;
    g_autoptr(GSocket) new_socket = g_socket_accept (priv->socket, NULL, &error);
    if (error)
        g_warning ("Failed to accept greeter connection: %s", error->message);
    if (!new_socket)
        return G_SOURCE_CONTINUE;

    /* Greeter already connected */
    if (priv->greeter)
    {
        g_socket_close (new_socket, NULL);
        return G_SOURCE_CONTINUE;
    }

    priv->greeter_socket = g_steal_pointer (&new_socket);
    g_signal_emit (socket, signals[CREATE_GREETER], 0, &priv->greeter);
    g_signal_connect (priv->greeter, GREETER_SIGNAL_DISCONNECTED, G_CALLBACK (greeter_disconnected_cb), socket);
    greeter_set_file_descriptors (priv->greeter, g_socket_get_fd (priv->greeter_socket), g_socket_get_fd (priv->greeter_socket));

    return G_SOURCE_CONTINUE;
}

gboolean
greeter_socket_start (GreeterSocket *socket, GError **error)
{
    GreeterSocketPrivate *priv = greeter_socket_get_instance_private (socket);

    g_return_val_if_fail (socket != NULL, FALSE);
    g_return_val_if_fail (priv->socket == NULL, FALSE);

    priv->socket = g_socket_new (G_SOCKET_FAMILY_UNIX, G_SOCKET_TYPE_STREAM, G_SOCKET_PROTOCOL_DEFAULT, error);
    if (!priv->socket)
        return FALSE;

    unlink (priv->path);
    g_autoptr(GSocketAddress) address = g_unix_socket_address_new (priv->path);
    gboolean result = g_socket_bind (priv->socket, address, FALSE, error);
    if (!result)
        return FALSE;
    if (!g_socket_listen (priv->socket, error))
        return FALSE;

    priv->source = g_socket_create_source (priv->socket, G_IO_IN, NULL);
    g_source_set_callback (priv->source, (GSourceFunc) greeter_connect_cb, socket, NULL);
    g_source_attach (priv->source, NULL);

    /* Allow to be written to */
    if (chmod (priv->path, S_IRWXU | S_IRWXG | S_IRWXO) < 0)
    {
        g_set_error (error,
                     G_FILE_ERROR,
                     g_file_error_from_errno (errno),
                     "Failed to set permissions on greeter socket %s: %s",
                     priv->path,
                     g_strerror (errno));
        return FALSE;
    }

    return TRUE;
}

static void
greeter_socket_init (GreeterSocket *socket)
{
}

static void
greeter_socket_finalize (GObject *object)
{
    GreeterSocket *self = GREETER_SOCKET (object);
    GreeterSocketPrivate *priv = greeter_socket_get_instance_private (self);

    if (priv->path)
        unlink (priv->path);
    g_clear_pointer (&priv->path, g_free);
    g_clear_object (&priv->socket);
    g_clear_object (&priv->source);
    g_clear_object (&priv->greeter_socket);
    g_clear_object (&priv->greeter);

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

static void
greeter_socket_class_init (GreeterSocketClass *klass)
{
    GObjectClass *object_class = G_OBJECT_CLASS (klass);

    object_class->finalize = greeter_socket_finalize;

    signals[CREATE_GREETER] =
        g_signal_new (GREETER_SOCKET_SIGNAL_CREATE_GREETER,
                      G_TYPE_FROM_CLASS (klass),
                      G_SIGNAL_RUN_LAST,
                      G_STRUCT_OFFSET (GreeterSocketClass, create_greeter),
                      g_signal_accumulator_first_wins,
                      NULL,
                      NULL,
                      GREETER_TYPE, 0);
}