statusnet/statusnet.php

   1 <?php
   2
   3 /**
   4  * Name: GNU Social Connector
   5  * Description: Bidirectional (posting, relaying and reading) connector for GNU Social.
   6  * Version: 1.0.5
   7  * Author: Tobias Diekershoff <https://f.diekershoff.de/profile/tobias>
   8  * Author: Michael Vogel <https://pirati.ca/profile/heluecht>
   9  *
  10  * Copyright (c) 2011-2013 Tobias Diekershoff, Michael Vogel
  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 define('STATUSNET_DEFAULT_POLL_INTERVAL', 5); // given in minutes
  37
  38 require_once __DIR__ . DIRECTORY_SEPARATOR . 'library' . DIRECTORY_SEPARATOR . 'statusnetoauth.php';
  39
  40 use CodebirdSN\CodebirdSN;
  41 use Friendica\App;
  42 use Friendica\Content\OEmbed;
  43 use Friendica\Content\PageInfo;
  44 use Friendica\Content\Text\HTML;
  45 use Friendica\Content\Text\Plaintext;
  46 use Friendica\Core\Hook;
  47 use Friendica\Core\Logger;
  48 use Friendica\Core\Protocol;
  49 use Friendica\Core\Renderer;
  50 use Friendica\Database\DBA;
  51 use Friendica\DI;
  52 use Friendica\Model\Contact;
  53 use Friendica\Model\Group;
  54 use Friendica\Model\Item;
  55 use Friendica\Model\Photo;
  56 use Friendica\Model\Post;
  57 use Friendica\Model\User;
  58 use Friendica\Protocol\Activity;
  59 use Friendica\Util\DateTimeFormat;
  60 use Friendica\Util\Strings;
  61
  62 function statusnet_install()
  63 {
  64         //  we need some hooks, for the configuration and for sending tweets
  65         Hook::register('connector_settings', 'addon/statusnet/statusnet.php', 'statusnet_settings');
  66         Hook::register('connector_settings_post', 'addon/statusnet/statusnet.php', 'statusnet_settings_post');
  67         Hook::register('notifier_normal', 'addon/statusnet/statusnet.php', 'statusnet_post_hook');
  68         Hook::register('hook_fork', 'addon/statusnet/statusnet.php', 'statusnet_hook_fork');
  69         Hook::register('post_local', 'addon/statusnet/statusnet.php', 'statusnet_post_local');
  70         Hook::register('jot_networks', 'addon/statusnet/statusnet.php', 'statusnet_jot_nets');
  71         Hook::register('cron', 'addon/statusnet/statusnet.php', 'statusnet_cron');
  72         Hook::register('prepare_body', 'addon/statusnet/statusnet.php', 'statusnet_prepare_body');
  73         Hook::register('check_item_notification', 'addon/statusnet/statusnet.php', 'statusnet_check_item_notification');
  74         Logger::log("installed GNU Social");
  75 }
  76
  77 function statusnet_check_item_notification(App $a, &$notification_data)
  78 {
  79         if (DI::pConfig()->get($notification_data["uid"], 'statusnet', 'post')) {
  80                 $notification_data["profiles"][] = DI::pConfig()->get($notification_data["uid"], 'statusnet', 'own_url');
  81         }
  82 }
  83
  84 function statusnet_jot_nets(App $a, array &$jotnets_fields)
  85 {
  86         if (!local_user()) {
  87                 return;
  88         }
  89
  90         if (DI::pConfig()->get(local_user(), 'statusnet', 'post')) {
  91                 $jotnets_fields[] = [
  92                         'type' => 'checkbox',
  93                         'field' => [
  94                                 'statusnet_enable',
  95                                 DI::l10n()->t('Post to GNU Social'),
  96                                 DI::pConfig()->get(local_user(), 'statusnet', 'post_by_default')
  97                         ]
  98                 ];
  99         }
 100 }
 101
 102 function statusnet_settings_post(App $a, $post)
 103 {
 104         if (!local_user()) {
 105                 return;
 106         }
 107         // don't check GNU Social settings if GNU Social submit button is not clicked
 108         if (empty($_POST['statusnet-submit'])) {
 109                 return;
 110         }
 111
 112         if (isset($_POST['statusnet-disconnect'])) {
 113                 /*               * *
 114                  * if the GNU Social-disconnect checkbox is set, clear the GNU Social configuration
 115                  */
 116                 DI::pConfig()->delete(local_user(), 'statusnet', 'consumerkey');
 117                 DI::pConfig()->delete(local_user(), 'statusnet', 'consumersecret');
 118                 DI::pConfig()->delete(local_user(), 'statusnet', 'post');
 119                 DI::pConfig()->delete(local_user(), 'statusnet', 'post_by_default');
 120                 DI::pConfig()->delete(local_user(), 'statusnet', 'oauthtoken');
 121                 DI::pConfig()->delete(local_user(), 'statusnet', 'oauthsecret');
 122                 DI::pConfig()->delete(local_user(), 'statusnet', 'baseapi');
 123                 DI::pConfig()->delete(local_user(), 'statusnet', 'lastid');
 124                 DI::pConfig()->delete(local_user(), 'statusnet', 'mirror_posts');
 125                 DI::pConfig()->delete(local_user(), 'statusnet', 'import');
 126                 DI::pConfig()->delete(local_user(), 'statusnet', 'create_user');
 127                 DI::pConfig()->delete(local_user(), 'statusnet', 'own_url');
 128         } else {
 129                 if (isset($_POST['statusnet-preconf-apiurl'])) {
 130                         /*                       * *
 131                          * If the user used one of the preconfigured GNU Social server credentials
 132                          * use them. All the data are available in the global config.
 133                          * Check the API Url never the less and blame the admin if it's not working ^^
 134                          */
 135                         $globalsn = DI::config()->get('statusnet', 'sites');
 136                         foreach ($globalsn as $asn) {
 137                                 if ($asn['apiurl'] == $_POST['statusnet-preconf-apiurl']) {
 138                                         $apibase = $asn['apiurl'];
 139                                         $c = DI::httpRequest()->fetch($apibase . 'statusnet/version.xml');
 140                                         if (strlen($c) > 0) {
 141                                                 DI::pConfig()->set(local_user(), 'statusnet', 'consumerkey', $asn['consumerkey']);
 142                                                 DI::pConfig()->set(local_user(), 'statusnet', 'consumersecret', $asn['consumersecret']);
 143                                                 DI::pConfig()->set(local_user(), 'statusnet', 'baseapi', $asn['apiurl']);
 144                                                 //DI::pConfig()->set(local_user(), 'statusnet', 'application_name', $asn['applicationname'] );
 145                                         } else {
 146                                                 notice(DI::l10n()->t('Please contact your site administrator.<br />The provided API URL is not valid.') . EOL . $asn['apiurl'] . EOL);
 147                                         }
 148                                 }
 149                         }
 150                         DI::baseUrl()->redirect('settings/connectors');
 151                 } else {
 152                         if (isset($_POST['statusnet-consumersecret'])) {
 153                                 //  check if we can reach the API of the GNU Social server
 154                                 //  we'll check the API Version for that, if we don't get one we'll try to fix the path but will
 155                                 //  resign quickly after this one try to fix the path ;-)
 156                                 $apibase = $_POST['statusnet-baseapi'];
 157                                 $c = DI::httpRequest()->fetch($apibase . 'statusnet/version.xml');
 158                                 if (strlen($c) > 0) {
 159                                         //  ok the API path is correct, let's save the settings
 160                                         DI::pConfig()->set(local_user(), 'statusnet', 'consumerkey', $_POST['statusnet-consumerkey']);
 161                                         DI::pConfig()->set(local_user(), 'statusnet', 'consumersecret', $_POST['statusnet-consumersecret']);
 162                                         DI::pConfig()->set(local_user(), 'statusnet', 'baseapi', $apibase);
 163                                         //DI::pConfig()->set(local_user(), 'statusnet', 'application_name', $_POST['statusnet-applicationname'] );
 164                                 } else {
 165                                         //  the API path is not correct, maybe missing trailing / ?
 166                                         $apibase = $apibase . '/';
 167                                         $c = DI::httpRequest()->fetch($apibase . 'statusnet/version.xml');
 168                                         if (strlen($c) > 0) {
 169                                                 //  ok the API path is now correct, let's save the settings
 170                                                 DI::pConfig()->set(local_user(), 'statusnet', 'consumerkey', $_POST['statusnet-consumerkey']);
 171                                                 DI::pConfig()->set(local_user(), 'statusnet', 'consumersecret', $_POST['statusnet-consumersecret']);
 172                                                 DI::pConfig()->set(local_user(), 'statusnet', 'baseapi', $apibase);
 173                                         } else {
 174                                                 //  still not the correct API base, let's do noting
 175                                                 notice(DI::l10n()->t('We could not contact the GNU Social API with the Path you entered.') . EOL);
 176                                         }
 177                                 }
 178                                 DI::baseUrl()->redirect('settings/connectors');
 179                         } else {
 180                                 if (isset($_POST['statusnet-pin'])) {
 181                                         //  if the user supplied us with a PIN from GNU Social, let the magic of OAuth happen
 182                                         $api = DI::pConfig()->get(local_user(), 'statusnet', 'baseapi');
 183                                         $ckey = DI::pConfig()->get(local_user(), 'statusnet', 'consumerkey');
 184                                         $csecret = DI::pConfig()->get(local_user(), 'statusnet', 'consumersecret');
 185                                         //  the token and secret for which the PIN was generated were hidden in the settings
 186                                         //  form as token and token2, we need a new connection to GNU Social using these token
 187                                         //  and secret to request a Access Token with the PIN
 188                                         $connection = new StatusNetOAuth($api, $ckey, $csecret, $_POST['statusnet-token'], $_POST['statusnet-token2']);
 189                                         $token = $connection->getAccessToken($_POST['statusnet-pin']);
 190                                         //  ok, now that we have the Access Token, save them in the user config
 191                                         DI::pConfig()->set(local_user(), 'statusnet', 'oauthtoken', $token['oauth_token']);
 192                                         DI::pConfig()->set(local_user(), 'statusnet', 'oauthsecret', $token['oauth_token_secret']);
 193                                         DI::pConfig()->set(local_user(), 'statusnet', 'post', 1);
 194                                         DI::pConfig()->set(local_user(), 'statusnet', 'post_taglinks', 1);
 195                                         //  reload the Addon Settings page, if we don't do it see Bug #42
 196                                         DI::baseUrl()->redirect('settings/connectors');
 197                                 } else {
 198                                         //  if no PIN is supplied in the POST variables, the user has changed the setting
 199                                         //  to post a dent for every new __public__ posting to the wall
 200                                         DI::pConfig()->set(local_user(), 'statusnet', 'post', intval($_POST['statusnet-enable']));
 201                                         DI::pConfig()->set(local_user(), 'statusnet', 'post_by_default', intval($_POST['statusnet-default']));
 202                                         DI::pConfig()->set(local_user(), 'statusnet', 'mirror_posts', intval($_POST['statusnet-mirror']));
 203                                         DI::pConfig()->set(local_user(), 'statusnet', 'import', intval($_POST['statusnet-import']));
 204                                         DI::pConfig()->set(local_user(), 'statusnet', 'create_user', intval($_POST['statusnet-create_user']));
 205
 206                                         if (!intval($_POST['statusnet-mirror']))
 207                                                 DI::pConfig()->delete(local_user(), 'statusnet', 'lastid');
 208                                 }
 209                         }
 210                 }
 211         }
 212 }
 213
 214 function statusnet_settings(App $a, &$s)
 215 {
 216         if (!local_user()) {
 217                 return;
 218         }
 219         DI::page()['htmlhead'] .= '<link rel="stylesheet"  type="text/css" href="' . DI::baseUrl()->get() . '/addon/statusnet/statusnet.css' . '" media="all" />' . "\r\n";
 220         /*       * *
 221          * 1) Check that we have a base api url and a consumer key & secret
 222          * 2) If no OAuthtoken & stuff is present, generate button to get some
 223          *    allow the user to cancel the connection process at this step
 224          * 3) Checkbox for "Send public notices (respect size limitation)
 225          */
 226         $api     = DI::pConfig()->get(local_user(), 'statusnet', 'baseapi');
 227         $ckey    = DI::pConfig()->get(local_user(), 'statusnet', 'consumerkey');
 228         $csecret = DI::pConfig()->get(local_user(), 'statusnet', 'consumersecret');
 229         $otoken  = DI::pConfig()->get(local_user(), 'statusnet', 'oauthtoken');
 230         $osecret = DI::pConfig()->get(local_user(), 'statusnet', 'oauthsecret');
 231         $enabled = DI::pConfig()->get(local_user(), 'statusnet', 'post');
 232         $checked = (($enabled) ? ' checked="checked" ' : '');
 233         $defenabled = DI::pConfig()->get(local_user(), 'statusnet', 'post_by_default');
 234         $defchecked = (($defenabled) ? ' checked="checked" ' : '');
 235         $mirrorenabled = DI::pConfig()->get(local_user(), 'statusnet', 'mirror_posts');
 236         $mirrorchecked = (($mirrorenabled) ? ' checked="checked" ' : '');
 237         $import = DI::pConfig()->get(local_user(), 'statusnet', 'import');
 238         $importselected = ["", "", ""];
 239         $importselected[$import] = ' selected="selected"';
 240         //$importenabled = DI::pConfig()->get(local_user(),'statusnet','import');
 241         //$importchecked = (($importenabled) ? ' checked="checked" ' : '');
 242         $create_userenabled = DI::pConfig()->get(local_user(), 'statusnet', 'create_user');
 243         $create_userchecked = (($create_userenabled) ? ' checked="checked" ' : '');
 244
 245         $css = (($enabled) ? '' : '-disabled');
 246
 247         $s .= '<span id="settings_statusnet_inflated" class="settings-block fakelink" style="display: block;" onclick="openClose(\'settings_statusnet_expanded\'); openClose(\'settings_statusnet_inflated\');">';
 248         $s .= '<img class="connector' . $css . '" src="images/gnusocial.png" /><h3 class="connector">' . DI::l10n()->t('GNU Social Import/Export/Mirror') . '</h3>';
 249         $s .= '</span>';
 250         $s .= '<div id="settings_statusnet_expanded" class="settings-block" style="display: none;">';
 251         $s .= '<span class="fakelink" onclick="openClose(\'settings_statusnet_expanded\'); openClose(\'settings_statusnet_inflated\');">';
 252         $s .= '<img class="connector' . $css . '" src="images/gnusocial.png" /><h3 class="connector">' . DI::l10n()->t('GNU Social Import/Export/Mirror') . '</h3>';
 253         $s .= '</span>';
 254
 255         if ((!$ckey) && (!$csecret)) {
 256                 /*               * *
 257                  * no consumer keys
 258                  */
 259                 $globalsn = DI::config()->get('statusnet', 'sites');
 260                 /*               * *
 261                  * lets check if we have one or more globally configured GNU Social
 262                  * server OAuth credentials in the configuration. If so offer them
 263                  * with a little explanation to the user as choice - otherwise
 264                  * ignore this option entirely.
 265                  */
 266                 if (!$globalsn == null) {
 267                         $s .= '<h4>' . DI::l10n()->t('Globally Available GNU Social OAuthKeys') . '</h4>';
 268                         $s .= '<p>' . DI::l10n()->t("There are preconfigured OAuth key pairs for some GNU Social servers available. If you are using one of them, please use these credentials. If not feel free to connect to any other GNU Social instance \x28see below\x29.") . '</p>';
 269                         $s .= '<div id="statusnet-preconf-wrapper">';
 270                         foreach ($globalsn as $asn) {
 271                                 $s .= '<input type="radio" name="statusnet-preconf-apiurl" value="' . $asn['apiurl'] . '">' . $asn['sitename'] . '<br />';
 272                         }
 273                         $s .= '<p></p><div class="clear"></div></div>';
 274                         $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="statusnet-submit" class="settings-submit" value="' . DI::l10n()->t('Save Settings') . '" /></div>';
 275                 }
 276                 $s .= '<h4>' . DI::l10n()->t('Provide your own OAuth Credentials') . '</h4>';
 277                 $s .= '<p>' . DI::l10n()->t('No consumer key pair for GNU Social found. Register your Friendica Account as an desktop client on your GNU Social account, copy the consumer key pair here and enter the API base root.<br />Before you register your own OAuth key pair ask the administrator if there is already a key pair for this Friendica installation at your favorited GNU Social installation.') . '</p>';
 278                 $s .= '<div id="statusnet-consumer-wrapper">';
 279                 $s .= '<label id="statusnet-consumerkey-label" for="statusnet-consumerkey">' . DI::l10n()->t('OAuth Consumer Key') . '</label>';
 280                 $s .= '<input id="statusnet-consumerkey" type="text" name="statusnet-consumerkey" size="35" /><br />';
 281                 $s .= '<div class="clear"></div>';
 282                 $s .= '<label id="statusnet-consumersecret-label" for="statusnet-consumersecret">' . DI::l10n()->t('OAuth Consumer Secret') . '</label>';
 283                 $s .= '<input id="statusnet-consumersecret" type="text" name="statusnet-consumersecret" size="35" /><br />';
 284                 $s .= '<div class="clear"></div>';
 285                 $s .= '<label id="statusnet-baseapi-label" for="statusnet-baseapi">' . DI::l10n()->t("Base API Path \x28remember the trailing /\x29") . '</label>';
 286                 $s .= '<input id="statusnet-baseapi" type="text" name="statusnet-baseapi" size="35" /><br />';
 287                 $s .= '<div class="clear"></div>';
 288                 //$s .= '<label id="statusnet-applicationname-label" for="statusnet-applicationname">'.DI::l10n()->t('GNU Socialapplication name').'</label>';
 289                 //$s .= '<input id="statusnet-applicationname" type="text" name="statusnet-applicationname" size="35" /><br />';
 290                 $s .= '<p></p><div class="clear"></div>';
 291                 $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="statusnet-submit" class="settings-submit" value="' . DI::l10n()->t('Save Settings') . '" /></div>';
 292                 $s .= '</div>';
 293         } else {
 294                 /*               * *
 295                  * ok we have a consumer key pair now look into the OAuth stuff
 296                  */
 297                 if ((!$otoken) && (!$osecret)) {
 298                         /*                       * *
 299                          * the user has not yet connected the account to GNU Social
 300                          * get a temporary OAuth key/secret pair and display a button with
 301                          * which the user can request a PIN to connect the account to a
 302                          * account at GNU Social
 303                          */
 304                         $connection = new StatusNetOAuth($api, $ckey, $csecret);
 305                         $request_token = $connection->getRequestToken('oob');
 306                         $token = $request_token['oauth_token'];
 307                         /*                       * *
 308                          *  make some nice form
 309                          */
 310                         $s .= '<p>' . DI::l10n()->t('To connect to your GNU Social account click the button below to get a security code from GNU Social which you have to copy into the input box below and submit the form. Only your <strong>public</strong> posts will be posted to GNU Social.') . '</p>';
 311                         $s .= '<a href="' . $connection->getAuthorizeURL($token, False) . '" target="_statusnet"><img src="addon/statusnet/signinwithstatusnet.png" alt="' . DI::l10n()->t('Log in with GNU Social') . '"></a>';
 312                         $s .= '<div id="statusnet-pin-wrapper">';
 313                         $s .= '<label id="statusnet-pin-label" for="statusnet-pin">' . DI::l10n()->t('Copy the security code from GNU Social here') . '</label>';
 314                         $s .= '<input id="statusnet-pin" type="text" name="statusnet-pin" />';
 315                         $s .= '<input id="statusnet-token" type="hidden" name="statusnet-token" value="' . $token . '" />';
 316                         $s .= '<input id="statusnet-token2" type="hidden" name="statusnet-token2" value="' . $request_token['oauth_token_secret'] . '" />';
 317                         $s .= '</div><div class="clear"></div>';
 318                         $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="statusnet-submit" class="settings-submit" value="' . DI::l10n()->t('Save Settings') . '" /></div>';
 319                         $s .= '<h4>' . DI::l10n()->t('Cancel Connection Process') . '</h4>';
 320                         $s .= '<div id="statusnet-cancel-wrapper">';
 321                         $s .= '<p>' . DI::l10n()->t('Current GNU Social API is') . ': ' . $api . '</p>';
 322                         $s .= '<label id="statusnet-cancel-label" for="statusnet-cancel">' . DI::l10n()->t('Cancel GNU Social Connection') . '</label>';
 323                         $s .= '<input id="statusnet-cancel" type="checkbox" name="statusnet-disconnect" value="1" />';
 324                         $s .= '</div><div class="clear"></div>';
 325                         $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="statusnet-submit" class="settings-submit" value="' . DI::l10n()->t('Save Settings') . '" /></div>';
 326                 } else {
 327                         /*                       * *
 328                          *  we have an OAuth key / secret pair for the user
 329                          *  so let's give a chance to disable the postings to GNU Social
 330                          */
 331                         $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
 332                         $details = $connection->get('account/verify_credentials');
 333                         if (!empty($details)) {
 334                                 $s .= '<div id="statusnet-info" ><img id="statusnet-avatar" src="' . $details->profile_image_url . '" /><p id="statusnet-info-block">' . DI::l10n()->t('Currently connected to: ') . '<a href="' . $details->statusnet_profile_url . '" target="_statusnet">' . $details->screen_name . '</a><br /><em>' . $details->description . '</em></p></div>';
 335                         }
 336                         $s .= '<p>' . DI::l10n()->t('If enabled all your <strong>public</strong> postings can be posted to the associated GNU Social account. You can choose to do so by default (here) or for every posting separately in the posting options when writing the entry.') . '</p>';
 337                         if ($a->getUserValue('hidewall')) {
 338                                 $s .= '<p>' . DI::l10n()->t('<strong>Note</strong>: Due your privacy settings (<em>Hide your profile details from unknown viewers?</em>) the link potentially included in public postings relayed to GNU Social will lead the visitor to a blank page informing the visitor that the access to your profile has been restricted.') . '</p>';
 339                         }
 340                         $s .= '<div id="statusnet-enable-wrapper">';
 341                         $s .= '<label id="statusnet-enable-label" for="statusnet-checkbox">' . DI::l10n()->t('Allow posting to GNU Social') . '</label>';
 342                         $s .= '<input id="statusnet-checkbox" type="checkbox" name="statusnet-enable" value="1" ' . $checked . '/>';
 343                         $s .= '<div class="clear"></div>';
 344                         $s .= '<label id="statusnet-default-label" for="statusnet-default">' . DI::l10n()->t('Send public postings to GNU Social by default') . '</label>';
 345                         $s .= '<input id="statusnet-default" type="checkbox" name="statusnet-default" value="1" ' . $defchecked . '/>';
 346                         $s .= '<div class="clear"></div>';
 347
 348                         $s .= '<label id="statusnet-mirror-label" for="statusnet-mirror">' . DI::l10n()->t('Mirror all posts from GNU Social that are no replies or repeated messages') . '</label>';
 349                         $s .= '<input id="statusnet-mirror" type="checkbox" name="statusnet-mirror" value="1" ' . $mirrorchecked . '/>';
 350
 351                         $s .= '<div class="clear"></div>';
 352                         $s .= '</div>';
 353
 354                         $s .= '<label id="statusnet-import-label" for="statusnet-import">' . DI::l10n()->t('Import the remote timeline') . '</label>';
 355                         //$s .= '<input id="statusnet-import" type="checkbox" name="statusnet-import" value="1" '. $importchecked . '/>';
 356
 357                         $s .= '<select name="statusnet-import" id="statusnet-import" />';
 358                         $s .= '<option value="0" ' . $importselected[0] . '>' . DI::l10n()->t("Disabled") . '</option>';
 359                         $s .= '<option value="1" ' . $importselected[1] . '>' . DI::l10n()->t("Full Timeline") . '</option>';
 360                         $s .= '<option value="2" ' . $importselected[2] . '>' . DI::l10n()->t("Only Mentions") . '</option>';
 361                         $s .= '</select>';
 362                         $s .= '<div class="clear"></div>';
 363                         /*
 364                           $s .= '<label id="statusnet-create_user-label" for="statusnet-create_user">'.DI::l10n()->t('Automatically create contacts').'</label>';
 365                           $s .= '<input id="statusnet-create_user" type="checkbox" name="statusnet-create_user" value="1" '. $create_userchecked . '/>';
 366                           $s .= '<div class="clear"></div>';
 367                          */
 368                         $s .= '<div id="statusnet-disconnect-wrapper">';
 369                         $s .= '<label id="statusnet-disconnect-label" for="statusnet-disconnect">' . DI::l10n()->t('Clear OAuth configuration') . '</label>';
 370                         $s .= '<input id="statusnet-disconnect" type="checkbox" name="statusnet-disconnect" value="1" />';
 371                         $s .= '</div><div class="clear"></div>';
 372                         $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="statusnet-submit" class="settings-submit" value="' . DI::l10n()->t('Save Settings') . '" /></div>';
 373                 }
 374         }
 375         $s .= '</div><div class="clear"></div>';
 376 }
 377
 378 function statusnet_hook_fork(App $a, array &$b)
 379 {
 380         if ($b['name'] != 'notifier_normal') {
 381                 return;
 382         }
 383
 384         $post = $b['data'];
 385
 386         // Deleting and editing is not supported by the addon
 387         if ($post['deleted'] || ($post['created'] !== $post['edited'])) {
 388                 $b['execute'] = false;
 389                 return;
 390         }
 391
 392         // if post comes from GNU Social don't send it back
 393         if ($post['extid'] == Protocol::STATUSNET) {
 394                 $b['execute'] = false;
 395                 return;
 396         }
 397
 398         if ($post['app'] == 'StatusNet') {
 399                 $b['execute'] = false;
 400                 return;
 401         }
 402
 403         if (DI::pConfig()->get($post['uid'], 'statusnet', 'import')) {
 404                 // Don't fork if it isn't a reply to a GNU Social post
 405                 if (($post['parent'] != $post['id']) && !Post::exists(['id' => $post['parent'], 'network' => Protocol::STATUSNET])) {
 406                         Logger::log('No GNU Social parent found for item ' . $post['id']);
 407                         $b['execute'] = false;
 408                         return;
 409                 }
 410         } else {
 411                 // Comments are never exported when we don't import the GNU Social timeline
 412                 if (!strstr($post['postopts'], 'statusnet') || ($post['parent'] != $post['id']) || $post['private']) {
 413                         $b['execute'] = false;
 414                         return;
 415                 }
 416         }
 417 }
 418
 419 function statusnet_post_local(App $a, &$b)
 420 {
 421         if ($b['edit']) {
 422                 return;
 423         }
 424
 425         if (!local_user() || (local_user() != $b['uid'])) {
 426                 return;
 427         }
 428
 429         $statusnet_post = DI::pConfig()->get(local_user(), 'statusnet', 'post');
 430         $statusnet_enable = (($statusnet_post && !empty($_REQUEST['statusnet_enable'])) ? intval($_REQUEST['statusnet_enable']) : 0);
 431
 432         // if API is used, default to the chosen settings
 433         if ($b['api_source'] && intval(DI::pConfig()->get(local_user(), 'statusnet', 'post_by_default'))) {
 434                 $statusnet_enable = 1;
 435         }
 436
 437         if (!$statusnet_enable) {
 438                 return;
 439         }
 440
 441         if (strlen($b['postopts'])) {
 442                 $b['postopts'] .= ',';
 443         }
 444
 445         $b['postopts'] .= 'statusnet';
 446 }
 447
 448 function statusnet_action(App $a, $uid, $pid, $action)
 449 {
 450         $api = DI::pConfig()->get($uid, 'statusnet', 'baseapi');
 451         $ckey = DI::pConfig()->get($uid, 'statusnet', 'consumerkey');
 452         $csecret = DI::pConfig()->get($uid, 'statusnet', 'consumersecret');
 453         $otoken = DI::pConfig()->get($uid, 'statusnet', 'oauthtoken');
 454         $osecret = DI::pConfig()->get($uid, 'statusnet', 'oauthsecret');
 455
 456         $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
 457
 458         Logger::log("statusnet_action '" . $action . "' ID: " . $pid, Logger::DATA);
 459
 460         switch ($action) {
 461                 case "delete":
 462                         $result = $connection->post("statuses/destroy/" . $pid);
 463                         break;
 464                 case "like":
 465                         $result = $connection->post("favorites/create/" . $pid);
 466                         break;
 467                 case "unlike":
 468                         $result = $connection->post("favorites/destroy/" . $pid);
 469                         break;
 470         }
 471         Logger::log("statusnet_action '" . $action . "' send, result: " . print_r($result, true), Logger::DEBUG);
 472 }
 473
 474 function statusnet_post_hook(App $a, &$b)
 475 {
 476         /**
 477          * Post to GNU Social
 478          */
 479         if (!DI::pConfig()->get($b["uid"], 'statusnet', 'import')) {
 480                 if ($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited']))
 481                         return;
 482         }
 483
 484         $b['body'] = Post\Media::addAttachmentsToBody($b['uri-id'], $b['body']);
 485
 486         $api = DI::pConfig()->get($b["uid"], 'statusnet', 'baseapi');
 487         $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $api);
 488
 489         if ($b['parent'] != $b['id']) {
 490                 Logger::log("statusnet_post_hook: parameter " . print_r($b, true), Logger::DATA);
 491
 492                 // Looking if its a reply to a GNU Social post
 493                 $hostlength = strlen($hostname) + 2;
 494                 if ((substr($b["parent-uri"], 0, $hostlength) != $hostname . "::") && (substr($b["extid"], 0, $hostlength) != $hostname . "::") && (substr($b["thr-parent"], 0, $hostlength) != $hostname . "::")) {
 495                         Logger::log("statusnet_post_hook: no GNU Social post " . $b["parent"]);
 496                         return;
 497                 }
 498
 499                 $condition = ['uri' => $b["thr-parent"], 'uid' => $b["uid"]];
 500                 $orig_post = Post::selectFirst(['author-link', 'uri'], $condition);
 501                 if (!DBA::isResult($orig_post)) {
 502                         Logger::log("statusnet_post_hook: no parent found " . $b["thr-parent"]);
 503                         return;
 504                 } else {
 505                         $iscomment = true;
 506                 }
 507
 508                 $nick = preg_replace("=https?://(.*)/(.*)=ism", "$2", $orig_post["author-link"]);
 509
 510                 $nickname = "@[url=" . $orig_post["author-link"] . "]" . $nick . "[/url]";
 511                 $nicknameplain = "@" . $nick;
 512
 513                 Logger::log("statusnet_post_hook: comparing " . $nickname . " and " . $nicknameplain . " with " . $b["body"], Logger::DEBUG);
 514                 if ((strpos($b["body"], $nickname) === false) && (strpos($b["body"], $nicknameplain) === false)) {
 515                         $b["body"] = $nickname . " " . $b["body"];
 516                 }
 517
 518                 Logger::log("statusnet_post_hook: parent found " . print_r($orig_post, true), Logger::DEBUG);
 519         } else {
 520                 $iscomment = false;
 521
 522                 if ($b['private'] || !strstr($b['postopts'], 'statusnet')) {
 523                         return;
 524                 }
 525
 526                 // Dont't post if the post doesn't belong to us.
 527                 // This is a check for forum postings
 528                 $self = DBA::selectFirst('contact', ['id'], ['uid' => $b['uid'], 'self' => true]);
 529                 if ($b['contact-id'] != $self['id']) {
 530                         return;
 531                 }
 532         }
 533
 534         if (($b['verb'] == Activity::POST) && $b['deleted']) {
 535                 statusnet_action($a, $b["uid"], substr($orig_post["uri"], $hostlength), "delete");
 536         }
 537
 538         if ($b['verb'] == Activity::LIKE) {
 539                 Logger::log("statusnet_post_hook: parameter 2 " . substr($b["thr-parent"], $hostlength), Logger::DEBUG);
 540                 if ($b['deleted'])
 541                         statusnet_action($a, $b["uid"], substr($b["thr-parent"], $hostlength), "unlike");
 542                 else
 543                         statusnet_action($a, $b["uid"], substr($b["thr-parent"], $hostlength), "like");
 544                 return;
 545         }
 546
 547         if ($b['deleted'] || ($b['created'] !== $b['edited'])) {
 548                 return;
 549         }
 550
 551         // if posts comes from GNU Social don't send it back
 552         if ($b['extid'] == Protocol::STATUSNET) {
 553                 return;
 554         }
 555
 556         if ($b['app'] == "StatusNet") {
 557                 return;
 558         }
 559
 560         Logger::log('GNU Socialpost invoked');
 561
 562         DI::pConfig()->load($b['uid'], 'statusnet');
 563
 564         $api     = DI::pConfig()->get($b['uid'], 'statusnet', 'baseapi');
 565         $ckey    = DI::pConfig()->get($b['uid'], 'statusnet', 'consumerkey');
 566         $csecret = DI::pConfig()->get($b['uid'], 'statusnet', 'consumersecret');
 567         $otoken  = DI::pConfig()->get($b['uid'], 'statusnet', 'oauthtoken');
 568         $osecret = DI::pConfig()->get($b['uid'], 'statusnet', 'oauthsecret');
 569
 570         if ($ckey && $csecret && $otoken && $osecret) {
 571                 // If it's a repeated message from GNU Social then do a native retweet and exit
 572                 if (statusnet_is_retweet($a, $b['uid'], $b['body'])) {
 573                         return;
 574                 }
 575
 576                 $dent = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
 577                 $max_char = $dent->get_maxlength(); // max. length for a dent
 578
 579                 DI::pConfig()->set($b['uid'], 'statusnet', 'max_char', $max_char);
 580
 581                 $tempfile = "";
 582                 $msgarr = Plaintext::getPost($b, $max_char, true, 7);
 583                 $msg = $msgarr["text"];
 584
 585                 if (($msg == "") && isset($msgarr["title"]))
 586                         $msg = Plaintext::shorten($msgarr["title"], $max_char - 50, $b['uid']);
 587
 588                 $image = "";
 589
 590                 if (isset($msgarr["url"]) && ($msgarr["type"] != "photo")) {
 591                         $msg .= " \n" . $msgarr["url"];
 592                 } elseif (isset($msgarr["image"]) && ($msgarr["type"] != "video")) {
 593                         $image = $msgarr["image"];
 594                 }
 595
 596                 if ($image != "") {
 597                         $img_str = DI::httpRequest()->fetch($image);
 598                         $tempfile = tempnam(get_temppath(), "cache");
 599                         file_put_contents($tempfile, $img_str);
 600                         $postdata = ["status" => $msg, "media[]" => $tempfile];
 601                 } else {
 602                         $postdata = ["status" => $msg];
 603                 }
 604
 605                 // and now send it :-)
 606                 if (strlen($msg)) {
 607                         if ($iscomment) {
 608                                 $postdata["in_reply_to_status_id"] = substr($orig_post["uri"], $hostlength);
 609                                 Logger::log('statusnet_post send reply ' . print_r($postdata, true), Logger::DEBUG);
 610                         }
 611
 612                         // New code that is able to post pictures
 613                         require_once __DIR__ . DIRECTORY_SEPARATOR . 'library' . DIRECTORY_SEPARATOR . 'codebirdsn.php';
 614                         $cb = CodebirdSN::getInstance();
 615                         $cb->setAPIEndpoint($api);
 616                         $cb->setConsumerKey($ckey, $csecret);
 617                         $cb->setToken($otoken, $osecret);
 618                         $result = $cb->statuses_update($postdata);
 619                         //$result = $dent->post('statuses/update', $postdata);
 620                         Logger::log('statusnet_post send, result: ' . print_r($result, true) .
 621                                 "\nmessage: " . $msg . "\nOriginal post: " . print_r($b, true) . "\nPost Data: " . print_r($postdata, true), Logger::DEBUG);
 622
 623                         if (!empty($result->source)) {
 624                                 DI::pConfig()->set($b["uid"], "statusnet", "application_name", strip_tags($result->source));
 625                         }
 626
 627                         if (!empty($result->error)) {
 628                                 Logger::log('Send to GNU Social failed: "' . $result->error . '"');
 629                         } elseif ($iscomment) {
 630                                 Logger::log('statusnet_post: Update extid ' . $result->id . " for post id " . $b['id']);
 631                                 Item::update(['extid' => $hostname . "::" . $result->id, 'body' => $result->text], ['id' => $b['id']]);
 632                         }
 633                 }
 634                 if ($tempfile != "") {
 635                         unlink($tempfile);
 636                 }
 637         }
 638 }
 639
 640 function statusnet_addon_admin_post(App $a)
 641 {
 642         $sites = [];
 643
 644         foreach ($_POST['sitename'] as $id => $sitename) {
 645                 $sitename = trim($sitename);
 646                 $apiurl = trim($_POST['apiurl'][$id]);
 647                 if (!(substr($apiurl, -1) == '/')) {
 648                         $apiurl = $apiurl . '/';
 649                 }
 650                 $secret = trim($_POST['secret'][$id]);
 651                 $key = trim($_POST['key'][$id]);
 652                 //$applicationname = (!empty($_POST['applicationname']) ? Strings::escapeTags(trim($_POST['applicationname'][$id])):'');
 653                 if ($sitename != "" &&
 654                         $apiurl != "" &&
 655                         $secret != "" &&
 656                         $key != "" &&
 657                         empty($_POST['delete'][$id])) {
 658
 659                         $sites[] = [
 660                                 'sitename' => $sitename,
 661                                 'apiurl' => $apiurl,
 662                                 'consumersecret' => $secret,
 663                                 'consumerkey' => $key,
 664                                 //'applicationname' => $applicationname
 665                         ];
 666                 }
 667         }
 668
 669         $sites = DI::config()->set('statusnet', 'sites', $sites);
 670 }
 671
 672 function statusnet_addon_admin(App $a, &$o)
 673 {
 674         $sites = DI::config()->get('statusnet', 'sites');
 675         $sitesform = [];
 676         if (is_array($sites)) {
 677                 foreach ($sites as $id => $s) {
 678                         $sitesform[] = [
 679                                 'sitename' => ["sitename[$id]", "Site name", $s['sitename'], ""],
 680                                 'apiurl' => ["apiurl[$id]", "Api url", $s['apiurl'], DI::l10n()->t("Base API Path \x28remember the trailing /\x29")],
 681                                 'secret' => ["secret[$id]", "Secret", $s['consumersecret'], ""],
 682                                 'key' => ["key[$id]", "Key", $s['consumerkey'], ""],
 683                                 //'applicationname' => Array("applicationname[$id]", "Application name", $s['applicationname'], ""),
 684                                 'delete' => ["delete[$id]", "Delete", False, "Check to delete this preset"],
 685                         ];
 686                 }
 687         }
 688         /* empty form to add new site */
 689         $id = count($sitesform);
 690         $sitesform[] = [
 691                 'sitename' => ["sitename[$id]", DI::l10n()->t("Site name"), "", ""],
 692                 'apiurl' => ["apiurl[$id]", "Api url", "", DI::l10n()->t("Base API Path \x28remember the trailing /\x29")],
 693                 'secret' => ["secret[$id]", DI::l10n()->t("Consumer Secret"), "", ""],
 694                 'key' => ["key[$id]", DI::l10n()->t("Consumer Key"), "", ""],
 695                 //'applicationname' => Array("applicationname[$id]", DI::l10n()->t("Application name"), "", ""),
 696         ];
 697
 698         $t = Renderer::getMarkupTemplate("admin.tpl", "addon/statusnet/");
 699         $o = Renderer::replaceMacros($t, [
 700                 '$submit' => DI::l10n()->t('Save Settings'),
 701                 '$sites' => $sitesform,
 702         ]);
 703 }
 704
 705 function statusnet_prepare_body(App $a, &$b)
 706 {
 707         if ($b["item"]["network"] != Protocol::STATUSNET) {
 708                 return;
 709         }
 710
 711         if ($b["preview"]) {
 712                 $max_char = DI::pConfig()->get(local_user(), 'statusnet', 'max_char');
 713                 if (intval($max_char) == 0) {
 714                         $max_char = 140;
 715                 }
 716
 717                 $item = $b["item"];
 718                 $item["plink"] = DI::baseUrl()->get() . "/display/" . $item["guid"];
 719
 720                 $condition = ['uri' => $item["thr-parent"], 'uid' => local_user()];
 721                 $orig_post = Post::selectFirst(['author-link', 'uri'], $condition);
 722                 if (DBA::isResult($orig_post)) {
 723                         $nick = preg_replace("=https?://(.*)/(.*)=ism", "$2", $orig_post["author-link"]);
 724
 725                         $nickname = "@[url=" . $orig_post["author-link"] . "]" . $nick . "[/url]";
 726                         $nicknameplain = "@" . $nick;
 727
 728                         if ((strpos($item["body"], $nickname) === false) && (strpos($item["body"], $nicknameplain) === false)) {
 729                                 $item["body"] = $nickname . " " . $item["body"];
 730                         }
 731                 }
 732
 733                 $msgarr = Plaintext::getPost($item, $max_char, true, 7);
 734                 $msg = $msgarr["text"];
 735
 736                 if (isset($msgarr["url"]) && ($msgarr["type"] != "photo")) {
 737                         $msg .= " " . $msgarr["url"];
 738                 }
 739
 740                 if (isset($msgarr["image"])) {
 741                         $msg .= " " . $msgarr["image"];
 742                 }
 743
 744                 $b['html'] = nl2br(htmlspecialchars($msg));
 745         }
 746 }
 747
 748 function statusnet_cron(App $a, $b)
 749 {
 750         $last = DI::config()->get('statusnet', 'last_poll');
 751
 752         $poll_interval = intval(DI::config()->get('statusnet', 'poll_interval'));
 753         if (!$poll_interval) {
 754                 $poll_interval = STATUSNET_DEFAULT_POLL_INTERVAL;
 755         }
 756
 757         if ($last) {
 758                 $next = $last + ($poll_interval * 60);
 759                 if ($next > time()) {
 760                         Logger::log('statusnet: poll intervall not reached');
 761                         return;
 762                 }
 763         }
 764         Logger::log('statusnet: cron_start');
 765
 766         $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'statusnet' AND `k` = 'mirror_posts' AND `v` = '1' ORDER BY RAND() ");
 767         if (DBA::isResult($r)) {
 768                 foreach ($r as $rr) {
 769                         Logger::log('statusnet: fetching for user ' . $rr['uid']);
 770                         statusnet_fetchtimeline($a, $rr['uid']);
 771                 }
 772         }
 773
 774         $abandon_days = intval(DI::config()->get('system', 'account_abandon_days'));
 775         if ($abandon_days < 1) {
 776                 $abandon_days = 0;
 777         }
 778
 779         $abandon_limit = date(DateTimeFormat::MYSQL, time() - $abandon_days * 86400);
 780
 781         $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'statusnet' AND `k` = 'import' AND `v` ORDER BY RAND()");
 782         if (DBA::isResult($r)) {
 783                 foreach ($r as $rr) {
 784                         if ($abandon_days != 0) {
 785                                 $user = q("SELECT `login_date` FROM `user` WHERE uid=%d AND `login_date` >= '%s'", $rr['uid'], $abandon_limit);
 786                                 if (!DBA::isResult($user)) {
 787                                         Logger::log('abandoned account: timeline from user ' . $rr['uid'] . ' will not be imported');
 788                                         continue;
 789                                 }
 790                         }
 791
 792                         Logger::log('statusnet: importing timeline from user ' . $rr['uid']);
 793                         statusnet_fetchhometimeline($a, $rr["uid"], $rr["v"]);
 794                 }
 795         }
 796
 797         Logger::log('statusnet: cron_end');
 798
 799         DI::config()->set('statusnet', 'last_poll', time());
 800 }
 801
 802 function statusnet_fetchtimeline(App $a, $uid)
 803 {
 804         $ckey    = DI::pConfig()->get($uid, 'statusnet', 'consumerkey');
 805         $csecret = DI::pConfig()->get($uid, 'statusnet', 'consumersecret');
 806         $api     = DI::pConfig()->get($uid, 'statusnet', 'baseapi');
 807         $otoken  = DI::pConfig()->get($uid, 'statusnet', 'oauthtoken');
 808         $osecret = DI::pConfig()->get($uid, 'statusnet', 'oauthsecret');
 809         $lastid  = DI::pConfig()->get($uid, 'statusnet', 'lastid');
 810
 811         require_once 'mod/item.php';
 812         //  get the application name for the SN app
 813         //  1st try personal config, then system config and fallback to the
 814         //  hostname of the node if neither one is set.
 815         $application_name = DI::pConfig()->get($uid, 'statusnet', 'application_name');
 816         if ($application_name == "") {
 817                 $application_name = DI::config()->get('statusnet', 'application_name');
 818         }
 819         if ($application_name == "") {
 820                 $application_name = DI::baseUrl()->getHostname();
 821         }
 822
 823         $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
 824
 825         $parameters = ["exclude_replies" => true, "trim_user" => true, "contributor_details" => false, "include_rts" => false];
 826
 827         $first_time = ($lastid == "");
 828
 829         if ($lastid <> "") {
 830                 $parameters["since_id"] = $lastid;
 831         }
 832
 833         $items = $connection->get('statuses/user_timeline', $parameters);
 834
 835         if (!is_array($items)) {
 836                 return;
 837         }
 838
 839         $posts = array_reverse($items);
 840
 841         if (count($posts)) {
 842                 foreach ($posts as $post) {
 843                         if ($post->id > $lastid)
 844                                 $lastid = $post->id;
 845
 846                         if ($first_time) {
 847                                 continue;
 848                         }
 849
 850                         if ($post->source == "activity") {
 851                                 continue;
 852                         }
 853
 854                         if (!empty($post->retweeted_status)) {
 855                                 continue;
 856                         }
 857
 858                         if ($post->in_reply_to_status_id != "") {
 859                                 continue;
 860                         }
 861
 862                         if (!stristr($post->source, $application_name)) {
 863                                 $_SESSION["authenticated"] = true;
 864                                 $_SESSION["uid"] = $uid;
 865
 866                                 unset($_REQUEST);
 867                                 $_REQUEST["api_source"] = true;
 868                                 $_REQUEST["profile_uid"] = $uid;
 869                                 //$_REQUEST["source"] = "StatusNet";
 870                                 $_REQUEST["source"] = $post->source;
 871                                 $_REQUEST["extid"] = Protocol::STATUSNET;
 872
 873                                 if (isset($post->id)) {
 874                                         $_REQUEST['message_id'] = Item::newURI($uid, Protocol::STATUSNET . ":" . $post->id);
 875                                 }
 876
 877                                 //$_REQUEST["date"] = $post->created_at;
 878
 879                                 $_REQUEST["title"] = "";
 880
 881                                 $_REQUEST["body"] = $post->text;
 882                                 if (is_string($post->place->name)) {
 883                                         $_REQUEST["location"] = $post->place->name;
 884                                 }
 885
 886                                 if (is_string($post->place->full_name)) {
 887                                         $_REQUEST["location"] = $post->place->full_name;
 888                                 }
 889
 890                                 if (is_array($post->geo->coordinates)) {
 891                                         $_REQUEST["coord"] = $post->geo->coordinates[0] . " " . $post->geo->coordinates[1];
 892                                 }
 893
 894                                 if (is_array($post->coordinates->coordinates)) {
 895                                         $_REQUEST["coord"] = $post->coordinates->coordinates[1] . " " . $post->coordinates->coordinates[0];
 896                                 }
 897
 898                                 //print_r($_REQUEST);
 899                                 if ($_REQUEST["body"] != "") {
 900                                         Logger::log('statusnet: posting for user ' . $uid);
 901
 902                                         item_post($a);
 903                                 }
 904                         }
 905                 }
 906         }
 907         DI::pConfig()->set($uid, 'statusnet', 'lastid', $lastid);
 908 }
 909
 910 function statusnet_address($contact)
 911 {
 912         $hostname = Strings::normaliseLink($contact->statusnet_profile_url);
 913         $nickname = $contact->screen_name;
 914
 915         $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $contact->statusnet_profile_url);
 916
 917         $address = $contact->screen_name . "@" . $hostname;
 918
 919         return $address;
 920 }
 921
 922 function statusnet_fetch_contact($uid, $contact, $create_user)
 923 {
 924         if (empty($contact->statusnet_profile_url)) {
 925                 return -1;
 926         }
 927
 928         $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' AND `network` = '%s'LIMIT 1", intval($uid), DBA::escape(Strings::normaliseLink($contact->statusnet_profile_url)), DBA::escape(Protocol::STATUSNET));
 929
 930         if (!DBA::isResult($r) && !$create_user) {
 931                 return 0;
 932         }
 933
 934         if (DBA::isResult($r) && ($r[0]["readonly"] || $r[0]["blocked"])) {
 935                 Logger::log("statusnet_fetch_contact: Contact '" . $r[0]["nick"] . "' is blocked or readonly.", Logger::DEBUG);
 936                 return -1;
 937         }
 938
 939         if (!DBA::isResult($r)) {
 940                 // create contact record
 941                 q("INSERT INTO `contact` ( `uid`, `created`, `url`, `nurl`, `addr`, `alias`, `notify`, `poll`,
 942                                         `name`, `nick`, `photo`, `network`, `rel`, `priority`,
 943                                         `location`, `about`, `writable`, `blocked`, `readonly`, `pending` )
 944                                         VALUES ( %d, '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', %d, %d, '%s', '%s', %d, 0, 0, 0 ) ",
 945                         intval($uid),
 946                         DBA::escape(DateTimeFormat::utcNow()),
 947                         DBA::escape($contact->statusnet_profile_url),
 948                         DBA::escape(Strings::normaliseLink($contact->statusnet_profile_url)),
 949                         DBA::escape(statusnet_address($contact)),
 950                         DBA::escape(Strings::normaliseLink($contact->statusnet_profile_url)),
 951                         DBA::escape(''),
 952                         DBA::escape(''),
 953                         DBA::escape($contact->name),
 954                         DBA::escape($contact->screen_name),
 955                         DBA::escape($contact->profile_image_url),
 956                         DBA::escape(Protocol::STATUSNET),
 957                         intval(Contact::FRIEND),
 958                         intval(1),
 959                         DBA::escape($contact->location),
 960                         DBA::escape($contact->description),
 961                         intval(1)
 962                 );
 963
 964                 $r = q("SELECT * FROM `contact` WHERE `alias` = '%s' AND `uid` = %d AND `network` = '%s' LIMIT 1",
 965                         DBA::escape($contact->statusnet_profile_url),
 966                         intval($uid),
 967                         DBA::escape(Protocol::STATUSNET));
 968
 969                 if (!DBA::isResult($r)) {
 970                         return false;
 971                 }
 972
 973                 $contact_id = $r[0]['id'];
 974
 975                 Group::addMember(User::getDefaultGroup($uid), $contact_id);
 976
 977                 $photos = Photo::importProfilePhoto($contact->profile_image_url, $uid, $contact_id);
 978
 979                 q("UPDATE `contact` SET `photo` = '%s',
 980                                         `thumb` = '%s',
 981                                         `micro` = '%s',
 982                                         `avatar-date` = '%s'
 983                                 WHERE `id` = %d",
 984                         DBA::escape($photos[0]),
 985                         DBA::escape($photos[1]),
 986                         DBA::escape($photos[2]),
 987                         DBA::escape(DateTimeFormat::utcNow()),
 988                         intval($contact_id)
 989                 );
 990         } else {
 991                 // update profile photos once every two weeks as we have no notification of when they change.
 992                 //$update_photo = (($r[0]['avatar-date'] < DateTimeFormat::convert('now -2 days', '', '', )) ? true : false);
 993                 $update_photo = ($r[0]['avatar-date'] < DateTimeFormat::utc('now -12 hours'));
 994
 995                 // check that we have all the photos, this has been known to fail on occasion
 996                 if ((!$r[0]['photo']) || (!$r[0]['thumb']) || (!$r[0]['micro']) || ($update_photo)) {
 997                         Logger::log("statusnet_fetch_contact: Updating contact " . $contact->screen_name, Logger::DEBUG);
 998
 999                         $photos = Photo::importProfilePhoto($contact->profile_image_url, $uid, $r[0]['id']);
1000
1001                         q("UPDATE `contact` SET `photo` = '%s',
1002                                                 `thumb` = '%s',
1003                                                 `micro` = '%s',
1004                                                 `name-date` = '%s',
1005                                                 `uri-date` = '%s',
1006                                                 `avatar-date` = '%s',
1007                                                 `url` = '%s',
1008                                                 `nurl` = '%s',
1009                                                 `addr` = '%s',
1010                                                 `name` = '%s',
1011                                                 `nick` = '%s',
1012                                                 `location` = '%s',
1013                                                 `about` = '%s'
1014                                         WHERE `id` = %d",
1015                                 DBA::escape($photos[0]),
1016                                 DBA::escape($photos[1]),
1017                                 DBA::escape($photos[2]),
1018                                 DBA::escape(DateTimeFormat::utcNow()),
1019                                 DBA::escape(DateTimeFormat::utcNow()),
1020                                 DBA::escape(DateTimeFormat::utcNow()),
1021                                 DBA::escape($contact->statusnet_profile_url),
1022                                 DBA::escape(Strings::normaliseLink($contact->statusnet_profile_url)),
1023                                 DBA::escape(statusnet_address($contact)),
1024                                 DBA::escape($contact->name),
1025                                 DBA::escape($contact->screen_name),
1026                                 DBA::escape($contact->location),
1027                                 DBA::escape($contact->description),
1028                                 intval($r[0]['id'])
1029                         );
1030                 }
1031         }
1032
1033         return $r[0]["id"];
1034 }
1035
1036 function statusnet_fetchuser(App $a, $uid, $screen_name = "", $user_id = "")
1037 {
1038         $ckey    = DI::pConfig()->get($uid, 'statusnet', 'consumerkey');
1039         $csecret = DI::pConfig()->get($uid, 'statusnet', 'consumersecret');
1040         $api     = DI::pConfig()->get($uid, 'statusnet', 'baseapi');
1041         $otoken  = DI::pConfig()->get($uid, 'statusnet', 'oauthtoken');
1042         $osecret = DI::pConfig()->get($uid, 'statusnet', 'oauthsecret');
1043
1044         require_once __DIR__ . DIRECTORY_SEPARATOR . 'library' . DIRECTORY_SEPARATOR . 'codebirdsn.php';
1045
1046         $cb = CodebirdSN::getInstance();
1047         $cb->setConsumerKey($ckey, $csecret);
1048         $cb->setToken($otoken, $osecret);
1049
1050         $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
1051                 intval($uid));
1052
1053         if (DBA::isResult($r)) {
1054                 $self = $r[0];
1055         } else {
1056                 return;
1057         }
1058
1059         $parameters = [];
1060
1061         if ($screen_name != "") {
1062                 $parameters["screen_name"] = $screen_name;
1063         }
1064
1065         if ($user_id != "") {
1066                 $parameters["user_id"] = $user_id;
1067         }
1068
1069         // Fetching user data
1070         $user = $cb->users_show($parameters);
1071
1072         if (!is_object($user)) {
1073                 return;
1074         }
1075
1076         $contact_id = statusnet_fetch_contact($uid, $user, true);
1077
1078         return $contact_id;
1079 }
1080
1081 function statusnet_createpost(App $a, $uid, $post, $self, $create_user, $only_existing_contact)
1082 {
1083         Logger::log("statusnet_createpost: start", Logger::DEBUG);
1084
1085         $api = DI::pConfig()->get($uid, 'statusnet', 'baseapi');
1086         $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $api);
1087
1088         $postarray = [];
1089         $postarray['network'] = Protocol::STATUSNET;
1090         $postarray['uid'] = $uid;
1091         $postarray['wall'] = 0;
1092
1093         if (!empty($post->retweeted_status)) {
1094                 $content = $post->retweeted_status;
1095                 statusnet_fetch_contact($uid, $content->user, false);
1096         } else {
1097                 $content = $post;
1098         }
1099
1100         $postarray['uri'] = $hostname . "::" . $content->id;
1101
1102         if (Post::exists(['extid' => $postarray['uri'], 'uid' => $uid])) {
1103                 return [];
1104         }
1105
1106         $contactid = 0;
1107
1108         if (!empty($content->in_reply_to_status_id)) {
1109                 $thr_parent = $hostname . "::" . $content->in_reply_to_status_id;
1110
1111                 $item = Post::selectFirst(['uri'], ['uri' => $thr_parent, 'uid' => $uid]);
1112                 if (!DBA::isResult($item)) {
1113                         $item = Post::selectFirst(['uri'], ['extid' => $thr_parent, 'uid' => $uid]);
1114                 }
1115
1116                 if (DBA::isResult($item)) {
1117                         $postarray['thr-parent'] = $item['uri'];
1118                         $postarray['object-type'] = Activity\ObjectType::COMMENT;
1119                 } else {
1120                         $postarray['object-type'] = Activity\ObjectType::NOTE;
1121                 }
1122
1123                 // Is it me?
1124                 $own_url = DI::pConfig()->get($uid, 'statusnet', 'own_url');
1125
1126                 if ($content->user->id == $own_url) {
1127                         $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
1128                                 intval($uid));
1129
1130                         if (DBA::isResult($r)) {
1131                                 $contactid = $r[0]["id"];
1132
1133                                 $postarray['owner-name'] = $r[0]["name"];
1134                                 $postarray['owner-link'] = $r[0]["url"];
1135                                 $postarray['owner-avatar'] = $r[0]["photo"];
1136                         } else {
1137                                 return [];
1138                         }
1139                 }
1140                 // Don't create accounts of people who just comment something
1141                 $create_user = false;
1142         } else {
1143                 $postarray['object-type'] = Activity\ObjectType::NOTE;
1144         }
1145
1146         if ($contactid == 0) {
1147                 $contactid = statusnet_fetch_contact($uid, $post->user, $create_user);
1148                 $postarray['owner-name'] = $post->user->name;
1149                 $postarray['owner-link'] = $post->user->statusnet_profile_url;
1150                 $postarray['owner-avatar'] = $post->user->profile_image_url;
1151         }
1152         if (($contactid == 0) && !$only_existing_contact) {
1153                 $contactid = $self['id'];
1154         } elseif ($contactid <= 0) {
1155                 return [];
1156         }
1157
1158         $postarray['contact-id'] = $contactid;
1159
1160         $postarray['verb'] = Activity::POST;
1161
1162         $postarray['author-name'] = $content->user->name;
1163         $postarray['author-link'] = $content->user->statusnet_profile_url;
1164         $postarray['author-avatar'] = $content->user->profile_image_url;
1165
1166         // To-Do: Maybe unreliable? Can the api be entered without trailing "/"?
1167         $hostname = str_replace("/api/", "/notice/", DI::pConfig()->get($uid, 'statusnet', 'baseapi'));
1168
1169         $postarray['plink'] = $hostname . $content->id;
1170         $postarray['app'] = strip_tags($content->source);
1171
1172         if ($content->user->protected) {
1173                 $postarray['private'] = 1;
1174                 $postarray['allow_cid'] = '<' . $self['id'] . '>';
1175         }
1176
1177         $postarray['body'] = HTML::toBBCode($content->statusnet_html);
1178
1179         $postarray['body'] = statusnet_convertmsg($a, $postarray['body']);
1180
1181         $postarray['created'] = DateTimeFormat::utc($content->created_at);
1182         $postarray['edited'] = DateTimeFormat::utc($content->created_at);
1183
1184         if (!empty($content->place->name)) {
1185                 $postarray["location"] = $content->place->name;
1186         }
1187
1188         if (!empty($content->place->full_name)) {
1189                 $postarray["location"] = $content->place->full_name;
1190         }
1191
1192         if (!empty($content->geo->coordinates)) {
1193                 $postarray["coord"] = $content->geo->coordinates[0] . " " . $content->geo->coordinates[1];
1194         }
1195
1196         if (!empty($content->coordinates->coordinates)) {
1197                 $postarray["coord"] = $content->coordinates->coordinates[1] . " " . $content->coordinates->coordinates[0];
1198         }
1199
1200         Logger::log("statusnet_createpost: end", Logger::DEBUG);
1201
1202         return $postarray;
1203 }
1204
1205 function statusnet_fetchhometimeline(App $a, $uid, $mode = 1)
1206 {
1207         $conversations = [];
1208
1209         $ckey    = DI::pConfig()->get($uid, 'statusnet', 'consumerkey');
1210         $csecret = DI::pConfig()->get($uid, 'statusnet', 'consumersecret');
1211         $api     = DI::pConfig()->get($uid, 'statusnet', 'baseapi');
1212         $otoken  = DI::pConfig()->get($uid, 'statusnet', 'oauthtoken');
1213         $osecret = DI::pConfig()->get($uid, 'statusnet', 'oauthsecret');
1214         $create_user = DI::pConfig()->get($uid, 'statusnet', 'create_user');
1215
1216         // "create_user" is deactivated, since currently you cannot add users manually by now
1217         $create_user = true;
1218
1219         Logger::log("statusnet_fetchhometimeline: Fetching for user " . $uid, Logger::DEBUG);
1220
1221         $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
1222
1223         $own_contact = statusnet_fetch_own_contact($a, $uid);
1224
1225         if (empty($own_contact)) {
1226                 return;
1227         }
1228
1229         $r = q("SELECT * FROM `contact` WHERE `id` = %d AND `uid` = %d LIMIT 1",
1230                 intval($own_contact),
1231                 intval($uid));
1232
1233         if (DBA::isResult($r)) {
1234                 $nick = $r[0]["nick"];
1235         } else {
1236                 Logger::log("statusnet_fetchhometimeline: Own GNU Social contact not found for user " . $uid, Logger::DEBUG);
1237                 return;
1238         }
1239
1240         $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
1241                 intval($uid));
1242
1243         if (DBA::isResult($r)) {
1244                 $self = $r[0];
1245         } else {
1246                 Logger::log("statusnet_fetchhometimeline: Own contact not found for user " . $uid, Logger::DEBUG);
1247                 return;
1248         }
1249
1250         $u = q("SELECT * FROM user WHERE uid = %d LIMIT 1",
1251                 intval($uid));
1252         if (!DBA::isResult($u)) {
1253                 Logger::log("statusnet_fetchhometimeline: Own user not found for user " . $uid, Logger::DEBUG);
1254                 return;
1255         }
1256
1257         $parameters = ["exclude_replies" => false, "trim_user" => false, "contributor_details" => true, "include_rts" => true];
1258         //$parameters["count"] = 200;
1259
1260         if ($mode == 1) {
1261                 // Fetching timeline
1262                 $lastid = DI::pConfig()->get($uid, 'statusnet', 'lasthometimelineid');
1263                 //$lastid = 1;
1264
1265                 $first_time = ($lastid == "");
1266
1267                 if ($lastid != "") {
1268                         $parameters["since_id"] = $lastid;
1269                 }
1270
1271                 $items = $connection->get('statuses/home_timeline', $parameters);
1272
1273                 if (!is_array($items)) {
1274                         if (is_object($items) && isset($items->error)) {
1275                                 $errormsg = $items->error;
1276                         } elseif (is_object($items)) {
1277                                 $errormsg = print_r($items, true);
1278                         } elseif (is_string($items) || is_float($items) || is_int($items)) {
1279                                 $errormsg = $items;
1280                         } else {
1281                                 $errormsg = "Unknown error";
1282                         }
1283
1284                         Logger::log("statusnet_fetchhometimeline: Error fetching home timeline: " . $errormsg, Logger::DEBUG);
1285                         return;
1286                 }
1287
1288                 $posts = array_reverse($items);
1289
1290                 Logger::log("statusnet_fetchhometimeline: Fetching timeline for user " . $uid . " " . sizeof($posts) . " items", Logger::DEBUG);
1291
1292                 if (count($posts)) {
1293                         foreach ($posts as $post) {
1294
1295                                 if ($post->id > $lastid) {
1296                                         $lastid = $post->id;
1297                                 }
1298
1299                                 if ($first_time) {
1300                                         continue;
1301                                 }
1302
1303                                 if (isset($post->statusnet_conversation_id)) {
1304                                         if (!isset($conversations[$post->statusnet_conversation_id])) {
1305                                                 statusnet_complete_conversation($a, $uid, $self, $create_user, $nick, $post->statusnet_conversation_id);
1306                                                 $conversations[$post->statusnet_conversation_id] = $post->statusnet_conversation_id;
1307                                         }
1308                                 } else {
1309                                         $postarray = statusnet_createpost($a, $uid, $post, $self, $create_user, true);
1310
1311                                         if (trim($postarray['body']) == "") {
1312                                                 continue;
1313                                         }
1314
1315                                         $item = Item::insert($postarray);
1316                                         $postarray["id"] = $item;
1317
1318                                         Logger::log('statusnet_fetchhometimeline: User ' . $self["nick"] . ' posted home timeline item ' . $item);
1319                                 }
1320                         }
1321                 }
1322                 DI::pConfig()->set($uid, 'statusnet', 'lasthometimelineid', $lastid);
1323         }
1324
1325         // Fetching mentions
1326         $lastid = DI::pConfig()->get($uid, 'statusnet', 'lastmentionid');
1327         $first_time = ($lastid == "");
1328
1329         if ($lastid != "") {
1330                 $parameters["since_id"] = $lastid;
1331         }
1332
1333         $items = $connection->get('statuses/mentions_timeline', $parameters);
1334
1335         if (!is_array($items)) {
1336                 Logger::log("statusnet_fetchhometimeline: Error fetching mentions: " . print_r($items, true), Logger::DEBUG);
1337                 return;
1338         }
1339
1340         $posts = array_reverse($items);
1341
1342         Logger::log("statusnet_fetchhometimeline: Fetching mentions for user " . $uid . " " . sizeof($posts) . " items", Logger::DEBUG);
1343
1344         if (count($posts)) {
1345                 foreach ($posts as $post) {
1346                         if ($post->id > $lastid) {
1347                                 $lastid = $post->id;
1348                         }
1349
1350                         if ($first_time) {
1351                                 continue;
1352                         }
1353
1354                         $postarray = statusnet_createpost($a, $uid, $post, $self, false, false);
1355
1356                         if (isset($post->statusnet_conversation_id)) {
1357                                 if (!isset($conversations[$post->statusnet_conversation_id])) {
1358                                         statusnet_complete_conversation($a, $uid, $self, $create_user, $nick, $post->statusnet_conversation_id);
1359                                         $conversations[$post->statusnet_conversation_id] = $post->statusnet_conversation_id;
1360                                 }
1361                         } else {
1362                                 if (trim($postarray['body']) == "") {
1363                                         continue;
1364                                 }
1365
1366                                 $item = Item::insert($postarray);
1367
1368                                 Logger::log('statusnet_fetchhometimeline: User ' . $self["nick"] . ' posted mention timeline item ' . $item);
1369                         }
1370                 }
1371         }
1372
1373         DI::pConfig()->set($uid, 'statusnet', 'lastmentionid', $lastid);
1374 }
1375
1376 function statusnet_complete_conversation(App $a, $uid, $self, $create_user, $nick, $conversation)
1377 {
1378         $ckey    = DI::pConfig()->get($uid, 'statusnet', 'consumerkey');
1379         $csecret = DI::pConfig()->get($uid, 'statusnet', 'consumersecret');
1380         $api     = DI::pConfig()->get($uid, 'statusnet', 'baseapi');
1381         $otoken  = DI::pConfig()->get($uid, 'statusnet', 'oauthtoken');
1382         $osecret = DI::pConfig()->get($uid, 'statusnet', 'oauthsecret');
1383         $own_url = DI::pConfig()->get($uid, 'statusnet', 'own_url');
1384
1385         $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
1386
1387         $parameters["count"] = 200;
1388
1389         $items = $connection->get('statusnet/conversation/' . $conversation, $parameters);
1390         if (is_array($items)) {
1391                 $posts = array_reverse($items);
1392
1393                 foreach ($posts as $post) {
1394                         $postarray = statusnet_createpost($a, $uid, $post, $self, false, false);
1395
1396                         if (empty($postarray['body'])) {
1397                                 continue;
1398                         }
1399
1400                         $item = Item::insert($postarray);
1401                         $postarray["id"] = $item;
1402
1403                         Logger::log('statusnet_complete_conversation: User ' . $self["nick"] . ' posted home timeline item ' . $item);
1404                 }
1405         }
1406 }
1407
1408 function statusnet_convertmsg(App $a, $body)
1409 {
1410         $body = preg_replace("=\[url\=https?://([0-9]*).([0-9]*).([0-9]*).([0-9]*)/([0-9]*)\](.*?)\[\/url\]=ism", "$1.$2.$3.$4/$5", $body);
1411
1412         $URLSearchString = "^\[\]";
1413         $links = preg_match_all("/[^!#@]\[url\=([$URLSearchString]*)\](.*?)\[\/url\]/ism", $body, $matches, PREG_SET_ORDER);
1414
1415         $footer = "";
1416         $footerurl = "";
1417         $footerlink = "";
1418         $type = "";
1419
1420         if ($links) {
1421                 foreach ($matches AS $match) {
1422                         $search = "[url=" . $match[1] . "]" . $match[2] . "[/url]";
1423
1424                         Logger::log("statusnet_convertmsg: expanding url " . $match[1], Logger::DEBUG);
1425
1426                         $expanded_url = DI::httpRequest()->finalUrl($match[1]);
1427
1428                         Logger::log("statusnet_convertmsg: fetching data for " . $expanded_url, Logger::DEBUG);
1429
1430                         $oembed_data = OEmbed::fetchURL($expanded_url, true);
1431
1432                         Logger::log("statusnet_convertmsg: fetching data: done", Logger::DEBUG);
1433
1434                         if ($type == "") {
1435                                 $type = $oembed_data->type;
1436                         }
1437
1438                         if ($oembed_data->type == "video") {
1439                                 //$body = str_replace($search, "[video]".$expanded_url."[/video]", $body);
1440                                 $type = $oembed_data->type;
1441                                 $footerurl = $expanded_url;
1442                                 $footerlink = "[url=" . $expanded_url . "]" . $expanded_url . "[/url]";
1443
1444                                 $body = str_replace($search, $footerlink, $body);
1445                         } elseif (($oembed_data->type == "photo") && isset($oembed_data->url)) {
1446                                 $body = str_replace($search, "[url=" . $expanded_url . "][img]" . $oembed_data->url . "[/img][/url]", $body);
1447                         } elseif ($oembed_data->type != "link") {
1448                                 $body = str_replace($search, "[url=" . $expanded_url . "]" . $expanded_url . "[/url]", $body);
1449                         } else {
1450                                 $img_str = DI::httpRequest()->fetch($expanded_url, 4);
1451
1452                                 $tempfile = tempnam(get_temppath(), "cache");
1453                                 file_put_contents($tempfile, $img_str);
1454                                 $mime = mime_content_type($tempfile);
1455                                 unlink($tempfile);
1456
1457                                 if (substr($mime, 0, 6) == "image/") {
1458                                         $type = "photo";
1459                                         $body = str_replace($search, "[img]" . $expanded_url . "[/img]", $body);
1460                                 } else {
1461                                         $type = $oembed_data->type;
1462                                         $footerurl = $expanded_url;
1463                                         $footerlink = "[url=" . $expanded_url . "]" . $expanded_url . "[/url]";
1464
1465                                         $body = str_replace($search, $footerlink, $body);
1466                                 }
1467                         }
1468                 }
1469
1470                 if ($footerurl != "") {
1471                         $footer = "\n" . PageInfo::getFooterFromUrl($footerurl);
1472                 }
1473
1474                 if (($footerlink != "") && (trim($footer) != "")) {
1475                         $removedlink = trim(str_replace($footerlink, "", $body));
1476
1477                         if (($removedlink == "") || strstr($body, $removedlink)) {
1478                                 $body = $removedlink;
1479                         }
1480
1481                         $body .= $footer;
1482                 }
1483         }
1484
1485         return $body;
1486 }
1487
1488 function statusnet_fetch_own_contact(App $a, $uid)
1489 {
1490         $ckey    = DI::pConfig()->get($uid, 'statusnet', 'consumerkey');
1491         $csecret = DI::pConfig()->get($uid, 'statusnet', 'consumersecret');
1492         $api     = DI::pConfig()->get($uid, 'statusnet', 'baseapi');
1493         $otoken  = DI::pConfig()->get($uid, 'statusnet', 'oauthtoken');
1494         $osecret = DI::pConfig()->get($uid, 'statusnet', 'oauthsecret');
1495         $own_url = DI::pConfig()->get($uid, 'statusnet', 'own_url');
1496
1497         $contact_id = 0;
1498
1499         if ($own_url == "") {
1500                 $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
1501
1502                 // Fetching user data
1503                 $user = $connection->get('account/verify_credentials');
1504
1505                 if (empty($user)) {
1506                         return false;
1507                 }
1508
1509                 DI::pConfig()->set($uid, 'statusnet', 'own_url', Strings::normaliseLink($user->statusnet_profile_url));
1510
1511                 $contact_id = statusnet_fetch_contact($uid, $user, true);
1512         } else {
1513                 $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1",
1514                         intval($uid), DBA::escape($own_url));
1515                 if (DBA::isResult($r)) {
1516                         $contact_id = $r[0]["id"];
1517                 } else {
1518                         DI::pConfig()->delete($uid, 'statusnet', 'own_url');
1519                 }
1520         }
1521         return $contact_id;
1522 }
1523
1524 function statusnet_is_retweet(App $a, $uid, $body)
1525 {
1526         $body = trim($body);
1527
1528         // Skip if it isn't a pure repeated messages
1529         // Does it start with a share?
1530         if (strpos($body, "[share") > 0) {
1531                 return false;
1532         }
1533
1534         // Does it end with a share?
1535         if (strlen($body) > (strrpos($body, "[/share]") + 8)) {
1536                 return false;
1537         }
1538
1539         $attributes = preg_replace("/\[share(.*?)\]\s?(.*?)\s?\[\/share\]\s?/ism", "$1", $body);
1540         // Skip if there is no shared message in there
1541         if ($body == $attributes) {
1542                 return false;
1543         }
1544
1545         $link = "";
1546         preg_match("/link='(.*?)'/ism", $attributes, $matches);
1547         if (!empty($matches[1])) {
1548                 $link = $matches[1];
1549         }
1550
1551         preg_match('/link="(.*?)"/ism', $attributes, $matches);
1552         if (!empty($matches[1])) {
1553                 $link = $matches[1];
1554         }
1555
1556         $ckey    = DI::pConfig()->get($uid, 'statusnet', 'consumerkey');
1557         $csecret = DI::pConfig()->get($uid, 'statusnet', 'consumersecret');
1558         $api     = DI::pConfig()->get($uid, 'statusnet', 'baseapi');
1559         $otoken  = DI::pConfig()->get($uid, 'statusnet', 'oauthtoken');
1560         $osecret = DI::pConfig()->get($uid, 'statusnet', 'oauthsecret');
1561         $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $api);
1562
1563         $id = preg_replace("=https?://" . $hostname . "/notice/(.*)=ism", "$1", $link);
1564
1565         if ($id == $link) {
1566                 return false;
1567         }
1568
1569         Logger::log('statusnet_is_retweet: Retweeting id ' . $id . ' for user ' . $uid, Logger::DEBUG);
1570
1571         $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
1572
1573         $result = $connection->post('statuses/retweet/' . $id);
1574
1575         Logger::log('statusnet_is_retweet: result ' . print_r($result, true), Logger::DEBUG);
1576
1577         return isset($result->id);
1578 }