/*
 * Copyright (c) 2021 Huawei Device Co., Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include <gtest/gtest.h>

#include "net_trans_common.h"
#include "wifi_utils.h"
#include "accesstoken_kit.h"

using namespace testing::ext;

class TransFuncTest : public testing::Test {
public:
    // 测试套前置和后置操作
    static void SetUpTestCase();
    static void TearDownTestCase();

    // 测试用例前置和后置操作
    void SetUp();
    void TearDown();
};

void TransFuncTest::SetUp() {}

void TransFuncTest::TearDown()
{
    sleepn(1);
}

void TransFuncTest::SetUpTestCase()
{
    LOG("SetUp begin");
    AddPermission();
    sleep(1);
    OHOS::Security::AccessToken::AccessTokenKit::ReloadNativeTokenInfo();
    sleep(1);
    TestSetUp();
    int ret = RegisterDeviceStateDefCallback();
    EXPECT_EQ(SOFTBUS_OK, ret) << "call reg node state callback fail";
    ret = CheckRemoteDeviceIsNull(BOOL_TRUE);
    ASSERT_EQ(SOFTBUS_OK, ret) << "get node fail,please check network";

    LOG("SetUp end");
}

void TransFuncTest::TearDownTestCase()
{
    int ret = UnRegisterDeviceStateDefCallback();
    EXPECT_EQ(SOFTBUS_OK, ret) << "call unReg node state callback fail";

    TestTearDown();
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendBytes_0100
 * @tc.name   : SendByte Packet size 1B, send and receive successful
 * @tc.desc   : Test the SendByte specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendBytes_0100, TestSize.Level3)
{
    int ret;
    ret = CreateSsAndOpenSession4Data();
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    int size = 1;
    ret = SendData4Data(DATA_TYPE_BYTE, size);
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(byte, 1B) fail";

    ret = CloseSessionAndRemoveSs4Data();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendBytes_0200
 * @tc.name   : SendByte Packet size 2M, send and receive successful
 * @tc.desc   : Test the SendByte specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendBytes_0200, TestSize.Level3)
{
    int ret;
    ret = CreateSsAndOpenSession4Data();
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    int size = 2 * 1024 * 1024;
    ret = SendData4Data(DATA_TYPE_BYTE, size);
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(byte,2M) fail";

    ret = CloseSessionAndRemoveSs4Data();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendBytes_0300
 * @tc.name   : SendByte Packet size 0, send and receive failed
 * @tc.desc   : Test the SendByte specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendBytes_0300, TestSize.Level3)
{
    int ret;
    ret = CreateSsAndOpenSession4Data();
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    int size = 0;
    string emptyStr = "";
    int sessionId = GetCurrentSessionId4Data();
    ret = SendBytes(sessionId, emptyStr.c_str(), size);
    EXPECT_NE(SOFTBUS_OK, ret) << "call sendbytes(empty) fail";

    ret = CloseSessionAndRemoveSs4Data();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}


/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendBytes_0400
 * @tc.name   : SendByte Packet size 1B ,Proxy channel, send and receive failed
 * @tc.desc   : Test the SendByte specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendBytes_0400, TestSize.Level3)
{
    int ret;
    ret = CreateSsAndOpenSession4Proxy();
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    int size = 1;
    ret = SendData4Message(DATA_TYPE_BYTE, size);
    EXPECT_NE(SOFTBUS_OK, ret) << "SendData4Data(byte, 1B) fail";

    ret = CloseSessionAndRemoveSs4Proxy();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendBytes_0500
 * @tc.name   : SendByte Packet size Max by session Negotiate, send and receive failed
 * @tc.desc   : Test the SendByte specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendBytes_0500, TestSize.Level3)
{
    int ret;
    ret = CreateSsAndOpenSession4Data();
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    int optionvalue = 0;
    ret = GetSessionOption(GetCurrentSessionId4Data(), SESSION_OPTION_MAX_SENDBYTES_SIZE,
                           &optionvalue, sizeof(optionvalue));
    EXPECT_EQ(SOFTBUS_OK, ret) << "GetSessionOption fail";
    LOG("GetSessionOption optionvalue = %d", optionvalue);
    int size = optionvalue;
    ret = SendData4Data(DATA_TYPE_BYTE, size);
    EXPECT_EQ(SOFTBUS_OK, ret) << "call sendbytes(Max) fail";

    ret = CloseSessionAndRemoveSs4Data();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendBytes_0600
 * @tc.name   : SendByte Packet size Max + 1 by session Negotiate, send and receive failed
 * @tc.desc   : Test the SendByte specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendBytes_0600, TestSize.Level3)
{
    int ret;
    ret = CreateSsAndOpenSession4Data();
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    int optionvalue = 0;
    ret = GetSessionOption(GetCurrentSessionId4Data(), SESSION_OPTION_MAX_SENDBYTES_SIZE,
                           &optionvalue, sizeof(optionvalue));
    EXPECT_EQ(SOFTBUS_OK, ret) << "GetSessionOption fail";
    LOG("GetSessionOption optionvalue = %d", optionvalue);
    int size = optionvalue + 1;
    ret = SendData4Data(DATA_TYPE_BYTE, size);
    EXPECT_NE(SOFTBUS_OK, ret) << "call sendbytes(Max + 1) fail";

    ret = CloseSessionAndRemoveSs4Data();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendMessage_0100
 * @tc.name   : SendMessage Packet size 1B, session type is TYPE_BYTES send and receive failed
 * @tc.desc   : Test the SendMessage specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendMessage_0100, TestSize.Level3)
{
    int ret;
    ret = CreateSsAndOpenSession4Data();
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    int size = 1;
    ret = SendData4Data(DATA_TYPE_MSG, size);
    EXPECT_NE(SOFTBUS_OK, ret) << "SendData4Data(msg, 1B) fail";

    ret = CloseSessionAndRemoveSs4Data();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendMessage_0200
 * @tc.name   : SendMessage Packet size 1B, proxy channel, send and receive successful
 * @tc.desc   : [G-DISTRIBUTED-0206]禁止修改传输的默认协议，新增或者变更默认传输协议必须通过协商机制来实现
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendMessage_0200, TestSize.Level3)
{
    int ret;
    ret = CreateSsAndOpenSession4Proxy();
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    int size = 1;
    ret = SendData4Message(DATA_TYPE_MSG, size);
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(msg, 1B) fail";

    ret = CloseSessionAndRemoveSs4Proxy();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendMessage_0300
 * @tc.name   : SendMessage Packet size 1K, proxy channel, send and receive successful
 * @tc.desc   : [G-DISTRIBUTED-0206]禁止修改传输的默认协议，新增或者变更默认传输协议必须通过协商机制来实现
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendMessage_0300, TestSize.Level3)
{
    int ret;
    ret = CreateSsAndOpenSession4Proxy();
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    int size = 1024;
    ret = SendData4Message(DATA_TYPE_MSG, size);
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(msg,1K) fail";

    ret = CloseSessionAndRemoveSs4Proxy();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendMessage_0400
 * @tc.name   : SendMessage Packet size 0, proxy channel, send and receive failed
 * @tc.desc   : Test the SendMessage specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendMessage_0400, TestSize.Level3)
{
    int ret;
    ret = CreateSsAndOpenSession4Proxy();
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    int size = 0;
    string emptystr = "";
    int sessionId = GetCurrentSessionId4Proxy();
    ret = SendMessage(sessionId, emptystr.c_str(), size);
    EXPECT_NE(SOFTBUS_OK, ret) << "call sendmsg(empty) fail";

    ret = CloseSessionAndRemoveSs4Proxy();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendMessage_0500
 * @tc.name   : SendMessage Packet size Max by session Negotiate, proxy channel, send and receive failed
 * @tc.desc   : [G-DISTRIBUTED-0210] 使用消息传输接口，消息大小不超过4K字节，超过时需要业务对消息进行分包
 *             处理，或者改为使用字节传输接口，字节传输可支持最大4M字节
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendMessage_0500, TestSize.Level3)
{
    int ret;
    ret = CreateSsAndOpenSession4Proxy();
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    int optionvalue = 0;
    ret = GetSessionOption(GetCurrentSessionId4Proxy(), SESSION_OPTION_MAX_SENDMESSAGE_SIZE,
                           &optionvalue, sizeof(optionvalue));
    EXPECT_EQ(SOFTBUS_OK, ret) << "GetSessionOption fail";
    LOG("GetSessionOption optionvalue = %d", optionvalue);
    int size = optionvalue;
    ret = SendData4Message(DATA_TYPE_MSG, size);
    EXPECT_EQ(SOFTBUS_OK, ret) << "call sendmsg(Max) fail";

    ret = CloseSessionAndRemoveSs4Proxy();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendMessage_0600
 * @tc.name   : SendMessage Packet size Max +1 by session Negotiate, proxy channel, send and receive failed
 * @tc.desc   : [G-DISTRIBUTED-0210] 使用消息传输接口，消息大小不超过4K字节，超过时需要业务对消息进行分包
 *             处理，或者改为使用字节传输接口，字节传输可支持最大4M字节
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendMessage_0600, TestSize.Level3)
{
    int ret;
    ret = CreateSsAndOpenSession4Proxy();
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    int optionvalue = 0;
    ret = GetSessionOption(GetCurrentSessionId4Proxy(), SESSION_OPTION_MAX_SENDMESSAGE_SIZE,
                           &optionvalue, sizeof(optionvalue));
    EXPECT_EQ(SOFTBUS_OK, ret) << "GetSessionOption fail";
    LOG("GetSessionOption optionvalue = %d", optionvalue);
    int size = optionvalue + 1;
    ret = SendData4Message(DATA_TYPE_MSG, size);
    EXPECT_NE(SOFTBUS_OK, ret) << "call sendmsg(Max+1) fail";

    ret = CloseSessionAndRemoveSs4Proxy();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendBytes_P2P_0100
 * @tc.name   : SendByte By P2P Packet size 1B, send and receive successful
 * @tc.desc   : [G-DISTRIBUTED-0206]禁止修改传输的默认协议，新增或者变更默认传输协议必须通过协商机制来实现
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendBytes_P2P_0100, TestSize.Level3)
{
    int ret;
    ret = CreateSessionServer(DEF_PKG_NAME, SESSION_NAME_DATA, GetSessionListenser4Data());
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    ret = OpenSession4DataByP2p();
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(byte, 1B) fail";

    int size = 1;
    ret = SendData4Data(DATA_TYPE_BYTE, size);
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(byte, 1B) fail";

    ret = CloseSessionAndRemoveSs4Data();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendBytes_P2P_0200
 * @tc.name   : SendByte By P2P Packet size 2M, send and receive successful
 * @tc.desc   : Test the SendByte specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendBytes_P2P_0200, TestSize.Level3)
{
    int ret;
    ret = CreateSessionServer(DEF_PKG_NAME, SESSION_NAME_DATA, GetSessionListenser4Data());
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    ret = OpenSession4DataByP2p();
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(byte, 1B) fail";

    int size = 2 * 1024 * 1024;
    ret = SendData4Data(DATA_TYPE_BYTE, size);
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(byte,2M) fail";

    ret = CloseSessionAndRemoveSs4Data();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendBytes_P2P_0300
 * @tc.name   : SendByte By P2P Packet size 0, send and receive failed
 * @tc.desc   : Test the SendByte specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendBytes_P2P_0300, TestSize.Level3)
{
    int ret;
    ret = CreateSessionServer(DEF_PKG_NAME, SESSION_NAME_DATA, GetSessionListenser4Data());
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    ret = OpenSession4DataByP2p();
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(byte, 1B) fail";

    int size = 0;
    string emptyStr = "";
    int sessionId = GetCurrentSessionId4Data();
    ret = SendBytes(sessionId, emptyStr.c_str(), size);
    EXPECT_NE(SOFTBUS_OK, ret) << "call sendbytes(empty) fail";

    ret = CloseSessionAndRemoveSs4Data();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendBytes_P2P_0400
 * @tc.name   : SendByte By P2P Packet size 1B ,Proxy channel, send and receive failed
 * @tc.desc   : Test the SendByte specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendBytes_P2P_0400, TestSize.Level3)
{
    int ret;
    ret = CreateSessionServer(DEF_PKG_NAME, SESSION_NAME_PROXY, GetSessionListenser4Proxy());
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    ret = OpenSession4ProxyByP2p();
    ASSERT_EQ(SOFTBUS_OK, ret) << "SendData4Data(byte, 1B) fail";

    int size = 1;
    ret = SendData4Message(DATA_TYPE_BYTE, size);
    EXPECT_NE(SOFTBUS_OK, ret) << "SendData4Data(byte, 1B) fail";

    ret = CloseSessionAndRemoveSs4Proxy();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendBytes_P2P_0500
 * @tc.name   : SendByte By P2P Packet size Max by session Negotiate, send and receive successful
 * @tc.desc   : [G-DISTRIBUTED-0210] 使用消息传输接口，消息大小不超过4K字节，超过时需要业务对消息进行分包
 *             处理，或者改为使用字节传输接口，字节传输可支持最大4M字节
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendBytes_P2P_0500, TestSize.Level3)
{
    int ret;
    ret = CreateSessionServer(DEF_PKG_NAME, SESSION_NAME_DATA, GetSessionListenser4Data());
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    ret = OpenSession4DataByP2p();
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(byte, 1B) fail";

    int optionvalue = 0;
    ret = GetSessionOption(GetCurrentSessionId4Data(), SESSION_OPTION_MAX_SENDBYTES_SIZE,
                           &optionvalue, sizeof(optionvalue));
    EXPECT_EQ(SOFTBUS_OK, ret) << "GetSessionOption fail";
    LOG("GetSessionOption optionvalue = %d", optionvalue);
    int size = optionvalue;
    ret = SendData4Data(DATA_TYPE_BYTE, size);
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(byte,Max) fail";

    ret = CloseSessionAndRemoveSs4Data();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendBytes_P2P_0600
 * @tc.name   : SendByte By P2P Packet size Max + 1 by session Negotiate, send and receive failed
 * @tc.desc   : [G-DISTRIBUTED-0210] 使用消息传输接口，消息大小不超过4K字节，超过时需要业务对消息进行分包
 *             处理，或者改为使用字节传输接口，字节传输可支持最大4M字节
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendBytes_P2P_0600, TestSize.Level3)
{
    int ret;
    ret = CreateSessionServer(DEF_PKG_NAME, SESSION_NAME_DATA, GetSessionListenser4Data());
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    ret = OpenSession4DataByP2p();
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(byte, 1B) fail";

    int optionvalue = 0;
    ret = GetSessionOption(GetCurrentSessionId4Data(), SESSION_OPTION_MAX_SENDBYTES_SIZE,
                           &optionvalue, sizeof(optionvalue));
    EXPECT_EQ(SOFTBUS_OK, ret) << "GetSessionOption fail";
    LOG("GetSessionOption optionvalue = %d", optionvalue);
    int size = optionvalue + 1;
    ret = SendData4Data(DATA_TYPE_BYTE, size);
    EXPECT_NE(SOFTBUS_OK, ret) << "call sendbytes(empty) fail";

    ret = CloseSessionAndRemoveSs4Data();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendMessage_P2P_0100
 * @tc.name   : SendMessage By P2P Packet size 1B, send and receive failed
 * @tc.desc   : Test the SendMessage specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendMessage_P2P_0100, TestSize.Level3)
{
    int ret;
    ret = CreateSessionServer(DEF_PKG_NAME, SESSION_NAME_DATA, GetSessionListenser4Data());
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss and openS[data] fail";

    ret = OpenSession4DataByP2p();
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(byte, 1B) fail";
    int size = 1;
    ret = SendData4Data(DATA_TYPE_MSG, size);
    EXPECT_NE(SOFTBUS_OK, ret) << "SendData4Data(msg, 1B) fail";

    ret = CloseSessionAndRemoveSs4Data();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendMessage_P2P_0200
 * @tc.name   : SendMessage Packet size 1B, proxy channel, send and receive successful
 * @tc.desc   : Test the SendMessage specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendMessage_P2P_0200, TestSize.Level3)
{
    int ret;
    ret = CreateSessionServer(DEF_PKG_NAME, SESSION_NAME_PROXY, GetSessionListenser4Proxy());
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss [Proxy] fail";

    ret = OpenSession4ProxyByP2p();
    EXPECT_EQ(SOFTBUS_OK, ret) << "OpenSession Proxy fail";

    int size = 1;
    ret = SendData4Message(DATA_TYPE_MSG, size);
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(msg, 1B) fail";

    ret = CloseSessionAndRemoveSs4Proxy();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendMessage_P2P_0300
 * @tc.name   : SendMessage Packet size 1K, proxy channel, send and receive successful
 * @tc.desc   : Test the SendMessage specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendMessage_P2P_0300, TestSize.Level3)
{
    int ret;
    ret = CreateSessionServer(DEF_PKG_NAME, SESSION_NAME_PROXY, GetSessionListenser4Proxy());
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss [Proxy] fail";

    ret = OpenSession4ProxyByP2p();
    EXPECT_EQ(SOFTBUS_OK, ret) << "OpenSession Proxy fail";

    int size = 1024;
    ret = SendData4Message(DATA_TYPE_MSG, size);
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(msg,1K) fail";

    ret = CloseSessionAndRemoveSs4Proxy();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendMessage_P2P_0400
 * @tc.name   : SendMessage Packet size 0, proxy channel, send and receive failed
 * @tc.desc   : Test the SendMessage specification
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendMessage_P2P_0400, TestSize.Level3)
{
    int ret;
    ret = CreateSessionServer(DEF_PKG_NAME, SESSION_NAME_PROXY, GetSessionListenser4Proxy());
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss [Proxy] fail";

    ret = OpenSession4ProxyByP2p();
    ASSERT_EQ(SOFTBUS_OK, ret) << "OpenSession Proxy fail";

    int size = 0;
    string emptystr = "";
    int sessionId = GetCurrentSessionId4Proxy();
    ret = SendMessage(sessionId, emptystr.c_str(), size);
    EXPECT_NE(SOFTBUS_OK, ret) << "call sendmsg(empty) fail";

    ret = CloseSessionAndRemoveSs4Proxy();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendMessage_P2P_0500
 * @tc.name   : SendMessage Packet size max by session Negotiate, proxy channel, send and receive successful
 * @tc.desc   : [G-DISTRIBUTED-0210] 使用消息传输接口，消息大小不超过4K字节，超过时需要业务对消息进行分包
 *             处理，或者改为使用字节传输接口，字节传输可支持最大4M字节
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendMessage_P2P_0500, TestSize.Level3)
{
    int ret;
    ret = CreateSessionServer(DEF_PKG_NAME, SESSION_NAME_PROXY, GetSessionListenser4Proxy());
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss [Proxy] fail";

    ret = OpenSession4ProxyByP2p();
    EXPECT_EQ(SOFTBUS_OK, ret) << "OpenSession Proxy fail";

    int optionvalue = 0;
    ret = GetSessionOption(GetCurrentSessionId4Proxy(), SESSION_OPTION_MAX_SENDMESSAGE_SIZE,
                           &optionvalue, sizeof(optionvalue));
    EXPECT_EQ(SOFTBUS_OK, ret) << "GetSessionOption fail";
    LOG("GetSessionOption optionvalue = %d", optionvalue);
    int size = optionvalue;
    ret = SendData4Message(DATA_TYPE_MSG, size);
    EXPECT_EQ(SOFTBUS_OK, ret) << "SendData4Data(msg,Max) fail";

    ret = CloseSessionAndRemoveSs4Proxy();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}

/**
 * @tc.number : SUB_DSoftbus_Spec_DCTS_SendMessage_P2P_0600
 * @tc.name   : SendMessage Packet size Max +1 by session Negotiate, proxy channel, send and receive failed
 * @tc.desc   : [G-DISTRIBUTED-0210] 使用消息传输接口，消息大小不超过4K字节，超过时需要业务对消息进行分包
 *             处理，或者改为使用字节传输接口，字节传输可支持最大4M字节
 * @tc.type   : FUNC
 * @tc.size   : MediumTest
 */
