arangodb/js/system/cursor.js

var actions = require("actions");

function postCursor(req, res) {
  if (req.suffix.length != 0) {
    actions.actionResultError (req, res, 404, actions.cursorNotModified, "Cursor not created"); 
    return;
  }

  try {
    var json = JSON.parse(req.requestBody);
    var queryString;

    if (json.qid != undefined) {
      var q = db.query.document_wrapped(json.qid);
      queryString = q.query;
    }    
    else if (json.query != undefined) {
      queryString = json.query;
    }

    if (queryString == undefined) {
      actions.actionResultError (req, res, 404, actions.cursorNotModified, "Missing query identifier");
      return;
    }
   
    var result;
    if (json.bindVars) {
      result = AQL_PREPARE(db, queryString, json.bindVars);
    }
    else {
      result = AQL_PREPARE(db, queryString);
    }

    if (result instanceof AvocadoQueryError) {
      actions.actionResultError (req, res, 404, result.code, result.message);
      return;
    }

    var cursor = result.execute();
    if (cursor instanceof AvocadoQueryError) {
      actionResultError (req, res, 404, result.code, result.message);
      return;
    }

    var maxResults = 1000;
    if (json.maxResults && parseInt(json.maxResults) > 0) {
      maxResults = parseInt(json.maxResults);
    }

    var lines = [];    
    var i = 0;
    
    while (i < maxResults && cursor.hasNext()) {
      lines[i++] = cursor.next();
    }
    
    var cursorId;
    var count = cursor.count();
    var hasMore = i < count;
    
    var result = { 
      "result" : lines,
      "_id" : cursorId,
      "hasMore" : hasMore
    };
    
    if (json.count) {
      result["count"] = count;
    } 
    
    actions.actionResultOK(req, res, 201, result);        
  }
  catch (e) {
    actions.actionResultError (req, res, 404, actions.cursorNotModified, "Cursor not created");
  }
}

function putCursor(req, res) {
  if (req.suffix.length != 1) {
    actions.actionResultError (req, res, 404, actions.cursorNotFound, "Cursor not found");
    return;
  }

  try {
    var cursorId = decodeURIComponent(req.suffix[0]);           
    
    // TODO

    var result = { 
      "result" : [{"test":"protest"}, {"hello":"world"}],
      "count" : 2,
      "_id" : cursorId,
      "hasMore" : false
    };
    
    actions.actionResultOK(req, res, 200, result);
  }
  catch (e) {
    actions.actionResultError (req, res, 404, actions.cursorNotFound, "Cursor not found");
  }
}

function deleteCursor(req, res) {
  if (req.suffix.length != 1) {
    actions.actionResultError (req, res, 404, actions.cursorNotFound, "Cursor not found");
    return;
  }

  try {
    var cid = decodeURIComponent(req.suffix[0]);
    if(db.cursor.delete(qid)) {
      actions.actionResultOK(req, res, 202, {"cid" : cid});                
    }
    else {
      actions.actionResultError (req, res, 404, actions.cursorNotFound, "Cursor not found");       
    }
  }
  catch (e) {
    actions.actionResultError (req, res, 404, actions.cursorNotFound, "Cursor not found");
  }
}

actions.defineHttp({
  url : "_api/cursor",
  context : "api",

  callback : function (req, res) {
    switch (req.requestType) {
      case ("POST") : 
        postCursor(req, res); 
        break;

      case ("PUT") :  
        putCursor(req, res); 
        break;

      case ("DELETE") :  
        deleteCursor(req, res); 
        break;

      default:
        actions.actionResultUnsupported(req, res);
    }
  }
});