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