dodb.cr/spec/test-common.cr

require "spec"
require "./db-cars.cr"

# NOTE: the following tests access both database and triggers' caches directly.
# It must not be done in real applications.
# `data` and `lru` properties are implementation details.

describe "SPECDB::Common" do
	it "basics, 3 values" do
		car0 = Car.new "Corvet-0", "red", [] of String
		car1 = Car.new "Corvet-1", "red", [] of String
		car2 = Car.new "Corvet-2", "red", [] of String
		car3 = Car.new "Corvet-3", "red", [] of String

		db = SPECDB::Common(Car).new "", 3

		db.data.keys.sort.should eq([] of Int32)

		db << car0
		db.data.keys.sort.should eq([0] of Int32)

		db << car1
		db.data.keys.sort.should eq([0, 1] of Int32)

		db << car2
		db.data.keys.sort.should eq([0, 1, 2] of Int32)
		db[0] # Let's use the first value, it shouldn't be the one to be dropped.

		db << car3
		db.data.keys.sort.should eq([0, 2, 3] of Int32)
		db.lru.to_s.should eq "[ 3, 0, 2 ]"

		db.delete 2
		db.data.keys.sort.should eq([0, 3] of Int32)
		db.lru.to_s.should eq "[ 3, 0 ]"
	end

	it "add some values, reindex, check the values" do
		car0 = Car.new "Corvet-0", "red", [] of String
		car1 = Car.new "Corvet-1", "red", [] of String
		car2 = Car.new "Corvet-2", "red", [] of String
		car3 = Car.new "Corvet-3", "red", [] of String

		db = SPECDB::Common(Car).new "reindex", 2
		index_name  = db.new_index     "name",  &.name
		index_color = db.new_partition "color", &.color

		db.data.keys.sort.should eq([] of Int32)

		db << car0
		db.data.keys.sort.should eq([0] of Int32)

		db << car1
		db.data.keys.sort.should eq([0, 1] of Int32)
		db.lru.to_s.should eq "[ 1, 0 ]"

		db.data.keys.sort.should eq([0, 1] of Int32)
		db.lru.to_s.should eq "[ 1, 0 ]"

		db << car2
		db.data.keys.sort.should eq([1, 2] of Int32)
		db.lru.to_s.should eq "[ 2, 1 ]"
		db[0] # Let's use the first value, it shouldn't be the one to be dropped.

		db << car3
		db.data.keys.sort.should eq([0, 3] of Int32)
		db.lru.to_s.should eq "[ 3, 0 ]"

		# Actually remove the value indexed "2".
		db.delete 2
		# The "delete" action actually puts the value in the cache before removing it.
		db.data.keys.sort.should eq([3] of Int32)
		db.lru.to_s.should eq "[ 3 ]"

		# db2: further tests for the LRU behavior, with `reindex_everything!` for example.
		db2 = SPECDB::Common(Car).new "reindex", 2, false
		index2_name  = db2.new_index     "name",  &.name

		# For now, we didn't use any value in the database.
		# Also, triggers should have empty caches.
		db2.data.keys.sort.should eq([] of Int32)
		db2.lru.to_s.should eq "[  ]"
		index2_name.get?("Corvet-0").should eq car0

		# Reindex removes all triggers (hard rm -rf trigger-dir) then reads all
		# data from the file-system to run the triggers. Data is put into the cache
		# of the `Common` database.
		db2.reindex_everything!

		# Values 1 and 3 are the last recently used values following `reindex_everything!`.
		db2.data.keys.sort.should eq([1, 3] of Int32)
		db2.lru.to_s.should eq "[ 3, 1 ]"

		total_values = 0
		db2.each_with_key do |v, k|
			total_values += 1
		end
		total_values.should eq 3

		# db3: no need for a reindex to access values from the database,
		# with `each` or `each_with_key` for example.
		db3 = SPECDB::Common(Car).new "reindex", 2, false
		total_values = 0
		db3.each do |v|
			total_values += 1
		end
		total_values.should eq 3

		# db4: no need for a reindex to access values from triggers.
		db4 = SPECDB::Common(Car).new "reindex", 2, false
		index4_name  = db4.new_index     "name",  &.name
		index4_color = db4.new_partition "color", &.color

		index4_name.data.size.should eq 0 # trigger cache is empty
		index4_name.get?("Corvet-3").should eq car3
		index4_name.data.size.should eq 1 # trigger cache: one value, Corvet-3

		index4_color.data.size.should eq 0 # trigger cache is empty
		index4_color.get("red").size.should eq 3 # read from the disk
		index4_color.data.size.should eq 1 # trigger cache: 1, the color "red"
		index4_color.data["red"].size.should eq 3 # 3 values in "red"
	end
end