X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=pumpio%2Fpumpio.php;h=357f17433b1bf495eb1868760b8fc00ae124b264;hb=940d4658541eef8b5f92bcb0b8b1ec1e73c1cf7b;hp=08e0ec9b98d10793b179ef858ddad3ff8c334e28;hpb=2ed38ad2934034a875eb215d2c6cb560b062b322;p=friendica-addons.git

diff --git a/pumpio/pumpio.php b/pumpio/pumpio.php
index 08e0ec9b..357f1743 100644
--- a/pumpio/pumpio.php
+++ b/pumpio/pumpio.php
@@ -389,7 +389,7 @@ function pumpio_hook_fork(App $a, array &$b)
 
         if (DI::pConfig()->get($post['uid'], 'pumpio', 'import')) {
                 // Don't fork if it isn't a reply to a pump.io post
-                if (($post['parent'] != $post['id']) && !Item::exists(['id' => $post['parent'], 'network' => Protocol::PUMPIO])) {
+                if (($post['parent'] != $post['id']) && !Post::exists(['id' => $post['parent'], 'network' => Protocol::PUMPIO])) {
                         Logger::log('No pump.io parent found for item ' . $post['id']);
                         $b['execute'] = false;
                         return;
@@ -954,7 +954,7 @@ function pumpio_dolike(App $a, $uid, $self, $post, $own_id, $threadcompletion =
 	}
 
 	$condition = ['verb' => Activity::LIKE, 'uid' => $uid, 'contact-id' => $contactid, 'thr-parent' => $orig_post['uri']];
-	if (Item::exists($condition)) {
+	if (Post::exists($condition)) {
 		Logger::log("pumpio_dolike: found existing like. User ".$own_id." ".$uid." Contact: ".$contactid." Url ".$orig_post['uri']);
 		return;
 	}
@@ -1065,13 +1065,13 @@ function pumpio_dodelete(App $a, $uid, $self, $post, $own_id)
 {
 	// Two queries for speed issues
 	$condition = ['uri' => $post->object->id, 'uid' => $uid];
-	if (Item::exists($condition)) {
+	if (Post::exists($condition)) {
 		Item::markForDeletion($condition);
 		return true;
 	}
 
 	$condition = ['extid' => $post->object->id, 'uid' => $uid];
-	if (Item::exists($condition)) {
+	if (Post::exists($condition)) {
 		Item::markForDeletion($condition);
 		return true;
 	}
@@ -1094,10 +1094,10 @@ function pumpio_dopost(App $a, $client, $uid, $self, $post, $own_id, $threadcomp
 
 	if ($post->verb != "update") {
 		// Two queries for speed issues
-		if (Item::exists(['uri' => $post->object->id, 'uid' => $uid])) {
+		if (Post::exists(['uri' => $post->object->id, 'uid' => $uid])) {
 			return false;
 		}
-		if (Item::exists(['extid' => $post->object->id, 'uid' => $uid])) {
+		if (Post::exists(['extid' => $post->object->id, 'uid' => $uid])) {
 			return false;
 		}
 	}
@@ -1299,10 +1299,10 @@ function pumpio_fetchinbox(App $a, $uid)
 	$self = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
 		intval($uid));
 
-	$lastitems = q("SELECT `uri` FROM `thread`
-			INNER JOIN `item` ON `item`.`id` = `thread`.`iid`
-			WHERE `thread`.`network` = '%s' AND `thread`.`uid` = %d AND `item`.`extid` != ''
-			ORDER BY `thread`.`commented` DESC LIMIT 10",
+	$lastitems = q("SELECT `uri` FROM `post-thread-user`
+			INNER JOIN `post-view` ON `post-view`.`id` = `post-thread-user`.`iid`
+			WHERE `post-thread-user`.`network` = '%s' AND `post-thread-user`.`uid` = %d AND `post-view`.`extid` != ''
+			ORDER BY `post-thread-user`.`commented` DESC LIMIT 10",
 				DBA::escape(Protocol::PUMPIO),
 				intval($uid)
 			);
@@ -1561,11 +1561,11 @@ function pumpio_fetchallcomments(App $a, $uid, $id)
 		}
 
 		// Checking if the comment already exists - Two queries for speed issues
-		if (Item::exists(['uri' => $item->id, 'uid' => $uid])) {
+		if (Post::exists(['uri' => $item->id, 'uid' => $uid])) {
 			continue;
 		}
 
-		if (Item::exists(['extid' => $item->id, 'uid' => $uid])) {
+		if (Post::exists(['extid' => $item->id, 'uid' => $uid])) {
 			continue;
 		}