X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FModel%2FPost.php;h=2e8bbe22e3650fdc7ffd265f5c3428d37b2b608d;hb=f23ecaff6af1982112469f90d6bcdf0408b0f22e;hp=e78e0f706f6bf65e694fc2b10882de7bbb700188;hpb=bbe05f523fbb73e34a909e247afab9be77481f70;p=friendica.git diff --git a/src/Model/Post.php b/src/Model/Post.php index e78e0f706f..2e8bbe22e3 100644 --- a/src/Model/Post.php +++ b/src/Model/Post.php @@ -1,6 +1,6 @@ select * @return array Data array - * @todo Find proper type-hint for $stmt and maybe avoid boolean + * @throws \Exception */ - public static function toArray($stmt, bool $do_close = true) + public static function toArray($stmt): array { if (is_bool($stmt)) { - return $stmt; + return []; } $data = []; while ($row = self::fetch($stmt)) { $data[] = $row; } - if ($do_close) { - DBA::close($stmt); - } + + DBA::close($stmt); + return $data; } @@ -229,6 +221,46 @@ class Post } } + /** + * Retrieve a single record from the post-user-view view and returns it in an associative array + * When the requested record is a reshare activity, the system fetches the reshared original post. + * Otherwise the function reacts similar to selectFirst + * + * @param array $fields + * @param array $condition + * @param array $params + * @param bool $user_mode true = post-user-view, false = post-view + * @return bool|array + * @throws \Exception + * @see DBA::select + */ + public static function selectOriginal(array $fields = [], array $condition = [], array $params = []) + { + $original_fields = $fields; + $remove = []; + if (!empty($fields)) { + foreach (['gravity', 'verb', 'thr-parent-id', 'uid'] as $field) { + if (!in_array($field, $fields)) { + $fields[] = $field; + $remove[] = $field; + } + } + } + $result = self::selectFirst($fields, $condition, $params); + if (empty($result)) { + return $result; + } + + if (($result['gravity'] != Item::GRAVITY_ACTIVITY) || ($result['verb'] != Activity::ANNOUNCE)) { + foreach ($remove as $field) { + unset($result[$field]); + } + return $result; + } + + return self::selectFirst($original_fields, ['uri-id' => $result['thr-parent-id'], 'uid' => [0, $result['uid']]], $params); + } + /** * Retrieve a single record from the post-view view and returns it in an associative array * @@ -377,6 +409,21 @@ class Post return self::selectView('post-thread-user-view', $selected, $condition, $params); } + /** + * Select rows from the post-thread-view view + * + * @param array $selected Array of selected fields, empty for all + * @param array $condition Array of fields for condition + * @param array $params Array of several parameters + * + * @return boolean|object + * @throws \Exception + */ + public static function selectPostThread(array $selected = [], array $condition = [], array $params = []) + { + return self::selectView('post-thread-view', $selected, $condition, $params); + } + /** * Select rows from the given view for a given user * @@ -400,18 +447,16 @@ class Post AND NOT `author-blocked` AND NOT `owner-blocked` AND (NOT `causer-blocked` OR `causer-id` = ? OR `causer-id` IS NULL) AND NOT `contact-blocked` AND ((NOT `contact-readonly` AND NOT `contact-pending` AND (`contact-rel` IN (?, ?))) - OR `self` OR `gravity` != ? OR `contact-uid` = ?) - AND NOT `" . $view . "`.`uri-id` IN (SELECT `uri-id` FROM `post-user` WHERE `uid` = ? AND `hidden`) - AND NOT `author-id` IN (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `blocked`) - AND NOT `owner-id` IN (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `blocked`) - AND NOT (`gravity` = ? AND `author-id` IN (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `ignored`)) - AND NOT (`gravity` = ? AND `owner-id` IN (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `ignored`))", - 0, Contact::SHARING, Contact::FRIEND, Item::GRAVITY_PARENT, 0, $uid, $uid, $uid, Item::GRAVITY_PARENT, $uid, Item::GRAVITY_PARENT, $uid]); + OR `self` OR `contact-uid` = ?) + AND NOT EXISTS(SELECT `uri-id` FROM `post-user` WHERE `uid` = ? AND `uri-id` = " . DBA::quoteIdentifier($view) . ".`uri-id` AND `hidden`) + AND NOT EXISTS(SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `cid` IN (`author-id`, `owner-id`) AND (`blocked` OR `ignored`)) + AND NOT EXISTS(SELECT `gsid` FROM `user-gserver` WHERE `uid` = ? AND `gsid` IN (`author-gsid`, `owner-gsid`, `causer-gsid`) AND `ignored`)", + 0, Contact::SHARING, Contact::FRIEND, 0, $uid, $uid, $uid]); $select_string = implode(', ', array_map([DBA::class, 'quoteIdentifier'], $selected)); $condition_string = DBA::buildCondition($condition); - $param_string = DBA::buildParameter($params); + $param_string = DBA::buildParameter($params); $sql = "SELECT " . $select_string . " FROM `" . $view . "` " . $condition_string . $param_string; $sql = DBA::cleanQuery($sql); @@ -451,6 +496,23 @@ class Post return self::selectViewForUser('post-view', $uid, $selected, $condition, $params); } + /** + * Select rows from the post-timeline-view view for a given user + * This function is used for API calls. + * + * @param integer $uid User ID + * @param array $selected Array of selected fields, empty for all + * @param array $condition Array of fields for condition + * @param array $params Array of several parameters + * + * @return boolean|object + * @throws \Exception + */ + public static function selectTimelineForUser(int $uid, array $selected = [], array $condition = [], array $params = []) + { + return self::selectViewForUser('post-timeline-view', $uid, $selected, $condition, $params); + } + /** * Select rows from the post-thread-user-view view for a given user * @@ -493,6 +555,46 @@ class Post } } + /** + * Retrieve a single record from the post-user-view view for a given user and returns it in an associative array + * When the requested record is a reshare activity, the system fetches the reshared original post. + * Otherwise the function reacts similar to selectFirstForUser + * + * @param integer $uid User ID + * @param array $selected + * @param array $condition + * @param array $params + * @return bool|array + * @throws \Exception + * @see DBA::select + */ + public static function selectOriginalForUser(int $uid, array $selected = [], array $condition = [], array $params = []) + { + $original_selected = $selected; + $remove = []; + if (!empty($selected)) { + foreach (['gravity', 'verb', 'thr-parent-id'] as $field) { + if (!in_array($field, $selected)) { + $selected[] = $field; + $remove[] = $field; + } + } + } + $result = self::selectFirstForUser($uid, $selected, $condition, $params); + if (empty($result)) { + return $result; + } + + if (($result['gravity'] != Item::GRAVITY_ACTIVITY) || ($result['verb'] != Activity::ANNOUNCE)) { + foreach ($remove as $field) { + unset($result[$field]); + } + return $result; + } + + return self::selectFirstForUser($uid, $original_selected, ['uri-id' => $result['thr-parent-id'], 'uid' => [0, $uid]], $params); + } + /** * Update existing post entries * @@ -508,7 +610,7 @@ class Post { $affected = 0; - Logger::info('Start Update', ['fields' => $fields, 'condition' => $condition, 'uid' => local_user(),'callstack' => System::callstack(10)]); + Logger::info('Start Update', ['fields' => $fields, 'condition' => $condition, 'uid' => DI::userSession()->getLocalUserId()]); // Don't allow changes to fields that are responsible for the relation between the records unset($fields['id']); @@ -529,7 +631,7 @@ class Post $update_fields = DI::dbaDefinition()->truncateFieldsForTable('post-user', $fields); if (!empty($update_fields)) { $affected_count = 0; - $posts = DBA::select('post-user-view', ['post-user-id'], $condition); + $posts = DBA::select('post-user-view', ['post-user-id'], $condition); while ($rows = DBA::toArray($posts, false, 100)) { $puids = array_column($rows, 'post-user-id'); if (!DBA::update('post-user', $update_fields, ['id' => $puids])) { @@ -546,7 +648,7 @@ class Post $update_fields = DI::dbaDefinition()->truncateFieldsForTable('post-content', $fields); if (!empty($update_fields)) { $affected_count = 0; - $posts = DBA::select('post-user-view', ['uri-id'], $condition, ['group_by' => ['uri-id']]); + $posts = DBA::select('post-user-view', ['uri-id'], $condition, ['group_by' => ['uri-id']]); while ($rows = DBA::toArray($posts, false, 100)) { $uriids = array_column($rows, 'uri-id'); if (!DBA::update('post-content', $update_fields, ['uri-id' => $uriids])) { @@ -563,7 +665,7 @@ class Post $update_fields = DI::dbaDefinition()->truncateFieldsForTable('post', $fields); if (!empty($update_fields)) { $affected_count = 0; - $posts = DBA::select('post-user-view', ['uri-id'], $condition, ['group_by' => ['uri-id']]); + $posts = DBA::select('post-user-view', ['uri-id'], $condition, ['group_by' => ['uri-id']]); while ($rows = DBA::toArray($posts, false, 100)) { $uriids = array_column($rows, 'uri-id'); @@ -586,7 +688,7 @@ class Post $update_fields = Post\DeliveryData::extractFields($fields); if (!empty($update_fields)) { $affected_count = 0; - $posts = DBA::select('post-user-view', ['uri-id'], $condition, ['group_by' => ['uri-id']]); + $posts = DBA::select('post-user-view', ['uri-id'], $condition, ['group_by' => ['uri-id']]); while ($rows = DBA::toArray($posts, false, 100)) { $uriids = array_column($rows, 'uri-id'); if (!DBA::update('post-delivery-data', $update_fields, ['uri-id' => $uriids])) { @@ -603,7 +705,7 @@ class Post $update_fields = DI::dbaDefinition()->truncateFieldsForTable('post-thread', $fields); if (!empty($update_fields)) { $affected_count = 0; - $posts = DBA::select('post-user-view', ['uri-id'], $thread_condition, ['group_by' => ['uri-id']]); + $posts = DBA::select('post-user-view', ['uri-id'], $thread_condition, ['group_by' => ['uri-id']]); while ($rows = DBA::toArray($posts, false, 100)) { $uriids = array_column($rows, 'uri-id'); if (!DBA::update('post-thread', $update_fields, ['uri-id' => $uriids])) { @@ -620,7 +722,7 @@ class Post $update_fields = DI::dbaDefinition()->truncateFieldsForTable('post-thread-user', $fields); if (!empty($update_fields)) { $affected_count = 0; - $posts = DBA::select('post-user-view', ['post-user-id'], $thread_condition); + $posts = DBA::select('post-user-view', ['post-user-id'], $thread_condition); while ($rows = DBA::toArray($posts, false, 100)) { $thread_puids = array_column($rows, 'post-user-id'); if (!DBA::update('post-thread-user', $update_fields, ['post-user-id' => $thread_puids])) {