❤
npm
Sign UpSign In

nlab

0.7.2 • Public • Published

Tests npm version npm version NpmLicense jest coverage

Table of Contents

(TOC generated using markdown-toc)

Promise delay

const delay = require("nlab/delay");

delay(3000, "ok").then((data) => console.log("then:", data));
// prints 'then: ok' after 3 sek
const delay = require("nlab/delay");

Promise.resolve("all good")
  .then(
    (data) => delay(3000, data),
    (data) => delay.reject(3000, data),
  )
  .then(
    (ok) => console.log("ok:", ok),
    (error) => console.log("catch:", error),
  );
// 'ok: all good' - after 3 sec
const delay = require("nlab/delay");

Promise.reject("all wrong")
  .then(
    (data) => delay(3000, data),
    (data) => delay.reject(3000, data),
  )
  .then(
    (ok) => console.log("ok:", ok),
    (error) => console.log("catch:", error),
  );
// 'catch: all wrong' - after 3 sec
const then = require("nlab/delay").then;

const { then } = require("nlab/delay");

Promise.resolve("resolved")
  .then(...then(1000))
  .then((data) => console.log("then:", data));
// 'then: resolved' - after 1 sec

Promise.reject("rejected")
  .then(...then(1000))
  .catch((data) => console.log("catch:", data));
// 'catch: rejected' - after 1 sec

Use of delay() with es6:

import delay from "nlab/delay";

const delay = require("nlab/delay");

(async function () {
  console.log("start");

  await delay(1000);

  console.log("end");
})();

// 'start'
// 'end' - after 1 sec

promiseall

Works like Promise.all but when one or more promises in array are rejected, it will still wait for all other promises to resolve or reject ( to finish their job ), and return array like:

const promiseall = require("nlab/promiseall");

import promiseall from "nlab/promiseall";

const list = promiseall([
  /* ... array of promises to wait ... */
]);

// example response (if at least one promise is rejected)

[
  {
    resolved: true,
    data: "...",
  },
  {
    resolved: true,
    data: "...",
  },
  {
    resolved: false,
    data: "...",
  },
  {
    resolved: true,
    data: "...",
  },
];

If all promises are resolved then there is not difference in behaviour from native Promise.all(). It just return array of payloads from those resolved promises.

promiseall in this variant is designed to address some particular issues with race condition

lightFetch

const lightFetch = require("nlab/lightFetch");

import lightFetch from "nlab/lightFetch";

(async function () {
  try {
    const res = await lightFetch("/url", {
      method: "POST",
      body: {
        // because body is object it will be sent as json
        some: "data",
      },
      timeout: 4000, // 4 sec
    });
  } catch (e) {
    console.log(`general error: ${e}`);
  }
})();

Doc

promiseany

const promiseany = require("nlab/promiseany");

import promiseany from "nlab/promiseany";

promiseany([Promise.resolve(1), Promise.resolve(2), Promise.resolve(3)]).then(console.log); // 1

promiseany([new Promise((r) => setTimeout(() => r(1), 100)), Promise.resolve(2), Promise.resolve(3)]).then(console.log); // 2

promiseany([Promise.reject(1), Promise.resolve(2), Promise.resolve(3)]).then(console.log); // 2

promiseany([Promise.reject(1), Promise.reject(2), Promise.reject(3)]).catch(console.log); // [ 1, 2, 3 ]

parallel

Allows only to specific number of asynchronous action to be executed in parallel, rest is queued.

const parallel = require("nlab/parallel");

import parallel from "nlab/parallel";

const instance = parallel({
  numberOfThreads: 3,
});

app.all((req, res) => {
  instance((slot, release) => {
    console.log(`do some stuff ${slot}/${instance.getSetup().numberOfThreads}`);

    setTimeout(() => {
      console.log(`still in the queue: ${instance.getQueue().length}`);

      release();
    }, 100);
  });
});

md5

