feature: add codecoverage and add race detection in go test, fix: fix…

… race conditions

.github/workflows/go.yml

@@ -63,10 +63,15 @@ jobs:
       run: go build -v ./cmd/bbgo
 
     - name: Test
-      run: go test ./pkg/...
+      run: go test -race -coverprofile coverage.txt -covermode atomic ./pkg/...
 
     - name: TestDnum
-      run: go test -tags dnum ./pkg/...
+      run: go test -race -coverprofile coverage_dnum.txt -covermode atomic -tags dnum ./pkg/...
+
+    - name: Upload Coverage Report
+      uses: codecov/codecov-actions@v2
+      with:
+        files: ./coverage.txt,./coverage_dnum.txt
 
     - name: Create dotenv file
       run: |

.gitignore

@@ -44,3 +44,6 @@ otp*png
 
 *.swp
 /pkg/backtest/assets.go
+
+coverage.txt
+coverage_dum.txt

codecov.yml

@@ -0,0 +1,23 @@
+codecov:
+    require_ci_to_pass: true
+
+comment:
+    behavior: default
+    layout: "reach,diff,flags,files,footer"
+    require_changes: no
+
+parsers:
+    gcov:
+        branch_detection:
+            conditional: yes
+            loop: yes
+            method: no
+            macro: no
+
+coverage:
+    precision: 2
+    round: down
+    range: "70...100"
+
+github_checks:
+    annotations: false

pkg/depth/buffer.go

@@ -133,16 +133,15 @@ func (b *Buffer) AddUpdate(o types.SliceOrderBook, firstUpdateID int64, finalArg
 }
 
 func (b *Buffer) fetchAndPush() error {
+	b.mu.Lock()
+	defer b.mu.Unlock()
 	book, finalUpdateID, err := b.fetcher()
 	if err != nil {
 		return err
 	}
 
 	log.Debugf("fetched depth snapshot, final update id %d", finalUpdateID)
 
-	b.mu.Lock()
-	defer b.mu.Unlock()
-
 	if len(b.buffer) > 0 {
 		// the snapshot is too early
 		if finalUpdateID < b.buffer[0].FirstUpdateID {

pkg/util/reonce_test.go

@@ -1,6 +1,7 @@
 package util
 
 import (
+	"sync"
 	"testing"
 	"time"
 
@@ -10,23 +11,29 @@ import (
 func TestReonce_DoAndReset(t *testing.T) {
 	var cnt = 0
 	var reonce Reonce
+	var wgAll, wg sync.WaitGroup
+	wg.Add(1)
+	wgAll.Add(2)
 	go reonce.Do(func() {
 		t.Log("once #1")
 		time.Sleep(10 * time.Millisecond)
 		cnt++
+		wg.Done()
+		wgAll.Done()
 	})
 
 	// make sure it's locked
-	time.Sleep(10 * time.Millisecond)
+	wg.Wait()
 	t.Logf("reset")
 	reonce.Reset()
 
 	go reonce.Do(func() {
 		t.Log("once #2")
 		time.Sleep(10 * time.Millisecond)
 		cnt++
+		wgAll.Done()
 	})
 
-	time.Sleep(time.Second)
+	wgAll.Wait()
 	assert.Equal(t, 2, cnt)
 }