50 lines
1.0 KiB
Nim
50 lines
1.0 KiB
Nim
import std/os
|
|
import pkg/asynctest
|
|
import pkg/chronos
|
|
import pkg/dagger
|
|
|
|
suite "integration":
|
|
|
|
let address = initTAddress("127.0.0.1:48952")
|
|
|
|
var peer1, peer2: DaggerPeer
|
|
var input, output: File
|
|
|
|
proc setupPeers =
|
|
peer1 = newDaggerPeer()
|
|
peer2 = newDaggerPeer()
|
|
peer1.listen(address)
|
|
peer2.dial(address)
|
|
|
|
proc setupFiles =
|
|
input = open("tests/input.txt", fmReadWrite)
|
|
output = open("tests/output.txt", fmReadWrite)
|
|
input.write("foo")
|
|
input.setFilePos(0)
|
|
|
|
proc teardownPeers =
|
|
peer1.close()
|
|
peer2.close()
|
|
|
|
proc teardownFiles =
|
|
input.close()
|
|
output.close()
|
|
removeFile("tests/input.txt")
|
|
removeFile("tests/output.txt")
|
|
|
|
setup:
|
|
setupPeers()
|
|
setupFiles()
|
|
|
|
teardown:
|
|
teardownPeers()
|
|
teardownFiles()
|
|
|
|
test "file can be transferred from one peer to another":
|
|
let identifier = await peer1.upload(input)
|
|
await peer2.download(identifier, output)
|
|
|
|
input.setFilePos(0)
|
|
output.setFilePos(0)
|
|
check output.readAll() == input.readAll()
|