attach session details inside account (#106)

* create message along with event

* removed unused references

* build message fixes

* build async api message object with session

* append event log attributes to headers

* updates for message options and session include

* attach session details inside account

* spec fixes

---------

Signed-off-by: Raghu Ram <[email protected]>

Author: raghuramg

lib/event_source/operations/build_message_options.rb

@@ -13,7 +13,7 @@ class BuildMessageOptions
       def call(params)
         headers = yield build_headers(params)
         payload = yield build_payload(params)
-        headers = yield append_session_details(headers)
+        headers = yield append_account_details(headers)
 
         Success(headers: headers, payload: payload)
       end
@@ -36,17 +36,20 @@ def build_payload(params)
         Success(payload)
       end
 
-      def append_session_details(headers)
+      def append_account_details(headers)
         output = FetchSession.new.call
+        account = {}
 
         if output.success?
           session, current_user = output.value!
-          headers[:session] = session&.symbolize_keys
+          account[:session] = session&.symbolize_keys
         else
           # Create system account user <[email protected]> when session is not available
           current_user = system_account if defined?(system_account)
         end
-        headers[:account_id] = current_user&.id&.to_s
+
+        account[:id] = current_user&.id&.to_s
+        headers[:account] = account
 
         Success(headers)
       end

spec/event_source/event_spec.rb

@@ -287,7 +287,7 @@ def session
 
       it "should build message" do
         expect(subject.message).to be_present
-        expect(subject.message.headers[:session]).to include(
+        expect(subject.message.headers[:account][:session]).to include(
           :session_id
         )
       end

spec/event_source/message_spec.rb

@@ -58,8 +58,7 @@ def session
             event_time
             event_outcome
             market_kind
-            account_id
-            session
+            account
           ]
         )
       end
@@ -74,8 +73,8 @@ def session
       it "should have payload with session on the message" do
         message = described_class.new(input_params)
 
-        expect(message.headers[:session]).to be_a(Hash)
-        expect(message.headers[:session].keys).to match_array(
+        expect(message.headers[:account][:session]).to be_a(Hash)
+        expect(message.headers[:account][:session].keys).to match_array(
           %i[session_id portal login_session_id]
         )
       end

spec/event_source/operations/build_message_options_spec.rb

@@ -59,8 +59,7 @@ def session
             event_time
             event_outcome
             market_kind
-            account_id
-            session
+            account
           ]
         )
       end
@@ -77,8 +76,8 @@ def session
         result = subject.call(input_params)
         message_options = result.value!
 
-        expect(message_options[:headers][:session]).to be_a(Hash)
-        expect(message_options[:headers][:session].keys).to match_array(
+        expect(message_options[:headers][:account][:session]).to be_a(Hash)
+        expect(message_options[:headers][:account][:session].keys).to match_array(
           %i[session_id portal login_session_id]
         )
       end