class Multiwoven::Integrations::Core::SourceConnector

def batched_query(sql_query, limit, offset)
  offset = offset.to_i
  limit = limit.to_i
  raise ArgumentError, "Offset and limit must be non-negative" if offset.negative? || limit.negative?
  # Removing any trailing semicolons
  sql_query.chomp!(";")
  # Checking if the query already has a LIMIT clause
  raise ArgumentError, "Query already contains a LIMIT clause" if sql_query.match?(/LIMIT \d+/i)
  # Appending the LIMIT and OFFSET clauses to the SQL query
  "#{sql_query} LIMIT #{limit} OFFSET #{offset}"
end

def create_connection(connector_config)
  # return a connection to the client's source
end

def query(connection, query)
  # return list of RecordMessage
end

def read(_sync_config)
  raise "Not implemented"
  # setup sync configs
  # call query(connection, query)
  # Returns list of RecordMessage
end

def send_request(options = {})
  Multiwoven::Integrations::Core::HttpClient.request(
    options[:url],
    options[:http_method],
    payload: options[:payload],
    headers: options[:headers],
    config: options[:config]
  )
end

def send_streaming_request(options = {})
  Multiwoven::Integrations::Core::StreamingHttpClient.request(
    options[:url],
    options[:http_method],
    payload: options[:payload],
    headers: options[:headers],
    config: options[:config]
  ) do |chunk|
    yield chunk if block_given? # Pass each chunk for processing (streaming response)
  end
end