1	<?php
2	namespace Dbmi\Webservice\Analysis;
3
4	use ArrayIterator;
5	use IteratorAggregate;
6	use Traversable;
7
8	use Dbmi\Webservice\Quake\QuakeId;
9
10	use Dbmi\Webservice\Contributor\ContributorData;
11	use Fdsn\Webservices\Event\Structs\LatLon as DS_LatLon;
12
13	/**
14	* Get analysis
15	*/
16	class Analysis implements IteratorAggregate{
17	private const templateUrlDataByContributor = 'https://emidius.mi.ingv.it/services/macroseismic/query?format=textmacro&includemdps=true&eventid=%s&contributor=%s';
18	private const templateUrlDataByContributorAndMdpId = 'https://emidius.mi.ingv.it/services/macroseismic/query?format=textmacro&includemdps=true&eventid=%s&contributor=%s&mdpsetid=%s';
19
20	private const curlCloceLatestPhpVersion = 7;
21
22	private ContributorData $contributor;
23	private QuakeId $quakeId;
24
25	private array $localities = array();
26
27	private int $curlErrNum = 0;
28	private string $curlErrInfo = '';
29
30	public function __construct(ContributorData $contributor, QuakeId $quakeId){
31	$this->contributor = $contributor;
32	$this->quakeId = $quakeId;
33	}
34
35	public function curlErrorNumber(){ return $this->curlErrNum; }
36	public function curlErrorInfo(){ return $this->curlErrInfo; }
37
38	/**
39	* get all localities intensity
40	*
41	* @return array locality intensity
42	*/
43	public function getIterator():Traversable{ return new ArrayIterator($this->localities); }
44
45	/**
46	* find contributor based on quakeId
47	*
48	* @return int number of studies found
49	*/
50	public function fetch():int{
51	$url = ( ! is_null ($this->contributor->mdpSetId()) )
52	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
53	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
54
55	$curlSession = curl_init();
56	curl_setopt_array($curlSession, array(
57	CURLOPT_URL         => $url,
58	CURLOPT_HEADER         => false,
59	CURLOPT_CUSTOMREQUEST    => 'GET',
60	CURLOPT_RETURNTRANSFER    => true,
61	CURLOPT_FAILONERROR     => true
62	)
63	);
64	$downloadedData = curl_exec($curlSession);
65
66	$this->curlErrNum = curl_errno($curlSession);
67	$this->curlErrInfo = curl_error($curlSession);
68	if ( $this->isCurlCloseSupported() )
69	curl_close($curlSession);
70
71	if(CURLE_OK != $this->curlErrNum){
72	error_log(sprintf("[%s] [CurlErr: %d] %s", __METHOD__, $this->curlErrNum, $this->curlErrInfo));
73	return -1;
74	}
75
76	$stringsData = preg_split("/\n/", $downloadedData);
77	$stringsArray = array_filter($stringsData, array($this, 'filterEmptyDataLine'));
78
79	if(0 == count($stringsArray)){
80	error_log(sprintf("[%s] No data\n'%s'", __METHOD__, $stringsData));
81	return 0;
82	}
83
84	foreach($stringsArray as $data){
85	$dataArray = str_getcsv($data, '|', "\"", "\\");
86
87	try{
88	$this->localities[] = new Locality(
89	$dataArray[8],
90	$dataArray[9],
91	new DS_LatLon($dataArray[10], $dataArray[11]),
92	new Intensity($dataArray[12])
93	);
94	}
95	catch(\TypeError $e){
96	error_log(sprintf( "[%s] Skipping invalid data with error '%s'", __METHOD__, $e->getMessage() ));
97	continue;
98	}
99	}
100
101	return count($this->localities);
102	}
103
104	/**
105	* filter empty lines or comment lines (starting with #)
106	*/
107	private function filterEmptyDataLine($data){
108	return !(preg_match('/^$/', $data) || preg_match("/^#/", $data));
109	}
110	/**
111	* Check if curl_close is still supported
112	* @return bool true is supported, false otherwise
113	*/
114	private function isCurlCloseSupported():bool{ return PHP_MAJOR_VERSION <= self::curlCloceLatestPhpVersion; }
115
116	}
117
118	?>
119

