diff options
| author | zotlabs <mike@macgirvin.com> | 2018-11-08 19:24:02 -0800 |
|---|---|---|
| committer | zotlabs <mike@macgirvin.com> | 2018-11-08 19:24:02 -0800 |
| commit | 22b3ddab66f128ca05a42ebfccda0964bddd7509 (patch) | |
| tree | 93b18472ca5e98e19d85a3b3212b30848e9b454f /Zotlabs/Daemon | |
| parent | 3fe2491b737375e7c616c47366d5ab6f1c4fb851 (diff) | |
| download | volse-hubzilla-22b3ddab66f128ca05a42ebfccda0964bddd7509.tar.gz volse-hubzilla-22b3ddab66f128ca05a42ebfccda0964bddd7509.tar.bz2 volse-hubzilla-22b3ddab66f128ca05a42ebfccda0964bddd7509.zip | |
refresh packets
Diffstat (limited to 'Zotlabs/Daemon')
| -rw-r--r-- | Zotlabs/Daemon/Notifier.php | 15 |
1 files changed, 12 insertions, 3 deletions
diff --git a/Zotlabs/Daemon/Notifier.php b/Zotlabs/Daemon/Notifier.php index f74c8f11c..48928f5ba 100644 --- a/Zotlabs/Daemon/Notifier.php +++ b/Zotlabs/Daemon/Notifier.php @@ -2,6 +2,8 @@ namespace Zotlabs\Daemon; +use Zotlabs\Lib\Libzot; + require_once('include/queue_fn.php'); require_once('include/html2plain.php'); require_once('include/conversation.php'); @@ -561,7 +563,7 @@ class Notifier { logger('notifier_hub: ' . $hub['hubloc_url'],LOGGER_DEBUG); - if($hub['hubloc_network'] !== 'zot') { + if(! in_array($hub['hubloc_network'], [ 'zot','zot6' ])) { $narr = [ 'channel' => $channel, 'upstream' => $upstream, @@ -610,14 +612,21 @@ class Notifier { continue; } - // default: zot protocol + if(! in_array($hub['hubloc_network'], [ 'zot','zot6' ])) { + continue; + } $hash = random_string(); $packet = null; $pmsg = ''; if($packet_type === 'refresh' || $packet_type === 'purge') { - $packet = zot_build_packet($channel,$packet_type,(($packet_recips) ? $packet_recips : null)); + if($hub['hubloc_network'] === 'zot6') { + $packet = Libzot::build_packet($channel, $packet_type, ids_to_array($packet_recips,'hash')); + } + else { + $packet = zot_build_packet($channel,$packet_type,(($packet_recips) ? $packet_recips : null)); + } } if($packet_type === 'keychange') { $pmsg = get_pconfig($channel['channel_id'],'system','keychange'); |