From: AsamK Date: Thu, 16 Dec 2021 20:10:15 +0000 (+0100) Subject: Improve error handling for tcp address parsing X-Git-Tag: v0.10.1~62 X-Git-Url: https://git.nmode.ca/signal-cli/commitdiff_plain/1c9d16e199e93abb60ce61ff4b88802ffe601089?ds=inline Improve error handling for tcp address parsing --- diff --git a/src/main/java/org/asamk/signal/util/IOUtils.java b/src/main/java/org/asamk/signal/util/IOUtils.java index b4c4c6dd..b772887b 100644 --- a/src/main/java/org/asamk/signal/util/IOUtils.java +++ b/src/main/java/org/asamk/signal/util/IOUtils.java @@ -98,16 +98,22 @@ public class IOUtils { public static InetSocketAddress parseInetSocketAddress(final String tcpAddress) throws UserErrorException { final var colonIndex = tcpAddress.lastIndexOf(':'); if (colonIndex < 0) { - throw new UserErrorException("Invalid tcp bind address: " + tcpAddress); + throw new UserErrorException("Invalid tcp bind address (expected host:port): " + tcpAddress); } - final String host = tcpAddress.substring(0, colonIndex); + final var host = tcpAddress.substring(0, colonIndex); + final var portString = tcpAddress.substring(colonIndex + 1); + final int port; try { - port = Integer.parseInt(tcpAddress.substring(colonIndex + 1)); + port = Integer.parseInt(portString); } catch (NumberFormatException e) { - throw new UserErrorException("Invalid tcp bind address: " + tcpAddress, e); + throw new UserErrorException("Invalid tcp port: " + portString, e); + } + final var socketAddress = new InetSocketAddress(host, port); + if (socketAddress.isUnresolved()) { + throw new UserErrorException("Invalid tcp bind address, invalid host: " + host); } - return new InetSocketAddress(host, port); + return socketAddress; } public static UnixDomainPrincipal getUnixDomainPrincipal(final SocketChannel channel) throws IOException {