You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
48 lines
1007 B
Ruby
48 lines
1007 B
Ruby
class AsciicastStreamer
|
|
|
|
delegate :each, :to => :json_streamer
|
|
|
|
def initialize(asciicast)
|
|
build_json_streamer(asciicast)
|
|
end
|
|
|
|
private
|
|
|
|
attr_reader :json_streamer
|
|
|
|
def build_json_streamer(asciicast)
|
|
attributes = attributes_for_streaming(asciicast)
|
|
@json_streamer = JsonStreamer.new(attributes)
|
|
end
|
|
|
|
def attributes_for_streaming(asciicast)
|
|
attributes = AsciicastSerializer.new(asciicast).as_json
|
|
|
|
duration = attributes.delete('duration')
|
|
|
|
saved_time = 0
|
|
|
|
attributes['stdout'] = lambda do |&blk|
|
|
blk.call('[')
|
|
|
|
asciicast.stdout.each do |delay, frame_bytes|
|
|
if asciicast.time_compression && delay > Asciicast::MAX_DELAY
|
|
saved_time += (delay - Asciicast::MAX_DELAY)
|
|
delay = Asciicast::MAX_DELAY
|
|
end
|
|
|
|
blk.call(%([#{delay},#{frame_bytes.bytes.to_a}],))
|
|
end
|
|
|
|
blk.call('[]]')
|
|
end
|
|
|
|
attributes['duration'] = lambda do |&blk|
|
|
blk.call(duration - saved_time)
|
|
end
|
|
|
|
attributes
|
|
end
|
|
|
|
end
|