step.rb in grumlin-1.0.0.rc1

- old
+ new
@@ -1,94 +1,92 @@
 # frozen_string_literal: true
 
-module Grumlin
-  class Step < Steppable
-    attr_reader :name, :args, :params, :next_step, :configuration_steps, :previous_step, :shortcut
+class Grumlin::Step < Grumlin::Steppable
+  attr_reader :name, :args, :params, :next_step, :configuration_steps, :previous_step, :shortcut
 
-    # TODO: replace pool, session_id and middlewares with a context?
-    def initialize(name, args: [], params: {}, previous_step: nil, pool: nil, session_id: nil, # rubocop:disable Metrics/ParameterLists
-                   middlewares: Grumlin.default_middlewares)
-      super(pool: pool, session_id: session_id, middlewares: middlewares)
+  # TODO: replace pool, session_id and middlewares with a context?
+  def initialize(name, args: [], params: {}, previous_step: nil, pool: nil, session_id: nil, # rubocop:disable Metrics/ParameterLists
+                 middlewares: Grumlin.default_middlewares)
+    super(pool: pool, session_id: session_id, middlewares: middlewares)
 
-      @name = name.to_sym
-      @args = args # TODO: add recursive validation: only json types or Step
-      @params = params # TODO: add recursive validation: only json types
-      @previous_step = previous_step
-      @shortcut = shortcuts[@name]
-    end
+    @name = name.to_sym
+    @args = args # TODO: add recursive validation: only json types or Step
+    @params = params # TODO: add recursive validation: only json types
+    @previous_step = previous_step
+    @shortcut = shortcuts[@name]
+  end
 
-    def configuration_step?
-      CONFIGURATION_STEPS.include?(@name) || name.to_sym == :tx
-    end
+  def configuration_step?
+    CONFIGURATION_STEPS.include?(@name) || name.to_sym == :tx
+  end
 
-    def start_step?
-      START_STEPS.include?(@name)
-    end
+  def start_step?
+    START_STEPS.include?(@name)
+  end
 
-    def regular_step?
-      REGULAR_STEPS.include?(@name)
-    end
+  def regular_step?
+    REGULAR_STEPS.include?(@name)
+  end
 
-    def supported_step?
-      ALL_STEPS.include?(@name)
-    end
+  def supported_step?
+    ALL_STEPS.include?(@name)
+  end
 
-    def ==(other)
-      self.class == other.class &&
-        @name == other.name &&
-        @args == other.args &&
-        @params == other.params &&
-        @previous_step == other.previous_step &&
-        shortcuts == other.shortcuts
-    end
+  def ==(other)
+    self.class == other.class &&
+      @name == other.name &&
+      @args == other.args &&
+      @params == other.params &&
+      @previous_step == other.previous_step &&
+      shortcuts == other.shortcuts
+  end
 
-    def steps
-      @steps ||= Steps.from(self)
-    end
+  def steps
+    @steps ||= Grumlin::Steps.from(self)
+  end
 
-    def to_s(**params)
-      StepsSerializers::String.new(steps, **params).serialize
-    end
+  def to_s(**params)
+    Grumlin::StepsSerializers::String.new(steps, **params).serialize
+  end
 
-    # TODO: add human readable mode
-    def inspect
-      conf_steps, regular_steps = StepsSerializers::HumanReadableBytecode.new(steps).serialize
-      "#{conf_steps.any? ? conf_steps : nil}#{regular_steps}"
-    end
+  # TODO: add human readable mode
+  def inspect
+    conf_steps, regular_steps = Grumlin::StepsSerializers::HumanReadableBytecode.new(steps).serialize
+    "#{conf_steps.any? ? conf_steps : nil}#{regular_steps}"
+  end
 
-    def bytecode(no_return: false)
-      StepsSerializers::Bytecode.new(steps, no_return: no_return)
-    end
+  def bytecode(no_return: false)
+    Grumlin::StepsSerializers::Bytecode.new(steps, no_return: no_return)
+  end
 
-    def next
-      to_enum.next
-    end
+  def next
+    to_enum.next
+  end
 
-    def hasNext # rubocop:disable Naming/MethodName
-      to_enum.peek
-      true
-    rescue StopIteration
-      false
-    end
+  def hasNext # rubocop:disable Naming/MethodName
+    to_enum.peek
+    true
+  rescue StopIteration
+    false
+  end
 
-    def to_enum
-      @to_enum ||= toList.to_enum
-    end
+  def to_enum
+    @to_enum ||= toList.to_enum
+  end
 
-    def toList
-      send_query(need_results: true)
-    end
+  def toList
+    send_query(need_results: true)
+  end
 
-    def iterate
-      send_query(need_results: false)
-    end
+  def iterate
+    send_query(need_results: false)
+  end
 
-    private
+  private
 
-    def send_query(need_results:)
-      @middlewares.call(traversal: self,
-                        need_results: need_results,
-                        session_id: @session_id,
-                        pool: @pool)
-    end
+  def send_query(need_results:)
+    @middlewares.call(traversal: self,
+                      need_results: need_results,
+                      session_id: @session_id,
+                      pool: @pool)
   end
 end