im.doctor/test/client/im.client.session.p2p.Test.js

/**
 * IM客户端单元测试。单元测试编写规则：至少对对每个接口执行正反例测试，若有条件可以增加接口的性能测试。
 *
 * 此部分为P2P会话测试。
 *
 * @author sand
 * @since 2016/12/24
 */
"use strict";

let assert = require('assert');
let imClient = require('../../src/client/im.client');

// 测试会话用的数据, test data
let TD = {
    SessionId: 'd5cbe9d10669f8741bc0805b20697ad1254c8e90', //'b07e8c4eabcb0c6fe790843026424afb2fb64d80',
    UnreadMessageCount: 0,
    P2P: {
        DoctorA: {
            id: "cd92414c-5b06-11e6-8344-fa163e8aee56",
            name: "周美丽",
            token: "0PFWlKmLBN9YzhCfFWVgYA",
            clientId: "c9e1c2cef42e609085ff15bac54004e3",
            platform: 1
        },
        DoctorB: {
            id: "cd919343-5b06-11e6-8344-fa163e8aee56",
            name: "李毅",
            token: "8F01F2780AA3677B1F01BDBD63BEBFA7530E1E73FC7FA4C110A5F475ECFD4ADE",
            clientId: "2fa4119e7f77a8077dbd0324838f963b",
            platform: 0
        },
        PatientA: {
            id: "d5cbe9d10669f8741bc0805b20697ad1254c8e90",
            name: "陈爱珍"
        }
    }
};

/**
 * 会话API。测试逻辑：
 * A医生登录
 * B医生登录
 *
 * A医生向B医生发送3条消息
 * B医生获取会话列表
 * B医生获取与A医生的会话未读消息列表
 *
 * B医生向A医生发送5条消息
 * A医生获取会话列表
 * A医生获取与A医生的会话未读消息列表
 *
 * A医生退出
 * B医生退出
 */
