Moved tablesaw build to javascript. Updated dependencies and jooby version. Requires java 17

Author: brianhks

build.groovy

@@ -0,0 +1,150 @@
+importPackage(Packages.tablesaw);
+importPackage(Packages.tablesaw.rules);
+importPackage(Packages.org.freecompany.redline);
+importPackage(Packages.org.freecompany.redline.header);
+importPackage(Packages.org.freecompany.redline.payload);
+importPackage(Packages.groovy.yaml);
+importPackage(Packages.java.nio.file);
+importPackage(Packages.java.io);
+importPackage(Packages.org.yaml.snakeyaml);
+
+saw.setProperty(Tablesaw.PROP_MULTI_THREAD_OUTPUT, Tablesaw.PROP_VALUE_ON);
+
+//Do not use '-' in version string, it breaks rpm uninstall.
+var release = saw.getProperty("KAIROS_RELEASE_NUMBER", "1"); //package release number
+
+saw.includeDefinitionFile("definitions.xml");
+
+var rpmDir = "target/rpm";
+new DirectoryRule("target");
+var rpmDirRule = new DirectoryRule(rpmDir);
+
+//Read pom file to get version out
+var pom = saw.parsePomFile("pom.xml");
+var version = pom.getVersion();
+
+//Read stork definitions
+var yaml = new Yaml();
+var yamlMap = yaml.load(Files.readString(Path.of("src/main/launchers/stork.yml")));
+
+var programName = yamlMap.get("name");
+var summary = yamlMap.get("short_description");
+var description = yamlMap.get("long_description");
+
+
+var mvnRule = new SimpleRule("maven-package")
+		.setDescription("Run maven package build")
+		.setMakeAction("doMavenBuild");
+
+function doMavenBuild(rule)
+{
+	saw.exec(`mvn package`);
+}
+
+rpmFile = `${programName}-${version}-${release}.rpm`
+srcRpmFile = `${programName}-${version}-${release}.src.rpm`
+
+//------------------------------------------------------------------------------
+//Build rpm file
+rpmBaseInstallDir = "/opt/topic-monitor"
+rpmRule = new SimpleRule("package-rpm").setDescription("Build RPM Package")
+		.addDepend(mvnRule)
+		.addDepend(rpmDirRule)
+		.addTarget(`${rpmDir}/${rpmFile}`)
+		.setMakeAction("doRPM")
+		.setProperty("dependency", "on");
+
+function doRPM(rule)
+{
+	//Build rpm using redline rpm library
+	host = Packages.java.net.InetAddress.getLocalHost().getHostName();
+	rpmBuilder = new Builder();
+	rpmBuilder.setDescription(description);
+	rpmBuilder.group = "System Environment/Daemons";
+	rpmBuilder.license = "license";
+	rpmBuilder.setPackage(programName, version, release);
+	rpmBuilder.setPlatform(Architecture.NOARCH, Os.LINUX);
+	rpmBuilder.summary = summary;
+	rpmBuilder.type = RpmType.BINARY;
+	rpmBuilder.url = "http://kairosdb.org";
+	rpmBuilder.vendor = "KairosDB";
+	rpmBuilder.provides = programName;
+				//prefixes = rpmBaseInstallDir
+	rpmBuilder.buildHost = host;
+	rpmBuilder.sourceRpm = srcRpmFile;
+
+	rpmBuilder.setPrefixes(rpmBaseInstallDir);
+	rpmBuilder.addDependencyMore("jre", yamlMap.get("min_java_version"));
+
+	rpmBuilder.addFile("$rpmBaseInstallDir/bin/topic-monitor", new File("target/stork/bin/topic-monitor"), 0755);
+
+	rpmBuilder.addFile("$rpmBaseInstallDir/conf/application.conf",
+			new File("target/stork/conf/application.conf"), 0644, new Directive(Directive.RPMFILE_CONFIG | Directive.RPMFILE_NOREPLACE));
+	rpmBuilder.addFile("$rpmBaseInstallDir/conf/logback.xml",
+			new File("target/stork/conf/logback.xml"), 0644, new Directive(Directive.RPMFILE_CONFIG | Directive.RPMFILE_NOREPLACE));
+	rpmBuilder.addFile("$rpmBaseInstallDir/conf/metrics4j.conf",
+			new File("target/stork/conf/metrics4j.conf"), 0644, new Directive(Directive.RPMFILE_CONFIG | Directive.RPMFILE_NOREPLACE));
+
+	addFileSetToRPM(rpmBuilder, "$rpmBaseInstallDir/lib", new RegExFileSet("target/stork/lib", ".*\\.jar"));
+	addFileSetToRPM(rpmBuilder, "$rpmBaseInstallDir/share", new RegExFileSet("target/stork/share", ".*").recurse());
+
+	print(`Building RPM ${rule.getTarget()}`);
+	outputFile = new FileOutputStream(rule.getTarget());
+	rpmBuilder.build(outputFile.channel);
+	outputFile.close();
+}
+
+function addFileSetToRPM(builder, destination, files)
+{
+	files.getFiles().forEach(function(file)
+	{
+		var f = new File(file.getBaseDir(), file.getFile());
+		builder.addFile(destination + "/" + file.getFile(), f);
+	});
+}
+
+
+debRule = new SimpleRule("package-deb").setDescription("Build Deb Package")
+		.addDepend(rpmRule)
+		.setMakeAction("doDeb");
+
+function doDeb(rule)
+{
+
+}
+
+
+
+//------------------------------------------------------------------------------
+//Build notification
+function printMessage(strTitle, strMessage)
+{
+	osName = saw.getProperty("os.name");
+
+	var notifyDef;
+	if (osName.startsWith("Linux"))
+	{
+		notifyDef = saw.getDefinition("linux-notify");
+	}
+	else if (osName.startsWith("Mac"))
+	{
+		notifyDef = saw.getDefinition("mac-notify");
+	}
+
+	if (notifyDef != null)
+	{
+		notifyDef.set("title", strTitle);
+		notifyDef.set("message", strMessage);
+		saw.exec(notifyDef.getCommand());
+	}
+}
+
+function buildFailure(exception)
+{
+	printMessage("Build Failure", exception.getMessage())
+}
+
+function buildSuccess(target)
+{
+	printMessage("Build Success", target)
+}

