content: /*
   * Licensed to the Apache Software Foundation (ASF) under one or more
   * contributor license agreements.  See the NOTICE file distributed with
   * this work for additional information regarding copyright ownership.
   * The ASF licenses this file to You 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.apache.camel.quarkus.component.debezium.common.it.sqlserv;
  
  import java.io.IOException;
  import java.net.URL;
  import java.nio.file.Files;
  import java.nio.file.Path;
  import java.util.Collections;
  import java.util.Map;
  
  import org.apache.camel.quarkus.component.debezium.common.it.sqlserver.DebeziumSqlserverResource;
  import org.apache.camel.quarkus.test.support.debezium.AbstractDebeziumTestResource;
  import org.apache.camel.quarkus.test.support.debezium.Type;
  import org.eclipse.microprofile.config.ConfigProvider;
  import org.jboss.logging.Logger;
  import org.testcontainers.containers.MSSQLServerContainer;
  import org.testcontainers.containers.wait.strategy.Wait;
  import org.testcontainers.utility.DockerImageName;
  
  public class DebeziumSqlserverTestResource extends AbstractDebeziumTestResource<MSSQLServerContainer<?>> {
      private static final Logger LOG = Logger.getLogger(DebeziumSqlserverTestResource.class);
      private static final DockerImageName DOCKER_IMAGE_NAME = DockerImageName
              .parse(ConfigProvider.getConfig().getValue("sql-server.container.image", String.class));
      private static final int DB_PORT = 1433;
      private Path historyFile;
  
      public DebeziumSqlserverTestResource() {
          super(Type.sqlserver);
      }
  
      @Override
      protected MSSQLServerContainer<?> createContainer() {
          return new MSSQLServerContainer<>(DOCKER_IMAGE_NAME)
                  .withEnv(Collections.singletonMap("MSSQL_AGENT_ENABLED", "True"))
                  .withInitScript("initSqlserver.sql")
                  .waitingFor(
                          Wait.forLogMessage(".*xp_sqlagent_notify.*", 1));
      }
  
      @Override
      public Map<String, String> start() {
          //detect EULA for MsSql
          URL eulaUrl = Thread.currentThread().getContextClassLoader().getResource("container-license-acceptance.txt");
          if (eulaUrl == null) {
              LOG.warn(
                      "MS SQL EULA is not accepted. Container won't start. See https://camel.apache.org/camel-quarkus/latest/extensions/debezium-sqlserver.html#_usage for more details.");
              return Collections.emptyMap();
          }
  
          Map<String, String> properties;
          try {
              properties = super.start();
          } catch (Exception e) {
              LOG.warn("If initSqlScript.sql fails with the message 'The error returned was 14258: " +
                      "'Cannot perform this operation while SQLServerAgent is starting.', " +
                      "please increase a delay interval in the script.");
              throw e;
          }
  
          try {
              historyFile = Files.createTempFile(getClass().getSimpleName() + "-history-file-", "");
  
              properties.put(DebeziumSqlserverResource.PROPERTY_DB_HISTORY_FILE, historyFile.toString());
          } catch (IOException e) {
              throw new RuntimeException(e);
          }
  
          return properties;
      }
  
      @Override
      public void stop() {
          super.stop();
  
          try {
              if (historyFile != null) {
                  Files.deleteIfExists(historyFile);
              }
          } catch (Exception e) {
              // ignored
          }
      }
  
      @Override
      protected String getJdbcUrl() {
          return container.getJdbcUrl() + ";databaseName=testDB;user=" + getUsername() + ";password="
                  + getPassword();
      }
  
      @Override
      protected String getUsername() {
          return container.getUsername();
      }
  
      @Override
      protected String getPassword() {
          return container.getPassword();
      }
  
      @Override
      protected int getPort() {
          return DB_PORT;
      }
  }
  