tv/tuner/aidl/vts/functional/DescramblerTests.cpp

/*
 * Copyright 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 "DescramblerTests.h"

using namespace std;

AssertionResult DescramblerTests::createCasPlugin(int32_t caSystemId) {
    mCasListener = ::ndk::SharedRefBase::make<MediaCasListener>();

    if (mMediaCasServiceAidl != nullptr) {
        bool rst = false;
        ScopedAStatus status = mMediaCasServiceAidl->isSystemIdSupported(caSystemId, &rst);
        if (!status.isOk() || !rst) {
            ALOGW("[vts] Failed to check isSystemIdSupported for AIDL service.");
            return failure();
        }
        status = mMediaCasServiceAidl->createPlugin(caSystemId, mCasListener, &mCasAidl);
        if (!status.isOk()) {
            ALOGW("[vts] Failed to createPlugin for AIDL service.");
            return failure();
        }
    } else {
        auto status = mMediaCasServiceHidl->isSystemIdSupported(caSystemId);
        if (!status.isOk() || !status) {
            ALOGW("[vts] Failed to check isSystemIdSupported for HIDL service.");
            return failure();
        }
        auto pluginStatus = mMediaCasServiceHidl->createPluginExt(
                caSystemId, sp<ICasListenerHidl>(mCasListener.get()));
        if (!pluginStatus.isOk()) {
            ALOGW("[vts] Failed to createPluginExt for HIDL service.");
            return failure();
        }
        mCasHidl = ICasHidl::castFrom(pluginStatus);
        if (mCasHidl == nullptr) {
            ALOGW("[vts] Failed to get ICas for HIDL service.");
            return failure();
        }
    }

    return success();
}

AssertionResult DescramblerTests::openCasSession(vector<uint8_t>& sessionId,
                                                 vector<uint8_t>& pvtData) {
    if (mMediaCasServiceAidl != nullptr) {
        SessionIntentAidl intent = SessionIntentAidl::LIVE;
        ScramblingModeAidl mode = ScramblingModeAidl::RESERVED;
        std::vector<uint8_t> sessionId;
        ScopedAStatus status = mCasAidl->openSession(intent, mode, &sessionId);
        if (!status.isOk()) {
            ALOGW("[vts] Failed to open cas session for AIDL service.");
            mCasAidl->closeSession(sessionId);
            return failure();
        }

        if (pvtData.size() > 0) {
            ScopedAStatus status = mCasAidl->setSessionPrivateData(sessionId, pvtData);
            if (!status.isOk()) {
                ALOGW("[vts] Failed to set session private data for AIDL service.");
                mCasAidl->closeSession(sessionId);
                return failure();
            }
        }
    } else {
        Status sessionStatus;
        SessionIntentHidl intent = SessionIntentHidl::LIVE;
        ScramblingModeHidl mode = ScramblingModeHidl::RESERVED;
        auto returnVoid = mCasHidl->openSession_1_2(
                intent, mode, [&](Status status, const hidl_vec<uint8_t>& id) {
                    sessionStatus = status;
                    sessionId = id;
                });
        if (!returnVoid.isOk() || (sessionStatus != Status::OK)) {
            ALOGW("[vts] Failed to open cas session for HIDL service.");
            mCasHidl->closeSession(sessionId);
            return failure();
        }

        if (pvtData.size() > 0) {
            auto status = mCasHidl->setSessionPrivateData(sessionId, pvtData);
            if (status != android::hardware::cas::V1_0::Status::OK) {
                ALOGW("[vts] Failed to set session private data for HIDL service.");
                mCasHidl->closeSession(sessionId);
                return failure();
            }
        }
    }

    return success();
}

AssertionResult DescramblerTests::getKeyToken(int32_t caSystemId, string& provisonStr,
                                              vector<uint8_t>& pvtData, vector<uint8_t>& token) {
    if (createCasPlugin(caSystemId) != success()) {
        ALOGW("[vts] createCasPlugin failed.");
        return failure();
    }

    if (provisonStr.size() > 0) {
        if (mMediaCasServiceAidl != nullptr) {
            ScopedAStatus status = mCasAidl->provision(provisonStr);
            if (!status.isOk()) {
                ALOGW("[vts] provision failed for AIDL service.");
                return failure();
            }
        } else {
            auto returnStatus = mCasHidl->provision(hidl_string(provisonStr));
            if (returnStatus != android::hardware::cas::V1_0::Status::OK) {
                ALOGW("[vts] provision failed for HIDL service.");
                return failure();
            }
        }
    }

    return openCasSession(token, pvtData);
}

AssertionResult DescramblerTests::openDescrambler(int32_t demuxId) {
    ndk::ScopedAStatus status;
    status = mService->openDescrambler(&mDescrambler);
    if (!status.isOk()) {
        ALOGW("[vts] openDescrambler failed.");
        return failure();
    }

    status = mDescrambler->setDemuxSource(demuxId);
    if (!status.isOk()) {
        ALOGW("[vts] setDemuxSource failed.");
        return failure();
    }

    return success();
}

AssertionResult DescramblerTests::setKeyToken(vector<uint8_t>& token) {
    ndk::ScopedAStatus status;
    if (!mDescrambler) {
        ALOGW("[vts] Descrambler is not opened yet.");
        return failure();
    }

    status = mDescrambler->setKeyToken(token);
    if (!status.isOk()) {
        ALOGW("[vts] setKeyToken failed.");
        return failure();
    }

    return success();
}

AssertionResult DescramblerTests::addPid(DemuxPid pid,
                                         std::shared_ptr<IFilter> optionalSourceFilter) {
    ndk::ScopedAStatus status;
    if (!mDescrambler) {
        ALOGW("[vts] Descrambler is not opened yet.");
        return failure();
    }

    status = mDescrambler->addPid(pid, optionalSourceFilter);
    if (!status.isOk()) {
        ALOGW("[vts] addPid failed.");
        return failure();
    }

    return success();
}

AssertionResult DescramblerTests::removePid(DemuxPid pid,
                                            std::shared_ptr<IFilter> optionalSourceFilter) {
    ndk::ScopedAStatus status;
    if (!mDescrambler) {
        ALOGW("[vts] Descrambler is not opened yet.");
        return failure();
    }

    status = mDescrambler->removePid(pid, optionalSourceFilter);
    if (!status.isOk()) {
        ALOGW("[vts] removePid failed.");
        return failure();
    }

    return success();
}

AssertionResult DescramblerTests::closeDescrambler() {
    ndk::ScopedAStatus status;
    if (!mDescrambler) {
        ALOGW("[vts] Descrambler is not opened yet.");
        return failure();
    }

    status = mDescrambler->close();
    mDescrambler = nullptr;
    if (!status.isOk()) {
        ALOGW("[vts] close Descrambler failed.");
        return failure();
    }

    return success();
}

AssertionResult DescramblerTests::getDemuxPidFromFilterSettings(DemuxFilterType type,
                                                                const DemuxFilterSettings& settings,
                                                                DemuxPid& pid) {
    switch (type.mainType) {
        case DemuxFilterMainType::TS:
            if (type.subType.get<DemuxFilterSubType::Tag::tsFilterType>() ==
                        DemuxTsFilterType::AUDIO ||
                type.subType.get<DemuxFilterSubType::Tag::tsFilterType>() ==
                        DemuxTsFilterType::VIDEO) {
                pid.set<DemuxPid::Tag::tPid>(settings.get<DemuxFilterSettings::Tag::ts>().tpid);
            } else {
                ALOGW("[vts] Not a media ts filter!");
                return failure();
            }
            break;
        case DemuxFilterMainType::MMTP:
            if (type.subType.get<DemuxFilterSubType::Tag::mmtpFilterType>() ==
                        DemuxMmtpFilterType::AUDIO ||
                type.subType.get<DemuxFilterSubType::Tag::mmtpFilterType>() ==
                        DemuxMmtpFilterType::VIDEO) {
                pid.set<DemuxPid::Tag::mmtpPid>(
                        settings.get<DemuxFilterSettings::Tag::mmtp>().mmtpPid);
            } else {
                ALOGW("[vts] Not a media mmtp filter!");
                return failure();
            }
            break;
        default:
            ALOGW("[vts] Not a media filter!");
            return failure();
    }
    return success();
}