Merge branch 'transaction-pooling' of https://github.com/ubclaunchpad…

…/cumulus into transaction-pooling

Makefile

@@ -1,3 +1,5 @@
+.PHONY: test deps clean install_glide
+
 PACKAGES = `go list ./... | grep -v vendor/`
 
 all: cumulus

glide.yaml

@@ -13,3 +13,9 @@ import:
 - package: github.com/Sirupsen/logrus
 - package: github.com/spf13/cobra
 - package: github.com/spf13/pflag
+- package: github.com/onsi/ginkgo
+  version: ^1.3.1
+  subpackages:
+  - ginkgo
+- package: github.com/onsi/gomega
+  version: ^1.1.0

test/cumulus_suite_test.go

@@ -0,0 +1,13 @@
+package test
+
+import (
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+
+	"testing"
+)
+
+func TestCumulus(t *testing.T) {
+	RegisterFailHandler(Fail)
+	RunSpecs(t, "Cumulus Suite")
+}

test/initialization.go

@@ -0,0 +1,33 @@
+package test
+
+import (
+	"os/exec"
+	"strconv"
+
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+	"github.com/ubclaunchpad/cumulus/conn"
+	"github.com/ubclaunchpad/cumulus/peer"
+)
+
+var _ = Describe("Initialization", func() {
+	var instance *exec.Cmd
+
+	BeforeEach(func() {
+		var err error
+		instance, err = startInstance()
+		Expect(err).ToNot(HaveOccurred())
+	})
+
+	AfterEach(func() {
+		if instance.Process != nil {
+			instance.Process.Kill()
+		}
+	})
+
+	// TODO fails until new peer implementation is merged in
+	PIt("should accept a TCP connection", func() {
+		_, err := conn.Dial(peer.DefaultIP + ":" + strconv.Itoa(peer.DefaultPort))
+		Expect(err).ToNot(HaveOccurred())
+	})
+})

test/utils.go

@@ -0,0 +1,29 @@
+package test
+
+import (
+	"fmt"
+	"os"
+	"os/exec"
+)
+
+func startInstance() (*exec.Cmd, error) {
+	fmt.Println("start instance")
+	install := exec.Command("go", "install")
+	install.Dir = "."
+
+	if out, err := install.CombinedOutput(); err != nil {
+		return nil, err
+	} else if len(out) != 0 {
+		// Successful go install is silent
+		return nil, fmt.Errorf(string(out))
+	}
+
+	app := exec.Command("cumulus", "run")
+	app.Stdout = os.Stdout
+	app.Stderr = os.Stderr
+
+	fmt.Println("about to start")
+	err := app.Start()
+	fmt.Println("started")
+	return app, err
+}