const md5 = require('nlab/md5');

import md5 from 'nlab/md5';

console.log(md5('str'));

# echo -n 'str' | node_modules/nlab/src/md5.js

CachePromise

const CachePromise = require("nlab/CachePromise");

import CachePromise from "nlab/CachePromise";

async (done) => {
  try {
    const cachePromise = new CachePromise({
      ttlms: 5,
    });

    let mainPromise = cachePromise.get({ a: "b3" }, () => new Promise((res) => setTimeout(res, 5, "abc")));

    let data = await mainPromise;

    expect(data).toEqual("abc");

    await delay(15);

    mainPromise = cachePromise.get({ a: "b3" }, () => new Promise((res) => setTimeout(res, 5, "abcd")));

    data = await mainPromise;

    expect(data).toEqual("abcd");

    done();
  } catch (e) {
    done({
      error: e,
    });
  }
};

isObject()

It's more strict method to test if given arg is an object - more strict than implementation from lodash or underscore.js

import isObject from "nlab/isObject";
// or
// const isObject = require('nlab/isObject');

//  ✓isObject - {}                                                  -> true
//  ✓isObject - using with object that have implemented toString()  -> true
//  ✓isObject - extended object                                     -> true
//  ✓isObject - new function () {}                                  -> true
//  ✓isObject - []                                                  -> false
//  ✓isObject - function () {}                                      -> false
//  ✓isObject - async function () {}                                -> false
//  ✓isObject - () => {}                                            -> false
//  ✓isObject - null                                                -> false
//  ✓isObject - true                                                -> false
//  ✓isObject - false                                               -> false
//  ✓isObject - NaN                                                 -> false
//  ✓isObject - undefined                                           -> false
//  ✓isObject - no arg                                              -> false
//  ✓isObject - 4                                                   -> false
//  ✓isObject - string                                              -> false
//  ✓isObject - Symbol('test')                                      -> false
//  ✓isObject - new Date()                                          -> false

To se more details about what is considired an object and what is not see test cases coverage for this file:

isArray()

It's actually Array.isArray with MDN polyfill.

import isArray from "nlab/isArray";
// or
// const isArray = require('nlab/isArray');

//  ✓isArray - []                                                  -> true
//  ✓isArray - {}                                                  -> false
//  ✓isArray - using with object that have implemented toString()  -> false
//  ✓isArray - extended object                                     -> false
//  ✓isArray - new function () {}                                  -> false
//  ✓isArray - function () {}                                      -> false
//  ✓isArray - async function () {}                                -> false
//  ✓isArray - () => {}                                            -> false
//  ✓isArray - null                                                -> false
//  ✓isArray - true                                                -> false
//  ✓isArray - false                                               -> false
//  ✓isArray - NaN                                                 -> false
//  ✓isArray - undefined                                           -> false
//  ✓isArray - no arg                                              -> false
//  ✓isArray - 4                                                   -> false
//  ✓isArray - string                                              -> false
//  ✓isArray - Symbol('test')                                      -> false

isAsyncFunction()

import isAsyncFunction from "nlab/isAsyncFunction";
// or
// const isAsyncFunction = require('nlab/isAsyncFunction');

//  ✓isAsyncFunction - []                                                  -> false
//  ✓isAsyncFunction - {}                                                  -> false
//  ✓isAsyncFunction - using with object that have implemented toString()  -> false
//  ✓isAsyncFunction - extended object                                     -> false
//  ✓isAsyncFunction - new function () {}                                  -> false
//  ✓isAsyncFunction - function () {}                                      -> false
//  ✓isAsyncFunction - async function () {}                                -> true
//  ✓isAsyncFunction - () => {}                                            -> false
//  ✓isAsyncFunction - null                                                -> false
//  ✓isAsyncFunction - true                                                -> false
//  ✓isAsyncFunction - false                                               -> false
//  ✓isAsyncFunction - NaN                                                 -> false
//  ✓isAsyncFunction - undefined                                           -> false
//  ✓isAsyncFunction - no arg                                              -> false
//  ✓isAsyncFunction - 4                                                   -> false
//  ✓isAsyncFunction - string                                              -> false
//  ✓isAsyncFunction - Symbol('test')                                      -> false

