root/freepbx/branches/2.2/amp_conf/bin/retrieve_queues_conf_from_mysql.pl

#!/usr/bin/perl -w

# if flags = 1 then the records are not included in the output file

use FindBin;
push @INC, "$FindBin::Bin";

use DBI;
require "retrieve_parse_amportal_conf.pl";

################### BEGIN OF CONFIGURATION ####################

if (scalar @ARGV == 2)
{
  $amportalconf = $ARGV[0];
  # WARNING: this file will be substituted by the output of this program
  $queues_conf = $ARGV[1]."/queues_additional.conf";
} else
{
  $amportalconf = "/etc/amportal.conf";
  # WARNING: this file will be substituted by the output of this program
  $queues_conf = "/etc/asterisk/queues_additional.conf";
}

# the name of the extensions table
$table_name = "queues";
# the path to the extensions.conf file
# WARNING: this file will be substituted by the output of this program

# cool hack by Julien BLACHE <jblache@debian.org>
$ampconf = parse_amportal_conf( $amportalconf );
# username to connect to the database
$username = $ampconf->{"AMPDBUSER"};
# password to connect to the database
$password = $ampconf->{"AMPDBPASS"};
# the name of the database our tables are kept
$database = $ampconf->{"AMPDBNAME"};
# the name of the box the MySQL database is running on
$hostname = $ampconf->{"AMPDBHOST"};

# the engine to be used for the SQL queries,
# if none supplied, backfall to mysql
$db_engine = "mysql";
if (exists($ampconf->{"AMPDBENGINE"})){
  $db_engine = $ampconf->{"AMPDBENGINE"};
}

################### END OF CONFIGURATION #######################

$warning_banner = "; do not edit this file, this is an auto-generated file by freepbx
; all modifications must be done from the web gui
";


if ( $db_engine eq "mysql" ) {
  $dbh = DBI->connect("dbi:mysql:dbname=$database;host=$hostname", "$username", "$password");
}
elsif ( $db_engine eq "pgsql" ) {
  $dbh = DBI->connect("dbi:pgsql:dbname=$database;host=$hostname", "$username", "$password");
}
elsif ( $db_engine eq "sqlite" ) {
  if (!exists($ampconf->{"AMPDBFILE"})) {
    print "No AMPDBFILE set in /etc/amportal.conf\n";
    exit;
  }
  
  my $db_file = $ampconf->{"AMPDBFILE"};
  $dbh = DBI->connect("dbi:SQLite2:dbname=$db_file","","");
}
elsif ( $db_engine eq "sqlite3" ) {
  if (!exists($ampconf->{"AMPDBFILE"})) {
    print "No AMPDBFILE set in /etc/amportal.conf\n";
    exit;
  }
  
  my $db_file = $ampconf->{"AMPDBFILE"};
  $dbh = DBI->connect("dbi:SQLite:dbname=$db_file","","");
}

$statement = "SELECT keyword,data from $table_name where id='-1' and keyword <> 'account'";
my $result = $dbh->selectall_arrayref($statement);
unless ($result) {
  # check for errors after every single database call
  print "dbh->selectall_arrayref($statement) failed!\n";
  print "DBI::err=[$DBI::err]\n";
  print "DBI::errstr=[$DBI::errstr]\n";
  exit;
}

open( EXTEN, ">$queues_conf" ) or die "Cannot create/overwrite extensions file: $queues_conf (!$)\n";
print EXTEN $warning_banner;

$additional = "";
my @resultSet = @{$result};
if ( $#resultSet > -1 ) {
  foreach $row (@{ $result }) {
    my @result = @{ $row };
    $additional .= $result[0]."=".$result[1]."\n";
  }
}

$statement = "SELECT data,id from $table_name where keyword='account' group by data";

$result = $dbh->selectall_arrayref($statement);
unless ($result) {
  # check for errors after every single database call
  print "dbh->selectall_arrayref($statement) failed!\n";
  print "DBI::err=[$DBI::err]\n";
  print "DBI::errstr=[$DBI::errstr]\n";
}

@resultSet = @{$result};
if ( $#resultSet == -1 ) {
  print "No queues defined in $table_name\n";
  exit;
}

foreach my $row ( @{ $result } ) {
  my $account = @{ $row }[0];
  my $id = @{ $row }[1];
  print EXTEN "[$account]\n";
  $statement = "SELECT keyword,data from $table_name where id='$id' and keyword <> 'account' and keyword <> 'rtone' order by flags";
  my $result = $dbh->selectall_arrayref($statement);
  unless ($result) {
    # check for errors after every single database call
    print "dbh->selectall_arrayref($statement) failed!\n";
    print "DBI::err=[$DBI::err]\n";
    print "DBI::errstr=[$DBI::errstr]\n";
    exit;
  }

  my @resSet = @{$result};
  if ( $#resSet == -1 ) {          
    print "no results\n";
    exit;
  }
  
  foreach my $row ( @{ $result } ) {
    my @result = @{ $row };
    print EXTEN "$result[0]=$result[1]\n";
  }                                           

  print EXTEN "$additional\n";
}

exit 0;