1	<?php
2	namespace Dbmi\Webservice\Analysis;
3
4	use ArrayIterator;
5	use IteratorAggregate;
6	use Traversable;
7
8	use Dbmi\Webservice\Contributor\Struct as DS_Contributor;
9	use Dbmi\Webservice\Quake\IdStruct as DS_QuakeId;
10
11	use Fdsn\DataStructure\LatLon as DS_LatLon;
12
13	/**
14	* Get analysis
15	*/
16	class SingleInstance 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 DS_Contributor $contributor;
21	private DS_QuakeId $quakeId;
22
23	private array $localities = array();
24
25	private int $curlErrNum = 0;
26	private string $curlErrInfo = '';
27
28	public function __construct(DS_Contributor $contributor, DS_QuakeId $quakeId){
29	$this->contributor = $contributor;
30	$this->quakeId = $quakeId;
31	}
32
33	public function curlErrorNumber(){ return $this->curlErrNum; }
34	public function curlErrorInfo(){ return $this->curlErrInfo; }
35
36	/**
37	* get all localities intensity
38	*
39	* @return array locality intensity
40	*/
41	public function getIterator():Traversable{ return new ArrayIterator($this->localities); }
42
43	/**
44	* find contributor based on quakeId
45	*
46	* @return int number of studies found
47	*/
48	public function fetch():int{
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
52
53	$curlSession = curl_init();
54	curl_setopt_array($curlSession, array(
55	CURLOPT_URL         => $url,
56	CURLOPT_HEADER         => false,
57	CURLOPT_CUSTOMREQUEST    => 'GET',
58	CURLOPT_RETURNTRANSFER    => true,
59	CURLOPT_FAILONERROR     => true
60	)
61	);
62	$downloadedData = curl_exec($curlSession);
63
64	$this->curlErrNum = curl_errno($curlSession);
65	$this->curlErrInfo = curl_error($curlSession);
66	curl_close($curlSession);
67
68	if(CURLE_OK != $this->curlErrNum){
69	error_log(sprintf("[%s] [CurlErr: %d] %s", __METHOD__, $this->curlErrNum, $this->curlErrInfo));
70	return -1;
71	}
72
73	$stringsData = preg_split("/\n/", $downloadedData);
74	$stringsArray = array_filter($stringsData, array($this, 'filterEmptyDataLine'));
75
76	if(0 == count($stringsArray)){
77	error_log(sprintf("[%s] No data\n'%s'", __METHOD__, $stringsData));
78	return 0;
79	}
80
81	foreach($stringsArray as $data){
82	$dataArray = str_getcsv($data, '|');
83
84	$this->localities[] = new Locality(
85	$dataArray[8],
86	$dataArray[9],
87	new DS_LatLon($dataArray[10], $dataArray[11]),
88	new Intensity($dataArray[12])
89	);
90	}
91
92	return count($this->localities);
93	}
94
95	/**
96	* filter empty lines or comment lines (starting with #)
97	*/
98	private function filterEmptyDataLine($data){
99	return !(preg_match('/^$/', $data) || preg_match("/^#/", $data));
100	}
101
102	}
103
104	?>
105

---

Paths

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

SingleInstance->__construct

28	public function __construct(DS_Contributor $contributor, DS_QuakeId $quakeId){
29	$this->contributor = $contributor;
30	$this->quakeId = $quakeId;
31	}

SingleInstance->curlErrorInfo

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

SingleInstance->curlErrorNumber

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

SingleInstance->fetch

