graph, store: Do not panic in Entity::try_make on uninterned keys

Author: lutter

graph/src/data/store/mod.rs

@@ -728,14 +728,15 @@ impl Entity {
         Ok(Entity(obj))
     }
 
-    pub fn try_make<E, I: TryIntoEntityIterator<E>>(
+    pub fn try_make<E: std::error::Error + Send + Sync + 'static, I: TryIntoEntityIterator<E>>(
         pool: Arc<AtomPool>,
         iter: I,
-    ) -> Result<Entity, E> {
+    ) -> Result<Entity, Error> {
         let mut obj = Object::new(pool);
         for pair in iter {
             let (key, value) = pair?;
-            obj.insert(key, value).expect("key is in AtomPool");
+            obj.insert(key, value)
+                .map_err(|e| anyhow!("unknown attribute {}", e.not_interned()))?;
         }
         Ok(Entity(obj))
     }

graph/src/schema/input_schema.rs

@@ -287,7 +287,13 @@ impl Inner {
         Entity::make(self.pool.clone(), iter)
     }
 
-    pub fn try_make_entity<E, I: TryIntoEntityIterator<E>>(&self, iter: I) -> Result<Entity, E> {
+    pub fn try_make_entity<
+        E: std::error::Error + Send + Sync + 'static,
+        I: TryIntoEntityIterator<E>,
+    >(
+        &self,
+        iter: I,
+    ) -> Result<Entity, Error> {
         Entity::try_make(self.pool.clone(), iter)
     }
 }

store/postgres/src/relational_queries.rs

@@ -254,7 +254,7 @@ impl FromEntityData for Entity {
         schema: &InputSchema,
         iter: I,
     ) -> Result<Self, StoreError> {
-        schema.try_make_entity(iter)
+        schema.try_make_entity(iter).map_err(StoreError::from)
     }
 }