tyler.durden
/
icingaweb2-module-director
mirror of https://github.com/Icinga/icingaweb2-module-director.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ObjectController: allow all REST api methods

This commit is contained in:
Thomas Gelf 2016-02-03 00:54:00 +01:00
parent 4eb3b1936c
commit 0ebf269ebd
1 changed files with 65 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

68
library/Director/Web/Controller/ObjectController.php
View File

@ -2,6 +2,7 @@
namespace Icinga\Module\Director\Web\Controller;
use Exception;
use Icinga\Web\Url;
use Icinga\Module\Director\Objects\IcingaObject;
@ -59,9 +60,11 @@ abstract class ObjectController extends ActionController
public function indexAction()
{
if ($this->getRequest()->isApiRequest()) {
return $this->sendJson(
$this->object->toPlainObject($this->params->shift('resolved'))
);
try {
return $this->handleApiRequest();
} catch (Exception $e) {
return $this->sendJson((object) array('error' => $e->getMessage()));
}
}
return $this->editAction();
@ -254,4 +257,63 @@ abstract class ObjectController extends ActionController
return $this->object;
}
protected function handleApiRequest()
{
$request = $this->getRequest();
$db = $this->db();
switch ($request->getMethod()) {
case 'DELETE':
$name = $this->object->object_name;
$obj = $this->object->toPlainObject(false, true);
$form = $this->loadForm(
'icingaDeleteObject'
)->setObject($this->object)->setRequest($request)->onSuccess();
return $this->sendJson($obj);
case 'POST':
case 'PUT':
$type = $this->getType();
$data = (array) json_decode($request->getRawBody());
if ($object = $this->object) {
if ($request->getMethod() === 'POST') {
$object->setProperties($data);
} else {
$object->replaceWith(
IcingaObject::createByType($type, $data)
);
}
} else {
$object = IcingaObject::createByType($type, $data, $db);
}
$response = $this->getResponse();
if ($object->hasBeenModified()) {
$object->store();
if ($object->hasBeenLoadedFromDb()) {
$response->setHttpResponseCode(200);
} else {
$response->setHttpResponseCode(201);
}
} else {
$response->setHttpResponseCode(304);
}
return $this->sendJson($object->toPlainObject(false, true));
case 'GET':
return $this->sendJson(
$this->object->toPlainObject(
$this->params->shift('resolved'),
! $this->params->shift('withNull'),
$this->params->shift('properties')
)
);
default:
throw new Exception('Unsupported method ' . $request->getMethod());
}
}
}