/**************************************************************************
 * LPRng IFHP Filter
 * Copyright 1994-1999 Patrick Powell, San Diego, CA <papowell@astart.com>
 **************************************************************************/
/**** HEADER *****/
static char *const _id = "$Id: open_device.c,v 1.1.1.2 1999/05/21 22:20:21 danw Exp $";

#include "ifhp.h"

extern int plp_usleep( int i );

void Do_stty();

void Open_device( char *device )
{
	char *s, *end;
	int fd = -1, port, option, attempt;
	struct hostent *hostent;
	struct sockaddr_in sin;
	int src_port = 0;
	char *dcopy = 0;

	DEBUG1("Open_device: device '%s'", device);

	Errorcode = 0;
	if( (device[0] == '/') ){
		attempt = 1;
		while( fd < 0 ){
			DEBUG1("Open_device: device '%s', attempt %d",
				device, attempt);
			fd = open( device, (Read_write?O_RDWR:O_WRONLY)|O_APPEND|O_CREAT, 0600 );
			if( fd < 0 ){
				if( Dev_retries == 0 || (Dev_retries >0 && attempt++ >= Dev_retries) ){
					Errorcode = JABORT;
					logerr_die("Open_device: open '%s' failed", device);
				}
				if( Dev_sleep > 0 ) plp_usleep(Dev_sleep*1000);
			}
		}
		if( isatty( fd ) && Stty_args){
			Do_stty( fd, Stty_args );
		}
	} else {
		dcopy = safestrdup( device,__FILE__,__LINE__ );
		if( (end = strchr( dcopy, '%' )) == 0 ){
			Errorcode = JABORT;
			fatal("Open_device: missing port number '%s'",device );
		}
		*end++ = 0; 
		s = end;
		port = strtol( end, &s, 0 );
		if( port <= 0 ){
			Errorcode = JABORT;
			fatal("Open_device: bad port number '%s'",end );
		}
		end = s;
		if( end && *end ){
			*end++ = 0;
			src_port = strtol( end, 0, 0 );
		}
		attempt = 1;
		fd = -1;
		hostent = gethostbyname(dcopy);
		if( hostent && hostent->h_addrtype != AF_INET ){
			Errorcode = JABORT;
			fatal("Open_device: bad address type for host '%s'", device);
			cleanup(0);
		}
		for( fd = -1; fd < 0; ++attempt ){
			memset( &sin, 0, sizeof(sin) );
			sin.sin_family = AF_INET;
				/*
				 * set up the address information
				 */
			if( hostent ){
				memcpy( &sin.sin_addr, hostent->h_addr, hostent->h_length );
			} else {
				sin.sin_addr.s_addr = inet_addr(dcopy);
				if( sin.sin_addr.s_addr == -1){
					Errorcode = JABORT;
					fatal("Open_device: getconnection: unknown host '%s'", device);
					cleanup(0);
				}
			}
			sin.sin_port = htons( port );
			if( attempt > 1 ){
				if( Dev_retries > 0 && attempt >= Dev_retries ){
					Errorcode = JABORT;
					logerr_die("Open_device: open '%s' failed", device);
				}
				if( Dev_sleep > 0 ) plp_usleep(Dev_sleep*1000);
			}
			DEBUG1("Open_device: destination '%s' port %d, attempt %d",
				inet_ntoa( sin.sin_addr ), ntohs( sin.sin_port ), attempt );
			fd = socket (AF_INET, SOCK_STREAM, 0);
			if( fd < 0 ){
				Errorcode = JABORT;
				logerr_die( "Open_device: socket() failed" ); 
			}
			option = 1;
			if( setsockopt( fd, SOL_SOCKET, SO_REUSEADDR,
					(char *)&option, sizeof(option) ) ){
				Errorcode = JABORT;
				logerr_die( "Open_device: setsockopt failed" );
			}
			if( src_port ){
				struct sockaddr_in src_sin;
				memset( &src_sin, 0, sizeof(src_sin) );
				src_sin.sin_family = AF_INET;
				src_sin.sin_port = htons( src_port );
				if( bind( fd, (struct sockaddr *)&src_sin,
					sizeof( src_sin )) < 0 ){
					logerr("Open_device: bind failed");
					close(fd);
					fd = -1;
					++src_port;
					continue;
				}
			}
			if( connect(fd, (struct sockaddr *) & sin, sizeof (sin)) < 0 ){
				Errorcode = JFAIL;
				logerr("Open_device: connect to '%s port %d' failed",
					inet_ntoa( sin.sin_addr ), ntohs( sin.sin_port ) );
				close(fd);
				fd = -1;
				continue;
			}
		}
	}
	if( fd != 1 ){
		if( dup2( fd, 1 ) < 0 ){
			Errorcode = JABORT;
			logerr_die("Open_device: open '%s' failed",device);
		}
		close( fd );
	}
	if( dcopy ) free(dcopy); dcopy = 0;
	DEBUG1("Open_device: success");
}

