Merge pull request #709 from dawnbreak/docu
Add some documentation for import functions.
This commit is contained in:
Klaus
GitHub
commit
dea4879938
@ -83,6 +83,7 @@ class Import extends \Zotlabs\Web\Controller {
|
||||
$api_path .= 'channel/export/basic?f=&channel=' . $channelname;
|
||||
if($import_posts)
|
||||
$api_path .= '&posts=1';
|
||||
|
||||
$binary = false;
|
||||
$redirects = 0;
|
||||
$opts = array('http_auth' => $email . ':' . $password);
|
||||
@ -104,8 +105,8 @@ class Import extends \Zotlabs\Web\Controller {
|
||||
|
||||
$data = json_decode($data,true);
|
||||
|
||||
// logger('import: data: ' . print_r($data,true));
|
||||
// print_r($data);
|
||||
//logger('import: data: ' . print_r($data,true));
|
||||
//print_r($data);
|
||||
|
||||
if(! array_key_exists('compatibility',$data)) {
|
||||
call_hooks('import_foreign_channel_data',$data);
|
||||
@ -248,7 +249,7 @@ class Import extends \Zotlabs\Web\Controller {
|
||||
|
||||
logger('import step 6');
|
||||
|
||||
|
||||
// import xchans
|
||||
$xchans = $data['xchan'];
|
||||
if($xchans) {
|
||||
foreach($xchans as $xchan) {
|
||||
@ -292,13 +293,11 @@ class Import extends \Zotlabs\Web\Controller {
|
||||
dbesc($photodate),
|
||||
dbesc($xchan['xchan_hash'])
|
||||
);
|
||||
|
||||
}
|
||||
|
||||
logger('import step 7');
|
||||
}
|
||||
|
||||
|
||||
$friends = 0;
|
||||
$feeds = 0;
|
||||
|
||||
@ -367,19 +366,20 @@ class Import extends \Zotlabs\Web\Controller {
|
||||
logger('import step 8');
|
||||
}
|
||||
|
||||
// import groups
|
||||
$groups = $data['group'];
|
||||
if($groups) {
|
||||
$saved = array();
|
||||
foreach($groups as $group) {
|
||||
$saved[$group['hash']] = array('old' => $group['id']);
|
||||
if(array_key_exists('name',$group)) {
|
||||
if(array_key_exists('name', $group)) {
|
||||
$group['gname'] = $group['name'];
|
||||
unset($group['name']);
|
||||
}
|
||||
unset($group['id']);
|
||||
$group['uid'] = $channel['channel_id'];
|
||||
|
||||
create_table_from_array('groups',$group);
|
||||
create_table_from_array('groups', $group);
|
||||
}
|
||||
$r = q("select * from groups where uid = %d",
|
||||
intval($channel['channel_id'])
|
||||
@ -391,7 +391,7 @@ class Import extends \Zotlabs\Web\Controller {
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
// import group members
|
||||
$group_members = $data['group_member'];
|
||||
if($group_members) {
|
||||
foreach($group_members as $group_member) {
|
||||
@ -401,7 +401,7 @@ class Import extends \Zotlabs\Web\Controller {
|
||||
if($x['old'] == $group_member['gid'])
|
||||
$group_member['gid'] = $x['new'];
|
||||
}
|
||||
create_table_from_array('group_member',$group_member);
|
||||
create_table_from_array('group_member', $group_member);
|
||||
}
|
||||
}
|
||||
|
||||
@ -450,7 +450,6 @@ class Import extends \Zotlabs\Web\Controller {
|
||||
|
||||
notifications_on($channel['channel_id'],$saved_notification_flags);
|
||||
|
||||
|
||||
if(array_key_exists('item_id',$data) && $data['item_id'])
|
||||
import_item_ids($channel,$data['item_id']);
|
||||
|
||||
@ -490,7 +489,7 @@ class Import extends \Zotlabs\Web\Controller {
|
||||
function get() {
|
||||
|
||||
if(! get_account_id()) {
|
||||
notice( t('You must be logged in to use this feature.'));
|
||||
notice( t('You must be logged in to use this feature.') . EOL);
|
||||
return '';
|
||||
}
|
||||
|
||||
|
||||
@ -3,7 +3,11 @@ namespace Zotlabs\Module;
|
||||
|
||||
require_once('include/import.php');
|
||||
|
||||
|
||||
/**
|
||||
* @brief Module for importing items.
|
||||
*
|
||||
* Import existing posts and content from an export file.
|
||||
*/
|
||||
class Import_items extends \Zotlabs\Web\Controller {
|
||||
|
||||
function post() {
|
||||
@ -38,7 +42,7 @@ class Import_items extends \Zotlabs\Web\Controller {
|
||||
$old_address = ((x($_REQUEST,'old_address')) ? $_REQUEST['old_address'] : '');
|
||||
|
||||
if(! $old_address) {
|
||||
logger('mod_import: nothing to import.');
|
||||
logger('Nothing to import.');
|
||||
notice( t('Nothing to import.') . EOL);
|
||||
return;
|
||||
}
|
||||
@ -64,19 +68,18 @@ class Import_items extends \Zotlabs\Web\Controller {
|
||||
$data = $ret['body'];
|
||||
else
|
||||
notice( t('Unable to download data from old server') . EOL);
|
||||
|
||||
}
|
||||
|
||||
if(! $data) {
|
||||
logger('mod_import: empty file.');
|
||||
logger('Empty file.');
|
||||
notice( t('Imported file is empty.') . EOL);
|
||||
return;
|
||||
}
|
||||
|
||||
$data = json_decode($data,true);
|
||||
$data = json_decode($data, true);
|
||||
|
||||
// logger('import: data: ' . print_r($data,true));
|
||||
// print_r($data);
|
||||
//logger('import: data: ' . print_r($data,true));
|
||||
//print_r($data);
|
||||
|
||||
if(! is_array($data))
|
||||
return;
|
||||
@ -86,13 +89,12 @@ class Import_items extends \Zotlabs\Web\Controller {
|
||||
$v2 = substr(DB_UPDATE_VERSION,-4);
|
||||
if($v2 > $v1) {
|
||||
$t = sprintf( t('Warning: Database versions differ by %1$d updates.'), $v2 - $v1 );
|
||||
notice($t);
|
||||
notice($t . EOL);
|
||||
}
|
||||
}
|
||||
|
||||
$channel = \App::get_channel();
|
||||
|
||||
|
||||
if(array_key_exists('item',$data) && $data['item']) {
|
||||
import_items($channel,$data['item'],false,((array_key_exists('relocate',$data)) ? $data['relocate'] : null));
|
||||
}
|
||||
@ -102,12 +104,14 @@ class Import_items extends \Zotlabs\Web\Controller {
|
||||
}
|
||||
|
||||
info( t('Import completed') . EOL);
|
||||
return;
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* @brief Generate item import page.
|
||||
*
|
||||
* @return string with parsed HTML.
|
||||
*/
|
||||
function get() {
|
||||
|
||||
if(! local_channel()) {
|
||||
@ -115,7 +119,7 @@ class Import_items extends \Zotlabs\Web\Controller {
|
||||
return login();
|
||||
}
|
||||
|
||||
$o = replace_macros(get_markup_template('item_import.tpl'),array(
|
||||
$o = replace_macros(get_markup_template('item_import.tpl'), array(
|
||||
'$title' => t('Import Items'),
|
||||
'$desc' => t('Use this form to import existing posts and content from an export file.'),
|
||||
'$label_filename' => t('File to Upload'),
|
||||
@ -123,9 +127,6 @@ class Import_items extends \Zotlabs\Web\Controller {
|
||||
));
|
||||
|
||||
return $o;
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
||||
@ -1,6 +1,17 @@
|
||||
<?php /** @file */
|
||||
|
||||
<?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 = [
|
||||
@ -25,8 +36,7 @@ function hubloc_store_lowlevel($arr) {
|
||||
'hubloc_deleted' => ((array_key_exists('hubloc_deleted',$arr)) ? $arr['hubloc_deleted'] : 0)
|
||||
];
|
||||
|
||||
return create_table_from_array('hubloc',$store);
|
||||
|
||||
return create_table_from_array('hubloc', $store);
|
||||
}
|
||||
|
||||
|
||||
@ -45,9 +55,8 @@ function prune_hub_reinstalls() {
|
||||
// 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');
|
||||
$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.
|
||||
@ -63,18 +72,22 @@ function prune_hub_reinstalls() {
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @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);
|
||||
|
||||
// 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.
|
||||
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
|
||||
@ -82,27 +95,25 @@ function remove_obsolete_hublocs() {
|
||||
|
||||
$r = q("select hubloc_id from hubloc where hubloc_url = '%s' and hubloc_sitekey = '%s'",
|
||||
dbesc(z_root()),
|
||||
dbesc(get_config('system','pubkey'))
|
||||
dbesc(get_config('system', 'pubkey'))
|
||||
);
|
||||
if((! $r) || (! count($r)))
|
||||
return;
|
||||
|
||||
$channels = array();
|
||||
|
||||
// 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(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(get_config('system', 'pubkey')),
|
||||
dbesc(z_root())
|
||||
);
|
||||
if(is_array($r) && is_array($p))
|
||||
$r = array_merge($r,$p);
|
||||
$r = array_merge($r, $p);
|
||||
|
||||
if(! $r)
|
||||
return;
|
||||
@ -111,8 +122,8 @@ function remove_obsolete_hublocs() {
|
||||
|
||||
logger('remove_obsolete_hublocs: removing ' . count($r) . ' hublocs.');
|
||||
|
||||
$interval = ((get_config('system','delivery_interval') !== false)
|
||||
? intval(get_config('system','delivery_interval')) : 2 );
|
||||
$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",
|
||||
@ -123,7 +134,7 @@ function remove_obsolete_hublocs() {
|
||||
dbesc($rr['hubloc_hash'])
|
||||
);
|
||||
if($x) {
|
||||
Zotlabs\Daemon\Master::Summon(array('Notifier','location',$x[0]['channel_id']));
|
||||
Zotlabs\Daemon\Master::Summon(array('Notifier', 'location', $x[0]['channel_id']));
|
||||
if($interval)
|
||||
@time_sleep_until(microtime(true) + (float) $interval);
|
||||
}
|
||||
@ -131,8 +142,15 @@ function remove_obsolete_hublocs() {
|
||||
}
|
||||
|
||||
|
||||
// This actually changes other structures to match the given (presumably current) hubloc primary selection
|
||||
|
||||
/**
|
||||
* @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)) {
|
||||
@ -179,7 +197,7 @@ function hubloc_change_primary($hubloc) {
|
||||
}
|
||||
|
||||
$url = $hubloc['hubloc_url'];
|
||||
$lwebbie = substr($hubloc['hubloc_addr'],0,strpos($hubloc['hubloc_addr'],'@'));
|
||||
$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']),
|
||||
@ -191,14 +209,19 @@ function hubloc_change_primary($hubloc) {
|
||||
if(! $r)
|
||||
logger('xchan_update failed.');
|
||||
|
||||
logger('primary hubloc changed.' . print_r($hubloc,true),LOGGER_DEBUG);
|
||||
logger('primary hubloc changed.' . print_r($hubloc, true), LOGGER_DEBUG);
|
||||
return true;
|
||||
|
||||
}
|
||||
|
||||
// We use the post url to distinguish between http and https hublocs.
|
||||
// The https might be alive, and the http dead.
|
||||
|
||||
/**
|
||||
* @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),
|
||||
@ -208,20 +231,19 @@ function hubloc_mark_as_down($posturl) {
|
||||
|
||||
|
||||
|
||||
|
||||
function ping_site($url) {
|
||||
|
||||
$ret = array('success' => false);
|
||||
|
||||
$sys = get_sys_channel();
|
||||
|
||||
$m = zot_build_packet($sys,'ping');
|
||||
$r = zot_zot($url . '/post',$m);
|
||||
$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);
|
||||
$packet_result = json_decode($r['body'], true);
|
||||
if(! $packet_result['success']) {
|
||||
$ret['message'] = 'packet failure from ' . $url;
|
||||
return $ret;
|
||||
|
||||
@ -1,8 +1,19 @@
|
||||
<?php
|
||||
|
||||
use Zotlabs\Lib\IConfig;
|
||||
|
||||
require_once('include/menu.php');
|
||||
require_once('include/perm_upgrade.php');
|
||||
|
||||
|
||||
/**
|
||||
* @brief Import a channel.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param int $account_id
|
||||
* @param int $seize
|
||||
* @return boolean|array
|
||||
*/
|
||||
function import_channel($channel, $account_id, $seize) {
|
||||
|
||||
if(! array_key_exists('channel_system',$channel)) {
|
||||
@ -108,24 +119,37 @@ function import_channel($channel, $account_id, $seize) {
|
||||
set_default_login_identity($account_id,$channel['channel_id'],false);
|
||||
logger('import step 1');
|
||||
$_SESSION['import_step'] = 1;
|
||||
return $channel;
|
||||
|
||||
return $channel;
|
||||
}
|
||||
|
||||
function import_config($channel,$configs) {
|
||||
/**
|
||||
* @brief Import pconfig for channel.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $configs
|
||||
*/
|
||||
function import_config($channel, $configs) {
|
||||
|
||||
if($channel && $configs) {
|
||||
foreach($configs as $config) {
|
||||
unset($config['id']);
|
||||
$config['uid'] = $channel['channel_id'];
|
||||
create_table_from_array('pconfig',$config);
|
||||
|
||||
create_table_from_array('pconfig', $config);
|
||||
}
|
||||
|
||||
load_pconfig($channel['channel_id']);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
function import_profiles($channel,$profiles) {
|
||||
/**
|
||||
* @brief Import profiles.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $profiles
|
||||
*/
|
||||
function import_profiles($channel, $profiles) {
|
||||
|
||||
if($channel && $profiles) {
|
||||
foreach($profiles as $profile) {
|
||||
@ -137,19 +161,29 @@ function import_profiles($channel,$profiles) {
|
||||
convert_oldfields($profile,'with','partner');
|
||||
convert_oldfields($profile,'work','employment');
|
||||
|
||||
|
||||
// we are going to reset all profile photos to the original
|
||||
// somebody will have to fix this later and put all the applicable photos into the export
|
||||
/**
|
||||
* @TODO we are going to reset all profile photos to the original
|
||||
* somebody will have to fix this later and put all the applicable
|
||||
* photos into the export.
|
||||
*/
|
||||
|
||||
$profile['photo'] = z_root() . '/photo/profile/l/' . $channel['channel_id'];
|
||||
$profile['thumb'] = z_root() . '/photo/profile/m/' . $channel['channel_id'];
|
||||
create_table_from_array('profile',$profile);
|
||||
|
||||
create_table_from_array('profile', $profile);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
function import_hublocs($channel,$hublocs,$seize,$moving = false) {
|
||||
/**
|
||||
* @brief Import hublocs.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $hublocs
|
||||
* @param unknown $seize
|
||||
* @param boolean $moving
|
||||
*/
|
||||
function import_hublocs($channel, $hublocs, $seize, $moving = false) {
|
||||
|
||||
if($channel && $hublocs) {
|
||||
foreach($hublocs as $hubloc) {
|
||||
@ -183,7 +217,7 @@ function import_hublocs($channel,$hublocs,$seize,$moving = false) {
|
||||
|
||||
if(($x = zot_gethub($arr,false)) === false) {
|
||||
unset($hubloc['hubloc_id']);
|
||||
create_table_from_array('hubloc',$hubloc);
|
||||
create_table_from_array('hubloc', $hubloc);
|
||||
}
|
||||
else {
|
||||
q("UPDATE hubloc set hubloc_primary = %d, hubloc_deleted = %d where hubloc_id = %d",
|
||||
@ -191,15 +225,18 @@ function import_hublocs($channel,$hublocs,$seize,$moving = false) {
|
||||
intval($hubloc['hubloc_deleted']),
|
||||
intval($x['hubloc_id'])
|
||||
);
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
function import_objs($channel,$objs) {
|
||||
/**
|
||||
* @brief Import things.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $objs
|
||||
*/
|
||||
function import_objs($channel, $objs) {
|
||||
|
||||
if($channel && $objs) {
|
||||
foreach($objs as $obj) {
|
||||
@ -214,21 +251,27 @@ function import_objs($channel,$objs) {
|
||||
|
||||
$obj['obj_channel'] = $channel['channel_id'];
|
||||
|
||||
if($baseurl && (strpos($obj['obj_url'],$baseurl . '/thing/') !== false)) {
|
||||
$obj['obj_url'] = str_replace($baseurl,z_root(),$obj['obj_url']);
|
||||
if($baseurl && (strpos($obj['obj_url'], $baseurl . '/thing/') !== false)) {
|
||||
$obj['obj_url'] = str_replace($baseurl, z_root(), $obj['obj_url']);
|
||||
}
|
||||
|
||||
if($obj['obj_imgurl']) {
|
||||
$x = import_xchan_photo($obj['obj_imgurl'],$channel['channel_hash'],true);
|
||||
$x = import_xchan_photo($obj['obj_imgurl'], $channel['channel_hash'], true);
|
||||
$obj['obj_imgurl'] = $x[0];
|
||||
}
|
||||
|
||||
create_table_from_array('obj',$obj);
|
||||
create_table_from_array('obj', $obj);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function sync_objs($channel,$objs) {
|
||||
/**
|
||||
* @brief Import things.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $objs
|
||||
*/
|
||||
function sync_objs($channel, $objs) {
|
||||
|
||||
if($channel && $objs) {
|
||||
foreach($objs as $obj) {
|
||||
@ -251,8 +294,8 @@ function sync_objs($channel,$objs) {
|
||||
|
||||
$obj['obj_channel'] = $channel['channel_id'];
|
||||
|
||||
if($baseurl && (strpos($obj['obj_url'],$baseurl . '/thing/') !== false)) {
|
||||
$obj['obj_url'] = str_replace($baseurl,z_root(),$obj['obj_url']);
|
||||
if($baseurl && (strpos($obj['obj_url'], $baseurl . '/thing/') !== false)) {
|
||||
$obj['obj_url'] = str_replace($baseurl, z_root(), $obj['obj_url']);
|
||||
}
|
||||
|
||||
$exists = false;
|
||||
@ -269,7 +312,7 @@ function sync_objs($channel,$objs) {
|
||||
}
|
||||
|
||||
if($obj['obj_imgurl']) {
|
||||
$x = import_xchan_photo($obj['obj_imgurl'],$channel['channel_hash'],true);
|
||||
$x = import_xchan_photo($obj['obj_imgurl'], $channel['channel_hash'], true);
|
||||
$obj['obj_imgurl'] = $x[0];
|
||||
}
|
||||
|
||||
@ -287,17 +330,19 @@ function sync_objs($channel,$objs) {
|
||||
}
|
||||
}
|
||||
else {
|
||||
create_table_from_array('obj',$obj);
|
||||
create_table_from_array('obj', $obj);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
function import_apps($channel,$apps) {
|
||||
/**
|
||||
* @brief Import apps.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $apps
|
||||
*/
|
||||
function import_apps($channel, $apps) {
|
||||
|
||||
if($channel && $apps) {
|
||||
foreach($apps as $app) {
|
||||
@ -311,13 +356,13 @@ function import_apps($channel,$apps) {
|
||||
$app['app_channel'] = $channel['channel_id'];
|
||||
|
||||
if($app['app_photo']) {
|
||||
$x = import_xchan_photo($app['app_photo'],$channel['channel_hash'],true);
|
||||
$x = import_xchan_photo($app['app_photo'], $channel['channel_hash'], true);
|
||||
$app['app_photo'] = $x[0];
|
||||
}
|
||||
|
||||
$hash = $app['app_id'];
|
||||
|
||||
create_table_from_array('app',$app);
|
||||
create_table_from_array('app', $app);
|
||||
|
||||
if($term) {
|
||||
$x = q("select * from app where app_id = '%s' and app_channel = %d limit 1",
|
||||
@ -328,20 +373,22 @@ function import_apps($channel,$apps) {
|
||||
foreach($term as $t) {
|
||||
if(array_key_exists('type',$t))
|
||||
$t['ttype'] = $t['type'];
|
||||
|
||||
store_item_tag($channel['channel_id'],$x[0]['id'],TERM_OBJ_APP,$t['ttype'],escape_tags($t['term']),escape_tags($t['url']));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
function sync_apps($channel,$apps) {
|
||||
/**
|
||||
* @brief Sync apps.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $apps
|
||||
*/
|
||||
function sync_apps($channel, $apps) {
|
||||
|
||||
if($channel && $apps) {
|
||||
foreach($apps as $app) {
|
||||
@ -440,9 +487,13 @@ function sync_apps($channel,$apps) {
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
function import_chatrooms($channel,$chatrooms) {
|
||||
/**
|
||||
* @brief Import chatrooms.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $chatrooms
|
||||
*/
|
||||
function import_chatrooms($channel, $chatrooms) {
|
||||
|
||||
if($channel && $chatrooms) {
|
||||
foreach($chatrooms as $chatroom) {
|
||||
@ -457,14 +508,18 @@ function import_chatrooms($channel,$chatrooms) {
|
||||
$chatroom['cr_aid'] = $channel['channel_account_id'];
|
||||
$chatroom['cr_uid'] = $channel['channel_id'];
|
||||
|
||||
create_table_from_array('chatroom',$chatroom);
|
||||
create_table_from_array('chatroom', $chatroom);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
function sync_chatrooms($channel,$chatrooms) {
|
||||
/**
|
||||
* @brief Sync chatrooms.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $chatrooms
|
||||
*/
|
||||
function sync_chatrooms($channel, $chatrooms) {
|
||||
|
||||
if($channel && $chatrooms) {
|
||||
foreach($chatrooms as $chatroom) {
|
||||
@ -480,7 +535,6 @@ function sync_chatrooms($channel,$chatrooms) {
|
||||
continue;
|
||||
}
|
||||
|
||||
|
||||
unset($chatroom['cr_id']);
|
||||
unset($chatroom['cr_aid']);
|
||||
unset($chatroom['cr_uid']);
|
||||
@ -502,6 +556,7 @@ function sync_chatrooms($channel,$chatrooms) {
|
||||
if($x) {
|
||||
if($x[0]['cr_edited'] >= $chatroom['cr_edited'])
|
||||
continue;
|
||||
|
||||
$exists = true;
|
||||
}
|
||||
$name = $chatroom['cr_name'];
|
||||
@ -517,15 +572,22 @@ function sync_chatrooms($channel,$chatrooms) {
|
||||
}
|
||||
}
|
||||
else {
|
||||
create_table_from_array('chatroom',$chatroom);
|
||||
create_table_from_array('chatroom', $chatroom);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
function import_items($channel,$items,$sync = false,$relocate = null) {
|
||||
/**
|
||||
* @brief Import items to channel.
|
||||
*
|
||||
* @param array $channel where to import to
|
||||
* @param array $items
|
||||
* @param boolean $sync
|
||||
* @param array $relocate default null
|
||||
*/
|
||||
function import_items($channel, $items, $sync = false, $relocate = null) {
|
||||
|
||||
if($channel && $items) {
|
||||
|
||||
@ -578,9 +640,17 @@ function import_items($channel,$items,$sync = false,$relocate = null) {
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
function sync_items($channel,$items,$relocate = null) {
|
||||
import_items($channel,$items,true,$relocate);
|
||||
/**
|
||||
* @brief Sync items to channel.
|
||||
*
|
||||
* @see import_items
|
||||
*
|
||||
* @param array $channel where to import to
|
||||
* @param array $items
|
||||
* @param array $relocate default null
|
||||
*/
|
||||
function sync_items($channel, $items, $relocate = null) {
|
||||
import_items($channel, $items, true, $relocate);
|
||||
}
|
||||
|
||||
|
||||
@ -601,13 +671,19 @@ function import_item_ids($channel,$itemids) {
|
||||
intval($r[0]['id'])
|
||||
);
|
||||
if(! $z) {
|
||||
\Zotlabs\Lib\IConfig::Set($r[0]['id'],'system',$i['service'],$i['sid'],true);
|
||||
IConfig::Set($r[0]['id'],'system',$i['service'],$i['sid'],true);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function import_events($channel,$events) {
|
||||
/**
|
||||
* @brief Import events.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $events
|
||||
*/
|
||||
function import_events($channel, $events) {
|
||||
|
||||
if($channel && $events) {
|
||||
foreach($events as $event) {
|
||||
@ -619,13 +695,18 @@ function import_events($channel,$events) {
|
||||
convert_oldfields($event,'type','etype');
|
||||
convert_oldfields($event,'ignore','dismissed');
|
||||
|
||||
create_table_from_array('event',$event);
|
||||
create_table_from_array('event', $event);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
function sync_events($channel,$events) {
|
||||
/**
|
||||
* @brief Sync events.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $events
|
||||
*/
|
||||
function sync_events($channel, $events) {
|
||||
|
||||
if($channel && $events) {
|
||||
foreach($events as $event) {
|
||||
@ -650,7 +731,6 @@ function sync_events($channel,$events) {
|
||||
convert_oldfields($event,'type','etype');
|
||||
convert_oldfields($event,'ignore','dismissed');
|
||||
|
||||
|
||||
$exists = false;
|
||||
|
||||
$x = q("select * from event where event_hash = '%s' and uid = %d limit 1",
|
||||
@ -660,6 +740,7 @@ function sync_events($channel,$events) {
|
||||
if($x) {
|
||||
if($x[0]['edited'] >= $event['edited'])
|
||||
continue;
|
||||
|
||||
$exists = true;
|
||||
}
|
||||
|
||||
@ -674,15 +755,19 @@ function sync_events($channel,$events) {
|
||||
}
|
||||
}
|
||||
else {
|
||||
create_table_from_array('event',$event);
|
||||
create_table_from_array('event', $event);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
function import_menus($channel,$menus) {
|
||||
|
||||
/**
|
||||
* @brief Import menus.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $menus
|
||||
*/
|
||||
function import_menus($channel, $menus) {
|
||||
|
||||
if($channel && $menus) {
|
||||
foreach($menus as $menu) {
|
||||
@ -701,7 +786,6 @@ function import_menus($channel,$menus) {
|
||||
$m['menu_flags'] |= MENU_BOOKMARK;
|
||||
if(in_array('system',$menu['flags']))
|
||||
$m['menu_flags'] |= MENU_SYSTEM;
|
||||
|
||||
}
|
||||
|
||||
$menu_id = menu_create($m);
|
||||
@ -733,12 +817,15 @@ function import_menus($channel,$menus) {
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
|
||||
function sync_menus($channel,$menus) {
|
||||
/**
|
||||
* @brief Sync menus.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $menus
|
||||
*/
|
||||
function sync_menus($channel, $menus) {
|
||||
|
||||
if($channel && $menus) {
|
||||
foreach($menus as $menu) {
|
||||
@ -795,7 +882,6 @@ function sync_menus($channel,$menus) {
|
||||
foreach($menu['items'] as $it) {
|
||||
$mitem = array();
|
||||
|
||||
|
||||
$mitem['mitem_link'] = str_replace('[channelurl]',z_root() . '/channel/' . $channel['channel_address'],$it['link']);
|
||||
$mitem['mitem_link'] = str_replace('[pageurl]',z_root() . '/page/' . $channel['channel_address'],$it['link']);
|
||||
$mitem['mitem_link'] = str_replace('[cloudurl]',z_root() . '/cloud/' . $channel['channel_address'],$it['link']);
|
||||
@ -820,9 +906,13 @@ function sync_menus($channel,$menus) {
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
function import_likes($channel,$likes) {
|
||||
/**
|
||||
* @brief Import likes.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $likes
|
||||
*/
|
||||
function import_likes($channel, $likes) {
|
||||
if($channel && $likes) {
|
||||
foreach($likes as $like) {
|
||||
if($like['deleted']) {
|
||||
@ -850,7 +940,7 @@ function import_likes($channel,$likes) {
|
||||
if($r)
|
||||
continue;
|
||||
|
||||
create_table_from_array('likes',$like);
|
||||
create_table_from_array('likes', $like);
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -877,14 +967,19 @@ function import_conv($channel,$convs) {
|
||||
);
|
||||
if($r)
|
||||
continue;
|
||||
|
||||
create_table_from_array('conv',$conv);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
function import_mail($channel,$mails,$sync = false) {
|
||||
/**
|
||||
* @brief Import mails.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $mails
|
||||
*/
|
||||
function import_mail($channel, $mails, $sync = false) {
|
||||
if($channel && $mails) {
|
||||
foreach($mails as $mail) {
|
||||
if(array_key_exists('flags',$mail) && in_array('deleted',$mail['flags'])) {
|
||||
@ -916,11 +1011,24 @@ function import_mail($channel,$mails,$sync = false) {
|
||||
}
|
||||
}
|
||||
|
||||
function sync_mail($channel,$mails) {
|
||||
import_mail($channel,$mails,true);
|
||||
/**
|
||||
* @brief Synchronise mails.
|
||||
*
|
||||
* @see import_mail
|
||||
* @param array $channel
|
||||
* @param array $mails
|
||||
*/
|
||||
function sync_mail($channel, $mails) {
|
||||
import_mail($channel, $mails, true);
|
||||
}
|
||||
|
||||
function sync_files($channel,$files) {
|
||||
/**
|
||||
* @brief Synchronise files.
|
||||
*
|
||||
* @param array $channel
|
||||
* @param array $files
|
||||
*/
|
||||
function sync_files($channel, $files) {
|
||||
|
||||
require_once('include/attach.php');
|
||||
|
||||
@ -964,7 +1072,6 @@ function sync_files($channel,$files) {
|
||||
$att['aid'] = $channel['channel_account_id'];
|
||||
$att['uid'] = $channel['channel_id'];
|
||||
|
||||
|
||||
// check for duplicate folder names with the same parent.
|
||||
// If we have a duplicate that doesn't match this hash value
|
||||
// change the name so that the contents won't be "covered over"
|
||||
@ -1009,7 +1116,7 @@ function sync_files($channel,$files) {
|
||||
|
||||
// end duplicate detection
|
||||
|
||||
// @fixme - update attachment structures if they are modified rather than created
|
||||
/// @FIXME update attachment structures if they are modified rather than created
|
||||
|
||||
$att['content'] = $newfname;
|
||||
|
||||
@ -1018,19 +1125,20 @@ function sync_files($channel,$files) {
|
||||
// If the hash ever contains any escapable chars this could cause
|
||||
// problems. Currently it does not.
|
||||
|
||||
// @TODO implement os_path
|
||||
/// @TODO implement os_path
|
||||
if(!isset($att['os_path']))
|
||||
$att['os_path'] = '';
|
||||
|
||||
|
||||
if($attach_exists) {
|
||||
logger('sync_files attach exists: ' . print_r($att,true), LOGGER_DEBUG);
|
||||
if(! dbesc_array($att))
|
||||
continue;
|
||||
|
||||
$str = '';
|
||||
foreach($att as $k => $v) {
|
||||
if($str)
|
||||
$str .= ",";
|
||||
|
||||
$str .= " " . TQUOT . $k . TQUOT . " = '" . $v . "' ";
|
||||
}
|
||||
$r = dbq("update attach set " . $str . " where id = " . intval($attach_id) );
|
||||
@ -1040,7 +1148,6 @@ function sync_files($channel,$files) {
|
||||
create_table_from_array('attach',$att);
|
||||
}
|
||||
|
||||
|
||||
// is this a directory?
|
||||
|
||||
if($att['filetype'] === 'multipart/mixed' && $att['is_dir']) {
|
||||
@ -1049,7 +1156,6 @@ function sync_files($channel,$files) {
|
||||
continue;
|
||||
}
|
||||
else {
|
||||
|
||||
// it's a file
|
||||
// for the sync version of this algorithm (as opposed to 'offline import')
|
||||
// we will fetch the actual file from the source server so it can be
|
||||
@ -1084,7 +1190,7 @@ function sync_files($channel,$files) {
|
||||
}
|
||||
}
|
||||
if(! $attachment_stored) {
|
||||
// @TODO should we queue this and retry or delete everything or what?
|
||||
/// @TODO should we queue this and retry or delete everything or what?
|
||||
logger('attachment store failed',LOGGER_NORMAL,LOG_ERR);
|
||||
}
|
||||
if($f['photo']) {
|
||||
@ -1128,7 +1234,6 @@ function sync_files($channel,$files) {
|
||||
else
|
||||
$p['content'] = base64_decode($p['content']);
|
||||
|
||||
|
||||
if(!isset($p['display_path']))
|
||||
$p['display_path'] = '';
|
||||
|
||||
@ -1138,14 +1243,15 @@ function sync_files($channel,$files) {
|
||||
intval($channel['channel_id'])
|
||||
);
|
||||
|
||||
|
||||
if($exists) {
|
||||
if(! dbesc_array($p))
|
||||
continue;
|
||||
|
||||
$str = '';
|
||||
foreach($p as $k => $v) {
|
||||
if($str)
|
||||
$str .= ",";
|
||||
|
||||
$str .= " " . TQUOT . $k . TQUOT . " = '" . $v . "' ";
|
||||
}
|
||||
$r = dbq("update photo set " . $str . " where id = " . intval($exists[0]['id']) );
|
||||
@ -1164,9 +1270,17 @@ function sync_files($channel,$files) {
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
function convert_oldfields(&$arr,$old,$new) {
|
||||
if(array_key_exists($old,$arr)) {
|
||||
/**
|
||||
* @brief Rename a key in an array.
|
||||
*
|
||||
* Replaces $old key with $new key in $arr.
|
||||
*
|
||||
* @param array[in,out] $arr The array where to work on
|
||||
* @param string $old The old key in the array
|
||||
* @param string $new The new key in the array
|
||||
*/
|
||||
function convert_oldfields(&$arr, $old, $new) {
|
||||
if(array_key_exists($old, $arr)) {
|
||||
$arr[$new] = $arr[$old];
|
||||
unset($arr[$old]);
|
||||
}
|
||||
@ -1240,6 +1354,7 @@ function scan_webpage_elements($path, $type, $cloud = false) {
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return $elements;
|
||||
}
|
||||
|
||||
@ -1352,8 +1467,7 @@ function import_webpage_element($element, $channel, $type) {
|
||||
intval(local_channel())
|
||||
);
|
||||
|
||||
\Zotlabs\Lib\IConfig::Set($arr,'system',$namespace,(($name) ? $name : substr($arr['mid'],0,16)),true);
|
||||
|
||||
IConfig::Set($arr,'system',$namespace,(($name) ? $name : substr($arr['mid'],0,16)),true);
|
||||
|
||||
if($i) {
|
||||
$arr['id'] = $i[0]['id'];
|
||||
@ -1374,7 +1488,7 @@ function import_webpage_element($element, $channel, $type) {
|
||||
}
|
||||
|
||||
if($x && $x['success']) {
|
||||
$item_id = $x['item_id'];
|
||||
//$item_id = $x['item_id'];
|
||||
//update_remote_id($channel, $item_id, $arr['item_type'], $name, $namespace, $remote_id, $arr['mid']);
|
||||
$element['import_success'] = 1;
|
||||
}
|
||||
@ -1399,7 +1513,6 @@ function get_webpage_elements($channel, $type = 'all') {
|
||||
|
||||
$sql_extra = item_permissions_sql($owner);
|
||||
|
||||
|
||||
$r = q("select * from iconfig left join item on iconfig.iid = item.id
|
||||
where item.uid = %d and iconfig.cat = 'system' and iconfig.k = 'WEBPAGE' and item_type = %d
|
||||
$sql_extra order by item.created desc",
|
||||
@ -1439,7 +1552,6 @@ function get_webpage_elements($channel, $type = 'all') {
|
||||
);
|
||||
$elements['pages'][] = $element_arr;
|
||||
}
|
||||
|
||||
}
|
||||
if($type !== 'all') {
|
||||
break;
|
||||
@ -1451,7 +1563,6 @@ function get_webpage_elements($channel, $type = 'all') {
|
||||
|
||||
$sql_extra = item_permissions_sql($owner);
|
||||
|
||||
|
||||
$r = q("select * from iconfig left join item on iconfig.iid = item.id
|
||||
where item.uid = %d and iconfig.cat = 'system' and iconfig.k = 'PDL' and item_type = %d
|
||||
$sql_extra order by item.created desc",
|
||||
@ -1459,11 +1570,9 @@ function get_webpage_elements($channel, $type = 'all') {
|
||||
intval(ITEM_TYPE_PDL)
|
||||
);
|
||||
|
||||
$layouts = null;
|
||||
|
||||
if($r) {
|
||||
$elements['layouts'] = array();
|
||||
$layouts = array();
|
||||
|
||||
foreach($r as $rr) {
|
||||
unobscure($rr);
|
||||
|
||||
@ -1490,7 +1599,6 @@ function get_webpage_elements($channel, $type = 'all') {
|
||||
|
||||
$sql_extra = item_permissions_sql($owner);
|
||||
|
||||
|
||||
$r = q("select iconfig.iid, iconfig.k, iconfig.v, mid, title, body, mimetype, created, edited from iconfig
|
||||
left join item on iconfig.iid = item.id
|
||||
where uid = %d and iconfig.cat = 'system' and iconfig.k = 'BUILDBLOCK'
|
||||
@ -1499,11 +1607,9 @@ function get_webpage_elements($channel, $type = 'all') {
|
||||
intval(ITEM_TYPE_BLOCK)
|
||||
);
|
||||
|
||||
$blocks = null;
|
||||
|
||||
if($r) {
|
||||
$elements['blocks'] = array();
|
||||
$blocks = array();
|
||||
|
||||
foreach($r as $rr) {
|
||||
unobscure($rr);
|
||||
|
||||
@ -1518,7 +1624,6 @@ function get_webpage_elements($channel, $type = 'all') {
|
||||
'mid' => $rr['mid']
|
||||
);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
if($type !== 'all') {
|
||||
@ -1528,11 +1633,18 @@ function get_webpage_elements($channel, $type = 'all') {
|
||||
default:
|
||||
break;
|
||||
}
|
||||
|
||||
return $elements;
|
||||
}
|
||||
|
||||
/* creates a compressed zip file */
|
||||
|
||||
/**
|
||||
* @brief Create a compressed zip file.
|
||||
*
|
||||
* @param array $files List of files to put in zip file
|
||||
* @param string $destination
|
||||
* @param boolean $overwrite
|
||||
* @return boolean Success status
|
||||
*/
|
||||
function create_zip_file($files = array(), $destination = '', $overwrite = false) {
|
||||
// if the zip file already exists and overwrite is false, return false
|
||||
if(file_exists($destination) && !$overwrite) {
|
||||
@ -1555,7 +1667,7 @@ function create_zip_file($files = array(), $destination = '', $overwrite = false
|
||||
if(count($valid_files)) {
|
||||
//create the archive
|
||||
$zip = new ZipArchive();
|
||||
if($zip->open($destination, $overwrite ? ZIPARCHIVE::OVERWRITE : ZIPARCHIVE::CREATE) !== true) {
|
||||
if($zip->open($destination, $overwrite ? ZipArchive::OVERWRITE : ZipArchive::CREATE) !== true) {
|
||||
return false;
|
||||
}
|
||||
// add the files
|
||||
|
||||
@ -3050,7 +3050,15 @@ function array2XML($obj, $array) {
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @brief Inserts an array into $table.
|
||||
*
|
||||
* @TODO Why is this function in include/text.php?
|
||||
*
|
||||
* @param string $table
|
||||
* @param array $arr
|
||||
* @return boolean|PDOStatement
|
||||
*/
|
||||
function create_table_from_array($table, $arr) {
|
||||
|
||||
if(! ($arr && $table))
|
||||
|
||||
Reference in New Issue
Block a user