Merge pull request #2 from serverless-tencent/mutil-region

增加多地域部署能力

Author: anycodes

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@serverless/tencent-pyramid",
   "description": "Tencent Cloud Python Pyramid Serverless Component",
-  "version": "0.0.1",
+  "version": "1.0.0",
   "main": "serverless.js",
   "publishConfig": {
     "access": "public"
@@ -24,12 +24,6 @@
   },
   "author": "Dfounderliu",
   "license": "Apache-2.0",
-  "husky": {
-    "hooks": {
-      "pre-commit": "lint-staged",
-      "commit-msg": "commitlint -E HUSKY_GIT_PARAMS"
-    }
-  },
   "lint-staged": {
     "**/*.{js,ts,tsx}": [
       "eslint --fix --ext .js,.ts,.tsx .",
@@ -47,8 +41,7 @@
   },
   "dependencies": {
     "@serverless/core": "^1.1.1",
-    "@serverless/tencent-apigateway": "^2.1.4",
-    "@serverless/tencent-scf": "^3.0.0",
+    "@serverless/tencent-framework": "^0.0.1",
     "ext": "^1.4.0",
     "type": "^2.0.0"
   },

serverless.js

@@ -1,7 +1,4 @@
 const ensureIterable = require('type/iterable/ensure')
-const ensurePlainObject = require('type/plain-object/ensure')
-const ensureString = require('type/string/ensure')
-const random = require('ext/string/random')
 const path = require('path')
 const { Component } = require('@serverless/core')
 const fs = require('fs')
@@ -39,125 +36,53 @@ class TencentPyramid extends Component {
     }
   }
 
