ddfreyne/d-stream

# frozen_string_literal: true

require 'd-stream'

events =
  Enumerator.new do |y|
    y << { id: 40_562_348, at: Time.now - 400, status: 'new' }
    y << { id: 40_564_682, at: Time.now - 300, assignee_id: 2 }
    y << { id: 40_565_795, at: Time.now - 250, priority: 'high' }
    y << { id: 40_569_932, at: Time.now - 100, status: 'solved' }
  end.lazy

S = DStream

merge =
  S.scan({}, &:merge)

add_version =
  S.compose(
    S.zip(1..),
    S.map { |(e, i)| e.merge(version: i) }
  )

remove_id =
  S.map { |e| e.except(:id) }

add_valid_dates =
  S.compose(
    S.with_next,
    S.map { |(a, b)| a.merge(valid_to: b ? b.fetch(:at) : nil) },
    S.map { |e| e.merge(valid_from: e.fetch(:at)) },
    S.map { |e| e.except(:at) }
  )

add_row_is_current =
  S.compose(
    S.with_next,
    S.map { |(a, b)| a.merge(row_is_current: b.nil?) }
  )

history_builder =
  S.compose(
    merge,
    add_version,
    remove_id,
    add_valid_dates,
    add_row_is_current
  )

history = history_builder.call(events)

history.each { |h| p h }