diff options
Diffstat (limited to 'engine/lib/river.php')
| -rw-r--r-- | engine/lib/river.php | 275 |
1 files changed, 134 insertions, 141 deletions
diff --git a/engine/lib/river.php b/engine/lib/river.php index a446886d8..36e9b9eb1 100644 --- a/engine/lib/river.php +++ b/engine/lib/river.php @@ -145,41 +145,20 @@ } /** - * Extract a list of river events from the current system log. - * This function retrieves the objects from the system log and will attempt to render - * the view "river/CLASSNAME/EVENT" where CLASSNAME is the class of the object the system event is referring to, - * and EVENT is the event (create, update, delete etc). - * - * This view will be passed the log entry (as 'log_entry') and the object (as 'object') which will be accessable - * through the $vars[] array. - * - * It returns an array of the result of each of these views. - * - * \TODO: Limit to just one user or just one user's friends - * \TODO: Make this more efficient / reduce DB queries. + * Perform a somewhat complicated query to extract river data from the system log based on available views. * - * @param int $by_user The user who initiated the event. - * @param string $relationship Limit return results to only those users who $by_user has $relationship with. - * @param int $limit Maximum number of events to show - * @param int $offset An offset - * @return array of river entities rendered with the appropriate view. + * NOTE: Do not use this function directly. It is called elsewhere and is subject to change without warning. + * + * @param unknown_type $by_user + * @param unknown_type $relationship + * @param unknown_type $limit + * @param unknown_type $offset + * @return unknown */ - function get_river_entries($by_user = "", $relationship = "", $limit = 10, $offset = 0) + function __get_river_from_log($by_user = "", $relationship = "", $limit = 10, $offset = 0) { global $CONFIG; - $limit = (int)$limit; - $offset = (int)$offset; - $relationship = sanitise_string($relationship); - - if (is_array($by_user) && sizeof($by_user) > 0) { - foreach($by_user as $key => $val) { - $by_user[$key] = (int) $val; - } - } else { - $by_user = array((int)$by_user); - } - // Get all potential river events from available view $river_events = array(); foreach (elgg_view_tree('river') as $view) @@ -209,42 +188,80 @@ } // Construct query - // Objects - $n = 0; - foreach ($river_events as $details) - { - // Get what we're talking about - - if ($details['subtype'] == 'default') $details['subtype'] = ''; - - if (($details['type']) && ($details['event'])) { - if ($n>0) $obj_query .= " or "; - - $obj_query .= "( sl.object_type='{$details['type']}' and sl.object_subtype='{$details['subtype']}' and sl.event='{$details['event']}' )"; - - $n++; - } - - } + // Objects + $n = 0; + foreach ($river_events as $details) + { + // Get what we're talking about - // User - $user = "sl.performed_by_guid in (".implode(',', $by_user).")"; + if ($details['subtype'] == 'default') $details['subtype'] = ''; - // Relationship - $relationship_query = ""; - $relationship_join = ""; - if ($relationship) - { - $relationship_join = " join {$CONFIG->dbprefix}entity_relationships r on sl.performed_by_guid=r.entity_guid "; - $relationship_query = "r.relationship = '$relationship'"; + if (($details['type']) && ($details['event'])) { + if ($n>0) $obj_query .= " or "; + + $obj_query .= "( sl.object_type='{$details['type']}' and sl.object_subtype='{$details['subtype']}' and sl.event='{$details['event']}' )"; + + $n++; } - - $query = "SELECT sl.* from {$CONFIG->dbprefix}system_log sl $relationship_join where $user and $relationship_query ($obj_query) order by sl.time_created desc limit $offset, $limit"; + + } + // User + $user = "sl.performed_by_guid in (".implode(',', $by_user).")"; + + // Relationship + $relationship_query = ""; + $relationship_join = ""; + if ($relationship) + { + $relationship_join = " join {$CONFIG->dbprefix}entity_relationships r on sl.performed_by_guid=r.entity_guid "; + $relationship_query = "r.relationship = '$relationship'"; + } + + $query = "SELECT sl.* from {$CONFIG->dbprefix}system_log sl $relationship_join where $user and $relationship_query ($obj_query) order by sl.time_created desc limit $offset, $limit"; // fetch data from system log (needs optimisation) - $log_data = get_data($query); + return get_data($query); + } + + /** + * Extract a list of river events from the current system log. + * This function retrieves the objects from the system log and will attempt to render + * the view "river/CLASSNAME/EVENT" where CLASSNAME is the class of the object the system event is referring to, + * and EVENT is the event (create, update, delete etc). + * + * This view will be passed the log entry (as 'log_entry') and the object (as 'object') which will be accessable + * through the $vars[] array. + * + * It returns an array of the result of each of these views. + * + * \TODO: Limit to just one user or just one user's friends + * \TODO: Make this more efficient / reduce DB queries. + * + * @param int $by_user The user who initiated the event. + * @param string $relationship Limit return results to only those users who $by_user has $relationship with. + * @param int $limit Maximum number of events to show + * @param int $offset An offset + * @return array of river entities rendered with the appropriate view. + */ + function get_river_entries($by_user = "", $relationship = "", $limit = 10, $offset = 0) + { + global $CONFIG; + $limit = (int)$limit; + $offset = (int)$offset; + $relationship = sanitise_string($relationship); + + if (is_array($by_user) && sizeof($by_user) > 0) { + foreach($by_user as $key => $val) { + $by_user[$key] = (int) $val; + } + } else { + $by_user = array((int)$by_user); + } + + // Get river data + $log_data = __get_river_from_log($by_user, $relationship, $limit, $offset); // until count reached, loop through and render $river = array(); @@ -334,107 +351,83 @@ */ function get_river_entries_as_opendd($by_user = "", $relationship = "", $limit = 10, $offset = 0) { - // set start limit and offset - $cnt = $limit; // Didn' cast to int here deliberately - $off = $offset; // here too + global $CONFIG; + + $limit = (int)$limit; + $offset = (int)$offset; + $relationship = sanitise_string($relationship); if (is_array($by_user) && sizeof($by_user) > 0) { foreach($by_user as $key => $val) { $by_user[$key] = (int) $val; } } else { - $by_user = (int)$by_user; + $by_user = array((int)$by_user); } - $exit = false; + // Get river data + $log_data = __get_river_from_log($by_user, $relationship, $limit, $offset); // River objects - $river = new ODDDocument(); - - do + $river = new ODDDocument(); + if ($log_data) { - $log_events = get_system_log($by_user, "","", $cnt, $off); - - if (!$log_events) - $exit = true; - else - { - - foreach ($log_events as $log) + foreach ($log_data as $log) + { + $event = $log->event; + $class = $log->object_class; + $type = $log->object_type; + $subtype = $log->object_subtype; + $tmp = new $class(); + $object = $tmp->getObjectFromID($log->object_id); + $by_user_obj = get_entity($log->performed_by_guid); + + // Belts and braces + if ($object instanceof $class) { - // See if we have access to the object we're talking about - $event = $log->event; - $class = $log->object_class; - $tmp = new $class(); - $object = $tmp->getObjectFromID($log->object_id); - - // Exists and we have access to it - // if (is_a($object, $class)) - if ($object instanceof $class) - { - // If no relationship defined or it matches $relationship - if ( - (!$relationship) || - ( - ($relationship) && - (check_entity_relationship($by_user, $relationship, $tmp->getObjectOwnerGUID())) - ) - ) - { - $relationship_obj = NULL; + $relationship_obj = NULL; - // Handle updates of entities - if ($object instanceof ElggEntity) - { - $relationship_obj = new ODDRelationship( - guid_to_uuid($log->performed_by_guid), - $log->event, - guid_to_uuid($log->object_id) - ); - } - - // Handle updates of metadata - if ($object instanceof ElggExtender) - { - $odd = $object->export(); - $relationship_obj = new ODDRelationship( - guid_to_uuid($log->performed_by_guid), - $log->event, - $odd->getAttribute('uuid') - ); - } + // Handle updates of entities + if ($object instanceof ElggEntity) + { + $relationship_obj = new ODDRelationship( + guid_to_uuid($log->performed_by_guid), + $log->event, + guid_to_uuid($log->object_id) + ); + } - // Handle updates of relationships - if ($object instanceof ElggRelationship) - { - $odd = $object->export(); - $relationship_obj = new ODDRelationship( - guid_to_uuid($log->performed_by_guid), - $log->event, - $odd->getAttribute('uuid') - ); - //$relationship_obj = $object->export(); // I figure this is what you're actually interested in in this instance. - } + // Handle updates of metadata + if ($object instanceof ElggExtender) + { + $odd = $object->export(); + $relationship_obj = new ODDRelationship( + guid_to_uuid($log->performed_by_guid), + $log->event, + $odd->getAttribute('uuid') + ); + } - // If we have handled it then add it to the document - if ($relationship_obj) { - $relationship_obj->setPublished($log->time_created); - $river->addElement($relationship_obj); - } + // Handle updates of relationships + if ($object instanceof ElggRelationship) + { + $odd = $object->export(); + $relationship_obj = new ODDRelationship( + guid_to_uuid($log->performed_by_guid), + $log->event, + $odd->getAttribute('uuid') + ); + } - } + // If we have handled it then add it to the document + if ($relationship_obj) { + $relationship_obj->setPublished($log->time_created); + $river->addElement($relationship_obj); } - - // Increase offset - $off++; } } - - } while ( - ($cnt > 0) && - (!$exit) - ); - + + } return $river; }
|