FunctionalTests.cpp

/*
* If not stated otherwise in this file or this component's license file the
* following copyright and licenses apply:
*
* Copyright 2023 RDK Management
*
* 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 <gmock/gmock.h>

#include "priv_aamp.h"

#include "AampConfig.h"
#include "AampStreamSinkManager.h"
#include "aampgstplayer.h"
#include "MockAampGstPlayer.h"
#include "MockStreamSink.h"
#include "MockStreamAbstractionAAMP.h"
#include "MockPrivateInstanceAAMP.h"

using ::testing::_;
using ::testing::NiceMock;
using ::testing::Return;

AampConfig *gpGlobalConfig=NULL;

class AampStreamSinkManagerTests : public ::testing::Test
{
protected:
    PrivateInstanceAAMP *mPrivateInstanceAAMP1{};
    PrivateInstanceAAMP *mPrivateInstanceAAMP2{};
    id3_callback_t mId3HandlerCallback1;
    id3_callback_t mId3HandlerCallback2;
    AampConfig mConfig1{};
	AampConfig mConfig2{};

    void SetUp() override
    {
        if(gpGlobalConfig == nullptr)
        {
            gpGlobalConfig =  new AampConfig();
        }
        mConfig1 = *gpGlobalConfig;
        mPrivateInstanceAAMP1 = new PrivateInstanceAAMP(&mConfig1);
        mPrivateInstanceAAMP1->mPlayerId = 1;

        mConfig2 = *gpGlobalConfig;
        mPrivateInstanceAAMP2 = new PrivateInstanceAAMP(&mConfig2);
        mPrivateInstanceAAMP2->mPlayerId = 2;

        g_mockPrivateInstanceAAMP = new NiceMock<MockPrivateInstanceAAMP>();

        g_mockStreamAbstractionAAMP = new NiceMock<MockStreamAbstractionAAMP>(mPrivateInstanceAAMP2);

        g_mockAampGstPlayer = new MockAAMPGstPlayer( mPrivateInstanceAAMP1);

        mPrivateInstanceAAMP2->mpStreamAbstractionAAMP = g_mockStreamAbstractionAAMP;

        const auto id3_callback = std::bind(&PrivateInstanceAAMP::ID3MetadataHandler, mPrivateInstanceAAMP1, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3, std::placeholders::_4, std::placeholders::_5);
        mId3HandlerCallback1 = id3_callback;
        mId3HandlerCallback2 = id3_callback;
    }

    void TearDown() override
    {
        delete g_mockPrivateInstanceAAMP;
        g_mockPrivateInstanceAAMP = nullptr;

        delete mPrivateInstanceAAMP1;
        mPrivateInstanceAAMP1 = nullptr;

        delete gpGlobalConfig;
        gpGlobalConfig = nullptr;

        mPrivateInstanceAAMP2->mpStreamAbstractionAAMP = nullptr;
        delete g_mockStreamAbstractionAAMP;
        g_mockStreamAbstractionAAMP = nullptr;

        delete mPrivateInstanceAAMP2;
        mPrivateInstanceAAMP2 = nullptr;

        delete g_mockAampGstPlayer;
        g_mockAampGstPlayer = nullptr;
        AampStreamSinkManager::GetInstance().Clear();
    }

public:

};
/*
    @brief: - Checks that the single pipeline mode of operation is active
    Test Procedure
    Initialize AampStreamSinkManager into single pipeline mode.
    Create 2 Sinks ( i.e. call CreateSinkStream twice).
    The first player is active, get the stream sink for it.
    Make Second Player active, get the stream sink for it.
    Compare it with the stream sink for first player, if found to be same than it is single pipeline mode.
    This test scenario also verfies that the Activate player is working.
*/
TEST_F(AampStreamSinkManagerTests, CheckSetSinglePipelineMode)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);

    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP2, mId3HandlerCallback2);
    AampStreamSinkManager::GetInstance().ActivatePlayer(mPrivateInstanceAAMP2);
    StreamSink *sink2 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP2);

    EXPECT_EQ(sink1, sink2);
}