void Open_monitor( char *device )
{
	char *s, *end;
	int port;
	struct hostent *hostent;
	struct sockaddr_in sin;
	int src_port = 0;
	char *dcopy = 0;

	DEBUG1("Open_monitor: device '%s'", device);

	Errorcode = 0;
	if( (device[0] != '/') ){
		dcopy = safestrdup( device,__FILE__,__LINE__ );
		if( (end = strchr( dcopy, '%' )) == 0 ){
			Errorcode = JABORT;
			fatal("Open_monitor: missing port number '%s'",device );
		}
		*end++ = 0; 
		s = end;
		port = strtol( end, &s, 0 );
		if( port <= 0 ){
			Errorcode = JABORT;
			fatal("Open_monitor: bad port number '%s'",end );
		}
		++port;
		end = s;
		if( end && *end ){
			*end++ = 0;
			src_port = strtol( end, 0, 0 );
		}
		memset( &sin, 0, sizeof(sin) );
		sin.sin_family = AF_INET;
		if( (hostent = gethostbyname(dcopy)) ){
			/*
			 * set up the address information
			 */
			if( hostent->h_addrtype != AF_INET ){
				Errorcode = JABORT;
				fatal("Open_monitor: bad address type for host '%s'", device);
				cleanup(0);
			}
			memcpy( &sin.sin_addr, hostent->h_addr, hostent->h_length );
		} else {
			sin.sin_addr.s_addr = inet_addr(dcopy);
			if( sin.sin_addr.s_addr == -1){
				Errorcode = JABORT;
				fatal("Open_monitor: getconnection: unknown host '%s'", device);
				cleanup(0);
			}
		}
		sin.sin_port = htons( port );
		Monitor_fd = -1;
		logmsg("appsocket destination '%s' port %d",
			inet_ntoa( sin.sin_addr ), ntohs( sin.sin_port ) );
		Monitor_fd = socket (AF_INET, SOCK_DGRAM, 0);
		if( Monitor_fd < 0 ){
			Errorcode = JABORT;
			logerr_die( "Open_monitor: socket() failed" ); 
		}
		if( src_port ){
			struct sockaddr_in src_sin;
			memset( &src_sin, 0, sizeof(src_sin) );
			src_sin.sin_family = AF_INET;
			src_sin.sin_port = htons( src_port );
			if( bind( Monitor_fd, (struct sockaddr *)&src_sin,
				sizeof( src_sin )) < 0 ){
				Errorcode = JABORT;
				logerr_die("Open_monitor: bind failed");
			}
		}
		if( connect (Monitor_fd, (struct sockaddr *) & sin, sizeof (sin)) < 0 ){
			Errorcode = JFAIL;
			logerr_die("Open_monitor: connect to '%s port %d' failed",
				inet_ntoa( sin.sin_addr ), ntohs( sin.sin_port ) );
		}
		if( dcopy ) free(dcopy); dcopy = 0;
	}
	DEBUG1("Open_monitor: port %d", Monitor_fd );
}