isDate()

import isDate from "nlab/isDate";
// or
// const isDate = require('nlab/isDate');

//  ✓isDate - new Date()                                          -> true
//  ✓isDate - {}                                                  -> false
//  ✓isDate - using with object that have implemented toString()  -> false
//  ✓isDate - extended object                                     -> false
//  ✓isDate - new function () {}                                  -> false
//  ✓isDate - []                                                  -> false
//  ✓isDate - function () {}                                      -> false
//  ✓isDate - async function () {}                                -> false
//  ✓isDate - () => {}                                            -> false
//  ✓isDate - null                                                -> false
//  ✓isDate - true                                                -> false
//  ✓isDate - false                                               -> false
//  ✓isDate - NaN                                                 -> false
//  ✓isDate - undefined                                           -> false
//  ✓isDate - no arg                                              -> false
//  ✓isDate - 4                                                   -> false
//  ✓isDate - string                                              -> false
//  ✓isDate - Symbol('test')                                      -> false

trim()

import trim from "nlab/trim";
// or
// const trim = require('nlab/trim');

/*!
 * direction : 'rl'|'r'|'l'   -->   (undefined => 'rl')
 * charlist  : (undefined => " \n")
 */
function trim(string, charlist, direction) {
  /* ... */
}

alphaid()

import alphaid from "nlab/alphaid";
// or
// const alphaid = require('nlab/alphaid');

const t = alphaid("abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789");

expect(t.encode(1)).toEqual("b");
expect(t.encode(2)).toEqual("c");
expect(t.encode(3)).toEqual("d");
expect(t.encode(61)).toEqual("9");
expect(t.encode(62)).toEqual("ba");
expect(t.encode(63)).toEqual("bb");

expect(t.decode(t.encode(5))).toEqual(5);
expect(t.decode(t.encode(50))).toEqual(50);
expect(t.decode(t.encode(150))).toEqual(150);

const t = alphaid("01");

expect(t.encode(1)).toEqual("1");
expect(t.encode(2)).toEqual("10");
expect(t.encode(3)).toEqual("11");
expect(t.encode(4)).toEqual("100");
expect(t.encode(5)).toEqual("101");
expect(t.encode(24)).toEqual("11000");
expect(t.encode(26)).toEqual("11010");
expect(t.encode(40)).toEqual("101000");
expect(t.encode(50)).toEqual("110010");
expect(t.encode(60)).toEqual("111100");
expect(t.encode(61)).toEqual("111101");
expect(t.encode(62)).toEqual("111110");
expect(t.encode(63)).toEqual("111111");

xor

import xor from "nlab/xor";

const key = "mysecret key";

const data = "my data";

if (xor(xor(data, key), key) === data) {
  // true
}

curry

import curry from "nlab/curry";

const curry = require("nlab/curry");

const fn = curry((a, b, c) => a + b + c);

expect(fn(2, 4)(8)).toEqual(14);

generateSalt

import generateSalt from "nlab/generateSalt";

const generateSalt = require("nlab/generateSalt");

console.log(generateSalt(12));

// d87c3e2c5373

all

import all from "nlab/all";

const all = require("nlab/all");

var k = () => {
  console.log("k");
  return ["k1", "k2"];
};

var l = () => {
  console.log("l");
  return ["l1", "l2"];
};

[k, l] = all([k, l], (data) =>
  console.log({
    callback: data,
  }),
);

setTimeout(k, 1800);
setTimeout(l, 1000);

// l
// k
// { callback: [ [ 'k1', 'k2' ], [ 'l1', 'l2' ] ] }