/* Test Procedure: -
    @brief If there are no active players then mGstPlayer should be returned.
*/
TEST_F(AampStreamSinkManagerTests, GetStoppingStreamSink_SinglePipelineMode_NoActivePlayers)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    AampStreamSinkManager::GetInstance().DeactivatePlayer(mPrivateInstanceAAMP1, true);
    StreamSink *sink2 = AampStreamSinkManager::GetInstance().GetStoppingStreamSink(mPrivateInstanceAAMP1);

    EXPECT_EQ(sink1, sink2);
}

/* Test Procedure: -
    @brief  When there is an active player GetStoppingStreamSink functions the same as GetStreamSink.
*/
TEST_F(AampStreamSinkManagerTests, GetStoppingStreamSink_SinglePipelineMode_ActivePlayers)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    StreamSink *sink2 = AampStreamSinkManager::GetInstance().GetStoppingStreamSink(mPrivateInstanceAAMP1);

    EXPECT_EQ(sink1, sink2);
}

/* Test Procedure: -
    @brief When the active map is empty, but there is an available player, use that.
*/
TEST_F(AampStreamSinkManagerTests, UpdateTuningPlayer_SinglePipelineMode_UseInactivePlayer)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    AampStreamSinkManager::GetInstance().DeactivatePlayer(mPrivateInstanceAAMP1, true);
    EXPECT_CALL(*g_mockAampGstPlayer, ChangeAamp(mPrivateInstanceAAMP1, _)).Times(1);
    AampStreamSinkManager::GetInstance().UpdateTuningPlayer(mPrivateInstanceAAMP1);
}

/* Test Procedure: -
    @brief Test UpdateTuningPlayer where we wouldn't expect the player to be changed.
*/
TEST_F(AampStreamSinkManagerTests, UpdateTuningPlayer_SinglePipelineMode_NoChange)
{
	/* Undefined pipeline */
    EXPECT_CALL(*g_mockAampGstPlayer, ChangeAamp(mPrivateInstanceAAMP1, _)).Times(0);
    AampStreamSinkManager::GetInstance().UpdateTuningPlayer(mPrivateInstanceAAMP1);

    /* Single pipeline not yet created */
    AampStreamSinkManager::GetInstance().UpdateTuningPlayer(mPrivateInstanceAAMP1);

    /* Active player exists */
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    AampStreamSinkManager::GetInstance().UpdateTuningPlayer(mPrivateInstanceAAMP1);

	/* No inactive stream sink for player
	 * Another player must exist so that the single pipeline isn't destroyed when the active player is deleted,
	 * so create a second player, which is currently inactive. */
	AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP2, mId3HandlerCallback2);
	AampStreamSinkManager::GetInstance().DeleteStreamSink(mPrivateInstanceAAMP1);
	AampStreamSinkManager::GetInstance().UpdateTuningPlayer(mPrivateInstanceAAMP1);
}

/* Test Procedure: -
    @brief Test UpdateTuningPlayer, we wouldn't expect the player to change in multi pipeline mode.
*/
TEST_F(AampStreamSinkManagerTests, UpdateTuningPlayer_MultiPipelineMode_NoChange)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
	AampStreamSinkManager::GetInstance().ActivatePlayer(mPrivateInstanceAAMP1);
    EXPECT_CALL(*g_mockAampGstPlayer, ChangeAamp(mPrivateInstanceAAMP1, _)).Times(0);
    AampStreamSinkManager::GetInstance().UpdateTuningPlayer(mPrivateInstanceAAMP1);
}

/*
    @brief: - Tests the scenario when single PrivateInstanceAAMP is deleted, the sink is deleted.
    Test Procedure: -
    In Single pipeline mode, create a stream sink.
    Delete the PrivateInstanceAAMP, this should delete the player since was only one PrivateInstanceAAMP.
*/
TEST_F(AampStreamSinkManagerTests, DeleteStreamSinkTest1)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    AampStreamSinkManager::GetInstance().DeleteStreamSink(mPrivateInstanceAAMP1);

    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(sink1, nullptr);
}

