blob: dcf0fcba6f6595b68052334c6adb1d3d3bbe313b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
use v6;
use IRC::Parser; # parse-irc
role IRC::Client::Plugin { ... }
class IRC::Client:ver<1.001001> {
has Bool:D $.debug = False;
has Str:D $.host = 'localhost';
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 IRC::Client::Plugin @.plugins = [];
has IRC::Client::Plugin @.plugins-essential = [];
method run {
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);
react {
whenever $!sock.Supply -> $str is copy {
$!debug and $str.say;
# say parse-irc($str).WHAT;
my $x = parse-irc $str;
@!plugins[0].msg(self, $x);
.msg(self, $x) for @!plugins.grep(*.msg);
}
}
say "Closing connection";
$!sock.close;
});
}
method ssay (Str:D $msg) {
$!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;
self;
}
}
|
