X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=twitter%2Ftwitter.php;h=380121c2e2a40bc0d820e2417021b077a3bfda33;hb=9e9916a8d5518860fda327de2d2e87d878efc0d2;hp=8a80f471baf30749b48443827004d13467946cb8;hpb=a000f735f2666a2697594f481ba6514c1bd90e4e;p=friendica-addons.git diff --git a/twitter/twitter.php b/twitter/twitter.php old mode 100755 new mode 100644 index 8a80f471..380121c2 --- a/twitter/twitter.php +++ b/twitter/twitter.php @@ -64,7 +64,7 @@ define('TWITTER_DEFAULT_POLL_INTERVAL', 5); // given in minutes function twitter_install() { // we need some hooks, for the configuration and for sending tweets - register_hook('connector_settings', 'addon/twitter/twitter.php', 'twitter_settings'); + register_hook('connector_settings', 'addon/twitter/twitter.php', 'twitter_settings'); register_hook('connector_settings_post', 'addon/twitter/twitter.php', 'twitter_settings_post'); register_hook('post_local', 'addon/twitter/twitter.php', 'twitter_post_local'); register_hook('notifier_normal', 'addon/twitter/twitter.php', 'twitter_post_hook'); @@ -72,12 +72,14 @@ function twitter_install() { register_hook('cron', 'addon/twitter/twitter.php', 'twitter_cron'); register_hook('queue_predeliver', 'addon/twitter/twitter.php', 'twitter_queue_hook'); 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'); logger("installed twitter"); } function twitter_uninstall() { - unregister_hook('connector_settings', 'addon/twitter/twitter.php', 'twitter_settings'); + unregister_hook('connector_settings', 'addon/twitter/twitter.php', 'twitter_settings'); unregister_hook('connector_settings_post', 'addon/twitter/twitter.php', 'twitter_settings_post'); unregister_hook('post_local', 'addon/twitter/twitter.php', 'twitter_post_local'); unregister_hook('notifier_normal', 'addon/twitter/twitter.php', 'twitter_post_hook'); @@ -85,10 +87,12 @@ function twitter_uninstall() { unregister_hook('cron', 'addon/twitter/twitter.php', 'twitter_cron'); unregister_hook('queue_predeliver', 'addon/twitter/twitter.php', 'twitter_queue_hook'); 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'); // old setting - remove only unregister_hook('post_local_end', 'addon/twitter/twitter.php', 'twitter_post_hook'); - unregister_hook('plugin_settings', 'addon/twitter/twitter.php', 'twitter_settings'); + unregister_hook('plugin_settings', 'addon/twitter/twitter.php', 'twitter_settings'); unregister_hook('plugin_settings_post', 'addon/twitter/twitter.php', 'twitter_settings_post'); } @@ -159,10 +163,10 @@ function twitter_settings_post ($a,$post) { */ del_pconfig(local_user(), 'twitter', 'consumerkey'); del_pconfig(local_user(), 'twitter', 'consumersecret'); - del_pconfig(local_user(), 'twitter', 'oauthtoken'); - del_pconfig(local_user(), 'twitter', 'oauthsecret'); - del_pconfig(local_user(), 'twitter', 'post'); - del_pconfig(local_user(), 'twitter', 'post_by_default'); + del_pconfig(local_user(), 'twitter', 'oauthtoken'); + del_pconfig(local_user(), 'twitter', 'oauthsecret'); + del_pconfig(local_user(), 'twitter', 'post'); + del_pconfig(local_user(), 'twitter', 'post_by_default'); del_pconfig(local_user(), 'twitter', 'lastid'); del_pconfig(local_user(), 'twitter', 'mirror_posts'); del_pconfig(local_user(), 'twitter', 'import'); @@ -181,30 +185,30 @@ function twitter_settings_post ($a,$post) { $connection = new TwitterOAuth($ckey, $csecret, $_POST['twitter-token'], $_POST['twitter-token2']); $token = $connection->getAccessToken( $_POST['twitter-pin'] ); // ok, now that we have the Access Token, save them in the user config - set_pconfig(local_user(),'twitter', 'oauthtoken', $token['oauth_token']); + set_pconfig(local_user(),'twitter', 'oauthtoken', $token['oauth_token']); set_pconfig(local_user(),'twitter', 'oauthsecret', $token['oauth_token_secret']); - set_pconfig(local_user(),'twitter', 'post', 1); - // reload the Addon Settings page, if we don't do it see Bug #42 - goaway($a->get_baseurl().'/settings/connectors'); + set_pconfig(local_user(),'twitter', 'post', 1); + // reload the Addon Settings page, if we don't do it see Bug #42 + goaway($a->get_baseurl().'/settings/connectors'); } else { // if no PIN is supplied in the POST variables, the user has changed the setting // to post a tweet for every new __public__ posting to the wall set_pconfig(local_user(),'twitter','post',intval($_POST['twitter-enable'])); - set_pconfig(local_user(),'twitter','post_by_default',intval($_POST['twitter-default'])); + set_pconfig(local_user(),'twitter','post_by_default',intval($_POST['twitter-default'])); set_pconfig(local_user(), 'twitter', 'mirror_posts', intval($_POST['twitter-mirror'])); set_pconfig(local_user(), 'twitter', 'import', intval($_POST['twitter-import'])); set_pconfig(local_user(), 'twitter', 'create_user', intval($_POST['twitter-create_user'])); - if (!intval($_POST['twitter-mirror'])) - del_pconfig(local_user(),'twitter','lastid'); + if (!intval($_POST['twitter-mirror'])) + del_pconfig(local_user(),'twitter','lastid'); - info(t('Twitter settings updated.') . EOL); + info(t('Twitter settings updated.') . EOL); }} } function twitter_settings(&$a,&$s) { - if(! local_user()) - return; - $a->page['htmlhead'] .= '' . "\r\n"; + if(! local_user()) + return; + $a->page['htmlhead'] .= '' . "\r\n"; /*** * 1) Check that we have global consumer key & secret * 2) If no OAuthtoken & stuff is present, generate button to get some @@ -214,16 +218,16 @@ function twitter_settings(&$a,&$s) { $csecret = get_config('twitter', 'consumersecret' ); $otoken = get_pconfig(local_user(), 'twitter', 'oauthtoken' ); $osecret = get_pconfig(local_user(), 'twitter', 'oauthsecret' ); - $enabled = get_pconfig(local_user(), 'twitter', 'post'); + $enabled = get_pconfig(local_user(), 'twitter', 'post'); $checked = (($enabled) ? ' checked="checked" ' : ''); - $defenabled = get_pconfig(local_user(),'twitter','post_by_default'); + $defenabled = get_pconfig(local_user(),'twitter','post_by_default'); $defchecked = (($defenabled) ? ' checked="checked" ' : ''); - $mirrorenabled = get_pconfig(local_user(),'twitter','mirror_posts'); - $mirrorchecked = (($mirrorenabled) ? ' checked="checked" ' : ''); - $importenabled = get_pconfig(local_user(),'twitter','import'); - $importchecked = (($importenabled) ? ' checked="checked" ' : ''); - $create_userenabled = get_pconfig(local_user(),'twitter','create_user'); - $create_userchecked = (($create_userenabled) ? ' checked="checked" ' : ''); + $mirrorenabled = get_pconfig(local_user(),'twitter','mirror_posts'); + $mirrorchecked = (($mirrorenabled) ? ' checked="checked" ' : ''); + $importenabled = get_pconfig(local_user(),'twitter','import'); + $importchecked = (($importenabled) ? ' checked="checked" ' : ''); + $create_userenabled = get_pconfig(local_user(),'twitter','create_user'); + $create_userchecked = (($create_userenabled) ? ' checked="checked" ' : ''); $css = (($enabled) ? '' : '-disabled'); @@ -252,7 +256,7 @@ function twitter_settings(&$a,&$s) { * which the user can request a PIN to connect the account to a * account at Twitter. */ - require_once('library/twitteroauth.php'); + require_once('library/twitteroauth.php'); $connection = new TwitterOAuth($ckey, $csecret); $request_token = $connection->getRequestToken(); $token = $request_token['oauth_token']; @@ -266,50 +270,50 @@ function twitter_settings(&$a,&$s) { $s .= ''; $s .= ''; $s .= ''; - $s .= '
'; - $s .= '
'; + $s .= '
'; + $s .= '
'; } else { /*** * we have an OAuth key / secret pair for the user * so let's give a chance to disable the postings to Twitter */ - require_once('library/twitteroauth.php'); + require_once('library/twitteroauth.php'); $connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret); $details = $connection->get('account/verify_credentials'); $s .= '

