refactor(fund): Change to loop.

Signed-off-by: Sophia Koehler <[email protected]>

Author: sophia1ch

channel/funder_test.go

@@ -198,7 +198,7 @@ func testFunderCrossOverFunding(t *testing.T, n int) {
 
 func TestEgoisticParticipantFunding(t *testing.T) {
 	// Peers will randomly fund for each other.
-	for i := 0; i < 10; i++ {
+	for i := 0; i < 30; i++ {
 		name := fmt.Sprintf("Egoistic Funding %v", i)
 		t.Run(name, func(t *testing.T) { testEgoisticParticipantFunding(t) })
 	}
@@ -235,7 +235,7 @@ func testEgoisticParticipantFunding(t *testing.T) {
 	require.True(t, len(finishTimes) == n, "Length of indexes must be n")
 	require.NoError(t, err)
 
-	t.Logf("Finish Times: %v", finishTimes)
+	t.Logf("finishTimes: %v", finishTimes)
 	// Check if finish time of egoistic funder is larger than finish time of non-egoistic funder.
 	correct := finishTimes[egoisticIndex].Time > finishTimes[int(math.Abs(float64(1-egoisticIndex)))].Time
 	// Use require.True to compare the finish times

channel/test/fund.go

@@ -36,38 +36,30 @@ func FundAll(ctx context.Context, funders []*channel.Funder, reqs []*pchannel.Fu
 	var mutex sync.Mutex
 
 	var wg sync.WaitGroup
-	wg.Add(2)
+	wg.Add(len(funders))
 
-	go func() {
-		defer wg.Done()
-		startTime := time.Now()
-		err := funders[egoisticIndex].Fund(ctx, *reqs[egoisticIndex])
-		require.NoError(t, err)
-		finishTime := time.Now()
-		require.NoError(t, err)
-		mutex.Lock()
-		finishTimes[egoisticIndex] = FunderFinishTime{
-			Index: egoisticIndex,
-			Time:  finishTime.Sub(startTime),
-		}
-		mutex.Unlock()
-	}()
+	waitTime := 2 * time.Second
 
-	go func() {
-		defer wg.Done()
-		time.Sleep(2 * time.Second)
-		startTime := time.Now()
-		err := funders[1-egoisticIndex].Fund(ctx, *reqs[1-egoisticIndex])
-		require.NoError(t, err)
-		finishTime := time.Now()
-		require.NoError(t, err)
-		mutex.Lock()
-		finishTimes[1-egoisticIndex] = FunderFinishTime{
-			Index: 1 - egoisticIndex,
-			Time:  finishTime.Sub(startTime),
-		}
-		mutex.Unlock()
-	}()
+	for i := range funders {
+		i := i
+		go func() {
+			defer wg.Done()
+			if i != egoisticIndex {
+				time.Sleep(waitTime)
+			}
+			startTime := time.Now()
+			err := funders[i].Fund(ctx, *reqs[i])
+			require.NoError(t, err)
+			finishTime := time.Now()
+			mutex.Lock()
+			finishTimes[i] = FunderFinishTime{
+				Index: i,
+				Time:  finishTime.Sub(startTime),
+			}
+			mutex.Unlock()
+		}()
+
+	}
 
 	wg.Wait()
 	return finishTimes, nil