func Monitor()

in slackbot/slackbot/monitor.go [15:48]

• 33 lines of code
• 7 McCabe index (conditional complexity)

func Monitor(ctx context.Context, projectId string, buildId string, webhook string, project string) {
	svc := gcbClient(ctx)
	errors := 0
	started := false

	t := time.Tick(tickDuration)
	for {
		log.Printf("Polling build %s", buildId)
		getMonitoredBuild := svc.Projects.Builds.Get(projectId, buildId)
		monitoredBuild, err := getMonitoredBuild.Do()
		if err != nil {
			if errors <= maxErrors {
				log.Printf("Failed to get build details from Cloud Build.  Will retry in %s", tickDuration)
				errors++
				continue
			} else {
				log.Fatalf("Reached maximum number of errors (%d).  Exiting", maxErrors)
			}
		}
		switch monitoredBuild.Status {
		case "WORKING":
			if !started {
				log.Printf("Build started. Notifying")
				Notify(monitoredBuild, webhook, project)
				started = true
			}
		case "SUCCESS", "FAILURE", "INTERNAL_ERROR", "TIMEOUT", "CANCELLED":
			log.Printf("Terminal status reached. Notifying")
			Notify(monitoredBuild, webhook, project)
			return
		}
		<-t
	}
}