operation_handler.rb in isomorfeus-operation-2.3.0

- old
+ new
@@ -8,49 +8,69 @@
           # promise_send_path('Isomorfeus::Operation::Handler::OperationHandler', self.to_s, props_hash)
           response_agent.request.each_key do |operation_class_name|
             if Isomorfeus.valid_operation_class_name?(operation_class_name)
               operation_class = Isomorfeus.cached_operation_class(operation_class_name)
               if operation_class
-                props = response_agent.request[operation_class_name]
-                props.transform_keys!(&:to_sym)
-                begin
-                  if Isomorfeus.current_user.authorized?(operation_class, :promise_run, props)
-                    operation_promise = operation_class.promise_run(**props)
-                    if operation_promise.realized?
-                      state = operation_promise.resolved? ? :resolved : :rejected
-                      result_hash = { state => operation_promise.value }
-                      if operation_promise.error
-                        e = operation_promise.error
-                        result_hash[:error] = { message: e.message, class_name: e.class.to_s, back_trace: e.backtrace }
-                      end
-                      response_agent.agent_result = { success: 'ok' , result: result_hash }
-                    else
-                      start = Time.now
-                      timeout = false
-                      while !operation_promise.realized?
-                        if (Time.now - start) > 20
-                          timeout = true
-                          break
-                        end
-                        sleep 0.01
-                      end
-                      if timeout
-                        response_agent.error = { error: 'Timeout' }
-                      else
+                response_agent.request[operation_class_name].each_key do |method|
+                  props = response_agent.request[operation_class_name][method]
+                  props.transform_keys!(&:to_sym)
+                  begin
+                    case method
+                    when 'run'
+                      raise 'Access denied!' unless Isomorfeus.current_user.authorized?(operation_class, :promise_run, props)
+                      operation_promise = operation_class.promise_run(**props)
+                      if operation_promise.realized?
                         state = operation_promise.resolved? ? :resolved : :rejected
                         result_hash = { state => operation_promise.value }
                         if operation_promise.error
                           e = operation_promise.error
                           result_hash[:error] = { message: e.message, class_name: e.class.to_s, back_trace: e.backtrace }
                         end
                         response_agent.agent_result = { success: 'ok' , result: result_hash }
+                      else
+                        start = Time.now
+                        timeout = false
+                        while !operation_promise.realized?
+                          if (Time.now - start) > 20
+                            timeout = true
+                            break
+                          end
+                          sleep 0.01
+                        end
+                        if timeout
+                          response_agent.error = { error: 'Timeout' }
+                        else
+                          state = operation_promise.resolved? ? :resolved : :rejected
+                          result_hash = { state => operation_promise.value }
+                          if operation_promise.error
+                            e = operation_promise.error
+                            result_hash[:error] = { message: e.message, class_name: e.class.to_s, back_trace: e.backtrace }
+                          end
+                          response_agent.agent_result = { success: 'ok' , result: result_hash }
+                        end
                       end
+                    when 'deferred'
+                      raise 'Access denied!' unless Isomorfeus.current_user.authorized?(operation_class, :promise_deferred, props)
+                      operation_promise = operation_class.promise_deferred(**props)
+                      response_agent.agent_result = { success: 'ok' , result: { :resolved => operation_promise.value }}
+                    when 'daily'
+                      raise 'Access denied!' unless Isomorfeus.current_user.authorized?(operation_class, :promise_daily, props)
+                      operation_promise = operation_class.promise_daily(**props)
+                      response_agent.agent_result = { success: 'ok' , result: { :resolved => operation_promise.value }}
+                    when 'remove_daily'
+                      raise 'Access denied!' unless Isomorfeus.current_user.authorized?(operation_class, :promise_daily, props)
+                      operation_promise = operation_class.promise_remove_daily(**props)
+                      response_agent.agent_result = { success: 'ok' , result: { :resolved => operation_promise.value }}
+                    when 'daily_exist'
+                      raise 'Access denied!' unless Isomorfeus.current_user.authorized?(operation_class, :promise_daily, props)
+                      operation_promise = operation_class.promise_daily(**props)
+                      response_agent.agent_result = { success: 'ok' , result: { :resolved => operation_promise.value }}
+                    else
+                      response_agent.error = { error: 'No such method!' }
                     end
-                  else
-                    response_agent.error = { error: 'Access denied!' }
+                  rescue Exception => e
+                    response_agent.error = { error: { operation_class_name => "Isomorfeus::Operation::Handler::OperationHandler: #{e.message}" }}
                   end
-                rescue Exception => e
-                  response_agent.error = { error: { operation_class_name => "Isomorfeus::Operation::Handler::OperationHandler: #{e.message}" }}
                 end
               else
                 response_agent.error = { error: { operation_class_name => 'Could not get operation class!' }}
               end
             else