Socket
Socket
Sign inDemoInstall

@alipay/faas-server-sdk

Package Overview
Dependencies
Maintainers
2
Versions
137
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

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

Comparing version 1.0.8-alpha.0 to 1.0.8

lib/utils.d.ts
lib/utils.js

2

lib/Cloud.js

@@ -1,1 +0,1 @@

"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Cloud=exports.initRuntimeEnv=void 0;const faas_server_utils_1=require("@alipay/faas-server-utils"),callFunction_1=require("./callFunction"),constant_1=require("./constant"),Database_1=require("./Database"),MySQL_1=require("./MySQL"),Openapi_1=require("./Openapi"),Storage_1=require("./Storage"),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||"",RUNTIME_OSS_ENDPOINT:process.env.RUNTIME_OSS_ENDPOINT||"",RUNTIME_MYSQL_ENDPOINT:process.env.RUNTIME_MYSQL_ENDPOINT||""};function initRuntimeEnv(E){Object.assign(runtimeEnv,E)}exports.initRuntimeEnv=initRuntimeEnv;class Cloud{#t;#E;#n;#e;constructor(){this.#t={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,functionStorageEndpoint:runtimeEnv.RUNTIME_OSS_ENDPOINT,functionMysqlEndpoint:runtimeEnv.RUNTIME_MYSQL_ENDPOINT}}refreshConfig(){runtimeEnv.RUNTIME_ACCESS_KEY&&(this.#t.secretId=runtimeEnv.RUNTIME_ACCESS_KEY),runtimeEnv.RUNTIME_SECRET_KEY&&(this.#t.secretKey=runtimeEnv.RUNTIME_SECRET_KEY),runtimeEnv.RUNTIME_ENV_ID&&(this.#t.fromEnvId=runtimeEnv.RUNTIME_ENV_ID,this.#t.toEnvId||(this.#t.toEnvId=runtimeEnv.RUNTIME_ENV_ID)),runtimeEnv.RUNTIME_FUNCTION_NAME&&(this.#t.functionName=runtimeEnv.RUNTIME_FUNCTION_NAME),runtimeEnv.RUNTIME_FUNCTION_GATEWAY_ENDPOINT&&(this.#t.functionGatewayEndpoint=runtimeEnv.RUNTIME_FUNCTION_GATEWAY_ENDPOINT),runtimeEnv.RUNTIME_FUNCTION_INSTANCE_ID&&(this.#t.functionInstanceId=runtimeEnv.RUNTIME_FUNCTION_INSTANCE_ID),runtimeEnv.RUNTIME_MONGO_CLUSTER_ENDPOINT&&(this.#t.functionDatabaseEndpoint=runtimeEnv.RUNTIME_MONGO_CLUSTER_ENDPOINT),runtimeEnv.RUNTIME_MONGO_DATABASE_NAME&&(this.#t.functionDatabaseName=runtimeEnv.RUNTIME_MONGO_DATABASE_NAME),runtimeEnv.RUNTIME_OSS_ENDPOINT&&(this.#t.functionStorageEndpoint=runtimeEnv.RUNTIME_OSS_ENDPOINT),runtimeEnv.RUNTIME_MYSQL_ENDPOINT&&(this.#t.functionMysqlEndpoint=runtimeEnv.RUNTIME_MYSQL_ENDPOINT)}init(t){const N=this.#i(t?.env);N&&(this.#t.toEnvId=N),t?.envId&&(this.#t.toEnvId=t.envId)}getAlipayContext(){return(0,faas_server_utils_1.getAlipayContext)()}async callFunction(t){const{config:N,...n}=t||{},e=this.#_(N?.env);return await(0,callFunction_1.callFunction)(e,n)}database(t){const N=this.#_(t?.env);return new Database_1.Database(N)}mysql(){return this.#n||(this.#n=new MySQL_1.MySQL(this.#t)),this.#n}get openapi(){return this.#e||(this.#e=(0,Openapi_1.createOpenapi)(this.#t)),this.#e}#N(){return this.#E||(this.#E=new Storage_1.Storage(this.#t)),this.#E}async uploadFile(t){return await this.#N().uploadFile(t)}async downloadFile(t){return await this.#N().downloadFile(t)}async deleteFile(t){return await this.#N().deleteFile(t)}async getTempFileURL(t){return await this.#N().getTempFileURL(t)}#_(t){const N=this.#i(t);return N?{...this.#t,toEnvId:N}:this.#t}#i(t){return t&&typeof t=="string"?t:t&&t===constant_1.DYNAMIC_CURRENT_ENV?runtimeEnv.RUNTIME_ENV_ID:null}}exports.Cloud=Cloud;
"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.Cloud=exports.initRuntimeEnv=void 0;const faas_server_utils_1=require("@alipay/faas-server-utils"),callFunction_1=require("./callFunction"),constant_1=require("./constant"),Database_1=require("./Database"),MySQL_1=require("./MySQL"),Openapi_1=require("./Openapi"),Storage_1=require("./Storage"),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||"",RUNTIME_OSS_ENDPOINT:process.env.RUNTIME_OSS_ENDPOINT||"",RUNTIME_MYSQL_ENDPOINT:process.env.RUNTIME_MYSQL_ENDPOINT||""};function initRuntimeEnv(e){Object.assign(runtimeEnv,e)}exports.initRuntimeEnv=initRuntimeEnv;class Cloud{#t;#e;#E;#n;constructor(){this.#t={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,functionStorageEndpoint:runtimeEnv.RUNTIME_OSS_ENDPOINT,functionMysqlEndpoint:runtimeEnv.RUNTIME_MYSQL_ENDPOINT}}refreshConfig(){runtimeEnv.RUNTIME_ACCESS_KEY&&(this.#t.secretId=runtimeEnv.RUNTIME_ACCESS_KEY),runtimeEnv.RUNTIME_SECRET_KEY&&(this.#t.secretKey=runtimeEnv.RUNTIME_SECRET_KEY),runtimeEnv.RUNTIME_ENV_ID&&(this.#t.fromEnvId=runtimeEnv.RUNTIME_ENV_ID,this.#t.toEnvId||(this.#t.toEnvId=runtimeEnv.RUNTIME_ENV_ID)),runtimeEnv.RUNTIME_FUNCTION_NAME&&(this.#t.functionName=runtimeEnv.RUNTIME_FUNCTION_NAME),runtimeEnv.RUNTIME_FUNCTION_GATEWAY_ENDPOINT&&(this.#t.functionGatewayEndpoint=runtimeEnv.RUNTIME_FUNCTION_GATEWAY_ENDPOINT),runtimeEnv.RUNTIME_FUNCTION_INSTANCE_ID&&(this.#t.functionInstanceId=runtimeEnv.RUNTIME_FUNCTION_INSTANCE_ID),runtimeEnv.RUNTIME_MONGO_CLUSTER_ENDPOINT&&(this.#t.functionDatabaseEndpoint=runtimeEnv.RUNTIME_MONGO_CLUSTER_ENDPOINT),runtimeEnv.RUNTIME_MONGO_DATABASE_NAME&&(this.#t.functionDatabaseName=runtimeEnv.RUNTIME_MONGO_DATABASE_NAME),runtimeEnv.RUNTIME_OSS_ENDPOINT&&(this.#t.functionStorageEndpoint=runtimeEnv.RUNTIME_OSS_ENDPOINT),runtimeEnv.RUNTIME_MYSQL_ENDPOINT&&(this.#t.functionMysqlEndpoint=runtimeEnv.RUNTIME_MYSQL_ENDPOINT)}init(t){const N=this.#_(t?.env);N&&(this.#t.toEnvId=N),t?.envId&&(this.#t.toEnvId=t.envId),t?.timeout!==void 0&&(this.#t.timeout=(0,utils_1.validateTimeout)(t.timeout))}getAlipayContext(){return(0,faas_server_utils_1.getAlipayContext)()}async callFunction(t){const{config:N,...E}=t||{},n=this.#i(N?.env);return await(0,callFunction_1.callFunction)(n,E)}database(t){const N=this.#i(t?.env);return new Database_1.Database({...N,throwOnNotFound:t?.throwOnNotFound!==!1,timeout:(0,utils_1.validateTimeout)(t?.timeout??N.timeout)})}mysql(){return this.#E||(this.#E=new MySQL_1.MySQL(this.#t)),this.#E}get openapi(){return this.#n||(this.#n=(0,Openapi_1.createOpenapi)(this.#t)),this.#n}#N(){return this.#e||(this.#e=new Storage_1.Storage(this.#t)),this.#e}async uploadFile(t){return await this.#N().uploadFile(t)}async downloadFile(t){return await this.#N().downloadFile(t)}async deleteFile(t){return await this.#N().deleteFile(t)}async getTempFileURL(t){return await this.#N().getTempFileURL(t)}#i(t){const N=this.#_(t);return N?{...this.#t,toEnvId:N}:this.#t}#_(t){return t&&typeof t=="string"?t:t&&t===constant_1.DYNAMIC_CURRENT_ENV?runtimeEnv.RUNTIME_ENV_ID:null}}exports.Cloud=Cloud;

