feat(CE): refactor google drive source connector (#895)

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

* chore(CE): Resolved conflict

---------

Co-authored-by: Rafael E. O'Neill <106079170+RafaelOAiSquared@users.noreply.github.com>
Co-authored-by: TivonB-AI2 <tivon.brown@squared.ai>

Author: 3 people

integrations/Gemfile.lock

@@ -7,7 +7,7 @@ GIT
 PATH
   remote: .
   specs:
-    multiwoven-integrations (0.34.8)
+    multiwoven-integrations (0.34.9)
       MailchimpMarketing
       activesupport
       async-websocket

integrations/lib/multiwoven/integrations/core/unstructured_source_connector.rb

@@ -30,15 +30,22 @@ class UnstructuredSourceConnector < SourceConnector
         source_defined_primary_key: [["element_id"]]
       }.freeze
 
-      # Commands for unstructured data operations
+      # Data types
       UNSTRUCTURED = "unstructured"
+      SEMISTRUCTURED = "semistructured"
+
+      # Commands for unstructured & semi-structured data operations
       LIST_FILES_CMD = "list_files"
       DOWNLOAD_FILE_CMD = "download_file"
 
       def unstructured_data?(connection_config)
         connection_config["data_type"] == UNSTRUCTURED
       end
 
+      def semistructured_data?(connection_config)
+        connection_config["data_type"] == SEMISTRUCTURED
+      end
+
       def create_unstructured_stream
         Multiwoven::Integrations::Protocol::Stream.new(
           name: UNSTRUCTURED,
@@ -47,6 +54,15 @@ def create_unstructured_stream
           **UNSTRUCTURED_STREAM_CONFIG
         )
       end
+
+      def create_semistructured_stream
+        Multiwoven::Integrations::Protocol::Stream.new(
+          name: SEMISTRUCTURED,
+          action: StreamAction["fetch"],
+          json_schema: UNSTRUCTURED_SCHEMA,
+          **UNSTRUCTURED_STREAM_CONFIG
+        )
+      end
     end
   end
 end

integrations/lib/multiwoven/integrations/rollout.rb

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