hestiacp/web/vesta/api/DB.class.php

<?php

/**
 * DB 
 * 
 * @author Naumov-Socolov <naumov.socolov@gmail.com>
 * @author Malishev Dima <dima.malishev@gmail.com>
 * @author vesta, http://vestacp.com/
 * @copyright vesta 2011
 */
class DB extends AjaxHandler 
{
	
	/**
	 * List entries
	 * 
	 * @param Request $request
	 * @return
	 */
    public function getListExecute($request) 
    {
		$_user = 'vesta';
		$reply = array();		
		$result = Vesta::execute(Vesta::V_LIST_DB_BASES, array($_user, Config::get('response_type')));

		foreach ($result['data'] as $db => $record)
		{
			$reply[$db] = array(
				'DB' => $db,
				'USER' => $record['USER'],
				'HOST' => $record['HOST'],
				'TYPE' => $record['TYPE'],
				'U_DISK' => $record['U_DISK'],
				'SUSPEND' => $record['SUSPEND'],
				'DATE' => date(Config::get('ui_date_format', strtotime($record['DATE'])))
			);
		}
		
		if (!$result['status'])
		{
			$this->errors[] = array($result['error_code'] => $result['error_message']);
		}
		
		return $this->reply($result['status'], $reply);
	}

	/**
	 * Add entry
	 * 
	 * @param Request $request
	 * @return
	 */
	public function addExecute($request) 
	{
		$r = new Request();
		$_s = $r->getSpell();
		$_user = 'vesta';

		$params = array(
			'USER' => $_user,
			'DB' => $_s['DB'],
			'DB_USER' => $_s['DB_USER'],
			'DB_PASSWORD' => $_s['DB_PASSWORD'],
			'TYPE' => $_s['TYPE']
		);
		if ($_s['HOST']) 
		{
			$params['HOST'] = $_s['HOST'];
		}

		$result = Vesta::execute(Vesta::V_ADD_DB_BASE, $params);

		if (!$result['status'])
		{
			$this->errors[] = array($result['error_code'] => $result['error_message']);
		}

		return $this->reply($result['status'], $result['data']);
	}
      
	/**
	 * Delete entry
	 * 
	 * @param Request $request
	 * @return
	 */
	public function delExecute($request) 
	{
		$r = new Request();
		$_s = $r->getSpell();
		$_user = 'vesta';

		$params = array(
			'USER' => $_user,
			'DB' => $_user.'_'.$_s['DB']
		);

		$result = Vesta::execute(Vesta::V_DEL_DB_BASE, $params);

		if (!$result['status'])
		{
			$this->errors[] = array($result['error_code'] => $result['error_message']);
		}

		return $this->reply($result['status'], $result['data']);
	}

	/**
	 * Change password
	 * 
	 * @param Request $request
	 * @return
	 */
	public function changePasswordExecute($request)
	{
		$r = new Request();
		$_s = $r->getSpell();

		$_user = 'vesta';

		$result = array();
		$params = array(
			'USER' => $_user,
			'DB' => $_user.'_'.$_s['DB'],
			'PASSWORD' => $_s['DB_PASSWORD']
		);

		$result = Vesta::execute(Vesta::V_CHANGE_DB_PASSWORD, $params);

		if (!$result['status'])
		{
			$this->errors[] = array($result['error_code'] => $result['error_message']);
		}

		return $this->reply($result['status'], $result['data']);
	}
	
	/**
	 * suspend user
	 * 
	 * @param Request $request
	 * @return
	 */
	public function suspendExecute($request)
	{
		$r = new Request();
		$_s = $r->getSpell();

		$_user = 'vesta';

		$params = array(
			'USER' => $_user,
			'DB' => $_user.'_'.$_s['DB']
		);

		$result = Vesta::execute(Vesta::V_SUSPEND_DB_BASE, $params);

		if (!$result['status'])
		{
			$this->errors[] = array($result['error_code'] => $result['error_message']);
		}

		return $this->reply($result['status'], $result['data']);
	}

	/**
	 * unsuspend entry
	 * 
	 * @param Request $request
	 * @return
	 */
	public function unsuspendExecute($request)
	{
		$r = new Request();
		$_s = $r->getSpell();

		$_user = 'vesta';

		$params = array(
			'USER' => $_user,
			'DB' => $_user.'_'.$_s['DB']
		);

		$result = Vesta::execute(Vesta::V_UNSUSPEND_DB_BASE, $params);

		if (!$result['status']) 
		{
			$this->errors[] = array($result['error_code'] => $result['error_message']);
		}

		return $this->reply($result['status'], $result['data']);
	}

	/**
	 * Batch suspend entries
	 * 
	 * @param Request $request
	 * @return
	 */
	public function suspendAllExecute($request)
	{
		$r = new Request();
		$_s = $r->getSpell();

		$_user = 'vesta';
		$_JOB = $_s['JOB'];

		$params = array(
			'USER' => $_user
		);

		$result = Vesta::execute(Vesta::V_SUSPEND_DB_BASES, $params);

		if (!$result['status'])
		{
			$this->errors[] = array($result['error_code'] => $result['error_message']);
		}

		return $this->reply($result['status'], $result['data']);
	}

	/**
	 * Batch unsuspend entries
	 * 
	 * @param Request $request
	 * @return
	 */
	public function unsuspendAllExecute($request)
	{
		$r = new Request();
		$_s = $r->getSpell();

		$_user = 'vesta';

		$params = array(
			'USER' => $_user
		);

		$result = Vesta::execute(Vesta::V_UNSUSPEND_DB_BASES, $params);

		if (!$result['status'])
		{
			$this->errors[] = array($result['error_code'] => $result['error_message']);
		}

		return $this->reply($result['status'], $result['data']);
	}
    
}