module Roda::RodaPlugins::ReeActions::ClassMethods

def build_actions_proc
  list = []
  context = self
  return list if @ree_actions.nil? || @ree_actions.empty?
  if context.opts[:ree_actions_swagger_url]
    list << Proc.new do |r|
      r.get context.opts[:ree_actions_swagger_url] do
        r.json do
          response.status = 200
          ReeJson::ToJson.new.call(context.opts[:ree_actions_swagger])
        end
      end
    end
  end
  @ree_actions.each do |action|
    route = []
    route_args = []
    action.path.split("/").each do |part|
      if part.start_with?(":")
        route << String
        route_args << part.gsub(":", "")
      else
        route << part
      end
    end
    list << Proc.new do |r|
      r.send(action.request_method, *route) do |*args|
        r.send(action.respond_to) do
          env["warden"].authenticate!(scope: action.warden_scope)
          if context.opts[:ree_actions_before]
            self.instance_exec(@_request, action.warden_scope, &scope.opts[:ree_actions_before])
          end
          # TODO: implement me when migration to roda DSL happens
          # if action.before; end
          route_args.each_with_index do |arg, index|
            r.params["#{arg}"] = args[index]
          end
          params = r.params
          if r.body
            body = begin
              JSON.parse(r.body.read)
            rescue => e
              {}
            end
            params = params.merge(body)
          end
          not_blank = ReeObject::NotBlank.new
          filtered_params = ReeHash::TransformValues.new.call(params) do |k, v|
            v.is_a?(Array) ? v.select { not_blank.call(_1) } : v
          end
          accessor = env["warden"].user(action.warden_scope)
          action_result = action.action.klass.new.call(accessor, filtered_params)
          if action.serializer
            serialized_result = action.serializer.klass.new.serialize(action_result)
          else
            serialized_result = {}
          end
          case action.request_method
          when :post
            response.status = 201
            ReeJson::ToJson.new.call(serialized_result)
          when :put, :delete, :patch
            response.status = 204
            ""
          else
            response.status = 200
            ReeJson::ToJson.new.call(serialized_result)
          end
        end
      end
    end
  end
  opts[:ree_actions_proc]  = list
end

def ree_actions(actions, swagger_title: "", swagger_description: "",
                swagger_version: "", swagger_url: "", api_url: "")
  @ree_actions ||= []
  @ree_actions += actions
  opts[:ree_actions_swagger_title] = swagger_title
  opts[:ree_actions_swagger_description] = swagger_description
  opts[:ree_actions_swagger_version] = swagger_version
  opts[:ree_actions_swagger_url] = swagger_url
  opts[:ree_actions_api_url] = api_url
  opts[:ree_actions_swagger] = ReeRoda::BuildSwaggerFromActions.new.call(
    @ree_actions,
    opts[:ree_actions_swagger_title],
    opts[:ree_actions_swagger_description],
    opts[:ree_actions_swagger_version],
    opts[:ree_actions_api_url]
  )
  build_actions_proc
  nil
end