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

Comparing version 0.0.26 to 0.0.27

lib/callFunction.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.callFunction=void 0;const errors_1=require("./errors"),middlewares_1=require("./requester/middlewares");async function callFunction(t,r){if(!r.name)throw errors_1.errors.INVALID_PARAM("name","\u51FD\u6570\u540D\u4E0D\u80FD\u4E3A\u7A7A");const n="POST",o=buildUrl(t),s={"x-to-function-name":r.name},e=await middlewares_1.HttpRequester.function.request(n,o,r.data,s,{cloudConfig:t});if(e.succeed)return{requestId:e.requestId,requestID:e.requestId,result:e.data};throw errors_1.errors.CALL_FUNCTION_ERR(e)}exports.callFunction=callFunction;function buildUrl(t){return`http://${t.functionGatewayVip}/functions/invokeFunction`}
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.callFunction=void 0;const errors_1=require("./errors"),middlewares_1=require("./requester/middlewares");async function callFunction(t,r){if(!r.name)throw errors_1.errors.INVALID_PARAM("name","\u51FD\u6570\u540D\u4E0D\u80FD\u4E3A\u7A7A");const n={"x-to-function-name":r.name},o="POST",s=buildUrl(t),u={requestData:r.data},e=await middlewares_1.HttpRequester.function.request(o,s,u,n,{cloudConfig:t});if(e.succeed)return{requestId:e.requestId,requestID:e.requestId,result:e.data};throw errors_1.errors.CALL_FUNCTION_ERR(e)}exports.callFunction=callFunction;function buildUrl(t){return`${t.functionGatewayEndpoint}/functions/invokeFunction`}

