Merge pull request #1790 from ustaxcourt/staging

Merge Staging into Prod

Author: mmarcotte

shared/src/sharedAppContext.js

@@ -12,6 +12,7 @@ const getCognitoLoginUrl = () => {
 };
 
 const getEnvironment = () => ({
+  dynamoDbTableName: process.env.DYNAMODB_TABLE_NAME,
   stage: process.env.STAGE || 'local',
 });
 

web-api/src/applicationContext.js

@@ -931,6 +931,9 @@ const {
 const {
   sendServedPartiesEmails,
 } = require('../../shared/src/business/useCaseHelper/service/sendServedPartiesEmails');
+const {
+  sendUpdatePetitionerCasesMessage,
+} = require('../../shared/src/persistence/messages/sendUpdatePetitionerCasesMessage');
 const {
   serveCaseDocument,
 } = require('../../shared/src/business/utilities/serveCaseDocument');
@@ -1097,6 +1100,9 @@ const {
 const {
   updateOtherStatisticsInteractor,
 } = require('../../shared/src/business/useCases/caseStatistics/updateOtherStatisticsInteractor');
+const {
+  updatePetitionerCasesInteractor,
+} = require('../../shared/src/business/useCases/users/updatePetitionerCasesInteractor');
 const {
   updatePetitionerInformationInteractor,
 } = require('../../shared/src/business/useCases/updatePetitionerInformationInteractor');
@@ -1660,6 +1666,24 @@ module.exports = (appContextUser, logger = createLogger()) => {
     getEnvironment,
     getHttpClient: () => axios,
     getIrsSuperuserEmail: () => process.env.IRS_SUPERUSER_EMAIL,
+    getMessageGateway: () => ({
+      sendUpdatePetitionerCasesMessage: ({
+        applicationContext: appContext,
+        user: userToSendTo,
+      }) => {
+        if (environment.stage === 'local') {
+          updatePetitionerCasesInteractor({
+            applicationContext: appContext,
+            user: userToSendTo,
+          });
+        } else {
+          sendUpdatePetitionerCasesMessage({
+            applicationContext: appContext,
+            user: userToSendTo,
+          });
+        }
+      },
+    }),
     getMessagingClient: () => {
       if (!sqsCache) {
         sqsCache = new SQS({
@@ -1953,6 +1977,7 @@ module.exports = (appContextUser, logger = createLogger()) => {
         updateDeficiencyStatisticInteractor,
         updateDocketEntryMetaInteractor,
         updateOtherStatisticsInteractor,
+        updatePetitionerCasesInteractor,
         updatePetitionerInformationInteractor,
         updatePractitionerUserInteractor,
         updateQcCompleteForTrialInteractor,

web-api/src/notifications/connectLambda.js

@@ -19,7 +19,7 @@ exports.connectLambda = event =>
           endpoint,
         });
 
-      applicationContext.logger.info('Websocket connected', {
+      applicationContext.logger.debug('Websocket connected', {
         requestId: {
           connection: event.requestContext.connectionId,
         },

web-api/src/notifications/disconnectLambda.js

@@ -16,7 +16,7 @@ exports.disconnectLambda = event =>
           connectionId: event.requestContext.connectionId,
         });
 
-      applicationContext.logger.info('Websocket disconnected', {
+      applicationContext.logger.debug('Websocket disconnected', {
         requestId: {
           connection: event.requestContext.connectionId,
         },