X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=twitter%2Ftwitter.php;h=16debcb7c2660e6cccf192d420f10aa7e8d77bab;hb=b5869e7961dd284c542f32769391f69d0a78c3de;hp=1b9f2c1b06961c53cc0019a83066915671635b13;hpb=7964aaeef3b8e0e9d46a8c9f4cebb7e1d1d30321;p=friendica-addons.git diff --git a/twitter/twitter.php b/twitter/twitter.php index 1b9f2c1b..16debcb7 100755 --- a/twitter/twitter.php +++ b/twitter/twitter.php @@ -64,31 +64,76 @@ 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'); register_hook('jot_networks', 'addon/twitter/twitter.php', 'twitter_jot_nets'); 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'); 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'); unregister_hook('jot_networks', 'addon/twitter/twitter.php', 'twitter_jot_nets'); 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'); // 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'); } +function twitter_follow($a, &$contact) { + + logger("twitter_follow: Check if contact is twitter contact. ".$contact["url"], LOGGER_DEBUG); + + if (!strstr($contact["url"], "://twitter.com") AND !strstr($contact["url"], "@twitter.com")) + return; + + // contact seems to be a twitter contact, so continue + $nickname = preg_replace("=https?://twitter.com/(.*)=ism", "$1", $contact["url"]); + $nickname = str_replace("@twitter.com", "", $nickname); + + $uid = $a->user["uid"]; + + $ckey = get_config('twitter', 'consumerkey'); + $csecret = get_config('twitter', 'consumersecret'); + $otoken = get_pconfig($uid, 'twitter', 'oauthtoken'); + $osecret = get_pconfig($uid, 'twitter', 'oauthsecret'); + + require_once("addon/twitter/codebird.php"); + + $cb = \Codebird\Codebird::getInstance(); + $cb->setConsumerKey($ckey, $csecret); + $cb->setToken($otoken, $osecret); + + $parameters = array(); + $parameters["screen_name"] = $nickname; + + $user = $cb->friendships_create($parameters); + + twitter_fetchuser($a, $uid, $nickname); + + $r = q("SELECT name,nick,url,addr,batch,notify,poll,request,confirm,poco,photo,priority,network,alias,pubkey + FROM `contact` WHERE `uid` = %d AND `nick` = '%s'", + intval($uid), + dbesc($nickname)); + if (count($r)) + $contact["contact"] = $r[0]; +} + function twitter_jot_nets(&$a,&$b) { if(! local_user()) return; @@ -105,9 +150,10 @@ function twitter_jot_nets(&$a,&$b) { function twitter_settings_post ($a,$post) { if(! local_user()) return; - // don't check twitter settings if twitter submit button is not clicked - if (!x($_POST,'twitter-submit')) return; - + // don't check twitter settings if twitter submit button is not clicked + if (!x($_POST,'twitter-submit')) + return; + if (isset($_POST['twitter-disconnect'])) { /*** * if the twitter-disconnect checkbox is set, clear the OAuth key/secret pair @@ -119,10 +165,11 @@ function twitter_settings_post ($a,$post) { 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', 'post_taglinks'); del_pconfig(local_user(), 'twitter', 'lastid'); del_pconfig(local_user(), 'twitter', 'mirror_posts'); - del_pconfig(local_user(), 'twitter', 'intelligent_shortening'); + del_pconfig(local_user(), 'twitter', 'import'); + del_pconfig(local_user(), 'twitter', 'create_user'); + del_pconfig(local_user(), 'twitter', 'own_id'); } else { if (isset($_POST['twitter-pin'])) { // if the user supplied us with a PIN from Twitter, let the magic of OAuth happen @@ -139,7 +186,6 @@ function twitter_settings_post ($a,$post) { 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); - set_pconfig(local_user(),'twitter', 'post_taglinks', 1); // reload the Addon Settings page, if we don't do it see Bug #42 goaway($a->get_baseurl().'/settings/connectors'); } else { @@ -147,10 +193,14 @@ function twitter_settings_post ($a,$post) { // 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_taglinks',intval($_POST['twitter-sendtaglinks'])); set_pconfig(local_user(), 'twitter', 'mirror_posts', intval($_POST['twitter-mirror'])); - set_pconfig(local_user(), 'twitter', 'intelligent_shortening', intval($_POST['twitter-shortening'])); - info( t('Twitter settings updated.') . EOL); + 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'); + + info(t('Twitter settings updated.') . EOL); }} } function twitter_settings(&$a,&$s) { @@ -170,15 +220,22 @@ function twitter_settings(&$a,&$s) { $checked = (($enabled) ? ' checked="checked" ' : ''); $defenabled = get_pconfig(local_user(),'twitter','post_by_default'); $defchecked = (($defenabled) ? ' checked="checked" ' : ''); - $linksenabled = get_pconfig(local_user(),'twitter','post_taglinks'); - $linkschecked = (($linksenabled) ? ' checked="checked" ' : ''); $mirrorenabled = get_pconfig(local_user(),'twitter','mirror_posts'); $mirrorchecked = (($mirrorenabled) ? ' checked="checked" ' : ''); - $shorteningenabled = get_pconfig(local_user(),'twitter','intelligent_shortening'); - $shorteningchecked = (($shorteningenabled) ? ' 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'); - $s .= '
'; - $s .= '

'. t('Twitter Posting Settings') .'

'; + $s .= ''; + $s .= '

'. t('Twitter Import/Export/Mirror').'

