X-Git-Url: http://git.rot13.org/?p=bak-git.git;a=blobdiff_plain;f=bak-git-server.pl;h=58d4dfe4365171632741ccbb0f34f1a78bb18b81;hp=4acf227e5454e0b384bdbb3bf33e5ee2c497c22e;hb=HEAD;hpb=6827651ffa94c4c9b3acc251a748d915e06a9653

diff --git a/bak-git-server.pl b/bak-git-server.pl
index 4acf227..3bd5f63 100755
--- a/bak-git-server.pl
+++ b/bak-git-server.pl
@@ -20,13 +20,15 @@ controll channel (or to pass through server ssh hops using C<ProxyCommand>)
 
   RemoteForward 9001 192.168.42.42:9001
 
-bak command overview:
+bak command, overview:
 
   bak add /path
   bak commit [/path [message]]
   bak diff [host:][/path]
   bak status [/path]
   bak log [/path]
+  bak log-grep pattern
+  bak grep pattern
 
   bak show
   bak ch[anges]
@@ -34,9 +36,12 @@ bak command overview:
 
   bak cat [host:]/path
   bak grep pattern
+  bak find filename-pattern
 
   bak - push all changed files to server
 
+  bak add,commit /path
+
 See L<http://blog.rot13.org/bak-git> for more information
 
 =cut
@@ -73,8 +78,10 @@ while(<$ssh_fd>) {
 		$host = $1;
 	} elsif ( /^\s+(\S+)\s+(.+)/ ) {
 		$ssh_tunnel->{$host}++ if lc($1) eq 'remoteforward' && $2 =~ m/9001/;
+	} elsif ( /^\s+$/ ) {
+		# nop
 	} else {
-		die "can't parse $_";
+		warn "can't parse [$_]";
 	}
 }
 
@@ -95,7 +102,7 @@ warn "# ssh_client $hostname $server";
 sub _kill_ssh {
 	while ( my($host,$pid) = each %$ssh_tunnel ) {
 		warn "$host kill TERM $pid";
-		kill 15, $pid; # TERM
+		eval { kill 15, $pid; } # TERM
 	}
 }
 
@@ -165,10 +172,24 @@ sub pull_changes {
 	rsync split / /, "-avv --files-from /tmp/$hostname.list root\@$hostname:/ $hostname/";
 }
 
+sub mkbasedir {
+	my $path = shift;
+	$path =~ s{/[^/]+$}{};
+	warn "# mkpath $path\n";
+	mkpath $path || die $!;
+}
+
 while (my $client = $server->accept()) {
 	my $line = <$client>;
 	chomp($line);
-	warn "<<< $line\n";
+
+	my $peerhost = $client->peerhost;
+	if ( $peerhost !~ m/^(10\.13\.37\.|10\.60\.0\.|10\.200\.100\.)/ ) {
+		print $client "$peerhost not allowed\n";
+		next;
+	}
+
+	warn "<<< $peerhost $line\n";
 	my ($user,$hostname,$pwd,$command,$rel_path,$message) = split(/\s+/,$line,6);
 	$hostname =~ s/\..+$//;
 
@@ -183,6 +204,8 @@ while (my $client = $server->accept()) {
 	}
 	my $path = $rel_path =~ m{^/} ? $rel_path : "$pwd/$rel_path";
 
+	foreach my $command ( split /,/, $command ) { # XXX command loop
+
 	warn "$hostname [$command] $on_host:$path | $message\n";
 
 	my $args_message = $message;
@@ -259,15 +282,32 @@ while (my $client = $server->accept()) {
 			print $client "ERROR: $file_path: $!\n";
 		}
 	} elsif ( $command eq 'ls' ) {
-		print $client `ls $backup_path`;
+		my $file_path = ( $on_host ? $on_host : $hostname ) . "/$path";
+		print $client `ls $file_path 2>&1`;
 	} elsif ( $command eq 'show' ) {
 		print $client `git show $rel_path`;
+	} elsif ( $command eq 'log-grep' ) {
+		#print $client `git log -g --grep=$rel_path`;
 	} elsif ( $command eq 'grep' ) {
-		print $client `git log -g --grep=$rel_path`;
+		print $client `git grep $rel_path`;
+	} elsif ( $command eq 'find' ) {
+		print $client `find . -iname '*$rel_path*' | sed -e 's,^./,,' -e 's,/,:/,'`
+	} elsif ( $command eq 'link' ) {
+		if ( $on_host ) {
+			mkbasedir "$on_host/$path";
+			rsync( '-avv', "root\@$on_host:$path", "$on_host/$path" );
+			mkbasedir "$hostname/$path";
+			link "$on_host/$path", "$hostname/$path";
+			rsync( '-avv', "$hostname/$path", "root\@$hostname:$path" );
+		} else {
+			print $client "ERROR: link requires host:/path\n";
+		}
 	} else {
-		print $client "Unknown command: $command\n";
+		print $client "ERROR: unknown command: $command\n";
 	}
 
+	} # XXX command, loop
+
 	close($client);
 }