Please use the form below to provide your feedback. Because your feedback is valuable to us, the information you submit in this form is recorded in our issue tracking system (JIRA), which is publicly available. You can track the status of your feedback using the ticket number displayed in the dialog once you submit the form.

Function: Advanced DELETE Operation

    March 16, 2025
    + 12

    Perform the Advanced DELETE operation where Eventing interacts with the Data Service.

    The advancedDeleteOp function:

    • Performs the Advanced DELETE operation

    • Requires Eventing Storage (or a metadata collection) and a source collection

    • Requires a binding of type bucket alias

    • Operates on any mutation where doc.type === "control_adv_delete"

    • Always tries to insert the test document and ignores insert errors

    • Has 4 modes of operation: no_cas, bad_cas, good_cas, and no_key

    For more information about the Advanced Self-Recursion Parameter, see Advanced DELETE Operation.

    javascript
    Copy
    // Configure the settings for the advancedDeleteOp function as follows:
//
// Version 7.1+
//   "Function Scope"
//     *.* (or try bulk.data if non-privileged)
// Version 7.0+
//   "Listen to Location"
//     bulk.data.source
//   "Eventing Storage"
//     rr100.eventing.metadata
//   Binding(s)
//    1. "binding type", "alias name...", "bucket.scope.collection", "Access"
//       "bucket alias", "src_col",       "bulk.data.source",        "read and write"
//
// Version 6.6.1
//   "Source Bucket"
//     source
//   "MetaData Bucket"
//     metadata
//   Binding(s)
//    1. "binding type", "alias name...", "bucket",     "Access"
//       "bucket alias", "src_col",       "source",     "read and write"

function OnUpdate(doc, meta) {
    if (!meta.id.startsWith("control_adv_delete")) return;

    log('input meta', meta);
    log('input doc ', doc);

    // Setup, make sure there is a doc to "delete", ignore any errors
    couchbase.insert(src_col,{"id":"test_adv_delete:" + doc.ins_id},{"a:": 1});

    var new_meta;
    if (doc.mode && doc.mode === "no_cas") {
        // No CAS is passed - it always succeeds
        new_meta = {"id":"test_adv_delete:" + doc.ins_id};
    }
    if (doc.mode && doc.mode === "bad_cas") {
        // Pass a non-matching CAS - it always fails
        new_meta = {"id":"test_adv_delete:" + doc.ins_id, "cas":"1111111111111111111"};
    }
    if (doc.mode && doc.mode === "good_cas") {
        // Pass the matching or current CAS - it succeeds
        var tmp_r = couchbase.get(src_col,{"id":"test_adv_delete:" + doc.ins_id});
        if (tmp_r.success) {
            // Use the current CAS to read via couchbase.get(...)
            new_meta = {"id":"test_adv_delete:" + doc.ins_id, "cas": tmp_r.meta.cas};
        } else {
            log('Cannot delete due to no such key',"test_adv_delete:" + doc.ins_id);
            return;
        }
    }
    if (doc.mode && doc.mode === "no_key") {
        // Remove (delete with a basic bucket op) so that we have: no such key
        delete src_col["test_adv_delete:" + doc.ins_id]
        new_meta = {"id":"test_adv_delete:" + doc.ins_id};
    }
    var result = couchbase.delete(src_col,new_meta);
    if (result.success) {
        log('success adv. delete: result',result);
    } else {
        log('failure adv. delete: id',new_meta.id,'result',result);
    }
}