This is an automated email from the ASF dual-hosted git repository.
tianxiaoliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/servicecomb-service-center.git
The following commit(s) were added to refs/heads/master by this push:
new 01671f4 [SCB-2094]open server/service ut (#864)
01671f4 is described below
commit 01671f49402b98123d3810dc8d4a12b2c6af99ea
Author: robotLJW <[email protected]>
AuthorDate: Fri Feb 19 17:20:21 2021 +0800
[SCB-2094]open server/service ut (#864)
---
scripts/ut.sh | 21 +++++++++++++++++----
scripts/ut_test_in_docker.sh | 1 +
server/service/dependency_test.go | 32 ++++++++++++++++++++------------
3 files changed, 38 insertions(+), 16 deletions(-)
diff --git a/scripts/ut.sh b/scripts/ut.sh
index 247cf6d..034725c 100755
--- a/scripts/ut.sh
+++ b/scripts/ut.sh
@@ -21,13 +21,26 @@ ROOT_PATH=$(dirname $CURRENT_PATH)
export COVERAGE_PATH=$(pwd)
cd $1
-for d in $(go list -f '{{.Dir}}' ./... | grep -v vendor| grep -v syncer); do
- cd $d
- if [ $(ls | grep _test.go | wc -l) -gt 0 ]; then
+
+run_test() {
+ cd $1
+ if [ $(ls | grep _test.go | wc -l) -gt 0 ]; then
go test -cover -covermode atomic -coverprofile coverage.out
if [ -f coverage.out ]; then
sed '1d;$d' coverage.out >> $ROOT_PATH/coverage.txt
fi
fi
-done
+}
+
+test_mode=${TEST_MODE}
+
+if [ ${test_mode} == "mongo" ];then
+ for d in $(go list -f '{{.Dir}}' ./... | grep -v vendor| grep -v syncer |
grep -v broker); do
+ run_test $d
+ done
+else
+ for d in $(go list -f '{{.Dir}}' ./... | grep -v vendor| grep -v syncer); do
+ run_test $d
+ done
+fi
diff --git a/scripts/ut_test_in_docker.sh b/scripts/ut_test_in_docker.sh
index 207f031..ee798ea 100755
--- a/scripts/ut_test_in_docker.sh
+++ b/scripts/ut_test_in_docker.sh
@@ -76,6 +76,7 @@ export TEST_MODE=mongo
[ $? == 0 ] && ut_for_file datasource
[ $? == 0 ] && ut_for_dir datasource/mongo
[ $? == 0 ] && ut_for_dir syncer
+[ $? == 0 ] && ut_for_dir server
ret=$?
if [ ${ret} == 0 ]; then
diff --git a/server/service/dependency_test.go
b/server/service/dependency_test.go
index 1bea684..5f5dbb5 100644
--- a/server/service/dependency_test.go
+++ b/server/service/dependency_test.go
@@ -19,13 +19,15 @@ package service_test
import (
"strconv"
+ pb "github.com/go-chassis/cari/discovery"
+ "github.com/go-chassis/go-archaius"
+ . "github.com/onsi/ginkgo"
+ . "github.com/onsi/gomega"
+
"github.com/apache/servicecomb-service-center/datasource/etcd/client"
"github.com/apache/servicecomb-service-center/datasource/etcd/event"
"github.com/apache/servicecomb-service-center/datasource/etcd/kv"
"github.com/apache/servicecomb-service-center/datasource/etcd/path"
- pb "github.com/go-chassis/cari/discovery"
- . "github.com/onsi/ginkgo"
- . "github.com/onsi/gomega"
)
var deh event.DependencyEventHandler
@@ -883,18 +885,24 @@ var _ = Describe("'Dependency' service", func() {
})
func DependencyHandle() {
- for {
- Expect(deh.Handle()).To(BeNil())
+ t := archaius.Get("TEST_MODE")
+ if t == nil {
+ t = "etcd"
+ }
+ if t == "etcd" {
+ for {
+ Expect(deh.Handle()).To(BeNil())
- key := path.GetServiceDependencyQueueRootKey("")
- resp, err := kv.Store().DependencyQueue().Search(getContext(),
- client.WithStrKey(key), client.WithPrefix(),
client.WithCountOnly())
+ key := path.GetServiceDependencyQueueRootKey("")
+ resp, err :=
kv.Store().DependencyQueue().Search(getContext(),
+ client.WithStrKey(key), client.WithPrefix(),
client.WithCountOnly())
- Expect(err).To(BeNil())
+ Expect(err).To(BeNil())
- // maintain dependency rules.
- if resp.Count == 0 {
- break
+ // maintain dependency rules.
+ if resp.Count == 0 {
+ break
+ }
}
}
}