blob: 59cca0c689111c798e2b87e02a80f2b80e656f73 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
<?php
namespace Elastica\Exception;
/**
* Elasticsearch exception.
*
* @author Ian Babrou <ibobrik@gmail.com>
*/
class ElasticsearchException extends \Exception implements ExceptionInterface
{
const REMOTE_TRANSPORT_EXCEPTION = 'RemoteTransportException';
/**
* @var string|null Elasticsearch exception name
*/
private $_exception;
/**
* @var bool Whether exception was local to server node or remote
*/
private $_isRemote = false;
/**
* Constructs elasticsearch exception.
*
* @param int $code Error code
* @param string $error Error message from elasticsearch
*/
public function __construct($code, $error)
{
$this->_parseError($error);
parent::__construct($error, $code);
}
/**
* Parse error message from elasticsearch.
*
* @param string $error Error message
*/
protected function _parseError($error)
{
$errors = explode(']; nested: ', $error);
if (count($errors) == 1) {
$this->_exception = $this->_extractException($errors[0]);
} else {
if ($this->_extractException($errors[0]) == self::REMOTE_TRANSPORT_EXCEPTION) {
$this->_isRemote = true;
$this->_exception = $this->_extractException($errors[1]);
} else {
$this->_exception = $this->_extractException($errors[0]);
}
}
}
/**
* Extract exception name from error response.
*
* @param string $error
*
* @return null|string
*/
protected function _extractException($error)
{
if (preg_match('/^(\w+)\[.*\]/', $error, $matches)) {
return $matches[1];
} else {
return;
}
}
/**
* Returns elasticsearch exception name.
*
* @return string|null
*/
public function getExceptionName()
{
return $this->_exception;
}
/**
* Returns whether exception was local to server node or remote.
*
* @return bool
*/
public function isRemoteTransportException()
{
return $this->_isRemote;
}
}
|
