implement externals via zot6 and zotfeed - part 2

1 files changed, 37 insertions, 17 deletions

diff --git a/include/items.php b/include/items.php
index 5b9bbd1f9..370aa5a93 100755
--- a/include/items.php
+++ b/include/items.php
@@ -4354,6 +4354,7 @@ function zot_feed($uid, $observer_hash, $arr) {
 	if(! is_sys_channel($uid))
 		$sql_extra = item_permissions_sql($uid,$observer_hash);
 
+
 	$limit = " LIMIT 5000 ";
 
 	if($mindate > NULL_DATE) {
@@ -4375,17 +4376,38 @@ function zot_feed($uid, $observer_hash, $arr) {
 	$item_normal = item_normal();
 
 	if(is_sys_channel($uid)) {
-
 		$nonsys_uids = q("SELECT channel_id FROM channel WHERE channel_system = 0");
 		$nonsys_uids_str = ids_to_querystr($nonsys_uids,'channel_id');
 
-		$r = q("SELECT parent, postopts FROM item
+		if ($arr['total']) {
+			$items = q("SELECT count(created) AS total FROM item
+				WHERE uid IN ( %s )
+				AND item_private = 0
+				$sql_extra $item_normal",
+				dbesc($nonsys_uids_str)
+			);
+			if ($items) {
+				return intval($items[0]['total']);
+			}
+			return 0;
+		}
+
+		$itemspage = (($channel) ? get_pconfig($uid,'system','itemspage') : 30);
+		App::set_pager_itemspage(((intval($itemspage)) ? $itemspage : 30));
+		$pager_sql = sprintf(" LIMIT %d OFFSET %d ", intval(App::$pager['itemspage']), intval(App::$pager['start']));
+
+		$items = q("SELECT item.*, item.id AS item_id FROM item
 			WHERE uid IN ( %s )
 			AND item_private = 0
-			$item_normal
-			$sql_extra ORDER BY created ASC $limit",
-			intval($nonsys_uids_str)
+			$item_normal $sql_extra
+			ORDER BY item.created DESC $pager_sql",
+			dbesc($nonsys_uids_str)
 		);
+
+		xchan_query($items);
+		$items = fetch_post_tags($items,true);
+
+		return $items;
 	}
 	else {
 		$r = q("SELECT parent, postopts FROM item
@@ -4411,7 +4433,6 @@ function zot_feed($uid, $observer_hash, $arr) {
 
 		$parents_str = ids_to_querystr($parents,'parent');
 		$sys_query = ((is_sys_channel($uid)) ? $sql_extra : '');
-		$item_normal = item_normal();
 
 		$items = q("SELECT item.*, item.id AS item_id FROM item
 			WHERE item.parent IN ( %s ) $item_normal $sys_query ",
@@ -4563,8 +4584,8 @@ function items_fetch($arr,$channel = null,$observer_hash = null,$client_mode = C
 		$pager_sql = '';
 	} else {
 		if(! $arr['total']) {
-			$itemspage = (($channel) ? get_pconfig($uid,'system','itemspage') : 20);
-			App::set_pager_itemspage(((intval($itemspage)) ? $itemspage : 20));
+			$itemspage = (($channel) ? get_pconfig($uid,'system','itemspage') : 10);
+			App::set_pager_itemspage(((intval($itemspage)) ? $itemspage : 10));
 			$pager_sql = sprintf(" LIMIT %d OFFSET %d ", intval(App::$pager['itemspage']), intval(App::$pager['start']));
 		}
 	}
@@ -4602,7 +4623,6 @@ function items_fetch($arr,$channel = null,$observer_hash = null,$client_mode = C
 	require_once('include/security.php');
 	$sql_extra .= item_permissions_sql($channel['channel_id'],$observer_hash);
 
-
 	if($arr['pages'])
 		$item_restrict = " AND item_type = " . ITEM_TYPE_WEBPAGE . " ";
 	else
@@ -4616,7 +4636,7 @@ function items_fetch($arr,$channel = null,$observer_hash = null,$client_mode = C
 		// "New Item View" - show all items unthreaded in reverse created date order
 
 		if ($arr['total']) {
-			$items = q("SELECT count(item.id) AS total FROM item
+			$items = dbq("SELECT count(item.id) AS total FROM item
 				WHERE $item_uids $item_restrict
 				$simple_update
 				$sql_extra $sql_nets $sql_extra3"
@@ -4627,11 +4647,11 @@ function items_fetch($arr,$channel = null,$observer_hash = null,$client_mode = C
 			return 0;
 		}
 
-		$items = q("SELECT item.*, item.id AS item_id FROM item
-				WHERE $item_uids $item_restrict
-				$simple_update
-				$sql_extra $sql_nets $sql_extra3
-				ORDER BY item.received DESC $pager_sql"
+		$items = dbq("SELECT item.*, item.id AS item_id FROM item
+			WHERE $item_uids $item_restrict
+			$simple_update
+			$sql_extra $sql_nets $sql_extra3
+			ORDER BY item.received DESC $pager_sql"
 		);
 
 		require_once('include/items.php');
@@ -4652,7 +4672,7 @@ function items_fetch($arr,$channel = null,$observer_hash = null,$client_mode = C
 
 			// Fetch a page full of parent items for this page
 
-			$r = q("SELECT distinct item.id AS item_id, item.$ordering FROM item
+			$r = dbq("SELECT distinct item.id AS item_id, item.$ordering FROM item
 				left join abook on item.author_xchan = abook.abook_xchan
 				WHERE $item_uids $item_restrict
 				AND item.parent = item.id
@@ -4663,7 +4683,7 @@ function items_fetch($arr,$channel = null,$observer_hash = null,$client_mode = C
 		}
 		else {
 			// update
-			$r = q("SELECT item.parent AS item_id FROM item
+			$r = dbq("SELECT item.parent AS item_id FROM item
 				left join abook on item.author_xchan = abook.abook_xchan
 				WHERE $item_uids $item_restrict $simple_update
 				and (abook.abook_blocked = 0 or abook.abook_flags is null)