Tumblr: Fix #11551 and introduce NPF

Reviewed-on: friendica/friendica-addons#1361

blockbot/blockbot.php

@@ -8,9 +8,7 @@
  *
  */
 
-use Friendica\App;
 use Friendica\Core\Hook;
-use Friendica\Core\System;
 use Friendica\DI;
 use Jaybizzle\CrawlerDetect\CrawlerDetect;
 use Friendica\Core\Logger;
@@ -52,12 +50,15 @@ function blockbot_init_1()
 	$logdata = ['agent' => $_SERVER['HTTP_USER_AGENT'], 'uri' => $_SERVER['REQUEST_URI']];
 
 	// List of "good" crawlers
-	$good_agents = ['fediverse.space crawler', 'fediverse.network crawler', 'Active_Pods_CheckBot_3.0',
+	$good_agents = [
+		'fediverse.space crawler', 'fediverse.network crawler', 'Active_Pods_CheckBot_3.0',
 		'Social-Relay/', 'Test Certificate Info', 'Uptimebot/', 'GNUSocialBot', 'UptimeRobot/',
-		'PTST/', 'Zabbix', 'Poduptime/'];
+		'PTST/', 'Zabbix', 'Poduptime/'
+	];
 
 	// List of known crawlers.
-	$agents = ['SemrushBot', 's~feedly-nikon3', 'Qwantify/Bleriot/', 'ltx71', 'Sogou web spider/',
+	$agents = [
+		'SemrushBot', 's~feedly-nikon3', 'Qwantify/Bleriot/', 'ltx71', 'Sogou web spider/',
 		'Diffbot/', 'Twitterbot/', 'YisouSpider', 'evc-batch/', 'LivelapBot/', 'TrendsmapResolver/',
 		'PaperLiBot/', 'Nuzzel', 'um-LN/', 'Google Favicon', 'Datanyze', 'BLEXBot/', '360Spider',
 		'adscanner/', 'HeadlessChrome', 'wpif', 'startmebot/', 'Googlebot/', 'Applebot/',
@@ -79,7 +80,8 @@ function blockbot_init_1()
 		'Google-Apps-Script; beanserver;', 'woorankreview/', 'Seekport Crawler;', 'AHC/',
 		'SkypeUriPreview Preview/', 'Semanticbot/', 'Embed PHP library', 'XoviOnpageCrawler;',
 		'GetHPinfo.com-Bot/', 'BoardReader Favicon Fetcher', 'Google-Adwords-Instant', 'newspaper/',
-		'YurichevBot/', 'Crawling at Home Project', 'InfoTigerBot/'];
+		'YurichevBot/', 'Crawling at Home Project', 'InfoTigerBot/'
+	];
 
 	if (!DI::config()->get('blockbot', 'good_crawlers')) {
 		$agents = array_merge($agents, $good_agents);
@@ -114,7 +116,8 @@ function blockbot_init_1()
 	}
 
 	// List of false positives' strings of known "good" agents.
-	$agents = ['curl', 'zgrab', 'Go-http-client', 'curb', 'github.com', 'reqwest', 'Feedly/',
+	$agents = [
+		'curl', 'zgrab', 'Go-http-client', 'curb', 'github.com', 'reqwest', 'Feedly/',
 		'Python-urllib/', 'Liferea/', 'aiohttp/', 'WordPress.com Reader', 'hackney/',
 		'Faraday v', 'okhttp', 'UniversalFeedParser', 'PixelFedBot', 'python-requests',
 		'WordPress/', 'http.rb/', 'Apache-HttpClient/', 'WordPress.com;', 'Pleroma',
@@ -122,7 +125,8 @@ function blockbot_init_1()
 		'lua-resty-http/', 'Tiny Tiny RSS/', 'Wget/', 'PostmanRuntime/',
 		'W3C_Validator/', 'NetNewsWire', 'FeedValidator/', 'theoldreader.com', 'axios/',
 		'Paw/', 'PeerTube/', 'fedi.inex.dev', 'FediDB/', 'index.community crawler',
-		'Slackbot-LinkExpanding'];
+		'Slackbot-LinkExpanding'
+	];
 
 	if (DI::config()->get('blockbot', 'good_crawlers')) {
 		$agents = array_merge($agents, $good_agents);
@@ -130,11 +134,11 @@ function blockbot_init_1()
 
 	foreach ($agents as $agent) {
 		if (stristr($_SERVER['HTTP_USER_AGENT'], $agent)) {
-			logger::notice('False positive', $logdata);
+			logger::info('False positive', $logdata);
 			return;
 		}
 	}
 
-	logger::info('Blocked bot', $logdata);
+	logger::notice('Blocked bot', $logdata);
 	throw new ForbiddenException('Bots are not allowed');
 }

