[Cs-cms-commits] SF.net SVN: cs-cms:[9] trunk/0.1/abstract
Status: Alpha
Brought to you by:
crazedsanity
Menu
▾
▴
[Cs-cms-commits] SF.net SVN: cs-cms:[9] trunk/0.1/abstract
|
From: <cra...@us...> - 2009-02-20 05:48:31
|
Revision: 9
http://cs-cms.svn.sourceforge.net/cs-cms/?rev=9&view=rev
Author: crazedsanity
Date: 2009-02-20 05:48:19 +0000 (Fri, 20 Feb 2009)
Log Message:
-----------
Renaming abstract classes...
Added Paths:
-----------
trunk/0.1/abstract/cs_cms.abstract.class.php
trunk/0.1/abstract/cs_cmsDataLayer.abstract.class.php
Removed Paths:
-------------
trunk/0.1/abstract/csb_blog.abstract.class.php
trunk/0.1/abstract/csb_dataLayer.abstract.class.php
Copied: trunk/0.1/abstract/cs_cms.abstract.class.php (from rev 5, trunk/0.1/abstract/csb_blog.abstract.class.php)
===================================================================
--- trunk/0.1/abstract/cs_cms.abstract.class.php (rev 0)
+++ trunk/0.1/abstract/cs_cms.abstract.class.php 2009-02-20 05:48:19 UTC (rev 9)
@@ -0,0 +1,456 @@
+<?php
+
+require_once(dirname(__FILE__) .'/csb_dataLayer.abstract.class.php');
+
+class csb_blogAbstract extends csb_dataLayerAbstract {
+
+ /** Internal name of blog (looks like a permalink) */
+ protected $blogName;
+
+ /** Displayable name of blog */
+ protected $blogDisplayName;
+
+ /** Numeric ID of blog */
+ protected $blogId=false;
+
+ /** Location of blog */
+ protected $blogLocation;
+
+ //-------------------------------------------------------------------------
+ /**
+ * The constructor.
+ *
+ * @param $blogName (str) name of blog (NOT the display name)
+ * @param $dbType (str) Type of database (pgsql/mysql/sqlite)
+ * @param $dbParams (array) connection options for database
+ *
+ * @return exception throws an exception on error.
+ */
+ public function __construct(array $dbParams=null) {
+
+ //TODO: put these in the constructor args, or require CONSTANTS.
+ parent::__construct($dbParams);
+
+ }//end __construct()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Initializes information about the selected blog.
+ *
+ * @param $blogName (str) name of blog (NOT the display name)
+ */
+ public function initialize_locals($blogName) {
+
+ if(!is_numeric($this->blogId)) {
+ $data = $this->get_blog_data_by_name($blogName);
+
+ $var2index = array(
+ 'blogDisplayName' => 'blog_display_name',
+ 'blogName' => 'blog_name',
+ 'blogId' => 'blog_id',
+ 'blogLocation' => 'location'
+ );
+
+ foreach($var2index as $var=>$index) {
+ if(isset($data[$index]) && strlen($data[$index])) {
+ $this->$var = $data[$index];
+ }
+ else {
+ throw new exception(__METHOD__ .": var ". $var ." not set from index ". $index .", no data (". $data[$index] .")");
+ }
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": already initialized");
+ }
+ }//end initialize_locals()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Retrieves protected (or private?) internal var values
+ *
+ * @param $var (str) name of internal var to retrieve
+ *
+ * @return exception throws an exception if named var doesn't exist.
+ */
+ public function get_internal_var($var) {
+ if(isset($this->$var)) {
+ $retval = $this->$var;
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid var name (". $var .")");
+ }
+
+ return($retval);
+ }//end get_internal_var()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ public function is_initialized() {
+ $retval = false;
+ if(is_numeric($this->blogId)) {
+ $retval = true;
+ }
+ return($retval);
+ }//end is_initialized()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Creates a "permalink" just from title (does NOT include blog location):
+ * lowercases, strips special characters, uses "_" in place of spaces and
+ * special characters (NEVER creates more than one "_" in a row)
+ *
+ * @param $title (str) string to create permalink from.
+ *
+ * @return exception throws exception on error
+ * @return (string) permalink
+ */
+ public function create_permalink_from_title($title) {
+ if(is_string($title) && strlen($title) >= CSBLOG_TITLE_MINLEN) {
+
+ $permalink = strtolower($title);
+ $permalink = preg_replace('/!/', '', $permalink);
+ $permalink = preg_replace('/&\+/', '-', $permalink);
+ $permalink = preg_replace('/\'/', '', $permalink);
+ $permalink = preg_replace("/[^a-zA-Z0-9_]/", "_", $permalink);
+
+ if(!strlen($permalink)) {
+ throw new exception(__METHOD__ .": invalid filename (". $permalink .") from title=(". $title .")");
+ }
+
+ //consolidate multiple underscores... (" . . ." becomes "______", after this becomes just "_")
+ $permalink = preg_replace('/__*/', '_', $permalink);
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid title (". $title .")");
+ }
+
+ return($permalink);
+ }//end create_permalink_from_title()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Encodes content using base64
+ *
+ * @param $content (str) content to encode
+ *
+ * @return (string) encoded content.
+ */
+ public function encode_content($content) {
+ //make it base64 data, so it is easy to insert.
+ $retval = base64_encode($content);
+ return($retval);
+ }//end encode_content()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Decoded content (reverse of encode_content())
+ *
+ * @param $content (str) Encoded content to decode
+ *
+ * @return (string) Decoded content.
+ */
+ public function decode_content($content) {
+ $retval = base64_decode($content);
+ return($retval);
+ }//end decode_content()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Retrieves all data about a blog (the main entry only) by its name.
+ *
+ * @param $blogName (str) name of blog (displayable or proper)
+ *
+ * @return exception throws exceptions on error
+ * @return (array) array of data about the blog.
+ */
+ public function get_blog_data_by_name($blogName) {
+ if(strlen($blogName) > 3) {
+ $data = $this->get_blogs(array('b.blog_name'=>$blogName), 'blog_id');
+
+ if(count($data) == 1) {
+ $keys = array_keys($data);
+ $retval = $data[$keys[0]];
+ }
+ else {
+ throw new exception(__METHOD__ .": too many records returned (". count($data) .")");
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid blog name (". $blogName .")");
+ }
+
+ return($retval);
+ }//end get_blog_data_by_name()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Same as get_blog_data_by_name(), but use blog_id to find it.
+ *
+ * @param $blogId (int) blog_id to retrieve info for.
+ *
+ * @return exception throws exception on error
+ * @return (array) array of data about the blog.
+ */
+ public function get_blog_data_by_id($blogId) {
+
+ if(is_numeric($blogId) && $blogId > 0) {
+ $data = $this->get_blogs(array('blog_id'=>$blogId), 'blog_id');
+ if(count($data) == 1) {
+ $keys = array_keys($data);
+ $retval = $data[$keys[0]];
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid number of records returned (". count($data) .")");
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid blog id (". $blogId .")");
+ }
+
+ return($retval);
+ }//end get_blog_data_by_id()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Determines if there is one or more matching permalinks for the given
+ * blog; duplicates are given a suffix of "-N" (where "N" is the number of
+ * matching entries; first dup is given "-1", and so on).
+ *
+ * @param $blogId (int) blog_id for the permalink
+ * @param $permaLink (str) permalink to check
+ *
+ * @return exception thrown on error.
+ * @return
+ */
+ public function check_permalink($blogId, $permalink) {
+ if(is_string($permalink) && strlen($permalink) >= CSBLOG_TITLE_MINLEN && is_numeric($blogId) && $blogId > 0) {
+ #if($permalink == $this->create_permalink_from_title($permalink)) {
+ $permalink = $this->create_permalink_from_title($permalink);
+ $sql = "SELECT * FROM csblog_entry_table WHERE blog_id=". $blogId
+ ." AND permalink='". $permalink ."' OR permalink LIKE '". $permalink ."-%'";
+
+ $numrows = $this->run_sql($sql, false);
+
+ if($numrows >= 0) {
+ if($numrows >= 1) {
+ //got a record, give 'em the data back.
+ $retval = $permalink ."-". $numrows;
+ }
+ elseif($numrows == 0) {
+ $retval = $permalink;
+ }
+ else {
+ throw new exception(__METHOD__ .": unknown error, numrows=(". $numrows ."), dberror");
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid numrows (". $numrows .") or dberror");
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid permalink (". $permalink .") or blog_id (". $blogId .")");
+ }
+
+ return($retval);
+ }//end check_permalink()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ protected function get_age_hype($timestamp, $addBrackets=FALSE) {
+ if(strlen($timestamp >= 9)) {
+ if(!is_numeric($timestamp)) {
+ $timestamp = strtotime($timestamp);
+ }
+
+ $age = time() - $timestamp;
+ switch($age) {
+ case ($age <= 1800): {
+ $extraText = '<font color="red"><b>Ink\'s still WET!</b></font>';
+ } break;
+
+ case ($age <= 3600): {
+ //modified less than an hour ago!
+ $extraText = '<font color="red"><b>Hot off the press!</b></font>';
+ } break;
+
+ case ($age <= 86400): {
+ //modified less than 24 hours ago.
+ $extraText = '<font color="red"><b>New!</b></font>';
+ } break;
+
+ case ($age <= 604800): {
+ //modified this week.
+ $extraText = '<font color="red">Less than a week old</font>';
+ } break;
+
+ case ($age <= 2592000): {
+ //modified this month.
+ $extraText = '<b>Less than a month old</b>';
+ } break;
+
+ case ($age <= 5184000): {
+ //modified in the last 2 months
+ $extraText = '<b>Updated last month</b>';
+ } break;
+
+ case ($age <= 7776000): {
+ $extraText = '<i>Updated 3 months ago</i>';
+ } break;
+
+ case ($age <= 10368000): {
+ $extraText = '<i>Updated 4 months ago</i>';
+ } break;
+
+ case ($age <= 12960000): {
+ $extraText = '<i>Updated 5 months ago</i>';
+ } break;
+
+ case ($age <= 15552000): {
+ $extraText = '<i>Updated in the last 6 months</i>';
+ } break;
+
+ default: {
+ $extraText = '<i>pretty old</i>';
+ }
+ }
+
+ if(strlen($extraText) && $addBrackets) {
+ $extraText = '['. $extraText .']';
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid timestamp (". $timestamp .")");
+ }
+
+ return($extraText);
+ }//end get_age_hype()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ public function get_most_recent_blog() {
+ $retval = $this->get_recent_blogs(1);
+ return($retval);
+ }//end get_most_recent_blog()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ public function get_recent_blogs($limit=5, $offset=0, $includeDrafts=false) {
+ if(is_numeric($this->blogId)) {
+ if(is_numeric($limit) && $limit > 0) {
+ if(is_numeric($offset) && $offset >= 0) {
+ $criteria = array(
+ 'blog_id' => $this->blogId,
+ 'is_draft' => 'f'
+ );
+ if($includeDrafts === true) {
+ unset($criteria['is_draft']);
+ }
+ $retval = $this->get_blog_entries($criteria, 'post_timestamp DESC', $limit, $offset);
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid offset (". $offset .")");
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid limit (". $limit .")");
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": blogId not set");
+ }
+
+ return($retval);
+ }//end get_recent_blogs()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ protected function get_full_permalink($permalink) {
+ if(!strlen($this->blogLocation)) {
+ throw new exception(__METHOD__ .": missing internal blogLocation (". $this->blogLocation .")");
+ }
+ elseif(!strlen($this->blogName)) {
+ throw new exception(__METHOD__ .": missing internal blogName (". $this->blogName .")");
+ }
+ elseif(!strlen($permalink)) {
+ throw new exception(__METHOD__ .": invalid/missing permalink (". $permalink .")");
+ }
+ else {
+ $retval = $this->blogLocation .'/'. $this->blogName .'/'. $permalink;
+ }
+
+ return($retval);
+ }//end get_full_permalink()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ public function parse_full_permalink($fullPermalink) {
+
+ if(strlen($fullPermalink) && preg_match("/\//", $fullPermalink)) {
+ $fullPermalink = preg_replace("/^\//", "", $fullPermalink);
+ $parts = explode("/", $fullPermalink);
+
+ if(count($parts) >= 3) {
+ $permalink = array_pop($parts);
+ $blogName = array_pop($parts);
+ $location = "/". $this->gfObj->string_from_array($parts, NULL, "/");
+
+ $retval = array(
+ 'location' => $location,
+ 'blogName' => $blogName,
+ 'permalink' => $permalink
+ );
+ }
+ else {
+ throw new exception(__METHOD__ .": not enough parts (i.e. location, blogName, & permalink) in " .
+ "full permalink (". $fullPermalink .")");
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid or non-full permalink given (". $fullPermalink .")");
+ }
+
+ return($retval);
+ }//end parse_full_permalink()
+ //-------------------------------------------------------------------------
+
+
+
+}// end blog{}
+?>
Property changes on: trunk/0.1/abstract/cs_cms.abstract.class.php
___________________________________________________________________
Added: svn:mergeinfo
+
Copied: trunk/0.1/abstract/cs_cmsDataLayer.abstract.class.php (from rev 5, trunk/0.1/abstract/csb_dataLayer.abstract.class.php)
===================================================================
--- trunk/0.1/abstract/cs_cmsDataLayer.abstract.class.php (rev 0)
+++ trunk/0.1/abstract/cs_cmsDataLayer.abstract.class.php 2009-02-20 05:48:19 UTC (rev 9)
@@ -0,0 +1,668 @@
+<?php
+
+require_once(dirname(__FILE__) .'/../../cs-content/cs_phpDB.class.php');
+require_once(dirname(__FILE__) .'/../../cs-content/cs_globalFunctions.class.php');
+require_once(dirname(__FILE__) .'/../../cs-versionparse/cs_version.abstract.class.php');
+require_once(dirname(__FILE__) .'/../csb_location.class.php');
+require_once(dirname(__FILE__) .'/../csb_permission.class.php');
+
+
+abstract class csb_dataLayerAbstract extends cs_versionAbstract {
+
+ /** */
+ protected $gfObj;
+
+ /** */
+ private $isConnected=false;
+
+ /** */
+ protected $dbParams;
+
+ const DBTYPE='pgsql';
+
+ //-------------------------------------------------------------------------
+ /**
+ * Constructor (must be called from extending class)
+ *
+ * @param $dbType (str) type of database to connect to (pgsql/mysql/sqlite)
+ * @param $dbParams (array) list of connection parameters for selected db.
+ */
+ function __construct(array $dbParams=NULL) {
+ $this->set_version_file_location(dirname(__FILE__) . '/../VERSION');
+ $this->gfObj = new cs_globalFunctions();
+
+ //check that some required constants exist.
+ if(!defined('CSBLOG_TITLE_MINLEN')) {
+ define('CSBLOG_TITLE_MINLEN', 4);
+ }
+
+ $this->dbParams = $dbParams;
+ $this->connect_db();
+ }//end __construct()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ protected function connect_db() {
+ if($this->isConnected === false) {
+ if(is_array($this->dbParams)) {
+ $this->db = new cs_phpDB('pgsql');
+ try {
+ $this->db->connect($this->dbParams);
+ }
+ catch(exception $e) {
+ throw new exception(__METHOD__ .": failed to connect to database, DETAILS: ". $e->getMessage());
+ }
+
+ //NOTE: if the call to "connect()" fails, it should throw an exception.
+ $this->isConnected=true;
+ }
+ else {
+ //no parameters passed. Try using constants.
+
+ $constantList = array(
+ 'CSBLOG_DB_HOST' => 'host',
+ 'CSBLOG_DB_PORT' => 'port',
+ 'CSBLOG_DB_DBNAME' => 'dbname',
+ 'CSBLOG_DB_USER' => 'user',
+ 'CSBLOG_DB_PASSWORD' => 'password'
+ );
+
+ $dbParams = array();
+ foreach($constantList as $constant=>$index) {
+ $value = '';
+ if(defined($constant)) {
+ $value = constant($constant);
+ }
+ else {
+ if($index != 'password') {
+ throw new exception(__METHOD__ .": missing one or more constants for database connectivity (". $constant .")");
+ }
+ }
+ $dbParams[$index] = $value;
+ }
+ $this->db = new cs_phpDB('pgsql');
+ try {
+ $this->db->connect($dbParams);
+ }
+ catch(exception $e) {
+ throw new exception(__METHOD__ .": failed to connect to database using constants, DETAILS: ". $e->getMessage());
+ }
+
+ //NOTE: if the call to "connect()" fails, it should throw an exception.
+ $this->isConnected = true;
+ }
+ }
+ else {
+ $this->gfObj->debug_print(__METHOD__ .": already connected");
+ }
+ }//end connect_db()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ public function run_sql($sql, $exceptionOnNoRows=true) {
+ //TODO: make EVERYTHING use this method, so it can automatically connect to the database.
+ if($this->isConnected !== true) {
+ $this->connect_db();
+ }
+
+ if($this->isConnected === true) {
+ if(is_string($sql) && strlen($sql)) {
+
+ //run the statement & check the output.
+ $numrows = $this->db->exec($sql);
+ $dberror = $this->db->errorMsg();
+
+ if($exceptionOnNoRows === true && $numrows <= 0 && !strlen($dberror)) {
+ throw new exception(__METHOD__ .": no rows returned (". $numrows .")");
+ }
+ elseif(is_numeric($numrows) && !strlen($dberror)) {
+ $retval = $numrows;
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid numrows (". $numrows ."), failed to run SQL... " .
+ "DBERROR: ". $dberror ."<BR>\nSQL::: ". $sql);
+ }
+
+ }
+ else {
+ throw new exception(__METHOD__ .": no sql to run");
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": database isn't connected");
+ }
+
+ return($retval);
+ }//end run_sql()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Loads data into blank (or existing) database.
+ *
+ * @param void (void) none
+ *
+ * @return exception throws exception on error
+ * @return (int) Number of records existing in auth table.
+ */
+ public function run_setup() {
+ $retval = false;
+ $this->connect_db();
+ $this->db->beginTrans();
+ $fs = new cs_fileSystem(dirname(__FILE__) .'/../schema');
+ $mySchema = $fs->read(self::DBTYPE .'.schema.sql');
+
+ $retval = $this->db->exec($mySchema);
+
+ #$internalValues = $this->get_version(true);
+ #foreach($internalValues as $name=>$value) {
+ # $sql = "INSERT INTO csblog_internal_data_table (internal_name, internal_value) " .
+ # "VALUES ('". $name ."', '". $value ."')";
+ # $this->run_sql($sql);
+ #}
+
+ $retval = 1;
+ $this->db->commitTrans();
+ return($retval);
+ }//end run_setup()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Create a user in the database. This assumes that the blogger is in
+ * complete control of authentication, so this doesn't work if an existing
+ * mechanism is already in place.
+ *
+ * @param $username (str) username to create
+ * @param $password (str) unencrypted password for the user
+ *
+ * @return exception throws exceptions on error
+ * @return (int) UID of new user
+ */
+ public function create_user($username, $password) {
+
+ $username = $this->gfObj->cleanString($username, 'email');
+ if($username != func_get_arg(0)) {
+ throw new exception(__METHOD__ .": username contained invalid characters (". $username ." != ". func_get_arg(0) .")");
+ }
+
+ $existingUser = $this->get_uid($username);
+
+ if($existingUser === false) {
+ $encryptedPass = md5($username .'-'. $password);
+ $sql = 'INSERT INTO cs_authentication_table (username, passwd) VALUES ' .
+ "('". $username ."', '". $encryptedPass ."')";
+
+ $numrows = $this->run_sql($sql);
+
+ if($numrows == 1) {
+ $sql = "SELECT currval('cs_authentication_table_uid_seq')";
+
+ $numrows = $this->run_sql($sql);
+ if($numrows == 1) {
+ $data = $this->db->farray();
+ $retval = $data[0];
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid numrows (". $numrows .") while retrieving last inserted uid");
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": failed insert (". $numrows ."): ");
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": user exists (". $username .")");
+ }
+
+ return($retval);
+ }//end create_user()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Retrieve UID for the given username (i.e. for checking dups)
+ *
+ * @param $username (str) username to check
+ *
+ * @return exception throws exception on error
+ * @return false boolean FALSE returned if no user
+ * @return (int) UID for existing user
+ */
+ public function get_user($username) {
+
+ if(strlen($username) && is_string($username) && !is_numeric($username)) {
+ $username = $this->gfObj->cleanString($username, 'email');
+ if($username != func_get_arg(0)) {
+ throw new exception(__METHOD__ .": username contained invalid characters (". $username ." != ". func_get_arg(0) .")");
+ }
+ $sql = "SELECT * FROM cs_authentication_table WHERE username='". $username ."'";
+ $numrows = $this->run_sql($sql, false);
+
+ if($numrows == 1) {
+ $retval = $this->db->farray_fieldnames();
+ }
+ elseif($numrows == 0) {
+ $retval = false;
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid numrows (". $numrows .")");
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid data for username (". $username .")");
+ }
+
+ return($retval);
+ }//end get_user()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ public function get_uid($username) {
+ $data = $this->get_user($username);
+ if(is_bool($data) && $data === false) {
+ $retval = $data;
+ }
+ else {
+ if(is_array($data) && isset($data['uid']) && is_numeric($data['uid'])) {
+ $retval = $data['uid'];
+ }
+ else {
+ throw new exception(__METHOD__ .": failed to locate uid column in return DATA::: ". $this->gfObj->debug_print($data,0));
+ }
+ }
+
+ return($retval);
+ }//end get_uid()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Creates new blog entry.
+ *
+ * @param $blogName (str) Display name of blog.
+ * @param $owner (str/int) UID of owner (username converted to uid)
+ * @param $location (str) location of blog
+ *
+ * @return exception throws exception on error
+ * @return (int) Newly created blog_id
+ */
+ function create_blog($blogName, $owner, $location) {
+ if(!strlen($blogName)) {
+ throw new exception(__METHOD__ .": invalid blogName (". $blogName .")");
+ }
+ elseif(!strlen($owner)) {
+ throw new exception(__METHOD__ .": invalid owner (". $owner .")");
+ }
+
+ if(!is_numeric($owner)) {
+ $username = $owner;//for later
+ $owner = $this->get_uid($owner);
+ if(!is_numeric($owner) || $owner < 1) {
+ throw new exception(__METHOD__ .": unable to find UID for user (". $username .")");
+ }
+ }
+
+ //attempt to get/create the location...
+ $loc = new csb_location($this->dbParams);
+ $locationId = $loc->get_location_id($location);
+ if(!is_numeric($locationId) || $locationId < 1) {
+ //TODO: should we really be creating this automatically?
+ $locationId = $loc->add_location($location);
+ }
+
+ $formattedBlogName = $this->create_permalink_from_title($blogName);
+ $sql = "INSERT INTO csblog_blog_table ". $this->gfObj->string_from_array(
+ array(
+ 'blog_display_name' => $blogName,
+ 'blog_name' => $formattedBlogName,
+ 'uid' => $owner,
+ 'location_id' => $locationId
+ ),
+ 'insert',
+ NULL,
+ 'sql_insert'
+ );
+
+ $numrows = $this->run_sql($sql);
+
+ if($numrows == 1) {
+ //pull the blogId.
+ $retval = $this->db->get_currval('csblog_blog_table_blog_id_seq');
+
+ if(is_numeric($retval) && $retval > 0) {
+ //Initialize locals now, if it hasn't been done yet.
+ if(defined('CSBLOG_SETUP_PENDING') && !$this->is_initialized()) {
+ $this->initialize_locals($formattedBlogName);
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": new blog_id (". $retval .") is invalid");
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid numrows (". $numrows .") returned, ERROR: ". $this->db->errorMsg());
+ }
+
+ return($retval);
+ }//end create_blog()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Create new entry for existing blog.
+ *
+ * @param $blogId (int) blog_id to associate entry with.
+ * @param $authorUid (int) UID of author
+ * @param $title (str) Title of blog.
+ * @param $content (str) Contents of blog.
+ * @param $optionalData (array) optional items to specify (i.e.
+ * post_timestamp)
+ *
+ * @return exception throws an exception on error
+ * @return (array) Array of data, indexes explain values
+ */
+ public function create_entry($blogId, $authorUid, $title, $content, array $optionalData=NULL) {
+
+ //check to make sure we've got all the proper fields and they're formatted appropriately.
+ $sqlArr = array();
+ $cleanStringArr = array(
+ 'blog_id' => "integer",
+ 'author_uid' => "integer",
+ 'title' => "sql",
+ 'content' => "sql",
+ 'permalink' => "email"
+ );
+ if(is_numeric($blogId) && $blogId > 0) {
+ $sqlArr['blog_id'] = $blogId;
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid data for blogId (". $blogId .")");
+ }
+ if(is_numeric($authorUid) && $authorUid > 0) {
+ $sqlArr['author_uid'] = $authorUid;
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid data for authorUid (". $authorUid .")");
+ }
+ if(is_string($title) && strlen($title) > CSBLOG_TITLE_MINLEN) {
+ $sqlArr['title'] = $title;
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid data for title (". $title .")");
+ }
+
+ //only allow a few other optional fields (make sure they're the appropriate data type).
+ if(is_array($optionalData) && count($optionalData)) {
+
+ //Valid optional fields are defined here.
+ $validOptionalFields = array(
+ 'post_timestamp' => 'datetime',
+ 'is_draft' => 'boolean'
+ );
+
+ $intersectedArray = array_intersect_key($optionalData, $validOptionalFields);
+
+ if(is_array($intersectedArray) && count($intersectedArray)) {
+ foreach($intersectedArray as $fieldName => $value) {
+ if(!isset($sqlArr[$fieldName])) {
+ $sqlArr[$fieldName] = $value;
+ $cleanStringArr[$fieldName] = $validOptionalFields[$fieldName];
+ }
+ else {
+ throw new exception(__METHOD__ .": index (". $fieldName .") already exists");
+ }
+ }
+ }
+ }
+
+
+ //lets check to see that there is NOT already a blog like this...
+ $permalink = $this->create_permalink_from_title($title);
+ $checkLink = $this->check_permalink($blogId, $title);
+
+ if($checkLink != $permalink) {
+ $permalink = $checkLink;
+ }
+ //set some fields that can't be specified...
+ $sqlArr['permalink'] = $permalink;
+ $sqlArr['content'] = $this->encode_content($content);
+
+ //build the SQL statement.
+ $sql = "INSERT INTO csblog_entry_table ". $this->gfObj->string_from_array($sqlArr, 'insert', NULL, $cleanStringArr);
+
+ //run the statement & check the output.
+ $numrows = $this->run_sql($sql);
+
+ if(is_numeric($numrows) && $numrows == 1) {
+ $blogData = $this->get_blog_data_by_id($blogId);
+ $retval = array(
+ 'entry_id' => $this->db->get_currval('csblog_entry_table_entry_id_seq'),
+ 'full_permalink' => $this->get_full_permalink($sqlArr['permalink'])
+ );
+
+ //one final thing: update the main blog table with the newest post_timestamp.
+ $this->update_blog_last_post_timestamps();
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid numrows (". $numrows ."), failed to insert data");
+ }
+
+ return($retval);
+ }//end create_entry)
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ /**
+ * Retrieve a blog entry based on the FULL permalink (location included)
+ *
+ * @param $fullPermalink (str) Permalink (blog location + permalink) for
+ * entry.
+ *
+ * @return exception throws exception on error
+ * @return (array) Returns array of data, includes decoded content
+ */
+ public function get_blog_entry($fullPermalink) {
+ //TODO: have this use get_blog_entries()
+ //the total permalink length should be at least double the minimum title length to include a path.
+ if(strlen($fullPermalink) > (CSBLOG_TITLE_MINLEN *2)) {
+ //now get the permalink separate from the title.
+ $parts = $this->parse_full_permalink($fullPermalink);
+ $permalink = $parts['permalink'];
+ $blogName = $parts['blogName'];
+ $location = $parts['location'];
+
+ $criteria = array('bl.location'=>$location, 'b.blog_name'=>$blogName,'be.permalink'=>$permalink);
+ $data = $this->get_blog_entries($criteria,'be.entry_id');
+
+ if(count($data) == 1) {
+ $keys = array_keys($data);
+ $retval = $data[$keys[0]];
+ }
+ elseif(count($data) > 1) {
+ throw new exception(__METHOD__ .": multiple records returned for same location (". count($data) .")");
+ }
+ else {
+ throw new exception(__METHOD__ .": invalid number of records (". count($data) .") or dberror");
+ }
+ }
+ else {
+ throw new exception(__METHOD__ .": failed to meet length requirement of ". (CSBLOG_TITLE_MINLEN *2));
+ }
+
+ return($retval);
+ }//end get_blog_entry()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ public function get_blog_entries(array $criteria, $orderBy, $limit=NULL, $offset=NULL) {
+ if(!is_array($criteria) || !count($criteria)) {
+ throw new exception(__METHOD__ .": invalid criteria");
+ }
+
+ //TODO: should be specifically limited to blogs that are accessible to current user.
+ $sql = "SELECT be.*, bl.location, b.blog_display_name, be.post_timestamp::date as date_short, " .
+ "b.blog_name, a.username FROM csblog_entry_table AS be INNER JOIN " .
+ "csblog_blog_table AS b ON (be.blog_id=b.blog_id) INNER JOIN " .
+ "csblog_location_table AS bl ON (b.location_id=bl.location_id) INNER JOIN " .
+ "cs_authentication_table AS a ON (a.uid=be.author_uid) WHERE ";
+
+ //add stuff to the SQL...
+ foreach($criteria as $field=>$value) {
+ if(!preg_match('/^[a-z]{1,}\./', $field)) {
+ unset($criteria[$field]);
+ $field = "be.". $field;
+ $criteria[$field] = $value;
+ }
+ }
+ $sql .= $this->gfObj->string_from_array($criteria, 'select', NULL, 'sql');
+
+ if(strlen($orderBy)) {
+ $sql .= " ORDER BY ". $orderBy;
+ }
+
+ if(is_numeric($limit) && $limit > 0) {
+ $sql .= " LIMIT ". $limit;
+ }
+ if(is_numeric($offset) && $limit > 0) {
+ $sql .= " OFFSET ". $offset;
+ }
+
+ $numrows = $this->run_sql($sql);
+
+ $retval = $this->db->farray_fieldnames('entry_id', true, false);
+ foreach($retval as $entryId=>$data) {
+ $retval[$entryId]['age_hype'] = $this->get_age_hype($data['post_timestamp']);
+ $retval[$entryId]['content'] = $this->decode_content($data['content']);
+ $retval[$entryId]['full_permalink'] = $this->get_full_permalink($data['permalink']);
+
+ //make a formatted post_timestamp index.
+ $retval[$entryId]['formatted_post_timestamp'] =
+ strftime('%A, %B %d, %Y %I:%M %p', strtotime($data['post_timestamp']));
+
+ //format the username...
+ $retval[$entryId]['formatted_author_name'] = ucwords($data['username']);
+
+ //make "is_draft" a real boolean.
+ $retval[$entryId]['is_draft'] = $this->gfObj->interpret_bool($data['is_draft']);
+ }
+
+ return($retval);
+ }//end get_blog_entries()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ public function get_blogs(array $criteria, $orderBy=NULL, $limit=NULL, $offset=NULL) {
+ if(!is_array($criteria) || !count($criteria)) {
+ throw new exception(__METHOD__ .": invalid criteria");
+ }
+
+ //TODO: should be specifically limited to blogs that are accessible to current user.
+ $sql = "SELECT b.*, bl.location FROM csblog_blog_table AS b INNER JOIN " .
+ "csblog_location_table AS bl ON (b.location_id=bl.location_id) WHERE ";
+
+ //add stuff to the SQL...
+ foreach($criteria as $field=>$value) {
+ if(!preg_match('/^[a-z]{1,}\./', $field)) {
+ unset($criteria[$field]);
+ $field = "b.". $field;
+ $criteria[$field] = $value;
+ }
+ }
+ $sql .= $this->gfObj->string_from_array($criteria, 'select', NULL, 'sql');
+
+ if(strlen($orderBy)) {
+ $sql .= " ORDER BY ". $orderBy;
+ }
+ else {
+ $sql .= " ORDER BY b.blog_id";
+ }
+
+ if(is_numeric($limit) && $limit > 0) {
+ $sql .= " LIMIT ". $limit;
+ }
+ if(is_numeric($offset) && $limit > 0) {
+ $sql .= " OFFSET ". $offset;
+ }
+
+ $numrows = $this->run_sql($sql);
+
+ $retval = $this->db->farray_fieldnames('blog_id', true, false);
+
+ return($retval);
+ }//end get_blogs()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ protected function update_blog_data(array $updates) {
+ $sql = "UPDATE csblog_blog_table SET ".
+ $this->gfObj->string_from_array($updates, 'update', null, 'sql') .
+ " WHERE blog_id=". $this->blogId;
+
+ try {
+ $this->db->beginTrans();
+ $numrows = $this->run_sql($sql);
+
+ if($numrows == 1) {
+ $retval = $numrows;
+ $this->db->commitTrans();
+ }
+ else {
+ throw new exception(__METHOD__ .": updated invalid number of rows (". $numrows .") - transaction aborted");
+ }
+ }
+ catch(exception $e) {
+ $this->db->rollbackTrans();
+ throw new exception(__METHOD__ .": failed to update blog (". $numrows .")");
+ }
+
+ return($retval);
+ }//end update_blog_data()
+ //-------------------------------------------------------------------------
+
+
+
+ //-------------------------------------------------------------------------
+ protected function update_blog_last_post_timestamps() {
+ $sql = "update csblog_blog_table AS b SET last_post_timestamp=" .
+ "(SELECT post_timestamp FROM csblog_entry_table WHERE " .
+ "blog_id=b.blog_id ORDER BY post_timestamp DESC limit 1)";
+
+ try {
+ $retval = $this->run_sql($sql);
+ }
+ catch(exception $e) {
+ throw new exception(__METHOD__ .": failed to update last_post_timestamp for blogs, DETAILS::: ". $e->getMessage());
+ }
+
+ return($retval);
+ }//end update_blog_last_post_timestamps()
+ //-------------------------------------------------------------------------
+
+
+}//end dataLayerAbstract{}
+?>
Property changes on: trunk/0.1/abstract/cs_cmsDataLayer.abstract.class.php
___________________________________________________________________
Added: svn:mergeinfo
+
Deleted: trunk/0.1/abstract/csb_blog.abstract.class.php
===================================================================
--- trunk/0.1/abstract/csb_blog.abstract.class.php 2009-02-20 05:47:12 UTC (rev 8)
+++ trunk/0.1/abstract/csb_blog.abstract.class.php 2009-02-20 05:48:19 UTC (rev 9)
@@ -1,456 +0,0 @@
-<?php
-
-require_once(dirname(__FILE__) .'/csb_dataLayer.abstract.class.php');
-
-class csb_blogAbstract extends csb_dataLayerAbstract {
-
- /** Internal name of blog (looks like a permalink) */
- protected $blogName;
-
- /** Displayable name of blog */
- protected $blogDisplayName;
-
- /** Numeric ID of blog */
- protected $blogId=false;
-
- /** Location of blog */
- protected $blogLocation;
-
- //-------------------------------------------------------------------------
- /**
- * The constructor.
- *
- * @param $blogName (str) name of blog (NOT the display name)
- * @param $dbType (str) Type of database (pgsql/mysql/sqlite)
- * @param $dbParams (array) connection options for database
- *
- * @return exception throws an exception on error.
- */
- public function __construct(array $dbParams=null) {
-
- //TODO: put these in the constructor args, or require CONSTANTS.
- parent::__construct($dbParams);
-
- }//end __construct()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- /**
- * Initializes information about the selected blog.
- *
- * @param $blogName (str) name of blog (NOT the display name)
- */
- public function initialize_locals($blogName) {
-
- if(!is_numeric($this->blogId)) {
- $data = $this->get_blog_data_by_name($blogName);
-
- $var2index = array(
- 'blogDisplayName' => 'blog_display_name',
- 'blogName' => 'blog_name',
- 'blogId' => 'blog_id',
- 'blogLocation' => 'location'
- );
-
- foreach($var2index as $var=>$index) {
- if(isset($data[$index]) && strlen($data[$index])) {
- $this->$var = $data[$index];
- }
- else {
- throw new exception(__METHOD__ .": var ". $var ." not set from index ". $index .", no data (". $data[$index] .")");
- }
- }
- }
- else {
- throw new exception(__METHOD__ .": already initialized");
- }
- }//end initialize_locals()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- /**
- * Retrieves protected (or private?) internal var values
- *
- * @param $var (str) name of internal var to retrieve
- *
- * @return exception throws an exception if named var doesn't exist.
- */
- public function get_internal_var($var) {
- if(isset($this->$var)) {
- $retval = $this->$var;
- }
- else {
- throw new exception(__METHOD__ .": invalid var name (". $var .")");
- }
-
- return($retval);
- }//end get_internal_var()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- public function is_initialized() {
- $retval = false;
- if(is_numeric($this->blogId)) {
- $retval = true;
- }
- return($retval);
- }//end is_initialized()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- /**
- * Creates a "permalink" just from title (does NOT include blog location):
- * lowercases, strips special characters, uses "_" in place of spaces and
- * special characters (NEVER creates more than one "_" in a row)
- *
- * @param $title (str) string to create permalink from.
- *
- * @return exception throws exception on error
- * @return (string) permalink
- */
- public function create_permalink_from_title($title) {
- if(is_string($title) && strlen($title) >= CSBLOG_TITLE_MINLEN) {
-
- $permalink = strtolower($title);
- $permalink = preg_replace('/!/', '', $permalink);
- $permalink = preg_replace('/&\+/', '-', $permalink);
- $permalink = preg_replace('/\'/', '', $permalink);
- $permalink = preg_replace("/[^a-zA-Z0-9_]/", "_", $permalink);
-
- if(!strlen($permalink)) {
- throw new exception(__METHOD__ .": invalid filename (". $permalink .") from title=(". $title .")");
- }
-
- //consolidate multiple underscores... (" . . ." becomes "______", after this becomes just "_")
- $permalink = preg_replace('/__*/', '_', $permalink);
- }
- else {
- throw new exception(__METHOD__ .": invalid title (". $title .")");
- }
-
- return($permalink);
- }//end create_permalink_from_title()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- /**
- * Encodes content using base64
- *
- * @param $content (str) content to encode
- *
- * @return (string) encoded content.
- */
- public function encode_content($content) {
- //make it base64 data, so it is easy to insert.
- $retval = base64_encode($content);
- return($retval);
- }//end encode_content()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- /**
- * Decoded content (reverse of encode_content())
- *
- * @param $content (str) Encoded content to decode
- *
- * @return (string) Decoded content.
- */
- public function decode_content($content) {
- $retval = base64_decode($content);
- return($retval);
- }//end decode_content()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- /**
- * Retrieves all data about a blog (the main entry only) by its name.
- *
- * @param $blogName (str) name of blog (displayable or proper)
- *
- * @return exception throws exceptions on error
- * @return (array) array of data about the blog.
- */
- public function get_blog_data_by_name($blogName) {
- if(strlen($blogName) > 3) {
- $data = $this->get_blogs(array('b.blog_name'=>$blogName), 'blog_id');
-
- if(count($data) == 1) {
- $keys = array_keys($data);
- $retval = $data[$keys[0]];
- }
- else {
- throw new exception(__METHOD__ .": too many records returned (". count($data) .")");
- }
- }
- else {
- throw new exception(__METHOD__ .": invalid blog name (". $blogName .")");
- }
-
- return($retval);
- }//end get_blog_data_by_name()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- /**
- * Same as get_blog_data_by_name(), but use blog_id to find it.
- *
- * @param $blogId (int) blog_id to retrieve info for.
- *
- * @return exception throws exception on error
- * @return (array) array of data about the blog.
- */
- public function get_blog_data_by_id($blogId) {
-
- if(is_numeric($blogId) && $blogId > 0) {
- $data = $this->get_blogs(array('blog_id'=>$blogId), 'blog_id');
- if(count($data) == 1) {
- $keys = array_keys($data);
- $retval = $data[$keys[0]];
- }
- else {
- throw new exception(__METHOD__ .": invalid number of records returned (". count($data) .")");
- }
- }
- else {
- throw new exception(__METHOD__ .": invalid blog id (". $blogId .")");
- }
-
- return($retval);
- }//end get_blog_data_by_id()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- /**
- * Determines if there is one or more matching permalinks for the given
- * blog; duplicates are given a suffix of "-N" (where "N" is the number of
- * matching entries; first dup is given "-1", and so on).
- *
- * @param $blogId (int) blog_id for the permalink
- * @param $permaLink (str) permalink to check
- *
- * @return exception thrown on error.
- * @return
- */
- public function check_permalink($blogId, $permalink) {
- if(is_string($permalink) && strlen($permalink) >= CSBLOG_TITLE_MINLEN && is_numeric($blogId) && $blogId > 0) {
- #if($permalink == $this->create_permalink_from_title($permalink)) {
- $permalink = $this->create_permalink_from_title($permalink);
- $sql = "SELECT * FROM csblog_entry_table WHERE blog_id=". $blogId
- ." AND permalink='". $permalink ."' OR permalink LIKE '". $permalink ."-%'";
-
- $numrows = $this->run_sql($sql, false);
-
- if($numrows >= 0) {
- if($numrows >= 1) {
- //got a record, give 'em the data back.
- $retval = $permalink ."-". $numrows;
- }
- elseif($numrows == 0) {
- $retval = $permalink;
- }
- else {
- throw new exception(__METHOD__ .": unknown error, numrows=(". $numrows ."), dberror");
- }
- }
- else {
- throw new exception(__METHOD__ .": invalid numrows (". $numrows .") or dberror");
- }
- }
- else {
- throw new exception(__METHOD__ .": invalid permalink (". $permalink .") or blog_id (". $blogId .")");
- }
-
- return($retval);
- }//end check_permalink()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- protected function get_age_hype($timestamp, $addBrackets=FALSE) {
- if(strlen($timestamp >= 9)) {
- if(!is_numeric($timestamp)) {
- $timestamp = strtotime($timestamp);
- }
-
- $age = time() - $timestamp;
- switch($age) {
- case ($age <= 1800): {
- $extraText = '<font color="red"><b>Ink\'s still WET!</b></font>';
- } break;
-
- case ($age <= 3600): {
- //modified less than an hour ago!
- $extraText = '<font color="red"><b>Hot off the press!</b></font>';
- } break;
-
- case ($age <= 86400): {
- //modified less than 24 hours ago.
- $extraText = '<font color="red"><b>New!</b></font>';
- } break;
-
- case ($age <= 604800): {
- //modified this week.
- $extraText = '<font color="red">Less than a week old</font>';
- } break;
-
- case ($age <= 2592000): {
- //modified this month.
- $extraText = '<b>Less than a month old</b>';
- } break;
-
- case ($age <= 5184000): {
- //modified in the last 2 months
- $extraText = '<b>Updated last month</b>';
- } break;
-
- case ($age <= 7776000): {
- $extraText = '<i>Updated 3 months ago</i>';
- } break;
-
- case ($age <= 10368000): {
- $extraText = '<i>Updated 4 months ago</i>';
- } break;
-
- case ($age <= 12960000): {
- $extraText = '<i>Updated 5 months ago</i>';
- } break;
-
- case ($age <= 15552000): {
- $extraText = '<i>Updated in the last 6 months</i>';
- } break;
-
- default: {
- $extraText = '<i>pretty old</i>';
- }
- }
-
- if(strlen($extraText) && $addBrackets) {
- $extraText = '['. $extraText .']';
- }
- }
- else {
- throw new exception(__METHOD__ .": invalid timestamp (". $timestamp .")");
- }
-
- return($extraText);
- }//end get_age_hype()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- public function get_most_recent_blog() {
- $retval = $this->get_recent_blogs(1);
- return($retval);
- }//end get_most_recent_blog()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- public function get_recent_blogs($limit=5, $offset=0, $includeDrafts=false) {
- if(is_numeric($this->blogId)) {
- if(is_numeric($limit) && $limit > 0) {
- if(is_numeric($offset) && $offset >= 0) {
- $criteria = array(
- 'blog_id' => $this->blogId,
- 'is_draft' => 'f'
- );
- if($includeDrafts === true) {
- unset($criteria['is_draft']);
- }
- $retval = $this->get_blog_entries($criteria, 'post_timestamp DESC', $limit, $offset);
- }
- else {
- throw new exception(__METHOD__ .": invalid offset (". $offset .")");
- }
- }
- else {
- throw new exception(__METHOD__ .": invalid limit (". $limit .")");
- }
- }
- else {
- throw new exception(__METHOD__ .": blogId not set");
- }
-
- return($retval);
- }//end get_recent_blogs()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- protected function get_full_permalink($permalink) {
- if(!strlen($this->blogLocation)) {
- throw new exception(__METHOD__ .": missing internal blogLocation (". $this->blogLocation .")");
- }
- elseif(!strlen($this->blogName)) {
- throw new exception(__METHOD__ .": missing internal blogName (". $this->blogName .")");
- }
- elseif(!strlen($permalink)) {
- throw new exception(__METHOD__ .": invalid/missing permalink (". $permalink .")");
- }
- else {
- $retval = $this->blogLocation .'/'. $this->blogName .'/'. $permalink;
- }
-
- return($retval);
- }//end get_full_permalink()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- public function parse_full_permalink($fullPermalink) {
-
- if(strlen($fullPermalink) && preg_match("/\//", $fullPermalink)) {
- $fullPermalink = preg_replace("/^\//", "", $fullPermalink);
- $parts = explode("/", $fullPermalink);
-
- if(count($parts) >= 3) {
- $permalink = array_pop($parts);
- $blogName = array_pop($parts);
- $location = "/". $this->gfObj->string_from_array($parts, NULL, "/");
-
- $retval = array(
- 'location' => $location,
- 'blogName' => $blogName,
- 'permalink' => $permalink
- );
- }
- else {
- throw new exception(__METHOD__ .": not enough parts (i.e. location, blogName, & permalink) in " .
- "full permalink (". $fullPermalink .")");
- }
- }
- else {
- throw new exception(__METHOD__ .": invalid or non-full permalink given (". $fullPermalink .")");
- }
-
- return($retval);
- }//end parse_full_permalink()
- //-------------------------------------------------------------------------
-
-
-
-}// end blog{}
-?>
Deleted: trunk/0.1/abstract/csb_dataLayer.abstract.class.php
===================================================================
--- trunk/0.1/abstract/csb_dataLayer.abstract.class.php 2009-02-20 05:47:12 UTC (rev 8)
+++ trunk/0.1/abstract/csb_dataLayer.abstract.class.php 2009-02-20 05:48:19 UTC (rev 9)
@@ -1,668 +0,0 @@
-<?php
-
-require_once(dirname(__FILE__) .'/../../cs-content/cs_phpDB.class.php');
-require_once(dirname(__FILE__) .'/../../cs-content/cs_globalFunctions.class.php');
-require_once(dirname(__FILE__) .'/../../cs-versionparse/cs_version.abstract.class.php');
-require_once(dirname(__FILE__) .'/../csb_location.class.php');
-require_once(dirname(__FILE__) .'/../csb_permission.class.php');
-
-
-abstract class csb_dataLayerAbstract extends cs_versionAbstract {
-
- /** */
- protected $gfObj;
-
- /** */
- private $isConnected=false;
-
- /** */
- protected $dbParams;
-
- const DBTYPE='pgsql';
-
- //-------------------------------------------------------------------------
- /**
- * Constructor (must be called from extending class)
- *
- * @param $dbType (str) type of database to connect to (pgsql/mysql/sqlite)
- * @param $dbParams (array) list of connection parameters for selected db.
- */
- function __construct(array $dbParams=NULL) {
- $this->set_version_file_location(dirname(__FILE__) . '/../VERSION');
- $this->gfObj = new cs_globalFunctions();
-
- //check that some required constants exist.
- if(!defined('CSBLOG_TITLE_MINLEN')) {
- define('CSBLOG_TITLE_MINLEN', 4);
- }
-
- $this->dbParams = $dbParams;
- $this->connect_db();
- }//end __construct()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- protected function connect_db() {
- if($this->isConnected === false) {
- if(is_array($this->dbParams)) {
- $this->db = new cs_phpDB('pgsql');
- try {
- $this->db->connect($this->dbParams);
- }
- catch(exception $e) {
- throw new exception(__METHOD__ .": failed to connect to database, DETAILS: ". $e->getMessage());
- }
-
- //NOTE: if the call to "connect()" fails, it should throw an exception.
- $this->isConnected=true;
- }
- else {
- //no parameters passed. Try using constants.
-
- $constantList = array(
- 'CSBLOG_DB_HOST' => 'host',
- 'CSBLOG_DB_PORT' => 'port',
- 'CSBLOG_DB_DBNAME' => 'dbname',
- 'CSBLOG_DB_USER' => 'user',
- 'CSBLOG_DB_PASSWORD' => 'password'
- );
-
- $dbParams = array();
- foreach($constantList as $constant=>$index) {
- $value = '';
- if(defined($constant)) {
- $value = constant($constant);
- }
- else {
- if($index != 'password') {
- throw new exception(__METHOD__ .": missing one or more constants for database connectivity (". $constant .")");
- }
- }
- $dbParams[$index] = $value;
- }
- $this->db = new cs_phpDB('pgsql');
- try {
- $this->db->connect($dbParams);
- }
- catch(exception $e) {
- throw new exception(__METHOD__ .": failed to connect to database using constants, DETAILS: ". $e->getMessage());
- }
-
- //NOTE: if the call to "connect()" fails, it should throw an exception.
- $this->isConnected = true;
- }
- }
- else {
- $this->gfObj->debug_print(__METHOD__ .": already connected");
- }
- }//end connect_db()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- public function run_sql($sql, $exceptionOnNoRows=true) {
- //TODO: make EVERYTHING use this method, so it can automatically connect to the database.
- if($this->isConnected !== true) {
- $this->connect_db();
- }
-
- if($this->isConnected === true) {
- if(is_string($sql) && strlen($sql)) {
-
- //run the statement & check the output.
- $numrows = $this->db->exec($sql);
- $dberror = $this->db->errorMsg();
-
- if($exceptionOnNoRows === true && $numrows <= 0 && !strlen($dberror)) {
- throw new exception(__METHOD__ .": no rows returned (". $numrows .")");
- }
- elseif(is_numeric($numrows) && !strlen($dberror)) {
- $retval = $numrows;
- }
- else {
- throw new exception(__METHOD__ .": invalid numrows (". $numrows ."), failed to run SQL... " .
- "DBERROR: ". $dberror ."<BR>\nSQL::: ". $sql);
- }
-
- }
- else {
- throw new exception(__METHOD__ .": no sql to run");
- }
- }
- else {
- throw new exception(__METHOD__ .": database isn't connected");
- }
-
- return($retval);
- }//end run_sql()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- /**
- * Loads data into blank (or existing) database.
- *
- * @param void (void) none
- *
- * @return exception throws exception on error
- * @return (int) Number of records existing in auth table.
- */
- public function run_setup() {
- $retval = false;
- $this->connect_db();
- $this->db->beginTrans();
- $fs = new cs_fileSystem(dirname(__FILE__) .'/../schema');
- $mySchema = $fs->read(self::DBTYPE .'.schema.sql');
-
- $retval = $this->db->exec($mySchema);
-
- #$internalValues = $this->get_version(true);
- #foreach($internalValues as $name=>$value) {
- # $sql = "INSERT INTO csblog_internal_data_table (internal_name, internal_value) " .
- # "VALUES ('". $name ."', '". $value ."')";
- # $this->run_sql($sql);
- #}
-
- $retval = 1;
- $this->db->commitTrans();
- return($retval);
- }//end run_setup()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- /**
- * Create a user in the database. This assumes that the blogger is in
- * complete control of authentication, so this doesn't work if an existing
- * mechanism is already in place.
- *
- * @param $username (str) username to create
- * @param $password (str) unencrypted password for the user
- *
- * @return exception throws exceptions on error
- * @return (int) UID of new user
- */
- public function create_user($username, $password) {
-
- $username = $this->gfObj->cleanString($username, 'email');
- if($username != func_get_arg(0)) {
- throw new exception(__METHOD__ .": username contained invalid characters (". $username ." != ". func_get_arg(0) .")");
- }
-
- $existingUser = $this->get_uid($username);
-
- if($existingUser === false) {
- $encryptedPass = md5($username .'-'. $password);
- $sql = 'INSERT INTO cs_authentication_table (username, passwd) VALUES ' .
- "('". $username ."', '". $encryptedPass ."')";
-
- $numrows = $this->run_sql($sql);
-
- if($numrows == 1) {
- $sql = "SELECT currval('cs_authentication_table_uid_seq')";
-
- $numrows = $this->run_sql($sql);
- if($numrows == 1) {
- $data = $this->db->farray();
- $retval = $data[0];
- }
- else {
- throw new exception(__METHOD__ .": invalid numrows (". $numrows .") while retrieving last inserted uid");
- }
- }
- else {
- throw new exception(__METHOD__ .": failed insert (". $numrows ."): ");
- }
- }
- else {
- throw new exception(__METHOD__ .": user exists (". $username .")");
- }
-
- return($retval);
- }//end create_user()
- //-------------------------------------------------------------------------
-
-
-
- //-------------------------------------------------------------------------
- /**
- * Retrieve UID for the given username (i.e. for checking dups)
- *
- * @param $username (str) username to check
- *
- * @return exception throws exception on error
- * @return false boolean FALSE returned if no user
- * @return (int) UID for existing user
- */
- public function get_user($username) {
-
- if(strlen($username) && is_string($username) && !is_numeric($username)) {
- $username = $this->gfObj->cleanString($username, 'email');
- if($username != func_get_arg(0)) {
- throw new exception(__METHOD__ .": username contained invalid characters (". $username ." != ". func_get_arg(0) .")");
- }
- $sql = "SELECT * FROM cs_authentication_table WHERE username='". $username ."'";
- $numrows = $this->run_sql($sql, false);
-
- if($numrows == 1) {
- $retval = $this->db->farray_fieldnames();
- }
- elseif($numrows == 0) {
- $retval = false;
- }
- else {
- throw new exception(__METHOD__ .": invalid numrows (". $numrows .")");
- }
- }
- else {
- throw new exception(__METHOD__ .": invalid data for username (". $username ...
[truncated message content] |
