X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FModel%2FPost.php;h=aae847664db2093efee10ebc45575a2fa44a39ad;hb=a24febb8b656217a7cd88db205007420cb64485e;hp=ec348c60ad3b7d7f1565448ab2721ca517a0e7c1;hpb=1193b73125fc911ae508276cde69718cc4c7f3c3;p=friendica.git

diff --git a/src/Model/Post.php b/src/Model/Post.php
index ec348c60ad..aae847664d 100644
--- a/src/Model/Post.php
+++ b/src/Model/Post.php
@@ -1,6 +1,6 @@
 <?php
 /**
- * @copyright Copyright (C) 2020, Friendica
+ * @copyright Copyright (C) 2010-2021, the Friendica project
  *
  * @license GNU AGPL version 3 or any later version
  *
@@ -21,11 +21,42 @@
 
 namespace Friendica\Model;
 
+use BadMethodCallException;
+use Friendica\Core\Logger;
+use Friendica\Core\System;
+use Friendica\Database\Database;
 use Friendica\Database\DBA;
+use Friendica\Database\DBStructure;
 use Friendica\Protocol\Activity;
 
 class Post
 {
+	/**
+	 * Insert a new post entry
+	 *
+	 * @param integer $uri_id
+	 * @param array   $fields
+	 * @return int    ID of inserted post
+	 * @throws \Exception
+	 */
+	public static function insert(int $uri_id, array $data = [])
+	{
+		if (empty($uri_id)) {
+			throw new BadMethodCallException('Empty URI_id');
+		}
+
+		$fields = DBStructure::getFieldsForTable('post', $data);
+
+		// Additionally assign the key fields
+		$fields['uri-id'] = $uri_id;
+
+		if (!DBA::insert('post', $fields, Database::INSERT_IGNORE)) {
+			return 0;
+		}
+
+		return DBA::lastInsertId();
+	}
+
 	/**
 	 * Fetch a single post row
 	 *
@@ -63,6 +94,10 @@ class Post
 			}
 		}
 
+		if (array_key_exists('extid', $row) && is_null($row['extid'])) {
+			$row['extid'] = '';
+		}
+
 		return $row;
 	}
 
@@ -92,12 +127,13 @@ class Post
 	 * Check if post data exists
 	 *
 	 * @param array $condition array of fields for condition
+	 * @param bool  $user_mode true = post-user-view, false = post-view
 	 *
 	 * @return boolean Are there rows for that condition?
 	 * @throws \Exception
 	 */
