SyncDbCurl - Code Metrics - fwolf/fwlib - Measure and Improve Code Quality continuously with Scrutinizer

SyncDbCurl A
last analyzed 2019-05-09 15:53 UTC

↳ Parent: Project

Complexity

Total Complexity

Size/Duplication

Total Lines	278
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

Metric	Value
dl	0
loc	278
rs	9.68
c	0
b	0
f	0
wmc	34
lcom	1
cbo	2

10 Methods

Rating	Name	Size	Complexity
A	__construct()	10	2
A	CommReturn()	13	2
A	CommReturnTestDb()	11	2
A	NewObjDb()	11	2
A	SetCfg()	8	2
B	SetCfgServer()	24	7
B	StartClient()	34	7
A	StartClientPull()	19	4
A	StartClientPullTbl()	7	2
A	TestDb()	28	4

<?php
/**
 * @package		fwolflib
 * @subpackage	class
 * @copyright	Copyright 2010, Fwolf
 * @author		Fwolf <[email protected]>
 * @since		2010-05-25
 */


require_once(dirname(__FILE__) . '/fwolflib.php');
require_once(FWOLFLIB . 'class/adodb.php');
require_once(FWOLFLIB . 'class/curl-comm.php');


/**
 * Sync db data via curl communication.
 *
 * Db schema of both side should be same,
 * Each data table should have timestamp and PK column.
 *
 *
 * If sync in two-way, that need server ID and write ID to every row,
 * which is 'functional' but not fast and need change many things
 * on app side, like readonly option.
 *
 * So I think make this a one-way sync tools, but it can do pull also
 * push, that is, for 1 table, it's one-way, but for the whole db,
 * it's somehow 'two-way' sync.
 *
 * Also I have some additional thought:
 * - Make app read and write to server/remote db through this.
 * - When write to server/remote db and remote side not accessable,
 * cache it and can call re-write later.
 *
 *
 * When act as server, make config vars as less as possible,
 * db param can passed in through POST,
 * but crypt key must be assigned.
 *
 * When act as client, can connect to multi server,
 * each have difference config, job, crypt etc,
 * client comm with them one by one.
 *
 *
 * Roadmap:
 *
 * 1.4	Cache for write to remote db, and re-call them.
 * 1.3	Provide app read and write functional from/to remote db.
 * 1.2	Sync push to server.
 * 1.1	Auto call data convert func.
 * 1.0	[:TODO:] Sync pull from server.
 *
 * @package		fwolflib
 * @subpackage	class
 * @copyright	Copyright 2010, Fwolf
 * @author		Fwolf <[email protected]>
 * @since		2010-05-25
 * @version		0.0
 */
class SyncDbCurl extends CurlComm {

	/**
	 * Default value of config
	 * array(
	 * 	url,
	 * 	db_client	=> array(
	 * 		type, host, user, pass, name, lang
	 * 	),
	 * 	db_server	=> array(
	 * 		type, host, user, pass, name, lang
	 * 	),
	 * pull		=> '' or array(),
	 * push		=> '' or array(),
	 * )
	 * @var	array
	 */
	public $aCfgDefault = array();

	/**
	 * Config of all server, empty val will fill by $aCfgDefault.
	 * @see	$aCfgDefault
	 * @var	array
	 */
	public $aCfgServer = array();

	/**
	 * Db conn obj
	 * @var	object
	 */
	protected $oDb = null;


	/**
	 * Constructor
	 *
	 * @param	array	$ar_cfg
	 */
	public function __construct($ar_cfg = array()) {
		// For auto new obj
		unset($this->oDb);

		parent::__construct($ar_cfg);

		// Server will auto start, manual start client
		if (empty($_POST))
			$this->StartClient();
	} // end of func __construct


