Function pollForEvent

cmd/puma-dev/main_test.go:182–211

(t *testing.T, app string, event string, reason string)

}

func pollForEvent(t *testing.T, app string, event string, reason string) error {
	return retry.Do(
		func() error {
			body := getURLWithHost(t, fmt.Sprintf("http://localhost:%d/events", *fHTTPPort), "puma-dev")
			eachEvent := strings.Split(body, "\n")

			for _, line := range eachEvent {
				var rawEvt interface{}
				if err := json.Unmarshal([]byte(line), &rawEvt); err != nil {
					assert.FailNow(t, err.Error())
				}
				evt := rawEvt.(map[string]interface{})
				LogDebugf("%+v", evt)

				eventFound := (app == "" || evt["app"] == app) &&
					(event == "" || evt["event"] == event) &&
					(reason == "" || evt["reason"] == reason)

				if eventFound {
					return nil
				}
			}

			return errors.New("not found")
		},
		retry.RetryIf(func(err error) bool {
			return err.Error() == "not found"
		}),
	)
}

func runPlatformAgnosticTestScenarios(t *testing.T) {
	t.Run("status", func(t *testing.T) {