refactor: replace logrus logger with zap

testtools/docker/docker.go

@@ -9,29 +9,29 @@ import (
 )
 
 func MqttContainer(t *testing.T) (context.Context, testcontainers.Container, string) {
-ctx := context.Background()
-req := testcontainers.ContainerRequest{
-Image:        "eclipse-mosquitto",
-ExposedPorts: []string{"1883/tcp"},
-WaitingFor:   wait.ForLog("listen socket on port 1883."),
-}
-mqttC, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
-ContainerRequest: req,
-Started:          true,
-})
-if err != nil {
-t.Error(err)
-}
+	ctx := context.Background()
+	req := testcontainers.ContainerRequest{
+		Image:        "eclipse-mosquitto",
+		ExposedPorts: []string{"1883/tcp"},
+		WaitingFor:   wait.ForLog("listen socket on port 1883."),
+	}
+	mqttC, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
+		ContainerRequest: req,
+		Started:          true,
+	})
+	if err != nil {
+		t.Error(err)
+	}
 
-ip, err := mqttC.Host(ctx)
-if err != nil {
-t.Error(err)
-}
-port, err := mqttC.MappedPort(ctx, "1883/tcp")
-if err != nil {
-t.Error(err)
-}
+	ip, err := mqttC.Host(ctx)
+	if err != nil {
+		t.Error(err)
+	}
+	port, err := mqttC.MappedPort(ctx, "1883/tcp")
+	if err != nil {
+		t.Error(err)
+	}
 
-mqttUri := fmt.Sprintf("tcp://%s:%d", ip, port.Int())
-return ctx, mqttC, mqttUri
+	mqttUri := fmt.Sprintf("tcp://%s:%d", ip, port.Int())
+	return ctx, mqttC, mqttUri
 }