The turnitin submission endpoint should save originality data

Fires off delayed job that hits the turnitin callback url,
creates a submission, and maps originality data into the turnitin_data
field.

Fixes PLAT-1167
Fixes PLAT-1169

Test Plan:
You'll need to have the TurnItIn LTI tool installed, and delayed_jobs
running

Create an assignment with the submission set to the External Tool for
turnitin.
As a student, submit the assignment.
wait for the delayed job to run. check out /jobs to see whats going on
After the job has ran you should see turnitin data, as you would
normally with the plugin

Change-Id: I5d60d250e91b422b5e77255d715abf2e4712f130
Reviewed-on: https://gerrit.instructure.com/59942
Tested-by: Jenkins
Reviewed-by: Nathan Mills <nathanm@instructure.com>
Product-Review: Nathan Mills <nathanm@instructure.com>
QA-Review: Nathan Mills <nathanm@instructure.com>

Author: Brad Horrocks

app/controllers/submissions_controller.rb

@@ -539,7 +539,11 @@ def turnitin_report
     @submission = @assignment.submissions.where(user_id: params[:submission_id]).first
     @asset_string = params[:asset_string]
     if authorized_action(@submission, @current_user, :read)
-      url = @submission.turnitin_report_url(@asset_string, @current_user) rescue nil
+      if (report_url = @submission.turnitin_data[@asset_string] && @submission.turnitin_data[@asset_string][:report_url])
+        url = polymorphic_url([:retrieve, @context, :external_tools], url:report_url, display:'borderless')
+      else
+        url = @submission.turnitin_report_url(@asset_string, @current_user) rescue nil
+      end
       if url
         redirect_to url
       else

app/models/submission.rb

@@ -301,11 +301,7 @@ def check_turnitin_status(attempt=1)
             data[:web_overlap] = res[:web_overlap].to_f
             data[:publication_overlap] = res[:publication_overlap].to_f
             data[:student_overlap] = res[:student_overlap].to_f
-            data[:state] = 'failure'
-            data[:state] = 'problem' if data[:similarity_score] < 75
-            data[:state] = 'warning' if data[:similarity_score] < 50
-            data[:state] = 'acceptable' if data[:similarity_score] < 25
-            data[:state] = 'none' if data[:similarity_score] == 0
+            data[:state] = Turnitin.state_from_similarity_score data[:similarity_score]
             data[:status] = 'scored'
           else
             needs_retry ||= true

gems/turnitin_api/lib/turnitin_api/outcomes_response_transformer.rb

@@ -31,6 +31,10 @@ def originality_data
       response.body['outcome_originalityreport'].select {|k, _| %w(breakdown numeric).include?(k)}
     end
 
+    def scored?
+      originality_data["numeric"]["score"].present?
+    end
+
     private
 
     def connection

lib/turnitin.rb

@@ -19,6 +19,14 @@
 require 'turnitin/response'
 
 module Turnitin
+  def self.state_from_similarity_score(similarity_score)
+    return 'none' if similarity_score == 0
+    return 'acceptable' if similarity_score < 25
+    return 'warning' if similarity_score < 50
+    return 'problem' if similarity_score < 75
+    'failure'
+  end
+
   class Client
     attr_accessor :endpoint, :account_id, :shared_secret, :host, :testing
 

lib/turnitin/outcome_response_processor.rb

@@ -2,31 +2,73 @@
 module Turnitin
   class OutcomeResponseProcessor
 
+    MAX_ATTEMPTS=11.freeze  # this one goes to 11
+    INTERVAL=5.minutes.freeze
     def initialize(tool, assignment, user, outcomes_response_json)
       @tool = tool
       @assignment = assignment
       @user = user
       @outcomes_response_json = outcomes_response_json
     end
 
-
     def process
       attachment = create_attachment
-      @assignment.submit_homework(@user ,attachments:[attachment], submission_type: 'online_upload')
+      submission = @assignment.submit_homework(@user, attachments:[attachment], submission_type: 'online_upload')
+      self.send_later(:update_originality_data, submission, attachment.asset_string)
     end
     handle_asynchronously :process, max_attempts: 1, priority: Delayed::LOW_PRIORITY
 
-    private
-
-    def create_attachment
-
-      lti_params = {
+    def turnitin_client
+      @turnitin_client ||= (
+        lti_params = {
           'user_id' => Lti::Asset.opaque_identifier_for(@user),
           'context_id' => Lti::Asset.opaque_identifier_for(@assignment.context),
           'context_title' => @assignment.context.name,
           'lis_person_contact_email_primary' => @user.email
-      }
-      turnitin_client = TurnitinApi::OutcomesResponseTransformer.new(@tool.consumer_key, @tool.shared_secret, lti_params, @outcomes_response_json)
+        }
+
+        TurnitinApi::OutcomesResponseTransformer.new(
+          @tool.consumer_key,
+          @tool.shared_secret,
+          lti_params,
+          @outcomes_response_json
+        )
+      )
+    end
+
+    def update_originality_data(submission, asset_string, attempt=1)
+      if turnitin_client.scored?
+        all_data = submission.turnitin_data || {}
+        all_data[asset_string] = turnitin_data
+        submission.update_attribute('turnitin_data', all_data)
+        submission.turnitin_data_changed!
+        submission.save
+      elsif attempt <= MAX_ATTEMPTS
+        send_at(INTERVAL.from_now, :update_originality_data,  submission, asset_string, attempt + 1)
+      end
+    end
+
+
+    # dont try and recreate the turnitin client in a delayed job. bad things happen
+    def send_later(*args)
+      stash { super(*args) }
+    end
+
+    # dont try and recreate the turnitin client in a delayed job. bad things happen
+    def send_at(*args)
+      stash { super(*args) }
+    end
+
+    private
+
+    def stash
+      old_turnit_client = @turnitin_client
+      @turnitin_client = nil
+      yield
+      @turnitin_client = old_turnit_client
+    end
+
+    def create_attachment
       attachment = nil
       Dir.mktmpdir do |dirname|
         turnitin_client.original_submission do |response|
@@ -46,6 +88,16 @@ def create_attachment
       attachment
     end
 
+    def turnitin_data
+      {
+        similarity_score: turnitin_client.originality_data["numeric"]["score"].to_f,
+        web_overlap: turnitin_client.originality_data["breakdown"]["internet_score"].to_f,
+        publication_overlap: turnitin_client.originality_data["breakdown"]["publications_score"].to_f,
+        student_overlap: turnitin_client.originality_data["breakdown"]["submitted_works_score"].to_f,
+        state: Turnitin.state_from_similarity_score(turnitin_client.originality_data["numeric"]["score"].to_f),
+        report_url: turnitin_client.originality_report_url,
+        status: "scored"
+      }
+    end
   end
-
 end