File Coverage

blib/lib/Tanker.pm

Criterion	Covered	Total	%
statement	32	42	76.1
branch	0	2	0.0
condition	2	5	40.0
subroutine	9	11	81.8
pod	0	5	0.0
total	43	65	66.1

package Tanker;

use strict;
use warnings;
use vars qw($VERSION);
use Data::Dumper;

$VERSION = 0.021;


sub new  ($$)
{
	# standard stuff for creating a new object
	# I'm not sure if this *should* be an object
	# but I think it'll probably be useful in the end
	my $proto  = shift;
        my $class  = ref($proto) || $proto;

	# yes, we must have a config file
	my $config = shift || die "You must pass a config file to $class\n";

	# bless our self into a hash
        my $self  = {};
        bless ($self, $class);

	# load that with the config
	$self->{config_file} = $config;
	$self->parse_config();

	# and give it on back
        return $self;
}

# read the config file somehow and load all the plugins
# RequestHandlers and ResponseHandlers and stick them global
# thinking about it, this shouldn't be in the module but we'll
# fix that it a bit
sub parse_config ($)
{
	my $self = shift;

	## todo make this proper
	use Tanker::Plugin::Log;

	my $logger = new Tanker::Plugin::Log ($self);
	$self->add_plugin($logger);

	use Tanker::RequestGenerator::IRC;
	my $irc    = new Tanker::RequestGenerator::IRC ($self);
	$irc->run();

}

sub add_plugin ($$)
{
	my ($self, $plugin) = @_;

	# so that the plugin will be able to get hold
	# of us if it needs to

	push @{$self->{plugins}}, $plugin;

}


# this gets called by the Request Generator
# it forks and sends off the request
sub inject ($$)
{
	my ($self, $request) = @_;


	# send the request down the pipeline asynchronously
	# this should be handled more defensively
	unless (fork())
	{

		$self->inject_aux($request);
		exit;
	}

}

sub inject_aux ($$)
{
	my ($self, $request) = @_;

	foreach my $plugin (@{$self->{plugins}})
	{

		$plugin->handle($request);
	}

}




1;
__END__