/*
 * This file is part of mpv.
 *
 * mpv is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * mpv 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 Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with mpv.  If not, see <http://www.gnu.org/licenses/>.
 */

#include <math.h>
#include <limits.h>

#include <subrandr/subrandr.h>
#include <subrandr/logging.h>

#include "mpv_talloc.h"

#include "options/m_config.h"
#include "options/options.h"
#include "common/common.h"
#include "demux/packet_pool.h"
#include "demux/stheader.h"
#include "sub/packer.h"
#include "sub/osd.h"
#include "sd.h"

struct sd_sbr_priv {
    struct sbr_library *sbr_library;
    struct sbr_renderer *sbr_renderer;
    struct sbr_subtitles *sbr_subtitles;
    struct mp_osd_res prev_osd;
    struct mp_sub_packer *packer;
#if SUBRANDR_MAJOR > 1 || SUBRANDR_MINOR >= 3
    struct sbr_subtitle_iterator *subtitle_iterator;
    struct active_text_line *text_lines;
    int n_text_lines;
#endif
};

static void enable_output(struct sd *sd, bool enable)
{
    struct sd_sbr_priv *ctx = sd->priv;
    if (enable == !!ctx->sbr_renderer)
        return;
    if (ctx->sbr_renderer) {
        sbr_renderer_destroy(ctx->sbr_renderer);
        ctx->sbr_renderer = NULL;
    } else {
        ctx->sbr_renderer = sbr_renderer_create(ctx->sbr_library);
        if (!ctx->sbr_renderer) {
            const char *error = sbr_get_last_error_string();
            mp_err(sd->log, "Failed to create renderer: %s\n", error);
        }
    }
}

static inline int mp_level_from_sbr_log_level(sbr_log_level level)
{
    switch (level) {
        case SBR_LOG_LEVEL_TRACE:
            return MSGL_TRACE;
        case SBR_LOG_LEVEL_DEBUG:
            return MSGL_DEBUG;
        case SBR_LOG_LEVEL_INFO: // fallthrough
        case SBR_LOG_LEVEL_WARN:
            return MSGL_V;
        case SBR_LOG_LEVEL_ERROR: // fallthrough
        default:
            return MSGL_WARN;
    }
}

static void mp_msg_sbr_log_callback(sbr_log_level level,
                                    const char *source, size_t source_len,
                                    const char *message, size_t message_len,
                                    void *user_data)
{
    struct sd *sd = user_data;
    int mp_level = mp_level_from_sbr_log_level(level);

    if (mp_msg_test(sd->log, mp_level)) {
        if (source_len > 0)
            mp_msg(sd->log, mp_level, "[%.*s] ", (int)source_len, source);
        mp_msg(sd->log, mp_level, "%.*s\n", (int)message_len, message);
    }
}

static int init(struct sd *sd)
{
    if (!sd->codec->codec)
        return -1;
    if (strcmp(sd->codec->codec, "subrandr/srv3"))
        return -1;

    uint32_t major, minor, patch;
    sbr_library_version(&major, &minor, &patch);

    MP_VERBOSE(sd, "subrandr version: %u.%u.%u", SUBRANDR_MAJOR, SUBRANDR_MINOR, SUBRANDR_PATCH);
    if(SUBRANDR_MAJOR != major || SUBRANDR_MINOR != minor || SUBRANDR_PATCH != patch)
        MP_VERBOSE(sd, " (runtime %u.%u.%u)", major, minor, patch);
    MP_VERBOSE(sd, "\n");

    if (major != SUBRANDR_MAJOR || (int32_t)minor < SUBRANDR_MINOR) {
        MP_ERR(sd, "build version %u.%u.%u incompatible with runtime version "
                   "%u.%u.%u, disabling...\n", SUBRANDR_MAJOR, SUBRANDR_MINOR,
               SUBRANDR_PATCH, major, minor, patch);
        return -1;
    }

    sbr_library *library = sbr_library_init();
    if (!library) {
        const char *error = sbr_get_last_error_string();
        mp_err(sd->log, "Failed to initialize library: %s\n", error);
        return -1;
    }

    struct sd_sbr_priv *ctx = talloc_zero(sd, struct sd_sbr_priv);
    sd->priv = ctx;

    ctx->sbr_library = library;
    sbr_library_set_log_callback(ctx->sbr_library, mp_msg_sbr_log_callback, sd);

    ctx->packer = mp_sub_packer_alloc(ctx);

    enable_output(sd, true);

    return 0;
}

