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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
# -----------------------------------------------------------------------------
# $Id: Connect.pm 36725 2010-02-11 18:33:02Z topia $
# -----------------------------------------------------------------------------
# copyright (C) 2002 Topia <topia@clovery.jp>. all rights reserved.
package Channel::Join::Connect;
use strict;
use warnings;
use base qw(Module);
use Multicast;
use RunLoop;
sub new {
my $class = shift;
my $this = $class->SUPER::new(@_);
$this->{servers} = {}; # servername => channellist
# channellist : HASH
# shortname => チャンネルショートネーム
# key => channel key
$this->{interval} = 1; # interval (sec)
$this->{channels} = 5; # channels
$this->_init;
}
sub _init {
my $this = shift;
foreach ($this->config->channel('all')) {
s/(,)\s+/$1/g; # コンマの直後にスペースがあった場合、削除する
my ($fullname, $key) = split(/\s+/, $_, 2);
my @fullnames = split(/\,/, $fullname);
my @keys = split(/,/, $key || '');
for (my $i = 0; $i < @fullnames; $i++) {
my $ch_fullname = $fullnames[$i];
my $ch_key = $keys[$i];
$ch_key = '' unless defined($ch_key);
if (!defined($ch_fullname) || $ch_fullname eq '') {
die "Illegal definition in Channel::Join::Connect/channel : $_\n";
}
my ($ch_shortname, $server_name) = Multicast::detach($ch_fullname);
push @{$this->{servers}->{$server_name}},{
shortname => $ch_shortname,
key => $ch_key
};
}
}
## FIXME _conf_general
$this->{interval} = $this->_runloop->_conf_general->join_interval;
$this->{interval} = 1 unless defined $this->{interval};
$this->{channels} = $this->_runloop->_conf_general->join_channels_per_command;
$this->{channels} = 5 unless defined $this->{channels};
if ($this->config->interval) {
$this->{interval} = 0+$this->config->interval;
if ($this->{interval} == 0) {
die "Channel::Join::Connect: do not set interval to 0!"
}
}
$this;
}
sub connected_to_server {
my ($this,$server,$new_connection) = @_;
my ($session) = $this->{servers}->{$server->network_name};
return if !$new_connection;
if (defined($session)) {
Timer->new(
Interval => $this->{interval},
Repeat => 1,
Code => sub {
my $timer = shift;
if (@$session > 0) {
# 一度に五つずつ送り出す。
my $msg_per_trigger = $this->{channels};
my (@param_chan, @param_key);
for (my $i = 0; $i < @$session && $i < $msg_per_trigger; $i++) {
if (!defined($session->[$i]->{key}) || $session->[$i]->{key} eq '') {
push (@param_chan, $session->[$i]->{shortname});
push (@param_key, '');
} else {
unshift (@param_chan, $session->[$i]->{shortname});
unshift (@param_key, $session->[$i]->{key});
}
}
splice @$session,0,$msg_per_trigger;
$server->send_message(
$this->construct_irc_message(
Command => 'JOIN',
Params => [join(',', @param_chan), join(',', @param_key)]));
}
if (@$session == 0) {
delete $this->{sessions}->{$server->network_name};
$timer->uninstall;
}
})->install;
}
}
1;
=pod
info: サーバーに初めて接続した時、指定したチャンネルに入るモジュール。
default: off
section: important
# 書式: <チャンネル1>[,<チャンネル2>,...] [<チャンネル1のキー>,...]
# コンマの直後のスペースは無視されます。
#
# 例:
# 「#aaaaa@ircnet」に「aaaaa」というキーで入る。
-channel: #aaaaa@ircnet aaaaa
#
# 「#aaaaa@ircnet」、「#bbbbb@ircnet:*.jp」、「#ccccc@ircnet」、「#ddddd@ircnet」の4つのチャンネルに入る。
-channel: #aaaaa@ircnet,#bbbbb@ircnet:*.jp, #ccccc@ircnet
-channel: #ddddd@ircnet
# join 送出の間隔(秒)
# この設定は obsolete です。 general/join-interval を利用してください。
# 設定されていた場合は general/join-interval に優先されます。
-interval: 1
=cut
|
