module Legion::Extensions::Transformer::Transport::Messages
  class Message < Legion::Transport::Message
    def type
      'task'
    end

    def message
      @options[:function] = function.values[:name]
      @options
    end

    def routing_key
      "#{function.runner.extension.values[:name]}.#{function.runner.values[:name]}.#{function.values[:name]}"
    end

    def exchange
      Legion::Transport::Exchange.new(function.runner.extension.values[:exchange])
    end

    def function
      @function ||= Legion::Data::Model::Function[@options[:function_id]]
    end
  end
end