#!/usr/local/bin/perl
# socketで特定のページを抜くスクリプト
# 8000

# getするhtml
$get_url = "http://nyama.sytes.net:8000/";
# checkする文字列
$check = "Server is currently up and";
# テンプレート的に保存するファイル
$logfile = "./radiolog.txt";
# 更新間隔時間 5分なら500
$updatetime_temp = 100;

# 引数無し時のimgディレクトリ 最後に / 必要
$noquery_imgurl = "http://laser.s7.xrea.com/";

# 接続数のログファイル
$uniqueip_log = "./radio_uniqueiplog.txt";

# 転送するファイル名は直指定なので注意
# ローカルディレクトリ
$ftp_local_dir = "./";

#--------------------------------------------------------------------

$ENV{TZ} = 'JST-9';
$times = time;
($sec,$min,$hour,$mday,$month,$year,$wday,undef,undef) = localtime($times);
$month++;
$year = 1900 + $year;
$actime = sprintf("%d%02d%02d%02d%02d%02d", $year, $month, $mday, $hour, $min, $sec);

open(IN,"<$logfile");
($onaircheck,$lastupdatetime) = split(/<>/, <IN>);
close(IN);

if($actime > $lastupdatetime + $updatetime_temp){
	$onairflag = &httpget;
	&wlog($onairflag,$actime);
	&printout($onairflag);
}else{
	&printout($onaircheck);
}
exit;

#--------------------------------------------------------------------

# 反応を返す
sub printout{
	local($onair_c) = @_;
	if($onair_c){
		$reprint = "radio_onair3.gif";
	}else{
		$reprint = "radio_off4.gif";
	}
	# ここから接続数
	open(IN,"<$uniqueip_log");
		($radioip_print) = split(/<>/, <IN>);
	close(IN);
	if($radioip_print eq "--"){
		$uniqueip_print = "";
	}else{
		$uniqueip_print = "<font size=\"-1\">現在の接続者 : $radioip_print名 (60秒以内)</font>";
	}
	@PAIRS = split(/&/,$ENV{'QUERY_STRING'});
	foreach(@PAIRS){
		($key, $value) = split(/=/, $_);
		$value =~ tr/+/ /;
		$value =~ s/%([a-fA-F0-9][a-fA-F0-9])/pack("C", hex($1))/eg;
		$QUERY{$key} = $value;
	}
	$QUERY{'imagedir'} = $noquery_imgurl if(!($QUERY{'imagedir'} =~ /http\:\/\//));
	# ここから出力
	if($QUERY{'mode'} eq "redirect"){
		print "Location: $QUERY{'imagedir'}$reprint\n\n";
        }else{
		print "Content-type: text/html\n\n";
		print "<a href=\"http://nyama.sytes.net:8000/listen.pls\"><img src=\"$QUERY{'imagedir'}$reprint\" alt=\"現在60秒ごとに更新\" border=\"0\"></a> $uniqueip_print\n";
        }
}

# logに書き込む
sub wlog{
	local($onair,$lasttime) = @_;
	open(OUT,"+< $logfile");
	flock(OUT,2);
	truncate(OUT,0);
	seek(OUT,0,0);
	print OUT "$onair<>$lasttime<>\n";
	close(OUT);
}

# socketでgetする
# あめぞう2000(www.amezo2000.com)のスクリプトから引っ張った
sub httpget{
	$get_url =~ /http:\/\/([^:\/]*)(:([0-9]+))?(\/.*)?/;
	$host = $1;
	$port = ($3 ne "") ? $3 : 80;
	$path = ($4 ne "") ? $4 : "/";
	$addr = (gethostbyname($host))[4];
	$name = pack("S n a4 x8", 2, $port, $addr);
	socket(S, 2, 1, 0);
	connect(S, $name);
	binmode(S);
	select(S); $| = 1; select(stdout);
	print S "GET $path HTTP/1.0\r\n"
		. "User-Agent: Mozilla/4.0 (compatible; MSIE 5.0; Windows 98)\r\n"
		. "Host: $host\r\n"
		. "Referer: $HEAD{'url'}\r\n\r\n";
	while(<S>){
		if ($_ eq "\n" || $_ eq "\r\n" || $_ eq "\r") { last; }
	}
	while(<S>){
		$data2 .= $_;
	}
	close(S);
	if($data2 =~ /$check/){
                if($data2 =~ /of 100 listeners \(([0-9]*) unique\)/){
			open(OUT,"+< $uniqueip_log");
			flock(OUT,2);
			truncate(OUT,0);
			seek(OUT,0,0);
			print OUT "$1<>\n";
			close(OUT);
                }else{
			open(OUT,"+< $uniqueip_log");
			flock(OUT,2);
			truncate(OUT,0);
			seek(OUT,0,0);
			print OUT "--<>\n";
			close(OUT);
                }
		return 1;
        }else{
		open(OUT,"+< $uniqueip_log");
		flock(OUT,2);
		truncate(OUT,0);
		seek(OUT,0,0);
		print OUT "--<>\n";
		close(OUT);
		return 0;
	}
}