statusnet/statusnet.php

   1 <?php
   2 /**
   3  * Name: GNU Social Connector
   4  * Description: Bidirectional (posting, relaying and reading) connector for GNU Social.
   5  * Version: 1.0.5
   6  * Author: Tobias Diekershoff <https://f.diekershoff.de/profile/tobias>
   7  * Author: Michael Vogel <https://pirati.ca/profile/heluecht>
   8  *
   9  * Copyright (c) 2011-2013 Tobias Diekershoff, Michael Vogel
  10  * All rights reserved.
  11  *
  12  * Redistribution and use in source and binary forms, with or without
  13  * modification, are permitted provided that the following conditions are met:
  14  *    * Redistributions of source code must retain the above copyright notice,
  15  *     this list of conditions and the following disclaimer.
  16  *    * Redistributions in binary form must reproduce the above
  17  *    * copyright notice, this list of conditions and the following disclaimer in
  18  *      the documentation and/or other materials provided with the distribution.
  19  *    * Neither the name of the <organization> nor the names of its contributors
  20  *      may be used to endorse or promote products derived from this software
  21  *      without specific prior written permission.
  22  *
  23  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
  24  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
  25  * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
  26  * DISCLAIMED. IN NO EVENT SHALL <COPYRIGHT HOLDER> BE LIABLE FOR ANY DIRECT,
  27  * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
  28  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  29  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
  30  * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
  31  * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
  32  * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  33  *
  34  */
  35
  36
  37 /***
  38  * We have to alter the TwitterOAuth class a little bit to work with any GNU Social
  39  * installation abroad. Basically it's only make the API path variable and be happy.
  40  *
  41  * Thank you guys for the Twitter compatible API!
  42  */
  43
  44 define('STATUSNET_DEFAULT_POLL_INTERVAL', 5); // given in minutes
  45
  46 require_once('library/twitteroauth.php');
  47 require_once('include/enotify.php');
  48 require_once("include/socgraph.php");
  49
  50 class StatusNetOAuth extends TwitterOAuth {
  51     function get_maxlength() {
  52         $config = $this->get($this->host . 'statusnet/config.json');
  53         return $config->site->textlimit;
  54     }
  55     function accessTokenURL()  { return $this->host.'oauth/access_token'; }
  56     function authenticateURL() { return $this->host.'oauth/authenticate'; }
  57     function authorizeURL() { return $this->host.'oauth/authorize'; }
  58     function requestTokenURL() { return $this->host.'oauth/request_token'; }
  59     function __construct($apipath, $consumer_key, $consumer_secret, $oauth_token = NULL, $oauth_token_secret = NULL) {
  60         parent::__construct($consumer_key, $consumer_secret, $oauth_token, $oauth_token_secret);
  61         $this->host = $apipath;
  62     }
  63   /**
  64    * Make an HTTP request
  65    *
  66    * @return API results
  67    *
  68    * Copied here from the twitteroauth library and complemented by applying the proxy settings of friendica
  69    */
  70   function http($url, $method, $postfields = NULL) {
  71     $this->http_info = array();
  72     $ci = curl_init();
  73     /* Curl settings */
  74     $prx = get_config('system','proxy');
  75     if(strlen($prx)) {
  76         curl_setopt($ci, CURLOPT_HTTPPROXYTUNNEL, 1);
  77         curl_setopt($ci, CURLOPT_PROXY, $prx);
  78         $prxusr = get_config('system','proxyuser');
  79         if(strlen($prxusr))
  80             curl_setopt($ci, CURLOPT_PROXYUSERPWD, $prxusr);
  81     }
  82     curl_setopt($ci, CURLOPT_USERAGENT, $this->useragent);
  83     curl_setopt($ci, CURLOPT_CONNECTTIMEOUT, $this->connecttimeout);
  84     curl_setopt($ci, CURLOPT_TIMEOUT, $this->timeout);
  85     curl_setopt($ci, CURLOPT_RETURNTRANSFER, TRUE);
  86     curl_setopt($ci, CURLOPT_HTTPHEADER, array('Expect:'));
  87     curl_setopt($ci, CURLOPT_SSL_VERIFYPEER, $this->ssl_verifypeer);
  88     curl_setopt($ci, CURLOPT_HEADERFUNCTION, array($this, 'getHeader'));
  89     curl_setopt($ci, CURLOPT_HEADER, FALSE);
  90
  91     switch ($method) {
  92       case 'POST':
  93         curl_setopt($ci, CURLOPT_POST, TRUE);
  94         if (!empty($postfields)) {
  95           curl_setopt($ci, CURLOPT_POSTFIELDS, $postfields);
  96         }
  97         break;
  98       case 'DELETE':
  99         curl_setopt($ci, CURLOPT_CUSTOMREQUEST, 'DELETE');
 100         if (!empty($postfields)) {
 101           $url = "{$url}?{$postfields}";
 102         }
 103     }
 104
 105     curl_setopt($ci, CURLOPT_URL, $url);
 106     $response = curl_exec($ci);
 107     $this->http_code = curl_getinfo($ci, CURLINFO_HTTP_CODE);
 108     $this->http_info = array_merge($this->http_info, curl_getinfo($ci));
 109     $this->url = $url;
 110     curl_close ($ci);
 111     return $response;
 112   }
 113 }
 114
 115 function statusnet_install() {
 116         //  we need some hooks, for the configuration and for sending tweets
 117         register_hook('connector_settings', 'addon/statusnet/statusnet.php', 'statusnet_settings');
 118         register_hook('connector_settings_post', 'addon/statusnet/statusnet.php', 'statusnet_settings_post');
 119         register_hook('notifier_normal', 'addon/statusnet/statusnet.php', 'statusnet_post_hook');
 120         register_hook('post_local', 'addon/statusnet/statusnet.php', 'statusnet_post_local');
 121         register_hook('jot_networks',    'addon/statusnet/statusnet.php', 'statusnet_jot_nets');
 122         register_hook('cron', 'addon/statusnet/statusnet.php', 'statusnet_cron');
 123         register_hook('prepare_body', 'addon/statusnet/statusnet.php', 'statusnet_prepare_body');
 124         register_hook('check_item_notification','addon/statusnet/statusnet.php', 'statusnet_check_item_notification');
 125         logger("installed GNU Social");
 126 }
 127
 128
 129 function statusnet_uninstall() {
 130         unregister_hook('connector_settings', 'addon/statusnet/statusnet.php', 'statusnet_settings');
 131         unregister_hook('connector_settings_post', 'addon/statusnet/statusnet.php', 'statusnet_settings_post');
 132         unregister_hook('notifier_normal', 'addon/statusnet/statusnet.php', 'statusnet_post_hook');
 133         unregister_hook('post_local', 'addon/statusnet/statusnet.php', 'statusnet_post_local');
 134         unregister_hook('jot_networks',    'addon/statusnet/statusnet.php', 'statusnet_jot_nets');
 135         unregister_hook('cron', 'addon/statusnet/statusnet.php', 'statusnet_cron');
 136         unregister_hook('prepare_body', 'addon/statusnet/statusnet.php', 'statusnet_prepare_body');
 137         unregister_hook('check_item_notification','addon/statusnet/statusnet.php', 'statusnet_check_item_notification');
 138
 139         // old setting - remove only
 140         unregister_hook('post_local_end', 'addon/statusnet/statusnet.php', 'statusnet_post_hook');
 141         unregister_hook('plugin_settings', 'addon/statusnet/statusnet.php', 'statusnet_settings');
 142         unregister_hook('plugin_settings_post', 'addon/statusnet/statusnet.php', 'statusnet_settings_post');
 143
 144 }
 145
 146 function statusnet_check_item_notification($a, &$notification_data) {
 147         $notification_data["profiles"][] = get_pconfig($notification_data["uid"], 'statusnet', 'own_url');
 148 }
 149
 150 function statusnet_jot_nets(&$a,&$b) {
 151         if(! local_user())
 152                 return;
 153
 154         $statusnet_post = get_pconfig(local_user(),'statusnet','post');
 155         if(intval($statusnet_post) == 1) {
 156                 $statusnet_defpost = get_pconfig(local_user(),'statusnet','post_by_default');
 157                 $selected = ((intval($statusnet_defpost) == 1) ? ' checked="checked" ' : '');
 158                 $b .= '<div class="profile-jot-net"><input type="checkbox" name="statusnet_enable"' . $selected . ' value="1" /> '
 159                         . t('Post to GNU Social') . '</div>';
 160         }
 161 }
 162
 163 function statusnet_settings_post ($a,$post) {
 164         if(! local_user())
 165                 return;
 166         // don't check GNU Social settings if GNU Social submit button is not clicked
 167         if (!x($_POST,'statusnet-submit'))
 168                 return;
 169
 170         if (isset($_POST['statusnet-disconnect'])) {
 171                 /***
 172                  * if the GNU Social-disconnect checkbox is set, clear the GNU Social configuration
 173                  */
 174                 del_pconfig(local_user(), 'statusnet', 'consumerkey');
 175                 del_pconfig(local_user(), 'statusnet', 'consumersecret');
 176                 del_pconfig(local_user(), 'statusnet', 'post');
 177                 del_pconfig(local_user(), 'statusnet', 'post_by_default');
 178                 del_pconfig(local_user(), 'statusnet', 'oauthtoken');
 179                 del_pconfig(local_user(), 'statusnet', 'oauthsecret');
 180                 del_pconfig(local_user(), 'statusnet', 'baseapi');
 181                 del_pconfig(local_user(), 'statusnet', 'lastid');
 182                 del_pconfig(local_user(), 'statusnet', 'mirror_posts');
 183                 del_pconfig(local_user(), 'statusnet', 'import');
 184                 del_pconfig(local_user(), 'statusnet', 'create_user');
 185                 del_pconfig(local_user(), 'statusnet', 'own_id');
 186         } else {
 187         if (isset($_POST['statusnet-preconf-apiurl'])) {
 188                 /***
 189                  * If the user used one of the preconfigured GNU Social server credentials
 190                  * use them. All the data are available in the global config.
 191                  * Check the API Url never the less and blame the admin if it's not working ^^
 192                  */
 193                 $globalsn = get_config('statusnet', 'sites');
 194                 foreach ( $globalsn as $asn) {
 195                         if ($asn['apiurl'] == $_POST['statusnet-preconf-apiurl'] ) {
 196                                 $apibase = $asn['apiurl'];
 197                                 $c = fetch_url( $apibase . 'statusnet/version.xml' );
 198                                 if (strlen($c) > 0) {
 199                                         set_pconfig(local_user(), 'statusnet', 'consumerkey', $asn['consumerkey'] );
 200                                         set_pconfig(local_user(), 'statusnet', 'consumersecret', $asn['consumersecret'] );
 201                                         set_pconfig(local_user(), 'statusnet', 'baseapi', $asn['apiurl'] );
 202                                         //set_pconfig(local_user(), 'statusnet', 'application_name', $asn['applicationname'] );
 203                                 } else {
 204                                         notice( t('Please contact your site administrator.<br />The provided API URL is not valid.').EOL.$asn['apiurl'].EOL );
 205                                 }
 206                         }
 207                 }
 208                 goaway($a->get_baseurl().'/settings/connectors');
 209         } else {
 210         if (isset($_POST['statusnet-consumersecret'])) {
 211                 //  check if we can reach the API of the GNU Social server
 212                 //  we'll check the API Version for that, if we don't get one we'll try to fix the path but will
 213                 //  resign quickly after this one try to fix the path ;-)
 214                 $apibase = $_POST['statusnet-baseapi'];
 215                 $c = fetch_url( $apibase . 'statusnet/version.xml' );
 216                 if (strlen($c) > 0) {
 217                         //  ok the API path is correct, let's save the settings
 218                         set_pconfig(local_user(), 'statusnet', 'consumerkey', $_POST['statusnet-consumerkey']);
 219                         set_pconfig(local_user(), 'statusnet', 'consumersecret', $_POST['statusnet-consumersecret']);
 220                         set_pconfig(local_user(), 'statusnet', 'baseapi', $apibase );
 221                         //set_pconfig(local_user(), 'statusnet', 'application_name', $_POST['statusnet-applicationname'] );
 222                 } else {
 223                         //  the API path is not correct, maybe missing trailing / ?
 224                         $apibase = $apibase . '/';
 225                         $c = fetch_url( $apibase . 'statusnet/version.xml' );
 226                         if (strlen($c) > 0) {
 227                                 //  ok the API path is now correct, let's save the settings
 228                                 set_pconfig(local_user(), 'statusnet', 'consumerkey', $_POST['statusnet-consumerkey']);
 229                                 set_pconfig(local_user(), 'statusnet', 'consumersecret', $_POST['statusnet-consumersecret']);
 230                                 set_pconfig(local_user(), 'statusnet', 'baseapi', $apibase );
 231                         } else {
 232                                 //  still not the correct API base, let's do noting
 233                                 notice( t('We could not contact the GNU Social API with the Path you entered.').EOL );
 234                         }
 235                 }
 236                 goaway($a->get_baseurl().'/settings/connectors');
 237         } else {
 238         if (isset($_POST['statusnet-pin'])) {
 239                 //  if the user supplied us with a PIN from GNU Social, let the magic of OAuth happen
 240                 $api     = get_pconfig(local_user(), 'statusnet', 'baseapi');
 241                 $ckey    = get_pconfig(local_user(), 'statusnet', 'consumerkey'  );
 242                 $csecret = get_pconfig(local_user(), 'statusnet', 'consumersecret' );
 243                 //  the token and secret for which the PIN was generated were hidden in the settings
 244                 //  form as token and token2, we need a new connection to GNU Social using these token
 245                 //  and secret to request a Access Token with the PIN
 246                 $connection = new StatusNetOAuth($api, $ckey, $csecret, $_POST['statusnet-token'], $_POST['statusnet-token2']);
 247                 $token   = $connection->getAccessToken( $_POST['statusnet-pin'] );
 248                 //  ok, now that we have the Access Token, save them in the user config
 249                 set_pconfig(local_user(),'statusnet', 'oauthtoken',  $token['oauth_token']);
 250                 set_pconfig(local_user(),'statusnet', 'oauthsecret', $token['oauth_token_secret']);
 251                 set_pconfig(local_user(),'statusnet', 'post', 1);
 252                 set_pconfig(local_user(),'statusnet', 'post_taglinks', 1);
 253                 //  reload the Addon Settings page, if we don't do it see Bug #42
 254                 goaway($a->get_baseurl().'/settings/connectors');
 255         } else {
 256                 //  if no PIN is supplied in the POST variables, the user has changed the setting
 257                 //  to post a dent for every new __public__ posting to the wall
 258                 set_pconfig(local_user(),'statusnet','post',intval($_POST['statusnet-enable']));
 259                 set_pconfig(local_user(),'statusnet','post_by_default',intval($_POST['statusnet-default']));
 260                 set_pconfig(local_user(), 'statusnet', 'mirror_posts', intval($_POST['statusnet-mirror']));
 261                 set_pconfig(local_user(), 'statusnet', 'import', intval($_POST['statusnet-import']));
 262                 set_pconfig(local_user(), 'statusnet', 'create_user', intval($_POST['statusnet-create_user']));
 263
 264                 if (!intval($_POST['statusnet-mirror']))
 265                         del_pconfig(local_user(),'statusnet','lastid');
 266
 267                 info( t('GNU Social settings updated.') . EOL);
 268         }}}}
 269 }
 270 function statusnet_settings(&$a,&$s) {
 271         if(! local_user())
 272                 return;
 273         $a->page['htmlhead'] .= '<link rel="stylesheet"  type="text/css" href="' . $a->get_baseurl() . '/addon/statusnet/statusnet.css' . '" media="all" />' . "\r\n";
 274         /***
 275          * 1) Check that we have a base api url and a consumer key & secret
 276          * 2) If no OAuthtoken & stuff is present, generate button to get some
 277          *    allow the user to cancel the connection process at this step
 278          * 3) Checkbox for "Send public notices (respect size limitation)
 279          */
 280         $api     = get_pconfig(local_user(), 'statusnet', 'baseapi');
 281         $ckey    = get_pconfig(local_user(), 'statusnet', 'consumerkey');
 282         $csecret = get_pconfig(local_user(), 'statusnet', 'consumersecret');
 283         $otoken  = get_pconfig(local_user(), 'statusnet', 'oauthtoken');
 284         $osecret = get_pconfig(local_user(), 'statusnet', 'oauthsecret');
 285         $enabled = get_pconfig(local_user(), 'statusnet', 'post');
 286         $checked = (($enabled) ? ' checked="checked" ' : '');
 287         $defenabled = get_pconfig(local_user(),'statusnet','post_by_default');
 288         $defchecked = (($defenabled) ? ' checked="checked" ' : '');
 289         $mirrorenabled = get_pconfig(local_user(),'statusnet','mirror_posts');
 290         $mirrorchecked = (($mirrorenabled) ? ' checked="checked" ' : '');
 291         $import = get_pconfig(local_user(),'statusnet','import');
 292         $importselected = array("", "", "");
 293         $importselected[$import] = ' selected="selected"';
 294         //$importenabled = get_pconfig(local_user(),'statusnet','import');
 295         //$importchecked = (($importenabled) ? ' checked="checked" ' : '');
 296         $create_userenabled = get_pconfig(local_user(),'statusnet','create_user');
 297         $create_userchecked = (($create_userenabled) ? ' checked="checked" ' : '');
 298
 299         $css = (($enabled) ? '' : '-disabled');
 300
 301         $s .= '<span id="settings_statusnet_inflated" class="settings-block fakelink" style="display: block;" onclick="openClose(\'settings_statusnet_expanded\'); openClose(\'settings_statusnet_inflated\');">';
 302         $s .= '<img class="connector'.$css.'" src="images/gnusocial.png" /><h3 class="connector">'. t('GNU Social Import/Export/Mirror').'</h3>';
 303         $s .= '</span>';
 304         $s .= '<div id="settings_statusnet_expanded" class="settings-block" style="display: none;">';
 305         $s .= '<span class="fakelink" onclick="openClose(\'settings_statusnet_expanded\'); openClose(\'settings_statusnet_inflated\');">';
 306         $s .= '<img class="connector'.$css.'" src="images/gnusocial.png" /><h3 class="connector">'. t('GNU Social Import/Export/Mirror').'</h3>';
 307         $s .= '</span>';
 308
 309         if ( (!$ckey) && (!$csecret) ) {
 310                 /***
 311                  * no consumer keys
 312                  */
 313                 $globalsn = get_config('statusnet', 'sites');
 314                 /***
 315                  * lets check if we have one or more globally configured GNU Social
 316                  * server OAuth credentials in the configuration. If so offer them
 317                  * with a little explanation to the user as choice - otherwise
 318                  * ignore this option entirely.
 319                  */
 320                 if (! $globalsn == null) {
 321                         $s .= '<h4>' . t('Globally Available GNU Social OAuthKeys') . '</h4>';
 322                         $s .= '<p>'. 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>';
 323                         $s .= '<div id="statusnet-preconf-wrapper">';
 324                         foreach ($globalsn as $asn) {
 325                                 $s .= '<input type="radio" name="statusnet-preconf-apiurl" value="'. $asn['apiurl'] .'">'. $asn['sitename'] .'<br />';
 326                         }
 327                         $s .= '<p></p><div class="clear"></div></div>';
 328                         $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="statusnet-submit" class="settings-submit" value="' . t('Save Settings') . '" /></div>';
 329                 }
 330                 $s .= '<h4>' . t('Provide your own OAuth Credentials') . '</h4>';
 331                 $s .= '<p>'. 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>';
 332                 $s .= '<div id="statusnet-consumer-wrapper">';
 333                 $s .= '<label id="statusnet-consumerkey-label" for="statusnet-consumerkey">'. t('OAuth Consumer Key') .'</label>';
 334                 $s .= '<input id="statusnet-consumerkey" type="text" name="statusnet-consumerkey" size="35" /><br />';
 335                 $s .= '<div class="clear"></div>';
 336                 $s .= '<label id="statusnet-consumersecret-label" for="statusnet-consumersecret">'. t('OAuth Consumer Secret') .'</label>';
 337                 $s .= '<input id="statusnet-consumersecret" type="text" name="statusnet-consumersecret" size="35" /><br />';
 338                 $s .= '<div class="clear"></div>';
 339                 $s .= '<label id="statusnet-baseapi-label" for="statusnet-baseapi">'. t("Base API Path \x28remember the trailing /\x29") .'</label>';
 340                 $s .= '<input id="statusnet-baseapi" type="text" name="statusnet-baseapi" size="35" /><br />';
 341                 $s .= '<div class="clear"></div>';
 342                 //$s .= '<label id="statusnet-applicationname-label" for="statusnet-applicationname">'.t('GNU Socialapplication name').'</label>';
 343                 //$s .= '<input id="statusnet-applicationname" type="text" name="statusnet-applicationname" size="35" /><br />';
 344                 $s .= '<p></p><div class="clear"></div>';
 345                 $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="statusnet-submit" class="settings-submit" value="' . t('Save Settings') . '" /></div>';
 346                 $s .= '</div>';
 347         } else {
 348                 /***
 349                  * ok we have a consumer key pair now look into the OAuth stuff
 350                  */
 351                 if ( (!$otoken) && (!$osecret) ) {
 352                         /***
 353                          * the user has not yet connected the account to GNU Social
 354                          * get a temporary OAuth key/secret pair and display a button with
 355                          * which the user can request a PIN to connect the account to a
 356                          * account at GNU Social
 357                          */
 358                         $connection = new StatusNetOAuth($api, $ckey, $csecret);
 359                         $request_token = $connection->getRequestToken('oob');
 360                         $token = $request_token['oauth_token'];
 361                         /***
 362                          *  make some nice form
 363                          */
 364                         $s .= '<p>'. 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>';
 365                         $s .= '<a href="'.$connection->getAuthorizeURL($token,False).'" target="_statusnet"><img src="addon/statusnet/signinwithstatusnet.png" alt="'. t('Log in with GNU Social') .'"></a>';
 366                         $s .= '<div id="statusnet-pin-wrapper">';
 367                         $s .= '<label id="statusnet-pin-label" for="statusnet-pin">'. t('Copy the security code from GNU Social here') .'</label>';
 368                         $s .= '<input id="statusnet-pin" type="text" name="statusnet-pin" />';
 369                         $s .= '<input id="statusnet-token" type="hidden" name="statusnet-token" value="'.$token.'" />';
 370                         $s .= '<input id="statusnet-token2" type="hidden" name="statusnet-token2" value="'.$request_token['oauth_token_secret'].'" />';
 371                         $s .= '</div><div class="clear"></div>';
 372                         $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="statusnet-submit" class="settings-submit" value="' . t('Save Settings') . '" /></div>';
 373                         $s .= '<h4>'.t('Cancel Connection Process').'</h4>';
 374                         $s .= '<div id="statusnet-cancel-wrapper">';
 375                         $s .= '<p>'.t('Current GNU Social API is').': '.$api.'</p>';
 376                         $s .= '<label id="statusnet-cancel-label" for="statusnet-cancel">'. t('Cancel GNU Social Connection') . '</label>';
 377                         $s .= '<input id="statusnet-cancel" type="checkbox" name="statusnet-disconnect" value="1" />';
 378                         $s .= '</div><div class="clear"></div>';
 379                         $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="statusnet-submit" class="settings-submit" value="' . t('Save Settings') . '" /></div>';
 380                 } else {
 381                         /***
 382                          *  we have an OAuth key / secret pair for the user
 383                          *  so let's give a chance to disable the postings to GNU Social
 384                          */
 385                         $connection = new StatusNetOAuth($api,$ckey,$csecret,$otoken,$osecret);
 386                         $details = $connection->get('account/verify_credentials');
 387                         $s .= '<div id="statusnet-info" ><img id="statusnet-avatar" src="'.$details->profile_image_url.'" /><p id="statusnet-info-block">'. t('Currently connected to: ') .'<a href="'.$details->statusnet_profile_url.'" target="_statusnet">'.$details->screen_name.'</a><br /><em>'.$details->description.'</em></p></div>';
 388                         $s .= '<p>'. 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>';
 389                         if ($a->user['hidewall']) {
 390                             $s .= '<p>'. 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>';
 391                         }
 392                         $s .= '<div id="statusnet-enable-wrapper">';
 393                         $s .= '<label id="statusnet-enable-label" for="statusnet-checkbox">'. t('Allow posting to GNU Social') .'</label>';
 394                         $s .= '<input id="statusnet-checkbox" type="checkbox" name="statusnet-enable" value="1" ' . $checked . '/>';
 395                         $s .= '<div class="clear"></div>';
 396                         $s .= '<label id="statusnet-default-label" for="statusnet-default">'. t('Send public postings to GNU Social by default') .'</label>';
 397                         $s .= '<input id="statusnet-default" type="checkbox" name="statusnet-default" value="1" ' . $defchecked . '/>';
 398                         $s .= '<div class="clear"></div>';
 399
 400                         $s .= '<label id="statusnet-mirror-label" for="statusnet-mirror">'.t('Mirror all posts from GNU Social that are no replies or repeated messages').'</label>';
 401                         $s .= '<input id="statusnet-mirror" type="checkbox" name="statusnet-mirror" value="1" '. $mirrorchecked . '/>';
 402
 403                         $s .= '<div class="clear"></div>';
 404                         $s .= '</div>';
 405
 406                         $s .= '<label id="statusnet-import-label" for="statusnet-import">'.t('Import the remote timeline').'</label>';
 407                         //$s .= '<input id="statusnet-import" type="checkbox" name="statusnet-import" value="1" '. $importchecked . '/>';
 408
 409                         $s .= '<select name="statusnet-import" id="statusnet-import" />';
 410                         $s .= '<option value="0" '.$importselected[0].'>'.t("Disabled").'</option>';
 411                         $s .= '<option value="1" '.$importselected[1].'>'.t("Full Timeline").'</option>';
 412                         $s .= '<option value="2" '.$importselected[2].'>'.t("Only Mentions").'</option>';
 413                         $s .= '</select>';
 414                         $s .= '<div class="clear"></div>';
 415 /*
 416                         $s .= '<label id="statusnet-create_user-label" for="statusnet-create_user">'.t('Automatically create contacts').'</label>';
 417                         $s .= '<input id="statusnet-create_user" type="checkbox" name="statusnet-create_user" value="1" '. $create_userchecked . '/>';
 418                         $s .= '<div class="clear"></div>';
 419 */
 420                         $s .= '<div id="statusnet-disconnect-wrapper">';
 421                         $s .= '<label id="statusnet-disconnect-label" for="statusnet-disconnect">'. t('Clear OAuth configuration') .'</label>';
 422                         $s .= '<input id="statusnet-disconnect" type="checkbox" name="statusnet-disconnect" value="1" />';
 423                         $s .= '</div><div class="clear"></div>';
 424                         $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="statusnet-submit" class="settings-submit" value="' . t('Save Settings') . '" /></div>';
 425                 }
 426         }
 427         $s .= '</div><div class="clear"></div>';
 428 }
 429
 430
 431 function statusnet_post_local(&$a,&$b) {
 432         if($b['edit'])
 433                 return;
 434
 435         if((local_user()) && (local_user() == $b['uid']) && (! $b['private'])) {
 436
 437                 $statusnet_post = get_pconfig(local_user(),'statusnet','post');
 438                 $statusnet_enable = (($statusnet_post && x($_REQUEST,'statusnet_enable')) ? intval($_REQUEST['statusnet_enable']) : 0);
 439
 440                 // if API is used, default to the chosen settings
 441                 if($_REQUEST['api_source'] && intval(get_pconfig(local_user(),'statusnet','post_by_default')))
 442                         $statusnet_enable = 1;
 443
 444                 if(! $statusnet_enable)
 445                         return;
 446
 447                 if(strlen($b['postopts']))
 448                         $b['postopts'] .= ',';
 449                 $b['postopts'] .= 'statusnet';
 450         }
 451 }
 452
 453 function statusnet_action($a, $uid, $pid, $action) {
 454         $api     = get_pconfig($uid, 'statusnet', 'baseapi');
 455         $ckey    = get_pconfig($uid, 'statusnet', 'consumerkey');
 456         $csecret = get_pconfig($uid, 'statusnet', 'consumersecret');
 457         $otoken  = get_pconfig($uid, 'statusnet', 'oauthtoken');
 458         $osecret = get_pconfig($uid, 'statusnet', 'oauthsecret');
 459
 460         $connection = new StatusNetOAuth($api,$ckey,$csecret,$otoken,$osecret);
 461
 462         logger("statusnet_action '".$action."' ID: ".$pid, LOGGER_DATA);
 463
 464         switch ($action) {
 465                 case "delete":
 466                         $result = $connection->post("statuses/destroy/".$pid);
 467                         break;
 468                 case "like":
 469                         $result = $connection->post("favorites/create/".$pid);
 470                         break;
 471                 case "unlike":
 472                         $result = $connection->post("favorites/destroy/".$pid);
 473                         break;
 474         }
 475         logger("statusnet_action '".$action."' send, result: " . print_r($result, true), LOGGER_DEBUG);
 476 }
 477
 478 function statusnet_post_hook(&$a,&$b) {
 479
 480         /**
 481          * Post to GNU Social
 482          */
 483
 484         if (!get_pconfig($b["uid"],'statusnet','import')) {
 485                 if($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited']))
 486                         return;
 487         }
 488
 489         $api = get_pconfig($b["uid"], 'statusnet', 'baseapi');
 490         $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $api);
 491
 492         if($b['parent'] != $b['id']) {
 493                 logger("statusnet_post_hook: parameter ".print_r($b, true), LOGGER_DATA);
 494
 495                 // Looking if its a reply to a GNU Social post
 496                 $hostlength = strlen($hostname) + 2;
 497                 if ((substr($b["parent-uri"], 0, $hostlength) != $hostname."::") AND (substr($b["extid"], 0, $hostlength) != $hostname."::")
 498                         AND (substr($b["thr-parent"], 0, $hostlength) != $hostname."::")) {
 499                         logger("statusnet_post_hook: no GNU Social post ".$b["parent"]);
 500                         return;
 501                 }
 502
 503                 $r = q("SELECT `item`.`author-link`, `item`.`uri`, `contact`.`nick` AS contact_nick
 504                         FROM `item` INNER JOIN `contact` ON `contact`.`id` = `item`.`contact-id`
 505                         WHERE `item`.`uri` = '%s' AND `item`.`uid` = %d LIMIT 1",
 506                         dbesc($b["thr-parent"]),
 507                         intval($b["uid"]));
 508
 509                 if(!count($r)) {
 510                         logger("statusnet_post_hook: no parent found ".$b["thr-parent"]);
 511                         return;
 512                 } else {
 513                         $iscomment = true;
 514                         $orig_post = $r[0];
 515                 }
 516
 517                 //$nickname = "@[url=".$orig_post["author-link"]."]".$orig_post["contact_nick"]."[/url]";
 518                 //$nicknameplain = "@".$orig_post["contact_nick"];
 519
 520                 $nick = preg_replace("=https?://(.*)/(.*)=ism", "$2", $orig_post["author-link"]);
 521
 522                 $nickname = "@[url=".$orig_post["author-link"]."]".$nick."[/url]";
 523                 $nicknameplain = "@".$nick;
 524
 525                 logger("statusnet_post_hook: comparing ".$nickname." and ".$nicknameplain." with ".$b["body"], LOGGER_DEBUG);
 526                 if ((strpos($b["body"], $nickname) === false) AND (strpos($b["body"], $nicknameplain) === false))
 527                         $b["body"] = $nickname." ".$b["body"];
 528
 529                 logger("statusnet_post_hook: parent found ".print_r($orig_post, true), LOGGER_DEBUG);
 530         } else {
 531                 $iscomment = false;
 532
 533                 if($b['private'] OR !strstr($b['postopts'],'statusnet'))
 534                         return;
 535         }
 536
 537         if (($b['verb'] == ACTIVITY_POST) AND $b['deleted'])
 538                 statusnet_action($a, $b["uid"], substr($orig_post["uri"], $hostlength), "delete");
 539
 540         if($b['verb'] == ACTIVITY_LIKE) {
 541                 logger("statusnet_post_hook: parameter 2 ".substr($b["thr-parent"], $hostlength), LOGGER_DEBUG);
 542                 if ($b['deleted'])
 543                         statusnet_action($a, $b["uid"], substr($b["thr-parent"], $hostlength), "unlike");
 544                 else
 545                         statusnet_action($a, $b["uid"], substr($b["thr-parent"], $hostlength), "like");
 546                 return;
 547         }
 548
 549         if($b['deleted'] || ($b['created'] !== $b['edited']))
 550                 return;
 551
 552         // if posts comes from GNU Social don't send it back
 553         if($b['extid'] == NETWORK_STATUSNET)
 554                 return;
 555
 556         if($b['app'] == "StatusNet")
 557                 return;
 558
 559         logger('GNU Socialpost invoked');
 560
 561         load_pconfig($b['uid'], 'statusnet');
 562
 563         $api     = get_pconfig($b['uid'], 'statusnet', 'baseapi');
 564         $ckey    = get_pconfig($b['uid'], 'statusnet', 'consumerkey');
 565         $csecret = get_pconfig($b['uid'], 'statusnet', 'consumersecret');
 566         $otoken  = get_pconfig($b['uid'], 'statusnet', 'oauthtoken');
 567         $osecret = get_pconfig($b['uid'], 'statusnet', 'oauthsecret');
 568
 569         if($ckey && $csecret && $otoken && $osecret) {
 570
 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                 require_once('include/bbcode.php');
 576                 $dent = new StatusNetOAuth($api,$ckey,$csecret,$otoken,$osecret);
 577                 $max_char = $dent->get_maxlength(); // max. length for a dent
 578
 579                 set_pconfig($b['uid'], 'statusnet', 'max_char', $max_char);
 580
 581                 $tempfile = "";
 582                 require_once("include/plaintext.php");
 583                 require_once("include/network.php");
 584                 $msgarr = plaintext($a, $b, $max_char, true, 7);
 585                 $msg = $msgarr["text"];
 586
 587                 if (($msg == "") AND isset($msgarr["title"]))
 588                         $msg = shortenmsg($msgarr["title"], $max_char - 50);
 589
 590                 $image = "";
 591
 592                 if (isset($msgarr["url"]) AND ($msgarr["type"] != "photo")) {
 593                         if ((strlen($msgarr["url"]) > 20) AND
 594                                 ((strlen($msg." \n".$msgarr["url"]) > $max_char)))
 595                                 $msg .= " \n".short_link($msgarr["url"]);
 596                         else
 597                                 $msg .= " \n".$msgarr["url"];
 598                 } elseif (isset($msgarr["image"]) AND ($msgarr["type"] != "video"))
 599                         $image = $msgarr["image"];
 600
 601                 if ($image != "") {
 602                         $img_str = fetch_url($image);
 603                         $tempfile = tempnam(get_temppath(), "cache");
 604                         file_put_contents($tempfile, $img_str);
 605                         $postdata = array("status" => $msg, "media[]" => $tempfile);
 606                 } else
 607                         $postdata = array("status"=>$msg);
 608
 609                 // and now dent it :-)
 610                 if(strlen($msg)) {
 611
 612                         if ($iscomment) {
 613                                 $postdata["in_reply_to_status_id"] = substr($orig_post["uri"], $hostlength);
 614                                 logger('statusnet_post send reply '.print_r($postdata, true), LOGGER_DEBUG);
 615                         }
 616
 617                         // New code that is able to post pictures
 618                         require_once("addon/statusnet/codebird.php");
 619                         $cb = \CodebirdSN\CodebirdSN::getInstance();
 620                         $cb->setAPIEndpoint($api);
 621                         $cb->setConsumerKey($ckey, $csecret);
 622                         $cb->setToken($otoken, $osecret);
 623                         $result = $cb->statuses_update($postdata);
 624                         //$result = $dent->post('statuses/update', $postdata);
 625                         logger('statusnet_post send, result: ' . print_r($result, true).
 626                                 "\nmessage: ".$msg, LOGGER_DEBUG."\nOriginal post: ".print_r($b, true)."\nPost Data: ".print_r($postdata, true));
 627
 628                         if ($result->source)
 629                                 set_pconfig($b["uid"], "statusnet", "application_name", strip_tags($result->source));
 630
 631                         if ($result->error) {
 632                                 logger('Send to GNU Social failed: "'.$result->error.'"');
 633                         } elseif ($iscomment) {
 634                                 logger('statusnet_post: Update extid '.$result->id." for post id ".$b['id']);
 635                                 q("UPDATE `item` SET `extid` = '%s', `body` = '%s' WHERE `id` = %d",
 636                                         dbesc($hostname."::".$result->id),
 637                                         dbesc($result->text),
 638                                         intval($b['id'])
 639                                 );
 640                         }
 641                 }
 642                 if ($tempfile != "")
 643                         unlink($tempfile);
 644         }
 645 }
 646
 647 function statusnet_plugin_admin_post(&$a){
 648
 649         $sites = array();
 650
 651         foreach($_POST['sitename'] as $id=>$sitename){
 652                 $sitename=trim($sitename);
 653                 $apiurl=trim($_POST['apiurl'][$id]);
 654                 if (! (substr($apiurl, -1)=='/'))
 655                     $apiurl=$apiurl.'/';
 656                 $secret=trim($_POST['secret'][$id]);
 657                 $key=trim($_POST['key'][$id]);
 658                 //$applicationname = ((x($_POST, 'applicationname')) ? notags(trim($_POST['applicationname'][$id])):'');
 659                 if ($sitename!="" &&
 660                         $apiurl!="" &&
 661                         $secret!="" &&
 662                         $key!="" &&
 663                         !x($_POST['delete'][$id])){
 664
 665                                 $sites[] = Array(
 666                                         'sitename' => $sitename,
 667                                         'apiurl' => $apiurl,
 668                                         'consumersecret' => $secret,
 669                                         'consumerkey' => $key,
 670                                         //'applicationname' => $applicationname
 671                                 );
 672                 }
 673         }
 674
 675         $sites = set_config('statusnet','sites', $sites);
 676
 677 }
 678
 679 function statusnet_plugin_admin(&$a, &$o){
 680
 681         $sites = get_config('statusnet','sites');
 682         $sitesform=array();
 683         if (is_array($sites)){
 684                 foreach($sites as $id=>$s){
 685                         $sitesform[] = Array(
 686                                 'sitename' => Array("sitename[$id]", "Site name", $s['sitename'], ""),
 687                                 'apiurl' => Array("apiurl[$id]", "Api url", $s['apiurl'], t("Base API Path \x28remember the trailing /\x29") ),
 688                                 'secret' => Array("secret[$id]", "Secret", $s['consumersecret'], ""),
 689                                 'key' => Array("key[$id]", "Key", $s['consumerkey'], ""),
 690                                 //'applicationname' => Array("applicationname[$id]", "Application name", $s['applicationname'], ""),
 691                                 'delete' => Array("delete[$id]", "Delete", False , "Check to delete this preset"),
 692                         );
 693                 }
 694         }
 695         /* empty form to add new site */
 696         $id++;
 697         $sitesform[] = Array(
 698                 'sitename' => Array("sitename[$id]", t("Site name"), "", ""),
 699                 'apiurl' => Array("apiurl[$id]", "Api url", "", t("Base API Path \x28remember the trailing /\x29") ),
 700                 'secret' => Array("secret[$id]", t("Consumer Secret"), "", ""),
 701                 'key' => Array("key[$id]", t("Consumer Key"), "", ""),
 702                 //'applicationname' => Array("applicationname[$id]", t("Application name"), "", ""),
 703         );
 704
 705         $t = get_markup_template( "admin.tpl", "addon/statusnet/" );
 706         $o = replace_macros($t, array(
 707                 '$submit' => t('Save Settings'),
 708                 '$sites' => $sitesform,
 709         ));
 710 }
 711
 712 function statusnet_prepare_body(&$a,&$b) {
 713         if ($b["item"]["network"] != NETWORK_STATUSNET)
 714                 return;
 715
 716         if ($b["preview"]) {
 717                 $max_char = get_pconfig(local_user(),'statusnet','max_char');
 718                 if (intval($max_char) == 0)
 719                         $max_char = 140;
 720
 721                 require_once("include/plaintext.php");
 722                 $item = $b["item"];
 723                 $item["plink"] = $a->get_baseurl()."/display/".$a->user["nickname"]."/".$item["parent"];
 724
 725                 $r = q("SELECT `item`.`author-link`, `item`.`uri`, `contact`.`nick` AS contact_nick
 726                         FROM `item` INNER JOIN `contact` ON `contact`.`id` = `item`.`contact-id`
 727                         WHERE `item`.`uri` = '%s' AND `item`.`uid` = %d LIMIT 1",
 728                         dbesc($item["thr-parent"]),
 729                         intval(local_user()));
 730
 731                 if(count($r)) {
 732                         $orig_post = $r[0];
 733                         //$nickname = "@[url=".$orig_post["author-link"]."]".$orig_post["contact_nick"]."[/url]";
 734                         //$nicknameplain = "@".$orig_post["contact_nick"];
 735
 736                         $nick = preg_replace("=https?://(.*)/(.*)=ism", "$2", $orig_post["author-link"]);
 737
 738                         $nickname = "@[url=".$orig_post["author-link"]."]".$nick."[/url]";
 739                         $nicknameplain = "@".$nick;
 740
 741                         if ((strpos($item["body"], $nickname) === false) AND (strpos($item["body"], $nicknameplain) === false))
 742                                 $item["body"] = $nickname." ".$item["body"];
 743                 }
 744
 745
 746                 $msgarr = plaintext($a, $item, $max_char, true, 7);
 747                 $msg = $msgarr["text"];
 748
 749                 if (isset($msgarr["url"]) AND ($msgarr["type"] != "photo"))
 750                         $msg .= " ".$msgarr["url"];
 751
 752                 if (isset($msgarr["image"]))
 753                         $msg .= " ".$msgarr["image"];
 754
 755                 $b['html'] = nl2br(htmlspecialchars($msg));
 756         }
 757 }
 758
 759 function statusnet_cron($a,$b) {
 760         $last = get_config('statusnet','last_poll');
 761
 762         $poll_interval = intval(get_config('statusnet','poll_interval'));
 763         if(! $poll_interval)
 764                 $poll_interval = STATUSNET_DEFAULT_POLL_INTERVAL;
 765
 766         if($last) {
 767                 $next = $last + ($poll_interval * 60);
 768                 if($next > time()) {
 769                         logger('statusnet: poll intervall not reached');
 770                         return;
 771                 }
 772         }
 773         logger('statusnet: cron_start');
 774
 775         $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'statusnet' AND `k` = 'mirror_posts' AND `v` = '1' ORDER BY RAND() ");
 776         if(count($r)) {
 777                 foreach($r as $rr) {
 778                         logger('statusnet: fetching for user '.$rr['uid']);
 779                         statusnet_fetchtimeline($a, $rr['uid']);
 780                 }
 781         }
 782
 783         $abandon_days = intval(get_config('system','account_abandon_days'));
 784         if ($abandon_days < 1)
 785                 $abandon_days = 0;
 786
 787         $abandon_limit = date("Y-m-d H:i:s", time() - $abandon_days * 86400);
 788
 789         $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'statusnet' AND `k` = 'import' AND `v` ORDER BY RAND()");
 790         if(count($r)) {
 791                 foreach($r as $rr) {
 792                         if ($abandon_days != 0) {
 793                                 $user = q("SELECT `login_date` FROM `user` WHERE uid=%d AND `login_date` >= '%s'", $rr['uid'], $abandon_limit);
 794                                 if (!count($user)) {
 795                                         logger('abandoned account: timeline from user '.$rr['uid'].' will not be imported');
 796                                         continue;
 797                                 }
 798                         }
 799
 800                         logger('statusnet: importing timeline from user '.$rr['uid']);
 801                         statusnet_fetchhometimeline($a, $rr["uid"], $rr["v"]);
 802                 }
 803         }
 804
 805         logger('statusnet: cron_end');
 806
 807         set_config('statusnet','last_poll', time());
 808 }
 809
 810 function statusnet_fetchtimeline($a, $uid) {
 811         $ckey    = get_pconfig($uid, 'statusnet', 'consumerkey');
 812         $csecret = get_pconfig($uid, 'statusnet', 'consumersecret');
 813         $api     = get_pconfig($uid, 'statusnet', 'baseapi');
 814         $otoken  = get_pconfig($uid, 'statusnet', 'oauthtoken');
 815         $osecret = get_pconfig($uid, 'statusnet', 'oauthsecret');
 816         $lastid  = get_pconfig($uid, 'statusnet', 'lastid');
 817
 818         require_once('mod/item.php');
 819         require_once('include/items.php');
 820
 821         //  get the application name for the SN app
 822         //  1st try personal config, then system config and fallback to the
 823         //  hostname of the node if neither one is set.
 824         $application_name  = get_pconfig( $uid, 'statusnet', 'application_name');
 825         if ($application_name == "")
 826                 $application_name  = get_config('statusnet', 'application_name');
 827         if ($application_name == "")
 828                 $application_name = $a->get_hostname();
 829
 830         $connection = new StatusNetOAuth($api, $ckey,$csecret,$otoken,$osecret);
 831
 832         $parameters = array("exclude_replies" => true, "trim_user" => true, "contributor_details" => false, "include_rts" => false);
 833
 834         $first_time = ($lastid == "");
 835
 836         if ($lastid <> "")
 837                 $parameters["since_id"] = $lastid;
 838
 839         $items = $connection->get('statuses/user_timeline', $parameters);
 840
 841         if (!is_array($items))
 842                 return;
 843
 844         $posts = array_reverse($items);
 845
 846         if (count($posts)) {
 847             foreach ($posts as $post) {
 848                 if ($post->id > $lastid)
 849                         $lastid = $post->id;
 850
 851                 if ($first_time)
 852                         continue;
 853
 854                 if ($post->source == "activity")
 855                         continue;
 856
 857                 if (is_object($post->retweeted_status))
 858                         continue;
 859
 860                 if ($post->in_reply_to_status_id != "")
 861                         continue;
 862
 863                 if (!stristr($post->source, $application_name)) {
 864                         $_SESSION["authenticated"] = true;
 865                         $_SESSION["uid"] = $uid;
 866
 867                         unset($_REQUEST);
 868                         $_REQUEST["type"] = "wall";
 869                         $_REQUEST["api_source"] = true;
 870                         $_REQUEST["profile_uid"] = $uid;
 871                         //$_REQUEST["source"] = "StatusNet";
 872                         $_REQUEST["source"] = $post->source;
 873                         $_REQUEST["extid"] = NETWORK_STATUSNET;
 874
 875                         if (isset($post->id))
 876                                 $_REQUEST['message_id'] = NETWORK_STATUSNET.":".$post->id;
 877
 878                         //$_REQUEST["date"] = $post->created_at;
 879
 880                         $_REQUEST["title"] = "";
 881
 882                         $_REQUEST["body"] = add_page_info_to_body($post->text, true);
 883                         if (is_string($post->place->name))
 884                                 $_REQUEST["location"] = $post->place->name;
 885
 886                         if (is_string($post->place->full_name))
 887                                 $_REQUEST["location"] = $post->place->full_name;
 888
 889                         if (is_array($post->geo->coordinates))
 890                                 $_REQUEST["coord"] = $post->geo->coordinates[0]." ".$post->geo->coordinates[1];
 891
 892                         if (is_array($post->coordinates->coordinates))
 893                                 $_REQUEST["coord"] = $post->coordinates->coordinates[1]." ".$post->coordinates->coordinates[0];
 894
 895                         //print_r($_REQUEST);
 896                         if ($_REQUEST["body"] != "") {
 897                                 logger('statusnet: posting for user '.$uid);
 898
 899                                 item_post($a);
 900                         }
 901                 }
 902             }
 903         }
 904         set_pconfig($uid, 'statusnet', 'lastid', $lastid);
 905 }
 906
 907 function statusnet_address($contact) {
 908         $hostname = normalise_link($contact->statusnet_profile_url);
 909         $nickname = $contact->screen_name;
 910
 911         $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $contact->statusnet_profile_url);
 912
 913         $address = $contact->screen_name."@".$hostname;
 914
 915         return($address);
 916 }
 917
 918 function statusnet_fetch_contact($uid, $contact, $create_user) {
 919         if ($contact->statusnet_profile_url == "")
 920                 return(-1);
 921
 922         if (function_exists("update_gcontact"))
 923                 update_gcontact(array("url" => $contact->statusnet_profile_url,
 924                                 "network" => NETWORK_STATUSNET, "photo" => $contact->profile_image_url,
 925                                 "name" => $contact->name, "nick" => $contact->screen_name,
 926                                 "location" => $contact->location, "about" => $contact->description,
 927                                 "addr" => statusnet_address($contact), "generation" => 3));
 928         else {
 929                 // Old Code
 930                  $r = q("SELECT id FROM unique_contacts WHERE url='%s' LIMIT 1",
 931                                 dbesc(normalise_link($contact->statusnet_profile_url)));
 932
 933                 if (count($r) == 0)
 934                         q("INSERT INTO unique_contacts (url, name, nick, avatar) VALUES ('%s', '%s', '%s', '%s')",
 935                                 dbesc(normalise_link($contact->statusnet_profile_url)),
 936                                 dbesc($contact->name),
 937                                 dbesc($contact->screen_name),
 938                                 dbesc($contact->profile_image_url));
 939                 else
 940                         q("UPDATE unique_contacts SET name = '%s', nick = '%s', avatar = '%s' WHERE url = '%s'",
 941                                 dbesc($contact->name),
 942                                 dbesc($contact->screen_name),
 943                                 dbesc($contact->profile_image_url),
 944                                 dbesc(normalise_link($contact->statusnet_profile_url)));
 945
 946                 if (DB_UPDATE_VERSION >= "1177")
 947                         q("UPDATE `unique_contacts` SET `location` = '%s', `about` = '%s' WHERE url = '%s'",
 948                                 dbesc($contact->location),
 949                                 dbesc($contact->description),
 950                                 dbesc(normalise_link($contact->statusnet_profile_url)));
 951         }
 952
 953         $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' AND `network` = '%s'LIMIT 1",
 954                 intval($uid), dbesc(normalise_link($contact->statusnet_profile_url)), dbesc(NETWORK_STATUSNET));
 955
 956         if(!count($r) AND !$create_user)
 957                 return(0);
 958
 959         if (count($r) AND ($r[0]["readonly"] OR $r[0]["blocked"])) {
 960                 logger("statusnet_fetch_contact: Contact '".$r[0]["nick"]."' is blocked or readonly.", LOGGER_DEBUG);
 961                 return(-1);
 962         }
 963
 964         if(!count($r)) {
 965                 // create contact record
 966                 q("INSERT INTO `contact` ( `uid`, `created`, `url`, `nurl`, `addr`, `alias`, `notify`, `poll`,
 967                                         `name`, `nick`, `photo`, `network`, `rel`, `priority`,
 968                                         `writable`, `blocked`, `readonly`, `pending` )
 969                                         VALUES ( %d, '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', %d, %d, %d, 0, 0, 0 ) ",
 970                         intval($uid),
 971                         dbesc(datetime_convert()),
 972                         dbesc($contact->statusnet_profile_url),
 973                         dbesc(normalise_link($contact->statusnet_profile_url)),
 974                         dbesc(statusnet_address($contact)),
 975                         dbesc(normalise_link($contact->statusnet_profile_url)),
 976                         dbesc(''),
 977                         dbesc(''),
 978                         dbesc($contact->name),
 979                         dbesc($contact->screen_name),
 980                         dbesc($contact->profile_image_url),
 981                         dbesc(NETWORK_STATUSNET),
 982                         intval(CONTACT_IS_FRIEND),
 983                         intval(1),
 984                         intval(1)
 985                 );
 986
 987                 $r = q("SELECT * FROM `contact` WHERE `alias` = '%s' AND `uid` = %d AND `network` = '%s' LIMIT 1",
 988                         dbesc($contact->statusnet_profile_url),
 989                         intval($uid),
 990                         dbesc(NETWORK_STATUSNET));
 991
 992                 if(! count($r))
 993                         return(false);
 994
 995                 $contact_id  = $r[0]['id'];
 996
 997                 $g = q("SELECT def_gid FROM user WHERE uid = %d LIMIT 1",
 998                         intval($uid)
 999                 );