lib/Cloud.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Cloud=exports.initRuntimeEnv=void 0;const callFunction_1=require("./callFunction"),Database_1=require("./Database"),MySQL_1=require("./MySQL"),utils_1=require("./utils"),runtimeEnv={RUNTIME_ACCESS_KEY:process.env.RUNTIME_ACCESS_KEY||"",RUNTIME_SECRET_KEY:process.env.RUNTIME_SECRET_KEY||"",RUNTIME_ENV_ID:process.env.RUNTIME_ENV_ID||"",RUNTIME_FUNCTION_NAME:process.env.RUNTIME_FUNCTION_NAME||"",RUNTIME_FUNCTION_GATEWAY_VIP:process.env.RUNTIME_FUNCTION_GATEWAY_VIP||"",RUNTIME_FUNCTION_INSTANCE_ID:process.env.RUNTIME_FUNCTION_INSTANCE_ID||"",RUNTIME_MONGO_CLUSTER_ENDPOINT:process.env.RUNTIME_MONGO_CLUSTER_ENDPOINT||"",RUNTIME_MONGO_DATABASE_NAME:process.env.RUNTIME_MONGO_DATABASE_NAME||""};function initRuntimeEnv(E){Object.assign(runtimeEnv,E)}exports.initRuntimeEnv=initRuntimeEnv;class Cloud{#N;#E;#_;constructor(){this.refreshConfig()}refreshConfig(){this.#N?(runtimeEnv.RUNTIME_ACCESS_KEY&&(this.#N.secretId=runtimeEnv.RUNTIME_ACCESS_KEY),runtimeEnv.RUNTIME_SECRET_KEY&&(this.#N.secretKey=runtimeEnv.RUNTIME_SECRET_KEY),runtimeEnv.RUNTIME_ENV_ID&&(this.#N.fromEnvId=runtimeEnv.RUNTIME_ENV_ID,this.#N.toEnvId||(this.#N.toEnvId=runtimeEnv.RUNTIME_ENV_ID)),runtimeEnv.RUNTIME_FUNCTION_NAME&&(this.#N.functionName=runtimeEnv.RUNTIME_FUNCTION_NAME),runtimeEnv.RUNTIME_FUNCTION_GATEWAY_VIP&&(this.#N.functionGatewayVip=runtimeEnv.RUNTIME_FUNCTION_GATEWAY_VIP),runtimeEnv.RUNTIME_FUNCTION_INSTANCE_ID&&(this.#N.functionInstanceId=runtimeEnv.RUNTIME_FUNCTION_INSTANCE_ID),runtimeEnv.RUNTIME_MONGO_CLUSTER_ENDPOINT&&(this.#N.functionDatabaseEndpoint=runtimeEnv.RUNTIME_MONGO_CLUSTER_ENDPOINT),runtimeEnv.RUNTIME_MONGO_DATABASE_NAME&&(this.#N.functionDatabaseName=runtimeEnv.RUNTIME_MONGO_DATABASE_NAME)):this.#N={secretId:runtimeEnv.RUNTIME_ACCESS_KEY,secretKey:runtimeEnv.RUNTIME_SECRET_KEY,fromEnvId:runtimeEnv.RUNTIME_ENV_ID,toEnvId:runtimeEnv.RUNTIME_ENV_ID,functionName:runtimeEnv.RUNTIME_FUNCTION_NAME,functionGatewayVip:runtimeEnv.RUNTIME_FUNCTION_GATEWAY_VIP,functionInstanceId:runtimeEnv.RUNTIME_FUNCTION_INSTANCE_ID,functionDatabaseEndpoint:runtimeEnv.RUNTIME_MONGO_CLUSTER_ENDPOINT,functionDatabaseName:runtimeEnv.RUNTIME_MONGO_DATABASE_NAME}}init(N){N?.env&&typeof N?.env=="string"&&(this.#N.toEnvId=N.env),N?.envId&&(this.#N.toEnvId=N.envId)}getAlipayContext(){return(0,utils_1.getAlipayContext)()}async callFunction(N){return await(0,callFunction_1.callFunction)(this.#N,N)}database(){return this.#E||(this.#E=new Database_1.Database(this.#N)),this.#E}mysql(){return this.#_||(this.#_=new MySQL_1.MySQL(this.#N)),this.#_}}exports.Cloud=Cloud;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Cloud=exports.initRuntimeEnv=void 0;const callFunction_1=require("./callFunction"),Database_1=require("./Database"),MySQL_1=require("./MySQL"),utils_1=require("./utils"),runtimeEnv={RUNTIME_ACCESS_KEY:process.env.RUNTIME_ACCESS_KEY||"",RUNTIME_SECRET_KEY:process.env.RUNTIME_SECRET_KEY||"",RUNTIME_ENV_ID:process.env.RUNTIME_ENV_ID||"",RUNTIME_FUNCTION_NAME:process.env.RUNTIME_FUNCTION_NAME||"",RUNTIME_FUNCTION_GATEWAY_ENDPOINT:process.env.RUNTIME_FUNCTION_GATEWAY_ENDPOINT||"",RUNTIME_FUNCTION_INSTANCE_ID:process.env.RUNTIME_FUNCTION_INSTANCE_ID||"",RUNTIME_MONGO_CLUSTER_ENDPOINT:process.env.RUNTIME_MONGO_CLUSTER_ENDPOINT||"",RUNTIME_MONGO_DATABASE_NAME:process.env.RUNTIME_MONGO_DATABASE_NAME||""};function initRuntimeEnv(E){Object.assign(runtimeEnv,E)}exports.initRuntimeEnv=initRuntimeEnv;class Cloud{#N;#E;#_;constructor(){this.refreshConfig()}refreshConfig(){this.#N?(runtimeEnv.RUNTIME_ACCESS_KEY&&(this.#N.secretId=runtimeEnv.RUNTIME_ACCESS_KEY),runtimeEnv.RUNTIME_SECRET_KEY&&(this.#N.secretKey=runtimeEnv.RUNTIME_SECRET_KEY),runtimeEnv.RUNTIME_ENV_ID&&(this.#N.fromEnvId=runtimeEnv.RUNTIME_ENV_ID,this.#N.toEnvId||(this.#N.toEnvId=runtimeEnv.RUNTIME_ENV_ID)),runtimeEnv.RUNTIME_FUNCTION_NAME&&(this.#N.functionName=runtimeEnv.RUNTIME_FUNCTION_NAME),runtimeEnv.RUNTIME_FUNCTION_GATEWAY_ENDPOINT&&(this.#N.functionGatewayEndpoint=runtimeEnv.RUNTIME_FUNCTION_GATEWAY_ENDPOINT),runtimeEnv.RUNTIME_FUNCTION_INSTANCE_ID&&(this.#N.functionInstanceId=runtimeEnv.RUNTIME_FUNCTION_INSTANCE_ID),runtimeEnv.RUNTIME_MONGO_CLUSTER_ENDPOINT&&(this.#N.functionDatabaseEndpoint=runtimeEnv.RUNTIME_MONGO_CLUSTER_ENDPOINT),runtimeEnv.RUNTIME_MONGO_DATABASE_NAME&&(this.#N.functionDatabaseName=runtimeEnv.RUNTIME_MONGO_DATABASE_NAME)):this.#N={secretId:runtimeEnv.RUNTIME_ACCESS_KEY,secretKey:runtimeEnv.RUNTIME_SECRET_KEY,fromEnvId:runtimeEnv.RUNTIME_ENV_ID,toEnvId:runtimeEnv.RUNTIME_ENV_ID,functionName:runtimeEnv.RUNTIME_FUNCTION_NAME,functionGatewayEndpoint:runtimeEnv.RUNTIME_FUNCTION_GATEWAY_ENDPOINT,functionInstanceId:runtimeEnv.RUNTIME_FUNCTION_INSTANCE_ID,functionDatabaseEndpoint:runtimeEnv.RUNTIME_MONGO_CLUSTER_ENDPOINT,functionDatabaseName:runtimeEnv.RUNTIME_MONGO_DATABASE_NAME}}init(N){N?.env&&typeof N?.env=="string"&&(this.#N.toEnvId=N.env),N?.envId&&(this.#N.toEnvId=N.envId)}getAlipayContext(){return(0,utils_1.getAlipayContext)()}async callFunction(N){return await(0,callFunction_1.callFunction)(this.#N,N)}database(){return this.#E||(this.#E=new Database_1.Database(this.#N)),this.#E}mysql(){return this.#_||(this.#_=new MySQL_1.MySQL(this.#N)),this.#_}}exports.Cloud=Cloud;

lib/Database/command/UpdateRequest.js

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

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"),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;
+"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;

lib/index.d.ts

 import { Cloud } from './Cloud';
 declare const cloud: Cloud;
 export * from './types';
-export type { CloudInitOptions } from './Cloud';
+export type { CloudInitOptions, initRuntimeEnv } from './Cloud';
+export type { sign, SignOptions } from './sign';
+export type { getAlipayContextStorage, getAlipayContext } from './utils';
 export default cloud;
 export { Cloud };

lib/index.js

@@ -1,1 +0,1 @@
-"use strict";var __createBinding=this&&this.__createBinding||(Object.create?function(o,t,e,r){r===void 0&&(r=e);var u=Object.getOwnPropertyDescriptor(t,e);(!u||("get"in u?!t.__esModule:u.writable||u.configurable))&&(u={enumerable:!0,get:function(){return t[e]}}),Object.defineProperty(o,r,u)}:function(o,t,e,r){r===void 0&&(r=e),o[r]=t[e]}),__exportStar=this&&this.__exportStar||function(o,t){for(var e in o)e!=="default"&&!Object.prototype.hasOwnProperty.call(t,e)&&__createBinding(t,o,e)};Object.defineProperty(exports,"__esModule",{value:!0}),exports.Cloud=void 0;const Cloud_1=require("./Cloud");Object.defineProperty(exports,"Cloud",{enumerable:!0,get:function(){return Cloud_1.Cloud}});const cloud=new Cloud_1.Cloud;__exportStar(require("./types"),exports),exports.default=cloud,module.exports=cloud,module.exports.Cloud=Cloud_1.Cloud;
+"use strict";var __createBinding=this&&this.__createBinding||(Object.create?function(o,t,e,r){r===void 0&&(r=e);var i=Object.getOwnPropertyDescriptor(t,e);(!i||("get"in i?!t.__esModule:i.writable||i.configurable))&&(i={enumerable:!0,get:function(){return t[e]}}),Object.defineProperty(o,r,i)}:function(o,t,e,r){r===void 0&&(r=e),o[r]=t[e]}),__exportStar=this&&this.__exportStar||function(o,t){for(var e in o)e!=="default"&&!Object.prototype.hasOwnProperty.call(t,e)&&__createBinding(t,o,e)};Object.defineProperty(exports,"__esModule",{value:!0}),exports.Cloud=void 0;const Cloud_1=require("./Cloud");Object.defineProperty(exports,"Cloud",{enumerable:!0,get:function(){return Cloud_1.Cloud}});const utils_1=require("./utils"),sign_1=require("./sign"),cloud=new Cloud_1.Cloud;__exportStar(require("./types"),exports),exports.default=cloud,module.exports=cloud,module.exports.Cloud=Cloud_1.Cloud,module.exports.sign=sign_1.sign,module.exports.getAlipayContextStorage=utils_1.getAlipayContextStorage,module.exports.initRuntimeEnv=Cloud_1.initRuntimeEnv,module.exports.getAlipayContext=utils_1.getAlipayContext;

lib/requester/middlewares/call_function_middleware.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.callFunctionMiddleware=void 0;async function callFunctionMiddleware(e,r){await r();const s=e.requestId;e.res.status!==200?e.result={succeed:!1,status:e.res.status,requestId:s,errCode:-1,errMsg:`code = -1, msg = ${e.res.data.errMsg}`}:e.result={succeed:!0,status:e.res.status,requestId:s,data:e.res.data.result}}exports.callFunctionMiddleware=callFunctionMiddleware;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.callFunctionMiddleware=void 0;async function callFunctionMiddleware(e,r){await r();const s=e.requestId;e.res.status!==200?e.result={succeed:!1,status:e.res.status,requestId:s,errCode:-1,errMsg:`code = ${e.res.data.errCode}, msg = ${e.res.data.errMsg}`}:e.result={succeed:!0,status:e.res.status,requestId:s,data:e.res.data.result}}exports.callFunctionMiddleware=callFunctionMiddleware;

lib/requester/middlewares/index.d.ts

 /// <reference types="node" />
+import { IncomingHttpHeaders } from 'node:http';
 import { HttpMethod } from 'urllib';
-import { IncomingHttpHeaders } from 'node:http';
 import type { Middleware } from 'koa-compose';
@@ -5,0 +5,0 @@ import { CloudConfig, HttpRequestResult } from '../../types';

lib/requester/middlewares/index.js

@@ -1,1 +0,1 @@
-"use strict";var __importDefault=this&&this.__importDefault||function(t){return t&&t.__esModule?t:{default:t}};Object.defineProperty(exports,"__esModule",{value:!0}),exports.HttpRequester=void 0;const assert_1=__importDefault(require("assert")),koa_compose_1=__importDefault(require("koa-compose")),HttpRequestContext_1=require("./HttpRequestContext"),call_database_middleware_1=require("./call_database_middleware"),call_function_middleware_1=require("./call_function_middleware"),call_middleware_1=require("./call_middleware"),sign_middleware_factory_1=require("./sign_middleware_factory"),init_call_database_headers_middleware_1=require("./init_call_database_headers_middleware"),node_crypto_1=require("node:crypto"),error_handler_middleware_1=require("./error_handler_middleware");class HttpRequester{static#e;static#t;#r;constructor(e){this.#r=(0,koa_compose_1.default)(e)}async request(e,s,n,r,d){const a=d?.cloudConfig;(0,assert_1.default)(a,"cloud config not set");const o=JSON.stringify(n),l=(0,node_crypto_1.randomUUID)();r["x-request-id"]=l;const c={method:e,contentType:"application/json",content:o,dataType:"json",headers:r},u={url:new URL(s),requestOptions:c},i=new HttpRequestContext_1.HttpRequestContext(u,a);return await this.#r(i),i.result}static get function(){if(!this.#e){const e=[error_handler_middleware_1.errorHandlerMiddleware,(0,sign_middleware_factory_1.signMiddlewareFactory)(["x-to-function-name"]),call_function_middleware_1.callFunctionMiddleware,call_middleware_1.callMiddleware];this.#e=new HttpRequester(e)}return this.#e}static get database(){if(!this.#t){const e=[error_handler_middleware_1.errorHandlerMiddleware,init_call_database_headers_middleware_1.initCallDatabaseHeadersMiddleware,(0,sign_middleware_factory_1.signMiddlewareFactory)(["x-data-api-type","x-expire-timestamp"]),call_database_middleware_1.callDatabaseMiddleware,call_middleware_1.callMiddleware];this.#t=new HttpRequester(e)}return this.#t}}exports.HttpRequester=HttpRequester;
+"use strict";var __importDefault=this&&this.__importDefault||function(t){return t&&t.__esModule?t:{default:t}};Object.defineProperty(exports,"__esModule",{value:!0}),exports.HttpRequester=void 0;const node_assert_1=__importDefault(require("node:assert")),koa_compose_1=__importDefault(require("koa-compose")),HttpRequestContext_1=require("./HttpRequestContext"),call_database_middleware_1=require("./call_database_middleware"),call_function_middleware_1=require("./call_function_middleware"),call_middleware_1=require("./call_middleware"),sign_middleware_factory_1=require("./sign_middleware_factory"),init_call_database_headers_middleware_1=require("./init_call_database_headers_middleware"),node_crypto_1=require("node:crypto"),error_handler_middleware_1=require("./error_handler_middleware");class HttpRequester{static#e;static#t;#r;constructor(e){this.#r=(0,koa_compose_1.default)(e)}async request(e,s,n,r,d){const a=d?.cloudConfig;(0,node_assert_1.default)(a,"cloud config not set");const o=JSON.stringify(n),l=(0,node_crypto_1.randomUUID)();r["x-request-id"]=l;const c={method:e,contentType:"application/json",content:o,dataType:"json",headers:r},_={url:new URL(s),requestOptions:c},i=new HttpRequestContext_1.HttpRequestContext(_,a);return await this.#r(i),i.result}static get function(){if(!this.#e){const e=[error_handler_middleware_1.errorHandlerMiddleware,(0,sign_middleware_factory_1.signMiddlewareFactory)(["x-to-function-name"]),call_function_middleware_1.callFunctionMiddleware,call_middleware_1.callMiddleware];this.#e=new HttpRequester(e)}return this.#e}static get database(){if(!this.#t){const e=[error_handler_middleware_1.errorHandlerMiddleware,init_call_database_headers_middleware_1.initCallDatabaseHeadersMiddleware,(0,sign_middleware_factory_1.signMiddlewareFactory)(["x-data-api-type","x-expire-timestamp"]),call_database_middleware_1.callDatabaseMiddleware,call_middleware_1.callMiddleware];this.#t=new HttpRequester(e)}return this.#t}}exports.HttpRequester=HttpRequester;

lib/requester/middlewares/sign_middleware_factory.js

@@ -1,1 +0,1 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.signMiddlewareFactory=void 0;const utils_1=require("../../utils"),sign_1=require("../../sign");function signMiddlewareFactory(t){return async function(e,o){const n=(0,utils_1.getAlipayContext)(),r=Date.now(),i={authorization:"","x-from-app-id":n.APPID,"x-from-env-id":e.config.fromEnvId,"x-to-env-id":e.config.toEnvId,"x-from-instance-id":e.config.functionInstanceId,"x-from-function-name":e.config.functionName,"x-client-timestamp":`${r}`,"x-trace-id":n.TRACEID,"sofa-rpcid":`${n.RPCID}.${++n.rpcCount}`},s=["x-from-app-id","x-from-env-id","x-from-instance-id","x-from-function-name","x-client-timestamp","x-to-env-id",...t].sort(),a={path:e.req.url.pathname,query:e.req.url.search,secretId:e.config.secretId,secretKey:e.config.secretKey,method:e.req.requestOptions.method,headers:i,body:e.req.requestOptions.content,timestamp:r,signedHeaders:s};i.authorization=(0,sign_1.sign)(a),e.req.requestOptions.headers={...i,...e.req.requestOptions.headers},await o()}}exports.signMiddlewareFactory=signMiddlewareFactory;
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.signMiddlewareFactory=void 0;const utils_1=require("../../utils"),sign_1=require("../../sign");function signMiddlewareFactory(t){return async function(e,s){const n=(0,utils_1.getAlipayContext)(),i=Date.now(),r={authorization:"","x-from-app-id":n.APPID,"x-from-env-id":e.config.fromEnvId,"x-to-env-id":e.config.toEnvId,"x-from-instance-id":e.config.functionInstanceId,"x-from-function-name":e.config.functionName,"x-client-timestamp":`${i}`,"x-trace-id":n.TRACEID,"sofa-rpcid":`${n.RPCID}.${++n.rpcCount}`};t.length>0&&t.forEach(o=>{r[o]=e.req.requestOptions.headers?.[o]});const a=["x-from-app-id","x-from-env-id","x-from-instance-id","x-from-function-name","x-client-timestamp","x-to-env-id",...t].sort(),d={path:e.req.url.pathname,query:e.req.url.search,secretId:e.config.secretId,secretKey:e.config.secretKey,method:e.req.requestOptions.method,headers:r,body:e.req.requestOptions.content,timestamp:i,signedHeaders:a};r.authorization=(0,sign_1.sign)(d),e.req.requestOptions.headers={...r,...e.req.requestOptions.headers},await s()}}exports.signMiddlewareFactory=signMiddlewareFactory;

lib/sign.js

@@ -1,2 +0,2 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.SignOptions=exports.sign=void 0;const node_crypto_1=require("node:crypto");function sign(e){const s=e.signedHeaders.join(",");let t="";for(const a of e.signedHeaders){const u=e.headers[a];t+=`${a}:${u}
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.SignOptions=exports.sign=void 0;const node_crypto_1=require("node:crypto");function sign(e){const s=e.signedHeaders.join(";");let t="";for(const a of e.signedHeaders){const u=e.headers[a];t+=`${a}:${u}
 `}const n=getHash(e.body||""),d=e.method.toUpperCase()+`
@@ -3,0 +3,0 @@ `+e.path+`

lib/types.d.ts

@@ -35,2 +35,3 @@ import { RequestOptions } from 'urllib';
 export interface CallFunctionResponse<T = object> {
+    errCode: string;
     result: T;
@@ -71,3 +72,3 @@ errMsg: string;
     functionName: string;
-    functionGatewayVip: string;
+    functionGatewayEndpoint: string;
     functionInstanceId: string;
@@ -74,0 +75,0 @@ functionDatabaseEndpoint?: string;

package.json

 {
   "name": "@alipay/faas-server-sdk",
-  "version": "0.0.26",
+  "version": "0.0.27",
   "description": "云函数服务 SDK",
@@ -18,4 +18,2 @@ "main": "lib/index.js",
   },
-  "keywords": [],
-  "author": "",
   "license": "MIT",
@@ -22,0 +20,0 @@ "devDependencies": {

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

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

No contributors or author data

Maintenance

Package does not specify a list of contributors or an author in package.json.

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

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

54828

increased by1.05%

Lines of code

516

increased by0.58%

No dependency changes