<?php
	#code copyright alex bosworth licence under gpl
	require_once('magpierss-0.71.1/rss_fetch.inc');
	
	function importFeedsFromSites() {
		$sql = "
		SELECT siteId, URL
		FROM mirrors";
		
		$result = mysql_query($sql) or die($sql.mysql_error());
		
		while ($row = mysql_fetch_assoc($result)) {
			importFeedIntoDatabase($row['URL']);
		}
	}
	
	function initialize() {
		$mlink = mysql_connect("localhost","root","") or die(mysql_error());
		mysql_select_db("phpsourcecaster") or die(mysql_error());	
	}

	function getFeed($url) {
		return fetch_rss( $url );
	}

	function importItems($RSSitems) {
		foreach ($RSSitems as $item) {
			$bookmark = mapItemToBookmark($item);
			if (!(bookmarkExists($bookmark))) {
				addBookMark($bookmark);
			}
		}
	}
	
	function mapItemToBookmark($item, $siteId = '1') {
		$bookmark['title'] = $item['title'];
		$bookmark['link'] = $item['link'];
		$bookmark['description'] = $item['description'];
		$bookmark['author'] = $item['dc']['creator'];
		$bookmark['date'] = $item['dc']['date'];
		$bookmark['tags'] = $item['dc']['subject'];
		$bookmark['siteId'] = $siteId;
		return $bookmark;
	}
	
	function bookmarkHash($bookmark) {
		return md5($bookmark['link'].
			$bookmark['author'].
			$bookmark['siteId']);
	}
	
	function addBookMark($bookmark) {	
		$sql = "
		INSERT INTO bookmarks 
		SET title = '".mysql_real_escape_string($bookmark['title'])."',
		link = '".mysql_real_escape_string($bookmark['link'])."',
		description = '".mysql_real_escape_string($bookmark['description'])."',
		author = '".mysql_real_escape_string($bookmark['author'])."',
		date = '".$bookmark['date']."',
		tags = '".mysql_real_escape_string($bookmark['tags'])."',
		hash = '".mysql_real_escape_string(bookmarkHash($bookmark))."',
		bookmarksite = '$bookmark[siteId]'
		";
		mysql_query($sql) or die($sql.mysql_error());
	}	

	function bookmarkExists($bookmark) {
		$sql = "
		SELECT hash FROM bookmarks
		WHERE hash = '".mysql_real_escape_string(bookmarkHash($bookmark))."'";
				
		$result = mysql_query($sql) or die($sql.mysql_error());
		
		if (mysql_fetch_row($result)) return true;
		else return false;
	}

	function importFeedIntoDatabase($url) {
		$rss = getFeed($url);
		importItems($rss->items);
	}

	initialize();
	importFeedsFromSites();

?>