feat: 支持函数URL (#300)

Co-authored-by: darminzhou <[email protected]>

Author: Serverlesstencent

src/modules/triggers/http.ts

@@ -0,0 +1,95 @@
+import Scf from '../scf';
+import { TriggerManager } from './manager';
+import { CapiCredentials, RegionType } from './../interface';
+import BaseTrigger from './base';
+import { HttpTriggerInputsParams, TriggerInputs, CreateTriggerReq } from './interface';
+
+export default class HttpTrigger extends BaseTrigger<HttpTriggerInputsParams> {
+  credentials: CapiCredentials;
+  region: RegionType;
+
+  constructor({ credentials, region }: { credentials: CapiCredentials; region: RegionType }) {
+    super();
+    this.credentials = credentials;
+    this.region = region;
+  }
+
+  getKey(triggerInputs: CreateTriggerReq) {
+    const triggerDesc = JSON.parse(triggerInputs.TriggerDesc!);
+    const tempDest = JSON.stringify({
+      authType: triggerDesc?.AuthType,
+      enableIntranet: triggerDesc?.NetConfig?.EnableIntranet,
+      enableExtranet: triggerDesc?.NetConfig?.EnableExtranet,
+    });
+    return `http-${tempDest}-${triggerInputs.Qualifier}`;
+  }
+
+  formatInputs({ inputs }: { region: RegionType; inputs: TriggerInputs<HttpTriggerInputsParams> }) {
+    const { parameters } = inputs;
+    const triggerInputs: CreateTriggerReq = {
+      Action: 'CreateTrigger',
+      FunctionName: inputs.functionName,
+      Namespace: inputs.namespace,
+
+      Type: 'http',
+      Qualifier: parameters?.qualifier || '$DEFAULT',
+      TriggerName: parameters?.name || 'url-trigger',
+      TriggerDesc: JSON.stringify({
+        AuthType: parameters?.authType || 'NONE',
+        NetConfig: {
+          EnableIntranet: parameters?.netConfig?.enableIntranet ?? false,
+          EnableExtranet: parameters?.netConfig?.enableExtranet ?? false,
+        },
+      }),
+      Enable: 'OPEN',
+    };
+
+    const triggerKey = this.getKey(triggerInputs);
+
+    return {
+      triggerInputs,
+      triggerKey,
+    } as any;
+  }
+
+  async create({
+    scf,
+    region,
+    inputs,
+  }: {
+    scf: Scf | TriggerManager;
+    region: RegionType;
+    inputs: TriggerInputs<HttpTriggerInputsParams>;
+  }) {
+    const { triggerInputs } = this.formatInputs({ region, inputs });
+    console.log(`Creating ${triggerInputs.Type} trigger ${triggerInputs.TriggerName}`);
+    const { TriggerInfo } = await scf.request(triggerInputs);
+    TriggerInfo.Qualifier = TriggerInfo.Qualifier || triggerInputs.Qualifier;
+
+    return TriggerInfo;
+  }
+
+  async delete({
+    scf,
+    inputs,
+  }: {
+    scf: Scf | TriggerManager;
+    inputs: TriggerInputs<HttpTriggerInputsParams>;
+  }) {
+    console.log(`Removing ${inputs.type} trigger ${inputs.triggerName}`);
+    try {
+      await scf.request({
+        Action: 'DeleteTrigger',
+        FunctionName: inputs.functionName,
+        Namespace: inputs.namespace,
+        Type: inputs.type,
+        TriggerName: inputs.triggerName,
+        Qualifier: inputs.qualifier,
+      });
+      return true;
+    } catch (e) {
+      console.log(e);
+      return false;
+    }
+  }
+}

src/modules/triggers/index.ts

@@ -1,6 +1,7 @@
 import TimerTrigger from './timer';
 import CosTrigger from './cos';
 import ApigwTrigger from './apigw';
+import HttpTrigger from './http';
 import CkafkaTrigger from './ckafka';
 import CmqTrigger from './cmq';
 import ClsTrigger from './cls';
@@ -12,6 +13,7 @@ import { CapiCredentials, RegionType } from '../interface';
 export { default as TimerTrigger } from './timer';
 export { default as CosTrigger } from './cos';
 export { default as ApigwTrigger } from './apigw';
+export { default as HttpTrigger } from './http';
 export { default as CkafkaTrigger } from './ckafka';
 export { default as CmqTrigger } from './cmq';
 export { default as ClsTrigger } from './cls';
@@ -21,6 +23,7 @@ const TRIGGER = {
   timer: TimerTrigger,
   cos: CosTrigger,
   apigw: ApigwTrigger,
+  http: HttpTrigger,
   ckafka: CkafkaTrigger,
   cmq: CmqTrigger,
   cls: ClsTrigger,

src/modules/triggers/interface/index.ts

@@ -91,6 +91,17 @@ export interface CosTriggerInputsParams {
   enable?: boolean;
 }
 
+/** 函数URL参数 */
+export interface HttpTriggerInputsParams {
+  qualifier?: string;
+  name?: string;
+  authType?: 'CAM' | 'NONE';
+  netConfig?: {
+    enableIntranet?: boolean;
+    enableExtranet?: boolean;
+  };
+}
+
 export interface MpsTriggerInputsParams {
   type?: string;
   qualifier?: string;