Alpha\Controller\ActiveRecordController::doPOST()

Complexity

Conditions	11
Paths	186

Size

Total Lines	82
Code Lines	54

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    public function doPOST($request)
    {
        self::$logger->debug('>>doDPOST(request=['.var_export($request, true).'])');

        $config = ConfigProvider::getInstance();

        $params = $request->getParams();
        $accept = $request->getAccept();

        try {
            if (isset($params['ActiveRecordType'])) {
                $ActiveRecordType = urldecode($params['ActiveRecordType']);
            } else {
                throw new IllegalArguementException('No ActiveRecord available to create!');
            }

            if (class_exists($ActiveRecordType)) {
                $record = new $ActiveRecordType();
            } else {
                throw new IllegalArguementException('No ActiveRecord ['.$ActiveRecordType.'] available to create!');
            }

            // check the hidden security fields before accepting the form POST data
            if (!$this->checkSecurityFields()) {
                throw new SecurityException('This page cannot accept post data from remote servers!');
            }

            $record->populateFromArray($params);

            try {
                $record->save();
            } catch (ValidationException $e) {
                self::$logger->warn($e->getMessage());
                $this->setStatusMessage(View::displayErrorMessage($e->getMessage()));
            }

            self::$logger->action('Created new '.$ActiveRecordType.' instance with ID '.$record->getID());

            if (isset($params['statusMessage'])) {
                $this->setStatusMessage(View::displayUpdateMessage($params['statusMessage']));
            } else {
                $this->setStatusMessage(View::displayUpdateMessage('Created'));
            }

            ActiveRecord::disconnect();

            if ($accept == 'application/json') {
                $view = View::getInstance($record, false, $accept);
                $body = $view->detailedView();
                $response = new Response(201);
                $response->setHeader('Content-Type', 'application/json');
                $response->setHeader('Location', $config->get('app.url').'/record/'.$params['ActiveRecordType'].'/'.$record->getID());
                $response->setBody($body);

                self::$logger->debug('<<doPOST');

                return $response;
            } else {
                $response = new Response(301);

                if ($this->getNextJob() != '') {
                    $response->redirect($this->getNextJob());
                } else {
                    if ($this->request->isSecureURI()) {
                        $response->redirect(FrontController::generateSecureURL('act=Alpha\\Controller\\ActiveRecordController&ActiveRecordType='.$ActiveRecordType.'&ActiveRecordID='.$record->getID()));
                    } else {
                        $response->redirect($config->get('app.url').'/record/'.$params['ActiveRecordType'].'/'.$record->getID());
                    }
                }

                self::$logger->debug('<<doPOST');

                return $response;
            }
        } catch (SecurityException $e) {
            self::$logger->warn($e->getMessage());
            throw new ResourceNotAllowedException($e->getMessage());
        } catch (IllegalArguementException $e) {
            self::$logger->warn($e->getMessage());
            throw new ResourceNotFoundException('The record that you have requested cannot be found!');
        }
    }