<?php
require_once 'AbstractDatabaseTest.php';

/*
 * Tests handling of inserting hits into the database, excluding them etc.
 */
class AbstractHitsTest extends AbstractDatabaseTest 
{
	
	function fs_commit_flush_pending()
	{
		ob_start();
		sleep(2); // since we use delayed insert, lets let mysql settle down and commit whatever was inserted before we flush.
		require_once(FS_ABS_PATH.'/php/commit-pending-impl.php');
		$res1 = fs_commit_pending();
		if (is_string($res1)) echo "Error committing pending hits : $res1";
		$res = ob_get_clean();
		if ($res != "")
		{
			echo "Unexpected output from commit-pending.php:\n$res";
			$this->_failed = TRUE;			
		}
	}
	
	function hit($timestamp, $ip, $site_id, $url, $referrer,$useragent)
	{
		$hit = new stdClass();
		$hit->timestamp = $timestamp;
		$hit->ip = $ip;
		$hit->site_id = $site_id;
		$hit->url = $url;
		$hit->referrer = $referrer;
		$hit->useragent= $useragent;
		return $hit;
	}

	function assertEquelsHits($hit, $actual)
	{
		$this->assertNotNull($hit, "null expect hit");
		$this->assertNotNull($actual, "null actual hit");
		if( $hit    == null) return;
		if( $actual == null) return;
	
		$this->assertEquals($hit->ip, fs_ip_to_string($actual->ip_int1, $actual->ip_int2));
		$this->assertEquals($hit->url, $actual->url);
		$this->assertEquals($hit->referrer, $actual->referer);
		$this->assertEquals($hit->useragent, $actual->useragent);
		$this->assertEquals($hit->site_id, $actual->site_id);
	}

	function insertHit($strategy,$hit,$is_rss = false)
	{
		$_SERVER['REMOTE_ADDR'] = $hit->ip;
		$_SERVER['HTTP_USER_AGENT'] = $hit->useragent;
		$_SERVER['REQUEST_URI'] = $hit->url;
		$_SERVER['HTTP_REFERER'] = $hit->referrer;

		require_once FS_ABS_PATH.'/php/db-hit.php';
		return fs_add_hit_with_with_strategy($strategy,$hit->site_id, $hit->timestamp,$is_rss);
	}


	function assertUrlEquals($expectedUrls)
	{
		$fsdb = &fs_get_db_conn();
		$urls = fs_urls_table();
		$urls = $fsdb->get_results("SELECT url from $urls");
		if (($expectedUrls == false || count($expectedUrls) == 0) && ($urls == false || $urls == null)) return;
		$this->assertTrue($urls != false, "Failed : $urls");
		if (count($expectedUrls) != count($urls)) return $this->fail("Invalid number of urls");
		$i = 0;
		foreach($expectedUrls as $url)
		{
			$actual = $urls[$i++]->url;
			$this->assertEquals($url, $actual, "URLs differ");
		}
	}
	
	function assertUseragentsEquals($expectedUseragents)
	{
		$fsdb = &fs_get_db_conn();
		$uas = fs_useragents_table();
		$uas = $fsdb->get_results("SELECT useragent from $uas");
		if (($expectedUseragents == false || count($expectedUseragents) == 0) && ($uas == false || $uas == null)) return;
		$this->assertTrue($uas != false, "Failed : $uas");
		if (count($expectedUseragents) != count($uas)) return $this->fail("Invalid number of useragents");
		$i = 0;
		foreach($expectedUseragents as $ua)
		{
			$this->assertEquals($ua, $uas[$i++]->useragent, "Useragents differ");
		}
	}
}
?>