fix(function): create db when not existed

cloudbaserc.js

@@ -22,7 +22,6 @@ module.exports = {
   envId: envId,
   functionRoot: './src/function',
   functions: [
-    { name: 'migrate', ...defaultFunctionConfig },
     { name: 'comment-get', ...defaultFunctionConfig },
     { name: 'comment-like', ...defaultFunctionConfig },
     { name: 'comment-submit', ...defaultFunctionConfig },

src/function/comment-get/index.js

@@ -17,19 +17,19 @@ exports.main = async (event, context) => {
   try {
     validate(event)
     uid = await auth.getEndUserInfo().userInfo.uid
+    const data = await db
+      .collection('comment')
+      .where({
+        url: event.url,
+        isSpam: _.neq(true)
+      })
+      .orderBy('created', 'desc')
+      .get()
+    res.data = parse(data.data, uid)
   } catch (e) {
+    res.data = []
     res.message = e.message
-    return res
   }
-  const data = await db
-    .collection('comment')
-    .where({
-      url: event.url,
-      isSpam: _.neq(true)
-    })
-    .orderBy('created', 'desc')
-    .get()
-  res.data = parse(data.data, uid)
   return res
 }
 

src/function/comment-submit/index.js

@@ -27,14 +27,19 @@ exports.main = async (event, context) => {
     res.message = e.message
     return res
   }
-  await init()
+  try {
+    await readConfig()
+  } catch (e) {
+    await createCollections()
+    await readConfig()
+  }
   const comment = await save(event)
   res.id = comment.id
   await sendMail(comment)
   return res
 }
 
-async function init () {
+async function readConfig () {
   if (!config) {
     config = await db
       .collection('config')

src/function/counter-get/index.js

@@ -12,10 +12,13 @@ exports.main = async (event, context) => {
   const res = {}
   try {
     validate(event)
-    const record = await db
-      .collection('counter')
-      .where({ url: event.url })
-      .get()
+    let record
+    try {
+      record = await read()
+    } catch (e) {
+      await createCollections()
+      record = await read()
+    }
     res.data = record.data[0] ? record.data[0] : {}
     res.time = res.data ? res.data.time : 0
     res.updated = await inc(event)
@@ -26,6 +29,13 @@ exports.main = async (event, context) => {
   return res
 }
 
+async function read () {
+  return await db
+    .collection('counter')
+    .where({ url: event.url })
+    .get()
+}
+
 /**
  * 更新阅读数
  * @param {String} event.url 文章地址
@@ -66,3 +76,10 @@ function validate (event) {
     }
   }
 }
+
+/**
+ * 建立数据库 collections
+ */
+async function createCollections () {
+  return await db.createCollection('counter')
+}