diff options
| -rw-r--r-- | include/zot.php | 2 | ||||
| -rw-r--r-- | mod/import.php | 145 |
2 files changed, 145 insertions, 2 deletions
diff --git a/include/zot.php b/include/zot.php index 4fcf518f5..524f958ad 100644 --- a/include/zot.php +++ b/include/zot.php @@ -19,7 +19,7 @@ function zot_new_uid($channel_nick) { /** * - * Given an array of zot_uid(s), return all distinct hubs + * Given an array of zot hashes, return all distinct hubs * If primary is true, return only primary hubs * Result is ordered by url to assist in batching. * Return only the first primary hub as there should only be one. diff --git a/mod/import.php b/mod/import.php index 7b5989f51..e9885cc7a 100644 --- a/mod/import.php +++ b/mod/import.php @@ -3,6 +3,8 @@ // Import a channel, either by direct file upload or via // connection to original server. +require_once('include/Contact.php'); + function import_post(&$a) { @@ -64,11 +66,152 @@ function import_post(&$a) { // print_r($data); // import channel + + $channel = $data['channel']; + + $r = q("select * from channel where (channel_guid = '%s' or channel_hash = '%s') limit 1", + dbesc($channel['channel_guid']), + dbesc($channel['channel_hash']) + ); + + // We should probably also verify the hash + + if($r) { + logger('mod_import: duplicate channel. ', print_r($channel,true)); + notice( t('Duplicate channel unique ID. Import failed.') . EOL); + return; + } + + unset($channel['channel_id']); + $channel['channel_account_id'] = get_account_id(); + $channel['channel_primary'] = (($seize) ? 1 : 0); - // import contacts + dbesc_array($channel); + + $r = dbq("INSERT INTO channel (`" + . implode("`, `", array_keys($channel)) + . "`) VALUES ('" + . implode("', '", array_values($channel)) + . "')" ); + + if(! $r) { + logger('mod_import: channel clone failed. ', print_r($channel,true)); + notice( t('Channel clone failed. Import failed.') . EOL); + return; + } + + $r = q("select * from channel where channel_account_id = %d and channel_guid = '%s' limit 1", + intval(get_account_id()), + $channel['channel_guid'] // Already dbesc'd + ); + if(! $r) { + logger('mod_import: channel not found. ', print_r($channel,true)); + notice( t('Cloned channel not found. Import failed.') . EOL); + return; + } + // reset + $channel = $r[0]; + + $profiles = $data['profile']; + if($profiles) { + foreach($profiles as $profile) { + $profile['aid'] = get_account_id(); + $profile['uid'] = $channel['channel_id']; + + // 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']; + + + dbesc_array($profile); + $r = dbq("INSERT INTO profile (`" + . implode("`, `", array_keys($profile)) + . "`) VALUES ('" + . implode("', '", array_values($profile)) + . "')" ); + } + } + + $hublocs = $data['hubloc']; + if($hublocs) { + foreach($hublocs as $hubloc) { + $arr = array( + 'guid' => $hubloc['hubloc_guid'], + 'guid_sig' => $hubloc['guid_sig'], + 'url' => $hubloc['hubloc_url'], + 'url_sig' => $hubloc['hubloc_url_sig'] + ); + if(($hubloc['hubloc_hash'] === $channel['channel_hash']) && ($hubloc['hubloc_flags'] & HUBLOC_FLAGS_PRIMARY) && ($seize)) + $hubloc['hubloc_flags'] = ($hubloc['hubloc_flags'] ^ HUBLOC_FLAGS_PRIMARY); + + if(! zot_gethub($arr)) { + dbesc_array($hubloc); + + $r = dbq("INSERT INTO hubloc (`" + . implode("`, `", array_keys($hubloc)) + . "`) VALUES ('" + . implode("', '", array_values($hubloc)) + . "')" ); + + } + + // create new hubloc for the new channel at this site + // and reset the original hubloc if it is being seized but wasn't created just now + } + } + + // import xchans and contact photos + $xchans = $data['xchan']; + if($xchans) { + foreach($xchans as $xchan) { + $r = q("select xchan_hash from xchan where xchan_hash = '%s' limit 1", + dbesc($xchan['xchan_hash']) + ); + if($r) + continue; + dbesc_array($xchan); + + $r = dbq("INSERT INTO xchan (`" + . implode("`, `", array_keys($xchan)) + . "`) VALUES ('" + . implode("', '", array_values($xchan)) + . "')" ); + + + require_once("Photo.php"); + $photos = import_profile_photo($xchan['xchan_photo_l'],$xchan['xchan_hash']); + $r = q("update xchan set xchan_photo_l = '%s', xchan_photo_m = '%s', xchan_photo_s = '%s', xchan_photo_mimetype = '%s' + where xchan_hash = '%s' limit 1", + dbesc($photos[0]), + dbesc($photos[1]), + dbesc($photos[2]), + dbesc($photos[3]), + dbesc($xchan_hash) + ); + + } + } + + + // import contacts + $abooks = $data['abook']; + if($abooks) { + foreach($abooks as $abook) { + $abook['abook_account'] = get_account_id(); + $abook['abook_channel'] = $channel['channel_id']; + dbesc_array($abook); + $r = dbq("INSERT INTO abook (`" + . implode("`, `", array_keys($abook)) + . "`) VALUES ('" + . implode("', '", array_values($abook)) + . "')" ); + } + } if($seize) { |