// This file is part of OpenCV project.
// It is subject to the license terms in the LICENSE file found in the top-level directory
// of this distribution and at http://opencv.org/license.html

#include "precomp.hpp"

#include <stdio.h>
#include <string.h>
#include <fstream>
#include <iostream>
#include <unistd.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <fcntl.h>
#include <android/log.h>
#include <android/native_window.h>
#include "media/NdkMediaCodec.h"
#include "media/NdkMediaMuxer.h"
#include "media/NdkMediaExtractor.h"
#include "media/NdkMediaFormat.h"

#define INPUT_TIMEOUT_MS 2000

#define COLOR_FormatUnknown -1
#define COLOR_FormatYUV420Planar 19
#define COLOR_FormatYUV420SemiPlanar 21
#define COLOR_FormatSurface 0x7f000789 //See https://developer.android.com/reference/android/media/MediaCodecInfo.CodecCapabilities for codes

#define FOURCC_BGR CV_FOURCC_MACRO('B','G','R','3')
#define FOURCC_RGB CV_FOURCC_MACRO('R','G','B','3')
#define FOURCC_BGRA CV_FOURCC_MACRO('B','G','R','4')
#define FOURCC_RGBA CV_FOURCC_MACRO('R','G','B','4')
#define FOURCC_GRAY CV_FOURCC_MACRO('G','R','E','Y')
#define FOURCC_NV12 CV_FOURCC_MACRO('N','V','1','2')
#define FOURCC_YV12 CV_FOURCC_MACRO('Y','V','1','2')
#define FOURCC_UNKNOWN  0xFFFFFFFF

using namespace cv;

#define TAG "NativeCodec"
#define LOGV(...) __android_log_print(ANDROID_LOG_VERBOSE, TAG, __VA_ARGS__)
#define LOGE(...) __android_log_print(ANDROID_LOG_ERROR, TAG, __VA_ARGS__)


static inline void deleter_AMediaExtractor(AMediaExtractor *extractor) {
    AMediaExtractor_delete(extractor);
}

static inline void deleter_AMediaCodec(AMediaCodec *codec) {
    AMediaCodec_stop(codec);
    AMediaCodec_delete(codec);
}

static inline void deleter_AMediaFormat(AMediaFormat *format) {
    AMediaFormat_delete(format);
}

class AndroidMediaNdkCapture : public IVideoCapture
{

public:
    AndroidMediaNdkCapture():
        sawInputEOS(false), sawOutputEOS(false),
        frameStride(0), frameWidth(0), frameHeight(0),
        colorFormat(COLOR_FormatUnknown), fourCC(FOURCC_BGR),
        videoWidth(0), videoHeight(0), videoFrameCount(0),
        videoRotation(0), videoRotationCode(-1),
        videoOrientationAuto(false) {}

    std::shared_ptr<AMediaExtractor> mediaExtractor;
    std::shared_ptr<AMediaCodec> mediaCodec;
    bool sawInputEOS;
    bool sawOutputEOS;
    int32_t frameStride;
    int32_t frameWidth;
    int32_t frameHeight;
    int32_t colorFormat;
    uint32_t fourCC;
    int32_t videoWidth;
    int32_t videoHeight;
    float videoFrameRate;
    int32_t videoFrameCount;
    int32_t videoRotation;
    int32_t videoRotationCode;
    bool videoOrientationAuto;
    std::vector<uint8_t> buffer;

    ~AndroidMediaNdkCapture() { cleanUp(); }

