Fix jwt module upgrade issue (#1744)

Author: gaoran10

amqp-client-auth/src/main/java/io/streamnative/rabbitmq/authentication/TokenCredentialsProvider.java

@@ -29,6 +29,8 @@
  */
 @Slf4j
 public class TokenCredentialsProvider implements CredentialsProvider {
+
+    private static final String JOSE_HEADER_UNSECURED_ENCODED = "eyJhbGciOiJub25lIn0";
     private final Supplier<String> tokenSupplier;
     private String token;
     private Jwt<Header, Claims> jwt;
@@ -40,12 +42,20 @@ public TokenCredentialsProvider(Supplier<String> tokenSupplier) {
 
     private void load(Supplier<String> tokenSupplier) {
         String token = tokenSupplier.get();
-        int i = token.lastIndexOf('.');
-        String withoutSignature = token.substring(0, i + 1);
-        this.jwt = Jwts.parserBuilder().build().parseClaimsJwt(withoutSignature);
+        this.jwt = Jwts.parser().unsecured().build().parseClaimsJwt(transformToUnsecuredJwt(token));
         this.token = token;
     }
 
+    public static String transformToUnsecuredJwt(String token) {
+        String[] parts = token.split("\\.");
+        if (parts.length != 3) {
+            throw new IllegalArgumentException("Invalid JWT token");
+        }
+        StringBuilder sb = new StringBuilder(128);
+        sb.append(JOSE_HEADER_UNSECURED_ENCODED).append('.').append(parts[1]).append('.');
+        return sb.toString();
+    }
+
     @Override
     public String getUsername() {
         return null;

pom.xml

@@ -44,6 +44,7 @@
     <qpid-protocol-plugin.version>8.0.0</qpid-protocol-plugin.version>
     <rabbitmq.version>5.8.0</rabbitmq.version>
     <sn.bom.version>4.2.0-SNAPSHOT</sn.bom.version>
+    <opentelemetry.version>1.56.0</opentelemetry.version>
 
     <!-- test dependencies -->
     <qpid-client-version>6.4.0</qpid-client-version>
@@ -146,6 +147,12 @@
         <version>${qpid-protocol-plugin.version}</version>
       </dependency>
 
+      <dependency>
+        <groupId>io.opentelemetry</groupId>
+        <artifactId>opentelemetry-sdk-extension-autoconfigure-spi</artifactId>
+        <version>${opentelemetry.version}</version>
+      </dependency>
+
     </dependencies>
   </dependencyManagement>
 

tests/pom.xml

@@ -66,6 +66,10 @@
       <scope>test</scope>
     </dependency>
 
+    <dependency>
+      <groupId>io.opentelemetry</groupId>
+      <artifactId>opentelemetry-sdk-extension-autoconfigure-spi</artifactId>
+    </dependency>
   </dependencies>
 
   <build>