rude-config-maker

#!/usr/bin/perl
# make rude config files from host lists
#   format : src dst1 dst2 ...

my $target;
my $list='mp-list.txt';
my $default_port=10001;
my $index;  # the index for event records
my $rude_port=3100; # start local port number udp
my $max_hops=30;

use Getopt::Long;
@opts=( 'target=s' => \$target, 'list=s' => \$list, 'index=s' => \$index, 'rude_start=i' => \$rude_port,
	'max_hops=i' => \$max_hops);
my $usage="usage: $0 [ -target <target host> ] [-list <mp-list.txt>] -index <index> config-file 
-rude_start <3001> --max_hops <n> (30)\n";

GetOptions(@opts) || die $usage;
die $usage if !$index;

open LIST, "<$list" || die "Could not open $list : $!\n";
while(<LIST>){
    next if /\s*#/; # comment
    ($name, $uid, $dns, $ip, $port, $crude_port, $ssh_port, $max_hop)=split;
    $ip{$name}=$ip;
    $dns{$name}=$dns;
    $port{$name}=$port;
    $crude_port{$name}=$crude_port if $crude_port;
    $max_hop{$name}= $max_hop || $max_hops_default;
}
if ($target && ! $port{$target} ){
    $port{$target} = $default_port;
}

use Socket;
while(<>){
    next if /\s*#/; # comment
    ($src, @dst)=split;
    foreach $dst(@dst){
	$peers{$src, $dst}++;
	$peers{$dst, $src}++;
    }
}


my $flow_no=1;
my $rude; # fd to write config
my $start; # fd to write config
my $outdir;
my $gotit=0;

foreach $peer ( sort(keys %peers)){
    my ($src, $dst)=split(/$;/,$peer);

    if ( $target ){
        if ($target eq $src){ # just write config for target to stdout
	    $gotit=1;
	    $outdir=".";
	} else { # avoid writing for other targets
	    $gotit=0;
	}
    } else {
	$gotit=1;
	$outdir=$src;
    }
    if ($psrc ne $src){
	if ( $gotit){
	    if ( $psrc){
		close $rude;
		$flow_no=1;
	    }
	    mkdir "$outdir" if ! -d $outdir;
	    open $rude, ">$outdir/rude.cfg" || die "Could not open ${outdir}/rude.cfg : $!";
	    print $rude "START NOW\n";
	}
    }

    $ip=$ip{$dst};
    if ( !$ip){
	if ( $dns{$dst} ){
	    $ipn=gethostbyname($dns{$dst});
	} else {
	    $ipn=gethostbyname($dst);
	}
	if ($ipn){
	    $ip=inet_ntoa($ipn);
	}
    }
    if ($gotit){
	if ($ip ){
	    printf $rude "0 %d ON %d %s:%s CONSTANT 100 64\n", $flow_no, $rude_port + $flow_no, $ip,
		$port{$dst} || $default_port;;
	    printf $rude "90010000 %d OFF\n", $flow_no; # varer en dag +10 sek skuddr
	    @$tracetarget{$src} = () if ! $tracetarget{$src};
	    push (@{$tracetarget{$src}}, $ip );
	} else {
	    warn "### Could not find IP for $dst, $ip";
	}
    }
    $psrc=$src;
    $flow_no++;
}

close RUDE;
close $rude;


foreach $name ( keys %port){
    if ( (! $target) || ( $target eq $name ) ){
	$outdir=$name;
	if ( -d $outdir ){
	    open ( $start, ">$outdir/parms.cfg") || die "Could not open ${outdir}/parms.cfg : $!" ;
	    printf $start "index=%s\n", $index ;
	    my $crude_port= $crude_port{$name} || $port{$name} || $default_port;
	    printf $start "crude_port=%s\n", $crude_port;
	    printf $start "max_hops=%s\n", $max_hop{$name};
	    # printf $start "%s", $startcfg; 
	    close $start;
	}
    }
    
}

foreach $src ( keys %tracetarget ){
    next if $target and $src ne $target;
    if ( $target){
	next if $src ne $target;
	$outdir=".";
    } else {
	$outdir=$src;
    }
    if ( -d $outdir ){
	open TRACE, ">$outdir/trace.cfg" || die "Could not open $outdir/start.cfg : $!" ;
	print TRACE join("\n", @{$tracetarget{$src}} );
	close TRACE;
    }
}