X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FCore%2FUserImport.php;h=f0d8f762e214cbaac022b311bb4c752451d27d7e;hb=1701ea2034feb1cb8b7cce8455ff8e3c1f8875c6;hp=70d93b0cc0900fbc67272a934bccbe48f6a636e0;hpb=5e60fa8210b502797209de770780d6d7ba81b86c;p=friendica.git diff --git a/src/Core/UserImport.php b/src/Core/UserImport.php index 70d93b0cc0..f0d8f762e2 100644 --- a/src/Core/UserImport.php +++ b/src/Core/UserImport.php @@ -1,22 +1,39 @@ . + * */ + namespace Friendica\Core; use Friendica\App; -use Friendica\Core\Logger; -use Friendica\Core\Protocol; -use Friendica\Core\System; use Friendica\Database\DBA; +use Friendica\Database\DBStructure; +use Friendica\DI; +use Friendica\Model\Contact; use Friendica\Model\Photo; use Friendica\Object\Image; +use Friendica\Repository\PermissionSet; use Friendica\Util\Strings; - -require_once "include/dba.php"; +use Friendica\Worker\Delivery; /** - * @brief UserImport class + * UserImport class */ class UserImport { @@ -35,22 +52,29 @@ class UserImport * Remove columns from array $arr that aren't in table $table * * @param string $table Table name - * @param array &$arr Column=>Value array from json (by ref) + * @param array &$arr Column=>Value array from json (by ref) + * @throws \Exception */ private static function checkCols($table, &$arr) { - $query = sprintf("SHOW COLUMNS IN `%s`", DBA::escape($table)); - Logger::log("uimport: $query", Logger::DEBUG); - $r = q($query); + $tableColumns = DBStructure::getColumns($table); + $tcols = []; + $ttype = []; // get a plain array of column names - foreach ($r as $tcol) { + foreach ($tableColumns as $tcol) { $tcols[] = $tcol['Field']; + $ttype[$tcol['Field']] = $tcol['Type']; } // remove inexistent columns foreach ($arr as $icol => $ival) { if (!in_array($icol, $tcols)) { unset($arr[$icol]); + continue; + } + + if ($ttype[$icol] === 'datetime') { + $arr[$icol] = $ival ?? DBA::NULL_DATETIME; } } } @@ -59,7 +83,9 @@ class UserImport * Import data into table $table * * @param string $table Table name - * @param array $arr Column=>Value array from json + * @param array $arr Column=>Value array from json + * @return array|bool + * @throws \Exception */ private static function dbImportAssoc($table, $arr) { @@ -68,25 +94,22 @@ class UserImport } self::checkCols($table, $arr); - $cols = implode("`,`", array_map(['Friendica\Database\DBA', 'escape'], array_keys($arr))); - $vals = implode("','", array_map(['Friendica\Database\DBA', 'escape'], array_values($arr))); - $query = "INSERT INTO `$table` (`$cols`) VALUES ('$vals')"; - Logger::log("uimport: $query", Logger::TRACE); if (self::IMPORT_DEBUG) { return true; } - return q($query); + return DBA::insert($table, $arr); } /** - * @brief Import account file exported from mod/uexport + * Import account file exported from mod/uexport * - * @param App $a Friendica App Class * @param array $file array from $_FILES + * @throws \Friendica\Network\HTTPException\InternalServerErrorException + * @throws \ImagickException */ - public static function importAccount(App $a, $file) + public static function importAccount($file) { Logger::log("Start user import from " . $file['tmp_name']); /* @@ -100,13 +123,13 @@ class UserImport $account = json_decode(file_get_contents($file['tmp_name']), true); if ($account === null) { - notice(L10n::t("Error decoding account file")); + notice(DI::l10n()->t("Error decoding account file")); return; } if (empty($account['version'])) { - notice(L10n::t("Error! No version data in file! This is not a Friendica account file?")); + notice(DI::l10n()->t("Error! No version data in file! This is not a Friendica account file?")); return; } @@ -114,12 +137,12 @@ class UserImport // check if username matches deleted account if (DBA::exists('user', ['nickname' => $account['user']['nickname']]) || DBA::exists('userd', ['username' => $account['user']['nickname']])) { - notice(L10n::t("User '%s' already exists on this server!", $account['user']['nickname'])); + notice(DI::l10n()->t("User '%s' already exists on this server!", $account['user']['nickname'])); return; } $oldbaseurl = $account['baseurl']; - $newbaseurl = System::baseUrl(); + $newbaseurl = DI::baseUrl(); $oldaddr = str_replace('http://', '@', Strings::normaliseLink($oldbaseurl)); $newaddr = str_replace('http://', '@', Strings::normaliseLink($newbaseurl)); @@ -150,29 +173,12 @@ class UserImport $r = self::dbImportAssoc('user', $account['user']); if ($r === false) { Logger::log("uimport:insert user : ERROR : " . DBA::errorMessage(), Logger::INFO); - notice(L10n::t("User creation error")); + notice(DI::l10n()->t("User creation error")); return; } $newuid = self::lastInsertId(); - PConfig::set($newuid, 'system', 'previous_addr', $old_handle); - - foreach ($account['profile'] as &$profile) { - foreach ($profile as $k => &$v) { - $v = str_replace([$oldbaseurl, $oldaddr], [$newbaseurl, $newaddr], $v); - foreach (["profile", "avatar"] as $k) { - $v = str_replace($oldbaseurl . "/photo/" . $k . "/" . $olduid . ".jpg", $newbaseurl . "/photo/" . $k . "/" . $newuid . ".jpg", $v); - } - } - $profile['uid'] = $newuid; - $r = self::dbImportAssoc('profile', $profile); - if ($r === false) { - Logger::log("uimport:insert profile " . $profile['profile-name'] . " : ERROR : " . DBA::errorMessage(), Logger::INFO); - info(L10n::t("User profile creation error")); - DBA::delete('user', ['uid' => $newuid]); - return; - } - } + DI::pConfig()->set($newuid, 'system', 'previous_addr', $old_handle); $errorcount = 0; foreach ($account['contact'] as &$contact) { @@ -212,7 +218,7 @@ class UserImport } } if ($errorcount > 0) { - notice(L10n::tt("%d contact not imported", "%d contacts not imported", $errorcount)); + notice(DI::l10n()->tt("%d contact not imported", "%d contacts not imported", $errorcount)); } foreach ($account['group'] as &$group) { @@ -249,6 +255,50 @@ class UserImport } } + foreach ($account['profile'] as &$profile) { + unset($profile['id']); + $profile['uid'] = $newuid; + + foreach ($profile as $k => &$v) { + $v = str_replace([$oldbaseurl, $oldaddr], [$newbaseurl, $newaddr], $v); + foreach (["profile", "avatar"] as $k) { + $v = str_replace($oldbaseurl . "/photo/" . $k . "/" . $olduid . ".jpg", $newbaseurl . "/photo/" . $k . "/" . $newuid . ".jpg", $v); + } + } + + if (count($account['profile']) === 1 || $profile['is-default']) { + $r = self::dbImportAssoc('profile', $profile); + + if ($r === false) { + Logger::log("uimport:insert profile: ERROR : " . DBA::errorMessage(), Logger::INFO); + notice(DI::l10n()->t("User profile creation error")); + DBA::delete('user', ['uid' => $newuid]); + DBA::delete('profile_field', ['uid' => $newuid]); + return; + } + + $profile['id'] = DBA::lastInsertId(); + } + + DI::profileField()->migrateFromLegacyProfile($profile); + } + + ///@TODO Replace with permissionset import + $self_contact = Contact::selectFirst(['id'], ['uid' => $newuid, 'self' => true]); + $allow_cid = DI::aclFormatter()->toString($self_contact['id']); + $self_psid = DI::permissionSet()->getIdFromACL($newuid, $allow_cid); + + foreach ($account['profile_fields'] ?? [] as $profile_field) { + $profile_field['uid'] = $newuid; + + ///@TODO Replace with permissionset import + $profile_field['psid'] = $profile_field['psid'] ? $self_psid : PermissionSet::PUBLIC; + + if (self::dbImportAssoc('profile_field', $profile_field) === false) { + Logger::info("uimport:insert profile field " . $profile_field['id'] . " : ERROR : " . DBA::errorMessage()); + } + } + foreach ($account['photo'] as &$photo) { $photo['uid'] = $newuid; $photo['data'] = hex2bin($photo['data']); @@ -275,9 +325,9 @@ class UserImport } // send relocate messages - Worker::add(PRIORITY_HIGH, 'Notifier', 'relocate', $newuid); + Worker::add(PRIORITY_HIGH, 'Notifier', Delivery::RELOCATION, $newuid); - info(L10n::t("Done. You can now login with your username and password")); - $a->internalRedirect('login'); + info(DI::l10n()->t("Done. You can now login with your username and password")); + DI::baseUrl()->redirect('login'); } }