Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'feature/Autofill_And_Mappers_Registry' into develop
- Loading branch information
Showing
6 changed files
with
3,777 additions
and
40 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,34 +1,116 @@ | ||
| import * as _ from 'lodash'; | ||
| export default function Morphism(schema, items) { | ||
|
|
||
| export default function Morphism(schema, items, type) { | ||
| let _schema = _.clone(schema); | ||
| let transformer = (items) => { | ||
| return _.chain(items) | ||
| .map((obj) => { | ||
| return _.mapValues(_schema, (predicate) => { | ||
| let transformedObject = _.mapValues(_schema, (predicate) => { | ||
| if (!_.isObject(predicate)) { // a predicate string path | ||
| return _.get(obj, predicate); | ||
| } | ||
| else if (_.isFunction(predicate)) { // a predicate function without a path | ||
| return predicate(obj); | ||
| } | ||
| else if(_.isArray(predicate)){ // a predicate array of string path => agregator | ||
| return _.reduce(predicate, (delta, path) =>{ | ||
| else if (_.isArray(predicate)) { // a predicate array of string path => agregator | ||
| return _.reduce(predicate, (delta, path) => { | ||
| return _.set(delta, path, _.get(obj, path)); | ||
| },{}); | ||
| }, {}); | ||
| } | ||
| else { // a predicate object with a path and a function | ||
| let delta = _.get(obj, predicate.path); | ||
| return predicate.fn(delta); | ||
| } | ||
| }); | ||
| }).value(); | ||
| return transformedObject; | ||
| }); | ||
| }; | ||
|
|
||
| if (items === undefined) { | ||
| if (items === undefined && type === undefined) { | ||
| return (items) => { | ||
| return transformer(items).value(); | ||
| }; | ||
| } else if (type) { | ||
| return (items) => { | ||
| return transformer(items); | ||
| return transformer(items).map((o) => { return _.assignIn(new type(), o); }).value(); // TODO: Refactor this in a chain of responsibility pattern | ||
| }; | ||
| } else { | ||
| return transformer(items); | ||
| } | ||
| else { | ||
| return transformer(items).value(); | ||
| } | ||
| } | ||
|
|
||
|
|
||
| function factory(type, schema, items) { | ||
| let typeFields = _.keys(new type()); | ||
| let defaultSchema = _.zipObject(typeFields, typeFields); | ||
| let finalSchema = _.assign(defaultSchema, schema); | ||
|
|
||
| return Morphism(finalSchema, items, type); | ||
| } | ||
|
|
||
|
|
||
| _.memoize.Cache = WeakMap; | ||
| const _registry = _.memoize(factory); | ||
|
|
||
| class _Morphism { | ||
| /** | ||
| * Register a mapper for a specific type against morphism | ||
| * | ||
| * @param {any} type | ||
| * @param {any} schema | ||
| */ | ||
| static register(type, schema) { | ||
| if (!type && !schema) { | ||
| throw new Error('type paramater is required when register a mapping'); | ||
| } else if (_Morphism.exists(type)) { | ||
| throw new Error(`A mapper for ${type.name} has already been registered`); | ||
| } | ||
| return _registry(type, schema); // Store the result of the executed function in a WeakMap cache object | ||
| } | ||
|
|
||
| static map(type, data) { | ||
| return _registry(type)(data); | ||
| } | ||
|
|
||
| static getMapper(type) { | ||
| return _registry.cache.get(type); | ||
| } | ||
|
|
||
| static get mappers() { | ||
| return _registry.cache; | ||
| } | ||
|
|
||
| static exists(type) { | ||
| return _registry.cache.has(type); | ||
| } | ||
|
|
||
| static setMapper(type, schema) { | ||
| if (!schema) { | ||
| throw new Error(`The schema must be an Object. Found ${schema}`); | ||
| } else if (!_Morphism.exists(type)) { | ||
| throw new Error(`The type ${type.name} is not registered. Register it using \`Mophism.register(${type.name}, schema)\``); | ||
| } else { | ||
| let fn = factory(type, schema); | ||
| _registry.cache.set(type, fn); | ||
| return _registry(type); | ||
| } | ||
|
|
||
| } | ||
|
|
||
| static deleteMapper(type) { | ||
| return _registry.cache.delete(type); | ||
| } | ||
| } | ||
|
|
||
| let api = { | ||
| register: _Morphism.register, | ||
| map: _Morphism.map, | ||
| getMapper: _Morphism.getMapper, | ||
| setMapper: _Morphism.setMapper, | ||
| deleteMapper: _Morphism.deleteMapper, | ||
| mappers: _Morphism.mappers | ||
| }; | ||
|
|
||
| _.assignIn(Morphism, api); | ||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,14 @@ | ||
| export class User { | ||
| constructor(firstName, lastName, phoneNumber){ | ||
| this.firstName = firstName; | ||
| this.lastName = lastName; | ||
| this.phoneNumber = phoneNumber; | ||
| } | ||
| } | ||
|
|
||
| export class Track { | ||
| constructor(id, title){ | ||
| this.id = id; | ||
| this.title = title; | ||
| } | ||
| } |
Oops, something went wrong.