class Multiwoven::Integrations::Core::UnstructuredSourceConnector

def create_unstructured_stream
  Multiwoven::Integrations::Protocol::Stream.new(
    name: UNSTRUCTURED,
    action: StreamAction["fetch"],
    json_schema: UNSTRUCTURED_SCHEMA,
    **UNSTRUCTURED_STREAM_CONFIG
  )
end

def unstructured_data?(connection_config)
  connection_config["data_type"] == UNSTRUCTURED
end