<?php namespace Zotlabs\Daemon; use Zotlabs\Web\HTTPSig; use Zotlabs\Lib\PConfig; require_once('include/cli_startup.php'); require_once('include/attach.php'); require_once('include/import.php'); class File_importer { static public function run($argc,$argv) { cli_startup(); $page = $argv[1]; $channel_address = $argv[2]; $hz_server = urldecode($argv[3]); $m = parse_url($hz_server); $channel = channelx_by_nick($channel_address); if(! $channel) { logger('channel not found'); return; } $headers = [ 'X-API-Token' => random_string(), 'X-API-Request' => $hz_server . '/api/z/1.0/file/export_page?f=records=1&page=' . $page, 'Host' => $m['host'], '(request-target)' => 'get /api/z/1.0/file/export_page?f=records=1&page=' . $page, ]; $headers = HTTPSig::create_sig($headers,$channel['channel_prvkey'],channel_url($channel),true,'sha512'); // TODO: implement total count $x = z_fetch_url($hz_server . '/api/z/1.0/file/export_page?f=records=1&page=' . $page, false, $redirects, [ 'headers' => $headers ]); // logger('file fetch: ' . print_r($x,true)); if(! $x['success']) { logger('no API response',LOGGER_DEBUG); killme(); } $j = json_decode($x['body'],true); if(! is_array($j['results'][0]['attach']) || ! count($j['results'][0]['attach'])) { PConfig::Set($channel['channel_id'], 'import', 'files_completed', 1); return; } $r = sync_files($channel, $j['results']); PConfig::Set($channel['channel_id'], 'import', 'files_progress', [ 'files_total' => $j['total'], 'files_page' => 1, // export page atm returns just one file 'last_page' => $page, 'next_cmd' => ['File_importer',sprintf('%d',$page + 1), $channel['channel_address'], urlencode($hz_server)] ]); $page++; Master::Summon([ 'File_importer',sprintf('%d',$page), $channel['channel_address'], urlencode($hz_server) ]); return; } }