Contents

# frozen_string_literal: true

using Rodbot::Refinements

module Rodbot
  class Services
    class Relay

      class << self
        include Rodbot::Memoize

        # URL (including port) to reach the given relay service locally
        #
        # @param name [Symbol] relay service
        # @return [String] URL
        memoize def url(name)
          [
            (ENV["RODBOT_RELAY_URL_#{name.upcase}"] || 'tcp://localhost'),
            Rodbot.config(:port) + 1 + Rodbot.config(:plugin).keys.index(name)
          ].join(':')
        end
      end

      def tasks(only: nil)
        Rodbot.plugins.extend_relay
        extensions = Rodbot.plugins.extensions[:relay]
        extensions.select! { _1 == only.to_sym } if only
        fail Rodbot::RelayError, "no matching relay plugin configured" if extensions.none?
        extensions.map do |name, path|
          puts "Starting relay service extension #{name} on #{self.class.url(name)}"
          path.constantize.new.loops
        end.flatten
      end

    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
rodbot-0.5.1	lib/rodbot/services/relay.rb
rodbot-0.5.0	lib/rodbot/services/relay.rb