serializeError

import serializeError from "nlab/serializeError";
import se from "nlab/se";

const serializeError = require("nlab/serializeError");
const se = require("nlab/se");

const log = require("inspc");

try {
  throw new Error(`naha you don't`);
} catch (e) {
  log.dump({
    implicit_to_string: e,
    serializeError: serializeError(e),
    leave_stack_as_a_string: serializeError(e, true),
  });
}

// Object {
//   <implicit_to_string> [Error]: >Error: naha you don't<
//   <serializeError> Object {
//     <name> [String]: >Error< len: 5
//     <message> [String]: >naha you don't< len: 14
//     <stack> Array [
//       <0> [String]: >Error: naha you don't< len: 21
//       <1> [String]: >    at Object.<anonymous> (.../ttt.js:9:9)< len: 80
//       <2> [String]: >    at Module._compile (module.js:653:30)< len: 41
//       <3> [String]: >    at Object.Module._extensions..js (module.js:664:10)< len: 55
//       <4> [String]: >    at Module.load (module.js:566:32)< len: 37
//       <5> [String]: >    at tryModuleLoad (module.js:506:12)< len: 39
//       <6> [String]: >    at Function.Module._load (module.js:498:3)< len: 46
//       <7> [String]: >    at Function.Module.runMain (module.js:694:10)< len: 49
//       <8> [String]: >    at startup (bootstrap_node.js:204:16)< len: 41
//       <9> [String]: >    at bootstrap_node.js:625:3< len: 30
//     ]
//   }
//   <leave_stack_as_a_string> Object {
//     <name> [String]: >Error< len: 5
//     <message> [String]: >naha you don't< len: 14
//     <stack> [String]: >Error: naha you don't
//     at Object.<anonymous> (.../ttt.js:9:9)
//     at Module._compile (module.js:653:30)
//     at Object.Module._extensions..js (module.js:664:10)
//     at Module.load (module.js:566:32)
//     at tryModuleLoad (module.js:506:12)
//     at Function.Module._load (module.js:498:3)
//     at Function.Module.runMain (module.js:694:10)
//     at startup (bootstrap_node.js:204:16)
//     at bootstrap_node.js:625:3< len: 448
//   }
// }

aes256

import aes256 from "nlab/aes256";
// or
// const aes256 = require('nlab/aes256');

const c = aes256(`password`);

let msg = `message `;

const enc = c.encrypt(msg);

const dec = c.decrypt(enc);

// dec === msg;

sha256

import sha256 from "nlab/sha256";
// or
// const sha256 = require('nlab/sha256');

sha256("test"); // '9f86d081884c7d659a2feaa0c55ad015a3bf4f1b2b0b822cd15d6c15b0f00a08'

color

import c from "nlab/colors";
// or
// const c = require('nlab/colors');

const glossary = {
  Bright: "\x1b[1m",
  Dim: "\x1b[2m",
  Underscore: "\x1b[4m",
  Blink: "\x1b[5m",
  Reverse: "\x1b[7m",
  Hidden: "\x1b[8m",
  FgBlack: "\x1b[30m",
  FgRed: "\x1b[31m", // red
  FgGreen: "\x1b[32m", // green
  FgYellow: "\x1b[33m", // yellow
  FgBlue: "\x1b[34m",
  FgMagenta: "\x1b[35m", // magenta
  FgCyan: "\x1b[36m", // cyan
  FgWhite: "\x1b[37m",
  BgBlack: "\x1b[40m",
  BgRed: "\x1b[41m",
  BgGreen: "\x1b[42m",
  BgYellow: "\x1b[43m",
  BgBlue: "\x1b[44m",
  BgMagenta: "\x1b[45m",
  BgCyan: "\x1b[46m",
  BgWhite: "\x1b[47m",
  r: "\x1b[31m", // red
  g: "\x1b[32m", // green
  b: "\x1b[34m", // blue
  y: "\x1b[33m", // yellow
  m: "\x1b[35m", // magenta
  c: "\x1b[36m", // cyan
  reset: "\x1b[0m",
};

