ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: usr / local / lib / node_modules / pm2 / node_modules / continuation-local-storage / test

'use strict';

var test   = require('tap').test
  , cls    = require('../context.js')
  , domain = require('domain')
  ;

test("continuation-local storage glue with a throw in the continuation chain",
     function (t) {
  var namespace = cls.createNamespace('test');
  namespace.run(function () {
    var d = domain.create();
    namespace.set('outer', true);
    namespace.bindEmitter(d);

d.on('error', function (blerg) {
      t.equal(blerg.message, "explicitly nonlocal exit", "got the expected exception");
      t.ok(namespace.get('outer'), "outer context is still active");
      t.notOk(namespace.get('inner'), "inner context should have been exited by throw");
      t.equal(namespace._set.length, 1, "should be back to outer state");

cls.destroyNamespace('test');
      t.end();
    });

// tap is only trying to help
    process.nextTick(d.bind(function () {
      t.ok(namespace.get('outer'), "outer mutation worked");
      t.notOk(namespace.get('inner'), "inner mutation hasn't happened yet");

namespace.run(function () {
        namespace.set('inner', true);
        throw new Error("explicitly nonlocal exit");
      });
    }));
  });
});

test("synchronous throw attaches the context", function (t) {
  t.plan(3);

t.equal(namespace.get('value'), 'transaction clear', "everything was reset");
  });

cls.destroyNamespace('cls@synchronous');
});

test("synchronous throw checks if error exists", function (t) {
  t.plan(2);

t.equal(namespace.get('value'), 'transaction clear', "everything was reset");
  });

cls.destroyNamespace('cls@synchronous-null-error');
});

test("throw in process.nextTick attaches the context", function (t) {
  t.plan(3);

var namespace = cls.createNamespace('cls@nexttick');
  var d = domain.create();
  namespace.bindEmitter(d);

d.on('error', function (e) {
    t.ok(namespace.fromException(e), "context was attached to error");
    t.equal(namespace.fromException(e)['value'], 'transaction set',
            "found the inner value");

cls.destroyNamespace('cls@nexttick');
  });

namespace.run(function () {
    namespace.set('value', 'transaction clear');

// tap is only trying to help
    process.nextTick(d.bind(function () {
      namespace.run(function () {
        namespace.set('value', 'transaction set');
        throw new Error("cls@nexttick explosion");
      });
    }));

t.equal(namespace.get('value'), 'transaction clear', "everything was reset");
  });
});

test("throw in setTimeout attaches the context", function (t) {
  t.plan(3);

var namespace = cls.createNamespace('cls@setTimeout');
  var d = domain.create();
  namespace.bindEmitter(d);

cls.destroyNamespace('cls@setTimeout');
  });

namespace.run(function () {
    namespace.set('value', 'transaction clear');

// tap is only trying to help
    setTimeout(d.bind(function () {
      namespace.run(function () {
        namespace.set('value', 'transaction set');
        throw new Error("cls@setTimeout explosion");
      });
    }));

t.equal(namespace.get('value'), 'transaction clear', "everything was reset");
  });
});

[-] bind.tap.js [edit]
[-] zlib.tap.js [edit]
[-] promises.tap.js [edit]
[-] tracer-scenarios.tap.js [edit]
[+] ..
[-] nesting.tap.js [edit]
[-] async-no-run-queue-multiple.tap.js [edit]
[-] monkeypatching.tap.js [edit]
[-] crypto.tap.js [edit]
[-] error-handling.tap.js [edit]
[-] proper-exit.tap.js [edit]
[-] namespaces.tap.js [edit]
[-] bind-emitter.tap.js [edit]
[-] run-and-return.tap.js [edit]
[-] timers.tap.js [edit]
[-] net-events.tap.js [edit]
[-] interleave-contexts.tap.js [edit]
[-] dns.tap.js [edit]
[-] fs.tap.js [edit]
[-] simple.tap.js [edit]
[-] async-context.tap.js [edit]