/* GdkPixbuf library - WebP Image Loader
 *
 * SPDX-License-Identifier: LGPL-2.0-or-later
 * Copyright (C) 2021 Alan Hawrelak
 * Copyright (C) 2022 Alberto Ruiz
 *
 * Authors: Alan Hawrelak <alangh@shaw.ca>
 *          Alberto Ruiz  <aruiz@gnome.org>
 */

#include "io-webp-anim.h"

#include <webp/decode.h>
#include <webp/demux.h>
#include <webp/encode.h>

typedef struct
{
  GdkPixbuf *pb;
  gint       length;
} Frame;

G_GNUC_BEGIN_IGNORE_DEPRECATIONS
typedef struct
{
  GTimeVal start_time;
  GTimeVal curr_time;
  GArray  *frames;
  guint    loop_length;
  gsize    curr_frame;
} GdkWebpAnimationIterPrivate;

struct _GdkWebpAnimationIter
{
  GdkPixbufAnimationIter parent_instance;
};

static void
clear_frame (Frame *fr)
{
  g_object_unref (fr->pb);
}

G_DEFINE_TYPE_WITH_PRIVATE (GdkWebpAnimationIter, gdk_webp_animation_iter, GDK_TYPE_PIXBUF_ANIMATION_ITER)

static void
iter_finalize (GObject *self)
{
  G_OBJECT_CLASS (gdk_webp_animation_iter_parent_class)->finalize (self);
}

static void
iter_dispose (GObject *self)
{
  GdkWebpAnimationIterPrivate *priv = gdk_webp_animation_iter_get_instance_private (
      GDK_WEBP_ANIMATION_ITER (self));

  if (priv->frames)
    {
      g_array_free (priv->frames, TRUE);
      priv->frames = NULL;
    }

  G_OBJECT_CLASS (gdk_webp_animation_iter_parent_class)->dispose (self);
}

static int
get_delay_time (GdkPixbufAnimationIter *self)
{
  GdkWebpAnimationIterPrivate *priv = gdk_webp_animation_iter_get_instance_private (
      GDK_WEBP_ANIMATION_ITER (self));
  Frame *frame = &g_array_index (priv->frames, Frame, priv->curr_frame);
  return frame->length;
}

static GdkPixbuf *
get_pixbuf (GdkPixbufAnimationIter *self)
{
  GdkWebpAnimationIterPrivate *priv = gdk_webp_animation_iter_get_instance_private (
      GDK_WEBP_ANIMATION_ITER (self));
  Frame *frame = &g_array_index (priv->frames, Frame, priv->curr_frame);
  return frame->pb;
}

static gboolean
on_currently_loading_frame (GdkPixbufAnimationIter *self)
{
  return FALSE;
}

static gint
timeval_sub_in_millis (const GTimeVal *a, const GTimeVal *b)
{
  gint delta_millis = (a->tv_sec - b->tv_sec) * 1000;

  if (b->tv_usec > a->tv_usec)
    {
      delta_millis -= 1000; // -1 second
      delta_millis += (1000000 + (a->tv_usec - b->tv_usec)) / 1000;
    }
  else
    {
      delta_millis += (a->tv_usec - b->tv_usec) / 1000;
    }

  return delta_millis;
}

static gboolean
advance (GdkPixbufAnimationIter *self, const GTimeVal *time)
{
  GdkWebpAnimationIterPrivate *priv = gdk_webp_animation_iter_get_instance_private (
      GDK_WEBP_ANIMATION_ITER (self));

  // time needs to be later than priv->curr_time
  if (time->tv_sec <= priv->curr_time.tv_sec && time->tv_usec <= priv->curr_time.tv_usec)
    return FALSE;

  if (priv->loop_length == 0)
    return FALSE;

  gint delta      = timeval_sub_in_millis (time, &priv->start_time);
  priv->curr_time = *time;

  delta = delta % priv->loop_length;

  for (guint f = 0; f < priv->frames->len; f++)
    {
      Frame *frame = &g_array_index (priv->frames, Frame, f);
      if (delta <= frame->length)
        {
          if (f == priv->curr_frame)
            return FALSE;

          priv->curr_frame = f;
          break;
        }

      delta -= frame->length;
    }

  return TRUE;
}

