lemoncloud-engine-js - npm Package Compare versions

Comparing version 0.3.21 to 0.3.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};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,m=e._,i=e.MS,d=e.DS,o=e.RS,u=e.ES,_=e.ES6;if(!f)throw new Error("$U is required!");if(!m)throw new Error("$U is required!");if(!i)throw new Error("$MS is required!");if(!d)throw new Error("$DS is required!");if(!o)throw new Error("$RS is required!");var h=e.log,a=e.inf,l=e.err,p=f.NS(n,"green"),s=t||{},c=function(e){throw new Error("NOT_IMPLEMENTED - "+p+":"+JSON.stringify(e))};s.do_prepare=c,s.do_create=c,s.do_clone=c,s.do_update=c,s.do_increment=c,s.do_read=c,s.do_delete=c,s.do_destroy=c,s.do_search=c,s.do_initialize=c,s.do_terminate=c,s.do_test_self=c,s.on_records=c,s.do_notify=c,s.do_subscribe=c,s.do_next_id=c,r.startsWith("_")||e(r,s);var v=function(e,r){return void 0===s[e]?r:s[e]},E=v("VERSION",1),y=v("REVISION",1),P=v("VERSION_NAME","V"),w=v("REVISION_NAME","R"),j=v("ID_INPUT","id"),g=v("ID_NAME","id"),S=v("ID_TYPE","test"),N=v("ID_NEXT",0),q=v("DYNA_TABLE","TestTable"),R=v("REDIS_PKEY","TPKEY"),O=v("FIELDS",null),b=v("DEFAULTS",null),T=v("CLONEABLE",!1),A=v("CLONED_ID","cloned"),x=v("PARENT_ID","parent"),D=v("PARENT_IMUT",!0),I=v("ES_INDEX","test-v1"),W=v("ES_TYPE","test"),M=v("ES_FIELDS",["updated_at","name"]),L=v("ES_MASTER",0),$=v("ES_VERSION",5),U=5<$?_:u;if(!U)throw new Error("$ES is required! Ver:"+$);var V=v("NS_NAME",""),k=require("dynamodb-value"),F=require("./notify-service")(e,"!"+V,{NS_NAME:V});s.do_notify=F.do_notify,s.do_subscribe=F.do_subscribe,T&&O&&(x&&O.indexOf(x)<0&&O.push(x),A&&O.indexOf(A)<0&&O.push(A));var Y=[j,g,"created_at","updated_at","deleted_at",A];D&&x&&Y.push(x);var z=function(e,r,t,n){t=t||"","object"===(void 0===(e=e||0)?"undefined":_typeof(e))?r=r?f.extend(e,r):e:(r=null==r?{}:"object"!==(void 0===r?"undefined":_typeof(r))||r instanceof Promise?{params:r}:f.copy(r),r=f.extend(r,{_id:e}));var i=r;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(p+"method-stack full. size:"+i._method_stack):f.promise(i);e=S.startsWith("#")?i._id||i[j]||"":f.N(i._id||i[j]||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=m.reduce(i,function(e,r,t){return t.startsWith("_")||t.startsWith("$")||0<=Y.indexOf(t)||e._params_count++,e},i)),f.promise(i)},B=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=m.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=O?O.reduce(function(e,r){return void 0!==e[r]&&void 0!==t[r]&&(e[r]=t[r]),e},e):e),e},Q=function(r){var e=r._id;if(h(p,"- my_prepare_id("+S+", "+e+")...."),S.startsWith("#")){if(S&&S.startsWith("#")&&1<S.length&&0<N){var t=S.substring(1);return i.do_get_next_id(t).then(function(e){return h(p,"> created next-id["+t+"]=",e),r._id=e,r})}}else if(S&&!e)return i.do_get_next_id(S).then(function(e){return h(p,"> created next-id=",e),r._id=e,r});return h(p,"> prepared-id =",e),Promise.resolve(r)},H=function(t){if(!t._current_mode)throw new Error(p+"_current_mode is required!");var n=t._current_mode,i=b||{},o=0,e=t._node||{};return O?"prepare"===n||"create"===n||"clone"===n?e=O.reduce(function(e,r){return r===g||r===P||r===w||("prepare"===n?(void 0!==i[r]?e[r]=b[r]:void 0!==t[r]&&(e[r]=t[r]),P&&(e[P]=E),w&&(e[w]=0)):("create"===n&&w&&(e[w]=y-1),void 0!==t[r]&&(e[r]=t[r])),o++),e},e):"update"!==n&&"increment"!==n&&"read"!==n||(e=O.reduce(function(e,r){return r===g||void 0!==t[r]&&o++,e},e)):o=-1,t._fields_count=o,t._node=e,t},C=function(e,r){return e.created_at=0,e.updated_at=r,e.deleted_at=r,e},J=function(e,r){return e.created_at=r,e.updated_at=r,e.deleted_at=0,e},K=function(t){if(!t._node)return Promise.reject(new Error(p+"_node is required!"));if(!t._current_time)return Promise.reject(new Error(p+"_current_time is required!"));var n=t._id,i=(t._node,t._current_time);return n?se(t).catch(function(e){var r=e&&e.message||"";if(!(0<=r.indexOf("404 NOT FOUND")))throw e;return l(p,"not found. err=",r),t}).then(function(e){var r=(e=H(e))._node||{};if(e._force_create)l(p,"WARN! _force_create is set!");else if(!r.deleted_at)return l(p,"INVALID STATE FOR PREPARED. ID=",n,", TIMES[CUD]=",[r.created_at,r.updated_at,r.deleted_at]),Promise.reject(new Error(p+"INVALID STATE."));return e[j]=e._id,r[g]=e._id,e._node=C(e._node,i),e}):(t=H(t),Q(t).then(function(e){var r=e._node||{};return e[j]=e._id,r[g]=e._id,e._node=C(r,i),e}))},X=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));if(!e._current_time)return Promise.reject(new Error(p+"_current_time is required!"));var t=e._id,n=(e._node,e._current_time);return h(p,"> prepared-id =",t,", current-time =",n),se(e).then(function(e){var r=(e=H(e))._node||{};if(e._force_create)l(p,"WARN! _force_create is set!");else if(!r.deleted_at)return l(p,"INVALID STATE FOR CREATED. ID=",t,", TIMES[CUD]=",[r.created_at,r.updated_at,r.deleted_at]),Promise.reject(new Error(p+"INVALID STATE."));return e._node=J(e._node,n),e})},G=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));if(!e._current_time)return Promise.reject(new Error(p+"_current_time is required!"));var r=e._id,t=e._node,n=e._current_time;return h(p,"> cloned-id =",r,", current-time =",n,", node =",f.json(t)),se(e).then(function(e){return h(p,">> get-item-node old=",f.json(e._node)),(e=H(e))._node=J(e._node,n),e})},Z=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));if(!e._current_time)return Promise.reject(new Error(p+"_current_time is required!"));e._id,e._node;var n=e._current_time;return 0===(e=H(e))._fields_count?e:se(e).then(function(e){var r,t;return e._node=(r=e._node,t=n,r.updated_at=t,r),e})},ee=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));if(!e._current_time)return Promise.reject(new Error(p+"_current_time is required!"));var r=e._id,t=e._node,n=e._current_time;return h(p,"> deleted-id =",r,", current-time =",n,", node =",f.json(t)),se(e).then(function(e){var r,t;return h(p,">> get-item-node old=",f.json(e._node)),(e=H(e))._node=(r=e._node,t=n,r.updated_at=t,r.deleted_at=t,r),e})},re=function(r){var e;if(!r._id)return Promise.reject(new Error(p+"_id is required!"));var t=r._id;h(p,"- dynamo:my_read_node ("+t+")....");var n=S.startsWith("#")?"String":"";return d.do_get_item(q,(e={},_defineProperty(e,g,t),_defineProperty(e,"idType",n),e)).then(function(e){return h(p,"> dynamo:get-item-node("+t+") res=",f.json(e)),r._node=e,r})},te=function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!r._node)return Promise.reject(new Error(p+"_node is required!"));var t=r._id,e=r._node,n={},i=0;for(var o in r)r.hasOwnProperty(o)&&(o=""+o)&&(o.startsWith("_")||o.startsWith("$")||0<=Y.indexOf(o)||O&&O.indexOf(o)<0||o&&(n[o]=r[o],e[o]=r[o],i++));return n.updated_at=e.updated_at,r._updated_node=null,(r._updated_count=i)?(void 0!==e[w]&&(e[w]=f.N(e[w],0)+1),d.do_update_item(q,_defineProperty({},g,t),n,w?_defineProperty({},w,1):null).then(function(e){return r._updated_node=n,h(p,"> dynamo:updated-item("+t+") res=",f.json(e)),r})):O?r:Promise.reject(new Error(p+"nothing to update"))},ne=function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!r._node)return Promise.reject(new Error(p+"_node is required!"));var t=r._id,e=r._node,n=r._current_mode||"",i=r._current_time;if(h(p,"- dynamo:my_save_node("+t+")...."),h(p,"> dynamo:node-id =",t,", current-time =",i,", node =",f.json(e)),"prepare"!==n)for(var o in r)r.hasOwnProperty(o)&&(o=""+o)&&(o.startsWith("_")||o.startsWith("$")||0<=Y.indexOf(o)||O&&O.indexOf(o)<0||(e[o]=r[o]));return void 0!==e[w]&&(e[w]=f.N(e[w],0)+1),d.do_create_item(q,_defineProperty({},g,t),e).then(function(e){return h(p,"> dynamo:saved-item("+t+") res=",e),r})},ie=function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!r._node)return Promise.reject(new Error(p+"_node is required!"));var t=r._id,e=r._node,n={},i=0;for(var o in r)r.hasOwnProperty(o)&&((o=""+o).startsWith("_")||o.startsWith("$")||0<=Y.indexOf(o)||O&&O.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,h(p,"> dynamo:increment-node =",n),r._updated_node=null,(r._updated_count=i)?(void 0!==e[w]&&(e[w]=f.N(e[w],0)+1),d.do_increment_item(q,_defineProperty({},g,t),n,w?_defineProperty({},w,1):null).then(function(e){return h(p,"> dynamo:updated-item("+t+") res=",f.json(e)),r._updated_node=n,r})):O?r:Promise.reject(new Error(p+"nothing to update"))},oe=function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));var t=r._id;return d.do_delete_item(q,_defineProperty({},g,t)).then(function(e){return h(p,"> dynamo:deleted-item-node("+t+") res=",f.json(e)),r._node=e||{},r})},de={my_read_node:function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!R)return Promise.reject(r);var t=r._id;return o.do_get_item(R,t).then(function(e){return e?(r._node=e,r):Promise.reject(r)}).catch(function(e){throw e instanceof Error&&(l(p,"! redis:get-item("+R+", "+t+") err =",e.message||e),r._error=e),r})},my_save_node:function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!r._node)return Promise.reject(new Error(p+"_node is required!"));if(!R)return Promise.resolve(r);var t=r._id,e=r._node;h(p,"- redis:my_save_node("+R+":"+t+"). node.updated_at=",e&&e.updated_at||0);var n=de.my_set_node_footprint(t,e);return n=n.then(function(){return o.do_create_item(R,t,e)}).then(function(e){return h(p,"> redis:save-item-node("+t+") res=",f.json(e)),r})},my_update_node:function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!r._node)return Promise.reject(new Error(p+"_node is required!"));if(!R)return Promise.resolve(r);var t=r._id,e=r._node,n=de.my_set_node_footprint(t,e);return n=n.then(function(){return o.do_update_item(R,t,e)}).then(function(e){return h(p,"> redis:update-item-node("+t+") res=",f.json(e)),r})},my_delete_node:function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!R)return Promise.resolve(r);var t=r._id;return o.do_delete_item(R,t).then(function(e){return h(p,"> redis:delete-item-node("+t+") res=",f.json(e)),r})},my_set_node_footprint:function(r,e){if(!r)return Promise.reject(new Error(p+"id is required!"));if(!R)return Promise.resolve(0);e=e||{};var t=f.N(e.updated_at,0),n=f.hash(e);return o.do_create_item([R+"/UPDATED",R+"/HASH"],r,[t,n]).then(function(e){return h(p,"> redis:set node-footprint("+r+") res=",f.json(e)),e})},my_get_updated_at:function(e){return e?R?o.do_get_item(R+"/UPDATED",e).then(function(e){return e}):Promise.resolve(-1):Promise.reject(new Error(p+"id is required!"))},my_get_hash_value:function(e){return e?R?o.do_get_item(R+"/HASH",e).then(function(e){return e}):Promise.resolve(-1):Promise.reject(new Error(p+"id is required!"))}},ue=function(r){if(!r._id)return Promise.reject(new Error(p+"elasticsearch:_id is required!"));if(!r._node)return Promise.reject(new Error(p+"elasticsearch:_node is required!"));if(!I||!W)return r;var t=r._id,n=r._node;if(M){var e=m.reduce(M,function(e,r){return void 0!==n[r]&&(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),L?U.do_create_item(I,W,t,e).then(function(e){return h(p,"! elasticsearch:saved-item("+t+") res=",f.json(e)),r}):U.do_update_item(I,W,t,e).then(function(e){return h(p,"! elasticsearch:updated-item("+t+") res=",f.json(e)),r})):(h(p,"! elasticsearch:WARN! nothing to update ("+t+")...."),r)}return U.do_create_item(I,W,t,n).then(function(e){return h(p,"! elasticsearch:saved-item2("+t+") res=",f.json(e)),r})},_e=function(r){if(!r._id)return Promise.reject(new Error(p+"elasticsearch:_id is required!"));if(!I||!W)return r;var t=r._id;return M&&!L?(h(p,"! elasticsearch:WARN! ignore delete ("+t+")...."),r):U.do_delete_item(I,W,t).then(function(e){return h(p,"! elasticsearch:deleted-item("+t+") res=",f.json(e)),r})},ae=function(i){if(!I||!W)return i;if(h(p,"- elasticsearch:do_search_item()...."),M&&!L)return h(p,"! elasticsearch:WARN! ignore search ()...."),i;var o={$page:0,$limit:0};return o.$page=f.N(i.page||0),o.$limit=f.N(0===i.ipp?0:i.ipp||10),o.deleted_at="0",i.$source&&(o.$source=i.$source),i.Q&&(o.$Q=i.Q),i.A&&(o.$A=i.A),i.O&&(o.$O=i.O),o.$O=o.$O||(S.startsWith("#")?"id.keyword":"id"),M&&M.forEach(function(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])}),U.do_search_item(I,W,o).then(function(e){var r=e&&e.hits||{},t=r.hits||[],n=r;return i.list=t.map(function(e){return f.extend({_score:e._score},e._source)}),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 l(p,"!ERR =",e),e})},se=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));e._id;return Promise.resolve(e).then(de.my_read_node).catch(function(e){return re(e).then(function(e){return void 0===(e._node||{})[g]?Promise.reject(new Error(p+"404 NOT FOUND. "+q+".id:"+(e._id||""))):e}).then(de.my_save_node)})},ce=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));e._id;return Promise.resolve(e).then(ne).then(de.my_save_node).then(ue).then(function(e){return e})},fe=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));if(!e._current_time)return Promise.reject(new Error(p+"_current_time is required!"));var r=e._id;return h(p,"- my_clone_node ("+r+")...."),Promise.resolve(e).then(function(n){if(!T)return n;var e=n._id,i=void 0!==n[x]?f.N(n[x],0):e,o=e;return Q({_id:0}).then(function(e){var r=e._id,t=n._node||{};return t[g]=r,x&&(t[x]=i),A&&(t[A]=o),x&&(n[x]=i),A&&(n[A]=o),n._clone_id=r,n._node=t,n})}).then(function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));if(!e._clone_id)return Promise.reject(new Error(p+"_clone_id is required!"));var r=e._id;return e._id=e._clone_id,m.reduce(e,function(e,r,t){return t&&(t.startsWith("_")||t.startsWith("$")||0<=Y.indexOf(t)||void 0!==e[t]&&(e[t]=r)),e},e._node),h(p,">> before save-node().. that._node =",f.json(e._node)),ce(e).then(function(){return e._id=r,e})}).then(function(e){return h(p,">> cloned-node["+e._id+" -> "+e._clone_id+"] res=",f.json(e._node)),e})},me=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));var r=e._id;return h(p,"- my_delete_node ("+r+")...."),Promise.resolve(e).then(oe).then(de.my_delete_node).then(_e).then(function(e){return h(p,">> deleted-node res=",f.json(e._node)),e})},he=function(e){return h(p,"- my_search_node ()...."),Promise.resolve(e).then(ae).then(function(e){return e})},le=function(e){if(!e)return e;if(!e._id)return Promise.reject(new Error(p+"_id is required!"));e._id;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 h(p,">>> notify event-id:",t,", notifiable=",e),Ee(t,r).then(function(e){return r})}return r})},pe=function(r){if(!r.records)return Promise.reject(new Error(p+"records is required!"));var e=r.records.slice(0);if(h(p,"- my_event_records().... records.len=",e.length),!e.length)return r;var t,n,i;return(t=e,n=ve,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 l(p,"error ignored! =",e),r}).then(function(){return r})},ve=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(h(p,"--- process-record("+o+") ... "),q!==o)return h(p,"! ignore record-table: "+q+" != "+o+" "),e;var t=e.dynamodb.Keys?k.toJavascript(e.dynamodb.Keys):{},d=e.dynamodb.NewImage?k.toJavascript(e.dynamodb.NewImage):null,n=e.dynamodb.OldImage?k.toJavascript(e.dynamodb.OldImage):null,u=t[g],_="MODIFY"===i?f.diff(n,d):null,a=f.N(d&&d.updated_at||0),s=_?m.reduce(_,function(e,r){return e[r]=n[r],e},{}):null,c={_id:u,_node:d,_updated_at:a,_diff:_,_prev:s};switch(r=Promise.resolve(c),_&&h(p,">> "+o+".different["+u+"]=",f.json(_)),i){case"INSERT":case"MODIFY":r=r.then(function(t){var n=t._id;return de.my_get_updated_at(n).then(function(e){if(l(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 de.my_get_hash_value(n).then(function(e){return e&&e===r?(h(p,"! WARN! ignored due to hash-value matching =",e),t):(h(p,"! INFO! node was updated. hash :=",r,"<-",e),de.my_save_node(t).then(ue))})}return h(p,"! ignored due to old-record"),t})});break;case"REMOVE":h(p,">> removed!"),r=(r=r.then(de.my_delete_node)).then(_e)}}else e.Sns&&(h(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 h(p,">>> notify event-id:",n,", notifiable=",t),Ee(n,r).then(function(e){return r})}return r}).then(function(){return e}):Promise.reject(new Error("invalid chain!"))},Ee=function(e,r){return F.do_notify(e,r)},ye=function(r){var e=[];if(q){var t=S.startsWith("#")?"S":"N";e.push(Promise.resolve("DynamoDb").then(function(e){return h(p,"# initialize ",e),d.do_create_table(q,g,t).then(function(e){return e.TableDescription.TableName===q})}).catch(function(e){if("ResourceInUseException"===e.code)return!1;throw e}))}else h(p,"DS: WARN! ignored configuration. DYNA_TABLE=",q);if(S&&!S.startsWith("#")?e.push(Promise.resolve("MySQL").then(function(e){return h(p,"# initialize MySQL (Sequence) "),i.do_create_id_seq(S,N).then(function(e){return h(p,"> create-id-seq res=",e),!0})}).catch(function(e){if("ER_TABLE_EXISTS_ERROR"===e.code)return!1;throw e})):S&&S.startsWith("#")&&1<S.length&&0<N?e.push(Promise.resolve("MySQL").then(function(e){h(p,"# initialize MySQL (Sequence) ");var r=S.substring(1);return i.do_create_id_seq(r,N).then(function(e){return h(p,"> create-id-seq["+r+"] res=",e),!0})}).catch(function(e){if("ER_TABLE_EXISTS_ERROR"===e.code)return!1;throw e})):h(p,"MS: WARN! ignored configuration. ID_TYPE=",S),I&&W&&M){var n={mappings:{_default_:{dynamic_templates:[{string_fields:{match:"*_multi",match_mapping_type:"string",mapping:{type:"multi_field",fields:{"{name}":{type:6<=$?"text":"string",index:"analyzed",omit_norms:!0,index_options:"docs"},"{name}.raw":{type:6<=$?"text":"string",index:"not_analyzed",ignore_above:256}}}}}],properties:{"@version":{type:6<=$?"text":"string",index:!(6<=$)&&"not_analyzed"},title:{type:6<=$?"text":"string"},name:{type:6<=$?"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"}}}}};6<=$||(n.mappings._default_.all={enabled:!0}),e.push(Promise.resolve("ElasticSearch").then(function(e){return h(p,"# initialize ElasticSearch (Type) ",W),U.do_create_index_type(I,W,n).then(function(e){return h(p,"> create-es-index res=",e),!0})}).catch(function(e){if(l(p,"> create-es-index error=",e),"index_already_exists_exception"===e.type)return!0;throw e}).then(function(e){return e}))}else h(p,"MS: WARN! ignored configuration. ES_TYPE=",W);return Promise.all(e).then(function(e){return h(p,">> results=",e),r._result=e,r})},Pe=function(r){var e=[];if(q&&(h(p,"# terminate DynamoDB"),e.push(d.do_delete_table(q).then(function(e){return e.TableDescription.TableName===q}).catch(function(e){if("ResourceNotFoundException"===e.code)return!0;throw e}))),S&&!S.startsWith("#"))h(p,"# terminate MySQL (Sequence) "),e.push(i.do_delete_id_seq(S).then(function(e){return h(p,"> delete-id-seq res=",e),!0}).catch(function(e){if("ER_BAD_TABLE_ERROR"===e.code)return!0;throw e}));else if(S&&S.startsWith("#")&&1<S.length&&0<N){h(p,"# terminate MySQL (Sequence) ");var t=S.substring(1);e.push(i.do_delete_id_seq(t).then(function(e){return h(p,"> delete-id-seq["+t+"] res=",e),!0}).catch(function(e){if("ER_BAD_TABLE_ERROR"===e.code)return!0;throw e}))}else h(p,"# ignored MySQL (Sequence) ");return I&&W?(h(p,"# terminate ES (Index) "),e.push(U.do_delete_index_type(I,null).then(function(e){return h(p,"> delete-es-index res=",e),!0}).catch(function(e){throw l(p,"> create-es-index error=",e),e}))):h(p,"# ignored ES (Index) "),Promise.all(e).then(function(e){return h(p,">> results=",e),r._result=e,r})},we=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",h(p,"# node1 =",f.json(r)),h(p,"> node2 =",f.json(t)),h(p,"> node3 =",f.json(n)),h(p,"# node1.sorted =",f.json(r,!0)),h(p,"> node2.sorted =",f.json(t,!0)),h(p,"> node3.sorted =",f.json(n,!0)),h(p,"# hash1 =",f.hash(1)),h(p,"> node1 =",f.hash(r)),h(p,"> node2 =",f.hash(t)),h(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 h(p,"> read-back data=",e),e})}).then(function(){return de.my_set_node_footprint(1,i)}).then(function(){return de.my_get_updated_at(1).then(function(e){return h(p,"> updated-at value=",void 0===e?"undefined":_typeof(e),":",e),e})}).then(function(){return de.my_get_hash_value(1).then(function(e){return h(p,"> hash-value value=",void 0===e?"undefined":_typeof(e),":",e),e})})},je=function(r){return h(p,"- my_test_self()...."),Promise.resolve(r).then(we).then(function(e){return e||r})};return s.do_prepare_chain=function(e,r,t,n){return z(e,r,t,n)},s.do_finish_chain=function(e,r,t,n){return B(e)},s.do_prepare=function(e,r){return z(e,r,"prepare").then(K).then(ce).then(le).then(B)},s.do_create=function(t,n){return z(t,n,"create").then(X).catch(function(e){l(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 a(p,"WARN! AUTO TRY TO PREPARE NODE. ID="+t),z(t,n,"create").then(function(e){var r=e._current_time;return e=H(e),h(p,">> prepared old-node=",f.json(e._node)),e._node=J(e._node,r),e});throw e}).then(ce).then(le).then(B)},s.do_clone=function(e,r){return z(e,r,"clone").then(G).then(fe).then(le).then(B)},s.do_read=function(e,r){return z(e,r,"read").then(H).then(function(e){return 0!==e._params_count&&0===e._fields_count?e:se(e)}).then(le).then(B)},s.do_update=function(e,r){return z(e,r,"update").then(Z).then(function(e){return 0===e._fields_count?e:function(t){if(!t._id)return Promise.reject(new Error(p+"_id is required!"));var e=t._id;return h(p,"- my_update_node ("+e+")...."),0===t._fields_count?(h(p,"! my_update_node() no need to update... fields_count="+t._fields_count),t):Promise.resolve(t).then(te).then(function(e){return e._updated_node?de.my_save_node(e):e}).then(function(e){return e._updated_node?ue(e):e}).then(function(e){return h(p,">> updated-node res=",f.json(e._updated_node)),e}).catch(function(e){var r=e&&e.message||"";if(l(p,">> updated-node err=",r),0<r.indexOf("an attribute that does not exist in the item"))return ce(t);throw e})}(e)}).then(le).then(B)},s.do_increment=function(e,r){return z(e,r,"increment").then(Z).then(function(e){return 0===e._fields_count?e:function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));var r=e._id;return h(p,"- my_increment_node ("+r+")...."),0===e._fields_count?(h(p,"! my_increment_node() no need to increment... fields_count="+e._fields_count),e):Promise.resolve(e).then(ie).then(function(e){return e._updated_node?de.my_save_node(e):e}).then(function(e){return e._updated_node?ue(e):e}).then(function(e){return h(p,">> increment-node res=",f.json(e._updated_node)),e})}(e)}).then(le).then(B)},s.do_delete=function(e,r){return z(e,r,"delete").then(ee).then(ce).then(le).then(B)},s.do_destroy=function(e,r){return z(e,r,"destroy").then(me).then(le).then(B)},s.do_search=function(e,r){return z(e,r,"search").then(he).then(B)},s.on_records=function(e,r){return z(e,r,"on_records").then(pe).then(B)},s.do_initialize=function(e,r){return z(e,r,"initialize").then(ye).then(B)},s.do_terminate=function(e,r){return z(e,r,"terminate").then(Pe).then(B)},s.do_test_self=function(e,r){return z(e,r,"self-test").then(je).then(B)},s.do_next_id=function(){return Q({_id:0}).then(function(e){return e._id})},s};
+"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,_=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 m=e.log,a=e.inf,l=e.err,p=f.NS(n,"green"),s=t||{},c=function(e){throw new Error("NOT_IMPLEMENTED - "+p+":"+JSON.stringify(e))};s.do_prepare=c,s.do_create=c,s.do_clone=c,s.do_update=c,s.do_increment=c,s.do_read=c,s.do_readX=c,s.do_delete=c,s.do_destroy=c,s.do_search=c,s.do_initialize=c,s.do_terminate=c,s.do_test_self=c,s.on_records=c,s.do_notify=c,s.do_subscribe=c,s.do_next_id=c,r.startsWith("_")||e(r,s);var v=function(e,r){return void 0===s[e]?r:s[e]},E=v("VERSION",1),y=v("REVISION",1),w=v("VERSION_NAME","V"),P=v("REVISION_NAME","R"),g=v("ID_INPUT","id"),j=v("ID_NAME","id"),S=v("ID_TYPE","test"),N=v("ID_NEXT",0),q=v("DYNA_TABLE","TestTable"),b=v("REDIS_PKEY","TPKEY"),O=v("DEFAULTS",null),A=v("CLONEABLE",!1),R=v("CLONED_ID","cloned"),I=v("PARENT_ID","parent"),D=v("PARENT_IMUT",!0),T=v("ES_INDEX","test-v1"),x=v("ES_TYPE","test"),W=v("ES_MASTER",0),L=v("ES_VERSION",5),M=5<L?_:d;if(!M)throw new Error("$ES is required! Ver:"+L);var $=v("XECURE_KEY",null),F=function(){var e=v("FIELDS",null),r=v("ES_FIELDS",["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&&a(p,"XECURED-FIELDS =",n)}return(!e||!e.length)&&(n=r=e=null),[e,r,n]}(),U=_slicedToArray(F,3),V=U[0],k=U[1],B=U[2],Y=v("NS_NAME",""),z=require("dynamodb-value"),C=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},Q=require("./notify-service")(e,"!"+Y,{NS_NAME:Y});s.do_notify=Q.do_notify,s.do_subscribe=Q.do_subscribe,A&&V&&(I&&V.indexOf(I)<0&&V.push(I),R&&V.indexOf(R)<0&&V.push(R));var X=[g,j,"created_at","updated_at","deleted_at",R];D&&I&&X.push(I);var H=function(e,r,t,n){t=t||"","object"===(void 0===(e=e||0)?"undefined":_typeof(e))?r=r?f.extend(e,r):e:(r=null==r?{}:"object"!==(void 0===r?"undefined":_typeof(r))||r instanceof Promise?{params:r}:f.copy(r),r=f.extend(r,{_id:e}));var i=r;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(p+"method-stack full. size:"+i._method_stack):f.promise(i);e=S.startsWith("#")?i._id||i[g]||"":f.N(i._id||i[g]||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)},J=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=V?V.reduce(function(e,r){return void 0!==e[r]&&void 0!==t[r]&&(e[r]=t[r]),e},e):e),e},K=function(r){var e=r._id;if(m(p,"- my_prepare_id("+S+", "+e+")...."),S.startsWith("#")){if(S&&S.startsWith("#")&&1<S.length&&0<N){var t=S.substring(1);return i.do_get_next_id(t).then(function(e){return m(p,"> created next-id["+t+"]=",e),r._id=e,r})}}else if(S&&!e)return i.do_get_next_id(S).then(function(e){return m(p,"> created next-id=",e),r._id=e,r});return m(p,"> prepared-id =",e),Promise.resolve(r)},G=function(t){if(!t._current_mode)throw new Error(p+"_current_mode is required!");var n=t._current_mode,i=O||{},o=0,e=t._node||{};return V?"prepare"===n||"create"===n||"clone"===n?e=V.reduce(function(e,r){return r===j||r===w||r===P||("prepare"===n?(void 0!==i[r]?e[r]=O[r]:void 0!==t[r]&&(e[r]=t[r]),w&&(e[w]=E),P&&(e[P]=0)):("create"===n&&P&&(e[P]=y-1),void 0!==t[r]&&(e[r]=t[r])),o++),e},e):"update"!==n&&"increment"!==n&&"read"!==n||(e=V.reduce(function(e,r){return r===j||void 0!==t[r]&&o++,e},e)):o=-1,t._fields_count=o,t._node=e,t},Z=function(e,r){return e.created_at=0,e.updated_at=r,e.deleted_at=r,e},ee=function(e,r){return e.created_at=r,e.updated_at=r,e.deleted_at=0,e},re=function(t){if(!t._node)return Promise.reject(new Error(p+"_node is required!"));if(!t._current_time)return Promise.reject(new Error(p+"_current_time is required!"));var n=t._id,i=(t._node,t._current_time);return n?le(t).catch(function(e){var r=e&&e.message||"";if(!(0<=r.indexOf("404 NOT FOUND")))throw e;return l(p,"not found. err=",r),t}).then(function(e){var r=(e=G(e))._node||{};if(e._force_create)l(p,"WARN! _force_create is set!");else if(!r.deleted_at)return l(p,"INVALID STATE FOR PREPARED. ID=",n,", TIMES[CUD]=",[r.created_at,r.updated_at,r.deleted_at]),Promise.reject(new Error(p+"INVALID STATE."));return e[g]=e._id,r[j]=e._id,e._node=Z(e._node,i),e}):(t=G(t),K(t).then(function(e){var r=e._node||{};return e[g]=e._id,r[j]=e._id,e._node=Z(r,i),e}))},te=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));if(!e._current_time)return Promise.reject(new Error(p+"_current_time is required!"));var t=e._id,n=(e._node,e._current_time);return m(p,"> prepared-id =",t,", current-time =",n),le(e).then(function(e){var r=(e=G(e))._node||{};if(e._force_create)l(p,"WARN! _force_create is set!");else if(!r.deleted_at)return l(p,"INVALID STATE FOR CREATED. ID=",t,", TIMES[CUD]=",[r.created_at,r.updated_at,r.deleted_at]),Promise.reject(new Error(p+"INVALID STATE."));return e._node=ee(e._node,n),e})},ne=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));if(!e._current_time)return Promise.reject(new Error(p+"_current_time is required!"));var r=e._id,t=e._node,n=e._current_time;return m(p,"> cloned-id =",r,", current-time =",n,", node =",f.json(t)),le(e).then(function(e){return m(p,">> get-item-node old=",f.json(e._node)),(e=G(e))._node=ee(e._node,n),e})},ie=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));if(!e._current_time)return Promise.reject(new Error(p+"_current_time is required!"));e._id,e._node;var n=e._current_time;return 0===(e=G(e))._fields_count?e:le(e).then(function(e){var r,t;return e._node=(r=e._node,t=n,r.updated_at=t,r),e})},oe=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));if(!e._current_time)return Promise.reject(new Error(p+"_current_time is required!"));var r=e._id,t=e._node,n=e._current_time;return m(p,"> deleted-id =",r,", current-time =",n,", node =",f.json(t)),le(e).then(function(e){var r,t;return m(p,">> get-item-node old=",f.json(e._node)),(e=G(e))._node=(r=e._node,t=n,r.updated_at=t,r.deleted_at=t,r),e})},de=function(r){var e;if(!r._id)return Promise.reject(new Error(p+"_id is required!"));var t=r._id;m(p,"- dynamo:my_read_node ("+t+")....");var n=S.startsWith("#")?"String":"";return u.do_get_item(q,(e={},_defineProperty(e,j,t),_defineProperty(e,"idType",n),e)).then(function(e){return m(p,"> dynamo:get-item-node("+t+") res=",f.json(e)),r._node=e,r})},ue=function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!r._node)return Promise.reject(new Error(p+"_node is required!"));var t=r._id,e=r._node,n={},i=0,o=$?C($):null;for(var d in r)r.hasOwnProperty(d)&&(d=""+d)&&(d.startsWith("_")||d.startsWith("$")||0<=X.indexOf(d)||V&&V.indexOf(d)<0||d&&(n[d]=r[d],e[d]=r[d],i++,o&&B&&0<=B.indexOf(d)&&(e[d]=o.encrypt(r[d]),n[d]=e[d])));return n.updated_at=e.updated_at,r._updated_node=null,(r._updated_count=i)?(void 0!==e[P]&&(e[P]=f.N(e[P],0)+1),u.do_update_item(q,_defineProperty({},j,t),n,P?_defineProperty({},P,1):null).then(function(e){return r._updated_node=n,m(p,"> dynamo:updated-item("+t+") res=",f.json(e)),r})):V?r:Promise.reject(new Error(p+"nothing to update"))},_e=function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!r._node)return Promise.reject(new Error(p+"_node is required!"));var t=r._id,e=r._node,n=r._current_mode||"",i=r._current_time;if(m(p,"- dynamo:my_save_node("+t+")...."),m(p,"> dynamo:node-id =",t,", current-time =",i,", node =",f.json(e)),"prepare"!==n){var o=$?C($):null;for(var d in r)r.hasOwnProperty(d)&&(d=""+d)&&(d.startsWith("_")||d.startsWith("$")||0<=X.indexOf(d)||V&&V.indexOf(d)<0||(e[d]=r[d],o&&B&&0<=B.indexOf(d)&&(e[d]=o.encrypt(r[d]))))}return void 0!==e[P]&&(e[P]=f.N(e[P],0)+1),u.do_create_item(q,_defineProperty({},j,t),e).then(function(e){return m(p,"> dynamo:saved-item("+t+") res=",e),r})},ae=function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!r._node)return Promise.reject(new Error(p+"_node is required!"));var t=r._id,e=r._node,n={},i=0;for(var o in r)r.hasOwnProperty(o)&&((o=""+o).startsWith("_")||o.startsWith("$")||0<=X.indexOf(o)||V&&V.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,m(p,"> dynamo:increment-node =",n),r._updated_node=null,(r._updated_count=i)?(void 0!==e[P]&&(e[P]=f.N(e[P],0)+1),u.do_increment_item(q,_defineProperty({},j,t),n,P?_defineProperty({},P,1):null).then(function(e){return m(p,"> dynamo:updated-item("+t+") res=",f.json(e)),r._updated_node=n,r})):V?r:Promise.reject(new Error(p+"nothing to update"))},se=function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));var t=r._id;return u.do_delete_item(q,_defineProperty({},j,t)).then(function(e){return m(p,"> dynamo:deleted-item-node("+t+") res=",f.json(e)),r._node=e||{},r})},ce={my_read_node:function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!b)return Promise.reject(r);var t=r._id;return 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&&(l(p,"! redis:get-item("+b+", "+t+") err =",e.message||e),r._error=e),r})},my_save_node:function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!r._node)return Promise.reject(new Error(p+"_node is required!"));if(!b)return Promise.resolve(r);var t=r._id,e=r._node;m(p,"- redis:my_save_node("+b+":"+t+"). node.updated_at=",e&&e.updated_at||0);var n=ce.my_set_node_footprint(t,e);return n=n.then(function(){return o.do_create_item(b,t,e)}).then(function(e){return m(p,"> redis:save-item-node("+t+") res=",f.json(e)),r})},my_update_node:function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!r._node)return Promise.reject(new Error(p+"_node is required!"));if(!b)return Promise.resolve(r);var t=r._id,e=r._node,n=ce.my_set_node_footprint(t,e);return n=n.then(function(){return o.do_update_item(b,t,e)}).then(function(e){return m(p,"> redis:update-item-node("+t+") res=",f.json(e)),r})},my_delete_node:function(r){if(!r._id)return Promise.reject(new Error(p+"_id is required!"));if(!b)return Promise.resolve(r);var t=r._id;return o.do_delete_item(b,t).then(function(e){return m(p,"> redis:delete-item-node("+t+") res=",f.json(e)),r})},my_set_node_footprint:function(r,e){if(!r)return Promise.reject(new Error(p+"id is required!"));if(!b)return Promise.resolve(0);e=e||{};var t=f.N(e.updated_at,0),n=f.hash(e);return o.do_create_item([b+"/UPDATED",b+"/HASH"],r,[t,n]).then(function(e){return m(p,"> redis:set node-footprint("+r+") res=",f.json(e)),e})},my_get_updated_at:function(e){return e?b?o.do_get_item(b+"/UPDATED",e).then(function(e){return e}):Promise.resolve(-1):Promise.reject(new Error(p+"id is required!"))},my_get_hash_value:function(e){return e?b?o.do_get_item(b+"/HASH",e).then(function(e){return e}):Promise.resolve(-1):Promise.reject(new Error(p+"id is required!"))}},fe=function(r){if(!r._id)return Promise.reject(new Error(p+"elasticsearch:_id is required!"));if(!r._node)return Promise.reject(new Error(p+"elasticsearch:_node is required!"));if(!T||!x)return r;var t=r._id,n=r._node;if(k){var e=h.reduce(k,function(e,r){return void 0!==n[r]&&(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),W?M.do_create_item(T,x,t,e).then(function(e){return m(p,"! elasticsearch:saved-item("+t+") res=",f.json(e)),r}):M.do_update_item(T,x,t,e).then(function(e){return m(p,"! elasticsearch:updated-item("+t+") res=",f.json(e)),r})):(m(p,"! elasticsearch:WARN! nothing to update ("+t+")...."),r)}return M.do_create_item(T,x,t,n).then(function(e){return m(p,"! elasticsearch:saved-item2("+t+") res=",f.json(e)),r})},he=function(r){if(!r._id)return Promise.reject(new Error(p+"elasticsearch:_id is required!"));if(!T||!x)return r;var t=r._id;return k&&!W?(m(p,"! elasticsearch:WARN! ignore delete ("+t+")...."),r):M.do_delete_item(T,x,t).then(function(e){return m(p,"! elasticsearch:deleted-item("+t+") res=",f.json(e)),r})},me=function(i){if(!T||!x)return i;if(m(p,"- elasticsearch:do_search_item()...."),k&&!W)return m(p,"! elasticsearch:WARN! ignore search ()...."),i;var o={$page:0,$limit:0};return o.$page=f.N(i.page||0),o.$limit=f.N(0===i.ipp?0:i.ipp||10),o.deleted_at="0",i.$source&&(o.$source=i.$source),i.Q&&(o.$Q=i.Q),i.A&&(o.$A=i.A),i.O&&(o.$O=i.O),o.$O=o.$O||(S.startsWith("#")?"id.keyword":"id"),k&&k.forEach(function(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])}),M.do_search_item(T,x,o).then(function(e){var r=e&&e.hits||{},t=r.hits||[],n=r;return i.list=t.map(function(e){return f.extend({_score:e._score},e._source)}),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 l(p,"!ERR =",e),e})},le=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));e._id;return Promise.resolve(e).then(ce.my_read_node).catch(function(e){return de(e).then(function(e){return void 0===(e._node||{})[j]?Promise.reject(new Error(p+"404 NOT FOUND. "+q+".id:"+(e._id||""))):e}).then(ce.my_save_node)})},pe=function(e){if(!e||!e._node)return e;if(!B||!B.length)return e;var n=$?C($):null;if(!n)return e;var r=e._node||{};return B.reduce(function(e,r){if(r.startsWith("_")||r.startsWith("$"))return e;var t=e[r];return void 0===t||(t=t?n.decrypt(t):t,e[r]=t),e},r),e},ve=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));e._id;return Promise.resolve(e).then(_e).then(ce.my_save_node).then(fe).then(function(e){return e})},Ee=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));if(!e._current_time)return Promise.reject(new Error(p+"_current_time is required!"));var r=e._id;return m(p,"- my_clone_node ("+r+")...."),Promise.resolve(e).then(function(n){if(!A)return n;var e=n._id,i=void 0!==n[I]?f.N(n[I],0):e,o=e;return K({_id:0}).then(function(e){var r=e._id,t=n._node||{};return t[j]=r,I&&(t[I]=i),R&&(t[R]=o),I&&(n[I]=i),R&&(n[R]=o),n._clone_id=r,n._node=t,n})}).then(function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));if(!e._node)return Promise.reject(new Error(p+"_node is required!"));if(!e._clone_id)return Promise.reject(new Error(p+"_clone_id is required!"));var r=e._id;return 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),m(p,">> before save-node().. that._node =",f.json(e._node)),ve(e).then(function(){return e._id=r,e})}).then(function(e){return m(p,">> cloned-node["+e._id+" -> "+e._clone_id+"] res=",f.json(e._node)),e})},ye=function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));var r=e._id;return m(p,"- my_delete_node ("+r+")...."),Promise.resolve(e).then(se).then(ce.my_delete_node).then(he).then(function(e){return m(p,">> deleted-node res=",f.json(e._node)),e})},we=function(e){return m(p,"- my_search_node ()...."),Promise.resolve(e).then(me).then(function(e){return e})},Pe=function(e){if(!e)return e;if(!e._id)return Promise.reject(new Error(p+"_id is required!"));e._id;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=Y+":event:"+n;return m(p,">>> notify event-id:",t,", notifiable=",e),Se(t,r).then(function(e){return r})}return r})},ge=function(r){if(!r.records)return Promise.reject(new Error(p+"records is required!"));var e=r.records.slice(0);if(m(p,"- my_event_records().... records.len=",e.length),!e.length)return r;var t,n,i;return(t=e,n=je,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 l(p,"error ignored! =",e),r}).then(function(){return r})},je=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(m(p,"--- process-record("+o+") ... "),q!==o)return m(p,"! ignore record-table: "+q+" != "+o+" "),e;var t=e.dynamodb.Keys?z.toJavascript(e.dynamodb.Keys):{},d=e.dynamodb.NewImage?z.toJavascript(e.dynamodb.NewImage):null,n=e.dynamodb.OldImage?z.toJavascript(e.dynamodb.OldImage):null,u=t[j],_="MODIFY"===i?f.diff(n,d):null,a=f.N(d&&d.updated_at||0),s=_?h.reduce(_,function(e,r){return e[r]=n[r],e},{}):null,c={_id:u,_node:d,_updated_at:a,_diff:_,_prev:s};switch(r=Promise.resolve(c),_&&m(p,">> "+o+".different["+u+"]=",f.json(_)),i){case"INSERT":case"MODIFY":r=r.then(function(t){var n=t._id;return ce.my_get_updated_at(n).then(function(e){if(l(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 ce.my_get_hash_value(n).then(function(e){return e&&e===r?(m(p,"! WARN! ignored due to hash-value matching =",e),t):(m(p,"! INFO! node was updated. hash :=",r,"<-",e),ce.my_save_node(t).then(fe))})}return m(p,"! ignored due to old-record"),t})});break;case"REMOVE":m(p,">> removed!"),r=(r=r.then(ce.my_delete_node)).then(he)}}else e.Sns&&(m(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=Y+":record:"+e;return m(p,">>> notify event-id:",n,", notifiable=",t),Se(n,r).then(function(e){return r})}return r}).then(function(){return e}):Promise.reject(new Error("invalid chain!"))},Se=function(e,r){return Q.do_notify(e,r)},Ne=function(r){var e=[];if(q){var t=S.startsWith("#")?"S":"N";e.push(Promise.resolve("DynamoDb").then(function(e){return m(p,"# initialize ",e),u.do_create_table(q,j,t).then(function(e){return e.TableDescription.TableName===q})}).catch(function(e){if("ResourceInUseException"===e.code)return!1;throw e}))}else m(p,"DS: WARN! ignored configuration. DYNA_TABLE=",q);if(S&&!S.startsWith("#")?e.push(Promise.resolve("MySQL").then(function(e){return m(p,"# initialize MySQL (Sequence) "),i.do_create_id_seq(S,N).then(function(e){return m(p,"> create-id-seq res=",e),!0})}).catch(function(e){if("ER_TABLE_EXISTS_ERROR"===e.code)return!1;throw e})):S&&S.startsWith("#")&&1<S.length&&0<N?e.push(Promise.resolve("MySQL").then(function(e){m(p,"# initialize MySQL (Sequence) ");var r=S.substring(1);return i.do_create_id_seq(r,N).then(function(e){return m(p,"> create-id-seq["+r+"] res=",e),!0})}).catch(function(e){if("ER_TABLE_EXISTS_ERROR"===e.code)return!1;throw e})):m(p,"MS: WARN! ignored configuration. ID_TYPE=",S),T&&x&&k){var n={mappings:{_default_:{dynamic_templates:[{string_fields:{match:"*_multi",match_mapping_type:"string",mapping:{type:"multi_field",fields:{"{name}":{type:6<=L?"text":"string",index:"analyzed",omit_norms:!0,index_options:"docs"},"{name}.raw":{type:6<=L?"text":"string",index:"not_analyzed",ignore_above:256}}}}}],properties:{"@version":{type:6<=L?"text":"string",index:!(6<=L)&&"not_analyzed"},title:{type:6<=L?"text":"string"},name:{type:6<=L?"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"}}}}};6<=L||(n.mappings._default_.all={enabled:!0}),e.push(Promise.resolve("ElasticSearch").then(function(e){return m(p,"# initialize ElasticSearch (Type) ",x),M.do_create_index_type(T,x,n).then(function(e){return m(p,"> create-es-index res=",e),!0})}).catch(function(e){if(l(p,"> create-es-index error=",e),"index_already_exists_exception"===e.type)return!0;throw e}).then(function(e){return e}))}else m(p,"MS: WARN! ignored configuration. ES_TYPE=",x);return Promise.all(e).then(function(e){return m(p,">> results=",e),r._result=e,r})},qe=function(r){var e=[];if(q&&(m(p,"# terminate DynamoDB"),e.push(u.do_delete_table(q).then(function(e){return e.TableDescription.TableName===q}).catch(function(e){if("ResourceNotFoundException"===e.code)return!0;throw e}))),S&&!S.startsWith("#"))m(p,"# terminate MySQL (Sequence) "),e.push(i.do_delete_id_seq(S).then(function(e){return m(p,"> delete-id-seq res=",e),!0}).catch(function(e){if("ER_BAD_TABLE_ERROR"===e.code)return!0;throw e}));else if(S&&S.startsWith("#")&&1<S.length&&0<N){m(p,"# terminate MySQL (Sequence) ");var t=S.substring(1);e.push(i.do_delete_id_seq(t).then(function(e){return m(p,"> delete-id-seq["+t+"] res=",e),!0}).catch(function(e){if("ER_BAD_TABLE_ERROR"===e.code)return!0;throw e}))}else m(p,"# ignored MySQL (Sequence) ");return T&&x?(m(p,"# terminate ES (Index) "),e.push(M.do_delete_index_type(T,null).then(function(e){return m(p,"> delete-es-index res=",e),!0}).catch(function(e){throw l(p,"> create-es-index error=",e),e}))):m(p,"# ignored ES (Index) "),Promise.all(e).then(function(e){return m(p,">> results=",e),r._result=e,r})},be=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",m(p,"# node1 =",f.json(r)),m(p,"> node2 =",f.json(t)),m(p,"> node3 =",f.json(n)),m(p,"# node1.sorted =",f.json(r,!0)),m(p,"> node2.sorted =",f.json(t,!0)),m(p,"> node3.sorted =",f.json(n,!0)),m(p,"# hash1 =",f.hash(1)),m(p,"> node1 =",f.hash(r)),m(p,"> node2 =",f.hash(t)),m(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 m(p,"> read-back data=",e),e})}).then(function(){return ce.my_set_node_footprint(1,i)}).then(function(){return ce.my_get_updated_at(1).then(function(e){return m(p,"> updated-at value=",void 0===e?"undefined":_typeof(e),":",e),e})}).then(function(){return ce.my_get_hash_value(1).then(function(e){return m(p,"> hash-value value=",void 0===e?"undefined":_typeof(e),":",e),e})})},Oe=function(r){return m(p,"- my_test_self()...."),Promise.resolve(r).then(be).then(function(e){return e||r})};return s.do_prepare_chain=function(e,r,t,n){return H(e,r,t,n)},s.do_finish_chain=function(e,r,t,n){return J(e)},s.do_prepare=function(e,r){return H(e,r,"prepare").then(re).then(ve).then(Pe).then(J)},s.do_create=function(t,n){return H(t,n,"create").then(te).catch(function(e){l(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 a(p,"WARN! AUTO TRY TO PREPARE NODE. ID="+t),H(t,n,"create").then(function(e){var r=e._current_time;return e=G(e),m(p,">> prepared old-node=",f.json(e._node)),e._node=ee(e._node,r),e});throw e}).then(ve).then(Pe).then(J)},s.do_clone=function(e,r){return H(e,r,"clone").then(ne).then(Ee).then(Pe).then(J)},s.do_read=function(e,r){return H(e,r,"read").then(G).then(function(e){return 0!==e._params_count&&0===e._fields_count?e:le(e)}).then(Pe).then(J)},s.do_readX=function(e,r){return H(e,r,"read").then(G).then(function(e){return 0!==e._params_count&&0===e._fields_count?e:le(e)}).then(pe).then(Pe).then(J)},s.do_update=function(e,r){return H(e,r,"update").then(ie).then(function(e){return 0===e._fields_count?e:function(t){if(!t._id)return Promise.reject(new Error(p+"_id is required!"));var e=t._id;return m(p,"- my_update_node ("+e+")...."),0===t._fields_count?(m(p,"! my_update_node() no need to update... fields_count="+t._fields_count),t):Promise.resolve(t).then(ue).then(function(e){return e._updated_node?ce.my_save_node(e):e}).then(function(e){return e._updated_node?fe(e):e}).then(function(e){return m(p,">> updated-node res=",f.json(e._updated_node)),e}).catch(function(e){var r=e&&e.message||"";if(l(p,">> updated-node err=",r),0<r.indexOf("an attribute that does not exist in the item"))return ve(t);throw e})}(e)}).then(Pe).then(J)},s.do_increment=function(e,r){return H(e,r,"increment").then(ie).then(function(e){return 0===e._fields_count?e:function(e){if(!e._id)return Promise.reject(new Error(p+"_id is required!"));var r=e._id;return m(p,"- my_increment_node ("+r+")...."),0===e._fields_count?(m(p,"! my_increment_node() no need to increment... fields_count="+e._fields_count),e):Promise.resolve(e).then(ae).then(function(e){return e._updated_node?ce.my_save_node(e):e}).then(function(e){return e._updated_node?fe(e):e}).then(function(e){return m(p,">> increment-node res=",f.json(e._updated_node)),e})}(e)}).then(Pe).then(J)},s.do_delete=function(e,r){return H(e,r,"delete").then(oe).then(ve).then(Pe).then(J)},s.do_destroy=function(e,r){return H(e,r,"destroy").then(ye).then(Pe).then(J)},s.do_search=function(e,r){return H(e,r,"search").then(we).then(J)},s.on_records=function(e,r){return H(e,r,"on_records").then(ge).then(J)},s.do_initialize=function(e,r){return H(e,r,"initialize").then(Ne).then(J)},s.do_terminate=function(e,r){return H(e,r,"terminate").then(qe).then(J)},s.do_test_self=function(e,r){return H(e,r,"self-test").then(Oe).then(J)},s.do_next_id=function(){return K({_id:0}).then(function(e){return e._id})},s};

