harukin/core
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

implement monthly directory pings

Browse Source
This commit is contained in:
friendica 2013-10-28 00:11:44 -07:00
parent d389ceed6c
commit 1bf6591e1b
3 changed files with 35 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
include/directory.php
View File

@ -31,6 +31,12 @@ function directory_run($argv, $argc){
if(($dirmode == DIRECTORY_MODE_PRIMARY) || ($dirmode == DIRECTORY_MODE_STANDALONE)) {
syncdirs($argv[1]);
q("update channel set channel_dirdate = '%s' where channel_id = %d limit 1",
dbesc(datetime_convert()),
intval($channel['channel_id'])
);
// Now update all the connections
proc_run('php','include/notifier.php','refresh_all',$channel['channel_id']);
return;
@ -53,6 +59,10 @@ function directory_run($argv, $argc){
// re-queue if unsuccessful
if(! $z['success']) {
// FIXME - we aren't updating channel_dirdate if we have to queue
// the directory packet. That means we'll try again on the next poll run.
$hash = random_string();
q("insert into outq ( outq_hash, outq_account, outq_channel, outq_posturl, outq_async, outq_created, outq_updated, outq_notify, outq_msg )
values ( '%s', %d, %d, '%s', %d, '%s', '%s', '%s', '%s' )",
@ -67,6 +77,12 @@ function directory_run($argv, $argc){
dbesc('')
);
}
else {
q("update channel set channel_dirdate = '%s' where channel_id = %d limit 1",
dbesc(datetime_convert()),
intval($channel['channel_id'])
);
}
// Now update all the connections

21
include/poller.php
View File

@ -21,6 +21,11 @@ function poller_run($argv, $argc){
}
}
$interval = intval(get_config('system','poll_interval'));
if(! $interval)
$interval = ((get_config('system','delivery_interval') === false) ? 3 : intval(get_config('system','delivery_interval')));
logger('poller: start');
// run queue delivery process in the background
@ -38,6 +43,19 @@ function poller_run($argv, $argc){
intval(ACCOUNT_EXPIRED)
);
// Ensure that every channel pings a directory server once a month. This way we can discover
// channels and sites that quietly vanished and prevent the directory from accumulating stale
// or dead entries.
$r = q("select channel_id from channel where channel_dirdate < UTC_TIMESTAMP() - INTERVAL 30 DAY");
if($r) {
foreach($r as $rr) {
proc_run('php','include/directory.php',$rr['channel_id']);
if($interval)
@time_sleep_until(microtime(true) + (float) $interval);
}
}
// publish any applicable items that were set to be published in the future
// (time travel posts)
@ -134,9 +152,6 @@ function poller_run($argv, $argc){
$force = true;
}
$interval = intval(get_config('system','poll_interval'));
if(! $interval)
$interval = ((get_config('system','delivery_interval') === false) ? 3 : intval(get_config('system','delivery_interval')));
$sql_extra = (($manual_id) ? " AND abook_id = $manual_id " : "");

2
version.inc
View File

@ -1 +1 @@
2013-10-27.479
2013-10-28.480