<?php

namespace HandlerSocket;

class Pipeline implements ReadCommands,WriteCommands
{
	/**
	 * @var array
	 */
	protected $queue = array();
	/**
	 * @var ReadSocket | WriteSocket
	 */
	protected $socket = NULL;
	
	public function __construct($socket)
	{
		$this->socket = $socket;
		$this->reset();
	}
	
	public function reset()
	{
		$this->queue = array();
		$this->accumulate = true;
	}
	
	public function execute()
	{
		foreach($this->queue as $call)
		{
			call_user_func_array(array($this->socket,$call['method']),$call['args']);
		}
		$ret = array();
		foreach($this->queue as $call)
		{
			$ret[] = call_user_func($call['callback'],$this->socket->readResponse());
		}
		return $ret;
	}
	
	protected function null_callback($ret){return $ret;}
	
	public function registerCallback($callback=NULL)
	{
		if($callback==NULL) $callback=$this->null_callback;
		$this->queue[count($this->queue)-1]['callback']=$callback;
		return NULL;
	}
	
	protected function addToQueue($item)
	{
		$this->queue[]=$item;
	}
	
	public function select($index,$compare,$keys,$limit=1,$begin=0)
	{
		$this->addToQueue(array('method'=>'select','args'=>func_get_args()));
	}
	
	public function update($index,$compare,$keys,$values,$limit=1,$begin=0)
	{
		$this->addToQueue(array('method'=>'update','args'=>func_get_args()));
	}
	
	public function delete($index,$compare,$keys,$limit=1,$begin=0)
	{
		$this->addToQueue(array('method'=>'delete','args'=>func_get_args()));
	}
	
	public function insert($index,$values)
	{
		$this->addToQueue(array('method'=>'insert','args'=>func_get_args()));
	}
	
	public function openIndex($index,$db,$table,$key,$fields)
	{
		$this->addToQueue(array('method'=>'openIndex','args'=>func_get_args()));
	}
	
	public function getIndexId($db,$table,$key,$fields)
	{
		return $this->socket->getIndexId($db,$table,$key,$fields);
	}
}