+function statusnet_fetch_contact($uid, $contact, $create_user)
+{
+ if ($contact->statusnet_profile_url == "") {
+ return -1;
+ }
+
+ GContact::update(["url" => $contact->statusnet_profile_url,
+ "network" => NETWORK_STATUSNET, "photo" => $contact->profile_image_url,
+ "name" => $contact->name, "nick" => $contact->screen_name,
+ "location" => $contact->location, "about" => $contact->description,
+ "addr" => statusnet_address($contact), "generation" => 3]);
+
+ $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' AND `network` = '%s'LIMIT 1", intval($uid), dbesc(normalise_link($contact->statusnet_profile_url)), dbesc(NETWORK_STATUSNET));
+
+ if (!count($r) && !$create_user) {
+ return 0;
+ }
+
+ if (count($r) && ($r[0]["readonly"] || $r[0]["blocked"])) {
+ logger("statusnet_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`,
+ `location`, `about`, `writable`, `blocked`, `readonly`, `pending` )
+ VALUES ( %d, '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', %d, %d, '%s', '%s', %d, 0, 0, 0 ) ",
+ intval($uid),
+ dbesc(datetime_convert()),
+ dbesc($contact->statusnet_profile_url),
+ dbesc(normalise_link($contact->statusnet_profile_url)),
+ dbesc(statusnet_address($contact)),
+ dbesc(normalise_link($contact->statusnet_profile_url)),
+ dbesc(''),
+ dbesc(''),
+ dbesc($contact->name),
+ dbesc($contact->screen_name),
+ dbesc($contact->profile_image_url),
+ dbesc(NETWORK_STATUSNET),
+ intval(CONTACT_IS_FRIEND),
+ intval(1),
+ dbesc($contact->location),
+ dbesc($contact->description),
+ intval(1)
+ );
+
+ $r = q("SELECT * FROM `contact` WHERE `alias` = '%s' AND `uid` = %d AND `network` = '%s' LIMIT 1",
+ dbesc($contact->statusnet_profile_url),
+ intval($uid),
+ dbesc(NETWORK_STATUSNET));
+
+ if (!count($r)) {
+ return false;
+ }
+
+ $contact_id = $r[0]['id'];
+
+ Group::addMember(User::getDefaultGroup($uid), $contact_id);
+
+ $photos = Photo::importProfilePhoto($contact->profile_image_url, $uid, $contact_id);
+
+ q("UPDATE `contact` SET `photo` = '%s',
+ `thumb` = '%s',
+ `micro` = '%s',
+ `avatar-date` = '%s'
+ WHERE `id` = %d",
+ dbesc($photos[0]),
+ dbesc($photos[1]),
+ dbesc($photos[2]),
+ 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("statusnet_fetch_contact: Updating contact " . $contact->screen_name, LOGGER_DEBUG);
+
+ $photos = Photo::importProfilePhoto($contact->profile_image_url, $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',
+ `location` = '%s',
+ `about` = '%s'
+ WHERE `id` = %d",
+ dbesc($photos[0]),
+ dbesc($photos[1]),
+ dbesc($photos[2]),
+ dbesc(datetime_convert()),
+ dbesc(datetime_convert()),
+ dbesc(datetime_convert()),
+ dbesc($contact->statusnet_profile_url),
+ dbesc(normalise_link($contact->statusnet_profile_url)),
+ dbesc(statusnet_address($contact)),
+ dbesc($contact->name),
+ dbesc($contact->screen_name),
+ dbesc($contact->location),
+ dbesc($contact->description),
+ intval($r[0]['id'])
+ );
+ }
+ }
+
+ return $r[0]["id"];
+}
+
+function statusnet_fetchuser(App $a, $uid, $screen_name = "", $user_id = "")
+{
+ $ckey = PConfig::get($uid, 'statusnet', 'consumerkey');
+ $csecret = PConfig::get($uid, 'statusnet', 'consumersecret');
+ $api = PConfig::get($uid, 'statusnet', 'baseapi');
+ $otoken = PConfig::get($uid, 'statusnet', 'oauthtoken');
+ $osecret = PConfig::get($uid, 'statusnet', 'oauthsecret');
+
+ require_once "addon/statusnet/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 = [];
+
+ 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 = statusnet_fetch_contact($uid, $user, true);
+
+ return $contact_id;
+}
+
+function statusnet_createpost(App $a, $uid, $post, $self, $create_user, $only_existing_contact)
+{
+ require_once "include/html2bbcode.php";
+
+ logger("statusnet_createpost: start", LOGGER_DEBUG);
+
+ $api = PConfig::get($uid, 'statusnet', 'baseapi');
+ $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $api);
+
+ $postarray = [];
+ $postarray['network'] = NETWORK_STATUSNET;
+ $postarray['gravity'] = 0;
+ $postarray['uid'] = $uid;
+ $postarray['wall'] = 0;
+
+ if (is_object($post->retweeted_status)) {
+ $content = $post->retweeted_status;
+ statusnet_fetch_contact($uid, $content->user, false);
+ } else {
+ $content = $post;
+ }
+
+ $postarray['uri'] = $hostname . "::" . $content->id;
+
+ $r = q("SELECT * FROM `item` WHERE `extid` = '%s' AND `uid` = %d LIMIT 1",
+ dbesc($postarray['uri']),
+ intval($uid)
+ );
+
+ if (count($r)) {
+ return [];
+ }
+
+ $contactid = 0;
+
+ if ($content->in_reply_to_status_id != "") {
+
+ $parent = $hostname . "::" . $content->in_reply_to_status_id;
+
+ $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_url = PConfig::get($uid, 'statusnet', 'own_url');
+
+ if ($content->user->id == $own_url) {
+ $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 [];
+ }
+ }
+ // 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 = statusnet_fetch_contact($uid, $post->user, $create_user);
+ $postarray['owner-name'] = $post->user->name;
+ $postarray['owner-link'] = $post->user->statusnet_profile_url;
+ $postarray['owner-avatar'] = $post->user->profile_image_url;
+ }
+ if (($contactid == 0) && !$only_existing_contact) {
+ $contactid = $self['id'];
+ } elseif ($contactid <= 0) {
+ return [];
+ }
+
+ $postarray['contact-id'] = $contactid;
+
+ $postarray['verb'] = ACTIVITY_POST;
+
+ $postarray['author-name'] = $content->user->name;
+ $postarray['author-link'] = $content->user->statusnet_profile_url;
+ $postarray['author-avatar'] = $content->user->profile_image_url;
+
+ // To-Do: Maybe unreliable? Can the api be entered without trailing "/"?
+ $hostname = str_replace("/api/", "/notice/", PConfig::get($uid, 'statusnet', 'baseapi'));
+
+ $postarray['plink'] = $hostname . $content->id;
+ $postarray['app'] = strip_tags($content->source);
+
+ if ($content->user->protected) {
+ $postarray['private'] = 1;
+ $postarray['allow_cid'] = '<' . $self['id'] . '>';
+ }
+
+ $postarray['body'] = html2bbcode($content->statusnet_html);
+
+ $converted = statusnet_convertmsg($a, $postarray['body'], false);
+ $postarray['body'] = $converted["body"];
+ $postarray['tag'] = $converted["tags"];
+
+ $postarray['created'] = datetime_convert('UTC', 'UTC', $content->created_at);
+ $postarray['edited'] = datetime_convert('UTC', 'UTC', $content->created_at);
+
+ if (is_string($content->place->name)) {
+ $postarray["location"] = $content->place->name;
+ }
+
+ if (is_string($content->place->full_name)) {
+ $postarray["location"] = $content->place->full_name;
+ }
+
+ if (is_array($content->geo->coordinates)) {
+ $postarray["coord"] = $content->geo->coordinates[0] . " " . $content->geo->coordinates[1];
+ }
+
+ if (is_array($content->coordinates->coordinates)) {
+ $postarray["coord"] = $content->coordinates->coordinates[1] . " " . $content->coordinates->coordinates[0];
+ }
+
+ logger("statusnet_createpost: end", LOGGER_DEBUG);
+
+ return $postarray;
+}
+
+function statusnet_checknotification(App $a, $uid, $own_url, $top_item, $postarray)
+{
+ // This function necer worked and need cleanup
+ $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($own_url)
+ );
+
+ if (!count($own_user)) {
+ return;
+ }
+
+ // Is it me from GNU Social?
+ 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"]) && !link_compare($conv['author-link'], $own_user[0]["url"])) {
+ continue;
+ }
+
+ require_once 'include/enotify.php';
+
+ $conv_parent = $conv['parent'];
+
+ notification([
+ '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 statusnet_fetchhometimeline(App $a, $uid, $mode = 1)
+{
+ $conversations = [];
+
+ $ckey = PConfig::get($uid, 'statusnet', 'consumerkey');
+ $csecret = PConfig::get($uid, 'statusnet', 'consumersecret');
+ $api = PConfig::get($uid, 'statusnet', 'baseapi');
+ $otoken = PConfig::get($uid, 'statusnet', 'oauthtoken');
+ $osecret = PConfig::get($uid, 'statusnet', 'oauthsecret');
+ $create_user = PConfig::get($uid, 'statusnet', 'create_user');
+
+ // "create_user" is deactivated, since currently you cannot add users manually by now
+ $create_user = true;
+
+ logger("statusnet_fetchhometimeline: Fetching for user " . $uid, LOGGER_DEBUG);
+
+ require_once 'library/twitteroauth.php';
+ require_once 'include/items.php';
+
+ $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
+
+ $own_contact = statusnet_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)) {
+ $nick = $r[0]["nick"];
+ } else {
+ logger("statusnet_fetchhometimeline: Own GNU Social 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("statusnet_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("statusnet_fetchhometimeline: Own user not found for user " . $uid, LOGGER_DEBUG);
+ return;
+ }
+
+ $parameters = ["exclude_replies" => false, "trim_user" => false, "contributor_details" => true, "include_rts" => true];
+ //$parameters["count"] = 200;
+
+ if ($mode == 1) {
+ // Fetching timeline
+ $lastid = PConfig::get($uid, 'statusnet', 'lasthometimelineid');
+ //$lastid = 1;
+
+ $first_time = ($lastid == "");
+
+ if ($lastid != "") {
+ $parameters["since_id"] = $lastid;
+ }
+
+ $items = $connection->get('statuses/home_timeline', $parameters);
+
+ if (!is_array($items)) {
+ if (is_object($items) && isset($items->error)) {
+ $errormsg = $items->error;
+ } elseif (is_object($items)) {
+ $errormsg = print_r($items, true);
+ } elseif (is_string($items) || is_float($items) || is_int($items)) {
+ $errormsg = $items;
+ } else {
+ $errormsg = "Unknown error";
+ }
+
+ logger("statusnet_fetchhometimeline: Error fetching home timeline: " . $errormsg, LOGGER_DEBUG);
+ return;
+ }
+
+ $posts = array_reverse($items);
+
+ logger("statusnet_fetchhometimeline: Fetching timeline for user " . $uid . " " . sizeof($posts) . " items", LOGGER_DEBUG);
+
+ if (count($posts)) {
+ foreach ($posts as $post) {
+
+ if ($post->id > $lastid) {
+ $lastid = $post->id;
+ }
+
+ if ($first_time) {
+ continue;
+ }
+
+ if (isset($post->statusnet_conversation_id)) {
+ if (!isset($conversations[$post->statusnet_conversation_id])) {
+ statusnet_complete_conversation($a, $uid, $self, $create_user, $nick, $post->statusnet_conversation_id);
+ $conversations[$post->statusnet_conversation_id] = $post->statusnet_conversation_id;
+ }
+ } else {
+ $postarray = statusnet_createpost($a, $uid, $post, $self, $create_user, true);
+
+ if (trim($postarray['body']) == "") {
+ continue;
+ }
+
+ $item = item_store($postarray);
+ $postarray["id"] = $item;
+
+ logger('statusnet_fetchhometimeline: User ' . $self["nick"] . ' posted home timeline item ' . $item);
+
+ if ($item && !function_exists("check_item_notification")) {
+ statusnet_checknotification($a, $uid, $nick, $item, $postarray);
+ }
+ }
+ }
+ }
+ PConfig::set($uid, 'statusnet', 'lasthometimelineid', $lastid);
+ }
+
+ // Fetching mentions
+ $lastid = PConfig::get($uid, 'statusnet', 'lastmentionid');
+ $first_time = ($lastid == "");
+
+ if ($lastid != "") {
+ $parameters["since_id"] = $lastid;
+ }
+
+ $items = $connection->get('statuses/mentions_timeline', $parameters);
+
+ if (!is_array($items)) {
+ logger("statusnet_fetchhometimeline: Error fetching mentions: " . print_r($items, true), LOGGER_DEBUG);
+ return;
+ }
+
+ $posts = array_reverse($items);
+
+ logger("statusnet_fetchhometimeline: Fetching mentions for user " . $uid . " " . sizeof($posts) . " items", LOGGER_DEBUG);
+
+ if (count($posts)) {
+ foreach ($posts as $post) {
+ if ($post->id > $lastid) {
+ $lastid = $post->id;
+ }
+
+ if ($first_time) {
+ continue;
+ }
+
+ $postarray = statusnet_createpost($a, $uid, $post, $self, false, false);
+
+ if (isset($post->statusnet_conversation_id)) {
+ if (!isset($conversations[$post->statusnet_conversation_id])) {
+ statusnet_complete_conversation($a, $uid, $self, $create_user, $nick, $post->statusnet_conversation_id);
+ $conversations[$post->statusnet_conversation_id] = $post->statusnet_conversation_id;
+ }
+ } else {
+ if (trim($postarray['body']) == "") {
+ continue;
+ }
+
+ $item = item_store($postarray);
+ $postarray["id"] = $item;
+
+ logger('statusnet_fetchhometimeline: User ' . $self["nick"] . ' posted mention timeline item ' . $item);
+
+ if ($item && function_exists("check_item_notification")) {
+ check_item_notification($item, $uid, NOTIFY_TAGSELF);
+ }
+ }
+
+ $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'];
+ }
+
+ if (($item != 0) && !function_exists("check_item_notification")) {
+ require_once 'include/enotify.php';
+ notification([
+ '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,
+ ]);
+ }
+ }
+ }
+
+ PConfig::set($uid, 'statusnet', 'lastmentionid', $lastid);
+}
+
+function statusnet_complete_conversation(App $a, $uid, $self, $create_user, $nick, $conversation)
+{
+ $ckey = PConfig::get($uid, 'statusnet', 'consumerkey');
+ $csecret = PConfig::get($uid, 'statusnet', 'consumersecret');
+ $api = PConfig::get($uid, 'statusnet', 'baseapi');
+ $otoken = PConfig::get($uid, 'statusnet', 'oauthtoken');
+ $osecret = PConfig::get($uid, 'statusnet', 'oauthsecret');
+ $own_url = PConfig::get($uid, 'statusnet', 'own_url');
+
+ require_once 'library/twitteroauth.php';
+
+ $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
+
+ $parameters["count"] = 200;
+
+ $items = $connection->get('statusnet/conversation/' . $conversation, $parameters);
+ if (is_array($items)) {
+ $posts = array_reverse($items);
+
+ foreach ($posts AS $post) {
+ $postarray = statusnet_createpost($a, $uid, $post, $self, false, false);
+
+ if (trim($postarray['body']) == "") {
+ continue;
+ }
+
+ $item = item_store($postarray);
+ $postarray["id"] = $item;
+
+ logger('statusnet_complete_conversation: User ' . $self["nick"] . ' posted home timeline item ' . $item);
+
+ if ($item && !function_exists("check_item_notification")) {
+ statusnet_checknotification($a, $uid, $nick, $item, $postarray);
+ }
+ }
+ }
+}
+
+function statusnet_convertmsg(App $a, $body, $no_tags = false)
+{
+ require_once "include/items.php";
+ require_once "include/network.php";
+
+ $body = preg_replace("=\[url\=https?://([0-9]*).([0-9]*).([0-9]*).([0-9]*)/([0-9]*)\](.*?)\[\/url\]=ism", "$1.$2.$3.$4/$5", $body);
+
+ $URLSearchString = "^\[\]";
+ $links = preg_match_all("/[^!#@]\[url\=([$URLSearchString]*)\](.*?)\[\/url\]/ism", $body, $matches, PREG_SET_ORDER);
+
+ $footer = "";
+ $footerurl = "";
+ $footerlink = "";
+ $type = "";
+
+ if ($links) {
+ foreach ($matches AS $match) {
+ $search = "[url=" . $match[1] . "]" . $match[2] . "[/url]";
+
+ logger("statusnet_convertmsg: expanding url " . $match[1], LOGGER_DEBUG);
+
+ $expanded_url = original_url($match[1]);
+
+ logger("statusnet_convertmsg: fetching data for " . $expanded_url, LOGGER_DEBUG);
+
+ $oembed_data = OEmbed::fetchURL($expanded_url, true);
+
+ logger("statusnet_convertmsg: fetching data: done", LOGGER_DEBUG);
+
+ if ($type == "") {
+ $type = $oembed_data->type;
+ }
+
+ if ($oembed_data->type == "video") {
+ //$body = str_replace($search, "[video]".$expanded_url."[/video]", $body);
+ $type = $oembed_data->type;
+ $footerurl = $expanded_url;
+ $footerlink = "[url=" . $expanded_url . "]" . $expanded_url . "[/url]";
+
+ $body = str_replace($search, $footerlink, $body);
+ } elseif (($oembed_data->type == "photo") && isset($oembed_data->url) && !$dontincludemedia) {
+ $body = str_replace($search, "[url=" . $expanded_url . "][img]" . $oembed_data->url . "[/img][/url]", $body);
+ } elseif ($oembed_data->type != "link") {
+ $body = str_replace($search, "[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($search, "[img]" . $expanded_url . "[/img]", $body);
+ } else {
+ $type = $oembed_data->type;
+ $footerurl = $expanded_url;
+ $footerlink = "[url=" . $expanded_url . "]" . $expanded_url . "[/url]";
+
+ $body = str_replace($search, $footerlink, $body);
+ }
+ }
+ }
+
+ if ($footerurl != "") {
+ $footer = add_page_info($footerurl);
+ }
+
+ if (($footerlink != "") && (trim($footer) != "")) {
+ $removedlink = trim(str_replace($footerlink, "", $body));
+
+ if (($removedlink == "") || strstr($body, $removedlink)) {
+ $body = $removedlink;
+ }
+
+ $body .= $footer;
+ }
+ }
+
+ if ($no_tags) {
+ return ["body" => $body, "tags" => ""];
+ }
+
+ $str_tags = '';
+
+ $cnt = preg_match_all("/([!#@])\[url\=([$URLSearchString]*)\](.*?)\[\/url\]/ism", $body, $matches, PREG_SET_ORDER);
+ if ($cnt) {
+ foreach ($matches as $mtch) {
+ if (strlen($str_tags)) {
+ $str_tags .= ',';
+ }
+
+ if ($mtch[1] == "#") {
+ // Replacing the hash tags that are directed to the GNU Social server with internal links
+ $snhash = "#[url=" . $mtch[2] . "]" . $mtch[3] . "[/url]";
+ $frdchash = '#[url=' . $a->get_baseurl() . '/search?tag=' . rawurlencode($mtch[3]) . ']' . $mtch[3] . '[/url]';
+ $body = str_replace($snhash, $frdchash, $body);
+
+ $str_tags .= $frdchash;
+ } else {
+ $str_tags .= "@[url=" . $mtch[2] . "]" . $mtch[3] . "[/url]";
+ }
+ // To-Do:
+ // There is a problem with links with to GNU Social groups, so these links are stored with "@" like friendica groups
+ //$str_tags .= $mtch[1]."[url=".$mtch[2]."]".$mtch[3]."[/url]";
+ }
+ }
+
+ return ["body" => $body, "tags" => $str_tags];
+}
+
+function statusnet_fetch_own_contact(App $a, $uid)
+{
+ $ckey = PConfig::get($uid, 'statusnet', 'consumerkey');
+ $csecret = PConfig::get($uid, 'statusnet', 'consumersecret');
+ $api = PConfig::get($uid, 'statusnet', 'baseapi');
+ $otoken = PConfig::get($uid, 'statusnet', 'oauthtoken');
+ $osecret = PConfig::get($uid, 'statusnet', 'oauthsecret');
+ $own_url = PConfig::get($uid, 'statusnet', 'own_url');
+
+ $contact_id = 0;
+
+ if ($own_url == "") {
+ require_once 'library/twitteroauth.php';
+
+ $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
+
+ // Fetching user data
+ $user = $connection->get('account/verify_credentials');
+
+ PConfig::set($uid, 'statusnet', 'own_url', normalise_link($user->statusnet_profile_url));
+
+ $contact_id = statusnet_fetch_contact($uid, $user, true);
+ } else {
+ $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1",
+ intval($uid), dbesc($own_url));
+ if (count($r)) {
+ $contact_id = $r[0]["id"];
+ } else {
+ PConfig::delete($uid, 'statusnet', 'own_url');
+ }
+ }
+ return $contact_id;
+}
+
+function statusnet_is_retweet(App $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];
+ }
+
+ $ckey = PConfig::get($uid, 'statusnet', 'consumerkey');
+ $csecret = PConfig::get($uid, 'statusnet', 'consumersecret');
+ $api = PConfig::get($uid, 'statusnet', 'baseapi');
+ $otoken = PConfig::get($uid, 'statusnet', 'oauthtoken');
+ $osecret = PConfig::get($uid, 'statusnet', 'oauthsecret');
+ $hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $api);
+
+ $id = preg_replace("=https?://" . $hostname . "/notice/(.*)=ism", "$1", $link);
+
+ if ($id == $link) {
+ return false;
+ }
+
+ logger('statusnet_is_retweet: Retweeting id ' . $id . ' for user ' . $uid, LOGGER_DEBUG);
+
+ $connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
+
+ $result = $connection->post('statuses/retweet/' . $id);
+
+ logger('statusnet_is_retweet: result ' . print_r($result, true), LOGGER_DEBUG);
+
+ return isset($result->id);
+}