引入redis服务,支持自动化单元测试
大石头 编写于 2022-03-31 22:56:30
X
using System;
using System.Collections.Generic;
using System.Text;
using NewLife.Messaging;
using Xunit;
using NewLife;

namespace XUnitTest.Messaging
{
    public class DefaultMessageTests
    {
        [Fact]
        public void BinaryEncode()
        {
            var msg = new DefaultMessage
            {
                Sequence = 1,
                Payload = "Open".GetBytes(),
            };
            var pk = msg.ToPacket();
            Assert.Equal(1, pk[0]);
            Assert.Equal(1, pk[1]);
            Assert.Equal(4, pk[2]);
            Assert.Equal(0, pk[3]);
            Assert.Equal("Open", pk.Slice(4).ToStr());

            var msgd = new DefaultMessage();
            var rs = msgd.Read(pk);
            Assert.True(rs);
            Assert.Equal(msg.Flag, msgd.Flag);
            Assert.Equal(msg.Sequence, msgd.Sequence);
            Assert.Equal(msg.Payload.ToStr(), msgd.Payload.ToStr());

            var msg2 = new DefaultMessage
            {
                Reply = true,
                Sequence = 1,
                Payload = "执行成功".GetBytes(),
            };
            var pk2 = msg2.ToPacket();
            Assert.Equal(0x81, pk2[0]);
            Assert.Equal(1, pk2[1]);
            Assert.Equal(12, pk2[2]);
            Assert.Equal(0, pk2[3]);
            Assert.Equal("执行成功", pk2.Slice(4).ToStr());

            var msgd2 = new DefaultMessage();
            var rs2 = msgd2.Read(pk2);
            Assert.True(rs2);
            Assert.Equal(msg2.Flag, msgd2.Flag);
            Assert.Equal(msg2.Sequence, msgd2.Sequence);
            Assert.Equal(msg2.Payload.ToStr(), msgd2.Payload.ToStr());
        }

        [Fact]
        public void StringEncode()
        {
            var msg = new DefaultMessage
            {
                Sequence = 1,
                Payload = "Open".GetBytes(),
            };
            var str = msg.Encode();
            Assert.Equal("4,1,1:Open", str);

            var msg2 = new DefaultMessage
            {
                Reply = true,
                Sequence = 1,
                Payload = "执行成功".GetBytes(),
            };
            var str2 = msg2.Encode();
            Assert.Equal("12,1,129:执行成功", str2);
        }

        [Fact]
        public void StringEncodeNoFlag()
        {
            var msg = new DefaultMessage
            {
                Sequence = 1,
                Payload = "Open".GetBytes(),
            };
            var str = msg.Encode(null, false);
            Assert.Equal("4,1:Open", str);

            var msg2 = new DefaultMessage
            {
                Reply = true,
                Sequence = 1,
                Payload = "执行成功".GetBytes(),
            };
            var str2 = msg2.Encode(null, false);
            Assert.Equal("12,1:执行成功", str2);
        }

        [Fact]
        public void StringDecode()
        {
            {
                var msg = new DefaultMessage();
                var rs = msg.Decode("4,1,1:Open");
                Assert.True(rs);
                Assert.Equal(1, msg.Sequence);
                Assert.Equal(1, msg.Flag);
                Assert.Equal("Open", msg.Payload.ToStr());
            }

            {
                var msg = new DefaultMessage();
                var rs = msg.Decode("12,1,129:执行成功");
                Assert.True(rs);
                Assert.Equal(1, msg.Sequence);
                Assert.Equal(0x81, msg.Flag);
                Assert.Equal("执行成功", msg.Payload.ToStr());
            }

            {
                var msg = new DefaultMessage();
                var rs = msg.Decode("12,1,129:执行成功".GetBytes());
                Assert.True(rs);
                Assert.Equal(1, msg.Sequence);
                Assert.Equal(0x81, msg.Flag);
                Assert.Equal("执行成功", msg.Payload.ToStr());
            }
        }
    }
}