@alipay/faas-db-builder - npm Package Compare versions

Comparing version 1.1.9 to 1.1.10-alpha.0

lib/command/aggregate/and.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AndAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class AndAggregateCommand extends AbstractCommand_1.AggregateCommand{commands;constructor(e){super(),this.commands=e.map(t=>new AggregateRequest_1.AggregateRequest(t).toJSON())}pushCommand(e){this.commands.push(new AggregateRequest_1.AggregateRequest(e).toJSON())}stringify(){return{$and:this.commands}}}exports.AndAggregateCommand=AndAggregateCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AndAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class AndAggregateCommand extends AbstractCommand_1.AggregateCommand{constructor(e){super(),this.commands=e.map(t=>new AggregateRequest_1.AggregateRequest(t).toJSON())}pushCommand(e){this.commands.push(new AggregateRequest_1.AggregateRequest(e).toJSON())}stringify(){return{$and:this.commands}}}exports.AndAggregateCommand=AndAggregateCommand;

lib/command/aggregate/avg.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AvgAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class AvgAggregateCommand extends AbstractCommand_1.AggregateCommand{val;constructor(e){super(),this.val=new AggregateRequest_1.AggregateRequest(e).toJSON()}stringify(){return{$avg:this.val}}}exports.AvgAggregateCommand=AvgAggregateCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AvgAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class AvgAggregateCommand extends AbstractCommand_1.AggregateCommand{constructor(e){super(),this.val=new AggregateRequest_1.AggregateRequest(e).toJSON()}stringify(){return{$avg:this.val}}}exports.AvgAggregateCommand=AvgAggregateCommand;

lib/command/aggregate/eq.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.EqAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class EqAggregateCommand extends AbstractCommand_1.AggregateCommand{val;constructor(e){super(),this.val=e}stringify(){return{$eq:this.val}}}exports.EqAggregateCommand=EqAggregateCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.EqAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class EqAggregateCommand extends AbstractCommand_1.AggregateCommand{constructor(e){super(),this.val=e}stringify(){return{$eq:this.val}}}exports.EqAggregateCommand=EqAggregateCommand;

lib/command/aggregate/gt.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.GtAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class GtAggregateCommand extends AbstractCommand_1.AggregateCommand{val;constructor(t){super(),this.val=t}stringify(){return{$gt:this.val}}}exports.GtAggregateCommand=GtAggregateCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.GtAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class GtAggregateCommand extends AbstractCommand_1.AggregateCommand{constructor(t){super(),this.val=t}stringify(){return{$gt:this.val}}}exports.GtAggregateCommand=GtAggregateCommand;

lib/command/aggregate/gte.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.GteAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class GteAggregateCommand extends AbstractCommand_1.AggregateCommand{val;constructor(e){super(),this.val=e}stringify(){return{$gte:this.val}}}exports.GteAggregateCommand=GteAggregateCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.GteAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class GteAggregateCommand extends AbstractCommand_1.AggregateCommand{constructor(e){super(),this.val=e}stringify(){return{$gte:this.val}}}exports.GteAggregateCommand=GteAggregateCommand;

lib/command/aggregate/lt.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.LtAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class LtAggregateCommand extends AbstractCommand_1.AggregateCommand{val;constructor(t){super(),this.val=t}stringify(){return{$lt:this.val}}}exports.LtAggregateCommand=LtAggregateCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.LtAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class LtAggregateCommand extends AbstractCommand_1.AggregateCommand{constructor(t){super(),this.val=t}stringify(){return{$lt:this.val}}}exports.LtAggregateCommand=LtAggregateCommand;

lib/command/aggregate/lte.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.LteAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class LteAggregateCommand extends AbstractCommand_1.AggregateCommand{val;constructor(e){super(),this.val=e}stringify(){return{$lte:this.val}}}exports.LteAggregateCommand=LteAggregateCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.LteAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class LteAggregateCommand extends AbstractCommand_1.AggregateCommand{constructor(e){super(),this.val=e}stringify(){return{$lte:this.val}}}exports.LteAggregateCommand=LteAggregateCommand;

lib/command/aggregate/max.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.MaxAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class MaxAggregateCommand extends AbstractCommand_1.AggregateCommand{val;constructor(e){super(),this.val=new AggregateRequest_1.AggregateRequest(e).toJSON()}stringify(){return{$max:this.val}}}exports.MaxAggregateCommand=MaxAggregateCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.MaxAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class MaxAggregateCommand extends AbstractCommand_1.AggregateCommand{constructor(e){super(),this.val=new AggregateRequest_1.AggregateRequest(e).toJSON()}stringify(){return{$max:this.val}}}exports.MaxAggregateCommand=MaxAggregateCommand;

lib/command/aggregate/min.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.MinAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class MinAggregateCommand extends AbstractCommand_1.AggregateCommand{val;constructor(e){super(),this.val=new AggregateRequest_1.AggregateRequest(e).toJSON()}stringify(){return{$min:this.val}}}exports.MinAggregateCommand=MinAggregateCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.MinAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class MinAggregateCommand extends AbstractCommand_1.AggregateCommand{constructor(e){super(),this.val=new AggregateRequest_1.AggregateRequest(e).toJSON()}stringify(){return{$min:this.val}}}exports.MinAggregateCommand=MinAggregateCommand;

lib/command/aggregate/neq.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.NeqAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class NeqAggregateCommand extends AbstractCommand_1.AggregateCommand{val;constructor(e){super(),this.val=e}stringify(){return{$ne:this.val}}}exports.NeqAggregateCommand=NeqAggregateCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.NeqAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class NeqAggregateCommand extends AbstractCommand_1.AggregateCommand{constructor(e){super(),this.val=e}stringify(){return{$ne:this.val}}}exports.NeqAggregateCommand=NeqAggregateCommand;

lib/command/aggregate/or.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.OrAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class OrAggregateCommand extends AbstractCommand_1.AggregateCommand{commands;constructor(e){super(),this.commands=e.map(t=>new AggregateRequest_1.AggregateRequest(t).toJSON())}pushCommand(e){this.commands.push(new AggregateRequest_1.AggregateRequest(e).toJSON())}stringify(){return{$or:this.commands}}}exports.OrAggregateCommand=OrAggregateCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.OrAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class OrAggregateCommand extends AbstractCommand_1.AggregateCommand{constructor(e){super(),this.commands=e.map(t=>new AggregateRequest_1.AggregateRequest(t).toJSON())}pushCommand(e){this.commands.push(new AggregateRequest_1.AggregateRequest(e).toJSON())}stringify(){return{$or:this.commands}}}exports.OrAggregateCommand=OrAggregateCommand;

lib/command/aggregate/sum.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.SumAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class SumAggregateCommand extends AbstractCommand_1.AggregateCommand{val;constructor(e){super(),this.val=new AggregateRequest_1.AggregateRequest(e).toJSON()}stringify(){return{$sum:this.val}}}exports.SumAggregateCommand=SumAggregateCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.SumAggregateCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class SumAggregateCommand extends AbstractCommand_1.AggregateCommand{constructor(e){super(),this.val=new AggregateRequest_1.AggregateRequest(e).toJSON()}stringify(){return{$sum:this.val}}}exports.SumAggregateCommand=SumAggregateCommand;