    bool decodeFrame() {
        while (!sawInputEOS || !sawOutputEOS) {
            if (!sawInputEOS) {
                auto bufferIndex = AMediaCodec_dequeueInputBuffer(mediaCodec.get(), INPUT_TIMEOUT_MS);
                LOGV("input buffer %zd", bufferIndex);
                if (bufferIndex >= 0) {
                    size_t bufferSize;
                    auto inputBuffer = AMediaCodec_getInputBuffer(mediaCodec.get(), bufferIndex, &bufferSize);
                    auto sampleSize = AMediaExtractor_readSampleData(mediaExtractor.get(), inputBuffer, bufferSize);
                    if (sampleSize < 0) {
                        sampleSize = 0;
                        sawInputEOS = true;
                        LOGV("EOS");
                    }
                    auto presentationTimeUs = AMediaExtractor_getSampleTime(mediaExtractor.get());

                    AMediaCodec_queueInputBuffer(mediaCodec.get(), bufferIndex, 0, sampleSize,
                        presentationTimeUs, sawInputEOS ? AMEDIACODEC_BUFFER_FLAG_END_OF_STREAM : 0);
                    AMediaExtractor_advance(mediaExtractor.get());
                }
            }

            if (!sawOutputEOS) {
                AMediaCodecBufferInfo info;
                auto bufferIndex = AMediaCodec_dequeueOutputBuffer(mediaCodec.get(), &info, 0);
                if (bufferIndex >= 0) {
                    size_t bufferSize = 0;
                    auto mediaFormat = std::shared_ptr<AMediaFormat>(AMediaCodec_getOutputFormat(mediaCodec.get()), deleter_AMediaFormat);
                    AMediaFormat_getInt32(mediaFormat.get(), AMEDIAFORMAT_KEY_WIDTH, &frameWidth);
                    AMediaFormat_getInt32(mediaFormat.get(), AMEDIAFORMAT_KEY_STRIDE, &frameStride);
                    AMediaFormat_getInt32(mediaFormat.get(), AMEDIAFORMAT_KEY_HEIGHT, &frameHeight);
                    AMediaFormat_getInt32(mediaFormat.get(), AMEDIAFORMAT_KEY_COLOR_FORMAT, &colorFormat);
                    uint8_t* codecBuffer = AMediaCodec_getOutputBuffer(mediaCodec.get(), bufferIndex, &bufferSize);
                    buffer = std::vector<uint8_t>(codecBuffer, codecBuffer + bufferSize);
                    LOGV("colorFormat: %d", colorFormat);
                    LOGV("buffer size: %zu", bufferSize);
                    LOGV("width (frame): %d", frameWidth);
                    LOGV("stride (frame): %d", frameStride);
                    LOGV("height (frame): %d", frameHeight);
                    if (info.flags & AMEDIACODEC_BUFFER_FLAG_END_OF_STREAM)
                    {
                        LOGV("output EOS");
                        sawOutputEOS = true;
                    }

                    AMediaCodec_releaseOutputBuffer(mediaCodec.get(), bufferIndex, info.size != 0);
                    return true;
                } else if (bufferIndex == AMEDIACODEC_INFO_OUTPUT_BUFFERS_CHANGED) {
                    LOGV("output buffers changed");
                } else if (bufferIndex == AMEDIACODEC_INFO_OUTPUT_FORMAT_CHANGED) {
                    auto format = AMediaCodec_getOutputFormat(mediaCodec.get());
                    LOGV("format changed to: %s", AMediaFormat_toString(format));
                    AMediaFormat_delete(format);
                } else if (bufferIndex == AMEDIACODEC_INFO_TRY_AGAIN_LATER) {
                    LOGV("no output buffer right now");
                } else {
                    LOGV("unexpected info code: %zd", bufferIndex);
                }
            }
        }
        return false;
    }

    bool isOpened() const CV_OVERRIDE { return mediaCodec.get() != nullptr; }

    int getCaptureDomain() CV_OVERRIDE { return CAP_ANDROID; }

    bool grabFrame() CV_OVERRIDE
    {
        // clear the previous frame
        buffer.clear();
        return decodeFrame();
    }

