feat: follow group #21

Author: wuomzfx

client/src/components/document/GroupContent.vue

@@ -2,32 +2,57 @@
   <div class="apis-doc" v-if="group">
     <div class="title">
       {{group.name}}接口文档
+      <div class="control">
+        <el-button class="follow"
+                    icon="star-on"
+                    v-if="followed"
+                    type="primary"
+                    @click="unfollowGroup(group._id)">取消订阅</el-button>
+        <el-button class="follow"
+                    icon="star-off"
+                    v-else
+                    @click="followGroup(group._id)">订阅</el-button>
+      </div>
     </div>
     <api-doc :api="api" v-for="api in apis" :key="api._id"></api-doc>
   </div>
 </template>
 
 <script>
 import ApiDoc from './apiDoc/Index'
+import { mapActions } from 'vuex'
 export default {
   components: {
     ApiDoc
   },
+  props: ['apis'],
   computed: {
-    groups () {
-      return this.$store.state.groups
-    },
     group () {
-      return this.groups.find(g => g._id === this.$route.params.groupId)
+      return this.$store.state.groups.find(g => g._id === this.$route.params.groupId)
+    },
+    user () {
+      return this.$store.state.user
+    },
+    followed () {
+      return !!this.group.follower.find(f => f === this.user._id)
     }
   },
-  props: ['apis']
+  methods: {
+    ...mapActions([
+      'followGroup',
+      'unfollowGroup'
+    ])
+  }
 }
 </script>
-<style>
+<style lang="less">
 .apis-doc > .title {
   padding: 30px;
   font-size: 28px;
   border-bottom: 1px solid #ddd;
+
+  .control {
+    float: right;
+  }
 }
 </style>

client/src/config/api.js

