add monitored event entity and contract

ideacrew · Dec 28, 2023 · ea42c72 · ea42c72
1 parent f67daf7
commit ea42c72
Show file tree

Hide file tree

Showing 5 changed files with 42 additions and 0 deletions.
diff --git a/lib/aca_entities/event_logs/contracts/event_log_contract.rb b/lib/aca_entities/event_logs/contracts/event_log_contract.rb
@@ -18,6 +18,7 @@ class EventLogContract < Dry::Validation::Contract
         required(:event_time).value(:date_time)
 
         required(:session_detail).hash(AcaEntities::EventLogs::SessionDetailContract.params)
+        optional(:monitored_event).hash(AcaEntities::EventLogs::MonitoredEventContract.params)
 
         required(:trigger).maybe(:string)
         optional(:tags).maybe(:array)

diff --git a/lib/aca_entities/event_logs/contracts/monitored_event_contract.rb b/lib/aca_entities/event_logs/contracts/monitored_event_contract.rb
@@ -0,0 +1,20 @@
+# frozen_string_literal: true
+
+require "dry/validation"
+
+module AcaEntities
+  module EventLogs
+    # contract for MonitoredEvent
+    class MonitoredEventContract < Dry::Validation::Contract
+
+      params do
+        required(:market_kind).filled(:string)
+        required(:account_id).filled(:string)
+        required(:subject_hbx_id).filled(:string)
+        required(:event_category).filled(:symbol)
+        required(:event_time).value(:date_time)
+        optional(:login_session_id).maybe(:string)
+      end
+    end
+  end
+end
diff --git a/lib/aca_entities/event_logs/entities/event_log.rb b/lib/aca_entities/event_logs/entities/event_log.rb
@@ -19,6 +19,8 @@ def self.included(base)
 
           attribute :session_detail,
                     AcaEntities::EventLogs::SessionDetail.optional.meta(omittable: false)
+          attribute :monitored_event,
+                    AcaEntities::EventLogs::MonitoredEvent.optional.meta(omittable: true)
 
           attribute :trigger, Types::String.optional.meta(omittable: false)
           attribute :tags, Types::Array.optional.meta(omittable: true)

diff --git a/lib/aca_entities/event_logs/entities/monitored_event.rb b/lib/aca_entities/event_logs/entities/monitored_event.rb
@@ -0,0 +1,17 @@
+# frozen_string_literal: true
+
+module AcaEntities
+  module EventLogs
+    # Entity for Monitored Log
+    class MonitoredEvent < Dry::Struct
+      transform_keys(&:to_sym)
+
+      attribute :market_kind, Types::String.optional.meta(omittable: false)
+      attribute :account_id, Types::String.optional.meta(omittable: false)
+      attribute :subject_hbx_id, Types::String.optional.meta(omittable: false)
+      attribute :event_category, Types::Strict::Symbol.meta(omittable: false)
+      attribute :event_time, Types::DateTime.optional.meta(omittable: false)  
+      attribute :login_session_id, Types::String.optional.meta(omittable: true)
+    end
+  end
+end
diff --git a/lib/aca_entities/libraries/core_library.rb b/lib/aca_entities/libraries/core_library.rb
@@ -197,11 +197,13 @@ module CoreLibrary
       require 'aca_entities/benefit_sponsors/entities/benefit_sponsorships/shop_osse_eligibilities/shop_osse_eligibility'
 
       require 'aca_entities/event_logs/contracts/session_detail_contract'
+      require 'aca_entities/event_logs/contracts/monitored_event_contract'
       require 'aca_entities/event_logs/contracts/event_log_contract'
       require 'aca_entities/event_logs/contracts/person_event_log_contract'
       require 'aca_entities/event_logs/contracts/benefit_sponsorship_event_log_contract'
 
       require 'aca_entities/event_logs/entities/session_detail'
+      require 'aca_entities/event_logs/entities/monitored_event'
       require 'aca_entities/event_logs/entities/event_log'
       require 'aca_entities/event_logs/entities/person_event_log'
       require 'aca_entities/event_logs/entities/benefit_sponsorship_event_log'