# frozen_string_literal: true require 'time' require 'dry/effects/provider' require 'dry/effects/providers/current_time/time_generators' module Dry module Effects module Providers class CurrentTime < Provider[:current_time] include ::Dry::Equalizer(:fixed, :round, inspect: false) include TimeGenetators Locate = Effect.new(type: :current_time, name: :locate) option :fixed, default: -> { true } option :round, default: -> { Undefined } alias_method :fixed?, :fixed attr_reader :generator # Yield the block with the handler installed # # @api private def call(*args) gen, options = value_with_options_from_args(args) @generator = build_generator(gen, **options) yield end def current_time(round_to: Undefined, **options) time = generator.(**options) round = Undefined.coalesce(round_to, self.round) if Undefined.equal?(round) time else time.round(round) end end # Locate handler in the stack # # @return [Provider] # @api private def locate self end # @return [String] # @api public def represent if fixed? if generator.nil? 'current_time[fixed=true]' else "current_time[fixed=#{generator.().iso8601(6)}]" end else 'current_time[fixed=false]' end end private # @return [Proc] time generator # @api private def build_generator(generator, step: Undefined, initial: Undefined, overridable: false) if overridable parent = ::Dry::Effects.yield(Locate) { nil } else parent = nil end if !parent.nil? -> **options { parent.current_time(**options) } elsif !Undefined.equal?(generator) generator elsif !Undefined.equal?(step) IncrementingTimeGenerator.(initial, step) elsif fixed? FixedTimeGenerator.() else RunningTimeGenerator.() end end end end end end