Merge pull request #50 from Multiwoven/fix/source-defined-curser-default-false

fix: source_defined_cursor default value to false in stream

Author: afthabvp

integrations/Gemfile.lock

@@ -7,7 +7,7 @@ GIT
 PATH
   remote: .
   specs:
-    multiwoven-integrations (0.1.58)
+    multiwoven-integrations (0.1.59)
       activesupport
       async-websocket
       csv

integrations/lib/multiwoven/integrations/protocol/protocol.rb

@@ -115,7 +115,7 @@ class Stream < ProtocolModel
       attribute? :supported_sync_modes, Types::Array.of(SyncMode).optional.default(["incremental"])
 
       # Applicable for database streams
-      attribute? :source_defined_cursor, Types::Bool.default(false).optional
+      attribute :source_defined_cursor, Types::Bool.default(false)
       attribute? :default_cursor_field, Types::Array.of(Types::String).optional
       attribute? :source_defined_primary_key, Types::Array.of(Types::Array.of(Types::String)).optional
       attribute? :namespace, Types::String.optional

integrations/lib/multiwoven/integrations/rollout.rb

@@ -2,7 +2,7 @@
 
 module Multiwoven
   module Integrations
-    VERSION = "0.1.58"
+    VERSION = "0.1.59"
 
     ENABLED_SOURCES = %w[
       Snowflake

integrations/lib/multiwoven/integrations/source/salesforce_consumer_goods_cloud/schema_helper.rb

@@ -118,7 +118,9 @@ def create_json_schema_for_object(metadata)
               "json_schema": json_schema,
               "required": required,
               "supported_sync_modes": %w[incremental],
-              "source_defined_primary_key": [primary_key]
+              "source_defined_primary_key": [primary_key],
+              "source_defined_cursor": false,
+              "default_cursor_field": nil
             }
           end
         end

integrations/spec/multiwoven/integrations/source/salesforce_consumer_goods/schema_helper_spec.rb

@@ -45,6 +45,8 @@
       expect(result[:json_schema]).to be_a(Hash)
       expect(result[:required]).to contain_exactly("Field1")
       expect(result[:supported_sync_modes]).to contain_exactly("incremental")
+      expect(result[:source_defined_cursor]).to eq(false)
+      expect(result[:default_cursor_field]).to eq(nil)
     end
   end
 end