require 'jsonapi/configuration' require 'jsonapi/resource_for' require 'jsonapi/association' module JSONAPI class Resource include ResourceFor @@resource_types = {} attr :context attr_reader :model def initialize(model, context = nil) @model = model @context = context end def remove @model.destroy end def create_has_many_link(association_type, association_key_value) association = self.class._associations[association_type] related_resource = self.class.resource_for(association.type).find_by_key(association_key_value, @context) # ToDo: Add option to skip relations that already exist instead of returning an error? relation = @model.send(association.type).where(association.primary_key => association_key_value).first if relation.nil? @model.send(association.type) << related_resource.model else raise JSONAPI::Exceptions::HasManyRelationExists.new(association_key_value) end end def replace_has_many_links(association_type, association_key_values) association = self.class._associations[association_type] @model.send("#{association.key}=", association_key_values) end def create_has_one_link(association_type, association_key_value) association = self.class._associations[association_type] # ToDo: Add option to skip relations that already exist instead of returning an error? relation = @model.send("#{association.key}") if relation.nil? @model.send("#{association.key}=", association_key_value) else raise JSONAPI::Exceptions::HasOneRelationExists.new end end def replace_has_one_link(association_type, association_key_value) association = self.class._associations[association_type] @model.send("#{association.key}=", association_key_value) end def remove_has_many_link(association_type, key) association = self.class._associations[association_type] @model.send(association.type).delete(key) end def remove_has_one_link(association_type) association = self.class._associations[association_type] @model.send("#{association.key}=", nil) end def replace_fields(field_data) field_data[:attributes].each do |attribute, value| send "#{attribute}=", value end field_data[:has_one].each do |association_type, value| if value.nil? remove_has_one_link(association_type) else replace_has_one_link(association_type, value) end end if field_data[:has_one] field_data[:has_many].each do |association_type, values| replace_has_many_links(association_type, values) end if field_data[:has_many] end def save @model.save! rescue ActiveRecord::RecordInvalid => e errors = [] e.record.errors.messages.each do |element| element[1].each do |message| errors.push(JSONAPI::Error.new( code: JSONAPI::VALIDATION_ERROR, status: :bad_request, title: "#{element[0]} - #{message}", detail: "can't be blank", path: "\\#{element[0]}")) end end raise JSONAPI::Exceptions::ValidationErrors.new(errors) end # Override this on a resource instance to override the fetchable keys def fetchable_fields self.class.fields end class << self def inherited(base) base._attributes = (_attributes || {}).dup base._associations = (_associations || {}).dup base._allowed_filters = (_allowed_filters || Set.new).dup type = base.name.demodulize.sub(/Resource$/, '').underscore base._type = type.pluralize.to_sym # If eager loading is on this is how all the resource types are setup # If eager loading is off some resource types will be initialized in # _resource_name_from_type @@resource_types[base._type] ||= base.name.demodulize end attr_accessor :_attributes, :_associations, :_allowed_filters , :_type def create(context) self.new(self.create_model, context) end def create_model _model_class.new end def routing_options(options) @_routing_resource_options = options end def routing_resource_options @_routing_resource_options ||= {} end # Methods used in defining a resource class def attributes(*attrs) attrs.each do |attr| attribute(attr) end end def attribute(attr, options = {}) @_attributes[attr] = options define_method attr do @model.send(attr) end unless method_defined?(attr) define_method "#{attr}=" do |value| @model.send "#{attr}=", value end unless method_defined?("#{attr}=") end def default_attribute_options {format: :default} end def has_one(*attrs) _associate(Association::HasOne, *attrs) end def has_many(*attrs) _associate(Association::HasMany, *attrs) end def model_name(model) @_model_name = model.to_sym end def filters(*attrs) @_allowed_filters.merge(attrs) end def filter(attr) @_allowed_filters.add(attr.to_sym) end def key(key) @_key = key.to_sym end # Override in your resource to filter the updateable keys def updateable_fields(context = nil) _updateable_associations | _attributes.keys end # Override in your resource to filter the createable keys def createable_fields(context = nil) _updateable_associations | _attributes.keys end def fields _associations.keys | _attributes.keys end # Override this method if you have more complex requirements than this basic find method provides def find(filters, context = nil) includes = [] where_filters = {} filters.each do |filter, value| if _associations.include?(filter) if _associations[filter].is_a?(JSONAPI::Association::HasMany) includes.push(filter) where_filters["#{filter}.#{_associations[filter].primary_key}"] = value else where_filters["#{_associations[filter].key}"] = value end else where_filters[filter] = value end end resources = [] _model_class.where(where_filters).includes(includes).each do |model| resources.push self.new(model, context) end return resources end def find_by_key(key, context = nil) model = _model_class.where({_key => key}).first if model.nil? raise JSONAPI::Exceptions::RecordNotFound.new(key) end self.new(model, context) end def verify_filters(filters, context = nil) verified_filters = {} filters.each do |filter, raw_value| verified_filter = verify_filter(filter, raw_value, context) verified_filters[verified_filter[0]] = verified_filter[1] end verified_filters end def is_filter_association?(filter) filter == _type || _associations.include?(filter) end def verify_filter(filter, raw, context = nil) filter_values = [] filter_values += CSV.parse_line(raw) unless raw.nil? || raw.empty? if is_filter_association?(filter) verify_association_filter(filter, filter_values, context) else verify_custom_filter(filter, filter_values, context) end end # override to allow for key processing and checking def verify_key(key, context = nil) return key end # override to allow for custom filters def verify_custom_filter(filter, value, context = nil) return filter, value end # override to allow for custom association logic, such as uuids, multiple keys or permission checks on keys def verify_association_filter(filter, raw, context = nil) return filter, raw end # quasi private class methods def _attribute_options(attr) default_attribute_options.merge(@_attributes[attr]) end def _updateable_associations associations = [] @_associations.each do |key, association| if association.is_a?(JSONAPI::Association::HasOne) || association.acts_as_set associations.push(key) end end associations end def _has_association?(type) type = type.to_s @_associations.has_key?(type.singularize.to_sym) || @_associations.has_key?(type.pluralize.to_sym) end def _association(type) type = type.to_sym @_associations[type] end def _model_name @_model_name ||= self.name.demodulize.sub(/Resource$/, '') end def _key @_key ||= :id end def _as_parent_key @_as_parent_key ||= "#{_type.to_s.singularize}_#{_key}" end def _allowed_filters !@_allowed_filters.nil? ? @_allowed_filters : Set.new([_key]) end def _resource_name_from_type(type) class_name = @@resource_types[type] if class_name.nil? class_name = type.to_s.singularize.camelize + 'Resource' @@resource_types[type] = class_name end return class_name end if RUBY_VERSION >= '2.0' def _model_class @model ||= Object.const_get(_model_name) end else def _model_class @model ||= _model_name.to_s.safe_constantize end end def _allowed_filter?(filter) _allowed_filters.include?(filter) end private def _associate(klass, *attrs) options = attrs.extract_options! attrs.each do |attr| @_associations[attr] = klass.new(attr, options) if @_associations[attr].is_a?(JSONAPI::Association::HasOne) key = @_associations[attr].key define_method key do @model.method(key).call end unless method_defined?(key) define_method "_#{attr}_resource" do type_name = self.class._associations[attr].type resource_class = self.class.resource_for(type_name) if resource_class associated_model = @model.send attr return resource_class.new(associated_model, @context) end end unless method_defined?("_#{attr}_resource") elsif @_associations[attr].is_a?(JSONAPI::Association::HasMany) key = @_associations[attr].key define_method key do @model.method(key).call end unless method_defined?(key) define_method "_#{attr}_resources" do type_name = self.class._associations[attr].type resource_class = self.class.resource_for(type_name) resources = [] if resource_class associated_models = @model.send attr associated_models.each do |associated_model| resources.push resource_class.new(associated_model, @context) end end return resources end unless method_defined?("_#{attr}_resources") end end end end end end