subscribing to authing events

pom.xml

@@ -97,6 +97,11 @@
             <version>2.3.0</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.java-websocket</groupId>
+            <artifactId>Java-WebSocket</artifactId>
+            <version>1.5.3</version>
+        </dependency>
     </dependencies>
 
     <build>
@@ -182,4 +187,4 @@
         </repository>
     </distributionManagement>
 
-</project>
+</project>

src/main/java/cn/authing/sdk/java/client/AuthenticationClient.java

@@ -4,12 +4,11 @@
 import cn.authing.sdk.java.dto.authentication.*;
 import cn.authing.sdk.java.enums.AuthMethodEnum;
 import cn.authing.sdk.java.enums.ProtocolEnum;
-import cn.authing.sdk.java.model.AuthenticationClientOptions;
-import cn.authing.sdk.java.model.AuthingRequestConfig;
-import cn.authing.sdk.java.model.ClientCredentialInput;
+import cn.authing.sdk.java.model.*;
 import cn.authing.sdk.java.util.CommonUtils;
 import cn.authing.sdk.java.util.HttpUtils;
 import cn.hutool.core.codec.Base64Encoder;
+import cn.hutool.core.lang.Assert;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.http.Header;
 import com.nimbusds.jose.JWSAlgorithm;
@@ -21,6 +20,8 @@
 import com.nimbusds.jose.jwk.RSAKey;
 
 import java.io.IOException;
+import java.net.URI;
+import java.net.URISyntaxException;
 import java.net.URL;
 import java.nio.charset.Charset;
 import java.security.MessageDigest;
@@ -2000,4 +2001,39 @@ public GetUserAuthResourceStructRespDto getUserAuthResourceStruct(
 
 // ==== AUTO GENERATED AUTHENTICATION METHODS END ====
 
+
+    @Override
+    public void subEvent(String eventCode, Receiver receiver) {
+        if (StrUtil.isBlank(eventCode)) {
+            throw new IllegalArgumentException("eventCode is required");
+        }
+        if (receiver == null) {
+            throw new IllegalArgumentException("receiver is required");
+        }
+        Assert.notNull(this.options.getAccessToken());
+        AuthenticationClientOptions options = (AuthenticationClientOptions) this.options;
+        String eventUri = options.getWebSocketHost()+options.getWebSocketEndpoint()
+                +"?code="+eventCode
+                +"&token="+this.options.getAccessToken();
+        URI wssUri = null;
+        try {
+            wssUri = new URI(eventUri);
+        } catch (URISyntaxException e) {
+            throw new RuntimeException(e);
+        }
+        HashMap<String,String> headers = new HashMap();
+        AuthingWebsocketClient client = new AuthingWebsocketClient(wssUri,headers,receiver);
+        client.connect();
+    }
+
+    public CommonResponseDto pubtEvent(String eventCode,Object data){
+        Assert.notNull(eventCode);
+        Assert.notNull(data);
+        AuthingRequestConfig config = new AuthingRequestConfig();
+        config.setUrl("/api/v3/pub-userEvent");
+        config.setBody(new EventDto(eventCode,data));
+        config.setMethod("POST");
+        String response = request(config);
+        return deserialize(response, CommonResponseDto.class);
+    }
 }

src/main/java/cn/authing/sdk/java/client/BaseClient.java

@@ -1,31 +1,34 @@
 package cn.authing.sdk.java.client;
 
+import cn.authing.sdk.java.model.Receiver;
 import cn.authing.sdk.java.model.AuthingClientOptions;
 import cn.authing.sdk.java.model.AuthingRequestConfig;
 import cn.authing.sdk.java.util.JsonUtils;
 
+
 /**
  * @author luojielin
  */
 public class BaseClient {
-    
+
     protected AuthingClientOptions options;
-    
+
     public BaseClient(AuthingClientOptions options) {
         this.options = options;
     }
-    
+
     public static <T> T deserialize(String content, Class<T> valueType) {
          return JsonUtils.deserialize(content, valueType);
     }
-    
+
     public static String serialize(Object value) {
         return JsonUtils.serialize(value);
     }
-    
+
     public String request(AuthingRequestConfig config) {
         return options.doRequest(config.getUrl(), config.getMethod(), config.getHeaders(), config.getBody());
     }
-
-
+
+    public void subEvent(String eventCode, Receiver receiver){
+    }
 }

src/main/java/cn/authing/sdk/java/client/ManagementClient.java

@@ -1,13 +1,18 @@
 package cn.authing.sdk.java.client;
 
