test: add service at unit test (#57)

* test: add service at unit test

* chore: fix lint

Author: sinchang

app/service/at.js

@@ -45,9 +45,10 @@ class AtService extends Service {
    * @param {String} text 文本内容
    * @param {String} topicId 主题ID
    * @param {String} authorId 作者ID
+   * @param {String} type 回复类型
    * @param {String} reply_id 回复ID
    */
-  async sendMessageToMentionUsers(text, topicId, authorId, reply_id = null) {
+  async sendMessageToMentionUsers(text, topicId, authorId, type, reply_id = null) {
     let users = await this.service.user.getUsersByNames(this.fetchUsers(text));
 
     users = users.filter(user => {
@@ -60,6 +61,7 @@ class AtService extends Service {
           user._id,
           authorId,
           topicId,
+          type,
           reply_id
         );
       })

app/service/message.js

@@ -117,6 +117,18 @@ class MessageService extends Service {
     const update = { $set: { has_read: true } };
     return this.ctx.model.Message.update(query, update, { multi: true }).exec();
   }
+
+  async sendAtMessage(userId, authorId, topicId, type, replyId) {
+    const message = this.ctx.model.Message();
+
+    message.type = type;
+    message.master_id = userId;
+    message.author_id = authorId;
+    message.topic_id = topicId;
+    message.reply_id = replyId;
+
+    return message.save();
+  }
 }
 
 module.exports = MessageService;

test/app/service/at.test.js

@@ -0,0 +1,68 @@
+'use strict';
+
+const { app, assert } = require('egg-mock/bootstrap');
+
+describe('test/app/service/at.test.js', () => {
+  let topicId,
+    loginname1,
+    loginname2,
+    user1,
+    user2,
+    replyId,
+    ctx,
+    atService;
+  before(async function() {
+    ctx = app.mockContext();
+    atService = ctx.service.at;
+    loginname1 = `loginname1_${Date.now()}`;
+    loginname2 = `loginname2_${Date.now()}`;
+    user1 = await ctx.service.user.newAndSave('name', loginname1, 'pass', `${loginname1}@test.com`, 'avatar_url', 'active');
+    user2 = await ctx.service.user.newAndSave('name', loginname2, 'pass', `${loginname2}@test.com`, 'avatar_url', 'active');
+    assert(user1.loginname === loginname1);
+    assert(user2.loginname === loginname2);
+
+    const title = 'first post';
+    const content = 'hello world';
+    const tab = 'share';
+    const topic = await ctx.service.topic.newAndSave(title, content, tab, user1._id);
+    topicId = topic._id;
+    assert(topic.title === title);
+    assert(topic.content === content);
+    assert(topic.tab === tab);
+    assert.equal(topic.author_id, user1._id);
+
+    const reply = await ctx.service.reply.newAndSave('hi', topicId, user1._id);
+    assert(reply.content === 'hi');
+    assert(reply.author_id === user1._id);
+    assert(reply.topic_id === topicId);
+    replyId = reply._id;
+  });
+
+  it('fetchUsers should ok', async () => {
+    const result1 = await atService.fetchUsers();
+    assert(result1.length === 0);
+    const result2 = await ctx.service.at.fetchUsers('good job!!! @sinchang @cnode');
+    assert(result2[0] === 'sinchang');
+    assert(result2[1] === 'cnode');
+  });
+
+  it('sendMessageToMentionUsers should ok', async () => {
+    const result1 = await atService.sendMessageToMentionUsers(`hi!!!@${loginname2}`, topicId, user1._id, 'at');
+    assert(result1[0].type === 'at');
+    assert(result1[0].topic_id === topicId);
+    assert(result1[0].author_id === user1._id);
+    assert.equal(result1[0].master_id.toString(), user2._id);
+    assert(result1[0].reply_id === null);
+    const result2 = await atService.sendMessageToMentionUsers(`hi!!!@${loginname2}`, topicId, user1._id, 'reply2', replyId);
+    assert(result2[0].type === 'reply2');
+    assert(result2[0].topic_id === topicId);
+    assert(result2[0].author_id === user1._id);
+    assert.equal(result2[0].master_id.toString(), user2._id);
+    assert(result2[0].reply_id === replyId);
+  });
+
+  it('linkUsers should ok', async () => {
+    const result = await atService.linkUsers(`hi!!!@${loginname2}`);
+    assert(result === `hi!!![@${loginname2}](/user/${loginname2})`);
+  });
+});