'. t('Currently connected to: ') .''.$details->screen_name.'
'.$details->description.'

'; $s .= '

'. t('If enabled all your public postings can be posted to the associated Twitter account. You can choose to do so by default (here) or for every posting separately in the posting options when writing the entry.') .'

'; - if ($a->user['hidewall']) { - $s .= '

'. t('Note: Due your privacy settings (Hide your profile details from unknown viewers?) the link potentially included in public postings relayed to Twitter will lead the visitor to a blank page informing the visitor that the access to your profile has been restricted.') .'

'; - } + if ($a->user['hidewall']) { + $s .= '

'. t('Note: Due your privacy settings (Hide your profile details from unknown viewers?) the link potentially included in public postings relayed to Twitter will lead the visitor to a blank page informing the visitor that the access to your profile has been restricted.') .'

'; + } $s .= '
'; $s .= ''; $s .= ''; - $s .= '
'; - $s .= ''; - $s .= ''; + $s .= '
'; + $s .= ''; + $s .= ''; $s .= '
'; - $s .= ''; - $s .= ''; + $s .= ''; + $s .= ''; $s .= '
'; $s .= '
'; - $s .= ''; - $s .= ''; + $s .= ''; + $s .= ''; $s .= '
'; - $s .= ''; - $s .= ''; + $s .= ''; + $s .= ''; $s .= '
'; $s .= '
'; - $s .= ''; - $s .= ''; + $s .= ''; + $s .= ''; $s .= '
'; $s .= '
'; } } - $s .= '
'; + $s .= '
'; } @@ -327,12 +331,12 @@ function twitter_post_local(&$a,&$b) { if($_REQUEST['api_source'] && intval(get_pconfig(local_user(),'twitter','post_by_default'))) $twitter_enable = 1; - if(! $twitter_enable) - return; + if(! $twitter_enable) + return; - if(strlen($b['postopts'])) - $b['postopts'] .= ','; - $b['postopts'] .= 'twitter'; + if(strlen($b['postopts'])) + $b['postopts'] .= ','; + $b['postopts'] .= 'twitter'; } } @@ -383,29 +387,31 @@ function twitter_post_hook(&$a,&$b) { if($b['parent'] != $b['id']) { logger("twitter_post_hook: parameter ".print_r($b, true), LOGGER_DATA); - // Looking if its a reply to a twitter post + // Looking if its a reply to a twitter post if ((substr($b["parent-uri"], 0, 9) != "twitter::") AND (substr($b["extid"], 0, 9) != "twitter::") AND (substr($b["thr-parent"], 0, 9) != "twitter::")) { - logger("twitter_post_hook: no twitter post ".$b["parent"]); - return; + logger("twitter_post_hook: no twitter post ".$b["parent"]); + return; } - $r = q("SELECT * FROM item WHERE item.uri = '%s' AND item.uid = %d LIMIT 1", - dbesc($b["thr-parent"]), - intval($b["uid"])); + $r = q("SELECT * FROM item WHERE item.uri = '%s' AND item.uid = %d LIMIT 1", + dbesc($b["thr-parent"]), + intval($b["uid"])); + + if(!count($r)) { + logger("twitter_post_hook: no parent found ".$b["thr-parent"]); + return; + } else { + $iscomment = true; + $orig_post = $r[0]; + } - if(!count($r)) { - logger("twitter_post_hook: no parent found ".$b["thr-parent"]); - return; - } else { - $iscomment = true; - $orig_post = $r[0]; - } - $nickname = preg_replace("=https?://twitter.com/(.*)=ism", "$1", $orig_post["author-link"]); - $nickname = "@[url=".$orig_post["author-link"]."]".$nickname."[/url]"; + $nicknameplain = preg_replace("=https?://twitter.com/(.*)=ism", "$1", $orig_post["author-link"]); + $nickname = "@[url=".$orig_post["author-link"]."]".$nicknameplain."[/url]"; + $nicknameplain = "@".$nicknameplain; - logger("twitter_post_hook: comparing ".$nickname." with ".$b["body"], LOGGER_DEBUG); - if (strpos($b["body"], $nickname) === false) + logger("twitter_post_hook: comparing ".$nickname." and ".$nicknameplain." with ".$b["body"], LOGGER_DEBUG); + if ((strpos($b["body"], $nickname) === false) AND (strpos($b["body"], $nicknameplain) === false)) $b["body"] = $nickname." ".$b["body"]; logger("twitter_post_hook: parent found ".print_r($orig_post, true), LOGGER_DATA); @@ -426,12 +432,15 @@ function twitter_post_hook(&$a,&$b) { else twitter_action($a, $b["uid"], substr($b["thr-parent"], 9), "like"); return; - } + } if($b['deleted'] || ($b['created'] !== $b['edited'])) - return; + return; // if post comes from twitter don't send it back + if($b['extid'] == NETWORK_TWITTER) + return; + if($b['app'] == "Twitter") return; @@ -458,7 +467,7 @@ function twitter_post_hook(&$a,&$b) { $max_char = 140; require_once("include/plaintext.php"); - $msgarr = plaintext($a, $b, $max_char, true); + $msgarr = plaintext($a, $b, $max_char, true, 8); $msg = $msgarr["text"]; if (($msg == "") AND isset($msgarr["title"])) @@ -468,21 +477,21 @@ function twitter_post_hook(&$a,&$b) { if (isset($msgarr["url"])) $msg .= "\n".$msgarr["url"]; - elseif (isset($msgarr["image"])) + elseif (isset($msgarr["image"]) AND ($msgarr["type"] != "video")) $image = $msgarr["image"]; // and now tweet it :-) if(strlen($msg) and ($image != "")) { $img_str = fetch_url($image); - $tempfile = tempnam(get_config("system","temppath"), "cache"); + $tempfile = tempnam(get_temppath(), "cache"); file_put_contents($tempfile, $img_str); // Twitter had changed something so that the old library doesn't work anymore // so we are using a new library for twitter // To-Do: // Switching completely to this library with all functions - require_once("addon/twitter/codebird.php"); + require_once("addon/twitter/codebird.php"); $cb = \Codebird\Codebird::getInstance(); $cb->setConsumerKey($ckey, $csecret); @@ -552,7 +561,7 @@ function twitter_post_hook(&$a,&$b) { function twitter_plugin_admin_post(&$a){ $consumerkey = ((x($_POST,'consumerkey')) ? notags(trim($_POST['consumerkey'])) : ''); $consumersecret = ((x($_POST,'consumersecret')) ? notags(trim($_POST['consumersecret'])): ''); - $applicationname = ((x($_POST, 'applicationname')) ? notags(trim($_POST['applicationname'])):''); + $applicationname = ((x($_POST, 'applicationname')) ? notags(trim($_POST['applicationname'])):''); set_config('twitter','consumerkey',$consumerkey); set_config('twitter','consumersecret',$consumersecret); set_config('twitter','application_name',$applicationname); @@ -565,8 +574,8 @@ function twitter_plugin_admin(&$a, &$o){ '$submit' => t('Save Settings'), // name, label, value, help, [extra values] '$consumerkey' => array('consumerkey', t('Consumer key'), get_config('twitter', 'consumerkey' ), ''), - '$consumersecret' => array('consumersecret', t('Consumer secret'), get_config('twitter', 'consumersecret' ), ''), - '$applicationname' => array('applicationname', t('Name of the Twitter Application'), get_config('twitter','application_name'),t('set this to avoid mirroring postings from ~friendica back to ~friendica')) + '$consumersecret' => array('consumersecret', t('Consumer secret'), get_config('twitter', 'consumersecret' ), ''), + '$applicationname' => array('applicationname', t('Name of the Twitter Application'), get_config('twitter','application_name'),t('set this to avoid mirroring postings from ~friendica back to ~friendica')) )); } @@ -603,27 +612,90 @@ function twitter_cron($a,$b) { /* // To-Do - // check for new contacts once a day - $last_contact_check = get_pconfig($rr['uid'],'pumpio','contact_check'); - if($last_contact_check) - $next_contact_check = $last_contact_check + 86400; - else - $next_contact_check = 0; - - if($next_contact_check <= time()) { - pumpio_getallusers($a, $rr["uid"]); - set_pconfig($rr['uid'],'pumpio','contact_check',time()); - } + // check for new contacts once a day + $last_contact_check = get_pconfig($rr['uid'],'pumpio','contact_check'); + if($last_contact_check) + $next_contact_check = $last_contact_check + 86400; + else + $next_contact_check = 0; + + if($next_contact_check <= time()) { + pumpio_getallusers($a, $rr["uid"]); + set_pconfig($rr['uid'],'pumpio','contact_check',time()); + } */ - } - } + } + } logger('twitter: cron_end'); set_config('twitter','last_poll', time()); } +function twitter_expire($a,$b) { + + $days = get_config('twitter', 'expire'); + + if ($days == 0) + return; + + $r = q("DELETE FROM `item` WHERE `deleted` AND `network` = '%s'", dbesc(NETWORK_TWITTER)); + + require_once("include/items.php"); + + logger('twitter_expire: expire_start'); + + $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'twitter' AND `k` = 'import' AND `v` = '1' ORDER BY RAND()"); + if(count($r)) { + foreach($r as $rr) { + logger('twitter_expire: user '.$rr['uid']); + item_expire($rr['uid'], $days, NETWORK_TWITTER, true); + } + } + + logger('twitter_expire: expire_end'); +} + +function twitter_prepare_body(&$a,&$b) { + if ($b["item"]["network"] != NETWORK_TWITTER) + return; + + if ($b["preview"]) { + $max_char = 140; + require_once("include/plaintext.php"); + $item = $b["item"]; + $item["plink"] = $a->get_baseurl()."/display/".$a->user["nickname"]."/".$item["parent"]; + + $r = q("SELECT `author-link` FROM item WHERE item.uri = '%s' AND item.uid = %d LIMIT 1", + dbesc($item["thr-parent"]), + intval(local_user())); + + if(count($r)) { + $orig_post = $r[0]; + + $nicknameplain = preg_replace("=https?://twitter.com/(.*)=ism", "$1", $orig_post["author-link"]); + $nickname = "@[url=".$orig_post["author-link"]."]".$nicknameplain."[/url]"; + $nicknameplain = "@".$nicknameplain; + + if ((strpos($item["body"], $nickname) === false) AND (strpos($item["body"], $nicknameplain) === false)) + $item["body"] = $nickname." ".$item["body"]; + } + + + $msgarr = plaintext($a, $item, $max_char, true, 8); + $msg = $msgarr["text"]; + + if (isset($msgarr["url"])) + $msg .= " ".$msgarr["url"]; + + if (isset($msgarr["image"])) + $msg .= " ".$msgarr["image"]; + + $b['html'] = nl2br(htmlspecialchars($msg)); + } +} + function twitter_fetchtimeline($a, $uid) { $ckey = get_config('twitter', 'consumerkey'); $csecret = get_config('twitter', 'consumersecret'); @@ -658,7 +730,7 @@ function twitter_fetchtimeline($a, $uid) { $posts = array_reverse($items); - if (count($posts)) { + if (count($posts)) { foreach ($posts as $post) { if ($post->id_str > $lastid) $lastid = $post->id_str; @@ -674,7 +746,9 @@ function twitter_fetchtimeline($a, $uid) { $_REQUEST["type"] = "wall"; $_REQUEST["api_source"] = true; $_REQUEST["profile_uid"] = $uid; - $_REQUEST["source"] = "Twitter"; + //$_REQUEST["source"] = "Twitter"; + $_REQUEST["source"] = $post->source; + $_REQUEST["extid"] = NETWORK_TWITTER; //$_REQUEST["date"] = $post->created_at; @@ -684,19 +758,23 @@ function twitter_fetchtimeline($a, $uid) { $_REQUEST['body'] = $post->retweeted_status->text; + $picture = ""; + // media if (is_array($post->retweeted_status->entities->media)) { foreach($post->retweeted_status->entities->media AS $media) { switch($media->type) { case 'photo': - $_REQUEST['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $_REQUEST['body']); - $has_picture = true; + //$_REQUEST['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $_REQUEST['body']); + //$has_picture = true; + $_REQUEST['body'] = str_replace($media->url, "", $_REQUEST['body']); + $picture = $media->media_url_https; break; } } } - $converted = twitter_expand_entities($a, $_REQUEST['body'], $post->retweeted_status, true, $has_picture); + $converted = twitter_expand_entities($a, $_REQUEST['body'], $post->retweeted_status, true, $picture); $_REQUEST['body'] = $converted["body"]; $_REQUEST['body'] = "[share author='".$post->retweeted_status->user->name. @@ -708,18 +786,22 @@ function twitter_fetchtimeline($a, $uid) { } else { $_REQUEST["body"] = $post->text; + $picture = ""; + if (is_array($post->entities->media)) { foreach($post->entities->media AS $media) { switch($media->type) { case 'photo': - $_REQUEST['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $_REQUEST['body']); - $has_picture = true; + //$_REQUEST['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $_REQUEST['body']); + //$has_picture = true; + $_REQUEST['body'] = str_replace($media->url, "", $_REQUEST['body']); + $picture = $media->media_url_https; break; } } } - $converted = twitter_expand_entities($a, $_REQUEST["body"], $post, true, $has_picture); + $converted = twitter_expand_entities($a, $_REQUEST["body"], $post, true, $picture); $_REQUEST['body'] = $converted["body"]; } @@ -741,8 +823,8 @@ function twitter_fetchtimeline($a, $uid) { // require_once('mod/item.php'); item_post($a); - } - } + } + } } set_pconfig($uid, 'twitter', 'lastid', $lastid); } @@ -813,10 +895,20 @@ function twitter_queue_hook(&$a,&$b) { } function twitter_fetch_contact($uid, $contact, $create_user) { + require_once("include/Photo.php"); + + if ($contact->id_str == "") + return(-1); + + $avatar = str_replace("_normal.", ".", $contact->profile_image_url_https); + + $info = get_photo_info($avatar); + if (!$info) + $avatar = $contact->profile_image_url_https; // 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", + $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) @@ -824,12 +916,12 @@ function twitter_fetch_contact($uid, $contact, $create_user) { dbesc(normalise_link("https://twitter.com/".$contact->screen_name)), dbesc($contact->name), dbesc($contact->screen_name), - dbesc($contact->profile_image_url_https)); + 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($contact->profile_image_url_https), + dbesc($avatar), dbesc(normalise_link("https://twitter.com/".$contact->screen_name))); $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1", @@ -859,7 +951,7 @@ function twitter_fetch_contact($uid, $contact, $create_user) { dbesc("twitter::".$contact->id_str), dbesc($contact->name), dbesc($contact->screen_name), - dbesc($contact->profile_image_url_https), + dbesc($avatar), dbesc(NETWORK_TWITTER), intval(CONTACT_IS_FRIEND), intval(1), @@ -887,7 +979,7 @@ function twitter_fetch_contact($uid, $contact, $create_user) { require_once("Photo.php"); - $photos = import_profile_photo($contact->profile_image_url_https,$uid,$contact_id); + $photos = import_profile_photo($avatar,$uid,$contact_id); q("UPDATE `contact` SET `photo` = '%s', `thumb` = '%s', @@ -919,7 +1011,7 @@ function twitter_fetch_contact($uid, $contact, $create_user) { require_once("Photo.php"); - $photos = import_profile_photo($contact->profile_image_url_https, $uid, $r[0]['id']); + $photos = import_profile_photo($avatar, $uid, $r[0]['id']); q("UPDATE `contact` SET `photo` = '%s', `thumb` = '%s', @@ -991,7 +1083,7 @@ function twitter_fetchuser($a, $uid, $screen_name = "", $user_id = "") { return $contact_id; } -function twitter_expand_entities($a, $body, $item, $no_tags = false, $dontincludemedia) { +function twitter_expand_entities($a, $body, $item, $no_tags = false, $picture) { require_once("include/oembed.php"); require_once("include/network.php"); @@ -1026,11 +1118,12 @@ function twitter_expand_entities($a, $body, $item, $no_tags = false, $dontinclud $footerlink = "[url=".$expanded_url."]".$expanded_url."[/url]"; $body = str_replace($url->url, $footerlink, $body); - } elseif (($oembed_data->type == "photo") AND isset($oembed_data->url) AND !$dontincludemedia) { + //} elseif (($oembed_data->type == "photo") AND isset($oembed_data->url) AND !$dontincludemedia) { + } elseif (($oembed_data->type == "photo") AND isset($oembed_data->url)) { $body = str_replace($url->url, "[url=".$expanded_url."][img]".$oembed_data->url."[/img][/url]", $body); - $dontincludemedia = true; + //$dontincludemedia = true; } elseif ($oembed_data->type != "link") $body = str_replace($url->url, "[url=".$expanded_url."]".$expanded_url."[/url]", @@ -1038,7 +1131,7 @@ function twitter_expand_entities($a, $body, $item, $no_tags = false, $dontinclud else { $img_str = fetch_url($expanded_url, true, $redirects, 4); - $tempfile = tempnam(get_config("system","temppath"), "cache"); + $tempfile = tempnam(get_temppath(), "cache"); file_put_contents($tempfile, $img_str); $mime = image_type_to_mime_type(exif_imagetype($tempfile)); unlink($tempfile); @@ -1046,7 +1139,7 @@ function twitter_expand_entities($a, $body, $item, $no_tags = false, $dontinclud if (substr($mime, 0, 6) == "image/") { $type = "photo"; $body = str_replace($url->url, "[img]".$expanded_url."[/img]", $body); - $dontincludemedia = true; + //$dontincludemedia = true; } else { $type = $oembed_data->type; $footerurl = $expanded_url; @@ -1059,17 +1152,20 @@ function twitter_expand_entities($a, $body, $item, $no_tags = false, $dontinclud } if ($footerurl != "") - $footer = add_page_info($footerurl); + $footer = add_page_info($footerurl, false, $picture); if (($footerlink != "") AND (trim($footer) != "")) { $removedlink = trim(str_replace($footerlink, "", $body)); - if (strstr($body, $removedlink)) + if (($removedlink == "") OR strstr($body, $removedlink)) $body = $removedlink; $body .= $footer; } + if (($footer == "") AND ($picture != "")) + $body .= "\n\n[img]".$picture."[/img]\n"; + if ($no_tags) return(array("body" => $body, "tags" => "")); @@ -1088,16 +1184,16 @@ function twitter_expand_entities($a, $body, $item, $no_tags = false, $dontinclud } // it seems as if the entities aren't always covering all mentions. So the rest will be checked here - $tags = get_tags($body); + $tags = get_tags($body); - if(count($tags)) { + if(count($tags)) { foreach($tags as $tag) { if (strstr(trim($tag), " ")) continue; - if(strpos($tag,'#') === 0) { - if(strpos($tag,'[url=')) - continue; + if(strpos($tag,'#') === 0) { + if(strpos($tag,'[url=')) + continue; // don't link tags that are already embedded in links @@ -1112,8 +1208,8 @@ function twitter_expand_entities($a, $body, $item, $no_tags = false, $dontinclud $tags_arr["#".$basetag] = $url; continue; } elseif(strpos($tag,'@') === 0) { - if(strpos($tag,'[url=')) - continue; + if(strpos($tag,'[url=')) + continue; $basetag = substr($tag,1); $url = '@[url=https://twitter.com/'.rawurlencode($basetag).']'.$basetag.'[/url]'; @@ -1162,6 +1258,8 @@ function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing if (count($r)) { $postarray['thr-parent'] = $r[0]["uri"]; $postarray['parent-uri'] = $r[0]["parent-uri"]; + $postarray['parent'] = $r[0]["parent"]; + $postarray['object-type'] = ACTIVITY_OBJ_COMMENT; } else { $r = q("SELECT * FROM `item` WHERE `extid` = '%s' AND `uid` = %d LIMIT 1", dbesc($parent), @@ -1170,9 +1268,12 @@ function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing if (count($r)) { $postarray['thr-parent'] = $r[0]['uri']; $postarray['parent-uri'] = $r[0]['parent-uri']; + $postarray['parent'] = $r[0]['parent']; + $postarray['object-type'] = ACTIVITY_OBJ_COMMENT; } else { $postarray['thr-parent'] = $postarray['uri']; $postarray['parent-uri'] = $postarray['uri']; + $postarray['object-type'] = ACTIVITY_OBJ_NOTE; } } @@ -1192,8 +1293,12 @@ function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing } else return(array()); } - } else + // Don't create accounts of people who just comment something + $create_user = false; + } else { $postarray['parent-uri'] = $postarray['uri']; + $postarray['object-type'] = ACTIVITY_OBJ_NOTE; + } if ($contactid == 0) { $contactid = twitter_fetch_contact($uid, $post->user, $create_user); @@ -1224,13 +1329,18 @@ function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing $postarray['body'] = $post->text; + $picture = ""; + // media if (is_array($post->entities->media)) { foreach($post->entities->media AS $media) { switch($media->type) { case 'photo': - $postarray['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $postarray['body']); - $has_picture = true; + //$postarray['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $postarray['body']); + //$has_picture = true; + $postarray['body'] = str_replace($media->url, "", $postarray['body']); + $postarray['object-type'] = ACTIVITY_OBJ_IMAGE; + $picture = $media->media_url_https; break; default: $postarray['body'] .= print_r($media, true); @@ -1238,7 +1348,7 @@ function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing } } - $converted = twitter_expand_entities($a, $postarray['body'], $post, false, $has_picture); + $converted = twitter_expand_entities($a, $postarray['body'], $post, false, $picture); $postarray['body'] = $converted["body"]; $postarray['tag'] = $converted["tags"]; @@ -1261,13 +1371,18 @@ function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing $postarray['body'] = $post->retweeted_status->text; + $picture = ""; + // media if (is_array($post->retweeted_status->entities->media)) { foreach($post->retweeted_status->entities->media AS $media) { switch($media->type) { case 'photo': - $postarray['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $postarray['body']); - $has_picture = true; + //$postarray['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $postarray['body']); + //$has_picture = true; + $postarray['body'] = str_replace($media->url, "", $postarray['body']); + $postarray['object-type'] = ACTIVITY_OBJ_IMAGE; + $picture = $media->media_url_https; break; default: $postarray['body'] .= print_r($media, true); @@ -1275,7 +1390,7 @@ function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing } } - $converted = twitter_expand_entities($a, $postarray['body'], $post->retweeted_status, false, $has_picture); + $converted = twitter_expand_entities($a, $postarray['body'], $post->retweeted_status, false, $picture); $postarray['body'] = $converted["body"]; $postarray['tag'] = $converted["tags"]; @@ -1306,6 +1421,8 @@ function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing function twitter_checknotification($a, $uid, $own_id, $top_item, $postarray) { + // this whole function doesn't seem to work. Needs complete check + $user = q("SELECT * FROM `contact` WHERE `uid` = %d AND `self` LIMIT 1", intval($uid) ); @@ -1354,7 +1471,7 @@ function twitter_checknotification($a, $uid, $own_id, $top_item, $postarray) { 'to_email' => $user[0]['email'], 'uid' => $user[0]['uid'], 'item' => $postarray, - 'link' => $a->get_baseurl() . '/display/' . $user[0]['nickname'] . '/' . $top_item, + 'link' => $a->get_baseurl().'/display/'.urlencode(get_item_guid($top_item)), 'source_name' => $postarray['author-name'], 'source_link' => $postarray['author-link'], 'source_photo' => $postarray['author-avatar'], @@ -1432,7 +1549,7 @@ function twitter_fetchhometimeline($a, $uid) { return; } - $posts = array_reverse($items); + $posts = array_reverse($items); logger("twitter_fetchhometimeline: Fetching timeline for user ".$uid." ".sizeof($posts)." items", LOGGER_DEBUG); @@ -1475,7 +1592,7 @@ function twitter_fetchhometimeline($a, $uid) { return; } - $posts = array_reverse($items); + $posts = array_reverse($items); logger("twitter_fetchhometimeline: Fetching mentions for user ".$uid." ".sizeof($posts)." items", LOGGER_DEBUG); @@ -1494,6 +1611,9 @@ function twitter_fetchhometimeline($a, $uid) { $item = item_store($postarray); + if (!isset($postarray["parent"]) OR ($postarray["parent"] == 0)) + $postarray["parent"] = $item; + logger('twitter_fetchhometimeline: User '.$self["nick"].' posted mention timeline item '.$item); if ($item == 0) { @@ -1501,27 +1621,31 @@ function twitter_fetchhometimeline($a, $uid) { dbesc($postarray['uri']), intval($uid) ); - if (count($r)) + if (count($r)) { $item = $r[0]['id']; - } + $parent_id = $r[0]['parent']; + } + } else + $parent_id = $postarray['parent']; if ($item != 0) { require_once('include/enotify.php'); notification(array( 'type' => NOTIFY_TAGSELF, - 'notify_flags' => $u[0]['notify-flags'], - 'language' => $u[0]['language'], - 'to_name' => $u[0]['username'], - 'to_email' => $u[0]['email'], - 'uid' => $u[0]['uid'], - 'item' => $postarray, - 'link' => $a->get_baseurl() . '/display/' . $u[0]['nickname'] . '/' . $item, - 'source_name' => $postarray['author-name'], - 'source_link' => $postarray['author-link'], + 'notify_flags' => $u[0]['notify-flags'], + 'language' => $u[0]['language'], + 'to_name' => $u[0]['username'], + 'to_email' => $u[0]['email'], + 'uid' => $u[0]['uid'], + 'item' => $postarray, + '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'], - 'verb' => ACTIVITY_TAG, - 'otype' => 'item' - )); + 'verb' => ACTIVITY_TAG, + 'otype' => 'item', + 'parent' => $parent_id + )); } } } @@ -1552,8 +1676,8 @@ function twitter_fetch_own_contact($a, $uid) { $contact_id = twitter_fetch_contact($uid, $user, true); } else { - $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1", - intval($uid), dbesc("twitter::".$own_id)); + $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1", + intval($uid), dbesc("twitter::".$own_id)); if(count($r)) $contact_id = $r[0]["id"]; else @@ -1610,5 +1734,4 @@ function twitter_is_retweet($a, $uid, $body) { return(!isset($result->errors)); } - ?>