diff --git a/src/main/java/io/kamax/mxisd/auth/AccountManager.java b/src/main/java/io/kamax/mxisd/auth/AccountManager.java index 9fc6fa3..666dbe5 100644 --- a/src/main/java/io/kamax/mxisd/auth/AccountManager.java +++ b/src/main/java/io/kamax/mxisd/auth/AccountManager.java @@ -62,7 +62,7 @@ public class AccountManager { String token = UUID.randomUUID().toString(); AccountDao account = new AccountDao(openIdToken.getAccessToken(), openIdToken.getTokenType(), - openIdToken.getMatrixServerName(), openIdToken.getExpiredIn(), + openIdToken.getMatrixServerName(), openIdToken.getExpiresIn(), Instant.now().getEpochSecond(), userId, token); storage.insertToken(account); diff --git a/src/main/java/io/kamax/mxisd/auth/OpenIdToken.java b/src/main/java/io/kamax/mxisd/auth/OpenIdToken.java index b70ffbb..5063000 100644 --- a/src/main/java/io/kamax/mxisd/auth/OpenIdToken.java +++ b/src/main/java/io/kamax/mxisd/auth/OpenIdToken.java @@ -1,14 +1,20 @@ package io.kamax.mxisd.auth; +import com.google.gson.annotations.SerializedName; + public class OpenIdToken { + @SerializedName("access_token") private String accessToken; + @SerializedName("token_type") private String tokenType; + @SerializedName("matrix_server_name") private String matrixServerName; - private long expiredIn; + @SerializedName("expires_in") + private long expiresIn; public String getAccessToken() { return accessToken; @@ -34,11 +40,11 @@ public class OpenIdToken { this.matrixServerName = matrixServerName; } - public long getExpiredIn() { - return expiredIn; + public long getExpiresIn() { + return expiresIn; } - public void setExpiredIn(long expiredIn) { - this.expiredIn = expiredIn; + public void setExpiresIn(long expiresIn) { + this.expiresIn = expiresIn; } } diff --git a/src/main/java/io/kamax/mxisd/config/HashingConfig.java b/src/main/java/io/kamax/mxisd/config/HashingConfig.java index dda4ccd..a19ffee 100644 --- a/src/main/java/io/kamax/mxisd/config/HashingConfig.java +++ b/src/main/java/io/kamax/mxisd/config/HashingConfig.java @@ -11,7 +11,7 @@ public class HashingConfig { private static final Logger LOGGER = LoggerFactory.getLogger(HashingConfig.class); private boolean enabled = false; - private int pepperLength = 10; + private int pepperLength = 20; private RotationPolicyEnum rotationPolicy; private HashStorageEnum hashStorageType; private long delay = 10; diff --git a/src/main/java/io/kamax/mxisd/hash/HashEngine.java b/src/main/java/io/kamax/mxisd/hash/HashEngine.java index 5aaee1e..a8c5b68 100644 --- a/src/main/java/io/kamax/mxisd/hash/HashEngine.java +++ b/src/main/java/io/kamax/mxisd/hash/HashEngine.java @@ -56,6 +56,6 @@ public class HashEngine { } protected String newPepper() { - return RandomStringUtils.random(config.getPepperLength()); + return RandomStringUtils.random(config.getPepperLength(), true, true); } } diff --git a/src/main/java/io/kamax/mxisd/hash/rotation/RotationPerRequests.java b/src/main/java/io/kamax/mxisd/hash/rotation/RotationPerRequests.java index 653b169..b78672a 100644 --- a/src/main/java/io/kamax/mxisd/hash/rotation/RotationPerRequests.java +++ b/src/main/java/io/kamax/mxisd/hash/rotation/RotationPerRequests.java @@ -12,6 +12,7 @@ public class RotationPerRequests implements HashRotationStrategy { @Override public void register(HashEngine hashEngine) { this.hashEngine = hashEngine; + trigger(); } @Override diff --git a/src/main/java/io/kamax/mxisd/http/undertow/handler/auth/v2/AccountRegisterHandler.java b/src/main/java/io/kamax/mxisd/http/undertow/handler/auth/v2/AccountRegisterHandler.java index 25be560..f10000e 100644 --- a/src/main/java/io/kamax/mxisd/http/undertow/handler/auth/v2/AccountRegisterHandler.java +++ b/src/main/java/io/kamax/mxisd/http/undertow/handler/auth/v2/AccountRegisterHandler.java @@ -48,7 +48,7 @@ public class AccountRegisterHandler extends BasicHttpHandler { if (LOGGER.isInfoEnabled()) { LOGGER.info("Registration from domain: {}, expired at {}", openIdToken.getMatrixServerName(), - new Date(openIdToken.getExpiredIn())); + new Date(openIdToken.getExpiresIn())); } String token = accountManager.register(openIdToken); diff --git a/src/main/java/io/kamax/mxisd/http/undertow/handler/identity/v2/HashLookupHandler.java b/src/main/java/io/kamax/mxisd/http/undertow/handler/identity/v2/HashLookupHandler.java index 5cc28d0..1fd391c 100644 --- a/src/main/java/io/kamax/mxisd/http/undertow/handler/identity/v2/HashLookupHandler.java +++ b/src/main/java/io/kamax/mxisd/http/undertow/handler/identity/v2/HashLookupHandler.java @@ -67,7 +67,7 @@ public class HashLookupHandler extends LookupHandler implements ApiHandler { throw new InvalidParamException(); } - if (!hashManager.getHashEngine().getPepper().equals(input.getPepper())) { + if ("sha256".equals(input.getAlgorithm()) && !hashManager.getHashEngine().getPepper().equals(input.getPepper())) { throw new InvalidPepperException(); } @@ -93,8 +93,8 @@ public class HashLookupHandler extends LookupHandler implements ApiHandler { for (String address : input.getAddresses()) { String[] parts = address.split(" "); ThreePidMapping mapping = new ThreePidMapping(); - mapping.setMedium(parts[0]); - mapping.setValue(parts[1]); + mapping.setMedium(parts[1]); + mapping.setValue(parts[0]); mappings.add(mapping); } bulkLookupRequest.setMappings(mappings);