Merge branch 'release/0.0.5'

Author: ess

README.md

@@ -1,5 +1,6 @@
 ## History ##
 
+* v0.0.5 - Now with listen port configuration
 * v0.0.4 - Now with working task creation
 * v0.0.3 - Better console errors
 * v0.0.1 - initial dev release

cf/auth_service.go

@@ -58,11 +58,6 @@ func (service *AuthService) getUser(username string) (cf.User, error) {
 		return cf.User{}, err
 	}
 
-	fmt.Println("got", len(users), "users:", users)
-	for i, u := range users {
-		fmt.Println("user", i, "guid:", u.Guid)
-	}
-
 	user := users.GetUserByUsername(username)
 	if len(user.Guid) == 0 {
 		return cf.User{}, fmt.Errorf("no such user")

cmd/scheduler/main.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"os"
 	"os/signal"
+	"strconv"
 	"time"
 
 	realcf "github.com/cloudfoundry-community/go-cfclient"
@@ -30,6 +31,14 @@ func main() {
 	log := logger.New()
 	tag := "scheduler-for-ocf"
 
+	port := 8000
+	portEnv := os.Getenv("SCHEDULER_PORT")
+	if len(portEnv) > 0 {
+		if t, err := strconv.Atoi(portEnv); err == nil {
+			port = t
+		}
+	}
+
 	clientID := os.Getenv("CLIENT_ID")
 	if len(clientID) == 0 {
 		log.Error(tag, "CLIENT_ID not set")
@@ -156,7 +165,7 @@ func main() {
 		}
 	}
 
-	server := http.Server("0.0.0.0:8000", services)
+	server := http.Server(fmt.Sprintf("0.0.0.0:%d", port), services)
 
 	go func() {
 		if err := server.ListenAndServe(); err != nil {

mock/cf_client.go

@@ -170,10 +170,6 @@ func (client *CFClient) ListUsersByQuery(query url.Values) (cf.Users, error) {
 		},
 	}
 
-	for i, u := range users {
-		fmt.Println("FAKE CLIENT user", i, "guid:", u.Guid)
-	}
-
 	return users, nil
 }