DBZ-2985 Add license headers and add CI checks

closes https://issues.redhat.com/browse/DBZ-2985
debezium · Feb 9, 2021 · 16a7b59 · 16a7b59
1 parent ee71d18
commit 16a7b59
Show file tree

Hide file tree

Showing 68 changed files with 467 additions and 42 deletions.
diff --git a/.github/workflows/backend-testing.yml b/.github/workflows/backend-testing.yml
@@ -0,0 +1,43 @@
+name: Test Debezium UI Backend
+
+on:
+  push:
+    branches:
+      - master
+    paths:
+      - 'backend/**'
+      - 'pom.xml'
+  pull_request:
+    branches:
+      - master
+    paths:
+      - 'backend/**'
+      - 'pom.xml'
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    env:
+      DEBEZIUM_VERSION: "v1.5.0.Alpha1"
+    steps:
+      - name: Checkout Debezium main repository
+        uses: actions/checkout@v2
+        with:
+          repository: debezium/debezium
+          ref: ${{ env.DEBEZIUM_VERSION }}
+          path: debezium
+      - name: Checkout Debezium UI
+        uses: actions/checkout@v2
+        with:
+          path: ui
+      - name: Cache local Maven repository
+        uses: actions/cache@v2
+        with:
+          path: ~/.m2/repository
+          key: ${{ runner.os }}-maven-${{ hashFiles('pom.xml', '**/pom.xml') }}
+          restore-keys: |
+            ${{ runner.os }}-maven-
+      - name: Build debezium-checkstyle
+        run: mvn clean install -f debezium/pom.xml -pl support/checkstyle -DskipTests -DskipITs
+      - name: Test Debezium UI
+        run: mvn clean install -f ui -B -Dformat.formatter.goal=validate -Dformat.imports.goal=check -Dorg.slf4j.simpleLogger.log.org.apache.maven.cli.transfer.Slf4jMavenTransferListener=warn
diff --git a/backend/pom.xml b/backend/pom.xml
@@ -164,6 +164,40 @@
           </execution>
         </executions>
       </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-checkstyle-plugin</artifactId>
+        <dependencies>
+          <dependency>
+            <groupId>io.debezium</groupId>
+            <artifactId>debezium-checkstyle</artifactId>
+            <version>[${debezium.base.version}],[1.5.0-SNAPSHOT]</version>
+          </dependency>
+        </dependencies>
+        <configuration>
+          <configLocation>checkstyle.xml</configLocation>
+          <suppressionsLocation>checkstyle-suppressions.xml</suppressionsLocation>
+          <suppressionsFileExpression>checkstyle.suppressions.file</suppressionsFileExpression>
+          <consoleOutput>true</consoleOutput>
+          <failsOnError>true</failsOnError>
+          <linkXRef>false</linkXRef>
+          <violationSeverity>error</violationSeverity>
+          <includeTestSourceDirectory>true</includeTestSourceDirectory>
+          <sourceDirectories>
+            <sourceDirectory>${project.build.sourceDirectory}</sourceDirectory>
+            <sourceDirectory>${project.build.testSourceDirectory}</sourceDirectory>
+          </sourceDirectories>
+        </configuration>
+        <executions>
+          <execution>
+            <id>check-style</id>
+            <phase>verify</phase>
+            <goals>
+              <goal>checkstyle</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
       <plugin>
         <artifactId>maven-surefire-plugin</artifactId>
         <version>${maven.surefire.plugin.version}</version>

diff --git a/backend/src/main/java/io/debezium/configserver/model/AdditionalPropertyMetadata.java b/backend/src/main/java/io/debezium/configserver/model/AdditionalPropertyMetadata.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 import java.util.List;

diff --git a/backend/src/main/java/io/debezium/configserver/model/ConnectConnectorConfigResponse.java b/backend/src/main/java/io/debezium/configserver/model/ConnectConnectorConfigResponse.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 import java.util.Map;

diff --git a/backend/src/main/java/io/debezium/configserver/model/ConnectConnectorStatus.java b/backend/src/main/java/io/debezium/configserver/model/ConnectConnectorStatus.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 import javax.json.bind.annotation.JsonbProperty;

diff --git a/backend/src/main/java/io/debezium/configserver/model/ConnectConnectorStatusResponse.java b/backend/src/main/java/io/debezium/configserver/model/ConnectConnectorStatusResponse.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 import javax.json.bind.annotation.JsonbProperty;

