forked from friendica/friendica-addons
Merge pull request #157 from annando/master
Bidirectional twitter sync - and some small fixes
This commit is contained in:
commit
14676e5b0d
7 changed files with 1041 additions and 35 deletions
|
|
@ -202,7 +202,7 @@ function appnetpost_original_url($url, $depth=1) {
|
||||||
curl_setopt($ch, CURLOPT_NOBODY, 0);
|
curl_setopt($ch, CURLOPT_NOBODY, 0);
|
||||||
curl_setopt($ch, CURLOPT_TIMEOUT, 3);
|
curl_setopt($ch, CURLOPT_TIMEOUT, 3);
|
||||||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
||||||
curl_setopt($ch,CURLOPT_USERAGENT,'Opera/9.64(Windows NT 5.1; U; de) Presto/2.1.1');
|
curl_setopt($ch,CURLOPT_USERAGENT,'Mozilla/5.0 (Macintosh; Intel Mac OS X 10.8; rv:24.0) Gecko/20100101 Firefox/24.0');
|
||||||
|
|
||||||
$header = curl_exec($ch);
|
$header = curl_exec($ch);
|
||||||
$curl_info = @curl_getinfo($ch);
|
$curl_info = @curl_getinfo($ch);
|
||||||
|
|
|
||||||
|
|
@ -304,6 +304,9 @@ function fromgplus_handleattachments($item, $displaytext) {
|
||||||
function fromgplus_fetch($a, $uid) {
|
function fromgplus_fetch($a, $uid) {
|
||||||
$maxfetch = 20;
|
$maxfetch = 20;
|
||||||
|
|
||||||
|
// Special blank to identify postings from the googleplus connector
|
||||||
|
$blank = html_entity_decode(" ", ENT_QUOTES, 'UTF-8');
|
||||||
|
|
||||||
$account = get_pconfig($uid,'fromgplus','account');
|
$account = get_pconfig($uid,'fromgplus','account');
|
||||||
$key = get_config('fromgplus','key');
|
$key = get_config('fromgplus','key');
|
||||||
|
|
||||||
|
|
@ -330,6 +333,15 @@ function fromgplus_fetch($a, $uid) {
|
||||||
$lastdate = strtotime($item->published);
|
$lastdate = strtotime($item->published);
|
||||||
|
|
||||||
if ($item->access->description == "Public")
|
if ($item->access->description == "Public")
|
||||||
|
|
||||||
|
// Loop prevention - ignore postings from HootSuite
|
||||||
|
if ($item->provider->title == "HootSuite")
|
||||||
|
continue;
|
||||||
|
|
||||||
|
// Loop prevention through the special blank from the googleplus connector
|
||||||
|
if (strstr($item->object->content, $blank))
|
||||||
|
continue;
|
||||||
|
|
||||||
switch($item->object->objectType) {
|
switch($item->object->objectType) {
|
||||||
case "note":
|
case "note":
|
||||||
$post = fromgplus_html2bbcode($item->object->content);
|
$post = fromgplus_html2bbcode($item->object->content);
|
||||||
|
|
@ -343,9 +355,7 @@ function fromgplus_fetch($a, $uid) {
|
||||||
else
|
else
|
||||||
$location = "";
|
$location = "";
|
||||||
|
|
||||||
// Loop prevention - should be made better
|
fromgplus_post($a, $uid, "Google+", $post, $location);
|
||||||
if ($item->provider->title != "HootSuite")
|
|
||||||
fromgplus_post($a, $uid, "Google+", $post, $location);
|
|
||||||
//fromgplus_post($a, $uid, $item->provider->title, $post, $location);
|
//fromgplus_post($a, $uid, $item->provider->title, $post, $location);
|
||||||
|
|
||||||
break;
|
break;
|
||||||
|
|
@ -353,7 +363,7 @@ function fromgplus_fetch($a, $uid) {
|
||||||
case "activity":
|
case "activity":
|
||||||
$post = fromgplus_html2bbcode($item->annotation)."\n";
|
$post = fromgplus_html2bbcode($item->annotation)."\n";
|
||||||
|
|
||||||
if (intval(get_config('system','new_share'))) {
|
if (!intval(get_config('system','old_share'))) {
|
||||||
$post .= "[share author='".str_replace("'", "'",$item->object->actor->displayName).
|
$post .= "[share author='".str_replace("'", "'",$item->object->actor->displayName).
|
||||||
"' profile='".$item->object->actor->url.
|
"' profile='".$item->object->actor->url.
|
||||||
"' avatar='".$item->object->actor->image->url.
|
"' avatar='".$item->object->actor->image->url.
|
||||||
|
|
@ -379,9 +389,7 @@ function fromgplus_fetch($a, $uid) {
|
||||||
else
|
else
|
||||||
$location = "";
|
$location = "";
|
||||||
|
|
||||||
// Loop prevention - should be made better
|
fromgplus_post($a, $uid, "Google+", $post, $location);
|
||||||
if ($item->provider->title != "HootSuite")
|
|
||||||
fromgplus_post($a, $uid, "Google+", $post, $location);
|
|
||||||
//fromgplus_post($a, $uid, $item->provider->title, $post, $location);
|
//fromgplus_post($a, $uid, $item->provider->title, $post, $location);
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -220,7 +220,7 @@ function gpluspost_original_url($url, $depth=1) {
|
||||||
curl_setopt($ch, CURLOPT_NOBODY, 0);
|
curl_setopt($ch, CURLOPT_NOBODY, 0);
|
||||||
curl_setopt($ch, CURLOPT_TIMEOUT, 3);
|
curl_setopt($ch, CURLOPT_TIMEOUT, 3);
|
||||||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
||||||
curl_setopt($ch,CURLOPT_USERAGENT,'Opera/9.64(Windows NT 5.1; U; de) Presto/2.1.1');
|
curl_setopt($ch,CURLOPT_USERAGENT,'Mozilla/5.0 (Macintosh; Intel Mac OS X 10.8; rv:24.0) Gecko/20100101 Firefox/24.0');
|
||||||
|
|
||||||
$header = curl_exec($ch);
|
$header = curl_exec($ch);
|
||||||
$curl_info = @curl_getinfo($ch);
|
$curl_info = @curl_getinfo($ch);
|
||||||
|
|
|
||||||
|
|
@ -484,7 +484,7 @@ function pumpio_send(&$a,&$b) {
|
||||||
logger('pumpio_send '.$username.': success '.$post_id);
|
logger('pumpio_send '.$username.': success '.$post_id);
|
||||||
if($post_id AND $iscomment) {
|
if($post_id AND $iscomment) {
|
||||||
logger('pumpio_send '.$username.': Update extid '.$post_id." for post id ".$b['id']);
|
logger('pumpio_send '.$username.': Update extid '.$post_id." for post id ".$b['id']);
|
||||||
q("UPDATE `item` SET `extid` = '%s' WHERE `id` = %d LIMIT 1",
|
q("UPDATE `item` SET `extid` = '%s' WHERE `id` = %d",
|
||||||
dbesc($post_id),
|
dbesc($post_id),
|
||||||
intval($b['id'])
|
intval($b['id'])
|
||||||
);
|
);
|
||||||
|
|
@ -925,7 +925,7 @@ function pumpio_get_contact($uid, $contact) {
|
||||||
`name-date` = '%s',
|
`name-date` = '%s',
|
||||||
`uri-date` = '%s',
|
`uri-date` = '%s',
|
||||||
`avatar-date` = '%s'
|
`avatar-date` = '%s'
|
||||||
WHERE `id` = %d LIMIT 1
|
WHERE `id` = %d
|
||||||
",
|
",
|
||||||
dbesc($photos[0]),
|
dbesc($photos[0]),
|
||||||
dbesc($photos[1]),
|
dbesc($photos[1]),
|
||||||
|
|
@ -952,8 +952,10 @@ function pumpio_get_contact($uid, $contact) {
|
||||||
`micro` = '%s',
|
`micro` = '%s',
|
||||||
`name-date` = '%s',
|
`name-date` = '%s',
|
||||||
`uri-date` = '%s',
|
`uri-date` = '%s',
|
||||||
`avatar-date` = '%s'
|
`avatar-date` = '%s',
|
||||||
WHERE `id` = %d LIMIT 1
|
`name` = '%s',
|
||||||
|
`nick` = '%s'
|
||||||
|
WHERE `id` = %d
|
||||||
",
|
",
|
||||||
dbesc($photos[0]),
|
dbesc($photos[0]),
|
||||||
dbesc($photos[1]),
|
dbesc($photos[1]),
|
||||||
|
|
@ -961,6 +963,8 @@ function pumpio_get_contact($uid, $contact) {
|
||||||
dbesc(datetime_convert()),
|
dbesc(datetime_convert()),
|
||||||
dbesc(datetime_convert()),
|
dbesc(datetime_convert()),
|
||||||
dbesc(datetime_convert()),
|
dbesc(datetime_convert()),
|
||||||
|
dbesc($contact->displayName),
|
||||||
|
dbesc($contact->preferredUsername),
|
||||||
intval($r[0]['id'])
|
intval($r[0]['id'])
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
|
@ -1129,10 +1133,17 @@ function pumpio_dopost(&$a, $client, $uid, $self, $post, $own_id, $threadcomplet
|
||||||
}
|
}
|
||||||
|
|
||||||
if ($post->verb == "share") {
|
if ($post->verb == "share") {
|
||||||
$postarray['body'] = "[share author='".$post->object->author->displayName.
|
if (!intval(get_config('system','wall-to-wall_share'))) {
|
||||||
"' profile='".$post->object->author->url.
|
$postarray['body'] = "[share author='".$post->object->author->displayName.
|
||||||
"' avatar='".$post->object->author->image->url.
|
"' profile='".$post->object->author->url.
|
||||||
"' link='".$post->links->self->href."']".$postarray['body']."[/share]";
|
"' avatar='".$post->object->author->image->url.
|
||||||
|
"' link='".$post->links->self->href."']".$postarray['body']."[/share]";
|
||||||
|
} else {
|
||||||
|
// Let shares look like wall-to-wall posts
|
||||||
|
$postarray['author-name'] = $post->object->author->displayName;
|
||||||
|
$postarray['author-link'] = $post->object->author->url;
|
||||||
|
$postarray['author-avatar'] = $post->object->author->image->url;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (trim($postarray['body']) == "")
|
if (trim($postarray['body']) == "")
|
||||||
|
|
@ -1350,7 +1361,7 @@ function pumpio_queue_hook(&$a,&$b) {
|
||||||
logger('pumpio_queue: send '.$username.': success '.$post_id);
|
logger('pumpio_queue: send '.$username.': success '.$post_id);
|
||||||
if($post_id AND $iscomment) {
|
if($post_id AND $iscomment) {
|
||||||
logger('pumpio_send '.$username.': Update extid '.$post_id." for post id ".$z['item']);
|
logger('pumpio_send '.$username.': Update extid '.$post_id." for post id ".$z['item']);
|
||||||
q("UPDATE `item` SET `extid` = '%s' WHERE `id` = %d LIMIT 1",
|
q("UPDATE `item` SET `extid` = '%s' WHERE `id` = %d",
|
||||||
dbesc($post_id),
|
dbesc($post_id),
|
||||||
intval($z['item'])
|
intval($z['item'])
|
||||||
);
|
);
|
||||||
|
|
|
||||||
|
|
@ -548,7 +548,7 @@ function statusnet_shortenmsg($b, $max_char) {
|
||||||
$msglink = $b["plink"];
|
$msglink = $b["plink"];
|
||||||
|
|
||||||
// If the message is short enough then don't modify it. (if the link exists in the original message)
|
// If the message is short enough then don't modify it. (if the link exists in the original message)
|
||||||
if ((strlen(trim($origmsg)) <= $max_char) AND (strpos($origmsg, $msglink) OR ($msglink == "")))
|
if ((strlen(trim($origmsg)) <= $max_char) AND (($msglink == "") OR strpos($origmsg, $msglink)))
|
||||||
return(array("msg"=>trim($origmsg), "image"=>""));
|
return(array("msg"=>trim($origmsg), "image"=>""));
|
||||||
|
|
||||||
// If the message is short enough and contains a picture then post the picture as well
|
// If the message is short enough and contains a picture then post the picture as well
|
||||||
|
|
|
||||||
|
|
@ -24,6 +24,8 @@
|
||||||
#twitter-enable-label,
|
#twitter-enable-label,
|
||||||
#twitter-shortening-label,
|
#twitter-shortening-label,
|
||||||
#twitter-mirror-label,
|
#twitter-mirror-label,
|
||||||
|
#twitter-import-label,
|
||||||
|
#twitter-create_user-label,
|
||||||
#twitter-pin-label {
|
#twitter-pin-label {
|
||||||
float: left;
|
float: left;
|
||||||
width: 250px;
|
width: 250px;
|
||||||
|
|
|
||||||
1017
twitter/twitter.php
1017
twitter/twitter.php
|
|
@ -71,6 +71,7 @@ function twitter_install() {
|
||||||
register_hook('jot_networks', 'addon/twitter/twitter.php', 'twitter_jot_nets');
|
register_hook('jot_networks', 'addon/twitter/twitter.php', 'twitter_jot_nets');
|
||||||
register_hook('cron', 'addon/twitter/twitter.php', 'twitter_cron');
|
register_hook('cron', 'addon/twitter/twitter.php', 'twitter_cron');
|
||||||
register_hook('queue_predeliver', 'addon/twitter/twitter.php', 'twitter_queue_hook');
|
register_hook('queue_predeliver', 'addon/twitter/twitter.php', 'twitter_queue_hook');
|
||||||
|
register_hook('follow', 'addon/twitter/twitter.php', 'twitter_follow');
|
||||||
logger("installed twitter");
|
logger("installed twitter");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -91,6 +92,45 @@ function twitter_uninstall() {
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function twitter_follow($a, &$contact) {
|
||||||
|
|
||||||
|
logger("twitter_follow: Check if contact is twitter contact. ".$contact["url"], LOGGER_DEBUG);
|
||||||
|
|
||||||
|
if (!strstr($contact["url"], "://twitter.com") AND !strstr($contact["url"], "@twitter.com"))
|
||||||
|
return;
|
||||||
|
|
||||||
|
// contact seems to be a twitter contact, so continue
|
||||||
|
$nickname = preg_replace("=https?://twitter.com/(.*)=ism", "$1", $contact["url"]);
|
||||||
|
$nickname = str_replace("@twitter.com", "", $nickname);
|
||||||
|
|
||||||
|
$uid = $a->user["uid"];
|
||||||
|
|
||||||
|
$ckey = get_config('twitter', 'consumerkey');
|
||||||
|
$csecret = get_config('twitter', 'consumersecret');
|
||||||
|
$otoken = get_pconfig($uid, 'twitter', 'oauthtoken');
|
||||||
|
$osecret = get_pconfig($uid, 'twitter', 'oauthsecret');
|
||||||
|
|
||||||
|
require_once("addon/twitter/codebird.php");
|
||||||
|
|
||||||
|
$cb = \Codebird\Codebird::getInstance();
|
||||||
|
$cb->setConsumerKey($ckey, $csecret);
|
||||||
|
$cb->setToken($otoken, $osecret);
|
||||||
|
|
||||||
|
$parameters = array();
|
||||||
|
$parameters["screen_name"] = $nickname;
|
||||||
|
|
||||||
|
$user = $cb->friendships_create($parameters);
|
||||||
|
|
||||||
|
twitter_fetchuser($a, $uid, $nickname);
|
||||||
|
|
||||||
|
$r = q("SELECT name,nick,url,addr,batch,notify,poll,request,confirm,poco,photo,priority,network,alias,pubkey
|
||||||
|
FROM `contact` WHERE `uid` = %d AND `nick` = '%s'",
|
||||||
|
intval($uid),
|
||||||
|
dbesc($nickname));
|
||||||
|
if (count($r))
|
||||||
|
$contact["contact"] = $r[0];
|
||||||
|
}
|
||||||
|
|
||||||
function twitter_jot_nets(&$a,&$b) {
|
function twitter_jot_nets(&$a,&$b) {
|
||||||
if(! local_user())
|
if(! local_user())
|
||||||
return;
|
return;
|
||||||
|
|
@ -107,9 +147,10 @@ function twitter_jot_nets(&$a,&$b) {
|
||||||
function twitter_settings_post ($a,$post) {
|
function twitter_settings_post ($a,$post) {
|
||||||
if(! local_user())
|
if(! local_user())
|
||||||
return;
|
return;
|
||||||
// don't check twitter settings if twitter submit button is not clicked
|
// don't check twitter settings if twitter submit button is not clicked
|
||||||
if (!x($_POST,'twitter-submit')) return;
|
if (!x($_POST,'twitter-submit'))
|
||||||
|
return;
|
||||||
|
|
||||||
if (isset($_POST['twitter-disconnect'])) {
|
if (isset($_POST['twitter-disconnect'])) {
|
||||||
/***
|
/***
|
||||||
* if the twitter-disconnect checkbox is set, clear the OAuth key/secret pair
|
* if the twitter-disconnect checkbox is set, clear the OAuth key/secret pair
|
||||||
|
|
@ -125,6 +166,8 @@ function twitter_settings_post ($a,$post) {
|
||||||
del_pconfig(local_user(), 'twitter', 'lastid');
|
del_pconfig(local_user(), 'twitter', 'lastid');
|
||||||
del_pconfig(local_user(), 'twitter', 'mirror_posts');
|
del_pconfig(local_user(), 'twitter', 'mirror_posts');
|
||||||
del_pconfig(local_user(), 'twitter', 'intelligent_shortening');
|
del_pconfig(local_user(), 'twitter', 'intelligent_shortening');
|
||||||
|
del_pconfig(local_user(), 'twitter', 'import');
|
||||||
|
del_pconfig(local_user(), 'twitter', 'create_user');
|
||||||
} else {
|
} else {
|
||||||
if (isset($_POST['twitter-pin'])) {
|
if (isset($_POST['twitter-pin'])) {
|
||||||
// if the user supplied us with a PIN from Twitter, let the magic of OAuth happen
|
// if the user supplied us with a PIN from Twitter, let the magic of OAuth happen
|
||||||
|
|
@ -152,6 +195,8 @@ function twitter_settings_post ($a,$post) {
|
||||||
set_pconfig(local_user(),'twitter','post_taglinks',intval($_POST['twitter-sendtaglinks']));
|
set_pconfig(local_user(),'twitter','post_taglinks',intval($_POST['twitter-sendtaglinks']));
|
||||||
set_pconfig(local_user(), 'twitter', 'mirror_posts', intval($_POST['twitter-mirror']));
|
set_pconfig(local_user(), 'twitter', 'mirror_posts', intval($_POST['twitter-mirror']));
|
||||||
set_pconfig(local_user(), 'twitter', 'intelligent_shortening', intval($_POST['twitter-shortening']));
|
set_pconfig(local_user(), 'twitter', 'intelligent_shortening', intval($_POST['twitter-shortening']));
|
||||||
|
set_pconfig(local_user(), 'twitter', 'import', intval($_POST['twitter-import']));
|
||||||
|
set_pconfig(local_user(), 'twitter', 'create_user', intval($_POST['twitter-create_user']));
|
||||||
info( t('Twitter settings updated.') . EOL);
|
info( t('Twitter settings updated.') . EOL);
|
||||||
}}
|
}}
|
||||||
}
|
}
|
||||||
|
|
@ -178,6 +223,10 @@ function twitter_settings(&$a,&$s) {
|
||||||
$mirrorchecked = (($mirrorenabled) ? ' checked="checked" ' : '');
|
$mirrorchecked = (($mirrorenabled) ? ' checked="checked" ' : '');
|
||||||
$shorteningenabled = get_pconfig(local_user(),'twitter','intelligent_shortening');
|
$shorteningenabled = get_pconfig(local_user(),'twitter','intelligent_shortening');
|
||||||
$shorteningchecked = (($shorteningenabled) ? ' checked="checked" ' : '');
|
$shorteningchecked = (($shorteningenabled) ? ' checked="checked" ' : '');
|
||||||
|
$importenabled = get_pconfig(local_user(),'twitter','import');
|
||||||
|
$importchecked = (($importenabled) ? ' checked="checked" ' : '');
|
||||||
|
$create_userenabled = get_pconfig(local_user(),'twitter','create_user');
|
||||||
|
$create_userchecked = (($create_userenabled) ? ' checked="checked" ' : '');
|
||||||
|
|
||||||
$s .= '<div class="settings-block">';
|
$s .= '<div class="settings-block">';
|
||||||
$s .= '<h3>'. t('Twitter Posting Settings') .'</h3>';
|
$s .= '<h3>'. t('Twitter Posting Settings') .'</h3>';
|
||||||
|
|
@ -236,7 +285,7 @@ function twitter_settings(&$a,&$s) {
|
||||||
$s .= '<input id="twitter-default" type="checkbox" name="twitter-default" value="1" ' . $defchecked . '/>';
|
$s .= '<input id="twitter-default" type="checkbox" name="twitter-default" value="1" ' . $defchecked . '/>';
|
||||||
$s .= '<div class="clear"></div>';
|
$s .= '<div class="clear"></div>';
|
||||||
|
|
||||||
$s .= '<label id="twitter-mirror-label" for="twitter-mirror">'.t('Mirror all posts from twitter that are no replies or retweets').'</label>';
|
$s .= '<label id="twitter-mirror-label" for="twitter-mirror">'.t('Mirror all posts from twitter that are no replies').'</label>';
|
||||||
$s .= '<input id="twitter-mirror" type="checkbox" name="twitter-mirror" value="1" '. $mirrorchecked . '/>';
|
$s .= '<input id="twitter-mirror" type="checkbox" name="twitter-mirror" value="1" '. $mirrorchecked . '/>';
|
||||||
$s .= '<div class="clear"></div>';
|
$s .= '<div class="clear"></div>';
|
||||||
|
|
||||||
|
|
@ -248,6 +297,14 @@ function twitter_settings(&$a,&$s) {
|
||||||
$s .= '<input id="twitter-sendtaglinks" type="checkbox" name="twitter-sendtaglinks" value="1" '. $linkschecked . '/>';
|
$s .= '<input id="twitter-sendtaglinks" type="checkbox" name="twitter-sendtaglinks" value="1" '. $linkschecked . '/>';
|
||||||
$s .= '</div><div class="clear"></div>';
|
$s .= '</div><div class="clear"></div>';
|
||||||
|
|
||||||
|
$s .= '<label id="twitter-import-label" for="twitter-import">'.t('Import the remote timeline').'</label>';
|
||||||
|
$s .= '<input id="twitter-import" type="checkbox" name="twitter-import" value="1" '. $importchecked . '/>';
|
||||||
|
$s .= '<div class="clear"></div>';
|
||||||
|
|
||||||
|
$s .= '<label id="twitter-create_user-label" for="twitter-create_user">'.t('Automatically create contacts').'</label>';
|
||||||
|
$s .= '<input id="twitter-create_user" type="checkbox" name="twitter-create_user" value="1" '. $create_userchecked . '/>';
|
||||||
|
$s .= '<div class="clear"></div>';
|
||||||
|
|
||||||
$s .= '<div id="twitter-disconnect-wrapper">';
|
$s .= '<div id="twitter-disconnect-wrapper">';
|
||||||
$s .= '<label id="twitter-disconnect-label" for="twitter-disconnect">'. t('Clear OAuth configuration') .'</label>';
|
$s .= '<label id="twitter-disconnect-label" for="twitter-disconnect">'. t('Clear OAuth configuration') .'</label>';
|
||||||
$s .= '<input id="twitter-disconnect" type="checkbox" name="twitter-disconnect" value="1" />';
|
$s .= '<input id="twitter-disconnect" type="checkbox" name="twitter-disconnect" value="1" />';
|
||||||
|
|
@ -506,20 +563,94 @@ function twitter_shortenmsg($b, $shortlink = false) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function twitter_action($a, $uid, $pid, $action) {
|
||||||
|
|
||||||
|
$ckey = get_config('twitter', 'consumerkey');
|
||||||
|
$csecret = get_config('twitter', 'consumersecret');
|
||||||
|
$otoken = get_pconfig($uid, 'twitter', 'oauthtoken');
|
||||||
|
$osecret = get_pconfig($uid, 'twitter', 'oauthsecret');
|
||||||
|
|
||||||
|
require_once("addon/twitter/codebird.php");
|
||||||
|
|
||||||
|
$cb = \Codebird\Codebird::getInstance();
|
||||||
|
$cb->setConsumerKey($ckey, $csecret);
|
||||||
|
$cb->setToken($otoken, $osecret);
|
||||||
|
|
||||||
|
$post = array('id' => $pid);
|
||||||
|
|
||||||
|
logger("twitter_action '".$action."' ID: ".$pid." data: " . print_r($post, true), LOGGER_DATA);
|
||||||
|
|
||||||
|
switch ($action) {
|
||||||
|
case "delete":
|
||||||
|
$result = $cb->statuses_destroy($post);
|
||||||
|
break;
|
||||||
|
case "like":
|
||||||
|
$result = $cb->favorites_create($post);
|
||||||
|
break;
|
||||||
|
case "unlike":
|
||||||
|
$result = $cb->favorites_destroy($post);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
logger("twitter_action '".$action."' send, result: " . print_r($result, true), LOGGER_DEBUG);
|
||||||
|
}
|
||||||
|
|
||||||
function twitter_post_hook(&$a,&$b) {
|
function twitter_post_hook(&$a,&$b) {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Post to Twitter
|
* Post to Twitter
|
||||||
*/
|
*/
|
||||||
|
|
||||||
if($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited']))
|
if (!get_pconfig($b["uid"],'twitter','import')) {
|
||||||
return;
|
if($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited']))
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
if(! strstr($b['postopts'],'twitter'))
|
if($b['parent'] != $b['id']) {
|
||||||
return;
|
logger("twitter_post_hook: parameter ".print_r($b, true), LOGGER_DATA);
|
||||||
|
|
||||||
if($b['parent'] != $b['id'])
|
// Looking if its a reply to a twitter post
|
||||||
|
if ((substr($b["parent-uri"], 0, 9) != "twitter::") AND (substr($b["extid"], 0, 9) != "twitter::") AND (substr($b["thr-parent"], 0, 9) != "twitter::")) {
|
||||||
|
logger("twitter_post_hook: no twitter post ".$b["parent"]);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
$r = q("SELECT * FROM item WHERE item.uri = '%s' AND item.uid = %d LIMIT 1",
|
||||||
|
dbesc($b["thr-parent"]),
|
||||||
|
intval($b["uid"]));
|
||||||
|
|
||||||
|
if(!count($r)) {
|
||||||
|
logger("twitter_post_hook: no parent found ".$b["thr-parent"]);
|
||||||
|
return;
|
||||||
|
} else {
|
||||||
|
$iscomment = true;
|
||||||
|
$orig_post = $r[0];
|
||||||
|
}
|
||||||
|
|
||||||
|
// To-Do: Ab dem letzten / nehmen
|
||||||
|
$b["body"] = "@".substr($orig_post["author-link"], 20)." ".$b["body"];
|
||||||
|
|
||||||
|
logger("twitter_post_hook: parent found ".print_r($orig_post, true), LOGGER_DATA);
|
||||||
|
} else {
|
||||||
|
$iscomment = false;
|
||||||
|
|
||||||
|
if($b['private'] OR !strstr($b['postopts'],'twitter'))
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (($b['verb'] == ACTIVITY_POST) AND $b['deleted'])
|
||||||
|
twitter_action($a, $b["uid"], substr($orig_post["uri"], 9), "delete");
|
||||||
|
|
||||||
|
if($b['verb'] == ACTIVITY_LIKE) {
|
||||||
|
logger("twitter_post_hook: parameter 2 ".substr($b["thr-parent"], 9), LOGGER_DEBUG);
|
||||||
|
if ($b['deleted'])
|
||||||
|
twitter_action($a, $b["uid"], substr($b["thr-parent"], 9), "unlike");
|
||||||
|
else
|
||||||
|
twitter_action($a, $b["uid"], substr($b["thr-parent"], 9), "like");
|
||||||
return;
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if($b['deleted'] || ($b['created'] !== $b['edited']))
|
||||||
|
return;
|
||||||
|
|
||||||
// if post comes from twitter don't send it back
|
// if post comes from twitter don't send it back
|
||||||
if($b['app'] == "Twitter")
|
if($b['app'] == "Twitter")
|
||||||
|
|
@ -646,7 +777,13 @@ function twitter_post_hook(&$a,&$b) {
|
||||||
$cb = \Codebird\Codebird::getInstance();
|
$cb = \Codebird\Codebird::getInstance();
|
||||||
$cb->setConsumerKey($ckey, $csecret);
|
$cb->setConsumerKey($ckey, $csecret);
|
||||||
$cb->setToken($otoken, $osecret);
|
$cb->setToken($otoken, $osecret);
|
||||||
$result = $cb->statuses_updateWithMedia(array('status' => $msg, 'media[]' => $tempfile));
|
|
||||||
|
$post = array('status' => $msg, 'media[]' => $tempfile);
|
||||||
|
|
||||||
|
if ($iscomment)
|
||||||
|
$post["in_reply_to_status_id"] = substr($orig_post["uri"], 9);
|
||||||
|
|
||||||
|
$result = $cb->statuses_updateWithMedia($post);
|
||||||
unlink($tempfile);
|
unlink($tempfile);
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
|
@ -666,18 +803,29 @@ function twitter_post_hook(&$a,&$b) {
|
||||||
// Workaround: Remove the picture link so that the post can be reposted without it
|
// Workaround: Remove the picture link so that the post can be reposted without it
|
||||||
$msg .= " ".$image;
|
$msg .= " ".$image;
|
||||||
$image = "";
|
$image = "";
|
||||||
|
} elseif ($iscomment) {
|
||||||
|
logger('twitter_post: Update extid '.$result->id_str." for post id ".$b['id']);
|
||||||
|
q("UPDATE `item` SET `extid` = '%s', `body` = '%s' WHERE `id` = %d",
|
||||||
|
dbesc("twitter::".$result->id_str),
|
||||||
|
dbesc($result->text),
|
||||||
|
intval($b['id'])
|
||||||
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if(strlen($msg) and ($image == "")) {
|
if(strlen($msg) and ($image == "")) {
|
||||||
$url = 'statuses/update';
|
$url = 'statuses/update';
|
||||||
$post = array('status' => $msg);
|
$post = array('status' => $msg);
|
||||||
|
|
||||||
|
if ($iscomment)
|
||||||
|
$post["in_reply_to_status_id"] = substr($orig_post["uri"], 9);
|
||||||
|
|
||||||
$result = $tweet->post($url, $post);
|
$result = $tweet->post($url, $post);
|
||||||
logger('twitter_post send, result: ' . print_r($result, true), LOGGER_DEBUG);
|
logger('twitter_post send, result: ' . print_r($result, true), LOGGER_DEBUG);
|
||||||
if ($result->errors) {
|
if ($result->errors) {
|
||||||
logger('Send to Twitter failed: "' . print_r($result->errors, true) . '"');
|
logger('Send to Twitter failed: "' . print_r($result->errors, true) . '"');
|
||||||
|
|
||||||
$r = q("SELECT `id` FROM `contact` WHERE `uid` = %d AND `self`", $b['uid']);
|
$r = q("SELECT `id` FROM `contact` WHERE `uid` = %d AND `self`", intval($b['uid']));
|
||||||
if (count($r))
|
if (count($r))
|
||||||
$a->contact = $r[0]["id"];
|
$a->contact = $r[0]["id"];
|
||||||
|
|
||||||
|
|
@ -685,6 +833,17 @@ function twitter_post_hook(&$a,&$b) {
|
||||||
require_once('include/queue_fn.php');
|
require_once('include/queue_fn.php');
|
||||||
add_to_queue($a->contact,NETWORK_TWITTER,$s);
|
add_to_queue($a->contact,NETWORK_TWITTER,$s);
|
||||||
notice(t('Twitter post failed. Queued for retry.').EOL);
|
notice(t('Twitter post failed. Queued for retry.').EOL);
|
||||||
|
} elseif ($iscomment) {
|
||||||
|
logger('twitter_post: Update extid '.$result->id_str." for post id ".$b['id']);
|
||||||
|
q("UPDATE `item` SET `extid` = '%s' WHERE `id` = %d",
|
||||||
|
dbesc("twitter::".$result->id_str),
|
||||||
|
intval($b['id'])
|
||||||
|
);
|
||||||
|
//q("UPDATE `item` SET `extid` = '%s', `body` = '%s' WHERE `id` = %d",
|
||||||
|
// dbesc("twitter::".$result->id_str),
|
||||||
|
// dbesc($result->text),
|
||||||
|
// intval($b['id'])
|
||||||
|
//);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
@ -727,7 +886,7 @@ function twitter_cron($a,$b) {
|
||||||
}
|
}
|
||||||
logger('twitter: cron_start');
|
logger('twitter: cron_start');
|
||||||
|
|
||||||
$r = q("SELECT * FROM `pconfig` WHERE `cat` = 'twitter' AND `k` = 'mirror_posts' AND `v` = '1' ORDER BY RAND() ");
|
$r = q("SELECT * FROM `pconfig` WHERE `cat` = 'twitter' AND `k` = 'mirror_posts' AND `v` = '1' ORDER BY RAND()");
|
||||||
if(count($r)) {
|
if(count($r)) {
|
||||||
foreach($r as $rr) {
|
foreach($r as $rr) {
|
||||||
logger('twitter: fetching for user '.$rr['uid']);
|
logger('twitter: fetching for user '.$rr['uid']);
|
||||||
|
|
@ -735,6 +894,31 @@ function twitter_cron($a,$b) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
$r = q("SELECT * FROM `pconfig` WHERE `cat` = 'twitter' AND `k` = 'import' AND `v` = '1' ORDER BY RAND()");
|
||||||
|
if(count($r)) {
|
||||||
|
foreach($r as $rr) {
|
||||||
|
logger('twitter: importing timeline from user '.$rr['uid']);
|
||||||
|
twitter_fetchhometimeline($a, $rr["uid"]);
|
||||||
|
|
||||||
|
/*
|
||||||
|
// To-Do
|
||||||
|
// check for new contacts once a day
|
||||||
|
$last_contact_check = get_pconfig($rr['uid'],'pumpio','contact_check');
|
||||||
|
if($last_contact_check)
|
||||||
|
$next_contact_check = $last_contact_check + 86400;
|
||||||
|
else
|
||||||
|
$next_contact_check = 0;
|
||||||
|
|
||||||
|
if($next_contact_check <= time()) {
|
||||||
|
pumpio_getallusers($a, $rr["uid"]);
|
||||||
|
set_pconfig($rr['uid'],'pumpio','contact_check',time());
|
||||||
|
}
|
||||||
|
*/
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
logger('twitter: cron_end');
|
logger('twitter: cron_end');
|
||||||
|
|
||||||
set_config('twitter','last_poll', time());
|
set_config('twitter','last_poll', time());
|
||||||
|
|
@ -752,10 +936,12 @@ function twitter_fetchtimeline($a, $uid) {
|
||||||
if ($application_name == "")
|
if ($application_name == "")
|
||||||
$application_name = $a->get_hostname();
|
$application_name = $a->get_hostname();
|
||||||
|
|
||||||
|
require_once('mod/item.php');
|
||||||
|
|
||||||
require_once('library/twitteroauth.php');
|
require_once('library/twitteroauth.php');
|
||||||
$connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret);
|
$connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret);
|
||||||
|
|
||||||
$parameters = array("exclude_replies" => true, "trim_user" => true, "contributor_details" => false, "include_rts" => false);
|
$parameters = array("exclude_replies" => true, "trim_user" => false, "contributor_details" => true, "include_rts" => true);
|
||||||
|
|
||||||
$first_time = ($lastid == "");
|
$first_time = ($lastid == "");
|
||||||
|
|
||||||
|
|
@ -791,7 +977,47 @@ function twitter_fetchtimeline($a, $uid) {
|
||||||
|
|
||||||
$_REQUEST["title"] = "";
|
$_REQUEST["title"] = "";
|
||||||
|
|
||||||
$_REQUEST["body"] = $post->text;
|
if (is_object($post->retweeted_status)) {
|
||||||
|
|
||||||
|
$_REQUEST['body'] = $post->retweeted_status->text;
|
||||||
|
|
||||||
|
// media
|
||||||
|
if (is_array($post->retweeted_status->entities->media)) {
|
||||||
|
foreach($post->retweeted_status->entities->media AS $media) {
|
||||||
|
switch($media->type) {
|
||||||
|
case 'photo':
|
||||||
|
$_REQUEST['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $_REQUEST['body']);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$converted = twitter_convertmsg($a, $_REQUEST['body'], true);
|
||||||
|
$_REQUEST['body'] = $converted["body"];
|
||||||
|
|
||||||
|
$_REQUEST['body'] = "[share author='".$post->retweeted_status->user->name.
|
||||||
|
"' profile='https://twitter.com/".$post->retweeted_status->user->screen_name.
|
||||||
|
"' avatar='".$post->retweeted_status->user->profile_image_url_https.
|
||||||
|
"' link='https://twitter.com/".$post->retweeted_status->user->screen_name."/status/".$post->retweeted_status->id_str."']".
|
||||||
|
$_REQUEST['body'];
|
||||||
|
$_REQUEST['body'] .= "[/share]";
|
||||||
|
} else {
|
||||||
|
$_REQUEST["body"] = $post->text;
|
||||||
|
|
||||||
|
if (is_array($post->entities->media)) {
|
||||||
|
foreach($post->entities->media AS $media) {
|
||||||
|
switch($media->type) {
|
||||||
|
case 'photo':
|
||||||
|
$_REQUEST['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $_REQUEST['body']);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$converted = twitter_convertmsg($a, $_REQUEST["body"], true);
|
||||||
|
$_REQUEST['body'] = $converted["body"];
|
||||||
|
}
|
||||||
|
|
||||||
if (is_string($post->place->name))
|
if (is_string($post->place->name))
|
||||||
$_REQUEST["location"] = $post->place->name;
|
$_REQUEST["location"] = $post->place->name;
|
||||||
|
|
||||||
|
|
@ -807,9 +1033,9 @@ function twitter_fetchtimeline($a, $uid) {
|
||||||
//print_r($_REQUEST);
|
//print_r($_REQUEST);
|
||||||
logger('twitter: posting for user '.$uid);
|
logger('twitter: posting for user '.$uid);
|
||||||
|
|
||||||
require_once('mod/item.php');
|
// require_once('mod/item.php');
|
||||||
item_post($a);
|
|
||||||
|
|
||||||
|
item_post($a);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
@ -880,3 +1106,762 @@ function twitter_queue_hook(&$a,&$b) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function twitter_fetch_contact($uid, $contact, $create_user) {
|
||||||
|
|
||||||
|
$r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1",
|
||||||
|
intval($uid), dbesc("twitter::".$contact->id_str));
|
||||||
|
|
||||||
|
if(!count($r) AND !$create_user)
|
||||||
|
return(0);
|
||||||
|
|
||||||
|
if (count($r) AND ($r[0]["readonly"] OR $r[0]["blocked"])) {
|
||||||
|
logger("twitter_fetch_contact: Contact '".$r[0]["nick"]."' is blocked or readonly.", LOGGER_DEBUG);
|
||||||
|
return(-1);
|
||||||
|
}
|
||||||
|
|
||||||
|
if(!count($r)) {
|
||||||
|
// create contact record
|
||||||
|
q("INSERT INTO `contact` ( `uid`, `created`, `url`, `nurl`, `addr`, `alias`, `notify`, `poll`,
|
||||||
|
`name`, `nick`, `photo`, `network`, `rel`, `priority`,
|
||||||
|
`writable`, `blocked`, `readonly`, `pending` )
|
||||||
|
VALUES ( %d, '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', %d, %d, %d, 0, 0, 0 ) ",
|
||||||
|
intval($uid),
|
||||||
|
dbesc(datetime_convert()),
|
||||||
|
dbesc("https://twitter.com/".$contact->screen_name),
|
||||||
|
dbesc(normalise_link("https://twitter.com/".$contact->screen_name)),
|
||||||
|
dbesc($contact->screen_name."@twitter.com"),
|
||||||
|
dbesc("twitter::".$contact->id_str),
|
||||||
|
dbesc(''),
|
||||||
|
dbesc("twitter::".$contact->id_str),
|
||||||
|
dbesc($contact->name),
|
||||||
|
dbesc($contact->screen_name),
|
||||||
|
dbesc($contact->profile_image_url_https),
|
||||||
|
dbesc(NETWORK_TWITTER),
|
||||||
|
intval(CONTACT_IS_FRIEND),
|
||||||
|
intval(1),
|
||||||
|
intval(1)
|
||||||
|
);
|
||||||
|
|
||||||
|
$r = q("SELECT * FROM `contact` WHERE `alias` = '%s' AND `uid` = %d LIMIT 1",
|
||||||
|
dbesc("twitter::".$contact->id_str),
|
||||||
|
intval($uid)
|
||||||
|
);
|
||||||
|
|
||||||
|
if(! count($r))
|
||||||
|
return(false);
|
||||||
|
|
||||||
|
$contact_id = $r[0]['id'];
|
||||||
|
|
||||||
|
$g = q("SELECT def_gid FROM user WHERE uid = %d LIMIT 1",
|
||||||
|
intval($uid)
|
||||||
|
);
|
||||||
|
|
||||||
|
if($g && intval($g[0]['def_gid'])) {
|
||||||
|
require_once('include/group.php');
|
||||||
|
group_add_member($uid,'',$contact_id,$g[0]['def_gid']);
|
||||||
|
}
|
||||||
|
|
||||||
|
require_once("Photo.php");
|
||||||
|
|
||||||
|
$photos = import_profile_photo($contact->profile_image_url_https,$uid,$contact_id);
|
||||||
|
|
||||||
|
q("UPDATE `contact` SET `photo` = '%s',
|
||||||
|
`thumb` = '%s',
|
||||||
|
`micro` = '%s',
|
||||||
|
`name-date` = '%s',
|
||||||
|
`uri-date` = '%s',
|
||||||
|
`avatar-date` = '%s'
|
||||||
|
WHERE `id` = %d",
|
||||||
|
dbesc($photos[0]),
|
||||||
|
dbesc($photos[1]),
|
||||||
|
dbesc($photos[2]),
|
||||||
|
dbesc(datetime_convert()),
|
||||||
|
dbesc(datetime_convert()),
|
||||||
|
dbesc(datetime_convert()),
|
||||||
|
intval($contact_id)
|
||||||
|
);
|
||||||
|
} else {
|
||||||
|
// update profile photos once every two weeks as we have no notification of when they change.
|
||||||
|
|
||||||
|
//$update_photo = (($r[0]['avatar-date'] < datetime_convert('','','now -2 days')) ? true : false);
|
||||||
|
$update_photo = ($r[0]['avatar-date'] < datetime_convert('','','now -12 hours'));
|
||||||
|
|
||||||
|
// check that we have all the photos, this has been known to fail on occasion
|
||||||
|
|
||||||
|
if((! $r[0]['photo']) || (! $r[0]['thumb']) || (! $r[0]['micro']) || ($update_photo)) {
|
||||||
|
|
||||||
|
logger("twitter_fetch_contact: Updating contact ".$contact->screen_name, LOGGER_DEBUG);
|
||||||
|
|
||||||
|
require_once("Photo.php");
|
||||||
|
|
||||||
|
$photos = import_profile_photo($contact->profile_image_url_https, $uid, $r[0]['id']);
|
||||||
|
|
||||||
|
q("UPDATE `contact` SET `photo` = '%s',
|
||||||
|
`thumb` = '%s',
|
||||||
|
`micro` = '%s',
|
||||||
|
`name-date` = '%s',
|
||||||
|
`uri-date` = '%s',
|
||||||
|
`avatar-date` = '%s',
|
||||||
|
`url` = '%s',
|
||||||
|
`nurl` = '%s',
|
||||||
|
`addr` = '%s',
|
||||||
|
`name` = '%s',
|
||||||
|
`nick` = '%s'
|
||||||
|
WHERE `id` = %d",
|
||||||
|
dbesc($photos[0]),
|
||||||
|
dbesc($photos[1]),
|
||||||
|
dbesc($photos[2]),
|
||||||
|
dbesc(datetime_convert()),
|
||||||
|
dbesc(datetime_convert()),
|
||||||
|
dbesc(datetime_convert()),
|
||||||
|
dbesc("https://twitter.com/".$contact->screen_name),
|
||||||
|
dbesc(normalise_link("https://twitter.com/".$contact->screen_name)),
|
||||||
|
dbesc($contact->screen_name."@twitter.com"),
|
||||||
|
dbesc($contact->name),
|
||||||
|
dbesc($contact->screen_name),
|
||||||
|
intval($r[0]['id'])
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return($r[0]["id"]);
|
||||||
|
}
|
||||||
|
|
||||||
|
function twitter_fetchuser($a, $uid, $screen_name = "", $user_id = "") {
|
||||||
|
$ckey = get_config('twitter', 'consumerkey');
|
||||||
|
$csecret = get_config('twitter', 'consumersecret');
|
||||||
|
$otoken = get_pconfig($uid, 'twitter', 'oauthtoken');
|
||||||
|
$osecret = get_pconfig($uid, 'twitter', 'oauthsecret');
|
||||||
|
|
||||||
|
require_once("addon/twitter/codebird.php");
|
||||||
|
|
||||||
|
$cb = \Codebird\Codebird::getInstance();
|
||||||
|
$cb->setConsumerKey($ckey, $csecret);
|
||||||
|
$cb->setToken($otoken, $osecret);
|
||||||
|
|
||||||
|
$r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
|
||||||
|
intval($uid));
|
||||||
|
|
||||||
|
if(count($r)) {
|
||||||
|
$self = $r[0];
|
||||||
|
} else
|
||||||
|
return;
|
||||||
|
|
||||||
|
$parameters = array();
|
||||||
|
|
||||||
|
if ($screen_name != "")
|
||||||
|
$parameters["screen_name"] = $screen_name;
|
||||||
|
|
||||||
|
if ($user_id != "")
|
||||||
|
$parameters["user_id"] = $user_id;
|
||||||
|
|
||||||
|
// Fetching user data
|
||||||
|
$user = $cb->users_show($parameters);
|
||||||
|
|
||||||
|
if (!is_object($user))
|
||||||
|
return;
|
||||||
|
|
||||||
|
$contact_id = twitter_fetch_contact($uid, $user, true);
|
||||||
|
|
||||||
|
return $contact_id;
|
||||||
|
}
|
||||||
|
|
||||||
|
function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing_contact) {
|
||||||
|
$postarray = array();
|
||||||
|
$postarray['gravity'] = 0;
|
||||||
|
$postarray['uid'] = $uid;
|
||||||
|
$postarray['wall'] = 0;
|
||||||
|
$postarray['uri'] = "twitter::".$post->id_str;
|
||||||
|
|
||||||
|
$r = q("SELECT * FROM `item` WHERE `extid` = '%s' AND `uid` = %d LIMIT 1",
|
||||||
|
dbesc($postarray['uri']),
|
||||||
|
intval($uid)
|
||||||
|
);
|
||||||
|
|
||||||
|
if (count($r))
|
||||||
|
return(array());
|
||||||
|
|
||||||
|
$contactid = 0;
|
||||||
|
|
||||||
|
if ($post->in_reply_to_status_id_str != "") {
|
||||||
|
|
||||||
|
$parent = "twitter::".$post->in_reply_to_status_id_str;
|
||||||
|
|
||||||
|
$r = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
|
||||||
|
dbesc($parent),
|
||||||
|
intval($uid)
|
||||||
|
);
|
||||||
|
if (count($r)) {
|
||||||
|
$postarray['thr-parent'] = $r[0]["uri"];
|
||||||
|
$postarray['parent-uri'] = $r[0]["parent-uri"];
|
||||||
|
} else {
|
||||||
|
$r = q("SELECT * FROM `item` WHERE `extid` = '%s' AND `uid` = %d LIMIT 1",
|
||||||
|
dbesc($parent),
|
||||||
|
intval($uid)
|
||||||
|
);
|
||||||
|
if (count($r)) {
|
||||||
|
$postarray['thr-parent'] = $r[0]['uri'];
|
||||||
|
$postarray['parent-uri'] = $r[0]['parent-uri'];
|
||||||
|
} else {
|
||||||
|
$postarray['thr-parent'] = $postarray['uri'];
|
||||||
|
$postarray['parent-uri'] = $postarray['uri'];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Is it me?
|
||||||
|
$own_id = get_pconfig($uid, 'twitter', 'own_id');
|
||||||
|
|
||||||
|
if ($post->user->id_str == $own_id) {
|
||||||
|
$r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
|
||||||
|
intval($uid));
|
||||||
|
|
||||||
|
if(count($r)) {
|
||||||
|
$contactid = $r[0]["id"];
|
||||||
|
|
||||||
|
$postarray['owner-name'] = $r[0]["name"];
|
||||||
|
$postarray['owner-link'] = $r[0]["url"];
|
||||||
|
$postarray['owner-avatar'] = $r[0]["photo"];
|
||||||
|
} else
|
||||||
|
return(array());
|
||||||
|
}
|
||||||
|
} else
|
||||||
|
$postarray['parent-uri'] = $postarray['uri'];
|
||||||
|
|
||||||
|
if ($contactid == 0) {
|
||||||
|
$contactid = twitter_fetch_contact($uid, $post->user, $create_user);
|
||||||
|
|
||||||
|
$postarray['owner-name'] = $post->user->name;
|
||||||
|
$postarray['owner-link'] = "https://twitter.com/".$post->user->screen_name;
|
||||||
|
$postarray['owner-avatar'] = $post->user->profile_image_url_https;
|
||||||
|
}
|
||||||
|
|
||||||
|
if(($contactid == 0) AND !$only_existing_contact)
|
||||||
|
$contactid = $self['id'];
|
||||||
|
elseif ($contactid <= 0)
|
||||||
|
return(array());
|
||||||
|
|
||||||
|
$postarray['contact-id'] = $contactid;
|
||||||
|
|
||||||
|
$postarray['verb'] = ACTIVITY_POST;
|
||||||
|
$postarray['author-name'] = $postarray['owner-name'];
|
||||||
|
$postarray['author-link'] = $postarray['owner-link'];
|
||||||
|
$postarray['author-avatar'] = $postarray['owner-avatar'];
|
||||||
|
$postarray['plink'] = "https://twitter.com/".$post->user->screen_name."/status/".$post->id_str;
|
||||||
|
$postarray['app'] = strip_tags($post->source);
|
||||||
|
|
||||||
|
if ($post->user->protected) {
|
||||||
|
$postarray['private'] = 1;
|
||||||
|
$postarray['allow_cid'] = '<' . $self['id'] . '>';
|
||||||
|
}
|
||||||
|
|
||||||
|
$postarray['body'] = $post->text;
|
||||||
|
|
||||||
|
// media
|
||||||
|
if (is_array($post->entities->media)) {
|
||||||
|
foreach($post->entities->media AS $media) {
|
||||||
|
switch($media->type) {
|
||||||
|
case 'photo':
|
||||||
|
$postarray['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $postarray['body']);
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
$postarray['body'] .= print_r($media, true);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$converted = twitter_convertmsg($a, $postarray['body']);
|
||||||
|
$postarray['body'] = $converted["body"];
|
||||||
|
$postarray['tag'] = $converted["tags"];
|
||||||
|
|
||||||
|
$postarray['created'] = datetime_convert('UTC','UTC',$post->created_at);
|
||||||
|
$postarray['edited'] = datetime_convert('UTC','UTC',$post->created_at);
|
||||||
|
|
||||||
|
if (is_string($post->place->name))
|
||||||
|
$postarray["location"] = $post->place->name;
|
||||||
|
|
||||||
|
if (is_string($post->place->full_name))
|
||||||
|
$postarray["location"] = $post->place->full_name;
|
||||||
|
|
||||||
|
if (is_array($post->geo->coordinates))
|
||||||
|
$postarray["coord"] = $post->geo->coordinates[0]." ".$post->geo->coordinates[1];
|
||||||
|
|
||||||
|
if (is_array($post->coordinates->coordinates))
|
||||||
|
$postarray["coord"] = $post->coordinates->coordinates[1]." ".$post->coordinates->coordinates[0];
|
||||||
|
|
||||||
|
if (is_object($post->retweeted_status)) {
|
||||||
|
|
||||||
|
$postarray['body'] = $post->retweeted_status->text;
|
||||||
|
|
||||||
|
// media
|
||||||
|
if (is_array($post->retweeted_status->entities->media)) {
|
||||||
|
foreach($post->retweeted_status->entities->media AS $media) {
|
||||||
|
switch($media->type) {
|
||||||
|
case 'photo':
|
||||||
|
$postarray['body'] = str_replace($media->url, "\n\n[img]".$media->media_url_https."[/img]\n", $postarray['body']);
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
$postarray['body'] .= print_r($media, true);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$converted = twitter_convertmsg($a, $postarray['body']);
|
||||||
|
$postarray['body'] = $converted["body"];
|
||||||
|
$postarray['tag'] = $converted["tags"];
|
||||||
|
|
||||||
|
|
||||||
|
if (!intval(get_config('system','wall-to-wall_share'))) {
|
||||||
|
$postarray['body'] = "[share author='".$post->retweeted_status->user->name.
|
||||||
|
"' profile='https://twitter.com/".$post->retweeted_status->user->screen_name.
|
||||||
|
"' avatar='".$post->retweeted_status->user->profile_image_url_https.
|
||||||
|
"' link='https://twitter.com/".$post->retweeted_status->user->screen_name."/status/".$post->retweeted_status->id_str."']".
|
||||||
|
$postarray['body'];
|
||||||
|
$postarray['body'] .= "[/share]";
|
||||||
|
} else {
|
||||||
|
// Let retweets look like wall-to-wall posts
|
||||||
|
$postarray['author-name'] = $post->retweeted_status->user->name;
|
||||||
|
$postarray['author-link'] = "https://twitter.com/".$post->retweeted_status->user->screen_name;
|
||||||
|
$postarray['author-avatar'] = $post->retweeted_status->user->profile_image_url_https;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
return($postarray);
|
||||||
|
}
|
||||||
|
|
||||||
|
function twitter_checknotification($a, $uid, $own_id, $top_item, $postarray) {
|
||||||
|
|
||||||
|
$user = q("SELECT * FROM `contact` WHERE `uid` = %d AND `self` LIMIT 1",
|
||||||
|
intval($uid)
|
||||||
|
);
|
||||||
|
|
||||||
|
if(!count($user))
|
||||||
|
return;
|
||||||
|
|
||||||
|
// Is it me?
|
||||||
|
if (link_compare($user[0]["url"], $postarray['author-link']))
|
||||||
|
return;
|
||||||
|
|
||||||
|
$own_user = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1",
|
||||||
|
intval($uid),
|
||||||
|
dbesc("twitter::".$own_id)
|
||||||
|
);
|
||||||
|
|
||||||
|
if(!count($own_user))
|
||||||
|
return;
|
||||||
|
|
||||||
|
// Is it me from twitter?
|
||||||
|
if (link_compare($own_user[0]["url"], $postarray['author-link']))
|
||||||
|
return;
|
||||||
|
|
||||||
|
$myconv = q("SELECT `author-link`, `author-avatar`, `parent` FROM `item` WHERE `parent-uri` = '%s' AND `uid` = %d AND `parent` != 0 AND `deleted` = 0",
|
||||||
|
dbesc($postarray['parent-uri']),
|
||||||
|
intval($uid)
|
||||||
|
);
|
||||||
|
|
||||||
|
if(count($myconv)) {
|
||||||
|
|
||||||
|
foreach($myconv as $conv) {
|
||||||
|
// now if we find a match, it means we're in this conversation
|
||||||
|
|
||||||
|
if(!link_compare($conv['author-link'],$user[0]["url"]) AND !link_compare($conv['author-link'],$own_user[0]["url"]))
|
||||||
|
continue;
|
||||||
|
|
||||||
|
require_once('include/enotify.php');
|
||||||
|
|
||||||
|
$conv_parent = $conv['parent'];
|
||||||
|
|
||||||
|
notification(array(
|
||||||
|
'type' => NOTIFY_COMMENT,
|
||||||
|
'notify_flags' => $user[0]['notify-flags'],
|
||||||
|
'language' => $user[0]['language'],
|
||||||
|
'to_name' => $user[0]['username'],
|
||||||
|
'to_email' => $user[0]['email'],
|
||||||
|
'uid' => $user[0]['uid'],
|
||||||
|
'item' => $postarray,
|
||||||
|
'link' => $a->get_baseurl() . '/display/' . $user[0]['nickname'] . '/' . $top_item,
|
||||||
|
'source_name' => $postarray['author-name'],
|
||||||
|
'source_link' => $postarray['author-link'],
|
||||||
|
'source_photo' => $postarray['author-avatar'],
|
||||||
|
'verb' => ACTIVITY_POST,
|
||||||
|
'otype' => 'item',
|
||||||
|
'parent' => $conv_parent,
|
||||||
|
));
|
||||||
|
|
||||||
|
// only send one notification
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
function twitter_fetchhometimeline($a, $uid) {
|
||||||
|
$ckey = get_config('twitter', 'consumerkey');
|
||||||
|
$csecret = get_config('twitter', 'consumersecret');
|
||||||
|
$otoken = get_pconfig($uid, 'twitter', 'oauthtoken');
|
||||||
|
$osecret = get_pconfig($uid, 'twitter', 'oauthsecret');
|
||||||
|
$create_user = get_pconfig($uid, 'twitter', 'create_user');
|
||||||
|
|
||||||
|
logger("twitter_fetchhometimeline: Fetching for user ".$uid, LOGGER_DEBUG);
|
||||||
|
|
||||||
|
require_once('library/twitteroauth.php');
|
||||||
|
require_once('include/items.php');
|
||||||
|
|
||||||
|
$connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret);
|
||||||
|
|
||||||
|
$own_contact = twitter_fetch_own_contact($a, $uid);
|
||||||
|
|
||||||
|
$r = q("SELECT * FROM `contact` WHERE `id` = %d AND `uid` = %d LIMIT 1",
|
||||||
|
intval($own_contact),
|
||||||
|
intval($uid));
|
||||||
|
|
||||||
|
if(count($r)) {
|
||||||
|
$own_id = $r[0]["nick"];
|
||||||
|
} else
|
||||||
|
return;
|
||||||
|
|
||||||
|
$r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
|
||||||
|
intval($uid));
|
||||||
|
|
||||||
|
if(count($r)) {
|
||||||
|
$self = $r[0];
|
||||||
|
} else
|
||||||
|
return;
|
||||||
|
|
||||||
|
$u = q("SELECT * FROM user WHERE uid = %d LIMIT 1",
|
||||||
|
intval($uid));
|
||||||
|
if(!count($u))
|
||||||
|
return;
|
||||||
|
|
||||||
|
$parameters = array("exclude_replies" => false, "trim_user" => false, "contributor_details" => true, "include_rts" => true);
|
||||||
|
//$parameters["count"] = 200;
|
||||||
|
|
||||||
|
|
||||||
|
// Fetching timeline
|
||||||
|
$lastid = get_pconfig($uid, 'twitter', 'lasthometimelineid');
|
||||||
|
|
||||||
|
$first_time = ($lastid == "");
|
||||||
|
|
||||||
|
if ($lastid <> "")
|
||||||
|
$parameters["since_id"] = $lastid;
|
||||||
|
|
||||||
|
$items = $connection->get('statuses/home_timeline', $parameters);
|
||||||
|
|
||||||
|
if (!is_array($items))
|
||||||
|
return;
|
||||||
|
|
||||||
|
$posts = array_reverse($items);
|
||||||
|
|
||||||
|
logger("twitter_fetchhometimeline: Fetching timeline for user ".$uid." ".sizeof($posts)." items", LOGGER_DEBUG);
|
||||||
|
|
||||||
|
if (count($posts)) {
|
||||||
|
foreach ($posts as $post) {
|
||||||
|
if ($post->id_str > $lastid)
|
||||||
|
$lastid = $post->id_str;
|
||||||
|
|
||||||
|
if ($first_time)
|
||||||
|
continue;
|
||||||
|
|
||||||
|
$postarray = twitter_createpost($a, $uid, $post, $self, $create_user, true);
|
||||||
|
|
||||||
|
if (trim($postarray['body']) == "")
|
||||||
|
continue;
|
||||||
|
|
||||||
|
$item = item_store($postarray);
|
||||||
|
|
||||||
|
logger('twitter_fetchhometimeline: User '.$self["nick"].' posted home timeline item '.$item);
|
||||||
|
|
||||||
|
if ($item != 0)
|
||||||
|
twitter_checknotification($a, $uid, $own_id, $item, $postarray);
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
set_pconfig($uid, 'twitter', 'lasthometimelineid', $lastid);
|
||||||
|
|
||||||
|
// Fetching mentions
|
||||||
|
$lastid = get_pconfig($uid, 'twitter', 'lastmentionid');
|
||||||
|
|
||||||
|
$first_time = ($lastid == "");
|
||||||
|
|
||||||
|
if ($lastid <> "")
|
||||||
|
$parameters["since_id"] = $lastid;
|
||||||
|
|
||||||
|
$items = $connection->get('statuses/mentions_timeline', $parameters);
|
||||||
|
|
||||||
|
if (!is_array($items))
|
||||||
|
return;
|
||||||
|
|
||||||
|
$posts = array_reverse($items);
|
||||||
|
|
||||||
|
logger("twitter_fetchhometimeline: Fetching mentions for user ".$uid." ".sizeof($posts)." items", LOGGER_DEBUG);
|
||||||
|
|
||||||
|
if (count($posts)) {
|
||||||
|
foreach ($posts as $post) {
|
||||||
|
if ($post->id_str > $lastid)
|
||||||
|
$lastid = $post->id_str;
|
||||||
|
|
||||||
|
if ($first_time)
|
||||||
|
continue;
|
||||||
|
|
||||||
|
$postarray = twitter_createpost($a, $uid, $post, $self, false, false);
|
||||||
|
|
||||||
|
if (trim($postarray['body']) == "")
|
||||||
|
continue;
|
||||||
|
|
||||||
|
$item = item_store($postarray);
|
||||||
|
|
||||||
|
logger('twitter_fetchhometimeline: User '.$self["nick"].' posted mention timeline item '.$item);
|
||||||
|
|
||||||
|
if ($item == 0) {
|
||||||
|
$r = q("SELECT * FROM `item` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1",
|
||||||
|
dbesc($postarray['uri']),
|
||||||
|
intval($uid)
|
||||||
|
);
|
||||||
|
if (count($r))
|
||||||
|
$item = $r[0]['id'];
|
||||||
|
}
|
||||||
|
|
||||||
|
if ($item != 0) {
|
||||||
|
require_once('include/enotify.php');
|
||||||
|
notification(array(
|
||||||
|
'type' => NOTIFY_TAGSELF,
|
||||||
|
'notify_flags' => $u[0]['notify-flags'],
|
||||||
|
'language' => $u[0]['language'],
|
||||||
|
'to_name' => $u[0]['username'],
|
||||||
|
'to_email' => $u[0]['email'],
|
||||||
|
'uid' => $u[0]['uid'],
|
||||||
|
'item' => $postarray,
|
||||||
|
'link' => $a->get_baseurl() . '/display/' . $u[0]['nickname'] . '/' . $item,
|
||||||
|
'source_name' => $postarray['author-name'],
|
||||||
|
'source_link' => $postarray['author-link'],
|
||||||
|
'source_photo' => $postarray['author-avatar'],
|
||||||
|
'verb' => ACTIVITY_TAG,
|
||||||
|
'otype' => 'item'
|
||||||
|
));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
set_pconfig($uid, 'twitter', 'lastmentionid', $lastid);
|
||||||
|
}
|
||||||
|
|
||||||
|
function twitter_original_url($url, $depth=1, $fetchbody = false) {
|
||||||
|
if ($depth > 10)
|
||||||
|
return($url);
|
||||||
|
|
||||||
|
$siteinfo = array();
|
||||||
|
$ch = curl_init();
|
||||||
|
curl_setopt($ch, CURLOPT_URL, $url);
|
||||||
|
curl_setopt($ch, CURLOPT_HEADER, 1);
|
||||||
|
|
||||||
|
if ($fetchbody)
|
||||||
|
curl_setopt($ch, CURLOPT_NOBODY, 0);
|
||||||
|
else
|
||||||
|
curl_setopt($ch, CURLOPT_NOBODY, 1);
|
||||||
|
|
||||||
|
curl_setopt($ch, CURLOPT_TIMEOUT, 10);
|
||||||
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
||||||
|
curl_setopt($ch,CURLOPT_USERAGENT,'Mozilla/5.0 (Macintosh; Intel Mac OS X 10.8; rv:24.0) Gecko/20100101 Firefox/24.0');
|
||||||
|
|
||||||
|
$header = curl_exec($ch);
|
||||||
|
$curl_info = @curl_getinfo($ch);
|
||||||
|
$http_code = $curl_info['http_code'];
|
||||||
|
curl_close($ch);
|
||||||
|
|
||||||
|
if ((($curl_info['http_code'] == "301") OR ($curl_info['http_code'] == "302"))
|
||||||
|
AND (($curl_info['redirect_url'] != "") OR ($curl_info['location'] != ""))) {
|
||||||
|
if ($curl_info['redirect_url'] != "")
|
||||||
|
return(twitter_original_url($curl_info['redirect_url'], ++$depth, $fetchbody));
|
||||||
|
else
|
||||||
|
return(twitter_original_url($curl_info['location'], ++$depth, $fetchbody));
|
||||||
|
}
|
||||||
|
|
||||||
|
$pos = strpos($header, "\r\n\r\n");
|
||||||
|
|
||||||
|
if ($pos)
|
||||||
|
$body = trim(substr($header, $pos));
|
||||||
|
else
|
||||||
|
$body = $header;
|
||||||
|
|
||||||
|
if (trim($body) == "")
|
||||||
|
return(twitter_original_url($url, ++$depth, true));
|
||||||
|
|
||||||
|
$doc = new DOMDocument();
|
||||||
|
@$doc->loadHTML($body);
|
||||||
|
|
||||||
|
$xpath = new DomXPath($doc);
|
||||||
|
|
||||||
|
$list = $xpath->query("//meta[@content]");
|
||||||
|
foreach ($list as $node) {
|
||||||
|
$attr = array();
|
||||||
|
if ($node->attributes->length)
|
||||||
|
foreach ($node->attributes as $attribute)
|
||||||
|
$attr[$attribute->name] = $attribute->value;
|
||||||
|
|
||||||
|
if (@$attr["http-equiv"] == 'refresh') {
|
||||||
|
$path = $attr["content"];
|
||||||
|
$pathinfo = explode(";", $path);
|
||||||
|
$content = "";
|
||||||
|
foreach ($pathinfo AS $value)
|
||||||
|
if (substr(strtolower($value), 0, 4) == "url=")
|
||||||
|
return(twitter_original_url(substr($value, 4), ++$depth));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return($url);
|
||||||
|
}
|
||||||
|
|
||||||
|
function twitter_siteinfo($url) {
|
||||||
|
require_once("mod/parse_url.php");
|
||||||
|
|
||||||
|
$data = parseurl_getsiteinfo($url);
|
||||||
|
|
||||||
|
if (!is_string($data["text"]) AND (sizeof($data["images"]) == 0) AND ($data["title"] == $url))
|
||||||
|
return("");
|
||||||
|
|
||||||
|
if (is_string($data["title"]))
|
||||||
|
$text .= "[bookmark=".$url."]".trim($data["title"])."[/bookmark]\n";
|
||||||
|
|
||||||
|
if (sizeof($data["images"]) > 0) {
|
||||||
|
$imagedata = $data["images"][0];
|
||||||
|
$text .= '[img='.$imagedata["width"].'x'.$imagedata["height"].']'.$imagedata["src"].'[/img]' . "\n";
|
||||||
|
}
|
||||||
|
|
||||||
|
if (is_string($data["text"]))
|
||||||
|
$text .= "[quote]".$data["text"]."[/quote]";
|
||||||
|
|
||||||
|
return($text);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
function twitter_convertmsg($a, $body, $no_tags = false) {
|
||||||
|
|
||||||
|
$links = preg_match_all("/([^\]\='".'"'."]|^)(https?\:\/\/[a-zA-Z0-9\:\/\-\?\&\;\.\=\_\~\#\%\$\!\+\,]+)/ism", $body,$matches,PREG_SET_ORDER);
|
||||||
|
|
||||||
|
$footer = "";
|
||||||
|
|
||||||
|
if ($links) {
|
||||||
|
foreach ($matches AS $match) {
|
||||||
|
$expanded_url = twitter_original_url($match[2]);
|
||||||
|
|
||||||
|
// To-Do:
|
||||||
|
// Twitlonger
|
||||||
|
|
||||||
|
if (strstr($expanded_url, "//www.youtube.com/"))
|
||||||
|
$body = str_replace($match[2], "\n[youtube]".$expanded_url."[/youtube]\n", $body);
|
||||||
|
elseif (strstr($expanded_url, "//player.vimeo.com/"))
|
||||||
|
$body = str_replace($match[2], "\n[vimeo]".$expanded_url."[/vimeo]\n", $body);
|
||||||
|
elseif (strstr($expanded_url, "//instagram.com"))
|
||||||
|
$body = str_replace($match[2], "\n[url]".$expanded_url."[/url]\n", $body);
|
||||||
|
else {
|
||||||
|
$img_str = fetch_url($expanded_url, true, $redirects, 4);
|
||||||
|
|
||||||
|
$tempfile = tempnam(get_config("system","temppath"), "cache");
|
||||||
|
file_put_contents($tempfile, $img_str);
|
||||||
|
$mime = image_type_to_mime_type(exif_imagetype($tempfile));
|
||||||
|
unlink($tempfile);
|
||||||
|
|
||||||
|
if (substr($mime, 0, 6) == "image/")
|
||||||
|
$body = str_replace($match[2], "[img]".$expanded_url."[/img]", $body);
|
||||||
|
else {
|
||||||
|
|
||||||
|
//if ($footer == "")
|
||||||
|
$footer = "\n\n".twitter_siteinfo($expanded_url);
|
||||||
|
$footerlink = "[url=".$expanded_url."]".$expanded_url."[/url]";
|
||||||
|
|
||||||
|
$body = str_replace($match[2], $footerlink, $body);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (($footerlink != "") AND ($footer != "")) {
|
||||||
|
$removedlink = trim(str_replace($footerlink, "", $body));
|
||||||
|
|
||||||
|
if (strstr($body, $removedlink))
|
||||||
|
$body = $removedlink;
|
||||||
|
|
||||||
|
$body .= $footer;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if ($no_tags)
|
||||||
|
return(array("body" => $body, $tags => ""));
|
||||||
|
|
||||||
|
$str_tags = '';
|
||||||
|
|
||||||
|
$tags = get_tags($body);
|
||||||
|
|
||||||
|
if(count($tags)) {
|
||||||
|
foreach($tags as $tag) {
|
||||||
|
if (strstr(trim($tag), " "))
|
||||||
|
continue;
|
||||||
|
|
||||||
|
if(strpos($tag,'#') === 0) {
|
||||||
|
if(strpos($tag,'[url='))
|
||||||
|
continue;
|
||||||
|
|
||||||
|
// don't link tags that are already embedded in links
|
||||||
|
|
||||||
|
if(preg_match('/\[(.*?)' . preg_quote($tag,'/') . '(.*?)\]/',$body))
|
||||||
|
continue;
|
||||||
|
if(preg_match('/\[(.*?)\]\((.*?)' . preg_quote($tag,'/') . '(.*?)\)/',$body))
|
||||||
|
continue;
|
||||||
|
|
||||||
|
$basetag = str_replace('_',' ',substr($tag,1));
|
||||||
|
$body = str_replace($tag,'#[url=' . $a->get_baseurl() . '/search?tag=' . rawurlencode($basetag) . ']' . $basetag . '[/url]',$body);
|
||||||
|
if(strlen($str_tags))
|
||||||
|
$str_tags .= ',';
|
||||||
|
$str_tags .= '#[url=' . $a->get_baseurl() . '/search?tag=' . rawurlencode($basetag) . ']' . $basetag . '[/url]';
|
||||||
|
continue;
|
||||||
|
} elseif(strpos($tag,'@') === 0) {
|
||||||
|
$basetag = substr($tag,1);
|
||||||
|
$body = str_replace($tag,'@[url=https://twitter.com/' . rawurlencode($basetag) . ']' . $basetag . '[/url]',$body);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$cnt = preg_match_all('/@\[url=(.*?)\[\/url\]/ism',$body,$matches,PREG_SET_ORDER);
|
||||||
|
if($cnt) {
|
||||||
|
foreach($matches as $mtch) {
|
||||||
|
if(strlen($str_tags))
|
||||||
|
$str_tags .= ',';
|
||||||
|
$str_tags .= '@[url=' . $mtch[1] . '[/url]';
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return(array("body"=>$body, "tags"=>$str_tags));
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
function twitter_fetch_own_contact($a, $uid) {
|
||||||
|
$ckey = get_config('twitter', 'consumerkey');
|
||||||
|
$csecret = get_config('twitter', 'consumersecret');
|
||||||
|
$otoken = get_pconfig($uid, 'twitter', 'oauthtoken');
|
||||||
|
$osecret = get_pconfig($uid, 'twitter', 'oauthsecret');
|
||||||
|
|
||||||
|
$own_id = get_pconfig($uid, 'twitter', 'own_id');
|
||||||
|
|
||||||
|
$contact_id = 0;
|
||||||
|
|
||||||
|
if ($own_id == "") {
|
||||||
|
require_once('library/twitteroauth.php');
|
||||||
|
|
||||||
|
$connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret);
|
||||||
|
|
||||||
|
// Fetching user data
|
||||||
|
$user = $connection->get('account/verify_credentials');
|
||||||
|
|
||||||
|
set_pconfig($uid, 'twitter', 'own_id', $user->id_str);
|
||||||
|
|
||||||
|
$contact_id = twitter_fetch_contact($uid, $user, true);
|
||||||
|
|
||||||
|
} else {
|
||||||
|
$r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1",
|
||||||
|
intval($uid), dbesc("twitter::".$own_id));
|
||||||
|
if(count($r))
|
||||||
|
$contact_id = $r[0]["id"];
|
||||||
|
}
|
||||||
|
|
||||||
|
return($contact_id);
|
||||||
|
}
|
||||||
|
?>
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue