/**
 * Copyright © 2016-2021 The Thingsboard Authors
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.thingsboard.server.msa;

import lombok.extern.slf4j.Slf4j;
import org.junit.ClassRule;
import org.junit.extensions.cpsuite.ClasspathSuite;
import org.junit.rules.ExternalResource;
import org.junit.runner.RunWith;
import org.testcontainers.containers.DockerComposeContainer;
import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.Base58;

import java.io.File;
import java.time.Duration;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RunWith(ClasspathSuite.class)
@ClasspathSuite.ClassnameFilters({"org.thingsboard.server.msa.*Test"})
@Slf4j
public class ContainerTestSuite {

    private static DockerComposeContainer<?> testContainer;

    @ClassRule
    public static ThingsBoardDbInstaller installTb = new ThingsBoardDbInstaller();

    @ClassRule
    public static DockerComposeContainer getTestContainer() {
        if (testContainer == null) {
            boolean skipTailChildContainers = Boolean.valueOf(System.getProperty("blackBoxTests.skipTailChildContainers"));
            try {
                String logRegexp = ".*Going to recalculate partitions.*";

                testContainer = new DockerComposeContainer<>(
                        new File("./../../docker/docker-compose.yml"),
                        new File("./../../docker/docker-compose.postgres.yml"),
                        new File("./../../docker/docker-compose.postgres.volumes.yml"),
                        new File("./../../docker/docker-compose.kafka.yml"))
                        .withPull(false)
                        .withLocalCompose(true)
                        .withTailChildContainers(!skipTailChildContainers)
                        .withEnv(installTb.getEnv())
                        .withEnv("LOAD_BALANCER_NAME", "")
                        .withExposedService("haproxy", 80, Wait.forHttp("/swagger-ui.html").withStartupTimeout(Duration.ofSeconds(400)))
                        .waitingFor("tb-http-transport1", Wait.forLogMessage(logRegexp, 1).withStartupTimeout(Duration.ofSeconds(400)))
                        .waitingFor("tb-http-transport2", Wait.forLogMessage(logRegexp, 1).withStartupTimeout(Duration.ofSeconds(400)))
                        .waitingFor("tb-mqtt-transport1", Wait.forLogMessage(logRegexp, 1).withStartupTimeout(Duration.ofSeconds(400)))
                        .waitingFor("tb-mqtt-transport2", Wait.forLogMessage(logRegexp, 1).withStartupTimeout(Duration.ofSeconds(400)));
            } catch (Exception e) {
                log.error("Failed to create test container", e);
                throw e;
            }
        }
        return testContainer;
    }
}

@@ -1722,17 +1722,103 @@
  String 
-l
+tbCoreLogRegexp = %22.*Starting polling for events.*%22;%0A                String transportsL
 ogRegexp
@@ -2643,32 +2643,296 @@
 fSeconds(400)))%0A
+                        .waitingFor(%22tb-core1%22, Wait.forLogMessage(tbCoreLogRegexp, 1).withStartupTimeout(Duration.ofSeconds(400)))%0A                        .waitingFor(%22tb-core2%22, Wait.forLogMessage(tbCoreLogRegexp, 1).withStartupTimeout(Duration.ofSeconds(400)))%0A
                 
@@ -2984,33 +2984,43 @@
 t.forLogMessage(
-l
+transportsL
 ogRegexp, 1).wit
@@ -3130,33 +3130,43 @@
 t.forLogMessage(
-l
+transportsL
 ogRegexp, 1).wit
@@ -3276,33 +3276,43 @@
 t.forLogMessage(
-l
+transportsL
 ogRegexp, 1).wit
@@ -3430,17 +3430,27 @@
 Message(
-l
+transportsL
 ogRegexp

Improve black box tests ready state check