Socket
Socket
Sign inDemoInstall

roarr

Package Overview
Dependencies
Maintainers
1
Versions
150
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

roarr - npm Package Compare versions

Comparing version 3.0.0 to 3.1.0

dist/constants.d.ts

21

dist/constants.js
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
Object.defineProperty(exports, "__esModule", { value: true });
exports.logLevels = void 0;
const logLevels = {
debug: 20,
error: 50,
fatal: 60,
info: 30,
trace: 10,
warn: 40
exports.logLevels = {
debug: 20,
error: 50,
fatal: 60,
info: 30,
trace: 10,
warn: 40,
};
exports.logLevels = logLevels;
//# sourceMappingURL=constants.js.map
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
exports.default = void 0;
var _detectNode = _interopRequireDefault(require("detect-node"));
var _globalthis = _interopRequireDefault(require("globalthis"));
var _isCircular = _interopRequireDefault(require("is-circular"));
var _jsonStringifySafe = _interopRequireDefault(require("json-stringify-safe"));
var _sprintfit = require("sprintfit");
var _constants = require("../constants");
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
const globalThis = (0, _globalthis.default)();
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
const detect_node_1 = __importDefault(require("detect-node"));
const globalthis_1 = __importDefault(require("globalthis"));
const is_circular_1 = __importDefault(require("is-circular"));
const json_stringify_safe_1 = __importDefault(require("json-stringify-safe"));
const sprintfit_1 = require("sprintfit");
const constants_1 = require("../constants");
const globalThis = globalthis_1.default();
let domain;
if (_detectNode.default) {
// eslint-disable-next-line node/global-require
domain = require('domain');
if (detect_node_1.default) {
// eslint-disable-next-line node/global-require
domain = require('domain');
}
const getParentDomainContext = () => {
if (!domain) {
return {};
}
const parentRoarrContexts = [];
let currentDomain = process.domain; // $FlowFixMe
if (!currentDomain || !currentDomain.parentDomain) {
return {};
}
while (currentDomain && currentDomain.parentDomain) {
currentDomain = currentDomain.parentDomain;
if (currentDomain.roarr && currentDomain.roarr.context) {
parentRoarrContexts.push(currentDomain.roarr.context);
if (!domain) {
return {};
}
}
let domainContext = {};
for (const parentRoarrContext of parentRoarrContexts) {
domainContext = { ...domainContext,
...parentRoarrContext
};
}
return domainContext;
const parentRoarrContexts = [];
let currentDomain = process.domain;
if (!currentDomain?.parentDomain) {
return {};
}
while (currentDomain?.parentDomain) {
currentDomain = currentDomain?.parentDomain;
if (currentDomain.roarr && currentDomain.roarr.context) {
parentRoarrContexts.push(currentDomain.roarr.context);
}
}
let domainContext = {};
for (const parentRoarrContext of parentRoarrContexts) {
domainContext = {
...domainContext,
...parentRoarrContext,
};
}
return domainContext;
};
const getFirstParentDomainContext = () => {
if (!domain) {
if (!domain) {
return {};
}
let currentDomain = process.domain;
if (currentDomain && currentDomain.roarr && currentDomain.roarr.context) {
return currentDomain.roarr.context;
}
if (!currentDomain || !currentDomain.parentDomain) {
return {};
}
while (currentDomain && currentDomain.parentDomain) {
currentDomain = currentDomain.parentDomain;
if (currentDomain.roarr && currentDomain.roarr.context) {
return currentDomain.roarr.context;
}
}
return {};
}
let currentDomain = process.domain; // $FlowFixMe
if (currentDomain && currentDomain.roarr && currentDomain.roarr.context) {
return currentDomain.roarr.context;
} // $FlowFixMe
if (!currentDomain || !currentDomain.parentDomain) {
return {};
}
while (currentDomain && currentDomain.parentDomain) {
currentDomain = currentDomain.parentDomain;
if (currentDomain.roarr && currentDomain.roarr.context) {
return currentDomain.roarr.context;
}
}
return {};
};
const defaultContext = {};
const createLogger = (onMessage, parentContext) => {
// eslint-disable-next-line id-length, unicorn/prevent-abbreviations
const log = (a, b, c, d, e, f, g, h, i, k) => {
const time = Date.now();
const sequence = globalThis.ROARR.sequence++;
let context;
let message;
if (typeof a === 'string') {
if (!domain || process.domain === null) {
context = parentContext || defaultContext;
} else {
context = { ...getFirstParentDomainContext(),
...parentContext
};
}
} else {
context = { ...getFirstParentDomainContext(),
...parentContext,
...a
};
}
if (context !== defaultContext && (0, _isCircular.default)(context)) {
context = JSON.parse((0, _jsonStringifySafe.default)(context));
}
if (typeof a === 'string' && b === undefined) {
message = a;
} else if (typeof a === 'string') {
message = (0, _sprintfit.sprintf)(a, b, c, d, e, f, g, h, i, k);
} else {
if (typeof b !== 'string') {
throw new TypeError('Message must be a string.');
}
message = (0, _sprintfit.sprintf)(b, c, d, e, f, g, h, i, k);
}
onMessage({
context,
message,
sequence,
time,
version: '1.0.0'
});
};
log.child = context => {
if (typeof context === 'function') {
return createLogger(message => {
if (typeof context !== 'function') {
throw new TypeError('Unexpected state.');
const log = (a, b, c, d, e, f, g, h, i, j) => {
const time = Date.now();
const sequence = globalThis.ROARR.sequence++;
let context;
let message;
if (typeof a === 'string') {
if (!domain || process.domain === null) {
context = parentContext || defaultContext;
}
else {
context = {
...getFirstParentDomainContext(),
...parentContext,
};
}
}
onMessage(context(message));
}, parentContext);
}
return createLogger(onMessage, { ...getFirstParentDomainContext(),
...parentContext,
...context
});
};
log.getContext = () => {
return { ...getFirstParentDomainContext(),
...(parentContext || defaultContext)
else {
context = {
...getFirstParentDomainContext(),
...parentContext,
...a,
};
}
if (context !== defaultContext && is_circular_1.default(context)) {
context = JSON.parse(json_stringify_safe_1.default(context));
}
if (typeof a === 'string' && b === undefined) {
message = a;
}
else if (typeof a === 'string') {
message = sprintfit_1.sprintf(a, b, c, d, e, f, g, h, i, j);
}
else {
if (typeof b !== 'string') {
throw new TypeError('Message must be a string.');
}
message = sprintfit_1.sprintf(b, c, d, e, f, g, h, i, j);
}
onMessage({
context,
message,
sequence,
time,
version: '1.0.0',
});
};
};
log.adopt = async (routine, context) => {
if (!domain) {
return routine();
}
const adoptedDomain = domain.create();
return adoptedDomain.run(() => {
// $FlowFixMe
adoptedDomain.roarr = {
context: { ...getParentDomainContext(),
...context
log.child = (context) => {
if (typeof context === 'function') {
return createLogger((message) => {
if (typeof context !== 'function') {
throw new TypeError('Unexpected state.');
}
onMessage(context(message));
}, parentContext);
}
};
return routine();
});
};
for (const logLevel of Object.keys(_constants.logLevels)) {
// eslint-disable-next-line id-length, unicorn/prevent-abbreviations
log[logLevel] = (a, b, c, d, e, f, g, h, i, k) => {
return log.child({
logLevel: _constants.logLevels[logLevel]
})(a, b, c, d, e, f, g, h, i, k);
return createLogger(onMessage, {
...getFirstParentDomainContext(),
...parentContext,
...context,
});
};
} // @see https://github.com/facebook/flow/issues/6705
// $FlowFixMe
return log;
log.getContext = () => {
return {
...getFirstParentDomainContext(),
...parentContext || defaultContext,
};
};
log.adopt = async (routine, context) => {
if (!domain) {
return routine();
}
const adoptedDomain = domain.create();
return adoptedDomain
.run(() => {
adoptedDomain.roarr = {
context: {
...getParentDomainContext(),
...context,
},
};
return routine();
});
};
log.trace = (a, b, c, d, e, f, g, h, i, j) => {
return log.child({
logLevel: constants_1.logLevels.trace,
})(a, b, c, d, e, f, g, h, i, j);
};
log.debug = (a, b, c, d, e, f, g, h, i, j) => {
return log.child({
logLevel: constants_1.logLevels.debug,
})(a, b, c, d, e, f, g, h, i, j);
};
log.info = (a, b, c, d, e, f, g, h, i, j) => {
return log.child({
logLevel: constants_1.logLevels.info,
})(a, b, c, d, e, f, g, h, i, j);
};
log.warn = (a, b, c, d, e, f, g, h, i, j) => {
return log.child({
logLevel: constants_1.logLevels.warn,
})(a, b, c, d, e, f, g, h, i, j);
};
log.error = (a, b, c, d, e, f, g, h, i, j) => {
return log.child({
logLevel: constants_1.logLevels.error,
})(a, b, c, d, e, f, g, h, i, j);
};
log.fatal = (a, b, c, d, e, f, g, h, i, j) => {
return log.child({
logLevel: constants_1.logLevels.fatal,
})(a, b, c, d, e, f, g, h, i, j);
};
return log;
};
var _default = createLogger;
exports.default = _default;
//# sourceMappingURL=createLogger.js.map
exports.default = createLogger;
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
exports.default = void 0;
var _constants = require("../constants");
Object.defineProperty(exports, "__esModule", { value: true });
const constants_1 = require("../constants");
const createMockLogger = (onMessage, parentContext) => {
// eslint-disable-next-line id-length, unicorn/prevent-abbreviations, no-unused-vars
const log = (a, b, c, d, e, f, g, h, i, k) => {//
};
log.adopt = async routine => {
return routine();
}; // eslint-disable-next-line no-unused-vars
log.child = context => {
return createMockLogger(onMessage, parentContext);
};
log.getContext = () => {
return {};
};
for (const logLevel of Object.keys(_constants.logLevels)) {
// eslint-disable-next-line id-length, unicorn/prevent-abbreviations
log[logLevel] = (a, b, c, d, e, f, g, h, i, k) => {
return log.child({
logLevel: _constants.logLevels[logLevel]
})(a, b, c, d, e, f, g, h, i, k);
const log = () => {
return undefined;
};
} // @see https://github.com/facebook/flow/issues/6705
// $FlowFixMe
return log;
log.adopt = async (routine) => {
return routine();
};
log.child = (context) => {
return createMockLogger(onMessage, parentContext);
};
log.getContext = () => {
return {};
};
log.trace = (a, b, c, d, e, f, g, h, i, j) => {
return log.child({
logLevel: constants_1.logLevels.trace,
})(a, b, c, d, e, f, g, h, i, j);
};
log.debug = (a, b, c, d, e, f, g, h, i, j) => {
return log.child({
logLevel: constants_1.logLevels.debug,
})(a, b, c, d, e, f, g, h, i, j);
};
log.info = (a, b, c, d, e, f, g, h, i, j) => {
return log.child({
logLevel: constants_1.logLevels.info,
})(a, b, c, d, e, f, g, h, i, j);
};
log.warn = (a, b, c, d, e, f, g, h, i, j) => {
return log.child({
logLevel: constants_1.logLevels.warn,
})(a, b, c, d, e, f, g, h, i, j);
};
log.error = (a, b, c, d, e, f, g, h, i, j) => {
return log.child({
logLevel: constants_1.logLevels.error,
})(a, b, c, d, e, f, g, h, i, j);
};
log.fatal = (a, b, c, d, e, f, g, h, i, j) => {
return log.child({
logLevel: constants_1.logLevels.fatal,
})(a, b, c, d, e, f, g, h, i, j);
};
return log;
};
var _default = createMockLogger;
exports.default = _default;
//# sourceMappingURL=createMockLogger.js.map
exports.default = createMockLogger;
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
exports.default = void 0;
const createBlockingWriter = stream => {
return {
write: message => {
stream.write(message + '\n');
}
};
Object.defineProperty(exports, "__esModule", { value: true });
const createBlockingWriter = (stream) => {
return {
write: (message) => {
stream.write(message + '\n');
},
};
};
const createNodeWriter = () => {
// eslint-disable-next-line node/no-process-env
const targetStream = (process.env.ROARR_STREAM || 'STDOUT').toUpperCase();
const stream = targetStream.toUpperCase() === 'STDOUT' ? process.stdout : process.stderr;
return createBlockingWriter(stream);
exports.default = () => {
// eslint-disable-next-line node/no-process-env
const targetStream = (process.env.ROARR_STREAM || 'STDOUT').toUpperCase();
const stream = targetStream.toUpperCase() === 'STDOUT' ? process.stdout : process.stderr;
return createBlockingWriter(stream);
};
var _default = createNodeWriter;
exports.default = _default;
//# sourceMappingURL=createNodeWriter.js.map
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
Object.defineProperty(exports, "createLogger", {
enumerable: true,
get: function () {
return _createLogger.default;
}
});
Object.defineProperty(exports, "createMockLogger", {
enumerable: true,
get: function () {
return _createMockLogger.default;
}
});
Object.defineProperty(exports, "createRoarrInititialGlobalState", {
enumerable: true,
get: function () {
return _createRoarrInititialGlobalState.default;
}
});
var _createLogger = _interopRequireDefault(require("./createLogger"));
var _createMockLogger = _interopRequireDefault(require("./createMockLogger"));
var _createRoarrInititialGlobalState = _interopRequireDefault(require("./createRoarrInititialGlobalState"));
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
//# sourceMappingURL=index.js.map
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.createRoarrInitialGlobalState = exports.createMockLogger = exports.createLogger = void 0;
var createLogger_1 = require("./createLogger");
Object.defineProperty(exports, "createLogger", { enumerable: true, get: function () { return __importDefault(createLogger_1).default; } });
var createMockLogger_1 = require("./createMockLogger");
Object.defineProperty(exports, "createMockLogger", { enumerable: true, get: function () { return __importDefault(createMockLogger_1).default; } });
var createRoarrInitialGlobalState_1 = require("./createRoarrInitialGlobalState");
Object.defineProperty(exports, "createRoarrInitialGlobalState", { enumerable: true, get: function () { return __importDefault(createRoarrInitialGlobalState_1).default; } });
"use strict";
Object.defineProperty(exports, "__esModule", {
value: true
});
exports.default = exports.ROARR = void 0;
var _boolean = require("boolean");
var _detectNode = _interopRequireDefault(require("detect-node"));
var _fastJsonStringify = _interopRequireDefault(require("fast-json-stringify"));
var _globalthis = _interopRequireDefault(require("globalthis"));
var _factories = require("./factories");
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
const stringify = (0, _fastJsonStringify.default)({
properties: {
context: {
additionalProperties: true,
type: 'object'
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.ROARR = void 0;
const boolean_1 = require("boolean");
const detect_node_1 = __importDefault(require("detect-node"));
const fast_json_stringify_1 = __importDefault(require("fast-json-stringify"));
const globalthis_1 = __importDefault(require("globalthis"));
const factories_1 = require("./factories");
const stringify = fast_json_stringify_1.default({
properties: {
context: {
additionalProperties: true,
type: 'object',
},
message: {
type: 'string',
},
sequence: {
type: 'integer',
},
time: {
type: 'integer',
},
version: {
type: 'string',
},
},
message: {
type: 'string'
},
sequence: {
type: 'integer'
},
time: {
type: 'integer'
},
version: {
type: 'string'
}
},
type: 'object'
type: 'object',
});
const globalThis = (0, _globalthis.default)();
const ROARR = globalThis.ROARR = (0, _factories.createRoarrInititialGlobalState)(globalThis.ROARR || {});
const globalThis = globalthis_1.default();
const ROARR = globalThis.ROARR = factories_1.createRoarrInitialGlobalState(globalThis.ROARR || {});
exports.ROARR = ROARR;
let logFactory = _factories.createLogger;
if (_detectNode.default) {
// eslint-disable-next-line node/no-process-env
const enabled = (0, _boolean.boolean)(process.env.ROARR_LOG || '');
if (!enabled) {
logFactory = _factories.createMockLogger;
}
let logFactory = factories_1.createLogger;
if (detect_node_1.default) {
// eslint-disable-next-line node/no-process-env
const enabled = boolean_1.boolean(process.env.ROARR_LOG || '');
if (!enabled) {
logFactory = factories_1.createMockLogger;
}
}
var _default = logFactory(message => {
if (ROARR.write) {
// Stringify message as soon as it is received to prevent
// properties of the context from being modified by reference.
const body = stringify(message);
ROARR.write(body);
}
exports.default = logFactory((message) => {
if (ROARR.write) {
// Stringify message as soon as it is received to prevent
// properties of the context from being modified by reference.
const body = stringify(message);
ROARR.write(body);
}
});
exports.default = _default;
//# sourceMappingURL=log.js.map
"use strict";
//# sourceMappingURL=types.js.map
/* eslint-disable import/exports-last */
Object.defineProperty(exports, "__esModule", { value: true });

@@ -8,7 +8,5 @@ {

"ava": {
"babel": {
"compileAsTests": [
"test/helpers/**/*"
]
},
"extensions": [
"ts"
],
"files": [

@@ -18,3 +16,3 @@ "test/roarr/**/*"

"require": [
"@babel/register"
"ts-node/register/transpile-only"
]

@@ -34,23 +32,21 @@ },

"devDependencies": {
"@ava/babel": "^1.0.1",
"@babel/cli": "^7.12.10",
"@babel/core": "^7.12.10",
"@babel/node": "^7.12.10",
"@babel/plugin-transform-flow-strip-types": "^7.12.10",
"@babel/preset-env": "^7.12.11",
"@babel/register": "^7.12.10",
"@istanbuljs/nyc-config-typescript": "^1.0.1",
"@types/detect-node": "^2.0.0",
"@types/globalthis": "^1.0.1",
"@types/json-stringify-safe": "^5.0.0",
"@types/node": "^14.14.16",
"@types/semver-compare": "^1.0.1",
"ava": "^3.14.0",
"babel-plugin-istanbul": "^6.0.0",
"babel-plugin-transform-export-default-name": "^2.1.0",
"benchmark": "^2.1.4",
"coveralls": "^3.1.0",
"del-cli": "^3.0.1",
"domain-parent": "^1.0.0",
"eslint": "^7.16.0",
"eslint-config-canonical": "^24.4.4",
"flow-bin": "^0.141.0",
"flow-copy-source": "^2.0.9",
"gitdown": "^3.1.3",
"husky": "^4.3.6",
"nyc": "^15.1.0",
"semantic-release": "^17.3.0"
"semantic-release": "^17.3.0",
"ts-node": "^9.1.1",
"typescript": "^4.1.3"
},

@@ -74,15 +70,2 @@ "engines": {

"name": "roarr",
"nyc": {
"include": [
"src/**/*.js"
],
"instrument": false,
"reporter": [
"text-lcov"
],
"require": [
"@babel/register"
],
"sourceMap": false
},
"repository": {

@@ -94,9 +77,10 @@ "type": "git",

"benchmark": "ROARR_LOG=true babel-node test/benchmark.js",
"build": "rm -fr ./dist && NODE_ENV=production babel ./src --out-dir ./dist --copy-files --source-maps && flow-copy-source src dist",
"build": "del-cli ./dist && tsc",
"create-readme": "gitdown ./.README/README.md --output-file ./README.md",
"dev": "NODE_ENV=production babel ./src --out-dir ./dist --copy-files --source-maps --watch",
"lint": "eslint ./src ./test && flow",
"lint": "eslint ./src ./test && tsc --noEmit",
"test": "NODE_ENV=test ava --serial --verbose"
},
"version": "3.0.0"
"typings": "./dist/log.d.ts",
"version": "3.1.0"
}

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc