add email notify of api created or deleted #21

Author: wuomzfx

server/app/controller/api.js

@@ -110,6 +110,15 @@ class ApiController extends AbstractController {
     const users = await this.service.user.getByIds(follower)
     this.service.email.notifyApiChange(api, users)
   }
+  async notifyApi (act, group, api) {
+    const selfIdx = group.follower.findIndex(f => f.toString() === this.ctx.authUser._id)
+    // 如果修改者也在关注列表中，不推送自己
+    if (selfIdx >= 0) {
+      group.follower.splice(selfIdx, 1)
+    }
+    const users = await this.service.user.getByIds(group.follower)
+    this.service.email[`notifyApi${act}`](group, api, users)
+  }
   async getApi () {
     const { groupId, apiId } = this.ctx.params
 
@@ -171,7 +180,7 @@ class ApiController extends AbstractController {
     }))
 
     this.service.group.updateTime(groupId)
-
+    this.notifyApi('Create', group, resources)
     this.ctx.body = { resources }
     this.ctx.status = 200
   }
@@ -196,7 +205,8 @@ class ApiController extends AbstractController {
         msg: '无权删除'
       })
     }
-    await this.ctx.model.Group.update({ _id: groupId }, { modifiedTime: Date.now() }, { new: true }).exec()
+    const group = await this.service.group.updateTime(groupId)
+    this.notifyApi('Delete', group, rs)
     this.ctx.logger.info('deleteApi')
     this.ctx.status = 204
   }

server/app/service/email.js

@@ -35,15 +35,34 @@ class Email extends Service {
     `
     return this.sent(user.email, 'Api Mocker 找回密码', html)
   }
+  getApiDocUrl (api) {
+    return `${this.config.clientRoot}/#/doc/${api.group}/${api._id}`
+  }
+  notifyApiCreate (group, api, users) {
+    const html = `
+      <strong>API：${api.name}</strong>
+      <p>分组：${group.name} </p>
+      <p>创建者：${this.ctx.authUser.name}</p>
+      <p>链接地址：${this.getApiDocUrl(api)}</p>
+    `
+    users.forEach(user => this.sent(user.email, 'Api Mocker 接口新增提醒', html))
+  }
+  notifyApiDelete (group, api, users) {
+    const html = `
+      <strong>API：${api.name}</strong>
+      <p>分组：${group.name} </p>
+      <p>删除者：${this.ctx.authUser.name}</p>
+      <p>链接地址：${this.getApiDocUrl(api)}</p>
+    `
+    users.forEach(user => this.sent(user.email, 'Api Mocker 接口删除提醒', html))
+  }
   notifyApiChange (api, users) {
     const html = `
       <strong>API：${api.name}</strong>
       <p>修改者：${this.ctx.authUser.name}</p>
-      <p>链接地址：${this.config.clientRoot}/#/doc/${api.group}/${api._id}</p>
+      <p>链接地址：${this.getApiDocUrl(api)}</p>
     `
-    users.map(user => {
-      this.sent(user.email, 'Api Mocker 接口变动提醒', html)
-    })
+    users.forEach(user => this.sent(user.email, 'Api Mocker 接口变动提醒', html))
   }
 }