49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
52
53	$curlSession = curl_init();
54	curl_setopt_array($curlSession, array(
55	CURLOPT_URL         => $url,
56	CURLOPT_HEADER         => false,
57	CURLOPT_CUSTOMREQUEST    => 'GET',
58	CURLOPT_RETURNTRANSFER    => true,
59	CURLOPT_FAILONERROR     => true
60	)
61	);
62	$downloadedData = curl_exec($curlSession);
63
64	$this->curlErrNum = curl_errno($curlSession);
65	$this->curlErrInfo = curl_error($curlSession);
66	curl_close($curlSession);
67
68	if(CURLE_OK != $this->curlErrNum){
69	error_log(sprintf("[%s] [CurlErr: %d] %s", __METHOD__, $this->curlErrNum, $this->curlErrInfo));
70	return -1;

49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
52
53	$curlSession = curl_init();
54	curl_setopt_array($curlSession, array(
55	CURLOPT_URL         => $url,
56	CURLOPT_HEADER         => false,
57	CURLOPT_CUSTOMREQUEST    => 'GET',
58	CURLOPT_RETURNTRANSFER    => true,
59	CURLOPT_FAILONERROR     => true
60	)
61	);
62	$downloadedData = curl_exec($curlSession);
63
64	$this->curlErrNum = curl_errno($curlSession);
65	$this->curlErrInfo = curl_error($curlSession);
66	curl_close($curlSession);
67
68	if(CURLE_OK != $this->curlErrNum){
73	$stringsData = preg_split("/\n/", $downloadedData);
74	$stringsArray = array_filter($stringsData, array($this, 'filterEmptyDataLine'));
75
76	if(0 == count($stringsArray)){
77	error_log(sprintf("[%s] No data\n'%s'", __METHOD__, $stringsData));
78	return 0;

49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
52
53	$curlSession = curl_init();
54	curl_setopt_array($curlSession, array(
55	CURLOPT_URL         => $url,
56	CURLOPT_HEADER         => false,
57	CURLOPT_CUSTOMREQUEST    => 'GET',
58	CURLOPT_RETURNTRANSFER    => true,
59	CURLOPT_FAILONERROR     => true
60	)
61	);
62	$downloadedData = curl_exec($curlSession);
63
64	$this->curlErrNum = curl_errno($curlSession);
65	$this->curlErrInfo = curl_error($curlSession);
66	curl_close($curlSession);
67
68	if(CURLE_OK != $this->curlErrNum){
73	$stringsData = preg_split("/\n/", $downloadedData);
74	$stringsArray = array_filter($stringsData, array($this, 'filterEmptyDataLine'));
75
76	if(0 == count($stringsArray)){
81	foreach($stringsArray as $data){
81	foreach($stringsArray as $data){
81	foreach($stringsArray as $data){
82	$dataArray = str_getcsv($data, '|');
81	foreach($stringsArray as $data){
81	foreach($stringsArray as $data){
82	$dataArray = str_getcsv($data, '|');
83
84	$this->localities[] = new Locality(
85	$dataArray[8],
86	$dataArray[9],
87	new DS_LatLon($dataArray[10], $dataArray[11]),
88	new Intensity($dataArray[12])
89	);
90	}
91
92	return count($this->localities);
93	}

49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
52
53	$curlSession = curl_init();
54	curl_setopt_array($curlSession, array(
55	CURLOPT_URL         => $url,
56	CURLOPT_HEADER         => false,
57	CURLOPT_CUSTOMREQUEST    => 'GET',
58	CURLOPT_RETURNTRANSFER    => true,
59	CURLOPT_FAILONERROR     => true
60	)
61	);
62	$downloadedData = curl_exec($curlSession);
63
64	$this->curlErrNum = curl_errno($curlSession);
65	$this->curlErrInfo = curl_error($curlSession);
66	curl_close($curlSession);
67
68	if(CURLE_OK != $this->curlErrNum){
73	$stringsData = preg_split("/\n/", $downloadedData);
74	$stringsArray = array_filter($stringsData, array($this, 'filterEmptyDataLine'));
75
76	if(0 == count($stringsArray)){
81	foreach($stringsArray as $data){
81	foreach($stringsArray as $data){
81	foreach($stringsArray as $data){
82	$dataArray = str_getcsv($data, '|');
83
84	$this->localities[] = new Locality(
85	$dataArray[8],
86	$dataArray[9],
87	new DS_LatLon($dataArray[10], $dataArray[11]),
88	new Intensity($dataArray[12])
89	);
90	}
91
92	return count($this->localities);
93	}

49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
52
53	$curlSession = curl_init();
54	curl_setopt_array($curlSession, array(
55	CURLOPT_URL         => $url,
56	CURLOPT_HEADER         => false,
57	CURLOPT_CUSTOMREQUEST    => 'GET',
58	CURLOPT_RETURNTRANSFER    => true,
59	CURLOPT_FAILONERROR     => true
60	)
61	);
62	$downloadedData = curl_exec($curlSession);
63
64	$this->curlErrNum = curl_errno($curlSession);
65	$this->curlErrInfo = curl_error($curlSession);
66	curl_close($curlSession);
67
68	if(CURLE_OK != $this->curlErrNum){
73	$stringsData = preg_split("/\n/", $downloadedData);
74	$stringsArray = array_filter($stringsData, array($this, 'filterEmptyDataLine'));
75
76	if(0 == count($stringsArray)){
81	foreach($stringsArray as $data){
81	foreach($stringsArray as $data){
82	$dataArray = str_getcsv($data, '|');
83
84	$this->localities[] = new Locality(
85	$dataArray[8],
86	$dataArray[9],
87	new DS_LatLon($dataArray[10], $dataArray[11]),
88	new Intensity($dataArray[12])
89	);
90	}
91
92	return count($this->localities);
93	}

49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
52
53	$curlSession = curl_init();
54	curl_setopt_array($curlSession, array(
55	CURLOPT_URL         => $url,
56	CURLOPT_HEADER         => false,
57	CURLOPT_CUSTOMREQUEST    => 'GET',
58	CURLOPT_RETURNTRANSFER    => true,
59	CURLOPT_FAILONERROR     => true
60	)
61	);
62	$downloadedData = curl_exec($curlSession);
63
64	$this->curlErrNum = curl_errno($curlSession);
65	$this->curlErrInfo = curl_error($curlSession);
66	curl_close($curlSession);
67
68	if(CURLE_OK != $this->curlErrNum){
69	error_log(sprintf("[%s] [CurlErr: %d] %s", __METHOD__, $this->curlErrNum, $this->curlErrInfo));
70	return -1;

49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
52
53	$curlSession = curl_init();
54	curl_setopt_array($curlSession, array(
55	CURLOPT_URL         => $url,
56	CURLOPT_HEADER         => false,
57	CURLOPT_CUSTOMREQUEST    => 'GET',
58	CURLOPT_RETURNTRANSFER    => true,
59	CURLOPT_FAILONERROR     => true
60	)
61	);
62	$downloadedData = curl_exec($curlSession);
63
64	$this->curlErrNum = curl_errno($curlSession);
65	$this->curlErrInfo = curl_error($curlSession);
66	curl_close($curlSession);
67
68	if(CURLE_OK != $this->curlErrNum){
73	$stringsData = preg_split("/\n/", $downloadedData);
74	$stringsArray = array_filter($stringsData, array($this, 'filterEmptyDataLine'));
75
76	if(0 == count($stringsArray)){
77	error_log(sprintf("[%s] No data\n'%s'", __METHOD__, $stringsData));
78	return 0;

49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
52
53	$curlSession = curl_init();
54	curl_setopt_array($curlSession, array(
55	CURLOPT_URL         => $url,
56	CURLOPT_HEADER         => false,
57	CURLOPT_CUSTOMREQUEST    => 'GET',
58	CURLOPT_RETURNTRANSFER    => true,
59	CURLOPT_FAILONERROR     => true
60	)
61	);
62	$downloadedData = curl_exec($curlSession);
63
64	$this->curlErrNum = curl_errno($curlSession);
65	$this->curlErrInfo = curl_error($curlSession);
66	curl_close($curlSession);
67
68	if(CURLE_OK != $this->curlErrNum){
73	$stringsData = preg_split("/\n/", $downloadedData);
74	$stringsArray = array_filter($stringsData, array($this, 'filterEmptyDataLine'));
75
76	if(0 == count($stringsArray)){
81	foreach($stringsArray as $data){
81	foreach($stringsArray as $data){
81	foreach($stringsArray as $data){
82	$dataArray = str_getcsv($data, '|');
81	foreach($stringsArray as $data){
81	foreach($stringsArray as $data){
82	$dataArray = str_getcsv($data, '|');
83
84	$this->localities[] = new Locality(
85	$dataArray[8],
86	$dataArray[9],
87	new DS_LatLon($dataArray[10], $dataArray[11]),
88	new Intensity($dataArray[12])
89	);
90	}
91
92	return count($this->localities);
93	}

49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
52
53	$curlSession = curl_init();
54	curl_setopt_array($curlSession, array(
55	CURLOPT_URL         => $url,
56	CURLOPT_HEADER         => false,
57	CURLOPT_CUSTOMREQUEST    => 'GET',
58	CURLOPT_RETURNTRANSFER    => true,
59	CURLOPT_FAILONERROR     => true
60	)
61	);
62	$downloadedData = curl_exec($curlSession);
63
64	$this->curlErrNum = curl_errno($curlSession);
65	$this->curlErrInfo = curl_error($curlSession);
66	curl_close($curlSession);
67
68	if(CURLE_OK != $this->curlErrNum){
73	$stringsData = preg_split("/\n/", $downloadedData);
74	$stringsArray = array_filter($stringsData, array($this, 'filterEmptyDataLine'));
75
76	if(0 == count($stringsArray)){
81	foreach($stringsArray as $data){
81	foreach($stringsArray as $data){
81	foreach($stringsArray as $data){
82	$dataArray = str_getcsv($data, '|');
83
84	$this->localities[] = new Locality(
85	$dataArray[8],
86	$dataArray[9],
87	new DS_LatLon($dataArray[10], $dataArray[11]),
88	new Intensity($dataArray[12])
89	);
90	}
91
92	return count($this->localities);
93	}

49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
49	$url = ( ! is_null ($this->contributor->mdpSetId()) )
50	? sprintf(self::templateUrlDataByContributorAndMdpId, $this->quakeId->id(), $this->contributor->name(), $this->contributor->mdpSetId() )
51	: sprintf(self::templateUrlDataByContributor, $this->quakeId->id(), $this->contributor->name() );
52
53	$curlSession = curl_init();
54	curl_setopt_array($curlSession, array(
55	CURLOPT_URL         => $url,
56	CURLOPT_HEADER         => false,
57	CURLOPT_CUSTOMREQUEST    => 'GET',
58	CURLOPT_RETURNTRANSFER    => true,
59	CURLOPT_FAILONERROR     => true
60	)
61	);
62	$downloadedData = curl_exec($curlSession);
63
64	$this->curlErrNum = curl_errno($curlSession);
65	$this->curlErrInfo = curl_error($curlSession);
66	curl_close($curlSession);
67
68	if(CURLE_OK != $this->curlErrNum){
73	$stringsData = preg_split("/\n/", $downloadedData);
74	$stringsArray = array_filter($stringsData, array($this, 'filterEmptyDataLine'));
75
76	if(0 == count($stringsArray)){
81	foreach($stringsArray as $data){
81	foreach($stringsArray as $data){
82	$dataArray = str_getcsv($data, '|');
83
84	$this->localities[] = new Locality(
85	$dataArray[8],
86	$dataArray[9],
87	new DS_LatLon($dataArray[10], $dataArray[11]),
88	new Intensity($dataArray[12])
89	);
90	}
91
92	return count($this->localities);
93	}

SingleInstance->filterEmptyDataLine

98	private function filterEmptyDataLine($data){
99	return !(preg_match('/^$/', $data) || preg_match("/^#/", $data));
99	return !(preg_match('/^$/', $data) || preg_match("/^#/", $data));
99	return !(preg_match('/^$/', $data) || preg_match("/^#/", $data));
100	}

98	private function filterEmptyDataLine($data){
99	return !(preg_match('/^$/', $data) || preg_match("/^#/", $data));
99	return !(preg_match('/^$/', $data) || preg_match("/^#/", $data));
100	}

SingleInstance->getIterator

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