require "fiona7/controllers/rest_api/obj_class_controller"
require "fiona7/controllers/rest_api/obj_controller"
require "fiona7/controllers/rest_api/blob_controller"
require "fiona7/controllers/rest_api/workspace_controller"

class Scrivito::CmsRestApi
  class << self
    alias_method :original_task_unaware_request, :task_unaware_request
    def task_unaware_request(method, resource_path, payload = nil)
      raise "Unexpected method #{method}" unless [:delete, :get, :post, :put].include?(method)
      self.send(method, resource_path, payload)
    end

    alias_method :original_get, :get
    def get(resource_path, payload = nil, options = nil)
      @number_of_requests += 1 if resource_path == @count_requests

      if !resource_path.start_with?('/')
        resource_path = '/' + resource_path
      end

      #$stdout.puts "DEBUG GET: #{resource_path}"
      case resource_path
      when /\A\/?revisions\/[a-zA-Z0-9_-]+\/obj_classes\Z/, /\A\/?workspaces\/[a-zA-Z0-9_-]+\/obj_classes\Z/
        Fiona7::Controllers::RestAPI::ObjClassController.new.all
      when /\A\/?revisions\/[a-zA-Z0-9_-]+\/objs\/[a-zA-Z0-9_-]+\Z/
        _, _, revision_id, _, obj_id = *resource_path.split("/")
        Fiona7::Controllers::RestAPI::ObjController.new.fetch_by_id_from_revision(revision_id, obj_id)
      when /\A\/?workspaces\Z/
        Fiona7::Controllers::RestAPI::WorkspaceController.new.all
      when /\A\/?workspaces\/[a-zA-Z0-9_-]+\/objs\/find_by_path/
        _, _, workspace_id = *resource_path.split("/")
        path = resource_path.match(/path=(.*)\Z/)[1]
        Fiona7::Controllers::RestAPI::ObjController.new.fetch_by_path(workspace_id, path)
      when /\A\/?workspaces\/[a-zA-Z0-9_-]+\/objs\/search/
        _, _, workspace_id = *resource_path.split("/")
        Fiona7::Controllers::RestAPI::ObjController.new.search(workspace_id, payload)
      when /\A\/?workspaces\/[a-zA-Z0-9_-]+\/obj_classes\/[a-zA-z0-9_-]+\Z/
        _, _, workspace_id, _, obj_class_name = *resource_path.split("/")
        Fiona7::Controllers::RestAPI::ObjClassController.new.fetch(workspace_id, obj_class_name)
      when /\A\/?workspaces\/[a-zA-Z0-9_-]+\Z/
        _, _, workspace_id = *resource_path.split("/")
        Fiona7::Controllers::RestAPI::WorkspaceController.new.fetch(workspace_id)
      when /\A\/?workspaces\/[a-zA-Z0-9_-]+\/objs\/[a-zA-Z0-9_-]+\Z/
        _, _, workspace_id, _, obj_id = *resource_path.split("/")
        Fiona7::Controllers::RestAPI::ObjController.new.fetch_by_id(workspace_id, obj_id)
      when /\A\/?blobs\/[a-zA-Z0-9_-]+\Z/
        _, _, blob_id = *resource_path.split("/")
        Fiona7::Controllers::RestAPI::BlobController.new.fetch(blob_id)
      else
        #$stdout.puts "GET: #{resource_path}"
        original_get(resource_path, payload, options)
      end
    end

    alias_method :original_delete, :delete
    def delete(resource_path, payload = nil, options = nil)
      @number_of_requests += 1 if resource_path == @count_requests

      if !resource_path.start_with?('/')
        resource_path = '/' + resource_path
      end

      case resource_path
      when /\A\/?workspaces\Z/
        true
      when /\A\/?workspaces\/[a-zA-Z0-9_-]+\Z/
        raise Scrivito::ScrivitoError, 'Delete operation unsupported for workspaces'
        _, _, workspace_id = *resource_path.split("/")
        Fiona7::Controllers::RestAPI::WorkspaceController.new.delete(workspace_id)
      when /\A\/?workspaces\/[a-zA-Z0-9_-]+\/objs\/[a-zA-Z0-9_-]+\Z/
        _, _, workspace_id, _, obj_id = *resource_path.split("/")
        Fiona7::Controllers::RestAPI::ObjController.new.destroy(workspace_id, obj_id)
      else
        #$stdout.puts "DELETE: #{resource_path}"
        original_delete(resource_path, payload, options)
      end
    end

    alias_method :original_post, :post
    def post(resource_path, payload, options = nil)
      @number_of_requests += 1 if resource_path == @count_requests

      if !resource_path.start_with?('/')
        resource_path = '/' + resource_path
      end

      #$stdout.puts "DEBUG POST: #{resource_path}"
      case resource_path
      when /\A\/?workspaces\Z/
        Fiona7::Controllers::RestAPI::WorkspaceController.new.create(payload)
      when /\A\/?workspaces\/[a-zA-Z0-9]+\/obj_classes/
        _, _, workspace_id = *resource_path.split("/")
        Fiona7::Controllers::RestAPI::ObjClassController.new.create(workspace_id, payload)
      when /\A\/?workspaces\/[a-zA-Z0-9]+\/objs/
        _, _, workspace_id = *resource_path.split("/")
        Fiona7::Controllers::RestAPI::ObjController.new.create(workspace_id, payload)
      else
        #$stdout.puts "POST: #{resource_path}"
        original_post(resource_path, payload, options)
      end
    end

    alias_method :original_put, :put
    def put(resource_path, payload, options = nil)
      @number_of_requests += 1 if resource_path == @count_requests

      if !resource_path.start_with?('/')
        resource_path = '/' + resource_path
      end

      #$stdout.puts "DEBUG PUT: #{resource_path}"
      case resource_path
      when /\A\/?workspaces\/[a-zA-Z0-9]+\/objs\/[a-zA-Z0-9]+\Z/
        _, _, workspace_id, _, obj_id = *resource_path.split("/")
        payload[:obj][:_id] = obj_id
        Fiona7::Controllers::RestAPI::ObjController.new.update(workspace_id, payload)
      when /\A\/?workspaces\/[a-zA-Z0-9]+\/obj_classes\/[a-zA-z0-9_-]+\Z/
        _, _, workspace_id, _, obj_class_name = *resource_path.split("/")
        payload[:obj_class][:name] = obj_class_name
        Fiona7::Controllers::RestAPI::ObjClassController.new.update(workspace_id, payload)
      when /\A\/?workspaces\/[a-zA-Z0-9]+\/publish/
        _, _, workspace_id = *resource_path.split("/")
        Fiona7::Controllers::RestAPI::WorkspaceController.new.publish(workspace_id)
      when /\A\/?workspaces\/[a-zA-Z0-9]+\/rebase/
        raise Scrivito::ScrivitoError, 'Rebase operation unsupported for workspaces'
        _, _, workspace_id = *resource_path.split("/")
        Fiona7::Controllers::RestAPI::WorkspaceController.new.publish(workspace_id)
      else
        #$stdout.puts "PUT: #{resource_path}"
        original_put(resource_path, payload, options)
      end
    end
  end
end