#!/usr/bin/php -q
<?php

# change this to match the code of your particular city
# for a complete list of US cities, go to
# http://www.nws.noaa.gov/data/current_obs/

$target_url = "http://w1.weather.gov/xml/current_obs/KTUS.xml";
$userAgent = 'Googlebot/2.1 (http://www.googlebot.com/bot.html)';

   	$ch = curl_init();
        curl_setopt($ch, CURLOPT_USERAGENT, $userAgent);
        curl_setopt($ch, CURLOPT_URL,$target_url);
        curl_setopt($ch, CURLOPT_FAILONERROR, true);
        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
        curl_setopt($ch, CURLOPT_AUTOREFERER, true);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER,true);
        curl_setopt($ch, CURLOPT_TIMEOUT, 10);
        $weatherPage = curl_exec($ch);

# don't let this script run for more than 60 seconds

# set_time_limit(60);

# turn off output buffering

ob_implicit_flush(false);

# turn off error reporting, as it will most likely interfere with
# the AGI interface

error_reporting(0);

# create file handles if needed

if (!defined('STDIN'))
{
define('STDIN', fopen('php://stdin', 'r'));
}
if (!defined('STDOUT'))
{
define('STDOUT', fopen('php://stdout', 'w'));
}
if (!defined('STDERR'))
{
define('STDERR', fopen('php://stderr', 'w'));
}

# retrieve all AGI variables from Asterisk

while (!feof(STDIN))
{
$temp = trim(fgets(STDIN,4096));
if (($temp == "") || ($temp == "\n"))
{
break;
}
$s = split(":",$temp);
$name = str_replace("agi_","",$s[0]);
$agi[$name] = trim($s[1]);
}

# print all AGI variables for debugging purposes

foreach($agi as $key=>$value)
{
fwrite(STDERR,"-- $key = $value\n");
fflush(STDERR);
}

# retrieve this web page
# get_contents no longer allowed, uses curl above.
# $weatherPage=file_get_contents($weatherURL);

# get temperature in Fahrenheit

if (preg_match("/<temp_f>([0-9.]+)<\/temp_f>/i",$weatherPage,$matches))

{$currentTemp=$matches[1];}


# get relative humidity

if (preg_match("/<relative_humidity>([0-9.]+)<\/relative_humidity>/i",$weatherPage,$matches))

{$currentHumidity=$matches[1];}

# get visibility in miles

if (preg_match("/<visibility_mi>([0-9.]+)<\/visibility_mi>/i",$weatherPage,$matches))

{$currentVisibility=$matches[1];}

# get wind direction

if (preg_match("/<wind_dir>North<\/wind_dir>/i",$weatherPage))
{
$currentWindDirection='northerly';
}
elseif (preg_match("/<wind_dir>South<\/wind_dir>/i",$weatherPage))
{
$currentWindDirection='southerly';
}
elseif (preg_match("/<wind_dir>East<\/wind_dir>/i",$weatherPage))
{
$currentWindDirection='easterly';
}
elseif (preg_match("/<wind_dir>West<\/wind_dir>/i",$weatherPage))
{
$currentWindDirection='westerly';
}
elseif (preg_match("/<wind_dir>Northwest<\/wind_dir>/i",$weatherPage))
{
$currentWindDirection='northwesterly';
}
elseif (preg_match("/<wind_dir>Northeast<\/wind_dir>/i",$weatherPage))
{
$currentWindDirection='northeasterly';
}
elseif (preg_match("/<wind_dir>Southwest<\/wind_dir>/i",$weatherPage))
{
$currentWindDirection='southwesterly';
}
elseif (preg_match("/<wind_dir>Southeast<\/wind_dir>/i",$weatherPage))
{
$currentWindDirection='southeasterly';
}

# get wind speed

if 
(preg_match("/<wind_mph>([0-9]+)([\.]+)([0-9]+)<\/wind_mph>/i",$weatherPage,$matches))
{
$currentWindSpeed = $matches[1];
}

# get barometric pressure

if 

(preg_match("/<pressure_in>([0-9]+)([\.]+)([0-9]+)<\/pressure_in>/i",$weatherPage,$matches))
{
$currentPressure1 = $matches[1];
$currentPressure2 = $matches[3];
}

# tell the caller the current conditions

if ($currentTemp)
{

fwrite(STDOUT,"STREAM FILE weather-conditions \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);


fwrite(STDOUT,"STREAM FILE temperature \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"SAY NUMBER $currentTemp \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"STREAM FILE degrees \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"STREAM FILE fahrenheit \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

}
# tell the caller the current humidity
if ($currentHumidity)
{

fwrite(STDOUT,"STREAM FILE with \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"SAY NUMBER $currentHumidity \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"STREAM FILE percent \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

#fwrite(STDOUT,"STREAM FILE relative \"\"\n");
#fflush(STDOUT);
#$result = trim(fgets(STDIN,4096));
#checkresult($result);

fwrite(STDOUT,"STREAM FILE humidity \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

}
if ($currentWindDirection && $currentWindSpeed)
{

fwrite(STDOUT,"STREAM FILE $currentWindDirection \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"STREAM FILE wind \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"STREAM FILE at \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"SAY NUMBER $currentWindSpeed \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"STREAM FILE miles-per-hour \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

}
# tell the caller the current barometric pressure
if ($currentTemp)
{

fwrite(STDOUT,"STREAM FILE barometric-pressure \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"SAY NUMBER $currentPressure1 \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"STREAM FILE point \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"SAY DIGITS $currentPressure2 \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);
}

# tell caller the current visibility
if ($currentVisibility)
{
fwrite(STDOUT,"STREAM FILE visibility \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"SAY NUMBER $currentVisibility \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

fwrite(STDOUT,"STREAM FILE miles \"\"\n");
fflush(STDOUT);
$result = trim(fgets(STDIN,4096));
checkresult($result);

}
function checkresult($res)
{
trim($res);
if (preg_match('/^200/',$res))
{
if (! preg_match('/result=(-?\d+)/',$res,$matches))
{
fwrite(STDERR,"FAIL ($res)\n");
fflush(STDERR);
return 0;
}
else{
fwrite(STDERR,"PASS (".$matches[1].")\n");
fflush(STDERR);
return $matches[1];
}
}
else
{
fwrite(STDERR,"FAIL (unexpected result '$res')\n");
fflush(STDERR);
return -1;
}
}
?>