@@ -8,6 +8,7 @@ export default R.map((url) => `${domain}${url}`)({
   GROUP: '/server/group/:groupId',
   APIS: '/server/api',
   GROUP_APIS: '/server/api/:groupId',
+  GROUP_FOLLOWER: '/server/group/follower/:groupId',
   API: '/server/api/:groupId/:apiId',
   API_HISTORY: '/server/history/api/:apiId',
   API_AUTHORITY: '/server/authority/api/:apiId',

client/src/store/actions.js

@@ -251,6 +251,18 @@ const actions = {
   unfollow ({ state }, apiId) {
     return axios.delete(API.API_FOLLOWER.replace(':apiId', apiId))
   },
+  followGroup ({ state, commit }, groupId) {
+    return axios.put(API.GROUP_FOLLOWER.replace(':groupId', groupId)).then(res => {
+      commit('UPDATE_GROUP', res.data)
+      return res
+    })
+  },
+  unfollowGroup ({ state, commit }, groupId) {
+    return axios.delete(API.GROUP_FOLLOWER.replace(':groupId', groupId)).then(res => {
+      commit('UPDATE_GROUP', res.data)
+      return res
+    })
+  },
   sendResetPassCode ({ state }, email) {
     return axios.post(`${API.USER}/recovery/password/code`, {email})
   },

client/src/store/mutations.js

@@ -1,6 +1,7 @@
 import { apiInitData } from '@/util'
 import Schema from '@/model/schema'
 import R from 'ramda'
+import Vue from 'vue'
 
 const mutations = {
   FETCH_GROUPS_SUCCESS (state, groups) {
@@ -27,7 +28,7 @@ const mutations = {
   },
   UPDATE_GROUP (state, group) {
     const index = R.findIndex(g => g._id === group._id)(state.groups)
-    state.groups[index] = group
+    Vue.set(state.groups, index, group)
   },
   CREATE_GROUP_SUCCESS (state, data) {
     state.groups.unshift(data)

server/app/controller/api.js

@@ -89,23 +89,25 @@ class ApiController extends AbstractController {
         msg: '系统错误，保存失败'
       })
     }
-    this.service.group.updateTime(groupId)
+    const group = await this.service.group.updateTime(groupId)
     // 存下历史记录，并将所有记录返回
     resources.history = await this.service.apiHistory.push(resources)
-    this.notifyApiChange(resources, lastModifiedTime)
+    this.notifyApiChange(group, resources, lastModifiedTime)
     this.ctx.body = { resources }
   }
-  async notifyApiChange (api, lastModifiedTime) {
+  async notifyApiChange (group, api, lastModifiedTime) {
     const interval = api.modifiedTime - lastModifiedTime
     if (interval < this.config.pushInterval.api) {
       return
     }
-    const selfIdx = api.follower.findIndex(f => f.toString() === this.ctx.authUser._id)
+    let follower = api.follower.concat(group.follower).map(f => f.toString())
+    follower = Array.from(new Set(follower))
+    const selfIdx = follower.findIndex(f => f === this.ctx.authUser._id)
     // 如果修改者也在关注列表中，不推送自己
     if (selfIdx >= 0) {
-      api.follower.splice(selfIdx, 1)
+      follower.splice(selfIdx, 1)
     }
-    const users = await this.service.user.getByIds(api.follower)
+    const users = await this.service.user.getByIds(follower)
     this.service.email.notifyApiChange(api, users)
   }
   async getApi () {

server/app/controller/group.js

@@ -64,6 +64,32 @@ class GroupController extends AbstractController {
     await this.service.api.deleteGroupApis(id)
     this.ctx.status = 204
   }
+
+  async follow () {
+    const groupId = this.ctx.params.groupId
+    const authId = this.ctx.authUser._id
+    const group = (await this.service.group.getById(groupId)).toObject()
+    group.follower = group.follower || []
+    const isExist = group.follower.find(f => f.toString() === authId)
+    if (isExist) {
+      this.ctx.body = group
+    } else {
+      group.follower.push(authId)
+      this.ctx.body = await this.service.group.updateFollower(groupId, group.follower)
+    }
+  }
+  async unfollow () {
+    const groupId = this.ctx.params.groupId
+    const authId = this.ctx.authUser._id
+    const group = (await this.service.group.getById(groupId)).toObject()
+    const index = group.follower.findIndex(f => f.toString() === authId)
+    if (index < 0) {
+      this.ctx.body = group
+    } else {
+      group.follower.splice(index, 1)
+      this.ctx.body = await this.service.group.updateFollower(groupId, group.follower)
+    }
+  }
 }
 
 module.exports = GroupController

server/app/model/group.js

@@ -14,6 +14,10 @@ module.exports = app => {
       type: ObjectId,
       required: true
     },
+    follower: [{ // 订阅者
+      type: ObjectId,
+      ref: 'user'
+    }],
     member: [ ObjectId ],
     operation: {
       type: Number,

server/app/router.js

@@ -10,6 +10,8 @@ module.exports = app => {
   app.put('/server/group/:id/claim', 'group.claim') // 认领分组，这是历史原因导致的接口，可以不关心
   app.delete('/server/group/:id', 'group.delete')
   app.put('/server/group/:id', 'group.update')
+  app.put('/server/group/follower/:groupId', 'group.follow')
+  app.delete('/server/group/follower/:groupId', 'group.unfollow')
 
   app.get('/server/api/', 'api.getAll')
   app.get('/server/api/manage', 'api.getManageApi')

server/app/service/group.js

@@ -46,9 +46,23 @@ class Group extends Service {
       manager: this.ctx.authUser._id
     }, Object.assign(group, { modifiedTime: Date.now() }), { new: true })
   }
+  updateFollower (groupId, follower) {
+    return this.ctx.model.Group.findOneAndUpdate(
+      { _id: groupId },
+      {
+        follower,
+        modifiedTime: Date.now()
+      },
+      { new: true }
+    )
+  }
   updateTime (groupId) {
     // 此方法允许异步执行
-    return this.ctx.model.Group.update({ _id: groupId }, { modifiedTime: Date.now() }, { new: true }).exec()
+    return this.ctx.model.Group.findOneAndUpdate(
+      { _id: groupId },
+      { modifiedTime: Date.now() },
+      { new: true }
+    ).exec()
   }
   create (group) {
     const authId = this.ctx.authUser._id