Contents

module JCukeForker
  class RecordingVncListener < AbstractListener

    attr_reader :output

    def initialize(worker, opts = {})
      @ext      = opts['ext'] || "webm"
      @options  = opts
      @worker = worker

      @recorder = nil
    end

    def on_task_starting(worker_path, feature)

      @recorder = recorder_for(feature)
      @recorder.start
    end

    def on_task_finished(worker, feature, status)
      if @recorder.crashed?
        raise 'ffmpeg failed'
      end

      if status
        FileUtils.rm_rf output
      end

      @recorder.stop

      @recorder = nil
    end

    def on_worker_dead(worker_path)
      @recorder && @recorder.stop
    end

    private

    def recorder_for(feature)
      @output  = File.join(@worker.out, "#{feature.gsub(/\W/, '_')}.#{@ext}")

      process = ChildProcess.build(
        'ffmpeg',
        '-an',
        '-y',
        '-f', 'x11grab',
        '-r', @options['frame_rate'] || '5',
        '-s', @options['frame_size'] || '1024x768',
        '-i', ENV['DISPLAY'],
        '-vcodec', @options['codec'] || 'vp8',
        @output
      )
      process.io.stdout = process.io.stderr = File.open('/dev/null', 'w')
      process
    end

  end # RecordingVncListener
end # CukeForker

Version data entries

10 entries across 10 versions & 1 rubygems

Version	Path
jcukeforker-0.4.0	lib/jcukeforker/recording_vnc_listener.rb
jcukeforker-0.3.1	lib/jcukeforker/recording_vnc_listener.rb
jcukeforker-0.2.10	lib/jcukeforker/recording_vnc_listener.rb
jcukeforker-0.2.9	lib/jcukeforker/recording_vnc_listener.rb
jcukeforker-0.2.8	lib/jcukeforker/recording_vnc_listener.rb
jcukeforker-0.2.7	lib/jcukeforker/recording_vnc_listener.rb
jcukeforker-0.2.6	lib/jcukeforker/recording_vnc_listener.rb
jcukeforker-0.2.5	lib/jcukeforker/recording_vnc_listener.rb
jcukeforker-0.2.4	lib/jcukeforker/recording_vnc_listener.rb
jcukeforker-0.2.3	lib/jcukeforker/recording_vnc_listener.rb