describe("Session P2P", function () {
    // 登录
    describe("User login", function () {
        it("all user must be success", function (done) {
            imClient.Users.login(TD.P2P.DoctorA.id, TD.P2P.DoctorA.token, TD.P2P.DoctorA.clientId, TD.P2P.DoctorA.platform,
                function (data) {
                    assert.ok(Object.keys(data).length === 0, "Doctor A login failed.");
                },
                function (xhr, status, error) {
                    assert.ok(false, xhr.responseJSON.message);
                });

            imClient.Users.login(TD.P2P.DoctorB.id, TD.P2P.DoctorB.token, TD.P2P.DoctorB.clientId, TD.P2P.DoctorB.platform,
                function (data) {
                    assert.ok(Object.keys(data).length === 0, "Doctor B login failed.");
                    done();
                },
                function (xhr, status, error) {
                    assert.ok(false, xhr.responseJSON.message);
                    done();
                });
        });
    });

    // 发送消息: A -> B
    describe("Send message from A to B", function () {
        it("every message must be ok", function (done) {
            // 创建会话并发送消息
            imClient.Sessions.createP2pSession(TD.P2P.DoctorA.id, TD.P2P.DoctorB.id,
                function (session) {
                    assert.ok(session.data.id.length > 0, "Create session failed.");

                    TD.SessionId = session.id;
                    imClient.Sessions.sendMessage(session.data.id, TD.P2P.DoctorA.id, TD.P2P.DoctorA.name, "李医生，你好", 1,
                        function (data) {
                            assert.ok(Object.keys(data).length > 0, "Send message failed.");
                        }, function (xhr, status, error) {
                            assert.ok(false, xhr.responseJSON.message)
                        });

                    imClient.Sessions.sendMessage(session.data.id, TD.P2P.DoctorA.id, TD.P2P.DoctorA.name, "莲前社区糖尿病患者已进入随访跟踪状态", 1,
                        function (data) {
                            assert.ok(Object.keys(data).length > 0, "Send message failed.");
                        }, function (xhr, status, error) {
                            assert.ok(false, xhr.responseJSON.message)
                        });

                    imClient.Sessions.sendMessage(session.data.id, TD.P2P.DoctorA.id, TD.P2P.DoctorA.name, "但处方信息还需要您的确认，请尽快回复，谢谢！", 1,
                        function (data) {
                            assert.ok(Object.keys(data).length > 0, "Send message failed.");
                            done();
                        }, function (xhr, status, error) {
                            assert.ok(false, xhr.responseJSON.message)
                        });
                },
                function (xhr, status, error) {
                    assert.ok(false, xhr.responseJSON.message);
                    done();
                });
        });
    });

    // 获取会话列表及消息数
    describe("B: Get sessions and unread messages", function () {
        it("every operation must be ok", function (done) {
            imClient.Sessions.getSessionsWithDoctor(TD.P2P.DoctorB.id, 0, 10,
                function (sessions) {
                    let isPass = false;
                    for (let i in sessions) {
                        if (sessions[i].id == TD.SessionId) {
                            isPass = true;
                            TD.UnreadMessageCount = sessions[i].unread_count;
                            break;
                        }
                    }

                    assert.ok(isPass, "Get sessions with doctor failed.");

                    // 读取未读消息数
                    imClient.Sessions.getSessionUnreadMessageCount(TD.SessionId, TD.P2P.DoctorB.id,
                        function (data) {
                            assert.strictEqual(data.count, TD.UnreadMessageCount, "Unread message count dismatch.");
                        },
                        function (xhr, status, error) {
                            assert(false, xhr.responseJSON.message);
                        });

                    // 获取未读消息
                    imClient.Sessions.getSessionUnreadMessages(TD.SessionId, TD.P2P.DoctorB.id,
                        function (data) {
                            assert.strictEqual(data.length, TD.UnreadMessageCount, "Get session unread messages failed.");
                            data.forEach(function (message) {
                                console.log(message);
                            });

                            done();
                        },
                        function (xhr, status, error) {
                            assert(false, xhr.responseJSON.message);
                            done();
                        });
                },
                function (xhr, status, error) {
                    assert.ok(false, xhr.responseJSON.message);

                    done();
                });
        });
    });

    // 获取最近会话列表，默认按7天
    describe("Get recent sessions", function () {
        it("should return recent session in 7 days", function (done) {
            imClient.Sessions.getRecentSessions('shiliuD20160926008',
                function (data) {
                    assert.ok(data.length > 0, "Test data must return at least one session");

                    console.log(data);

                    done();
                },
                function (xhr, status, error) {
                    assert.ok(false, xhr.responseJSON.message);

                    done();
                });
        });
    });

    // 获取会话的消息
    describe("Get session messages", function () {
        it("should return session messages by page", function (done) {
            imClient.Sessions.getMessagesBySession(TD.SessionId, TD.DoctorB.id, null, null, null, null,
                function (messages) {
                    assert.ok(messages.length > 0);
                },
                function (xhr, status, error) {
                    assert.ok(false, message.responseJSON.message);
                });
        });
    });

    // 获取会话成员及头像
    describe("Get session participants", function () {
        it("should return two participants and avatars", function (done) {
            imClient.Sessions.getParticipants(TD.SessionId,
                function (data) {
                    assert.ok(data.length, 2, "P2P session participant number must be 2");

                    data.forEach(function (participant) {
                        console.log(participant);
                    });
                },
                function (xhr, status, error) {
                    assert.ok(false, xhr.responseJSON.message);
                });

            imClient.Sessions.getParticipantsAvatars(TD.SessionId,
                function (avatars) {
                    assert.ok(avatars.length, 2, "P2P session participant avatars number must be 2");

                    avatars.forEach(function (avatars) {
                        console.log(avatars);
                    });

                    done();
                },
                function (xhr, status, error) {
                    assert.ok(false, xhr.responseJSON.message);

                    done();
                });
        });
    });

    // 退出
    describe("User logout", function () {
        it("all user must be success", function (done) {
            imClient.Users.logout(TD.P2P.DoctorA.id, function (data) {
                assert.ok(Object.keys(data).length === 0, "Doctor A logout failed.");
            }, function (xhr, status, error) {
                assert.ok(false, xhr.responseJSON.message);
            });
            imClient.Users.logout(TD.P2P.DoctorB.id, function (data) {
                assert.ok(Object.keys(data).length === 0, "Doctor B logout failed.");
                done();
            }, function (xhr, status, error) {
                assert.ok(false, xhr.responseJSON.message);
                done();
            });
        });
    });
});