More usages of workflow signals added

entity/Order_entity/recordcontainers/db/onDBDelete.js

+import("Workflow_lib");
 import("Context_lib");
 import("system.vars");
 import("Sql_lib");
@@ -6,4 +7,6 @@ import("Attribute_lib");
 newWhere("SALESORDERITEM.SALESORDER_ID", "$field.SALESORDERID").deleteData();
 
 new AttributeRelationQuery(vars.get("$field.SALESORDERID"), null, ContextUtils.getCurrentContextId())
-    .deleteAllAttributes();
\ No newline at end of file
+    .deleteAllAttributes();
+    
+WorkflowSignalSender.deleted();
\ No newline at end of file

entity/Order_entity/recordcontainers/db/onDBInsert.js

+import("Workflow_lib");
 import("Order_lib");
 import("system.neon");
 import("system.vars");
@@ -5,3 +6,5 @@ import("system.vars");
 //@TODO: OfferId_param is also set by 'copy order' -> the items of the offer are copied. What should happen?
 if (vars.get("$sys.recordstate") == neon.OPERATINGSTATE_NEW && vars.exists("$param.OfferId_param"))
     OrderUtils.copyOfferItemsToOrder(vars.getString("$param.OfferId_param"), vars.get("$local.rowdata")["SALESORDER.SALESORDERID"]);
+
+WorkflowSignalSender.inserted();
\ No newline at end of file

entity/Order_entity/recordcontainers/db/onDBUpdate.js

+import("Workflow_lib");
+
+WorkflowSignalSender.updated();
\ No newline at end of file

entity/Organisation_entity/afterOperatingState.js

@@ -5,5 +5,4 @@ if (vars.exists("$context.workflowQueue") && vars.get("$context.workflowQueue"))
 {
     WorkflowStarter.inserted(vars.get("$context.workflowQueue"));
     vars.set("$context.workflowQueue", null);
-}
-WorkflowSignalSender.throwQueuedEvents();
+}
\ No newline at end of file

entity/Organisation_entity/recordcontainers/db/onDBDelete.js

@@ -17,4 +17,4 @@ newWhere("ADDRESS.CONTACT_ID", contactId).deleteData();
 newWhere("COMMRESTRICTION.CONTACT_ID", contactId).deleteData();
 
 //WorkflowStarter.deleted();
-//WorkflowSignalSender.deleted();
\ No newline at end of file
+WorkflowSignalSender.deleted();
\ No newline at end of file

entity/Organisation_entity/recordcontainers/db/onDBInsert.js

@@ -3,4 +3,4 @@ import("system.vars");
 
 //start the execution in afterOperatingState, because here the dataset is not yet inserted
 vars.set("$context.workflowQueue", {});
-WorkflowSignalSender.markInserted();
\ No newline at end of file
+WorkflowSignalSender.inserted();
\ No newline at end of file

entity/Organisation_entity/recordcontainers/db/onDBUpdate.js

@@ -16,4 +16,4 @@ FieldChanges.assimilateChangeAndDispose("$field.STANDARD_PHONE_COMMUNICATION", f
 });
 
 WorkflowStarter.updated();
-WorkflowSignalSender.markUpdated();
\ No newline at end of file
+WorkflowSignalSender.updated();
\ No newline at end of file

entity/Person_entity/afterOperatingState.js

@@ -5,5 +5,4 @@ if (vars.exists("$context.workflowQueue") && vars.get("$context.workflowQueue"))
 {
     WorkflowStarter.inserted(vars.get("$context.workflowQueue"));
     vars.set("$context.workflowQueue", null);
-}
-WorkflowSignalSender.throwQueuedEvents();
\ No newline at end of file
+}
\ No newline at end of file

entity/Person_entity/recordcontainers/db/onDBDelete.js

@@ -16,4 +16,4 @@ newWhere("ADDRESS.CONTACT_ID", contactId).deleteData();
 newWhere("COMMRESTRICTION.CONTACT_ID", contactId).deleteData();
 
 //WorkflowStarter.deleted();
-//WorkflowSignalSender.deleted();
\ No newline at end of file
+WorkflowSignalSender.deleted();
\ No newline at end of file

entity/Person_entity/recordcontainers/db/onDBInsert.js

@@ -11,7 +11,7 @@ DataPrivacyUtils.notifyNeedDataPrivacyUpdate(contactId);
 
 //start the execution in afterOperatingState, because here the dataset is not yet inserted
 vars.set("$context.workflowQueue", {});
-WorkflowSignalSender.markInserted();
+WorkflowSignalSender.inserted();
 
 //let valuesToCheck = {};
 //

entity/Person_entity/recordcontainers/db/onDBUpdate.js