build.js

@@ -1,7 +1,7 @@
-Building requires JDK 1.8 or later.
+Building requires JDK 17 or later.
 
 To build set your classpath to the tablesaw jar file like so:
->export CLASSPATH=tools/tablesaw-1.2.6.jar
+>export CLASSPATH=tools/tablesaw-1.2.9.jar
 
 Then to build type
 >java make package-rpm

how_to_build.txt

@@ -7,7 +7,7 @@
 
   <artifactId>kafka-topic-monitor</artifactId>
   <groupId>app</groupId>
-  <version>2.0.2</version>
+  <version>2.1.0</version>
 
   <name>kafka-topic-monitor</name>
 
@@ -63,7 +63,7 @@
     <dependency>
       <groupId>org.kairosdb</groupId>
       <artifactId>metrics4j</artifactId>
-      <version>1.0.0</version>
+      <version>1.0.1</version>
     </dependency>
 
     <!-- Tests -->

pom.xml

@@ -133,7 +133,7 @@ protected int readTopic()
 					continue;
 				}
 
-				System.out.println("Topic: "+offset.getTopic()+" Partition: "+offset.getPartition()+" Offset: "+offset.getOffset());
+				//System.out.println("Topic: "+offset.getTopic()+" Partition: "+offset.getPartition()+" Offset: "+offset.getOffset());
 				//Filter out expired offsets.  We can still read them long after they have expired
 				//System.out.println(offset.getCommitTime() + " " + expireTime);
 				if (offset.getCommitTime() > expireTime)