From 3f65d48264430428a2165f6a9f5a4e16f823f6b8 Mon Sep 17 00:00:00 2001
From: Zoffix Znet <cpan@zoffix.com>
Date: Thu, 19 May 2016 19:49:39 -0400
Subject: Start new design docs

---
 lib/old-IRC/Client.pm6 | 174 +++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 174 insertions(+)
 create mode 100644 lib/old-IRC/Client.pm6

(limited to 'lib/old-IRC/Client.pm6')

diff --git a/lib/old-IRC/Client.pm6 b/lib/old-IRC/Client.pm6
new file mode 100644
index 0000000..700739c
--- /dev/null
+++ b/lib/old-IRC/Client.pm6
@@ -0,0 +1,174 @@
+use v6;
+use IRC::Parser; # parse-irc
+use IRC::Client::Plugin::PingPong;
+use IRC::Client::Plugin;
+unit class IRC::Client;
+
+has Bool:D $.debug                          = False;
+has Str:D  $.host                           = 'localhost';
+has Str    $.password;
+has Int:D  $.port where 0 <= $_ <= 65535    = 6667;
+has Str:D  $.nick                           = 'Perl6IRC';
+has Str:D  $.username                       = 'Perl6IRC';
+has Str:D  $.userhost                       = 'localhost';
+has Str:D  $.userreal                       = 'Perl6 IRC Client';
+has Str:D  @.channels                       = ['#perl6bot'];
+has IO::Socket::Async   $.sock;
+has @.plugins           = [];
+has @.plugins-essential = [
+    IRC::Client::Plugin::PingPong.new
+];
+has @!plugs             = [|@!plugins-essential, |@!plugins];
+
+method handle-event ($e) {
+    $e<pipe>    = {};
+
+    for @!plugs.grep(*.^can: 'irc-all-events') -> $p {
+        my $res = $p.irc-all-events(self, $e);
+        return unless $res === IRC_NOT_HANDLED;
+    }
+
+    # Wait for END_MOTD or ERR_NOMOTD before attempting to join
+    if $e<command> eq '422' | '376' {
+        $.ssay("JOIN {@!channels[]}\n");
+        .irc-connected: self for @!plugs.grep(*.^can: 'irc-connected');
+    }
+
+    my $nick = $!nick;
+    if (   ( $e<command> eq 'PRIVMSG' and $e<params>[0] eq $nick )
+        or ( $e<command> eq 'NOTICE'  and $e<params>[0] eq $nick )
+        or ( $e<command> eq 'PRIVMSG'
+                and $e<params>[1] ~~ /:i ^ $nick <[,:]> \s+/
+        )
+    ) {
+        my %res = :where($e<who><nick> ),
+                  :who(  $e<who><nick> ),
+                  :how(  $e<command>   ),
+                  :what( $e<params>[1] );
+
+        %res<where> = $e<params>[0] # this message was said in the channel
+            unless ( $e<command> eq 'PRIVMSG' and $e<params>[0] eq $nick )
+                or ( $e<command> eq 'NOTICE'  and $e<params>[0] eq $nick );
+
+        %res<what>.subst-mutate: /:i ^ $nick <[,:]> \s+/, ''
+            if %res<where> ~~ /^ <[#&]>/;
+
+        for @!plugs.grep(*.^can: 'irc-to-me') -> $p {
+            my $res = $p.irc-to-me(self, $e, %res);
+            return 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);
+            return 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);
+            return unless $res === IRC_NOT_HANDLED;
+        }
+    }
+
+    my $cmd = 'irc-' ~ $e<command>.lc;
+    for @!plugs.grep(*.^can: $cmd) -> $p {
+        my $res = $p."$cmd"(self, $e);
+        return unless $res === IRC_NOT_HANDLED;
+    }
+
+    for @!plugs.grep(*.^can: 'irc-unhandled') -> $p {
+        my $res = $p.irc-unhandled(self, $e);
+        return unless $res === IRC_NOT_HANDLED;
+    }
+}
+
+method notice (Str $who, Str $what) {
+    my $msg = "NOTICE $who :$what\n";
+    $!debug and "{plug-name}$msg".put;
+    $!sock.print("$msg\n");
+    self;
+}
+
+method privmsg (Str $who, Str $what) {
+    my $msg = "PRIVMSG $who :$what\n";
+    $!debug and "{plug-name}$msg".put;
+    $!sock.print("$msg\n");
+    self;
+}
+
+method respond (
+    Str:D :$how   = 'privmsg',
+    Str:D :$where is required,
+    Str:D :$what  is required is copy,
+    Str:D :$who,
+          :$when  where Any|Dateish|Instant;
+          # TODO: remove Any: https://rt.perl.org/Ticket/Display.html?id=127142
+) {
+    $what = "$who, $what" if $who and $where ~~ /^<[#&]>/;
+    my $method = $how.fc eq 'PRIVMSG'.fc ?? 'privmsg'
+        !! $how.fc eq 'NOTICE'.fc ?? 'notice'
+            !! fail 'Unknown :$how specified. Use PRIVMSG or NOTICE';
+
+    if $when {
+        Promise.at($when).then: { self."$method"($where, $what) };
+        CATCH { warn .backtrace }
+    }
+    else {
+        self."$method"($where, $what);
+    }
+    self;
+}
+
+method run {
+    .irc-start-up: self for @!plugs.grep(*.^can: 'irc-start-up');
+
+    await IO::Socket::Async.connect( $!host, $!port ).then({
+        $!sock = .result;
+        $.ssay("PASS $!password\n") if $!password.defined;
+        $.ssay("NICK $!nick\n");
+        $.ssay("USER $!username $!username $!host :$!userreal\n");
+
+        # my $left-overs = '';
+        react {
+            whenever $!sock.Supply :bin -> $buf is copy {
+                my $str = try $buf.decode: 'utf8';
+                $str or $str = $buf.decode: 'latin-1';
+                # $str ~= $left-overs;
+                $!debug and "[server {DateTime.now}] {$str}".put;
+                my $events = parse-irc $str;
+                for @$events -> $e {
+                    self.handle-event: $e;
+                    CATCH { warn .backtrace }
+                }
+            }
+
+            CATCH { warn .backtrace }
+        }
+
+        say "Closing connection";
+        $!sock.close;
+
+        # CATCH { warn .backtrace }
+    });
+}
+
+method ssay (Str:D $msg) {
+    $!debug and "{plug-name}$msg".put;
+    $!sock.print("$msg\n");
+    self;
+}
+
+#### HELPER SUBS
+
+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] ";
+}
-- 
cgit v1.1