RDBC-1018/1019/1023 Fix change tracking metadata aliasing, type-coercion, add per-entity change API

ravendb/documents/session/document_info.py

@@ -44,4 +44,4 @@ def get_new_document_info(cls, document: Dict) -> DocumentInfo:
         if not change_vector or not isinstance(change_vector, str):
             raise ValueError(f"Document {key} must have a Change Vector")
 
-        return cls(key=key, document=document, metadata=metadata, entity=None, change_vector=change_vector)
+        return cls(key=key, document=document, metadata=dict(metadata), entity=None, change_vector=change_vector)

ravendb/documents/session/document_session.py

@@ -802,6 +802,12 @@ def graph_query(self, object_type: type, query: str):  # -> GraphDocumentQuery:
         def what_changed(self) -> Dict[str, List[DocumentsChanges]]:
             return self._session._what_changed()
 
+        def what_changed_for(self, entity: object) -> List[DocumentsChanges]:
+            return self._session._what_changed_for(entity)
+
+        def get_tracked_entities(self) -> Dict[str, dict]:
+            return self._session._get_tracked_entities()
+
         def exists(self, key: str) -> bool:
             if key is None:
                 raise ValueError("Key cannot be None")

ravendb/documents/session/document_session_operations/in_memory_document_session_operations.py

@@ -1183,6 +1183,59 @@ def _what_changed(self) -> Dict[str, List[DocumentsChanges]]:
 
         return changes
 
+    def _what_changed_for(self, entity: object) -> List[DocumentsChanges]:
+        if self._documents_by_entity.get(entity) is None:
+            return []
+        if entity in self._deleted_entities:
+            return [
+                DocumentsChanges(
+                    field_old_value="",
+                    field_new_value="",
+                    change=DocumentsChanges.ChangeType.DOCUMENT_DELETED,
+                )
+            ]
+        doc_info = self._get_document_info(entity)
+        _update_metadata_modifications(doc_info.metadata_instance, doc_info.metadata)
+        new_obj = self.entity_to_json.convert_entity_to_json(entity, doc_info)
+        changes: Dict[str, List[DocumentsChanges]] = {}
+        self._entity_changed(new_obj, doc_info, changes)
+        return [
+            DocumentsChanges(
+                field_old_value=d["old_value"],
+                field_new_value=d["new_value"],
+                change=d["change"],
+                field_name=d["field_name"],
+                field_path=d["field_path"],
+            )
+            for d in changes.get(doc_info.key, [])
+        ]
+
+    def _get_tracked_entities(self) -> Dict[str, dict]:
+        result = {}
+        for entity_result in self._documents_by_entity:
+            doc_info = entity_result.value
+            result[doc_info.key] = {
+                "id": doc_info.key,
+                "entity": entity_result.key,
+                "is_deleted": self.is_deleted(doc_info.key),
+            }
+        for deleted in self._deleted_entities:
+            doc_info = self._documents_by_entity.get(deleted.entity)
+            if doc_info:
+                result[doc_info.key] = {
+                    "id": doc_info.key,
+                    "entity": deleted.entity,
+                    "is_deleted": True,
+                }
+        for key in self._known_missing_ids:
+            if key not in result:
+                result[key] = {
+                    "id": key,
+                    "entity": None,
+                    "is_deleted": True,
+                }
+        return result
+
     def __get_all_entities_changes(self, changes: Dict[str, List[DocumentsChanges]]) -> None:
         for key, value in self._documents_by_id.items():
             _update_metadata_modifications(value.metadata_instance, value.metadata)

ravendb/json/json_operation.py

@@ -82,7 +82,7 @@ def compare_json(
             old_prop = original_json[prop]
 
             if isinstance(new_prop, (int, float, bool, str)):
-                if new_prop == old_prop or JsonOperation.compare_values(old_prop, new_prop):
+                if JsonOperation.compare_values(old_prop, new_prop):
                     continue
                 if changes is None:
                     return True
@@ -193,7 +193,7 @@ def compare_json_array(field_path: str, key: str, old_collection, new_collection
                             DocumentsChanges.ChangeType.ARRAY_VALUE_CHANGED,
                         )
             elif isinstance(new_collection_item, (int, float, bool, str)):
-                if not str(old_collection_item) == str(new_collection_item):
+                if type(old_collection_item) != type(new_collection_item) or old_collection_item != new_collection_item:
                     if changes is not None:
                         JsonOperation.new_change(
                             JsonOperation.add_index_field_path(field_path, position),