Files
VestaCP/web/vesta/api/DNS.class.php
2011-12-29 19:59:51 +03:00

453 lines
17 KiB
PHP

<?php
/**
* DNS
*
* TODO: Too many "if" statements. Code should be refactored in order to not use a lot of "if" conditions
*
* @author vesta, http://vestacp.com/
* @author Dmitry Malishev <dima.malishev@gmail.com>
* @author Dmitry Naumov-Socolov <naumov.socolov@gmail.com>
* @copyright vesta 2010-2011
*/
class DNS extends AjaxHandler
{
/**
* Get DNS entries
*
* @param Request $request
* @return string - Ajax Reply
*/
public function getListExecute(Request $request)
{
$user = $this->getLoggedUser();
$reply = array();
$result = Vesta::execute(Vesta::V_LIST_DNS_DOMAINS, array($user['uid'], Config::get('response_type')));
foreach ($result['data'] as $dns_domain => $details) {
$reply[] = array(
'DNS_DOMAIN' => $dns_domain,
'IP' => $details['IP'],
'TPL' => $details['TPL'],
'TTL' => $details['TTL'],
'EXP' => $details['EXP'],
'SOA' => $details['SOA'],
'SUSPEND' => $details['SUSPEND'],
'DATE' => date(Config::get('ui_date_format', strtotime($details['DATE'])))
);
}
if (!$result['status']) {
$this->errors[] = array($result['error_code'] => $result['error_message']);
}
return $this->reply($result['status'], $reply);
}
/**
* Get DNS records
*
* @param Request $request
* @return string - Ajax Reply
*/
public function getListRecordsExecute(Request $request)
{
$_s = $request->getParameter('spell');
$user = $this->getLoggedUser();
$reply = array();
$params = array(
'USER' => $user['uid'],
'DOMAIN' => $_s['DNS_DOMAIN']
);
$result = Vesta::execute(Vesta::V_LIST_DNS_DOMAIN_RECORDS, $params, self::JSON);
foreach ($result['data'] as $record_id => $details) {
$reply[$record_id] = array(
'ID' => $record_id,
'RECORD_ID' => $record_id,
'RECORD' => $details['RECORD'],
'RECORD_TYPE' => $details['TYPE'],
'RECORD_VALUE' => str_replace('"', '', $details['VALUE']),
'SUSPEND' => $details['SUSPEND'],
'DATE' => date(Config::get('ui_date_format', strtotime($details['DATE'])))
);
}
if (!$result['status']) {
$this->errors[] = array($result['error_code'] => $result['error_message']);
}
return $this->reply($result['status'], $reply);
}
/**
* Add DNS entry
*
* v_add_dns_domain user domain ip [template] [exp] [soa] [ttl]
* http://95.163.16.160:8083/dispatch.php?jedi_method=DNS.add&USER=vesta&DOMAIN=dev.vestacp.com&IP_ADDRESS=95.163.16.160&TEMPLATE=default&EXP=01-01-12&SOA=ns1.vestacp.com&TTL=3600
*
* @param Request $request
* @return string - Ajax Reply
*/
public function addExecute(Request $request)
{
$user = $this->getLoggedUser();
$_s = $request->getParameter('spell');
$params = array(
'USER' => $user['uid'], /// OWNER ???
'DNS_DOMAIN' => $_s['DNS_DOMAIN'],
'IP' => $_s['IP']
);
// TODO: rewrite this block. Get away from if/if/if/if
if ($_s['TPL']) {
$params['TPL'] = $_s['TPL'];
}
if ($_s['EXP']) {
$params['EXP'] = $_s['EXP'];
}
if ($_s['SOA']) {
$params['SOA'] = $_s['SOA'];
}
if ($_s['TTL']) {
$params['TTL'] = $_s['TTL'];
}
$result = Vesta::execute(Vesta::V_ADD_DNS_DOMAIN, $params);
if (!$result['status']) {
$this->errors[] = array($result['error_code'] => $result['error_message']);
}
if ($_s['SUSPEND'] == 'on') {
if($result['status']){
$result = array();
$result = Vesta::execute(Vesta::V_SUSPEND_DNS_DOMAIN, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_s['DNS_DOMAIN']));
if (!$result['status']) {
$this->status = FALSE;
$this->errors['SUSPEND'] = array($result['error_code'] => $result['error_message']);
}
}
}
return $this->reply($result['status'], $result['data']);
}
/**
* Add DNS record
*
* v_add_dns_domain_record user domain record type value [id]
* http://95.163.16.160:8083/dispatch.php?jedi_method=DNS.addRecord&USER=vesta&DOMAIN=dev.vestacp.com&RECORD=ftp&TYPE=a&VALUE=87.248.190.222
*
* @param Request $request
* @return string - Ajax Reply
*/
public function addRecordExecute(Request $request)
{
$user = $this->getLoggedUser();
$_s = $request->getParameter('spell');
$params = array(
'USER' => $user['uid'],
'DOMAIN' => $_s['DOMAIN'],
'RECORD' => $_s['RECORD'],
'RECORD_TYPE' => $_s['TYPE'],
'RECORD_VALUE' => $_s['VALUE'],
'RECORD_ID' => $_s['RECORD_ID']
);
$result = Vesta::execute(Vesta::V_ADD_DNS_DOMAIN_RECORD, $params);
if (!$result['status']) {
$this->errors[] = array($result['error_code'] => $result['error_message']);
}
return $this->reply($result['status'], $result['data']);
}
/**
* Delete DNS entry
*
* v_delete_dns_domain user domain
* http://95.163.16.160:8083/dispatch.php?jedi_method=DNS.del&USER=vesta&DOMAIN=dev.vestacp.com
*
* @param Request $request
* @return string - Ajax Reply
*/
public function deleteExecute(Request $request)
{
$user = $this->getLoggedUser();
$_s = $request->getParameter('spell');
$params = array(
'USER' => $user['uid'], /// OWNER ???
'DOMAIN' => $_s['DNS_DOMAIN'],
);
$result = Vesta::execute(Vesta::V_DEL_DNS_DOMAIN, $params);
if (!$result['status']) {
$this->errors[] = array($result['error_code'] => $result['error_message']);
}
return $this->reply($result['status'], $result['data']);
}
/**
* Add DNS record
*
* v_delete_dns_domain_record user domain id
* http://95.163.16.160:8083/dispatch.php?jedi_method=DNS.delRecord&USER=vesta&DOMAIN=dev.vestacp.com&RECORD_ID=9
*
* @param Request $request
* @return string - Ajax Reply
*/
public function deleteRecordExecute(Request $request)
{
$_s = $request->getParameter('spell');
$dns = $request->getParameter('dns');
$user = $this->getLoggedUser();
$params = array(
'USER' => $user['uid'], // TODO: OWNER ???
'DOMAIN' => $dns['DNS_DOMAIN'],
'RECORD_ID' => $_s['RECORD_ID']
);
$result = Vesta::execute(Vesta::V_DEL_DNS_DOMAIN_RECORD, $params);
if (!$result['status']) {
$this->errors[] = array($result['error_code'] => $result['error_message']);
}
return $this->reply($result['status'], $result['data']);
}
/**
* Change DNS entry
*
* TODO: get away from multiple "if" statements
*
* DNS.change&spell={"old":{"DNS_DOMAIN": "dev.vestacp.com","IP": "95.163.16.160","TPL": "default","TTL": "3377","EXP": "12-12-12","SOA": "ns2.vestacp.com"},"new":{"DNS_DOMAIN": "dev.vestacp.com","IP": "95.163.16.160","TPL": "default","TTL": "3600","EXP": "02-02-12","SOA": "ns1.vestacp.com"}}
*
* @param Request $request
* @return string - Ajax Reply
*/
public function changeExecute(Request $request)
{
$_old = $request->getParameter('old');
$_new = $request->getParameter('new');
$user = $this->getLoggedUser();
$_DNS_DOMAIN = $_old['DNS_DOMAIN'];
$result = array();
if($_new['SUSPEND'] == 'on'){
$result = Vesta::execute(Vesta::V_SUSPEND_DNS_DOMAIN, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_DNS_DOMAIN));
return $this->reply($result['status']);
}
else{
$result = Vesta::execute(Vesta::V_UNSUSPEND_DNS_DOMAIN, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_DNS_DOMAIN));
}
if (!$result['status']) {
$this->status = FALSE;
$this->errors['SUSPEND'] = array($result['error_code'] => $result['error_message']);
}
if ($_old['IP'] != $_new['IP']) {
$result = array();
$result = Vesta::execute(Vesta::V_CHANGE_DNS_DOMAIN_IP, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_DNS_DOMAIN, 'IP' => $_new['IP']));
if (!$result['status']) {
$this->status = FALSE;
$this->errors['IP_ADDRESS'] = array($result['error_code'] => $result['error_message']);
}
}
if ($_old['TPL'] != $_new['TPL']) {
$result = array();
$result = Vesta::execute(Vesta::V_CHANGE_DNS_DOMAIN_TPL, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_DNS_DOMAIN, 'IP' => $_new['TPL']));
if (!$result['status']) {
$this->status = FALSE;
$this->errors['TPL'] = array($result['error_code'] => $result['error_message']);
}
}
if ($_old['TTL'] != $_new['TTL']) {
$result = array();
$result = Vesta::execute(Vesta::V_CHANGE_DNS_DOMAIN_TTL, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_DNS_DOMAIN, 'IP' => $_new['TTL']));
if (!$result['status']) {
$this->status = FALSE;
$this->errors['TTL'] = array($result['error_code'] => $result['error_message']);
}
}
if ($_old['EXP'] != $_new['EXP']) {
$result = array();
$result = Vesta::execute(Vesta::V_CHANGE_DNS_DOMAIN_EXP, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_DNS_DOMAIN, 'IP' => $_new['EXP']));
if (!$result['status']) {
$this->status = FALSE;
$this->errors['EXP'] = array($result['error_code'] => $result['error_message']);
}
}
if ($_old['SOA'] != $_new['SOA']) {
$result = array();
$result = Vesta::execute(Vesta::V_CHANGE_DNS_DOMAIN_SOA, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_new['DNS_DOMAIN'], 'IP' => $_new['SOA']));
if (!$result['status']) {
$this->status = FALSE;
$this->errors['SOA'] = array($result['error_code'] => $result['error_message']);
}
}
if (!$this->status) {
Vesta::execute(Vesta::V_CHANGE_DNS_DOMAIN_IP, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_DNS_DOMAIN, 'IP' => $_old['IP']));
Vesta::execute(Vesta::V_CHANGE_DNS_DOMAIN_TPL, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_DNS_DOMAIN, 'IP' => $_old['TPL']));
Vesta::execute(Vesta::V_CHANGE_DNS_DOMAIN_TTL, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_DNS_DOMAIN, 'IP' => $_old['TTL']));
Vesta::execute(Vesta::V_CHANGE_DNS_DOMAIN_EXP, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_DNS_DOMAIN, 'IP' => $_old['EXP']));
Vesta::execute(Vesta::V_CHANGE_DNS_DOMAIN_SOA, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_new['DNS_DOMAIN'], 'IP' => $_old['SOA']));
if($_old['SUSPEND'] == 'on'){
$result = Vesta::execute(Vesta::V_SUSPEND_DNS_DOMAIN, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_DNS_DOMAIN));
}
else{
$result = Vesta::execute(Vesta::V_UNSUSPEND_DNS_DOMAIN, array('USER' => $user['uid'], 'DNS_DOMAIN' => $_DNS_DOMAIN));
}
}
return $this->reply($this->status, '');
}
/**
* Change DNS record
*
* @param Request $request
* @return string - Ajax Reply
*/
public function changeRecordsExecute(Request $request)
{
$records = $request->getParameter('spell');
$dns = $request->getParameter('dns');
$user = $this->getLoggedUser();
$domain = $dns['DNS_DOMAIN'];
// Get current records
$curr_records = array();
$params = array(
'USER' => $user['uid'],
'DOMAIN' => $domain
);
$result = Vesta::execute(Vesta::V_LIST_DNS_DOMAIN_RECORDS, $params, self::JSON);
foreach ($result['data'] as $record_id => $details) {
$curr_records[] = $record_id;
}
$new_records = array();
foreach ($records as $record) {
if ((int)$record['RECORD_ID'] > 0) {
$new_records[] = $record['RECORD_ID'];
}
}
$delete = array_diff(array_values($curr_records), array_values($new_records));
foreach ($records as $record) {
if (((int)$record['RECORD_ID'] > 0) == false) {
$params = array(
'USER' => $user['uid'],
'DOMAIN' => $domain,
'RECORD' => $record['RECORD'],
'RECORD_TYPE' => $record['RECORD_TYPE'],
'RECORD_VALUE' => $record['RECORD_VALUE']
);
$result = Vesta::execute(Vesta::V_ADD_DNS_DOMAIN_RECORD, $params);
if (!$result['status']) {
$this->status = FALSE;
$this->errors[$record_id] = array($result['error_code'] => $result['error_message']);
}
}
else {
$params = array(
'USER' => $user['uid'],
'DOMAIN' => $domain,
'ID' => (int)$record['RECORD_ID'],
'RECORD' => $record['RECORD'],
'RECORD_TYPE' => $record['RECORD_TYPE'],
'RECORD_VALUE' => $record['RECORD_VALUE']
);
$result = Vesta::execute(Vesta::V_CHANGE_DNS_DOMAIN_RECORD, $params);
if (!$result['status']) {
$this->status = FALSE;
$this->errors[$record_id] = array($result['error_code'] => $result['error_message']);
}
}
}
foreach ($delete as $record_id) {
$params = array(
'USER' => $user['uid'],
'DOMAIN' => $domain,
'ID' => $record_id
);
$result = Vesta::execute(Vesta::V_DEL_DNS_DOMAIN_RECORD, $params);
if (!$result['status']) {
$this->status = FALSE;
$this->errors[$record_id] = array($result['error_code'] => $result['error_message']);
}
}
return $this->reply($this->status, '');
}
public function getTemplateInfoExecute($request)
{
$spell = $request->getParameter('spell');
$result = Vesta::execute('v_list_user_packages', null, self::JSON);
$reply = $result['data'];
if (isset($spell['PACKAGE'])) {
$reply = $result['data'][$spell['PACKAGE']];
}
return $this->reply(true, $reply);
}
public function massiveSuspendExecute(Request $request)
{
$user = $this->getLoggedUser();
$_entities = $request->getParameter('entities');
foreach($_entities as $entity){
$result = Vesta::execute(Vesta::V_SUSPEND_DNS_DOMAIN, array('USER' => $user['uid'], $entity['DNS_DOMAIN']));
}
return $this->reply($result['status'], $result['data']);
}
public function massiveUnsuspendExecute(Request $request)
{
$user = $this->getLoggedUser();
$_entities = $request->getParameter('entities');
foreach($_entities as $entity){
$result = Vesta::execute(Vesta::V_UNUSPEND_DNS_DOMAIN, array('USER' => $user['uid'], $entity['DNS_DOMAIN']));
}
return $this->reply($result['status'], $result['data']);
}
public function massiveDeleteExecute(Request $request)
{
$user = $this->getLoggedUser();
$_entities = $request->getParameter('entities');
foreach($_entities as $entity){
$result = Vesta::execute(Vesta::V_DEL_DNS_DOMAIN, array('USER' => $user['uid'], $entity['DNS_DOMAIN']));
}
return $this->reply($result['status'], $result['data']);
}
}