namespace Friendica\Database;
-use Friendica\Core\Logger;
use Friendica\Core\Protocol;
use Friendica\DI;
use Friendica\Model\Contact;
$max_item_delivery_data = DBA::selectFirst('item-delivery-data', ['iid'], ['queue_count > 0 OR queue_done > 0'], ['order' => ['iid']]);
$max_iid = $max_item_delivery_data['iid'] ?? 0;
- Logger::info('Start update1297 with max iid: ' . $max_iid);
+ DI::logger()->info('Start update1297 with max iid: ' . $max_iid);
$condition = ['`queue_count` = 0 AND `iid` < ?', $max_iid];
DBA::update('item-delivery-data', ['queue_count' => -1], $condition);
if (DBA::errorNo() != 0) {
- Logger::error('Database error ' . DBA::errorNo() . ':' . DBA::errorMessage());
+ DI::logger()->error('Database error ' . DBA::errorNo() . ':' . DBA::errorMessage());
return false;
}
- Logger::info('Processed rows: ' . DBA::affectedRows());
+ DI::logger()->info('Processed rows: ' . DBA::affectedRows());
DI::keyValue()->set('post_update_version', 1297);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
return true;
}
- Logger::info('Start');
+ DI::logger()->info('Start');
$contacts = DBA::p("SELECT `nurl`, `uid` FROM `contact`
WHERE EXISTS (SELECT `nurl` FROM `contact` AS `c2`
Protocol::DIASPORA, Protocol::OSTATUS, Protocol::ACTIVITYPUB, 0);
while ($contact = DBA::fetch($contacts)) {
- Logger::info('Remove duplicates', ['nurl' => $contact['nurl'], 'uid' => $contact['uid']]);
+ DI::logger()->info('Remove duplicates', ['nurl' => $contact['nurl'], 'uid' => $contact['uid']]);
Contact::removeDuplicates($contact['nurl'], $contact['uid']);
}
DBA::close($contact);
DI::keyValue()->set('post_update_version', 1322);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
$id = DI::keyValue()->get('post_update_version_1329_id') ?? 0;
- Logger::info('Start', ['item' => $id]);
+ DI::logger()->info('Start', ['item' => $id]);
$start_id = $id;
$rows = 0;
$items = DBA::select('item', ['id', 'uri-id', 'uid'], $condition, $params);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1329_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id]);
if ($start_id == $id) {
DI::keyValue()->set('post_update_version', 1329);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
$id = DI::keyValue()->get('post_update_version_1341_id') ?? 0;
- Logger::info('Start', ['item' => $id]);
+ DI::logger()->info('Start', ['item' => $id]);
$rows = 0;
ORDER BY `uri-id` LIMIT 100000", '%#%', '%@%', '%!%', $id);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1341_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id]);
// When there are less than 1,000 items processed this means that we reached the end
// The other entries will then be processed with the regular functionality
if ($rows < 1000) {
DI::keyValue()->set('post_update_version', 1341);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
$id = DI::keyValue()->get('post_update_version_1342_id') ?? 0;
- Logger::info('Start', ['item' => $id]);
+ DI::logger()->info('Start', ['item' => $id]);
$rows = 0;
Tag::HASHTAG, Tag::MENTION, Tag::EXCLUSIVE_MENTION, Tag::IMPLICIT_MENTION, $id);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1342_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id]);
// When there are less than 1,000 items processed this means that we reached the end
// The other entries will then be processed with the regular functionality
if ($rows < 1000) {
DI::keyValue()->set('post_update_version', 1342);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
$id = DI::keyValue()->get('post_update_version_1345_id') ?? 0;
- Logger::info('Start', ['item' => $id]);
+ DI::logger()->info('Start', ['item' => $id]);
$rows = 0;
WHERE `iid` >= ? ORDER BY `iid` LIMIT 10000", $id);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1345_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id]);
// When there are less than 100 items processed this means that we reached the end
// The other entries will then be processed with the regular functionality
if ($rows < 100) {
DI::keyValue()->set('post_update_version', 1345);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
$id = DI::keyValue()->get('post_update_version_1346_id') ?? 0;
- Logger::info('Start', ['item' => $id]);
+ DI::logger()->info('Start', ['item' => $id]);
$rows = 0;
['order' => ['oid'], 'limit' => 1000, 'group_by' => ['oid']]);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1346_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id]);
// When there are less than 10 items processed this means that we reached the end
// The other entries will then be processed with the regular functionality
if ($rows < 10) {
DI::keyValue()->set('post_update_version', 1346);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
$id = DI::keyValue()->get('post_update_version_1347_id') ?? 0;
- Logger::info('Start', ['item' => $id]);
+ DI::logger()->info('Start', ['item' => $id]);
$start_id = $id;
$rows = 0;
WHERE `item`.`id` >= ? AND `item`.`vid` IS NULL ORDER BY `item`.`id` LIMIT 10000", Item::GRAVITY_ACTIVITY, $id);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1347_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id]);
if ($start_id == $id) {
DI::keyValue()->set('post_update_version', 1347);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
$id = DI::keyValue()->get('post_update_version_1348_id') ?? 0;
- Logger::info('Start', ['contact' => $id]);
+ DI::logger()->info('Start', ['contact' => $id]);
$start_id = $id;
$rows = 0;
$contacts = DBA::select('contact', ['id', 'baseurl'], $condition, $params);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1348_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id]);
if ($start_id == $id) {
DI::keyValue()->set('post_update_version', 1348);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
$id = DI::keyValue()->get('post_update_version_1349_id') ?? '';
- Logger::info('Start', ['apcontact' => $id]);
+ DI::logger()->info('Start', ['apcontact' => $id]);
$start_id = $id;
$rows = 0;
$apcontacts = DBA::select('apcontact', ['url', 'baseurl'], $condition, $params);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1349_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id]);
if ($start_id == $id) {
DI::keyValue()->set('post_update_version', 1349);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
return true;
}
- Logger::info('Start');
+ DI::logger()->info('Start');
$deleted = 0;
$avatar = [4 => 'photo', 5 => 'thumb', 6 => 'micro'];
DBA::close($photos);
DI::keyValue()->set('post_update_version', 1383);
- Logger::info('Done', ['deleted' => $deleted]);
+ DI::logger()->info('Done', ['deleted' => $deleted]);
return true;
}
}
$condition = ["`hash` IS NULL"];
- Logger::info('Start', ['rest' => DBA::count('photo', $condition)]);
+ DI::logger()->info('Start', ['rest' => DBA::count('photo', $condition)]);
$rows = 0;
$photos = DBA::select('photo', [], $condition, ['limit' => 100]);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
}
DBA::close($photos);
- Logger::info('Processed', ['rows' => $rows]);
+ DI::logger()->info('Processed', ['rows' => $rows]);
if ($rows <= 100) {
DI::keyValue()->set('post_update_version', 1384);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
}
$condition = ["`extid` != ? AND EXISTS(SELECT `id` FROM `post-user` WHERE `uri-id` = `item`.`uri-id` AND `uid` = `item`.`uid` AND `external-id` IS NULL)", ''];
- Logger::info('Start', ['rest' => DBA::count('item', $condition)]);
+ DI::logger()->info('Start', ['rest' => DBA::count('item', $condition)]);
$rows = 0;
$items = DBA::select('item', ['uri-id', 'uid', 'extid'], $condition, ['order' => ['id'], 'limit' => 10000]);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
}
DBA::close($items);
- Logger::info('Processed', ['rows' => $rows]);
+ DI::logger()->info('Processed', ['rows' => $rows]);
if ($rows <= 100) {
DI::keyValue()->set('post_update_version', 1400);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
}
$condition = ["`uri-id` IS NULL"];
- Logger::info('Start', ['rest' => DBA::count('contact', $condition)]);
+ DI::logger()->info('Start', ['rest' => DBA::count('contact', $condition)]);
$rows = 0;
$contacts = DBA::select('contact', ['id', 'url'], $condition, ['limit' => 1000]);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
}
DBA::close($contacts);
- Logger::info('Processed', ['rows' => $rows]);
+ DI::logger()->info('Processed', ['rows' => $rows]);
if ($rows <= 100) {
DI::keyValue()->set('post_update_version', 1424);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
}
$condition = ["`uri-id` IS NULL"];
- Logger::info('Start', ['rest' => DBA::count('fcontact', $condition)]);
+ DI::logger()->info('Start', ['rest' => DBA::count('fcontact', $condition)]);
$rows = 0;
$fcontacts = DBA::select('fcontact', ['id', 'url', 'guid'], $condition, ['limit' => 1000]);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
}
DBA::close($fcontacts);
- Logger::info('Processed', ['rows' => $rows]);
+ DI::logger()->info('Processed', ['rows' => $rows]);
if ($rows <= 100) {
DI::keyValue()->set('post_update_version', 1425);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
}
$condition = ["`uri-id` IS NULL"];
- Logger::info('Start', ['rest' => DBA::count('apcontact', $condition)]);
+ DI::logger()->info('Start', ['rest' => DBA::count('apcontact', $condition)]);
$rows = 0;
$apcontacts = DBA::select('apcontact', ['url', 'uuid'], $condition, ['limit' => 1000]);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
}
DBA::close($apcontacts);
- Logger::info('Processed', ['rows' => $rows]);
+ DI::logger()->info('Processed', ['rows' => $rows]);
if ($rows <= 100) {
DI::keyValue()->set('post_update_version', 1426);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
}
$condition = ["`uri-id` IS NULL"];
- Logger::info('Start', ['rest' => DBA::count('event', $condition)]);
+ DI::logger()->info('Start', ['rest' => DBA::count('event', $condition)]);
$rows = 0;
$events = DBA::select('event', ['id', 'uri', 'guid'], $condition, ['limit' => 1000]);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
}
DBA::close($events);
- Logger::info('Processed', ['rows' => $rows]);
+ DI::logger()->info('Processed', ['rows' => $rows]);
if ($rows <= 100) {
DI::keyValue()->set('post_update_version', 1427);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
$id = DI::keyValue()->get('post_update_version_1452_id') ?? 0;
- Logger::info('Start', ['uri-id' => $id]);
+ DI::logger()->info('Start', ['uri-id' => $id]);
$rows = 0;
$received = '';
Conversation::PARCEL_ACTIVITYPUB, $id, 1000);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1452_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id, 'last-received' => $received]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id, 'last-received' => $received]);
if ($rows <= 100) {
DI::keyValue()->set('post_update_version', 1452);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
return true;
}
- Logger::info('Start');
+ DI::logger()->info('Start');
$posts = DBA::select('post-view', ['uri-id'], ['conversation' => './']);
while ($post = DBA::fetch($posts)) {
DBA::close($posts);
DI::keyValue()->set('post_update_version', 1483);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
$id = DI::keyValue()->get('post_update_version_1484_id') ?? 0;
- Logger::info('Start', ['id' => $id]);
+ DI::logger()->info('Start', ['id' => $id]);
$rows = 0;
$contacts = DBA::select('contact', ['id', 'uid', 'uri-id', 'url'], ["`id` > ?", $id], ['order' => ['id'], 'limit' => 1000]);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1484_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id]);
if ($rows <= 100) {
DI::keyValue()->set('post_update_version', 1484);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
$id = DI::keyValue()->get('post_update_version_1506_id') ?? 0;
- Logger::info('Start', ['contact' => $id]);
+ DI::logger()->info('Start', ['contact' => $id]);
$start_id = $id;
$rows = 0;
$contacts = DBA::select('contact', ['id', 'url'], $condition, $params);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1506_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id]);
if ($start_id == $id) {
DI::keyValue()->set('post_update_version', 1506);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
$id = DI::keyValue()->get('post_update_version_1507_id') ?? '';
- Logger::info('Start', ['apcontact' => $id]);
+ DI::logger()->info('Start', ['apcontact' => $id]);
$start_id = $id;
$rows = 0;
$apcontacts = DBA::select('apcontact', ['url', 'gsid', 'sharedinbox', 'inbox'], $condition, $params);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1507_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id]);
if ($start_id == $id) {
DI::keyValue()->set('post_update_version', 1507);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
$id = (int)($post['uri-id'] ?? 0);
}
- Logger::info('Start', ['uri-id' => $id]);
+ DI::logger()->info('Start', ['uri-id' => $id]);
$rows = 0;
$posts = Post::selectPosts(['uri-id', 'parent-uri-id'], ["`uri-id` < ? AND `gravity` IN (?, ?)", $id, Item::GRAVITY_COMMENT, Item::GRAVITY_PARENT], ['order' => ['uri-id' => true], 'limit' => 1000]);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1544_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id]);
if ($rows <= 100) {
DI::keyValue()->set('post_update_version', 1544);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}
try {
Post\Engagement::storeFromItem($item);
} catch (\Throwable $th) {
- Logger::notice('Exception on storing engagement', ['uri-id' => $engagement['uri-id'], 'code' => $th->getCode(), 'message' => $th->getMessage()]);
+ DI::logger()->notice('Exception on storing engagement', ['uri-id' => $engagement['uri-id'], 'code' => $th->getCode(), 'message' => $th->getMessage()]);
}
}
DBA::close($engagements);
$id = (int)($post['uri-id'] ?? 0);
}
- Logger::info('Start', ['uri-id' => $id]);
+ DI::logger()->info('Start', ['uri-id' => $id]);
$rows = 0;
$posts = Post::selectPosts(['uri-id', 'created'], $condition, ['order' => ['uri-id' => true], 'limit' => 1000]);
if (DBA::errorNo() != 0) {
- Logger::error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
+ DI::logger()->error('Database error', ['no' => DBA::errorNo(), 'message' => DBA::errorMessage()]);
return false;
}
DI::keyValue()->set('post_update_version_1550_id', $id);
- Logger::info('Processed', ['rows' => $rows, 'last' => $id]);
+ DI::logger()->info('Processed', ['rows' => $rows, 'last' => $id]);
if ($rows <= 100) {
DI::keyValue()->set('post_update_version', 1550);
- Logger::info('Done');
+ DI::logger()->info('Done');
return true;
}