#!/usr/bin/perl
use strict;
use warnings;
use Log::Log4perl qw(:easy);
use Getopt::Long qw(GetOptions);
my $log_file = "gsgd.log";
sub get_log_name { return $log_file; };
my $log_conf = q(
log4perl.rootLogger = INFO, LOG1, screen
log4perl.appender.LOG1 = Log::Log4perl::Appender::File
log4perl.appender.LOG1.filename = sub { get_log_name(); }
log4perl.appender.LOG1.mode = append
log4perl.appender.LOG1.layout = Log::Log4perl::Layout::PatternLayout
log4perl.appender.LOG1.layout.ConversionPattern = %d %p >> %m %n
log4perl.appender.screen = Log::Log4perl::Appender::Screen
log4perl.appender.screen.stderr = 0
log4perl.appender.screen.layout = PatternLayout
log4perl.appender.screen.layout.ConversionPattern = %d %p >> %m %n
);
Log::Log4perl::init(\$log_conf);
my $logger = get_logger();
my %args;
GetOptions(
\%args,
'gsg-cmd=s',
'comms-file=s'
);
my $comm_file = "talk.gsgd";
my $LOCK_FILE = "lock.gsgd";
my $regen_cmd;
sub process_args() {
if ( ! defined $args{'gsg-cmd'} || $args{'gsg-cmd'} eq "" ) {
$logger->error("Must pass --gsg-cmd");
exit 1;
}
$regen_cmd = $args{'gsg-cmd'};
if ( defined $args{'comms-file'} ) {
if ( ! -f $args{'comms-file'} ) {
$logger->error("$args{'comms-file'} doesn't look like a regular file");
exit 1;
}
if ( ! -w $args{'comms-file'} ) {
$logger->error("$0 doesn't appear to have permission to write to $args{'comms-file'}");
exit 1;
}
$comm_file = $args{'comms-file'};
}
}
process_args();
sub create_lock() {
$logger->debug("Creating lock file while operating");
open(my $fh, ">", $LOCK_FILE) or die $logger->error("Couldn't create $LOCK_FILE");
print $fh "";
close $fh;
}
sub remove_lock() {
$logger->debug("Removing lock file, not operating");
unlink($LOCK_FILE) or die $logger->error("Couldn't unlink $LOCK_FILE");
}
sub check_lock() {
if ( -f $LOCK_FILE ) {
$logger->info("Found lock file");
sleeper(5);
if ( -f $LOCK_FILE ) {
die $logger->error("$LOCK_FILE still exists even after waiting, why?");
}
}
}
sub remove_instruction($) {
my $instruction_to_remove = shift;
$logger->debug("Removing $instruction_to_remove instruction");
$logger->debug("Opening $comm_file for writing");
open(my $fh, ">", $comm_file);
my @lines = $fh;
foreach my $line ( @lines ) {
# This is bad TODO
print $fh "$line\n" unless ( $line =~ m/$instruction_to_remove/ || $line =~ m/GLOB/);
}
$logger->debug("Closing $comm_file");
close $fh;
}
sub regen() {
$logger->info("Regening site");
system("$regen_cmd") == 0
or die $logger->error("Failed to exec $regen_cmd !");
check_lock();
create_lock();
remove_instruction("Regen");
remove_lock();
}
sub gsgd_exit() {
check_lock();
create_lock();
remove_instruction("Exit");
remove_lock();
exit 0;
}
sub sleeper($) {
my $sleep_time = shift;
$logger->debug("Sleeping $sleep_time seconds");
sleep $sleep_time;
}
sub open_comms() {
$logger->debug("Opening $comm_file for reading");
open(my $fh, "<", $comm_file) or die $logger->error("Could not open $comm_file for reading");
my @instructions = <$fh>;
$logger->debug("Closing $comm_file");
close $fh;
foreach my $line ( @instructions ) {
chomp $line;
if ( $line =~ m/^Regen$/ ) {
$logger->info("Got $line instruction");
regen();
} elsif ( $line =~ m/^Exit$/ ) {
$logger->info("Got $line instruction");
gsgd_exit();
} else {
$logger->error("Unrecognized instruction $line");
}
}
}
$logger->info("Starting");
while() {
sleeper(1);
open_comms();
}