diff --git a/.gitignore b/.gitignore index 4dc7919..5dfd7d5 100644 --- a/.gitignore +++ b/.gitignore @@ -42,3 +42,7 @@ Thumbs.db ###################### target/ *.txt + +# Generated KML files # +####################### +*.kml diff --git a/README.md b/README.md index 797c702..7ba99d3 100644 --- a/README.md +++ b/README.md @@ -204,6 +204,66 @@ Duplicate filters are also instantiated through the FilterFactory class, like th Predicate doubletFilter = FilterFactory.newDoubletFilter(15, TimeUnit.SECONDS); ``` +## KML Export + +The KML exporter allows you to export AIS vessel tracks to KML (Keyhole Markup Language) format for visualization in Google Earth and other KML-compatible applications. + +### Export vessel positions to KML + +The KMLExporter class provides static methods to export one or more vessel tracks to KML format: + +```java +import dk.tbsalling.ais.exporter.KMLExporter; +import dk.tbsalling.ais.tracker.AISTrack; +import dk.tbsalling.ais.tracker.AISTracker; +import java.io.FileWriter; +import java.io.IOException; +import java.io.InputStream; +import java.util.Set; + +public class MyApp { + + public static void main(String [] args) throws IOException { + // Create and update tracker + AISTracker tracker = new AISTracker(); + InputStream aisInputStream = ...; + tracker.update(aisInputStream); + + // Get all tracked vessels + Set tracks = tracker.getAisTracks(); + + // Export to KML file + try (FileWriter writer = new FileWriter("vessels.kml")) { + KMLExporter.exportToKML(tracks, writer); + } + + // You can now open vessels.kml in Google Earth! + } +} +``` + +The exported KML file includes detailed information for each vessel: +- Vessel name (or MMSI if name is unavailable) +- Position (latitude/longitude) +- MMSI, callsign, ship type +- Speed over ground and course over ground +- Heading +- Vessel dimensions (length and beam) +- Last update timestamp + +Each vessel is represented as a KML Placemark with a Point geometry at its current position. + +### Export a single vessel + +You can also export a single vessel track: + +```java +AISTrack track = tracker.getAisTrack(219997000); // Get specific track by MMSI +try (FileWriter writer = new FileWriter("vessel.kml")) { + KMLExporter.exportSingleTrackToKML(track, writer); +} +``` + ## How to get, build and include AISutils in your project You do not need to compile AISutils yourself. It is available in [Maven Central](https://mvnrepository.com/artifact/dk.tbsalling/aisutils). So if you are using Maven, all you need to do is add these lines to your pom.xml: @@ -240,4 +300,4 @@ Roadmap More advanced free-text filter expressions for AIS messages event triggering message archiving in Big Data stores -export of KML-files for Google Earth \ No newline at end of file +~~export of KML-files for Google Earth~~ (implemented) \ No newline at end of file diff --git a/mvnw b/mvnw index 5bf251c..1fdbaf2 100755 --- a/mvnw +++ b/mvnw @@ -19,7 +19,7 @@ # ---------------------------------------------------------------------------- # ---------------------------------------------------------------------------- -# Maven2 Start Up Batch script +# Apache Maven Wrapper startup batch script, version 3.3.0 # # Required ENV vars: # ------------------ @@ -27,199 +27,306 @@ # # Optional ENV vars # ----------------- -# M2_HOME - location of maven2's installed home dir # MAVEN_OPTS - parameters passed to the Java VM when running Maven # e.g. to debug Maven itself, use # set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000 # MAVEN_SKIP_RC - flag to disable loading of mavenrc files # ---------------------------------------------------------------------------- -if [ -z "$MAVEN_SKIP_RC" ] ; then +if [ -z "$MAVEN_SKIP_RC" ]; then - if [ -f /etc/mavenrc ] ; then + if [ -f /usr/local/etc/mavenrc ]; then + . /usr/local/etc/mavenrc + fi + + if [ -f /etc/mavenrc ]; then . /etc/mavenrc fi - if [ -f "$HOME/.mavenrc" ] ; then + if [ -f "$HOME/.mavenrc" ]; then . "$HOME/.mavenrc" fi fi # OS specific support. $var _must_ be set to either true or false. -cygwin=false; -darwin=false; +cygwin=false +darwin=false mingw=false -case "`uname`" in - CYGWIN*) cygwin=true ;; - MINGW*) mingw=true;; - Darwin*) darwin=true - # Use /usr/libexec/java_home if available, otherwise fall back to /Library/Java/Home - # See https://developer.apple.com/library/mac/qa/qa1170/_index.html - if [ -z "$JAVA_HOME" ]; then - if [ -x "/usr/libexec/java_home" ]; then - export JAVA_HOME="`/usr/libexec/java_home`" - else - export JAVA_HOME="/Library/Java/Home" - fi +case "$(uname)" in +CYGWIN*) cygwin=true ;; +MINGW*) mingw=true ;; +Darwin*) + darwin=true + # Use /usr/libexec/java_home if available, otherwise fall back to /Library/Java/Home + # See https://developer.apple.com/library/mac/qa/qa1170/_index.html + if [ -z "$JAVA_HOME" ]; then + if [ -x "/usr/libexec/java_home" ]; then + JAVA_HOME="$(/usr/libexec/java_home)" + export JAVA_HOME + else + JAVA_HOME="/Library/Java/Home" + export JAVA_HOME fi - ;; + fi + ;; esac -if [ -z "$JAVA_HOME" ] ; then - if [ -r /etc/gentoo-release ] ; then - JAVA_HOME=`java-config --jre-home` +if [ -z "$JAVA_HOME" ]; then + if [ -r /etc/gentoo-release ]; then + JAVA_HOME=$(java-config --jre-home) fi fi -if [ -z "$M2_HOME" ] ; then - ## resolve links - $0 may be a link to maven's home - PRG="$0" - - # need this for relative symlinks - while [ -h "$PRG" ] ; do - ls=`ls -ld "$PRG"` - link=`expr "$ls" : '.*-> \(.*\)$'` - if expr "$link" : '/.*' > /dev/null; then - PRG="$link" - else - PRG="`dirname "$PRG"`/$link" - fi - done - - saveddir=`pwd` - - M2_HOME=`dirname "$PRG"`/.. - - # make it fully qualified - M2_HOME=`cd "$M2_HOME" && pwd` - - cd "$saveddir" - # echo Using m2 at $M2_HOME -fi - # For Cygwin, ensure paths are in UNIX format before anything is touched -if $cygwin ; then - [ -n "$M2_HOME" ] && - M2_HOME=`cygpath --unix "$M2_HOME"` - [ -n "$JAVA_HOME" ] && - JAVA_HOME=`cygpath --unix "$JAVA_HOME"` - [ -n "$CLASSPATH" ] && - CLASSPATH=`cygpath --path --unix "$CLASSPATH"` +if $cygwin; then + [ -n "$JAVA_HOME" ] \ + && JAVA_HOME=$(cygpath --unix "$JAVA_HOME") + [ -n "$CLASSPATH" ] \ + && CLASSPATH=$(cygpath --path --unix "$CLASSPATH") fi -# For Migwn, ensure paths are in UNIX format before anything is touched -if $mingw ; then - [ -n "$M2_HOME" ] && - M2_HOME="`(cd "$M2_HOME"; pwd)`" - [ -n "$JAVA_HOME" ] && - JAVA_HOME="`(cd "$JAVA_HOME"; pwd)`" - # TODO classpath? +# For Mingw, ensure paths are in UNIX format before anything is touched +if $mingw; then + [ -n "$JAVA_HOME" ] && [ -d "$JAVA_HOME" ] \ + && JAVA_HOME="$( + cd "$JAVA_HOME" || ( + echo "cannot cd into $JAVA_HOME." >&2 + exit 1 + ) + pwd + )" fi if [ -z "$JAVA_HOME" ]; then - javaExecutable="`which javac`" - if [ -n "$javaExecutable" ] && ! [ "`expr \"$javaExecutable\" : '\([^ ]*\)'`" = "no" ]; then + javaExecutable="$(which javac)" + if [ -n "$javaExecutable" ] && ! [ "$(expr "$javaExecutable" : '\([^ ]*\)')" = "no" ]; then # readlink(1) is not available as standard on Solaris 10. - readLink=`which readlink` - if [ ! `expr "$readLink" : '\([^ ]*\)'` = "no" ]; then - if $darwin ; then - javaHome="`dirname \"$javaExecutable\"`" - javaExecutable="`cd \"$javaHome\" && pwd -P`/javac" + readLink=$(which readlink) + if [ ! "$(expr "$readLink" : '\([^ ]*\)')" = "no" ]; then + if $darwin; then + javaHome="$(dirname "$javaExecutable")" + javaExecutable="$(cd "$javaHome" && pwd -P)/javac" else - javaExecutable="`readlink -f \"$javaExecutable\"`" + javaExecutable="$(readlink -f "$javaExecutable")" fi - javaHome="`dirname \"$javaExecutable\"`" - javaHome=`expr "$javaHome" : '\(.*\)/bin'` + javaHome="$(dirname "$javaExecutable")" + javaHome=$(expr "$javaHome" : '\(.*\)/bin') JAVA_HOME="$javaHome" export JAVA_HOME fi fi fi -if [ -z "$JAVACMD" ] ; then - if [ -n "$JAVA_HOME" ] ; then - if [ -x "$JAVA_HOME/jre/sh/java" ] ; then +if [ -z "$JAVACMD" ]; then + if [ -n "$JAVA_HOME" ]; then + if [ -x "$JAVA_HOME/jre/sh/java" ]; then # IBM's JDK on AIX uses strange locations for the executables JAVACMD="$JAVA_HOME/jre/sh/java" else JAVACMD="$JAVA_HOME/bin/java" fi else - JAVACMD="`which java`" + JAVACMD="$( + \unset -f command 2>/dev/null + \command -v java + )" fi fi -if [ ! -x "$JAVACMD" ] ; then +if [ ! -x "$JAVACMD" ]; then echo "Error: JAVA_HOME is not defined correctly." >&2 echo " We cannot execute $JAVACMD" >&2 exit 1 fi -if [ -z "$JAVA_HOME" ] ; then - echo "Warning: JAVA_HOME environment variable is not set." +if [ -z "$JAVA_HOME" ]; then + echo "Warning: JAVA_HOME environment variable is not set." >&2 fi -CLASSWORLDS_LAUNCHER=org.codehaus.plexus.classworlds.launcher.Launcher - # traverses directory structure from process work directory to filesystem root # first directory with .mvn subdirectory is considered project base directory find_maven_basedir() { - - if [ -z "$1" ] - then - echo "Path not specified to find_maven_basedir" + if [ -z "$1" ]; then + echo "Path not specified to find_maven_basedir" >&2 return 1 fi basedir="$1" wdir="$1" - while [ "$wdir" != '/' ] ; do - if [ -d "$wdir"/.mvn ] ; then + while [ "$wdir" != '/' ]; do + if [ -d "$wdir"/.mvn ]; then basedir=$wdir break fi # workaround for JBEAP-8937 (on Solaris 10/Sparc) if [ -d "${wdir}" ]; then - wdir=`cd "$wdir/.."; pwd` + wdir=$( + cd "$wdir/.." || exit 1 + pwd + ) fi # end of workaround done - echo "${basedir}" + printf '%s' "$( + cd "$basedir" || exit 1 + pwd + )" } # concatenates all lines of a file concat_lines() { if [ -f "$1" ]; then - echo "$(tr -s '\n' ' ' < "$1")" + # Remove \r in case we run on Windows within Git Bash + # and check out the repository with auto CRLF management + # enabled. Otherwise, we may read lines that are delimited with + # \r\n and produce $'-Xarg\r' rather than -Xarg due to word + # splitting rules. + tr -s '\r\n' ' ' <"$1" fi } -BASE_DIR=`find_maven_basedir "$(pwd)"` +log() { + if [ "$MVNW_VERBOSE" = true ]; then + printf '%s\n' "$1" + fi +} + +BASE_DIR=$(find_maven_basedir "$(dirname "$0")") if [ -z "$BASE_DIR" ]; then - exit 1; + exit 1 +fi + +MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"} +export MAVEN_PROJECTBASEDIR +log "$MAVEN_PROJECTBASEDIR" + +########################################################################################## +# Extension to allow automatically downloading the maven-wrapper.jar from Maven-central +# This allows using the maven wrapper in projects that prohibit checking in binary data. +########################################################################################## +wrapperJarPath="$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" +if [ -r "$wrapperJarPath" ]; then + log "Found $wrapperJarPath" +else + log "Couldn't find $wrapperJarPath, downloading it ..." + + if [ -n "$MVNW_REPOURL" ]; then + wrapperUrl="$MVNW_REPOURL/org/apache/maven/wrapper/maven-wrapper/3.3.0/maven-wrapper-3.3.0.jar" + else + wrapperUrl="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.3.0/maven-wrapper-3.3.0.jar" + fi + while IFS="=" read -r key value; do + # Remove '\r' from value to allow usage on windows as IFS does not consider '\r' as a separator ( considers space, tab, new line ('\n'), and custom '=' ) + safeValue=$(echo "$value" | tr -d '\r') + case "$key" in wrapperUrl) + wrapperUrl="$safeValue" + break + ;; + esac + done <"$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.properties" + log "Downloading from: $wrapperUrl" + + if $cygwin; then + wrapperJarPath=$(cygpath --path --windows "$wrapperJarPath") + fi + + if command -v wget >/dev/null; then + log "Found wget ... using wget" + [ "$MVNW_VERBOSE" = true ] && QUIET="" || QUIET="--quiet" + if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then + wget $QUIET "$wrapperUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath" + else + wget $QUIET --http-user="$MVNW_USERNAME" --http-password="$MVNW_PASSWORD" "$wrapperUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath" + fi + elif command -v curl >/dev/null; then + log "Found curl ... using curl" + [ "$MVNW_VERBOSE" = true ] && QUIET="" || QUIET="--silent" + if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then + curl $QUIET -o "$wrapperJarPath" "$wrapperUrl" -f -L || rm -f "$wrapperJarPath" + else + curl $QUIET --user "$MVNW_USERNAME:$MVNW_PASSWORD" -o "$wrapperJarPath" "$wrapperUrl" -f -L || rm -f "$wrapperJarPath" + fi + else + log "Falling back to using Java to download" + javaSource="$MAVEN_PROJECTBASEDIR/.mvn/wrapper/MavenWrapperDownloader.java" + javaClass="$MAVEN_PROJECTBASEDIR/.mvn/wrapper/MavenWrapperDownloader.class" + # For Cygwin, switch paths to Windows format before running javac + if $cygwin; then + javaSource=$(cygpath --path --windows "$javaSource") + javaClass=$(cygpath --path --windows "$javaClass") + fi + if [ -e "$javaSource" ]; then + if [ ! -e "$javaClass" ]; then + log " - Compiling MavenWrapperDownloader.java ..." + ("$JAVA_HOME/bin/javac" "$javaSource") + fi + if [ -e "$javaClass" ]; then + log " - Running MavenWrapperDownloader.java ..." + ("$JAVA_HOME/bin/java" -cp .mvn/wrapper MavenWrapperDownloader "$wrapperUrl" "$wrapperJarPath") || rm -f "$wrapperJarPath" + fi + fi + fi +fi +########################################################################################## +# End of extension +########################################################################################## + +# If specified, validate the SHA-256 sum of the Maven wrapper jar file +wrapperSha256Sum="" +while IFS="=" read -r key value; do + case "$key" in wrapperSha256Sum) + wrapperSha256Sum=$value + break + ;; + esac +done <"$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.properties" +if [ -n "$wrapperSha256Sum" ]; then + wrapperSha256Result=false + if command -v sha256sum >/dev/null; then + if echo "$wrapperSha256Sum $wrapperJarPath" | sha256sum -c >/dev/null 2>&1; then + wrapperSha256Result=true + fi + elif command -v shasum >/dev/null; then + if echo "$wrapperSha256Sum $wrapperJarPath" | shasum -a 256 -c >/dev/null 2>&1; then + wrapperSha256Result=true + fi + else + echo "Checksum validation was requested but neither 'sha256sum' or 'shasum' are available." >&2 + echo "Please install either command, or disable validation by removing 'wrapperSha256Sum' from your maven-wrapper.properties." >&2 + exit 1 + fi + if [ $wrapperSha256Result = false ]; then + echo "Error: Failed to validate Maven wrapper SHA-256, your Maven wrapper might be compromised." >&2 + echo "Investigate or delete $wrapperJarPath to attempt a clean download." >&2 + echo "If you updated your Maven version, you need to update the specified wrapperSha256Sum property." >&2 + exit 1 + fi fi -export MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"} -echo $MAVEN_PROJECTBASEDIR MAVEN_OPTS="$(concat_lines "$MAVEN_PROJECTBASEDIR/.mvn/jvm.config") $MAVEN_OPTS" # For Cygwin, switch paths to Windows format before running java if $cygwin; then - [ -n "$M2_HOME" ] && - M2_HOME=`cygpath --path --windows "$M2_HOME"` - [ -n "$JAVA_HOME" ] && - JAVA_HOME=`cygpath --path --windows "$JAVA_HOME"` - [ -n "$CLASSPATH" ] && - CLASSPATH=`cygpath --path --windows "$CLASSPATH"` - [ -n "$MAVEN_PROJECTBASEDIR" ] && - MAVEN_PROJECTBASEDIR=`cygpath --path --windows "$MAVEN_PROJECTBASEDIR"` + [ -n "$JAVA_HOME" ] \ + && JAVA_HOME=$(cygpath --path --windows "$JAVA_HOME") + [ -n "$CLASSPATH" ] \ + && CLASSPATH=$(cygpath --path --windows "$CLASSPATH") + [ -n "$MAVEN_PROJECTBASEDIR" ] \ + && MAVEN_PROJECTBASEDIR=$(cygpath --path --windows "$MAVEN_PROJECTBASEDIR") fi +# Provide a "standardized" way to retrieve the CLI args that will +# work with both Windows and non-Windows executions. +MAVEN_CMD_LINE_ARGS="$MAVEN_CONFIG $*" +export MAVEN_CMD_LINE_ARGS + WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain +# shellcheck disable=SC2086 # safe args exec "$JAVACMD" \ $MAVEN_OPTS \ + $MAVEN_DEBUG_OPTS \ -classpath "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" \ - "-Dmaven.home=${M2_HOME}" "-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \ + "-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \ ${WRAPPER_LAUNCHER} $MAVEN_CONFIG "$@" diff --git a/mvnw.cmd b/mvnw.cmd old mode 100755 new mode 100644 index 019bd74..b694e6c --- a/mvnw.cmd +++ b/mvnw.cmd @@ -1,143 +1,206 @@ -@REM ---------------------------------------------------------------------------- -@REM Licensed to the Apache Software Foundation (ASF) under one -@REM or more contributor license agreements. See the NOTICE file -@REM distributed with this work for additional information -@REM regarding copyright ownership. The ASF licenses this file -@REM to you under the Apache License, Version 2.0 (the -@REM "License"); you may not use this file except in compliance -@REM with the License. You may obtain a copy of the License at -@REM -@REM http://www.apache.org/licenses/LICENSE-2.0 -@REM -@REM Unless required by applicable law or agreed to in writing, -@REM software distributed under the License is distributed on an -@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY -@REM KIND, either express or implied. See the License for the -@REM specific language governing permissions and limitations -@REM under the License. -@REM ---------------------------------------------------------------------------- - -@REM ---------------------------------------------------------------------------- -@REM Maven2 Start Up Batch script -@REM -@REM Required ENV vars: -@REM JAVA_HOME - location of a JDK home dir -@REM -@REM Optional ENV vars -@REM M2_HOME - location of maven2's installed home dir -@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands -@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a key stroke before ending -@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven -@REM e.g. to debug Maven itself, use -@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000 -@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files -@REM ---------------------------------------------------------------------------- - -@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on' -@echo off -@REM enable echoing my setting MAVEN_BATCH_ECHO to 'on' -@if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO% - -@REM set %HOME% to equivalent of $HOME -if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%") - -@REM Execute a user defined script before this one -if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre -@REM check for pre script, once with legacy .bat ending and once with .cmd ending -if exist "%HOME%\mavenrc_pre.bat" call "%HOME%\mavenrc_pre.bat" -if exist "%HOME%\mavenrc_pre.cmd" call "%HOME%\mavenrc_pre.cmd" -:skipRcPre - -@setlocal - -set ERROR_CODE=0 - -@REM To isolate internal variables from possible post scripts, we use another setlocal -@setlocal - -@REM ==== START VALIDATION ==== -if not "%JAVA_HOME%" == "" goto OkJHome - -echo. -echo Error: JAVA_HOME not found in your environment. >&2 -echo Please set the JAVA_HOME variable in your environment to match the >&2 -echo location of your Java installation. >&2 -echo. -goto error - -:OkJHome -if exist "%JAVA_HOME%\bin\java.exe" goto init - -echo. -echo Error: JAVA_HOME is set to an invalid directory. >&2 -echo JAVA_HOME = "%JAVA_HOME%" >&2 -echo Please set the JAVA_HOME variable in your environment to match the >&2 -echo location of your Java installation. >&2 -echo. -goto error - -@REM ==== END VALIDATION ==== - -:init - -@REM Find the project base dir, i.e. the directory that contains the folder ".mvn". -@REM Fallback to current working directory if not found. - -set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR% -IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir - -set EXEC_DIR=%CD% -set WDIR=%EXEC_DIR% -:findBaseDir -IF EXIST "%WDIR%"\.mvn goto baseDirFound -cd .. -IF "%WDIR%"=="%CD%" goto baseDirNotFound -set WDIR=%CD% -goto findBaseDir - -:baseDirFound -set MAVEN_PROJECTBASEDIR=%WDIR% -cd "%EXEC_DIR%" -goto endDetectBaseDir - -:baseDirNotFound -set MAVEN_PROJECTBASEDIR=%EXEC_DIR% -cd "%EXEC_DIR%" - -:endDetectBaseDir - -IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig - -@setlocal EnableExtensions EnableDelayedExpansion -for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a -@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS% - -:endReadAdditionalConfig - -SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe" - -set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar" -set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain - -%MAVEN_JAVA_EXE% %JVM_CONFIG_MAVEN_PROPS% %MAVEN_OPTS% %MAVEN_DEBUG_OPTS% -classpath %WRAPPER_JAR% "-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" %WRAPPER_LAUNCHER% %MAVEN_CONFIG% %* -if ERRORLEVEL 1 goto error -goto end - -:error -set ERROR_CODE=1 - -:end -@endlocal & set ERROR_CODE=%ERROR_CODE% - -if not "%MAVEN_SKIP_RC%" == "" goto skipRcPost -@REM check for post script, once with legacy .bat ending and once with .cmd ending -if exist "%HOME%\mavenrc_post.bat" call "%HOME%\mavenrc_post.bat" -if exist "%HOME%\mavenrc_post.cmd" call "%HOME%\mavenrc_post.cmd" -:skipRcPost - -@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on' -if "%MAVEN_BATCH_PAUSE%" == "on" pause - -if "%MAVEN_TERMINATE_CMD%" == "on" exit %ERROR_CODE% - -exit /B %ERROR_CODE% +@REM ---------------------------------------------------------------------------- +@REM Licensed to the Apache Software Foundation (ASF) under one +@REM or more contributor license agreements. See the NOTICE file +@REM distributed with this work for additional information +@REM regarding copyright ownership. The ASF licenses this file +@REM to you under the Apache License, Version 2.0 (the +@REM "License"); you may not use this file except in compliance +@REM with the License. You may obtain a copy of the License at +@REM +@REM http://www.apache.org/licenses/LICENSE-2.0 +@REM +@REM Unless required by applicable law or agreed to in writing, +@REM software distributed under the License is distributed on an +@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY +@REM KIND, either express or implied. See the License for the +@REM specific language governing permissions and limitations +@REM under the License. +@REM ---------------------------------------------------------------------------- + +@REM ---------------------------------------------------------------------------- +@REM Apache Maven Wrapper startup batch script, version 3.3.0 +@REM +@REM Required ENV vars: +@REM JAVA_HOME - location of a JDK home dir +@REM +@REM Optional ENV vars +@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands +@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending +@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven +@REM e.g. to debug Maven itself, use +@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000 +@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files +@REM ---------------------------------------------------------------------------- + +@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on' +@echo off +@REM set title of command window +title %0 +@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on' +@if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO% + +@REM set %HOME% to equivalent of $HOME +if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%") + +@REM Execute a user defined script before this one +if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre +@REM check for pre script, once with legacy .bat ending and once with .cmd ending +if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %* +if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %* +:skipRcPre + +@setlocal + +set ERROR_CODE=0 + +@REM To isolate internal variables from possible post scripts, we use another setlocal +@setlocal + +@REM ==== START VALIDATION ==== +if not "%JAVA_HOME%" == "" goto OkJHome + +echo. >&2 +echo Error: JAVA_HOME not found in your environment. >&2 +echo Please set the JAVA_HOME variable in your environment to match the >&2 +echo location of your Java installation. >&2 +echo. >&2 +goto error + +:OkJHome +if exist "%JAVA_HOME%\bin\java.exe" goto init + +echo. >&2 +echo Error: JAVA_HOME is set to an invalid directory. >&2 +echo JAVA_HOME = "%JAVA_HOME%" >&2 +echo Please set the JAVA_HOME variable in your environment to match the >&2 +echo location of your Java installation. >&2 +echo. >&2 +goto error + +@REM ==== END VALIDATION ==== + +:init + +@REM Find the project base dir, i.e. the directory that contains the folder ".mvn". +@REM Fallback to current working directory if not found. + +set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR% +IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir + +set EXEC_DIR=%CD% +set WDIR=%EXEC_DIR% +:findBaseDir +IF EXIST "%WDIR%"\.mvn goto baseDirFound +cd .. +IF "%WDIR%"=="%CD%" goto baseDirNotFound +set WDIR=%CD% +goto findBaseDir + +:baseDirFound +set MAVEN_PROJECTBASEDIR=%WDIR% +cd "%EXEC_DIR%" +goto endDetectBaseDir + +:baseDirNotFound +set MAVEN_PROJECTBASEDIR=%EXEC_DIR% +cd "%EXEC_DIR%" + +:endDetectBaseDir + +IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig + +@setlocal EnableExtensions EnableDelayedExpansion +for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a +@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS% + +:endReadAdditionalConfig + +SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe" +set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar" +set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain + +set WRAPPER_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.3.0/maven-wrapper-3.3.0.jar" + +FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO ( + IF "%%A"=="wrapperUrl" SET WRAPPER_URL=%%B +) + +@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central +@REM This allows using the maven wrapper in projects that prohibit checking in binary data. +if exist %WRAPPER_JAR% ( + if "%MVNW_VERBOSE%" == "true" ( + echo Found %WRAPPER_JAR% + ) +) else ( + if not "%MVNW_REPOURL%" == "" ( + SET WRAPPER_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.3.0/maven-wrapper-3.3.0.jar" + ) + if "%MVNW_VERBOSE%" == "true" ( + echo Couldn't find %WRAPPER_JAR%, downloading it ... + echo Downloading from: %WRAPPER_URL% + ) + + powershell -Command "&{"^ + "$webclient = new-object System.Net.WebClient;"^ + "if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^ + "$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^ + "}"^ + "[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%WRAPPER_URL%', '%WRAPPER_JAR%')"^ + "}" + if "%MVNW_VERBOSE%" == "true" ( + echo Finished downloading %WRAPPER_JAR% + ) +) +@REM End of extension + +@REM If specified, validate the SHA-256 sum of the Maven wrapper jar file +SET WRAPPER_SHA_256_SUM="" +FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO ( + IF "%%A"=="wrapperSha256Sum" SET WRAPPER_SHA_256_SUM=%%B +) +IF NOT %WRAPPER_SHA_256_SUM%=="" ( + powershell -Command "&{"^ + "Import-Module $PSHOME\Modules\Microsoft.PowerShell.Utility -Function Get-FileHash;"^ + "$hash = (Get-FileHash \"%WRAPPER_JAR%\" -Algorithm SHA256).Hash.ToLower();"^ + "If('%WRAPPER_SHA_256_SUM%' -ne $hash){"^ + " Write-Error 'Error: Failed to validate Maven wrapper SHA-256, your Maven wrapper might be compromised.';"^ + " Write-Error 'Investigate or delete %WRAPPER_JAR% to attempt a clean download.';"^ + " Write-Error 'If you updated your Maven version, you need to update the specified wrapperSha256Sum property.';"^ + " exit 1;"^ + "}"^ + "}" + if ERRORLEVEL 1 goto error +) + +@REM Provide a "standardized" way to retrieve the CLI args that will +@REM work with both Windows and non-Windows executions. +set MAVEN_CMD_LINE_ARGS=%* + +%MAVEN_JAVA_EXE% ^ + %JVM_CONFIG_MAVEN_PROPS% ^ + %MAVEN_OPTS% ^ + %MAVEN_DEBUG_OPTS% ^ + -classpath %WRAPPER_JAR% ^ + "-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^ + %WRAPPER_LAUNCHER% %MAVEN_CONFIG% %* +if ERRORLEVEL 1 goto error +goto end + +:error +set ERROR_CODE=1 + +:end +@endlocal & set ERROR_CODE=%ERROR_CODE% + +if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost +@REM check for post script, once with legacy .bat ending and once with .cmd ending +if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat" +if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\mavenrc_post.cmd" +:skipRcPost + +@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on' +if "%MAVEN_BATCH_PAUSE%"=="on" pause + +if "%MAVEN_TERMINATE_CMD%"=="on" exit %ERROR_CODE% + +cmd /C exit /B %ERROR_CODE% diff --git a/src/main/java/dk/tbsalling/ais/exporter/KMLExporter.java b/src/main/java/dk/tbsalling/ais/exporter/KMLExporter.java new file mode 100644 index 0000000..07a17b2 --- /dev/null +++ b/src/main/java/dk/tbsalling/ais/exporter/KMLExporter.java @@ -0,0 +1,193 @@ +package dk.tbsalling.ais.exporter; + +import dk.tbsalling.ais.tracker.AISTrack; + +import java.io.IOException; +import java.io.Writer; +import java.time.format.DateTimeFormatter; +import java.util.Collection; + +/** + * KMLExporter provides functionality to export AIS track data to KML (Keyhole Markup Language) format + * for visualization in Google Earth and other KML-compatible applications. + * + *

