Resource (REST) programming model and conventions

HTTP Method    URI                   Description
-----------    ---                   ----------------
GET            /people               list members
POST           /people               create member
GET            /people/1             retrieve member
PUT            /people/1             update member
DELETE         /people/1             delete member

/resources/<collection name>[/<member identifier>[/<path info>]]

def onList() {
    // Get configured DataManager for data access
    def data = zero.data.groovy.Manager.create('peopleDB')

    def result = data.queryArray('SELECT * FROM people')

    // Serialize list to JavaScript Object Notation format
    request.view = 'JSON'
    request.json.output = result
      
    render()
}

def onCreate() {
    // Convert entity to JSON object
    def emp = zero.json.Json.decode(request.input[])

    def data = zero.data.groovy.Manager.create('peopleDB')

    def memberId = data.insert(
                      """INSERT INTO people (firstname, lastname)
                         VALUES ($emp.firstname, $emp.lastname)""", ['id'])

    // Set a Location header with URI to the new record
    locationUri = getRequestedUri(false) + '/' + memberId
    request.headers.out.Location = locationUri
    request.status = HttpURLConnection.HTTP_NO_CONTENT
}

def onRetrieve() {
    // Member id is parsed from the path
    String id = request.params.peopleId[]

    def data = zero.data.groovy.Manager.create('peopleDB')
    def person = data.queryFirst("SELECT * FROM people WHERE id=$id")

    if(person!= null) {
        // Use ViewEngine JSON rendering
        request.view='JSON'
        request.json.output = person
     
        render()
    
    } else {
        // Error handling
        request.status = HttpURLConnection.HTTP_NOT_FOUND
        request.error.message = "username $username not found."
        request.view = 'error'
        render()
    }
}
 
def onUpdate() {
    def emp = zero.json.Json.decode(request.input[])

    def data = zero.data.groovy.Manager.create('personDB')

    data.update("UPDATE employees "
        + "SET firstname=$emp.firstname, lastname=$emp.lastname "
        + "WHERE id=$emp.id")

    request.status = HttpURLConnection.HTTP_NO_CONTENT
}
 
def onDelete() {
    def id = request.params.peopleId[]
    def data = zero.data.groovy.Manager.create('personDB')

    data.update("DELETE FROM people WHERE id=$id");

    request.status = HttpURLConnection.HTTP_NO_CONTENT
}

<?php

switch (zget('/request/method')) {
        case 'GET':
        if (zget('/event/_name') == 'list') {
                // Perform a list specific operation on the collection
        } else {
                // /event/_name = "retrieve"
                // Retrieve the resource
        }
        break;
        case 'POST':
        // do POST specific handling
        break;
        case 'DELETE':
        // do DELETE specific handling
        break;
        case 'PUT':
        // do PUT specific handling
        break;
}

?>

<?php
// Initialization common to all operations
// Get configured (as 'employee_db' in zero.config) DataManager for data access
$dataManager = data_manager('employee_db');
class Employees {
	function onList() {
		global $dataManager;
		// Retrieve employee records via Query Zero
		$employeeRecords = dataExec($dataManager, "SELECT * FROM employees");
                // Use the zero global context to render the data as JSON
		zput('/request/view', 'JSON');
		zput('/request/json/output', $employeeRecords);
		render_view();
	}
	function onCreate() {
		global $dataManager;
		// Convert the raw JSON stream in to a PHP array
		$er = json_decode($HTTP_RAW_POST_DATA);
		$result = dataExec($dataManager, "INSERT INTO employees (username, firstname, lastname, location, phonenumber) ". 
		 	"VALUES (?, ?, ?, ?, ?)", array($er['username'], $er['firstname'], $er['lastname'], $er['location'], $er['phonenumber']));
		// verify that an entry was inserted
		// Set a Location header with URI to the new record
		zput('/request/status', 201);
		$locationUri = zget('/request/path') . "/" . $er["username"];
		zput('/request/headers/out/Location', $locationUri);
		zput('/request/headers/out/Content-Type', 'text/json');  			
  	 	echo json_encode($er);
	}
	function onRetrieve() {
		// Get configured DataManager for data access
		global $dataManager;
		// Zero puts 'itemId' when accessing restful resources 
		$username = zget("/request/params/employeesId");
		// Retrieve employee record via Query Zero
		$employeeRecord = dataQueryFirst($dataManager, "SELECT * FROM employees WHERE username=?", array($username));
	  	// JSON encode employee record
		zput('/request/headers/out/Content-Type', 'text/json');  			
	 	echo json_encode($employeeRecord);
	}
	function onUpdate() {
		// Get configured DataManager for data access
		global $dataManager;
		$employeeId = zget('/request/params/employeesId');
		// By convention, Zero places posted text/json into the GC as a JSON object
		$er = json_decode($HTTP_RAW_POST_DATA);
		$result = dataExec($dataManager, "UPDATE employees SET firstname=?, lastname=?, ".
                            "location=?, phonenumber=? WHERE username=?",
                            array($er['firstname'], $er['lastname'], $er['location'], $er['phonenumber'], $employeeId));
		zput("/request/status", 204);
	}
	function onDelete() {
		// Get configured DataManager for data access
		global $dataManager;
		$username = zget("/request/params/employeesId");
		// Delete employee record via Query Zero
		$result = dataExec($dataManager, "DELETE FROM employees WHERE username=?", array($username));
		zput("/request/status", 204);
	}
}
?>