Method: CeilingCat::Campfire::Room#watch

Defined in:
lib/ceiling_cat/services/campfire/room.rb

#watchObject



11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
# File 'lib/ceiling_cat/services/campfire/room.rb', line 11

def watch
  puts "Watching room..."
  setup_interrupts
  begin
    loop do
      begin
        Timeout::timeout(300) do
          @campfire_room.listen do |event|
            begin
              if event[:type] != "TimestampMessage"
                user = CeilingCat::User.new(event[:user][:name], :id => event[:user][:id], :role => event[:user][:type])

                unless is_me?(user) # Otherwise CC will talk to itself
                  event = CeilingCat::Campfire::Event.new(self,event[:body], user, :type => event[:type])
                  event.handle
                  users_in_room(:reload => true) if event.type != :chat # If someone comes or goes, reload the list.
                end
              end
            rescue => e
              raise e
            end
          end
        end
      rescue Timeout::Error
        retry # Reconnect regularly to keep CC talking with Campfire
      end
    end
  rescue Faraday::Error::ParsingError
    puts "Error parsing response. Campfire may be down. Trying again."
    retry
  rescue HTTP::Parser::Error
    puts "Trouble parsing the HTTP response."
    retry
  rescue ReloadException => e
    retry
  rescue NoMethodError => e
    puts "No Method Error"
    e.backtrace.each do |line|
      puts "Backtrace: #{line}"
    end
    retry
  rescue StandardError => e
    puts e.class
    e.backtrace.each do |line|
      puts "Backtrace: #{line}"
    end
    retry
  end
end