public class org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService extends java.lang.Object implements org.apache.nifi.web.security.jwt.key.service.VerificationKeyService
{
private static final org.slf4j.Logger LOGGER;
private static final com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER;
private static final org.apache.nifi.components.state.Scope SCOPE;
private final org.apache.nifi.components.state.StateManager stateManager;
public void <init>(org.apache.nifi.components.state.StateManager)
{
org.apache.nifi.components.state.StateManager v;
org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService v;
v := @this: org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService;
v := @parameter: org.apache.nifi.components.state.StateManager;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.apache.nifi.components.state.StateManager stateManager> = v;
return;
}
public java.util.Optional findById(java.lang.String)
{
java.util.Optional v, v, v;
java.lang.String v;
java.util.function.Function v, v;
org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService v;
v := @this: org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: java.util.Optional findSerializedKey(java.lang.String)>(v);
v = staticinvoke <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService$getVerificationKey__13: java.util.function.Function bootstrap$(org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService)>(v);
v = virtualinvoke v.<java.util.Optional: java.util.Optional map(java.util.function.Function)>(v);
v = staticinvoke <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService$getKey__14: java.util.function.Function bootstrap$(org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService)>(v);
v = virtualinvoke v.<java.util.Optional: java.util.Optional map(java.util.function.Function)>(v);
return v;
}
public synchronized void deleteExpired()
{
java.lang.Integer v, v;
java.util.function.Function v, v, v;
org.apache.nifi.components.state.Scope v;
java.util.Map v;
int v, v;
java.util.stream.Collector v;
boolean v;
org.slf4j.Logger v, v;
java.util.function.Predicate v;
org.apache.nifi.components.state.StateManager v;
java.util.Collection v;
java.io.IOException v;
java.time.Instant v;
org.apache.nifi.components.state.StateMap v;
org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService v;
java.io.UncheckedIOException v;
java.util.stream.Stream v, v, v;
java.lang.Object v;
v := @this: org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService;
v = specialinvoke v.<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.apache.nifi.components.state.StateMap getStateMap()>();
v = interfaceinvoke v.<org.apache.nifi.components.state.StateMap: java.util.Map toMap()>();
v = staticinvoke <java.time.Instant: java.time.Instant now()>();
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService$getVerificationKey__15: java.util.function.Function bootstrap$(org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService$lambda_deleteExpired_0__16: java.util.function.Predicate bootstrap$(java.time.Instant)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService$getId__17: java.util.function.Function bootstrap$()>();
v = staticinvoke <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService$serializeVerificationKey__18: java.util.function.Function bootstrap$(org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toMap(java.util.function.Function,java.util.function.Function)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = interfaceinvoke v.<java.util.Map: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Expired Verification Keys not found");
goto label;
label:
v = v.<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.apache.nifi.components.state.StateManager stateManager>;
v = <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.apache.nifi.components.state.Scope SCOPE>;
interfaceinvoke v.<org.apache.nifi.components.state.StateManager: void setState(java.util.Map,org.apache.nifi.components.state.Scope)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.UncheckedIOException;
specialinvoke v.<java.io.UncheckedIOException: void <init>(java.lang.String,java.io.IOException)>("Delete Expired Verification Keys Failed", v);
throw v;
label:
v = <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.slf4j.Logger LOGGER>;
v = interfaceinvoke v.<java.util.Map: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Delete Expired Verification Keys Completed: Keys Before [{}] Keys After [{}]", v, v);
label:
return;
catch java.io.IOException from label to label with label;
}
public void save(java.lang.String, java.security.Key, java.time.Instant)
{
java.security.Key v;
byte[] v;
org.apache.nifi.web.security.jwt.key.service.VerificationKey v;
java.lang.String v, v;
java.time.Instant v;
org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService v;
v := @this: org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService;
v := @parameter: java.lang.String;
v := @parameter: java.security.Key;
v := @parameter: java.time.Instant;
v = new org.apache.nifi.web.security.jwt.key.service.VerificationKey;
specialinvoke v.<org.apache.nifi.web.security.jwt.key.service.VerificationKey: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.security.jwt.key.service.VerificationKey: void setId(java.lang.String)>(v);
v = interfaceinvoke v.<java.security.Key: byte[] getEncoded()>();
virtualinvoke v.<org.apache.nifi.web.security.jwt.key.service.VerificationKey: void setEncoded(byte[])>(v);
v = interfaceinvoke v.<java.security.Key: java.lang.String getAlgorithm()>();
virtualinvoke v.<org.apache.nifi.web.security.jwt.key.service.VerificationKey: void setAlgorithm(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.web.security.jwt.key.service.VerificationKey: void setExpiration(java.time.Instant)>(v);
specialinvoke v.<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: void setVerificationKey(org.apache.nifi.web.security.jwt.key.service.VerificationKey)>(v);
return;
}
public void setExpiration(java.lang.String, java.time.Instant)
{
org.apache.nifi.web.security.jwt.key.service.VerificationKey v;
java.util.Optional v;
java.lang.Object v;
java.lang.String v;
java.time.Instant v;
org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService v;
boolean v;
v := @this: org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService;
v := @parameter: java.lang.String;
v := @parameter: java.time.Instant;
v = specialinvoke v.<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: java.util.Optional findSerializedKey(java.lang.String)>(v);
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = specialinvoke v.<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.apache.nifi.web.security.jwt.key.service.VerificationKey getVerificationKey(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.web.security.jwt.key.service.VerificationKey: void setExpiration(java.time.Instant)>(v);
specialinvoke v.<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: void setVerificationKey(org.apache.nifi.web.security.jwt.key.service.VerificationKey)>(v);
label:
return;
}
private synchronized void setVerificationKey(org.apache.nifi.web.security.jwt.key.service.VerificationKey)
{
org.slf4j.Logger v;
org.apache.nifi.web.security.jwt.key.service.VerificationKey v;
org.apache.nifi.components.state.StateManager v;
java.io.IOException v;
java.util.HashMap v;
java.time.Instant v;
org.apache.nifi.components.state.StateMap v;
org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService v;
java.io.UncheckedIOException v;
org.apache.nifi.components.state.Scope v;
java.util.Map v;
java.lang.String v, v, v;
v := @this: org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService;
v := @parameter: org.apache.nifi.web.security.jwt.key.service.VerificationKey;
label:
v = specialinvoke v.<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: java.lang.String serializeVerificationKey(org.apache.nifi.web.security.jwt.key.service.VerificationKey)>(v);
v = new java.util.HashMap;
v = specialinvoke v.<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.apache.nifi.components.state.StateMap getStateMap()>();
v = interfaceinvoke v.<org.apache.nifi.components.state.StateMap: java.util.Map toMap()>();
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = virtualinvoke v.<org.apache.nifi.web.security.jwt.key.service.VerificationKey: java.lang.String getId()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.apache.nifi.components.state.StateManager stateManager>;
v = <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.apache.nifi.components.state.Scope SCOPE>;
interfaceinvoke v.<org.apache.nifi.components.state.StateManager: void setState(java.util.Map,org.apache.nifi.components.state.Scope)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.io.UncheckedIOException;
specialinvoke v.<java.io.UncheckedIOException: void <init>(java.lang.String,java.io.IOException)>("Set Verification Key State Failed", v);
throw v;
label:
v = <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.slf4j.Logger LOGGER>;
v = virtualinvoke v.<org.apache.nifi.web.security.jwt.key.service.VerificationKey: java.lang.String getId()>();
v = virtualinvoke v.<org.apache.nifi.web.security.jwt.key.service.VerificationKey: java.time.Instant getExpiration()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Stored Verification Key [{}] Expiration [{}]", v, v);
return;
catch java.io.IOException from label to label with label;
}
private java.util.Optional findSerializedKey(java.lang.String)
{
java.util.Optional v;
java.lang.String v, v;
org.apache.nifi.components.state.StateMap v;
org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService v;
v := @this: org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.apache.nifi.components.state.StateMap getStateMap()>();
v = interfaceinvoke v.<org.apache.nifi.components.state.StateMap: java.lang.String get(java.lang.String)>(v);
v = staticinvoke <java.util.Optional: java.util.Optional ofNullable(java.lang.Object)>(v);
return v;
}
public java.lang.String serializeVerificationKey(org.apache.nifi.web.security.jwt.key.service.VerificationKey)
{
java.io.UncheckedIOException v;
java.lang.Throwable v;
org.apache.nifi.web.security.jwt.key.service.VerificationKey v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.lang.String v;
org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService v;
v := @this: org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService;
v := @parameter: org.apache.nifi.web.security.jwt.key.service.VerificationKey;
label:
v = <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.String writeValueAsString(java.lang.Object)>(v);
label:
return v;
label:
v := @caughtexception;
v = new java.io.UncheckedIOException;
specialinvoke v.<java.io.UncheckedIOException: void <init>(java.lang.String,java.io.IOException)>("Serialize Verification Key Failed", v);
throw v;
catch com.fasterxml.jackson.core.JsonProcessingException from label to label with label;
}
public org.apache.nifi.web.security.jwt.key.service.VerificationKey getVerificationKey(java.lang.String)
{
java.io.UncheckedIOException v;
java.lang.Throwable v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.lang.Object v;
java.lang.String v;
org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService v;
v := @this: org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService;
v := @parameter: java.lang.String;
label:
v = <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,java.lang.Class)>(v, class "Lorg/apache/nifi/web/security/jwt/key/service/VerificationKey;");
label:
return v;
label:
v := @caughtexception;
v = new java.io.UncheckedIOException;
specialinvoke v.<java.io.UncheckedIOException: void <init>(java.lang.String,java.io.IOException)>("Read Verification Key Failed", v);
throw v;
catch com.fasterxml.jackson.core.JsonProcessingException from label to label with label;
}
public java.security.Key getKey(org.apache.nifi.web.security.jwt.key.service.VerificationKey)
{
byte[] v;
java.lang.IllegalStateException v;
java.lang.Object[] v;
org.apache.nifi.web.security.jwt.key.service.VerificationKey v;
java.security.PublicKey v;
java.security.spec.X509EncodedKeySpec v;
org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService v;
java.security.KeyFactory v;
java.security.GeneralSecurityException v;
java.lang.String v, v, v;
v := @this: org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService;
v := @parameter: org.apache.nifi.web.security.jwt.key.service.VerificationKey;
v = new java.security.spec.X509EncodedKeySpec;
v = virtualinvoke v.<org.apache.nifi.web.security.jwt.key.service.VerificationKey: byte[] getEncoded()>();
specialinvoke v.<java.security.spec.X509EncodedKeySpec: void <init>(byte[])>(v);
v = virtualinvoke v.<org.apache.nifi.web.security.jwt.key.service.VerificationKey: java.lang.String getAlgorithm()>();
label:
v = staticinvoke <java.security.KeyFactory: java.security.KeyFactory getInstance(java.lang.String)>(v);
v = virtualinvoke v.<java.security.KeyFactory: java.security.PublicKey generatePublic(java.security.spec.KeySpec)>(v);
label:
return v;
label:
v := @caughtexception;
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<org.apache.nifi.web.security.jwt.key.service.VerificationKey: java.lang.String getId()>();
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Parsing Encoded Key [%s] Algorithm [%s] Failed", v);
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.security.spec.InvalidKeySpecException from label to label with label;
catch java.security.NoSuchAlgorithmException from label to label with label;
}
private org.apache.nifi.components.state.StateMap getStateMap()
{
java.io.UncheckedIOException v;
org.apache.nifi.components.state.Scope v;
org.apache.nifi.components.state.StateManager v;
java.io.IOException v;
org.apache.nifi.components.state.StateMap v;
org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService v;
v := @this: org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService;
label:
v = v.<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.apache.nifi.components.state.StateManager stateManager>;
v = <org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.apache.nifi.components.state.Scope SCOPE>;
v = interfaceinvoke v.<org.apache.nifi.components.state.StateManager: org.apache.nifi.components.state.StateMap getState(org.apache.nifi.components.state.Scope)>(v);
label:
return v;
label:
v := @caughtexception;
v = new java.io.UncheckedIOException;
specialinvoke v.<java.io.UncheckedIOException: void <init>(java.lang.String,java.io.IOException)>("Get State Failed", v);
throw v;
catch java.io.IOException from label to label with label;
}
static void <clinit>()
{
org.slf4j.Logger v;
org.apache.nifi.components.state.Scope v;
com.fasterxml.jackson.datatype.jsr.JavaTimeModule v;
com.fasterxml.jackson.databind.ObjectMapper v, v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/nifi/web/security/jwt/key/service/StandardVerificationKeyService;");
<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.slf4j.Logger LOGGER> = v;
v = new com.fasterxml.jackson.databind.ObjectMapper;
specialinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: void <init>()>();
v = new com.fasterxml.jackson.datatype.jsr.JavaTimeModule;
specialinvoke v.<com.fasterxml.jackson.datatype.jsr.JavaTimeModule: void <init>()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.ObjectMapper registerModule(com.fasterxml.jackson.databind.Module)>(v);
<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER> = v;
v = <org.apache.nifi.components.state.Scope: org.apache.nifi.components.state.Scope LOCAL>;
<org.apache.nifi.web.security.jwt.key.service.StandardVerificationKeyService: org.apache.nifi.components.state.Scope SCOPE> = v;
return;
}
}