module JSONAPI
  class ResourceSerializer

    attr_reader :link_builder, :key_formatter, :serialization_options, :primary_class_name

    # initialize
    # Options can include
    # include:
    #     Purpose: determines which objects will be side loaded with the source objects in a linked section
    #     Example: ['comments','author','comments.tags','author.posts']
    # fields:
    #     Purpose: determines which fields are serialized for a resource type. This encompasses both attributes and
    #              relationship ids in the links section for a resource. Fields are global for a resource type.
    #     Example: { people: [:id, :email, :comments], posts: [:id, :title, :author], comments: [:id, :body, :post]}
    # key_formatter: KeyFormatter instance to override the default configuration
    # serializer_options: additional options that will be passed to resource meta and links lambdas

    def initialize(primary_resource_klass, options = {})
      @primary_class_name = primary_resource_klass._type
      @fields             = options.fetch(:fields, {})
      @include            = options.fetch(:include, [])
      @include_directives = options[:include_directives]
      @key_formatter      = options.fetch(:key_formatter, JSONAPI.configuration.key_formatter)
      @id_formatter       = ValueFormatter.value_formatter_for(:id)
      @link_builder       = generate_link_builder(primary_resource_klass, options)
      @always_include_to_one_linkage_data = options.fetch(:always_include_to_one_linkage_data,
                                                          JSONAPI.configuration.always_include_to_one_linkage_data)
      @always_include_to_many_linkage_data = options.fetch(:always_include_to_many_linkage_data,
                                                           JSONAPI.configuration.always_include_to_many_linkage_data)
      @serialization_options = options.fetch(:serialization_options, {})

      # Warning: This makes ResourceSerializer non-thread-safe. That's not a problem with the
      # request-specific way it's currently used, though.
      @value_formatter_type_cache = NaiveCache.new{|arg| ValueFormatter.value_formatter_for(arg) }
    end

    # Converts a single resource, or an array of resources to a hash, conforming to the JSONAPI structure
    def serialize_to_hash(source)
      @top_level_sources = Set.new([source].flatten.compact.map {|s| top_level_source_key(s) })

      is_resource_collection = source.respond_to?(:to_ary)

      @included_objects = {}
      @include_directives ||= JSONAPI::IncludeDirectives.new(@include)

      process_primary(source, @include_directives.include_directives)

      included_objects = []
      primary_objects = []
      @included_objects.each_value do |objects|
        objects.each_value do |object|
          if object[:primary]
            primary_objects.push(object[:object_hash])
          else
            included_objects.push(object[:object_hash])
          end
        end
      end

      primary_hash = { data: is_resource_collection ? primary_objects : primary_objects[0] }

      primary_hash[:included] = included_objects if included_objects.size > 0
      primary_hash
    end

    def serialize_to_links_hash(source, requested_relationship)
      if requested_relationship.is_a?(JSONAPI::Relationship::ToOne)
        data = to_one_linkage(source, requested_relationship)
      else
        data = to_many_linkage(source, requested_relationship)
      end

      {
        links: {
          self: self_link(source, requested_relationship),
          related: related_link(source, requested_relationship)
        },
        data: data
      }
    end

    def query_link(query_params)
      link_builder.query_link(query_params)
    end

    def format_key(key)
      @key_formatter.format(key)
    end

    def format_value(value, format)
      @value_formatter_type_cache.get(format).format(value)
    end

    private

    # Process the primary source object(s). This will then serialize associated object recursively based on the
    # requested includes. Fields are controlled fields option for each resource type, such
    # as fields: { people: [:id, :email, :comments], posts: [:id, :title, :author], comments: [:id, :body, :post]}
    # The fields options controls both fields and included links references.
    def process_primary(source, include_directives)
      if source.respond_to?(:to_ary)
        source.each { |resource| process_primary(resource, include_directives) }
      else
        return {} if source.nil?

        resource = source
        id = resource.id
        add_included_object(id, object_hash(source, include_directives), true)
      end
    end

    # Returns a serialized hash for the source model
    def object_hash(source, include_directives)
      obj_hash = {}

      id_format = source.class._attribute_options(:id)[:format]
      # protect against ids that were declared as an attribute, but did not have a format set.
      id_format = 'id' if id_format == :default
      obj_hash['id'] = format_value(source.id, id_format)

      obj_hash['type'] = format_key(source.class._type.to_s)

      links = links_hash(source)
      obj_hash['links'] = links unless links.empty?

      attributes = attributes_hash(source)
      obj_hash['attributes'] = attributes unless attributes.empty?

      relationships = relationships_hash(source, include_directives)
      obj_hash['relationships'] = relationships unless relationships.nil? || relationships.empty?

      meta = meta_hash(source)
      obj_hash['meta'] = meta unless meta.empty?

      obj_hash
    end

    def requested_fields(klass)
      return if @fields.nil? || @fields.empty?
      if @fields[klass._type]
        @fields[klass._type]
      elsif klass.superclass != JSONAPI::Resource
        requested_fields(klass.superclass)
      end
    end

    def attributes_hash(source)
      requested = requested_fields(source.class)
      fields = source.fetchable_fields & source.class._attributes.keys.to_a
      fields = requested & fields unless requested.nil?

      fields.each_with_object({}) do |name, hash|
        format = source.class._attribute_options(name)[:format]
        unless name == :id
          hash[format_key(name)] = format_value(source.public_send(name), format)
        end
      end
    end

    def custom_generation_options
      {
        serializer: self,
        serialization_options: @serialization_options
      }
    end

    def meta_hash(source)
      meta = source.meta(custom_generation_options)
      (meta.is_a?(Hash) && meta) || {}
    end

    def links_hash(source)
      {
        self: link_builder.self_link(source)
      }.merge(custom_links_hash(source)).compact
    end

    def custom_links_hash(source)
      custom_links = source.custom_links(custom_generation_options)
      (custom_links.is_a?(Hash) && custom_links) || {}
    end

    def top_level_source_key(source)
      "#{source.class}_#{source.id}"
    end

    def self_referential_and_already_in_source(resource)
      resource && @top_level_sources.include?(top_level_source_key(resource))
    end

    def relationships_hash(source, include_directives)
      relationships = source.class._relationships
      requested = requested_fields(source.class)
      fields = relationships.keys
      fields = requested & fields unless requested.nil?

      field_set = Set.new(fields)

      included_relationships = source.fetchable_fields & relationships.keys

      data = {}

      relationships.each_with_object(data) do |(name, relationship), hash|
        if included_relationships.include? name
          ia = include_directives[:include_related][name]

          include_linkage = ia && ia[:include]
          include_linked_children = ia && !ia[:include_related].empty?
          resources = (include_linkage || include_linked_children) && [source.public_send(name)].flatten.compact

          if field_set.include?(name)
            hash[format_key(name)] = link_object(source, relationship, include_linkage)
          end

          # If the object has been serialized once it will be in the related objects list,
          # but it's possible all children won't have been captured. So we must still go
          # through the relationships.
          if include_linkage || include_linked_children
            resources.each do |resource|
              next if self_referential_and_already_in_source(resource)
              id = resource.id
              relationships_only = already_serialized?(relationship.type, id)
              if include_linkage && !relationships_only
                add_included_object(id, object_hash(resource, ia))
              elsif include_linked_children || relationships_only
                relationships_hash(resource, ia)
              end
            end
          end
        end
      end
    end

    def already_serialized?(type, id)
      type = format_key(type)
      @included_objects.key?(type) && @included_objects[type].key?(id)
    end

    def self_link(source, relationship)
      link_builder.relationships_self_link(source, relationship)
    end

    def related_link(source, relationship)
      link_builder.relationships_related_link(source, relationship)
    end

    def to_one_linkage(source, relationship)
      linkage = {}
      linkage_id = foreign_key_value(source, relationship)

      if linkage_id
        linkage[:type] = format_key(relationship.type_for_source(source))
        linkage[:id] = linkage_id
      else
        linkage = nil
      end
      linkage
    end

    def to_many_linkage(source, relationship)
      linkage = []
      linkage_types_and_values = foreign_key_types_and_values(source, relationship)

      linkage_types_and_values.each do |type, value|
        linkage.append({type: format_key(type), id: value})
      end
      linkage
    end

    def link_object_to_one(source, relationship, include_linkage)
      include_linkage = include_linkage | @always_include_to_one_linkage_data | relationship.always_include_linkage_data
      link_object_hash = {}
      link_object_hash[:links] = {}
      link_object_hash[:links][:self] = self_link(source, relationship)
      link_object_hash[:links][:related] = related_link(source, relationship)
      link_object_hash[:data] = to_one_linkage(source, relationship) if include_linkage
      link_object_hash
    end

    def link_object_to_many(source, relationship, include_linkage)
      include_linkage = include_linkage | relationship.always_include_linkage_data
      link_object_hash = {}
      link_object_hash[:links] = {}
      link_object_hash[:links][:self] = self_link(source, relationship)
      link_object_hash[:links][:related] = related_link(source, relationship)
      link_object_hash[:data] = to_many_linkage(source, relationship) if include_linkage
      link_object_hash
    end

    def link_object(source, relationship, include_linkage = false)
      if relationship.is_a?(JSONAPI::Relationship::ToOne)
        link_object_to_one(source, relationship, include_linkage)
      elsif relationship.is_a?(JSONAPI::Relationship::ToMany)
        link_object_to_many(source, relationship, include_linkage)
      end
    end

    # Extracts the foreign key value for a to_one relationship.
    def foreign_key_value(source, relationship)
      foreign_key = relationship.foreign_key
      value = source.public_send(foreign_key)
      @id_formatter.format(value)
    end

    def foreign_key_types_and_values(source, relationship)
      if relationship.is_a?(JSONAPI::Relationship::ToMany)
        if relationship.polymorphic?
          assoc = source._model.public_send(relationship.name)
          # Avoid hitting the database again for values already pre-loaded
          if assoc.respond_to?(:loaded?) and assoc.loaded?
            assoc.map do |obj|
              [obj.type.underscore.pluralize, @id_formatter.format(obj.id)]
            end
          else
            assoc.pluck(:type, :id).map do |type, id|
              [type.underscore.pluralize, @id_formatter.format(id)]
            end
          end
        else
          source.public_send(relationship.foreign_key).map do |value|
            [relationship.type, @id_formatter.format(value)]
          end
        end
      end
    end

    # Sets that an object should be included in the primary document of the response.
    def set_primary(type, id)
      type = format_key(type)
      @included_objects[type][id][:primary] = true
    end

    # Collects the hashes for all objects processed by the serializer
    def add_included_object(id, object_hash, primary = false)
      type = object_hash['type']

      @included_objects[type] = {} unless @included_objects.key?(type)

      if already_serialized?(type, id)
        @included_objects[type][id][:object_hash].merge!(object_hash)
        set_primary(type, id) if primary
      else
        @included_objects[type].store(id, primary: primary, object_hash: object_hash)
      end
    end

    def generate_link_builder(primary_resource_klass, options)
      LinkBuilder.new(
        base_url: options.fetch(:base_url, ''),
        route_formatter: options.fetch(:route_formatter, JSONAPI.configuration.route_formatter),
        primary_resource_klass: primary_resource_klass,
      )
    end
  end
end