Merge pull request #74 from linkernetworks/hwchiu/VX-154

Check the volume before deleting the storage

Former-commit-id: 9b073fc36c5e6fda4dd79a0761cfcb7eb1a0ebb6 [formerly 9b073fc36c5e6fda4dd79a0761cfcb7eb1a0ebb6 [formerly 92d1323]]
Former-commit-id: 5ea79fa75eb3d0bb64339b4023829e68cd3cf875
Former-commit-id: 88cb75f

src/storageprovider/nfs.go

@@ -6,11 +6,12 @@ import (
 
 	"github.com/linkernetworks/vortex/src/entity"
 	"github.com/linkernetworks/vortex/src/serviceprovider"
+	"gopkg.in/mgo.v2/bson"
+
 	appsv1 "k8s.io/api/apps/v1"
 	"k8s.io/api/core/v1"
 	storagev1 "k8s.io/api/storage/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	//	"gopkg.in/mgo.v2/bson"
 )
 
 const NFS_PROVISIONER_PREFIX = "nfs-provisioner-"
@@ -119,6 +120,19 @@ func (nfs NFSStorageProvider) CreateStorage(sp *serviceprovider.Container, stora
 func (nfs NFSStorageProvider) DeleteStorage(sp *serviceprovider.Container, storage *entity.Storage) error {
 	deployName := NFS_PROVISIONER_PREFIX + storage.ID.Hex()
 	storageName := NFS_STORAGECLASS_PREFIX + storage.ID.Hex()
+
+	//If the storage is used by some volume, we can't delete it.
+	q := bson.M{"storageName": storage.Name}
+	session := sp.Mongo.NewSession()
+	defer session.Close()
+
+	count, err := session.Count(entity.VolumeCollectionName, q)
+	if err != nil {
+		return err
+	} else if count > 0 {
+		return fmt.Errorf("The StorageName %s can't be deleted, since there're some volume still use it", storage.Name)
+	}
+
 	//Delete StorageClass
 	if err := sp.KubeCtl.DeleteStorageClass(storageName); err != nil {
 		return err

src/storageprovider/nfs_test.go

@@ -1,16 +1,24 @@
 package storageprovider
 
 import (
+	"math/rand"
 	"testing"
+	"time"
 
 	//"github.com/linkernetworks/mongo"
 	"github.com/linkernetworks/vortex/src/config"
 	"github.com/linkernetworks/vortex/src/entity"
 	"github.com/linkernetworks/vortex/src/serviceprovider"
+	"github.com/moby/moby/pkg/namesgenerator"
 	"github.com/stretchr/testify/suite"
+
 	"gopkg.in/mgo.v2/bson"
 )
 
+func init() {
+	rand.Seed(time.Now().UnixNano())
+}
+
 type StorageTestSuite struct {
 	suite.Suite
 	sp *serviceprovider.Container
@@ -52,7 +60,6 @@ func (suite *StorageTestSuite) TestGetStorageClass() {
 
 	storageClass := getStorageClass(bson.NewObjectId().Hex(), bson.NewObjectId().Hex(), storage)
 	suite.NotNil(storageClass)
-
 }
 
 func (suite *StorageTestSuite) TestValidateBeforeCreating() {
@@ -124,6 +131,36 @@ func (suite *StorageTestSuite) TestDeleteStorage() {
 	suite.Error(err)
 }
 
+func (suite *StorageTestSuite) TestDeleteStorageFail() {
+	storage := &entity.Storage{
+		ID:   bson.NewObjectId(),
+		Type: entity.NFSStorageType,
+		NFS: &entity.NFSStorage{
+			IP:   "1.2.3.4",
+			PATH: "/exports",
+		},
+		Name: namesgenerator.GetRandomName(0),
+	}
+
+	volume := entity.Volume{
+		ID:          bson.NewObjectId(),
+		StorageName: storage.Name,
+	}
+
+	session := suite.sp.Mongo.NewSession()
+	defer session.Close()
+
+	session.Insert(entity.VolumeCollectionName, volume)
+	defer session.Remove(entity.VolumeCollectionName, "_id", volume.ID)
+
+	sp, err := GetStorageProvider(storage)
+	suite.NoError(err)
+	sp = sp.(NFSStorageProvider)
+
+	err = sp.DeleteStorage(suite.sp, storage)
+	suite.Error(err)
+}
+
 func (suite *StorageTestSuite) TestValidateBeforeCreatingFail() {
 	testCases := []struct {
 		caseName string