Serverless-Devs 实践——基于 Node 的前端 CICD

s.yaml
services:
  fc-deploy-test: #  服务名称
    component: devsapp/fc # 组件名称
    props: #  组件的属性值
      region: cn-shenzhen ## 此处可不修改
      service:
        name: fc-deploy-cicd
        description: 'demo for fc-node-cicd component'
        internetAccess: true
        ## 增加日志配置
        logConfig:
          enableRequestMetrics: true
          logstore: serverless-cicd-log
          project: serverless-cicd-log
      function:
        name: http-trigger-function
        description: this is a test
        runtime: nodejs12
        codeUri: ./
        handler: index.handler
        memorySize: 128
        timeout: 180 ## 增加时长，避免因为网络问题超时
      triggers:
        - name: httpTrigger
          type: http
          config:
            authType: anonymous
            methods:
              - GET
              - POST ## Github Webhook 为 POST 方式
      customDomains:
        - domainName: auto
          protocol: HTTP
          routeConfigs:
            - path: /*
              methods:
                - GET

my_ssh_executable.sh
#! /bin/sh
ID_RSA=/tmp/id_rsa
exec /usr/bin/ssh -o StrictHostKeyChecking=no -i $ID_RSA "$@"

index.js
const getRawBody = require('raw-body')
const getFormBody = require('body/form')
const body = require('body')
const execSync = require('child_process').execSync
const oss = require('ali-oss')
const fs = require('fs')
const path = require('path')

exports.handler = async (req, resp, context) => {
  // 设置响应类型
  resp.setHeader('Content-type', 'application/json')

  const client = new oss({
    region: 'oss-cn-shenzhen', // 根据实际设置填写
    accessKeyId: '<Your accessKeyId>',
    accessKeySecret: '<Your accessKeySecret>',
    bucket: 'serverless-cicd',
  })

  async function get(filename, localpath, cmd) {
    try {
      let res = await client.get(filename, localpath)
      if (res.res.status == 200) execSync(`${cmd} ${localpath}`)
    } catch (e) {
      console.error(e)
    }
  }
  // 下载密钥及脚本
  get('id_rsa', '/tmp/id_rsa', 'chmod 0600')
  get('my_ssh_executable.sh', '/tmp/my_ssh_executable.sh', 'chmod +x')

  console.log('下载密钥和脚本完成')

  // 获取 webhook 提交的推送信息
  getRawBody(req, async function (err, body) {
    body = body.toString().replace('undefined', '",')
    body = JSON.parse(body)
    const ref = body.ref
    const ref_type = body.ref_type
    const repository_name = body.repository.name
    const clone_url = body.repository.clone_url

    if (ref_type != 'tag') {
      resp.send('No tag event')
      return 0
    }

    // 删除可能存在的代码，并重新克隆
    if (fs.existsSync(`/tmp/${repository_name}/`)) execSync(`rm -rf /tmp/${repository_name}`)
    gitclone = `GIT_SSH="/tmp/my_ssh_executable.sh" git clone -b ${ref} ${clone_url} /tmp/${repository_name}`
    try {
      execSync(gitclone)
      console.log('克隆完成')
    } catch (e) {
      resp.send('git clone fail')
    }

    // 执行自定义的打包脚本
    // execSync(`cd /tmp/${repository_name} && sh build.sh`)

    function getFilesList(dir) {
      let res = []
      let files = fs.readdirSync(dir)
      files.forEach((filename) => {
        if (filename[0] == '.') return
        let filepath = path.join(dir, filename)
        let info = fs.statSync(filepath)
        if (info.isFile()) res.push({ filename, filepath })
        else res = res.concat(getFilesList(filepath))
      })
      return res
    }

    // 获取文件列表
    const files = getFilesList(`/tmp/${repository_name}/`)
    // 遍历上传文件
    Promise.all(
      files.map((file) => {
        return new Promise(async (resolve) => {
          let res = await client.put(file.filepath.replace(`/tmp`, ``), file.filepath)
          resolve(`${file.filename} uploading: ${res.res.status == 200}`)
        })
      })
    ).then((r) => {
      console.log(r)
      resp.send(
        JSON.stringify({
          ref,
          ref_type,
          repository_name,
          clone_url,
        })
      )
    })
  })
}

cd frontend-project-dir
git tag v1.0 -m 'new version'
git push origin tag v1.0