Create a Vacate appeal stream for a Motion to Vacate

app/models/appeal.rb

@@ -26,9 +26,9 @@ class Appeal < DecisionReview
   has_many :record_synced_by_job, as: :record
 
   enum stream_type: {
-    "Original": "Original",
-    "Vacate": "Vacate",
-    "De Novo": "De Novo"
+    "original": "original",
+    "vacate": "vacate",
+    "de_novo": "de_novo"
   }
 
   before_save :set_stream_docket_number_and_stream_type
@@ -81,7 +81,20 @@ def ui_hash
   end
 
   def type
-    stream_type || "Original"
+    stream_type&.titlecase || "Original"
+  end
+
+  def create_stream(stream_type)
+    ActiveRecord::Base.transaction do
+      Appeal.create!(slice(
+        :receipt_date,
+        :veteran_file_number,
+        :legacy_opt_in_approved,
+        :veteran_is_not_claimant
+      ).merge(stream_type: stream_type, stream_docket_number: docket_number)).tap do |stream|
+        stream.create_claimant!(participant_id: claimant.participant_id, payee_code: claimant.payee_code)
+      end
+    end
   end
 
   # Returns the most directly responsible party for an appeal when it is at the Board,
@@ -434,7 +447,7 @@ def set_stream_docket_number_and_stream_type
     if receipt_date && persisted?
       self.stream_docket_number ||= docket_number
     end
-    self.stream_type ||= type
+    self.stream_type ||= type.parameterize.underscore.to_sym
   end
 
   def maybe_create_translation_task

app/models/decision_issue.rb

@@ -246,7 +246,7 @@ def create_remand_supplemental_claim!
     )
     fail AppealDTAPayeeCodeError, decision_review.id unless dta_payee_code
 
