File Coverage

blib/lib/App/FonBot/Plugin/Common.pm

Criterion	Covered	Total	%
statement	19	21	90.4
branch			n/a
condition			n/a
subroutine	7	7	100.0
pod			n/a
total	26	28	92.8

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

our $VERSION = '0.001';

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__