+import cn.authing.sdk.java.model.AuthingWebsocketClient;
+import cn.authing.sdk.java.model.Receiver;
+import cn.authing.sdk.java.util.signature.Impl.SignatureComposer;
+import cn.hutool.core.lang.Assert;
 import cn.hutool.core.util.StrUtil;
 import cn.authing.sdk.java.dto.*;
 
 import cn.authing.sdk.java.model.AuthingRequestConfig;
 import cn.authing.sdk.java.model.ManagementClientOptions;
+
+import java.net.URI;
+import java.net.URISyntaxException;
 import java.util.HashMap;
-import java.util.Collections;
-import java.util.Map;
 
 
 public class ManagementClient extends BaseClient {
@@ -3310,6 +3315,17 @@ public CostGetCurrentUsageRespDto getUsageInfo() {
         return deserialize(response, CostGetCurrentUsageRespDto.class);
     }
 
+    public CostGetAllRightItemRespDto pubtEvent(String eventCode,Object data){
+        Assert.notNull(eventCode);
+        Assert.notNull(data);
+        AuthingRequestConfig config = new AuthingRequestConfig();
+        config.setUrl("/api/v3/pub-event");
+        config.setBody(new EventDto(eventCode,data));
+        config.setMethod("POST");
+        String response = request(config);
+        return deserialize(response, CostGetAllRightItemRespDto.class);
+    }
+
     /**
      * @summary 获取 MAU 使用记录
      * @description 获取当前用户池 MAU 使用记录
@@ -3651,4 +3667,34 @@ public IsSuccessRespDto updateAccessKey(UpdateAccessKeyDto reqDto) {
     }
 
 
-}
+
+    @Override
+    public void subEvent(String eventCode, Receiver receiver) {
+        if (StrUtil.isBlank(eventCode)) {
+            throw new IllegalArgumentException("eventCode is required");
+        }
+        if (receiver == null) {
+            throw new IllegalArgumentException("receiver is required");
+        }
+        ManagementClientOptions options = (ManagementClientOptions) this.options;
+        String eventUri = options.getWebsocketHost()+options.getWebsocketEndpoint()+"?code="+eventCode;
+        URI wssUri = null;
+        try {
+            wssUri = new URI(eventUri);
+        } catch (URISyntaxException e) {
+            throw new RuntimeException(e);
+        }
+        // System.out.println("eventUri:"+eventUri);
+        SignatureComposer signatureComposer = new SignatureComposer();
+        HashMap<String,String> query = new HashMap<String, String>();
+        String signa = signatureComposer.composeStringToSign("websocket","",query,query);
+        // String signa = signatureComposer.composeStringToSign("websocket",eventUri,query,query); // server 端验证不用传 uri
+        // System.out.println("signa:"+signa);
+        String authorization = signatureComposer.getAuthorization(options.getAccessKeyId(),options.getAccessKeySecret(),signa);
+        // System.out.println(authorization);
+        HashMap<String,String> headers = new HashMap();
+        headers.put("Authorization",authorization);
+        AuthingWebsocketClient client = new AuthingWebsocketClient(wssUri,headers,receiver);
+        client.connect();
+    }
+}

src/main/java/cn/authing/sdk/java/dto/CostGetAllRightItemRespDto.java

@@ -67,6 +67,14 @@ public void setData(RightItemRes data) {
         this.data = data;
     }
 
-
-
-}
+    @Override
+    public String toString() {
+        return "CostGetAllRightItemRespDto{" +
+                "statusCode=" + statusCode +
+                ", message='" + message + '\'' +
+                ", apiCode=" + apiCode +
+                ", requestId='" + requestId + '\'' +
+                ", data=" + data +
+                '}';
+    }
+}

src/main/java/cn/authing/sdk/java/dto/EventDto.java

@@ -0,0 +1,37 @@
+package cn.authing.sdk.java.dto;
+
+/**
+ * @author songxueyan
+ * @date 2023/2/23
+ **/
+public class EventDto {
+    private String eventType ;
+    private Object eventData ;
+
+    public EventDto() {
+    }
+
+    public EventDto(String eventType, Object eventData) {
+        this.eventType = eventType;
+        this.eventData = eventData;
+    }
+
+    public String getEventType() {
+        return eventType;
+    }
+
+    public void setEventType(String eventType) {
+        this.eventType = eventType;
+    }
+
+    public Object getEventData() {
+        return eventData;
+    }
+
+    public void setEventData(Object eventData) {
+        this.eventData = eventData;
+    }
+
+
+
+}

src/main/java/cn/authing/sdk/java/model/AuthingClientOptions.java

@@ -1,5 +1,7 @@
 package cn.authing.sdk.java.model;
 
+import org.java_websocket.client.WebSocketClient;
+
 import java.util.Map;
 
 /**
@@ -28,4 +30,5 @@ public abstract class AuthingClientOptions {
      * @return 响应
      */
     public abstract String doRequest(String url, String method, Map<String, String> headers, Object body);
+
 }