package.json

 {
   "name": "lemoncloud-engine-js",
-  "version": "0.3.21",
+  "version": "0.3.22",
   "description": "lemoncloud.io - core engine module with user/group/chat service.",
@@ -20,2 +20,3 @@ "main": "index.js",
   "dependencies": {
+    "crypto": "^1.0.1",
     "dynamodb-value": "^1.0.5",
@@ -22,0 +23,0 @@ "js-yaml": "^3.11.0",

README.md

@@ -54,6 +54,7 @@ # lemoncloud-engine-js
     NS_NAME     : name,                         // Notify Service Name. (null means no notifications)
-    ES_MASTER	: 1,							// MASTER NODE.
-    ES_VERSION  : 6,                            // Use ES Version 6.
+    ES_MASTER	: 1,							// ES Master NODE.
+    ES_VERSION  : 6,                            // ES Version 6.x.
     CLONEABLE   : true,                         // 복제 가능하며, parent/cloned 필드를 지원함.
     PARENT_IMUT : false,						// parent-id 변경 가능함(2018.03.15)
+	XECURE_KEY  : 'lemon',					    // Encryption Key (use '*' prefix at property name: ver 0.3.22)
 });    // load core-service with parameters.
@@ -89,2 +90,3 @@ if (!$LEM) throw new Error(NS+'$LEM is required!');
 |--         |--
+| 0.3.22    | support xecured fields see `XECURE_KEY`. @180801.
 | 0.3.21    | add 'do_post_execute_protocol'
@@ -91,0 +93,0 @@ | 0.3.20    | try to parse body for `http-proxy`.

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

111314

increased by6.09%

Number of package files

26

increased by4%

Number of lines in readme file

118

increased by1.72%

Worsened metrics

Dependency count

5

increased by25%

Number of medium supply chain risk alerts

2

increased by100%

Dependency changes

• + Addedcrypto@^1.0.1

• + Addedcrypto@1.0.1(transitive)