cs\modules\WebSockets\Pool

Complexity

Total Complexity

7

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	del()	0	5	1
A	add()	0	12	1
A	get_master()	0	3	2
A	cdb()	0	2	1
A	get_all()	0	6	2

<?php
/**
 * @package    WebSockets
 * @subpackage CleverStyle Framework We
 * @author     Nazar Mokrynskyi <nazar@mokrynskyi.com>
 * @license    0BSD
 */
namespace cs\modules\WebSockets;
use
	cs\Config,
	cs\DB\Accessor,
	cs\Singleton;

/**
 * @method static $this instance($check = false)
 */
class Pool {
	use
		Accessor,
		Singleton;
	/**
	 * @inheritdoc
	 */
	protected function cdb () {
		return Config::instance()->module('WebSockets')->db('pool');
	}
	/**
	 * Get addresses of all servers
	 *
	 * @return string[]
	 */
	public function get_all () {
		return $this->db_prime()->qfas(
			'SELECT `address`

'SELECT `address` FROM `[prefix]websockets_pool` ORDER BY `date` ASC' of type string is incompatible with the type string[] expected by parameter $query of cs\DB\_Abstract::qfas().

			FROM `[prefix]websockets_pool`
			ORDER BY `date` ASC'
		) ?: [];
	}
	/**
	 * Get master server address
	 *
	 * @return false|string
	 */
	public function get_master () {
		$servers = $this->get_all();
		return $servers ? $servers[0] : false;
	}
	/**
	 * Add server with specified address to server
	 *
	 * @param string $server_address Address of WebSockets server in format wss://server/WebSockets or ws://server/WebSockets
	 *
	 * @return bool
	 */
	public function add ($server_address) {
		return (bool)$this->db_prime()->q(
			"INSERT IGNORE INTO `[prefix]websockets_pool`
			(
				`date`,
				`address`
			) VALUES (
				'%s',
				'%s'
			)",
			time(),

time() of type integer is incompatible with the type array expected by parameter $parameters of cs\DB\_Abstract::q().

			$server_address

$server_address of type string is incompatible with the type array expected by parameter $parameters of cs\DB\_Abstract::q().

		);
	}
	/**
	 * Delete server with specified address from pool
	 *
	 * @param string $server_address
	 *
	 * @return bool
	 *
	 */
	public function del ($server_address) {
		return (bool)$this->db_prime()->q(
			"DELETE FROM `[prefix]websockets_pool`
			WHERE `address` = '%s'",
			$server_address

$server_address of type string is incompatible with the type array expected by parameter $parameters of cs\DB\_Abstract::q().

		);
	}
}