2016-04-19 03:38:38 +00:00
< ? php
2016-05-24 08:25:13 +00:00
2016-10-01 22:41:25 +00:00
namespace Zotlabs\Module ;
2016-04-19 03:38:38 +00:00
require_once ( 'include/bbcode.php' );
2016-05-24 08:25:13 +00:00
2016-04-19 03:38:38 +00:00
/**
2016-10-01 22:41:25 +00:00
* @ brief Ping Controller .
2016-04-19 03:38:38 +00:00
*
*/
class Ping extends \Zotlabs\Web\Controller {
2016-10-01 22:41:25 +00:00
/**
* @ brief do several updates when pinged .
*
* This function does several tasks . Whenever called it checks for new messages ,
* introductions , notifications , etc . and returns a json with the results .
*
* @ result JSON
*/
2016-04-19 03:38:38 +00:00
function init () {
2017-10-06 14:46:27 +00:00
2016-04-19 03:38:38 +00:00
$result = array ();
$notifs = array ();
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
$result [ 'notify' ] = 0 ;
$result [ 'home' ] = 0 ;
$result [ 'network' ] = 0 ;
$result [ 'intros' ] = 0 ;
$result [ 'mail' ] = 0 ;
$result [ 'register' ] = 0 ;
$result [ 'events' ] = 0 ;
$result [ 'events_today' ] = 0 ;
$result [ 'birthdays' ] = 0 ;
$result [ 'birthdays_today' ] = 0 ;
$result [ 'all_events' ] = 0 ;
$result [ 'all_events_today' ] = 0 ;
$result [ 'notice' ] = array ();
$result [ 'info' ] = array ();
2017-07-28 20:42:02 +00:00
$result [ 'pubs' ] = 0 ;
$result [ 'files' ] = 0 ;
2016-10-01 22:41:25 +00:00
2017-07-29 10:24:03 +00:00
if ( ! $_SESSION [ 'static_loadtime' ])
$_SESSION [ 'static_loadtime' ] = datetime_convert ();
2016-04-19 03:38:38 +00:00
$t0 = dba_timer ();
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
header ( " content-type: application/json " );
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
$vnotify = false ;
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
$item_normal = item_normal ();
2016-10-01 22:41:25 +00:00
if ( local_channel ()) {
2016-04-19 03:38:38 +00:00
$vnotify = get_pconfig ( local_channel (), 'system' , 'vnotify' );
$evdays = intval ( get_pconfig ( local_channel (), 'system' , 'evdays' ));
$ob_hash = get_observer_hash ();
}
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
// if unset show all visual notification types
if ( $vnotify === false )
$vnotify = ( - 1 );
if ( $evdays < 1 )
$evdays = 3 ;
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
/**
* If you have several windows open to this site and switch to a different channel
2016-10-01 22:41:25 +00:00
* in one of them , the others may get into a confused state showing you a page or options
2016-04-19 03:38:38 +00:00
* on that page which were only valid under the old identity . You session has changed .
* Therefore we send a notification of this fact back to the browser where it is picked up
* in javascript and which reloads the page it is on so that it is valid under the context
2016-10-01 22:41:25 +00:00
* of the now current channel .
2016-04-19 03:38:38 +00:00
*/
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
$result [ 'invalid' ] = (( intval ( $_GET [ 'uid' ])) && ( intval ( $_GET [ 'uid' ]) != local_channel ()) ? 1 : 0 );
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
/**
* Send all system messages ( alerts ) to the browser .
* Some are marked as informational and some represent
* errors or serious notifications . These typically
* will popup on the current page ( no matter what page it is )
*/
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( x ( $_SESSION , 'sysmsg' )){
foreach ( $_SESSION [ 'sysmsg' ] as $m ){
$result [ 'notice' ][] = array ( 'message' => $m );
}
unset ( $_SESSION [ 'sysmsg' ]);
}
if ( x ( $_SESSION , 'sysmsg_info' )){
foreach ( $_SESSION [ 'sysmsg_info' ] as $m ){
$result [ 'info' ][] = array ( 'message' => $m );
}
unset ( $_SESSION [ 'sysmsg_info' ]);
}
if ( ! ( $vnotify & VNOTIFY_INFO ))
$result [ 'info' ] = array ();
if ( ! ( $vnotify & VNOTIFY_ALERT ))
$result [ 'notice' ] = array ();
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( \App :: $install ) {
echo json_encode ( $result );
killme ();
}
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
/**
* Update chat presence indication ( if applicable )
*/
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( get_observer_hash () && ( ! $result [ 'invalid' ])) {
$r = q ( " select cp_id, cp_room from chatpresence where cp_xchan = '%s' and cp_client = '%s' and cp_room = 0 limit 1 " ,
dbesc ( get_observer_hash ()),
dbesc ( $_SERVER [ 'REMOTE_ADDR' ])
);
$basic_presence = false ;
if ( $r ) {
2016-10-01 22:41:25 +00:00
$basic_presence = true ;
2016-04-19 03:38:38 +00:00
q ( " update chatpresence set cp_last = '%s' where cp_id = %d " ,
dbesc ( datetime_convert ()),
intval ( $r [ 0 ][ 'cp_id' ])
);
}
if ( ! $basic_presence ) {
q ( " insert into chatpresence ( cp_xchan, cp_last, cp_status, cp_client)
values ( '%s' , '%s' , '%s' , '%s' ) " ,
dbesc ( get_observer_hash ()),
dbesc ( datetime_convert ()),
dbesc ( 'online' ),
dbesc ( $_SERVER [ 'REMOTE_ADDR' ])
);
}
}
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
/**
* Chatpresence continued ... if somebody hasn 't pinged recently, they' ve most likely left the page
* and shouldn ' t count as online anymore . We allow an expection for bots .
*/
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
q ( " delete from chatpresence where cp_last < %s - INTERVAL %s and cp_client != 'auto' " ,
db_utcnow (), db_quoteinterval ( '3 MINUTE' )
2016-10-01 22:41:25 +00:00
);
2017-12-03 11:31:41 +00:00
$discover_tab_on = (( get_config ( 'system' , 'disable_discover_tab' ) || get_config ( 'system' , 'disable_discover_tab' ) === false ) ? false : true );
2017-10-06 14:46:27 +00:00
$notify_pubs = (( local_channel ()) ? ( $vnotify & VNOTIFY_PUBS ) && $discover_tab_on : $discover_tab_on );
2017-07-28 20:42:02 +00:00
2017-07-29 10:24:03 +00:00
if ( $notify_pubs ) {
2017-07-28 20:42:02 +00:00
$sys = get_sys_channel ();
$pubs = q ( " SELECT count(id) as total from item
WHERE uid = % d
2017-07-29 10:24:03 +00:00
AND author_xchan != '%s'
2017-08-01 21:45:41 +00:00
AND obj_type != '%s'
2017-07-28 20:42:02 +00:00
AND item_unseen = 1
AND created > '" . datetime_convert(' UTC ',' UTC ',$_SESSION[' static_loadtime ']) . "'
$item_normal " ,
2017-07-29 10:24:03 +00:00
intval ( $sys [ 'channel_id' ]),
2017-08-01 21:45:41 +00:00
dbesc ( get_observer_hash ()),
dbesc ( ACTIVITY_OBJ_FILE )
2017-07-28 20:42:02 +00:00
);
if ( $pubs )
$result [ 'pubs' ] = intval ( $pubs [ 0 ][ 'total' ]);
}
2017-10-06 14:46:27 +00:00
if (( argc () > 1 ) && ( argv ( 1 ) === 'pubs' ) && ( $notify_pubs )) {
$sys = get_sys_channel ();
$result = array ();
$r = q ( " SELECT * FROM item
WHERE uid = % d
AND author_xchan != '%s'
AND item_unseen = 1
AND created > '" . datetime_convert(' UTC ',' UTC ',$_SESSION[' static_loadtime ']) . "'
$item_normal
ORDER BY created DESC
LIMIT 300 " ,
intval ( $sys [ 'channel_id' ]),
2017-11-03 12:49:58 +00:00
dbesc ( get_observer_hash ())
2017-10-06 14:46:27 +00:00
);
if ( $r ) {
xchan_query ( $r );
foreach ( $r as $rr ) {
2017-10-07 13:40:34 +00:00
$rr [ 'llink' ] = str_replace ( 'display/' , 'pubstream/?f=&mid=' , $rr [ 'llink' ]);
2017-10-06 14:46:27 +00:00
$result [] = \Zotlabs\Lib\Enotify :: format ( $rr );
}
}
// logger('ping (network||home): ' . print_r($result, true), LOGGER_DATA);
echo json_encode ( array ( 'notify' => $result ));
killme ();
}
2017-07-28 20:42:02 +00:00
$t1 = dba_timer ();
2016-04-19 03:38:38 +00:00
if (( ! local_channel ()) || ( $result [ 'invalid' ])) {
echo json_encode ( $result );
killme ();
}
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
/**
* Everything following is only permitted under the context of a locally authenticated site member .
*/
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
/**
* Handle " mark all xyz notifications read " requests .
*/
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
// mark all items read
if ( x ( $_REQUEST , 'markRead' ) && local_channel ()) {
switch ( $_REQUEST [ 'markRead' ]) {
case 'network' :
2016-10-01 22:41:25 +00:00
$r = q ( " update item set item_unseen = 0 where item_unseen = 1 and uid = %d " ,
2016-04-19 03:38:38 +00:00
intval ( local_channel ())
);
break ;
case 'home' :
2016-10-01 22:41:25 +00:00
$r = q ( " update item set item_unseen = 0 where item_unseen = 1 and item_wall = 1 and uid = %d " ,
2016-04-19 03:38:38 +00:00
intval ( local_channel ())
);
break ;
2017-11-06 08:34:20 +00:00
case 'mail' :
2016-04-19 03:38:38 +00:00
$r = q ( " update mail set mail_seen = 1 where mail_seen = 0 and channel_id = %d " ,
intval ( local_channel ())
);
break ;
case 'all_events' :
2016-10-04 04:48:53 +00:00
$r = q ( " update event set dismissed = 1 where dismissed = 0 and uid = %d AND dtstart < '%s' AND dtstart > '%s' " ,
2016-04-19 03:38:38 +00:00
intval ( local_channel ()),
dbesc ( datetime_convert ( 'UTC' , date_default_timezone_get (), 'now + ' . intval ( $evdays ) . ' days' )),
dbesc ( datetime_convert ( 'UTC' , date_default_timezone_get (), 'now - 1 days' ))
);
break ;
case 'notify' :
$r = q ( " update notify set seen = 1 where uid = %d " ,
intval ( local_channel ())
);
break ;
2017-10-06 14:46:27 +00:00
case 'pubs' :
unset ( $_SESSION [ 'static_loadtime' ]);
break ;
2016-04-19 03:38:38 +00:00
default :
break ;
}
}
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( x ( $_REQUEST , 'markItemRead' ) && local_channel ()) {
2016-10-01 22:41:25 +00:00
$r = q ( " update item set item_unseen = 0 where parent = %d and uid = %d " ,
2016-04-19 03:38:38 +00:00
intval ( $_REQUEST [ 'markItemRead' ]),
intval ( local_channel ())
);
}
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
/**
* URL ping / something will return detail for " something " , e . g . a json list with which to populate a notification
* dropdown menu .
*/
if ( argc () > 1 && argv ( 1 ) === 'notify' ) {
2017-10-22 19:01:58 +00:00
$t = q ( " select * from notify where uid = %d and seen = 0 order by created desc " ,
2016-04-19 03:38:38 +00:00
intval ( local_channel ())
);
2016-10-01 22:41:25 +00:00
2017-10-22 19:01:58 +00:00
if ( $t ) {
foreach ( $t as $tt ) {
2017-11-17 09:40:34 +00:00
$message = trim ( strip_tags ( bbcode ( $tt [ 'msg' ])));
if ( strpos ( $message , $tt [ 'xname' ]) === 0 )
2017-11-17 20:25:18 +00:00
$message = substr ( $message , strlen ( $tt [ 'xname' ]) + 1 );
2017-11-17 09:40:34 +00:00
2017-11-19 19:37:58 +00:00
$mid = basename ( $tt [ 'link' ]);
$b64mid = (( strpos ( $mid , 'b64.' === 0 )) ? $mid : 'b64.' . base64url_encode ( $mid ));
2016-04-19 03:38:38 +00:00
$notifs [] = array (
2017-10-22 19:01:58 +00:00
'notify_link' => z_root () . '/notify/view/' . $tt [ 'id' ],
'name' => $tt [ 'xname' ],
'url' => $tt [ 'url' ],
'photo' => $tt [ 'photo' ],
'when' => relative_date ( $tt [ 'created' ]),
'hclass' => (( $tt [ 'seen' ]) ? 'notify-seen' : 'notify-unseen' ),
2017-11-19 19:37:58 +00:00
'b64mid' => $b64mid ,
2017-11-19 19:40:50 +00:00
'notify_id' => (( $tt [ 'otype' ] == 'item' ) ? $tt [ 'id' ] : '' ),
2017-11-17 09:40:34 +00:00
'message' => $message
2016-04-19 03:38:38 +00:00
);
}
}
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
echo json_encode ( array ( 'notify' => $notifs ));
killme ();
}
2016-10-01 22:41:25 +00:00
2017-10-08 20:21:19 +00:00
if ( argc () > 1 && argv ( 1 ) === 'mail' ) {
2016-04-19 03:38:38 +00:00
$channel = \App :: get_channel ();
2016-10-01 22:41:25 +00:00
$t = q ( " select mail.*, xchan.* from mail left join xchan on xchan_hash = from_xchan
where channel_id = % d and mail_seen = 0 and mail_deleted = 0
2016-04-19 03:38:38 +00:00
and from_xchan != '%s' order by created desc limit 50 " ,
intval ( local_channel ()),
dbesc ( $channel [ 'channel_hash' ])
);
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( $t ) {
foreach ( $t as $zz ) {
$notifs [] = array (
2016-10-01 22:41:25 +00:00
'notify_link' => z_root () . '/mail/' . $zz [ 'id' ],
2016-04-19 03:38:38 +00:00
'name' => $zz [ 'xchan_name' ],
'url' => $zz [ 'xchan_url' ],
'photo' => $zz [ 'xchan_photo_s' ],
2016-10-01 22:41:25 +00:00
'when' => relative_date ( $zz [ 'created' ]),
'hclass' => ( intval ( $zz [ 'mail_seen' ]) ? 'notify-seen' : 'notify-unseen' ),
2016-04-19 03:38:38 +00:00
'message' => t ( 'sent you a private message' ),
);
}
}
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
echo json_encode ( array ( 'notify' => $notifs ));
killme ();
}
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( argc () > 1 && ( argv ( 1 ) === 'network' || argv ( 1 ) === 'home' )) {
$result = array ();
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
$r = q ( " SELECT * FROM item
WHERE item_unseen = 1 and uid = % d $item_normal
2017-07-30 15:49:35 +00:00
AND author_xchan != '%s'
ORDER BY created DESC limit 300 " ,
2016-04-19 03:38:38 +00:00
intval ( local_channel ()),
2017-11-03 12:49:58 +00:00
dbesc ( $ob_hash )
2016-04-19 03:38:38 +00:00
);
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( $r ) {
xchan_query ( $r );
foreach ( $r as $item ) {
if (( argv ( 1 ) === 'home' ) && ( ! intval ( $item [ 'item_wall' ])))
continue ;
2016-05-26 12:23:17 +00:00
$result [] = \Zotlabs\Lib\Enotify :: format ( $item );
2016-04-19 03:38:38 +00:00
}
}
2016-10-01 22:41:25 +00:00
// logger('ping (network||home): ' . print_r($result, true), LOGGER_DATA);
2016-04-19 03:38:38 +00:00
echo json_encode ( array ( 'notify' => $result ));
killme ();
}
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( argc () > 1 && ( argv ( 1 ) === 'intros' )) {
$result = array ();
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
$r = q ( " SELECT * FROM abook left join xchan on abook.abook_xchan = xchan.xchan_hash where abook_channel = %d and abook_pending = 1 and abook_self = 0 and abook_ignored = 0 and xchan_deleted = 0 and xchan_orphan = 0 ORDER BY abook_created DESC LIMIT 50 " ,
intval ( local_channel ())
);
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( $r ) {
foreach ( $r as $rr ) {
$result [] = array (
'notify_link' => z_root () . '/connections/ifpending' ,
'name' => $rr [ 'xchan_name' ],
'url' => $rr [ 'xchan_url' ],
'photo' => $rr [ 'xchan_photo_s' ],
2016-10-01 22:41:25 +00:00
'when' => relative_date ( $rr [ 'abook_created' ]),
'hclass' => ( 'notify-unseen' ),
2016-04-19 03:38:38 +00:00
'message' => t ( 'added your channel' )
);
}
}
logger ( 'ping (intros): ' . print_r ( $result , true ), LOGGER_DATA );
echo json_encode ( array ( 'notify' => $result ));
killme ();
}
2016-10-01 22:41:25 +00:00
2017-10-04 11:37:17 +00:00
if (( argc () > 1 && ( argv ( 1 ) === 'register' )) && is_site_admin ()) {
$result = array ();
$r = q ( " SELECT account_email, account_created from account where (account_flags & %d) > 0 " ,
intval ( ACCOUNT_PENDING )
);
if ( $r ) {
foreach ( $r as $rr ) {
$result [] = array (
'notify_link' => z_root () . '/admin/accounts' ,
'name' => $rr [ 'account_email' ],
'url' => '' ,
'photo' => get_default_profile_photo ( 48 ),
'when' => relative_date ( $rr [ 'account_created' ]),
'hclass' => ( 'notify-unseen' ),
'message' => t ( 'requires approval' )
);
}
}
logger ( 'ping (register): ' . print_r ( $result , true ), LOGGER_DATA );
echo json_encode ( array ( 'notify' => $result ));
killme ();
}
2016-04-19 03:38:38 +00:00
if ( argc () > 1 && ( argv ( 1 ) === 'all_events' )) {
$bd_format = t ( 'g A l F d' ) ; // 8 AM Friday January 18
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
$result = array ();
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
$r = q ( " SELECT * FROM event left join xchan on event_xchan = xchan_hash
2016-10-04 04:48:53 +00:00
WHERE event . uid = % d AND dtstart < '%s' AND dtstart > '%s' and dismissed = 0
2016-06-02 04:48:54 +00:00
and etype in ( 'event' , 'birthday' )
2016-10-04 04:48:53 +00:00
ORDER BY dtstart DESC LIMIT 1000 " ,
2016-04-19 03:38:38 +00:00
intval ( local_channel ()),
dbesc ( datetime_convert ( 'UTC' , date_default_timezone_get (), 'now + ' . intval ( $evdays ) . ' days' )),
dbesc ( datetime_convert ( 'UTC' , date_default_timezone_get (), 'now - 1 days' ))
);
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( $r ) {
foreach ( $r as $rr ) {
2016-10-01 22:41:25 +00:00
2016-06-02 04:48:54 +00:00
$strt = datetime_convert ( 'UTC' , (( $rr [ 'adjust' ]) ? date_default_timezone_get () : 'UTC' ), $rr [ 'dtstart' ]);
2016-04-19 03:38:38 +00:00
$today = (( substr ( $strt , 0 , 10 ) === datetime_convert ( 'UTC' , date_default_timezone_get (), 'now' , 'Y-m-d' )) ? true : false );
2016-06-02 04:48:54 +00:00
$when = day_translate ( datetime_convert ( 'UTC' , (( $rr [ 'adjust' ]) ? date_default_timezone_get () : 'UTC' ), $rr [ 'dtstart' ], $bd_format )) . (( $today ) ? ' ' . t ( '[today]' ) : '' );
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
$result [] = array (
2016-10-01 22:41:25 +00:00
'notify_link' => z_root () . '/events' , /// @FIXME this takes you to an edit page and it may not be yours, we really want to just view the single event --> '/events/event/' . $rr['event_hash'],
2016-04-19 03:38:38 +00:00
'name' => $rr [ 'xchan_name' ],
'url' => $rr [ 'xchan_url' ],
'photo' => $rr [ 'xchan_photo_s' ],
'when' => $when ,
2016-10-01 22:41:25 +00:00
'hclass' => ( 'notify-unseen' ),
2016-04-19 03:38:38 +00:00
'message' => t ( 'posted an event' )
);
}
}
logger ( 'ping (all_events): ' . print_r ( $result , true ), LOGGER_DATA );
echo json_encode ( array ( 'notify' => $result ));
killme ();
}
2016-10-01 22:41:25 +00:00
2017-10-04 20:11:18 +00:00
if ( argc () > 1 && ( argv ( 1 ) === 'files' )) {
$result = array ();
$r = q ( " SELECT item.created, xchan.xchan_name, xchan.xchan_url, xchan.xchan_photo_s FROM item
LEFT JOIN xchan on author_xchan = xchan_hash
WHERE item . verb = '%s'
AND item . obj_type = '%s'
AND item . uid = % d
AND item . owner_xchan != '%s'
AND item . item_unseen = 1 " ,
dbesc ( ACTIVITY_POST ),
dbesc ( ACTIVITY_OBJ_FILE ),
intval ( local_channel ()),
dbesc ( $ob_hash )
);
if ( $r ) {
foreach ( $r as $rr ) {
$result [] = array (
'notify_link' => z_root () . '/sharedwithme' ,
'name' => $rr [ 'xchan_name' ],
'url' => $rr [ 'xchan_url' ],
'photo' => $rr [ 'xchan_photo_s' ],
'when' => relative_date ( $rr [ 'created' ]),
'hclass' => ( 'notify-unseen' ),
'message' => t ( 'shared a file with you' )
);
}
}
logger ( 'ping (files): ' . print_r ( $result , true ), LOGGER_DATA );
echo json_encode ( array ( 'notify' => $result ));
killme ();
}
2016-04-19 03:38:38 +00:00
/**
* Normal ping - just the counts , no detail
*/
if ( $vnotify & VNOTIFY_SYSTEM ) {
$t = q ( " select count(*) as total from notify where uid = %d and seen = 0 " ,
intval ( local_channel ())
);
if ( $t )
$result [ 'notify' ] = intval ( $t [ 0 ][ 'total' ]);
}
2016-10-01 22:41:25 +00:00
2017-07-28 20:42:02 +00:00
$t2 = dba_timer ();
if ( $vnotify & VNOTIFY_FILES ) {
$files = q ( " SELECT count(id) as total FROM item
WHERE verb = '%s'
AND obj_type = '%s'
AND uid = % d
AND owner_xchan != '%s'
AND item_unseen = 1 " ,
dbesc ( ACTIVITY_POST ),
dbesc ( ACTIVITY_OBJ_FILE ),
intval ( local_channel ()),
dbesc ( $ob_hash )
);
if ( $files )
$result [ 'files' ] = intval ( $files [ 0 ][ 'total' ]);
}
2017-10-04 20:11:18 +00:00
$t3 = dba_timer ();
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( $vnotify & ( VNOTIFY_NETWORK | VNOTIFY_CHANNEL )) {
2017-11-20 05:51:21 +00:00
2016-04-19 03:38:38 +00:00
$r = q ( " SELECT id, item_wall FROM item
WHERE item_unseen = 1 and uid = % d
$item_normal
2017-11-24 14:01:34 +00:00
AND author_xchan != '%s' " ,
2016-04-19 03:38:38 +00:00
intval ( local_channel ()),
2017-11-03 12:49:58 +00:00
dbesc ( $ob_hash )
2016-04-19 03:38:38 +00:00
);
2016-10-01 22:41:25 +00:00
if ( $r ) {
2016-04-19 03:38:38 +00:00
$arr = array ( 'items' => $r );
call_hooks ( 'network_ping' , $arr );
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
foreach ( $r as $it ) {
if ( intval ( $it [ 'item_wall' ]))
$result [ 'home' ] ++ ;
else
$result [ 'network' ] ++ ;
}
}
}
if ( ! ( $vnotify & VNOTIFY_NETWORK ))
$result [ 'network' ] = 0 ;
if ( ! ( $vnotify & VNOTIFY_CHANNEL ))
$result [ 'home' ] = 0 ;
2016-10-01 22:41:25 +00:00
2017-07-28 20:42:02 +00:00
$t4 = dba_timer ();
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( $vnotify & VNOTIFY_INTRO ) {
$intr = q ( " SELECT COUNT(abook.abook_id) AS total FROM abook left join xchan on abook.abook_xchan = xchan.xchan_hash where abook_channel = %d and abook_pending = 1 and abook_self = 0 and abook_ignored = 0 and xchan_deleted = 0 and xchan_orphan = 0 " ,
intval ( local_channel ())
);
2016-10-01 22:41:25 +00:00
2017-07-28 20:42:02 +00:00
$t5 = dba_timer ();
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( $intr )
$result [ 'intros' ] = intval ( $intr [ 0 ][ 'total' ]);
}
2016-10-01 22:41:25 +00:00
2017-07-28 20:42:02 +00:00
$t6 = dba_timer ();
2016-04-19 03:38:38 +00:00
$channel = \App :: get_channel ();
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( $vnotify & VNOTIFY_MAIL ) {
$mails = q ( " SELECT count(id) as total from mail
WHERE channel_id = % d AND mail_seen = 0 and from_xchan != '%s' " ,
intval ( local_channel ()),
dbesc ( $channel [ 'channel_hash' ])
);
if ( $mails )
$result [ 'mail' ] = intval ( $mails [ 0 ][ 'total' ]);
}
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( $vnotify & VNOTIFY_REGISTER ) {
if ( \App :: $config [ 'system' ][ 'register_policy' ] == REGISTER_APPROVE && is_site_admin ()) {
$regs = q ( " SELECT count(account_id) as total from account where (account_flags & %d) > 0 " ,
intval ( ACCOUNT_PENDING )
);
if ( $regs )
$result [ 'register' ] = intval ( $regs [ 0 ][ 'total' ]);
}
2016-10-01 22:41:25 +00:00
}
2017-07-28 20:42:02 +00:00
$t7 = dba_timer ();
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( $vnotify & ( VNOTIFY_EVENT | VNOTIFY_EVENTTODAY | VNOTIFY_BIRTHDAY )) {
2016-10-04 04:48:53 +00:00
$events = q ( " SELECT etype, dtstart, adjust FROM event
WHERE event . uid = % d AND dtstart < '%s' AND dtstart > '%s' and dismissed = 0
2016-06-02 04:48:54 +00:00
and etype in ( 'event' , 'birthday' )
2016-10-04 04:48:53 +00:00
ORDER BY dtstart ASC " ,
2016-04-19 03:38:38 +00:00
intval ( local_channel ()),
dbesc ( datetime_convert ( 'UTC' , date_default_timezone_get (), 'now + ' . intval ( $evdays ) . ' days' )),
dbesc ( datetime_convert ( 'UTC' , date_default_timezone_get (), 'now - 1 days' ))
);
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( $events ) {
$result [ 'all_events' ] = count ( $events );
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
if ( $result [ 'all_events' ]) {
$str_now = datetime_convert ( 'UTC' , date_default_timezone_get (), 'now' , 'Y-m-d' );
foreach ( $events as $x ) {
$bd = false ;
2016-06-02 04:48:54 +00:00
if ( $x [ 'etype' ] === 'birthday' ) {
2016-04-19 03:38:38 +00:00
$result [ 'birthdays' ] ++ ;
$bd = true ;
}
else {
$result [ 'events' ] ++ ;
}
2016-06-02 04:48:54 +00:00
if ( datetime_convert ( 'UTC' , (( intval ( $x [ 'adjust' ])) ? date_default_timezone_get () : 'UTC' ), $x [ 'dtstart' ], 'Y-m-d' ) === $str_now ) {
2016-04-19 03:38:38 +00:00
$result [ 'all_events_today' ] ++ ;
if ( $bd )
$result [ 'birthdays_today' ] ++ ;
else
$result [ 'events_today' ] ++ ;
}
}
}
}
}
if ( ! ( $vnotify & VNOTIFY_EVENT ))
$result [ 'all_events' ] = $result [ 'events' ] = 0 ;
if ( ! ( $vnotify & VNOTIFY_EVENTTODAY ))
$result [ 'all_events_today' ] = $result [ 'events_today' ] = 0 ;
if ( ! ( $vnotify & VNOTIFY_BIRTHDAY ))
$result [ 'birthdays' ] = 0 ;
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
$x = json_encode ( $result );
2016-10-01 22:41:25 +00:00
2017-07-28 20:42:02 +00:00
$t8 = dba_timer ();
2016-10-01 22:41:25 +00:00
2017-07-28 20:42:02 +00:00
// logger('ping timer: ' . sprintf('%01.4f %01.4f %01.4f %01.4f %01.4f %01.4f %01.4f %01.4f',$t8 - $t7, $t7 - $t6, $t6 - $t5, $t5 - $t4, $t4 - $t3, $t3 - $t2, $t2 - $t1, $t1 - $t0));
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
echo $x ;
killme ();
}
2016-10-01 22:41:25 +00:00
2016-04-19 03:38:38 +00:00
}