lib/command/AggregatePipeline.d.ts

 import type { QueryChainCommand, SampleAggregateParam } from '../typing';
 import { LookupAggregateParam } from '../typing';
 export declare class AggregatePipeline {
-    #private;
     constructor();
@@ -6,0 +5,0 @@ match(match: QueryChainCommand): this;

lib/command/AggregatePipeline.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AggregatePipeline=void 0;const AggregateRequest_1=require("./AggregateRequest"),QueryRequest_1=require("./QueryRequest"),constant_1=require("../common/constant"),error_1=require("../common/error");class AggregatePipeline{#t;constructor(){this.#t=[]}match(e){return this.#e(constant_1.PipelineStageName.match,e),this}group(e){return this.#e(constant_1.PipelineStageName.group,e),this}sample(e){return this.#e(constant_1.PipelineStageName.sample,e),this}lookup(e){return this.#e(constant_1.PipelineStageName.lookup,e),this}done(){return this.#t.map(e=>{switch(e.name){case constant_1.PipelineStageName.match:return{$match:new QueryRequest_1.QueryRequest(e.param).toJSON()};case constant_1.PipelineStageName.sample:case constant_1.PipelineStageName.lookup:return{[e.name]:e.param};case constant_1.PipelineStageName.group:return{$group:new AggregateRequest_1.AggregateRequest(e.param).toJSON()};default:{const t=e.name;throw error_1.DbBuildError.invalidParam(t,"\u4E0D\u652F\u6301\u7684 aggregate \u64CD\u4F5C")}}})}#e(e,t){this.#t.push({name:e,param:t})}}exports.AggregatePipeline=AggregatePipeline;
+"use strict";var __classPrivateFieldSet=this&&this.__classPrivateFieldSet||function(r,e,t,a,i){if(a==="m")throw new TypeError("Private method is not writable");if(a==="a"&&!i)throw new TypeError("Private accessor was defined without a setter");if(typeof e=="function"?r!==e||!i:!e.has(r))throw new TypeError("Cannot write private member to an object whose class did not declare it");return a==="a"?i.call(r,t):i?i.value=t:e.set(r,t),t},__classPrivateFieldGet=this&&this.__classPrivateFieldGet||function(r,e,t,a){if(t==="a"&&!a)throw new TypeError("Private accessor was defined without a getter");if(typeof e=="function"?r!==e||!a:!e.has(r))throw new TypeError("Cannot read private member from an object whose class did not declare it");return t==="m"?a:t==="a"?a.call(r):a?a.value:e.get(r)},_AggregatePipeline_instances,_AggregatePipeline_pipeline,_AggregatePipeline_pushStage;Object.defineProperty(exports,"__esModule",{value:!0}),exports.AggregatePipeline=void 0;const AggregateRequest_1=require("./AggregateRequest"),QueryRequest_1=require("./QueryRequest"),constant_1=require("../common/constant"),error_1=require("../common/error");class AggregatePipeline{constructor(){_AggregatePipeline_instances.add(this),_AggregatePipeline_pipeline.set(this,void 0),__classPrivateFieldSet(this,_AggregatePipeline_pipeline,[],"f")}match(e){return __classPrivateFieldGet(this,_AggregatePipeline_instances,"m",_AggregatePipeline_pushStage).call(this,constant_1.PipelineStageName.match,e),this}group(e){return __classPrivateFieldGet(this,_AggregatePipeline_instances,"m",_AggregatePipeline_pushStage).call(this,constant_1.PipelineStageName.group,e),this}sample(e){return __classPrivateFieldGet(this,_AggregatePipeline_instances,"m",_AggregatePipeline_pushStage).call(this,constant_1.PipelineStageName.sample,e),this}lookup(e){return __classPrivateFieldGet(this,_AggregatePipeline_instances,"m",_AggregatePipeline_pushStage).call(this,constant_1.PipelineStageName.lookup,e),this}done(){return __classPrivateFieldGet(this,_AggregatePipeline_pipeline,"f").map(e=>{switch(e.name){case constant_1.PipelineStageName.match:return{$match:new QueryRequest_1.QueryRequest(e.param).toJSON()};case constant_1.PipelineStageName.sample:case constant_1.PipelineStageName.lookup:return{[e.name]:e.param};case constant_1.PipelineStageName.group:return{$group:new AggregateRequest_1.AggregateRequest(e.param).toJSON()};default:{const t=e.name;throw error_1.DbBuildError.invalidParam(t,"\u4E0D\u652F\u6301\u7684 aggregate \u64CD\u4F5C")}}})}}exports.AggregatePipeline=AggregatePipeline,_AggregatePipeline_pipeline=new WeakMap,_AggregatePipeline_instances=new WeakSet,_AggregatePipeline_pushStage=function(e,t){__classPrivateFieldGet(this,_AggregatePipeline_pipeline,"f").push({name:e,param:t})};

lib/command/AggregateRequest.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AggregateRequest=void 0;const error_1=require("../common/error"),AbstractCommand_1=require("./AbstractCommand");class AggregateRequest{data;prefix;constructor(r,t=""){this.data=r,this.prefix=t}stringify(){if(this.data instanceof AbstractCommand_1.AbstractCommand){if(!(this.data instanceof AbstractCommand_1.AggregateCommand))throw error_1.DbBuildError.invalidCommand("Command \u4E0D\u662F\u805A\u5408\u64CD\u4F5C");return this.data.stringify()}if(this.data===null)return this.data;if(Array.isArray(this.data))return this.data.map((r,t)=>new AggregateRequest(r,`${this.prefix}.$.${t}`).stringify());switch(typeof this.data){case"number":return this.data;case"boolean":return this.data;case"string":return this.data;case"bigint":return this.data;case"function":throw error_1.DbBuildError.invalidParam(this.prefix,"\u4E0D\u652F\u6301\u51FD\u6570");case"symbol":throw error_1.DbBuildError.invalidParam(this.prefix,"\u4E0D\u652F\u6301 symbol");case"undefined":throw error_1.DbBuildError.invalidParam(this.prefix,"\u4E0D\u652F\u6301 undefined");default:{const r={};for(const t in this.data){const a=this.prefix?`${this.prefix}.${t}`:t,i=this.data[t],e=new AggregateRequest(i,a);r[t]=e.stringify()}return r}}}toJSON(){return this.stringify()}}exports.AggregateRequest=AggregateRequest;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AggregateRequest=void 0;const error_1=require("../common/error"),AbstractCommand_1=require("./AbstractCommand");class AggregateRequest{constructor(r,t=""){this.data=r,this.prefix=t}stringify(){if(this.data instanceof AbstractCommand_1.AbstractCommand){if(!(this.data instanceof AbstractCommand_1.AggregateCommand))throw error_1.DbBuildError.invalidCommand("Command \u4E0D\u662F\u805A\u5408\u64CD\u4F5C");return this.data.stringify()}if(this.data===null)return this.data;if(Array.isArray(this.data))return this.data.map((r,t)=>new AggregateRequest(r,`${this.prefix}.$.${t}`).stringify());switch(typeof this.data){case"number":return this.data;case"boolean":return this.data;case"string":return this.data;case"bigint":return this.data;case"function":throw error_1.DbBuildError.invalidParam(this.prefix,"\u4E0D\u652F\u6301\u51FD\u6570");case"symbol":throw error_1.DbBuildError.invalidParam(this.prefix,"\u4E0D\u652F\u6301 symbol");case"undefined":throw error_1.DbBuildError.invalidParam(this.prefix,"\u4E0D\u652F\u6301 undefined");default:{const r={};for(const t in this.data){const i=this.prefix?`${this.prefix}.${t}`:t,a=this.data[t],e=new AggregateRequest(a,i);r[t]=e.stringify()}return r}}}toJSON(){return this.stringify()}}exports.AggregateRequest=AggregateRequest;

lib/command/index.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Command=exports.AggregateCommandFactory=void 0;const and_1=require("./aggregate/and"),avg_1=require("./aggregate/avg"),count_1=require("./aggregate/count"),eq_1=require("./aggregate/eq"),AggregatePipeline_1=require("./AggregatePipeline"),expr_1=require("./query/expr"),gt_1=require("./aggregate/gt"),gte_1=require("./aggregate/gte"),lt_1=require("./aggregate/lt"),lte_1=require("./aggregate/lte"),max_1=require("./aggregate/max"),min_1=require("./aggregate/min"),neq_1=require("./aggregate/neq"),or_1=require("./aggregate/or"),sum_1=require("./aggregate/sum"),set_1=require("./update/set"),inc_1=require("./update/inc"),QueryChain_1=require("./query/QueryChain"),or_2=require("./query/or"),and_2=require("./query/and"),util_1=require("./util"),not_1=require("./query/not"),nor_1=require("./query/nor"),eq_2=require("./query/eq"),neq_2=require("./query/neq"),lt_2=require("./query/lt"),lte_2=require("./query/lte"),gt_2=require("./query/gt"),gte_2=require("./query/gte"),in_1=require("./query/in"),nin_1=require("./query/nin"),exists_1=require("./query/exists"),mod_1=require("./query/mod"),all_1=require("./query/all"),elemMatch_1=require("./query/elemMatch"),size_1=require("./query/size");class AggregateCommandFactory{pipeline(){return new AggregatePipeline_1.AggregatePipeline}avg(e){return new avg_1.AvgAggregateCommand(e)}count(){return new count_1.CountAggregateCommand}max(e){return new max_1.MaxAggregateCommand(e)}min(e){return new min_1.MinAggregateCommand(e)}sum(e){return new sum_1.SumAggregateCommand(e)}and(...e){return e=Array.isArray(e[0])?e[0]:e,new and_1.AndAggregateCommand(e)}or(...e){return e=Array.isArray(e[0])?e[0]:e,new or_1.OrAggregateCommand(e)}eq(e){return new eq_1.EqAggregateCommand(e)}neq(e){return new neq_1.NeqAggregateCommand(e)}lt(e){return new lt_1.LtAggregateCommand(e)}lte(e){return new lte_1.LteAggregateCommand(e)}gt(e){return new gt_1.GtAggregateCommand(e)}gte(e){return new gte_1.GteAggregateCommand(e)}}exports.AggregateCommandFactory=AggregateCommandFactory;class Command{aggregate;constructor(){this.aggregate=new AggregateCommandFactory}set(e){return new set_1.SetCommand(e)}inc(e){return new inc_1.IncCommand(e)}expr(e){return new expr_1.ExprCommand(e)}and(...e){e=Array.isArray(e[0])?e[0]:e;const r=new and_2.AndCommand(e.map(util_1.CommandUtils.unchain));return new QueryChain_1.QueryChain(r)}or(...e){e=Array.isArray(e[0])?e[0]:e;const r=new or_2.OrCommand(e.map(util_1.CommandUtils.unchain));return new QueryChain_1.QueryChain(r)}not(e){const r=new not_1.NotCommand(util_1.CommandUtils.unchain(e));return new QueryChain_1.QueryChain(r)}nor(...e){e=Array.isArray(e[0])?e[0]:e;const r=new nor_1.NorCommand(e.map(util_1.CommandUtils.unchain));return new QueryChain_1.QueryChain(r)}eq(e){return new QueryChain_1.QueryChain(new eq_2.EqCommand(e))}neq(e){return new QueryChain_1.QueryChain(new neq_2.NeqCommand(e))}lt(e){return new QueryChain_1.QueryChain(new lt_2.LtCommand(e))}lte(e){return new QueryChain_1.QueryChain(new lte_2.LteCommand(e))}gt(e){return new QueryChain_1.QueryChain(new gt_2.GtCommand(e))}gte(e){return new QueryChain_1.QueryChain(new gte_2.GteCommand(e))}in(e){return new QueryChain_1.QueryChain(new in_1.InCommand(e))}nin(e){return new QueryChain_1.QueryChain(new nin_1.NinCommand(e))}exists(e){return new QueryChain_1.QueryChain(new exists_1.ExistsCommand(e))}mod(e,r){return new QueryChain_1.QueryChain(new mod_1.ModCommand(e,r))}all(e){return new QueryChain_1.QueryChain(new all_1.AllCommand(e))}elemMatch(e){return new QueryChain_1.QueryChain(new elemMatch_1.ElemMatchCommand(util_1.CommandUtils.unchain(e)))}size(e){return new QueryChain_1.QueryChain(new size_1.SizeCommand(e))}}exports.Command=Command;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Command=exports.AggregateCommandFactory=void 0;const and_1=require("./aggregate/and"),avg_1=require("./aggregate/avg"),count_1=require("./aggregate/count"),eq_1=require("./aggregate/eq"),AggregatePipeline_1=require("./AggregatePipeline"),expr_1=require("./query/expr"),gt_1=require("./aggregate/gt"),gte_1=require("./aggregate/gte"),lt_1=require("./aggregate/lt"),lte_1=require("./aggregate/lte"),max_1=require("./aggregate/max"),min_1=require("./aggregate/min"),neq_1=require("./aggregate/neq"),or_1=require("./aggregate/or"),sum_1=require("./aggregate/sum"),set_1=require("./update/set"),inc_1=require("./update/inc"),QueryChain_1=require("./query/QueryChain"),or_2=require("./query/or"),and_2=require("./query/and"),util_1=require("./util"),not_1=require("./query/not"),nor_1=require("./query/nor"),eq_2=require("./query/eq"),neq_2=require("./query/neq"),lt_2=require("./query/lt"),lte_2=require("./query/lte"),gt_2=require("./query/gt"),gte_2=require("./query/gte"),in_1=require("./query/in"),nin_1=require("./query/nin"),exists_1=require("./query/exists"),mod_1=require("./query/mod"),all_1=require("./query/all"),elemMatch_1=require("./query/elemMatch"),size_1=require("./query/size");class AggregateCommandFactory{pipeline(){return new AggregatePipeline_1.AggregatePipeline}avg(e){return new avg_1.AvgAggregateCommand(e)}count(){return new count_1.CountAggregateCommand}max(e){return new max_1.MaxAggregateCommand(e)}min(e){return new min_1.MinAggregateCommand(e)}sum(e){return new sum_1.SumAggregateCommand(e)}and(...e){return e=Array.isArray(e[0])?e[0]:e,new and_1.AndAggregateCommand(e)}or(...e){return e=Array.isArray(e[0])?e[0]:e,new or_1.OrAggregateCommand(e)}eq(e){return new eq_1.EqAggregateCommand(e)}neq(e){return new neq_1.NeqAggregateCommand(e)}lt(e){return new lt_1.LtAggregateCommand(e)}lte(e){return new lte_1.LteAggregateCommand(e)}gt(e){return new gt_1.GtAggregateCommand(e)}gte(e){return new gte_1.GteAggregateCommand(e)}}exports.AggregateCommandFactory=AggregateCommandFactory;class Command{constructor(){this.aggregate=new AggregateCommandFactory}set(e){return new set_1.SetCommand(e)}inc(e){return new inc_1.IncCommand(e)}expr(e){return new expr_1.ExprCommand(e)}and(...e){e=Array.isArray(e[0])?e[0]:e;const r=new and_2.AndCommand(e.map(util_1.CommandUtils.unchain));return new QueryChain_1.QueryChain(r)}or(...e){e=Array.isArray(e[0])?e[0]:e;const r=new or_2.OrCommand(e.map(util_1.CommandUtils.unchain));return new QueryChain_1.QueryChain(r)}not(e){const r=new not_1.NotCommand(util_1.CommandUtils.unchain(e));return new QueryChain_1.QueryChain(r)}nor(...e){e=Array.isArray(e[0])?e[0]:e;const r=new nor_1.NorCommand(e.map(util_1.CommandUtils.unchain));return new QueryChain_1.QueryChain(r)}eq(e){return new QueryChain_1.QueryChain(new eq_2.EqCommand(e))}neq(e){return new QueryChain_1.QueryChain(new neq_2.NeqCommand(e))}lt(e){return new QueryChain_1.QueryChain(new lt_2.LtCommand(e))}lte(e){return new QueryChain_1.QueryChain(new lte_2.LteCommand(e))}gt(e){return new QueryChain_1.QueryChain(new gt_2.GtCommand(e))}gte(e){return new QueryChain_1.QueryChain(new gte_2.GteCommand(e))}in(e){return new QueryChain_1.QueryChain(new in_1.InCommand(e))}nin(e){return new QueryChain_1.QueryChain(new nin_1.NinCommand(e))}exists(e){return new QueryChain_1.QueryChain(new exists_1.ExistsCommand(e))}mod(e,r){return new QueryChain_1.QueryChain(new mod_1.ModCommand(e,r))}all(e){return new QueryChain_1.QueryChain(new all_1.AllCommand(e))}elemMatch(e){return new QueryChain_1.QueryChain(new elemMatch_1.ElemMatchCommand(util_1.CommandUtils.unchain(e)))}size(e){return new QueryChain_1.QueryChain(new size_1.SizeCommand(e))}}exports.Command=Command;

lib/command/Operator.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Operator=void 0;class Operator{res;constructor(){this.res={}}set(s,e){this.res.$set=this.res.$set||{},this.res.$set[s]=e}applyOperator(s,e,t){this.res[s]=this.res[s]||{},this.res[s][e]=t}emit(){return this.res}}exports.Operator=Operator;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Operator=void 0;class Operator{constructor(){this.res={}}set(s,e){this.res.$set=this.res.$set||{},this.res.$set[s]=e}applyOperator(s,e,t){this.res[s]=this.res[s]||{},this.res[s][e]=t}emit(){return this.res}}exports.Operator=Operator;

lib/command/query/all.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AllCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class AllCommand extends AbstractCommand_1.QueryCommand{val;constructor(t){super(),this.val=t}stringify(){return{$all:this.val}}}exports.AllCommand=AllCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AllCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class AllCommand extends AbstractCommand_1.QueryCommand{constructor(t){super(),this.val=t}stringify(){return{$all:this.val}}}exports.AllCommand=AllCommand;

lib/command/query/and.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AndCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),util_1=require("../util");class AndCommand extends AbstractCommand_1.QueryCommand{commands;constructor(s){super(),this.commands=s.map(util_1.CommandUtils.stringify)}pushCommand(s){this.commands.push(util_1.CommandUtils.stringify(s))}stringify(){return{$and:this.commands}}}exports.AndCommand=AndCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AndCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),util_1=require("../util");class AndCommand extends AbstractCommand_1.QueryCommand{constructor(s){super(),this.commands=s.map(util_1.CommandUtils.stringify)}pushCommand(s){this.commands.push(util_1.CommandUtils.stringify(s))}stringify(){return{$and:this.commands}}}exports.AndCommand=AndCommand;