@@ -44,4 +44,4 @@ vars.get("$local.changed").forEach(function(fieldName)
 DataPrivacyUtils.notifyNeedDataPrivacyUpdate(uid);
 
 WorkflowStarter.updated();
-WorkflowSignalSender.markUpdated();
\ No newline at end of file
+WorkflowSignalSender.updated();
\ No newline at end of file

entity/Product_entity/Product_entity.aod

@@ -462,6 +462,7 @@
       <fromClauseProcess>%aditoprj%/entity/Product_entity/recordcontainers/db/fromClauseProcess.js</fromClauseProcess>
       <conditionProcess>%aditoprj%/entity/Product_entity/recordcontainers/db/conditionProcess.js</conditionProcess>
       <orderClauseProcess>%aditoprj%/entity/Product_entity/recordcontainers/db/orderClauseProcess.js</orderClauseProcess>
+      <onDBInsert>%aditoprj%/entity/Product_entity/recordcontainers/db/onDBInsert.js</onDBInsert>
       <onDBUpdate>%aditoprj%/entity/Product_entity/recordcontainers/db/onDBUpdate.js</onDBUpdate>
       <onDBDelete>%aditoprj%/entity/Product_entity/recordcontainers/db/onDBDelete.js</onDBDelete>
       <linkInformation>

entity/Product_entity/recordcontainers/db/onDBDelete.js

+import("Workflow_lib");
 import("Context_lib");
 import("Sql_lib");
 import("Attribute_lib");
@@ -15,4 +16,6 @@ newWhereIfSet("STOCK.PRODUCT_ID", "$field.PRODUCTID")
     .deleteData();
     
 new AttributeRelationQuery(productId, null, ContextUtils.getCurrentContextId())
-    .deleteAllAttributes();
\ No newline at end of file
+    .deleteAllAttributes();
+    
+WorkflowSignalSender.deleted();
\ No newline at end of file

entity/Product_entity/recordcontainers/db/onDBInsert.js

+import("Workflow_lib");
+
+WorkflowSignalSender.inserted();
\ No newline at end of file

entity/Product_entity/recordcontainers/db/onDBUpdate.js

+import("Workflow_lib");
 import("system.vars");
 import("Product_lib");
 import("Entity_lib");
@@ -9,3 +10,5 @@ FieldChanges.assimilateChangeAndDispose("$field.IMAGE", function(state, value){
     else
         ProductUtils.removeImage(vars.get("$local.uid"));
 });
+
+WorkflowSignalSender.updated();
\ No newline at end of file

entity/Salesproject_entity/recordcontainers/db/onDBDelete.js

@@ -44,4 +44,5 @@ if (currentId)
 new AttributeRelationQuery(currentId, null, ContextUtils.getCurrentContextId())
     .deleteAllAttributes();
 
-WorkflowStarter.deleted();
\ No newline at end of file
+WorkflowStarter.deleted();
+WorkflowSignalSender.deleted();
\ No newline at end of file

entity/Salesproject_entity/recordcontainers/db/onDBInsert.js

+import("Workflow_lib");
 import("Context_lib");
 import("Attribute_lib");
 import("AttributeRegistry_basic");
@@ -16,4 +17,5 @@ if (vars.get("$field.PROJECTTYPE"))
 }
 
 //start the execution in afterOperatingState, because here the dataset is not yet inserted
-vars.set("$context.workflowQueue", {});
\ No newline at end of file
+vars.set("$context.workflowQueue", {});
+WorkflowSignalSender.inserted();
\ No newline at end of file

entity/Salesproject_entity/recordcontainers/db/onDBUpdate.js

@@ -101,6 +101,7 @@ if (needToUpdateForecast)
     Salesproject.notifyToUpdateForecast();
 
 WorkflowStarter.updated();
+WorkflowSignalSender.updated();
 
 neon.refreshAll();
 

entity/SerialLetter_entity/recordcontainers/db/onDBDelete.js

+import("Workflow_lib");
 import("system.vars");
 import("Binary_lib");
 import("Sql_lib");
@@ -6,4 +7,6 @@ newWhere("LETTERRECIPIENT.SERIALLETTER_ID", "$local.uid").deleteData();
 
 var uid = vars.get("$local.uid");
 SingleBinaryUtils.remove("SERIALLETTER", "DOCUMENT", uid);
-SingleBinaryUtils.remove("SERIALLETTER", "SERIALLETTERFILE", uid);
\ No newline at end of file
+SingleBinaryUtils.remove("SERIALLETTER", "SERIALLETTERFILE", uid);
+
+WorkflowSignalSender.deleted();
\ No newline at end of file

entity/SerialLetter_entity/recordcontainers/db/onDBInsert.js

+import("Workflow_lib");
 import("Binary_lib");
 import("Sql_lib");
 import("DocumentTemplate_lib");
@@ -15,4 +16,6 @@ var template = DocumentTemplate.fromUpload(bindata);
 if (template.content)
 {
     SingleBinaryUtils.insert("SERIALLETTER", "SERIALLETTERFILE", letterId, template.content, template.filename, "");
-}
\ No newline at end of file
+}
+
+WorkflowSignalSender.inserted();
\ No newline at end of file