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
|
#!/usr/bin/env perl
#
# Author: Guillermo Ramos <gramos@gramos.me> (2019)
#
# Run `tgserver -h` for quick help, or `tgserver -h -v` for full manual.
################################################################################
$main::VERSION = "0.1.1";
use Getopt::Long qw(:config auto_version);
use Pod::Usage qw<pod2usage>;
use Data::Dumper;
use FindBin;
use lib "$FindBin::Bin/lib";
use TgLib qw<fetch_token>;
require TgLib::Api;
require TgLib::Cache;
require TgLib::Logger;
my $TOKEN;
my $VERBOSE = 0;
my $HELP;
GetOptions("token=s" => \$TOKEN,
"verbose+" => \$VERBOSE,
"help" => \$HELP);
pod2usage(-verbose => $VERBOSE+1) if $HELP or not @ARGV;
my $logger = TgLib::Logger->new($VERBOSE);
# If token was not specified in CLI, get it from ENV/file
$TOKEN ||= fetch_token() or
pod2usage(-message => "ERROR: Unable to get bot token ($!).\n",
-verbose => 99, -sections => "AUTHENTICATION");
my $cache = TgLib::Cache->new($logger);
my $api = TgLib::Api->new($TOKEN, $logger);
while (1) {
# FIXME magic timeout
foreach my $update (@{$api->get_updates(3600, $cache->offset)}) {
# Cache current offset
$cache->offset($update->{'update_id'}+1);
$logger->debug(sprintf "Update %s", Dumper($update));
my $text = $update->{'message'}{'text'};
my $chat_id = $update->{'message'}{'chat'}{'id'};
$logger->info("Received from chat $chat_id: '$text'\n");
use IPC::Open2 qw<open2>;
my $pid = open2(my $progr, my $progw, "@ARGV");
print $progw $text;
close($progw);
my $response = join "", <$progr>;
chomp $response;
$logger->debug("'$text' -> @ARGV -> '$response'\n");
close($progr);
if ($response) {
my $api = TgLib::Api->new($TOKEN, $logger);
$api->send_message($chat_id, $text, $response);
} else {
$logger->warn("Empty response, skipping\n");
}
}
}
__END__
=head1 NAME
tgserver - Interact with a Telegram Bot
=head1 SYNOPSIS
tgserver [-h | --help] [-v]
tgserver [options] -- B<prog>
=head1 OPTIONS
--token | -t Bot token (see AUTHENTICATION)
--version Show version
--verbose | -v Show more information (combine with -h to see full manual)
--help | -h Show this message
=head1 DESCRIPTION
This program waits for Telegram updates from the bot specified by the token. For
every update it runs B<prog> with stdin piped to the update, and sending stdout
back as response.
=head1 AUTHENTICATION
To get the bot token, this program will check (in order):
- The "--token" CLI argument
- The "TGUTILS_TOKEN" environment variable
- The contents of "$XDG_CONFIG_HOME/tgutils_token"
(usually ~/.config/tgutils_token)
=cut
|
