start_offset, end_offset added in each and to_a.

master
Luka Vandervelden 2020-01-12 15:12:01 +01:00
parent 1bb5268602
commit 011348b33a
2 changed files with 40 additions and 5 deletions

View File

@ -174,6 +174,22 @@ describe "DODB::DataBase" do
item.should eq Ship.all_ships.reverse[index] item.should eq Ship.all_ships.reverse[index]
end end
end end
it "respects the provided offsets if any" do
db = DODB::SpecDataBase.new
Ship.all_ships.each do |ship|
db << ship
end
db.to_a(start_offset: 0, end_offset: 0)[0]?.should eq Ship.mutsuki
db.to_a(start_offset: 1, end_offset: 1)[0]?.should eq Ship.kisaragi
db.to_a(start_offset: 2, end_offset: 2)[0]?.should eq Ship.yayoi
db.to_a(start_offset: 0, end_offset: 2).should eq [
Ship.mutsuki, Ship.kisaragi, Ship.yayoi
]
end
end end
describe "indices" do describe "indices" do

View File

@ -197,10 +197,21 @@ class DODB::DataBase(V)
## ##
# CAUTION: Very slow. Try not to use. # CAUTION: Very slow. Try not to use.
# Can be useful for making dumps or to restore a database, however. # Can be useful for making dumps or to restore a database, however.
def each_with_index(reversed = false) def each_with_index(reversed : Bool = false, start_offset = 0, end_offset : Int32? = nil)
dirname = data_path dirname = data_path
offset = -1
each_key(reversed) do |key, path| each_key(reversed) do |key, path|
offset += 1
if offset < start_offset
next
end
if !end_offset.nil? && offset > end_offset
next
end
begin begin
# FIXME: Only intercept JSON parsing errors. # FIXME: Only intercept JSON parsing errors.
field = read path field = read path
@ -211,18 +222,26 @@ class DODB::DataBase(V)
yield field, key yield field, key
end end
end end
def each(reversed = false) def each(reversed : Bool = false, start_offset = 0, end_offset : Int32? = nil)
each_with_index(reversed: reversed) do |item, index| each_with_index(
reversed: reversed,
start_offset: start_offset,
end_offset: end_offset
) do |item, index|
yield item yield item
end end
end end
## ##
# CAUTION: Very slow. Try not to use. # CAUTION: Very slow. Try not to use.
def to_a(reversed = false) def to_a(reversed : Bool = false, start_offset = 0, end_offset : Int32? = nil)
array = ::Array(V).new array = ::Array(V).new
each(reversed) do |value| each(
reversed: reversed,
start_offset: start_offset,
end_offset: end_offset
) do |value|
array << value array << value
end end