+
+function twitter_fetch_contact($uid, $contact, $create_user) {
+ require_once("include/Photo.php");
+
+ if ($contact->id_str == "")
+ return(-1);
+
+ $avatar = str_replace("_normal.", ".", $contact->profile_image_url_https);
+
+ $info = get_photo_info($avatar);
+ if (!$info)
+ $avatar = $contact->profile_image_url_https;
+
+ // Check if the unique contact is existing
+ // To-Do: only update once a while
+ $r = q("SELECT id FROM unique_contacts WHERE url='%s' LIMIT 1",
+ dbesc(normalise_link("https://twitter.com/".$contact->screen_name)));
+
+ if (count($r) == 0)
+ q("INSERT INTO unique_contacts (url, name, nick, avatar) VALUES ('%s', '%s', '%s', '%s')",
+ dbesc(normalise_link("https://twitter.com/".$contact->screen_name)),
+ dbesc($contact->name),
+ dbesc($contact->screen_name),
+ dbesc($avatar));
+ else
+ q("UPDATE unique_contacts SET name = '%s', nick = '%s', avatar = '%s' WHERE url = '%s'",
+ dbesc($contact->name),
+ dbesc($contact->screen_name),
+ dbesc($avatar),
+ dbesc(normalise_link("https://twitter.com/".$contact->screen_name)));
+
+ if (DB_UPDATE_VERSION >= "1177")
+ q("UPDATE `unique_contacts` SET `location` = '%s', `about` = '%s' WHERE url = '%s'",
+ dbesc($contact->location),
+ dbesc($contact->description),
+ dbesc(normalise_link("https://twitter.com/".$contact->screen_name)));
+
+ $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($avatar),
+ 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($avatar,$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)
+ );
+
+ if (DB_UPDATE_VERSION >= "1177")
+ q("UPDATE `contact` SET `location` = '%s',
+ `about` = '%s'
+ WHERE `id` = %d",
+ dbesc($contact->location),
+ dbesc($contact->description),
+ 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($avatar, $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'])
+ );
+
+ if (DB_UPDATE_VERSION >= "1177")
+ q("UPDATE `contact` SET `location` = '%s',
+ `about` = '%s'
+ WHERE `id` = %d",
+ dbesc($contact->location),
+ dbesc($contact->description),
+ 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_expand_entities($a, $body, $item, $no_tags = false, $picture) {
+ require_once("include/oembed.php");
+ require_once("include/network.php");
+
+ $tags = "";
+
+ if (isset($item->entities->urls)) {
+ $type = "";
+ $footerurl = "";
+ $footerlink = "";
+ $footer = "";
+
+ foreach ($item->entities->urls AS $url) {
+ if ($url->url AND $url->expanded_url AND $url->display_url) {
+
+ $expanded_url = original_url($url->expanded_url);
+
+ $oembed_data = oembed_fetch_url($expanded_url);
+
+ // Quickfix: Workaround for URL with "[" and "]" in it
+ if (strpos($expanded_url, "[") OR strpos($expanded_url, "]"))
+ $expanded_url = $url->url;
+
+ if ($type == "")
+ $type = $oembed_data->type;
+
+ if ($oembed_data->type == "video") {
+ //$body = str_replace($url->url,
+ // "[video]".$expanded_url."[/video]", $body);
+ //$dontincludemedia = true;
+ $type = $oembed_data->type;
+ $footerurl = $expanded_url;
+ $footerlink = "[url=".$expanded_url."]".$expanded_url."[/url]";
+
+ $body = str_replace($url->url, $footerlink, $body);
+ //} elseif (($oembed_data->type == "photo") AND isset($oembed_data->url) AND !$dontincludemedia) {
+ } elseif (($oembed_data->type == "photo") AND isset($oembed_data->url)) {
+ $body = str_replace($url->url,
+ "[url=".$expanded_url."][img]".$oembed_data->url."[/img][/url]",
+ $body);
+ //$dontincludemedia = true;
+ } elseif ($oembed_data->type != "link")
+ $body = str_replace($url->url,
+ "[url=".$expanded_url."]".$expanded_url."[/url]",
+ $body);
+ else {
+ $img_str = fetch_url($expanded_url, true, $redirects, 4);
+
+ $tempfile = tempnam(get_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/") {
+ $type = "photo";
+ $body = str_replace($url->url, "[img]".$expanded_url."[/img]", $body);
+ //$dontincludemedia = true;
+ } else {
+ $type = $oembed_data->type;
+ $footerurl = $expanded_url;
+ $footerlink = "[url=".$expanded_url."]".$expanded_url."[/url]";
+
+ $body = str_replace($url->url, $footerlink, $body);
+ }
+ }
+ }
+ }
+
+ if ($footerurl != "")
+ $footer = add_page_info($footerurl, false, $picture);
+
+ if (($footerlink != "") AND (trim($footer) != "")) {
+ $removedlink = trim(str_replace($footerlink, "", $body));
+
+ if (($removedlink == "") OR strstr($body, $removedlink))
+ $body = $removedlink;
+
+ $body .= $footer;
+ }
+
+ if (($footer == "") AND ($picture != ""))
+ $body .= "\n\n[img]".$picture."[/img]\n";
+
+ if ($no_tags)
+ return(array("body" => $body, "tags" => ""));
+
+ $tags_arr = array();
+
+ foreach ($item->entities->hashtags AS $hashtag) {
+ $url = "#[url=".$a->get_baseurl()."/search?tag=".rawurlencode($hashtag->text)."]".$hashtag->text."[/url]";
+ $tags_arr["#".$hashtag->text] = $url;
+ $body = str_replace("#".$hashtag->text, $url, $body);
+ }
+
+ foreach ($item->entities->user_mentions AS $mention) {
+ $url = "@[url=https://twitter.com/".rawurlencode($mention->screen_name)."]".$mention->screen_name."[/url]";
+ $tags_arr["@".$mention->screen_name] = $url;
+ $body = str_replace("@".$mention->screen_name, $url, $body);
+ }
+
+ // it seems as if the entities aren't always covering all mentions. So the rest will be checked here
+ $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));
+ $url = '#[url='.$a->get_baseurl().'/search?tag='.rawurlencode($basetag).']'.$basetag.'[/url]';
+ $body = str_replace($tag,$url,$body);
+ $tags_arr["#".$basetag] = $url;
+ continue;
+ } elseif(strpos($tag,'@') === 0) {
+ if(strpos($tag,'[url='))
+ continue;
+
+ $basetag = substr($tag,1);
+ $url = '@[url=https://twitter.com/'.rawurlencode($basetag).']'.$basetag.'[/url]';
+ $body = str_replace($tag,$url,$body);
+ $tags_arr["@".$basetag] = $url;
+ }
+ }
+ }
+
+
+ $tags = implode($tags_arr, ",");
+
+ }
+ return(array("body" => $body, "tags" => $tags));
+}
+
+function twitter_createpost($a, $uid, $post, $self, $create_user, $only_existing_contact) {
+
+ $has_picture = false;
+
+ $postarray = array();
+ $postarray['network'] = NETWORK_TWITTER;
+ $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"];
+ $postarray['parent'] = $r[0]["parent"];
+ $postarray['object-type'] = ACTIVITY_OBJ_COMMENT;
+ } 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'];
+ $postarray['parent'] = $r[0]['parent'];
+ $postarray['object-type'] = ACTIVITY_OBJ_COMMENT;
+ } else {
+ $postarray['thr-parent'] = $postarray['uri'];
+ $postarray['parent-uri'] = $postarray['uri'];
+ $postarray['object-type'] = ACTIVITY_OBJ_NOTE;
+ }
+ }
+
+ // 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());
+ }
+ // Don't create accounts of people who just comment something
+ $create_user = false;
+ } else {
+ $postarray['parent-uri'] = $postarray['uri'];
+ $postarray['object-type'] = ACTIVITY_OBJ_NOTE;
+ }
+
+ 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;
+
+ $picture = "";
+
+ // 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']);
+ //$has_picture = true;
+ $postarray['body'] = str_replace($media->url, "", $postarray['body']);
+ $postarray['object-type'] = ACTIVITY_OBJ_IMAGE;
+ $picture = $media->media_url_https;
+ break;
+ default:
+ $postarray['body'] .= print_r($media, true);
+ }
+ }
+ }
+
+ $converted = twitter_expand_entities($a, $postarray['body'], $post, false, $picture);
+ $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;
+
+ $picture = "";
+
+ // 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']);
+ //$has_picture = true;
+ $postarray['body'] = str_replace($media->url, "", $postarray['body']);
+ $postarray['object-type'] = ACTIVITY_OBJ_IMAGE;
+ $picture = $media->media_url_https;
+ break;
+ default:
+ $postarray['body'] .= print_r($media, true);
+ }
+ }
+ }
+
+ $converted = twitter_expand_entities($a, $postarray['body'], $post->retweeted_status, false, $picture);
+ $postarray['body'] = $converted["body"];
+ $postarray['tag'] = $converted["tags"];
+
+ twitter_fetch_contact($uid, $post->retweeted_status->user, false);
+
+ // Deactivated at the moment, since there are problems with answers to retweets
+ if (false AND !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;
+ //if (($post->retweeted_status->user->screen_name != "") AND ($post->retweeted_status->id_str != "")) {
+ // $postarray['plink'] = "https://twitter.com/".$post->retweeted_status->user->screen_name."/status/".$post->retweeted_status->id_str;
+ // $postarray['uri'] = "twitter::".$post->retweeted_status->id_str;
+ //}
+ }
+
+ }
+ return($postarray);
+}
+
+function twitter_checknotification($a, $uid, $own_id, $top_item, $postarray) {
+
+ // this whole function doesn't seem to work. Needs complete check
+
+ $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/'.urlencode(get_item_guid($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 {
+ logger("twitter_fetchhometimeline: Own twitter contact not found for user ".$uid, LOGGER_DEBUG);
+ return;
+ }
+
+ $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
+ intval($uid));
+
+ if(count($r)) {
+ $self = $r[0];
+ } else {
+ logger("twitter_fetchhometimeline: Own contact not found for user ".$uid, LOGGER_DEBUG);
+ return;
+ }
+
+ $u = q("SELECT * FROM user WHERE uid = %d LIMIT 1",
+ intval($uid));
+ if(!count($u)) {
+ logger("twitter_fetchhometimeline: Own user not found for user ".$uid, LOGGER_DEBUG);
+ 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)) {
+ logger("twitter_fetchhometimeline: Error fetching home timeline: ".print_r($items, true), LOGGER_DEBUG);
+ 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)) {
+ logger("twitter_fetchhometimeline: Error fetching mentions: ".print_r($items, true), LOGGER_DEBUG);
+ 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);
+
+ if (!isset($postarray["parent"]) OR ($postarray["parent"] == 0))
+ $postarray["parent"] = $item;
+
+ 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'];
+ $parent_id = $r[0]['parent'];
+ }
+ } else
+ $parent_id = $postarray['parent'];
+
+ 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/'.urlencode(get_item_guid($item)),
+ 'source_name' => $postarray['author-name'],
+ 'source_link' => $postarray['author-link'],
+ 'source_photo' => $postarray['author-avatar'],
+ 'verb' => ACTIVITY_TAG,
+ 'otype' => 'item',
+ 'parent' => $parent_id
+ ));
+ }
+ }
+ }
+
+ set_pconfig($uid, 'twitter', 'lastmentionid', $lastid);
+}
+
+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"];
+ else
+ del_pconfig($uid, 'twitter', 'own_id');
+
+ }
+
+ return($contact_id);
+}
+
+function twitter_is_retweet($a, $uid, $body) {
+ $body = trim($body);
+
+ // Skip if it isn't a pure repeated messages
+ // Does it start with a share?
+ if (strpos($body, "[share") > 0)
+ return(false);
+
+ // Does it end with a share?
+ if (strlen($body) > (strrpos($body, "[/share]") + 8))
+ return(false);
+
+ $attributes = preg_replace("/\[share(.*?)\]\s?(.*?)\s?\[\/share\]\s?/ism","$1",$body);
+ // Skip if there is no shared message in there
+ if ($body == $attributes)
+ return(false);
+
+ $link = "";
+ preg_match("/link='(.*?)'/ism", $attributes, $matches);
+ if ($matches[1] != "")
+ $link = $matches[1];
+
+ preg_match('/link="(.*?)"/ism', $attributes, $matches);
+ if ($matches[1] != "")
+ $link = $matches[1];
+
+ $id = preg_replace("=https?://twitter.com/(.*)/status/(.*)=ism", "$2", $link);
+ if ($id == $link)
+ return(false);
+
+ logger('twitter_is_retweet: Retweeting id '.$id.' for user '.$uid, LOGGER_DEBUG);
+
+ $ckey = get_config('twitter', 'consumerkey');
+ $csecret = get_config('twitter', 'consumersecret');
+ $otoken = get_pconfig($uid, 'twitter', 'oauthtoken');
+ $osecret = get_pconfig($uid, 'twitter', 'oauthsecret');
+
+ require_once('library/twitteroauth.php');
+ $connection = new TwitterOAuth($ckey,$csecret,$otoken,$osecret);
+
+ $result = $connection->post('statuses/retweet/'.$id);
+
+ logger('twitter_is_retweet: result '.print_r($result, true), LOGGER_DEBUG);
+
+ return(!isset($result->errors));
+}
+?>