diff --git a/ifttt/ifttt.php b/ifttt/ifttt.php index 5021a63ed..a0cc1ae80 100644 --- a/ifttt/ifttt.php +++ b/ifttt/ifttt.php @@ -6,7 +6,6 @@ * Version: 0.1 * Author: Michael Vogel */ -require_once 'mod/item.php'; use Friendica\App; use Friendica\Content\PageInfo; use Friendica\Core\Hook; @@ -15,6 +14,7 @@ use Friendica\Core\Protocol; use Friendica\Database\DBA; use Friendica\DI; use Friendica\Model\Item; +use Friendica\Model\Post; use Friendica\Util\Strings; function ifttt_install() @@ -161,25 +161,16 @@ function ifttt_message($uid, $item) { $a = DI::app(); - $_SESSION['authenticated'] = true; - $_SESSION['uid'] = $uid; - - unset($_REQUEST); - $_REQUEST['api_source'] = true; - $_REQUEST['profile_uid'] = $uid; - $_REQUEST['source'] = 'IFTTT'; - $_REQUEST['title'] = ''; - $_REQUEST['body'] = $item['msg']; - //$_REQUEST['date'] = $item['date']; - //$_REQUEST['uri'] = $item['url']; - - if (!empty($item['url']) && strstr($item['url'], 'facebook.com')) { - $hash = hash('ripemd128', $item['url']); - $_REQUEST['extid'] = Protocol::FACEBOOK; - $_REQUEST['message_id'] = Item::newURI($uid, Protocol::FACEBOOK . ':' . $hash); - } + $post = []; + $post['uid'] = $uid; + $post['app'] = 'IFTTT'; + $post['title'] = ''; + $post['body'] = $item['msg']; + //$post['date'] = $item['date']; + //$post['uri'] = $item['url']; if ($item['type'] == 'link') { + $link = $item['link']; $data = PageInfo::queryUrl($item['link']); if (isset($item['title']) && (trim($item['title']) != '')) { @@ -190,10 +181,15 @@ function ifttt_message($uid, $item) $data['text'] = $item['description']; } - $_REQUEST['body'] .= "\n" . PageInfo::getFooterFromData($data); + $post['body'] .= "\n" . PageInfo::getFooterFromData($data); } elseif (($item['type'] == 'photo') && ($item['image'] != '')) { - $_REQUEST['body'] .= "\n\n[img]" . $item['image'] . "[/img]\n"; + $link = $item['image']; + $post['body'] .= "\n\n[img]" . $item['image'] . "[/img]\n"; + } elseif (!empty($item['url'])) { + $link = $item['url']; + } else { + $link = hash('ripemd128', $item['msg']); } - item_post($a); + Post\Delayed::add($link, $post, PRIORITY_MEDIUM, true); } diff --git a/twitter/twitter.php b/twitter/twitter.php index 52ff7ae48..42986d162 100644 --- a/twitter/twitter.php +++ b/twitter/twitter.php @@ -83,6 +83,7 @@ use Friendica\Model\Group; use Friendica\Model\Item; use Friendica\Model\ItemContent; use Friendica\Model\ItemURI; +use Friendica\Model\Post; use Friendica\Model\Tag; use Friendica\Model\User; use Friendica\Protocol\Activity; @@ -1004,11 +1005,8 @@ function twitter_parse_link(App $a, array &$b) */ function twitter_do_mirrorpost(App $a, $uid, $post) { - $datarray['api_source'] = true; - $datarray['profile_uid'] = $uid; + $datarray['uid'] = $uid; $datarray['extid'] = 'twitter::' . $post->id; - $datarray['protocol'] = Conversation::PARCEL_TWITTER; - $datarray['source'] = json_encode($post); $datarray['title'] = ''; if (!empty($post->retweeted_status)) { @@ -1038,7 +1036,7 @@ function twitter_do_mirrorpost(App $a, $uid, $post) $datarray['body'] = $item['body']; } - $datarray['source'] = $item['app']; + $datarray['app'] = $item['app']; $datarray['verb'] = $item['verb']; if (isset($item['location'])) { @@ -1066,11 +1064,16 @@ function twitter_fetchtimeline(App $a, $uid) $application_name = DI::baseUrl()->getHostname(); } - require_once 'mod/item.php'; - require_once 'mod/share.php'; - $connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret); + // Ensure to have the own contact + try { + twitter_fetch_own_contact($a, $uid); + } catch (TwitterOAuthException $e) { + Logger::warning('Error fetching own contact', ['uid' => $uid, 'message' => $e->getMessage()]); + return; + } + $parameters = ["exclude_replies" => true, "trim_user" => false, "contributor_details" => true, "include_rts" => true, "tweet_mode" => "extended", "include_ext_alt_text" => true]; $first_time = ($lastid == ""); @@ -1107,20 +1110,17 @@ function twitter_fetchtimeline(App $a, $uid) } if (!stristr($post->source, $application_name)) { - $_SESSION["authenticated"] = true; - $_SESSION["uid"] = $uid; - Logger::info('Preparing mirror post', ['twitter-id' => $post->id_str, 'uid' => $uid]); - $_REQUEST = twitter_do_mirrorpost($a, $uid, $post); + $mirrorpost = twitter_do_mirrorpost($a, $uid, $post); - if (empty($_REQUEST['body'])) { + if (empty($mirrorpost['body'])) { continue; } - Logger::info('Posting mirror post ', ['twitter-id' => $post->id_str, 'uid' => $uid]); + Logger::info('Posting mirror post', ['twitter-id' => $post->id_str, 'uid' => $uid]); - item_post($a); + Post\Delayed::add($mirrorpost['extid'], $mirrorpost, PRIORITY_MEDIUM, true); } } } @@ -1237,12 +1237,16 @@ function twitter_fetch_contact($uid, $data, $create_user) if (!empty($cid)) { DBA::update('contact', $fields, ['id' => $cid]); Contact::updateAvatar($cid, $avatar); + } else { + Logger::warning('No contact found', ['fields' => $fields]); } $contact = DBA::selectFirst('contact', [], ['uid' => $uid, 'alias' => "twitter::" . $data->id_str]); - if (!DBA::isResult($contact) && !$create_user) { + if (!DBA::isResult($contact) && empty($cid)) { Logger::warning('User contact not found', ['uid' => $uid, 'twitter-id' => $data->id_str]); return 0; + } elseif (!$create_user) { + return $cid; } if (!DBA::isResult($contact)) {