	/**
	 * At server, conn to db before call action func.
	 *
	 * @param	array	$ar_req
	 * @return	array
	 */
	protected function CommReturn($ar_req) {
		// Db, use posted db config first.
		if (isset($ar_req['db_server']))
			$ar_db_prof = $ar_req['db_server'];
		else
			// Using default config
			// Notice, there is no server config array on the server.
			// so we only read default config.
			$ar_db_prof = $this->aCfgDefault['db_server'];
		$this->oDb = $this->NewObjDb($ar_db_prof);

		return parent::CommReturn($ar_req);
	} // end of func CommReturn


	/**
	 * Test db conn @ server side.
	 *
	 * @see		TestDb()
	 * @see		CommReturn()	Db is connected here.
	 * @param	array	$ar_req	Request msg array
	 * @return	array
	 */
	protected function CommReturnTestDb($ar_req = array()) {

		$ar = array();
		if (empty($this->oDb)) {
			$ar['code'] = 1;
			$ar['msg'] = 'Test server db conn fail.';
		} else {
			$ar['code'] = 0;
			$ar['msg'] = 'Test server db conn ok.';
		}
		return $ar;
	} // end of func CommReturnTestDb


	/**
	 * New db conn obj
	 *
	 * @param	array	$db_prof
	 * @return	object
	 * @see	$oDb
	 */
	protected function NewObjDb($db_prof) {
		$obj = new Adodb($db_prof);

		if (false == $obj->Connect()) {

			$this->Log('Db conn fail.', 5);
			return null;
		}
		else {
			$this->Log('New obj db.', 1);
			return $obj;
		}
	} // end of func NewObjDb


	/**
	 * Read and set config
	 *
	 * @param	array	$ar_cfg
	 * @return	$this
	 */
	public function SetCfg($ar_cfg = array()) {
		parent::SetCfg($ar_cfg);
		if (!empty($ar_cfg)) {
			$this->aCfgDefault = ArrayRead($ar_cfg, 'default', array());

			$this->aCfgServer = ArrayRead($ar_cfg, 'server', array());

		}
		return $this;
	} // end of func SetCfg


	/**
	 * Fill server config using default
	 *
	 * @return	$this
	 */
	protected function SetCfgServer() {
		// These keys in cfg default can assign to server.
		$ar_keys = array('url', 'db_client', 'db_server'
			, 'pull', 'push');

		if (!empty($this->aCfgServer)) {
			foreach ($this->aCfgServer as $server => &$cfg) {
				foreach ($ar_keys as $key) {
					if (empty($cfg[$key])
						&& !empty($this->aCfgDefault[$key]))
						$cfg[$key] = $this->aCfgDefault[$key];
				}
				if (empty($cfg)) {
					// Invalid server config
					$this->Log('Invalid server config: ' . $server, 4);
				}
			}
		}

		$this->Log('Got ' . count($this->aCfgServer)
			. ' server todo.', 1);

		return $this;
	} // end of func SetCfgServer


	/**
	 * Act as client
	 *
	 * @return	$this
	 */
	public function StartClient() {
		// Fill server config using default
		$this->SetCfgServer();

		if (empty($this->aCfgServer)) {
			$this->Log('Got no valid server config.', 5);
			return $this;
		}

		foreach ($this->aCfgServer as $server => $cfg) {
			$this->Log('Treat server "' . $server . '".', 3);
			$this->sUrlRemote = $cfg['url'];
			if (!empty($cfg['db_server']))
				$this->aMsgExtra['db_server'] = $cfg['db_server'];

			// Test curl connection
			if (0 != $this->CommSendTest()) {
				$this->Log('Error conn to server "' . $server
					. '" ', 4);
				return $this;
			}
			// Test db connection
			if (0 != $this->TestDb($cfg)) {
				$this->Log('Error when test db.', 5);
				return $this;
			}

			// Begin pull and push
			if (!empty($cfg['pull']))
				$this->StartClientPull($cfg);
		}

		return $this;
	} // end of func StartClient


