Contents

# frozen_string_literal: true

require "dry/struct"
require "http"
require "active_support/core_ext/hash"

module PuppeteerEntity
  class Base < Dry::Struct
    attribute? :browserless_url, Types::URL.default { ENV["BROWSERLESS_URL"] }
    attribute? :retry_limit, Types::Integer.default { 3 }

    attributes_from Attributes::Query

    def response
      url = url_with_query_params
      json = as_body_json
      retries = 0
      begin
        HTTP.headers(response_headers)
            .post(url, json:)
            .tap do |res|
          raise RequestError.new(res.body.to_s) unless res.status.success?
        rescue RequestError => e
          retries = retries + 1
          retries > retry_limit ? raise(e) : retry
        end
      end
    end

    private

    def response_headers
      {
        content_type: "application/json"
      }
    end

    def browserless_uri
      raise NotImplementedError
    end

    def url_with_query_params
      browserless_uri.tap do |uri|
        uri.query = URI.encode_www_form(as_query_params)
      end.to_s
    end

    def as_query_params
      to_h
        .slice(*Attributes::Query.attribute_names)
        .reject { |_, v| v.blank? }
        .deep_stringify_keys
        .deep_transform_keys { |k| k.camelcase(:lower) }
    end

    def as_body_json
      raise NotImplementedError
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
puppeteer_entity-0.1.1	lib/puppeteer_entity/base.rb
puppeteer_entity-0.1.0	lib/puppeteer_entity/base.rb