#!/usr/bin/perl
#
# A hook that notifies its companion cidaemon through a simple
# queue file that a ref has been updated via a push (actually
# by a receive-pack running on the server).
#
# See cidaemon for per-repository configuration details.
#
# To use this hook, add it as the post-receive hook, make it
# executable, and set its configuration options.
#

local $ENV{PATH} = '/opt/git/bin';

use strict;
use warnings;
use File::Spec;
use Storable qw(retrieve nstore);
use Fcntl ':flock';

my $git_dir = File::Spec->rel2abs($ENV{GIT_DIR});
my $queue_name = `git config --get builder.queue`;chop $queue_name;
$queue_name =~ m,^([^\s]+)$,; $queue_name = $1; # untaint
unless ($queue_name) {
        1 while <STDIN>;
        print STDERR "\nerror: builder.queue not set.  Not enqueing.\n\n";
        exit;
}
my $queue_lock = "$queue_name.lock";

my @skip;
open S, "git config --get-all builder.skip|";
while (<S>) {
        chop;
        push @skip, $_;
}
close S;

my @new_branch_base;
open S, "git config --get-all builder.newBranchBase|";
while (<S>) {
        chop;
        push @new_branch_base, $_;
}
close S;

sub skip ($)
{
        local $_ = shift;
        foreach my $p (@skip) {
                return 1 if /^$p/;
        }
        0;
}

open LOCK, ">$queue_lock" or die "Can't open $queue_lock: $!";
flock LOCK, LOCK_EX;

my $queue = -f $queue_name ? retrieve $queue_name : [];
my %existing;
foreach my $r (@$queue) {
        my ($gd, $ref) = @$r;
        $existing{$gd}{$ref} = $r;
}

my @new_branch_commits;
my $loaded_new_branch_commits = 0;

while (<STDIN>) {
        chop;
        my ($old, $new, $ref) = split / /, $_, 3;

        next if $old eq $new;
        next if $new =~ /^0{40}$/;
        next if skip $ref;

        my $r = $existing{$git_dir}{$ref};
        if ($r) {
                $r->[3] = $new;
        } else {
                if ($old =~ /^0{40}$/) {
                        if (!$loaded_new_branch_commits && @new_branch_base) {
                                open M,'-|','git','show-ref',@new_branch_base;
                                while (<M>) {
                                        ($_) = split / /, $_;
                                        push @new_branch_commits, $_;
                                }
                                close M;
                                $loaded_new_branch_commits = 1;
                        }
                        $old = [@new_branch_commits];
                } else {
                        $old = [$old];
                }

                $r = [$git_dir, $ref, $old, $new];
                $existing{$git_dir}{$ref} = $r;
                push @$queue, $r;
        }
}
nstore $queue, $queue_name;

flock LOCK, LOCK_UN;
close LOCK;