/*
 * Copyright (c) 2023 Fancy Code.
 * 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.
 */
#ifndef MEDI_AHANDLE_H
#define MEDI_AHANDLE_H
#include "IHalCpp.h"
#include "IMediaManager.h"
#include "VStreamHandle.h"
#include <condition_variable>
#include <mutex>
#include <thread>
using std::placeholders::_1;
using std::placeholders::_2;
using std::placeholders::_3;
class MediaHandle : public VMediaHandle, public std::enable_shared_from_this<MediaHandle>
{
public:
    MediaHandle(const MediaChannel &mediaChannel, const std::shared_ptr<VCameraHal> &cameraHal);
    virtual ~MediaHandle() = default;
    void Init(void);
    void UnInit(void);

protected:
    StatusCode ExecuteTask(std::shared_ptr<VMediaTask> &task) override;
    StatusCode StopTask(void) override;
    StatusCode ClearTask(void) override;

private:
    void StartTaskTimer(void);
    void TaskTimer(void);
    CameraTaskType TaskTypeConvert(const MediaTaskType &type);
    void GetVideoStreamCallback(const void *stream, const int &length, const unsigned long long &timeStamp);
    void GetAudioStreamCallback(const void *stream, const int &length, const unsigned long long &timeStamp);

private:
    std::mutex mMutex;
    std::condition_variable mCv;
    const MediaChannel &mMediaChannel;
    std::shared_ptr<VCameraHal> mCameraHal;
    std::weak_ptr<VMediaTask> mCurrentTask;
    std::shared_ptr<VStreamHandle> mStreamHandle;
    bool mTaskRuning;
    std::thread mTaskTimerThread;
};
#endif