tangent/itchy
1
0
Fork 0
mirror of https://github.com/TangentFoxy/itchy.git synced 2024-11-14 10:14:22 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

updated to use new returned data format

Browse Source
This commit is contained in:
Paul Liverman III 2018-03-25 13:43:34 -07:00
parent d7ced8d1a4
commit ca8bb9b6a9
2 changed files with 84 additions and 44 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

75
check.lua
View File

@ -8,40 +8,62 @@ local http = require("socket.http")
local receive = thread.getChannel("send-itchy")
local send = thread.getChannel("receive-itchy")
local check
check = function(data, send_errors)
if send_errors == nil then
send_errors = true
end
check = function(data)
local exponential_backoff = 1
while true do
local body, status
if data.url then
body, status = http.request(data.url)
elseif data.proxy then
body, status = http.request(tostring(data.proxy) .. "/get/https://itch.io/api/1/x/wharf/latest?target=" .. tostring(data.target) .. "&channel_name=" .. tostring(data.channel))
end
if status == 200 then
local latest = body:match('%s*{%s*"latest"%s*:%s*"(.+)"%s*}%s*')
send:push(latest)
return true
else
if send_errors then
send:push("unknown, error getting latest version: HTTP " .. tostring(status) .. ", trying again in " .. tostring(exponential_backoff) .. " seconds")
local _continue_0 = false
repeat
do
local result = { }
if data.url then
result.body, result.status = http.request(data.url)
elseif data.proxy then
if not (data.target) then
result.message = "'target' or 'url' must be defined!"
send:push(result)
return false
end
result.body, result.status = http.request(tostring(data.proxy) .. "/get/https://itch.io/api/1/x/wharf/latest?target=" .. tostring(data.target) .. "&channel_name=" .. tostring(data.channel))
end
if not (result.body) then
result.message = "socket.http.request error: " .. tostring(status)
send:push(result)
return false
end
result.version = result.body:match('%s*{%s*"latest"%s*:%s*"(.+)"%s*}%s*')
result.version = tonumber(result.version) or result.version
if data.version then
result.latest = result.version == data.version
end
if status ~= 200 and (not version) then
result.message = "unknown, error getting latest version: HTTP " .. tostring(status) .. ", trying again in " .. tostring(exponential_backoff) .. " seconds"
send:push(result)
timer.sleep(exponential_backoff)
exponential_backoff = exponential_backoff * 2
_continue_0 = true
break
elseif latest ~= nil then
if latest then
result.message = tostring(result.version) .. ", you have the latest version"
else
result.message = tostring(result.version) .. ", there is a newer version available!"
end
else
result.message = result.version
end
send:push(result)
return true
end
timer.sleep(exponential_backoff)
exponential_backoff = exponential_backoff * 2
_continue_0 = true
until true
if not _continue_0 then
break
end
end
end
local start
start = function()
local data = receive:demand()
if not (data.target) then
error("Target undefined. Cannot search for latest version of unknown target!")
end
if not (data.version) then
data.version = "0"
end
if not (data.proxy or data.url) then
data.proxy = "http://104.236.139.220:16343"
end
@ -69,8 +91,9 @@ start = function()
timer.sleep(data.interval)
if receive:getCount() > 0 then
return start()
else
check(data)
end
check(data, data.send_interval_errors)
end
end
end

53
check.moon
View File

@ -5,32 +5,49 @@ http = require "socket.http"
receive = thread.getChannel "send-itchy"
send = thread.getChannel "receive-itchy"
check = (data, send_errors=true) ->
check = (data) ->
exponential_backoff = 1
while true
local body, status
result = {}
if data.url
body, status = http.request data.url
result.body, result.status = http.request data.url
elseif data.proxy
body, status = http.request "#{data.proxy}/get/https://itch.io/api/1/x/wharf/latest?target=#{data.target}&channel_name=#{data.channel}"
unless data.target
result.message = "'target' or 'url' must be defined!"
send\push result
return false
result.body, result.status = http.request "#{data.proxy}/get/https://itch.io/api/1/x/wharf/latest?target=#{data.target}&channel_name=#{data.channel}"
if status == 200
latest = body\match '%s*{%s*"latest"%s*:%s*"(.+)"%s*}%s*'
send\push latest
return true
else
if send_errors
send\push "unknown, error getting latest version: HTTP #{status}, trying again in #{exponential_backoff} seconds"
unless result.body
result.message = "socket.http.request error: #{status}"
send\push result
return false
result.version = result.body\match '%s*{%s*"latest"%s*:%s*"(.+)"%s*}%s*'
result.version = tonumber(result.version) or result.version
result.latest = if data.version
result.version == data.version
if status != 200 and (not version)
result.message = "unknown, error getting latest version: HTTP #{status}, trying again in #{exponential_backoff} seconds"
send\push result
timer.sleep exponential_backoff
exponential_backoff = exponential_backoff * 2
exponential_backoff *= 2
continue
elseif latest != nil
if latest
result.message = "#{result.version}, you have the latest version"
else
result.message = "#{result.version}, there is a newer version available!"
else
result.message = result.version
send\push result
return true
start = ->
-- data should be a table of information
data = receive\demand!
unless data.target
error "Target undefined. Cannot search for latest version of unknown target!"
data.version = "0" unless data.version
data.proxy = "http://104.236.139.220:16343" unless data.proxy or data.url
-- channel can be autodetected if not specified
@ -61,7 +78,7 @@ start = ->
-- if we are sent new data, start over entirely
if receive\getCount! > 0
return start!
check data, data.send_interval_errors
else
check data
start!