/*
    @brief: - Tests the scenario when two PrivateInstanceAAMP exists and one of them is active
              then deleting the inactive PrivateInstanceAAMP has no effect on active instance
    Test Procedure: -
    In Single pipeline mode.
    Create two stream sink - first player is active.
    Delete the inactiveplayer.
    Calling GetStreamSink return AAMPGstPlayer type of Object.
*/
TEST_F(AampStreamSinkManagerTests, DeleteStreamSinkTest2)
{

    AAMPGstPlayer gstPlayerobj { mPrivateInstanceAAMP1, mId3HandlerCallback1};

    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP2, mId3HandlerCallback2);
    AampStreamSinkManager::GetInstance().DeleteStreamSink(mPrivateInstanceAAMP2);

    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(typeid(*sink1), typeid(gstPlayerobj));
}

/*
    @brief: - When an active mPrivateInstanceAAMP is deactivated, it gets assigned to AampStreamSinkInactive
    Test Procedure: -
    Enable single pipeline mode and Call Create stream sink
    Check the typeid of returned from GetStreamSink Matches AAMPGstPlayer
    Now deactivate player
    Check the typeid of returned from GetStreamSink Matches AampStreamSinkInactive
*/
TEST_F(AampStreamSinkManagerTests, Deactivateplayer)
{
    AampStreamSinkInactive inactiveSink {mId3HandlerCallback1};
    AAMPGstPlayer gstPlayerobj { mPrivateInstanceAAMP1, mId3HandlerCallback1};

    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(typeid(gstPlayerobj), typeid(*sink1));

    AampStreamSinkManager::GetInstance().DeactivatePlayer(mPrivateInstanceAAMP1, false);
    StreamSink *sink2 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(typeid(*sink2), typeid(inactiveSink));
}

/*  @brief : - Establishes that the multipipeline mode of operation is active.
    Test Procedure: -
    Create 2 Players ( i.e. call CreateSinkStream twice)
    The first player is active, get the stream sink for it and store it
    Make Second Player active, get the stream sink for it.
    Compare it with the stream sink for first player, they should be different
*/
TEST_F(AampStreamSinkManagerTests, CheckMultiPipelineMode)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP2, mId3HandlerCallback2);
    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);

    AampStreamSinkManager::GetInstance().ActivatePlayer(mPrivateInstanceAAMP2);
    StreamSink *sink2 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP2);

    EXPECT_NE(sink1, sink2);
}

/* Test Procedure: -
    @brief In MultiPipeline mode GetStoppingStreamSink returns the same as GetStreamSink
*/
TEST_F(AampStreamSinkManagerTests, GetStoppingStreamSink_MultiPipelineMode)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    StreamSink *sink2 = AampStreamSinkManager::GetInstance().GetStoppingStreamSink(mPrivateInstanceAAMP1);

    EXPECT_EQ(sink1, sink2);
}

/* Test Procedure: -
    @brief Without Creating any sink; call GetStreamSink; nullptr should be returned
*/
TEST_F(AampStreamSinkManagerTests, MultiPipelineMode_CheckGetStreamSink1)
{
    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(sink1, nullptr);
}

/*  Test Procedure
    @brief Verifies deletion of a sink
    Create StreamSink, verify that sink if of AAMPGstPlayer.
    Delete it,call to GetStreamSink Should return null.
*/
TEST_F(AampStreamSinkManagerTests, MultiPipelineMode_CheckGetStreamSink2)
{
    AAMPGstPlayer gstPlayerobj { mPrivateInstanceAAMP1, mId3HandlerCallback1};
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);

    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(typeid(gstPlayerobj), typeid(*sink1));

    AampStreamSinkManager::GetInstance().DeleteStreamSink(mPrivateInstanceAAMP1);
    sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(sink1, nullptr);
}

