From 5cdadcf28cba5f1158aaf801a081ed3ca9750829 Mon Sep 17 00:00:00 2001
From: Cody Seibert <cseibert113@gmail.com>
Date: Fri, 15 Mar 2019 10:10:37 -0400
Subject: [PATCH] making a booleaning to prevent the outbox entries from being
 created

---
 .../workitems/completeWorkItemInteractor.js   |  1 +
 .../workitems/forwardWorkItemInteractor.js    |  1 +
 .../dynamo/workitems/saveWorkItem.js          | 40 +++++++++++--------
 3 files changed, 25 insertions(+), 17 deletions(-)

diff --git a/shared/src/business/useCases/workitems/completeWorkItemInteractor.js b/shared/src/business/useCases/workitems/completeWorkItemInteractor.js
index 3e6a64fc485..f0f3d0ea3e1 100644
--- a/shared/src/business/useCases/workitems/completeWorkItemInteractor.js
+++ b/shared/src/business/useCases/workitems/completeWorkItemInteractor.js
@@ -41,6 +41,7 @@ exports.completeWorkItem = async ({
 
   await applicationContext.getPersistenceGateway().saveWorkItem({
     applicationContext,
+    createOutboxEntries: true,
     workItemToSave: completedWorkItem,
   });
 
diff --git a/shared/src/business/useCases/workitems/forwardWorkItemInteractor.js b/shared/src/business/useCases/workitems/forwardWorkItemInteractor.js
index d9b4664fc8e..858adcfd57d 100644
--- a/shared/src/business/useCases/workitems/forwardWorkItemInteractor.js
+++ b/shared/src/business/useCases/workitems/forwardWorkItemInteractor.js
@@ -62,6 +62,7 @@ exports.forwardWorkItem = async ({
 
   return applicationContext.getPersistenceGateway().saveWorkItem({
     applicationContext,
+    createOutboxEntries: true,
     workItemToSave: workItemToForward.validate().toRawObject(),
   });
 };
diff --git a/shared/src/persistence/dynamo/workitems/saveWorkItem.js b/shared/src/persistence/dynamo/workitems/saveWorkItem.js
index 00aa7371f03..04d5c406e05 100644
--- a/shared/src/persistence/dynamo/workitems/saveWorkItem.js
+++ b/shared/src/persistence/dynamo/workitems/saveWorkItem.js
@@ -5,7 +5,11 @@ const { stripInternalKeys } = require('../../dynamo/helpers/stripInternalKeys');
 const { getCaseByCaseId } = require('../cases/getCaseByCaseId');
 const { saveVersionedCase } = require('../cases/saveCase');
 
-exports.saveWorkItem = async ({ workItemToSave, applicationContext }) => {
+exports.saveWorkItem = async ({
+  workItemToSave,
+  createOutboxEntries,
+  applicationContext,
+}) => {
   const user = applicationContext.getCurrentUser();
 
   const existingWorkItem = await getWorkItemById({
@@ -40,23 +44,25 @@ exports.saveWorkItem = async ({ workItemToSave, applicationContext }) => {
     existingVersion: (caseToUpdate || {}).currentVersion,
   });
 
-  await client.put({
-    applicationContext,
-    Item: {
-      pk: `${user.userId}|outbox`,
-      sk: new Date().toISOString(),
-      ...workItemToSave,
-    },
-  });
+  if (createOutboxEntries) {
+    await client.put({
+      applicationContext,
+      Item: {
+        pk: `${user.userId}|outbox`,
+        sk: new Date().toISOString(),
+        ...workItemToSave,
+      },
+    });
 
-  await client.put({
-    applicationContext,
-    Item: {
-      pk: `${user.section}|outbox`,
-      sk: new Date().toISOString(),
-      ...workItemToSave,
-    },
-  });
+    await client.put({
+      applicationContext,
+      Item: {
+        pk: `${user.section}|outbox`,
+        sk: new Date().toISOString(),
+        ...workItemToSave,
+      },
+    });
+  }
 
   const workItem = await client.put({
     applicationContext,