Function: Advanced DECREMENT operation

Enterprise Edition

Goal: Perform the Advanced DECREMENT operation where Eventing interacts with the Data service.

This function advancedDecrementOp merely demonstrates the Advanced DECREMENT operation.
Requires a metadata bucket, a source bucket.
Needs a Binding of type Bucket Alias (as documented in the Scriptlet).
Will operate on any mutation and count down (decrement) the mutations subject to DCP dedup.
For more information refer to Advanced DECREMENT operation in the detailed documentation.

advancedDecrementOp
Input Data/Mutation
Output Data
Output Log

// To run need a Binding in this Function's Settings as follows:
// 1. Bucket Alias
// 2. src_bkt
// 3. source
// 4. read+write
function OnUpdate(doc, meta) {
    if (!meta.id.startsWith("dec:")) return;
    // log('input meta', meta);
    // log('input doc ', doc);

    // if doc.count doesn't exist it will be created
    var ctr_meta = {"id": "my_atomic_counter:1" };
    var result = couchbase.decrement(src_bkt,ctr_meta);
    if (result.success) {
        log('success adv. decrement: result',result);
    } else {
        log('failure adv. decrement: id',ctr_meta.id,'result',result);
    }
}

UPSERT INTO `source` (KEY,VALUE)
  VALUES ( "dec:1",  {"somekey":"someValue"} ),
  VALUES ( "dec:2",  {"somekey":"someValue"} ),
  VALUES ( "dec:3",  {"somekey":"someValue"} ),
  VALUES ( "dec:4",  {"somekey":"someValue"} ),
  VALUES ( "dec:5",  {"somekey":"someValue"} ),
  VALUES ( "dec:6",  {"somekey":"someValue"} ),
  VALUES ( "dec:7",  {"somekey":"someValue"} ),
  VALUES ( "dec:8",  {"somekey":"someValue"} ),
  VALUES ( "dec:9",  {"somekey":"someValue"} ),
  VALUES ( "dec:10", {"somekey":"someValue"} );

We insert ten (10) documents and count the mutations via decrementing

KEY: my_atomic_counter:1

{
  "count": -10
}

2021-01-08T12:30:59.910-08:00 [INFO] "success adv. increment: result"
{"doc":{"count":-1},"meta":{"id":"my_atomic_counter:1","cas":"1610137859908960256"},"success":true}

2021-01-08T12:30:59.910-08:00 [INFO] "success adv. increment: result"
{"doc":{"count":-2},"meta":{"id":"my_atomic_counter:1","cas":"1610137859909222400"},"success":true}

2021-01-08T12:30:59.911-08:00 [INFO] "success adv. increment: result"
{"doc":{"count":-3},"meta":{"id":"my_atomic_counter:1","cas":"1610137859911385088"},"success":true}

2021-01-08T12:30:59.931-08:00 [INFO] "success adv. increment: result"
{"doc":{"count":-4},"meta":{"id":"my_atomic_counter:1","cas":"1610137859929997312"},"success":true}

2021-01-08T12:30:59.931-08:00 [INFO] "success adv. increment: result"
{"doc":{"count":-5},"meta":{"id":"my_atomic_counter:1","cas":"1610137859930193920"},"success":true}

2021-01-08T12:30:59.932-08:00 [INFO] "success adv. increment: result"
{"doc":{"count":-6},"meta":{"id":"my_atomic_counter:1","cas":"1610137859932160000"},"success":true}

2021-01-08T12:30:59.932-08:00 [INFO] "success adv. increment: result"
{"doc":{"count":-7},"meta":{"id":"my_atomic_counter:1","cas":"1610137859932356608"},"success":true}

2021-01-08T12:30:59.948-08:00 [INFO] "success adv. increment: result"
{"doc":{"count":-8},"meta":{"id":"my_atomic_counter:1","cas":"1610137859946381312"},"success":true}

2021-01-08T12:30:59.948-08:00 [INFO] "success adv. increment: result"
{"doc":{"count":-9},"meta":{"id":"my_atomic_counter:1","cas":"1610137859946708992"},"success":true}

2021-01-08T12:30:59.948-08:00 [INFO] "success adv. increment: result"
{"doc":{"count":-10},"meta":{"id":"my_atomic_counter:1","cas":"1610137859948412928"},"success":true}