2020-09-01 04:09:16 -04:00
< ? php
/**
2021-03-29 02:40:20 -04:00
* @ copyright Copyright ( C ) 2010 - 2021 , the Friendica project
2020-09-01 04:09:16 -04:00
*
* @ license GNU AGPL version 3 or any later version
*
* This program is free software : you can redistribute it and / or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation , either version 3 of the
* License , or ( at your option ) any later version .
*
* This program is distributed in the hope that it will be useful ,
* but WITHOUT ANY WARRANTY ; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE . See the
* GNU Affero General Public License for more details .
*
* You should have received a copy of the GNU Affero General Public License
* along with this program . If not , see < https :// www . gnu . org / licenses />.
*
*/
namespace Friendica\Worker ;
use Friendica\Core\Logger ;
use Friendica\Core\Protocol ;
use Friendica\Core\Worker ;
use Friendica\Database\DBA ;
use Friendica\DI ;
2020-11-30 00:39:12 -05:00
use Friendica\Protocol\Feed ;
2020-09-01 04:09:16 -04:00
use Friendica\Util\DateTimeFormat ;
/**
* Poll contacts for unreceived messages
*/
class PollContacts
{
public static function execute ()
{
$abandon_days = intval ( DI :: config () -> get ( 'system' , 'account_abandon_days' ));
if ( $abandon_days < 1 ) {
$abandon_days = 0 ;
}
2020-12-04 00:53:11 -05:00
$condition = [ 'network' => [ Protocol :: FEED , Protocol :: MAIL , Protocol :: OSTATUS ], 'self' => false , 'blocked' => false ];
2020-11-22 09:42:24 -05:00
2020-09-01 04:09:16 -04:00
if ( ! empty ( $abandon_days )) {
2020-11-22 09:42:24 -05:00
$condition = DBA :: mergeConditions ( $condition ,
[ " `uid` != ? AND `uid` IN (SELECT `uid` FROM `user` WHERE NOT `account_expired` AND NOT `account_removed` AND `login_date` > UTC_TIMESTAMP() - INTERVAL ? DAY) " , 0 , $abandon_days ]);
} else {
$condition = DBA :: mergeConditions ( $condition ,
[ " `uid` != ? AND `uid` IN (SELECT `uid` FROM `user` WHERE NOT `account_expired` AND NOT `account_removed`) " , 0 ]);
2020-09-01 04:09:16 -04:00
}
2020-11-22 09:42:24 -05:00
$contacts = DBA :: select ( 'contact' , [ 'id' , 'nick' , 'name' , 'network' , 'archive' , 'last-update' , 'priority' , 'rating' ], $condition );
2020-09-01 04:09:16 -04:00
if ( ! DBA :: isResult ( $contacts )) {
return ;
}
while ( $contact = DBA :: fetch ( $contacts )) {
2020-11-30 00:39:12 -05:00
$interval = Feed :: getPollInterval ( $contact );
if ( $interval == 0 ) {
2020-09-01 04:09:16 -04:00
continue ;
}
$now = DateTimeFormat :: utcNow ();
2020-11-30 00:39:12 -05:00
$next_update = DateTimeFormat :: utc ( $contact [ 'last-update' ] . ' + ' . $interval . ' minute' );
2020-09-01 04:09:16 -04:00
2020-11-30 00:39:12 -05:00
if ( $now < $next_update ) {
Logger :: debug ( 'No update' , [ 'cid' => $contact [ 'id' ], 'interval' => $interval , 'next' => $next_update , 'now' => $now ]);
2020-09-01 04:09:16 -04:00
continue ;
}
if ((( $contact [ 'network' ] == Protocol :: FEED ) && ( $contact [ 'priority' ] <= 3 )) || ( $contact [ 'network' ] == Protocol :: MAIL )) {
$priority = PRIORITY_MEDIUM ;
} elseif ( $contact [ 'archive' ]) {
$priority = PRIORITY_NEGLIGIBLE ;
} else {
$priority = PRIORITY_LOW ;
}
Logger :: notice ( " Polling " . $contact [ " network " ] . " " . $contact [ " id " ] . " " . $contact [ 'priority' ] . " " . $contact [ " nick " ] . " " . $contact [ " name " ]);
Worker :: add ([ 'priority' => $priority , 'dont_fork' => true , 'force_priority' => true ], 'OnePoll' , ( int ) $contact [ 'id' ]);
}
DBA :: close ( $contacts );
}
}