-	public static function exists($condition) {
-		return DBA::exists('post-view', $condition);
+	public static function exists($condition, bool $user_mode = true) {
+		return DBA::exists($user_mode ? 'post-user-view' : 'post-view', $condition);
 	}
 
 	/**
@@ -105,6 +141,7 @@ class Post
 	 *
 	 * @param array        $condition array of fields for condition
 	 * @param array        $params    Array of several parameters
+	 * @param bool         $user_mode true = post-user-view, false = post-view
 	 *
 	 * @return int
 	 *
@@ -116,9 +153,9 @@ class Post
 	 * $count = Post::count($condition);
 	 * @throws \Exception
 	 */
-	public static function count(array $condition = [], array $params = [])
+	public static function count(array $condition = [], array $params = [], bool $user_mode = true)
 	{
-		return DBA::count('post-view', $condition, $params);
+		return DBA::count($user_mode ? 'post-user-view' : 'post-view', $condition, $params);
 	}
 
 	/**
@@ -146,6 +183,31 @@ class Post
 		}
 	}
 
+	/**
+	 * Retrieve a single record from the post-thread table and returns it in an associative array
+	 *
+	 * @param array $fields
+	 * @param array $condition
+	 * @param array $params
+	 * @return bool|array
+	 * @throws \Exception
+	 * @see   DBA::select
+	 */
+	public static function selectFirstThread(array $fields = [], array $condition = [], $params = [])
+	{
+		$params['limit'] = 1;
+
+		$result = self::selectThread($fields, $condition, $params);
+
+		if (is_bool($result)) {
+			return $result;
+		} else {
+			$row = self::fetch($result);
+			DBA::close($result);
+			return $row;
+		}
+	}
+
 	/**
 	 * Select rows from the post table and returns them as an array
 	 *
@@ -176,7 +238,7 @@ class Post
 	/**
 	 * Select rows from the given view
 	 *
-	 * @param string $view      View (post-view or post-thread-view)
+	 * @param string $view      View (post-user-view or post-thread-user-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
@@ -187,13 +249,10 @@ class Post
 	private static function selectView(string $view, array $selected = [], array $condition = [], $params = [])
 	{
 		if (empty($selected)) {
-			$selected = array_merge(['author-addr', 'author-nick', 'owner-addr', 'owner-nick', 'causer-addr', 'causer-nick',
-				'causer-network', 'photo', 'name-date', 'uri-date', 'avatar-date', 'thumb', 'dfrn-id',
-				'parent-guid', 'parent-network', 'parent-author-id', 'parent-author-link', 'parent-author-name',
-				'parent-author-network', 'signed_text'], Item::DISPLAY_FIELDLIST, Item::ITEM_FIELDLIST, Item::CONTENT_FIELDLIST);
-			
-			if ($view == 'post-thread-view') {
-				$selected = array_merge($selected, ['ignored', 'iid']);
+			$selected = array_merge(Item::DISPLAY_FIELDLIST, Item::ITEM_FIELDLIST);
+
+			if ($view == 'post-thread-user-view') {
+				$selected = array_merge($selected, ['ignored']);
 			}
 		}
 
@@ -208,13 +267,14 @@ class Post
 	 * @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
+	 * @param bool  $user_mode true = post-user-view, false = post-view
 	 *
 	 * @return boolean|object
 	 * @throws \Exception
 	 */
-	public static function select(array $selected = [], array $condition = [], $params = [])
+	public static function select(array $selected = [], array $condition = [], $params = [], bool $user_mode = true)
 	{
-		return self::selectView('post-view', $selected, $condition, $params);
+		return self::selectView($user_mode ? 'post-user-view' : 'post-view', $selected, $condition, $params);
 	}
 
 	/**
@@ -229,13 +289,13 @@ class Post
 	 */
 	public static function selectThread(array $selected = [], array $condition = [], $params = [])
 	{
-		return self::selectView('post-thread-view', $selected, $condition, $params);
+		return self::selectView('post-thread-user-view', $selected, $condition, $params);
 	}
 
 	/**
 	 * Select rows from the given view for a given user
 	 *
-	 * @param string  $view      View (post-view or post-thread-view)
+	 * @param string  $view      View (post-user-view or post-thread-user-view)
 	 * @param integer $uid       User ID
 	 * @param array   $selected  Array of selected fields, empty for all
 	 * @param array   $condition Array of fields for condition
@@ -251,29 +311,19 @@ class Post
 		}
 
 		$condition = DBA::mergeConditions($condition,
-			["`visible` AND NOT `deleted` AND NOT `moderated`
+			["`visible` AND NOT `deleted`
 			AND NOT `author-blocked` AND NOT `owner-blocked`
-			AND (NOT `causer-blocked` OR `causer-id` = ?) AND NOT `contact-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 EXISTS (SELECT `iid` FROM `user-item` WHERE `hidden` AND `iid` = `id` AND `uid` = ?)
+			AND NOT EXISTS (SELECT `uri-id` FROM `post-user` WHERE `uid` = ? AND `uri-id` = `" . $view . "`.`uri-id` AND `hidden`)
 			AND NOT EXISTS (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `cid` = `author-id` AND `blocked`)
 			AND NOT EXISTS (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `cid` = `owner-id` AND `blocked`)
 			AND NOT EXISTS (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `cid` = `author-id` AND `ignored` AND `gravity` = ?)
 			AND NOT EXISTS (SELECT `cid` FROM `user-contact` WHERE `uid` = ? AND `cid` = `owner-id` AND `ignored` AND `gravity` = ?)",
 			0, Contact::SHARING, Contact::FRIEND, GRAVITY_PARENT, 0, $uid, $uid, $uid, $uid, GRAVITY_PARENT, $uid, GRAVITY_PARENT]);
 
-		$select_string = '';
-
-		if (in_array('pinned', $selected)) {
-			$selected = array_flip($selected);
-			unset($selected['pinned']);
-			$selected = array_flip($selected);	
-
-			$select_string = "(SELECT `pinned` FROM `user-item` WHERE `iid` = `" . $view . "`.`id` AND uid=`" . $view . "`.`uid`) AS `pinned`, ";
-		}
-
-		$select_string .= implode(', ', array_map([DBA::class, 'quoteIdentifier'], $selected));
+		$select_string = implode(', ', array_map([DBA::class, 'quoteIdentifier'], $selected));
 
 		$condition_string = DBA::buildCondition($condition);
 		$param_string = DBA::buildParameter($params);
@@ -297,7 +347,7 @@ class Post
 	 */
 	public static function selectForUser($uid, array $selected = [], array $condition = [], $params = [])
 	{
-		return self::selectViewForUser('post-view', $uid, $selected, $condition, $params);
+		return self::selectViewForUser('post-user-view', $uid, $selected, $condition, $params);
 	}
 
 		/**
@@ -313,7 +363,7 @@ class Post
 	 */
 	public static function selectThreadForUser($uid, array $selected = [], array $condition = [], $params = [])
 	{
-		return self::selectViewForUser('post-thread-view', $uid, $selected, $condition, $params);
+		return self::selectViewForUser('post-thread-user-view', $uid, $selected, $condition, $params);
 	}
 
 	/**
@@ -342,32 +392,6 @@ class Post
 		}
 	}
 
-	/**
-	 * Retrieve a single record from the starting post in the item table and returns it in an associative array
-	 *
-	 * @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 selectFirstThreadForUser($uid, array $selected = [], array $condition = [], $params = [])
-	{
-		$params['limit'] = 1;
-
-		$result = self::selectThreadForUser($uid, $selected, $condition, $params);
-
-		if (is_bool($result)) {
-			return $result;
-		} else {
-			$row = self::fetch($result);
-			DBA::close($result);
-			return $row;
-		}
-	}
-
 	/**
 	 * Select pinned rows from the item table for a given user
 	 *
@@ -381,23 +405,180 @@ class Post
 	 */
 	public static function selectPinned(int $uid, array $selected = [], array $condition = [], $params = [])
 	{
-		$useritems = DBA::select('user-item', ['iid'], ['uid' => $uid, 'pinned' => true]);
-		if (!DBA::isResult($useritems)) {
-			return $useritems;
+		$postthreaduser = DBA::select('post-thread-user', ['uri-id'], ['uid' => $uid, 'pinned' => true]);
+		if (!DBA::isResult($postthreaduser)) {
+			return $postthreaduser;
 		}
 
 		$pinned = [];
-		while ($useritem = DBA::fetch($useritems)) {
-			$pinned[] = $useritem['iid'];
+		while ($useritem = DBA::fetch($postthreaduser)) {
+			$pinned[] = $useritem['uri-id'];
 		}
-		DBA::close($useritems);
+		DBA::close($postthreaduser);
 
 		if (empty($pinned)) {
 			return [];
 		}
 
-		$condition = DBA::mergeConditions(['iid' => $pinned], $condition);
+		$condition = DBA::mergeConditions(['uri-id' => $pinned, 'uid' => $uid, 'gravity' => GRAVITY_PARENT], $condition);
+
+		return self::selectForUser($uid, $selected, $condition, $params);
+	}
 
-		return self::selectThreadForUser($uid, $selected, $condition, $params);
+	/**
+	 * Update existing post entries
+	 *
+	 * @param array $fields    The fields that are to be changed
+	 * @param array $condition The condition for finding the item entries
+	 *
+	 * A return value of "0" doesn't mean an error - but that 0 rows had been changed.
+	 *
+	 * @return integer|boolean number of affected rows - or "false" if there was an error
+	 * @throws \Friendica\Network\HTTPException\InternalServerErrorException
+	 */
+	public static function update(array $fields, array $condition)
+	{
+		$affected = 0;
+
+		Logger::info('Start Update', ['fields' => $fields, 'condition' => $condition, 'uid' => local_user(),'callstack' => System::callstack(10)]);
+
+		// Don't allow changes to fields that are responsible for the relation between the records
+		unset($fields['id']);
+		unset($fields['parent']);
+		unset($fields['uid']);
+		unset($fields['uri']);
+		unset($fields['uri-id']);
+		unset($fields['thr-parent']);
+		unset($fields['thr-parent-id']);
+		unset($fields['parent-uri']);
+		unset($fields['parent-uri-id']);
+
+		$thread_condition = DBA::mergeConditions($condition, ['gravity' => GRAVITY_PARENT]);
+
+		// To ensure the data integrity we do it in an transaction
+		DBA::transaction();
+
+		$update_fields = DBStructure::getFieldsForTable('post-user', $fields);
+		if (!empty($update_fields)) {
+			$affected_count = 0;
+			$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])) {
+					DBA::rollback();
+					Logger::notice('Updating post-user failed', ['fields' => $update_fields, 'condition' => $condition]);
+					return false;
+				}
+				$affected_count += DBA::affectedRows();
+			}
+			DBA::close($posts);
+			$affected = $affected_count;
+		}
+
+		$update_fields = DBStructure::getFieldsForTable('post-content', $fields);
+		if (!empty($update_fields)) {
+			$affected_count = 0;
+			$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])) {
+					DBA::rollback();
+					Logger::notice('Updating post-content failed', ['fields' => $update_fields, 'condition' => $condition]);
+					return false;
+				}
+				$affected_count += DBA::affectedRows();
+			}
+			DBA::close($posts);
+			$affected = max($affected, $affected_count);
+		}
+
+		$update_fields = DBStructure::getFieldsForTable('post', $fields);
+		if (!empty($update_fields)) {
+			$affected_count = 0;
+			$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', $update_fields, ['uri-id' => $uriids])) {
+					DBA::rollback();
+					Logger::notice('Updating post failed', ['fields' => $update_fields, 'condition' => $condition]);
+					return false;
+				}
+				$affected_count += DBA::affectedRows();
+			}
+			DBA::close($posts);
+			$affected = max($affected, $affected_count);
+		}
+
+		$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']]);
+			while ($rows = DBA::toArray($posts, false, 100)) {
+				$uriids = array_column($rows, 'uri-id');
+				if (!DBA::update('post-delivery-data', $update_fields, ['uri-id' => $uriids])) {
+					DBA::rollback();
+					Logger::notice('Updating post-delivery-data failed', ['fields' => $update_fields, 'condition' => $condition]);
+					return false;
+				}
+				$affected_count += DBA::affectedRows();
+			}
+			DBA::close($posts);
+			$affected = max($affected, $affected_count);
+		}
+
+		$update_fields = DBStructure::getFieldsForTable('post-thread', $fields);
+		if (!empty($update_fields)) {
+			$affected_count = 0;
+			$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])) {
+					DBA::rollback();
+					Logger::notice('Updating post-thread failed', ['fields' => $update_fields, 'condition' => $condition]);
+					return false;
+				}
+				$affected_count += DBA::affectedRows();
+			}
+			DBA::close($posts);
+			$affected = max($affected, $affected_count);
+		}
+
+		$update_fields = DBStructure::getFieldsForTable('post-thread-user', $fields);
+		if (!empty($update_fields)) {
+			$affected_count = 0;
+			$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])) {
+					DBA::rollback();
+					Logger::notice('Updating post-thread-user failed', ['fields' => $update_fields, 'condition' => $condition]);
+					return false;
+				}
+				$affected_count += DBA::affectedRows();
+			}
+			DBA::close($posts);
+			$affected = max($affected, $affected_count);
+		}
+
+		DBA::commit();
+
+		Logger::info('Updated posts', ['rows' => $affected]);
+		return $affected;
+	}
+
+	/**
+	 * Delete a row from the post table
+	 *
+	 * @param array        $conditions Field condition(s)
+	 * @param array        $options
+	 *                           - cascade: If true we delete records in other tables that depend on the one we're deleting through
+	 *                           relations (default: true)
+	 *
+	 * @return boolean was the delete successful?
+	 * @throws \Exception
+	 */
+	public static function delete(array $conditions, array $options = [])
+	{
+		return DBA::delete('post', $conditions, $options);
 	}
 }