Fix Go-SDK for OpenFass API

example/main.go

@@ -18,10 +18,10 @@ func main() {
 		return
 	}
 
-	_, err = cli.GetSystemFunctions()
-	if err != nil {
-		golog.Error("Error from system functions:  ", err)
-	}
+	//_, err = cli.GetSystemFunctions()
+	//if err != nil {
+	//	golog.Error("Error from system functions:  ", err)
+	//}
 
 	data := &faas.FunctionDefintion{
 		Service: "nodeinfo",

go_faas_integration_test.go

@@ -0,0 +1,150 @@
+// +build integration
+
+package go_faas
+
+import "github.com/stretchr/testify/assert"
+
+func (suite *GoFaasTestSuite) TestFunctionsCRUD() {
+	funcName := "integration_testnodeinfo"
+
+	// get functions
+	resp, err := suite.cli.GetSystemFunctions()
+	if err != nil {
+		suite.T().Fatalf("GetSystemFunctions/Error: %v", err)
+	}
+	assert.Equal(suite.T(), nil, err)
+	assert.Equal(suite.T(), 200, resp.StatusCode)
+
+	// create a func
+	def := &FunctionDefintion{
+		Service:    funcName,
+		Network:    "func_functions",
+		Image:      "functions/nodeinfo:latest",
+		EnvProcess: "node main.js",
+		Constraints: []string{
+			"node.platform.os == linux",
+		},
+		Labels: map[string]string{
+			"labelkey": "labelval",
+		},
+		Annotations: Annotations{
+			Topics: "awesome-kafka-topic",
+			Foo:    "some",
+		},
+		RegistryAuth: "dXNlcjpwYXNzd29yZA==",
+		Limits: Limits{
+			Memory: "128M",
+			CPU:    "0.01",
+		},
+		Requests: Requests{
+			Memory: "128M",
+			CPU:    "0.01",
+		},
+		ReadOnlyRootFilesystem: true,
+	}
+	resp, err = suite.cli.CreateSystemFunctions(def)
+	if err != nil {
+		suite.T().Fatalf("CreateSystemFunctions/Error: %v", err)
+	}
+	assert.Equal(suite.T(), nil, err)
+	assert.Equal(suite.T(), 202, resp.StatusCode)
+
+	// get function summary
+	resp, err = suite.cli.GetFunctionSummary(funcName)
+	if err != nil {
+		suite.T().Fatalf("CreateSystemFunctions/Error: %v", err)
+	}
+	assert.Equal(suite.T(), nil, err)
+	assert.Equal(suite.T(), 200, resp.StatusCode)
+
+	// update the func
+	update := &FunctionDefintion{
+		Service: funcName,
+		Image:   "functions/nodeinfo:latest",
+		Limits: Limits{
+			Memory: "130M",
+			CPU:    "0.01",
+		},
+	}
+	resp, err = suite.cli.UpdateSystemFunctions(update)
+	if err != nil {
+		suite.T().Fatalf("UpdateSystemFunctions/Error: %v", err)
+	}
+	assert.Equal(suite.T(), nil, err)
+	assert.Equal(suite.T(), 202, resp.StatusCode)
+
+	// scale up the func
+	resp, err = suite.cli.ScaleFunction(&ScaleFunctionBodyOpts{
+		Service:  funcName,
+		Replicas: 3,
+	})
+	if err != nil {
+		suite.T().Fatalf("ScaleFunction/Up/Error: %v", err)
+	}
+	assert.Equal(suite.T(), nil, err)
+	assert.Equal(suite.T(), 202, resp.StatusCode)
+
+	// scale down the func
+	resp, err = suite.cli.ScaleFunction(&ScaleFunctionBodyOpts{
+		Service:  funcName,
+		Replicas: 1,
+	})
+	if err != nil {
+		suite.T().Fatalf("ScaleFunction/Down/Error: %v", err)
+	}
+	assert.Equal(suite.T(), nil, err)
+	assert.Equal(suite.T(), 202, resp.StatusCode)
+
+	// delete the func
+	resp, err = suite.cli.DeleteSystemFunction(&DeleteFunctionBodyOpts{FunctionName: funcName})
+	if err != nil {
+		suite.T().Fatalf("DeleteSystemFunction/Error: %v", err)
+	}
+	assert.Equal(suite.T(), nil, err)
+	assert.Equal(suite.T(), 202, resp.StatusCode)
+}
+
+func (suite *GoFaasTestSuite) TestSecretsCRUD() {
+	secretName := "integration_test_secret"
+	secretVal := "integration_test_secret_val"
+
+	//get secrets list
+	resp, err := suite.cli.GetSecrets()
+	if err != nil {
+		suite.T().Errorf("GetSecrets/Error: %v", err)
+	}
+	assert.Equal(suite.T(), nil, err)
+	assert.Equal(suite.T(), resp.StatusCode, 200)
+
+	// create new secret
+	resp, err = suite.cli.CreateNewSecret(&SecretBodyOpts{
+		Name:  secretName,
+		Value: secretVal,
+	})
+	if err != nil {
+		suite.T().Fatalf("CreateNewSecret/Error: %v", err)
+	}
+	assert.Equal(suite.T(), nil, err)
+	assert.Equal(suite.T(), 201, resp.StatusCode)
+
+	// update the secret if not a swarm cluster
+	if suite.cli.ClusterType != "swarm" {
+		resp, err = suite.cli.UpdateSecret(&SecretBodyOpts{
+			Name:  secretName,
+			Value: "updated_integration_test_secret_val",
+		})
+		if err != nil {
+			suite.T().Fatalf("UpdateSecret/Error: %v", err)
+		}
+		assert.Equal(suite.T(), nil, err)
+		assert.Equal(suite.T(), 200, resp.StatusCode)
+	}
+
+	// delete the secret
+	resp, err = suite.cli.DeleteSecret(&SecretNameBodyOpts{Name: secretName})
+	if err != nil {
+		suite.T().Fatalf("DeleteSecret/Error: %v", err)
+	}
+	assert.Equal(suite.T(), nil, err)
+	assert.Equal(suite.T(), 200, resp.StatusCode)
+}

go_faas_test.go

@@ -766,15 +766,21 @@ func (suite *GoFaasTestSuite) TestGetHealthz() {
 }
 
 func (suite *GoFaasTestSuite) TearDownSuite() {
+	// teardown functions
 	_, err := suite.cli.DeleteSystemFunction(&DeleteFunctionBodyOpts{FunctionName: "nodeinfo123456"})
 	if err != nil {
 		suite.T().Logf("error occurred while tearing down nodeinfo1235: %v", err)
-		_, err = suite.cli.DeleteSystemFunction(&DeleteFunctionBodyOpts{FunctionName: "yetanothernodeinfo"})
-		if err != nil {
-			suite.T().Logf("error occurred while tearing down yetanothernodeinfo: %v", err)
-		}
+	}
+	_, err = suite.cli.DeleteSystemFunction(&DeleteFunctionBodyOpts{FunctionName: "yetanothernodeinfo"})
+	if err != nil {
+		suite.T().Logf("error occurred while tearing down yetanothernodeinfo: %v", err)
+	}
+	_, err = suite.cli.DeleteSystemFunction(&DeleteFunctionBodyOpts{FunctionName: "integration_testnodeinfo"})
+	if err != nil {
+		suite.T().Logf("error occurred while tearing down integration_testnodeinfo: %v", err)
 	}
 
+	// teardown secrets
 	_, err = suite.cli.DeleteSecret(&SecretNameBodyOpts{Name: "secretkey101"})
 	if err != nil {
 		suite.T().Logf("Error tearing down secretkey101 : %v", err)
@@ -787,5 +793,9 @@ func (suite *GoFaasTestSuite) TearDownSuite() {
 	if err != nil {
 		suite.T().Logf("Error tearing down secretkey101 : %v", err)
 	}
+	_, err = suite.cli.DeleteSecret(&SecretNameBodyOpts{Name: "integration_test_secret"})
+	if err != nil {
+		suite.T().Logf("Error tearing down secretkey101 : %v", err)
+	}
 
 }