lemoncloud-engine-js - npm Package Compare versions

Comparing version 1.0.21 to 1.0.22

core/lemon-engine-model.js

@@ -1,1 +0,1 @@
-"use strict";var _typeof="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e},_slicedToArray=function(e,r){if(Array.isArray(e))return e;if(Symbol.iterator in Object(e))return function(e,r){var t=[],n=!0,i=!1,o=void 0;try{for(var d,u=e[Symbol.iterator]();!(n=(d=u.next()).done)&&(t.push(d.value),!r||t.length!==r);n=!0);}catch(e){i=!0,o=e}finally{try{!n&&u.return&&u.return()}finally{if(i)throw o}}return t}(e,r);throw new TypeError("Invalid attempt to destructure non-iterable instance")};function _defineProperty(e,r,t){return r in e?Object.defineProperty(e,r,{value:t,enumerable:!0,configurable:!0,writable:!0}):e[r]=t,e}module.exports=function(e,r,t){var n=r||"LEM",f=e.U,h=e._,i=e.MS,u=e.DS,o=e.RS,d=e.ES,a=e.ES6;if(!f)throw new Error("$U is required!");if(!h)throw new Error("$U is required!");if(!i)throw new Error("$MS is required!");if(!u)throw new Error("$DS is required!");if(!o)throw new Error("$RS is required!");var l=e.log,m=e.inf,s=e.err,p=f.NS(n,"green"),_=t||{},c=function(e){throw new Error("NOT_IMPLEMENTED - "+p+":"+JSON.stringify(e))};_.do_prepare=c,_.do_create=c,_.do_clone=c,_.do_update=c,_.do_increment=c,_.do_read=c,_.do_readX=c,_.do_delete=c,_.do_destroy=c,_.do_search=c,_.do_initialize=c,_.do_terminate=c,_.do_test_self=c,_.on_records=c,_.do_notify=c,_.do_subscribe=c,_.do_next_id=c,r.startsWith("_")||e(r,_);var v=function(e,r){return void 0===_[e]?r:_[e]},E=v("VERSION",1),y=v("REVISION",1),P=v("VERSION_NAME","V"),g=v("REVISION_NAME","R"),w=v("ID_INPUT","id"),S=v("ID_NAME","id"),j=v("ID_TYPE","test"),q=v("ID_NEXT",0),N=v("DYNA_TABLE","TestTable"),b=v("REDIS_PKEY","TPKEY"),O=v("DEFAULTS",null),I=v("CLONEABLE",!1),R=v("CLONED_ID","cloned"),A=v("PARENT_ID","parent"),T=v("PARENT_IMUT",!0),x=v("ES_INDEX","test-v1"),D=v("ES_TIMESERIES",!1),W=v("ES_TYPE",""),L=v("ES_MASTER",D?1:0),M=v("ES_VERSION",5);l(p,"! CONF_ES_TIMESERIES=",D);var $=v("XECURE_KEY",null),F=function(){var e=v("FIELDS",null),r=v("ES_FIELDS",D?null:["updated_at","name"]),n=v("XEC_FIELDS",null),t=function(e){return e&&"string"==typeof e?e.split(",").reduce(function(e,r){return(r=r.trim())&&e.push(r),r},[]):e};if(e){if(e=t(e),r=t(r||[]),n=t(n||[]),!Array.isArray(e))throw new Error("FIELDS must be array!");if(!Array.isArray(r))throw new Error("ES_FIELDS must be array!");if(!Array.isArray(n))throw new Error("XEC_FIELDS must be array!");e=e.reduce(function(e,r){var t=r.startsWith("*");if(!(r=t?r.substring(1):r))throw new Error("Invalid field name");return t&&n.indexOf(r)<0&&n.push(r),e.push(r),e},[]),r=r.reduce(function(e,r){var t=r.startsWith("*");if(!(r=t?r.substring(1):r))throw new Error("Invalid field name");return t&&n.indexOf(r)<0&&n.push(r),e.push(r),e},[]),n.length&&m(p,"XECURED-FIELDS =",n)}return!e||!e.length?n=r=e=null:r&&!r.length&&(r=D?e:null),[e,r,n]}(),k=_slicedToArray(F,3),Q=k[0],U=k[1],C=k[2];if(l(p,"! CONF_ES_FIELDS :=",U&&U.join(", ")),D&&b&&!b.startsWith("#"))throw new Error("ES_TIMESERIES - Redis should be inactive. PKEY:"+b);if(D&&!U.length)throw new Error("ES_TIMESERIES - CONF_ES_FIELDS should be valid!");var V=v("NS_NAME",""),Y=5<M?a:d;if(!Y)throw new Error("$ES is required! Ver:"+M);var B=require("dynamodb-value"),z=function(e){var o=require("crypto"),d="aes-256-ctr";if(!o)throw new Error("crypto module is required!");var r={crypto:o,algorithm:d,passwd:e};return r.encrypt=function(e){e=void 0===e?null:e;var r=JSON.stringify({alg:d,val:e}),t=new Buffer("LM!#"+(r||""),"utf8"),n=this.passwd||"",i=o.createCipher(d,n);return Buffer.concat([i.update(t),i.final()]).toString("base64")},r.decrypt=function(e){var r=new Buffer(e||"","base64"),t=this.passwd||"",n=o.createDecipher(d,t),i=Buffer.concat([n.update(r),n.final()]).toString("utf8");return(JSON.parse(i.substr("LM!#".length))||{}).val},r},H=require("./notify-service")(e,"!"+V,{NS_NAME:V});_.do_notify=H.do_notify,_.do_subscribe=H.do_subscribe,I&&Q&&(A&&Q.indexOf(A)<0&&Q.push(A),R&&Q.indexOf(R)<0&&Q.push(R));var X=[w,S,"created_at","updated_at","deleted_at",R];T&&A&&X.push(A);var J=function(e,r,t,n){t=t||"";var i=r="object"===(void 0===(e=e||0)?"undefined":_typeof(e))?r?f.extend(e,r):e:(r=null==r?{}:"object"!==(void 0===r?"undefined":_typeof(r))||r instanceof Promise?{params:r}:f.copy(r),f.extend(r,{_id:e}));if(void 0!==i.records)return f.promise(i);if(t.startsWith("notify"))return f.promise(i);if(i&&void 0!==i._is_prepared&&i._is_prepared)return i._current_mode=t,i._method_stack.push(t),1e3<i._method_stack.length?Promise.reject("method-stack full. size:"+i._method_stack):f.promise(i);e=j.startsWith("#")?i._id||i[w]||"":f.N(i._id||i[w]||0);var o=i._current_time||f.current_time_ms();return i._id=e,i._current_time=o,i._current_mode=t,i._method_stack=[],i._method_stack.push(t),i._updated_node=null,i._ctx=n,i._node={},i._is_prepared=!0,void 0===i._params_count&&(i._params_count=0,i=h.reduce(i,function(e,r,t){return t.startsWith("_")||t.startsWith("$")||0<=X.indexOf(t)||e._params_count++,e},i)),f.promise(i)},K=function(e){if(!e)return e;var r=e._current_mode||"";if(void 0!==e.records)return f.promise(e);if(r.startsWith("notify"))return f.promise(e);if(e._method_stack&&e._method_stack.pop(),"read"!==r&&"increment"!==r&&"create"!==r)return e;if(void 0!==e._auto_populate&&!e._auto_populate)return e;var t=e._node;return 0===e._params_count||-1===e._fields_count?e=h.reduce(t,function(e,r,t){return"updated_at"===t&&void 0!==e[t]?e[t]=e[t]>r?e[t]:r:e[t]=r,e},e):0<=e._fields_count&&(e=Q?Q.reduce(function(e,r){return void 0!==e[r]&&void 0!==t[r]&&(e[r]=t[r]),e},e):e),e},G=function(r){var e=r._id;if(l(p,"- my_prepare_id("+j+", "+e+")...."),j.startsWith("#")){if(j&&j.startsWith("#")&&1<j.length&&0<q){var t=j.substring(1);return i.do_get_next_id(t).then(function(e){return l(p,"> created next-id["+t+"]=",e),r._id=e,r})}}else if(j&&!e)return i.do_get_next_id(j).then(function(e){return l(p,"> created next-id=",e),r._id=e,r});return l(p,"> prepared-id =",e),Promise.resolve(r)},Z=function(t){if(!t._current_mode)throw new Error("._current_mode is required!");var n=t._current_mode,i=O||{},o=0,e=t._node||{};return Q?"prepare"===n||"create"===n||"clone"===n?e=Q.reduce(function(e,r){return r===S||r===P||r===g||("prepare"===n?(void 0!==i[r]?e[r]=O[r]:void 0!==t[r]&&(e[r]=t[r]),P&&(e[P]=E),g&&(e[g]=0)):("create"===n&&g&&(e[g]=y-1),void 0!==t[r]&&(e[r]=t[r])),o++),e},e):"update"!==n&&"increment"!==n&&"read"!==n||(e=Q.reduce(function(e,r){return r===S||void 0!==t[r]&&o++,e},e)):o=-1,t._fields_count=o,t._node=e,t},ee=function(e,r){return e.created_at=0,e.updated_at=r,e.deleted_at=r,e},re=function(e,r){return e.created_at=r,e.updated_at=r,e.deleted_at=0,e},te=function(t){if(!t._node)return Promise.reject(new Error("._node is required!"));if(!t._current_time)return Promise.reject(new Error("._current_time is required!"));if(D)return t._node=t._node||{},Promise.resolve(t);var n=t._id,i=t._current_time;return n?ye(t).catch(function(e){var r=e&&e.message||"";if(r.indexOf("404 NOT FOUND")<0)throw e;return m(p,"WARN! NOT FOUND. msg=",r),t}).then(function(e){var r=(e=Z(e))._node||{};if(e._force_create)s(p,"WARN! _force_create is set!");else if(!r.deleted_at)return s(p,"INVALID STATE FOR PREPARED. ID=",n,", TIMES[CUD]=",[r.created_at,r.updated_at,r.deleted_at]),Promise.reject(new Error("INVALID STATE. deleted_at:"+r.deleted_at));return e[w]=e._id,r[S]=e._id,e._node=ee(e._node,i),e}):(t=Z(t),G(t).then(function(e){var r=e._node||{};return e[w]=e._id,r[S]=e._id,e._node=ee(r,i),e}))},ne=function(e){if(!e._id)return Promise.reject(new Error("._id is required!"));if(!e._node)return Promise.reject(new Error("._node is required!"));if(!e._current_time)return Promise.reject(new Error("._current_time is required!"));if(D)return e._node=e._node||{},Promise.resolve(e);var t=e._id,n=e._current_time;return l(p,"> prepared-id =",t,", current-time =",n),ye(e).then(function(e){var r=(e=Z(e))._node||{};if(e._force_create)m(p,"WARN! _force_create is set!");else if(!r.deleted_at)return s(p,"INVALID STATE FOR CREATED. ID=",t,", TIMES[CUD]=",[r.created_at,r.updated_at,r.deleted_at]),Promise.reject(new Error("INVALID STATE. deleted_at:"+r.deleted_at));return e._node=re(r,n),e})},ie=function(e){if(!e._id)return Promise.reject(new Error("._id is required!"));if(!e._node)return Promise.reject(new Error("._node is required!"));if(!e._current_time)return Promise.reject(new Error("._current_time is required!"));if(D)return e._node=e._node||{},Promise.resolve(e);e._id,e._node;var r=e._current_time;return ye(e).then(function(e){return(e=Z(e))._node=re(e._node,r),e})},oe=function(e){if(!e._id)return Promise.reject(new Error("._id is required!"));if(!e._node)return Promise.reject(new Error("._node is required!"));if(!e._current_time)return Promise.reject(new Error("._current_time is required!"));if(D)return e._node=e._node||{},Promise.resolve(e);e._id,e._node;var n=e._current_time;return 0===(e=Z(e))._fields_count?e:ye(e).then(function(e){var r,t;return e._node=(r=e._node,t=n,r.updated_at=t,r),e})},de=function(e){if(!e._id)return Promise.reject(new Error("._id is required!"));if(!e._node)return Promise.reject(new Error("._node is required!"));if(!e._current_time)return Promise.reject(new Error("._current_time is required!"));if(D)return e._node=e._node||{},Promise.resolve(e);e._id;var n=e._current_time;return ye(e).then(function(e){var r,t;return(e=Z(e))._node=(r=e._node,t=n,r.updated_at=t,r.deleted_at=t,r),e})},ue=function(r){var e;if(!r._id)return Promise.reject(new Error("._id is required!"));var t=r._id;l(p,"- dynamo: read("+t+")....");var n=j.startsWith("#")?"String":"";return u.do_get_item(N,(e={},_defineProperty(e,S,t),_defineProperty(e,"idType",n),e)).then(function(e){return l(p,"> dynamo: node("+t+") res=",f.json(e)),r._node=e,r})},ae=function(r){if(!r._id)return Promise.reject(new Error("._id is required!"));if(!r._node)return Promise.reject(new Error("._node is required!"));var t=r._id,e=r._node;l(p,"- dynamo: update("+t+")....");var n={},i=0,o=$?z($):null;for(var d in r)d&&r.hasOwnProperty(d)&&((d=""+d).startsWith("_")||d.startsWith("$")||0<=X.indexOf(d)||Q&&Q.indexOf(d)<0||d&&(n[d]=r[d],e[d]=r[d],i++,o&&C&&0<=C.indexOf(d)&&(e[d]=r[d]?o.encrypt(r[d]):"",n[d]=e[d])));return n.updated_at=e.updated_at,l(p,"> dynamo: updated =",n),r._updated_node=null,(r._updated_count=i)?(void 0!==e[g]&&(e[g]=f.N(e[g],0)+1),u.do_update_item(N,_defineProperty({},S,t),n,g?_defineProperty({},g,1):null).then(function(e){return r._updated_node=n,r._node=Object.assign(r._node,n),l(p,"> dynamo: updated("+t+") res=",f.json(e)),r})):Q?r:Promise.reject(new Error("nothing to update"))},se=function(r){if(!r._id)return Promise.reject(new Error("._id is required!"));if(!r._node)return Promise.reject(new Error("._node is required!"));var t=r._id,e=r._node,n=r._current_mode||"",i=r._current_time;if(l(p,"- dynamo: save("+t+")...."),"prepare"!==n){var o=$?z($):null;for(var d in r)d&&r.hasOwnProperty(d)&&((d=""+d).startsWith("_")||d.startsWith("$")||0<=X.indexOf(d)||Q&&Q.indexOf(d)<0||(e[d]=r[d],o&&C&&0<=C.indexOf(d)&&(e[d]=r[d]?o.encrypt(r[d]):"")))}return void 0!==e[g]&&(e[g]=f.N(e[g],0)+1),l(p,"> save@node-id =",t,", current-time =",i,", node :=",f.json(e)),u.do_create_item(N,_defineProperty({},S,t),e).then(function(e){return l(p,"> dynamo: saved("+t+") res=",e),r})},_e=function(r){if(!r._id)return Promise.reject(new Error("._id is required!"));if(!r._node)return Promise.reject(new Error("._node is required!"));var t=r._id,e=r._node;l(p,"- dynamo: increment("+t+")....");var n={},i=0;for(var o in r)r.hasOwnProperty(o)&&((o=""+o).startsWith("_")||o.startsWith("$")||0<=X.indexOf(o)||Q&&Q.indexOf(o)<0||o&&(n[o]=r[o],e[o]=f.N(e[o],0)+f.N(r[o]),i++));return n.updated_at=e.updated_at,l(p,"> dynamo: incremented["+t+"] :=",n),r._updated_node=null,(r._updated_count=i)?(void 0!==e[g]&&(e[g]=f.N(e[g],0)+1),u.do_increment_item(N,_defineProperty({},S,t),n,g?_defineProperty({},g,1):null).then(function(e){return l(p,"> dynamo: increment("+t+") res=",f.json(e)),r._updated_node=n,r})):Q?r:Promise.reject(new Error("nothing to update"))},ce=function(r){var t=r._id;return t?(l(p,"- dynamo: delete("+t+")...."),u.do_delete_item(N,_defineProperty({},S,t)).then(function(e){return l(p,"> dynamo: deleted("+t+") res=",f.json(e)),r._node=e||{},r})):Promise.reject(new Error("._id is required!"))},fe={do_read_cache:function(r){var t=r._id;return t?b?b.startsWith("#")?D?ue(r).then(function(e){return void 0===(e._node||{})[S]?Promise.reject(new Error("404 NOT FOUND. "+N+".id:"+(e._id||""))):e}):he.do_read_search(r).catch(function(e){throw e instanceof Error&&(s(p,"! redis: read-search("+b+", "+t+") err :=",e.message||e),r._error=e),r}):(l(p,"- redis: get-item("+t+")...."),o.do_get_item(b,t).then(function(e){return e?(r._node=e,r):Promise.reject(r)}).catch(function(e){throw e instanceof Error&&(s(p,"! redis: get-item("+b+", "+t+") err :=",e.message||e),r._error=e),r})):Promise.reject(r):Promise.reject(new Error("._id is required!"))},do_save_cache:function(r){var e=r._id;if(!e)return Promise.reject(new Error("._id is required!"));if(!r._node)return Promise.reject(new Error("._node is required!"));if(!b)return Promise.resolve(r);if(b.startsWith("#"))return Promise.resolve(r);var t=r._node;l(p,"- redis: create-item("+e+")....");var n=fe.do_set_cache_footprint(e,t);return n=n.then(function(){return o.do_create_item(b,e,t)}).then(function(e){return r})},do_update_cache:function(r){var e=r._id;if(!e)return Promise.reject(new Error("._id is required!"));if(!r._node)return Promise.reject(new Error("._node is required!"));if(!b)return Promise.resolve(r);if(b.startsWith("#"))return Promise.resolve(r);var t=r._node;l(p,"- redis: update-item("+e+")....");var n=fe.do_set_cache_footprint(e,t);return n=n.then(function(){return o.do_update_item(b,e,t)}).then(function(e){return r})},do_delete_cache:function(r){var t=r._id;if(!t)return Promise.reject(new Error("._id is required!"));if(!b)return Promise.resolve(r);var e=b.startsWith("#")?b.substr(1):b;if(!e)return Promise.resolve(r);return Promise.all([e,e+"/UPDATED",e+"/HASH"].map(function(e){return o.do_delete_item(e,t).then(function(e){return e}).catch(function(e){return e.message||""+e})})).then(function(e){return l(p,"> redis: deleted("+t+") res=",f.json(e)),r})},do_set_cache_footprint:function(e,r){if(!e)return Promise.reject(new Error("id is required!"));if(!b)return Promise.resolve(0);r=r||{};var t=f.N(r.updated_at,0),n=f.hash(r);return o.do_create_item([b+"/UPDATED",b+"/HASH"],e,[t,n]).then(function(e){return e})},do_get_cache_updated:function(e){return e?b?b.startsWith("#")?Promise.resolve(-1):o.do_get_item(b+"/UPDATED",e).then(function(e){return e}):Promise.resolve(-1):Promise.reject(new Error("id is required!"))},do_get_cache_hash:function(e){return e?b?b.startsWith("#")?Promise.resolve(-1):o.do_get_item(b+"/HASH",e).then(function(e){return e}):Promise.resolve(-1):Promise.reject(new Error("id is required!"))}},he={do_read_search:function(r){var e=r._id;return e?x?(l(p,"- elasticsearch: read("+e+")...."),Y.do_get_item(x,W,e).then(function(e){return e?(r._node=U?f.extend(r._node||{},e):e,r):Promise.reject(r)})):r:Promise.reject(new Error("._id is required!"))},do_save_search:function(r){var t=r._id;if(!t)return Promise.reject(new Error("._id is required!"));if(!r._node)return Promise.reject(new Error("._node is required!"));if(!x)return r;var n=r._node,e=r._current_time||f.current_time_ms();if(U){var i=h.reduce(U,function(e,r){return void 0!==n[r]&&(e[r]=n[r]),e},{});return Object.keys(i).length?(void 0!==n.created_at&&(i.created_at=n.created_at),void 0!==n.updated_at&&(i.updated_at=n.updated_at),void 0!==n.deleted_at&&(i.deleted_at=n.deleted_at),l(p,"> elasticsearch:save("+L+"/"+t+").... node2=",f.json(i)),D?(i["@timestamp"]=e,i[S]=t,Y.do_push_item(x,W,i).then(function(e){return l(p,"! elasticsearch: pushed-item("+t+")@1 res=",f.json(e)),r})):L?Y.do_create_item(x,W,t,i).then(function(e){return l(p,"! elasticsearch: saved-item("+t+")@1 res=",f.json(e)),r}):Y.do_update_item(x,W,t,i).then(function(e){return l(p,"! elasticsearch: updated-item("+t+")@1 res=",f.json(e)),r})):(s(p,"! elasticsearch:WARN! nothing to update ("+t+")...."),r)}return Y.do_create_item(x,W,t,n).then(function(e){return l(p,"! elasticsearch: create-item("+t+")@3 res=",f.json(e)),r})},do_update_search:function(r){var t=r._id;if(!t)return Promise.reject(new Error("._id is required!"));if(!r._updated_node)return Promise.reject(new Error("._updated_node is required!"));if(!x)return r;var n=r._updated_node;if(U){var e=h.reduce(U,function(e,r){return e[r]=n[r],e},{});return Object.keys(e).length?(void 0!==n.created_at&&(e.created_at=n.created_at),void 0!==n.updated_at&&(e.updated_at=n.updated_at),void 0!==n.deleted_at&&(e.deleted_at=n.deleted_at),Y.do_update_item(x,W,t,e).then(function(e){return l(p,"! elasticsearch: updated-item("+t+") res=",f.json(e)),r})):(s(p,"! elasticsearch:WARN! nothing to update ("+t+")...."),r)}return Y.do_update_item(x,W,t,n).then(function(e){return l(p,"! elasticsearch: updated-item("+t+") res=",f.json(e)),r})},do_delete_search:function(r){var t=r._id;return t?x?U&&!L?(l(p,"! elasticsearch:WARN! ignore delete ("+t+")...."),r):Y.do_delete_item(x,W,t).then(function(e){return l(p,"! elasticsearch: deleted-item("+t+") res=",f.json(e)),r}).catch(function(e){return l(p,"ERR! ignore - elastic:delete("+t+") res=",e),r}):r:Promise.reject(new Error("._id is required!"))},do_search:function(i){if(!x)return i;if(U&&!L)return i;var o={$page:0,$limit:0};return o.$page=f.N(i.page,0),o.$limit=f.N(i.ipp,0===i.ipp?0:10),D||(o.deleted_at=void 0!==i.deleted_at?i.deleted_at:"0"),i.$source&&(o.$source=i.$source),i.$exist&&(o.$exist=i.$exist),i.Q&&(o.$Q=i.Q),i.A&&(o.$A=i.A),i.O&&(o.$O=i.O),i.H&&(o.$H=i.H),D&&(o.$O=o.$O||"!@timestamp"),o.$O=o.$O||(j.startsWith("#")?S+".keyword":S),U&&U.forEach(function(e){"page"!=e&&"ipp"!=e&&(void 0!==i[e]&&(o[e]=i[e]),void 0!==i["!"+e]&&(o["!"+e]=i["!"+e]),void 0!==i["#"+e]&&(o["#"+e]=i["#"+e]))}),l(p,"! elasticsearch: search["+x+"/"+W+"] =",f.json(o)),Y.do_search_item(x,W,o).then(function(e){var r=e&&e.hits||{},t=r.hits||[],n=r;return i.list=t.map(function(r){var t=r._score?f.extend({_score:r._score},r._source):r._source;return D&&(t["@id"]=r._id),null!=r.highlight&&Object.keys(r.highlight).forEach(function(e){t[e+"_highlight"]=r.highlight[e][0]}),t}),i.total=f.N(n.total||0),i.page=o.$page,i.ipp=o.$limit,i.took=e.took||0,void 0!==e.aggregations&&(i.aggregations=e.aggregations),i}).catch(function(e){throw s(p,"!ERR @search =",e),e})}},le={},me=function(e){var r=e._id||"";return[b,N,""+r].join(":").toUpperCase()},pe=function(e){if(D)return e;var r=me(e),t=e._node,n=e._current_time||f.current_time_ms();t||delete le[r];var i={cached_at:n,node:t};return le[r]=i,e},ve=function(e){var r=me(e);return delete le[r],e},Ee=function(n){var i=n._id;return Object.keys(n).forEach(function(t,e){if(n.hasOwnProperty(t)&&!(t.startsWith("_")||t.startsWith("$")||Q&&Q.indexOf(t)<0)){var r=n[t];if(r&&"object"==(void 0===r?"undefined":_typeof(r))){if(!Array.isArray(r))throw new Error("Invalid data-type (object) key:"+t+"@"+i);r.forEach(function(e,r){if(e&&"object"==(void 0===e?"undefined":_typeof(e)))throw new Error("Invalid data-type (object) key:"+t+"@"+i+":"+r)})}}}),n},ye=function(e){var r,t,n,i,o;return e._id?(t=me(r=e),n=le[t]||{},i=f.N(n.cached_at,0),o=(r._current_time||f.current_time_ms())-i,n.node&&i&&!(2e3<o)&&(r._node=Object.assign({},n.node),r.C=i,1)?Promise.resolve(e):Promise.resolve(e).then(fe.do_read_cache).catch(function(e){if(e&&e instanceof Error)throw e;return ue(e).then(function(e){return void 0===(e._node||{})[S]?Promise.reject(new Error("404 NOT FOUND. "+N+".id:"+(e._id||""))):e}).then(fe.do_save_cache).then(he.do_save_search)}).then(pe)):Promise.reject(new Error("._id is required!"))},Pe=function(e){if(!e)return e;if(!C||!C.length)return e;var n=$?z($):null;return n?C.reduce(function(e,r){var t=e[r];return void 0===t||(e[r]=t?n.decrypt(t):t),e},e):e},ge=function(e){return e._id?e._node?Promise.resolve(e).then(Ee).then(se).then(fe.do_save_cache).then(he.do_save_search).then(pe):Promise.reject(new Error("_node is required!")):Promise.reject(new Error("._id is required!"))},we=function(e){var r=e._id;return r?e._node?e._current_time?(l(p,"- my_clone_node ("+r+")...."),Promise.resolve(e).then(function(n){if(!I)return n;var i=void 0!==n[A]?f.N(n[A],0):r,o=r;return G({_id:0}).then(function(e){var r=e._id,t=n._node||{};return t[S]=r,A&&(t[A]=i),R&&(t[R]=o),A&&(n[A]=i),R&&(n[R]=o),n._clone_id=r,n._node=t,n})}).then(function(e){var r=e._id;return e._node?e._clone_id?(e._id=e._clone_id,h.reduce(e,function(e,r,t){return t&&(t.startsWith("_")||t.startsWith("$")||0<=X.indexOf(t)||void 0!==e[t]&&(e[t]=r)),e},e._node),l(p,">> before save-node().. that._node =",f.json(e._node)),ge(e).then(function(){return e._id=r,e})):Promise.reject(new Error("._clone_id is required!")):Promise.reject(new Error("._node is required!"))}).then(function(e){return l(p,">> cloned-node["+e._id+" -> "+e._clone_id+"] res=",f.json(e._node)),e})):Promise.reject(new Error("._current_time is required!")):Promise.reject(new Error("._node is required!")):Promise.reject(new Error("._id is required!"))},Se=function(e){return e._id?Promise.resolve(e).then(ce).then(fe.do_delete_cache).then(he.do_delete_search).then(ve).then(function(e){return l(p,">> deleted-node res=",f.json(e._node)),e}):Promise.reject(new Error("._id is required!"))},je=function(e){return Promise.resolve(e).then(he.do_search)},qe=function(e){if(!e)return e;if(!e._id)return Promise.reject(new Error("_id is required!"));var n=e._current_mode;return Promise.resolve(e).then(function(r){var e=!1;if("create"===n||"prepare"===n||"delete"===n||"destroy"===n?e=!0:"update"!==n&&"increment"!==n||(e=0<r._fields_count),e){var t=V+":event:"+n;return l(p,">>> notify event-id:",t,", notifiable=",e),Oe(t,r).then(function(e){return r})}return r})},Ne=function(r){if(!r.records)return Promise.reject(new Error("records is required!"));var e=r.records.slice(0);if(l(p,"- my_event_records().... records.len=",e.length),!e.length)return r;var t,n,i;return(t=e,n=be,i=f.promise(t.shift()),i=t.reduce(function(e,r){return e.then(function(){return n(r)})},i.then(function(e){return n(e)}))).catch(function(e){return s(p,"error ignored! =",e),r}).then(function(){return r})},be=function(e){if(!e)return Promise.reject(new Error("record is required"));if(!e.dynamodb&&!e.Sns)return Promise.reject(new Error("record.dynamodb|Sns is required"));var i=e.eventName||"EVENT",r=null;if(e.dynamodb){var o=e.table||e.eventSourceARN&&e.eventSourceARN.split("/")[1]||"";if(l(p,"--- process-record("+o+") ... "),N!==o)return l(p,"! ignore record-table: "+N+" != "+o+" "),e;var t=e.dynamodb.Keys?B.toJavascript(e.dynamodb.Keys):{},d=e.dynamodb.NewImage?B.toJavascript(e.dynamodb.NewImage):null,n=e.dynamodb.OldImage?B.toJavascript(e.dynamodb.OldImage):null,u=t[S],a="MODIFY"===i?f.diff(n,d):null,s=f.N(d&&d.updated_at||0),_=a?h.reduce(a,function(e,r){return e[r]=n[r],e},{}):null,c={_id:u,_node:d,_updated_at:s,_diff:a,_prev:_};switch(r=Promise.resolve(c),a&&l(p,">> "+o+".different["+u+"]=",f.json(a)),i){case"INSERT":case"MODIFY":r=r.then(function(t){var n=t._id;return D?t:fe.do_get_cache_updated(n).then(function(e){if(m(p,">> "+o+".updated_at["+n+"] res=",e," <- ",t._updated_at,t._updated_at!==e?"*":""),!e||t._updated_at>=e){var r=f.hash(d);return fe.do_get_cache_hash(n).then(function(e){return e&&e===r?(l(p,"!WARN! ignored due to hash-value matching =",e),t):(-1!==e&&l(p,"! INFO! node was updated. hash :=",r,"<-",e),fe.do_save_cache(t).then(he.do_save_search))})}return l(p,"! ignored due to old-record"),t})});break;case"REMOVE":l(p,">> removed!"),r=(r=r.then(fe.do_delete_cache)).then(he.do_delete_search)}}else if(e.Sns){l(p,">> event-SNS =",e.Sns);r=Promise.resolve(e.Sns)}return r?r.then(function(r){var e={INSERT:"create",MODIFY:"update",REMOVE:"delete",EVENT:"event"}[i],t=!!e;if(r._current_mode=e,t){var n=V+":record:"+e;return l(p,">>> notify event-id:",n,", notifiable=",t),Oe(n,r).then(function(e){return r})}return r}).then(function(){return e}):Promise.reject(new Error("invalid chain!"))},Oe=function(e,r){return H.do_notify(e,r)},Ie=function(r){var e=[];if(N){var t=j.startsWith("#")?"S":"N";e.push(Promise.resolve("DynamoDb").then(function(e){return l(p,"# initialize ",e),u.do_create_table(N,S,t).then(function(e){return{result:e.TableDescription.TableName===N,name:"dynamo:"+N}})}).catch(function(e){var r=e.message||""+e;return s(p,"> create-table error=",e),"ResourceInUseException"===e.code?{result:!1,name:"dynamo:"+N,code:e.code}:{result:!1,name:"dynamo:"+N,error:r}}))}else l(p,"DS: WARN! ignored configuration. DYNA_TABLE=",N);if(j&&!j.startsWith("#")?e.push(Promise.resolve("MySQL").then(function(e){return l(p,"# initialize MySQL (Sequence) "),i.do_create_id_seq(j,q).then(function(e){return l(p,"> create-id-seq res=",e),{result:!0,name:"sequence"}})}).catch(function(e){var r=e.message||""+e;return s(p,"> create-id-seq error=",e),"ER_TABLE_EXISTS_ERROR"===e.code?{result:!1,name:"MySQL",code:e.code}:{result:!1,name:"MySQL",error:r}})):j&&j.startsWith("#")&&1<j.length&&0<q?e.push(Promise.resolve("MySQL").then(function(e){l(p,"# initialize MySQL (Sequence) ");var r=j.substring(1);return i.do_create_id_seq(r,q).then(function(e){return l(p,"> create-id-seq["+r+"] res=",e),{result:!0,name:"MySQL"}})}).catch(function(e){var r=e.message||""+e;return s(p,"> create-id-seq error=",e),"ER_TABLE_EXISTS_ERROR"===e.code?{result:!1,name:"MySQL",code:e.code}:{result:!1,name:"MySQL",error:r}})):l(p,"MS: WARN! ignored configuration. ID_TYPE=",j),x&&U){var n={template:x,mappings:{_default_:{dynamic_templates:[{string_fields:{match:"*_multi",match_mapping_type:"string",mapping:{type:"multi_field",fields:{"{name}":{type:6<=M?"text":"string",index:"analyzed",omit_norms:!0,index_options:"docs"},"{name}.raw":{type:6<=M?"text":"string",index:"not_analyzed",ignore_above:256}}}}}],_source:{enabled:6<=M},properties:{"@version":{type:6<=M?"text":"string",index:!(6<=M)&&"not_analyzed"},title:{type:6<=M?"text":"string"},name:{type:6<=M?"text":"string"},created_at:{type:"date",format:"strict_date_optional_time||epoch_millis"},updated_at:{type:"date",format:"strict_date_optional_time||epoch_millis"},deleted_at:{type:"date",format:"strict_date_optional_time||epoch_millis"}}}}};if(6<=M||(n.mappings._default_.all={enabled:!0}),S&&j.startsWith("#")&&(n.mappings._default_.properties[S]={type:6<=M?"text":"string",fields:{keyword:{type:"keyword",ignore_above:256}}}),D)n.settings={index:{refresh_interval:"5s"}},n.mappings._default_.properties["@timestamp"]={type:"date",doc_values:!0},n.mappings._default_.properties.ip={type:"ip"},"@version,title,created_at,updated_at,deleted_at".split(",").map(function(e){return delete n.mappings._default_.properties[e]});e.push(Promise.resolve("ElasticSearch").then(function(e){return l(p,"# initialize ElasticSearch. ES_TYPE=",W),Y.do_create_index_type(x,W,n).then(function(e){return l(p,"> create-es-index res=",e),{result:!0,name:"elasticsearch:"+x,settings:n}}).catch(function(e){var r=e.message||e.reason||""+e;return s(p,"> create-es-index error=",e),"index_already_exists_exception"===e.type?{result:!0,name:"elasticsearch:"+x,warn:e.type}:{result:!1,name:"elasticsearch:"+x,error:r}})}))}else l(p,"MS: WARN! ignored configuration. ES_TYPE=",W);return Promise.all(e).then(function(e){return l(p,">> results=",e),r.results=e,r})},Re=function(r){var e=[];if(N&&(l(p,"# terminate DynamoDB"),e.push(u.do_delete_table(N).then(function(e){e.TableDescription.TableName;return{result:!0,name:"dynamo:"+N}}).catch(function(e){var r=e.message||""+e;return s(p,"> delete-table error=",e),"ResourceNotFoundException"===e.code?{result:!0,name:"dynamo:"+N,code:e.code}:{result:!1,name:"dynamo:"+N,error:r}}))),j&&!j.startsWith("#"))l(p,"# terminate MySQL (Sequence) "),e.push(i.do_delete_id_seq(j).then(function(e){return l(p,"> delete-id-seq res=",e),{result:!0,name:"MySQL:"+j}}).catch(function(e){var r=e.message||""+e;return s(p,"> delete-id-seq error=",e),"ER_BAD_TABLE_ERROR"===e.code?{result:!0,name:"MySQL:"+j,code:e.code}:{result:!1,name:"MySQL:"+j,error:r}}));else if(j&&j.startsWith("#")&&1<j.length&&0<q){l(p,"# terminate MySQL (Sequence) ");var t=j.substring(1);e.push(i.do_delete_id_seq(t).then(function(e){return l(p,"> delete-id-seq["+t+"] res=",e),{result:!0,name:"MySQL:"+t}}).catch(function(e){var r=e.message||""+e;return s(p,"> delete-id-seq error=",e),"ER_BAD_TABLE_ERROR"===e.code?{result:!0,name:"MySQL:"+t,code:e.code}:{result:!1,name:"MySQL:"+t,error:r}}))}else l(p,"# ignored MySQL (Sequence) ");return x?(l(p,"# terminate ES (Index) "),e.push(Y.do_delete_index_type(x,null).then(function(e){return l(p,"> delete-es-index res=",e),{result:!0,name:"elasticsearch:"+x}}).catch(function(e){var r=e.message||e.reason||""+e;return s(p,"> delete-es-index error=",e),{result:!1,name:"elasticsearch:"+x,error:r}}))):l(p,"# ignored ES (Index) "),Promise.all(e).then(function(e){return l(p,">> results=",e),r.results=e,r})},Ae=function(e){var r={a:1,b:2,x:3},t={x:3,a:1,b:2},n={b:2,x:3,a:1};r.name="hi",t.name="hi",n.name="hi",l(p,"# node1 =",f.json(r)),l(p,"> node2 =",f.json(t)),l(p,"> node3 =",f.json(n)),l(p,"# node1.sorted =",f.json(r,!0)),l(p,"> node2.sorted =",f.json(t,!0)),l(p,"> node3.sorted =",f.json(n,!0)),l(p,"# hash1 =",f.hash(1)),l(p,"> node1 =",f.hash(r)),l(p,"> node2 =",f.hash(t)),l(p,"> node3 =",f.hash(n));var i={updated_at:234,name:"test hash"};return Promise.resolve(i).then(function(e){return o.do_create_item("H#",1,e)}).then(function(){return o.do_get_item("H#",1).then(function(e){return l(p,"> read-back data=",e),e})}).then(function(){return fe.do_set_cache_footprint(1,i)}).then(function(){return fe.do_get_cache_updated(1).then(function(e){return l(p,"> updated-at value=",void 0===e?"undefined":_typeof(e),":",e),e})}).then(function(){return fe.do_get_cache_hash(1).then(function(e){return l(p,"> hash-value value=",void 0===e?"undefined":_typeof(e),":",e),e})})},Te=function(r){return l(p,"- my_test_self()...."),Promise.resolve(r).then(Ae).then(function(e){return e||r})};return _.do_prepare_chain=function(e,r,t,n){return J(e,r,t,n)},_.do_finish_chain=function(e,r,t,n){return K(e)},_.do_prepare=function(e,r){return J(e,r,"prepare").then(te).then(ge).then(qe).then(K)},_.do_create=function(t,n){return J(t,n,"create").then(ne).catch(function(e){s(p,"ERR! prepare_node_created =",e instanceof Error,e.message||e);var r=e&&e.message||"";if(e instanceof Error&&0<=r.indexOf("404 NOT FOUND"))return m(p,"WARN! AUTO TRY TO PREPARE NODE. ID="+t),J(t,n,"create").then(function(e){var r=e._current_time;return e=Z(e),l(p,">> prepared old-node=",f.json(e._node)),e._node=re(e._node,r),e});throw e}).then(ge).then(qe).then(K)},_.do_saveES=function(e,r){return e?r?J(e,{},"save").then(Ee).then(function(e){return e._node=r,e}).then(he.do_save_search).then(K):Promise.reject(new Error("node is required!")):Promise.reject(new Error("id is required!"))},_.do_cleanRedis=function(e,r){return e?J(e,{},"clean").then(function(e){return e._node=r,e}).then(fe.do_delete_cache).then(K):Promise.reject(new Error("id is required!"))},_.do_clone=function(e,r){return J(e,r,"clone").then(ie).then(we).then(qe).then(K)},_.do_read=function(e,r){return J(e,r,"read").then(Z).then(function(e){return 0!==e._params_count&&0===e._fields_count?e:ye(e)}).then(K)},_.do_readX=function(e,r){return J(e,r,"read").then(Z).then(function(e){return 0!==e._params_count&&0===e._fields_count?e:ye(e)}).then(K).then(Pe)},_.do_update=function(e,r){return J(e,r,"update").then(oe).then(function(e){return 0===e._fields_count?e:(n=(t=e)._id)?0===t._fields_count?(l(p,"! my_update_node() no need to update... fields_count="+t._fields_count),t):Promise.resolve(t).then(Ee).then(ae).then(function(e){return e._updated_node?fe.do_save_cache(e):e}).then(function(e){return e._updated_node?he.do_save_search(e):e}).then(function(e){return e._updated_node?pe(e):e}).then(function(e){return l(p,">> updated-node["+n+"] res=",f.json(e._updated_node)),e}).catch(function(e){var r=e&&e.message||"";if(s(p,">> updated-node["+n+"] err=",r),0<r.indexOf("an attribute that does not exist in the item"))return ge(t);throw e}):Promise.reject(new Error("._id is required!"));var t,n}).then(qe).then(K)},_.do_increment=function(e,r){return J(e,r,"increment").then(oe).then(function(e){return 0===e._fields_count?e:(t=(r=e)._id)?0===r._fields_count?(l(p,"! my_increment_node() no need to increment... fields_count="+r._fields_count),r):Promise.resolve(r).then(Ee).then(_e).then(function(e){return e._updated_node?fe.do_save_cache(e):e}).then(function(e){return e._updated_node?he.do_save_search(e):e}).then(function(e){return e._updated_node?pe(e):e}).then(function(e){return l(p,">> increment-node["+t+"] res=",f.json(e._updated_node)),e}):Promise.reject(new Error("._id is required!"));var r,t}).then(qe).then(K)},_.do_delete=function(e,r){return J(e,r,"delete").then(de).then(ge).then(qe).then(K)},_.do_destroy=function(e,r){return J(e,r,"destroy").then(Se).then(qe).then(K)},_.do_search=function(e,r){return J(e,r,"search").then(je).then(K)},_.on_records=function(e,r){return J(e,r,"on_records").then(Ne).then(K)},_.do_initialize=function(e,r){return J(e,r,"initialize").then(Ie).then(K)},_.do_terminate=function(e,r){return J(e,r,"terminate").then(Re).then(K)},_.do_test_self=function(e,r){return J(e,r,"self-test").then(Te).then(K)},_.do_next_id=function(){return G({_id:0}).then(function(e){return e._id})},_};
+"use strict";var _typeof="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e},_slicedToArray=function(e,r){if(Array.isArray(e))return e;if(Symbol.iterator in Object(e))return function(e,r){var t=[],n=!0,i=!1,o=void 0;try{for(var d,u=e[Symbol.iterator]();!(n=(d=u.next()).done)&&(t.push(d.value),!r||t.length!==r);n=!0);}catch(e){i=!0,o=e}finally{try{!n&&u.return&&u.return()}finally{if(i)throw o}}return t}(e,r);throw new TypeError("Invalid attempt to destructure non-iterable instance")};function _defineProperty(e,r,t){return r in e?Object.defineProperty(e,r,{value:t,enumerable:!0,configurable:!0,writable:!0}):e[r]=t,e}module.exports=function(e,r,t){var n=r||"LEM",f=e.U,h=e._,i=e.MS,u=e.DS,o=e.RS,d=e.ES,a=e.ES6;if(!f)throw new Error("$U is required!");if(!h)throw new Error("$U is required!");if(!i)throw new Error("$MS is required!");if(!u)throw new Error("$DS is required!");if(!o)throw new Error("$RS is required!");var l=e.log,m=e.inf,s=e.err,p=f.NS(n,"green"),_=t||{},c=function(e){throw new Error("NOT_IMPLEMENTED - "+p+":"+JSON.stringify(e))};_.do_prepare=c,_.do_create=c,_.do_clone=c,_.do_update=c,_.do_increment=c,_.do_read=c,_.do_readX=c,_.do_delete=c,_.do_destroy=c,_.do_search=c,_.do_initialize=c,_.do_terminate=c,_.do_test_self=c,_.on_records=c,_.do_notify=c,_.do_subscribe=c,_.do_next_id=c,r.startsWith("_")||e(r,_);var v=function(e,r){return void 0===_[e]?r:_[e]},E=v("VERSION",1),y=v("REVISION",1),P=v("VERSION_NAME","V"),g=v("REVISION_NAME","R"),w=v("ID_INPUT","id"),S=v("ID_NAME","id"),j=v("ID_TYPE","test"),q=v("ID_NEXT",0),N=v("DYNA_TABLE","TestTable"),b=v("REDIS_PKEY","TPKEY"),O=v("DEFAULTS",null),I=v("CLONEABLE",!1),R=v("CLONED_ID","cloned"),A=v("PARENT_ID","parent"),T=v("PARENT_IMUT",!0),x=v("ES_INDEX","test-v1"),D=v("ES_TIMESERIES",!1),W=v("ES_TYPE",""),L=v("ES_MASTER",D?1:0),M=v("ES_VERSION",5);l(p,"! CONF_ES_TIMESERIES=",D);var $=v("XECURE_KEY",null),F=function(){var e=v("FIELDS",null),r=v("ES_FIELDS",D?null:["updated_at","name"]),n=v("XEC_FIELDS",null),t=function(e){return e&&"string"==typeof e?e.split(",").reduce(function(e,r){return(r=r.trim())&&e.push(r),r},[]):e};if(e){if(e=t(e),r=t(r||[]),n=t(n||[]),!Array.isArray(e))throw new Error("FIELDS must be array!");if(!Array.isArray(r))throw new Error("ES_FIELDS must be array!");if(!Array.isArray(n))throw new Error("XEC_FIELDS must be array!");e=e.reduce(function(e,r){var t=r.startsWith("*");if(!(r=t?r.substring(1):r))throw new Error("Invalid field name");return t&&n.indexOf(r)<0&&n.push(r),e.push(r),e},[]),r=r.reduce(function(e,r){var t=r.startsWith("*");if(!(r=t?r.substring(1):r))throw new Error("Invalid field name");return t&&n.indexOf(r)<0&&n.push(r),e.push(r),e},[]),n.length&&m(p,"XECURED-FIELDS =",n)}return!e||!e.length?n=r=e=null:r&&!r.length&&(r=D?e:null),[e,r,n]}(),k=_slicedToArray(F,3),Q=k[0],U=k[1],C=k[2];if(l(p,"! CONF_ES_FIELDS :=",U&&U.join(", ")),D&&b&&!b.startsWith("#"))throw new Error("ES_TIMESERIES - Redis should be inactive. PKEY:"+b);if(D&&!U.length)throw new Error("ES_TIMESERIES - CONF_ES_FIELDS should be valid!");var V=v("NS_NAME",""),Y=5<M?a:d;if(!Y)throw new Error("$ES is required! Ver:"+M);var B=require("dynamodb-value"),z=function(e){var o=require("crypto"),d="aes-256-ctr";if(!o)throw new Error("crypto module is required!");var r={crypto:o,algorithm:d,passwd:e};return r.encrypt=function(e){e=void 0===e?null:e;var r=JSON.stringify({alg:d,val:e}),t=new Buffer("LM!#"+(r||""),"utf8"),n=this.passwd||"",i=o.createCipher(d,n);return Buffer.concat([i.update(t),i.final()]).toString("base64")},r.decrypt=function(e){var r=new Buffer(e||"","base64"),t=this.passwd||"",n=o.createDecipher(d,t),i=Buffer.concat([n.update(r),n.final()]).toString("utf8");return(JSON.parse(i.substr("LM!#".length))||{}).val},r},H=require("./notify-service")(e,"!"+V,{NS_NAME:V});_.do_notify=H.do_notify,_.do_subscribe=H.do_subscribe,I&&Q&&(A&&Q.indexOf(A)<0&&Q.push(A),R&&Q.indexOf(R)<0&&Q.push(R));var X=[w,S,"created_at","updated_at","deleted_at",R];T&&A&&X.push(A);var J=function(e,r,t,n){t=t||"";var i=r="object"===(void 0===(e=e||0)?"undefined":_typeof(e))?r?f.extend(e,r):e:(r=null==r?{}:"object"!==(void 0===r?"undefined":_typeof(r))||r instanceof Promise?{params:r}:f.copy(r),f.extend(r,{_id:e}));if(void 0!==i.records)return f.promise(i);if(t.startsWith("notify"))return f.promise(i);if(i&&void 0!==i._is_prepared&&i._is_prepared)return i._current_mode=t,i._method_stack.push(t),1e3<i._method_stack.length?Promise.reject("method-stack full. size:"+i._method_stack):f.promise(i);e=j.startsWith("#")?i._id||i[w]||"":f.N(i._id||i[w]||0);var o=i._current_time||f.current_time_ms();return i._id=e,i._current_time=o,i._current_mode=t,i._method_stack=[],i._method_stack.push(t),i._updated_node=null,i._ctx=n,i._node={},i._is_prepared=!0,void 0===i._params_count&&(i._params_count=0,i=h.reduce(i,function(e,r,t){return t.startsWith("_")||t.startsWith("$")||0<=X.indexOf(t)||e._params_count++,e},i)),f.promise(i)},K=function(e){if(!e)return e;var r=e._current_mode||"";if(void 0!==e.records)return f.promise(e);if(r.startsWith("notify"))return f.promise(e);if(e._method_stack&&e._method_stack.pop(),"read"!==r&&"increment"!==r&&"create"!==r)return e;if(void 0!==e._auto_populate&&!e._auto_populate)return e;var t=e._node;return 0===e._params_count||-1===e._fields_count?e=h.reduce(t,function(e,r,t){return"updated_at"===t&&void 0!==e[t]?e[t]=e[t]>r?e[t]:r:e[t]=r,e},e):0<=e._fields_count&&(e=Q?Q.reduce(function(e,r){return void 0!==e[r]&&void 0!==t[r]&&(e[r]=t[r]),e},e):e),e},G=function(r){var e=r._id;if(l(p,"- my_prepare_id("+j+", "+e+")...."),j.startsWith("#")){if(j&&j.startsWith("#")&&1<j.length&&0<q){var t=j.substring(1);return i.do_get_next_id(t).then(function(e){return l(p,"> created next-id["+t+"]=",e),r._id=e,r})}}else if(j&&!e)return i.do_get_next_id(j).then(function(e){return l(p,"> created next-id=",e),r._id=e,r});return l(p,"> prepared-id =",e),Promise.resolve(r)},Z=function(t){if(!t._current_mode)throw new Error("._current_mode is required!");var n=t._current_mode,i=O||{},o=0,e=t._node||{};return Q?"prepare"===n||"create"===n||"clone"===n?e=Q.reduce(function(e,r){return r===S||r===P||r===g||("prepare"===n?(void 0!==i[r]?e[r]=O[r]:void 0!==t[r]&&(e[r]=t[r]),P&&(e[P]=E),g&&(e[g]=0)):("create"===n&&g&&(e[g]=y-1),void 0!==t[r]&&(e[r]=t[r])),o++),e},e):"update"!==n&&"increment"!==n&&"read"!==n||(e=Q.reduce(function(e,r){return r===S||void 0!==t[r]&&o++,e},e)):o=-1,t._fields_count=o,t._node=e,t},ee=function(e,r){return e.created_at=0,e.updated_at=r,e.deleted_at=r,e},re=function(e,r){return e.created_at=r,e.updated_at=r,e.deleted_at=0,e},te=function(t){if(!t._node)return Promise.reject(new Error("._node is required!"));if(!t._current_time)return Promise.reject(new Error("._current_time is required!"));if(D)return t._node=t._node||{},Promise.resolve(t);var n=t._id,i=t._current_time;return n?ye(t).catch(function(e){var r=e&&e.message||"";if(r.indexOf("404 NOT FOUND")<0)throw e;return m(p,"WARN! NOT FOUND. msg=",r),t}).then(function(e){var r=(e=Z(e))._node||{};if(e._force_create)s(p,"WARN! _force_create is set!");else if(!r.deleted_at)return s(p,"INVALID STATE FOR PREPARED. ID=",n,", TIMES[CUD]=",[r.created_at,r.updated_at,r.deleted_at]),Promise.reject(new Error("INVALID STATE. deleted_at:"+r.deleted_at));return e[w]=e._id,r[S]=e._id,e._node=ee(e._node,i),e}):(t=Z(t),G(t).then(function(e){var r=e._node||{};return e[w]=e._id,r[S]=e._id,e._node=ee(r,i),e}))},ne=function(e){if(!e._id)return Promise.reject(new Error("._id is required!"));if(!e._node)return Promise.reject(new Error("._node is required!"));if(!e._current_time)return Promise.reject(new Error("._current_time is required!"));if(D)return e._node=e._node||{},Promise.resolve(e);var t=e._id,n=e._current_time;return l(p,"> prepared-id =",t,", current-time =",n),ye(e).then(function(e){var r=(e=Z(e))._node||{};if(e._force_create)m(p,"WARN! _force_create is set!");else if(!r.deleted_at)return s(p,"INVALID STATE FOR CREATED. ID=",t,", TIMES[CUD]=",[r.created_at,r.updated_at,r.deleted_at]),Promise.reject(new Error("INVALID STATE. deleted_at:"+r.deleted_at));return e._node=re(r,n),e})},ie=function(e){if(!e._id)return Promise.reject(new Error("._id is required!"));if(!e._node)return Promise.reject(new Error("._node is required!"));if(!e._current_time)return Promise.reject(new Error("._current_time is required!"));if(D)return e._node=e._node||{},Promise.resolve(e);e._id,e._node;var r=e._current_time;return ye(e).then(function(e){return(e=Z(e))._node=re(e._node,r),e})},oe=function(e){if(!e._id)return Promise.reject(new Error("._id is required!"));if(!e._node)return Promise.reject(new Error("._node is required!"));if(!e._current_time)return Promise.reject(new Error("._current_time is required!"));if(D)return e._node=e._node||{},Promise.resolve(e);e._id,e._node;var n=e._current_time;return 0===(e=Z(e))._fields_count?e:ye(e).then(function(e){var r,t;return e._node=(r=e._node,t=n,r.updated_at=t,r),e})},de=function(e){if(!e._id)return Promise.reject(new Error("._id is required!"));if(!e._node)return Promise.reject(new Error("._node is required!"));if(!e._current_time)return Promise.reject(new Error("._current_time is required!"));if(D)return e._node=e._node||{},Promise.resolve(e);e._id;var n=e._current_time;return ye(e).then(function(e){var r,t;return(e=Z(e))._node=(r=e._node,t=n,r.updated_at=t,r.deleted_at=t,r),e})},ue=function(r){var e;if(!r._id)return Promise.reject(new Error("._id is required!"));var t=r._id;l(p,"- dynamo: read("+t+")....");var n=j.startsWith("#")?"String":"";return u.do_get_item(N,(e={},_defineProperty(e,S,t),_defineProperty(e,"idType",n),e)).then(function(e){return l(p,"> dynamo: node("+t+") res=",f.json(e)),r._node=e,r})},ae=function(r){if(!r._id)return Promise.reject(new Error("._id is required!"));if(!r._node)return Promise.reject(new Error("._node is required!"));var t=r._id,e=r._node;l(p,"- dynamo: update("+t+")....");var n={},i=0,o=$?z($):null;for(var d in r)d&&r.hasOwnProperty(d)&&((d=""+d).startsWith("_")||d.startsWith("$")||0<=X.indexOf(d)||Q&&Q.indexOf(d)<0||d&&(n[d]=r[d],e[d]=r[d],i++,o&&C&&0<=C.indexOf(d)&&(e[d]=r[d]?o.encrypt(r[d]):"",n[d]=e[d])));return n.updated_at=e.updated_at,l(p,"> dynamo: updated["+t+"]["+i+"] =",f.json(n)),r._updated_node=null,(r._updated_count=i)?(void 0!==e[g]&&(e[g]=f.N(e[g],0)+1),u.do_update_item(N,_defineProperty({},S,t),n,g?_defineProperty({},g,1):null).then(function(e){return r._updated_node=n,r._node=Object.assign(r._node,n),l(p,"> dynamo: updated("+t+") res=",f.json(e)),r})):Q?r:Promise.reject(new Error("nothing to update"))},se=function(r){if(!r._id)return Promise.reject(new Error("._id is required!"));if(!r._node)return Promise.reject(new Error("._node is required!"));var t=r._id,e=r._node,n=r._current_mode||"",i=r._current_time;if(l(p,"- dynamo: save("+t+")...."),"prepare"!==n){var o=$?z($):null;for(var d in r)d&&r.hasOwnProperty(d)&&((d=""+d).startsWith("_")||d.startsWith("$")||0<=X.indexOf(d)||Q&&Q.indexOf(d)<0||(e[d]=r[d],o&&C&&0<=C.indexOf(d)&&(e[d]=r[d]?o.encrypt(r[d]):"")))}return void 0!==e[g]&&(e[g]=f.N(e[g],0)+1),l(p,"> save@node-id =",t,", current-time =",i,", node :=",f.json(e)),u.do_create_item(N,_defineProperty({},S,t),e).then(function(e){return l(p,"> dynamo: saved("+t+") res=",f.json(e)),r})},_e=function(r){if(!r._id)return Promise.reject(new Error("._id is required!"));if(!r._node)return Promise.reject(new Error("._node is required!"));var t=r._id,e=r._node;l(p,"- dynamo: increment("+t+")....");var n={},i=0;for(var o in r)r.hasOwnProperty(o)&&((o=""+o).startsWith("_")||o.startsWith("$")||0<=X.indexOf(o)||Q&&Q.indexOf(o)<0||o&&(n[o]=r[o],e[o]=f.N(e[o],0)+f.N(r[o]),i++));return n.updated_at=e.updated_at,l(p,"> dynamo: incremented["+t+"] :=",f.json(n)),r._updated_node=null,(r._updated_count=i)?(void 0!==e[g]&&(e[g]=f.N(e[g],0)+1),u.do_increment_item(N,_defineProperty({},S,t),n,g?_defineProperty({},g,1):null).then(function(e){return l(p,"> dynamo: increment("+t+") res=",f.json(e)),r._updated_node=n,r})):Q?r:Promise.reject(new Error("nothing to update"))},ce=function(r){var t=r._id;return t?(l(p,"- dynamo: delete("+t+")...."),u.do_delete_item(N,_defineProperty({},S,t)).then(function(e){return l(p,"> dynamo: deleted("+t+") res=",f.json(e)),r._node=e||{},r})):Promise.reject(new Error("._id is required!"))},fe={do_read_cache:function(r){var t=r._id;return t?b?b.startsWith("#")?D?ue(r).then(function(e){return void 0===(e._node||{})[S]?Promise.reject(new Error("404 NOT FOUND. "+N+".id:"+(e._id||""))):e}):he.do_read_search(r).catch(function(e){throw e instanceof Error&&(s(p,"! redis: read-search("+b+", "+t+") err :=",e.message||e),r._error=e),r}):(l(p,"- redis: get-item("+t+")...."),o.do_get_item(b,t).then(function(e){return e?(r._node=e,r):Promise.reject(r)}).catch(function(e){throw e instanceof Error&&(s(p,"! redis: get-item("+b+", "+t+") err :=",e.message||e),r._error=e),r})):Promise.reject(r):Promise.reject(new Error("._id is required!"))},do_save_cache:function(r){var e=r._id;if(!e)return Promise.reject(new Error("._id is required!"));if(!r._node)return Promise.reject(new Error("._node is required!"));if(!b)return Promise.resolve(r);if(b.startsWith("#"))return Promise.resolve(r);var t=r._node;l(p,"- redis: create-item("+e+")....");var n=fe.do_set_cache_footprint(e,t);return n=n.then(function(){return o.do_create_item(b,e,t)}).then(function(e){return r})},do_update_cache:function(r){var e=r._id;if(!e)return Promise.reject(new Error("._id is required!"));if(!r._node)return Promise.reject(new Error("._node is required!"));if(!b)return Promise.resolve(r);if(b.startsWith("#"))return Promise.resolve(r);var t=r._node;l(p,"- redis: update-item("+e+")....");var n=fe.do_set_cache_footprint(e,t);return n=n.then(function(){return o.do_update_item(b,e,t)}).then(function(e){return r})},do_delete_cache:function(r){var t=r._id;if(!t)return Promise.reject(new Error("._id is required!"));if(!b)return Promise.resolve(r);var e=b.startsWith("#")?b.substr(1):b;if(!e)return Promise.resolve(r);return Promise.all([e,e+"/UPDATED",e+"/HASH"].map(function(e){return o.do_delete_item(e,t).then(function(e){return e}).catch(function(e){return e.message||""+e})})).then(function(e){return l(p,"> redis: deleted("+t+") res=",f.json(e)),r})},do_set_cache_footprint:function(e,r){if(!e)return Promise.reject(new Error("id is required!"));if(!b)return Promise.resolve(0);r=r||{};var t=f.N(r.updated_at,0),n=f.hash(r);return o.do_create_item([b+"/UPDATED",b+"/HASH"],e,[t,n]).then(function(e){return e})},do_get_cache_updated:function(e){return e?b?b.startsWith("#")?Promise.resolve(-1):o.do_get_item(b+"/UPDATED",e).then(function(e){return e}):Promise.resolve(-1):Promise.reject(new Error("id is required!"))},do_get_cache_hash:function(e){return e?b?b.startsWith("#")?Promise.resolve(-1):o.do_get_item(b+"/HASH",e).then(function(e){return e}):Promise.resolve(-1):Promise.reject(new Error("id is required!"))}},he={do_read_search:function(r){var e=r._id;return e?x?(l(p,"- elasticsearch: read("+e+")...."),Y.do_get_item(x,W,e).then(function(e){return e?(r._node=U?f.extend(r._node||{},e):e,r):Promise.reject(r)})):r:Promise.reject(new Error("._id is required!"))},do_save_search:function(r){var t=r._id;if(!t)return Promise.reject(new Error("._id is required!"));if(!r._node)return Promise.reject(new Error("._node is required!"));if(!x)return r;var n=r._node,e=r._current_time||f.current_time_ms();if(U){var i=h.reduce(U,function(e,r){return void 0!==n[r]&&(e[r]=n[r]),e},{});return Object.keys(i).length?(void 0!==n.created_at&&(i.created_at=n.created_at),void 0!==n.updated_at&&(i.updated_at=n.updated_at),void 0!==n.deleted_at&&(i.deleted_at=n.deleted_at),l(p,"> elasticsearch:save("+L+"/"+t+").... node2=",f.json(i)),D?(i["@timestamp"]=e,i[S]=t,Y.do_push_item(x,W,i).then(function(e){return l(p,"! elasticsearch: pushed-item("+t+")@1 res=",f.json(e)),r})):L?Y.do_create_item(x,W,t,i).then(function(e){return l(p,"! elasticsearch: saved-item("+t+")@1 res=",f.json(e)),r}):Y.do_update_item(x,W,t,i).then(function(e){return l(p,"! elasticsearch: updated-item("+t+")@1 res=",f.json(e)),r})):(s(p,"! elasticsearch:WARN! nothing to update ("+t+")...."),r)}return Y.do_create_item(x,W,t,n).then(function(e){return l(p,"! elasticsearch: create-item("+t+")@3 res=",f.json(e)),r})},do_update_search:function(r){var t=r._id;if(!t)return Promise.reject(new Error("._id is required!"));if(!r._updated_node)return Promise.reject(new Error("._updated_node is required!"));if(!x)return r;var n=r._updated_node;if(U){var e=h.reduce(U,function(e,r){return e[r]=n[r],e},{});return Object.keys(e).length?(void 0!==n.created_at&&(e.created_at=n.created_at),void 0!==n.updated_at&&(e.updated_at=n.updated_at),void 0!==n.deleted_at&&(e.deleted_at=n.deleted_at),Y.do_update_item(x,W,t,e).then(function(e){return l(p,"! elasticsearch: updated-item("+t+") res=",f.json(e)),r})):(s(p,"! elasticsearch:WARN! nothing to update ("+t+")...."),r)}return Y.do_update_item(x,W,t,n).then(function(e){return l(p,"! elasticsearch: updated-item("+t+") res=",f.json(e)),r})},do_delete_search:function(r){var t=r._id;return t?x?U&&!L?(l(p,"! elasticsearch:WARN! ignore delete ("+t+")...."),r):Y.do_delete_item(x,W,t).then(function(e){return l(p,"! elasticsearch: deleted-item("+t+") res=",f.json(e)),r}).catch(function(e){return l(p,"ERR! ignore - elastic:delete("+t+") res=",e),r}):r:Promise.reject(new Error("._id is required!"))},do_search:function(i){if(!x)return i;if(U&&!L)return i;var o={$page:0,$limit:0};return o.$page=f.N(i.page,0),o.$limit=f.N(i.ipp,0===i.ipp?0:10),D||(o.deleted_at=void 0!==i.deleted_at?i.deleted_at:"0"),i.$source&&(o.$source=i.$source),i.$exist&&(o.$exist=i.$exist),i.Q&&(o.$Q=i.Q),i.A&&(o.$A=i.A),i.O&&(o.$O=i.O),i.H&&(o.$H=i.H),D&&(o.$O=o.$O||"!@timestamp"),o.$O=o.$O||(j.startsWith("#")?S+".keyword":S),U&&U.forEach(function(e){"page"!=e&&"ipp"!=e&&(void 0!==i[e]&&(o[e]=i[e]),void 0!==i["!"+e]&&(o["!"+e]=i["!"+e]),void 0!==i["#"+e]&&(o["#"+e]=i["#"+e]))}),l(p,"! elasticsearch: search["+x+"/"+W+"] =",f.json(o)),Y.do_search_item(x,W,o).then(function(e){var r=e&&e.hits||{},t=r.hits||[],n=r;return i.list=t.map(function(r){var t=r._score?f.extend({_score:r._score},r._source):r._source;return D&&(t["@id"]=r._id),null!=r.highlight&&Object.keys(r.highlight).forEach(function(e){t[e+"_highlight"]=r.highlight[e][0]}),t}),i.total=f.N(n.total||0),i.page=o.$page,i.ipp=o.$limit,i.took=e.took||0,void 0!==e.aggregations&&(i.aggregations=e.aggregations),i}).catch(function(e){throw s(p,"!ERR @search =",e),e})}},le={},me=function(e){var r=e._id||"";return[b,N,""+r].join(":").toUpperCase()},pe=function(e){if(D)return e;var r=me(e),t=e._node,n=e._current_time||f.current_time_ms();t||delete le[r];var i={cached_at:n,node:t};return le[r]=i,e},ve=function(e){var r=me(e);return delete le[r],e},Ee=function(n){var i=n._id;return Object.keys(n).forEach(function(t,e){if(n.hasOwnProperty(t)&&!(t.startsWith("_")||t.startsWith("$")||Q&&Q.indexOf(t)<0)){var r=n[t];if(r&&"object"==(void 0===r?"undefined":_typeof(r))){if(!Array.isArray(r))throw new Error("Invalid data-type (object) key:"+t+"@"+i);r.forEach(function(e,r){if(e&&"object"==(void 0===e?"undefined":_typeof(e)))throw new Error("Invalid data-type (object) key:"+t+"@"+i+":"+r)})}}}),n},ye=function(e){var r,t,n,i,o;return e._id?(t=me(r=e),n=le[t]||{},i=f.N(n.cached_at,0),o=(r._current_time||f.current_time_ms())-i,n.node&&i&&!(2e3<o)&&(r._node=Object.assign({},n.node),r.C=i,1)?Promise.resolve(e):Promise.resolve(e).then(fe.do_read_cache).catch(function(e){if(e&&e instanceof Error)throw e;return ue(e).then(function(e){return void 0===(e._node||{})[S]?Promise.reject(new Error("404 NOT FOUND. "+N+".id:"+(e._id||""))):e}).then(fe.do_save_cache).then(he.do_save_search)}).then(pe)):Promise.reject(new Error("._id is required!"))},Pe=function(e){if(!e)return e;if(!C||!C.length)return e;var n=$?z($):null;return n?C.reduce(function(e,r){var t=e[r];return void 0===t||(e[r]=t?n.decrypt(t):t),e},e):e},ge=function(e){return e._id?e._node?Promise.resolve(e).then(Ee).then(se).then(fe.do_save_cache).then(he.do_save_search).then(pe):Promise.reject(new Error("_node is required!")):Promise.reject(new Error("._id is required!"))},we=function(e){var r=e._id;return r?e._node?e._current_time?(l(p,"- my_clone_node ("+r+")...."),Promise.resolve(e).then(function(n){if(!I)return n;var i=void 0!==n[A]?f.N(n[A],0):r,o=r;return G({_id:0}).then(function(e){var r=e._id,t=n._node||{};return t[S]=r,A&&(t[A]=i),R&&(t[R]=o),A&&(n[A]=i),R&&(n[R]=o),n._clone_id=r,n._node=t,n})}).then(function(e){var r=e._id;return e._node?e._clone_id?(e._id=e._clone_id,h.reduce(e,function(e,r,t){return t&&(t.startsWith("_")||t.startsWith("$")||0<=X.indexOf(t)||void 0!==e[t]&&(e[t]=r)),e},e._node),l(p,">> before save-node().. that._node =",f.json(e._node)),ge(e).then(function(){return e._id=r,e})):Promise.reject(new Error("._clone_id is required!")):Promise.reject(new Error("._node is required!"))}).then(function(e){return l(p,">> cloned-node["+e._id+" -> "+e._clone_id+"] res=",f.json(e._node)),e})):Promise.reject(new Error("._current_time is required!")):Promise.reject(new Error("._node is required!")):Promise.reject(new Error("._id is required!"))},Se=function(e){return e._id?Promise.resolve(e).then(ce).then(fe.do_delete_cache).then(he.do_delete_search).then(ve).then(function(e){return l(p,">> deleted-node res=",f.json(e._node)),e}):Promise.reject(new Error("._id is required!"))},je=function(e){return Promise.resolve(e).then(he.do_search)},qe=function(e){if(!e)return e;if(!e._id)return Promise.reject(new Error("_id is required!"));var n=e._current_mode;return Promise.resolve(e).then(function(r){var e=!1;if("create"===n||"prepare"===n||"delete"===n||"destroy"===n?e=!0:"update"!==n&&"increment"!==n||(e=0<r._fields_count),e){var t=V+":event:"+n;return l(p,">>> notify event-id:",t,", notifiable=",e),Oe(t,r).then(function(e){return r})}return r})},Ne=function(r){if(!r.records)return Promise.reject(new Error("records is required!"));var e=r.records.slice(0);if(l(p,"- my_event_records().... records.len=",e.length),!e.length)return r;var t,n,i;return(t=e,n=be,i=f.promise(t.shift()),i=t.reduce(function(e,r){return e.then(function(){return n(r)})},i.then(function(e){return n(e)}))).catch(function(e){return s(p,"error ignored! =",e),r}).then(function(){return r})},be=function(e){if(!e)return Promise.reject(new Error("record is required"));if(!e.dynamodb&&!e.Sns)return Promise.reject(new Error("record.dynamodb|Sns is required"));var i=e.eventName||"EVENT",r=null;if(e.dynamodb){var o=e.table||e.eventSourceARN&&e.eventSourceARN.split("/")[1]||"";if(l(p,"--- process-record("+o+") ... "),N!==o)return l(p,"! ignore record-table: "+N+" != "+o+" "),e;var t=e.dynamodb.Keys?B.toJavascript(e.dynamodb.Keys):{},d=e.dynamodb.NewImage?B.toJavascript(e.dynamodb.NewImage):null,n=e.dynamodb.OldImage?B.toJavascript(e.dynamodb.OldImage):null,u=t[S],a="MODIFY"===i?f.diff(n,d):null,s=f.N(d&&d.updated_at||0),_=a?h.reduce(a,function(e,r){return e[r]=n[r],e},{}):null,c={_id:u,_node:d,_updated_at:s,_diff:a,_prev:_};switch(r=Promise.resolve(c),a&&l(p,">> "+o+".different["+u+"]=",f.json(a)),i){case"INSERT":case"MODIFY":r=r.then(function(t){var n=t._id;return D?t:fe.do_get_cache_updated(n).then(function(e){if(m(p,">> "+o+".updated_at["+n+"] res=",e," <- ",t._updated_at,t._updated_at!==e?"*":""),!e||t._updated_at>=e){var r=f.hash(d);return fe.do_get_cache_hash(n).then(function(e){return e&&e===r?(l(p,"!WARN! ignored due to hash-value matching =",e),t):(-1!==e&&l(p,"! INFO! node was updated. hash :=",r,"<-",e),fe.do_save_cache(t).then(he.do_save_search))})}return l(p,"! ignored due to old-record"),t})});break;case"REMOVE":l(p,">> removed!"),r=(r=r.then(fe.do_delete_cache)).then(he.do_delete_search)}}else if(e.Sns){l(p,">> event-SNS =",e.Sns);r=Promise.resolve(e.Sns)}return r?r.then(function(r){var e={INSERT:"create",MODIFY:"update",REMOVE:"delete",EVENT:"event"}[i],t=!!e;if(r._current_mode=e,t){var n=V+":record:"+e;return l(p,">>> notify event-id:",n,", notifiable=",t),Oe(n,r).then(function(e){return r})}return r}).then(function(){return e}):Promise.reject(new Error("invalid chain!"))},Oe=function(e,r){return H.do_notify(e,r)},Ie=function(r){var e=[];if(N){var t=j.startsWith("#")?"S":"N";e.push(Promise.resolve("DynamoDb").then(function(e){return l(p,"# initialize ",e),u.do_create_table(N,S,t).then(function(e){return{result:e.TableDescription.TableName===N,name:"dynamo:"+N}})}).catch(function(e){var r=e.message||""+e;return s(p,"> create-table error=",e),"ResourceInUseException"===e.code?{result:!1,name:"dynamo:"+N,code:e.code}:{result:!1,name:"dynamo:"+N,error:r}}))}else l(p,"DS: WARN! ignored configuration. DYNA_TABLE=",N);if(j&&!j.startsWith("#")?e.push(Promise.resolve("MySQL").then(function(e){return l(p,"# initialize MySQL (Sequence) "),i.do_create_id_seq(j,q).then(function(e){return l(p,"> create-id-seq res=",e),{result:!0,name:"sequence"}})}).catch(function(e){var r=e.message||""+e;return s(p,"> create-id-seq error=",e),"ER_TABLE_EXISTS_ERROR"===e.code?{result:!1,name:"MySQL",code:e.code}:{result:!1,name:"MySQL",error:r}})):j&&j.startsWith("#")&&1<j.length&&0<q?e.push(Promise.resolve("MySQL").then(function(e){l(p,"# initialize MySQL (Sequence) ");var r=j.substring(1);return i.do_create_id_seq(r,q).then(function(e){return l(p,"> create-id-seq["+r+"] res=",e),{result:!0,name:"MySQL"}})}).catch(function(e){var r=e.message||""+e;return s(p,"> create-id-seq error=",e),"ER_TABLE_EXISTS_ERROR"===e.code?{result:!1,name:"MySQL",code:e.code}:{result:!1,name:"MySQL",error:r}})):l(p,"MS: WARN! ignored configuration. ID_TYPE=",j),x&&U){var n={template:x,mappings:{_default_:{dynamic_templates:[{string_fields:{match:"*_multi",match_mapping_type:"string",mapping:{type:"multi_field",fields:{"{name}":{type:6<=M?"text":"string",index:"analyzed",omit_norms:!0,index_options:"docs"},"{name}.raw":{type:6<=M?"text":"string",index:"not_analyzed",ignore_above:256}}}}}],_source:{enabled:6<=M},properties:{"@version":{type:6<=M?"text":"string",index:!(6<=M)&&"not_analyzed"},title:{type:6<=M?"text":"string"},name:{type:6<=M?"text":"string"},created_at:{type:"date",format:"strict_date_optional_time||epoch_millis"},updated_at:{type:"date",format:"strict_date_optional_time||epoch_millis"},deleted_at:{type:"date",format:"strict_date_optional_time||epoch_millis"}}}}};if(6<=M||(n.mappings._default_.all={enabled:!0}),S&&j.startsWith("#")&&(n.mappings._default_.properties[S]={type:6<=M?"text":"string",fields:{keyword:{type:"keyword",ignore_above:256}}}),D)n.settings={index:{refresh_interval:"5s"}},n.mappings._default_.properties["@timestamp"]={type:"date",doc_values:!0},n.mappings._default_.properties.ip={type:"ip"},"@version,title,created_at,updated_at,deleted_at".split(",").map(function(e){return delete n.mappings._default_.properties[e]});e.push(Promise.resolve("ElasticSearch").then(function(e){return l(p,"# initialize ElasticSearch. ES_TYPE=",W),Y.do_create_index_type(x,W,n).then(function(e){return l(p,"> create-es-index res=",e),{result:!0,name:"elasticsearch:"+x,settings:n}}).catch(function(e){var r=e.message||e.reason||""+e;return s(p,"> create-es-index error=",e),"index_already_exists_exception"===e.type?{result:!0,name:"elasticsearch:"+x,warn:e.type}:{result:!1,name:"elasticsearch:"+x,error:r}})}))}else l(p,"MS: WARN! ignored configuration. ES_TYPE=",W);return Promise.all(e).then(function(e){return l(p,">> results=",e),r.results=e,r})},Re=function(r){var e=[];if(N&&(l(p,"# terminate DynamoDB"),e.push(u.do_delete_table(N).then(function(e){e.TableDescription.TableName;return{result:!0,name:"dynamo:"+N}}).catch(function(e){var r=e.message||""+e;return s(p,"> delete-table error=",e),"ResourceNotFoundException"===e.code?{result:!0,name:"dynamo:"+N,code:e.code}:{result:!1,name:"dynamo:"+N,error:r}}))),j&&!j.startsWith("#"))l(p,"# terminate MySQL (Sequence) "),e.push(i.do_delete_id_seq(j).then(function(e){return l(p,"> delete-id-seq res=",e),{result:!0,name:"MySQL:"+j}}).catch(function(e){var r=e.message||""+e;return s(p,"> delete-id-seq error=",e),"ER_BAD_TABLE_ERROR"===e.code?{result:!0,name:"MySQL:"+j,code:e.code}:{result:!1,name:"MySQL:"+j,error:r}}));else if(j&&j.startsWith("#")&&1<j.length&&0<q){l(p,"# terminate MySQL (Sequence) ");var t=j.substring(1);e.push(i.do_delete_id_seq(t).then(function(e){return l(p,"> delete-id-seq["+t+"] res=",e),{result:!0,name:"MySQL:"+t}}).catch(function(e){var r=e.message||""+e;return s(p,"> delete-id-seq error=",e),"ER_BAD_TABLE_ERROR"===e.code?{result:!0,name:"MySQL:"+t,code:e.code}:{result:!1,name:"MySQL:"+t,error:r}}))}else l(p,"# ignored MySQL (Sequence) ");return x?(l(p,"# terminate ES (Index) "),e.push(Y.do_delete_index_type(x,null).then(function(e){return l(p,"> delete-es-index res=",e),{result:!0,name:"elasticsearch:"+x}}).catch(function(e){var r=e.message||e.reason||""+e;return s(p,"> delete-es-index error=",e),{result:!1,name:"elasticsearch:"+x,error:r}}))):l(p,"# ignored ES (Index) "),Promise.all(e).then(function(e){return l(p,">> results=",e),r.results=e,r})},Ae=function(e){var r={a:1,b:2,x:3},t={x:3,a:1,b:2},n={b:2,x:3,a:1};r.name="hi",t.name="hi",n.name="hi",l(p,"# node1 =",f.json(r)),l(p,"> node2 =",f.json(t)),l(p,"> node3 =",f.json(n)),l(p,"# node1.sorted =",f.json(r,!0)),l(p,"> node2.sorted =",f.json(t,!0)),l(p,"> node3.sorted =",f.json(n,!0)),l(p,"# hash1 =",f.hash(1)),l(p,"> node1 =",f.hash(r)),l(p,"> node2 =",f.hash(t)),l(p,"> node3 =",f.hash(n));var i={updated_at:234,name:"test hash"};return Promise.resolve(i).then(function(e){return o.do_create_item("H#",1,e)}).then(function(){return o.do_get_item("H#",1).then(function(e){return l(p,"> read-back data=",e),e})}).then(function(){return fe.do_set_cache_footprint(1,i)}).then(function(){return fe.do_get_cache_updated(1).then(function(e){return l(p,"> updated-at value=",void 0===e?"undefined":_typeof(e),":",e),e})}).then(function(){return fe.do_get_cache_hash(1).then(function(e){return l(p,"> hash-value value=",void 0===e?"undefined":_typeof(e),":",e),e})})},Te=function(r){return l(p,"- my_test_self()...."),Promise.resolve(r).then(Ae).then(function(e){return e||r})};return _.do_prepare_chain=function(e,r,t,n){return J(e,r,t,n)},_.do_finish_chain=function(e,r,t,n){return K(e)},_.do_prepare=function(e,r){return J(e,r,"prepare").then(te).then(ge).then(qe).then(K)},_.do_create=function(t,n){return J(t,n,"create").then(ne).catch(function(e){s(p,"ERR! prepare_node_created =",e instanceof Error,e.message||e);var r=e&&e.message||"";if(e instanceof Error&&0<=r.indexOf("404 NOT FOUND"))return m(p,"WARN! AUTO TRY TO PREPARE NODE. ID="+t),J(t,n,"create").then(function(e){var r=e._current_time;return e=Z(e),l(p,">> prepared old-node=",f.json(e._node)),e._node=re(e._node,r),e});throw e}).then(ge).then(qe).then(K)},_.do_saveES=function(e,r){return e?r?J(e,{},"save").then(Ee).then(function(e){return e._node=r,e}).then(he.do_save_search).then(K):Promise.reject(new Error("node is required!")):Promise.reject(new Error("id is required!"))},_.do_cleanRedis=function(e,r){return e?J(e,{},"clean").then(function(e){return e._node=r,e}).then(fe.do_delete_cache).then(K):Promise.reject(new Error("id is required!"))},_.do_clone=function(e,r){return J(e,r,"clone").then(ie).then(we).then(qe).then(K)},_.do_read=function(e,r){return J(e,r,"read").then(Z).then(function(e){return 0!==e._params_count&&0===e._fields_count?e:ye(e)}).then(K)},_.do_readX=function(e,r){return J(e,r,"read").then(Z).then(function(e){return 0!==e._params_count&&0===e._fields_count?e:ye(e)}).then(K).then(Pe)},_.do_update=function(e,r){return J(e,r,"update").then(oe).then(function(e){return 0===e._fields_count?e:(n=(t=e)._id)?0===t._fields_count?(l(p,"! my_update_node() no need to update... fields_count="+t._fields_count),t):Promise.resolve(t).then(Ee).then(ae).then(function(e){return e._updated_node?fe.do_save_cache(e):e}).then(function(e){return e._updated_node?he.do_save_search(e):e}).then(function(e){return e._updated_node?pe(e):e}).then(function(e){return l(p,">> updated-node["+n+"] res=",f.json(e._updated_node)),e}).catch(function(e){var r=e&&e.message||"";if(s(p,">> updated-node["+n+"] err=",r),0<r.indexOf("an attribute that does not exist in the item"))return ge(t);throw e}):Promise.reject(new Error("._id is required!"));var t,n}).then(qe).then(K)},_.do_increment=function(e,r){return J(e,r,"increment").then(oe).then(function(e){return 0===e._fields_count?e:(t=(r=e)._id)?0===r._fields_count?(l(p,"! my_increment_node() no need to increment... fields_count="+r._fields_count),r):Promise.resolve(r).then(Ee).then(_e).then(function(e){return e._updated_node?fe.do_save_cache(e):e}).then(function(e){return e._updated_node?he.do_save_search(e):e}).then(function(e){return e._updated_node?pe(e):e}).then(function(e){return l(p,">> increment-node["+t+"] res=",f.json(e._updated_node)),e}):Promise.reject(new Error("._id is required!"));var r,t}).then(qe).then(K)},_.do_delete=function(e,r){return J(e,r,"delete").then(de).then(ge).then(qe).then(K)},_.do_destroy=function(e,r){return J(e,r,"destroy").then(Se).then(qe).then(K)},_.do_search=function(e,r){return J(e,r,"search").then(je).then(K)},_.on_records=function(e,r){return J(e,r,"on_records").then(Ne).then(K)},_.do_initialize=function(e,r){return J(e,r,"initialize").then(Ie).then(K)},_.do_terminate=function(e,r){return J(e,r,"terminate").then(Re).then(K)},_.do_test_self=function(e,r){return J(e,r,"self-test").then(Te).then(K)},_.do_next_id=function(){return G({_id:0}).then(function(e){return e._id})},_};