lib/command/query/elemMatch.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.ElemMatchCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),util_1=require("../util");class ElemMatchCommand extends AbstractCommand_1.QueryCommand{val;constructor(t){super(),this.val=util_1.CommandUtils.stringify(t)}stringify(){return{$elemMatch:this.val}}}exports.ElemMatchCommand=ElemMatchCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.ElemMatchCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),util_1=require("../util");class ElemMatchCommand extends AbstractCommand_1.QueryCommand{constructor(t){super(),this.val=util_1.CommandUtils.stringify(t)}stringify(){return{$elemMatch:this.val}}}exports.ElemMatchCommand=ElemMatchCommand;

lib/command/query/eq.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.EqCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class EqCommand extends AbstractCommand_1.QueryCommand{val;constructor(e){super(),this.val=e}stringify(){return{$eq:this.val}}}exports.EqCommand=EqCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.EqCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class EqCommand extends AbstractCommand_1.QueryCommand{constructor(e){super(),this.val=e}stringify(){return{$eq:this.val}}}exports.EqCommand=EqCommand;

lib/command/query/exists.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.ExistsCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class ExistsCommand extends AbstractCommand_1.QueryCommand{exists;constructor(s){super(),this.exists=s}stringify(){return{$exists:this.exists}}}exports.ExistsCommand=ExistsCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.ExistsCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class ExistsCommand extends AbstractCommand_1.QueryCommand{constructor(s){super(),this.exists=s}stringify(){return{$exists:this.exists}}}exports.ExistsCommand=ExistsCommand;

