Extend DeciderModule to automatically decide Requests

packages/app-runtime/src/modules/appEvents/RelationshipTemplateProcessedModule.ts

@@ -69,6 +69,10 @@ export class RelationshipTemplateProcessedModule extends AppRuntimeModule<Relati
                 );
                 break;
             }
+
+            case RelationshipTemplateProcessedResult.RequestAutomaticallyDecided: {
+                break;
+            }
         }
     }
 

packages/runtime/src/RuntimeConfig.ts

@@ -1,8 +1,10 @@
 import { IConfigOverwrite } from "@nmshd/transport";
 import { ModuleConfiguration } from "./extensibility/modules/RuntimeModule";
+import { DeciderModuleConfiguration } from "./modules";
 
 export interface RuntimeConfig {
     transportLibrary: Omit<IConfigOverwrite, "supportedIdentityVersion">;
-
-    modules: Record<string, ModuleConfiguration>;
+    modules: Record<string, ModuleConfiguration> & {
+        decider: DeciderModuleConfiguration;
+    };
 }

packages/runtime/src/events/consumption/MessageProcessedEvent.ts

@@ -10,6 +10,7 @@ export class MessageProcessedEvent extends DataEvent<MessageProcessedEventData>
 }
 
 export enum MessageProcessedResult {
+    RequestAutomaticallyDecided = "RequestAutomaticallyDecided",
     ManualRequestDecisionRequired = "ManualRequestDecisionRequired",
     NoRequest = "NoRequest",
     Error = "Error"

packages/runtime/src/events/consumption/RelationshipTemplateProcessedEvent.ts

@@ -12,6 +12,7 @@ export class RelationshipTemplateProcessedEvent extends DataEvent<RelationshipTe
 }
 
 export enum RelationshipTemplateProcessedResult {
+    RequestAutomaticallyDecided = "RequestAutomaticallyDecided",
     ManualRequestDecisionRequired = "ManualRequestDecisionRequired",
     NonCompletedRequestExists = "NonCompletedRequestExists",
     RelationshipExists = "RelationshipExists",
@@ -20,6 +21,11 @@ export enum RelationshipTemplateProcessedResult {
 }
 
 export type RelationshipTemplateProcessedEventData =
+    | {
+          template: RelationshipTemplateDTO;
+          result: RelationshipTemplateProcessedResult.RequestAutomaticallyDecided;
+          requestId: string;
+      }
     | {
           template: RelationshipTemplateDTO;
           result: RelationshipTemplateProcessedResult.ManualRequestDecisionRequired;

packages/runtime/src/modules/decide/RequestConfig.ts

@@ -0,0 +1,147 @@
+import { RelationshipAttributeConfidentiality } from "@nmshd/content";
+
+export interface GeneralRequestConfig {
+    peer?: string | string[];
+    createdAt?: string | string[];
+    "source.type"?: "Message" | "RelationshipTemplate";
+    "content.expiresAt"?: string | string[];
+    "content.title"?: string | string[];
+    "content.description"?: string | string[];
+    "content.metadata"?: object | object[];
+}
+
+export interface RequestItemConfig extends GeneralRequestConfig {
+    "content.item.@type"?: string | string[];
+    "content.item.mustBeAccepted"?: boolean;
+    "content.item.title"?: string | string[];
+    "content.item.description"?: string | string[];
+    "content.item.metadata"?: object | object[];
+}
+
+export interface AuthenticationRequestItemConfig extends RequestItemConfig {
+    "content.item.@type": "AuthenticationRequestItem";
+}
+
+export interface ConsentRequestItemConfig extends RequestItemConfig {
+    "content.item.@type": "ConsentRequestItem";
+    "content.item.consent"?: string | string[];
+    "content.item.link"?: string | string[];
+}
+
+export interface CreateAttributeRequestItemConfig extends RequestItemConfig {
+    "content.item.@type": "CreateAttributeRequestItem";
+    "content.item.attribute.@type"?: "IdentityAttribute" | "RelationshipAttribute";
+    "content.item.attribute.owner"?: string | string[];
+    "content.item.attribute.validFrom"?: string | string[];
+    "content.item.attribute.validTo"?: string | string[];
+    "content.item.attribute.tags"?: string[];
+    "content.item.attribute.key"?: string | string[];
+    "content.item.attribute.isTechnical"?: boolean;
+    "content.item.attribute.confidentiality"?: RelationshipAttributeConfidentiality | RelationshipAttributeConfidentiality[];
+    "content.item.attribute.value.@type"?: string | string[];
+    "content.item.attribute.value.value"?: string | string[];
+    "content.item.attribute.value.title"?: string | string[];
+    "content.item.attribute.value.description"?: string | string[];
+}
+
+export interface DeleteAttributeRequestItemConfig extends RequestItemConfig {
+    "content.item.@type": "DeleteAttributeRequestItem";
+}
+
+export interface FreeTextRequestItemConfig extends RequestItemConfig {
+    "content.item.@type": "FreeTextRequestItem";
+    "content.item.freeText"?: string | string[];
+}
+
+export interface ProposeAttributeRequestItemConfig extends RequestItemConfig {
+    "content.item.@type": "ProposeAttributeRequestItem";
+    "content.item.attribute.@type"?: "IdentityAttribute" | "RelationshipAttribute";
+    "content.item.attribute.owner"?: string | string[];
+    "content.item.attribute.validFrom"?: string | string[];
+    "content.item.attribute.validTo"?: string | string[];
+    "content.item.attribute.tags"?: string[];
+    "content.item.attribute.key"?: string | string[];
+    "content.item.attribute.isTechnical"?: boolean;
+    "content.item.attribute.confidentiality"?: RelationshipAttributeConfidentiality | RelationshipAttributeConfidentiality[];
+    "content.item.attribute.value.@type"?: string | string[];
+    "content.item.attribute.value.value"?: string | string[];
+    "content.item.attribute.value.title"?: string | string[];
+    "content.item.attribute.value.description"?: string | string[];
+    "content.item.query.@type"?: "IdentityAttributeQuery" | "RelationshipAttributeQuery" | "IQLQuery";
+    "content.item.query.validFrom"?: string | string[];
+    "content.item.query.validTo"?: string | string[];
+    "content.item.query.valueType"?: string | string[];
+    "content.item.query.tags"?: string[];
+    "content.item.query.key"?: string | string[];
+    "content.item.query.owner"?: string | string[];
+    "content.item.query.queryString"?: string | string[];
+    "content.item.query.attributeCreationHints.title"?: string | string[];
+    "content.item.query.attributeCreationHints.description"?: string | string[];
+    "content.item.query.attributeCreationHints.valueType"?: string | string[];
+    "content.item.query.attributeCreationHints.confidentiality"?: RelationshipAttributeConfidentiality | RelationshipAttributeConfidentiality[];
+    "content.item.query.attributeCreationHints.tags"?: string[];
+}
+
+export interface ReadAttributeRequestItemConfig extends RequestItemConfig {
+    "content.item.@type": "ReadAttributeRequestItem";
+    "content.item.query.@type"?: "IdentityAttributeQuery" | "RelationshipAttributeQuery" | "IQLQuery";
+    "content.item.query.validFrom"?: string | string[];
+    "content.item.query.validTo"?: string | string[];
+    "content.item.query.valueType"?: string | string[];
+    "content.item.query.tags"?: string[];
+    "content.item.query.key"?: string | string[];
+    "content.item.query.owner"?: string | string[];
+    "content.item.query.queryString"?: string | string[];
+    "content.item.query.attributeCreationHints.title"?: string | string[];
+    "content.item.query.attributeCreationHints.description"?: string | string[];
+    "content.item.query.attributeCreationHints.valueType"?: string | string[];
+    "content.item.query.attributeCreationHints.confidentiality"?: RelationshipAttributeConfidentiality | RelationshipAttributeConfidentiality[];
+    "content.item.query.attributeCreationHints.tags"?: string[];
+}
+
+export interface RegisterAttributeListenerRequestItemConfig extends RequestItemConfig {
+    "content.item.@type": "RegisterAttributeListenerRequestItem";
+    "content.item.query.@type"?: "IdentityAttributeQuery";
+    "content.item.query.validFrom"?: string | string[];
+    "content.item.query.validTo"?: string | string[];
+    "content.item.query.valueType"?: string | string[];
+    "content.item.query.tags"?: string[];
+}
+
+export interface ShareAttributeRequestItemConfig extends RequestItemConfig {
+    "content.item.@type": "ShareAttributeRequestItem";
+    "content.item.attribute.@type"?: "IdentityAttribute" | "RelationshipAttribute";
+    "content.item.attribute.owner"?: string | string[];
+    "content.item.attribute.validFrom"?: string | string[];
+    "content.item.attribute.validTo"?: string | string[];
+    "content.item.attribute.tags"?: string[];
+    "content.item.attribute.key"?: string | string[];
+    "content.item.attribute.isTechnical"?: boolean;
+    "content.item.attribute.confidentiality"?: RelationshipAttributeConfidentiality | RelationshipAttributeConfidentiality[];
+    "content.item.attribute.value.@type"?: string | string[];
+    "content.item.attribute.value.value"?: string | string[];
+    "content.item.attribute.value.title"?: string | string[];
+    "content.item.attribute.value.description"?: string | string[];
+}
+
+export type RequestItemDerivationConfig =
+    | RequestItemConfig
+    | AuthenticationRequestItemConfig
+    | ConsentRequestItemConfig
+    | CreateAttributeRequestItemConfig
+    | DeleteAttributeRequestItemConfig
+    | FreeTextRequestItemConfig
+    | ProposeAttributeRequestItemConfig
+    | ReadAttributeRequestItemConfig
+    | RegisterAttributeListenerRequestItemConfig
+    | ShareAttributeRequestItemConfig;
+
+export function isGeneralRequestConfig(input: any): input is GeneralRequestConfig {
+    return !Object.keys(input).some((key) => key.startsWith("content.item."));
+}
+
+export function isRequestItemDerivationConfig(input: any): input is RequestItemDerivationConfig {
+    return Object.keys(input).some((key) => key.startsWith("content.item."));
+}
+
+export type RequestConfig = GeneralRequestConfig | RequestItemDerivationConfig;

packages/runtime/src/modules/decide/ResponseConfig.ts

@@ -0,0 +1,64 @@
+import { IdentityAttribute, RelationshipAttribute } from "@nmshd/content";
+
+export interface RejectResponseConfig {
+    accept: false;
+    code?: string;
+    message?: string;
+}
+
+export function isRejectResponseConfig(input: any): input is RejectResponseConfig {
+    return input.accept === false;
+}
+
+export interface AcceptResponseConfig {
+    accept: true;
+}
+
+export function isAcceptResponseConfig(input: any): input is AcceptResponseConfig {
+    return input.accept === true;
+}
+
+export function isSimpleAcceptResponseConfig(input: any): input is AcceptResponseConfig {
+    return input.accept === true && Object.keys(input).length === 1;
+}
+
+export interface DeleteAttributeAcceptResponseConfig extends AcceptResponseConfig {
+    deletionDate: string;
+}
+
+export function isDeleteAttributeAcceptResponseConfig(object: any): object is DeleteAttributeAcceptResponseConfig {
+    return "deletionDate" in object;
+}
+
+export interface FreeTextAcceptResponseConfig extends AcceptResponseConfig {
+    freeText: string;
+}
+
+export function isFreeTextAcceptResponseConfig(object: any): object is FreeTextAcceptResponseConfig {
+    return "freeText" in object;
+}
+
+export interface ProposeAttributeWithNewAttributeAcceptResponseConfig extends AcceptResponseConfig {
+    attribute: IdentityAttribute | RelationshipAttribute;
+}
+
+export function isProposeAttributeWithNewAttributeAcceptResponseConfig(object: any): object is ProposeAttributeWithNewAttributeAcceptResponseConfig {
+    return "attribute" in object;
+}
+
+export interface ReadAttributeWithNewAttributeAcceptResponseConfig extends AcceptResponseConfig {
+    newAttribute: IdentityAttribute | RelationshipAttribute;
+}
+
+export function isReadAttributeWithNewAttributeAcceptResponseConfig(object: any): object is ReadAttributeWithNewAttributeAcceptResponseConfig {
+    return "newAttribute" in object;
+}
+
+export type AcceptResponseConfigDerivation =
+    | AcceptResponseConfig
+    | DeleteAttributeAcceptResponseConfig
+    | FreeTextAcceptResponseConfig
+    | ProposeAttributeWithNewAttributeAcceptResponseConfig
+    | ReadAttributeWithNewAttributeAcceptResponseConfig;
+
+export type ResponseConfig = AcceptResponseConfigDerivation | RejectResponseConfig;

packages/runtime/src/modules/decide/index.ts

@@ -0,0 +1,2 @@
+export * from "./RequestConfig";
+export * from "./ResponseConfig";

packages/runtime/src/useCases/common/RuntimeErrors.ts

@@ -241,6 +241,39 @@ class IdentityDeletionProcess {
     }
 }
 
+class DeciderModule {
+    public doesNotHaveAutomationConfig() {
+        return new ApplicationError("error.runtime.decide.doesNotHaveAutomationConfig", "The Request can't be decided automatically, since no automationConfig was provided.");
+    }
+
+    public someItemsOfRequestCouldNotBeDecidedAutomatically() {
+        return new ApplicationError(
+            "error.runtime.decide.someItemsOfRequestCouldNotBeDecidedAutomatically",
+            "The Request couldn't be decided automatically, since it contains RequestItems for which no suitable automationConfig was provided."
+        );
+    }
+
+    public requestConfigDoesNotMatchResponseConfig() {
+        return new ApplicationError("error.runtime.decide.requestConfigDoesNotMatchResponseConfig", "The RequestConfig does not match the ResponseConfig.");
+    }
+
+    public canRejectRequestFailed(requestId: string, errorMessage?: string) {
+        return new ApplicationError("error.runtime.decide.canRejectRequestFailed", `Can not reject Request ${requestId}: ${errorMessage}`);
+    }
+
+    public canAcceptRequestFailed(requestId: string, errorMessage?: string) {
+        return new ApplicationError("error.runtime.decide.canAcceptRequestFailed", `Can not accept Request ${requestId}: ${errorMessage}`);
+    }
+
+    public rejectRequestFailed(requestId: string, errorMessage: string) {
+        return new ApplicationError("error.runtime.decide.rejectRequestFailed", `An error occured trying to reject Request ${requestId}: ${errorMessage}`);
+    }
+
+    public acceptRequestFailed(requestId: string, errorMessage: string) {
+        return new ApplicationError("error.runtime.decide.acceptRequestFailed", `An error occured trying to accept Request ${requestId}: ${errorMessage}`);
+    }
+}
+
 export class RuntimeErrors {
     public static readonly general = new General();
     public static readonly serval = new Serval();
@@ -253,4 +286,5 @@ export class RuntimeErrors {
     public static readonly notifications = new Notifications();
     public static readonly attributes = new Attributes();
     public static readonly identityDeletionProcess = new IdentityDeletionProcess();
+    public static readonly deciderModule = new DeciderModule();
 }

packages/runtime/test/lib/RuntimeServiceProvider.ts

@@ -1,5 +1,5 @@
 import correlator from "correlation-id";
-import { AnonymousServices, ConsumptionServices, DataViewExpander, RuntimeConfig, TransportServices } from "../../src";
+import { AnonymousServices, ConsumptionServices, DataViewExpander, DeciderModuleConfigurationOverwrite, RuntimeConfig, TransportServices } from "../../src";
 import { MockEventBus } from "./MockEventBus";
 import { TestRuntime } from "./TestRuntime";
 
@@ -15,6 +15,7 @@ export interface TestRuntimeServices {
 export interface LaunchConfiguration {
     enableDatawallet?: boolean;
     enableDeciderModule?: boolean;
+    configureDeciderModule?: DeciderModuleConfigurationOverwrite;
     enableRequestModule?: boolean;
     enableAttributeListenerModule?: boolean;
     enableNotificationModule?: boolean;
@@ -86,13 +87,16 @@ export class RuntimeServiceProvider {
             if (launchConfiguration.enableAttributeListenerModule) config.modules.attributeListener.enabled = true;
             if (launchConfiguration.enableNotificationModule) config.modules.notification.enabled = true;
 
+            config.modules.decider.automationConfig = launchConfiguration.configureDeciderModule?.automationConfig;
+
             const runtime = new TestRuntime(
                 config,
                 {
                     setDefaultRepositoryAttributes: launchConfiguration.enableDefaultRepositoryAttributes ?? false
                 },
                 launchConfiguration.useCorrelator ? correlator : undefined
             );
+
             this.runtimes.push(runtime);
 
             await runtime.init();