[twitter] Combine POST calls in a single function for centralized logging
This commit is contained in:
parent
c208a4ec14
commit
52828b2b45
1 changed files with 32 additions and 36 deletions
|
@ -189,25 +189,7 @@ function twitter_api_contact(string $apiPath, array $contact, int $uid): ?bool
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
$ckey = DI::config()->get('twitter', 'consumerkey');
|
return twitter_api_call($uid, $apiPath, ['screen_name' => $contact['nick']]);
|
||||||
$csecret = DI::config()->get('twitter', 'consumersecret');
|
|
||||||
$otoken = DI::pConfig()->get($uid, 'twitter', 'oauthtoken');
|
|
||||||
$osecret = DI::pConfig()->get($uid, 'twitter', 'oauthsecret');
|
|
||||||
|
|
||||||
// If the addon is not configured (general or for this user) quit here
|
|
||||||
if (empty($ckey) || empty($csecret) || empty($otoken) || empty($osecret)) {
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
try {
|
|
||||||
$connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret);
|
|
||||||
$result = $connection->post($apiPath, ['screen_name' => $contact['nick']]);
|
|
||||||
Logger::info('[twitter] API call successful', ['apiPath' => $apiPath, 'result' => $result]);
|
|
||||||
return true;
|
|
||||||
} catch (Exception $e) {
|
|
||||||
Logger::notice('[twitter] API call failed', ['apiPath' => $apiPath, 'uid' => $uid, 'url' => $contact['url'], 'exception' => $e]);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
function twitter_jot_nets(App $a, array &$jotnets_fields)
|
function twitter_jot_nets(App $a, array &$jotnets_fields)
|
||||||
|
@ -518,36 +500,50 @@ function twitter_probe_detect(App $a, array &$hookData)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
function twitter_api_post(string $apiPath, string $pid, int $uid)
|
function twitter_api_post(string $apiPath, string $pid, int $uid): ?bool
|
||||||
{
|
{
|
||||||
if (empty($pid)) {
|
if (empty($pid)) {
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
return twitter_api_call($uid, $apiPath, ['id' => $pid]);
|
||||||
|
}
|
||||||
|
|
||||||
|
function twitter_api_call(int $uid, string $apiPath, array $parameters = []): ?bool
|
||||||
|
{
|
||||||
$ckey = DI::config()->get('twitter', 'consumerkey');
|
$ckey = DI::config()->get('twitter', 'consumerkey');
|
||||||
$csecret = DI::config()->get('twitter', 'consumersecret');
|
$csecret = DI::config()->get('twitter', 'consumersecret');
|
||||||
$otoken = DI::pConfig()->get($uid, 'twitter', 'oauthtoken');
|
$otoken = DI::pConfig()->get($uid, 'twitter', 'oauthtoken');
|
||||||
$osecret = DI::pConfig()->get($uid, 'twitter', 'oauthsecret');
|
$osecret = DI::pConfig()->get($uid, 'twitter', 'oauthsecret');
|
||||||
|
|
||||||
$connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret);
|
// If the addon is not configured (general or for this user) quit here
|
||||||
|
if (empty($ckey) || empty($csecret) || empty($otoken) || empty($osecret)) {
|
||||||
$post = ['id' => $pid];
|
return null;
|
||||||
|
}
|
||||||
Logger::debug('before action', ['action' => $apiPath, 'pid' => $pid, 'data' => $post]);
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
$result = $connection->post($apiPath, $post);
|
$connection = new TwitterOAuth($ckey, $csecret, $otoken, $osecret);
|
||||||
|
$result = $connection->post($apiPath, $parameters);
|
||||||
|
|
||||||
if ($connection->getLastHttpCode() != 200) {
|
if ($connection->getLastHttpCode() != 200) {
|
||||||
Logger::warning('[twitter] API call unsuccessful', ['apiPath' => $apiPath, 'post' => $post, 'result' => $result]);
|
throw new Exception($result->errors[0]->message ?? json_encode($result), $connection->getLastHttpCode());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (!empty($result->errors)) {
|
||||||
|
throw new Exception($result->errors[0]->message, $result->errors[0]->code);
|
||||||
|
}
|
||||||
|
|
||||||
|
Logger::info('[twitter] API call successful', ['apiPath' => $apiPath, 'parameters' => $parameters]);
|
||||||
|
Logger::debug('[twitter] API call result', ['apiPath' => $apiPath, 'parameters' => $parameters, 'result' => $result]);
|
||||||
|
|
||||||
|
return true;
|
||||||
} catch (TwitterOAuthException $twitterOAuthException) {
|
} catch (TwitterOAuthException $twitterOAuthException) {
|
||||||
Logger::warning('Unable to communicate with twitter', ['apiPath' => $apiPath, 'data' => $post, 'code' => $twitterOAuthException->getCode(), 'exception' => $twitterOAuthException]);
|
Logger::warning('Unable to communicate with twitter', ['apiPath' => $apiPath, 'parameters' => $parameters, 'code' => $twitterOAuthException->getCode(), 'exception' => $twitterOAuthException]);
|
||||||
$result = false;
|
return false;
|
||||||
|
} catch (Exception $e) {
|
||||||
|
Logger::notice('[twitter] API call failed', ['apiPath' => $apiPath, 'parameters' => $parameters, 'code' => $e->getCode(), 'message' => $e->getMessage()]);
|
||||||
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
Logger::info('after action', ['action' => $apiPath, 'result' => $result]);
|
|
||||||
|
|
||||||
return $result;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
function twitter_get_id(string $uri)
|
function twitter_get_id(string $uri)
|
||||||
|
|
Loading…
Reference in a new issue