tumblr/library/tumblroauth.php

@@ -6,6 +6,7 @@
  * The first PHP Library to support OAuth for Tumblr's REST API.  (Originally for Twitter, modified for Tumblr by Lucas)
  */
 
+use Friendica\DI;
 use Friendica\Security\OAuth1\OAuthConsumer;
 use Friendica\Security\OAuth1\OAuthRequest;
 use Friendica\Security\OAuth1\Signature\OAuthSignatureMethod_HMAC_SHA1;
@@ -17,301 +18,91 @@ use Friendica\Security\OAuth1\OAuthUtil;
  */
 class TumblrOAuth
 {
-	/* Set up the API root URL. */
-	public $host = "https://api.tumblr.com/v2/";
-	/* Set timeout default. */
-	public $timeout = 30;
-	/* Set connect timeout. */
-	public $connecttimeout = 30;
-	/* Verify SSL Cert. */
-	public $ssl_verifypeer = FALSE;
-	/* Response format. */
-	public $format = 'json';
-	/* Decode returned json data. */
-	public $decode_json = TRUE;
-	/* Set the useragent. */
-	public $useragent = 'TumblrOAuth v0.2.0-beta2';
-
 	/* Contains the last HTTP status code returned. */
 	public $http_code;
-	/* Contains the last API call. */
-	public $url;
-	/**
-	 * Contains the last HTTP headers returned.
-	 * @var array
-	 */
-	public $http_header;
-	/**
-	 * Contains the last HTTP request info
-	 * @var string
-	 */
-	public $http_info;
 
-	/** @var OAuthToken */
-	private $token;
 	/** @var OAuthConsumer */
 	private $consumer;
 	/** @var \Friendica\Security\OAuth1\Signature\OAuthSignatureMethod_HMAC_SHA1 */
 	private $sha1_method;
 
-	/**
+	// API URLs
-	 * Set API URLS
+	const accessTokenURL  = 'https://www.tumblr.com/oauth/access_token';
-	 */
+	const authorizeURL    = 'https://www.tumblr.com/oauth/authorize';
-	function accessTokenURL()
+	const requestTokenURL = 'https://www.tumblr.com/oauth/request_token';
-	{
-		return 'https://www.tumblr.com/oauth/access_token';
-	}
 
-	function authenticateURL()
+	function __construct(string $consumer_key, string $consumer_secret)
-	{
-		return 'https://www.tumblr.com/oauth/authorize';
-	}
-
-	function authorizeURL()
-	{
-		return 'https://www.tumblr.com/oauth/authorize';
-	}
-
-	function requestTokenURL()
-	{
-		return 'https://www.tumblr.com/oauth/request_token';
-	}
-
-	function __construct($consumer_key, $consumer_secret, $oauth_token = null, $oauth_token_secret = null)
 	{
 		$this->sha1_method = new OAuthSignatureMethod_HMAC_SHA1();
-		$this->consumer = new OAuthConsumer($consumer_key, $consumer_secret);
+		$this->consumer    = new OAuthConsumer($consumer_key, $consumer_secret);
-		if (!empty($oauth_token) && !empty($oauth_token_secret)) {
-			$this->token = new OAuthToken($oauth_token, $oauth_token_secret);
-		} else {
-			$this->token = null;
-		}
 	}
 
 	/**
 	 * Get a request_token from Tumblr
 	 *
-	 * @param callback $oauth_callback
+	 * @param string $oauth_callback
 	 * @return array
 	 */
-	function getRequestToken($oauth_callback = null)
+	function getRequestToken(string $oauth_callback): array
 	{
-		$parameters = [];
+		$request = $this->oAuthRequest(self::requestTokenURL, ['oauth_callback' => $oauth_callback]);
-		if (!empty($oauth_callback)) {
+		return OAuthUtil::parse_parameters($request);
-			$parameters['oauth_callback'] = $oauth_callback;
-		}
-
-		$request = $this->oAuthRequest($this->requestTokenURL(), 'GET', $parameters);
-		$token = OAuthUtil::parse_parameters($request);
-		$this->token = new OAuthToken($token['oauth_token'], $token['oauth_token_secret']);
-		return $token;
 	}
 
 	/**
 	 * Get the authorize URL
 	 *
-	 * @param array $token
+	 * @param string $oauth_token
-	 * @param bool $sign_in_with_tumblr
 	 * @return string
 	 */
-	function getAuthorizeURL($token, $sign_in_with_tumblr = TRUE)
+	function getAuthorizeURL(string $oauth_token): string
 	{
-		if (is_array($token)) {
+		return self::authorizeURL . "?oauth_token={$oauth_token}";
-			$token = $token['oauth_token'];
-		}
-
-		if (empty($sign_in_with_tumblr)) {
-			return $this->authorizeURL() . "?oauth_token={$token}";
-		} else {
-			return $this->authenticateURL() . "?oauth_token={$token}";
-		}
 	}
 
 	/**
 	 * Exchange request token and secret for an access token and
 	 * secret, to sign API calls.
 	 *
-	 * @param bool $oauth_verifier
+	 * @param string $oauth_verifier
+	 * @param string $request_token
+	 * @param string $request_token_secret
 	 * @return array ("oauth_token" => "the-access-token",
 	 *                "oauth_token_secret" => "the-access-secret",
 	 *                "user_id" => "9436992",
 	 *                "screen_name" => "abraham")
 	 */
-	function getAccessToken($oauth_verifier = FALSE)
+	function getAccessToken(string $oauth_verifier, string $request_token, string $request_token_secret): array
 	{
+		$token = new OAuthToken($request_token, $request_token_secret);
+
 		$parameters = [];
 		if (!empty($oauth_verifier)) {
 			$parameters['oauth_verifier'] = $oauth_verifier;
 		}
 
-		$request = $this->oAuthRequest($this->accessTokenURL(), 'GET', $parameters);
+		$request = $this->oAuthRequest(self::accessTokenURL, $parameters, $token);
-		$token = OAuthUtil::parse_parameters($request);
+		return OAuthUtil::parse_parameters($request);
-		$this->token = new OAuthToken($token['oauth_token'], $token['oauth_token_secret']);
-
-		return $token;
-	}
-
-	/**
-	 * One time exchange of username and password for access token and secret.
-	 *
-	 * @param string $username
-	 * @param string $password
-	 * @return array ("oauth_token" => "the-access-token",
-	 *                "oauth_token_secret" => "the-access-secret",
-	 *                "user_id" => "9436992",
-	 *                "screen_name" => "abraham",
-	 *                "x_auth_expires" => "0")
-	 */
-	function getXAuthToken($username, $password)
-	{
-		$parameters = [];
-		$parameters['x_auth_username'] = $username;
-		$parameters['x_auth_password'] = $password;
-		$parameters['x_auth_mode'] = 'client_auth';
-		$request = $this->oAuthRequest($this->accessTokenURL(), 'POST', $parameters);
-		$token = OAuthUtil::parse_parameters($request);
-		$this->token = new OAuthToken($token['oauth_token'], $token['oauth_token_secret']);
-
-		return $token;
-	}
-
-	/**
-	 * GET wrapper for oAuthRequest.
-	 *
-	 * @param string $url
-	 * @param array $parameters
-	 * @return mixed|string
-	 */
-	function get($url, $parameters = [])
-	{
-		$response = $this->oAuthRequest($url, 'GET', $parameters);
-		if ($this->format === 'json' && $this->decode_json) {
-			return json_decode($response);
-		}
-
-		return $response;
-	}
-
-	/**
-	 * POST wrapper for oAuthRequest.
-	 *
-	 * @param string $url
-	 * @param array $parameters
-	 * @return mixed|string
-	 */
-	function post($url, $parameters = [])
-	{
-		$response = $this->oAuthRequest($url, 'POST', $parameters);
-		if ($this->format === 'json' && $this->decode_json) {
-			return json_decode($response);
-		}
-
-		return $response;
-	}
-
-	/**
-	 * DELETE wrapper for oAuthReqeust.
-	 *
-	 * @param string $url
-	 * @param array $parameters
-	 * @return mixed|string
-	 */
-	function delete($url, $parameters = [])
-	{
-		$response = $this->oAuthRequest($url, 'DELETE', $parameters);
-		if ($this->format === 'json' && $this->decode_json) {
-			return json_decode($response);
-		}
-
-		return $response;
 	}
 
 	/**
 	 * Format and sign an OAuth / API request
 	 *
-	 * @param string $url
+	 * @param string     $url
-	 * @param string $method
+	 * @param array      $parameters
-	 * @param array $parameters
+	 * @param OAuthToken $token $name
-	 * @return mixed|string
+	 * @return string
 	 */
-	function oAuthRequest($url, $method, $parameters)
+	private function oAuthRequest(string $url, array $parameters, OAuthToken $token = null): string
 	{
-		if (strrpos($url, 'https://') !== 0 && strrpos($url, 'http://') !== 0) {
+		$request = OAuthRequest::from_consumer_and_token($this->consumer, 'GET', $url, $parameters, $token);
-			$url = "{$this->host}{$url}";
+		$request->sign_request($this->sha1_method, $this->consumer, $token);
+
+		$curlResult = DI::httpClient()->get($request->to_url());
+		$this->http_code = $curlResult->getReturnCode();
+		if ($curlResult->isSuccess()) {
+			return $curlResult->getBody();
 		}
-
+		return '';
-		$request = OAuthRequest::from_consumer_and_token($this->consumer, $method, $url, $parameters, $this->token);
-		$request->sign_request($this->sha1_method, $this->consumer, $this->token);
-		switch ($method) {
-			case 'GET':
-				return $this->http($request->to_url(), 'GET');
-			default:
-				return $this->http($request->get_normalized_http_url(), $method, $request->to_postdata());
-		}
-	}
-
-	/**
-	 * Make an HTTP request
-	 *
-	 * @param string $url
-	 * @param string $method
-	 * @param mixed  $postfields
-	 * @return string API results
-	 */
-	function http($url, $method, $postfields = null)
-	{
-		$this->http_info = [];
-		$ci = curl_init();
-		/* Curl settings */
-		curl_setopt($ci, CURLOPT_USERAGENT, $this->useragent);
-		curl_setopt($ci, CURLOPT_CONNECTTIMEOUT, $this->connecttimeout);
-		curl_setopt($ci, CURLOPT_TIMEOUT, $this->timeout);
-		curl_setopt($ci, CURLOPT_RETURNTRANSFER, TRUE);
-		curl_setopt($ci, CURLOPT_HTTPHEADER, array('Expect:'));
-		curl_setopt($ci, CURLOPT_SSL_VERIFYPEER, $this->ssl_verifypeer);
-		curl_setopt($ci, CURLOPT_HEADERFUNCTION, array($this, 'getHeader'));
-		curl_setopt($ci, CURLOPT_HEADER, FALSE);
-
-		switch ($method) {
-			case 'POST':
-				curl_setopt($ci, CURLOPT_POST, TRUE);
-				if (!empty($postfields)) {
-					curl_setopt($ci, CURLOPT_POSTFIELDS, $postfields);
-				}
-				break;
-			case 'DELETE':
-				curl_setopt($ci, CURLOPT_CUSTOMREQUEST, 'DELETE');
-				if (!empty($postfields)) {
-					$url = "{$url}?{$postfields}";
-				}
-		}
-
-		curl_setopt($ci, CURLOPT_URL, $url);
-		$response = curl_exec($ci);
-		$this->http_code = curl_getinfo($ci, CURLINFO_HTTP_CODE);
-		$this->http_info = array_merge($this->http_info, curl_getinfo($ci));
-		$this->url = $url;
-		curl_close($ci);
-
-		return $response;
-	}
-
-	/**
-	 * Get the header info to store.
-	 *
-	 * @param resource $ch
-	 * @param string $header
-	 * @return int
-	 */
-	function getHeader($ch, $header)
-	{
-		$i = strpos($header, ':');
-		if (!empty($i)) {
-			$key = str_replace('-', '_', strtolower(substr($header, 0, $i)));
-			$value = trim(substr($header, $i + 2));
-			$this->http_header[$key] = $value;
-		}
-
-		return strlen($header);
 	}
 }

tumblr/tumblr.php

@@ -10,13 +10,21 @@
 require_once __DIR__ . DIRECTORY_SEPARATOR . 'library' . DIRECTORY_SEPARATOR . 'tumblroauth.php';
 
 use Friendica\Content\Text\BBCode;
+use Friendica\Content\Text\NPF;
 use Friendica\Core\Hook;
 use Friendica\Core\Logger;
 use Friendica\Core\Renderer;
 use Friendica\DI;
 use Friendica\Model\Item;
+use Friendica\Model\Photo;
 use Friendica\Model\Post;
 use Friendica\Model\Tag;
+use Friendica\Util\DateTimeFormat;
+use Friendica\Util\Network;
+use GuzzleHttp\Client;
+use GuzzleHttp\Exception\RequestException;
+use GuzzleHttp\HandlerStack;
+use GuzzleHttp\Subscriber\Oauth\Oauth1;
 
 function tumblr_install()
 {
@@ -107,14 +115,14 @@ function tumblr_connect()
 	$request_token = $tum_oauth->getRequestToken($callback_url);
 
 	// Store the request token and Request Token Secret as out callback.php script will need this
-	$_SESSION['request_token'] = $token = $request_token['oauth_token'];
+	DI::session()->set('request_token', $request_token['oauth_token']);
-	$_SESSION['request_token_secret'] = $request_token['oauth_token_secret'];
+	DI::session()->set('request_token_secret', $request_token['oauth_token_secret']);
 
 	// Check the HTTP Code.  It should be a 200 (OK), if it's anything else then something didn't work.
 	switch ($tum_oauth->http_code) {
 		case 200:
 			// Ask Tumblr to give us a special address to their login page
-			$url = $tum_oauth->getAuthorizeURL($token);
+			$url = $tum_oauth->getAuthorizeURL($request_token['oauth_token']);
 
 			// Redirect the user to the login URL given to us by Tumblr
 			header('Location: ' . $url);
@@ -141,7 +149,7 @@ function tumblr_callback()
 	session_start();
 
 	// Define the needed keys
-	$consumer_key = DI::config()->get('tumblr', 'consumer_key');
+	$consumer_key    = DI::config()->get('tumblr', 'consumer_key');
 	$consumer_secret = DI::config()->get('tumblr', 'consumer_secret');
 
 	// Once the user approves your app at Tumblr, they are sent back to this script.
@@ -151,14 +159,14 @@ function tumblr_callback()
 
 	// Create instance of TumblrOAuth.
 	// It'll need our Consumer Key and Secret as well as our Request Token and Secret
-	$tum_oauth = new TumblrOAuth($consumer_key, $consumer_secret, $_SESSION['request_token'], $_SESSION['request_token_secret']);
+	$tum_oauth = new TumblrOAuth($consumer_key, $consumer_secret);
 
 	// Ok, let's get an Access Token. We'll need to pass along our oauth_verifier which was given to us in the URL.
-	$access_token = $tum_oauth->getAccessToken($_REQUEST['oauth_verifier']);
+	$access_token = $tum_oauth->getAccessToken($_REQUEST['oauth_verifier'], DI::session()->get('request_token'), DI::session()->get('request_token_secret'));
 
 	// We're done with the Request Token and Secret so let's remove those.
-	unset($_SESSION['request_token']);
+	DI::session()->remove('request_token');
-	unset($_SESSION['request_token_secret']);
+	DI::session()->remove('request_token_secret');
 
 	// Make sure nothing went wrong.
 	if (200 == $tum_oauth->http_code) {
@@ -212,14 +220,20 @@ function tumblr_settings(array &$data)
 		$consumer_key    = DI::config()->get('tumblr', 'consumer_key');
 		$consumer_secret = DI::config()->get('tumblr', 'consumer_secret');
 
-		$tum_oauth = new TumblrOAuth($consumer_key, $consumer_secret, $oauth_token, $oauth_token_secret);
+		$blogs = [];
-		$userinfo  = $tum_oauth->get('user/info');
 
-		$blogs = array_map(function ($blog) {
+		$connection = tumblr_client($consumer_key, $consumer_secret, $oauth_token, $oauth_token_secret);
-			return substr(str_replace(['http://', 'https://'], ['', ''], $blog->url), 0, -1);
+		if ($connection) {
-		}, $userinfo->response->user->blogs);
+			$userinfo = tumblr_get($connection, 'user/info');
+			if (!empty($userinfo['success'])) {
+				foreach ($userinfo['data']->response->user->blogs as $blog) {
+					$url = parse_url($blog->url, PHP_URL_HOST);
+					$blogs[$url] = $url;
+				}
+			}
+		}
 
-		$page_select = ['tumblr-page', DI::l10n()->t('Post to page:'), $page, '', $blogs];
+		$page_select = ['tumblr_page', DI::l10n()->t('Post to page:'), $page, '', $blogs];
 	}
 
 	$t    = Renderer::getMarkupTemplate('connector_settings.tpl', 'addon/tumblr/');
@@ -308,7 +322,6 @@ function tumblr_post_local(array &$b)
 
 function tumblr_send(array &$b)
 {
-
 	if ($b['deleted'] || $b['private'] || ($b['created'] !== $b['edited'])) {
 		return;
 	}
@@ -321,107 +334,194 @@ function tumblr_send(array &$b)
 		return;
 	}
 
-	$b['body'] = Post\Media::addAttachmentsToBody($b['uri-id'], DI::contentItem()->addSharedPost($b));
+	if (tumblr_send_npf($b)) {
+		return;
+	}
+
+	$connection = tumblr_connection($b['uid']);
+	if (empty($connection)) {
+		return;
+	}
+
+	$b['body'] = BBCode::removeAttachment($b['body']);
+
+	$title = trim($b['title']);
+
+	$media = Post\Media::getByURIId($b['uri-id'], [Post\Media::HTML, Post\Media::AUDIO, Post\Media::VIDEO, Post\Media::IMAGE]);
+
+	$photo = array_search(Post\Media::IMAGE, array_column($media, 'type'));
+	$link  = array_search(Post\Media::HTML, array_column($media, 'type'));
+	$audio = array_search(Post\Media::AUDIO, array_column($media, 'type'));
+	$video = array_search(Post\Media::VIDEO, array_column($media, 'type'));
+
+	$params = [
+		'state'  => 'published',
+		'tags'   => implode(',', array_column(Tag::getByURIId($b['uri-id']), 'name')),
+		'tweet'  => 'off',
+		'format' => 'html',
+	];
+
+	$body = BBCode::removeShareInformation($b['body']);
+	$body = Post\Media::removeFromEndOfBody($body);
+
+	if ($photo !== false) {
+		$params['type'] = 'photo';
+		$params['caption'] = BBCode::convertForUriId($b['uri-id'], $body, BBCode::CONNECTORS);
+		$params['data'] = [];
+		foreach ($media as $photo) {
+			if ($photo['type'] == Post\Media::IMAGE) {
+				if (Network::isLocalLink($photo['url']) && ($data = Photo::getResourceData($photo['url']))) {
+					$photo = Photo::selectFirst([], ["`resource-id` = ? AND `scale` > ?", $data['guid'], 0]);
+					if (!empty($photo)) {
+						$params['data'][] = Photo::getImageDataForPhoto($photo);
+					}
+				}
+			}
+		}
+	} elseif ($link !== false) {
+		$params['type']        = 'link';
+		$params['title']       = $media[$link]['name'];
+		$params['url']         = $media[$link]['url'];
+		$params['description'] = BBCode::convertForUriId($b['uri-id'], $body, BBCode::CONNECTORS);
+
+		if (!empty($media[$link]['preview'])) {
+			$params['thumbnail'] = $media[$link]['preview'];
+		}
+		if (!empty($media[$link]['description'])) {
+			$params['excerpt'] = $media[$link]['description'];
+		}
+		if (!empty($media[$link]['author-name'])) {
+			$params['author'] = $media[$link]['author-name'];
+		}
+	} elseif ($audio !== false) {
+		$params['type']         = 'audio';
+		$params['external_url'] = $media[$audio]['url'];
+		$params['caption']      = BBCode::convertForUriId($b['uri-id'], $body, BBCode::CONNECTORS);
+	} elseif ($video !== false) {
+		$params['type']    = 'video';
+		$params['embed']   = $media[$video]['url'];
+		$params['caption'] = BBCode::convertForUriId($b['uri-id'], $body, BBCode::CONNECTORS);
+	} else {
+		$params['type']  = 'text';
+		$params['title'] = $title;
+		$params['body']  = BBCode::convertForUriId($b['uri-id'], $b['body'], BBCode::CONNECTORS);
+	}
+
+	if (isset($params['caption']) && (trim($title) != '')) {
+		$params['caption'] = '<h1>' . $title . '</h1>' .
+			'<p>' . $params['caption'] . '</p>';
+	}
 
-	$oauth_token = DI::pConfig()->get($b['uid'], 'tumblr', 'oauth_token');
-	$oauth_token_secret = DI::pConfig()->get($b['uid'], 'tumblr', 'oauth_token_secret');
 	$page = DI::pConfig()->get($b['uid'], 'tumblr', 'page');
-	$tmbl_blog = 'blog/' . $page . '/post';
 
-	if ($oauth_token && $oauth_token_secret && $tmbl_blog) {
+	$result = tumblr_post($connection, 'blog/' . $page . '/post', $params);
-		$tags = Tag::getByURIId($b['uri-id']);
 
-		$tag_arr = [];
+	if ($result['success']) {
-
+		Logger::info('success', ['blog' => $page, 'params' => $params]);
-		foreach ($tags as $tag) {
+		return true;
-			$tag_arr[] = $tag['name'];
+	} else {
-		}
+		Logger::notice('error', ['blog' => $page, 'params' => $params, 'result' => $result['data']]);
-
+		return false;
-		if (count($tag_arr)) {
-			$tags = implode(',', $tag_arr);
-		}
-
-		$title = trim($b['title']);
-
-		$media = Post\Media::getByURIId($b['uri-id'], [Post\Media::HTML, Post\Media::AUDIO, Post\Media::VIDEO, Post\Media::IMAGE]);
-
-		$photo = array_search(Post\Media::IMAGE, array_column($media, 'type'));
-		$link  = array_search(Post\Media::HTML, array_column($media, 'type'));
-		$audio = array_search(Post\Media::AUDIO, array_column($media, 'type'));
-		$video = array_search(Post\Media::VIDEO, array_column($media, 'type'));
-
-		$params = [
-			'state'  => 'published',
-			'tags'   => $tags,
-			'tweet'  => 'off',
-			'format' => 'html',
-		];
-
-		$body = BBCode::removeShareInformation($b['body']);
-
-		if ($photo != false) {
-			$params['type'] = 'photo';
-			if (!empty($body)) {
-				$params['caption'] = BBCode::convertForUriId($b['uri-id'], $body, BBCode::CONNECTORS);
-			} elseif (!empty($params['caption'])) {
-				$params['caption'] = $photo['description'];
-			}
-			$params['source'] = $photo['url'];
-		} elseif ($link != false) {
-			$params['type']        = 'link';
-			$params['title']       = $link['name'];
-			$params['url']         = $link['url'];
-			$params['description'] = BBCode::convertForUriId($b['uri-id'], $body, BBCode::CONNECTORS);
-
-			if (!empty($link['preview'])) {
-				$params['thumbnail'] = $link['preview'];
-			}
-			if (!empty($link['description'])) {
-				$params['excerpt'] = $link['description'];
-			}
-			if (!empty($link['author-name'])) {
-				$params['author'] = $link['author-name'];
-			} elseif (!empty($link['publisher-name'])) {
-				$params['author'] = $link['publisher-name'];
-			}
-		} elseif ($audio != false) {
-			$params['type']         = 'audio';
-			$params['external_url'] = $audio['url'];
-			$params['caption']      = BBCode::convertForUriId($b['uri-id'], $body, BBCode::CONNECTORS);
-		} elseif ($video != false) {
-			$params['type']    = 'video';
-			$params['embed']   = $video['url'];
-			$params['caption'] = BBCode::convertForUriId($b['uri-id'], $body, BBCode::CONNECTORS);
-		} else {
-			$params['type']  = 'text';
-			$params['title'] = $title;
-			$params['body']  = BBCode::convertForUriId($b['uri-id'], $b['body'], BBCode::CONNECTORS);
-		}
-
-		if (isset($params['caption']) && (trim($title) != '')) {
-			$params['caption'] = '<h1>' . $title . '</h1>' .
-				'<p>' . $params['caption'] . '</p>';
-		}
-
-		if (empty($params['caption']) && !empty($siteinfo['description'])) {
-			$params['caption'] = BBCode::convertForUriId($b['uri-id'], '[quote]' . $siteinfo['description'] . '[/quote]', BBCode::CONNECTORS);
-		}
-
-		$consumer_key    = DI::config()->get('tumblr', 'consumer_key');
-		$consumer_secret = DI::config()->get('tumblr', 'consumer_secret');
-
-		$tum_oauth = new TumblrOAuth($consumer_key, $consumer_secret, $oauth_token, $oauth_token_secret);
-
-		// Make an API call with the TumblrOAuth instance.
-		$x = $tum_oauth->post($tmbl_blog, $params);
-		$ret_code = $tum_oauth->http_code;
-
-		if ($ret_code == 201) {
-			Logger::notice('tumblr_send: success');
-		} elseif ($ret_code == 403) {
-			Logger::notice('tumblr_send: authentication failure');
-		} else {
-			Logger::notice('tumblr_send: general error', ['error' => $x]);
-		}
 	}
 }
+
+function tumblr_send_npf(array $post): bool
+{
+	$page = DI::pConfig()->get($post['uid'], 'tumblr', 'page');
+
+	$connection = tumblr_connection($post['uid']);
+	if (empty($connection)) {
+		Logger::notice('Missing data, post will not be send to Tumblr.', ['uid' => $post['uid'], 'page' => $page, 'id' => $post['id']]);
+		// "true" is returned, since the legacy function will fail as well.
+		return true;
+	}
+	
+	$post['body'] = Post\Media::addAttachmentsToBody($post['uri-id'], $post['body']);
+	if (!empty($post['title'])) {
+		$post['body'] = '[h1]' . $post['title'] . "[/h1]\n" . $post['body'];
+	}
+
+	$params = [
+		'content'                => NPF::fromBBCode($post['body'], $post['uri-id']),
+		'state'                  => 'published',
+		'date'                   => DateTimeFormat::utc($post['created'], DateTimeFormat::ATOM),
+		'tags'                   => implode(',', array_column(Tag::getByURIId($post['uri-id']), 'name')),
+		'is_private'             => false,
+		'interactability_reblog' => 'everyone'
+	];
+
+	$result = tumblr_post($connection, 'blog/' . $page . '/posts', $params);
+
+	if ($result['success']) {
+		Logger::info('success', ['blog' => $page, 'params' => $params]);
+		return true;
+	} else {
+		Logger::notice('error', ['blog' => $page, 'params' => $params, 'result' => $result['data']]);
+		return false;
+	}
+}
+
+function tumblr_connection(int $uid): GuzzleHttp\Client|null
+{
+	$oauth_token        = DI::pConfig()->get($uid, 'tumblr', 'oauth_token');
+	$oauth_token_secret = DI::pConfig()->get($uid, 'tumblr', 'oauth_token_secret');
+
+	$page = DI::pConfig()->get($uid, 'tumblr', 'page');
+
+	$consumer_key    = DI::config()->get('tumblr', 'consumer_key');
+	$consumer_secret = DI::config()->get('tumblr', 'consumer_secret');
+
+	if (!$consumer_key || !$consumer_secret || !$oauth_token || !$oauth_token_secret || !$page) {
+		Logger::notice('Missing data, connection is not established', ['uid' => $uid, 'page' => $page]);
+		return null;
+	}
+	return tumblr_client($consumer_key, $consumer_secret, $oauth_token, $oauth_token_secret);
+}
+
+function tumblr_client(string $consumer_key, string $consumer_secret, string $oauth_token, string $oauth_token_secret): GuzzleHttp\Client
+{
+	$stack = HandlerStack::create();
+
+	$middleware = new Oauth1([
+		'consumer_key'    => $consumer_key,
+		'consumer_secret' => $consumer_secret,
+		'token'           => $oauth_token,
+		'token_secret'    => $oauth_token_secret
+	]);
+	$stack->push($middleware);
+	
+	return new Client([
+		'base_uri' => 'https://api.tumblr.com/v2/',
+		'handler' => $stack
+	]);
+}
+
+function tumblr_get($connection, string $url)
+{
+	try {
+		$res = $connection->get($url, ['auth' => 'oauth']);
+
+		$success = true;
+		$data    = json_decode($res->getBody()->getContents());
+	} catch (RequestException $exception) {
+		$success = false;
+		Logger::notice('Request failed', ['code' => $exception->getCode(), 'message' => $exception->getMessage()]);
+		$data    = json_decode($exception->getResponse()->getBody()->getContents());
+	}
+	return ['success' => $success, 'data' => $data];
+}
+
+function tumblr_post($connection, string $url, array $parameter)
+{
+	try {
+		$res = $connection->post($url, ['auth' => 'oauth', 'json' => $parameter]);
+
+		$success = true;
+		$data    = json_decode($res->getBody()->getContents());
+	} catch (RequestException $exception) {
+		$success = false;
+		Logger::notice('Post failed', ['code' => $exception->getCode(), 'message' => $exception->getMessage()]);
+		$data    = json_decode($exception->getResponse()->getBody()->getContents());
+	}
+	return ['success' => $success, 'data' => $data];
+}

wppost/wppost.php

@@ -13,6 +13,7 @@ use Friendica\Core\Logger;
 use Friendica\Core\Renderer;
 use Friendica\Database\DBA;
 use Friendica\DI;
+use Friendica\Model\Item;
 use Friendica\Model\Post;
 use Friendica\Util\XML;