1 files changed, 57 insertions, 11 deletions

diff --git a/lib/IRC/Client.pm6 b/lib/IRC/Client.pm6
index 55d4262..65f80e7 100644
--- a/lib/IRC/Client.pm6
+++ b/lib/IRC/Client.pm6
@@ -1,8 +1,8 @@
 use v6;
 use IRC::Parser; # parse-irc
 use IRC::Client::Plugin::PingPong;
-role IRC::Client::Plugin { ... }
-class IRC::Client:ver<1.001001> {
+use IRC::Client::Plugin;
+class IRC::Client:ver<2.001001> {
     has Bool:D $.debug                          = False;
     has Str:D  $.host                           = 'localhost';
     has Int:D  $.port where 0 <= $_ <= 65535    = 6667;
@@ -16,24 +16,59 @@ class IRC::Client:ver<1.001001> {
     has @.plugins-essential = [
         IRC::Client::Plugin::PingPong.new
     ];
+    has @!plugs             = [|@!plugins-essential, |@!plugins];
 
     method run {
+        .irc-start-up: self for @!plugs.grep(*.^can: 'irc-start-up');
+
         await IO::Socket::Async.connect( $!host, $!port ).then({
             $!sock = .result;
             $.ssay("NICK $!nick\n");
             $.ssay("USER $!username $!userhost $!host :$!userreal\n");
             $.ssay("JOIN $_\n") for @!channels;
 
-            Supply.interval( .interval ).tap({ $OUTER::_.interval(self) })
-                for @!plugins.grep(*.interval);
+            .irc-connected: self for @!plugs.grep(*.^can: 'irc-connected');
 
             react {
                 whenever $!sock.Supply -> $str is copy {
-                    $!debug and $str.say;
-                    my $messages = parse-irc $str;
-                    for @$messages -> $message {
-                        .msg(self, $message)
-                        for (@!plugins-essential, @!plugins).flat.grep(*.msg);
+                    $!debug and "[server {DateTime.now}] {$str}".put;
+                    my $events = parse-irc $str;
+                    EVENTS: for @$events -> $e {
+                        $e<pipe>    = {};
+
+                        for @!plugs.grep(*.^can: 'irc-all-events') -> $p {
+                            my $res = $p.irc-all-events(self, $e);
+                            next EVENTS unless $res === IRC_NOT_HANDLED;
+                        }
+
+                        if ( $e<command> eq 'PRIVMSG'
+                            and $e<params>[0] eq $!nick
+                        ) {
+                            for @!plugs.grep(*.^can: 'irc-privmsg-me') -> $p {
+                                my $res = $p.irc-privmsg-me(self, $e);
+                                next EVENTS unless $res === IRC_NOT_HANDLED;
+                            }
+                        }
+
+                        if ( $e<command> eq 'NOTICE'
+                            and $e<params>[0] eq $!nick
+                        ) {
+                            for @!plugs.grep(*.^can: 'irc-notice-me') -> $p {
+                                my $res = $p.irc-notice-me(self, $e);
+                                next EVENTS unless $res === IRC_NOT_HANDLED;
+                            }
+                        }
+
+                        my $cmd = 'irc-' ~ $e<command>.lc;
+                        for @!plugs.grep(*.^can: $cmd) -> $p {
+                            my $res = $p."$cmd"(self, $e);
+                            next EVENTS unless $res === IRC_NOT_HANDLED;
+                        }
+
+                        for @!plugs.grep(*.^can: 'irc-unhandled') -> $p {
+                            my $res = $p.irc-unhandled(self, $e);
+                            next EVENTS unless $res === IRC_NOT_HANDLED;
+                        }
                     }
                 }
             }
@@ -44,14 +79,25 @@ class IRC::Client:ver<1.001001> {
     }
 
     method ssay (Str:D $msg) {
+        $!debug and "{plug-name}$msg".put;
         $!sock.print("$msg\n");
         self;
     }
 
     method privmsg (Str $who, Str $what) {
         my $msg = ":$!nick!$!username\@$!userhost PRIVMSG $who :$what\n";
-        $!debug and say ".privmsg({$msg.subst("\n", "␤", :g)})";
-        self.ssay: $msg;
+        $!debug and "{plug-name}$msg".put;
+        $!sock.print("$msg\n");
         self;
     }
 }
+
+sub plug-name {
+    my $plug = callframe(3).file;
+    my $cur = $?FILE;
+    return '[core] ' if $plug eq $cur;
+    $cur ~~ s/'.pm6'$//;
+    $plug ~~ s:g/^ $cur '/' | '.pm6'$//;
+    $plug ~~ s/'/'/::/;
+    return "[$plug] ";
+}