308 lines
11 KiB
PHP
308 lines
11 KiB
PHP
<?php
|
|
/**
|
|
* @file include/hubloc.php
|
|
* @brief Hubloc related functions.
|
|
*/
|
|
|
|
/**
|
|
* @brief Create an array for hubloc table and insert record.
|
|
*
|
|
* Creates an assoziative array which will be inserted into the hubloc table.
|
|
*
|
|
* @param array $arr An assoziative array with hubloc values
|
|
* @return boolean|PDOStatement
|
|
*/
|
|
function hubloc_store_lowlevel($arr) {
|
|
|
|
$store = [
|
|
'hubloc_guid' => ((array_key_exists('hubloc_guid',$arr)) ? $arr['hubloc_guid'] : ''),
|
|
'hubloc_guid_sig' => ((array_key_exists('hubloc_guid_sig',$arr)) ? $arr['hubloc_guid_sig'] : ''),
|
|
'hubloc_hash' => ((array_key_exists('hubloc_hash',$arr)) ? $arr['hubloc_hash'] : ''),
|
|
'hubloc_addr' => ((array_key_exists('hubloc_addr',$arr)) ? $arr['hubloc_addr'] : ''),
|
|
'hubloc_network' => ((array_key_exists('hubloc_network',$arr)) ? $arr['hubloc_network'] : ''),
|
|
'hubloc_flags' => ((array_key_exists('hubloc_flags',$arr)) ? $arr['hubloc_flags'] : 0),
|
|
'hubloc_status' => ((array_key_exists('hubloc_status',$arr)) ? $arr['hubloc_status'] : 0),
|
|
'hubloc_url' => ((array_key_exists('hubloc_url',$arr)) ? $arr['hubloc_url'] : ''),
|
|
'hubloc_url_sig' => ((array_key_exists('hubloc_url_sig',$arr)) ? $arr['hubloc_url_sig'] : ''),
|
|
'hubloc_id_url' => ((array_key_exists('hubloc_id_url',$arr)) ? $arr['hubloc_id_url'] : ''),
|
|
'hubloc_site_id' => ((array_key_exists('hubloc_site_id',$arr)) ? $arr['hubloc_site_id'] : ''),
|
|
'hubloc_host' => ((array_key_exists('hubloc_host',$arr)) ? $arr['hubloc_host'] : ''),
|
|
'hubloc_callback' => ((array_key_exists('hubloc_callback',$arr)) ? $arr['hubloc_callback'] : ''),
|
|
'hubloc_connect' => ((array_key_exists('hubloc_connect',$arr)) ? $arr['hubloc_connect'] : ''),
|
|
'hubloc_sitekey' => ((array_key_exists('hubloc_sitekey',$arr)) ? $arr['hubloc_sitekey'] : ''),
|
|
'hubloc_updated' => ((array_key_exists('hubloc_updated',$arr)) ? $arr['hubloc_updated'] : NULL_DATE),
|
|
'hubloc_connected' => ((array_key_exists('hubloc_connected',$arr)) ? $arr['hubloc_connected'] : NULL_DATE),
|
|
'hubloc_primary' => ((array_key_exists('hubloc_primary',$arr)) ? $arr['hubloc_primary'] : 0),
|
|
'hubloc_orphancheck' => ((array_key_exists('hubloc_orphancheck',$arr)) ? $arr['hubloc_orphancheck'] : 0),
|
|
'hubloc_error' => ((array_key_exists('hubloc_error',$arr)) ? $arr['hubloc_error'] : 0),
|
|
'hubloc_deleted' => ((array_key_exists('hubloc_deleted',$arr)) ? $arr['hubloc_deleted'] : 0)
|
|
];
|
|
|
|
return create_table_from_array('hubloc', $store);
|
|
}
|
|
|
|
function site_store_lowlevel($arr) {
|
|
|
|
$store = [
|
|
'site_url' => ((array_key_exists('site_url',$arr)) ? $arr['site_url'] : ''),
|
|
'site_access' => ((array_key_exists('site_access',$arr)) ? $arr['site_access'] : 0),
|
|
'site_flags' => ((array_key_exists('site_flags',$arr)) ? $arr['site_flags'] : 0),
|
|
'site_update' => ((array_key_exists('site_update',$arr)) ? $arr['site_update'] : NULL_DATE),
|
|
'site_pull' => ((array_key_exists('site_pull',$arr)) ? $arr['site_pull'] : NULL_DATE),
|
|
'site_sync' => ((array_key_exists('site_sync',$arr)) ? $arr['site_sync'] : NULL_DATE),
|
|
'site_directory' => ((array_key_exists('site_directory',$arr)) ? $arr['site_directory'] : ''),
|
|
'site_register' => ((array_key_exists('site_register',$arr)) ? $arr['site_register'] : 0),
|
|
'site_sellpage' => ((array_key_exists('site_sellpage',$arr)) ? $arr['site_sellpage'] : ''),
|
|
'site_location' => ((array_key_exists('site_location',$arr)) ? $arr['site_location'] : ''),
|
|
'site_realm' => ((array_key_exists('site_realm',$arr)) ? $arr['site_realm'] : ''),
|
|
'site_valid' => ((array_key_exists('site_valid',$arr)) ? $arr['site_valid'] : 0),
|
|
'site_dead' => ((array_key_exists('site_dead',$arr)) ? $arr['site_dead'] : 0),
|
|
'site_type' => ((array_key_exists('site_type',$arr)) ? $arr['site_type'] : 0),
|
|
'site_project' => ((array_key_exists('site_project',$arr)) ? $arr['site_project'] : ''),
|
|
'site_version' => ((array_key_exists('site_version',$arr)) ? $arr['site_version'] : ''),
|
|
'site_crypto' => ((array_key_exists('site_crypto',$arr)) ? $arr['site_crypto'] : '')
|
|
];
|
|
|
|
return create_table_from_array('site', $store);
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
function prune_hub_reinstalls() {
|
|
|
|
$r = q("select site_url from site where site_type = %d",
|
|
intval(SITE_TYPE_ZOT)
|
|
);
|
|
if($r) {
|
|
foreach($r as $rr) {
|
|
$x = q("select count(*) as t, hubloc_sitekey, max(hubloc_connected) as c from hubloc where hubloc_url = '%s' group by hubloc_sitekey order by c",
|
|
dbesc($rr['site_url'])
|
|
);
|
|
|
|
// see if this url has more than one sitekey, indicating it has been re-installed.
|
|
|
|
if(count($x) > 1) {
|
|
$d1 = datetime_convert('UTC', 'UTC', $x[0]['c']);
|
|
$d2 = datetime_convert('UTC', 'UTC', 'now - 3 days');
|
|
|
|
// allow some slop period, say 3 days - just in case this is a glitch or transient occurrence
|
|
// Then remove any hublocs pointing to the oldest entry.
|
|
|
|
if(($d1 < $d2) && ($x[0]['hubloc_sitekey'])) {
|
|
logger('prune_hub_reinstalls: removing dead hublocs at ' . $rr['site_url']);
|
|
$y = q("delete from hubloc where hubloc_sitekey = '%s'",
|
|
dbesc($x[0]['hubloc_sitekey'])
|
|
);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* @brief Remove obsolete hublocs.
|
|
*
|
|
* Get rid of any hublocs which are ours but aren't valid anymore -
|
|
* e.g. they point to a different and perhaps transient URL that we aren't using.
|
|
*
|
|
* I need to stress that this shouldn't happen. fix_system_urls() fixes hublocs
|
|
* when it discovers the URL has changed. So it's unclear how we could end up
|
|
* with URLs pointing to the old site name. But it happens. This may be an artifact
|
|
* of an old bug or maybe a regression in some newer code. In any event, they
|
|
* mess up communications and we have to take action if we find any.
|
|
*/
|
|
function remove_obsolete_hublocs() {
|
|
|
|
logger('remove_obsolete_hublocs', LOGGER_DEBUG);
|
|
|
|
// First make sure we have any hublocs (at all) with this URL and sitekey.
|
|
// We don't want to perform this operation while somebody is in the process
|
|
// of renaming their hub or installing certs.
|
|
|
|
$r = q("select hubloc_id from hubloc where hubloc_url = '%s' and hubloc_sitekey = '%s'",
|
|
dbesc(z_root()),
|
|
dbesc(get_config('system', 'pubkey'))
|
|
);
|
|
if((! $r) || (! count($r)))
|
|
return;
|
|
|
|
// Good. We have at least one *valid* hubloc.
|
|
|
|
// Do we have any invalid ones?
|
|
|
|
$r = q("select hubloc_id from hubloc where hubloc_sitekey = '%s' and hubloc_url != '%s'",
|
|
dbesc(get_config('system', 'pubkey')),
|
|
dbesc(z_root())
|
|
);
|
|
$p = q("select hubloc_id from hubloc where hubloc_sitekey != '%s' and hubloc_url = '%s'",
|
|
dbesc(get_config('system', 'pubkey')),
|
|
dbesc(z_root())
|
|
);
|
|
if(is_array($r) && is_array($p))
|
|
$r = array_merge($r, $p);
|
|
|
|
if(! $r)
|
|
return;
|
|
|
|
// We've got invalid hublocs. Get rid of them.
|
|
|
|
logger('remove_obsolete_hublocs: removing ' . count($r) . ' hublocs.');
|
|
|
|
$interval = ((get_config('system', 'delivery_interval') !== false)
|
|
? intval(get_config('system', 'delivery_interval')) : 2 );
|
|
|
|
foreach($r as $rr) {
|
|
q("update hubloc set hubloc_deleted = 1 where hubloc_id = %d",
|
|
intval($rr['hubloc_id'])
|
|
);
|
|
|
|
$x = q("select channel_id from channel where channel_hash = '%s' limit 1",
|
|
dbesc($rr['hubloc_hash'])
|
|
);
|
|
if($x) {
|
|
Zotlabs\Daemon\Master::Summon(array('Notifier', 'location', $x[0]['channel_id']));
|
|
if($interval)
|
|
@time_sleep_until(microtime(true) + (float) $interval);
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* @brief Change primary hubloc.
|
|
*
|
|
* This actually changes other structures to match the given (presumably current)
|
|
* hubloc primary selection.
|
|
*
|
|
* @param array $hubloc
|
|
* @return boolean
|
|
*/
|
|
function hubloc_change_primary($hubloc) {
|
|
|
|
if(! is_array($hubloc)) {
|
|
logger('no hubloc');
|
|
return false;
|
|
}
|
|
|
|
logger('setting primary: ' . $hubloc['hubloc_url'] . ((intval($hubloc['hubloc_primary'])) ? ' true' : ' false'));
|
|
|
|
// See if this is a local hubloc and if so update the primary for the corresponding channel record.
|
|
|
|
if($hubloc['hubloc_url'] === z_root()) {
|
|
$r = q("select channel_id from channel where channel_hash = '%s' limit 1",
|
|
dbesc($hubloc['hubloc_hash'])
|
|
);
|
|
if($r) {
|
|
q("update channel set channel_primary = %d where channel_id = %d",
|
|
intval($hubloc['hubloc_primary']),
|
|
intval($r[0]['channel_id'])
|
|
);
|
|
}
|
|
}
|
|
|
|
// we only need to proceed further if this particular hubloc is now primary
|
|
|
|
if(! (intval($hubloc['hubloc_primary']))) {
|
|
logger('not primary: ' . $hubloc['hubloc_url']);
|
|
return false;
|
|
}
|
|
|
|
// do we even have an xchan for this hubloc and if so is it already set as primary?
|
|
|
|
$r = q("select * from xchan where xchan_hash = '%s' limit 1",
|
|
dbesc($hubloc['hubloc_hash'])
|
|
);
|
|
if(! $r) {
|
|
logger('xchan not found');
|
|
return false;
|
|
}
|
|
if($r[0]['xchan_addr'] === $hubloc['hubloc_addr']) {
|
|
logger('xchan already changed');
|
|
return false;
|
|
}
|
|
|
|
$url = $hubloc['hubloc_url'];
|
|
$lwebbie = substr($hubloc['hubloc_addr'], 0, strpos($hubloc['hubloc_addr'], '@'));
|
|
|
|
$r = q("update xchan set xchan_addr = '%s', xchan_url = '%s', xchan_follow = '%s', xchan_connurl = '%s' where xchan_hash = '%s'",
|
|
dbesc($hubloc['hubloc_addr']),
|
|
dbesc($url . '/channel/' . $lwebbie),
|
|
dbesc($url . '/follow?f=&url=%s'),
|
|
dbesc($url . '/poco/' . $lwebbie),
|
|
dbesc($hubloc['hubloc_hash'])
|
|
);
|
|
if(! $r)
|
|
logger('xchan_update failed.');
|
|
|
|
logger('primary hubloc changed.' . print_r($hubloc, true), LOGGER_DEBUG);
|
|
return true;
|
|
}
|
|
|
|
|
|
/**
|
|
* @brief Mark a hubloc as down.
|
|
*
|
|
* We use the post url to distinguish between http and https hublocs.
|
|
* The https might be alive, and the http dead.
|
|
*
|
|
* @param string $posturl Hubloc callback url which to disable
|
|
*/
|
|
function hubloc_mark_as_down($posturl) {
|
|
$r = q("update hubloc set hubloc_status = ( hubloc_status | %d ) where hubloc_callback = '%s'",
|
|
intval(HUBLOC_OFFLINE),
|
|
dbesc($posturl)
|
|
);
|
|
}
|
|
|
|
|
|
/**
|
|
* @brief return comma separated string of non-dead clone locations (net addresses) for a given netid
|
|
*
|
|
* @param string $netid network identity (typically xchan_hash or hubloc_hash)
|
|
* @return string
|
|
*/
|
|
|
|
function locations_by_netid($netid) {
|
|
|
|
$locs = q("select hubloc_addr as location from hubloc left join site on hubloc_url = site_url where hubloc_hash = '%s' and hubloc_deleted = 0 and site_dead = 0",
|
|
dbesc($netid)
|
|
);
|
|
|
|
|
|
return array_elm_to_str($locs,'location',', ','trim_and_unpunify');
|
|
|
|
}
|
|
|
|
|
|
|
|
function ping_site($url) {
|
|
|
|
$ret = array('success' => false);
|
|
|
|
$sys = get_sys_channel();
|
|
|
|
$m = zot_build_packet($sys, 'ping');
|
|
$r = zot_zot($url . '/post', $m);
|
|
if(! $r['success']) {
|
|
$ret['message'] = 'no answer from ' . $url;
|
|
return $ret;
|
|
}
|
|
$packet_result = json_decode($r['body'], true);
|
|
if(! $packet_result['success']) {
|
|
$ret['message'] = 'packet failure from ' . $url;
|
|
return $ret;
|
|
}
|
|
|
|
if($packet_result['success']) {
|
|
$ret['success'] = true;
|
|
}
|
|
else {
|
|
$ret['message'] = 'unknown error from ' . $url;
|
|
}
|
|
|
|
return $ret;
|
|
}
|