Add recent logs test to Lats

- Also includes cf cli in loggregator-acceptance-tests job spec

[#109838452]

Signed-off-by: Sam Nelson <snelson@pivotal.io>

jobs/loggregator-acceptance-tests/spec

@@ -6,7 +6,7 @@ description: "The loggregator acceptance tests."
 packages:
   - golang1.7
   - loggregator-acceptance-tests
-
+  - cli
 templates:
   run.erb: bin/run
   config.json.erb: bin/config.json

jobs/loggregator-acceptance-tests/templates/config.json.erb

@@ -2,6 +2,7 @@
   require 'json'
 
   config = {
+    "AppDomain" => properties.system_domain,
     "DopplerEndpoint" => "wss://doppler." + properties.system_domain + ":4443",
     "SkipSSLVerify" => properties.ssl.skip_cert_verify,
     "DropsondePort" => properties.metron_agent.dropsonde_incoming_port,

jobs/loggregator-acceptance-tests/templates/run.erb

@@ -2,8 +2,9 @@
 
 set -e
 
+CLI_PATH=/var/vcap/packages/cli/bin
 export GOROOT=$(readlink -nf /var/vcap/packages/golang1.7)
-export PATH=${GOROOT}/bin:${PATH}
+export PATH=${GOROOT}/bin:${CLI_PATH}:${PATH}
 
 export GOPATH=/var/vcap/packages/loggregator-acceptance-tests
 export PATH=${GOPATH}/bin:${PATH}

src/lats/config/config.go

@@ -6,6 +6,7 @@ import (
 )
 
 type TestConfig struct {
+	AppDomain       string
 	DopplerEndpoint string
 	SkipSSLVerify   bool
 

src/lats/logs_test.go

@@ -0,0 +1,48 @@
+package lats_test
+
+import (
+	"crypto/tls"
+	"lats/helpers"
+	"strings"
+	"time"
+
+	"github.com/cloudfoundry-incubator/cf-test-helpers/cf"
+	"github.com/cloudfoundry/noaa/consumer"
+	. "github.com/onsi/ginkgo"
+	. "github.com/onsi/gomega"
+	. "github.com/onsi/gomega/gexec"
+)
+
+const (
+	cfSetupTimeOut     = 10 * time.Second
+	cfPushTimeOut      = 2 * time.Minute
+	defaultMemoryLimit = "256MB"
+)
+
+var _ = Describe("Logs", func() {
+	It("gets through recent logs", func() {
+
+		Expect(cf.Cf("api", "api."+config.AppDomain, "--skip-ssl-validation").Wait(cfSetupTimeOut)).To(Exit(0))
+		Expect(cf.Cf("auth", config.AdminUser, config.AdminPassword).Wait(cfSetupTimeOut)).To(Exit(0))
+		Expect(cf.Cf("create-org", "lats").Wait(cfSetupTimeOut)).To(Exit(0))
+		Expect(cf.Cf("create-space", "-o", "lats", "lats").Wait(cfSetupTimeOut)).To(Exit(0))
+		Expect(cf.Cf("target", "-o", "lats", "-s", "lats").Wait(cfSetupTimeOut)).To(Exit(0))
+		Expect(cf.Cf("push", "lumberjack", "--no-start",
+			"-b", "go_buildpack",
+			"-m", defaultMemoryLimit,
+			"-p", "../tools/lumberjack",
+			"-d", config.AppDomain).Wait(cfPushTimeOut)).To(Exit(0))
+
+		sess := cf.Cf("app", "lumberjack", "--guid")
+		Expect(sess.Wait(cfSetupTimeOut)).To(Exit(0))
+		appGuid := strings.TrimSpace(string(sess.Out.Contents()))
+
+		tlsConfig := &tls.Config{InsecureSkipVerify: true}
+		consumer := consumer.New(config.DopplerEndpoint, tlsConfig, nil)
+
+		token := helpers.GetAuthToken()
+		envelopes, err := consumer.RecentLogs(appGuid, token)
+		Expect(err).NotTo(HaveOccurred())
+		Expect(envelopes).ToNot(BeEmpty())
+	})
+})