diff --git a/src/main/java/org/opentripplanner/middleware/models/MonitoredTrip.java b/src/main/java/org/opentripplanner/middleware/models/MonitoredTrip.java
index e38c814d..c8e8002c 100644
--- a/src/main/java/org/opentripplanner/middleware/models/MonitoredTrip.java
+++ b/src/main/java/org/opentripplanner/middleware/models/MonitoredTrip.java
@@ -524,7 +524,7 @@ public TripUsers(MobilityProfileLite primary, RelatedUser companion, List<Relate
      * Trip created by primary user.
      */
     public boolean ownedByPrimary() {
-        return primary != null && primary.userId.equalsIgnoreCase(userId);
+        return primary != null && userId.equalsIgnoreCase(primary.userId);
     }
 
     /**
@@ -532,6 +532,9 @@ public boolean ownedByPrimary() {
      */
     public boolean ownedByCompanion() {
         OtpUser tripOwner = Persistence.otpUsers.getById(userId);
-        return tripOwner != null && companion != null && companion.email.equalsIgnoreCase(tripOwner.email);
+        return tripOwner != null &&
+            tripOwner.email != null &&
+            companion != null &&
+            tripOwner.email.equalsIgnoreCase(companion.email);
     }
 }
diff --git a/src/test/java/org/opentripplanner/middleware/models/LegTransitionNotificationTest.java b/src/test/java/org/opentripplanner/middleware/models/LegTransitionNotificationTest.java
index 8d96ee71..e9154288 100644
--- a/src/test/java/org/opentripplanner/middleware/models/LegTransitionNotificationTest.java
+++ b/src/test/java/org/opentripplanner/middleware/models/LegTransitionNotificationTest.java
@@ -2,6 +2,7 @@
 
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.Arguments;
 import org.junit.jupiter.params.provider.MethodSource;
@@ -123,4 +124,18 @@ private static Stream<Arguments> createLegTransitionNotifyUsersTestCases() {
             Arguments.of(companion.id, Set.of(primary, observer))
         );
     }
+
+    @Test
+    void testLegTransitionNotifyUsersIncompleteData() {
+        MonitoredTrip trip = new MonitoredTrip();
+        // Set as owner an existing user that is not the primary or the companion user from the setup method.
+        trip.userId = observer.id;
+        trip.primary = new MobilityProfileLite();
+        trip.companion = new RelatedUser();
+        trip.observers.add(new RelatedUser());
+
+        Set<OtpUser> users = LegTransitionNotification.getLegTransitionNotifyUsers(trip);
+        assertNotNull(users);
+        assertTrue(users.isEmpty());
+    }
 }
\ No newline at end of file