The exporter can generate KML documents containing vessel positions, metadata, and track history. + * Each vessel is represented as a Placemark with its current position and detailed information including + * name, MMSI, callsign, ship type, speed, course, and heading.

+ * + *

Example usage:

+ * 
+ * AISTracker tracker = new AISTracker();
+ * // ... update tracker with AIS messages ...
+ * 
+ * Set<AISTrack> tracks = tracker.getAisTracks();
+ * try (FileWriter writer = new FileWriter("vessels.kml")) {
+ *     KMLExporter.exportToKML(tracks, writer);
+ * }
+ *
+ * + * @see AISTrack + */ +public class KMLExporter { + + private static final String KML_HEADER = "\n" + + "\n" + + "\n" + + " AIS Vessel Tracks\n" + + " Vessel positions from AIS data\n"; + + private static final String KML_FOOTER = "\n\n"; + + private static final DateTimeFormatter TIME_FORMATTER = DateTimeFormatter.ISO_INSTANT; + + /** + * Exports a collection of AIS tracks to KML format. + * + * @param tracks the collection of AIS tracks to export + * @param writer the writer to output KML content to + * @throws IOException if an I/O error occurs during writing + * @throws IllegalArgumentException if tracks is null or writer is null + */ + public static void exportToKML(Collection tracks, Writer writer) throws IOException { + if (tracks == null) { + throw new IllegalArgumentException("tracks cannot be null"); + } + if (writer == null) { + throw new IllegalArgumentException("writer cannot be null"); + } + + writer.write(KML_HEADER); + + for (AISTrack track : tracks) { + if (track.getLatitude() != null && track.getLongitude() != null) { + writeTrackPlacemark(track, writer); + } + } + + writer.write(KML_FOOTER); + writer.flush(); + } + + /** + * Exports a single AIS track to KML format. + * + * @param track the AIS track to export + * @param writer the writer to output KML content to + * @throws IOException if an I/O error occurs during writing + * @throws IllegalArgumentException if track is null, writer is null, or track has no position data + */ + public static void exportSingleTrackToKML(AISTrack track, Writer writer) throws IOException { + if (track == null) { + throw new IllegalArgumentException("track cannot be null"); + } + if (writer == null) { + throw new IllegalArgumentException("writer cannot be null"); + } + if (track.getLatitude() == null || track.getLongitude() == null) { + throw new IllegalArgumentException("track must have valid position data (latitude and longitude)"); + } + + writer.write(KML_HEADER); + writeTrackPlacemark(track, writer); + writer.write(KML_FOOTER); + writer.flush(); + } + + private static void writeTrackPlacemark(AISTrack track, Writer writer) throws IOException { + writer.write(" \n"); + + // Name - use ship name if available, otherwise MMSI + String name = track.getShipName() != null && !track.getShipName().trim().isEmpty() + ? track.getShipName().trim() + : "MMSI " + track.getMmsi(); + writer.write(" "); + writer.write(escapeXml(name)); + writer.write("\n"); + + // Description with detailed vessel information + writer.write(" MMSI: " + track.getMmsi() + "
\n"); + + if (track.getCallsign() != null && !track.getCallsign().trim().isEmpty()) { + writer.write(" Callsign: " + escapeXml(track.getCallsign().trim()) + "
\n"); + } + + if (track.getShipName() != null && !track.getShipName().trim().isEmpty()) { + writer.write(" Vessel Name: " + escapeXml(track.getShipName().trim()) + "
\n"); + } + + if (track.getShipType() != null) { + writer.write(" Ship Type: " + track.getShipType() + "
\n"); + } + + if (track.getTransponderClass() != null) { + writer.write(" Transponder Class: " + track.getTransponderClass() + "
\n"); + } + + writer.write(" Position: " + + String.format("%.6f", track.getLatitude()) + ", " + + String.format("%.6f", track.getLongitude()) + "
\n"); + + if (track.getSpeedOverGround() != null) { + writer.write(" Speed: " + String.format("%.1f", track.getSpeedOverGround()) + " knots
\n"); + } + + if (track.getCourseOverGround() != null) { + writer.write(" Course: " + String.format("%.1f", track.getCourseOverGround()) + "°
\n"); + } + + if (track.getTrueHeading() != null && track.getTrueHeading() != 511) { + writer.write(" Heading: " + track.getTrueHeading() + "°
\n"); + } + + if (track.getTimeOfLastUpdate() != null) { + writer.write(" Last Update: " + TIME_FORMATTER.format(track.getTimeOfLastUpdate()) + "
\n"); + } + + // Add vessel dimensions if available + try { + Integer toBow = track.getToBow(); + Integer toStern = track.getToStern(); + Integer toPort = track.getToPort(); + Integer toStarboard = track.getToStarboard(); + + if (toBow != null || toStern != null || toPort != null || toStarboard != null) { + writer.write(" Dimensions: "); + if (toBow != null && toStern != null) { + writer.write("Length " + (toBow + toStern) + "m "); + } + if (toPort != null && toStarboard != null) { + writer.write("(Beam " + (toPort + toStarboard) + "m)"); + } + writer.write("
\n"); + } + } catch (Exception e) { + // Skip dimensions if there's an error retrieving them + } + + writer.write(" ]]>\n"); + + // Point coordinates (longitude, latitude, altitude) + writer.write(" \n"); + writer.write(" "); + writer.write(String.format("%.6f,%.6f,0", track.getLongitude(), track.getLatitude())); + writer.write("\n"); + writer.write(" \n"); + + writer.write(" \n"); + } + + /** + * Escapes special XML characters in a string. + */ + private static String escapeXml(String text) { + if (text == null) { + return ""; + } + return text.replace("&", "&") + .replace("<", "<") + .replace(">", ">") + .replace("\"", """) + .replace("'", "'"); + } +} diff --git a/src/main/java/dk/tbsalling/ais/exporter/demo/KMLExportDemoApp.java b/src/main/java/dk/tbsalling/ais/exporter/demo/KMLExportDemoApp.java new file mode 100644 index 0000000..48322c9 --- /dev/null +++ b/src/main/java/dk/tbsalling/ais/exporter/demo/KMLExportDemoApp.java @@ -0,0 +1,71 @@ +package dk.tbsalling.ais.exporter.demo; + +import dk.tbsalling.ais.exporter.KMLExporter; +import dk.tbsalling.ais.tracker.AISTrack; +import dk.tbsalling.ais.tracker.AISTracker; + +import java.io.ByteArrayInputStream; +import java.io.FileWriter; +import java.io.IOException; +import java.io.InputStream; +import java.util.Set; + +/** + * Demo application showing how to use the KML exporter to export AIS vessel tracks + * to KML format for visualization in Google Earth or other KML-compatible applications. + * + * This demo: + * 1. Creates an AIS tracker + * 2. Feeds it with sample NMEA AIS messages + * 3. Exports the tracked vessels to a KML file + */ +public class KMLExportDemoApp { + + public static void main(String[] args) throws IOException { + System.out.println("AIS KML Export Demo"); + System.out.println("===================\n"); + + // Sample NMEA AIS messages containing position reports and static vessel data + String sampleNmeaMessages = + "!AIVDM,2,1,6,B,55NOpt400001L@O?;G0HuE9@R15D59@E:222220O0p>4440Ht6hhjH4QDiDU,0*46\n" + + "!AIVDM,2,2,6,B,QH888888880,2*38\n" + + "!AIVDM,1,1,,B,15NOpt0P00qQJLvA tracks = tracker.getAisTracks(); + System.out.println("Step 2: Found " + tracks.size() + " vessel(s) in the message stream\n"); + + // Display information about tracked vessels + System.out.println("Tracked vessels:"); + System.out.println("----------------"); + for (AISTrack track : tracks) { + String name = track.getShipName() != null && !track.getShipName().trim().isEmpty() + ? track.getShipName() + : "MMSI " + track.getMmsi(); + String position = track.getLatitude() != null && track.getLongitude() != null + ? String.format("%.4f, %.4f", track.getLatitude(), track.getLongitude()) + : "Unknown"; + System.out.println(" - " + name + " at position: " + position); + } + + // Export to KML file + System.out.println("\nStep 3: Exporting vessels to KML file..."); + String kmlFilename = "vessels.kml"; + try (FileWriter writer = new FileWriter(kmlFilename)) { + KMLExporter.exportToKML(tracks, writer); + } + + System.out.println("✓ KML export complete! File saved as: " + kmlFilename); + System.out.println("\nYou can now open '" + kmlFilename + "' in Google Earth or any KML-compatible application"); + System.out.println("to visualize the vessel positions."); + } +} diff --git a/src/test/java/dk/tbsalling/ais/exporter/KMLExporterTest.java b/src/test/java/dk/tbsalling/ais/exporter/KMLExporterTest.java new file mode 100644 index 0000000..0aede22 --- /dev/null +++ b/src/test/java/dk/tbsalling/ais/exporter/KMLExporterTest.java @@ -0,0 +1,413 @@ +package dk.tbsalling.ais.exporter; + +import dk.tbsalling.ais.tracker.AISTrack; +import dk.tbsalling.ais.tracker.AISTracker; +import dk.tbsalling.aismessages.ais.messages.AISMessage; +import dk.tbsalling.aismessages.ais.messages.PositionReport; +import dk.tbsalling.aismessages.ais.messages.ShipAndVoyageData; +import dk.tbsalling.aismessages.nmea.NMEAMessageHandler; +import dk.tbsalling.aismessages.nmea.messages.NMEAMessage; +import org.junit.jupiter.api.BeforeAll; +import org.junit.jupiter.api.Test; + +import java.io.IOException; +import java.io.StringWriter; +import java.util.ArrayList; +import java.util.Collections; +import java.util.List; +import java.util.Set; + +import static org.junit.jupiter.api.Assertions.*; + +public class KMLExporterTest { + + static ShipAndVoyageData staticAisMessageMMSI367524080; + static PositionReport dynamicAisMessageMMSI367524080; + static PositionReport dynamicAisMessageMMSI576048000; + static ShipAndVoyageData staticAisMessageMMSI211339980; + + private static AISMessage parseNMEA(NMEAMessage... nmeaMessages) { + List aisMessages = new ArrayList<>(); + NMEAMessageHandler handler = new NMEAMessageHandler("TESTSRC", aisMessages::add); + for (NMEAMessage msg : nmeaMessages) { + handler.accept(msg); + } + return aisMessages.isEmpty() ? null : aisMessages.get(0); + } + + @BeforeAll + public static void setup() { + staticAisMessageMMSI367524080 = (ShipAndVoyageData) parseNMEA( + new NMEAMessage("!AIVDM,2,1,6,B,55NOpt400001L@O?;G0HuE9@R15D59@E:222220O0p>4440Ht6hhjH4QDiDU,0*46"), + new NMEAMessage("!AIVDM,2,2,6,B,QH888888880,2*38") + ); + dynamicAisMessageMMSI367524080 = (PositionReport) parseNMEA( + new NMEAMessage("!AIVDM,1,1,,B,15NOpt0P00qQJLvA tracks = tracker.getAisTracks(); + return tracks.iterator().next(); + } + + private static AISTrack createTrackWithDynamicOnly() { + AISTracker tracker = new AISTracker(); + tracker.update(dynamicAisMessageMMSI576048000); + Set tracks = tracker.getAisTracks(); + return tracks.iterator().next(); + } + + private static AISTrack createTrackWithStaticOnly() { + AISTracker tracker = new AISTracker(); + tracker.update(staticAisMessageMMSI211339980); + Set tracks = tracker.getAisTracks(); + return tracks.iterator().next(); + } + + @Test + public void testExportToKMLWithNullTracksThrowsException() { + // Arrange + StringWriter writer = new StringWriter(); + + // Act & Assert + assertThrows(IllegalArgumentException.class, () -> + KMLExporter.exportToKML(null, writer) + ); + } + + @Test + public void testExportToKMLWithNullWriterThrowsException() { + // Arrange + List tracks = Collections.emptyList(); + + // Act & Assert + assertThrows(IllegalArgumentException.class, () -> + KMLExporter.exportToKML(tracks, null) + ); + } + + @Test + public void testExportSingleTrackToKMLWithNullTrackThrowsException() { + // Arrange + StringWriter writer = new StringWriter(); + + // Act & Assert + assertThrows(IllegalArgumentException.class, () -> + KMLExporter.exportSingleTrackToKML(null, writer) + ); + } + + @Test + public void testExportSingleTrackToKMLWithNullWriterThrowsException() { + // Arrange + AISTrack track = createTrackWithStaticAndDynamic(); + + // Act & Assert + assertThrows(IllegalArgumentException.class, () -> + KMLExporter.exportSingleTrackToKML(track, null) + ); + } + + @Test + public void testExportSingleTrackToKMLWithoutPositionThrowsException() { + // Arrange + AISTrack track = createTrackWithStaticOnly(); + StringWriter writer = new StringWriter(); + + // Act & Assert + assertThrows(IllegalArgumentException.class, () -> + KMLExporter.exportSingleTrackToKML(track, writer) + ); + } + + @Test + public void testExportEmptyTracksCollectionProducesValidKML() throws IOException { + // Arrange + List tracks = Collections.emptyList(); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportToKML(tracks, writer); + + // Assert + String kml = writer.toString(); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + } + + @Test + public void testExportSingleTrackWithCompleteDataProducesValidKML() throws IOException { + // Arrange + AISTrack track = createTrackWithStaticAndDynamic(); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportSingleTrackToKML(track, writer); + + // Assert + String kml = writer.toString(); + + // Check KML structure + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + + // Check vessel data + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("MMSI")); + assertTrue(kml.contains(String.valueOf(track.getMmsi()))); + + // Check position data + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + } + + @Test + public void testExportSingleTrackIncludesShipName() throws IOException { + // Arrange + AISTrack track = createTrackWithStaticAndDynamic(); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportSingleTrackToKML(track, writer); + + // Assert + String kml = writer.toString(); + if (track.getShipName() != null) { + assertTrue(kml.contains(track.getShipName())); + } + } + + @Test + public void testExportSingleTrackIncludesCallsign() throws IOException { + // Arrange + AISTrack track = createTrackWithStaticAndDynamic(); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportSingleTrackToKML(track, writer); + + // Assert + String kml = writer.toString(); + if (track.getCallsign() != null && !track.getCallsign().trim().isEmpty()) { + assertTrue(kml.contains("Callsign")); + assertTrue(kml.contains(track.getCallsign())); + } + } + + @Test + public void testExportSingleTrackIncludesPosition() throws IOException { + // Arrange + AISTrack track = createTrackWithStaticAndDynamic(); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportSingleTrackToKML(track, writer); + + // Assert + String kml = writer.toString(); + assertNotNull(track.getLatitude()); + assertNotNull(track.getLongitude()); + + // KML uses longitude,latitude order + String expectedCoords = String.format("%.6f,%.6f", track.getLongitude(), track.getLatitude()); + assertTrue(kml.contains(expectedCoords)); + } + + @Test + public void testExportSingleTrackIncludesSpeedAndCourse() throws IOException { + // Arrange + AISTrack track = createTrackWithStaticAndDynamic(); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportSingleTrackToKML(track, writer); + + // Assert + String kml = writer.toString(); + if (track.getSpeedOverGround() != null) { + assertTrue(kml.contains("Speed")); + assertTrue(kml.contains("knots")); + } + if (track.getCourseOverGround() != null) { + assertTrue(kml.contains("Course")); + } + } + + @Test + public void testExportMultipleTracksProducesValidKML() throws IOException { + // Arrange + AISTracker tracker = new AISTracker(); + tracker.update(staticAisMessageMMSI367524080); + tracker.update(dynamicAisMessageMMSI367524080); + tracker.update(dynamicAisMessageMMSI576048000); + List tracks = new ArrayList<>(tracker.getAisTracks()); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportToKML(tracks, writer); + + // Assert + String kml = writer.toString(); + + // Check KML structure + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + assertTrue(kml.contains("")); + + // Should contain placemarks for both tracks with positions + int placemarkCount = countOccurrences(kml, ""); + assertEquals(2, placemarkCount); + } + + @Test + public void testExportTracksSkipsTracksWithoutPosition() throws IOException { + // Arrange + AISTracker tracker = new AISTracker(); + tracker.update(staticAisMessageMMSI367524080); + tracker.update(dynamicAisMessageMMSI367524080); + tracker.update(staticAisMessageMMSI211339980); + List tracks = new ArrayList<>(tracker.getAisTracks()); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportToKML(tracks, writer); + + // Assert + String kml = writer.toString(); + + // Should only contain one placemark (for the track with position) + int placemarkCount = countOccurrences(kml, ""); + assertEquals(1, placemarkCount); + } + + @Test + public void testExportTracksHandlesSpecialCharactersInNames() throws IOException { + // Arrange - this would need a track with special characters in name + // For now, test that XML escaping is working by checking the method doesn't crash + AISTrack track = createTrackWithStaticAndDynamic(); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportSingleTrackToKML(track, writer); + + // Assert + String kml = writer.toString(); + // Should not contain unescaped XML special characters in CDATA sections + // CDATA sections can contain raw text, but outside CDATA should be escaped + assertNotNull(kml); + assertTrue(kml.contains("")); + } + + @Test + public void testExportSingleTrackUsesMMSIWhenShipNameNotAvailable() throws IOException { + // Arrange + AISTrack track = createTrackWithDynamicOnly(); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportSingleTrackToKML(track, writer); + + // Assert + String kml = writer.toString(); + assertTrue(kml.contains("MMSI " + track.getMmsi())); + } + + @Test + public void testExportIncludesTransponderClass() throws IOException { + // Arrange + AISTrack track = createTrackWithStaticAndDynamic(); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportSingleTrackToKML(track, writer); + + // Assert + String kml = writer.toString(); + if (track.getTransponderClass() != null) { + assertTrue(kml.contains("Transponder Class")); + } + } + + @Test + public void testExportIncludesShipType() throws IOException { + // Arrange + AISTrack track = createTrackWithStaticAndDynamic(); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportSingleTrackToKML(track, writer); + + // Assert + String kml = writer.toString(); + if (track.getShipType() != null) { + assertTrue(kml.contains("Ship Type")); + } + } + + @Test + public void testExportIncludesLastUpdateTime() throws IOException { + // Arrange + AISTrack track = createTrackWithStaticAndDynamic(); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportSingleTrackToKML(track, writer); + + // Assert + String kml = writer.toString(); + assertTrue(kml.contains("Last Update")); + } + + @Test + public void testExportIncludesVesselDimensionsWhenAvailable() throws IOException { + // Arrange + AISTrack track = createTrackWithStaticAndDynamic(); + StringWriter writer = new StringWriter(); + + // Act + KMLExporter.exportSingleTrackToKML(track, writer); + + // Assert + String kml = writer.toString(); + if (track.getToBow() != null && track.getToStern() != null) { + assertTrue(kml.contains("Dimensions")); + assertTrue(kml.contains("Length")); + } + } + + private int countOccurrences(String text, String pattern) { + int count = 0; + int index = 0; + while ((index = text.indexOf(pattern, index)) != -1) { + count++; + index += pattern.length(); + } + return count; + } +}