@marblejs/core - npm Package Compare versions

Comparing version 4.0.0-rc.1 to 4.0.0-rc.2

dist/+internal/files/fileReader.helper.d.ts

@@ -1,4 +0,3 @@
-/// <reference types="node" />
 import { Observable } from 'rxjs';
 export declare const readFile: (basePath: string) => (dir: string) => Observable<Buffer>;
 //# sourceMappingURL=fileReader.helper.d.ts.map

dist/+internal/utils/any.util.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="node" />
 import { Observable, UnaryFunction } from 'rxjs';
@@ -3,0 +2,0 @@ import { IO } from 'fp-ts/lib/IO';

dist/+internal/utils/any.util.js

@@ -11,7 +11,7 @@ "use strict";
 exports.isNonNullable = isNonNullable;
-const isNullable = (value) => !exports.isNonNullable(value);
+const isNullable = (value) => !(0, exports.isNonNullable)(value);
 exports.isNullable = isNullable;
 const isTestEnv = () => process.env.NODE_ENV === 'test';
 exports.isTestEnv = isTestEnv;
-const getPortEnv = () => function_1.pipe(O.fromNullable(process.env.PORT), O.map(Number), O.toUndefined);
+const getPortEnv = () => (0, function_1.pipe)(O.fromNullable(process.env.PORT), O.map(Number), O.toUndefined);
 exports.getPortEnv = getPortEnv;
