[app-fonbot-daemon.git] / lib / App / FonBot / Plugin / Common.pm

package App::FonBot::Plugin::Common;

our $VERSION = '0.000_5';

use v5.14;
use strict;
use warnings;

use parent qw/Exporter/;

use JSON qw/encode_json/;
use Log::Log4perl qw//;

use DB_File qw//;
use Storable qw/freeze thaw/;

use App::FonBot::Plugin::Config qw/$dir $user $group @supplementary_groups/;

##################################################

our (%ok_user_addresses, %commands, %waiting_requests);
our @EXPORT = qw/%ok_user_addresses %commands %waiting_requests sendmsg/;

my $log=Log::Log4perl->get_logger(__PACKAGE__);

sub init{
	$log->info('setting user and group');
	$)=join ' ', scalar getgrnam $group, map {scalar getgrnam $_} @supplementary_groups;
	$(=scalar getgrnam $group;
	$<=$>=scalar getpwnam $user;
	chdir $dir;

	$log->info('initializing '.__PACKAGE__);
	tie %ok_user_addresses, DB_File => 'ok_user_addresses.db';
	tie %commands, DB_File => 'commands.db';
}

sub fini{
	$log->info('finishing '.__PACKAGE__);
	untie %ok_user_addresses;
	untie %commands;
}

##################################################

sub sendmsg{
	my ($touser,$requestid,$replyto,$command,@args)=@_;

	my $data={command=>$command, replyto=>$replyto, args => \@args };
	$data->{requestid} = $requestid if defined $requestid;

	if (exists $commands{$touser}) {
		my $temp = thaw $commands{$touser};
		push @$temp, $data;
		$commands{$touser} = freeze $temp
	} else {
		$commands{$touser} = freeze [$data]
	}

	if (exists $waiting_requests{$touser}) {
		$waiting_requests{$touser}->continue;
		delete $waiting_requests{$touser}
	}
}

1;
__END__

=encoding utf-8

=head1 NAME

App::FonBot::Plugin::Common - FonBot plugin that provides global variables and functions

=head1 SYNOPSIS

	use App::FonBot::Plugin::Common;
	App::FonBot::Plugin::Common->init;

	$ok_user_addresses{'marius OFTC mgvx'}=1; # Let user marius send messages to mgvx via the OFTC plugin
	sendmsg 'marius', 'OFTC mgvx', 'echo', 'Hello', 'world!';

	App::FonBot::Plugin::Common->fini;

=head1 DESCRIPTION

This FonBot plugin provides global variables and functions to the other plugins. It also sets the user and group according to the configuration file. It is a required plugin, since most other plugins depend on it.

=head1 CONFIGURATION VARIABLES

These are the L<App::FonBot::Plugin::Config> configuration variables used in this module

=over

=item C<$dir>

Directory to chdir to.

=item C<$user>

User to change to.

=item C<$group>

Group to change to.

=item C<@supplementary_groups>

Supplementary groups list to set.

=back

=head1 EXPORTED SYMBOLS

=over

=item B<%ok_user_addresses>

Hash that records combinations of username, driver and address that have sent commands to us. The key format is C<"$username $drivername $address">. B<fonbotd> will never send a message to an address which is not found in this hash.

Example entry: C<$ok_user_address{"nobody EMAIL nobody@mailinator.com"}>.

=item B<%commands>

Hash from usernames to a C<Storable::freeze>d array of pending commands for the user.

=item B<%waiting_requests>

Hash from usernames to a waiting HTTP::Response, as defined by the POE::Component::Server::HTTP documentation.

=item B<sendmsg>(I<$touser>, I<$requestid>, I<$replyto>, I<$command>, I<@args>)

Sends a command to C<$touser>'s phone. The command includes a command name (C<$command>), a list of arguments (C<@args>) and a reply address (C<$replyto>). If I<$requestid> is defined, the command will also include that request ID.

=back

=head1 METHODS

=over

=item C<App::FonBot::Plugin::Common-E<gt>init>

Sets the user and group according to the configuration variables and reads the exported variables from the disk.

=item C<App::FonBot::Plugin::Common-E<gt>fini>

Writes the exported variables to the disk.

=back

=head1 AUTHOR

Marius Gavrilescu C<< <marius@ieval.ro> >>

=head1 COPYRIGHT AND LICENSE

Copyright 2013 Marius Gavrilescu

This file is part of fonbotd.

fonbotd is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.

fonbotd is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU Affero General Public License for more details.

You should have received a copy of the GNU Affero General Public License
along with fonbotd.  If not, see <http://www.gnu.org/licenses/>


