basic integration tests

integration-test/init_test.go

@@ -1,23 +1,19 @@
 package main
 
 import (
-	"encoding/json"
 	"errors"
-	"io"
-	"io/ioutil"
+	"log"
 	"net"
-	"net/http"
 	"os"
 	"testing"
 
-	log "github.com/Sirupsen/logrus"
-	"gopkg.in/check.v1"
+	check "gopkg.in/check.v1"
 )
 
 func init() {
 	s, err := newApiSuite()
 	if err != nil {
-		log.Fatalln(err)
+		log.Fatal(err)
 	}
 
 	check.Suite(s)
@@ -47,27 +43,3 @@ func newApiSuite() (*ApiSuite, error) {
 		SwanHost: swanHost,
 	}, nil
 }
-
-func (s *ApiSuite) sendRequest(method, uri string, data io.Reader) (code int, body []byte, err error) {
-	req, err := http.NewRequest(method, "http://"+s.SwanHost+uri, data)
-	if err != nil {
-		return -1, nil, err
-	}
-
-	resp, err := http.DefaultClient.Do(req)
-	if err != nil {
-		return -1, nil, err
-	}
-	defer resp.Body.Close()
-
-	bs, err := ioutil.ReadAll(resp.Body)
-	if err != nil {
-		return -1, nil, err
-	}
-
-	return resp.StatusCode, bs, nil
-}
-
-func (s *ApiSuite) bind(data []byte, val interface{}) error {
-	return json.Unmarshal(data, &val)
-}

integration-test/swan_api_create_test.go

@@ -0,0 +1,54 @@
+package main
+
+import (
+	"fmt"
+	"time"
+
+	check "gopkg.in/check.v1"
+
+	"github.com/Dataman-Cloud/swan/types"
+)
+
+func (s *ApiSuite) TestCreateApp(c *check.C) {
+	// Purge
+	//
+	err := s.purge(time.Second*30, c)
+	c.Assert(err, check.IsNil)
+	fmt.Println("TestCreateApp() purged")
+
+	// New Create App
+	//
+	ver := demoVersion().setName("demo").setCount(10).setCPU(0.01).setMem(5).Get()
+	id := s.createApp(ver, c)
+	err = s.waitApp(id, types.OpStatusNoop, time.Second*30, c)
+	c.Assert(err, check.IsNil)
+	fmt.Println("TestCreateApp() created")
+
+	// verify app
+	app := s.inspectApp(id, c)
+	c.Assert(app.Name, check.Equals, "demo")
+	c.Assert(app.TaskCount, check.Equals, 10)
+	c.Assert(app.VersionCount, check.Equals, 1)
+	c.Assert(len(app.Version), check.Equals, 1)
+
+	// verify app versions
+	vers := s.listAppVersions(id, c)
+	c.Assert(len(vers), check.Equals, 1)
+	c.Assert(vers[0].CPUs, check.Equals, 0.01)
+	c.Assert(vers[0].Mem, check.Equals, float64(5))
+	c.Assert(vers[0].Instances, check.Equals, int32(10))
+	c.Assert(vers[0].RunAs, check.Equals, app.RunAs)
+
+	// verify app tasks
+	tasks := s.listAppTasks(id, c)
+	c.Assert(len(tasks), check.Equals, 10)
+	for _, task := range tasks {
+		c.Assert(task.Version, check.Equals, vers[0].ID)
+	}
+
+	// Remove
+	//
+	err = s.removeApp(id, time.Second*10, c)
+	c.Assert(err, check.IsNil)
+	fmt.Println("TestCreateApp() removed")
+}