-  async prepareInputs(inputs = {}) {
-    inputs.name =
-      ensureString(inputs.functionName, { isOptional: true }) ||
-      this.state.functionName ||
-      `PyramidComponent_${random({ length: 6 })}`
-    inputs.codeUri = ensureString(inputs.code, { isOptional: true }) || process.cwd()
-    inputs.region = ensureString(inputs.region, { default: 'ap-guangzhou' })
-    inputs.namespace = ensureString(inputs.namespace, { default: 'default' })
-    inputs.include = ensureIterable(inputs.include, { default: [], ensureItem: ensureString })
-    inputs.exclude = ensureIterable(inputs.exclude, { default: [], ensureItem: ensureString })
-    inputs.apigatewayConf = ensurePlainObject(inputs.apigatewayConf, { default: {} })
+  async default(inputs = {}) {
+    if (!inputs.pyramidProjectName) {
+      throw new Error(`'pyramidProjectName' is required in serverless.yaml`)
+    }
+    const cachePath = path.join(inputs.code, '.cache')
+    inputs.include = ensureIterable(inputs.include, { default: [] })
+    inputs.include.push(cachePath)
 
     const src = path.join(__dirname, 'component')
-    const dst = path.join(inputs.codeUri, '.cache')
-    await this.copyDir(src, dst)
+    await this.copyDir(src, cachePath)
     const indexPyFile = await fs.readFileSync(
-      path.join(path.resolve(inputs.codeUri), '.cache', 'index.py'),
+      path.join(path.resolve(inputs.code), '.cache', 'index.py'),
       'utf8'
     )
     const replacedFile = indexPyFile.replace(
       eval('/{{pyramid_project}}/g'),
       inputs.pyramidProjectName
     )
-    await fs.writeFileSync(
-      path.join(path.resolve(inputs.codeUri), '.cache', 'index.py'),
-      replacedFile
-    )
+    await fs.writeFileSync(path.join(path.resolve(inputs.code), '.cache', 'index.py'), replacedFile)
 
-    inputs.include = [path.join(inputs.codeUri, '.cache')]
-    inputs.exclude.push('.git/**', '.gitignore', '.serverless', '.DS_Store')
+    inputs.handelr = DEFAULTS.handler
+    inputs.runtime = DEFAULTS.runtime
 
-    inputs.handler = ensureString(inputs.handler, { default: DEFAULTS.handler })
-    inputs.runtime = ensureString(inputs.runtime, { default: DEFAULTS.runtime })
-    inputs.apigatewayConf = ensurePlainObject(inputs.apigatewayConf, { default: {} })
+    const Framework = await this.load('@serverless/tencent-framework')
 
-    if (inputs.functionConf) {
-      inputs.timeout = inputs.functionConf.timeout ? inputs.functionConf.timeout : 3
-      inputs.memorySize = inputs.functionConf.memorySize ? inputs.functionConf.memorySize : 128
-      if (inputs.functionConf.environment) {
-        inputs.environment = inputs.functionConf.environment
-      }
-      if (inputs.functionConf.vpcConfig) {
-        inputs.vpcConfig = inputs.functionConf.vpcConfig
+    const framworkOutpus = await Framework({
+      ...inputs,
+      ...{
+        framework: 'pyramid'
       }
-    }
-
-    return inputs
-  }
-
-  async default(inputs = {}) {
-    if (!inputs.pyramidProjectName) {
-      throw new Error(`'pyramidProjectName' is required in serverless.yaml`)
-    }
-    inputs = await this.prepareInputs(inputs)
-
-    const tencentCloudFunction = await this.load('@serverless/tencent-scf')
-    const tencentApiGateway = await this.load('@serverless/tencent-apigateway')
-
-    inputs.fromClientRemark = inputs.fromClientRemark || 'tencent-pyramid'
-    const tencentCloudFunctionOutputs = await tencentCloudFunction(inputs)
-    const apigwParam = {
-      serviceName: inputs.serviceName,
-      description: 'Serverless Framework Tencent-Pyramid Component',
-      serviceId: inputs.serviceId,
-      region: inputs.region,
-      protocols: inputs.apigatewayConf.protocols || ['http'],
-      environment:
-        inputs.apigatewayConf && inputs.apigatewayConf.environment
-          ? inputs.apigatewayConf.environment
-          : 'release',
-      endpoints: [
-        {
-          path: '/',
-          method: 'ANY',
-          function: {
-            isIntegratedResponse: true,
-            functionName: tencentCloudFunctionOutputs.Name,
-            functionNamespace: inputs.namespace
-          }
-        }
-      ],
-      customDomain: inputs.apigatewayConf.customDomain
-    }
-
-    if (inputs.apigatewayConf && inputs.apigatewayConf.auth) {
-      apigwParam.endpoints[0].usagePlan = inputs.apigatewayConf.usagePlan
-    }
-    if (inputs.apigatewayConf && inputs.apigatewayConf.auth) {
-      apigwParam.endpoints[0].auth = inputs.apigatewayConf.auth
-    }
-
-    apigwParam.fromClientRemark = inputs.fromClientRemark || 'tencent-pyramid'
-    const tencentApiGatewayOutputs = await tencentApiGateway(apigwParam)
-    const outputs = {
-      region: inputs.region,
-      functionName: inputs.name,
-      apiGatewayServiceId: tencentApiGatewayOutputs.serviceId,
-      url: `${this.getDefaultProtocol(tencentApiGatewayOutputs.protocols)}://${
-        tencentApiGatewayOutputs.subDomain
-      }/${tencentApiGatewayOutputs.environment}/`
-    }
-
-    this.state = outputs
+    })
 
+    this.state = framworkOutpus
     await this.save()
-
-    return outputs
+    return framworkOutpus
   }
 
   async remove(inputs = {}) {
-    const removeInput = {
-      fromClientRemark: inputs.fromClientRemark || 'tencent-pyramid'
-    }
-    const tencentCloudFunction = await this.load('@serverless/tencent-scf')
-    const tencentApiGateway = await this.load('@serverless/tencent-apigateway')
-
-    await tencentCloudFunction.remove(removeInput)
-    await tencentApiGateway.remove(removeInput)
-
+    const Framework = await this.load('@serverless/tencent-framework')
+    await Framework.remove({
+      ...inputs,
+      ...{
+        framework: 'pyramid'
+      }
+    })
+    this.state = {}
+    await this.save()
     return {}
   }
 }