aboutsummaryrefslogtreecommitdiffstats
path: root/Zotlabs/Daemon/Directory.php
diff options
context:
space:
mode:
authorredmatrix <git@macgirvin.com>2016-05-19 19:42:45 -0700
committerredmatrix <git@macgirvin.com>2016-05-19 19:42:45 -0700
commit5b2474238eb0d257db14b0668ef25eab92e53fea (patch)
tree30518577199eeb91e902ed1f3b39401268eece6c /Zotlabs/Daemon/Directory.php
parent6e7d7c50174ffe3db78c5318dde0d9b0b1f416b8 (diff)
downloadvolse-hubzilla-5b2474238eb0d257db14b0668ef25eab92e53fea.tar.gz
volse-hubzilla-5b2474238eb0d257db14b0668ef25eab92e53fea.tar.bz2
volse-hubzilla-5b2474238eb0d257db14b0668ef25eab92e53fea.zip
first phase of daemon refactoring
Diffstat (limited to 'Zotlabs/Daemon/Directory.php')
-rw-r--r--Zotlabs/Daemon/Directory.php100
1 files changed, 100 insertions, 0 deletions
diff --git a/Zotlabs/Daemon/Directory.php b/Zotlabs/Daemon/Directory.php
new file mode 100644
index 000000000..1312f0638
--- /dev/null
+++ b/Zotlabs/Daemon/Directory.php
@@ -0,0 +1,100 @@
+<?php
+
+namespace Zotlabs\Daemon;
+
+require_once('include/zot.php');
+require_once('include/dir_fns.php');
+require_once('include/queue_fn.php');
+
+
+class Directory {
+
+ static public function run($argc,$argv){
+
+ if($argc < 2)
+ return;
+
+ $force = false;
+ $pushall = true;
+
+ if($argc > 2) {
+ if($argv[2] === 'force')
+ $force = true;
+ if($argv[2] === 'nopush')
+ $pushall = false;
+ }
+
+ logger('directory update', LOGGER_DEBUG);
+
+ $dirmode = get_config('system','directory_mode');
+ if($dirmode === false)
+ $dirmode = DIRECTORY_MODE_NORMAL;
+
+ $x = q("select * from channel where channel_id = %d limit 1",
+ intval($argv[1])
+ );
+ if(! $x)
+ return;
+
+ $channel = $x[0];
+
+ if($dirmode != DIRECTORY_MODE_NORMAL) {
+
+ // this is an in-memory update and we don't need to send a network packet.
+
+ local_dir_update($argv[1],$force);
+
+ q("update channel set channel_dirdate = '%s' where channel_id = %d",
+ dbesc(datetime_convert()),
+ intval($channel['channel_id'])
+ );
+
+ // Now update all the connections
+ if($pushall)
+ proc_run('php','include/notifier.php','refresh_all',$channel['channel_id']);
+
+ return;
+ }
+
+ // otherwise send the changes upstream
+
+ $directory = find_upstream_directory($dirmode);
+ $url = $directory['url'] . '/post';
+
+ // ensure the upstream directory is updated
+
+ $packet = zot_build_packet($channel,(($force) ? 'force_refresh' : 'refresh'));
+ $z = zot_zot($url,$packet);
+
+ // 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();
+
+ queue_insert(array(
+ 'hash' => $hash,
+ 'account_id' => $channel['channel_account_id'],
+ 'channel_id' => $channel['channel_id'],
+ 'posturl' => $url,
+ 'notify' => $packet,
+ ));
+
+ }
+ else {
+ q("update channel set channel_dirdate = '%s' where channel_id = %d",
+ dbesc(datetime_convert()),
+ intval($channel['channel_id'])
+ );
+ }
+
+ // Now update all the connections
+ if($pushall)
+ proc_run('php','include/notifier.php','refresh_all',$channel['channel_id']);
+
+ }
+}