Improve handling of null software and error handling

lansweeper/aws/integration-lambda/discovery_mutation_helper.js

@@ -47,8 +47,10 @@ class DiscoveryMutationHelper {
       const ci = this.createCi(asset, mappedProduct);
       mappedProduct.configurationItems.push(ci);
     } catch (e) {
-      console.error(`Error processing: ${key}`);
-      throw new LoggedError(e);
+      const msg = `Error processing: ${key}`;
+      console.error('%s.\nAsset:\n%j', msg, asset);
+      console.info(e);
+      throw new LoggedError(msg);
     }
   }
 
@@ -159,11 +161,12 @@ class DiscoveryMutationHelper {
   }
 
   mapSoftware(softwares) {
-    return this.mapSoftwareName(softwares.map(s => s.name));
+    return this.mapSoftwareName(softwares.map(s => s && s.name));
   }
 
   mapSoftwareName(softwareNames) {
     return softwareNames
+      .filter(n => !!n)
       .map(n => this.lansweeperHelper.cleanupName(n))
       .map(n => this.referenceData.softwareCis.get(n))
       .filter(id => !!id);

lansweeper/aws/integration-lambda/lansweeper_integration.js

@@ -148,7 +148,9 @@ class LansweeperIntegration {
             // no need to keep process going
             throw e;
           }
-          console.error(e);
+          if (!(e instanceof LoggedError)) {
+            console.error(e);
+          }
           errors.push(`Unable to upload assets to 4me.`);
         }
       }

lansweeper/aws/integration-lambda/tests/discovery_mutation_helper.test.js

@@ -3,6 +3,7 @@
 const DiscoveryMutationHelper = require('../discovery_mutation_helper');
 const assetArray = require('./assets/asset_array.json');
 const LansweeperHelper = require('../lansweeper_helper');
+const LoggedError = require('../../../../library/helpers/errors/logged_error');
 const referenceData = {
   softwareCis: new Map(),
   users: new Map(),
@@ -258,3 +259,28 @@ it('maps stateNames', () => {
 
   expect(helper.mapState('foo')).toEqual('installed');
 });
+
+it('handles null software elements', () => {
+  const helper = new DiscoveryMutationHelper(referenceData, false, []);
+  const asset = assetArray[0];
+  asset.softwares = [undefined];
+
+  expect(() => helper.toDiscoveryUploadInput('a', [asset])).not.toThrow();
+});
+
+it('logs errors', () => {
+  const helper = new DiscoveryMutationHelper(null, false, []);
+  const asset = assetArray[0];
+  asset.softwares = [undefined];
+  const consoleErrorSpy = jest.spyOn(console, 'error');
+  const infoCalls = [];
+  const consoleInfoSpy = jest.spyOn(console, 'info').mockImplementation((a) => infoCalls.push(a));
+
+  expect(() => helper.toDiscoveryUploadInput('a', [asset])).toThrow(LoggedError);
+
+  expect(consoleErrorSpy).toHaveBeenCalledWith('%s.\nAsset:\n%j',
+                                               'Error processing: MT1Bc3NldC02023hZWZiZi1mMjYzLTRkOGQtOGMzOC04OGRhZTQ2MTA3NWN=',
+                                               asset);
+  expect(consoleInfoSpy).toHaveBeenCalled();
+  expect(infoCalls[0].message).toEqual("Cannot read properties of null (reading 'users')");
+});

lansweeper/aws/integration-lambda/tests/lansweeper_integration.test.js

@@ -19,6 +19,7 @@ const TimeHelper = require('../../../../library/helpers/time_helper');
 const LansweeperAuthorizationError = require('../errors/lansweeper_authorization_error');
 const Js4meAuthorizationError = require('../../../../library/helpers/errors/js_4me_authorization_error');
 const LansweeperGraphQLError = require('../errors/lansweeper_graphql_error');
+const LoggedError = require('../../../../library/helpers/errors/logged_error');
 jest.mock('../../../../library/helpers/time_helper');
 
 describe('processSite', () => {
@@ -118,6 +119,76 @@ describe('processSite', () => {
     expect(result).toEqual({uploadCount: uploadCount});
   });
 
+  it('handles logged error preparing upload', async () => {
+    const siteId = 'abddda';
+    TimeHelper.mockImplementation(() => ({
+      getMsSinceEpoch: () => Date.UTC(2021, 8, 29, 7, 12, 33),
+    }));
+
+    DiscoveryMutationHelper.mockImplementation((referenceData, generateLabels) => {
+      expect(generateLabels).toBe(false);
+      return ({
+        toDiscoveryUploadInput: () => { throw new LoggedError('broken') },
+      });
+    });
+
+    LansweeperClient.mockImplementationOnce(() => ({
+      getSiteName: async (id) => {
+        expect(id).toBe(siteId);
+        return 'site 2';
+      },
+      getAssetsPaged: async (id, cutOffDate, handler) => {
+        expect(id).toBe(siteId);
+        return await handler(assetArray);
+      },
+    }));
+
+    const consoleErrorSpy = jest.spyOn(console, 'error');
+    const integration = new LansweeperIntegration('client id',
+                                                  'secret',
+                                                  'refresh token',
+                                                  null);
+
+    const result = await integration.processSite(siteId, false, false, installations[0], installations, null);
+    expect(result).toEqual({errors: ['Unable to upload assets to 4me.']});
+    expect(consoleErrorSpy).not.toHaveBeenCalled();
+  });
+
+  it('handles non-logged error preparing upload', async () => {
+    const siteId = 'sadsa';
+    TimeHelper.mockImplementation(() => ({
+      getMsSinceEpoch: () => Date.UTC(2021, 8, 29, 7, 12, 33),
+    }));
+
+    DiscoveryMutationHelper.mockImplementation((referenceData, generateLabels) => {
+      expect(generateLabels).toBe(false);
+      return ({
+        toDiscoveryUploadInput: () => { throw new Error('broken') },
+      });
+    });
+
+    LansweeperClient.mockImplementationOnce(() => ({
+      getSiteName: async (id) => {
+        expect(id).toBe(siteId);
+        return 'site 2';
+      },
+      getAssetsPaged: async (id, cutOffDate, handler) => {
+        expect(id).toBe(siteId);
+        return await handler(assetArray);
+      },
+    }));
+    const consoleErrorSpy = jest.spyOn(console, 'error');
+
+    const integration = new LansweeperIntegration('client id',
+                                                  'secret',
+                                                  'refresh token',
+                                                  null);
+
+    const result = await integration.processSite(siteId, false, false, installations[0], installations, null);
+    expect(result).toEqual({errors: ['Unable to upload assets to 4me.']});
+    expect(consoleErrorSpy).toHaveBeenCalled();
+  });
+
   it('handles error on first page upload', async () => {
     const siteId = 'abddda';
     TimeHelper.mockImplementation(() => ({