Module: Dhall::Resolvers

Defined in:

lib/dhall/resolve.rb

Defined Under Namespace

Modules: NoCache Classes: Default, LocalOnly, None, RamCache, ReadPathAndIPFSSources, ResolutionSet, SourceWithDeadline, Standard, StandardFileCache

Constant Summary

ReadPathSources =

lambda do |sources|
  sources.map do |source|
    Promise.resolve(nil).then { source.pathname.binread }
  end
end

ReadEnvironmentSources =

lambda do |sources|
  sources.map do |source|
    Promise.resolve(nil).then do
      ENV.fetch(source.var) do
        raise ImportFailedException, "No #{source}"
      end
    end
  end
end

PreflightCORS =

lambda do |source, parent_origin|
  timeout = source.deadline.timeout
  uri = source.uri
  if parent_origin != "localhost" && parent_origin != source.origin
    req = Net::HTTP::Options.new(uri)
    req["Origin"] = parent_origin
    req["Access-Control-Request-Method"] = "GET"
    req["Access-Control-Request-Headers"] =
      source.headers.to_a.map { |h|
        (h.fetch("header") { h.fetch("mapKey") }).to_s
      }.join(",")
    r = Util.net_http_req_with_timeout(uri, req, timeout: timeout)

    raise ImportFailedException, source if r.code != "200"
    unless r["Access-Control-Allow-Origin"] == parent_origin ||
           r["Access-Control-Allow-Origin"] == "*"
      raise ImportBannedException, source
    end
  end
end

ReadHttpSources =

lambda do |sources, parent_origin|
  sources.map do |source|
    Promise.resolve(nil).then do
      PreflightCORS.call(source, parent_origin)
      timeout = source.deadline.timeout
      uri = source.uri
      r = loop do
        req = Net::HTTP::Get.new(uri)
        source.headers.each do |header|
          req[(header.fetch("header") { header.fetch("mapKey") }).to_s] =
            (header.fetch("value") { header.fetch("mapValue") }).to_s
        end
        r = Util.net_http_req_with_timeout(uri, req, timeout: timeout)

        break r unless ["301", "302", "303", "307", "308"].include?(r.code)
        uri = URI(r["Location"])
      end

      raise ImportFailedException, source if r.code != "200"
      r.body
    end
  end
end

StandardReadHttpSources =

lambda do |sources, parent_origin|
  ReadHttpSources.call(sources, parent_origin).map do |source_promise|
    source_promise.then do |s|
      s = s.dup.force_encoding("UTF-8")
      unless s.valid_encoding?
        raise ImportFailedException, "#{s.inspect} is not valid UTF-8"
      end
      s
    end
  end
end

RejectSources =

lambda do |sources|
  sources.map do |source|
    Promise.new.reject(ImportBannedException.new(source))
  end
end