]> git.mxchange.org Git - friendica-addons.git/blob - twitter.php
3cabbff3d500903ca04398a709e10ab4c6f6281f
[friendica-addons.git] / twitter.php
1 <?php
2 /**
3  * Name: Twitter Connector
4  * Description: Relay public postings to a connected Twitter account
5  * Version: 1.0.4
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 /*   Twitter Plugin for Friendica
37  *
38  *   Author: Tobias Diekershoff
39  *           tobias.diekershoff@gmx.net
40  *
41  *   License:3-clause BSD license
42  *
43  *   Configuration:
44  *     To use this plugin you need a OAuth Consumer key pair (key & secret)
45  *     you can get it from Twitter at https://twitter.com/apps
46  *
47  *     Register your Friendica site as "Client" application with "Read & Write" access
48  *     we do not need "Twitter as login". When you've registered the app you get the
49  *     OAuth Consumer key and secret pair for your application/site.
50  *
51  *     Add this key pair to your global .htconfig.php or use the admin panel.
52  *
53  *     $a->config['twitter']['consumerkey'] = 'your consumer_key here';
54  *     $a->config['twitter']['consumersecret'] = 'your consumer_secret here';
55  *
56  *     To activate the plugin itself add it to the $a->config['system']['addon']
57  *     setting. After this, your user can configure their Twitter account settings
58  *     from "Settings -> Plugin Settings".
59  *
60  *     Requirements: PHP5, curl [Slinky library]
61  */
62
63 define('TWITTER_DEFAULT_POLL_INTERVAL', 5); // given in minutes
64
65 function twitter_install() {
66         //  we need some hooks, for the configuration and for sending tweets
67         register_hook('connector_settings', 'addon/twitter/twitter.php', 'twitter_settings'); 
68         register_hook('connector_settings_post', 'addon/twitter/twitter.php', 'twitter_settings_post');
69         register_hook('post_local', 'addon/twitter/twitter.php', 'twitter_post_local');
70         register_hook('notifier_normal', 'addon/twitter/twitter.php', 'twitter_post_hook');
71         register_hook('jot_networks', 'addon/twitter/twitter.php', 'twitter_jot_nets');
72         register_hook('cron', 'addon/twitter/twitter.php', 'twitter_cron');
73         register_hook('queue_predeliver', 'addon/twitter/twitter.php', 'twitter_queue_hook');
74         register_hook('follow', 'addon/twitter/twitter.php', 'twitter_follow');
75         logger("installed twitter");
76 }
77
78
79 function twitter_uninstall() {
80         unregister_hook('connector_settings', 'addon/twitter/twitter.php', 'twitter_settings'); 
81         unregister_hook('connector_settings_post', 'addon/twitter/twitter.php', 'twitter_settings_post');
82         unregister_hook('post_local', 'addon/twitter/twitter.php', 'twitter_post_local');
83         unregister_hook('notifier_normal', 'addon/twitter/twitter.php', 'twitter_post_hook');
84         unregister_hook('jot_networks', 'addon/twitter/twitter.php', 'twitter_jot_nets');
85         unregister_hook('cron', 'addon/twitter/twitter.php', 'twitter_cron');
86         unregister_hook('queue_predeliver', 'addon/twitter/twitter.php', 'twitter_queue_hook');
87         unregister_hook('follow', 'addon/twitter/twitter.php', 'twitter_follow');
88
89         // old setting - remove only
90         unregister_hook('post_local_end', 'addon/twitter/twitter.php', 'twitter_post_hook');
91         unregister_hook('plugin_settings', 'addon/twitter/twitter.php', 'twitter_settings'); 
92         unregister_hook('plugin_settings_post', 'addon/twitter/twitter.php', 'twitter_settings_post');
93
94 }
95
96 function twitter_follow($a, &$contact) {
97
98         logger("twitter_follow: Check if contact is twitter contact. ".$contact["url"], LOGGER_DEBUG);
99
100         if (!strstr($contact["url"], "://twitter.com") AND !strstr($contact["url"], "@twitter.com"))
101                 return;
102
103         // contact seems to be a twitter contact, so continue
104         $nickname = preg_replace("=https?://twitter.com/(.*)=ism", "$1", $contact["url"]);
105         $nickname = str_replace("@twitter.com", "", $nickname);
106
107         $uid = $a->user["uid"];
108
109         $ckey    = get_config('twitter', 'consumerkey');
110         $csecret = get_config('twitter', 'consumersecret');
111         $otoken  = get_pconfig($uid, 'twitter', 'oauthtoken');
112         $osecret = get_pconfig($uid, 'twitter', 'oauthsecret');
113
114         require_once("addon/twitter/codebird.php");
115
116         $cb = \Codebird\Codebird::getInstance();
117         $cb->setConsumerKey($ckey, $csecret);
118         $cb->setToken($otoken, $osecret);
119
120         $parameters = array();
121         $parameters["screen_name"] = $nickname;
122
123         $user = $cb->friendships_create($parameters);
124
125         twitter_fetchuser($a, $uid, $nickname);
126
127         $r = q("SELECT name,nick,url,addr,batch,notify,poll,request,confirm,poco,photo,priority,network,alias,pubkey
128                 FROM `contact` WHERE `uid` = %d AND `nick` = '%s'",
129                                 intval($uid),
130                                 dbesc($nickname));
131         if (count($r))
132                 $contact["contact"] = $r[0];
133 }
134
135 function twitter_jot_nets(&$a,&$b) {
136         if(! local_user())
137                 return;
138
139         $tw_post = get_pconfig(local_user(),'twitter','post');
140         if(intval($tw_post) == 1) {
141                 $tw_defpost = get_pconfig(local_user(),'twitter','post_by_default');
142                 $selected = ((intval($tw_defpost) == 1) ? ' checked="checked" ' : '');
143                 $b .= '<div class="profile-jot-net"><input type="checkbox" name="twitter_enable"' . $selected . ' value="1" /> ' 
144                         . t('Post to Twitter') . '</div>';
145         }
146 }
147
148 function twitter_settings_post ($a,$post) {
149         if(! local_user())
150                 return;
151         // don't check twitter settings if twitter submit button is not clicked
152         if (!x($_POST,'twitter-submit'))
153                 return;
154
155         if (isset($_POST['twitter-disconnect'])) {
156                 /***
157                  * if the twitter-disconnect checkbox is set, clear the OAuth key/secret pair
158                  * from the user configuration
159                  */
160                 del_pconfig(local_user(), 'twitter', 'consumerkey');
161                 del_pconfig(local_user(), 'twitter', 'consumersecret');
162                 del_pconfig(local_user(), 'twitter', 'oauthtoken');
163                 del_pconfig(local_user(), 'twitter', 'oauthsecret');
164                 del_pconfig(local_user(), 'twitter', 'post');
165                 del_pconfig(local_user(), 'twitter', 'post_by_default');
166                 del_pconfig(local_user(), 'twitter', 'post_taglinks');
167                 del_pconfig(local_user(), 'twitter', 'lastid');
168                 del_pconfig(local_user(), 'twitter', 'mirror_posts');
169                 del_pconfig(local_user(), 'twitter', 'intelligent_shortening');
170                 del_pconfig(local_user(), 'twitter', 'import');
171                 del_pconfig(local_user(), 'twitter', 'create_user');
172         } else {
173         if (isset($_POST['twitter-pin'])) {
174                 //  if the user supplied us with a PIN from Twitter, let the magic of OAuth happen
175                 logger('got a Twitter PIN');
176                 require_once('library/twitteroauth.php');
177                 $ckey    = get_config('twitter', 'consumerkey');
178                 $csecret = get_config('twitter', 'consumersecret');
179                 //  the token and secret for which the PIN was generated were hidden in the settings
180                 //  form as token and token2, we need a new connection to Twitter using these token
181                 //  and secret to request a Access Token with the PIN
182                 $connection = new TwitterOAuth($ckey, $csecret, $_POST['twitter-token'], $_POST['twitter-token2']);
183                 $token   = $connection->getAccessToken( $_POST['twitter-pin'] );
184                 //  ok, now that we have the Access Token, save them in the user config
185                 set_pconfig(local_user(),'twitter', 'oauthtoken',  $token['oauth_token']);
186                 set_pconfig(local_user(),'twitter', 'oauthsecret', $token['oauth_token_secret']);
187                 set_pconfig(local_user(),'twitter', 'post', 1);
188                 set_pconfig(local_user(),'twitter', 'post_taglinks', 1);
189                 //  reload the Addon Settings page, if we don't do it see Bug #42
190                 goaway($a->get_baseurl().'/settings/connectors');
191         } else {
192                 //  if no PIN is supplied in the POST variables, the user has changed the setting
193                 //  to post a tweet for every new __public__ posting to the wall
194                 set_pconfig(local_user(),'twitter','post',intval($_POST['twitter-enable']));
195                 set_pconfig(local_user(),'twitter','post_by_default',intval($_POST['twitter-default']));
196                 set_pconfig(local_user(),'twitter','post_taglinks',intval($_POST['twitter-sendtaglinks']));
197                 set_pconfig(local_user(), 'twitter', 'mirror_posts', intval($_POST['twitter-mirror']));
198                 set_pconfig(local_user(), 'twitter', 'intelligent_shortening', intval($_POST['twitter-shortening']));
199                 set_pconfig(local_user(), 'twitter', 'import', intval($_POST['twitter-import']));
200                 set_pconfig(local_user(), 'twitter', 'create_user', intval($_POST['twitter-create_user']));
201                 info( t('Twitter settings updated.') . EOL);
202         }}
203 }
204 function twitter_settings(&$a,&$s) {
205         if(! local_user())
206                 return;
207         $a->page['htmlhead'] .= '<link rel="stylesheet"  type="text/css" href="' . $a->get_baseurl() . '/addon/twitter/twitter.css' . '" media="all" />' . "\r\n";
208         /***
209          * 1) Check that we have global consumer key & secret
210          * 2) If no OAuthtoken & stuff is present, generate button to get some
211          * 3) Checkbox for "Send public notices (140 chars only)
212          */
213         $ckey    = get_config('twitter', 'consumerkey' );
214         $csecret = get_config('twitter', 'consumersecret' );
215         $otoken  = get_pconfig(local_user(), 'twitter', 'oauthtoken'  );
216         $osecret = get_pconfig(local_user(), 'twitter', 'oauthsecret' );
217         $enabled = get_pconfig(local_user(), 'twitter', 'post');
218         $checked = (($enabled) ? ' checked="checked" ' : '');
219         $defenabled = get_pconfig(local_user(),'twitter','post_by_default');
220         $defchecked = (($defenabled) ? ' checked="checked" ' : '');
221         $linksenabled = get_pconfig(local_user(),'twitter','post_taglinks');
222         $linkschecked = (($linksenabled) ? ' checked="checked" ' : '');
223         $mirrorenabled = get_pconfig(local_user(),'twitter','mirror_posts');
224         $mirrorchecked = (($mirrorenabled) ? ' checked="checked" ' : '');
225         $shorteningenabled = get_pconfig(local_user(),'twitter','intelligent_shortening');
226         $shorteningchecked = (($shorteningenabled) ? ' checked="checked" ' : '');
227         $importenabled = get_pconfig(local_user(),'twitter','import');
228         $importchecked = (($importenabled) ? ' checked="checked" ' : '');
229         $create_userenabled = get_pconfig(local_user(),'twitter','create_user');
230         $create_userchecked = (($create_userenabled) ? ' checked="checked" ' : '');
231
232         $s .= '<div class="settings-block">';
233         $s .= '<h3>'. t('Twitter Posting Settings') .'</h3>';
234
235         if ( (!$ckey) && (!$csecret) ) {
236                 /***
237                  * no global consumer keys
238                  * display warning and skip personal config
239                  */
240                 $s .= '<p>'. t('No consumer key pair for Twitter found. Please contact your site administrator.') .'</p>';
241         } else {
242                 /***
243                  * ok we have a consumer key pair now look into the OAuth stuff
244                  */
245                 if ( (!$otoken) && (!$osecret) ) {
246                         /***
247                          * the user has not yet connected the account to twitter...
248                          * get a temporary OAuth key/secret pair and display a button with
249                          * which the user can request a PIN to connect the account to a
250                          * account at Twitter.
251                          */
252                         require_once('library/twitteroauth.php');
253                         $connection = new TwitterOAuth($ckey, $csecret);
254                         $request_token = $connection->getRequestToken();
255                         $token = $request_token['oauth_token'];
256                         /***
257                          *  make some nice form
258                          */
259                         $s .= '<p>'. t('At this Friendica instance the Twitter plugin was enabled but you have not yet connected your account to your Twitter account. To do so click the button below to get a PIN from Twitter which you have to copy into the input box below and submit the form. Only your <strong>public</strong> posts will be posted to Twitter.') .'</p>';
260                         $s .= '<a href="'.$connection->getAuthorizeURL($token).'" target="_twitter"><img src="addon/twitter/lighter.png" alt="'.t('Log in with Twitter').'"></a>';
261                         $s .= '<div id="twitter-pin-wrapper">';
262                         $s .= '<label id="twitter-pin-label" for="twitter-pin">'. t('Copy the PIN from Twitter here') .'</label>';
263                         $s .= '<input id="twitter-pin" type="text" name="twitter-pin" />';
264                         $s .= '<input id="twitter-token" type="hidden" name="twitter-token" value="'.$token.'" />';
265                         $s .= '<input id="twitter-token2" type="hidden" name="twitter-token2" value="'.$request_token['oauth_token_secret'].'" />';
266             $s .= '</div><div class="clear"></div>';
267             $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="twitter-submit" class="settings-submit" value="' . t('Submit') . '" /></div>';
268                 } else {
269                         /***
270                          *  we have an OAuth key / secret pair for the user
271                          *  so let's give a chance to disable the postings to Twitter
272                          */
273                         require_once('library/twitteroauth.php');
274                         $connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret);
275                         $details = $connection->get('account/verify_credentials');
276                         $s .= '<div id="twitter-info" ><img id="twitter-avatar" src="'.$details->profile_image_url.'" /><p id="twitter-info-block">'. t('Currently connected to: ') .'<a href="https://twitter.com/'.$details->screen_name.'" target="_twitter">'.$details->screen_name.'</a><br /><em>'.$details->description.'</em></p></div>';
277                         $s .= '<p>'. t('If enabled all your <strong>public</strong> postings can be posted to the associated Twitter account. You can choose to do so by default (here) or for every posting separately in the posting options when writing the entry.') .'</p>';
278                         if ($a->user['hidewall']) {
279                             $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 Twitter will lead the visitor to a blank page informing the visitor that the access to your profile has been restricted.') .'</p>';
280                         }
281                         $s .= '<div id="twitter-enable-wrapper">';
282                         $s .= '<label id="twitter-enable-label" for="twitter-checkbox">'. t('Allow posting to Twitter'). '</label>';
283                         $s .= '<input id="twitter-checkbox" type="checkbox" name="twitter-enable" value="1" ' . $checked . '/>';
284                         $s .= '<div class="clear"></div>';
285                         $s .= '<label id="twitter-default-label" for="twitter-default">'. t('Send public postings to Twitter by default') .'</label>';
286                         $s .= '<input id="twitter-default" type="checkbox" name="twitter-default" value="1" ' . $defchecked . '/>';
287                         $s .= '<div class="clear"></div>';
288
289                         $s .= '<label id="twitter-mirror-label" for="twitter-mirror">'.t('Mirror all posts from twitter that are no replies').'</label>';
290                         $s .= '<input id="twitter-mirror" type="checkbox" name="twitter-mirror" value="1" '. $mirrorchecked . '/>';
291                         $s .= '<div class="clear"></div>';
292
293                         $s .= '<label id="twitter-shortening-label" for="twitter-shortening">'.t('Shortening method that optimizes the tweet').'</label>';
294                         $s .= '<input id="twitter-shortening" type="checkbox" name="twitter-shortening" value="1" '. $shorteningchecked . '/>';
295                         $s .= '<div class="clear"></div>';
296
297                         $s .= '<label id="twitter-sendtaglinks-label" for="twitter-sendtaglinks">'.t('Send linked #-tags and @-names to Twitter').'</label>';
298                         $s .= '<input id="twitter-sendtaglinks" type="checkbox" name="twitter-sendtaglinks" value="1" '. $linkschecked . '/>';
299                         $s .= '</div><div class="clear"></div>';
300
301                         $s .= '<label id="twitter-import-label" for="twitter-import">'.t('Import the remote timeline').'</label>';
302                         $s .= '<input id="twitter-import" type="checkbox" name="twitter-import" value="1" '. $importchecked . '/>';
303                         $s .= '<div class="clear"></div>';
304
305                         $s .= '<label id="twitter-create_user-label" for="twitter-create_user">'.t('Automatically create contacts').'</label>';
306                         $s .= '<input id="twitter-create_user" type="checkbox" name="twitter-create_user" value="1" '. $create_userchecked . '/>';
307                         $s .= '<div class="clear"></div>';
308
309                         $s .= '<div id="twitter-disconnect-wrapper">';
310                         $s .= '<label id="twitter-disconnect-label" for="twitter-disconnect">'. t('Clear OAuth configuration') .'</label>';
311                         $s .= '<input id="twitter-disconnect" type="checkbox" name="twitter-disconnect" value="1" />';
312                         $s .= '</div><div class="clear"></div>';
313                         $s .= '<div class="settings-submit-wrapper" ><input type="submit" name="twitter-submit" class="settings-submit" value="' . t('Submit') . '" /></div>'; 
314                 }
315         }
316         $s .= '</div><div class="clear"></div>';
317 }
318
319
320 function twitter_post_local(&$a,&$b) {
321
322         if($b['edit'])
323                 return;
324
325         if((local_user()) && (local_user() == $b['uid']) && (! $b['private']) && (! $b['parent']) ) {
326
327                 $twitter_post = intval(get_pconfig(local_user(),'twitter','post'));
328                 $twitter_enable = (($twitter_post && x($_REQUEST,'twitter_enable')) ? intval($_REQUEST['twitter_enable']) : 0);
329
330                 // if API is used, default to the chosen settings
331                 if($_REQUEST['api_source'] && intval(get_pconfig(local_user(),'twitter','post_by_default')))
332                         $twitter_enable = 1;
333
334         if(! $twitter_enable)
335             return;
336
337         if(strlen($b['postopts']))
338             $b['postopts'] .= ',';
339         $b['postopts'] .= 'twitter';
340         }
341 }
342
343 if (! function_exists('short_link')) {
344 function short_link ($url) {
345     require_once('library/slinky.php');
346     $slinky = new Slinky( $url );
347     $yourls_url = get_config('yourls','url1');
348     if ($yourls_url) {
349             $yourls_username = get_config('yourls','username1');
350             $yourls_password = get_config('yourls', 'password1');
351             $yourls_ssl = get_config('yourls', 'ssl1');
352             $yourls = new Slinky_YourLS();
353             $yourls->set( 'username', $yourls_username );
354             $yourls->set( 'password', $yourls_password );
355             $yourls->set( 'ssl', $yourls_ssl );
356             $yourls->set( 'yourls-url', $yourls_url );
357             $slinky->set_cascade( array( $yourls, new Slinky_UR1ca(), new Slinky_Trim(), new Slinky_IsGd(), new Slinky_TinyURL() ) );
358     }
359     else {
360             // setup a cascade of shortening services
361             // try to get a short link from these services
362             // in the order ur1.ca, trim, id.gd, tinyurl
363             $slinky->set_cascade( array( new Slinky_UR1ca(), new Slinky_Trim(), new Slinky_IsGd(), new Slinky_TinyURL() ) );
364     }
365     return $slinky->short();
366 } };
367
368 function twitter_shortenmsg($b, $shortlink = false) {
369         require_once("include/bbcode.php");
370         require_once("include/html2plain.php");
371
372         $max_char = 140;
373
374         // Looking for the first image
375         $image = '';
376         if(preg_match("/\[img\=([0-9]*)x([0-9]*)\](.*?)\[\/img\]/is",$b['body'],$matches))
377                 $image = $matches[3];
378
379         if ($image == '')
380                 if(preg_match("/\[img\](.*?)\[\/img\]/is",$b['body'],$matches))
381                         $image = $matches[1];
382
383         $multipleimages = (strpos($b['body'], "[img") != strrpos($b['body'], "[img"));
384
385         // When saved into the database the content is sent through htmlspecialchars
386         // That means that we have to decode all image-urls
387         $image = htmlspecialchars_decode($image);
388
389         $body = $b["body"];
390         if ($b["title"] != "")
391                 $body = $b["title"]."\n\n".$body;
392
393         if (strpos($body, "[bookmark") !== false) {
394                 // splitting the text in two parts:
395                 // before and after the bookmark
396                 $pos = strpos($body, "[bookmark");
397                 $body1 = substr($body, 0, $pos);
398                 $body2 = substr($body, $pos);
399
400                 // Removing all quotes after the bookmark
401                 // they are mostly only the content after the bookmark.
402                 $body2 = preg_replace("/\[quote\=([^\]]*)\](.*?)\[\/quote\]/ism",'',$body2);
403                 $body2 = preg_replace("/\[quote\](.*?)\[\/quote\]/ism",'',$body2);
404                 $body = $body1.$body2;
405         }
406
407         // Add some newlines so that the message could be cut better
408         $body = str_replace(array("[quote", "[bookmark", "[/bookmark]", "[/quote]"),
409                         array("\n[quote", "\n[bookmark", "[/bookmark]\n", "[/quote]\n"), $body);
410
411         // remove the recycle signs and the names since they aren't helpful on twitter
412         // recycle 1
413         $recycle = html_entity_decode("&#x2672; ", ENT_QUOTES, 'UTF-8');
414         $body = preg_replace( '/'.$recycle.'\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', "\n", $body);
415         // recycle 2 (Test)
416         $recycle = html_entity_decode("&#x25CC; ", ENT_QUOTES, 'UTF-8');
417         $body = preg_replace( '/'.$recycle.'\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', "\n", $body);
418
419         // remove the share element
420         //$body = preg_replace("/\[share(.*?)\](.*?)\[\/share\]/ism","\n\n$2\n\n",$body);
421
422         // At first convert the text to html
423         $html = bbcode($body, false, false, 2);
424
425         // Then convert it to plain text
426         $msg = trim(html2plain($html, 0, true));
427         $msg = html_entity_decode($msg,ENT_QUOTES,'UTF-8');
428
429         // Removing multiple newlines
430         while (strpos($msg, "\n\n\n") !== false)
431                 $msg = str_replace("\n\n\n", "\n\n", $msg);
432
433         // Removing multiple spaces
434         while (strpos($msg, "  ") !== false)
435                 $msg = str_replace("  ", " ", $msg);
436
437         $origmsg = trim($msg);
438
439         // Removing URLs
440         $msg = preg_replace('/(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)/i', "", $msg);
441
442         $msg = trim($msg);
443
444         $link = '';
445         // look for bookmark-bbcode and handle it with priority
446         if(preg_match("/\[bookmark\=([^\]]*)\](.*?)\[\/bookmark\]/is",$b['body'],$matches))
447                 $link = $matches[1];
448
449         $multiplelinks = (strpos($b['body'], "[bookmark") != strrpos($b['body'], "[bookmark"));
450
451         // If there is no bookmark element then take the first link
452         if ($link == '') {
453                 $links = collecturls($html);
454
455                 foreach($links AS $singlelink) {
456                         $img_str = fetch_url($singlelink);
457
458                         $tempfile = tempnam(get_config("system","temppath"), "cache");
459                         file_put_contents($tempfile, $img_str);
460                         $mime = image_type_to_mime_type(exif_imagetype($tempfile));
461                         unlink($tempfile);
462
463                         if (substr($mime, 0, 6) == "image/") {
464                                 $image = $singlelink;
465                                 unset($links[$singlelink]);
466                         }
467                 }
468
469                 if (sizeof($links) > 0) {
470                         reset($links);
471                         $link = current($links);
472                 }
473                 $multiplelinks = (sizeof($links) > 1);
474         }
475
476         $msglink = "";
477         if ($multiplelinks)
478                 $msglink = $b["plink"];
479         else if ($link != "")
480                 $msglink = $link;
481         else if ($multipleimages)
482                 $msglink = $b["plink"];
483         else if ($image != "")
484                 $msglink = $image;
485
486         if (($msglink == "") and strlen($msg) > $max_char)
487                 $msglink = $b["plink"];
488
489         // If the message is short enough then don't modify it.
490         if ((strlen($origmsg) <= $max_char) AND ($msglink == ""))
491                 return(array("msg"=>$origmsg, "image"=>""));
492
493         // If the message is short enough and contains a picture then post the picture as well
494         if ((strlen($origmsg) <= ($max_char - 23)) AND strpos($origmsg, $msglink))
495                 return(array("msg"=>$origmsg, "image"=>$image));
496
497         // If the message is short enough and the link exists in the original message don't modify it as well
498         // -3 because of the bad shortener of twitter
499         if ((strlen($origmsg) <= ($max_char - 3)) AND strpos($origmsg, $msglink))
500                 return(array("msg"=>$origmsg, "image"=>""));
501
502         // Preserve the unshortened link
503         $orig_link = $msglink;
504
505         // Just replace the message link with a 22 character long string
506         // Twitter calculates with this length
507         if (trim($msglink) <> '')
508                 $msglink = "1234567890123456789012";
509
510         if (strlen(trim($msg." ".$msglink)) > ($max_char)) {
511                 $msg = substr($msg, 0, ($max_char) - (strlen($msglink)));
512                 $lastchar = substr($msg, -1);
513                 $msg = substr($msg, 0, -1);
514                 $pos = strrpos($msg, "\n");
515                 if ($pos > 0)
516                         $msg = substr($msg, 0, $pos);
517                 else if ($lastchar != "\n")
518                         $msg = substr($msg, 0, -3)."...";
519
520                 // if the post contains a picture and a link then the system tries to cut the post earlier.
521                 // So the link and the picture can be posted.
522                 if (($image != "") AND ($orig_link != $image)) {
523                         $msg2 = substr($msg, 0, ($max_char - 20) - (strlen($msglink)));
524                         $lastchar = substr($msg2, -1);
525                         $msg2 = substr($msg2, 0, -1);
526                         $pos = strrpos($msg2, "\n");
527                         if ($pos > 0)
528                                 $msg = substr($msg2, 0, $pos);
529                         else if ($lastchar == "\n")
530                                 $msg = trim($msg2);
531                 }
532
533         }
534         // Removing multiple spaces - again
535         while (strpos($msg, "  ") !== false)
536                 $msg = str_replace("  ", " ", $msg);
537
538         $msg = trim($msg);
539
540         // Removing multiple newlines
541         //while (strpos($msg, "\n\n") !== false)
542         //      $msg = str_replace("\n\n", "\n", $msg);
543
544         // Looking if the link points to an image
545         $img_str = fetch_url($orig_link);
546
547         $tempfile = tempnam(get_config("system","temppath"), "cache");
548         file_put_contents($tempfile, $img_str);
549         $mime = image_type_to_mime_type(exif_imagetype($tempfile));
550         unlink($tempfile);
551
552         if (($image == $orig_link) OR (substr($mime, 0, 6) == "image/"))
553                 return(array("msg"=>$msg, "image"=>$orig_link));
554         else if (($image != $orig_link) AND ($image != "") AND (strlen($msg." ".$msglink) <= ($max_char - 23))) {
555                 if ($shortlink)
556                         $orig_link = short_link($orig_link);
557
558                 return(array("msg"=>$msg." ".$orig_link, "image"=>$image));
559         } else {
560                 if ($shortlink)
561                         $orig_link = short_link($orig_link);
562
563                 return(array("msg"=>$msg." ".$orig_link, "image"=>""));
564         }
565 }
566
567 function twitter_action($a, $uid, $pid, $action) {
568
569         $ckey    = get_config('twitter', 'consumerkey');
570         $csecret = get_config('twitter', 'consumersecret');
571         $otoken  = get_pconfig($uid, 'twitter', 'oauthtoken');
572         $osecret = get_pconfig($uid, 'twitter', 'oauthsecret');
573
574         require_once("addon/twitter/codebird.php");
575
576         $cb = \Codebird\Codebird::getInstance();
577         $cb->setConsumerKey($ckey, $csecret);
578         $cb->setToken($otoken, $osecret);
579
580         $post = array('id' => $pid);
581
582         logger("twitter_action '".$action."' ID: ".$pid." data: " . print_r($post, true), LOGGER_DATA);
583
584         switch ($action) {
585                 case "delete":
586                         $result = $cb->statuses_destroy($post);
587                         break;
588                 case "like":
589                         $result = $cb->favorites_create($post);
590                         break;
591                 case "unlike":
592                         $result = $cb->favorites_destroy($post);
593                         break;
594         }
595         logger("twitter_action '".$action."' send, result: " . print_r($result, true), LOGGER_DEBUG);
596 }
597
598 function twitter_post_hook(&$a,&$b) {
599
600         /**
601          * Post to Twitter
602          */
603
604         if (!get_pconfig($b["uid"],'twitter','import')) {
605                 if($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited']))
606                         return;
607         }
608
609         if($b['parent'] != $b['id']) {
610                 logger("twitter_post_hook: parameter ".print_r($b, true), LOGGER_DATA);
611
612                 // Looking if its a reply to a twitter post
613                 if ((substr($b["parent-uri"], 0, 9) != "twitter::") AND (substr($b["extid"], 0, 9) != "twitter::") AND (substr($b["thr-parent"], 0, 9) != "twitter::")) {
614                         logger("twitter_post_hook: no twitter post ".$b["parent"]);
615                         return;
616                 }
617
618                 $r = q("SELECT * FROM item WHERE item.uri = '%s' AND item.uid = %d LIMIT 1",
619                         dbesc($b["thr-parent"]),
620                         intval($b["uid"]));
621
622                 if(!count($r)) {
623                         logger("twitter_post_hook: no parent found ".$b["thr-parent"]);
624                         return;
625                 } else {
626                         $iscomment = true;
627                         $orig_post = $r[0];
628                 }
629
630                 // To-Do: Ab dem letzten / nehmen
631                 $b["body"] = "@".substr($orig_post["author-link"], 20)." ".$b["body"];
632
633                 logger("twitter_post_hook: parent found ".print_r($orig_post, true), LOGGER_DATA);
634         } else {
635                 $iscomment = false;
636
637                 if($b['private'] OR !strstr($b['postopts'],'twitter'))
638                         return;
639         }
640
641         if (($b['verb'] == ACTIVITY_POST) AND $b['deleted'])
642                 twitter_action($a, $b["uid"], substr($orig_post["uri"], 9), "delete");
643
644         if($b['verb'] == ACTIVITY_LIKE) {
645                 logger("twitter_post_hook: parameter 2 ".substr($b["thr-parent"], 9), LOGGER_DEBUG);
646                 if ($b['deleted'])
647                         twitter_action($a, $b["uid"], substr($b["thr-parent"], 9), "unlike");
648                 else
649                         twitter_action($a, $b["uid"], substr($b["thr-parent"], 9), "like");
650                 return;
651         }
652
653         if($b['deleted'] || ($b['created'] !== $b['edited']))
654                 return;
655
656         // if post comes from twitter don't send it back
657         if($b['app'] == "Twitter")
658                 return;
659
660         logger('twitter post invoked');
661
662
663         load_pconfig($b['uid'], 'twitter');
664
665         $ckey    = get_config('twitter', 'consumerkey');
666         $csecret = get_config('twitter', 'consumersecret');
667         $otoken  = get_pconfig($b['uid'], 'twitter', 'oauthtoken');
668         $osecret = get_pconfig($b['uid'], 'twitter', 'oauthsecret');
669         $intelligent_shortening = get_pconfig($b['uid'], 'twitter', 'intelligent_shortening');
670
671         // Global setting overrides this
672         if (get_config('twitter','intelligent_shortening'))
673                 $intelligent_shortening = get_config('twitter','intelligent_shortening');
674
675         if($ckey && $csecret && $otoken && $osecret) {
676                 logger('twitter: we have customer key and oauth stuff, going to send.', LOGGER_DEBUG);
677
678                 require_once('library/twitteroauth.php');
679                 require_once('include/bbcode.php');
680                 $tweet = new TwitterOAuth($ckey,$csecret,$otoken,$osecret);
681                 // in theory max char is 140 but T. uses t.co to make links 
682                 // longer so we give them 10 characters extra
683                 if (!$intelligent_shortening) {
684                         $max_char = 130; // max. length for a tweet
685                         // we will only work with up to two times the length of the dent 
686                         // we can later send to Twitter. This way we can "gain" some 
687                         // information during shortening of potential links but do not 
688                         // shorten all the links in a 200000 character long essay.
689                         if (! $b['title']=='') {
690                             $tmp = $b['title'] . ' : '. $b['body'];
691         //                    $tmp = substr($tmp, 0, 4*$max_char);
692                         } else {
693                             $tmp = $b['body']; // substr($b['body'], 0, 3*$max_char);
694                         }
695                         // if [url=bla][img]blub.png[/img][/url] get blub.png
696                         $tmp = preg_replace( '/\[url\=(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)\]\[img\](\\w+.*?)\\[\\/img\]\\[\\/url\]/i', '$2', $tmp);
697                         // preserve links to images, videos and audios
698                         $tmp = preg_replace( '/\[img\=([0-9]*)x([0-9]*)\](.*?)\[\/img\]/ism', '$3', $tmp);
699                         $tmp = preg_replace( '/\[\\/?img(\\s+.*?\]|\])/i', '', $tmp);
700                         $tmp = preg_replace( '/\[\\/?video(\\s+.*?\]|\])/i', '', $tmp);
701                         $tmp = preg_replace( '/\[\\/?youtube(\\s+.*?\]|\])/i', '', $tmp);
702                         $tmp = preg_replace( '/\[\\/?vimeo(\\s+.*?\]|\])/i', '', $tmp);
703                         $tmp = preg_replace( '/\[\\/?audio(\\s+.*?\]|\])/i', '', $tmp);
704                         $linksenabled = get_pconfig($b['uid'],'twitter','post_taglinks');
705                         // if a #tag is linked, don't send the [url] over to SN
706                         // that is, don't send if the option is not set in the
707                         // connector settings
708                         if ($linksenabled=='0') {
709                                 // #-tags
710                                 $tmp = preg_replace( '/#\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', '#$2', $tmp);
711                                 // @-mentions
712                                 $tmp = preg_replace( '/@\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', '@$2', $tmp);
713                                 // recycle 1
714                                 $recycle = html_entity_decode("&#x2672; ", ENT_QUOTES, 'UTF-8');
715                                 $tmp = preg_replace( '/'.$recycle.'\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', $recycle.'$2', $tmp);
716                                 // recycle 2 (Test)
717                                 $recycle = html_entity_decode("&#x25CC; ", ENT_QUOTES, 'UTF-8');
718                                 $tmp = preg_replace( '/'.$recycle.'\[url\=(\w+.*?)\](\w+.*?)\[\/url\]/i', $recycle.'$2', $tmp);
719                         }
720                         $tmp = preg_replace( '/\[url\=(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)\](\w+.*?)\[\/url\]/i', '$2 $1', $tmp);
721                         $tmp = preg_replace( '/\[bookmark\=(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)\](\w+.*?)\[\/bookmark\]/i', '$2 $1', $tmp);
722                         // find all http or https links in the body of the entry and
723                         // apply the shortener if the link is longer then 20 characters
724                         if (( strlen($tmp)>$max_char ) && ( $max_char > 0 )) {
725                             preg_match_all ( '/(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)/i', $tmp, $allurls  );
726                             foreach ($allurls as $url) {
727                                 foreach ($url as $u) {
728                                     if (strlen($u)>20) {
729                                         $sl = short_link($u);
730                                         $tmp = str_replace( $u, $sl, $tmp );
731                                     }
732                                 }
733                             }
734                         }
735                         // ok, all the links we want to send out are save, now strip 
736                         // away the remaining bbcode
737                         //$msg = strip_tags(bbcode($tmp, false, false));
738                         $msg = bbcode($tmp, false, false, true);
739                         $msg = str_replace(array('<br>','<br />'),"\n",$msg);
740                         $msg = strip_tags($msg);
741
742                         // quotes not working - let's try this
743                         $msg = html_entity_decode($msg);
744                         if (( strlen($msg) > $max_char) && $max_char > 0) {
745                                 $shortlink = short_link( $b['plink'] );
746                                 // the new message will be shortened such that "... $shortlink"
747                                 // will fit into the character limit
748                                 $msg = nl2br(substr($msg, 0, $max_char-strlen($shortlink)-4));
749                                 $msg = str_replace(array('<br>','<br />'),' ',$msg);
750                                 $e = explode(' ', $msg);
751                                 //  remove the last word from the cut down message to 
752                                 //  avoid sending cut words to the MicroBlog
753                                 array_pop($e);
754                                 $msg = implode(' ', $e);
755                                 $msg .= '... ' . $shortlink;
756                         }
757
758                         $msg = trim($msg);
759                         $image = "";
760                 } else {
761                         $msgarr = twitter_shortenmsg($b);
762                         $msg = $msgarr["msg"];
763                         $image = $msgarr["image"];
764                 }
765                 // and now tweet it :-)
766                 if(strlen($msg) and ($image != "")) {
767                         $img_str = fetch_url($image);
768
769                         $tempfile = tempnam(get_config("system","temppath"), "cache");
770                         file_put_contents($tempfile, $img_str);
771
772                         // Twitter had changed something so that the old library doesn't work anymore
773                         // so we are using a new library for twitter
774                         // To-Do:
775                         // Switching completely to this library with all functions
776                         require_once("addon/twitter/codebird.php");
777
778                         $cb = \Codebird\Codebird::getInstance();
779                         $cb->setConsumerKey($ckey, $csecret);
780                         $cb->setToken($otoken, $osecret);
781
782                         $post = array('status' => $msg, 'media[]' => $tempfile);
783
784                         if ($iscomment)
785                                 $post["in_reply_to_status_id"] = substr($orig_post["uri"], 9);
786
787                         $result = $cb->statuses_updateWithMedia($post);
788                         unlink($tempfile);
789
790                         /*
791                         // Old Code
792                         $mime = image_type_to_mime_type(exif_imagetype($tempfile));
793                         unlink($tempfile);
794
795                         $filename = "upload";
796
797                         $result = $tweet->post('statuses/update_with_media', array('media[]' => "{$img_str};type=".$mime.";filename={$filename}" , 'status' => $msg));
798                         */
799
800                         logger('twitter_post_with_media send, result: ' . print_r($result, true), LOGGER_DEBUG);
801                         if ($result->errors OR $result->error) {
802                                 logger('Send to Twitter failed: "' . print_r($result->errors, true) . '"');
803
804                                 // Workaround: Remove the picture link so that the post can be reposted without it
805                                 $msg .= " ".$image;
806                                 $image = "";
807                         } elseif ($iscomment) {
808                                 logger('twitter_post: Update extid '.$result->id_str." for post id ".$b['id']);
809                                 q("UPDATE `item` SET `extid` = '%s', `body` = '%s' WHERE `id` = %d",
810                                         dbesc("twitter::".$result->id_str),
811                                         dbesc($result->text),
812                                         intval($b['id'])
813                                 );
814                         }
815                 }
816
817                 if(strlen($msg) and ($image == "")) {
818                         $url = 'statuses/update';
819                         $post = array('status' => $msg);
820
821                         if ($iscomment)
822                                 $post["in_reply_to_status_id"] = substr($orig_post["uri"], 9);
823
824                         $result = $tweet->post($url, $post);
825                         logger('twitter_post send, result: ' . print_r($result, true), LOGGER_DEBUG);
826                         if ($result->errors) {
827                                 logger('Send to Twitter failed: "' . print_r($result->errors, true) . '"');
828
829                                 $r = q("SELECT `id` FROM `contact` WHERE `uid` = %d AND `self`", intval($b['uid']));
830                                 if (count($r))
831                                         $a->contact = $r[0]["id"];
832
833                                 $s = serialize(array('url' => $url, 'item' => $b['id'], 'post' => $post));
834                                 require_once('include/queue_fn.php');
835                                 add_to_queue($a->contact,NETWORK_TWITTER,$s);
836                                 notice(t('Twitter post failed. Queued for retry.').EOL);
837                         } elseif ($iscomment) {
838                                 logger('twitter_post: Update extid '.$result->id_str." for post id ".$b['id']);
839                                 q("UPDATE `item` SET `extid` = '%s' WHERE `id` = %d",
840                                         dbesc("twitter::".$result->id_str),
841                                         intval($b['id'])
842                                 );
843                                 //q("UPDATE `item` SET `extid` = '%s', `body` = '%s' WHERE `id` = %d",
844                                 //      dbesc("twitter::".$result->id_str),
845                                 //      dbesc($result->text),
846                                 //      intval($b['id'])
847                                 //);
848                         }
849                 }
850         }
851 }
852
853 function twitter_plugin_admin_post(&$a){
854         $consumerkey    =       ((x($_POST,'consumerkey'))              ? notags(trim($_POST['consumerkey']))   : '');
855         $consumersecret =       ((x($_POST,'consumersecret'))   ? notags(trim($_POST['consumersecret'])): '');
856         $applicationname = ((x($_POST, 'applicationname')) ? notags(trim($_POST['applicationname'])):'');
857         set_config('twitter','consumerkey',$consumerkey);
858         set_config('twitter','consumersecret',$consumersecret);
859         set_config('twitter','application_name',$applicationname);
860         info( t('Settings updated.'). EOL );
861 }
862 function twitter_plugin_admin(&$a, &$o){
863         $t = get_markup_template( "admin.tpl", "addon/twitter/" );
864
865         $o = replace_macros($t, array(
866                 '$submit' => t('Submit'),
867                                                                 // name, label, value, help, [extra values]
868                 '$consumerkey' => array('consumerkey', t('Consumer key'),  get_config('twitter', 'consumerkey' ), ''),
869                 '$consumersecret' => array('consumersecret', t('Consumer secret'),  get_config('twitter', 'consumersecret' ), ''),
870                 '$applicationname' => array('applicationname', t('Name of the Twitter Application'), get_config('twitter','application_name'),t('set this to avoid mirroring postings from ~friendica back to ~friendica'))
871         ));
872 }
873
874 function twitter_cron($a,$b) {
875         $last = get_config('twitter','last_poll');
876
877         $poll_interval = intval(get_config('twitter','poll_interval'));
878         if(! $poll_interval)
879                 $poll_interval = TWITTER_DEFAULT_POLL_INTERVAL;
880
881         if($last) {
882                 $next = $last + ($poll_interval * 60);
883                 if($next > time()) {
884                         logger('twitter: poll intervall not reached');
885                         return;
886                 }
887         }
888         logger('twitter: cron_start');
889
890         $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'twitter' AND `k` = 'mirror_posts' AND `v` = '1' ORDER BY RAND()");
891         if(count($r)) {
892                 foreach($r as $rr) {
893                         logger('twitter: fetching for user '.$rr['uid']);
894                         twitter_fetchtimeline($a, $rr['uid']);
895                 }
896         }
897
898
899         $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'twitter' AND `k` = 'import' AND `v` = '1' ORDER BY RAND()");
900         if(count($r)) {
901                 foreach($r as $rr) {
902                         logger('twitter: importing timeline from user '.$rr['uid']);
903                         twitter_fetchhometimeline($a, $rr["uid"]);
904
905 /*
906                         // To-Do
907                         // check for new contacts once a day
908                         $last_contact_check = get_pconfig($rr['uid'],'pumpio','contact_check');
909                         if($last_contact_check)
910                                 $next_contact_check = $last_contact_check + 86400;
911                         else
912                                 $next_contact_check = 0;
913
914                         if($next_contact_check <= time()) {
915                                 pumpio_getallusers($a, $rr["uid"]);
916                                 set_pconfig($rr['uid'],'pumpio','contact_check',time());
917                         }
918 */
919
920                 }
921         }
922
923         logger('twitter: cron_end');
924
925         set_config('twitter','last_poll', time());
926 }
927
928 function twitter_fetchtimeline($a, $uid) {
929         $ckey    = get_config('twitter', 'consumerkey');
930         $csecret = get_config('twitter', 'consumersecret');
931         $otoken  = get_pconfig($uid, 'twitter', 'oauthtoken');
932         $osecret = get_pconfig($uid, 'twitter', 'oauthsecret');
933         $lastid  = get_pconfig($uid, 'twitter', 'lastid');
934
935         $application_name  = get_config('twitter', 'application_name');
936
937         if ($application_name == "")
938                 $application_name = $a->get_hostname();
939
940         require_once('mod/item.php');
941
942         require_once('library/twitteroauth.php');
943         $connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret);
944
945         $parameters = array("exclude_replies" => true, "trim_user" => false, "contributor_details" => true, "include_rts" => true);
946
947         $first_time = ($lastid == "");
948
949         if ($lastid <> "")
950                 $parameters["since_id"] = $lastid;
951
952         $items = $connection->get('statuses/user_timeline', $parameters);
953
954         if (!is_array($items))
955                 return;
956
957         $posts = array_reverse($items);
958
959         if (count($posts)) {
960             foreach ($posts as $post) {
961                 if ($post->id_str > $lastid)
962                         $lastid = $post->id_str;
963
964                 if ($first_time)
965                         continue;
966
967                 if (!strpos($post->source, $application_name)) {
968                         $_SESSION["authenticated"] = true;
969                         $_SESSION["uid"] = $uid;
970
971                         unset($_REQUEST);
972                         $_REQUEST["type"] = "wall";
973                         $_REQUEST["api_source"] = true;
974                         $_REQUEST["profile_uid"] = $uid;
975                         $_REQUEST["source"] = "Twitter";
976
977                         //$_REQUEST["date"] = $post->created_at;
978
979                         $_REQUEST["title"] = "";
980
981                         if (is_object($post->retweeted_status)) {
982
983                                 $_REQUEST['body'] = $post->retweeted_status->text;
984
985                                 // media
986                                 if (is_array($post->retweeted_status->entities->media)) {
987                                         foreach($post->retweeted_status->entities->media AS $media) {
988                                                 switch($media->type) {
989                                                         case 'photo':
990                                                                 $_REQUEST['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $_REQUEST['body']);
991                                                                 break;
992                                                 }
993                                         }
994                                 }
995
996                                 $converted = twitter_convertmsg($a, $_REQUEST['body'], true);
997                                 $_REQUEST['body'] = $converted["body"];
998
999                                 $_REQUEST['body'] = "[share author='".$post->retweeted_status->user->name.
1000                                         "' profile='https://twitter.com/".$post->retweeted_status->user->screen_name.
1001                                         "' avatar='".$post->retweeted_status->user->profile_image_url_https.
1002                                         "' link='https://twitter.com/".$post->retweeted_status->user->screen_name."/status/".$post->retweeted_status->id_str."']".
1003                                         $_REQUEST['body'];
1004                                 $_REQUEST['body'] .= "[/share]";
1005                         } else {
1006                                 $_REQUEST["body"] = $post->text;
1007
1008                                 if (is_array($post->entities->media)) {
1009                                         foreach($post->entities->media AS $media) {
1010                                                 switch($media->type) {
1011                                                         case 'photo':
1012                                                                 $_REQUEST['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $_REQUEST['body']);
1013                                                                 break;
1014                                                 }
1015                                         }
1016                                 }
1017
1018                                 $converted = twitter_convertmsg($a, $_REQUEST["body"], true);
1019                                 $_REQUEST['body'] = $converted["body"];
1020                         }
1021
1022                         if (is_string($post->place->name))
1023                                 $_REQUEST["location"] = $post->place->name;
1024
1025                         if (is_string($post->place->full_name))
1026                                 $_REQUEST["location"] = $post->place->full_name;
1027
1028                         if (is_array($post->geo->coordinates))
1029                                 $_REQUEST["coord"] = $post->geo->coordinates[0]." ".$post->geo->coordinates[1];
1030
1031                         if (is_array($post->coordinates->coordinates))
1032                                 $_REQUEST["coord"] = $post->coordinates->coordinates[1]." ".$post->coordinates->coordinates[0];
1033
1034                         //print_r($_REQUEST);
1035                         logger('twitter: posting for user '.$uid);
1036
1037 //                      require_once('mod/item.php');
1038
1039                         item_post($a);
1040                 }
1041             }
1042         }
1043         set_pconfig($uid, 'twitter', 'lastid', $lastid);
1044 }
1045
1046 function twitter_queue_hook(&$a,&$b) {
1047
1048         $qi = q("SELECT * FROM `queue` WHERE `network` = '%s'",
1049                 dbesc(NETWORK_TWITTER)
1050                 );
1051         if(! count($qi))
1052                 return;
1053
1054         require_once('include/queue_fn.php');
1055
1056         foreach($qi as $x) {
1057                 if($x['network'] !== NETWORK_TWITTER)
1058                         continue;
1059
1060                 logger('twitter_queue: run');
1061
1062                 $r = q("SELECT `user`.* FROM `user` LEFT JOIN `contact` on `contact`.`uid` = `user`.`uid` 
1063                         WHERE `contact`.`self` = 1 AND `contact`.`id` = %d LIMIT 1",
1064                         intval($x['cid'])
1065                 );
1066                 if(! count($r))
1067                         continue;
1068
1069                 $user = $r[0];
1070
1071                 $ckey    = get_config('twitter', 'consumerkey');
1072                 $csecret = get_config('twitter', 'consumersecret');
1073                 $otoken  = get_pconfig($user['uid'], 'twitter', 'oauthtoken');
1074                 $osecret = get_pconfig($user['uid'], 'twitter', 'oauthsecret');
1075
1076                 $success = false;
1077
1078                 if ($ckey AND $csecret AND $otoken AND $osecret) {
1079
1080                         logger('twitter_queue: able to post');
1081
1082                         $z = unserialize($x['content']);
1083
1084                         require_once("addon/twitter/codebird.php");
1085
1086                         $cb = \Codebird\Codebird::getInstance();
1087                         $cb->setConsumerKey($ckey, $csecret);
1088                         $cb->setToken($otoken, $osecret);
1089
1090                         if ($z['url'] == "statuses/update")
1091                                 $result = $cb->statuses_update($z['post']);
1092
1093                         logger('twitter_queue: post result: ' . print_r($result, true), LOGGER_DEBUG);
1094
1095                         if ($result->errors)
1096                                 logger('twitter_queue: Send to Twitter failed: "' . print_r($result->errors, true) . '"');
1097                         else {
1098                                 $success = true;
1099                                 remove_queue_item($x['id']);
1100                         }
1101                 } else
1102                         logger("twitter_queue: Error getting tokens for user ".$user['uid']);
1103
1104                 if (!$success) {
1105                         logger('twitter_queue: delayed');
1106                         update_queue_time($x['id']);
1107                 }
1108         }
1109 }
1110
1111 function twitter_fetch_contact($uid, $contact, $create_user) {
1112
1113         $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1",
1114                 intval($uid), dbesc("twitter::".$contact->id_str));
1115
1116         if(!count($r) AND !$create_user)
1117                 return(0);
1118
1119         if (count($r) AND ($r[0]["readonly"] OR $r[0]["blocked"])) {
1120                 logger("twitter_fetch_contact: Contact '".$r[0]["nick"]."' is blocked or readonly.", LOGGER_DEBUG);
1121                 return(-1);
1122         }
1123
1124         if(!count($r)) {
1125                 // create contact record
1126                 q("INSERT INTO `contact` ( `uid`, `created`, `url`, `nurl`, `addr`, `alias`, `notify`, `poll`,
1127                                         `name`, `nick`, `photo`, `network`, `rel`, `priority`,
1128                                         `writable`, `blocked`, `readonly`, `pending` )
1129                                         VALUES ( %d, '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', %d, %d, %d, 0, 0, 0 ) ",
1130                         intval($uid),
1131                         dbesc(datetime_convert()),
1132                         dbesc("https://twitter.com/".$contact->screen_name),
1133                         dbesc(normalise_link("https://twitter.com/".$contact->screen_name)),
1134                         dbesc($contact->screen_name."@twitter.com"),
1135                         dbesc("twitter::".$contact->id_str),
1136                         dbesc(''),
1137                         dbesc("twitter::".$contact->id_str),
1138                         dbesc($contact->name),
1139                         dbesc($contact->screen_name),
1140                         dbesc($contact->profile_image_url_https),
1141                         dbesc(NETWORK_TWITTER),
1142                         intval(CONTACT_IS_FRIEND),
1143                         intval(1),
1144                         intval(1)
1145                 );
1146
1147                 $r = q("SELECT * FROM `contact` WHERE `alias` = '%s' AND `uid` = %d LIMIT 1",
1148                         dbesc("twitter::".$contact->id_str),
1149                         intval($uid)
1150                         );
1151
1152                 if(! count($r))
1153                         return(false);
1154
1155                 $contact_id  = $r[0]['id'];
1156
1157                 $g = q("SELECT def_gid FROM user WHERE uid = %d LIMIT 1",
1158                         intval($uid)
1159                 );
1160
1161                 if($g && intval($g[0]['def_gid'])) {
1162                         require_once('include/group.php');
1163                         group_add_member($uid,'',$contact_id,$g[0]['def_gid']);
1164                 }
1165
1166                 require_once("Photo.php");
1167
1168                 $photos = import_profile_photo($contact->profile_image_url_https,$uid,$contact_id);
1169
1170                 q("UPDATE `contact` SET `photo` = '%s',
1171                                         `thumb` = '%s',
1172                                         `micro` = '%s',
1173                                         `name-date` = '%s',
1174                                         `uri-date` = '%s',
1175                                         `avatar-date` = '%s'
1176                                 WHERE `id` = %d",
1177                         dbesc($photos[0]),
1178                         dbesc($photos[1]),
1179                         dbesc($photos[2]),
1180                         dbesc(datetime_convert()),
1181                         dbesc(datetime_convert()),
1182                         dbesc(datetime_convert()),
1183                         intval($contact_id)
1184                 );
1185         } else {
1186                 // update profile photos once every two weeks as we have no notification of when they change.
1187
1188                 //$update_photo = (($r[0]['avatar-date'] < datetime_convert('','','now -2 days')) ? true : false);
1189                 $update_photo = ($r[0]['avatar-date'] < datetime_convert('','','now -12 hours'));
1190
1191                 // check that we have all the photos, this has been known to fail on occasion
1192
1193                 if((! $r[0]['photo']) || (! $r[0]['thumb']) || (! $r[0]['micro']) || ($update_photo)) {
1194
1195                         logger("twitter_fetch_contact: Updating contact ".$contact->screen_name, LOGGER_DEBUG);
1196
1197                         require_once("Photo.php");
1198
1199                         $photos = import_profile_photo($contact->profile_image_url_https, $uid, $r[0]['id']);
1200
1201                         q("UPDATE `contact` SET `photo` = '%s',
1202                                                 `thumb` = '%s',
1203                                                 `micro` = '%s',
1204                                                 `name-date` = '%s',
1205                                                 `uri-date` = '%s',
1206                                                 `avatar-date` = '%s',
1207                                                 `url` = '%s',
1208                                                 `nurl` = '%s',
1209                                                 `addr` = '%s',
1210                                                 `name` = '%s',
1211                                                 `nick` = '%s'
1212                                         WHERE `id` = %d",
1213                                 dbesc($photos[0]),
1214                                 dbesc($photos[1]),
1215                                 dbesc($photos[2]),
1216                                 dbesc(datetime_convert()),
1217                                 dbesc(datetime_convert()),
1218                                 dbesc(datetime_convert()),
1219                                 dbesc("https://twitter.com/".$contact->screen_name),
1220                                 dbesc(normalise_link("https://twitter.com/".$contact->screen_name)),
1221                                 dbesc($contact->screen_name."@twitter.com"),
1222                                 dbesc($contact->name),
1223                                 dbesc($contact->screen_name),
1224                                 intval($r[0]['id'])
1225                         );
1226                 }
1227         }
1228
1229         return($r[0]["id"]);
1230 }
1231
1232 function twitter_fetchuser($a, $uid, $screen_name = "", $user_id = "") {
1233         $ckey    = get_config('twitter', 'consumerkey');
1234         $csecret = get_config('twitter', 'consumersecret');
1235         $otoken  = get_pconfig($uid, 'twitter', 'oauthtoken');
1236         $osecret = get_pconfig($uid, 'twitter', 'oauthsecret');
1237
1238         require_once("addon/twitter/codebird.php");
1239
1240         $cb = \Codebird\Codebird::getInstance();
1241         $cb->setConsumerKey($ckey, $csecret);
1242         $cb->setToken($otoken, $osecret);
1243
1244         $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
1245                 intval($uid));
1246
1247         if(count($r)) {
1248                 $self = $r[0];
1249         } else
1250                 return;
1251
1252         $parameters = array();
1253
1254         if ($screen_name != "")
1255                 $parameters["screen_name"] = $screen_name;
1256
1257         if ($user_id != "")
1258                 $parameters["user_id"] = $user_id;
1259
1260         // Fetching user data
1261         $user = $cb->users_show($parameters);
1262
1263         if (!is_object($user))
1264                 return;
1265
1266         $contact_id = twitter_fetch_contact($uid, $user, true);
1267
1268         return $contact_id;
1269 }
1270
1271 function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing_contact) {
1272         $postarray = array();
1273         $postarray['gravity'] = 0;
1274         $postarray['uid'] = $uid;
1275         $postarray['wall'] = 0;
1276         $postarray['uri'] = "twitter::".$post->id_str;
1277
1278         $r = q("SELECT * FROM `item` WHERE `extid` = '%s' AND `uid` = %d LIMIT 1",
1279                         dbesc($postarray['uri']),
1280                         intval($uid)
1281                 );
1282
1283         if (count($r))
1284                 return(array());
1285
1286         $contactid = 0;
1287
1288         if ($post->in_reply_to_status_id_str != "") {
1289
1290                 $parent = "twitter::".$post->in_reply_to_status_id_str;
1291
1292                 $r = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
1293                                 dbesc($parent),
1294                                 intval($uid)
1295                         );
1296                 if (count($r)) {
1297                         $postarray['thr-parent'] = $r[0]["uri"];
1298                         $postarray['parent-uri'] = $r[0]["parent-uri"];
1299                 } else {
1300                         $r = q("SELECT * FROM `item` WHERE `extid` = '%s' AND `uid` = %d LIMIT 1",
1301                                         dbesc($parent),
1302                                         intval($uid)
1303                                 );
1304                         if (count($r)) {
1305                                 $postarray['thr-parent'] = $r[0]['uri'];
1306                                 $postarray['parent-uri'] = $r[0]['parent-uri'];
1307                         } else {
1308                                 $postarray['thr-parent'] = $postarray['uri'];
1309                                 $postarray['parent-uri'] = $postarray['uri'];
1310                         }
1311                 }
1312
1313                 // Is it me?
1314                 $own_id = get_pconfig($uid, 'twitter', 'own_id');
1315
1316                 if ($post->user->id_str == $own_id) {
1317                         $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
1318                                 intval($uid));
1319
1320                         if(count($r)) {
1321                                 $contactid = $r[0]["id"];
1322
1323                                 $postarray['owner-name'] =  $r[0]["name"];
1324                                 $postarray['owner-link'] = $r[0]["url"];
1325                                 $postarray['owner-avatar'] =  $r[0]["photo"];
1326                         } else
1327                                 return(array());
1328                 }
1329         } else
1330                 $postarray['parent-uri'] = $postarray['uri'];
1331
1332         if ($contactid == 0) {
1333                 $contactid = twitter_fetch_contact($uid, $post->user, $create_user);
1334
1335                 $postarray['owner-name'] = $post->user->name;
1336                 $postarray['owner-link'] = "https://twitter.com/".$post->user->screen_name;
1337                 $postarray['owner-avatar'] = $post->user->profile_image_url_https;
1338         }
1339
1340         if(($contactid == 0) AND !$only_existing_contact)
1341                 $contactid = $self['id'];
1342         elseif ($contactid <= 0)
1343                 return(array());
1344
1345         $postarray['contact-id'] = $contactid;
1346
1347         $postarray['verb'] = ACTIVITY_POST;
1348         $postarray['author-name'] = $postarray['owner-name'];
1349         $postarray['author-link'] = $postarray['owner-link'];
1350         $postarray['author-avatar'] = $postarray['owner-avatar'];
1351         $postarray['plink'] = "https://twitter.com/".$post->user->screen_name."/status/".$post->id_str;
1352         $postarray['app'] = strip_tags($post->source);
1353
1354         if ($post->user->protected) {
1355                 $postarray['private'] = 1;
1356                 $postarray['allow_cid'] = '<' . $self['id'] . '>';
1357         }
1358
1359         $postarray['body'] = $post->text;
1360
1361         // media
1362         if (is_array($post->entities->media)) {
1363                 foreach($post->entities->media AS $media) {
1364                         switch($media->type) {
1365                                 case 'photo':
1366                                         $postarray['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $postarray['body']);
1367                                         break;
1368                                 default:
1369                                         $postarray['body'] .= print_r($media, true);
1370                         }
1371                 }
1372         }
1373
1374         $converted = twitter_convertmsg($a, $postarray['body']);
1375         $postarray['body'] = $converted["body"];
1376         $postarray['tag'] = $converted["tags"];
1377
1378         $postarray['created'] = datetime_convert('UTC','UTC',$post->created_at);
1379         $postarray['edited'] = datetime_convert('UTC','UTC',$post->created_at);
1380
1381         if (is_string($post->place->name))
1382                 $postarray["location"] = $post->place->name;
1383
1384         if (is_string($post->place->full_name))
1385                 $postarray["location"] = $post->place->full_name;
1386
1387         if (is_array($post->geo->coordinates))
1388                 $postarray["coord"] = $post->geo->coordinates[0]." ".$post->geo->coordinates[1];
1389
1390         if (is_array($post->coordinates->coordinates))
1391                 $postarray["coord"] = $post->coordinates->coordinates[1]." ".$post->coordinates->coordinates[0];
1392
1393         if (is_object($post->retweeted_status)) {
1394
1395                 $postarray['body'] = $post->retweeted_status->text;
1396
1397                 // media
1398                 if (is_array($post->retweeted_status->entities->media)) {
1399                         foreach($post->retweeted_status->entities->media AS $media) {
1400                                 switch($media->type) {
1401                                         case 'photo':
1402                                                 $postarray['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $postarray['body']);
1403                                                 break;
1404                                         default:
1405                                                 $postarray['body'] .= print_r($media, true);
1406                                 }
1407                         }
1408                 }
1409
1410                 $converted = twitter_convertmsg($a, $postarray['body']);
1411                 $postarray['body'] = $converted["body"];
1412                 $postarray['tag'] = $converted["tags"];
1413
1414
1415                 // Deactivated at the moment, since there are problems with answers to retweets
1416                 if (false AND !intval(get_config('system','wall-to-wall_share'))) {
1417                         $postarray['body'] = "[share author='".$post->retweeted_status->user->name.
1418                                 "' profile='https://twitter.com/".$post->retweeted_status->user->screen_name.
1419                                 "' avatar='".$post->retweeted_status->user->profile_image_url_https.
1420                                 "' link='https://twitter.com/".$post->retweeted_status->user->screen_name."/status/".$post->retweeted_status->id_str."']".
1421                                 $postarray['body'];
1422                         $postarray['body'] .= "[/share]";
1423                 } else {
1424                         // Let retweets look like wall-to-wall posts
1425                         $postarray['author-name'] = $post->retweeted_status->user->name;
1426                         $postarray['author-link'] = "https://twitter.com/".$post->retweeted_status->user->screen_name;
1427                         $postarray['author-avatar'] = $post->retweeted_status->user->profile_image_url_https;
1428                 }
1429
1430         }
1431         return($postarray);
1432 }
1433
1434 function twitter_checknotification($a, $uid, $own_id, $top_item, $postarray) {
1435
1436         $user = q("SELECT * FROM `contact` WHERE `uid` = %d AND `self` LIMIT 1",
1437                         intval($uid)
1438                 );
1439
1440         if(!count($user))
1441                 return;
1442
1443         // Is it me?
1444         if (link_compare($user[0]["url"], $postarray['author-link']))
1445                 return;
1446
1447         $own_user = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1",
1448                         intval($uid),
1449                         dbesc("twitter::".$own_id)
1450                 );
1451
1452         if(!count($own_user))
1453                 return;
1454
1455         // Is it me from twitter?
1456         if (link_compare($own_user[0]["url"], $postarray['author-link']))
1457                 return;
1458
1459         $myconv = q("SELECT `author-link`, `author-avatar`, `parent` FROM `item` WHERE `parent-uri` = '%s' AND `uid` = %d AND `parent` != 0 AND `deleted` = 0",
1460                         dbesc($postarray['parent-uri']),
1461                         intval($uid)
1462                         );
1463
1464         if(count($myconv)) {
1465
1466                 foreach($myconv as $conv) {
1467                         // now if we find a match, it means we're in this conversation
1468
1469                         if(!link_compare($conv['author-link'],$user[0]["url"]) AND !link_compare($conv['author-link'],$own_user[0]["url"]))
1470                                 continue;
1471
1472                         require_once('include/enotify.php');
1473
1474                         $conv_parent = $conv['parent'];
1475
1476                         notification(array(
1477                                 'type'         => NOTIFY_COMMENT,
1478                                 'notify_flags' => $user[0]['notify-flags'],
1479                                 'language'     => $user[0]['language'],
1480                                 'to_name'      => $user[0]['username'],
1481                                 'to_email'     => $user[0]['email'],
1482                                 'uid'          => $user[0]['uid'],
1483                                 'item'         => $postarray,
1484                                 'link'             => $a->get_baseurl() . '/display/' . $user[0]['nickname'] . '/' . $top_item,
1485                                 'source_name'  => $postarray['author-name'],
1486                                 'source_link'  => $postarray['author-link'],
1487                                 'source_photo' => $postarray['author-avatar'],
1488                                 'verb'         => ACTIVITY_POST,
1489                                 'otype'        => 'item',
1490                                 'parent'       => $conv_parent,
1491                         ));
1492
1493                         // only send one notification
1494                         break;
1495                 }
1496         }
1497 }
1498
1499 function twitter_fetchhometimeline($a, $uid) {
1500         $ckey    = get_config('twitter', 'consumerkey');
1501         $csecret = get_config('twitter', 'consumersecret');
1502         $otoken  = get_pconfig($uid, 'twitter', 'oauthtoken');
1503         $osecret = get_pconfig($uid, 'twitter', 'oauthsecret');
1504         $create_user = get_pconfig($uid, 'twitter', 'create_user');
1505
1506         logger("twitter_fetchhometimeline: Fetching for user ".$uid, LOGGER_DEBUG);
1507
1508         require_once('library/twitteroauth.php');
1509         require_once('include/items.php');
1510
1511         $connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret);
1512
1513         $own_contact = twitter_fetch_own_contact($a, $uid);
1514
1515         $r = q("SELECT * FROM `contact` WHERE `id` = %d AND `uid` = %d LIMIT 1",
1516                 intval($own_contact),
1517                 intval($uid));
1518
1519         if(count($r)) {
1520                 $own_id = $r[0]["nick"];
1521         } else {
1522                 logger("twitter_fetchhometimeline: Own twitter contact not found for user ".$uid, LOGGER_DEBUG);
1523                 return;
1524         }
1525
1526         $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
1527                 intval($uid));
1528
1529         if(count($r)) {
1530                 $self = $r[0];
1531         } else {
1532                 logger("twitter_fetchhometimeline: Own contact not found for user ".$uid, LOGGER_DEBUG);
1533                 return;
1534         }
1535
1536         $u = q("SELECT * FROM user WHERE uid = %d LIMIT 1",
1537                 intval($uid));
1538         if(!count($u)) {
1539                 logger("twitter_fetchhometimeline: Own user not found for user ".$uid, LOGGER_DEBUG);
1540                 return;
1541         }
1542
1543         $parameters = array("exclude_replies" => false, "trim_user" => false, "contributor_details" => true, "include_rts" => true);
1544         //$parameters["count"] = 200;
1545
1546
1547         // Fetching timeline
1548         $lastid  = get_pconfig($uid, 'twitter', 'lasthometimelineid');
1549
1550         $first_time = ($lastid == "");
1551
1552         if ($lastid <> "")
1553                 $parameters["since_id"] = $lastid;
1554
1555         $items = $connection->get('statuses/home_timeline', $parameters);
1556
1557         if (!is_array($items)) {
1558                 logger("twitter_fetchhometimeline: Error fetching home timeline: ".print_r($items, true), LOGGER_DEBUG);
1559                 return;
1560         }
1561
1562         $posts = array_reverse($items);
1563
1564         logger("twitter_fetchhometimeline: Fetching timeline for user ".$uid." ".sizeof($posts)." items", LOGGER_DEBUG);
1565
1566         if (count($posts)) {
1567                 foreach ($posts as $post) {
1568                         if ($post->id_str > $lastid)
1569                                 $lastid = $post->id_str;
1570
1571                         if ($first_time)
1572                                 continue;
1573
1574                         $postarray = twitter_createpost($a, $uid, $post, $self, $create_user, true);
1575
1576                         if (trim($postarray['body']) == "")
1577                                 continue;
1578
1579                         $item = item_store($postarray);
1580
1581                         logger('twitter_fetchhometimeline: User '.$self["nick"].' posted home timeline item '.$item);
1582
1583                         if ($item != 0)
1584                                 twitter_checknotification($a, $uid, $own_id, $item, $postarray);
1585
1586                 }
1587         }
1588         set_pconfig($uid, 'twitter', 'lasthometimelineid', $lastid);
1589
1590         // Fetching mentions
1591         $lastid  = get_pconfig($uid, 'twitter', 'lastmentionid');
1592
1593         $first_time = ($lastid == "");
1594
1595         if ($lastid <> "")
1596                 $parameters["since_id"] = $lastid;
1597
1598         $items = $connection->get('statuses/mentions_timeline', $parameters);
1599
1600         if (!is_array($items)) {
1601                 logger("twitter_fetchhometimeline: Error fetching mentions: ".print_r($items, true), LOGGER_DEBUG);
1602                 return;
1603         }
1604
1605         $posts = array_reverse($items);
1606
1607         logger("twitter_fetchhometimeline: Fetching mentions for user ".$uid." ".sizeof($posts)." items", LOGGER_DEBUG);
1608
1609         if (count($posts)) {
1610                 foreach ($posts as $post) {
1611                         if ($post->id_str > $lastid)
1612                                 $lastid = $post->id_str;
1613
1614                         if ($first_time)
1615                                 continue;
1616
1617                         $postarray = twitter_createpost($a, $uid, $post, $self, false, false);
1618
1619                         if (trim($postarray['body']) == "")
1620                                 continue;
1621
1622                         $item = item_store($postarray);
1623
1624                         logger('twitter_fetchhometimeline: User '.$self["nick"].' posted mention timeline item '.$item);
1625
1626                         if ($item == 0) {
1627                                 $r = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
1628                                         dbesc($postarray['uri']),
1629                                         intval($uid)
1630                                 );
1631                                 if (count($r))
1632                                         $item = $r[0]['id'];
1633                         }
1634
1635                         if ($item != 0) {
1636                                 require_once('include/enotify.php');
1637                                 notification(array(
1638                                         'type'         => NOTIFY_TAGSELF,
1639                                         'notify_flags' => $u[0]['notify-flags'],
1640                                         'language'     => $u[0]['language'],
1641                                         'to_name'      => $u[0]['username'],
1642                                         'to_email'     => $u[0]['email'],
1643                                         'uid'          => $u[0]['uid'],
1644                                         'item'         => $postarray,
1645                                         'link'         => $a->get_baseurl() . '/display/' . $u[0]['nickname'] . '/' . $item,
1646                                         'source_name'  => $postarray['author-name'],
1647                                         'source_link'  => $postarray['author-link'],
1648                                         'source_photo' => $postarray['author-avatar'],
1649                                         'verb'         => ACTIVITY_TAG,
1650                                         'otype'        => 'item'
1651                                 ));
1652                         }
1653                 }
1654         }
1655
1656         set_pconfig($uid, 'twitter', 'lastmentionid', $lastid);
1657 }
1658
1659 function twitter_original_url($url, $depth=1, $fetchbody = false) {
1660         if ($depth > 10)
1661                 return($url);
1662
1663         $siteinfo = array();
1664         $ch = curl_init();
1665         curl_setopt($ch, CURLOPT_URL, $url);
1666         curl_setopt($ch, CURLOPT_HEADER, 1);
1667
1668         if ($fetchbody)
1669                 curl_setopt($ch, CURLOPT_NOBODY, 0);
1670         else
1671                 curl_setopt($ch, CURLOPT_NOBODY, 1);
1672
1673         curl_setopt($ch, CURLOPT_TIMEOUT, 10);
1674         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
1675         curl_setopt($ch,CURLOPT_USERAGENT,'Mozilla/5.0 (Macintosh; Intel Mac OS X 10.8; rv:24.0) Gecko/20100101 Firefox/24.0');
1676
1677         $header = curl_exec($ch);
1678         $curl_info = @curl_getinfo($ch);
1679         $http_code = $curl_info['http_code'];
1680         curl_close($ch);
1681
1682         if ((($curl_info['http_code'] == "301") OR ($curl_info['http_code'] == "302"))
1683                 AND (($curl_info['redirect_url'] != "") OR ($curl_info['location'] != ""))) {
1684                 if ($curl_info['redirect_url'] != "")
1685                         return(twitter_original_url($curl_info['redirect_url'], ++$depth, $fetchbody));
1686                 else
1687                         return(twitter_original_url($curl_info['location'], ++$depth, $fetchbody));
1688         }
1689
1690         $pos = strpos($header, "\r\n\r\n");
1691
1692         if ($pos)
1693                 $body = trim(substr($header, $pos));
1694         else
1695                 $body = $header;
1696
1697         if (trim($body) == "")
1698                 return(twitter_original_url($url, ++$depth, true));
1699
1700         $doc = new DOMDocument();
1701         @$doc->loadHTML($body);
1702
1703         $xpath = new DomXPath($doc);
1704
1705         $list = $xpath->query("//meta[@content]");
1706         foreach ($list as $node) {
1707                 $attr = array();
1708                 if ($node->attributes->length)
1709                         foreach ($node->attributes as $attribute)
1710                                 $attr[$attribute->name] = $attribute->value;
1711
1712                 if (@$attr["http-equiv"] == 'refresh') {
1713                         $path = $attr["content"];
1714                         $pathinfo = explode(";", $path);
1715                         $content = "";
1716                         foreach ($pathinfo AS $value)
1717                                 if (substr(strtolower($value), 0, 4) == "url=")
1718                                         return(twitter_original_url(substr($value, 4), ++$depth));
1719                 }
1720         }
1721
1722         return($url);
1723 }
1724
1725 function twitter_siteinfo($url) {
1726         require_once("mod/parse_url.php");
1727
1728         $data = parseurl_getsiteinfo($url);
1729
1730         if (!is_string($data["text"]) AND (sizeof($data["images"]) == 0) AND ($data["title"] == $url))
1731                 return("");
1732
1733         if (is_string($data["title"]))
1734                 $text .= "[bookmark=".$url."]".trim($data["title"])."[/bookmark]\n";
1735
1736         if (sizeof($data["images"]) > 0) {
1737                 $imagedata = $data["images"][0];
1738                 $text .= '[img='.$imagedata["width"].'x'.$imagedata["height"].']'.$imagedata["src"].'[/img]' . "\n";
1739         }
1740
1741         if (is_string($data["text"]))
1742                 $text .= "[quote]".$data["text"]."[/quote]";
1743
1744         return($text);
1745
1746 }
1747
1748 function twitter_convertmsg($a, $body, $no_tags = false) {
1749
1750         $links = preg_match_all("/([^\]\='".'"'."]|^)(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)/ism", $body,$matches,PREG_SET_ORDER);
1751
1752         $footer = "";
1753
1754         if ($links) {
1755                 foreach ($matches AS $match) {
1756                         $expanded_url = twitter_original_url($match[2]);
1757
1758                         // To-Do:
1759                         // Twitlonger
1760
1761                         if (strstr($expanded_url, "//www.youtube.com/"))
1762                                 $body = str_replace($match[2], "\n[youtube]".$expanded_url."[/youtube]\n", $body);
1763                         elseif (strstr($expanded_url, "//player.vimeo.com/"))
1764                                 $body = str_replace($match[2], "\n[vimeo]".$expanded_url."[/vimeo]\n", $body);
1765                         elseif (strstr($expanded_url, "//instagram.com"))
1766                                 $body = str_replace($match[2], "\n[url]".$expanded_url."[/url]\n", $body);
1767                         else {
1768                                 $img_str = fetch_url($expanded_url, true, $redirects, 4);
1769
1770                                 $tempfile = tempnam(get_config("system","temppath"), "cache");
1771                                 file_put_contents($tempfile, $img_str);
1772                                 $mime = image_type_to_mime_type(exif_imagetype($tempfile));
1773                                 unlink($tempfile);
1774
1775                                 if (substr($mime, 0, 6) == "image/")
1776                                         $body = str_replace($match[2], "[img]".$expanded_url."[/img]", $body);
1777                                 else {
1778
1779                                         //if ($footer == "")
1780                                         $footer = "\n\n".twitter_siteinfo($expanded_url);
1781                                         $footerlink = "[url=".$expanded_url."]".$expanded_url."[/url]";
1782
1783                                         $body = str_replace($match[2], $footerlink, $body);
1784                                 }
1785                         }
1786                 }
1787
1788                 if (($footerlink != "") AND ($footer != "")) {
1789                         $removedlink = trim(str_replace($footerlink, "", $body));
1790
1791                         if (strstr($body, $removedlink))
1792                                 $body = $removedlink;
1793
1794                         $body .= $footer;
1795                 }
1796         }
1797
1798         if ($no_tags)
1799                 return(array("body" => $body, $tags => ""));
1800
1801         $str_tags = '';
1802
1803         $tags = get_tags($body);
1804
1805         if(count($tags)) {
1806                 foreach($tags as $tag) {
1807                         if (strstr(trim($tag), " "))
1808                                 continue;
1809
1810                         if(strpos($tag,'#') === 0) {
1811                                 if(strpos($tag,'[url='))
1812                                         continue;
1813
1814                                 // don't link tags that are already embedded in links
1815
1816                                 if(preg_match('/\[(.*?)' . preg_quote($tag,'/') . '(.*?)\]/',$body))
1817                                         continue;
1818                                 if(preg_match('/\[(.*?)\]\((.*?)' . preg_quote($tag,'/') . '(.*?)\)/',$body))
1819                                         continue;
1820
1821                                 $basetag = str_replace('_',' ',substr($tag,1));
1822                                 $body = str_replace($tag,'#[url=' . $a->get_baseurl() . '/search?tag=' . rawurlencode($basetag) . ']' . $basetag . '[/url]',$body);
1823                                 if(strlen($str_tags))
1824                                         $str_tags .= ',';
1825                                 $str_tags .= '#[url=' . $a->get_baseurl() . '/search?tag=' . rawurlencode($basetag) . ']' . $basetag . '[/url]';
1826                                 continue;
1827                         } elseif(strpos($tag,'@') === 0) {
1828                                 $basetag = substr($tag,1);
1829                                 $body = str_replace($tag,'@[url=https://twitter.com/' . rawurlencode($basetag) . ']' . $basetag . '[/url]',$body);
1830                         }
1831
1832                 }
1833         }
1834
1835         $cnt = preg_match_all('/@\[url=(.*?)\[\/url\]/ism',$body,$matches,PREG_SET_ORDER);
1836         if($cnt) {
1837                 foreach($matches as $mtch) {
1838                         if(strlen($str_tags))
1839                                 $str_tags .= ',';
1840                         $str_tags .= '@[url=' . $mtch[1] . '[/url]';
1841                 }
1842         }
1843
1844         return(array("body"=>$body, "tags"=>$str_tags));
1845
1846 }
1847
1848 function twitter_fetch_own_contact($a, $uid) {
1849         $ckey    = get_config('twitter', 'consumerkey');
1850         $csecret = get_config('twitter', 'consumersecret');
1851         $otoken  = get_pconfig($uid, 'twitter', 'oauthtoken');
1852         $osecret = get_pconfig($uid, 'twitter', 'oauthsecret');
1853
1854         $own_id = get_pconfig($uid, 'twitter', 'own_id');
1855
1856         $contact_id = 0;
1857
1858         if ($own_id == "") {
1859                 require_once('library/twitteroauth.php');
1860
1861                 $connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret);
1862
1863                 // Fetching user data
1864                 $user = $connection->get('account/verify_credentials');
1865
1866                 set_pconfig($uid, 'twitter', 'own_id', $user->id_str);
1867
1868                 $contact_id = twitter_fetch_contact($uid, $user, true);
1869
1870         } else {
1871                 $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1",
1872                         intval($uid), dbesc("twitter::".$own_id));
1873                 if(count($r))
1874                         $contact_id = $r[0]["id"];
1875         }
1876
1877         return($contact_id);
1878 }
1879 ?>