const { http } = require('@serverless-devs/dk');

const { searchApp, getAppDetail, getSpecialDetail, getSpecialApp, getCategorys, getTags } = require('./services');

http
  .get("/appCenter/getSpecial", async (ctx) => {
    const data = await getSpecialApp(ctx);
    ctx.body = data;
  })
  .post("/appCenter/getSpecialDetail", async (ctx, next) => {
    const data = await getSpecialDetail(ctx);
    ctx.body = data;
  })  
  .post("/appCenter/getAppDetail", async (ctx) => {
    const data = await getAppDetail(ctx);
    ctx.body = data;
  })  
  .get("/appCenter/getCategory", async (ctx) => {
    const data = await getCategorys();
    ctx.body = data;  
  })  
  .get("/appCenter/getTags", async (ctx) => {
    const data = await getTags();
    ctx.body = data;  
  })  
  .post("/appCenter/getApps", async (ctx) => {
    const data = await searchApp(ctx);
    ctx.body = data;
  })  
  .get("/", async (ctx, next) => {
    let result = "Hello ServerlessDevs";
    ctx.body = result;
  })
  
http.app.use(http.routes());

exports.handler = http();

edition: 1.0.0 #  命令行YAML规范版本，遵循语义化版本（Semantic Versioning）规范
name: fc-http-demo #  项目名称
access: default #  秘钥别名
vars:
services:
  serverlesshub:
    component: devsapp/fc # 组件名称
    props:
      region: cn-hangzhou
      service:
        name: myserverlesstest
        description: demo for fc-http component
        internetAccess: true
      function:
        name: myhub
        description: this is a test
        runtime: nodejs12
        codeUri: ./code
        handler: index.handler
        memorySize: 128
        timeout: 10
      triggers:
        - name: httpTrigger
        type: http
        config:            
          authType: anonymous            
          methods:              
            - GET              
            - POST      
      customDomains:
        - domainName: auto
        protocol: HTTP          
        routeConfigs:            
          - path: /*
# 函数计算FC组件文档参考地址：https://github.com/devsapp/fc

const  TableStore = require('tablestore');

let internal; // 先定义一个全局变量
exports.initializer = (context, callback) => {
  try {    
    const endpoint = process.env.tablestore_endpoint; // tablestore的连接地址    
    const instanceName = process.env.tablestore_instanceName;// tablestore实例名    
    const tableClient = new TableStore.Client({
      accessKeyId: context.credentials.accessKeyId,
      accessKeySecret: context.credentials.accessKeySecret,
      stsToken: context.credentials.securityToken,
      endpoint,
      instancename: instanceName,
    });
    internal = { tableClient, TableStore };
    callback();
  } catch (err) {
    callback(err.message);
  }
}

const { http } = require('@serverless-devs/dk');
http
  // 创建表
  .post("/table", async (ctx, next) => {
    const { tableName } = ctx.request.body;
    const { tableClient } = ctx.req.requestContext.internal;
    const params = {
      tableMeta: {
        tableName,
        primaryKey: [
          {            
            name: 'id',
            type: 'INTEGER',
          },
        ],
      },
      reservedThroughput: {
        capacityUnit: {
          read: 0,          
          write: 0,
        },
      },
      tableOptions: {
        timeToLive: -1, // 数据的过期时间, 单位秒, -1代表永不过期. 假如设置过期时间为一年, 即为 365 * 24 * 3600.
        maxVersions: 1, // 保存的最大版本数, 设置为1即代表每列上最多保存一个版本(保存最新的版本).
      },
      streamSpecification: {
        enableStream: true, //开启Stream
        expirationTime: 24, //Stream的过期时间，单位是小时，最长为168，设置完以后不能修改
      },
    };
    await tableClient.createTable(params);
    ctx.body = {
      success: true,
      message: `${tableName}表已创建成功`,
    }
  })
  
exports.handler = (req, res, context) => {
  context.internal = internal;
  http()(req, res, context);
};

$ s init dk-tablestore

$ cd code
$ npm install
$ npm run serve

$ s deploy