Move dummy classes out of Flex module (#32)

- Move classes in dummy application out of Flex module
- Namespace "application submitted" event to name of ApplicationForm
subclass. In other words, publish "<classname>ApplicationSubmitted"
instead of the "application submitted" string

Author: lorenyu

template/{{app_name}}/engines/flex/app/helpers/flex/event_manager.rb

@@ -16,6 +16,7 @@ def self.unsubscribe(subscription)
     end
 
     def self.publish(event_key, payload = {})
+      puts "Event Manager: Publishing event '#{event_key}' with payload: #{payload.inspect}"
       ActiveSupport::Notifications.instrument(event_key, payload)
     end
 

template/{{app_name}}/engines/flex/app/models/flex/application_form.rb

@@ -9,6 +9,7 @@ class ApplicationForm < ApplicationRecord
     before_update :prevent_changes_if_submitted, if: :was_submitted?
 
     def submit_application
+      puts "Submitting application with ID: #{id}"
       self[:status] = :submitted
       save!
       publish_event
@@ -32,7 +33,8 @@ def prevent_changes_if_submitted
     end
 
     def publish_event
-      EventManager.publish("application_submitted", self.event_payload)
+      puts "Publishing event #{self.class.name}Submitted for application with ID: #{id}"
+      EventManager.publish("#{self.class.name}Submitted", self.event_payload)
     end
   end
 end

template/{{app_name}}/engines/flex/spec/dummy/app/business_processes/flex/passport_application_business_process_manager.rb

@@ -0,0 +1,69 @@
+class PassportApplicationBusinessProcessManager
+  include Singleton
+
+  attr_reader :business_process
+
+  private
+
+  def initialize
+    @business_process = create_passport_application_business_process
+  end
+
+  def create_passport_application_business_process
+    business_process = Flex::BusinessProcess.new(
+      name: 'Passport Application Process',
+      find_case_callback: ->(case_id) { PassportCase.find(case_id) },
+      description: 'Process for applying for a passport'
+    )
+    business_process.define_steps(
+      {
+        "collect_application_info" => Flex::UserTask.new(
+          "Collect App Info",
+          UserTaskCreationService
+        ),
+        "verify_identity" => Flex::SystemProcess.new("Verify Identity", ->(kase) {
+          IdentityVerificationService.new(kase).verify_identity # IdentityVerificationService would publish an event when verify_identity completes
+        }),
+        "manual_adjudicator_review" => Flex::UserTask.new("Manual Adjudicator Review", AdjudicatorTaskCreationService), # create an adjudicator task for manual review
+        "review_passport_photo" => Flex::SystemProcess.new("Review Passport Photo", ->(kase) {
+          PhotoVerificationService.new(kase).verify_photo # PhotoVerificationService would publish an event when verify_photo completes
+        }),
+        "notify_user_passport_approved" => Flex::SystemProcess.new("Notify Passport Approval", ->(kase) {
+          UserNotificationService.new(kase).send_notification("approval") # UserNotificationService would publish an event when send_notification completes
+        }),
+        "notify_user_passport_rejected" => Flex::SystemProcess.new("Notify Passport Rejection", ->(kase) {
+          UserNotificationService.new(kase).send_notification("rejection") # UserNotificationService would publish an event when send_notification completes
+        })
+      }
+    )
+    business_process.define_transitions(
+      {
+        "collect_application_info" => {
+          "PassportApplicationFormSubmitted" => 'verify_identity',
+          "application_cancelled" => 'end'
+        },
+        "verify_identity" => {
+          "identity_verified" => 'review_passport_photo',
+          "identity_warning" => 'manual_adjudicator_review'
+        },
+        "manual_adjudicator_review" => {
+          "identity_verified" => 'review_passport_photo',
+          "identity_rejected" => 'application_rejected'
+        },
+        "review_passport_photo" => {
+          "passport_photo_approved" => 'notify_user_passport_approved',
+          "passport_photo_rejected" => 'review_passport_photo'
+        },
+        "notify_user_passport_approved" => {
+          "notification_completed" => "end"
+        },
+        "notify_user_passport_rejected" => {
+          "notification_completed" => 'end'
+        }
+      }
+    )
+    business_process.define_start('collect_application_info')
+
+    business_process
+  end
+end

template/{{app_name}}/engines/flex/spec/dummy/app/business_processes/passport_application_business_process_manager.rb

@@ -0,0 +1,3 @@
+class ApplicationRecord < ActiveRecord::Base
+  primary_abstract_class
+end

template/{{app_name}}/engines/flex/spec/dummy/app/models/application_record.rb

@@ -0,0 +1,38 @@
+class PassportApplicationForm < Flex::ApplicationForm
+  before_create :create_passport_case, unless: -> { has_case_id? }
+
+  attribute :first_name, :string
+  attribute :last_name, :string
+  attribute :date_of_birth, :date
+
+  attribute :case_id, :integer
+  private def case_id=(value)
+    self[:case_id] = value
+  end
+
+  def has_all_necessary_fields?
+    !first_name.nil? && !last_name.nil? && !date_of_birth.nil?
+  end
+
+  def submit_application
+    has_all_necessary_fields? ? super : false
+  end
+
+  protected
+
+  def event_payload
+    parent_payload = super
+    parent_payload.merge({ case_id: case_id })
+  end
+
+  private
+
+  def has_case_id?
+    !case_id.nil?
+  end
+
+  def create_passport_case
+    kase = PassportCase.create
+    self.case_id = kase.id
+  end
+end

template/{{app_name}}/engines/flex/spec/dummy/app/models/flex/application_record.rb

@@ -0,0 +1,14 @@
+class PassportCase < Flex::Case
+  readonly attribute :passport_id, :string, default: SecureRandom.uuid # always defaults to a new UUID
+
+  attribute :business_process_current_step, :string, default: "collect_application_info"
+
+  after_create :initialize_business_process
+
+  private
+
+  def initialize_business_process
+    business_process = PassportApplicationBusinessProcessManager.instance.business_process
+    business_process.execute({ case_id: id })
+  end
+end