fix: integrate mutation policy with current runtime boundaries

Refs #196

Author: Philip Z

teaql-runtime/src/main/java/io/teaql/runtime/LogPrivacy.java

@@ -202,6 +202,7 @@ public static RawAuditEvent audit(RawAuditEvent source, boolean allow) {
         if (source.entityId() != null) intentValues.add(source.entityId());
         return new RawAuditEvent(source.kind(), source.entityType(), source.entityId(), changes,
                 trace(source.traceChain(), intentValues), scrub(source.actor(), intentValues), source.category(),
-                scrub(source.reason(), intentValues), source.resultingVersion(), source.occurredAt());
+                scrub(source.reason(), intentValues), source.resultingVersion(), source.occurredAt(),
+                source.governance());
     }
 }

teaql-runtime/src/main/java/io/teaql/runtime/RawAuditEvent.java

@@ -22,4 +22,19 @@ public record RawAuditEvent(
         traceChain = List.copyOf(traceChain == null ? List.of() : traceChain);
         occurredAt = occurredAt == null ? Instant.now() : occurredAt;
     }
+
+    public RawAuditEvent(
+            MutationAuditKind kind,
+            String entityType,
+            Object entityId,
+            List<AuditFieldChange> changes,
+            List<TraceNode> traceChain,
+            String actor,
+            String category,
+            String reason,
+            Long resultingVersion,
+            Instant occurredAt) {
+        this(kind, entityType, entityId, changes, traceChain, actor, category, reason,
+                resultingVersion, occurredAt, null);
+    }
 }

teaql-runtime/src/main/java/io/teaql/runtime/TeaQLRuntime.java

@@ -246,24 +246,24 @@ public <T extends Entity> Stream<T> executeForStream(
             throw new TeaQLRuntimeException(
                     "[PURPOSE REQUIRED] Missing .purpose() on streaming query execution.");
         }
