twitter/twitter.php

   1 <?php
   2 /**
   3  * Name: Twitter Connector
   4  * Description: Bidirectional (posting, relaying and reading) connector for Twitter.
   5  * Version: 1.1.0
   6  * Author: Tobias Diekershoff <https://f.diekershoff.de/profile/tobias>
   7  * Author: Michael Vogel <https://pirati.ca/profile/heluecht>
   8  * Maintainer: Hypolite Petovan <https://friendica.mrpetovan.com/profile/hypolite>
   9  *
  10  * Copyright (c) 2011-2013 Tobias Diekershoff, Michael Vogel, Hypolite Petovan
  11  * All rights reserved.
  12  *
  13  * Redistribution and use in source and binary forms, with or without
  14  * modification, are permitted provided that the following conditions are met:
  15  *    * Redistributions of source code must retain the above copyright notice,
  16  *     this list of conditions and the following disclaimer.
  17  *    * Redistributions in binary form must reproduce the above
  18  *    * copyright notice, this list of conditions and the following disclaimer in
  19  *      the documentation and/or other materials provided with the distribution.
  20  *    * Neither the name of the <organization> nor the names of its contributors
  21  *      may be used to endorse or promote products derived from this software
  22  *      without specific prior written permission.
  23  *
  24  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
  25  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
  26  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
  27  * DISCLAIMED. IN NO EVENT SHALL <COPYRIGHT HOLDER> BE LIABLE FOR ANY DIRECT,
  28  * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
  29  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  30  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
  31  * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
  32  * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
  33  * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  34  *
  35  */
  36 /*   Twitter Addon for Friendica
  37  *
  38  *   Author: Tobias Diekershoff
  39  *           tobias.diekershoff@gmx.net
  40  *
  41  *   License:3-clause BSD license
  42  *
  43  *   Configuration:
  44  *     To use this addon you need a OAuth Consumer key pair (key & secret)
  45  *     you can get it from Twitter at https://twitter.com/apps
  46  *
  47  *     Register your Friendica site as "Client" application with "Read & Write" access
  48  *     we do not need "Twitter as login". When you've registered the app you get the
  49  *     OAuth Consumer key and secret pair for your application/site.
  50  *
  51  *     Add this key pair to your global config/addon.ini.php or use the admin panel.
  52  *
  53  *     [twitter]
  54  *     consumerkey = your consumer_key here
  55  *     consumersecret = your consumer_secret here
  56  *
  57  *     To activate the addon itself add it to the [system] addon
  58  *     setting. After this, your user can configure their Twitter account settings
  59  *     from "Settings -> Addon Settings".
  60  *
  61  *     Requirements: PHP5, curl
  62  */
  63
  64 use Abraham\TwitterOAuth\TwitterOAuth;
  65 use Abraham\TwitterOAuth\TwitterOAuthException;
  66 use Friendica\App;
  67 use Friendica\Content\OEmbed;
  68 use Friendica\Content\Text\Plaintext;
  69 use Friendica\Core\Addon;
  70 use Friendica\Core\Config;
  71 use Friendica\Core\L10n;
  72 use Friendica\Core\PConfig;
  73 use Friendica\Core\Worker;
  74 use Friendica\Database\DBA;
  75 use Friendica\Model\Contact;
  76 use Friendica\Model\Conversation;
  77 use Friendica\Model\GContact;
  78 use Friendica\Model\Group;
  79 use Friendica\Model\Item;
  80 use Friendica\Model\ItemContent;
  81 use Friendica\Model\Queue;
  82 use Friendica\Model\User;
  83 use Friendica\Object\Image;
  84 use Friendica\Util\DateTimeFormat;
  85 use Friendica\Util\Network;
  86
  87 require_once 'boot.php';
  88 require_once 'include/dba.php';
  89 require_once 'include/enotify.php';
  90 require_once 'include/text.php';
  91
  92 require_once __DIR__ . DIRECTORY_SEPARATOR . 'vendor' . DIRECTORY_SEPARATOR . 'autoload.php';
  93
  94 define('TWITTER_DEFAULT_POLL_INTERVAL', 5); // given in minutes
  95
  96 function twitter_install()
  97 {
  98         //  we need some hooks, for the configuration and for sending tweets
  99         Addon::registerHook('load_config'            , __FILE__, 'twitter_load_config');
 100         Addon::registerHook('connector_settings'     , __FILE__, 'twitter_settings');
 101         Addon::registerHook('connector_settings_post', __FILE__, 'twitter_settings_post');
 102         Addon::registerHook('post_local'             , __FILE__, 'twitter_post_local');
 103         Addon::registerHook('notifier_normal'        , __FILE__, 'twitter_post_hook');
 104         Addon::registerHook('jot_networks'           , __FILE__, 'twitter_jot_nets');
 105         Addon::registerHook('cron'                   , __FILE__, 'twitter_cron');
 106         Addon::registerHook('queue_predeliver'       , __FILE__, 'twitter_queue_hook');
 107         Addon::registerHook('follow'                 , __FILE__, 'twitter_follow');
 108         Addon::registerHook('expire'                 , __FILE__, 'twitter_expire');
 109         Addon::registerHook('prepare_body'           , __FILE__, 'twitter_prepare_body');
 110         Addon::registerHook('check_item_notification', __FILE__, 'twitter_check_item_notification');
 111         logger("installed twitter");
 112 }
 113
 114 function twitter_uninstall()
 115 {
 116         Addon::unregisterHook('load_config'            , __FILE__, 'twitter_load_config');
 117         Addon::unregisterHook('connector_settings'     , __FILE__, 'twitter_settings');
 118         Addon::unregisterHook('connector_settings_post', __FILE__, 'twitter_settings_post');
 119         Addon::unregisterHook('post_local'             , __FILE__, 'twitter_post_local');
 120         Addon::unregisterHook('notifier_normal'        , __FILE__, 'twitter_post_hook');
 121         Addon::unregisterHook('jot_networks'           , __FILE__, 'twitter_jot_nets');
 122         Addon::unregisterHook('cron'                   , __FILE__, 'twitter_cron');
 123         Addon::unregisterHook('queue_predeliver'       , __FILE__, 'twitter_queue_hook');
 124         Addon::unregisterHook('follow'                 , __FILE__, 'twitter_follow');
 125         Addon::unregisterHook('expire'                 , __FILE__, 'twitter_expire');
 126         Addon::unregisterHook('prepare_body'           , __FILE__, 'twitter_prepare_body');
 127         Addon::unregisterHook('check_item_notification', __FILE__, 'twitter_check_item_notification');
 128
 129         // old setting - remove only
 130         Addon::unregisterHook('post_local_end'     , __FILE__, 'twitter_post_hook');
 131         Addon::unregisterHook('addon_settings'     , __FILE__, 'twitter_settings');
 132         Addon::unregisterHook('addon_settings_post', __FILE__, 'twitter_settings_post');
 133 }
 134
 135 function twitter_load_config(App $a)
 136 {
 137         $a->loadConfigFile(__DIR__ . '/config/twitter.ini.php');
 138 }
 139
 140 function twitter_check_item_notification(App $a, array &$notification_data)
 141 {
 142         $own_id = PConfig::get($notification_data["uid"], 'twitter', 'own_id');
 143
 144         $own_user = q("SELECT `url` FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1",
 145                         intval($notification_data["uid"]),
 146                         DBA::escape("twitter::".$own_id)
 147         );
 148
 149         if ($own_user) {
 150                 $notification_data["profiles"][] = $own_user[0]["url"];
 151         }
 152 }
 153
 154 function twitter_follow(App $a, array &$contact)
 155 {
 156         logger("twitter_follow: Check if contact is twitter contact. " . $contact["url"], LOGGER_DEBUG);
 157
 158         if (!strstr($contact["url"], "://twitter.com") && !strstr($contact["url"], "@twitter.com")) {
 159                 return;
 160         }
 161
 162         // contact seems to be a twitter contact, so continue
 163         $nickname = preg_replace("=https?://twitter.com/(.*)=ism", "$1", $contact["url"]);
 164         $nickname = str_replace("@twitter.com", "", $nickname);
 165
 166         $uid = $a->user["uid"];
 167
 168         $ckey = Config::get('twitter', 'consumerkey');
 169         $csecret = Config::get('twitter', 'consumersecret');
 170         $otoken = PConfig::get($uid, 'twitter', 'oauthtoken');
 171         $osecret = PConfig::get($uid, 'twitter', 'oauthsecret');
 172
 173         // If the addon is not configured (general or for this user) quit here
 174         if (empty($ckey) || empty($csecret) || empty($otoken) || empty($osecret)) {
 175                 $contact = false;
 176                 return;
 177         }
 178
 179         $connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret);
 180         $connection->post('friendships/create', ['screen_name' => $nickname]);
 181
 182         twitter_fetchuser($a, $uid, $nickname);
 183
 184         $r = q("SELECT name,nick,url,addr,batch,notify,poll,request,confirm,poco,photo,priority,network,alias,pubkey
 185                 FROM `contact` WHERE `uid` = %d AND `nick` = '%s'",
 186                                 intval($uid),
 187                                 DBA::escape($nickname));
 188         if (DBA::isResult($r)) {
 189                 $contact["contact"] = $r[0];
 190         }
 191 }
 192
 193 function twitter_jot_nets(App $a, &$b)
 194 {
 195         if (!local_user()) {
 196                 return;
 197         }
 198
 199         $tw_post = PConfig::get(local_user(), 'twitter', 'post');
 200         if (intval($tw_post) == 1) {
 201                 $tw_defpost = PConfig::get(local_user(), 'twitter', 'post_by_default');
 202                 $selected = ((intval($tw_defpost) == 1) ? ' checked="checked" ' : '');
 203                 $b .= '<div class="profile-jot-net"><input type="checkbox" name="twitter_enable"' . $selected . ' value="1" /> '
 204                         . L10n::t('Post to Twitter') . '</div>';
 205         }
 206 }
 207
 208 function twitter_settings_post(App $a)
 209 {
 210         if (!local_user()) {
 211                 return;
 212         }
 213         // don't check twitter settings if twitter submit button is not clicked
 214         if (empty($_POST['twitter-disconnect']) && empty($_POST['twitter-submit'])) {
 215                 return;
 216         }
 217
 218         if (!empty($_POST['twitter-disconnect'])) {
 219                 /*               * *
 220                  * if the twitter-disconnect checkbox is set, clear the OAuth key/secret pair
 221                  * from the user configuration
 222                  */
 223                 PConfig::delete(local_user(), 'twitter', 'consumerkey');
 224                 PConfig::delete(local_user(), 'twitter', 'consumersecret');
 225                 PConfig::delete(local_user(), 'twitter', 'oauthtoken');
 226                 PConfig::delete(local_user(), 'twitter', 'oauthsecret');
 227                 PConfig::delete(local_user(), 'twitter', 'post');
 228                 PConfig::delete(local_user(), 'twitter', 'post_by_default');
 229                 PConfig::delete(local_user(), 'twitter', 'lastid');
 230                 PConfig::delete(local_user(), 'twitter', 'mirror_posts');
 231                 PConfig::delete(local_user(), 'twitter', 'import');
 232                 PConfig::delete(local_user(), 'twitter', 'create_user');
 233                 PConfig::delete(local_user(), 'twitter', 'own_id');
 234         } else {
 235                 if (isset($_POST['twitter-pin'])) {
 236                         //  if the user supplied us with a PIN from Twitter, let the magic of OAuth happen
 237                         logger('got a Twitter PIN');
 238                         $ckey    = Config::get('twitter', 'consumerkey');
 239                         $csecret = Config::get('twitter', 'consumersecret');
 240                         //  the token and secret for which the PIN was generated were hidden in the settings
 241                         //  form as token and token2, we need a new connection to Twitter using these token
 242                         //  and secret to request a Access Token with the PIN
 243                         try {
 244                                 if (empty($_POST['twitter-pin'])) {
 245                                         throw new Exception(L10n::t('You submitted an empty PIN, please Sign In with Twitter again to get a new one.'));
 246                                 }
 247
 248                                 $connection = new TwitterOAuth($ckey, $csecret, $_POST['twitter-token'], $_POST['twitter-token2']);
 249                                 $token = $connection->oauth("oauth/access_token", ["oauth_verifier" => $_POST['twitter-pin']]);
 250                                 //  ok, now that we have the Access Token, save them in the user config
 251                                 PConfig::set(local_user(), 'twitter', 'oauthtoken', $token['oauth_token']);
 252                                 PConfig::set(local_user(), 'twitter', 'oauthsecret', $token['oauth_token_secret']);
 253                                 PConfig::set(local_user(), 'twitter', 'post', 1);
 254                         } catch(Exception $e) {
 255                                 info($e->getMessage());
 256                         } catch(TwitterOAuthException $e) {
 257                                 info($e->getMessage());
 258                         }
 259                         //  reload the Addon Settings page, if we don't do it see Bug #42
 260                         goaway('settings/connectors');
 261                 } else {
 262                         //  if no PIN is supplied in the POST variables, the user has changed the setting
 263                         //  to post a tweet for every new __public__ posting to the wall
 264                         PConfig::set(local_user(), 'twitter', 'post', intval($_POST['twitter-enable']));
 265                         PConfig::set(local_user(), 'twitter', 'post_by_default', intval($_POST['twitter-default']));
 266                         PConfig::set(local_user(), 'twitter', 'mirror_posts', intval($_POST['twitter-mirror']));
 267                         PConfig::set(local_user(), 'twitter', 'import', intval($_POST['twitter-import']));
 268                         PConfig::set(local_user(), 'twitter', 'create_user', intval($_POST['twitter-create_user']));
 269
 270                         if (!intval($_POST['twitter-mirror'])) {
 271                                 PConfig::delete(local_user(), 'twitter', 'lastid');
 272                         }
 273
 274                         info(L10n::t('Twitter settings updated.') . EOL);
 275                 }
 276         }
 277 }
 278
 279 function twitter_settings(App $a, &$s)
 280 {
 281         if (!local_user()) {
 282                 return;
 283         }
 284         $a->page['htmlhead'] .= '<link rel="stylesheet"  type="text/css" href="' . $a->get_baseurl() . '/addon/twitter/twitter.css' . '" media="all" />' . "\r\n";
 285         /*       * *
 286          * 1) Check that we have global consumer key & secret
 287          * 2) If no OAuthtoken & stuff is present, generate button to get some
 288          * 3) Checkbox for "Send public notices (280 chars only)
 289          */
 290         $ckey    = Config::get('twitter', 'consumerkey');
 291         $csecret = Config::get('twitter', 'consumersecret');
 292         $otoken  = PConfig::get(local_user(), 'twitter', 'oauthtoken');
 293         $osecret = PConfig::get(local_user(), 'twitter', 'oauthsecret');
 294
 295         $enabled            = intval(PConfig::get(local_user(), 'twitter', 'post'));
 296         $defenabled         = intval(PConfig::get(local_user(), 'twitter', 'post_by_default'));
 297         $mirrorenabled      = intval(PConfig::get(local_user(), 'twitter', 'mirror_posts'));
 298         $importenabled      = intval(PConfig::get(local_user(), 'twitter', 'import'));
 299         $create_userenabled = intval(PConfig::get(local_user(), 'twitter', 'create_user'));
 300
 301         $css = (($enabled) ? '' : '-disabled');
 302
 303         $s .= '<span id="settings_twitter_inflated" class="settings-block fakelink" style="display: block;" onclick="openClose(\'settings_twitter_expanded\'); openClose(\'settings_twitter_inflated\');">';
 304         $s .= '<img class="connector' . $css . '" src="images/twitter.png" /><h3 class="connector">' . L10n::t('Twitter Import/Export/Mirror') . '</h3>';
 305         $s .= '</span>';
 306         $s .= '<div id="settings_twitter_expanded" class="settings-block" style="display: none;">';
 307         $s .= '<span class="fakelink" onclick="openClose(\'settings_twitter_expanded\'); openClose(\'settings_twitter_inflated\');">';
 308         $s .= '<img class="connector' . $css . '" src="images/twitter.png" /><h3 class="connector">' . L10n::t('Twitter Import/Export/Mirror') . '</h3>';
 309         $s .= '</span>';
 310
 311         if ((!$ckey) && (!$csecret)) {
 312                 /* no global consumer keys
 313                  * display warning and skip personal config
 314                  */
 315                 $s .= '<p>' . L10n::t('No consumer key pair for Twitter found. Please contact your site administrator.') . '</p>';
 316         } else {
 317                 // ok we have a consumer key pair now look into the OAuth stuff
 318                 if ((!$otoken) && (!$osecret)) {
 319                         /* the user has not yet connected the account to twitter...
 320                          * get a temporary OAuth key/secret pair and display a button with
 321                          * which the user can request a PIN to connect the account to a
 322                          * account at Twitter.
 323                          */
 324                         $connection = new TwitterOAuth($ckey, $csecret);
 325                         try {
 326                                 $result = $connection->oauth('oauth/request_token', ['oauth_callback' => 'oob']);
 327                                 $s .= '<p>' . L10n::t('At this Friendica instance the Twitter addon was enabled but you have not yet connected your account to your Twitter account. To do so click the button below to get a PIN from Twitter which you have to copy into the input box below and submit the form. Only your <strong>public</strong> posts will be posted to Twitter.') . '</p>';
 328                                 $s .= '<a href="' . $connection->url('oauth/authorize', ['oauth_token' => $result['oauth_token']]) . '" target="_twitter"><img src="addon/twitter/lighter.png" alt="' . L10n::t('Log in with Twitter') . '"></a>';
 329                                 $s .= '<div id="twitter-pin-wrapper">';
 330                                 $s .= '<label id="twitter-pin-label" for="twitter-pin">' . L10n::t('Copy the PIN from Twitter here') . '</label>';
 331                                 $s .= '<input id="twitter-pin" type="text" name="twitter-pin" />';
 332                                 $s .= '<input id="twitter-token" type="hidden" name="twitter-token" value="' . $result['oauth_token'] . '" />';
 333                                 $s .= '<input id="twitter-token2" type="hidden" name="twitter-token2" value="' . $result['oauth_token_secret'] . '" />';
 334                                 $s .= '</div><div class="clear"></div>';
 335                                 $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="twitter-submit" class="settings-submit" value="' . L10n::t('Save Settings') . '" /></div>';
 336                         } catch (TwitterOAuthException $e) {
 337                                 $s .= '<p>' . L10n::t('An error occured: ') . $e->getMessage() . '</p>';
 338                         }
 339                 } else {
 340                         /*                       * *
 341                          *  we have an OAuth key / secret pair for the user
 342                          *  so let's give a chance to disable the postings to Twitter
 343                          */
 344                         $connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret);
 345                         try {
 346                                 $details = $connection->get('account/verify_credentials');
 347
 348                                 $field_checkbox = get_markup_template('field_checkbox.tpl');
 349
 350                                 $s .= '<div id="twitter-info" >
 351                                         <p>' . L10n::t('Currently connected to: ') . '<a href="https://twitter.com/' . $details->screen_name . '" target="_twitter">' . $details->screen_name . '</a>
 352                                                 <button type="submit" name="twitter-disconnect" value="1">' . L10n::t('Disconnect') . '</button>
 353                                         </p>
 354                                         <p id="twitter-info-block">
 355                                                 <a href="https://twitter.com/' . $details->screen_name . '" target="_twitter"><img id="twitter-avatar" src="' . $details->profile_image_url . '" /></a>
 356                                                 <em>' . $details->description . '</em>
 357                                         </p>
 358                                 </div>';
 359                                 $s .= '<div class="clear"></div>';
 360
 361                                 $s .= replace_macros($field_checkbox, [
 362                                         '$field' => ['twitter-enable', L10n::t('Allow posting to Twitter'), $enabled, L10n::t('If enabled all your <strong>public</strong> 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.')]
 363                                 ]);
 364                                 if ($a->user['hidewall']) {
 365                                         $s .= '<p>' . L10n::t('<strong>Note</strong>: Due to your privacy settings (<em>Hide your profile details from unknown viewers?</em>) 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.') . '</p>';
 366                                 }
 367                                 $s .= replace_macros($field_checkbox, [
 368                                         '$field' => ['twitter-default', L10n::t('Send public postings to Twitter by default'), $defenabled, '']
 369                                 ]);
 370                                 $s .= replace_macros($field_checkbox, [
 371                                         '$field' => ['twitter-mirror', L10n::t('Mirror all posts from twitter that are no replies'), $mirrorenabled, '']
 372                                 ]);
 373                                 $s .= replace_macros($field_checkbox, [
 374                                         '$field' => ['twitter-import', L10n::t('Import the remote timeline'), $importenabled, '']
 375                                 ]);
 376                                 $s .= replace_macros($field_checkbox, [
 377                                         '$field' => ['twitter-create_user', L10n::t('Automatically create contacts'), $create_userenabled, L10n::t('This will automatically create a contact in Friendica as soon as you receive a message from an existing contact via the Twitter network. If you do not enable this, you need to manually add those Twitter contacts in Friendica from whom you would like to see posts here. However if enabled, you cannot merely remove a twitter contact from the Friendica contact list, as it will recreate this contact when they post again.')]
 378                                 ]);
 379                                 $s .= '<div class="clear"></div>';
 380                                 $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="twitter-submit" class="settings-submit" value="' . L10n::t('Save Settings') . '" /></div>';
 381                         } catch (TwitterOAuthException $e) {
 382                                 $s .= '<p>' . L10n::t('An error occured: ') . $e->getMessage() . '</p>';
 383                         }
 384                 }
 385         }
 386         $s .= '</div><div class="clear"></div>';
 387 }
 388
 389 function twitter_post_local(App $a, array &$b)
 390 {
 391         if ($b['edit']) {
 392                 return;
 393         }
 394
 395         if (!local_user() || (local_user() != $b['uid'])) {
 396                 return;
 397         }
 398
 399         $twitter_post = intval(PConfig::get(local_user(), 'twitter', 'post'));
 400         $twitter_enable = (($twitter_post && x($_REQUEST, 'twitter_enable')) ? intval($_REQUEST['twitter_enable']) : 0);
 401
 402         // if API is used, default to the chosen settings
 403         if ($b['api_source'] && intval(PConfig::get(local_user(), 'twitter', 'post_by_default'))) {
 404                 $twitter_enable = 1;
 405         }
 406
 407         if (!$twitter_enable) {
 408                 return;
 409         }
 410
 411         if (strlen($b['postopts'])) {
 412                 $b['postopts'] .= ',';
 413         }
 414
 415         $b['postopts'] .= 'twitter';
 416 }
 417
 418 function twitter_action(App $a, $uid, $pid, $action)
 419 {
 420         $ckey = Config::get('twitter', 'consumerkey');
 421         $csecret = Config::get('twitter', 'consumersecret');
 422         $otoken = PConfig::get($uid, 'twitter', 'oauthtoken');
 423         $osecret = PConfig::get($uid, 'twitter', 'oauthsecret');
 424
 425         $connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret);
 426
 427         $post = ['id' => $pid];
 428
 429         logger("twitter_action '" . $action . "' ID: " . $pid . " data: " . print_r($post, true), LOGGER_DATA);
 430
 431         switch ($action) {
 432                 case "delete":
 433                         // To-Do: $result = $connection->post('statuses/destroy', $post);
 434                         $result = [];
 435                         break;
 436                 case "like":
 437                         $result = $connection->post('favorites/create', $post);
 438                         break;
 439                 case "unlike":
 440                         $result = $connection->post('favorites/destroy', $post);
 441                         break;
 442                 default:
 443                         logger('Unhandled action ' . $action, LOGGER_DEBUG);
 444                         $result = [];
 445         }
 446         logger("twitter_action '" . $action . "' send, result: " . print_r($result, true), LOGGER_DEBUG);
 447 }
 448
 449 function twitter_post_hook(App $a, array &$b)
 450 {
 451         // Post to Twitter
 452         if (!PConfig::get($b["uid"], 'twitter', 'import')
 453                 && ($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited']))) {
 454                 return;
 455         }
 456
 457         if ($b['parent'] != $b['id']) {
 458                 logger("twitter_post_hook: parameter " . print_r($b, true), LOGGER_DATA);
 459
 460                 // Looking if its a reply to a twitter post
 461                 if ((substr($b["parent-uri"], 0, 9) != "twitter::")
 462                         && (substr($b["extid"], 0, 9) != "twitter::")
 463                         && (substr($b["thr-parent"], 0, 9) != "twitter::"))
 464                 {
 465                         logger("twitter_post_hook: no twitter post " . $b["parent"]);
 466                         return;
 467                 }
 468
 469                 $condition = ['uri' => $b["thr-parent"], 'uid' => $b["uid"]];
 470                 $orig_post = Item::selectFirst([], $condition);
 471                 if (!DBA::isResult($orig_post)) {
 472                         logger("twitter_post_hook: no parent found " . $b["thr-parent"]);
 473                         return;
 474                 } else {
 475                         $iscomment = true;
 476                 }
 477
 478
 479                 $nicknameplain = preg_replace("=https?://twitter.com/(.*)=ism", "$1", $orig_post["author-link"]);
 480                 $nickname = "@[url=" . $orig_post["author-link"] . "]" . $nicknameplain . "[/url]";
 481                 $nicknameplain = "@" . $nicknameplain;
 482
 483                 logger("twitter_post_hook: comparing " . $nickname . " and " . $nicknameplain . " with " . $b["body"], LOGGER_DEBUG);
 484                 if ((strpos($b["body"], $nickname) === false) && (strpos($b["body"], $nicknameplain) === false)) {
 485                         $b["body"] = $nickname . " " . $b["body"];
 486                 }
 487
 488                 logger("twitter_post_hook: parent found " . print_r($orig_post, true), LOGGER_DATA);
 489         } else {
 490                 $iscomment = false;
 491
 492                 if ($b['private'] || !strstr($b['postopts'], 'twitter')) {
 493                         return;
 494                 }
 495
 496                 // Dont't post if the post doesn't belong to us.
 497                 // This is a check for forum postings
 498                 $self = DBA::selectFirst('contact', ['id'], ['uid' => $b['uid'], 'self' => true]);
 499                 if ($b['contact-id'] != $self['id']) {
 500                         return;
 501                 }
 502         }
 503
 504         if (($b['verb'] == ACTIVITY_POST) && $b['deleted']) {
 505                 twitter_action($a, $b["uid"], substr($orig_post["uri"], 9), "delete");
 506         }
 507
 508         if ($b['verb'] == ACTIVITY_LIKE) {
 509                 logger("twitter_post_hook: parameter 2 " . substr($b["thr-parent"], 9), LOGGER_DEBUG);
 510                 if ($b['deleted']) {
 511                         twitter_action($a, $b["uid"], substr($b["thr-parent"], 9), "unlike");
 512                 } else {
 513                         twitter_action($a, $b["uid"], substr($b["thr-parent"], 9), "like");
 514                 }
 515
 516                 return;
 517         }
 518
 519         if ($b['deleted'] || ($b['created'] !== $b['edited'])) {
 520                 return;
 521         }
 522
 523         // if post comes from twitter don't send it back
 524         if ($b['extid'] == NETWORK_TWITTER) {
 525                 return;
 526         }
 527
 528         if ($b['app'] == "Twitter") {
 529                 return;
 530         }
 531
 532         logger('twitter post invoked');
 533
 534         PConfig::load($b['uid'], 'twitter');
 535
 536         $ckey    = Config::get('twitter', 'consumerkey');
 537         $csecret = Config::get('twitter', 'consumersecret');
 538         $otoken  = PConfig::get($b['uid'], 'twitter', 'oauthtoken');
 539         $osecret = PConfig::get($b['uid'], 'twitter', 'oauthsecret');
 540
 541         if ($ckey && $csecret && $otoken && $osecret) {
 542                 logger('twitter: we have customer key and oauth stuff, going to send.', LOGGER_DEBUG);
 543
 544                 // If it's a repeated message from twitter then do a native retweet and exit
 545                 if (twitter_is_retweet($a, $b['uid'], $b['body'])) {
 546                         return;
 547                 }
 548
 549                 $connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret);
 550
 551                 // Set the timeout for upload to 30 seconds
 552                 $connection->setTimeouts(10, 30);
 553
 554                 $max_char = 280;
 555                 $msgarr = ItemContent::getPlaintextPost($b, $max_char, true, 8);
 556                 $msg = $msgarr["text"];
 557
 558                 if (($msg == "") && isset($msgarr["title"])) {
 559                         $msg = Plaintext::shorten($msgarr["title"], $max_char - 50);
 560                 }
 561
 562                 $image = "";
 563
 564                 if (isset($msgarr["url"]) && ($msgarr["type"] != "photo")) {
 565                         $msg .= "\n" . $msgarr["url"];
 566                         $url_added = true;
 567                 } else {
 568                         $url_added = false;
 569                 }
 570
 571                 if (isset($msgarr["image"]) && ($msgarr["type"] != "video")) {
 572                         $image = $msgarr["image"];
 573                 }
 574
 575                 if (empty($msg)) {
 576                         return;
 577                 }
 578
 579                 // and now tweet it :-)
 580                 $post = [];
 581
 582                 if (!empty($image)) {
 583                         try {
 584                                 $img_str = Network::fetchUrl($image);
 585
 586                                 $tempfile = tempnam(get_temppath(), 'cache');
 587                                 file_put_contents($tempfile, $img_str);
 588
 589                                 $media = $connection->upload('media/upload', ['media' => $tempfile]);
 590
 591                                 unlink($tempfile);
 592
 593                                 $post['media_ids'] = $media->media_id_string;
 594                         } catch (Exception $e) {
 595                                 logger('Exception when trying to send to Twitter: ' . $e->getMessage());
 596
 597                                 // Workaround: Remove the picture link so that the post can be reposted without it
 598                                 // When there is another url already added, a second url would be superfluous.
 599                                 if (!$url_added) {
 600                                         $msg .= "\n" . $image;
 601                                 }
 602
 603                                 $image = "";
 604                         }
 605                 }
 606
 607                 $post['status'] = $msg;
 608
 609                 if ($iscomment) {
 610                         $post["in_reply_to_status_id"] = substr($orig_post["uri"], 9);
 611                 }
 612
 613                 $url = 'statuses/update';
 614                 $result = $connection->post($url, $post);
 615                 logger('twitter_post send, result: ' . print_r($result, true), LOGGER_DEBUG);
 616
 617                 if (!empty($result->source)) {
 618                         Config::set("twitter", "application_name", strip_tags($result->source));
 619                 }
 620
 621                 if (!empty($result->errors)) {
 622                         logger('Send to Twitter failed: "' . print_r($result->errors, true) . '"');
 623
 624                         $r = q("SELECT `id` FROM `contact` WHERE `uid` = %d AND `self`", intval($b['uid']));
 625                         if (DBA::isResult($r)) {
 626                                 $a->contact = $r[0]["id"];
 627                         }
 628
 629                         $s = serialize(['url' => $url, 'item' => $b['id'], 'post' => $post]);
 630
 631                         Queue::add($a->contact, NETWORK_TWITTER, $s);
 632                         notice(L10n::t('Twitter post failed. Queued for retry.') . EOL);
 633                 } elseif ($iscomment) {
 634                         logger('twitter_post: Update extid ' . $result->id_str . " for post id " . $b['id']);
 635                         Item::update(['extid' => "twitter::" . $result->id_str], ['id' => $b['id']]);
 636                 }
 637         }
 638 }
 639
 640 function twitter_addon_admin_post(App $a)
 641 {
 642         $consumerkey    = x($_POST, 'consumerkey')    ? notags(trim($_POST['consumerkey']))    : '';
 643         $consumersecret = x($_POST, 'consumersecret') ? notags(trim($_POST['consumersecret'])) : '';
 644         Config::set('twitter', 'consumerkey', $consumerkey);
 645         Config::set('twitter', 'consumersecret', $consumersecret);
 646         info(L10n::t('Settings updated.') . EOL);
 647 }
 648
 649 function twitter_addon_admin(App $a, &$o)
 650 {
 651         $t = get_markup_template("admin.tpl", "addon/twitter/");
 652
 653         $o = replace_macros($t, [
 654                 '$submit' => L10n::t('Save Settings'),
 655                 // name, label, value, help, [extra values]
 656                 '$consumerkey' => ['consumerkey', L10n::t('Consumer key'), Config::get('twitter', 'consumerkey'), ''],
 657                 '$consumersecret' => ['consumersecret', L10n::t('Consumer secret'), Config::get('twitter', 'consumersecret'), ''],
 658         ]);
 659 }
 660
 661 function twitter_cron(App $a)
 662 {
 663         $last = Config::get('twitter', 'last_poll');
 664
 665         $poll_interval = intval(Config::get('twitter', 'poll_interval'));
 666         if (!$poll_interval) {
 667                 $poll_interval = TWITTER_DEFAULT_POLL_INTERVAL;
 668         }
 669
 670         if ($last) {
 671                 $next = $last + ($poll_interval * 60);
 672                 if ($next > time()) {
 673                         logger('twitter: poll intervall not reached');
 674                         return;
 675                 }
 676         }
 677         logger('twitter: cron_start');
 678
 679         $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'twitter' AND `k` = 'mirror_posts' AND `v` = '1'");
 680         if (DBA::isResult($r)) {
 681                 foreach ($r as $rr) {
 682                         logger('twitter: fetching for user ' . $rr['uid']);
 683                         Worker::add(PRIORITY_MEDIUM, "addon/twitter/twitter_sync.php", 1, (int) $rr['uid']);
 684                 }
 685         }
 686
 687         $abandon_days = intval(Config::get('system', 'account_abandon_days'));
 688         if ($abandon_days < 1) {
 689                 $abandon_days = 0;
 690         }
 691
 692         $abandon_limit = date(DateTimeFormat::MYSQL, time() - $abandon_days * 86400);
 693
 694         $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'twitter' AND `k` = 'import' AND `v` = '1'");
 695         if (DBA::isResult($r)) {
 696                 foreach ($r as $rr) {
 697                         if ($abandon_days != 0) {
 698                                 $user = q("SELECT `login_date` FROM `user` WHERE uid=%d AND `login_date` >= '%s'", $rr['uid'], $abandon_limit);
 699                                 if (!DBA::isResult($user)) {
 700                                         logger('abandoned account: timeline from user ' . $rr['uid'] . ' will not be imported');
 701                                         continue;
 702                                 }
 703                         }
 704
 705                         logger('twitter: importing timeline from user ' . $rr['uid']);
 706                         Worker::add(PRIORITY_MEDIUM, "addon/twitter/twitter_sync.php", 2, (int) $rr['uid']);
 707                         /*
 708                           // To-Do
 709                           // check for new contacts once a day
 710                           $last_contact_check = PConfig::get($rr['uid'],'pumpio','contact_check');
 711                           if($last_contact_check)
 712                           $next_contact_check = $last_contact_check + 86400;
 713                           else
 714                           $next_contact_check = 0;
 715
 716                           if($next_contact_check <= time()) {
 717                           pumpio_getallusers($a, $rr["uid"]);
 718                           PConfig::set($rr['uid'],'pumpio','contact_check',time());
 719                           }
 720                          */
 721                 }
 722         }
 723
 724         logger('twitter: cron_end');
 725
 726         Config::set('twitter', 'last_poll', time());
 727 }
 728
 729 function twitter_expire(App $a)
 730 {
 731         $days = Config::get('twitter', 'expire');
 732
 733         if ($days == 0) {
 734                 return;
 735         }
 736
 737         $r = DBA::select('item', ['id', 'iaid', 'icid'], ['deleted' => true, 'network' => NETWORK_TWITTER]);
 738         while ($row = DBA::fetch($r)) {
 739                 DBA::delete('item', ['id' => $row['id']]);
 740                 if (!empty($row['iaid']) && !DBA::exists('item', ['iaid' => $row['iaid']])) {
 741                         DBA::delete('item-activity', ['id' => $row['iaid']]);
 742                 }
 743                 if (!empty($row['icid']) && !DBA::exists('item', ['icid' => $row['icid']])) {
 744                         DBA::delete('item-content', ['id' => $row['icid']]);
 745                 }
 746         }
 747         DBA::close($r);
 748
 749         require_once "include/items.php";
 750
 751         logger('twitter_expire: expire_start');
 752
 753         $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'twitter' AND `k` = 'import' AND `v` = '1' ORDER BY RAND()");
 754         if (DBA::isResult($r)) {
 755                 foreach ($r as $rr) {
 756                         logger('twitter_expire: user ' . $rr['uid']);
 757                         Item::expire($rr['uid'], $days, NETWORK_TWITTER, true);
 758                 }
 759         }
 760
 761         logger('twitter_expire: expire_end');
 762 }
 763
 764 function twitter_prepare_body(App $a, array &$b)
 765 {
 766         if ($b["item"]["network"] != NETWORK_TWITTER) {
 767                 return;
 768         }
 769
 770         if ($b["preview"]) {
 771                 $max_char = 280;
 772                 $item = $b["item"];
 773                 $item["plink"] = $a->get_baseurl() . "/display/" . $a->user["nickname"] . "/" . $item["parent"];
 774
 775                 $condition = ['uri' => $item["thr-parent"], 'uid' => local_user()];
 776                 $orig_post = Item::selectFirst(['author-link'], $condition);
 777                 if (DBA::isResult($orig_post)) {
 778                         $nicknameplain = preg_replace("=https?://twitter.com/(.*)=ism", "$1", $orig_post["author-link"]);
 779                         $nickname = "@[url=" . $orig_post["author-link"] . "]" . $nicknameplain . "[/url]";
 780                         $nicknameplain = "@" . $nicknameplain;
 781
 782                         if ((strpos($item["body"], $nickname) === false) && (strpos($item["body"], $nicknameplain) === false)) {
 783                                 $item["body"] = $nickname . " " . $item["body"];
 784                         }
 785                 }
 786
 787                 $msgarr = ItemContent::getPlaintextPost($item, $max_char, true, 8);
 788                 $msg = $msgarr["text"];
 789
 790                 if (isset($msgarr["url"]) && ($msgarr["type"] != "photo")) {
 791                         $msg .= " " . $msgarr["url"];
 792                 }
 793
 794                 if (isset($msgarr["image"])) {
 795                         $msg .= " " . $msgarr["image"];
 796                 }
 797
 798                 $b['html'] = nl2br(htmlspecialchars($msg));
 799         }
 800 }
 801
 802 /**
 803  * @brief Build the item array for the mirrored post
 804  *
 805  * @param App $a Application class
 806  * @param integer $uid User id
 807  * @param object $post Twitter object with the post
 808  *
 809  * @return array item data to be posted
 810  */
 811 function twitter_do_mirrorpost(App $a, $uid, $post)
 812 {
 813         $datarray['api_source'] = true;
 814         $datarray['profile_uid'] = $uid;
 815         $datarray['extid'] = NETWORK_TWITTER;
 816         $datarray['message_id'] = Item::newURI($uid, NETWORK_TWITTER . ':' . $post->id);
 817         $datarray['protocol'] = Conversation::PARCEL_TWITTER;
 818         $datarray['source'] = json_encode($post);
 819         $datarray['title'] = '';
 820
 821         if (!empty($post->retweeted_status)) {
 822                 // We don't support nested shares, so we mustn't show quotes as shares on retweets
 823                 $item = twitter_createpost($a, $uid, $post->retweeted_status, ['id' => 0], false, false, true);
 824
 825                 $datarray['body'] = "\n" . share_header(
 826                         $item['author-name'],
 827                         $item['author-link'],
 828                         $item['author-avatar'],
 829                         '',
 830                         $item['created'],
 831                         $item['plink']
 832                 );
 833
 834                 $datarray['body'] .= $item['body'] . '[/share]';
 835         } else {
 836                 $item = twitter_createpost($a, $uid, $post, ['id' => 0], false, false, false);
 837
 838                 $datarray['body'] = $item['body'];
 839         }
 840
 841         $datarray['source'] = $item['app'];
 842         $datarray['verb'] = $item['verb'];
 843
 844         if (isset($item['location'])) {
 845                 $datarray['location'] = $item['location'];
 846         }
 847
 848         if (isset($item['coord'])) {
 849                 $datarray['coord'] = $item['coord'];
 850         }
 851
 852         return $datarray;
 853 }
 854
 855 function twitter_fetchtimeline(App $a, $uid)
 856 {
 857         $ckey    = Config::get('twitter', 'consumerkey');
 858         $csecret = Config::get('twitter', 'consumersecret');
 859         $otoken  = PConfig::get($uid, 'twitter', 'oauthtoken');
 860         $osecret = PConfig::get($uid, 'twitter', 'oauthsecret');
 861         $lastid  = PConfig::get($uid, 'twitter', 'lastid');
 862
 863         $application_name = Config::get('twitter', 'application_name');
 864
 865         if ($application_name == "") {
 866                 $application_name = $a->get_hostname();
 867         }
 868
 869         $has_picture = false;
 870
 871         require_once 'mod/item.php';
 872         require_once 'include/items.php';
 873         require_once 'mod/share.php';
 874
 875         $connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret);
 876
 877         $parameters = ["exclude_replies" => true, "trim_user" => false, "contributor_details" => true, "include_rts" => true, "tweet_mode" => "extended"];
 878
 879         $first_time = ($lastid == "");
 880
 881         if ($lastid != "") {
 882                 $parameters["since_id"] = $lastid;
 883         }
 884
 885         try {
 886                 $items = $connection->get('statuses/user_timeline', $parameters);
 887         } catch (TwitterOAuthException $e) {
 888                 logger('twitter_fetchtimeline: Error fetching timeline for user ' . $uid . ': ' . $e->getMessage());
 889                 return;
 890         }
 891
 892         if (!is_array($items)) {
 893                 return;
 894         }
 895
 896         $posts = array_reverse($items);
 897
 898         if (count($posts)) {
 899                 foreach ($posts as $post) {
 900                         if ($post->id_str > $lastid) {
 901                                 $lastid = $post->id_str;
 902                                 PConfig::set($uid, 'twitter', 'lastid', $lastid);
 903                         }
 904
 905                         if ($first_time) {
 906                                 continue;
 907                         }
 908
 909                         if (!stristr($post->source, $application_name)) {
 910                                 $_SESSION["authenticated"] = true;
 911                                 $_SESSION["uid"] = $uid;
 912
 913                                 $_REQUEST = twitter_do_mirrorpost($a, $uid, $post);
 914
 915                                 logger('twitter: posting for user ' . $uid);
 916
 917                                 item_post($a);
 918                         }
 919                 }
 920         }
 921         PConfig::set($uid, 'twitter', 'lastid', $lastid);
 922 }
 923
 924 function twitter_queue_hook(App $a)
 925 {
 926         $qi = q("SELECT * FROM `queue` WHERE `network` = '%s'",
 927                 DBA::escape(NETWORK_TWITTER)
 928         );
 929         if (!DBA::isResult($qi)) {
 930                 return;
 931         }
 932
 933         foreach ($qi as $x) {
 934                 if ($x['network'] !== NETWORK_TWITTER) {
 935                         continue;
 936                 }
 937
 938                 logger('twitter_queue: run');
 939
 940                 $r = q("SELECT `user`.* FROM `user` LEFT JOIN `contact` on `contact`.`uid` = `user`.`uid`
 941                         WHERE `contact`.`self` = 1 AND `contact`.`id` = %d LIMIT 1",
 942                         intval($x['cid'])
 943                 );
 944                 if (!DBA::isResult($r)) {
 945                         continue;
 946                 }
 947
 948                 $user = $r[0];
 949
 950                 $ckey    = Config::get('twitter', 'consumerkey');
 951                 $csecret = Config::get('twitter', 'consumersecret');
 952                 $otoken  = PConfig::get($user['uid'], 'twitter', 'oauthtoken');
 953                 $osecret = PConfig::get($user['uid'], 'twitter', 'oauthsecret');
 954
 955                 $success = false;
 956
 957                 if ($ckey && $csecret && $otoken && $osecret) {
 958                         logger('twitter_queue: able to post');
 959
 960                         $z = unserialize($x['content']);
 961
 962                         $connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret);
 963                         $result = $connection->post($z['url'], $z['post']);
 964
 965                         logger('twitter_queue: post result: ' . print_r($result, true), LOGGER_DEBUG);
 966
 967                         if ($result->errors) {
 968                                 logger('twitter_queue: Send to Twitter failed: "' . print_r($result->errors, true) . '"');
 969                         } else {
 970                                 $success = true;
 971                                 Queue::removeItem($x['id']);
 972                         }
 973                 } else {
 974                         logger("twitter_queue: Error getting tokens for user " . $user['uid']);
 975                 }
 976
 977                 if (!$success) {
 978                         logger('twitter_queue: delayed');
 979                         Queue::updateTime($x['id']);
 980                 }
 981         }
 982 }
 983
 984 function twitter_fix_avatar($avatar)
 985 {
 986         $new_avatar = str_replace("_normal.", ".", $avatar);
 987
 988         $info = Image::getInfoFromURL($new_avatar);
 989         if (!$info) {
 990                 $new_avatar = $avatar;
 991         }
 992
 993         return $new_avatar;
 994 }
 995
 996 function twitter_fetch_contact($uid, $data, $create_user)
 997 {
 998         if ($data->id_str == "") {
 999                 return -1;
1000         }
1001
1002         $avatar = twitter_fix_avatar($data->profile_image_url_https);
1003         $url = "https://twitter.com/" . $data->screen_name;
1004         $addr = $data->screen_name . "@twitter.com";
1005
1006         GContact::update(["url" => $url, "network" => NETWORK_TWITTER,
1007                 "photo" => $avatar, "hide" => true,
1008                 "name" => $data->name, "nick" => $data->screen_name,
1009                 "location" => $data->location, "about" => $data->description,
1010                 "addr" => $addr, "generation" => 2]);
1011
1012         $fields = ['url' => $url, 'network' => NETWORK_TWITTER,
1013                 'name' => $data->name, 'nick' => $data->screen_name, 'addr' => $addr,
1014                 'location' => $data->location, 'about' => $data->description];
1015
1016         $cid = Contact::getIdForURL($url, 0, true, $fields);
1017         if (!empty($cid)) {
1018                 DBA::update('contact', $fields, ['id' => $cid]);
1019                 Contact::updateAvatar($avatar, 0, $cid);
1020         }
1021
1022         $contact = DBA::selectFirst('contact', [], ['uid' => $uid, 'alias' => "twitter::" . $data->id_str]);
1023         if (!DBA::isResult($contact) && !$create_user) {
1024                 return 0;
1025         }
1026
1027         if (!DBA::isResult($contact)) {
1028                 // create contact record
1029                 $fields['uid'] = $uid;
1030                 $fields['created'] = DateTimeFormat::utcNow();
1031                 $fields['nurl'] = normalise_link($url);
1032                 $fields['alias'] = 'twitter::' . $data->id_str;
1033                 $fields['poll'] = 'twitter::' . $data->id_str;
1034                 $fields['rel'] = Contact::FRIEND;
1035                 $fields['priority'] = 1;
1036                 $fields['writable'] = true;
1037                 $fields['blocked'] = false;
1038                 $fields['readonly'] = false;
1039                 $fields['pending'] = false;
1040
1041                 if (!DBA::insert('contact', $fields)) {
1042                         return false;
1043                 }
1044
1045                 $contact_id = DBA::lastInsertId();
1046
1047                 Group::addMember(User::getDefaultGroup($uid), $contact_id);
1048
1049                 Contact::updateAvatar($avatar, $uid, $contact_id);
1050         } else {
1051                 if ($contact["readonly"] || $contact["blocked"]) {
1052                         logger("twitter_fetch_contact: Contact '" . $contact["nick"] . "' is blocked or readonly.", LOGGER_DEBUG);
1053                         return -1;
1054                 }
1055
1056                 $contact_id = $contact['id'];
1057
1058                 // update profile photos once every twelve hours as we have no notification of when they change.
1059                 $update_photo = ($contact['avatar-date'] < DateTimeFormat::utc('now -12 hours'));
1060
1061                 // check that we have all the photos, this has been known to fail on occasion
1062                 if (empty($contact['photo']) || empty($contact['thumb']) || empty($contact['micro']) || $update_photo) {
1063                         logger("twitter_fetch_contact: Updating contact " . $data->screen_name, LOGGER_DEBUG);
1064
1065                         Contact::updateAvatar($avatar, $uid, $contact['id']);
1066
1067                         $fields['name-date'] = DateTimeFormat::utcNow();
1068                         $fields['uri-date'] = DateTimeFormat::utcNow();
1069
1070                         DBA::update('contact', $fields, ['id' => $contact['id']]);
1071                 }
1072         }
1073
1074         return $contact_id;
1075 }
1076
1077 function twitter_fetchuser(App $a, $uid, $screen_name = "", $user_id = "")
1078 {
1079         $ckey = Config::get('twitter', 'consumerkey');
1080         $csecret = Config::get('twitter', 'consumersecret');
1081         $otoken = PConfig::get($uid, 'twitter', 'oauthtoken');
1082         $osecret = PConfig::get($uid, 'twitter', 'oauthsecret');
1083
1084         $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
1085                 intval($uid));
1086
1087         if (DBA::isResult($r)) {
1088                 $self = $r[0];
1089         } else {
1090                 return;
1091         }
1092
1093         $parameters = [];
1094
1095         if ($screen_name != "") {
1096                 $parameters["screen_name"] = $screen_name;
1097         }
1098
1099         if ($user_id != "") {
1100                 $parameters["user_id"] = $user_id;
1101         }
1102
1103         // Fetching user data
1104         $connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret);
1105         try {
1106                 $user = $connection->get('users/show', $parameters);
1107         } catch (TwitterOAuthException $e) {
1108                 logger('twitter_fetchuser: Error fetching user ' . $uid . ': ' . $e->getMessage());
1109                 return;
1110         }
1111
1112         if (!is_object($user)) {
1113                 return;
1114         }
1115
1116         $contact_id = twitter_fetch_contact($uid, $user, true);
1117
1118         return $contact_id;
1119 }
1120
1121 function twitter_expand_entities(App $a, $body, $item, $picture)
1122 {
1123         $plain = $body;
1124
1125         $tags_arr = [];
1126
1127         foreach ($item->entities->hashtags AS $hashtag) {
1128                 $url = "#[url=" . $a->get_baseurl() . "/search?tag=" . rawurlencode($hashtag->text) . "]" . $hashtag->text . "[/url]";
1129                 $tags_arr["#" . $hashtag->text] = $url;
1130                 $body = str_replace("#" . $hashtag->text, $url, $body);
1131         }
1132
1133         foreach ($item->entities->user_mentions AS $mention) {
1134                 $url = "@[url=https://twitter.com/" . rawurlencode($mention->screen_name) . "]" . $mention->screen_name . "[/url]";
1135                 $tags_arr["@" . $mention->screen_name] = $url;
1136                 $body = str_replace("@" . $mention->screen_name, $url, $body);
1137         }
1138
1139         if (isset($item->entities->urls)) {
1140                 $type = "";
1141                 $footerurl = "";
1142                 $footerlink = "";
1143                 $footer = "";
1144
1145                 foreach ($item->entities->urls as $url) {
1146                         $plain = str_replace($url->url, '', $plain);
1147
1148                         if ($url->url && $url->expanded_url && $url->display_url) {
1149                                 $expanded_url = Network::finalUrl($url->expanded_url);
1150
1151                                 $oembed_data = OEmbed::fetchURL($expanded_url);
1152
1153                                 if (empty($oembed_data) || empty($oembed_data->type)) {
1154                                         continue;
1155                                 }
1156
1157                                 // Quickfix: Workaround for URL with "[" and "]" in it
1158                                 if (strpos($expanded_url, "[") || strpos($expanded_url, "]")) {
1159                                         $expanded_url = $url->url;
1160                                 }
1161
1162                                 if ($type == "") {
1163                                         $type = $oembed_data->type;
1164                                 }
1165
1166                                 if ($oembed_data->type == "video") {
1167                                         //$body = str_replace($url->url,
1168                                         //              "[video]".$expanded_url."[/video]", $body);
1169                                         //$dontincludemedia = true;
1170                                         $type = $oembed_data->type;
1171                                         $footerurl = $expanded_url;
1172                                         $footerlink = "[url=" . $expanded_url . "]" . $url->display_url . "[/url]";
1173
1174                                         $body = str_replace($url->url, $footerlink, $body);
1175                                         //} elseif (($oembed_data->type == "photo") AND isset($oembed_data->url) AND !$dontincludemedia) {
1176                                 } elseif (($oembed_data->type == "photo") && isset($oembed_data->url)) {
1177                                         $body = str_replace($url->url, "[url=" . $expanded_url . "][img]" . $oembed_data->url . "[/img][/url]", $body);
1178                                         //$dontincludemedia = true;
1179                                 } elseif ($oembed_data->type != "link") {
1180                                         $body = str_replace($url->url, "[url=" . $expanded_url . "]" . $url->display_url . "[/url]", $body);
1181                                 } else {
1182                                         $img_str = Network::fetchUrl($expanded_url, true, $redirects, 4);
1183
1184                                         $tempfile = tempnam(get_temppath(), "cache");
1185                                         file_put_contents($tempfile, $img_str);
1186
1187                                         // See http://php.net/manual/en/function.exif-imagetype.php#79283
1188                                         if (filesize($tempfile) > 11) {
1189                                                 $mime = image_type_to_mime_type(exif_imagetype($tempfile));
1190                                         } else {
1191                                                 $mime = false;
1192                                         }
1193
1194                                         unlink($tempfile);
1195
1196                                         if (substr($mime, 0, 6) == "image/") {
1197                                                 $type = "photo";
1198                                                 $body = str_replace($url->url, "[img]" . $expanded_url . "[/img]", $body);
1199                                                 //$dontincludemedia = true;
1200                                         } else {
1201                                                 $type = $oembed_data->type;
1202                                                 $footerurl = $expanded_url;
1203                                                 $footerlink = "[url=" . $expanded_url . "]" . $url->display_url . "[/url]";
1204
1205                                                 $body = str_replace($url->url, $footerlink, $body);
1206                                         }
1207                                 }
1208                         }
1209                 }
1210
1211                 if ($footerurl != "") {
1212                         $footer = add_page_info($footerurl, false, $picture);
1213                 }
1214
1215                 if (($footerlink != "") && (trim($footer) != "")) {
1216                         $removedlink = trim(str_replace($footerlink, "", $body));
1217
1218                         if (($removedlink == "") || strstr($body, $removedlink)) {
1219                                 $body = $removedlink;
1220                         }
1221
1222                         $body .= $footer;
1223                 }
1224
1225                 if (($footer == "") && ($picture != "")) {
1226                         $body .= "\n\n[img]" . $picture . "[/img]\n";
1227                 } elseif (($footer == "") && ($picture == "")) {
1228                         $body = add_page_info_to_body($body);
1229                 }
1230         }
1231
1232         // it seems as if the entities aren't always covering all mentions. So the rest will be checked here
1233         $tags = get_tags($body);
1234
1235         if (count($tags)) {
1236                 foreach ($tags as $tag) {
1237                         if (strstr(trim($tag), " ")) {
1238                                 continue;
1239                         }
1240
1241                         if (strpos($tag, '#') === 0) {
1242                                 if (strpos($tag, '[url=')) {
1243                                         continue;
1244                                 }
1245
1246                                 // don't link tags that are already embedded in links
1247                                 if (preg_match('/\[(.*?)' . preg_quote($tag, '/') . '(.*?)\]/', $body)) {
1248                                         continue;
1249                                 }
1250                                 if (preg_match('/\[(.*?)\]\((.*?)' . preg_quote($tag, '/') . '(.*?)\)/', $body)) {
1251                                         continue;
1252                                 }
1253
1254                                 $basetag = str_replace('_', ' ', substr($tag, 1));
1255                                 $url = '#[url=' . $a->get_baseurl() . '/search?tag=' . rawurlencode($basetag) . ']' . $basetag . '[/url]';
1256                                 $body = str_replace($tag, $url, $body);
1257                                 $tags_arr["#" . $basetag] = $url;
1258                         } elseif (strpos($tag, '@') === 0) {
1259                                 if (strpos($tag, '[url=')) {
1260                                         continue;
1261                                 }
1262
1263                                 $basetag = substr($tag, 1);
1264                                 $url = '@[url=https://twitter.com/' . rawurlencode($basetag) . ']' . $basetag . '[/url]';
1265                                 $body = str_replace($tag, $url, $body);
1266                                 $tags_arr["@" . $basetag] = $url;
1267                         }
1268                 }
1269         }
1270
1271         $tags = implode($tags_arr, ",");
1272
1273         return ["body" => $body, "tags" => $tags, "plain" => $plain];
1274 }
1275
1276 /**
1277  * @brief Fetch media entities and add media links to the body
1278  *
1279  * @param object $post Twitter object with the post
1280  * @param array $postarray Array of the item that is about to be posted
1281  *
1282  * @return $picture string Image URL or empty string
1283  */
1284 function twitter_media_entities($post, array &$postarray)
1285 {
1286         // There are no media entities? So we quit.
1287         if (empty($post->extended_entities->media)) {
1288                 return "";
1289         }
1290
1291         // When the post links to an external page, we only take one picture.
1292         // We only do this when there is exactly one media.
1293         if ((count($post->entities->urls) > 0) && (count($post->extended_entities->media) == 1)) {
1294                 $picture = "";
1295                 foreach ($post->extended_entities->media AS $medium) {
1296                         if (isset($medium->media_url_https)) {
1297                                 $picture = $medium->media_url_https;
1298                                 $postarray['body'] = str_replace($medium->url, "", $postarray['body']);
1299                         }
1300                 }
1301                 return $picture;
1302         }
1303
1304         // This is a pure media post, first search for all media urls
1305         $media = [];
1306         foreach ($post->extended_entities->media AS $medium) {
1307                 if (!isset($media[$medium->url])) {
1308                         $media[$medium->url] = '';
1309                 }
1310                 switch ($medium->type) {
1311                         case 'photo':
1312                                 $media[$medium->url] .= "\n[img]" . $medium->media_url_https . "[/img]";
1313                                 $postarray['object-type'] = ACTIVITY_OBJ_IMAGE;
1314                                 break;
1315                         case 'video':
1316                         case 'animated_gif':
1317                                 $media[$medium->url] .= "\n[img]" . $medium->media_url_https . "[/img]";
1318                                 $postarray['object-type'] = ACTIVITY_OBJ_VIDEO;
1319                                 if (is_array($medium->video_info->variants)) {
1320                                         $bitrate = 0;
1321                                         // We take the video with the highest bitrate
1322                                         foreach ($medium->video_info->variants AS $variant) {
1323                                                 if (($variant->content_type == "video/mp4") && ($variant->bitrate >= $bitrate)) {
1324                                                         $media[$medium->url] = "\n[video]" . $variant->url . "[/video]";
1325                                                         $bitrate = $variant->bitrate;
1326                                                 }
1327                                         }
1328                                 }
1329                                 break;
1330                         // The following code will only be activated for test reasons
1331                         //default:
1332                         //      $postarray['body'] .= print_r($medium, true);
1333                 }
1334         }
1335
1336         // Now we replace the media urls.
1337         foreach ($media AS $key => $value) {
1338                 $postarray['body'] = str_replace($key, "\n" . $value . "\n", $postarray['body']);
1339         }
1340         return "";
1341 }
1342
1343 function twitter_createpost(App $a, $uid, $post, array $self, $create_user, $only_existing_contact, $noquote)
1344 {
1345         $postarray = [];
1346         $postarray['network'] = NETWORK_TWITTER;
1347         $postarray['uid'] = $uid;
1348         $postarray['wall'] = 0;
1349         $postarray['uri'] = "twitter::" . $post->id_str;
1350         $postarray['protocol'] = Conversation::PARCEL_TWITTER;
1351         $postarray['source'] = json_encode($post);
1352
1353         // Don't import our own comments
1354         if (DBA::exists('item', ['extid' => $postarray['uri'], 'uid' => $uid])) {
1355                 logger("Item with extid " . $postarray['uri'] . " found.", LOGGER_DEBUG);
1356                 return [];
1357         }
1358
1359         $contactid = 0;
1360
1361         if ($post->in_reply_to_status_id_str != "") {
1362                 $parent = "twitter::" . $post->in_reply_to_status_id_str;
1363
1364                 $fields = ['uri', 'parent-uri', 'parent'];
1365                 $parent_item = Item::selectFirst($fields, ['uri' => $parent, 'uid' => $uid]);
1366                 if (!DBA::isResult($parent_item)) {
1367                         $parent_item = Item::selectFirst($fields, ['extid' => $parent, 'uid' => $uid]);
1368                 }
1369
1370                 if (DBA::isResult($parent_item)) {
1371                         $postarray['thr-parent'] = $parent_item['uri'];
1372                         $postarray['parent-uri'] = $parent_item['parent-uri'];
1373                         $postarray['parent'] = $parent_item['parent'];
1374                         $postarray['object-type'] = ACTIVITY_OBJ_COMMENT;
1375                 } else {
1376                         $postarray['thr-parent'] = $postarray['uri'];
1377                         $postarray['parent-uri'] = $postarray['uri'];
1378                         $postarray['object-type'] = ACTIVITY_OBJ_NOTE;
1379                 }
1380
1381                 // Is it me?
1382                 $own_id = PConfig::get($uid, 'twitter', 'own_id');
1383
1384                 if ($post->user->id_str == $own_id) {
1385                         $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
1386                                 intval($uid));
1387
1388                         if (DBA::isResult($r)) {
1389                                 $contactid = $r[0]["id"];
1390
1391                                 $postarray['owner-name']   = $r[0]["name"];
1392                                 $postarray['owner-link']   = $r[0]["url"];
1393                                 $postarray['owner-avatar'] = $r[0]["photo"];
1394                         } else {
1395                                 logger("No self contact for user " . $uid, LOGGER_DEBUG);
1396                                 return [];
1397                         }
1398                 }
1399                 // Don't create accounts of people who just comment something
1400                 $create_user = false;
1401         } else {
1402                 $postarray['parent-uri'] = $postarray['uri'];
1403                 $postarray['object-type'] = ACTIVITY_OBJ_NOTE;
1404         }
1405
1406         if ($contactid == 0) {
1407                 $contactid = twitter_fetch_contact($uid, $post->user, $create_user);
1408
1409                 $postarray['owner-name'] = $post->user->name;
1410                 $postarray['owner-link'] = "https://twitter.com/" . $post->user->screen_name;
1411                 $postarray['owner-avatar'] = twitter_fix_avatar($post->user->profile_image_url_https);
1412         }
1413
1414         if (($contactid == 0) && !$only_existing_contact) {
1415                 $contactid = $self['id'];
1416         } elseif ($contactid <= 0) {
1417                 logger("Contact ID is zero or less than zero.", LOGGER_DEBUG);
1418                 return [];
1419         }
1420
1421         $postarray['contact-id'] = $contactid;
1422
1423         $postarray['verb'] = ACTIVITY_POST;
1424         $postarray['author-name'] = $postarray['owner-name'];
1425         $postarray['author-link'] = $postarray['owner-link'];
1426         $postarray['author-avatar'] = $postarray['owner-avatar'];
1427         $postarray['plink'] = "https://twitter.com/" . $post->user->screen_name . "/status/" . $post->id_str;
1428         $postarray['app'] = strip_tags($post->source);
1429
1430         if ($post->user->protected) {
1431                 $postarray['private'] = 1;
1432                 $postarray['allow_cid'] = '<' . $self['id'] . '>';
1433         } else {
1434                 $postarray['private'] = 0;
1435                 $postarray['allow_cid'] = '';
1436         }
1437
1438         if (is_string($post->full_text)) {
1439                 $postarray['body'] = $post->full_text;
1440         } else {
1441                 $postarray['body'] = $post->text;
1442         }
1443
1444         // When the post contains links then use the correct object type
1445         if (count($post->entities->urls) > 0) {
1446                 $postarray['object-type'] = ACTIVITY_OBJ_BOOKMARK;
1447         }
1448
1449         // Search for media links
1450         $picture = twitter_media_entities($post, $postarray);
1451
1452         $converted = twitter_expand_entities($a, $postarray['body'], $post, $picture);
1453         $postarray['body'] = $converted["body"];
1454         $postarray['tag'] = $converted["tags"];
1455         $postarray['created'] = DateTimeFormat::utc($post->created_at);
1456         $postarray['edited'] = DateTimeFormat::utc($post->created_at);
1457
1458         $statustext = $converted["plain"];
1459
1460         if (!empty($post->place->name)) {
1461                 $postarray["location"] = $post->place->name;
1462         }
1463         if (!empty($post->place->full_name)) {
1464                 $postarray["location"] = $post->place->full_name;
1465         }
1466         if (!empty($post->geo->coordinates)) {
1467                 $postarray["coord"] = $post->geo->coordinates[0] . " " . $post->geo->coordinates[1];
1468         }
1469         if (!empty($post->coordinates->coordinates)) {
1470                 $postarray["coord"] = $post->coordinates->coordinates[1] . " " . $post->coordinates->coordinates[0];
1471         }
1472         if (!empty($post->retweeted_status)) {
1473                 $retweet = twitter_createpost($a, $uid, $post->retweeted_status, $self, false, false, $noquote);
1474
1475                 $retweet['source'] = $postarray['source'];
1476                 $retweet['private'] = $postarray['private'];
1477                 $retweet['allow_cid'] = $postarray['allow_cid'];
1478                 $retweet['contact-id'] = $postarray['contact-id'];
1479                 $retweet['owner-name'] = $postarray['owner-name'];
1480                 $retweet['owner-link'] = $postarray['owner-link'];
1481                 $retweet['owner-avatar'] = $postarray['owner-avatar'];
1482
1483                 $postarray = $retweet;
1484         }
1485
1486         if (!empty($post->quoted_status) && !$noquote) {
1487                 $quoted = twitter_createpost($a, $uid, $post->quoted_status, $self, false, false, true);
1488
1489                 $postarray['body'] = $statustext;
1490
1491                 $postarray['body'] .= "\n" . share_header(
1492                         $quoted['author-name'],
1493                         $quoted['author-link'],
1494                         $quoted['author-avatar'],
1495                         "",
1496                         $quoted['created'],
1497                         $quoted['plink']
1498                 );
1499
1500                 $postarray['body'] .= $quoted['body'] . '[/share]';
1501         }
1502
1503         return $postarray;
1504 }
1505
1506 function twitter_fetchparentposts(App $a, $uid, $post, TwitterOAuth $connection, array $self)
1507 {
1508         logger("twitter_fetchparentposts: Fetching for user " . $uid . " and post " . $post->id_str, LOGGER_DEBUG);
1509
1510         $posts = [];
1511
1512         while (!empty($post->in_reply_to_status_id_str)) {
1513                 $parameters = ["trim_user" => false, "tweet_mode" => "extended", "id" => $post->in_reply_to_status_id_str];
1514
1515                 try {
1516                         $post = $connection->get('statuses/show', $parameters);
1517                 } catch (TwitterOAuthException $e) {
1518                         logger('twitter_fetchparentposts: Error fetching for user ' . $uid . ' and post ' . $post->id_str . ': ' . $e->getMessage());
1519                         break;
1520                 }
1521
1522                 if (empty($post)) {
1523                         logger("twitter_fetchparentposts: Can't fetch post " . $parameters->id, LOGGER_DEBUG);
1524                         break;
1525                 }
1526
1527                 if (empty($post->id_str)) {
1528                         logger("twitter_fetchparentposts: This is not a post " . json_encode($post), LOGGER_DEBUG);
1529                         break;
1530                 }
1531
1532                 if (DBA::exists('item', ['uri' => 'twitter::' . $post->id_str, 'uid' => $uid])) {
1533                         break;
1534                 }
1535
1536                 $posts[] = $post;
1537         }
1538
1539         logger("twitter_fetchparentposts: Fetching " . count($posts) . " parents", LOGGER_DEBUG);
1540
1541         $posts = array_reverse($posts);
1542
1543         if (!empty($posts)) {
1544                 foreach ($posts as $post) {
1545                         $postarray = twitter_createpost($a, $uid, $post, $self, false, false, false);
1546
1547                         if (empty($postarray['body'])) {
1548                                 continue;
1549                         }
1550
1551                         $item = Item::insert($postarray);
1552
1553                         $postarray["id"] = $item;
1554
1555                         logger('twitter_fetchparentpost: User ' . $self["nick"] . ' posted parent timeline item ' . $item);
1556                 }
1557         }
1558 }
1559
1560 function twitter_fetchhometimeline(App $a, $uid)
1561 {
1562         $ckey    = Config::get('twitter', 'consumerkey');
1563         $csecret = Config::get('twitter', 'consumersecret');
1564         $otoken  = PConfig::get($uid, 'twitter', 'oauthtoken');
1565         $osecret = PConfig::get($uid, 'twitter', 'oauthsecret');
1566         $create_user = PConfig::get($uid, 'twitter', 'create_user');
1567         $mirror_posts = PConfig::get($uid, 'twitter', 'mirror_posts');
1568
1569         logger("twitter_fetchhometimeline: Fetching for user " . $uid, LOGGER_DEBUG);
1570
1571         $application_name = Config::get('twitter', 'application_name');
1572
1573         if ($application_name == "") {
1574                 $application_name = $a->get_hostname();
1575         }
1576
1577         require_once 'include/items.php';
1578
1579         $connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret);
1580
1581         try {
1582                 $own_contact = twitter_fetch_own_contact($a, $uid);
1583         } catch (TwitterOAuthException $e) {
1584                 logger('twitter_fetchhometimeline: Error fetching own contact for user ' . $uid . ': ' . $e->getMessage());
1585                 return;
1586         }
1587
1588         $r = q("SELECT * FROM `contact` WHERE `id` = %d AND `uid` = %d LIMIT 1",
1589                 intval($own_contact),
1590                 intval($uid));
1591
1592         if (DBA::isResult($r)) {
1593                 $own_id = $r[0]["nick"];
1594         } else {
1595                 logger("twitter_fetchhometimeline: Own twitter contact not found for user " . $uid, LOGGER_DEBUG);
1596                 return;
1597         }
1598
1599         $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
1600                 intval($uid));
1601
1602         if (DBA::isResult($r)) {
1603                 $self = $r[0];
1604         } else {
1605                 logger("twitter_fetchhometimeline: Own contact not found for user " . $uid, LOGGER_DEBUG);
1606                 return;
1607         }
1608
1609         $u = q("SELECT * FROM user WHERE uid = %d LIMIT 1",
1610                 intval($uid));
1611         if (!DBA::isResult($u)) {
1612                 logger("twitter_fetchhometimeline: Own user not found for user " . $uid, LOGGER_DEBUG);
1613                 return;
1614         }
1615
1616         $parameters = ["exclude_replies" => false, "trim_user" => false, "contributor_details" => true, "include_rts" => true, "tweet_mode" => "extended"];
1617         //$parameters["count"] = 200;
1618         // Fetching timeline
1619         $lastid = PConfig::get($uid, 'twitter', 'lasthometimelineid');
1620
1621         $first_time = ($lastid == "");
1622
1623         if ($lastid != "") {
1624                 $parameters["since_id"] = $lastid;
1625         }
1626
1627         try {
1628                 $items = $connection->get('statuses/home_timeline', $parameters);
1629         } catch (TwitterOAuthException $e) {
1630                 logger('twitter_fetchhometimeline: Error fetching home timeline: ' . $e->getMessage());
1631                 return;
1632         }
1633
1634         if (!is_array($items)) {
1635                 logger("twitter_fetchhometimeline: Error fetching home timeline: " . print_r($items, true), LOGGER_DEBUG);
1636                 return;
1637         }
1638
1639         $posts = array_reverse($items);
1640
1641         logger("twitter_fetchhometimeline: Fetching timeline for user " . $uid . " " . sizeof($posts) . " items", LOGGER_DEBUG);
1642
1643         if (count($posts)) {
1644                 foreach ($posts as $post) {
1645                         if ($post->id_str > $lastid) {
1646                                 $lastid = $post->id_str;
1647                                 PConfig::set($uid, 'twitter', 'lasthometimelineid', $lastid);
1648                         }
1649
1650                         if ($first_time) {
1651                                 continue;
1652                         }
1653
1654                         if (stristr($post->source, $application_name) && $post->user->screen_name == $own_id) {
1655                                 logger("twitter_fetchhometimeline: Skip previously sended post", LOGGER_DEBUG);
1656                                 continue;
1657                         }
1658
1659                         if ($mirror_posts && $post->user->screen_name == $own_id && $post->in_reply_to_status_id_str == "") {
1660                                 logger("twitter_fetchhometimeline: Skip post that will be mirrored", LOGGER_DEBUG);
1661                                 continue;
1662                         }
1663
1664                         if ($post->in_reply_to_status_id_str != "") {
1665                                 twitter_fetchparentposts($a, $uid, $post, $connection, $self);
1666                         }
1667
1668                         $postarray = twitter_createpost($a, $uid, $post, $self, $create_user, true, false);
1669
1670                         if (empty($postarray['body']) || trim($postarray['body']) == "") {
1671                                 continue;
1672                         }
1673
1674                         $notify = false;
1675
1676                         if ($postarray['uri'] == $postarray['parent-uri']) {
1677                                 $contact = DBA::selectFirst('contact', [], ['id' => $postarray['contact-id'], 'self' => false]);
1678                                 if (DBA::isResult($contact)) {
1679                                         $notify = Item::isRemoteSelf($contact, $postarray);
1680                                 }
1681                         }
1682
1683                         $item = Item::insert($postarray, false, $notify);
1684                         $postarray["id"] = $item;
1685
1686                         logger('twitter_fetchhometimeline: User ' . $self["nick"] . ' posted home timeline item ' . $item);
1687                 }
1688         }
1689         PConfig::set($uid, 'twitter', 'lasthometimelineid', $lastid);
1690
1691         // Fetching mentions
1692         $lastid = PConfig::get($uid, 'twitter', 'lastmentionid');
1693
1694         $first_time = ($lastid == "");
1695
1696         if ($lastid != "") {
1697                 $parameters["since_id"] = $lastid;
1698         }
1699
1700         try {
1701                 $items = $connection->get('statuses/mentions_timeline', $parameters);
1702         } catch (TwitterOAuthException $e) {
1703                 logger('twitter_fetchhometimeline: Error fetching mentions: ' . $e->getMessage());
1704                 return;
1705         }
1706
1707         if (!is_array($items)) {
1708                 logger("twitter_fetchhometimeline: Error fetching mentions: " . print_r($items, true), LOGGER_DEBUG);
1709                 return;
1710         }
1711
1712         $posts = array_reverse($items);
1713
1714         logger("twitter_fetchhometimeline: Fetching mentions for user " . $uid . " " . sizeof($posts) . " items", LOGGER_DEBUG);
1715
1716         if (count($posts)) {
1717                 foreach ($posts as $post) {
1718                         if ($post->id_str > $lastid) {
1719                                 $lastid = $post->id_str;
1720                         }
1721
1722                         if ($first_time) {
1723                                 continue;
1724                         }
1725
1726                         if ($post->in_reply_to_status_id_str != "") {
1727                                 twitter_fetchparentposts($a, $uid, $post, $connection, $self);
1728                         }
1729
1730                         $postarray = twitter_createpost($a, $uid, $post, $self, false, false, false);
1731
1732                         if (trim($postarray['body']) == "") {
1733                                 continue;
1734                         }
1735
1736                         $item = Item::insert($postarray);
1737
1738                         logger('twitter_fetchhometimeline: User ' . $self["nick"] . ' posted mention timeline item ' . $item);
1739                 }
1740         }
1741
1742         PConfig::set($uid, 'twitter', 'lastmentionid', $lastid);
1743 }
1744
1745 function twitter_fetch_own_contact(App $a, $uid)
1746 {
1747         $ckey    = Config::get('twitter', 'consumerkey');
1748         $csecret = Config::get('twitter', 'consumersecret');
1749         $otoken  = PConfig::get($uid, 'twitter', 'oauthtoken');
1750         $osecret = PConfig::get($uid, 'twitter', 'oauthsecret');
1751
1752         $own_id = PConfig::get($uid, 'twitter', 'own_id');
1753
1754         $contact_id = 0;
1755
1756         if ($own_id == "") {
1757                 $connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret);
1758
1759                 // Fetching user data
1760                 // get() may throw TwitterOAuthException, but we will catch it later
1761                 $user = $connection->get('account/verify_credentials');
1762
1763                 PConfig::set($uid, 'twitter', 'own_id', $user->id_str);
1764
1765                 $contact_id = twitter_fetch_contact($uid, $user, true);
1766         } else {
1767                 $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1",
1768                         intval($uid),
1769                         DBA::escape("twitter::" . $own_id));
1770                 if (DBA::isResult($r)) {
1771                         $contact_id = $r[0]["id"];
1772                 } else {
1773                         PConfig::delete($uid, 'twitter', 'own_id');
1774                 }
1775         }
1776
1777         return $contact_id;
1778 }
1779
1780 function twitter_is_retweet(App $a, $uid, $body)
1781 {
1782         $body = trim($body);
1783
1784         // Skip if it isn't a pure repeated messages
1785         // Does it start with a share?
1786         if (strpos($body, "[share") > 0) {
1787                 return false;
1788         }
1789
1790         // Does it end with a share?
1791         if (strlen($body) > (strrpos($body, "[/share]") + 8)) {
1792                 return false;
1793         }
1794
1795         $attributes = preg_replace("/\[share(.*?)\]\s?(.*?)\s?\[\/share\]\s?/ism", "$1", $body);
1796         // Skip if there is no shared message in there
1797         if ($body == $attributes) {
1798                 return false;
1799         }
1800
1801         $link = "";
1802         preg_match("/link='(.*?)'/ism", $attributes, $matches);
1803         if (!empty($matches[1])) {
1804                 $link = $matches[1];
1805         }
1806
1807         preg_match('/link="(.*?)"/ism', $attributes, $matches);
1808         if (!empty($matches[1])) {
1809                 $link = $matches[1];
1810         }
1811
1812         $id = preg_replace("=https?://twitter.com/(.*)/status/(.*)=ism", "$2", $link);
1813         if ($id == $link) {
1814                 return false;
1815         }
1816
1817         logger('twitter_is_retweet: Retweeting id ' . $id . ' for user ' . $uid, LOGGER_DEBUG);
1818
1819         $ckey    = Config::get('twitter', 'consumerkey');
1820         $csecret = Config::get('twitter', 'consumersecret');
1821         $otoken  = PConfig::get($uid, 'twitter', 'oauthtoken');
1822         $osecret = PConfig::get($uid, 'twitter', 'oauthsecret');
1823
1824         $connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret);
1825         $result = $connection->post('statuses/retweet/' . $id);
1826
1827         logger('twitter_is_retweet: result ' . print_r($result, true), LOGGER_DEBUG);
1828
1829         return !isset($result->errors);
1830 }