feat: create alias (#301)

Co-authored-by: darminzhou <darminzhou@tencent.com>

Author: DarminZ

src/modules/scf/entities/alias.ts

@@ -13,17 +13,21 @@ import BaseEntity from './base';
 
 export default class AliasEntity extends BaseEntity {
  async create(inputs: ScfCreateAlias) {
- const publishInputs = {
+ const publishInputs: any = {
  Action: 'CreateAlias' as const,
  FunctionName: inputs.functionName,
- FunctionVersion: inputs.functionVersion,
+ FunctionVersion: inputs.functionVersion || '$LATEST',
  Name: inputs.aliasName,
  Namespace: inputs.namespace || 'default',
- RoutingConfig: {
- AdditionalVersionWeights: [{ Version: inputs.lastVersion, Weight: inputs.traffic }],
- },
  Description: inputs.description || 'Published by Serverless Component',
  };
+ if (inputs.lastVersion && inputs.traffic) {
+ publishInputs.RoutingConfig = {
+ AdditionalVersionWeights: [
+ { Version: inputs.lastVersion, Weight: strip(1 - inputs.traffic) },
+ ],
+ };
+ }
  const Response = await this.request(publishInputs);
  return Response;
  }

src/modules/scf/index.ts

@@ -321,19 +321,56 @@ export default class Scf {
  });
  }
 
+ const aliasAddionalVersion = inputs.aliasAddionalVersion || inputs.lastVersion;
  const needSetTraffic =
- inputs.traffic != null && inputs.lastVersion && inputs.lastVersion !== '$LATEST';
- if (needSetTraffic) {
- await this.alias.update({
- namespace,
- functionName,
- region: this.region,
- additionalVersions: needSetTraffic
- ? [{ weight: strip(1 - inputs.traffic!), version: inputs.lastVersion! }]
- : [],
- aliasName: inputs.aliasName,
- description: inputs.aliasDescription,
- });
+ inputs.traffic != null && aliasAddionalVersion && aliasAddionalVersion !== '$LATEST';
+ const needSetAlias = (inputs.aliasName && inputs.aliasName !== '$DEFAULT') || needSetTraffic;
+ if (needSetAlias) {
+ let needCreateAlias = false;
+ if (inputs.aliasName && inputs.aliasName !== '$DEFAULT') {
+ try {
+ const aliasInfo = await this.alias.get({
+ namespace,
+ functionName,
+ region: this.region,
+ aliasName: inputs.aliasName,
+ });
+ if (!aliasInfo?.Name) {
+ needCreateAlias = true;
+ }
+ } catch (error: any) {
+ if (
+ error.message &&
+ (error.message.includes('未找到指定的') || error.message.include('is not found'))
+ ) {
+ needCreateAlias = true;
+ }
+ }
+ }
+ if (needCreateAlias) {
+ await this.alias.create({
+ namespace,
+ functionName,
+ functionVersion: inputs.aliasFunctionVersion || funcInfo?.Qualifier,
+ aliasName: inputs.aliasName!,
+ lastVersion: aliasAddionalVersion!,
+ traffic: inputs.traffic!,
+ description: inputs.aliasDescription,
+ });
+ } else {
+ await this.alias.update({
+ namespace,
+ functionName,
+ functionVersion: inputs.aliasFunctionVersion || funcInfo?.Qualifier,
+ additionalVersions: needSetTraffic
+ ? [{ weight: strip(1 - inputs.traffic!), version: aliasAddionalVersion! }]
+ : [],
+ region: this.region,
+ aliasName: inputs.aliasName,
+ description: inputs.aliasDescription,
+ });
+ }
+
  outputs.Traffic = inputs.traffic;
  outputs.ConfigTrafficVersion = inputs.lastVersion;
  }

src/modules/scf/interface.ts

@@ -142,7 +142,7 @@ export interface ScfListAliasInputs extends ScfGetAliasInputs {}
 
 export interface ScfCreateAlias {
  functionName: string;
- functionVersion: string;
+ functionVersion?: string;
  aliasName: string;
  namespace?: string;
  lastVersion: string;
@@ -279,6 +279,8 @@ export interface ScfDeployInputs extends ScfCreateFunctionInputs {
 
  aliasName?: string;
  aliasDescription?: string;
+ aliasFunctionVersion?: string;
+ aliasAddionalVersion?: string;
 
  tags?: Record<string, string>;