fix device-has->user relationship _key

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@jupiterone/graph-netskope",
-  "version": "1.2.8",
+  "version": "1.2.9",
   "description": "A JupiterOne Integration for ingesting data of the Netskope",
   "repository": {
     "type": "git",

src/steps/user/index.ts

@@ -41,31 +41,33 @@ export async function buildDeviceHasUserRelationships({
             const userSchema = toJsonSchema(user);
             logger.warn({ userSchema }, `User doesn't have a unique key`);
           } catch (err) {
-            // pass
+            logger.warn({ err }, 'Failed to extract user schema');
           }
           continue;
         }
         const userEntity = createUserEntity(user);
         if (!jobState.hasKey(userEntity._key)) {
           await jobState.addEntity(userEntity);
         }
-        await jobState.addRelationship(
-          createDirectRelationship({
-            _class: RelationshipClass.HAS,
-            from: deviceEntity,
-            to: userEntity,
-            properties: {
-              lastEvent: user.last_event.event,
-              lastEventStatus: user.last_event.status,
-              lastEventNpaStatus: user.last_event.npa_status,
-              lastEventActor: user.last_event.actor,
-              lastEventOccurredOn: parseTimePropertyValue(
-                user.last_event.timestamp,
-                'ms',
-              ),
-            },
-          }),
-        );
+        const relationship = createDirectRelationship({
+          _class: RelationshipClass.HAS,
+          from: deviceEntity,
+          to: userEntity,
+          properties: {
+            _key: `${deviceEntity._key}|has|${userEntity._key}-${user._id}`,
+            lastEvent: user.last_event.event,
+            lastEventStatus: user.last_event.status,
+            lastEventNpaStatus: user.last_event.npa_status,
+            lastEventActor: user.last_event.actor,
+            lastEventOccurredOn: parseTimePropertyValue(
+              user.last_event.timestamp,
+              'ms',
+            ),
+          },
+        });
+        if (!jobState.hasKey(relationship._key)) {
+          await jobState.addRelationship(relationship);
+        }
       }
     },
   );