console.log(c.r(`print in red`));
console.log(c.g(`print in green`));
console.log(c.BgGreen(`print in green`));

// or
c(`print`, `in`, `blue\n`, `b`); // last arg will be use to choose color
c(`print`, `in`, `green\n`, `g`);
// the difference is that it will also print it directly using one of
// console.log() - in browser
// process.stdout.write() - in node

table of colors

get

import get from "nlab/get";
// or
// const get = require('nlab/get');

const data = {
  one: {
    two: [
      {
        t: "e",
      },
      {
        three: {
          four: {
            six: "test",
          },
        },
      },
    ],
  },
};

console.log(get(data, "one.two.1.three.four.six"));
// will print: 'test'

console.log(get(data, "one.two.1.three"));
// // will print: { four: { six: 'test' } }
//
console.log(get(data));
// // will print: { one: { two: [ [Object], [Object] ] } }
//
console.log(get(data, "one.two.1.nonexisting"));
// // will print: undefined
//
console.log(get(data, "one.two.1.nonexisting", "defvalifnotexist"));
// // will print: 'defvalifnotexist'

set

import set from "nlab/set";
// or
// const set = require('nlab/set');

let data = { one: "two" };

set(data, "three", "four");
console.log(JSON.stringify(data));
// will print: {"one":"two","three":"four"}

set(data, "three.a", "four");
console.log(JSON.stringify(data));
// will print: {"one":"two","three":{"a":"four"}}
// -> string 'four' has been replaced with object {a:'four'}

set(data, "six.seven.eight", "nine");
console.log(JSON.stringify(data, null, 4));
// will print:
// {
//     "one": "two",
//     "three": {
//         "a": "four"
//     },
//     "six": {
//         "seven": {
//             "eight": "nine"
//         }
//     }
// }

set(data, "three.bbb.ccc", "ddd");
console.log(JSON.stringify(data, null, 4));
// will print:
// {
//     "one": "two",
//     "three": {
//         "a": "four",
//         "bbb": {
//             "ccc": "ddd"
//         }
//     },
//     "six": {
//         "seven": {
//             "eight": "nine"
//         }
//     }
// }

data = { one: "two" };
set(data, "arr", []);
console.log(JSON.stringify(data));
// will print: {"one":"two","arr":[]}

set(data, "arr.", "v1"); // works like array.push();
console.log(JSON.stringify(data));
// will print: {"one":"two","arr":["v1"]}

set(data, "arr.", "v2");
console.log(JSON.stringify(data));
// will print: {"one":"two","arr":["v1","v2"]}

set(data, "arr..a.b..c", "v3");
console.log(JSON.stringify(data, null, 4));
// will print:
// {
//     "one": "two",
//     "arr": [
//         "v1",
//         "v2",
//         {
//             "a": {
//                 "b": [
//                     {
//                         "c": "v3"
//                     }
//                 ]
//             }
//         }
//     ]
// }

del

import del from "nlab/del";
// or
// const del = require('nlab/del');

const data = {
  test: {
    one: [
      {
        two: "three",
      },
      {
        four: "five",
      },
      {
        two: {
          a: "b",
          c: "d",
        },
      },
      {
        six: "seven",
      },
    ],
    empty: false,
  },
};

del(data, `test.one`);

expect(data).toEqual({
  test: {
    empty: false,
  },
});

pregQuote

Function to prefix in regex reserved characters.

import pregQuote from "nlab/pregQuote";
// or
// const pregQuote = require('nlab/pregQuote');

pregQuote("test"); // 'test'
pregQuote("test[]test"); // 'test\[\]test'
pregQuote("t?e(st"); // 't\?es\(t'

stringToRegex

Function to convert string to regex.

