X-Git-Url: https://git.nmode.ca/signal-cli/blobdiff_plain/81a11dc9776672e3468ee9a8eed556889fb2e070..c7a7d00da56f8f90fe8d6a11042fa2cd7cb3b985:/src/main/java/org/asamk/signal/util/IOUtils.java 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 {