$uri = bluesky_get_uri($post);
if ($id = Post::selectFirst(['id'], ['uri' => $uri, 'uid' => $uid])) {
- return $id['id'];
+ return $id['id'];
}
if ($id = Post::selectFirst(['id'], ['extid' => $uri, 'uid' => $uid])) {
- return $id['id'];
+ return $id['id'];
}
Logger::debug('Importing post', ['uid' => $uid, 'indexedAt' => $post->indexedAt, 'uri' => $post->uri, 'cid' => $post->cid, 'root' => $post->record->reply->root ?? '']);
$url = DI::baseUrl() . '/search?tag=' . urlencode($feature->tag);
$linktext = '#' . $feature->tag;
break;
-
+
default:
Logger::notice('Unhandled feature type', ['type' => $feature->$type, 'feature' => $feature, 'record' => $record]);
break;
}
if (!$curlResult->isSuccess()) {
- Logger::notice('API Error', ['error' => json_decode($curlResult->getBody()) ?: $curlResult->getBody()]);
+ Logger::notice('API Error', ['error' => json_decode($curlResult->getBodyString()) ?: $curlResult->getBodyString()]);
DI::pConfig()->set($uid, 'bluesky', 'status', BLUEKSY_STATUS_API_FAIL);
return null;
}
DI::pConfig()->set($uid, 'bluesky', 'status', BLUEKSY_STATUS_SUCCESS);
- return json_decode($curlResult->getBody());
+ return json_decode($curlResult->getBodyString());
}
function bluesky_xrpc_get(int $uid, string $url, array $parameters = []): ?stdClass
}
if (!$curlResult->isSuccess()) {
- Logger::notice('API Error', ['error' => json_decode($curlResult->getBody()) ?: $curlResult->getBody()]);
+ Logger::notice('API Error', ['error' => json_decode($curlResult->getBodyString()) ?: $curlResult->getBodyString()]);
return null;
}
- return json_decode($curlResult->getBody());
+ return json_decode($curlResult->getBodyString());
}
return false;
}
- $raw = $curlResult->getBody();
+ $raw = $curlResult->getBodyString();
$data = json_decode($raw, true);
$posts = $data['post_stream']['posts'];
foreach($posts as $post) {
return false;
}
- $raw = $curlResult->getBody();
+ $raw = $curlResult->getBodyString();
$data = json_decode($raw, true);
if (empty($data)) {
return false;
Logger::debug('dwpost: data: ' . $xml);
if ($dw_blog !== 'test') {
- $x = DI::httpClient()->post($dw_blog, $xml, ['Content-Type' => 'text/xml'])->getBody();
+ $x = DI::httpClient()->post($dw_blog, $xml, ['Content-Type' => 'text/xml'])->getBodyString();
}
Logger::info('posted to dreamwidth: ' . ($x) ? $x : '');
Logger::debug('ijpost: data: ' . $xml);
if ($ij_blog !== 'test') {
- $x = DI::httpClient()->post($ij_blog, $xml, ['Content-Type' => 'text/xml'])->getBody();
+ $x = DI::httpClient()->post($ij_blog, $xml, ['Content-Type' => 'text/xml'])->getBodyString();
}
Logger::info('posted to insanejournal: ' . $x ? $x : '');
}
// 'token' => $ltree_api_token
];
- $result = DI::httpClient()->post($ltree_blog, $params)->getBody();
+ $result = DI::httpClient()->post($ltree_blog, $params)->getBodyString();
Logger::notice('libertree: ' . $result);
}
}
Logger::debug('ljpost: data: ' . $xml);
if ($lj_blog !== 'test') {
- $x = DI::httpClient()->post($lj_blog, $xml, ['Content-Type' => 'text/xml'])->getBody();
+ $x = DI::httpClient()->post($lj_blog, $xml, ['Content-Type' => 'text/xml'])->getBodyString();
}
Logger::info('posted to livejournal: ' . ($x) ? $x : '');
continue;
}
$attachments[$url] = [
- 'data' => $curlResult->getBody(),
+ 'data' => $curlResult->getBodyString(),
'guid' => hash('crc32', $url),
'filename' => basename($components['path']),
'type' => $curlResult->getContentType()
$fetchResult = DI::httpClient()->fetchFull($api_url);
if ($fetchResult->isSuccess()) {
- $emojis_array = json_decode($fetchResult->getBody(), true);
+ $emojis_array = json_decode($fetchResult->getBodyString(), true);
if (is_array($emojis_array) && count($emojis_array)) {
foreach ($emojis_array as $emoji) {
if (is_null($j)) {
$curlResult = DI::httpClient()->get($nomserver . $args);
if ($curlResult->isSuccess()) {
- $j = json_decode($curlResult->getBody(), true);
+ $j = json_decode($curlResult->getBodyString(), true);
DI::cache()->set($cachekey, $j, Duration::MONTH);
}
}
} catch (\Exception $e) {
return null;
}
- $html = $curlResult->getBody();
+ $html = $curlResult->getBodyString();
if (empty($html)) {
return null;
}
*/
function tumblr_format_result(ICanHandleHttpResponses $curlResult): stdClass
{
- $result = json_decode($curlResult->getBody());
+ $result = json_decode($curlResult->getBodyString());
if (empty($result) || empty($result->meta)) {
$result = new stdClass;
$result->meta = new stdClass;
$curlResult = DI::httpClient()->post('https://api.tumblr.com/v2/oauth2/token', $parameters);
if (!$curlResult->isSuccess()) {
- Logger::info('Error fetching token', ['uid' => $uid, 'code' => $code, 'result' => $curlResult->getBody(), 'parameters' => $parameters]);
+ Logger::info('Error fetching token', ['uid' => $uid, 'code' => $code, 'result' => $curlResult->getBodyString(), 'parameters' => $parameters]);
return '';
}
- $result = json_decode($curlResult->getBody());
+ $result = json_decode($curlResult->getBodyString());
if (empty($result)) {
Logger::info('Invalid result when updating token', ['uid' => $uid]);
return '';
]);
$response = $client->post('oauth2/exchange', ['auth' => 'oauth']);
- return json_decode($response->getBody()->getContents());
+ return json_decode($response->getBodyString()->getContents());
} catch (RequestException $exception) {
Logger::notice('Exchange failed', ['code' => $exception->getCode(), 'message' => $exception->getMessage()]);
return new stdClass;
]);
$response = $client->post($url, ['auth' => 'oauth', $type => $data]);
- $body = $response->getBody()->getContents();
+ $body = $response->getBodyString()->getContents();
$status = [
'code' => $response->getStatusCode(),
$status = [
'code' => $response->getStatusCode(),
'reason' => $response->getReasonPhrase(),
- 'content' => $response->getBody()->getContents()
+ 'content' => $response->getBodyString()->getContents()
];
DI::pConfig()->set(1, 'twitter', 'last_status', $status);
Logger::info('Test successful', ['uid' => $uid]);
$response = $this->client->request('propfind', $uri, $opts);
$responseDoc = new \DOMDocument();
- $responseDoc->loadXML($response->getBody());
+ $responseDoc->loadXML($response->getBodyString());
$responseDoc->formatOutput = true;
$xpath = new \DOMXPath($responseDoc);
throw new ReferenceStorageException(sprintf('Invalid reference %s', $reference));
}
- return $response->getBody();
+ return $response->getBodyString();
}
/**
Logger::debug('wppost: data: ' . $xml);
if ($wp_blog !== 'test') {
- $x = DI::httpClient()->post($wp_blog, $xml)->getBody();
+ $x = DI::httpClient()->post($wp_blog, $xml)->getBodyString();
}
Logger::info('posted to wordpress: ' . (($x) ? $x : ''));
}