=cut
Commit	Line	Data
	1	package App::FonBot::Plugin::Common;
	2
	3	our $VERSION = '0.000_5';
	4
	5	use v5.14;
	6	use strict;
	7	use warnings;
	8
	9	use parent qw/Exporter/;
	10
	11	use JSON qw/encode_json/;
	12	use Log::Log4perl qw//;
	13
	14	use DB_File qw//;
	15	use Storable qw/freeze thaw/;
	16
	17	use App::FonBot::Plugin::Config qw/$dir $user $group @supplementary_groups/;
	18
	19	##################################################
	20
	21	our (%ok_user_addresses, %commands, %waiting_requests);
	22	our @EXPORT = qw/%ok_user_addresses %commands %waiting_requests sendmsg/;
	23
	24	my $log=Log::Log4perl->get_logger(__PACKAGE__);
	25
	26	sub init{
	27	$log->info('setting user and group');
	28	$)=join ' ', scalar getgrnam $group, map {scalar getgrnam $_} @supplementary_groups;
	29	$(=scalar getgrnam $group;
	30	$<=$>=scalar getpwnam $user;
	31	chdir $dir;
	32
	33	$log->info('initializing '.__PACKAGE__);
	34	tie %ok_user_addresses, DB_File => 'ok_user_addresses.db';
	35	tie %commands, DB_File => 'commands.db';
	36	}
	37
	38	sub fini{
	39	$log->info('finishing '.__PACKAGE__);
	40	untie %ok_user_addresses;
	41	untie %commands;
	42	}
	43
	44	##################################################
	45
	46	sub sendmsg{
	47	my ($touser,$requestid,$replyto,$command,@args)=@_;
	48
	49	my $data={command=>$command, replyto=>$replyto, args => \@args };
	50	$data->{requestid} = $requestid if defined $requestid;
	51
	52	if (exists $commands{$touser}) {
	53	my $temp = thaw $commands{$touser};
	54	push @$temp, $data;
	55	$commands{$touser} = freeze $temp
	56	} else {
	57	$commands{$touser} = freeze [$data]
	58	}
	59
	60	if (exists $waiting_requests{$touser}) {
	61	$waiting_requests{$touser}->continue;
	62	delete $waiting_requests{$touser}
	63	}
	64	}
	65
	66	1;
	67	__END__
	68
	69	=encoding utf-8
	70
	71	=head1 NAME
	72
	73	App::FonBot::Plugin::Common - FonBot plugin that provides global variables and functions
	74
	75	=head1 SYNOPSIS
	76
	77	use App::FonBot::Plugin::Common;
	78	App::FonBot::Plugin::Common->init;
	79
	80	$ok_user_addresses{'marius OFTC mgvx'}=1; # Let user marius send messages to mgvx via the OFTC plugin
	81	sendmsg 'marius', 'OFTC mgvx', 'echo', 'Hello', 'world!';
	82
	83	App::FonBot::Plugin::Common->fini;
	84
	85	=head1 DESCRIPTION
	86
	87	This FonBot plugin provides global variables and functions to the other plugins. It also sets the user and group according to the configuration file. It is a required plugin, since most other plugins depend on it.
	88
	89	=head1 CONFIGURATION VARIABLES
	90
	91	These are the L<App::FonBot::Plugin::Config> configuration variables used in this module
	92
	93	=over
	94
	95	=item C<$dir>
	96
	97	Directory to chdir to.
	98
	99	=item C<$user>
	100
	101	User to change to.
	102
	103	=item C<$group>
	104
	105	Group to change to.
	106
	107	=item C<@supplementary_groups>
	108
	109	Supplementary groups list to set.
	110
	111	=back
	112
	113	=head1 EXPORTED SYMBOLS
	114
	115	=over
	116
	117	=item B<%ok_user_addresses>
	118
	119	Hash that records combinations of username, driver and address that have sent commands to us. The key format is C<"$username $drivername $address">. B<fonbotd> will never send a message to an address which is not found in this hash.
	120
	121	Example entry: C<$ok_user_address{"nobody EMAIL nobody@mailinator.com"}>.
	122
	123	=item B<%commands>
	124
	125	Hash from usernames to a C<Storable::freeze>d array of pending commands for the user.
	126
	127	=item B<%waiting_requests>
	128
	129	Hash from usernames to a waiting HTTP::Response, as defined by the POE::Component::Server::HTTP documentation.
	130
	131	=item B<sendmsg>(I<$touser>, I<$requestid>, I<$replyto>, I<$command>, I<@args>)
	132
	133	Sends a command to C<$touser>'s phone. The command includes a command name (C<$command>), a list of arguments (C<@args>) and a reply address (C<$replyto>). If I<$requestid> is defined, the command will also include that request ID.
	134
	135	=back
	136
	137	=head1 METHODS
	138
	139	=over
	140
	141	=item C<App::FonBot::Plugin::Common-E<gt>init>
	142
	143	Sets the user and group according to the configuration variables and reads the exported variables from the disk.
	144
	145	=item C<App::FonBot::Plugin::Common-E<gt>fini>
	146
	147	Writes the exported variables to the disk.
	148
	149	=back
	150
	151	=head1 AUTHOR
	152
	153	Marius Gavrilescu C<< <marius@ieval.ro> >>
	154
	155	=head1 COPYRIGHT AND LICENSE
	156
	157	Copyright 2013 Marius Gavrilescu
	158
	159	This file is part of fonbotd.
	160
	161	fonbotd is free software: you can redistribute it and/or modify
	162	it under the terms of the GNU Affero General Public License as published by
	163	the Free Software Foundation, either version 3 of the License, or
	164	(at your option) any later version.
	165
	166	fonbotd is distributed in the hope that it will be useful,
	167	but WITHOUT ANY WARRANTY; without even the implied warranty of
	168	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	169	GNU Affero General Public License for more details.
	170
	171	You should have received a copy of the GNU Affero General Public License
	172	along with fonbotd. If not, see <http://www.gnu.org/licenses/>
	173
	174
	175	=cut