Merge pull request #8 from embulk/embulk/checkstyle

Checkstyle with checkstyle 9.3

Author: hiroyuki-sato

build.gradle

@@ -3,6 +3,7 @@ plugins {
     id "maven-publish"
     id "signing"
     id "org.embulk.embulk-plugins" version "0.7.0"
+    id "checkstyle"
 }
 repositories {
     mavenCentral()
@@ -174,3 +175,13 @@ test {
         outputs.upToDateWhen { false }
     }
 }
+
+checkstyle {
+    toolVersion = libs.versions.checkstyle.get()
+    configFile = file("${rootProject.projectDir}/config/checkstyle/checkstyle.xml")
+    configProperties = [
+            "org.checkstyle.google.suppressionfilter.config": file("${rootProject.projectDir}/config/checkstyle/checkstyle-suppressions.xml"),
+    ]
+    ignoreFailures = false
+    maxWarnings = 0
+}

config/checkstyle/README.md

@@ -0,0 +1,11 @@
+Checkstyle for the Embulk project
+==================================
+
+* google_check.xml: Downloaded from: https://github.com/checkstyle/checkstyle/blob/checkstyle-9.3/src/main/resources/google_checks.xml
+     * Commit: 5c1903792f8432243cc8ae5cd79a03a004d3c09c
+* checkstyle.xml: Customized from google_check.xml.
+    * To enable suppressions through checkstyle-suppressions.xml.
+    * To enable suppressions with @SuppressWarnings.
+    * To indent with 4-column spaces.
+    * To limit columns to 180 characters.
+    * To reject unused imports.

config/checkstyle/checkstyle-suppressions.xml

@@ -0,0 +1,14 @@
+<?xml version="1.0"?>
+
+<!DOCTYPE suppressions PUBLIC
+    "-//Puppy Crawl//DTD Suppressions 1.2//EN"
+    "http://checkstyle.sourceforge.net/dtds/suppressions_1_2.dtd">
+
+<suppressions>
+  <suppress checks="JavadocMethod" files=".*"/>
+  <suppress checks="JavadocParagraph" files=".*"/>
+  <suppress checks="JavadocTagContinuationIndentation" files=".*"/>
+  <suppress checks="MissingJavadocType" files=".*"/>
+  <suppress checks="SingleLineJavadoc" files=".*"/>
+  <suppress checks="SummaryJavadoc" files=".*"/>
+</suppressions>

config/checkstyle/checkstyle.xml

@@ -14,6 +14,8 @@ jackson = "2.16.2"
 
 junit4 = "4.13.2"
 
+checkstyle = "9.3"
+
 [libraries]
 
 embulk-core = { group = "org.embulk", name = "embulk-core", version.ref = "embulk-core" }

config/checkstyle/google_checks.xml

@@ -1,40 +1,37 @@
 package org.embulk.output;
 
-import java.util.List;
+import java.io.FilterOutputStream;
+import java.io.IOException;
+import java.io.OutputStream;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
-import java.io.OutputStream;
-import java.io.FilterOutputStream;
-import java.io.IOException;
-import org.slf4j.Logger;
-import org.embulk.config.TaskReport;
-import org.embulk.util.config.Config;
+import java.util.List;
 import org.embulk.config.ConfigDiff;
 import org.embulk.config.ConfigSource;
-import org.embulk.util.config.ConfigMapper;
-import org.embulk.util.config.ConfigMapperFactory;
-import org.embulk.util.config.Task;
-import org.embulk.util.config.TaskMapper;
+import org.embulk.config.TaskReport;
 import org.embulk.config.TaskSource;
 import org.embulk.spi.Buffer;
 import org.embulk.spi.FileOutputPlugin;
 import org.embulk.spi.TransactionalFileOutput;