src/main/java/cn/authing/sdk/java/model/AuthingWebsocketClient.java

@@ -0,0 +1,42 @@
+package cn.authing.sdk.java.model;
+
+import org.java_websocket.client.WebSocketClient;
+import org.java_websocket.handshake.ServerHandshake;
+
+import java.net.URI;
+import java.util.Map;
+
+/**
+ * @author songxueyan
+ * @date 2023/2/21
+ **/
+public class AuthingWebsocketClient extends WebSocketClient {
+
+    private final Receiver receiver;
+
+    public AuthingWebsocketClient(URI serverUri, Map<String, String> httpHeaders, Receiver receiver) {
+        super(serverUri, httpHeaders);
+        this.receiver = receiver;
+    }
+
+    @Override
+    public void onOpen(ServerHandshake serverHandshake) {
+        System.out.println("onOpen");
+    }
+
+    @Override
+    public void onMessage(String s) {
+        // System.out.println("onMessage:"+s);
+        this.receiver.onReceiverMessage(s);
+    }
+
+    @Override
+    public void onClose(int i, String s, boolean b) {
+        System.out.println("onClose,i="+i+",s="+s+",b="+b);
+    }
+
+    @Override
+    public void onError(Exception e) {
+        System.out.println(e);
+    }
+}

src/main/java/cn/authing/sdk/java/model/ManagementClientOptions.java

