<?php

class Guestbook {
    public $db;

    public function __construct(){
        $this->db = GetDatabaseLink();
    }

    public function getEntryCount($includeDeleted = false){
        $sql = "SELECT COUNT(*) FROM guestbook WHERE isPending = 0 ";
        if (!$includeDeleted){
            $sql .= ' AND deletedEntry=0';
        }
    
        $e = $this->db->getOne($sql);
        if (DB::isError($e)){
            throw new DatabaseException('Unable to pull count of guestbook entries.', $e);
        }
        else {
            return $e;
        }
    }

	public function deleteEntriesById($ids){
		if (is_array($ids)){
			$ids = implode(', ', $ids);
		}

		$sql = 'UPDATE guestbook SET deletedEntry = 1 WHERE entryId IN ('.$ids.')';

		LogError('DEBUG: Delete from guestbook sql: '.$sql, __FILE__, __LINE__);

		$res = $this->db->query($sql);
		if (DB::isError($res)){
			throw new DatabaseException('Unable to delete selected entries.', $res);
		}
		else {
			return true;
		}
	}

    public function getEntries($start=0, $numToGet=null, $includeDeleted=false){
        $sql  = "SELECT entryid, name, lat, lng, location, comments, time, dontMap, deletedEntry ";
        $sql .= "FROM guestbook WHERE isPending = 0 ";

        if (!$includeDeleted){
            $sql .= ' AND deletedEntry = 0';
        }

        $sql .= ' ORDER BY time DESC';

        if (!is_null($numToGet)){
            $res = $this->db->limitQuery($sql, $start, $numToGet);
        }
        else {
            $res = $this->db->query($sql);
        }

        if (DB::isError($res)){
            throw new DatabaseException('Unable to pull guestbook entries.', $res);
        }

        $entries = array();
        while ($row = $res->fetchRow()){
            $entry = new GuestbookEntry();
            $entry->setProperties($row);
            $entries[] = $entry;
        }
        return $entries;
    }

    public function addPendingEntry($entry){
        $map = ($entry->DontMap=='1')?1:0;

        $sql = 'INSERT INTO guestbook (name, lat, lng, location, comments, time, dontMap, deletedEntry, isPending) ';
        $sql .= 'VALUES ('.$this->db->quoteSmart($entry->Name).', '.$this->db->quoteSmart($entry->Lat).', '.$this->db->quoteSmart($entry->Lng);
		$sql .= ', '.$this->db->quoteSmart($entry->Location).', '.$this->db->quoteSmart($entry->Comments).', CURRENT_TIMESTAMP';
		$sql .= ', '.$this->db->quoteSmart($map).', 0, 1)';

		$res = $this->db->query($sql);
		if (DB::isError($res)){
			throw new DatabaseException('Unable to add pending entry to guestbook.', $res);
		}
		else {
			$res = $this->db->getOne('SELECT LAST_INSERT_ID()');
			if (DB::isError($res)){
				throw new DatabaseException('Unable to add pending entry to guestbook.  Could not fetch new ID', $res);
			}
			else {
				return $res;
			}
		}
    }

	public function restorePendingEntry($id){
		$sql = 'SELECT entryid, name, lat, lng, location, comments, time, dontMap FROM guestbook ';
		$sql .= 'WHERE isPending=1 AND entryid = '.intval($id);

		$res = $this->db->query($sql);
		if (DB::isError($res)){
			throw new DatabaseException('Unable to pull pending entry information.', $res);
		}
		else if ($res->numRows() == 0){
			throw new Exception('Pending entry not found.', 0);
		}
		else {
			$row=$res->fetchRow();
			$entry = new GuestbookEntry();
			$entry->setProperties($row);
			return $entry;
		}
	}

	public function removePendingEntry($id){
		$res = $this->db->query('DELETE FROM guestbook WHERE entryid = '.intval($id).' AND isPending=1');
		if (DB::isError($res)){
			throw new DatabaseException('Unable to delete pending entry.');
		}
		else {
			return true;
		}
	}

	public function add($entry){
		if (!$entry->isPendingEntry()){
			$id = $this->addPendingEntry($entry);
			$entry->setProperties(array('entryid'=>$id));
		}
		$sql = 'UPDATE guestbook SET isPending = 0, deletedEntry = 0 WHERE entryid = '.$entry->EntryID;
		$res = $this->db->query($sql);
		if (DB::isError($res)){
			throw new DatabaseException('Unable to add entry to guestbook.', $res);
		}
		else {
			return true;
		}
	}
}

?>