import stringToRegex from "nlab/stringToRegex";
// or
// const stringToRegex = require('nlab/stringToRegex');

const r = stringToRegex("/abc\\/abcf/i");

console.log(r);
// {
//   "flags": "i",
//   "source": "abc\\/abcf",
//   "str": "/abc\\/abcf/i"
// }

incrementSlug

Function to generate next possible value in db for unique key column. (In order to use it it's necessary to find 'last/biggest' slug in column):

import incrementSlug from "nlab/incrementSlug";

import slugify from "nlab/slugify";

const title = "....";

const prefix = slugify(title, { lower: true });

let newSlug = prefix;

let lastSlug = await this.queryColumn(
  debug,
  trx,
  `SELECT slug FROM :table: WHERE slug LIKE :slug ORDER BY slug desc limit 1`,
  {
    slug: prefix + "%",
  },
);

if (lastSlug) {
  nextSlug = incrementSlug(lastSlug);
}

return nextSlug;
import incrementSlug from "nlab/incrementSlug";
// or
// const incrementSlug = require('nlab/incrementSlug');

incrementSlug("test"); // 'test-1'
incrementSlug("test-30"); // 'test-31'
incrementSlug("test-30", "_"); // 'test-30_1'
incrementSlug("test_30", "_"); // 'test-31'

negotiatePort

import negotiatePort from "nlab/negotiatePort";
// or
// const negotiatePort = require('nlab/negotiatePort');

negotiatePort("http", 80); // ''
negotiatePort("http", "80"); // ''
negotiatePort("http:", "80"); // ''
negotiatePort("http://", "80"); // ''
negotiatePort("http", "81"); // '81'
negotiatePort("http", "81", ":"); // ':81'
negotiatePort("https", "80"); // '80'
negotiatePort("https", "80", ":"); // ':80'
negotiatePort("https", 443); // '443'
negotiatePort("https:", 443); // '443'
negotiatePort("https:/", 443); // '443'
negotiatePort("https://", 443); // '443'
negotiatePort("https", "443"); // '443'
negotiatePort("https", "443", ":"); // ':443'

ms

Generate human readable version of time left based on given number of miliseconds (or other unit);

import ms from "nlab/ms";

const ms = require("nlab/ms");

const generate = ms.generate;

const raw = ms.raw;

console.log(ms(89754389233)); // number of miliseconds
// 2y 308d 19h 46m 29s 233ms

console.log(ms(89754389)); // number of miliseconds
// 1d 55m 54s 389ms

console.log(ms(89754389, "s")); // number of seconds
// 2y 308d 19h 46m 29s
// other units m,h,d,y - default 'ms'

console.log(
  ms(89754389, {
    unit: "s",
    dict: {
      ms: " ms",
      s: " sec",
      m: " min",
      h: " hours",
      d: " days",
      y: " years",
    },
  }),
);
// 2 years 308 days 19 hours 46 min 29 sec

const k = generate(
  {
    ms: 45,
    s: 46,
    m: 47,
    h: 4,
    d: 3,
    y: 2,
  } /* unit: default 'ms' */,
);

console.log(k); // 63348466045

console.log(ms(k)); // 2y 3d 4h 47m 46s 45ms

console.log(JSON.stringify(raw(k)));
// {"ms":45,"s":46,"m":47,"h":4,"d":3,"y":2}

see also

cachePromiseInterval

Library for caching data and refreshing it periodicly using given async function to get the cache content, it is possible to cache multiple sets of data based on unique set of input arguments. If new set arguments appear then it will fetch data on demand.

import cachePromiseInterval from "nlab/cachePromiseInterval";

const cachePromiseInterval = require("nlab/cachePromiseInterval");

// example

const log = require("inspc");

const delay = require("nlab/delay");

const cache = cachePromiseInterval("separatebucket");

const fetch = (args, data) => {
  return cache({
    args,
    create: () =>
      new Promise((res) => {
        // console.log('fetch...')

        setTimeout(res, 20, `res: ${data}`);
      }),
    refreshinterval: 20,
  });
};

(async function () {
  {
    const { data } = await fetch(["arg"], "dd");

    console.log(`data: ${data}`); // data: res: dd
  }

  {
    // will server data from cache because args are the same
    const { data } = await fetch(["arg"], "ddd");

    console.log(`data: ${data}`); // data: res: dd
  }

  process.exit(0);
})();

// end of case 1

(async function () {
  {
    const { data } = await fetch(["arg"], "dd");

    console.log(`data: ${data}`); // data: res: dd
  }

  {
    // arguments has changed so create will be called for this set of arguments
    // and it will return different data
    const { data } = await fetch(["arg", "arg2"], "ddd");

    console.log(`data: ${data}`); // data: res: ddd
  }

  process.exit(0);
})();

// end of case 2

// first failed cache will crash server (process.exit(1)) if create return rejected promise
// it means library can't populate cache for this case
const fetchCrash = (args, data) => {
  return cache({
    args,
    // firstcrach: true, it is true by defualt
    create: () =>
      new Promise((res, rej) => {
        // console.log('fetch...')

        setTimeout(rej, 20, `rej: ${data}`);
      }),
    refreshinterval: 20,
  });
};

(async function () {
  {
    const { data } = await fetchCrash(["arg"], "dd");

    console.log(`data: ${data}`); // data: res: dd
  }

  // Object {
  //     <key> [String]: >separatebucket< len: 14
  //     <ckey> [String]: >separatebucket_9b6bc915ce444bab0f263ac01bfb83b14c5a13d0351b22a7e5c748a6d594144f< len: 79
  //     <catch> [String]: >cachePromiseInterval error: promise catch< len: 41
  //     <o> Object {
  //     <args> Array [
  //         <0> [String]: >arg< len: 3
  //     ]
  //     <create> [Function]: ><
  //     <refreshinterval> [Integer]: >20<
  //         <firstcrach> [Boolean]: >true<
  //     }
  //     <e> [String]: >rej: dd< len: 7
  //     <firstcrach> [Undefined]: >undefined<
  // }

  // server will exit with status code: 1
})();

// end of case 3

// first failed cache will crash server (process.exit(1)) if create return rejected promise
// it means library can't populate cache for this case
const fetchCrash2 = (args, data) => {
  return cache({
    args,
    firstcrach: false, // it is true by defualt
    create: () =>
      new Promise((res, rej) => {
        // console.log('fetch...')

        setTimeout(rej, 20, `rej: ${data}`);
      }),
    refreshinterval: 200,
  });
};

(async function () {
  try {
    const { data } = await fetchCrash2(["arg"], "dd");
  } catch (e) {
    log.dump({
      catch_error: e, // rej: dd
    });
  }

  try {
    const { data } = await fetchCrash2(["arg"], "ddd");
  } catch (e) {
    log.dump({
      catch_error2: e, // rej: dd - the same value
    });
  }

  // It will just try and try to fetch it every interval given in refreshinterval
  // Object {
  //     <key> [String]: >separatebucket< len: 14
  //     <ckey> [String]: >separatebucket_9b6bc915ce444bab0f263ac01bfb83b14c5a13d0351b22a7e5c748a6d594144f< len: 79
  //     <error> [String]: >o.refreshinterval next call error< len: 33
  //     <e> [String]: >rej: dd< len: 7
  // }

  // server will not crash
})();

// end of case 4

Readme

Keywords

none

Package Sidebar

Install

npm i nlab

Repository

github.com/stopsopa/nlab

Homepage

github.com/stopsopa/nlab

Weekly Downloads

32

Version

0.7.2

License

MIT

Unpacked Size

133 kB

Total Files

108

Last publish

Collaborators

  • stopsopa-owner
Try on RunKit
Report malware