class Multiwoven::Integrations::Destination::MicrosoftExcel::Client

def create_streams(records, catalog_json)
  group_by_table(records).flat_map do |_, record|
    record.map do |_, r|
      Multiwoven::Integrations::Protocol::Stream.new(
        name: r[:workbook],
        action: StreamAction["fetch"],
        json_schema: convert_to_json_schema(r[:columns]),
        request_rate_limit: catalog_json["request_rate_limit"] || 60,
        request_rate_limit_unit: catalog_json["request_rate_limit_unit"] || "minute",
        request_rate_concurrency: catalog_json["request_rate_concurrency"] || 1
      )
    end
  end
end