Contents

require "test_helper"
require "helpers/mocked_instrumentation_service"

class HTML::PipelineTest < Test::Unit::TestCase
  Pipeline = HTML::Pipeline
  class TestFilter
    def self.call(input, context, result)
      input
    end
  end

  def setup
    @context = {}
    @result_class = Hash
    @pipeline = Pipeline.new [TestFilter], @context, @result_class
  end

  def test_filter_instrumentation
    service = MockedInstrumentationService.new
    service.subscribe "call_filter.html_pipeline"
    @pipeline.instrumentation_service = service
    filter("hello")
    event, payload, res = service.events.pop
    assert event, "event expected"
    assert_equal "call_filter.html_pipeline", event
    assert_equal TestFilter.name, payload[:filter]
  end

  def test_pipeline_instrumentation
    service = MockedInstrumentationService.new
    service.subscribe "call_pipeline.html_pipeline"
    @pipeline.instrumentation_service = service
    filter("hello")
    event, payload, res = service.events.pop
    assert event, "event expected"
    assert_equal "call_pipeline.html_pipeline", event
    assert_equal @pipeline.filters.map(&:name), payload[:filters]
  end

  def test_default_instrumentation_service
    service = 'default'
    Pipeline.default_instrumentation_service = service
    pipeline = Pipeline.new [], @context, @result_class
    assert_equal service, pipeline.instrumentation_service
  ensure
    Pipeline.default_instrumentation_service = nil
  end

  def filter(input)
    @pipeline.call(input)
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
html-pipeline-0.0.11	test/html/pipeline_test.rb