Skip to content

Commit

Permalink
halfway done with the decision core
Browse files Browse the repository at this point in the history
  • Loading branch information
@camshaft
camshaft committed Feb 24, 2012
1 parent 6c65008 commit 0487cbc
Showing 1 changed file with 199 additions and 20 deletions.
219 changes: 199 additions & 20 deletions src/phpmachine_decision_core.php
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,29 +9,31 @@


function handle_request($resource, $state) {
phpmachine_registry/set(RESOURCE_KEY, $resource);
phpmachine_registry/set(STATE_KEY, $state);
phpmachine_registry\set(RESOURCE_KEY, $resource);
phpmachine_registry\set(STATE_KEY, $state);
try {
_decision('v3b13');
return _decision('v3b13');
}
catch($e) {
catch(Exception $e) {

}
}

function _wrcall($x) {
$state = phpmachine_registry/get(STATE_KEY);
$request = phpmachine_request/new($state);
list($response, $newState) = $request:call($x);
phpmachine_registry/set(STATE_KEY, $newState);
$state = phpmachine_registry\get(STATE_KEY);
$request = phpmachine_request\new_req($state);
$requestFun = $request.'\\call';
list($response, $newState) = $requestFun($x);
phpmachine_registry\set(STATE_KEY, $newState);
return $response;
}

function _resource_call($function) {
$resource = phpmachine_registry/get(RESOURCE_KEY);
list($reply, $newResource, $newState) = $resource:do($function, phpmachine_registry/all());
phpmachine_registry/set(RESOURCE_KEY, $newResource);
phpmachine_registry/set(STATE_KEY, $newState);
$resource = phpmachine_registry\get(RESOURCE_KEY);
$resourceFun = $resource.'\\do';
list($reply, $newResource, $newState) = $resourceFun($function, phpmachine_registry\all());
phpmachine_registry\set(RESOURCE_KEY, $newResource);
phpmachine_registry\set(STATE_KEY, $newState);
return $reply;
}

Expand All @@ -44,7 +46,7 @@ function _method() {
}

function _decision($id) {
phpmachine_registry/set(DECISION_KEY, $id);
phpmachine_registry\set(DECISION_KEY, $id);
// log the decision
$fun = '_decision_'.$id;
return $fun();
Expand All @@ -55,7 +57,7 @@ function _respond($code, $headers = NULL) {
_wrcall(array('set_resp_headers', $headers));
}

$resource = phpmachine_registry/get(RESOURCE_KEY);
$resource = phpmachine_registry\get(RESOURCE_KEY);
$endTime = time();

switch ($code) {
Expand All @@ -70,7 +72,7 @@ function _respond($code, $headers = NULL) {
break;
}

phpmachine_registry/set(CODE_KEY, $code);
phpmachine_registry\set(CODE_KEY, $code);
_wrcall(array('set_response_code', $code));
_resource_call('finish_response');
$rnamespace = _wrcall(array('get_metadata', 'resource_module'));
Expand All @@ -82,7 +84,8 @@ function _respond($code, $headers = NULL) {

// do log

$resource\stop();
$resourceFun = $resource.'\\stop';
$resourceFun();
}

function _error_response($reason, $code = 500) {
Expand Down Expand Up @@ -134,8 +137,9 @@ function do_log($logData) {
}

function _log_decision($id) {
$resource = phpmachine_registry/get(RESOURCE_KEY);
return $resource\log_d($id);
$resource = phpmachine_registry\get(RESOURCE_KEY);
$resourceFun = $resource.'\\log_d';
return $resourceFun($id);
}

// Service Available
Expand All @@ -160,7 +164,7 @@ function _decision_v3b11() {
function _decision_v3b10() {
$methods = _resource_call('allowed_methods');
if (in_array(_method(), $methods)) {
return _decision_v3b9();
return _decision('v3b9');
}
else {
_wrcall(array('set_resp_headers', array('Allow'=>implode(', ', $methods))));
Expand All @@ -176,7 +180,182 @@ function _decision_v3b9() {
// Authorized?
function _decision_v3b8() {
$isAuthorized = _resource_call('is_authorized');
if($isAuthorized === true) {
return _decision('v3b7');
}
elseif (is_array($isAuthorized)) {
if ($isAuthorized[0] == 'error') {
return _error_response($isAuthorized[1]);
}
else {
return _respond($isAuthorized[1]);
}
}
else {
_wrcall(array('set_resp_header', 'WWW-Authenticate', $isAuthorized));
return _respond(401);
}
}

return _decision_test(_resource_call('malformed_request') , true, 400, 'v3b8');
// Forbidden ?
function _decision_v3b7() {
return _decision_test(_resource_call('forbidden'), true, 403, 'v3b6');
}

// Okay Content-* Headers?
function _decision_v3b6() {
return _decision_test(_resource_call('valid_content_headers'), true, 'v3b5', 501);
}

// Known Content-Type?
function _decision_v3b5() {
return _decision_test(_resource_call('known_content_type'), true, 'v3b4', 415);
}

// Req Entity Too Large?
function _decision_v3b4() {
return _decision_test(_resource_call('valid_entity_length'), true, 'v3b3', 413);
}

// OPTIONS?
function _decision_v3b3() {
$method = _method();
if ($method == 'OPTIONS') {
$headers = _resource_call('options');
return _respond(200, $headers);
}
else {
return _decision('v3c3');
}
}

// Accept exists?
function _decision_v3c3() {
$accept = _get_header_val('accept');
if ($accept === null) {
$providedTypes = _resource_call('content_types_provided');
_wrcall(array('set_metadata', 'content-type', $providedTypes[0]));
return _decision('v3d4');
}
else {
return _decision('v3c4');
}
}

// Acceptable media type available?
function _decision_v3c4() {
$providedTypes = _resource_call('content_types_provided');
$accept = _get_header_val('accept');
$type = phpmachine_util\choose_media_type($providedTypes, $accept);

if ($type === null) {
return _respond(406);
}
else {
_wrcall(array('set_metadata', 'content-type', $type));
return _decision('v3d4');
}
}

// Accept-Language exists?
function _decision_v3d4() {
return _decision_test(get_header_val('accept-language'), null, 'v3e5', 'v3d5');
}

// Acceptable Language available?
function _decision_v3d5() {
return _decision_test(_resource_call('language_available'), true, 'v3e5', 406);
}

// Accept-Charset exists?
function _decision_v3e5() {
$charset = _get_header_val('accept-charset');

if($charset === null) {
return _decision_test(_choose_charset('*'), 'none', 406, 'v3f6');
}
else {
return _decision('v3e6');
}
}

// Accept-Encoding exists?
function _decision_v3f6() {
$contentType = _wrcall(array('get_metadata', 'content-type'));
$charset = _wrcall(array('get_metadata', 'chosen-charset'));
if ($charset === null) {
$charset = '';
}
else {
$charset = '; charset=' . $charset;
}

_wrcall(array('set_resp_headers', 'Content-Type', $contentType . $charset));

$encoding = _get_header_val('accept-encoding');
if ($encoding === null) {
return _decision_test(_choose_encoding('identity;q=1.0,*;q=0.5'), 'none', 406, 'v3g7');
}
else {
return _decision('v3f7');
}

}

// Acceptable encoding available?
function _decision_v3f7() {
return _decision_test(_choose_encoding(_get_header_val('accept-encoding')), 'none', 406, 'v3g7');
}

// Resource exists?
function _decision_v3g7() {
$variances = _variances();
if (is_array($variances) && count($variances)) {
_wrcall(array('set_resp_header', 'Vary', implode(', ', $variances)));
}
return _decision_test(_resource_call('resource_exists'), true, 'v3g8', 'v3h7');
}

// If-Match exists?
function _decision_v3g8() {
return _decision_test(_get_header_val('if-match'), null, 'v3h10', 'v3g11');
}

// If-Match: * exists?
function _decision_v3g9() {
return _decision_test(_get_header_val('if-match'), '*', 'v3h10', 'v3g11');
}

// ETag in If-Match
function _decision_v3g11() {
$etags = phpmachine_util\split_quoted_strings(_get_header_val('if-match'));
return _decision_test(_resource_call('generate_etag'),
function($etag) use ($etags) { return in_array($etag, $etags); },
'v3h10',
412);
}

// If-Match exists?
function _decision_v3h7() {
return _decision_test(_get_header_val('if-match'), null, 'v3i7', 412);
}

// If-unmodified-since exists?
function _decision_v3h10() {
return _decision_test(_get_header_val('if-unmodified-since'), null, 'v3i12', 'v3h11');
}

// I-UM-S is valid date?
function _decision_v3h11() {
$IUMSDate = get_header_val("if-unmodified-since");
return _decision_test(phpmachine_util\convert_request_date($IUMSDate), 'bad_date', 'v3i12', 'v3h12');
}

// Last-Modified > I-UM-S?
function _decision_v3h12() {
$requestDate = get_header_val("if-unmodified-since");
$reqPhpDate = phpmachine_util\convert_request_date($requestDate);
$resPhpDate = _resource_call('last_modified');
return _decision_test($resPhpDate > $reqPhpDate, true, 412, 'v3i12');
}

0 comments on commit 0487cbc

Please sign in to comment.