X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=fbsync%2Ffbsync.php;h=40a7ef46d470c31efb186544a838c610827b5357;hb=3d8d0e2860c3cb379e486e5a9565df5cbcc041a0;hp=21779769e8809dbcf1c54fddd87571b24b174b3d;hpb=29afc4bf02fa6e3ac3e4525dce853cc78165c1cf;p=friendica-addons.git

diff --git a/fbsync/fbsync.php b/fbsync/fbsync.php
index 21779769..40a7ef46 100644
--- a/fbsync/fbsync.php
+++ b/fbsync/fbsync.php
@@ -26,6 +26,7 @@ function fbsync_install() {
 	register_hook('connector_settings_post', 'addon/fbsync/fbsync.php', 'fbsync_settings_post');
 	register_hook('cron', 'addon/fbsync/fbsync.php', 'fbsync_cron');
 	register_hook('follow', 'addon/fbsync/fbsync.php', 'fbsync_follow');
+	register_hook('expire', 'addon/fbsync/fbsync.php', 'fbsync_expire');
 }
 
 function fbsync_uninstall() {
@@ -33,6 +34,7 @@ function fbsync_uninstall() {
 	unregister_hook('connector_settings_post', 'addon/fbsync/fbsync.php', 'fbsync_settings_post');
 	unregister_hook('cron', 'addon/fbsync/fbsync.php', 'fbsync_cron');
 	unregister_hook('follow', 'addon/fbsync/fbsync.php', 'fbsync_follow');
+	unregister_hook('expire', 'addon/fbsync/fbsync.php', 'fbsync_expire');
 }
 
 function fbsync_follow($a, &$contact) {
@@ -185,9 +187,37 @@ function fbsync_cron($a,$b) {
 	set_config('fbsync','last_poll', time());
 }
 
+function fbsync_expire($a,$b) {
+
+	$days = get_config('fbsync', 'expire');
+
+	if ($days == 0)
+		return;
+
+	$r = q("DELETE FROM `item` WHERE `deleted` AND `network` = '%s'", dbesc(NETWORK_FACEBOOK));
+
+	require_once("include/items.php");
+
+	logger('fbsync_expire: expire_start');
+
+	$r = q("SELECT * FROM `pconfig` WHERE `cat` = 'fbsync' AND `k` = 'sync' AND `v` = '1' ORDER BY RAND()");
+	if(count($r)) {
+		foreach($r as $rr) {
+			logger('fbsync_expire: user '.$rr['uid']);
+			item_expire($rr['uid'], $days, NETWORK_FACEBOOK, true);
+		}
+	}
+
+	logger('fbsync_expire: expire_end');
+}
+
 function fbsync_createpost($a, $uid, $self, $contacts, $applications, $post, $create_user) {
 
+	$access_token = get_pconfig($uid,'facebook','access_token');
+
 	require_once("include/oembed.php");
+	require_once("include/network.php");
+	require_once("include/items.php");
 
 	// check if it was already imported
 	$r = q("SELECT * FROM `item` WHERE `uid` = %d AND `uri` = '%s' LIMIT 1",
@@ -203,6 +233,7 @@ function fbsync_createpost($a, $uid, $self, $contacts, $applications, $post, $cr
 	$postarray['wall'] = 0;
 
 	$postarray['verb'] = ACTIVITY_POST;
+	$postarray['object-type'] = ACTIVITY_OBJ_NOTE; // default value - is maybe changed later when media is attached
 	$postarray['network'] =  dbesc(NETWORK_FACEBOOK);
 
 	$postarray['uri'] = "fb::".$post->post_id;
@@ -252,7 +283,19 @@ function fbsync_createpost($a, $uid, $self, $contacts, $applications, $post, $cr
 	}
 
 	if ($contact_id <= 0) {
-		$contact_id = fbsync_fetch_contact($uid, $contacts[$post->source_id], $create_user);
+		if ($post->actor_id != $post->source_id) {
+			// Testing if we know the source or the actor
+			$contact_id = fbsync_fetch_contact($uid, $contacts[$post->source_id], false);
+
+			if (($contact_id == 0) and array_key_exists($post->actor_id, $contacts))
+				$contact_id = fbsync_fetch_contact($uid, $contacts[$post->actor_id], false);
+
+			// If we don't know anyone, we guess we should know the source. Could be the wrong decision
+			if ($contact_id == 0)
+				$contact_id = fbsync_fetch_contact($uid, $contacts[$post->source_id], $create_user);
+		} else
+			$contact_id = fbsync_fetch_contact($uid, $contacts[$post->source_id], $create_user);
+
 
 		if ($contact_id == -1) {
 			logger('fbsync_createpost: Contact is blocked. Post not imported '.print_r($post, true), LOGGER_DEBUG);
@@ -276,73 +319,115 @@ function fbsync_createpost($a, $uid, $self, $contacts, $applications, $post, $cr
 	$postarray["body"] = $msgdata["body"];
 	$postarray["tag"] = $msgdata["tags"];
 
+	// Change the object type when an attachment is present
+	if (isset($post->attachment->fb_object_type))
+		logger('fb_object_type: '.$post->attachment->fb_object_type." ".print_r($post->attachment, true), LOGGER_DEBUG);
+		switch ($post->attachment->fb_object_type) {
+			case 'photo':
+				$postarray['object-type'] = ACTIVITY_OBJ_IMAGE; // photo is deprecated: http://activitystrea.ms/head/activity-schema.html#image
+				break;
+			case 'video':
+				$postarray['object-type'] = ACTIVITY_OBJ_VIDEO;
+				break;
+			case '':
+				//$postarray['object-type'] = ACTIVITY_OBJ_BOOKMARK;
+				break;
+			default:
+				logger('Unknown object type '.$post->attachment->fb_object_type, LOGGER_DEBUG);
+				break;
+		}
+
+	$pagedata = array();
 	$content = "";
-	$type = "";
+	$pagedata["type"] = "";
 
 	if (isset($post->attachment->name) and isset($post->attachment->href)) {
+		$post->attachment->href = original_url($post->attachment->href);
 		$oembed_data = oembed_fetch_url($post->attachment->href);
-		$type = $oembed_data->type;
-		if ($type == "rich")
-			$type = "link";
+		$pagedata["type"] = $oembed_data->type;
+		if ($pagedata["type"] == "rich")
+			$pagedata["type"] = "link";
 
+		$pagedata["url"] = $post->attachment->href;
+		$pagedata["title"] = $post->attachment->name;
 		$content = "[bookmark=".$post->attachment->href."]".$post->attachment->name."[/bookmark]";
+
+		// If a link is not only attached but also added in the body, look if it can be removed in the body.
+		$removedlink = trim(str_replace($post->attachment->href, "", $postarray["body"]));
+
+		if (($removedlink == "") OR strstr($postarray["body"], $removedlink))
+			$postarray["body"] = $removedlink;
+
 	} elseif (isset($post->attachment->name) AND ($post->attachment->name != ""))
 		$content = "[b]" . $post->attachment->name."[/b]";
 
-	$quote = "";
-	if(isset($post->attachment->description) and ($post->attachment->fb_object_type != "photo"))
-		$quote = $post->attachment->description;
+	$pagedata["text"] = "";
+	if (isset($post->attachment->description) and ($post->attachment->fb_object_type != "photo"))
+		$pagedata["text"] = $post->attachment->description;
 
-	if(isset($post->attachment->caption) and ($post->attachment->fb_object_type == "photo"))
-		$quote = $post->attachment->caption;
+	if (isset($post->attachment->caption) and ($post->attachment->fb_object_type == "photo"))
+		$pagedata["text"] = $post->attachment->caption;
 
-	if ($quote.$post->attachment->href.$content.$postarray["body"] == "")
+	if ($pagedata["text"].$post->attachment->href.$content.$postarray["body"] == "")
 		return;
 
-	if (isset($post->attachment->media) // AND !strstr($post->attachment->href, "://www.youtube.com/")
-		//AND !strstr($post->attachment->href, "://youtu.be/")
-		//AND !strstr($post->attachment->href, ".vimeo.com/"))
-		AND (($type == "") OR ($type == "link"))) {
+	if (isset($post->attachment->media) AND (($pagedata["type"] == "") OR ($pagedata["type"] == "link"))) {
 		foreach ($post->attachment->media AS $media) {
-			//$media->photo->owner = number_format($media->photo->owner, 0, '', '');
-			//if ($media->photo->owner != '') {
-			//	$postarray['author-name'] = $contacts[$media->photo->owner]->name;
-			//	$postarray['author-link'] = $contacts[$media->photo->owner]->url;
-			//	$postarray['author-avatar'] = $contacts[$media->photo->owner]->pic_square;
-			//}
 
 			if (isset($media->type))
-				$type = $media->type;
+				$pagedata["type"] = $media->type;
+
+			if (isset($media->src))
+				$pagedata["images"][0]["src"] = $media->src;
+
+			if (isset($media->photo)) {
+				if (isset($media->photo->images) AND (count($media->photo->images) > 1))
+					$pagedata["images"][0]["src"] = $media->photo->images[1]->src;
+
+				if (isset($media->photo->fbid)) {
+					logger('fbsync_createpost: fetching fbid '.$media->photo->fbid, LOGGER_DEBUG);
+					$url = "https://graph.facebook.com/".$media->photo->fbid."?access_token=".$access_token;
+					$feed = fetch_url($url);
+					$data = json_decode($feed);
+					if (isset($data->images)) {
+						$pagedata["images"][0]["src"] = $data->images[0]->source;
+						logger('fbsync_createpost: got fbid '.$media->photo->fbid.' image '.$pagedata["images"][0]["src"], LOGGER_DEBUG);
+					} else
+						logger('fbsync_createpost: error fetching fbid '.$media->photo->fbid.' '.print_r($data, true), LOGGER_DEBUG);
+				}
+			}
+
+			$pagedata["images"][0]["src"] = fbpost_cleanpicture($pagedata["images"][0]["src"]);
 
-			if(isset($media->src) && isset($media->href) AND ($media->src != "") AND ($media->href != ""))
-				$content .= "\n".'[url='.$media->href.'][img]'.fpost_cleanpicture($media->src).'[/img][/url]';
-			else {
-				if (isset($media->src) AND ($media->src != ""))
-					$content .= "\n".'[img]'.fpost_cleanpicture($media->src).'[/img]';
+			if (isset($media->href) AND ($pagedata["images"][0]["src"] != "") AND ($media->href != "")) {
+				$media->href = original_url($media->href);
+				$pagedata["url"] = $media->href;
+				$content .= "\n".'[url='.$media->href.'][img]'.$pagedata["images"][0]["src"].'[/img][/url]';
+			} else {
+				if ($pagedata["images"][0]["src"] != "")
+					$content .= "\n".'[img]'.$pagedata["images"][0]["src"].'[/img]';
 
 				// if just a link, it may be a wall photo - check
-				if(isset($post->link))
+				if (isset($post->link))
 					$content .= fbpost_get_photo($media->href);
 			}
 		}
 	}
 
-	if ($content)
-		$postarray["body"] .= "\n";
+	if ($pagedata["type"] != "") {
+		if ($pagedata["type"] == "link")
+			$postarray["object-type"] = ACTIVITY_OBJ_BOOKMARK;
 
-	if ($type)
-		$postarray["body"] .= "[class=type-".$type."]";
-
-	if ($content)
-		$postarray["body"] .= trim($content);
-
-	if ($quote)
-		$postarray["body"] .= "\n[quote]".trim($quote)."[/quote]";
+		$postarray["body"] .= add_page_info_data($pagedata);
+	} else {
+		if ($content)
+			$postarray["body"] .= "\n".trim($content);
 
-	if ($type)
-		$postarray["body"] .= "[/class]";
+		if ($pagedata["text"])
+			$postarray["body"] .= "\n[quote]".trim($pagedata["text"])."[/quote]";
 
-	$postarray["body"] = trim($postarray["body"]);
+		$postarray["body"] = trim($postarray["body"]);
+	}
 
 	if (trim($postarray["body"]) == "")
 		return;
@@ -452,6 +537,7 @@ function fbsync_createcomment($a, $uid, $self_id, $self, $user, $contacts, $appl
 	$postarray['wall'] = 0;
 
 	$postarray['verb'] = ACTIVITY_POST;
+	$postarray['object-type'] = ACTIVITY_OBJ_COMMENT;
 	$postarray['network'] =  dbesc(NETWORK_FACEBOOK);
 
 	$postarray['uri'] = "fb::".$comment->id;
@@ -551,7 +637,7 @@ function fbsync_createcomment($a, $uid, $self_id, $self, $user, $contacts, $appl
 					'to_email'     => $user[0]['email'],
 					'uid'          => $user[0]['uid'],
 					'item'         => $postarray,
-					'link'             => $a->get_baseurl() . '/display/' . $user[0]['nickname'] . '/' . $item,
+					'link'         => $a->get_baseurl().'/display/'.urlencode(get_item_guid($item)),
 					'source_name'  => $postarray['author-name'],
 					'source_link'  => $postarray['author-link'],
 					'source_photo' => $postarray['author-avatar'],
@@ -603,8 +689,11 @@ function fbsync_createlike($a, $uid, $self_id, $self, $contacts, $like) {
 
 	$likedata = array();
 	$likedata['parent'] = $orig_post['id'];
+
 	$likedata['verb'] = ACTIVITY_LIKE;
+	$likedata['object-type'] = ACTIVITY_OBJ_NOTE;
 	$likedate['network'] =  dbesc(NETWORK_FACEBOOK);
+
 	$likedata['gravity'] = 3;
 	$likedata['uid'] = $uid;
 	$likedata['wall'] = 0;
@@ -654,6 +743,9 @@ function fbsync_createlike($a, $uid, $self_id, $self, $contacts, $like) {
 
 function fbsync_fetch_contact($uid, $contact, $create_user) {
 
+	if($contact->url == "")
+		return(0);
+
 	// Check if the unique contact is existing
 	// To-Do: only update once a while
 	$r = q("SELECT id FROM unique_contacts WHERE url='%s' LIMIT 1",
@@ -1018,7 +1110,6 @@ function fbsync_fetchfeed($a, $uid) {
 	foreach ($post_data AS $post) {
 		if ($post->updated_time > $last_updated)
 			$last_updated = $post->updated_time;
-
 		fbsync_createpost($a, $uid, $self, $contacts, $application_data, $post, $create_user);
 	}