File Coverage

blib/lib/App/Twirc.pm

Criterion	Covered	Total	%
statement	16	18	88.8
branch			n/a
condition			n/a
subroutine	6	6	100.0
pod			n/a
total	22	24	91.6

package App::Twirc;
$App::Twirc::VERSION = '0.20';
use Moose;
use Config::Any;
use POE qw/Loop::AnyEvent Wheel::ReadWrite/;
use AnyEvent::Twitter;
use POE::Component::Server::Twirc;
use Proc::Daemon;
use Path::Class::File;
use Log::Log4perl qw/:easy/;

with 'MooseX::Getopt',
     'MooseX::Log::Log4perl::Easy';

has configfile => (
    metaclass   => 'Getopt',
    cmd_aliases => 'c',
    isa         => 'Str',
    is          => 'ro',
    documentation => 'configration file name',
);

has background => (
    metaclass   => 'Getopt',
    cmd_aliases => 'b',
    isa         => 'Bool',
    is          => 'ro',
    documentation => 'run as daemon',
);

has authenticate => (
    metaclass   => 'Getopt',
    cmd_aliases => [qw/a auth/],
    isa         => 'Bool',
    is          => 'ro',
    default     => 0,
    documentation => 'force Twitter authentication',
);

has state_file => (
    metaclass   => 'Getopt',
    cmd_aliases => 's',
    isa         => 'Str',
    is          => 'ro',
    predicate   => 'has_state_file',
    documentation => 'state file name',
);

has debug => (
    metaclass   => 'Getopt',
    cmd_aliases => 'd',
    isa         => 'Bool',
    is          => 'ro',
    default     => 0,
    documentation => 'set logging level to DEBUG',
);

sub run {
    my $self = shift;

    my $config;
    if ( my $file = $self->configfile ) {
        $config = Config::Any->load_files({ files => [ $file ], use_ext => 1 });
        $config = $config->[0]{$file};
    }

    # override/provide config options from the commandline
    $$config{state_file} = $self->state_file if $self->has_state_file;
    $$config{log_level}  = 'DEBUG'           if $self->debug;

    Log::Log4perl->easy_init({
        layout => '%d{HH:mm:ss} [%p] %m%n',
        level  => $$config{log_level} && eval "\$$$config{log_level}" || $WARN,
    });

    # Make sure state_file is absolute before we background (which does a cd /).
    $$config{state_file} = Path::Class::File->new($config->{state_file})->absolute->stringify
        if $$config{state_file};

    my $state = $$config{state_file} && -r $$config{state_file}
              ? POE::Component::Server::Twirc::State->load($$config{state_file})
              : POE::Component::Server::Twirc::State->new;

    $self->oauth_handshake($state, $$config{sate_file}) if $self->authenticate || !$state->access_token;

    if ( $self->background ) {
        Proc::Daemon::Init;
        POE::Kernel->has_forked;
    }
    else {
        eval 'use POE qw(Component::TSTP)';
        die "$@\n" if $@;
    }

    $config->{plugins} = $self->_init_plugins($config);
    POE::Component::Server::Twirc->new(%{$config || {}}, state => $state);
    POE::Kernel->run;
}

sub oauth_handshake {
    my ( $self, $state, $state_file )  = @_;

    my %consumer = POE::Component::Server::Twirc->_twitter_auth;

    my ( $wheel, $oauth );
    POE::Session->create(
        inline_states => {
            _start => sub {
                my $cb = $_[SESSION]->postback('get_pin');
                my $w; $w = AnyEvent::Twitter->get_request_token(
                    %consumer,
                    callback_url => 'oob',
                    cb => sub { $cb->(@_); undef $w }
                );
            },
            get_pin => sub {
                my ( $url, $r, $body, $header ) = @{ $_[ARG1] };
                $oauth = $r;
                $wheel = POE::Wheel::ReadWrite->new(
                    InputHandle  => \*STDIN,
                    OutputHandle => \*STDOUT,
                    InputEvent   => 'got_pin'
                );
                print "Authorize twirc at $url\nThen, enter the PIN# provided: ";
            },
            got_pin => sub {
                undef $wheel;
                my $pin = $_[ARG0];
                my $cb = $_[SESSION]->postback('got_access_token');
                my $w; $w = AnyEvent::Twitter->get_access_token(
                    %consumer,
                    oauth_token        => $$oauth{oauth_token},
                    oauth_token_secret => $$oauth{oauth_token_secret},
                    oauth_verifier     => $pin,
                    cb => sub { $cb->(@_); undef $w }
                );
            },
            got_access_token => sub {
                my ( $r, $body, $header ) = @{ $_[ARG1] };
                $state->access_token($$r{oauth_token});
                $state->access_token_secret($$r{oauth_token_secret});
                $state->store($state_file) if $state_file;
            },
        },
    );

    POE::Kernel->run;
}

sub _init_plugins {
    my ($self, $config) = @_;

    my $plugins = delete $config->{plugins};

    my @plugins;
    for my $plugin ( @$plugins ) {
        my ($class, $options) = ref $plugin ? %$plugin : ($plugin, {});
        $class = "App::Twirc::Plugin::$class" unless $class =~ s/^\+//;

        eval "use $class";
        die $@ if $@;

        push @plugins, $class->new($options);
    }
    return \@plugins;
}

no Moose;

__PACKAGE__->meta->make_immutable;

1;

__END__

=head1 NAME

App::Twirc - IRC is my twitter client

=head1 SYNOPSIS

    use App::Twirc;

    my $app = App::Twirc->new_with_options();
    $app->run;

=head1 DESCRIPTION

C<App::Twirc> is an IRC server making the IRC client of your choice your twitter client.  The C<twirc>
program in this distribution launches the application.

See L<App::Twirc::Manual> for more details.

=head1 OPTIONS

=over 4

=item configfile

Required.  The name of the configuration file containing options for L<POE::Component::Server::Twirc>.

=item background

Boolean value to determine whether to run in the foreground (0), or background (1).

=item authenticate

Forces OAuth authentication with Twitter, supplying a URL for Twitter OAuth
authentication and prompting for the OAuth verifier PIN. Use this method
re-authenticate with Twitter, if necessary.

=item state_file

Specifies a file name for loading/storing state information, including a list
of friends, followers_ids, and OAuth access tokens.

=item debug

Boolean, when set to 1, enables DEBUG level logging.

=back

=head1 METHODS

=over 4

=item run

Run the application.

=back

=head1 AUTHOR

Marc Mims <[e-mail]>

=head1 LICENSE

Copyright (c) 2008 Marc Mims

You may distribute this code and/or modify it under the same terms as Perl itself.