X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FCore%2FUserImport.php;h=fbc89ccf580ce0deed66a66dc9421c33bce321aa;hb=06284e60073f374c1bd411e0bba6474a13c14f10;hp=97a6e6028e3b4905e341506a5f4d540ccbbd219d;hpb=bae4a5e406c3b93d0c2e6bef55fd665fc88b243e;p=friendica.git diff --git a/src/Core/UserImport.php b/src/Core/UserImport.php index 97a6e6028e..fbc89ccf58 100644 --- a/src/Core/UserImport.php +++ b/src/Core/UserImport.php @@ -1,18 +1,38 @@ . + * */ + namespace Friendica\Core; -use Friendica\App; use Friendica\Database\DBA; use Friendica\Database\DBStructure; +use Friendica\DI; use Friendica\Model\Photo; +use Friendica\Model\Profile; use Friendica\Object\Image; +use Friendica\Security\PermissionSet\Repository\PermissionSet; use Friendica\Util\Strings; +use Friendica\Worker\Delivery; /** - * @brief UserImport class + * UserImport class */ class UserImport { @@ -82,16 +102,15 @@ class UserImport } /** - * @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']); + Logger::notice("Start user import from " . $file['tmp_name']); /* STEPS 1. checks @@ -103,13 +122,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; } @@ -117,12 +136,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)); @@ -152,30 +171,13 @@ class UserImport // import user $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")); + Logger::warning("uimport:insert user : ERROR : " . DBA::errorMessage()); + 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) { @@ -208,21 +210,21 @@ class UserImport $contact['uid'] = $newuid; $r = self::dbImportAssoc('contact', $contact); if ($r === false) { - Logger::log("uimport:insert contact " . $contact['nick'] . "," . $contact['network'] . " : ERROR : " . DBA::errorMessage(), Logger::INFO); + Logger::warning("uimport:insert contact " . $contact['nick'] . "," . $contact['network'] . " : ERROR : " . DBA::errorMessage()); $errorcount++; } else { $contact['newid'] = self::lastInsertId(); } } 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) { $group['uid'] = $newuid; $r = self::dbImportAssoc('group', $group); if ($r === false) { - Logger::log("uimport:insert group " . $group['name'] . " : ERROR : " . DBA::errorMessage(), Logger::INFO); + Logger::warning("uimport:insert group " . $group['name'] . " : ERROR : " . DBA::errorMessage()); } else { $group['newid'] = self::lastInsertId(); } @@ -247,11 +249,52 @@ class UserImport if ($import == 2) { $r = self::dbImportAssoc('group_member', $group_member); if ($r === false) { - Logger::log("uimport:insert group member " . $group_member['id'] . " : ERROR : " . DBA::errorMessage(), Logger::INFO); + Logger::warning("uimport:insert group member " . $group_member['id'] . " : ERROR : " . DBA::errorMessage()); } } } + 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::warning("uimport:insert profile: ERROR : " . DBA::errorMessage()); + notice(DI::l10n()->t("User profile creation error")); + DBA::delete('user', ['uid' => $newuid]); + DBA::delete('profile_field', ['uid' => $newuid]); + return; + } + + $profile['id'] = DBA::lastInsertId(); + } + + Profile::migrate($profile); + } + + $permissionSet = DI::permissionSet()->selectDefaultForUser($newuid); + + foreach ($account['profile_fields'] ?? [] as $profile_field) { + $profile_field['uid'] = $newuid; + + ///@TODO Replace with permissionset import + $profile_field['psid'] = $profile_field['psid'] ? $permissionSet->uid : 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']); @@ -265,7 +308,7 @@ class UserImport ); if ($r === false) { - Logger::log("uimport:insert photo " . $photo['resource-id'] . "," . $photo['scale'] . " : ERROR : " . DBA::errorMessage(), Logger::INFO); + Logger::warning("uimport:insert photo " . $photo['resource-id'] . "," . $photo['scale'] . " : ERROR : " . DBA::errorMessage()); } } @@ -273,14 +316,14 @@ class UserImport $pconfig['uid'] = $newuid; $r = self::dbImportAssoc('pconfig', $pconfig); if ($r === false) { - Logger::log("uimport:insert pconfig " . $pconfig['id'] . " : ERROR : " . DBA::errorMessage(), Logger::INFO); + Logger::warning("uimport:insert pconfig " . $pconfig['id'] . " : ERROR : " . DBA::errorMessage()); } } // 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'); } }