/*
    @brief: - verifies that ChangeAamp receives expected parameters
    Test Procedure
    Initialize AampStreamSinkManager into single pipeline mode.
    Create 1 sink, it will be the active sink. Verify test requirments
*/
TEST_F(AampStreamSinkManagerTests, ChangeAampTests)
{
    EXPECT_CALL(*g_mockAampGstPlayer, ChangeAamp(mPrivateInstanceAAMP1, _)).Times(0);
    EXPECT_CALL(*g_mockAampGstPlayer, ChangeAamp(mPrivateInstanceAAMP2, _)).Times(0);

    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);

    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP2, mId3HandlerCallback2);

    EXPECT_CALL(*g_mockAampGstPlayer, ChangeAamp(mPrivateInstanceAAMP1, _)).Times(0);
    AampStreamSinkManager::GetInstance().ActivatePlayer(mPrivateInstanceAAMP1);

    mPrivateInstanceAAMP2->mMediaFormat = eMEDIAFORMAT_DASH;
    /* ActivatePlayer() calls GetFirstPTS() of StreamAbstractionAAMP to get the
    flush position of the second AAMP private instance and
    AAMPGstPlayer::Flush() gets called with this position in seconds. */
    double flushPosition = 5.0;
    EXPECT_CALL(*g_mockStreamAbstractionAAMP, GetFirstPTS()).WillOnce(Return(flushPosition));

    EXPECT_CALL(*g_mockAampGstPlayer, ChangeAamp(mPrivateInstanceAAMP2, _)).Times(1);
    EXPECT_CALL(*g_mockAampGstPlayer, Flush(flushPosition, _, true)).Times(1);
    AampStreamSinkManager::GetInstance().ActivatePlayer(mPrivateInstanceAAMP2);
}

/*
    @brief: - Tests SetTuned sets the tuned flag for an inactive player
    Test Procedure: -
    Create a stream sink and deactivate it (making it inactive).
    Call SetTuned to mark it as tuned.
    Verify the tuned flag can be read back via GetStreamSink and checking IsTuned.
*/
TEST_F(AampStreamSinkManagerTests, SetTuned_MarksInactivePlayerAsTuned)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    AampStreamSinkManager::GetInstance().DeactivatePlayer(mPrivateInstanceAAMP1, false);

    // Set the tuned flag
    AampStreamSinkManager::GetInstance().SetTuned(mPrivateInstanceAAMP1);

    // Get the inactive sink and verify it's tuned
    StreamSink *sink = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    ASSERT_NE(sink, nullptr);

    AampStreamSinkInactive *inactiveSink = dynamic_cast<AampStreamSinkInactive*>(sink);
    ASSERT_NE(inactiveSink, nullptr);
    EXPECT_TRUE(inactiveSink->IsTuned());
}

/*
    @brief: - Tests that IsTuned returns false by default for a newly created inactive sink
    Test Procedure: -
    Create a stream sink and deactivate it.
    Without calling SetTuned, verify IsTuned returns false.
*/
TEST_F(AampStreamSinkManagerTests, IsTuned_DefaultsToFalse)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    AampStreamSinkManager::GetInstance().DeactivatePlayer(mPrivateInstanceAAMP1, false);

    // Get the inactive sink and verify it's not tuned by default
    StreamSink *sink = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    ASSERT_NE(sink, nullptr);

    AampStreamSinkInactive *inactiveSink = dynamic_cast<AampStreamSinkInactive*>(sink);
    ASSERT_NE(inactiveSink, nullptr);
    EXPECT_FALSE(inactiveSink->IsTuned());
}

/*
    @brief: - Tests GetStoppingStreamSink returns single pipeline sink when no tuned inactive players exist
    Test Procedure: -
    In single pipeline mode with no active players and no tuned inactive players,
    GetStoppingStreamSink should return the single pipeline sink (mGstPlayer).
*/
TEST_F(AampStreamSinkManagerTests, GetStoppingStreamSink_NoTunedInactivePlayers_ReturnsSinglePipeline)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    StreamSink *singlePipelineSink = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);

    // Deactivate player but don't tune it
    AampStreamSinkManager::GetInstance().DeactivatePlayer(mPrivateInstanceAAMP1, false);

    // GetStoppingStreamSink should return the single pipeline sink
    StreamSink *stoppingSink = AampStreamSinkManager::GetInstance().GetStoppingStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(singlePipelineSink, stoppingSink);
}

