cerebrate-project
/
cerebrate
mirror of https://github.com/cerebrate-project/cerebrate
1
0
Fork 0
Code Issues Releases Wiki Activity

new: [localtool:commonConnectorTools] Added new logger for each local tools

pull/85/head
Sami Mokaddem 2022-01-18 11:51:54 +01:00
parent a29a4ea024
commit 5eeda6b682
No known key found for this signature in database
GPG Key ID: 164C473F627A06FA
2 changed files with 41 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/Lib/default/local_tool_connectors/CommonConnectorTools.php
View File

@ -2,6 +2,8 @@
namespace CommonConnectorTools; namespace CommonConnectorTools;
use Cake\ORM\Locator\LocatorAwareTrait; use Cake\ORM\Locator\LocatorAwareTrait;
use Cake\Log\Log;
use Cake\Log\Engine\FileLog;
class CommonConnectorTools class CommonConnectorTools
{ {
@ -20,6 +22,35 @@ class CommonConnectorTools
const STATE_CANCELLED = 'Request cancelled'; const STATE_CANCELLED = 'Request cancelled';
const STATE_DECLINED = 'Request declined by remote'; const STATE_DECLINED = 'Request declined by remote';
public function __construct()
{
Log::setConfig("LocalToolDebug", [
'className' => FileLog::class,
'path' => LOGS,
'file' => "{$this->connectorName}-debug",
'scopes' => [$this->connectorName],
'levels' => ['notice', 'info', 'debug'],
]);
Log::setConfig("LocalToolError", [
'className' => FileLog::class,
'path' => LOGS,
'file' => "{$this->connectorName}-error",
'scopes' => [$this->connectorName],
'levels' => ['warning', 'error', 'critical', 'alert', 'emergency'],
]);
}
protected function logDebug($message)
{
Log::debug($message, [$this->connectorName]);
}
protected function logError($message, $scope=[])
{
Log::error($message, [$this->connectorName]);
}
public function addExposedFunction(string $functionName): void public function addExposedFunction(string $functionName): void
{ {
$this->exposedFunctions[] = $functionName; $this->exposedFunctions[] = $functionName;

13
src/Lib/default/local_tool_connectors/MispConnector.php
View File

@ -188,6 +188,7 @@ class MispConnector extends CommonConnectorTools
$settings = json_decode($connection->settings, true); $settings = json_decode($connection->settings, true);
$http = $this->genHTTPClient($connection, $options); $http = $this->genHTTPClient($connection, $options);
$url = sprintf('%s%s', $settings['url'], $relativeURL); $url = sprintf('%s%s', $settings['url'], $relativeURL);
$this->logDebug(sprintf('%s %s %s', __('Posting data') . PHP_EOL, "POST {$url}" . PHP_EOL, json_encode($data)));
return $http->post($url, $data, $options); return $http->post($url, $data, $options);
} }
@ -239,14 +240,18 @@ class MispConnector extends CommonConnectorTools
if (!empty($params['softError'])) { if (!empty($params['softError'])) {
return $response; return $response;
} }
throw new NotFoundException(__('Could not retrieve the requested resource.')); $errorMsg = __('Could not post to the requested resource for `{0}`. Remote returned:', $url) . PHP_EOL . $response->getStringBody();
$this->logError($errorMsg);
throw new NotFoundException($errorMsg);
} }
} }
private function postData(string $url, array $params): Response private function postData(string $url, array $params): Response
{ {
if (empty($params['connection'])) { if (empty($params['connection'])) {
throw new NotFoundException(__('No connection object received.')); $errorMsg = __('No connection object received.');
$this->logError($errorMsg);
throw new NotFoundException($errorMsg);
} }
$url = $this->urlAppendParams($url, $params); $url = $this->urlAppendParams($url, $params);
if (!is_string($params['body'])) { if (!is_string($params['body'])) {
@ -256,7 +261,9 @@ class MispConnector extends CommonConnectorTools
if ($response->isOk()) { if ($response->isOk()) {
return $response; return $response;
} else { } else {
throw new NotFoundException(__('Could not post to the requested resource. Remote returned:') . PHP_EOL . $response->getStringBody()); $errorMsg = __('Could not post to the requested resource for `{0}`. Remote returned:', $url) . PHP_EOL . $response->getStringBody();
$this->logError($errorMsg);
throw new NotFoundException($errorMsg);
} }
} }