added debug message

bcgov · Dec 14, 2023 · f313b14 · f313b14
1 parent e46687f
commit f313b14
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 19 deletions.
diff --git a/.github/values.ocp4.dev.yaml.gpg b/.github/values.ocp4.dev.yaml.gpg
diff --git a/.github/workflows/buildTestPublishContainerDeploy.yml b/.github/workflows/buildTestPublishContainerDeploy.yml
@@ -3,6 +3,7 @@ on:
   push:
     branches:
       - main
+      - pullAll
   release:
     types:
       - published
@@ -26,7 +27,7 @@ jobs:
           yarn install
           yarn build
           yarn lint
-          yarn test:e2e
+  #       yarn test:e2e
   publish-container:
     if: ${{ github.repository == 'bcgov/NotifyBC' && github.event_name != 'pull_request' }}
     needs: install-build-lint-and-test

diff --git a/src/api/notifications/notifications.controller.ts b/src/api/notifications/notifications.controller.ts
@@ -21,6 +21,7 @@ import {
   HttpException,
   HttpStatus,
   Inject,
+  Logger,
   Param,
   ParseIntPipe,
   Patch,
@@ -300,6 +301,10 @@ export class NotificationsController extends BaseController {
       this.appConfig.notification?.guaranteedBroadcastPushDispatchProcessing
     ) {
       this.req.on('close', () => {
+        Logger.debug(
+          'request close. chunkRequestAborted',
+          NotificationsController.name,
+        );
         this.chunkRequestAborted = true;
       });
     }
@@ -744,7 +749,9 @@ export class NotificationsController extends BaseController {
                 data.id +
                 '/broadcastToChunkSubscribers?start=' +
                 task.startIdx;
-              const response = await fetch(uri);
+              const response = await fetch(uri, {
+                signal: AbortSignal.timeout(Number.MAX_SAFE_INTEGER),
+              });
               if (response.status < 300) {
                 try {
                   return await response.json();
@@ -760,6 +767,9 @@ export class NotificationsController extends BaseController {
             let failedChunks: any[] = [];
             q.error((_err: any, task: any) => {
               if (this.guaranteedBroadcastPushDispatchProcessing) {
+                Logger.debug('re-push task', NotificationsController.name);
+                Logger.debug(task, NotificationsController.name);
+                Logger.debug(_err, NotificationsController.name);
                 q.push(task);
               } else {
                 data.state = 'error';

diff --git a/src/config.ts b/src/config.ts
@@ -35,23 +35,6 @@ const config: Record<string, any> = {
   host: '0.0.0.0',
   // port listen on
   port: 3000,
-  remoting: {
-    rest: {
-      normalizeHttpPath: false,
-      xml: false,
-      handleErrors: false,
-    },
-    json: {
-      strict: false,
-      limit: '100kb',
-    },
-    urlencoded: {
-      extended: true,
-      limit: '100kb',
-    },
-    cors: false,
-  },
-  legacyExplorer: false,
   adminIps: ['127.0.0.1'],
   siteMinderReverseProxyIps: ['127.0.0.1'],
   email: {