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

start timestamping hubloc connections so we can eventually remove dead ones

Browse Source
This commit is contained in:
friendica 2013-08-24 18:55:07 -07:00
parent 4925f7fc53
commit 1c17d1b69c
2 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
boot.php
View File

@ -1284,7 +1284,7 @@ function fix_system_urls($oldurl,$newurl) {
// that they can clean up their hubloc tables (this includes directories). // that they can clean up their hubloc tables (this includes directories).
// It's a very expensive operation so you don't want to have to do it often or after your site gets to be large. // It's a very expensive operation so you don't want to have to do it often or after your site gets to be large.
$r = q("select * from xchan left join channel on channel_hash = xchan_hash where xchan_url like '%s'", $r = q("select xchan.*, channel.* from xchan left join channel on channel_hash = xchan_hash where xchan_url like '%s'",
dbesc($oldurl . '%') dbesc($oldurl . '%')
); );
if($r) { if($r) {
@ -1317,7 +1317,10 @@ function fix_system_urls($oldurl,$newurl) {
dbesc($newurl . '/post'), dbesc($newurl . '/post'),
dbesc($rr['xchan_hash']), dbesc($rr['xchan_hash']),
dbesc($oldurl) dbesc($oldurl)
); );
proc_run('php', 'include/notifier.php', 'refresh_all', $rr['channel_id']);
} }
} }
} }

12
mod/post.php
View File

@ -297,13 +297,23 @@ function post_post(&$a) {
// (!!) this will validate the sender // (!!) this will validate the sender
$result = zot_register_hub($sender); $result = zot_register_hub($sender);
if((! $result['success']) || (! zot_gethub($sender))) { if((! $result['success']) || (! ($hub = zot_gethub($sender)))) {
$ret['message'] = 'Hub not available.'; $ret['message'] = 'Hub not available.';
logger('mod_zot: no hub'); logger('mod_zot: no hub');
json_return_and_die($ret); json_return_and_die($ret);
} }
} }
// Update our DB to show when we last communicated successfully with this hub
// This will allow us to prune dead hubs from using up resources
$r = q("update hubloc set hubloc_connected = '%s' where hubloc_id = %d limit 1",
dbesc(datetime_convert()),
intval($hub['hubloc_id'])
);
// TODO: check which hub is primary and take action if mismatched // TODO: check which hub is primary and take action if mismatched
if(array_key_exists('recipients',$data)) if(array_key_exists('recipients',$data))