johannespetzold/main.go

## main.go
package main

import (
	"log"
	"net/http"
	"os"

	"github.com/cloudfoundry-incubator/receptor/cmd/receptor/testrunner"
	"github.com/cloudfoundry/storeadapter/storerunner/etcdstorerunner"
	"github.com/onsi/ginkgo"
	"github.com/onsi/gomega"
	"github.com/onsi/gomega/gexec"
	"github.com/tedsuo/ifrit"
	"github.com/tedsuo/ifrit/grouper"
	"github.com/tedsuo/ifrit/http_server"
	"github.com/tedsuo/ifrit/sigmon"
)

const (
	EtcdPort        = 4001
	EtcdUrl         = "http://127.0.0.1:4001"
	ReceptorAddress = "bar.com:6700"
	TestAddress     = "foo.com:8081"
	Username        = "user"
	Password        = "pass"
)

const Html = `
<html>
	<head></head>
	<body>
		<div id="output"></div>
		<script type="text/javascript">
			window.onload = function(){
				console.log("starting CORS request")
	    	var req = new XMLHttpRequest();
	    	req.withCredentials = true;
	    	req.onreadystatechange = function(){
	    		console.log("readyState",this.readyState)
	    		if (this.readyState == 4) {
	    			console.log("Finished CORS request",this.responseText);
	    		}
	    	}
	    	req.open("delete", "http://` + ReceptorAddress + `/v1/tasks/abcd", true, "` + Username + `", "` + Password + `");
	    	req.send()
	    }
		</script>
	</body>
</html>
`

var handler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
	w.Write([]byte(Html))
}

var etcdRunner ifrit.RunFunc = func(signals <-chan os.Signal, ready chan<- struct{}) error {
	etcdProcess := etcdstorerunner.NewETCDClusterRunner(EtcdPort, 1)
	etcdProcess.Start()
	close(ready)

	<-signals
	etcdProcess.Stop()
	return nil
}

func main() {
	gomega.RegisterFailHandler(ginkgo.Fail)
	receptorBinPath, err := gexec.Build("github.com/cloudfoundry-incubator/receptor/cmd/receptor")
	exitOnError(err)
	defer gexec.CleanupBuildArtifacts()

	receptorArgs := testrunner.Args{
		Address:     ReceptorAddress,
		EtcdCluster: EtcdUrl,
		Username:    Username,
		Password:    Password,
		CORSEnabled: true,
	}

	group := grouper.NewOrdered(os.Interrupt, grouper.Members{
		{"etcd", etcdRunner},
		{"receptor", testrunner.New(receptorBinPath, receptorArgs)},
		{"cors-test", http_server.New(TestAddress, handler)},
	})

	log.Print("CORS Test starting")
	process := ifrit.Invoke(sigmon.New(group))
	log.Print("CORS Test started")

	err = <-process.Wait()
	exitOnError(err)
}

func exitOnError(err error) {
	if err != nil {
		log.Print("FATAL ERROR", err)
		os.Exit(1)
	}
}
	package main

	import (
	"log"
	"net/http"
	"os"

	"github.com/cloudfoundry-incubator/receptor/cmd/receptor/testrunner"
	"github.com/cloudfoundry/storeadapter/storerunner/etcdstorerunner"
	"github.com/onsi/ginkgo"
	"github.com/onsi/gomega"
	"github.com/onsi/gomega/gexec"
	"github.com/tedsuo/ifrit"
	"github.com/tedsuo/ifrit/grouper"
	"github.com/tedsuo/ifrit/http_server"
	"github.com/tedsuo/ifrit/sigmon"
	)

	const (
	EtcdPort = 4001
	EtcdUrl = "http://127.0.0.1:4001"
	ReceptorAddress = "bar.com:6700"
	TestAddress = "foo.com:8081"
	Username = "user"
	Password = "pass"
	)

	const Html = `
	<html>
	<head></head>
	<body>
	<div id="output"></div>
	<script type="text/javascript">
	window.onload = function(){
	console.log("starting CORS request")
	var req = new XMLHttpRequest();
	req.withCredentials = true;
	req.onreadystatechange = function(){
	console.log("readyState",this.readyState)
	if (this.readyState == 4) {
	console.log("Finished CORS request",this.responseText);
	}
	}
	req.open("delete", "http://` + ReceptorAddress + `/v1/tasks/abcd", true, "` + Username + `", "` + Password + `");
	req.send()
	}
	</script>
	</body>
	</html>
	`

	var handler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) {
	w.Write([]byte(Html))
	}

	var etcdRunner ifrit.RunFunc = func(signals <-chan os.Signal, ready chan<- struct{}) error {
	etcdProcess := etcdstorerunner.NewETCDClusterRunner(EtcdPort, 1)
	etcdProcess.Start()
	close(ready)

	<-signals
	etcdProcess.Stop()
	return nil
	}

	func main() {
	gomega.RegisterFailHandler(ginkgo.Fail)
	receptorBinPath, err := gexec.Build("github.com/cloudfoundry-incubator/receptor/cmd/receptor")
	exitOnError(err)
	defer gexec.CleanupBuildArtifacts()

	receptorArgs := testrunner.Args{
	Address: ReceptorAddress,
	EtcdCluster: EtcdUrl,
	Username: Username,
	Password: Password,
	CORSEnabled: true,
	}

	group := grouper.NewOrdered(os.Interrupt, grouper.Members{
	{"etcd", etcdRunner},
	{"receptor", testrunner.New(receptorBinPath, receptorArgs)},
	{"cors-test", http_server.New(TestAddress, handler)},
	})

	log.Print("CORS Test starting")
	process := ifrit.Invoke(sigmon.New(group))
	log.Print("CORS Test started")

	err = <-process.Wait()
	exitOnError(err)
	}

	func exitOnError(err error) {
	if err != nil {
	log.Print("FATAL ERROR", err)
	os.Exit(1)
	}
	}