File Coverage

blib/lib/Mail/POPRelay/Daemon.pm

Criterion	Covered	Total	%
statement	15	46	32.6
branch	0	18	0.0
condition			n/a
subroutine	5	11	45.4
pod	0	1	0.0
total	20	76	26.3

package Mail::POPRelay::Daemon;

use strict;
use Mail::POPRelay;
use File::Tail;
use vars qw[@ISA $VERSION ];
use POSIX qw[setsid ];

@ISA     = qw[Mail::POPRelay ];
$VERSION = '0.1.1';


# trap signals
# ---------
sub __setupSignals {
	my $self = shift;

	$SIG{'TERM'} = sub { $self->wipeRelayDirectory(); $self->generateRelayFile(); };
	$SIG{'KILL'} = sub { $self->wipeRelayDirectory(); $self->generateRelayFile(); };
	$SIG{'HUP'}  = sub {
				$self->initWithConfigFile($self->{'configFile'});
				$self->cleanRelayDirectory();
				$self->generateRelayFile();
	};
}


# daemonize
# ---------
sub init {
	my $self = Mail::POPRelay::initWithConfigFile(@_);

	defined(my $pid = fork()) or die "Unable to fork: $!";
	if ($pid) {
		# parent
		return $pid;
	} else {
		# sibling
		#chdir('/')              or die "Can't chdir to /: $!";
		setsid()                or die "Can't start new session: $!";
		open STDERR, '>&STDOUT' or die "Can't dup stdout: $!";

		$self->__setupSignals();
		$self->__mainLoop();

		return $self;
	}
}


# ---------
sub __mainLoop {
	my $self = shift;

	my $fileTail = File::Tail->new (
		name        => $self->{'mailLogFile'},
		interval    => 2,
		maxinterval => 3,
		adjustafter => 3,
	) or die "Unable to tail $self->{'mailLogFile'}: $!";

	my($line, $flag);
	while (defined($line = $fileTail->read())) {
		if ($line =~ m|$self->{'mailLogRegExp'}|) {
			# save processing cycles and exit early if possible
			$flag = 0;
			$flag = 1 if $self->addRelayAddress($1, $2);
			$flag = 1 if $self->cleanRelayDirectory();
			$self->generateRelayFile() if $flag;

		}
	}
	$self->wipeRelayDirectory();
	$self->generateRelayFile();
}


1337;

__END__