tc_wc.rb

require './test_common'

class WordCount1
  include Bud

  attr_reader :pattern

  def initialize(pattern, *options)
    super(*options)
    @pattern = pattern
  end

  state do
    file_reader :txt, 'text/ulysses.txt'
    scratch :wc, [:word] => [:cnt]
  end

  bloom do
    wc <= txt.flat_map do |t|
      t.text.split.enum_for(:each_with_index).map {|w, i| [t.lineno, i, w]}
    end.rename(:loo, [:lineno, :wordno, :word]).group([:word], count)
  end
end

class TestWC1 < Minitest::Test
  def test_wc1
    program = WordCount1.new(/[Bb]loom/)
    program.tick
    assert_equal(23, program.wc[["yes"]].cnt)
  end
end


class WordCount2
  include Bud

  attr_reader :pattern

  def initialize(pattern, *options)
    super(*options)
    @pattern = pattern
  end

  state do
    file_reader :txt, 'text/ulysses.txt'
    scratch :words, [:lineno, :wordno] => [:word]
    scratch :wc, [:word] => [:cnt]
  end

  bloom do
    words <= txt.flat_map do |t|
      t.text.split.enum_for(:each_with_index).map {|w, i| [t.lineno, i, w]}
    end
    wc <= words.reduce(Hash.new) do |memo, t|
      memo[t.word] ||= 0
      memo[t.word] += 1
      memo
    end
  end
end

class TestWC2 < Minitest::Test
  def test_wc2
    program = WordCount2.new(/[Bb]loom/)
    program.tick
    assert_equal(23, program.wc[["yes"]].cnt)
  end
end