Contents

require 'network_executive/program_schedule_proxy'

module NetworkExecutive
  class ProgramSchedule
    attr_accessor :program, :start_time, :duration, :proxy

    Occurrence = Struct.new('Occurrence', :start_time, :duration, :end_time)

    def initialize( program, options = {}, &block )
      options.symbolize_keys!

      options[:duration] ||= 24.hours

      @start_time, @duration = options[:start_time], options[:duration]

      @program = Program.find_by_name program

      raise ProgramNameError, %Q{"#{program}" is not a registered Program} unless @program

      @block = block
    end

    def proxy
      @proxy ||= ProgramScheduleProxy.new( start_time, duration, &@block )
    end

    def start_time=( time )
      @start_time = time

      reset_proxy!

      time
    end

    def duration=( d )
      @duration = d

      reset_proxy!

      d
    end

    def whats_on?( time = Time.now )
      proxy.occurring_at? time
    end

    def occurs_at?( time )
      proxy.occurs_at? time
    end

    def play( &block )
      program.play( &block )
    end

    def update( &block )
      program.update( &block )
    end

    # Returns the scheduled occurrence that matches the specified time
    def occurrence_at( time )
      real_duration = duration - 1

      range = [ time - real_duration, time ]

      start_time = proxy.occurrences_between( range[0], range[1] ).first
      end_time   = start_time + real_duration

      Occurrence.new start_time, real_duration, end_time
    end

    def respond_to_missing?( method_id, include_private = false )
      proxy.respond_to?( method_id ) \
        || program.respond_to?( method_id ) \
        || super
    end

    def method_missing( method_id, *args )
      if program.respond_to?( method_id )
        program.send method_id, *args
      elsif proxy.respond_to?( method_id )
        proxy.send method_id, *args
      else
        super
      end
    end

  private

    def reset_proxy!
      @proxy = nil

      self.proxy
    end

  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
network_executive-0.0.8	lib/network_executive/program_schedule.rb
network_executive-0.0.7	lib/network_executive/program_schedule.rb