HWTEST_F(TransFuncTest, SUB_DSoftbus_Spec_DCTS_SendMessage_P2P_0600, TestSize.Level3)
{
    int ret;
    ret = CreateSessionServer(DEF_PKG_NAME, SESSION_NAME_PROXY, GetSessionListenser4Proxy());
    ASSERT_EQ(SOFTBUS_OK, ret) << "create Ss [Proxy] fail";

    ret = OpenSession4ProxyByP2p();
    ASSERT_EQ(SOFTBUS_OK, ret) << "OpenSession Proxy fail";

    int optionvalue = 0;
    ret = GetSessionOption(GetCurrentSessionId4Proxy(), SESSION_OPTION_MAX_SENDMESSAGE_SIZE,
                           &optionvalue, sizeof(optionvalue));
    EXPECT_EQ(SOFTBUS_OK, ret) << "GetSessionOption fail";
    LOG("GetSessionOption optionvalue = %d", optionvalue);
    int size = optionvalue + 1;
    ret = SendData4Message(DATA_TYPE_MSG, size);
    EXPECT_NE(SOFTBUS_OK, ret) << "call sendmsg(Max+1) fail";

    ret = CloseSessionAndRemoveSs4Proxy();
    EXPECT_EQ(SOFTBUS_OK, ret) << "close session and remove Ss fail";
}