/*
    @brief: - Tests GetStoppingStreamSink returns inactive sink when tuned inactive players exist
    Test Procedure: -
    In single pipeline mode with no active players but a tuned inactive player exists,
    GetStoppingStreamSink should NOT return the single pipeline sink but the specific player's sink.
*/
TEST_F(AampStreamSinkManagerTests, GetStoppingStreamSink_WithTunedInactivePlayers_ReturnsSpecificSink)
{
    // Create two players
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP2, mId3HandlerCallback2);

    StreamSink *singlePipelineSink = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);

    // Deactivate both players
    AampStreamSinkManager::GetInstance().DeactivatePlayer(mPrivateInstanceAAMP1, false);
    AampStreamSinkManager::GetInstance().DeactivatePlayer(mPrivateInstanceAAMP2, false);

    // Mark player2 as tuned
    AampStreamSinkManager::GetInstance().SetTuned(mPrivateInstanceAAMP2);

    // GetStoppingStreamSink for player1 should NOT return the single pipeline sink
    // because player2 is tuned
    StreamSink *stoppingSink = AampStreamSinkManager::GetInstance().GetStoppingStreamSink(mPrivateInstanceAAMP1);
    StreamSink *player1Sink = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);

    EXPECT_EQ(player1Sink, stoppingSink);
    EXPECT_NE(singlePipelineSink, stoppingSink);
}

/*
    @brief: - Tests GetStoppingStreamSink ignores the calling aamp when checking for tuned players
    Test Procedure: -
    In single pipeline mode with no active players, if only the calling player is tuned,
    GetStoppingStreamSink should still return the single pipeline sink.
*/
TEST_F(AampStreamSinkManagerTests, GetStoppingStreamSink_IgnoresCallingPlayerTunedStatus)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    StreamSink *singlePipelineSink = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);

    // Deactivate and tune player1
    AampStreamSinkManager::GetInstance().DeactivatePlayer(mPrivateInstanceAAMP1, false);
    AampStreamSinkManager::GetInstance().SetTuned(mPrivateInstanceAAMP1);

    // GetStoppingStreamSink for player1 should return the single pipeline sink
    // because the calling player (player1) itself should be ignored
    StreamSink *stoppingSink = AampStreamSinkManager::GetInstance().GetStoppingStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(singlePipelineSink, stoppingSink);
}