-        if (requestPolicy != null) {
-            requestPolicy.enforceSelect(context, request);
+        if (queryPolicy != null) {
+            queryPolicy.enforceSelect(context, request);
         }
         return executeForStreamResolved(context, request);
     }
 
     /**
      * Executes a framework-owned nested stream under an already-authorized root query. The
-     * nested request still passes through RequestPolicy before reaching the provider.
+     * nested request still passes through QueryPolicy before reaching the provider.
      */
     public <T extends Entity> Stream<T> internalExecuteForStream(
             UserContext context, SearchRequest<T> request) {
         if (context.getTraceChain() == null || context.getTraceChain().isEmpty()) {
             throw new TeaQLRuntimeException(
                     "[INTERNAL QUERY CONTEXT REQUIRED] Nested streaming query has no authorized root trace.");
         }
-        if (requestPolicy != null) {
-            requestPolicy.enforceSelect(context, request);
+        if (queryPolicy != null) {
+            queryPolicy.enforceSelect(context, request);
         }
         return executeForStreamResolved(context, request);
     }

teaql-runtime/src/main/java/io/teaql/runtime/mutation/MutationPlanner.java

@@ -4,7 +4,7 @@
 import io.teaql.core.meta.EntityDescriptor;
 import io.teaql.core.meta.EntityMetaFactory;
 import io.teaql.core.meta.PropertyDescriptor;
-import io.teaql.runtime.DefaultMutationRequest;
+import io.teaql.runtime.EntityPersistenceMutation;
 
 import java.util.*;
 
@@ -152,8 +152,8 @@ void executeLedgerPlan(UserContext ctx, EntityMutationLedger root, MutationExecu
             deleteEntity.markForDeletion();
             if (root.getComment() != null) deleteEntity.setComment(root.getComment());
 
-            DefaultMutationRequest mutationRequest = new DefaultMutationRequest(
-                deleteEntity, DefaultMutationRequest.Action.DELETE);
+            EntityPersistenceMutation mutationRequest = new EntityPersistenceMutation(
+                deleteEntity, EntityPersistenceMutation.Action.DELETE);
             mutationExecutor.mutate(ctx, mutationRequest);
         }
 
@@ -175,17 +175,17 @@ void executeLedgerPlan(UserContext ctx, EntityMutationLedger root, MutationExecu
 
         // 3. Execute Inserts
         executeBatchMutations(ctx, insertBatches, changeSet, realEntities, root, mutationExecutor,
-                            DefaultMutationRequest.Action.SAVE, false);
+                            EntityPersistenceMutation.Action.SAVE, false);
 
         // 4. Execute Updates
         executeBatchMutations(ctx, updateBatches, changeSet, realEntities, root, mutationExecutor,
-                            DefaultMutationRequest.Action.SAVE, true);
+                            EntityPersistenceMutation.Action.SAVE, true);
     }
 
     private void executeBatchMutations(UserContext ctx, Map<String, List<EntityKey>> batches,
                                       EntityChangeSet changeSet, Map<EntityKey, BaseEntity> realEntities,
                                       EntityMutationLedger root, MutationExecutor mutationExecutor,
-                                      DefaultMutationRequest.Action action, boolean markAsUpdated) {
+                                      EntityPersistenceMutation.Action action, boolean markAsUpdated) {
         for (Map.Entry<String, List<EntityKey>> entry : batches.entrySet()) {
             String entityName = entry.getKey();
             List<EntityKey> keys = entry.getValue();
@@ -213,7 +213,7 @@ private void executeBatchMutations(UserContext ctx, Map<String, List<EntityKey>>
                 }
                 if (root.getComment() != null) entity.setComment(root.getComment());
 
-                DefaultMutationRequest mutationRequest = new DefaultMutationRequest(entity, action);
+                EntityPersistenceMutation mutationRequest = new EntityPersistenceMutation(entity, action);
                 mutationExecutor.mutate(ctx, mutationRequest);
                 entity.clearUpdatedProperties();
             }

teaql-runtime/src/test/java/io/teaql/runtime/TeaQLRuntimeTest.java

@@ -603,7 +603,7 @@ public void streamingExecutionAppliesRequestPolicyBeforeProvider() {
         TeaQLRuntime runtime = TeaQLRuntime.builder()
                 .metadata(new DummyMetaFactory())
                 .dataService("dummy", executor)
-                .requestPolicy(new RequestPolicy() {
+                .queryPolicy(new QueryPolicy() {
                     @Override public void enforceSelect(
                             UserContext context, SearchRequest<?> query) {
                         policyCalls.incrementAndGet();
@@ -636,7 +636,7 @@ public void internalStreamingRequiresAuthorizedRootAndAppliesRequestPolicy() {
         TeaQLRuntime runtime = TeaQLRuntime.builder()
                 .metadata(new DummyMetaFactory())
                 .dataService("dummy", executor)
-                .requestPolicy(new RequestPolicy() {
+                .queryPolicy(new QueryPolicy() {
                     @Override public void enforceSelect(
                             UserContext context, SearchRequest<?> query) {
                         policyCalls.incrementAndGet();

teaql-tfp-endpoint/src/test/java/io/teaql/tfp/TfpConformanceServer.java

@@ -87,6 +87,7 @@ private static Map<String, String> headers(HttpExchange exchange) {
     private static UserContext createContext() {
         EntityDescriptor descriptor = new EntityDescriptor();
         descriptor.setType("CustomerOrder"); descriptor.setTargetType(CustomerOrder.class);
+        descriptor.withEntitySupplier(CustomerOrder::new);
         descriptor.addSimpleProperty("status", String.class);
         descriptor.addSimpleProperty("orderNumber", String.class);
         descriptor.addSimpleProperty("tenantId", Long.class);

teaql-tfp-endpoint/src/test/java/io/teaql/tfp/TfpEndpointPolicyTest.java

@@ -216,6 +216,7 @@ public void isolatesTopLevelFacetAndMutationMetadataByInvokingContext() throws E
         EntityDescriptor probe = new EntityDescriptor();
         probe.setType("Probe");
         probe.setTargetType(AlternateProbe.class);
+        probe.withEntitySupplier(AlternateProbe::new);
         probe.addSimpleProperty("id", Long.class);
         probe.addSimpleProperty("status", String.class);
         alternate.register(probe);
@@ -347,6 +348,13 @@ public static final class AlternateProbe extends BaseEntity {
         public String typeName() { return "Probe"; }
         public String getStatus() { return status; }
         public void setStatus(String value) { status = value; }
+        @Override public void __internalSet(String property, Object value) {
+            if ("status".equals(property)) status = (String) value;
+            else super.__internalSet(property, value);
+        }
+        @Override public Object __internalGet(String property) {
+            return "status".equals(property) ? status : super.__internalGet(property);
+        }
     }
     public static final class AlternateProbeStatus extends BaseEntity {
         public String typeName() { return "ProbeStatus"; }

teaql-tfp-endpoint/src/test/java/io/teaql/tfp/TfpEndpointTelemetryTest.java

@@ -41,6 +41,7 @@ public void registerMetadata() {
         EntityDescriptor descriptor = new EntityDescriptor();
         descriptor.setType("Probe");
         descriptor.setTargetType(Probe.class);
+        descriptor.withEntitySupplier(Probe::new);
         metadata.register(descriptor);
         EntityMetaFactory.registerGlobal(null);
         context = new DefaultUserContext(TeaQLRuntime.builder()