#!/usr/bin/perl

use lib '/home/channel/EPICS/base/lib/perl/';

use MongoDB;

use MongoDB::Timestamp;

use CA;

my $hostname = "localhost";

my $port = 27017;

my $conn = MongoDB::Connection->new( "host" => "$hostname", 

                                     "port" => $port );

my $db = $conn->get_database( 'channelfinder' );

my $ioc_stats = $db->get_collection( 'ioc_stats' );

my $pv_stats = $db->get_collection( 'pv_stats' );

$path="/srv/ioc/log/Database";

@hosts = qw(ioc160 ioc161 ioc162 ioc163 ioc164 ioc165 ioc167 ioc168 agrajag zoot bacnet-gw resume fel03 mprot fel04);

my $dt   = DateTime->now;   # Stores current date and time as datetime object

my $date = $dt->ymd;   # Retrieves date as a string in 'yyyy-mm-dd' format

my $time = $dt->hms;   # Retrieves time as a string in 'hh:mm:ss' format

my $dtString = $date ." ".$time;

%iocs = ();

foreach $host(@hosts) {

  open (SSH,"/usr/bin/ssh epics\@$host ls $path/* |") or die "$!\n";

  while (<SSH>) {

    $name = $_;

    $name =~ s{.*/}{};

    $name =~ s{\.[^.]+$}{};

    $iocs{ $name } = $host;

  }

  close SSH;

}

  while ( my ($name, $host) = each(%iocs) ) {

    $ioc_stats->remove({name => $name});

    $ioc_stats->insert({name => $name, 

			host => $host, 

			type => 'ioc', 

			dt => $dtString });

  }

$cnt = $ioc_stats->count();

printf("Info:  $cnt iocs\n");

sub readDesc ()

{

my ($chan, $status, $data) = @_;

$desc = $data;

#print "Desc in callback : $desc\n";

}

sub readVal ()

{

my ($chan, $status, $data) = @_;

$val = $data;

#print "Val in callback : $val\n";

}

sub readDisa ()

{

my ($chan, $status, $data) = @_;

$disa = $data;

#print "DISA in callback : $disa\n";

}

while ( my ($ioc, $host) = each(%iocs) ) {

print " ............ $ioc on $host ..................\n";

  open (SSH,"/usr/bin/ssh epics\@$host cat $path/$ioc.dbl |") or die "$!\n";

  while (<SSH>) {

    $pv=$_;

    chomp($pv);

    print "PV: $pv ... ";

    $pv_stats->remove({name => $pv});

    my $pv_desc = $pv . ".DESC";

    my $pv_disa = $pv . ".DISA";

    $pv_chan = CA->new($pv_desc);

eval { CA->pend_io(1); };

if ($@) {

    if ($@ =~ m/^ECA_TIMEOUT/) {

        print "Channel $pv_chan->name connect timed out.\n";

    } else {

        die $@;

    }

} else {

 printf "    Host:          %s\n", $pv_chan->host_name;

 $host = $pv_chan->host_name;

}

if($pv_chan->is_connected) {

    $pv_chan->get_callback (\&readDesc,1);

eval { CA->pend_io(2); };

if ($@) {

    if ($@ =~ m/^ECA_TIMEOUT/) {

        print "Channel $pv_chan->name connect timed out.\n";

    } else {

        die $@;

    }

}

print " DESC : $desc ... ";

    $pv_chan = CA->new($pv);

eval { CA->pend_io(2); };

if ($@) {

    if ($@ =~ m/^ECA_TIMEOUT/) {

        print "Channel $pv_chan->name connect timed out.\n";

    } else {

        die $@;

    }

}

    $pv_chan->get_callback (\&readVal,1);

eval { CA->pend_io(2); };

if ($@) {

    if ($@ =~ m/^ECA_TIMEOUT/) {

        print "Channel $pv_chan->name connect timed out.\n";

    } else {

        die $@;

    }

}

print " VAL : $val ... ";

    $pv_chan = CA->new($pv_disa);

eval { CA->pend_io(2); };

if ($@) {

    if ($@ =~ m/^ECA_TIMEOUT/) {

        print "Channel $pv_chan->name connect timed out.\n";

    } else {

        die $@;

    }

}

    $pv_chan->get_callback (\&readDisa,1);

eval { CA->pend_io(2); };

if ($@) {

    if ($@ =~ m/^ECA_TIMEOUT/) {

        print "Channel $pv_chan->name connect timed out.\n";

    } else {

        die $@;

    }

}

print " DISA : $disa ...\n";

    $pv_stats->insert({	name => $pv, 

			ioc => $ioc, 

			host => $host, 

			desc => $desc,

                        val => $val,

			disa => $disa,

			type => "toBeDef", 

			dt => $dtString });

  }

}

  close SSH;

}

$cnt = $pv_stats->count();

print ("Info:  $cnt PVs \n");