+import org.embulk.util.config.Config;
+import org.embulk.util.config.ConfigMapper;
+import org.embulk.util.config.ConfigMapperFactory;
+import org.embulk.util.config.Task;
+import org.embulk.util.config.TaskMapper;
+import org.slf4j.Logger;
 
 public class CommandFileOutputPlugin
-        implements FileOutputPlugin
-{
+        implements FileOutputPlugin {
     public interface PluginTask
-            extends Task
-    {
+            extends Task {
         @Config("command")
         public String getCommand();
     }
 
     @Override
     public ConfigDiff transaction(ConfigSource config, int taskCount,
-            FileOutputPlugin.Control control)
-    {
+                                  FileOutputPlugin.Control control) {
         final ConfigMapper configMapper = CONFIG_MAPPER_FACTORY.createConfigMapper();
         final PluginTask task = configMapper.map(config, PluginTask.class);
 
@@ -44,23 +41,20 @@ public ConfigDiff transaction(ConfigSource config, int taskCount,
 
     @Override
     public ConfigDiff resume(TaskSource taskSource,
-            int taskCount,
-            FileOutputPlugin.Control control)
-    {
+                             int taskCount,
+                             FileOutputPlugin.Control control) {
         control.run(taskSource);
         return CONFIG_MAPPER_FACTORY.newConfigDiff();
     }
 
     @Override
     public void cleanup(TaskSource taskSource,
-            int taskCount,
-            List<TaskReport> successTaskReports)
-    {
+                        int taskCount,
+                        List<TaskReport> successTaskReports) {
     }
 
     @Override
-    public TransactionalFileOutput open(TaskSource taskSource, final int taskIndex)
-    {
+    public TransactionalFileOutput open(TaskSource taskSource, final int taskIndex) {
         final TaskMapper taskMapper = CONFIG_MAPPER_FACTORY.createTaskMapper();
         final PluginTask task = taskMapper.map(taskSource, PluginTask.class);
 
@@ -73,36 +67,31 @@ public TransactionalFileOutput open(TaskSource taskSource, final int taskIndex)
         return new PluginFileOutput(cmdline, taskIndex);
     }
 
-    static List<String> buildShell()
-    {
+    static List<String> buildShell() {
         String osName = System.getProperty("os.name");
-        if(osName.indexOf("Windows") >= 0) {
+        if (osName.indexOf("Windows") >= 0) {
             return Collections.unmodifiableList(Arrays.asList("PowerShell.exe", "-Command"));
         } else {
             return Collections.unmodifiableList(Arrays.asList("sh", "-c"));
         }
     }
 
     private static class ProcessWaitOutputStream
-            extends FilterOutputStream
-    {
+            extends FilterOutputStream {
         private Process process;
 
-        public ProcessWaitOutputStream(OutputStream out, Process process)
-        {
+        public ProcessWaitOutputStream(OutputStream out, Process process) {
             super(out);
             this.process = process;
         }
 
         @Override
-        public void close() throws IOException
-        {
+        public void close() throws IOException {
             super.close();
             waitFor();
         }
 
-        private synchronized void waitFor() throws IOException
-        {
+        private synchronized void waitFor() throws IOException {
             if (process != null) {
                 int code;
                 try {
@@ -113,38 +102,34 @@ private synchronized void waitFor() throws IOException
                 process = null;
                 if (code != 0) {
                     throw new IOException(String.format(
-                                "Command finished with non-zero exit code. Exit code is %d.", code));
+                            "Command finished with non-zero exit code. Exit code is %d.", code));
                 }
             }
         }
     }
 
     public class PluginFileOutput
-            implements TransactionalFileOutput
-    {
+            implements TransactionalFileOutput {
         private final List<String> cmdline;
         private final int taskIndex;
         private int seqId;
         private ProcessWaitOutputStream currentProcess;
 
-        public PluginFileOutput(List<String> cmdline, int taskIndex)
-        {
+        public PluginFileOutput(List<String> cmdline, int taskIndex) {
             this.cmdline = cmdline;
             this.taskIndex = taskIndex;
             this.seqId = 0;
             this.currentProcess = null;
         }
 
-        public void nextFile()
-        {
+        public void nextFile() {
             closeCurrentProcess();
             Process proc = startProcess(cmdline, taskIndex, seqId);
             currentProcess = new ProcessWaitOutputStream(proc.getOutputStream(), proc);
             seqId++;
         }
 
-        public void add(Buffer buffer)
-        {
+        public void add(Buffer buffer) {
             try {
                 currentProcess.write(buffer.array(), buffer.offset(), buffer.limit());
             } catch (IOException ex) {
@@ -154,27 +139,22 @@ public void add(Buffer buffer)
             }
         }
 
-        public void finish()
-        {
+        public void finish() {
             closeCurrentProcess();
         }
 
-        public void close()
-        {
+        public void close() {
             closeCurrentProcess();
         }
 
-        public void abort()
-        {
+        public void abort() {
         }
 
-        public TaskReport commit()
-        {
+        public TaskReport commit() {
             return CONFIG_MAPPER_FACTORY.newTaskReport();
         }
 
-        private void closeCurrentProcess()
-        {
+        private void closeCurrentProcess() {
             try {
                 if (currentProcess != null) {
                     currentProcess.close();
@@ -185,11 +165,10 @@ private void closeCurrentProcess()
             }
         }
 
-        private Process startProcess(List<String> cmdline, int taskIndex, int seqId)
-        {
+        private Process startProcess(List<String> cmdline, int taskIndex, int seqId) {
             ProcessBuilder builder = new ProcessBuilder(cmdline.toArray(new String[cmdline.size()]))
-                .redirectError(ProcessBuilder.Redirect.INHERIT)
-                .redirectOutput(ProcessBuilder.Redirect.INHERIT);
+                    .redirectError(ProcessBuilder.Redirect.INHERIT)
+                    .redirectOutput(ProcessBuilder.Redirect.INHERIT);
             builder.environment().put("INDEX", Integer.toString(taskIndex));
             builder.environment().put("SEQID", Integer.toString(seqId));
             // TODO transaction_time, etc
@@ -201,6 +180,7 @@ private Process startProcess(List<String> cmdline, int taskIndex, int seqId)
             }
         }
     }
+
     private static final Logger logger = org.slf4j.LoggerFactory.getLogger(CommandFileOutputPlugin.class);
 
     private static final ConfigMapperFactory CONFIG_MAPPER_FACTORY = ConfigMapperFactory.builder().addDefaultModules().build();

gradle/libs.versions.toml

@@ -1,26 +1,24 @@
 package org.embulk.output;
 
+import static org.embulk.output.CommandFileOutputPlugin.buildShell;
+import static org.junit.Assert.assertEquals;
+
 import java.util.Arrays;
 import java.util.Collections;
+import org.embulk.test.EmbulkTestRuntime;
 import org.junit.Rule;
 import org.junit.Test;
-import org.embulk.test.EmbulkTestRuntime;
-import static org.embulk.output.CommandFileOutputPlugin.buildShell;
-
-import static org.junit.Assert.assertEquals;
 
-public class TestCommandFileOutputPlugin
-{
+public class TestCommandFileOutputPlugin {
     @Rule
     public EmbulkTestRuntime runtime = new EmbulkTestRuntime();
 
     @Test
     public void testShell() {
         if (System.getProperty("os.name").indexOf("Windows") >= 0) {
-            assertEquals(Collections.unmodifiableList(Arrays.asList("PowerShell.exe", "-Command"))
-, buildShell());
-        }
-        else {
+            assertEquals(Collections.unmodifiableList(Arrays.asList("PowerShell.exe", "-Command")),
+                    buildShell());
+        } else {
             assertEquals(Collections.unmodifiableList(Arrays.asList("sh", "-c")), buildShell());
         }
     }