lib/command/query/expr.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.ExprCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class ExprCommand extends AbstractCommand_1.QueryCommand{commands;constructor(e){super(),this.commands=new AggregateRequest_1.AggregateRequest(e).toJSON()}stringify(){return{$expr:this.commands}}}exports.ExprCommand=ExprCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.ExprCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),AggregateRequest_1=require("../AggregateRequest");class ExprCommand extends AbstractCommand_1.QueryCommand{constructor(e){super(),this.commands=new AggregateRequest_1.AggregateRequest(e).toJSON()}stringify(){return{$expr:this.commands}}}exports.ExprCommand=ExprCommand;

lib/command/query/gt.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.GtCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class GtCommand extends AbstractCommand_1.QueryCommand{val;constructor(t){super(),this.val=t}stringify(){return{$gt:this.val}}}exports.GtCommand=GtCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.GtCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class GtCommand extends AbstractCommand_1.QueryCommand{constructor(t){super(),this.val=t}stringify(){return{$gt:this.val}}}exports.GtCommand=GtCommand;

lib/command/query/gte.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.GteCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class GteCommand extends AbstractCommand_1.QueryCommand{val;constructor(t){super(),this.val=t}stringify(){return{$gte:this.val}}}exports.GteCommand=GteCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.GteCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class GteCommand extends AbstractCommand_1.QueryCommand{constructor(t){super(),this.val=t}stringify(){return{$gte:this.val}}}exports.GteCommand=GteCommand;

lib/command/query/in.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.InCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class InCommand extends AbstractCommand_1.QueryCommand{val;constructor(t){super(),this.val=t}stringify(){return{$in:this.val}}}exports.InCommand=InCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.InCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class InCommand extends AbstractCommand_1.QueryCommand{constructor(t){super(),this.val=t}stringify(){return{$in:this.val}}}exports.InCommand=InCommand;

lib/command/query/lt.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.LtCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class LtCommand extends AbstractCommand_1.QueryCommand{val;constructor(t){super(),this.val=t}stringify(){return{$lt:this.val}}}exports.LtCommand=LtCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.LtCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class LtCommand extends AbstractCommand_1.QueryCommand{constructor(t){super(),this.val=t}stringify(){return{$lt:this.val}}}exports.LtCommand=LtCommand;

lib/command/query/lte.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.LteCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class LteCommand extends AbstractCommand_1.QueryCommand{val;constructor(t){super(),this.val=t}stringify(){return{$lte:this.val}}}exports.LteCommand=LteCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.LteCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class LteCommand extends AbstractCommand_1.QueryCommand{constructor(t){super(),this.val=t}stringify(){return{$lte:this.val}}}exports.LteCommand=LteCommand;

lib/command/query/mod.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.ModCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class ModCommand extends AbstractCommand_1.QueryCommand{divisor;remainder;constructor(r,e){super(),this.divisor=r,this.remainder=e}stringify(){return{$mod:[this.divisor,this.remainder]}}}exports.ModCommand=ModCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.ModCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class ModCommand extends AbstractCommand_1.QueryCommand{constructor(r,e){super(),this.divisor=r,this.remainder=e}stringify(){return{$mod:[this.divisor,this.remainder]}}}exports.ModCommand=ModCommand;

lib/command/query/neq.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.NeqCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class NeqCommand extends AbstractCommand_1.QueryCommand{val;constructor(e){super(),this.val=e}stringify(){return{$ne:this.val}}}exports.NeqCommand=NeqCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.NeqCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class NeqCommand extends AbstractCommand_1.QueryCommand{constructor(e){super(),this.val=e}stringify(){return{$ne:this.val}}}exports.NeqCommand=NeqCommand;

lib/command/query/nin.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.NinCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class NinCommand extends AbstractCommand_1.QueryCommand{val;constructor(t){super(),this.val=t}stringify(){return{$nin:this.val}}}exports.NinCommand=NinCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.NinCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class NinCommand extends AbstractCommand_1.QueryCommand{constructor(t){super(),this.val=t}stringify(){return{$nin:this.val}}}exports.NinCommand=NinCommand;

lib/command/query/nor.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.NorCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),util_1=require("../util");class NorCommand extends AbstractCommand_1.QueryCommand{commands;constructor(s){super(),this.commands=s.map(util_1.CommandUtils.stringify)}pushCommand(s){this.commands.push(util_1.CommandUtils.stringify(s))}stringify(){return{$nor:this.commands}}}exports.NorCommand=NorCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.NorCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),util_1=require("../util");class NorCommand extends AbstractCommand_1.QueryCommand{constructor(s){super(),this.commands=s.map(util_1.CommandUtils.stringify)}pushCommand(s){this.commands.push(util_1.CommandUtils.stringify(s))}stringify(){return{$nor:this.commands}}}exports.NorCommand=NorCommand;

lib/command/query/not.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.NotCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),util_1=require("../util");class NotCommand extends AbstractCommand_1.QueryCommand{command;constructor(t){super(),this.command=util_1.CommandUtils.stringify(t)}stringify(){return{$not:this.command.stringify()}}}exports.NotCommand=NotCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.NotCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),util_1=require("../util");class NotCommand extends AbstractCommand_1.QueryCommand{constructor(t){super(),this.command=util_1.CommandUtils.stringify(t)}stringify(){return{$not:this.command.stringify()}}}exports.NotCommand=NotCommand;

lib/command/query/or.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.OrCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),util_1=require("../util");class OrCommand extends AbstractCommand_1.QueryCommand{commands;constructor(s){super(),this.commands=s.map(util_1.CommandUtils.stringify)}pushCommand(s){this.commands.push(util_1.CommandUtils.stringify(s))}stringify(){return{$or:this.commands}}}exports.OrCommand=OrCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.OrCommand=void 0;const AbstractCommand_1=require("../AbstractCommand"),util_1=require("../util");class OrCommand extends AbstractCommand_1.QueryCommand{constructor(s){super(),this.commands=s.map(util_1.CommandUtils.stringify)}pushCommand(s){this.commands.push(util_1.CommandUtils.stringify(s))}stringify(){return{$or:this.commands}}}exports.OrCommand=OrCommand;

