mirror of https://github.com/waku-org/nwaku.git
171 lines
5.1 KiB
Nim
171 lines
5.1 KiB
Nim
{.used.}
|
|
|
|
import std/[sequtils, options], testutils/unittests, chronos
|
|
import
|
|
waku/[
|
|
waku_archive,
|
|
waku_archive/driver/postgres_driver,
|
|
waku_core,
|
|
waku_core/message/digest,
|
|
],
|
|
../testlib/wakucore,
|
|
../testlib/testasync,
|
|
../testlib/postgres
|
|
|
|
suite "Postgres driver":
|
|
## Unique driver instance
|
|
var driver {.threadvar.}: PostgresDriver
|
|
|
|
asyncSetup:
|
|
let driverRes = await newTestPostgresDriver()
|
|
if driverRes.isErr():
|
|
assert false, driverRes.error
|
|
|
|
driver = PostgresDriver(driverRes.get())
|
|
|
|
asyncTeardown:
|
|
let resetRes = await driver.reset()
|
|
if resetRes.isErr():
|
|
assert false, resetRes.error
|
|
|
|
(await driver.close()).expect("driver to close")
|
|
|
|
asyncTest "Asynchronous queries":
|
|
var futures = newSeq[Future[ArchiveDriverResult[void]]](0)
|
|
|
|
let beforeSleep = now()
|
|
|
|
for _ in 1 .. 25:
|
|
futures.add(driver.sleep(1))
|
|
|
|
await allFutures(futures)
|
|
|
|
let diff = now() - beforeSleep
|
|
|
|
assert diff < 2_000_000_000 ## nanoseconds
|
|
|
|
asyncTest "Insert a message":
|
|
const contentTopic = "test-content-topic"
|
|
const meta = "test meta"
|
|
|
|
let msg = fakeWakuMessage(contentTopic = contentTopic, meta = meta)
|
|
|
|
let putRes = await driver.put(
|
|
computeMessageHash(DefaultPubsubTopic, msg), DefaultPubsubTopic, msg
|
|
)
|
|
assert putRes.isOk(), putRes.error
|
|
|
|
let storedMsg = (await driver.getAllMessages()).tryGet()
|
|
|
|
assert storedMsg.len == 1
|
|
|
|
let (_, pubsubTopic, actualMsg) = storedMsg[0]
|
|
assert actualMsg.contentTopic == contentTopic
|
|
assert pubsubTopic == DefaultPubsubTopic
|
|
assert toHex(actualMsg.payload) == toHex(msg.payload)
|
|
assert toHex(actualMsg.meta) == toHex(msg.meta)
|
|
|
|
asyncTest "Insert and query message":
|
|
const contentTopic1 = "test-content-topic-1"
|
|
const contentTopic2 = "test-content-topic-2"
|
|
const pubsubTopic1 = "pubsubtopic-1"
|
|
const pubsubTopic2 = "pubsubtopic-2"
|
|
|
|
let msg1 = fakeWakuMessage(contentTopic = contentTopic1)
|
|
|
|
var putRes =
|
|
await driver.put(computeMessageHash(pubsubTopic1, msg1), pubsubTopic1, msg1)
|
|
assert putRes.isOk(), putRes.error
|
|
|
|
let msg2 = fakeWakuMessage(contentTopic = contentTopic2)
|
|
|
|
putRes =
|
|
await driver.put(computeMessageHash(pubsubTopic2, msg2), pubsubTopic2, msg2)
|
|
assert putRes.isOk(), putRes.error
|
|
|
|
let countMessagesRes = await driver.getMessagesCount()
|
|
|
|
assert countMessagesRes.isOk(), $countMessagesRes.error
|
|
assert countMessagesRes.get() == 2
|
|
|
|
var messagesRes = await driver.getMessages(contentTopics = @[contentTopic1])
|
|
|
|
assert messagesRes.isOk(), $messagesRes.error
|
|
assert messagesRes.get().len == 1
|
|
|
|
# Get both content topics, check ordering
|
|
messagesRes =
|
|
await driver.getMessages(contentTopics = @[contentTopic1, contentTopic2])
|
|
assert messagesRes.isOk(), messagesRes.error
|
|
|
|
assert messagesRes.get().len == 2
|
|
assert messagesRes.get()[0][2].contentTopic == contentTopic1
|
|
|
|
# Descending order
|
|
messagesRes = await driver.getMessages(
|
|
contentTopics = @[contentTopic1, contentTopic2], ascendingOrder = false
|
|
)
|
|
assert messagesRes.isOk(), messagesRes.error
|
|
|
|
assert messagesRes.get().len == 2
|
|
assert messagesRes.get()[0][2].contentTopic == contentTopic2
|
|
|
|
# cursor
|
|
# Get both content topics
|
|
messagesRes = await driver.getMessages(
|
|
contentTopics = @[contentTopic1, contentTopic2],
|
|
cursor = some(computeMessageHash(pubsubTopic1, messagesRes.get()[1][2])),
|
|
)
|
|
assert messagesRes.isOk()
|
|
assert messagesRes.get().len == 1
|
|
|
|
# Get both content topics but one pubsub topic
|
|
messagesRes = await driver.getMessages(
|
|
contentTopics = @[contentTopic1, contentTopic2], pubsubTopic = some(pubsubTopic1)
|
|
)
|
|
assert messagesRes.isOk(), messagesRes.error
|
|
|
|
assert messagesRes.get().len == 1
|
|
assert messagesRes.get()[0][2].contentTopic == contentTopic1
|
|
|
|
# Limit
|
|
messagesRes = await driver.getMessages(
|
|
contentTopics = @[contentTopic1, contentTopic2], maxPageSize = 1
|
|
)
|
|
assert messagesRes.isOk(), messagesRes.error
|
|
assert messagesRes.get().len == 1
|
|
|
|
asyncTest "Insert true duplicated messages":
|
|
# Validates that two completely equal messages can not be stored.
|
|
|
|
let now = now()
|
|
|
|
let msg1 = fakeWakuMessage(ts = now)
|
|
let msg2 = fakeWakuMessage(ts = now)
|
|
|
|
let initialNumMsgs = (await driver.getMessagesCount()).valueOr:
|
|
raiseAssert "could not get num mgs correctly: " & $error
|
|
|
|
var putRes = await driver.put(
|
|
computeMessageHash(DefaultPubsubTopic, msg1), DefaultPubsubTopic, msg1
|
|
)
|
|
assert putRes.isOk(), putRes.error
|
|
|
|
var newNumMsgs = (await driver.getMessagesCount()).valueOr:
|
|
raiseAssert "could not get num mgs correctly: " & $error
|
|
|
|
assert newNumMsgs == (initialNumMsgs + 1.int64),
|
|
"wrong number of messages: " & $newNumMsgs
|
|
|
|
putRes = await driver.put(
|
|
computeMessageHash(DefaultPubsubTopic, msg2), DefaultPubsubTopic, msg2
|
|
)
|
|
|
|
assert putRes.isOk()
|
|
|
|
newNumMsgs = (await driver.getMessagesCount()).valueOr:
|
|
raiseAssert "could not get num mgs correctly: " & $error
|
|
|
|
assert newNumMsgs == (initialNumMsgs + 1.int64),
|
|
"wrong number of messages: " & $newNumMsgs
|