Use Java 17

.github/workflows/ci.yml

@@ -8,7 +8,7 @@ jobs:
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        java: [ '11', '17' ]
+        java: [ '17' ]
 
     steps:
       - uses: actions/checkout@v1

.github/workflows/codeql-analysis.yml

@@ -19,7 +19,7 @@ jobs:
       - name: Setup Java JDK
         uses: actions/setup-java@v1
         with:
-          java-version: 11
+          java-version: 17
 
       - name: Checkout repository
         uses: actions/checkout@v2

CHANGELOG.md

@@ -1,6 +1,7 @@
 # Changelog
 
 ## [Unreleased]
+**Attention**: Now requires Java 17
 
 ## [0.9.2] - 2021-10-24
 ### Fixed

README.md

@@ -11,7 +11,7 @@ It also has a JSON-RPC based interface, see the [documentation](https://github.c
 You can [build signal-cli](#building) yourself, or use the [provided binary files](https://github.com/AsamK/signal-cli/releases/latest), which should work on Linux, macOS and Windows. For Arch Linux there is also a [package in AUR](https://aur.archlinux.org/packages/signal-cli/) and there is a [FreeBSD port](https://www.freshports.org/net-im/signal-cli) available as well.
 
 System requirements:
-- at least Java Runtime Environment (JRE) 11
+- at least Java Runtime Environment (JRE) 17
 - native libraries: libzkgroup, libsignal-client
 
   Those are bundled for x86_64 Linux (with recent enough glibc, see #643), for other systems/architectures see: [Provide native lib for libsignal](https://github.com/AsamK/signal-cli/wiki/Provide-native-lib-for-libsignal)

build.gradle.kts

@@ -9,8 +9,8 @@ plugins {
 version = "0.9.2"
 
 java {
-    sourceCompatibility = JavaVersion.VERSION_11
+    sourceCompatibility = JavaVersion.VERSION_17
-    targetCompatibility = JavaVersion.VERSION_11
+    targetCompatibility = JavaVersion.VERSION_17
 }
 
 application {
@@ -22,6 +22,7 @@ graalvmNative {
         this["main"].run {
             configurationFileDirectories.from(file("graalvm-config-dir"))
             buildArgs.add("--allow-incomplete-classpath")
+            buildArgs.add("--report-unsupported-elements-at-runtime")
         }
     }
 }

lib/build.gradle.kts

@@ -4,8 +4,8 @@ plugins {
 }
 
 java {
-    sourceCompatibility = JavaVersion.VERSION_11
+    sourceCompatibility = JavaVersion.VERSION_17
-    targetCompatibility = JavaVersion.VERSION_11
+    targetCompatibility = JavaVersion.VERSION_17
 }
 
 repositories {

lib/src/main/java/org/asamk/signal/manager/LibSignalLogger.java

@@ -20,22 +20,11 @@ public class LibSignalLogger implements SignalProtocolLogger {
     public void log(final int priority, final String tag, final String message) {
         final var logMessage = String.format("[%s]: %s", tag, message);
         switch (priority) {
-            case SignalProtocolLogger.VERBOSE:
+            case SignalProtocolLogger.VERBOSE -> logger.trace(logMessage);
-                logger.trace(logMessage);
+            case SignalProtocolLogger.DEBUG -> logger.debug(logMessage);
-                break;
+            case SignalProtocolLogger.INFO -> logger.info(logMessage);
-            case SignalProtocolLogger.DEBUG:
+            case SignalProtocolLogger.WARN -> logger.warn(logMessage);
-                logger.debug(logMessage);
+            case SignalProtocolLogger.ERROR, SignalProtocolLogger.ASSERT -> logger.error(logMessage);
-                break;
-            case SignalProtocolLogger.INFO:
-                logger.info(logMessage);
-                break;
-            case SignalProtocolLogger.WARN:
-                logger.warn(logMessage);
-                break;
-            case SignalProtocolLogger.ERROR:
-            case SignalProtocolLogger.ASSERT:
-                logger.error(logMessage);
-                break;
         }
     }
 }

lib/src/main/java/org/asamk/signal/manager/ManagerImpl.java

@@ -569,16 +569,15 @@ public class ManagerImpl implements Manager {
         long timestamp = System.currentTimeMillis();
         messageBuilder.withTimestamp(timestamp);
         for (final var recipient : recipients) {
-            if (recipient instanceof RecipientIdentifier.Single) {
+            if (recipient instanceof RecipientIdentifier.Single single) {
-                final var recipientId = resolveRecipient((RecipientIdentifier.Single) recipient);
+                final var recipientId = resolveRecipient(single);
                 final var result = sendHelper.sendMessage(messageBuilder, recipientId);
                 results.put(recipient, List.of(result));
             } else if (recipient instanceof RecipientIdentifier.NoteToSelf) {
                 final var result = sendHelper.sendSelfMessage(messageBuilder);
                 results.put(recipient, List.of(result));
-            } else if (recipient instanceof RecipientIdentifier.Group) {
+            } else if (recipient instanceof RecipientIdentifier.Group group) {
-                final var groupId = ((RecipientIdentifier.Group) recipient).groupId;
+                final var result = sendHelper.sendAsGroupMessage(messageBuilder, group.groupId);
-                final var result = sendHelper.sendAsGroupMessage(messageBuilder, groupId);
                 results.put(recipient, result);
             }
         }

lib/src/main/java/org/asamk/signal/manager/SignalWebSocketHealthMonitor.java

@@ -63,15 +63,9 @@ public final class SignalWebSocketHealthMonitor implements HealthMonitor {
 
     private synchronized void onStateChange(WebSocketConnectionState connectionState, HealthState healthState) {
         switch (connectionState) {
-            case CONNECTED:
+            case CONNECTED -> logger.debug("WebSocket is now connected");
-                logger.debug("WebSocket is now connected");
+            case AUTHENTICATION_FAILED -> logger.debug("WebSocket authentication failed");
-                break;
+            case FAILED -> logger.debug("WebSocket connection failed");
-            case AUTHENTICATION_FAILED:
-                logger.debug("WebSocket authentication failed");
-                break;
-            case FAILED:
-                logger.debug("WebSocket connection failed");
-                break;
         }
 
         healthState.needsKeepAlive = connectionState == WebSocketConnectionState.CONNECTED;

lib/src/main/java/org/asamk/signal/manager/TrustLevel.java

@@ -18,40 +18,27 @@ public enum TrustLevel {
     }
 
     public static TrustLevel fromIdentityState(ContactRecord.IdentityState identityState) {
-        switch (identityState) {
+        return switch (identityState) {
-            case DEFAULT:
+            case DEFAULT -> TRUSTED_UNVERIFIED;
-                return TRUSTED_UNVERIFIED;
+            case UNVERIFIED -> UNTRUSTED;
-            case UNVERIFIED:
+            case VERIFIED -> TRUSTED_VERIFIED;
-                return UNTRUSTED;
+            case UNRECOGNIZED -> null;
-            case VERIFIED:
+        };
-                return TRUSTED_VERIFIED;
-            case UNRECOGNIZED:
-                return null;
-        }
-        throw new RuntimeException("Unknown identity state: " + identityState);
     }
 
     public static TrustLevel fromVerifiedState(VerifiedMessage.VerifiedState verifiedState) {
-        switch (verifiedState) {
+        return switch (verifiedState) {
-            case DEFAULT:
+            case DEFAULT -> TRUSTED_UNVERIFIED;
-                return TRUSTED_UNVERIFIED;
+            case UNVERIFIED -> UNTRUSTED;
-            case UNVERIFIED:
+            case VERIFIED -> TRUSTED_VERIFIED;
-                return UNTRUSTED;
+        };
-            case VERIFIED:
-                return TRUSTED_VERIFIED;
-        }
-        throw new RuntimeException("Unknown verified state: " + verifiedState);
     }
 
     public VerifiedMessage.VerifiedState toVerifiedState() {
-        switch (this) {
+        return switch (this) {
-            case TRUSTED_UNVERIFIED:
+            case TRUSTED_UNVERIFIED -> VerifiedMessage.VerifiedState.DEFAULT;
-                return VerifiedMessage.VerifiedState.DEFAULT;
+            case UNTRUSTED -> VerifiedMessage.VerifiedState.UNVERIFIED;
-            case UNTRUSTED:
+            case TRUSTED_VERIFIED -> VerifiedMessage.VerifiedState.VERIFIED;
-                return VerifiedMessage.VerifiedState.UNVERIFIED;
+        };
-            case TRUSTED_VERIFIED:
-                return VerifiedMessage.VerifiedState.VERIFIED;
-        }
-        throw new RuntimeException("Unknown verified state: " + this);
     }
 }

lib/src/main/java/org/asamk/signal/manager/actions/SendRetryMessageRequestAction.java

@@ -54,17 +54,12 @@ public class SendRetryMessageRequestAction implements HandleAction {
     }
 
     private static int envelopeTypeToCiphertextMessageType(int envelopeType) {
-        switch (envelopeType) {
+        return switch (envelopeType) {
-            case SignalServiceProtos.Envelope.Type.PREKEY_BUNDLE_VALUE:
+            case SignalServiceProtos.Envelope.Type.PREKEY_BUNDLE_VALUE -> CiphertextMessage.PREKEY_TYPE;
-                return CiphertextMessage.PREKEY_TYPE;
+            case SignalServiceProtos.Envelope.Type.UNIDENTIFIED_SENDER_VALUE -> CiphertextMessage.SENDERKEY_TYPE;
-            case SignalServiceProtos.Envelope.Type.UNIDENTIFIED_SENDER_VALUE:
+            case SignalServiceProtos.Envelope.Type.PLAINTEXT_CONTENT_VALUE -> CiphertextMessage.PLAINTEXT_CONTENT_TYPE;
-                return CiphertextMessage.SENDERKEY_TYPE;
+            default -> CiphertextMessage.WHISPER_TYPE;
-            case SignalServiceProtos.Envelope.Type.PLAINTEXT_CONTENT_VALUE:
+        };
-                return CiphertextMessage.PLAINTEXT_CONTENT_TYPE;
-            case SignalServiceProtos.Envelope.Type.CIPHERTEXT_VALUE:
-            default:
-                return CiphertextMessage.WHISPER_TYPE;
-        }
     }
 
     @Override

lib/src/main/java/org/asamk/signal/manager/api/RecipientIdentifier.java

@@ -9,9 +9,9 @@ import org.whispersystems.signalservice.api.util.UuidUtil;
 
 import java.util.UUID;
 
-public abstract class RecipientIdentifier {
+public sealed abstract class RecipientIdentifier {
 
-    public static class NoteToSelf extends RecipientIdentifier {
+    public static final class NoteToSelf extends RecipientIdentifier {
 
         public static NoteToSelf INSTANCE = new NoteToSelf();
 
@@ -19,7 +19,7 @@ public abstract class RecipientIdentifier {
         }
     }
 
-    public abstract static class Single extends RecipientIdentifier {
+    public sealed static abstract class Single extends RecipientIdentifier {
 
         public static Single fromString(String identifier, String localNumber) throws InvalidNumberException {
             return UuidUtil.isUuid(identifier)
@@ -43,7 +43,7 @@ public abstract class RecipientIdentifier {
         public abstract String getIdentifier();
     }
 
-    public static class Uuid extends Single {
+    public static final class Uuid extends Single {
 
         public final UUID uuid;
 
@@ -72,7 +72,7 @@ public abstract class RecipientIdentifier {
         }
     }
 
-    public static class Number extends Single {
+    public static final class Number extends Single {
 
         public final String number;
 
@@ -101,7 +101,7 @@ public abstract class RecipientIdentifier {
         }
     }
 
-    public static class Group extends RecipientIdentifier {
+    public static final class Group extends RecipientIdentifier {
 
         public final GroupId groupId;
 

lib/src/main/java/org/asamk/signal/manager/api/TypingAction.java

@@ -7,13 +7,9 @@ public enum TypingAction {
     STOP;
 
     public SignalServiceTypingMessage.Action toSignalService() {
-        switch (this) {
+        return switch (this) {
-            case START:
+            case START -> SignalServiceTypingMessage.Action.STARTED;
-                return SignalServiceTypingMessage.Action.STARTED;
+            case STOP -> SignalServiceTypingMessage.Action.STOPPED;
-            case STOP:
+        };
-                return SignalServiceTypingMessage.Action.STOPPED;
-            default:
-                throw new IllegalStateException("Invalid typing action " + this);
-        }
     }
 }

lib/src/main/java/org/asamk/signal/manager/config/ServiceConfig.java

@@ -88,19 +88,15 @@ public class ServiceConfig {
 
         final var interceptors = List.of(userAgentInterceptor);
 
-        switch (serviceEnvironment) {
+        return switch (serviceEnvironment) {
-            case LIVE:
+            case LIVE -> new ServiceEnvironmentConfig(LiveConfig.createDefaultServiceConfiguration(interceptors),
-                return new ServiceEnvironmentConfig(LiveConfig.createDefaultServiceConfiguration(interceptors),
+                    LiveConfig.getUnidentifiedSenderTrustRoot(),
-                        LiveConfig.getUnidentifiedSenderTrustRoot(),
+                    LiveConfig.createKeyBackupConfig(),
-                        LiveConfig.createKeyBackupConfig(),
+                    LiveConfig.getCdsMrenclave());
-                        LiveConfig.getCdsMrenclave());
+            case SANDBOX -> new ServiceEnvironmentConfig(SandboxConfig.createDefaultServiceConfiguration(interceptors),
-            case SANDBOX:
+                    SandboxConfig.getUnidentifiedSenderTrustRoot(),
-                return new ServiceEnvironmentConfig(SandboxConfig.createDefaultServiceConfiguration(interceptors),
+                    SandboxConfig.createKeyBackupConfig(),
-                        SandboxConfig.getUnidentifiedSenderTrustRoot(),
+                    SandboxConfig.getCdsMrenclave());
-                        SandboxConfig.createKeyBackupConfig(),
+        };
-                        SandboxConfig.getCdsMrenclave());
-            default:
-                throw new IllegalArgumentException("Unsupported environment");
-        }
     }
 }

lib/src/main/java/org/asamk/signal/manager/groups/GroupId.java

@@ -3,7 +3,7 @@ package org.asamk.signal.manager.groups;
 import java.util.Arrays;
 import java.util.Base64;
 
-public abstract class GroupId {
+public abstract sealed class GroupId permits GroupIdV1, GroupIdV2 {
 
     private final byte[] id;
 

lib/src/main/java/org/asamk/signal/manager/groups/GroupIdV1.java

@@ -4,7 +4,7 @@ import java.util.Base64;
 
 import static org.asamk.signal.manager.util.KeyUtils.getSecretBytes;
 
-public class GroupIdV1 extends GroupId {
+public final class GroupIdV1 extends GroupId {
 
     public static GroupIdV1 createRandom() {
         return new GroupIdV1(getSecretBytes(16));

lib/src/main/java/org/asamk/signal/manager/groups/GroupIdV2.java

@@ -2,7 +2,7 @@ package org.asamk.signal.manager.groups;
 
 import java.util.Base64;
 
-public class GroupIdV2 extends GroupId {
+public final class GroupIdV2 extends GroupId {
 
     public static GroupIdV2 fromBase64(String groupId) {
         return new GroupIdV2(Base64.getDecoder().decode(groupId));

lib/src/main/java/org/asamk/signal/manager/groups/GroupInviteLinkUrl.java

@@ -56,7 +56,7 @@ public final class GroupInviteLinkUrl {
             var groupInviteLink = GroupInviteLink.parseFrom(bytes);
 
             switch (groupInviteLink.getContentsCase()) {
-                case V1CONTENTS: {
+                case V1CONTENTS -> {
                     var groupInviteLinkContentsV1 = groupInviteLink.getV1Contents();
                     var groupMasterKey = new GroupMasterKey(groupInviteLinkContentsV1.getGroupMasterKey()
                             .toByteArray());
@@ -65,8 +65,7 @@ public final class GroupInviteLinkUrl {
 
                     return new GroupInviteLinkUrl(groupMasterKey, password);
                 }
-                default:
+                default -> throw new UnknownGroupLinkVersionException("Url contains no known group link content");
-                    throw new UnknownGroupLinkVersionException("Url contains no known group link content");
             }
         } catch (InvalidInputException | IOException e) {
             throw new InvalidGroupLinkException(e);

lib/src/main/java/org/asamk/signal/manager/helper/GroupHelper.java

@@ -351,8 +351,7 @@ public class GroupHelper {
 
     private GroupInfo getGroup(GroupId groupId, boolean forceUpdate) {
         final var group = account.getGroupStore().getGroup(groupId);
-        if (group instanceof GroupInfoV2) {
+        if (group instanceof GroupInfoV2 groupInfoV2) {
-            final var groupInfoV2 = (GroupInfoV2) group;
             if (forceUpdate || (!groupInfoV2.isPermissionDenied() && groupInfoV2.getGroup() == null)) {
                 final var groupSecretParams = GroupSecretParams.deriveFromMasterKey(groupInfoV2.getMasterKey());
                 DecryptedGroup decryptedGroup;

lib/src/main/java/org/asamk/signal/manager/helper/GroupV2Helper.java

@@ -391,27 +391,18 @@ public class GroupV2Helper {
     }
 
     private AccessControl.AccessRequired toAccessControl(final GroupLinkState state) {
-        switch (state) {
+        return switch (state) {
-            case DISABLED:
+            case DISABLED -> AccessControl.AccessRequired.UNSATISFIABLE;
-                return AccessControl.AccessRequired.UNSATISFIABLE;
+            case ENABLED -> AccessControl.AccessRequired.ANY;
-            case ENABLED:
+            case ENABLED_WITH_APPROVAL -> AccessControl.AccessRequired.ADMINISTRATOR;
-                return AccessControl.AccessRequired.ANY;
+        };
-            case ENABLED_WITH_APPROVAL:
-                return AccessControl.AccessRequired.ADMINISTRATOR;
-            default:
-                throw new AssertionError();
-        }
     }
 
     private AccessControl.AccessRequired toAccessControl(final GroupPermission permission) {
-        switch (permission) {
+        return switch (permission) {
-            case EVERY_MEMBER:
+            case EVERY_MEMBER -> AccessControl.AccessRequired.MEMBER;
-                return AccessControl.AccessRequired.MEMBER;
+            case ONLY_ADMINS -> AccessControl.AccessRequired.ADMINISTRATOR;
-            case ONLY_ADMINS:
+        };
-                return AccessControl.AccessRequired.ADMINISTRATOR;
-            default:
-                throw new AssertionError();
-        }
     }
 
     private GroupsV2Operations.GroupOperations getGroupOperations(final GroupInfoV2 groupInfoV2) {

lib/src/main/java/org/asamk/signal/manager/helper/SyncHelper.java

@@ -83,8 +83,7 @@ public class SyncHelper {
             try (OutputStream fos = new FileOutputStream(groupsFile)) {
                 var out = new DeviceGroupsOutputStream(fos);
                 for (var record : account.getGroupStore().getGroups()) {
-                    if (record instanceof GroupInfoV1) {
+                    if (record instanceof GroupInfoV1 groupInfo) {
-                        var groupInfo = (GroupInfoV1) record;
                         out.write(new DeviceGroup(groupInfo.getGroupId().serialize(),
                                 Optional.fromNullable(groupInfo.name),
                                 groupInfo.getMembers()

lib/src/main/java/org/asamk/signal/manager/storage/groups/GroupInfo.java

@@ -9,7 +9,7 @@ import java.util.Set;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
-public abstract class GroupInfo {
+public sealed abstract class GroupInfo permits GroupInfoV1, GroupInfoV2 {
 
     public abstract GroupId getGroupId();
 

lib/src/main/java/org/asamk/signal/manager/storage/groups/GroupInfoV1.java

@@ -11,7 +11,7 @@ import java.util.Collection;
 import java.util.HashSet;
 import java.util.Set;
 
-public class GroupInfoV1 extends GroupInfo {
+public final class GroupInfoV1 extends GroupInfo {
 
     private final GroupIdV1 groupId;
 

lib/src/main/java/org/asamk/signal/manager/storage/groups/GroupInfoV2.java

@@ -15,7 +15,7 @@ import org.whispersystems.signalservice.api.util.UuidUtil;
 import java.util.Set;
 import java.util.stream.Collectors;
 
-public class GroupInfoV2 extends GroupInfo {
+public final class GroupInfoV2 extends GroupInfo {
 
     private final GroupIdV2 groupId;
     private final GroupMasterKey masterKey;
@@ -197,12 +197,9 @@ public class GroupInfoV2 extends GroupInfo {
     }
 
     private static GroupPermission toGroupPermission(final AccessControl.AccessRequired permission) {
-        switch (permission) {
+        return switch (permission) {
-            case ADMINISTRATOR:
+            case ADMINISTRATOR -> GroupPermission.ONLY_ADMINS;
-                return GroupPermission.ONLY_ADMINS;
+            default -> GroupPermission.EVERY_MEMBER;
-            case MEMBER:
+        };
-            default:
-                return GroupPermission.EVERY_MEMBER;
-        }
     }
 }

lib/src/main/java/org/asamk/signal/manager/storage/groups/GroupStore.java

@@ -75,8 +75,7 @@ public class GroupStore {
             final Saver saver
     ) {
         final var groups = storage.groups.stream().map(g -> {
-            if (g instanceof Storage.GroupV1) {
+            if (g instanceof Storage.GroupV1 g1) {
-                final var g1 = (Storage.GroupV1) g;
                 final var members = g1.members.stream().map(m -> {
                     if (m.recipientId == null) {
                         return recipientResolver.resolveRecipient(new RecipientAddress(UuidUtil.parseOrNull(m.uuid),
@@ -186,8 +185,7 @@ public class GroupStore {
         synchronized (groups) {
             var modified = false;
             for (var group : this.groups.values()) {
-                if (group instanceof GroupInfoV1) {
+                if (group instanceof GroupInfoV1 groupV1) {
-                    var groupV1 = (GroupInfoV1) group;
                     if (groupV1.isMember(toBeMergedRecipientId)) {
                         groupV1.removeMember(toBeMergedRecipientId);
                         groupV1.addMembers(List.of(recipientId));
@@ -220,8 +218,7 @@ public class GroupStore {
 
     private GroupInfoV1 getGroupV1ByV2IdLocked(GroupIdV2 groupIdV2) {
         for (var g : groups.values()) {
-            if (g instanceof GroupInfoV1) {
+            if (g instanceof GroupInfoV1 gv1) {
-                final var gv1 = (GroupInfoV1) g;
                 if (groupIdV2.equals(gv1.getExpectedV2Id())) {
                     return gv1;
                 }
@@ -256,8 +253,7 @@ public class GroupStore {
 
     private Storage toStorageLocked() {
         return new Storage(groups.values().stream().map(g -> {
-            if (g instanceof GroupInfoV1) {
+            if (g instanceof GroupInfoV1 g1) {
-                final var g1 = (GroupInfoV1) g;
                 return new Storage.GroupV1(g1.getGroupId().toBase64(),
                         g1.getExpectedV2Id().toBase64(),
                         g1.name,

lib/src/main/java/org/asamk/signal/manager/storage/recipients/RecipientAddress.java

@@ -19,7 +19,7 @@ public class RecipientAddress {
      */
     public RecipientAddress(Optional<UUID> uuid, Optional<String> e164) {
         uuid = uuid.isPresent() && uuid.get().equals(UuidUtil.UNKNOWN_UUID) ? Optional.empty() : uuid;
-        if (!uuid.isPresent() && !e164.isPresent()) {
+        if (uuid.isEmpty() && e164.isEmpty()) {
             throw new AssertionError("Must have either a UUID or E164 number!");
         }
 

lib/src/main/java/org/asamk/signal/manager/util/ProfileUtils.java

@@ -91,14 +91,11 @@ public class ProfileUtils {
         }
         String[] parts = name.split("\0");
 
-        switch (parts.length) {
+        return switch (parts.length) {
-            case 0:
+            case 0 -> new Pair<>(null, null);
-                return new Pair<>(null, null);
+            case 1 -> new Pair<>(parts[0], null);
-            case 1:
+            default -> new Pair<>(parts[0], parts[1]);
-                return new Pair<>(parts[0], null);
+        };
-            default:
-                return new Pair<>(parts[0], parts[1]);
-        }
     }
 
     static String trimZeros(String str) {

run_tests.sh

@@ -6,7 +6,7 @@ fi
 
 set -e
 # To update graalvm config, set GRAALVM_HOME, e.g:
-# export GRAALVM_HOME=/usr/lib/jvm/java-11-graalvm
+# export GRAALVM_HOME=/usr/lib/jvm/java-17-graalvm
 if [ ! -z "$GRAALVM_HOME" ]; then
   export JAVA_HOME=$GRAALVM_HOME
   export SIGNAL_CLI_OPTS='-agentlib:native-image-agent=config-merge-dir=graalvm-config-dir/'

src/main/java/org/asamk/SignalControl.java

@@ -26,7 +26,7 @@ public interface SignalControl extends DBusInterface {
 
     String link(String newDeviceName) throws Error.Failure;
 
-    public String version();
+    String version();
 
     List<DBusPath> listAccounts();
 

src/main/java/org/asamk/signal/ReceiveMessageHandler.java

@@ -53,8 +53,7 @@ public class ReceiveMessageHandler implements Manager.ReceiveMessageHandler {
             writer.println("Got receipt.");
         } else if (envelope.isSignalMessage() || envelope.isPreKeySignalMessage() || envelope.isUnidentifiedSender()) {
             if (exception != null) {
-                if (exception instanceof UntrustedIdentityException) {
+                if (exception instanceof UntrustedIdentityException e) {
-                    var e = (UntrustedIdentityException) exception;
                     writer.println(
                             "The user’s key is untrusted, either the user has reinstalled Signal or a third party sent this message.");
                     final var recipientName = getLegacyIdentifier(m.resolveSignalServiceAddress(e.getSender()));

src/main/java/org/asamk/signal/commands/GetUserStatusCommand.java

@@ -47,8 +47,7 @@ public class GetUserStatusCommand implements JsonRpcLocalCommand {
         }
 
         // Output
-        if (outputWriter instanceof JsonWriter) {
+        if (outputWriter instanceof JsonWriter jsonWriter) {
-            final var jsonWriter = (JsonWriter) outputWriter;
 
             var jsonUserStatuses = registered.entrySet().stream().map(entry -> {
                 final var number = entry.getValue().first();

src/main/java/org/asamk/signal/commands/JoinGroupCommand.java

@@ -55,8 +55,7 @@ public class JoinGroupCommand implements JsonRpcLocalCommand {
         try {
             final var results = m.joinGroup(linkUrl);
             var newGroupId = results.first();
-            if (outputWriter instanceof JsonWriter) {
+            if (outputWriter instanceof JsonWriter writer) {
-                final var writer = (JsonWriter) outputWriter;
                 if (!m.getGroup(newGroupId).isMember()) {
                     writer.write(Map.of("groupId", newGroupId.toBase64(), "onlyRequested", true));
                 } else {

src/main/java/org/asamk/signal/commands/ListContactsCommand.java

@@ -27,8 +27,7 @@ public class ListContactsCommand implements JsonRpcLocalCommand {
     public void handleCommand(final Namespace ns, final Manager m, final OutputWriter outputWriter) {
         var contacts = m.getContacts();
 
-        if (outputWriter instanceof PlainTextWriter) {
+        if (outputWriter instanceof PlainTextWriter writer) {
-            final var writer = (PlainTextWriter) outputWriter;
             for (var c : contacts) {
                 final var contact = c.second();
                 writer.println("Number: {} Name: {} Blocked: {} Message expiration: {}",

src/main/java/org/asamk/signal/commands/ListDevicesCommand.java

@@ -43,8 +43,7 @@ public class ListDevicesCommand implements JsonRpcLocalCommand {
             throw new IOErrorException("Failed to get linked devices: " + e.getMessage(), e);
         }
 
-        if (outputWriter instanceof PlainTextWriter) {
+        if (outputWriter instanceof PlainTextWriter writer) {
-            final var writer = (PlainTextWriter) outputWriter;
             for (var d : devices) {
                 writer.println("- Device {}{}:", d.getId(), (d.isThisDevice() ? " (this device)" : ""));
                 writer.indent(w -> {

src/main/java/org/asamk/signal/commands/ListGroupsCommand.java

@@ -80,8 +80,7 @@ public class ListGroupsCommand implements JsonRpcLocalCommand {
     ) throws CommandException {
         final var groups = m.getGroups();
 
-        if (outputWriter instanceof JsonWriter) {
+        if (outputWriter instanceof JsonWriter jsonWriter) {
-            final var jsonWriter = (JsonWriter) outputWriter;
 
             var jsonGroups = groups.stream().map(group -> {
                 final var groupInviteLink = group.getGroupInviteLinkUrl();

src/main/java/org/asamk/signal/commands/ListIdentitiesCommand.java

@@ -59,8 +59,7 @@ public class ListIdentitiesCommand implements JsonRpcLocalCommand {
             identities = m.getIdentities(CommandUtil.getSingleRecipientIdentifier(number, m.getSelfNumber()));
         }
 
-        if (outputWriter instanceof PlainTextWriter) {
+        if (outputWriter instanceof PlainTextWriter writer) {
-            final var writer = (PlainTextWriter) outputWriter;
             for (var id : identities) {
                 printIdentityFingerprint(writer, m, id);
             }

src/main/java/org/asamk/signal/commands/QuitGroupCommand.java

@@ -79,8 +79,7 @@ public class QuitGroupCommand implements JsonRpcLocalCommand {
     }
 
     private void outputResult(final OutputWriter outputWriter, final long timestamp) {
-        if (outputWriter instanceof PlainTextWriter) {
+        if (outputWriter instanceof PlainTextWriter writer) {
-            final var writer = (PlainTextWriter) outputWriter;
             writer.println("{}", timestamp);
         } else {
             final var writer = (JsonWriter) outputWriter;

src/main/java/org/asamk/signal/commands/ReceiveCommand.java

@@ -58,8 +58,7 @@ public class ReceiveCommand implements ExtendedDbusCommand, LocalCommand {
             final Namespace ns, final Signal signal, DBusConnection dbusconnection, final OutputWriter outputWriter
     ) throws CommandException {
         try {
-            if (outputWriter instanceof JsonWriter) {
+            if (outputWriter instanceof JsonWriter jsonWriter) {
-                final var jsonWriter = (JsonWriter) outputWriter;
 
                 dbusconnection.addSigHandler(Signal.MessageReceived.class, signal, messageReceived -> {
                     var envelope = new JsonMessageEnvelope(messageReceived);

src/main/java/org/asamk/signal/commands/RegisterCommand.java

@@ -40,10 +40,11 @@ public class RegisterCommand implements RegistrationCommand {
         } catch (CaptchaRequiredException e) {
             String message;
             if (captcha == null) {
-                message = "Captcha required for verification, use --captcha CAPTCHA\n"
+                message = """
-                        + "To get the token, go to https://signalcaptchas.org/registration/generate.html\n"
+                        Captcha required for verification, use --captcha CAPTCHA
-                        + "Check the developer tools (F12) console for a failed redirect to signalcaptcha://\n"
+                        To get the token, go to https://signalcaptchas.org/registration/generate.html
-                        + "Everything after signalcaptcha:// is the captcha token.";
+                        Check the developer tools (F12) console for a failed redirect to signalcaptcha://
+                        Everything after signalcaptcha:// is the captcha token.""";
             } else {
                 message = "Invalid captcha given.";
             }

src/main/java/org/asamk/signal/commands/RemoteDeleteCommand.java

@@ -67,8 +67,7 @@ public class RemoteDeleteCommand implements JsonRpcLocalCommand {
     }
 
     private void outputResult(final OutputWriter outputWriter, final long timestamp) {
-        if (outputWriter instanceof PlainTextWriter) {
+        if (outputWriter instanceof PlainTextWriter writer) {
-            final var writer = (PlainTextWriter) outputWriter;
             writer.println("{}", timestamp);
         } else {
             final var writer = (JsonWriter) outputWriter;

src/main/java/org/asamk/signal/commands/SendCommand.java

@@ -113,8 +113,7 @@ public class SendCommand implements JsonRpcLocalCommand {
     }
 
     private void outputResult(final OutputWriter outputWriter, final long timestamp) {
-        if (outputWriter instanceof PlainTextWriter) {
+        if (outputWriter instanceof PlainTextWriter writer) {
-            final var writer = (PlainTextWriter) outputWriter;
             writer.println("{}", timestamp);
         } else {
             final var writer = (JsonWriter) outputWriter;

src/main/java/org/asamk/signal/commands/SendReactionCommand.java

@@ -83,8 +83,7 @@ public class SendReactionCommand implements JsonRpcLocalCommand {
     }
 
     private void outputResult(final OutputWriter outputWriter, final long timestamp) {
-        if (outputWriter instanceof PlainTextWriter) {
+        if (outputWriter instanceof PlainTextWriter writer) {
-            final var writer = (PlainTextWriter) outputWriter;
             writer.println("{}", timestamp);
         } else {
             final var writer = (JsonWriter) outputWriter;

src/main/java/org/asamk/signal/commands/UpdateGroupCommand.java

@@ -77,33 +77,23 @@ public class UpdateGroupCommand implements JsonRpcLocalCommand {
         if (value == null) {
             return null;
         }
-        switch (value) {
+        return switch (value) {
-            case "enabled":
+            case "enabled" -> GroupLinkState.ENABLED;
-                return GroupLinkState.ENABLED;
+            case "enabled-with-approval", "enabledWithApproval" -> GroupLinkState.ENABLED_WITH_APPROVAL;
-            case "enabled-with-approval":
+            case "disabled" -> GroupLinkState.DISABLED;
-            case "enabledWithApproval":
+            default -> throw new UserErrorException("Invalid group link state: " + value);
-                return GroupLinkState.ENABLED_WITH_APPROVAL;
+        };
-            case "disabled":
-                return GroupLinkState.DISABLED;
-            default:
-                throw new UserErrorException("Invalid group link state: " + value);
-        }
     }
 
     GroupPermission getGroupPermission(String value) throws UserErrorException {
         if (value == null) {
             return null;
         }
-        switch (value) {
+        return switch (value) {
-            case "every-member":
+            case "every-member", "everyMember" -> GroupPermission.EVERY_MEMBER;
-            case "everyMember":
+            case "only-admins", "onlyAdmins" -> GroupPermission.ONLY_ADMINS;
-                return GroupPermission.EVERY_MEMBER;
+            default -> throw new UserErrorException("Invalid group permission: " + value);
-            case "only-admins":
+        };
-            case "onlyAdmins":
-                return GroupPermission.ONLY_ADMINS;
-            default:
-                throw new UserErrorException("Invalid group permission: " + value);
-        }
     }
 
     @Override
@@ -179,8 +169,7 @@ public class UpdateGroupCommand implements JsonRpcLocalCommand {
     }
 
     private void outputResult(final OutputWriter outputWriter, final Long timestamp, final GroupId groupId) {
-        if (outputWriter instanceof PlainTextWriter) {
+        if (outputWriter instanceof PlainTextWriter writer) {
-            final var writer = (PlainTextWriter) outputWriter;
             if (groupId != null) {
                 writer.println("Created new group: \"{}\"", groupId.toBase64());
             }

src/main/java/org/asamk/signal/commands/UploadStickerPackCommand.java

@@ -42,8 +42,7 @@ public class UploadStickerPackCommand implements JsonRpcLocalCommand {
 
         try {
             var url = m.uploadStickerPack(path);
-            if (outputWriter instanceof PlainTextWriter) {
+            if (outputWriter instanceof PlainTextWriter writer) {
-                final var writer = (PlainTextWriter) outputWriter;
                 writer.println("{}", url);
             } else {
                 final var writer = (JsonWriter) outputWriter;

src/main/java/org/asamk/signal/dbus/DbusManagerImpl.java

@@ -274,15 +274,9 @@ public class DbusManagerImpl implements Manager {
         }
         if (updateGroup.getGroupLinkState() != null) {
             switch (updateGroup.getGroupLinkState()) {
-                case DISABLED:
+                case DISABLED -> group.disableLink();
-                    group.disableLink();
+                case ENABLED -> group.enableLink(false);
-                    break;
+                case ENABLED_WITH_APPROVAL -> group.enableLink(true);
-                case ENABLED:
-                    group.enableLink(false);
-                    break;
-                case ENABLED_WITH_APPROVAL:
-                    group.enableLink(true);
-                    break;
             }
         }
         return new SendGroupMessageResults(0, List.of());

src/main/java/org/asamk/signal/json/JsonMessageEnvelope.java

@@ -71,8 +71,7 @@ public class JsonMessageEnvelope {
             this.sourceNumber = source.getNumber().orNull();
             this.sourceUuid = source.getUuid().toString();
             this.sourceDevice = content.getSenderDevice();
-        } else if (exception instanceof UntrustedIdentityException) {
+        } else if (exception instanceof UntrustedIdentityException e) {
-            var e = (UntrustedIdentityException) exception;
             final var source = m.resolveSignalServiceAddress(e.getSender());
             this.source = getLegacyIdentifier(source);
             this.sourceNumber = source.getNumber().orNull();

src/main/java/org/asamk/signal/jsonrpc/JsonRpcBulkMessage.java

@@ -4,7 +4,7 @@ import com.fasterxml.jackson.databind.JsonNode;
 
 import java.util.List;
 
-public class JsonRpcBulkMessage extends JsonRpcMessage {
+public final class JsonRpcBulkMessage extends JsonRpcMessage {
 
     List<JsonNode> messages;
 

src/main/java/org/asamk/signal/jsonrpc/JsonRpcMessage.java

@@ -4,6 +4,6 @@ package org.asamk.signal.jsonrpc;
  * Represents a JSON-RPC (bulk) request or (bulk) response.
  * https://www.jsonrpc.org/specification
  */
-public abstract class JsonRpcMessage {
+public sealed abstract class JsonRpcMessage permits JsonRpcBulkMessage, JsonRpcRequest, JsonRpcResponse {
 
 }

src/main/java/org/asamk/signal/jsonrpc/JsonRpcRequest.java

@@ -8,7 +8,7 @@ import com.fasterxml.jackson.databind.node.ValueNode;
  * Represents a JSON-RPC request.
  * https://www.jsonrpc.org/specification#request_object
  */
-public class JsonRpcRequest extends JsonRpcMessage {
+public final class JsonRpcRequest extends JsonRpcMessage {
 
     /**
      * A String specifying the version of the JSON-RPC protocol. MUST be exactly "2.0".

src/main/java/org/asamk/signal/jsonrpc/JsonRpcResponse.java

@@ -8,7 +8,7 @@ import com.fasterxml.jackson.databind.node.ValueNode;
  * Represents a JSON-RPC response.
  * https://www.jsonrpc.org/specification#response_object
  */
-public class JsonRpcResponse extends JsonRpcMessage {
+public final class JsonRpcResponse extends JsonRpcMessage {
 
     /**
      * A String specifying the version of the JSON-RPC protocol. MUST be exactly "2.0".

src/main/java/org/asamk/signal/util/ErrorUtils.java

@@ -64,12 +64,12 @@ public class ErrorUtils {
                     "CAPTCHA proof required for sending to \"%s\", available options \"%s\" with challenge token \"%s\", or wait \"%d\" seconds.\n"
                             + (
                             failure.getOptions().contains(ProofRequiredException.Option.RECAPTCHA)
-                                    ?
+                                    ? """
-                                    "To get the captcha token, go to https://signalcaptchas.org/challenge/generate.html\n"
+                                    To get the captcha token, go to https://signalcaptchas.org/challenge/generate.html
-                                            + "Check the developer tools (F12) console for a failed redirect to signalcaptcha://\n"
+                                    Check the developer tools (F12) console for a failed redirect to signalcaptcha://
-                                            + "Everything after signalcaptcha:// is the captcha token.\n"
+                                    Everything after signalcaptcha:// is the captcha token.
-                                            + "Use the following command to submit the captcha token:\n"
+                                    Use the following command to submit the captcha token:
-                                            + "signal-cli submitRateLimitChallenge --challenge CHALLENGE_TOKEN --captcha CAPTCHA_TOKEN"
+                                    signal-cli submitRateLimitChallenge --challenge CHALLENGE_TOKEN --captcha CAPTCHA_TOKEN"""
                                     : ""
                     ),
                     identifier,