/*-
 * Copyright (c) 1998 Dag-Erling Coïdan Smørgrav
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer
 *    in this position and unchanged.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. The name of the author may not be used to endorse or promote products
 *    derived from this software without specific prior written permission
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 *	$Id: common.c,v 1.1 1998/11/05 19:48:16 des Exp $
 */

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>

#include <com_err.h>
#include <errno.h>
#include <netdb.h>
#include <string.h>
#include <unistd.h>

#include "fetch.h"
#include "common.h"


/*** Local data **************************************************************/

/*
 * Error messages for resolver errors
 */
static struct fetcherr _netdb_errlist[] = {
    { HOST_NOT_FOUND,	FETCH_RESOLV,	"Host not found" },
    { TRY_AGAIN,	FETCH_RESOLV,	"Transient resolver failure" },
    { NO_RECOVERY,	FETCH_RESOLV,	"Non-recoverable resolver failure" },
    { NO_DATA,		FETCH_RESOLV,	"No address record" },
    { -1,		FETCH_UNKNOWN,	"Unknown resolver error" }
};

static int com_err_initialized;

/*** Error-reporting functions ***********************************************/

/*
 * Initialize the common error library
 */
static void
_fetch_init_com_err(void)
{
    initialize_ftch_error_table();
    com_err_initialized = 1;
}

/*
 * Map error code to string
 */
static int
_fetch_finderr(struct fetcherr *p, int e)
{
    int i;
    for (i = 0; p[i].num != -1; i++)
	if (p[i].num == e)
	    break;
    return i;
}

/*
 * Set error code
 */
void
_fetch_seterr(struct fetcherr *p, int e)
{
    int n;
    
    if (!com_err_initialized)
	_fetch_init_com_err();

    n = _fetch_finderr(p, e);
    com_err("libfetch", p[n].cat, "(%d %s)", e, p[n].string);
}

/*
 * Set error code according to errno
 */
void
_fetch_syserr(void)
{
    int cat;
    
    if (!com_err_initialized)
	_fetch_init_com_err();

    switch (errno) {
    case 0:
	cat = FETCH_OK;
	break;
    case EPERM:
    case EACCES:
    case EROFS:
    case EAUTH:
    case ENEEDAUTH:
	cat = FETCH_AUTH;
	break;
    case ENOENT:
    case EISDIR: /* XXX */
	cat = FETCH_UNAVAIL;
	break;
    case ENOMEM:
	cat = FETCH_MEMORY;
	break;
    case EBUSY:
    case EAGAIN:	
	cat = FETCH_TEMP;
	break;
    case EEXIST:
	cat = FETCH_EXISTS;
	break;
    case ENOSPC:
	cat = FETCH_FULL;
	break;
    case EADDRINUSE:
    case EADDRNOTAVAIL:
    case ENETDOWN:
    case ENETUNREACH:
    case ENETRESET:
    case EHOSTUNREACH:
	cat = FETCH_NETWORK;
	break;
    case ECONNABORTED:
    case ECONNRESET:
	cat = FETCH_ABORT;
	break;
    case ETIMEDOUT:
	cat = FETCH_TIMEOUT;
	break;
    case ECONNREFUSED:
    case EHOSTDOWN:
	cat = FETCH_DOWN;
	break;
    default:
	cat = FETCH_UNKNOWN;
    }
    com_err("libfetch", cat, "(%02d %s)", errno, strerror(errno));
}


/*** Network-related utility functions ***************************************/

/*
 * Establish a TCP connection to the specified port on the specified host.
 */
int
fetchConnect(char *host, int port)
{
    struct sockaddr_in sin;
    struct hostent *he;
    int sd;

#ifndef NDEBUG
    fprintf(stderr, "\033[1m---> %s:%d\033[m\n", host, port);
#endif
    
    /* look up host name */
    if ((he = gethostbyname(host)) == NULL) {
	_netdb_seterr(h_errno);
	return -1;
    }

    /* set up socket address structure */
    bzero(&sin, sizeof(sin));
    bcopy(he->h_addr, (char *)&sin.sin_addr, he->h_length);
    sin.sin_family = he->h_addrtype;
    sin.sin_port = htons(port);

    /* try to connect */
    if ((sd = socket(sin.sin_family, SOCK_STREAM, IPPROTO_TCP)) == -1) {
	_fetch_syserr();
	return -1;
    }
    if (connect(sd, (struct sockaddr *)&sin, sizeof sin) == -1) {
	_fetch_syserr();
	close(sd);
	return -1;
    }

    return sd;
}