//!/usr/bin/perl
// sphinx.agi
// Copyright (c) 2005 Josh McAllister
//
// This program is free software; you can redistribute it and/or modify
// it under the same terms as Perl itself.
//
// Written by Josh McAllister 

use Asterisk::AGI;
my $AGI = new Asterisk::AGI;
%input = $AGI->ReadParse();

sub asr {
use IO::Socket;
use FileHandle;
use IPC::Open2;
my $file = shift or return undef;
my $host = shift || 'localhost';
my $port = shift || '1069';
my $fh;

my $remote =  IO::Socket::INET->new(
		Proto    => "tcp",
		PeerAddr => "$host",
		PeerPort => "$port",
		) or return undef;

#Idea here being that you can pass a reference to an existing file handle... not yet implemented, just pass a filename.
if (ref $file) { 
   my $fh = $file;
} else {
   open (FH, $file) || return undef;
   $fh = *FH;
}

$file =~ /(gsm|wav)$/;
my $type = $1;
if ($type !~ /gsm|wav/) {
   warn "Unknown file type ($file)";
   return undef;
}
#print "FTYPE: $type\n";
$pid = open2(*SOXIN, *SOXOUT, "sox -t $type - -s -r 8000 -w -t wav - 2>/dev/null") || warn ("Could not open2.\n");

binmode $fh;
binmode SOXIN;
binmode SOXOUT;
binmode $remote;

while (defined(my $b = read $fh, my($buf), 4096)) {
   last if $b == 0;
   $count += $b;
   print SOXOUT $buf;
}
close SOXOUT;

$count = 0;
my $sox = undef;
while (defined(my $b = read SOXIN, my($buf), 4096)) {
   last if $b == 0;
   $count += $b;
   $sox .= $buf;
}
print $remote length($sox) . "\n";
print $remote "$sox";
close SOXIN;

#print "DEBUG: Waiting for result.\n";
   
$count=0;
while (defined(my $b = read $remote, my($buf), 4096)) {
   last if $b == 0;
   $count += $b;
   $result .= $buf;
}

close $fh;
close $remote;

return "$result";
}

sub confirm {
      while (my $tries <= 3) {
         $tries++;

         $AGI->stream_file("vr/say_yes_no",'""');

         $AGI->stream_file("beep",'""');
         $AGI->record_file("/tmp/$$", 'gsm', '0',3000);
         $AGI->stream_file("beep",'""');


         #Here is where the magic happens, this is calling the asr sub from sphinx-netclient.pl
         #Again, this sub needs to be in this same script. $vresponse will contain the
         #transcription of the what the caler said.

         my $vresponse = asr("/tmp/$$.gsm");
         $AGI->verbose("CONFIRM: $vresponse");

         next if $vresponse !~ /YES|NO|ACCEPT|CANCEL/;

         $gotresp = 1;


         if ($vresponse =~ /NO|CANCEL/i) {
            sleep 1;
            $AGI->stream_file("cancelled",'""');
            return undef;
         } else {
	    $AGI->set_variable('RESPONSE', 'YES');
            return 1;
         }

      }

      if (! $gotresp) {
         sleep 1;
         $AGI->stream_file("invalid_selection",'""');
         return undef;
      }
}

$AGI->stream_file("vr/green_eggs_ham",'""');
unless ( confirm() ) {
   #They said no
   $AGI->set_variable('RESPONSE', 'NO');
   exit;
}

    function sphinx($filename='', $timeout=3000, $service_port = 1069, $address = '127.0.0.1'){
		
		/* if a recording has not been passed in we create one */
		if ($filename=="") {
			$filename = "/var/lib/asterisk/sounds/sphinx_".$this->request['agi_uniqueid'];
			$extension = "wav";
			$this->stream_file('beep', 3000, 5);
			$this->record_file($filename, $extension, '0',$timeout);
			$filename=$filename.'.'.$extension;
		}	
			
		/* Create a TCP/IP socket. */
		$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
		if ($socket < 0) {
			return false;
		}
		
		$result = socket_connect($socket, $address, $service_port);
		if ($result < 0) {
		   return false;
		}
		
		//open the file and read in data
		$handle = fopen($filename, "rb");
		$data = fread($handle, filesize($filename));
		
		socket_write($socket, filesize($filename)."\n");
		socket_write($socket, $data);
		
		$response = socket_read($socket, 2048);
		
		socket_close($socket);
		
		unlink($filename);
		return $response;
   }