5

lib/Database/Collection.d.ts
import type { AddDocumentParam, QueryChainCommand } from '@alipay/faas-db-builder';
import { Sort } from '@alipay/faas-db-builder';
import { CloudConfig } from '@alipay/faas-server-utils';
import { CountDocumentResult } from '../types';
import { CountDocumentResult, DatabaseCloudConfig } from '../types';
import { Aggregate } from './Aggregate';

@@ -10,3 +9,3 @@ import { Document } from './Document';

#private;
constructor(config: CloudConfig, collectionName: string);
constructor(config: DatabaseCloudConfig, collectionName: string);
add(param: AddDocumentParam): Promise<AddDocumentResult>;

@@ -13,0 +12,0 @@ doc(_id: string): Document;

7

lib/Database/Document.d.ts
import type { UpdateData } from '@alipay/faas-db-builder';
import type { CloudConfig } from '@alipay/faas-server-utils';
import { DeleteResult, UpdateResult } from '../types';
import type { DatabaseCloudConfig, DeleteResult, UpdateResult } from '../types';
export declare class Document {
#private;
constructor(collectionName: string, id: string, config: CloudConfig);
constructor(collectionName: string, id: string, config: DatabaseCloudConfig);
update(data: UpdateData): Promise<UpdateResult>;
set(data: UpdateData): Promise<UpdateResult>;
remove(): Promise<DeleteResult>;
get<T = any>(): Promise<T>;
get<T = any>(): Promise<T | null>;
}

