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

Comparing version 1.1.1 to 1.1.2-alpha.0

lib/common/constant.d.ts

@@ -30,3 +30,4 @@ export declare enum Sort {
     group = "$group",
-    sample = "$sample"
+    sample = "$sample",
+    lookup = "$lookup"
 }

lib/common/constant.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.PipelineStageName=exports.Target=exports.DocumentAction=exports.CollectionAction=exports.Sort=void 0;var Sort;(function(e){e.DESC="desc",e.ASC="asc"})(Sort||(exports.Sort=Sort={}));var CollectionAction;(function(e){e.update="update",e.delete="delete",e.query="query",e.queryList="queryList",e.create="create"})(CollectionAction||(exports.CollectionAction=CollectionAction={}));var DocumentAction;(function(e){e.update="update",e.replace="replace",e.delete="delete",e.query="query",e.queryList="queryList",e.create="create",e.batchCreate="batchCreate",e.count="count",e.aggregate="aggregate"})(DocumentAction||(exports.DocumentAction=DocumentAction={}));var Target;(function(e){e.collection="collection",e.document="document"})(Target||(exports.Target=Target={}));var PipelineStageName;(function(e){e.match="$match",e.group="$group",e.sample="$sample"})(PipelineStageName||(exports.PipelineStageName=PipelineStageName={}));
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.PipelineStageName=exports.Target=exports.DocumentAction=exports.CollectionAction=exports.Sort=void 0;var Sort;(function(e){e.DESC="desc",e.ASC="asc"})(Sort||(exports.Sort=Sort={}));var CollectionAction;(function(e){e.update="update",e.delete="delete",e.query="query",e.queryList="queryList",e.create="create"})(CollectionAction||(exports.CollectionAction=CollectionAction={}));var DocumentAction;(function(e){e.update="update",e.replace="replace",e.delete="delete",e.query="query",e.queryList="queryList",e.create="create",e.batchCreate="batchCreate",e.count="count",e.aggregate="aggregate"})(DocumentAction||(exports.DocumentAction=DocumentAction={}));var Target;(function(e){e.collection="collection",e.document="document"})(Target||(exports.Target=Target={}));var PipelineStageName;(function(e){e.match="$match",e.group="$group",e.sample="$sample",e.lookup="$lookup"})(PipelineStageName||(exports.PipelineStageName=PipelineStageName={}));

lib/mongo-builder/Aggregate.d.ts

@@ -0,1 +1,2 @@
+import { LookupAggregateParam } from '../typing';
 import type { MongoDocumentOperation, QueryChainCommand, SampleAggregateParam } from '../typing';
@@ -8,3 +9,4 @@ export declare class AggregateBuilder {
     sample(sample: SampleAggregateParam): AggregateBuilder;
+    lookup(lookup: LookupAggregateParam): AggregateBuilder;
     end(): MongoDocumentOperation;
 }

lib/mongo-builder/Aggregate.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AggregateBuilder=void 0;const AggregateRequest_1=require("../command/AggregateRequest"),QueryRequest_1=require("../command/QueryRequest"),constant_1=require("../common/constant"),error_1=require("../common/error"),util_1=require("../common/util");class AggregateBuilder{#r;#e;constructor(e){this.#r=e,this.#e=[]}match(e){return this.#t(constant_1.PipelineStageName.match,e),this}group(e){return this.#t(constant_1.PipelineStageName.group,e),this}sample(e){return this.#t(constant_1.PipelineStageName.sample,e),this}end(){const r={$aggregate:this.#e.map(t=>{switch(t.name){case constant_1.PipelineStageName.match:return{$match:new QueryRequest_1.QueryRequest(t.param).toJSON()};case constant_1.PipelineStageName.sample:return{$sample:t.param};case constant_1.PipelineStageName.group:return{$group:new AggregateRequest_1.AggregateRequest(t.param).toJSON()};default:{const a=t.name;throw error_1.DbBuildError.invalidParam(a,"\u4E0D\u652F\u6301\u7684 aggregate \u64CD\u4F5C")}}})};return util_1.ActionBuilder.buildDocumentAction(constant_1.DocumentAction.aggregate,this.#r,r)}#t(e,r){this.#e.push({name:e,param:r})}}exports.AggregateBuilder=AggregateBuilder;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.AggregateBuilder=void 0;const AggregateRequest_1=require("../command/AggregateRequest"),QueryRequest_1=require("../command/QueryRequest"),constant_1=require("../common/constant"),error_1=require("../common/error"),util_1=require("../common/util");class AggregateBuilder{#r;#t;constructor(e){this.#r=e,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}end(){const r={$aggregate:this.#t.map(t=>{switch(t.name){case constant_1.PipelineStageName.match:return{$match:new QueryRequest_1.QueryRequest(t.param).toJSON()};case constant_1.PipelineStageName.sample:case constant_1.PipelineStageName.lookup:return{[t.name]:t.param};case constant_1.PipelineStageName.group:return{$group:new AggregateRequest_1.AggregateRequest(t.param).toJSON()};default:{const a=t.name;throw error_1.DbBuildError.invalidParam(a,"\u4E0D\u652F\u6301\u7684 aggregate \u64CD\u4F5C")}}})};return util_1.ActionBuilder.buildDocumentAction(constant_1.DocumentAction.aggregate,this.#r,r)}#e(e,r){this.#t.push({name:e,param:r})}}exports.AggregateBuilder=AggregateBuilder;

lib/typing.d.ts

@@ -58,1 +58,7 @@ import { QueryCommand } from './command/AbstractCommand';
 }
+export interface LookupAggregateParam {
+    from: string;
+    localField: string;
+    foreignField: string;
+    as: string;
+}

package.json

 {
   "name": "@alipay/faas-db-builder",
-  "version": "1.1.1",
+  "version": "1.1.2-alpha.0",
   "description": "db builder",
@@ -5,0 +5,0 @@ "main": "lib/index.js",

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

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

Improved metrics

Total package byte prevSize

46743

increased by0.86%

Lines of code

452

increased by2.03%

Worsened metrics

Number of low quality alerts

39

increased by2.63%

No dependency changes