/*
    @brief: - verifies that progressive ActivatePlayer() uses stream position
    Test Procedure
    Initialize AampStreamSinkManager into single pipeline mode.
    Create 1 sink, it will be the active sink.
    For second player with progressive format, verify GetStreamPosition() is used
*/
TEST_F(AampStreamSinkManagerTests, ChangeAampTests_ProgressiveUsesStreamPosition)
{
    EXPECT_CALL(*g_mockAampGstPlayer, ChangeAamp(mPrivateInstanceAAMP1, _))
        .Times(0);
    EXPECT_CALL(*g_mockAampGstPlayer, ChangeAamp(mPrivateInstanceAAMP2, _))
        .Times(0);

    AampStreamSinkManager::GetInstance().CreateStreamSink(
        mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(
        mPrivateInstanceAAMP1);

    AampStreamSinkManager::GetInstance().CreateStreamSink(
        mPrivateInstanceAAMP2, mId3HandlerCallback2);

    EXPECT_CALL(*g_mockAampGstPlayer, ChangeAamp(mPrivateInstanceAAMP1, _))
        .Times(0);
    AampStreamSinkManager::GetInstance().ActivatePlayer(mPrivateInstanceAAMP1);

    mPrivateInstanceAAMP2->mMediaFormat = eMEDIAFORMAT_PROGRESSIVE;
    /* ActivatePlayer() calls GetStreamPosition() of StreamAbstractionAAMP to get the
    flush position of the second AAMP private instance and
    AAMPGstPlayer::Flush() gets called with this position in seconds. */
    double flushPosition = 7.0;
    EXPECT_CALL(*g_mockStreamAbstractionAAMP, GetStreamPosition())
        .WillOnce(Return(flushPosition));

    EXPECT_CALL(*g_mockAampGstPlayer, ChangeAamp(mPrivateInstanceAAMP2, _))
        .Times(1);
    EXPECT_CALL(*g_mockAampGstPlayer, Flush(flushPosition, _, true)).Times(1);
    AampStreamSinkManager::GetInstance().ActivatePlayer(mPrivateInstanceAAMP2);
}

/*  @brief: - Tests the API SetEncryptedAamp, SetEncryptedHeaders, GetEncryptedHeaders and ReinjectEncryptedHeaders.
    Test procedure
    Set the singlepipeline mode and create streamsink.
    Set the encrypted headers to a test data via SetEncryptedHeaders.
    Read back the encrypted data via GetEncryptedHeaders.
    The read test data should match the set test data.
    Further read using GetEncryptedHeaders should mismatch set data
    Call to ReinjectEncryptedHeaders, followed by GetEncryptedHeaders, returns headers one more time.
*/
TEST_F(AampStreamSinkManagerTests, CheckEncyptedHeaders)
{
    std::map<int, std::string> set_headers;
    std::map<int, std::string> get_headers;

    set_headers.insert({1, "Test String"});

    EXPECT_CALL(*g_mockAampGstPlayer, ChangeAamp(mPrivateInstanceAAMP1, _)).Times(0);
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);

    EXPECT_CALL(*g_mockAampGstPlayer, SetEncryptedAamp(mPrivateInstanceAAMP1));
    AampStreamSinkManager::GetInstance().SetEncryptedHeaders(mPrivateInstanceAAMP1, set_headers);
    AampStreamSinkManager::GetInstance().GetEncryptedHeaders(get_headers);
    EXPECT_EQ(set_headers, get_headers);

    //Once the GetEncryptedHeaders is called, subsequent call should return nothing
    AampStreamSinkManager::GetInstance().GetEncryptedHeaders(get_headers);
    EXPECT_NE(set_headers, get_headers);

    AampStreamSinkManager::GetInstance().ReinjectEncryptedHeaders();
    AampStreamSinkManager::GetInstance().GetEncryptedHeaders(get_headers);
    EXPECT_EQ(set_headers, get_headers);
}

/*  @brief: - Tests the API GetActiveStreamSink
    Test procedure
    Set the singlepipeline mode and create streamsink X 2. First instance is active
    Verify that type id of sink matches AAMPGstPlayer when GetActiveStreamSink called on active instance
    call to GetActiveStreamSink with instance of inactive PrivateInstance should return the sink of active player.
*/
TEST_F(AampStreamSinkManagerTests, CheckGetActiveStreamSink)
{
    AAMPGstPlayer gstPlayerobj {mPrivateInstanceAAMP1, mId3HandlerCallback1};

    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);

    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP2, mId3HandlerCallback2);

    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetActiveStreamSink(mPrivateInstanceAAMP1);
    ASSERT_NE(nullptr, sink1);
    EXPECT_EQ(typeid(gstPlayerobj), typeid(*sink1));

    StreamSink *sink2 = AampStreamSinkManager::GetInstance().GetActiveStreamSink(mPrivateInstanceAAMP2);
    ASSERT_NE(nullptr, sink2);
    EXPECT_EQ(sink1, sink2);
}

