Sha256: 974b80167c67f80bd0d8b9c2b47d49d8e2cad27ca1524a6562bcf2226ea49b70

Contents?: true

Size: 1.35 KB

Versions: 2

Compression:

Stored size: 1.35 KB

Contents

# frozen_string_literal: true

module Grumlin
  class AnonymousStep
    attr_reader :name, :previous_step, :configuration_steps

    # TODO: add other steps
    SUPPORTED_STEPS = %i[E V addE addV and as both bothE by choose coalesce count dedup drop elementMap emit fold from
                         group groupCount has hasId hasLabel hasNot id in inE inV is label limit not or order out outE
                         path project property range repeat sack select sideEffect skip sum tail to unfold union until
                         valueMap values where with].freeze

    def initialize(name, *args, configuration_steps: [], previous_step: nil, **params)
      @name = name
      @previous_step = previous_step
      @args = args
      @params = params
      @configuration_steps = configuration_steps
    end

    SUPPORTED_STEPS.each do |step|
      define_method(step) do |*args, **params|
        step(step, *args, **params)
      end
    end

    def step(name, *args, **params)
      self.class.new(name, *args, previous_step: self, configuration_steps: configuration_steps, **params)
    end

    def inspect
      bytecode.inspect
    end

    def to_s
      inspect
    end

    def bytecode(no_return: false)
      @bytecode ||= Bytecode.new(self, no_return: no_return)
    end

    def args
      [*@args, @params.any? ? arg.params : nil].compact
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
grumlin-0.14.4 lib/grumlin/anonymous_step.rb
grumlin-0.14.3 lib/grumlin/anonymous_step.rb