@@ -24,5 +24,5 @@ const wait = (seconds = 1) => new Promise(res => {
 exports.bufferFrom = bufferFrom;
-const stringifyJson = (data) => !string_util_1.isString(data) ? JSON.stringify(data) : data;
+const stringifyJson = (data) => !(0, string_util_1.isString)(data) ? JSON.stringify(data) : data;
 exports.stringifyJson = stringifyJson;
-const parseJson = (data) => function_1.pipe(E.tryCatch(() => JSON.parse(data), () => data), E.fold(function_1.identity, function_1.identity));
+const parseJson = (data) => (0, function_1.pipe)(E.tryCatch(() => JSON.parse(data), () => data), E.fold(function_1.identity, function_1.identity));
 exports.parseJson = parseJson;
@@ -39,5 +39,5 @@ const pipeFromArray = (fns) => {
 exports.pipeFromArray = pipeFromArray;
-const fromIO = (fa) => rxjs_1.defer(() => rxjs_1.of(fa()));
+const fromIO = (fa) => (0, rxjs_1.defer)(() => (0, rxjs_1.of)(fa()));
 exports.fromIO = fromIO;
-const fromTask = (fa) => rxjs_1.defer(fa);
+const fromTask = (fa) => (0, rxjs_1.defer)(fa);
 exports.fromTask = fromTask;

dist/+internal/utils/array.util.js

@@ -7,5 +7,5 @@ "use strict";
 exports.getArrayFromEnum = getArrayFromEnum;
-const getHead = (array) => Option_1.fromNullable(array[0]);
+const getHead = (array) => (0, Option_1.fromNullable)(array[0]);
 exports.getHead = getHead;
-const getLast = (array) => Option_1.fromNullable(array[array.length - 1]);
+const getLast = (array) => (0, Option_1.fromNullable)(array[array.length - 1]);
 exports.getLast = getLast;
@@ -12,0 +12,0 @@ const filterArray = (f) => (array) => array.filter(f);

dist/+internal/utils/env.util.js

@@ -24,3 +24,3 @@ "use strict";
  */
-const getEnvConfig = (envKey) => memoize(() => Option_1.fromNullable(process.env[envKey]));
+const getEnvConfig = (envKey) => memoize(() => (0, Option_1.fromNullable)(process.env[envKey]));
 exports.getEnvConfig = getEnvConfig;
@@ -34,3 +34,3 @@ /**
  */
-const getEnvConfigOrElse = (envKey, onNone) => function_1.pipe(exports.getEnvConfig(envKey), IO.map(Option_1.getOrElse(() => onNone)));
+const getEnvConfigOrElse = (envKey, onNone) => (0, function_1.pipe)((0, exports.getEnvConfig)(envKey), IO.map((0, Option_1.getOrElse)(() => onNone)));
 exports.getEnvConfigOrElse = getEnvConfigOrElse;
@@ -45,3 +45,3 @@ /**
  */
-const getEnvConfigOrElseAsBoolean = (envKey, onNone) => function_1.pipe(exports.getEnvConfigOrElse(envKey, String(onNone)), IO.map(val => val.toLowerCase() === 'true'));
+const getEnvConfigOrElseAsBoolean = (envKey, onNone) => (0, function_1.pipe)((0, exports.getEnvConfigOrElse)(envKey, String(onNone)), IO.map(val => val.toLowerCase() === 'true'));
 exports.getEnvConfigOrElseAsBoolean = getEnvConfigOrElseAsBoolean;

dist/+internal/utils/error.util.js

@@ -15,3 +15,3 @@ "use strict";
 exports.isError = isError;
-const encodeError = (error) => !exports.isError(error) ? error : ['name', ...Object.getOwnPropertyNames(error)]
+const encodeError = (error) => !(0, exports.isError)(error) ? error : ['name', ...Object.getOwnPropertyNames(error)]
     .filter(key => !['stack'].includes(key))
@@ -18,0 +18,0 @@ .reduce((acc, key) => {

dist/+internal/utils/stream.util.d.ts

@@ -1,4 +0,3 @@
-/// <reference types="node" />
 import { Stream } from 'stream';
 export declare const isStream: (stream: any) => stream is Stream;
 //# sourceMappingURL=stream.util.d.ts.map

dist/+internal/utils/string.util.js

@@ -10,3 +10,3 @@ "use strict";
 const trim = (strings, ...values) => {
-    const notNilValues = values.map(function_1.flow(Option_1.fromNullable, Option_1.getOrElse(() => '')));
+    const notNilValues = values.map((0, function_1.flow)(Option_1.fromNullable, (0, Option_1.getOrElse)(() => '')));
     const interpolation = strings.reduce((prev, current) => prev + current + (notNilValues.length ? notNilValues.shift() : ''), '');
@@ -24,3 +24,3 @@ return interpolation.trim();
 exports.stringify = stringify;
-const createUuid = () => uuid_1.v4();
+const createUuid = () => (0, uuid_1.v4)();
 exports.createUuid = createUuid;
@@ -27,0 +27,0 @@ const maskUriComponent = (type) => (uri) => {

dist/context/context.helper.js

@@ -17,4 +17,4 @@ "use strict";
 const unregisterRedundantToken = (token) => (context) => {
-    const deleteToken = pipeable_1.pipe(() => context.delete(token), IO.map(function_1.constant(context)));
-    return pipeable_1.pipe(context_1.lookup(context)(context_1.DerivedContextToken), O.chain(derivedContext => context_1.lookup(derivedContext)(token)), O.fold(() => IO.of(context), () => deleteToken));
+    const deleteToken = (0, pipeable_1.pipe)(() => context.delete(token), IO.map((0, function_1.constant)(context)));
+    return (0, pipeable_1.pipe)((0, context_1.lookup)(context)(context_1.DerivedContextToken), O.chain(derivedContext => (0, context_1.lookup)(derivedContext)(token)), O.fold(() => IO.of(context), () => deleteToken));
 };
@@ -25,6 +25,6 @@ /**
  */
-const constructContext = (context) => (...dependencies) => pipeable_1.pipe(context !== null && context !== void 0 ? context : context_1.createContext(), context_1.registerAll([
-    context_1.bindTo(logger_1.LoggerToken)(utils_1.isTestEnv() ? logger_1.mockLogger : logger_1.logger),
+const constructContext = (context) => (...dependencies) => (0, pipeable_1.pipe)(context !== null && context !== void 0 ? context : (0, context_1.createContext)(), (0, context_1.registerAll)([
+    (0, context_1.bindTo)(logger_1.LoggerToken)((0, utils_1.isTestEnv)() ? logger_1.mockLogger : logger_1.logger),
     ...dependencies,
-]), context => () => context_1.resolve(context), T.chain(context => T.fromIO(unregisterRedundantToken(logger_1.LoggerToken)(context))))();
+]), context => () => (0, context_1.resolve)(context), T.chain(context => T.fromIO(unregisterRedundantToken(logger_1.LoggerToken)(context))))();
 exports.constructContext = constructContext;
@@ -35,2 +35,2 @@ /**
  */
-exports.contextFactory = exports.constructContext();
+exports.contextFactory = (0, exports.constructContext)();

dist/context/context.hook.js

@@ -10,7 +10,7 @@ "use strict";
 const coreErrorOptions = { contextMethod: 'useContext', offset: 2 };
-const useContext = (token) => (ask) => pipeable_1.pipe(ask(token), O.fold(() => {
+const useContext = (token) => (ask) => (0, pipeable_1.pipe)(ask(token), O.fold(() => {
     const message = `Cannot resolve "${token.name || token._id}" context token.`;
     const detail = `You've probably forgot to register the bound token in the app context.`;
     const error = new error_model_1.ContextError(`${message} ${detail}`);
-    const coreError = error_factory_1.coreErrorFactory(error.message, coreErrorOptions);
+    const coreError = (0, error_factory_1.coreErrorFactory)(error.message, coreErrorOptions);
     console.error(coreError.stack);
@@ -17,0 +17,0 @@ throw error;

dist/context/context.js

@@ -20,3 +20,3 @@ "use strict";
 const context_token_factory_1 = require("./context.token.factory");
-exports.ordContextToken = Ord_1.contramap((t) => t._id)(Ord_1.ordString);
+exports.ordContextToken = (0, Ord_1.contramap)((t) => t._id)(Ord_1.ordString);
 exports.setoidContextToken = { equals: exports.ordContextToken.equals };
@@ -28,3 +28,3 @@ var ContextReaderTag;
 })(ContextReaderTag = exports.ContextReaderTag || (exports.ContextReaderTag = {}));
-exports.DerivedContextToken = context_token_factory_1.createContextToken('DerivedContext');
+exports.DerivedContextToken = (0, context_token_factory_1.createContextToken)('DerivedContext');
 const isEagerDependency = (x) => Boolean(x.eval && x.tag === ContextReaderTag.EAGER_READER);
@@ -36,3 +36,3 @@ const isLazyDependency = (x) => Boolean(x.eval && x.tag === ContextReaderTag.LAZY_READER);
 exports.register = register;
-const registerAll = (boundDependencies) => (context) => boundDependencies.reduce((ctx, dependency) => exports.register(dependency)(ctx), context);
+const registerAll = (boundDependencies) => (context) => boundDependencies.reduce((ctx, dependency) => (0, exports.register)(dependency)(ctx), context);
 exports.registerAll = registerAll;
@@ -50,3 +50,3 @@ /**
 const resolve = (context) => __awaiter(void 0, void 0, void 0, function* () {
-    const resolveEagerDependency = ({ token, dependency }) => pipeable_1.pipe(() => pipeable_1.pipe(context, dependency.eval, d => Promise.resolve(d)), T.chain(resolvedDependency => T.fromIO(() => context.set(token, resolvedDependency))));
+    const resolveEagerDependency = ({ token, dependency }) => (0, pipeable_1.pipe)(() => (0, pipeable_1.pipe)(context, dependency.eval, d => Promise.resolve(d)), T.chain(resolvedDependency => T.fromIO(() => context.set(token, resolvedDependency))));
     for (const [token, dependency] of context) {
@@ -64,3 +64,3 @@ if (!isEagerDependency(dependency))
  */
-const lookup = (context) => (token) => pipeable_1.pipe(M.lookup(exports.ordContextToken)(token, context), O.map(dependency => {
+const lookup = (context) => (token) => (0, pipeable_1.pipe)(M.lookup(exports.ordContextToken)(token, context), O.map(dependency => {
     if (!dependency.eval)
@@ -73,3 +73,3 @@ return dependency;
     return boostrapedDependency;
-}), O.fold(() => pipeable_1.pipe(M.lookup(exports.ordContextToken)(exports.DerivedContextToken, context), O.chain((derivedContext) => exports.lookup(derivedContext)(token))), O.some));
+}), O.fold(() => (0, pipeable_1.pipe)(M.lookup(exports.ordContextToken)(exports.DerivedContextToken, context), O.chain((derivedContext) => (0, exports.lookup)(derivedContext)(token))), O.some));
 exports.lookup = lookup;
@@ -94,2 +94,2 @@ /**
 exports.bindTo = exports.bindLazilyTo;
-exports.reader = pipeable_1.pipe(R.ask(), R.map(exports.lookup));
+exports.reader = (0, pipeable_1.pipe)(R.ask(), R.map(exports.lookup));

dist/context/context.logger.js

@@ -12,3 +12,3 @@ "use strict";
 const logContext = (tag) => (context) => {
-    const logger = pipeable_1.pipe(context_1.lookup(context), context_hook_1.useContext(logger_1.LoggerToken));
+    const logger = (0, pipeable_1.pipe)((0, context_1.lookup)(context), (0, context_hook_1.useContext)(logger_1.LoggerToken));
     const log = (token) => logger({
@@ -21,3 +21,3 @@ tag,
     });
-    const logDependencies = A.array.sequence(IO_1.io)(pipeable_1.pipe(context, M.keys(context_1.ordContextToken), A.map(log)));
+    const logDependencies = A.array.sequence(IO_1.io)((0, pipeable_1.pipe)(context, M.keys(context_1.ordContextToken), A.map(log)));
     logDependencies();
@@ -24,0 +24,0 @@ return context;

dist/context/context.reader.factory.js

@@ -7,3 +7,3 @@ "use strict";
 const context_1 = require("./context");
-const createReader = (handler) => pipeable_1.pipe(context_1.reader, R.map(handler));
+const createReader = (handler) => (0, pipeable_1.pipe)(context_1.reader, R.map(handler));
 exports.createReader = createReader;

dist/context/context.token.factory.js

@@ -8,3 +8,3 @@ "use strict";
         this.name = name;
-        this._id = utils_1.createUuid();
+        this._id = (0, utils_1.createUuid)();
     }
@@ -11,0 +11,0 @@ }

dist/effects/effects.combiner.js

@@ -8,3 +8,3 @@ "use strict";
 exports.combineMiddlewares = combineMiddlewares;
-const combineEffects = (...effects) => (input$, ctx) => rxjs_1.merge(...effects.map(effect => effect(input$, ctx))).pipe(operators_1.share());
+const combineEffects = (...effects) => (input$, ctx) => (0, rxjs_1.merge)(...effects.map(effect => effect(input$, ctx))).pipe((0, operators_1.share)());
 exports.combineEffects = combineEffects;

dist/error/error.factory.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="node" />
 import { CoreError } from './error.model';
@@ -3,0 +2,0 @@ export declare type CoreErrorOptions = {

dist/error/error.factory.js

@@ -31,3 +31,3 @@ "use strict";
 
-  ${exports.stringifyStackTrace(restStack)}\n` : ''}
+  ${(0, exports.stringifyStackTrace)(restStack)}\n` : ''}
   `;
@@ -37,5 +37,5 @@ };
 const coreErrorFactory = (message, opts) => new error_model_1.CoreError(message || 'Something is not right...', {
-    stackTraceFactory: exports.coreErrorStackTraceFactory(opts),
+    stackTraceFactory: (0, exports.coreErrorStackTraceFactory)(opts),
     context: exports.coreErrorFactory,
 });
 exports.coreErrorFactory = coreErrorFactory;

dist/listener/listener.factory.js

@@ -6,3 +6,3 @@ "use strict";
 const context_reader_factory_1 = require("../context/context.reader.factory");
-const createListener = (fn) => function_1.flow(fn, context_reader_factory_1.createReader);
+const createListener = (fn) => (0, function_1.flow)(fn, context_reader_factory_1.createReader);
 exports.createListener = createListener;

dist/logger/logger.js

@@ -15,3 +15,3 @@ "use strict";
 };
-const colorizeText = (level) => pipeable_1.pipe(O.fromNullable({
+const colorizeText = (level) => (0, pipeable_1.pipe)(O.fromNullable({
     [logger_interface_1.LoggerLevel.ERROR]: chalk.red,
@@ -27,6 +27,6 @@ [logger_interface_1.LoggerLevel.INFO]: chalk.green,
     .replace(/\..+/, '');
-exports.logger = context_reader_factory_1.createReader(() => opts => {
+exports.logger = (0, context_reader_factory_1.createReader)(() => opts => {
     var _a, _b;
     const sep = ' - ';
-    const truncItem = utils_1.trunc(15);
+    const truncItem = (0, utils_1.trunc)(15);
     const colorize = colorizeText((_a = opts.level) !== null && _a !== void 0 ? _a : logger_interface_1.LoggerLevel.INFO);
@@ -40,2 +40,2 @@ const sign = chalk.magenta('λ');
 });
-exports.mockLogger = context_reader_factory_1.createReader(() => _ => IO_1.io.of(function_1.constUndefined));
+exports.mockLogger = (0, context_reader_factory_1.createReader)(() => _ => IO_1.io.of(function_1.constUndefined));

dist/logger/logger.token.js

@@ -5,2 +5,2 @@ "use strict";
 const context_token_factory_1 = require("../context/context.token.factory");
-exports.LoggerToken = context_token_factory_1.createContextToken('LoggerToken');
+exports.LoggerToken = (0, context_token_factory_1.createContextToken)('LoggerToken');

dist/operators/act/act.operator.js

@@ -13,16 +13,16 @@ "use strict";
         var _a;
-        return rxjs_1.of({
+        return (0, rxjs_1.of)({
             type: !event.type.includes(DEFAULT_ERROR_SUFFIX)
                 ? event.type + DEFAULT_ERROR_SUFFIX
                 : event.type,
-            error: (_a = utils_1.encodeError(error)) !== null && _a !== void 0 ? _a : true,
+            error: (_a = (0, utils_1.encodeError)(error)) !== null && _a !== void 0 ? _a : true,
             metadata: event.metadata,
         });
     };
-    const handleError = (event) => (error) => pipeable_1.pipe(O.fromNullable(errorFn), O.map(fn => fn(error, event)), O.map(res => !rxjs_1.isObservable(res) ? rxjs_1.of(res) : res), O.map(res => res.pipe(operators_1.map(r => { var _a; return (Object.assign(Object.assign({}, r), { error: (_a = r.error) !== null && _a !== void 0 ? _a : true })); }))), O.getOrElse(() => getDefaultErrorEvent(error)(event)));
-    return (source) => source.pipe(operators_1.mergeMap(event => rxjs_1.defer(() => {
+    const handleError = (event) => (error) => (0, pipeable_1.pipe)(O.fromNullable(errorFn), O.map(fn => fn(error, event)), O.map(res => !(0, rxjs_1.isObservable)(res) ? (0, rxjs_1.of)(res) : res), O.map(res => res.pipe((0, operators_1.map)(r => { var _a; return (Object.assign(Object.assign({}, r), { error: (_a = r.error) !== null && _a !== void 0 ? _a : true })); }))), O.getOrElse(() => getDefaultErrorEvent(error)(event)));
+    return (source) => source.pipe((0, operators_1.mergeMap)(event => (0, rxjs_1.defer)(() => {
         try {
             return event.error
                 ? handleError(event)(event.error)
-                : pipeable_1.pipe(callFn(event), operators_1.catchError(handleError(event)));
+                : (0, pipeable_1.pipe)(callFn(event), (0, operators_1.catchError)(handleError(event)));
         }
@@ -29,0 +29,0 @@ catch (error) {

dist/operators/matchEvent/matchEvent.operator.js

@@ -9,9 +9,9 @@ "use strict";
 function matchEvent(...events) {
-    const match = (incomingEvent) => (matchingEvent) => event_1.isEventCodec(matchingEvent)
+    const match = (incomingEvent) => (matchingEvent) => (0, event_1.isEventCodec)(matchingEvent)
         ? matchingEvent.props.type.value === incomingEvent.type
-        : utils_1.isString(matchingEvent)
+        : (0, utils_1.isString)(matchingEvent)
             ? matchingEvent === incomingEvent.type
             : matchingEvent.type === incomingEvent.type;
-    return (source$) => source$.pipe(operators_1.filter(incomingEvent => events.some(match(incomingEvent))));
+    return (source$) => source$.pipe((0, operators_1.filter)(incomingEvent => events.some(match(incomingEvent))));
 }
 exports.matchEvent = matchEvent;

dist/operators/use/use.operator.js

@@ -11,3 +11,3 @@ "use strict";
  */
-const use = (middleware, effectContext) => (source$) => source$.pipe(operators_1.mergeMap(req => middleware(rxjs_1.of(req), effectContext)));
+const use = (middleware, effectContext) => (source$) => source$.pipe((0, operators_1.mergeMap)(req => middleware((0, rxjs_1.of)(req), effectContext)));
 exports.use = use;

package.json

 {
   "name": "@marblejs/core",
-  "version": "4.0.0-rc.1",
+  "version": "4.0.0-rc.2",
   "description": "Reactive Node APIs made easy",
@@ -46,3 +46,3 @@ "main": "./dist/index.js",
   },
-  "gitHead": "b94d738f1ee4cc9c3cf434575f6b5c219613c6cd"
+  "gitHead": "086fe663a428304060a4d32872814bc329bee649"
 }

No alert changes

Improved metrics

Total package byte prevSize

101039

increased by0.24%

Worsened metrics

Lines of code

1429

decreased by-0.28%

No dependency changes