static void decode(struct sd *sd, struct demux_packet *packet)
{
    struct sd_sbr_priv *ctx = sd->priv;

    if (ctx->sbr_subtitles)
        sbr_subtitles_destroy(ctx->sbr_subtitles);
    if (ctx->sbr_renderer)
        sbr_renderer_set_subtitles(ctx->sbr_renderer, NULL);

    sbr_subtitle_format fmt = SBR_SUBTITLE_FORMAT_UNKNOWN;
    if (!strcmp(sd->codec->codec, "subrandr/srv3") )
        fmt = SBR_SUBTITLE_FORMAT_SRV3;

    ctx->sbr_subtitles = sbr_load_text(
        ctx->sbr_library,
        packet->buffer,
        packet->len,
        fmt,
        sd->lang
    );

    // Since `demux_sbr` only ever sends us one packet,
    // we treat it as a giant "animated" packet to make sure we don't
    // stop updating the subtitles after one frame if nothing else is
    // driving updates (like if no video is being played).
    packet->animated = true;
    packet->sub_duration = packet->duration;

    if (!ctx->sbr_subtitles) {
        const char *error = sbr_get_last_error_string();
        mp_err(sd->log, "Failed to load subtitles: %s\n", error);
    }
}

static struct sub_bitmaps *get_bitmaps(struct sd *sd, struct mp_osd_res dim,
                                       int format, double pts)
{
    struct sd_sbr_priv *ctx = sd->priv;
    struct mp_subtitle_opts *opts = sd->opts;

    if (pts == MP_NOPTS_VALUE || !ctx->sbr_renderer || !ctx->sbr_subtitles)
        return NULL;

    if (opts->sub_forced_events_only)
        return NULL;

    struct sbr_subtitle_context context = (sbr_subtitle_context) {
        .dpi = 72,
        .video_height = (int32_t)(dim.h - dim.mt - dim.mb) << 6,
        .video_width = (int32_t)(dim.w - dim.ml - dim.mr) << 6,
    };
    struct sbr_rect2i clip_rect = {
        .min_x = 0, .min_y = 0,
        .max_x = dim.w, .max_y = dim.h
    };

    // Translate our clip rect by the zoom (negative) margin to get the
    // part we're actually interested in.
    clip_rect.min_x -= MPMIN(0, dim.ml);
    clip_rect.min_y -= MPMIN(0, dim.mt);
    clip_rect.max_x -= MPMIN(0, dim.ml);
    clip_rect.max_y -= MPMIN(0, dim.mt);

    if (opts->sub_use_margins) {
        context.padding_left = (int32_t)MPMAX(0, dim.ml) << 6;
        context.padding_right = (int32_t)MPMAX(0, dim.mr) << 6;
        context.padding_top = (int32_t)MPMAX(0, dim.mt) << 6;
        context.padding_bottom = (int32_t)MPMAX(0, dim.mb) << 6;
    } else {
        // Remove normal (positive) margins from our clip rect as
        // those are already included in `dim.{w,h}` but we specifically
        // don't want them here.
        clip_rect.max_x -= MPMAX(0, dim.ml) + MPMAX(0, dim.mr);
        clip_rect.max_y -= MPMAX(0, dim.mt) + MPMAX(0, dim.mb);
    }

    unsigned t = lrint(pts * 1000);

    struct sub_bitmaps res;
    const struct sub_bitmaps *cached = mp_sub_packer_get_cached(ctx->packer);

    bool redraw_required = ctx->prev_osd.w != dim.w || ctx->prev_osd.h != dim.h ||
                           ctx->prev_osd.ml != dim.ml || ctx->prev_osd.mt != dim.mt ||
                           ctx->prev_osd.mr != dim.mr || ctx->prev_osd.mb != dim.mb ||
                           !cached || sbr_renderer_did_change(ctx->sbr_renderer, &context, t);
    if (redraw_required) {
        sbr_renderer_set_subtitles(ctx->sbr_renderer, ctx->sbr_subtitles);
        sbr_instanced_raster_pass *pass =
            sbr_renderer_render_instanced(ctx->sbr_renderer, &context, t, clip_rect, 0);
        if (!pass) {
            const char *error = sbr_get_last_error_string();
            mp_err(sd->log, "Failed to render frame: %s\n", error);
            return NULL;
        }

        ctx->prev_osd = dim;

        mp_sub_packer_pack_sbr(ctx->packer, pass, &res);
        sbr_instanced_raster_pass_finish(pass);

        for (int i = 0; i < res.num_parts; ++i) {
            struct sub_bitmap *part = &res.parts[i];
            if (opts->sub_use_margins) {
                part->x += MPMIN(0, dim.ml);
                part->y += MPMIN(0, dim.mt);
            } else {
                part->x += dim.ml;
                part->y += dim.mt;
            }
        }
    } else
        res = *cached;

    return sub_bitmaps_copy(NULL, &res);
}

#if SUBRANDR_MAJOR > 1 || SUBRANDR_MINOR >= 3
// Needed to make sure line order in `get_text` is stable and to deduplicate
// identical lines.
// Without this some styles of karaoke subtitles cause lines to jump around.
// This isn't perfect and messes up some unusual subtitles like braille
// Bad Apple but it's the best we can do without coordinates.
struct active_text_line {
    bstr text;
    bool alive;
};

