aboutsummaryrefslogtreecommitdiffstats
path: root/mod
diff options
context:
space:
mode:
authorfriendica <info@friendica.com>2013-02-19 17:13:23 -0800
committerfriendica <info@friendica.com>2013-02-19 17:13:23 -0800
commit24eac8c65614a71ac1ec0ffec8bcf877c1fa0355 (patch)
treef7536e16882a3f8b01bb15782254a66dd19668f2 /mod
parent8a474cbff57971da7c911ea84a5331e0588cd65e (diff)
downloadvolse-hubzilla-24eac8c65614a71ac1ec0ffec8bcf877c1fa0355.tar.gz
volse-hubzilla-24eac8c65614a71ac1ec0ffec8bcf877c1fa0355.tar.bz2
volse-hubzilla-24eac8c65614a71ac1ec0ffec8bcf877c1fa0355.zip
the heavy lifting is done for location migration aka channel import - now it's just connecting all the dots. Don't get impatient, there are a lot of dots.
Diffstat (limited to 'mod')
-rw-r--r--mod/import.php145
1 files changed, 144 insertions, 1 deletions
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) {