# File app/models/stream_flow.rb, line 32
32:   def self.programmed
33:     Event.current.with_streaming.map {|evt| evt.stream_flow}.compact.uniq
34:   end

     # File app/models/stream_flow.rb, line 107
107:   def announced?(subsite)
108:     self.send("announced_in_#{subsite}?") 
109:   end

    # File app/models/stream_flow.rb, line 74
74:   def assign_event!
75:     if self.event.nil? 
76:       if !self.on_web?
77:         evt = self.default_event
78:         self.update_attribute(:event_id, evt.id) if evt
79:       end
80:     else
81:       unless self.event.starts_at.to_date.eql?(Date.today)
82:         self.event = nil
83:         self.save
84:       end
85:     end
86:     self.event
87:   end

    # File app/models/stream_flow.rb, line 50
50:   def day_events
51:     Event.published.with_streaming.find(:all, 
52:                 :conditions => [ "(stream_flow_id = :flow_id) AND (starts_at <= :end) AND (ends_at >= :beginning)", 
53:                                {
54:                                  :flow_id => self.id,
55:                                  :beginning => Time.zone.now.at_beginning_of_day,
56:                                  :end => Time.zone.now.end_of_day
57:                                 }],
58:                 :order => 'starts_at')
59:   end

    # File app/models/stream_flow.rb, line 67
67:   def default_event
68:     self.next_event || self.day_events.first
69:   end

     # File app/models/stream_flow.rb, line 168
168:   def delete_photo=(value)
169:     self.photo = nil if value.to_i == 1
170:   end

     # File app/models/stream_flow.rb, line 186
186:   def event_info_file_name(subsite)
187:     "streamed_event#{self.id}_#{subsite}.txt"
188:   end

     # File app/models/stream_flow.rb, line 190
190:   def event_info_file_path(subsite)
191:     File.join(RAILS_ROOT, '/public/streaming_status', self.event_info_file_name(subsite))
192:   end

     # File app/models/stream_flow.rb, line 194
194:   def event_info_file_url(subsite)
195:     "/streaming_status/#{self.event_info_file_name(subsite)}"
196:   end

    # File app/models/stream_flow.rb, line 37
37:   def events_to_be_emitted(time_interval)
38:     evt = Event.published.with_streaming.find(:all, 
39:                 :conditions => [ "(stream_flow_id = :flow_id) AND (starts_at <= :time_int) AND (ends_at >= :now)", 
40:                                {
41:                                  :flow_id => self.id,
42:                                  :time_int => Time.zone.now + time_interval.minutes,
43:                                  :now => Time.zone.now
44:                                 }],
45:                 :order => 'starts_at')
46:     evt
47:   end

     # File app/models/stream_flow.rb, line 162
162:   def has_photo?
163:     self.photo_file_name.present?
164:   end

    # File app/models/stream_flow.rb, line 62
62:   def next_event
63:     self.events_to_be_emitted(60).to_a.first
64:   end

     # File app/models/stream_flow.rb, line 102
102:   def on_air?(subsite)
103:     self.send("show_in_#{subsite}?") 
104:   end

    # File app/models/stream_flow.rb, line 97
97:   def on_web?
98:     self.show_in_irekia? || self.show_in_agencia? || self.announced_in_irekia? || self.announced_in_agencia?
99:   end

     # File app/models/stream_flow.rb, line 157
157:   def photo_path
158:     self.has_photo? ?  self.photo.url(:n320) : "/video/streaming.gif"
159:   end

     # File app/models/stream_flow.rb, line 120
120:   def pretty_dates(locale = I18n.locale)
121:     self.event.present? ? self.event.pretty_dates : "#{I18n.localize(self.updated_at.to_date, :format => :long, :locale => locale)}, #{self.updated_at.strftime('%H:%M')}"
122:   end

     # File app/models/stream_flow.rb, line 124
124:   def start_announcing(where)
125:     if [:irekia, :agencia].include?(where)
126:       self.update_attribute("announced_in_#{where}".to_sym, true)
127:     else
128:       return false
129:     end
130:   end

     # File app/models/stream_flow.rb, line 140
140:   def start_streaming(where)
141:     if [:irekia, :agencia].include?(where)
142:       self.update_attribute("show_in_#{where}".to_sym, true)
143:     else
144:       return false
145:     end
146:   end

     # File app/models/stream_flow.rb, line 173
173:   def status_file_name(subsite)
174:     "streaming#{self.id}_#{subsite}.txt"
175:   end

     # File app/models/stream_flow.rb, line 177
177:   def status_file_path(subsite)
178:     File.join(RAILS_ROOT, '/public/streaming_status', self.status_file_name(subsite))
179:   end

     # File app/models/stream_flow.rb, line 181
181:   def status_file_url(subsite)
182:     "/streaming_status/#{self.status_file_name(subsite)}"
183:   end

     # File app/models/stream_flow.rb, line 132
132:   def stop_announcing(where)
133:     if [:irekia, :agencia].include?(where)
134:       self.update_attribute("announced_in_#{where}".to_sym, false)
135:     else
136:       return false
137:     end
138:   end

     # File app/models/stream_flow.rb, line 148
148:   def stop_streaming(where)
149:     if [:irekia, :agencia].include?(where)
150:       self.update_attribute("show_in_#{where}".to_sym, false)
151:     else
152:       return false
153:     end
154:   end

     # File app/models/stream_flow.rb, line 112
112:   def streaming_status(subsite)
113:     status = 'finished'
114:     status = 'announced' if self.announced?(subsite)
115:     status = 'live' if self.on_air?(subsite)
116:     status
117:   end

    # File app/models/stream_flow.rb, line 92
92:   def to_be_shown?(time_interval=60)
93:     !self.events_to_be_emitted(time_interval).blank?
94:   end