1000
1001                 if($g && intval($g[0]['def_gid'])) {
1002                         require_once('include/group.php');
1003                         group_add_member($uid,'',$contact_id,$g[0]['def_gid']);
1004                 }
1005
1006                 require_once("Photo.php");
1007
1008                 $photos = import_profile_photo($contact->profile_image_url,$uid,$contact_id);
1009
1010                 q("UPDATE `contact` SET `photo` = '%s',
1011                                         `thumb` = '%s',
1012                                         `micro` = '%s',
1013                                         `avatar-date` = '%s'
1014                                 WHERE `id` = %d",
1015                         dbesc($photos[0]),
1016                         dbesc($photos[1]),
1017                         dbesc($photos[2]),
1018                         dbesc(datetime_convert()),
1019                         intval($contact_id)
1020                 );
1021
1022                 if (DB_UPDATE_VERSION >= "1177")
1023                         q("UPDATE `contact` SET `location` = '%s',
1024                                                 `about` = '%s'
1025                                         WHERE `id` = %d",
1026                                 dbesc($contact->location),
1027                                 dbesc($contact->description),
1028                                 intval($contact_id)
1029                         );
1030
1031         } else {
1032                 // update profile photos once every two weeks as we have no notification of when they change.
1033
1034                 //$update_photo = (($r[0]['avatar-date'] < datetime_convert('','','now -2 days')) ? true : false);
1035                 $update_photo = ($r[0]['avatar-date'] < datetime_convert('','','now -12 hours'));
1036
1037                 // check that we have all the photos, this has been known to fail on occasion
1038
1039                 if((!$r[0]['photo']) || (!$r[0]['thumb']) || (!$r[0]['micro']) || ($update_photo)) {
1040
1041                         logger("statusnet_fetch_contact: Updating contact ".$contact->screen_name, LOGGER_DEBUG);
1042
1043                         require_once("Photo.php");
1044
1045                         $photos = import_profile_photo($contact->profile_image_url, $uid, $r[0]['id']);
1046
1047                         q("UPDATE `contact` SET `photo` = '%s',
1048                                                 `thumb` = '%s',
1049                                                 `micro` = '%s',
1050                                                 `name-date` = '%s',
1051                                                 `uri-date` = '%s',
1052                                                 `avatar-date` = '%s',
1053                                                 `url` = '%s',
1054                                                 `nurl` = '%s',
1055                                                 `addr` = '%s',
1056                                                 `name` = '%s',
1057                                                 `nick` = '%s'
1058                                         WHERE `id` = %d",
1059                                 dbesc($photos[0]),
1060                                 dbesc($photos[1]),
1061                                 dbesc($photos[2]),
1062                                 dbesc(datetime_convert()),
1063                                 dbesc(datetime_convert()),
1064                                 dbesc(datetime_convert()),
1065                                 dbesc($contact->statusnet_profile_url),
1066                                 dbesc(normalise_link($contact->statusnet_profile_url)),
1067                                 dbesc(statusnet_address($contact)),
1068                                 dbesc($contact->name),
1069                                 dbesc($contact->screen_name),
1070                                 intval($r[0]['id'])
1071                         );
1072
1073                         if (DB_UPDATE_VERSION >= "1177")
1074                                 q("UPDATE `contact` SET `location` = '%s',
1075                                                         `about` = '%s'
1076                                                 WHERE `id` = %d",
1077                                         dbesc($contact->location),
1078                                         dbesc($contact->description),
1079                                         intval($r[0]['id'])
1080                                 );
1081                 }
1082         }
1083
1084         return($r[0]["id"]);
1085 }
1086
1087 function statusnet_fetchuser($a, $uid, $screen_name = "", $user_id = "") {
1088         $ckey    = get_pconfig($uid, 'statusnet', 'consumerkey');
1089         $csecret = get_pconfig($uid, 'statusnet', 'consumersecret');
1090         $api     = get_pconfig($uid, 'statusnet', 'baseapi');
1091         $otoken  = get_pconfig($uid, 'statusnet', 'oauthtoken');
1092         $osecret = get_pconfig($uid, 'statusnet', 'oauthsecret');
1093
1094         require_once("addon/statusnet/codebird.php");
1095
1096         $cb = \Codebird\Codebird::getInstance();
1097         $cb->setConsumerKey($ckey, $csecret);
1098         $cb->setToken($otoken, $osecret);
1099
1100         $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
1101                 intval($uid));
1102
1103         if(count($r)) {
1104                 $self = $r[0];
1105         } else
1106                 return;
1107
1108         $parameters = array();
1109
1110         if ($screen_name != "")
1111                 $parameters["screen_name"] = $screen_name;
1112
1113         if ($user_id != "")
1114                 $parameters["user_id"] = $user_id;
1115
1116         // Fetching user data
1117         $user = $cb->users_show($parameters);
1118
1119         if (!is_object($user))
1120                 return;
1121
1122         $contact_id = statusnet_fetch_contact($uid, $user, true);
1123
1124         return $contact_id;
1125 }
1126
1127 function statusnet_createpost($a, $uid, $post, $self, $create_user, $only_existing_contact) {
1128
1129         require_once("include/html2bbcode.php");
1130
1131         logger("statusnet_createpost: start", LOGGER_DEBUG);
1132
1133         $api = get_pconfig($uid, 'statusnet', 'baseapi');
1134         $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $api);
1135
1136         $postarray = array();
1137         $postarray['network'] = NETWORK_STATUSNET;
1138         $postarray['gravity'] = 0;
1139         $postarray['uid'] = $uid;
1140         $postarray['wall'] = 0;
1141
1142         if (is_object($post->retweeted_status)) {
1143                 $content = $post->retweeted_status;
1144                 statusnet_fetch_contact($uid, $content->user, false);
1145         } else
1146                 $content = $post;
1147
1148         $postarray['uri'] = $hostname."::".$content->id;
1149
1150         $r = q("SELECT * FROM `item` WHERE `extid` = '%s' AND `uid` = %d LIMIT 1",
1151                         dbesc($postarray['uri']),
1152                         intval($uid)
1153                 );
1154
1155         if (count($r))
1156                 return(array());
1157
1158         $contactid = 0;
1159
1160         if ($content->in_reply_to_status_id != "") {
1161
1162                 $parent = $hostname."::".$content->in_reply_to_status_id;
1163
1164                 $r = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
1165                                 dbesc($parent),
1166                                 intval($uid)
1167                         );
1168                 if (count($r)) {
1169                         $postarray['thr-parent'] = $r[0]["uri"];
1170                         $postarray['parent-uri'] = $r[0]["parent-uri"];
1171                         $postarray['parent'] = $r[0]["parent"];
1172                         $postarray['object-type'] = ACTIVITY_OBJ_COMMENT;
1173                 } else {
1174                         $r = q("SELECT * FROM `item` WHERE `extid` = '%s' AND `uid` = %d LIMIT 1",
1175                                         dbesc($parent),
1176                                         intval($uid)
1177                                 );
1178                         if (count($r)) {
1179                                 $postarray['thr-parent'] = $r[0]['uri'];
1180                                 $postarray['parent-uri'] = $r[0]['parent-uri'];
1181                                 $postarray['parent'] = $r[0]['parent'];
1182                                 $postarray['object-type'] = ACTIVITY_OBJ_COMMENT;
1183                         } else {
1184                                 $postarray['thr-parent'] = $postarray['uri'];
1185                                 $postarray['parent-uri'] = $postarray['uri'];
1186                                 $postarray['object-type'] = ACTIVITY_OBJ_NOTE;
1187                         }
1188                 }
1189
1190                 // Is it me?
1191                 $own_url = get_pconfig($uid, 'statusnet', 'own_url');
1192
1193                 if ($content->user->id == $own_url) {
1194                         $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
1195                                 intval($uid));
1196
1197                         if(count($r)) {
1198                                 $contactid = $r[0]["id"];
1199
1200                                 $postarray['owner-name'] =  $r[0]["name"];
1201                                 $postarray['owner-link'] = $r[0]["url"];
1202                                 $postarray['owner-avatar'] =  $r[0]["photo"];
1203                         } else
1204                                 return(array());
1205                 }
1206                 // Don't create accounts of people who just comment something
1207                 $create_user = false;
1208         } else {
1209                 $postarray['parent-uri'] = $postarray['uri'];
1210                 $postarray['object-type'] = ACTIVITY_OBJ_NOTE;
1211         }
1212
1213         if ($contactid == 0) {
1214                 $contactid = statusnet_fetch_contact($uid, $post->user, $create_user);
1215                 $postarray['owner-name'] = $post->user->name;
1216                 $postarray['owner-link'] = $post->user->statusnet_profile_url;
1217                 $postarray['owner-avatar'] = $post->user->profile_image_url;
1218         }
1219         if(($contactid == 0) AND !$only_existing_contact)
1220                 $contactid = $self['id'];
1221         elseif ($contactid <= 0)
1222                 return(array());
1223
1224         $postarray['contact-id'] = $contactid;
1225
1226         $postarray['verb'] = ACTIVITY_POST;
1227
1228         $postarray['author-name'] = $content->user->name;
1229         $postarray['author-link'] = $content->user->statusnet_profile_url;
1230         $postarray['author-avatar'] = $content->user->profile_image_url;
1231
1232         // To-Do: Maybe unreliable? Can the api be entered without trailing "/"?
1233         $hostname = str_replace("/api/", "/notice/", get_pconfig($uid, 'statusnet', 'baseapi'));
1234
1235         $postarray['plink'] = $hostname.$content->id;
1236         $postarray['app'] = strip_tags($content->source);
1237
1238         if ($content->user->protected) {
1239                 $postarray['private'] = 1;
1240                 $postarray['allow_cid'] = '<' . $self['id'] . '>';
1241         }
1242
1243         $postarray['body'] = html2bbcode($content->statusnet_html);
1244
1245         $converted = statusnet_convertmsg($a, $postarray['body'], false);
1246         $postarray['body'] = $converted["body"];
1247         $postarray['tag'] = $converted["tags"];
1248
1249         $postarray['created'] = datetime_convert('UTC','UTC',$content->created_at);
1250         $postarray['edited'] = datetime_convert('UTC','UTC',$content->created_at);
1251
1252         if (is_string($content->place->name))
1253                 $postarray["location"] = $content->place->name;
1254
1255         if (is_string($content->place->full_name))
1256                 $postarray["location"] = $content->place->full_name;
1257
1258         if (is_array($content->geo->coordinates))
1259                 $postarray["coord"] = $content->geo->coordinates[0]." ".$content->geo->coordinates[1];
1260
1261         if (is_array($content->coordinates->coordinates))
1262                 $postarray["coord"] = $content->coordinates->coordinates[1]." ".$content->coordinates->coordinates[0];
1263
1264         /*if (is_object($post->retweeted_status)) {
1265                 $postarray['body'] = html2bbcode($post->retweeted_status->statusnet_html);
1266
1267                 $converted = statusnet_convertmsg($a, $postarray['body'], false);
1268                 $postarray['body'] = $converted["body"];
1269                 $postarray['tag'] = $converted["tags"];
1270
1271                 statusnet_fetch_contact($uid, $post->retweeted_status->user, false);
1272
1273                 // Let retweets look like wall-to-wall posts
1274                 $postarray['author-name'] = $post->retweeted_status->user->name;
1275                 $postarray['author-link'] = $post->retweeted_status->user->statusnet_profile_url;
1276                 $postarray['author-avatar'] = $post->retweeted_status->user->profile_image_url;
1277         }*/
1278         logger("statusnet_createpost: end", LOGGER_DEBUG);
1279         return($postarray);
1280 }
1281
1282 function statusnet_checknotification($a, $uid, $own_url, $top_item, $postarray) {
1283
1284         // This function necer worked and need cleanup
1285
1286         $user = q("SELECT * FROM `contact` WHERE `uid` = %d AND `self` LIMIT 1",
1287                         intval($uid)
1288                 );
1289
1290         if(!count($user))
1291                 return;
1292
1293         // Is it me?
1294         if (link_compare($user[0]["url"], $postarray['author-link']))
1295                 return;
1296
1297         $own_user = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1",
1298                         intval($uid),
1299                         dbesc($own_url)
1300                 );
1301
1302         if(!count($own_user))
1303                 return;
1304
1305         // Is it me from GNU Social?
1306         if (link_compare($own_user[0]["url"], $postarray['author-link']))
1307                 return;
1308
1309         $myconv = q("SELECT `author-link`, `author-avatar`, `parent` FROM `item` WHERE `parent-uri` = '%s' AND `uid` = %d AND `parent` != 0 AND `deleted` = 0",
1310                         dbesc($postarray['parent-uri']),
1311                         intval($uid)
1312                         );
1313
1314         if(count($myconv)) {
1315
1316                 foreach($myconv as $conv) {
1317                         // now if we find a match, it means we're in this conversation
1318
1319                         if(!link_compare($conv['author-link'],$user[0]["url"]) AND !link_compare($conv['author-link'],$own_user[0]["url"]))
1320                                 continue;
1321
1322                         require_once('include/enotify.php');
1323
1324                         $conv_parent = $conv['parent'];
1325
1326                         notification(array(
1327                                 'type'         => NOTIFY_COMMENT,
1328                                 'notify_flags' => $user[0]['notify-flags'],
1329                                 'language'     => $user[0]['language'],
1330                                 'to_name'      => $user[0]['username'],
1331                                 'to_email'     => $user[0]['email'],
1332                                 'uid'          => $user[0]['uid'],
1333                                 'item'         => $postarray,
1334                                 'link'         => $a->get_baseurl().'/display/'.urlencode(get_item_guid($top_item)),
1335                                 'source_name'  => $postarray['author-name'],
1336                                 'source_link'  => $postarray['author-link'],
1337                                 'source_photo' => $postarray['author-avatar'],
1338                                 'verb'         => ACTIVITY_POST,
1339                                 'otype'        => 'item',
1340                                 'parent'       => $conv_parent,
1341                         ));
1342
1343                         // only send one notification
1344                         break;
1345                 }
1346         }
1347 }
1348
1349 function statusnet_fetchhometimeline($a, $uid, $mode = 1) {
1350         $conversations = array();
1351
1352         $ckey    = get_pconfig($uid, 'statusnet', 'consumerkey');
1353         $csecret = get_pconfig($uid, 'statusnet', 'consumersecret');
1354         $api     = get_pconfig($uid, 'statusnet', 'baseapi');
1355         $otoken  = get_pconfig($uid, 'statusnet', 'oauthtoken');
1356         $osecret = get_pconfig($uid, 'statusnet', 'oauthsecret');
1357         $create_user = get_pconfig($uid, 'statusnet', 'create_user');
1358
1359         // "create_user" is deactivated, since currently you cannot add users manually by now
1360         $create_user = true;
1361
1362         logger("statusnet_fetchhometimeline: Fetching for user ".$uid, LOGGER_DEBUG);
1363
1364         require_once('library/twitteroauth.php');
1365         require_once('include/items.php');
1366
1367         $connection = new StatusNetOAuth($api, $ckey,$csecret,$otoken,$osecret);
1368
1369         $own_contact = statusnet_fetch_own_contact($a, $uid);
1370
1371         $r = q("SELECT * FROM `contact` WHERE `id` = %d AND `uid` = %d LIMIT 1",
1372                 intval($own_contact),
1373                 intval($uid));
1374
1375         if(count($r)) {
1376                 $nick = $r[0]["nick"];
1377         } else {
1378                 logger("statusnet_fetchhometimeline: Own GNU Social contact not found for user ".$uid, LOGGER_DEBUG);
1379                 return;
1380         }
1381
1382         $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
1383                 intval($uid));
1384
1385         if(count($r)) {
1386                 $self = $r[0];
1387         } else {
1388                 logger("statusnet_fetchhometimeline: Own contact not found for user ".$uid, LOGGER_DEBUG);
1389                 return;
1390         }
1391
1392         $u = q("SELECT * FROM user WHERE uid = %d LIMIT 1",
1393                 intval($uid));
1394         if(!count($u)) {
1395                 logger("statusnet_fetchhometimeline: Own user not found for user ".$uid, LOGGER_DEBUG);
1396                 return;
1397         }
1398
1399         $parameters = array("exclude_replies" => false, "trim_user" => false, "contributor_details" => true, "include_rts" => true);
1400         //$parameters["count"] = 200;
1401
1402         if ($mode == 1) {
1403                 // Fetching timeline
1404                 $lastid  = get_pconfig($uid, 'statusnet', 'lasthometimelineid');
1405                 //$lastid = 1;
1406
1407                 $first_time = ($lastid == "");
1408
1409                 if ($lastid <> "")
1410                         $parameters["since_id"] = $lastid;
1411
1412                 $items = $connection->get('statuses/home_timeline', $parameters);
1413
1414                 if (!is_array($items)) {
1415                         if (is_object($items) AND isset($items->error))
1416                                 $errormsg = $items->error;
1417                         elseif (is_object($items))
1418                                 $errormsg = print_r($items, true);
1419                         elseif (is_string($items) OR is_float($items) OR is_int($items))
1420                                 $errormsg = $items;
1421                         else
1422                                 $errormsg = "Unknown error";
1423
1424                         logger("statusnet_fetchhometimeline: Error fetching home timeline: ".$errormsg, LOGGER_DEBUG);
1425                         return;
1426                 }
1427
1428                 $posts = array_reverse($items);
1429
1430                 logger("statusnet_fetchhometimeline: Fetching timeline for user ".$uid." ".sizeof($posts)." items", LOGGER_DEBUG);
1431
1432                 if (count($posts)) {
1433                         foreach ($posts as $post) {
1434
1435                                 if ($post->id > $lastid)
1436                                         $lastid = $post->id;
1437
1438                                 if ($first_time)
1439                                         continue;
1440
1441                                 if (isset($post->statusnet_conversation_id)) {
1442                                         if (!isset($conversations[$post->statusnet_conversation_id])) {
1443                                                 statusnet_complete_conversation($a, $uid, $self, $create_user, $nick, $post->statusnet_conversation_id);
1444                                                 $conversations[$post->statusnet_conversation_id] = $post->statusnet_conversation_id;
1445                                         }
1446                                 } else {
1447                                         $postarray = statusnet_createpost($a, $uid, $post, $self, $create_user, true);
1448
1449                                         if (trim($postarray['body']) == "")
1450                                                 continue;
1451
1452                                         $item = item_store($postarray);
1453                                         $postarray["id"] = $item;
1454
1455                                         logger('statusnet_fetchhometimeline: User '.$self["nick"].' posted home timeline item '.$item);
1456
1457                                         if ($item AND !function_exists("check_item_notification"))
1458                                                 statusnet_checknotification($a, $uid, $nick, $item, $postarray);
1459                                 }
1460
1461                         }
1462                 }
1463                 set_pconfig($uid, 'statusnet', 'lasthometimelineid', $lastid);
1464         }
1465
1466         // Fetching mentions
1467         $lastid  = get_pconfig($uid, 'statusnet', 'lastmentionid');
1468         $first_time = ($lastid == "");
1469
1470         if ($lastid <> "")
1471                 $parameters["since_id"] = $lastid;
1472
1473         $items = $connection->get('statuses/mentions_timeline', $parameters);
1474
1475         if (!is_array($items)) {
1476                 logger("statusnet_fetchhometimeline: Error fetching mentions: ".print_r($items, true), LOGGER_DEBUG);
1477                 return;
1478         }
1479
1480         $posts = array_reverse($items);
1481
1482         logger("statusnet_fetchhometimeline: Fetching mentions for user ".$uid." ".sizeof($posts)." items", LOGGER_DEBUG);
1483
1484         if (count($posts)) {
1485                 foreach ($posts as $post) {
1486                         if ($post->id > $lastid)
1487                                 $lastid = $post->id;
1488
1489                         if ($first_time)
1490                                 continue;
1491
1492                         $postarray = statusnet_createpost($a, $uid, $post, $self, false, false);
1493
1494                         if (isset($post->statusnet_conversation_id)) {
1495                                 if (!isset($conversations[$post->statusnet_conversation_id])) {
1496                                         statusnet_complete_conversation($a, $uid, $self, $create_user, $nick, $post->statusnet_conversation_id);
1497                                         $conversations[$post->statusnet_conversation_id] = $post->statusnet_conversation_id;
1498                                 }
1499                         } else {
1500                                 if (trim($postarray['body']) != "") {
1501                                         continue;
1502
1503                                         $item = item_store($postarray);
1504                                         $postarray["id"] = $item;
1505
1506                                         logger('statusnet_fetchhometimeline: User '.$self["nick"].' posted mention timeline item '.$item);
1507
1508                                         if ($item AND function_exists("check_item_notification"))
1509                                                 check_item_notification($item, $uid, NOTIFY_TAGSELF);
1510                                 }
1511                         }
1512
1513                         $r = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
1514                                 dbesc($postarray['uri']),
1515                                 intval($uid)
1516                         );
1517                         if (count($r)) {
1518                                 $item = $r[0]['id'];
1519                                 $parent_id = $r[0]['parent'];
1520                         }
1521
1522                         if (($item != 0) AND !function_exists("check_item_notification")) {
1523                                 require_once('include/enotify.php');
1524                                 notification(array(
1525                                         'type'         => NOTIFY_TAGSELF,
1526                                         'notify_flags' => $u[0]['notify-flags'],
1527                                         'language'     => $u[0]['language'],
1528                                         'to_name'      => $u[0]['username'],
1529                                         'to_email'     => $u[0]['email'],
1530                                         'uid'          => $u[0]['uid'],
1531                                         'item'         => $postarray,
1532                                         'link'         => $a->get_baseurl().'/display/'.urlencode(get_item_guid($item)),
1533                                         'source_name'  => $postarray['author-name'],
1534                                         'source_link'  => $postarray['author-link'],
1535                                         'source_photo' => $postarray['author-avatar'],
1536                                         'verb'         => ACTIVITY_TAG,
1537                                         'otype'        => 'item',
1538                                         'parent'       => $parent_id,
1539                                 ));
1540                         }
1541                 }
1542         }
1543
1544         set_pconfig($uid, 'statusnet', 'lastmentionid', $lastid);
1545 }
1546
1547 function statusnet_complete_conversation($a, $uid, $self, $create_user, $nick, $conversation) {
1548         $ckey    = get_pconfig($uid, 'statusnet', 'consumerkey');
1549         $csecret = get_pconfig($uid, 'statusnet', 'consumersecret');
1550         $api     = get_pconfig($uid, 'statusnet', 'baseapi');
1551         $otoken  = get_pconfig($uid, 'statusnet', 'oauthtoken');
1552         $osecret = get_pconfig($uid, 'statusnet', 'oauthsecret');
1553         $own_url = get_pconfig($uid, 'statusnet', 'own_url');
1554
1555         require_once('library/twitteroauth.php');
1556
1557         $connection = new StatusNetOAuth($api, $ckey,$csecret,$otoken,$osecret);
1558
1559         $parameters["count"] = 200;
1560
1561         $items = $connection->get('statusnet/conversation/'.$conversation, $parameters);
1562         if (is_array($items)) {
1563                 $posts = array_reverse($items);
1564
1565                 foreach($posts AS $post) {
1566                         $postarray = statusnet_createpost($a, $uid, $post, $self, false, false);
1567
1568                         if (trim($postarray['body']) == "")
1569                                 continue;
1570
1571                         //print_r($postarray);
1572                         $item = item_store($postarray);
1573                         $postarray["id"] = $item;
1574
1575                         logger('statusnet_complete_conversation: User '.$self["nick"].' posted home timeline item '.$item);
1576
1577                         if ($item AND !function_exists("check_item_notification"))
1578                                 statusnet_checknotification($a, $uid, $nick, $item, $postarray);
1579                 }
1580         }
1581 }
1582
1583 function statusnet_convertmsg($a, $body, $no_tags = false) {
1584
1585         require_once("include/oembed.php");
1586         require_once("include/items.php");
1587         require_once("include/network.php");
1588
1589         $body = preg_replace("=\[url\=https?://([0-9]*).([0-9]*).([0-9]*).([0-9]*)/([0-9]*)\](.*?)\[\/url\]=ism","$1.$2.$3.$4/$5",$body);
1590
1591         $URLSearchString = "^\[\]";
1592         $links = preg_match_all("/[^!#@]\[url\=([$URLSearchString]*)\](.*?)\[\/url\]/ism", $body,$matches,PREG_SET_ORDER);
1593
1594         $footer = "";
1595         $footerurl = "";
1596         $footerlink = "";
1597         $type = "";
1598
1599         if ($links) {
1600                 foreach ($matches AS $match) {
1601                         $search = "[url=".$match[1]."]".$match[2]."[/url]";
1602
1603                         logger("statusnet_convertmsg: expanding url ".$match[1], LOGGER_DEBUG);
1604
1605                         $expanded_url = original_url($match[1]);
1606
1607                         logger("statusnet_convertmsg: fetching data for ".$expanded_url, LOGGER_DEBUG);
1608
1609                         $oembed_data = oembed_fetch_url($expanded_url, true);
1610
1611                         logger("statusnet_convertmsg: fetching data: done", LOGGER_DEBUG);
1612
1613                         if ($type == "")
1614                                 $type = $oembed_data->type;
1615                         if ($oembed_data->type == "video") {
1616                                 //$body = str_replace($search, "[video]".$expanded_url."[/video]", $body);
1617                                 $type = $oembed_data->type;
1618                                 $footerurl = $expanded_url;
1619                                 $footerlink = "[url=".$expanded_url."]".$expanded_url."[/url]";
1620
1621                                 $body = str_replace($search, $footerlink, $body);
1622                         } elseif (($oembed_data->type == "photo") AND isset($oembed_data->url) AND !$dontincludemedia)
1623                                 $body = str_replace($search, "[url=".$expanded_url."][img]".$oembed_data->url."[/img][/url]", $body);
1624                         elseif ($oembed_data->type != "link")
1625                                 $body = str_replace($search,  "[url=".$expanded_url."]".$expanded_url."[/url]", $body);
1626                         else {
1627                                 $img_str = fetch_url($expanded_url, true, $redirects, 4);
1628
1629                                 $tempfile = tempnam(get_temppath(), "cache");
1630                                 file_put_contents($tempfile, $img_str);
1631                                 $mime = image_type_to_mime_type(exif_imagetype($tempfile));
1632                                 unlink($tempfile);
1633
1634                                 if (substr($mime, 0, 6) == "image/") {
1635                                         $type = "photo";
1636                                         $body = str_replace($search, "[img]".$expanded_url."[/img]", $body);
1637                                 } else {
1638                                         $type = $oembed_data->type;
1639                                         $footerurl = $expanded_url;
1640                                         $footerlink = "[url=".$expanded_url."]".$expanded_url."[/url]";
1641
1642                                         $body = str_replace($search, $footerlink, $body);
1643                                 }
1644                         }
1645                 }
1646
1647                 if ($footerurl != "")
1648                         $footer = add_page_info($footerurl);
1649
1650                 if (($footerlink != "") AND (trim($footer) != "")) {
1651                         $removedlink = trim(str_replace($footerlink, "", $body));
1652
1653                         if (($removedlink == "") OR strstr($body, $removedlink))
1654                                 $body = $removedlink;
1655
1656                         $body .= $footer;
1657                 }
1658         }
1659
1660         if ($no_tags)
1661                 return(array("body" => $body, "tags" => ""));
1662
1663         $str_tags = '';
1664
1665         $cnt = preg_match_all("/([!#@])\[url\=([$URLSearchString]*)\](.*?)\[\/url\]/ism",$body,$matches,PREG_SET_ORDER);
1666         if($cnt) {
1667                 foreach($matches as $mtch) {
1668                         if(strlen($str_tags))
1669                                 $str_tags .= ',';
1670
1671                         if ($mtch[1] == "#") {
1672                                 // Replacing the hash tags that are directed to the GNU Social server with internal links
1673                                 $snhash = "#[url=".$mtch[2]."]".$mtch[3]."[/url]";
1674                                 $frdchash = '#[url='.$a->get_baseurl().'/search?tag='.rawurlencode($mtch[3]).']'.$mtch[3].'[/url]';
1675                                 $body = str_replace($snhash, $frdchash, $body);
1676
1677                                 $str_tags .= $frdchash;
1678                         } else
1679                                 $str_tags .= "@[url=".$mtch[2]."]".$mtch[3]."[/url]";
1680                                 // To-Do:
1681                                 // There is a problem with links with to GNU Social groups, so these links are stored with "@" like friendica groups
1682                                 //$str_tags .= $mtch[1]."[url=".$mtch[2]."]".$mtch[3]."[/url]";
1683                 }
1684         }
1685
1686         return(array("body"=>$body, "tags"=>$str_tags));
1687
1688 }
1689
1690 function statusnet_fetch_own_contact($a, $uid) {
1691         $ckey    = get_pconfig($uid, 'statusnet', 'consumerkey');
1692         $csecret = get_pconfig($uid, 'statusnet', 'consumersecret');
1693         $api     = get_pconfig($uid, 'statusnet', 'baseapi');
1694         $otoken  = get_pconfig($uid, 'statusnet', 'oauthtoken');
1695         $osecret = get_pconfig($uid, 'statusnet', 'oauthsecret');
1696         $own_url = get_pconfig($uid, 'statusnet', 'own_url');
1697
1698         $contact_id = 0;
1699
1700         if ($own_url == "") {
1701                 require_once('library/twitteroauth.php');
1702
1703                 $connection = new StatusNetOAuth($api, $ckey,$csecret,$otoken,$osecret);
1704
1705                 // Fetching user data
1706                 $user = $connection->get('account/verify_credentials');
1707
1708                 set_pconfig($uid, 'statusnet', 'own_url', normalise_link($user->statusnet_profile_url));
1709
1710                 $contact_id = statusnet_fetch_contact($uid, $user, true);
1711
1712         } else {
1713                 $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1",
1714                         intval($uid), dbesc($own_url));
1715                 if(count($r))
1716                         $contact_id = $r[0]["id"];
1717                 else
1718                         del_pconfig($uid, 'statusnet', 'own_url');
1719
1720         }
1721         return($contact_id);
1722 }
1723
1724 function statusnet_is_retweet($a, $uid, $body) {
1725         $body = trim($body);
1726
1727         // Skip if it isn't a pure repeated messages
1728         // Does it start with a share?
1729         if (strpos($body, "[share") > 0)
1730                 return(false);
1731
1732         // Does it end with a share?
1733         if (strlen($body) > (strrpos($body, "[/share]") + 8))
1734                 return(false);
1735
1736         $attributes = preg_replace("/\[share(.*?)\]\s?(.*?)\s?\[\/share\]\s?/ism","$1",$body);
1737         // Skip if there is no shared message in there
1738         if ($body == $attributes)
1739                 return(false);
1740
1741         $link = "";
1742         preg_match("/link='(.*?)'/ism", $attributes, $matches);
1743         if ($matches[1] != "")
1744                 $link = $matches[1];
1745
1746         preg_match('/link="(.*?)"/ism', $attributes, $matches);
1747         if ($matches[1] != "")
1748                 $link = $matches[1];
1749
1750         $ckey    = get_pconfig($uid, 'statusnet', 'consumerkey');
1751         $csecret = get_pconfig($uid, 'statusnet', 'consumersecret');
1752         $api     = get_pconfig($uid, 'statusnet', 'baseapi');
1753         $otoken  = get_pconfig($uid, 'statusnet', 'oauthtoken');
1754         $osecret = get_pconfig($uid, 'statusnet', 'oauthsecret');
1755         $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $api);
1756
1757         $id = preg_replace("=https?://".$hostname."/notice/(.*)=ism", "$1", $link);
1758
1759         if ($id == $link)
1760                 return(false);
1761
1762         logger('statusnet_is_retweet: Retweeting id '.$id.' for user '.$uid, LOGGER_DEBUG);
1763
1764         $connection = new StatusNetOAuth($api, $ckey,$csecret,$otoken,$osecret);
1765
1766         $result = $connection->post('statuses/retweet/'.$id);
1767
1768         logger('statusnet_is_retweet: result '.print_r($result, true), LOGGER_DEBUG);
1769         return(isset($result->id));
1770 }