use CodebirdSN\CodebirdSN;
use Friendica\App;
use Friendica\Content\OEmbed;
+use Friendica\Content\PageInfo;
use Friendica\Content\Text\HTML;
use Friendica\Content\Text\Plaintext;
use Friendica\Core\Hook;
use Friendica\Model\Contact;
use Friendica\Model\Group;
use Friendica\Model\Item;
-use Friendica\Model\ItemContent;
use Friendica\Model\Photo;
+use Friendica\Model\Post;
use Friendica\Model\User;
use Friendica\Protocol\Activity;
use Friendica\Util\DateTimeFormat;
-use Friendica\Util\Network;
use Friendica\Util\Strings;
+use GuzzleHttp\Exception\TransferException;
function statusnet_install()
{
Hook::register('cron', 'addon/statusnet/statusnet.php', 'statusnet_cron');
Hook::register('prepare_body', 'addon/statusnet/statusnet.php', 'statusnet_prepare_body');
Hook::register('check_item_notification', 'addon/statusnet/statusnet.php', 'statusnet_check_item_notification');
- Logger::log("installed GNU Social");
-}
-
-function statusnet_uninstall()
-{
- Hook::unregister('connector_settings', 'addon/statusnet/statusnet.php', 'statusnet_settings');
- Hook::unregister('connector_settings_post', 'addon/statusnet/statusnet.php', 'statusnet_settings_post');
- Hook::unregister('notifier_normal', 'addon/statusnet/statusnet.php', 'statusnet_post_hook');
- Hook::unregister('hook_fork', 'addon/statusnet/statusnet.php', 'statusnet_hook_fork');
- Hook::unregister('post_local', 'addon/statusnet/statusnet.php', 'statusnet_post_local');
- Hook::unregister('jot_networks', 'addon/statusnet/statusnet.php', 'statusnet_jot_nets');
- Hook::unregister('cron', 'addon/statusnet/statusnet.php', 'statusnet_cron');
- Hook::unregister('prepare_body', 'addon/statusnet/statusnet.php', 'statusnet_prepare_body');
- Hook::unregister('check_item_notification', 'addon/statusnet/statusnet.php', 'statusnet_check_item_notification');
-
- // old setting - remove only
- Hook::unregister('post_local_end', 'addon/statusnet/statusnet.php', 'statusnet_post_hook');
- Hook::unregister('addon_settings', 'addon/statusnet/statusnet.php', 'statusnet_settings');
- Hook::unregister('addon_settings_post', 'addon/statusnet/statusnet.php', 'statusnet_settings_post');
+ Logger::notice("installed GNU Social");
}
function statusnet_check_item_notification(App $a, &$notification_data)
foreach ($globalsn as $asn) {
if ($asn['apiurl'] == $_POST['statusnet-preconf-apiurl']) {
$apibase = $asn['apiurl'];
- $c = Network::fetchUrl($apibase . 'statusnet/version.xml');
+ $c = DI::httpClient()->fetch($apibase . 'statusnet/version.xml');
if (strlen($c) > 0) {
DI::pConfig()->set(local_user(), 'statusnet', 'consumerkey', $asn['consumerkey']);
DI::pConfig()->set(local_user(), 'statusnet', 'consumersecret', $asn['consumersecret']);
// we'll check the API Version for that, if we don't get one we'll try to fix the path but will
// resign quickly after this one try to fix the path ;-)
$apibase = $_POST['statusnet-baseapi'];
- $c = Network::fetchUrl($apibase . 'statusnet/version.xml');
+ $c = DI::httpClient()->fetch($apibase . 'statusnet/version.xml');
if (strlen($c) > 0) {
// ok the API path is correct, let's save the settings
DI::pConfig()->set(local_user(), 'statusnet', 'consumerkey', $_POST['statusnet-consumerkey']);
} else {
// the API path is not correct, maybe missing trailing / ?
$apibase = $apibase . '/';
- $c = Network::fetchUrl($apibase . 'statusnet/version.xml');
+ $c = DI::httpClient()->fetch($apibase . 'statusnet/version.xml');
if (strlen($c) > 0) {
// ok the API path is now correct, let's save the settings
DI::pConfig()->set(local_user(), 'statusnet', 'consumerkey', $_POST['statusnet-consumerkey']);
if (!intval($_POST['statusnet-mirror']))
DI::pConfig()->delete(local_user(), 'statusnet', 'lastid');
-
- info(DI::l10n()->t('GNU Social settings updated.') . EOL);
}
}
}
if (!local_user()) {
return;
}
+
+ $user = User::getById(local_user());
+
DI::page()['htmlhead'] .= '<link rel="stylesheet" type="text/css" href="' . DI::baseUrl()->get() . '/addon/statusnet/statusnet.css' . '" media="all" />' . "\r\n";
/* * *
* 1) Check that we have a base api url and a consumer key & secret
$s .= '<div id="statusnet-info" ><img id="statusnet-avatar" src="' . $details->profile_image_url . '" /><p id="statusnet-info-block">' . DI::l10n()->t('Currently connected to: ') . '<a href="' . $details->statusnet_profile_url . '" target="_statusnet">' . $details->screen_name . '</a><br /><em>' . $details->description . '</em></p></div>';
}
$s .= '<p>' . DI::l10n()->t('If enabled all your <strong>public</strong> postings can be posted to the associated GNU Social account. You can choose to do so by default (here) or for every posting separately in the posting options when writing the entry.') . '</p>';
- if ($a->user['hidewall']) {
+ if ($user['hidewall']) {
$s .= '<p>' . DI::l10n()->t('<strong>Note</strong>: Due your privacy settings (<em>Hide your profile details from unknown viewers?</em>) the link potentially included in public postings relayed to GNU Social will lead the visitor to a blank page informing the visitor that the access to your profile has been restricted.') . '</p>';
}
$s .= '<div id="statusnet-enable-wrapper">';
if (DI::pConfig()->get($post['uid'], 'statusnet', 'import')) {
// Don't fork if it isn't a reply to a GNU Social post
- if (($post['parent'] != $post['id']) && !Item::exists(['id' => $post['parent'], 'network' => Protocol::STATUSNET])) {
- Logger::log('No GNU Social parent found for item ' . $post['id']);
+ if (($post['parent'] != $post['id']) && !Post::exists(['id' => $post['parent'], 'network' => Protocol::STATUSNET])) {
+ Logger::notice('No GNU Social parent found for item ' . $post['id']);
$b['execute'] = false;
return;
}
$connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
- Logger::log("statusnet_action '" . $action . "' ID: " . $pid, Logger::DATA);
+ Logger::debug("statusnet_action '" . $action . "' ID: " . $pid);
switch ($action) {
case "delete":
$result = $connection->post("favorites/destroy/" . $pid);
break;
}
- Logger::log("statusnet_action '" . $action . "' send, result: " . print_r($result, true), Logger::DEBUG);
+ Logger::info("statusnet_action '" . $action . "' send, result: " . print_r($result, true));
}
function statusnet_post_hook(App $a, &$b)
return;
}
+ $b['body'] = Post\Media::addAttachmentsToBody($b['uri-id'], $b['body']);
+
$api = DI::pConfig()->get($b["uid"], 'statusnet', 'baseapi');
$hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $api);
if ($b['parent'] != $b['id']) {
- Logger::log("statusnet_post_hook: parameter " . print_r($b, true), Logger::DATA);
+ Logger::debug("statusnet_post_hook: parameter " . print_r($b, true));
// Looking if its a reply to a GNU Social post
$hostlength = strlen($hostname) + 2;
if ((substr($b["parent-uri"], 0, $hostlength) != $hostname . "::") && (substr($b["extid"], 0, $hostlength) != $hostname . "::") && (substr($b["thr-parent"], 0, $hostlength) != $hostname . "::")) {
- Logger::log("statusnet_post_hook: no GNU Social post " . $b["parent"]);
+ Logger::notice("statusnet_post_hook: no GNU Social post " . $b["parent"]);
return;
}
$condition = ['uri' => $b["thr-parent"], 'uid' => $b["uid"]];
- $orig_post = Item::selectFirst(['author-link', 'uri'], $condition);
+ $orig_post = Post::selectFirst(['author-link', 'uri'], $condition);
if (!DBA::isResult($orig_post)) {
- Logger::log("statusnet_post_hook: no parent found " . $b["thr-parent"]);
+ Logger::notice("statusnet_post_hook: no parent found " . $b["thr-parent"]);
return;
} else {
$iscomment = true;
$nickname = "@[url=" . $orig_post["author-link"] . "]" . $nick . "[/url]";
$nicknameplain = "@" . $nick;
- Logger::log("statusnet_post_hook: comparing " . $nickname . " and " . $nicknameplain . " with " . $b["body"], Logger::DEBUG);
+ Logger::info("statusnet_post_hook: comparing " . $nickname . " and " . $nicknameplain . " with " . $b["body"]);
if ((strpos($b["body"], $nickname) === false) && (strpos($b["body"], $nicknameplain) === false)) {
$b["body"] = $nickname . " " . $b["body"];
}
- Logger::log("statusnet_post_hook: parent found " . print_r($orig_post, true), Logger::DEBUG);
+ Logger::info("statusnet_post_hook: parent found " . print_r($orig_post, true));
} else {
$iscomment = false;
}
if ($b['verb'] == Activity::LIKE) {
- Logger::log("statusnet_post_hook: parameter 2 " . substr($b["thr-parent"], $hostlength), Logger::DEBUG);
+ Logger::info("statusnet_post_hook: parameter 2 " . substr($b["thr-parent"], $hostlength));
if ($b['deleted'])
statusnet_action($a, $b["uid"], substr($b["thr-parent"], $hostlength), "unlike");
else
return;
}
- Logger::log('GNU Socialpost invoked');
+ Logger::notice('GNU Socialpost invoked');
DI::pConfig()->load($b['uid'], 'statusnet');
DI::pConfig()->set($b['uid'], 'statusnet', 'max_char', $max_char);
$tempfile = "";
- $msgarr = ItemContent::getPlaintextPost($b, $max_char, true, 7);
+ $msgarr = Plaintext::getPost($b, $max_char, true, 7);
$msg = $msgarr["text"];
if (($msg == "") && isset($msgarr["title"]))
- $msg = Plaintext::shorten($msgarr["title"], $max_char - 50);
+ $msg = Plaintext::shorten($msgarr["title"], $max_char - 50, $b['uid']);
$image = "";
}
if ($image != "") {
- $img_str = Network::fetchUrl($image);
+ $img_str = DI::httpClient()->fetch($image);
$tempfile = tempnam(get_temppath(), "cache");
file_put_contents($tempfile, $img_str);
$postdata = ["status" => $msg, "media[]" => $tempfile];
if (strlen($msg)) {
if ($iscomment) {
$postdata["in_reply_to_status_id"] = substr($orig_post["uri"], $hostlength);
- Logger::log('statusnet_post send reply ' . print_r($postdata, true), Logger::DEBUG);
+ Logger::info('statusnet_post send reply ' . print_r($postdata, true));
}
// New code that is able to post pictures
$cb->setToken($otoken, $osecret);
$result = $cb->statuses_update($postdata);
//$result = $dent->post('statuses/update', $postdata);
- Logger::log('statusnet_post send, result: ' . print_r($result, true) .
- "\nmessage: " . $msg . "\nOriginal post: " . print_r($b, true) . "\nPost Data: " . print_r($postdata, true), Logger::DEBUG);
+ Logger::info('statusnet_post send, result: ' . print_r($result, true) .
+ "\nmessage: " . $msg . "\nOriginal post: " . print_r($b, true) . "\nPost Data: " . print_r($postdata, true));
if (!empty($result->source)) {
DI::pConfig()->set($b["uid"], "statusnet", "application_name", strip_tags($result->source));
}
if (!empty($result->error)) {
- Logger::log('Send to GNU Social failed: "' . $result->error . '"');
+ Logger::notice('Send to GNU Social failed: "' . $result->error . '"');
} elseif ($iscomment) {
- Logger::log('statusnet_post: Update extid ' . $result->id . " for post id " . $b['id']);
+ Logger::notice('statusnet_post: Update extid ' . $result->id . " for post id " . $b['id']);
Item::update(['extid' => $hostname . "::" . $result->id, 'body' => $result->text], ['id' => $b['id']]);
}
}
$item["plink"] = DI::baseUrl()->get() . "/display/" . $item["guid"];
$condition = ['uri' => $item["thr-parent"], 'uid' => local_user()];
- $orig_post = Item::selectFirst(['author-link', 'uri'], $condition);
+ $orig_post = Post::selectFirst(['author-link', 'uri'], $condition);
if (DBA::isResult($orig_post)) {
$nick = preg_replace("=https?://(.*)/(.*)=ism", "$2", $orig_post["author-link"]);
}
}
- $msgarr = ItemContent::getPlaintextPost($item, $max_char, true, 7);
+ $msgarr = Plaintext::getPost($item, $max_char, true, 7);
$msg = $msgarr["text"];
if (isset($msgarr["url"]) && ($msgarr["type"] != "photo")) {
if ($last) {
$next = $last + ($poll_interval * 60);
if ($next > time()) {
- Logger::log('statusnet: poll intervall not reached');
+ Logger::notice('statusnet: poll intervall not reached');
return;
}
}
- Logger::log('statusnet: cron_start');
+ Logger::notice('statusnet: cron_start');
- $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'statusnet' AND `k` = 'mirror_posts' AND `v` = '1' ORDER BY RAND() ");
- if (DBA::isResult($r)) {
- foreach ($r as $rr) {
- Logger::log('statusnet: fetching for user ' . $rr['uid']);
- statusnet_fetchtimeline($a, $rr['uid']);
- }
+ $pconfigs = DBA::selectToArray('pconfig', [], ['cat' => 'statusnet', 'k' => 'mirror_posts', 'v' => true]);
+ foreach ($pconfigs as $rr) {
+ Logger::notice('statusnet: fetching for user ' . $rr['uid']);
+ statusnet_fetchtimeline($a, $rr['uid']);
}
$abandon_days = intval(DI::config()->get('system', 'account_abandon_days'));
$abandon_limit = date(DateTimeFormat::MYSQL, time() - $abandon_days * 86400);
- $r = q("SELECT * FROM `pconfig` WHERE `cat` = 'statusnet' AND `k` = 'import' AND `v` ORDER BY RAND()");
- if (DBA::isResult($r)) {
- foreach ($r as $rr) {
- if ($abandon_days != 0) {
- $user = q("SELECT `login_date` FROM `user` WHERE uid=%d AND `login_date` >= '%s'", $rr['uid'], $abandon_limit);
- if (!DBA::isResult($user)) {
- Logger::log('abandoned account: timeline from user ' . $rr['uid'] . ' will not be imported');
- continue;
- }
+ $pconfigs = DBA::selectToArray('pconfig', [], ['cat' => 'statusnet', 'k' => 'import', 'v' => true]);
+ foreach ($pconfigs as $rr) {
+ if ($abandon_days != 0) {
+ if (!DBA::exists('user', ["`uid` = ? AND `login_date` >= ?", $rr['uid'], $abandon_limit])) {
+ Logger::notice('abandoned account: timeline from user ' . $rr['uid'] . ' will not be imported');
+ continue;
}
-
- Logger::log('statusnet: importing timeline from user ' . $rr['uid']);
- statusnet_fetchhometimeline($a, $rr["uid"], $rr["v"]);
}
+
+ Logger::notice('statusnet: importing timeline from user ' . $rr['uid']);
+ statusnet_fetchhometimeline($a, $rr["uid"], $rr["v"]);
}
- Logger::log('statusnet: cron_end');
+ Logger::notice('statusnet: cron_end');
DI::config()->set('statusnet', 'last_poll', time());
}
$_REQUEST["title"] = "";
- $_REQUEST["body"] = add_page_info_to_body($post->text, true);
+ $_REQUEST["body"] = $post->text;
if (is_string($post->place->name)) {
$_REQUEST["location"] = $post->place->name;
}
//print_r($_REQUEST);
if ($_REQUEST["body"] != "") {
- Logger::log('statusnet: posting for user ' . $uid);
+ Logger::notice('statusnet: posting for user ' . $uid);
item_post($a);
}
return -1;
}
- $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' AND `network` = '%s'LIMIT 1", intval($uid), DBA::escape(Strings::normaliseLink($contact->statusnet_profile_url)), DBA::escape(Protocol::STATUSNET));
+ $contact_record = Contact::selectFirst([],
+ ['alias' => Strings::normaliseLink($contact->statusnet_profile_url), 'uid' => $uid, 'network' => Protocol::STATUSNET]);
- if (!DBA::isResult($r) && !$create_user) {
+ if (!DBA::isResult($contact_record) && !$create_user) {
return 0;
}
- if (DBA::isResult($r) && ($r[0]["readonly"] || $r[0]["blocked"])) {
- Logger::log("statusnet_fetch_contact: Contact '" . $r[0]["nick"] . "' is blocked or readonly.", Logger::DEBUG);
+ if (DBA::isResult($contact_record) && ($contact_record["readonly"] || $contact_record["blocked"])) {
+ Logger::info("statusnet_fetch_contact: Contact '" . $contact_record["nick"] . "' is blocked or readonly.");
return -1;
}
- if (!DBA::isResult($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),
- DBA::escape(DateTimeFormat::utcNow()),
- DBA::escape($contact->statusnet_profile_url),
- DBA::escape(Strings::normaliseLink($contact->statusnet_profile_url)),
- DBA::escape(statusnet_address($contact)),
- DBA::escape(Strings::normaliseLink($contact->statusnet_profile_url)),
- DBA::escape(''),
- DBA::escape(''),
- DBA::escape($contact->name),
- DBA::escape($contact->screen_name),
- DBA::escape($contact->profile_image_url),
- DBA::escape(Protocol::STATUSNET),
- intval(Contact::FRIEND),
- intval(1),
- DBA::escape($contact->location),
- DBA::escape($contact->description),
- intval(1)
- );
-
- $r = q("SELECT * FROM `contact` WHERE `alias` = '%s' AND `uid` = %d AND `network` = '%s' LIMIT 1",
- DBA::escape($contact->statusnet_profile_url),
- intval($uid),
- DBA::escape(Protocol::STATUSNET));
-
- if (!DBA::isResult($r)) {
+ if (!DBA::isResult($contact_record)) {
+ $fields = [
+ 'uid' => $uid,
+ 'created' => DateTimeFormat::utcNow(),
+ 'url' => $contact->statusnet_profile_url,
+ 'nurl' => Strings::normaliseLink($contact->statusnet_profile_url),
+ 'addr' => statusnet_address($contact),
+ 'alias' => Strings::normaliseLink($contact->statusnet_profile_url),
+ 'notify' => '',
+ 'poll' => '',
+ 'name' => $contact->name,
+ 'nick' => $contact->screen_name,
+ 'photo' => $contact->profile_image_url,
+ 'network' => Protocol::STATUSNET,
+ 'rel' => Contact::FRIEND,
+ 'priority' => 1,
+ 'location' => $contact->location,
+ 'about' => $contact->description,
+ 'writable' => true,
+ 'blocked' => false,
+ 'readonly' => false,
+ 'pending' => false,
+ ];
+
+ if (!Contact::insert($fields)) {
+ return false;
+ }
+
+ $contact_record = Contact::selectFirst([],
+ ['alias' => Strings::normaliseLink($contact->statusnet_profile_url), 'uid' => $uid, 'network' => Protocol::STATUSNET]);
+ if (!DBA::isResult($contact_record)) {
return false;
}
- $contact_id = $r[0]['id'];
+ $contact_id = $contact_record['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",
- DBA::escape($photos[0]),
- DBA::escape($photos[1]),
- DBA::escape($photos[2]),
- DBA::escape(DateTimeFormat::utcNow()),
- intval($contact_id)
- );
+ Contact::update(['photo' => $photos[0], 'thumb' => $photos[1],
+ 'micro' => $photos[2], 'avatar-date' => DateTimeFormat::utcNow()], ['id' => $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'] < DateTimeFormat::convert('now -2 days', '', '', )) ? true : false);
- $update_photo = ($r[0]['avatar-date'] < DateTimeFormat::utc('now -12 hours'));
+ //$update_photo = (($contact_record['avatar-date'] < DateTimeFormat::convert('now -2 days', '', '', )) ? true : false);
+ $update_photo = ($contact_record['avatar-date'] < DateTimeFormat::utc('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::log("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",
- DBA::escape($photos[0]),
- DBA::escape($photos[1]),
- DBA::escape($photos[2]),
- DBA::escape(DateTimeFormat::utcNow()),
- DBA::escape(DateTimeFormat::utcNow()),
- DBA::escape(DateTimeFormat::utcNow()),
- DBA::escape($contact->statusnet_profile_url),
- DBA::escape(Strings::normaliseLink($contact->statusnet_profile_url)),
- DBA::escape(statusnet_address($contact)),
- DBA::escape($contact->name),
- DBA::escape($contact->screen_name),
- DBA::escape($contact->location),
- DBA::escape($contact->description),
- intval($r[0]['id'])
- );
+ if ((!$contact_record['photo']) || (!$contact_record['thumb']) || (!$contact_record['micro']) || ($update_photo)) {
+ Logger::info("statusnet_fetch_contact: Updating contact " . $contact->screen_name);
+
+ $photos = Photo::importProfilePhoto($contact->profile_image_url, $uid, $contact_record['id']);
+
+ Contact::update([
+ 'photo' => $photos[0],
+ 'thumb' => $photos[1],
+ 'micro' => $photos[2],
+ 'name-date' => DateTimeFormat::utcNow(),
+ 'uri-date' => DateTimeFormat::utcNow(),
+ 'avatar-date' => DateTimeFormat::utcNow(),
+ 'url' => $contact->statusnet_profile_url,
+ 'nurl' => Strings::normaliseLink($contact->statusnet_profile_url),
+ 'addr' => statusnet_address($contact),
+ 'name' => $contact->name,
+ 'nick' => $contact->screen_name,
+ 'location' => $contact->location,
+ 'about' => $contact->description
+ ], ['id' => $contact_record['id']]);
}
}
- return $r[0]["id"];
+ return $contact_record["id"];
}
function statusnet_fetchuser(App $a, $uid, $screen_name = "", $user_id = "")
$cb->setConsumerKey($ckey, $csecret);
$cb->setToken($otoken, $osecret);
- $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
- intval($uid));
-
- if (DBA::isResult($r)) {
- $self = $r[0];
- } else {
+ $self = Contact::selectFirst([], ['self' => true, 'uid' => $uid]);
+ if (!DBA::isResult($self)) {
return;
}
function statusnet_createpost(App $a, $uid, $post, $self, $create_user, $only_existing_contact)
{
- Logger::log("statusnet_createpost: start", Logger::DEBUG);
+ Logger::info("statusnet_createpost: start");
$api = DI::pConfig()->get($uid, 'statusnet', 'baseapi');
$hostname = preg_replace("=https?://([\w\.]*)/.*=ism", "$1", $api);
$postarray['uri'] = $hostname . "::" . $content->id;
- if (Item::exists(['extid' => $postarray['uri'], 'uid' => $uid])) {
+ if (Post::exists(['extid' => $postarray['uri'], 'uid' => $uid])) {
return [];
}
$contactid = 0;
if (!empty($content->in_reply_to_status_id)) {
+ $thr_parent = $hostname . "::" . $content->in_reply_to_status_id;
- $parent = $hostname . "::" . $content->in_reply_to_status_id;
-
- $fields = ['uri', 'parent-uri', 'parent'];
- $item = Item::selectFirst($fields, ['uri' => $parent, 'uid' => $uid]);
-
+ $item = Post::selectFirst(['uri'], ['uri' => $thr_parent, 'uid' => $uid]);
if (!DBA::isResult($item)) {
- $item = Item::selectFirst($fields, ['extid' => $parent, 'uid' => $uid]);
+ $item = Post::selectFirst(['uri'], ['extid' => $thr_parent, 'uid' => $uid]);
}
if (DBA::isResult($item)) {
$postarray['thr-parent'] = $item['uri'];
- $postarray['parent-uri'] = $item['parent-uri'];
- $postarray['parent'] = $item['parent'];
$postarray['object-type'] = Activity\ObjectType::COMMENT;
} else {
- $postarray['thr-parent'] = $postarray['uri'];
- $postarray['parent-uri'] = $postarray['uri'];
$postarray['object-type'] = Activity\ObjectType::NOTE;
}
$own_url = DI::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 (DBA::isResult($r)) {
- $contactid = $r[0]["id"];
+ $self = DBA::selectFirst([], ['self' => true, 'uid' => $uid]);
+ if (DBA::isResult($self)) {
+ $contactid = $self["id"];
- $postarray['owner-name'] = $r[0]["name"];
- $postarray['owner-link'] = $r[0]["url"];
- $postarray['owner-avatar'] = $r[0]["photo"];
+ $postarray['owner-name'] = $self["name"];
+ $postarray['owner-link'] = $self["url"];
+ $postarray['owner-avatar'] = $self["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\ObjectType::NOTE;
}
$postarray["coord"] = $content->coordinates->coordinates[1] . " " . $content->coordinates->coordinates[0];
}
- Logger::log("statusnet_createpost: end", Logger::DEBUG);
+ Logger::info("statusnet_createpost: end");
return $postarray;
}
// "create_user" is deactivated, since currently you cannot add users manually by now
$create_user = true;
- Logger::log("statusnet_fetchhometimeline: Fetching for user " . $uid, Logger::DEBUG);
+ Logger::info("statusnet_fetchhometimeline: Fetching for user " . $uid);
$connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
return;
}
- $r = q("SELECT * FROM `contact` WHERE `id` = %d AND `uid` = %d LIMIT 1",
- intval($own_contact),
- intval($uid));
-
- if (DBA::isResult($r)) {
- $nick = $r[0]["nick"];
+ $contact = Contact::selectFirst([], ['id' => $own_contact, 'uid' => $uid]);
+ if (DBA::isResult($contact)) {
+ $nick = $contact["nick"];
} else {
- Logger::log("statusnet_fetchhometimeline: Own GNU Social contact not found for user " . $uid, Logger::DEBUG);
+ Logger::info("statusnet_fetchhometimeline: Own GNU Social contact not found for user " . $uid);
return;
}
- $r = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1",
- intval($uid));
-
- if (DBA::isResult($r)) {
- $self = $r[0];
- } else {
- Logger::log("statusnet_fetchhometimeline: Own contact not found for user " . $uid, Logger::DEBUG);
+ $self = Contact::selectFirst([], ['self' => true, 'uid' => $uid]);
+ if (!DBA::isResult($self)) {
+ Logger::info("statusnet_fetchhometimeline: Own contact not found for user " . $uid);
return;
}
- $u = q("SELECT * FROM user WHERE uid = %d LIMIT 1",
- intval($uid));
- if (!DBA::isResult($u)) {
- Logger::log("statusnet_fetchhometimeline: Own user not found for user " . $uid, Logger::DEBUG);
+ $user = User::getById($uid);
+ if (!DBA::isResult($user)) {
+ Logger::info("statusnet_fetchhometimeline: Own user not found for user " . $uid);
return;
}
$errormsg = "Unknown error";
}
- Logger::log("statusnet_fetchhometimeline: Error fetching home timeline: " . $errormsg, Logger::DEBUG);
+ Logger::info("statusnet_fetchhometimeline: Error fetching home timeline: " . $errormsg);
return;
}
$posts = array_reverse($items);
- Logger::log("statusnet_fetchhometimeline: Fetching timeline for user " . $uid . " " . sizeof($posts) . " items", Logger::DEBUG);
+ Logger::info("statusnet_fetchhometimeline: Fetching timeline for user " . $uid . " " . sizeof($posts) . " items");
if (count($posts)) {
foreach ($posts as $post) {
$item = Item::insert($postarray);
$postarray["id"] = $item;
- Logger::log('statusnet_fetchhometimeline: User ' . $self["nick"] . ' posted home timeline item ' . $item);
+ Logger::notice('statusnet_fetchhometimeline: User ' . $self["nick"] . ' posted home timeline item ' . $item);
}
}
}
$items = $connection->get('statuses/mentions_timeline', $parameters);
if (!is_array($items)) {
- Logger::log("statusnet_fetchhometimeline: Error fetching mentions: " . print_r($items, true), Logger::DEBUG);
+ Logger::info("statusnet_fetchhometimeline: Error fetching mentions: " . print_r($items, true));
return;
}
$posts = array_reverse($items);
- Logger::log("statusnet_fetchhometimeline: Fetching mentions for user " . $uid . " " . sizeof($posts) . " items", Logger::DEBUG);
+ Logger::info("statusnet_fetchhometimeline: Fetching mentions for user " . $uid . " " . sizeof($posts) . " items");
if (count($posts)) {
foreach ($posts as $post) {
$item = Item::insert($postarray);
- Logger::log('statusnet_fetchhometimeline: User ' . $self["nick"] . ' posted mention timeline item ' . $item);
+ Logger::notice('statusnet_fetchhometimeline: User ' . $self["nick"] . ' posted mention timeline item ' . $item);
}
}
}
$item = Item::insert($postarray);
$postarray["id"] = $item;
- Logger::log('statusnet_complete_conversation: User ' . $self["nick"] . ' posted home timeline item ' . $item);
+ Logger::notice('statusnet_complete_conversation: User ' . $self["nick"] . ' posted home timeline item ' . $item);
}
}
}
foreach ($matches AS $match) {
$search = "[url=" . $match[1] . "]" . $match[2] . "[/url]";
- Logger::log("statusnet_convertmsg: expanding url " . $match[1], Logger::DEBUG);
+ Logger::info("statusnet_convertmsg: expanding url " . $match[1]);
- $expanded_url = Network::finalUrl($match[1]);
+ try {
+ $expanded_url = DI::httpClient()->finalUrl($match[1]);
+ } catch (TransferException $exception) {
+ Logger::notice('statusnet_convertmsg: Couldn\'t get final URL.', ['url' => $match[1], 'exception' => $exception]);
+ $expanded_url = $match[1];
+ }
- Logger::log("statusnet_convertmsg: fetching data for " . $expanded_url, Logger::DEBUG);
+ Logger::info("statusnet_convertmsg: fetching data for " . $expanded_url);
$oembed_data = OEmbed::fetchURL($expanded_url, true);
- Logger::log("statusnet_convertmsg: fetching data: done", Logger::DEBUG);
+ Logger::info("statusnet_convertmsg: fetching data: done");
if ($type == "") {
$type = $oembed_data->type;
} elseif ($oembed_data->type != "link") {
$body = str_replace($search, "[url=" . $expanded_url . "]" . $expanded_url . "[/url]", $body);
} else {
- $img_str = Network::fetchUrl($expanded_url, true, 4);
+ $img_str = DI::httpClient()->fetch($expanded_url, 4);
$tempfile = tempnam(get_temppath(), "cache");
file_put_contents($tempfile, $img_str);
}
if ($footerurl != "") {
- $footer = add_page_info($footerurl);
+ $footer = "\n" . PageInfo::getFooterFromUrl($footerurl);
}
if (($footerlink != "") && (trim($footer) != "")) {
$contact_id = statusnet_fetch_contact($uid, $user, true);
} else {
- $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `alias` = '%s' LIMIT 1",
- intval($uid), DBA::escape($own_url));
- if (DBA::isResult($r)) {
- $contact_id = $r[0]["id"];
+ $contact = Contact::selectFirst([], ['uid' => $uid, 'alias' => $own_url]);
+ if (DBA::isResult($contact)) {
+ $contact_id = $contact["id"];
} else {
DI::pConfig()->delete($uid, 'statusnet', 'own_url');
}
return false;
}
- Logger::log('statusnet_is_retweet: Retweeting id ' . $id . ' for user ' . $uid, Logger::DEBUG);
+ Logger::info('statusnet_is_retweet: Retweeting id ' . $id . ' for user ' . $uid);
$connection = new StatusNetOAuth($api, $ckey, $csecret, $otoken, $osecret);
$result = $connection->post('statuses/retweet/' . $id);
- Logger::log('statusnet_is_retweet: result ' . print_r($result, true), Logger::DEBUG);
+ Logger::info('statusnet_is_retweet: result ' . print_r($result, true));
return isset($result->id);
}
projects / friendica-addons.git / blobdiff