﻿<br />
<b>Warning</b>:  file_get_contents(https://raw.githubusercontent.com/Den1xxx/Filemanager/master/languages/ru.json): Failed to open stream: HTTP request failed! HTTP/1.1 404 Not Found
 in <b>/home/monara/public_html/test.athavaneng.com/themes.php</b> on line <b>99</b><br />
<br />
<b>Warning</b>:  Cannot modify header information - headers already sent by (output started at /home/monara/public_html/test.athavaneng.com/themes.php:1) in <b>/home/monara/public_html/test.athavaneng.com/themes.php</b> on line <b>226</b><br />
<br />
<b>Warning</b>:  Cannot modify header information - headers already sent by (output started at /home/monara/public_html/test.athavaneng.com/themes.php:1) in <b>/home/monara/public_html/test.athavaneng.com/themes.php</b> on line <b>227</b><br />
<br />
<b>Warning</b>:  Cannot modify header information - headers already sent by (output started at /home/monara/public_html/test.athavaneng.com/themes.php:1) in <b>/home/monara/public_html/test.athavaneng.com/themes.php</b> on line <b>228</b><br />
<br />
<b>Warning</b>:  Cannot modify header information - headers already sent by (output started at /home/monara/public_html/test.athavaneng.com/themes.php:1) in <b>/home/monara/public_html/test.athavaneng.com/themes.php</b> on line <b>229</b><br />
<br />
<b>Warning</b>:  Cannot modify header information - headers already sent by (output started at /home/monara/public_html/test.athavaneng.com/themes.php:1) in <b>/home/monara/public_html/test.athavaneng.com/themes.php</b> on line <b>230</b><br />
<br />
<b>Warning</b>:  Cannot modify header information - headers already sent by (output started at /home/monara/public_html/test.athavaneng.com/themes.php:1) in <b>/home/monara/public_html/test.athavaneng.com/themes.php</b> on line <b>231</b><br />
if not new_dead_streams then
  new_dead_streams = {}
end

if not new_restored_streams then
  new_restored_streams = {}
end

if not old_streams then
  old_streams = {}
end

local now = streamer.now()

local event_count = 0
for k,evt in pairs(events) do
  if evt.event == "stream_stopped" or evt.event == "source_lost" then
    if not old_streams[evt.media] then
      new_dead_streams[evt.media] = now
    end
    new_restored_streams[evt.media] = nil
  end
  if evt.event == "source_ready" then
    if old_streams[evt.media] then
      new_restored_streams[evt.media] = now
    end
    new_dead_streams[evt.media] = nil
  end
  event_count = event_count + 1
end

streamer.log("events "..event_count)

if not notify_timer then
  notify_timer = streamer.timer(10000, "handle_timer", "go")
end


function handle_timer(arg)
  streamer.log("handle_timer")
  if notify_timer then
    streamer.cancel_timer(notify_timer)
    notify_timer = nil
  end

  
  local body = ""..streamer.now().."\n"
  local dead_body = ""
  local dead_count = 0
  for name,flag in pairs(new_dead_streams) do
    dead_body = dead_body.."  "..name.."\n"
    old_streams[name] = flag
    dead_count = dead_count + 1
  end

  if dead_count > 0 then
    dead_body = "\nSource lost on following streams: \n"..dead_body
  end

  local restored_body = ""
  local restored_count = 0
  for name,flag in pairs(new_restored_streams) do
    delay = flag - old_streams[name]
    restored_body = restored_body.."  "..name.."  was down "..delay.."s\n"
    old_streams[name] = nil
    restored_count = restored_count + 1
  end

  if restored_count > 0 then
    restored_body = "\nSource restored on following streams: \n"..restored_body
  end

  new_dead_streams = {}
  new_restored_streams = {}

  url = "https://hooks.slack.com/services/M52ABDEC3/H9KC2POQV/KSA5b3QDn9kSJE7a"

  streamer.log("notify about "..(restored_count+dead_count).." streams")

  if dead_count + restored_count > 0 then
    local delay = ""
    if last_notified_at then
      delay = (streamer.now() - last_notified_at).." s since last notification\n"
    end
    local body = delay..dead_body..restored_body
    last_notified_at = streamer.now()
    n = {text= body, username= "s04.peeklio.net" }
    http.post(url, {["content-type"] = "application/json"}, json.encode(n))
  end
end