	/**
	 * Do pull of a single server
	 *
	 * @param	array	$cfg
	 */
	public function StartClientPull($cfg) {
		// Which tbl to pull ?
		$ar_tbl = $this->oDb->MetaTables('TABLES');
		if (!empty($ar_tbl)) {
			$ar_tbl = FilterWildcard($ar_tbl, $cfg['pull']);

			$this->Log('Got ' . count($ar_tbl) . ' tables to pull: '
				. implode(', ', $ar_tbl), 3);

			// Pull tables
			if (!empty($ar_tbl)) {
				foreach ($ar_tbl as $s_tbl) {
					$this->StartClientPullTbl($cfg, $s_tbl);
				}
			}
		}
		else {
			$this->Log('Pull fail: no tables on client side.', 4);
		}
	} // end of func StartClientPull


	/**
	 * Do pull of a single table
	 *
	 * @param	array	$cfg
	 * @param	string	$s_tbl
	 */
	public function StartClientPullTbl($cfg, $s_tbl) {

		if (empty($s_tbl)) {
			$this->Log('StartClientPullTbl: empty table name.', 5);
		}
		else
			$this->Log("StartClientPullTbl: $s_tbl");
	} // end of func StartClientPullTbl


	/**
	 * Test db connection
	 *
	 * @param	array	$cfg
	 * @return	int 0=ok, other=error.
	 */
	public function TestDb($cfg) {
		// Client db
		$this->oDb = $this->NewObjDb($cfg['db_client']);
		if (empty($this->oDb)) {
			$this->Log('Test client db conn fail.', 5);
			return 1;
		}
		$this->Log('Test local db conn ok.', 1);

		// Server db
		$ar = array('action' => 'test-db');
		$ar = $this->CommSend($ar);
		if (isset($ar['code'])) {
			if (0 == $ar['code']) {
				$this->Log('Test server db conn ok.', 1);
			} else {
				$this->Log('Test server db conn fail.', 5);
				return 2;
			}
		} else {
			$this->Log('Test server db conn fail, invalid response.', 5);
			return 3;
		}


		$this->Log('Db conn ok, both local and server.', 3);
		return 0;
	} // end of func TestDb


} // end of class SyncDbCurl
?>



