yuanbiao
/
jetlinks-official-protocol
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

优化认证

This commit is contained in:
zhou-hao 2020-11-23 10:57:36 +08:00
parent bbf512f4b6
commit 2df6e16ca9
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/java/org/jetlinks/protocol/official/JetLinksAuthenticator.java
View File

@ -3,10 +3,7 @@ package org.jetlinks.protocol.official;
import org.apache.commons.codec.digest.DigestUtils; import org.apache.commons.codec.digest.DigestUtils;
import org.jetlinks.core.Value; import org.jetlinks.core.Value;
import org.jetlinks.core.defaults.Authenticator; import org.jetlinks.core.defaults.Authenticator;
import org.jetlinks.core.device.AuthenticationRequest; import org.jetlinks.core.device.*;
import org.jetlinks.core.device.AuthenticationResponse;
import org.jetlinks.core.device.DeviceOperator;
import org.jetlinks.core.device.MqttAuthenticationRequest;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
import javax.annotation.Nonnull; import javax.annotation.Nonnull;
@ -14,6 +11,15 @@ import java.util.concurrent.TimeUnit;
public class JetLinksAuthenticator implements Authenticator { public class JetLinksAuthenticator implements Authenticator {
@Override
public Mono<AuthenticationResponse> authenticate(@Nonnull AuthenticationRequest request, @Nonnull DeviceRegistry registry) {
MqttAuthenticationRequest mqtt = ((MqttAuthenticationRequest) request);
return registry
.getDevice(mqtt.getClientId())
.flatMap(device -> authenticate(request, device));
}
@Override @Override
public Mono<AuthenticationResponse> authenticate(@Nonnull AuthenticationRequest request, @Nonnull DeviceOperator deviceOperation) { public Mono<AuthenticationResponse> authenticate(@Nonnull AuthenticationRequest request, @Nonnull DeviceOperator deviceOperation) {
if (request instanceof MqttAuthenticationRequest) { if (request instanceof MqttAuthenticationRequest) {