Packages
kvs
8.5.2
13.5.22-aleph
13.4.16
13.4.15
13.4.14
13.4.13
13.3.1
13.2.28
11.9.1
10.8.3
10.8.2
10.3.0
9.9.2
9.9.1
9.9.0
9.8.0
9.7.0
9.4.8
9.4.7
9.4.6
9.4.5
9.4.4
9.4.3
9.4.2
9.4.1
9.4.0
8.12.0
8.11.2
8.11.1
8.10.4
8.10.3
8.10.2
8.10.1
8.10.0
8.5.2
8.5.1
8.5.0
8.4.1
8.4.0
8.3.1
8.3.0
7.11.5
7.9.1
7.7.0
7.1.3
7.1.2
7.1.1
6.12.11
6.12.10
6.12.9
6.12.8
6.12.7
6.12.6
6.12.5
6.12.4
6.12.3
6.12.2
6.12.1
6.12.0
6.11.2
6.11.1
6.11.0
6.10.2
6.10.1
6.10.0
6.9.2
6.9.1
6.9.0
6.7.7
6.7.6
6.7.5
6.7.4
6.7.3
6.7.2
6.7.1
6.7.0
6.6.0
2.1.0
0.12.1
retired
KVS Key-Value Store Abstraction Layer
Current section
Files
Jump to
Current section
Files
test/st_test.exs
ExUnit.start()
defmodule St.Test do
use ExUnit.Case, async: false
import Record
require KVS
defrecord(:msg, id: [], body: [])
setup do: (on_exit(fn -> :ok = :kvs.leave();:ok = :kvs_rocks.destroy() end);:kvs.join())
setup kvs, do: [
ids: :lists.map(fn _ -> :kvs.append(msg(id: :kvs.seq([],[])), :feed) end, :lists.seq(1,10)),
id0: :lists.map(fn _ -> :kvs.append(msg(id: :kvs.seq([],[])), "/crm/personal/Реєстратор А1/in/directory/duck") end, :lists.seq(1,10)),
id1: :lists.map(fn _ -> :kvs.append(msg(id: :kvs.seq([],[])), "/crm/personal/Реєстратор А1/in/mail") end, :lists.seq(1,10)),
id2: :lists.map(fn _ -> :kvs.append(msg(id: :kvs.seq([],[])), "/crm/personal/Реєстратор А1/in/doc") end, :lists.seq(1,10))]
test "take-ø", kvs do
r = KVS.reader() = :kvs.reader("/empty-feed")
assert r1 = KVS.reader(feed: "//empty-feed", args: []) = :kvs.take(KVS.reader(r, args: 1))
assert r1 = KVS.reader(feed: "//empty-feed", args: []) = :kvs.take(KVS.reader(r, args: 1, dir: 1))
assert r2 = KVS.reader(feed: "//empty-feed", args: []) = :kvs.next(r)
assert r3 = KVS.reader(feed: "//empty-feed", args: []) = :kvs.prev(r)
assert r1 = KVS.reader(feed: "//empty-feed", args: []) = :kvs.take(KVS.reader(r, args: 100))
assert r1 = KVS.reader(feed: "//empty-feed", args: []) = :kvs.take(KVS.reader(r, args: 100, dir: 1))
KVS.reader(id: rid) = :kvs.save(r1)
assert rs1 = KVS.reader(id: rid) = :kvs.load_reader(rid)
assert KVS.reader(feed: "//empty-feed", args: []) = :kvs.take(KVS.reader(rs1, args: 5))
assert KVS.reader(feed: "//empty-feed", args: []) = :kvs.take(KVS.reader(rs1, args: 5, dir: 1))
assert KVS.reader(feed: "//empty-feed", args: []) = :kvs.next(rs1)
assert KVS.reader(feed: "//empty-feed", args: []) = :kvs.prev(rs1)
assert KVS.reader(feed: "//empty-feed", args: []) = :kvs.take(KVS.reader(rs1, args: 0))
assert KVS.reader(feed: "//empty-feed", args: []) = :kvs.take(KVS.reader(rs1, args: 0, dir: 1))
end
test "take-0", kvs do
feed = "//crm/personal/Реєстратор А1/in/doc"
assert r = KVS.reader(id: rid, args: []) = :kvs.reader("/crm/personal/Реєстратор А1/in/doc")
assert KVS.reader(id: ^rid, feed: ^feed, args: []) = :kvs.take(KVS.reader(r, args: 0, dir: 0))
assert KVS.reader(id: ^rid, feed: ^feed, args: []) = :kvs.take(KVS.reader(r, args: -1, dir: 0))
assert r1 = KVS.reader(id: ^rid, feed: ^feed, args: a01) = :kvs.take(KVS.reader(r, args: 10, dir: 0))
assert kvs[:id2] |> Enum.map(&msg(id: &1)) == a01
assert KVS.reader(id: ^rid, feed: ^feed, args: []) = :kvs.take(KVS.reader(r1, args: 10, dir: 0))
assert KVS.reader(id: ^rid, feed: ^feed, args: af) = :kvs.take(KVS.reader(r, args: 100, dir: 0))
assert kvs[:id2] |> Enum.map(&msg(id: &1)) == af
assert r2 = KVS.reader(id: ^rid, feed: ^feed, args: a03) = :kvs.take(KVS.reader(r, args: 3, dir: 0))
assert Enum.take(kvs[:id2],3) |> Enum.map(&msg(id: &1)) == a03
assert KVS.reader(id: ^rid, feed: ^feed, args: a07) = :kvs.take(KVS.reader(r2, args: 7, dir: 0))
assert Enum.drop(kvs[:id2],3) |> Enum.map(&msg(id: &1)) == a07
assert KVS.reader(id: ^rid, feed: ^feed, args: a17) = :kvs.take(KVS.reader(r2, args: 100, dir: 0))
assert Enum.drop(kvs[:id2],3) |> Enum.map(&msg(id: &1)) == a17
end
test "take-1", kvs do
feed = "//crm/personal/Реєстратор А1/in/mail"
top = Enum.at(kvs[:id1],0)
bot = Enum.at(kvs[:id1],9)
tpm = Enum.take(kvs[:id1],1) |> Enum.map(&msg(id: &1))
assert r = KVS.reader(id: rid, args: [], cache: {:msg, ^top, ^feed}, count: 10) = :kvs.reader("/crm/personal/Реєстратор А1/in/mail")
assert r = :kvs.top(r)
assert KVS.reader(id: ^rid, feed: ^feed, args: ^tpm, dir: 1) = :kvs.take(KVS.reader(r, args: 1, dir: 1))
assert KVS.reader(id: ^rid, feed: ^feed, args: ^tpm, dir: 1) = :kvs.take(KVS.reader(r, args: 100, dir: 1))
assert r1 = KVS.reader(feed: ^feed, count: 10, args: [], cache: {:msg,^bot,^feed}) = :kvs.bot(r)
assert r2 = KVS.reader(feed: ^feed, count: 10, args: a01) = :kvs.take(KVS.reader(r1, args: 5, dir: 1))
x01 = Enum.drop(kvs[:id1],5) |> Enum.map(&msg(id: &1)) |> Enum.reverse
assert x01 == a01
assert r3 = KVS.reader(feed: ^feed, count: 10, args: a02) = :kvs.take(KVS.reader(r2, args: 10, dir: 1))
x02 = Enum.take(kvs[:id1],5) |> Enum.map(&msg(id: &1)) |> Enum.reverse
assert x02 == a02
assert KVS.reader(feed: ^feed, count: 10, args: []) = :kvs.take(KVS.reader(r3, args: 20, dir: 1))
end
test "drop", kvs do
feed = "/feed"
assert r = KVS.reader(id: rid, args: []) = :kvs.save(:kvs.reader(:feed))
assert r1 = KVS.reader(id: ^rid, feed: ^feed, args: []) = :kvs.drop(KVS.reader(r, args: 10, dir: 0))
kvs[:ids] |> Enum.map(&msg(id: &1))
|> Enum.each(&assert(
KVS.reader(id: rid, feed: ^feed, args: [], cache: &1) =
:kvs.save(:kvs.drop(KVS.reader(:kvs.load_reader(rid), args: 1, dir: 0)))))
assert r2 = KVS.reader(id: ^rid, feed: ^feed, args: [], cache: c1) = :kvs.drop(KVS.reader(r, args: 1, dir: 0))
assert {:msg, Enum.at(kvs[:ids], 1), feed} == c1
assert KVS.reader(id: ^rid, feed: ^feed, args: [], cache: c2) = :kvs.drop(KVS.reader(r2, args: 5, dir: 0))
assert {:msg, Enum.at(kvs[:ids], 6), feed} == c2
assert KVS.reader(id: ^rid, feed: ^feed, args: []) = :kvs.drop(KVS.reader(r1, args: 100))
end
test "feed",kvs do
docs = :kvs.all("/crm/personal/Реєстратор А1/in/doc")
ducks = :kvs.all("/crm/personal/Реєстратор А1/in/directory/duck")
mail = :kvs.all("/crm/personal/Реєстратор А1/in/mail")
total = :kvs.all("/crm/personal/Реєстратор А1/in")
assert ducks++docs++mail == total
assert docs = :kvs.feed("/crm/personal/Реєстратор А1/in/doc")
assert ducks = :kvs.feed("/crm/personal/Реєстратор А1/in/directory/duck")
assert mail = :kvs.feed("/crm/personal/Реєстратор А1/in/mail")
assert total = :kvs.feed("/crm/personal/Реєстратор А1/in")
assert :kvs.feed("/crm/personal/Реєстратор А1/in/directory/duck")
++ :kvs.feed("/crm/personal/Реєстратор А1/in/doc")
++ :kvs.feed("/crm/personal/Реєстратор А1/in/mail") == :kvs.feed("/crm/personal/Реєстратор А1/in")
end
defp log(x), do: IO.puts '#{inspect(x)}'
defp log(m, x), do: IO.puts '#{m} #{inspect(x)}'
end