From 7b3e5ab327653fb4b2f805f9055addbc5c23d81f Mon Sep 17 00:00:00 2001
From: Jonathan Branan <jonbranan@gmail.com>
Date: Tue, 16 Jul 2024 23:47:15 -0500
Subject: [PATCH] updating processData

---
 README.md             | 33 ++++++++++++++++++++++++++++++++-
 inexDataProcessing.py |  6 +++---
 2 files changed, 35 insertions(+), 4 deletions(-)

diff --git a/README.md b/README.md
index e406edb..e707942 100644
--- a/README.md
+++ b/README.md
@@ -1,3 +1,34 @@
 # Inex
 
-Information Exchange - Pull data from EFT ARM then dump it to a json file
\ No newline at end of file
+Information Exchange - Pull data from EFT ARM then dump it to a json file
+
+# Data Map:
+## tbl_ProtocolCommands
+- ProtocolCommandID
+- Time_stamp
+- RemoteIP
+- RemotePort
+- LocalIP
+- LocalPort
+- Protocol
+- SiteName
+- Command
+- CommandParameters
+- FileName
+- VirtualFolderName
+- PhysicalFolderName
+- IsInternal
+- FileSize
+- TransferTime
+- BytesTransferred
+- ResultID
+- TransactionID
+- Description
+- Actor
+## tbl_Transactions
+- TransactionID
+- ParentTransactionID
+- TransactionObject
+- TransactionGUID
+- NodeName
+- time_stamp
\ No newline at end of file
diff --git a/inexDataProcessing.py b/inexDataProcessing.py
index 7489f71..5b408e0 100644
--- a/inexDataProcessing.py
+++ b/inexDataProcessing.py
@@ -9,19 +9,19 @@ def processData(data, template):
                             file_path=row.get('PhysicalFolderName'),\
                             file_virtual_path=row.get('VirtualFolderName'),\
                             file_name=row.get('FileName'),\
-                            guid=row.get(''),\
+                            guid=row.get('TransactionGUID'),\
                             ref_id=row.get('ProtocolCommandID'),\
                             prd_instance_id=row.get(''),\
                             product_guid=row.get(''),\
                             product_name=row.get(''),\
                             product_version=row.get(''),\
-                            node_name=row.get(''),\
+                            node_name=row.get('NodeName'),\
                             src_endpoint_port=row.get('RemotePort'),\
                             src_endpoint_ip=row.get('RemoteIP'),\
                             dst_endpoint_port=row.get('LocalPort'),\
                             dst_endpoint_ip=row.get('LocalIP'),\
                             dst_endpoint_type=row.get('Protocol'),\
-                            session_uid=row.get(''),\
+                            session_uid=row.get('TransactionID'),\
                             bytes_out=row.get('BytesTransferred'),\
                             transfer_time=row.get('TransferTime'),\
                             time=row.get('Time_stamp'),\