X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=update.php;h=40a3e8ff0d22ee39328b8eddcd39621144af1e00;hb=c65faecc8c88c708e42e9ca686a23bbb34c5bf5a;hp=2ed1a819979b60f45e0b1f0b7752bead2592a63f;hpb=8f9c0fe14956efbcaf0db9dbfb83222e18e0ab2f;p=friendica.git diff --git a/update.php b/update.php index 2ed1a81997..40a3e8ff0d 100644 --- a/update.php +++ b/update.php @@ -13,6 +13,7 @@ use Friendica\Model\GContact; use Friendica\Model\Item; use Friendica\Model\User; use Friendica\Util\DateTimeFormat; +use Friendica\Worker\Delivery; /** * @@ -161,9 +162,9 @@ function update_1191() function update_1203() { $r = q("UPDATE `user` SET `account-type` = %d WHERE `page-flags` IN (%d, %d)", - DBA::escape(Contact::ACCOUNT_TYPE_COMMUNITY), - DBA::escape(Contact::PAGE_COMMUNITY), - DBA::escape(Contact::PAGE_PRVGROUP) + DBA::escape(User::ACCOUNT_TYPE_COMMUNITY), + DBA::escape(User::PAGE_FLAGS_COMMUNITY), + DBA::escape(User::PAGE_FLAGS_PRVGROUP) ); } @@ -334,7 +335,7 @@ function update_1298() DBA::update('profile', [$translateKey => $key], ['id' => $data['id']]); Logger::notice('Updated contact', ['action' => 'update', 'contact' => $data['id'], "$translateKey" => $key, 'was' => $data[$translateKey]]); - Worker::add(PRIORITY_LOW, 'ProfileUpdate', $data['id']); + Worker::add(PRIORITY_LOW, 'ProfileUpdate', $data['id']); Contact::updateSelfFromUserID($data['id']); GContact::updateForUser($data['id']); $success++; @@ -346,3 +347,31 @@ function update_1298() } return Update::SUCCESS; } + +function update_1309() +{ + $queue = DBA::select('queue', ['id', 'cid', 'guid']); + while ($entry = DBA::fetch($queue)) { + $contact = DBA::selectFirst('contact', ['uid'], ['id' => $entry['cid']]); + if (!DBA::isResult($contact)) { + continue; + } + + $item = Item::selectFirst(['id', 'gravity'], ['uid' => $contact['uid'], 'guid' => $entry['guid']]); + if (!DBA::isResult($item)) { + continue; + } + + if ($item['gravity'] == GRAVITY_PARENT) { + $cmd = Delivery::POST; + } else { + $cmd = Delivery::COMMENT; + } + + $deliver_options = ['priority' => PRIORITY_MEDIUM, 'dont_fork' => true]; + Worker::add($deliver_options, 'Delivery', $cmd, $item['id'], $entry['cid']); + Logger::info('Added delivery worker', ['command' => $cmd, 'item' => $item['id'], 'contact' => $entry['cid']]); + DBA::delete('queue', ['id' => $entry['id']]); + } + return Update::SUCCESS; +}