X-Git-Url: https://ruin.nu/git/?a=blobdiff_plain;f=Bot.pm;h=0d517867f3dd39869ec9a4e542ca0afee753b0c6;hb=8d103256e7f29d892d040ec25a38b2cb56e7f942;hp=c90f8339d0d061e6009c10c5dd88ac6729ed8860;hpb=921132036eac2233472b1b315e4ee39f5ab17fbd;p=NDIRC.git diff --git a/Bot.pm b/Bot.pm index c90f833..0d51786 100644 --- a/Bot.pm +++ b/Bot.pm @@ -24,14 +24,20 @@ use feature ':5.10'; use Moose; +use POE::Component::IRC::Common qw/irc_to_utf8/; use POE::Session; +use POE::Kernel; use POE::Component::IRC::Plugin::Logger; use POE::Component::IRC::Plugin::BotTraffic; use POE::Component::IRC::Plugin::Connector; use POE::Component::IRC::Plugin::AutoJoin; use POE::Component::IRC::Plugin::NickReclaim; +use Mojo::Discord; +use Mojo::IOLoop; + use NDIRC::Dispatcher; +use NDIRC::IrcContext; use IO::File; @@ -41,6 +47,33 @@ has disp => ( lazy_build => 1 ); +has discord => ( + is => 'rw', + isa => 'Object' +); + +has discord_name => ( + is => 'rw', + isa => 'Str' +); + +has discord_id => ( + is => 'rw', + isa => 'Str' +); + +has discord_channels => ( + is => 'rw', + isa => 'HashRef', + default => sub { {} } +); + +has targets => ( + is => 'ro', + isa => 'HashRef[ArrayRef[Str]]', + default => sub{ {} }, +); + # We registered for all events, this will produce some debug info. sub _default { my ($event, $args) = @_[ARG0 .. $#_]; @@ -59,7 +92,7 @@ sub _default { } sub _start { - my ($kernel,$heap,$session) = @_[KERNEL,HEAP,SESSION]; + my ($self,$kernel,$heap,$session) = @_[OBJECT,KERNEL,HEAP,SESSION]; # retrieve our component's object from the heap where we stashed it my $irc = $heap->{irc}; @@ -79,11 +112,12 @@ sub _start { Sort_by_date => 1, Strip_color => 1, Strip_formatting => 1, + Notices => 1, )); $heap->{connector} = POE::Component::IRC::Plugin::Connector->new( - servers => ['irc.netgamers.org', 'underworld.no.eu.netgamers.org' - ,'firefly.no.eu.netgamers.org', 'underworld.ca.us.netgamers.org' ] + servers => [['irc.netgamers.org'], ['underworld.no.eu.netgamers.org'] + ,['firefly.no.eu.netgamers.org'], ['underworld.ca.us.netgamers.org'] ] ); $irc->plugin_add( 'Connector' => $heap->{connector} ); @@ -91,6 +125,29 @@ sub _start { $irc->yield( connect => { server => 'irc.netgamers.org' } ); $kernel->delay( refresh => 60 ); + + if (my $f = new IO::File 'discord'){ + my $user = <$f>; + chomp $user; + my $token = <$f>; + chomp $token; + + $self->discord(Mojo::Discord->new( + 'token' => $token, + 'name' => $user, + 'url' => 'https://nd.ruin.nu', + 'version' => '1.0', + 'callbacks' => { + 'READY' => sub { $self->discord_ready(@_) }, + 'MESSAGE_CREATE' => sub { $self->discord_message_create(@_) }, + 'GUILD_CREATE' => sub { $self->discord_guild_create(@_) }, + 'CHANNEL_CREATE' => sub { $self->discord_channel_create(@_) }, + }, + 'reconnect' => 1, + 'verbose' => 1, + )); + $self->discord->init(); + } return; } @@ -112,9 +169,66 @@ sub sig_usr1 { $kernel->yield( 'refresh' ); } +sub clear_constraint { + my $tc = shift; + + while (1) { + if (ref $tc eq 'MooseX::Meta::TypeConstraint::Structured'){ + for my $t (@{$tc->{type_constraints}}){ + clear_constraint($t); + } + + } + if (ref $tc eq 'Moose::Meta::TypeConstraint::Parameterized'){ + clear_constraint($tc->{type_parameter}); + } + last if ref $tc eq 'HASH'; + last if ref $tc eq ''; + if (defined $tc->{_type_constraint}){ + $tc = $tc->{_type_constraint}; + }elsif(defined $tc->{__type_constraint}){ + $tc = $tc->{__type_constraint}; + }else{ + last; + } + } +} + +sub clear_metains { + my $ins = shift; + + for my $a (@{$ins->{attributes}}){ + for my $m (@{$a->{associated_methods}}){ + $m->{body} = undef; + } + clear_constraint($a->{isa}); + } +} + +sub clear_cycles { + my $c = shift; + + for my $m (values %{$c->meta->{methods}}){ + clear_constraint($m->{type_constraint}); + + my $ps = $m->{parsed_signature}; + for my $p (@{$ps->{_positional_params}->{params}}){ + clear_metains($p->{__MOP__}->{_meta_instance}); + } + + $m->{body} = undef; + } + clear_metains($c->meta->{_meta_instance}); +} + + sub sig_usr2 { my $self = shift @_; + for my $c (values %{$self->disp->commands}){ + clear_cycles($c); + } + $self->disp($self->_build_disp); } @@ -128,13 +242,16 @@ sub _build_disp { $disp->load(@commands); } - my $channels = new IO::File 'channels'; + %{$self->targets} = (); + my $channels = new IO::File 'channels' or die $!;; while (<$channels>){ my ($chan, @types) = split /\s+/; say "$chan - @types"; if ($chan =~ /^(.*):(.*)$/){ $chan = $1; - $disp->set_target($2,$chan); + $self->targets->{$2} = [] unless exists $self->targets->{$2}; + push @{$self->targets->{$2}},$chan; + say "$2 - @{$self->targets->{$2}}"; } $disp->add_channel($chan,\@types); } @@ -196,16 +313,18 @@ sub irc_001 { } sub irc_invite { - my ($self,$sender, $who, $channel) = @_[OBJECT,SENDER, HEAP, ARG0 .. ARG1]; + my ($self,$sender, $who, $channel) = @_[OBJECT,SENDER, ARG0 .. ARG1]; my $irc = $sender->get_heap(); $irc->yield( join => $_ ) for grep /^$channel$/i, keys %{$self->disp->channels} } sub irc_public { + $_[ARG2] = irc_to_utf8 $_[ARG2]; } sub irc_msg { + $_[ARG2] = irc_to_utf8 $_[ARG2]; } sub refresh { @@ -214,6 +333,38 @@ sub refresh { sub irc_join { } +sub discord_ready { + my $self = shift; + my $hash = shift; + $self->discord_id($hash->{user}{id}); + $self->discord_name($hash->{user}{username}); + + say localtime(time) . " - Connected to Discord. $self->{discord_id}"; +} + +sub discord_message_create { +} + +sub discord_guild_create { + my $self = shift; + my $hash = shift; + + for my $chan (@{$hash->{channels}}) { + say localtime(time) . " - $chan->{id} - $chan->{name}"; + $self->discord_channels->{$chan->{id}} = $chan; + } +} + +sub discord_channel_create { + my $self = shift; + my $chan = shift; + + for my $key (keys %{$chan}) { + say localtime(time) . " - $key - $chan->{$key}"; + } + $self->discord_channels->{$chan->{id}} = $chan; +} + sub parseCommand { my ($self, $msg, $server, $nick, $address, $channel, $model) = @_; @@ -222,8 +373,8 @@ sub parseCommand { my ($p,$command,$args) = ($msg =~ /^([.!~])(\S+)(?: (.+))?/); - if ($msg =~ m{http://[\w.]+/.+?scan(_id|_grp)?=(\w+)}){ - if (!$command || $command =~ m{^http://}){ + if ($msg =~ m{https?://[\w.]+/.+?scan(_id|_grp)?=(\w+)}){ + if (!$command || $command =~ m{^https?://}){ ($p,$command,$args) = ('.','addscan',$msg); }elsif($command ne 'addscan'){ $self->parseCommand (".addscan $msg", $server, $nick, $address, $channel, $model) @@ -246,7 +397,7 @@ sub parseCommand { } $address =~ s/.*@(.*)/$1/; - my $c = NDIRC::Context->new({ + my $c = NDIRC::IrcContext->new({ host => $address, nick => $nick, channel => $channel, @@ -259,4 +410,24 @@ sub parseCommand { return $self->disp->run_command($c,$command,$args); } +sub toTarget { + my ($self, $target, $msg) = @_; + + return unless exists $self->targets->{$target}; + + my $session = $poe_kernel->get_active_session(); + my $heap = $session->get_heap(); + my $irc = $heap->{irc}; + + + for (@{$self->targets->{$target}}) { + when (/^#/) { + $irc->yield(privmsg => $_, $msg); + } + when (/^d-(\d+)/i) { + $self->discord->send_message($1, $msg ); + } + } +} + 1;