2

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"),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;
"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(t,e,r){this.#t=r,this.#r=t,this.#e=e}async update(t){return await new Query_1.Query(this.#r,this.#t).where({_id:String(this.#e)}).limit(1).update(t)}async set(t){return await new Query_1.Query(this.#r,this.#t).where({_id:String(this.#e)}).limit(1).set(t)}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){if(this.#t.throwOnNotFound)throw errors_1.errors.NOT_FOUND(`document with _id ${this.#e} does not exist`);return null}return r}}exports.Document=Document;

5

lib/Database/index.d.ts
import { Command } from '@alipay/faas-db-builder';
import type { CloudConfig } from '@alipay/faas-server-utils';
import { CollectionDescription, DeleteResult } from '../types';
import { CollectionDescription, DatabaseCloudConfig, DeleteResult } from '../types';
import { Collection } from './Collection';

@@ -8,3 +7,3 @@ export declare class Database {

command: Command;
constructor(config: CloudConfig);
constructor(config: DatabaseCloudConfig);
collection(collectionName: string): Collection;

@@ -11,0 +10,0 @@ createCollection(collectionName: string): Promise<CollectionDescription>;

1

lib/errors.d.ts

@@ -25,2 +25,3 @@ import { HttpRequestFailedResult } from './types';

CALL_OPENAPI_ERR(result: HttpRequestFailedResult): FunctionError;
INVALID_OPENAPI_RESPONSE_ERR(requestId: string, res: any): FunctionError;
CALL_DATABASE_ERR(result: HttpRequestFailedResult): FunctionError;

@@ -27,0 +28,0 @@ SYS_ERR(message?: string): FunctionError;

2

lib/errors.js

@@ -1,1 +0,1 @@

"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.errors=exports.FunctionError=exports.ErrorCode=void 0;const node_util_1=require("node:util");var ErrorCode;(function(e){e.INVALID_PARAM="INVALID_PARAM",e.CALL_FUNCTION_ERR="CALL_FUNCTION_ERR",e.CALL_STORAGE_ERR="CALL_STORAGE_ERR",e.CALL_DATABASE_ERR="CALL_DATABASE_ERR",e.CALL_OPENAPI_ERR="CALL_OPENAPI_ERR",e.SYS_ERR="SYS_ERR",e.NOT_FOUND="NOT_FOUND"})(ErrorCode=exports.ErrorCode||(exports.ErrorCode={}));class FunctionError extends Error{code;requestId;errCode=-1;get requestID(){return this.requestId}get errMsg(){return this.message}static create(r,t,...R){const A=new FunctionError((0,node_util_1.format)(t,...R));return A.code=r,A}static createByHttpRequestFailedResult(r,t){const R=FunctionError.create(r,`requestId ${t.requestId}, ${t.errMsg}`);return R.requestId=t.requestId,R.errCode=t.errCode,R}}exports.FunctionError=FunctionError,exports.errors={INVALID_PARAM(e,r){return FunctionError.create(ErrorCode.INVALID_PARAM,`Invalid param "${e}", ${r}`)},CALL_FUNCTION_ERR(e){return FunctionError.createByHttpRequestFailedResult(ErrorCode.CALL_FUNCTION_ERR,e)},CALL_STORAGE_ERR(e){return FunctionError.createByHttpRequestFailedResult(ErrorCode.CALL_STORAGE_ERR,e)},CALL_OPENAPI_ERR(e){return FunctionError.createByHttpRequestFailedResult(ErrorCode.CALL_OPENAPI_ERR,e)},CALL_DATABASE_ERR(e){return FunctionError.createByHttpRequestFailedResult(ErrorCode.CALL_DATABASE_ERR,e)},SYS_ERR(e="\u5185\u90E8\u7CFB\u7EDF\u9519\u8BEF"){return FunctionError.create(ErrorCode.SYS_ERR,e)},NOT_FOUND(e){return FunctionError.create(ErrorCode.NOT_FOUND,e)}};
"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.errors=exports.FunctionError=exports.ErrorCode=void 0;const node_util_1=require("node:util");var ErrorCode;(function(e){e.INVALID_PARAM="INVALID_PARAM",e.CALL_FUNCTION_ERR="CALL_FUNCTION_ERR",e.CALL_STORAGE_ERR="CALL_STORAGE_ERR",e.CALL_DATABASE_ERR="CALL_DATABASE_ERR",e.CALL_OPENAPI_ERR="CALL_OPENAPI_ERR",e.SYS_ERR="SYS_ERR",e.NOT_FOUND="NOT_FOUND"})(ErrorCode=exports.ErrorCode||(exports.ErrorCode={}));class FunctionError extends Error{code;requestId;errCode=-1;get requestID(){return this.requestId}get errMsg(){return this.message}static create(t,r,...R){const A=new FunctionError((0,node_util_1.format)(r,...R));return A.code=t,A}static createByHttpRequestFailedResult(t,r){const R=FunctionError.create(t,`requestId ${r.requestId}, ${r.errMsg}`);return R.requestId=r.requestId,R.errCode=r.errCode,R}}exports.FunctionError=FunctionError,exports.errors={INVALID_PARAM(e,t){return FunctionError.create(ErrorCode.INVALID_PARAM,`Invalid param "${e}", ${t}`)},CALL_FUNCTION_ERR(e){return FunctionError.createByHttpRequestFailedResult(ErrorCode.CALL_FUNCTION_ERR,e)},CALL_STORAGE_ERR(e){return FunctionError.createByHttpRequestFailedResult(ErrorCode.CALL_STORAGE_ERR,e)},CALL_OPENAPI_ERR(e){return FunctionError.createByHttpRequestFailedResult(ErrorCode.CALL_OPENAPI_ERR,e)},INVALID_OPENAPI_RESPONSE_ERR(e,t){const r=FunctionError.create(ErrorCode.CALL_OPENAPI_ERR,`Invalid response ${JSON.stringify(t)}`);return r.requestId=e,r.errCode=-1,r},CALL_DATABASE_ERR(e){return FunctionError.createByHttpRequestFailedResult(ErrorCode.CALL_DATABASE_ERR,e)},SYS_ERR(e="\u5185\u90E8\u7CFB\u7EDF\u9519\u8BEF"){return FunctionError.create(ErrorCode.SYS_ERR,e)},NOT_FOUND(e){return FunctionError.create(ErrorCode.NOT_FOUND,e)}};

2

lib/Openapi/caller.js

@@ -1,1 +0,1 @@

"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.OpenapiCaller=void 0;const errors_1=require("../errors"),middlewares_1=require("../requester/middlewares");class OpenapiCaller{#e;#t;constructor(t,r){this.#e=t,this.#t=r}async request(t,r){const s="POST",i=this.#r(),e=Object.assign({},r);e.biz_content&&typeof e.biz_content!="string"&&(e.biz_content=JSON.stringify(e.biz_content));const n=await middlewares_1.HttpRequester.openapi.request(s,i,e,{"x-openapi":t,"x-openapi-version":this.#t},{cloudConfig:this.#e});if(!n.succeed)throw errors_1.errors.CALL_OPENAPI_ERR(n);return n.data}#r(){return`${this.#e.functionGatewayEndpoint}/functions/invokeOpenapi`}}exports.OpenapiCaller=OpenapiCaller;
"use strict";var __importDefault=this&&this.__importDefault||function(e){return e&&e.__esModule?e:{default:e}};Object.defineProperty(exports,"__esModule",{value:!0}),exports.OpenapiCaller=void 0;const snakecase_keys_1=__importDefault(require("snakecase-keys")),errors_1=require("../errors"),middlewares_1=require("../requester/middlewares");class OpenapiCaller{#e;#t;constructor(s,n){this.#e=s,this.#t=n}async request(s,n){const o="POST",a=this.#r(),t=(0,snakecase_keys_1.default)(Object.assign({},n),{deep:!0});t.biz_content&&typeof t.biz_content!="string"&&(t.biz_content=JSON.stringify(t.biz_content));const r=await middlewares_1.HttpRequester.openapi.request(o,a,t,{"x-openapi":s,"x-openapi-version":this.#t},{cloudConfig:this.#e});if(!r.succeed)throw errors_1.errors.CALL_OPENAPI_ERR(r);const c=`${s.replace(/\./g,"_")}_response`,i=r.data?.[c];if(!i)throw errors_1.errors.INVALID_OPENAPI_RESPONSE_ERR(r.requestId,r.data||"");return i}#r(){return`${this.#e.functionGatewayEndpoint}/functions/invokeOpenapi`}}exports.OpenapiCaller=OpenapiCaller;

2

lib/requester/middlewares/HttpRequestContext.js

@@ -1,1 +0,1 @@

"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.HttpRequestContext=void 0;class HttpRequestContext{req;config;res;result;constructor(e,t){this.req=e,this.config=t}get requestId(){return this.req.requestOptions.headers["x-request-id"]}}exports.HttpRequestContext=HttpRequestContext;
"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.HttpRequestContext=void 0;class HttpRequestContext{req;config;res;result;constructor(e,t){this.req=e,this.config=t}get requestId(){return this.req.requestOptions.headers["x-trace-id"]}}exports.HttpRequestContext=HttpRequestContext;

2

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 node_assert_1=__importDefault(require("node:assert")),node_crypto_1=require("node:crypto"),koa_compose_1=__importDefault(require("koa-compose")),call_openapi_middleware_1=require("./call_openapi_middleware"),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_dataproxy_headers_middleware_1=require("./init_call_dataproxy_headers_middleware"),error_handler_middleware_1=require("./error_handler_middleware");class HttpRequester{static#e;static#t;static#a;static#r;#i;constructor(e){this.#i=(0,koa_compose_1.default)(e)}async request(e,d,s,a,n){const r=n.cloudConfig;(0,node_assert_1.default)(r,"cloud config not set");const l=JSON.stringify(s),o=(0,node_crypto_1.randomUUID)();a["x-request-id"]=o;const c={method:e,contentType:"application/json",content:l,dataType:"json",headers:a},_={url:new URL(d),requestOptions:c},i=new HttpRequestContext_1.HttpRequestContext(_,r);return await this.#i(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,(0,init_call_dataproxy_headers_middleware_1.createInitCallDataProxyHeadersMiddleware)("mongo"),(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}static get storage(){if(!this.#a){const e=[error_handler_middleware_1.errorHandlerMiddleware,(0,init_call_dataproxy_headers_middleware_1.createInitCallDataProxyHeadersMiddleware)("oss"),(0,sign_middleware_factory_1.signMiddlewareFactory)(["x-data-api-type","x-expire-timestamp"]),call_database_middleware_1.callDatabaseMiddleware,call_middleware_1.callMiddleware];this.#a=new HttpRequester(e)}return this.#a}static get openapi(){if(!this.#r){const e=[error_handler_middleware_1.errorHandlerMiddleware,(0,sign_middleware_factory_1.signMiddlewareFactory)(["x-openapi","x-openapi-version"]),call_openapi_middleware_1.callOpenapiMiddleware,call_middleware_1.callMiddleware];this.#r=new HttpRequester(e)}return this.#r}}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")),node_crypto_1=require("node:crypto"),koa_compose_1=__importDefault(require("koa-compose")),call_openapi_middleware_1=require("./call_openapi_middleware"),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_dataproxy_headers_middleware_1=require("./init_call_dataproxy_headers_middleware"),error_handler_middleware_1=require("./error_handler_middleware");class HttpRequester{static#e;static#t;static#a;static#r;#i;constructor(e){this.#i=(0,koa_compose_1.default)(e)}async request(e,n,s,r,l){const a=l.cloudConfig;(0,node_assert_1.default)(a,"cloud config not set");const o=JSON.stringify(s),c=(0,node_crypto_1.randomUUID)();r["x-request-id"]=c;const i={method:e,contentType:"application/json",content:o,dataType:"json",headers:r};a.timeout!==void 0&&(i.timeout=a.timeout);const u={url:new URL(n),requestOptions:i},d=new HttpRequestContext_1.HttpRequestContext(u,a);return await this.#i(d),d.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,(0,init_call_dataproxy_headers_middleware_1.createInitCallDataProxyHeadersMiddleware)("mongo"),(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}static get storage(){if(!this.#a){const e=[error_handler_middleware_1.errorHandlerMiddleware,(0,init_call_dataproxy_headers_middleware_1.createInitCallDataProxyHeadersMiddleware)("oss"),(0,sign_middleware_factory_1.signMiddlewareFactory)(["x-data-api-type","x-expire-timestamp"]),call_database_middleware_1.callDatabaseMiddleware,call_middleware_1.callMiddleware];this.#a=new HttpRequester(e)}return this.#a}static get openapi(){if(!this.#r){const e=[error_handler_middleware_1.errorHandlerMiddleware,(0,sign_middleware_factory_1.signMiddlewareFactory)(["x-openapi","x-openapi-version"]),call_openapi_middleware_1.callOpenapiMiddleware,call_middleware_1.callMiddleware];this.#r=new HttpRequester(e)}return this.#r}}exports.HttpRequester=HttpRequester;

7

lib/types.d.ts

@@ -5,2 +5,3 @@ /// <reference types="node" />

import type { RequestOptions } from 'urllib';
import type { CloudConfig } from '@alipay/faas-server-utils';
export type CloudInitOptions = {

@@ -12,2 +13,3 @@ env?: string | symbol | {

};
timeout?: number | [number, number];
envId?: string;

@@ -18,3 +20,8 @@ traceUser?: boolean;

env?: string | symbol;
throwOnNotFound?: boolean;
timeout?: number | [number, number];
};
export interface DatabaseCloudConfig extends CloudConfig {
throwOnNotFound: boolean;
}
export interface CallFunctionParam {

@@ -21,0 +28,0 @@ name: string;

7

package.json
{
"name": "@alipay/faas-server-sdk",
"version": "1.0.8-alpha.0",
"version": "1.0.8",
"description": "云函数服务 SDK",

@@ -33,6 +33,7 @@ "main": "lib/index.js",

"dependencies": {
"@alipay/faas-db-builder": "^1.0.8-alpha.0",
"@alipay/faas-server-utils": "^1.0.8-alpha.0",
"@alipay/faas-db-builder": "^1.0.8",
"@alipay/faas-server-utils": "^1.0.8",
"ali-rds": "^5.1.2",
"koa-compose": "^4.1.0",
"snakecase-keys": "^5.4.5",
"urllib": "^3.11.0"

@@ -39,0 +40,0 @@ },

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc