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.

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) {