@@ -49,6 +49,24 @@ public class ManagementClientOptions extends AuthingClientOptions {
      * Authing 服务器地址
      */
     private String host = "https://core.authing.cn";
+    private String websocketHost = "wss://openevent.authing.cn";
+    private String websocketEndpoint = "/events/v1/management/sub";
+
+    public String getWebsocketHost() {
+        return websocketHost;
+    }
+
+    public void setWebsocketHost(String websocketHost) {
+        this.websocketHost = websocketHost;
+    }
+
+    public String getWebsocketEndpoint() {
+        return websocketEndpoint;
+    }
+
+    public void setWebsocketEndpoint(String websocketEndpoint) {
+        this.websocketEndpoint = websocketEndpoint;
+    }
 
     /**
      * 请求头 key，适用于去 Authing 品牌化场景
@@ -317,4 +335,5 @@ public void setExpires_in(Long expires_in) {
         }
 
     }
+
 }

src/main/java/cn/authing/sdk/java/model/Receiver.java

@@ -0,0 +1,5 @@
+package cn.authing.sdk.java.model;
+
+public interface Receiver {
+     void onReceiverMessage(String msg);
+}

src/main/java/cn/authing/sdk/java/util/signature/Impl/SignatureComposer.java

@@ -92,6 +92,8 @@ public String getAuthorization(String accessKeyId, String accessKeySecret, Strin
 
     private String signString(String stringToSign, String accessKeySecret) {
         try {
+            // System.out.println("stringToSign:"+stringToSign);
+            // System.out.println("accessKeySecret:"+accessKeySecret);
             Mac mac = Mac.getInstance(ALGORITHM_NAME);
             mac.init(new SecretKeySpec(accessKeySecret.getBytes(ENCODING), ALGORITHM_NAME));
             byte[] signData = mac.doFinal(stringToSign.getBytes(ENCODING));

src/test/java/test/authentication/EventClientPubTest.java

@@ -0,0 +1,30 @@
+package test.authentication;
+
+import cn.authing.sdk.java.client.AuthenticationClient;
+import cn.authing.sdk.java.dto.CommonResponseDto;
+import cn.authing.sdk.java.model.AuthenticationClientOptions;
+
+import java.io.IOException;
+import java.text.ParseException;
+
+/**
+ * @author songxueyan
+ * @date 2023/2/24
+ **/
+public class EventClientPubTest {
+    // 需要替换成你的 Authing App ID
+    private static final String APP_ID = "AUTHING_APP_ID";
+    // 需要替换成你的 Authing App Secret
+    private static final String APP_SECRET = "AUTHING_APP_SECRET";
+
+    public static void main(String[] args) throws IOException, ParseException {
+        AuthenticationClientOptions authenOptions = new AuthenticationClientOptions();
+        authenOptions.setAppId(APP_ID); // Authing 应用 ID
+        authenOptions.setAppSecret(APP_SECRET); // Authing 应用密钥
+
+        AuthenticationClient authenticationClient = new AuthenticationClient(authenOptions);
+        String eventData = "{\"id\":\"q\",\"createdAt\":1675579686427,\"updatedAt\":1675579686427}";
+        CommonResponseDto result = authenticationClient.pubtEvent("yourapp.event.code", eventData);
+        System.out.println(result);
+    }
+}

src/test/java/test/authentication/EventClientSubTest.java

@@ -0,0 +1,34 @@
+package test.authentication;
+
+import cn.authing.sdk.java.client.AuthenticationClient;
+import cn.authing.sdk.java.dto.CommonResponseDto;
+import cn.authing.sdk.java.model.AuthenticationClientOptions;
+import cn.authing.sdk.java.model.Receiver;
+
+import java.io.IOException;
+import java.text.ParseException;
+
+/**
+ * @author songxueyan
+ * @date 2023/2/24
+ **/
+public class EventClientSubTest {
+    // 需要替换成你的 Authing App ID
+    private static final String APP_ID = "AUTHING_APP_ID";
+    // 需要替换成你的 Authing App Secret
+    private static final String APP_SECRET = "AUTHING_APP_SECRET";
+
+    public static void main(String[] args) throws IOException, ParseException {
+        AuthenticationClientOptions authenOptions = new AuthenticationClientOptions();
+        authenOptions.setAppId(APP_ID); // Authing 应用 ID
+        authenOptions.setAppSecret(APP_SECRET); // Authing 应用密钥
+
+        AuthenticationClient authenticationClient = new AuthenticationClient(authenOptions);
+        authenticationClient.subEvent("yourapp.event.code", new Receiver() {
+            @Override
+            public void onReceiverMessage(String msg) {
+                System.out.println(msg);
+            }
+        });
+    }
+}

src/test/java/test/management/EventPubTest.java

@@ -0,0 +1,29 @@
+package test.management;
+
+import cn.authing.sdk.java.client.ManagementClient;
+import cn.authing.sdk.java.dto.CostGetAllRightItemRespDto;
+import cn.authing.sdk.java.model.ManagementClientOptions;
+
+/**
+ * @author songxueyan
+ * @date 2023/2/23
+ **/
+public class EventPubTest {
+    // 需要替换成你的 Authing Access Key ID
+    private static final String ACCESS_KEY_ID = "AUTHING_ACCESS_KEY_ID";
+    // 需要替换成你的 Authing Access Key Secret
+    private static final String ACCESS_KEY_SECRET = "AUTHING_ACCESS_KEY_SECRET";
+
+    public static void main(String[] args) {
+
+        ManagementClientOptions clientOptions = new ManagementClientOptions();
+        clientOptions.setAccessKeyId(ACCESS_KEY_ID);
+        clientOptions.setAccessKeySecret(ACCESS_KEY_SECRET);
+        ManagementClient client = new ManagementClient(clientOptions);
+
+        String eventData = "{\"id\":\"q\",\"createdAt\":1675579686427,\"updatedAt\":1675579686427}";
+        CostGetAllRightItemRespDto result = client.pubtEvent("yourapp.event.code", eventData);
+        System.out.println(result);
+
+    }
+}

src/test/java/test/management/EventSubTest.java

@@ -0,0 +1,31 @@
+package test.management;
+
+import cn.authing.sdk.java.client.ManagementClient;
+import cn.authing.sdk.java.model.ManagementClientOptions;
+import cn.authing.sdk.java.model.Receiver;
+
+/**
+ * @author songxueyan
+ * @date 2023/2/21
+ **/
+public class EventSubTest {
+    // 需要替换成你的 Authing Access Key ID
+    private static final String ACCESS_KEY_ID = "AUTHING_ACCESS_KEY_ID";
+    // 需要替换成你的 Authing Access Key Secret
+    private static final String ACCESS_KEY_SECRET = "AUTHING_ACCESS_KEY_SECRET";
+
+    public static void main(String[] args) {
+        ManagementClientOptions clientOptions = new ManagementClientOptions();
+        clientOptions.setAccessKeyId(ACCESS_KEY_ID);
+        clientOptions.setAccessKeySecret(ACCESS_KEY_SECRET);
+        clientOptions.setWebsocketHost("ws://192.168.0.145:8866");
+
+        ManagementClient client = new ManagementClient(clientOptions);
+        client.subEvent("authing.user.login", new Receiver() {
+            @Override
+            public void onReceiverMessage(String msg) {
+                System.out.println(msg);
+            }
+        });
+    }
+}