/*  @brief : - Establishes that the multipipeline mode of operation is active when client StreamSink set.
    Test Procedure: -
    Check that no StreamSink associated with Players
    Set a unique client StreamSink to 2 Players ( i.e. call SetStreamSink twice)
    Get each StreamSink and check they return the corresponding client StreamSink
    Get active StreamSink and check they return the corresponding client StreamSink
    Delete each StreamSink associated with each Player and check getting StreamSink returns nullptr
*/
TEST_F(AampStreamSinkManagerTests, CheckSetStreamSink)
{
    MockStreamSink streamSinkMock1, streamSinkMock2;

    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(sink1, nullptr);

    StreamSink *sink2 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP2);
    EXPECT_EQ(sink2, nullptr);

    AampStreamSinkManager::GetInstance().SetStreamSink(mPrivateInstanceAAMP1, &streamSinkMock1);
    AampStreamSinkManager::GetInstance().SetStreamSink(mPrivateInstanceAAMP2, &streamSinkMock2);

    sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(sink1, &streamSinkMock1);

    sink2 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP2);
    EXPECT_EQ(sink2, &streamSinkMock2);

    sink1 = AampStreamSinkManager::GetInstance().GetActiveStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(sink1, &streamSinkMock1);

    sink2 = AampStreamSinkManager::GetInstance().GetActiveStreamSink(mPrivateInstanceAAMP2);
    EXPECT_EQ(sink2, &streamSinkMock2);

    AampStreamSinkManager::GetInstance().DeleteStreamSink(mPrivateInstanceAAMP1);
    sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(sink1, nullptr);

    AampStreamSinkManager::GetInstance().DeleteStreamSink(mPrivateInstanceAAMP2);
    sink2 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP2);
    EXPECT_EQ(sink2, nullptr);
}

/*  @brief : - Extra test to check consistent behavior with obtaining StreamSink
*/
TEST_F(AampStreamSinkManagerTests, CheckMultipipeline1)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP2, mId3HandlerCallback2);

    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    StreamSink *sink2 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP2);
    StreamSink *sink;

    sink = AampStreamSinkManager::GetInstance().GetActiveStreamSink(mPrivateInstanceAAMP1);
    ASSERT_NE(nullptr, sink);
    EXPECT_EQ(sink, sink1);

    sink = AampStreamSinkManager::GetInstance().GetActiveStreamSink(mPrivateInstanceAAMP2);
    ASSERT_NE(nullptr, sink2);
    EXPECT_EQ(sink, sink2);

    sink = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    ASSERT_NE(nullptr, sink);
    EXPECT_EQ(sink, sink1);

    sink = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP2);
    ASSERT_NE(nullptr, sink2);
    EXPECT_EQ(sink, sink2);
}

/*  @brief : - Extra test to check consistent behavior with obtaining StreamSink after deletion
*/
TEST_F(AampStreamSinkManagerTests,  CheckMultipipeline2)
{
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);

    StreamSink *sink1 = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    StreamSink *sink;

    AampStreamSinkManager::GetInstance().DeleteStreamSink(mPrivateInstanceAAMP1);

    sink = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    EXPECT_EQ(sink, nullptr);

    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);

    sink = AampStreamSinkManager::GetInstance().GetStreamSink(mPrivateInstanceAAMP1);
    ASSERT_NE(nullptr, sink);
}

/*
    @brief: - Microtests for AddMediaHeader, RemoveMediaHeader, and GetMediaHeader
*/
TEST_F(AampStreamSinkManagerTests, MediaHeader_AddGetRemove)
{
    auto& manager = AampStreamSinkManager::GetInstance();

    // Create a MediaHeader and add it
    auto header = std::make_shared<AampStreamSinkManager::MediaHeader>("http://test.url/init.mp4", "application/mp4");
    int trackId = eMEDIATYPE_SUBTITLE;

    manager.AddMediaHeader(trackId, header);

    // GetMediaHeader should return the same header
    auto retrieved = manager.GetMediaHeader(trackId);
    ASSERT_NE(retrieved, nullptr);
    EXPECT_EQ(retrieved->url, "http://test.url/init.mp4");
    EXPECT_EQ(retrieved->mimeType, "application/mp4");
    EXPECT_FALSE(retrieved->injected);

    // RemoveMediaHeader should remove the header
    manager.RemoveMediaHeader(trackId);
    auto removed = manager.GetMediaHeader(trackId);
    EXPECT_EQ(removed, nullptr);
}

