@alipay/faas-server-sdk - npm Package Compare versions

Comparing version 0.0.22 to 0.0.23

lib/Database/Collection.d.ts

 import { CloudConfig } from '../types';
 import { Document } from './Document';
+import { Query, Sort } from './Query';
 export declare class Collection {
@@ -8,2 +9,7 @@ #private;
     doc(_id: string): Document;
+    limit(limit: number): Query;
+    skip(skip: number): Query;
+    where(match: object): Query;
+    projection(projection: object): Query;
+    orderBy(field: string, sort: Sort): Query;
 }
@@ -10,0 +16,0 @@ export type DocumentData = {

lib/Database/Collection.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Collection=void 0;const errors_1=require("../errors"),Document_1=require("./Document"),middlewares_1=require("../requester/middlewares");class Collection{#t;#e;constructor(t,e){this.#e=e,this.#t=t}async add(t){const e="POST",r=this.#s(t.data._id),s=await middlewares_1.HttpRequester.database.request(e,r,t.data,{},{cloudConfig:this.#t});if(!s.succeed)throw errors_1.errors.SYS_ERR(s.errMsg);return s.data}doc(t){return new Document_1.Document(this.#e,t,this.#t)}#s(t){return t||(t=""),`${this.#t.functionDatabaseEndpoint}/${this.#t.functionDatabaseName||"faas"}/${this.#e}?_id=${t}`}}exports.Collection=Collection;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Collection=void 0;const errors_1=require("../errors"),Document_1=require("./Document"),middlewares_1=require("../requester/middlewares"),utils_1=require("../utils"),Query_1=require("./Query");class Collection{#e;#t;constructor(e,t){this.#t=t,this.#e=e}async add(e){const t="POST",s=this.#r(e.data._id),i=(0,utils_1.getAlipayContext)();e.data._openid=e.data._openid||i.OPENID;const r=await middlewares_1.HttpRequester.database.request(t,s,e.data,{},{cloudConfig:this.#e});if(!r.succeed)throw errors_1.errors.SYS_ERR(r.errMsg);return r.data}doc(e){return new Document_1.Document(this.#t,e,this.#e)}limit(e){return new Query_1.Query(this.#t,this.#e).limit(e)}skip(e){return new Query_1.Query(this.#t,this.#e).skip(e)}where(e){return new Query_1.Query(this.#t,this.#e).where(e)}projection(e){return new Query_1.Query(this.#t,this.#e).projection(e)}orderBy(e,t){return new Query_1.Query(this.#t,this.#e).orderBy(e,t)}#r(e){return e||(e=""),`${this.#e.functionDatabaseEndpoint}/${this.#e.functionDatabaseName||"faas"}/${this.#t}?_id=${e}`}}exports.Collection=Collection;

lib/Database/Document.d.ts

 import { CloudConfig, DeleteResult, UpdateResult } from '../types';
+export interface UpdateData {
+    data: object;
+}
 export declare class Document {
     #private;
     constructor(collectionName: string, id: string, config: CloudConfig);
-    update(data: object): Promise<UpdateResult>;
+    update(data: UpdateData): Promise<UpdateResult>;
+    set(data: UpdateData): Promise<UpdateResult>;
     remove(): Promise<DeleteResult>;
-    get(): Promise<object>;
+    get<T>(): Promise<T>;
 }

lib/Database/Document.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Document=void 0;const errors_1=require("../errors"),middlewares_1=require("../requester/middlewares");class Document{#t;#e;#r;constructor(e,s,r){this.#t=r,this.#r=e,this.#e=s}async update(e){const s="POST",r=`${this.#s()}?update`,t={$match:{_id:this.#e},$update:e},o=await middlewares_1.HttpRequester.database.request(s,r,t,{},{cloudConfig:this.#t});if(!o.succeed)throw errors_1.errors.SYS_ERR(o.errMsg);return o.data}async remove(){const e="POST",s=`${this.#s()}?delete`,r={$match:{_id:this.#e},$limit:1},t=await middlewares_1.HttpRequester.database.request(e,s,r,{},{cloudConfig:this.#t});if(!t.succeed)throw errors_1.errors.SYS_ERR(t.errMsg);return t.data}async get(){const e="POST",s=`${this.#s()}?query`,r={$match:{_id:this.#e}},t=await middlewares_1.HttpRequester.database.request(e,s,r,{},{cloudConfig:this.#t});if(!t.succeed)throw errors_1.errors.SYS_ERR(t.errMsg);const o=t.data[0];if(!o)throw errors_1.errors.NOT_FOUND(`document with _id ${this.#e} does not exist`);return o}#s(){return`${this.#t.functionDatabaseEndpoint}/${this.#t.functionDatabaseName||"faas"}/${this.#r}`}}exports.Document=Document;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Document=void 0;const errors_1=require("../errors"),Query_1=require("./Query");class Document{#t;#e;#r;constructor(e,t,r){this.#t=r,this.#r=e,this.#e=t}async update(e){return await new Query_1.Query(this.#r,this.#t).where({_id:String(this.#e)}).limit(1).update(e)}async set(e){return await new Query_1.Query(this.#r,this.#t).where({_id:String(this.#e)}).limit(1).set(e)}async remove(){return await new Query_1.Query(this.#r,this.#t).where({_id:String(this.#e)}).limit(1).remove()}async get(){const r=(await new Query_1.Query(this.#r,this.#t).where({_id:String(this.#e)}).limit(1).get())[0];if(!r)throw errors_1.errors.NOT_FOUND(`document with _id ${this.#e} does not exist`);return r}}exports.Document=Document;

lib/Database/index.d.ts

 import { CloudConfig, CollectionDescription, DeleteResult } from '../types';
 import { Collection } from './Collection';
+import { Command } from './command';
 export declare class Database {
     #private;
+    command: Command;
     constructor(config: CloudConfig);
@@ -6,0 +8,0 @@ collection(collectionName: string): Collection;

lib/Database/index.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Database=void 0;const Collection_1=require("./Collection"),errors_1=require("../errors"),middlewares_1=require("../requester/middlewares");class Database{#t;constructor(t){this.#t=t}collection(t){return new Collection_1.Collection(this.#t,t)}#s(){return`${this.#t.functionDatabaseEndpoint}/${this.#t.functionDatabaseName||"faas"}`}#e(t){return`${this.#s()}/${t}`}async createCollection(t){const s="PUT",r=this.#e(t),e=await middlewares_1.HttpRequester.database.request(s,r,{},{},{cloudConfig:this.#t});if(!e.succeed)throw errors_1.errors.SYS_ERR(e.errMsg);return e.data}async getCollection(t){const s="GET",r=this.#e(t),e=await middlewares_1.HttpRequester.database.request(s,r,{},{},{cloudConfig:this.#t});if(!e.succeed)throw errors_1.errors.SYS_ERR(e.errMsg);return e.data}async listCollection(t,s){const r="POST",e=`${this.#s()}?list`,a={limit:t??10,skip:s??0},o=await middlewares_1.HttpRequester.database.request(r,e,a,{},{cloudConfig:this.#t});if(!o.succeed)throw errors_1.errors.SYS_ERR(o.errMsg);return o.data}async deleteCollection(t){const s="DELETE",r=this.#e(t),e=await middlewares_1.HttpRequester.database.request(s,r,{},{},{cloudConfig:this.#t});if(!e.succeed)throw errors_1.errors.SYS_ERR(e.errMsg);return e.data}}exports.Database=Database;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Database=void 0;const Collection_1=require("./Collection"),errors_1=require("../errors"),middlewares_1=require("../requester/middlewares"),command_1=require("./command");class Database{#t;command;constructor(t){this.#t=t,this.command=new command_1.Command}collection(t){return new Collection_1.Collection(this.#t,t)}#s(){return`${this.#t.functionDatabaseEndpoint}/${this.#t.functionDatabaseName||"faas"}`}#e(t){return`${this.#s()}/${t}`}async createCollection(t){const s="PUT",r=this.#e(t),e=await middlewares_1.HttpRequester.database.request(s,r,{},{},{cloudConfig:this.#t});if(!e.succeed)throw errors_1.errors.SYS_ERR(e.errMsg);return e.data}async getCollection(t){const s="GET",r=this.#e(t),e=await middlewares_1.HttpRequester.database.request(s,r,{},{},{cloudConfig:this.#t});if(!e.succeed)throw errors_1.errors.SYS_ERR(e.errMsg);return e.data}async listCollection(t,s){const r="POST",e=`${this.#s()}?list`,a={limit:t??10,skip:s??0},o=await middlewares_1.HttpRequester.database.request(r,e,a,{},{cloudConfig:this.#t});if(!o.succeed)throw errors_1.errors.SYS_ERR(o.errMsg);return o.data}async deleteCollection(t){const s="DELETE",r=this.#e(t),e=await middlewares_1.HttpRequester.database.request(s,r,{},{},{cloudConfig:this.#t});if(!e.succeed)throw errors_1.errors.SYS_ERR(e.errMsg);return e.data}}exports.Database=Database;

package.json

 {
   "name": "@alipay/faas-server-sdk",
-  "version": "0.0.22",
+  "version": "0.0.23",
   "description": "云函数服务 SDK",
@@ -35,4 +35,4 @@ "main": "lib/index.js",
   "dependencies": {
+    "ali-rds": "^5.1.2",
     "koa-compose": "^4.1.0",
-    "ali-rds": "^5.1.2",
     "urllib": "^3.11.0"
@@ -48,3 +48,4 @@ },
     "access": "public"
-  }
+  },
+  "gitHead": "928d8b518830335295aee3fb112780c6a222e61d"
 }

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 3 instances 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

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

37793

increased by32.65%

Number of package files

56

increased by40%

Lines of code

345

increased by31.68%

Number of medium supply chain risk alerts

0

decreased by-100%

Worsened metrics

Number of low quality alerts

21

increased by40%

No dependency changes