169 lines
4.3 KiB
PHP
169 lines
4.3 KiB
PHP
<?php
|
|
namespace Zotlabs\Module;
|
|
|
|
require_once('include/conversation.php');
|
|
|
|
|
|
class Pubstream extends \Zotlabs\Web\Controller {
|
|
|
|
function get($update = 0, $load = false) {
|
|
|
|
if($load)
|
|
$_SESSION['loadtime'] = datetime_convert();
|
|
|
|
|
|
if(observer_prohibited(true)) {
|
|
return login();
|
|
}
|
|
|
|
|
|
if(get_config('system','disable_discover_tab'))
|
|
return;
|
|
|
|
$item_normal = item_normal();
|
|
|
|
if(! $update) {
|
|
|
|
$maxheight = get_config('system','home_divmore_height');
|
|
if(! $maxheight)
|
|
$maxheight = 400;
|
|
|
|
$o .= '<div id="live-pubstream"></div>' . "\r\n";
|
|
$o .= "<script> var profile_uid = " . ((intval(local_channel())) ? local_channel() : (-1))
|
|
. "; var profile_page = " . \App::$pager['page']
|
|
. "; divmore_height = " . intval($maxheight) . "; </script>\r\n";
|
|
|
|
\App::$page['htmlhead'] .= replace_macros(get_markup_template("build_query.tpl"),array(
|
|
'$baseurl' => z_root(),
|
|
'$pgtype' => 'pubstream',
|
|
'$uid' => ((local_channel()) ? local_channel() : '0'),
|
|
'$gid' => '0',
|
|
'$cid' => '0',
|
|
'$cmin' => '0',
|
|
'$cmax' => '99',
|
|
'$star' => '0',
|
|
'$liked' => '0',
|
|
'$conv' => '0',
|
|
'$spam' => '0',
|
|
'$fh' => '1',
|
|
'$nouveau' => '0',
|
|
'$wall' => '0',
|
|
'$list' => '0',
|
|
'$page' => ((\App::$pager['page'] != 1) ? \App::$pager['page'] : 1),
|
|
'$search' => '',
|
|
'$order' => 'comment',
|
|
'$file' => '',
|
|
'$cats' => '',
|
|
'$tags' => '',
|
|
'$dend' => '',
|
|
'$mid' => '',
|
|
'$verb' => '',
|
|
'$dbegin' => ''
|
|
));
|
|
}
|
|
|
|
if($update && ! $load) {
|
|
// only setup pagination on initial page view
|
|
$pager_sql = '';
|
|
}
|
|
else {
|
|
\App::set_pager_itemspage(20);
|
|
$pager_sql = sprintf(" LIMIT %d OFFSET %d ", intval(\App::$pager['itemspage']), intval(\App::$pager['start']));
|
|
}
|
|
|
|
require_once('include/channel.php');
|
|
require_once('include/security.php');
|
|
|
|
if(get_config('system','site_firehose')) {
|
|
$uids = " and item.uid in ( " . stream_perms_api_uids(PERMS_PUBLIC) . " ) and item_private = 0 and item_wall = 1 ";
|
|
}
|
|
else {
|
|
$sys = get_sys_channel();
|
|
$uids = " and item.uid = " . intval($sys['channel_id']) . " ";
|
|
$sql_extra = item_permissions_sql($sys['channel_id']);
|
|
\App::$data['firehose'] = intval($sys['channel_id']);
|
|
}
|
|
|
|
if(get_config('system','public_list_mode'))
|
|
$page_mode = 'list';
|
|
else
|
|
$page_mode = 'client';
|
|
|
|
|
|
$simple_update = (($update) ? " and item.item_unseen = 1 " : '');
|
|
|
|
if($update && $_SESSION['loadtime'])
|
|
$simple_update = " AND (( item_unseen = 1 AND item.changed > '" . datetime_convert('UTC','UTC',$_SESSION['loadtime']) . "' ) OR item.changed > '" . datetime_convert('UTC','UTC',$_SESSION['loadtime']) . "' ) ";
|
|
if($load)
|
|
$simple_update = '';
|
|
|
|
//logger('update: ' . $update . ' load: ' . $load);
|
|
|
|
if($update) {
|
|
|
|
$ordering = "commented";
|
|
|
|
if($load) {
|
|
|
|
// Fetch a page full of parent items for this page
|
|
|
|
$r = q("SELECT distinct item.id AS item_id, $ordering FROM item
|
|
left join abook on item.author_xchan = abook.abook_xchan
|
|
WHERE true $uids $item_normal
|
|
AND item.parent = item.id
|
|
and (abook.abook_blocked = 0 or abook.abook_flags is null)
|
|
$sql_extra3 $sql_extra $sql_nets
|
|
ORDER BY $ordering DESC $pager_sql "
|
|
);
|
|
|
|
|
|
}
|
|
elseif($update) {
|
|
|
|
$r = q("SELECT distinct item.id AS item_id, $ordering FROM item
|
|
left join abook on item.author_xchan = abook.abook_xchan
|
|
WHERE true $uids $item_normal
|
|
AND item.parent = item.id $simple_update
|
|
and (abook.abook_blocked = 0 or abook.abook_flags is null)
|
|
$sql_extra3 $sql_extra $sql_nets"
|
|
);
|
|
$_SESSION['loadtime'] = datetime_convert();
|
|
}
|
|
// Then fetch all the children of the parents that are on this page
|
|
$parents_str = '';
|
|
$update_unseen = '';
|
|
|
|
if($r) {
|
|
|
|
$parents_str = ids_to_querystr($r,'item_id');
|
|
|
|
$items = q("SELECT item.*, item.id AS item_id FROM item
|
|
WHERE true $uids $item_normal
|
|
AND item.parent IN ( %s )
|
|
$sql_extra ",
|
|
dbesc($parents_str)
|
|
);
|
|
|
|
xchan_query($items,true,(-1));
|
|
$items = fetch_post_tags($items,true);
|
|
$items = conv_sort($items,$ordering);
|
|
}
|
|
else {
|
|
$items = array();
|
|
}
|
|
|
|
}
|
|
|
|
// fake it
|
|
$mode = ('network');
|
|
|
|
$o .= conversation($a,$items,$mode,$update,$page_mode);
|
|
|
|
if(($items) && (! $update))
|
|
$o .= alt_pager($a,count($items));
|
|
|
|
return $o;
|
|
|
|
}
|
|
}
|