lib/command/query/QueryChain.d.ts

 import { QueryCommand } from '../AbstractCommand';
 export declare class QueryChain {
-    #private;
     lastCmd: QueryCommand;
@@ -5,0 +4,0 @@ constructor(cmd: QueryCommand);

lib/command/query/QueryChain.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.QueryChain=void 0;const and_1=require("./and"),or_1=require("./or"),eq_1=require("./eq"),neq_1=require("./neq"),lt_1=require("./lt"),lte_1=require("./lte"),gt_1=require("./gt"),gte_1=require("./gte"),in_1=require("./in"),nin_1=require("./nin"),exists_1=require("./exists"),mod_1=require("./mod"),all_1=require("./all"),elemMatch_1=require("./elemMatch"),util_1=require("../util");class QueryChain{lastCmd;constructor(t){this.lastCmd=t}#t(t){return t=util_1.CommandUtils.unchain(t),this.lastCmd instanceof and_1.AndCommand?this.lastCmd.pushCommand(t):this.lastCmd=new and_1.AndCommand([this.lastCmd,t]),this}and(t){return this.#t(t)}or(t){return t=util_1.CommandUtils.unchain(t),this.lastCmd instanceof or_1.OrCommand?this.lastCmd.pushCommand(t):this.lastCmd=new or_1.OrCommand([this.lastCmd,t]),this}not(t){return this.#t(t)}nor(t){return this.#t(t)}eq(t){return this.#t(new eq_1.EqCommand(t))}neq(t){return this.#t(new neq_1.NeqCommand(t))}lt(t){return this.#t(new lt_1.LtCommand(t))}lte(t){return this.#t(new lte_1.LteCommand(t))}gt(t){return this.#t(new gt_1.GtCommand(t))}gte(t){return this.#t(new gte_1.GteCommand(t))}in(t){return this.#t(new in_1.InCommand(t))}nin(t){return this.#t(new nin_1.NinCommand(t))}exists(t){return this.#t(new exists_1.ExistsCommand(t))}mod(t,e){return this.#t(new mod_1.ModCommand(t,e))}all(t){return this.#t(new all_1.AllCommand(t))}elemMatch(t){return this.#t(new elemMatch_1.ElemMatchCommand(util_1.CommandUtils.unchain(t)))}size(t){return this.#t(t)}}exports.QueryChain=QueryChain;
+"use strict";var __classPrivateFieldGet=this&&this.__classPrivateFieldGet||function(e,t,s,n){if(s==="a"&&!n)throw new TypeError("Private accessor was defined without a getter");if(typeof t=="function"?e!==t||!n:!t.has(e))throw new TypeError("Cannot read private member from an object whose class did not declare it");return s==="m"?n:s==="a"?n.call(e):n?n.value:t.get(e)},_QueryChain_instances,_QueryChain_appendCommand;Object.defineProperty(exports,"__esModule",{value:!0}),exports.QueryChain=void 0;const and_1=require("./and"),or_1=require("./or"),eq_1=require("./eq"),neq_1=require("./neq"),lt_1=require("./lt"),lte_1=require("./lte"),gt_1=require("./gt"),gte_1=require("./gte"),in_1=require("./in"),nin_1=require("./nin"),exists_1=require("./exists"),mod_1=require("./mod"),all_1=require("./all"),elemMatch_1=require("./elemMatch"),util_1=require("../util");class QueryChain{constructor(t){_QueryChain_instances.add(this),this.lastCmd=t}and(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,t)}or(t){return t=util_1.CommandUtils.unchain(t),this.lastCmd instanceof or_1.OrCommand?this.lastCmd.pushCommand(t):this.lastCmd=new or_1.OrCommand([this.lastCmd,t]),this}not(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,t)}nor(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,t)}eq(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,new eq_1.EqCommand(t))}neq(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,new neq_1.NeqCommand(t))}lt(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,new lt_1.LtCommand(t))}lte(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,new lte_1.LteCommand(t))}gt(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,new gt_1.GtCommand(t))}gte(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,new gte_1.GteCommand(t))}in(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,new in_1.InCommand(t))}nin(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,new nin_1.NinCommand(t))}exists(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,new exists_1.ExistsCommand(t))}mod(t,s){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,new mod_1.ModCommand(t,s))}all(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,new all_1.AllCommand(t))}elemMatch(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,new elemMatch_1.ElemMatchCommand(util_1.CommandUtils.unchain(t)))}size(t){return __classPrivateFieldGet(this,_QueryChain_instances,"m",_QueryChain_appendCommand).call(this,t)}}exports.QueryChain=QueryChain,_QueryChain_instances=new WeakSet,_QueryChain_appendCommand=function(t){return t=util_1.CommandUtils.unchain(t),this.lastCmd instanceof and_1.AndCommand?this.lastCmd.pushCommand(t):this.lastCmd=new and_1.AndCommand([this.lastCmd,t]),this};

lib/command/query/size.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.SizeCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class SizeCommand extends AbstractCommand_1.QueryCommand{val;constructor(e){super(),this.val=e}stringify(){return{$size:this.val}}}exports.SizeCommand=SizeCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.SizeCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class SizeCommand extends AbstractCommand_1.QueryCommand{constructor(e){super(),this.val=e}stringify(){return{$size:this.val}}}exports.SizeCommand=SizeCommand;

lib/command/QueryRequest.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.QueryRequest=void 0;const AbstractCommand_1=require("./AbstractCommand"),error_1=require("../common/error"),util_1=require("./util");class QueryRequest{query;prefix;constructor(t,r=""){this.query=t,this.prefix=r}stringify(){const t={},r=util_1.CommandUtils.unchain(this.query),e=typeof r;if(r instanceof AbstractCommand_1.QueryCommand)return r.stringify();if(Array.isArray(r))return r.map((i,s)=>new QueryRequest(i,`${this.prefix}.$.${s}`).stringify());if(e==="number")return r;if(e==="boolean")return r;if(e==="string")return r;if(e==="bigint")return r;if(e==="function")throw error_1.DbBuildError.invalidParam(this.prefix,"\u4E0D\u652F\u6301\u51FD\u6570");if(e==="symbol")throw error_1.DbBuildError.invalidParam(this.prefix,"\u4E0D\u652F\u6301 symbol");if(e==="undefined")throw error_1.DbBuildError.invalidParam(this.prefix,"\u4E0D\u652F\u6301 undefined");if(r===null)return r;for(const i in r){const s=this.prefix?`${this.prefix}.${i}`:i,n=r[i],o=new QueryRequest(n,s);t[i]=o.stringify()}return t}toJSON(){return this.stringify()}}exports.QueryRequest=QueryRequest;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.QueryRequest=void 0;const AbstractCommand_1=require("./AbstractCommand"),error_1=require("../common/error"),util_1=require("./util");class QueryRequest{constructor(t,r=""){this.query=t,this.prefix=r}stringify(){const t={},r=util_1.CommandUtils.unchain(this.query),e=typeof r;if(r instanceof AbstractCommand_1.QueryCommand)return r.stringify();if(Array.isArray(r))return r.map((i,s)=>new QueryRequest(i,`${this.prefix}.$.${s}`).stringify());if(e==="number")return r;if(e==="boolean")return r;if(e==="string")return r;if(e==="bigint")return r;if(e==="function")throw error_1.DbBuildError.invalidParam(this.prefix,"\u4E0D\u652F\u6301\u51FD\u6570");if(e==="symbol")throw error_1.DbBuildError.invalidParam(this.prefix,"\u4E0D\u652F\u6301 symbol");if(e==="undefined")throw error_1.DbBuildError.invalidParam(this.prefix,"\u4E0D\u652F\u6301 undefined");if(r===null)return r;for(const i in r){const s=this.prefix?`${this.prefix}.${i}`:i,n=r[i],o=new QueryRequest(n,s);t[i]=o.stringify()}return t}toJSON(){return this.stringify()}}exports.QueryRequest=QueryRequest;

lib/command/update/inc.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.IncCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class IncCommand extends AbstractCommand_1.UpdateCommand{num;constructor(t){super(),this.num=t}get operator(){return"$inc"}stringify(){return this.num}}exports.IncCommand=IncCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.IncCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class IncCommand extends AbstractCommand_1.UpdateCommand{constructor(t){super(),this.num=t}get operator(){return"$inc"}stringify(){return this.num}}exports.IncCommand=IncCommand;

lib/command/update/set.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.SetCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class SetCommand extends AbstractCommand_1.UpdateCommand{data;constructor(t){super(),this.data=t}get operator(){return"$set"}stringify(){return this.data}}exports.SetCommand=SetCommand;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.SetCommand=void 0;const AbstractCommand_1=require("../AbstractCommand");class SetCommand extends AbstractCommand_1.UpdateCommand{constructor(t){super(),this.data=t}get operator(){return"$set"}stringify(){return this.data}}exports.SetCommand=SetCommand;

