X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=twitter%2Ftwitter.php;h=e5b058cc8166025d07839dedc99610dae039cab7;hb=91757d72d870ef57ab325d8c45b6730e1251e49f;hp=d7a5eec50b0cd5c21d8c917e4720e7667b765286;hpb=e98c299cd2b3f2f855c31c8fca4fd5659f53cced;p=friendica-addons.git diff --git a/twitter/twitter.php b/twitter/twitter.php index d7a5eec5..e5b058cc 100644 --- a/twitter/twitter.php +++ b/twitter/twitter.php @@ -1,7 +1,7 @@ * Author: Michael Vogel @@ -60,6 +60,8 @@ * Requirements: PHP5, curl [Slinky library] */ +require_once('include/enotify.php'); + define('TWITTER_DEFAULT_POLL_INTERVAL', 5); // given in minutes function twitter_install() { @@ -74,6 +76,7 @@ function twitter_install() { register_hook('follow', 'addon/twitter/twitter.php', 'twitter_follow'); register_hook('expire', 'addon/twitter/twitter.php', 'twitter_expire'); register_hook('prepare_body', 'addon/twitter/twitter.php', 'twitter_prepare_body'); + register_hook('check_item_notification','addon/twitter/twitter.php', 'twitter_check_item_notification'); logger("installed twitter"); } @@ -89,6 +92,7 @@ function twitter_uninstall() { unregister_hook('follow', 'addon/twitter/twitter.php', 'twitter_follow'); unregister_hook('expire', 'addon/twitter/twitter.php', 'twitter_expire'); unregister_hook('prepare_body', 'addon/twitter/twitter.php', 'twitter_prepare_body'); + unregister_hook('check_item_notification','addon/twitter/twitter.php', 'twitter_check_item_notification'); // old setting - remove only unregister_hook('post_local_end', 'addon/twitter/twitter.php', 'twitter_post_hook'); @@ -97,6 +101,18 @@ function twitter_uninstall() { } +function twitter_check_item_notification($a, &$notification_data) { + $own_id = get_pconfig($notification_data["uid"], 'twitter', 'own_id'); + + $own_user = q("SELECT `url` FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1", + intval($notification_data["uid"]), + dbesc("twitter::".$own_id) + ); + + if ($own_user) + $notification_data["profiles"][] = $own_user[0]["url"]; +} + function twitter_follow($a, &$contact) { logger("twitter_follow: Check if contact is twitter contact. ".$contact["url"], LOGGER_DEBUG); @@ -359,7 +375,7 @@ function twitter_action($a, $uid, $pid, $action) { switch ($action) { case "delete": - $result = $cb->statuses_destroy($post); + // To-Do: $result = $cb->statuses_destroy($post); break; case "like": $result = $cb->favorites_create($post); @@ -475,7 +491,7 @@ function twitter_post_hook(&$a,&$b) { $image = ""; - if (isset($msgarr["url"])) + if (isset($msgarr["url"]) AND ($msgarr["type"] != "photo")) $msg .= "\n".$msgarr["url"]; elseif (isset($msgarr["image"]) AND ($msgarr["type"] != "video")) $image = $msgarr["image"]; @@ -707,7 +723,7 @@ function twitter_prepare_body(&$a,&$b) { $msgarr = plaintext($a, $item, $max_char, true, 8); $msg = $msgarr["text"]; - if (isset($msgarr["url"])) + if (isset($msgarr["url"]) AND ($msgarr["type"] != "photo")) $msg .= " ".$msgarr["url"]; if (isset($msgarr["image"])) @@ -925,41 +941,55 @@ function twitter_queue_hook(&$a,&$b) { } } -function twitter_fetch_contact($uid, $contact, $create_user) { +function twitter_fix_avatar($avatar) { require_once("include/Photo.php"); - if ($contact->id_str == "") - return(-1); - - $avatar = str_replace("_normal.", ".", $contact->profile_image_url_https); + $new_avatar = str_replace("_normal.", ".", $avatar); - $info = get_photo_info($avatar); + $info = get_photo_info($new_avatar); if (!$info) - $avatar = $contact->profile_image_url_https; + $new_avatar = $avatar; - // 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", - dbesc(normalise_link("https://twitter.com/".$contact->screen_name))); + return $new_avatar; +} - if (count($r) == 0) - q("INSERT INTO unique_contacts (url, name, nick, avatar) VALUES ('%s', '%s', '%s', '%s')", - dbesc(normalise_link("https://twitter.com/".$contact->screen_name)), - dbesc($contact->name), - dbesc($contact->screen_name), - dbesc($avatar)); - else - q("UPDATE unique_contacts SET name = '%s', nick = '%s', avatar = '%s' WHERE url = '%s'", - dbesc($contact->name), - dbesc($contact->screen_name), - dbesc($avatar), - dbesc(normalise_link("https://twitter.com/".$contact->screen_name))); +function twitter_fetch_contact($uid, $contact, $create_user) { + + if ($contact->id_str == "") + return(-1); + + $avatar = twitter_fix_avatar($contact->profile_image_url_https); + + if (function_exists("update_gcontact")) + update_gcontact(array("url" => "https://twitter.com/".$contact->screen_name, + "network" => NETWORK_TWITTER, "photo" => $avatar, "hide" => true, + "name" => $contact->name, "nick" => $contact->screen_name, + "location" => $contact->location, "about" => $contact->description, + "addr" => $contact->screen_name."@twitter.com", "generation" => 2)); + else { + // Old Code + $r = q("SELECT id FROM unique_contacts WHERE url='%s' LIMIT 1", + dbesc(normalise_link("https://twitter.com/".$contact->screen_name))); + + if (count($r) == 0) + q("INSERT INTO unique_contacts (url, name, nick, avatar) VALUES ('%s', '%s', '%s', '%s')", + dbesc(normalise_link("https://twitter.com/".$contact->screen_name)), + dbesc($contact->name), + dbesc($contact->screen_name), + dbesc($avatar)); + else + q("UPDATE unique_contacts SET name = '%s', nick = '%s', avatar = '%s' WHERE url = '%s'", + dbesc($contact->name), + dbesc($contact->screen_name), + dbesc($avatar), + dbesc(normalise_link("https://twitter.com/".$contact->screen_name))); - if (DB_UPDATE_VERSION >= "1177") - q("UPDATE `unique_contacts` SET `location` = '%s', `about` = '%s' WHERE url = '%s'", - dbesc($contact->location), - dbesc($contact->description), - dbesc(normalise_link("https://twitter.com/".$contact->screen_name))); + if (DB_UPDATE_VERSION >= "1177") + q("UPDATE `unique_contacts` SET `location` = '%s', `about` = '%s' WHERE url = '%s'", + dbesc($contact->location), + dbesc($contact->description), + dbesc(normalise_link("https://twitter.com/".$contact->screen_name))); + } $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1", intval($uid), dbesc("twitter::".$contact->id_str)); @@ -1220,6 +1250,8 @@ function twitter_expand_entities($a, $body, $item, $no_tags = false, $picture) { if (($footer == "") AND ($picture != "")) $body .= "\n\n[img]".$picture."[/img]\n"; + elseif (($footer == "") AND ($picture == "")) + $body = add_page_info_to_body($body); if ($no_tags) return(array("body" => $body, "tags" => "")); @@ -1360,7 +1392,7 @@ function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing $postarray['owner-name'] = $post->user->name; $postarray['owner-link'] = "https://twitter.com/".$post->user->screen_name; - $postarray['owner-avatar'] = $post->user->profile_image_url_https; + $postarray['owner-avatar'] = twitter_fix_avatar($post->user->profile_image_url_https); } if(($contactid == 0) AND !$only_existing_contact) @@ -1464,7 +1496,7 @@ function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing // Let retweets look like wall-to-wall posts $postarray['author-name'] = $post->retweeted_status->user->name; $postarray['author-link'] = "https://twitter.com/".$post->retweeted_status->user->screen_name; - $postarray['author-avatar'] = $post->retweeted_status->user->profile_image_url_https; + $postarray['author-avatar'] = twitter_fix_avatar($post->retweeted_status->user->profile_image_url_https); //if (($post->retweeted_status->user->screen_name != "") AND ($post->retweeted_status->id_str != "")) { // $postarray['plink'] = "https://twitter.com/".$post->retweeted_status->user->screen_name."/status/".$post->retweeted_status->id_str; // $postarray['uri'] = "twitter::".$post->retweeted_status->id_str; @@ -1542,15 +1574,69 @@ function twitter_checknotification($a, $uid, $own_id, $top_item, $postarray) { } } +function twitter_fetchparentposts($a, $uid, $post, $connection, $self, $own_id) { + logger("twitter_fetchparentposts: Fetching for user ".$uid." and post ".$post->id_str, LOGGER_DEBUG); + + $posts = array(); + + while ($post->in_reply_to_status_id_str != "") { + $parameters = array("trim_user" => false, "id" => $post->in_reply_to_status_id_str); + + $post = $connection->get('statuses/show', $parameters); + + if (!count($post)) { + logger("twitter_fetchparentposts: Can't fetch post ".$parameters->id, LOGGER_DEBUG); + break; + } + + $r = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1", + dbesc("twitter::".$post->id_str), + intval($uid) + ); + + if (count($r)) + break; + + $posts[] = $post; + } + + logger("twitter_fetchparentposts: Fetching ".count($posts)." parents", LOGGER_DEBUG); + + $posts = array_reverse($posts); + + if (count($posts)) { + foreach ($posts as $post) { + $postarray = twitter_createpost($a, $uid, $post, $self, false, false); + + if (trim($postarray['body']) == "") + continue; + + $item = item_store($postarray); + $postarray["id"] = $item; + + logger('twitter_fetchparentpost: User '.$self["nick"].' posted parent timeline item '.$item); + + if ($item AND !function_exists("check_item_notification")) + twitter_checknotification($a, $uid, $own_id, $item, $postarray); + } + } +} + function twitter_fetchhometimeline($a, $uid) { $ckey = get_config('twitter', 'consumerkey'); $csecret = get_config('twitter', 'consumersecret'); $otoken = get_pconfig($uid, 'twitter', 'oauthtoken'); $osecret = get_pconfig($uid, 'twitter', 'oauthsecret'); $create_user = get_pconfig($uid, 'twitter', 'create_user'); + $mirror_posts = get_pconfig($uid, 'twitter', 'mirror_posts'); logger("twitter_fetchhometimeline: Fetching for user ".$uid, LOGGER_DEBUG); + $application_name = get_config('twitter', 'application_name'); + + if ($application_name == "") + $application_name = $a->get_hostname(); + require_once('library/twitteroauth.php'); require_once('include/items.php'); @@ -1617,16 +1703,30 @@ function twitter_fetchhometimeline($a, $uid) { if ($first_time) continue; + if (stristr($post->source, $application_name) && $post->user->screen_name == $own_id) { + logger("twitter_fetchhometimeline: Skip previously sended post", LOGGER_DEBUG); + continue; + } + + if ($mirror_posts && $post->user->screen_name == $own_id && $post->in_reply_to_status_id_str == "") { + logger("twitter_fetchhometimeline: Skip post that will be mirrored", LOGGER_DEBUG); + continue; + } + + if ($post->in_reply_to_status_id_str != "") + twitter_fetchparentposts($a, $uid, $post, $connection, $self, $own_id); + $postarray = twitter_createpost($a, $uid, $post, $self, $create_user, true); if (trim($postarray['body']) == "") continue; $item = item_store($postarray); + $postarray["id"] = $item; logger('twitter_fetchhometimeline: User '.$self["nick"].' posted home timeline item '.$item); - if ($item != 0) + if ($item AND !function_exists("check_item_notification")) twitter_checknotification($a, $uid, $own_id, $item, $postarray); } @@ -1660,12 +1760,19 @@ function twitter_fetchhometimeline($a, $uid) { if ($first_time) continue; + if ($post->in_reply_to_status_id_str != "") + twitter_fetchparentposts($a, $uid, $post, $connection, $self, $own_id); + $postarray = twitter_createpost($a, $uid, $post, $self, false, false); if (trim($postarray['body']) == "") continue; $item = item_store($postarray); + $postarray["id"] = $item; + + if ($item AND function_exists("check_item_notification")) + check_item_notification($item, $uid, NOTIFY_TAGSELF); if (!isset($postarray["parent"]) OR ($postarray["parent"] == 0)) $postarray["parent"] = $item; @@ -1684,7 +1791,7 @@ function twitter_fetchhometimeline($a, $uid) { } else $parent_id = $postarray['parent']; - if ($item != 0) { + if (($item != 0) AND !function_exists("check_item_notification")) { require_once('include/enotify.php'); notification(array( 'type' => NOTIFY_TAGSELF,