<?php
/**
- * @copyright Copyright (C) 2010-2021, the Friendica project
+ * @copyright Copyright (C) 2010-2022, the Friendica project
*
* @license GNU AGPL version 3 or any later version
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*
- * Automatic post-databse structure change updates
+ * Automatic post-database structure change updates
*
* These functions are responsible for doing critical post update changes to the data (not the structure) in the database.
*
* If you need to run a script before the database update, name the function "pre_update_4712()"
*/
+use Friendica\Core\Config\ValueObject\Cache;
use Friendica\Core\Logger;
+use Friendica\Core\Protocol;
+use Friendica\Core\Storage\Capability\ICanReadFromStorage;
+use Friendica\Core\Storage\Type\Database as DatabaseStorage;
use Friendica\Core\Update;
use Friendica\Core\Worker;
use Friendica\Database\Database;
use Friendica\Model\Photo;
use Friendica\Model\Post;
use Friendica\Model\Profile;
-use Friendica\Model\Storage;
+use Friendica\Model\User;
+use Friendica\Security\PermissionSet\Repository\PermissionSet;
use Friendica\Worker\Delivery;
// Post-update script of PR 5751
$a->strings = [];
// First we get the the localizations
- if (file_exists("view/lang/$lang/strings.php")) {
- include "view/lang/$lang/strings.php";
+ if (file_exists('view/lang/$lang/strings.php')) {
+ include 'view/lang/$lang/strings.php';
}
- if (file_exists("addon/morechoice/lang/$lang/strings.php")) {
- include "addon/morechoice/lang/$lang/strings.php";
+ if (file_exists('addon/morechoice/lang/$lang/strings.php')) {
+ include 'addon/morechoice/lang/$lang/strings.php';
}
$localizedStrings = $a->strings;
}
}
- Logger::notice($translateKey . " fix completed", ['action' => 'update', 'translateKey' => $translateKey, 'Success' => $success, 'Fail' => $fail ]);
+ Logger::notice($translateKey . ' fix completed', ['action' => 'update', 'translateKey' => $translateKey, 'Success' => $success, 'Fail' => $fail ]);
}
return Update::SUCCESS;
}
continue;
}
- $deliver_options = ['priority' => PRIORITY_MEDIUM, 'dont_fork' => true];
+ $deliver_options = ['priority' => Worker::PRIORITY_MEDIUM, 'dont_fork' => true];
Worker::add($deliver_options, 'Delivery', Delivery::POST, $item['id'], $entry['cid']);
Logger::info('Added delivery worker', ['item' => $item['id'], 'contact' => $entry['cid']]);
DBA::delete('queue', ['id' => $entry['id']]);
function update_1318()
{
- DBA::update('profile', ['marital' => "In a relation"], ['marital' => "Unavailable"]);
- DBA::update('profile', ['marital' => "Single"], ['marital' => "Available"]);
+ DBA::update('profile', ['marital' => 'In a relation'], ['marital' => 'Unavailable']);
+ DBA::update('profile', ['marital' => 'Single'], ['marital' => 'Available']);
- Worker::add(PRIORITY_LOW, 'ProfileUpdate');
+ Worker::add(Worker::PRIORITY_LOW, 'ProfileUpdate');
return Update::SUCCESS;
}
// set the name of the storage instead of the classpath as config
if (!empty($currStorage)) {
- /** @var Storage\IStorage $currStorage */
+ /** @var ICanReadFromStorage $currStorage */
if (!DI::config()->set('storage', 'name', $currStorage::getName())) {
return Update::FAILED;
}
}
// Update attachments and photos
- if (!DBA::p("UPDATE `photo` SET `photo`.`backend-class` = SUBSTR(`photo`.`backend-class`, 25) WHERE `photo`.`backend-class` LIKE 'Friendica\\\Model\\\Storage\\\%' ESCAPE '|'") ||
- !DBA::p("UPDATE `attach` SET `attach`.`backend-class` = SUBSTR(`attach`.`backend-class`, 25) WHERE `attach`.`backend-class` LIKE 'Friendica\\\Model\\\Storage\\\%' ESCAPE '|'")) {
+ if (!DBA::e("UPDATE `photo` SET `photo`.`backend-class` = SUBSTR(`photo`.`backend-class`, 25) WHERE `photo`.`backend-class` LIKE 'Friendica\\\Model\\\Storage\\\%' ESCAPE '|'") ||
+ !DBA::e("UPDATE `attach` SET `attach`.`backend-class` = SUBSTR(`attach`.`backend-class`, 25) WHERE `attach`.`backend-class` LIKE 'Friendica\\\Model\\\Storage\\\%' ESCAPE '|'")) {
return Update::FAILED;
};
$profiles = DBA::select('profile', [], $condition);
while ($profile = DBA::fetch($profiles)) {
- DI::profileField()->migrateFromLegacyProfile($profile);
+ Profile::migrate($profile);
}
DBA::close($profiles);
update_1348();
- DBA::e("DELETE FROM `auth_codes` WHERE NOT `client_id` IN (SELECT `client_id` FROM `clients`)");
- DBA::e("DELETE FROM `tokens` WHERE NOT `client_id` IN (SELECT `client_id` FROM `clients`)");
-
+ if (DBStructure::existsTable('auth_codes') && DBStructure::existsTable('clients')) {
+ DBA::e("DELETE FROM `auth_codes` WHERE NOT `client_id` IN (SELECT `client_id` FROM `clients`)");
+ }
+ if (DBStructure::existsTable('tokens') && DBStructure::existsTable('clients')) {
+ DBA::e("DELETE FROM `tokens` WHERE NOT `client_id` IN (SELECT `client_id` FROM `clients`)");
+ }
return Update::SUCCESS;
}
}
if (!DBA::e("UPDATE `item` INNER JOIN `item-activity` ON `item`.`uri-id` = `item-activity`.`uri-id`
- SET `vid` = `item-activity`.`activity` + 1 WHERE `gravity` = ? AND (`vid` IS NULL OR `vid` = 0)", GRAVITY_ACTIVITY)) {
+ SET `vid` = `item-activity`.`activity` + 1 WHERE `gravity` = ? AND (`vid` IS NULL OR `vid` = 0)", Item::GRAVITY_ACTIVITY)) {
return Update::FAILED;
}
return Update::FAILED;
}
- if (!DBA::e("DELETE FROM `clients` WHERE NOT `uid` IN (SELECT `uid` FROM `user`)")) {
+ if (DBStructure::existsTable('clients') && !DBA::e("DELETE FROM `clients` WHERE NOT `uid` IN (SELECT `uid` FROM `user`)")) {
return Update::FAILED;
}
return Update::FAILED;
}
- if (!DBA::e("DELETE FROM `profile_check` WHERE NOT `uid` IN (SELECT `uid` FROM `user`)")) {
+ if (DBStructure::existsTable('profile_check') && !DBA::e("DELETE FROM `profile_check` WHERE NOT `uid` IN (SELECT `uid` FROM `user`)")) {
return Update::FAILED;
}
return Update::FAILED;
}
- if (!DBA::e("DELETE FROM `tokens` WHERE NOT `uid` IN (SELECT `uid` FROM `user`)")) {
+ if (DBStructure::existsTable('tokens') && !DBA::e("DELETE FROM `tokens` WHERE NOT `uid` IN (SELECT `uid` FROM `user`)")) {
return Update::FAILED;
}
return Update::FAILED;
}
- if (!DBA::e("DELETE FROM `profile_check` WHERE NOT `cid` IN (SELECT `id` FROM `contact`)")) {
+ if (DBStructure::existsTable('profile_check') && !DBA::e("DELETE FROM `profile_check` WHERE NOT `cid` IN (SELECT `id` FROM `contact`)")) {
return Update::FAILED;
}
return Update::SUCCESS;
}
- if (!DBA::e("INSERT IGNORE INTO `post-content`(`uri-id`, `title`, `content-warning`, `body`, `raw-body`,
- `location`, `coord`, `language`, `app`, `rendered-hash`, `rendered-html`,
- `object-type`, `object`, `target-type`, `target`, `resource-id`, `plink`)
- SELECT `item-content`.`uri-id`, `item-content`.`title`, `item-content`.`content-warning`,
- `item-content`.`body`, `item-content`.`raw-body`, `item-content`.`location`, `item-content`.`coord`,
- `item-content`.`language`, `item-content`.`app`, `item-content`.`rendered-hash`,
- `item-content`.`rendered-html`, `item-content`.`object-type`, `item-content`.`object`,
- `item-content`.`target-type`, `item-content`.`target`, `item`.`resource-id`, `item-content`.`plink`
- FROM `item-content` INNER JOIN `item` ON `item`.`uri-id` = `item-content`.`uri-id`")) {
- return Update::FAILED;
+ if (DBStructure::existsColumn('item-content', ['raw-body'])) {
+ if (!DBA::e("INSERT IGNORE INTO `post-content`(`uri-id`, `title`, `content-warning`, `body`, `raw-body`,
+ `location`, `coord`, `language`, `app`, `rendered-hash`, `rendered-html`,
+ `object-type`, `object`, `target-type`, `target`, `resource-id`, `plink`)
+ SELECT `item-content`.`uri-id`, `item-content`.`title`, `item-content`.`content-warning`,
+ `item-content`.`body`, `item-content`.`raw-body`, `item-content`.`location`, `item-content`.`coord`,
+ `item-content`.`language`, `item-content`.`app`, `item-content`.`rendered-hash`,
+ `item-content`.`rendered-html`, `item-content`.`object-type`, `item-content`.`object`,
+ `item-content`.`target-type`, `item-content`.`target`, `item`.`resource-id`, `item-content`.`plink`
+ FROM `item-content` INNER JOIN `item` ON `item`.`uri-id` = `item-content`.`uri-id`")) {
+ return Update::FAILED;
+ }
+ } else {
+ if (!DBA::e("INSERT IGNORE INTO `post-content`(`uri-id`, `title`, `content-warning`, `body`,
+ `location`, `coord`, `language`, `app`, `rendered-hash`, `rendered-html`,
+ `object-type`, `object`, `target-type`, `target`, `resource-id`, `plink`)
+ SELECT `item-content`.`uri-id`, `item-content`.`title`, `item-content`.`content-warning`,
+ `item-content`.`body`, `item-content`.`location`, `item-content`.`coord`,
+ `item-content`.`language`, `item-content`.`app`, `item-content`.`rendered-hash`,
+ `item-content`.`rendered-html`, `item-content`.`object-type`, `item-content`.`object`,
+ `item-content`.`target-type`, `item-content`.`target`, `item`.`resource-id`, `item-content`.`plink`
+ FROM `item-content` INNER JOIN `item` ON `item`.`uri-id` = `item-content`.`uri-id`")) {
+ return Update::FAILED;
+ }
}
return Update::SUCCESS;
}
function pre_update_1403()
{
// Necessary before a primary key change
- if (!DBA::e("DROP TABLE `parsed_url`")) {
+ if (DBStructure::existsTable('parsed_url') && !DBA::e("DROP TABLE `parsed_url`")) {
return Update::FAILED;
}
return Update::FAILED;
}
- DI::config()->set("system", "post_update_version", 1423);
+ DI::config()->set('system', 'post_update_version', 1423);
+
+ return Update::SUCCESS;
+}
+
+function update_1434()
+{
+ $name = DI::config()->get('storage', 'name');
+
+ // In case of an empty config, set "Database" as default storage backend
+ if (empty($name)) {
+ DI::config()->set('storage', 'name', DatabaseStorage::getName());
+ }
+
+ // In case of a Using deprecated storage class value, set the right name for it
+ if (stristr($name, 'Friendica\Model\Storage\\')) {
+ DI::config()->set('storage', 'name', substr($name, 24));
+ }
+
+ return Update::SUCCESS;
+}
+
+function update_1438()
+{
+ DBA::update('photo', ['photo-type' => Photo::USER_AVATAR], ['profile' => true]);
+ DBA::update('photo', ['photo-type' => Photo::CONTACT_AVATAR], ["NOT `profile` AND NOT `contact-id` IS NULL AND `contact-id` != ?", 0]);
+ DBA::update('photo', ['photo-type' => Photo::DEFAULT], ["NOT `profile` AND (`contact-id` IS NULL OR `contact-id` = ?) AND `photo-type` IS NULL AND `album` != ?", 0, Photo::CONTACT_PHOTOS]);
+}
+
+function update_1439()
+{
+ $intros = DBA::select('intro', ['id', 'fid'], ["NOT `fid` IS NULL AND `fid` != ?", 0]);
+ while ($intro = DBA::fetch($intros)) {
+ $fcontact = DBA::selectFirst('fcontact', ['url'], ['id' => $intro['fid']]);
+ if (!empty($fcontact['url'])) {
+ $id = Contact::getIdForURL($fcontact['url']);
+ if (!empty($id)) {
+ DBA::update('intro',['suggest-cid' => $id], ['id' => $intro['id']]);
+ }
+ }
+ }
+ DBA::close($intros);
+}
+
+function update_1440()
+{
+ // Fix wrong public permissionset
+ DBA::p("UPDATE `profile_field` SET `psid` = ? WHERE psid IN (SELECT `id` FROM `permissionset` WHERE `id` != ? AND `allow_cid` = '' AND `allow_gid` = '' AND `deny_cid` = '' AND `deny_gid` = '')", PermissionSet::PUBLIC, PermissionSet::PUBLIC);
+ DBA::delete('permissionset', ["`id` != ? AND `allow_cid` = '' AND `allow_gid` = '' AND `deny_cid` = '' AND `deny_gid` = ''", PermissionSet::PUBLIC]);
+
+ return Update::SUCCESS;
+}
+
+function update_1441()
+{
+ $languages = DI::l10n()->getAvailableLanguages();
+
+ $albums = [Photo::PROFILE_PHOTOS];
+ foreach ($languages as $language) {
+ $albums[] = DI::l10n()->withLang($language)->t(Photo::PROFILE_PHOTOS);
+ }
+ $albums = array_unique($albums);
+
+ Photo::update(['photo-type' => Photo::USER_AVATAR], ['album' => $albums]);
+
+ return Update::SUCCESS;
+}
+
+function update_1442()
+{
+ // transform blocked intros into ignored intros
+ DBA::update('intro', ['ignore' => 1, 'blocked' => 0], ['blocked' => 1]);
+
+ return Update::SUCCESS;
+}
+
+/**
+ * A bug in Contact\User::updateByContactUpdate prevented any update to the user-contact table since the rows have been
+ * created in version 1435. This version fixes this bug but the user-contact rows are outdated, we need to regenerate
+ * them.
+ */
+function update_1444()
+{
+ DBA::e('TRUNCATE TABLE `user-contact`');
+
+ $contacts = DBA::select('contact', [], ["`uid` != ?", 0]);
+ while ($contact = DBA::fetch($contacts)) {
+ Contact\User::insertForContactArray($contact);
+ }
+
+ return Update::SUCCESS;
+}
+
+function update_1446()
+{
+ $distributed_cache_driver_source = DI::config()->getCache()->getSource('system', 'distributed_cache_driver');
+ $cache_driver_source = DI::config()->getCache()->getSource('system', 'cache_driver');
+
+ // In case the distributed cache driver is the default value, but the current cache driver isn't default,
+ // we assume that the distributed cache driver should be the same as the current cache driver
+ if ($distributed_cache_driver_source === Cache::SOURCE_STATIC && $cache_driver_source > Cache::SOURCE_STATIC) {
+ DI::config()->set('system', 'distributed_cache_driver', DI::config()->get('system', 'cache_driver'));
+ }
+
+ return Update::SUCCESS;
+}
+
+function update_1451()
+{
+ DBA::update('user', ['account-type' => User::ACCOUNT_TYPE_COMMUNITY], ['page-flags' => [User::PAGE_FLAGS_COMMUNITY, User::PAGE_FLAGS_PRVGROUP]]);
+ DBA::update('contact', ['contact-type' => Contact::TYPE_COMMUNITY], ["`forum` OR `prv`"]);
+ DBA::update('contact', ['manually-approve' => true], ['prv' => true]);
+
+ return Update::SUCCESS;
+}
+
+function update_1457()
+{
+ $pinned = DBA::select('post-thread-user', ['uri-id', 'author-id'], ['pinned' => true]);
+ while ($post = DBA::fetch($pinned)) {
+ Post\Collection::add($post['uri-id'], Post\Collection::FEATURED, $post['author-id']);
+ }
+ DBA::close($pinned);
+
+ return Update::SUCCESS;
+}
+
+function update_1480()
+{
+ DBA::update('contact', ['next-update' => DBA::NULL_DATETIME], ['network' => Protocol::FEDERATED]);
+ DBA::update('post', ['deleted' => false], ["`uri-id` IN (SELECT `uri-id` FROM `post-user` WHERE NOT `deleted`)"]);
+ return Update::SUCCESS;
+}
+
+function update_1481()
+{
+ DBA::e("UPDATE `post-collection` INNER JOIN `post` ON `post`.`uri-id` = `post-collection`.`uri-id` SET `post-collection`.`author-id` = `post`.`author-id` WHERE `post-collection`.`author-id` IS null");
+ return Update::SUCCESS;
+}
+function update_1491()
+{
+ DBA::update('contact', ['remote_self' => Contact::MIRROR_OWN_POST], ['remote_self' => Contact::MIRROR_FORWARDED]);
+ return Update::SUCCESS;
+}
+
+function update_1497()
+{
+ DBA::e("UPDATE `user` SET `last-activity` = DATE(`login_date`) WHERE `last-activity` IS NULL");
return Update::SUCCESS;
}
\ No newline at end of file