From f6da7679b8bbef5185d3a7c179571cccbf3fc33c Mon Sep 17 00:00:00 2001
From: Anton Evangelatov <anton.evangelatov@gmail.com>
Date: Wed, 24 Jun 2020 14:40:29 +0200
Subject: [PATCH] connect client to miner; fix topic bug

---
 lotus-soup/baseline.go | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/lotus-soup/baseline.go b/lotus-soup/baseline.go
index 001066d5e..0ed3e1033 100644
--- a/lotus-soup/baseline.go
+++ b/lotus-soup/baseline.go
@@ -46,7 +46,7 @@ func runBaselineBootstrapper(t *TestEnvironment) error {
 
 func runBaselineMiner(t *TestEnvironment) error {
 	t.RecordMessage("running miner")
-	miner, err := prepareMiner(t)
+	_, err := prepareMiner(t)
 	if err != nil {
 		return err
 	}
@@ -59,12 +59,6 @@ func runBaselineMiner(t *TestEnvironment) error {
 
 	t.RecordMessage("got %v client addrs", len(addrs))
 
-	if err := miner.fullApi.NetConnect(ctx, addrs[0]); err != nil {
-		return err
-	}
-
-	t.RecordMessage("miner connected to client")
-
 	// subscribe to clients
 
 	// TODO wait a bit for network to bootstrap
@@ -76,7 +70,7 @@ func runBaselineMiner(t *TestEnvironment) error {
 
 func runBaselineClient(t *TestEnvironment) error {
 	t.RecordMessage("running client")
-	_, err := prepareClient(t)
+	client, err := prepareClient(t)
 	if err != nil {
 		return err
 	}
@@ -89,6 +83,12 @@ func runBaselineClient(t *TestEnvironment) error {
 
 	t.RecordMessage("got %v miner addrs", len(addrs))
 
+	if err := client.fullApi.NetConnect(ctx, addrs[0]); err != nil {
+		return err
+	}
+
+	t.RecordMessage("client connected to miner")
+
 	// TODO generate a number of random "files" and publish them to one or more miners
 	// TODO broadcast published content CIDs to other clients
 	// TODO select a random piece of content published by some other client and retreieve it
@@ -107,7 +107,7 @@ func collectClientsAddrs(t *TestEnvironment, ctx context.Context, clients int) (
 
 func collectAddrs(t *TestEnvironment, ctx context.Context, topic *sync.Topic, expectedValues int) ([]peer.AddrInfo, error) {
 	ch := make(chan peer.AddrInfo)
-	sub := t.SyncClient.MustSubscribe(ctx, clientsAddrsTopic, ch)
+	sub := t.SyncClient.MustSubscribe(ctx, topic, ch)
 
 	addrs := make([]peer.AddrInfo, 0, expectedValues)
 	for i := 0; i < expectedValues; i++ {