/*
 * Copyright (C) 2021 The Android Open Source Project
 *
 * 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 "MockVehicleCallback.h"

#include <android-base/thread_annotations.h>
#include <chrono>

namespace android {
namespace hardware {
namespace automotive {
namespace vehicle {

namespace {

using ::aidl::android::hardware::automotive::vehicle::GetValueResults;
using ::aidl::android::hardware::automotive::vehicle::SetValueResults;
using ::aidl::android::hardware::automotive::vehicle::VehiclePropErrors;
using ::aidl::android::hardware::automotive::vehicle::VehiclePropValues;
using ::android::base::ScopedLockAssertion;
using ::ndk::ScopedAStatus;
using ::ndk::ScopedFileDescriptor;

template <class T>
static ScopedAStatus storeResults(const T& results, std::list<T>* storedResults) {
    T resultsCopy{
            .payloads = results.payloads,
    };
    int fd = results.sharedMemoryFd.get();
    if (fd != -1) {
        resultsCopy.sharedMemoryFd = ScopedFileDescriptor(dup(fd));
    }
    storedResults->push_back(std::move(resultsCopy));
    return ScopedAStatus::ok();
}

}  // namespace

ScopedAStatus MockVehicleCallback::onGetValues(const GetValueResults& results) {
    ScopedAStatus result;
    {
        std::scoped_lock<std::mutex> lockGuard(mLock);
        result = storeResults(results, &mGetValueResults);
    }
    mCond.notify_all();
    return result;
}

ScopedAStatus MockVehicleCallback::onSetValues(const SetValueResults& results) {
    ScopedAStatus result;
    {
        std::scoped_lock<std::mutex> lockGuard(mLock);
        result = storeResults(results, &mSetValueResults);
    }
    mCond.notify_all();
    return result;
}

ScopedAStatus MockVehicleCallback::onPropertyEvent(const VehiclePropValues& results,
                                                   int32_t sharedMemoryFileCount) {
    ScopedAStatus result;
    {
        std::scoped_lock<std::mutex> lockGuard(mLock);
        mSharedMemoryFileCount = sharedMemoryFileCount;
        result = storeResults(results, &mOnPropertyEventResults);
    }
    mCond.notify_all();
    return result;
}

ScopedAStatus MockVehicleCallback::onPropertySetError(const VehiclePropErrors& results) {
    ScopedAStatus result;
    {
        std::scoped_lock<std::mutex> lockGuard(mLock);
        result = storeResults(results, &mOnPropertySetErrorResults);
    }
    mCond.notify_all();
    return result;
}

std::optional<GetValueResults> MockVehicleCallback::nextGetValueResults() {
    std::scoped_lock<std::mutex> lockGuard(mLock);
    return pop(mGetValueResults);
}

std::optional<SetValueResults> MockVehicleCallback::nextSetValueResults() {
    std::scoped_lock<std::mutex> lockGuard(mLock);
    return pop(mSetValueResults);
}

std::optional<VehiclePropValues> MockVehicleCallback::nextOnPropertyEventResults() {
    std::scoped_lock<std::mutex> lockGuard(mLock);
    return pop(mOnPropertyEventResults);
}

size_t MockVehicleCallback::countOnPropertyEventResults() {
    std::scoped_lock<std::mutex> lockGuard(mLock);
    return mOnPropertyEventResults.size();
}

std::optional<VehiclePropErrors> MockVehicleCallback::nextOnPropertySetErrorResults() {
    std::scoped_lock<std::mutex> lockGuard(mLock);
    return pop(mOnPropertySetErrorResults);
}

size_t MockVehicleCallback::countOnPropertySetErrorResults() {
    std::scoped_lock<std::mutex> lockGuard(mLock);
    return mOnPropertySetErrorResults.size();
}

bool MockVehicleCallback::waitForSetValueResults(size_t size, size_t timeoutInNano) {
    std::unique_lock lk(mLock);
    return mCond.wait_for(lk, std::chrono::nanoseconds(timeoutInNano), [this, size] {
        ScopedLockAssertion lockAssertion(mLock);
        return mSetValueResults.size() >= size;
    });
}

bool MockVehicleCallback::waitForGetValueResults(size_t size, size_t timeoutInNano) {
    std::unique_lock lk(mLock);
    return mCond.wait_for(lk, std::chrono::nanoseconds(timeoutInNano), [this, size] {
        ScopedLockAssertion lockAssertion(mLock);
        return mGetValueResults.size() >= size;
    });
}

bool MockVehicleCallback::waitForOnPropertyEventResults(size_t size, size_t timeoutInNano) {
    std::unique_lock lk(mLock);
    return mCond.wait_for(lk, std::chrono::nanoseconds(timeoutInNano), [this, size] {
        ScopedLockAssertion lockAssertion(mLock);
        return mOnPropertyEventResults.size() >= size;
    });
}

}  // namespace vehicle
}  // namespace automotive
}  // namespace hardware
}  // namespace android