my $ws = AnyEvent::WebSocket::Client->new;
$ws->connect($ws_url)->cb(\&ws_cb);
$ws_disconnected->recv;
- print "Disconnected; trying to reconnect.\n\n";
+ print STDERR "Disconnected; trying to reconnect.\n\n";
};
sub ws_cb {
return;
}
- print "Connected to the Slack WebSocket.\n";
+ print STDERR "Connected to the Slack WebSocket.\n";
$connection->on(each_message => sub {
my ($conn, $message) = @_;
- print "Message: $message->{'body'}\n";
+ print STDERR "Message: $message->{'body'}\n";
my $json = JSON::XS::decode_json($message->{'body'});
eval {
if (exists($json->{'payload'}{'event'})) {
}
};
if ($@) {
- print "Error during handling: $@";
+ print STDERR "Error during handling: $@";
die;
} elsif (exists($json->{'envelope_id'})) {
my $ack = { envelope_id => $json->{'envelope_id'} };
- print "Ack: " . JSON::XS::encode_json($ack) . "\n";
+ print STDERR "Ack: " . JSON::XS::encode_json($ack) . "\n";
$conn->send(JSON::XS::encode_json($ack))
or die "Error sending ack: $!";
}
$connection->on(finish => sub {
my ($conn, $msg) = @_;
$msg //= '(none)';
- print "Finished with message: $msg\n";
+ print STDERR "Finished with message: $msg\n";
$ws_disconnected->send;
});
}
my $date = $1;
my $channel = $ev->{'channel'};
my $ts = $ev->{'message'}{'ts'};
- print "Matching message {$channel, $ts} to date $date\n";
+ print STDERR "Matching message {$channel, $ts} to date $date\n";
$dbh->do('INSERT INTO message_sheet_link (channel, ts, sheet_title) VALUES (?,?,?)', undef,
$channel, $ts, $date);
} else {