    bool retrieveFrame(int, OutputArray out) CV_OVERRIDE
    {
        if (buffer.empty()) {
            return false;
        }

        ColorConversionCodes ccCode;
        const Mat yuv(frameHeight + frameHeight/2,
                      frameWidth, CV_8UC1, buffer.data(), frameStride);

        if (colorFormat == COLOR_FormatYUV420Planar) {
            switch(fourCC)
            {
                case     FOURCC_BGR: ccCode = COLOR_YUV2BGR_YV12;   break;
                case     FOURCC_RGB: ccCode = COLOR_YUV2RGB_YV12;   break;
                case    FOURCC_BGRA: ccCode = COLOR_YUV2BGRA_YV12;  break;
                case    FOURCC_RGBA: ccCode = COLOR_YUV2RGBA_YV12;  break;
                case    FOURCC_GRAY: ccCode = COLOR_YUV2GRAY_YV12;  break;
                case    FOURCC_YV12: break;
                case FOURCC_UNKNOWN: fourCC = FOURCC_YV12;          break;
                            default: LOGE("Unexpected FOURCC value: %d", fourCC);
                                     return false;
            }
        } else if (colorFormat == COLOR_FormatYUV420SemiPlanar) {
            // Attention: COLOR_FormatYUV420SemiPlanar seems to correspond to NV12.
            //            This is different from the Camera2 interface, where NV21
            //            is used in this situation.
            switch(fourCC)
            {
                case     FOURCC_BGR: ccCode = COLOR_YUV2BGR_NV12;   break;
                case     FOURCC_RGB: ccCode = COLOR_YUV2RGB_NV12;   break;
                case    FOURCC_BGRA: ccCode = COLOR_YUV2BGRA_NV12;  break;
                case    FOURCC_RGBA: ccCode = COLOR_YUV2RGBA_NV12;  break;
                case    FOURCC_GRAY: ccCode = COLOR_YUV2GRAY_NV12;  break;
                case    FOURCC_NV12: break;
                case FOURCC_UNKNOWN: fourCC = FOURCC_NV12;          break;
                            default: LOGE("Unexpected FOURCC value: %d", fourCC);
                                     return false;
            }
        } else {
            LOGE("Unsupported video format: %d", colorFormat);
            return false;
        }

        if (fourCC == FOURCC_YV12 || fourCC == FOURCC_NV12)
            yuv.copyTo(out);
        else
            cvtColor(yuv, out, ccCode);

        if (videoOrientationAuto && -1 != videoRotationCode)
            rotate(out, out, videoRotationCode);

        return true;
    }

    double getProperty(int property_id) const CV_OVERRIDE
    {
        switch (property_id)
        {
            case CAP_PROP_FRAME_WIDTH:
                return (( videoOrientationAuto &&
                         (cv::ROTATE_90_CLOCKWISE == videoRotationCode || cv::ROTATE_90_COUNTERCLOCKWISE == videoRotationCode))
                        ? videoHeight : videoWidth);
            case CAP_PROP_FRAME_HEIGHT:
                return (( videoOrientationAuto &&
                         (cv::ROTATE_90_CLOCKWISE == videoRotationCode || cv::ROTATE_90_COUNTERCLOCKWISE == videoRotationCode))
                        ? videoWidth : videoHeight);
            case CAP_PROP_FPS: return videoFrameRate;
            case CAP_PROP_FRAME_COUNT: return videoFrameCount;
            case CAP_PROP_ORIENTATION_META: return videoRotation;
            case CAP_PROP_ORIENTATION_AUTO: return videoOrientationAuto ? 1 : 0;
            case CAP_PROP_FOURCC: return fourCC;
        }

        // unknown parameter or value not available
        return -1;
    }