lib/command/UpdateRequest.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.UpdateRequest=void 0;const error_1=require("../common/error"),AbstractCommand_1=require("./AbstractCommand"),Operator_1=require("./Operator");class UpdateRequest{data;prefix;constructor(e,s=""){this.data=e,this.prefix=s}stringify(e){e=e||new Operator_1.Operator;for(const s in this.data){const i=this.prefix?`${this.prefix}.${s}`:s,t=this.data[s],r=typeof t;if(t instanceof AbstractCommand_1.AbstractCommand){if(!(t instanceof AbstractCommand_1.UpdateCommand))throw error_1.DbBuildError.invalidCommand("Command \u4E0D\u662F\u66F4\u65B0\u64CD\u4F5C");e.applyOperator(t.operator,i,t.stringify())}else if(r==="number")e.set(i,t);else if(r==="boolean")e.set(i,t);else if(r==="string")e.set(i,t);else if(r==="bigint")e.set(i,t);else{if(r==="function")throw error_1.DbBuildError.invalidParam(i,"\u4E0D\u652F\u6301\u51FD\u6570");if(r==="symbol")throw error_1.DbBuildError.invalidParam(i,"\u4E0D\u652F\u6301 symbol");if(r==="undefined")throw error_1.DbBuildError.invalidParam(i,"\u4E0D\u652F\u6301 undefined");t===null||Array.isArray(t)?e.set(i,t):new UpdateRequest(t,i).stringify(e)}}return e}toJSON(){return this.stringify().emit()}}exports.UpdateRequest=UpdateRequest;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.UpdateRequest=void 0;const error_1=require("../common/error"),AbstractCommand_1=require("./AbstractCommand"),Operator_1=require("./Operator");class UpdateRequest{constructor(e,r=""){this.data=e,this.prefix=r}stringify(e){e=e||new Operator_1.Operator;for(const r in this.data){const i=this.prefix?`${this.prefix}.${r}`:r,t=this.data[r],s=typeof t;if(t instanceof AbstractCommand_1.AbstractCommand){if(!(t instanceof AbstractCommand_1.UpdateCommand))throw error_1.DbBuildError.invalidCommand("Command \u4E0D\u662F\u66F4\u65B0\u64CD\u4F5C");e.applyOperator(t.operator,i,t.stringify())}else if(s==="number")e.set(i,t);else if(s==="boolean")e.set(i,t);else if(s==="string")e.set(i,t);else if(s==="bigint")e.set(i,t);else{if(s==="function")throw error_1.DbBuildError.invalidParam(i,"\u4E0D\u652F\u6301\u51FD\u6570");if(s==="symbol")throw error_1.DbBuildError.invalidParam(i,"\u4E0D\u652F\u6301 symbol");if(s==="undefined")throw error_1.DbBuildError.invalidParam(i,"\u4E0D\u652F\u6301 undefined");t===null||Array.isArray(t)?e.set(i,t):new UpdateRequest(t,i).stringify(e)}}return e}toJSON(){return this.stringify().emit()}}exports.UpdateRequest=UpdateRequest;

lib/common/error.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.DbBuildError=exports.ErrorCode=void 0;var ErrorCode;(function(t){t.INVALID_PARAM="INVALID_PARAM",t.INVALID_COMMAND="INVALID_COMMAND"})(ErrorCode||(exports.ErrorCode=ErrorCode={}));class DbBuildError extends Error{code;static create(e,r){const o=new DbBuildError(r);return o.code=e,o}static invalidParam(e,r){return DbBuildError.create(ErrorCode.INVALID_PARAM,`\u65E0\u6548\u5165\u53C2 "${e}", ${r}`)}static invalidCommand(e){return DbBuildError.create(ErrorCode.INVALID_COMMAND,e)}}exports.DbBuildError=DbBuildError;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.DbBuildError=exports.ErrorCode=void 0;var ErrorCode;(function(t){t.INVALID_PARAM="INVALID_PARAM",t.INVALID_COMMAND="INVALID_COMMAND"})(ErrorCode||(exports.ErrorCode=ErrorCode={}));class DbBuildError extends Error{static create(r,e){const o=new DbBuildError(e);return o.code=r,o}static invalidParam(r,e){return DbBuildError.create(ErrorCode.INVALID_PARAM,`\u65E0\u6548\u5165\u53C2 "${r}", ${e}`)}static invalidCommand(r){return DbBuildError.create(ErrorCode.INVALID_COMMAND,r)}}exports.DbBuildError=DbBuildError;

lib/mongo-builder/Aggregate.d.ts

 import { AggregatePipeline } from '../command/AggregatePipeline';
 import type { MongoDocumentOperation } from '../typing';
 export declare class AggregateBuilder extends AggregatePipeline {
-    #private;
     constructor(collectionName: string);
     end(): MongoDocumentOperation;
 }

