aboutsummaryrefslogtreecommitdiffstats
path: root/Zotlabs/Daemon/Content_importer.php
diff options
context:
space:
mode:
Diffstat (limited to 'Zotlabs/Daemon/Content_importer.php')
-rw-r--r--Zotlabs/Daemon/Content_importer.php18
1 files changed, 14 insertions, 4 deletions
diff --git a/Zotlabs/Daemon/Content_importer.php b/Zotlabs/Daemon/Content_importer.php
index ff6956051..4a07b4cf4 100644
--- a/Zotlabs/Daemon/Content_importer.php
+++ b/Zotlabs/Daemon/Content_importer.php
@@ -3,6 +3,8 @@
namespace Zotlabs\Daemon;
use Zotlabs\Web\HTTPSig;
+use Zotlabs\Lib\PConfig;
+
require_once('include/cli_startup.php');
require_once('include/attach.php');
@@ -38,6 +40,8 @@ class Content_importer {
$x = z_fetch_url($hz_server . '/api/z/1.0/item/export_page?f=&since=' . urlencode($since) . '&until=' . urlencode($until) . '&page=' . $page,false,$redirects,[ 'headers' => $headers ]);
+ // logger('item fetch: ' . print_r($x,true));
+
if(! $x['success']) {
logger('no API response',LOGGER_DEBUG);
killme();
@@ -48,11 +52,9 @@ class Content_importer {
return;
}
- if(! is_array($j['item']) || ! count($j['item']))
+ if(! is_array($j['item']) || ! count($j['item'])) {
return;
-
- //$total_pages = floor(intval($j['items_total']) / intval($j['items_page']));
- //logger('importing items: ' . floor((intval($page) * 100) / $total_pages) . '%');
+ }
$saved_notification_flags = notifications_off($channel['channel_id']);
@@ -60,6 +62,14 @@ class Content_importer {
notifications_on($channel['channel_id'], $saved_notification_flags);
+ PConfig::Set($channel['channel_id'], 'import', 'content_progress', [
+ 'items_total' => $j['items_total'],
+ 'items_page' => $j['items_page'],
+ 'items_current_page' => count($j['item']),
+ 'last_page' => $page,
+ 'next_cmd' => ['Content_importer', sprintf('%d',$page + 1), $since, $until, $channel['channel_address'], urlencode($hz_server)]
+ ]);
+
$page++;
Master::Summon([ 'Content_importer', sprintf('%d',$page), $since, $until, $channel['channel_address'], urlencode($hz_server) ]);