From 127cca8a3a12b764208ccea3ff6790dfb5513edb Mon Sep 17 00:00:00 2001
From: TivonB-AI2 <124182151+TivonB-AI2@users.noreply.github.com>
Date: Fri, 28 Jun 2024 07:15:33 -0400
Subject: [PATCH 1/9] chore(CE): update README for MariaDB connectors (#249)

---
 integrations/README.md | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

diff --git a/integrations/README.md b/integrations/README.md
index 254ba67a..19c95be9 100644
--- a/integrations/README.md
+++ b/integrations/README.md
@@ -43,6 +43,23 @@ Multiwoven integrations is the collection of connectors built on top of [Multiwo
 Multiwoven protocol is an open source standard for moving data between data sources to any third-part destinations.
 Anyone can build a connetor with basic ruby knowledge using the protocol.
 
+## Prerequisites
+
+Before you begin the installation, ensure you have the following dependencies installed:
+
+- **MySQL Client**
+  - Command: `brew install mysql-client`
+  - Description: Required for database interactions.
+
+- **Zstandard (zstd)**
+  - Command: `brew install zstd`
+  - Description: Needed for data compression and decompression.
+
+- **OpenSSL 3**
+  - Command: `brew install openssl@3`
+  - Description: Essential for secure communication.
+
+
 ### Installation
 
 Install the gem and add to the application's Gemfile by executing:

From b5415e820c6a1a50960e31d5ae34bed983532067 Mon Sep 17 00:00:00 2001
From: github-actions <developer@multiwoven.com>
Date: Tue, 2 Jul 2024 00:17:25 +0000
Subject: [PATCH 2/9] Multiwoven release v0.14.0

---
 release-notes.md | 25 +++++++++++++++----------
 1 file changed, 15 insertions(+), 10 deletions(-)

diff --git a/release-notes.md b/release-notes.md
index 40d07309..9864442c 100644
--- a/release-notes.md
+++ b/release-notes.md
@@ -2,24 +2,29 @@
 
 All notable changes to this project will be documented in this file.
 
-## [0.13.0] - 2024-06-24
+## [0.14.0] - 2024-07-01
 
 ### 🚀 Features
 
-- Added Iterable Connector
-- *(CE)* Workspace settings and useQueryWrapper (#193)
-- *(CE)* Add amazon s3 source connector
+- *(CE)* Separate code climate reports and badges (#203)
+- *(CE)* Add mariaDB source connector (#208)
+- *(CE)* Lock user login attempts (#182)
+- *(CE)* Sync records error log (#211)
+- *(CE)* Add table selector as model query type (#243) (#209)
+- *(CE)* Force refresh catalog when refresh flag is set true (#248) (#217)
+- *(CE)* Add table selector as model query type (#234) (#213)
 
 ### 🐛 Bug Fixes
 
-- *(CE)* EE to CE Commit Sync PAT issue
-- *(CE)* Github URL issues
-- *(CE)* Change Github PAT to SSH PRIVATE KEY (#196)
-- *(CE)* UI Maintainability and workspace id on page refresh (#228) (#200)
-- *(CE)* CE sync commit not working for multiple commits (#201)
+- *(CE)* Skip verify_authorized in logout (#204)
+- *(CE)* Json error field added in sync record (#205)
+- *(CE)* Add mariadb-dev in DockerFile (#235)
+- *(CE)* Signup error response (#214)
 
 ### ⚙️ Miscellaneous Tasks
 
-- *(CE)* Add GitHub actions for syncing previous days CE commits
+- *(CE)* Update the role policies (#206)
+- *(CE)* Update server gem (#227)
+- *(CE)* Pundit policy at role permissions level (#210)
 
 <!-- generated by git-cliff -->

From f28c6f9d0c96a52c243347c0706fac2596464cb1 Mon Sep 17 00:00:00 2001
From: "github-actions[bot]"
 <41898282+github-actions[bot]@users.noreply.github.com>
Date: Thu, 4 Jul 2024 15:46:43 +0530
Subject: [PATCH 3/9] fix(CE): Fixed issue where sync interval dropdown text
 was hidden in smaller screens (#252) (#230)

Co-authored-by: Tushar Selvakumar <54372016+macintushar@users.noreply.github.com>
---
 ui/src/components/FormFooter/FormFooter.tsx   |  2 +-
 .../Activate/Syncs/EditSync/ScheduleForm.tsx  | 28 +++++++++----
 .../FinaliseSync/CronScheduleType.tsx         |  2 +-
 .../SyncForm/FinaliseSync/FinaliseSync.tsx    | 41 +++++++++++--------
 4 files changed, 46 insertions(+), 27 deletions(-)

diff --git a/ui/src/components/FormFooter/FormFooter.tsx b/ui/src/components/FormFooter/FormFooter.tsx
index 3682c8dd..11343f12 100644
--- a/ui/src/components/FormFooter/FormFooter.tsx
+++ b/ui/src/components/FormFooter/FormFooter.tsx
@@ -43,7 +43,7 @@ const FormFooter = ({
       right='0'
       borderWidth='thin'
       bottom='0'
-      backgroundColor='#fff'
+      backgroundColor='gray.100'
       padding='30px'
       display='flex'
       justifyContent='center'
diff --git a/ui/src/views/Activate/Syncs/EditSync/ScheduleForm.tsx b/ui/src/views/Activate/Syncs/EditSync/ScheduleForm.tsx
index a1ab1a1f..0249ed6e 100644
--- a/ui/src/views/Activate/Syncs/EditSync/ScheduleForm.tsx
+++ b/ui/src/views/Activate/Syncs/EditSync/ScheduleForm.tsx
@@ -19,7 +19,7 @@ const ScheduleForm = ({ formik, isEdit }: ScheduleFormProps) => {
       <Text fontWeight='semibold' mb='6' size='md'>
         Finalise setting for this sync
       </Text>
-      <Box display='flex' justifyContent='space-between'>
+      <Box display='flex' flexDir={{ base: 'column', md: 'row' }} justifyContent='space-between'>
         <Box>
           <Text mb='4' fontWeight='semibold' size='sm'>
             Schedule type
@@ -50,7 +50,7 @@ const ScheduleForm = ({ formik, isEdit }: ScheduleFormProps) => {
                 value='interval'
                 display='flex'
                 alignItems='flex-start'
-                backgroundColor='#fff'
+                backgroundColor='gray.100'
                 marginBottom='10px'
               >
                 <Box position='relative' top='-5px'>
@@ -81,7 +81,7 @@ const ScheduleForm = ({ formik, isEdit }: ScheduleFormProps) => {
             </Stack>
           </RadioGroup>
         </Box>
-        <Box width='40%'>
+        <Box width={{ base: '100%', lg: '40%' }}>
           {formik.values.schedule_type === 'interval' ? (
             <>
               <Text mb={4} fontWeight='semibold' size='sm'>
@@ -89,7 +89,6 @@ const ScheduleForm = ({ formik, isEdit }: ScheduleFormProps) => {
               </Text>
               <Box
                 border='thin'
-                padding='5px 10px 5px 20px'
                 display='flex'
                 backgroundColor='gray.100'
                 borderRadius='8px'
@@ -98,23 +97,29 @@ const ScheduleForm = ({ formik, isEdit }: ScheduleFormProps) => {
                 borderStyle='solid'
                 borderColor='gray.400'
                 height='40px'
-                justifyContent='space-around'
+                gap='12px'
+                maxW='450px'
+                w='fit-content'
+                px='12px'
               >
                 <Box>
-                  <Text>Every</Text>
+                  <Text size='sm' fontWeight='medium'>
+                    Every
+                  </Text>
                 </Box>
                 <Box>
                   <Input
                     name='sync_interval'
-                    pr='4.5rem'
                     type='number'
                     placeholder='Enter a value'
                     border='none'
-                    _focusVisible={{ border: '#fff' }}
+                    _focusVisible={{ border: 'gray.100' }}
                     value={formik.values.sync_interval}
                     onChange={formik.handleChange}
                     isRequired
                     height='35px'
+                    minW='60px'
+                    maxW='280px'
                   />
                 </Box>
                 <Divider orientation='vertical' height='24px' color='gray.400' />
@@ -122,9 +127,14 @@ const ScheduleForm = ({ formik, isEdit }: ScheduleFormProps) => {
                   <Select
                     name='sync_interval_unit'
                     border='none'
-                    _focusVisible={{ border: '#fff' }}
+                    _focusVisible={{ border: 'gray.100' }}
                     value={formik.values.sync_interval_unit}
                     onChange={formik.handleChange}
+                    height='35px'
+                    minW='120px'
+                    w='full'
+                    fontWeight='medium'
+                    size='sm'
                   >
                     <option value='minutes'>Minute(s)</option>
                     <option value='hours'>Hour(s)</option>
diff --git a/ui/src/views/Activate/Syncs/SyncForm/FinaliseSync/CronScheduleType.tsx b/ui/src/views/Activate/Syncs/SyncForm/FinaliseSync/CronScheduleType.tsx
index f87954ca..61568d43 100644
--- a/ui/src/views/Activate/Syncs/SyncForm/FinaliseSync/CronScheduleType.tsx
+++ b/ui/src/views/Activate/Syncs/SyncForm/FinaliseSync/CronScheduleType.tsx
@@ -80,7 +80,7 @@ const CronScheduleType = ({ formik }: { formik: FormikContextType<any> }): JSX.E
           type='text'
           placeholder='Enter cron expression'
           border='none'
-          _focusVisible={{ border: '#fff' }}
+          _focusVisible={{ border: 'gray.100' }}
           value={formik.values.cron_expression}
           onChange={handleCronExpressionChange}
           isRequired
diff --git a/ui/src/views/Activate/Syncs/SyncForm/FinaliseSync/FinaliseSync.tsx b/ui/src/views/Activate/Syncs/SyncForm/FinaliseSync/FinaliseSync.tsx
index 9b649ae2..56e91bab 100644
--- a/ui/src/views/Activate/Syncs/SyncForm/FinaliseSync/FinaliseSync.tsx
+++ b/ui/src/views/Activate/Syncs/SyncForm/FinaliseSync/FinaliseSync.tsx
@@ -106,10 +106,13 @@ const FinaliseSync = (): JSX.Element => {
               borderStyle='solid'
               borderColor='gray.400'
             />
-
-            <Box display='flex' justifyContent='space-between'>
-              <Box mr={4}>
-                <Text mb='4' fontWeight='600' size='sm'>
+            <Box
+              display='flex'
+              flexDir={{ base: 'column', md: 'row' }}
+              justifyContent='space-between'
+            >
+              <Box>
+                <Text mb='4' fontWeight='semibold' size='sm'>
                   Schedule type
                 </Text>
                 <RadioGroup
@@ -123,11 +126,10 @@ const FinaliseSync = (): JSX.Element => {
                       display='flex'
                       alignItems='flex-start'
                       marginBottom='10px'
-                      backgroundColor='gray.100'
                       isDisabled
                     >
                       <Box position='relative' top='-5px'>
-                        <Text fontWeight='500' size='sm'>
+                        <Text fontWeight='medium' size='sm'>
                           Manual{' '}
                         </Text>
                         <Text size='xs' color='black.200'>
@@ -143,7 +145,7 @@ const FinaliseSync = (): JSX.Element => {
                       marginBottom='10px'
                     >
                       <Box position='relative' top='-5px'>
-                        <Text fontWeight='500' size='sm'>
+                        <Text fontWeight='medium' size='sm'>
                           Interval{' '}
                         </Text>
                         <Text size='xs' color='black.200'>
@@ -170,15 +172,14 @@ const FinaliseSync = (): JSX.Element => {
                   </Stack>
                 </RadioGroup>
               </Box>
-              <Box width='40%'>
+              <Box width={{ base: '100%', lg: '40%' }}>
                 {formik.values.schedule_type === 'interval' ? (
                   <>
-                    <Text mb={4} fontWeight='600' size='sm'>
+                    <Text mb={4} fontWeight='semibold' size='sm'>
                       Schedule Configuration
                     </Text>
                     <Box
                       border='thin'
-                      padding='5px 10px 5px 20px'
                       display='flex'
                       backgroundColor='gray.100'
                       borderRadius='8px'
@@ -187,26 +188,29 @@ const FinaliseSync = (): JSX.Element => {
                       borderStyle='solid'
                       borderColor='gray.400'
                       height='40px'
-                      justifyContent='space-around'
+                      gap='12px'
+                      maxW='450px'
+                      w='fit-content'
+                      px='12px'
                     >
                       <Box>
-                        <Text size='sm' fontWeight={500}>
+                        <Text size='sm' fontWeight='medium'>
                           Every
                         </Text>
                       </Box>
                       <Box>
                         <Input
                           name='sync_interval'
-                          pr='4.5rem'
                           type='number'
                           placeholder='Enter a value'
                           border='none'
-                          _focusVisible={{ border: '#fff' }}
+                          _focusVisible={{ border: 'gray.100' }}
                           value={formik.values.sync_interval}
                           onChange={formik.handleChange}
                           isRequired
-                          color='gray.600'
                           height='35px'
+                          minW='60px'
+                          maxW='280px'
                         />
                       </Box>
                       <Divider orientation='vertical' height='24px' color='gray.400' />
@@ -214,9 +218,14 @@ const FinaliseSync = (): JSX.Element => {
                         <Select
                           name='sync_interval_unit'
                           border='none'
-                          _focusVisible={{ border: '#fff' }}
+                          _focusVisible={{ border: 'gray.100' }}
                           value={formik.values.sync_interval_unit}
                           onChange={formik.handleChange}
+                          height='35px'
+                          minW='120px'
+                          w='full'
+                          fontWeight='medium'
+                          size='sm'
                         >
                           <option value='minutes'>Minute(s)</option>
                           <option value='hours'>Hour(s)</option>

From 800fe3d139bccf0bb464eedc14b970403103f0c6 Mon Sep 17 00:00:00 2001
From: "github-actions[bot]"
 <41898282+github-actions[bot]@users.noreply.github.com>
Date: Thu, 4 Jul 2024 15:47:14 +0530
Subject: [PATCH 4/9] fix(CE): added processFormData to process form data
 before checking connection (#262) (#228)

Co-authored-by: Tushar Selvakumar <54372016+macintushar@users.noreply.github.com>
---
 .../DestinationConfigForm/DestinationConfigForm.tsx           | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/ui/src/views/Connectors/Destinations/DestinationsForm/DestinationConfigForm/DestinationConfigForm.tsx b/ui/src/views/Connectors/Destinations/DestinationsForm/DestinationConfigForm/DestinationConfigForm.tsx
index 5d76bdb6..5379c4db 100644
--- a/ui/src/views/Connectors/Destinations/DestinationsForm/DestinationConfigForm/DestinationConfigForm.tsx
+++ b/ui/src/views/Connectors/Destinations/DestinationsForm/DestinationConfigForm/DestinationConfigForm.tsx
@@ -10,6 +10,7 @@ import SourceFormFooter from '@/views/Connectors/Sources/SourcesForm/SourceFormF
 import JSONSchemaForm from '@/components/JSONSchemaForm';
 import { generateUiSchema } from '@/utils/generateUiSchema';
 import { useStore } from '@/stores';
+import { processFormData } from '@/views/Connectors/helpers';
 
 const DestinationConfigForm = (): JSX.Element | null => {
   const { state, stepInfo, handleMoveForward } = useContext(SteppedFormContext);
@@ -34,7 +35,8 @@ const DestinationConfigForm = (): JSX.Element | null => {
   if (!connectorSchema) return null;
 
   const handleFormSubmit = async (formData: FormData) => {
-    handleMoveForward(stepInfo?.formKey as string, formData);
+    const processedFormData = processFormData(formData);
+    handleMoveForward(stepInfo?.formKey as string, processedFormData);
   };
 
   const generatedSchema = generateUiSchema(connectorSchema);

From eebc9dc88a160e0afa7750255c25c2286f11d05b Mon Sep 17 00:00:00 2001
From: "github-actions[bot]"
 <41898282+github-actions[bot]@users.noreply.github.com>
Date: Thu, 4 Jul 2024 15:58:53 +0530
Subject: [PATCH 5/9] feat(CE): integration changes for sync record log (#223)

* Resolve conflict in cherry-pick of 32aaa10b522739667ba42574b646b6b9ad6e80a3 and change the commit message

* chore(CE): conflict resolve

* chore(CE): update gem lock

---------

Co-authored-by: afthab vp <afthab@multiwoven.com>
Co-authored-by: afthab vp <afthab01@gmail.com>
---
 integrations/Gemfile.lock                     |  3 +-
 .../core/destination_connector.rb             |  6 ++++
 .../lib/multiwoven/integrations/core/utils.rb |  8 +++++
 .../destination/postgresql/client.rb          | 13 +++-----
 .../salesforce_consumer_goods_cloud/client.rb | 24 ++++++--------
 .../integrations/protocol/protocol.rb         |  1 +
 .../lib/multiwoven/integrations/rollout.rb    |  2 +-
 .../core/destination_connector_spec.rb        | 32 +++++++++++++++++++
 .../integrations/core/utils_spec.rb           | 18 +++++++++++
 .../destination/postgresql/client_spec.rb     | 19 +++++++++++
 .../client_spec.rb                            | 14 ++++++++
 .../integrations/protocol/protocol_spec.rb    | 14 ++++++--
 12 files changed, 127 insertions(+), 27 deletions(-)

diff --git a/integrations/Gemfile.lock b/integrations/Gemfile.lock
index b81231bf..0809ed77 100644
--- a/integrations/Gemfile.lock
+++ b/integrations/Gemfile.lock
@@ -7,7 +7,7 @@ GIT
 PATH
   remote: .
   specs:
-    multiwoven-integrations (0.3.4)
+    multiwoven-integrations (0.3.5)
       activesupport
       async-websocket
       aws-sdk-athena
@@ -326,6 +326,7 @@ GEM
 
 PLATFORMS
   arm64-darwin-22
+  arm64-darwin-23
   x64-mingw-ucrt
   x86_64-darwin-23
 
diff --git a/integrations/lib/multiwoven/integrations/core/destination_connector.rb b/integrations/lib/multiwoven/integrations/core/destination_connector.rb
index dff29687..f0595a31 100644
--- a/integrations/lib/multiwoven/integrations/core/destination_connector.rb
+++ b/integrations/lib/multiwoven/integrations/core/destination_connector.rb
@@ -9,6 +9,12 @@ def write(_sync_config, _records, _action = "destination_insert")
         raise "Not implemented"
         # return Protocol::TrackingMessage
       end
+
+      def tracking_message(success, failure, log_message_array)
+        Multiwoven::Integrations::Protocol::TrackingMessage.new(
+          success: success, failed: failure, logs: log_message_array
+        ).to_multiwoven_message
+      end
     end
   end
 end
diff --git a/integrations/lib/multiwoven/integrations/core/utils.rb b/integrations/lib/multiwoven/integrations/core/utils.rb
index 32b4238e..e1078f70 100644
--- a/integrations/lib/multiwoven/integrations/core/utils.rb
+++ b/integrations/lib/multiwoven/integrations/core/utils.rb
@@ -53,6 +53,14 @@ def report_exception(exception, meta = {})
         reporter&.report(exception, meta)
       end
 
+      def log_request_response(level, request, response)
+        Integrations::Protocol::LogMessage.new(
+          name: self.class.name,
+          level: level,
+          message: { request: request.to_s, response: response.to_s, level: level }.to_json
+        )
+      end
+
       def create_log_message(context, type, exception)
         Integrations::Protocol::LogMessage.new(
           name: context,
diff --git a/integrations/lib/multiwoven/integrations/destination/postgresql/client.rb b/integrations/lib/multiwoven/integrations/destination/postgresql/client.rb
index 89038783..6d943331 100644
--- a/integrations/lib/multiwoven/integrations/destination/postgresql/client.rb
+++ b/integrations/lib/multiwoven/integrations/destination/postgresql/client.rb
@@ -46,6 +46,7 @@ def write(sync_config, records, action = "destination_insert")
         connection_config = sync_config.destination.connection_specification.with_indifferent_access
         table_name = sync_config.stream.name
         primary_key = sync_config.model.primary_key
+        log_message_array = []
         db = create_connection(connection_config)
 
         write_success = 0
@@ -55,8 +56,9 @@ def write(sync_config, records, action = "destination_insert")
           query = Multiwoven::Integrations::Core::QueryBuilder.perform(action, table_name, record, primary_key)
           logger.debug("POSTGRESQL:WRITE:QUERY query = #{query} sync_id = #{sync_config.sync_id} sync_run_id = #{sync_config.sync_run_id}")
           begin
-            db.exec(query)
+            response = db.exec(query)
             write_success += 1
+            log_message_array << log_request_response("info", query, response)
           rescue StandardError => e
             handle_exception(e, {
                                context: "POSTGRESQL:RECORD:WRITE:EXCEPTION",
@@ -65,9 +67,10 @@ def write(sync_config, records, action = "destination_insert")
                                sync_run_id: sync_config.sync_run_id
                              })
             write_failure += 1
+            log_message_array << log_request_response("error", query, e.message)
           end
         end
-        tracking_message(write_success, write_failure)
+        tracking_message(write_success, write_failure, log_message_array)
       rescue StandardError => e
         handle_exception(e, {
                            context: "POSTGRESQL:RECORD:WRITE:EXCEPTION",
@@ -119,12 +122,6 @@ def group_by_table(records)
           }
         end
       end
-
-      def tracking_message(success, failure)
-        Multiwoven::Integrations::Protocol::TrackingMessage.new(
-          success: success, failed: failure
-        ).to_multiwoven_message
-      end
     end
   end
 end
diff --git a/integrations/lib/multiwoven/integrations/destination/salesforce_consumer_goods_cloud/client.rb b/integrations/lib/multiwoven/integrations/destination/salesforce_consumer_goods_cloud/client.rb
index 4754c4bc..dd22b70c 100644
--- a/integrations/lib/multiwoven/integrations/destination/salesforce_consumer_goods_cloud/client.rb
+++ b/integrations/lib/multiwoven/integrations/destination/salesforce_consumer_goods_cloud/client.rb
@@ -80,10 +80,14 @@ def process_records(records, stream)
             write_success = 0
             write_failure = 0
             properties = stream.json_schema[:properties]
+            log_message_array = []
+
             records.each do |record_object|
               record = extract_data(record_object, properties)
-              process_record(stream, record)
+              args = [stream.name, "Id", record]
+              response = send_data_to_salesforce(args)
               write_success += 1
+              log_message_array << log_request_response("info", args, response)
             rescue StandardError => e
               # TODO: add sync_id and sync run id to the logs
               handle_exception(e, {
@@ -93,18 +97,14 @@ def process_records(records, stream)
                                  sync_run_id: @sync_config.sync_run_id
                                })
               write_failure += 1
+              log_message_array << log_request_response("error", args, e.message)
             end
-            tracking_message(write_success, write_failure)
-          end
-
-          def process_record(stream, record)
-            send_data_to_salesforce(stream.name, record)
+            tracking_message(write_success, write_failure, log_message_array)
           end
 
-          def send_data_to_salesforce(stream_name, record = {})
+          def send_data_to_salesforce(args)
             method_name = "upsert!"
-            args = [stream_name, "Id", record]
-            @logger.debug("sync_id: #{@sync_config.sync_id}, sync_run_id: #{@sync_config.sync_run_id}, record: #{record}")
+            @logger.debug("sync_id: #{@sync_config.sync_id}, sync_run_id: #{@sync_config.sync_run_id}, args: #{args}")
             @client.send(method_name, *args)
           end
 
@@ -124,12 +124,6 @@ def load_catalog
             read_json(CATALOG_SPEC_PATH)
           end
 
-          def tracking_message(success, failure)
-            Multiwoven::Integrations::Protocol::TrackingMessage.new(
-              success: success, failed: failure
-            ).to_multiwoven_message
-          end
-
           def log_debug(message)
             Multiwoven::Integrations::Service.logger.debug(message)
           end
diff --git a/integrations/lib/multiwoven/integrations/protocol/protocol.rb b/integrations/lib/multiwoven/integrations/protocol/protocol.rb
index b3381659..9b4c5efd 100644
--- a/integrations/lib/multiwoven/integrations/protocol/protocol.rb
+++ b/integrations/lib/multiwoven/integrations/protocol/protocol.rb
@@ -197,6 +197,7 @@ class TrackingMessage < ProtocolModel
       attribute :success, Types::Integer.default(0)
       attribute :failed, Types::Integer.default(0)
       attribute? :meta, Types::Hash
+      attribute? :logs, Types::Array.of(LogMessage)
 
       def to_multiwoven_message
         MultiwovenMessage.new(
diff --git a/integrations/lib/multiwoven/integrations/rollout.rb b/integrations/lib/multiwoven/integrations/rollout.rb
index a55b8e5c..b78c0746 100644
--- a/integrations/lib/multiwoven/integrations/rollout.rb
+++ b/integrations/lib/multiwoven/integrations/rollout.rb
@@ -2,7 +2,7 @@
 
 module Multiwoven
   module Integrations
-    VERSION = "0.3.4"
+    VERSION = "0.3.5"
 
     ENABLED_SOURCES = %w[
       Snowflake
diff --git a/integrations/spec/multiwoven/integrations/core/destination_connector_spec.rb b/integrations/spec/multiwoven/integrations/core/destination_connector_spec.rb
index f28920dd..31cec0d8 100644
--- a/integrations/spec/multiwoven/integrations/core/destination_connector_spec.rb
+++ b/integrations/spec/multiwoven/integrations/core/destination_connector_spec.rb
@@ -17,6 +17,38 @@ module Integrations::Core
           expect { connector.write(sync_config, records) }.to raise_error("Not implemented")
         end
       end
+
+      describe "#tracking_message" do
+        let(:log_message_data) do
+          Multiwoven::Integrations::Protocol::LogMessage.new(
+            name: self.class.name,
+            level: "info",
+            message: { request: "Sample req", response: "Sample req", level: "info" }.to_json
+          )
+        end
+        it "returns a MultiwovenMessage with tracking information" do
+          connector = described_class.new
+          success = 2
+          failure = 1
+
+          multiwoven_message = connector.tracking_message(success, failure, [log_message_data])
+
+          expect(multiwoven_message).to be_a(Multiwoven::Integrations::Protocol::MultiwovenMessage)
+          expect(multiwoven_message.type).to eq("tracking")
+
+          tracking_message = multiwoven_message.tracking
+          expect(tracking_message).to be_a(Multiwoven::Integrations::Protocol::TrackingMessage)
+          expect(tracking_message.success).to eq(success)
+          expect(tracking_message.failed).to eq(failure)
+
+          logs = tracking_message.logs
+          expect(logs).to be_an(Array)
+          expect(logs.size).to eq(1)
+          expect(logs.first).to be_a(Multiwoven::Integrations::Protocol::LogMessage)
+          expect(logs.first.level).to eq("info")
+          expect(logs.first.message).to eq("{\"request\":\"Sample req\",\"response\":\"Sample req\",\"level\":\"info\"}")
+        end
+      end
     end
   end
 end
diff --git a/integrations/spec/multiwoven/integrations/core/utils_spec.rb b/integrations/spec/multiwoven/integrations/core/utils_spec.rb
index 48c85e8d..028ae405 100644
--- a/integrations/spec/multiwoven/integrations/core/utils_spec.rb
+++ b/integrations/spec/multiwoven/integrations/core/utils_spec.rb
@@ -50,6 +50,24 @@ module Core
             expect(dummy_class.hash_to_string(hash)).to eq("key1 = 1, key2 = 2.5, key3 = true, key4 = ")
           end
         end
+
+        describe "#log_request_response" do
+          let(:level) { "info" }
+          let(:request) { { user_id: 1, action: "create" } }
+          let(:response) { { status: "success" } }
+
+          it "creates a LogMessage object with correct attributes" do
+            log_message = dummy_class.log_request_response(level, request, response)
+
+            expect(log_message).to be_a(Multiwoven::Integrations::Protocol::LogMessage)
+            expect(log_message.level).to eq(level)
+
+            parsed_message = JSON.parse(log_message.message)
+            expect(parsed_message["request"]).to eq(request.to_s)
+            expect(parsed_message["response"]).to eq(response.to_s)
+            expect(parsed_message["level"]).to eq(level)
+          end
+        end
       end
     end
   end
diff --git a/integrations/spec/multiwoven/integrations/destination/postgresql/client_spec.rb b/integrations/spec/multiwoven/integrations/destination/postgresql/client_spec.rb
index 8860c6f0..b4155222 100644
--- a/integrations/spec/multiwoven/integrations/destination/postgresql/client_spec.rb
+++ b/integrations/spec/multiwoven/integrations/destination/postgresql/client_spec.rb
@@ -114,6 +114,12 @@
 
         tracking = subject.write(s_config, [records.first.data.transform_keys(&:to_s)]).tracking
         expect(tracking.success).to eql(1)
+        log_message = tracking.logs.first
+        expect(log_message).to be_a(Multiwoven::Integrations::Protocol::LogMessage)
+        expect(log_message.level).to eql("info")
+
+        expect(log_message.message).to include("request")
+        expect(log_message.message).to include("response")
       end
 
       it "write records successfully on update record action destination_update" do
@@ -125,6 +131,13 @@
 
         tracking = subject.write(s_config, [records.first.data.transform_keys(&:to_s)], "destination_update").tracking
         expect(tracking.success).to eql(1)
+        expect(tracking.logs.count).to eql(1)
+        log_message = tracking.logs.first
+        expect(log_message).to be_a(Multiwoven::Integrations::Protocol::LogMessage)
+        expect(log_message.level).to eql("info")
+
+        expect(log_message.message).to include("request")
+        expect(log_message.message).to include("response")
       end
     end
 
@@ -139,6 +152,12 @@
 
         tracking = subject.write(s_config, [records.first.data.transform_keys(&:to_s)]).tracking
         expect(tracking.failed).to eql(1)
+        expect(tracking.logs.count).to eql(1)
+        log_message = tracking.logs.first
+        expect(log_message).to be_a(Multiwoven::Integrations::Protocol::LogMessage)
+        expect(log_message.level).to eql("error")
+        expect(log_message.message).to include("request")
+        expect(log_message.message).to include("\"response\":\"test error\"")
       end
     end
   end
diff --git a/integrations/spec/multiwoven/integrations/destination/salesforce_consumer_goods_cloud/client_spec.rb b/integrations/spec/multiwoven/integrations/destination/salesforce_consumer_goods_cloud/client_spec.rb
index 70c6769c..30e17a2b 100644
--- a/integrations/spec/multiwoven/integrations/destination/salesforce_consumer_goods_cloud/client_spec.rb
+++ b/integrations/spec/multiwoven/integrations/destination/salesforce_consumer_goods_cloud/client_spec.rb
@@ -194,6 +194,13 @@
         response = client.write(sync_config, records)
         expect(response.tracking.success).to eq(records.size)
         expect(response.tracking.failed).to eq(0)
+        expect(response.tracking.logs.count).to eql(2)
+        log_message = response.tracking.logs.first
+        expect(log_message).to be_a(Multiwoven::Integrations::Protocol::LogMessage)
+        expect(log_message.level).to eql("info")
+
+        expect(log_message.message).to include("request")
+        expect(log_message.message).to include("response")
       end
     end
 
@@ -207,6 +214,13 @@
         response = client.write(sync_config, records)
         expect(response.tracking.failed).to eq(records.size)
         expect(response.tracking.success).to eq(0)
+        expect(response.tracking.logs.count).to eql(2)
+        log_message = response.tracking.logs.first
+        expect(log_message).to be_a(Multiwoven::Integrations::Protocol::LogMessage)
+        expect(log_message.level).to eql("error")
+
+        expect(log_message.message).to include("request")
+        expect(log_message.message).to include("response")
       end
     end
   end
diff --git a/integrations/spec/multiwoven/integrations/protocol/protocol_spec.rb b/integrations/spec/multiwoven/integrations/protocol/protocol_spec.rb
index e2735380..bcb9e589 100644
--- a/integrations/spec/multiwoven/integrations/protocol/protocol_spec.rb
+++ b/integrations/spec/multiwoven/integrations/protocol/protocol_spec.rb
@@ -457,16 +457,26 @@ module Integrations::Protocol
 
   RSpec.describe Multiwoven::Integrations::Protocol::TrackingMessage do
     describe "#to_multiwoven_message" do
+      let(:log_message_data) do
+        Multiwoven::Integrations::Protocol::LogMessage.new(
+          name: self.class.name,
+          level: "info",
+          message: { request: "Sample req", response: "Sample req", level: "info" }.to_json
+        )
+      end
       let(:tracking_message) do
-        Multiwoven::Integrations::Protocol::TrackingMessage.new(success: 3, failed: 1)
+        Multiwoven::Integrations::Protocol::TrackingMessage.new(success: 3, failed: 1, logs: [log_message_data])
       end
 
       it "converts to a MultiwovenMessage" do
         multiwoven_message = tracking_message.to_multiwoven_message
-
         expect(multiwoven_message).to be_a(Multiwoven::Integrations::Protocol::MultiwovenMessage)
         expect(multiwoven_message.type).to eq("tracking")
         expect(multiwoven_message.tracking).to eq(tracking_message)
+        expect(multiwoven_message.tracking.logs.first).to be_a(Multiwoven::Integrations::Protocol::LogMessage)
+        expect(multiwoven_message.tracking.logs.first.level).to eq("info")
+        expect(multiwoven_message.tracking.logs.first.message)
+          .to eq("{\"request\":\"Sample req\",\"response\":\"Sample req\",\"level\":\"info\"}")
       end
     end
   end

From 096bd7cc746ca5ffef18e011e117720d9b41f837 Mon Sep 17 00:00:00 2001
From: "github-actions[bot]"
 <41898282+github-actions[bot]@users.noreply.github.com>
Date: Thu, 4 Jul 2024 15:59:57 +0530
Subject: [PATCH 6/9] chore(CE): Update Role Descriptions (#229)

Co-authored-by: afthab vp <afthab@multiwoven.com>
---
 ...20240702095541_update_role_descriptions.rb | 25 +++++++++++++++++++
 server/db/data_schema.rb                      |  2 +-
 2 files changed, 26 insertions(+), 1 deletion(-)
 create mode 100644 server/db/data/20240702095541_update_role_descriptions.rb

diff --git a/server/db/data/20240702095541_update_role_descriptions.rb b/server/db/data/20240702095541_update_role_descriptions.rb
new file mode 100644
index 00000000..0475064c
--- /dev/null
+++ b/server/db/data/20240702095541_update_role_descriptions.rb
@@ -0,0 +1,25 @@
+# frozen_string_literal: true
+
+class UpdateRoleDescriptions < ActiveRecord::Migration[7.1]
+  def change
+    update_role_description(
+      "Admin",
+      "An Admin can add and manage Sources, Destinations, Models, Syncs, and Workspaces."
+    )
+    update_role_description(
+      "Member",
+      "A Member can add and manage Sources, Destinations, Models, and Syncs but cannot manage the Workspaces."
+    )
+    update_role_description(
+      "Viewer",
+      "A Viewer has read-only access to the already created Sources, Destinations, Models, and Syncs and cannot manage"\
+      " the Workspaces."
+    )
+  end
+
+  private
+
+  def update_role_description(role_name, role_desc)
+    Role.find_by(role_name:)&.update!(role_desc:)
+  end
+end
diff --git a/server/db/data_schema.rb b/server/db/data_schema.rb
index a02fa32e..f783f44d 100644
--- a/server/db/data_schema.rb
+++ b/server/db/data_schema.rb
@@ -1,3 +1,3 @@
 # frozen_string_literal: true
 
-DataMigrate::Data.define(version: 20_240_626_120_511)
+DataMigrate::Data.define(version: 20_240_702_095_541)

From f61ad1a87c015c7c0bd4a5cf3dc102fafac9e75e Mon Sep 17 00:00:00 2001
From: "github-actions[bot]"
 <41898282+github-actions[bot]@users.noreply.github.com>
Date: Thu, 4 Jul 2024 16:07:04 +0530
Subject: [PATCH 7/9] feat(CE): Server changes for save logs to sync record
 table (#231)

---
 server/Gemfile                                |  2 +-
 server/Gemfile.lock                           |  9 +--
 .../app/serializers/sync_record_serializer.rb |  2 +-
 ...09_rename_error_to_logs_in_sync_records.rb |  9 +++
 server/db/schema.rb                           |  4 +-
 server/lib/reverse_etl/loaders/standard.rb    | 25 ++++----
 .../lib/reverse_etl/loaders/standard_spec.rb  | 62 ++++++++++++++++++-
 .../api/v1/sync_records_controller_spec.rb    | 14 ++---
 8 files changed, 97 insertions(+), 30 deletions(-)
 create mode 100644 server/db/migrate/20240628122409_rename_error_to_logs_in_sync_records.rb

diff --git a/server/Gemfile b/server/Gemfile
index ca70a3f6..0f4fea74 100644
--- a/server/Gemfile
+++ b/server/Gemfile
@@ -13,7 +13,7 @@ gem "interactor", "~> 3.0"
 
 gem "ruby-odbc", git: "https://github.com/Multiwoven/ruby-odbc.git"
 
-gem "multiwoven-integrations", "~> 0.3.4"
+gem "multiwoven-integrations", "~> 0.3.5"
 
 gem "temporal-ruby", github: "coinbase/temporal-ruby"
 
diff --git a/server/Gemfile.lock b/server/Gemfile.lock
index ffe8c7b6..af27ac53 100644
--- a/server/Gemfile.lock
+++ b/server/Gemfile.lock
@@ -1760,10 +1760,7 @@ GEM
       multipart-post (~> 2)
     faraday-net_http (3.1.0)
       net-http
-    ffi (1.17.0-aarch64-linux-gnu)
     ffi (1.17.0-arm64-darwin)
-    ffi (1.17.0-x86_64-darwin)
-    ffi (1.17.0-x86_64-linux-gnu)
     fiber-annotation (0.2.0)
     fiber-local (1.1.0)
       fiber-storage
@@ -1895,7 +1892,7 @@ GEM
     msgpack (1.7.2)
     multi_json (1.15.0)
     multipart-post (2.4.1)
-    multiwoven-integrations (0.3.4)
+    multiwoven-integrations (0.3.5)
       activesupport
       async-websocket
       aws-sdk-athena
@@ -2095,7 +2092,7 @@ GEM
     ruby-progressbar (1.13.0)
     ruby2_keywords (0.0.5)
     rubyzip (2.3.2)
-    sequel (5.81.0)
+    sequel (5.82.0)
       bigdecimal
     shoulda-matchers (5.3.0)
       activesupport (>= 5.2.0)
@@ -2192,7 +2189,7 @@ DEPENDENCIES
   jwt
   kaminari
   liquid
-  multiwoven-integrations (~> 0.3.4)
+  multiwoven-integrations (~> 0.3.5)
   mysql2
   newrelic_rpm
   parallel
diff --git a/server/app/serializers/sync_record_serializer.rb b/server/app/serializers/sync_record_serializer.rb
index c4e46c9d..36a202ce 100644
--- a/server/app/serializers/sync_record_serializer.rb
+++ b/server/app/serializers/sync_record_serializer.rb
@@ -2,5 +2,5 @@
 
 class SyncRecordSerializer < ActiveModel::Serializer
   attributes :id, :sync_id, :sync_run_id, :record, :status, :action,
-             :error, :created_at, :updated_at
+             :logs, :created_at, :updated_at
 end
diff --git a/server/db/migrate/20240628122409_rename_error_to_logs_in_sync_records.rb b/server/db/migrate/20240628122409_rename_error_to_logs_in_sync_records.rb
new file mode 100644
index 00000000..3b263013
--- /dev/null
+++ b/server/db/migrate/20240628122409_rename_error_to_logs_in_sync_records.rb
@@ -0,0 +1,9 @@
+class RenameErrorToLogsInSyncRecords < ActiveRecord::Migration[7.1]
+  def up
+    safety_assured { rename_column :sync_records, :error, :logs }
+  end
+
+  def down
+    safety_assured { rename_column :sync_records, :logs , :error }
+  end
+end
diff --git a/server/db/schema.rb b/server/db/schema.rb
index aa80b336..24144932 100644
--- a/server/db/schema.rb
+++ b/server/db/schema.rb
@@ -10,7 +10,7 @@
 #
 # It's strongly recommended that you check this file into your version control system.
 
-ActiveRecord::Schema[7.1].define(version: 2024_06_14_140619) do
+ActiveRecord::Schema[7.1].define(version: 2024_06_28_122409) do
   # These are extensions that must be enabled in order to support this database
   enable_extension "plpgsql"
 
@@ -82,7 +82,7 @@
     t.integer "action"
     t.string "primary_key"
     t.integer "status", default: 0
-    t.jsonb "error"
+    t.jsonb "logs"
     t.index ["sync_id", "fingerprint"], name: "index_sync_records_on_sync_id_and_fingerprint", unique: true
     t.index ["sync_id", "primary_key"], name: "index_sync_records_on_sync_id_and_primary_key", unique: true
   end
diff --git a/server/lib/reverse_etl/loaders/standard.rb b/server/lib/reverse_etl/loaders/standard.rb
index b9b99d92..d84580c3 100644
--- a/server/lib/reverse_etl/loaders/standard.rb
+++ b/server/lib/reverse_etl/loaders/standard.rb
@@ -29,10 +29,6 @@ def process_individual_records(sync_run, sync, sync_config, activity)
         client = sync.destination.connector_client.new
 
         sync_run.sync_records.pending.find_in_batches do |sync_records|
-          # track sync record status
-          successfull_sync_records = []
-          failed_sync_records = []
-
           # concurrent request rate limit
           concurrency = sync_config.stream.request_rate_concurrency || THREAD_COUNT
 
@@ -41,11 +37,7 @@ def process_individual_records(sync_run, sync, sync_config, activity)
             record = transformer.transform(sync, sync_record)
             Rails.logger.info "sync_id = #{sync.id} sync_run_id = #{sync_run.id} sync_record = #{record}"
             report = handle_response(client.write(sync_config, [record], sync_record.action), sync_run)
-            if report.tracking.success.zero?
-              failed_sync_records << sync_record.id
-            else
-              successfull_sync_records << sync_record.id
-            end
+            update_sync_record_logs_and_status(report, sync_record)
           rescue Activities::LoaderActivity::FullRefreshFailed
             raise
           rescue StandardError => e
@@ -56,8 +48,6 @@ def process_individual_records(sync_run, sync, sync_config, activity)
             Rails.logger(e)
           end
 
-          update_sync_records_status(sync_run, successfull_sync_records, failed_sync_records)
-
           heartbeat(activity)
         end
       end
@@ -75,7 +65,6 @@ def process_batch_records(sync_run, sync, sync_config, activity)
                       in_threads: THREAD_COUNT) do |sync_records|
           transformed_records = sync_records.map { |sync_record| transformer.transform(sync, sync_record) }
           report = handle_response(client.write(sync_config, transformed_records), sync_run)
-          heartbeat(activity)
           if report.tracking.success.zero?
             failed_sync_records.concat(sync_records.map { |record| record["id"] }.compact)
           else
@@ -94,6 +83,7 @@ def process_batch_records(sync_run, sync, sync_config, activity)
           }.to_s)
         end
         update_sync_records_status(sync_run, successfull_sync_records, failed_sync_records)
+        heartbeat(activity)
       end
 
       def handle_response(report, sync_run)
@@ -114,6 +104,17 @@ def raise_non_retryable_error(report, sync_run)
         raise Activities::LoaderActivity::FullRefreshFailed, "Full refresh failed (non-retryable)"
       end
 
+      def update_sync_record_logs_and_status(report, sync_record)
+        status = report.tracking.success.zero? ? "failed" : "success"
+        sync_record.update(logs: get_sync_records_logs(report), status:)
+      end
+
+      def get_sync_records_logs(report)
+        return unless report.tracking.respond_to?(:logs) && report.tracking.logs&.first&.message.present?
+
+        JSON.parse(report.tracking.logs.first.message)
+      end
+
       def update_sync_records_status(sync_run, successfull_sync_records, failed_sync_records)
         sync_run.sync_records.where(id: successfull_sync_records).update_all(status: "success") # rubocop:disable Rails/SkipsModelValidations
         sync_run.sync_records.where(id: failed_sync_records).update_all(status: "failed") # rubocop:disable Rails/SkipsModelValidations
diff --git a/server/spec/lib/reverse_etl/loaders/standard_spec.rb b/server/spec/lib/reverse_etl/loaders/standard_spec.rb
index 78a65b4a..11ea4f1e 100644
--- a/server/spec/lib/reverse_etl/loaders/standard_spec.rb
+++ b/server/spec/lib/reverse_etl/loaders/standard_spec.rb
@@ -123,7 +123,14 @@
     context "when batch support is disabled" do
       tracker = Multiwoven::Integrations::Protocol::TrackingMessage.new(
         success: 1,
-        failed: 0
+        failed: 0,
+        logs: [
+          Multiwoven::Integrations::Protocol::LogMessage.new(
+            name: self.class.name,
+            level: "info",
+            message: { request: "Sample req", response: "Sample req", level: "info" }.to_json
+          )
+        ]
       )
       let(:transformer) { ReverseEtl::Transformers::UserMapping.new }
       let(:transform) { transformer.transform(sync_individual, sync_record_individual) }
@@ -138,6 +145,9 @@
         allow(sync_individual.destination.connector_client).to receive(:new).and_return(client)
         allow(client).to receive(:write).with(sync_config, [transform],
                                               "destination_insert").and_return(multiwoven_message)
+        expect(subject).to receive(:update_sync_record_logs_and_status)
+          .once.with(multiwoven_message, sync_run_individual.sync_records.first)
+          .and_call_original
         expect(subject).to receive(:heartbeat).once.with(activity)
         expect(sync_run_individual).to have_state(:queued)
         subject.write(sync_run_individual.id, activity)
@@ -298,5 +308,55 @@
         expect(sync_run_batch).to have_state(:failed)
       end
     end
+
+    context "when the report has tracking logs with a message" do
+      let(:log_message) { '{"request":"Sample log message"}' }
+      let(:report) do
+        double("Report", tracking: double("Tracking", logs: [double("Log", message: log_message)]))
+      end
+
+      it "returns the log message" do
+        expected_result = { "request" => "Sample log message" }
+        expect(subject.send(:get_sync_records_logs, report)).to eq(expected_result)
+      end
+    end
+
+    context "when the report has tracking logs without a message" do
+      let(:report) do
+        double("Report", tracking: double("Tracking", logs: [double("Log", message: nil)]))
+      end
+
+      it "returns nil" do
+        expect(subject.send(:get_sync_records_logs, report)).to be_nil
+      end
+    end
+
+    context "when the report has tracking logs but no logs present" do
+      let(:report) do
+        double("Report", tracking: double("Tracking", logs: []))
+      end
+
+      it "returns nil" do
+        expect(subject.send(:get_sync_records_logs, report)).to be_nil
+      end
+    end
+
+    context "when the report does not respond to logs" do
+      let(:report) { double("Report", tracking: double("Tracking")) }
+
+      it "returns nil" do
+        expect(subject.send(:get_sync_records_logs, report)).to be_nil
+      end
+    end
+
+    context "when the report has no tracking" do
+      let(:report) do
+        double("Report", tracking: double("Tracking", logs: nil))
+      end
+
+      it "returns nil" do
+        expect(subject.send(:get_sync_records_logs, report)).to be_nil
+      end
+    end
   end
 end
diff --git a/server/spec/requests/api/v1/sync_records_controller_spec.rb b/server/spec/requests/api/v1/sync_records_controller_spec.rb
index b905aa9e..94252262 100644
--- a/server/spec/requests/api/v1/sync_records_controller_spec.rb
+++ b/server/spec/requests/api/v1/sync_records_controller_spec.rb
@@ -20,7 +20,7 @@
   let!(:sync_records) do
     [
       create(:sync_record, sync:, sync_run:, status: "success", primary_key: "key1"),
-      create(:sync_record, sync:, sync_run:, status: "failed", primary_key: "key2", error: { message: "test" })
+      create(:sync_record, sync:, sync_run:, status: "failed", primary_key: "key2", logs: { message: "test" })
     ]
   end
   let(:viewer_role) { create(:role, :viewer) }
@@ -52,8 +52,8 @@
           expect(row.dig(:attributes, :action)).to eq(sync_record.action)
           expect(row.dig(:attributes, :status)).to eq(sync_record.status)
           if sync_record.status == "failed"
-            expect(row.dig(:attributes, :error)).to eq(sync_record.error)
-            expect { JSON.parse(row.dig(:attributes, :error).to_json) }.not_to raise_error
+            expect(row.dig(:attributes, :logs)).to eq(sync_record.logs)
+            expect { JSON.parse(row.dig(:attributes, :logs).to_json) }.not_to raise_error
           end
           expect(response_hash.dig(:links, :first)).to include("http://www.example.com/api/v1/syncs/#{sync.id}/sync_runs/#{sync_run.id}/sync_records?page=1")
         end
@@ -77,8 +77,8 @@
           expect(row.dig(:attributes, :action)).to eq(sync_record.action)
           expect(row.dig(:attributes, :status)).to eq(sync_record.status)
           if sync_record.status == "failed"
-            expect(row.dig(:attributes, :error)).to eq(sync_record.error)
-            expect { JSON.parse(row.dig(:attributes, :error).to_json) }.not_to raise_error
+            expect(row.dig(:attributes, :logs)).to eq(sync_record.logs)
+            expect { JSON.parse(row.dig(:attributes, :logs).to_json) }.not_to raise_error
           end
           expect(response_hash.dig(:links, :first)).to include("http://www.example.com/api/v1/syncs/#{sync.id}/sync_runs/#{sync_run.id}/sync_records?page=1")
         end
@@ -102,8 +102,8 @@
           expect(row.dig(:attributes, :action)).to eq(sync_record.action)
           expect(row.dig(:attributes, :status)).to eq(sync_record.status)
           if sync_record.status == "failed"
-            expect(row.dig(:attributes, :error)).to eq(sync_record.error)
-            expect { JSON.parse(row.dig(:attributes, :error).to_json) }.not_to raise_error
+            expect(row.dig(:attributes, :logs)).to eq(sync_record.logs)
+            expect { JSON.parse(row.dig(:attributes, :logs).to_json) }.not_to raise_error
           end
           expect(response_hash.dig(:links, :first)).to include("http://www.example.com/api/v1/syncs/#{sync.id}/sync_runs/#{sync_run.id}/sync_records?page=1")
         end

From a7971b45fce849c00d0acb7a255e29a240b61bc2 Mon Sep 17 00:00:00 2001
From: "github-actions[bot]"
 <41898282+github-actions[bot]@users.noreply.github.com>
Date: Fri, 5 Jul 2024 15:01:52 +0530
Subject: [PATCH 8/9] chore(CE): config jwt secret from env variable (#269)
 (#233)

Co-authored-by: datafloyd <subinthattaparambil@gmail.com>
---
 server/config/initializers/devise.rb | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/server/config/initializers/devise.rb b/server/config/initializers/devise.rb
index 7e604419..f39a24d4 100644
--- a/server/config/initializers/devise.rb
+++ b/server/config/initializers/devise.rb
@@ -360,7 +360,7 @@
   # changed. Defaults to true, so a user is signed in automatically after changing a password.
   # config.sign_in_after_change_password = true
   config.jwt do |jwt|
-    jwt.secret = 'ff49fe469ce501cbb07be03fd81e13a350bf55c27f213f75b0b0bbe3d1c79fd544ac863cb58af47841aecdf7f06e529b1016933c9aeb28c80848d4fde7f140e9'
+    jwt.secret = ENV.fetch("JWT_SECRET", "ff49fe469ce501cbb07be03fd81e13a350bf55c27f213f75b0b0bbe3d1c79fd544ac863cb58af47841aecdf7f06e529b1016933c9aeb28c80848d4fde7f140e9")
     jwt.dispatch_requests = [["POST", %r{^/api/v1/login$}]]
     jwt.revocation_requests = [["DELETE", %r{^/api/v1/logout$}]]
     jwt.expiration_time = 30.minutes.to_i

From b7ed6ad1bc14e6f1da54f6515c4834b6599d5651 Mon Sep 17 00:00:00 2001
From: "github-actions[bot]"
 <41898282+github-actions[bot]@users.noreply.github.com>
Date: Fri, 5 Jul 2024 20:40:01 +0530
Subject: [PATCH 9/9] feat(CE): added select row support to data table (#232)

Co-authored-by: Tushar Selvakumar <54372016+macintushar@users.noreply.github.com>
---
 ui/src/components/DataTable/Table.tsx | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/ui/src/components/DataTable/Table.tsx b/ui/src/components/DataTable/Table.tsx
index a6c9be65..f624e169 100644
--- a/ui/src/components/DataTable/Table.tsx
+++ b/ui/src/components/DataTable/Table.tsx
@@ -1,5 +1,6 @@
 import { Table, Tbody, Td, Th, Thead, Tr } from '@chakra-ui/react';
 import { flexRender, getCoreRowModel, useReactTable, ColumnDef } from '@tanstack/react-table';
+import { useState } from 'react';
 
 type DataTableProps<TData, TValue> = {
   columns: ColumnDef<TData, TValue>[];
@@ -7,10 +8,16 @@ type DataTableProps<TData, TValue> = {
 };
 
 const DataTable = <TData, TValue>({ data, columns }: DataTableProps<TData, TValue>) => {
+  const [rowSelection, setRowSelection] = useState({});
+
   const table = useReactTable({
     data,
     columns,
     getCoreRowModel: getCoreRowModel(),
+    onRowSelectionChange: setRowSelection,
+    state: {
+      rowSelection,
+    },
   });
 
   return (