    bool setProperty(int property_id, double value) CV_OVERRIDE
    {
        switch (property_id)
        {
            case CAP_PROP_ORIENTATION_AUTO: {
                videoOrientationAuto = value != 0 ? true : false;
                return true;
            }
            case CAP_PROP_FOURCC: {
                uint32_t newFourCC = cvRound(value);
                switch (newFourCC)
                {
                    case FOURCC_BGR:
                    case FOURCC_RGB:
                    case FOURCC_BGRA:
                    case FOURCC_RGBA:
                    case FOURCC_GRAY:
                        fourCC = newFourCC;
                        return true;
                    case FOURCC_YV12:
                        if (colorFormat != COLOR_FormatYUV420SemiPlanar) {
                            fourCC = (colorFormat == COLOR_FormatUnknown) ? FOURCC_UNKNOWN : FOURCC_YV12;
                            return true;
                        }
                        break;
                    case FOURCC_NV12:
                        if (colorFormat != COLOR_FormatYUV420Planar) {
                            fourCC = (colorFormat == COLOR_FormatUnknown) ? FOURCC_UNKNOWN : FOURCC_NV12;
                            return true;
                        }
                        break;
                }
            }
        }

        return false;
    }

    bool initCapture(const char * filename)
    {
        struct stat statBuffer;
        if (stat(filename, &statBuffer) != 0) {
            LOGE("failed to stat file: %s (%s)", filename, strerror(errno));
            return false;
        }

        int fd = open(filename, O_RDONLY);

        if (fd < 0) {
            LOGE("failed to open file: %s %d (%s)", filename, fd, strerror(errno));
            return false;
        }

        mediaExtractor = std::shared_ptr<AMediaExtractor>(AMediaExtractor_new(), deleter_AMediaExtractor);
        if (!mediaExtractor) {
            return false;
        }
        media_status_t err = AMediaExtractor_setDataSourceFd(mediaExtractor.get(), fd, 0, statBuffer.st_size);
        close(fd);
        if (err != AMEDIA_OK) {
            LOGV("setDataSource error: %d", err);
            return false;
        }

        int numtracks = AMediaExtractor_getTrackCount(mediaExtractor.get());

        LOGV("input has %d tracks", numtracks);
        for (int i = 0; i < numtracks; i++) {
            auto format = std::shared_ptr<AMediaFormat>(AMediaExtractor_getTrackFormat(mediaExtractor.get(), i), deleter_AMediaFormat);
            if (!format) {
                continue;
            }
            const char *s = AMediaFormat_toString(format.get());
            LOGV("track %d format: %s", i, s);
            const char *mime;
            if (!AMediaFormat_getString(format.get(), AMEDIAFORMAT_KEY_MIME, &mime)) {
                LOGV("no mime type");
            } else if (!strncmp(mime, "video/", 6)) {
                int32_t trackWidth, trackHeight, fps, frameCount = 0, rotation = 0;
                AMediaFormat_getInt32(format.get(), AMEDIAFORMAT_KEY_WIDTH, &trackWidth);
                AMediaFormat_getInt32(format.get(), AMEDIAFORMAT_KEY_HEIGHT, &trackHeight);
                AMediaFormat_getInt32(format.get(), AMEDIAFORMAT_KEY_FRAME_RATE, &fps);

                #if __ANDROID_API__ >= 28
                    AMediaFormat_getInt32(format.get(), AMEDIAFORMAT_KEY_ROTATION, &rotation);
                    LOGV("rotation (track): %d", rotation);
                #endif

                #if __ANDROID_API__ >= 29
                    AMediaFormat_getInt32(format.get(), AMEDIAFORMAT_KEY_FRAME_COUNT, &frameCount);
                #endif

                LOGV("width (track): %d", trackWidth);
                LOGV("height (track): %d", trackHeight);
                if (AMediaExtractor_selectTrack(mediaExtractor.get(), i) != AMEDIA_OK) {
                    continue;
                }
                mediaCodec = std::shared_ptr<AMediaCodec>(AMediaCodec_createDecoderByType(mime), deleter_AMediaCodec);
                if (!mediaCodec) {
                    continue;
                }
                if (AMediaCodec_configure(mediaCodec.get(), format.get(), NULL, NULL, 0) != AMEDIA_OK) {
                    continue;
                }
                sawInputEOS = false;
                sawOutputEOS = false;
                if (AMediaCodec_start(mediaCodec.get()) != AMEDIA_OK) {
                    continue;
                }

                videoWidth = trackWidth;
                videoHeight = trackHeight;
                videoFrameRate = fps;
                videoFrameCount = frameCount;
                videoRotation = rotation;

                switch(videoRotation) {
                    case 90:
                        videoRotationCode = cv::ROTATE_90_CLOCKWISE;
                        break;

                    case 180:
                        videoRotationCode = cv::ROTATE_180;
                        break;

                    case 270:
                        videoRotationCode = cv::ROTATE_90_COUNTERCLOCKWISE;
                        break;

                    default:
                        videoRotationCode = -1;
                        break;
                }

                return true;
            }
        }

        return false;
    }

