/* notmuch - Not much of an email program, (just index and search)
 *
 * Copyright © 2012 Peter Wang
 *
 * 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.
 *
 * 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.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see http://www.gnu.org/licenses/ .
 *
 * Author: Peter Wang <novalazy@gmail.com>
 */

#include "notmuch-client.h"

#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>

static notmuch_bool_t
safe_gethostname (char *hostname, size_t hostname_size)
{
    if (gethostname (hostname, hostname_size) == -1) {
	strncpy (hostname, "unknown", hostname_size);
    }
    hostname[hostname_size - 1] = '\0';

    return (strchr (hostname, '/') == NULL);
}

static int
maildir_open_tmp (void *ctx, const char *dir, char **tmppath, char **newpath)
{
    pid_t pid;
    char hostname[256];
    struct timeval tv;
    char *filename;
    int fd = -1;

    /* This is the file name format used by Dovecot. */
    pid = getpid ();
    if (! safe_gethostname (hostname, sizeof (hostname))) {
	fprintf (stderr, "Error: invalid host name.\n");
	return -1;
    }
    gettimeofday (&tv, NULL);
    filename = talloc_asprintf (ctx, "%ld.M%ldP%d.%s",
				tv.tv_sec, tv.tv_usec, pid, hostname);

    *tmppath = talloc_asprintf (ctx, "%s/tmp/%s", dir, filename);

    do {
	fd = open (*tmppath, O_WRONLY | O_CREAT | O_TRUNC | O_EXCL, 0666);
    } while (fd == -1 && errno == EEXIST);

    if (fd != -1) {
	*newpath = talloc_asprintf (ctx, "%s/new/%s", dir, filename);
    }
    else {
	fprintf (stderr, "Error: opening %s: %s\n",
		 *tmppath, strerror (errno));
	talloc_free (*tmppath);
    }

    talloc_free (filename);

    return fd;
}

static notmuch_bool_t
maildir_move_to_new (const char *tmppath, const char *newpath)
{
    /* We follow the Dovecot recommendation to simply use rename()
     * instead of link() and unlink().
     */
    if (rename (tmppath, newpath) == 0) {
	return TRUE;
    }

    fprintf (stderr, "Error: rename() failed: %s\n", strerror (errno));
    return FALSE;
}

static notmuch_bool_t
copy_fd_data (int fdin, int fdout)
{
    char buf[4096];
    char *p;
    ssize_t remain;
    ssize_t written;

    for (;;) {
	remain = read (fdin, buf, sizeof(buf));
	if (remain == 0)
	    break;
	if (remain < 0) {
	    if (errno == EINTR)
		continue;
	    fprintf (stderr, "Error: reading from standard input: %s\n",
		     strerror (errno));
	    return FALSE;
	}

	p = buf;
	do {
	    written = write (fdout, p, remain);
	    if (written == 0)
		return FALSE;
	    if (written < 0) {
		if (errno == EINTR)
		    continue;
		fprintf (stderr, "Error: writing to temporary file: %s",
			 strerror (errno));
		return FALSE;
	    }
	    p += written;
	    remain -= written;
	} while (remain > 0);
    }

    return TRUE;
}

static notmuch_bool_t
save_database (notmuch_database_t *notmuch, const char *path)
{
    notmuch_message_t *message;
    notmuch_status_t status;

    status = notmuch_database_add_message (notmuch, path, &message);
    switch (status) {
    case NOTMUCH_STATUS_SUCCESS:
	break;
    case NOTMUCH_STATUS_DUPLICATE_MESSAGE_ID:
	fprintf (stderr, "Warning: duplicate message.\n");
	break;
    default:
    case NOTMUCH_STATUS_FILE_NOT_EMAIL:
    case NOTMUCH_STATUS_READ_ONLY_DATABASE:
    case NOTMUCH_STATUS_XAPIAN_EXCEPTION:
    case NOTMUCH_STATUS_OUT_OF_MEMORY:
    case NOTMUCH_STATUS_FILE_ERROR:
    case NOTMUCH_STATUS_NULL_POINTER:
    case NOTMUCH_STATUS_TAG_TOO_LONG:
    case NOTMUCH_STATUS_UNBALANCED_FREEZE_THAW:
    case NOTMUCH_STATUS_UNBALANCED_ATOMIC:
    case NOTMUCH_STATUS_LAST_STATUS:
	fprintf (stderr, "Error: failed to add `%s' to notmuch database: %s\n",
		 path, notmuch_status_to_string (status));
	return FALSE;
    }

    notmuch_message_tags_to_maildir_flags (message);

    notmuch_message_destroy (message);

    return TRUE;
}

static notmuch_bool_t
insert_message (void *ctx, notmuch_database_t *notmuch, int fdin,
		const char *dir)
{
    char *tmppath;
    char *newpath;
    int fdout;
    notmuch_bool_t ret;

    fdout = maildir_open_tmp (ctx, dir, &tmppath, &newpath);
    if (fdout < 0) {
	return FALSE;
    }

    ret = copy_fd_data (fdin, fdout);

    close (fdout);

    if (ret) {
	ret = maildir_move_to_new (tmppath, newpath);
    }

    if (!ret) {
	unlink (tmppath);
	return FALSE;
    }

    ret = save_database (notmuch, newpath);

    if (!ret) {
	/* XXX maybe there should be an option to keep the file in maildir? */
	unlink (newpath);
    }

    return ret;
}

int
notmuch_insert_command (void *ctx, int argc, char *argv[])
{
    notmuch_config_t *config;
    notmuch_database_t *notmuch;
    const char *db_path;
    char *maildir;
    notmuch_bool_t ret;

    config = notmuch_config_open (ctx, NULL, NULL);
    if (config == NULL)
	return 1;

    db_path = notmuch_config_get_database_path (config);

    maildir = talloc_asprintf (ctx, "%s", db_path);

    if (notmuch_database_open (notmuch_config_get_database_path (config),
			       NOTMUCH_DATABASE_MODE_READ_WRITE, &notmuch))
	return 1;

    ret = insert_message (ctx, notmuch, STDIN_FILENO, maildir);

    notmuch_database_destroy (notmuch);

    return (ret) ? 0 : 1;
}