lib/utilities.js

@@ -1,1 +0,1 @@
-"use strict";var _typeof="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e};module.exports=function(n){var i={},u=y("util"),s=n._;if(!s)throw new Error("$_ is required!");i.name=u+"-utils",i.ts=l,i.dt=m,i.now=m,i.escape=function(e,r){if(void 0===e)return"NULL";if(t=e,"number"==typeof t&&t%1==0)return e;var t;"object"==(void 0===(e=e||"")?"undefined":_typeof(e))&&(e=JSON.stringify(e));e=e.replace(/\\/g,"\\\\").replace(/\$/g,"\\$").replace(/'/g,"\\'").replace(/"/g,'\\"'),r&&(e=decodeURI(e));return"'"+e+"'"},i.cleanup=function(e){return Object.keys(e).reduce(function(e,r){return r.startsWith("_")&&delete e[r],r.startsWith("$")&&delete e[r],e},e)},i.updated=function(t,n){return Object.keys(n).reduce(function(e,r){if(t[r]!==n[r]){if(null===t[r]&&""===n[r])return e;e[r]=n[r]}return e},{})},i.copy=function(t){return Object.keys(t).reduce(function(e,r){return e[r]=t[r],e},{})},i.N=_,i.F=v,i.current_time_ms=function(){var e=(new Date).getTime();return e+=0},i.NS=y,i.env=r,i.extend=d,i.isset=function(e){return void 0!==e},i.empty=function(e){return!e},i.min=function(e,r){return e<r?e:r},i.max=function(e,r){return r<e?e:r},i.round=function(e){return Math.round(e)},i.json=p,i.diff=function(n,i){return Object.keys(n).reduce(function(e,r){if(i.hasOwnProperty(r)){if(s.isEqual(n[r],i[r])){var t=e.indexOf(r);e.splice(t,1)}}else e.push(r);return e},Object.keys(i))},i.copy_node=function(t,n){return n=void 0!==n&&n,Object.keys(t).reduce(function(e,r){return r.startsWith("_")||r.startsWith("$")||(e[r]=n?null:t[r]),e},{})},i.bare_node=function(e,r){var t={};t._id=e._id,t._current_time=e._current_time,r&&(t=d(t,r));return t},i.diff_node=function(n,i){var r=[],t=[];return Object.keys(n).forEach(function(e){e.startsWith("_")||e.startsWith("$")||r.push(e)}),Object.keys(i).forEach(function(e){e.startsWith("_")||e.startsWith("$")||t.push(e)}),r.reduce(function(e,r){if(i.hasOwnProperty(r)){if(s.isEqual(n[r],i[r])){var t=e.indexOf(r);e.splice(t,1)}}else e.push(r);return e},t)},i.hash=function(e){return function(e,r,t){var n,i=void 0,o=void 0===t?2166136261:t;for(i=0,n=e.length;i<n;i++)o^=e.charCodeAt(i),o+=(o<<1)+(o<<4)+(o<<7)+(o<<8)+(o<<24);return r?("0000000"+(o>>>0).toString(16)).substr(-8):o>>>0}(e="string"!=typeof(e="object"===(void 0===(e=e||"")?"undefined":_typeof(e))?p(e,!0):e)?String(e):e)},i.md5=function(e,r){var t=require("crypto");return r=void 0===r?"hex":r,t.createHash("md5").update(e).digest(r)},i.hmac=function(e,r,t,n){var i=require("crypto");return r=r||"XENI",n=n||"base64",t=t||"sha256",i.createHmac(t,r).update(e).digest(n)},i.qs_parse=function(e){var r=require("query-string").parse(e);return Object.keys(r).forEach(function(e){null===r[e]?r[e]="":/^[1-9][0-9]*$/.test(r[e])&&(r[e]=_(r[e]))}),r},i.qs_stringify=function(e){return require("query-string").stringify(e)},i.logger_factory=t,i.load_data_csv=function(e){if(!e)throw new Error("param:name is required!");var r=require("fs"),i=require("csv-parse"),o=require("path").resolve(__dirname,"../data/"+e+(e.endsWith(".csv")?"":".csv"));return new Promise(function(t,n){r.readFile(o,"UTF-8",function(e,r){if(e)return n(e);i(r,{columns:!0,trim:!0},function(e,r){return e?n(e):t(r)})})})},i.load_data_yml=function(e){if(!e)throw new Error("param:name is required!");var t=require("fs"),r=require("path"),n=require("js-yaml"),i=r.resolve(__dirname,"../data/"+e+(e.endsWith(".yml")?"":".yml"));return o(u,"load file =",i),new Promise(function(e,r){try{e(n.safeLoad(t.readFileSync(i,"utf8")))}catch(e){r(e)}})},i.promise=h,i.promise_sequence=function(e,t){var r=h(e.shift());return r=e.reduce(function(e,r){return e.then(function(){return t(r)})},r.then(function(e){return t(e)}))},i.trans_row_to_prod_node=function(e){if(!e)return null;if(Array.isArray(e))throw new Error("row is array.");return b().transform_row(e)},i.trans_prod_node_to_row=function(e){if(!e)return null;if("object"!=(void 0===e?"undefined":_typeof(e)))throw new Error("node must be object. but is "+(void 0===e?"undefined":_typeof(e)));return b().transform_node(e)},i.split_prod_node_to_aid=function(e,r,t,n){if(!e)return null;if("object"!=(void 0===e?"undefined":_typeof(e)))throw new Error("node must be object. but is "+(void 0===e?"undefined":_typeof(e)));if("object"!=(void 0===r?"undefined":_typeof(r)))throw new Error("atem must be object. but is "+(void 0===r?"undefined":_typeof(r)));if("object"!=(void 0===t?"undefined":_typeof(t)))throw new Error("item must be object. but is "+(void 0===t?"undefined":_typeof(t)));if("object"!=(void 0===n?"undefined":_typeof(n)))throw new Error("deal must be object. but is "+(void 0===n?"undefined":_typeof(n)));return b().split_node(e,r,t,n)},i.merge_prod_node_by_aid=function(e,r,t,n){if(!e)return null;if("object"!=(void 0===e?"undefined":_typeof(e)))throw new Error("node must be object. but is "+(void 0===e?"undefined":_typeof(e)));if("object"!=(void 0===r?"undefined":_typeof(r)))throw new Error("atem must be object. but is "+(void 0===r?"undefined":_typeof(r)));if("object"!=(void 0===t?"undefined":_typeof(t)))throw new Error("item must be object. but is "+(void 0===t?"undefined":_typeof(t)));if("object"!=(void 0===n?"undefined":_typeof(n)))throw new Error("deal must be object. but is "+(void 0===n?"undefined":_typeof(n)));return b().merge_node(e,r,t,n)};var o=o||n.log||function(){return c(arguments,"I")},f=f||n.err||function(){return c(arguments,"E")},e=e||function(){var e=r("ENV")||r("NODE_ENV")||r("STAGE");return"production"!==e&&"op"!==e};function r(e,r){if("function"==typeof n.get_env)return n.get_env(e,r);if("function"==typeof n.environ)return n.environ(e,r);var t=process&&process.env[e]||void 0;return void 0===t?r:t}function t(){return{create:function(e,r){e=e||u,r=r||"/var/www/html/logs/";var t=require("log4js"),n=r+e+".log";return t.loadAppender("file"),t.addAppender(t.appenders.file(n),e),t.getLogger(e)}}}i.log=o,i.err=f,i.is_dev=e();var a=null,c=function(e,r){return a?"E"==r?a.error.apply(a,e):a.info.apply(a,e):"undefined"!=typeof console&&(Array.isArray(e)||(e=Array.prototype.slice.call(e)),r&&e.unshift(r),e.unshift(l()),"E"==r?console.error.apply(console,e):console.log.apply(console,e)),!0};function d(e,r){for(var t in r)e[t]=r[t];return e}function p(r,e){if(e){var t={};Object.keys(r).sort().forEach(function(e){t[e]=r[e]}),r=t}return r&&JSON.stringify(r)||r}function l(e){var r=e&&"object"===(void 0===e?"undefined":_typeof(e))?e:e?new Date(e):new Date,t=r.getFullYear(),n=r.getMonth()+1,i=(e=r.getDate(),r.getHours()),o=r.getMinutes(),u=r.getSeconds();return(t<10?"0":"")+t+"-"+(n<10?"0":"")+n+"-"+(e<10?"0":"")+e+" "+(i<10?"0":"")+i+":"+(o<10?"0":"")+o+":"+(u<10?"0":"")+u}function m(e){var r=(e=e||l()).split(" "),t=r[0].split("-"),n=r[1].split(":"),i=parseInt(t[0]),o=parseInt(t[1])-1,u=parseInt(t[2]),a=parseInt(n[0]),s=parseInt(n[1]),f=parseInt(n[2]);return Date.prototype.add_seconds||(Date.prototype.add_seconds=function(e){return this.setSeconds(this.getSeconds()+e),this}),Date.prototype.ts||(Date.prototype.ts=function(){return l(this)}),new Date(i,o,u,a,s,f,0)}function y(e,r,t){if(!e)return e;t=t||4,t-=e.length;if(e="           ".substr(0,t=t<0?0:t)+e+":",i.is_dev&&r){e={red:"",green:"",yellow:"",blue:"",magenta:"",cyan:"",white:""}[r]+e+""}return e}function _(r,t){try{return""===r||null==r?t:"number"==typeof r&&r%1==0?r:"number"==typeof r?parseInt(r):(r=(r="0"+r).startsWith("0-")?r.substr(1):r,parseInt(r.replace(/,/gi,"").trim()))}catch(e){return f("err at _N: x="+r+";"+(void 0===r?"undefined":_typeof(r))+";"+(e.message||""),e),t}}function v(r,t){try{return""===r||null==r?t:"number"==typeof r&&r%1==0?r:"number"==typeof r?parseFloat(r):(r=(r="0"+r).startsWith("0-")?r.substr(1):r,parseFloat(r.replace(/,/gi,"").trim()))}catch(e){return f("err at _N: x="+r+";"+(void 0===r?"undefined":_typeof(r))+";"+(e.message||""),e),t}}function h(t){return new Promise(function(e,r){e(t)})}function b(){var e="_trans_handler_prod",a=i[e];return a||(o(u,"build transformer of prod!"),(a={initialize:function(){var e=function(r){if(!r)throw new Error("param:name is required!");var e=require("fs"),t=require("path"),n=require("js-yaml"),i=t.resolve(__dirname,"../data/"+r+(r.endsWith(".yml")?"":".yml"));try{return o(u,"load-sync-file =",i),n.safeLoad(e.readFileSync(i,"utf8"))}catch(e){f(u,"error:load-sync-yaml("+r+")=",e)}return{}}("prod-fields"),r=e&&e.fields;if(!r)throw new Error(u+"valid fields definition is required!");var t={parser:{},serial:{},splits:{}};t=s.reduce(r,function(e,r,o){var t=function(e,r){if("object"===(void 0===r?"undefined":_typeof(r)))e=s.reduce(r,function(e,t,r){if("X"==r){var n={atem:null,item:null,deal:null};if(t)(Array.isArray(t)?t:t.split(",")).forEach(function(e){if((e=e.trim()).startsWith("."))n.atem=e.substring(1),n.item=e.substring(1),n.deal=e.substring(1);else if(e.endsWith("."))n[e.substring(0,e.length-1)]=o;else if(e.indexOf(".")){var r=e.split(".",2);n[r[0]]=r[1]}else f(u,"WARN!! NO ALIAS SUPPORT name:"+t)});return e.splits[o]=n,e}var i=a.parser[r];return i||f(u,"ERROR! invalid type:"+r+", name:"+t),t&&i&&(e.parser[t]={name:o,trans:i},e.serial[o]||(e.serial[o]={name:t,trans:a.serial[r]})),e},e);else{var t=a.parser.S;e.parser[r]={name:o,trans:t},e.serial[o]||(e.serial[o]={name:r,trans:a.serial.S})}return e};return e=Array.isArray(r)?s.reduce(r,function(e,r){return e=t(e,r)},e):t(e,r)},t),a._map=t},transform_row:function(e){var r={};return r=s.reduce(e,function(e,r,t){var n=a._map.parser[t];return n||f(u,"ERROR! invalid parser by key:"+t),n&&(e[n.name]=n.trans(r)),e},r)},transform_node:function(e){var r={};return r=s.reduce(e,function(e,r,t){var n=a._map.serial[t];return n||f(u,"ERROR! invalid serial by name:"+t),n&&(e[n.name]=n.trans(r)),e},r)},split_node:function(e,i,o,u){var r={};return r=s.reduce(e,function(e,r,t){if(t.startsWith("_")||t.startsWith("$"))return e;var n=a._map.splits[t];return n?(n.atem&&(i[n.atem]=r),n.item&&(o[n.item]=r),n.deal&&(u[n.deal]=r)):i[t]=r,e},r)},merge_node:function(e,i,o,u){i=i||{},o=o||{},u=u||{};var r={};return d(e,r=s.reduce(e,function(e,r,t){if(t.startsWith("_")||t.startsWith("$"))return e;var n=a._map.splits[t];return n?(n.item&&(e[t]=o[n.item]),n.atem&&(e[t]=i[n.atem]),n.deal&&(e[t]=u[n.deal])):void 0!==i[t]&&(e[t]=i[t]),e},r)),r},parser:{I:function(e){return parseInt(_(e,0))},N:function(e){return _(e,0)},F:function(e){return v(e,0)},F1:function(e){return Math.round(10*v(e,0))/10},F2:function(e){return Math.round(100*v(e,0))/100},F3:function(e){return Math.round(1e3*v(e,0))/1e3},U:function(e){throw new Error("not implemented!")},O:function(e){throw new Error("not implemented!")},A:function(e){return e?(e||"").split(","):[]},AI:function(e){return e?(e||"").split(",").map(function(e){return _(e,0)}):[]},AN:function(e){return e?(e||"").split(",").map(function(e){return _(e,0)}):[]},M:function(e){return JSON.parse(e)},S:function(e){return"string"==typeof e?e.trim():""+e},B:function(e){return"Y"===(e=(e||"").toUpperCase())||"T"===e||"1"===e||"true"===e}},serial:{I:function(e){return e},N:function(e){return e},F:function(e){return e},F1:function(e){return _(Math.round(10*e))/10},F2:function(e){return _(Math.round(100*e))/100},F3:function(e){return _(Math.round(1e3*e))/1e3},U:function(e){throw new Error("not implemented!")},O:function(e){throw new Error("not implemented!")},A:function(e){return(e||[]).join(",")},AI:function(e){return(e||[]).join(",")},AN:function(e){return(e||[]).join(",")},M:function(e){return p(e)},S:function(e){return""+e},B:function(e){return e?"Y":"N"}}}).initialize(),i[e]=a)}return i};
+"use strict";var _typeof="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(e){return typeof e}:function(e){return e&&"function"==typeof Symbol&&e.constructor===Symbol&&e!==Symbol.prototype?"symbol":typeof e};module.exports=function(n){var i={},u=y("util"),s=n._;if(!s)throw new Error("$_(lodash) is required!");i.name=u+"-utils",i.ts=l,i.dt=m,i.now=m,i.escape=function(e,r){if(void 0===e)return"NULL";if(t=e,"number"==typeof t&&t%1==0)return e;var t;"object"==(void 0===(e=e||"")?"undefined":_typeof(e))&&(e=JSON.stringify(e));e=e.replace(/\\/g,"\\\\").replace(/\$/g,"\\$").replace(/'/g,"\\'").replace(/"/g,'\\"'),r&&(e=decodeURI(e));return"'"+e+"'"},i.cleanup=function(e){return Object.keys(e).reduce(function(e,r){return r.startsWith("_")&&delete e[r],r.startsWith("$")&&delete e[r],e},e)},i.updated=function(t,n){return Object.keys(n).reduce(function(e,r){if(t[r]!==n[r]){if(null===t[r]&&""===n[r])return e;e[r]=n[r]}return e},{})},i.copy=function(t){return Object.keys(t).reduce(function(e,r){return e[r]=t[r],e},{})},i.N=_,i.F=v,i.current_time_ms=function(){var e=(new Date).getTime();return e+=0},i.NS=y,i.env=r,i.extend=d,i.isset=function(e){return void 0!==e},i.empty=function(e){return!e},i.min=function(e,r){return e<r?e:r},i.max=function(e,r){return r<e?e:r},i.round=function(e){return Math.round(e)},i.json=p,i.diff=function(n,i){return Object.keys(n).reduce(function(e,r){if(i.hasOwnProperty(r)){if(s.isEqual(n[r],i[r])){var t=e.indexOf(r);e.splice(t,1)}}else e.push(r);return e},Object.keys(i))},i.copy_node=function(t,n){return n=void 0!==n&&n,Object.keys(t).reduce(function(e,r){return r.startsWith("_")||r.startsWith("$")||(e[r]=n?null:t[r]),e},{})},i.bare_node=function(e,r){var t={};t._id=e._id,t._current_time=e._current_time,r&&(t=d(t,r));return t},i.diff_node=function(n,i){var r=[],t=[];return Object.keys(n).forEach(function(e){e.startsWith("_")||e.startsWith("$")||r.push(e)}),Object.keys(i).forEach(function(e){e.startsWith("_")||e.startsWith("$")||t.push(e)}),r.reduce(function(e,r){if(i.hasOwnProperty(r)){if(s.isEqual(n[r],i[r])){var t=e.indexOf(r);e.splice(t,1)}}else e.push(r);return e},t)},i.hash=function(e){return function(e,r,t){var n,i=void 0,o=void 0===t?2166136261:t;for(i=0,n=e.length;i<n;i++)o^=e.charCodeAt(i),o+=(o<<1)+(o<<4)+(o<<7)+(o<<8)+(o<<24);return r?("0000000"+(o>>>0).toString(16)).substr(-8):o>>>0}(e="string"!=typeof(e="object"===(void 0===(e=e||"")?"undefined":_typeof(e))?p(e,!0):e)?String(e):e)},i.md5=function(e,r){var t=require("crypto");return r=void 0===r?"hex":r,t.createHash("md5").update(e).digest(r)},i.hmac=function(e,r,t,n){var i=require("crypto");return r=r||"XENI",n=n||"base64",t=t||"sha256",i.createHmac(t,r).update(e).digest(n)},i.qs_parse=function(e){var r=require("query-string").parse(e);return Object.keys(r).forEach(function(e){null===r[e]?r[e]="":/^[1-9][0-9]*$/.test(r[e])&&(r[e]=_(r[e]))}),r},i.qs_stringify=function(e){return require("query-string").stringify(e)},i.logger_factory=t,i.load_data_csv=function(e){if(!e)throw new Error("param:name is required!");var r=require("fs"),i=require("csv-parse"),o=require("path").resolve(__dirname,"../data/"+e+(e.endsWith(".csv")?"":".csv"));return new Promise(function(t,n){r.readFile(o,"UTF-8",function(e,r){if(e)return n(e);i(r,{columns:!0,trim:!0},function(e,r){return e?n(e):t(r)})})})},i.load_data_yml=function(e){if(!e)throw new Error("param:name is required!");var t=require("fs"),r=require("path"),n=require("js-yaml"),i=r.resolve(__dirname,"../data/"+e+(e.endsWith(".yml")?"":".yml"));return o(u,"load file =",i),new Promise(function(e,r){try{e(n.safeLoad(t.readFileSync(i,"utf8")))}catch(e){r(e)}})},i.promise=h,i.promise_sequence=function(e,t){var r=h(e.shift());return r=e.reduce(function(e,r){return e.then(function(){return t(r)})},r.then(function(e){return t(e)}))},i.trans_row_to_prod_node=function(e){if(!e)return null;if(Array.isArray(e))throw new Error("row is array.");return b().transform_row(e)},i.trans_prod_node_to_row=function(e){if(!e)return null;if("object"!=(void 0===e?"undefined":_typeof(e)))throw new Error("node must be object. but is "+(void 0===e?"undefined":_typeof(e)));return b().transform_node(e)},i.split_prod_node_to_aid=function(e,r,t,n){if(!e)return null;if("object"!=(void 0===e?"undefined":_typeof(e)))throw new Error("node must be object. but is "+(void 0===e?"undefined":_typeof(e)));if("object"!=(void 0===r?"undefined":_typeof(r)))throw new Error("atem must be object. but is "+(void 0===r?"undefined":_typeof(r)));if("object"!=(void 0===t?"undefined":_typeof(t)))throw new Error("item must be object. but is "+(void 0===t?"undefined":_typeof(t)));if("object"!=(void 0===n?"undefined":_typeof(n)))throw new Error("deal must be object. but is "+(void 0===n?"undefined":_typeof(n)));return b().split_node(e,r,t,n)},i.merge_prod_node_by_aid=function(e,r,t,n){if(!e)return null;if("object"!=(void 0===e?"undefined":_typeof(e)))throw new Error("node must be object. but is "+(void 0===e?"undefined":_typeof(e)));if("object"!=(void 0===r?"undefined":_typeof(r)))throw new Error("atem must be object. but is "+(void 0===r?"undefined":_typeof(r)));if("object"!=(void 0===t?"undefined":_typeof(t)))throw new Error("item must be object. but is "+(void 0===t?"undefined":_typeof(t)));if("object"!=(void 0===n?"undefined":_typeof(n)))throw new Error("deal must be object. but is "+(void 0===n?"undefined":_typeof(n)));return b().merge_node(e,r,t,n)};var o=o||n.log||function(){return c(arguments,"I")},f=f||n.err||function(){return c(arguments,"E")},e=e||function(){var e=r("ENV")||r("NODE_ENV")||r("STAGE");return"production"!==e&&"op"!==e};function r(e,r){if("function"==typeof n.get_env)return n.get_env(e,r);if("function"==typeof n.environ)return n.environ(e,r);var t=process&&process.env[e]||void 0;return void 0===t?r:t}function t(){return{create:function(e,r){e=e||u,r=r||"/var/www/html/logs/";var t=require("log4js"),n=r+e+".log";return t.loadAppender("file"),t.addAppender(t.appenders.file(n),e),t.getLogger(e)}}}i.log=o,i.err=f,i.is_dev=e();var a=null,c=function(e,r){return a?"E"==r?a.error.apply(a,e):a.info.apply(a,e):"undefined"!=typeof console&&(Array.isArray(e)||(e=Array.prototype.slice.call(e)),r&&e.unshift(r),e.unshift(l()),"E"==r?console.error.apply(console,e):console.log.apply(console,e)),!0};function d(e,r){for(var t in r)e[t]=r[t];return e}function p(r,e){if(e){var t={};Object.keys(r).sort().forEach(function(e){t[e]=r[e]}),r=t}return r&&JSON.stringify(r)||r}function l(e){var r=e&&"object"===(void 0===e?"undefined":_typeof(e))?e:e?new Date(e):new Date,t=r.getFullYear(),n=r.getMonth()+1,i=(e=r.getDate(),r.getHours()),o=r.getMinutes(),u=r.getSeconds();return(t<10?"0":"")+t+"-"+(n<10?"0":"")+n+"-"+(e<10?"0":"")+e+" "+(i<10?"0":"")+i+":"+(o<10?"0":"")+o+":"+(u<10?"0":"")+u}function m(e){var r=(e=e||l()).split(" "),t=r[0].split("-"),n=r[1].split(":"),i=parseInt(t[0]),o=parseInt(t[1])-1,u=parseInt(t[2]),a=parseInt(n[0]),s=parseInt(n[1]),f=parseInt(n[2]);return Date.prototype.add_seconds||(Date.prototype.add_seconds=function(e){return this.setSeconds(this.getSeconds()+e),this}),Date.prototype.ts||(Date.prototype.ts=function(){return l(this)}),new Date(i,o,u,a,s,f,0)}function y(e,r,t){if(!e)return e;t=t||4,t-=e.length;if(e="           ".substr(0,t=t<0?0:t)+e+":",i.is_dev&&r){e={red:"",green:"",yellow:"",blue:"",magenta:"",cyan:"",white:""}[r]+e+""}return e}function _(r,t){try{return""===r||null==r?t:"number"==typeof r&&r%1==0?r:"number"==typeof r?parseInt(r):(r=(r="0"+r).startsWith("0-")?r.substr(1):r,parseInt(r.replace(/,/gi,"").trim()))}catch(e){return f("err at _N: x="+r+";"+(void 0===r?"undefined":_typeof(r))+";"+(e.message||""),e),t}}function v(r,t){try{return""===r||null==r?t:"number"==typeof r&&r%1==0?r:"number"==typeof r?parseFloat(r):(r=(r="0"+r).startsWith("0-")?r.substr(1):r,parseFloat(r.replace(/,/gi,"").trim()))}catch(e){return f("err at _N: x="+r+";"+(void 0===r?"undefined":_typeof(r))+";"+(e.message||""),e),t}}function h(t){return new Promise(function(e,r){e(t)})}function b(){var e="_trans_handler_prod",a=i[e];return a||(o(u,"build transformer of prod!"),(a={initialize:function(){var e=function(r){if(!r)throw new Error("param:name is required!");var e=require("fs"),t=require("path"),n=require("js-yaml"),i=t.resolve(__dirname,"../data/"+r+(r.endsWith(".yml")?"":".yml"));try{return o(u,"load-sync-file =",i),n.safeLoad(e.readFileSync(i,"utf8"))}catch(e){f(u,"error:load-sync-yaml("+r+")=",e)}return{}}("prod-fields"),r=e&&e.fields;if(!r)throw new Error(u+"valid fields definition is required!");var t={parser:{},serial:{},splits:{}};t=s.reduce(r,function(e,r,o){var t=function(e,r){if("object"===(void 0===r?"undefined":_typeof(r)))e=s.reduce(r,function(e,t,r){if("X"==r){var n={atem:null,item:null,deal:null};if(t)(Array.isArray(t)?t:t.split(",")).forEach(function(e){if((e=e.trim()).startsWith("."))n.atem=e.substring(1),n.item=e.substring(1),n.deal=e.substring(1);else if(e.endsWith("."))n[e.substring(0,e.length-1)]=o;else if(e.indexOf(".")){var r=e.split(".",2);n[r[0]]=r[1]}else f(u,"WARN!! NO ALIAS SUPPORT name:"+t)});return e.splits[o]=n,e}var i=a.parser[r];return i||f(u,"ERROR! invalid type:"+r+", name:"+t),t&&i&&(e.parser[t]={name:o,trans:i},e.serial[o]||(e.serial[o]={name:t,trans:a.serial[r]})),e},e);else{var t=a.parser.S;e.parser[r]={name:o,trans:t},e.serial[o]||(e.serial[o]={name:r,trans:a.serial.S})}return e};return e=Array.isArray(r)?s.reduce(r,function(e,r){return e=t(e,r)},e):t(e,r)},t),a._map=t},transform_row:function(e){var r={};return r=s.reduce(e,function(e,r,t){var n=a._map.parser[t];return n||f(u,"ERROR! invalid parser by key:"+t),n&&(e[n.name]=n.trans(r)),e},r)},transform_node:function(e){var r={};return r=s.reduce(e,function(e,r,t){var n=a._map.serial[t];return n||f(u,"ERROR! invalid serial by name:"+t),n&&(e[n.name]=n.trans(r)),e},r)},split_node:function(e,i,o,u){var r={};return r=s.reduce(e,function(e,r,t){if(t.startsWith("_")||t.startsWith("$"))return e;var n=a._map.splits[t];return n?(n.atem&&(i[n.atem]=r),n.item&&(o[n.item]=r),n.deal&&(u[n.deal]=r)):i[t]=r,e},r)},merge_node:function(e,i,o,u){i=i||{},o=o||{},u=u||{};var r={};return d(e,r=s.reduce(e,function(e,r,t){if(t.startsWith("_")||t.startsWith("$"))return e;var n=a._map.splits[t];return n?(n.item&&(e[t]=o[n.item]),n.atem&&(e[t]=i[n.atem]),n.deal&&(e[t]=u[n.deal])):void 0!==i[t]&&(e[t]=i[t]),e},r)),r},parser:{I:function(e){return parseInt(_(e,0))},N:function(e){return _(e,0)},F:function(e){return v(e,0)},F1:function(e){return Math.round(10*v(e,0))/10},F2:function(e){return Math.round(100*v(e,0))/100},F3:function(e){return Math.round(1e3*v(e,0))/1e3},U:function(e){throw new Error("not implemented!")},O:function(e){throw new Error("not implemented!")},A:function(e){return e?(e||"").split(","):[]},AI:function(e){return e?(e||"").split(",").map(function(e){return _(e,0)}):[]},AN:function(e){return e?(e||"").split(",").map(function(e){return _(e,0)}):[]},M:function(e){return JSON.parse(e)},S:function(e){return"string"==typeof e?e.trim():""+e},B:function(e){return"Y"===(e=(e||"").toUpperCase())||"T"===e||"1"===e||"true"===e}},serial:{I:function(e){return e},N:function(e){return e},F:function(e){return e},F1:function(e){return _(Math.round(10*e))/10},F2:function(e){return _(Math.round(100*e))/100},F3:function(e){return _(Math.round(1e3*e))/1e3},U:function(e){throw new Error("not implemented!")},O:function(e){throw new Error("not implemented!")},A:function(e){return(e||[]).join(",")},AI:function(e){return(e||[]).join(",")},AN:function(e){return(e||[]).join(",")},M:function(e){return p(e)},S:function(e){return""+e},B:function(e){return e?"Y":"N"}}}).initialize(),i[e]=a)}return i};

package.json

 {
   "name": "lemoncloud-engine-js",
-  "version": "1.0.21",
+  "version": "1.0.22",
   "description": "lemoncloud.io - Lemon Engine Modle of Node for Robust Micro-service based on DynamoDB + ElastiCache + Elasticsearch.",
@@ -5,0 +5,0 @@ "main": "index.js",

README.md

@@ -89,2 +89,3 @@ # lemoncloud-engine-js
 |--         |--
+| 1.0.22    | improve log
 | 1.0.21    | `environ.TS` for time-stamp.
@@ -91,0 +92,0 @@ | 1.0.20    | add $exist for elasticsearch to check existing field

New alerts

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

118126

increased by0.06%

Number of lines in readme file

143

increased by0.7%

Worsened metrics

Number of medium supply chain risk alerts

2

increased by100%

No dependency changes