static void collect_dead_text_lines(struct sd_sbr_priv *ctx)
{
    int shift = 0;
    for (int i = 0; i < ctx->n_text_lines;) {
        struct active_text_line *line = &ctx->text_lines[i + shift];
        if (!line->alive) {
            talloc_free(line->text.start);
            ++shift, --ctx->n_text_lines;
            continue;
        }

        line->alive = false;
        ctx->text_lines[i++] = *line;
    }
}

static char *get_text(struct sd *sd, double pts, enum sd_text_type type)
{
    struct sd_sbr_priv *ctx = sd->priv;

    if (pts == MP_NOPTS_VALUE || !ctx->sbr_subtitles)
        return NULL;
    uint32_t ms = lrint(pts * 1000);

    if (!ctx->subtitle_iterator)
        ctx->subtitle_iterator = sbr_subtitle_iterator_new();
    sbr_subtitle_iterator *iter = ctx->subtitle_iterator;

    size_t total_len = 0;
    sbr_subtitles_iter(ctx->sbr_subtitles, iter);
    for (; !iter->exhausted; sbr_subtitle_iterator_next(iter)) {
        if (iter->start > ms || iter->end <= ms)
            continue;

        const char *text = sbr_subtitle_iterator_get_text(iter, 0);

        for (int i = 0; i < ctx->n_text_lines; ++i) {
            if (!bstrcmp0(ctx->text_lines[i].text, text)) {
                if (!ctx->text_lines[i].alive) {
                    total_len += ctx->text_lines[i].text.len;
                    ctx->text_lines[i].alive = true;
                }
                goto skip;
            }
        }

        struct active_text_line line = {
            .text = bstrdup(ctx, bstr0(text)),
            .alive = true,
        };
        MP_TARRAY_APPEND(ctx, ctx->text_lines, ctx->n_text_lines, line);
        total_len += line.text.len;

    skip:;
    }
    sbr_subtitle_iterator_reset(iter);

    collect_dead_text_lines(ctx);

    if (!ctx->n_text_lines)
        return NULL;

    // For newlines between each surviving line and the null terminator
    total_len += ctx->n_text_lines;
    char *result = talloc_size(NULL, total_len);
    char *current = result;
    for (int i = 0; i < ctx->n_text_lines; ++i) {
        struct active_text_line *line = &ctx->text_lines[i];
        memcpy(current, line->text.start, line->text.len);
        current += line->text.len;
        *current++ = '\n';
    }
    *--current = '\0';

    return result;
}

static struct sub_lines *get_lines(struct sd *sd)
{
    struct sd_sbr_priv *ctx = sd->priv;

    struct sub_lines *res = talloc_zero(NULL, struct sub_lines);
    if (!ctx->sbr_subtitles)
        return res;

    if (!ctx->subtitle_iterator)
        ctx->subtitle_iterator = sbr_subtitle_iterator_new();
    sbr_subtitle_iterator *iter = ctx->subtitle_iterator;

    sbr_subtitles_iter(ctx->sbr_subtitles, iter);
    for (; !iter->exhausted; sbr_subtitle_iterator_next(iter)) {
        const char *text = sbr_subtitle_iterator_get_text(iter, 0);

        struct sub_line line = {
            .text  = bstrdup0(res, bstr_strip(bstr0(text))),
            .start = iter->start / 1000.,
            .end   = iter->end / 1000.
        };
        MP_TARRAY_APPEND(res, res->entries, res->num_entries, line);
    }
    sbr_subtitle_iterator_reset(iter);

    return res;
}
#endif

static void uninit(struct sd *sd)
{
    struct sd_sbr_priv *ctx = sd->priv;

    enable_output(sd, false);
#if SUBRANDR_MAJOR > 1 || SUBRANDR_MINOR >= 3
    if (ctx->subtitle_iterator)
        sbr_subtitle_iterator_destroy(ctx->subtitle_iterator);
#endif
    if (ctx->sbr_subtitles)
        sbr_subtitles_destroy(ctx->sbr_subtitles);
    sbr_library_fini(ctx->sbr_library);
}

static int control(struct sd *sd, enum sd_ctrl cmd, void *arg)
{
    switch (cmd) {
    default:
        return CONTROL_UNKNOWN;
    }
}

const struct sd_functions sd_sbr = {
    .name = "subrandr",
    .accept_packets_in_advance = true,
    .init = init,
    .decode = decode,
    .get_bitmaps = get_bitmaps,
#if SUBRANDR_MAJOR > 1 || SUBRANDR_MINOR >= 3
    .get_text = get_text,
    .get_lines = get_lines,
#endif
    .control = control,
    .select = enable_output,
    .uninit = uninit,
};