HSAL\Driver\Handlersocketi

Complexity

Total Complexity

24

Size/Duplication

Total Lines	155
Duplicated Lines	42.58 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	getReadSocket()	13	13	3
A	getWriteSocket()	13	13	3
A	fetchArray()	0	17	4
B	fetchAll()	11	24	5
A	delete()	0	14	2
A	insert()	0	12	1
A	update()	0	14	2
A	increment()	14	14	2
A	decrement()	15	15	2

<?php

// Copyright (c) Dmitry Kosenkov,  All rights reserved.

namespace HSAL\Driver;

use \HSAL\HSAL;
use \HSAL\Driver;
use \HSAL\DriverInterface;

class Handlersocketi extends Driver implements DriverInterface
{
	private $hsr;	
	private $hsr_connected = FALSE;

	private $hsw;
	private $hsw_connected = FALSE;

	protected function getReadSocket()

This method seems to be duplicated in your project.

	{
		if (!$this->hsr_connected)
		{
			$options = ['timeout' => (isset($this->options['timeout']) ? $this->options['timeout'] : 5)];

			$this->hsr = new \HandlerSocketi($this->host, $this->port_read, $options);

			$this->hsr_connected = TRUE;
		}

		return $this->hsr;
	}

	protected function getWriteSocket()

This method seems to be duplicated in your project.

	{
		if (!$this->hsw_connected)
		{
			$options = ['timeout' => (isset($this->options['timeout']) ? $this->options['timeout'] : 5)];

			$this->hsw = new \HandlerSocketi($this->host, $this->port_write, $options);

			$this->hsw_connected = TRUE;
		}

		return $this->hsw;
	}


	public function fetchArray($table, Array $fields, $index, Array $condition, $operator)
	{
		$hs = $this->getReadSocket();

		list($database, $table) = $this->getTableDatabase($table);

		if ($index == HSAL::INDEX_PRIMARY) $index = 'PRIMARY';

		$idx = $hs->openIndex($database, $table, $fields, ['index' => $index]);

		$result = $idx->find([$operator => $condition]);

		if (!empty($result) && is_array($result))
			return $result[0];
		else
			return FALSE;
	}

	public function fetchAll($table, Array $fields, $index, Array $condition, $operator, $limit, $offset)
	{
		$hs = $this->getReadSocket();

		list($database, $table) = $this->getTableDatabase($table);

		if ($index == HSAL::INDEX_PRIMARY) $index = 'PRIMARY';

		$idx = $hs->openIndex($database, $table, $fields, ['index' => $index]);

		$result = $idx->find([$operator => $condition], ['limit' => $limit, 'offset' => $offset]);

		if (!empty($result) && is_array($result))

This code seems to be duplicated across your project.

		{
			foreach ($result as $key => $arr) 
			{
				$result[$key] = array_combine($fields, $arr);
			}

			return $result;
		}
		else
			return FALSE;
	}

	public function delete($table, $index, Array $condition, $operator)
	{
		$hs = $this->getWriteSocket();

		list($database, $table) = $this->getTableDatabase($table);

		if ($index == HSAL::INDEX_PRIMARY) $index = 'PRIMARY';

		$idx = $hs->openIndex($database, $table, [], ['index' => $index]);

		$result = $idx->remove([$operator => $condition]);

		return (bool)$result;
	}

	public function insert($table, Array $values)
	{
		$hs = $this->getWriteSocket();

		list($database, $table) = $this->getTableDatabase($table);

		$idx = $hs->openIndex($database, $table, array_keys($values));

		$result = $idx->insert(array_values($values));

		return (bool)$result;
	}

	public function update($table, Array $values, $index, Array $condition, $operator)
	{
		$hs = $this->getWriteSocket();

		list($database, $table) = $this->getTableDatabase($table);

		if ($index == HSAL::INDEX_PRIMARY) $index = 'PRIMARY';

		$idx = $hs->openIndex($database, $table, array_keys($values), ['index' => $index]);

		$result = $idx->update([$operator => $condition], array_values($values));

		return (bool)$result;
	}

	public function increment($table, $field, $index, Array $condition, $operator, $increment)

This method seems to be duplicated in your project.

	{
		$hs = $this->getWriteSocket();

		list($database, $table) = $this->getTableDatabase($table);

		if ($index == HSAL::INDEX_PRIMARY) $index = 'PRIMARY';

		$idx = $hs->openIndex($database, $table, [$field], ['index' => $index]);

		$result = $idx->update([$operator => $condition], ['+' => $increment]);

		return (bool)$result;
	}

	public function decrement($table, $field, $index, Array $condition, $operator, $decrement)

This method seems to be duplicated in your project.

	{

		$hs = $this->getWriteSocket();

		list($database, $table) = $this->getTableDatabase($table);

		if ($index == HSAL::INDEX_PRIMARY) $index = 'PRIMARY';

		$idx = $hs->openIndex($database, $table, [$field], ['index' => $index]);

		$result = $idx->update([$operator => $condition], ['-' => $decrement]);

		return (bool)$result;
	}

}