public class org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws extends java.lang.Object implements org.apache.kafkaesqueesque.common.security.oauthbearer.OAuthBearerToken
{
private final java.lang.String compactSerialization;
private final java.util.List splits;
private final java.util.Map header;
private final java.lang.String principalClaimName;
private final java.lang.String scopeClaimName;
private final java.util.Map claims;
private final java.util.Set scope;
private final long lifetime;
private final java.lang.String principalName;
private final java.lang.Long startTimeMs;
public void <init>(java.lang.String, java.lang.String, java.lang.String) throws org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException
{
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException v, v, v, v, v;
java.lang.Long v;
java.util.Map v, v, v;
boolean v, v, v, v, v, v;
java.util.Set v;
java.util.List v, v, v, v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
long v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Number v;
java.lang.IllegalArgumentException v, v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult v, v, v, v, v;
java.lang.Object v, v, v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String compactSerialization> = v;
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("..");
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException;
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult newFailure(java.lang.String)>("Malformed compact serialization contains \'..\'");
specialinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException: void <init>(org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult)>(v);
throw v;
label:
v = specialinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.List extractCompactSerializationSplits()>();
v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.List splits> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.List splits()>();
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.Map toMap(java.lang.String)>(v);
v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.Map header> = v;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.List splits>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(1);
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.Map toMap(java.lang.String)>(v);
v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.Map claims> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.Map header()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("alg");
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object,java.lang.String)>(v, "JWS header must have an Algorithm value");
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = "none";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException;
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult newFailure(java.lang.String)>("Unsecured JWS must have \'none\' for an algorithm");
specialinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException: void <init>(org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult)>(v);
throw v;
label:
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.List splits>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(2);
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
v = new org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException;
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult newFailure(java.lang.String)>("Unsecured JWS must not contain a digital signature");
specialinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException: void <init>(org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult)>(v);
throw v;
label:
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String principalClaimName> = v;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String principalClaimName>;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Must specify a non-blank principal claim name");
throw v;
label:
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String scopeClaimName> = v;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String scopeClaimName>;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Must specify a non-blank scope claim name");
throw v;
label:
v = specialinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.Set calculateScope()>();
v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.Set scope> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Number expirationTime()>();
if v != null goto label;
v = new org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException;
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult newFailure(java.lang.String)>("No expiration time in JWT");
specialinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException: void <init>(org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult)>(v);
throw v;
label:
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: long convertClaimTimeInSecondsToMs(java.lang.Number)>(v);
v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: long lifetime> = v;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String principalClaimName>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Object claim(java.lang.String,java.lang.Class)>(v, class "Ljava/lang/String;");
if v == null goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
label:
v = new org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String principalClaimName>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("No principal name in JWT claim: \u0001");
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult newFailure(java.lang.String)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException: void <init>(org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult)>(v);
throw v;
label:
v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String principalName> = v;
v = specialinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Long calculateStartTimeMs()>();
v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Long startTimeMs> = v;
return;
}
public java.lang.String value()
{
java.lang.String v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String compactSerialization>;
return v;
}
public java.util.List splits()
{
java.util.List v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.List splits>;
return v;
}
public java.util.Map header()
{
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.Map header>;
return v;
}
public java.lang.String principalName()
{
java.lang.String v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String principalName>;
return v;
}
public java.lang.Long startTimeMs()
{
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
java.lang.Long v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Long startTimeMs>;
return v;
}
public long lifetimeMs()
{
long v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: long lifetime>;
return v;
}
public java.util.Set scope() throws org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException
{
java.util.Set v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.Set scope>;
return v;
}
public java.util.Map claims()
{
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.Map claims>;
return v;
}
public java.lang.String principalClaimName()
{
java.lang.String v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String principalClaimName>;
return v;
}
public java.lang.String scopeClaimName()
{
java.lang.String v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String scopeClaimName>;
return v;
}
public boolean isClaimType(java.lang.String, java.lang.Class)
{
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
java.lang.Class v;
java.lang.Object v;
java.lang.String v;
boolean v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Class;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Object rawClaim(java.lang.String)>(v);
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
if v != null goto label;
return 0;
label:
if v != class "Ljava/lang/String;" goto label;
v = v instanceof java.lang.String;
if v == 0 goto label;
return 1;
label:
if v != class "Ljava/lang/Number;" goto label;
v = v instanceof java.lang.Number;
if v == 0 goto label;
return 1;
label:
if v != class "Ljava/util/List;" goto label;
v = v instanceof java.util.List;
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public java.lang.Object claim(java.lang.String, java.lang.Class) throws org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException
{
java.lang.Object[] v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException v;
java.lang.ClassCastException v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
java.lang.Class v, v;
java.lang.Object v, v, v;
java.lang.String v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Class;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Object rawClaim(java.lang.String)>(v);
label:
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.Class: java.lang.Object cast(java.lang.Object)>(v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException;
v = newarray (java.lang.Object)[3];
v[0] = v;
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v[1] = v;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
v[2] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("The \'%s\' claim was not of type %s: %s", v);
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult newFailure(java.lang.String)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException: void <init>(org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult)>(v);
throw v;
catch java.lang.ClassCastException from label to label with label;
}
public java.lang.Object rawClaim(java.lang.String)
{
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
java.util.Map v;
java.lang.Object v, v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.util.Map claims()>();
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public java.lang.Number expirationTime() throws org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException
{
java.lang.Object v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Object claim(java.lang.String,java.lang.Class)>("exp", class "Ljava/lang/Number;");
return v;
}
public java.lang.Number issuedAt() throws org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException
{
java.lang.Object v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Object claim(java.lang.String,java.lang.Class)>("iat", class "Ljava/lang/Number;");
return v;
}
public java.lang.String subject() throws org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException
{
java.lang.Object v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Object claim(java.lang.String,java.lang.Class)>("sub", class "Ljava/lang/String;");
return v;
}
public static java.util.Map toMap(java.lang.String) throws org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException
{
byte[] v;
java.util.Base64$Decoder v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException v, v, v;
java.util.HashMap v;
java.util.Map v;
com.fasterxml.jackson.databind.JsonNode v;
java.lang.String v;
boolean v;
java.util.Iterator v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.io.IOException v;
java.lang.IllegalArgumentException v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult v, v, v;
java.lang.Object v, v, v, v;
v := @parameter: java.lang.String;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
label:
v = staticinvoke <java.util.Base64: java.util.Base64$Decoder getDecoder()>();
v = virtualinvoke v.<java.util.Base64$Decoder: byte[] decode(java.lang.String)>(v);
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(byte[])>(v);
if v != null goto label;
v = new org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException;
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult newFailure(java.lang.String)>("malformed JSON");
specialinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException: void <init>(org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult)>(v);
throw v;
label:
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.util.Iterator fields()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Object convert(com.fasterxml.jackson.databind.JsonNode)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException;
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult newFailure(java.lang.String)>("malformed Base URL encoded value");
specialinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException: void <init>(org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult)>(v);
throw v;
label:
v := @caughtexception;
v = new org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException;
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult newFailure(java.lang.String)>("malformed JSON");
specialinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException: void <init>(org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult)>(v);
throw v;
catch java.lang.IllegalArgumentException from label to label with label;
catch java.io.IOException from label to label with label;
}
private java.util.List extractCompactSerializationSplits()
{
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException v;
java.lang.String[] v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult v;
java.util.ArrayList v;
java.util.List v, v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
int v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = new java.util.ArrayList;
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String compactSerialization>;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>("\\.");
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
v = v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String compactSerialization>;
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>(".");
if v == 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("");
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v == 3 goto label;
v = new org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException;
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult newFailure(java.lang.String)>("Unsecured JWS compact serializations must have 3 dot-separated Base64URL-encoded values");
specialinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException: void <init>(org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerValidationResult)>(v);
throw v;
label:
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
return v;
}
private static java.lang.Object convert(com.fasterxml.jackson.databind.JsonNode)
{
java.util.Iterator v;
java.io.Serializable v;
java.util.ArrayList v;
com.fasterxml.jackson.databind.JsonNode v;
java.lang.Object v;
java.lang.String v;
boolean v, v;
com.fasterxml.jackson.databind.node.JsonNodeType v, v;
v := @parameter: com.fasterxml.jackson.databind.JsonNode;
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: boolean isArray()>();
if v == 0 goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
label:
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.node.JsonNodeType getNodeType()>();
v = <com.fasterxml.jackson.databind.node.JsonNodeType: com.fasterxml.jackson.databind.node.JsonNodeType NUMBER>;
if v != v goto label;
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.Number numberValue()>();
goto label;
label:
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String asText()>();
label:
return v;
}
private java.lang.Long calculateStartTimeMs() throws org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerIllegalTokenException
{
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
java.lang.Long v;
java.lang.Object v;
long v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Object claim(java.lang.String,java.lang.Class)>("iat", class "Ljava/lang/Number;");
if v != null goto label;
v = null;
goto label;
label:
v = staticinvoke <org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: long convertClaimTimeInSecondsToMs(java.lang.Number)>(v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
label:
return v;
}
private static long convertClaimTimeInSecondsToMs(java.lang.Number)
{
long v;
java.lang.Number v;
double v, v;
v := @parameter: java.lang.Number;
v = virtualinvoke v.<java.lang.Number: double doubleValue()>();
v = v * 1000.0;
v = staticinvoke <java.lang.Math: long round(double)>(v);
return v;
}
private java.util.Set calculateScope()
{
java.util.HashSet v, v;
java.lang.String v, v, v, v, v;
boolean v, v, v, v, v;
java.util.Iterator v;
java.util.Set v, v, v, v;
org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.String scopeClaimName()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: boolean isClaimType(java.lang.String,java.lang.Class)>(v, class "Ljava/lang/String;");
if v == 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Object claim(java.lang.String,java.lang.Class)>(v, class "Ljava/lang/String;");
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
return v;
label:
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.oauthbearer.internals.unsecured.OAuthBearerUnsecuredJws: java.lang.Object claim(java.lang.String,java.lang.Class)>(v, class "Ljava/util/List;");
if v == null goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
label:
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
return v;
label:
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
return v;
}
}