HSAL\Driver\Handlersocketi

Complexity

Total Complexity

22

Size/Duplication

Total Lines	156
Duplicated Lines	34.62 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	3
Bugs	2	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	getReadSocket()	0	11	2
A	getWriteSocket()	0	11	2
A	fetchArray()	0	17	4
B	fetchAll()	11	24	5
A	delete()	14	14	2
A	insert()	0	12	1
A	update()	0	16	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;

This use statement conflicts with another class in this namespace, HSAL\Driver\DriverInterface.

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

	private $hsw;
	private $hsw_connected = FALSE;

	const PORT_READ = 9998;
	const PORT_WRITE = 9999;

	protected function getReadSocket()
	{
		if (!$this->hsr_connected)
		{
			$this->hsr = new \HandlerSocketi($this->host, self::PORT_READ);

			$this->hsr_connected = TRUE;
		}

		return $this->hsr;
	}

	protected function getWriteSocket()
	{
		if (!$this->hsw_connected)
		{
			$this->hsw = new \HandlerSocketi($this->host, self::PORT_WRITE);

			$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';

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

		$result = $index->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';

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

		$result = $index->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)

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';

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

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

		return (bool)$result;
	}

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

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

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

		$result = $index->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';

$index is not used, you could remove the assignment.

		$fields = array_keys($values);

$fields is not used, you could remove the assignment.

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

		$result = $index->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';

$index is not used, you could remove the assignment.

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

		$result = $index->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';

$index is not used, you could remove the assignment.

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

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

		return (bool)$result;
	}

}