    void cleanUp() {
        sawInputEOS = true;
        sawOutputEOS = true;
        frameStride = 0;
        frameWidth = 0;
        frameHeight = 0;
        colorFormat = 0;
        videoWidth = 0;
        videoHeight = 0;
        videoFrameRate = 0;
        videoFrameCount = 0;
        videoRotation = 0;
        videoRotationCode = -1;
    }
};



class AndroidMediaNdkVideoWriter CV_FINAL :
    public cv::IVideoWriter
{
    typedef struct {
        int fourcc;
        const char* mime;
        OutputFormat muxerFormat;
    }
    FourCCInfo;

    static const int64_t TIMEOUT = 1000L;
    static const FourCCInfo FOURCC_INFO[];

    static const FourCCInfo* findInfo(int fourcc) {
        for( const FourCCInfo *it = FOURCC_INFO; NULL != it->mime; it++ ) {
            if (fourcc == it->fourcc) return it;
        }
        return NULL;
    }

    AMediaFormat* format;
    AMediaCodec* encoder;
    AMediaMuxer* muxer;

    #if __ANDROID_API__ >= 26
    ANativeWindow* surface;
    #endif

    long frameIndex;
    int width;
    int height;
    double frameRate;
    ssize_t videoTrackIndex;
    int fd;

    void drainEncoder(bool end) {
        if (end) {
            #if __ANDROID_API__ >= 26
            AMediaCodec_signalEndOfInputStream(encoder);
            #else
            writeBytes(NULL, 0);
            #endif
        }

        AMediaCodecBufferInfo bufferInfo;
        ssize_t bufferIndex;
        size_t  bufferSize;
        uint8_t *buffer;

        while (true) {
            bufferIndex = AMediaCodec_dequeueOutputBuffer(encoder, &bufferInfo, TIMEOUT);
            if (bufferIndex >= 0) {
                buffer = AMediaCodec_getOutputBuffer(encoder, (size_t)bufferIndex, &bufferSize);

                if (NULL == buffer || 0 == bufferSize){
                    LOGE("Can't get output buffer");
                    break;
                }

                if (videoTrackIndex >= 0) {
                    bufferInfo.presentationTimeUs = frameIndex * 1000000L / frameRate;
                    LOGV("Muxer write to track %d: %d byte(s)", (int)videoTrackIndex, (int)bufferInfo.size);
                    AMediaMuxer_writeSampleData(muxer, (size_t)videoTrackIndex, buffer, &bufferInfo);
                } else {
                    LOGE("Invalid video track !");
                }

                AMediaCodec_releaseOutputBuffer(encoder, (size_t)bufferIndex, false);
                if (bufferInfo.flags & AMEDIACODEC_BUFFER_FLAG_END_OF_STREAM) break;
            } else if (AMEDIACODEC_INFO_TRY_AGAIN_LATER == bufferIndex) {
                if (!end) break;
            } else if (AMEDIACODEC_INFO_OUTPUT_FORMAT_CHANGED == bufferIndex) {
                videoTrackIndex = AMediaMuxer_addTrack(muxer, AMediaCodec_getOutputFormat(encoder));
                if (videoTrackIndex >= 0) {
                    AMediaMuxer_start(muxer);
                }
                LOGV("New videoTrackIndex: %d", (int)videoTrackIndex);
            }
        }
    }

    #if __ANDROID_API__ < 26
    void writeBytes( uint8_t* inputBuffer, size_t inputBufferSize ) {
        LOGV("[writeBytes] inputBufferSize=%u", (unsigned int)inputBufferSize);

        ssize_t bufferIndex;
        size_t  bufferSize;
        uint8_t* buffer;
        size_t  partialSize;
        bool firstCall = true;
        uint32_t flags;

        while(inputBufferSize > 0 || firstCall) {
            bufferIndex = AMediaCodec_dequeueInputBuffer(encoder, TIMEOUT);

            if (bufferIndex >= 0) {
                firstCall = false;
                buffer = AMediaCodec_getInputBuffer(encoder, (size_t)bufferIndex, &bufferSize);
                if (NULL == buffer || 0 == bufferSize) break;

                flags = 0;
                partialSize = (inputBufferSize > bufferSize) ? bufferSize : inputBufferSize;
                if (partialSize > 0) {
                    memcpy(buffer, inputBuffer, partialSize);
                    inputBuffer += partialSize;
                    inputBufferSize -= partialSize;
                    if (inputBufferSize > 0) {
                        flags = AMEDIACODEC_BUFFER_FLAG_PARTIAL_FRAME;
                    }
                } else {
                    flags = AMEDIACODEC_BUFFER_FLAG_END_OF_STREAM;
                }

                LOGV(
                    "[writeBytes] partial - bufferIndex=%d, bufferSize=%u, partialSize=%u, remaining inputBufferSize=%u",
                    (int)bufferIndex, (unsigned int)bufferSize, (unsigned int)partialSize, (unsigned int)inputBufferSize
                );

                AMediaCodec_queueInputBuffer(encoder, (size_t)bufferIndex, 0, partialSize, frameIndex * 1000000L / frameRate, flags);
                if (NULL != inputBuffer) drainEncoder(false);
            }
        }
    }
    #endif

public:
    AndroidMediaNdkVideoWriter(const cv::String& filename, int fourcc, double fps, cv::Size frameSize, const VideoWriterParameters& params)
        : format(NULL),
          encoder(NULL),
          muxer(NULL),
          #if __ANDROID_API__ >= 26
          surface(NULL),
          #endif
          frameIndex(0),
          width(0),
          height(0),
          frameRate(0.),
          videoTrackIndex(-1),
          fd(-1) {
        open(filename, fourcc, fps, frameSize, params);
    }
    virtual ~AndroidMediaNdkVideoWriter() { close(); }

    virtual int getCaptureDomain() const CV_OVERRIDE { return cv::CAP_ANDROID; }

    virtual void write(cv::InputArray image_ ) CV_OVERRIDE
    {
        if (!image_.isMat()) {
            LOGE("Support only Mat input");
            return;
        }

        Mat image = image_.getMat();
        if (image.cols > width || image.rows > height ||
            (CV_8UC1 != image.type() && CV_8UC3 != image.type() && CV_8UC4 != image.type())) {
            LOGE(
                "Expected input to be a mat of maximum %d x %d of type CV_8UC1, CV_8UC3 or CV_8UC4"
                " (%d, %d, %d), but received %d x %d of type %d",
                width, height, CV_8UC1, CV_8UC3, CV_8UC4,
                image.cols, image.rows, image.type()
            );
            return;
        }

        #if __ANDROID_API__ >= 26
        ANativeWindow_Buffer buffer;
        if (0 != ANativeWindow_lock(surface, &buffer, NULL)) {
            LOGE("Failed to lock the surface");
            return;
        }

        if (AHARDWAREBUFFER_FORMAT_R8G8B8A8_UNORM == buffer.format) {
            Mat bufferMat(image.rows, image.cols, CV_8UC4, buffer.bits, buffer.stride * 4);
            switch (image.type()) {
                case CV_8UC4: image.copyTo(bufferMat);                  break;
                case CV_8UC3: cvtColor(image, bufferMat, COLOR_BGR2RGBA);  break;
                case CV_8UC1: cvtColor(image, bufferMat, COLOR_GRAY2RGBA); break;
            }
        } else {
            LOGE("Unknown surface buffer format: 0x%x", buffer.format);
        }

        ANativeWindow_unlockAndPost(surface);
        #else
        //OpenCV doesn't support RGB to NV12 so we need to convert to YV12 and then manually changed it to NV12
        Mat imageYV12;
        switch (image.type()) {
            case CV_8UC4: cvtColor(image, imageYV12, COLOR_RGBA2YUV_YV12); break;
            case CV_8UC3: cvtColor(image, imageYV12, COLOR_BGR2YUV_YV12);  break;
            case CV_8UC1: imageYV12.create(image.rows + image.rows/2, image.cols, CV_8UC1);
                          image.copyTo(imageYV12.rowRange(0, image.rows));
                          imageYV12.rowRange(image.rows, imageYV12.rows) = 128;
                          break;
        }

        //convert from YV12 to NV12
        if (image.type() != CV_8UC1) {
            size_t yPlaneSize = width * height;
            size_t vPlaneSize = yPlaneSize / 4;

            Mat channels[2] = {
                Mat( vPlaneSize, 1, CV_8UC1, imageYV12.ptr() + yPlaneSize + vPlaneSize ).clone(),
                Mat( vPlaneSize, 1, CV_8UC1, imageYV12.ptr() + yPlaneSize ).clone()
            };
            Mat vuMat( vPlaneSize, 1, CV_8UC2, imageYV12.ptr() + yPlaneSize );
            merge(channels, 2, vuMat);
        }

        writeBytes( imageYV12.ptr(), imageYV12.rows * imageYV12.cols );
        #endif

        drainEncoder(false);

        frameIndex++;
    }

    virtual bool open( const cv::String& filename, int fourcc, double fps, cv::Size frameSize, const VideoWriterParameters& params )
    {
        media_status_t status;

        close();

        const FourCCInfo* info = findInfo(fourcc);
        if (NULL == info) {
            LOGE("ERROR: findInfo");
            return false;
        }

        format = AMediaFormat_new();
        if (NULL == format) {
            LOGE("ERROR: AMediaFormat_new");
            goto error;
        }

        LOGV("mime: %s, width: %d, height: %d, fps: %f", info->mime, frameSize.width, frameSize.height, fps);

        AMediaFormat_setString(format, AMEDIAFORMAT_KEY_MIME, info->mime);
        AMediaFormat_setInt32(format, AMEDIAFORMAT_KEY_WIDTH, frameSize.width);
        AMediaFormat_setInt32(format, AMEDIAFORMAT_KEY_HEIGHT, frameSize.height);
        AMediaFormat_setFloat(format, AMEDIAFORMAT_KEY_FRAME_RATE, (float)fps);
        AMediaFormat_setInt32(format, AMEDIAFORMAT_KEY_I_FRAME_INTERVAL, 5);
        AMediaFormat_setInt32(format, AMEDIAFORMAT_KEY_BIT_RATE, frameSize.width * frameSize.height * 5);
        AMediaFormat_setInt32(
            format, AMEDIAFORMAT_KEY_COLOR_FORMAT,
            #if __ANDROID_API__ >= 26
            COLOR_FormatSurface
            #else
            COLOR_FormatYUV420SemiPlanar
            #endif
        );

        encoder = AMediaCodec_createEncoderByType(info->mime);
        if (NULL == encoder) {
            LOGE("ERROR: AMediaCodec_createEncoderByType");
            goto error;
        }

        status = AMediaCodec_configure(encoder, format, NULL, NULL, AMEDIACODEC_CONFIGURE_FLAG_ENCODE);
        if (AMEDIA_OK != status) {
            LOGE("ERROR: AMediaCodec_configure (%d)", status);
            goto error;
        }

        #if __ANDROID_API__ >= 26
        status = AMediaCodec_createInputSurface(encoder, &surface);
        if (AMEDIA_OK != status || NULL == surface) {
            LOGE("ERROR: AMediaCodec_createInputSurface (%d)", status);
            goto error;
        }
        ANativeWindow_setBuffersGeometry(surface, width, height, AHARDWAREBUFFER_FORMAT_R8G8B8A8_UNORM);
        #endif

        AMediaCodec_start(encoder);

        fd = ::open(filename.c_str(), O_WRONLY | O_CREAT | O_TRUNC, 0666);
        if (fd < 0) {
            LOGE("ERROR: open");
            goto error;
        }

        muxer = AMediaMuxer_new(fd, info->muxerFormat);
        if (NULL == muxer) {
            LOGE("ERROR: AMediaMuxer_new");
            goto error;
        }

        AMediaMuxer_setOrientationHint(muxer, params.get(CAP_PROP_ORIENTATION_META, 0));

        frameIndex = 0;
        width = frameSize.width;
        height = frameSize.height;
        frameRate = fps;
        videoTrackIndex = -1;

        return true;

    error:
        close();
        return false;
    }

    virtual void close()
    {
        if (videoTrackIndex >= 0 && NULL != muxer) {
            drainEncoder(true);
            AMediaMuxer_stop(muxer);
        }

        if (NULL != encoder) AMediaCodec_delete(encoder);
        if (NULL != muxer) AMediaMuxer_delete(muxer);

        #if __ANDROID_API__ >= 26
        if (NULL != surface) ANativeWindow_release(surface);
        #endif

        if (fd >= 0) ::close(fd);
        if (NULL != format) AMediaFormat_delete(format);

        format = NULL;
        encoder = NULL;
        muxer = NULL;
        #if __ANDROID_API__ >= 26
        surface = NULL;
        #endif
        frameIndex = 0;
        width = 0;
        height = 0;
        frameRate = 0.;
        videoTrackIndex = -1;
        fd = -1;
    }

    virtual double getProperty(int) const CV_OVERRIDE { return 0.; }
    virtual bool setProperty(int, double) CV_OVERRIDE { return false; }
    virtual bool isOpened() const CV_OVERRIDE { return NULL != encoder; }
};