1			<?php
2			/**
3			* @package fwolflib
4			* @subpackage class
5			* @copyright Copyright 2010, Fwolf
6			* @author Fwolf <[email protected]>
7			* @since 2010-05-25
8			*/
9
10
11			require_once(dirname(__FILE__) . '/fwolflib.php');
12			require_once(FWOLFLIB . 'class/adodb.php');
13			require_once(FWOLFLIB . 'class/curl-comm.php');
14
15
16			/**
17			* Sync db data via curl communication.
18			*
19			* Db schema of both side should be same,
20			* Each data table should have timestamp and PK column.
21			*
22			*
23			* If sync in two-way, that need server ID and write ID to every row,
24			* which is 'functional' but not fast and need change many things
25			* on app side, like readonly option.
26			*
27			* So I think make this a one-way sync tools, but it can do pull also
28			* push, that is, for 1 table, it's one-way, but for the whole db,
29			* it's somehow 'two-way' sync.
30			*
31			* Also I have some additional thought:
32			* - Make app read and write to server/remote db through this.
33			* - When write to server/remote db and remote side not accessable,
34			* cache it and can call re-write later.
35			*
36			*
37			* When act as server, make config vars as less as possible,
38			* db param can passed in through POST,
39			* but crypt key must be assigned.
40			*
41			* When act as client, can connect to multi server,
42			* each have difference config, job, crypt etc,
43			* client comm with them one by one.
44			*
45			*
46			* Roadmap:
47			*
48			* 1.4 Cache for write to remote db, and re-call them.
49			* 1.3 Provide app read and write functional from/to remote db.
50			* 1.2 Sync push to server.
51			* 1.1 Auto call data convert func.
52			* 1.0 [:TODO:] Sync pull from server.
53			*
54			* @package fwolflib
55			* @subpackage class
56			* @copyright Copyright 2010, Fwolf
57			* @author Fwolf <[email protected]>
58			* @since 2010-05-25
59			* @version 0.0
60			*/
61			class SyncDbCurl extends CurlComm {
62
63			/**
64			* Default value of config
65			* array(
66			* url,
67			* db_client => array(
68			* type, host, user, pass, name, lang
69			* ),
70			* db_server => array(
71			* type, host, user, pass, name, lang
72			* ),
73			* pull => '' or array(),
74			* push => '' or array(),
75			* )
76			* @var array
77			*/
78			public $aCfgDefault = array();
79
80			/**
81			* Config of all server, empty val will fill by $aCfgDefault.
82			* @see $aCfgDefault
83			* @var array
84			*/
85			public $aCfgServer = array();
86
87			/**
88			* Db conn obj
89			* @var object
90			*/
91			protected $oDb = null;
92
93
94			/**
95			* Constructor
96			*
97			* @param array $ar_cfg
98			*/
99			public function __construct($ar_cfg = array()) {
100			// For auto new obj
101			unset($this->oDb);
102
103			parent::__construct($ar_cfg);
104
105			// Server will auto start, manual start client
106			if (empty($_POST))
107			$this->StartClient();
108			} // end of func __construct
109
110
111			/**
112			* At server, conn to db before call action func.
113			*
114			* @param array $ar_req
115			* @return array
116			*/
117			protected function CommReturn($ar_req) {
118			// Db, use posted db config first.
119			if (isset($ar_req['db_server']))
120			$ar_db_prof = $ar_req['db_server'];
121			else
122			// Using default config
123			// Notice, there is no server config array on the server.
124			// so we only read default config.
125			$ar_db_prof = $this->aCfgDefault['db_server'];
126			$this->oDb = $this->NewObjDb($ar_db_prof);
127
128			return parent::CommReturn($ar_req);
129			} // end of func CommReturn
130
131
132			/**
133			* Test db conn @ server side.
134			*
135			* @see TestDb()
136			* @see CommReturn() Db is connected here.
137			* @param array $ar_req Request msg array
138			* @return array
139			*/
140			protected function CommReturnTestDb($ar_req = array()) {
			0 ignored issues – show Unused Code introduced 2018-01-24 08:29 UTC by Report Bug Copy Issue Report The parameter `$ar_req` is not used and could be removed. This check looks from parameters that have been defined for a function or method, but which are not used in the method body. Loading history...
141			$ar = array();
142			if (empty($this->oDb)) {
143			$ar['code'] = 1;
144			$ar['msg'] = 'Test server db conn fail.';
145			} else {
146			$ar['code'] = 0;
147			$ar['msg'] = 'Test server db conn ok.';
148			}
149			return $ar;
150			} // end of func CommReturnTestDb
151
152
153			/**
154			* New db conn obj
155			*
156			* @param array $db_prof
157			* @return object
158			* @see $oDb
159			*/
160			protected function NewObjDb($db_prof) {
161			$obj = new Adodb($db_prof);
			0 ignored issues – show Deprecated Code introduced 2016-06-01 06:17 UTC by Report Bug Copy Issue Report The class `Adodb` has been deprecated with message: Use Fwlib\Bridge\Adodb This class, trait or interface has been deprecated. The supplier of the file has supplied an explanatory message. The explanatory message should give you some clue as to whether and when the type will be removed from the class and what other constant to use instead. Loading history...
162			if (false == $obj->Connect()) {
			0 ignored issues – show Coding Style Best Practice introduced 2016-06-01 06:17 UTC by Report Bug Copy Issue Report It seems like you are loosely comparing two booleans. Considering using the strict comparison `===` instead. When comparing two booleans, it is generally considered safer to use the strict comparison operator. Loading history...
163			$this->Log('Db conn fail.', 5);
164			return null;
165			}
166			else {
167			$this->Log('New obj db.', 1);
168			return $obj;
169			}
170			} // end of func NewObjDb
171
172
173			/**
174			* Read and set config
175			*
176			* @param array $ar_cfg
177			* @return $this
178			*/
179			public function SetCfg($ar_cfg = array()) {
180			parent::SetCfg($ar_cfg);
181			if (!empty($ar_cfg)) {
182			$this->aCfgDefault = ArrayRead($ar_cfg, 'default', array());
			0 ignored issues – show Documentation Bug introduced 2016-06-01 06:17 UTC by Report Bug Copy Issue Report It seems like `ArrayRead($ar_cfg, 'default', array())` of type `*` is incompatible with the declared type `array` of property `$aCfgDefault`. Our type inference engine has found an assignment to a property that is incompatible with the declared type of that property. Either this assignment is in error or the assigned type should be added to the documentation/type hint for that property.. Loading history... Deprecated Code introduced 2016-06-01 06:17 UTC by Report Bug Copy Issue Report The function `ArrayRead()` has been deprecated with message: Use Fwlib\Util\ArrayUtil::getIdx(), getEdx() This function has been deprecated. The supplier of the file has supplied an explanatory message. The explanatory message should give you some clue as to whether and when the function will be removed from the class and what other function to use instead. Loading history...
183			$this->aCfgServer = ArrayRead($ar_cfg, 'server', array());
			0 ignored issues – show Documentation Bug introduced 2016-06-01 06:17 UTC by Report Bug Copy Issue Report It seems like `ArrayRead($ar_cfg, 'server', array())` of type `*` is incompatible with the declared type `array` of property `$aCfgServer`. Our type inference engine has found an assignment to a property that is incompatible with the declared type of that property. Either this assignment is in error or the assigned type should be added to the documentation/type hint for that property.. Loading history... Deprecated Code introduced 2016-06-01 06:17 UTC by Report Bug Copy Issue Report The function `ArrayRead()` has been deprecated with message: Use Fwlib\Util\ArrayUtil::getIdx(), getEdx() This function has been deprecated. The supplier of the file has supplied an explanatory message. The explanatory message should give you some clue as to whether and when the function will be removed from the class and what other function to use instead. Loading history...
184			}
185			return $this;
186			} // end of func SetCfg
187
188
189			/**
190			* Fill server config using default
191			*
192			* @return $this
193			*/
194			protected function SetCfgServer() {
195			// These keys in cfg default can assign to server.
196			$ar_keys = array('url', 'db_client', 'db_server'
197			, 'pull', 'push');
198
199			if (!empty($this->aCfgServer)) {
200			foreach ($this->aCfgServer as $server => &$cfg) {
201			foreach ($ar_keys as $key) {
202			if (empty($cfg[$key])
203			&& !empty($this->aCfgDefault[$key]))
204			$cfg[$key] = $this->aCfgDefault[$key];
205			}
206			if (empty($cfg)) {
207			// Invalid server config
208			$this->Log('Invalid server config: ' . $server, 4);
209			}
210			}
211			}
212
213			$this->Log('Got ' . count($this->aCfgServer)
214			. ' server todo.', 1);
215
216			return $this;
217			} // end of func SetCfgServer
218
219
220			/**
221			* Act as client
222			*
223			* @return $this
224			*/
225			public function StartClient() {
226			// Fill server config using default
227			$this->SetCfgServer();
228
229			if (empty($this->aCfgServer)) {
230			$this->Log('Got no valid server config.', 5);
231			return $this;
232			}
233
234			foreach ($this->aCfgServer as $server => $cfg) {
235			$this->Log('Treat server "' . $server . '".', 3);
236			$this->sUrlRemote = $cfg['url'];
237			if (!empty($cfg['db_server']))
238			$this->aMsgExtra['db_server'] = $cfg['db_server'];
239
240			// Test curl connection
241			if (0 != $this->CommSendTest()) {
242			$this->Log('Error conn to server "' . $server
243			. '" ', 4);
244			return $this;
245			}
246			// Test db connection
247			if (0 != $this->TestDb($cfg)) {
248			$this->Log('Error when test db.', 5);
249			return $this;
250			}
251
252			// Begin pull and push
253			if (!empty($cfg['pull']))
254			$this->StartClientPull($cfg);
255			}
256
257			return $this;
258			} // end of func StartClient
259
260
261			/**
262			* Do pull of a single server
263			*
264			* @param array $cfg
265			*/
266			public function StartClientPull($cfg) {
267			// Which tbl to pull ?
268			$ar_tbl = $this->oDb->MetaTables('TABLES');
269			if (!empty($ar_tbl)) {
270			$ar_tbl = FilterWildcard($ar_tbl, $cfg['pull']);
			0 ignored issues – show Deprecated Code introduced 2016-06-01 06:17 UTC by Report Bug Copy Issue Report The function `FilterWildcard()` has been deprecated with message: Use Fwlib\Util\ArrayUtil::searchByWildcard() This function has been deprecated. The supplier of the file has supplied an explanatory message. The explanatory message should give you some clue as to whether and when the function will be removed from the class and what other function to use instead. Loading history...
271			$this->Log('Got ' . count($ar_tbl) . ' tables to pull: '
272			. implode(', ', $ar_tbl), 3);
273
274			// Pull tables
275			if (!empty($ar_tbl)) {
276			foreach ($ar_tbl as $s_tbl) {
277			$this->StartClientPullTbl($cfg, $s_tbl);
278			}
279			}
280			}
281			else {
282			$this->Log('Pull fail: no tables on client side.', 4);
283			}
284			} // end of func StartClientPull
285
286
287			/**
288			* Do pull of a single table
289			*
290			* @param array $cfg
291			* @param string $s_tbl
292			*/
293			public function StartClientPullTbl($cfg, $s_tbl) {
			0 ignored issues – show Unused Code introduced 2018-01-24 08:29 UTC by Report Bug Copy Issue Report The parameter `$cfg` is not used and could be removed. This check looks from parameters that have been defined for a function or method, but which are not used in the method body. Loading history...
294			if (empty($s_tbl)) {
295			$this->Log('StartClientPullTbl: empty table name.', 5);
296			}
297			else
298			$this->Log("StartClientPullTbl: $s_tbl");
299			} // end of func StartClientPullTbl
300
301
302			/**
303			* Test db connection
304			*
305			* @param array $cfg
306			* @return int 0=ok, other=error.
307			*/
308			public function TestDb($cfg) {
309			// Client db
310			$this->oDb = $this->NewObjDb($cfg['db_client']);
311			if (empty($this->oDb)) {
312			$this->Log('Test client db conn fail.', 5);
313			return 1;
314			}
315			$this->Log('Test local db conn ok.', 1);
316
317			// Server db
318			$ar = array('action' => 'test-db');
319			$ar = $this->CommSend($ar);
320			if (isset($ar['code'])) {
321			if (0 == $ar['code']) {
322			$this->Log('Test server db conn ok.', 1);
323			} else {
324			$this->Log('Test server db conn fail.', 5);
325			return 2;
326			}
327			} else {
328			$this->Log('Test server db conn fail, invalid response.', 5);
329			return 3;
330			}
331
332
333			$this->Log('Db conn ok, both local and server.', 3);
334			return 0;
335			} // end of func TestDb
336
337
338			} // end of class SyncDbCurl
339			?>
			0 ignored issues – show Best Practice introduced 2016-06-01 06:17 UTC by Report Bug Copy Issue Report It is not recommended to use PHP's closing tag `?>` in files other than templates. Using a closing tag in PHP files that only contain PHP code is not recommended as you might accidentally add whitespace after the closing tag which would then be output by PHP. This can cause severe problems, for example headers cannot be sent anymore. A simple precaution is to leave off the closing tag as it is not required, and it also has no negative effects whatsoever. Loading history...
340

fwolf / fwlib

SyncDbCurl A last analyzed 2019-05-09 15:53 UTC

Complexity

Size/Duplication

Coupling/Cohesion

Importance

10 Methods

Duplication Side-by-Side

Filter issues like

SyncDbCurl A
last analyzed 2019-05-09 15:53 UTC