'; + $s .= ''; + $s .= '
'; - $s .= '
'; + $s .= '
'; } else { /*** * we have an OAuth key / secret pair for the user @@ -234,23 +291,24 @@ function twitter_settings(&$a,&$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 .= '
'; @@ -280,195 +338,100 @@ function twitter_post_local(&$a,&$b) { } } -if (! function_exists('short_link')) { -function short_link ($url) { - require_once('library/slinky.php'); - $slinky = new Slinky( $url ); - $yourls_url = get_config('yourls','url1'); - if ($yourls_url) { - $yourls_username = get_config('yourls','username1'); - $yourls_password = get_config('yourls', 'password1'); - $yourls_ssl = get_config('yourls', 'ssl1'); - $yourls = new Slinky_YourLS(); - $yourls->set( 'username', $yourls_username ); - $yourls->set( 'password', $yourls_password ); - $yourls->set( 'ssl', $yourls_ssl ); - $yourls->set( 'yourls-url', $yourls_url ); - $slinky->set_cascade( array( $yourls, new Slinky_UR1ca(), new Slinky_Trim(), new Slinky_IsGd(), new Slinky_TinyURL() ) ); - } - else { - // setup a cascade of shortening services - // try to get a short link from these services - // in the order ur1.ca, trim, id.gd, tinyurl - $slinky->set_cascade( array( new Slinky_UR1ca(), new Slinky_Trim(), new Slinky_IsGd(), new Slinky_TinyURL() ) ); - } - return $slinky->short(); -} }; - -function twitter_shortenmsg($b) { - require_once("include/bbcode.php"); - require_once("include/html2plain.php"); - - $max_char = 140; - - // Looking for the first image - $image = ''; - if(preg_match("/\[img\=([0-9]*)x([0-9]*)\](.*?)\[\/img\]/is",$b['body'],$matches)) - $image = $matches[3]; - - if ($image == '') - if(preg_match("/\[img\](.*?)\[\/img\]/is",$b['body'],$matches)) - $image = $matches[1]; - - $multipleimages = (strpos($b['body'], "[img") != strrpos($b['body'], "[img")); - - // When saved into the database the content is sent through htmlspecialchars - // That means that we have to decode all image-urls - $image = htmlspecialchars_decode($image); - - $body = $b["body"]; - if ($b["title"] != "") - $body = $b["title"]."\n\n".$body; - - if (strpos($body, "[bookmark") !== false) { - // splitting the text in two parts: - // before and after the bookmark - $pos = strpos($body, "[bookmark"); - $body1 = substr($body, 0, $pos); - $body2 = substr($body, $pos); - - // Removing all quotes after the bookmark - // they are mostly only the content after the bookmark. - $body2 = preg_replace("/\[quote\=([^\]]*)\](.*?)\[\/quote\]/ism",'',$body2); - $body2 = preg_replace("/\[quote\](.*?)\[\/quote\]/ism",'',$body2); - $body = $body1.$body2; - } - - // Add some newlines so that the message could be cut better - $body = str_replace(array("[quote", "[bookmark", "[/bookmark]", "[/quote]"), - array("\n[quote", "\n[bookmark", "[/bookmark]\n", "[/quote]\n"), $body); +function twitter_action($a, $uid, $pid, $action) { - // remove the recycle signs and the names since they aren't helpful on twitter - // recycle 1 - $recycle = html_entity_decode("♲ ", ENT_QUOTES, 'UTF-8'); - $body = preg_replace( '/'.$recycle.'\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', "\n", $body); - // recycle 2 (Test) - $recycle = html_entity_decode("◌ ", ENT_QUOTES, 'UTF-8'); - $body = preg_replace( '/'.$recycle.'\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', "\n", $body); + $ckey = get_config('twitter', 'consumerkey'); + $csecret = get_config('twitter', 'consumersecret'); + $otoken = get_pconfig($uid, 'twitter', 'oauthtoken'); + $osecret = get_pconfig($uid, 'twitter', 'oauthsecret'); - // remove the share element - $body = preg_replace("/\[share(.*?)\](.*?)\[\/share\]/ism","\n\n$2\n\n",$body); + require_once("addon/twitter/codebird.php"); - // At first convert the text to html - $html = bbcode($body, false, false); + $cb = \Codebird\Codebird::getInstance(); + $cb->setConsumerKey($ckey, $csecret); + $cb->setToken($otoken, $osecret); - // Then convert it to plain text - //$msg = trim($b['title']." \n\n".html2plain($html, 0, true)); - $msg = trim(html2plain($html, 0, true)); - $msg = html_entity_decode($msg,ENT_QUOTES,'UTF-8'); + $post = array('id' => $pid); - // Removing multiple newlines - while (strpos($msg, "\n\n\n") !== false) - $msg = str_replace("\n\n\n", "\n\n", $msg); + logger("twitter_action '".$action."' ID: ".$pid." data: " . print_r($post, true), LOGGER_DATA); - // Removing multiple spaces - while (strpos($msg, " ") !== false) - $msg = str_replace(" ", " ", $msg); + switch ($action) { + case "delete": + $result = $cb->statuses_destroy($post); + break; + case "like": + $result = $cb->favorites_create($post); + break; + case "unlike": + $result = $cb->favorites_destroy($post); + break; + } + logger("twitter_action '".$action."' send, result: " . print_r($result, true), LOGGER_DEBUG); +} - $origmsg = $msg; +function twitter_post_hook(&$a,&$b) { - // Removing URLs - $msg = preg_replace('/(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)/i', "", $msg); + /** + * Post to Twitter + */ - $msg = trim($msg); + require_once("include/network.php"); - $link = ''; - // look for bookmark-bbcode and handle it with priority - if(preg_match("/\[bookmark\=([^\]]*)\](.*?)\[\/bookmark\]/is",$b['body'],$matches)) - $link = $matches[1]; + if (!get_pconfig($b["uid"],'twitter','import')) { + if($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited'])) + return; + } - $multiplelinks = (strpos($b['body'], "[bookmark") != strrpos($b['body'], "[bookmark")); + if($b['parent'] != $b['id']) { + logger("twitter_post_hook: parameter ".print_r($b, true), LOGGER_DATA); - // If there is no bookmark element then take the first link - if ($link == '') { - $links = collecturls($html); - if (sizeof($links) > 0) { - reset($links); - $link = current($links); + // 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; } - $multiplelinks = (sizeof($links) > 1); - } - $msglink = ""; - if ($multiplelinks) - $msglink = $b["plink"]; - else if ($link != "") - $msglink = $link; - else if ($multipleimages) - $msglink = $b["plink"]; - else if ($image != "") - $msglink = $image; - - if (($msglink == "") and strlen($msg) > $max_char) - $msglink = $b["plink"]; - - // If the message is short enough then don't modify it. - if ((strlen(trim($origmsg)) <= $max_char) AND ($msglink == "")) - return(trim($origmsg)); - - // If the message is short enough and the link exists in the original message don't modify it as well - // -3 because of the bad shortener of twitter - if ((strlen(trim($origmsg)) <= ($max_char - 3)) AND strpos($origmsg, $msglink)) - return(trim($origmsg)); - - // Preserve the unshortened link - $orig_link = $msglink; - - //if (strlen($msglink) > 20) - // $msglink = short_link($msglink); - // - //if (strlen(trim($msg." ".$msglink)) > ($max_char - 3)) { - // $msg = substr($msg, 0, ($max_char - 3) - (strlen($msglink))); - - // Just replace the message link with a 15 character long string - // Twitter shortens it anyway to this length - if (trim($msglink) <> '') - $msglink = "123456789012345"; - - if (strlen(trim($msg." ".$msglink)) > ($max_char)) { - $msg = substr($msg, 0, ($max_char) - (strlen($msglink))); - $lastchar = substr($msg, -1); - $msg = substr($msg, 0, -1); - $pos = strrpos($msg, "\n"); - if ($pos > 0) - $msg = substr($msg, 0, $pos); - else if ($lastchar != "\n") - $msg = substr($msg, 0, -3)."..."; - } - $msg = str_replace("\n", " ", $msg); + $r = q("SELECT * FROM item WHERE item.uri = '%s' AND item.uid = %d LIMIT 1", + dbesc($b["thr-parent"]), + intval($b["uid"])); - // Removing multiple spaces - again - while (strpos($msg, " ") !== false) - $msg = str_replace(" ", " ", $msg); + if(!count($r)) { + logger("twitter_post_hook: no parent found ".$b["thr-parent"]); + return; + } else { + $iscomment = true; + $orig_post = $r[0]; + } - //return(trim($msg." ".$msglink)); - return(trim($msg." ".$orig_link)); -} + $nickname = preg_replace("=https?://twitter.com/(.*)=ism", "$1", $orig_post["author-link"]); + $nickname = "@[url=".$orig_post["author-link"]."]".$nickname."[/url]"; -function twitter_post_hook(&$a,&$b) { + logger("twitter_post_hook: comparing ".$nickname." with ".$b["body"], LOGGER_DEBUG); + if (strpos($b["body"], $nickname) === false) + $b["body"] = $nickname." ".$b["body"]; - /** - * Post to Twitter - */ + logger("twitter_post_hook: parent found ".print_r($orig_post, true), LOGGER_DATA); + } else { + $iscomment = false; - if($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited'])) - return; + if($b['private'] OR !strstr($b['postopts'],'twitter')) + return; + } - if(! strstr($b['postopts'],'twitter')) - return; + if (($b['verb'] == ACTIVITY_POST) AND $b['deleted']) + twitter_action($a, $b["uid"], substr($orig_post["uri"], 9), "delete"); - if($b['parent'] != $b['id']) + if($b['verb'] == ACTIVITY_LIKE) { + logger("twitter_post_hook: parameter 2 ".substr($b["thr-parent"], 9), LOGGER_DEBUG); + if ($b['deleted']) + twitter_action($a, $b["uid"], substr($b["thr-parent"], 9), "unlike"); + else + twitter_action($a, $b["uid"], substr($b["thr-parent"], 9), "like"); return; + } + + if($b['deleted'] || ($b['created'] !== $b['edited'])) + return; // if post comes from twitter don't send it back if($b['app'] == "Twitter") @@ -483,105 +446,106 @@ function twitter_post_hook(&$a,&$b) { $csecret = get_config('twitter', 'consumersecret'); $otoken = get_pconfig($b['uid'], 'twitter', 'oauthtoken'); $osecret = get_pconfig($b['uid'], 'twitter', 'oauthsecret'); - $intelligent_shortening = get_pconfig($b['uid'], 'twitter', 'intelligent_shortening'); - - // Global setting overrides this - if (get_config('twitter','intelligent_shortening')) - $intelligent_shortening = get_config('twitter','intelligent_shortening'); if($ckey && $csecret && $otoken && $osecret) { logger('twitter: we have customer key and oauth stuff, going to send.', LOGGER_DEBUG); + // If it's a repeated message from twitter then do a native retweet and exit + if (twitter_is_retweet($a, $b['uid'], $b['body'])) + return; + require_once('library/twitteroauth.php'); require_once('include/bbcode.php'); $tweet = new TwitterOAuth($ckey,$csecret,$otoken,$osecret); - // in theory max char is 140 but T. uses t.co to make links - // longer so we give them 10 characters extra - if (!$intelligent_shortening) { - $max_char = 130; // max. length for a tweet - // we will only work with up to two times the length of the dent - // we can later send to Twitter. This way we can "gain" some - // information during shortening of potential links but do not - // shorten all the links in a 200000 character long essay. - if (! $b['title']=='') { - $tmp = $b['title'] . ' : '. $b['body']; - // $tmp = substr($tmp, 0, 4*$max_char); - } else { - $tmp = $b['body']; // substr($b['body'], 0, 3*$max_char); - } - // if [url=bla][img]blub.png[/img][/url] get blub.png - $tmp = preg_replace( '/\[url\=(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)\]\[img\](\\w+.*?)\\[\\/img\]\\[\\/url\]/i', '$2', $tmp); - // preserve links to images, videos and audios - $tmp = preg_replace( '/\[img\=([0-9]*)x([0-9]*)\](.*?)\[\/img\]/ism', '$3', $tmp); - $tmp = preg_replace( '/\[\\/?img(\\s+.*?\]|\])/i', '', $tmp); - $tmp = preg_replace( '/\[\\/?video(\\s+.*?\]|\])/i', '', $tmp); - $tmp = preg_replace( '/\[\\/?youtube(\\s+.*?\]|\])/i', '', $tmp); - $tmp = preg_replace( '/\[\\/?vimeo(\\s+.*?\]|\])/i', '', $tmp); - $tmp = preg_replace( '/\[\\/?audio(\\s+.*?\]|\])/i', '', $tmp); - $linksenabled = get_pconfig($b['uid'],'twitter','post_taglinks'); - // if a #tag is linked, don't send the [url] over to SN - // that is, don't send if the option is not set in the - // connector settings - if ($linksenabled=='0') { - // #-tags - $tmp = preg_replace( '/#\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', '#$2', $tmp); - // @-mentions - $tmp = preg_replace( '/@\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', '@$2', $tmp); - // recycle 1 - $recycle = html_entity_decode("♲ ", ENT_QUOTES, 'UTF-8'); - $tmp = preg_replace( '/'.$recycle.'\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', $recycle.'$2', $tmp); - // recycle 2 (Test) - $recycle = html_entity_decode("◌ ", ENT_QUOTES, 'UTF-8'); - $tmp = preg_replace( '/'.$recycle.'\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', $recycle.'$2', $tmp); - } - $tmp = preg_replace( '/\[url\=(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)\](\w+.*?)\[\/url\]/i', '$2 $1', $tmp); - $tmp = preg_replace( '/\[bookmark\=(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)\](\w+.*?)\[\/bookmark\]/i', '$2 $1', $tmp); - // find all http or https links in the body of the entry and - // apply the shortener if the link is longer then 20 characters - if (( strlen($tmp)>$max_char ) && ( $max_char > 0 )) { - preg_match_all ( '/(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)/i', $tmp, $allurls ); - foreach ($allurls as $url) { - foreach ($url as $u) { - if (strlen($u)>20) { - $sl = short_link($u); - $tmp = str_replace( $u, $sl, $tmp ); - } - } - } - } - // ok, all the links we want to send out are save, now strip - // away the remaining bbcode - //$msg = strip_tags(bbcode($tmp, false, false)); - $msg = bbcode($tmp, false, false, true); - $msg = str_replace(array('
','
'),"\n",$msg); - $msg = strip_tags($msg); - - // quotes not working - let's try this - $msg = html_entity_decode($msg); - if (( strlen($msg) > $max_char) && $max_char > 0) { - $shortlink = short_link( $b['plink'] ); - // the new message will be shortened such that "... $shortlink" - // will fit into the character limit - $msg = nl2br(substr($msg, 0, $max_char-strlen($shortlink)-4)); - $msg = str_replace(array('
','
'),' ',$msg); - $e = explode(' ', $msg); - // remove the last word from the cut down message to - // avoid sending cut words to the MicroBlog - array_pop($e); - $msg = implode(' ', $e); - $msg .= '... ' . $shortlink; - } - $msg = trim($msg); - } else - $msg = twitter_shortenmsg($b); + $max_char = 140; + require_once("include/plaintext.php"); + $msgarr = plaintext($a, $b, $max_char, true); + $msg = $msgarr["text"]; + + if (($msg == "") AND isset($msgarr["title"])) + $msg = shortenmsg($msgarr["title"], $max_char - 50); + + $image = ""; + + if (isset($msgarr["url"])) + $msg .= "\n".$msgarr["url"]; + elseif (isset($msgarr["image"])) + $image = $msgarr["image"]; // and now tweet it :-) - if(strlen($msg)) { - $result = $tweet->post('statuses/update', array('status' => $msg)); + if(strlen($msg) and ($image != "")) { + $img_str = fetch_url($image); + + $tempfile = tempnam(get_config("system","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"); + + $cb = \Codebird\Codebird::getInstance(); + $cb->setConsumerKey($ckey, $csecret); + $cb->setToken($otoken, $osecret); + + $post = array('status' => $msg, 'media[]' => $tempfile); + + if ($iscomment) + $post["in_reply_to_status_id"] = substr($orig_post["uri"], 9); + + $result = $cb->statuses_updateWithMedia($post); + unlink($tempfile); + + logger('twitter_post_with_media send, result: ' . print_r($result, true), LOGGER_DEBUG); + if ($result->errors OR $result->error) { + logger('Send to Twitter failed: "' . print_r($result->errors, true) . '"'); + + // Workaround: Remove the picture link so that the post can be reposted without it + $msg .= " ".$image; + $image = ""; + } elseif ($iscomment) { + logger('twitter_post: Update extid '.$result->id_str." for post id ".$b['id']); + q("UPDATE `item` SET `extid` = '%s', `body` = '%s' WHERE `id` = %d", + dbesc("twitter::".$result->id_str), + dbesc($result->text), + intval($b['id']) + ); + } + } + + if(strlen($msg) and ($image == "")) { + $url = 'statuses/update'; + $post = array('status' => $msg); + + if ($iscomment) + $post["in_reply_to_status_id"] = substr($orig_post["uri"], 9); + + $result = $tweet->post($url, $post); logger('twitter_post send, result: ' . print_r($result, true), LOGGER_DEBUG); - if ($result->error) { - logger('Send to Twitter failed: "' . $result->error . '"'); + if ($result->errors) { + logger('Send to Twitter failed: "' . print_r($result->errors, true) . '"'); + + $r = q("SELECT `id` FROM `contact` WHERE `uid` = %d AND `self`", intval($b['uid'])); + if (count($r)) + $a->contact = $r[0]["id"]; + + $s = serialize(array('url' => $url, 'item' => $b['id'], 'post' => $post)); + require_once('include/queue_fn.php'); + add_to_queue($a->contact,NETWORK_TWITTER,$s); + notice(t('Twitter post failed. Queued for retry.').EOL); + } elseif ($iscomment) { + logger('twitter_post: Update extid '.$result->id_str." for post id ".$b['id']); + q("UPDATE `item` SET `extid` = '%s' WHERE `id` = %d", + dbesc("twitter::".$result->id_str), + intval($b['id']) + ); + //q("UPDATE `item` SET `extid` = '%s', `body` = '%s' WHERE `id` = %d", + // dbesc("twitter::".$result->id_str), + // dbesc($result->text), + // intval($b['id']) + //); } } } @@ -600,7 +564,7 @@ function twitter_plugin_admin(&$a, &$o){ $t = get_markup_template( "admin.tpl", "addon/twitter/" ); $o = replace_macros($t, array( - '$submit' => t('Submit'), + '$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' ), ''), @@ -624,7 +588,7 @@ function twitter_cron($a,$b) { } logger('twitter: cron_start'); - $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'twitter' AND `k` = 'mirror_posts' AND `v` = '1' ORDER BY RAND() "); + $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'twitter' AND `k` = 'mirror_posts' AND `v` = '1' ORDER BY RAND()"); if(count($r)) { foreach($r as $rr) { logger('twitter: fetching for user '.$rr['uid']); @@ -632,11 +596,60 @@ function twitter_cron($a,$b) { } } + + $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: importing timeline from user '.$rr['uid']); + twitter_fetchhometimeline($a, $rr["uid"]); + +/* + // 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()); + } +*/ + + } + } + 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_fetchtimeline($a, $uid) { $ckey = get_config('twitter', 'consumerkey'); $csecret = get_config('twitter', 'consumersecret'); @@ -649,10 +662,15 @@ function twitter_fetchtimeline($a, $uid) { if ($application_name == "") $application_name = $a->get_hostname(); + $has_picture = false; + + require_once('mod/item.php'); + require_once('include/items.php'); + require_once('library/twitteroauth.php'); $connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret); - $parameters = array("exclude_replies" => true, "trim_user" => true, "contributor_details" => false, "include_rts" => false); + $parameters = array("exclude_replies" => true, "trim_user" => false, "contributor_details" => true, "include_rts" => true); $first_time = ($lastid == ""); @@ -678,6 +696,7 @@ function twitter_fetchtimeline($a, $uid) { $_SESSION["authenticated"] = true; $_SESSION["uid"] = $uid; + unset($_REQUEST); $_REQUEST["type"] = "wall"; $_REQUEST["api_source"] = true; $_REQUEST["profile_uid"] = $uid; @@ -685,7 +704,51 @@ function twitter_fetchtimeline($a, $uid) { //$_REQUEST["date"] = $post->created_at; - $_REQUEST["body"] = $post->text; + $_REQUEST["title"] = ""; + + if (is_object($post->retweeted_status)) { + + $_REQUEST['body'] = $post->retweeted_status->text; + + // 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; + break; + } + } + } + + $converted = twitter_expand_entities($a, $_REQUEST['body'], $post->retweeted_status, true, $has_picture); + $_REQUEST['body'] = $converted["body"]; + + $_REQUEST['body'] = "[share author='".$post->retweeted_status->user->name. + "' profile='https://twitter.com/".$post->retweeted_status->user->screen_name. + "' avatar='".$post->retweeted_status->user->profile_image_url_https. + "' link='https://twitter.com/".$post->retweeted_status->user->screen_name."/status/".$post->retweeted_status->id_str."']". + $_REQUEST['body']; + $_REQUEST['body'] .= "[/share]"; + } else { + $_REQUEST["body"] = $post->text; + + 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; + break; + } + } + } + + $converted = twitter_expand_entities($a, $_REQUEST["body"], $post, true, $has_picture); + $_REQUEST['body'] = $converted["body"]; + } + if (is_string($post->place->name)) $_REQUEST["location"] = $post->place->name; @@ -701,11 +764,877 @@ function twitter_fetchtimeline($a, $uid) { //print_r($_REQUEST); logger('twitter: posting for user '.$uid); - require_once('mod/item.php'); - item_post($a); +// require_once('mod/item.php'); + item_post($a); } } } set_pconfig($uid, 'twitter', 'lastid', $lastid); } + +function twitter_queue_hook(&$a,&$b) { + + $qi = q("SELECT * FROM `queue` WHERE `network` = '%s'", + dbesc(NETWORK_TWITTER) + ); + if(! count($qi)) + return; + + require_once('include/queue_fn.php'); + + foreach($qi as $x) { + if($x['network'] !== NETWORK_TWITTER) + continue; + + logger('twitter_queue: run'); + + $r = q("SELECT `user`.* FROM `user` LEFT JOIN `contact` on `contact`.`uid` = `user`.`uid` + WHERE `contact`.`self` = 1 AND `contact`.`id` = %d LIMIT 1", + intval($x['cid']) + ); + if(! count($r)) + continue; + + $user = $r[0]; + + $ckey = get_config('twitter', 'consumerkey'); + $csecret = get_config('twitter', 'consumersecret'); + $otoken = get_pconfig($user['uid'], 'twitter', 'oauthtoken'); + $osecret = get_pconfig($user['uid'], 'twitter', 'oauthsecret'); + + $success = false; + + if ($ckey AND $csecret AND $otoken AND $osecret) { + + logger('twitter_queue: able to post'); + + $z = unserialize($x['content']); + + require_once("addon/twitter/codebird.php"); + + $cb = \Codebird\Codebird::getInstance(); + $cb->setConsumerKey($ckey, $csecret); + $cb->setToken($otoken, $osecret); + + if ($z['url'] == "statuses/update") + $result = $cb->statuses_update($z['post']); + + logger('twitter_queue: post result: ' . print_r($result, true), LOGGER_DEBUG); + + if ($result->errors) + logger('twitter_queue: Send to Twitter failed: "' . print_r($result->errors, true) . '"'); + else { + $success = true; + remove_queue_item($x['id']); + } + } else + logger("twitter_queue: Error getting tokens for user ".$user['uid']); + + if (!$success) { + logger('twitter_queue: delayed'); + update_queue_time($x['id']); + } + } +} + +function twitter_fetch_contact($uid, $contact, $create_user) { + + // 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))); + + 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($contact->profile_image_url_https)); + 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(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)); + + if(!count($r) AND !$create_user) + return(0); + + if (count($r) AND ($r[0]["readonly"] OR $r[0]["blocked"])) { + logger("twitter_fetch_contact: Contact '".$r[0]["nick"]."' is blocked or readonly.", LOGGER_DEBUG); + return(-1); + } + + if(!count($r)) { + // create contact record + q("INSERT INTO `contact` ( `uid`, `created`, `url`, `nurl`, `addr`, `alias`, `notify`, `poll`, + `name`, `nick`, `photo`, `network`, `rel`, `priority`, + `writable`, `blocked`, `readonly`, `pending` ) + VALUES ( %d, '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', %d, %d, %d, 0, 0, 0 ) ", + intval($uid), + dbesc(datetime_convert()), + dbesc("https://twitter.com/".$contact->screen_name), + dbesc(normalise_link("https://twitter.com/".$contact->screen_name)), + dbesc($contact->screen_name."@twitter.com"), + dbesc("twitter::".$contact->id_str), + dbesc(''), + dbesc("twitter::".$contact->id_str), + dbesc($contact->name), + dbesc($contact->screen_name), + dbesc($contact->profile_image_url_https), + dbesc(NETWORK_TWITTER), + intval(CONTACT_IS_FRIEND), + intval(1), + intval(1) + ); + + $r = q("SELECT * FROM `contact` WHERE `alias` = '%s' AND `uid` = %d LIMIT 1", + dbesc("twitter::".$contact->id_str), + intval($uid) + ); + + if(! count($r)) + return(false); + + $contact_id = $r[0]['id']; + + $g = q("SELECT def_gid FROM user WHERE uid = %d LIMIT 1", + intval($uid) + ); + + if($g && intval($g[0]['def_gid'])) { + require_once('include/group.php'); + group_add_member($uid,'',$contact_id,$g[0]['def_gid']); + } + + require_once("Photo.php"); + + $photos = import_profile_photo($contact->profile_image_url_https,$uid,$contact_id); + + q("UPDATE `contact` SET `photo` = '%s', + `thumb` = '%s', + `micro` = '%s', + `name-date` = '%s', + `uri-date` = '%s', + `avatar-date` = '%s' + WHERE `id` = %d", + dbesc($photos[0]), + dbesc($photos[1]), + dbesc($photos[2]), + dbesc(datetime_convert()), + dbesc(datetime_convert()), + dbesc(datetime_convert()), + intval($contact_id) + ); + + } else { + // update profile photos once every two weeks as we have no notification of when they change. + + //$update_photo = (($r[0]['avatar-date'] < datetime_convert('','','now -2 days')) ? true : false); + $update_photo = ($r[0]['avatar-date'] < datetime_convert('','','now -12 hours')); + + // check that we have all the photos, this has been known to fail on occasion + + if((! $r[0]['photo']) || (! $r[0]['thumb']) || (! $r[0]['micro']) || ($update_photo)) { + + logger("twitter_fetch_contact: Updating contact ".$contact->screen_name, LOGGER_DEBUG); + + require_once("Photo.php"); + + $photos = import_profile_photo($contact->profile_image_url_https, $uid, $r[0]['id']); + + q("UPDATE `contact` SET `photo` = '%s', + `thumb` = '%s', + `micro` = '%s', + `name-date` = '%s', + `uri-date` = '%s', + `avatar-date` = '%s', + `url` = '%s', + `nurl` = '%s', + `addr` = '%s', + `name` = '%s', + `nick` = '%s' + WHERE `id` = %d", + dbesc($photos[0]), + dbesc($photos[1]), + dbesc($photos[2]), + dbesc(datetime_convert()), + dbesc(datetime_convert()), + dbesc(datetime_convert()), + dbesc("https://twitter.com/".$contact->screen_name), + dbesc(normalise_link("https://twitter.com/".$contact->screen_name)), + dbesc($contact->screen_name."@twitter.com"), + dbesc($contact->name), + dbesc($contact->screen_name), + intval($r[0]['id']) + ); + } + } + + return($r[0]["id"]); +} + +function twitter_fetchuser($a, $uid, $screen_name = "", $user_id = "") { + $ckey = get_config('twitter', 'consumerkey'); + $csecret = get_config('twitter', 'consumersecret'); + $otoken = get_pconfig($uid, 'twitter', 'oauthtoken'); + $osecret = get_pconfig($uid, 'twitter', 'oauthsecret'); + + require_once("addon/twitter/codebird.php"); + + $cb = \Codebird\Codebird::getInstance(); + $cb->setConsumerKey($ckey, $csecret); + $cb->setToken($otoken, $osecret); + + $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1", + intval($uid)); + + if(count($r)) { + $self = $r[0]; + } else + return; + + $parameters = array(); + + if ($screen_name != "") + $parameters["screen_name"] = $screen_name; + + if ($user_id != "") + $parameters["user_id"] = $user_id; + + // Fetching user data + $user = $cb->users_show($parameters); + + if (!is_object($user)) + return; + + $contact_id = twitter_fetch_contact($uid, $user, true); + + return $contact_id; +} + +function twitter_expand_entities($a, $body, $item, $no_tags = false, $dontincludemedia) { + require_once("include/oembed.php"); + require_once("include/network.php"); + + $tags = ""; + + if (isset($item->entities->urls)) { + $type = ""; + $footerurl = ""; + $footerlink = ""; + $footer = ""; + + foreach ($item->entities->urls AS $url) { + if ($url->url AND $url->expanded_url AND $url->display_url) { + + $expanded_url = original_url($url->expanded_url); + + $oembed_data = oembed_fetch_url($expanded_url); + + // Quickfix: Workaround for URL with "[" and "]" in it + if (strpos($expanded_url, "[") OR strpos($expanded_url, "]")) + $expanded_url = $url->url; + + if ($type == "") + $type = $oembed_data->type; + + if ($oembed_data->type == "video") { + //$body = str_replace($url->url, + // "[video]".$expanded_url."[/video]", $body); + //$dontincludemedia = true; + $type = $oembed_data->type; + $footerurl = $expanded_url; + $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) { + $body = str_replace($url->url, + "[url=".$expanded_url."][img]".$oembed_data->url."[/img][/url]", + $body); + $dontincludemedia = true; + } elseif ($oembed_data->type != "link") + $body = str_replace($url->url, + "[url=".$expanded_url."]".$expanded_url."[/url]", + $body); + else { + $img_str = fetch_url($expanded_url, true, $redirects, 4); + + $tempfile = tempnam(get_config("system","temppath"), "cache"); + file_put_contents($tempfile, $img_str); + $mime = image_type_to_mime_type(exif_imagetype($tempfile)); + unlink($tempfile); + + if (substr($mime, 0, 6) == "image/") { + $type = "photo"; + $body = str_replace($url->url, "[img]".$expanded_url."[/img]", $body); + $dontincludemedia = true; + } else { + $type = $oembed_data->type; + $footerurl = $expanded_url; + $footerlink = "[url=".$expanded_url."]".$expanded_url."[/url]"; + + $body = str_replace($url->url, $footerlink, $body); + } + } + } + } + + if ($footerurl != "") + $footer = add_page_info($footerurl); + + if (($footerlink != "") AND (trim($footer) != "")) { + $removedlink = trim(str_replace($footerlink, "", $body)); + + if (strstr($body, $removedlink)) + $body = $removedlink; + + $body .= $footer; + } + + if ($no_tags) + return(array("body" => $body, "tags" => "")); + + $tags_arr = array(); + + foreach ($item->entities->hashtags AS $hashtag) { + $url = "#[url=".$a->get_baseurl()."/search?tag=".rawurlencode($hashtag->text)."]".$hashtag->text."[/url]"; + $tags_arr["#".$hashtag->text] = $url; + $body = str_replace("#".$hashtag->text, $url, $body); + } + + foreach ($item->entities->user_mentions AS $mention) { + $url = "@[url=https://twitter.com/".rawurlencode($mention->screen_name)."]".$mention->screen_name."[/url]"; + $tags_arr["@".$mention->screen_name] = $url; + $body = str_replace("@".$mention->screen_name, $url, $body); + } + + // it seems as if the entities aren't always covering all mentions. So the rest will be checked here + $tags = get_tags($body); + + if(count($tags)) { + foreach($tags as $tag) { + if (strstr(trim($tag), " ")) + continue; + + if(strpos($tag,'#') === 0) { + if(strpos($tag,'[url=')) + continue; + + // don't link tags that are already embedded in links + + if(preg_match('/\[(.*?)' . preg_quote($tag,'/') . '(.*?)\]/',$body)) + continue; + if(preg_match('/\[(.*?)\]\((.*?)' . preg_quote($tag,'/') . '(.*?)\)/',$body)) + continue; + + $basetag = str_replace('_',' ',substr($tag,1)); + $url = '#[url='.$a->get_baseurl().'/search?tag='.rawurlencode($basetag).']'.$basetag.'[/url]'; + $body = str_replace($tag,$url,$body); + $tags_arr["#".$basetag] = $url; + continue; + } elseif(strpos($tag,'@') === 0) { + if(strpos($tag,'[url=')) + continue; + + $basetag = substr($tag,1); + $url = '@[url=https://twitter.com/'.rawurlencode($basetag).']'.$basetag.'[/url]'; + $body = str_replace($tag,$url,$body); + $tags_arr["@".$basetag] = $url; + } + } + } + + + $tags = implode($tags_arr, ","); + + } + return(array("body" => $body, "tags" => $tags)); +} + +function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing_contact) { + + $has_picture = false; + + $postarray = array(); + $postarray['network'] = NETWORK_TWITTER; + $postarray['gravity'] = 0; + $postarray['uid'] = $uid; + $postarray['wall'] = 0; + $postarray['uri'] = "twitter::".$post->id_str; + + $r = q("SELECT * FROM `item` WHERE `extid` = '%s' AND `uid` = %d LIMIT 1", + dbesc($postarray['uri']), + intval($uid) + ); + + if (count($r)) + return(array()); + + $contactid = 0; + + if ($post->in_reply_to_status_id_str != "") { + + $parent = "twitter::".$post->in_reply_to_status_id_str; + + $r = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1", + dbesc($parent), + intval($uid) + ); + if (count($r)) { + $postarray['thr-parent'] = $r[0]["uri"]; + $postarray['parent-uri'] = $r[0]["parent-uri"]; + } else { + $r = q("SELECT * FROM `item` WHERE `extid` = '%s' AND `uid` = %d LIMIT 1", + dbesc($parent), + intval($uid) + ); + if (count($r)) { + $postarray['thr-parent'] = $r[0]['uri']; + $postarray['parent-uri'] = $r[0]['parent-uri']; + } else { + $postarray['thr-parent'] = $postarray['uri']; + $postarray['parent-uri'] = $postarray['uri']; + } + } + + // Is it me? + $own_id = get_pconfig($uid, 'twitter', 'own_id'); + + if ($post->user->id_str == $own_id) { + $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1", + intval($uid)); + + if(count($r)) { + $contactid = $r[0]["id"]; + + $postarray['owner-name'] = $r[0]["name"]; + $postarray['owner-link'] = $r[0]["url"]; + $postarray['owner-avatar'] = $r[0]["photo"]; + } else + return(array()); + } + } else + $postarray['parent-uri'] = $postarray['uri']; + + if ($contactid == 0) { + $contactid = twitter_fetch_contact($uid, $post->user, $create_user); + + $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; + } + + if(($contactid == 0) AND !$only_existing_contact) + $contactid = $self['id']; + elseif ($contactid <= 0) + return(array()); + + $postarray['contact-id'] = $contactid; + + $postarray['verb'] = ACTIVITY_POST; + $postarray['author-name'] = $postarray['owner-name']; + $postarray['author-link'] = $postarray['owner-link']; + $postarray['author-avatar'] = $postarray['owner-avatar']; + $postarray['plink'] = "https://twitter.com/".$post->user->screen_name."/status/".$post->id_str; + $postarray['app'] = strip_tags($post->source); + + if ($post->user->protected) { + $postarray['private'] = 1; + $postarray['allow_cid'] = '<' . $self['id'] . '>'; + } + + $postarray['body'] = $post->text; + + // 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; + break; + default: + $postarray['body'] .= print_r($media, true); + } + } + } + + $converted = twitter_expand_entities($a, $postarray['body'], $post, false, $has_picture); + $postarray['body'] = $converted["body"]; + $postarray['tag'] = $converted["tags"]; + + $postarray['created'] = datetime_convert('UTC','UTC',$post->created_at); + $postarray['edited'] = datetime_convert('UTC','UTC',$post->created_at); + + if (is_string($post->place->name)) + $postarray["location"] = $post->place->name; + + if (is_string($post->place->full_name)) + $postarray["location"] = $post->place->full_name; + + if (is_array($post->geo->coordinates)) + $postarray["coord"] = $post->geo->coordinates[0]." ".$post->geo->coordinates[1]; + + if (is_array($post->coordinates->coordinates)) + $postarray["coord"] = $post->coordinates->coordinates[1]." ".$post->coordinates->coordinates[0]; + + if (is_object($post->retweeted_status)) { + + $postarray['body'] = $post->retweeted_status->text; + + // 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; + break; + default: + $postarray['body'] .= print_r($media, true); + } + } + } + + $converted = twitter_expand_entities($a, $postarray['body'], $post->retweeted_status, false, $has_picture); + $postarray['body'] = $converted["body"]; + $postarray['tag'] = $converted["tags"]; + + twitter_fetch_contact($uid, $post->retweeted_status->user, false); + + // Deactivated at the moment, since there are problems with answers to retweets + if (false AND !intval(get_config('system','wall-to-wall_share'))) { + $postarray['body'] = "[share author='".$post->retweeted_status->user->name. + "' profile='https://twitter.com/".$post->retweeted_status->user->screen_name. + "' avatar='".$post->retweeted_status->user->profile_image_url_https. + "' link='https://twitter.com/".$post->retweeted_status->user->screen_name."/status/".$post->retweeted_status->id_str."']". + $postarray['body']; + $postarray['body'] .= "[/share]"; + } else { + // 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; + //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; + //} + } + + } + return($postarray); +} + +function twitter_checknotification($a, $uid, $own_id, $top_item, $postarray) { + + $user = q("SELECT * FROM `contact` WHERE `uid` = %d AND `self` LIMIT 1", + intval($uid) + ); + + if(!count($user)) + return; + + // Is it me? + if (link_compare($user[0]["url"], $postarray['author-link'])) + return; + + $own_user = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1", + intval($uid), + dbesc("twitter::".$own_id) + ); + + if(!count($own_user)) + return; + + // Is it me from twitter? + if (link_compare($own_user[0]["url"], $postarray['author-link'])) + return; + + $myconv = q("SELECT `author-link`, `author-avatar`, `parent` FROM `item` WHERE `parent-uri` = '%s' AND `uid` = %d AND `parent` != 0 AND `deleted` = 0", + dbesc($postarray['parent-uri']), + intval($uid) + ); + + if(count($myconv)) { + + foreach($myconv as $conv) { + // now if we find a match, it means we're in this conversation + + if(!link_compare($conv['author-link'],$user[0]["url"]) AND !link_compare($conv['author-link'],$own_user[0]["url"])) + continue; + + require_once('include/enotify.php'); + + $conv_parent = $conv['parent']; + + notification(array( + 'type' => NOTIFY_COMMENT, + 'notify_flags' => $user[0]['notify-flags'], + 'language' => $user[0]['language'], + 'to_name' => $user[0]['username'], + 'to_email' => $user[0]['email'], + 'uid' => $user[0]['uid'], + 'item' => $postarray, + 'link' => $a->get_baseurl() . '/display/' . $user[0]['nickname'] . '/' . $top_item, + 'source_name' => $postarray['author-name'], + 'source_link' => $postarray['author-link'], + 'source_photo' => $postarray['author-avatar'], + 'verb' => ACTIVITY_POST, + 'otype' => 'item', + 'parent' => $conv_parent, + )); + + // only send one notification + break; + } + } +} + +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'); + + logger("twitter_fetchhometimeline: Fetching for user ".$uid, LOGGER_DEBUG); + + require_once('library/twitteroauth.php'); + require_once('include/items.php'); + + $connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret); + + $own_contact = twitter_fetch_own_contact($a, $uid); + + $r = q("SELECT * FROM `contact` WHERE `id` = %d AND `uid` = %d LIMIT 1", + intval($own_contact), + intval($uid)); + + if(count($r)) { + $own_id = $r[0]["nick"]; + } else { + logger("twitter_fetchhometimeline: Own twitter contact not found for user ".$uid, LOGGER_DEBUG); + return; + } + + $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1", + intval($uid)); + + if(count($r)) { + $self = $r[0]; + } else { + logger("twitter_fetchhometimeline: Own contact not found for user ".$uid, LOGGER_DEBUG); + return; + } + + $u = q("SELECT * FROM user WHERE uid = %d LIMIT 1", + intval($uid)); + if(!count($u)) { + logger("twitter_fetchhometimeline: Own user not found for user ".$uid, LOGGER_DEBUG); + return; + } + + $parameters = array("exclude_replies" => false, "trim_user" => false, "contributor_details" => true, "include_rts" => true); + //$parameters["count"] = 200; + + + // Fetching timeline + $lastid = get_pconfig($uid, 'twitter', 'lasthometimelineid'); + + $first_time = ($lastid == ""); + + if ($lastid <> "") + $parameters["since_id"] = $lastid; + + $items = $connection->get('statuses/home_timeline', $parameters); + + if (!is_array($items)) { + logger("twitter_fetchhometimeline: Error fetching home timeline: ".print_r($items, true), LOGGER_DEBUG); + return; + } + + $posts = array_reverse($items); + + logger("twitter_fetchhometimeline: Fetching timeline for user ".$uid." ".sizeof($posts)." items", LOGGER_DEBUG); + + if (count($posts)) { + foreach ($posts as $post) { + if ($post->id_str > $lastid) + $lastid = $post->id_str; + + if ($first_time) + continue; + + $postarray = twitter_createpost($a, $uid, $post, $self, $create_user, true); + + if (trim($postarray['body']) == "") + continue; + + $item = item_store($postarray); + + logger('twitter_fetchhometimeline: User '.$self["nick"].' posted home timeline item '.$item); + + if ($item != 0) + twitter_checknotification($a, $uid, $own_id, $item, $postarray); + + } + } + set_pconfig($uid, 'twitter', 'lasthometimelineid', $lastid); + + // Fetching mentions + $lastid = get_pconfig($uid, 'twitter', 'lastmentionid'); + + $first_time = ($lastid == ""); + + if ($lastid <> "") + $parameters["since_id"] = $lastid; + + $items = $connection->get('statuses/mentions_timeline', $parameters); + + if (!is_array($items)) { + logger("twitter_fetchhometimeline: Error fetching mentions: ".print_r($items, true), LOGGER_DEBUG); + return; + } + + $posts = array_reverse($items); + + logger("twitter_fetchhometimeline: Fetching mentions for user ".$uid." ".sizeof($posts)." items", LOGGER_DEBUG); + + if (count($posts)) { + foreach ($posts as $post) { + if ($post->id_str > $lastid) + $lastid = $post->id_str; + + if ($first_time) + continue; + + $postarray = twitter_createpost($a, $uid, $post, $self, false, false); + + if (trim($postarray['body']) == "") + continue; + + $item = item_store($postarray); + + logger('twitter_fetchhometimeline: User '.$self["nick"].' posted mention timeline item '.$item); + + if ($item == 0) { + $r = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1", + dbesc($postarray['uri']), + intval($uid) + ); + if (count($r)) + $item = $r[0]['id']; + } + + 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'], + 'source_photo' => $postarray['author-avatar'], + 'verb' => ACTIVITY_TAG, + 'otype' => 'item' + )); + } + } + } + + set_pconfig($uid, 'twitter', 'lastmentionid', $lastid); +} + +function twitter_fetch_own_contact($a, $uid) { + $ckey = get_config('twitter', 'consumerkey'); + $csecret = get_config('twitter', 'consumersecret'); + $otoken = get_pconfig($uid, 'twitter', 'oauthtoken'); + $osecret = get_pconfig($uid, 'twitter', 'oauthsecret'); + + $own_id = get_pconfig($uid, 'twitter', 'own_id'); + + $contact_id = 0; + + if ($own_id == "") { + require_once('library/twitteroauth.php'); + + $connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret); + + // Fetching user data + $user = $connection->get('account/verify_credentials'); + + set_pconfig($uid, 'twitter', 'own_id', $user->id_str); + + $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)); + if(count($r)) + $contact_id = $r[0]["id"]; + else + del_pconfig($uid, 'twitter', 'own_id'); + + } + + return($contact_id); +} + +function twitter_is_retweet($a, $uid, $body) { + $body = trim($body); + + // Skip if it isn't a pure repeated messages + // Does it start with a share? + if (strpos($body, "[share") > 0) + return(false); + + // Does it end with a share? + if (strlen($body) > (strrpos($body, "[/share]") + 8)) + return(false); + + $attributes = preg_replace("/\[share(.*?)\]\s?(.*?)\s?\[\/share\]\s?/ism","$1",$body); + // Skip if there is no shared message in there + if ($body == $attributes) + return(false); + + $link = ""; + preg_match("/link='(.*?)'/ism", $attributes, $matches); + if ($matches[1] != "") + $link = $matches[1]; + + preg_match('/link="(.*?)"/ism', $attributes, $matches); + if ($matches[1] != "") + $link = $matches[1]; + + $id = preg_replace("=https?://twitter.com/(.*)/status/(.*)=ism", "$2", $link); + if ($id == $link) + return(false); + + logger('twitter_is_retweet: Retweeting id '.$id.' for user '.$uid, LOGGER_DEBUG); + + $ckey = get_config('twitter', 'consumerkey'); + $csecret = get_config('twitter', 'consumersecret'); + $otoken = get_pconfig($uid, 'twitter', 'oauthtoken'); + $osecret = get_pconfig($uid, 'twitter', 'oauthsecret'); + + require_once('library/twitteroauth.php'); + $connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret); + + $result = $connection->post('statuses/retweet/'.$id); + + logger('twitter_is_retweet: result '.print_r($result, true), LOGGER_DEBUG); + + return(!isset($result->errors)); +} + +?>