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
|
class JobEvent
def initialize
@ecs=HttpEcs.instance
end
##
# Process a *sys/events* job event.
# This is the entrypoint of job event processing.
def process(jobevbody)
Rails.logger.info "***** JobEvent#process: eventbody=#{jobevbody}"
case jobevbody[0]['status']
when "created","updated"
jobr= @ecs.connection[jobevbody[0]['ressource']].delete
job_headers= jobr.headers
job=JSON.parse(jobr)
exercise = JSON.parse fetch_exercise(job)
evaluation = JSON.parse fetch_evaluation(job)
solution = JSON.parse fetch_solution(job)
exercise,solution = merge(exercise, evaluation, solution, job, job_headers)
computation_backend = job["EvaluationJob"]["target"]["mid"]
compute(exercise, solution, computation_backend)
end
end
private
##
# Fetch an exercise from ECS.
def fetch_exercise(job)
# URI#path returns the path with leading "/"
path= URI(job["EvaluationJob"]["resources"]["exercise"]).path[1..-1]
exercise= @ecs.connection[path].get # FIXME change to delete
Rails.logger.info "***** JobEvent#fetch_exercise: #{path} = #{exercise}"
exercise
end
##
# Fetch an evaluation from ECS.
def fetch_evaluation(job)
# URI#path returns the path with leading "/"
path= URI(job["EvaluationJob"]["resources"]["evaluation"]).path[1..-1]
evaluation= @ecs.connection[path].get # FIXME change to delete
Rails.logger.info "***** JobEvent#fetch_evaluation: #{path} = #{evaluation}"
evaluation
end
##
# Fetch a solution from ECS.
def fetch_solution(job)
# URI#path returns the path with leading "/"
path= URI(job["EvaluationJob"]["resources"]["solution"]).path[1..-1]
solution= @ecs.connection[path].get # FIXME change to delete
Rails.logger.info "***** JobEvent#fetch_solution: #{path} = #{solution}"
solution
end
##
# Substitute evaluation code snippets with appropriate exercise code
# snippets.
def merge(exercise, evaluation, solution, job, job_headers)
jobid= job["EvaluationJob"]["identifier"]
job_sender= job_headers[:x_ecssender]
evaluation["Evaluation"]["elements"].each do |ev|
exercise["Exercise"]["elements"].map! do |ex|
if ex["identifier"] == ev["identifier"]
ex=ev
else
ex
end
end
end
solution["Solution"]["evaluationService"]= { :jobID => jobid, :jobSender => job_sender }
Rails.logger.info "***** JobEvent#merge exercise: #{exercise.to_json}"
Rails.logger.info "***** JobEvent#merge solution: #{solution.to_json}"
return exercise, solution
end
##
# Calls the computation backend with membership_id *mid*.
def compute(exercise, solution, mid)
response= @ecs.connection[APP_CONFIG["resources"]["exercises"]["name"]].post exercise.to_json, {"X-EcsReceiverMemberships" => mid}
solution["Solution"]["exercise"]= response.headers[:location]
Rails.logger.info "***** JobEvent#compute substitute exersice URL in solution to: #{solution["Solution"]["exercise"]}"
@ecs.connection[APP_CONFIG["resources"]["solutions"]["name"]].post solution.to_json, {"X-EcsReceiverMemberships" => mid} do |response, request, result|
Rails.logger.info "***** JobEvent#compute solution post response: #{response.headers}"
end
end
end
|