-    sc.create_claimants!(
+    sc.create_claimant!(
       participant_id: decision_review.claimant_participant_id,
       payee_code: dta_payee_code
     )

app/models/decision_review.rb

@@ -138,7 +138,7 @@ def start_review!
   end
 
   # Creates claimants for automatically generated decision reviews
-  def create_claimants!(participant_id:, payee_code:)
+  def create_claimant!(participant_id:, payee_code:)
     remove_claimants!
     claimants.create_without_intake!(participant_id: participant_id, payee_code: payee_code)
   end

app/models/tasks/judge_task.rb

@@ -7,7 +7,6 @@
 # - JudgeDispatchReturnTasks
 # - JudgeAssignTasks
 # - JudgeAddressMotionToVacateTasks
-# - JudgeSignMotionToVacateTasks
 
 class JudgeTask < Task
   def available_actions(user)

app/workflows/initial_tasks_factory.rb

@@ -9,7 +9,7 @@ def initialize(appeal)
   def create_root_and_sub_tasks!
     create_vso_tracking_tasks
     ActiveRecord::Base.transaction do
-      create_subtasks!
+      create_subtasks! if @appeal.original?
     end
   end
 

app/workflows/post_decision_motion_updater.rb

@@ -1,26 +1,42 @@
 # frozen_string_literal: true
 
+##
+# The PostDecisionMotionUpdater validates and creates a PostDecisionMotion from the JudgeAddressMotionToVacateTask,
+# and creates the subsequent tasks or appeal streams.
+
 class PostDecisionMotionUpdater
   include ActiveModel::Model
 
-  attr_reader :task, :params
+  attr_reader :task, :params, :disposition, :instructions
 
   def initialize(task, params)
     @task = task
     @params = params
+    @disposition = @params[:disposition]
+    @instructions = @params[:instructions]
   end
 
+  delegate :appeal, to: :task
+
   def process
     ActiveRecord::Base.transaction do
-      motion = create_motion
-      return unless motion
+      return unless post_decision_motion
+
+      handle_denial_or_dismissal
+      handle_grant
 
-      create_new_tasks
+      return if errors.messages.any?
+
+      task.update(status: Constants.TASK_STATUSES.completed)
     end
   end
 
   private
 
+  def post_decision_motion
+    @post_decision_motion ||= create_motion
+  end
+
   def create_motion
     motion = PostDecisionMotion.new(
       task: task,
@@ -32,7 +48,7 @@ def create_motion
       motion.vacated_decision_issue_ids = params[:vacated_decision_issue_ids]
     elsif disposition == "granted"
       # For full grant, auto populate all decision issue IDs
-      motion.vacated_decision_issue_ids = task.appeal.decision_issues.map(&:id)
+      motion.vacated_decision_issue_ids = appeal.decision_issues.map(&:id)
     end
 
     unless motion.valid?
@@ -43,96 +59,97 @@ def create_motion
     motion.save
   end
 
-  def create_new_tasks
-    # We create an AbstractMotionToVacateTask as sibling to the judge task
-    # to serve as parent for all successive tasks. It is created when associated with
-    # the new task in order to pass responsibility for validation to child task
+  # We create an AbstractMotionToVacateTask as sibling to the JudgeAddressMotionToVacateTask
+  # to serve as parent for successive Denied or Dismissed tasks. It is created when associated with
+  # the new task in order to pass responsibility for validation to child task
+  def handle_denial_or_dismissal
+    return unless denied_or_dismissed?
 
     abstract_task = create_abstract_task
     unless abstract_task.valid?
       errors.messages.merge!(abstract_task.errors.messages)
       return
     end
 
-    if grant_type?
-      judge_sign_task = create_judge_sign_task(abstract_task)
-    end
-
-    new_task = create_new_task((judge_sign_task || abstract_task))
+    new_task = create_new_task(abstract_task)
 
     unless new_task.valid?
       errors.messages.merge!(new_task.errors.messages)
       return
     end
     new_task.save
+  end
+
+  def handle_grant
+    return unless grant_type?
 
-    task.update(status: Constants.TASK_STATUSES.completed)
+    vacate_stream = appeal.create_stream(:vacate)
+    create_new_stream_tasks(vacate_stream)
   end
 
   def create_abstract_task
     AbstractMotionToVacateTask.new(
-      appeal: task.appeal,
+      appeal: appeal,
       parent: task.parent,
-      assigned_to: task.assigned_to
+      assigned_to: judge_user
     )
   end
 
   def create_new_task(parent)
     task_class.new(
-      appeal: task.appeal,
+      appeal: appeal,
       parent: parent,
-      assigned_by: task.assigned_to,
-      assigned_to: assigned_to,
-      instructions: [params[:instructions]]
+      assigned_by: judge_user,
+      assigned_to: attorney_user,
+      instructions: [instructions]
     )
   end
 
-  def create_judge_sign_task(parent)
-    JudgeSignMotionToVacateTask.new(
-      appeal: task.appeal,
-      parent: parent,
-      assigned_to: task.assigned_to
+  def create_new_stream_tasks(stream)
+    InitialTasksFactory.new(stream).create_root_and_sub_tasks!
+
+    jdrt = JudgeDecisionReviewTask.create!(appeal: stream, parent: stream.root_task, assigned_to: judge_user)
+    attorney_task = AttorneyTask.new(
+      appeal: stream, parent: jdrt, assigned_by: judge_user, assigned_to: attorney_user, instructions: [instructions]
     )
-  end
 
-  def disposition
-    case params[:disposition]
-    when "partial"
-      "partially_granted"
-    else
-      params[:disposition]
+    unless attorney_task.valid?
+      errors.messages.merge!(attorney_task.errors.messages)
+      return
     end
+
+    attorney_task.save
   end
 
   def task_class
     @task_class ||= (task_type + "_task").classify.constantize
   end
 
   def task_type
-    grant_type? ? params[:vacate_type] : "#{params[:disposition]}_motion_to_vacate"
+    "#{disposition}_motion_to_vacate"
   end
 
   def grant_type?
-    %w[granted partial].include? params[:disposition]
+    %w[granted partially_granted].include? disposition
   end
 
   def denied_or_dismissed?
     %w[denied dismissed].include? disposition
   end
 
-  def assigned_to
-    @assigned_to ||= (denied_or_dismissed? ? prev_motions_attorney : User.find_by(id: params[:assigned_to_id]))
+  def judge_user
+    task.assigned_to
+  end
+
+  def attorney_user
+    @attorney_user ||= denied_or_dismissed? ? prev_motions_attorney : User.find_by(id: params[:assigned_to_id])
   end
 
   def prev_motions_attorney
-    mtv_mail_task.assigned_to
+    task.parent.assigned_to
   end
 
   def prev_motions_attorney_or_org
     prev_motions_attorney.inactive? ? LitigationSupport.singleton : prev_motions_attorney
   end
-
-  def mtv_mail_task
-    task.parent
-  end
 end

client/app/queue/mtv/MTVJudgeDisposition.jsx

@@ -39,7 +39,7 @@ const formatInstructions = ({ disposition, vacateType, hyperlink, instructions }
 
   switch (disposition) {
   case 'granted':
-  case 'partial':
+  case 'partially_granted':
     parts.push(`This will be a ${vacateTypeText(vacateType)}`);
     parts.push(instructions);
     break;
@@ -53,7 +53,7 @@ const formatInstructions = ({ disposition, vacateType, hyperlink, instructions }
   return parts.join('\n');
 };
 
-const grantTypes = ['granted', 'partial'];
+const grantTypes = ['granted', 'partially_granted'];
 
 const dispositionStrings = {
   denied: 'denial',
@@ -113,7 +113,7 @@ export const MTVJudgeDisposition = ({
       !disposition ||
       !instructions ||
       (isGrantType() && !vacateType) ||
-      (disposition === 'partial' && !issueIds.length) ||
+      (disposition === 'partially_granted' && !issueIds.length) ||
       (disposition === 'dismissed' && !hyperlink)
     );
   };
@@ -140,7 +140,7 @@ export const MTVJudgeDisposition = ({
           value={disposition}
         />
 
-        {disposition && disposition === 'partial' && (
+        {disposition && disposition === 'partially_granted' && (
           <MTVIssueSelection
             issues={appeal.decisionIssues}
             onChange={({ issueIds: newIssueIds }) => setIssueIds(newIssueIds)}

client/constants/MOTION_TO_VACATE.json

@@ -30,12 +30,12 @@
   ],
   "PARTIAL_GRANT_OPTION": {
     "displayText": "Grant partial vacatur",
-    "value": "partial",
+    "value": "partially_granted",
     "help": "e.g. if you do not want to vacate all the issues the veteran is requesting"
   },
   "DISPOSITION_TEXT": {
     "granted": "grant or partial vacatur",
-    "partial": "partial vacatur",
+    "partially_granted": "partial vacatur",
     "denied": "denial of all issues for vacatur",
     "dismissed": "dismissal"
   }