public class org.finos.legend.engine.application.query.api.QueryStoreManager extends java.lang.Object { private static final java.util.regex.Pattern VALID_ARTIFACT_ID_PATTERN; private static final int MAX_NUMBER_OF_QUERIES; private static final int MAX_NUMBER_OF_EVENTS; private final com.fasterxml.jackson.databind.ObjectMapper objectMapper; private static final org.bson.Document EMPTY_FILTER; private static final java.lang.String QUERY_PROFILE_PATH; private static final java.lang.String QUERY_PROFILE_TAG_DATA_SPACE; private static final java.util.List LIGHT_QUERY_PROJECTION; private static final int GET_QUERIES_LIMIT; private final com.mongodb.client.MongoClient mongoClient; public void (com.mongodb.client.MongoClient) { com.fasterxml.jackson.databind.ObjectMapper v; org.finos.legend.engine.application.query.api.QueryStoreManager v; com.mongodb.client.MongoClient v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v := @parameter: com.mongodb.client.MongoClient; specialinvoke v.()>(); v = new com.fasterxml.jackson.databind.ObjectMapper; specialinvoke v.()>(); v. = v; v. = v; return; } private com.mongodb.client.MongoDatabase getQueryDatabase() { com.mongodb.client.MongoClient v; com.mongodb.client.MongoDatabase v; java.lang.RuntimeException v; org.finos.legend.engine.shared.core.vault.Vault v, v; org.finos.legend.engine.application.query.api.QueryStoreManager v; java.lang.String v; boolean v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v = ; v = virtualinvoke v.("query.mongo.database"); if v == 0 goto label; v = v.; v = ; v = virtualinvoke v.("query.mongo.database"); v = interfaceinvoke v.(v); return v; label: v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("Query MongoDB database has not been configured properly"); throw v; } private com.mongodb.client.MongoCollection getQueryCollection() { com.mongodb.client.MongoCollection v; com.mongodb.client.MongoDatabase v; java.lang.RuntimeException v; org.finos.legend.engine.shared.core.vault.Vault v, v; org.finos.legend.engine.application.query.api.QueryStoreManager v; java.lang.String v; boolean v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v = ; v = virtualinvoke v.("query.mongo.collection.query"); if v == 0 goto label; v = specialinvoke v.(); v = ; v = virtualinvoke v.("query.mongo.collection.query"); v = interfaceinvoke v.(v); return v; label: v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("Query MongoDB collection has not been configured properly"); throw v; } private com.mongodb.client.MongoCollection getQueryEventCollection() { com.mongodb.client.MongoCollection v; com.mongodb.client.MongoDatabase v; java.lang.RuntimeException v; org.finos.legend.engine.shared.core.vault.Vault v, v; org.finos.legend.engine.application.query.api.QueryStoreManager v; java.lang.String v; boolean v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v = ; v = virtualinvoke v.("query.mongo.collection.queryEvent"); if v == 0 goto label; v = specialinvoke v.(); v = ; v = virtualinvoke v.("query.mongo.collection.queryEvent"); v = interfaceinvoke v.(v); return v; label: v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("Query event MongoDB collection has not been configured properly"); throw v; } private java.lang.Object documentToClass(org.bson.Document, java.lang.Class) { org.bson.Document v; com.fasterxml.jackson.databind.ObjectMapper v; java.lang.Exception v; org.finos.legend.engine.application.query.api.ApplicationQueryException v; javax.ws.rs.core.Response$Status v; java.lang.Class v; java.lang.Object v; org.finos.legend.engine.application.query.api.QueryStoreManager v; java.lang.String v, v, v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v := @parameter: org.bson.Document; v := @parameter: java.lang.Class; label: v = v.; v = virtualinvoke v.(v, v); label: return v; label: v := @caughtexception; v = new org.finos.legend.engine.application.query.api.ApplicationQueryException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Unable to deserialize document to class \'\u0001\':\u0001"); v = ; specialinvoke v.(java.lang.String,javax.ws.rs.core.Response$Status)>(v, v); throw v; catch java.lang.Exception from label to label with label; } public org.finos.legend.engine.application.query.model.Query documentToQuery(org.bson.Document) { org.bson.Document v; java.lang.Object v; org.finos.legend.engine.application.query.api.QueryStoreManager v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v := @parameter: org.bson.Document; v = specialinvoke v.(v, class "Lorg/finos/legend/engine/application/query/model/Query;"); return v; } private org.bson.Document queryToDocument(org.finos.legend.engine.application.query.model.Query) throws com.fasterxml.jackson.core.JsonProcessingException { org.bson.Document v; org.finos.legend.engine.application.query.model.Query v; com.fasterxml.jackson.databind.ObjectMapper v; org.finos.legend.engine.application.query.api.QueryStoreManager v; java.lang.String v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v := @parameter: org.finos.legend.engine.application.query.model.Query; v = v.; v = virtualinvoke v.(v); v = staticinvoke (v); return v; } private static org.finos.legend.engine.application.query.model.QueryEvent createEvent(java.lang.String, org.finos.legend.engine.application.query.model.QueryEvent$QueryEventType) { org.finos.legend.engine.application.query.model.QueryEvent v; org.finos.legend.engine.application.query.model.QueryEvent$QueryEventType v; java.lang.Long v; long v; java.lang.String v; java.time.Instant v; v := @parameter: java.lang.String; v := @parameter: org.finos.legend.engine.application.query.model.QueryEvent$QueryEventType; v = new org.finos.legend.engine.application.query.model.QueryEvent; specialinvoke v.()>(); v. = v; v = staticinvoke (); v = virtualinvoke v.(); v = staticinvoke (v); v. = v; v. = v; return v; } public static org.finos.legend.engine.application.query.model.QueryEvent documentToQueryEvent(org.bson.Document) { org.bson.Document v; java.lang.ClassCastException v; java.lang.Integer v; org.finos.legend.engine.application.query.model.QueryEvent v; org.finos.legend.engine.application.query.model.QueryEvent$QueryEventType v; java.lang.Long v, v; int v; java.lang.String v, v; v := @parameter: org.bson.Document; v = new org.finos.legend.engine.application.query.model.QueryEvent; specialinvoke v.()>(); v = virtualinvoke v.("queryId"); v. = v; label: v = virtualinvoke v.("timestamp"); v. = v; label: goto label; label: v := @caughtexception; v = virtualinvoke v.("timestamp"); v = virtualinvoke v.(); v = staticinvoke (v); v. = v; label: v = virtualinvoke v.("eventType"); v = staticinvoke (v); v. = v; return v; catch java.lang.ClassCastException from label to label with label; } private org.bson.Document queryEventToDocument(org.finos.legend.engine.application.query.model.QueryEvent) throws com.fasterxml.jackson.core.JsonProcessingException { org.bson.Document v; org.finos.legend.engine.application.query.model.QueryEvent v; com.fasterxml.jackson.databind.ObjectMapper v; org.finos.legend.engine.application.query.api.QueryStoreManager v; java.lang.String v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v := @parameter: org.finos.legend.engine.application.query.model.QueryEvent; v = v.; v = virtualinvoke v.(v); v = staticinvoke (v); return v; } private static void validate(boolean, java.lang.String) { org.finos.legend.engine.application.query.api.ApplicationQueryException v; javax.ws.rs.core.Response$Status v; java.lang.String v; boolean v; v := @parameter: boolean; v := @parameter: java.lang.String; if v != 0 goto label; v = new org.finos.legend.engine.application.query.api.ApplicationQueryException; v = ; specialinvoke v.(java.lang.String,javax.ws.rs.core.Response$Status)>(v, v); throw v; label: return; } private static void validateNonEmptyQueryField(java.lang.String, java.lang.String) { java.lang.String v, v; boolean v, v; v := @parameter: java.lang.String; v := @parameter: java.lang.String; if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v, v); return; } public static void validateQuery(org.finos.legend.engine.application.query.model.Query) { java.util.regex.Matcher v; org.finos.legend.engine.application.query.model.QueryExecutionContext v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v; org.finos.legend.engine.application.query.model.Query v; java.util.regex.Pattern v; v := @parameter: org.finos.legend.engine.application.query.model.Query; v = v.; staticinvoke (v, "Query ID is missing or empty"); v = v.; staticinvoke (v, "Query name is missing or empty"); v = v.; staticinvoke (v, "Query project group ID is missing or empty"); v = v.; staticinvoke (v, "Query project artifact ID is missing or empty"); v = v.; staticinvoke (v, "Query project version is missing or empty"); v = v.; v = v instanceof org.finos.legend.engine.application.query.model.QueryExplicitExecutionContext; if v == 0 goto label; v = v.; v = v.; staticinvoke (v, "Query mapping is missing or empty"); v = v.; staticinvoke (v, "Query runtime is missing or empty"); goto label; label: v = v.; v = v instanceof org.finos.legend.engine.application.query.model.QueryDataSpaceExecutionContext; if v == 0 goto label; v = v.; v = v.; staticinvoke (v, "Query data Space execution context dataSpace path is missing or empty"); goto label; label: v = v.; staticinvoke (v, "Query mapping is missing or empty"); v = v.; staticinvoke (v, "Query runtime is missing or empty"); label: v = v.; staticinvoke (v, "Query content is missing or empty"); v = v.; v = staticinvoke (v); staticinvoke (v, "Query project group ID is invalid"); v = ; v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); staticinvoke (v, "Query project artifact ID is invalid"); return; } public java.util.List searchQueries(org.finos.legend.engine.application.query.model.QuerySearchSpecification, java.lang.String) { org.bson.Document v; java.lang.Integer v, v; javax.ws.rs.core.Response$Status v; java.util.stream.Collector v; com.mongodb.client.AggregateIterable v; java.util.stream.Stream v, v, v; org.finos.legend.engine.application.query.api.QueryStoreManager v; com.mongodb.client.MongoCollection v; org.eclipse.collections.api.block.function.Function v, v, v; java.util.ArrayList v, v, v; org.bson.conversions.Bson v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; com.mongodb.client.model.Field v; java.lang.String v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.application.query.model.QuerySearchTermSpecification v, v; org.finos.legend.engine.application.query.model.QuerySearchSortBy v, v; org.finos.legend.engine.application.query.model.QuerySearchSpecification v; org.eclipse.collections.api.list.MutableList v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v; java.util.function.Predicate v; java.util.List v, v, v, v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.application.query.api.ApplicationQueryException v; java.lang.String[] v, v, v, v; java.util.function.Function v; com.mongodb.client.MongoCursor v; int v, v; java.lang.Boolean v, v, v, v, v, v, v, v, v, v; org.finos.legend.engine.application.query.model.Query v; org.bson.conversions.Bson[] v, v, v, v, v; com.mongodb.client.model.Field[] v; java.lang.Object v, v, v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v := @parameter: org.finos.legend.engine.application.query.model.QuerySearchSpecification; v := @parameter: java.lang.String; v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; if v == null goto label; v = v.; v = v.; if v != null goto label; v = new org.finos.legend.engine.application.query.api.ApplicationQueryException; v = ; specialinvoke v.(java.lang.String,javax.ws.rs.core.Response$Status)>("Query search spec expecting a search term", v); throw v; label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = staticinvoke ("name", v); v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = newarray (org.bson.conversions.Bson)[2]; v[0] = v; v = v.; v = staticinvoke ("owner", v); v[1] = v; v = staticinvoke (v); label: interfaceinvoke v.(v); goto label; label: v = v.; v = staticinvoke ("id", v); v = v.; v = staticinvoke (v); v = staticinvoke ("name", v, "i"); v = newarray (org.bson.conversions.Bson)[2]; v[0] = v; v[1] = v; v = staticinvoke (v); v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = newarray (org.bson.conversions.Bson)[3]; v[0] = v; v[1] = v; v = v.; v = staticinvoke (v); v = staticinvoke ("owner", v, "i"); v[2] = v; v = staticinvoke (v); label: interfaceinvoke v.(v); label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = newarray (java.lang.String)[2]; v[0] = v; v[1] = null; v = staticinvoke ("owner", v); interfaceinvoke v.(v); label: v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = staticinvoke (); v = staticinvoke (v, v); v = staticinvoke (v); interfaceinvoke v.(v); label: v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = staticinvoke (); v = staticinvoke (v, v); v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (v); goto label; label: v = staticinvoke (v); label: v = v; v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); goto label; label: v = staticinvoke (); label: v = interfaceinvoke v.(); if v != 0 goto label; v = newarray (org.bson.conversions.Bson)[2]; v = staticinvoke ("executionContext._type", "dataSpaceExecutionContext"); v[0] = v; v = staticinvoke ("executionContext.dataSpacePath", v); v[1] = v; v = staticinvoke (v); v = newarray (org.bson.conversions.Bson)[2]; v[0] = v; v[1] = v; v = staticinvoke (v); interfaceinvoke v.(v); goto label; label: interfaceinvoke v.(v); label: v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = staticinvoke (); v = staticinvoke (v, v); v = staticinvoke (v); interfaceinvoke v.(v); label: v = new java.util.ArrayList; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v = newarray (com.mongodb.client.model.Field)[1]; v = new com.mongodb.client.model.Field; v = new org.bson.Document; v = newarray (java.lang.String)[2]; v[0] = "$owner"; v[1] = v; v = staticinvoke (v); specialinvoke v.(java.lang.String,java.lang.Object)>("$eq", v); specialinvoke v.(java.lang.String,java.lang.Object)>("isCurrentUser", v); v[0] = v; v = staticinvoke (v); interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; v = ; goto label; label: v = staticinvoke (v); label: v = staticinvoke (v); interfaceinvoke v.(v); v = newarray (java.lang.String)[1]; v[0] = "isCurrentUser"; v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.(v); v = v.; if v == null goto label; v = newarray (java.lang.String)[1]; v = v.; v = virtualinvoke v.(v); v[0] = v; v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.(v); label: v = ; v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.(v); v = v.; if v != null goto label; v = 2147483647; goto label; label: v = v.; v = virtualinvoke v.(); label: v = staticinvoke (100, v); v = staticinvoke (v); interfaceinvoke v.(v); v = specialinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = specialinvoke v.(v); interfaceinvoke v.(v); goto label; label: return v; } public java.lang.String getSortByField(org.finos.legend.engine.application.query.model.QuerySearchSortBy) { int[] v; org.finos.legend.engine.protocol.pure.v.model.context.EngineErrorType v; int v, v; org.finos.legend.engine.shared.core.operational.errorManagement.EngineException v; org.finos.legend.engine.application.query.model.QuerySearchSortBy v; org.finos.legend.engine.application.query.api.QueryStoreManager v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v := @parameter: org.finos.legend.engine.application.query.model.QuerySearchSortBy; v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; default: goto label; }; label: return "createdAt"; label: return "lastOpenAt"; label: return "lastUpdatedAt"; label: v = new org.finos.legend.engine.shared.core.operational.errorManagement.EngineException; v = ; specialinvoke v.(java.lang.String,org.finos.legend.engine.protocol.pure.v.model.context.EngineErrorType)>("Fail to understand sort-by value", v); throw v; } public java.util.List getQueries(java.util.List) { java.lang.IllegalStateException v; com.mongodb.client.MongoCollection v; org.eclipse.collections.api.block.function.Function v; org.eclipse.collections.api.list.MutableList v; org.bson.conversions.Bson v; org.eclipse.collections.api.LazyIterable v; int v, v, v; javax.ws.rs.core.Response$Status v, v; java.lang.String v, v; org.eclipse.collections.api.factory.set.sorted.MutableSortedSetFactory v, v; java.util.function.Consumer v; org.eclipse.collections.api.set.sorted.MutableSortedSet v, v; java.util.List v; com.mongodb.client.FindIterable v, v; org.finos.legend.engine.application.query.api.ApplicationQueryException v, v; org.finos.legend.engine.application.query.api.QueryStoreManager v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v := @parameter: java.util.List; v = interfaceinvoke v.(); if v <= 50 goto label; v = new org.finos.legend.engine.application.query.api.ApplicationQueryException; v = ; specialinvoke v.(java.lang.String,javax.ws.rs.core.Response$Status)>("Can\'t fetch more than 50 queries", v); throw v; label: v = specialinvoke v.(); v = staticinvoke ("id", v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(50); v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); v = staticinvoke (v, v, v); interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; v = new java.lang.IllegalStateException; v = interfaceinvoke v.("Found multiple queries with duplicated ID for the following ID(s):\\n", "\\n", ""); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(); if v == 0 goto label; v = new org.finos.legend.engine.application.query.api.ApplicationQueryException; v = interfaceinvoke v.("Can\'t find queries for the following ID(s):\\n", "\\n", ""); v = ; specialinvoke v.(java.lang.String,javax.ws.rs.core.Response$Status)>(v, v); throw v; label: return v; } public org.finos.legend.engine.application.query.model.Query getQuery(java.lang.String) throws com.fasterxml.jackson.core.JsonProcessingException { java.lang.IllegalStateException v; com.mongodb.client.MongoCollection v, v; org.eclipse.collections.api.block.function.Function v; long v, v; org.eclipse.collections.api.list.MutableList v; org.bson.conversions.Bson v, v, v; org.eclipse.collections.api.LazyIterable v; java.lang.Long v, v; int v, v; javax.ws.rs.core.Response$Status v; java.lang.String v, v, v; java.time.Instant v, v; com.mongodb.client.FindIterable v; org.finos.legend.engine.application.query.api.ApplicationQueryException v; java.lang.Object v; org.finos.legend.engine.application.query.api.QueryStoreManager v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v := @parameter: java.lang.String; v = specialinvoke v.(); v = staticinvoke ("id", v); v = interfaceinvoke v.(v); v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v <= 1 goto label; v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Found multiple queries with ID \'\u0001\'"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(); if v != 0 goto label; v = new org.finos.legend.engine.application.query.api.ApplicationQueryException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Can\'t find query with ID \'\u0001\'"); v = ; specialinvoke v.(java.lang.String,javax.ws.rs.core.Response$Status)>(v, v); throw v; label: v = interfaceinvoke v.(0); v = staticinvoke (); v = virtualinvoke v.(); v = staticinvoke (v); v. = v; v = specialinvoke v.(); v = staticinvoke ("id", v); v = staticinvoke (); v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke ("lastOpenAt", v); interfaceinvoke v.(v, v); return v; } public org.finos.legend.engine.application.query.model.QueryStoreStats getQueryStoreStats() throws com.fasterxml.jackson.core.JsonProcessingException { com.mongodb.client.MongoCollection v, v; org.bson.conversions.Bson[] v; long v, v; java.util.ArrayList v; org.bson.conversions.Bson v, v, v, v; org.finos.legend.engine.application.query.model.QueryStoreStats v; java.lang.Long v, v; org.finos.legend.engine.application.query.api.QueryStoreManager v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v = specialinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = new org.finos.legend.engine.application.query.model.QueryStoreStats; specialinvoke v.()>(); virtualinvoke v.(v); v = new java.util.ArrayList; specialinvoke v.()>(); v = newarray (org.bson.conversions.Bson)[2]; v = staticinvoke ("taggedValues.tag.profile", "meta::pure::profiles::query"); v[0] = v; v = staticinvoke ("taggedValues.tag.value", "dataSpace"); v[1] = v; v = staticinvoke (v); interfaceinvoke v.(v); v = specialinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (v); virtualinvoke v.(v); return v; } public org.finos.legend.engine.application.query.model.Query createQuery(org.finos.legend.engine.application.query.model.Query, java.lang.String) throws com.fasterxml.jackson.core.JsonProcessingException { org.bson.Document v, v; com.mongodb.client.MongoCollection v, v, v; org.eclipse.collections.api.block.function.Function v; long v; org.eclipse.collections.api.list.MutableList v; org.bson.conversions.Bson v; org.eclipse.collections.api.LazyIterable v; org.finos.legend.engine.application.query.model.QueryEvent$QueryEventType v; java.lang.Long v, v, v, v; int v; javax.ws.rs.core.Response$Status v; java.lang.String v, v, v, v, v; org.finos.legend.engine.application.query.model.Query v; java.time.Instant v; org.finos.legend.engine.application.query.model.QueryEvent v; com.mongodb.client.FindIterable v; org.finos.legend.engine.application.query.api.ApplicationQueryException v; org.finos.legend.engine.application.query.api.QueryStoreManager v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v := @parameter: org.finos.legend.engine.application.query.model.Query; v := @parameter: java.lang.String; staticinvoke (v); v. = v; v = specialinvoke v.(); v = v.; v = staticinvoke ("id", v); v = interfaceinvoke v.(v); v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v < 1 goto label; v = new org.finos.legend.engine.application.query.api.ApplicationQueryException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Query with ID \'\u0001\' already existed"); v = ; specialinvoke v.(java.lang.String,javax.ws.rs.core.Response$Status)>(v, v); throw v; label: v = staticinvoke (); v = virtualinvoke v.(); v = staticinvoke (v); v. = v; v = v.; v. = v; v = v.; v. = v; v = specialinvoke v.(); v = specialinvoke v.(v); interfaceinvoke v.(v); v = v.; v = ; v = staticinvoke (v, v); v = v.; v. = v; v = specialinvoke v.(); v = specialinvoke v.(v); interfaceinvoke v.(v); return v; } public org.finos.legend.engine.application.query.model.Query updateQuery(java.lang.String, org.finos.legend.engine.application.query.model.Query, java.lang.String) throws com.fasterxml.jackson.core.JsonProcessingException { org.bson.Document v, v; java.lang.IllegalStateException v; org.eclipse.collections.api.list.MutableList v; java.lang.Long v, v, v, v; javax.ws.rs.core.Response$Status v, v, v; boolean v, v; java.time.Instant v, v; org.finos.legend.engine.application.query.model.QueryEvent v; com.mongodb.client.FindIterable v; org.finos.legend.engine.application.query.api.ApplicationQueryException v, v, v; org.finos.legend.engine.application.query.api.QueryStoreManager v; com.mongodb.client.MongoCollection v, v, v; org.eclipse.collections.api.block.function.Function v; long v, v; org.bson.conversions.Bson v, v; org.eclipse.collections.api.LazyIterable v; org.finos.legend.engine.application.query.model.QueryEvent$QueryEventType v; int v, v; java.lang.String v, v, v, v, v, v, v, v, v; org.finos.legend.engine.application.query.model.Query v; java.lang.Object v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v := @parameter: java.lang.String; v := @parameter: org.finos.legend.engine.application.query.model.Query; v := @parameter: java.lang.String; staticinvoke (v); v = specialinvoke v.(); v = staticinvoke ("id", v); v = interfaceinvoke v.(v); v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = new org.finos.legend.engine.application.query.api.ApplicationQueryException; v = ; specialinvoke v.(java.lang.String,javax.ws.rs.core.Response$Status)>("Updating query ID is not supported", v); throw v; label: v = interfaceinvoke v.(); if v <= 1 goto label; v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Found multiple queries with ID \'\u0001\'"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(); if v != 0 goto label; v = new org.finos.legend.engine.application.query.api.ApplicationQueryException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Can\'t find query with ID \'\u0001\'"); v = ; specialinvoke v.(java.lang.String,javax.ws.rs.core.Response$Status)>(v, v); throw v; label: v = interfaceinvoke v.(0); v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = new org.finos.legend.engine.application.query.api.ApplicationQueryException; v = ; specialinvoke v.(java.lang.String,javax.ws.rs.core.Response$Status)>("Only owner can update the query", v); throw v; label: v. = v; v = v.; v. = v; v = staticinvoke (); v = virtualinvoke v.(); v = staticinvoke (v); v. = v; v = staticinvoke (); v = virtualinvoke v.(); v = staticinvoke (v); v. = v; v = v.; v. = v; v = specialinvoke v.(); v = staticinvoke ("id", v); v = specialinvoke v.(v); interfaceinvoke v.(v, v); v = v.; v = ; v = staticinvoke (v, v); v = v.; v. = v; v = specialinvoke v.(); v = specialinvoke v.(v); interfaceinvoke v.(v); return v; } public org.finos.legend.engine.application.query.model.Query patchQuery(java.lang.String, org.finos.legend.engine.application.query.model.Query, java.lang.String) throws com.fasterxml.jackson.core.JsonProcessingException { org.bson.Document v, v; java.lang.Long v, v, v; javax.ws.rs.core.Response$Status v, v; boolean v; java.lang.IllegalAccessException v; java.time.Instant v, v; org.finos.legend.engine.application.query.model.QueryEvent v; org.finos.legend.engine.application.query.api.ApplicationQueryException v, v; org.finos.legend.engine.application.query.api.QueryStoreManager v; com.mongodb.client.MongoCollection v, v; long v, v; org.bson.conversions.Bson v; org.finos.legend.engine.application.query.model.QueryEvent$QueryEventType v; int v, v; java.lang.String v, v, v, v, v, v; org.finos.legend.engine.application.query.model.Query v, v; java.lang.reflect.Field v; java.lang.reflect.Field[] v; java.lang.Class v; java.lang.Object v; v := @this: org.finos.legend.engine.application.query.api.QueryStoreManager; v := @parameter: java.lang.String; v := @parameter: org.finos.legend.engine.application.query.model.Query; v := @parameter: java.lang.String; v = virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = new org.finos.legend.engine.application.query.api.ApplicationQueryException; v = ; specialinvoke v.(java.lang.String,javax.ws.rs.core.Response$Status)>("Only owner can update the query", v); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; label: virtualinvoke v.(1); v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = new org.finos.legend.engine.application.query.api.ApplicationQueryException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Can\'t modify query field\u0001"); v = ; specialinvoke v.(java.lang.String,javax.ws.rs.core.Response$Status)>(v, v); throw v; label: v = v + 1; goto label; label: v. = v; v = staticinvoke (); v = virtualinvoke v.(); v = staticinvoke (v); v. = v; v = staticinvoke (); v = virtualinvoke v.(); v = staticinvoke (v); v. = v; v = specialinvoke v.(); v = staticinvoke ("id", v); v = specialinvoke v.(v); interfaceinvoke v.(v, v); v =