[twitter] Add HTTP error code handling #991

Merged
MrPetovan merged 3 commits from bug/notices into 2020.06-rc 2020-06-22 06:41:53 +02:00

View file

@ -491,24 +491,31 @@ function twitter_action(App $a, $uid, $pid, $action)
$post = ['id' => $pid]; $post = ['id' => $pid];
Logger::log("twitter_action '" . $action . "' ID: " . $pid . " data: " . print_r($post, true), Logger::DATA); Logger::debug('before action', ['action' => $action, 'pid' => $pid, 'data' => $post]);
switch ($action) { switch ($action) {
case "delete": case 'delete':
// To-Do: $result = $connection->post('statuses/destroy', $post); // To-Do: $result = $connection->post('statuses/destroy', $post);
$result = []; $result = [];
break; break;
case "like": case 'like':
$result = $connection->post('favorites/create', $post); $result = $connection->post('favorites/create', $post);
if ($connection->getLastHttpCode() != 200) {
Logger::error('Unable to create favorite', ['result' => $result]);
}
break; break;
case "unlike": case 'unlike':
$result = $connection->post('favorites/destroy', $post); $result = $connection->post('favorites/destroy', $post);
if ($connection->getLastHttpCode() != 200) {
Logger::error('Unable to destroy favorite', ['result' => $result]);
}
break; break;
default: default:
Logger::log('Unhandled action ' . $action, Logger::DEBUG); Logger::warning('Unhandled action', ['action' => $action]);
$result = []; $result = [];
} }
Logger::log("twitter_action '" . $action . "' send, result: " . print_r($result, true), Logger::DEBUG);
Logger::info('after action', ['action' => $action, 'result' => $result]);
} }
function twitter_post_hook(App $a, array &$b) function twitter_post_hook(App $a, array &$b)
@ -1047,9 +1054,8 @@ function twitter_get_relation($uid, $target, $contact = [])
try { try {
$status = $connection->get('friendships/show', $parameters); $status = $connection->get('friendships/show', $parameters);
} catch (TwitterOAuthException $e) { if ($connection->getLastHttpCode() !== 200) {
Logger::info('Error fetching friendship status', ['user' => $uid, 'target' => $target, 'message' => $e->getMessage()]); throw new Exception($status->errors[0]->message ?? 'HTTP response code ' . $connection->getLastHttpCode(), $status->errors[0]->code ?? $connection->getLastHttpCode());
return $relation;
} }
$following = $status->relationship->source->following; $following = $status->relationship->source->following;
@ -1066,14 +1072,21 @@ function twitter_get_relation($uid, $target, $contact = [])
} }
Logger::info('Fetched friendship relation', ['user' => $uid, 'target' => $target, 'relation' => $relation]); Logger::info('Fetched friendship relation', ['user' => $uid, 'target' => $target, 'relation' => $relation]);
} catch (Throwable $e) {
Logger::error('Error fetching friendship status', ['user' => $uid, 'target' => $target, 'message' => $e->getMessage()]);
}
return $relation; return $relation;
} }
/**
* @param $data
* @return array
*/
function twitter_user_to_contact($data) function twitter_user_to_contact($data)
{ {
if (empty($data->id_str)) { if (empty($data->id_str)) {
return -1; return [];
} }
$baseurl = 'https://twitter.com'; $baseurl = 'https://twitter.com';
@ -1915,7 +1928,7 @@ function twitter_fetch_own_contact(App $a, $uid)
// Fetching user data // Fetching user data
// get() may throw TwitterOAuthException, but we will catch it later // get() may throw TwitterOAuthException, but we will catch it later
$user = $connection->get('account/verify_credentials'); $user = $connection->get('account/verify_credentials');
if (empty($user) || empty($user->id_str)) { if (empty($user->id_str)) {
return false; return false;
} }