move files to new locations

git-svn-id: https://semanticscuttle.svn.sourceforge.net/svnroot/semanticscuttle/trunk@386 b3834d28-1941-0410-a4f8-b48e95affb8f

1 files changed, 552 insertions, 0 deletions

diff --git a/src/SemanticScuttle/Service/bookmarkservice.php b/src/SemanticScuttle/Service/bookmarkservice.php
new file mode 100644
index 0000000..f119593
--- /dev/null
+++ b/src/SemanticScuttle/Service/bookmarkservice.php
@@ -0,0 +1,552 @@
+<?php
+class BookmarkService {
+	var $db;
+	var $tablename;
+
+	function & getInstance(& $db) {
+		static $instance;
+		if (!isset ($instance))
+		$instance = & new BookmarkService($db);
+		return $instance;
+	}
+
+	function BookmarkService(& $db) {
+		$this->db = & $db;
+		$this->tablename = $GLOBALS['tableprefix'] .'bookmarks';
+	}
+
+	function _getbookmark($fieldname, $value, $all = false) {
+		if (!$all) {
+			$userservice = & ServiceFactory :: getServiceInstance('UserService');
+			$sId = $userservice->getCurrentUserId();
+			$range = ' AND uId = '. $sId;
+		} else {
+			$range = '';
+		}
+
+		$query = 'SELECT * FROM '. $this->getTableName() .' WHERE '. $fieldname .' = "'. $this->db->sql_escape($value) .'"'. $range;
+
+		if (!($dbresult = & $this->db->sql_query_limit($query, 1, 0))) {
+			message_die(GENERAL_ERROR, 'Could not get bookmark', '', __LINE__, __FILE__, $query, $this->db);
+			return false;
+		}
+
+		if ($row =& $this->db->sql_fetchrow($dbresult)) {
+			$output = $row;
+		} else {
+			$output =  false;
+		}
+		$this->db->sql_freeresult($dbresult);
+		return $output;
+	}
+
+	function & getBookmark($bid, $include_tags = false) {
+		if (!is_numeric($bid))
+		return;
+
+		$sql = 'SELECT * FROM '. $this->getTableName() .' WHERE bId = '. $this->db->sql_escape($bid);
+
+		if (!($dbresult = & $this->db->sql_query($sql)))
+		message_die(GENERAL_ERROR, 'Could not get vars', '', __LINE__, __FILE__, $sql, $this->db);
+
+		if ($row = & $this->db->sql_fetchrow($dbresult)) {
+			if ($include_tags) {
+				$b2tservice = & ServiceFactory :: getServiceInstance('Bookmark2TagService');
+				$row['tags'] = $b2tservice->getTagsForBookmark($bid);
+			}
+			$output = $row;			
+		} else {
+			$output = false;
+		}
+		$this->db->sql_freeresult($dbresult);
+		return $output;
+	}
+
+	function getBookmarkByAddress($address) {
+		$hash = md5($address);
+		return $this->getBookmarkByHash($hash);
+	}
+
+	function getBookmarkByHash($hash) {
+		return $this->_getbookmark('bHash', $hash, true);
+	}
+
+	/* Counts bookmarks for a user. $range = {'public', 'shared', 'private', 'all'}*/
+	function countBookmarks($uId, $range = 'public') {
+		$sql = 'SELECT COUNT(*) FROM '. $GLOBALS['tableprefix'] .'bookmarks';
+		$sql.= ' WHERE uId = '.$uId;
+		switch ($range) {
+			case 'all':
+			//no constraints
+			break;
+			case 'private':
+			$sql.= ' AND bStatus = 2';
+			break;
+			case 'shared':
+			$sql.= ' AND bStatus = 1';
+			break;			
+			case 'public':
+			default:
+			$sql.= ' AND bStatus = 0';
+			break;
+		}			
+		
+		if (!($dbresult = & $this->db->sql_query($sql))) {
+			message_die(GENERAL_ERROR, 'Could not get vars', '', __LINE__, __FILE__, $sql, $this->db);
+		}
+		return $this->db->sql_fetchfield(0, 0);
+	}
+
+	/**
+	 * Check if a bookmark may be edited by the current user
+     *
+	 * @param integer|array $bookmark Bookmark uId or bookmark array
+	 *
+	 * @return boolean True if allowed
+	 */
+	function editAllowed($bookmark)
+	{
+		if (!is_numeric($bookmark) && (!is_array($bookmark)
+			|| !is_numeric($bookmark['bId']))
+		) {
+			return false;
+		}
+
+		if (!is_array($bookmark)
+			 && !($bookmark = $this->getBookmark($bookmark))
+		) {
+			return false;
+		}
+
+		$userservice = & ServiceFactory::getServiceInstance('UserService');
+		$user = $userservice->getCurrentUser();
+
+		//user has to be either admin, or owner
+		if ($GLOBALS['adminsCanModifyBookmarksFromOtherUsers']
+			&& $userservice->isAdmin($user)
+		) {
+			return true;
+		} else {
+			return ($bookmark['uId'] == $user['uId']);
+		}
+	}
+
+	function bookmarkExists($address = false, $uid = NULL) {
+		if (!$address) {
+			return;
+		}
+
+		$address = $this->normalize($address);
+
+		$crit = array ('bHash' => md5($address));
+		if (isset ($uid)) {
+			$crit['uId'] = $uid;
+		}
+
+		$sql = 'SELECT COUNT(*) FROM '. $GLOBALS['tableprefix'] .'bookmarks WHERE '. $this->db->sql_build_array('SELECT', $crit);
+		if (!($dbresult = & $this->db->sql_query($sql))) {
+			message_die(GENERAL_ERROR, 'Could not get vars', '', __LINE__, __FILE__, $sql, $this->db);
+		}
+		if($this->db->sql_fetchfield(0, 0) > 0) {
+			$output = true; 
+		} else {
+			$output = false;
+		}
+		$this->db->sql_freeresult($dbresult);
+		return $output;
+	}
+
+	// Adds a bookmark to the database.
+	// Note that date is expected to be a string that's interpretable by strtotime().
+	function addBookmark($address, $title, $description, $privateNote, $status, $categories, $date = NULL, $fromApi = false, $fromImport = false, $sId = -1) {
+		if($sId == -1) {
+			$userservice = & ServiceFactory :: getServiceInstance('UserService');
+			$sId = $userservice->getCurrentUserId();
+		}
+
+		$address = $this->normalize($address);
+
+		// Get the client's IP address and the date; note that the date is in GMT.
+		if (getenv('HTTP_CLIENT_IP'))
+		$ip = getenv('HTTP_CLIENT_IP');
+		else
+		if (getenv('REMOTE_ADDR'))
+		$ip = getenv('REMOTE_ADDR');
+		else
+		$ip = getenv('HTTP_X_FORWARDED_FOR');
+
+		// Note that if date is NULL, then it's added with a date and time of now, and if it's present,
+		// it's expected to be a string that's interpretable by strtotime().
+		if (is_null($date) || $date == '')
+		$time = time();
+		else
+		$time = strtotime($date);
+		$datetime = gmdate('Y-m-d H:i:s', $time);
+
+		// Set up the SQL insert statement and execute it.
+		$values = array('uId' => intval($sId), 'bIp' => $ip, 'bDatetime' => $datetime, 'bModified' => $datetime, 'bTitle' => $title, 'bAddress' => $address, 'bDescription' => $description, 'bPrivateNote' => $privateNote, 'bStatus' => intval($status), 'bHash' => md5($address));
+		$sql = 'INSERT INTO '. $this->getTableName() .' '. $this->db->sql_build_array('INSERT', $values);
+		$this->db->sql_transaction('begin');
+		if (!($dbresult = & $this->db->sql_query($sql))) {
+			$this->db->sql_transaction('rollback');
+			message_die(GENERAL_ERROR, 'Could not insert bookmark', '', __LINE__, __FILE__, $sql, $this->db);
+			return false;
+		}
+		// Get the resultant row ID for the bookmark.
+		$bId = $this->db->sql_nextid($dbresult);
+		if (!isset($bId) || !is_int($bId)) {
+			$this->db->sql_transaction('rollback');
+			message_die(GENERAL_ERROR, 'Could not insert bookmark', '', __LINE__, __FILE__, $sql, $this->db);
+			return false;
+		}
+
+		$uriparts = explode('.', $address);
+		$extension = end($uriparts);
+		unset($uriparts);
+
+		$b2tservice = & ServiceFactory :: getServiceInstance('Bookmark2TagService');
+		if (!$b2tservice->attachTags($bId, $categories, $fromApi, $extension, false, $fromImport)) {
+			$this->db->sql_transaction('rollback');
+			message_die(GENERAL_ERROR, 'Could not insert bookmark', '', __LINE__, __FILE__, $sql, $this->db);
+			return false;
+		}
+		$this->db->sql_transaction('commit');
+		// Everything worked out, so return the new bookmark's bId.
+		return $bId;
+	}
+
+	function updateBookmark($bId, $address, $title, $description, $privateNote, $status, $categories, $date = NULL, $fromApi = false) {
+		if (!is_numeric($bId))
+		return false;		
+
+		// Get the client's IP address and the date; note that the date is in GMT.
+		if (getenv('HTTP_CLIENT_IP'))
+		$ip = getenv('HTTP_CLIENT_IP');
+		else
+		if (getenv('REMOTE_ADDR'))
+		$ip = getenv('REMOTE_ADDR');
+		else
+		$ip = getenv('HTTP_X_FORWARDED_FOR');
+
+		$moddatetime = gmdate('Y-m-d H:i:s', time());
+		
+		$address = $this->normalize($address);
+		
+		//check if a new address ($address) doesn't already exist for another bookmark from the same user 
+		$bookmark = $this->getBookmark($bId);
+		if($bookmark['bAddress'] != $address && $this->bookmarkExists($address, $bookmark['uId'])) {
+			message_die(GENERAL_ERROR, 'Could not update bookmark (URL already existing = '.$address.')', '', __LINE__, __FILE__);
+			return false;
+		}
+
+		// Set up the SQL update statement and execute it.
+		$updates = array('bModified' => $moddatetime, 'bTitle' => $title, 'bAddress' => $address, 'bDescription' => $description, 'bPrivateNote' => $privateNote, 'bStatus' => $status, 'bHash' => md5($address));
+
+		if (!is_null($date)) {
+			$datetime = gmdate('Y-m-d H:i:s', strtotime($date));
+			$updates[] = array('bDateTime' => $datetime);
+		}
+
+		$sql = 'UPDATE '. $GLOBALS['tableprefix'] .'bookmarks SET '. $this->db->sql_build_array('UPDATE', $updates) .' WHERE bId = '. intval($bId);
+		$this->db->sql_transaction('begin');
+
+		if (!($dbresult = & $this->db->sql_query($sql))) {
+			$this->db->sql_transaction('rollback');
+			message_die(GENERAL_ERROR, 'Could not update bookmark', '', __LINE__, __FILE__, $sql, $this->db);
+			return false;
+		}
+
+		$uriparts = explode('.', $address);
+		$extension = end($uriparts);
+		unset($uriparts);
+
+		$b2tservice = & ServiceFactory :: getServiceInstance('Bookmark2TagService');
+		if (!$b2tservice->attachTags($bId, $categories, $fromApi, $extension)) {
+			$this->db->sql_transaction('rollback');
+			message_die(GENERAL_ERROR, 'Could not update bookmark', '', __LINE__, __FILE__, $sql, $this->db);
+			return false;
+		}
+
+		$this->db->sql_transaction('commit');
+		// Everything worked out, so return true.
+		return true;
+	}
+
+	function & getBookmarks($start = 0, $perpage = NULL, $user = NULL, $tags = NULL, $terms = NULL, $sortOrder = NULL, $watched = NULL, $startdate = NULL, $enddate = NULL, $hash = NULL) {
+		// Only get the bookmarks that are visible to the current user.  Our rules:
+		//  - if the $user is NULL, that means get bookmarks from ALL users, so we need to make
+		//    sure to check the logged-in user's watchlist and get the contacts-only bookmarks from
+		//    those users. If the user isn't logged-in, just get the public bookmarks.
+		//  - if the $user is set and isn't the logged-in user, then get that user's bookmarks, and
+		//    if that user is on the logged-in user's watchlist, get the public AND contacts-only
+		//    bookmarks; otherwise, just get the public bookmarks.
+		//  - if the $user is set and IS the logged-in user, then get all bookmarks.
+
+		$userservice =& ServiceFactory::getServiceInstance('UserService');
+		$b2tservice =& ServiceFactory::getServiceInstance('Bookmark2TagService');
+		$tag2tagservice =& ServiceFactory::getServiceInstance('Tag2TagService');
+		$sId = $userservice->getCurrentUserId();
+
+		if ($userservice->isLoggedOn()) {
+			// All public bookmarks, user's own bookmarks and any shared with user
+			$privacy = ' AND ((B.bStatus = 0) OR (B.uId = '. $sId .')';
+			$watchnames = $userservice->getWatchNames($sId, true);
+			foreach($watchnames as $watchuser) {
+				$privacy .= ' OR (U.username = "'. $watchuser .'" AND B.bStatus = 1)';
+			}
+			$privacy .= ')';
+		} else {
+			// Just public bookmarks
+			$privacy = ' AND B.bStatus = 0';
+		}
+
+		// Set up the tags, if need be.
+		if (!is_array($tags) && !is_null($tags)) {
+			$tags = explode('+', trim($tags));
+		}
+
+		$tagcount = count($tags);
+		for ($i = 0; $i < $tagcount; $i ++) {
+			$tags[$i] = trim($tags[$i]);
+		}
+
+		// Set up the SQL query.
+		$query_1 = 'SELECT DISTINCT ';
+		if (SQL_LAYER == 'mysql4') {
+			$query_1 .= 'SQL_CALC_FOUND_ROWS ';
+		}
+		$query_1 .= 'B.*, U.'. $userservice->getFieldName('username');
+
+		$query_2 = ' FROM '. $userservice->getTableName() .' AS U, '. $this->getTableName() .' AS B';
+
+		$query_3 = ' WHERE B.uId = U.'. $userservice->getFieldName('primary') . $privacy;
+		if (is_null($watched)) {
+			if (!is_null($user)) {
+				$query_3 .= ' AND B.uId = '. $user;
+			}
+		} else {
+			$arrWatch = $userservice->getWatchlist($user);
+			if (count($arrWatch) > 0) {
+				$query_3_1 = '';
+				foreach($arrWatch as $row) {
+					$query_3_1 .= 'B.uId = '. intval($row) .' OR ';
+				}
+				$query_3_1 = substr($query_3_1, 0, -3);
+			} else {
+				$query_3_1 = 'B.uId = -1';
+			}
+			$query_3 .= ' AND ('. $query_3_1 .') AND B.bStatus IN (0, 1)';
+		}
+
+		$query_5 = '';
+		if($hash == null) {
+			$query_5.= ' GROUP BY B.bHash';
+		}
+
+		switch($sortOrder) {
+			case 'date_asc':
+				$query_5.= ' ORDER BY B.bModified ASC ';
+				break;
+			case 'title_desc':
+				$query_5.= ' ORDER BY B.bTitle DESC ';
+				break;
+			case 'title_asc':
+				$query_5.= ' ORDER BY B.bTitle ASC ';
+				break;
+			case 'url_desc':
+				$query_5.= ' ORDER BY B.bAddress DESC ';
+				break;
+			case 'url_asc':
+				$query_5.= ' ORDER BY B.bAddress ASC ';
+				break;
+			default:
+				$query_5.= ' ORDER BY B.bModified DESC ';
+		}
+
+		// Handle the parts of the query that depend on any tags that are present.
+		$query_4 = '';
+		for ($i = 0; $i < $tagcount; $i ++) {
+			$query_2 .= ', '. $b2tservice->getTableName() .' AS T'. $i;
+			$query_4 .= ' AND (';
+
+			$allLinkedTags = $tag2tagservice->getAllLinkedTags($this->db->sql_escape($tags[$i]), '>', $user);
+
+			while (is_array($allLinkedTags) && count($allLinkedTags)>0) {
+				$query_4 .= ' T'. $i .'.tag = "'. array_pop($allLinkedTags) .'"';
+				$query_4 .= ' OR';
+			}
+
+			$query_4 .= ' T'. $i .'.tag = "'. $this->db->sql_escape($tags[$i]) .'"';
+
+			$query_4 .= ') AND T'. $i .'.bId = B.bId';
+			//die($query_4);
+		}
+
+		// Search terms
+		if ($terms) {
+			// Multiple search terms okay
+			$aTerms = explode(' ', $terms);
+			$aTerms = array_map('trim', $aTerms);	
+
+			// Search terms in tags as well when none given
+			if (!count($tags)) {
+				$query_2 .= ' LEFT JOIN '. $b2tservice->getTableName() .' AS T ON B.bId = T.bId';
+				$dotags = true;
+			} else {
+				$dotags = false;
+			}
+
+			$query_4 = '';
+			for ($i = 0; $i < count($aTerms); $i++) {
+				$query_4 .= ' AND (B.bTitle LIKE "%'. $this->db->sql_escape($aTerms[$i]) .'%"';
+				$query_4 .= ' OR B.bDescription LIKE "%'. $this->db->sql_escape($aTerms[$i]) .'%"';
+				$query_4 .= ' OR B.bPrivateNote LIKE "'. $this->db->sql_escape($aTerms[$i]) .'%"'; //warning : search in private notes of everybody but private notes won't appear if not allowed.
+				$query_4 .= ' OR U.username = "'. $this->db->sql_escape($aTerms[$i]) .'"'; //exact match for username				
+				if ($dotags) {
+					$query_4 .= ' OR T.tag LIKE "'. $this->db->sql_escape($aTerms[$i]) .'%"';
+				}
+				$query_4 .= ')';
+			}
+		}
+
+		// Start and end dates
+		if ($startdate) {
+			$query_4 .= ' AND B.bDatetime > "'. $startdate .'"';
+		}
+		if ($enddate) {
+			$query_4 .= ' AND B.bDatetime < "'. $enddate .'"';
+		}
+
+		// Hash
+		if ($hash) {
+			$query_4 .= ' AND B.bHash = "'. $hash .'"';
+		}
+		$query = $query_1 . $query_2 . $query_3 . $query_4 . $query_5;
+
+		if (!($dbresult = & $this->db->sql_query_limit($query, intval($perpage), intval($start)))) {
+			message_die(GENERAL_ERROR, 'Could not get bookmarks', '', __LINE__, __FILE__, $query, $this->db);
+			return false;
+		}
+
+		if (SQL_LAYER == 'mysql4') {
+			$totalquery = 'SELECT FOUND_ROWS() AS total';
+		} else {
+			if ($hash) {
+				$totalquery = 'SELECT COUNT(*) AS total'. $query_2 . $query_3 . $query_4;
+			} else {
+				$totalquery = 'SELECT COUNT(DISTINCT bAddress) AS total'. $query_2 . $query_3 . $query_4;
+			}
+		}
+
+		if (!($totalresult = & $this->db->sql_query($totalquery)) || (!($row = & $this->db->sql_fetchrow($totalresult)))) {
+			message_die(GENERAL_ERROR, 'Could not get total bookmarks', '', __LINE__, __FILE__, $totalquery, $this->db);
+			return false;
+		}
+
+		$total = $row['total'];
+		$this->db->sql_freeresult($totalresult);
+
+		$bookmarks = array();
+		while ($row = & $this->db->sql_fetchrow($dbresult)) {
+			$row['tags'] = $b2tservice->getTagsForBookmark(intval($row['bId']));
+			$bookmarks[] = $row;
+		}
+
+		$this->db->sql_freeresult($dbresult);
+		$output = array ('bookmarks' => $bookmarks, 'total' => $total);
+		return $output;
+	}
+
+	function deleteBookmark($bookmarkid) {
+		$query = 'DELETE FROM '. $GLOBALS['tableprefix'] .'bookmarks WHERE bId = '. intval($bookmarkid);
+		$this->db->sql_transaction('begin');
+		if (!($dbresult = & $this->db->sql_query($query))) {
+			$this->db->sql_transaction('rollback');
+			message_die(GENERAL_ERROR, 'Could not delete bookmarks', '', __LINE__, __FILE__, $query, $this->db);
+			return false;
+		}
+		
+		
+
+		$query = 'DELETE FROM '. $GLOBALS['tableprefix'] .'bookmarks2tags WHERE bId = '. intval($bookmarkid);
+		$this->db->sql_transaction('begin');
+		if (!($dbresult = & $this->db->sql_query($query))) {
+			$this->db->sql_transaction('rollback');
+			message_die(GENERAL_ERROR, 'Could not delete bookmarks', '', __LINE__, __FILE__, $query, $this->db);
+			return false;
+		}
+
+		$this->db->sql_transaction('commit');
+		return true;
+	}
+
+	function deleteBookmarksForUser($uId) {

+		$query = 'DELETE FROM '. $GLOBALS['tableprefix'] .'bookmarks WHERE uId = '. intval($uId);

+

+		if (!($dbresult = & $this->db->sql_query($query))) {

+			message_die(GENERAL_ERROR, 'Could not delete bookmarks', '', __LINE__, __FILE__, $query, $this->db);

+			return false;

+		}

+

+		return true;

+	}
+
+	function countOthers($address) {
+		if (!$address) {
+			return false;
+		}
+
+		$userservice = & ServiceFactory :: getServiceInstance('UserService');
+		$sId = $userservice->getCurrentUserId();
+
+		if ($userservice->isLoggedOn()) {
+			// All public bookmarks, user's own bookmarks and any shared with user
+			$privacy = ' AND ((B.bStatus = 0) OR (B.uId = '. $sId .')';
+			$watchnames = $userservice->getWatchNames($sId, true);
+			foreach($watchnames as $watchuser) {
+				$privacy .= ' OR (U.username = "'. $watchuser .'" AND B.bStatus = 1)';
+			}
+			$privacy .= ')';
+		} else {
+			// Just public bookmarks
+			$privacy = ' AND B.bStatus = 0';
+		}
+
+		$sql = 'SELECT COUNT(*) FROM '. $userservice->getTableName() .' AS U, '. $GLOBALS['tableprefix'] .'bookmarks AS B WHERE U.'. $userservice->getFieldName('primary') .' = B.uId AND B.bHash = "'. md5($address) .'"'. $privacy;
+		if (!($dbresult = & $this->db->sql_query($sql))) {
+			message_die(GENERAL_ERROR, 'Could not get vars', '', __LINE__, __FILE__, $sql, $this->db);
+		}
+		
+		$output = $this->db->sql_fetchfield(0, 0) - 1;
+		$this->db->sql_freeresult($dbresult);
+		return $output;
+	}
+
+	function normalize($address) {
+		// If bookmark address doesn't contain ":", add "http://" to the start as a default protocol
+		if (strpos($address, ':') === false) {
+			$address = 'http://'. $address;
+		}
+
+		// Delete final /
+		if (substr($address, -1) == '/') {
+			$address = substr($address, 0, count($address)-2);
+		}
+
+		return $address;
+	}
+
+	function deleteAll() {
+		$query = 'TRUNCATE TABLE `'. $this->getTableName() .'`';
+		$this->db->sql_query($query);
+	}
+
+	// Properties
+	function getTableName()       { return $this->tablename; }
+	function setTableName($value) { $this->tablename = $value; }
+
+}
+
+
+
+?>