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
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
package Bot::Flowdock::IRC;
use Moose;
use MooseX::NonMoose;
use List::MoreUtils 'any';
use Net::Flowdock;
use Net::Flowdock::Stream;
extends 'Bot::BasicBot';
sub FOREIGNBUILDARGS {
my $class = shift;
my (%args) = @_;
delete $args{$_} for qw(token key organization flow);
return %args;
}
has token => (
is => 'ro',
isa => 'Str',
required => 1,
);
has key => (
is => 'ro',
isa => 'Str',
);
has organization => (
is => 'ro',
isa => 'Str',
required => 1,
);
has flow => (
is => 'ro',
isa => 'Str',
required => 1,
);
has flowdock_api => (
is => 'ro',
isa => 'Net::Flowdock',
lazy => 1,
default => sub {
my $self = shift;
Net::Flowdock->new(
token => $self->token,
($self->key ? (key => $self->key) : ()),
);
}
);
has flowdock_stream => (
is => 'ro',
isa => 'Net::Flowdock::Stream',
lazy => 1,
default => sub {
my $self = shift;
Net::Flowdock::Stream->new(
token => $self->token,
flows => [join('/', $self->organization, $self->flow)],
);
},
);
has _id_map => (
traits => ['Hash'],
is => 'ro',
isa => 'HashRef[Str]',
default => sub { {} },
handles => {
name_from_id => 'get',
flowdock_names => 'values',
},
);
sub has_flowdock_name {
my $self = shift;
my ($name) = @_;
warn "checking $name";
return any { $name eq $_ } $self->flowdock_names;
}
sub connected {
my $self = shift;
my $flow = $self->flowdock_api->get_flow({
organization => $self->organization,
flow => $self->flow,
});
for my $user (@{ $flow->body->{users} }) {
$self->_id_map->{$user->{id}} = $user->{nick};
}
}
sub tick {
my $self = shift;
for (1..20) {
my $event = $self->flowdock_stream->get_next_event;
last unless $event;
next unless $event->{event} eq 'message';
# skip if this is a message that we just sent
next if exists $event->{external_user_name};
my $name = $self->name_from_id($event->{user});
$self->say(
channel => ($self->channels)[0],
body => "<$name> $event->{content}",
);
}
return 1;
}
sub said {
my $self = shift;
my ($args) = @_;
my $address = $args->{address} || '';
return if $address eq 'msg';
# XXX: Bot::BasicBot does a lot of "helpful" munging of messages that we
# receive. this is annoying for this use case. look into switching to raw
# poco::irc at some point.
my $msg = ($address ? "$address: " : '') . $args->{body};
$self->flowdock_api->push_chat({
external_user_name => $args->{who},
content => $msg,
});
return;
}
__PACKAGE__->meta->make_immutable;
no Moose;
1;
|
