/*
 * Copyright (c) 2021-2024 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 "network/softbus/softbus_session.h"

#include "dfs_session.h"
#include "fcntl.h"
#include "utils_log.h"

namespace OHOS {
namespace Storage {
namespace DistributedFile {
using namespace std;

constexpr int32_t SOFTBUS_OK = 0;

SoftbusSession::SoftbusSession(int32_t sessionId, std::string peerDeviceId) : sessionId_(sessionId), cid_(peerDeviceId)
{
    int32_t socketFd = INVALID_SOCKET_FD;
    int32_t ret = ::GetSessionHandle(sessionId_, &socketFd);
    if (ret != SOFTBUS_OK || socketFd < 0) {
        LOGE("get session socket fd failed, errno:%{public}d, sessionId:%{public}d", ret, sessionId_);
        socketFd_ = INVALID_SOCKET_FD;
        return;
    }
    int32_t flags = fcntl(socketFd, F_GETFL, 0);
    if (flags < 0) {
        LOGE("SoftbusSession flags:%{public}d", flags);
        return;
    }
    flags = (int32_t)((uint32_t)flags & ~O_NONBLOCK);
    ret = fcntl(socketFd, F_SETFL, flags);
    if (ret < 0) {
        LOGE("error flags:%{public}d", ret);
        return;
    }
    socketFd_ = socketFd;

    array<char, KEY_SIZE_MAX> key;
    ret = ::GetSessionKey(sessionId_, key.data(), key.size());
    if (ret != SOFTBUS_OK) {
        LOGE("get session key failed, errno:%{public}d, sessionId:%{public}d", ret, sessionId_);
        key_ = {};
    } else {
        key_ = key;
    }
}

bool SoftbusSession::IsFromServer() const
{
    return IsServerSide_;
}

void SoftbusSession::SetFromServer(bool isServer)
{
    IsServerSide_ = isServer;
}

string SoftbusSession::GetCid() const
{
    return cid_;
}

int32_t SoftbusSession::GetHandle() const
{
    return socketFd_;
}

int SoftbusSession::GetSessionId() const
{
    return sessionId_;
}

array<char, KEY_SIZE_MAX> SoftbusSession::GetKey() const
{
    return key_;
}

void SoftbusSession::Release() const
{
    Shutdown(sessionId_);
    LOGI("session closed, sessionId:%{public}d", sessionId_);
}

void SoftbusSession::DisableSessionListener() const
{
    LOGI("DisableSessionListener Enter.");
    int32_t ret = ::DisableSessionListener(sessionId_);
    if (ret != SOFTBUS_OK) {
        LOGE("disableSessionlistener failed, errno:%{public}d, sessionId:%{public}d", ret, sessionId_);
        return;
    }
}
} // namespace DistributedFile
} // namespace Storage
} // namespace OHOS