require 'nokogiri'
require 'json'
require 'ostruct'
require 'set'
require 'kconv'
require 'uri'
require 'http/cookie'

# https://github.com/taganaka/polipus/blob/master/lib/polipus/page.rb
module Digger
  class Page
    attr_reader :url
    # The raw HTTP response body of the page
    attr_reader :body
    # Headers of the HTTP response
    attr_reader :headers
    # URL of the page this one redirected to, if any
    attr_reader :redirect_to
    # Exception object, if one was raised during HTTP#fetch_page
    attr_reader :error
    # Integer response code of the page
    attr_accessor :code
    # Depth of this page from the root of the crawl.
    attr_accessor :depth
    # URL of the page that brought us to this page
    attr_accessor :referer
    # Response time of the request for this page in milliseconds
    attr_accessor :response_time
    # OpenStruct it holds users defined data
    attr_accessor :user_data

    attr_accessor :aliases, :domain_aliases, :fetched_at

    # Whether the current page should be stored
    # Default: true
    attr_accessor :storable

    #
    # Create a new page
    #
    def initialize(url, params = {})
      @url = URI(url)
      @code = params[:code]
      @headers = params[:headers] || {}
      @headers['content-type'] ||= ['']
      @aliases = Array(params[:aka]).compact
      @referer = params[:referer]
      @depth = params[:depth] || 0
      @redirect_to = to_absolute(params[:redirect_to])
      @response_time = params[:response_time]
      @body = params[:body]
      @error = params[:error]
      @fetched = !params[:code].nil?
      @user_data = OpenStruct.new
      @domain_aliases = params[:domain_aliases] ||= []
      @storable = true
      @fetched_at = params[:fetched_at]
    end

    def title
      doc&.title
    end

    #
    # Array of distinct A tag HREFs from the page
    #
    def links
      unless @links.nil?
        @links = Set.new
        return [] unless doc

        doc.search('//a[@href]').each do |a|
          u = a['href']
          next if u.nil? || u.empty?

          abs = to_absolute(u) rescue next
          @links << abs if abs && in_domain?(abs)
        end
      end
      @links.to_a
    end

    #
    # Nokogiri document for the HTML body
    #
    def doc
      # return @doc if @doc
      # @body ||= ''
      # @body = @body.encode('utf-8', 'binary', :invalid => :replace,
      #                      :undef => :replace, :replace => '')
      # @doc = Nokogiri::HTML(@body.toutf8, nil, 'utf-8') if @body && html?
      @doc ||= begin
        Nokogiri::HTML(body) if !body.nil? && html? rescue nil
      end
    end

    def json
      @json ||= JSON.parse body
    end

    def jsonp
      @jsonp ||= JSON.parse body.match(/^[^(]+?\((.+)\)[^)]*$/)[1]
    end

    def cookies
      @cookies ||= (headers['set-cookie'] || []).flat_map { |c| ::HTTP::Cookie.parse(c, url) }
    end

    #
    # Discard links, a next call of page.links will return an empty array
    #
    def discard_links!
      @links = []
    end

    #
    # Delete the Nokogiri document and response body to conserve memory
    #
    def discard_doc!
      links # force parsing of page links before we trash the document
      @doc = @body = nil
    end

    #
    # Was the page successfully fetched?
    # +true+ if the page was fetched with no error, +false+ otherwise.
    #
    def fetched?
      @fetched
    end

    #
    # The content-type returned by the HTTP request for this page
    #
    def content_type
      headers['content-type'].first
    end

    #
    # Returns +true+ if the page is a HTML document, returns +false+
    # otherwise.
    #
    def html?
      content_type =~ %r{^(text/html|application/xhtml+xml)\b}
    end

    #
    # Returns +true+ if the page is a HTTP redirect, returns +false+
    # otherwise.
    #
    def redirect?
      (300...400).include?(@code)
    end

    #
    # Returns +true+ if the page is a HTTP success, returns +false+
    # otherwise.
    #
    def success?
      (200..206).include?(@code)
    end

    #
    # Returns +true+ if the page was not found (returned 404 code),
    # returns +false+ otherwise.
    #
    def not_found?
      @code == 404
    end

    #
    # Base URI from the HTML doc head element
    # http://www.w3.org/TR/html4/struct/links.html#edef-BASE
    #
    def base
      @base = if doc
                href = doc.search('//head/base/@href')
                URI(href.to_s) unless href.nil? rescue nil
              end unless @base

      return nil if @base && @base.to_s.empty?

      @base
    end

    #
    # Converts relative URL *link* into an absolute URL based on the
    # location of the page
    #
    def to_absolute(link)
      return nil if link.nil?

      link = link.to_s.encode('utf-8', 'binary', invalid: :replace, undef: :replace, replace: '').gsub(/#[\w]*$/, '')
      relative = begin
                   URI(link)
                 rescue URI::Error
                   return nil
                 end
      absolute = base ? base.merge(relative) : @url.merge(relative)

      absolute.path = '/' if absolute.path.empty?

      absolute
    end

    #
    # Returns +true+ if *uri* is in the same domain as the page, returns
    # +false+ otherwise
    #
    def in_domain?(uri)
      @domain_aliases ||= []
      uri.host == @url.host || @domain_aliases.include?(uri.host)
    end

    def to_hash
      {
        'url'           => @url.to_s,
        'headers'       => Marshal.dump(@headers),
        'body'          => @body,
        'links'         => links.map(&:to_s),
        'code'          => @code,
        'depth'         => @depth,
        'referer'       => @referer.to_s,
        'redirect_to'   => @redirect_to.to_s,
        'response_time' => @response_time,
        'fetched'       => @fetched,
        'user_data'     => @user_data.nil? ? {} : @user_data.marshal_dump,
        'fetched_at'    => @fetched_at,
        'error'         => @error.to_s
      }
    end

    def to_json
      th = to_hash.dup
      th.each { |k, v| th.delete(k) if v.nil? || (v.respond_to?(:empty?) && v.empty?) }
      th.delete('headers') if content_type.empty?
      th.to_json
    end

    #
    # Returns +true+ if page is marked as storeable
    # +false+ otherwise
    # Default is +true+
    #
    def storable?
      @storable
    end

    def expired?(ttl)
      return false if fetched_at.nil?

      (Time.now.to_i - ttl) > fetched_at
    end

    def self.from_hash(hash)
      page = new(URI(hash['url']))
      {
        '@headers'       => hash['headers'] && !hash['headers'].empty? ? Marshal.load(hash['headers']) : { 'content-type' => [''] },
        '@body'          => hash['body'],
        '@links'         => hash['links'] ? hash['links'].map { |link| URI(link) } : [],
        '@code'          => hash['code'].to_i,
        '@depth'         => hash['depth'].to_i,
        '@referer'       => hash['referer'],
        '@redirect_to'   => (hash['redirect_to'] && !hash['redirect_to'].empty?) ? URI(hash['redirect_to']) : nil,
        '@response_time' => hash['response_time'].to_i,
        '@fetched'       => hash['fetched'],
        '@user_data'     => hash['user_data'] ? OpenStruct.new(hash['user_data']) : nil,
        '@fetched_at'    => hash['fetched_at'],
        '@error'         => hash['error']
      }.each do |var, value|
        page.instance_variable_set(var, value)
      end
      page
    end

    def self.from_json(json)
      hash = JSON.parse json
      from_hash hash
    end
  end
end