/*  @brief : - Specific error case leading to invalid encrypted headers
*/
TEST_F(AampStreamSinkManagerTests, CheckEncryptedHeaders_PlayerNotDeactivated)
{
    std::map<int, std::string> set_headers1;
    std::map<int, std::string> set_headers2;
    set_headers1.insert({1, "Test String1"});
    set_headers2.insert({1, "Test String2"});
	
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP2, mId3HandlerCallback2);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP2);
    
    AampStreamSinkManager::GetInstance().ActivatePlayer(mPrivateInstanceAAMP1);

    // Only expect one call to SetEncryptedAamp for the same player
    EXPECT_CALL(*g_mockAampGstPlayer, SetEncryptedAamp(mPrivateInstanceAAMP1)).Times(1);
    AampStreamSinkManager::GetInstance().SetEncryptedHeaders(mPrivateInstanceAAMP1, set_headers1);
    AampStreamSinkManager::GetInstance().SetEncryptedHeaders(mPrivateInstanceAAMP1, set_headers1);

    //-- not called here as expected: AampStreamSinkManager::GetInstance().DeactivatePlayer(mPrivateInstanceAAMP1, true);

    AampStreamSinkManager::GetInstance().ActivatePlayer(mPrivateInstanceAAMP2);

    // called after next player activated
    AampStreamSinkManager::GetInstance().DeactivatePlayer(mPrivateInstanceAAMP1, true);

    // Check that the encrypted info is still updated for the new player
    EXPECT_CALL(*g_mockAampGstPlayer, SetEncryptedAamp(mPrivateInstanceAAMP2));
    AampStreamSinkManager::GetInstance().SetEncryptedHeaders(mPrivateInstanceAAMP2, set_headers2);

    AampStreamSinkManager::GetInstance().DeactivatePlayer(mPrivateInstanceAAMP2, true);
}

/*  @brief: - Regression test for VPAAMP-294.
    Tests that SetEncryptedHeaders succeeds on retune in single pipeline mode.
    After DeactivatePlayer(stop=true) the player is removed from mActiveGstPlayersMap
    but mGstPlayer is retained. A subsequent CreateStreamSink takes the reuse branch
    and does NOT re-insert the player into mActiveGstPlayersMap. The old code had a
    guard that silently dropped SetEncryptedHeaders in this state. The fix removes
    that guard so DRM headers are correctly forwarded to the GstPlayer on retune.
*/
TEST_F(AampStreamSinkManagerTests, CheckEncryptedHeaders_RetuneInSinglePipelineMode)
{
    std::map<int, std::string> set_headers;
    set_headers.insert({1, "Test String"});

    // --- First tune ---
    // CreateStreamSink in UNDEFINED mode creates GstPlayer and inserts player into both maps.
    // SetSinglePipelineMode retains that GstPlayer as mGstPlayer.
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);
    AampStreamSinkManager::GetInstance().SetSinglePipelineMode(mPrivateInstanceAAMP1);

    EXPECT_CALL(*g_mockAampGstPlayer, SetEncryptedAamp(mPrivateInstanceAAMP1)).Times(1);
    AampStreamSinkManager::GetInstance().SetEncryptedHeaders(mPrivateInstanceAAMP1, set_headers);

    // --- Stop ---
    // DeactivatePlayer(stop=true) removes player from mActiveGstPlayersMap and clears
    // mEncryptedHeaders. mGstPlayer is retained (player stays in mInactiveGstPlayersMap).
    AampStreamSinkManager::GetInstance().DeactivatePlayer(mPrivateInstanceAAMP1, true);

    // --- Retune (VPAAMP-294 scenario) ---
    // CreateStreamSink in SINGLE mode with mGstPlayer != null takes the reuse branch
    // and does NOT re-insert player into mActiveGstPlayersMap. SetEncryptedHeaders
    // must still succeed (calling SetEncryptedAamp) because mGstPlayer is non-null
    // and mEncryptedHeaders was cleared by DeactivatePlayer. The original VPAAMP-214
    // guard (mActiveGstPlayersMap.count(aamp) == 0 => early return) would have
    // silently dropped the headers here; the VPAAMP-294 fix removes that guard.
    AampStreamSinkManager::GetInstance().CreateStreamSink(mPrivateInstanceAAMP1, mId3HandlerCallback1);

    EXPECT_CALL(*g_mockAampGstPlayer, SetEncryptedAamp(mPrivateInstanceAAMP1)).Times(1);
    AampStreamSinkManager::GetInstance().SetEncryptedHeaders(mPrivateInstanceAAMP1, set_headers);
}