cephfs/admin: Use internal wrapper for detecting server version

Signed-off-by: Anoop C S <[email protected]>

Author: anoopcs9

cephfs/admin/fsadmin_test.go

@@ -2,12 +2,12 @@ package admin
 
 import (
 	"errors"
-	"os"
 	"testing"
 
 	"github.com/stretchr/testify/assert"
 
 	"github.com/ceph/go-ceph/internal/admintest"
+	"github.com/ceph/go-ceph/internal/util"
 )
 
 var (
@@ -17,21 +17,8 @@ var (
 	serverVersion string
 )
 
-const (
-	cephNautilus = "nautilus"
-	cephOctopus  = "octopus"
-	cephPacfic   = "pacific"
-	cephQuincy   = "quincy"
-	cephReef     = "reef"
-	cephSquid    = "squid"
-	cephMain     = "main"
-)
-
 func init() {
-	switch vname := os.Getenv("CEPH_VERSION"); vname {
-	case cephNautilus, cephOctopus, cephPacfic, cephQuincy, cephReef, cephSquid, cephMain:
-		serverVersion = vname
-	}
+	serverVersion = util.CurrentCephVersionString()
 }
 
 func TestServerSentinel(t *testing.T) {

cephfs/admin/volume_test.go

@@ -5,6 +5,8 @@ import (
 	"testing"
 
 	"github.com/stretchr/testify/assert"
+
+	"github.com/ceph/go-ceph/internal/util"
 )
 
 func TestListVolumes(t *testing.T) {
@@ -182,7 +184,7 @@ func TestParseDumpToIdents(t *testing.T) {
 }
 
 func TestVolumeStatus(t *testing.T) {
-	if serverVersion == cephNautilus {
+	if serverVersion == util.Nautilus {
 		t.Skipf("can only execute on octopus/pacific servers")
 	}
 	fsa := getFSAdmin(t)
@@ -193,7 +195,7 @@ func TestVolumeStatus(t *testing.T) {
 }
 
 func TestVolumeStatusInvalid(t *testing.T) {
-	if serverVersion != cephNautilus {
+	if serverVersion != util.Nautilus {
 		t.Skipf("can only excecute on nautilus servers")
 	}
 	fsa := getFSAdmin(t)