/*
 * Copyright (C) 2014-2025 Amlogic, Inc. All rights reserved.
 *
 * All information contained herein is Amlogic confidential.
 *
 * This software is provided to you pursuant to Software License Agreement
 * (SLA) with Amlogic Inc ("Amlogic"). This software may be used
 * only in accordance with the terms of this agreement.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification is strictly prohibited without prior written permission from
 * Amlogic.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

#pragma once

#include <utils/Thread.h>

#include <memory>
#include <mutex>
#include <string>
#include <thread>

#include "DataSource.h"
#include "Segment.h"
#include "StreamUtils.h"
#include "SubtitleTypes.h"

#define DEMUX_SOURCE_ID 0
#define SCTE27_TID      0xC6

class DemuxSource : public DataSource {
public:
    DemuxSource();
    virtual ~DemuxSource();

    std::shared_ptr<BufferSegment> mSegment;
    int mSubType = -1;

    // DataSource interfaces
    SubtitleIOType type() override;
    bool start() override;
    bool stop() override;
    size_t availableDataSize() override;
    size_t read(void *buffer, size_t size) override;
    size_t lseek(int /*offSet*/, int /*whence*/) override { return 0; }
    void updateParameter(int type, void *data) override;
    void setPipId(int mode, int id) override;
    bool isFileAvailable() override;
    void dump(int fd, const char *prefix) override;
    void updateNewestAVPts(int64_t subtitlePts, int64_t syncedPts) override;

    // DataListener interface
    int onData(const char * /*buffer*/, int /*len*/) override { return -1; }

    static inline DemuxSource *getCurrentInstance();
    void onPesCallback();

private:
    int mRdFd = -1;
    std::shared_ptr<std::thread> mRenderTimeThread;
    // For poping and parsing
    std::shared_ptr<BufferItem> mCurrentItem;

    SubtitleIOState mState = E_SOURCE_INV;
    TVSubtitleData *mDemuxContext = nullptr;
    bool mExitRequested = false;

    int mPid = -1;
    int mDemuxId = -1;
    int mSecureLevelFlag = 0;
    int mParam1 = -1;
    int mParam2 = -1;
    void *mMediaSync = nullptr;
    bool mMediaSyncDestroyFlag = false;

    static DemuxSource *sInstance;

    // Thread function of mRenderTimeThread
    void loopRenderTime();

    void pes_data_cb(int dev_no, int fhandle, const uint8_t *data, int len, void *user_data);

    bool notifyInfoChange();
};