Class: TranscodingMachine::Server::TranscodingEventListener

Inherits:
Object
  • Object
show all
Defined in:
lib/transcoding_machine/server/transcoding_event_listener.rb

Instance Method Summary collapse

Constructor Details

#initialize(message_properties) ⇒ TranscodingEventListener

Returns a new instance of TranscodingEventListener.



6
7
8
9
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 6

def initialize(message_properties)
  @message_properties = message_properties
  @result_queue = RightAws::SqsGen2.new.queue(message_properties[:result_queue])
end

Instance Method Details

#analyzed_source_file(source_file_attributes, source_media_format, target_media_formats) ⇒ Object 



23
24
25
26
27
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 23

def analyzed_source_file(source_file_attributes, source_media_format, target_media_formats)
  push_status(:analyzed, :media_format => source_media_format ? source_media_format.id : nil,
                         :media_attributes => source_file_attributes,
                         :target_formats => target_media_formats.map(&:id))
end

#analyzing_source_file ⇒ Object 



19
20
21
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 19

def analyzing_source_file
  push_status(:analyzing)
end

#generated_thumbnail_file ⇒ Object 



33
34
35
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 33

def generated_thumbnail_file
  push_status(:created_thumbnail)
end

#generating_thumbnail_file ⇒ Object 



29
30
31
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 29

def generating_thumbnail_file
  push_status(:creating_thumbnail)
end

#getting_source_file ⇒ Object 



11
12
13
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 11

def getting_source_file
  push_status(:downloading)
end

#got_source_file ⇒ Object 



15
16
17
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 15

def got_source_file

end

#push_status(status, options = {}) ⇒ Object 



53
54
55
56
57
58
59
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 53

def push_status(status, options = {})
  msg = @message_properties.clone
  msg[:status] = status
  msg[:transcoding_machine_version] = TranscodingMachine::VERSION
  msg.merge!(options)
  @result_queue.push(msg.to_yaml)
end

#put_destination_file(file_path, media_format) ⇒ Object 



49
50
51
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 49

def put_destination_file(file_path, media_format)
  push_status(:uploaded, :media_format => media_format.id, :destination_key => file_path)
end

#putting_destination_file(file_path, media_format) ⇒ Object 



45
46
47
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 45

def putting_destination_file(file_path, media_format)
  push_status(:uploading, :media_format => media_format.id, :destination_key => file_path)
end

#transcoded(media_format) ⇒ Object 



41
42
43
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 41

def transcoded(media_format)
  push_status(:transcoded, :media_format => media_format.id)
end

#transcoding(media_format) ⇒ Object 



37
38
39
 
# File 'lib/transcoding_machine/server/transcoding_event_listener.rb', line 37

def transcoding(media_format)
  push_status(:transcoding, :media_format => media_format.id)
end