lib/mongo-builder/Aggregate.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AggregateBuilder=void 0;const AggregatePipeline_1=require("../command/AggregatePipeline"),constant_1=require("../common/constant"),util_1=require("../common/util");class AggregateBuilder extends AggregatePipeline_1.AggregatePipeline{#e;constructor(e){super(),this.#e=e}end(){const e={$aggregate:this.done()};return util_1.ActionBuilder.buildDocumentAction(constant_1.DocumentAction.aggregate,this.#e,e)}}exports.AggregateBuilder=AggregateBuilder;
+"use strict";var __classPrivateFieldSet=this&&this.__classPrivateFieldSet||function(t,e,o,r,i){if(r==="m")throw new TypeError("Private method is not writable");if(r==="a"&&!i)throw new TypeError("Private accessor was defined without a setter");if(typeof e=="function"?t!==e||!i:!e.has(t))throw new TypeError("Cannot write private member to an object whose class did not declare it");return r==="a"?i.call(t,o):i?i.value=o:e.set(t,o),o},__classPrivateFieldGet=this&&this.__classPrivateFieldGet||function(t,e,o,r){if(o==="a"&&!r)throw new TypeError("Private accessor was defined without a getter");if(typeof e=="function"?t!==e||!r:!e.has(t))throw new TypeError("Cannot read private member from an object whose class did not declare it");return o==="m"?r:o==="a"?r.call(t):r?r.value:e.get(t)},_AggregateBuilder_collectionName;Object.defineProperty(exports,"__esModule",{value:!0}),exports.AggregateBuilder=void 0;const AggregatePipeline_1=require("../command/AggregatePipeline"),constant_1=require("../common/constant"),util_1=require("../common/util");class AggregateBuilder extends AggregatePipeline_1.AggregatePipeline{constructor(e){super(),_AggregateBuilder_collectionName.set(this,void 0),__classPrivateFieldSet(this,_AggregateBuilder_collectionName,e,"f")}end(){const e={$aggregate:this.done()};return util_1.ActionBuilder.buildDocumentAction(constant_1.DocumentAction.aggregate,__classPrivateFieldGet(this,_AggregateBuilder_collectionName,"f"),e)}}exports.AggregateBuilder=AggregateBuilder,_AggregateBuilder_collectionName=new WeakMap;

lib/mongo-builder/Collection.d.ts

@@ -7,3 +7,2 @@ import { Sort } from '../common/constant';
 export declare class CollectionBuilder {
-    #private;
     constructor(collectionName: string);
@@ -10,0 +9,0 @@ add(param: AddDocumentParam): MongoDocumentOperation;

lib/mongo-builder/Collection.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.CollectionBuilder=void 0;const constant_1=require("../common/constant"),error_1=require("../common/error"),util_1=require("../common/util"),Aggregate_1=require("./Aggregate"),Document_1=require("./Document"),Query_1=require("./Query");class CollectionBuilder{#e;constructor(e){this.#e=e}add(e){return Array.isArray(e.data)?this.batchAdd(e):util_1.ActionBuilder.buildDocumentAction(constant_1.DocumentAction.create,this.#e,e.data)}batchAdd(e){if(e.data.length>200)throw error_1.DbBuildError.invalidParam("data","\u6700\u5927\u957F\u5EA6 200");const r={$create:e.data};return typeof e.ordered=="boolean"&&(r.$ordered=e.ordered),util_1.ActionBuilder.buildDocumentAction(constant_1.DocumentAction.batchCreate,this.#e,r)}doc(e){return new Document_1.DocumentBuilder(this.#e,e)}limit(e){return new Query_1.QueryBuilder(this.#e).limit(e)}skip(e){return new Query_1.QueryBuilder(this.#e).skip(e)}where(e){return new Query_1.QueryBuilder(this.#e).where(e)}projection(e){return new Query_1.QueryBuilder(this.#e).projection(e)}orderBy(e,r){return new Query_1.QueryBuilder(this.#e).orderBy(e,r)}aggregate(){return new Aggregate_1.AggregateBuilder(this.#e)}get(){return new Query_1.QueryBuilder(this.#e).get()}count(){return new Query_1.QueryBuilder(this.#e).count()}}exports.CollectionBuilder=CollectionBuilder;
+"use strict";var __classPrivateFieldSet=this&&this.__classPrivateFieldSet||function(t,e,r,o,i){if(o==="m")throw new TypeError("Private method is not writable");if(o==="a"&&!i)throw new TypeError("Private accessor was defined without a setter");if(typeof e=="function"?t!==e||!i:!e.has(t))throw new TypeError("Cannot write private member to an object whose class did not declare it");return o==="a"?i.call(t,r):i?i.value=r:e.set(t,r),r},__classPrivateFieldGet=this&&this.__classPrivateFieldGet||function(t,e,r,o){if(r==="a"&&!o)throw new TypeError("Private accessor was defined without a getter");if(typeof e=="function"?t!==e||!o:!e.has(t))throw new TypeError("Cannot read private member from an object whose class did not declare it");return r==="m"?o:r==="a"?o.call(t):o?o.value:e.get(t)},_CollectionBuilder_collectionName;Object.defineProperty(exports,"__esModule",{value:!0}),exports.CollectionBuilder=void 0;const constant_1=require("../common/constant"),error_1=require("../common/error"),util_1=require("../common/util"),Aggregate_1=require("./Aggregate"),Document_1=require("./Document"),Query_1=require("./Query");class CollectionBuilder{constructor(e){_CollectionBuilder_collectionName.set(this,void 0),__classPrivateFieldSet(this,_CollectionBuilder_collectionName,e,"f")}add(e){return Array.isArray(e.data)?this.batchAdd(e):util_1.ActionBuilder.buildDocumentAction(constant_1.DocumentAction.create,__classPrivateFieldGet(this,_CollectionBuilder_collectionName,"f"),e.data)}batchAdd(e){if(e.data.length>200)throw error_1.DbBuildError.invalidParam("data","\u6700\u5927\u957F\u5EA6 200");const r={$create:e.data};return typeof e.ordered=="boolean"&&(r.$ordered=e.ordered),util_1.ActionBuilder.buildDocumentAction(constant_1.DocumentAction.batchCreate,__classPrivateFieldGet(this,_CollectionBuilder_collectionName,"f"),r)}doc(e){return new Document_1.DocumentBuilder(__classPrivateFieldGet(this,_CollectionBuilder_collectionName,"f"),e)}limit(e){return new Query_1.QueryBuilder(__classPrivateFieldGet(this,_CollectionBuilder_collectionName,"f")).limit(e)}skip(e){return new Query_1.QueryBuilder(__classPrivateFieldGet(this,_CollectionBuilder_collectionName,"f")).skip(e)}where(e){return new Query_1.QueryBuilder(__classPrivateFieldGet(this,_CollectionBuilder_collectionName,"f")).where(e)}projection(e){return new Query_1.QueryBuilder(__classPrivateFieldGet(this,_CollectionBuilder_collectionName,"f")).projection(e)}orderBy(e,r){return new Query_1.QueryBuilder(__classPrivateFieldGet(this,_CollectionBuilder_collectionName,"f")).orderBy(e,r)}aggregate(){return new Aggregate_1.AggregateBuilder(__classPrivateFieldGet(this,_CollectionBuilder_collectionName,"f"))}get(){return new Query_1.QueryBuilder(__classPrivateFieldGet(this,_CollectionBuilder_collectionName,"f")).get()}count(){return new Query_1.QueryBuilder(__classPrivateFieldGet(this,_CollectionBuilder_collectionName,"f")).count()}}exports.CollectionBuilder=CollectionBuilder,_CollectionBuilder_collectionName=new WeakMap;

lib/mongo-builder/Document.d.ts

 import type { MongoDocumentOperation, UpdateData } from '../typing';
 export declare class DocumentBuilder {
-    #private;
     constructor(collectionName: string, id: string);
@@ -5,0 +4,0 @@ update(data: UpdateData): MongoDocumentOperation;

lib/mongo-builder/Document.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.DocumentBuilder=void 0;const constant_1=require("../common/constant"),Query_1=require("./Query");class DocumentBuilder{#e;#t;constructor(e,t){this.#t=e,this.#e=t}update(e){return new Query_1.QueryBuilder(this.#t).where({_id:String(this.#e)}).limit(1).update(e)}set(e){return new Query_1.QueryBuilder(this.#t).where({_id:String(this.#e)}).limit(1).set(e)}remove(){return new Query_1.QueryBuilder(this.#t).where({_id:String(this.#e)}).limit(1).remove()}get(){const t=new Query_1.QueryBuilder(this.#t).where({_id:String(this.#e)}).limit(1).get();return t.action=constant_1.DocumentAction.query,t}}exports.DocumentBuilder=DocumentBuilder;
+"use strict";var __classPrivateFieldSet=this&&this.__classPrivateFieldSet||function(r,e,t,i,o){if(i==="m")throw new TypeError("Private method is not writable");if(i==="a"&&!o)throw new TypeError("Private accessor was defined without a setter");if(typeof e=="function"?r!==e||!o:!e.has(r))throw new TypeError("Cannot write private member to an object whose class did not declare it");return i==="a"?o.call(r,t):o?o.value=t:e.set(r,t),t},__classPrivateFieldGet=this&&this.__classPrivateFieldGet||function(r,e,t,i){if(t==="a"&&!i)throw new TypeError("Private accessor was defined without a getter");if(typeof e=="function"?r!==e||!i:!e.has(r))throw new TypeError("Cannot read private member from an object whose class did not declare it");return t==="m"?i:t==="a"?i.call(r):i?i.value:e.get(r)},_DocumentBuilder_id,_DocumentBuilder_collectionName;Object.defineProperty(exports,"__esModule",{value:!0}),exports.DocumentBuilder=void 0;const constant_1=require("../common/constant"),Query_1=require("./Query");class DocumentBuilder{constructor(e,t){_DocumentBuilder_id.set(this,void 0),_DocumentBuilder_collectionName.set(this,void 0),__classPrivateFieldSet(this,_DocumentBuilder_collectionName,e,"f"),__classPrivateFieldSet(this,_DocumentBuilder_id,t,"f")}update(e){return new Query_1.QueryBuilder(__classPrivateFieldGet(this,_DocumentBuilder_collectionName,"f")).where({_id:String(__classPrivateFieldGet(this,_DocumentBuilder_id,"f"))}).limit(1).update(e)}set(e){return new Query_1.QueryBuilder(__classPrivateFieldGet(this,_DocumentBuilder_collectionName,"f")).where({_id:String(__classPrivateFieldGet(this,_DocumentBuilder_id,"f"))}).limit(1).set(e)}remove(){return new Query_1.QueryBuilder(__classPrivateFieldGet(this,_DocumentBuilder_collectionName,"f")).where({_id:String(__classPrivateFieldGet(this,_DocumentBuilder_id,"f"))}).limit(1).remove()}get(){const t=new Query_1.QueryBuilder(__classPrivateFieldGet(this,_DocumentBuilder_collectionName,"f")).where({_id:String(__classPrivateFieldGet(this,_DocumentBuilder_id,"f"))}).limit(1).get();return t.action=constant_1.DocumentAction.query,t}}exports.DocumentBuilder=DocumentBuilder,_DocumentBuilder_id=new WeakMap,_DocumentBuilder_collectionName=new WeakMap;

lib/mongo-builder/index.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.MongoBuilder=void 0;const command_1=require("../command"),constant_1=require("../common/constant"),util_1=require("../common/util"),Collection_1=require("./Collection");class MongoBuilder{command;constructor(){this.command=new command_1.Command}collection(o){return new Collection_1.CollectionBuilder(o)}createCollection(o){return util_1.ActionBuilder.buildCollectionAction(constant_1.CollectionAction.create,o)}getCollection(o){return util_1.ActionBuilder.buildCollectionAction(constant_1.CollectionAction.query,o)}listCollection(o,e){return util_1.ActionBuilder.buildCollectionListQueryAction({$limit:o??10,$skip:e??0})}deleteCollection(o){return util_1.ActionBuilder.buildCollectionAction(constant_1.CollectionAction.delete,o)}}exports.MongoBuilder=MongoBuilder;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.MongoBuilder=void 0;const command_1=require("../command"),constant_1=require("../common/constant"),util_1=require("../common/util"),Collection_1=require("./Collection");class MongoBuilder{constructor(){this.command=new command_1.Command}collection(o){return new Collection_1.CollectionBuilder(o)}createCollection(o){return util_1.ActionBuilder.buildCollectionAction(constant_1.CollectionAction.create,o)}getCollection(o){return util_1.ActionBuilder.buildCollectionAction(constant_1.CollectionAction.query,o)}listCollection(o,e){return util_1.ActionBuilder.buildCollectionListQueryAction({$limit:o??10,$skip:e??0})}deleteCollection(o){return util_1.ActionBuilder.buildCollectionAction(constant_1.CollectionAction.delete,o)}}exports.MongoBuilder=MongoBuilder;

lib/mongo-builder/Query.d.ts

 import { Sort } from '../common/constant';
 import type { MongoDocumentOperation, QueryChainCommand, UpdateData } from '../typing';
 export declare class QueryBuilder {
-    #private;
     constructor(collectionName: string);
@@ -6,0 +5,0 @@ limit(limit: number): QueryBuilder;

lib/mongo-builder/Query.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.QueryBuilder=void 0;const QueryRequest_1=require("../command/QueryRequest"),UpdateRequest_1=require("../command/UpdateRequest"),constant_1=require("../common/constant"),util_1=require("../common/util");class QueryBuilder{#s;#r;#u;#i;#n;#o;constructor(t){this.#o=t,this.#i=[]}limit(t){return this.#r=t,this}skip(t){return this.#u=t,this}where(t){return this.#s=t,this}projection(t){for(const e in t)t[e]?typeof t[e]!="object"&&(t[e]=1):t[e]=0;return this.#n=t,this}orderBy(t,e){return this.#i.push({field:t,sort:e}),this}update(t){return this.#e(constant_1.DocumentAction.update,{...this.#t(),$update:new UpdateRequest_1.UpdateRequest(t.data).toJSON()})}set(t){return this.#e(constant_1.DocumentAction.replace,{...this.#t(),$replace:t.data})}remove(){return this.#e(constant_1.DocumentAction.delete,this.#t())}get(){return this.#e(constant_1.DocumentAction.queryList,{$limit:100,...this.#c()})}count(){return this.#e(constant_1.DocumentAction.count,this.#t())}#t(){const t={};if(typeof this.#s<"u"){const e=new QueryRequest_1.QueryRequest(this.#s);t.$match=e.toJSON()}return typeof this.#r<"u"&&(t.$limit=this.#r),t}#c(){const t=this.#t();if(typeof this.#n<"u"&&(t.$project=this.#n),typeof this.#i<"u"){t.$sort={};for(const e of this.#i)t.$sort[e.field]=e.sort===constant_1.Sort.DESC?-1:1}return typeof this.#u<"u"&&(t.$skip=this.#u),t}#e(t,e){return util_1.ActionBuilder.buildDocumentAction(t,this.#o,e)}}exports.QueryBuilder=QueryBuilder;
+"use strict";var __classPrivateFieldSet=this&&this.__classPrivateFieldSet||function(i,t,e,s,r){if(s==="m")throw new TypeError("Private method is not writable");if(s==="a"&&!r)throw new TypeError("Private accessor was defined without a setter");if(typeof t=="function"?i!==t||!r:!t.has(i))throw new TypeError("Cannot write private member to an object whose class did not declare it");return s==="a"?r.call(i,e):r?r.value=e:t.set(i,e),e},__classPrivateFieldGet=this&&this.__classPrivateFieldGet||function(i,t,e,s){if(e==="a"&&!s)throw new TypeError("Private accessor was defined without a getter");if(typeof t=="function"?i!==t||!s:!t.has(i))throw new TypeError("Cannot read private member from an object whose class did not declare it");return e==="m"?s:e==="a"?s.call(i):s?s.value:t.get(i)},_QueryBuilder_instances,_QueryBuilder_match,_QueryBuilder_limit,_QueryBuilder_skip,_QueryBuilder_sort,_QueryBuilder_projection,_QueryBuilder_collectionName,_QueryBuilder_baseOptions,_QueryBuilder_findOptions,_QueryBuilder_build;Object.defineProperty(exports,"__esModule",{value:!0}),exports.QueryBuilder=void 0;const QueryRequest_1=require("../command/QueryRequest"),UpdateRequest_1=require("../command/UpdateRequest"),constant_1=require("../common/constant"),util_1=require("../common/util");class QueryBuilder{constructor(t){_QueryBuilder_instances.add(this),_QueryBuilder_match.set(this,void 0),_QueryBuilder_limit.set(this,void 0),_QueryBuilder_skip.set(this,void 0),_QueryBuilder_sort.set(this,void 0),_QueryBuilder_projection.set(this,void 0),_QueryBuilder_collectionName.set(this,void 0),__classPrivateFieldSet(this,_QueryBuilder_collectionName,t,"f"),__classPrivateFieldSet(this,_QueryBuilder_sort,[],"f")}limit(t){return __classPrivateFieldSet(this,_QueryBuilder_limit,t,"f"),this}skip(t){return __classPrivateFieldSet(this,_QueryBuilder_skip,t,"f"),this}where(t){return __classPrivateFieldSet(this,_QueryBuilder_match,t,"f"),this}projection(t){for(const e in t)t[e]?typeof t[e]!="object"&&(t[e]=1):t[e]=0;return __classPrivateFieldSet(this,_QueryBuilder_projection,t,"f"),this}orderBy(t,e){return __classPrivateFieldGet(this,_QueryBuilder_sort,"f").push({field:t,sort:e}),this}update(t){return __classPrivateFieldGet(this,_QueryBuilder_instances,"m",_QueryBuilder_build).call(this,constant_1.DocumentAction.update,Object.assign(Object.assign({},__classPrivateFieldGet(this,_QueryBuilder_instances,"m",_QueryBuilder_baseOptions).call(this)),{$update:new UpdateRequest_1.UpdateRequest(t.data).toJSON()}))}set(t){return __classPrivateFieldGet(this,_QueryBuilder_instances,"m",_QueryBuilder_build).call(this,constant_1.DocumentAction.replace,Object.assign(Object.assign({},__classPrivateFieldGet(this,_QueryBuilder_instances,"m",_QueryBuilder_baseOptions).call(this)),{$replace:t.data}))}remove(){return __classPrivateFieldGet(this,_QueryBuilder_instances,"m",_QueryBuilder_build).call(this,constant_1.DocumentAction.delete,__classPrivateFieldGet(this,_QueryBuilder_instances,"m",_QueryBuilder_baseOptions).call(this))}get(){return __classPrivateFieldGet(this,_QueryBuilder_instances,"m",_QueryBuilder_build).call(this,constant_1.DocumentAction.queryList,Object.assign({$limit:100},__classPrivateFieldGet(this,_QueryBuilder_instances,"m",_QueryBuilder_findOptions).call(this)))}count(){return __classPrivateFieldGet(this,_QueryBuilder_instances,"m",_QueryBuilder_build).call(this,constant_1.DocumentAction.count,__classPrivateFieldGet(this,_QueryBuilder_instances,"m",_QueryBuilder_baseOptions).call(this))}}exports.QueryBuilder=QueryBuilder,_QueryBuilder_match=new WeakMap,_QueryBuilder_limit=new WeakMap,_QueryBuilder_skip=new WeakMap,_QueryBuilder_sort=new WeakMap,_QueryBuilder_projection=new WeakMap,_QueryBuilder_collectionName=new WeakMap,_QueryBuilder_instances=new WeakSet,_QueryBuilder_baseOptions=function(){const t={};if(typeof __classPrivateFieldGet(this,_QueryBuilder_match,"f")<"u"){const e=new QueryRequest_1.QueryRequest(__classPrivateFieldGet(this,_QueryBuilder_match,"f"));t.$match=e.toJSON()}return typeof __classPrivateFieldGet(this,_QueryBuilder_limit,"f")<"u"&&(t.$limit=__classPrivateFieldGet(this,_QueryBuilder_limit,"f")),t},_QueryBuilder_findOptions=function(){const t=__classPrivateFieldGet(this,_QueryBuilder_instances,"m",_QueryBuilder_baseOptions).call(this);if(typeof __classPrivateFieldGet(this,_QueryBuilder_projection,"f")<"u"&&(t.$project=__classPrivateFieldGet(this,_QueryBuilder_projection,"f")),typeof __classPrivateFieldGet(this,_QueryBuilder_sort,"f")<"u"){t.$sort={};for(const e of __classPrivateFieldGet(this,_QueryBuilder_sort,"f"))t.$sort[e.field]=e.sort===constant_1.Sort.DESC?-1:1}return typeof __classPrivateFieldGet(this,_QueryBuilder_skip,"f")<"u"&&(t.$skip=__classPrivateFieldGet(this,_QueryBuilder_skip,"f")),t},_QueryBuilder_build=function(t,e){return util_1.ActionBuilder.buildDocumentAction(t,__classPrivateFieldGet(this,_QueryBuilder_collectionName,"f"),e)};

package.json

 {
   "name": "@alipay/faas-db-builder",
-  "version": "1.1.9",
+  "version": "1.1.10-alpha.0",
   "description": "db builder",
@@ -11,3 +11,4 @@ "main": "lib/index.js",
     "lint": "eslint src test --cache --fix --ext ts",
-    "build": "tsc -p ./tsconfig.json && minimize-js lib",
+    "build": "tspc -p ./tsconfig.json && minimize-js lib",
+    "dev": "tspc -p ./tsconfig.json",
     "clean": "tsc --build --clean",
@@ -29,2 +30,3 @@ "test": "egg-bin test",
     "mm": "^3.2.1",
+    "ts-patch": "^3.0.1",
     "typescript": "^5.0.4"
@@ -31,0 +33,0 @@ },

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Minified code

Quality

This package contains minified code. This may be harmless in some cases where minified code is included in packaged libraries, however packages on npm should not minify code.

Found 1 instance in 1 package

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Minified code

Quality

This package contains minified code. This may be harmless in some cases where minified code is included in packaged libraries, however packages on npm should not minify code.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

66414

increased by19.18%

Worsened metrics

Dev dependency count

10

increased by11.11%

Lines of code

548

decreased by-1.08%

Number of low quality alerts

49

increased by2.08%

No dependency changes