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

diff --git a/src/Model/Post.php b/src/Model/Post.php
index 5bb41d16c2..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,13 +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
 	 *
@@ -65,6 +94,10 @@ class Post
 			}
 		}
 
+		if (array_key_exists('extid', $row) && is_null($row['extid'])) {
+			$row['extid'] = '';
+		}
+
 		return $row;
 	}
 
@@ -94,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);
 	}
 
 	/**
@@ -107,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
 	 *
@@ -118,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);
 	}
 
 	/**
@@ -148,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
 	 *
@@ -178,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
@@ -189,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']);
 			}
 		}
 
@@ -210,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);
 	}
 
 	/**
@@ -231,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
@@ -253,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 `uri-id` FROM `post-user` WHERE `hidden` AND `uri-id` = `" . $view . "`.`uri-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);
@@ -299,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);
 	}
 
 		/**
@@ -315,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);
 	}
 
 	/**
@@ -344,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
 	 *
@@ -383,24 +405,24 @@ 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::selectThreadForUser($uid, $selected, $condition, $params);
+		return self::selectForUser($uid, $selected, $condition, $params);
 	}
 
 	/**
@@ -418,7 +440,7 @@ class Post
 	{
 		$affected = 0;
 
-		Logger::info('Start Update', ['fields' => $fields, 'condition' => $condition]);
+		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']);
@@ -438,93 +460,104 @@ class Post
 
 		$update_fields = DBStructure::getFieldsForTable('post-user', $fields);
 		if (!empty($update_fields)) {
-			$rows = DBA::selectToArray('post-view', ['post-user-id'], $condition);
-			$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 = 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();
 			}
-			$affected = DBA::affectedRows();			
+			DBA::close($posts);
+			$affected = $affected_count;
 		}
 
 		$update_fields = DBStructure::getFieldsForTable('post-content', $fields);
 		if (!empty($update_fields)) {
-			$rows = DBA::selectToArray('post-view', ['uri-id'], $condition, ['group_by' => ['uri-id']]);
-			$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 = 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();
 			}
-			$affected = max($affected, DBA::affectedRows());
+			DBA::close($posts);
+			$affected = max($affected, $affected_count);
 		}
 
-		$update_fields = Post\DeliveryData::extractFields($fields);
+		$update_fields = DBStructure::getFieldsForTable('post', $fields);
 		if (!empty($update_fields)) {
-			if (empty($uriids)) {
-				$rows = DBA::selectToArray('post-view', ['uri-id'], $condition, ['group_by' => ['uri-id']]);
+			$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();
 			}
-			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 = max($affected, DBA::affectedRows());
+			DBA::close($posts);
+			$affected = max($affected, $affected_count);
 		}
 
-		$update_fields = DBStructure::getFieldsForTable('post-thread-user', $fields);
+		$update_fields = Post\DeliveryData::extractFields($fields);
 		if (!empty($update_fields)) {
-			$rows = DBA::selectToArray('post-view', ['post-user-id'], $thread_condition);
-			$thread_puids = array_column($rows, 'post-user-id');
-
-			$post_thread_condition = DBA::collapseCondition(['id' => $thread_puids]);
-
-			$post_thread_condition[0] = "EXISTS(SELECT `id` FROM `post-user` WHERE " .
-				$post_thread_condition[0] . " AND `uri-id` = `post-thread-user`.`uri-id` AND `uid` = `post-thread-user`.`uid`)";
-			Logger::info('Test2-start', ['condition' => $post_thread_condition]);
-				if (!DBA::update('post-thread-user', $update_fields, $post_thread_condition)) {
-				DBA::rollback();
-				Logger::notice('Updating post-thread-user failed', ['fields' => $update_fields, 'condition' => $condition]);
-				return false;
+			$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();
 			}
-			Logger::info('Test2-end');
-			$affected = max($affected, DBA::affectedRows());
+			DBA::close($posts);
+			$affected = max($affected, $affected_count);
 		}
 
-		$update_fields = DBStructure::getFieldsForTable('thread', $fields);
+		$update_fields = DBStructure::getFieldsForTable('post-thread', $fields);
 		if (!empty($update_fields)) {
-			$rows = DBA::selectToArray('post-view', ['id'], $thread_condition);
-			$ids = array_column($rows, 'id');
-			if (!DBA::update('thread', $update_fields, ['iid' => $ids])) {
-				DBA::rollback();
-				Logger::notice('Updating thread failed', ['fields' => $update_fields, 'condition' => $thread_condition]);
-				return false;
+			$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();
 			}
-			$affected = max($affected, DBA::affectedRows());
+			DBA::close($posts);
+			$affected = max($affected, $affected_count);
 		}
 
-		$item_fields = ['guid', 'type', 'wall', 'gravity', 'extid', 'created', 'edited', 'commented', 'received', 'changed',
-			'resource-id', 'post-type', 'private', 'pubmail', 'moderated', 'visible', 'starred', 'bookmark',
-			'unseen', 'deleted', 'origin', 'forum_mode', 'mention', 'global', 'network', 'vid', 'psid',
-			'contact-id', 'author-id', 'owner-id', 'causer-id', 'event-id'];
-
-		$update_fields = [];
-		foreach ($item_fields as $field) {
-			if (array_key_exists($field, $fields)) {
-				$update_fields[$field] = $fields[$field];
-			}
-		}
+		$update_fields = DBStructure::getFieldsForTable('post-thread-user', $fields);
 		if (!empty($update_fields)) {
-			$rows = DBA::selectToArray('post-view', ['id'], $condition, []);
-			$ids = array_column($rows, 'id');
-			if (!DBA::update('item', $update_fields, ['id' => $ids])) {
-				DBA::rollback();
-				Logger::notice('Updating item failed', ['fields' => $update_fields, 'condition' => $condition]);
-				return false;
+			$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();
 			}
-			$affected = max($affected, DBA::affectedRows());
+			DBA::close($posts);
+			$affected = max($affected, $affected_count);
 		}
 
 		DBA::commit();
@@ -532,4 +565,20 @@ class Post
 		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);
+	}
 }