/**
 * RPiPlay - An open-source AirPlay mirroring server for Raspberry Pi
 * Copyright (C) 2019 Florian Draschbacher
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software Foundation,
 * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301  USA
 */

#include "video_renderer.h"
#include <stdlib.h>
#include <assert.h>
#include <stdio.h>
#include <string.h>
#include <stdbool.h>
#include <unistd.h>
#include <gst/gst.h>
#include <gst/app/gstappsrc.h>
#include <gst/video/videooverlay.h>



struct video_renderer_s {
    logger_t *logger;
    GstElement *appsrc, *pipeline, *sink, *decodebin, *videoconvert, *queue;
    int data_lengh;
    uint64_t pts;

};

video_renderer_t *video_renderer_init(logger_t *logger, background_mode_t background_mode, bool low_latency) {
    video_renderer_t *renderer;
    GError *error = NULL;

    renderer = calloc(1, sizeof(video_renderer_t));
    assert(renderer);

    gst_init(NULL, NULL);

    renderer->logger = logger;

    renderer->pipeline = gst_parse_launch("appsrc name=video_source stream-type=0 format=GST_FORMAT_TIME is-live=true ! queue ! decodebin ! videoconvert ! videoscale ! xvimagesink name=video_sink sync=false", &error);
    /*

    renderer->pipeline = gst_parse_launch("appsrc name=video_source stream-type=0 format=GST_FORMAT_TIME is-live=true ! queue ! decodebin ! videoconvert ! videoscale ! tee name=t ! queue ! xvimagesink name=video-sink sync=false ! queue ! v4l2sink device=/dev/video4 t.", &error);


    renderer->pipeline = gst_pipeline_new("test-pipeline");
    renderer->appsrc = gst_element_factory_make("appsrc","video_source");
    renderer->queue = gst_element_factory_make("queue",NULL);
    renderer->sink = gst_element_factory_make("xvimagesink","video_sink");
    renderer->decodebin = gst_element_factory_make("decodebin",NULL);
    renderer->videoconvert = gst_element_factory_make("videoconvert",NULL);
    g_object_set (G_OBJECT (renderer->appsrc),
            "is-live", TRUE, NULL);
    g_object_set (renderer->sink, "sync", FALSE, NULL);
    gst_bin_add_many(GST_BIN (renderer->pipeline), renderer->appsrc, renderer->queue, renderer->decodebin, renderer->videoconvert, renderer->sink, NULL);
    gst_element_link_many (renderer->appsrc,renderer->queue, renderer->decodebin, renderer->videoconvert, renderer->sink, NULL);
    */
    
    g_assert (renderer->pipeline);
    

    renderer->appsrc = gst_bin_get_by_name (GST_BIN (renderer->pipeline), "video_source");
    renderer->sink = gst_bin_get_by_name (GST_BIN (renderer->pipeline), "video_sink");


    return renderer;
}



void set_video_overlay2(video_renderer_t *renderer, gulong embed_xid) {
 
    gst_video_overlay_set_window_handle (GST_VIDEO_OVERLAY (renderer->sink), embed_xid);
}

void video_renderer_start(video_renderer_t *renderer) {
    //g_signal_connect( renderer->pipeline, "deep-notify", G_CALLBACK(gst_object_default_deep_notify ), NULL );
    gst_element_set_state (renderer->pipeline, GST_STATE_PLAYING);
}

void video_renderer_render_buffer(video_renderer_t *renderer, raop_ntp_t *ntp, unsigned char* data, int data_len, uint64_t pts, int type) {
    GstBuffer *buffer;

    assert(data_len != 0);
    renderer->data_lengh = data_len;
    renderer->pts = pts;
    buffer = gst_buffer_new_and_alloc(data_len);
    assert(buffer != NULL);
    GST_BUFFER_DTS(buffer) = (GstClockTime)pts;
    gst_buffer_fill(buffer, 0, data, data_len);
    GST_BUFFER_FLAG_SET(buffer, GST_BUFFER_FLAG_CORRUPTED);
    gst_app_src_push_buffer (GST_APP_SRC(renderer->appsrc), buffer);

}

void video_renderer_flush(video_renderer_t *renderer) {

}

void video_renderer_destroy(video_renderer_t *renderer) {
    gst_app_src_end_of_stream (GST_APP_SRC(renderer->appsrc));
    gst_element_set_state (renderer->pipeline, GST_STATE_NULL);
    gst_object_unref (renderer->pipeline);
    if (renderer) {
        free(renderer);
    }
}

void video_renderer_update_background(video_renderer_t *renderer, int type) {
    /*
    if(type==-1) {
        GstBuffer *buffer;
        buffer = gst_buffer_new_and_alloc(renderer->data_lengh);
        assert(buffer != NULL);
        GST_BUFFER_DTS(buffer) = (GstClockTime)renderer->pts;
        memset (buffer,  0xff, renderer->data_lengh);
        GST_BUFFER_FLAG_SET(buffer, GST_BUFFER_FLAG_CORRUPTED);
        gst_app_src_push_buffer (GST_APP_SRC(renderer->appsrc), buffer);
        //gst_app_src_end_of_stream (GST_APP_SRC(renderer->appsrc));
    }
    */

}