memphis.js/lib/utils.js at master · superstreamlabs/memphis.js · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.sleep = exports.generateNameSuffix = exports.stringToHex = exports.MemphisErrorString = exports.MemphisError = void 0;
const MemphisError = (error) => {
    if (error === null || error === void 0 ? void 0 : error.message) {
        error.message = error.message.replace('NatsError', 'memphis');
        error.message = error.message.replace('Nats', 'memphis');
        error.message = error.message.replace('nats', 'memphis');
    }
    if (error === null || error === void 0 ? void 0 : error.stack) {
        error.stack = error.stack.replace('NatsError', 'memphis');
        error.stack = error.stack.replace('Nats:', 'memphis');
        error.stack = error.stack.replace('nats:', 'memphis');
    }
    if (error === null || error === void 0 ? void 0 : error.name) {
        error.name = error.name.replace('NatsError', 'MemphisError');
        error.name = error.name.replace('Nats', 'MemphisError');
        error.name = error.name.replace('nats', 'MemphisError');
    }
    return error;
};
exports.MemphisError = MemphisError;
const MemphisErrorString = (err) => {
    if (err) {
        err = err.replace('NatsError', 'memphis');
        err = err.replace('Nats', 'memphis');
        err = err.replace('nats', 'memphis');
        err = err.replace('NATS', 'Memphis');
    }
    return err;
};
exports.MemphisErrorString = MemphisErrorString;
const stringToHex = (str) => {
    var hex = '';
    for (var i = 0; i < str.length; i++) {
        hex += '' + str.charCodeAt(i).toString(16);
    }
    return hex;
};
exports.stringToHex = stringToHex;
const generateNameSuffix = (additonalStr = "") => {
    return `${additonalStr}${[...Array(8)].map(() => Math.floor(Math.random() * 16).toString(16)).join('')}`;
};
exports.generateNameSuffix = generateNameSuffix;
const sleep = ms => new Promise(r => setTimeout(r, ms));
exports.sleep = sleep;