Satyarepo

.travis.yml

@@ -25,6 +25,9 @@ before_install:
   - sudo apt-get install -y build-essential gcc
   - sudo apt-get install -y librados-dev librbd-dev
   - sudo apt-get install -y lvm2 tgt open-iscsi
+  - go get github.com/onsi/gomega
+  - go get github.com/onsi/ginkgo/ginkgo
+  - go get github.com/modocache/gover
 
 matrix:
   fast_finish: true
@@ -61,6 +64,10 @@ jobs:
     - script: make osds_e2etest_build
       name: "e2e_test"     # names the fifth Tests stage job
 
+after_failure:
+        - for v in /var/log/opensds/*.log ; do
+          echo $v logtail ======================== ; tail -100 $v ;
+          done
 after_success:
   - bash <(curl -s https://codecov.io/bash)
   # Clean OpenSDS Controller built data

Makefile

@@ -9,7 +9,7 @@
 # Unless required by applicable law or agreed to in writing, software
 # distributed under the License is distributed on an "AS IS" BASIS,
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
+# See the License for the specific language governing permissions and 
 # limitations under the License.
 
 BASE_DIR := $(shell pwd)

test/integration/fileshare_suit_test.go

@@ -0,0 +1,40 @@
+// Copyright 2019 The OpenSDS Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+// +build integration
+
+package integration
+
+import (
+	"fmt"
+	"testing"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+)
+
+//Function to run the Ginkgo Test
+func TestFileShareIntegration(t *testing.T) {
+	RegisterFailHandler(Fail)
+	//var UID string
+	var _ = BeforeSuite(func() {
+		fmt.Println("Before Suite Execution")
+
+	})
+	AfterSuite(func() {
+		By("After Suite Execution....!")
+	})
+
+	RunSpecs(t, "File Share Integration Test Suite")
+}

test/integration/fileshare_test.go

@@ -0,0 +1,94 @@
+// Copyright 2019 The OpenSDS Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+// +build integration
+
+package integration
+
+import (
+
+	"testing"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+	utils "github.com/opensds/opensds/test/integration/utils"
+)
+
+func TestFileShare(t *testing.T) {
+	RegisterFailHandler(Fail)
+	RunSpecs(t, "FileShare Suite")
+}
+
+var (
+	OPERATION_FAILED = "OPERATION_FAILED"
+)
+var _ = Describe("FileShare Testing", func() {
+
+	Context("create FileShare ", func() {
+
+		BeforeEach(func() {
+
+		})
+		AfterEach(func() {
+		})
+		It("TC_FS_IT_01: Create fileshare with name input ", func() {
+			var jsonStr = map[string]interface{}{"name": "share2223", "description": "This is just for test222", "size": 2}
+
+			// var jsonStr1 = []byte(`{"name":"share22234", "description":"This is just for test222", "size": 2}`)
+
+			url := "http://127.0.0.1:50040/v1beta/e93b4c0934da416eb9c8d120c5d04d96/file/shares" //curl -X POST -H "Content-Type: application/json" -d '{"name":"share1", "description":"This is just for test", "size": 1}' -url "http://127.0.0.1:50040/v1beta/e93b4c0934da416eb9c8d120c5d04d96/file/shares"
+			methodName := "POST"
+			resp, err := utils.ConnectToHTTP(methodName, url, jsonStr)
+
+			Expect(resp.StatusCode).Should(Equal(202))
+			Expect(err).NotTo(HaveOccurred())
+
+		})
+		It("TC_FS_IT_02: Create fileshare with duplicate name input ", func() {
+			var jsonStr2 = map[string]interface{}{"name": "sharexxx", "description": "This is just for testxxx", "size": 2}
+			url := "http://127.0.0.1:50040/v1beta/e93b4c0934da416eb9c8d120c5d04d96/file/shares" //curl -X POST -H "Content-Type: application/json" -d '{"name":"share1", "description":"This is just for test", "size": 1}' -url "http://127.0.0.1:50040/v1beta/e93b4c0934da416eb9c8d120c5d04d96/file/shares"
+			methodName := "POST"
+			utils.ConnectToHTTP(methodName, url, jsonStr2)
+		})
+		// It("has 0 units", func() {})
+		// Specify("the total amount is 0.00", func() {})
+	})
+	Context("Get FileShare ", func() {
+		// var jsonStr1 = []byte(`{"name":"share2223", "description":"This is just for test222", "size": 2}`)
+		// var jsonStr = map[string]interface{}{"name": "share2223", "description": "This is just for test222", "size": 2}
+		BeforeEach(func() {
+		})
+		AfterEach(func() {
+		})
+		It("TC_FS_IT_03: fileshare GET all ", func() {
+			url := "http://127.0.0.1:50040/v1beta/e93b4c0934da416eb9c8d120c5d04d96/file/shares" //curl -X POST -H "Content-Type: application/json" -d '{"name":"share1", "description":"This is just for test", "size": 1}' -url "http://127.0.0.1:50040/v1beta/e93b4c0934da416eb9c8d120c5d04d96/file/shares"
+			methodName := "GET"
+			utils.ConnectToHTTP(methodName, url, nil)
+		})
+		It("TC_FS_IT_04: fileshare GET of specific Id", func() {
+			fId := "v1beta/file/shares/e93b4c0934da416eb9c8d120c5d04d96/f2ab9308-f208-40c6-bb1f-6fbfa8bf14b5"
+			url := "http://127.0.0.1:50040/v1beta/e93b4c0934da416eb9c8d120c5d04d96/file/shares/f2ab9308-f208-40c6-bb1f-6fbfa8bf14b5" //curl -X POST -H "Content-Type: application/json" -d '{"name":"share1", "description":"This is just for test", "size": 1}' -url "http://127.0.0.1:50040/v1beta/e93b4c0934da416eb9c8d120c5d04d96/file/shares"
+			methodName := "GET"
+			utils.ConnectToHTTP(methodName, url, nil)
+			// ctx, kv := utils.ConnectToDB()
+			ret := utils.GetValueByKeyFromDB(fId)
+			Expect(ret).ShouldNot(Equal(OPERATION_FAILED))
+			textFound := utils.ReadAndFindTextInFile("C:/go/src/opensds/opensds/test/integration/utils/output.json", "17c60641-63c9-4f7f-992a-c0dcd9abd502")
+			Expect(textFound).To(BeTrue(), "Text found in the log file")
+
+		})
+		// It("has 0 units", func() {})
+		// Specify("the total amount is 0.00", func() {})
+	})
+})

test/integration/utils/DBHelper.go

@@ -0,0 +1,87 @@
+// Copyright 2019 The OpenSDS Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+package utils
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/coreos/etcd/clientv3"
+)
+
+var (
+	dialTimeout    = 10 * time.Second
+	requestTimeout = 200 * time.Second
+)
+
+func GetValueByKeyFromDB(key string) string {
+	ctx, _ := context.WithTimeout(context.Background(), requestTimeout)
+	cli, err := clientv3.New(clientv3.Config{
+		DialTimeout: dialTimeout,
+		Endpoints:   []string{"192.168.20.123:62379"},
+	})
+	if err != nil {
+		log.Fatal(err)
+		// can define the below one in constants file and import
+		return "OPERATION_FAILED"
+	}
+	defer cli.Close()
+	kv := clientv3.NewKV(cli)
+	return GetValueByKey(ctx, kv, key)
+	// GetSingleValueDemo(ctx, kv)
+	// GetMultipleValuesWithPaginationDemo(ctx, kv)
+	// WatchDemo(ctx, cli, kv)
+	// LeaseDemo(ctx, cli, kv)
+	// return ctx, kv
+}
+func GetValueByKey(ctx context.Context, kv clientv3.KV, key string) string {
+	fmt.Println("*** GetValueByKey()")
+	// Delete all keys
+	// kv.Delete(ctx, "key", clientv3.WithPrefix())
+
+	// // Insert a key value
+	// pr, err := kv.Put(ctx, "key", "444")
+	// if err != nil {
+	// 	log.Fatal(err)
+	// }
+
+	// rev := pr.Header.Revision
+
+	// fmt.Println("Revision:", rev)
+
+	// gr, err := kv.Get(ctx, "v1beta/file/shares/e93b4c0934da416eb9c8d120c5d04d96/f2ab9308-f208-40c6-bb1f-6fbfa8bf14b5")
+	// 09b1c6e4-9dac-46cc-bb09-54795a354a79
+	// gr, err := kv.Get(ctx, "09b1c6e4-9dac-46cc-bb09-54795a354a79")
+
+	gr, err := kv.Get(ctx, key)
+	if err != nil {
+		log.Fatal(err)
+		// can define the below one in constants file and import
+		return "OPERATION_FAILED"
+	}
+
+	fmt.Println("Value: ", string(gr.Kvs[0].Value), "Revision: ", gr.Header.Revision)
+	return string(gr.Kvs[0].Value)
+	// // Modify the value of an existing key (create new revision)
+	// kv.Put(ctx, "key", "555")
+
+	// gr, _ = kv.Get(ctx, "key")
+	// fmt.Println("Value: ", string(gr.Kvs[0].Value), "Revision: ", gr.Header.Revision)
+
+	// // Get the value of the previous revision
+	// gr, _ = kv.Get(ctx, "key", clientv3.WithRev(rev))
+	// fmt.Println("Value: ", string(gr.Kvs[0].Value), "Revision: ", gr.Header.Revision)
+}