@atlas-engine/admin_domain.repository.embedded - npm Package Compare versions

Comparing version 0.1.3 to 0.1.4

dist/amd/notification_repository.js

@@ -8,2 +8,40 @@ define(["require", "exports", "@atlas-engine/process_model", "@atlas-engine/admin_domain.contracts"], function (require, exports, process_model_1, admin_domain_contracts_1) {
         }
+        async onProcessDeployed(identity, callback, subscribeOnce) {
+            return this.createSubscription(admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processDeployed, callback, subscribeOnce);
+        }
+        async onProcessUndeployed(identity, callback, subscribeOnce) {
+            return this.createSubscription(admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processUndeployed, callback, subscribeOnce);
+        }
+        onProcessStarted(identity, callback, subscribeOnce) {
+            const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processStarted;
+            const sanitationCallback = (message) => {
+                const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
+                callback(sanitizedMessage);
+            };
+            return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
+        }
+        onProcessEnded(identity, callback, subscribeOnce) {
+            const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processEnded;
+            const sanitationCallback = (message) => {
+                const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
+                callback(sanitizedMessage);
+            };
+            return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
+        }
+        onProcessTerminated(identity, callback, subscribeOnce) {
+            const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processTerminated;
+            const sanitationCallback = (message) => {
+                const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
+                callback(sanitizedMessage);
+            };
+            return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
+        }
+        onProcessError(identity, callback, subscribeOnce) {
+            const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processError;
+            const sanitationCallback = (message) => {
+                const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
+                callback(sanitizedMessage);
+            };
+            return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
+        }
         async onCronjobCreated(identity, callback, subscribeOnce) {
@@ -131,34 +169,2 @@ const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.cronjobCreated;
         }
-        onProcessStarted(identity, callback, subscribeOnce) {
-            const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processStarted;
-            const sanitationCallback = (message) => {
-                const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
-                callback(sanitizedMessage);
-            };
-            return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
-        }
-        onProcessEnded(identity, callback, subscribeOnce) {
-            const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processEnded;
-            const sanitationCallback = (message) => {
-                const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
-                callback(sanitizedMessage);
-            };
-            return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
-        }
-        onProcessTerminated(identity, callback, subscribeOnce) {
-            const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processTerminated;
-            const sanitationCallback = (message) => {
-                const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
-                callback(sanitizedMessage);
-            };
-            return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
-        }
-        onProcessError(identity, callback, subscribeOnce) {
-            const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processError;
-            const sanitationCallback = (message) => {
-                const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
-                callback(sanitizedMessage);
-            };
-            return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
-        }
         async removeSubscription(identity, subscription) {
@@ -165,0 +171,0 @@ await this.eventAggregator.unsubscribe(subscription);

dist/commonjs/notification_repository.js

@@ -9,2 +9,40 @@ "use strict";
     }
+    async onProcessDeployed(identity, callback, subscribeOnce) {
+        return this.createSubscription(admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processDeployed, callback, subscribeOnce);
+    }
+    async onProcessUndeployed(identity, callback, subscribeOnce) {
+        return this.createSubscription(admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processUndeployed, callback, subscribeOnce);
+    }
+    onProcessStarted(identity, callback, subscribeOnce) {
+        const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processStarted;
+        const sanitationCallback = (message) => {
+            const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
+            callback(sanitizedMessage);
+        };
+        return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
+    }
+    onProcessEnded(identity, callback, subscribeOnce) {
+        const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processEnded;
+        const sanitationCallback = (message) => {
+            const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
+            callback(sanitizedMessage);
+        };
+        return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
+    }
+    onProcessTerminated(identity, callback, subscribeOnce) {
+        const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processTerminated;
+        const sanitationCallback = (message) => {
+            const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
+            callback(sanitizedMessage);
+        };
+        return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
+    }
+    onProcessError(identity, callback, subscribeOnce) {
+        const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processError;
+        const sanitationCallback = (message) => {
+            const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
+            callback(sanitizedMessage);
+        };
+        return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
+    }
     async onCronjobCreated(identity, callback, subscribeOnce) {
@@ -132,34 +170,2 @@ const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.cronjobCreated;
     }
-    onProcessStarted(identity, callback, subscribeOnce) {
-        const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processStarted;
-        const sanitationCallback = (message) => {
-            const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
-            callback(sanitizedMessage);
-        };
-        return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
-    }
-    onProcessEnded(identity, callback, subscribeOnce) {
-        const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processEnded;
-        const sanitationCallback = (message) => {
-            const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
-            callback(sanitizedMessage);
-        };
-        return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
-    }
-    onProcessTerminated(identity, callback, subscribeOnce) {
-        const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processTerminated;
-        const sanitationCallback = (message) => {
-            const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
-            callback(sanitizedMessage);
-        };
-        return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
-    }
-    onProcessError(identity, callback, subscribeOnce) {
-        const eventName = admin_domain_contracts_1.Messages.EventAggregatorSettings.messagePaths.processError;
-        const sanitationCallback = (message) => {
-            const sanitizedMessage = this.sanitizeMessage(message, admin_domain_contracts_1.Messages.EventMessage);
-            callback(sanitizedMessage);
-        };
-        return this.createSubscription(eventName, sanitationCallback, subscribeOnce);
-    }
     async removeSubscription(identity, subscription) {
@@ -166,0 +172,0 @@ await this.eventAggregator.unsubscribe(subscription);

dist/notification_repository.d.ts

@@ -7,2 +7,8 @@ import { IEventAggregator, Subscription } from '@atlas-engine/event_aggregator_contracts';
     constructor(eventAggregator: IEventAggregator);
+    onProcessDeployed(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessDeployedCallback, subscribeOnce?: boolean): Promise<Subscription>;
+    onProcessUndeployed(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessUndeployedCallback, subscribeOnce?: boolean): Promise<Subscription>;
+    onProcessStarted(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessStartedCallback, subscribeOnce: boolean): Subscription;
+    onProcessEnded(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessEndedCallback, subscribeOnce: boolean): Subscription;
+    onProcessTerminated(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessTerminatedCallback, subscribeOnce: boolean): Subscription;
+    onProcessError(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessErrorCallback, subscribeOnce: boolean): Subscription;
     onCronjobCreated(identity: IIdentity, callback: Messages.CallbackTypes.OnCronjobCreatedCallback, subscribeOnce?: boolean): Promise<Subscription>;
@@ -25,6 +31,2 @@ onCronjobStopped(identity: IIdentity, callback: Messages.CallbackTypes.OnCronjobStoppedCallback, subscribeOnce?: boolean): Promise<Subscription>;
     onIntermediateCatchEventFinished(identity: IIdentity, callback: Messages.CallbackTypes.OnIntermediateCatchEventFinishedCallback, subscribeOnce: boolean): Subscription;
-    onProcessStarted(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessStartedCallback, subscribeOnce: boolean): Subscription;
-    onProcessEnded(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessEndedCallback, subscribeOnce: boolean): Subscription;
-    onProcessTerminated(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessTerminatedCallback, subscribeOnce: boolean): Subscription;
-    onProcessError(identity: IIdentity, callback: Messages.CallbackTypes.OnProcessErrorCallback, subscribeOnce: boolean): Subscription;
     removeSubscription(identity: IIdentity, subscription: Subscription): Promise<void>;
@@ -31,0 +33,0 @@ private createSubscription;

package.json

 {
   "name": "@atlas-engine/admin_domain.repository.embedded",
-  "version": "0.1.3",
+  "version": "0.1.4",
   "description": "Contains the repository that the admin domain uses for accessing the Core- and Runtime- domains in an embedded application.",
@@ -5,0 +5,0 @@ "main": "dist/commonjs/index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

91393

increased by2.15%

Lines of code

939

increased by1.51%

No dependency changes