Check for operational message since container start instead of pollin…

…g api (#8)

cmd/instant-sonar.go

@@ -14,7 +14,6 @@ import (
 	"os/user"
 	"path/filepath"
 	"strings"
-	"time"
 )
 
 type options struct {
@@ -93,7 +92,7 @@ func main() {
 	}
 
 	log.Verboseln("Waiting for SonarQube to be operational")
-	out := cli.FollowContainerLogStream(qubeContId)
+	out := cli.FollowContainerLogStream(qubeContId, cli.InspectContainer(qubeContId).State.StartedAt)
 	bufOut := bufio.NewReader(out)
 
 	for {
@@ -111,19 +110,9 @@ func main() {
 
 	sonarApi := sonar.NewApiClient("http://127.0.0.1:9000", opts.username, opts.password)
 
-	log.Verboseln("Waiting for SonarQube API to be up")
-	var lastErr error
-	for i := 0; i < 30; i++ {
-		lastErr = sonarApi.Ping()
-		if lastErr == nil || errors.Is(lastErr, sonar.ErrUnauthorized) {
-			break
-		}
-
-		time.Sleep(time.Second)
-	}
-
-	if lastErr != nil {
-		log.Errorln(lastErr)
+	log.Verboseln("Checking SonarQube API")
+	if err := sonarApi.Ping(); err != nil {
+		log.Errorln(err)
 		os.Exit(1)
 	}
 

internal/docker/client.go

@@ -63,11 +63,12 @@ func (c *Client) StartContainer(id string) {
 	}
 }
 
-func (c *Client) FollowContainerLogStream(id string) io.ReadCloser {
+func (c *Client) FollowContainerLogStream(id string, since string) io.ReadCloser {
 	out, err := c.Cli.ContainerLogs(context.Background(), id, dockerTypes.ContainerLogsOptions{
 		Follow:     true,
 		ShowStdout: true,
 		ShowStderr: true,
+		Since:      since,
 	})
 	if err != nil {
 		panic(err)
@@ -99,3 +100,11 @@ func (c *Client) CopyDirToContainer(id, src, dest string) {
 		panic(err)
 	}
 }
+
+func (c *Client) InspectContainer(id string) dockerTypes.ContainerJSON {
+	insp, err := c.Cli.ContainerInspect(context.Background(), id)
+	if err != nil {
+		panic(err)
+	}
+	return insp
+}