logos-storage/logos-storage-network-testing
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-network-testing.git synced 2026-01-02 13:33:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

UPD image and codex runs on dockers

Browse Source
This commit is contained in:
Shorssaud 2023-02-08 14:19:47 +01:00
parent 86e91cd2df
commit 5cdacf93ec
2 changed files with 29 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
Dockerfile
View File

@ -8,4 +8,5 @@ RUN apt update -qq && \
RUN curl https://nim-lang.org/choosenim/init.sh -sSf | sh -s -- -y RUN curl https://nim-lang.org/choosenim/init.sh -sSf | sh -s -- -y
ARG corecount=1 ARG corecount=1
COPY . . EXPOSE 8080
COPY nim-codex .

52
tests/codex_test.go
View File

@ -28,38 +28,41 @@ func TestHello(t *testing.T) {
nodes := c.MustNewNodes(5) nodes := c.MustNewNodes(5)
group, groupCtx := errgroup.WithContext(context.Background()) group, groupCtx := errgroup.WithContext(context.Background())
addrs := "/ip4/0.0.0.0/tcp/50880" addrs := "/ip4/0.0.0.0/tcp/8090"
for i, node := range nodes { for i, node := range nodes {
node := node.Context(groupCtx) node := node.Context(groupCtx)
if i == 0 { if i == 0 {
// host node group.Go(func() error {
stdout := &bytes.Buffer{} // host node
stderr := &bytes.Buffer{} stdout := &bytes.Buffer{}
_, err := node.StartProc(cluster.StartProcRequest{ stderr := &bytes.Buffer{}
Command: "./build/codex", // when running api on 8080, the host node will not be able to connect to the client node
Args: []string{"--nat=100.80.179.146", "--metrics", "--api-port=8080", "--data-dir=`pwd`/Codex1", "--disc-port=8090", "--log-level=TRACE", "-i=" + addrs, "-q=1099511627776"}, _, err := node.StartProc(cluster.StartProcRequest{
Stdout: stdout, Command: "./build/codex",
Stderr: stderr, Args: []string{"--metrics", "--api-port=8090", "--data-dir=`pwd`/Codex1", "--disc-port=8080", "--log-level=TRACE", "-i=" + addrs, "-q=1099511627776"},
Stdout: stdout,
Stderr: stderr,
})
if err != nil {
t.Errorf(`starting client on node %d: %s`, i, err)
return err
}
if err != nil {
t.Errorf(`waiting for client on node %d: %s`, i, err)
return err
}
for true {
t.Logf("HOST Output: %s\n\n", stdout.String())
t.Logf("HOST EOutput: %s\n\n", stderr.String())
}
return nil
}) })
if err != nil {
t.Errorf(`starting client on node %d: %s`, i, err)
continue
}
// extract spr from host node output
time.Sleep(2 * time.Second) time.Sleep(2 * time.Second)
if err != nil {
t.Errorf(`waiting for client on node %d: %s`, i, err)
continue
}
t.Logf("HOST Output: %s\n\n", stdout.String())
t.Logf("HOST EOutput: %s\n\n", stderr.String())
// t.Log("HOST proc: ", code)
continue continue
} else { } else {
group.Go(func() error { group.Go(func() error {
// wait for host to start // wait for host to start
resp, err := http.Get("http://127.0.0.1:8080/api/codex/v1/info") resp, err := http.Get("http://127.0.0.1:8090/api/codex/v1/info")
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }
@ -93,7 +96,6 @@ func TestHello(t *testing.T) {
// TODO ping host using get request // TODO ping host using get request
}) })
} }
// run(t, "local cluster", local.MustNewCluster()) // run(t, "local cluster", local.MustNewCluster())
run(t, "Docker cluster", docker.MustNewCluster().WithBaseImage("corbo12/nim-codex:v3")) run(t, "Docker cluster", docker.MustNewCluster().WithBaseImage("corbo12/nim-codex:v5"))
} }