1
2
3
4
5
6
7
8
9
10
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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
module OpenTox
class Application < Service
helpers do
def status_code uri
sparql = "SELECT DISTINCT ?o WHERE { GRAPH <#{uri}> { <#{uri}> <#{RDF::OT.hasStatus}> ?o. } }"
status = Backend::FourStore.query(sparql,"text/uri-list")#.strip.to_s
case status
when "Completed"
200
when "Running"
202
when "Cancelled"
503
when "Error"
sparql = "SELECT ?code WHERE { GRAPH <#{uri}> { <#{uri}> <#{RDF::OT.error}> ?error. ?error <#{RDF::OT.statusCode}> ?code } }"
code = Backend::FourStore.query(sparql,"text/uri-list")
code != "" ? code.to_i : 500
else
500
end
end
end
head "/task/?" do
end
head '/task/:id/?' do
halt 404 unless FourStore.head(@uri.split('?').first)
end
get '/task/:id/?' do
uri = uri("/task/#{params[:id]}")
code = status_code(uri)
if @accept == "text/uri-list" # return resultURI
halt code, uri unless code == 200
sparql = "SELECT ?o WHERE { GRAPH <#{uri}> { <#{uri}> <#{RDF::OT.resultURI}> ?o. } }"
result_uri = Backend::FourStore.query(sparql,"text/uri-list").gsub(/"|'/,'').gsub(/\^\^.*$/,'')
halt code, result_uri
else
rdf = FourStore.get(uri, @accept)
halt code, rdf
end
end
put '/task/:id/:status/?' do
uri = uri("/task/#{params[:id]}")
sparql = []
case params[:status]
when "Completed"
bad_request_error "No resultURI parameter recieved. Cannot complete task '#{uri}' without resultURI." unless params[:resultURI]
sparql << "DELETE DATA { GRAPH <#{uri}> {<#{uri}> <#{RDF::OT.hasStatus}> \"Running\"}}"
sparql << "INSERT DATA { GRAPH <#{uri}> {<#{uri}> <#{RDF::OT.hasStatus}> \"Completed\"}}"
sparql << "INSERT DATA { GRAPH <#{uri}> {<#{uri}> <#{RDF::OT.resultURI}> <#{params[:resultURI]}>}}"
sparql << "INSERT DATA { GRAPH <#{uri}> {<#{uri}> <#{RDF::OT.percentageCompleted}> \"100.0\"}}"
sparql << "INSERT DATA { GRAPH <#{uri}> {<#{uri}> <#{RDF::OT.finished_at}> \"#{DateTime.now}\"}}"
when "Running"
sparql << "INSERT DATA { GRAPH <#{uri}> {<#{uri}> <#{RDF::OT.percentageCompleted}> \"#{params["percentageCompleted"].to_f}\"^^#{RDF::XSD.float}}" if params["percentageCompleted"]
#task.waiting_for = params[:waiting_for] if params.has_key?("waiting_for")
when "Cancelled"
sparql << "DELETE DATA { GRAPH <#{uri}> {<#{uri}> <#{RDF::OT.hasStatus}> \"Running\"}}"
sparql << "INSERT DATA { GRAPH <#{uri}> {<#{uri}> <#{RDF::OT.hasStatus}> \"Cancelled\"}}"
sparql << "INSERT DATA { GRAPH <#{uri}> {<#{uri}> <#{RDF::OT.finished_at}> \"#{DateTime.now}\"}}"
when "Error"
sparql << "DELETE DATA { GRAPH <#{uri}> {<#{uri}> <#{RDF::OT.hasStatus}> \"Running\"}}"
sparql << "INSERT DATA { GRAPH <#{uri}> {<#{uri}> <#{RDF::OT.hasStatus}> \"Error\"}}"
sparql << "INSERT DATA { GRAPH <#{uri}> {<#{uri}> <#{RDF::OT.finished_at}> \"#{DateTime.now}\"}}"
if params[:errorReport]
id = params[:errorReport].split("\n").first.sub(/^(_:\w+) .*/,'\1')
params[:errorReport] += "\n<#{uri}> <#{RDF::OT.error}> #{id} ."
Backend::FourStore.post uri, params[:errorReport], "text/plain"
end
#if task.waiting_for and task.waiting_for.uri?
# try cancelling the child task
else
bad_request_error "Invalid status value: '"+params[:status].to_s+"'"
end
sparql.each{|q| Backend::FourStore.update q}
end
delete '/task/:id/?' do
uri = uri("/task/#{params[:id]}")
sparql = "SELECT ?o WHERE { GRAPH <#{uri}> { <#{uri}> <#{RDF::OT.created_at}> ?o. } }"
created_at = Backend::FourStore.query(sparql,"text/uri-list").gsub(/"|'/,'').gsub(/\^\^.*$/,'')
created = DateTime.parse(created_at)
today = DateTime.now
daysback = (today - 30)
(created <= daysback) ? (result = Backend::FourStore.delete uri) : (bad_request_error "Not allowed.")
# prevent backend type and version displayed
result.split("\n").first
end
end
end
|
