class Multiwoven::Integrations::Source::Odoo::Client

def create_streams(connection_config, models)
  models.map do |model|
    fields = @client.execute_kw(connection_config[:database], @uid, connection_config[:password],
                                model["model"], "fields_get", [], { 'attributes': %w[name type] })
    Multiwoven::Integrations::Protocol::Stream.new(name: model["model"], action: StreamAction["fetch"],
                                                   supported_sync_modes: %w[incremental], json_schema: convert_to_json_schema(fields))
  end
end