---

Branches

Below are the source code lines that represent each code branch as identified by Xdebug. Please note a branch is not necessarily coterminous with a line, a line may contain multiple branches and therefore show up more than once. Please also be aware that some branches may be implicit rather than explicit, e.g. an if statement always has an else as part of its logical flow even if you didn't write one.

Analysis->__construct

30	public function __construct(ContributorData $contributor, QuakeId $quakeId){
31	$this->contributor = $contributor;
32	$this->quakeId = $quakeId;
33	}

Analysis->curlErrorInfo

36	public function curlErrorInfo(){ return $this->curlErrInfo; }

Analysis->curlErrorNumber

35	public function curlErrorNumber(){ return $this->curlErrNum; }

Analysis->fetch

51	$url = ( ! is_null ($this->contributor->mdpSetId()) )

52	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )

51	$url = ( ! is_null ($this->contributor->mdpSetId()) )
52	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
53	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );

51	$url = ( ! is_null ($this->contributor->mdpSetId()) )
52	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
53	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
54
55	$curlSession = curl_init();
56	curl_setopt_array($curlSession, array(
57	CURLOPT_URL         => $url,
58	CURLOPT_HEADER         => false,
59	CURLOPT_CUSTOMREQUEST    => 'GET',
60	CURLOPT_RETURNTRANSFER    => true,
61	CURLOPT_FAILONERROR     => true
62	)
63	);
64	$downloadedData = curl_exec($curlSession);
65
66	$this->curlErrNum = curl_errno($curlSession);
67	$this->curlErrInfo = curl_error($curlSession);
68	if ( $this->isCurlCloseSupported() )

69	curl_close($curlSession);
70
71	if(CURLE_OK != $this->curlErrNum){

71	if(CURLE_OK != $this->curlErrNum){

72	error_log(sprintf("[%s] [CurlErr: %d] %s", __METHOD__, $this->curlErrNum, $this->curlErrInfo));
73	return -1;

76	$stringsData = preg_split("/\n/", $downloadedData);
77	$stringsArray = array_filter($stringsData, array($this, 'filterEmptyDataLine'));
78
79	if(0 == count($stringsArray)){

80	error_log(sprintf("[%s] No data\n'%s'", __METHOD__, $stringsData));
81	return 0;

84	foreach($stringsArray as $data){

84	foreach($stringsArray as $data){

85	$dataArray = str_getcsv($data, '|', "\"", "\\");
86
87	try{
88	$this->localities[] = new Locality(
89	$dataArray[8],
90	$dataArray[9],
91	new DS_LatLon($dataArray[10], $dataArray[11]),
92	new Intensity($dataArray[12])

95	catch(\TypeError $e){

96	error_log(sprintf( "[%s] Skipping invalid data with error '%s'", __METHOD__, $e->getMessage() ));
97	continue;

84	foreach($stringsArray as $data){

84	foreach($stringsArray as $data){
85	$dataArray = str_getcsv($data, '|', "\"", "\\");
86
87	try{
88	$this->localities[] = new Locality(
89	$dataArray[8],
90	$dataArray[9],
91	new DS_LatLon($dataArray[10], $dataArray[11]),
92	new Intensity($dataArray[12])
93	);
94	}
95	catch(\TypeError $e){
96	error_log(sprintf( "[%s] Skipping invalid data with error '%s'", __METHOD__, $e->getMessage() ));
97	continue;
98	}
99	}
100
101	return count($this->localities);
102	}

Analysis->filterEmptyDataLine

107	private function filterEmptyDataLine($data){
108	return !(preg_match('/^$/', $data) || preg_match("/^#/", $data));

108	return !(preg_match('/^$/', $data) || preg_match("/^#/", $data));

108	return !(preg_match('/^$/', $data) || preg_match("/^#/", $data));
109	}

Analysis->getIterator

43	public function getIterator():Traversable{ return new ArrayIterator($this->localities); }

Analysis->isCurlCloseSupported

114	private function isCurlCloseSupported():bool{ return PHP_MAJOR_VERSION <= self::curlCloceLatestPhpVersion; }