const AndroidMediaNdkVideoWriter::FourCCInfo AndroidMediaNdkVideoWriter::FOURCC_INFO[] = {
    { CV_FOURCC('H', '2', '6', '4'), "video/avc", AMEDIAMUXER_OUTPUT_FORMAT_MPEG_4 },
    { CV_FOURCC('H', '2', '6', '5'), "video/hevc", AMEDIAMUXER_OUTPUT_FORMAT_MPEG_4 },
    { CV_FOURCC('H', '2', '6', '3'), "video/3gpp", AMEDIAMUXER_OUTPUT_FORMAT_MPEG_4 },
    { CV_FOURCC('M', 'P', '4', 'V'), "video/mp4v-es", AMEDIAMUXER_OUTPUT_FORMAT_MPEG_4 },
    { 0, NULL, AMEDIAMUXER_OUTPUT_FORMAT_MPEG_4 },
};



/****************** Implementation of interface functions ********************/

Ptr<IVideoCapture> cv::createAndroidCapture_file(const std::string &filename, const VideoCaptureParameters& ) {
    Ptr<AndroidMediaNdkCapture> res = makePtr<AndroidMediaNdkCapture>();
    if (res && res->initCapture(filename.c_str()))
        return res;
    return Ptr<IVideoCapture>();
}


Ptr<IVideoWriter> cv::createAndroidVideoWriter(
    const std::string& filename, int fourcc,
    double fps, const cv::Size& frameSize,
    const VideoWriterParameters& params) {
    Ptr<AndroidMediaNdkVideoWriter> writer = makePtr<AndroidMediaNdkVideoWriter>(filename, fourcc, fps, frameSize, params);
    if (writer && writer->isOpened())
        return writer;
    return Ptr<IVideoWriter>();
}