mirror of
https://github.com/logos-storage/logos-storage-nim.git
synced 2026-01-05 15:03:07 +00:00
7d29afbae8
- set disabled topics during codex compilation due to lack of support for disabling chronicles topics at runtime in codex - ensure that TRACE logs are set for nodes running in multinodesuite when DebugCodexNodes is set - add TRACE loglevel to testcli
120 lines
3.8 KiB
Nim
120 lines
3.8 KiB
Nim
import std/tempfiles
|
|
import std/times
|
|
import codex/conf
|
|
import codex/utils/fileutils
|
|
import ../../asynctest
|
|
import ../../checktest
|
|
import ../codexprocess
|
|
import ../nodeprocess
|
|
import ../utils
|
|
import ../../examples
|
|
|
|
const HardhatPort {.intdefine.}: int = 8545
|
|
const CodexApiPort {.intdefine.}: int = 8080
|
|
const CodexDiscPort {.intdefine.}: int = 8090
|
|
const DebugCodexNodes {.booldefine.}: bool = false
|
|
const LogsDir {.strdefine.}: string = ""
|
|
|
|
asyncchecksuite "Command line interface":
|
|
let startTime = now().format("yyyy-MM-dd'_'HH:mm:ss")
|
|
let key = "4242424242424242424242424242424242424242424242424242424242424242"
|
|
|
|
var currentTestName = ""
|
|
var testCount = 0
|
|
var nodeCount = 0
|
|
|
|
template test(tname, tbody) =
|
|
inc testCount
|
|
currentTestName = tname
|
|
test tname:
|
|
tbody
|
|
|
|
proc addLogFile(args: seq[string]): seq[string] =
|
|
when DebugCodexNodes:
|
|
return args.concat @[
|
|
"--log-file=" &
|
|
getLogFile(
|
|
LogsDir,
|
|
startTime,
|
|
"Command line interface",
|
|
currentTestName,
|
|
"Client",
|
|
some nodeCount mod testCount,
|
|
),
|
|
"--log-level=" & $LogLevel.TRACE,
|
|
]
|
|
else:
|
|
return args
|
|
|
|
proc startCodex(arguments: seq[string]): Future[CodexProcess] {.async.} =
|
|
inc nodeCount
|
|
let args = arguments.addLogFile
|
|
return await CodexProcess.startNode(
|
|
args.concat(
|
|
@[
|
|
"--api-port=" & $(await nextFreePort(CodexApiPort + nodeCount)),
|
|
"--disc-port=" & $(await nextFreePort(CodexDiscPort + nodeCount)),
|
|
]
|
|
),
|
|
debug = DebugCodexNodes,
|
|
"cli-test-node",
|
|
)
|
|
|
|
test "complains when persistence is enabled without ethereum account":
|
|
let node = await startCodex(@["persistence"])
|
|
await node.waitUntilOutput("Persistence enabled, but no Ethereum account was set")
|
|
await node.stop(expectedErrCode = 1)
|
|
|
|
test "complains when ethereum private key file has wrong permissions":
|
|
let unsafeKeyFile = genTempPath("", "")
|
|
discard unsafeKeyFile.writeFile(key, 0o666)
|
|
let node = await startCodex(
|
|
@[
|
|
"persistence",
|
|
"--eth-provider=" & "http://127.0.0.1:" & $HardhatPort,
|
|
"--eth-private-key=" & unsafeKeyFile,
|
|
]
|
|
)
|
|
await node.waitUntilOutput(
|
|
"Ethereum private key file does not have safe file permissions"
|
|
)
|
|
await node.stop(expectedErrCode = 1)
|
|
discard removeFile(unsafeKeyFile)
|
|
|
|
let
|
|
marketplaceArg = "--marketplace-address=" & $EthAddress.example
|
|
expectedDownloadInstruction =
|
|
"Proving circuit files are not found. Please run the following to download them:"
|
|
|
|
test "suggests downloading of circuit files when persistence is enabled without accessible r1cs file":
|
|
let node = await startCodex(@["persistence", "prover", marketplaceArg])
|
|
await node.waitUntilOutput(expectedDownloadInstruction)
|
|
await node.stop(expectedErrCode = 1)
|
|
|
|
test "suggests downloading of circuit files when persistence is enabled without accessible wasm file":
|
|
let node = await startCodex(
|
|
@[
|
|
"persistence",
|
|
"--eth-provider=" & "http://127.0.0.1:" & $HardhatPort,
|
|
"prover",
|
|
marketplaceArg,
|
|
"--circom-r1cs=tests/circuits/fixtures/proof_main.r1cs",
|
|
]
|
|
)
|
|
await node.waitUntilOutput(expectedDownloadInstruction)
|
|
await node.stop(expectedErrCode = 1)
|
|
|
|
test "suggests downloading of circuit files when persistence is enabled without accessible zkey file":
|
|
let node = await startCodex(
|
|
@[
|
|
"persistence",
|
|
"--eth-provider=" & "http://127.0.0.1:" & $HardhatPort,
|
|
"prover",
|
|
marketplaceArg,
|
|
"--circom-r1cs=tests/circuits/fixtures/proof_main.r1cs",
|
|
"--circom-wasm=tests/circuits/fixtures/proof_main.wasm",
|
|
]
|
|
)
|
|
await node.waitUntilOutput(expectedDownloadInstruction)
|
|
await node.stop(expectedErrCode = 1)
|