Refactor DBus Connection Initialization (#9)

Refactor DBus Connection Initialization
Fixes #6

Co-authored-by: Sebastian Stenzel <[email protected]>

Author: purejava

pom.xml

@@ -40,7 +40,7 @@
 		<!-- runtime dependencies -->
 		<api.version>1.0.0-beta2</api.version>
 		<secret-service.version>1.6.2</secret-service.version>
-		<kdewallet.version>1.1.1</kdewallet.version>
+		<kdewallet.version>1.2.1</kdewallet.version>
 		<guava.version>30.0-jre</guava.version>
 		<slf4j.version>1.7.30</slf4j.version>
 		<junit.version>5.7.0</junit.version>

src/main/java/org/cryptomator/linux/keychain/KDEWalletKeychainAccess.java

@@ -4,6 +4,7 @@
 import org.cryptomator.integrations.keychain.KeychainAccessException;
 import org.cryptomator.integrations.keychain.KeychainAccessProvider;
 import org.freedesktop.dbus.connections.impl.DBusConnection;
+import org.freedesktop.dbus.exceptions.DBusConnectionException;
 import org.freedesktop.dbus.exceptions.DBusException;
 import org.kde.KWallet;
 import org.kde.Static;
@@ -22,24 +23,7 @@ public class KDEWalletKeychainAccess implements KeychainAccessProvider {
 	private final Optional<ConnectedWallet> wallet;
 
 	public KDEWalletKeychainAccess() {
-		ConnectedWallet wallet = null;
-		try {
-			DBusConnection conn = null;
-			try {
-				conn = DBusConnection.getConnection(DBusConnection.DBusBusType.SESSION);
-			} catch (RuntimeException e) {
-				if (e.getMessage() == "Cannot Resolve Session Bus Address") {
-					LOG.warn("SESSION DBus not found.");
-				}
-			}
-			if (conn == null) {
-				conn = DBusConnection.getConnection(DBusConnection.DBusBusType.SYSTEM);
-			}
-			wallet = new ConnectedWallet(conn);
-		} catch (DBusException e) {
-			LOG.warn("Connecting to D-Bus failed.", e);
-		}
-		this.wallet = Optional.ofNullable(wallet);
+		this.wallet = ConnectedWallet.connect();
 	}
 
 	@Override
@@ -85,6 +69,28 @@ public ConnectedWallet(DBusConnection connection) {
 			this.wallet = new KDEWallet(connection);
 		}
 
+		static Optional<ConnectedWallet> connect() {
+			try {
+				return Optional.of(new ConnectedWallet(getConnection()));
+			} catch (DBusException e) {
+				LOG.warn("Connecting to D-Bus failed.", e);
+				return Optional.empty();
+			}
+		}
+
+		private static DBusConnection getConnection() throws DBusException {
+			try {
+				return DBusConnection.getConnection(DBusConnection.DBusBusType.SESSION);
+			} catch (DBusConnectionException ce) {
+				LOG.warn("SESSION DBus not found, falling back to SYSTEM DBus");
+				try {
+					return DBusConnection.getConnection(DBusConnection.DBusBusType.SYSTEM);
+				} catch (DBusException e) {
+					throw e;
+				}
+			}
+		}
+
 		public boolean isSupported() {
 			return wallet.isEnabled();
 		}