diff --git a/backend/src/main/java/io/debezium/configserver/model/ConnectTaskStatus.java b/backend/src/main/java/io/debezium/configserver/model/ConnectTaskStatus.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 import javax.json.bind.annotation.JsonbProperty;

diff --git a/backend/src/main/java/io/debezium/configserver/model/ConnectionValidationResult.java b/backend/src/main/java/io/debezium/configserver/model/ConnectionValidationResult.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 import java.util.Collections;

diff --git a/backend/src/main/java/io/debezium/configserver/model/ConnectorProperty.java b/backend/src/main/java/io/debezium/configserver/model/ConnectorProperty.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 import java.util.List;
@@ -26,7 +31,7 @@ public ConnectorProperty(String name, String displayName, String description, Ty
         this.displayName = displayName;
         this.description = description;
         this.type = type;
-        this.defaultValue = defaultValue instanceof Class ? ((Class<?>)defaultValue).getName() : defaultValue;
+        this.defaultValue = defaultValue instanceof Class ? ((Class<?>) defaultValue).getName() : defaultValue;
         this.isMandatory = isMandatory;
         this.category = category;
         this.allowedValues = allowedValues;

diff --git a/backend/src/main/java/io/debezium/configserver/model/ConnectorStatus.java b/backend/src/main/java/io/debezium/configserver/model/ConnectorStatus.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 import java.util.HashMap;

diff --git a/backend/src/main/java/io/debezium/configserver/model/ConnectorType.java b/backend/src/main/java/io/debezium/configserver/model/ConnectorType.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 import java.util.List;

diff --git a/backend/src/main/java/io/debezium/configserver/model/DataCollection.java b/backend/src/main/java/io/debezium/configserver/model/DataCollection.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 public class DataCollection {

diff --git a/backend/src/main/java/io/debezium/configserver/model/FilterValidationResult.java b/backend/src/main/java/io/debezium/configserver/model/FilterValidationResult.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 import java.util.Collections;

diff --git a/backend/src/main/java/io/debezium/configserver/model/FrontendConfig.java b/backend/src/main/java/io/debezium/configserver/model/FrontendConfig.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 public class FrontendConfig {

diff --git a/backend/src/main/java/io/debezium/configserver/model/FrontendConfigArtifacts.java b/backend/src/main/java/io/debezium/configserver/model/FrontendConfigArtifacts.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 public class FrontendConfigArtifacts {

diff --git a/backend/src/main/java/io/debezium/configserver/model/GenericValidationResult.java b/backend/src/main/java/io/debezium/configserver/model/GenericValidationResult.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 public class GenericValidationResult {

diff --git a/backend/src/main/java/io/debezium/configserver/model/KafkaConnectClusterList.java b/backend/src/main/java/io/debezium/configserver/model/KafkaConnectClusterList.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 import org.eclipse.microprofile.openapi.annotations.enums.SchemaType;

diff --git a/backend/src/main/java/io/debezium/configserver/model/PropertiesValidationResult.java b/backend/src/main/java/io/debezium/configserver/model/PropertiesValidationResult.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 import java.util.Collections;

diff --git a/backend/src/main/java/io/debezium/configserver/model/PropertyValidationResult.java b/backend/src/main/java/io/debezium/configserver/model/PropertyValidationResult.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 public class PropertyValidationResult {

diff --git a/backend/src/main/java/io/debezium/configserver/model/TaskStatus.java b/backend/src/main/java/io/debezium/configserver/model/TaskStatus.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.model;
 
 import java.util.List;

diff --git a/backend/src/main/java/io/debezium/configserver/rest/ConnectorResource.java b/backend/src/main/java/io/debezium/configserver/rest/ConnectorResource.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.rest;
 
 import java.io.IOException;
@@ -310,7 +315,8 @@ public Response createConnector(
         LOGGER.debug("Sending valid connector config: " + kafkaConnectConfig.getConfig());
         try {
             result = kafkaConnectClient.createConnector(kafkaConnectConfig);
-        } catch (ProcessingException | IOException e) {
+        }
+        catch (ProcessingException | IOException e) {
             throw new KafkaConnectClientException(kafkaConnectURI, e);
         }
         LOGGER.debug("Kafka Connect response: " + result);
@@ -350,7 +356,8 @@ public Response listConnectors(@PathParam("cluster") int cluster)
         List<String> activeConnectors;
         try {
             activeConnectors = kafkaConnectClient.listConnectors();
-        } catch (ProcessingException | IOException e) {
+        }
+        catch (ProcessingException | IOException e) {
             throw new KafkaConnectClientException(kafkaConnectURI, e);
         }
 
@@ -381,7 +388,8 @@ public Response listConnectors(@PathParam("cluster") int cluster)
                                                     )
                                                 ));
                                     return connectorState;
-                                } catch (ProcessingException | IOException e) {
+                                }
+                                catch (ProcessingException | IOException e) {
                                     LOGGER.error(e.getMessage(), e);
                                 }
                                 return null;
@@ -427,7 +435,8 @@ public Response deleteConnector(
         Response kafkaConnectDeleteConnectorResponse;
         try {
             kafkaConnectDeleteConnectorResponse = kafkaConnectClient.deleteConnector(connectorName);
-        } catch (ProcessingException | IOException e) {
+        }
+        catch (ProcessingException | IOException e) {
             throw new KafkaConnectClientException(kafkaConnectURI, e);
         }
 

diff --git a/backend/src/main/java/io/debezium/configserver/rest/ConnectorURIs.java b/backend/src/main/java/io/debezium/configserver/rest/ConnectorURIs.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.rest;
 
 public final class ConnectorURIs {

diff --git a/backend/src/main/java/io/debezium/configserver/rest/FrontendConfigResource.java b/backend/src/main/java/io/debezium/configserver/rest/FrontendConfigResource.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.rest;
 
 import io.debezium.configserver.model.FrontendConfig;

diff --git a/backend/src/main/java/io/debezium/configserver/rest/KafkaConnectClientException.java b/backend/src/main/java/io/debezium/configserver/rest/KafkaConnectClientException.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.rest;
 
 import java.net.URI;

diff --git a/backend/src/main/java/io/debezium/configserver/rest/KafkaConnectClientExceptionMapper.java b/backend/src/main/java/io/debezium/configserver/rest/KafkaConnectClientExceptionMapper.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.rest;
 
 import io.debezium.configserver.rest.model.ServerError;

diff --git a/backend/src/main/java/io/debezium/configserver/rest/KafkaConnectExceptionMapper.java b/backend/src/main/java/io/debezium/configserver/rest/KafkaConnectExceptionMapper.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.rest;
 
 import io.debezium.configserver.rest.client.KafkaConnectException;

diff --git a/backend/src/main/java/io/debezium/configserver/rest/LifecycleResource.java b/backend/src/main/java/io/debezium/configserver/rest/LifecycleResource.java
@@ -1,3 +1,8 @@
+/*
+ * Copyright Debezium Authors.
+ *
+ * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
+ */
 package io.debezium.configserver.rest;
 
 import io.debezium.configserver.model.ConnectionValidationResult;
@@ -69,7 +74,8 @@ public Response pauseConnector(
         Response result;
         try {
             result = kafkaConnectClient.pauseConnector(connectorName);
-        } catch (ProcessingException | IOException e) {
+        }
+        catch (ProcessingException | IOException e) {
             throw new KafkaConnectClientException(kafkaConnectURI, e);
         }
         LOGGER.debug("Kafka Connect response: " + result.readEntity(String.class));
@@ -118,7 +124,8 @@ public Response resumeConnector(
         Response result;
         try {
             result = kafkaConnectClient.resumeConnector(connectorName);
-        } catch (ProcessingException | IOException e) {
+        }
+        catch (ProcessingException | IOException e) {
             throw new KafkaConnectClientException(kafkaConnectURI, e);
         }
         LOGGER.debug("Kafka Connect response: " + result.readEntity(String.class));
@@ -171,7 +178,8 @@ public Response restartConnector(
         Response result;
         try {
             result = kafkaConnectClient.restartConnector(connectorName);
-        } catch (ProcessingException | IOException e) {
+        }
+        catch (ProcessingException | IOException e) {
             throw new KafkaConnectClientException(kafkaConnectURI, e);
         }
         LOGGER.debug("Kafka Connect response: " + result.readEntity(String.class));
@@ -225,7 +233,8 @@ public Response restartTask(
         Response result;
         try {
             result = kafkaConnectClient.restartConnectorTask(connectorName, taskNumber);
-        } catch (ProcessingException | IOException e) {
+        }
+        catch (ProcessingException | IOException e) {
             throw new KafkaConnectClientException(kafkaConnectURI, e);
         }
         LOGGER.debug("Kafka Connect response: " + result.readEntity(String.class));