Contents

module Rworkflow
  class FlowRegistry
    REDIS_PREFIX = 'flow:__registry'.freeze

    def initialize(prefix = nil)
      @redis_key = [REDIS_PREFIX, prefix].compact.join(':')
      @public = RedisRds::SortedSet.new("#{@redis_key}:public")
      @private = RedisRds::SortedSet.new("#{@redis_key}:private")
    end

    # Warning: using parent_class forces us to load everything, make this potentially much slower as we have to do the
    # pagination in the app, not in the db
    def all(options = {})
      return self.public_flows(options) + self.private_flows(options)
    end

    def public_flows(options = {})
      return get(@public, **options)
    end

    def private_flows(options = {})
      return get(@private, **options)
    end

    def add(flow)
      key = flow.created_at.to_i

      if flow.public?
        @public.add(key, flow.id)
      else
        @private.add(key, flow.id)
      end
    end

    def remove(flow)
      if flow.public?
        @public.remove(flow.id)
      else
        @private.remove(flow.id)
      end
    end

    def include?(flow)
      if flow.public?
        @public.include?(flow.id)
      else
        @private.include?(flow.id)
      end
    end

    def get(zset, parent_class: nil, from: nil, to: nil, order: :asc)
      from = from.to_i
      to = to.nil? ? -1 : to.to_i

      ids = []
      if parent_class.nil? || parent_class == Flow
        ids = zset.range(from, to, order: order)
      else
        ids = zset.range(0, -1, order: order).select do |id|
          klass = Flow.read_flow_class(id)
          !klass.nil? && klass <= parent_class
        end.slice(from..to)
      end

      return ids
    end
    private :get
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
rworkflow-0.7.3	lib/rworkflow/flow_registry.rb
rworkflow-0.7.2	lib/rworkflow/flow_registry.rb
rworkflow-0.7.1	lib/rworkflow/flow_registry.rb
rworkflow-0.7.0	lib/rworkflow/flow_registry.rb
rworkflow-0.6.5	lib/rworkflow/flow_registry.rb
rworkflow-0.6.4	lib/rworkflow/flow_registry.rb
rworkflow-0.6.3	lib/rworkflow/flow_registry.rb
rworkflow-0.6.2	lib/rworkflow/flow_registry.rb
rworkflow-0.6.1	lib/rworkflow/flow_registry.rb