static void
gdk_webp_animation_iter_class_init (GdkWebpAnimationIterClass *klass)
{
  GObjectClass *object_class = G_OBJECT_CLASS (klass);
  GdkPixbufAnimationIterClass *iter_class = GDK_PIXBUF_ANIMATION_ITER_CLASS (klass);

  object_class->finalize = iter_finalize;
  object_class->dispose  = iter_dispose;

  iter_class->get_delay_time             = get_delay_time;
  iter_class->get_pixbuf                 = get_pixbuf;
  iter_class->on_currently_loading_frame = on_currently_loading_frame;
  iter_class->advance                    = advance;
}

static void
gdk_webp_animation_iter_init (GdkWebpAnimationIter *self)
{
  GdkWebpAnimationIterPrivate *priv = gdk_webp_animation_iter_get_instance_private (self);
  *priv = (GdkWebpAnimationIterPrivate){ 0 };

  priv->frames = g_array_new (FALSE, FALSE, sizeof (Frame));
  g_array_set_clear_func (priv->frames, (GDestroyNotify) clear_frame);
}

GdkWebpAnimationIter *
gdk_webp_animation_new_from_buffer_and_time (const GByteArray *buf,
                                             const GTimeVal   *start_time,
                                             GError          **error)
{
  WebPAnimDecoderOptions opts;
  if (! WebPAnimDecoderOptionsInit (&opts))
    {
      g_set_error (error, GDK_PIXBUF_ERROR, GDK_PIXBUF_ERROR_FAILED,
                   "Could not initialize WebP decoder options");
      return NULL;
    }

  opts.color_mode = MODE_RGBA;

  WebPData         data = { .bytes = buf->data, .size = (size_t) buf->len };
  WebPAnimDecoder *adec = WebPAnimDecoderNew (&data, &opts);
  if (! adec)
    {
      g_set_error (error, GDK_PIXBUF_ERROR, GDK_PIXBUF_ERROR_FAILED,
                   "Could not instantiate WebPAnimDecoder");
      return NULL;
    }

  WebPAnimInfo ainfo;
  if (! WebPAnimDecoderGetInfo (adec, &ainfo))
    {
      g_set_error (error, GDK_PIXBUF_ERROR, GDK_PIXBUF_ERROR_FAILED,
                   "Could not get animation info from WebP decoder");
      g_clear_pointer (&adec, WebPAnimDecoderDelete);
      return NULL;
    }

  GdkWebpAnimationIter *iter = g_object_new (GDK_WEBP_ANIMATION_ITER_TYPE, NULL);
  GdkWebpAnimationIterPrivate *priv = gdk_webp_animation_iter_get_instance_private (iter);

  if (start_time == NULL)
    {
      g_get_current_time (&priv->start_time);
    }
  else
    {
      priv->start_time = *start_time;
    }

  guchar *tmp_data    = NULL;
  gint    timestamp   = 0;
  gint    loop_length = 0;

  while (WebPAnimDecoderHasMoreFrames (adec))
    {
      if (! WebPAnimDecoderGetNext (adec, &tmp_data, &timestamp))
        {
          g_set_error (error, GDK_PIXBUF_ERROR, GDK_PIXBUF_ERROR_FAILED,
                       "Could not get frame from WebP animation decoder");
          g_clear_pointer (&adec, WebPAnimDecoderDelete);
          return NULL;
        }

      GdkPixbuf *pb = gdk_pixbuf_new (GDK_COLORSPACE_RGB, TRUE, 8, (gint) ainfo.canvas_width,
                                      (gint) ainfo.canvas_height);

      guchar *pb_pixels   = gdk_pixbuf_get_pixels (pb);
      gsize   pb_stride   = (gsize) gdk_pixbuf_get_rowstride (pb);
      gsize   data_stride = (gsize) ainfo.canvas_width * 4;
      for (int i = 0; i < ainfo.canvas_height; i++)
        {
          guchar *data_row = tmp_data + (i * data_stride);
          guchar *pb_row   = pb_pixels + (i * pb_stride);
          memcpy (pb_row, data_row, data_stride);
        }

      Frame f = { .pb = pb, .length = timestamp - loop_length };
      g_array_append_vals (priv->frames, &f, 1);

      loop_length = timestamp;
      tmp_data    = NULL;
      timestamp   = 0;
    }

  priv->loop_length = loop_length;

  g_clear_pointer (&adec, WebPAnimDecoderDelete);
  return iter;
}
G_GNUC_END_IGNORE_DEPRECATIONS