2016-04-19 03:38:38 +00:00
< ? php
2021-12-03 03:01:39 +00:00
2022-02-16 04:08:28 +00:00
namespace Code\Module ;
2016-04-19 03:38:38 +00:00
2019-04-16 04:55:59 +00:00
use App ;
2022-02-16 04:08:28 +00:00
use Code\Web\Controller ;
use Code\Lib\AccessList ;
use Code\Lib\Apps ;
use Code\Lib\PConfig ;
use Code\Lib\PermissionDescription ;
use Code\Lib\Channel ;
use Code\Lib\Navbar ;
use Code\Lib\Libacl ;
use Code\Extend\Hook ;
use Code\Render\Theme ;
2022-02-12 20:43:29 +00:00
2019-01-18 21:04:05 +00:00
2016-04-19 03:38:38 +00:00
require_once ( 'include/conversation.php' );
2021-12-02 23:02:31 +00:00
class Stream extends Controller
{
// State passed in from the Update module.
2022-08-13 02:09:50 +00:00
public int $profile_uid = 0 ;
public int $loading = 0 ;
public int $updating = 0 ;
2021-12-02 23:02:31 +00:00
public function init ()
{
if ( ! local_channel ()) {
return ;
}
// setup identity information for page
$channel = App :: get_channel ();
App :: $profile_uid = local_channel ();
App :: $data [ 'channel' ] = $channel ;
head_set_icon ( $channel [ 'xchan_photo_s' ]);
}
public function get ()
{
if ( ! local_channel ()) {
$_SESSION [ 'return_url' ] = App :: $query_string ;
2022-08-13 02:09:50 +00:00
return login ();
2021-12-02 23:02:31 +00:00
}
$o = '' ;
2022-08-21 10:50:19 +00:00
if ( $this -> loading && intval ( App :: $pager [ 'page' ]) <= 1 ) {
2021-12-02 23:02:31 +00:00
$_SESSION [ 'loadtime_stream' ] = datetime_convert ();
PConfig :: Set ( local_channel (), 'system' , 'loadtime_stream' , $_SESSION [ 'loadtime_stream' ]);
// stream is a superset of channel when it comes to notifications
$_SESSION [ 'loadtime_channel' ] = datetime_convert ();
PConfig :: Set ( local_channel (), 'system' , 'loadtime_channel' , $_SESSION [ 'loadtime_channel' ]);
}
$arr = [ 'query' => App :: $query_string ];
2022-02-12 08:50:48 +00:00
Hook :: call ( 'stream_content_init' , $arr );
2021-12-02 23:02:31 +00:00
$channel = (( isset ( App :: $data [ 'channel' ])) ? App :: $data [ 'channel' ] : null );
// if called from liveUpdate() we will not have called Stream->init() on this request and $channel will not be set
if ( ! $channel ) {
$channel = App :: get_channel ();
}
$item_normal = item_normal ();
$item_normal_update = item_normal_update ();
$group = 0 ;
2022-08-13 02:09:50 +00:00
// $nouveau indicates the output is an unthreaded timeline.
2021-12-02 23:02:31 +00:00
$nouveau = false ;
$datequery = (( x ( $_GET , 'dend' ) && is_a_date_arg ( $_GET [ 'dend' ])) ? notags ( $_GET [ 'dend' ]) : '' );
$datequery2 = (( x ( $_GET , 'dbegin' ) && is_a_date_arg ( $_GET [ 'dbegin' ])) ? notags ( $_GET [ 'dbegin' ]) : '' );
$static = (( x ( $_GET , 'static' )) ? intval ( $_GET [ 'static' ]) : 0 );
$gid = (( x ( $_GET , 'gid' )) ? $_REQUEST [ 'gid' ] : 0 );
$category = (( x ( $_REQUEST , 'cat' )) ? $_REQUEST [ 'cat' ] : '' );
$hashtags = (( x ( $_REQUEST , 'tag' )) ? $_REQUEST [ 'tag' ] : '' );
$verb = (( x ( $_REQUEST , 'verb' )) ? $_REQUEST [ 'verb' ] : '' );
$dm = (( x ( $_REQUEST , 'dm' )) ? $_REQUEST [ 'dm' ] : 0 );
2022-09-16 21:55:12 +00:00
$distance = (( x ( $_REQUEST , 'distance' )) ? $_REQUEST [ 'distance' ] : 0 );
$distance_from = (( x ( $_REQUEST , 'distance_from' )) ? notags ( trim ( $_REQUEST [ 'distance_from' ])) : '' );
2021-12-02 23:02:31 +00:00
2022-10-02 07:41:06 +00:00
if ( $distance_from ) {
$tmp = preg_split ( '/[ ,\/]/' , $distance_from );
$distance_lat = floatval ( $tmp [ 0 ]);
$distance_lon = floatval ( $tmp [ 1 ]);
if ( ! ( $distance_lat || $distance_lon )) {
$distance = 0 ;
}
}
2021-12-02 23:02:31 +00:00
$c_order = get_pconfig ( local_channel (), 'mod_stream' , 'order' , 0 );
switch ( $c_order ) {
case 0 :
$order = 'comment' ;
break ;
case 1 :
$order = 'post' ;
break ;
case 2 :
$nouveau = true ;
break ;
2022-05-25 23:00:59 +00:00
case 3 :
$order = 'received' ;
break ;
2022-09-16 21:55:12 +00:00
case 4 :
$order = 'distance' ;
break ;
2021-12-02 23:02:31 +00:00
}
2022-08-13 02:09:50 +00:00
$search = ( $_GET [ 'search' ] ? ? '' );
2021-12-02 23:02:31 +00:00
if ( $search ) {
$_GET [ 'netsearch' ] = escape_tags ( $search );
2022-09-16 21:55:12 +00:00
if ( str_starts_with ( $search , '@' )) {
2021-12-03 03:01:39 +00:00
$r = q (
" select abook_id from abook left join xchan on abook_xchan = xchan_hash where xchan_name = '%s' and abook_channel = %d limit 1 " ,
2021-12-02 23:02:31 +00:00
dbesc ( substr ( $search , 1 )),
intval ( local_channel ())
);
if ( $r ) {
$_GET [ 'cid' ] = $r [ 0 ][ 'abook_id' ];
$search = $_GET [ 'search' ] = '' ;
}
2022-09-16 21:55:12 +00:00
} elseif ( str_starts_with ( $search , '#' )) {
2021-12-02 23:02:31 +00:00
$hashtags = substr ( $search , 1 );
$search = $_GET [ 'search' ] = '' ;
}
}
if ( $datequery ) {
$order = 'post' ;
}
// filter by collection (e.g. group)
$vg = false ;
if ( $gid ) {
2022-09-16 21:55:12 +00:00
if ( str_starts_with ( $gid , ':' )) {
2021-12-02 23:02:31 +00:00
$g = substr ( $gid , 1 );
switch ( $g ) {
case '1' :
$r = [[ 'hash' => 'connections:' . $channel [ 'channel_hash' ]]];
$vg = t ( 'Connections' );
break ;
case '2' :
$r = [[ 'hash' => 'zot:' . $channel [ 'channel_hash' ]]];
$vg = t ( 'Nomad' );
break ;
case '3' :
$r = [[ 'hash' => 'activitypub:' . $channel [ 'channel_hash' ]]];
$vg = t ( 'ActivityPub' );
break ;
default :
break ;
}
} else {
2021-12-03 03:01:39 +00:00
$r = q (
" SELECT * FROM pgrp WHERE id = %d AND uid = %d LIMIT 1 " ,
2021-12-02 23:02:31 +00:00
intval ( $gid ),
intval ( local_channel ())
);
if ( ! $r ) {
if ( $this -> updating ) {
killme ();
}
notice ( t ( 'Access list not found' ) . EOL );
goaway ( z_root () . '/stream' );
}
}
$group = $gid ;
$group_hash = $r [ 0 ][ 'hash' ];
}
$default_cmin = (( Apps :: system_app_installed ( local_channel (), 'Friend Zoom' )) ? get_pconfig ( local_channel (), 'affinity' , 'cmin' , 0 ) : ( - 1 ));
$default_cmax = (( Apps :: system_app_installed ( local_channel (), 'Friend Zoom' )) ? get_pconfig ( local_channel (), 'affinity' , 'cmax' , 99 ) : ( - 1 ));
$cid = (( x ( $_GET , 'cid' )) ? intval ( $_GET [ 'cid' ]) : 0 );
$draft = (( x ( $_GET , 'draft' )) ? intval ( $_GET [ 'draft' ]) : 0 );
$star = (( x ( $_GET , 'star' )) ? intval ( $_GET [ 'star' ]) : 0 );
$liked = (( x ( $_GET , 'liked' )) ? intval ( $_GET [ 'liked' ]) : 0 );
$conv = (( x ( $_GET , 'conv' )) ? intval ( $_GET [ 'conv' ]) : 0 );
$spam = (( x ( $_GET , 'spam' )) ? intval ( $_GET [ 'spam' ]) : 0 );
$cmin = (( array_key_exists ( 'cmin' , $_GET )) ? intval ( $_GET [ 'cmin' ]) : $default_cmin );
$cmax = (( array_key_exists ( 'cmax' , $_GET )) ? intval ( $_GET [ 'cmax' ]) : $default_cmax );
$file = (( x ( $_GET , 'file' )) ? $_GET [ 'file' ] : '' );
$xchan = (( x ( $_GET , 'xchan' )) ? $_GET [ 'xchan' ] : '' );
$net = (( x ( $_GET , 'net' )) ? $_GET [ 'net' ] : '' );
$pf = (( x ( $_GET , 'pf' )) ? $_GET [ 'pf' ] : '' );
$deftag = '' ;
if ( x ( $_GET , 'search' ) || $file || ( ! $pf && $cid )) {
$nouveau = true ;
}
if ( $cid ) {
2021-12-03 03:01:39 +00:00
$cid_r = q (
" SELECT abook.abook_xchan, xchan.xchan_addr, xchan.xchan_name, xchan.xchan_url, xchan.xchan_photo_s, xchan.xchan_type from abook left join xchan on abook_xchan = xchan_hash where abook_id = %d and abook_channel = %d and abook_blocked = 0 limit 1 " ,
2021-12-02 23:02:31 +00:00
intval ( $cid ),
intval ( local_channel ())
);
if ( ! $cid_r ) {
if ( $this -> updating ) {
killme ();
}
notice ( t ( 'No such channel' ) . EOL );
goaway ( z_root () . '/stream' );
}
}
2022-08-13 02:09:50 +00:00
$status_editor = '' ;
2021-12-02 23:02:31 +00:00
if ( ! $this -> updating ) {
// search terms header
// hide the terms we use to search for videos from
// the activity_filter widget because it doesn't look very good
if ( $search && $search !== 'video]' ) {
2021-12-03 03:01:39 +00:00
$o .= replace_macros (
2022-02-12 20:43:29 +00:00
Theme :: get_template ( " section_title.tpl " ),
2021-12-02 23:02:31 +00:00
[ '$title' => t ( 'Search Results For:' ) . ' ' . htmlspecialchars ( $search , ENT_COMPAT , 'UTF-8' )]
);
}
$body = EMPTY_STR ;
2022-01-25 04:16:38 +00:00
Navbar :: set_selected ( 'Stream' );
2021-12-02 23:02:31 +00:00
$channel_acl = [
'allow_cid' => $channel [ 'channel_allow_cid' ],
'allow_gid' => $channel [ 'channel_allow_gid' ],
'deny_cid' => $channel [ 'channel_deny_cid' ],
'deny_gid' => $channel [ 'channel_deny_gid' ]
];
$x = [
'is_owner' => true ,
'allow_location' => (( intval ( get_pconfig ( $channel [ 'channel_id' ], 'system' , 'use_browser_location' ))) ? '1' : '' ),
'default_location' => $channel [ 'channel_location' ],
'nickname' => $channel [ 'channel_address' ],
'lockstate' => (( $channel [ 'channel_allow_cid' ] || $channel [ 'channel_allow_gid' ] || $channel [ 'channel_deny_cid' ] || $channel [ 'channel_deny_gid' ]) ? 'lock' : 'unlock' ),
2022-01-25 20:51:37 +00:00
'acl' => Libacl :: populate ( $channel_acl , true , PermissionDescription :: fromGlobalPermission ( 'view_stream' ), Libacl :: get_post_aclDialogDescription (), 'acl_dialog_post' ),
2021-12-02 23:02:31 +00:00
'permissions' => $channel_acl ,
'bang' => EMPTY_STR ,
'body' => $body ,
'visitor' => true ,
'profile_uid' => local_channel (),
'editor_autocomplete' => true ,
'bbco_autocomplete' => 'bbcode' ,
'bbcode' => true ,
'jotnets' => true ,
'reset' => t ( 'Reset form' )
];
if ( $deftag ) {
$x [ 'pretext' ] = $deftag ;
}
$status_editor = status_editor ( $x );
$o .= $status_editor ;
2022-01-25 01:26:12 +00:00
$static = Channel :: manual_conv_update ( local_channel ());
2021-12-02 23:02:31 +00:00
}
// We don't have to deal with ACL's on this page. You're looking at everything
// that belongs to you, hence you can see all of it. We will filter by group if
// desired.
$sql_options = (( $star )
? " and item_starred = 1 "
: '' );
$sql_nets = '' ;
$item_thread_top = ' AND item_thread_top = 1 ' ;
$sql_extra = '' ;
if ( $draft ) {
$item_normal = item_normal_draft ();
$sql_extra = " AND item.parent IN ( SELECT DISTINCT parent FROM item WHERE item_unpublished = 1 and item_deleted = 0 ) " ;
}
2022-08-22 09:33:44 +00:00
$title = '' ;
2021-12-02 23:02:31 +00:00
if ( $group ) {
$contacts = AccessList :: members ( local_channel (), $group );
if ( $contacts ) {
$contact_str = ids_to_querystr ( $contacts , 'xchan' , true );
} else {
$contact_str = " '0' " ;
if ( ! $this -> updating ) {
info ( t ( 'Access list is empty' ));
}
}
$item_thread_top = '' ;
$sql_extra = " AND item.parent IN ( SELECT DISTINCT parent FROM item WHERE true $sql_options AND (( author_xchan IN ( $contact_str ) OR owner_xchan in ( $contact_str )) or allow_gid like ' " . protect_sprintf ( '%<' . dbesc ( $group_hash ) . '>%' ) . " ' ) and id = parent $item_normal ) " ;
if ( ! $vg ) {
$x = AccessList :: rec_byhash ( local_channel (), $group_hash );
}
if ( $x || $vg ) {
2022-02-12 20:43:29 +00:00
$title = replace_macros ( Theme :: get_template ( " section_title.tpl " ), array (
2022-08-22 09:33:44 +00:00
'$title' => sprintf ( t ( 'Access list: %s' ), (( $vg ) ? : $x [ 'gname' ]))
2021-12-02 23:02:31 +00:00
));
}
$o = $title . $status_editor ;
} elseif ( isset ( $cid_r ) && $cid_r ) {
$item_thread_top = EMPTY_STR ;
if ( $this -> loading || $this -> updating ) {
if ( ! $pf && $nouveau ) {
$sql_extra = " AND author_xchan = ' " . dbesc ( $cid_r [ 0 ][ 'abook_xchan' ]) . " ' " ;
} else {
$ttype = (( $pf ) ? TERM_FORUM : TERM_MENTION );
$p1 = q ( " SELECT DISTINCT parent FROM item WHERE uid = " . intval ( local_channel ()) . " AND ( author_xchan = ' " . dbesc ( $cid_r [ 0 ][ 'abook_xchan' ]) . " ' OR owner_xchan = ' " . dbesc ( $cid_r [ 0 ][ 'abook_xchan' ]) . " ' ) $item_normal " );
$p2 = q ( " SELECT oid AS parent FROM term WHERE uid = " . intval ( local_channel ()) . " AND ttype = $ttype AND term = ' " . dbesc ( $cid_r [ 0 ][ 'xchan_name' ]) . " ' " );
$p_str = ids_to_querystr ( array_merge ( $p1 , $p2 ), 'parent' );
$sql_extra = " AND item.parent IN ( $p_str ) " ;
}
}
2022-02-12 20:43:29 +00:00
$title = replace_macros ( Theme :: get_template ( 'section_title.tpl' ), [
2021-12-02 23:02:31 +00:00
'$title' => '<a href="' . zid ( $cid_r [ 0 ][ 'xchan_url' ]) . '" ><img src="' . zid ( $cid_r [ 0 ][ 'xchan_photo_s' ]) . '" alt="' . urlencode ( $cid_r [ 0 ][ 'xchan_name' ]) . '" /></a> <a href="' . zid ( $cid_r [ 0 ][ 'xchan_url' ]) . '" >' . $cid_r [ 0 ][ 'xchan_name' ] . '</a>'
]);
$o = $title ;
$o .= $status_editor ;
} elseif ( $xchan ) {
2021-12-03 03:01:39 +00:00
$r = q (
" select * from xchan where xchan_hash = '%s' " ,
2021-12-02 23:02:31 +00:00
dbesc ( $xchan )
);
if ( $r ) {
$item_thread_top = '' ;
$sql_extra = " AND item.parent IN ( SELECT DISTINCT parent FROM item WHERE true $sql_options AND uid = " . intval ( local_channel ()) . " AND ( author_xchan = ' " . dbesc ( $xchan ) . " ' or owner_xchan = ' " . dbesc ( $xchan ) . " ' ) $item_normal ) " ;
2022-02-12 20:43:29 +00:00
$title = replace_macros ( Theme :: get_template ( 'section_title.tpl' ), [
2021-12-02 23:02:31 +00:00
'$title' => '<a href="' . zid ( $r [ 0 ][ 'xchan_url' ]) . '" ><img src="' . zid ( $r [ 0 ][ 'xchan_photo_s' ]) . '" alt="' . urlencode ( $r [ 0 ][ 'xchan_name' ]) . '" /></a> <a href="' . zid ( $r [ 0 ][ 'xchan_url' ]) . '" >' . $r [ 0 ][ 'xchan_name' ] . '</a>'
]);
$o = $title ;
$o .= $status_editor ;
} else {
notice ( t ( 'Invalid channel.' ) . EOL );
goaway ( z_root () . '/stream' );
}
}
if ( x ( $category )) {
$sql_extra .= protect_sprintf ( term_query ( 'item' , $category , TERM_CATEGORY ));
}
if ( x ( $hashtags )) {
$sql_extra .= protect_sprintf ( term_query ( 'item' , $hashtags , TERM_HASHTAG , TERM_COMMUNITYTAG ));
}
if ( ! $this -> updating ) {
// The special div is needed for liveUpdate to kick in for this page.
// We only launch liveUpdate if you aren't filtering in some incompatible
2022-08-13 02:09:50 +00:00
// way, and also you aren't writing a comment (discovered in javascript).
2021-12-02 23:02:31 +00:00
$maxheight = get_pconfig ( local_channel (), 'system' , 'stream_divmore_height' );
2021-12-03 03:01:39 +00:00
if ( ! $maxheight ) {
2021-12-02 23:02:31 +00:00
$maxheight = 400 ;
2021-12-03 03:01:39 +00:00
}
2021-12-02 23:02:31 +00:00
$o .= '<div id="live-stream"></div>' . " \r \n " ;
2022-09-16 21:55:12 +00:00
$o .= " <script> let profile_uid = " . local_channel ()
. " ; let profile_page = " . App :: $pager [ 'page' ]
2021-12-02 23:02:31 +00:00
. " ; divmore_height = " . intval ( $maxheight ) . " ; </script> \r \n " ;
2022-02-12 20:43:29 +00:00
App :: $page [ 'htmlhead' ] .= replace_macros ( Theme :: get_template ( 'build_query.tpl' ), [
2021-12-02 23:02:31 +00:00
'$baseurl' => z_root (),
'$pgtype' => 'stream' ,
'$uid' => (( local_channel ()) ? local_channel () : '0' ),
2022-08-22 09:33:44 +00:00
'$gid' => (( $gid ) ? : '0' ),
'$cid' => (( $cid ) ? : '0' ),
'$cmin' => (( $cmin ) ? : '(-1)' ),
'$cmax' => (( $cmax ) ? : '(-1)' ),
'$star' => (( $star ) ? : '0' ),
'$liked' => (( $liked ) ? : '0' ),
'$conv' => (( $conv ) ? : '0' ),
'$spam' => (( $spam ) ? : '0' ),
2021-12-02 23:02:31 +00:00
'$fh' => '0' ,
2022-08-22 09:33:44 +00:00
'$dm' => (( $dm ) ? : '0' ),
'$nouveau' => (( $nouveau ) ? : '0' ),
2021-12-02 23:02:31 +00:00
'$wall' => '0' ,
2022-08-22 09:33:44 +00:00
'$draft' => (( $draft ) ? : '0' ),
2021-12-02 23:02:31 +00:00
'$static' => $static ,
'$list' => (( x ( $_REQUEST , 'list' )) ? intval ( $_REQUEST [ 'list' ]) : 0 ),
'$page' => (( App :: $pager [ 'page' ] != 1 ) ? App :: $pager [ 'page' ] : 1 ),
'$search' => (( $search ) ? urlencode ( $search ) : '' ),
'$xchan' => (( $xchan ) ? urlencode ( $xchan ) : '' ),
'$order' => (( $order ) ? urlencode ( $order ) : '' ),
'$file' => (( $file ) ? urlencode ( $file ) : '' ),
'$cats' => (( $category ) ? urlencode ( $category ) : '' ),
'$tags' => (( $hashtags ) ? urlencode ( $hashtags ) : '' ),
'$dend' => $datequery ,
'$mid' => '' ,
'$verb' => (( $verb ) ? urlencode ( $verb ) : '' ),
'$net' => (( $net ) ? urlencode ( $net ) : '' ),
'$dbegin' => $datequery2 ,
'$pf' => (( $pf ) ? intval ( $pf ) : '0' ),
2022-09-16 21:55:12 +00:00
'$distance' => (( $distance ) ? intval ( $distance ) : '0' ),
'$distance_from' => (( $distance_from ) ? urlencode ( $distance_from ) : '' ),
2021-12-02 23:02:31 +00:00
]);
}
$sql_extra3 = '' ;
if ( $datequery ) {
$sql_extra3 .= protect_sprintf ( sprintf ( " AND item.created <= '%s' " , dbesc ( datetime_convert ( date_default_timezone_get (), '' , $datequery ))));
}
if ( $datequery2 ) {
$sql_extra3 .= protect_sprintf ( sprintf ( " AND item.created >= '%s' " , dbesc ( datetime_convert ( date_default_timezone_get (), '' , $datequery2 ))));
}
$sql_extra3 = (( $nouveau ) ? '' : $sql_extra3 );
if ( x ( $_GET , 'search' )) {
$search = escape_tags ( $_GET [ 'search' ]);
2022-09-16 21:55:12 +00:00
if ( str_starts_with ( $search , '#' )) {
2021-12-02 23:02:31 +00:00
$sql_extra .= term_query ( 'item' , substr ( $search , 1 ), TERM_HASHTAG , TERM_COMMUNITYTAG );
} else {
2021-12-03 03:01:39 +00:00
$sql_extra .= sprintf (
" AND (item.body like '%s' OR item.title like '%s') " ,
2021-12-02 23:02:31 +00:00
dbesc ( protect_sprintf ( '%' . $search . '%' )),
dbesc ( protect_sprintf ( '%' . $search . '%' ))
);
}
}
if ( $verb ) {
// the presence of a leading dot in the verb determines
// whether to match the type of activity or the child object.
// The name 'verb' is a holdover from the earlier XML
// ActivityStreams specification.
2022-09-16 21:55:12 +00:00
if ( str_starts_with ( $verb , '.' )) {
2021-12-02 23:02:31 +00:00
$verb = substr ( $verb , 1 );
2021-12-03 03:01:39 +00:00
$sql_extra .= sprintf (
" AND item.obj_type like '%s' " ,
2021-12-02 23:02:31 +00:00
dbesc ( protect_sprintf ( '%' . $verb . '%' ))
);
} else {
2021-12-03 03:01:39 +00:00
$sql_extra .= sprintf (
" AND item.verb like '%s' " ,
2021-12-02 23:02:31 +00:00
dbesc ( protect_sprintf ( '%' . $verb . '%' ))
);
}
}
if ( strlen ( $file )) {
$sql_extra .= term_query ( 'item' , $file , TERM_FILE );
}
if ( $dm ) {
$sql_extra .= " and item_private = 2 " ;
}
if ( $conv ) {
$item_thread_top = '' ;
if ( $nouveau ) {
$sql_extra .= " AND author_xchan = ' " . dbesc ( $channel [ 'channel_hash' ]) . " ' " ;
} else {
2021-12-03 03:01:39 +00:00
$sql_extra .= sprintf (
" AND parent IN (SELECT distinct(parent) from item where ( author_xchan = '%s' or item_mentionsme = 1 ) and item_deleted = 0 ) " ,
2021-12-02 23:02:31 +00:00
dbesc ( protect_sprintf ( $channel [ 'channel_hash' ]))
);
}
}
if ( $this -> updating && ! $this -> loading ) {
// only setup pagination on initial page view
$pager_sql = '' ;
} else {
$itemspage = get_pconfig ( local_channel (), 'system' , 'itemspage' );
App :: set_pager_itemspage ((( intval ( $itemspage )) ? $itemspage : 20 ));
$pager_sql = sprintf ( " LIMIT %d OFFSET %d " , intval ( App :: $pager [ 'itemspage' ]), intval ( App :: $pager [ 'start' ]));
}
// cmin and cmax are both -1 when the affinity tool is disabled
if (( $cmin != ( - 1 )) || ( $cmax != ( - 1 ))) {
// Not everybody who shows up in the network stream will be in your address book.
2022-08-13 02:09:50 +00:00
// By default, those that aren't are assumed to have closeness = 99; but this isn't
2021-12-02 23:02:31 +00:00
// recorded anywhere. So if cmax is 99, we'll open the search up to anybody in
// the stream with a NULL address book entry.
$sql_nets .= " AND " ;
2021-12-03 03:01:39 +00:00
if ( $cmax == 99 ) {
2021-12-02 23:02:31 +00:00
$sql_nets .= " ( " ;
2021-12-03 03:01:39 +00:00
}
2021-12-02 23:02:31 +00:00
$sql_nets .= " ( abook.abook_closeness >= " . intval ( $cmin ) . " " ;
$sql_nets .= " AND abook.abook_closeness <= " . intval ( $cmax ) . " ) " ;
2021-12-03 03:01:39 +00:00
if ( $cmax == 99 ) {
2021-12-02 23:02:31 +00:00
$sql_nets .= " OR abook.abook_closeness IS NULL ) " ;
2021-12-03 03:01:39 +00:00
}
2021-12-02 23:02:31 +00:00
}
$net_query = (( $net ) ? " left join xchan on xchan_hash = author_xchan " : '' );
$net_query2 = (( $net ) ? " and xchan_network = ' " . protect_sprintf ( dbesc ( $net )) . " ' " : '' );
$abook_uids = " and abook.abook_channel = " . local_channel () . " " ;
$uids = " and item.uid = " . local_channel () . " " ;
2021-12-03 03:01:39 +00:00
if ( get_pconfig ( local_channel (), 'system' , 'stream_list_mode' )) {
2021-12-02 23:02:31 +00:00
$page_mode = 'list' ;
2021-12-03 03:01:39 +00:00
} else {
2021-12-02 23:02:31 +00:00
$page_mode = 'client' ;
2021-12-03 03:01:39 +00:00
}
2021-12-02 23:02:31 +00:00
$simple_update = (( $this -> updating ) ? " and item_changed > = ' " . $_SESSION [ 'loadtime_stream' ] . " ' " : '' );
$parents_str = '' ;
$update_unseen = '' ;
$items = [];
2022-08-13 02:09:50 +00:00
// This fixes a very subtle bug, so I'd better explain it. You wake up in the morning or return after a day
2021-12-02 23:02:31 +00:00
// or three and look at your stream page - after opening up your browser. The first page loads just as it
// should. All of a sudden a few seconds later, page 2 will get inserted at the beginning of the page
// (before the page 1 content). The update code is actually doing just what it's supposed
// to, it's fetching posts that have the ITEM_UNSEEN bit set. But the reason that page 2 content is being
// returned in an UPDATE is because you hadn't gotten that far yet - you're still on page 1 and everything
// that we loaded for page 1 is now marked as seen. But the stuff on page 2 hasn't been. So... it's being
// treated as "new fresh" content because it is unseen. We need to distinguish it somehow from content
// which "arrived as you were reading page 1". We're going to do this
// by storing in your session the current UTC time whenever you LOAD a network page, and only UPDATE items
// which are both ITEM_UNSEEN and have "changed" since that time. Cross fingers...
2021-12-03 03:01:39 +00:00
if ( $this -> updating && $_SESSION [ 'loadtime_stream' ]) {
2021-12-02 23:02:31 +00:00
$simple_update = " AND item.changed > ' " . datetime_convert ( 'UTC' , 'UTC' , $_SESSION [ 'loadtime_stream' ]) . " ' " ;
2021-12-03 03:01:39 +00:00
}
if ( $this -> loading ) {
2021-12-02 23:02:31 +00:00
$simple_update = '' ;
2021-12-03 03:01:39 +00:00
}
2021-12-02 23:02:31 +00:00
2021-12-03 03:01:39 +00:00
if ( $static && $simple_update ) {
2021-12-02 23:02:31 +00:00
$simple_update .= " and item_thread_top = 0 and author_xchan = ' " . protect_sprintf ( get_observer_hash ()) . " ' " ;
2021-12-03 03:01:39 +00:00
}
2021-12-02 23:02:31 +00:00
// we are not yet using this in updates because the content may have just been marked seen
// and this might prevent us from loading the update. Will need to test further.
$seenstr = EMPTY_STR ;
if ( local_channel ()) {
$seen = PConfig :: Get ( local_channel (), 'system' , 'seen_items' , []);
if ( $seen ) {
$seenstr = " and not item.id in ( " . implode ( ',' , $seen ) . " ) " ;
}
}
if ( $nouveau && $this -> loading ) {
2022-05-25 23:00:59 +00:00
// "New Item View" - show all items unthreaded in reverse date order
2021-12-02 23:02:31 +00:00
$items = q ( " SELECT item.*, item.id AS item_id, created FROM item
2016-04-19 03:38:38 +00:00
left join abook on ( item . owner_xchan = abook . abook_xchan $abook_uids )
2017-11-01 09:53:12 +00:00
$net_query
2016-04-19 03:38:38 +00:00
WHERE true $uids $item_normal
and ( abook . abook_blocked = 0 or abook . abook_flags is null )
$simple_update
2018-04-15 08:15:49 +00:00
$sql_extra $sql_options $sql_nets
2017-11-01 09:53:12 +00:00
$net_query2
2022-05-25 23:00:59 +00:00
ORDER BY item . edited DESC $pager_sql " );
2021-12-02 23:02:31 +00:00
xchan_query ( $items );
2022-10-23 00:50:31 +00:00
$items = fetch_post_tags ( $items );
2021-12-02 23:02:31 +00:00
} elseif ( $this -> updating ) {
// Normal conversation view
2021-12-03 03:01:39 +00:00
if ( $order === 'post' ) {
2022-05-25 23:00:59 +00:00
$ordering = 'created' ;
} elseif ( $order === 'received' ) {
$ordering = 'changed' ;
2022-10-02 07:41:06 +00:00
} elseif ( $distance ) {
$ordering = 'distance asc, commented' ;
$sql_extra .= " and (lat != 0 or lon != 0) " ;
2021-12-03 03:01:39 +00:00
} else {
2022-05-25 23:00:59 +00:00
$ordering = 'commented' ;
2021-12-03 03:01:39 +00:00
}
2022-10-02 07:41:06 +00:00
$base_query = ( $distance )
? " SELECT item.parent AS item_id,
( 6371 * acos ( cos ( radians ( lat ) )
* cos ( radians ( $distance_lat ) )
* cos ( radians ( $distance_lon ) - radians ( lon ) )
+ sin ( radians ( lat ) )
* sin ( radians ( $distance_lat ) )
)) as distance from item "
: " SELECT item.parent AS item_id FROM item " ;
2021-12-02 23:02:31 +00:00
if ( $this -> loading ) {
// Fetch a page full of parent items for this page
2022-10-02 07:41:06 +00:00
$r = q ( " $base_query
2016-04-19 03:38:38 +00:00
left join abook on ( item . owner_xchan = abook . abook_xchan $abook_uids )
2017-11-01 09:53:12 +00:00
$net_query
2018-02-04 19:42:40 +00:00
WHERE true $uids $item_thread_top $item_normal
AND item . mid = item . parent_mid
2016-04-19 03:38:38 +00:00
and ( abook . abook_blocked = 0 or abook . abook_flags is null )
2018-04-15 08:15:49 +00:00
$sql_extra3 $sql_extra $sql_options $sql_nets
2017-11-01 09:53:12 +00:00
$net_query2
2021-12-03 03:01:39 +00:00
ORDER BY $ordering DESC $pager_sql " );
2022-10-02 07:41:06 +00:00
2021-12-02 23:02:31 +00:00
} else {
// this is an update
2022-10-02 07:41:06 +00:00
$r = q ( " $base_query
2016-04-19 03:38:38 +00:00
left join abook on ( item . owner_xchan = abook . abook_xchan $abook_uids )
2017-11-01 09:53:12 +00:00
$net_query
2017-09-03 19:33:07 +00:00
WHERE true $uids $item_normal_update $simple_update
2016-04-19 03:38:38 +00:00
and ( abook . abook_blocked = 0 or abook . abook_flags is null )
2021-12-03 03:01:39 +00:00
$sql_extra3 $sql_extra $sql_options $sql_nets $net_query2 " );
2021-12-02 23:02:31 +00:00
}
if ( $r ) {
$parents_str = ids_to_querystr ( $r , 'item_id' );
2021-12-03 03:01:39 +00:00
$items = q (
" SELECT item.*, item.id AS item_id FROM item
2016-04-19 03:38:38 +00:00
WHERE true $uids $item_normal
AND item . parent IN ( % s )
$sql_extra " ,
2021-12-02 23:02:31 +00:00
dbesc ( $parents_str )
);
2022-10-02 07:41:06 +00:00
if ( $distance ) {
foreach ( $r as $parent ) {
for ( $cnt = 0 ; $cnt < count ( $items ); $cnt ++ ) {
if ( $parent [ 'item_id' ] === $items [ $cnt ][ 'id' ]) {
$items [ $cnt ][ 'distance' ] = $parent [ 'distance' ];
}
}
}
}
2021-12-02 23:02:31 +00:00
xchan_query ( $items , true );
2022-10-23 00:50:31 +00:00
$items = fetch_post_tags ( $items );
2021-12-02 23:02:31 +00:00
$items = conv_sort ( $items , $ordering );
}
if ( $page_mode === 'list' ) {
/**
* in " list mode " , only mark the parent item and any like activities as " seen " .
* We won ' t distinguish between comment likes and post likes . The important thing
* is that the number of unseen comments will be accurate . The SQL to separate the
* comment likes could also get somewhat hairy .
*/
if ( $parents_str ) {
$update_unseen = " AND ( id IN ( " . dbesc ( $parents_str ) . " ) " ;
$update_unseen .= " OR ( parent IN ( " . dbesc ( $parents_str ) . " ) AND verb in ( ' " . dbesc ( ACTIVITY_LIKE ) . " ',' " . dbesc ( ACTIVITY_DISLIKE ) . " ' ))) " ;
}
} else {
if ( $parents_str ) {
$update_unseen = " AND parent IN ( " . dbesc ( $parents_str ) . " ) " ;
}
}
}
if ( $update_unseen && ( ! ( isset ( $_SESSION [ 'sudo' ]) && $_SESSION [ 'sudo' ]))) {
$x = [ 'channel_id' => local_channel (), 'update' => 'unset' ];
2022-02-12 08:50:48 +00:00
Hook :: call ( 'update_unseen' , $x );
2021-12-02 23:02:31 +00:00
if ( $x [ 'update' ] === 'unset' || intval ( $x [ 'update' ])) {
2022-08-13 02:09:50 +00:00
q ( " UPDATE item SET item_unseen = 0 WHERE item_unseen = 1 AND uid = %d $update_unseen " ,
2021-12-02 23:02:31 +00:00
intval ( local_channel ())
);
}
}
$mode = (( $nouveau ) ? 'stream-new' : 'stream' );
if ( $search ) {
$mode = 'search' ;
}
$o .= conversation ( $items , $mode , $this -> updating , $page_mode );
if (( $items ) && ( ! $this -> updating )) {
$o .= alt_pager ( count ( $items ));
}
return $o ;
}
2016-04-19 03:38:38 +00:00
}