tc_errors.rb

require './test_common'
require 'tempfile'

class TestErrorHandling < Minitest::Test
  class EmptyBud
    include Bud
  end

  def test_do_sync_error
    b = EmptyBud.new
    b.run_bg
    3.times {
      assert_raises(ZeroDivisionError) {
        b.sync_do {
          puts 5 / 0
        }
      }
    }

    b.stop
  end

  class IllegalOp
    include Bud

    state do
      table :t1
    end

    bloom do
      t1 < t1 {|t| [t.key + 1, t.val + 1]}
    end
  end

  def test_illegal_op_error
    assert_raises(Bud::CompileError) { IllegalOp.new }
  end

  class IllegalAsyncOp
    include Bud

    state do
      table :t1
    end

    bloom do
      t1 <~ t1 {|x| ["foo"]}
    end
  end

  def test_illegal_async_op
    assert_raises(Bud::CompileError) { IllegalAsyncOp.new.tick }
  end

  class IllegalAsyncLattice
    include Bud

    state do
      lmap :m1
    end

    bloom do
      m1 <~ m1
    end
  end

  def test_illegal_async_lattice
    assert_raises(Bud::CompileError) { IllegalAsyncLattice.new.tick }
  end

  class InsertInBloomBlock
    include Bud

    state do
      table :t1
    end

    bloom do
      t1 << [5, 10]
    end
  end

  def test_insert_in_bloom_error
    assert_raises(Bud::CompileError) { InsertInBloomBlock.new }
  end

  class MissingTable
    include Bud

    state do
      table :t1
    end

    bloom do
      t2 <= t1
    end
  end

  class BadSchemy
    include Bud

    state do
      table :num, ["key"] => []
    end
  end

  def test_bad_schemy
    assert_raises(Bud::Error) do
      p = BadSchemy.new
      p.tick
    end
  end

  class SchemyConflict
    include Bud

    state do
      table :num, [:map] => []
    end
  end

  def test_schemy_conflict
    assert_raises(Bud::Error) do
      p = SchemyConflict.new
      p.tick
    end
  end

  def test_missing_table_error
    assert_raises(Bud::CompileError) { MissingTable.new }
  end

  class PrecedenceError
    include Bud

    state do
      table :foo
      table :bar
      table :baz
    end

    bloom do
      foo <= baz
      # Mistake: <= binds more tightly than "or"
      foo <= (bar.first and baz.first) or []
    end
  end

  def test_precedence_error
    assert_raises(Bud::CompileError) { PrecedenceError.new }
  end

  class VarShadowError
    include Bud

    state do
      table :t1
      table :t2
    end

    bloom do
      temp :t2 <= (t1 * t1)
    end
  end

  def test_var_shadow_error
    assert_raises(Bud::CompileError) { VarShadowError.new }
  end

  def test_bloom_block_error
    defn = "class BloomBlockError\ninclude Bud\nbloom \"blockname\" do\nend\n\nend\n"
    assert_raises(Bud::CompileError) {eval(defn)}
  end

  def test_dup_blocks
    src = "class DupBlocks\ninclude Bud\nbloom :foo do\nend\nbloom :foo do\nend\nend\n"
    f = Tempfile.new("dup_blocks.rb")
    f.write(src)
    f.close
    assert_raises(Bud::CompileError) { load f.path }
  end

  class EvalError
    include Bud

    state do
      scratch :t1
      scratch :t2
    end

    bloom do
      t2 <= t1 { |t| [t.key, 5 / t.val]}
    end
  end

  def test_eval_error
    e = EvalError.new
    e.run_bg

    assert_raises(ZeroDivisionError) {
      e.sync_do {
        e.t1 <+ [[5, 0]]
      }
    }

    e.stop
  end

  class BadGroupingCols
    include Bud

    state do
      table :t1
    end

    bootstrap do
      t1 << [1,1]
    end

    bloom do
      temp :t2 <= t1.group(["key"], min(:val))
    end
  end

  def test_bad_grouping_cols
    p = BadGroupingCols.new
    assert_raises(Bud::Error) {p.tick}
  end

  class BadJoinTabs
    include Bud
    state do
      table :t1
      table :t2
      table :t3
    end
    bootstrap do
      t1 << [1,1]
      t2 << [2,2]
    end

    bloom do
      temp :out <= (t1*t2).pairs(t3.key => t2.val)
    end
  end

  def test_bad_join_tabs
    p = BadJoinTabs.new
    assert_raises(Bud::CompileError) {p.tick}
  end

  class BadNextChannel
    include Bud
    state do
      channel :c1
    end
    bloom do
      c1 <+ [["doh"]]
    end
  end

  def test_bad_next_channel
    p = BadNextChannel.new
    assert_raises(Bud::CompileError) {p.tick}
  end

  class BadStdio
    include Bud
    bloom do
      stdio <= [["phooey"]]
    end
  end

  def test_bad_stdio
    p = BadStdio.new
    assert_raises(Bud::CompileError) {p.tick}
  end

  class BadFileReader1
    include Bud
    state do
      file_reader :fd, "/tmp/foo#{Process.pid}"
    end
    bloom do
      fd <= [['no!']]
    end
  end

  def test_bad_file_reader_1
    File.open("/tmp/foo#{Process.pid}", 'a')
    p = BadFileReader1.new
    assert_raises(Bud::CompileError){p.tick}
  end

  class BadFileReader2
    include Bud
    state do
      file_reader :fd, "/tmp/foo#{Process.pid}"
    end
    bloom do
      fd <+ [['no!']]
    end
  end

  def test_bad_file_reader_2
    File.open("/tmp/foo#{Process.pid}", 'a')
    assert_raises(Bud::CompileError) { BadFileReader2.new.tick}
  end

  class BadFileReader3
    include Bud
    state do
      file_reader :fd, "/tmp/foo#{Process.pid}"
    end
    bloom do
      fd <~ [['no!']]
    end
  end

  def test_bad_file_reader_3
    File.open("/tmp/foo#{Process.pid}", 'a')
    assert_raises(Bud::CompileError) { BadFileReader3.new.tick}
  end

  class BadOp
    include Bud
    state do
      table :foo
      table :bar
    end
    bloom do
      foo + bar
    end
  end

  def test_bad_op
    assert_raises(Bud::CompileError) { BadOp.new }
  end

  class BadTerminal
    include Bud
    state {terminal :joeio}
    bloom do
      joeio <~ [["hi"]]
    end
  end

  def test_bad_terminal
    assert_raises(Bud::Error) { BadTerminal.new }
  end

  module SyntaxBase
    state do
      table :foo
      table :bar
    end
  end

  class SyntaxTest1
    include Bud
    include SyntaxBase

    bloom :foobar do
      foo = bar
    end
  end

  def test_parsetime_error
    begin
      SyntaxTest1.new
      assert(false)
    rescue
      assert_equal(Bud::CompileError, $!.class)
      # fragile assertion? (whitespace etc)
      assert_equal("illegal operator: '=' in rule block \"__bloom__foobar\"\nCode: foo = bar", $!.to_s)
    end
  end
end